資訊專(zhuān)欄INFORMATION COLUMN
摘要：事實(shí)也確實(shí)如此，可以配置數(shù)據(jù)庫(kù)，其中存儲(chǔ)了流程運(yùn)行時(shí)的相關(guān)信息。在初學(xué)之時(shí)，了解所有的數(shù)據(jù)庫(kù)表的含義對(duì)理解工作機(jī)制是有很大幫助的，總共涉及的表格總共有個(gè)通用數(shù)據(jù)，用于存放數(shù)據(jù)。強(qiáng)行回顧了一下前兩天的學(xué)習(xí)歷程。
1、關(guān)于Activiti
初學(xué)activiti我關(guān)心的它是什么東西、有什么功能、怎么實(shí)現(xiàn)？
先來(lái)看一張流程圖感受一下：
activiti是一個(gè)業(yè)務(wù)流程管理引擎，它的流程圖大概就像是列車(chē)的軌道，而所要執(zhí)行的對(duì)象像是一輛自動(dòng)運(yùn)行的列車(chē)，只要列車(chē)啟動(dòng)，它就能沿著軌道一直走到終點(diǎn)，而其中的節(jié)點(diǎn)就像是列車(chē)到達(dá)終點(diǎn)途中所要經(jīng)過(guò)的火車(chē)站，它會(huì)告訴火車(chē)下一站是哪里，然后火車(chē)就往指定的下一站駛?cè)?，直到終點(diǎn)，流程結(jié)束。
如上所描述，最主要的功能就是實(shí)現(xiàn)了代碼的自動(dòng)按流程執(zhí)行
關(guān)于怎么實(shí)現(xiàn)，既然這是一個(gè)框架，自然就是引進(jìn)jar包，畫(huà)流程圖，然后實(shí)現(xiàn)該框架提供的接口來(lái)做我們想要做的事情。
2、Activiti數(shù)據(jù)庫(kù)的理解activiti在每個(gè)節(jié)點(diǎn)都能知道下一個(gè)節(jié)點(diǎn)是什么，以及當(dāng)前任務(wù)是什么，那勢(shì)必會(huì)有存儲(chǔ)流程的各種信息的表。事實(shí)也確實(shí)如此，activiti可以配置數(shù)據(jù)庫(kù)，其中存儲(chǔ)了流程運(yùn)行時(shí)的相關(guān)信息。在初學(xué)Activiti之時(shí)，了解activiti所有的數(shù)據(jù)庫(kù)表的含義對(duì)理解activiti工作機(jī)制是有很大幫助的，activiti總共涉及的表格總共有23個(gè)：
act_ge_*:general通用數(shù)據(jù)，用于存放數(shù)據(jù)。
act_re_*:reposity類(lèi)似于倉(cāng)庫(kù)，存放流程定義文件和流程圖片文件，比如一個(gè)流程部署之后可以在act_re_deployment表中看到。
act_ru_*:run服務(wù)運(yùn)行時(shí)候的數(shù)據(jù)，當(dāng)一個(gè)流程啟動(dòng)之后當(dāng)前的活動(dòng)任務(wù)可以在act_ru_task表格中查看 ，以及流程中所有的變量都保存在act_ru_variable表格當(dāng)中。
4、下載畫(huà)流程工具activiti-app.war
從官網(wǎng)下載war包（登錄用戶(hù)密碼：admin test），找到activiti-app.war放進(jìn)tomcat，啟動(dòng)之后自己畫(huà)一個(gè)流程圖，用于下面的測(cè)試
war包下載：https://www.activiti.org/down...
版本6.xx的相關(guān)文檔都在這里：https://www.activiti.org/docs
版本5.xx的官網(wǎng)好像不再維護(hù)了
[畫(huà)圖工具]
package com.lewin.activiti.taskListener;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.TaskService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.Execution;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
public class DepolyTest {
@Test
public void run(){
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
Deployment deployment = processEngine.getRepositoryService()
.createDeployment()
//.addClasspathResource("taskListener.bpmn20.xml")
.addClasspathResource("UserExecuteTask.bpmn20.xml")
.deploy();
String piid = deployment.getId();
System.out.println("processDefinitionId:"+piid);
//String processKey = "lewin";
String processKey = "UserExecuteTask";
ProcessInstance pi = processEngine.getRuntimeService().startProcessInstanceByKey(processKey);
System.out.println(pi.getId());
}
/**
* 根據(jù)流程定義里的id啟動(dòng)流程實(shí)例
*/
public void startInstance(){
String processInstanceKey = "lewin";
//“l(fā)ewin”即對(duì)應(yīng)著流程定義中的id值
ProcessInstance pi = ProcessEngines.getDefaultProcessEngine()
.getRuntimeService()
.startProcessInstanceByKey(processInstanceKey);
System.out.println("started processInstance id is:"+processInstanceKey+"; pi.id is:"+pi.getId());
}
/*
* 從class_path中部署流程實(shí)例
*/
@Test
public void deploymentProcessDefinition_classpath(){
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
Deployment deployment = processEngine.getRepositoryService()//獲取倉(cāng)庫(kù)服務(wù)
.createDeployment()//創(chuàng)建部署實(shí)例
.name("deploymentName")//設(shè)置將要部署的流程實(shí)例的名稱(chēng)
.addClasspathResource("taskListener.bpmn20.xml")//資源文件：默認(rèn)路徑在class_path下面
//.addClasspathResource("diagrams/HelloWorld.png")
.deploy();//部署
System.out.println("id："+deployment.getId());
System.out.println("name:"+deployment.getName());
}
/*
* 查詢(xún)定義了的流程
* 查詢(xún)內(nèi)容來(lái)自act_re_deployment
*/
@Test
public void findProcessDefinition(){
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
List list = processEngine.getRepositoryService()
.createProcessDefinitionQuery()
//.deploymentId(deploymentId)
//.processDefinitionId(processDefinitionId)
//.processDefinitionKey(processDefinitionKey)
//.processDefinitionNameLike(processDefinitionNameLike)
.orderByProcessDefinitionVersion().asc()
//.orderByProcessDefinitionName().desc()
.list();
//.singleResult();
//.count();
//.listPage(firstResult, maxResults)
if(list != null && list.size()>0){
for(ProcessDefinition processDefinition:list){
System.out.println("ID:"+processDefinition.getId());
System.out.println("NAME:"+processDefinition.getName());
System.out.println("KEY:"+processDefinition.getKey());
System.out.println("VERSION:"+processDefinition.getVersion());
System.out.println("resourceName:"+processDefinition.getResourceName());
System.out.println("圖片名字:"+processDefinition.getDiagramResourceName());
System.out.println("部署的流程id:"+processDefinition.getDeploymentId());
System.out.println("################################");
}
}
}
/*
* 刪除流程定義
*/
@Test
public void deleteProcessDefinition(){
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//流程定義id
String deploymentId = "2201";
processEngine.getRepositoryService()
.deleteDeployment(deploymentId, true);
System.out.println("刪除成功！");
}
/*
* 查看流程定義圖并下載到本地
*/
@Test
public void viewPic() throws IOException{
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
/**流程部署id*/
String deploymentId = "201";
//根據(jù)id獲取存儲(chǔ)在act_re_deployment表里面的靜態(tài)資源，里面就有圖片
List list = processEngine.getRepositoryService()//
.getDeploymentResourceNames(deploymentId);
//獲取名字
String resourceName = "";
if(list!=null && list.size()>0){
for(String name:list){
if(name.indexOf(".png")>=0){
resourceName = name;
}
}
}
//獲取圖片資源
InputStream in = processEngine.getRepositoryService()//
.getResourceAsStream(deploymentId, resourceName);
//新建文件
File file = new File("D:/"+resourceName);
//文件復(fù)制
FileUtils.copyInputStreamToFile(in, file);
}
/*
* 刪除路程定義根據(jù)定義中的名字
*/
@Test
public void deleteProcessDefinitionByKey(){
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//流程定義文件中的名字，如果相同名字有多個(gè)默認(rèn)使用版本最高的那個(gè)
String processDefinitionKey = "UserExecuteTask";
List list = processEngine.getRepositoryService()
.createProcessDefinitionQuery()
.processDefinitionKey(processDefinitionKey)
.list();
//刪除所有名字為UserExecuteTask的流程定義
if(list!=null && list.size()>0){
for(ProcessDefinition pd:list){
//獲取ID
String deploymentId = pd.getDeploymentId();
processEngine.getRepositoryService()
.deleteDeployment(deploymentId);
}
}
}
/**
* 查詢(xún)流程狀態(tài)
*/
@Test
public void queryInstanceState(){
//流程id
String instanceId = "1309";
//任務(wù)id
String taskId = "1312";
//獲取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//通過(guò)流程id查詢(xún)狀態(tài)
ProcessInstance pi = processEngine.getRuntimeService()
.createProcessInstanceQuery()//創(chuàng)建查詢(xún)
.processInstanceId(instanceId)//根據(jù)id
.singleResult();//獲取狀態(tài)
if(pi!=null){
System.out.println("id為"+instanceId+"的流程正在進(jìn)行中......");
//完成當(dāng)前節(jié)點(diǎn)
processEngine.getTaskService().complete(taskId);
}else{
System.out.println("id為"+instanceId+"的流程已經(jīng)完成！");
}
}
/**
* 查詢(xún)流程執(zhí)行對(duì)象
*/
@Test
public void queryExecution(){
//查詢(xún)執(zhí)行對(duì)象
String exe = "User Task";
//獲取流程實(shí)例
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//查詢(xún)
Execution e1 = processEngine.getRuntimeService()
.createExecutionQuery()
.processInstanceId("1509")
.activityId(exe)
.singleResult();
if(e1!=null){
System.out.println("e1!=null");
}else{
System.out.println("e1==null");
}
}
/**
* 根據(jù)用戶(hù)查詢(xún)?nèi)蝿?wù)
*/
@Test
public void queryUserTask(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// Fetch all tasks for the management group
TaskService taskService = processEngine.getTaskService();
List tasks = taskService.createTaskQuery().taskCandidateGroup("management").list();
for (Task task : tasks) {
System.out.println("Task available: " + task.getName());
}
}
}
6、例子1：只有用戶(hù)任務(wù)和并行網(wǎng)關(guān)的運(yùn)行
UserExecuteTask.bpmn20.xml文件：
