接上文,本文主要讲述如何使用Activiti搭建一个简单的工程。
首先就是下载Activiti5.9的官方文件,下载地址见:http://activiti.org/download.html,新建一个Java工程导入相关的JAR包,安装Activiti的插件。因为单一的仅使用Activiti的项目在现实生活中几乎不存在,所以本文中的项目还是集成了Spring框架,所需要的JAR包截图如下:
新建一个Java Project,在该项目中新建一个Activiti Process,打开插件面板。
这里模拟的流程是某公司的实习生招聘流程:
新建一个开始节点:
接下来新建其余的节点:
最终的结果图如下:
该步骤会自动生成相应的bpmn2.0文件,如图所示:
接下来就是创建配置文件了:
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="true" />
<property name="jdbcUrl" value="jdbc:mysql://localhost:9906/activiti" />
<property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
<property name="jdbcUsername" value="root" />
<property name="jdbcPassword" value="root" />
<property name="jobExecutorActivate" value="true" />
</bean>
</beans>
测试类:
InterviewTest.java
package com.activiti04;
import java.util.List;
import org.activiti.engine.HistoryService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.task.Task;
public class InterviewTest {
//本流程模拟的是某公司2012年实习生招聘流程
public static void main(String[] args) {
//加载配置文件
ProcessEngine processEngine = ProcessEngineConfiguration
.createProcessEngineConfigurationFromResource("activiti.cfg.xml")
.buildProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();
repositoryService.createDeployment()
.addClasspathResource("main/resources/diagrams/Interview.bpmn20.xml")
.deploy();
String processId = runtimeService.startProcessInstanceByKey("Interview").getId();
TaskService taskService = processEngine.getTaskService();
//得到笔试的流程
System.out.println("***************笔试流程开始***************");
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("***************一面流程开始***************");
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("***************二面流程开始***************");
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("***************录用流程开始***************");
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("流程结束时间:"+historicProcessInstance.getEndTime());
System.exit(0);
}
}
然后执行即可,结果如下:
***************笔试流程开始***************
人力资源部的任务:name:笔试,id:307
张三的任务数量:1
张三的任务:name:笔试,id:307
张三的任务数量:0
***************笔试流程结束***************
***************一面流程开始***************
技术部的任务:name:技术一面,id:310
李四的任务数量:1
李四的任务:name:技术一面,id:310
李四的任务数量:0
***************一面流程结束***************
***************二面流程开始***************
技术部的任务:name:技术二面,id:313
李四的任务数量:1
李四的任务:name:技术二面,id:313
李四的任务数量:0
***************二面流程结束***************
***************HR面流程开始***************
技术部的任务:name:HR面,id:316
李四的任务数量:1
李四的任务:name:HR面,id:316
李四的任务数量:0
***************HR面流程结束***************
***************录用流程开始***************
技术部的任务:name:录用,发放Offer,id:319
李四的任务数量:1
李四的任务:name:录用,发放Offer,id:319
李四的任务数量:0
***************录用流程结束***************
流程结束时间:Tue May 15 17:44:26 CST 2012
至此,该项目结束,项目源码放在附件中。
- 大小: 10.9 KB
- 大小: 11.8 KB
- 大小: 10.6 KB
- 大小: 32.1 KB
- 大小: 16.7 KB
- 大小: 18.8 KB
- 大小: 10.4 KB
分享到:
相关推荐
Activiti学习笔记,介绍Activiti的组成结构,工作流BPMN2.0规范等
Activiti 学习笔记五:流程变量
Activiti5学习笔记
Activiti 学习笔记九:并行网关(parallelGateWay)
Activiti 学习笔记八:排他网关(ExclusiveGateWay)
Activiti 学习笔记13:分配组任务
Activiti学习笔记三:管理流程定义
Activiti 学习笔记六:流程执行历史记录
Activiti 学习笔记12:个人任务
Activiti 学习笔记七:连线(SequenceFlow)
Activiti 学习笔记14:工作流定义的角色组
Activiti 学习笔记十:开始活动节点(判断流程是否结束及查询历史)
Activiti 学习笔记11:接收活动(receiveTask,即等待活动)
Activiti 学习笔记四:流程实例、任务的执行
activiti5学习笔记.pdf
NULL 博文链接:https://json20080301.iteye.com/blog/1534903
包括:Activiti5的10分钟入门指南(转载);Activiti5学习笔记;Activiti5与SSH的整合笔记。
包括学习笔记 新手必看不适用与高手.以及activiti实战前几章内容