import java.io.File;
import java.io.InputStream;
import java.util.ArrayList;
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.repository.DeploymentBuilder;
import org.activiti.engine.repository.DeploymentQuery;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.repository.ProcessDefinitionQuery;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.runtime.ProcessInstanceQuery;
import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery;
import org.apache.commons.io.FileUtils;
import org.junit.Test;

/**
 * 使用Activiti框架的API操作流程
 * 
 * @author PuHaiyang
 * @createTime 2016年6月28日 下午4:50:39
 * @email 
 
[email protected]
 * @function Activiti基本功能測試
 *
 */
public class MyActivitiAPITest {
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

	@Test
	public void deployActiviti() {
		// 如果之前沒有建立activiti相關的表，呼叫它會自動建立,由activiti-context.xml檔案內容建立
		DeploymentBuilder deploymentBuilder = processEngine.getRepositoryService().createDeployment();
		deploymentBuilder.addClasspathResource("MyTest.bpmn");
		deploymentBuilder.addClasspathResource("MyTest.png");
		deploymentBuilder.name("i_am_name");
		Deployment deploy = deploymentBuilder.deploy();
		System.out.println(deploy.getId());
		// 部署資訊表 insert into ACT_RE_DEPLOYMENT(ID_, NAME_, CATEGORY_,
		// DEPLOY_TIME_) values(?, ?, ?, ?)
		// 二進位制資料表,bpmn檔案插入 insert into ACT_GE_BYTEARRAY(ID_, REV_, NAME_,
		// BYTES_, DEPLOYMENT_ID_, GENERATED_) values (?, 1, ?, ?, ?, ?)
		// 二進位制資料表,png檔案插入 insert into ACT_GE_BYTEARRAY(ID_, REV_, NAME_, BYTES_,
		// DEPLOYMENT_ID_, GENERATED_) values (?, 1, ?, ?, ?, ?)
		// 流程定義資料表 insert into ACT_RE_PROCDEF(ID_, REV_, CATEGORY_, NAME_, KEY_,
		// VERSION_, DEPLOYMENT_ID_, RESOURCE_NAME_, DGRM_RESOURCE_NAME_,
		// DESCRIPTION_, HAS_START_FORM_KEY_, SUSPENSION_STATE_) values (?, 1,
		// ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
	}

	/**
	 * 查詢部署列表
	 */
	@Test
	public void queryDeployment() {
		DeploymentQuery deploymentQuery = processEngine.getRepositoryService().createDeploymentQuery();
		List<Deployment> list = deploymentQuery.list();
		for (Deployment deployment : list) {
			String id = deployment.getId();
			System.out.println(id);
		}
	}

	/**
	 * 刪除部署資訊
	 */
	@Test
	public void deleteDeployment() {
		String deploymentId = "1";
		// 第二個引數代表級聯操作
		processEngine.getRepositoryService().deleteDeployment(deploymentId, true);
		// 刪除所有相關的activiti資訊
	}

	/**
	 * 查詢一次部署對應的流程定義檔名稱和對應的輸入流（bpmn png）
	 * 
	 * @throws Exception
	 */
	@Test
	public void queryDeploymentResource() throws Exception {
		String deploymentId = "101";
		List<String> names = processEngine.getRepositoryService().getDeploymentResourceNames(deploymentId);
		for (String name : names) {
			System.out.println(name);
			InputStream in = processEngine.getRepositoryService().getResourceAsStream(deploymentId, name);
			// 將檔案儲存到本地磁碟
			// FileUtils來自commons-io-xxx.jar
			FileUtils.copyInputStreamToFile(in, new File("d:\\" + name));
			in.close();
		}
	}

	/**
	 * 獲得流程表中流程圖
	 * 
	 * @throws Exception
	 */
	@Test
	public void getProcessDiagream() throws Exception {
		String processDefinitionId = "myProcess:1:104";
		InputStream pngInputStream = processEngine.getRepositoryService().getProcessDiagram(processDefinitionId);
		FileUtils.copyInputStreamToFile(pngInputStream, new File("d:\\my.png"));
	}

	/**
	 * 啟動流程例項 <br>
	 * 方式一：根據流程定義的id啟動 <br>
	 * 方式二：根據流程定義的key啟動(自動選擇最新版本的流程定義啟動流程例項)
	 */
	@Test
	public void startProcess() {
		/*
		 * 方式一：根據流程定義的id啟動 String processDefinitionId = "myProcess:1:104";
		 * ProcessInstance processInstance =
		 * processEngine.getRuntimeService().startProcessInstanceById
		 * (processDefinitionId ); System.out.println(processInstance.getId());
		 */

		// 方式二：根據流程定義的key啟動(自動選擇最新版本的流程定義啟動流程例項)
		String processDefinitionKey = "myProcess";
		ProcessInstance processInstance = processEngine.getRuntimeService()
				.startProcessInstanceByKey(processDefinitionKey);
		System.out.println(processInstance.getId());
		// 呼叫SQL語句如下
		// 1 ACT_RU_EXECUTION 執行時流程執行例項表
		// insert into ACT_RU_EXECUTION (ID_, REV_, PROC_INST_ID_,
		// BUSINESS_KEY_, PROC_DEF_ID_, ACT_ID_, IS_ACTIVE_, IS_CONCURRENT_,
		// IS_SCOPE_,IS_EVENT_SCOPE_, PARENT_ID_, SUPER_EXEC_,
		// SUSPENSION_STATE_, CACHED_ENT_STATE_) values ( ?, 1, ?, ?, ?, ?, ?,
		// ?, ?, ?, ?, ?, ?, ? )

		// 2 ACT_HI_PROCINST 歷史流程例項表
		// insert into ACT_HI_PROCINST ( ID_, PROC_INST_ID_, BUSINESS_KEY_,
		// PROC_DEF_ID_, START_TIME_, END_TIME_, DURATION_, START_USER_ID_,
		// START_ACT_ID_, END_ACT_ID_, SUPER_PROCESS_INSTANCE_ID_,
		// DELETE_REASON_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 3 ACT_HI_ACTINST 歷史節點表
		// insert into ACT_HI_ACTINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_,
		// EXECUTION_ID_, ACT_ID_, TASK_ID_, CALL_PROC_INST_ID_, ACT_NAME_,
		// ACT_TYPE_, ASSIGNEE_, START_TIME_, END_TIME_, DURATION_ ) values ( ?,
		// ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 4 ACT_HI_ACTINST 歷史節點表
		// insert into ACT_HI_ACTINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_,
		// EXECUTION_ID_, ACT_ID_, TASK_ID_, CALL_PROC_INST_ID_, ACT_NAME_,
		// ACT_TYPE_, ASSIGNEE_, START_TIME_, END_TIME_, DURATION_ ) values ( ?,
		// ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 5 ACT_RU_TASK 執行時任務節點表
		// insert into ACT_RU_TASK (ID_, REV_, NAME_, PARENT_TASK_ID_,
		// DESCRIPTION_, PRIORITY_, CREATE_TIME_, OWNER_, ASSIGNEE_,
		// DELEGATION_, EXECUTION_ID_, PROC_INST_ID_, PROC_DEF_ID_,
		// TASK_DEF_KEY_, DUE_DATE_, SUSPENSION_STATE_) values (?, 1, ?, ?, ?,
		// ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 6 ACT_HI_TASKINST 歷史任務例項表
		// insert into ACT_HI_TASKINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_,
		// EXECUTION_ID_, NAME_, PARENT_TASK_ID_, DESCRIPTION_, OWNER_,
		// ASSIGNEE_, START_TIME_, CLAIM_TIME_, END_TIME_, DURATION_,
		// DELETE_REASON_, TASK_DEF_KEY_, FORM_KEY_, PRIORITY_, DUE_DATE_ )
		// values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 7 ACT_RU_IDENTITYLINK 執行時流程人員表，主要儲存任務節點與參與者的相關資訊
		// insert into ACT_RU_IDENTITYLINK (ID_, REV_, TYPE_, USER_ID_,
		// GROUP_ID_, TASK_ID_, PROC_INST_ID_, PROC_DEF_ID_) values (?, 1, ?, ?,
		// ?, ?, ?, ?)

		// 8 ACT_HI_IDENTITYLINK 歷史流程人員表
		// insert into ACT_HI_IDENTITYLINK (ID_, TYPE_, USER_ID_, GROUP_ID_,
		// TASK_ID_, PROC_INST_ID_) values (?, ?, ?, ?, ?, ?)

	}

	/**
	 * 查詢流程例項列表,查詢act_ru_execution表
	 */
	@Test
	public void queryRuntimeProcess() {
		// 流程例項查詢物件，查詢act_ru_execution表
		ProcessInstanceQuery query = processEngine.getRuntimeService().createProcessInstanceQuery();
		query.processDefinitionKey("myProcess");
		query.orderByProcessInstanceId().desc();
		query.listPage(0, 2);
		List<ProcessInstance> list = query.list();
		for (ProcessInstance pi : list) {
			System.out.println(pi.getId() + " " + pi.getActivityId());
		}
	}

	/**
	 * 不通過<br>
	 * 刪除流程例項
	 */
	@Test
	public void deleteProcess() {
		String processInstanceId = "201";
		processEngine.getRuntimeService().deleteProcessInstance(processInstanceId, "不準逃課！");

		// 執行刪除部分SQL如下
		// 1 ACT_RU_TASK 執行時任務節點表
		// delete from ACT_RU_TASK where ID_ = ? and REV_ = ?

		// 2 ACT_RU_IDENTITYLINK 執行時流程人員表，主要儲存任務節點與參與者的相關資訊
		// delete from ACT_RU_IDENTITYLINK where ID_ = ?

		// 3 ACT_RU_EXECUTION 執行時流程執行例項表
		// delete from ACT_RU_EXECUTION where ID_ = ? and REV_ = ?

		// 執行更新部分SQL如下
		// 1 ACT_HI_PROCINST 歷史流程例項表
		// update ACT_HI_PROCINST set PROC_DEF_ID_ = ?, START_TIME_ = ?,
		// END_TIME_ = ?, DURATION_ = ?, END_ACT_ID_ = ?, DELETE_REASON_ = ?
		// where ID_ = ?

		// 2 ACT_HI_ACTINST 歷史節點表
		// update ACT_HI_ACTINST set EXECUTION_ID_ = ?, ASSIGNEE_ = ?, END_TIME_
		// = ?, DURATION_ = ? where ID_ = ?

		// 3 ACT_HI_TASKINST 歷史任務例項表
		// update ACT_HI_TASKINST set EXECUTION_ID_ = ?, NAME_ = ?,
		// PARENT_TASK_ID_ = ?, DESCRIPTION_ = ?, OWNER_ = ?, ASSIGNEE_ = ?,
		// CLAIM_TIME_ = ?, END_TIME_ = ?, DURATION_ = ?, DELETE_REASON_ = ?,
		// TASK_DEF_KEY_ = ?, FORM_KEY_ = ?, PRIORITY_ = ?, DUE_DATE_ = ? where
		// ID_ = ?
	}

	/**
	 * 查詢任務
	 */
	@Test
	public void queryTask() {
		// 任務查詢物件,查詢act_ru_task表
		TaskQuery query = processEngine.getTaskService().createTaskQuery();
		String assignee = "班主任";
		query.taskAssignee(assignee);
		query.orderByTaskCreateTime().desc();
		List<Task> list = query.list();
		for (Task task : list) {
			System.out.println(task.getId());
		}
		// 執行sql如下
		// 1 ACT_GE_PROPERTY 屬性資料表儲存整個流程引擎級別的資料,初始化表結構時，會預設插入三條記錄，
		// select * from ACT_GE_PROPERTY where NAME_ = ?

		// 2 ACT_RU_TASK 執行時任務節點表
		// select distinct RES.* from ACT_RU_TASK RES WHERE RES.ASSIGNEE_ = ?
		// order by RES.CREATE_TIME_ desc LIMIT ? OFFSET ?
	}

	/**
	 * 處理任務
	 */
	@Test
	public void completeTask() {
		String taskId = "304";
		processEngine.getTaskService().complete(taskId);

		// 執行的主要SQL如下
		// 1 ACT_GE_PROPERTY 屬性資料表儲存整個流程引擎級別的資料,初始化表結構時，會預設插入三條記錄
		// update ACT_GE_PROPERTY SET REV_ = ?, VALUE_ = ? where NAME_ = ? and
		// REV_ = ?

		// 2 ACT_HI_ACTINST 歷史節點表
		// insert into ACT_HI_ACTINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_,
		// EXECUTION_ID_, ACT_ID_, TASK_ID_, CALL_PROC_INST_ID_, ACT_NAME_,
		// ACT_TYPE_, ASSIGNEE_, START_TIME_, END_TIME_, DURATION_ ) values ( ?,
		// ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 3 ACT_RU_TASK 執行時任務節點表
		// insert into ACT_RU_TASK (ID_, REV_, NAME_, PARENT_TASK_ID_,
		// DESCRIPTION_, PRIORITY_, CREATE_TIME_, OWNER_, ASSIGNEE_,
		// DELEGATION_, EXECUTION_ID_, PROC_INST_ID_, PROC_DEF_ID_,
		// TASK_DEF_KEY_, DUE_DATE_, SUSPENSION_STATE_) values (?, 1, ?, ?, ?,
		// ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 4 ACT_HI_TASKINST 歷史任務例項表
		// insert into ACT_HI_TASKINST ( ID_, PROC_DEF_ID_, PROC_INST_ID_,
		// EXECUTION_ID_, NAME_, PARENT_TASK_ID_, DESCRIPTION_, OWNER_,
		// ASSIGNEE_, START_TIME_, CLAIM_TIME_, END_TIME_, DURATION_,
		// DELETE_REASON_, TASK_DEF_KEY_, FORM_KEY_, PRIORITY_, DUE_DATE_ )
		// values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

		// 5 ACT_RU_IDENTITYLINK 執行時流程人員表，主要儲存任務節點與參與者的相關資訊
		// insert into ACT_RU_IDENTITYLINK (ID_, REV_, TYPE_, USER_ID_,
		// GROUP_ID_, TASK_ID_, PROC_INST_ID_, PROC_DEF_ID_) values (?, 1, ?, ?,
		// ?, ?, ?, ?)

		// 6 ACT_HI_IDENTITYLINK 歷史流程人員表
		// insert into ACT_HI_IDENTITYLINK (ID_, TYPE_, USER_ID_, GROUP_ID_,
		// TASK_ID_, PROC_INST_ID_) values (?, ?, ?, ?, ?, ?)

		// 7 ACT_HI_TASKINST 歷史任務例項表
		// update ACT_HI_TASKINST set EXECUTION_ID_ = ?, NAME_ = ?,
		// PARENT_TASK_ID_ = ?, DESCRIPTION_ = ?, OWNER_ = ?, ASSIGNEE_ = ?,
		// CLAIM_TIME_ = ?, END_TIME_ = ?, DURATION_ = ?, DELETE_REASON_ = ?,
		// TASK_DEF_KEY_ = ?, FORM_KEY_ = ?, PRIORITY_ = ?, DUE_DATE_ = ? where
		// ID_ = ?

		// 8 ACT_RU_EXECUTION 執行時流程執行例項表
		// update ACT_RU_EXECUTION set REV_ = ?, PROC_DEF_ID_ = ?, ACT_ID_ = ?,
		// IS_ACTIVE_ = ?, IS_CONCURRENT_ = ?, IS_SCOPE_ = ?, IS_EVENT_SCOPE_ =
		// ?, PARENT_ID_ = ?, SUPER_EXEC_ = ?, SUSPENSION_STATE_ = ?,
		// CACHED_ENT_STATE_ = ? where ID_ = ? and REV_ = ?

		// 9 ACT_HI_ACTINST 歷史節點表
		// update ACT_HI_ACTINST set EXECUTION_ID_ = ?, ASSIGNEE_ = ?, END_TIME_
		// = ?, DURATION_ = ? where ID_ = ?

		// 10 ACT_RU_TASK 執行時任務節點表
		// delete from ACT_RU_TASK where ID_ = ? and REV_ = ?

	}

	/**
	 * 直接將流程向下執行一步
	 */
	@Test
	public void signal() {
		String executionId = "301";// 流程例項id
		processEngine.getRuntimeService().signal(executionId);
	}

	/**
	 * 查詢最新版本的流程定義列表
	 */
	@Test
	public void getLastTasks() {
		ProcessDefinitionQuery query = processEngine.getRepositoryService().createProcessDefinitionQuery();
		query.orderByProcessDefinitionVersion().asc();
		List<ProcessDefinition> list = query.list();
		Map<String, ProcessDefinition> map = new HashMap<String, ProcessDefinition>();
		for (ProcessDefinition pd : list) {
			map.put(pd.getKey(), pd);
		}
		ArrayList<ProcessDefinition> lastList = new ArrayList<>(map.values());
		for (ProcessDefinition processDefinition : lastList) {
			System.out.println(processDefinition.getName() + "  " + processDefinition.getVersion());
		}
	}
}