|
@@ -27,6 +27,7 @@ class GetCoverService(Response):
|
|
|
return None
|
|
|
|
|
|
async def fetch_cover_info(self, pool_name, channel_content_id: str):
|
|
|
+
|
|
|
match pool_name:
|
|
|
case "aigc_db_pool":
|
|
|
fetch_response, sql_error = await fetch_aigc_cover(
|
|
@@ -42,13 +43,17 @@ class GetCoverService(Response):
|
|
|
if image_oss:
|
|
|
cover = await self.montage_cover(image_oss, "aigc_db_pool")
|
|
|
else:
|
|
|
- image_url = fetch_response[0]['image_url']
|
|
|
+ image_url = fetch_response[0]["image_url"]
|
|
|
if not image_url:
|
|
|
- return await self.fetch_cover_info("long_video_db_pool", channel_content_id)
|
|
|
+ return await self.fetch_cover_info(
|
|
|
+ "long_video_db_pool", channel_content_id
|
|
|
+ )
|
|
|
else:
|
|
|
cover = await self.montage_cover(image_url, "aigc_db_pool")
|
|
|
else:
|
|
|
- return await self.fetch_cover_info("long_video_db_pool", channel_content_id)
|
|
|
+ return await self.fetch_cover_info(
|
|
|
+ "long_video_db_pool", channel_content_id
|
|
|
+ )
|
|
|
case "long_video_db_pool":
|
|
|
fetch_response, sql_error = await fetch_long_video_cover(
|
|
|
self.pool, channel_content_id
|