pfc修复,查询user_id修复

pull/914/head
Bakadax 2025-05-01 20:19:21 +08:00
parent f042f7b689
commit 420aecb7be
3 changed files with 3 additions and 12 deletions

View File

@ -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:

View File

@ -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并进行必要的设置"""

View File

@ -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