|
|
@@ -622,16 +622,16 @@ class VideoProcessor:
|
|
|
return
|
|
|
task = json.loads(data)
|
|
|
try:
|
|
|
- # limit_number = task["limit_number"]
|
|
|
- # if limit_number:
|
|
|
- # task_mark = task["task_mark"]
|
|
|
- # makr_count = sqlCollect.get_mark_count(task_mark)
|
|
|
- # if int(limit_number) <= int(makr_count[0][0]):
|
|
|
- # AliyunLogger.logging((task["channel_id"]), name, task["channel_url"], '', f"{task_mark}标识任务每日指定条数已足够，指定条数{limit_number},实际生成条数{int(makr_count[0][0])}",
|
|
|
- # "1111")
|
|
|
- # logger.info(f"[+] {task_mark}标识任务每日指定条数已足够，指定条数{limit_number},实际生成条数{int(makr_count[0][0])}")
|
|
|
- #
|
|
|
- # return
|
|
|
+ limit_number = task["limit_number"]
|
|
|
+ if limit_number:
|
|
|
+ task_mark = task["task_mark"]
|
|
|
+ makr_count = sqlCollect.get_mark_count(task_mark)
|
|
|
+ if int(limit_number) <= int(makr_count[0][0]):
|
|
|
+ AliyunLogger.logging((task["channel_id"]), name, task["channel_url"], '', f"{task_mark}标识任务每日指定条数已足够，指定条数{limit_number},实际生成条数{int(makr_count[0][0])}",
|
|
|
+ "1111")
|
|
|
+ logger.info(f"[+] {task_mark}标识任务每日指定条数已足够，指定条数{limit_number},实际生成条数{int(makr_count[0][0])}")
|
|
|
+
|
|
|
+ return
|
|
|
if mark == 'dy-pl-gjc' and task['channel_id'] == '抖音搜索':
|
|
|
mark_count = 'dyss-count'
|
|
|
count = get_first_value_with_prefix(mark_count)
|
