首页 > 学术百科

flowable特殊多实例并行例子解决方案

flowable特殊多实例并⾏例⼦解决⽅案

场景描述：

由于公司需要在流程图中明确的显⽰不同部门的流程情况，⽽这些部门是并⾏的，最后要有系统⾃动判断这些节点的审核结果给出⼀个最终

的结果，来确定流程的⾛向，如果是单个审核节点的话可以使⽤多实例(设置多实例结束条件即可)，但是通常业务中包含着不⽌⼀个节点，

这种情况我们可以使⽤⼦流程解决，也可以使⽤下边我要介绍的⽅案，这个⽅案我只画了每个并⾏节点的⼀个审核，但是实际通常会有多个，

我只做例⼦讲解，就不画多个了。

注意：如果⼤家有更好的解决，请⼤家在下⽅留⾔，谢谢。(还有⼀种简单的解决⽅案是设置任务过期时间)

流程图如下

流程图xml

<?xml version="1.0" encoding="UTF-8"?>

<modeler:initiator-can-complete xmlns:modeler="/modeler"><![CDATA[false]]></modeler:initiator-can-complete>

</extensionElements>

</userTask>

<modeler:initiator-can-complete xmlns:modeler="/modeler"><![CDATA[false]]></modeler:initiator-can-complete>

</extensionElements>

</userTask>

<flowable:taskListener event="create" class="com.spark.platform.flowable.biz.listener.MyTaskListener"></flowable:taskListener>

<modeler:initiator-can-complete xmlns:modeler="/modeler"><![CDATA[false]]></m

odeler:initiator-can-complete>

</extensionElements>

</userTask>

<modeler:initiator-can-complete xmlns:modeler="/modeler"><![CDATA[false]]></modeler:initiator-can-complete>

</extensionElements>

</userTask>

</sequenceFlow>

<sequenceFlow id="sid-97861805-692B-48CA-BBC8-C3BCF604E7AB" name="通过" sourceRef="sid-E2A8AD68-FA23-4D9B-8CA4-863CA08E483A" targe <conditionExpression xsi:t

ype="tFormalExpression"><![CDATA[${GROUP_LEADER_APPROVE_SUBMIT_VALUE=='GROUP_EDITOR'}]]></conditionExp </sequenceFlow>

</sequenceFlow>

</process>

<bpmndi:BPMNDiagram id="BPMNDiagram_audit-article">

<bpmndi:BPMNPlane bpmnElement="audit-article" id="BPMNPlane_audit-article">

<bpmndi:BPMNShape bpmnElement="start" id="BPMNShape_start">

<omgdc:Bounds height="30.0" width="30.0" x="10.0" y="150.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="group_leader_approve" id="BPMNShape_group_leader_approve">

<omgdc:Bounds height="80.0" width="100.0" x="105.0" y="125.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="sid-6E2896F8-BF54-4F7B-BF14-DF9C850E7BDE" id="BPMNShape_sid-6E2896F8-BF54-4F7B-BF14-DF9C850E <omgdc:Bounds height="40.0" width="40.0" x="370.0" y="145.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="editor1_approval" id="BPMNShape_editor1_approval">

<omgdc:Bounds height="80.0" width="100.0" x="460.0" y="45.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="editor2_approval" id="BPMNShape_editor2_approval">

<omgdc:Bounds height="80.0" width="100.0" x="460.0" y="180.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="sid-56FAADCB-CE8E-4F10-834C-EB29D9A30F72" id="BPMNShape_sid-56FAADCB-CE8E-4F10-834C-EB29D9A <omgdc:Bounds height="40.0" width="40.0" x="593.5" y="145.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="system_judge" id="BPMNShape_system_judge">

<omgdc:Bounds height="80.0" width="100.0" x="678.5" y="125.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="sid-AC406909-E994-4CD0-9AEC-901ABB27688E" id="BPMNShape_sid-AC406909-E994-4CD0-9AEC-901ABB27 <omgdc:Bounds height="40.0" width="40.0" x="823.5" y="145.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="submit_approval" id="BPMNShape_submit_approval">

<omgdc:Bounds height="80.0" width="100.0" x="222.5" y="270.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

fastdb<bpmndi:BPMNShape bpmnElement="pass" id="BPMNShape_pass">

<omgdc:Bounds height="28.0" width="28.0" x="908.5" y="151.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="sid-E2A8AD68-FA23-4D9B-8CA4-863CA08E483A" id="BPMNShape_sid-E2A8AD68-FA23-4D9B-8CA4-863CA08E <omgdc:Bounds height="40.0" width="40.0" x="255.0" y="145.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="sid-A9213851-D3FA-450B-8A9D-FCD4C54F2440" id="BPMNShape_sid-A9213851-D3FA-450B-8A9D-FCD4C54F <omgdc:Bounds height="40.0" width="40.0" x="135.0" y="290.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="over" id="BPMNShape_over">

<omgdc:Bounds height="28.0" width="28.0" x="141.0" y="390.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNEdge bpmnElement="sid-9D742EBD-78A0-4CBE-884C-BBE85340FC5A" id="BPMNEdge_sid-9D742EBD-78A0-4CBE-884C-BBE85340F <omgdi:waypoint x="390.5" y="184.43264652014656"></omgdi:waypoint>

执法公信力<omgdi:waypoint x="390.5" y="220.0"></omgdi:waypoint>

<omgdi:waypoint x="460.0" y="220.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-E2AE9738-1E1E-4C66-853C-8E8E50E7D5BD" id="BPMNEdge_sid-E2AE9738-1E1E-4C66-853C-8E8E50E7D5 <omgdi:waypoint x="274.66101694915255" y="184.6118644067797"></omgdi:waypoint>

<omgdi:waypoint x="273.1887931034483" y="270.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-32CBC3C6-757D-41CC-AC34-3CC7E71C226A" id="BPMNEdge_sid-32CBC3C6-757D-41CC-AC34-3CC7E71C <omgdi:waypoint x="390.5" y="145.5"></omgdi:waypoint>

<omgdi:waypoint x="390.5" y="85.0"></omgdi:waypoint>

参与式管理<omgdi:waypoint x="460.0" y="85.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-88320958-56A0-458B-A8DC-D6EB60D548BA" id="BPMNEdge_sid-88320958-56A0-458B-A8DC-D6EB60D548 <omgdi:waypoint x="778.4499999999999" y="165.0"></omgdi:waypoint>

远程教育论坛

<omgdi:waypoint x="823.5" y="165.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-38F4E395-FC66-4BA5-B5E5-FB4C217FF3DC" id="BPMNEdge_sid-38F4E395-FC66-4BA5-B5E5-FB4C217FF3 <omgdi:waypoint x="863.4373893805309" y="165.0"></omgdi:waypoint>

<omgdi:waypoint x="908.5" y="165.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-F0149E5B-E9A1-49C9-A243-638C4E21E378" id="BPMNEdge_sid-F0149E5B-E9A1-49C9-A243-638C4E21E37 <omgdi:waypoint x="39.94999891869115" y="165.0"></omgdi:waypoint>

<omgdi:waypoint x="105.0" y="165.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-C91352A8-84D9-474E-89A5-0AF0EFC5F58B" id="BPMNEdge_sid-C91352A8-84D9-474E-89A5-0AF0EFC5F5 <omgdi:waypoint x="559.9499999999681" y="220.0"></omgdi:waypoint>

<omgdi:waypoint x="613.5" y="220.0"></omgdi:waypoint>

<omgdi:waypoint x="613.5" y="184.9180783242259"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-7492310C-5318-4379-8DEB-53D6CA7E6AD9" id="BPMNEdge_sid-7492310C-5318-4379-8DEB-53D6CA7E6A <omgdi:waypoint x="843.5" y="184.94312543073747"></omgdi:waypoint>

<omgdi:waypoint x="843.5" y="310.0"></omgdi:waypoint>

<omgdi:waypoint x="322.45000000000005" y="310.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-97861805-692B-48CA-BBC8-C3BCF604E7AB" id="BPMNEdge_sid-97861805-692B-48CA-BBC8-C3BCF604E7 <omgdi:waypoint x="294.94133362293655" y="165.0"></omgdi:waypoint>

<omgdi:waypoint x="370.0" y="165.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-89703E3C-E4C1-4DBF-9462-2DAE98EF4D55" id="BPMNEdge_sid-89703E3C-E4C1-4DBF-9462-2DAE98EF4D <omgdi:waypoint x="559.9499999999823" y="85.0"></omgdi:waypoint>

<omgdi:waypoint x="613.5" y="85.0"></omgdi:waypoint>

<omgdi:waypoint x="613.5" y="145.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-C39C6BE4-57FF-4153-8C1E-1D97D37146DE" id="BPMNEdge_sid-C39C6BE4-57FF-4153-8C1E-1D97D37146 <omgdi:waypoint x="155.0" y="329.93939957492034"></omgdi:waypoint>

<omgdi:waypoint x="155.0" y="390.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-FF7E4059-6000-4335-8F8E-AC2295A8DB5B" id="BPMNEdge_sid-FF7E4059-6000-4335-8F8E-AC2295A8DB5 <omgdi:waypoint x="633.4413336229366" y="165.0"></omgdi:waypoint>

<omgdi:waypoint x="678.5" y="165.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-71206A86-A1DC-42CE-92FF-179507B2AC04" id="BPMNEdge_sid-71206A86-A1DC-42CE-92FF-179507B2AC <omgdi:waypoint x="222.5" y="310.0"></omgdi:waypoint>

<omgdi:waypoint x="174.9084540032961" y="310.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-606C543E-F974-42F7-8BBE-86E19E6A40FC" id="BPMNEdge_sid-606C543E-F974-42F7-8BBE-86E19E6A40F

<omgdi:waypoint x="204.95" y="165.0"></omgdi:waypoint>

<omgdi:waypoint x="255.0" y="165.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="sid-8882D268-789B-4A66-99A8-513C8F19E21C" id="BPMNEdge_sid-8882D268-789B-4A66-99A8-513C8F19E21 <omgdi:waypoint x="155.0" y="290.0"></omgdi:waypoint>

<omgdi:waypoint x="155.0" y="204.95"></omgdi:waypoint>

</bpmndi:BPMNEdge>

</bpmndi:BPMNPlane>

</bpmndi:BPMNDiagram>

</definitions>

此时我们可以看到主编1和主编2 是并⾏审核的，当他们审核完的时候要有有⼀个系统判断来判断最终的审核结果，决定流程的⾛向。

解决⽅案：

在系统判断这个节点的时候我们就要是使⽤任务：TaskListener

/**

* @ProjectName: spark-platform

* @Package: com.spark.platform.flowable.biz.listener

* @ClassName: TaskListener

* @Author: wangdingfeng

* @Description: 任务

* @Date: 2020/4/8 14:22

* @Version: 1.0

秋天的雨教学实录

@Slf4j

@Component

public class MyTaskListener implements TaskListener {

@Override

public void notify(DelegateTask delegateTask) {

String eventName = EventName();

switch (eventName) {

case BaseTaskListener.EVENTNAME_CREATE:

log.info("当前监听创建事件:create");

//开启消息发送线程

Thread thread = new Thread(

new MessageRunnableTask(delegateTask));

thread.start();

break;

case BaseTaskListener.EVENTNAME_ASSIGNMENT:

log.info("当前监听指派事件:assignment");

break;

case BaseTaskListener.EVENTNAME_COMPLETE:

log.info("当前监听完成事件:complete");

break;

case BaseTaskListener.EVENTNAME_DELETE:

log.info("当前监听销毁事件:delete");

break;

default:

break;

}

TaskListener 虽然是可以做监听，但是由于此时任务数据还没有在数据库中落地，所以⽆法获取到当前节点的taskID，不能⾃动推动流程

的⾛向，所以我加了⼀个线程⽤来刷此个节点的taskId，代码如下

/**

* @ProjectName: spark-platform

* @Package: com.spark.platform.flowable.biz.listener

* @ClassName: RunnableTask

* @Author: wangdingfeng

* @Description: 线程

* @Date: 2020/4/14 11:07

* @Version: 1.0

@Slf4j

public class MessageRunnableTask implements Runnable {

冷窝

private DelegateTask delegateTask;

MessageRunnableTask(DelegateTask delegateTask) {

this.delegateTask = delegateTask;

}

@Override

public void run() {

Task task = getTask(delegateTask);

StringRedisTemplate redisTemplate = Bean(StringRedisTemplate.class);

TaskVO taskVO = new TaskVO();

taskVO.ProcessVariables());

}

/**

* 递归查询直到查询到task任务已经落地为⽌，然后发布消息

* @param delegateTask

* @return

private Task getTask(DelegateTask delegateTask) {

ActTaskQueryService actTaskQueryService = Bean(ActTaskQueryService.class);

Task task = null;

while (null == task){

log.info("开是休眠40S");

ThreadUtil.sleep(1000 * 40);

task = ateTaskQuery().ProcessInstanceId()).Assignee()).incl }

log.info("代办任务数据库已经落地----");

return task;

}

由于通常我们的业务代码不会在⼯作流这个服务中判断，通常由业务发起服务器判断，所以我使⽤了消息订阅。此⽰例代码⽤的是redis消

息发布订阅，实际开发中不要使⽤redis，由于redis的消息队列⼀旦消费者不存在，就会出现消息丢失的情况，请使⽤rabbitmq这些消息

队列。

Redis 订阅处理消息

本文发布于:2024-09-21 08:39:54，感谢您对本站的认可！

本文链接：https://www.17tex.com/xueshu/99320.html

上一篇：制作笛子的方法

下一篇：Redis必学（三）redis多节点集

标签：判断流程节点消息审核任务监听

留言与评论（共有 0 条评论）