Merge branch '2024-11-01-luojunhui-do-not-process-exit-article' of Server/title_with_video into 2024-09-23newDbTasks

server/api/response.py

@@ -270,6 +270,12 @@ class Response(object):
                     "traceId": self.trace_id,
                     "miniprogramList": card_list
                 }
+            case 97:
+                return {
+                    "traceId": self.trace_id,
+                    "code": 97,
+                    "error": "该文章已经退场or晋级， 不再冷启处理"
+                }
             case 99:
                 return {
                     "traceId": self.trace_id,

tasks/history_task.py

@@ -16,6 +16,7 @@ class historyContentIdTask(object):
     处理已经匹配过小程序的文章
     """
     TASK_PROCESSING_STATUS = 101
+    EXIT_STATUS = 97
     TASK_INIT_STATUS = 0
     TASK_PUBLISHED_STATUS = 4
 
@@ -233,6 +234,29 @@ class historyContentIdTask(object):
             )
         )
 
+    async def check_title_whether_exit(self, content_id):
+        """
+        校验文章是标题是否晋升 or 退场
+        :return:
+        """
+        UP_LEVEL_STATUS = 1
+        TITLE_EXIT_STATUS = -1
+        sql = f"""
+            SELECT lat.article_title, cstp.status
+            FROM long_articles_text lat
+            JOIN cold_start_title_pool cstp ON lat.article_title = cstp.title
+            WHERE lat.content_id = '{content_id}';
+        """
+        result = await self.mysql_client.async_select(sql)
+        if result:
+            status = result[0][1]
+            if status in {UP_LEVEL_STATUS, TITLE_EXIT_STATUS}:
+                return True
+            else:
+                return False
+        else:
+            return False
+
     async def process_task(self, params):
         """
         异步执行
@@ -242,6 +266,18 @@ class historyContentIdTask(object):
         content_id = params['content_id']
         trace_id = params['trace_id']
         flow_pool_level = params['flow_pool_level']
+        if flow_pool_level == "autoArticlePoolLevel4":
+            exit_status = await self.check_title_whether_exit(content_id)
+            if exit_status:
+                # 修改状态为退出状态
+                affected_rows = await self.update_content_status(
+                    trace_id=trace_id,
+                    new_content_status=self.EXIT_STATUS,
+                    ori_content_status=self.TASK_INIT_STATUS
+                )
+                if affected_rows == 0:
+                    print("修改行数为 0，多个进程抢占同一个 task， 抢占失败，进程退出")
+                    return
         gh_id = params['gh_id']
         process_times = params['process_times']
         download_videos = await self.get_video_list(content_id=content_id)