|
Maven配置
<properties>
<spring.version>4.1.0.RELEASE</spring.version>
<mybatis.version>3.3.0</mybatis.version>
<mybatis-spring.version>1.2.3</mybatis-spring.version>
<junit.version>4.12</junit.version>
<activiti.version>5.19.0.2</activiti.version>
<logback.version>1.1.3</logback.version>
<mysql.connector.java>5.1.35</mysql.connector.java>
<com.alibaba.druid>1.0.2</com.alibaba.druid>
<druid.version>1.0.2</druid.version>
<org.aspectj.aspectjweaver>1.8.4</org.aspectj.aspectjweaver>
</properties>
<dependencies>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.4</version>
</dependency>
<!-- JUnit -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${junit.version}</version>
<scope>test</scope>
</dependency>
<!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>${logback.version}</version>
</dependency>
<!-- mybatis -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>${mybatis.version}</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>${mybatis-spring.version}</version>
</dependency>
<!-- activiti -->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-engine</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-rest</artifactId>
<version>${activiti.version}</version>
</dependency>
<!--JDBC驱动 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.connector.java}</version>
</dependency>
<!-- 连接池 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>${druid.version}</version>
</dependency>
整合数据库
默认配置文件名为activiti.cfg.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
<property name="databaseSchemaUpdate" value="drop-create"/>
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db_activiti?useUnicode=true&characterEncoding=utf-8"/>
<property name="jdbcDriver" value="com.mysql.jdbc.Driver"/>
<property name="jdbcUsername" value="root"/>
<property name="jdbcPassword" value="****"/>
<property name="jobExecutorActivate" value="true"/>
</bean>
</beans>
数据内容会在运行前自动创建
创建工作流文件
由于BPMN规范的作用，一些高级的IDE会自动识别后缀为*.bpmn的文件，不过这些都无所谓，bpmn文件实际上就是XML文件，只是加上了一些图形的标记，如width、height、x和y的坐标，下面为一个招聘面试流程，只包含流程节点，不包含位置标记节点。
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
xmlns:activiti="http://activiti.org/bpmn"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
targetNamespace="Examples"
xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL
http://www.omg.org/spec/BPMN/2.0/20100501/BPMN20.xsd">
<process id="Interview" name="某公司2012年实习生招聘流程">
<documentation>招聘工作流程</documentation>
<startEvent id="start" name="实习生招聘启动"/>
<userTask id="bishi" name="笔试" activiti:candidateGroups="人力资源部"/>
<sequenceFlow id="flow1" name="" sourceRef="start" targetRef="bishi"/>
<userTask id="yimian" name="技术一面" activiti:candidateGroups="技术部"/>
<sequenceFlow id="flow2" name="" sourceRef="bishi" targetRef="yimian"/>
<userTask id="ermian" name="技术二面" activiti:candidateGroups="技术部"/>
<sequenceFlow id="flow3" name="" sourceRef="yimian" targetRef="ermian"/>
<userTask id="hrmian" name="HR面" activiti:candidateGroups="人力资源部"/>
<sequenceFlow id="flow4" name="" sourceRef="ermian" targetRef="hrmian"/>
<userTask id="luyong" name="录用，发放Offer" activiti:candidateGroups="人力资源部"/>
<sequenceFlow id="flow5" name="" sourceRef="hrmian" targetRef="luyong"/>
<endEvent id="end" name="实习生招聘结束"/>
<sequenceFlow id="flow6" name="" sourceRef="luyong" targetRef="end"/>
</process>
</definitions>
测试运行
有了流程引擎的配置文件和流程文件后，就可以编写代码启动流程引擎并加载该流程文件了。测试清单如下：
@Test
public void processTests(){
// 加载配置文件
ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
// 取得 Activiti 服务
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();
repositoryService.createDeployment().addClasspathResource("Interview.bpmn").deploy();
// 启动流程实例
String processId = runtimeService.startProcessInstanceByKey("Interview").getId();
TaskService taskService = processEngine.getTaskService();
//得到笔试的流程
System.out.println("\n***************笔试流程开始***************");
//List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey("bishi").list();
List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
for (Task task : tasks) {
System.out.println("人力资源部的任务：name:"+task.getName()+",id:"+task.getId());
taskService.claim(task.getId(), "张三");
}
System.out.println("张三的任务数量："+taskService.createTaskQuery().taskAssignee("张三").count());
tasks = taskService.createTaskQuery().taskAssignee("张三").list();
for (Task task : tasks) {
System.out.println("张三的任务：name:"+task.getName()+",id:"+task.getId());
taskService.complete(task.getId());
}
System.out.println("张三的任务数量："+taskService.createTaskQuery().taskAssignee("张三").count());
System.out.println("***************笔试流程结束***************");
System.out.println("\n***************一面流程开始***************");
tasks = taskService.createTaskQuery().taskCandidateGroup("技术部").list();
for (Task task : tasks) {
System.out.println("技术部的任务：name:"+task.getName()+",id:"+task.getId());
taskService.claim(task.getId(), "李四");
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
for (Task task : tasks) {
System.out.println("李四的任务：name:"+task.getName()+",id:"+task.getId());
taskService.complete(task.getId());
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
System.out.println("***************一面流程结束***************");
System.out.println("\n***************二面流程开始***************");
tasks = taskService.createTaskQuery().taskCandidateGroup("技术部").list();
for (Task task : tasks) {
System.out.println("技术部的任务：name:"+task.getName()+",id:"+task.getId());
taskService.claim(task.getId(), "李四");
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
for (Task task : tasks) {
System.out.println("李四的任务：name:"+task.getName()+",id:"+task.getId());
taskService.complete(task.getId());
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
System.out.println("***************二面流程结束***************");
System.out.println("***************HR面流程开始***************");
tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
for (Task task : tasks) {
System.out.println("技术部的任务：name:"+task.getName()+",id:"+task.getId());
taskService.claim(task.getId(), "李四");
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
for (Task task : tasks) {
System.out.println("李四的任务：name:"+task.getName()+",id:"+task.getId());
taskService.complete(task.getId());
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
System.out.println("***************HR面流程结束***************");
System.out.println("\n***************录用流程开始***************");
tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
for (Task task : tasks) {
System.out.println("技术部的任务：name:"+task.getName()+",id:"+task.getId());
taskService.claim(task.getId(), "李四");
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
for (Task task : tasks) {
System.out.println("李四的任务：name:"+task.getName()+",id:"+task.getId());
taskService.complete(task.getId());
}
System.out.println("李四的任务数量："+taskService.createTaskQuery().taskAssignee("李四").count());
System.out.println("***************录用流程结束***************");
HistoryService historyService = processEngine.getHistoryService();
HistoricProcessInstance historicProcessInstance = historyService
.createHistoricProcessInstanceQuery()
.processInstanceId(processId).singleResult();
System.out.println("\n流程结束时间："+historicProcessInstance.getEndTime());
}
代码清单中使用 ProcessEngines类加载默认的流程配置文件(activiti.cfg.xml)，再获取各个服务组件的实例。RepositoryService主要用于管理流程的资源， RuntimeService主要用于流程运行时的流程管理，TaskService主要用于管理流程任务。最后， HistoricProcessInstance会将工作的流程历史记录下来
| 
转播
