From 2d80f39eefa8d74c56a2ac2cb69ef3db847d0d25 Mon Sep 17 00:00:00 2001 From: lhx Date: Tue, 16 Dec 2025 11:52:10 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=96=E6=B6=88=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/utils/scheduler.py | 57 +++++++++++++++++++++--------------------- 1 file changed, 29 insertions(+), 28 deletions(-) diff --git a/app/utils/scheduler.py b/app/utils/scheduler.py index 5332ff7..c7d39a5 100644 --- a/app/utils/scheduler.py +++ b/app/utils/scheduler.py @@ -78,36 +78,37 @@ class TaskScheduler: def _setup_system_tasks(self): """设置系统定时任务""" try: + logger.info("无定时任务") # 检查是否已存在每日重置任务 - existing_job = self.scheduler.get_job("daily_reset_today_updated") - # existing_job = self.scheduler.get_job("get_max_nyid") - if not existing_job: - # 添加每天午夜12点重置today_updated字段的任务 - self.scheduler.add_job( - reset_today_updated_task, - 'cron', - id='daily_reset_today_updated', - hour=0, - minute=0, - second=0, - 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关联数据任务已添加") + # existing_job = self.scheduler.get_job("daily_reset_today_updated") + # # existing_job = self.scheduler.get_job("get_max_nyid") + # if not existing_job: + # # 添加每天午夜12点重置today_updated字段的任务 + # self.scheduler.add_job( + # reset_today_updated_task, + # 'cron', + # id='daily_reset_today_updated', + # hour=0, + # minute=0, + # second=0, + # 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}")