定时任务取消
This commit is contained in:
@@ -186,24 +186,24 @@ task_scheduler = TaskScheduler()
|
|||||||
# 系统定时任务函数
|
# 系统定时任务函数
|
||||||
def reset_today_updated_task():
|
def reset_today_updated_task():
|
||||||
"""每日重置账号today_updated字段为0的任务"""
|
"""每日重置账号today_updated字段为0的任务"""
|
||||||
db = SessionLocal()
|
# db = SessionLocal()
|
||||||
try:
|
# try:
|
||||||
logger.info("开始执行每日重置账号更新状态任务")
|
# logger.info("开始执行每日重置账号更新状态任务")
|
||||||
|
|
||||||
# 更新所有账号的today_updated字段为0
|
# # 更新所有账号的today_updated字段为0
|
||||||
updated_need_count = db.query(Account).filter(Account.today_updated == 1).count()
|
# updated_need_count = db.query(Account).filter(Account.today_updated == 1).count()
|
||||||
updated_count = db.query(Account).update({Account.today_updated: 0})
|
# updated_count = db.query(Account).update({Account.today_updated: 0})
|
||||||
db.commit()
|
# db.commit()
|
||||||
|
|
||||||
logger.info(f"每日重置任务完成,已重置 {updated_count} 个账号的today_updated字段")
|
# logger.info(f"每日重置任务完成,已重置 {updated_count} 个账号的today_updated字段")
|
||||||
return f"成功重置 {updated_count} 个账号的更新状态"
|
# return f"成功重置 {updated_count} 个账号的更新状态"
|
||||||
|
|
||||||
except Exception as e:
|
# except Exception as e:
|
||||||
db.rollback()
|
# db.rollback()
|
||||||
logger.error(f"每日重置任务执行失败: {e}")
|
# logger.error(f"每日重置任务执行失败: {e}")
|
||||||
raise e
|
# raise e
|
||||||
finally:
|
# finally:
|
||||||
db.close()
|
# db.close()
|
||||||
|
|
||||||
|
|
||||||
# 示例定时任务函数
|
# 示例定时任务函数
|
||||||
|
|||||||
Reference in New Issue
Block a user