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

update - 业务节点"不设置审批人"配置时, 根据审批方式调整执行监听的配置是否要添加 engineExecutionStartListener

Browse Source
This commit is contained in:
wangli 2024-02-05 11:29:01 +08:00
parent ce61f8f56d
commit a1d0dc424a
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
workflow-engine-core/src/main/java/cn/axzo/workflow/core/converter/json/ReceiveTaskJsonConverter.java
View File

@ -1,5 +1,6 @@
package cn.axzo.workflow.core.converter.json; package cn.axzo.workflow.core.converter.json;
import cn.axzo.workflow.common.enums.ApprovalMethodEnum;
import cn.axzo.workflow.common.model.request.bpmn.BpmnJsonNode; import cn.axzo.workflow.common.model.request.bpmn.BpmnJsonNode;
import cn.axzo.workflow.common.model.request.bpmn.BpmnJsonNodeProperty; import cn.axzo.workflow.common.model.request.bpmn.BpmnJsonNodeProperty;
import org.flowable.bpmn.model.ExtensionAttribute; import org.flowable.bpmn.model.ExtensionAttribute;
@ -35,19 +36,24 @@ public class ReceiveTaskJsonConverter extends AbstractBpmnJsonConverter<ReceiveT
// "设置审批人" // "设置审批人"
setApprovalExtensionElement(node, receiveTask); setApprovalExtensionElement(node, receiveTask);
setExecutionListeners(receiveTask);
// 设置执行监听
setExecutionListeners(node, receiveTask);
return receiveTask; return receiveTask;
} }
private static void setExecutionListeners(ReceiveTask receiveTask) { private static void setExecutionListeners(BpmnJsonNode node, ReceiveTask receiveTask) {
List<FlowableListener> executionListeners = new ArrayList<>(); List<FlowableListener> executionListeners = new ArrayList<>();
// 设置执行监听
FlowableListener executionListener = new FlowableListener(); if (Objects.nonNull(node.getProperty()) && Objects.equals(node.getProperty().getApprovalMethod(),
executionListener.setEvent(BaseExecutionListener.EVENTNAME_START); ApprovalMethodEnum.nobody)) {
executionListener.setImplementationType(IMPLEMENTATION_TYPE_DELEGATEEXPRESSION); FlowableListener executionListener = new FlowableListener();
executionListener.setImplementation("${engineExecutionStartListener}"); executionListener.setEvent(BaseExecutionListener.EVENTNAME_START);
executionListeners.add(executionListener); executionListener.setImplementationType(IMPLEMENTATION_TYPE_DELEGATEEXPRESSION);
executionListener.setImplementation("${engineExecutionStartListener}");
executionListeners.add(executionListener);
}
FlowableListener activityStartListener = new FlowableListener(); FlowableListener activityStartListener = new FlowableListener();
activityStartListener.setEvent(BaseExecutionListener.EVENTNAME_START); activityStartListener.setEvent(BaseExecutionListener.EVENTNAME_START);