From 47af64d1e197f298851cfa9e6969db855de4fd83 Mon Sep 17 00:00:00 2001 From: whm <973418690@qq.com> Date: Fri, 7 Nov 2025 10:57:10 +0800 Subject: [PATCH] =?UTF-8?q?1.=E8=AE=BE=E7=BD=AE=E5=85=A8=E5=B1=80=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E5=8F=98=E9=87=8F=202.=E6=8A=8A=E8=BF=87=E6=9C=9F?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E4=B8=80=E5=B9=B6=E6=8A=93=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/api/comprehensive_data.py | 1 + app/models/daily.py | 1 + app/utils/scheduler.py | 9 +++++---- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/app/api/comprehensive_data.py b/app/api/comprehensive_data.py index 6917bae..07580a5 100644 --- a/app/api/comprehensive_data.py +++ b/app/api/comprehensive_data.py @@ -394,6 +394,7 @@ def get_today_data(request: TodayDataRequest, db: Session = Depends(get_db)): # account_id = request.account_id # 根据根据实际需求决定是否需要 # 触发定时任务（如果需要传入参数，可在这里添加） + # from ..utils.scheduler import scheduled_get_max_nyid_by_point_id # scheduled_get_max_nyid_by_point_id() # 调用服务层获取数据 diff --git a/app/models/daily.py b/app/models/daily.py index 2c45f1b..ad9a470 100644 --- a/app/models/daily.py +++ b/app/models/daily.py @@ -13,3 +13,4 @@ class DailyData(Base): section_id = Column(String(255), nullable=False, comment="所属断面id") remaining = Column(Integer, nullable=False, comment="剩余天数") user_id = Column(Integer, default=1, nullable=False, comment="用户id") + is_all = Column(Integer, default=1, nullable=False, comment="是否全量数据") diff --git a/app/utils/scheduler.py b/app/utils/scheduler.py index 32862ec..f3d039a 100644 --- a/app/utils/scheduler.py +++ b/app/utils/scheduler.py @@ -238,6 +238,7 @@ def scheduled_get_max_nyid_by_point_id(): daily_data = monitor.get_due_data(result) data = daily_data['data'] error_data = daily_data['error_data'] + winters = daily_data['winter'] logger.info(f"首次获取数据完成，共{len(result)}条记录") @@ -254,9 +255,9 @@ def scheduled_get_max_nyid_by_point_id(): winters = w_list['winter'] data.extend(w_list['data']) # 过期数据一并处理 - data.extend(w_list['error_data']) - # error_data.extend(w_list['error_data']) - + # data.extend(w_list['error_data']) + error_data.extend(w_list['error_data']) + data.extend(error_data) # 4. 初始化服务实例 level_service = LevelDataService() checkpoint_db = CheckpointService() @@ -299,7 +300,7 @@ def scheduled_get_max_nyid_by_point_id(): 'linecode': d['level_data']['linecode'], 'account_id': d['account_data']['account_id'], 'section_id': d['section_data']['section_id'], - 'remaining': d['remaining'], + 'remaining': (0-int(d['overdue'])) if 'overdue' in d else d['remaining'], } daily_create_data.append(tem)