网站开发代做,广州番禺区天气,服装印花图案网站,网站开发费用如何入账flowable流程结束触发监听器 | flowable流程结束获取结束节点 | flowable流程结束事件响应监听器
下面代码是该监听器是对每个到达结束事件后执行的。
原本的流程定义是如果其中任意某个节点进行了驳回#xff0c;则直接结束流程。
所以在每个节点的驳回对应的排他网关都设…flowable流程结束触发监听器 | flowable流程结束获取结束节点 | flowable流程结束事件响应监听器
下面代码是该监听器是对每个到达结束事件后执行的。
原本的流程定义是如果其中任意某个节点进行了驳回则直接结束流程。
所以在每个节点的驳回对应的排他网关都设置了EndEvent import cn.hutool.extra.spring.SpringUtil;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.flowable.bpmn.model.BpmnModel;
import org.flowable.bpmn.model.EndEvent;
import org.flowable.bpmn.model.FlowNode;
import org.flowable.common.engine.api.delegate.event.FlowableEvent;
import org.flowable.common.engine.api.delegate.event.FlowableEventListener;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.TaskService;
import org.flowable.engine.delegate.event.impl.FlowableEntityEventImpl;
import org.flowable.engine.impl.util.ProcessDefinitionUtil;
import org.flowable.engine.runtime.Execution;
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.Task;
import org.springframework.stereotype.Component;import java.util.List;/*** description 全局监听器判断流程是不是运行到了最后一个EndEvent* since 2024/1/15*/
Slf4j
Component
public class ProcessEndListener implements FlowableEventListener {Overridepublic void onEvent(FlowableEvent event) {log.info(ProcessEndListener:{}, JSON.toJSONString(event.getType()));TaskService taskService SpringUtil.getBean(TaskService.class);RuntimeService runtimeService SpringUtil.getBean(RuntimeService.class);FlowableEntityEventImpl flowableEntityEvent ((FlowableEntityEventImpl) event);ProcessInstance pi (ProcessInstance) flowableEntityEvent.getEntity();ListTask tasks taskService.createTaskQuery().active().processInstanceId(pi.getId()).list();Task t tasks.get(0);String bizKey pi.getBusinessKey();log.info(ProcessEndListener#bizKey:{}, bizKey);String procDefId pi.getProcessDefinitionId();ListExecution exes runtimeService.createExecutionQuery().processInstanceId(pi.getProcessInstanceId()).processDefinitionId(procDefId).executionId(t.getExecutionId()).list();String curActId exes.get(0).getActivityId();//获得当前执行器的活动IDBpmnModel bm ProcessDefinitionUtil.getBpmnModel(t.getProcessDefinitionId());FlowNode flowNode (FlowNode) bm.getFlowElement(curActId);//获得当前节点if (flowNode instanceof EndEvent) {//判断当前节点是否为结束事件if (flowNode.getId().equals(end)) {//end是自定义的EndEvent节点的ID//todo 通知回调log.info(当前节点是结束节点:{}, JSON.toJSONString(flowNode));}}}Overridepublic boolean isFailOnException() {return false;}Overridepublic boolean isFireOnTransactionLifecycleEvent() {return false;}Overridepublic String getOnTransaction() {return null;}}
百度关于该问题答案出来的几乎清一色全是同一个答案给了三种方法但是每个方法的代码都有他自定义的部分是不完整的东西。 下面是网上找的东西里面的flowableService是这个比玩意自定义的。
下面这段代码是被转载多次的代码 它监听的是指向结束事件的上一个节点。 也就是他的当前节点可能是最后一岗。 然后最后一岗—EndEvent
Component
public class ProcessEndListener implements FlowableEventListener {AutowiredFlowableService flowableService;Overridepublic void onEvent(FlowableEvent event) {// 当前节点任务实体,TaskEntity taskEntity (TaskEntity) ((FlowableEntityEventImpl) event).getEntity();String taskId taskEntity.getId();String curActId flowableService.getNodeId(taskId);String procDefId ProcUtils.getProcessDefinitionByTaskId(taskEntity.getId()).getId();Process process ProcessDefinitionUtil.getProcess(procDefId);//遍历整个process,找到endEventId是什么与当前taskId作对比ListFlowElement flowElements (ListFlowElement) process.getFlowElements();for (FlowElement flowElement : flowElements) {if (flowElement instanceof SequenceFlow) {SequenceFlow flow (SequenceFlow) flowElement;FlowElement sourceFlowElement flow.getSourceFlowElement();FlowElement targetFlowElement flow.getTargetFlowElement();//如果当前边的下一个节点是endEvent那么获取当前边if(targetFlowElement instanceof EndEvent sourceFlowElement.getId().equals(curActId)){System.out.println(下一个是结束节点);}}}}Overridepublic boolean isFailOnException() {return false;}Overridepublic boolean isFireOnTransactionLifecycleEvent() {return false;}Overridepublic String getOnTransaction() {return null;}
}用我上面的代码实现示例这个b的代码 Overridepublic void onEvent(FlowableEvent event) {log.info(ProcessEndListener:{}, JSON.toJSONString(event.getType()));TaskService taskService SpringUtil.getBean(TaskService.class);RuntimeService runtimeService SpringUtil.getBean(RuntimeService.class);FlowableEntityEventImpl flowableEntityEvent ((FlowableEntityEventImpl) event);ProcessInstance pi (ProcessInstance) flowableEntityEvent.getEntity();ListTask tasks taskService.createTaskQuery().active().processInstanceId(pi.getId()).list();Task t tasks.get(0);String bizKey pi.getBusinessKey();log.info(ProcessEndListener#bizKey:{}, bizKey);String procDefId pi.getProcessDefinitionId();ListExecution exes runtimeService.createExecutionQuery().processInstanceId(pi.getProcessInstanceId()).processDefinitionId(procDefId).executionId(t.getExecutionId()).list();String curActId exes.get(0).getActivityId();BpmnModel bm ProcessDefinitionUtil.getBpmnModel(t.getProcessDefinitionId());FlowNode flowNode (FlowNode) bm.getFlowElement(curActId);//如果当前节点是最后一岗ListSequenceFlow outFlows flowNode.getOutgoingFlows(); //此处需要获取他的下一个节点是否为EndEventfor (SequenceFlow sequenceFlow : outFlows) { //遍历outFlowssequenceFlow.getTargetFlowElement();//用该flow节点与EndEvent进行对比判断也就是当前节点的下一个节点和EndEvent判断是否一致是则说明当前节点就是最后一岗且它的下一个节点就是结束事件}}
