假设有这样的一个审批流程,审批通过,就输出审批结果。审批节点采用用户任务,输出审批结果采用脚本任务。
流程定义如下:
<?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