审批工作流引擎：LifecycleBus 拦截模式——Agent 世界的零侵入事件架构

> EAMX 的审批流不是写在业务代码里的——审批插件通过 LifecycleBus 的 intercept 模式挂载到 equipment:beforeCreate、purchase:beforeSubmit 等业务事件上，实现零侵入的审批门控。本文详解 LifecycleBus 的 emit/intercept 双模式设计，以及如何通过 checkApprovalGate 实现可配置的多级审批。

1. 问题：审批流与业务代码的耦合

传统系统审批的实现方式：

``typescript // 反模式：审批逻辑侵入业务代码 async function createEquipment(data) { if (data.value > 100000) { await createApprovalRequest(data); return { status: "pending_approval" }; } await insertEquipment(data); return { status: "created" }; } ``

问题显而易见：

审批规则修改需要改业务代码
多个实体（设备、采购、工单）需要各自写审批检查
审批流插件的启用/禁用需要改业务代码

2. EAMX 方案：LifecycleBus 拦截模式

```typescript // equipment 业务代码——完全不涉及审批 async function createEquipment(data, ctx) { const result = await db.insert(equipmentsTable).values(data); return { id: result.id, status: "created" }; }

// approval 插件——独立于业务代码 lifecycleHandler("equipment:beforeCreate", async ({ payload, ctx, abort }) => { if (payload.value > 100000) { const needsApproval = await checkApprovalGate(ctx, { entityType: "Equipment", threshold: 100000, }); if (needsApproval) { await createApprovalRequest(ctx, payload); abort("设备价值超过阈值，已提交审批"); } } }); ```

业务代码完全不知道审批的存在。

3. LifecycleBus 双模式对比

| 属性 | emit（观察） | intercept（拦截） | |---|---|---| | 执行方式 | 并行 Promise.allSettled | 串行 for-of | | 失败处理 | 打日志，不中断 | AbortError → 中断主流程 | | 数据修改 | 不能 | ctx.intercept(modified) 修改 payload | | 典型用例 | 通知、日志、缓存失效 | 审批、校验、权限注入 |

4. 完整审批流生命周期

`` equipment:beforeCreate ├─ approval 插件检查 → 需要审批？ │ ├─ 需要 → 创建审批单 → abort("需要审批") │ └─ 不需要 → 继续 ├─ [如果 abort] approval:created 事件 → 通知主管 ├─ [主管审批] POST /api/approval/:id/approve │ └─ approval:approved 事件 │ └─ equipment 插件监听 → 重新执行 createEquipment └─ [主管拒绝] POST /api/approval/:id/reject └─ approval:rejected 事件 → 通知申请人 ``

5. 插件注册示例

``typescript export const approvalPlugin: PluginManifest = { id: "approval", name: "审批流", tier: 1, dependencies: ["auth"], permissions: [ { action: "approve", subject: "WorkOrder" }, { action: "approve", subject: "PurchaseRequest" }, ], routePrefix: "/api/approval", createRouter: () => { / CRUD routes / }, lifecycleHandlers: { "equipment:beforeCreate": equipmentCreateGate, "purchase:beforeSubmit": purchaseSubmitGate, }, }; ``

17 行注册，零侵入业务代码。

6. 核心文件索引

| 文件 | 行数 | 职责 | |---|---|---| | packages/core/src/lifecycle-bus.ts | 79 | emit/intercept 双模式事件总线 | | packages/core/src/types.ts | — | LifecycleEvent 类型定义 |

下一篇：Tool Registry + MCP Server——AI 的"工具箱"如何按权限动态装配。