From 52dd03c36d6b29b12da64520aa8ecf24c7e46dd0 Mon Sep 17 00:00:00 2001 From: liyxie Date: Thu, 6 Nov 2025 22:46:26 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/utils/scheduler.py | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/app/utils/scheduler.py b/app/utils/scheduler.py index fd1e730..db56b94 100644 --- a/app/utils/scheduler.py +++ b/app/utils/scheduler.py @@ -81,7 +81,6 @@ class TaskScheduler: # 添加每天午夜12点重置today_updated字段的任务 self.scheduler.add_job( reset_today_updated_task, - scheduled_get_max_nyid_by_point_id, 'cron', id='daily_reset_today_updated', hour=0, @@ -90,6 +89,20 @@ class TaskScheduler: name='每日重置账号更新状态' ) logger.info("系统定时任务：每日重置账号更新状态已添加") + existing_job = None + existing_job = self.scheduler.get_job("scheduled_get_max_nyid_by_point_id") + if not existing_job: + # 添加每天凌晨1点执行获取max NYID关联数据任务 + self.scheduler.add_job( + scheduled_get_max_nyid_by_point_id, + 'cron', + id='scheduled_get_max_nyid_by_point_id', + hour=1, + minute=0, + second=0, + name='每日获取max NYID关联数据并创建DailyData记录' + ) + logger.info("系统定时任务：每日获取max NYID关联数据任务已添加") except Exception as e: logger.error(f"设置系统定时任务失败: {e}") @@ -205,6 +218,7 @@ def scheduled_get_max_nyid_by_point_id(): """定时任务：获取max NYID关联数据并批量创建DailyData记录""" db: Session = None try: + logger.info("定时任务触发：开始获取max NYID关联数据并处理") # 初始化数据库会话（替代接口的Depends依赖） db = SessionLocal() logger.info("定时任务开始执行：获取max NYID关联数据并处理")