update get_pool_redis_key with appType=6

video_recall.py

@@ -271,6 +271,8 @@ class PoolRecall(object):
         :return: key_name
         """
         if pool_type == 'rov':
+            # appType = 6也使用统一的ROV列表视频
+            """
             # appType = 6
             if self.app_type == config_.APP_TYPE['SHORT_VIDEO']:
                 # 获取当前所在小时
@@ -322,6 +324,33 @@ class PoolRecall(object):
                         send_msg_to_feishu(feishu_text)
 
                 return key_name, redis_date
+            """
+
+            # appType = 13  票圈视频app
+            if self.app_type == config_.APP_TYPE['APP']:
+                key_name_prefix = config_.RECALL_KEY_NAME_PREFIX_APP
+            # 其他
+            else:
+                key_name_prefix = config_.RECALL_KEY_NAME_PREFIX
+
+            # 判断热度列表是否更新，未更新则使用前一天的热度列表
+            key_name = key_name_prefix + time.strftime('%Y%m%d')
+            if self.redis_helper.key_exists(key_name):
+                redis_date = date.today().strftime('%Y%m%d')
+            else:
+                redis_date = (date.today() - timedelta(days=1)).strftime('%Y%m%d')
+                key_name = key_name_prefix + redis_date
+                # if not self.redis_helper.key_exists(key_name):
+                #     return None, None
+
+                # 判断当前时间是否晚于rov召回池更新时间 + 1h，发送消息到飞书
+                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)
 
         elif pool_type == 'flow':
             return config_.FLOW_POOL_KEY_NAME_PREFIX + str(self.app_type)