4、分配规则引擎架构：规则引擎的模块组成、输入输出接口、与ERP/MES的集成方式
分配规则引擎是制造物料协同的中枢决策单元。它接收来自上游计划与订单系统的需求信号，结合实时库存与在途数据，通过可配置的规则链输出物料分配方案与缺料预警。本节从模块组成、接口定义、系统集成三个维度拆解其架构。
4.1 规则引擎核心模块组成
规则引擎采用微内核+插件化规则库的架构，主要包含以下五个模块：
| 模块名称 | 职责说明 | 关键技术点 |
|---|---|---|
| 规则解析器 | 加载并编译用户定义的分配规则（如优先级、齐套、FIFO） | DRL/Drools、表达式树、热加载 |
| 需求聚合器 | 按时间窗口/工单/批次合并来自MES/ERP的需求 | 滑动窗口、去重、优先级排序 |
| 库存快照引擎 | 获取当前可用库存、在途、质检冻结等状态 | Redis缓存、分布式锁、实时订阅 |
| 分配执行器 | 按规则链逐条匹配需求与库存，生成分配结果 | 责任链模式、事务补偿、预占锁 |
| 预警触发器 | 当分配后剩余库存低于安全阈值时，生成缺料事件 | 事件驱动、Webhook、消息队列 |
架构要点： 规则解析器与分配执行器之间采用规则链模式，每条规则独立编译、独立回滚，避免单条规则异常导致整个分配失败。
4.2 输入输出接口定义
规则引擎对外暴露标准化接口，确保上下游系统能够以统一协议进行交互。接口设计遵循请求-响应与事件推送双模式。
4.2.1 输入接口
| 接口名称 | 协议/方式 | 核心字段 | 触发时机 |
|---|---|---|---|
| 需求注册 | REST / gRPC | 工单号、物料编码、需求量、需求时间、优先级 | 工单下达、紧急插单 |
| 库存变更 | 消息队列 (Kafka/RabbitMQ) | 物料编码、仓库、变更类型、变更数量、批次号 | 入库、出库、盘点、质检 |
| 规则配置 | REST / 管理后台 | 规则ID、规则表达式、优先级、生效时间 | 规则新增、修改、启用/禁用 |
| 安全阈值 | REST | 物料编码、安全库存、预警等级、通知方式 | 参数初始化、周期性调整 |
4.2.2 输出接口
| 接口名称 | 协议/方式 | 核心字段 | 消费方 |
|---|---|---|---|
| 分配结果 | REST / 消息队列 | 工单号、物料编码、分配数量、批次、锁定状态 | MES、WMS |
| 缺料预警 | Webhook / 消息队列 | 物料编码、缺料数量、预计缺料时间、影响工单列表 | ERP、采购系统、SCM |
| 预留锁定 | REST | 物料编码、仓库、锁定数量、锁定ID、有效期 | WMS、库存服务 |
| 规则执行日志 | 消息队列 / 数据库 | 规则ID、输入快照、输出结果、执行耗时、异常信息 | 监控系统、审计 |
接口设计建议： 输入接口尽量采用幂等设计，避免重复请求导致分配异常；输出接口中的缺料预警建议增加分级通知（紧急/一般/提示），减少无效告警。
4.3 与ERP/MES的集成方式
规则引擎作为中间层，需要同时对接企业资源计划（ERP）与制造执行系统（MES），实现数据双向同步与业务闭环。集成方式分为数据层集成与服务层集成两种模式。
4.3.1 与ERP集成
- 主数据同步： 通过ETL或CDC（Change Data Capture）从ERP同步物料主数据、BOM、供应商信息到规则引擎的本地缓存。
- 订单需求接收： ERP下达生产订单或采购订单后，通过REST接口或MQ将需求数据推送至规则引擎的需求聚合器。
- 缺料反馈： 规则引擎生成的缺料预警通过Webhook回写ERP的采购建议表或异常工单表，触发采购流程。
- 库存对账： 每日定时或事件触发，规则引擎与ERP进行库存总量对账，确保分配基数准确。
4.3.2 与MES集成
- 工单状态订阅： MES实时推送工单开工、完工、暂停、报废等状态变更，规则引擎据此释放或回收已分配物料。
- 物料消耗反馈： MES每完成一道工序或一次领料，将实际消耗量回传至规则引擎，更新可用库存快照。
- 分配指令下发： 规则引擎生成的分配方案（如指定批次、库位）直接推送至MES的拣料任务列表，指导现场作业。
- 异常协同： MES发现物料不良或来料短缺时，通过接口触发规则引擎的重新分配流程。
4.4 集成关键注意事项
常见集成陷阱：
- 数据一致性： ERP与MES的库存数据可能存在时间差，规则引擎应优先使用MES的实时消耗数据，定期与ERP对账修正。
- 接口超时与重试： 分配执行器调用WMS预留接口时，必须设置合理的超时时间（建议≤3秒）和指数退避重试策略。
- 规则热部署： 规则变更不应中断正在执行的分配任务，建议采用版本化规则包+灰度发布机制。
- 审计追溯： 每次分配执行必须记录完整的输入快照与输出结果，便于事后追溯与责任界定。
4.5 规则引擎部署形态建议
| 部署场景 | 推荐形态 | 优势 | 适用企业规模 |
|---|---|---|---|
| 单工厂 | 嵌入式规则引擎（如Drools嵌入Java应用） | 低延迟、运维简单 | 中小型制造企业 |
| 多工厂/集团 | 独立微服务 + 分布式规则库 | 高可用、规则统一管理 | 大型集团、多基地 |
| 云原生 | 容器化部署 + 规则引擎PaaS | 弹性伸缩、按需付费 | 快速扩张、SaaS模式 |
架构总结： 分配规则引擎的核心价值在于解耦——将分配逻辑从ERP和MES中抽离，形成独立的决策层。通过标准化的输入输出接口与事件驱动机制，实现需求、库存、分配、预警的实时闭环，为制造物料协同提供可配置、可审计、可追溯的规则底座。