|
|
@@ -91,7 +91,7 @@ class VideoProcessor:
|
|
|
channel_url_list = [channel_urls]
|
|
|
for url in channel_url_list:
|
|
|
Common.logger("log").info(f"{name}的{task_mark}下的用户:{channel_url_list}开始获取视频")
|
|
|
- data_list = cls.get_data_list(channel_id, task_mark, url, number, mark, feishu_id, cookie_sheet)
|
|
|
+ data_list = cls.get_data_list(channel_id, task_mark, url, number, mark, feishu_id, cookie_sheet, name)
|
|
|
if not data_list:
|
|
|
Common.logger("log").info(f"{name}的{task_mark}下的视频ID{url} 已经改造过了")
|
|
|
Feishu.bot(mark, '机器自动改造消息通知', f'{task_mark}任务下的用户ID{url},没有已经改造的视频了', name)
|
|
|
@@ -187,18 +187,18 @@ class VideoProcessor:
|
|
|
Feishu.bot(mark, '机器自动改造消息通知', f'{task_mark}任务改造完成，请关注', name)
|
|
|
|
|
|
@classmethod
|
|
|
- def get_data_list(cls, channel_id, task_mark, url, number, mark, feishu_id, cookie_sheet):
|
|
|
+ def get_data_list(cls, channel_id, task_mark, url, number, mark, feishu_id, cookie_sheet, name):
|
|
|
"""
|
|
|
根据渠道ID获取数据列表
|
|
|
"""
|
|
|
if channel_id == "抖音":
|
|
|
- return DY.get_dy_url(task_mark, url, number, mark, feishu_id, cookie_sheet, channel_id)
|
|
|
+ return DY.get_dy_url(task_mark, url, number, mark, feishu_id, cookie_sheet, channel_id, name)
|
|
|
elif channel_id == "票圈":
|
|
|
return PQ.get_pq_url(task_mark, url, number, mark)
|
|
|
elif channel_id == "视频号":
|
|
|
return SPH.get_sph_url(task_mark, url, number, mark)
|
|
|
elif channel_id == "快手":
|
|
|
- return KS.get_ks_url(task_mark, url, number, mark, feishu_id, cookie_sheet, channel_id)
|
|
|
+ return KS.get_ks_url(task_mark, url, number, mark, feishu_id, cookie_sheet, channel_id, name)
|
|
|
elif channel_id == "快手创作者版":
|
|
|
return KsFeedVideo.get_data()
|
|
|
elif channel_id == "视频号单视频":
|
