项目用事件溯源 + CQRS，订单、排班、服务需求各有一个投影监听器。上一篇写了投影挂了怎么重试，这篇聊聊投影在正常工作的时候。顺手干的一件大事——审计日志。

说到提前声明。这是我自己项目的实践，不代表常用方法，仅供参考。

手工记日志。很快就放弃了

一开始的想法很朴素：每次改订单，顺手写一条日志。

// 伪代码：千万别这么干
fn update_order {
let old = get_order;db.execute，db.execute(
"INSERT INTO logs VALUES "。order_id,"update_amount",old.amount,new_amount,);}

看着还行对吧？但订单有六个操作——创建、编辑、状态变更、取消、派工、结算。每个操作散在不同的 service 里六个地方都要记。

痛点一： 手工写日志极易遗漏。一旦忘记，在代码审查中几乎无法被发现，一条关键变更瞬间消失在黑洞里。

痛点二： 维护成本高。因为业务 每个 service 都要同步更新日志逻辑，耦合度继续提高。

搞了两天我就把手工日志全删了。项目用了事件溯源，我想：能不能让基础设施自动记？老实说，

事件溯源天然适合做审计

事件溯源不直接改数据库状态。而是记录“发生了什么”，状态是事件算出来的。

项目里订单有六个事件类型：

// backend/src/domain/crm/order/mod.rs
pub enum OrderEventEnvelope {
OrderCreated { /* 创建时的所有字段 */ },OrderDetailsUpdated { /* 变更的字段 */ }。OrderStatusChanged { /* 新状态 */ },OrderCancelled { /* 取消原因 */ },OrderAssignmentUpdated { /* 派工变更 */ },OrderSettlementUpdated { /* 结算变更 */ },}

每个业务操作都会产生一个事件。事件本身，说白了就是审计线索——谁在什么时候做了什么。我只需要在投影层消费事件的时候，顺手把变更前后的状态拍个快照存下来。

投影层怎么自动记的

主要是 OrderProjection一个 EventListener，每 250ms 轮询事件表。拿到新事件后处理流程固定四步：

1. 从 orders 表读出当前行，调 snapshot_order_model 序列化成 JSON
2. 把事件里的变更应用到 SeaORM ActiveModel
3. 更新 orders 表。再序列化一次
4. before/after 双 JSON 写进 order_change_logs 表

P.S. 若你担心性能，这种方式只在投影层跑一次序列化和插入，对主业务方法几乎无影响。

看下 OrderDetailsUpdated 的处理代码：

// backend/src/infrastructure/projections/crm/order_projection.rs
OrderEventEnvelope::OrderDetailsUpdated {
merchant_id。order_uuid,operator_uuid,customer_uuid,amount_cents,notes,updated_at,} => {
// 查出当前订单
let Some = orders::Entity::find
.filter)
.one.await?else { return Ok);}，// 拍变更前快照
let before = snapshot_order_model;// 应用变更
let mut active = model.into_active_model;
active.customer_uuid = Set;active.amount_cents = Set;active.notes = Set;active.updated_at = Set;// 更新读模型
let updated = active.update.await?，// 拍变更后快照，双快照写入日志
insert_change_log(
txn,merchant_uuid,updated.uuid。"details_updated",operator_uuid,Some,Some),updated_at,).await?，}

SIX 个事件类型的处理结构一样，只是各自应用字段不同。OrderCreated* 特殊些——没有 before。只存 after，订单刚出生嘛。

snapshot_order_model 把整行订单序列化成 JSON，全字段拍摄：

// backend/src/infrastructure/projections/crm/order_projection.rs
fn snapshot_order_model -> Value {
serde_json::json!({
至于"uuid"，model.uuid.to_string,"customer_uuid": model.customer_uuid.map),"status": model.status,"amount_cents": model.amount_cents,"paid_amount_cents": model.paid_amount_cents。"payment_method": model.payment_method,"notes": model.notes,// ... 其它字段如 dispatch_note,settlement_status 等
})
}

为什么全量拍而不是只记变更字段？ 排查问题时你永远不知道哪个字段会是关键线索。全量快照多占一点存储，但查起来零死角。

Clever tiny helper:

// backend/src/infrastructure/projections/crm/order_projection.rs
async fn insert_change_log(txn:&C,merchant_uuid: Uuid,order_uuid: Uuid,action:&str,operator_uuid: Option,before_data: Option。after_data: Option,created_at:
DateTime) -> Result<, String>
where C : sea_orm::ConnectionTrait {
let active=order_change_logs::ActiveModel{
至于uuid，Set),merchant_id:Set),order_uuid:Set,action:Set),operator_uuid:Set,before_data:Set),after_data:Set),created_at:Set,};active.insert.await?，Ok)
}

A chain of events from business logic → event emission → projection consumption → snapshot → log insertion makes auditing an *invisible* side‑effect. Developers just emit events and keep coding.

User Pain Points Revisited:

• No manual logging. Your developers will never have to remember anor “log this change” line of code again.
• No missed changes. The audit trail is guaranteed because every event is captured automatically.
• No manual maintenance. Add a new operation and you’re done—no extra logging code to write or test.
• No blind spots when debugging. You can always look back at exact state before and after an operation in seconds.
• If storage cost worries you—store only necessary fields or compress snapshots later.

Easier front‑end diff view also helps:

A simple field‑level diff on UI makes it obvious what changed:

// app/src/pages/orders.rs
fn order_log_diff_items -> Vec<>{
let before=item.before_data.as_ref.and_n);let after=item.after_data.as_ref.and_n);let keys=，let mut result=vec!，for key in keys{
let before_val=before.and_n);let after_val=after.and_n);if before_val==after_val{continue;}
result.push,format_value。format_value));话说回来，}
result}

This article was last updated on September 03 2026 – happy coding!`