bugfix

app/domains/monitor_tasks/auto_reply_cards_monitor/_mapper.py

@@ -220,9 +220,11 @@ class AutoReplyCardsMonitorMapper(AutoReplyCardsMonitorConst):
         query = """
             SELECT task_id, position, task_result
             FROM cooperate_auto_reply_detail
-            WHERE cover_status = %s;
+            WHERE cover_status IN (%s, %s);
         """
-        return await self.pool.async_fetch(query=query, params=(self.FAIL_STATUS,))
+        return await self.pool.async_fetch(
+            query=query, params=(self.CoverStatus.INIT, self.CoverStatus.FAILED)
+        )
 
     # 保存封面至封面表
     async def save_cover(self, cover_id, root_source_id, oss_path):

app/domains/monitor_tasks/auto_reply_cards_monitor/entrance.py

@@ -42,7 +42,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
         )
 
         mini_program = xml_obj.get("mini_program", "")
-        need_cover = mini_program == "票圈视频"
+        need_cover = mini_program in ("票圈视频", "票圈 l 3亿人喜欢的视频平台")
 
         # Phase 1: 直接落库
         query = """
@@ -71,7 +71,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorConst):
         )
         await self.mapper.store_extract_result(query, insert_row)
 
-        # Phase 2: 仅票圈视频下载封面
+        # Phase 2: 票圈视频/票圈3亿人 下载封面
         if need_cover:
             cover_ok = await self._try_download_cover(task_id, index, xml_obj)
             return cover_ok