Parcourir la source

Merge branch 'special-mid' into pre-master

liqian il y a 2 ans
Parent
commit
3c207a8951
2 fichiers modifiés avec 11 ajouts et 8 suppressions
  1. 7 4
      recommend.py
  2. 4 4
      video_recall.py

+ 7 - 4
recommend.py

@@ -814,12 +814,15 @@ def special_mid_recommend(request_id, mid, uid, app_type, size,
                         'pushFrom': push_from, 'abCode': ab_code}
                        for value in data]
         recall_result.extend(temp_result)
-        # 将此次获取的末位视频id同步刷新到Redis中,方便下次快速定位到召回位置,过期时间为1天
-        if mid:
-            # mid为空时,不做记录
-            redis_helper.set_data_to_redis(key_name=last_special_recall_key, value=data[-1][0], expire_time=expire_time)
         idx += get_size
 
+    # 将此次获取的末位视频id同步刷新到Redis中,方便下次快速定位到召回位置,过期时间为1天
+    if mid:
+        # mid为空时,不做记录
+        redis_helper.set_data_to_redis(key_name=last_special_recall_key,
+                                       value=recall_result[:size][-1]['videoId'],
+                                       expire_time=expire_time)
+
     return recall_result[:size]
 
 

+ 4 - 4
video_recall.py

@@ -637,10 +637,10 @@ class PoolRecall(object):
                 now_h = datetime.now().hour
                 now_m = datetime.now().minute
                 feishu_text = '{} —— 今日ROV召回池数据未按时更新,请及时查看解决。'.format(config_.ENV_TEXT)
-                if now_h == config_.ROV_UPDATE_H + 1 and now_m > config_.ROV_UPDATE_MINUTE:
-                    send_msg_to_feishu(feishu_text)
-                elif now_h > config_.ROV_UPDATE_H + 2:
-                    send_msg_to_feishu(feishu_text)
+                # if now_h == config_.ROV_UPDATE_H + 1 and now_m > config_.ROV_UPDATE_MINUTE:
+                #     send_msg_to_feishu(feishu_text)
+                # elif now_h > config_.ROV_UPDATE_H + 2:
+                #     send_msg_to_feishu(feishu_text)
 
             return key_name, redis_date