|
@@ -62,13 +62,14 @@ async def get_content_oss_fission_dict(db_client, config, content_id) -> dict[st
|
|
|
:return:
|
|
|
"""
|
|
|
FISSION_DETAIL_TABLE = config.fission_detail_table
|
|
|
- yesterday_dt = (datetime.now() - timedelta(days=1)).strftime('%Y%m%d')
|
|
|
+ two_days_ago_dt = (datetime.now() - timedelta(days=2)).strftime('%Y%m%d')
|
|
|
sql = f"""
|
|
|
SELECT
|
|
|
oss_name, fission_rate_0, fission_0_on_read
|
|
|
FROM
|
|
|
{FISSION_DETAIL_TABLE}
|
|
|
- WHERE content_id = '{content_id}' and dt = '{yesterday_dt}';
|
|
|
+ WHERE content_id = '{content_id}' and dt >= '{two_days_ago_dt}'
|
|
|
+ ORDER BY dt DESC;
|
|
|
"""
|
|
|
result = await db_client.select(sql)
|
|
|
fission_info_dict = {}
|
|
@@ -79,7 +80,10 @@ async def get_content_oss_fission_dict(db_client, config, content_id) -> dict[st
|
|
|
"fission_rate_0": item[1],
|
|
|
"fission_0_on_read": item[2]
|
|
|
}
|
|
|
- fission_info_dict[key] = value
|
|
|
+ if fission_info_dict.get(key):
|
|
|
+ continue
|
|
|
+ else:
|
|
|
+ fission_info_dict[key] = value
|
|
|
else:
|
|
|
return {}
|
|
|
|