flowable工作流看这一篇就够了(高级篇 上)

2023-12-16 10:36:05

目录

一、Flowable基础表结构

1.1、表结构讲解

1.2、ProcessEngine讲解

1.2.1、硬编码的方式

1.2.2、配置文件

1.2.3、自定义配置文件

1.3、Service服务接口

1.3.1、Service创建方式

1.3.2、Service总览

1.4、图标介绍

1.4.1、事件图标

1.4.2、活动(任务)图标

1.4.3、结构图标

1.4.4、网关图标

1.5、流程部署详解

1.5.1、部署实现

1.5.2、部署涉及表结构

1.5.3、挂起和激活

1.6、启动流程实例

1.7、处理流程

1.8、完成一个流程

二、任务分配和流程变量

2.1、任务分配

2.1.1、固定分配

2.1.2、表达式分配

值表达式

方法表达式

2.1.3、监听器分配

2.2、流程变量

2.2.1、全局变量

2.2.2、局部变量

2.2.3、案例讲解


一、Flowable基础表结构

1.1、表结构讲解

工作流程的相关操作都是操作存储在对应的表结构中,为了能更好的弄清楚Flowable的实现原理和细节,我们有必要先弄清楚Flowable的相关表结构及其作用。在Flowable中的表结构在初始化的时候会创建五类表结构,具体如下:

  • ACT_RE :'RE'表示 repository。 这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。

  • ACT_RU:'RU'表示 runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Flowable只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。

  • ACT_HI:'HI'表示 history。 这些表包含历史数据,比如历史流程实例, 变量,任务等等。

  • ACT_GE: GE 表示 general。 通用数据, 用于不同场景下

  • ACT_ID: ’ID’表示identity(组织机构)。这些表包含标识的信息,如用户,用户组,等等。

具体的表结构的含义:

表分类表名解释
一般数据
[ACT_GE_BYTEARRAY]通用的流程定义和流程资源
[ACT_GE_PROPERTY]系统相关属性
流程历史记录
[ACT_HI_ACTINST]历史的流程实例
[ACT_HI_ATTACHMENT]历史的流程附件
[ACT_HI_COMMENT]历史的说明性信息
[ACT_HI_DETAIL]历史的流程运行中的细节信息
[ACT_HI_IDENTITYLINK]历史的流程运行过程中用户关系
[ACT_HI_PROCINST]历史的流程实例
[ACT_HI_TASKINST]历史的任务实例
[ACT_HI_VARINST]历史的流程运行中的变量信息
流程定义表
[ACT_RE_DEPLOYMENT]部署单元信息
[ACT_RE_MODEL]模型信息
[ACT_RE_PROCDEF]已部署的流程定义
运行实例表
[ACT_RU_EVENT_SUBSCR]运行时事件
[ACT_RU_EXECUTION]运行时流程执行实例
[ACT_RU_IDENTITYLINK]运行时用户关系信息,存储任务节点与参与者的相关信息
[ACT_RU_JOB]运行时作业
[ACT_RU_TASK]运行时任务
[ACT_RU_VARIABLE]运行时变量表
用户用户组表
[ACT_ID_BYTEARRAY]二进制数据表
[ACT_ID_GROUP]用户组信息表
[ACT_ID_INFO]用户信息详情表
[ACT_ID_MEMBERSHIP]人与组关系表
[ACT_ID_PRIV]权限表
[ACT_ID_PRIV_MAPPING]用户或组权限关系表
[ACT_ID_PROPERTY]属性表
[ACT_ID_TOKEN]记录用户的token信息
[ACT_ID_USER]用户表

1.2、ProcessEngine讲解

1.2.1、硬编码的方式

我们前面讲解案例的时候是通过ProcessEngineConfiguration这个配置类来加载的。

// 配置数据库相关信息 获取 ProcessEngineConfiguration
ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
    .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC&nullCatalogMeansCurrent=true")
    .setJdbcUsername("root")
    .setJdbcPassword("root")
    .setJdbcDriver("com.mysql.cj.jdbc.Driver")
    .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
// 获取流程引擎对象
ProcessEngine processEngine = cfg.buildProcessEngine();

1.2.2、配置文件

除了上面的硬编码的方式外,我们还可以在resources目录下创建一个flowable.cfg.xml文件,注意这个名称是固定的哦。内容如下:

<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.flowable.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/flow1?allowMultiQueries=true&amp;useUnicode=true&amp;characterEncoding=UTF-8&amp;useSSL=false&amp;serverTimezone=UTC&amp;nullCatalogMeansCurrent=true" /><property name="jdbcDriver" value="com.mysql.cj.jdbc.Driver" />
        <property name="jdbcUsername" value="root" />
        <property name="jdbcPassword" value="root" />
        <property name="databaseSchemaUpdate" value="true" />
        <property name="asyncExecutorActivate" value="false" />
    </bean>
</beans>

在上面的配置文件中配置相关的信息。我们在Java代码中就可以简化为:

@Test
public void test01(){
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	System.out.println("processEngine = " + processEngine);
}

1.2.3、自定义配置文件

最后我们如果要加载自定义名称的配置文件可以通过ProcessEngineConfiguration中的对应构造方法来实现:

@Test
public void test2() throws Exception{
	ProcessEngineConfiguration configuration = ProcessEngineConfiguration
			.createProcessEngineConfigurationFromResource("flowable.cfg.xml");
	ProcessEngine processEngine = configuration.buildProcessEngine();
	System.out.println("processEngine = " + processEngine);
}

1.3、Service服务接口

Service是工作流引擎提供用于进行工作流部署、执行、管理的服务接口,我们使用这些接口可以就是操作服务对应的数据表。

1.3.1、Service创建方式

通过ProcessEngine创建Service。

方式如下:

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

1.3.2、Service总览

service名称service作用
RepositoryServiceFlowable的资源管理类
RuntimeServiceFlowable的流程运行管理类
TaskServiceFlowable的任务管理类
HistoryServiceFlowable的历史管理类
ManagerServiceFlowable的引擎管理类

简单介绍:

RepositoryService

是activiti的资源管理类,提供了管理和控制流程发布包和流程定义的操作。使用工作流建模工具设计的业务流程图需要使用此service将流程定义文件的内容部署到计算机。

除了部署流程定义以外还可以:查询引擎中的发布包和流程定义。

暂停或激活发布包,对应全部和特定流程定义。 暂停意味着它们不能再执行任何操作了,激活是对应的反向操作。获得多种资源,像是包含在发布包里的文件, 或引擎自动生成的流程图。

获得流程定义的pojo版本, 可以用来通过java解析流程,而不必通过xml。

RuntimeService

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

TaskService

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

HistoryService

Flowable的历史管理类,可以查询历史信息,执行流程时,引擎会保存很多数据(根据配置),比如流程实例启动时间,任务的参与者, 完成任务的时间,每个流程实例的执行路径,等等。 这个服务主要通过查询功能来获得这些数据。

ManagementService

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

1.4、图标介绍

BPMN 2.0是业务流程建模符号2.0的缩写。它由Business Process Management Initiative这个非营利协会创建并不断发展。作为一种标识,BPMN 2.0是使用一些符号来明确业务流程设计流程图的一整套符号规范,它能增进业务建模时的沟通效率。目前BPMN2.0是最新的版本,它用于在BPM上下文中进行布局和可视化的沟通。接下来我们先来了解在流程设计中常见的符号。

BPMN2.0的基本符合主要包含:

1.4.1、事件图标

在Flowable中的事件图标启动事件,边界事件,中间事件和结束事件。

1.4.2、活动(任务)图标

活动是工作或任务的一个通用术语。一个活动可以是一个任务,还可以是一个当前流程的子处理流程; 其次,你还可以为活动指定不同的类型。常见活动如下:

1.4.3、结构图标

1.4.4、网关图标

网关用来处理决策,有几种常用网关需要了解:

1.5、流程部署详解

1.5.1、部署实现

我们先来看下流程部署的具体过程。代码实现:

/**
 * 部署流程
 */
@Test
public void test3(){
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	RepositoryService repositoryService = processEngine.getRepositoryService();
	Deployment deploy = repositoryService.createDeployment()
			.addClasspathResource("MyHolidayUI.bpmn20.xml")
			.name("请假流程...")
			.category("请假") // 分类
			.tenantId("dpb") // 租户id
			.deploy();
	System.out.println("deploy.getId() = " + deploy.getId());
	System.out.println("deploy.getName() = " + deploy.getName());
	System.out.println("deploy.getCategory() = " + deploy.getCategory());
}

1.5.2、部署涉及表结构

涉及到的三张表:

部署资源表:act_ge_bytearray

字段名称备注
ID_主键
REV_版本号
NAME_名称部署的文件名称,如:holiday-request-new.bpmn20.xml、holiday-request-new.bpmn20.png
DEPLOYMENT_ID_部署ID
BYTES_字节(二进制数据)
GENERATED_是否系统生成0为用户上传,<br/>1为系统自动生成, 比如系统会 自动根据xml生 成png

部署ID表:act_re_deployment

字段名称备注
ID_主键
NAME_名称
CATEGORY_分类
TENANT_ID_租户ID
DEPLOY_TIME_部署时间
DERIVED_FROM_来源于
DERIVED_FROM_ROOT_来源于
ENGINE_VERSION_流程引擎的版本

流程表:act_re_procdef

字段名称备注
ID_主键
REV_版本号
CATEGORY_分类流程定义的Namespace就是类别
NAME_名称
KEY_标识
VERSION_版本
DEPLOYMENT_ID_部署ID
RESOURCE_NAME_资源名称流程bpmn文件名称
DGRM_RESOURCE_NAME_图片资源名称
DESCRIPTION_描述
HAS_START_FORM_KEY_拥有开始表单标识start节点是否存在formKey 0否 1是
HAS_GRAPHICAL_NOTATION_拥有图形信息
SUSPENSION_STATE_挂起状态暂停状态 1激活 2暂停
TENANT_ID_租户ID

注意:业务流程定义数据表。此表和ACT_RE_DEPLOYMENT是多对一的关系,即,一个部署的bar包里可能包含多个流程定义文件,每个流程定义文件都会有一条记录在ACT_REPROCDEF表内,每个流程定义的数据,都会对于ACT_GE_BYTEARRAY表内的一个资源文件和PNG图片文件。和ACT_GE_BYTEARRAY的关联是通过程序用ACT_GE_BYTEARRAY.NAME与ACT_RE_PROCDEF.NAME_完成的。

1.5.3、挂起和激活

部署的流程默认的状态为激活,如果我们暂时不想使用该定义的流程,那么可以挂起该流程。当然该流程定义下边所有的流程实例全部暂停。

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

/**
 * 挂起流程
 */
@Test
public void test05(){
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	RepositoryService repositoryService = processEngine.getRepositoryService();
	ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
			.processDefinitionId("MyHolidayUI:1:4")
			.singleResult();
	// 获取流程定义的状态
	boolean suspended = processDefinition.isSuspended();
	System.out.println("suspended = " + suspended);
	if(suspended){
		// 表示被挂起
		System.out.println("激活流程定义");
		repositoryService.activateProcessDefinitionById("MyHolidayUI:1:4",true,null);
	}else{
		// 表示激活状态
		System.out.println("挂起流程");
		repositoryService.suspendProcessDefinitionById("MyHolidayUI:1:4",true,null);
	}
}

当我运行挂起方法:

1.6、启动流程实例

然后我们来看看启动流程实例的过程。实现代码如下:

/**
 * 启动流程实例
 */
@Test
public void testStartRunProcess(){
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	// 启动流程实例通过 RuntimeService 对象
	RuntimeService runtimeService = processEngine.getRuntimeService();
	// 构建流程变量
	Map<String,Object> variables = new HashMap<>();
	variables.put("employee","张三") ;// 谁申请请假
	variables.put("nrOfHolidays",3); // 请几天假
	variables.put("description","工作累了,想出去玩玩"); // 请假的原因
	// 启动流程实例,第一个参数是流程定义的id
	ProcessInstance processInstance = runtimeService
			.startProcessInstanceById("MyHolidayUI:1:4", variables);// 启动流程实例
	// 输出相关的流程实例信息
	System.out.println("流程定义的ID:" + processInstance.getProcessDefinitionId());
	System.out.println("流程实例的ID:" + processInstance.getId());
	System.out.println("当前活动的ID:" + processInstance.getActivityId());
}

当我们启动了一个流程实例后,会在ACT_RU_*对应的表结构中操作,运行时实例涉及的表结构共10张:

  • ACT_RU_DEADLETTER_JOB 正在运行的任务表

  • ACT_RU_EVENT_SUBSCR 运行时事件

  • ACT_RU_EXECUTION 运行时流程执行实例

  • ACT_RU_HISTORY_JOB 历史作业表

  • ACT_RU_IDENTITYLINK 运行时用户关系信息

  • ACT_RU_JOB 运行时作业表

  • ACT_RU_SUSPENDED_JOB 暂停作业表

  • ACT_RU_TASK 运行时任务表

  • ACT_RU_TIMER_JOB 定时作业表

  • ACT_RU_VARIABLE 运行时变量表

启动一个流程实例的时候涉及到的表有

  • ACT_RU_EXECUTION 运行时流程执行实例

  • ACT_RU_IDENTITYLINK 运行时用户关系信息

  • ACT_RU_TASK 运行时任务表

  • ACT_RU_VARIABLE 运行时变量表

ACT_RU_EXECUTION表结构

字段名称备注
ID_主键
REV_版本号
PROC_INST_ID_流程实例ID
BUSINESS_KEY_业务主键ID
PARENT_ID_父执行流的ID
PROC_DEF_ID_流程定义的数据ID
SUPER_EXEC_
ROOT_PROC_INST_ID_流程实例的root流程id
ACT_ID_节点实例ID
IS_ACTIVE_是否存活
IS_CONCURRENT_执行流是否正在并行
IS_SCOPE_
IS_EVENT_SCOPE_
IS_MI_ROOT_
SUSPENSION_STATE_流程终端状态
CACHED_ENT_STATE_
TENANT_ID_租户编号
NAME_
START_TIME_开始时间
START_USER_ID_开始的用户编号
LOCK_TIME_锁定时间
IS_COUNT_ENABLED_
EVT_SUBSCR_COUNT_
TASK_COUNT_
JOB_COUNT_
TIMER_JOB_COUNT_
SUSP_JOB_COUNT_
DEADLETTER_JOB_COUNT_
VAR_COUNT_
ID_LINK_COUNT_

创建流程实例后对应的表结构的数据

ACT_RU_TASK 运行时任务表

字段名称备注
ID_主键
REV_版本号
EXECUTION_ID_任务所在的执行流ID
PROC_INST_ID_流程实例ID
PROC_DEF_ID_流程定义数据ID
NAME_任务名称
PARENT_TASK_ID_父任务ID
DESCRIPTION_说明
TASK_DEF_KEY_任务定义的ID值
OWNER_任务拥有人
ASSIGNEE_被指派执行该任务的人
DELEGATION_委托人
PRIORITY_优先级
CREATE_TIME_创建时间
DUE_DATE_耗时
CATEGORY_类别
SUSPENSION_STATE_是否挂起1代表激活 2代表挂起
TENANT_ID_租户编号
FORM_KEY_
CLAIM_TIME_拾取时间

创建流程实例后对应的表结构的数据

ACT_RU_VARIABLE 运行时变量表

字段名称备注
ID_主键
REV_版本号
TYPE_参数类型可以是基本的类型,也可以用户自行扩展
NAME_参数名称
EXECUTION_ID_参数执行ID
PROC_INST_ID_流程实例ID
TASK_ID_任务ID
BYTEARRAY_ID_资源ID
DOUBLE_参数为double,则保存在该字段中
LONG_参数为long,则保存在该字段中
TEXT_用户保存文本类型的参数值
TEXT2_用户保存文本类型的参数值

创建流程实例后对应的表结构的数据

ACT_RU_IDENTITYLINK 运行时用户关系信息

字段名称备注
ID_主键
REV_版本号
GROUP_ID_用户组ID
TYPE_关系数据类型assignee支配人(组)、candidate候选人(组)、owner拥有人,participant参与者
USER_ID_用户ID
TASK_ID_任务ID
PROC_INST_ID_流程定义ID
PROC_DEF_ID_属性ID

创建流程实例后对应的表结构的数据

1.7、处理流程

上面的流程已经流转到了user1这个用户这里,然后可以开始审批了

@Test
public void testStartCompleteTask() {
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	TaskService taskService = processEngine.getTaskService();
	Task task = taskService.createTaskQuery()
			.processDefinitionId("MyHolidayUI:1:4")
			.taskAssignee("user1")
			.singleResult();
	// 添加流程变量
	Map<String,Object> variables = new HashMap<>();
	variables.put("approved",true); // 审批
	// 完成任务
	taskService.complete(task.getId(),variables);
}

ACT_RU_TASK 运行时任务表:会新生成一条记录

ACT_RU_VARIABLE 运行时变量表:会记录新的流程变量

1.8、完成一个流程

然后我们把第一个流程处理完成

@Test
public void testStartCompleteTask() {
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	TaskService taskService = processEngine.getTaskService();
	Task task = taskService.createTaskQuery()
			.processDefinitionId("MyHolidayUI:1:4")
			.taskAssignee("user2")
			.singleResult();
	// 添加流程变量
	Map<String,Object> variables = new HashMap<>();
	variables.put("approved",true); // 审批
	// 完成任务
	taskService.complete(task.getId(),variables);
}

处理完了一个工作流程后,我们来看看相关的表结构信息

首先我们会发现

  • ACT_RU_EXECUTION 运行时流程执行实例

  • ACT_RU_IDENTITYLINK 运行时用户关系信息

  • ACT_RU_TASK 运行时任务表

  • ACT_RU_VARIABLE 运行时变量表

这四张表中对应的数据都没有了,也就是这个流程已经不是运行中的流程了。然后在对应的历史表中我们可以看到相关的信息

  • ACT_HI_ACTINST 历史的流程实例

  • ACT_HI_ATTACHMENT 历史的流程附件

  • ACT_HI_COMMENT 历史的说明性信息

  • ACT_HI_DETAIL 历史的流程运行中的细节信息

  • ACT_HI_IDENTITYLINK 历史的流程运行过程中用户关系

  • ACT_HI_PROCINST 历史的流程实例

  • ACT_HI_TASKINST 历史的任务实例

  • ACT_HI_VARINST 历史的流程运行中的变量信息

在我们上面的处理流程的过程中设计到的历史表有

ACT_HI_ACTINST 历史的流程实例

字段名称备注
ID_主键
PROC_DEF_ID_流程定义ID
PROC_INST_ID_流程实例ID
EXECUTION_ID_执行ID
ACT_ID_节点实例ID
TASK_ID_任务ID
CALL_PROC_INST_ID_调用外部的流程实例ID
ACT_NAME_节点名称
ACT_TYPE_节点类型
ASSIGNEE_处理人
START_TIME_开始时间
END_TIME_结束时间
DURATION_耗时
DELETE_REASON_删除原因
TENANT_ID_租户编号

ACT_HI_IDENTITYLINK 历史的流程运行过程中用户关系

字段名称备注
ID_主键
GROUP_ID_组编号
TYPE_类型
USER_ID_用户编号
TASK_ID_任务编号
CREATE_TIME_创建时间
PROC_INST_ID_流程实例编号
SCOPE_ID_
SCOPE_TYPE_
SCOPE_DEFINITION_ID_

ACT_HI_PROCINST 历史的流程实例

字段名称备注
ID_主键
PROC_INST_ID_流程实例ID
BUSINESS_KEY_业务主键
PROC_DEF_ID_属性ID
START_TIME_开始时间
END_TIME_结束时间
DURATION_耗时
START_USER_ID_起始人
START_ACT_ID_起始节点
END_ACT_ID_结束节点
SUPER_PROCESS_INSTANCE_ID_父流程实例ID
DELETE_REASON_删除原因
TENANT_ID_租户编号
NAME_名称

ACT_HI_TASKINST 历史的任务实例

字段名称备注
ID_主键
PROC_DEF_ID_流程定义ID
TASK_DEF_KEY_任务定义的ID值
PROC_INST_ID_流程实例ID
EXECUTION_ID_执行ID
PARENT_TASK_ID_父任务ID
NAME_名称
DESCRIPTION_说明
OWNER_实际签收人 任务的拥有者签收人(默认为空,只有在委托时才有值)
ASSIGNEE_被指派执行该任务的人
START_TIME_开始时间
CLAIM_TIME_任务拾取时间
END_TIME_结束时间
DURATION_耗时
DELETE_REASON_删除原因
PRIORITY_优先级别
DUE_DATE_过期时间
FORM_KEY_节点定义的formkey
CATEGORY_类别
TENANT_ID_租户

ACT_HI_VARINST 历史的流程运行中的变量信息:流程变量虽然在任务完成后在流程实例表中会删除,但是在历史表中还是会记录的

字段名称备注
ID_主键
PROC_INST_ID_流程实例ID
EXECUTION_ID_指定ID
TASK_ID_任务ID
NAME_名称
VAR_TYPE_参数类型
REV_数据版本
BYTEARRAY_ID_字节表ID
DOUBLE_存储double类型数据
LONG_存储long类型数据

好了一个相对简单的流程处理涉及到的相关表结构内容就介绍完了。

二、任务分配和流程变量

2.1、任务分配

2.1.1、固定分配

固定分配就是我们前面介绍的,在绘制流程图或者直接在流程文件中通过Assignee来指定的方式

2.1.2、表达式分配

Flowable使用UEL进行表达式解析。UEL代表Unified Expression Language,是EE6规范的一部分.Flowable支持两种UEL表达式: UEL-value 和UEL-method。

值表达式

值表达式 Value expression: 解析为一个值。默认情况下,所有流程变量都可以使用。(若使用Spring)所有的Spring bean也可以用在表达式里。例如:

${myVar}
${myBean.myProperty}

先部署流程,然后在启动流程实例的时候绑定表达式对应的值

/**
 * 部署流程
 */
@Test
public void testDeploy(){
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	RepositoryService repositoryService = processEngine.getRepositoryService();
	Deployment deploy = repositoryService.createDeployment()
			.addClasspathResource("qjlc.bpmn20.xml")
			.name("XXX公司请求流程")
			.deploy();
	System.out.println("deploy.getId() = " + deploy.getId());
	System.out.println("deploy.getName() = " + deploy.getName());
	System.out.println("deploy.getCategory() = " + deploy.getCategory());
}

/**
 * 启动流程实例
 */
@Test
public void testRunProcess(){

	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	// 启动流程实例通过 RuntimeService 对象
	RuntimeService runtimeService = processEngine.getRuntimeService();
	// 设置 assignee 的取值
	Map<String,Object> variables = new HashMap<>();
	variables.put("assignee0","张三") ;
	variables.put("assignee1","李四");
	// 启动流程实例,第一个参数是流程定义的id
	ProcessInstance processInstance = runtimeService
			.startProcessInstanceById("holiday-new:1:27504", variables);// 启动流程实例
	// 输出相关的流程实例信息
	System.out.println("流程定义的ID:" + processInstance.getProcessDefinitionId());
	System.out.println("流程实例的ID:" + processInstance.getId());
	System.out.println("当前活动的ID:" + processInstance.getActivityId());
}

在流程变量表中我们可以看到对应的流程变量信息

同时在Task表中,可以看到流程当前的分配人是张三,说明UEL表达式被解析了

方法表达式

方法表达式 Method expression: 调用一个方法,可以带或不带参数。当调用不带参数的方法时,要确保在方法名后添加空括号(以避免与值表达式混淆)。传递的参数可以是字面值(literal value),也可以是表达式,它们会被自动解析。例如:

${printer.print()}
${myBean.addNewOrder('orderName')}
${myBean.doSomething(myVar, execution)}

myBean是Spring容器中的个Bean对象,表示调用的是bean的addNewOrder方法。

2.1.3、监听器分配

可以使用监听器来完成很多Flowable的流程业务。

我们在此处使用监听器来完成负责人的指定,那么我们在流程设计的时候就不需要指定assignee

创建自定义监听器:

/**
 * 自定义的监听器
 */
public class MyTaskListener implements TaskListener {
    @Override
    public void notify(DelegateTask delegateTask) {
        System.out.println("监听器触发了:" + delegateTask.getName());
        if("创建请假流程".equals(delegateTask.getName()) &&
                "create".equals(delegateTask.getEventName())){
            // 指定任务的负责人
            delegateTask.setAssignee("小明");
        }else {
            delegateTask.setAssignee("小张");
        }
    }
}

注意:代码中的【提交请假流程】对应的是流程中的步骤名。

然后在FlowableUI中关联对应的监听器

create:任务创建后触发
assignment:任务分配后触发
Delete:任务完成后触发
All:所有事件都触发

然后我们先部署流程,然后执行查看效果:

/**
 * 部署流程
 */
@Test
public void testDeploy(){
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	RepositoryService repositoryService = processEngine.getRepositoryService();
	Deployment deploy = repositoryService.createDeployment()
			.addClasspathResource("testjt.bpmn20.xml")
			.name("XXX公司请求流程")
			.deploy();
	System.out.println("deploy.getId() = " + deploy.getId());
	System.out.println("deploy.getName() = " + deploy.getName());
	System.out.println("deploy.getCategory() = " + deploy.getCategory());
}


/**
 * 启动流程实例
 */
@Test
public void testRunProcess(){
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	// 启动流程实例通过 RuntimeService 对象
	RuntimeService runtimeService = processEngine.getRuntimeService();
	// 启动流程实例,第一个参数是流程定义的id
	ProcessInstance processInstance = runtimeService
			.startProcessInstanceById("holiday-new:1:4");// 启动流程实例
	// 输出相关的流程实例信息
	System.out.println("流程定义的ID:" + processInstance.getProcessDefinitionId());
	System.out.println("流程实例的ID:" + processInstance.getId());
	System.out.println("当前活动的ID:" + processInstance.getActivityId());
}

当我们启动流程,触发监听器,设置审批人为小明。

2.2、流程变量

流程实例按步骤执行时,需要使用一些数据。在Flowable中,这些数据称作变量(variable),并会存储在数据库中。变量可以用在表达式中(例如在排他网关中用于选择正确的出口路径),也可以在Java服务任务(service task)中用于调用外部服务(例如为服务调用提供输入或结果存储),等等。

流程实例可以持有变量(称作流程变量 process variables);用户任务以及执行(executions)——流程当前活动节点的指针——也可以持有变量。流程实例可以持有任意数量的变量,每个变量存储为ACT_RU_VARIABLE数据库表的一行。

所有的startProcessInstanceXXX方法都有一个可选参数,用于在流程实例创建及启动时设置变量。例如,在RuntimeService中:

ProcessInstance startProcessInstanceByKey(String processDefinitionKey, Map<String, Object> variables);

也可以在流程执行中加入变量。例如,(RuntimeService):

void setVariable(String executionId, String variableName, Object value);
void setVariableLocal(String executionId, String variableName, Object value);
void setVariables(String executionId, Map<String, ? extends Object> variables);
void setVariablesLocal(String executionId, Map<String, ? extends Object> variables);

2.2.1、全局变量

流程变量的默认作用域是流程实例。当一个流程变量的作用域为流程实例时,可以称为 global 变量。

注意:如: Global变量:userId(变量名)、zhangsan(变量值)

global 变量中变量名不允许重复,设置相同名称的变量,后设置的值会覆盖前设置的变量值。

整个流程可见全局变量。

Map<String, Object> map = task.getProcessVariables();
map.put("num",2);
taskService.setVariable(map);  //设置全局变量

2.2.2、局部变量

任务和执行实例仅仅是针对一个任务和一个执行实例范围,范围没有流程实例大, 称为 local 变量。

Local 变量由于在不同的任务或不同的执行实例中,作用域互不影响,变量名可以相同没有影响。Local 变量名也可以和 global 变量名相同,没有影响。

单个节点可见局部变量。

Map<String, Object> map = task.getProcessVariables();
map.put("num",2);
taskService.setVariableLocal(map);  //设置局部变量

2.2.3、案例讲解

需求:员工创建出差申请单,由部门经理审核,部门经理申请通过后3天以下由财务直接申批,3天以上先由总经理审批,总经理审批通过后再由财务审批。

第一步:创建模型

第二步:制图

第三步:分别分配用户

第四步:设置连接条件

第五步:下载下来,拷贝到resources下

第六步:部署流程

/**
 * 部署流程
 */
@Test
public void testDeploy(){
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	RepositoryService repositoryService = processEngine.getRepositoryService();
	repositoryService.createDeployment()
			.addClasspathResource("出差申请单.bpmn20.xml")
			.name("出差申请单")
			.deploy();
}

第七步:启动流程实例

/**
 * 在启动流程实例的时候设置流程变量
 */
@Test
public void runProcess(){
	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	// 启动流程实例通过 RuntimeService 对象
	RuntimeService runtimeService = processEngine.getRuntimeService();
	// 设置流程变量
	Map<String,Object> variables = new HashMap<>();
	// 设置assignee的取值
	variables.put("assignee0","张三");
	variables.put("assignee1","李四");
	variables.put("assignee2","王五");
	variables.put("assignee3","赵财务");
	// 启动流程实例,第一个参数是流程定义的id
	runtimeService.startProcessInstanceById("evection:1:4",variables); //启动流程实例
}

第八步:完成Task任务,同时也可以指定流程变量

/**
 * 完成任务时指定流程变量
 */
@Test
public void completeTask(){

	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	TaskService taskService = processEngine.getTaskService();
	Task task = taskService.createTaskQuery()
			.processDefinitionId("evection:1:4")
			.taskAssignee("张三")
			.singleResult();
	// 添加流程变量
	Map<String, Object> map = task.getProcessVariables();
	map.put("num",2);

	// 完成任务
	taskService.complete(task.getId(),map);
}

现在已经走到这了:

这时我们李四审批,并且将num改为5:

/**
 * 完成任务时指定流程变量
 */
@Test
public void completeTask(){

	// 获取流程引擎对象
	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
	TaskService taskService = processEngine.getTaskService();
	Task task = taskService.createTaskQuery()
			.processDefinitionId("evection:1:4")
			.taskAssignee("李四")
			.singleResult();
	// 添加流程变量
	Map<String, Object> map = task.getProcessVariables();
	map.put("num",5);

	// 完成任务
	taskService.complete(task.getId(),map);
}

因为num>=3,所以到了总经理审批。

文章来源:https://blog.csdn.net/qq_38196449/article/details/134936612
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。