Activiti7工作流引擎：基础篇 流程变量

Posted 2022-01-21 vbirdbest

不要指望别人能帮你多少，人生事事物物都得靠自己。

一：简介

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

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

二：流程变量设置时机

2.1 启动实例时设置为全局变量

runtimeService.startProcessInstanceByKey(key, map);

2.2 任务办理时设置变量

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

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

2.3 通过流程实例设置变量

通过流程实例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)

2.4 通过当前任务设置变量

@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)

2.5 办理任务前设置局部变量

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

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

三：条件分支

流程条件就是在连接线(sequenceFlow)增加一个Boolean类型的添加，当条件满足后就会走对应的任务。

• 当有多个条件满足时：只要满足条件的都执行。
• 当所有条件都不成立时：抛异常，流程走不下去报错。

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);
        
    

---

修改条件$day >= 3 和 $day >= 2，当day=5时两个条件都满足，两个任务都执行，所以部门经理和人事都需要审核。

修改条件$day >= 3 和 $day >= 2，当day=1时两个条件都不满足，报错不能继续流程org.activiti.engine.ActivitiException: No outgoing sequence flow of element 'pmApprove' could be selected for continuing the process。