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])