调试

video_agc/agc_video.py

@@ -365,12 +365,15 @@ class AGC():
             list_data = cls.get_unique_uid_data(data_list, int(video_count))
         count = 0
         pj_count = 0
+        error_count = 0
         while True:
             # 清空所有文件
             cls.clear_mp4_files(mark)
             s_path, v_path, video_path_url, v_oss_path = cls.create_folders(mark)
+
             if pj_count == 10:
                 Feishu.bot('recommend', 'AGC拼接画面不足通知', f'视频画面不足，请即使补充！！', mark, mark_name)
+                return
             if count == len(list_data):
                 break
         # for d_list in list_data:
@@ -387,16 +390,11 @@ class AGC():
                 # else:
                 srt_new = SRT.getSrt(int(uid))
                 Common.logger("video").info(f"S{mark}的{platform}渠道音频ID")
-
+                if error_count == 5:
+                    Feishu.bot('recommend', 'AGC异常通知', f'音频id为{uid},任务处理异常5次，该任务跳过，请检查格式！', mark, mark_name)
+                    count += 1
+                    continue
                 if srt_new:
-                    current_time = datetime.now()
-                    formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
-                    values = [[mark, str(uid), srt_new, formatted_time]]
-                    random_wait_time = random.uniform(0.5, 2.5)
-                    time.sleep(random_wait_time)
-                    Feishu.insert_columns("IbVVsKCpbhxhSJtwYOUc8S1jnWb", "jd9qD9", "ROWS", 1, 2)
-                    time.sleep(random_wait_time)
-                    Feishu.update_values("IbVVsKCpbhxhSJtwYOUc8S1jnWb", "jd9qD9", "A2:Z2", values)
                     # 创建临时字幕文件
                     cls.create_subtitle_file(srt_new, s_path)
                     Common.logger("video").info(f"S{mark}的{platform}渠道SRT 文件目录创建成功")
@@ -420,7 +418,6 @@ class AGC():
                         else:
                             videos = [str(videos)]
                     video_id = random.choice(videos)
-
                     video_url = PQ.get_audio_url(video_id)
                     download_video = Oss.download_url(video_url, video_path_url, str(video_id))
                     if download_video:
@@ -498,7 +495,18 @@ class AGC():
                     random_wait_time = random.uniform(0.5, 2.5)
                     time.sleep(random_wait_time)
                     Feishu.update_values("LAn9so7E0hxRYht2UMEcK5wpnMj", sheet, "A2:Z2", values)
+                    if srt_new:
+                        current_time = datetime.now()
+                        formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
+                        values = [[mark, str(uid), srt_new, formatted_time]]
+                        random_wait_time = random.uniform(0.5, 2.5)
+                        time.sleep(random_wait_time)
+                        Feishu.insert_columns("IbVVsKCpbhxhSJtwYOUc8S1jnWb", "jd9qD9", "ROWS", 1, 2)
+                        time.sleep(random_wait_time)
+                        Feishu.update_values("IbVVsKCpbhxhSJtwYOUc8S1jnWb", "jd9qD9", "A2:Z2", values)
+                    error_count = 0
             except Exception as e:
+                error_count += 1
                 Common.logger("video").warning(f"{mark}的视频拼接失败:{e}\n")
                 # 清空所有mp4数据
                 cls.clear_mp4_files(mark)