上一篇部落格中，都是比較基礎的Activiti的設定，Assignee都是寫死的，這樣，強大的Activiti有不用寫死的Assignee的功能，現在我們來實現Demo。

先看我們的目錄：

同樣的，我們的Activiti.cfg.xml檔案和log4j.properties檔案都在上一篇部落格中，已經寫好了。

一、畫task.bpmn檔案

我們在選中節點“審批”，properties--Listeners--New

點選New之後，是這樣的：

當然這裡我已經寫好了一個TaskListenerImpl了，因此我這裡，就會出現這個選項，選擇就可以了，如果沒有，我們來寫Listener。

二、taskListenerimpl.java類

<span style="font-size:18px;">package cn.itcast.k_personalTask02;

import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;

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

	/**用來指定任務的辦理人*/
	@Override
	public void notify(DelegateTask delegateTask) {
		//指定個人任務的辦理人，也可以指定組任務的辦理人
		//個人任務：通過類去查詢資料庫，將下一個任務的辦理人查詢獲取，然後通過setAssignee()的方法指定任務的辦理人
		delegateTask.setAssignee("滅絕師太");
	}

}
</span>
 

我們可以看到，這裡的類，一定要實現TaskListener（org.activiti.engine.delegate.TaskListener）介面，才可以。從寫裡面的方法notify方法，就可以在程式碼中置頂下一個辦理人是誰了。

三、TaskTest.java類

<span style="font-size:18px;">package cn.itcast.k_personalTask02;

import java.io.InputStream;
import java.util.List;

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）*/
	@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);
	}
	
	//可以分配個人任務從一個人到另一個人（認領任務）
	@Test
	public void setAssigneeTask(){
		//任務ID
		String taskId = "5804";
		//指定的辦理人
		String userId = "張翠山";
		processEngine.getTaskService()//
					.setAssignee(taskId, userId);
	}

}
</span>
 

注：

我們可以看到程式碼，跟Activiti系列（一）中的程式碼一模一樣，方法什麼的都沒有變，但是我們在測試的是會後，就會發現，startProcessInstance（）啟動流程例項的時候，就會呼叫TaskListenerImpl中的notify方法，這個時候，就會指定了下一個Assignee。