一、流程图
二、分配个人任务方式一(直接指定办理人)
1、流程图中任务节点的配置
2、测试代码
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//部署流程定义,启动流程实例@Testpublic void testTask() throws Exception {// 1 发布流程InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn");InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png");processEngine.getRepositoryService()//.createDeployment()//.addInputStream("userTask.bpmn", inputStreamBpmn)//.addInputStream("userTask.png", inputStreamPng)//.deploy();// 2 启动流程//启动流程实例的同时,设置流程变量ProcessInstance pi = processEngine.getRuntimeService()//.startProcessInstanceByKey("taskProcess");System.out.println("pid:" + pi.getId());}//查询我的个人任务列表@Testpublic void findMyTaskList(){String userId = "张三丰";List<Task> list = processEngine.getTaskService()//.createTaskQuery()//.taskAssignee(userId)//指定个人任务查询.list();for(Task task:list ){System.out.println("id="+task.getId());System.out.println("name="+task.getName());System.out.println("assinee="+task.getAssignee());System.out.println("createTime="+task.getCreateTime());System.out.println("executionId="+task.getExecutionId());}}//完成任务@Testpublic void completeTask(){String taskId = "3209";processEngine.getTaskService()//.complete(taskId);//System.out.println("完成任务");}
3、说明
1) 张三丰是个人任务的办理人
2) 但是这样分配任务的办理人不够灵活,因为项目开发中任务的办理人不要放置XML文件中。
三、分配个人任务方式二(使用流程变量)
1、流程图中任务节点的配置
2、测试代码
import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;public class TaskTest {ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();/**部署流程定义(从inputStream)*/@Testpublic void deploymentProcessDefinition_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("部署ID:"+deployment.getId());//System.out.println("部署名称:"+deployment.getName());//}/**启动流程实例*/@Testpublic void startProcessInstance(){//流程定义的keyString processDefinitionKey = "task";/**启动流程实例的同时,设置流程变量,使用流程变量用来指定任务的办理人,对应task.pbmn文件中#{userID}*/Map<String, Object> variables = new HashMap<String, Object>();variables.put("userID", "周芷若");ProcessInstance pi = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service.startProcessInstanceByKey(processDefinitionKey,variables);//使用流程定义的key启动流程实例,key对应helloworld.bpmn文件中id的属性值,使用key值启动,默认是按照最新版本的流程定义启动System.out.println("流程实例ID:"+pi.getId());//流程实例ID 101System.out.println("流程定义ID:"+pi.getProcessDefinitionId());//流程定义ID helloworld:1:4}/**查询当前人的个人任务*/@Testpublic void findMyPersonalTask(){String assignee = "周芷若";List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service.createTaskQuery()//创建任务查询对象/**查询条件(where部分)*/.taskAssignee(assignee)//指定个人任务查询,指定办理人
// .taskCandidateUser(candidateUser)//组任务的办理人查询
// .processDefinitionId(processDefinitionId)//使用流程定义ID查询
// .processInstanceId(processInstanceId)//使用流程实例ID查询
// .executionId(executionId)//使用执行对象ID查询/**排序*/.orderByTaskCreateTime().asc()//使用创建时间的升序排列/**返回结果集*/
// .singleResult()//返回惟一结果集
// .count()//返回结果集的数量
// .listPage(firstResult, maxResults);//分页查询.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());System.out.println("########################################################");}}}/**完成我的任务*/@Testpublic void completeMyPersonalTask(){//任务IDString taskId = "5505";processEngine.getTaskService()//与正在执行的任务管理相关的Service.complete(taskId);System.out.println("完成任务:任务ID:"+taskId);}
}
说明:
1) 周芷若是个人任务的办理人
2) 在开发中,可以在页面中指定下一个任务的办理人,通过流程变量设置下一个任务的办理人
四、分配个人任务方式三(使用类)
1、流程图中任务节点的配置
此时流程图的XML文件,如图:
2、TaskListenerImpl类,用来设置任务的办理人
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;@SuppressWarnings("serial")
public class TaskListenerImpl implements TaskListener {/**用来指定任务的办理人*/@Overridepublic void notify(DelegateTask delegateTask) {//指定个人任务的办理人,也可以指定组任务的办理人//个人任务:通过类去查询数据库,将下一个任务的办理人查询获取,然后通过setAssignee()的方法指定任务的办理人delegateTask.setAssignee("灭绝师太");}}
3、测试代码
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;public class TaskTest {ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();/**部署流程定义(从inputStream)*/@Testpublic void deploymentProcessDefinition_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("部署ID:"+deployment.getId());//System.out.println("部署名称:"+deployment.getName());//}/**启动流程实例*/@Testpublic void startProcessInstance(){//流程定义的keyString processDefinitionKey = "task";ProcessInstance pi = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service.startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例,key对应helloworld.bpmn文件中id的属性值,使用key值启动,默认是按照最新版本的流程定义启动System.out.println("流程实例ID:"+pi.getId());//流程实例ID 101System.out.println("流程定义ID:"+pi.getProcessDefinitionId());//流程定义ID helloworld:1:4}/**查询当前人的个人任务*/@Testpublic void findMyPersonalTask(){String assignee = "张翠山";List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service.createTaskQuery()//创建任务查询对象/**查询条件(where部分)*/.taskAssignee(assignee)//指定个人任务查询,指定办理人
// .taskCandidateUser(candidateUser)//组任务的办理人查询
// .processDefinitionId(processDefinitionId)//使用流程定义ID查询
// .processInstanceId(processInstanceId)//使用流程实例ID查询
// .executionId(executionId)//使用执行对象ID查询/**排序*/.orderByTaskCreateTime().asc()//使用创建时间的升序排列/**返回结果集*/
// .singleResult()//返回惟一结果集
// .count()//返回结果集的数量
// .listPage(firstResult, maxResults);//分页查询.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());System.out.println("########################################################");}}}/**完成我的任务*/@Testpublic void completeMyPersonalTask(){//任务IDString taskId = "5804";processEngine.getTaskService()//与正在执行的任务管理相关的Service.complete(taskId);System.out.println("完成任务:任务ID:"+taskId);}//可以分配个人任务从一个人到另一个人(认领任务)@Testpublic void setAssigneeTask(){//任务IDString taskId = "5804";//指定的办理人String userId = "张翠山";processEngine.getTaskService()//.setAssignee(taskId, userId);}}
说明:
1) 在类中使用delegateTask.setAssignee(assignee);的方式分配个人任务的办理人,此时灭绝师太是下一个任务的办理人
2) 通过processEngine.getTaskService().setAssignee(taskId, userId);将个人任务从一个人分配给另一个人,此时灭绝师太不再是下一个任务的办理人,而换成了张翠山
3) 在开发中,可以将每一个任务的办理人规定好,例如张三的领导是李四,李四的领导是王五,这样张三提交任务,就可以查询出张三的领导是李四,通过类的方式设置下一个任务的办理人
五、小结
个人任务及三种分配方式:
- 在taskProcess.bpmn中直接写 assignee=“张三丰”
- 使用流程变量指定办理人
在taskProcess.bpmn中写 assignee=“#{userID}”,变量的值要是String的。 - 使用TaskListener接口,要使类实现该接口,在类中定义:
delegateTask.setAssignee(assignee);// 指定个人任务的办理人
使用任务ID和办理人重新指定办理人:
processEngine.getTaskService()//.setAssignee(taskId, userId);
演示代码下载:http://download.csdn.net/detail/xunzaosiyecao/9627675
本文部分内容整理自itcast讲义,在此表示感谢。
作者:jiankunking 出处:http://blog.csdn.net/jiankunking