From 16b2c80ab75599ea7ca4ef69a466b06245731ffd Mon Sep 17 00:00:00 2001 From: yangqicheng Date: Mon, 27 May 2024 11:47:45 +0800 Subject: [PATCH] =?UTF-8?q?update=20-=20REQ-2324-=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E8=BD=AC=E6=8D=A2job=E5=86=85=E5=AE=B9=E6=8A=A5=E9=94=99?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../engine/listener/EngineAsyncJobEventListener.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java index 49dc85d13..a5c667986 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java @@ -9,10 +9,9 @@ import com.google.common.collect.ImmutableSet; import lombok.extern.slf4j.Slf4j; import org.flowable.common.engine.api.delegate.event.FlowableEngineEventType; import org.flowable.common.engine.api.delegate.event.FlowableEvent; -import org.flowable.common.engine.impl.event.FlowableEngineEventImpl; import org.flowable.common.engine.impl.event.FlowableEntityEventImpl; import org.flowable.engine.delegate.event.AbstractFlowableEngineEventListener; -import org.flowable.job.service.impl.persistence.entity.AbstractJobEntity; +import org.flowable.job.service.impl.persistence.entity.JobEntity; import org.slf4j.MDC; import org.springframework.beans.factory.ObjectProvider; import org.springframework.stereotype.Component; @@ -56,7 +55,7 @@ public class EngineAsyncJobEventListener extends AbstractFlowableEngineEventList StopWatch stopWatch = new StopWatch("EngineAsyncJobEventListener"); stopWatch.start("async-job-event-listener"); if (ASYNC_JOB_EVENTS.contains(flowableEvent.getType())) { - if (flowableEvent instanceof FlowableEngineEventImpl) { + if (flowableEvent instanceof FlowableEntityEventImpl) { resolveJobInfoBeforeOperate((FlowableEntityEventImpl) flowableEvent); } getOrderedListeners().forEach(i -> { @@ -81,8 +80,8 @@ public class EngineAsyncJobEventListener extends AbstractFlowableEngineEventList } Object entity = flowableEvent.getEntity(); log.info("resolve job info,eventInfo:{},jobEntity:{}", JSONUtil.toJsonStr(flowableEvent), entity); - if (entity instanceof AbstractJobEntity) { - AbstractJobEntity jobInfo = (AbstractJobEntity) entity; + if (entity instanceof JobEntity) { + JobEntity jobInfo = (JobEntity) entity; String customValues = jobInfo.getCustomValues(); if (AsyncJobUtils.isWrappedCustomValues(customValues)) { AsyncJobUtils.WrappedJobCustomValuesInfo wrappedInfo = AsyncJobUtils.convert2WrappedCustomValuesInfo(customValues);