|
@@ -274,24 +274,24 @@ class PoolRecall(object):
|
|
# appType = 6
|
|
# appType = 6
|
|
if self.app_type == config_.APP_TYPE['SHORT_VIDEO']:
|
|
if self.app_type == config_.APP_TYPE['SHORT_VIDEO']:
|
|
# 获取当前所在小时
|
|
# 获取当前所在小时
|
|
- redis_date = datetime.now().hour
|
|
|
|
|
|
+ h = datetime.now().hour
|
|
# 判断热度列表是否更新,未更新则使用前一小时的热度列表
|
|
# 判断热度列表是否更新,未更新则使用前一小时的热度列表
|
|
- key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type, redis_date)
|
|
|
|
|
|
+ key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type, h)
|
|
if self.redis_helper.key_exists(key_name):
|
|
if self.redis_helper.key_exists(key_name):
|
|
- return key_name, redis_date
|
|
|
|
|
|
+ return key_name, h
|
|
else:
|
|
else:
|
|
- if redis_date == 0:
|
|
|
|
- key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type, 23)
|
|
|
|
|
|
+ if h == 0:
|
|
|
|
+ redis_h = 23
|
|
else:
|
|
else:
|
|
- key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type,
|
|
|
|
- redis_date - 1)
|
|
|
|
|
|
+ redis_h = h - 1
|
|
|
|
+ key_name = '{}{}.{}'.format(config_.RECALL_KEY_NAME_PREFIX_APP_TYPE, self.app_type, redis_h)
|
|
# 判断当前时间是否晚于数据正常更新时间,发送消息到飞书
|
|
# 判断当前时间是否晚于数据正常更新时间,发送消息到飞书
|
|
now_m = datetime.now().minute
|
|
now_m = datetime.now().minute
|
|
feishu_text = '{} —— appType = {}, h = {} 数据未按时更新,请及时查看解决。'.format(
|
|
feishu_text = '{} —— appType = {}, h = {} 数据未按时更新,请及时查看解决。'.format(
|
|
- config_.ENV_TEXT, self.app_type, redis_date)
|
|
|
|
|
|
+ config_.ENV_TEXT, self.app_type, h)
|
|
if now_m > config_.ROV_UPDATE_MINUTE_6:
|
|
if now_m > config_.ROV_UPDATE_MINUTE_6:
|
|
send_msg_to_feishu(feishu_text)
|
|
send_msg_to_feishu(feishu_text)
|
|
- return key_name, redis_date - 1
|
|
|
|
|
|
+ return key_name, redis_h
|
|
# 其他
|
|
# 其他
|
|
else:
|
|
else:
|
|
# 判断热度列表是否更新,未更新则使用前一天的热度列表
|
|
# 判断热度列表是否更新,未更新则使用前一天的热度列表
|