wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 业务节点事件状态修复

Browse Source
This commit is contained in:
wangli 2024-03-05 11:31:11 +08:00
parent b94f38434e
commit 7fab02dbb0
2 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ReceiveTaskExtInstCreateEvent.java
View File

@ -3,7 +3,7 @@ package cn.axzo.workflow.core.engine.event;
import cn.axzo.workflow.common.enums.BpmnProcessInstanceResultEnum; import cn.axzo.workflow.common.enums.BpmnProcessInstanceResultEnum;
import org.flowable.common.engine.api.delegate.event.FlowableEventType; import org.flowable.common.engine.api.delegate.event.FlowableEventType;
import static cn.axzo.workflow.core.engine.event.ReceiveTaskEventType.COMPLETE; import static cn.axzo.workflow.core.engine.event.ReceiveTaskEventType.CREATE;
/** /**
* 接收任务的扩展任务记录表创建的事件实现 * 接收任务的扩展任务记录表创建的事件实现
@ -44,7 +44,7 @@ public class ReceiveTaskExtInstCreateEvent implements ReceiveTaskExtInstEvent {
@Override @Override
public FlowableEventType getType() { public FlowableEventType getType() {
return COMPLETE; return CREATE;
} }
} }

27
workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstventListener.java → workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstEventListener.java
View File

@ -2,6 +2,7 @@ package cn.axzo.workflow.core.listener.impl;
import cn.axzo.workflow.core.engine.event.ReceiveTaskEventType; import cn.axzo.workflow.core.engine.event.ReceiveTaskEventType;
import cn.axzo.workflow.core.engine.event.ReceiveTaskExtInstCreateEvent; import cn.axzo.workflow.core.engine.event.ReceiveTaskExtInstCreateEvent;
import cn.axzo.workflow.core.engine.event.ReceiveTaskExtInstEvent;
import cn.axzo.workflow.core.repository.entity.ExtAxHiTaskInst; import cn.axzo.workflow.core.repository.entity.ExtAxHiTaskInst;
import cn.axzo.workflow.core.service.ExtAxHiTaskInstService; import cn.axzo.workflow.core.service.ExtAxHiTaskInstService;
import com.google.common.collect.ImmutableSet; import com.google.common.collect.ImmutableSet;
@ -26,7 +27,7 @@ import static cn.axzo.workflow.core.engine.event.ReceiveTaskEventType.CREATE;
@AllArgsConstructor @AllArgsConstructor
@Component @Component
@Slf4j @Slf4j
public class ReceiveTaskExtInstventListener extends AbstractFlowableEventListener { public class ReceiveTaskExtInstEventListener extends AbstractFlowableEventListener {
private final ExtAxHiTaskInstService extAxHiTaskInstService; private final ExtAxHiTaskInstService extAxHiTaskInstService;
public static final Set<ReceiveTaskEventType> SUPPORT_EVENTS = public static final Set<ReceiveTaskEventType> SUPPORT_EVENTS =
ImmutableSet.<ReceiveTaskEventType>builder() ImmutableSet.<ReceiveTaskEventType>builder()
@ -36,17 +37,19 @@ public class ReceiveTaskExtInstventListener extends AbstractFlowableEventListene
@Override @Override
public void onEvent(FlowableEvent flowableEvent) { public void onEvent(FlowableEvent flowableEvent) {
if (flowableEvent instanceof ReceiveTaskExtInstCreateEvent) { if (flowableEvent instanceof ReceiveTaskExtInstEvent) {
ReceiveTaskExtInstCreateEvent event = (ReceiveTaskExtInstCreateEvent) flowableEvent; ReceiveTaskExtInstEvent event = (ReceiveTaskExtInstEvent) flowableEvent;
ReceiveTaskEventType type = (ReceiveTaskEventType) event.getType(); ReceiveTaskEventType eventType = (ReceiveTaskEventType) flowableEvent.getType();
switch (type) { if (SUPPORT_EVENTS.contains(eventType)) {
case CREATE: switch (eventType) {
saveExtTaskInst(event); case CREATE:
break; saveExtTaskInst((ReceiveTaskExtInstCreateEvent) event);
case COMPLETE: break;
updateExtTaskInst(event); case COMPLETE:
break; updateExtTaskInst((ReceiveTaskExtInstCreateEvent) event);
default: break;
default:
}
} }
} }
} }