采用裂变信息重排序

applications/match_algorithm/rank.py

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