阅读:39
概要:工作流引擎,实现业务表与工作流的分离,便于开发。
技术使用:采用activiti7版本,mysql数据库,Maven、idea2021、Activiti BPMNvisualizer插件,Camunda Modeler流程图设计器。
1、Activiti BPMN visualizer插件安装
(一)setting的Plugins中搜索并点击installed
(二)在此处可看到创建BPMN文件、或者可以编辑即可
2、Camunda Modeler流程图设计器安装
问题:有了Activiti BPMN visualize为什么还要安装呢?
第一点:idea2021不能兼容常用的actiBPM。
第二点:Activiti BPMN visualize找不到加入监听器的功能(后续讲到)。
第三点:关于 assignee 失效。解决办法:将camunda 替换为 activiti,命名空间改为activity的命名空间,1、加入xmlns:activiti=“http://activiti.org/bpmn”,2、camunda改为activiti
(一)安装路径
链接:https://pan.baidu.com/s/10_W1VpduQXxCSitSKXxM7Q
提取码:6666
下载完成解压即可使用。
(二)idea配置Camunda Modeler
File > setting > Tools > External tool > 点击+号
(三)在此处可看见有新增的工具即可
3、创建项目后进行Maven配置
<!-- activiti 的相关包 mysql的驱动包 mybatis log4j 数据库链接池-->
<properties>
<slf4j.version>1.6.6</slf4j.version>
<log4j.version>1.2.12</log4j.version>
<activiti.version>7.0.0.Beta1</activiti.version>
</properties>
<dependencies>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-engine</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn 模型处理 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-model</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn 转换 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-converter</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn json数据转换 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-json-converter</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- bpmn 布局 -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-layout</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- activiti 云支持 -->
<dependency>
<groupId>org.activiti.cloud</groupId>
<artifactId>activiti-cloud-services-api</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- mysql驱动 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.40</version>
</dependency>
<!-- mybatis -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.5</version>
</dependency>
<!-- 链接池 -->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.4</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.6</version>
</dependency>
</dependencies>
4、activiti配置文件(activiti.cfg.xml放于resource文件夹下)
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<!--dbcp链接池-->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql:///activiti?nullCatalogMeansCurrent=true"/>
<property name="username" value="root"/>
<property name="password" value="123456"/>
<property name="maxActive" value="3"/>
<property name="maxIdle" value="1"/>
</bean>
<!--在默认方式下 bean的id 固定为 processEngineConfiguration-->
<bean id="processEngineConfiguration"
class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
<!--直接引用上面配置的链接池-->
<property name="dataSource" ref="dataSource"/>
<!--actviti数据库表在生成时的策略
true - 如果数据库中已经存在相应的表,那么直接使用,
如果不存在,那么会创建-->
<property name="databaseSchemaUpdate" value="true"/>
</bean>
</beans>
(一)首先创建一个bpmn2.0文件,然后编辑,上述有提到。
(二)右键可创建组件
(三)连线点击右上角的箭头并拖动到其他组件中
(四)创建完毕后可通过Camunda Modeler打开文件
(五)创建一个较为完整的流程图
(六)生成流程图片(方式一)
生成流程图片(方式二)
(一)创建activiti表方式一:
1、使用方法getDefaultProcessEngine
2、默认从resources下读取名字为actviti.cfg.xml的文件
3、创建processEngine时,就会创建mysql的表
//默认方式
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
repositoryService.createDeployment();
//获取流程引擎对象(此时创建activiti的表)
ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
(二)创建activiti表方式二:
配置文件的名字可以自定义,bean的名字也可以自定义
ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.
createProcessEngineConfigurationFromResource("activiti.cfg.xml","processEngineConfiguration");
//获取流程引擎对象(此时创建activiti的表)
ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
(三)了解activiti表结构
- act_hi_*:'hi’表示 history,历史数据。
- act_ge_*:'ge’表示 general,通用数据。
- act_evt_*:'evt’表示 event,事件日志。
- act_procdef_*:'procdef’表示processdefine,流程定义信息。
- act_re_*:'re’表示 repository,静态资源。
- act_ru_*:'ru’表示 runtime,表示运行时数据。
通用数据表:(ge)
表名 | 说明 |
---|---|
act_ge_bytearray | 存储通用的流程定义和流程资源 |
act_ge_bytearray | 存储整个流程引擎级别的数据 |
流程定义表:(re)
表名 | 说明 |
---|---|
act_re_model | 流程设计模型部署数据 |
act_re_deployment | 部署信息数据表 |
act_re_procdef | 流程定义数据 |
运行实例表:(ru)
表名 | 说明 |
---|---|
act_ru_deadletter_job | 作业失败超过重试次数部署数据 |
act_ru_event_subscr | 运行时事件数据 |
act_ru_execution | 运行时流程执行实例数据 |
act_ru_identitylink | 运行时用户信息数据 |
act_ru_integration | 运行时积分数据 |
act_ru_suspended_job | 运行时作业暂停数据 |
act_ru_task | 运行时任务信息数据 |
act_ru_timer_job | 运行时定时器作业表 |
act_ru_variable | 运行时变量信息表 |
act_ru_job | 运行时作业信息数据 |
历史流程表:(hi)
表名 | 说明 |
---|---|
act_hi_actinst | 历史节点数据 |
act_hi_attachment | 历史附件 |
act_hi_comment | 历史意见数据 |
act_hi_detail | 历史详情 |
act_hi_identitylink | 历史流程用户信息数据 |
act_hi_procinst | 历史流程实例数据 |
act_hi_taskinst | 历史任务实例数据 |
act_hi_varinst | 历史变量数据 |
其他表:
表名 | 说明 |
---|---|
act_evt_log | 通用事件日志记录数据 |
act_procdef_info | 流程定义的动态变更信息数据 |
(一)流程部署方式一、
//1、创建(流程引擎)ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2、获取RepositoryServcie(re表的服务层)\
RepositoryService repositoryService = processEngine.getRepositoryService();
//3、使用service进行流程的部署,部署bpmn和png
Deployment deploy = repositoryService.createDeployment()
.name("出差申请流程")
.addClasspathResource("bpmn/evection.bpmn")
.addClasspathResource("bpmn/evection.png")
.deploy();
(二)、流程部署方式二、
//1、将png和bpmn打包成zip包
//2、创建(流程引擎)ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//3、获取RepositoryServcie(re表的服务层)\
RepositoryService repositoryService = processEngine.getRepositoryService();
//读取资源包文件,构造成inputStream
InputStream inputStream = this.getClass()
.getClassLoader()
.getResourceAsStream("bpmn/evection.zip");
//用inputStream 构造ZipInputStream
ZipInputStream zipInputStream = new ZipInputStream(inputStream);
//使用压缩包的流进行流程的部署
Deployment deploy = repositoryService.createDeployment()
.addZipInputStream(zipInputStream)
.deploy();
(三)流程部署修改的表
1. ACT_RE_DEPLOYMENT(流程部署表)先创建7501部署表数据
2. ACT_GE_PROPERTY(流程定义表)后创建id为myEvection:1:7504的流程定义数据,myEvent是创建bpmn文件时定义的文件id,7501对应ACT_RE_DEPLOYMENT刚部署的记录id。注意:key相同时选取version最大的记录。
(一)启动流程实例,先找到刚刚流程定义的key
//1、创建ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2、获取RunTimeService
RuntimeService runtimeService = processEngine.getRuntimeService();
//3、根据流程定义的id启动流程
ProcessInstance instance = runtimeService.startProcessInstanceByKey("myEvection");
(二)启动流程修改的表
1. ACT_HI_TASKINST(历史任务实例数据表)
2. ACT_HI_PROCINST(历史流程实例数据表,正在执行的任务也在其中)
3. ACT_HI_ACTINST(历史节点数据,图片上的节点信息)
4. ACT_HI_IDENTITYLINK(历史流程用户信息数据表)
5. ACT_RU_EXECUTION(运行时流程执行实例数据表,一条是开始事件的执行实例,这个一直存在,只到流程结束后才会自动删除,is_active字段表示是否正在执行实例)
6. ACT_RU_TASK(运行时任务信息数据信息表)
(一)代码实现
//1、获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2、获取taskService
TaskService taskService = processEngine.getTaskService();
//3、根据流程key 和 任务的负责人 查询任务
List<Task> taskList = taskService.createTaskQuery()
.processDefinitionKey("myEvection") //流程Key
.taskAssignee("zhangsan") //要查询的负责人
.list();
//4、输出
for (Task task : taskList) {
System.out.println("流程实例id="+task.getProcessInstanceId());
System.out.println("任务Id="+task.getId());
System.out.println("任务负责人="+task.getAssignee());
System.out.println("任务名称="+task.getName());
}
(二)查询过程
1. 查询ACT_GE_PROPERTY(系统相关属性数据表,查询版本等相关信息,对于我们帮助不大)
2. 查询以下sql语句(ACT_RU_TASK 与 ACT_RE_PROCDEF关联查询)
select distinct RES.* from ACT_RU_TASK RES inner join ACT_RE_PROCDEF D on RES.PROC_DEF_ID_ = D.ID_ WHERE RES.ASSIGNEE_ = 'zhangsan' and D.KEY_ = 'myEvection' order by RES.ID_ asc LIMIT 2147483647 OFFSET 0
//查询结果如下
(一)代码实现方式一(完成zhangsan的任务)、
//获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取操作任务的服务 TaskService
TaskService taskService = processEngine.getTaskService();
//完成任务,参数:任务id,完成zhangsan的任务,10005是上述ACT_RU_TASK表的id
taskService.complete("10005");
(二)代码实现方式二(完成其余三人的任务)、
//完成jerry的任务
//获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取操作任务的服务 TaskService
TaskService taskService = processEngine.getTaskService();
//获取jerry - myEvection 对应的任务
Task task = taskService.createTaskQuery()
.processDefinitionKey("myEvection")
.taskAssignee("jerry")
.singleResult();
System.out.println("流程实例id="+task.getProcessInstanceId());
System.out.println("任务Id="+task.getId());
System.out.println("任务负责人="+task.getAssignee());
System.out.println("任务名称="+task.getName());
//完成jerry的任务
taskService.complete(task.getId());
//输出
//流程实例id=10001
//任务Id=12502
//任务负责人=jerry
//任务名称=经理审批
//完成jack的任务
Task taskjack = taskService.createTaskQuery()
.processDefinitionKey("myEvection")
.taskAssignee("jack")
.singleResult();
System.out.println("流程实例id="+taskjack .getProcessInstanceId());
System.out.println("任务Id="+taskjack .getId());
System.out.println("任务负责人="+taskjack .getAssignee());
System.out.println("任务名称="+taskjack .getName());
//完成jack的任务
taskService.complete(task.getId());
//输出
//流程实例id=10001
//任务Id=15002
//任务负责人=jack
//任务名称=总经理审批
//完成rose的任务
Task taskjack = taskService.createTaskQuery()
.processDefinitionKey("myEvection")
.taskAssignee("rose")
.singleResult();
System.out.println("流程实例id="+taskjack .getProcessInstanceId());
System.out.println("任务Id="+taskjack .getId());
System.out.println("任务负责人="+taskjack .getAssignee());
System.out.println("任务名称="+taskjack .getName());
//完成jack的任务
taskService.complete(task.getId());
//输出
//流程实例id=10001
//任务Id=17502
//任务负责人=rose
//任务名称=财务审批
(三)完成个人任务修改的表、
1. ACT_HI_TASKINST(历史的任务实例表)
1、zhangsan完成任务(插入下一个jerry的任务实例,zhangsan任务实例end_time加入处理完结时间)
2、jerry完成任务(插入下一个jack的任务实例,jerry任务实例end_time加入处理完结时间)
3、jack完成任务(插入下一个rose的任务实例,jack任务实例end_time加入处理完结时间)
4、rose完成任务(插入结束的任务实例,任务实例end_time加入处理完结时间)
2. ACT_HI_ACTINST(历史节点数据)
3. ACT_HI_IDENTITYLINK(历史流程用户信息数据表)
4. ACT_RU_TASK(运行时任务信息数据信息表)
5. ACT_RU_IDENTITYLINK(运行时用户信息数据)
6. ACT_RU_EXECUTION(运行时流程执行实例数据表)
7. ACT_HI_PROCINST(历史流程实例数据表)
(一)代码实现
//获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取HistoryService
HistoryService historyService = processEngine.getHistoryService();
//获取 actinst表的查询对象
HistoricActivityInstanceQuery instanceQuery = historyService.createHistoricActivityInstanceQuery();
//查询 actinst表,条件:根据 InstanceId 查询
//instanceQuery.processInstanceId("2501");
//查询 actinst表,条件:根据 DefinitionId 查询
instanceQuery.processDefinitionId("myEvection:1:7504");
//增加排序操作,orderByHistoricActivityInstanceStartTime 根据开始时间排序 asc 升序
instanceQuery.orderByHistoricActivityInstanceStartTime().asc();
//查询所有内容
List<HistoricActivityInstance> activityInstanceList = instanceQuery.list();
//输出
for (HistoricActivityInstance hi : activityInstanceList) {
System.out.println(hi.getActivityId());
System.out.println(hi.getActivityName());
System.out.println(hi.getProcessDefinitionId());
System.out.println(hi.getProcessInstanceId());
System.out.println("<==========================>");
}
输出:
_2
StartEvent
myEvection:1:7504
10001
<==========================>
_3
创建出差申请
myEvection:1:7504
10001
<==========================>
_4
经理审批
myEvection:1:7504
10001
<==========================>
_5
总经理审批
myEvection:1:7504
10001
<==========================>
_6
财务审批
myEvection:1:7504
10001
<==========================>
_7
EndEvent
myEvection:1:7504
10001
<==========================>
(一)代码实现(使用关联id启动流程)
//1、获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2、获取RuntimeService
RuntimeService runtimeService = processEngine.getRuntimeService();
// 3、启动流程的过程中,添加businesskey
//第二个参数:businessKey,业务表的id,就是1001
ProcessInstance instance = runtimeService.
startProcessInstanceByKey("myEvection", "1001");
//4、输出
System.out.println("businessKey=="+instance.getBusinessKey());
输出
businessKey==1001
(二)与普通方式启动实例比较
1. ACT_HI_PROCINST(历史流程实例数据表比较,普通启动business_key为空,说明业务表的id存在这个字段中)
2. ACT_RU_EXECUTION(运行时流程执行实例数据表比较,普通启动business_key为空,说明业务表的id存在这个字段中)
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现:
//1、创建ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2、获取RepositoryServcie
RepositoryService repositoryService = processEngine.getRepositoryService();
//3、使用service进行流程的部署,定义一个流程的名字,把bpmn和png部署到数据中
Deployment deploy = repositoryService.createDeployment()
.name("出差申请流程-uel")
.addClasspathResource("bpmn/uel.bpmn")
.deploy();
//4、输出部署信息
System.out.println("流程部署id="+deploy.getId());
System.out.println("流程部署名字="+deploy.getName());
输出:
流程部署id=25001
流程部署名字=出差申请流程-uel
act_re_procdef表结果:
(三)流程启动代码实现:
//获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取RunTimeService
RuntimeService runtimeService = processEngine.getRuntimeService();
//设定assignee的值,用来替换uel表达式
Map<String,Object> assigneeMap = new HashMap<>();
assigneeMap.put("assignee0","张三");
assigneeMap.put("assignee1","李经理");
assigneeMap.put("assignee2","王总经理");
assigneeMap.put("assignee3","赵财务");
//启动流程实例
runtimeService.startProcessInstanceByKey("myEvection1",assigneeMap);
(四)添加uel表达式后,额外修改的表
1. ACT_HI_VARINST(历史流程运行中的变量信息数据表)
2. ACT_RU_VARIABLE(运行时变量表)
注:其余表的修改与普通流程启动相同
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现:
//1、创建ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2、获取RepositoryServcie
RepositoryService repositoryService = processEngine.getRepositoryService();
//3、使用service进行流程的部署,定义一个流程的名字,把bpmn和png部署到数据中
Deployment deploy = repositoryService.createDeployment()
.name("出差申请流程-Candidate")
.addClasspathResource("bpmn/evection-candidate.bpmn")
.deploy();
- act_re_procdef表结果:
(三)流程启动代码实现:
//获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取RunTimeService
RuntimeService runtimeService = processEngine.getRuntimeService();
runtimeService.startProcessInstanceByKey("testCandidate");
说明:除了部门经理审批,其余流程与第六章相同。
(四)查询组任务代码实现(提前将五好青年1完成任务,到达部门经理审批):
//获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取TaskService
TaskService taskService = processEngine.getTaskService();
//查询组任务
List<Task> taskList = taskService.createTaskQuery()
.processDefinitionKey("testCandidate")
.taskCandidateUser("wangwu") //根据候选人查询任务
.list();
for (Task task : taskList) {
System.out.println("========================");
System.out.println("流程实例ID="+task.getProcessInstanceId());
System.out.println("任务id="+task.getId());
System.out.println("任务负责人="+task.getAssignee());
}
输出
========================
流程实例ID=55001
任务id=57502
任务负责人=null
- ACT_RU_TASK结果(当前负责人为空):
- ACT_HI_ACTINST结果(部门经理审批负责人为空):
- ACT_HI_TASKINST结果 (部门经理审批负责人为空):
(五)wangwu拾取任务代码实现:
//获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取TaskService
TaskService taskService = processEngine.getTaskService();
//当前任务的id
String taskId = "57502";
//任务候选人
String candidateUser = "wangwu";
// 查询任务
Task task = taskService.createTaskQuery()
.taskId(taskId)
.taskCandidateUser(candidateUser)
.singleResult();
if(task != null){
// 拾取任务
taskService.claim(taskId,candidateUser);
System.out.println("taskid-"+taskId+"-用户-"+candidateUser+"-拾取任务完成");
}
输出:
taskid-57502-用户-wangwu-拾取任务完成
- ACT_RU_TASK结果图(回归正常流程):
- ACT_HI_ACTINST结果(回归正常流程):
- ACT_HI_TASKINST结果 (回归正常流程):
(五)wang归还任务、交接任务代码实现:
总的来说就是改assignee_字段
归还任务设置成null
交接任务设置成lisi
//获取引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取TaskService
TaskService taskService = processEngine.getTaskService();
//当前任务的id
String taskId = "57502";
//任务负责人
String assignee = "wangwu";
//根据key 和负责人来查询任务
Task task = taskService.createTaskQuery()
.taskId(taskId)
.taskAssignee(assignee)
.singleResult();
if(task != null){
//归还任务 ,就是把负责人 设置为空
taskService.setAssignee(taskId,null);
taskService.setAssignee(taskId,'lisi');
System.out.println("taskid-"+taskId+"-归还任务完成");
}
(六)后续完成任务按照第六章正常思路完成
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deploy = repositoryService.createDeployment()
.name("测试监听器")
.addClasspathResource("bpmn/demo-listen.bpmn")
.deploy();
- act_re_procdef表结果:
(二)启动流程代码实现
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
runtimeService.startProcessInstanceByKey("testListener");
- ACT_RU_TASK结果图
- ACT_HI_ACTINST结果
- ACT_HI_TASKINST结果 (回归正常流程):
问题来了,为什么ACT_RU_TASK中的负责人是张三呢?
这就是监听器的作用,我在图中设置了监听器的路径,一旦开始流程便开始调用监听类中的notify方法。代码如下
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;
public class MyTaskListener implements TaskListener {
//delegateTasK是当前任务的对象
@Override
public void notify(DelegateTask delegateTask) {
//默认是create事件
if("创建申请".equals(delegateTask.getName()) &&
"create".equals(delegateTask.getEventName())){
delegateTask.setAssignee("张三");
}
}
}
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deploy = repositoryService.createDeployment()
.name("出差申请流程-variables")
.addClasspathResource("bpmn/evection-global.bpmn")
.deploy();
- act_re_procdef表结果:
(三)主体类准备(必须继承Serializable ,不然bpmn文件无法识别变量)
/**
* 出差申请中的流程变量对象
*/
public class Evection implements Serializable {
private Long id;
private String evectionName;
private Double num;
private String reson;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getEvectionName() {
return evectionName;
}
public void setEvectionName(String evectionName) {
this.evectionName = evectionName;
}
public Double getNum() {
return num;
}
public void setNum(Double num) {
this.num = num;
}
public String getReson() {
return reson;
}
public void setReson(String reson) {
this.reson = reson;
}
}
(四)流程启动代码实现方式一(启动流程的时候设置流程变量):
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
//流程变量的map
Map<String,Object> variables = new HashMap<>();
//设置流程变量
Evection evection = new Evection();
//设置出差日期
evection.setNum(2d);
//把流程变量的pojo放入map
variables.put("evection",evection);
//设定任务的负责人
variables.put("assignee0","李四");
variables.put("assignee1","王经理");
variables.put("assignee2","杨总经理");
variables.put("assignee3","张财务");
//启动流程
runtimeService.startProcessInstanceByKey("myEvection2",variables);
(五)流程启动代码实现方式二(完成个人任务的时候设置流程变量):
//设置流程变量
Evection evection = new Evection();
//设置出差时间
evection.setNum(2d);
Map<String,Object> map = new HashMap<>();
map.put("evection",evection);
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
TaskService taskService = processEngine.getTaskService();
//查询任务
Task task = taskService.createTaskQuery()
.processDefinitionKey("myEvection2")
.taskAssignee("李四")
.singleResult();
if(task != null){
//根据任务id 完成任务,并传递流程变量
taskService.complete(task.getId(),map);
System.out.println(task.getId()+"----任务已完成");
};
(六)添加流程变量修改的表,除了ACT_HI_VARINST其余表正常执行
1. ACT_HI_VARINST(历史流程运行中的变量信息数据表)
说明:图中的evection.num就是代码中设置的2d
(七)以(ACT_RU_TASK表、方式一)为代表简述执行过程:
第一步:李四送审后表结果
第二步:王经理送审后表结果(可见直接跳过了杨总经理,直接到了张财务,说明图中的变量表达式生效,天数小于2不需要杨总经理审批)
第三步:张财务送审后表结果(所有记录删除)
注:若两个条件均满足要求,则走flowid最小的任务。都不符合条件,流程结束
简介:所有分支都会判断条件是否为true,如果为true就执行该分支
注意:只会选择一个true的分支执行,如果都满足条件,则走flowid最小的任务。
与上述条件变量的区别:都不满足条件,则抛出异常。
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现:
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("bpmn/evection-exclusive.bpmn")
.name("出差申请流程-排他网关")
.deploy();
- act_re_procdef表结果:
(三)流程启动代码实现:
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> map = new HashMap<>();
Evection evection = new Evection();
evection.setNum(2d);
//定义流程变量,把出差pojo对象放入map
map.put("evection",evection);
//启动流程实例,并设置流程变量的值(把map传入)
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey("exclusive", map);
- ACT_RU_TASK表结果:
ACT_RU_VARIABLE表结果:
(三)以(ACT_RU_TASK表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:jerry送审后表结果(经过判断到达财务审批rose负责人手上)
第三步:rose送审后表结果(记录删除)
可以把多条分支汇聚一起,会走所有的分支、还要等多个分支完成才可继续完成。
注意:并行网关不会解析条件,即使定义了条件也会被忽略。
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现:
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("bpmn/evection-parallel.bpmn")
.name("出差申请流程-并行网关")
.deploy();
- act_re_procdef表结果:
(三)流程启动代码实现:
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> map = new HashMap<>();
Evection evection = new Evection();
evection.setNum(4d);
map.put("evection",evection);
//启动流程实例,并设置流程变量的值(把map传入)
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey("parallel", map);
ACT_RU_TASK表结果:
ACT_RU_EXECUTION表结果:
ACT_RU_VARIABLE表结果:
(三)以(ACT_RU_TASK表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:jerry送审后表结果
第三步:jack送审后表结果
第四步:rose送审后表结果(记录删除)
(四)以(ACT_RU_EXECUTION表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:jerry送审后表结果(项目经理审批到达汇聚节点)
第三步:jack送审后表结果
第四步:rose送审后表结果(记录删除)
(五)以(ACT_HI_TASKINST表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:jerry送审后表结果(jerry加上了end_time)
第三步:jack送审后表结果(添加总经理审批节点)
第四步:rose送审后表结果
(六)以(ACT_HI_PROCINST表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:jerry送审后表结果
第三步:jack送审后表结果
第四步:rose送审后表结果
(七)以(ACT_HI_ACTINST表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:jerry送审后表结果(技术经理审批endtime更新,汇聚节点创建)
第三步:jack送审后表结果(因为请4天假期,所以,再添加一个并行网关节点,添加一个总经理审批节点)
第四步:rose送审后表结果
排他网关和并行网关的结合。都为ture的时候,都要执行任务,并且最后汇聚在一起才可以执行下去。
(一)重新创建bpmn文件,如下图
(二)流程部署代码实现:
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("bpmn/evection-inclusive.bpmn")
.name("出差申请流程-包含网关")
.deploy();
- act_re_procdef表结果:
(三)流程启动代码实现:
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
String key = "inclusive";
Map<String, Object> map = new HashMap<>();
Evection evection = new Evection();
evection.setNum(4d);
//定义流程变量,把出差pojo对象放入map
map.put("evection",evection);
//启动流程实例,并设置流程变量的值(把map传入)
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey(key, map);
ACT_RU_TASK表结果:
ACT_RU_EXECUTION表结果:
ACT_RU_VARIABLE表结果:
(三)以(ACT_RU_TASK表)为代表简述执行过程:
第一步:tom送审后表结果(过滤了技术经理审批)
第二步:miki送审后表结果
第三步:jack送审后表结果
第四步:rose送审后表结果(记录删除)
(四)以(ACT_RU_EXECUTION表)为代表简述执行过程:
第一步:tom送审后表结果(技术经理节点不在)
第二步:miki送审后表结果(项目经理审批到达汇聚节点)
第三步:jack送审后表结果
第四步:rose送审后表结果(记录删除)
(五)以(ACT_HI_TASKINST表)为代表简述执行过程:
第一步:tom送审后表结果(技术经理节点不在)
第二步:miki送审后表结果(miki加上了end_time)
第三步:jack送审后表结果(添加总经理审批节点)
第四步:rose送审后表结果
(六)以(ACT_HI_ACTINST表)为代表简述执行过程:
第一步:tom送审后表结果
第二步:miki送审后表结果(技术经理审批endtime更新,汇聚节点创建)
第三步:jack送审后表结果(因为请4天假期,所以,再添加一个并行网关节点,添加一个总经理审批节点)
第四步:rose送审后表结果