调试

agc_main.py

@@ -22,43 +22,41 @@ def video_start(user_data):
         if mark:
             returned_usernames_today.add(mark)
 
-data = Material.feishu_list()
-video_start(data[0])
-#
-# # 定义定时任务
-# def video_task():
-#     print("开始执行生成视频脚.")
-#     data = Material.feishu_list()
-#     # 创建一个线程池
-#     with concurrent.futures.ThreadPoolExecutor() as executor:
-#         futures = [executor.submit(video_start, user_data) for user_data in data]
-#         # 等待所有任务执行完成
-#         for future in concurrent.futures.as_completed(futures):
-#             # 获取每个任务的执行结果
-#             result = future.result()
-#             print("处理结果:", result)
-#     print("执行生成视频脚结束")
-# schedule.every(10).minutes.do(video_task)
-#
-# # 每天0点清空集合
-# schedule.every().day.at("00:00").do(lambda: returned_usernames_today.clear())
-#
-#
-# def job_feishu_bot():
-#     name_list = Material.feishu_name()
-#     count_list = sqlHelp.get_count_list(name_list)
-#     Feishu.bot('recommend', 'AGC视频', f'{"".join(count_list)}', 'all')
-#     print("机器人通知完成")
-#
-#
-# # 每天下午1:30执行任务
-# schedule.every().day.at("15:00").do(job_feishu_bot)
-#
-# while True:
-#     schedule.run_pending()
-#     time.sleep(1)
-#
-# # list = Material.feishu_list()
-# # AgcVidoe.video_stitching(list)
-# # print(list)
-#
+
+# 定义定时任务
+def video_task():
+    print("开始执行生成视频脚.")
+    data = Material.feishu_list()
+    # 创建一个线程池
+    with concurrent.futures.ThreadPoolExecutor() as executor:
+        futures = [executor.submit(video_start, user_data) for user_data in data]
+        # 等待所有任务执行完成
+        for future in concurrent.futures.as_completed(futures):
+            # 获取每个任务的执行结果
+            result = future.result()
+            print("处理结果:", result)
+    print("执行生成视频脚结束")
+schedule.every(10).minutes.do(video_task)
+
+# 每天0点清空集合
+schedule.every().day.at("00:00").do(lambda: returned_usernames_today.clear())
+
+
+def job_feishu_bot():
+    name_list = Material.feishu_name()
+    count_list = sqlHelp.get_count_list(name_list)
+    Feishu.bot('recommend', 'AGC视频', f'{"".join(count_list)}', 'all')
+    print("机器人通知完成")
+
+
+# 每天下午1:30执行任务
+schedule.every().day.at("15:00").do(job_feishu_bot)
+
+while True:
+    schedule.run_pending()
+    time.sleep(1)
+
+# list = Material.feishu_list()
+# AgcVidoe.video_stitching(list)
+# print(list)
+

video_agc/agc_video_method.py

@@ -218,7 +218,6 @@ class AgcVidoe():
         formatted_time = current_time.strftime("%Y-%m-%d")
         for j in video_files:
             insert_sql = f"""INSERT INTO agc_video_deposit (audio, video_id, account_id, oss_object_key, time, platform, mark) values ('{uid}', '{j[0]}', '{j[1]}', '{j[2]}', '{formatted_time}', '{platform}', '{mark}')"""
-            print("insert_sql")
             MysqlHelper.update_values(
                 sql=insert_sql,
                 env="prod",