admin/railway_cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
whm
2025-12-18 22:23:35 +08:00
parent 8c6d596a28
commit a1a9bdd468
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/utils/scheduler.py
View File

@@ -240,7 +240,6 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
# 2. 计算到期数据 # 2. 计算到期数据
monitor = ConstructionMonitorUtils() monitor = ConstructionMonitorUtils()
daily_data = monitor.get_due_data(result,start=start,end=end) daily_data = monitor.get_due_data(result,start=start,end=end)
print(daily_data)
data = daily_data['data'] data = daily_data['data']
error_data = daily_data['error_data'] error_data = daily_data['error_data']
@@ -255,6 +254,7 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
print(max_num) print(max_num)
# 提取冬休数据的point_id列表 # 提取冬休数据的point_id列表
new_list = [int(w['point_id']) for w in winters] new_list = [int(w['point_id']) for w in winters]
# print(new_list)
if new_list == []: if new_list == []:
break break
# 获取更多历史记录 # 获取更多历史记录
@@ -266,6 +266,7 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
# 过期数据一并处理 # 过期数据一并处理
# data.extend(w_list['error_data']) # data.extend(w_list['error_data'])
error_data.extend(w_list['error_data']) error_data.extend(w_list['error_data'])
# print(f"第{max_num}次获取冬休数据完成，共{len(winters)}条记录")
if winters == []: if winters == []:
break break
data.extend(error_data) data.extend(error_data)