LuBan.ApprovalFlow 2026.7.13.2

English | 中文

LuBan.ApprovalFlow

作者: yswenli | 联系邮箱: yswenli@outlook.com | 代码仓库: https://github.com/yswenli/luban-framework

JSON 定义流程、代码驱动审批——一个轻量级审批流引擎，支持会签、网关路由、HTTP 回调和自动推进。

Related Projects: LuBan.Framework | LuBan.Common | LuBan.DI | LuBan.EventBus | LuBan.Orm | LuBan.Web.Core

为什么选择 LuBan.ApprovalFlow？

市面上的审批流引擎要么太重（Activiti/Flowable 需要独立部署），要么太封闭（SaaS 平台无法定制）。
LuBan.ApprovalFlow 是一个嵌入式审批流引擎：用 JSON 定义流程结构，用 C# 扩展节点行为，无需额外基础设施，直接跑在你的 ASP.NET Core 进程里。

快速预览

// 1. 注册服务
services.AddApprovalFlow();

// 2. 启动流程
var engine = ServiceProviderUtil.GetRequiredService<ApprovalFlowEngine>();
var response = await engine.StartFlowAsync(new StartFlowRequest
{
    FormPayload = new Dictionary<string, object> { ["amount"] = 50000 },
    Variables = new Dictionary<string, object> { ["deptId"] = 101 }
}, definition, repository);

// 3. 处理审批
await engine.ProcessApprovalAsync(new ProcessApprovalRequest
{
    RecordId = response.RecordId,
    ApproverId = "user_001",
    Approved = true,
    Comment = "同意"
});

技术栈 & 依赖

安装

dotnet add package LuBan.ApprovalFlow

功能全景

核心架构

FlowEngine (单例，管理线程池 + 定时检查)
  └── ApprovalFlowEngine (核心引擎，~700行)
        ├── FlowBuilder — 从 JSON 加载流程定义，缓存执行器
        ├── FlowExecutor — 执行流程步骤
        ├── RuleEngine — 条件网关路由
        ├── AggregationEvaluator — 会签聚合（AND/OR/比例）
        ├── HttpCallbackExecutor — HTTP 回调通知
        └── Node Handlers
              ├── StartNodeHandler
              ├── EndNodeHandler
              ├── TaskNodeHandler
              ├── UserNodeHandler
              ├── GatewayNodeHandler
              └── HttpNodeHandler

流程引擎

节点处理器

规则 & 聚合

持久化实体

扩展接口

DI 注册

// 注册审批流核心服务
services.AddApprovalFlow(options);

// 或从配置自动加载 JSON 流程定义
services.AddApprovalFlow(configuration);

// 注册自定义持久化
services.AddApprovalRepository<MyApprovalRepository>();

// 注册事件监听器
services.AddApprovalFlowListener<MyFlowEventListener>();

// 注册用户服务
services.AddApprovalUserService<MyUserService>();

// 注册通知服务
services.AddApprovalNotificationService<MyNotificationService>();

// 注册统计更新器
services.AddStatisticsUpdater<MyStatisticsUpdater>();

配置

在 appsettings.json 中配置：

{
  "ApprovalFlowOptions": {
    "DataDir": "data",
    "AutoApproval": true,
    "ThreadPoolSize": 10
  }
}

代码示例

定义流程（JSON）

{
  "Key": "leave_approval",
  "Name": "请假审批",
  "Nodes": [
    { "Id": "start", "Type": "Start", "Name": "开始" },
    { "Id": "manager", "Type": "User", "Name": "经理审批", "Assignee": "${managerId}" },
    { "Id": "gateway1", "Type": "Gateway", "Name": "金额判断" },
    { "Id": "director", "Type": "User", "Name": "总监审批", "Assignee": "${directorId}" },
    { "Id": "end", "Type": "End", "Name": "结束" }
  ],
  "Edges": [
    { "From": "start", "To": "manager" },
    { "From": "manager", "To": "gateway1" },
    { "From": "gateway1", "To": "director", "Condition": "amount > 10000" },
    { "From": "gateway1", "To": "end", "Condition": "amount <= 10000" },
    { "From": "director", "To": "end" }
  ]
}

启动流程

var engine = ServiceProviderUtil.GetRequiredService<ApprovalFlowEngine>();
var repository = ServiceProviderUtil.GetRequiredService<IApprovalRepository>();

// 加载流程定义
var builder = ServiceProviderUtil.GetRequiredService<FlowBuilder>();
var executor = await builder.CreateExecutorFromJsonFileAsync("data/leave_approval.json");
var definition = executor.Definition;

// 启动流程
var response = await engine.StartFlowAsync(new StartFlowRequest
{
    FormPayload = new Dictionary<string, object>
    {
        ["applicant"] = "张三",
        ["days"] = 3,
        ["reason"] = "年假"
    },
    Variables = new Dictionary<string, object>
    {
        ["amount"] = 5000,
        ["managerId"] = "user_002"
    }
}, definition, repository);

Console.WriteLine($"流程已启动，RecordId: {response.RecordId}");

处理审批

var result = await engine.ProcessApprovalAsync(new ProcessApprovalRequest
{
    RecordId = 1001,
    ApproverId = "user_002",
    Approved = true,
    Comment = "同意请假"
}, repository);

小贴士

1. 自动推进：开启 AutoApproval = true 后，FlowEngine 会每分钟检查进行中的流程，自动推进到下一步
2. JSON 热加载：FlowBuilder 支持从目录批量加载 *.json，修改文件后自动更新缓存
3. 会签模式：AggregationEvaluator 支持 AND（所有人通过）、OR（任一人通过）、比例（如 2/3 通过）
4. HTTP 回调：HttpNodeHandler 可在流程中调用外部 API，实现自动化集成
5. 审批委托：通过 DbApprovalDelegation 实体支持代审功能
6. 事件驱动：实现 IFlowEventListener 可监听流程初始化、节点进入/离开、完成等事件

许可证

Copyright (c) yswenli. All Rights Reserved.