agc_bk_main.py 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. import re
  2. from common import Material, Common, Feishu
  3. from video_agc.agc_video_method import AgcVidoe
  4. import concurrent.futures
  5. import schedule
  6. import time
  7. # 记录今天已经返回的用户名
  8. returned_usernames_today = []
  9. def video_start(user_data):
  10. global returned_usernames_today
  11. user_data_mark = user_data["mark"]
  12. mark_name = user_data['mark_name']
  13. # 开始准备执行生成视频脚本
  14. if user_data_mark is not None and user_data_mark in returned_usernames_today:
  15. Common.logger("video").info(f"视频脚本参数中的用户名 {user_data_mark} 今天已经返回过,不再启动线程。今天已经返回的用户名:{returned_usernames_today}")
  16. print(f"视频脚本参数中的用户名 {user_data_mark} 今天已经返回过,不再启动线程。")
  17. return # 如果返回了某个用户名,并且今天已经返回过,则不启动线程
  18. else:
  19. print(f"视频脚本参数{user_data}")
  20. mark = AgcVidoe.video_bk_stitching(user_data)
  21. print(f"返回用户名{mark}")
  22. if mark:
  23. returned_usernames_today.append(mark)
  24. Common.logger("video").info(f"返回用户名{mark}")
  25. # gs_name_list = Material.feishu_bk_list()
  26. # video_start(gs_name_list[0])
  27. def clear_returned_usernames():
  28. returned_usernames_today.clear()
  29. print("returned_usernames_today 已清空")
  30. # 定义定时任务
  31. def video_task():
  32. print("开始执行生成视频脚.")
  33. data = Material.feishu_bk_list()
  34. # 创建一个线程池
  35. with concurrent.futures.ThreadPoolExecutor() as executor:
  36. futures = [executor.submit(video_start, user_data) for user_data in data]
  37. # 等待所有任务执行完成
  38. for future in concurrent.futures.as_completed(futures):
  39. try:
  40. # 获取每个任务的执行结果
  41. result = future.result()
  42. print("处理结果:", result)
  43. except Exception as e:
  44. print("处理任务时出现异常:", e)
  45. print("执行生成视频脚结束")
  46. # 每天12点30清空集合
  47. schedule.every().day.at("19:00").do(clear_returned_usernames)
  48. #每10分钟执行次脚本
  49. schedule.every(10).minutes.do(video_task)
  50. while True:
  51. schedule.run_pending()
  52. time.sleep(1)