|
@@ -422,16 +422,19 @@ class VideoProcessor:
|
|
|
if status == 200:
|
|
|
oss_object_key = oss_object_key.get("oss_object_key")
|
|
|
time.sleep(1)
|
|
|
- jpg_path = PQ.download_video_jpg(cover, video_path_url, v_id) # 下载视频封面
|
|
|
- if os.path.isfile(jpg_path):
|
|
|
- oss_jpg_key = Oss.stitching_fm_upload_oss(jpg_path, oss_id) # 封面发送OSS
|
|
|
- status = oss_jpg_key.get("status")
|
|
|
- if status == 200:
|
|
|
- jpg = oss_jpg_key.get("oss_object_key")
|
|
|
+ if channel_id == "快手历史":
|
|
|
+ jpg = None
|
|
|
+ else:
|
|
|
+ jpg_path = PQ.download_video_jpg(cover, video_path_url, v_id) # 下载视频封面
|
|
|
+ if os.path.isfile(jpg_path):
|
|
|
+ oss_jpg_key = Oss.stitching_fm_upload_oss(jpg_path, oss_id) # 封面发送OSS
|
|
|
+ status = oss_jpg_key.get("status")
|
|
|
+ if status == 200:
|
|
|
+ jpg = oss_jpg_key.get("oss_object_key")
|
|
|
+ else:
|
|
|
+ jpg = None
|
|
|
else:
|
|
|
jpg = None
|
|
|
- else:
|
|
|
- jpg = None
|
|
|
code = PQ.insert_piaoquantv(oss_object_key, new_title, jpg, piaoquan_id)
|
|
|
Common.logger(mark).info(f"{name}的{task_mark}下的视频ID{v_id}发送成功")
|
|
|
sqlCollect.insert_task(task_mark, v_id, mark, channel_id) # 插入数据库
|