初识Activiti工作流

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4   xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd">
 5 
 6   <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
 7    <property name="databaseType" value="h2" />
 8    <property name="databaseSchemaUpdate" value="true" />
 9    <property name="jobExecutorActivate" value="false" />
10    <property name="history" value="full" />
11   </bean>
12 
13 </beans>

<dependency>
  <groupId>org.activiti</groupId>
  <artifactId>activiti-engine</artifactId>
  <version>6.0.0</version>
</dependency>

 1 /**
 2  * 该实例测试简单流程包含审批和审批结果
 3  * @throws Exception
 4  */
 5 @Test
 6 public void testStartProcess2() throws Exception {
 7     // 1 创建流程引擎，使用内存数据库
 8     ProcessEngine processEngine = ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration().buildProcessEngine();
 9 
10     // 2 部署流程定义文件
11     RepositoryService repositoryService = processEngine.getRepositoryService();
12 //        String bpmnFileName = "leave2.bpmn";
13     String bpmnFileName = "leave2.bpmn.xml";
14     repositoryService.createDeployment().addInputStream("leave2.bpmn", this.getClass().getClassLoader().getResourceAsStream(bpmnFileName)).deploy();
15 
16     // 3 验证已部署的流程定义
17     ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
18     assertEquals("leave2", processDefinition.getKey());
19 
20     // 4 启动流程并返回流程实例
21     RuntimeService runtimeService = processEngine.getRuntimeService();
22 
23     Map<String, Object> variables = new HashMap<>();
24     variables.put("applyUser", "employee1"); //申请人名称
25     variables.put("days", 3); //请假天数
26 
27     ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("leave2", variables);
28     assertNotNull(processInstance);
29     System.out.println("pid=" + processInstance.getId() + ", pdid=" + processInstance.getProcessDefinitionId());
30 
31     TaskService taskService = processEngine.getTaskService();
32     Task deptLeaderTask = taskService.createTaskQuery().taskCandidateGroup("deptLeader").singleResult(); //查询deptLeader组未签收的任务
33     assertNotNull(deptLeaderTask);
34     assertEquals("领导审批", deptLeaderTask.getName());
35     taskService.claim(deptLeaderTask.getId(), "leaderUser"); //签收此任务归用户leaderUser所有
36 
37     variables = new HashMap<>();//.clear(); //处理结果
38     variables.put("approved", true); //设置审批通过
39 
40     taskService.complete(deptLeaderTask.getId(), variables); //设置审批结果
41 
42     deptLeaderTask = taskService.createTaskQuery().taskCandidateGroup("deptLeader").singleResult(); //由于任务已经完成，此时查询任务应该为空
43     assertNull(deptLeaderTask);
44 
45     // 获取历史记录
46     HistoryService historyService = processEngine.getHistoryService();
47     long count = historyService.createHistoricProcessInstanceQuery().finished().count(); //已经完成的流程实例数
48     assertEquals(1, count);
49 }

1 pid=4, pdid=leave2:1:3
2 applyUser:employee1, days:3, approval:true