说说如何使用 Activiti 创建带用户任务与脚本任务的审批流程

ゝ一纸荒年。 2023-07-12 09:21 13阅读 0赞

假设有这样的一个审批流程，审批通过，就输出审批结果。审批节点采用用户任务，输出审批结果采用脚本任务。

![format_png][]

流程定义如下：

<?xml version="1.0" encoding="UTF-8"?>
    <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
      <process id="leaveWithApprovalProcess" name="leaveWithApprovalProcess" isExecutable="true">
      	
        <startEvent id="startevent1" name="Start"></startEvent>
        
        
        <userTask id="usertask1" name="审批">
        	
        	<potentialOwner>
        		<resourceAssignmentExpression>
        			<formalExpression>deptLeader</formalExpression>
        		</resourceAssignmentExpression>
        	</potentialOwner>
        </userTask>
        <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
        
    	    
    	
        <scriptTask id="scripttask1" name="输出审批结果" scriptFormat="groovy" activiti:autoStoreVariables="false">
        	<script><![CDATA[out:println "applyUser:"+applyUser+",days:"+days+",approval:"+approved;]]></script>
        </scriptTask>
        <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="scripttask1"></sequenceFlow>
        <endEvent id="endevent1" name="End"></endEvent>
        
        
        <sequenceFlow id="flow3" sourceRef="scripttask1" targetRef="endevent1"></sequenceFlow>
      </process>
       ...
    </definitions>

在此流程定义中，我们定义了一个名为 “审批” 的用户任务，并把它交由 “deptLeader” 角色处理，也就是所有拥有 deptLeader 角色的用户，都可以领取该任务。

还定义了一个名为 “输出审批结果” 的脚本任务。script 支持 Javascript 或 Groovy，如果需要使用 Groovy，需要在项目中加入 Groovy 依赖，比如在 Maven 项目中，可以这样添加：

<dependency>
                <groupId>org.codehaus.groovy</groupId>
                <artifactId>groovy-all</artifactId>
                <version>${groovy.version}</version>
    </dependency>

某个审批流程的审核人可能有多个，他们都同属于一个角色。当某个任务分配给审核人角色后，所有的审核人都会收到一条未签收状态的任务。当某个审核人执行了签收（领取）动作之后，这项任务就归签收人所有。我们写个测试用例，来验证这一流程。

public class LeaveWithApprovalProcess {
    
        @Test
        public void testLeaveWithApprovalProcess() {
    
            //流程定义的 Key
            String processDefinitionKey = "leaveWithApprovalProcess";
    
            //流程引擎
            ProcessEngine processEngine = ProcessEngineConfiguration
                    .createStandaloneInMemProcessEngineConfiguration().buildProcessEngine();
    
            /**
             * 部署流程
             */
            RepositoryService repositoryService = processEngine.getRepositoryService();
            String bpmnFileName = BPMN_PATH + "leaveWithApprovalProcess.bpmn";
            repositoryService.createDeployment().addInputStream("leaveWithApprovalProcess.bpmn", this.getClass()
                    .getClassLoader().getResourceAsStream(bpmnFileName)).deploy();
    
            //流程定义
            ProcessDefinition definition = repositoryService.createProcessDefinitionQuery()
                    .singleResult();
            //确认流程定义
            assertEquals(processDefinitionKey, definition.getKey());
    
    
            /**
             * 启动流程 【1】
             */
            RuntimeService runtimeService = processEngine.getRuntimeService();
            Map<String, Object> variables = new HashMap<String, Object>();
            //申请人名称
            variables.put("applyUser", "安妙依");
            //请假天数
            variables.put("days", 5);
            ProcessInstance processInstance = runtimeService.startProcessInstanceByKey
                    (processDefinitionKey, variables);
            //确认流程实例
            assertNotNull(processInstance);
            System.out.printf("instance_id=%s;definition_id=%s\n", processInstance.getId(),
                    processInstance.getProcessDefinitionId());
    
            /**
             * 流转到【审批】节点
             */
            TaskService taskService = processEngine.getTaskService();
            Task deptLeaderTask = taskService.createTaskQuery().taskCandidateGroup
                    ("deptLeader").singleResult();
            //确认用户任务
            assertNotNull(deptLeaderTask);
            //确认任务名称
            assertEquals("审批", deptLeaderTask.getName());
            //用户 唐三 签收该任务 【2】
            taskService.claim(deptLeaderTask.getId(), "唐三");
            //用户 唐三 签署意见，审批通过
            variables = new HashMap<String, Object>();
            variables.put("approved", "true");
            taskService.complete(deptLeaderTask.getId(), variables);
    
    
            /**
             * 流转到【输出审批结果】节点 【3】
             */
            /**
             * 流程结束
             */
            deptLeaderTask = taskService.createTaskQuery().taskCandidateGroup("deptLeader")
                    .singleResult();
            //任务流转到下一节点，所以当前节点没有任务
            assertNull(deptLeaderTask);
            //通过历史接口，统计已完成的流程数量
            HistoryService historyService = processEngine.getHistoryService();
            long count = historyService.createHistoricProcessInstanceQuery().count();
            assertEquals(1, count);
    
    
        }
    }

【1】启动流程时，传入了两个变量（申请人名称与请假天数），Activiti 会把这两个变量持久化到数据库中，以后就可以通过接口读取到这些变量。  
【2】当某个用户通过 taskService.claim() 方法签收了该任务后，这个任务就归他所有。  
【3】因为输出审批结果是脚本任务，所以会被自动执行，然后流转到下一节点。

运行结果：

> instance\_id=5;definition\_id=leaveWithApprovalProcess:1:4  
> applyUser:安妙依,days:5,approval:true

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy8zMzg2MTA4LTY3ZmZhYjIyNmI1YmQyNWYucG5n?x-oss-process=image/format,png