Activiti核心配置文件，配置流程引擎创建工具的基本参数和数据库连接池参数。

定义数据库配置参数：

4) 回到Install界面，在面板正中列表中把所有展示出来的项目都勾上：

5) 点击复选框

在Detail部分记得选中 “Contact all updates sites..” , 因为它会检查所有当前安装所需要的插件并可以被Eclipse下载.

6) 安装完以后，点击新建工程new->Other…打开面板，如果看到下图内容：

说明安装成功了。

4.4：对流程设计器的使用说明

打开菜单Windows->Preferences->Activiti->Save下流程流程图片的生成方式:

虽然流程引擎在单独部署bpmn文件时会自动生成图片，但在实际开发过程中，自动生成的图片会导致和BPMN中的坐标有出入，在实际项目中展示流程当前位置图会有问题。

所在完成以上配置后，会由我们自己来管理流程图片。在发布流程时把流程规则文件和流程图片一起上传就行了。

4.5：准备Activiti5开发环境

4.5.1：添加Activiti5的jar包

在activiti-5.13->wars目录下是一些示例项目，解压activiti-rest项目，导入activiti-rest目录中WEB-INF\lib下所有包。添加到classpath中。

由于我们使用的是Mysql数据库，Mysql数据库的链接驱动Activiti官方包中并没有提供，需要我们自己导入。手动导入mysql-connector-java.jar，添加到classpath下。

4.5.2：初始化数据库

  在Activiti中，在创建核心的流程引擎对象时会自动建表。如果程序正常执行，mysql会自动建库，然后创建23张表。

4.5.3：添加并制定配置文件

在Actiiti5中定制流程必定会操作到数据库，如果都像上面那样写一大段代码会非常麻烦，所以我们可以把数据库连接配置写入配置文件。

在Activiti5的官方示例中并没有现成的配置文件，所以先得找到activiti-rest\WEB-INF\classes下有：

4.5.3.1：activiti-context.xml：

一个类似spring结构的配置文件，清空内容后改名为activiti.cfg.xml，用来做流程引擎的相关配置。

按照上面代码配置ProcessEngineConfiguration对象，主要定义数据库的连接配置和建表策略，配置文件代码如下：

Java代码如下：

createProcessEngineConfigurationFromResource的参数值为我们添加的配置文件activiti.cfg.xml的名称，执行java代码，流程引擎对象创建成功运行后数据库会自动建表。

4.5.3.2：log4j.properties日志配置文件

把两个文件放入resource目录下即可。

5：核心API

5.1：ProcessEngine

说明：

1) 在Activiti中最核心的类，其他的类都是由他而来。

2) 产生方式：

7.1.2：bpmn文件

    BPMN 2.0根节点是definitions节点。 这个元素中，可以定义多个流程定义（不过我们建议每个文件只包含一个流程定义， 可以简化开发过程中的维护难度）。 一个空的流程定义看起来像下面这样。注意，definitions元素 最少也要包含xmlns 和 targetNamespace的声明。 targetNamespace可以是任意值，它用来对流程实例进行分类。

说明：流程定义文档有两部分组成：

1) bpmn文件

流程规则文件。在部署后，每次系统启动时都会被解析，把内容封装成流程定义放入项目缓存中。Activiti框架结合这个xml文件自动管理流程，流程的执行就是按照bpmn文件定义的规则执行的，bpmn文件是给计算机执行用的。

2) 展示流程图的图片

在系统里需要展示流程的进展图片，图片是给用户看的。

7.2：部署流程定义（classpath路径加载文件）

/**

 * ReceiceTask任务，机器自动完成的任务

 * 只会在act_ru_execution表中产生一条数据

 * @throws Exception

 */

@Test

public void testExecution()throws Exception {

// 1发布流程

InputStream inputStreamBpmn = this.getClass().getResourceAsStream(“receiveTask.bpmn”);

InputStream inputStreamPng = this.getClass().getResourceAsStream(“receiveTask.png”);

processEngine.getRepositoryService()//

.createDeployment()//

.addInputStream(“receiveTask.bpmn”, inputStreamBpmn)//

.addInputStream(“receiveTask.png”, inputStreamPng)//

.deploy();

// 2启动流程

ProcessInstance pi = processEngine.getRuntimeService()//

.startProcessInstanceByKey(“receiveTaskDemo”);

System.out.println(“pid:” + pi.getId());

String pid = pi.getId();

// 3查询是否有一个执行对象在描述”汇总当日销售额“

Execution e1 = processEngine.getRuntimeService()//

.createExecutionQuery()//

.processInstanceId(pid)//

.activityId(“汇总当日销售额“)//

.singleResult();

// 4执行一堆逻辑，并设置流程变量

Map<String,Object> vars = new HashMap<String, Object>();

vars.put(“当日销售额“, 10000);

// 5流程向后执行一步：往后推移e1,使用signal给流程引擎信号，告诉他当前任务已经完成了，可以往后执行

processEngine.getRuntimeService()

.signal(e1.getId(),vars);

// 6判断当前流程是否在”给老板发短信“节点

Execution e2 = processEngine.getRuntimeService()//

.createExecutionQuery()//

.processInstanceId(pid)//

.activityId(“给总经理发短信“)//

.singleResult();

// 7获取流程变量

Integer money = (Integer) processEngine.getRuntimeService()//

.getVariable(e2.getId(), “当日销售额“);

System.out.println(“老板，今天赚了“ +money);

// 8向后执行一步：任务完成，往后推移”给老板发短信“任务

processEngine.getRuntimeService()//

.signal(e2.getId());

// 9查询流程状态

    pi = processEngine.getRuntimeService()//

     .createProcessInstanceQuery()//

     .processInstanceId(pid)//

     .singleResult();

    if(pi==null){

         System.out.println(“流程正常执行！！！，已经结束了“);

    }

}

说明：

1） 当前任务（一般指机器自动完成，但需要耗费一定时间的工作）完成后，向后推移流程，可以调用runtimeService.signal(executionId)，传递接收执行对象的id。

16：用户任务（userTask，即用户操作的任务）

16.1：个人任务

16.1.1：流程图

16.1.2:：分配个人任务方式一（直接指定办理人）

1：流程图中任务节点的配置

2：测试代码：

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

//部署流程定义，启动流程实例

@Test

public void testTask()throws Exception {

// 1 发布流程

InputStream inputStreamBpmn = this.getClass().getResourceAsStream(“taskProcess.bpmn”);

InputStream inputStreamPng = this.getClass().getResourceAsStream(“taskProcess.png”);

processEngine.getRepositoryService()//

.createDeployment()//

.addInputStream(“userTask.bpmn”, inputStreamBpmn)//

.addInputStream(“userTask.png”, inputStreamPng)//

.deploy();

// 2 启动流程

//启动流程实例的同时，设置流程变量

ProcessInstance pi = processEngine.getRuntimeService()//

.startProcessInstanceByKey(“taskProcess”);

System.out.println(“pid:” + pi.getId());

}

//查询我的个人任务列表

@Test

public void findMyTaskList(){

String userId = “张三丰“;

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskAssignee(userId)//指定个人任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“createTime=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

}

}

//完成任务

@Test

public void completeTask(){

String taskId = “3209”;

processEngine.getTaskService()//

.complete(taskId);//

System.out.println(“完成任务“);

}

说明：

1） 张三丰是个人任务的办理人

2） 但是这样分配任务的办理人不够灵活，因为项目开发中任务的办理人不要放置XML文件中。

16.1.3:：分配个人任务方式二（使用流程变量）

1：流程图中任务节点的配置

2：测试代码

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

//部署流程定义，启动流程实例

@Test

public void testTask()throws Exception {

// 1发布流程

InputStream inputStreamBpmn =this.getClass().getResourceAsStream(“taskProcess.bpmn”);

InputStream inputStreamPng =this.getClass().getResourceAsStream(“taskProcess.png”);

processEngine.getRepositoryService()//

.createDeployment()//

.addInputStream(“userTask.bpmn”, inputStreamBpmn)//

.addInputStream(“userTask.png”, inputStreamPng)//

.deploy();

// 2启动流程

//启动流程实例的同时，设置流程变量

Map<String, Object> variables =new HashMap<String, Object>();

variables.put(“userID”,“张翠三“);

ProcessInstance pi = processEngine.getRuntimeService()//

.startProcessInstanceByKey(“taskProcess”,variables);

System.out.println(“pid:” + pi.getId());

}

//查询我的个人任务列表

@Test

public void findMyTaskList(){

String userId = “张翠三“;

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskAssignee(userId)//指定个人任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“createTime=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

}

}

//完成任务

@Test

public void completeTask(){

String taskId = “3209”;

processEngine.getTaskService()//

.complete(taskId);//

System.out.println(“完成任务“);

}

说明：

1） 张翠山是个人任务的办理人

2） 在开发中，可以在页面中指定下一个任务的办理人，通过流程变量设置下一个任务的办理人

16.1.4:：分配个人任务方式三（使用类）

1：流程图中任务节点的配置

此时流程图的XML文件，如图：

2：TaskListenerImpl类，用来设置任务的办理人

public class TaskListenerImplimplements TaskListener {

/**指定个人任务和组任务的办理人*/

@Override

public void notify(DelegateTask delegateTask) {

String assignee = “张无忌“;

//指定个人任务

delegateTask.setAssignee(assignee);

}

}

3：测试代码

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

//部署流程定义，启动流程实例

@Test

public void testTask()throws Exception {

// 1 发布流程

InputStream inputStreamBpmn = this.getClass().getResourceAsStream(“taskProcess.bpmn”);

InputStream inputStreamPng = this.getClass().getResourceAsStream(“taskProcess.png”);

processEngine.getRepositoryService()//

.createDeployment()//

.addInputStream(“userTask.bpmn”, inputStreamBpmn)//

.addInputStream(“userTask.png”, inputStreamPng)//

.deploy();

// 2 启动流程

ProcessInstance pi = processEngine.getRuntimeService()//

.startProcessInstanceByKey(“taskProcess”);

System.out.println(“pid:” + pi.getId());

}

//查询我的个人任务列表

@Test

public void findMyTaskList(){

String userId = “张无忌“;

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskAssignee(userId)//指定个人任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“createTime=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

}

}

//完成任务

@Test

public void completeTask(){

String taskId = “3408”;

processEngine.getTaskService()//

.complete(taskId);//

System.out.println(“完成任务“);

}

//可以分配个人任务从一个人到另一个人（认领任务）

@Test

public void setAssigneeTask(){

//任务ID

String taskId = “3408”;

//指定认领的办理者

String userId = “周芷若“;

processEngine.getTaskService()//

.setAssignee(taskId, userId);

}

说明：

1） 在类中使用delegateTask.setAssignee(assignee);的方式分配个人任务的办理人，此时张无忌是下一个任务的办理人

2） 通过processEngine.getTaskService().setAssignee(taskId, userId);将个人任务从一个人分配给另一个人，此时张无忌不再是下一个任务的办理人，而换成了周芷若

3） 在开发中，可以将每一个任务的办理人规定好，例如张三的领导是李四，李四的领导是王五，这样张三提交任务，就可以查询出张三的领导是李四，通过类的方式设置下一个任务的办理人

16.1.5：总结

个人任务及三种分配方式：

    1：在taskProcess.bpmn中直接写 assignee=“张三丰”

    2：在taskProcess.bpmn中写 assignee=“#{userID}”，变量的值要是String的。

         使用流程变量指定办理人

    3，使用TaskListener接口，要使类实现该接口，在类中定义：

         delegateTask.setAssignee(assignee);// 指定个人任务的办理人

 使用任务ID和办理人重新指定办理人：

     processEngine.getTaskService()//

                           .setAssignee(taskId, userId);

16.2：组任务

16.2.1：流程图

16.2.3:：分配个人任务方式二（使用流程变量）

1：流程图中任务节点的配置

2：测试代码

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

//部署流程定义，启动流程实例

@Test

public void testTask()throws Exception {

// 1 发布流程

InputStream inputStreamBpmn = this.getClass().getResourceAsStream(“taskProcess.bpmn”);

InputStream inputStreamPng = this.getClass().getResourceAsStream(“taskProcess.png”);

processEngine.getRepositoryService()//

.createDeployment()//

.addInputStream(“userTask.bpmn”, inputStreamBpmn)//

.addInputStream(“userTask.png”, inputStreamPng)//

.deploy();

// 2启动流程

//启动流程实例，同时设置流程变量，用来指定组任务的办理人

Map<String, Object> variables = new HashMap<String, Object>();

variables.put(“userIDs”,“大大,小小,中中“);

ProcessInstance pi = processEngine.getRuntimeService()//

.startProcessInstanceByKey(“taskProcess”,variables);

System.out.println(“pid:” + pi.getId());

}

//查询我的个人任务列表

@Test

public void findMyTaskList(){

String userId = “大大“;

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskAssignee(userId)//指定个人任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“assinee=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

}

}

//查询组任务列表

@Test

public void findGroupList(){

String userId = “大大“;

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskCandidateUser(userId)//指定组任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“assinee=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

System.out.println(“##################################”);

}

}

//查询组任务成员列表

@Test

public void findGroupUser(){

String taskId = “3709”;

List<IdentityLink> list = processEngine.getTaskService()//

                .getIdentityLinksForTask(taskId);

for(IdentityLink identityLink:list ){

System.out.println(“userId=”+identityLink.getUserId());

System.out.println(“taskId=”+identityLink.getTaskId());

System.out.println(“piId=”+identityLink.getProcessInstanceId());

System.out.println(“######################”);

}

}

//查询组任务成员历史列表

@Test

public void findGroupHisUser(){

String taskId = “3709”;

List<HistoricIdentityLink> list = processEngine.getHistoryService()//

.getHistoricIdentityLinksForTask(taskId);

for(HistoricIdentityLink identityLink:list ){

System.out.println(“userId=”+identityLink.getUserId());

System.out.println(“taskId=”+identityLink.getTaskId());

System.out.println(“piId=”+identityLink.getProcessInstanceId());

System.out.println(“######################”);

}

}

//完成任务

@Test

public void completeTask(){

String taskId = “3709”;

processEngine.getTaskService()//

.complete(taskId);//

System.out.println(“完成任务“);

}

     /**将组任务分配给个人任务，拾取任务*/

//由1个人去完成任务

@Test

public void claim(){

//任务ID

String taskId = “5908”;

//分配的办理人

String userId = “小B”;

processEngine.getTaskService()//

.claim(taskId, userId);

}

说明：

1） 大大，中中，小小是组任务的办理人

2） 在开发中，可以在页面中指定下一个组任务的办理人，通过流程变量设置下一个任务的办理人

16.2.4:：分配个人任务方式三（使用类）

1：流程图中任务节点的配置

此时流程图的XML文件，如图：

流程图中任务节点的配置：

分配任务负责的组

使用 candidate groups 属性指定 任务负责组

代码： 

<userTask id=“usertask1” name=“审批” activiti:candidateGroups=“部门经理”>

</userTask>    

其中部门经理表示一个用户组的角色

16.3.2：测试代码

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

//部署流程定义，启动流程实例

@Test

public void testTask()throws Exception {

// 1 发布流程

InputStream inputStreamBpmn = this.getClass().getResourceAsStream(“taskProcess.bpmn”);

InputStream inputStreamPng = this.getClass().getResourceAsStream(“taskProcess.png”);

processEngine.getRepositoryService()//

.createDeployment()//

.addInputStream(“userTask.bpmn”, inputStreamBpmn)//

.addInputStream(“userTask.png”, inputStreamPng)//

.deploy();

/**在部署流程定义和启动流程实例的中间，设置组任务的办理人，向Activity表中存放组和用户的信息*/

IdentityService identityService = processEngine.getIdentityService();//认证：保存组和用户信息

identityService.saveGroup(new GroupEntity(“部门经理“));//建立组

identityService.saveGroup(new GroupEntity(“总经理“));//建立组

identityService.saveUser(new UserEntity(“小张“));

identityService.saveUser(new UserEntity(“小李“));

identityService.saveUser(new UserEntity(“小王“));

identityService.createMembership(“小张“, “部门经理“);//建立组和用户关系

identityService.createMembership(“小李“, “部门经理“);//建立组和用户关系

identityService.createMembership(“小王“, “总经理“);//建立组和用户关系

// 2 启动流程

ProcessInstance pi = processEngine.getRuntimeService()//

.startProcessInstanceByKey(“taskProcess”);

System.out.println(“pid:” + pi.getId());

}

//查询我的个人任务列表

@Test

public void findMyTaskList(){

String userId = “唐僧“;

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskAssignee(userId)//指定个人任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“assinee=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

}

}

//查询组任务列表

@Test

public void findGroupList(){

String userId = “小李“;//小张，小李可以查询结果，小王不可以，因为他不是部门经理

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskCandidateUser(userId)//指定组任务查询

                .list();

for(Task task:list ){

System.out.println(“id=”+task.getId());

System.out.println(“name=”+task.getName());

System.out.println(“assinee=”+task.getAssignee());

System.out.println(“assinee=”+task.getCreateTime());

System.out.println(“executionId=”+task.getExecutionId());

System.out.println(“##################################”);

}

}

//查询组任务成员列表

@Test

public void findGroupUser(){

String taskId = “4408”;

List<IdentityLink> list = processEngine.getTaskService()//

                .getIdentityLinksForTask(taskId);

for(IdentityLink identityLink:list ){

System.out.println(“userId=”+identityLink.getUserId());

System.out.println(“taskId=”+identityLink.getTaskId());

System.out.println(“piId=”+identityLink.getProcessInstanceId());

System.out.println(“######################”);

}

}

//完成任务

@Test

public void completeTask(){

String taskId = “5108”;

processEngine.getTaskService()//

.complete(taskId);//

System.out.println(“完成任务“);

}

}

16.3.3：分配任务负责的组(IdentityService)

/**在部署流程定义和启动流程实例的中间，设置组任务的办理人，向Activiti表中存放组和用户的信息*/

IdentityService identityService = processEngine.getIdentityService();//认证：保存组和用户信息

identityService.saveGroup(new GroupEntity(“部门经理”));//建立组

identityService.saveGroup(new GroupEntity(“总经理”));//建立组

identityService.saveUser(new UserEntity(“小张”));//建立用户

identityService.saveUser(new UserEntity(“小李”)); //建立用户

identityService.saveUser(new UserEntity(“小王”)); //建立用户

identityService.createMembership(“小张”, “部门经理”);//建立组和用户关系

identityService.createMembership(“小李”, “部门经理”);//建立组和用户关系

identityService.createMembership(“小王”, “总经理”);//建立组和用户关系

表结构介绍

act_id_group：角色组表

act_id_user：用户表：

act_id_membership：用户角色表

指定组任务的办理人，查询组任务

String userId = “小张”;//小张，小李可以查询结果，小王不可以，因为他不是部门经理角色

List<Task> list = processEngine.getTaskService()//

                .createTaskQuery()//

                .taskCandidateUser(userId)//指定组任务查询

                .list();

Activiti总结：