refactor(health): 更新 message.sent 消费者注释 — last_message_at 已在 CAS 中处理
This commit is contained in:
@@ -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 (mut msg_rx, _msg_handle) = state.event_bus.subscribe_filtered("message.".to_string());
|
||||||
let _msg_db = state.db.clone();
|
let _msg_db = state.db.clone();
|
||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
@@ -125,8 +125,9 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) {
|
|||||||
recipient_id = ?recipient_id,
|
recipient_id = ?recipient_id,
|
||||||
"message.sent 消费者收到事件"
|
"message.sent 消费者收到事件"
|
||||||
);
|
);
|
||||||
// TODO: 若 message 关联了 consultation session(通过 metadata 或 reference),
|
// 注:consultation_session.last_message_at 已在
|
||||||
// 可在此更新 consultation_session.last_message_at
|
// consultation_service::create_message() 的 CAS 操作中直接更新,
|
||||||
|
// 无需通过此消费者重复处理
|
||||||
}
|
}
|
||||||
Some(_) => {}
|
Some(_) => {}
|
||||||
None => break,
|
None => break,
|
||||||
|
|||||||
Reference in New Issue
Block a user