記錄一下工作流的在Springboot中的使用,，順便寫個(gè)demo，概念，什么東西的我就不解釋了，如有問(wèn)題歡迎各位大佬指導(dǎo)一下。

1.創(chuàng)建springboot項(xiàng)目后導(dǎo)入依賴

<dependency> <groupId>org.activiti</groupId> <artifactId>activiti-spring-boot-starter-basic</artifactId> <version>6.0.0</version> </dependency>

添加配置之后再springboot啟動(dòng)類后面加上一行代碼否則啟動(dòng)時(shí)會(huì)報(bào)錯(cuò)

@SpringBootApplication(exclude = SecurityAutoConfiguration.class)

添加數(shù)據(jù)源以及activiti的配置

spring: activiti: database-schema-update: drop?create //默認(rèn)為false,activiti在啟動(dòng)的時(shí)候會(huì)對(duì)比數(shù)據(jù)庫(kù)中的表中保存的版本，如果不一樣會(huì)拋出異常 // true activiti會(huì)對(duì)數(shù)據(jù)庫(kù)中的表進(jìn)行更新操作，如果表不存在，則自動(dòng)創(chuàng)建 // create_drop 在activiti啟動(dòng)的時(shí)候創(chuàng)建表，關(guān)閉時(shí)刪除表，必須手動(dòng)關(guān)閉 // drop-create 在啟動(dòng)的時(shí)候先刪除表后再創(chuàng)建新的表 check-process-definitions: false datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTC username: root password: root

2.初始化activiti表

這里一共有3種方式去創(chuàng)建

第一種

@Test public void initTables() { //創(chuàng)建數(shù)據(jù)源// DriverManagerDataSource dataSource=new DriverManagerDataSource();// dataSource.setDriverClassName('com.mysql.jdbc.Driver');// dataSource.setUrl('jdbc:mysql://127.0.0.1:3306/test');// dataSource.setUsername('root');// dataSource.setPassword('root'); // 創(chuàng)建流程引擎的配置 ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration(); configuration.setJdbcDriver('com.mysql.cj.jdbc.Driver'); configuration.setJdbcUrl('jdbc:mysql://localhost:3306/test?useUnicode=true&nullCatalogMeansCurrent=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTC'); configuration.setJdbcUsername('root'); configuration.setJdbcPassword('root');//configuration.setDataSource(dataSource); /** * ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE 如果數(shù)據(jù)庫(kù)里面沒(méi)有activit的表，也不會(huì)創(chuàng)建 * ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP 創(chuàng)建表，使用完之后刪除 * ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE 如果數(shù)據(jù)庫(kù)里面沒(méi)有表，就創(chuàng)建 * * dorp-create 代表如果數(shù)據(jù)庫(kù)里面有表，那么先刪除再創(chuàng)建 * */ //配置表的初始化的方式 configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE); //得到流程引擎 ProcessEngine processEngine=configuration.buildProcessEngine(); System.out.println(processEngine); }

第二種配置activiti.cfg.xml

<?xml version='1.0' encoding='UTF-8'?><beans xmlns='http://www.springframework.org/schema/beans' xmlns:context='http://www.springframework.org/schema/context' xmlns:tx='http://www.springframework.org/schema/tx' xmlns:aop='http://www.springframework.org/schema/aop' xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' xsi:schemaLocation='http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsd'> <bean class='org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration'> <property name='jdbcDriver' value='com.mysql.cj.jdbc.Driver'></property> <property name='jdbcUrl' value='jdbc:mysql://localhost:3306/test?useUnicode=true%26nullCatalogMeansCurrent=true%26characterEncoding=utf8%26useSSL=false%26serverTimezone=UTC'></property> <property name='jdbcUsername' value='root'></property> <property name='jdbcPassword' value='root'></property> <!-- flase： 默認(rèn)值。activiti在啟動(dòng)時(shí)，會(huì)對(duì)比數(shù)據(jù)庫(kù)表中保存的版本，如果沒(méi)有表或者版本不匹配，將拋出異常。 true： activiti會(huì)對(duì)數(shù)據(jù)庫(kù)中所有表進(jìn)行更新操作。如果表不存在，則自動(dòng)創(chuàng)建。 create_drop： 在activiti啟動(dòng)時(shí)創(chuàng)建表，在關(guān)閉時(shí)刪除表（必須手動(dòng)關(guān)閉引擎，才能刪除表）。 drop-create： 在activiti啟動(dòng)時(shí)刪除原來(lái)的舊表，然后在創(chuàng)建新表（不需要手動(dòng)關(guān)閉引擎）。 --> <property name='databaseSchemaUpdate' value='drop-create'></property> </bean></beans>

然后寫一個(gè)測(cè)試類

@Testpublic void intiTables2() {ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource('activiti.cfg.xml');// 得到流程引擎ProcessEngine processEngine = configuration.buildProcessEngine();System.out.println(processEngine);}

第三種方法

@Test public void intiTables3() { //必須創(chuàng)建activiti.cfg.xml 并配置好數(shù)據(jù)庫(kù)的信息 ProcessEngine processEngine= ProcessEngines.getDefaultProcessEngine(); System.out.println(processEngine); }

3.打開(kāi)數(shù)據(jù)庫(kù)查看

我們打開(kāi)數(shù)據(jù)庫(kù)查看數(shù)據(jù)庫(kù)，會(huì)發(fā)現(xiàn)activiti已自動(dòng)幫我們創(chuàng)建了28張表（有的好像也只有24張表，有興趣的可以研究一下）

這里為大家解釋一下各張表的含義：Activiti的后臺(tái)是有數(shù)據(jù)庫(kù)的支持，所有的表都以ACT_開(kāi)頭。 第二部分是表示表的用途的兩個(gè)字母標(biāo)識(shí)。

ACT_RE_*: ’RE’表示repository。 這個(gè)前綴的表包含了流程定義和流程靜態(tài)資源 （圖片，規(guī)則，等等）。

ACT_RU_*: ’RU’表示runtime。 這些運(yùn)行時(shí)的表，包含流程實(shí)例，任務(wù)，變量，異步任務(wù)，等運(yùn)行中的數(shù)據(jù)。 Activiti只在流程實(shí)例執(zhí)行過(guò)程中保存這些數(shù)據(jù)， 在流程結(jié)束時(shí)就會(huì)刪除這些記錄。 這樣運(yùn)行時(shí)表可以一直很小速度很快。

ACT_ID_*: ’ID’表示identity。 這些表包含身份信息，比如用戶，組等等。

ACT_HI_*: ’HI’表示history。 這些表包含歷史數(shù)據(jù)，比如歷史流程實(shí)例， 變量，任務(wù)等等。

ACT_GE_*: 通用數(shù)據(jù)， 用于不同場(chǎng)景下，如存放資源文件。

#RepositoryServiceSelect * from act_ge_bytearray; 二進(jìn)制文件夾表Select * from act_re_deployment; 流程部署表Select * from act_re_procdef; 流程定義表Select * from act_ge_property; 屬性數(shù)據(jù)表存儲(chǔ)整個(gè)流程引擎級(jí)別的數(shù)據(jù),初始化表結(jié)構(gòu)時(shí)，會(huì)默認(rèn)插入三條記錄#RuntimeService TaskService 運(yùn)行時(shí)數(shù)據(jù)庫(kù)表Select * from act_ru_excution; 流程啟動(dòng)一次只要沒(méi)有執(zhí)行完就會(huì)有一條數(shù)據(jù)Select * from act_ru_task; 可能有多條數(shù)據(jù)Select * from act_ru_variable; 記錄流程運(yùn)行時(shí)的流程變量Select * from act_ru_identitylink; 存放流程辦理人的信息#HistoryService 歷史數(shù)據(jù)庫(kù)表Select * from act_hi_procinst; 歷史流程實(shí)例Select * from act_hi_taskinst; 歷史任務(wù)實(shí)例Select * from act_hi_actinst; 歷史節(jié)點(diǎn)表Select * from act_hi_attachment; 歷史附件表Select * from act_hicomment; 歷史意見(jiàn)表Select * from act_hi_identitylink; 歷史流程人員表Select * from act_hi_detail; 歷史詳情表提供歷史變量查詢Select * from act_hi_procinst; 歷史流程實(shí)例表Select * from act_hi_taskinst; 歷史任務(wù)實(shí)例表Select * from act_hi_varinst; 歷史變量表#IdentityService 這四張表盡量使用自己的一套，難以滿足需求Select * from act_id_group; 用戶組信息表Select * from act_id_info; 用戶拓展信息表Select * from act_id_menbership; 用戶與用戶組對(duì)應(yīng)表Select * from act_id_user; 用戶信息表

4.接下來(lái)開(kāi)始畫請(qǐng)假流程圖（需要先安裝插件），新建一個(gè)bpm文件開(kāi)始編輯

Assignee相當(dāng)于辦理人的意思 我這里是zhang 提出申請(qǐng)，主管yuan 審核。

5.部署流程流程

// 得到流程引擎private ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); @Test public void deployProcess01() { // 得到流程部署的service RepositoryService repositoryService = this.processEngine.getRepositoryService(); Deployment deploy = repositoryService.createDeployment().name('請(qǐng)假流程').addClasspathResource('activitiTest.bpmn').deploy(); System.out.println('部署成功:流程部署ID：' + deploy.getId()); }

6.啟動(dòng)流程（這里的key與第五部第一張途中對(duì)應(yīng)）

/** * 啟動(dòng)流程 */ @Test public void startProcess() { RuntimeService runtimeService = this.processEngine.getRuntimeService();// String processDefinitionId='HelloWorld:1:4';//runtimeService.startProcessInstanceById(processDefinitionId); String processDefinitionKey='mytest'; runtimeService.startProcessInstanceByKey(processDefinitionKey); System.out.println('流程啟動(dòng)成功'); }

7.根據(jù)用戶查詢?nèi)蝿?wù)（這里使用流程圖中的assignee字段）

@Test public void queryTask() { TaskService taskService = this.processEngine.getTaskService(); String assignee='chen'; List<Task> list = taskService.createTaskQuery().taskAssignee(assignee).list(); if(null!=list&&list.size()>0) { for (Task task : list) {System.out.println('任務(wù)ID:'+task.getId());System.out.println('流程實(shí)例ID:'+task.getProcessInstanceId());System.out.println('執(zhí)行實(shí)例ID:'+task.getExecutionId());System.out.println('流程定義ID:'+task.getProcessDefinitionId());System.out.println('任務(wù)名稱:'+task.getName());System.out.println('任務(wù)辦理人:'+task.getAssignee());System.out.println('################################'); } } }

8.辦理任務(wù)（配合步驟8查詢出taskid然后進(jìn)行辦理任務(wù)）

@Test public void completeTask() { TaskService taskService = this.processEngine.getTaskService(); String taskId='5005';//步驟8中查詢出來(lái)的taskId taskService.complete(taskId); System.out.println('任務(wù)完成'); }

重復(fù)7、8兩個(gè)步驟，自此一個(gè)完整的請(qǐng)假流程就完成了。

那么肯定會(huì)有人問(wèn)了，如果我想查看一我們流程定義的信息，流程圖，刪除流程定義等怎么辦呢，話不多說(shuō)直接上代碼

package com.example;import org.activiti.engine.ProcessEngine;import org.activiti.engine.ProcessEngines;import org.activiti.engine.RepositoryService;import org.activiti.engine.RuntimeService;import org.activiti.engine.repository.Deployment;import org.activiti.engine.repository.ProcessDefinition;import org.junit.jupiter.api.Test;import java.io.BufferedOutputStream;import java.io.File;import java.io.FileOutputStream;import java.io.InputStream;import java.util.Collection;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.zip.ZipInputStream;public class TestProcessProdef { // 得到流程引擎 private ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); /** * 部署流程使用classpath */ @Test public void deployProcess01() { // 得到流程部署的service RepositoryService repositoryService = this.processEngine.getRepositoryService(); Deployment deploy = repositoryService.createDeployment().name('請(qǐng)假流程2').addClasspathResource('activiti.bpmn').deploy(); System.out.println('部署成功:流程部署ID：' + deploy.getId()); } /** * 查詢流程部署信息 act_re_deployment */ @Test public void queryProcessDeploy() { RepositoryService repositoryService = this.processEngine.getRepositoryService(); // 創(chuàng)建部署信息的查詢 String deploymentId = '1';//Deployment deploy = repositoryService.createDeploymentQuery() List<Deployment> list = repositoryService.createDeploymentQuery()// 條件// .deploymentId(deploymentId) //根據(jù)部署ID去查詢// .deploymentName(name)//根據(jù)部署名稱去查詢// .deploymentTenantId(tenantId)//根據(jù)tenantId去查詢//.deploymentNameLike(nameLike)//根據(jù)部署名稱模糊查詢// .deploymentTenantIdLike(tenantIdLike)//根據(jù)tenantId模糊查詢// 排序//.orderByDeploymentId().asc() //根據(jù)部署ID升序// .orderByDeploymenTime().desc() //根據(jù)部署時(shí)間降序// .orderByDeploymentName()//根據(jù)部署名稱升序// 結(jié)果集.list(); // 查詢返回list集合//.listPage(firstResult, maxResults) 分頁(yè)查詢返回list集合 // .singleResult(); //返回單個(gè)對(duì)象//.count(); /* * System.out.println('部署ID:'+deploy.getId()); * System.out.println('部署名稱:'+deploy.getName()); * System.out.println('部署時(shí)間:'+deploy.getDeploymentTime()); *///System.out.println(count); for (Deployment deployment : list) { System.out.println('部署ID:' + deployment.getId()); System.out.println('部署名稱:' + deployment.getName()); System.out.println('部署時(shí)間:' + deployment.getDeploymentTime()); System.out.println('########################'); } } /** * 查詢流程定義 */ @Test public void queryProcDef() { RepositoryService repositoryService = this.processEngine.getRepositoryService(); List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery()// 條件//.deploymentId(deploymentId) 根據(jù)部署ID查詢//.deploymentIds(deploymentIds) 根據(jù)部署ID的集合查詢Set<String> deploymentIds//.processDefinitionId(processDefinitionId)//根據(jù)流程定義IDHelloWorld:1:4//.processDefinitionIds(processDefinitionIds)//根據(jù)流程定義的IDS查詢//.processDefinitionKey(processDefinitionKey)//根據(jù)流程定義的的key查詢//.processDefinitionKeyLike(processDefinitionKeyLike)//根據(jù)流程定義的的key模糊查詢//.processDefinitionName(processDefinitionName)//根據(jù)流程定義的名稱查詢//.processDefinitionNameLike(processDefinitionNameLike)//根據(jù)流程定義的名稱模糊查詢//.processDefinitionResourceName(resourceName)//根據(jù)流程圖的BPMN文件名查詢//.processDefinitionResourceNameLike(resourceNameLike)//根據(jù)流程圖的BPMN文件名模糊查詢//.processDefinitionVersion(processDefinitionVersion)//根據(jù)流程定義的版本查詢//.processDefinitionVersionGreaterThan(processDefinitionVersion)//version>num//.processDefinitionVersionGreaterThanOrEquals(processDefinitionVersion)//version>=num//.processDefinitionVersionLowerThan(processDefinitionVersion)//version<num//.processDefinitionVersionLowerThanOrEquals(processDefinitionVersion)//version<=num// 排序//.orderByDeploymentId()//.orderByProcessDefinitionId()//.orderByProcessDefinitionKey()//.orderByProcessDefinitionName()//.orderByProcessDefinitionVersion()// 結(jié)果集.list();//.listPage(firstResult, maxResults)//.count()//.singleResult() if (null != list && list.size() > 0) { for (ProcessDefinition pd : list) {System.out.println('流程定義ID:' + pd.getId());System.out.println('流程部署ID:' + pd.getDeploymentId());System.out.println('流程定義KEY:' + pd.getKey());System.out.println('流程定義的名稱:' + pd.getName());System.out.println('流程定義的bpmn文件名:' + pd.getResourceName());// bpmn的nameSystem.out.println('流程圖片名:' + pd.getDiagramResourceName());// png的nameSystem.out.println('流程定義的版本號(hào):' + pd.getVersion());System.out.println('##################'); } } } /** * 啟動(dòng)流程 */ @Test public void startProcess() { RuntimeService runtimeService = this.processEngine.getRuntimeService(); String processDefinitionKey = 'mytest'; runtimeService.startProcessInstanceByKey(processDefinitionKey); System.out.println('流程啟動(dòng)成功'); } /** * 刪除流程定義 */ @Test public void deleteProcessDef() { RepositoryService repositoryService = this.processEngine.getRepositoryService(); String deploymentId = '2501'; // 根據(jù)流程部署id刪除流程定義 如果當(dāng)前id的流程正在執(zhí)行，那么會(huì)報(bào)錯(cuò) // repositoryService.deleteDeployment(deploymentId); // 根據(jù)流程部署id刪除刪除流程定義 如果當(dāng)前id的流程正在執(zhí)行,會(huì)把正在執(zhí)行的流程數(shù)據(jù)刪除 act_ru_*和act_hi_*表里面的數(shù)據(jù) repositoryService.deleteDeployment(deploymentId, true);//repositoryService.deleteDeploymentCascade(deploymentId);==repositoryService.deleteDeployment(deploymentId, true); System.out.println('刪除成功'); } /** * 查詢流程圖 根據(jù)流程定義ID */ @Test public void viewProcessImg() { RepositoryService repositoryService = this.processEngine.getRepositoryService(); String processDefinitionId = 'mytest:2:2504'; InputStream inputStream = repositoryService.getProcessDiagram(processDefinitionId); File file = new File('d:/mytest.png'); try { BufferedOutputStream outputStream = new BufferedOutputStream(new FileOutputStream(file)); int len = 0; byte[] b = new byte[1024]; while ((len = inputStream.read(b)) != -1) {outputStream.write(b, 0, len);outputStream.flush(); } outputStream.close(); inputStream.close(); System.out.println('查詢成功'); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 查詢流程圖 根據(jù)流流程部署ID */ @Test public void viewProcessImg2() { RepositoryService repositoryService = this.processEngine.getRepositoryService(); // 根據(jù)流程部署ID查詢流程定義對(duì)象 String deploymentId = '1'; ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deploymentId).singleResult(); // 從流程定義對(duì)象里面查詢出流程定義ID String processDefinitionId = processDefinition.getId(); InputStream inputStream = repositoryService.getProcessDiagram(processDefinitionId); File file = new File('d:/' + processDefinition.getDiagramResourceName()); try { BufferedOutputStream outputStream = new BufferedOutputStream(new FileOutputStream(file)); int len = 0; byte[] b = new byte[1024]; while ((len = inputStream.read(b)) != -1) {outputStream.write(b, 0, len);outputStream.flush(); } outputStream.close(); inputStream.close(); System.out.println('查詢成功'); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 查詢最新的流程定義 */ @Test public void queryNewProcessDef() { Map<String, ProcessDefinition> map = new HashMap<>(); // 查詢所有的流程定義根據(jù)版本號(hào)升序 RepositoryService repositoryService = this.processEngine.getRepositoryService(); List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().orderByProcessDefinitionVersion().asc().list(); if (null != list && list.size() > 0) { for (ProcessDefinition pd : list) {map.put(pd.getKey(), pd); } } // 循環(huán)map集合 Collection<ProcessDefinition> values = map.values(); for (ProcessDefinition pd : values) { System.out.println('流程定義ID:' + pd.getId()); System.out.println('流程部署ID:' + pd.getDeploymentId()); System.out.println('流程定義KEY:' + pd.getKey()); System.out.println('流程定義的名稱:' + pd.getName()); System.out.println('流程定義的bpmn文件名:' + pd.getResourceName());// bpmn的name System.out.println('流程圖片名:' + pd.getDiagramResourceName());// png的name System.out.println('流程定義的版本號(hào):' + pd.getVersion()); System.out.println('##################'); } } /** * 已知key 附加功能：刪除流程定義（刪除key相同的所有不同版本的流程定義） */ public void deleteAllSameVersion() { String processDefinitionKey = 'mytest'; RepositoryService repositoryService = this.processEngine.getRepositoryService(); // 根據(jù)流程定義的key查詢流程集合 List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().processDefinitionKey(processDefinitionKey).list(); if (null != list && list.size() > 0) { for (ProcessDefinition pd : list) {repositoryService.deleteDeployment(pd.getDeploymentId(), true); } } }}

肯定還有人會(huì)問(wèn)，上面的請(qǐng)假流程是走完了，但是沒(méi)有寫請(qǐng)假理由，請(qǐng)假天數(shù)，如果是報(bào)銷單的話 還需要上傳報(bào)銷單據(jù)等，那么這個(gè)怎么解決呢？這個(gè)時(shí)候就需要activiti提供給我們的流程變量了，那么什么是流程變量呢？

流程變量在整個(gè)工作流中扮演很重要的作用。例如：請(qǐng)假流程中有請(qǐng)假天數(shù)、請(qǐng)假原因等一些參數(shù)都為流程變量的范圍。流程變量的作用域范圍是只對(duì)應(yīng)一個(gè)流程實(shí)例。也就是說(shuō)各個(gè)流程實(shí)例的流程變量是不相互影響的。流程實(shí)例結(jié)束完成以后流程變量還保存在數(shù)據(jù)庫(kù)中（存放到流程變量的歷史表中）。圖中紅框的信息就是流程變量。

那么我們?cè)趺丛O(shè)置流程變量呢，我們啟動(dòng)流程的時(shí)候就可以設(shè)置流程變量了，見(jiàn)代碼：

/** * 啟動(dòng)流程 */@Testpublic void startProcess() {RuntimeService runtimeService = this.processEngine.getRuntimeService();String processDefinitionKey = 'mytest';//ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey);//創(chuàng)建流程變量對(duì)象Map<String,Object> variables=new HashMap<>();variables.put('請(qǐng)假天數(shù)', 30);//intvariables.put('請(qǐng)假原因', '結(jié)婚');variables.put('請(qǐng)假時(shí)間', new Date());ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey, variables);System.out.println('流程啟動(dòng)成功:' + processInstance.getId() + ' ' + processInstance.getProcessDefinitionId() + ' '+ processInstance.getProcessInstanceId());}

說(shuō)明：

1)流程變量的作用域就是流程實(shí)例，所以只要設(shè)置就行了，不用管在哪個(gè)階段設(shè)置

2)基本類型設(shè)置流程變量，在taskService中使用任務(wù)ID，定義流程變量的名稱，設(shè)置流程變量的值。

3)Javabean類型設(shè)置獲取流程變量，除了需要這個(gè)javabean實(shí)現(xiàn)了Serializable接口外，還要求流程變量對(duì)象的屬性不能發(fā)生變化，否則拋出異常。解決方案，固定序列化ID

4)設(shè)置流程變量的時(shí)候，向act_ru_variable這個(gè)表添加數(shù)據(jù)

RuntimeService對(duì)象可以設(shè)置流程變量和獲取流程變量 TaskService對(duì)象可以設(shè)置流程變量和獲取流程變量

Map集合的key表示流程變量的名稱 Map集合的value表示流程變量的值

查詢流程變量以及查詢歷史流程變量：

/** * 獲取流程變量 */@Testpublic void getVariables() {RuntimeService runtimeService = this.processEngine.getRuntimeService();String executionId='2501';Integer days=(Integer) runtimeService.getVariable(executionId, '請(qǐng)假天數(shù)');Date date=(Date) runtimeService.getVariable(executionId, '請(qǐng)假時(shí)間');User user=(User) runtimeService.getVariable(executionId, '用戶對(duì)象');System.out.println(days);System.out.println(date.toLocaleString());System.out.println(user.getId()+' '+user.getName());}/** * 7：查詢歷史的流程變量 */@Testpublic void getHistoryVariables() {HistoryService historyService = this.processEngine.getHistoryService();/*HistoricVariableInstance singleResult = historyService.createHistoricVariableInstanceQuery().id('2503').singleResult();;System.out.println(singleResult.getId());System.out.println(singleResult.getValue());System.out.println(singleResult.getVariableName());System.out.println(singleResult.getVariableTypeName());*/String processInstanceId='2501';List<HistoricVariableInstance> list = historyService.createHistoricVariableInstanceQuery().processInstanceId(processInstanceId).list();for (HistoricVariableInstance hvs : list) {System.out.println('ID'+hvs.getId());System.out.println('變量值'+hvs.getValue());System.out.println('變量名'+hvs.getVariableName());System.out.println('變量類型'+hvs.getVariableTypeName());System.out.println('#####################');}}

查詢歷史流程實(shí)例 、查詢歷史活動(dòng) 以及查詢歷史任務(wù)

public class TestHistoryQuery {private ProcessEngine processEngine=ProcessEngines.getDefaultProcessEngine();HistoryService historyService = this.processEngine.getHistoryService();/* 1，查詢歷史流程實(shí)例 */@Testpublic void historyProcessInstince() {List<HistoricProcessInstance> list = historyService.createHistoricProcessInstanceQuery()//條件//.processDefinitionId(processDefinitionId)//.processDefinitionKey(processDefinitionKey)//.processDefinitionKeyIn(processDefinitionKeys)//.processDefinitionName(processDefinitionName)//.processDefinitionVersion(processDefinitionVersion)//.processInstanceBusinessKey(processInstanceBusinessKey)//.processInstanceId(processInstanceId)//.processInstanceIds(processInstanceIds)//排序//.orderByProcessDefinitionId()//.orderByProcessInstanceBusinessKey()//.orderByProcessInstanceDuration()//.orderByProcessInstanceStartTime()//.orderByProcessInstanceId()//結(jié)果集.list();//.listPage(firstResult, maxResults)//.count()//.singleResult();if(null!=list&&list.size()>0) {for (HistoricProcessInstance hpi : list) {System.out.println('歷史流程實(shí)例ID:' + hpi.getId());System.out.println('流程定義ID:' + hpi.getProcessDefinitionId());System.out.println('歷史流程實(shí)例的業(yè)務(wù)ID:' + hpi.getBusinessKey());System.out.println('流程部署ID:' + hpi.getDeploymentId());System.out.println('流程定義KEY:' + hpi.getProcessDefinitionKey());System.out.println('開(kāi)始活動(dòng)ID:' + hpi.getStartActivityId());System.out.println('結(jié)束活動(dòng)ID:' + hpi.getEndActivityId());System.out.println('########################');}}}/* 2，查詢歷史活動(dòng) */@Testpublic void queryHistoryAct() {List<HistoricActivityInstance> list = this.historyService.createHistoricActivityInstanceQuery()//條件//.activityId(activityId)//.activityInstanceId(activityInstanceId)//.activityName(activityName)//排序//.orderByActivityId()//.orderByActivityName()//結(jié)果集.list();if(null!=list&&list.size()>0){for (HistoricActivityInstance hai : list) {System.out.println('ID:'+hai.getId());System.out.println('流程定義ID:'+hai.getProcessDefinitionId());System.out.println('流程實(shí)例ID:'+hai.getProcessInstanceId());System.out.println('執(zhí)行實(shí)例ID:'+hai.getExecutionId());System.out.println('活動(dòng)ID:'+hai.getActivityId());System.out.println('任務(wù)ID:'+hai.getTaskId());System.out.println('活動(dòng)名稱:'+hai.getActivityName());System.out.println('活動(dòng)類型:'+hai.getActivityType());System.out.println('任務(wù)辦理人:'+hai.getAssignee());System.out.println('開(kāi)始時(shí)間:'+hai.getStartTime());System.out.println('結(jié)束時(shí)間:'+hai.getEndTime());System.out.println('持續(xù)時(shí)間:'+hai.getDurationInMillis());System.out.println('#######################################');}}}/* 3，查詢歷史任務(wù) act_hi_taskinst */@Testpublic void queryHistoryTask() {List<HistoricTaskInstance> list = this.historyService.createHistoricTaskInstanceQuery()//條件//.deploymentId(deploymentId)//.deploymentIdIn(deploymentIds)//.executionId(executionId)//.processDefinitionId(processDefinitionId)//.processDefinitionKey(processDefinitionKey)//.processDefinitionKeyIn(processDefinitionKeys)//.processDefinitionKeyLike(processDefinitionKeyLike) processDefinitionKeyLike='%Hello%'//.processDefinitionName(processDefinitionName)//.processDefinitionNameLike(processDefinitionNameLike)//排序//.orderByTaskDefinitionKey()//結(jié)果集.list();//.listPage(firstResult, maxResults)//.count()//.singleResult()if(null!=list&&list.size()>0){for (HistoricTaskInstance task : list) {System.out.println('任務(wù)ID:' + task.getId());System.out.println('任務(wù)辦理人:' + task.getAssignee());System.out.println('執(zhí)行實(shí)例ID:' + task.getExecutionId());System.out.println('任務(wù)名稱:' + task.getName());System.out.println('流程定義ID:' + task.getProcessDefinitionId());System.out.println('流程實(shí)例ID:' + task.getProcessInstanceId());System.out.println('任務(wù)創(chuàng)建時(shí)間:' + task.getCreateTime());System.out.println('任務(wù)結(jié)束時(shí)間:' + task.getEndTime());System.out.println('#######################################');}}}}

最近我發(fā)現(xiàn)上面的代碼不能完全在開(kāi)發(fā)中應(yīng)用，比如上面的用戶申請(qǐng)是在畫流程圖的時(shí)候?qū)懰赖模趯?shí)際開(kāi)發(fā)中肯定是根據(jù)當(dāng)前登錄的用戶來(lái)提出申請(qǐng)，另外還沒(méi)有分支的情況，所以我特地修改了一下流程圖。

這個(gè)流程圖中 沒(méi)有設(shè)置用戶，在Condition中傳入?yún)?shù)#{UserId},后面的重要與不重要分支同樣加上Condition條件${message==’重要’}和${message==’不重要’}，然后主管審核和總經(jīng)理的assignee可以設(shè)置成固定的值也可以像用戶一樣根據(jù)傳參設(shè)置。接下來(lái)直接上代碼

1.啟動(dòng)流程

/**啟動(dòng)流程實(shí)例*/ @Test public void startProcessInstance(){ String processDefinitionKey = 'myProcess_1'; /**啟動(dòng)流程實(shí)例的同時(shí)，設(shè)置流程變量，使用流程變量用來(lái)指定任務(wù)的辦理人，對(duì)應(yīng)task.pbmn文件中#{userID}*/ Map<String, Object> variables = new HashMap<String, Object>(); variables.put('userID', '袁志豪'); ProcessInstance pi = processEngine.getRuntimeService()//與正在執(zhí)行的流程實(shí)例和執(zhí)行對(duì)象相關(guān)的Service .startProcessInstanceByKey(processDefinitionKey,variables);//使用流程定義的key啟動(dòng)流程實(shí)例，key對(duì)應(yīng)helloworld.bpmn文件中id的屬性值，使用key值啟動(dòng)，默認(rèn)是按照最新版本的流程定義啟動(dòng) System.out.println('流程實(shí)例ID:'+pi.getId());//流程實(shí)例ID 101 System.out.println('流程定義ID:'+pi.getProcessDefinitionId());//流程定義ID }

用戶完成申請(qǐng)?zhí)峤唬鞴茉诹鞒蓤D中沒(méi)有設(shè)置固定值

@Test public void completeTask() { TaskService taskService = this.processEngine.getTaskService(); String taskId = '2508'; // 根據(jù)任務(wù)ID去完成任務(wù) // taskService.complete(taskId); // 根據(jù)任務(wù)ID去完成任務(wù)并指定流程變量 Map<String,Object > variable =new HashMap<>(); String shenheren ='張三';//實(shí)際開(kāi)發(fā)中可在前臺(tái)選擇主管傳入后臺(tái) variable.put('zhuguan','張三');//這里的 zhuguan 和 activiti.bpmn中的#{zhuguan}保持一致,既可以設(shè)置下一級(jí)審核主管taskService.complete(taskId, variables); System.out.println('任務(wù)完成'); }

主管審核

@Test public void complateTask2(){ TaskService taskService = this.processEngine.getTaskService(); String taskId2= '5002'; Map<String,Object > variable =new HashMap<>(); /***這里的message 是流程圖中分支條件message,根據(jù)傳入的參數(shù)判斷走那一條線***/ variable.put('message','重要');// variable.put('message','不重要'); taskService.complete(taskId2,variable); }

經(jīng)理審核

@Test public void complateTask3(){ TaskService taskService = this.processEngine.getTaskService(); String taskId2= '7503'; Map<String,Object > variable =new HashMap<>(); variable.put('審核意見(jiàn)','好好休假注意身體');//領(lǐng)導(dǎo)審核意見(jiàn) taskService.complete(taskId2,variable); }

另外我在開(kāi)發(fā)中發(fā)現(xiàn)在流程圖畫完之后將bpmn后綴改為xml方式生成圖片之后，再次改為bpmn的時(shí)候，發(fā)現(xiàn)之前寫的Condition中變成了n,如圖

我們?cè)俅螌⒑缶Y改為xml之后查看我們的條件：

解決方式：

將condition前面后面的空格刪掉即可；

到此這篇關(guān)于關(guān)于在IDEA中SpringBoot項(xiàng)目中activiti工作流的使用詳解的文章就介紹到這了,更多相關(guān)IDEA SpringBoot activiti工作流內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！