Merge branch 'feature/2025-11-21-fix-publish-video' of luojunhui/LongArticlesJob into master

cold_start/publish/publish_video_to_pq_for_audit.py

@@ -228,51 +228,61 @@ class PublishVideosForAudit(object):
         """
         video_id = video_obj['audit_video_id']
         response = pq_functions.getPQVideoListDetail([video_id])
-        audit_status = response.get("data")[0].get("auditStatus")
-        # 请求成功
-        if audit_status == const.PQ_AUDIT_SUCCESS_STATUS:
-            # 更新小程序标题字段
-            mini_program_title_flag = self.update_mini_program_title(video_id)
-            if mini_program_title_flag:
-                # 处理成功，修改审核状态为1
-                affected_rows = self.update_audit_status(
-                    video_id=video_id,
-                    ori_audit_status=const.VIDEO_AUDIT_PROCESSING_STATUS,
-                    new_audit_status=const.VIDEO_AUDIT_SUCCESS_STATUS
-                )
-                # 将视频存储到任务队列
-                self.insert_into_task_queue(video_obj)
-
-                # 将视频存储到 aigc 表
-                aigc.insert_crawler_relation_to_aigc_system(
-                    relation_list=[
-                        {
-                            "videoPoolTraceId": video_obj['content_trace_id'],
-                            "channelContentId": str(video_id),
-                            "platform": video_obj['platform'],
-                        }
-                    ]
-                )
-            else:
-                # 修改小程序标题失败，修改审核状态为4
-                affected_rows = self.update_audit_status(
-                    video_id=video_id,
-                    ori_audit_status=const.VIDEO_AUDIT_PROCESSING_STATUS,
-                    new_audit_status=const.VIDEO_TITLE_GENERATE_FAIL_STATUS
-                )
-        elif audit_status in {const.PQ_AUDIT_SELF_VISIBLE_STATUS, const.PQ_AUDIT_FAIL_STATUS}:
-            # 视频审核失败，修改审核状态为2
+        response_data = response.get("data")
+        if not  response_data:
             affected_rows = self.update_audit_status(
                 video_id=video_id,
                 ori_audit_status=const.VIDEO_AUDIT_PROCESSING_STATUS,
                 new_audit_status=const.VIDEO_AUDIT_FAIL_STATUS
             )
-        elif audit_status == const.PQ_AUDIT_PROCESSING_STATUS:
-            # 视频正在审核中，不做处理
-            affected_rows = 0
+            audit_status = None
         else:
-            # 其他情况，暂时不做处理
-            affected_rows = 0
+            audit_status = response.get("data")[0].get("auditStatus")
+            # 请求成功
+            if audit_status == const.PQ_AUDIT_SUCCESS_STATUS:
+                # 更新小程序标题字段
+                mini_program_title_flag = self.update_mini_program_title(video_id)
+                if mini_program_title_flag:
+                    # 处理成功，修改审核状态为1
+                    affected_rows = self.update_audit_status(
+                        video_id=video_id,
+                        ori_audit_status=const.VIDEO_AUDIT_PROCESSING_STATUS,
+                        new_audit_status=const.VIDEO_AUDIT_SUCCESS_STATUS
+                    )
+                    # 将视频存储到任务队列
+                    self.insert_into_task_queue(video_obj)
+
+                    # 将视频存储到 aigc 表
+                    aigc.insert_crawler_relation_to_aigc_system(
+                        relation_list=[
+                            {
+                                "videoPoolTraceId": video_obj['content_trace_id'],
+                                "channelContentId": str(video_id),
+                                "platform": video_obj['platform'],
+                            }
+                        ]
+                    )
+                else:
+                    # 修改小程序标题失败，修改审核状态为4
+                    affected_rows = self.update_audit_status(
+                        video_id=video_id,
+                        ori_audit_status=const.VIDEO_AUDIT_PROCESSING_STATUS,
+                        new_audit_status=const.VIDEO_TITLE_GENERATE_FAIL_STATUS
+                    )
+            elif audit_status in {const.PQ_AUDIT_SELF_VISIBLE_STATUS, const.PQ_AUDIT_FAIL_STATUS}:
+                # 视频审核失败，修改审核状态为2
+                affected_rows = self.update_audit_status(
+                    video_id=video_id,
+                    ori_audit_status=const.VIDEO_AUDIT_PROCESSING_STATUS,
+                    new_audit_status=const.VIDEO_AUDIT_FAIL_STATUS
+                )
+            elif audit_status == const.PQ_AUDIT_PROCESSING_STATUS:
+                # 视频正在审核中，不做处理
+                affected_rows = 0
+            else:
+                # 其他情况，暂时不做处理
+                affected_rows = 0
+
         result = {
             "affected_rows": affected_rows,
             "video_id": video_id,