From 27d354050df8cf8777a75ab8027388eab9f0d0c0 Mon Sep 17 00:00:00 2001 From: lhx Date: Wed, 17 Dec 2025 15:19:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E5=8F=96?= =?UTF-8?q?=E6=B6=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/utils/scheduler.py | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/app/utils/scheduler.py b/app/utils/scheduler.py index c7d39a5..4a12445 100644 --- a/app/utils/scheduler.py +++ b/app/utils/scheduler.py @@ -186,24 +186,24 @@ task_scheduler = TaskScheduler() # 系统定时任务函数 def reset_today_updated_task(): """每日重置账号today_updated字段为0的任务""" - db = SessionLocal() - try: - logger.info("开始执行每日重置账号更新状态任务") + # db = SessionLocal() + # try: + # logger.info("开始执行每日重置账号更新状态任务") - # 更新所有账号的today_updated字段为0 - updated_need_count = db.query(Account).filter(Account.today_updated == 1).count() - updated_count = db.query(Account).update({Account.today_updated: 0}) - db.commit() + # # 更新所有账号的today_updated字段为0 + # updated_need_count = db.query(Account).filter(Account.today_updated == 1).count() + # updated_count = db.query(Account).update({Account.today_updated: 0}) + # db.commit() - logger.info(f"每日重置任务完成,已重置 {updated_count} 个账号的today_updated字段") - return f"成功重置 {updated_count} 个账号的更新状态" + # logger.info(f"每日重置任务完成,已重置 {updated_count} 个账号的today_updated字段") + # return f"成功重置 {updated_count} 个账号的更新状态" - except Exception as e: - db.rollback() - logger.error(f"每日重置任务执行失败: {e}") - raise e - finally: - db.close() + # except Exception as e: + # db.rollback() + # logger.error(f"每日重置任务执行失败: {e}") + # raise e + # finally: + # db.close() # 示例定时任务函数