Activiti 用户任务并行动态多实例(多用户执行流…

2018-10-29 15:32:47来源：博客园阅读 ()

在很多情况下，我们需要多用户共同执行余下流程，比如开会流程：

领导发起开会，选择开会人员(多个)
每个开会人员接收到通知后需要签到(一名用户签到不会影响到另一位用户的签到)
签到完成后则流程结束

　　如果只使用代理(Assignee、Candidate users、Candidate groups) 将无法解决上述问题，因为即使使用 Candidate users ，但每个用户实际上还是在一个任务里面，其中一个用户完成任务，另外的用户任务也随之完成，此时，就需要用到多实例（多任务）。

以上面开会流程为例:

1. 创建模型

2. 模型相关配置

【领导发起开会】
由于具体是哪个领导发起开会有不确定性(只要是领导都可以发起)，所以需要设置代理人属性:
Assignee: ${leader} -- 此处采用变量形式

为了方便后面的【开发人员签到】流程，我们还需要在【领导发起开会】流程处设置一个流程执行监听器（此操作不是必须，此处只是为了解释动态多实例）,在Activiti中，配置监听器需要在模型和JAVA中都进行相应配置：
在JAVA中我们想要创建监听器只需要创建一个类，并实现系统监听器类 ExecutionListener 即可，代码如下:
package com.kenary.activiti.listener;

import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.ExecutionListener;

/**
 * 自定义监听器
 */
public class MyExecutionListener implements ExecutionListener {
    @Override
    public void notify(DelegateExecution delegateExecution) throws Exception {

    }
}
可见此时监听器没做任何处理，我们稍安勿躁。
接下来就是模型中的配置，由于我们想在领导指派了开会人员后进行监听，所以需要如下设置

其中 Event 代表事件触发类型，作用如其名
Class 代表监听器全路径，此处为 com.kenary.activiti.listener.MyExecutionListener，则是之前创建的 MyExecutionListener
监听器配置完成后领导发起开会流程就配置完成了！

【开会人员签到】
相对于【领导发起开会】流程，【开发人员签到】流程则需要配置更多东西

其中，集合(Collection) 设置的是存储开会人员集合的变量名，注意：此处不需要${},并且变量的值必须是 Collection的子类，即List、Set等

多实例类型设置的是并行、串行等方式

　　并行代表同时进行，如把任务分给5个人来处理，这5个人同时会收到任务，并且可以同时处理，不受各自的影响。

　　串行代表工作或任务由一个人完成后，再由另一个人去处理，直至全部完成，每个任务依赖于前一个任务完成。

元素变量(Element variable) 设置的是集合(Collection)每遍历一次设置的变量值的变量名，即迭代集合时存储集合里面单个元素的变量名，集合遍历时会根据内容创建任务

代理设置的是处理该任务的用户，由于集合每遍历一次就创建了一个任务，所以这里和领导发起开会流程无太大差异，指定代理人即可，不过代理人员需要使用元素变量(Element variable)(Item 迭代的值)

至此，流程配置基本完成

3. 部署流程

import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;

......



private RepositoryService repositoryService;

......


Deployment deployment = repositoryService.createDeployment()
                    .name(modelData.getName())
                    .addString(processName, new String(bpmnBytes, "UTF-8"))
                    .deploy();
            modelData.setDeploymentId("99999");
            repositoryService.saveModel(modelData);

其中，99999 为模型id

4. 领导发起开会

import org.activiti.engine.RuntimeService;
.......

@Autowired
private RuntimeService runtimeService;

......

// 开始-》开启领导发起开会流程(指定领导)
Map<String,Object> p1 = new HashMap<>();
p1.put("leader","jjh");
runtimeService.startProcessInstanceByKey("10001",map);

其中，"jjh" 为设置的变量值，因为我内部通过用户名来区分，所以直接设置 jjh

 runtimeService.startProcessInstanceByKey("10001",map);   为启动流程,10001 为流程id

当这步执行完成后，我们来查询属于 jjh 的任务

5. 开会人员签到
开会人员签到需要设置多个用户

import org.activiti.engine.TaskService;

.......

@Autowired
private TaskService taskService;
.......

Map<String,Object> map = new HashMap<>();
map.put("assigneeList","jjh,yxc");
// 完成任务

teskService.complete("75167", map);

可以看见，我们的用户设置了多个，并且使用逗号隔开，但是刚才也介绍了 集合(Colloection) 必须是 Collection的子类，也就是 List、Set等，而String不是

所以此时可以回到监听器，并将其改为：

public class MyExecutionListener implements ExecutionListener {
    @Override
    public void notify(DelegateExecution delegateExecution) throws Exception {
        String assigneeList = String.valueOf(delegateExecution.getVariable("assigneeList"));
        if(assigneeList != null){
            // 根据逗号分割并以数组形式重新设置进去
            delegateExecution.setVariable("assigneeList", Arrays.asList(assigneeList.split(",")));
        }
    }
}