Skip to main content

flowable 任务节点多实例使用

flowable 任务节点多实例使用

我们在使用Flowable 工作流引擎的时候，最常用的肯定是任务节点，因为在OA系统、审批系统、办公自动化系统中核心的处理就是流程的运转，在流程运转的时候，可能我们有这样的一个需求，在一个任务节点的时候，我们需要多个人对这个节点进行审批，比如实际中这样一个例子，假如是一个部门的投票，这个部门有5个人，那么当5个人都投票的时候大概分为如下几种：

  1. 部门所有人都去投票，当所有人都投票完成的时候，这个节点结束，流程运转到下一个节点。(所有的人都需要投票)

  2. 部门所有人都去投票,只要有任意2/3的人同意，这个节点结束，流程运转到下一个节点。(部分人投票只要满足条件就算完成)。

  3. 部门中有一个部门经理，只要部门经理投票过了，这个节点结束，流程运转到下一个节点（一票否决权）。

  4. 部门中根据职位不同，不同的人都不同的权重，当满足条件的时候，这个节点结束，流程运转到下一个节点。比如说所有的人员权重加起来是1，a有0.2的权重，其他的四个人分别是0.1的权重，我们可以配置权重达到0.3就可以走向下一个节点，换言之a的权重是其他人的2倍，那就是a的投票相当于2个人投票。这种需求还是很常见的。

  5. 部门所有人都去投票，a投票结束到b,b开始投票结束到c,一直如此，串行执行。最终到最后一个人再统计结果，决定流程的运转。

上面的五种情况，我们可以提取出来一些信息，我们的activiti 工作流引擎，必须支持如下功能，才能满足上面的需求：

  1. 任务节点可以配置自定义满足条件。

  2. 任务节点必须支持串行、并行。

  3. 任务节点必须支持可以指定候选人或者候选组。

  4. 任务节点必须支持可以循环的次数。

  5. 任务节点必须支持可以自定义权重。

  6. 任务节点必须支持加签、减签。(就是动态的修改任务节点的处理人)

因为实际上的需求可能比上面的几种情况更加的复杂，上面的6个满足条件，工作流支持前4个，后面的2个条件是不支持的，所以我们必须要扩展activiti 工作流引擎才能使用5、6等的功能。下面我们将详细的介绍前四种条件的使用，在掌握基本使用之后，我们在后面的章节中将详细的介绍，5、6这两种功能以及可能更加复杂的操作。

串行、并行配置

为了演示如何使用，我们采用由浅入深的使用，结合流程图、流程定义xml、以及代码和数据库的变化来阐释每一个配置的使用以及含义。

流程的详细定义如下图所示：

流程的详细定义xml如下:

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

<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:flowable="http://flowable.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.flowable.org/processdef">

  <process id="multiInstance" name="multiInstance" isExecutable="true">

    <documentation>multiInstance</documentation>

    <startEvent id="startEvent1"></startEvent>

    <userTask id="A" name="多实例测试" flowable:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4" xmlns:shareniu="http://www.shareniu.com/" shareniu:shareniuext="" shareniu:shareniuextboolen="false">

      <multiInstanceLoopCharacteristics isSequential="true">

        <loopCardinality>2</loopCardinality>

      </multiInstanceLoopCharacteristics>

    </userTask>

    <sequenceFlow id="sid-6D482A8A-F796-4E2B-AB2C-ABBFD2DA428D" sourceRef="startEvent1" targetRef="A"></sequenceFlow>

    <userTask id="shareniu-B" name="shareniu-B" xmlns:shareniu="http://www.shareniu.com/" shareniu:shareniuext="" shareniu:shareniuextboolen="false"></userTask>

    <sequenceFlow id="sid-BA8FC337-40DC-493B-805C-F213B7C4A17D" sourceRef="A" targetRef="shareniu-B"></sequenceFlow>

    <endEvent id="sid-4AC81F5B-49F8-4135-B68E-1C182D004080"></endEvent>

    <sequenceFlow id="sid-DF962BB4-EA4C-4D86-9A91-214EB2EC1A47" sourceRef="shareniu-B" targetRef="sid-4AC81F5B-49F8-4135-B68E-1C182D004080"></sequenceFlow>

  </process>

  <bpmndi:BPMNDiagram id="BPMNDiagram_multiInstance">

    <bpmndi:BPMNPlane bpmnElement="multiInstance" id="BPMNPlane_multiInstance">

      <bpmndi:BPMNShape bpmnElement="startEvent1" id="BPMNShape_startEvent1">

        <omgdc:Bounds height="30.0" width="30.0" x="100.0" y="130.0"></omgdc:Bounds>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape bpmnElement="A" id="BPMNShape_A">

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

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape bpmnElement="shareniu-B" id="BPMNShape_shareniu-B">

        <omgdc:Bounds height="80.0" width="100.0" x="315.0" y="120.0"></omgdc:Bounds>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape bpmnElement="sid-4AC81F5B-49F8-4135-B68E-1C182D004080" id="BPMNShape_sid-4AC81F5B-49F8-4135-B68E-1C182D004080">

        <omgdc:Bounds height="28.0" width="28.0" x="442.0" y="146.0"></omgdc:Bounds>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNEdge bpmnElement="sid-DF962BB4-EA4C-4D86-9A91-214EB2EC1A47" id="BPMNEdge_sid-DF962BB4-EA4C-4D86-9A91-214EB2EC1A47">

        <omgdi:waypoint x="414.9499999999902" y="160.0"></omgdi:waypoint>

        <omgdi:waypoint x="442.0" y="160.0"></omgdi:waypoint>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge bpmnElement="sid-BA8FC337-40DC-493B-805C-F213B7C4A17D" id="BPMNEdge_sid-BA8FC337-40DC-493B-805C-F213B7C4A17D">

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

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

        <omgdi:waypoint x="290.0" y="160.0"></omgdi:waypoint>

        <omgdi:waypoint x="314.99999999998477" y="160.0"></omgdi:waypoint>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge bpmnElement="sid-6D482A8A-F796-4E2B-AB2C-ABBFD2DA428D" id="BPMNEdge_sid-6D482A8A-F796-4E2B-AB2C-ABBFD2DA428D">

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

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

      </bpmndi:BPMNEdge>

    </bpmndi:BPMNPlane>

  </bpmndi:BPMNDiagram>


</definitions>

xml配置文件的部分含义如下：

  1. flowable:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4" 这个节点可以4个人审核。
  2. <loopCardinality>2</loopCardinality> 循环2次结束。
  3. <multiInstanceLoopCharacteristics isSequential="true"> 串行并行的配置。

串行的配置

修改<multiInstanceLoopCharacteristics isSequential="true"> 中的isSequential为true是串行，isSequential为false是并行。我们测试串行。下面的代码展示启动流程因为是以一个节点所以部署启动后，直接进入多实例任务。

流程的部署

        @Test

	public void addBytes() {

		byte[] bytes = IoUtil.readInputStream(

				ProcessengineTest.class.getClassLoader()

						.getResourceAsStream("com/shareniu/shareniu_flowable_study/bpmn/ch3/multiInstance.bpmn20.xml"),

				"multiInstance.bpmn20.xml");

		String resourceName = "multiInstance.bpmn";

		Deployment deployment = repositoryService.createDeployment().addBytes(resourceName, bytes).deploy();

		System.out.println(deployment);

	}

流程的启动

        @Test

	public void startProcessInstanceByKey() {

		String processDefinitionKey = "multiInstance";

		ProcessInstance startProcessInstanceByKey = runtimeService.startProcessInstanceByKey(processDefinitionKey);

		System.out.println(startProcessInstanceByKey);

	}

我们按照上面的步骤启动一个流程看一下数据库的变化。

ACT_RU_TASK表的数据有了如下图所示：

ACT_RU_IDENTITYLINK表的数据有了如下图所示：

ACT_RU_IDENTITYLINK权限表中，确实把我们设置的人员信息设置进去了，shareniu1,shareniu2,shareniu3,shareniu4现在就有代办信息了。

ACT_RU_VARIABLE表的数据有了如下图示：

上面重要的变量需要解释一下，要不然还真不好理解，多任务是怎么运转的。

  1. nrOfInstances 实例总数。

  2. nrOfCompletedInstances 当前还没有完成的实例 nr是number单词缩写 。

  3. loopCounter 已经循环的次数。

  4. nrOfActiveInstances 已经完成的实例个数。

下面我们结束一个任务看一下，流程走到那个节点了。

完成任务

        @Test

	public void complete() {

		String taskId="15011";

		taskService.complete(taskId);

	}

接下来看一下数据库表的变化。

ACT_RU_VARIABLE表的数据有了如下图所示：

上面我们仔细的发现，可以看到

nrOfCompletedInstances、loopCounter、nrOfActiveInstances都加1了，确实多任务就是参考这几个值的变化进行判断的。

因为我们设置了循环2次，所以我们看看ACT_RU_IDENTITYLINK还有一个任务，因为我们是并行处理的。

所以我们在结束新的任务看一下流程是不是真的结束了，如果结束了，那么我们循环次数的配置就是正确的。

完成任务

        @Test

	public void complete() {

		String taskId="17502";

		taskService.complete(taskId);

	}

下面看一下ACT_RU_TASK，里面没有任务信息了，所以侧面证明循环次数的配置就是正确的。

接下来我们测试并行任务。除了isSequential="false",其他的配置是一样的。

并行的配置测试

除了isSequential="false",其他的配置跟上面的串行是一样一样的。

重新部署测试，部署后我们启动一个新的流程测试。

ACT_RU_TASK表如下：

一次性的有2个任务需要处理，因为我们循环的是2次，所以直接就是2个。

ok串行、并行就讲解到这里。

串行、并行总结

我们配置的是循环2次，看以看到不管是并行还是串行，两个代办任务结束之后，流程直接跳转到下一个状态，但是

我们并没有配置结束条件，所以上面的例子，也可以看出来，如果不配置默认的通过条件，则默认条件是1，后面的源码章节会给大家说明这一点的。

通过条件的配置

在上面的串行、并行实例中，我们没有设置通过条件，但是程序按照配置的循环的次数，然后跳转到了下一个状态，可以侧面印证，如果不配置通过条件则默认值就是1.

下面的代码详细的介绍通过条件的配置，具体的配置代码如下：

<process id="multiInstance" name="multiInstance"
isExecutable="true">

		<documentation>multiInstance</documentation>

		<startEvent id="startEvent1"></startEvent>

		<userTask id="A" name="多实例测试"

			flowable:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4">

			<multiInstanceLoopCharacteristics

				isSequential="true">

				<loopCardinality>4</loopCardinality>

				<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

			</multiInstanceLoopCharacteristics>

		</userTask>

		<sequenceFlow

			id="sid-6D482A8A-F796-4E2B-AB2C-ABBFD2DA428D" sourceRef="startEvent1"

			targetRef="A"></sequenceFlow>

		<userTask id="shareniu-B" name="shareniu-B"

			xmlns:shareniu="http://www.shareniu.com/" shareniu:shareniuext=""

			shareniu:shareniuextboolen="false"></userTask>

		<sequenceFlow

			id="sid-BA8FC337-40DC-493B-805C-F213B7C4A17D" sourceRef="A"

			targetRef="shareniu-B"></sequenceFlow>

		<endEvent id="sid-4AC81F5B-49F8-4135-B68E-1C182D004080"></endEvent>

		<sequenceFlow

			id="sid-DF962BB4-EA4C-4D86-9A91-214EB2EC1A47" sourceRef="shareniu-B"

			targetRef="sid-4AC81F5B-49F8-4135-B68E-1C182D004080"></sequenceFlow>

	</process>

配置描述

<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

nrOfCompletedInstances、nrOfInstances 变量描述上面已经描述了，我们这里设置的条件是大于1/4的人完成任务，任务就结束了。下面我们代码部署流程，启动流程后进行测试：

ACT_RU_TASK表如下：

我们随便结束一个任务，看一下ACT_RU_TASK表变化。

        @Test

	public void complete() {

		String taskId="40003";

		taskService.complete(taskId);

	}

执行上面的代码，我们很神奇的发现，ACT_RU_TASK表中的其他任务没有了，因为我们配置了4个人，通过条件是1/4,所以任意一个人结束了，流程就结束了。这里我们测试的是并行，串行也是一样的，读者可以自行测试验证。

动态的配置

上面的几种方式，我们定义xml的时候，循环的次数是固定写在xml中的，也就是说我们配置的是循环2次，那么所有的流程实例都是循环2次，这样就不灵活了，程序当然是灵活了比较好，所以在实际开发中，我们可以使用下面的这种方式操作，使程序更加的灵活。

程序的xml配置如下所示：

<process id="multiInstance" name="multiInstance"

		isExecutable="true">

		<documentation>multiInstance</documentation>

		<startEvent id="startEvent1"></startEvent>

		<userTask id="A" name="多实例测试" flowable:assignee="${assignee}">

			<multiInstanceLoopCharacteristics

				isSequential="false" flowable:collection="assigneeList"

				flowable:elementVariable="assignee">

				<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}

				</completionCondition>

			</multiInstanceLoopCharacteristics>

		</userTask>

		<sequenceFlow

			id="sid-6D482A8A-F796-4E2B-AB2C-ABBFD2DA428D" sourceRef="startEvent1"

			targetRef="A"></sequenceFlow>

		<userTask id="shareniu-B" name="shareniu-B"

			xmlns:shareniu="http://www.shareniu.com/" shareniu:shareniuext=""

			shareniu:shareniuextboolen="false"></userTask>

		<sequenceFlow

			id="sid-BA8FC337-40DC-493B-805C-F213B7C4A17D" sourceRef="A"

			targetRef="shareniu-B"></sequenceFlow>

		<endEvent id="sid-4AC81F5B-49F8-4135-B68E-1C182D004080"></endEvent>

		<sequenceFlow

			id="sid-DF962BB4-EA4C-4D86-9A91-214EB2EC1A47" sourceRef="shareniu-B"

			targetRef="sid-4AC81F5B-49F8-4135-B68E-1C182D004080"></sequenceFlow>

</process>

动态配置如下所示：

<userTask id="usertask1" name="多实例任务" flowable:assignee="${assignee}">

      <multiInstanceLoopCharacteristics isSequential="false" activiti:collection="assigneeList" activiti:elementVariable="assignee">

        <completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

      </multiInstanceLoopCharacteristics>

</userTask>

参数说明：

  • activiti:assignee="${assignee}"

  • activiti:elementVariable="assignee" 多实例任务依赖上面的配置${assignee}

  • activiti:collection="assigneeList"

三个参数结合决定了，当前节点的处理人来自assigneeList集合，注意这里是集合信息而不是字符串，所以程序的运行时候变量的赋值，如下所示：

        @Test

	public void startProcessInstanceByKey() {

		Map<String, Object> vars = new HashMap<>();

		String[] v = { "shareniu1", "shareniu2", "shareniu3", "shareniu4" };

		vars.put("assigneeList", Arrays.asList(v));

		String processDefinitionKey = "multiInstance";

		ProcessInstance startProcessInstanceByKey = runtimeService.startProcessInstanceByKey(processDefinitionKey,

				vars);

		// Sys

ok了，测试一下，确实程序如预期的所示，大功告成。

总结

参数的使用总结

  1. flowable:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4" 这个节点可以4个人审核。

  2. loopCardinality>2</loopCardinality> 循环2次结束。

  3. <multiInstanceLoopCharacteristics isSequential="true"> 串行并行的配置。 <completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition> 完成条件的配置。

这里我们还可以得出一个结论：

如果使用串行方式操作nrOfActiveInstances 变量始终是1，因为并行的时候才会去+1操作。

遗留点

上面的程序已经解决了常用的问题，关于会签、加签、减签、退签、权重配置、自定义通过条件配置(条件自定义通过)

这些问题，这个章节还没有具体的实现，关于这些问题，由于本章内容有限，我们就后续章节讲解吧。

No Comments
Back to top