liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增 消息定时推送功能

Browse Source
This commit is contained in:
liuwei
2025-06-10 13:01:08 +08:00
parent eeed1113fb
commit 7bd158896e
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
plugins/message_push_task/main.py
View File

@@ -199,11 +199,7 @@ class MessagePushTask(MessagePluginInterface):
else: else:
status = 'partially_completed' status = 'partially_completed'
self.db.update_task(task['task_id'], { self.db.update_task(task['task_id'], {'status': status})
'status': status,
'success_count': success_count,
'fail_count': fail_count
})
# 记录任务完成 # 记录任务完成
self.db.log_task_action({ self.db.log_task_action({
@@ -211,11 +207,7 @@ class MessagePushTask(MessagePluginInterface):
'task_id': task['task_id'], 'task_id': task['task_id'],
'action': 'update', # 使用现有的action类型 'action': 'update', # 使用现有的action类型
'user_id': task['creator_id'], 'user_id': task['creator_id'],
'changes': { 'changes': {'status': status}
'status': status,
'success_count': success_count,
'fail_count': fail_count
}
}) })
# 如果是重复任务，更新下次执行时间 # 如果是重复任务，更新下次执行时间
@@ -241,9 +233,9 @@ class MessagePushTask(MessagePluginInterface):
self.db.log_task_action({ self.db.log_task_action({
'log_id': f"log_{datetime.now().strftime('%Y%m%d%H%M%S')}", 'log_id': f"log_{datetime.now().strftime('%Y%m%d%H%M%S')}",
'task_id': task['task_id'], 'task_id': task['task_id'],
'action': 'error', 'action': 'update', # 使用现有的action类型
'user_id': task['creator_id'], 'user_id': task['creator_id'],
'changes': {'error': str(e)} 'changes': {'status': 'failed', 'error': str(e)}
}) })
except Exception as e: except Exception as e: