diff --git a/src/plugins/PFC/chat_observer.py b/src/plugins/PFC/chat_observer.py index e66824a2..1a17db90 100644 --- a/src/plugins/PFC/chat_observer.py +++ b/src/plugins/PFC/chat_observer.py @@ -39,7 +39,6 @@ class ChatObserver: stream_id: 聊天流ID """ self.last_check_time = None - self.last_check_time = None self.last_bot_speak_time = None self.last_user_speak_time = None if stream_id in self._instances: diff --git a/src/plugins/PFC/observation_info.py b/src/plugins/PFC/observation_info.py index af7f537b..2fc5e4c5 100644 --- a/src/plugins/PFC/observation_info.py +++ b/src/plugins/PFC/observation_info.py @@ -158,9 +158,6 @@ class ObservationInfo: # meta_plan_trigger: bool = False # --- 修改:移除 __post_init__ 的参数 --- - def __init__(self): - self.chat_observer = None - self.chat_observer = None def __post_init__(self): """初始化后创建handler并进行必要的设置""" diff --git a/src/plugins/person_info/relationship_manager.py b/src/plugins/person_info/relationship_manager.py index fe229b2c..57976176 100644 --- a/src/plugins/person_info/relationship_manager.py +++ b/src/plugins/person_info/relationship_manager.py @@ -94,18 +94,13 @@ class RelationshipManager: person_ids = [person_info_manager.get_person_id(platform, str(uid)) for uid in user_ids] names_map = {} try: - # --- 修改点:直接使用 db.person_info.find --- - # !!! 确保 'person_info' 是正确的集合名称 !!! cursor = db.person_info.find( {"person_id": {"$in": person_ids}}, - {"_id": 0, "person_id": 1, "person_name": 1} # 只查询需要的字段 + {"_id": 0, "person_id": 1, "user_id": 1, "person_name": 1} # 只查询需要的字段 ) - # --- 结束修改点 --- - # 注意:pymongo 的 find 返回的是同步游标,如果你的 db 对象是 motor 客户端,需要使用 await cursor.to_list(length=None) - # 假设这里 db 是 pymongo 同步客户端,或者你的环境允许在异步函数中迭代同步游标 - for doc in cursor: # 如果 db 是 motor,这里会报错,需要改为 async for - original_user_id = doc.get("person_id", "").split("_", 1)[-1] + for doc in cursor: + original_user_id = doc.get("user_id", "").split("_", 1)[-1] person_name = doc.get("person_name") if original_user_id and person_name: names_map[original_user_id] = person_name