From 7bd158896e84292b5cde8c7ba510398b1d3c2225 Mon Sep 17 00:00:00 2001
From: liuwei <liuwei@wdtrgf.com.cn>
Date: Tue, 10 Jun 2025 13:01:08 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=20=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E5=AE=9A=E6=97=B6=E6=8E=A8=E9=80=81=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 plugins/message_push_task/main.py | 16 ++++------------
 1 file changed, 4 insertions(+), 12 deletions(-)

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