-
idea2021+Activiti【最完整笔记一(基础使用)】
Activiti从0到1
概要：工作流引擎，实现业务表与工作流的分离，便于开发。
技术使用：采用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配置
1.6.6 1.2.12 7.0.0.Beta1 org.activiti activiti-engine ${activiti.version} org.activiti activiti-spring ${activiti.version} org.activiti activiti-bpmn-model ${activiti.version} org.activiti activiti-bpmn-converter ${activiti.version} org.activiti activiti-json-converter ${activiti.version} org.activiti activiti-bpmn-layout ${activiti.version} org.activiti.cloud activiti-cloud-services-api ${activiti.version} mysql mysql-connector-java 5.1.40 org.mybatis mybatis 3.4.5 commons-dbcp commons-dbcp 1.4 junit junit 4.12 log4j log4j ${log4j.version} org.slf4j slf4j-api ${slf4j.version} org.slf4j slf4j-log4j12 ${slf4j.version} commons-io commons-io 2.6 - 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
4、activiti配置文件（activiti.cfg.xml放于resource文件夹下）
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
二、流程图制作
（一）首先创建一个bpmn2.0文件，然后编辑，上述有提到。
（二）右键可创建组件
（三）连线点击右上角的箭头并拖动到其他组件中
（四）创建完毕后可通过Camunda Modeler打开文件
（五）创建一个较为完整的流程图
（六）生成流程图片（方式一）
生成流程图片（方式二）
三、创建activiti表与了解其结构
（一）创建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();- 1
- 2
- 3
- 4
- 5
- 6
（二）创建activiti表方式二：
配置文件的名字可以自定义,bean的名字也可以自定义
ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration. createProcessEngineConfigurationFromResource("activiti.cfg.xml","processEngineConfiguration"); //获取流程引擎对象（此时创建activiti的表） ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();- 1
- 2
- 3
- 4
（三）了解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
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
（二）、流程部署方式二、
//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
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
（三）流程部署修改的表
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
- 2
- 3
- 4
- 5
- 6
（二）启动流程修改的表
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 和 任务的负责人 查询任务 ListtaskList = 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
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
（二）查询过程
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 //查询结果如下- 1
- 2
六、完成个人任务
（一）代码实现方式一（完成zhangsan的任务）、
//获取引擎 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //获取操作任务的服务 TaskService TaskService taskService = processEngine.getTaskService(); //完成任务,参数：任务id,完成zhangsan的任务，10005是上述ACT_RU_TASK表的id taskService.complete("10005");- 1
- 2
- 3
- 4
- 5
- 6
（二）代码实现方式二（完成其余三人的任务）、
//完成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
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
（三）完成个人任务修改的表、
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（历史节点数据）
- 1、zhangsan完成任务(插入下一个经理审批节点，节点中taskid为运行时任务信息表中的id,end_time加入处理完结时间)
- 2、jerry完成任务(插入下一个总经理节点，节点中taskid为运行时任务信息表中的id,end_time加入处理完结时间)
- 3、jack完成任务(插入下一个财务审批节点，节点中taskid为运行时任务信息表中的id,end_time加入处理完结时间)
- 4、rose完成任务(插入下一个结束节点，节点中taskid为运行时任务信息表中的id,end_time加入处理完结时间)
3. ACT_HI_IDENTITYLINK（历史流程用户信息数据表）
- 1、zhangsan完成任务(插入jerry负责人)
- 2、jerry完成任务(插入jack负责人)
- 3、jack完成任务(插入rose负责人)
4. ACT_RU_TASK（运行时任务信息数据信息表）
- 1、zhangsan完成任务(删除了10005zhangsan的创建出差申请任务,添加了经理审批任务记录)
- 2、jerry完成任务(删除了12502jerry的经理审批任务,添加了总经理审批任务记录)
- 3、jack完成任务(删除了15002jerry的总经理审批任务,添加了财务审批任务记录)
- 3、rose完成任务(删除了17502jack的财务审批任务)
5. ACT_RU_IDENTITYLINK（运行时用户信息数据）
- 1、zhangsan完成任务(插入jerry负责人)
- 2、jerry完成任务(插入jack负责人)
- 3、jack完成任务(插入rose负责人)***
负责人) - 4、rose完成任务(删除所有记录)
6. ACT_RU_EXECUTION（运行时流程执行实例数据表）
- 1、zhangsan完成任务(第二条记录改为_4id的节点（经理审批）)
- 2、jerry完成任务(第二条记录改为_5id的节点（总经理经理审批）)
- 3、jack完成任务(第二条记录改为_6id的节点（财务审批）)
- 4、rose完成任务(第一、二条记录删除细节)：
- 第一步先更改第二条记录REV为5、ACT_ID_为_7（结束节点）
- 第二步删除id为10002的记录。
- 第三步删除结束节点，id为10001的记录。
7. ACT_HI_PROCINST（历史流程实例数据表）
- 4、rose完成任务：end_time更新为完成时间、end_act_id_更新为最后一个节点的id
七、查看历史信息
（一）代码实现
//获取引擎 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(); //查询所有内容 ListactivityInstanceList = 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("<==========================>"); } - 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
输出：
_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 <==========================>- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
八、与业务表关联
（一）代码实现（使用关联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());- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
输出
businessKey==1001- 1
（二）与普通方式启动实例比较
1. ACT_HI_PROCINST（历史流程实例数据表比较,普通启动business_key为空，说明业务表的id存在这个字段中）
2. ACT_RU_EXECUTION（运行时流程执行实例数据表比较，普通启动business_key为空，说明业务表的id存在这个字段中）
九、使用uel设置负责人
（一）重新创建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());- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
输出：
流程部署id=25001 流程部署名字=出差申请流程-uel- 1
- 2
act_re_procdef表结果：
（三）流程启动代码实现：
//获取流程引擎 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //获取RunTimeService RuntimeService runtimeService = processEngine.getRuntimeService(); //设定assignee的值，用来替换uel表达式 Map- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
（四）添加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();- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- act_re_procdef表结果：
（三）流程启动代码实现：
//获取流程引擎 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //获取RunTimeService RuntimeService runtimeService = processEngine.getRuntimeService(); runtimeService.startProcessInstanceByKey("testCandidate");- 1
- 2
- 3
- 4
- 5
说明：除了部门经理审批，其余流程与第六章相同。
（四）查询组任务代码实现（提前将五好青年1完成任务，到达部门经理审批）：
//获取引擎 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //获取TaskService TaskService taskService = processEngine.getTaskService(); //查询组任务 ListtaskList = 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()); } - 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
输出
======================== 流程实例ID=55001 任务id=57502 任务负责人=null- 1
- 2
- 3
- 4
- 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+"-拾取任务完成"); }- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
输出：
taskid-57502-用户-wangwu-拾取任务完成- 1
- 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+"-归还任务完成"); }- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
（六）后续完成任务按照第六章正常思路完成
十一、监听器
（一）重新创建bpmn文件，如下图
（二）流程部署代码实现ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RepositoryService repositoryService = processEngine.getRepositoryService(); Deployment deploy = repositoryService.createDeployment() .name("测试监听器") .addClasspathResource("bpmn/demo-listen.bpmn") .deploy();- 1
- 2
- 3
- 4
- 5
- 6
- act_re_procdef表结果：
（二）启动流程代码实现ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RuntimeService runtimeService = processEngine.getRuntimeService(); runtimeService.startProcessInstanceByKey("testListener");- 1
- 2
- 3
- 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("张三"); } } }- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
十二、设置变量
（一）重新创建bpmn文件，如下图
（二）流程部署代码实现ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RepositoryService repositoryService = processEngine.getRepositoryService(); Deployment deploy = repositoryService.createDeployment() .name("出差申请流程-variables") .addClasspathResource("bpmn/evection-global.bpmn") .deploy();- 1
- 2
- 3
- 4
- 5
- 6
- 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; } }- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
（四）流程启动代码实现方式一（启动流程的时候设置流程变量）：
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RuntimeService runtimeService = processEngine.getRuntimeService(); //流程变量的map Map- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
（五）流程启动代码实现方式二（完成个人任务的时候设置流程变量）：
//设置流程变量 Evection evection = new Evection(); //设置出差时间 evection.setNum(2d); Map- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
（六）添加流程变量修改的表，除了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();- 1
- 2
- 3
- 4
- 5
- 6
- act_re_procdef表结果：
（三）流程启动代码实现：ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RuntimeService runtimeService = processEngine.getRuntimeService(); Map- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 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();- 1
- 2
- 3
- 4
- 5
- 6
- act_re_procdef表结果：
（三）流程启动代码实现：ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RuntimeService runtimeService = processEngine.getRuntimeService(); Map- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
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();- 1
- 2
- 3
- 4
- 5
- 6
- act_re_procdef表结果：
（三）流程启动代码实现：ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); RuntimeService runtimeService = processEngine.getRuntimeService(); String key = "inclusive"; Map- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
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送审后表结果
-
相关阅读:
分布式数据库·Hive和MySQL的安装与配置
可拓展的低代码全栈框架
java基于springboot+vue的旅游博客旅游经验分享系统
thingsboard3.4版本之OTA升级
saas化多租户-动态数据源
go error处理
Java虚拟机运算指令学习
【Python】Java工程师学Python之PyCharm安装详细教程
上传图片签名验证
[Spring笔记] Spring-27-Spring整合MyBatis
- 原文地址：https://blog.csdn.net/m0_54850467/article/details/126013617
