2024-0627-处理mysql问题

applications/deal/get_done_content_deal.py

@@ -68,34 +68,19 @@ class ProcessDeal2(object):
                 trace_id, content_status = item
                 if content_status == 2:
                     return trace_id
+                elif content_status == 3:
+                    update_sql = f"""
+                    UPDATE {db_article}
+                    SET content_status = 3
+                    WHERE trace_id = %s;
+                    """
+                    await self.mysql_client.async_insert(update_sql, trace_id)
                 else:
                     continue
             return None
         else:
             return None
 
-    async def judge_content_processing(self, content_id):
-        """
-        判断该content_id是否在处理中
-        :param content_id:
-        :return:
-        """
-        select_sql = f"""
-                       SELECT trace_id, content_status
-                       FROM {db_article}
-                       WHERE content_id = '{content_id}'
-                       ORDER BY id DESC;
-                   """
-        result = await self.mysql_client.async_select(select_sql)
-        if result:
-            for item in result:
-                trace_id, content_status = item
-                if content_status == 1:
-                    return False
-            return True
-        else:
-            return True
-
     async def insert_history_contents_videos(self, history_trace_id, params):
         """
         插入历史视频id

applications/schedule/process_schedule.py

@@ -202,7 +202,12 @@ async def recall_videos(trace_id, mysql_client):
             "traceId": trace_id,
             "miniprogramList": L
         }
-
+    elif content_status == 3:
+        result = {
+            "traceId": trace_id,
+            "code": 0,
+            "error": "匹配失败，检查原因"
+        }
     else:
         result = {
             "traceId": trace_id,