江苏省城市建设信用手册网站,上海网站优化上,跨境电商公司取名,百度做网站的电话Activiti7工作流
一、工作流介绍
1.1 概念
工作流(Workflow)#xff0c;就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程#xff0c;从而实现某个预期的业务目标#xff0c;或者促使…Activiti7工作流
一、工作流介绍
1.1 概念
工作流(Workflow)就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程从而实现某个预期的业务目标或者促使此目标的实现”。
案例: 出差费用报销
目标: 公司把出差费用转账到自己的账户中.
参与人: 申请人、部门主管、总经理、财务
** **
传递文件/执行任务
** **
什么是工作流系统?
一个软件系统中具有工作流的功能我们把它称为工作流系统。
1.2 适用行业
消费品行业制造业电信服务业银证险等金融服务业物流服务业物业服务业物业管理大中型进出口贸易公司政府事业机构研究院所及教育服务业等特别是大的跨国企业和集团公司。
1.3 应用领域
企业: 采购流程、合同审核流程
客户: 客户电话投诉处理流程
生活中: 住房贷款审批流程、办理身份证、办理准生手续
行政: 出差审批、报销流程、请假审批、用车流程、会议室申请
银行业: 信贷审批、信用卡发卡审批
人事: 员工培训、绩效考核、职位变动
1.4 传统实现方式
我们可以思考下,如果需要实现【出差费用报销】工作流程,代码应该如何实现? 1.需要在发起申请的时候选择每个阶段由哪个人员进行审批(数据库需要记录)
2.我们需要在数据库中设计一个状态的字段【主管审批0,总经理审批1,财务审批2】主管审批通过之后把状态修改为总经理审批.(硬编码的方式)
3.当流程处于主管审批时只有角色为主管的用户才能看到这条审核数据.
通过上面的描述同学们会发现我们要实现这个流程控制我们需要大量的代码才能完成.【工作量大】
而且如果流程发生改变的情况下,我们编写的代码也需要进行调整【不灵活】
1.5 什么是工作流引擎
是一种按照预定义规则【需要符合BPMN规范】进行部署将业务和节点的流程进行分离【特定形式进行关联】
实现节点的自动流转的工作流框架. 1.需要将预定于的流程文件BPMN部署到工作流引擎中,会把节点,路径信息存储到数据库中.
2.工作流引擎提供了大量的API对流程进行查询处理,细节都是对应用程序屏蔽的,大大提供开发效率
3.业务逻辑的处理和流程的流转是分离的是通过BusinessKey进行关联的.
二、什么是Activiti7
2.1 概述
Alfresco 软件在 2010 年 5 月 17 日宣布 Activiti 业务流程管理BPM开源项目的正式启动 其 首席架构师由业务流程管理 BPM 的专家 Tom Baeyens 担任 Tom Baeyens 就是原来 jbpm 的架构师 而 jbpm 是一个非常有名的工作流引擎当然 activiti 也是一个工作流引擎。Activiti 是一个工作流引擎 activiti 可以将业务系统中复杂的业务流程抽取出来使用专门的 建模语言BPMN2.0进行定义业务系统按照预先定义的流程进行执行实现了业务系统的业务 流程由 activiti 进行管理减少业务系统由于流程变更进行系统升级改造的工作量从而提高系统的 健壮性同时也减少了系统开发维护成本。
官方网站: https://www.activiti.org 2.2 Activiti7内部核心机制
1️⃣业务流程图要规范化需要遵守一套标准。2️⃣业务流程图本质上就是一个XML文件而XML可以存放所要的数据。3️⃣读取业务流程图的过程就是解析XML文件的过程。4️⃣读取一个业务流程图的结点就相当于解析一个XML的结点进一步将数据插入到MySQL表中形成一条记录。5️⃣将一个业务流程图的所有节点都读取并存入到MySQL表中。6️⃣后面只要读取MySQL表中的记录就相当于读取业务流程图的一个节点。7️⃣业务流程的推进后面就转换为读取表中的数据并且处理数据结束的时候这一行数据就可以删除了。
2.3 BPMN BPMNBusiness Process Model And Notation业务流程模型和符号是由BPMIBusiness Process Management Initiative开发的一套的业务流程建模符号使用BPMN提供的符号可以创建业务流程。2004年5月发布了BPMN1.0规范。BPMI于2005年9月并入OMGThe Object Management Group对象管理组织组织。OMG于2011年1月发布BPMN2.0的最终版本。 Activit就是使用BPMN2.0进行流程建模、流程执行管理它包括很多的建模符号。 一个BPMN的例子 当事人填写请假单启动流程后把请假单ID绑定到流程中部门经理对请假单进行审核然后人事经理进行复核并进行备案最后请假流程结束。 思考: 我们看到的是一张图片(png),但是应用程序如何知道下一个节点应该流向到哪里呢?拿到需要去解析png文件吗? BPMN其实是用XML表示业务流程的上面的.bpmn文件使用文本编辑器打开 ?xml version1.0 encodingUTF-8 standaloneyes?
definitions xmlnshttp://www.omg.org/spec/BPMN/20100524/MODEL xmlns:activitihttp://activiti.org/bpmn xmlns:bpmndihttp://www.omg.org/spec/BPMN/20100524/DI xmlns:omgdchttp://www.omg.org/spec/DD/20100524/DC xmlns:omgdihttp://www.omg.org/spec/DD/20100524/DI xmlns:tnshttp://www.activiti.org/test xmlns:xsdhttp://www.w3.org/2001/XMLSchema xmlns:xsihttp://www.w3.org/2001/XMLSchema-instance expressionLanguagehttp://www.w3.org/1999/XPath idm1620716847764 name targetNamespacehttp://www.activiti.org/test typeLanguagehttp://www.w3.org/2001/XMLSchemaprocess idleave isClosedfalse isExecutabletrue processTypeNonestartEvent id_2 nameStartEvent/userTask activiti:candidateUserslisi,wangwu activiti:exclusivetrue id_4 name部门经理审批/userTask activiti:assigneerose activiti:exclusivetrue id_6 name人事复批/endEvent id_7 nameEndEvent/sequenceFlow id_12 sourceRef_6 targetRef_7/sequenceFlow id_13 sourceRef_2 targetRef_4/sequenceFlow id_14 sourceRef_4 targetRef_6//processbpmndi:BPMNDiagram documentationbackground#FFFFFF;count1;horizontalcount1;orientation0;width842.4;height1195.2;imageableWidth832.4;imageableHeight1185.2;imageableX5.0;imageableY5.0 idDiagram-_1 nameNew Diagrambpmndi:BPMNPlane bpmnElementleavebpmndi:BPMNShape bpmnElement_2 idShape-_2omgdc:Bounds height32.0 width32.0 x175.0 y185.0/bpmndi:BPMNLabelomgdc:Bounds height32.0 width32.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNShapebpmndi:BPMNShape bpmnElement_4 idShape-_4omgdc:Bounds height55.0 width85.0 x245.0 y175.0/bpmndi:BPMNLabelomgdc:Bounds height55.0 width85.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNShapebpmndi:BPMNShape bpmnElement_6 idShape-_6omgdc:Bounds height55.0 width85.0 x380.0 y175.0/bpmndi:BPMNLabelomgdc:Bounds height55.0 width85.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNShapebpmndi:BPMNShape bpmnElement_7 idShape-_7omgdc:Bounds height32.0 width32.0 x505.0 y185.0/bpmndi:BPMNLabelomgdc:Bounds height32.0 width32.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNShapebpmndi:BPMNEdge bpmnElement_13 idBPMNEdge__13 sourceElement_2 targetElement_4omgdi:waypoint x207.0 y201.0/omgdi:waypoint x245.0 y202.5/bpmndi:BPMNLabelomgdc:Bounds height0.0 width0.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNEdgebpmndi:BPMNEdge bpmnElement_12 idBPMNEdge__12 sourceElement_6 targetElement_7omgdi:waypoint x465.0 y202.5/omgdi:waypoint x505.0 y201.0/bpmndi:BPMNLabelomgdc:Bounds height0.0 width0.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNEdgebpmndi:BPMNEdge bpmnElement_14 idBPMNEdge__14 sourceElement_4 targetElement_6omgdi:waypoint x330.0 y202.5/omgdi:waypoint x380.0 y202.5/bpmndi:BPMNLabelomgdc:Bounds height0.0 width0.0 x0.0 y0.0//bpmndi:BPMNLabel/bpmndi:BPMNEdge/bpmndi:BPMNPlane/bpmndi:BPMNDiagram
/definitions2.4 Activiti如何使用
2.4.1 整合Activiti
Activiti是一个工作流引擎业务系统使用Activiti来对系统的业务流程进行自动化管理为了方便业务系统访问操作Activiti的接口或功能通常将Activiti和业务系统的环境集成在一起。
2.4.2 业务流程建模
使用Activiti流程建模工具(Activity-designer)定义业务流程(.bpmn文件)。.bpmn文件就是业务流程定义文件通过xml定义业务流程。如果使用其他公司开发的工作引擎一般都提供了可视化的建模工具Process Designer用于生成流程定义文件建模工具操作直观一般都支持图形化拖拽方式、多窗口的用户界面、丰富的过程图形元素、过程元素拷贝、粘贴、删除等功能。
2.4.3 部署业务流程
向Activiti部署业务流程定义(.bpmn文件)。使用Activiti提供的API向Activiti中部署.bpmn文件一般情况下还需要一起部署业务流程的图片.png。
2.4.4 启动流程实例
启动一个流程实例表示开始一次业务流程的运行比如员工请假流程部署完成如果张三要请假就可以启动一个流程实例如果李四要请假也需要启动一个流程实例两个流程的执行互不影响就好比定义一个Java类实例化两个Java对象一样部署的流程就好比Java类启动一个流程实例就好比new一个Java对象。
2.4.5 查询待办任务
因为现在系统的业务流程已经交给Activiti管理通过Activiti就可以查询当前流程执行到哪里了当前用户需要办理什么任务了这些Activiti帮我们管理了而不像传统方式中需要我们在SQL语句中的WHERE条件中指定当前查询的状态值是多少。
2.4.6 处理待办任务
用户查询待办任务后就可以办理某个任务如果这任务办理完成还需要其他用户办理比如采购单创建后由部门经理审核这个过程也是由Activiti帮我们完成了不需要我们在代码中硬编码指定下一个任务办理人了
2.4.7 结束流程
当任务办理完成没有下一个任务/结点了这个流程实例就完成了。
三、Activiti7环境
3.1 开发环境
Jdk1.8或以上版本
Mysql 5及以上的版本
Tomcat8.5
IDEA
Activiti 7.0.0.SR1
3.2 安装Activiti流程设计器
3.2.1 在线安装
在Plugins中搜索actiBPM然后点击Search in repositories,无法在线安装的同学请选择本地安装 会弹出如下窗口 安装完成之后点击Restart IntelliJ IDEA 重启IDEA即可
3.2.2 本地安装 从IDEA官网下载actiBPM.jar包,下载地址:https://plugins.jetbrains.com/plugin/7429-actibpm/versions 从本地安装actiBPM 点击Install plugin from disk 后选择下载好的actiBPM.jar然后重启IDEA即可.
3.3 解决actiBPM中文乱码
在IDEA中将File–Settings–Editor–File Encodings修改为UTF-8 在IDEA的Help–Edit Custom VM Options中末尾添加-Dfile.encodingUTF-8 在IDEA的安装目录的bin目录下将idea.exe.vmoptions和idea64.exe.vmoptions两个文件末尾添加-Dfile.encodingUTF-8 重启IDEA即可。
3.4 Activiti支持的数据库 Activiti的运行需要数据库的支撑支持如下: h2MySQLOracleDb2postgresmssql 在Navicat工具中创建activiti的数据库用于后续的实验.
四、集成Activiti7
4.1 创建Maven项目
通过IDEA创建Maven的Java工程。
4.2 添加Maven依赖
在Java工程中加入ProcessEngine所需要的jar包包括
activiti-engine-7.0.0.GA.jaractiviti依赖的jar包mybatis、slf4j、log4j等activiti依赖的spring的jar包数据库驱动第三方数据库连接池dbcp单元测试junit
pom.xml文件 propertiesslf4j.version1.6.6/slf4j.versionlog4j.version1.2.12/log4j.versionactiviti.version7.0.0.SR1/activiti.version/propertiesdependencies!-- activiti引擎 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-engine/artifactIdversion${activiti.version}/version/dependency!-- 整合Spring --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-spring/artifactIdversion${activiti.version}/version/dependency!-- bpmn 模型处理 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-bpmn-model/artifactIdversion${activiti.version}/version/dependency!-- bpmn 转换 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-bpmn-converter/artifactIdversion${activiti.version}/version/dependency!-- bpmn json数据转换 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-json-converter/artifactIdversion${activiti.version}/version/dependency!-- bpmn 布局 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-bpmn-layout/artifactIdversion${activiti.version}/version/dependency!-- mysql驱动 --dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion5.1.40/version/dependency!-- mybatis --dependencygroupIdorg.mybatis/groupIdartifactIdmybatis/artifactIdversion3.4.5/version/dependency!-- 链接池 --dependencygroupIdcommons-dbcp/groupIdartifactIdcommons-dbcp/artifactIdversion1.4/version/dependency!-- 单元测试 --dependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.12/version/dependency!-- log start --dependencygroupIdlog4j/groupIdartifactIdlog4j/artifactIdversion${log4j.version}/version/dependencydependencygroupIdorg.slf4j/groupIdartifactIdslf4j-api/artifactIdversion${slf4j.version}/version/dependencydependencygroupIdorg.slf4j/groupIdartifactIdslf4j-log4j12/artifactIdversion${slf4j.version}/version/dependency!-- log end --dependencygroupIdcommons-io/groupIdartifactIdcommons-io/artifactIdversion2.6/version/dependency!--数据库连接池--dependencygroupIdcom.alibaba/groupIdartifactIddruid/artifactIdversion1.2.4/version/dependency/dependencies4.3 添加log4j日志配置
我们使用log4j日志包可以对日志进行配置在resources下创建log4j.properties,内容如下:
# Set root category priority to INFO and its only appender to CONSOLE.
#log4j.rootCategoryINFO, CONSOLE debug info warn error fatal
log4j.rootCategorydebug, CONSOLE, LOGFILE
# Set the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterpriseFATAL, CONSOLE
# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLEorg.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layoutorg.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n
# LOGFILE is set to be a File appender using a PatternLayout.
log4j.appender.LOGFILEorg.apache.log4j.FileAppender
log4j.appender.LOGFILE.File./activiti.log
log4j.appender.LOGFILE.Appendtrue
log4j.appender.LOGFILE.layoutorg.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n4.4 添加核心配置文件
需要在resource目录中添加配置文件activiti.cfg.xml,内容如下:
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/contex
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
/beans需要在配置文件中配置如下信息 数据库连接池Activiti单独运行的ProcessEngine配置
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/contex
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd!--数据库连接池--bean iddataSource classcom.alibaba.druid.pool.DruidDataSourceproperty namedriverClassName valuecom.mysql.jdbc.Driver /property nameurl valuejdbc:mysql:///activiti /property nameusername valueroot /property namepassword valueadmin //bean!-- 默认id对应的值 为processEngineConfiguration --bean idprocessEngineConfiguration classorg.activiti.engine.impl.cfg.StandaloneProcessEngineConfigurationproperty namedataSource refdataSource/!--activiti数据库表处理策略false(默认值)检查数据库的版本和依赖库的版本如果不匹配就抛出异常true构建流程引擎时执行检查如果需要就执行更新。如果表不存在就创建。create-drop构建流程引擎时创建数据库报表关闭流程引擎时就删除这些表。drop-create先删除表再创建表。create构建流程引擎时创建数据库表关闭流程引擎时不删除这些表--property namedatabaseSchemaUpdate valuetrue//bean
/beans4.5 测试
创建一个测试类调用activiti的工具类生成acitivti需要的数据库表。代码如下:
package cn.wolfcode.demo;import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.junit.Test;public class _01TestInit {Testpublic void testInit(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();System.out.println(processEngine);}
}4.6 数据库表的命名规则 此时我们查看数据库发现25张表结果如下所示
Activiti的表都是以ACT_开头。第二部分是表示表的用途的两个字母标识。用途也和服务的API对应。
ACT_RE_*RE’表示Repository。这个前缀的表包含了流程定义和流程静态资源图片、规则等等。ACT_RU_*RU’表示Runtime。这些运行时的表包含流程实例任务、变量异步任务等运行中的数据。Activiti只在流程实例执行过程中保存这些数据在流程结束时就会删除这些记录。这些运行时表可以一直很小并且速度很快。ACT_HI_*HI’表示History。这些表包含历史数据比如历史流程实例变量任务等等。ACT_GE_*GE’表示General。通用数据用于不同场景下。
五、流程引擎API ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();
这行代码默认是读取resource目录下的activiti.cfg.xml文件这个文件本质上就是spring的配置文件加载之后会读取配置文件中id名为processEngineConfiguration的bean,通过这个配置对象可以获取到流程引擎对象ProcessEngine
5.1 Service总览
Service接口说明RepositoryServiceActiviti的资源管理接口RuntimeServiceActiviti的流程运行管理接口TaskServiceActiviti的任务管理接口HistoryServiceActiviti的历史管理接口ManagementServiceActiviti的引擎管理接口 RepositoryService是Activiti的资源管理接口提供了管理和控制流程发布包和流程定义的操作。使用工作流建模工具设计的业务流程图需要使用此Service将流程定义文件的内容部署到计算机中。 RuntimeService是Activiti的流程运行管理接口可以从这个接口中获取很多关于流程执行相关的信息。 TaskService是Activiti的任务管理接口可以从这个接口中获取任务的信息。 HistoryService是Activiti的历史管理类可以查询历史信息执行流程时引擎会包含很多数据根据配置比如流程实例启动时间任务的参与者完成任务的时间每个流程实例的执行路径等等。 ManagementService是Activiti的引擎管理接口提供了对Activiti流程引擎的管理和维护功能这些功能不在工作流驱动的应用程序中使用主要用于Activiti系统的日常维护。
六、Activiti7入门
6.1 业务流程建模
6.1.1 绘制流程图
在resource目录下新建bpmn目录用于存放所有的流程文件 ,在bpmn目录下新建leave.bpmn,内容如下: 6.1.2 指定任务负责人
为每个任务结点指定负责人如部门经理的审核人是李四。 6.1.3 生成png格式流程图
bpmn文件本质上是xml格式,我们打开看到的是图片格式是因为我们在IDEA中安装了actiBPM的插件.
如果我们把bpmn文件部署到Web环境,那么就只能看到xml信息,无法看到类似上面的图形了.
我们可以再部署之前根据bpmn文件生成png文件然后把bpmn和png文件同时部署到Web环境中.如果我们想查看流程图的话我们就可以通过Activiti把这个png文件读取出来. 接下来我们把bpmn导出为png文件 将leave.bpmn文件重命名为leave.xml文件 右键点击leave.xml文件 -- Diagrams -- Show BPMN Designer... 点击导出按钮,保存在resource/bpmn同级目录下 导出png之后,把leave.xml更名为leave.bpmn 6.2 部署流程定义
使用RepositoryService部署流程定义
package cn.wolfcode.demo;import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
import org.junit.Test;/*** Created by wolfcode*/
public class ActivitiTest {Testpublic void testDeploy(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryService对象RepositoryService repositoryService processEngine.getRepositoryService();//进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(bpmn/leave.bpmn).addClasspathResource(bpmn/leave.png).name(请假流程).deploy();//输出部署的一些信息System.out.println(流程部署ID:deployment.getId());System.out.println(流程部署名称:deployment.getName());}
}观察日志发现进行部署会操作如下表.
ACT_GE_PROPERTY 引擎属性表
Preparing: update ACT_GE_PROPERTY SET REV_ ?, VALUE_ ? where NAME_ ? and REV_ ? Parameters: 2(Integer), 2501(String), next.dbid(String), 1(Integer)ACT_RE_PROCDEF 流程定义表
Preparing: insert into ACT_RE_PROCDEF(ID_, REV_, CATEGORY_, NAME_, KEY_, VERSION_, DEPLOYMENT_ID_, RESOURCE_NAME_, DGRM_RESOURCE_NAME_, DESCRIPTION_, HAS_START_FORM_KEY_, HAS_GRAPHICAL_NOTATION_ , SUSPENSION_STATE_, TENANT_ID_, ENGINE_VERSION_) values (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) Parameters: leaveProcess:1:4(String), http://www.activiti.org/test(String), 请假流程(String), leaveProcess(String), 1(Integer), 1(String), bpmn/leave.bpmn(String), bpmn/leave.png(String), null, false(Boolean), true(Boolean), 1(Integer), (String), nullACT_RE_DEPLOYMENT 流程部署表
Preparing: insert into ACT_RE_DEPLOYMENT(ID_, NAME_, CATEGORY_, KEY_, TENANT_ID_, DEPLOY_TIME_, ENGINE_VERSION_) values(?, ?, ?, ?, ?, ?, ?) Parameters: 1(String), 请假流程(String), null, null, (String), 2021-06-02 11:01:44.838(Timestamp), nullACT_GE_BYTEARRAY 二进制资源表
Preparing: INSERT INTO ACT_GE_BYTEARRAY(ID_, REV_, NAME_, BYTES_, DEPLOYMENT_ID_, GENERATED_) VALUES (?, 1, ?, ?, ?, ?) , (?, 1, ?, ?, ?, ?) Parameters: 2(String), bpmn/leave.png(String), java.io.ByteArrayInputStream7fe7c640(ByteArrayInputStream), 1(String), false(Boolean), 3(String), bpmn/leave.bpmn(String), java.io.ByteArrayInputStream4c4748bf(ByteArrayInputStream), 1(String), false(Boolean)6.3 启动流程实例
流程定义部署在Activiti中之后就可以通过工作流管理业务流程了。针对该流程启动一个流程表示发起一个新的请假申请单这就相当于Java类和Java对象的关系类定义好之后需要new创建一个对象使用当然也可以new多个对象。对于请假申请流程张三发起一个请假申请单需要启动一个流程实例李四发起一个请求申请单也需要启动一个流程实例。
Test
public void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveProcess);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());
}观察日志发现启动流程会操作如下表.
ACT_HI_TASKINST 历史任务表
Preparing: 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_, CATEGORY_, TENANT_ID_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) Parameters: 2505(String), leaveProcess:1:4(String), 2501(String), 2502(String), 部门经理审批(String), null, null, null, 李四(String), 2021-06-02 16:34:52.827(Timestamp), null, null, null, null, _4(String), null, 50(Integer), null, null, (String)ACT_HI_PROCINST 历史流程实例表
Preparing: 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_, TENANT_ID_, NAME_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) Parameters: 2501(String), 2501(String), null, leaveProcess:1:4(String), 2021-06-02 16:34:52.798(Timestamp), null, null, null, _2(String), null, null, null, (String), nullACT_HI_ACTINST 历史活动信息表
Preparing: 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_, DELETE_REASON_, TENANT_ID_ ) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) , (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) Parameters: 2503(String), leaveProcess:1:4(String), 2501(String), 2502(String), _2(String), null, null, StartEvent(String), startEvent(String), null, 2021-06-02 16:34:52.815(Timestamp), 2021-06-02 16:34:52.816(Timestamp), 1(Long), null, (String), 2504(String), leaveProcess:1:4(String), 2501(String), 2502(String), _4(String), 2505(String), null, 部门经理审批(String), userTask(String), 李四(String), 2021-06-02 16:34:52.817(Timestamp), null, null, null, (String)ACT_HI_IDENTITYLINK 历史身份连接表
Preparing: insert into ACT_HI_IDENTITYLINK (ID_, TYPE_, USER_ID_, GROUP_ID_, TASK_ID_, PROC_INST_ID_) values (?, ?, ?, ?, ?, ?) Parameters: 2506(String), participant(String), 李四(String), null, null, 2501(String)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_, IS_MI_ROOT_, PARENT_ID_, SUPER_EXEC_, ROOT_PROC_INST_ID_, SUSPENSION_STATE_, TENANT_ID_, NAME_, START_TIME_, START_USER_ID_, IS_COUNT_ENABLED_, EVT_SUBSCR_COUNT_, TASK_COUNT_, JOB_COUNT_, TIMER_JOB_COUNT_, SUSP_JOB_COUNT_, DEADLETTER_JOB_COUNT_, VAR_COUNT_, ID_LINK_COUNT_) values (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) , (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) Parameters: 2501(String), 2501(String), null, leaveProcess:1:4(String), null, true(Boolean), false(Boolean), true(Boolean), false(Boolean), false(Boolean), null, null, 2501(String), 1(Integer), (String), null, 2021-06-02 16:34:52.798(Timestamp), null, false(Boolean), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 2502(String), 2501(String), null, leaveProcess:1:4(String), _4(String), true(Boolean), false(Boolean), false(Boolean), false(Boolean), false(Boolean), 2501(String), null, 2501(String), 1(Integer), (String), null, 2021-06-02 16:34:52.813(Timestamp), null, false(Boolean), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer)ACT_RU_TASK 运行时任务表
Preparing: 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_, CATEGORY_, SUSPENSION_STATE_, TENANT_ID_, FORM_KEY_, CLAIM_TIME_) values (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) Parameters: 2505(String), 部门经理审批(String), null, null, 50(Integer), 2021-06-02 16:34:52.817(Timestamp), null, 李四(String), null, 2502(String), 2501(String), leaveProcess:1:4(String), _4(String), null, null, 1(Integer), (String), null, nullACT_RU_IDENTITYLINK 运行时身份连接表
Preparing: insert into ACT_RU_IDENTITYLINK (ID_, REV_, TYPE_, USER_ID_, GROUP_ID_, TASK_ID_, PROC_INST_ID_, PROC_DEF_ID_) values (?, 1, ?, ?, ?, ?, ?, ?) Parameters: 2506(String), participant(String), 李四(String), null, null, 2501(String), null6.4 任务查询
流程启动后各个任务的负责人就可以查询自己当前需要处理的任务查询出来的任务都是该用户的待办任务。
Test
public void testSelectTodoTaskList(){//任务负责人String assignee 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){System.out.println(流程定义id task.getProcessDefinitionId());System.out.println(流程实例id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务名称 task.getName());}
}观察日志发现查询任务会操作如下表.
ACT_RU_TASK 运行时任务表ACT_RE_PROCDEF 流程定义表
Preparing: select distinct RES.* from ACT_RU_TASK RES inner join ACT_RE_PROCDEF D on RES.PROC_DEF_ID_ D.ID_ WHERE RES.ASSIGNEE_ ? and D.KEY_ ? order by RES.ID_ asc LIMIT ? OFFSET ? Parameters: 李四(String), leaveProcess(String), 2147483647(Integer), 0(Integer)6.5 任务处理
任务负责人查询待办任务选择任务进行处理完成任务。
Test
public void testCompleteTask(){//任务负责人String assignee 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){taskService.complete(task.getId());}
}观察日志发现查询任务会操作如下表.
ACT_GE_PROPERTY 引擎属性表
Preparing: update ACT_GE_PROPERTY SET REV_ ?, VALUE_ ? where NAME_ ? and REV_ ? Parameters: 4(Integer), 7501(String), next.dbid(String), 3(Integer)ACT_HI_TASKINST 历史任务表
Preparing: 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_, CATEGORY_, TENANT_ID_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) Parameters: 5002(String), leaveProcess:1:4(String), 2501(String), 2502(String), 人事复批(String), null, null, null, 王五(String), 2021-06-02 16:39:19.036(Timestamp), null, null, null, null, _5(String), null, 50(Integer), null, null, (String)ACT_HI_ACTINST 历史活动信息表
Preparing: 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_, DELETE_REASON_, TENANT_ID_ ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) Parameters: 5001(String), leaveProcess:1:4(String), 2501(String), 2502(String), _5(String), 5002(String), null, 人事复批(String), userTask(String), 王五(String), 2021-06-02 16:39:19.025(Timestamp), null, null, null, (String)ACT_HI_IDENTITYLINK 历史身份连接表
Preparing: insert into ACT_HI_IDENTITYLINK (ID_, TYPE_, USER_ID_, GROUP_ID_, TASK_ID_, PROC_INST_ID_) values (?, ?, ?, ?, ?, ?) Parameters: 5003(String), participant(String), 王五(String), null, null, 2501(String)ACT_RU_TASK 运行时任务表
Preparing: 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_, CATEGORY_, SUSPENSION_STATE_, TENANT_ID_, FORM_KEY_, CLAIM_TIME_) values (?, 1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) Parameters: 5002(String), 人事复批(String), null, null, 50(Integer), 2021-06-02 16:39:19.025(Timestamp), null, 王五(String), null, 2502(String), 2501(String), leaveProcess:1:4(String), _5(String), null, null, 1(Integer), (String), null, nullACT_RU_IDENTITYLINK 运行时身份连接表
Preparing: insert into ACT_RU_IDENTITYLINK (ID_, REV_, TYPE_, USER_ID_, GROUP_ID_, TASK_ID_, PROC_INST_ID_, PROC_DEF_ID_) values (?, 1, ?, ?, ?, ?, ?, ?) Parameters: 5003(String), participant(String), 王五(String), null, null, 2501(String), nullACT_RU_EXECUTION 运行时执行实例表
Preparing: update ACT_RU_EXECUTION set REV_ ?, BUSINESS_KEY_ ?, PROC_DEF_ID_ ?, ACT_ID_ ?, IS_ACTIVE_ ?, IS_CONCURRENT_ ?, IS_SCOPE_ ?, IS_EVENT_SCOPE_ ?, IS_MI_ROOT_ ?, PARENT_ID_ ?, SUPER_EXEC_ ?, ROOT_PROC_INST_ID_ ?, SUSPENSION_STATE_ ?, NAME_ ?, IS_COUNT_ENABLED_ ?, EVT_SUBSCR_COUNT_ ?, TASK_COUNT_ ?, JOB_COUNT_ ?, TIMER_JOB_COUNT_ ?, SUSP_JOB_COUNT_ ?, DEADLETTER_JOB_COUNT_ ?, VAR_COUNT_ ?, ID_LINK_COUNT_ ? where ID_ ? and REV_ ? Parameters: 2(Integer), null, leaveProcess:1:4(String), _5(String), true(Boolean), false(Boolean), false(Boolean), false(Boolean), false(Boolean), 2501(String), null, 2501(String), 1(Integer), null, false(Boolean), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 0(Integer), 2502(String), 1(Integer)ACT_HI_TASKINST 历史任务表
Preparing: update ACT_HI_TASKINST set PROC_DEF_ID_ ?, EXECUTION_ID_ ?, NAME_ ?, PARENT_TASK_ID_ ?, DESCRIPTION_ ?, OWNER_ ?, ASSIGNEE_ ?, CLAIM_TIME_ ?, END_TIME_ ?, DURATION_ ?, DELETE_REASON_ ?, TASK_DEF_KEY_ ?, FORM_KEY_ ?, PRIORITY_ ?, DUE_DATE_ ?, CATEGORY_ ? where ID_ ? Parameters: leaveProcess:1:4(String), 2502(String), 部门经理审批(String), null, null, null, 李四(String), null, 2021-06-02 16:39:18.995(Timestamp), 266168(Long), null, _4(String), null, 50(Integer), null, null, 2505(String)ACT_HI_TASKINST 历史任务表
Preparing: update ACT_HI_ACTINST set EXECUTION_ID_ ?, ASSIGNEE_ ?, END_TIME_ ?, DURATION_ ?, DELETE_REASON_ ? where ID_ ? Parameters: 2502(String), 李四(String), 2021-06-02 16:39:19.009(Timestamp), 266192(Long), null, 2504(String)ACT_RU_TASK 运行时任务表
Preparing: delete from ACT_RU_TASK where ID_ ? and REV_ ? Parameters: 2505(String), 1(Integer)6.6 添加审批意见
在执行任务之前可以给该任务添加审批意见,会存储在历史表中,我们后续可以审批历史中查看到该意见
Test
public void testAddComment(){//任务负责人String assignee 王五;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){//在任务执行之前任务添加批注信息taskService.addComment(task.getId(),task.getProcessInstanceId(),task.getName()审批通过);taskService.complete(task.getId());}
}观察日志发现其余操作和任务处理的表是一致的但是添加批注会往如下表中插入记录:
Preparing: insert into ACT_HI_COMMENT (ID_, TYPE_, TIME_, USER_ID_, TASK_ID_, PROC_INST_ID_, ACTION_, MESSAGE_, FULL_MSG_) values (?, ?, ?, ?, ?, ?, ?, ?, ?) Parameters: 7501(String), comment(String), 2021-06-02 16:43:09.13(Timestamp), null, 5002(String), 2501(String), AddComment(String), 人事复批审批通过(String), java.io.ByteArrayInputStream1b765a2c(ByteArrayInputStream)6.6 查看历史审批
用户可以查看历史审批记录
Test
public void testSelectHistoryTask(){//流程实例IDString processInstanceId 2501;//任务审核人String taskAssignee 王五;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取historyServiceHistoryService historyService processEngine.getHistoryService();//获取taskServiceTaskService taskService processEngine.getTaskService();//获取历史审核信息ListHistoricActivityInstance list historyService.createHistoricActivityInstanceQuery().activityType(userTask)//只获取用户任务.processInstanceId(processInstanceId).taskAssignee(taskAssignee).finished().list();for(HistoricActivityInstance instance:list){System.out.println(任务名称:instance.getActivityName());System.out.println(任务开始时间:instance.getStartTime());System.out.println(任务结束时间:instance.getEndTime());System.out.println(任务耗时:instance.getDurationInMillis());//获取审核批注信息ListComment taskComments taskService.getTaskComments(instance.getTaskId());if(taskComments.size()0){System.out.println(审批批注:taskComments.get(0).getFullMessage());}}
}七、Activiti7进阶
7.1 流程定义相关
7.1.1 流程定义查询
查询流程相关信息包含流程定义流程部署流程定义版本
Test
public void testDefinitionQuery(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();//获取流程定义集合ListProcessDefinition processDefinitionList repositoryService.createProcessDefinitionQuery().processDefinitionKey(leaveProcess).list();//遍历集合for (ProcessDefinition definition:processDefinitionList){System.out.println(流程定义ID:definition.getId());System.out.println(流程定义名称:definition.getName());System.out.println(流程定义key:definition.getKey());System.out.println(流程定义版本:definition.getVersion());System.out.println(流程部署ID:definition.getDeploymentId());System.out.println();}
}7.1.2 流程资源下载 现在我们的流程资源文件已经上传到数据库了如果其他用户想要查看这些资源文件可以从数据库中把资源文件下载到本地。 Test
public void testDownloadResource() throws Exception {//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();//获取流程定义集合ListProcessDefinition list repositoryService.createProcessDefinitionQuery().processDefinitionKey(leaveProcess).orderByProcessDefinitionVersion()//按照版本排序.desc()//降序.list();//获取最新那个ProcessDefinition definition list.get(0);//获取部署IDString deploymentId definition.getDeploymentId();//获取bpmn的输入流InputStream bpmnInput repositoryService.getResourceAsStream(deploymentId,definition.getResourceName());//获取png的输入流InputStream pngInput repositoryService.getResourceAsStream(deploymentId,definition.getDiagramResourceName());//设置bpmn输入FileOutputStream bpmnOutPut new FileOutputStream(D:/leave.bpmn);//设置png输入FileOutputStream pngOutPut new FileOutputStream(D:/leave.png);IOUtils.copy(bpmnInput,bpmnOutPut);IOUtils.copy(pngInput,pngOutPut);
}7.1.3 流程定义删除
根据部署Id删除对应的流程定义
Test
public void testDeleteDeploy(){//流程部署IdString deploymentId 10001;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();//删除流程定义如果该流程定义已有流程实例启动则删除时出错repositoryService.deleteDeployment(deploymentId);//设置true 级联删除流程定义即使该流程有流程实例启动也可以删除设置为false非级别删除方式如果流程//repositoryService.deleteDeployment(deploymentId,true);
}说明 如果该流程定义下没有正在运行的流程则可以用普通删除。 如果该流程定义下存在已经运行的流程使用普通删除报错可用级联删除方法将流程及相关记录全部删除。 项目开发中级联删除操作一般只开放给超级管理员使用.
7.2 流程实例相关
7.2.1 什么是流程实例
用户或程序按照流程定义内容发起一个流程这就是一个流程实例。
流程定义和流程实例的图解 7.2.2 BusinessKey业务标识
小张要在5.1~5.10这段时间请假,请假理由为:回家相亲.小陈要在5.5~5.15这段时间请假,请假理由为:家里拆迁,回家办手续.
请问会创建几个流程实例?
流程发起之后目前设定的部门审批人都是李四李四在审批之前需要看到申请人申请的时间和申请的理由才能决定是否同意.
那么申请人的请假信息【请假时间、请假理由】是如何绑定到流程中的呢?
此时就需要使用到BusinessKey
启动流程实例时指定的businessKey就会在act_run_execution表中存储businessKey。BusinessKey业务标识通常为业务表的主键业务标识和流程实例一一对应。业务标识来源于业务系统。存储业务标识就是根据业务标识来关联查询业务系统的数据。比如请假流程启动一个流程实例就可以将请假单的id作为业务标识存储到Activiti中将来查询Activiti的流程实例信息就可以获取请假单的id从而关联查询业务系统数据库得到请假单信息。
Test
public void testStartProcess(){String businessKey 8001;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的//在启动流程的时候将业务key加入进去ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveProcess,businessKey);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());
}观察数据库可以发现在activiti的act_ru_execution表字段BUSINESS_KEY就是存放业务KEY的。 在用户执行任务的时候如何获取BusinessKey并关联对应的业务信息呢?
Test
public void testGetBusinessKey(){//任务负责人String assignee 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取RuntimeServiceRuntimeService runtimeService processEngine.getRuntimeService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){System.out.println(流程定义id task.getProcessDefinitionId());System.out.println(流程实例id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务名称 task.getName());//根据任务上的流程实例Id查询出对应的流程实例对象从流程实例对象中获取BusinessKeyProcessInstance instance runtimeService.createProcessInstanceQuery().processInstanceId(task.getProcessInstanceId()).singleResult();System.out.println(业务key:instance.getBusinessKey());System.out.println();}
}7.2.3 流程定义/实例挂起/激活
全部流程实例挂起场景: 例如公司制度改变过程中的流程, 总经理更换过程中的流程有100个人的流程, 70个人已经完成,30个人流程正好在总经理更换中,就需要挂起. 比如我们的业务流程为:
【开始节点】–【A节点】–【B节点】–【C节点】–【结束节点】
【C节点】的业务逻辑需要和外部接口交互刚好外部接口出问题了,如果剩下的流程都走到【C节点】执行【C节点】的业务逻辑那都会报错我们就可以把流程挂起等待外部接口可用之后再重新激活流程.
业务流程发生改变,已经发起的流程实例继续按照旧的流程走,如果新发起的流程就按照新的业务流程走.这时候我们就需要挂起流程定义,但是不挂起流程实例.
操作流程定义为挂起状态该操作定义下面的所有的流程实例将全部暂停。流程定义为挂起状态该流程定义下将不允许启动新的流程实例同时该流程定义下的所有流程实例将全部挂起暂停执行
Test
public void testSuspendAllProcessInstance(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryServiceRepositoryService repositoryService processEngine.getRepositoryService();//获取流程定义对象ProcessDefinition processDefinition repositoryService.createProcessDefinitionQuery().processDefinitionKey(leaveProcess).singleResult();boolean suspended processDefinition.isSuspended();//输出流程定义状态System.out.println(流程定义状态:(suspended ?已挂起:已激活));String processDefinitionId processDefinition.getId();if(suspended){//如果是挂起可以执行激活操作 ,参数1 流程定义id 参数2是否激活流程实例参数3激活时间repositoryService.activateProcessDefinitionById(processDefinitionId,true,null);System.out.println(流程ID:processDefinitionId,已激活);}else{//如果是激活可以执行挂起操作 ,参数1 流程定义id 参数2是否暂停流程实例参数3激活时间repositoryService.suspendProcessDefinitionById(processDefinitionId,true,null);System.out.println(流程ID:processDefinitionId,已挂起);}
}查询待办任务的状态,如果是【已挂起】,前台则不允许点击【任务处理】按钮
Test
public void testSuspendStatus(){//任务负责人String assignee 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){System.out.println(流程定义id task.getProcessDefinitionId());System.out.println(流程实例id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务名称 task.getName());System.out.println(任务状态:(task.isSuspended()?已挂起:已激活));System.out.println();}
}利用之前的测试用例测试在流程挂起的情况是否能发起新的流程实例 org.activiti.engine.ActivitiException: Cannot start process instance. Process definition 请假流程 (id leaveProcess:1:4) is suspended利用之前的测试用例测试在流程挂起的情况是否可以处理任务 org.activiti.engine.ActivitiException: Cannot complete a suspended task单个流程实例挂起场景
评分流程可设置多级评分评分流程会按照从上往下的顺序依次评分评分人必须在评分截至时间内完成评分否则不允许继续评分流程将会挂起停止流转
操作流程实例对象针对单个流程执行挂起操作某个流程实例挂起则此流程不再执行完成该流程实例的当前任务将报异常。
查询所有的流程实例
Test
public void testQueryProcessInstance(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryServiceRuntimeService runtimeService processEngine.getRuntimeService();ListProcessInstance processInstanceList runtimeService.createProcessInstanceQuery().processDefinitionKey(leaveProcess).list();for(ProcessInstance processInstance:processInstanceList){System.out.println(流程实例Id:processInstance.getId(),状态:(processInstance.isSuspended()?已挂起:已激活));}
}挂起某个流程实例
Test
public void testSuspendSingleProcessInstance(){//流程实例IdString processInstanceId 2501;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryServiceRuntimeService runtimeService processEngine.getRuntimeService();//根据流程实例Id获取流程实例对象ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();//状态boolean suspended processInstance.isSuspended();System.out.println(流程实例ID:processInstanceId,状态: (suspended?已挂起:已激活));if(suspended){runtimeService.activateProcessInstanceById(processInstanceId);System.out.println(流程实例ID:processInstanceId,状态修改为已激活);}else{runtimeService.suspendProcessInstanceById(processInstanceId);System.out.println(流程实例ID:processInstanceId,状态修改为已挂起);}
}7.3 任务分配负责人
7.3.1 固定分配 在进行业务流程建模的时候指定固定的任务负责人。
7.3.2 UEL表达式分配
Activiti 使用 UEL 表达式 UEL 是 java EE6 规范的一部分 UELUnified Expression Language即 统一表达式语言。 IDEA中的actiBPM插件在修改Assignee存在bug,在界面上修改了,但是实际文件并没有修改.所以我们需要借助编辑工具在xml文件中修改一下Assignee 修改流程定义之后重新进行部署 编写代码配置负责人
Test
public void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();MapString,Object variables new HashMapString, Object();variables.put(assignee0,zhangsan);variables.put(assignee1,lisi);//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveProcess,variables);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());
}执行成功后可以在act_ru_variable表中看到刚才map中的数据 7.3.3 监听器分配
任务监听器是发生对应的任务相关事件时执行自定义的Java逻辑或表达式。任务相关事件包括 Event Create任务创建后触发。Assignment任务分配后触发。Delete任务完成后触发。All所有事件发生都触发。 自定义一个任务监听器类然后此类必须实现org.activiti.engine.delegate.TaskListener接口 package cn.wolfcode;import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;/*** Created by wolfcode*/
public class AssigneeTaskListener implements TaskListener {public void notify(DelegateTask delegateTask) {if(delegateTask.getName().equals(部门经理审批)){delegateTask.setAssignee(赵六);}else if(delegateTask.getName().equals(部门经理审批)){delegateTask.setAssignee(孙七);}}
}在bpmn文件中配置监听器
在实际开发中一般也不使用监听器分配方式太麻烦了。
7.4 流程变量
7.4.1 什么是流程变量
流程变量在Activiti中是一个非常重要的角色流程运转有时需要靠流程变量业务系统和Activiti结合时少不了流程变量流程变量就是Activiti在管理工作流时根据管理需要而设置的变量。比如在请假流程流转时如果请假天数3天则有总经理审批否则由人事直接审批请假天数就可以设置流程变量在流程流转时使用。
注意虽然流程变量中可以存储业务数据可以通过Activiti的API查询流程变量从而实现查询业务数据但是不建议这么使用因为业务数据查询由业务系统负责Activiti设置流程变量是为了流程执行需要而创建的。7.4.2 流程变量类型 注意
如果将POJO存储到流程变量中必须实现序列化接口Serializable为了防止由于新增字段无法反序列化。7.4.3 流程变量的作用域
流程变量的作用域范围可以是一个流程实例ProcessInstance、一个任务Task或一个执行实例Execution。
global变量: 流程变量的作用域范围的默认值是流程实例作用域范围最大。local变量 : 流程变量的作用域范围如果仅仅针对一个任务或一个执行实例那么作用域范围没有流程实例大
实际开发中一般不用local变量了解即可.7.4.4 流程变量的使用方法 在属性上使用UEL表达式 可以在 assignee 处设置 UEL 表达式表达式的值为任务的负责人比如 ${assignee} assignee 就是一个流程变量名称。 Activiti获取UEL表达式的值即流程变量assignee的值 将assignee的值作为任务的负责人进行任务分配 在连线上使用UEL表达式 可以在连线上设置UEL表达式决定流程走向。 比如${price10000} 。price就是一个流程变量名称uel表达式结果类型为布尔类型。 如果UEL表达式是true要决定 流程执行走向。
7.4.5 使用global变量控制流程
需求:员工创建请假流程申请单由部门经理审批部门经理审批通过后请假3天以下(含3天)的由人事经理直接审批3天以上的由总经理审批总经理审批通过再通过人事经理审批。 在连线处添加判断条件 本次画BPMN文件的时候将部门经理的assignee设置为李四总经理审批的assignee设置为王五总经理审批的assignee设置为王五人事复批存档设置为赵六。package cn.wolfcode.demo;import org.activiti.engine.*;
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.HashMap;
import java.util.List;
import java.util.Map;/*** Created by wolfcode*/
public class VariablesTest {/*** 部署*/Testpublic void testDeploy(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryService对象RepositoryService repositoryService processEngine.getRepositoryService();//进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(bpmn/leave-variables.bpmn).name(请假流程).deploy();//输出部署的一些信息System.out.println(流程部署ID:deployment.getId());System.out.println(流程部署名称:deployment.getName());}Testpublic void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();MapString,Object variables new HashMapString,Object();variables.put(day,2);//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveVariablesProcess,variables);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());}Testpublic void testSelectTodoTaskList(){//任务负责人String assignee 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveVariablesProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){System.out.println(流程定义id task.getProcessDefinitionId());System.out.println(流程实例id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务名称 task.getName());}}Testpublic void testCompleteTask(){//任务负责人String assignee 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveVariablesProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){taskService.complete(task.getId());}}
}
注意事项:
1.如果UEL表达式中流程变量名不存在则报错。
2.如果如果UEL表达式都不符合条件,流程报错。
3.如果连接不设置条件/条件都满足,每个连线都会走.7.5 任务候选人
在流程定义中在任务结点的 assignee 固定设置任务负责人在流程定义时将参与者固定设置在.bpmn 文件中如果临时任务负责人变更则需要修改流程定义系统可扩展性差。
针对这种情况可以给任务设置多个候选人可以从候选人中选择参与者来完成任务。
7.5.1 设置任务候选人
在流程图中任务节点的配置中设置 candidate-users(候选人)多个候选人之间用逗号分开。 查看bpmn文件 我们可以看到部门经理的审核人已经设置为 lisi,wangwu 这样的一组候选人可以使用activiti:candiateUsers”用户 1,用户 2,用户 3”的这种方式来实现设置一组候选人
7.5.2 部署启动流程
package cn.wolfcode.demo;import org.activiti.engine.*;
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.HashMap;
import java.util.List;
import java.util.Map;/*** Created by wolfcode*/
public class CandidateTest {/*** 部署*/Testpublic void testDeploy(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryService对象RepositoryService repositoryService processEngine.getRepositoryService();//进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(bpmn/leave-candidate.bpmn).name(请假流程-候选人).deploy();//输出部署的一些信息System.out.println(流程部署ID:deployment.getId());System.out.println(流程部署名称:deployment.getName());}//启动流程Testpublic void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveCandidateProcess);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());}
}7.5.3 查询候选人任务
//查询候选任务
Test
public void testSelectCandidateTaskList(){//任务负责人String candidateUser 李四;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveCandidateProcess).taskCandidateUser(candidateUser).list();//遍历任务列表for(Task task:taskList){System.out.println(流程定义id task.getProcessDefinitionId());System.out.println(流程实例id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务名称 task.getName());}
}7.5.4 领取候选人任务
Test
public void testClaimTask(){//任务IDString taskId 2505;String assignee 张三;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//领取任务taskService.claim(taskId,assignee);
}7.5.4 完成任务
如果候选任务没有进行领取就直接完成的话那么在历史记录中就不会记录是哪个用户执行了这个任务.
所以对于这种候选人的任务我们需要先领取再完成.
//执行任务
Test
public void testCompleteTask(){//任务IDString taskId 2505;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();taskService.complete(taskId);
}7.6 网关
7.6.1 排他网关
排他网关(ExclusiveGateway)异或网关或基于数据的排他网关用来在流程中实现决策。当流程执行到这个网关的时候所有分支都会判断条件是否为true如果为true则执行该分支。
注意
排他网关只会选择一个为true的分支执行即使有两个分支条件都为true排他网关也只会选择一条分支去执行,选择序号小的路径执行。本次画BPMN文件的时候将部门经理的assignee设置为李四总经理审批的assignee设置为王五总经理审批的assignee设置为王五人事复批存档设置为赵六。package cn.wolfcode.demo;import org.activiti.engine.*;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.After;
import org.junit.Test;import java.util.HashMap;
import java.util.List;
import java.util.Map;/*** Created by wolfcode*/
public class EGatewayTest {/*** 部署*/Testpublic void testDeploy(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryService对象RepositoryService repositoryService processEngine.getRepositoryService();//进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(bpmn/leave-EGateway.bpmn).name(请假流程-排他网关).deploy();//输出部署的一些信息System.out.println(流程部署ID:deployment.getId());System.out.println(流程部署名称:deployment.getName());}Testpublic void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();MapString,Object variables new HashMapString,Object();variables.put(day,0);//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveEGatewayProcess,variables);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());}Testpublic void testCompleteTask(){//任务负责人String assignee 张三;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveEGatewayProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){taskService.complete(task.getId());}}
}7.6.2 并行网关
并行网关(InclusiveGateway)允许将流程分成多条分支也可以把多条分支汇聚到一起并行网关的功能是基于进入和外出的顺序流的。
并行网关不会解析条件。即使顺序流中定义了条件也会被忽略本次画BPMN文件的时候将技术经理的assignee设置为李四项目经理审批的assignee设置为王五人事复批的assignee设置为王五package cn.wolfcode.demo;import org.activiti.engine.*;
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.HashMap;
import java.util.List;
import java.util.Map;/*** Created by wolfcode*/
public class PGatewayTest {/*** 部署*/Testpublic void testDeploy(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryService对象RepositoryService repositoryService processEngine.getRepositoryService();//进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(bpmn/leave-PGateway.bpmn).name(请假流程-并行网关).deploy();//输出部署的一些信息System.out.println(流程部署ID:deployment.getId());System.out.println(流程部署名称:deployment.getName());}Testpublic void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();MapString,Object variables new HashMapString,Object();//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leavePGatewayProcess);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());}//完成任务Testpublic void testCompleteTask(){//任务负责人String assignee 张三;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leavePGatewayProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){taskService.complete(task.getId());}}
}7.6.3 包含网关
包含网关可以看做是排他网关和并行网关的结合体。
需求:出差申请大于3天需要由项目经理审批小于3等于天由技术经理审批出差申请必须经过人事助理审批。 本次画BPMN文件的时候将技术经理的assignee设置为张三项目经理的assignee设置为李四人事助理的assignee设置为王五人事复批存档设置为赵六。package cn.wolfcode.demo;import org.activiti.engine.*;
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.HashMap;
import java.util.List;
import java.util.Map;/*** Created by wolfcode*/
public class IGatewayTest {/*** 部署*/Testpublic void testDeploy(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RepositoryService对象RepositoryService repositoryService processEngine.getRepositoryService();//进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(bpmn/leave-IGateway.bpmn).name(请假流程-包含网关).deploy();//输出部署的一些信息System.out.println(流程部署ID:deployment.getId());System.out.println(流程部署名称:deployment.getName());}Testpublic void testStartProcess(){//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取RuntimeService对象RuntimeService runtimeService processEngine.getRuntimeService();MapString,Object variables new HashMapString,Object();variables.put(day,5);//根据流程定义的key启动流程实例,这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leaveIGatewayProcess,variables);//获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());}//完成任务Testpublic void testCompleteTask(){//任务负责人String assignee 王五;//创建ProcessEngine对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();//获取TaskServiceTaskService taskService processEngine.getTaskService();//获取任务集合ListTask taskList taskService.createTaskQuery().processDefinitionKey(leaveIGatewayProcess).taskAssignee(assignee).list();//遍历任务列表for(Task task:taskList){taskService.complete(task.getId());}}
}
