diff --git a/src/chat/focus_chat/heartflow_message_processor.py b/src/chat/focus_chat/heartflow_message_processor.py index 1f78280de..f5bd091f9 100644 --- a/src/chat/focus_chat/heartflow_message_processor.py +++ b/src/chat/focus_chat/heartflow_message_processor.py @@ -155,14 +155,13 @@ class HeartFCMessageReceiver: groupinfo = message.message_info.group_info userinfo = message.message_info.user_info messageinfo = message.message_info - chat = await get_chat_manager().get_or_create_stream( platform=messageinfo.platform, user_info=userinfo, group_info=groupinfo, ) - + await self.storage.store_message(message, chat) subheartflow = await heartflow.get_or_create_subheartflow(chat.stream_id) @@ -173,7 +172,6 @@ class HeartFCMessageReceiver: message.raw_message, chat, userinfo ): return - # 6. 兴趣度计算与更新 interested_rate, is_mentioned = await _calculate_interest(message) diff --git a/src/chat/heart_flow/observation/chatting_observation.py b/src/chat/heart_flow/observation/chatting_observation.py index a70e6e73e..8888ddb43 100644 --- a/src/chat/heart_flow/observation/chatting_observation.py +++ b/src/chat/heart_flow/observation/chatting_observation.py @@ -81,9 +81,13 @@ class ChattingObservation(Observation): self.talking_message = initial_messages self.talking_message_short = initial_messages_short self.talking_message_str = build_readable_messages(self.talking_message, show_actions=True) - self.talking_message_str_truncate = build_readable_messages(self.talking_message, show_actions=True, truncate=True) + self.talking_message_str_truncate = build_readable_messages( + self.talking_message, show_actions=True, truncate=True + ) self.talking_message_str_short = build_readable_messages(self.talking_message_short, show_actions=True) - self.talking_message_str_truncate_short = build_readable_messages(self.talking_message_short, show_actions=True, truncate=True) + self.talking_message_str_truncate_short = build_readable_messages( + self.talking_message_short, show_actions=True, truncate=True + ) def to_dict(self) -> dict: """将观察对象转换为可序列化的字典""" diff --git a/src/plugins/built_in/core_actions/plugin.py b/src/plugins/built_in/core_actions/plugin.py index f30d77a2b..66a2e2ba3 100644 --- a/src/plugins/built_in/core_actions/plugin.py +++ b/src/plugins/built_in/core_actions/plugin.py @@ -296,9 +296,7 @@ class NoReplyAction(BaseAction): elif over_count <= 5: frequency_block = "你今天说话比较多,感觉有点疲惫,想要稍微休息一下。\n" else: - frequency_block = ( - "你发现自己说话太多了,感觉很累,想要安静一会儿,除非有重要的事情否则不想回复。\n" - ) + frequency_block = "你发现自己说话太多了,感觉很累,想要安静一会儿,除非有重要的事情否则不想回复。\n" logger.info( f"{self.log_prefix} 过去10分钟发言{bot_message_count}条,超过阈值{talk_frequency_threshold},添加疲惫提示" @@ -306,7 +304,7 @@ class NoReplyAction(BaseAction): else: # 回复次数少时的正向提示 under_count = talk_frequency_threshold - bot_message_count - + if under_count >= talk_frequency_threshold * 0.8: # 回复很少(少于20%) frequency_block = "你感觉精力充沛,状态很好。\n" elif under_count >= talk_frequency_threshold * 0.5: # 回复较少(少于50%)