传统成本核算系统是 T+1 批处理架构，月底跑一次 ABC，算的是"旧账"且只摊到产品级。本文给出一套可落地的重构方案——基于事件溯源（Event Sourcing）+ CQRS + 元数据驱动（Metadata-Driven），把成本从"定时算"变成"业务发生即按作业动因（ABC）实时分摊"，并附 YAML/SQL/Python 完整示意代码与自检清单。所有代码带注释，可直接作为工程骨架改造。
1、 问题场景：月底跑批为什么算不准
某制造企业的成本表每月 3 号才出，且只到"产品"一级。问题是：同一产品，大客户账期 60 天、小客户现结，履约成本差出一大截，却被平摊掉了。根因有二：① 核算是批处理（Batch），时效 T+1；② 分摊维度单一，没有按订单/客户/部门拆。要做实时多维分摊，必须先改架构，不是改算法。
2、架构总览：事件驱动替代批处理
统一数据层（Unified Data Layer）用领域模型（Domain Model）+ 主数据管理（MDM）消除口径冲突；事件溯源把业务记成不可变事件序列；CQRS 让查询侧实时物化；元数据层让业务人员配置分摊规则，不写代码。
3. 实践一：用元数据定义"入库即分摊"（YAML）
要点：规则以配置而非代码描述，改动由业务人员在后台完成，避免实施商排期。
4. 实践二：实时成本物化视图（SQL）
5. 实践三：ABC 作业成本法分摊（Python）
6. 实践四：事件溯源的核算 reducer（Python 示意）
事件溯源让每笔业务记成不可变事件，按事件序列重放即可得到任意时刻的成本，审计与回溯成本大幅降低。
7. 工程避坑点
动因选错比平均分摊更糟：ABC 的准确性完全依赖动因（Driver）选得对。动因选错，结果比简单比例更误导，必须做敏感性校验。
- 事件幂等：入库事件可能因重试重复投递，核算引擎须按事件 ID 做幂等，防止成本重复累加。
- 物化视图刷新成本：高并发下 REFRESH CONCURRENTLY 有锁竞争，建议按业务域分片刷新。
- 口径统一前置：MDM 不统一，再多实时计算也是"垃圾进垃圾出"。
- 自检清单（常见问题）
[ ] 成本核算是否从 T+1 批处理改为事件触发即时算？
[ ] 分摊是否至少覆盖 订单/客户/部门 三维，而非仅产品级？
[ ] 分摊规则是否以元数据配置实现，业务可自助变更？
[ ] ABC 动因是否来自真实业务度量并做过敏感性校验？
[ ] 事件消费是否幂等，避免重复累加成本？
[ ] 统一数据层（MDM）是否先打通，再谈实时？
[ ] 是否建立了动因定期复校机制，防止分摊随时间失真？
综上，成本核算实时化的关键不在"算得快"，而在"架构对"——事件驱动替代批处理、元数据驱动替代写代码、ABC 按真实动因替代笼统分摊。架构就位，算准、算细、算快是顺带结果。
