Slickflow.NET 开源工作流引擎高级开发(五) -- 引擎和外部事件的交互

程序员文章站 2022-04-15 15:12:23

前言：引擎组件的基本职责是负责流程流转，但是在流转过程中，除了对内部控制逻辑进行实现外，也不可避免的要去调用或者响应外部事件。本文主要描述外部事件的类型，以及调用方法过程。 1. 外部事件的类型外部事件的类型是随着引擎功能的需要而不断增加，开发人员也可以在此基础上进行扩展，目前主要常用的事件类型如 ......

前言：引擎组件的基本职责是负责流程流转，但是在流转过程中，除了对内部控制逻辑进行实现外，也不可避免的要去调用或者响应外部事件。本文主要描述外部事件的类型，以及调用方法过程。

1. 外部事件的类型

外部事件的类型是随着引擎功能的需要而不断增加，开发人员也可以在此基础上进行扩展，目前主要常用的事件类型如下：

public enum actionmethodtype
{
　　localmethod, //本地程序
　　webapi,  //调用webapi程序
　　sql,    //执行sql脚本
　　storeprocedure,    //调用存储过程
　　python,     //执行python脚本
}

2. 外部事件的调用方法

2.1 本地程序

要调用的外部服务类，需要首先继承externalservicebase类，同时实现iexternalservice接口。下面的ordersubmitservice类就是一个具体实现类。请参考slickflow.module.external项目。

/// <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();
             //实现其它数据库业务逻辑
            //.............................
        }
}

在引擎流转执行过程中，当解析到节点上有调用外部事件的action定义时，将会使用反射方法，查找到组件是否有ordersubmitservice类，并且是实现了extneralservicebase和iexternalservice 接口的服务类，才能被执行其中的execute()方法，必须满足上述的查找基类继承和接口实现条件才能被反射执行，否则是不能被执行的。这样可以确保是执行到了明确定义的事件程序代码。

2.2 webapi

步骤1：节点属性上的事件定义