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

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

流程定义如下：

<?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="审批">
    	<!-- 由角色 deptLeader 处理-->
    	<potentialOwner>
    		<resourceAssignmentExpression>
    			<formalExpression>deptLeader</formalExpression>
    		</resourceAssignmentExpression>
    	</potentialOwner>
    </userTask>
    <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
    
	<!-- 脚本任务 -->    
	<!-- 由 groovy 处理 -->
    <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

deniro_li

发布了671 篇原创文章 · 获赞 766 · 访问量 99万+

他的留言板关注

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

猜你喜欢