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

This commit is contained in:
wangli 2024-03-05 11:39:04 +08:00
parent 7fab02dbb0
commit 3c2cce823d

View File

@ -1,6 +1,7 @@
package cn.axzo.workflow.core.listener.impl; 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.ReceiveTaskExtInstCompleteEvent;
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.engine.event.ReceiveTaskExtInstEvent;
import cn.axzo.workflow.core.repository.entity.ExtAxHiTaskInst; import cn.axzo.workflow.core.repository.entity.ExtAxHiTaskInst;
@ -46,7 +47,7 @@ public class ReceiveTaskExtInstEventListener extends AbstractFlowableEventListen
saveExtTaskInst((ReceiveTaskExtInstCreateEvent) event); saveExtTaskInst((ReceiveTaskExtInstCreateEvent) event);
break; break;
case COMPLETE: case COMPLETE:
updateExtTaskInst((ReceiveTaskExtInstCreateEvent) event); updateExtTaskInst((ReceiveTaskExtInstCompleteEvent) event);
break; break;
default: default:
} }
@ -59,7 +60,7 @@ public class ReceiveTaskExtInstEventListener extends AbstractFlowableEventListen
return true; return true;
} }
private void updateExtTaskInst(ReceiveTaskExtInstCreateEvent event) { private void updateExtTaskInst(ReceiveTaskExtInstCompleteEvent event) {
ExtAxHiTaskInst entity = extAxHiTaskInstService.getByTaskId(event.getTaskId(), event.getProcessInstanceId()); ExtAxHiTaskInst entity = extAxHiTaskInstService.getByTaskId(event.getTaskId(), event.getProcessInstanceId());
if (Objects.nonNull(entity)) { if (Objects.nonNull(entity)) {
entity.setStatus(event.getResultEnum().getStatus()); entity.setStatus(event.getResultEnum().getStatus());