第八,我的任務分配- 接口插入

1.流程圖

2.xml

<process id="task" name="taskProcess" isExecutable="true">
    <startEvent id="startevent1" name="Start"></startEvent>
    <userTask id="usertask1" name="審批">
      <extensionElements>
        <activiti:taskListener event="create" class="cn.itcast.k_personalTask02.TaskListenerImpl"></activiti:taskListener>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
    <endEvent id="endevent1" name="End"></endEvent>
    <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow>
  </process>

3.接口

@SuppressWarnings("serial")
public class TaskListenerImpl implements TaskListener {

	/**用來指定任務的辦理人*/
	@Override
	public void notify(DelegateTask delegateTask) {
		//指定我的任務的辦理人，也能夠指定組任務的辦理人
		//我的任務：經過類去查詢數據庫，將下一個任務的辦理人查詢獲取，而後經過setAssignee()的方法指定任務的辦理人
		delegateTask.setAssignee("滅絕師太");
	}

}

4.代碼

public class TaskTest {

	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	
	/**部署流程定義（從inputStream）*/
	@Test
	public 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());//
	}
	
	/**啓動流程實例*/
	@Test
	public void startProcessInstance(){
		//流程定義的key
		String processDefinitionKey = "task";
		ProcessInstance pi = processEngine.getRuntimeService()//與正在執行的流程實例和執行對象相關的Service
						.startProcessInstanceByKey(processDefinitionKey);//使用流程定義的key啓動流程實例，key對應helloworld.bpmn文件中id的屬性值，使用key值啓動，默認是按照最新版本的流程定義啓動
		System.out.println("流程實例ID:"+pi.getId());//流程實例ID    101
		System.out.println("流程定義ID:"+pi.getProcessDefinitionId());//流程定義ID   helloworld:1:4
	}
	
	/**查詢當前人的我的任務*/
	@Test
	public 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("########################################################");
			}
		}
	}
	
	/**完成個人任務*/
	@Test
	public void completeMyPersonalTask(){
		//任務ID
		String taskId = "5804";
		processEngine.getTaskService()//與正在執行的任務管理相關的Service
					.complete(taskId);
		System.out.println("完成任務：任務ID："+taskId);
	}