From dea45b083dbcae1d7c20f07f6b6bbd607c98f8a9 Mon Sep 17 00:00:00 2001
From: Windpicker-owo <3431391539@qq.com>
Date: Mon, 10 Nov 2025 15:18:40 +0800
Subject: [PATCH] =?UTF-8?q?feat(stream):=20=E4=BC=98=E5=8C=96=E6=9C=AA?=
 =?UTF-8?q?=E8=AF=BB=E6=B6=88=E6=81=AF=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?=
 =?UTF-8?q?=EF=BC=8C=E9=81=BF=E5=85=8D=E6=97=A0=E6=95=88=E7=9A=84=20chatte?=
 =?UTF-8?q?r=20=E8=B0=83=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/chat/message_manager/distribution_manager.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/chat/message_manager/distribution_manager.py b/src/chat/message_manager/distribution_manager.py
index 17e1cc861..bb2d922dd 100644
--- a/src/chat/message_manager/distribution_manager.py
+++ b/src/chat/message_manager/distribution_manager.py
@@ -340,6 +340,14 @@ class StreamLoopManager:
 
             # 注意：缓存消息刷新已移至planner开始时执行（动作修改器之后），此处不再刷新
 
+            # 检查未读消息，如果为空则直接返回（优化：避免无效的 chatter 调用）
+            unread_messages = context.get_unread_messages()
+            if not unread_messages:
+                logger.debug(f"流 {stream_id} 未读消息为空，跳过 chatter 处理")
+                return True  # 返回 True 表示处理完成（虽然没有实际处理）
+
+            logger.debug(f"流 {stream_id} 有 {len(unread_messages)} 条未读消息，开始处理")
+
             # 设置触发用户ID，以实现回复保护
             last_message = context.get_last_message()
             if last_message: