fix(chat): 修复消息打断后的重复处理并优化回复逻辑

本次提交包含两项关键更改：

1.  将 `triggering_user_id` 的设置逻辑从 `ChatterManager` 迁移至 `StreamLoopManager` 的处理循环初期。这确保了触发用户ID能够更早、更可靠地被设置，为回复保护机制提供了正确的上下文，避免了潜在的逻辑错误。

2.  在消息成功打断正在执行的任务后，立即调用 `clear_all_unread_messages`。此举修复了当新消息打断旧任务时，旧消息队列未被清空，导致机器人可能在之后重新处理这些过时消息的缺陷，从而防止了重复响应。

src/chat/message_manager/message_manager.py

@@ -401,12 +401,16 @@ class MessageManager:
             if random.random() < interruption_probability:
                 logger.info(f"聊天流 {chat_stream.stream_id} 触发消息打断，打断概率: {interruption_probability:.2f}")
 
-                # 取消 stream_loop_task，子任务会通过 try-catch 自动取消
-                try:
-                    stream_loop_task.cancel()
-                    logger.info(f"已取消流循环任务: {chat_stream.stream_id}")
-                except Exception as e:
-                    logger.warning(f"取消流循环任务失败: {chat_stream.stream_id} - {e}")
+                # 修复：取消所有任务（包括多重回复）
+                cancelled_count = self.chatter_manager.cancel_all_stream_tasks(chat_stream.stream_id)
+
+                if cancelled_count > 0:
+                    logger.info(f"消息打断成功取消 {cancelled_count} 个任务: {chat_stream.stream_id}")
+
+                    # 修复：打断后，将被打断的消息标记为已读，防止重复处理
+                    await self.clear_all_unread_messages(chat_stream.stream_id)
+                else:
+                    logger.warning(f"消息打断未能取消任何任务: {chat_stream.stream_id}")
 
                 # 增加打断计数
                 await context.increment_interruption_count()