From 2db59cc66047f72943c9b9d3e8614fd1fcff708a Mon Sep 17 00:00:00 2001 From: yangqicheng Date: Tue, 28 May 2024 11:20:08 +0800 Subject: [PATCH] =?UTF-8?q?update=20-=20REQ-2324-=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E6=89=B9=E9=87=8F=E9=A9=B3=E5=9B=9E=E5=BE=85=E5=8A=9E=E6=9C=AA?= =?UTF-8?q?=E6=81=A2=E5=A4=8D=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../error/ApproveErrorReporterEventListener.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java index 43c333b06..501ae8c5e 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java @@ -6,6 +6,7 @@ import cn.axzo.workflow.core.common.utils.BpmnMetaParserHelper; import cn.axzo.workflow.core.engine.event.MessagePushEvent; import cn.axzo.workflow.core.engine.event.MessagePushEventBuilder; import cn.axzo.workflow.core.engine.job.AsyncApproveTaskJobHandler; +import cn.axzo.workflow.core.engine.job.AsyncRejectTaskJobHandler; import cn.axzo.workflow.core.listener.BpmnAsyncJobEventListener; import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; @@ -45,6 +46,10 @@ public class ApproveErrorReporterEventListener implements BpmnAsyncJobEventListe TASK_COMPLETE_FAIL_NOT_EXISTS.getRespCode(), TASK_COMPLETE_FAIL_ASSIGN_NOT_SELF.getRespCode()); + private final List RESOLVE_HANDLER_TYPES = Arrays.asList( + AsyncApproveTaskJobHandler.TYPE, + AsyncRejectTaskJobHandler.TYPE); + @Override public boolean support(FlowableEngineEventType eventType) { return Objects.equals(JOB_MOVED_TO_DEADLETTER, eventType); @@ -60,8 +65,8 @@ public class ApproveErrorReporterEventListener implements BpmnAsyncJobEventListe JobInfo jobInfo = (JobInfo) jobEvent.getEntity(); String handlerType = jobInfo.getJobHandlerType(); //只处理审批类型任务 - if (!AsyncApproveTaskJobHandler.TYPE.equals(handlerType)) { - log.warn("非审批类型任务,handlerType:{}", handlerType); + if (!RESOLVE_HANDLER_TYPES.contains(handlerType)) { + log.warn("非审批类型任务,handlerType:{},event:{}", handlerType, JSONUtil.toJsonStr(flowableEvent)); return; } if (StringUtils.isBlank(jobInfo.getCustomValues())) {