Slickflow.NET 开源工作流引擎高级开发(一)--流程实现外部事件调用和变量存储

前言:流程实现基本流转功能外,通常也需要调用外部事件,用于和业务系统的交互,同时存储一些流程变量,用于追踪和记录业务数据变化对流程流转的影响。

1. 流程事件

流程执行过程中,伴随各种事件的发生,而且是存在于整个流程的生命周期,即从流程启动一直到流程结束的整个过程都有事件发生。这些事件的发生,业务系统通常也需要知道一些流程过程的关键节点,或里程碑状态。我们统称为流程事件。

1.1  流程事件触发类型

流程事件类型的定义是按照事件发生的位置来确定划分,跟流程直接有关的比如有:启动、运行、撤销、退回、返送、跳转、返签和结束等。而跟活动有关的事件类型有:创建、执行和结束等。我们可以用下图来描述常见的事件触发:

1.2  流程事件触发实现

流程事件的触发,是按照先订阅,后触发的机制来实现。订阅(Subscribe)是流程服务接口开放出来的方法,可以直接在这个方法里面注册匿名函数来绑定事件。程序代码如下:

IWorkflowService wfService = new WorkflowService();
var wfResult = wfService.CreateRunner(runner.UserID, runner.UserName)
         .UseApp(runner.AppInstanceID, runner.AppName, runner.AppInstanceCode)
         .UseProcess(runner.ProcessGUID, runner.Version)
         .NextStep(runner.NextActivityPerformers)
         .IfCondition(runner.Conditions)	//condition on the transiton
         .Subscribe(EventFireTypeEnum.OnActivityExecuting, (activityInstanceID, activityCode, delegateService) => {
             if (activityCode == "Task1")
             {
                 delegateService.SetVariable("name", "book-task1");
                 delegateService.SetVariable("amount", "50");
             }
             return true;
         })
         .Run();

  

2. 事件类型节点

BPMN规范里面,涉及到事件类型的节点,虽然不同于任务类型的节点,但是事件类型的节点通常都是表示一种流程的状态,比如流程的开始和结束是最基本的两个状态。中间事件(Intermediate Event)是本次我们主要涉及到的事件类型的节点,其它事件类型的节点将在后期的文章中描述到。

2.1 中间事件(Intermediate Event)

中间事件(Intermediate Event)类型的节点一般用于流程中间状态的变换,而且可以作为流程里程碑的事件或状态触发,用于通知业务系统流程的里程碑状态已经发生,或者也可以收到业务系统的反馈的信息,用于一些流程下一步路径的解析。

比如在中间事件触发时,只有从业务系统中读取到业务变量,然后传入流程的下一步分支选择条件变量中,才能确定下一步的流转路径。这样的处理过程是经常的一种业务场景。一个有中间事件类型节点的流程图示意如下:

2.2 节点上事件的定义

在流程设计器中,节点上的事件定义主要有两个属性:事件触发的位置(执行前和执行后)、以及事件执行的表达式。一个定义示例描述如下:

触发位置:执行前

表达式:Slickflow.Module.External.OrderSubmitService

2.3 业务服务的代码实现

上文中提到的表达式是业务服务的程序代码,业务服务的逻辑实现,除了本身的功能代码实现,还需要继承如下的两个接口: ExternalServiceBase 和 IExternalService。 主要用于明确定义Execute()执行方法,然后在引擎内部执行过程中,在调用和执行这个接口方法。具体代码示例如下:

 /// <summary>
    /// 订单提交服务类(对应订单流程中订单提交节点)
    /// </summary>
    public class OrderSubmitService : ExternalServiceBase, IExternalService
    {
        /// <summary>
        /// 业务逻辑前置调用方法
        /// </summary>
        public override void Execute()
        {
            //实现用户自己的业务逻辑
            var id = DelegateService.GetID();
            var amount = DelegateService.GetVariable("amount");

            DoSomethingElse(amount, 20);
        }

        /// <summary>
        /// 业务逻辑具体实现方法
        /// </summary>
        /// <param name="amount"></param>
        /// <param name="newAmount"></param>
        private void DoSomethingElse(string amount, int newAmount)
        {
            var intAmount = 0;
            int.TryParse(amount, out intAmount);

            if (intAmount < newAmount)
            {
                DelegateService.SetVariable("amount", newAmount.ToString());
            }

            //调用其它业务处理逻辑
            var session = DelegateService.GetSession();

            //实现其它数据库业务逻辑
            //.............................
        }
    }

  

3. 委托服务的内部机制

委托服务用于统一处理所有流程发生的时间,跟事件交互过程中,除了触发事件本身以外,还要考虑引擎内部和外部业务系统之间的交互。比如流程变量的保存和读取就是一种交互应用。

3.1 委托服务接口

委托服务接口定义出事件订阅时候的接口类型,具体代码如下:

 /// <summary>
    /// 委托接口
    /// </summary>
    public interface IDelegateService
    {
        int ID { get; set; }
        int GetID();
        IDbSession GetSession();
        string GetVariable(string name, Nullable<ScopeTypeEnum> scopeType = null);
        void SetVariable(string name, string value, Nullable<ScopeTypeEnum> scopeType = null);
        string GetCondition(string name);
        void SetCondition(string name, string value);
        T GetInstance<T>(int id) where T : class;
    }

3.2 委托服务继承类

继承委托服务的接口实现目前有两种类型,一是流程委托服务接口,而是活动委托服务接口。实现的主要目的是对流程变量的读取和存储,还有给外部应用展示流程实例的关键信息。

4. 流程变量

流程变量是流程流转过程发生的一些数据变化,这些变量一般是来自业务系统的关键参数,而且在流程流转时,通过条件表达式传入,可以决定流程流转下一步的路径选择。

4.1 流程变量类型

流程变量类型分为全局变量和局部变量。在程序中也可以命名为流程变量(ProcessVariable)和活动变量(ActivityVariable)。

4.2 流程变量存储

流程变量的存储是持久化存储在数据库表(WfProcessVariables)中,变量名和数值的key-value是其记录格式。

 delegateService.SetVariable("name", "book-task1");
 delegateService.SetVariable("amount", "50");

  

5. 总结

流程引擎跟外部事件的交互实现,可以丰富业务过程的状态变化和响应,通过流程变量的存储,记录业务过程中的关键数据变化,同时也做到了对流程分支选择的路径跟踪。程序开发人员可以通过实现外部事件的委托服务,然后再订阅流程过程事件,来彻底实现业务系统跟引擎内部的进一步协作整合。

原文地址:https://www.cnblogs.com/slickflow/p/10332493.html

时间: 2025-01-08 00:02:31

Slickflow.NET 开源工作流引擎高级开发(一)--流程实现外部事件调用和变量存储的相关文章

Slickflow.NET 开源工作流引擎基础介绍(二)

集成流程引擎的必要性 业务过程的变化是在BPM系统中常见的现象,企业管理层需要不断优化组织架构,改造业务流程,不可避免地带来了业务流程的变化,企业信息系统就会随之面临重构的可能性.一种直接的方式是改造业务代码,适应业务过程的变化,这将会面临不断改写代码的需求:还有一种方式是使用流程引擎控制业务过程的变化,将改写业务代码的操作交由流程引擎,通过流程引擎解析业务规则,驱动业务过程流转,从而将改写业务代码的可能性降到最低. 显而易见,流程引擎带来的好处是为了更好解决业务过程变化后带来的重构风险,信息系

Slickflow.NET 开源工作流引擎基础介绍(十)--邮件轮询异步发送模块集成

前言:在任务数据生成时,为了让办理任务的用户及时获取到待办任务的主题和内容,需要发送通知类的消息,而电子邮件和手机端的短信通知则是比较普通的消息发送.本文是针对电子邮件异步发送模块的实现来做实例说明. 1. 邮件发送通知的位置 通常任务数据生成时,就需要发送一封邮件通知,邮件内容包括正文和页面地址信息:任务办理人员在接收到邮件后,会及时登录系统进行任务处理,发送邮件通知的好处就在于方便和及时. 但是邮件发送并不是所有的业务客户都需要的一个功能,它不便于紧耦合地在引擎流转环节,即跟任务数据的生成绑

Slickflow.NET 开源工作流引擎基础介绍(三)

1. Slickflow Designer 技术优势 1) 基于HTML5技术,兼容常见浏览器; 2) 纯Javascript / JsPlumb 脚本实现SVG图形化显示; JsPlumb允许您使用SVG.Canvas 或者 VML链接屏幕上的元素,这些取决于您使用的浏览器的能力; 3) 图形元素参考BPMN定义,XML存储,更加适合商务人员理解业务过程定义; 4) 富客户端开发技术,使用JQuery/SlickGrid等组件,用户体验良好; 4) 前端架构开放,可允许程序开发人员扩展新的节点

.net开源工作流引擎ccflow

关于济南驰骋信息技术有限公司的.net开源工作流引擎 驰骋工作流引擎,工作流程管理系统:简称ccflow,驰骋一体化解决方案简称ccport. ccflow是济南驰骋信息技术有限公司向社会提供的一款100%开源软件,我们向社会承诺,核心代码100%的开源,多年以来我们践行自己的诺言,努力提高产品质量,奉献社会,成为了国内知名的老牌工作流引擎. ccflow1.0 发展于2003年,xxx省税收业务管理信息系统. ccflow5.0 诞生于2013年北京亿阳信通股份有限公司,应用于xx省电信,xx

几种开源工作流引擎的简单比较(转)

摘要:目前开源工作流引擎用的最多的是jbpm , 各种特性都不错, 文档也比较多, 下面只简单列举一下 目前开源工作流引擎用的最多的是jbpm , 各种特性都不错, 文档也比较多, 下面只简单列举一下 其他几种工作流引擎的特性.   Apache ODE Enhydra Shark Bonita Open Business Engine Eclipse JWT  支持的流程建模标准  WS-BPEL 2.0,流程定义必须使用该标准编写才能执行 WfMC和OMG标准 符合WfMC规范 遵循WfMC

Java三大主流开源工作流引擎技术分析

Java三大主流开源工作流引擎技术分析 首先,这个评论是我从网上,书中,搜索和整理出来的,也许有技术点上的错误点,也许理解没那么深入.但是我是秉着学习的态度加以评论,学习,希望对大家有用,进入正题! 三大主流工作流引擎:Shark,osworkflow,jbpm! Shark的靠山是Enhydra.Enhydra做过什么呢?多了!从j2ee应用服务器,到o/r mapping工具,到这个工作流引擎等等.为什么Shark的持久层采用DODS来实现?就是因为他们是一家人. Jbpm的靠山是jboss

开源工作流引擎内核主要关心的是什么?

JBPM是开源工作流引擎中最突出的一种,这种引擎模式现在使用的范围是比较广的.目前,开源工作流引擎有很多,不同的开源工作流引擎不管是设计还是实现方式都是不同的,其选型.算法.机制等各不相同.说起开源工作流引擎内核,我相信大家最关心的莫过于其引擎内核问题了.开源工作流的引擎内核最关注的是什么呢?下面我们一起来看看: 其实,引擎内核所关注的,只是一个抽象层面的问题,它的职责是很精简的,主要是为了确保流程从一个节点运行到另一个节点上,保证能够执行当前的节点.概括地来说,开源工作流引擎内核所关注的问题有

java开源工作流引擎osworkflow

目前实际用到的三个方法 初始化:initialize(String workflowName, int initialAction, Map inputs) 查询:query(WorkflowExpressionQuery query) 操作:doAction(long id, int actionId, Map inputs) ---- 最重要的两步是初始化和操作,查询可以自己定义查询,因为在初始化和操作的时候会操作表中数据,查询不会修改数据. 目前就本工作流理解的是根据配置文件记录流程的操作

开源工作流引擎 Workflow Core 的研究和使用教程

目录 开源工作流引擎 Workflow Core 的研究和使用教程 一,工作流对象和使用前说明 二,IStepBuilder 节点 三,工作流节点的逻辑和操作 容器操作 普通节点 事件 条件体和循环体 节点的异步或多线程 用于事务的操作 四,条件或开关 迭代 条件判断 节点并发 五,其它 开源工作流引擎 Workflow Core 的研究和使用教程 一,工作流对象和使用前说明 为了避免歧义,事先约定. 工作流有很多节点组成,一个节点成为步骤点(Step). 1,IWorkflow / IWork