Activiti7工作流引擎：流程变量

Posted 2022-01-04 vbirdbest

流程变量就是if条件中使用到的变量用于参与条件表达式的计算。

程序中的变量是有作用域的，如是方法内部的变量还是对象变量，同样流程变量也分全局变量global（作用在整个流程实例范围）和本地变量local（作用在单个任务或者单个执行实例）

UEL表达式

UEL表达式类似于JSP中的ETL表达式，不同的是UEL表达式的结果必须是一个布尔结果，就是在$内可以写表达式，如引用一个变量值 $ assignee、 $ xxx.assignee，做一些简单的boolean条件运算$ xxx.day >= 3 || xxx.role == ‘pm’，甚至调用一个类中的方法。

多个流程变量可以封装到一个POJO对象中，不过必须实现Serializable接口。

任务启动时设置变量

public class LeaveVariable implements Serializable 
    private Long id;
    private Double day;
    
    // Get && Seter

LeaveVariable leaveVariable = new LeaveVariable();
leaveVariable.setDay(2.5d);

Map<String, Object> map = new HashMap<>();
map.put("proposer", "张三");
map.put("pm", "狗经理");
map.put("deptPM", "狗部门经理");
map.put("hr", "狗人事");

// key随意写
map.put("xxx", leaveVariable);
// .bpmn中的Condition可以通过$xxx.day来获取对象的属性值
// 在启动流程实例时设置变量，变量为全局变量
runtimeService.startProcessInstanceByKey(key, map);

任务办理时设置变量

也可以在任务办理时设置变量。在完成任务时设置流程变量，该流程变量只有在该任务完成后其它结点才可使用该变量，它的作用域是整个流程实例，如果设置的流程变量的key在流程实例中已存在相同的名字则后设置的变量替换前边设置的变量。

String assingee = "张三";
Task task = taskService.createTaskQuery()
                .processDefinitionKey(key)
                .taskAssignee(assingee)
                .singleResult();
if(task != null)
    //完成任务时为以后的节点设置流程变量的值
    taskService.complete(task.getId(),map);

通过当前流程实例设置变量

通过流程实例id设置全局变量，该流程实例必须未执行完成。executionId必须当前未结束 流程实例的执行id，通常此id设置流程实例 的id。也可以通runtimeService.getVariable()获取流程变量。

@Test
public void setGlobalVariableByExecutionId()
    String executionId="2601";
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    RuntimeService runtimeService = processEngine.getRuntimeService();
    Evection evection = new Evection();
    evection.setNum(3d);
//      通过流程实例 id设置流程变量
    runtimeService.setVariable(executionId, "evection", evection);
//      一次设置多个值
//      runtimeService.setVariables(executionId, variables)

通过当前任务设置变量

@Test
public void setGlobalVariableByTaskId()
	
	String taskId="1404";
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	TaskService taskService = processEngine.getTaskService();
	Evection evection = new Evection();
	evection.setNum(3);
	//通过任务设置流程变量
	taskService.setVariable(taskId, "evection", evection);
	//一次设置多个值 
	//taskService.setVariables(taskId, variables)

---

任务办理时设置local流程变量，当前运行的流程实例只能在该任务结束前使用，任务结束该变量无法在当前流程实例使用，可以通过查询历史任务查询。

//  设置local变量，作用域为该任务
Map<String, Object> variables = new HashMap<>();
// 设置单个
taskService.setVariableLocal(taskId, "xxx", evection);
// 设置多个
taskService.setVariablesLocal(taskId, variables);
taskService.complete(taskId);

public class ProcessVariableTest 
    @Test
    public void testCreateDBTable() 
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        System.out.println(processEngine);
    

    @Test
    public void delopyBpmn() 
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        Deployment deploy = processEngine.getRepositoryService()
                .createDeployment()
                .addClasspathResource("bpmn/leave.bpmn")
                .name("请假流程")
                .deploy();
        // DeploymentEntity[id=1, name=请假流程]
        System.out.println(deploy);
    


    @Test
    public void startProcessInstance() 
        Map<String, Object> assignees = new HashMap<>();
        assignees.put("proposer", "张三");
        assignees.put("pm", "狗经理");
        assignees.put("deptPM", "狗部门经理");
        assignees.put("hr", "狗人事");

        String businessKey = "1";

        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        ProcessInstance processInstance = processEngine.getRuntimeService()
                .startProcessInstanceByKey("LeaveProcess", businessKey, assignees);
        // processInstance.getId() = processInstance.getProcessInstanceId()
        System.out.println("实例Id：" + processInstance.getId());
        System.out.println("实例Id：" + processInstance.getProcessInstanceId());
        System.out.println("流程定义Id：" + processInstance.getProcessDefinitionId());
    

    @Test
    public void testQueryRuTask() 
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        List<Task> list = processEngine.getTaskService()
                .createTaskQuery()
                .processDefinitionKey("LeaveProcess")
                .taskAssignee("张三")
                .list();
        System.out.println(list);
    

    @Test
    public void completeTask() 
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        Task task = taskService
                .createTaskQuery()
                .processDefinitionKey("LeaveProcess")
                .taskAssignee("张三")
                .singleResult();
        if (task != null) 
            taskService.complete(task.getId());
        
    

    @Test
    public void testCompleteTask2() 
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();

        Task task = taskService
                .createTaskQuery()
                .processDefinitionKey("LeaveProcess")
                .taskAssignee("狗经理")
                .singleResult();
        // 设置流程变量
        Map<String, Object> variables = new HashMap<>();
        variables.put("day", 3);
        if (task != null) 
            taskService.complete(task.getId(), variables);
        
    

注意：如果所有条件都不成立，整个流程算结束🔚。