automas_admin/AUTO-MAS-test
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 后端添加定时任务防止重复启动机制

Browse Source
This commit is contained in:
DLmaster361
2025-09-22 15:52:11 +08:00
parent 0437778c14
commit 22ebe7e51b
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/core/timer.py
View File

@@ -87,13 +87,9 @@ class _MainTimer:
# 避免重复调起任务 # 避免重复调起任务
if curtime == queue.get("Data", "LastTimedStart"): if curtime == queue.get("Data", "LastTimedStart"):
logger.debug("已启动过任务，跳过本任务")
continue continue
for time_set in queue.TimeSet.values(): for time_set in queue.TimeSet.values():
logger.debug(
f"检查定时任务：{time_set.get('Info', 'Time')}, 启用状态：{time_set.get('Info', 'Enabled')}"
)
if ( if (
time_set.get("Info", "Enabled") time_set.get("Info", "Enabled")
and curtime[11:16] == time_set.get("Info", "Time") and curtime[11:16] == time_set.get("Info", "Time")
@@ -101,6 +97,8 @@ class _MainTimer:
): ):
logger.info(f"定时唤起任务：{uid}") logger.info(f"定时唤起任务：{uid}")
task_id = await TaskManager.add_task("自动代理", str(uid)) task_id = await TaskManager.add_task("自动代理", str(uid))
await queue.set("Data", "LastTimedStart", curtime)
await Config.QueueConfig.save()
await Config.send_json( await Config.send_json(
WebSocketMessage( WebSocketMessage(