From 72ab05cbe49d98a8cb873e5fea9d27d2aaeef71b Mon Sep 17 00:00:00 2001
From: "zhangf@suq.cn" <zhangf@suq.cn>
Date: Wed, 10 Dec 2025 15:26:50 +0800
Subject: [PATCH] =?UTF-8?q?feat(task):=20=E6=B7=BB=E5=8A=A0=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E6=9B=B4=E6=96=B0=E5=90=8E=E7=9A=84=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E6=8A=95=E9=80=92=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 在任务更新成功后向Redis发送消息通知
- 消息内容包含任务ID以便后续处理
---
 app/service/CreationTaskService.php | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/app/service/CreationTaskService.php b/app/service/CreationTaskService.php
index 10f8283..f9d1950 100644
--- a/app/service/CreationTaskService.php
+++ b/app/service/CreationTaskService.php
@@ -69,6 +69,8 @@ class CreationTaskService extends BaseService
         try {
             $this->dao->update(['id' => $params['id']], $params);
             Db::commit();
+            //投递消息
+            Redis::send('creation-task', ['task_id' => $params['id']]);
         } catch (\Exception $exception) {
             Db::rollback();
             throw new ApiException($exception->getMessage());