博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Activiti 用户任务并行动态多实例(多用户执行流程)
阅读量:5156 次
发布时间:2019-06-13

本文共 3409 字,大约阅读时间需要 11 分钟。

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

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

  如果只使用代理(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
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
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(",")));        }    }}

作用是将变量中的字符串根据逗号分割成了集合,其实此步骤完全多余,在设置变量时直接设置集合即可,但是为了顺带加上监听器的作用,所以则以此种方式说明

 

6. 效果预览

当任务执行后,我们分别看看 jjh 和 yxc 双用户的任务

可以看到,两个不同的用户的任务id是不相同的,所以他们不会互不干扰,Activiti动态多实例完成。

转载于:https://www.cnblogs.com/adversary/p/9854707.html

你可能感兴趣的文章
有关快速幂取模
查看>>
Linux运维必备工具
查看>>
字符串的查找删除
查看>>
NOI2018垫底记
查看>>
快速切题 poj 1002 487-3279 按规则处理 模拟 难度:0
查看>>
Codeforces Round #277 (Div. 2)
查看>>
【更新】智能手机批量添加联系人
查看>>
NYOJ-128前缀式计算
查看>>
淡定,啊。数据唯一性
查看>>
深入理解 JavaScript 事件循环(一)— event loop
查看>>
Hive(7)-基本查询语句
查看>>
注意java的对象引用
查看>>
C++ 面向对象 类成员函数this指针
查看>>
NSPredicate的使用,超级强大
查看>>
自动分割mp3等音频视频文件的脚本
查看>>
判断字符串是否为空的注意事项
查看>>
布兰诗歌
查看>>
js编码
查看>>
Pycharm Error loading package list:Status: 403错误解决方法
查看>>
steps/train_sat.sh
查看>>