diff --git a/crates/erp-health/src/event.rs b/crates/erp-health/src/event.rs index 7baebca..6b6058c 100644 --- a/crates/erp-health/src/event.rs +++ b/crates/erp-health/src/event.rs @@ -110,7 +110,7 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) { } }); - // message.sent → 通用消息事件消费者(预留咨询联动) + // message.sent → 通用消息事件消费者(预留扩展) let (mut msg_rx, _msg_handle) = state.event_bus.subscribe_filtered("message.".to_string()); let _msg_db = state.db.clone(); tokio::spawn(async move { @@ -125,8 +125,9 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) { recipient_id = ?recipient_id, "message.sent 消费者收到事件" ); - // TODO: 若 message 关联了 consultation session(通过 metadata 或 reference), - // 可在此更新 consultation_session.last_message_at + // 注:consultation_session.last_message_at 已在 + // consultation_service::create_message() 的 CAS 操作中直接更新, + // 无需通过此消费者重复处理 } Some(_) => {} None => break,