From 1c760798b01a53268b8ceaec19de564cd423d7fd Mon Sep 17 00:00:00 2001 From: tt-P607 <68868379+tt-P607@users.noreply.github.com> Date: Sat, 20 Sep 2025 12:43:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=80=BB=E7=AE=97=E8=83=BD=E5=9B=9E=E5=A4=8D?= =?UTF-8?q?=E4=BA=86=F0=9F=98=AD=F0=9F=98=AD=F0=9F=98=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/chat/chat_loop/response_handler.py | 2 +- src/chat/replyer/default_generator.py | 2 +- src/person_info/relationship_fetcher.py | 6 +++++- 3 files changed, 7 insertions(+), 3 deletions(-) diff --git a/src/chat/chat_loop/response_handler.py b/src/chat/chat_loop/response_handler.py index 9859c76c3..99f065319 100644 --- a/src/chat/chat_loop/response_handler.py +++ b/src/chat/chat_loop/response_handler.py @@ -130,7 +130,7 @@ class ResponseHandler: """ current_time = time.time() # 计算新消息数量 - new_message_count = message_api.count_new_messages( + new_message_count = await message_api.count_new_messages( chat_id=self.context.stream_id, start_time=thinking_start_time, end_time=current_time ) diff --git a/src/chat/replyer/default_generator.py b/src/chat/replyer/default_generator.py index d2b37237e..7f311803f 100644 --- a/src/chat/replyer/default_generator.py +++ b/src/chat/replyer/default_generator.py @@ -1361,7 +1361,7 @@ class DefaultReplyer: # 获取用户ID person_info_manager = get_person_info_manager() - person_id = person_info_manager.get_person_id_by_person_name(sender) + person_id = await person_info_manager.get_person_id_by_person_name(sender) if not person_id: logger.warning(f"未找到用户 {sender} 的ID,跳过信息提取") return f"你完全不认识{sender},不理解ta的相关信息。" diff --git a/src/person_info/relationship_fetcher.py b/src/person_info/relationship_fetcher.py index e903915a7..4b25f6b14 100644 --- a/src/person_info/relationship_fetcher.py +++ b/src/person_info/relationship_fetcher.py @@ -110,7 +110,11 @@ class RelationshipFetcher: if person_name == nickname_str and not short_impression: return "" - current_points = person_info.get("points") or [] + current_points = person_info.get("points") + if isinstance(current_points, str): + current_points = orjson.loads(current_points) + else: + current_points = current_points or [] # 按时间排序forgotten_points current_points.sort(key=lambda x: x[2])