activiti（十）组任务Group

activiti组任务第一种：直接指定办理人bpmn文件：

第二种：使用流程变量代码语言：javascript复制package cn.panda.l_group;

import java.io.InputStream;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.zip.ZipInputStream;

import org.activiti.engine.ProcessEngine;

import org.activiti.engine.ProcessEngines;

import org.activiti.engine.history.HistoricIdentityLink;

import org.activiti.engine.history.HistoricProcessInstance;

import org.activiti.engine.history.HistoricTaskInstance;

import org.activiti.engine.history.HistoricVariableInstance;

import org.activiti.engine.repository.Deployment;

import org.activiti.engine.runtime.ProcessInstance;

import org.activiti.engine.task.IdentityLink;

import org.activiti.engine.task.Task;

import org.junit.Test;

public class TaskTest {

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

/**

* 部署流程定义 (从inputStream)

*/

@Test

//key值相同 资源升级

public void deployementProcessDefinition_inputStream() {

//从当前文件夹查找

InputStream inputStreamBpmn =this.getClass().getResourceAsStream("task.bpmn");

InputStream inputStreamPng =this.getClass().getResourceAsStream("task.png");

Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署相关的service

.createDeployment()//创建部署对象

.name("任务")//添加部署对象

.addInputStream("task.bpmn", inputStreamBpmn)

.addInputStream("task.png", inputStreamPng)

.deploy();//完成部署

System.out.println(deployment.getId());

System.out.println(deployment.getName());

}

/**

* 启动流程实例

*/

@Test

public void startProcessInstance() {

//使用key值启动 默认按照最新版本的流程定义启动

String processDefinitionKey="task";

//启动流程实例同时 设置流程变量 使用流程变量指定任务办理人#{userID}

Map variables = new HashMap();

variables.put("userIDs", "周杰伦,大大,中中,小小");

ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service

.startProcessInstanceByKey(processDefinitionKey,variables);//使用流程定义的key启动流程实例 key对应bpmn文件的id属性值

System.out.println("流程实例id"+processInstance.getId());//流程实例id

System.out.println("流程定义ID"+processInstance.getProcessDefinitionId());//流程定义ID

}

/**

* 查询当前人的组任务act_ru_task

*/

@Test

public void findMyPersonalTask() {

String candidateUser="大大";

List list = processEngine.getTaskService()//与正在执行的任务管理相关的Service

.createTaskQuery()//创建任务查询对象

.taskCandidateUser(candidateUser)

.orderByTaskCreateTime().asc()

.list();

if (list!=null&&list.size()>0) {

for (Task task : list) {

System.out.println("任务ID"+task.getId());

System.out.println("任务名称"+task.getName());

System.out.println("任务创建时间"+task.getCreateTime());

System.out.println("任务的办理人"+task.getAssignee());

System.out.println("流程实例id:"+task.getProcessInstanceId());

System.out.println("执行对象id:"+task.getExecutionId());

System.out.println("流程定义id:"+task.getProcessDefinitionId());

}

}

}

/**

* 完成我的任务

*/

@Test

public void completeMyPersonalTask() {

String taskId = "11105";

processEngine.getTaskService()

.complete(taskId);

System.out.println("完成任务 任务ID："+taskId);

}

/**

* 查询正在执行的任务办理人表

*/

@Test

public void findRunPersonTask() {

String taskId = "8701";

List list = processEngine.getTaskService()

.getIdentityLinksForTask(taskId);

if (list!=null&&list.size()>0) {

for (IdentityLink identityLink : list) {

System.out.println(identityLink.getUserId()+" "

+identityLink.getProcessInstanceId()+" "

+identityLink.getType());

}

}

}

/**

* 查询历史任务的办理人

*/

@Test

public void findHistoryPersonTask() {

String processInstanceId = "8901";

List list = processEngine.getHistoryService()

.getHistoricIdentityLinksForProcessInstance(processInstanceId);

if (list!=null&&list.size()>0) {

for (HistoricIdentityLink historicIdentityLink : list) {

System.out.println(historicIdentityLink.getTaskId()+" "

+historicIdentityLink.getType()+" "

+historicIdentityLink.getProcessInstanceId());

}

}

}

/**

* 拾取任务 组任务分配给个人任务 指定任务的办理人字段

*/

@Test

public void claim() {

//个人Id

String userId = "大大";

String taskId = "9905";

//可以是组任务的成员 也可以是其他人

processEngine.getTaskService()

.claim(taskId, userId);

}

/**

* 将个人任务回退到组任务 前提是之前一定是组任务

*/

@Test

public void setAssignee() {

String taskId = "8905";

processEngine.getTaskService()

.setAssignee(taskId, null);

}

/**

* 向组任务中添加成员

*/

@Test

public void addGroupUser() {

String taskId = "8905";

String userId = "大S";

processEngine.getTaskService()

.addCandidateUser(taskId, userId);

}

/**

* 从组任务中删除成员

*/

@Test

public void deleteGroupUser() {

String taskId = "8905";

String userId = "大S";

processEngine.getTaskService()

.deleteCandidateUser(taskId, userId);

}

}部署流程 开启流程 查看当前人的组任务 组任务拾取个人任务 完成任务（组任务最后也要个人来完成）

bpmn文件：

第三种：使用类实体类：

代码语言：javascript复制package cn.panda.l_group03;

import org.activiti.engine.delegate.DelegateTask;

import org.activiti.engine.delegate.TaskListener;

@SuppressWarnings("serial")

public class TaskListenerImpl implements TaskListener {

/**

* 指定组任务的办理人

*/

//通过类找办理人

public void notify(DelegateTask delegateTask) {

delegateTask.addCandidateUser("郭靖");

delegateTask.addCandidateUser("黄蓉");

}

}测试类：

代码语言：javascript复制package cn.panda.l_group03;

import java.io.InputStream;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.zip.ZipInputStream;

import org.activiti.engine.ProcessEngine;

import org.activiti.engine.ProcessEngines;

import org.activiti.engine.history.HistoricIdentityLink;

import org.activiti.engine.history.HistoricProcessInstance;

import org.activiti.engine.history.HistoricTaskInstance;

import org.activiti.engine.history.HistoricVariableInstance;

import org.activiti.engine.repository.Deployment;

import org.activiti.engine.runtime.ProcessInstance;

import org.activiti.engine.task.IdentityLink;

import org.activiti.engine.task.Task;

import org.junit.Test;

public class TaskTest {

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

/**

* 部署流程定义 (从inputStream)

*/

@Test

//key值相同 资源升级

public void deployementProcessDefinition_inputStream() {

//从当前文件夹查找

InputStream inputStreamBpmn =this.getClass().getResourceAsStream("task.bpmn");

InputStream inputStreamPng =this.getClass().getResourceAsStream("task.png");

Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署相关的service

.createDeployment()//创建部署对象

.name("任务")//添加部署对象

.addInputStream("task.bpmn", inputStreamBpmn)

.addInputStream("task.png", inputStreamPng)

.deploy();//完成部署

System.out.println(deployment.getId());

System.out.println(deployment.getName());

}

/**

* 启动流程实例

*/

@Test

public void startProcessInstance() {

//使用key值启动 默认按照最新版本的流程定义启动

String processDefinitionKey="task";

ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service

.startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例 key对应bpmn文件的id属性值

System.out.println("流程实例id"+processInstance.getId());//流程实例id

System.out.println("流程定义ID"+processInstance.getProcessDefinitionId());//流程定义ID

}

/**

* 查询当前人的组任务act_ru_task

*/

@Test

public void findMyPersonalTask() {

String candidateUser="郭靖";

List list = processEngine.getTaskService()//与正在执行的任务管理相关的Service

.createTaskQuery()//创建任务查询对象

.taskCandidateUser(candidateUser)

.orderByTaskCreateTime().asc()

.list();

if (list!=null&&list.size()>0) {

for (Task task : list) {

System.out.println("任务ID"+task.getId());

System.out.println("任务名称"+task.getName());

System.out.println("任务创建时间"+task.getCreateTime());

System.out.println("任务的办理人"+task.getAssignee());

System.out.println("流程实例id:"+task.getProcessInstanceId());

System.out.println("执行对象id:"+task.getExecutionId());

System.out.println("流程定义id:"+task.getProcessDefinitionId());

}

}

}

/**

* 完成我的任务

*/

@Test

public void completeMyPersonalTask() {

String taskId = "10404";

processEngine.getTaskService()

.complete(taskId);

System.out.println("完成任务 任务ID："+taskId);

}

/**

* 查询正在执行的任务办理人表

*/

@Test

public void findRunPersonTask() {

String taskId = "8701";

List list = processEngine.getTaskService()

.getIdentityLinksForTask(taskId);

if (list!=null&&list.size()>0) {

for (IdentityLink identityLink : list) {

System.out.println(identityLink.getUserId()+" "

+identityLink.getProcessInstanceId()+" "

+identityLink.getType());

}

}

}

/**

* 查询历史任务的办理人

*/

@Test

public void findHistoryPersonTask() {

String processInstanceId = "8901";

List list = processEngine.getHistoryService()

.getHistoricIdentityLinksForProcessInstance(processInstanceId);

if (list!=null&&list.size()>0) {

for (HistoricIdentityLink historicIdentityLink : list) {

System.out.println(historicIdentityLink.getTaskId()+" "

+historicIdentityLink.getType()+" "

+historicIdentityLink.getProcessInstanceId());

}

}

}

/**

* 拾取任务 组任务分配给个人任务 指定任务的办理人字段

*/

@Test

public void claim() {

//个人Id

String userId = "郭靖";

String taskId = "10404";

//可以是组任务的成员 也可以是其他人

processEngine.getTaskService()

.claim(taskId, userId);

}

/**

* 将个人任务回退到组任务 前提是之前一定是组任务

*/

@Test

public void setAssignee() {

String taskId = "8905";

processEngine.getTaskService()

.setAssignee(taskId, null);

}

/**

* 向组任务中添加成员

*/

@Test

public void addGroupUser() {

String taskId = "8905";

String userId = "大S";

processEngine.getTaskService()

.addCandidateUser(taskId, userId);

}

/**

* 从组任务中删除成员

*/

@Test

public void deleteGroupUser() {

String taskId = "8905";

String userId = "大S";

processEngine.getTaskService()

.deleteCandidateUser(taskId, userId);

}

}bpmn文件：

1） 在类中使用delegateTask.addCandidateUser (userId);的方式分配组任务的办理人，此时孙悟空和猪八戒是下一个任务的办理人。

2） 通过processEngine.getTaskService().claim (taskId, userId);将组任务分配给个人任务，也叫认领任务，即指定某个人去办理这个任务，此时由如来去办理任务。

注意：认领任务的时候，可以是组任务成员中的人，也可以不是组任务成员的人，此时通过Type的类型为participant来指定任务的办理人

3） addCandidateUser()即向组任务添加成员，deleteCandidateUser()即删除组任务的成员。

在开发中，可以将每一个任务的办理人规定好，例如张三的领导是李四和王五，这样张三提交任务，由李四或者王五去查询组任务，可以看到对应张三的申请，李四或王五再通过认领任务（

claim）的方式，由某个人去完成这个任务。

总结：组任务及三种分配方式：

​ 1：在taskProcess.bpmn中直接写 candidate-users=“小A,小B,小C,小D”

​ 2：在taskProcess.bpmn中写 candidate-users =“#{userIDs}”，变量的值要是String的。

​ 使用流程变量指定办理

代码语言：javascript复制Mapvariables = new HashMap();

variables.put("userIDs", "大大,小小,中中");​ 3，使用TaskListener接口，使用类实现该接口，在类中定义：

​ //添加组任务的用户

delegateTask.addCandidateUser(userId1);

delegateTask.addCandidateUser(userId2);

组任务分配给个人任务（认领任务）：

​ processEngine.getTaskService().claim(taskId, userId);

个人任务分配给组任务：

​ processEngine.getTaskService(). setAssignee(taskId,null);

向组任务添加人员：

​ processEngine.getTaskService().addCandidateUser(taskId, userId);

向组任务删除人员：

​ processEngine.getTaskService().deleteCandidateUser(taskId, userId);

个人任务和组任务存放办理人对应的表：

act_ru_identitylink表存放任务的办理人，包括个人任务和组任务，表示正在执行的任务

act_hi_identitylink表存放任务的办理人，包括个人任务和组任务，表示历史任务

区别在于：如果是个人任务TYPE的类型表示participant（参与者）

​ 如果是组任务TYPE的类型表示candidate（候选者）和participant（参与者）两种 完成任务的是参与者而不是候选者