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关联数据并处理")