diff --git a/src/chat/focus_chat/heartFC_sender.py b/src/chat/focus_chat/heartFC_sender.py index 4f2c873e4..ed801b505 100644 --- a/src/chat/focus_chat/heartFC_sender.py +++ b/src/chat/focus_chat/heartFC_sender.py @@ -106,7 +106,8 @@ class HeartFCSender: and not message.is_private_message() and message.reply.processed_plain_text != "[System Trigger Context]" ): - message.set_reply(message.reply) + # message.set_reply(message.reply) + message.set_reply() logger.debug(f"[{chat_id}] 应用 set_reply 逻辑: {message.processed_plain_text[:20]}...") await message.process() diff --git a/src/chat/focus_chat/info_processors/chattinginfo_processor.py b/src/chat/focus_chat/info_processors/chattinginfo_processor.py index 3812a6fd7..872851579 100644 --- a/src/chat/focus_chat/info_processors/chattinginfo_processor.py +++ b/src/chat/focus_chat/info_processors/chattinginfo_processor.py @@ -64,7 +64,7 @@ class ChattingInfoProcessor(BaseProcessor): obs_info = ObsInfo() # 改为异步任务,不阻塞主流程 - asyncio.create_task(self.chat_compress(obs)) + # asyncio.create_task(self.chat_compress(obs)) # 设置说话消息 if hasattr(obs, "talking_message_str"): diff --git a/src/chat/message_receive/message.py b/src/chat/message_receive/message.py index ecd5c8b9a..92aff4c31 100644 --- a/src/chat/message_receive/message.py +++ b/src/chat/message_receive/message.py @@ -108,8 +108,8 @@ class MessageRecv(Message): self.raw_message = message_dict.get("raw_message") # 处理消息内容 - self.processed_plain_text = "" # 初始化为空字符串 - self.detailed_plain_text = "" # 初始化为空字符串 + self.processed_plain_text = message_dict.get("processed_plain_text", "") # 初始化为空字符串 + self.detailed_plain_text = message_dict.get("detailed_plain_text", "") # 初始化为空字符串 self.is_emoji = False def update_chat_stream(self, chat_stream: "ChatStream"): @@ -217,7 +217,9 @@ class MessageProcessBase(Message): return f"[@{seg.data}]" elif seg.type == "reply": if self.reply and hasattr(self.reply, "processed_plain_text"): - return f"[回复:{self.reply.processed_plain_text}]" + # print(f"self.reply.processed_plain_text: {self.reply.processed_plain_text}") + # print(f"reply: {self.reply}") + return f"[回复<{self.reply.message_info.user_info.user_nickname}:{self.reply.message_info.user_info.user_id}> 的消息:{self.reply.processed_plain_text}]" return None else: return f"[{seg.type}:{str(seg.data)}]"