From c0e3d26b71fb089d5cf8fb369b43e1e2b4b9cef4 Mon Sep 17 00:00:00 2001 From: iven Date: Thu, 30 Apr 2026 08:32:29 +0800 Subject: [PATCH] =?UTF-8?q?refactor(health):=20=E6=9B=B4=E6=96=B0=20messag?= =?UTF-8?q?e.sent=20=E6=B6=88=E8=B4=B9=E8=80=85=E6=B3=A8=E9=87=8A=20?= =?UTF-8?q?=E2=80=94=20last=5Fmessage=5Fat=20=E5=B7=B2=E5=9C=A8=20CAS=20?= =?UTF-8?q?=E4=B8=AD=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- crates/erp-health/src/event.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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,