|
|
@@ -11,6 +11,7 @@ import requests
|
|
|
|
|
|
from application.common.feishu import FsData
|
|
|
from application.common.feishu.feishu_utils import FeishuUtils
|
|
|
+from application.common.ffmpeg.ffmpeg_utils import Ffmpeg
|
|
|
from application.common.gpt import GPT4oMini
|
|
|
from application.common.mysql.sql import Sql
|
|
|
from application.common.redis.xng_redis import xng_in_video_data
|
|
|
@@ -97,7 +98,12 @@ class FQHYDRecommend(object):
|
|
|
time.sleep(random.randint(3, 8))
|
|
|
trace_id = self.platform + str(uuid.uuid1())
|
|
|
our_user = random.choice(self.user_list)
|
|
|
+ video_url = video_obj["videoPath"]
|
|
|
item = VideoItem()
|
|
|
+ ffmpeg = Ffmpeg()
|
|
|
+ new_video_url = ffmpeg.merge_m3u8(video_url)
|
|
|
+ if not new_video_url:
|
|
|
+ return
|
|
|
item.add_video_info("video_id", video_obj["videoId"])
|
|
|
item.add_video_info("video_title", video_obj["title"])
|
|
|
item.add_video_info("play_cnt", 0)
|
|
|
@@ -107,7 +113,7 @@ class FQHYDRecommend(object):
|
|
|
item.add_video_info("like_cnt", 0)
|
|
|
item.add_video_info("share_cnt", 0)
|
|
|
item.add_video_info("comment_cnt", 0)
|
|
|
- item.add_video_info("video_url", video_obj["videoPath"])
|
|
|
+ item.add_video_info("video_url", video_url)
|
|
|
item.add_video_info("out_video_id", video_obj["videoId"])
|
|
|
item.add_video_info("platform", self.platform)
|
|
|
item.add_video_info("strategy", self.mode)
|
