diff --git a/src/chat/chat_loop/heartFC_chat.py b/src/chat/chat_loop/heartFC_chat.py index 69453a3bc..261d85c12 100644 --- a/src/chat/chat_loop/heartFC_chat.py +++ b/src/chat/chat_loop/heartFC_chat.py @@ -386,7 +386,7 @@ class HeartFChatting: chat_target_info=planner_info[1], current_available_actions=planner_info[2], ) - await events_manager.handle_mai_events(EventType.ON_PLAN, None, prompt_info[0], None) + await events_manager.handle_mai_events(EventType.ON_PLAN, None, prompt_info[0], None, self.chat_stream.stream_id) with Timer("规划器", cycle_timers): plan_result, target_message = await self.action_planner.plan(mode=self.loop_mode) diff --git a/src/chat/message_receive/bot.py b/src/chat/message_receive/bot.py index a6a8aeb16..9a8c1b630 100644 --- a/src/chat/message_receive/bot.py +++ b/src/chat/message_receive/bot.py @@ -148,7 +148,7 @@ class ChatBot: if message.message_info.message_id == "notice": message.is_notify = True logger.info("notice消息") - print(message) + # print(message) return True diff --git a/src/plugin_system/core/events_manager.py b/src/plugin_system/core/events_manager.py index da1d81c28..8f65d8861 100644 --- a/src/plugin_system/core/events_manager.py +++ b/src/plugin_system/core/events_manager.py @@ -3,7 +3,7 @@ import contextlib from typing import List, Dict, Optional, Type, Tuple from src.chat.message_receive.message import MessageRecv -from src.chat.message_receive.chat_stream import chat_manager +from src.chat.message_receive.chat_stream import get_chat_manager from src.common.logger import get_logger from src.plugin_system.base.component_types import EventType, EventHandlerInfo, MaiMessages from src.plugin_system.base.base_events_handler import BaseEventHandler @@ -174,7 +174,7 @@ class EventsManager: self, stream_id: str, llm_prompt: Optional[str] = None, llm_response: Optional[str] = None ) -> MaiMessages: """从流ID构建消息""" - chat_stream = chat_manager.get_stream(stream_id) + chat_stream = get_chat_manager().get_stream(stream_id) assert chat_stream, f"未找到流ID为 {stream_id} 的聊天流" message = chat_stream.context.get_last_message() return self._transform_event_message(message, llm_prompt, llm_response)