为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

时间:2022-09-04 07:39:54

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

为什么使用工作流引擎?

反证法,如果不使用工作流引擎,先以请假流程举例,从头开始开发流程的业务逻辑:(来看看会出现哪些问题?使用工作流能解决哪些问题?又会带来什么问题?)

一、业务流程梳理

“流程定义可能是hardcoding或者存储在某张表

  1. 总经理审批
  2. 结束
  3. 结束
  4. 员工发起请假单
  5. 组长审批
  6. 请假天数小于等于2天
  7. 请假天数大于2天

二、每个节点都要记录当前操作人和判断下个节点

  • if(day>2)
  • 总经理审批 (记录谁发起的以及判断下个节点)
  • 结束
  • if(day<=2)
  • 结束
  • 同意或者拒绝
  • nextUserId根据上面的流程定义获取
  • 存入transfer状态流转表, userId nextUserId等 驱动到下一个节点
  • 员工填写请假单并提交
  • nextUserId根据上面的流程定义获取
  • 存入leave表,创建人,创建时间
  • 存入transfer状态流转表, userId nextUserId等 驱动到下一个节点
  • 员工发起请假单 (记录谁发起的以及判断下个节点)
  • 组长审批 (记录谁发起的以及判断下个节点)
  • 请假天数小于等于2天 (记录谁发起的以及判断下个节点)
  • 请假天数大于2天 (记录谁发起的以及判断下个节点)

如果再来个用车流程、报销流程等,那么你的项目将无法维护

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

不使用工作流存在以下问题

  • 流程设计没有可视化
  • 流程没有版本管理,热部署等
  • 每个活动的流转都需要硬性判断下一步活动节点及其操作人
  • 每次操作都需要维护业务数据和流程的相关数据
  • 缺乏数据管理、流程监控等功能

工作流优缺点

对上面共性问题进行抽象,抽象,抽象,可以得出下面的视图。

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

把业务和流程进行了抽象分离,降低耦合,

优点

  • 具有可视化的流程设计工具
  • 业务数据和流程数据的分离,可以进行更专注的性能优化,业务划分
  • 内置API能很好的完成常见的功能场景
  • 具有完善的流程监控体系
  • 具备大量的自定义扩展接口

缺点

需要额外的学习成本

什么是工作流引擎

所谓工作流引擎是指workflow作为应用系统的一部分,并为之提供对各应用系统有决定作用的根据角色、分工和条件的不同决定信息传递路由、内容等级等核心解决方案。工作流引擎包括流程的节点管理、流向管理、流程样例管理等重要功能。(来自百科)

尝试自己构建工作流引擎

以下内容取自:https://www.cnblogs.com/duck-and-duck/p/14436373.html

并进行了部分修改。

第1天

我查了一天啥是工作流,然后做出了如下版本:

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

按顺序添加任意个审批人组成一个链表,最后加一个结束节点

记录当前审批人,当审批完后,审批人向后移动一位

当审批人对应结束节点时,流程结束

“每个节点执行人是hardcoding的

第二天

发现部分业务需要支持会签节点。

我又查了一天啥是会签节点,发现会签节点就是一个大节点,里面有很多审批人,当这个大节点里的所有人都审批通过后,才能进入下一个节点。

翻了原来的链表式设计:

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

第三天

发现部分业务需要支持条件节点。

要根据表单的内容确定下一步进入哪个分支。

第四天

审批人多加两种类型,比如可以从表单中选择下一个审批人,还有根据发起人不同选择不同的审批人。

第五天

需要满足xxx需求,卒。。。

“看来实现一个工作流引擎还是蛮难的,那有什么可选的*吗

有哪些选型方案呢

工作流整体流程如下:

建模(事前) 运行 (事中) 管理 (事后) 监控(全生命周期)
流程设计 engine驱动 数据管理 流程监控

基于bpmn标准进行流程定义

什么是BPMN

BPMN 是 Business Process Modeling Notation 的简称,即业务流程建模与标注。BPMN 定义了一个业务流程图,这个流程图被设计用于创建业务流程操作的图形化模型 。而一个业务流程模型( Business Process Model ),指一个由图形对象( graphical objects )组成的网状图,图形对象包括活动(activities) 和用于定义这些活动执行顺序的流程控制器( flow controls )。

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

代表实现产品如下:

  • JBPM
  • Activiti
  • Flowable

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

国产自定义

  • snaker
  • jflow

如何使用SnakerFlow工作流

仅列出常见功能场景实现,具体介绍和详情文档参见:Spring Boot 集成SnakerFlow流程引擎,简介、功能列表、详细解读、扩展点分析

“?? ?? ?? 已开源基于SnakerFlow轻量级工作流引擎的脚手架项目 easy-admin

“详情参见:终于写了个开源项目,easy-admin 为打造一款简单、轻量级的后台管理系统脚手架

以请假流程来看下数据库中数据流转情况

相关源码已开源

已开源基于SnakerFlow轻量级工作流引擎的脚手架项目 easy-admin

详情参见:终于写了个开源项目,easy-admin 为打造一款简单、轻量级的后台管理系统脚手架

初始状态

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_process

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

员工发起请假申请

  1. args.put("user1",StpUtil.getLoginIdAsString());
  2. args.put("user2","yang");
  3. args.put("user3","zhang");
  4. Objectday=args.get("day");
  5. if(day!=null){
  6. args.put("day",Integer.valueOf((String)day));
  7. }b
  8. snakerEngineFacets.startAndExecute(name,version,StpUtil.getLoginIdAsString(),args);

员工laker发起一个请假单,请假3天

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

laker的待办列表为空,已办列表如下:

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

yang的待办列表如下:

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

当前监控流程图

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_order

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_task

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_task_actor

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_hist_order

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_hist_task

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

wf_hist_task_actor

为什么使用工作流引擎,什么是工作流引擎,工作流引擎选型以及如何使用

常见功能

流程标题

我们经常希望待办任务列表有一列是流程实例的名称,即标题,例如,我们希望流程的标题是:张三 - 2019-12-04 16:40:20的请假申请 ,通常会采用一个命名规则:发起人+发起时间+流程模型名称把它作为流程的标题。这时候就希望启动流程实例时可以设置流程实例的名称。

  1. args.put(SnakerEngine.ID,"张三-2019-12-0416:40:20的请假申请");
  2. snakerEngineFacets.startAndExecute(name,version,StpUtil.getLoginIdAsString(),args);

发起申请

  1. args.put(SnakerEngine.ID,"张三-2019-12-0416:40:20的请假申请");
  2. snakerEngineFacets.startAndExecute(name,version,StpUtil.getLoginIdAsString(),args);

我的发起

  1. QueryFilterfilter=newQueryFilter();
  2. filter.setOperator(operator);
  3. filter.orderBy("create_Time").order(DESC);
  4. snakerEngineFacets.getEngine().query().getHistoryOrders(page,filter);

我的待办

  1. Pagepage=newPage<>(30);
  2. snakerEngineFacets.getEngine().query().getWorkItems(page,
  3. newQueryFilter().setOperator(operator));

我的已办

  1. Pagepage=newPage<>(30);
  2. snakerEngineFacets.getEngine().query().getHistoryWorkItems(page,
  3. newQueryFilter().setOperator(operator));

催办

  1. Listtasks=snakerEngineFacets.getEngine().query().getActiveTasks(newQueryFilter().setOrderId(orderId));
  2. 根据这个task跟指定人发消息

转办

转办任务(换当前办理人,或者叫变更当前办理人)

  1. snakerEngineFacets.transferMajor(taskId,operator,nextOperators);

驳回

驳回/退回上一步/退回至(即退回到历史某一个节点)

  1. snakerEngineFacets.executeAndJump(taskId,operator,args,nodeName);

撤回

根据历史任务id,撤回由该历史任务派发的所有活动任务,如果无活动任务,则不允许撤回

  1. snakerEngineFacets.getEngine().task().withdrawTask(taskId,operator);

抄送

实例的抄送类似于邮箱里面的抄送功能,一般用于将该流程实例抄送给领导查阅。

  1. 新增表wf_cc_order根据实例id、创建人、抄送人创建抄送记录engine.order().createCCOrder(StringorderId,Stringcreator,String...actorIds)更新状态用于更新抄送记录为已经阅读engine.order().updateCCStatus(StringorderId,String...actorIds)

加签

加签(增加另一人或多人的审批)

  1. engine.task().addTaskActor(StringtaskId,1,String...actorIds)

会签

会签(通常用于审批后给相关的人签字确认,以获得工作上的协调。)

snaker的会签目前相对比较简单,仅仅是根据任务节点的performType属性值确定是否产生多个相同任务。

performType的值有两种,分别是ANY、ALL。

ANY多个参与者时,任何一个完成任务即继续流转 (或签)

ALL多个参与者时,所有都需要完成任务才能继续流转

会签只需要在流程定义时,将任务节点的属性performType值设置为ALL即可,当调用api时传递多个参与者时,则自动派发与参与者数量相同的任务。会签任务必须等待所有参与者完成后,才继续流转

或签

同上

已开源基于SnakerFlow轻量级工作流引擎的脚手架项目 easy-admin详情参见:终于写了个开源项目,easy-admin 为打造一款简单、轻量级的后台管理系统脚手架