Activiti6系列(5)- 核心API
阿新 • • 發佈:2019-08-09
前言
本來想把《瘋狂工作流講義-activiti6.0》這本書裡面的例項拿過來,但是這本書我看完後,認為裡面編寫的activiti6的核心API程式碼片段不是很清晰,有不少需要雕琢的地方才好形成一篇部落格。
所以我就把以前看過的黑馬activiti5的案例拿過來放到activiti6.0依賴中執行測試,可以正常使用,說明5和6的核心API也就是最常用的那些其實沒多少區別,而黑馬的activiti核心API的程式碼片段寫的更加通俗易懂,註釋簡潔,一目瞭然,就摘取了過來。
一、程式碼建立表
package com.guoj.activiti.A_CreateTable; import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngineConfiguration; import org.junit.Test; public class TestActiviti { /**使用程式碼建立工作流需要的23張表*/ @Test public void createTable(){ ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration(); //連線資料庫的配置 processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver"); processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti6_guoj?useUnicode=true&characterEncoding=utf8"); processEngineConfiguration.setJdbcUsername("root"); processEngineConfiguration.setJdbcPassword("123456"); /** public static final String DB_SCHEMA_UPDATE_FALSE = "false";不能自動建立表,需要表存在 public static final String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";先刪除表再建立表 public static final String DB_SCHEMA_UPDATE_TRUE = "true";如果表不存在,自動建立表 */ processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE); //工作流的核心物件,ProcessEnginee物件 ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine(); System.out.println("processEngine:"+processEngine); } /**使用配置檔案建立工作流需要的23張表*/ @Test public void createTable_2(){ // ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml"); // //工作流的核心物件,ProcessEnginee物件 // ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine(); ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml") // .buildProcessEngine(); System.out.println("processEngine:"+processEngine); } }
二、HelloWorld實現最基本的流程
package com.guoj.activiti.B_HelloWorld; 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; import java.util.List; public class HelloWorld { ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); /**部署流程定義*/ @Test public void deploymentProcessDefinition(){ Deployment deployment = processEngine.getRepositoryService()//與流程定義和部署物件相關的Service .createDeployment()//建立一個部署物件 .name("helloworld入門程式")//新增部署的名稱 .addClasspathResource("diagram/helloworld.bpmn")//從classpath的資源中載入,一次只能載入一個檔案 .addClasspathResource("diagram/helloworld.png")//從classpath的資源中載入,一次只能載入一個檔案 .deploy();//完成部署 System.out.println("部署ID:"+deployment.getId());//1 System.out.println("部署名稱:"+deployment.getName());//helloworld入門程式 } /**啟動流程例項*/ @Test public void startProcessInstance(){ //流程定義的key String processDefinitionKey = "helloworld"; 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()//建立任務查詢物件 .taskAssignee(assignee)//指定個人任務查詢,指定辦理人 .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 = "105002"; processEngine.getTaskService()//與正在執行的任務管理相關的Service .complete(taskId); System.out.println("完成任務:任務ID:"+taskId); } }
三、流程定義
package com.guoj.activiti.C_ProcessDefinition; import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngines; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; import org.apache.commons.io.FileUtils; import org.junit.Test; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.zip.ZipInputStream; public class ProcessDefinitionTest { ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); /**部署流程定義(從classpath)*/ @Test public void deploymentProcessDefinition_classpath(){ Deployment deployment = processEngine.getRepositoryService()//與流程定義和部署物件相關的Service .createDeployment()//建立一個部署物件 .name("流程定義")//新增部署的名稱 .addClasspathResource("diagrams/helloworld.bpmn")//從classpath的資源中載入,一次只能載入一個檔案 .addClasspathResource("diagrams/helloworld.png")//從classpath的資源中載入,一次只能載入一個檔案 .deploy();//完成部署 System.out.println("部署ID:"+deployment.getId());// System.out.println("部署名稱:"+deployment.getName());// } /**部署流程定義(從zip)*/ @Test public void deploymentProcessDefinition_zip(){ InputStream in = this.getClass().getClassLoader().getResourceAsStream("diagrams/helloworld.zip"); ZipInputStream zipInputStream = new ZipInputStream(in); Deployment deployment = processEngine.getRepositoryService()//與流程定義和部署物件相關的Service .createDeployment()//建立一個部署物件 .name("流程定義")//新增部署的名稱 .addZipInputStream(zipInputStream)//指定zip格式的檔案完成部署 .deploy();//完成部署 System.out.println("部署ID:"+deployment.getId());// System.out.println("部署名稱:"+deployment.getName());// } /**查詢流程定義*/ @Test public void findProcessDefinition(){ List<ProcessDefinition> list = processEngine.getRepositoryService()//與流程定義和部署物件相關的Service .createProcessDefinitionQuery()//建立一個流程定義的查詢 /**指定查詢條件,where條件*/ // .deploymentId(deploymentId)//使用部署物件ID查詢 // .processDefinitionId(processDefinitionId)//使用流程定義ID查詢 // .processDefinitionKey(processDefinitionKey)//使用流程定義的key查詢 // .processDefinitionNameLike(processDefinitionNameLike)//使用流程定義的名稱模糊查詢 /**排序*/ .orderByProcessDefinitionVersion().asc()//按照版本的升序排列 // .orderByProcessDefinitionName().desc()//按照流程定義的名稱降序排列 /**返回的結果集*/ .list();//返回一個集合列表,封裝流程定義 // .singleResult();//返回惟一結果集 // .count();//返回結果集數量 // .listPage(firstResult, maxResults);//分頁查詢 if(list!=null && list.size()>0){ for(ProcessDefinition pd:list){ System.out.println("流程定義ID:"+pd.getId());//流程定義的key+版本+隨機生成數 System.out.println("流程定義的名稱:"+pd.getName());//對應helloworld.bpmn檔案中的name屬性值 System.out.println("流程定義的key:"+pd.getKey());//對應helloworld.bpmn檔案中的id屬性值 System.out.println("流程定義的版本:"+pd.getVersion());//當流程定義的key值相同的相同下,版本升級,預設1 System.out.println("資源名稱bpmn檔案:"+pd.getResourceName()); System.out.println("資源名稱png檔案:"+pd.getDiagramResourceName()); System.out.println("部署物件ID:"+pd.getDeploymentId()); System.out.println("#########################################################"); } } } /**刪除流程定義*/ @Test public void deleteProcessDefinition(){ //使用部署ID,完成刪除 String deploymentId = "601"; /** * 不帶級聯的刪除 * 只能刪除沒有啟動的流程,如果流程啟動,就會丟擲異常 */ // processEngine.getRepositoryService()// // .deleteDeployment(deploymentId); /** * 級聯刪除 * 不管流程是否啟動,都能可以刪除 */ processEngine.getRepositoryService()// .deleteDeployment(deploymentId, true); System.out.println("刪除成功!"); } /**檢視流程圖 * @throws IOException */ @Test public void viewPic() throws IOException{ /**將生成圖片放到資料夾下*/ String deploymentId = "801"; //============== 第一種方式 start ==================// //獲取圖片資源名稱 List<String> 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); //將圖片生成到D盤的目錄下 File file = new File("D:/"+resourceName); //將輸入流的圖片寫到D盤下 FileUtils.copyInputStreamToFile(in, file); //============== 第一種方式 end ==================// //=============== 第二種方式 start ==================// // // 查詢流程定義 // ProcessDefinition processDefinition = processEngine.getRepositoryService().createProcessDefinitionQuery().deploymentId(dep.getId()) // .singleResult(); // // 查詢圖片資原始檔 // InputStream is = processEngine.getRepositoryService().getProcessDiagram(processDefinition.getId()); // //將圖片生成到D盤的目錄下 // File file = new File("D:/"+resourceName); // //將輸入流的圖片寫到D盤下 // FileUtils.copyInputStreamToFile(in, file); //=============== 第二種方式 end ==================// } /***附加功能:查詢最新版本的流程定義*/ @Test public void findLastVersionProcessDefinition(){ List<ProcessDefinition> list = processEngine.getRepositoryService()// .createProcessDefinitionQuery()// .orderByProcessDefinitionVersion().asc()//使用流程定義的版本升序排列 .list(); /** * Map<String,ProcessDefinition> map集合的key:流程定義的key map集合的value:流程定義的物件 map集合的特點:當map集合key值相同的情況下,後一次的值將替換前一次的值 */ Map<String, ProcessDefinition> map = new LinkedHashMap<String, ProcessDefinition>(); if(list!=null && list.size()>0){ for(ProcessDefinition pd:list){ map.put(pd.getKey(), pd); } } List<ProcessDefinition> pdList = new ArrayList<ProcessDefinition>(map.values()); if(pdList!=null && pdList.size()>0){ for(ProcessDefinition pd:pdList){ System.out.println("流程定義ID:"+pd.getId());//流程定義的key+版本+隨機生成數 System.out.println("流程定義的名稱:"+pd.getName());//對應helloworld.bpmn檔案中的name屬性值 System.out.println("流程定義的key:"+pd.getKey());//對應helloworld.bpmn檔案中的id屬性值 System.out.println("流程定義的版本:"+pd.getVersion());//當流程定義的key值相同的相同下,版本升級,預設1 System.out.println("資源名稱bpmn檔案:"+pd.getResourceName()); System.out.println("資源名稱png檔案:"+pd.getDiagramResourceName()); System.out.println("部署物件ID:"+pd.getDeploymentId()); System.out.println("#########################################################"); } } } /**附加功能:刪除流程定義(刪除key相同的所有不同版本的流程定義)*/ @Test public void deleteProcessDefinitionByKey(){ //流程定義的key String processDefinitionKey = "helloworld"; //先使用流程定義的key查詢流程定義,查詢出所有的版本 List<ProcessDefinition> list = processEngine.getRepositoryService()// .createProcessDefinitionQuery()// .processDefinitionKey(processDefinitionKey)//使用流程定義的key查詢 .list(); //遍歷,獲取每個流程定義的部署ID if(list!=null && list.size()>0){ for(ProcessDefinition pd:list){ //獲取部署ID String deploymentId = pd.getDeploymentId(); processEngine.getRepositoryService()// .deleteDeployment(deploymentId, true); } } } }
四、流程例項、任務、執行物件
package com.guoj.activiti.D_ProcessInstance;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;
import java.io.InputStream;
import java.util.List;
import java.util.zip.ZipInputStream;
public class ProcessInstanceTest {
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
/**部署流程定義(從zip)*/
@Test
public void deploymentProcessDefinition_zip(){
InputStream in = this.getClass().getClassLoader().getResourceAsStream("diagrams/helloworld.zip");
ZipInputStream zipInputStream = new ZipInputStream(in);
Deployment deployment = processEngine.getRepositoryService()//與流程定義和部署物件相關的Service
.createDeployment()//建立一個部署物件
.name("流程定義")//新增部署的名稱
.addZipInputStream(zipInputStream)//指定zip格式的檔案完成部署
.deploy();//完成部署
System.out.println("部署ID:"+deployment.getId());//
System.out.println("部署名稱:"+deployment.getName());//
}
/**啟動流程例項*/
@Test
public void startProcessInstance(){
//流程定義的key
String processDefinitionKey = "helloworld";
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 = "1202";
processEngine.getTaskService()//與正在執行的任務管理相關的Service
.complete(taskId);
System.out.println("完成任務:任務ID:"+taskId);
}
/**查詢流程狀態(判斷流程正在執行,還是結束)*/
@Test
public void isProcessEnd(){
String processInstanceId = "1001";
ProcessInstance pi = processEngine.getRuntimeService()//表示正在執行的流程例項和執行物件
.createProcessInstanceQuery()//建立流程例項查詢
.processInstanceId(processInstanceId)//使用流程例項ID查詢
.singleResult();
if(pi==null){
System.out.println("流程已經結束");
}
else{
System.out.println("流程沒有結束");
}
}
/**查詢歷史任務(後面講)*/
@Test
public void findHistoryTask(){
String taskAssignee = "張三";
List<HistoricTaskInstance> list = processEngine.getHistoryService()//與歷史資料(歷史表)相關的Service
.createHistoricTaskInstanceQuery()//建立歷史任務例項查詢
.taskAssignee(taskAssignee)//指定歷史任務的辦理人
.list();
if(list!=null && list.size()>0){
for(HistoricTaskInstance hti:list){
System.out.println(hti.getId()+" "+hti.getName()+" "+hti.getProcessInstanceId()+" "+hti.getStartTime()+" "+hti.getEndTime()+" "+hti.getDurationInMillis());
System.out.println("################################");
}
}
}
/**查詢歷史流程例項(後面講)*/
@Test
public void findHistoryProcessInstance(){
String processInstanceId = "1001";
HistoricProcessInstance hpi = processEngine.getHistoryService()//與歷史資料(歷史表)相關的Service
.createHistoricProcessInstanceQuery()//建立歷史流程例項查詢
.processInstanceId(processInstanceId)//使用流程例項ID查詢
.singleResult();
System.out.println(hpi.getId()+" "+hpi.getProcessDefinitionId()+" "+hpi.getStartTime()+" "+hpi.getEndTime()+" "+hpi.getDurationInMillis());
}
}
五、流程變數
Person
package com.guoj.activiti.E_ProcessVariables;
import java.io.Serializable;
public class Person implements Serializable {
/**
*
*/
private static final long serialVersionUID = 6757393795687480331L;
private Integer id;//編號
private String name;//姓名
private String education;
public String getEducation() {
return education;
}
public void setEducation(String education) {
this.education = education;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
ProcessVariablesTest
package com.guoj.activiti.E_ProcessVariables;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricVariableInstance;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.junit.Test;
import java.io.InputStream;
import java.util.List;
public class ProcessVariablesTest {
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
/**部署流程定義(從InputStream)*/
@Test
public void deploymentProcessDefinition_inputStream(){
InputStream inputStreambpmn = this.getClass().getResourceAsStream("/diagrams/processVariables.bpmn");
InputStream inputStreampng = this.getClass().getResourceAsStream("/diagrams/processVariables.png");
Deployment deployment = processEngine.getRepositoryService()//與流程定義和部署物件相關的Service
.createDeployment()//建立一個部署物件
.name("流程定義")//新增部署的名稱
.addInputStream("processVariables.bpmn", inputStreambpmn)//使用資原始檔的名稱(要求:與資原始檔的名稱要一致),和輸入流完成部署
.addInputStream("processVariables.png", inputStreampng)//使用資原始檔的名稱(要求:與資原始檔的名稱要一致),和輸入流完成部署
.deploy();//完成部署
System.out.println("部署ID:"+deployment.getId());//
System.out.println("部署名稱:"+deployment.getName());//
}
/**啟動流程例項*/
@Test
public void startProcessInstance(){
//流程定義的key
String processDefinitionKey = "processVariables";
ProcessInstance pi = processEngine.getRuntimeService()//與正在執行的流程例項和執行物件相關的Service
.startProcessInstanceByKey(processDefinitionKey);//使用流程定義的key啟動流程例項,key對應helloworld.bpmn檔案中id的屬性值,使用key值啟動,預設是按照最新版本的流程定義啟動
System.out.println("流程例項ID:"+pi.getId());//流程例項ID
System.out.println("流程定義ID:"+pi.getProcessDefinitionId());//流程定義ID
}
/**設定流程變數*/
@Test
public void setVariables(){
/**與任務(正在執行)*/
TaskService taskService = processEngine.getTaskService();
//任務ID
String taskId = "2104";
/**一:設定流程變數,使用基本資料型別*/
// taskService.setVariableLocal(taskId, "請假天數", 5);//與任務ID繫結
// taskService.setVariable(taskId, "請假日期", new Date());
// taskService.setVariable(taskId, "請假原因", "回家探親,一起吃個飯");
/**二:設定流程變數,使用javabean型別*/
/**
* 當一個javabean(實現序列號)放置到流程變數中,要求javabean的屬性不能再發生變化
* * 如果發生變化,再獲取的時候,丟擲異常
*
* 解決方案:在Person物件中新增:
* private static final long serialVersionUID = 6757393795687480331L;
* 同時實現Serializable
* */
Person p = new Person();
p.setId(20);
p.setName("翠花");
taskService.setVariable(taskId, "人員資訊(新增固定版本)", p);
System.out.println("設定流程變數成功!");
}
/**獲取流程變數*/
@Test
public void getVariables(){
/**與任務(正在執行)*/
TaskService taskService = processEngine.getTaskService();
//任務ID
String taskId = "2104";
/**一:獲取流程變數,使用基本資料型別*/
// Integer days = (Integer) taskService.getVariable(taskId, "請假天數");
// Date date = (Date) taskService.getVariable(taskId, "請假日期");
// String resean = (String) taskService.getVariable(taskId, "請假原因");
// System.out.println("請假天數:"+days);
// System.out.println("請假日期:"+date);
// System.out.println("請假原因:"+resean);
/**二:獲取流程變數,使用javabean型別*/
Person p = (Person)taskService.getVariable(taskId, "人員資訊(新增固定版本)");
System.out.println(p.getId()+" "+p.getName());
}
/**模擬設定和獲取流程變數的場景*/
public void setAndGetVariables(){
/**與流程例項,執行物件(正在執行)*/
RuntimeService runtimeService = processEngine.getRuntimeService();
/**與任務(正在執行)*/
TaskService taskService = processEngine.getTaskService();
/**設定流程變數*/
// runtimeService.setVariable(executionId, variableName, value)//表示使用執行物件ID,和流程變數的名稱,設定流程變數的值(一次只能設定一個值)
// runtimeService.setVariables(executionId, variables)//表示使用執行物件ID,和Map集合設定流程變數,map集合的key就是流程變數的名稱,map集合的value就是流程變數的值(一次設定多個值)
// taskService.setVariable(taskId, variableName, value)//表示使用任務ID,和流程變數的名稱,設定流程變數的值(一次只能設定一個值)
// taskService.setVariables(taskId, variables)//表示使用任務ID,和Map集合設定流程變數,map集合的key就是流程變數的名稱,map集合的value就是流程變數的值(一次設定多個值)
// runtimeService.startProcessInstanceByKey(processDefinitionKey, variables);//啟動流程例項的同時,可以設定流程變數,用Map集合
// taskService.complete(taskId, variables)//完成任務的同時,設定流程變數,用Map集合
/**獲取流程變數*/
// runtimeService.getVariable(executionId, variableName);//使用執行物件ID和流程變數的名稱,獲取流程變數的值
// runtimeService.getVariables(executionId);//使用執行物件ID,獲取所有的流程變數,將流程變數放置到Map集合中,map集合的key就是流程變數的名稱,map集合的value就是流程變數的值
// runtimeService.getVariables(executionId, variableNames);//使用執行物件ID,獲取流程變數的值,通過設定流程變數的名稱存放到集合中,獲取指定流程變數名稱的流程變數的值,值存放到Map集合中
// taskService.getVariable(taskId, variableName);//使用任務ID和流程變數的名稱,獲取流程變數的值
// taskService.getVariables(taskId);//使用任務ID,獲取所有的流程變數,將流程變數放置到Map集合中,map集合的key就是流程變數的名稱,map集合的value就是流程變數的值
// taskService.getVariables(taskId, variableNames);//使用任務ID,獲取流程變數的值,通過設定流程變數的名稱存放到集合中,獲取指定流程變數名稱的流程變數的值,值存放到Map集合中
}
/**完成我的任務*/
@Test
public void completeMyPersonalTask(){
//任務ID
String taskId = "2402";
processEngine.getTaskService()//與正在執行的任務管理相關的Service
.complete(taskId);
System.out.println("完成任務:任務ID:"+taskId);
}
/**查詢流程變數的歷史表*/
@Test
public void findHistoryProcessVariables(){
List<HistoricVariableInstance> list = processEngine.getHistoryService()//
.createHistoricVariableInstanceQuery()//建立一個歷史的流程變數查詢物件
.variableName("請假天數")
.list();
if(list!=null && list.size()>0){
for(HistoricVariableInstance hvi:list){
System.out.println(hvi.getId()+" "+hvi.getProcessInstanceId()+" "+hvi.getVariableName()+" "+hvi.getVariableTypeName()+" "+hvi.getValue());
System.out.println("###############################################");
}
}
}
}
六、流程歷史
package com.guoj.activiti.F_HistoryQuery;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.history.HistoricActivityInstance;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.history.HistoricVariableInstance;
import org.junit.Test;
import java.util.List;
public class HistoryQueryTest {
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
/**查詢歷史流程例項*/
@Test
public void findHistoryProcessInstance(){
String processInstanceId = "2101";
HistoricProcessInstance hpi = processEngine.getHistoryService()//與歷史資料(歷史表)相關的Service
.createHistoricProcessInstanceQuery()//建立歷史流程例項查詢
.processInstanceId(processInstanceId)//使用流程例項ID查詢
.orderByProcessInstanceStartTime().asc()
.singleResult();
System.out.println(hpi.getId()+" "+hpi.getProcessDefinitionId()+" "+hpi.getStartTime()+" "+hpi.getEndTime()+" "+hpi.getDurationInMillis());
}
/**查詢歷史活動*/
@Test
public void findHistoryActiviti(){
String processInstanceId = "2101";
List<HistoricActivityInstance> list = processEngine.getHistoryService()//
.createHistoricActivityInstanceQuery()//建立歷史活動例項的查詢
.processInstanceId(processInstanceId)//
.orderByHistoricActivityInstanceStartTime().asc()//
.list();
if(list!=null && list.size()>0){
for(HistoricActivityInstance hai:list){
System.out.println(hai.getId()+" "+hai.getProcessInstanceId()+" "+hai.getActivityType()+" "+hai.getStartTime()+" "+hai.getEndTime()+" "+hai.getDurationInMillis());
System.out.println("#####################");
}
}
}
/**查詢歷史任務*/
@Test
public void findHistoryTask(){
String processInstanceId = "2101";
List<HistoricTaskInstance> list = processEngine.getHistoryService()//與歷史資料(歷史表)相關的Service
.createHistoricTaskInstanceQuery()//建立歷史任務例項查詢
.processInstanceId(processInstanceId)//
.orderByHistoricTaskInstanceStartTime().asc()
.list();
if(list!=null && list.size()>0){
for(HistoricTaskInstance hti:list){
System.out.println(hti.getId()+" "+hti.getName()+" "+hti.getProcessInstanceId()+" "+hti.getStartTime()+" "+hti.getEndTime()+" "+hti.getDurationInMillis());
System.out.println("################################");
}
}
}
/**查詢歷史流程變數*/
@Test
public void findHistoryProcessVariables(){
String processInstanceId = "2101";
List<HistoricVariableInstance> list = processEngine.getHistoryService()//
.createHistoricVariableInstanceQuery()//建立一個歷史的流程變數查詢物件
.processInstanceId(processInstanceId)//
.list();
if(list!=null && list.size()>0){
for(HistoricVariableInstance hvi:list){
System.out.println(hvi.getId()+" "+hvi.getProcessInstanceId()+" "+hvi.getVariableName()+" "+hvi.getVariableTypeName()+" "+hvi.getValue());
System.out.println("###############################################");
}
}
}
}
總結
activiti6.0最核心的就是它的API,分別對應了28張表中的某幾張表,一般是1-2張,API的操作實際上就是對這些表的CRUD,而整個流程的運轉實際上就是這些表資料的變化,因此,只要掌握了activiti6.0的核心API,就能對流程例項進行更熟練的控制和操作。
<