activiti中多实例任务中动态添加用户ID、删除用户、委派
2016-04-07 21:25
519 查看
首先得说下这个其实名不副实,因为多实例任务不太容易实现动态增加用户ID,到底要创建几个task,在启动流程的时候已经完成了。后来在朋友的提示下换了个方式。
第一、流程图:
第二、排他网管向User Task的连接需要增加一个表达式,比如:${endFlat=="false"},排他网关朝着结束节点的连接线需要增加${endFlag=="true"}。
第三、增加一个创建UserTask时触发的监听器,代码如:
package com.yilone.component.workflow;
import java.util.Arrays;
import java.util.List;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;
/**
* 分配用户
*
*/
public class UserAssignerListener implements TaskListener {
private static final long serialVersionUID = 778211731749616447L;
List<String> users = Arrays.asList("zc","ls","zt");
@Override
public void notify(DelegateTask delegateTask) {
String endFlag = (String)delegateTask.getVariable("endFlag"); //这里的逻辑可以扩展,动态去取用户,可以增加用户,或者替换用户,也或者是删除用户。
if(endFlag.equals("false")) {
int index = (Integer)delegateTask.getVariable("index");
String user = users.get(index);
delegateTask.setAssignee(user);
// 设置结束工作流标志
if(index == (users.size() - 1)) {
delegateTask.setVariable("endFlag", "true");
}
}
}
}
第三:测试代码如:
public void multleInstance() {
Map<String, Object> map = new HashMap<String, Object>();
map.put("index", 0); // 放入变量表示完成了第几个task;
map.put("endFlag", "false");
ProcessUtil.getProcessInstanceByKey("approve5", null, map);
// 获取zc的用户
List<Task> taskList = TaskUtil.getTaskOfUser("zc", null);
for(Task tempTask : taskList) {
System.out.println("zc任务是:" + tempTask.getName());
Map<String, Object> map1 = new HashMap<String, Object>();
map1.put("index", 1);
TaskUtil.completeTask(tempTask.getId(), map1);
}
// 获取ls的用户,这个在count变量为1的时候在UserGetService中动弹增加的
List<Task> taskList2 = TaskUtil.getTaskOfUser("ls", null);
for(Task tempTask : taskList2) {
System.out.println("ls任务是:" + tempTask.getName());
Map<String, Object> map2 = new HashMap<String, Object>();
map2.put("index", 2);
TaskUtil.completeTask(tempTask.getId(), map2);
}
// 获取zt的用户,这个在count变量为1的时候在这个在UserGetService中动弹增加的
List<Task> taskList3 = TaskUtil.getTaskOfUser("zt", null);
for(Task tempTask : taskList3) {
System.out.println("zt任务是:" + tempTask.getName());
TaskUtil.completeTask(tempTask.getId(), null);
}
}
这个思路的核心思想就是:只要还有用户就充分创建UserTask,否则就结束工作流。
第一、流程图:
第二、排他网管向User Task的连接需要增加一个表达式,比如:${endFlat=="false"},排他网关朝着结束节点的连接线需要增加${endFlag=="true"}。
第三、增加一个创建UserTask时触发的监听器,代码如:
package com.yilone.component.workflow;
import java.util.Arrays;
import java.util.List;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;
/**
* 分配用户
*
*/
public class UserAssignerListener implements TaskListener {
private static final long serialVersionUID = 778211731749616447L;
List<String> users = Arrays.asList("zc","ls","zt");
@Override
public void notify(DelegateTask delegateTask) {
String endFlag = (String)delegateTask.getVariable("endFlag"); //这里的逻辑可以扩展,动态去取用户,可以增加用户,或者替换用户,也或者是删除用户。
if(endFlag.equals("false")) {
int index = (Integer)delegateTask.getVariable("index");
String user = users.get(index);
delegateTask.setAssignee(user);
// 设置结束工作流标志
if(index == (users.size() - 1)) {
delegateTask.setVariable("endFlag", "true");
}
}
}
}
第三:测试代码如:
public void multleInstance() {
Map<String, Object> map = new HashMap<String, Object>();
map.put("index", 0); // 放入变量表示完成了第几个task;
map.put("endFlag", "false");
ProcessUtil.getProcessInstanceByKey("approve5", null, map);
// 获取zc的用户
List<Task> taskList = TaskUtil.getTaskOfUser("zc", null);
for(Task tempTask : taskList) {
System.out.println("zc任务是:" + tempTask.getName());
Map<String, Object> map1 = new HashMap<String, Object>();
map1.put("index", 1);
TaskUtil.completeTask(tempTask.getId(), map1);
}
// 获取ls的用户,这个在count变量为1的时候在UserGetService中动弹增加的
List<Task> taskList2 = TaskUtil.getTaskOfUser("ls", null);
for(Task tempTask : taskList2) {
System.out.println("ls任务是:" + tempTask.getName());
Map<String, Object> map2 = new HashMap<String, Object>();
map2.put("index", 2);
TaskUtil.completeTask(tempTask.getId(), map2);
}
// 获取zt的用户,这个在count变量为1的时候在这个在UserGetService中动弹增加的
List<Task> taskList3 = TaskUtil.getTaskOfUser("zt", null);
for(Task tempTask : taskList3) {
System.out.println("zt任务是:" + tempTask.getName());
TaskUtil.completeTask(tempTask.getId(), null);
}
}
这个思路的核心思想就是:只要还有用户就充分创建UserTask,否则就结束工作流。
相关文章推荐
- 单项链表反转
- 机器学习第二篇——线性回归与梯度下降
- 对玩家爱好的深渊魔王们--魔兽争霸里的Azgalor评议
- iOS AFNetWorking中block执行完后再执行其它操作
- Mysql 删除用户 问题
- 1009. Product of Polynomials (25)
- js作用域和词法分析
- [android] 手机卫士关闭自动更新
- 集群管理和分布式任务 Apache helix 抽象模型
- AndroidUI之注册界面的实现分析
- 20145229吴姗珊第八章第九章总结
- Android编程学习笔记 之 BroadcastReceiver组件
- [HDU 1024] Max Sum Plus Plus (DP)
- adb command
- 《Linux内核设计与实现》CHAPTER4阅读梳理
- poj 2385 Apple Catching 基础dp
- 第七周
- JS中数组的操作
- 100. Same Tree
- [BZOJ3636] 教义问答手册