debug

video_rank.py

@@ -175,7 +175,7 @@ def bottom_strategy(request_id, size, app_type, ab_code, params):
         log_.info('{} —— ROV推荐进入了二次兜底, data = {}'.format(config_.ENV_TEXT, data))
         send_msg_to_feishu('{} —— ROV推荐进入了二次兜底，请查看是否有数据更新失败问题。'.format(config_.ENV_TEXT))
         # 二次兜底
-        bottom_data = bottom_strategy_last(size=size, app_type=app_type, ab_code=ab_code)
+        bottom_data = bottom_strategy_last(size=size, app_type=app_type, ab_code=ab_code, params=params)
         return bottom_data
 
     # 视频状态过滤采用离线定时过滤方案

video_recall.py

@@ -1651,6 +1651,7 @@ class PoolRecall(object):
 
         if not self.redis_helper.key_exists(key_name=record_key):
             # ###### 记录key不存在
+            self.redis_helper.del_keys(key_name=last_video_key)
             idx = 0
             pool_recall_key = self.update_last_video_record(record_key=record_key, pool_key_prefix=pool_key_prefix,
                                                             province_code=province_code)
@@ -1674,12 +1675,14 @@ class PoolRecall(object):
                     new_record = {'date': now_dt, 'h': h}
                     self.redis_helper.set_data_to_redis(key_name=record_key, value=str(new_record), expire_time=2*3600)
                     idx = 0
+                    self.redis_helper.del_keys(key_name=last_video_key)
                     pool_recall_key = now_pool_recall_key
                 else:
                     pool_recall_key = f"{pool_key_prefix}{province_code}.{self.app_type}.{self.data_key}.{self.rule_key}.{record_dt}.{record_h}"
                     idx = self.get_video_idx(pool_recall_key=pool_recall_key, last_video_key=last_video_key)
             else:
                 idx = 0
+                self.redis_helper.del_keys(key_name=last_video_key)
                 pool_recall_key = self.update_last_video_record(record_key=record_key, pool_key_prefix=pool_key_prefix,
                                                                 province_code=province_code)