activiti6.0學(xué)習(xí)筆記（一）：核心api之RepostoryService

一、前言

???? 最近因?yàn)楣ぷ餍枰?，需要搭建工作流平臺(tái)。經(jīng)過研究后覺得使用activiti6.0作為平臺(tái)搭建技術(shù)?，F(xiàn)將學(xué)習(xí)過程記錄下來，此處不記錄整合activiti的過程。整合過程另開博客記錄。

二、環(huán)境準(zhǔn)備

???? 筆者環(huán)境為：

???? jdk 1.8

???? idea 2018.1.1

???? springboot? 2.0.5.RELEASE

三、核心api之RepostoryService

?? 1、創(chuàng)建流程文件TestProcess.bpmn

? 可以使用圖形化界面創(chuàng)建，如圖：

創(chuàng)建以后將后綴改為xml，如testProcess.bpmn20.xml

?修改后的xml文件內(nèi)容為：

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>

<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" xmlns:tns="http://www.activiti.org/test" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" expressionLanguage="http://www.w3.org/1999/XPath" id="m1538297113127" name="" targetNamespace="http://www.activiti.org/test" typeLanguage="http://www.w3.org/2001/XMLSchema">

? <process id="myProcess" isClosed="false" isExecutable="true" name="測試流程" processType="None">

? ? <startEvent id="startevent1" name="Start"/>

? ? <endEvent id="endevent1" name="End"/>

? ? <userTask activiti:assignee="張三" activiti:exclusive="true" id="test" name="用戶"/>

? ? <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="test"/>

? ? <sequenceFlow id="flow2" sourceRef="test" targetRef="endevent1"/>

? <bpmndi:BPMNDiagram documentation="background=#3C3F41;count=1;horizontalcount=1;orientation=0;width=842.4;height=1195.2;imageableWidth=832.4;imageableHeight=1185.2;imageableX=5.0;imageableY=5.0" id="Diagram-_1" name="New Diagram">

//此處省略

</bpmndi:BPMNDiagram>

</definitions>

2、測試代碼 如下

/**

*

*? 測試RepostoryService

*? RepostoryService操作對象：

*? ? 1、部署文件構(gòu)造器? DeploymentBuilder

*? ? 2、部署文件查詢器? DeploymentQuery

*? ? 3、流程定義文件查詢對象? ProcessDefinitionQuery

*? ? 4、流程部署文件對象 Deployment

*? ? 5、流程定義文件對象 ProcessDefinition

*? ? 6、流程定義的java格式 BpmnModel

*

*

* @author chaoge

* @since 2018/9/29 17:22

*/

public class RepositoryServiceTest {

private static final LoggerLOGGER = LoggerFactory.getLogger(RepositoryServiceTest.class);

? ? @Rule

? ? public ActivitiRulerule =new ActivitiRule();//默認(rèn)資源配置文件activiti.cfg.xml

? ? /**

? ? * 測試流程部署

? ? */

? ? @Test

? ? public void testRepostoryService() {

RepositoryService repositoryService =rule.getRepositoryService();

? ? ? ? DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();//創(chuàng)建部署流程的builder

? ? ? ? Deployment deployment = deploymentBuilder.name("測試部署資源")

.addClasspathResource("processes/TestProcess.bpmn").deploy();

? ? ? ? LOGGER.info("deployment = {}", deployment);

? ? ? ? //使用repositoryService獲取流程部署的query對象，根據(jù)這個(gè)對象可以獲取流程部署信息

? ? ? ? DeploymentQuery deploymentQuery = repositoryService.createDeploymentQuery();

? ? ? ? Deployment deployment1 = deploymentQuery.deploymentId(deployment.getId()).singleResult();

? ? ? ? LOGGER.info("deployment1 = {}", deployment1);

? ? ? ? LOGGER.info("deployment = deployment1？ {}", deployment1.equals(deployment));//結(jié)果居然是false

? ? ? ? //輸出后兩個(gè)deployment居然不等，為false? debug后發(fā)現(xiàn) deployment下的deploymentTime中fastTime屬性不一樣

? ? ? ? List deployments = deploymentQuery.orderByDeploymenTime().asc().listPage(1, 100);

? ? ? ? deployments.forEach(deployment2 -> {

LOGGER.info("deployment1 = {}", deployment2);

? ? ? ? ? ? //級聯(lián)刪除流程

? ? ? ? ? ? //repositoryService.deleteDeployment(a.getId(),true);

? ? ? ? });

? ? ? ? //上面使用了lambda表達(dá)式，該方法等同于下面的使用for循環(huán)，后面的一樣，此處說明方便不會(huì)使用lambda的人，會(huì)的人直接忽略

//? ? ? ? for (Deployment deployment2:deployments){

//? ? ? ? ? ? LOGGER.info("deployment1 = {}", deployment2);

//? ? ? ? }

? ? ? ? //使用repositoryService查找流程定義的query對象根據(jù)這個(gè)對象可以獲取流程定義信息

? ? ? ? ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();

? ? ? ? List processDefinitions = processDefinitionQuery.listPage(1, 100);

? ? ? ? processDefinitions.forEach(

a ->LOGGER.info("processDefinition:{};version:{},key:{};name:{};id:{}"

? ? ? ? ? ? ? ? ? ? ? ? , a, a.getVersion(), a.getKey(), a.getName(), a.getId())

);

? ? }

/**

? ? * 測試流程定義掛起和激活

? ? */

? ? @Test

? ? @org.activiti.engine.test.Deployment(resources ="processes/TestProcess.bpmn")//activiti自動(dòng)部署

? ? public void testSuspend() {

RepositoryService repositoryService =rule.getRepositoryService();

? ? ? ? ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();

? ? ? ? LOGGER.info("processDefinition.id = {}", processDefinition.getId());

? ? ? ? System.out.println("processDefinition.id = " + processDefinition.getId());

? ? ? ? //將流程掛起-暫停

? ? ? ? //如果已經(jīng)掛起，則會(huì)報(bào)錯(cuò)

? ? ? ? // org.activiti.engine.ActivitiException:

// Cannot set suspension state 'suspended' for

// ProcessDefinitionEntity[exclusiveGatewayAndTimerBoundaryEventProcess:2:2504]':

// already in state 'suspended'.

? ? ? ? repositoryService.suspendProcessDefinitionById(processDefinition.getId());

? ? ? ? LOGGER.info("啟動(dòng)流程,但是因?yàn)榱鞒桃呀?jīng)被掛起，所以此時(shí)就會(huì)報(bào)錯(cuò)? 啟動(dòng)的流程id={}", processDefinition.getId());

? ? ? ? System.out.println("啟動(dòng)流程,但是因?yàn)榱鞒桃呀?jīng)被掛起，所以此時(shí)就會(huì)報(bào)錯(cuò)");

? ? ? ? //報(bào)錯(cuò)信息為org.activiti.engine.ActivitiException:

? ? ? ? // Cannot start process instance. Process definition 排他網(wǎng)關(guān)和定時(shí)邊界任務(wù)流程

? ? ? ? // (id = exclusiveGatewayAndTimerBoundaryEventProcess:2:2504) is suspended

? ? ? ? //啟動(dòng)流程

? ? ? ? startProcessInstanceById(processDefinition);

? ? ? ? //激活流程定義

? ? ? ? repositoryService.activateProcessDefinitionById(processDefinition.getId());

? ? ? ? startProcessInstanceById(processDefinition);

? ? ? ? //刪除流程

? ? ? ? //repositoryService.deleteDeployment(processDefinition.getId(),true);

? ? }

/**

? ? * 測試用戶和用戶組

? ? */

? ? @Test

? ? @org.activiti.engine.test.Deployment(resources ="processes/second_approve.bpmn")//activiti自動(dòng)部署

? ? public void testCandidateStart() {

RepositoryService repositoryService =rule.getRepositoryService();

? ? ? ? ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();

? ? ? ? LOGGER.info("processDefinition.id = {}", processDefinition.getId());

? ? ? ? System.out.println("processDefinition.id = " + processDefinition.getId());

? ? ? ? //添加啟動(dòng)用戶，對應(yīng)流程文件中啟動(dòng)人的Candidate User屬性，多個(gè)用戶以“，”相隔

? ? ? ? repositoryService.addCandidateStarterUser(processDefinition.getId(),"use1");

? ? ? ? repositoryService.addCandidateStarterGroup(processDefinition.getId(),"groupM");//啟動(dòng)用戶組

? ? ? ? List identityLinks = repositoryService.getIdentityLinksForProcessDefinition(processDefinition.getId());

? ? ? ? identityLinks.forEach(identityLink ->LOGGER.info("identityLink: {}",identityLink));

? ? ? ? //刪除啟動(dòng)用戶及用戶組

? ? ? ? repositoryService.deleteCandidateStarterUser(processDefinition.getId(),"use1");

? ? ? ? repositoryService.deleteCandidateStarterGroup(processDefinition.getId(),"groupM");

? ? }

private void startProcessInstanceById(ProcessDefinition processDefinition) {

try {

System.out.println("開始啟動(dòng)流程");

? ? ? ? ? ? rule.getRuntimeService().startProcessInstanceById(processDefinition.getId());

? ? ? ? ? ? System.out.println("流程已啟動(dòng)");

? ? ? ? }catch (Exception e) {

System.out.println("流程啟動(dòng)失敗");

? ? ? ? ? ? LOGGER.info("流程啟動(dòng)失敗");

? ? ? ? ? ? LOGGER.info(e.getMessage(), e);

? ? ? ? }

}

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容