|
|
@@ -443,7 +443,11 @@ def h_timer_check():
|
|
|
now_h = datetime.now().hour
|
|
|
# 查看当前天级更新的数据是否已准备好
|
|
|
h_data_count = h_data_check(project=project, table=table, now_date=now_date, now_h=now_h)
|
|
|
- if h_data_count > 0:
|
|
|
+ if now_h == 23 or now_h < 8:
|
|
|
+ log_.info(f'now_h = {now_h} use bottom data!')
|
|
|
+ h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params)
|
|
|
+ log_.info(f"24h_data end!")
|
|
|
+ elif h_data_count > 0:
|
|
|
log_.info(f'h_by24h_data_count = {h_data_count}')
|
|
|
# 数据准备好，进行更新
|
|
|
rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params, project=project, table=table)
|
