zhangyong 10 ماه پیش
والد
کامیت
a78108f1a6
2فایلهای تغییر یافته به همراه7 افزوده شده و 4 حذف شده
  1. 1 1
      agc_job.py
  2. 6 3
      video_agc/agc_video.py

+ 1 - 1
agc_job.py

@@ -144,4 +144,4 @@ from common import Material
 from video_agc.agc_video import AGC
 
 data = Material.feishu_list()
-AGC.video(data[1],  "常规")
+AGC.video(data[3],  "常规")

+ 6 - 3
video_agc/agc_video.py

@@ -256,6 +256,7 @@ class AGC():
         ]
         output = subprocess.check_output(ffprobe_cmd).decode("utf-8").strip()
         return float(output)
+
     """
     创建临时字幕
     """
@@ -381,6 +382,7 @@ class AGC():
             try:
                 d_list = list_data[count]
                 uid = d_list['uid']  # 音频id
+                uid = "20470411"
                 srt = d_list['text']  # srt
                 cover = d_list['cover']
                 audio_title = d_list['title']
@@ -390,7 +392,7 @@ class AGC():
                 #     Common.logger("bk_video").info(f"S{mark} 文件目录创建成功")
                 # else:
                 srt_new = SRT.getSrt(int(uid))
-                Common.logger("video").info(f"S{mark}的{platform}渠道音频ID")
+                Common.logger("video").info(f"S{mark}的{platform}渠道音频ID{uid}")
                 if error_count == 5:
                     Feishu.bot('recommend', 'AGC异常通知', f'音频id为{uid},任务处理异常5次,该任务跳过,请检查格式!', name, mark_name)
                     count += 1
@@ -402,7 +404,7 @@ class AGC():
                 try:
                     # 获取音频
                     audio_video = PQ.get_audio_url(uid)
-                    Common.logger("video").info(f"{mark}的{platform}渠道获音频成功")
+                    Common.logger("video").info(f"{mark}的{platform}渠道获音频成功{audio_video}")
                     audio_duration = cls.get_audio_duration(audio_video)
                     Common.logger("video").info(f"{mark}的{platform}渠道获取需要拼接的音频秒数为:{audio_duration}")
                 except Exception as e:
@@ -411,6 +413,7 @@ class AGC():
                     cls.clear_mp4_files(mark)
                     Feishu.bot('recommend', 'AGC异常通知', f'{platform}任务下,{uid}音频格式填写该任务跳过,请关注', name, mark_name)
                     continue
+
                 if platform != "常规":
                     if platform == "爆款":
                         videos = str(d_list['video'])
@@ -435,7 +438,7 @@ class AGC():
                     channels = ["douyin", "kuaishou"]
                     channel = random.choice(channels)
                     user_id = sqlHelp.get_user_id(channel, mark)
-                    url_list, user = sqlHelp.get_url_list(user_id, mark, "35")
+                    url_list, user = sqlHelp.get_url_list(user_id, mark, "50")
                     videos = [list(item) for item in url_list]
                     videos = Oss.get_oss_url(videos, video_path_url)
                     video_files = cls.zw_concatenate_videos(videos, audio_duration, audio_video, platform, s_path, v_path,