定时任务

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