From f95be2c1b35fa2f2238a5cc4b43aab880af3f7fb Mon Sep 17 00:00:00 2001
From: zengqiao <zengqiao@didiglobal.com>
Date: Thu, 9 Feb 2023 16:36:19 +0800
Subject: [PATCH] =?UTF-8?q?[Optimize]TaskResult=E5=A2=9E=E5=8A=A0=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E=E4=BB=BB=E5=8A=A1=E5=88=86=E7=BB=84=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../know/streaming/km/task/AbstractDispatchTask.java  | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java
index fc211c14..5150430e 100644
--- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java
+++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java
@@ -9,6 +9,7 @@ import com.didiglobal.logi.log.ILog;
 import com.didiglobal.logi.log.LogFactory;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.EntityIdInterface;
 import com.xiaojukeji.know.streaming.km.common.exception.AdminTaskCodeException;
+import com.xiaojukeji.know.streaming.km.common.utils.ConvertUtil;
 import com.xiaojukeji.know.streaming.km.common.utils.ValidateUtils;
 
 import javax.annotation.PostConstruct;
@@ -82,7 +83,15 @@ public abstract class AbstractDispatchTask<E extends Comparable & EntityIdInterf
             }
 
             // 进行任务处理
-            return this.processTask(subTaskList, triggerTimeUnitMs);
+            TaskResult ret = this.processTask(subTaskList, triggerTimeUnitMs);
+
+            //组装信息
+            TaskResult taskResult = new TaskResult();
+            taskResult.setCode(ret.getCode());
+            taskResult.setMessage(ConvertUtil.list2String(subTaskList, ","));
+
+            return taskResult;
+
         } catch (Exception e) {
             LOGGER.error("process task failed, taskName:{}", taskName, e);