两款开源.NET工作流引擎 Elsa 与ccflow使用比较

​

相对java开源的工作流程引擎.net开源的工作流程引擎相对较少，这里整理两款.net开源工作流引擎，做一下对比使用。

elsa示例代码:

Githubd地址：https://github.com/zhenl/MyElsa

ccflow下载地址：https://gitee.com/opencc/ccflow

CCFlow

1.           概述：

ccflow是国产的一款流程引擎，好在中文文档，名词概念符合中国人的理解习惯，文档视频教程较多，官网都是开放的。Ccflow对国产化支持较好，国内乱七八糟的数据库兼容。

2.           特性：

ccflow与表单引擎结合在一起，深化了的应用场景的融合，配置大于代码开发这也是设计者的设计理念吧。可以做为中间件的模式与自己的系统开发框架集成，支持基础的以代码驱动流程运转。

3.           正文：

安装与集成，参考他们的手册，下载下来，直接安装上即可，比较顺利与其它软件安装不同的是，自动生成数据库，没有提供数据库脚本，创建一个新的数据库修改一下数据库连接即可,按照向导执行安装。

参考视频教程一步步的创建一个流程，功能点太丰富，主要击中在节点属性，流程属性上，这也是国产软件的“通病”吧，猛地感觉上手困难。

           4.接口定义：

接口高级开发

Ccflow的接口在流程属性里有定义，分为Url调用接口，sdk开发接口。

登录与门户API

1. 首先要进行代码集成与组织机构的集成
2. 其次在自己的系统登录界面，登录成功后要执行ccbpm的框架登录。
3. 所谓的登录就是调用ccbpm的登录接口，如左边的代码所示。

// 如下代码需要写入您的系统校验密码与用户名之后。
string userNo = "zhangsan";
BP.WF.Dev2Interface.Port_Login(userNo);菜单

1. 发起：一个操作员可以发起的工作
2. 待办：等待处理的工作。
3. 在途：我参与的，但是这条流程还没有结束的流程。
4. 抄送：不需要我处理，但是需要我知晓的工作。

发起:
//获得指定人员的可以发起的流程列表,调用这个接口返回一个datatable, 可以参考一个demo实现发起列表的输出。

System.Data.DataTable dtStart = BP.WF.Dev2Interface.DB_GenerCanStartFlowsOfDataTable("zhangsan");待办：
//获得指定人员的待办,调用这个接口返回一个datatable, 可以参考一个demo实现发起列表的输出。
DataTable dtTodolist = BP.WF.Dev2Interface.DB_GenerEmpWorksOfDataTable();在途：
//获得指定人员的在途,调用这个接口返回一个datatable ，代码参考：。
DataTable dtRuning = BP.WF.Dev2Interface.DB_GenerRuning();查询：
//ccbpm给你提供了一个link ，您可以调用这个link ,也可以自己去根据代码实现。

实现列表输出代码，请参考:

运行Demo: ​​查询​​创建WorkID

1. 创建工作ID是启动流程的开始。
2. ccbpm的工作ID是一个Int64位的整数，始终是按照顺序号+1产生的。
3. 该workid全局唯一，并且没有重复性，该信息记录到Sys_Serial，WorkID的生成从100开始。
4. 该workid全局唯一，并且没有重复性，该信息记录到Sys_Serial，WorkID的生成从100开始。

//传入流程编号，调用创建一个工作ID。
Int64 workid = BP.WF. Dev2Interface.Node_CreateBlankWork("001");发送 - 简单发送

1. 工作发送就是让节点向下运动。
2. 调用接口执行发送后，返回一个执行结果的对象，该对象是流程引擎执行过程中的变量。
3. 解析该变量，可以检查出流程是否完成，运行到那一个节点上去了，下一个节点谁可以处理工作？
4. 它的流向，是根据流程设计的规则执行的。
5. 它的接收人，是根据接受人的规则确定的。

//传入流程编号, WorkID执行发送.
BP.WF.SendReturnObjs objs= BP.WF.Dev2Interface.Node_SendWork("001",workid);

// 检查流程是否结束？
bool isFlowOver = objs.IsStopFlow;

// 获得发送到那个节点上去了？
int toNodeID = objs.VarToNodeID;
string toNodeName = objs.VarToNodeName;

// 获得发送给谁了？ 注意：这里如果是多个接受人员就会使用逗号分开。
string toEmpID = objs.VarAcceptersID;
string toEmpName = objs.VarAcceptersName;

// 输出提示信息, 这个信息可以提示给操作员.
string infoMsg = objs.ToMsgOfHtml();

发送 - 要指定发送给谁？发送到那个节点？(万能发送接口)

1. 如果程序员知道下一步要发送给谁，发送到那一个节点的情况下，就可以调用这个接口。
2. 该接口就会摆脱流程引擎设计的网关规则与接受人规则。

//如果确定了（或者自己计算好了）下一步要达到的节点，下一步的接受人，就可以按照如下格式调用。
BP.WF.SendReturnObjs objs = null; objs = BP.WF.Dev2Interface.Node_SendWork("001", workid, 103, "zhangsan" );
//发送给一个人,如果发送给多个人用逗号分开比如: zhangsan,lisi,wangwu

//下面调用方式，是知道要发送到那一个节点，但是不知道要发送给谁，让当前的节点定义的接受人规则来确定。
objs = BP.WF.Dev2Interface.Node_SendWork("001", workid, 103, null);

//下面调用方式，是知道要发送到那些人，但是不知道要发送到那个节点，让当前的节点定义的网关来确定。
objs = BP.WF.Dev2Interface.Node_SendWork("001", workid, 103,"zhangsan");

// 输出提示信息, 这个信息可以提示给操作员.
string infoMsg = objs.ToMsgOfHtml();
撤销

1. 撤销是发送的逆向操作。
2. 撤销可以调用ccbpm提供的撤销窗口完成，这是最简单的方式。
3. 地址为：/WF/WorkOpt/UnSend.htm 参数为: FK_Flow,FK_Node,WorkID,FID，当前流程的4大参数。
4. 如果需要在其他设备上工作，或者要自己写一个移交界面，请参考。
5. 能否被撤销，是有当前活动节点的撤销规则所决定的。
6. 撤销的功能显示在，在途的流程列表里，只有在途的工作才能被撤销。
7. 在途工作：顾名思义，就是我参与的工作，并且工作尚未完成。
8. 回滚流程，是在流程结束后需要重新在指定的节点，让指定的人员从新向下走。

/*
*执行撤销，返回撤销是否成功信息，如果抛出异常就说明撤销失败。
*撤销失败的原因多种，最有可能的是因为当前活动节点不允许撤销规则决定的。
*/string msg= BP.WF.Dev2Interface.Flow_DoUnSend( workID);
回滚

1. 回滚与撤销不同的是回滚是在流程完成以后的操作，并且回滚是由管理员操作的。
2. 回滚流程，是在流程结束后需要重新在指定的节点，让指定的人员从新向下走。

//执行回滚，返回的是回滚执行信息，如果回滚失败，则会抛出异常。
string msg= BP.WF.Dev2Interface.Flow_DoRebackWorkFlow("001", workID, 103, "因为审批错误，需要回滚，从节点103重新开始审批。");退回

1. 退回可以调用ccbpm提供的退回窗口完成，这是最简单的方式。
2. 地址为：/WF/WorkOpt/ReturnWork.htm 参数为: FK_Flow,FK_Node,WorkID,FID，当前流程的4大参数。
3. 如果需要在其他设备上工作，或者要自己写一个退回界面，请参考。

/*
* 1, 获得当前节点可以退回的节点，该接口返回一个datatable。
* 2, 一个节点能够退回到那写节点是由当前节点的退回规则确定的。
* 3, 调用退回需要三个参数：节点编号，工作ID, 流程ID, 对于线性流程FID始终等于0.
*/
System.Data.DataTable dtCanReturnNodes = BP.WF.Dev2Interface.DB_GenerWillReturnNodes(103, workid, 0);
// 返回的是可以退回的节点。

//执行退回，当前的节点是103，要退回的节点是105，
string msg = BP.WF.Dev2Interface.Node_ReturnWork("001", workid, 0, 103, 105, "您的申请信息不完整，请修改后重新发送。", false);
移交

1. 移交也可以调用ccbpm提供的移交窗口完成，这是最简单的方式。
2. 地址为：/WF/WorkOpt/Shift.htm 参数为: FK_Flow,FK_Node,WorkID,FID，当前流程的4大参数。
3. 移交就是把自己所要做的工作交给其他人处理。
4. 如果需要在其他设备上工作，或者要自己写一个移交界面，请参考。

/*
* 调用移交接口，传入必要的参数执行移交.
* FID 在线性流程上始终等于0.
*/
BP.WF.Dev2Interface.Node_Shift("001", 103, workid, 0, "zhangsan", "因我需要出差，所以特把工作移交给您。");
/*
* 撤销移交
* 如果在移交之后，发现不需要移交，就需要撤销回来，调用撤销移交接口。
*/BP.WF.Dev2Interface.Node_ShiftUn("001", workid);加签

1. 加签也可以调用ccbpm提供的加签窗口完成，这是最简单的方式。
2. 地址为：/WF/WorkOpt/Shift.htm 参数为: FK_Flow,FK_Node,WorkID,FID，当前流程的4大参数。
3. 加签就是把自己所要做的工作参考其他人意见，或者让其他人处理。
4. 加签有两种模式：1，加签后由加签人发送到下一个节点。2，加签后由让加签人发送给当前人，由当前人发送给下一个节点。
5. 如果需要在其他设备上工作，或者要自己写一个加签界面，请参考。

/*
* 调用加签接口，传入必要的参数执行.
* FID 在线性流程上始终等于0.
*/
//技术人员zhangsan接受工作后，点击发送还会发送给当前人员，由当前人员发送给下一节点。
string info1= BP.WF.Dev2Interface.Node_Askfor(workid, BP.WF.AskforHelpSta.AfterDealSendByWorker, "zhangsan", "这里需要您出具技术鉴定意见.");

//技术人员填写后，直接就发送了下一节点.
string info2 = BP.WF.Dev2Interface.Node_Askfor(workid, BP.WF.AskforHelpSta.AfterDealSend, "zhangsan", "这里需要您出具技术鉴定意见.");

//技术人员回复加签，在由当前人发送到下一个节点。
string infoReply = BP.WF.Dev2Interface.Node_AskforReply("001", 103, workid,0, "我已经出具了技术鉴定意见，请参考.");结束流程

1. 流程结束有三种方式
2. 第一种走到最后一个节点正常结束。
3. 第二种在特定的节点上，用户需要终止流程向下运动(与删除流程不同)。
4. 第三种在特定的节点上，用户需要删除流程。

/* * 手工的结束流程,这种方式会记录日志.
*/string overInfo = BP.WF.Dev2Interface .Flow_DoFlowOver( workID, "该供应商找不到了，要结束掉该流程。");
/* * 删除流程,
* 删除流程有多种方式，用户可以根据自己的需求，调用不同的方式.
* 最后一个参数是是否删除子流程.
*/

//按照标记删除流程
string delInfo0 = BP.WF.Dev2Interface .Flow_DoDeleteFlowByFlag( workID, "我不需要请假了", true);

//彻底的删除流程，无日志记录.
string delInfo1 = BP.WF.Dev2Interface .Flow_DoDeleteFlowByReal( workID, "我不需要请假了", true);

//彻底的删除流程,有日志记录.
string delInfo2 = BP.WF.Dev2Interface .Flow_DoDeleteFlowByWriteLog("001", workID, "我不需要请假了", true);

代码事件定义

在流程属性里提供了开发接口demo, 这是提供开发者用的，需要写一个子类，然后编译里ddl里面去，通过反射，流程在运行的过程中，可以调用它。

开发人员只要重写这些事件方法即可，比如发送前，发送成功时，发送失败时，流程结束前，结束后，退回前，退回后等等。

Elsa 

5.           概述

微软的Workflow Foundation基于.NET Framework，并且没有向.NET Core迁移的计划。

我们的很多项目使用了工作流引擎，这些项目向.NET Core以及更高版本迁移时遇到了不少问题，一直在寻找/开发适合的工作流引擎。

找到一些开源的项目，可以解决一些问题，还有些项目不是基于.NET生态的，但我希望能有一个长期稳定的基于.NET生态的项目，能够满足多种场景，可以替换原来的Workflow Foundation。

6.           特性

1、同时支持编程工作流定义和配置工作流定义，最好有图形化的管理工具。

2、支持长期工作流。

3、支持有限状态机类型的工作流定义。

4、工作流引擎可以集成在应用中，也可以独立部署为工作流服务器，采用Web API的方式调用。

在我们跟踪的工作流相关项目中，Elsa一直在稳步发展，最新的版本（2.9）已经基本可以满足我们的上述要求了，在以后的版本也会增加对有限状态机的支持。

这里简单介绍一下如何创建工作流服务器和图形化的工作流配置管理应用。

7.           正文

首先，使用Visual Studio 2022创建一个空的ASP.NET Core Web应用，名称为MyElsaServer。

项目创建完成后，使用NuGet包管理器，安装如下程序包：

Install-Package Elsa

Install-Package Elsa.Activities.Http

Install-Package Elsa.Persistence.EntityFramework.Sqlite

Install-Package Elsa.Server.Api

然后，修改项目的Properties/launchSettings.json，去掉通过IIS Express启动的选项:

{

}

最后，修改Program.cs：

using Elsa.Persistence.EntityFramework.Core.Extensions;

using Elsa.Persistence.EntityFramework.Sqlite;

var builder = WebApplication.CreateBuilder(args);

var elsaSection = builder.Configuration.GetSection("Elsa");

// Elsa services.

builder.Services

// Elsa API endpoints.

builder.Services.AddElsaApiEndpoints();

// Allow arbitrary client browser apps to access the API.

// In a production environment, make sure to allow only origins you trust.

builder.Services.AddCors(cors => cors.AddDefaultPolicy(policy => policy

);

var app = builder.Build();

app

app.Run();

最后，在appSettings.json中增加服务器地址的定义：

启动项目，会出现欢迎界面：

服务器可以运行了，但还没有定义工作流，现在我们创建图形化的工作流定义和管理应用，向工作流服务器发布工作流，并查看工作流的执行情况。

在解决方案中增加一个新的ASP.NET Core Web空项目，命名为MyElsaDashboard，修改Properties/launchSettings.json,将项目改为自启动:

{

}

在项目中添加如下程序包：

Install-Package Elsa.Designer.Components.Web

修改Program.cs：

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddRazorPages();

var app = builder.Build();

app.UseStaticFiles();

app.UseRouting();

app.UseEndpoints(endpoints => { endpoints.MapFallbackToPage("/_Host"); });

app.Run();

然后在项目中创建Pages文件夹，在文件夹中添加两个Razepage页面，名称为_ViewImports.cshtml和_Host.cshtml，_ViewImports的内容如下：

@ addTagHelper *, Microsoft .AspNetCore.Mvc.TagHelpers

_Host.cshtml的内容如下：

@page "/"

<!DOCTYPE html>

<html lang="en">

<head>

</head>

<body>

<elsa-studio-root server-url="http://localhost:5298" monaco-lib-path="_content/Elsa.Designer.Components.Web/monaco-editor/min">

</elsa-studio-root>

</body>

</html>

请注意上面的server-url属性，这里指向我们前面创建的Elsa服务器地址。

现在我们修改解决方案的启动项目，设置为两个项目同时启动：

在Visual Studio中执行启动，管理界面如下：

选择Workflow Definitions进入流程定义管理界面，点击“Create Workflow”创建新的流程：

点击Start,然后选择Http->Http EndPoint,定义流程的入口url:

设置完成后按Save保存，可以看到多个一个环节，在这个环节下点击“+”图标可以继续添加环节，这里选择HttpResponse:

在Advanced选择卡中，选择Status Code为Ok，添加完成后，流程如下：

流程定义完成了，点击Publish发布流程到流程服务器。

流程发布后，可以在流程服务器执行流程。

我们在浏览器访问http://localhost:5298/hello-world，可以看到流程执行的结果：

回到流程管理应用，选择Workflow Instances,可以看到刚刚执行完成的流程实例：

点击流程Id,可以查看流程执行的详细过程：

到此，我们完成了工作流服务和管理应用的创建。

示例代码

Githubd地址：https://github.com/zhenl/MyElsa