标签：
一、新建工程，导入相应的jar包，建议用maven做jar包的依赖管理。maven依赖部分代码如下：
<dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.11</version> <scope>test</scope> </dependency> <!--activiti的核心jar包，其相关依赖jar包会一并导入--> <dependency> <groupId>org.activiti</groupId> <artifactId>activiti-engine</artifactId> <version>5.18.0</version> </dependency> <!--h2内存数据库的jar包，本文的例子用的是h2数据库，基于内存模式，方便测试--> <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <version>1.3.176</version> </dependency> </dependencies>
二、流程文件，测试中用到的两个流程文件，放到合适的目录下，一般是resources目录下，至于如何生成流程文件，请参照相关资料：
MyProcess.bpmn20.xml
<?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="myProcess" name="My process" isExecutable="true"> <startEvent id="startevent1" name="Start"></startEvent> <userTask id="usertask1" name="User Task"></userTask> <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow> <endEvent id="endevent1" name="End"></endEvent> <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow> </process> </definitions>
这是一个最简单的流程，流程图如下：
2. pool.bpmn
<?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">
<collaboration id="Collaboration">
<participant id="pool1" name="请假流程" processRef="process_pool1"></participant>
</collaboration>
<process id="process_pool1" name="process_pool1" isExecutable="true">
<laneSet id="laneSet_process_pool1">
<lane id="lane1" name="员工">
<flowNodeRef>startevent1</flowNodeRef>
<flowNodeRef>usertask1</flowNodeRef>
<flowNodeRef>usertask4</flowNodeRef>
<flowNodeRef>endevent1</flowNodeRef>
<flowNodeRef>exclusivegateway3</flowNodeRef>
</lane>
<lane id="lane2" name="领导">
<flowNodeRef>usertask2</flowNodeRef>
<flowNodeRef>exclusivegateway1</flowNodeRef>
</lane>
<lane id="lane3" name="人事">
<flowNodeRef>usertask3</flowNodeRef>
<flowNodeRef>exclusivegateway2</flowNodeRef>
</lane>
</laneSet>
<startEvent id="startevent1" name="Start" activiti:initiator="applyUserId">
<extensionElements>
<activiti:formProperty id="startDate" name="请假开始日期" type="date" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
<activiti:formProperty id="endDate" name="请假结束日期" type="date" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
<activiti:formProperty id="reason" name="请假原因" type="string" required="true"></activiti:formProperty>
</extensionElements>
</startEvent>
<userTask id="usertask1" name="调整申请" activiti:assignee="${applyUserId}">
<extensionElements>
<activiti:formProperty id="startDate" name="请假开始日期" type="date" value="${startDate}" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
<activiti:formProperty id="endDate" name="请假结束日期" type="date" value="${endDate}" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
<activiti:formProperty id="reason" name="请假原因" type="string" value="${reason}" required="true"></activiti:formProperty>
<activiti:formProperty id="reApply" name="重新申请" type="enum" required="true">
<activiti:value id="true" name="重新申请"></activiti:value>
<activiti:value id="false" name="取消申请"></activiti:value>
</activiti:formProperty>
</extensionElements>
</userTask>
<sequenceFlow id="flow2" name="提交申请" sourceRef="startevent1" targetRef="usertask2"></sequenceFlow>
<userTask id="usertask2" name="领导审批" activiti:candidateGroups="deptLeader">
<extensionElements>
<activiti:formProperty id="startDate" name="请假开始日期" type="date" value="${startDate}" datePattern="yyyy-MM-dd" writable="false"></activiti:formProperty>
<activiti:formProperty id="endDate" name="请假结束日期" type="date" value="${endDate}" datePattern="yyyy-MM-dd" writable="false"></activiti:formProperty>
<activiti:formProperty id="reason" name="请假原因" type="string" value="${reason}" writable="false"></activiti:formProperty>
<activiti:formProperty id="deptLeaderApprove" name="审批意见" type="enum" required="true">
<activiti:value id="true" name="同意"></activiti:value>
<activiti:value id="false" name="拒绝"></activiti:value>
</activiti:formProperty>
</extensionElements>
</userTask>
<exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway"></exclusiveGateway>
<sequenceFlow id="flow3" sourceRef="usertask2" targetRef="exclusivegateway1"></sequenceFlow>
<sequenceFlow id="flow4" name="同意" sourceRef="exclusivegateway1" targetRef="usertask3">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${deptLeaderApprove==‘true‘}]]></conditionExpression>
</sequenceFlow>
<userTask id="usertask3" name="人事审批" activiti:candidateGroups="hr">
<extensionElements>
<activiti:formProperty id="startDate" name="请假开始日期" type="date" value="${startDate}" datePattern="yyyy-MM-dd" writable="false"></activiti:formProperty>
<activiti:formProperty id="endDate" name="请假结束日期" type="date" value="${endDate}" datePattern="yyyy-MM-dd" writable="false"></activiti:formProperty>
<activiti:formProperty id="reason" name="请假原因" type="string" value="${reason}" writable="false"></activiti:formProperty>
<activiti:formProperty id="hrApprove" name="审批意见" type="enum" required="true">
<activiti:value id="true" name="同意"></activiti:value>
<activiti:value id="false" name="拒绝"></activiti:value>
</activiti:formProperty>
</extensionElements>
</userTask>
<sequenceFlow id="flow6" name="不同意" sourceRef="exclusivegateway1" targetRef="usertask1">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${deptLeaderApprove==‘false‘}]]></conditionExpression>
</sequenceFlow>
<exclusiveGateway id="exclusivegateway2" name="Exclusive Gateway"></exclusiveGateway>
<sequenceFlow id="flow7" sourceRef="usertask3" targetRef="exclusivegateway2"></sequenceFlow>
<sequenceFlow id="flow8" name="同意" sourceRef="exclusivegateway2" targetRef="usertask4">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrApprove==‘true‘}]]></conditionExpression>
</sequenceFlow>
<userTask id="usertask4" name="销假" activiti:assignee="${applyUserId}">
<extensionElements>
<activiti:formProperty id="startDate" name="请假开始日期" type="date" value="${startDate}" datePattern="yyyy-MM-dd" writable="false"></activiti:formProperty>
<activiti:formProperty id="endDate" name="请假结束日期" type="date" value="${endDate}" datePattern="yyyy-MM-dd" writable="false"></activiti:formProperty>
<activiti:formProperty id="reason" name="请假原因" type="string" value="${reason}" writable="false"></activiti:formProperty>
<activiti:formProperty id="reportBackDate" name="销假日期" type="date" default="${endDate}" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
</extensionElements>
</userTask>
<sequenceFlow id="flow9" name="不同意" sourceRef="exclusivegateway2" targetRef="usertask1">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrApprove==‘false‘}]]></conditionExpression>
</sequenceFlow>
<endEvent id="endevent1" name="End"></endEvent>
<sequenceFlow id="flow10" sourceRef="usertask4" targetRef="endevent1">
<extensionElements>
<activiti:executionListener event="take" expression="${execution.setVariable(‘result‘,‘OK‘)}"></activiti:executionListener>
</extensionElements>
</sequenceFlow>
<sequenceFlow id="flow11" name="继续提交申请" sourceRef="exclusivegateway3" targetRef="usertask2">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${reApply==‘true‘}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow12" name="取消申请" sourceRef="exclusivegateway3" targetRef="endevent1">
<extensionElements>
<activiti:executionListener event="take" expression="${execution.setVariable(‘result‘,‘canceled‘)}"></activiti:executionListener>
</extensionElements>
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${reApply==‘false‘}]]></conditionExpression>
</sequenceFlow>
<exclusiveGateway id="exclusivegateway3" name="Exclusive Gateway"></exclusiveGateway>
<sequenceFlow id="flow13" sourceRef="usertask1" targetRef="exclusivegateway3"></sequenceFlow>
</process>
</definitions>
这是一个请假流程，流程图如下：
三、用于测试的java代码，采用junit方式运行：
package com.wangtl.activiti;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.activiti.engine.FormService;
import org.activiti.engine.HistoryService;
import org.activiti.engine.IdentityService;
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.HistoricDetail;
import org.activiti.engine.history.HistoricFormProperty;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.history.HistoricVariableInstance;
import org.activiti.engine.history.HistoricVariableUpdate;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;
public class VerySimpleLeaveProcessTest {
@Test
public void testProcessDefinition() throws Exception{
// 创建 Activiti流程引擎
ProcessEngine processEngine=
ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration()
.buildProcessEngine();
// 取得 Activiti 服务
RepositoryService repositoryService=processEngine.getRepositoryService();
// 部署流程定义
Deployment deploy=repositoryService.createDeployment().addClasspathResource("MyProcess.bpmn20.xml").deploy();
ProcessDefinition processDefinition=repositoryService.createProcessDefinitionQuery().deploymentId(deploy.getId())
.singleResult();
System.out.println(processDefinition.getKey());
// 启动流程实例
RuntimeService runtimeService=processEngine.getRuntimeService();
ProcessInstance processInstance=runtimeService.startProcessInstanceByKey(processDefinition.getKey());
System.out.println("pid="+processInstance.getId()+",pdid="+
processInstance.getProcessDefinitionId());
}
@Test
public void testStartProcess() throws Exception{
// 1.创建 Activiti流程引擎（此处使用的是h2数据库，并启用的是内存模式，即数据保存在内存中，程序运行完数据就丢失）
ProcessEngine processEngine=
ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration()
.buildProcessEngine();
// 2.部署流程定义
//取得 Activiti 服务
RepositoryService repositoryService=processEngine.getRepositoryService();
//获得流程定义的相关数据
String fileName="E:/workspace/activiti-demo/src/main/resources/MyProcess.bpmn20.xml";
File f =new File(fileName);
InputStream fileInputStream = new FileInputStream(f);
//创建Deployment，同时部署流程定义
repositoryService.createDeployment()
.addInputStream(fileName, fileInputStream)
.deploy();
//查看定义的流程（非必须，只是验证流程定义是否部署成功）
ProcessDefinition processDefinition=repositoryService.createProcessDefinitionQuery()
.singleResult();
System.out.println("流程定义文件的key为："+processDefinition.getKey());
// 3.启动流程实例
RuntimeService runtimeService=processEngine.getRuntimeService();
ProcessInstance processInstance=runtimeService.startProcessInstanceByKey(processDefinition.getKey());
System.out.println("流程实例的id="+processInstance.getId()+",流程实例的definitionId="+
processInstance.getProcessDefinitionId());
//4.取得当前任务
//获得任务服务
TaskService taskService=processEngine.getTaskService();
//取得当前任务(由于流程定义中没有指明任务指派给谁，所以这里不用申明任务由谁获得)
Task task=taskService.createTaskQuery().singleResult();
System.out.println("当前任务的名称是："+task.getName());
//5.认领任务（由于流程定义中没有指明任务指派给谁，任何人都可以认领该任务，如这里的“leaderUser”）
taskService.claim(task.getId(), "leaderUser");
//查看"leaderUser"现在是否能够获取到该任务(非必须)
task=taskService.createTaskQuery().taskAssignee("leaderUser").singleResult();
System.out.println("认领任务的人是："+task.getAssignee());
//6.完成任务
taskService.complete(task.getId());
//以下是验证任务是否完成，通过重新查找任务（为空），查询历史记录（有），说明之前的任务完成了(非必须)
task=taskService.createTaskQuery().singleResult();
System.out.println("当前的任务是："+task);
HistoryService historyService=processEngine.getHistoryService();
long count=historyService.createHistoricProcessInstanceQuery().finished().count();
System.out.println("已完成的任务数是："+count);
}
@Test
public void testStartProcess2() throws Exception{
// 1.创建 Activiti流程引擎（此处使用的是h2数据库，并启用的是内存模式，即数据保存在内存中，程序运行完数据就丢失）
ProcessEngine processEngine=
ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration()
// .setHistory("full")
.buildProcessEngine();
// 2.部署流程定义
//取得 Activiti 服务
RepositoryService repositoryService=processEngine.getRepositoryService();
//获得流程定义的相关数据
String fileName="E:/workspace/activiti-demo/src/main/resources/pool.bpmn";
File f =new File(fileName);
InputStream fileInputStream = new FileInputStream(f);
//创建Deployment，同时部署流程定义
repositoryService.createDeployment()
.addInputStream(fileName, fileInputStream)
.deploy();
//查看定义的流程（非必须，只是验证流程定义是否部署成功）
ProcessDefinition processDefinition=repositoryService.createProcessDefinitionQuery()
.processDefinitionKey("process_pool1")
.singleResult();
System.out.println("流程定义文件的key为："+processDefinition.getKey());
//设置当前用户
String currentUserId="hen";
IdentityService identityService=processEngine.getIdentityService();
identityService.setAuthenticatedUserId(currentUserId);
//设置表单变量
SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
Map<String,String> variables =new HashMap<String,String>();
Calendar ca=Calendar.getInstance();
String startDate = sdf.format(ca.getTime());
ca.add(Calendar.DAY_OF_MONTH, 2);
String endDate=sdf.format(ca.getTime());
variables.put("startDate", startDate);
variables.put("endDate", endDate);
variables.put("reason", "年假");
// 3.当前用户启动流程实例（类似RuntimeService，只是这里带上了表单数据）
FormService formService=processEngine.getFormService();
ProcessInstance processInstance=
formService.submitStartFormData(processDefinition.getId(), variables);
System.out.println("流程实例的id="+processInstance.getId()+",流程实例的definitionId="+
processInstance.getProcessDefinitionId());
//取得deptLeader的任务
TaskService taskService=processEngine.getTaskService();
Task leaderTask=taskService.createTaskQuery().taskCandidateGroup("deptLeader").singleResult();
System.out.println("当前任务的名称是："+leaderTask.getName());
//审批当前任务（类似于TaskService的complete）
variables=new HashMap<String,String>();
variables.put("deptLeaderApprove", "true");
formService.submitTaskFormData(leaderTask.getId(), variables);
//取得hr的任务
Task hrTask=taskService.createTaskQuery().taskCandidateGroup("hr").singleResult();
System.out.println("当前任务的名称是："+hrTask.getName());
//审批当前任务（类似于TaskService的complete）
variables=new HashMap<String,String>();
variables.put("hrApprove", "true");
formService.submitTaskFormData(hrTask.getId(), variables);
//取得用户的销假任务
Task reportBackTask=taskService.createTaskQuery().taskAssignee(currentUserId).singleResult();
//提交任务
variables=new HashMap<String,String>();
variables.put("reportBackDate", endDate);
formService.submitTaskFormData(reportBackTask.getId(),variables);
//以下是验证流程是否结束（非必须）
HistoryService historyService=processEngine.getHistoryService();
HistoricProcessInstance historicProcessInstance=historyService
.createHistoricProcessInstanceQuery().finished().singleResult();
System.out.println("已执行的流程id："+historicProcessInstance.getId());
Map<String,Object> historyVariables=packageVariables(historyService,processInstance);
System.out.println(historyVariables.get("result"));
}
private Map<String,Object> packageVariables(HistoryService historyService,ProcessInstance processInstance){
Map<String,Object> historyVariables=new HashMap<String,Object>();
//在保存表单字段的同时会复制一份经过类型转换的值，并以字段的ID为变量名保存到数据库中，当然前提是要设置引擎的“history”属性为“full”级别
/*List<HistoricDetail> list=
historyService.createHistoricDetailQuery().processInstanceId(processInstance.getId()).list();
System.out.println("历史记录数"+list.size());
for(HistoricDetail historicDetail:list){
if(historicDetail instanceof HistoricFormProperty){
HistoricFormProperty field=(HistoricFormProperty) historicDetail;
historyVariables.put(field.getPropertyId(), field.getPropertyValue());
System.out.println("form field: taskId="+field.getTaskId()+", "
+field.getPropertyId()+"="+field.getPropertyValue());
}else if(historicDetail instanceof HistoricVariableUpdate){
HistoricVariableUpdate variable=(HistoricVariableUpdate) historicDetail;
historyVariables.put(variable.getVariableName(),variable.getValue());
System.out.println("variable: "+variable.getVariableName()+"="+variable.getValue());
}
}*/
/* 查询所有保存的变量:5.11版本之后，从表act_hi_varinst*/
List<HistoricVariableInstance> list =
historyService.createHistoricVariableInstanceQuery().processInstanceId(processInstance.getId()).list();
for (HistoricVariableInstance variable : list)
{
historyVariables.put(variable.getVariableName(),variable.getValue());
System.out.println("variable: " + variable.getVariableName() + " = " + variable.getValue());
}
/* 只读取表单变量:从表act_hi_detail*/
/*List<HistoricDetail> formProperties =
historyService.createHistoricDetailQuery().processInstanceId(processInstance.getId())
.formProperties().list();
for (HistoricDetail historicDetail : formProperties) {
HistoricFormProperty field = (HistoricFormProperty) historicDetail;
historyVariables.put(field.getPropertyId(), field.getPropertyValue());
System.out.println("field id: " + field.getPropertyId() + ", value: " + field.getPropertyValue());
} */
return historyVariables;
}
}标签：
原文地址：http://my.oschina.net/wangrikui/blog/506338
