主要理解一下知识点
一、名字解释
详情解释传送门
setVariables 和 setVariablesLocal区别?
1.流程变量
在流程执行或者任务执行的过程中,用于设置和获取变量,使用流程变量在流程传递的过程中传递业务参数。
对应的表:
act_ru_variable:正在执行的流程变量表
act_hi_varinst:流程变量历史表
2.setVariable和setVariableLocal的区别
setVariable:设置流程变量的时候,流程变量名称相同的时候,后一次的值替换前一次的值,而且可以看到TASK_ID的字段不会存放任务ID的值
setVariableLocal:
1)设置流程变量的时候,针对当前活动的节点设置流程变量,如果一个流程中存在2个活动节点,对每个活动节点都设置流程变量,即使流程变量的名称相同,后一次的版本的值也不会替换前一次版本的值,它会使用不同的任务ID作为标识,存放2个流程变量值,而且可以看到TASK_ID的字段会存放任务ID的值。
例如act_hi_varinst 表的数据:不同的任务节点,即使流程变量名称相同,存放的值也是不同的。
2)还有,使用setVariableLocal说明流程变量绑定了当前的任务,当流程继续执行时,下个任务获取不到这个流程变量(因为正在执行的流程变量中没有这个数据),所有查询正在执行的任务时不能查询到我们需要的数据,此时需要查询历史的流程变量。
可以简单认为,variable都是针对processInstance的。
local可能是针对某个execution分支的,也可能针对task的。
这里就要谈一下变量的作用域,变量肯定是依附于某个流程里的概念而存在的,所以才能在流程流转过程中使用这些变量。
默认的变量都是流程实例级别的,也就是说,分支execution和task都可以读取到对应processInstance里的变量。
与之相对的就是local变量,简单来说就不是processInstance范围的变量,如何区分global和local呢?差别就是local的作用范围小,如果是分支execution的local变量,就只能在execution分支生存期使用。
比如并发分支结束了,变量也就没了
比如task结束了,变量也就没了。
local变量的好处是,可以在每个分支使用同名的变量,互相之间不受影响,会签multi-instance就是通过local局部变量实现的。
流程实例结束完成以后流程变量还保存在数据库中(存放到流程变量的历史表中)。
1)流程变量的作用域就是流程实例,所以只要设置就行了,不用管在哪个阶段设置
2)基本类型设置流程变量,在taskService中使用任务ID,定义流程变量的名称,设置流程变量的值
3)Javabean类型设置流程变量,需要这个javabean实现了Serializable接口
4)设置流程变量的时候,向act_ru_variable这个表添加数据
5)流程变量的获取针对流程实例(1个流程),每个流程实例获取的流程变量是不同的
6)使用基本类型获取流程变量,在taskService中使用任务ID,流程变量的名称,获取流程变量的值。
7)Javabean类型设置获取流程变量,除了需要这个javabean实现了Serializable接口外,还要求流程变量对象的属性不能发生变化,否则抛出异常。解决方案,固定序列化ID
二、实操
test公用代码
ProcessEngineConfiguration configuration= null;
@Before
public void before(){
//获取 ProcessEngineConfiguration 对象
configuration = new StandaloneProcessEngineConfiguration();
// 配置数据库连接信息
configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");
configuration.setJdbcUsername("root");
configuration.setJdbcPassword("123456");
configuration.setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC&nullCatalogMeansCurrent=true");
//如果数据库中不存在表结构就新建
configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
}
@Test
public void test(){
ProcessEngine processEngine = configuration.buildProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
//完成流程部署
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("test.bpmn20.xml")
.name("测试流程 部署")
.deploy();
System.out.println("deployment.getName() : " + deployment.getName());
System.out.println("deployment.getId() : " + deployment.getId());
}
先注意一个小细节
ProcessInstance instance1 = runtimeService.createProcessInstanceQuery().processInstanceId("75001").singleResult();
System.out.println("instance1 proVar: "+instance.getProcessVariables()); // 结果{}
instance.getProcessVariables()为什么为空
这个问题,要从模型说起。
flowable自己实现了一个命令模式,所有的操作都是通过命令模式实现的,命令模式的好处是可以在执行命令前打开环境,命名结束后关闭环境。
很不幸的是,flowable是通过这种方式,打开jdbc和关闭jdbc的。
所以,一旦关闭jdbc,也就是执行cmd后,就不能操作数据库里,它没有hibernate那种OpenSessionInVIew的功能。
所以,你必须在cmd执行完之前,告诉activiti,需要取变量,否则它根本就不会去搜索,不发sql,就算数据库里有变量,也取不出来啊。
告诉flowable的方式,就是通过includeProcessVariables。
比如runtimeService.createProcessInstanceQuery().includeProcessVariables().list()就有变量
比如runtimeService.createProcessInstanceQuery().list()就没变量
1. 全局变量的替换规则
@Test
public void test02(){
ProcessEngine processEngine = configuration.buildProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> var = new HashMap<>();
var.put("test","申请变量");
ProcessInstance instance = runtimeService.startProcessInstanceById("test:2:47504",var);
Map<String, Object> variables = new HashMap<>();
// variables.put("Local","proInst");
variables.put("test","proInst");
runtimeService.setVariables(instance.getId(),variables);
System.out.println(" instanceid: "+instance.getId());
}
@Test
public void complete(){
ProcessEngine processEngine = configuration.buildProcessEngine();
TaskService taskService = processEngine.getTaskService();
RuntimeService runtimeService = processEngine.getRuntimeService();
ProcessInstance instance1 = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
System.out.println("instance proVar: "+instance.getProcessVariables());
System.out.println("instance1 proVar: "+instance1.getProcessVariables());
// instance proVar: {test=proInst}
// instance1 proVar: {test=proInst}
}
结果被后面一个值所替换,如果其中一个设置为局部变量就不会被替换 == runtimeService.setVariablesLocal(instance.getId(),variables); ==
2. 任务变量
代码实操
// 设置流程变量
@Test
public void test02(){
ProcessEngine processEngine = configuration.buildProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> var = new HashMap<>();
var.put("test","申请变量");
ProcessInstance instance = runtimeService.startProcessInstanceById("test:2:47504",var);
Map<String, Object> variables = new HashMap<>();
variables.put("Local","proInst");
runtimeService.setVariablesLocal(instance.getId(),variables);
System.out.println(" instanceid: "+instance.getId());
// 1. 50001 2. 57501 3. 62501 4.70001 5.
}
// 完成任务,同时设置任务的局部变量
@Test
public void complete(){
ProcessEngine processEngine = configuration.buildProcessEngine();
TaskService taskService = processEngine.getTaskService();
RuntimeService runtimeService = processEngine.getRuntimeService();
// 62501 局部70001 全局72501
// ProcessInstance instance1 = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
// ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
// System.out.println("instance proVar: "+instance.getProcessVariables());
// System.out.println("instance1 proVar: "+instance1.getProcessVariables());
Map<String, Object> var = new HashMap<>();
// 如果scope 为false,则任务变量都是空的,只有统一的流程实例变量
var.put("complete","完成任务65003的变量,scope true");
taskService.complete("65003",var,true);
}
// 查看变量
@Test
public void var(){
ProcessEngine processEngine = configuration.buildProcessEngine();
TaskService taskService = processEngine.getTaskService();
HistoryService historyService = processEngine.getHistoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();
HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery()
.processInstanceId("62501")
.includeProcessVariables()
.singleResult();
// ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId("50001").singleResult();
System.out.println("流程实例 ProcessVariables: "+historicProcessInstance.getProcessVariables());
List<HistoricVariableInstance> list1 = historyService.createHistoricVariableInstanceQuery().processInstanceId("62501").list();
System.out.println("流程实例变量 =================== ");
list1.forEach(item -> {
System.out.println("name: "+item.getVariableName());
System.out.println("value: "+item.getValue());
});
System.out.println("流程实例变量 =================== ");
// ("50006");
List<HistoricVariableInstance> list = historyService.createHistoricVariableInstanceQuery().taskId("62506").list();
System.out.println("任务1的变量 =================== ");
list.forEach(item -> {
System.out.println(item.getVariableName());
System.out.println(item.getValue());
});
System.out.println("任务1的变量 =================== ");
List<HistoricVariableInstance> list2 = historyService.createHistoricVariableInstanceQuery().taskId("65003").list();
System.out.println("任务2的变量 =================== ");
list2.forEach(item -> {
System.out.println(item.getVariableName());
System.out.println(item.getValue());
});
System.out.println("任务2的变量 =================== ");
// Map<String, Object> variables02 = taskService.getVariables("52503");
// System.out.println("任务2的变量: "+variables02);
// Map<String, Object> var = new HashMap<>();
// var.put("complete","完成任务50006的变量");
// taskService.complete("50006",var);
/**
* 流程实例 ProcessVariables: {test=申请变量, Local=proInst}
* 流程实例变量 ===================
* name: test
* value: 申请变量
* name: Local
* value: proInst
* name: complete
* value: 完成任务62506的变量,scope true
* name: complete
* value: 完成任务65003的变量,scope true
* 流程实例变量 ===================
* 任务1的变量 ===================
* complete
* 完成任务62506的变量,scope true
* 任务1的变量 ===================
* 任务2的变量 ===================
* complete
* 完成任务65003的变量,scope true
* 任务2的变量 ===================
*/
}
结果
taskService.complete(“65003”,var,true)
complete可以增加每个任务的环境变量(就是一个任务关联一些独有变量),比如一个任务一个表单,scope 要设置为true(true为局部,false为全局 [ 默认 ])
scope为true时
历史变量表就会关联taskid
scope为false时
历史变量表就不会关联taskid,是实例全局变量,会发生替换之前的变量值问题