新系统-发布之后获取 video_id,

再重新获取 share_img_path

bug-fix

tasks/history_task.py

@@ -180,9 +180,9 @@ class historyContentIdTask(object):
                 "uid": video_obj['uid'],
                 "source": video_obj['platform'],
                 "kimiTitle": kimi_title,
-                "videoId": response['data']['id'],
-                "videoCover": response['data']['shareImgPath'],
-                "videoPath": response['data']['videoPath'],
+                "videoId": response['data'][0]['id'],
+                "videoCover": response['data'][0]['shareImgPath'],
+                "videoPath": response['data'][0]['videoPath'],
                 "videoOss": video_obj['video_oss_path']
             }
             L.append(obj)

tasks/newContentIdTask.py

@@ -621,9 +621,9 @@ class NewContentIdTask(object):
                     "uid": video_obj['uid'],
                     "source": video_obj['platform'],
                     "kimiTitle": kimi_title,
-                    "videoId": response['data']['id'],
-                    "videoCover": response['data']['shareImgPath'],
-                    "videoPath": response['data']['videoPath'],
+                    "videoId": response['data'][0]['id'],
+                    "videoCover": response['data'][0]['shareImgPath'],
+                    "videoPath": response['data'][0]['videoPath'],
                     "videoOss": video_obj['video_oss_path']
                 }
                 L.append(obj)
@@ -731,7 +731,7 @@ class NewContentIdTask(object):
             if processing_flag:
                 logging(
                     code="9001",
-                    info="该 content id 正在处理中， 跳过此任务"
+                    info="该 content id 正在处理中， 跳过此任务--{}".format(content_id)
                 )
             else:
                 await self.start_process(params=params)