|
@@ -65,7 +65,10 @@ class GetCoverService(Response):
|
|
|
|
|
|
return self.success_response(data={"cover": cover})
|
|
|
|
|
|
- async def get_cover(self, content_id: str):
|
|
|
+ async def get_cover(self, content_id: str, video_index: int, seed_video_id: str):
|
|
|
+ if video_index == 2:
|
|
|
+ return await self.fetch_cover_info("long_video_db_pool", seed_video_id)
|
|
|
+
|
|
|
channel_info, sql_error = await fetch_channel_info(self.pool, content_id)
|
|
|
if sql_error:
|
|
|
return self.error_response(
|
|
@@ -97,10 +100,22 @@ class GetCoverService(Response):
|
|
|
|
|
|
async def deal(self):
|
|
|
content_id = self.params.get("content_id")
|
|
|
+ video_index = self.params.get("video_index")
|
|
|
+ seed_video_id = self.params.get("seed_video_id")
|
|
|
if not content_id:
|
|
|
return self.error_response(
|
|
|
error_code="401",
|
|
|
error_message="content_id is required",
|
|
|
)
|
|
|
+ elif not video_index:
|
|
|
+ return self.error_response(
|
|
|
+ error_code="401",
|
|
|
+ error_message="video_index is required",
|
|
|
+ )
|
|
|
+ elif not seed_video_id:
|
|
|
+ return self.error_response(
|
|
|
+ error_code="401",
|
|
|
+ error_message="seed_video_id is required",
|
|
|
+ )
|
|
|
else:
|
|
|
- return await self.get_cover(content_id)
|
|
|
+ return await self.get_cover(content_id, int(video_index), seed_video_id)
|