2024-06-13

异步定时任务

applications/schedule/process_schedule.py

@@ -136,21 +136,28 @@ async def recall_videos(trace_id, mysql_client):
     :return:
     """
     select_sql = f"""
-        SELECT recall_video_id1, recall_video_id2, recall_video_id3, kimi_title, content_status
+        SELECT recall_video_id1, recall_video_id2, recall_video_id3, kimi_title, content_status, process_times
         FROM {db_article}
         WHERE trace_id = '{trace_id}';
     """
     info_tuple = await mysql_client.async_select(select_sql)
-    vid1, vid2, vid3, kimi_title, content_status = info_tuple[0]
+    vid1, vid2, vid3, kimi_title, content_status, process_times = info_tuple[0]
     vid_list = [vid1, vid2, vid3]
     unEmptyList = [i for i in vid_list if i]
     L = []
     if content_status == 0:
-        result = {
-            "traceId": trace_id,
-            "code": 0,
-            "Message": "该请求还没处理"
-        }
+        if process_times > 5:
+            result = {
+                "traceId": trace_id,
+                "code": 0,
+                "Message": "匹配失败，检查原因"
+            }
+        else:
+            result = {
+                "traceId": trace_id,
+                "code": 0,
+                "Message": "该请求还没处理"
+            }
     elif content_status == 1:
         result = {
             "traceId": trace_id,