调试

agc_job_main.py

@@ -60,7 +60,7 @@ schedule.every().day.at("00:20").do(video_start, "bk")
 
 
 if __name__ == "__main__":
-    video_start("bk")
+    video_start("cg")
     while True:
         try:
             schedule.run_pending()

video_agc/agc_video.py

@@ -336,7 +336,7 @@ class AGC():
             video_call = data["video_call"]  # 脚本sheet
             list_data = Material.get_allbk_data(feishu_id, video_call)
             if len(list_data) == 0:
-                # Feishu.bot('recommend', 'AGC完成通知', f'爆款任务数为0,不做拼接', mark, mark_name)
+                Feishu.bot('recommend', 'AGC完成通知', f'{platform}任务数为0,不做拼接', mark, mark_name)
                 return mark
         elif platform == "常规":
             pq_ids = data["pq_id"]# 账号ID
@@ -346,7 +346,7 @@ class AGC():
             video_call = data["video_call"]  # 脚本sheet
             video_count = data["video_count"]
             if int(video_count) == 0:
-                # Feishu.bot('recommend', 'AGC完成通知', f'常规任务数为{video_count},不做拼接', mark, mark_name)
+                Feishu.bot('recommend', 'AGC完成通知', f'{platform}任务数为{video_count},不做拼接', mark, mark_name)
                 return mark
             data_list, videos_mark = Material.get_all_data(feishu_id, video_call, mark)
             list_data = cls.get_unique_uid_data(data_list, int(video_count))
@@ -358,11 +358,11 @@ class AGC():
             video_call = data["video_call"]
             video_count = data["video_count"]
             if int(video_count) == 0:
-                # Feishu.bot('recommend', 'AGC完成通知', f'跟随任务数为{video_count},不做拼接', mark, mark_name)
+                Feishu.bot('recommend', 'AGC完成通知', f'{platform}任务数为{video_count},不做拼接', mark, mark_name)
                 return mark
             data_list, videos = Material.get_all_data(feishu_id, video_call, mark)
             list_data = cls.get_unique_uid_data(data_list, int(video_count))
-        count = 20
+        count = 0
         while True:
             # 清空所有文件
             cls.clear_mp4_files(mark)
@@ -397,11 +397,19 @@ class AGC():
                     # 创建临时字幕文件
                     cls.create_subtitle_file(srt_new, s_path)
                     Common.logger("video").info(f"S{mark}的{platform}渠道SRT 文件目录创建成功")
-                # 获取音频
-                audio_video = PQ.get_audio_url(uid)
-                Common.logger("video").info(f"{mark}的{platform}渠道获音频成功")
-                audio_duration = cls.get_audio_duration(audio_video)
-                Common.logger("video").info(f"{mark}的{platform}渠道获取需要拼接的音频秒数为:{audio_duration}")
+                try:
+                    # 获取音频
+                    audio_video = PQ.get_audio_url(uid)
+                    Common.logger("video").info(f"{mark}的{platform}渠道获音频成功")
+                    audio_duration = cls.get_audio_duration(audio_video)
+                    Common.logger("video").info(f"{mark}的{platform}渠道获取需要拼接的音频秒数为:{audio_duration}")
+                except Exception as e:
+                    count += 1
+                    # 清空所有mp4数据
+                    cls.clear_mp4_files(mark)
+                    Feishu.bot('recommend', 'AGC异常通知', f'{platform}任务下，{uid}音频格式填写该任务跳过，请关注', mark, mark_name)
+
+                    continue
                 if platform != "常规":
                     if platform == "爆款":
                         videos = str(d_list['video'])
@@ -487,7 +495,7 @@ class AGC():
                     time.sleep(random_wait_time)
                     Feishu.update_values("LAn9so7E0hxRYht2UMEcK5wpnMj", sheet, "A2:Z2", values)
             except Exception as e:
-                Common.logger("bk_video").warning(f"{mark}的视频拼接失败:{e}\n")
+                Common.logger("video").warning(f"{mark}的视频拼接失败:{e}\n")
                 # 清空所有mp4数据
                 cls.clear_mp4_files(mark)
                 continue