From 2fb1674a4df0e69a04f76f4a19dcc76f81e58bf8 Mon Sep 17 00:00:00 2001 From: Windpicker-owo <3431391539@qq.com> Date: Mon, 29 Sep 2025 07:29:20 +0800 Subject: [PATCH] =?UTF-8?q?feat(logging):=20=E5=B0=86=E8=B0=83=E8=AF=95?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E5=8D=87=E7=BA=A7=E4=B8=BA=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E7=BA=A7=E5=88=AB=E4=BB=A5=E5=A2=9E=E5=BC=BA=E7=9B=91=E6=8E=A7?= =?UTF-8?q?=E8=83=BD=E5=8A=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 将多个模块中的调试日志(logger.debug)升级为信息级别(logger.info)，包括流循环管理、聊天动作生成和消息兴趣度计算等关键组件。 这些修改使得生产环境中能够更直观地监控系统运行状态，包括流等待间隔、动作生成数量和消息处理决策等重要指标，同时移除了冗余的用户ID计算逻辑。 --- src/chat/message_manager/distribution_manager.py | 2 +- .../affinity_flow_chatter/affinity_chatter.py | 4 ++-- .../built_in/affinity_flow_chatter/planner.py | 15 ++------------- 3 files changed, 5 insertions(+), 16 deletions(-) diff --git a/src/chat/message_manager/distribution_manager.py b/src/chat/message_manager/distribution_manager.py index 6a2aa794a..ca648b49f 100644 --- a/src/chat/message_manager/distribution_manager.py +++ b/src/chat/message_manager/distribution_manager.py @@ -163,7 +163,7 @@ class StreamLoopManager: interval = await self._calculate_interval(stream_id, has_messages) # 5. sleep等待下次检查 - logger.debug(f"流 {stream_id} 等待 {interval:.2f}s") + logger.info(f"流 {stream_id} 等待 {interval:.2f}s") await asyncio.sleep(interval) except asyncio.CancelledError: diff --git a/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py b/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py index 9d9786e5d..44566b86d 100644 --- a/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py +++ b/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py @@ -77,7 +77,7 @@ class AffinityChatter(BaseChatter): # 执行动作（如果规划器返回了动作） execution_result = {"executed_count": len(actions) if actions else 0} if actions: - logger.debug(f"聊天流 {self.stream_id} 生成了 {len(actions)} 个动作") + logger.info(f"聊天流 {self.stream_id} 生成了 {len(actions)} 个动作") # 更新统计 self.stats["messages_processed"] += 1 @@ -95,7 +95,7 @@ class AffinityChatter(BaseChatter): **execution_result, } - logger.debug( + logger.info( f"聊天流 {self.stream_id} StreamContext处理成功: 动作数={result['actions_count']}, 未读消息={result['unread_messages_processed']}" ) diff --git a/src/plugins/built_in/affinity_flow_chatter/planner.py b/src/plugins/built_in/affinity_flow_chatter/planner.py index af0b68029..3b2071024 100644 --- a/src/plugins/built_in/affinity_flow_chatter/planner.py +++ b/src/plugins/built_in/affinity_flow_chatter/planner.py @@ -106,17 +106,6 @@ class ChatterActionPlanner: reply_not_available = False if unread_messages: - # 获取用户ID，优先从user_info.user_id获取，其次从user_id属性获取 - user_id = None - first_message = unread_messages[0] - user_id = first_message.user_info.user_id - - # 构建计算上下文 - calc_context = { - "stream_id": self.chat_id, - "user_id": user_id, - } - # 为每条消息计算兴趣度 for message in unread_messages: try: @@ -133,7 +122,7 @@ class ChatterActionPlanner: # 简单的回复决策逻辑：兴趣度超过阈值则回复 message.should_reply = message_interest > global_config.affinity_flow.non_reply_action_interest_threshold - logger.debug(f"消息 {message.message_id} 兴趣度: {message_interest:.3f}, 应回复: {message.should_reply}") + logger.info(f"消息 {message.message_id} 兴趣度: {message_interest:.3f}, 应回复: {message.should_reply}") # 更新StreamContext中的消息信息并刷新focus_energy if context: @@ -149,7 +138,7 @@ class ChatterActionPlanner: try: from src.chat.message_receive.storage import MessageStorage await MessageStorage.update_message_interest_value(message.message_id, message_interest) - logger.debug(f"已更新数据库中消息 {message.message_id} 的兴趣度为: {message_interest:.3f}") + logger.info(f"已更新数据库中消息 {message.message_id} 的兴趣度为: {message_interest:.3f}") except Exception as e: logger.warning(f"更新数据库消息兴趣度失败: {e}")