Activiti工作流--任务的分配--之十

时间：2024-03-27 07:18:02
用户任务分配主要有三种方式
  • 将任务分配个某个人
  • 将任务分配个某群人
  • 将任务分配个某个角色(组)
将任务分配个某个人有三个途径
  • 在流程设计当中指定处理任务的某个人
  • 在流程设计的时候用流程变量的方式指定任务处理人,然后在前面的流程处理完的时候用流程变量指定某个具体的人传入到下一个流程 .
  • 在流程设计的时候给流程任务添加一个监听器 ,在业务代码里面指定处理人
流程业务模拟
  • 我们来设计一个简单的流程 ,有三个任务 ,分别用三种任务分配的方式给每个任务来分配一个处理人

先获取连接

private ProcessEngine processEngine ;
	
@Before
public void initProcessEngine(){
	processEngine = ProcessEngines.getDefaultProcessEngine();
}
流程的定义及部署
/**
 * 流程定义(流程图的设计)好以后,需要部署
 * 流程部署涉及到的几个动作和表
 * 流程部署表 act_re_deployment
 * 流程定义表 act_re_procdef
 * 流程资源表 act_ge_bytearray
 * */
@Test
public void testProcessDeploy(){
	/*//1:通过流程定义相关的接口 respositoryService 来创建部署构建器
	RepositoryService respositoryService = 
				processEngine.getRepositoryService();  //流程部署和流程定义相关的服务接口
	DeploymentBuilder deploymentBuilder  = respositoryService.createDeployment();
	//2:添加资源
	deploymentBuilder.addClasspathResource("diagrams/leave.bpmn");
	deploymentBuilder.addClasspathResource("diagrams/leave.png");
	deploymentBuilder.name("请假流程");
	//3 :进行部署
	Deployment deploy = deploymentBuilder.deploy();*/
	
	
	//activiti支持链式编程
	Deployment deploy = processEngine.getRepositoryService()
										.createDeployment()
										.addClasspathResource("diagrams/userTaskDelegate.bpmn")
										.addClasspathResource("diagrams/userTaskDelegate.png")
										.name("分配个人任务")
										.deploy();
	System.out.println("流程部署ID:"+deploy.getId());
	System.out.println("流程部署的名称:"+deploy.getName());
}

流程图
userTaskDelegate.bpmn代码

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
  <process id="usertaskDelegate" name="usertaskDelegateProcess" isExecutable="true">
    <startEvent id="startevent1" name="Start"></startEvent>
    <userTask id="usertask1" name="任务1" activiti:assignee="张三"></userTask>
    <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
    <userTask id="usertask2" name="任务2" activiti:assignee="${userId}"></userTask>
    <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow>
    <userTask id="usertask3" name="任务3">
      <extensionElements>
        <activiti:taskListener event="create" class="com.tz.activitiTest.listener.UserTaskListener"></activiti:taskListener>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow3" sourceRef="usertask2" targetRef="usertask3"></sequenceFlow>
    <endEvent id="endevent1" name="End"></endEvent>
    <sequenceFlow id="flow4" sourceRef="usertask3" targetRef="endevent1"></sequenceFlow>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_usertaskDelegate">
    <bpmndi:BPMNPlane bpmnElement="usertaskDelegate" id="BPMNPlane_usertaskDelegate">
      <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="300.0" y="70.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">
        <omgdc:Bounds height="55.0" width="105.0" x="265.0" y="142.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2">
        <omgdc:Bounds height="55.0" width="105.0" x="265.0" y="251.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="usertask3" id="BPMNShape_usertask3">
        <omgdc:Bounds height="55.0" width="105.0" x="265.0" y="362.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="300.0" y="450.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
        <omgdi:waypoint x="317.0" y="105.0"></omgdi:waypoint>
        <omgdi:waypoint x="317.0" y="142.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
        <omgdi:waypoint x="317.0" y="197.0"></omgdi:waypoint>
        <omgdi:waypoint x="317.0" y="251.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
        <omgdi:waypoint x="317.0" y="306.0"></omgdi:waypoint>
        <omgdi:waypoint x="317.0" y="362.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
        <omgdi:waypoint x="317.0" y="417.0"></omgdi:waypoint>
        <omgdi:waypoint x="317.0" y="450.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions>

Activiti工作流--任务的分配--之十

任务的分配
/** 
 * 
 * 流程的启动(流程实例的产生) new Class->Object	
 * 涉及到的表 :
 * 			act_ru_execution  流程实例表
 * 			act_ru_task 会产生一条待执行的任务记录
 * 			act_hi_taskinst 也会产生一条历史任务记录(注意:endtime is null)
 * 注意: 以流程定义的key启动的话,默认会进入版本最新的流程
 */
@Test
public void testStartProcess(){
	String processDefinitionKey = "usertaskDelegate";
	//流程定义的key启动的话,默认会进入版本最新的流程
	ProcessInstance processInstance = processEngine.getRuntimeService() //与流程实例运行相关的服务类
				  .startProcessInstanceByKey(processDefinitionKey);//启动流程 ,生成一个流程实例
	
	System.out.println("流程部署的ID:"+processInstance.getDeploymentId());
	System.out.println("流程定义的ID:"+processInstance.getProcessDefinitionId());
	System.out.println("流程实例的ID:"+processInstance.getProcessInstanceId());
	
}

/**
 * 流程处理过程：查询个人任务
 * 处理流程的步骤:查询个人任务 完成个人任务
 * 涉及到的表：act_ru_task
 * 
 */
@Test
public void testQueryMyTask(){
	/*String assignee = "xiaoxi";
	String processinstanceId = "60001";
	List<Task> taskList= processEngine.getTaskService()  //跟任务处理相关的服务类
				 .createTaskQuery() //创建一个任务查询 
				 .taskAssignee(assignee) //加入查询条件
				 .processInstanceId(processinstanceId)
				 .list();					//返回形式
		
	if(taskList!=null&&taskList.size()>0){
		for(Task task:taskList){
			System.out.println("流程定义ID:"+task.getProcessDefinitionId());
			System.out.println("流程实例ID:"+task.getProcessInstanceId());
			System.out.println("执行对象ID:"+task.getExecutionId());
			System.out.println("任务ID:"+task.getId());//任务ID:10004
			System.out.println("任务名称:"+task.getName());
			System.out.println("任务的创建时间:"+task.getCreateTime());
			
		}
	}*/
	
	String assignee = "王五";
	
	String processinstanceId = "115001";
	List<Task> taskList= processEngine.getTaskService()  //跟任务处理相关的服务类
				 .createTaskQuery() //创建一个任务查询 
				 .taskAssignee(assignee) //加入查询条件
				 .processInstanceId(processinstanceId)
				 .list();					//返回形式
		
	if(taskList!=null&&taskList.size()>0){
		for(Task task:taskList){
			System.out.println("流程定义ID:"+task.getProcessDefinitionId());
			System.out.println("流程实例ID:"+task.getProcessInstanceId());
			System.out.println("执行对象ID:"+task.getExecutionId());
			System.out.println("任务ID:"+task.getId());//任务ID:10004
			System.out.println("任务名称:"+task.getName());
			System.out.println("任务的创建时间:"+task.getCreateTime());
			
		}
	}
}

/**
 * 流程处理过程：完成个人任务
 * 处理流程的步骤:查询个人任务 完成个人任务
 * 涉及到的表：act_ru_task
 * 
 */
@Test
public void testCompleteMyTask(){
	String taskId = "122502"; //
	Map<String,Object> mapVariables = new HashMap<String,Object>();
	mapVariables.put("userId", "李四");
	
	processEngine.getTaskService()
					.complete(taskId,mapVariables);
	

	System.out.println("第三个任务完成");
	
	/*String taskId = "25002";
	processEngine.getTaskService()
					.complete(taskId);
	System.out.println("审批任务完成");*/
}


/**
 * 在流程的执行过程中,我们需要查询流程执行到了那一个状态
 */
@Test
public void testQueryProinstanceState(){
	String processInstanceId = "115001";
	ProcessInstance processInstance = processEngine.getRuntimeService()
								.createProcessInstanceQuery()
								.processInstanceId(processInstanceId)
								.singleResult();
	if(processInstance!=null){
		System.out.println("当前流程执行到:"+processInstance.getActivityId());
	}else{
		System.out.println("当前流程已结束");

	}
}


/**
 * 当某个任务结束以后,在任务表act_ru_task中的记录会被删除 ,
 * 但是act_hi_taskinst记录的endtime会加上 ,所以我们可以从这个表查询我们的任务执行历史记录
 *  
 * 
 */
@Test
public void testQueryHistoryTask(){
	String assignee = "vicky";
	List<HistoricTaskInstance> historyTaskList = processEngine.getHistoryService()
								.createHistoricTaskInstanceQuery()
								.taskAssignee(assignee)
								.list();
	if(historyTaskList!=null&&historyTaskList.size()>0){
		for(HistoricTaskInstance hisTask:historyTaskList){
			System.out.println("流程定义ID:"+hisTask.getProcessDefinitionId());
			System.out.println("流程实例ID:"+hisTask.getProcessInstanceId());
			System.out.println("执行对象ID:"+hisTask.getExecutionId());
			System.out.println("历史任务ID:"+hisTask.getId());//任务ID:12502
			System.out.println("历史任务名称:"+hisTask.getName());
			System.out.println("历史任务的结束时间:"+hisTask.getEndTime());
			System.out.println("---------------------");

			
		}
	}
}

/**
 * 当某个流程实例执行完以后以后,在流程实例表表act_ru_execution中的记录会被删除 ,
 * 但是act_hi_procinst表中记录的endtime会加上 ,所以我们可以从这个表查询我们的历史流程实例记录
 * 
 */
@Test
public void testQueryHistoryProcessInstance(){
	String processInstanceId = "22501";
	HistoricProcessInstance hisProcessInst = processEngine.getHistoryService()
				 .createHistoricProcessInstanceQuery()
				 .processInstanceId(processInstanceId)
				 .singleResult();
	 
	if(hisProcessInst!=null){
		System.out.println("流程定义ID:"+hisProcessInst.getProcessDefinitionId());
			System.out.println("执行对象ID:"+hisProcessInst.getId());
		 
		System.out.println("---------------------");

	}
}

【上一篇：Activiti工作流–并行网关–之九】
【下一篇：Activiti工作流–组任务分配–之十一】

相关文章