大家好,我是 杰哥

在公司中,每个人都需要经常创建或者审批一些流程,比如说转正申请请假流程出差申请等等

那么,你有没有想过,要是你,你会如何实现这些流程的控制逻辑呢?

比如说请假申请,首先需要提前定义好一个流程模板吧,包括当请假天数大于 3 天的话,需要公司级的领导审批等这些规则

然后当某个员工发起请假申请时,根据这个员工所在的部门以及请假天数等信息,便可以确定其具体的流程信息,包括每个节点的审批人

在任何一个审批节点,都需要看到这个流程的历史审批信息以及将来要走的流程吧,所以还需要将完成的和将要完成的任务保存下来

你应该很容易想到,我们可以通过表的字段状态来进行流程的这些逻辑控制

但是呢,简单的流程的话,还可以实现,流程一旦复杂一点,不仅需要实现的代码会增加,而且需要操作的表的数量也特别多,逻辑只会更复杂

那么,有没有现成的工作流框架,可以直接拿来使用,轻松实现这些逻辑,实现流程的自动化控制呢?

答案是肯定的,今天带领大家认识的就是一个专门用来管理工作流的框架:Activiti

一 理论篇

1 实现逻辑

Activiti 就是使用 BPMN 2.0 进行流程建模、流程执行管理,那么,BPMN 又是什么呢?

BPMN(Business Process Model AndNotation)- 业务流程模型和符号 是由 BPMI(BusinessProcess Management Initiative)开发的一套标准的业务流程建模符号,使用 BPMN 提供的符号可以创建业务流程

定义好的流程模板,最终会被存储至数据库表中,而它的实现逻辑其实就是封装了诸多流程控制的表的操作,提供给开发人员一些快捷操作的 API ,来进行快捷的工作流管理

2 实现步骤

使用 Activiti 这种工作流框架大致都分为以下几个步骤:

  • 流程定义

  • 部署流程定义

  • 启动流程实例

  • 查询当前用户的待办任务

  • 完成任务

说明:

流程定义就相当于是一个个的流程模板,比如预先定义好的请假流程、出差流程模板,而流程实例则是由各个员工发起的实实在在的流程,流程实例一旦创建,那么这个流程需要经历哪些审批环节,每个环节由哪个(或者哪些)人负责审批,便完全确定下来了

流程定义与流程实例的关系,你也可以理解为类与对象实例的关系。一个是静态的,一个则是真正被拿来使用的,相对动态

3 Service

Activiti 提供了几个 Service 类,用来管理工作流,常用的有以下四项:

  • 1)RepositoryService:提供流程定义和部署等功能。比如说,实现流程的的部署、删除,暂停和激活以及流程的查询等功能

  • 2)RuntimeService:提供了处理流程实例不同步骤的结构和行为。包括启动流程实例、暂停和激活流程实例等功能

  • 3)TaskService:提供有关任务相关功能的服务。包括任务的查询、删除以及完成等功能

  • 4)HistoryService:提供 Activiti 引擎收集的历史记录信息服务。主要用于历史信息的查询功能

    还有以下两项:

  • **1)**ManagementService:job 任务查询和数据库操作

  • **2)**DynamicBpmnService:无需重新部署就能修改流程定义内容

4 认识表结构

二 实战篇

以下进入实战环节,分别从生成 25 张表运行第一个 Activiti 流程实例,快速认识这个工作流框架的简单易用性

这两个例子,采用 Activiti7 版本,需要预先引入如下依赖:

<dependencies><dependency><groupId>org.activiti</groupId><artifactId>activiti-engine</artifactId><version>7.1.0.M6</version></dependency><dependency><groupId>org.activiti</groupId><artifactId>activiti-spring</artifactId><version>7.1.0.M6</version></dependency><dependency><groupId>org.activiti</groupId><artifactId>activiti-bpmn-model</artifactId><version>7.1.0.M6</version></dependency><dependency><groupId>org.activiti</groupId><artifactId>activiti-bpmn-converter</artifactId><version>7.1.0.M6</version></dependency><dependency><groupId>org.activiti</groupId><artifactId>activiti-json-converter</artifactId><version>7.1.0.M6</version></dependency><dependency><groupId>org.activiti</groupId><artifactId>activiti-bpmn-layout</artifactId><version>7.1.0.M6</version></dependency><dependency><groupId>org.activiti.cloud</groupId><artifactId>activiti-cloud-services-api</artifactId><version>7.0.0.Beta1</version></dependency><!-- mysql 连接--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.29</version></dependency><dependency><groupId>commons-dbcp</groupId><artifactId>commons-dbcp</artifactId><version>1.4</version></dependency><!--lombok 工具 --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.24</version><optional>true</optional></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-slf4j-impl</artifactId><version>2.17.2</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.11.0</version></dependency>
</dependencies>

然后来看看如何生成 25 张表

(一) 生成 25 张表

1 代码编写

1) activiti.cfg.xml 文件配置

我们在 resources 目录下,创建一个文件 activiti.cfg.xml ,主要用来配置数据库的信息

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd"><!-- 配置数据库 dataSouce 信息--><bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"><property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/><property name="url" value="jdbc:mysql://localhost:3306/activiti"/><property name="username" value="root"/><property name="password" value="123456"/><property name="maxActive" value="3"/><property name="maxIdle" value="1"/></bean><bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration"><property name="dataSource" ref="dataSource"/><!-- 配置模式 true : 自动创建和更新表 --><property name="databaseSchemaUpdate" value="true" /></bean></beans>

Activiti7 支持 h2、mssql、mysql 、db2、oracle hsql以及 postgres7 种数据库,我们在这里使用 mysql 数据库

分别配置 mysql 数据库的 url数据库驱动以及用户名密码等信息,然后通过定义类型为 StandaloneProcessEngineConfiguration 的对象 processEngineConfiguration,并指定其配置模式为databaseSchemaUpdate,表示每次启动项目,均会检查数据库中的表,如果不存在,则创建,否则检查更新

2)代码编写

通过 ProcessEngines.getDefaultProcessEngine() 方法,实现 25 张表的自动创建

@Slf4j
public class TestCreat {/*** 数据库表结构的创建*/@Testpublic void testCreateDbTable(){/*** 创建 processEngine 时,会自动加载 /resources 目录下的 activiti.cfg.xml 文件* 进行 mysql 数据库中表的创建*/ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();log.info(processEngine.getName());}

在创建 processEngine 时,Activiti 会自动加载 /resources 目录下的 activiti.cfg.xml 文件进行 mysql 数据库中表的创建

感兴趣的话,可以一路点下去,看看这个方法的源码。

一直到 ProcessEngines 的 init() 方法(当系统判断,当前还未在数据库中进行过表的创建动作时),会发现其加载的就是 resource 目录下的 activiti.cfg.xml 文件

当然要是 Spring 项目,则加载的是 activiti-context.xml 文件。Spring 与 Activiti 的集成,本篇暂且不看,留在下一篇去讨论

2 运行

启动运行,发现控制台中日志打印如下

通过执行 org/activiti/db/create/activiti.mysql.create.engine.sql 这个 sql 文件,完成了 Activiti 所需要的 25 张表的创建动作

检查数据库,你会发现,数据库中便生成了 25 张表

(二) 第一个 activiti 流程实例

Activiti 在 eclipseIDEA 中均有流程定义的插件,在 IDEA 中需要安装的插件如下

插件安装完毕之后,重启 IDEA ,然后在 resources 目录下创建一个文件夹 bpmn(专门用于存储 Activiti 的流程文件)

1 流程定义

1)流程文件创建

如下图所示,创建我们的第一个 bpmn 文件

右键,New -> New Activiti 6.x BPMN 2.0 file->填写文件名称,创建好之后发现,其实该文件就是一个 xml 文件

右键该文件,点击:View BPMN(Activiti) Diagram,便可以进行流程的设计了

2)流程文件设计

在空白处,右键点击

可以看到有分别有流程启动事件活动架构网关边界事件紧急捕获紧急抛出事件以及结束事件等,点击对应的右三角,便可以创建对应的事件或活动

比如

通过拖动各个事件右上角的箭头,即可画一条连线。这里我们创建了一个比较简单的请假流程

需要注意,点击空白处,可以更新流程定义的名称与 id,这里,我们的流程定义 idleaveApplication流程定义名称请假流程定义

然后,分别指定两个活动的名称与负责人。一个流程模板每个工作节点的负责人当然不可能是固定的,所以,在这里我们采用 Activiti 所支持的 UEL 表达式,将负责人定义为动态参数:assignee0assignee1

- 创建申请

- 审批申请

好了,这样我们就定义好了一个简单的流程,接下来,进行流程的部署操作,也就是说需要把我们所创建的流程定义文件,真正与数据库的表关联起来

2 流程部署

/*** 部署流程 --RepositoryService*/
@Test
public void testDeploy(){ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService = processEngine.getRepositoryService();Deployment deploy = repositoryService.createDeployment().name("请假申请流程定义").addClasspathResource("bpmn/leaveApplication.bpmn20.xml").deploy();log.info("流程部署id:{}",deploy.getId());log.info("流程部署名称:{}",deploy.getName());
}

因为需要对流程本身进行部署操作,而流程本身属于静态资源,需要进行存储的,所以采用 RepositoryService 这个服务的 API 进行部署操作

运行该测试方法,发现控制台对以下三张表分别进行了插入记录操作

act_re_procdef(流程定义数据表)
act_re_deployment(部署信息表)
act_ge_bytearray(二进制数据表,存储流程定义时的资源文件信息,如这里的 bpmn/leaveApplication.bpmn20.xml 文件)

也就是说我们将这个流程定义文件中的信息分别存入了数据库中关于流程定义的表中

3 启动流程实例

/*** 启动流程 --  RuntimeService**/
@Test
public void testStartProcess(){ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService = processEngine.getRuntimeService();Map<String,Object> map = new HashMap<>();map.put("assignee0","张三");map.put("assignee1","王经理");ProcessInstance instance = runtimeService.startProcessInstanceByKey(key,map);System.out.println("流程定义id:"+instance.getProcessDefinitionId());System.out.println("流程实例 id:"+instance.getId());System.out.println("当前活动的id:"+instance.getActivityId());}

启动流程时,分别指定各个任务的负责人,上述代码表示该请假流程是由张三发起的,审批人是王经理

由于启动一个流程,就表示是流程实例被运行起来了,那么,就使用 RuntimeService 的 startProcessInstanceByKey() 方法进行,其中参数 key 表示指定所启动的流程定义,而 map 则是为其启动之后的流程实例赋值

启动一个流程实例,我们的预期就是完成 Start event 事件,流程进入到张三的“创建申请”这个步骤

那么就会执行完 Start event 这个任务节点,并将相应的信息存入历史信息表中,然后将下一步要执行的“创建申请”这个任务节点的信息,存入运行时信息表中。具体是怎样的呢?

我们运行该启动方法,观察控制台,发现所操作的表如下:

1) 历史表ACT_HI_VARINST    历史变量表
ACT_HI_TASKINST   历史任务实例表
ACT_HI_PROCINST   历史流程实例表
ACT_HI_ACTINST    历史节点表
ACT_HI_IDENTITYLINK 历史人员参与表2) 运行时表ACT_RU_EXECUTION   运行时流程执行实例
ACT_RU_TASK        运行时任务节点表
ACT_RU_IDENTITYLINK  运行时人员参与表
ACT_RU_VARIABLE      运行时变量表

通过查看这些表的变化,结果是符合上述预期的。比如查看一下 ACT_RU_TASK 表,会发现任务节点信息已被存入表中,表示当前将要进行的任务就是创建申请

4 查询代表任务

/*** 查询个人待执行的任务 -- TaskService*/
@Test
public void testFindPersonalTaskList(){ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();TaskService taskService = processEngine.getTaskService();List<Task> taskList = taskService.createTaskQuery().processDefinitionKey(key).taskAssignee("张三").list();for (Task task: taskList) {System.out.println("流程实例id:"+task.getProcessInstanceId());System.out.println("任务id:"+task.getId());System.out.println("任务负责人:"+task.getAssignee());System.out.println("任务名称:"+task.getName());}
}

通过 TaskService 进行查询,分别通过请假流程的 key用户名称,查询该用户名下的所有任务

5 完成任务

@Testpublic void completeProcess(){String assignee = "张三";/*** 完成任务*/ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();TaskService taskService = processEngine.getTaskService();Task task = taskService.createTaskQuery().processDefinitionKey(key).taskAssignee(assignee).singleResult();taskService.complete(task.getId());}

首先查询到所需要完成的任务,然后通过 TaskService 的 complete() 方法进行任务的完成动作(当然实际业务中,需要先进行任务的具体操作,比如添加自己的审批意见等之后才会点击任务的完成,进入下一步骤)

完成任务时,通过查看日志,发现其与启动任务的任务节点所操作的表类似,就是将当前节点所完成的任务转存到历史信息表中,再将下一步需要完成的任务存入运行时信息表中

这里,我们完成创建申请的任务之后,表里面当前需要执行的任务,变成了“审批申请”

说明任务已经成功得到了执行 接下来,采用同样的方法,完成审批申请的任务,我们可以猜想一下,表中的数据又会得到怎样的变化

/*** 完成任务 -- TaskService*/@Testpublic void completeTask(){
//        String assignee = "张三";String assignee = "王经理";/*** 完成任务*/ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();TaskService taskService = processEngine.getTaskService();Task task = taskService.createTaskQuery().processDefinitionKey(key).taskAssignee(assignee).singleResult();taskService.complete(task.getId());}

是的,依旧是一样的操作,将当前节点所完成的任务转存到历史信息表中,只是这里已经是最后一步任务了,所以执行完成之后,也会直接执行 End event

所以,运行完这个步骤之后,我们会发现 act_ru_task 表变成了空的,而 act_hi_taskinst 表中可以看到历史所有执行过的任务实例,包括启动事件、创建申请、审批申请以及结束事件

总结

好了,到这里,我们就轻松完成了一个请假流程的流程的定义流程定义的部署流程实例的启动任务完成的所有操作

会发现,其实 Activiti 的逻辑其实就是通过控制表来进行具体的任务状态操作的。每一步的操作都需要根据一定的逻辑关系,更新数张表来进行控制的

而这些操作,都由 Activiti 框架帮助我们封装好了,提供给我们的只是一个个服务的 API ,从而大大简化了工作流的操作,所以还不快用起来?

文章演示代码地址:

https://github.com/helemile/Spring-Boot-Notes/tree/master/activiti/activiti_demo

嗯,就这样。每天学习一点,时间会见证你的强大~

欢迎大家关注我们的公众号,一起持续性学习吧~

往期精彩回顾

总结复盘

架构设计读书笔记与感悟总结

带领新人团队的沉淀总结

复盘篇:问题解决经验总结复盘

网络篇

网络篇(四):《图解 TCP/IP》读书笔记

网络篇(一):《趣谈网络协议》读书笔记(一)

事务篇章

事务篇(四):Spring事务并发问题解决

事务篇(三):分享一个隐性事务失效场景

事务篇(一):毕业三年,你真的学会事务了吗?

Docker篇章

Docker篇(六):Docker Compose如何管理多个容器?

Docker篇(二):Docker实战,命令解析

Docker篇(一):为什么要用Docker?

SpringCloud篇章

Spring Cloud(十三):Feign居然这么强大?

Spring Cloud(十):消息中心篇-Kafka经典面试题,你都会吗?

Spring Cloud(九):注册中心选型篇-四种注册中心特点超全总结

Spring Cloud(四):公司内部,关于Eureka和zookeeper的一场辩论赛

Spring Boot篇章

Spring Boot(七):你不能不知道的Mybatis缓存机制!

Spring Boot(六):那些好用的数据库连接池们

Spring Boot(四):让人又爱又恨的JPA

SpringBoot(一):特性概览

翻译

[译]用 Mint 这门强大的语言来创建一个 Web 应用

【译】基于 50 万个浏览器指纹的新发现

使用 CSS 提升页面渲染速度

WebTransport 会在不久的将来取代 WebRTC 吗?

职业、生活感悟

你有没有想过,旅行的意义是什么?

程序员的职业规划

灵魂拷问:人生最重要的是什么?

如何高效学习一个新技术?

如何让自己更坦然地度过一天?

Activiti工作流(一):OA 上的那些请假流程如何快速实现呢?相关推荐

  1. Activiti工作流使用之Activiti-app的安装及流程创建

    Activiti使用之Activiti-app的安装及流程创建 文章目录 Activiti使用之Activiti-app的安装及流程创建 一.简介 二.Activiti-app安装 三.流程创建 3. ...

  2. 请假流程如何快速实现(OA )呢?:Activiti工作流

    大家好, 在公司中,每个人都需要经常创建或者审批一些流程,比如说转正申请.请假流程.出差申请等等 那么,你有没有想过,要是你,你会如何实现这些流程的控制逻辑呢? 比如说请假申请,首先需要提前定义好一个 ...

  3. Activiti7工作流-使用Idea开发体验Activti_请假流程---工作流工作笔记006

    然后上一个文章我们已经创建了一个请假流程,然后然后我们用这个请假流程来做一下,审批 来使用一下activiti完成一个简单的工作流 首先我们是来部署,可以看到,部署首先要拿到ProcessEngine ...

  4. Activiti学习(4)简单的请假流程

    在前一篇文章的基础上,编写一个稍微复杂的请假流程,进一步熟悉Activiti的基本知识,并期望能够触类旁通,解决上一篇博文中没有解决的问题.实现过程中,参考了以下文章,在此向作者表示感谢. 1.act ...

  5. Activiti工作流开发笔记(二)-在线流程设计的使用说明

    在线流程设计 点击 [在线设计] 按钮,会打开 流程在线设计器 ,对流程的设计都将在该设计器上进行. 可以看到流程设计器由四部分组成: ①:基本操作工具栏 ②:节点.任务.事件类型列表 ③:流程设计画 ...

  6. Activiti工作流视频教程-基于Activiti5工作流实战企业协同OA办公系统

    Activiti工作流视频教程-基于Activiti5工作流实战企业协同OA办公系统(spring-data-jpa.uur前台组件) 一.Activiti工作流视频教程课程内容简介 在工作流方面,使 ...

  7. Activiti工作流学习之流程图应用详解

    Activiti工作流学习之流程图应用详解 1.目的 了解Activiti工作流是怎样应用流程图的. 2.环境准备 2.1.相关软件及版本 jdk版本:Jdk1.7及以上 IDE:eclipse 数据 ...

  8. Activiti6.0(三)实现一个请假流程

    目录 一.前言 二.实现请假流程 1.制作流程图 2.导出xml流程文件 3.流程部署及运行 4.流程部署时数据库表变化 一.前言 上文SpringBoot已经与Activiti做了基本整合,所有流程 ...

  9. Activiti6.0流程引擎学习——(11)使用IDEA编码实现的请假流程

    本篇博客要使用IDEA来实现之前绘制好的请假流程图.流程图如下: 具体创建这个流程图请看这篇博客:https://blog.csdn.net/JJBOOM425/article/details/850 ...

最新文章

  1. 用ffmpeg把gif动图分离成多张图片和ffmpeg多张图片合成gif动图
  2. 《敏捷迭代开发:管理者指南》—第2章2.9节增量交付
  3. Spring第三篇【Core模块之对象依赖】
  4. c++ 正则表达式_Python教程:进程和线程amp;正则表达式
  5. MyBatis由浅入深学习总结之二:MyBatis解决Java实体类和数据库表字段不一致方法总结
  6. springcloud工作笔记093---springcloud封装按钮权限控制_思路和实现_根据用户拥有的权限控制是否显示某个按钮
  7. if __name__ == __main__:什么意思_【Python】__name__ 是什么?
  8. python源码中的学习笔记_第1章_print 函数与数据类型
  9. 如何更好的优化MySQL数据库
  10. 网络管理:3分钟排障秘技,一招胜过十年功
  11. python-图书管理系统2-整体 代码架构
  12. 408考研经验分享(待更
  13. 华为android打开usb调试模式,华为 PE-CL00 开启USB调试模式
  14. 解决win2003里IIS运行ASP时出现请求资源在使用中的问题
  15. Restricted cubic splines
  16. 关于用户注册登录的问题
  17. 清华AI圈 | 李骏:驰骋在智能汽车科技创新的广阔征途中
  18. 2019年‘泰迪杯’数据分析职业技能大赛A题——个人代码分享
  19. [PC] 微软账号连接不上
  20. 逆向思维--魔兽世界封包分析

热门文章

  1. 解决python利用openpyxl读取excel中公式结果值的问题
  2. 调试stvd遇到的问题
  3. python小游戏——俄罗斯方块
  4. #今日论文推荐# 斯坦福开发微型机器人,改善靶向给药技术
  5. 北京理工大学-嵩天python语言程序设计-9-Python计算生态概览
  6. 如何使用HomePod和Apple TV 4K设置家庭影院音频?
  7. 技术科普:虚拟现实系统
  8. 如何提高idea运行的速度
  9. ZBrush的用途是什么
  10. 【信息学奥赛一本通】2075:【21CSPJ普及组】插入排序(sort)