update get_pool_redis_key

video_recall.py

@@ -280,7 +280,17 @@ class PoolRecall(object):
                 if self.redis_helper.key_exists(key_name):
                     return key_name, redis_date
                 else:
-                    key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type, redis_date - 1)
+                    if redis_date == 0:
+                        key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type, 23)
+                    else:
+                        key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type,
+                                                    redis_date - 1)
+                    # 判断当前时间是否晚于数据正常更新时间，发送消息到飞书
+                    now_m = datetime.now().minute
+                    feishu_text = '生产环境 —— appType = {}, h = {} 数据未按时更新，请及时查看解决。'.format(self.app_type,
+                                                                                         redis_date)
+                    if now_m > 2:
+                        send_msg_to_feishu(feishu_text)
                     return key_name, redis_date - 1
                 # 其他
             else: