Activiti7

什么是工作流

工作流

可以理解为：工作的一个流程，事物发展的一个业务流程

比如说请假流程:

graph LR
  A[员工申请] --> B[部门经理]
  B --> C[总经理]
  C --> D[人事存档]

在传统方式下，主要通过请假条的传递来实现

无纸化办公，通过线上申请的方式去实现

在计算机的帮助下，能够实现流程的自动化控制，就称为工作流

工作流引擎

为了实现自动化控制，Activiti引擎就产生了。

作用：实现流程自动化控制

工作流系统

具有工作流的系统，详细解释为：如果一个系统具备流程的自动化管理功能，这个系统就可以称为工作流系统

流程自动化实现方式

程序员编码来实现

拿上面的请假流程来说，有一个流程表，存在以下字段

工号
部门号
姓名
日期
天数
原因
状态（0：未提交 1：提交）

针对状态字段去控制流程所处的阶段

员工：0：未提交 1：提交

部门经理：

先去查询：查询条件为：部门号 = 部门经理的部门号，状态=1
2：同意 3：不同意

总经理：

先去查询：查询条件为：状态 = 2
4：同意 5：不同意

人事存档：

查询条件：状态=4
6：同意 7：不同意

弊端：业务流程变更后，程序不能使用

解决方式:Activiti就可以实现业务流程变化后，程序代码不需要改动，更新的是业务流程图

适用行业

消费品行业，制造业，电信服务业，银证险等金融服务业，物流服务业，物业服务业，物业管理，大中型进出口贸易公司，政府事业机构，研究院所及教育服务业等，特别是大的跨国企业和集团公司

具体应用

关键业务流程：订单、报价处理、合同审核、客户电话处理、供应链管理等
行政管理类:出差申请、加班申请、请假申请、用车申请、各种办公用品申请、购买申请、日报周报等凡是原来手工流转处理的行政表单。
人事管理类：员工培训安排、绩效考评、职位变动处理、员工档案信息管理等。
财务相关类：付款请求、应收款处理、日常报销处理、出差报销、预算和计划申请等。
客户服务类：客户信息管理、客户投诉、请求处理、售后服务管理等。
特殊服务类：ISO 系列对应流程、质量管理对应流程、产品数据信息管理、贸易公司报关处理、物流公司货物跟踪处理等各种通过表单逐步手工流转完成的任务均可应用工作流软件自动规范地实施。

工作流实现原理分析

先将流程图画好
将流程图中每个节点的数据读取并放入表中
读取表中的第一条记录，处理并删除

实现上述自动化

底层需要的技术栈：xml+dom4j+mysql+jdbc

业务流程图要规范化，遵守一套标准（有专门的画图插件）
这个业务流程图本质上是一个xml文件，这样就可以存入所要的数据
读取业务流程图的过程就是解析xml文件的过程
读取一个业务流程图的节点就相当于是解析一个xml结构，进一步将数据插入到mysql表中，形成一条记录
将所有的节点都存入到mysql表中
后面只要读取mysql表中的记录就可以了，读取一条记录就相当于读一个节点
业务流程的推进，后面就转化为读表中的数据，并且处理数据，结束时这一行数据就可以删除。

什么是Activiti7

介绍

Alfresco 软件在 2010 年 5 月 17 日宣布 Activiti 业务流程管理（BPM）开源项目的正式启动，其首席架构师由业务流程管理 BPM 的专家 Tom Baeyens 担任，Tom Baeyens 就是原来 jbpm 的架构师，而 jbpm 是一个非常有名的工作流引擎，当然 activiti 也是一个工作流引擎。

Activiti 是一个工作流引擎， activiti 可以将业务系统中复杂的业务流程抽取出来，使用专门的建模语言（BPMN2.0）进行定义，业务系统按照预先定义的流程进行执行，实现了业务系统的业务流程由 activiti 进行管理，减少业务系统由于流程变更进行系统升级改造的工作量，从而提高系统的健壮性，同时也减少了系统开发维护成本。

官方网站：https://www.activiti.org

BPM

BPM（Business Process Management），即业务流程管理，是一种以规范化的构造端到端的卓越业务流程为中心，以持续的提高组织业务绩效为目的系统化方法，常见商业管理教育如 EMBA、MBA等均将 BPM 包含在内。

BPM软件

BPM 软件就是根据企业中业务环境的变化，推进人与人之间、人与系统之间以及系统与系统之间的整合及调整的经营方法与解决方案的 IT 工具。通常以 Internet 方式实现信息传递、数据同步、业务监控和企业业务流程的持续升级优化，从而实现跨应用、跨部门、跨合作伙伴与客户的企业运作。通过 BPM 软件对企业内部及外部的业务流程的整个生命周期进行建模、自动化、管理监控和优化，使企业成本降低，利润得以大幅提升。

BPM 软件在企业中应用领域广泛，凡是有业务流程的地方都可以 BPM 软件进行管理，比如企业人事办公管理、采购流程管理、公文审批流程管理、财务管理等。

BPMN

BPMN（Business Process Model And Notation）- 业务流程模型和符号是由 BPMI（Business Process Management Initiative）开发的一套标准的业务流程建模符号，使用 BPMN 提供的符号可以创建业务流程。 2004 年 5 月发布了 BPMN1.0 规范.BPMI 于 2005 年 9 月并入 OMG（The Object Management Group 对象管理组织)组织。OMG 于 2011 年 1 月发布 BPMN2.0 的最终版本。

BPMN 是目前被各 BPM 厂商广泛接受的 BPM 标准。Activiti 就是使用 BPMN 2.0 进行流程建模、流程执行管理，它包括很多的建模符号。

比如：

Event 用一个圆圈表示，它是流程中运行过程中发生的事情
活动用圆角矩形表示，一个流程由一个活动或多个活动组成

Bpmn 图形其实是通过 xml 表示业务流程，上边的.bpmn 文件可以使用文本编辑器打开。

使用

部署activiti

Activiti 是一个工作流引擎（其实就是一堆 jar 包 API），业务系统使用 activiti 来对系统的业务流程进行自动化管理
为了方便业务系统访问(操作)activiti 的接口或功能，通常将 activiti 环境与业务系统的环境集成在一起。

流程定义

使用 activiti 流程建模工具(activity-designer)定义业务流程(.bpmn 文件)
.bpmn 文件就是业务流程定义文件，通过 xml 定义业务流程。
如果使用其它公司开发的工作作引擎一般都提供了可视化的建模工具(Process Designer)用于生成流程定义文件，建模工具操作直观，一般都支持图形化拖拽方式、多窗口的用户界面、丰富的过程图形元素、过程元素拷贝、粘贴、删除等功能。

流程定义部署

向 activiti 部署业务流程定义（.bpmn 文件）。
使用 activiti 提供的 api 向 activiti 中部署.bpmn 文件（一般情况还需要一块儿部署业务流程的图片.png）

启动一个流程实例（ProcessInstance）

启动一个流程实例表示开始一次业务流程的运行
比如员工请假流程部署完成，如果张三要请假就可以启动一个流程实例，如果李四要请假也启动一个流程实例，两个流程的执行互相不影响。
流程定义就好比是java中的类，
流程实例就好比java中的一个实例(对象)
一个流程定义可以对应多个流程实例

用户查询待办任务（Task）

因为现在系统的业务流程已经交给 activiti 管理，通过 activiti 就可以查询当前流程执行到哪了，当前用户需要办理什么任务了，这些 activiti帮我们管理了，而不像上边需要我们在 sql语句中的where条件中指定当前查询的状态值是多少。

用户办理任务

用户查询待办任务后，就可以办理某个任务，如果这个任务办理完成还需要其它用户办理
比如采购单创建后由部门经理审核，这个过程也是由 activiti 帮我们完成了，不需要我们在代码中硬编码指定下一个任务办理人了。

流程结束

当任务办理完成没有下一个任务/结点了，这个流程实例就完成了。

开发环境

jdk1.8及以上
mysql、oracle等数据库
web容器（Tomcat8.5）
开发工具（Navicat、Idea、Activiti BPMN visualizer）

开发步骤

创建mysql数据库(数据库名字任意)

1	`CREATE DATABASE activiti DEFAULT CHARACTER SET utf8;`

创建Maven工程

加入Maven依赖的坐标

首先需要在 java 工程中加入 ProcessEngine 所需要的 jar 包：
activiti-engine-7.0.0.beta1.jar
activiti 依赖的 jar 包：mybatis、alf4j、log4j 等
activiti 依赖的 spring 包
数据库驱动
第三方数据连接池 dbcp
单元测试 Junit-4.12.jar

<properties>
 <slf4j.version>1.6.6</slf4j.version>
 <log4j.version>1.2.12</log4j.version>
</properties>
<dependencies>
    <!--activiti核心工程包-->
     <dependency>
         <groupId>org.activiti</groupId>
         <artifactId>activiti-engine</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
    <!--Activiti与spring的整合包-->
     <dependency>
         <groupId>org.activiti</groupId>
         <artifactId>activiti-spring</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
     <!--activiti处理bpmn资源包-->
     <dependency>
         <groupId>org.activiti</groupId>
         <artifactId>activiti-bpmn-model</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
    <!--该模块负责对Model对象与XML进行互转-->
     <dependency>
         <groupId>org.activiti</groupId>
         <artifactId>activiti-bpmn-converter</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
     <!--activiti处理json包-->
     <dependency>
         <groupId>org.activiti</groupId>
         <artifactId>activiti-json-converter</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
    <!--可以根据流程定义文件中的XML定义生成BPMN DI信息（定义了流程中每一个活动的坐标、宽度、高度等）。-->
    <dependency>
         <groupId>org.activiti</groupId>
         <artifactId>activiti-bpmn-layout</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
    <!--activiti用来做分布式业务-->
     <dependency>
         <groupId>org.activiti.cloud</groupId>
         <artifactId>activiti-cloud-services-api</artifactId>
         <version>7.0.0.Beta1</version>
     </dependency>
     <dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
         <version>5.1.40</version>
     </dependency>
     <dependency>
         <groupId>junit</groupId>
         <artifactId>junit</artifactId>
         <version>4.12</version>
     </dependency>
 <!-- log start -->
     <dependency>
         <groupId>log4j</groupId>
         <artifactId>log4j</artifactId>
         <version>${log4j.version}</version>
     </dependency>
     <dependency>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-api</artifactId>
         <version>${slf4j.version}</version>
     </dependency>
     <dependency>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-log4j12</artifactId>
         <version>${slf4j.version}</version>
     </dependency>
     <!-- log end -->
     <dependency>
         <groupId>org.mybatis</groupId>
         <artifactId>mybatis</artifactId>
         <version>3.4.5</version>
     </dependency>
    <dependency>
         <groupId>commons-dbcp</groupId>
         <artifactId>commons-dbcp</artifactId>
         <version>1.4</version>
    </dependency>
</dependencies>

log4j.properties

# Set root category priority to INFO and its only appender to CONSOLE.
#log4j.rootCategory=INFO, CONSOLE debug info warn error fatal
log4j.rootCategory=debug, CONSOLE, LOGFILE
# Set the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE
# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r 
[%15.15t] %-5p %30.30c %x - %m\n
# LOGFILE is set to be a File appender using a PatternLayout.
log4j.appender.LOGFILE=org.apache.log4j.FileAppender
log4j.appender.LOGFILE.File=d:\axis.log
log4j.appender.LOGFILE.Append=true
log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r 
[%15.15t] %-5p %30.30c %x - %m\n

activiti.cfg.xml

在classpath下创建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"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:tx="http://www.springframework.org/schema/tx"
 xsi:schemaLocation="http://www.springframework.org/schema/beans
                     http://www.springframework.org/schema/beans/spring-beans.xsd
 http://www.springframework.org/schema/contex 
 http://www.springframework.org/schema/context/spring-context.xsd
 http://www.springframework.org/schema/tx 
 http://www.springframework.org/schema/tx/spring-tx.xsd">
</beans>

在 activiti.cfg.xml 中配置数据源和 processEngineConfiguration

数据源

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/
    itcast0711activiti" />
    <property name="username" value="root" />
    <property name="password" value="root" />
    <property name=" maxActive" value="3" />
    <property name="maxIdle" value="1" />
</bean>

processEngineConfiguration

processEngineConfiguration 用来创建 ProcessEngine，在创建 ProcessEngine 时会执行数据库的操作(Activiti表的创建)。

<bean id="processEngineConfiguration"
class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
<!-- 数据源 -->
<property name="dataSource" ref="dataSource" />
<!-- activiti数据库表处理策略 -->
<property name="databaseSchemaUpdate" value="true"/>
</bean>

关于 processEngineConfiguration 中的 databaseSchemaUpdate 参数，通过此参数设计 activiti数据表的处理策略，参数如下：

false（默认）：检查数据库表的版本和依赖库的版本，如果版本不匹配就抛出异常。
true: 构建流程引擎时，执行检查，如果需要就执行更新。如果表不存在，就创建。
create-drop: 构建流程引擎时创建数据库表，关闭流程引擎时删除这些表。
drop-create：先删除表再创建表。
create: 构建流程引擎时创建数据库表，关闭流程引擎时不删除这些表。

注意：在activiti.cfg.xml配置文件中的dataSource和 processEngineConfiguration也可以使用一次性配置出来

<bean
id="processEngineConfiguration" 
class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
 <property name="jdbcDriver" value="com.mysql.jdbc.Driver"/>
 <property name="jdbcUrl" 
value="jdbc:mysql://localhost:3306/itcast0711activiti"/>
 <property name="jdbcUsername" value="root"/>
 <property name="jdbcPassword" value="root"/>
 <property name="databaseSchemaUpdate" value="true"/>
</bean>

开发总结

使用java代码方式来生成25张表

pom.xml文件需要引入Activiti7开发相关的坐标
log4j.properties日志文件添加
activiti.cfg.xml默认配置文件，也可以是其他名称
- 配置数据源
- 创建ProcessEnginConfiguration对象，使用脱机方式StandaloneProcessEngineConfiguration
- 设置databaseSchemaUpdate=true
写java代码
- ProcessEngineConfiguration类
- ProcessEngine类

数据库表的命名规则

Activiti的表都以ACT_开头。第二部分是表示表的用途的两个字母标识。用途也和服务的API对应

ACT_RE_*
RE表示repository。这个前缀的表包含了流程定义和流程静态资源(图片、规则等等)
ACT_RU_*
RU表示runtime。这些运行时的表，包含流程实例，任务、变量、异步任务等运行中的数据。
Activiti只在流程实例执行过程中保存这些数据，在流程结束时就会删除这些记录。这样运行时表就可以一直很小速度很快
ACT_HI_*
HI表示history。这些表包含历史数据，比如历史流程实例，变量，任务等等
ACT_GE_*
GE表示general。通用数据，用于不同场景下。

Activiti服务架构

activiti.cfg.xml

activiti 的引擎配置文件，包括：ProcessEngineConfiguration 的定义、数据源定义、事务管理器等，此文件其实就是一个 spring 配置文件，下面是一个基本的配置只配置了 ProcessEngineConfiguration和数据源：

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
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-3.1.xsd
                    http://www.springframework.org/schema/context
                    http://www.springframework.org/schema/context/spring-context-3.1.xsd
                    http://www.springframework.org/schema/tx
                    http://www.springframework.org/schema/tx/spring-tx-3.1.xsd">
 
    <!--数据库连接池 -->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/activiti" />
        <property name="username" value="root" />
        <property name="password" value="mysql" />
    </bean>
    <bean id="processEngineConfiguration"class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <!-- 数据源 -->
        <property name="dataSource" ref="dataSource" />
        <!-- 数据库策略 -->
        <property name="databaseSchemaUpdate" value="true"/>
    </bean>
</beans>

ProcessEngineConfiguration

流程引擎的配置类，通过 ProcessEngineConfiguration 可以创建工作流引擎 ProceccEngine，常用的两种方法如下

StandaloneProcessEngineConfiguration

通过org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration

Activiti 可以单独运行，使用它创建的 ProcessEngine，Activiti 会自己处理事务。

配置文件方式：

通常在 activiti.cfg.xml 配置文件中定义一个 id 为 processEngineConfiguration 的 bean，这里会使用 spring 的依赖注入来构建引擎

方法如下:

<bean id="processEngineConfiguration"
class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
    <!-- 数据源 -->
    <property name="dataSource" ref="dataSource" />
    <!-- 数据库策略 -->
    <property name="databaseSchemaUpdate" value="true"/>
</bean>

SpringProcessEngineConfiguration

通过 org.activiti.spring.SpringProcessEngineConfiguration与Spring 整合

创建 spring 与 activiti 的整合配置文件：activity-spring.cfg.xml（名称不固定)

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
		xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-3.1.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-3.1.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-3.1.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-3.1.xsd ">
<!-- 工作流引擎配置bean -->
<bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
    <!-- 数据源 -->
    <property name="dataSource" ref="dataSource" />
    <!-- 使用spring事务管理器 -->
    <property name="transactionManager" ref="transactionManager" />
    <!-- 数据库策略 -->
    <property name="databaseSchemaUpdate" value="drop-create" />
    <!-- activiti的定时任务关闭 -->
    <property name="jobExecutorActivate" value="false" />
</bean>
<!-- 流程引擎 -->
<bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
    <property name="processEngineConfiguration" ref="processEngineConfiguration" />
</bean>
<!-- 资源服务service -->
<bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService" />
<!-- 流程运行service -->
<bean id="runtimeService" factory-bean="processEngine"factory-method="getRuntimeService" />
<!-- 任务管理service -->
<bean id="taskService" factory-bean="processEngine" factory-method="getTaskService" />
<!-- 历史管理service -->
<bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService" />
<!-- 用户管理service -->
<bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService" />
<!-- 引擎管理service -->
<bean id="managementService" factory-bean="processEngine" factory-method="getManagementService" />
<!-- 数据源 -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/activiti" />
    <property name="username" value="root" />
    <property name="password" value="mysql" />
    <property name="maxActive" value="3" />
    <property name="maxIdle" value="1" />
</bean>
<!-- 事务管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
	<property name="dataSource" ref="dataSource" />
</bean>
<!-- 通知 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
    <tx:attributes>
        <!-- 传播行为 -->
        <tx:method name="save*" propagation="REQUIRED" />
            <tx:method name="insert*" propagation="REQUIRED" />
        <tx:method name="delete*" propagation="REQUIRED" />
        <tx:method name="update*" propagation="REQUIRED" />
        <tx:method name="find*" propagation="SUPPORTS" read-only="true" />
        <tx:method name="get*" propagation="SUPPORTS" read-only="true" />
    </tx:attributes>
</tx:advice>
<!-- 切面，根据具体项目修改切点配置 -->
<aop:config proxy-target-class="true">
	<aop:advisor advice-ref="txAdvice" pointcut="execution(* com.itheima.ihrm.service.impl.*.*(..))" />
</aop:config>
</beans>

创建processEngineConfiguration

1 2	`ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml")`

上边的代码要求 activiti.cfg.xml 中必须有一个 processEngineConfiguration 的 bean也可以使用下边的方法，更改 bean 的名字：

1	`ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(String resource, String beanName);`

ProcessEngine

工作流引擎，相当于一个门面接口，通过 ProcessEngineConfiguration 创建 processEngine，通过ProcessEngine 创建各个 service 接口。

一般创建方式

1 2	`//通过ProcessEngineConfiguration创建ProcessEngine ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();`

简单创建方式

将 activiti.cfg.xml 文件名及路径固定，且 activiti.cfg.xml 文件中有 processEngineConfiguration 的配置，可以使用如下代码创建 processEngine:

1
2
3

//使用classpath下的activiti.cfg.xml中的配置创建processEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
System.out.println(processEngine);

Service

Service创建方式

通过 ProcessEngine 创建 Service，Service 是工作流引擎提供用于进行工作流部署、执行、管理的服务接口。

RuntimeService runtimeService = processEngine.getRuntimeService();
RepositoryService repositoryService = processEngine.getRepositoryService();
TaskService taskService = processEngine.getTaskService();
.......

Service总览

RepositoryService	activiti的资源管理类
RuntimeService	activiti的流程运行管理类
TaskService	activiti的任务管理类
HistoryService	activiti的历史管理类
ManagerService	activiti的引擎管理类

RepositoryService

是 activiti 的资源管理类，提供了管理和控制流程发布包和流程定义的操作。

使用工作流建模工具设计的业务流程图需要使用此 service 将流程定义文件的内容部署到计算机。

除了部署流程定义以外还可以：

查询引擎中的发布包和流程定义
暂停或激活发布包，对应全部和特定流程定义，暂停意味着它们不能再执行任何操作了，激活是对应的反向操作
获得多种资源，像是包含在发布包里的文件，或引擎自动生成的流程图
获得流程定义的pojo版本，可以用来通过java解析流程，而不必通过xml

RuntimeService

它是 activiti 的流程运行管理类。可以从这个服务类中获取很多关于流程执行相关的信息。

TaskService

是 activiti 的任务管理类。可以从这个类中获取任务的信息。

HistoryService

是 activiti 的历史管理类，可以查询历史信息，执行流程时，引擎会保存很多数据（根据配置）。

比如流程实例启动时间，任务的参与者，完成任务的时间，每个流程实例的执行路径，等等。

这个服务主要通过查询功能来获得这些数据。

ManagementService

是 activiti 的引擎管理类，提供了对 Activiti 流程引擎的管理和维护功能，这些功能不在工作流驱动的应用程序中使用，主要用于 Activiti 系统的日常维护。

Activiti入门体验

流程定义

Activiti-Designer 使用

Palette（画板）

在 eclipse 或 idea 中安装 activiti-designer 插件即可使用，画板中包括以下结点

Connection：连接
Event：事件
Task：任务
Gateway：网关
Container：容器
Boundary Event：边界事件
Intermediate Event：中间事件

流程图设计完毕保存生成.bpmn文件

新建流程

起完名字 holiday 后，就可以看到进入了流程设计页面，如图所示

在文件的任意位置点击右键：view bpmn(Activiti)Diagram

指定流程定义key

流程定义 key 即流程定义的标识，在 eclipse 中通过 properties 视图查看流程的 key。

建议：相同的业务流程，流程定义的 key 名字定义一样，比如，如果需要创建新的业务流程，请假流程则使用新的 key

指定任务负责人

在 properties 视图指定每个任务结点的负责人，

比如下边是填写请假单的负责人为 zhangsan

部署流程定义

部署流程定义就是要将上边绘制的图形即流程定义（.bpmn）部署在工作流程引擎 activiti 中，方法如下:

使用 ProcessEngine 创建 RepositoryService，代码如下：

// 获取repositoryService
RepositoryService repositoryService = processEngine.getRepositoryService();
//部署对象
Deployment deployment = repositoryService.createDeployment().addClasspathResource("diagram/myholiday.bpmn")// bpmn文件
    .addClasspathResource("diagram/myholiday.png")// 图片文件
    .name("请假申请流程")
    .deploy();
System.out.println("流程部署id:" + deployment.getId());
System.out.println("流程部署名称:" + deployment.getName());

执行此操作后 activiti 会将上边代码中指定的 bpm 文件和图片文件保存在 activiti 数据库。

启动一个流程实例

流程定义部署在 activiti 后就可以通过工作流管理业务流程了，也就是说上边部署的请假申请流程可以使用了。

针对该流程，启动一个流程表示发起一个新的请假申请单，这就相当于 java 类与 java 对象的关系，类定义好后需要 new 创建一个对象使用，当然可以 new 多个对象。

对于请假申请流程，张三发起一个请假申请单需要启动一个流程实例，请假申请单发起一个请假单也需要启动一个流程实例。

// 启动一个流程实例
@Test
public void startProcessInstance() {
    // 获取RunTimeService
    RuntimeService runtimeService =  processEngine.getRuntimeService();
    // 根据流程定义key启动流程
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myholiday01");
    System.out.println(" 流程定义 id ： " + processInstance.getProcessDefinitionId());
    System.out.println("流程实例id：" + processInstance.getId());
    System.out.println(" 当前活动 Id ： " + processInstance.getActivityId());
}

任务查询

流程启动后，各各任务的负责人就可以查询自己当前需要处理的任务，查询出来的任务都是该用户的待办任务。

// 查询当前个人待执行的任务
@Test
public void findPersonalTaskList() {
    // 任务负责人
    String assignee = "zhangsan";
     // 创建TaskService
    TaskService taskService = processEngine.getTaskService();
    List<Task> list = taskService.createTaskQuery()
    .processDefinitionKey("myholiday01")//根据流程定义的可以去查询
    .taskAssignee(assignee)//只查询该任务负责人的任务
    .list();
    for (Task task : list) {
        System.out.println(" 流 程 实 例 id ： " + task.getProcessInstanceId());
        System.out.println("任务id：" + task.getId());
        System.out.println("任务负责人：" + task.getAssignee());
        System.out.println("任务名称：" + task.getName());
    }
}

任务处理

任务负责人查询待办任务，选择任务进行处理，完成任务。

// 完成任务
@Test
public void completTask() {
    //任务id
    String taskId = "8305";
    // 创建TaskService
    TaskService taskService = processEngine.getTaskService();
    //完成任务 结合当前用户任务列表的查询操作的话 任务ID:2505
    taskService.complete(taskId);
    System.out.println("完成任务id="+taskId);
}

流程定义

什么是流程定义

流程定义是线下按照 bpmn2.0 标准去描述业务流程，通常使用 activiti-explorer（web 控制台）或 activiti-eclipse-designer 插件对业务流程进行建模，这两种方式都遵循 bpmn2.0 标准。使用 designer 设计器绘制流程，会生成两个文件：.bpmn和.png

.bpmn

使用 activiti-desinger 设计业务流程，会生成.bpmn 文件，直接点击打开

BPMN 2.0 根节点是 definitions 节点。这个元素中，可以定义多个流程定义（不过我们建议每个文件只包含一个流程定义，可以简化开发过程中的维护难度）。注意，definitions 元素最少也要

包含 xmlns 和 targetNamespace 的声明。 targetNamespace 可以是任意值，它用来对流程实例进行分类。

流程定义部分：定义了流程每个结点的描述及结点之间的流程流转。
流程布局定义：定义流程每个结点在流程图上的位置坐标等信息。

.png图片文件

eclipse工具中的操作

使用 activiti-designer 设计流程图时自动生成，使用 designer 设计流程图的同时自动生成与 bpmn 文件同名的图片文件(.png)，需在 eclipse 中进行配置：
由 activiti 自动生成图形
流程图设计完毕向 activiti 中部署流程定义文件 bpmn，部署时由 activiti 自动生成流程图片。
注意：此方法生成时如果图形中有中文生成的图片上显示乱码，且.bpmn 中的坐标和图片显示错位。

IDEA工具中的操作方式

将xxx.bpmn文件改为扩展名xml的文件名称：xxx.xml
在文件上面，点击右键并选择Diagrams 菜单，再选择 Show BPMN2.0 Designer…
打开后效果图如下
点击Export To File的小图标
注意填写文件名及扩展名，选择好保存图片的位置
中文乱码的解决
打开IDEA安装路径,找到如下安装目录

根据自己所安装的版本来决定，我使用的是 64 位的 idea，所以在 idea64.exe.vmoptions 文件的最后一行追加一条命令：

-Dfile.encoding=UTF-8

一定注意，不要有空格，否则重启 IDEA 时会打不开，然后重启 IDEA，把原来的 png 图片删掉，再重新生成，即可解决乱码问题

流程定义部署

什么是流程定义部署

将线下定义的流程部署到 activiti 数据库中，这就是流程定义部署，通过调用 activiti 的 api 将流程定义的 bpmn 和 png 两个文件一个一个添加部署到 activiti 中，也可以将两个文件打成 zip 包进行部署。

单个文件部署方式

分别将 bpmn 文件和 png图片文件部署

@Test
public void deployProcess() {
    // 获取repositoryService
    RepositoryService repositoryService = processEngine.getRepositoryService();
    // bpmn输入流
    InputStream inputStream_bpmn = this.getClass().getClassLoader().getResourceAsStream("diagram/holiday.bpmn");
    // 图片输入流
    InputStream inputStream_png = this.getClass().getClassLoader().getResourceAsStream("diagram/holiday.png");
    // 流程部署对象 进行部署
    Deployment deployment = repositoryService.createDeployment()
    .addInputStream("holiday.bpmn", inputStream_bpmn)//添加bpmn资源
    .addInputStream("holiday.png", inputStream_png)
    .deploy();
   	//输出一些部署信息
    System.out.println("流程部署id：" + deployment.getId());
    System.out.println("流程部署名称：" + deployment.getName());
}

执行此操作后 activiti 会将上边代码中指定的 bpm 文件和图片文件保存在 activiti 数据库。

压缩包部署方式

将 holiday.bpmn 和 holiday.png 压缩成 zip 包。

@Test
public void deployProcessByZip() {
    // 定义zip输入流
    InputStream inputStream = this.getClass()
        .getClassLoader()
        .getResourceAsStream("diagram/holiday.zip");
    ZipInputStream zipInputStream = new ZipInputStream(inputStream);
    // 获取repositoryService
    RepositoryService repositoryService = processEngine.getRepositoryService();
    // 流程部署
    Deployment deployment = repositoryService.createDeployment()
    .addZipInputStream(zipInputStream)
    .deploy();
    System.out.println("流程部署id：" + deployment.getId());
    System.out.println("流程部署名称：" + deployment.getName());
}

执行此操作后 activiti 会将上边代码中指定的 bpm 文件和图片文件保存在 activiti 数据库

操作数据表

流程定义部署后操作 activiti 数据表如下：

SELECT * FROM act_re_deployment #流程定义部署表，记录流程部署信息

SELECT * FROM act_re_procdef #流程定义表，记录流程定义信息

SELECT * FROM act_ge_bytearray #资源表

说明：

act_re_deployment 和 act_re_procdef 一对多关系，一次部署在流程部署表生成一条记录，但一次部署可以部署多个流程定义，每个流程定义在流程定义表生成一条记录。每一个流程定义在act_ge_bytearray 会存在两个资源记录，bpmn 和 png。

建议：一次部署一个流程，这样部署表和流程定义表是一对一有关系，方便读取流程部署及流程定义信息。

流程定义查询

查询部署的流程定义

@Test
public void queryProceccDefinition() {
    // 流程定义key
    String processDefinitionKey = "holiday";
    // 获取repositoryService
    RepositoryService repositoryService = processEngine.getRepositoryService();
    // 查询流程定义
    ProcessDefinitionQuery processDefinitionQuery = repositoryService
    .createProcessDefinitionQuery();
    //遍历查询结果
    List<ProcessDefinition> list = processDefinitionQuery
    	.processDefinitionKey(processDefinitionKey)
        .orderByProcessDefinitionVersion().desc().list();
    for (ProcessDefinition processDefinition : list) {
        System.out.println("------------------------");
        System.out.println(" 流 程 部 署 id ： " + 
        processDefinition.getDeploymentId());
        System.out.println("流程定义id：" + processDefinition.getId());
        System.out.println("流程定义名称：" + processDefinition.getName());
        System.out.println("流程定义key：" + processDefinition.getKey());
        System.out.println("流程定义版本：" + processDefinition.getVersion());
    }
}

流程定义删除

删除已经部署成功的流程定义。

public void deleteDeployment() {
	// 流程部署id
    String deploymentId = "8801";
    // 通过流程引擎获取repositoryService
    RepositoryService repositoryService = processEngine
    .getRepositoryService();
    //删除流程定义，如果该流程定义已有流程实例启动则删除时出错
    repositoryService.deleteDeployment(deploymentId);
    //设置true 级联删除流程定义，即使该流程有流程实例启动也可以删除，设
    置为false非级别删除方式，如果流程
    //repositoryService.deleteDeployment(deploymentId, true);
}

说明：

使用 repositoryService 删除流程定义
如果该流程定义下没有正在运行的流程，则可以用普通删除。
如果该流程定义下存在已经运行的流程，使用普通删除报错，可用级联删除方法将流程及相关记录全部删除。项目开发中使用级联删除的情况比较多，删除操作一般只开放给超级管理员使用

流程定义资源查询

方式1

通过流程定义对象获取流程定义资源，获取bpmn和png

@Test
public void getProcessResources() throws IOException {
    // 流程定义id
    String processDefinitionId = "";
    // 获取repositoryService
    RepositoryService repositoryService = processEngine.getRepositoryService();
    // 流程定义对象
    ProcessDefinition processDefinition = repositoryService
        .createProcessDefinitionQuery()
        .processDefinitionId(processDefinitionId)
        .singleResult();
    //获取bpmn
    String resource_bpmn = processDefinition.getResourceName();
    //获取png
    String resource_png = processDefinition.getDiagramResourceName();
    // 资源信息
    System.out.println("bpmn：" + resource_bpmn);
    System.out.println("png：" + resource_png);
    File file_png = new File("d:/purchasingflow01.png");
    File file_bpmn = new File("d:/purchasingflow01.bpmn");
    // 输出bpmn
    InputStream resourceAsStream = null;
    resourceAsStream = repositoryService.getResourceAsStream(
    processDefinition.getDeploymentId(), resource_bpmn);

    FileOutputStream fileOutputStream = new
    FileOutputStream(file_bpmn);
    byte[] b = new byte[1024];
    int len = -1;
    while ((len = resourceAsStream.read(b, 0, 1024)) != -1) {
    	fileOutputStream.write(b, 0, len);
    }
    // 输出图片
    resourceAsStream = repositoryService.getResourceAsStream(
    processDefinition.getDeploymentId(), resource_png);
    fileOutputStream = new FileOutputStream(file_png);
    // byte[] b = new byte[1024];
    // int len = -1;
    while ((len = resourceAsStream.read(b, 0, 1024)) != -1) {
    	fileOutputStream.write(b, 0, len);
    }
}

方式2

通过查询流程部署信息获取流程定义资源。

// 获取流程定义图片资源
@Test
public void getProcessResources() throws IOException {
    //流程部署id
    String deploymentId = "9001";
    // 通过流程引擎获取repositoryService
    RepositoryService repositoryService = processEngine.getRepositoryService();
    //读取资源名称
    List<String> resources = repositoryService.getDeploymentResourceNames(deploymentId);
    String resource_image = null;
    //获取图片
    for(String resource_name :resources){
        if(resource_name.indexOf(".png")>=0){
        	resource_image = resource_name;
        }
	}
    //图片输入流
    InputStream inputStream = repositoryService.getResourceAsStream(deploymentId, resource_image);
    File exportFile = new File("d:/holiday.png");
    FileOutputStream fileOutputStream = new FileOutputStream(exportFile);
    byte[] buffer = new byte[1024];
    int len = -1;
    //输出图片
    while((len = inputStream.read(buffer))!=-1){
    	fileOutputStream.write(buffer, 0, len);
    }
    inputStream.close();
    fileOutputStream.close();
}

说明:

deploy mentId为流程部署ID
resource_name为act_ge_bytearray表中NAME_列的值
使用 repositoryService 的 getDeploymentResourceNames方法可以获取指定部署下得所有文件的名称
使用 repositoryService 的 getResourceAsStream 方法传入部署 ID和资源图片名称可以获取部署下指定名称文件的输入流
最后的将输入流中的图片资源进行输出

流程历史信息的查看

即使流程定义已经删除了，流程执行的历史信息通过前面的分析，依然保存在 activiti 的 act_hi_*相关的表中。所以我们还是可以查询流程执行的历史信息，可以通过 HistoryService 来查看相关的历史记录。

public void testHistoric01(){
 HistoryService historyService = pe.getHistoryService();
 HistoricActivityInstanceQuery query = historyService.createHistoricActivityInstanceQuery();
 query.processInstanceId("1501");
 
 List<HistoricActivityInstance> list = query.list();
 for(HistoricActivityInstance ai :list){
     System.out.println(ai.getActivityId());
     System.out.println(ai.getActivityName());
     System.out.println(ai.getProcessDefinitionId());
     System.out.println(ai.getProcessInstanceId());
     System.out.println("==============================");
 	}
 }

流程实例

什么是流程实例

参与者(可以是用户也可以是程序) 按照流程定义内容发起一个流程，这就是一个流程实例。是动态的

流程定义和流程实例的图解

启动流程实例

流程定义部署在 activiti 后，就可以在系统中通过 activiti 去管理该流程的执行，执行流程表示流程的一次执行。

比如部署系统请假流程后，如果某用户要申请请假这时就需要执行这个流程，如果另外一个用户也要申请请假则也需要执行该流程，每个执行互不影响，每个执行是单独的流程实例。

执行流程首先需要启动流程实例：

@Test
public void startProcessInstance() {
    // 流程定义key
    String processDefinitionKey = "";
    // 获取RunTimeService
    RuntimeService runtimeService = processEngine.getRuntimeService();
    // 根据流程定义key启动流程
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey);
    System.out.println(" 流 程 定 义 id ： " + processInstance.getProcessDefinitionId());
    System.out.println("流程实例id：" + processInstance.getId());
    System.out.println("当前活动Id：" + processInstance.getActivityId());
}

Businesskey（业务标识）

启动流程实例时，指定的businesskey，就会在act_ru_execution

（流程实例的执行表）中存储businesskey。

Businesskey：业务标识，通常为业务表的主键，业务标识和流程实例一一对应。

业务标识来源于业务系统。存储业务标识就是根据业务标识来关联查询业务系统的数据。

比如：请假流程启动一个流程实例，就可以将请假单的 id 作为业务标识存储到 activiti 中，将来查询activiti 的流程实例信息就可以获取请假单的 id 从而关联查询业务系统数据库得到请假单信息。

// 根据流程定义的key启动一个流程实例
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey(processDefinitionKey, 
businessKey);

操作的数据库表

启动流程实例，操作如下数据库表：
SELECT * FROM act_ru_execution
流程实例执行表，记录当前流程实例的执行情况
说明：
流程实例执行，如果当前只有一个分支时，一个流程实例只有一条记录且执行表的主键 id 和流程实例 id 相同
如果当前有多个分支正在运行则该执行表中有多条记录，存在执行表的主键和流程实例id 不相同的记录。
不论当前有几个分支总会有一条记录的执行表的主键和流程实例 id 相同
一个流程实例运行完成，此表中与流程实例相关的记录删除。
任务执行表，记录当前执行的任务
select * from act_ru_task
说明:启动流程实例，流程当前执行到第一个任务节点，此表会插入一条记录表示当前任务的情况，如果任务完成则记录删除
任务参与者，记录当前参与任务的用户或组
SELECT * FROM act_ru_identitylink
流程实例历史表
SELECT * FROM act_hi_procinst
流程实例启动，会在此表插入一条记录，流程实例运行完成记录也不会删除。
任务历史表，记录所有任务
SELECT * FROM act_hi_taskinst
开始一个任务，不仅在 act_ru_task 表插入记录，也会在历史任务表插入一条记录，任务历史表的主键就是任务 id，任务完成此表记录不删除。
活动历史表，记录所有活动
SELECT * FROM act_hi_actinst
活动包括任务，所以此表中不仅记录了任务，还记录了流程执行过程的其它活动，比如开始事件、结束事件。

查询流程实例

流程在运行过程中可以查询流程实例的状态，当前运行结点等信息。

@Test
public void queryProcessInstance() {
    // 流程定义key
    String processDefinitionKey = "holiday";
    // 获取RunTimeService
    RuntimeService runtimeService = processEngine.getRuntimeService();
    List<ProcessInstance> list = runtimeService
    .createProcessInstanceQuery()
    .processDefinitionKey(processDefinitionKey)//
    .list();
    for (ProcessInstance processInstance : list) {
    System.out.println("----------------------------");
    System.out.println("流程实例id："
    + processInstance.getProcessInstanceId());
    System.out.println("所属流程定义id："
    + processInstance.getProcessDefinitionId());
    System.out.println("是否执行完成：" + processInstance.isEnded());
    System.out.println("是否暂停：" + processInstance.isSuspended());
    System.out.println(" 当 前 活 动 标 识 ： " + 
    processInstance.getActivityId());
    }
}

关联businessKey

需求：

在 activiti 实际应用时，查询流程实例列表时可能要显示出业务系统的一些相关信息

比如：查询当前运行的请假流程列表需要将请假单名称、请假天数等信息显示出来，请假天数等信息在业务系统中存在，而并没有在 activiti 数据库中存在，所以是无法通过 activiti 的 api 查询到请假天数等信息。

实现：

在查询流程实例时，通过 businessKey（业务标识）关联查询业务系统的请假单表，查询出请假天数等信息。

通过下面的代码就可以获取 activiti 中所对应实例保存的业务 Key。

而这个业务 Key 一般都会保存相关联的业务操作表的主键，再通过主键 ID 去查询业务信息，比如通过请假单的 ID，去查询更多的请假信息（请假人，请假时间，请假天数，请假事由等）

1	`String businessKey = processInstance.getBusinessKey();`

在Activiti的act_ru_execution表，字段BUSINESS_KEY就是存放业务KEY的

挂起、激活流程实例

某些情况可能由于流程变更需要将当前运行的流程暂停而不是直接删除，流程暂停后将不会继续执行

全部流程实例挂起

操作流程定义为挂起状态，该流程定义下边所有的流程实例全部暂停：

流程定义为挂起状态该流程定义将不允许启动新的流程实例，同时该流程定义下所有的流程实例将全部挂起暂停执行。

// 挂起激活流程定义
@Test
public void suspendOrActivateProcessDefinition() {
    // 流程定义id
    String processDefinitionId = "";
    RepositoryService repositoryService = processEngine.getRepositoryService();
    // 获得流程定义
    ProcessDefinition processDefinition = repositoryService
    	.createProcessDefinitionQuery()
    	.processDefinitionId(processDefinitionId)
        .singleResult();
    //是否暂停
    boolean suspend = processDefinition.isSuspended();
    if(suspend){
        //如果暂停则激活，这里将流程定义下的所有流程实例全部激活
        repositoryService.activateProcessDefinitionById(processDefinitionId, true, null);
  		System.out.println("流程定义："+processDefinitionId+"激活");
	}else{
        //如果激活则挂起，这里将流程定义下的所有流程实例全部挂起
        repositoryService.suspendProcessDefinitionById(processDefinitionId, true, null);
		System.out.println("流程定义："+processDefinitionId+"挂起");
	}
}

单个流程实例挂起

操作流程实例对象，针对单个流程执行挂起操作，某个流程实例挂起则此流程不再继续执行，完成该流程实例的当前任务将报异常。

@Test
public void suspendOrActiveProcessInstance() {
    // 流程实例id
    String processInstanceId = "";
    // 获取RunTimeService
    RuntimeService runtimeService = processEngine.getRuntimeService();
    //根据流程实例id查询流程实例
    ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
    	.processInstanceId(processInstanceId)
        .singleResult();
    boolean suspend = processInstance.isSuspended();
    if(suspend){
        //如果暂停则激活
        runtimeService.activateProcessInstanceById(processInstanceId);
        System.out.println("流程实例："+processInstanceId+"激活");
    }else{
        //如果激活则挂起
        runtimeService.suspendProcessInstanceById(processInstanceId);
        System.out.println("流程实例："+processInstanceId+"挂起");
    }
}

个人任务

分配任务负责人

固定分配

在进行业务流程建模时指定固定的任务负责人

在properties视图中，填写Assignee项为任务负责人

注意事项

由于固定分配方式，任务只管一步一步执行任务，执行到每一个任务将按照bpmn的配置去分配任务负责人

表达式分配

UEL表达式

Activiti使用UEL表达式，UEL是javaEE6规范的一部分，UEL(Unified Expression Language)即统一表达式语言，Activiti支持两个UEL表达式：UEL-value和UEL-method

UEL-value定义如下:

assignee这个变量是Activiti的一个流程变量。或：

user也是Activiti的一个流程变量，user.assignee表示通过调用user的getter方法获取值。

UEL-method方式如下:

userBean是spring容器中的一个bean，表示调用该bean的getUserId（）方法

UEL-method与UEL-value结合
再比如：${IdapService.findManagerForEmployee(emp)}
- IdapService是spring容器的一个bean
- findManagerForEmployee是该bean的一个方法
- emp是Activiti流程变量
- emp作为参数传到IdapService.findManagerForEmployee方法中
其他
表达式支持解析基础类型、bean、list、array和map，也可以作为条件判断。如下
${order.price > 100 && order.price < 250}

使用流程变量分配任务

定义任务分配流程变量

设置流程变量

在启动流程实例时设置流程变量，如下:

//启动流程实例时设计流程变量
//定义流程变量
Map<String, Object> variables = new HashMap<String, Object>();
//设置流程变量assignee
variables.put("assignee", "张三");
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey(processDefinitionKey, variables);

注意事项

由于使用了表达式分配，必须保证在任务执行过程表达式执行成功，比如：

某个任务使用了表达式${order.price > 100 && order.price < 250}，当执行该任务时必须保证 order 在流程变量中存在，否则 activiti 异常。

监听器分配

任务监听器是发生对应的任务相关事件时执行自定义 java 逻辑或表达式。任务相当事件包括：

Create：任务创建后触发
Assignment：任务分配后触发
Delete：任务完成后触发
All：所有事件发生都触发

java逻辑或表达式

表达式参考上边的介绍的 UEL 表达式，这里主要介绍监听类使用。

定义任务监听类，且类必须实现org.activiti.engine.delegate.TaskListener 接口

public class MyTaskListener implements TaskListener {
    @Override
    public void notify(DelegateTask delegateTask) {
        //这里指定任务负责人
        delegateTask.setAssignee("张三");
    }
}

注意事项

使用监听器分配方式，按照监听事件去执行监听类的notify方法，方法如果不能正常执行也会影响任务的执行。

查询任务

查询任务负责人的待办任务：

// 查询当前个人待执行的任务
@Test
public void findPersonalTaskList() {
        // 流程定义key
        String processDefinitionKey = "holiday";
        // 任务负责人
        String assignee = "张三丰";
        // 创建TaskService
        TaskService taskService = processEngine.getTaskService();
        List<Task> list = taskService.createTaskQuery()
        	.processDefinitionKey(processDefinitionKey)
        	.includeProcessVariables()
            .taskAssignee(assignee)
            .list();
        for (Task task : list) {
            System.out.println("----------------------------");
            System.out.println("流程实例id：" + task.getProcessInstanceId());
            System.out.println("任务id：" + task.getId());
            System.out.println("任务负责人：" + task.getAssignee());
            System.out.println("任务名称：" + task.getName());
		}
}

关联businessKey

需求：

在 activiti 实际应用时，查询待办任务可能要显示出业务系统的一些相关信息。

比如：查询待审批请假单任务列表需要将请假单的日期、请假天数等信息显示出来，请假天数等信息在业务系统中存在，而并没有在 activiti 数据库中存在，所以是无法通过 activiti 的 api 查询到请假天数等信息

实现：

在查询待办任务时，通过 businessKey（业务标识）关联查询业务系统的请假单表，查询出请假天数等信息。

//2.创建RuntimeService对象
RuntimeService runtimeService = processEngine.getRuntimeService();
TaskService taskService = processEngine.getTaskService();

//3.通过TaskService查询到个人任务
Task task = taskService.createTaskQuery()
    .processDefinitionKey("holiday")
    .taskAssignee("zhangsan")
    .singleResult();

//4.通过task对象，得到任务id
String processInstanceId = task.getProccessInstanceId();

//5.通过流程实例id，得到流程实例对象
ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
    .processInstanceId(processInstanceId)
    .singleResult();

//6.对象processInstance对象 得到businessKey
String businessKey = processInstance.getBusinessKey();

//7.根据businessKey就可以得到请假单的信息
System.out.println("businessKey:"+businessKey);

办理任务

指定任务id，调用TaskService完成任务

// 完成任务
@Test
public void completTask() {
	//任务id
    String taskId = "10305";
    // 创建TaskService
    TaskService taskService = processEngine.getTaskService();
    taskService.complete(taskId);
    System.out.println("完成任务");
}

注意：在实际应用中，完成任务前需要校验任务的负责人是否具有该任务的办理权限。

//指定要办理任务id
String taskId = "2802";

//任务负责人
String assignee = "zhouliu";

TaskService taskService = processEngine.getTaskService();

//这里只能指定任务id并没有指定任务负责人，只要调用complete，该任务就完成
//所以说必须完成任务前校验
//校验方法：根据任务id和任务负责人assignee查询当前任务，如果查到说该用户有完成该任务权限，否则没有权限
Task task = taskService.createTaskQuery()
    .taskId(taskId)
    .taskAssignee(assignee)
    .singleResult();
if(task !=null){
    taskService.complete(taskId);
    System.out.println("完成任务!!!");
}

流程变量

什么是流程变量

流程变量在 activiti 中是一个非常重要的角色，流程运转有时需要靠流程变量，业务系统和 activiti结合时少不了流程变量，流程变量就是 activiti 在管理工作流时根据管理需要而设置的变量。

比如在请假流程流转时如果请假天数大于 3 天则由总经理审核，否则由人事直接审核，请假天数就可以设置为流程变量，在流程流转时使用。

注意：虽然流程变量中可以存储业务数据可以通过activiti的 api查询流程变量从而实现查询业务数据，但是不建议这样使用，因为业务数据查询由业务系统负责，activiti设置流程变量是为了流程执行需要而创建

流程变量类型

String
Integer
short
long
double
boolean
date
binary
serializable

注意：如果将pojo存储到流程变量中，必须实现序列化接口serializable，为了防止由于新增字段无法序列化，需要生成serialVersionUID

流程变量作用域

流程变量的作用域默认是一个流程实例(processInstance)，也可以是一个任务(task)或一个执行实例(execution)，这三个作用域流程实例的范围最大，可以称为 global 变量，任务和执行实例仅仅是针对一个任务和一个执行实例范围，范围没有流程实例大，称为 local 变量。

global 变量中变量名不允许重复，设置相同名称的变量，后设置的值会覆盖前设置的变量值。
Local 变量由于在不同的任务或不同的执行实例中，作用域互不影响，变量名可以相同没有影响。
Local 变量名也可以和 global 变量名相同，没有影响。

流程变量的使用方法

第一步：设置流程变量

第二步：通过UEL表达式使用流程变量

可以在assignee处设置UEL表达式，表达式的值为任务的负责人
- 比如${assignee}，assignee就是一个流程变量名称
- Activiti获取UEL表达式的值，即流程变量assignee的值，将assignee的值作为任务的负责人进行任务分配
可以在连线上设置UEL表达式，决定流程走向
- 比如：${price>=10000}和${price<10000}，price就是一个流程变量名称，uel表达式结果类型为布尔类型
- 如果表达式的结果为true，决定流程执行走向

使用GLobal变量控制流程

需求

员工创建请假申请单，由部门经理审核，部门经理审核通过后请假 3 天及以下由人事经理直接审核，3 天以上先由总经理审核，总经理审核通过再由人事经理存档。

流程定义

设置global流程变量

在部门经理审核前设置流程变量，变量值为请假单信息（包括请假天数），部门经理审核后可以根据流程变量的值决定流程走向。

启动流程时设置

在启动流程时设置流程变量，变量的作用域是整个流程实例。

通过 map<key,value>设置流程变量，map 中可以设置多个变量，这个 key 就是流程变量的名字。

// 启动流程时设置流程变量
@Test
public void startProcessInstance() {
    // 流程定义key
    String processDefinitionKey = "";
    Holiday holiday = new Holiday();
	holiday.setNum(3);
    // 定义流程变量
    Map<String, Object> variables = new HashMap<String, Object>();
    //变量名是num，变量值是holiday.getNum(),变量名也可以是一个对象
    variables.put("num", holiday.getNum());
	RuntimeService runtimeService = processEngine.getRuntimeService();
	ProcessInstance processInstance = runtimeService
		.startProcessInstanceByKey(processDefinitionKey, variables);
	System.out.println(" 流 程 实 例 id:" + processInstance.getProcessInstanceId());
}

说明：startProcessInstanceByKey(processDefinitionKey, variables)流程变量作用域是一个流程实例，流程变量使用 Map 存储，同一个流程实例设置变量 map 中 key 相同，后者覆盖前者。

任务办理时设置

在完成任务时设置流程变量，该流程变量只有在该任务完成后其它结点才可使用该变量，它的作用域是整个流程实例，如果设置的流程变量的 key 在流程实例中已存在相同的名字则后设置的变量替换前边设置的变量。

这里需要在创建请假单任务完成时设置流程变量

// 办理任务时设置流程变量
@Test
public void completTask() {
    //任务id
    String taskId = "";
    TaskService taskService = processEngine.getTaskService();
    Holiday holiday = new Holiday();
    holiday.setNum(4);
    // 定义流程变量
    Map<String, Object> variables = new HashMap<String, Object>();
    //变量名是holiday，变量值是holiday对象
    variables.put("holiday", holiday);
    taskService.complete(taskId, variables);
}

说明：通过当前任务设置流程变量，需要指定当前任务 id，如果当前执行的任务 id 不存在则抛出异常。任务办理时也是通过 map<key,value>设置流程变量，一次可以设置多个变量。

通过当前流程实例设置

通过流程实例id设置全局变量，该流程实例必须未执行完成

public void setGlobalVariableByExecutionId(){
    //当前流程实例执行 id，通常设置为当前执行的流程实例
    String executionId="2601";
    RuntimeService runtimeService = processEngine.getRuntimeService();
    Holiday holiday = new Holiday();
    holiday.setNum(3);
    //通过流程实例 id设置流程变量
    runtimeService.setVariable(executionId, "holiday", holiday);
    //一次设置多个值
    //runtimeService.setVariables(executionId, variables)
}

注意：executionId必须当前未结束流程实例的执行id，通常此id设置流程实例的id。也可以通过runtimeService.getVariable()获取流程变量

通过当前任务设置

@Test
public void setGlobalVariableByTaskId(){
    //当前待办任务id
    String taskId="1404";
    TaskService taskService = processEngine.getTaskService();
    Holiday holiday = new Holiday();
    holiday.setNum(3);
    //通过任务设置流程变量
    taskService.setVariable(taskId, "holiday", holiday);
    //一次设置多个值
    //taskService.setVariables(taskId, variables)
}

注意：任务id必须是当前待办任务id，act_ru_task中存在。如果该任务已结束，会报错。

也可以通过 taskService.getVariable()获取流程变量。

注意事项

如果 UEL表达式中流程变量名不存在则报错。
如果 UEL表达式中流程变量值为空 NULL，流程不按 UEL 表达式去执行，而流程结束。
如果 UEL表达式都不符合条件，流程结束
如果连线不设置条件，会走 flow 序号小的那条线

操作数据库

设置流程变量会在当前执行流程变量表插入记录，同时也会在历史流程变量表也插入记录。

SELECT * FROM act_ru_variable #当前流程变量表

记录当前运行流程实例可使用的流程变量，包括 global 和 local 变量

Id_：主键
Type_：变量类型
Name_：变量名称
Execution_id_：所属流程实例执行 id，global 和 local 变量都存储
Proc_inst_id_：所属流程实例 id，global 和 local 变量都存储
Task_id_：所属任务 id，local 变量存储
Bytearray_：serializable 类型变量存储对应 act_ge_bytearray 表的 id
Double_：double 类型变量值
Long_：long 类型变量值
Text_：text 类型变量值

SELECT * FROM act_hi_varinst #历史流程变量表

记录所有已创建的流程变量，包括 global 和 local 变量
字段意义参考当前流程变量表。

设置local流程变量

任务办理时设置

任务办理时设置 local 流程变量，当前运行的流程实例只能在该任务结束前使用，任务结束该变量无法在当前流程实例使用，可以通过查询历史任务查询。

// 办理任务时设置local流程变量
@Test
public void completTask() {
    //任务id
    String taskId = "";
    TaskService taskService = processEngine.getTaskService();
    // 定义流程变量
    Map<String, Object> variables = new HashMap<String, Object>();
    Holiday holiday = new Holiday ();
    holiday.setNum(3);
    // 定义流程变量
       Map<String, Object> variables = new HashMap<String, Object>();
    //变量名是holiday，变量值是holiday对象
    variables.put("holiday", holiday);
    // 设置local变量，作用域为该任务
    taskService.setVariablesLocal(tasked, variables);
    taskService.complete(taskId);
}

说明：设置作用域为任务的local变量，每个任务可以设置同名的变量，互不影响

通过当前任务设置

@Test
public void setLocalVariableByTaskId(){
    //当前待办任务id
    String taskId="1404";
    TaskService taskService = processEngine.getTaskService();
    Holiday holiday = new Holiday ();
    holiday.setNum(3);
    //通过任务设置流程变量
    taskService.setVariableLocal(taskId, "holiday", holiday);
    //一次设置多个值
    //taskService.setVariablesLocal(taskId, variables)
}

注意：任务id必须是当前待办任务id，act_ru_task中存在

Local变量测试1

如果上边例子中设置 global 变量改为设置 local变量是否可行？为什么？

Local 变量在任务结束后无法在当前流程实例执行中使用，如果后续的流程执行需要用到此变量则会报错。

Local变量测试2

在部门经理审核、总经理审核、人事经理审核时设置 local 变量，可通过 historyService 查询每个历史任务时将流程变量的值也查询出来。

// 创建历史任务查询对象
HistoricTaskInstanceQuery historicTaskInstanceQuery = historyService.createHistoricTaskInstanceQuery();
// 查询结果包括 local变量
historicTaskInstanceQuery.includeTaskLocalVariables();
for (HistoricTaskInstance historicTaskInstance : list) {
    System.out.println("==============================");
    System.out.println(" 任 务 id ： " + historicTaskInstance.getId());
    System.out.println(" 任 务 名 称 ： " +  historicTaskInstance.getName());
    System.out.println(" 任 务 负 责 人 ： " +  historicTaskInstance.getAssignee());
    System.out.println(" 任 务 local 变 量 ： "+ historicTaskInstance.getTaskLocalVariables());
}

注意：查询历史流程变量，特别是查询 pojo 变量需要经过反序列化，不推荐使用

组任务

Candidate-users候选人

需求

在流程定义中在任务结点的 assignee 固定设置任务负责人，在流程定义时将参与者固定设置在.bpmn 文件中，如果临时任务负责人变更则需要修改流程定义，系统可扩展性差。

针对这种情况可以给任务设置多个候选人，可以从候选人中选择参与者来完成任务。

设置任务候选人

在流程图中任务节点的配置中设置 candidate-users(候选人)，多个候选人之间用逗号分开。

可以使用activiti:candiateUsers=”用户 1,用户 2,用户 3”的这种方式来实现设置一组候选人。

办理组任务

组任务办理流程

查询组任务
- 指定候选人，查询该候选人当前的待办任务。
- 候选人不能办理任务
拾取（claim）任务
- 该组任务的所有候选人都能拾取。
- 将候选人的组任务，变成个人任务。原来候选人就变成了该任务的负责人。
- 如果拾取后不想办理该任务
  需要将已经拾取的个人任务归还到组里边，将个人任务变成组任务。
查询个人任务
- 查询方式同个人任务部分，根据assignee查询用户负责的个人任务
办理个人任务

用户查询组任务

根据候选人查询组任务

@Test
public void findGroupTaskList() {
    // 流程定义key
    String processDefinitionKey = "holiday4";
    // 任务候选人
    String candidateUser = "zhangsan";
    // 创建TaskService
    TaskService taskService = processEngine.getTaskService();
    //查询组任务
    List<Task> list = taskService.createTaskQuery()//
    	.processDefinitionKey(processDefinitionKey)//
    	.taskCandidateUser(candidateUser)//根据候选人查询
    	.list();
    for (Task task : list) {
        System.out.println("----------------------------");
        System.out.println("流程实例id：" + task.getProcessInstanceId());
        System.out.println("任务id：" + task.getId());
        System.out.println("任务负责人：" + task.getAssignee());
        System.out.println("任务名称：" + task.getName());
	}
}

用户拾取组任务

候选人员拾取组任务后该任务变为自己的个人任务。

@Test
public void claimTask(){
TaskService taskService = processEngine.getTaskService();
    //要拾取的任务id
    String taskId = "6302";
    //任务候选人id
    String userId = "lisi";
    //拾取任务
    //即使该用户不是候选人也能拾取(建议拾取时校验是否有资格)
    //校验该用户有没有拾取任务的资格
    Task task = taskService.createTaskQuery()//
    	.taskId(taskId)
    	.taskCandidateUser(userId)//根据候选人查询
    	.singleResult();
    if(task!=null){
        taskService.claim(taskId, userId);
        System.out.println("任务拾取成功");
    }
}

说明：即使该用户不是候选人也能拾取，建议拾取时校验是否有资格组任务拾取后，该任务已有负责人，通过候选人将查询不到该任务

用户查询个人待办任务

查询方式同个人任务查询

@Test
public void findPersonalTaskList() {
    // 流程定义key
    String processDefinitionKey = "holiday4";
    // 任务负责人
    String assignee = "zhangsan";
    // 创建TaskService
    TaskService taskService = processEngine.getTaskService();
    List<Task> list = taskService.createTaskQuery()
    	.processDefinitionKey(processDefinitionKey)
    	.taskAssignee(assignee).list();
    for (Task task : list) {
        System.out.println("----------------------------");
        System.out.println(" 流 程 实 例 id ： " + 
        task.getProcessInstanceId());
        System.out.println("任务id：" + task.getId());
        System.out.println("任务负责人：" + task.getAssignee());
        System.out.println("任务名称：" + task.getName());
    }
}

用户办理个人任务

同个人任务办理

/**完成任务*/
@Test
public void completeTask(){
    //任务ID
    String taskId = "12304";
    processEngine.getTaskService()
    .complete(taskId);
    System.out.println("完成任务："+taskId);
}

说明：建议完成任务前校验该用户是否是该任务的负责人。

归还组任务

如果个人不想办理该组任务，可以归还组任务，归还后该用户不再是该任务的负责人

// 归还组任务，由个人任务变为组任务，还可以进行任务交接
@Test
public void setAssigneeToGroupTask() {
// 查询任务使用TaskService
TaskService taskService = processEngine.getTaskService();
// 当前待办任务
String taskId = "6004";
// 任务负责人
String userId = "zhangsan2";
// 校验userId是否是taskId的负责人，如果是负责人才可以归还组任务
Task task = taskService.createTaskQuery().taskId(taskId)
.taskAssignee(userId).singleResult();
if (task != null) {
// 如果设置为null，归还组任务,该 任务没有负责人
taskService.setAssignee(taskId, null);
}
}

说明：建议归还任务前校验该用户是否是该任务的负责人也可以通过 setAssignee 方法将任务委托给其它用户负责，注意被委托的用户可以不是候选人（建议不要这样使用)

任务交接

任务交接,任务负责人将任务交给其它候选人办理该任务

@Test
public void setAssigneeToCandidateUser() {
	// 查询任务使用TaskService
    TaskService taskService = processEngine.getTaskService();
    // 当前待办任务
    String taskId = "6004";
    // 任务负责人
    String userId = "zhangsan2";
    // 校验userId是否是taskId的负责人，如果是负责人才可以归还组任务
    Task task = taskService.createTaskQuery().taskId(taskId)
		.taskAssignee(userId)
        .singleResult();
    if (task != null) {
        // 将此任务交给其它候选人办理该 任务
        String candidateuser = "zhangsan";
        // 根据候选人和组任务id查询，如果有记录说明该 候选人有资格拾取该 任务
        Task task2 = taskService.createTaskQuery()
            .taskId(taskId)
        	.taskCandidateUser(candidateuser)
            .singleResult();
        if (task2 != null) {
            // 才可以交接
            taskService.setAssignee(taskId, candidateuser);
        }
    }
}

数据库表操作

SELECT * FROM act_ru_task #任务执行表

记录当前执行的任务，由于该任务当前是组任务，所有assignee 为空，当拾取任务后该字段就是拾取用户的 id

SELECT * FROM act_ru_identitylink #任务参与者

记录当前参考任务用户或组，当前任务如果设置了候选人，会向该表插入候选人记录，有几个候选就插入几个

于 act_ru_identitylink 对应的还有一张历史表 act_hi_identitylink，向 act_ru_identitylink 插入记录的同时也会向历史表插入记录。任务完成。

网关

排他网关

什么是排他网关

排他网关（也叫异或（XOR）网关，或叫基于数据的排他网关），用来在流程中实现决策。当流程执行到这个网关，所有分支都会判断条件是否为 true，如果为 true 则执行该分支，注意，排他网关只会选择一个为 true 的分支执行。(即使有两个分支条件都为 true，排他网关也会只选择一条分支去执行)

为什么要用排他网关

不用排他网关也可以实现分支，如下图：

上图中，在连线的 condition 条件上设置分支条件

缺点：

如果条件都不满足，不使用排他网关，流程就结束了（是异常结束）

如果使用排他网关决定分支的走向，如下：

如果从网关出去的线所有条件不满足则系统抛出异常

说明：经过排他网关必须要有一条且只有一条分支走

流程定义

测试

在部门经理审核后，走排他网关，从排他网关出来的分支有两条，一条是判断请假天数是否大于 3天，另一条是判断请假天数是否小于等于 3 天。

设置分支条件时，如果所有分支条件都不是 true，则会报错

并行网关

什么是并行网关

并行网关允许将流程分成多条分支，也可以把多条分支汇聚到一起，并行网关的功能是基于进入和外出顺序流的：

for分支
并行后的所有外出顺序流，为每个顺序流都创建一个并发分支
join汇聚
所有到达并行网关，在此等待的进入分支，直到所有进入顺序流的分支都到达以后，过汇聚网关

注意，如果同一个并行网关有多个进入和多个外出顺序流，它就同时具有分支和汇聚功能。这时，网关会先汇聚所有进入的顺序流，然后再切分成多个并行分支。

与其他网关的主要区别是，并行网关不会解析条件。即使顺序流中定义了条件，也会被忽略

说明：

财务结算和入库是两个 execution 分支，在 act_ru_execution 表有两条记录分别是财务结算和入库，act_ru_execution 还有一条记录表示该流程实例。
待财务结算和入库任务全部完成，在汇聚点汇聚，通过 parallelGateway 并行网关。

并行网关在业务应用中常用于会签任务，会签任务即多个参与者共同办理的任务。

流程定义

测试

当执行到并行网关数据库跟踪如下

当前任务表：SELECT * FROM act_ru_task #当前任务表

通过流程实例执行表：SELECT * FROM act_ru_execution #流程实例的执行表

对并行任务的执行：并行任务执行不分前后，由任务的负责人去执行即可。

当完成并任务中一个任务后：已完成的任务在当前任务表 act_ru_task_已被删除。
在流程实例执行表：SELECT * FROM act_ru_execution 有中多个分支存在且有并行网关的汇聚结点

有并行网关的汇聚结点：说明有一个分支已经到汇聚，等待其它的分支到达。
当所有分支任务都完成，都到达汇聚结点后：流程实例执行表：SELECT * FROM act_ru_execution，执行流程实例不存在，说明流程执行结束。

总结：所有分支到达汇聚结点，并行网关执行完成。

包含网关

什么是包含网关

包含网关可以看做是排他网关和并行网关的结合体。和排他网关一样，你可以在外出顺序流上定义条件，包含网关会解析它们。但是主要的区别是包含网关可以选择多于一条顺序流，这和并行网关一样

包含网关的功能是基于进入和外出顺序流的：

分支
所有外出顺序流的条件都会被解析，结果为 true 的顺序流会以并行方式继续执行，会为每个顺序流创建一个分支。
汇聚
所有并行分支到达包含网关，会进入等待状态，直到每个包含流程 token 的进入顺序流的分支都到达。这是与并行网关的最大不同。换句话说，包含网关只会等待被选中执行了的进入顺序流。在汇聚之后，流程会穿过包含网关继续执行。