zhangyong 1 rok pred
rodič
commit
8f8d28b6cb
1 zmenil súbory, kde vykonal 44 pridanie a 42 odobranie
  1. 44 42
      agc_main.py

+ 44 - 42
agc_main.py

@@ -23,48 +23,50 @@ def video_start(user_data):
         print(f"返回用户名{mark}")
         if mark:
             Common.logger("video").info(f"返回用户名{mark}")
-            returned_usernames_today.append(returned_usernames_today)
-
-
-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("机器人通知完成")
-
-def clear_returned_usernames():
-    returned_usernames_today.clear()
-    print("returned_usernames_today 已清空")
-
-# 定义定时任务
-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("执行生成视频脚结束")
-
-# 每天0点10清空集合
-schedule.every().day.at("00:10").do(clear_returned_usernames)
-
-#每10分钟执行次脚本
-schedule.every(10).minutes.do(video_task)
-
-
-
-
-# 每天下午1:30执行任务
-schedule.every().day.at("15:00").do(job_feishu_bot)
-
-while True:
-    schedule.run_pending()
-    time.sleep(1)
+            returned_usernames_today.append(user_data_mark)
+
+name_list = Material.feishu_list()
+video_start(name_list[0])
+
+# 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("机器人通知完成")
+#
+# def clear_returned_usernames():
+#     returned_usernames_today.clear()
+#     print("returned_usernames_today 已清空")
+#
+# # 定义定时任务
+# 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("执行生成视频脚结束")
+#
+# # 每天0点10清空集合
+# schedule.every().day.at("00:10").do(clear_returned_usernames)
+#
+# #每10分钟执行次脚本
+# schedule.every(10).minutes.do(video_task)
+#
+#
+#
+#
+# # 每天下午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)