fix(chat): 将同步调用改为异步调用以匹配接口变更
修改了多处 person_info_manager.get_value() 方法的调用方式,从同步调用改为异步调用(添加 await 关键字),使其与异步接口保持一致。这确保了在获取用户信息时的正确异步操作,避免了潜在的阻塞问题。 涉及文件: - src/chat/replyer/default_generator.py (3处修改) - src/chat/utils/prompt.py (1处修改) - src/person_info/relationship_builder.py (1处修改)
This commit is contained in:
@@ -757,7 +757,7 @@ class DefaultReplyer:
|
|||||||
if platform and user_id:
|
if platform and user_id:
|
||||||
person_id = PersonInfoManager.get_person_id(platform, user_id)
|
person_id = PersonInfoManager.get_person_id(platform, user_id)
|
||||||
person_info_manager = get_person_info_manager()
|
person_info_manager = get_person_info_manager()
|
||||||
sender_name = person_info_manager.get_value(person_id, "person_name") or "未知用户"
|
sender_name = await person_info_manager.get_value(person_id, "person_name") or "未知用户"
|
||||||
else:
|
else:
|
||||||
sender_name = "未知用户"
|
sender_name = "未知用户"
|
||||||
|
|
||||||
@@ -856,7 +856,7 @@ class DefaultReplyer:
|
|||||||
if platform and user_id:
|
if platform and user_id:
|
||||||
person_id = PersonInfoManager.get_person_id(platform, user_id)
|
person_id = PersonInfoManager.get_person_id(platform, user_id)
|
||||||
person_info_manager = get_person_info_manager()
|
person_info_manager = get_person_info_manager()
|
||||||
sender_name = person_info_manager.get_value(person_id, "person_name") or "未知用户"
|
sender_name = await person_info_manager.get_value(person_id, "person_name") or "未知用户"
|
||||||
else:
|
else:
|
||||||
sender_name = "未知用户"
|
sender_name = "未知用户"
|
||||||
|
|
||||||
@@ -1030,7 +1030,7 @@ class DefaultReplyer:
|
|||||||
|
|
||||||
# 检查是否是bot自己的名字,如果是则替换为"(你)"
|
# 检查是否是bot自己的名字,如果是则替换为"(你)"
|
||||||
bot_user_id = str(global_config.bot.qq_account)
|
bot_user_id = str(global_config.bot.qq_account)
|
||||||
current_user_id = person_info_manager.get_value(person_id, "user_id")
|
current_user_id = await person_info_manager.get_value(person_id, "user_id")
|
||||||
current_platform = reply_message.get("chat_info_platform")
|
current_platform = reply_message.get("chat_info_platform")
|
||||||
|
|
||||||
if current_user_id == bot_user_id and current_platform == global_config.bot.platform:
|
if current_user_id == bot_user_id and current_platform == global_config.bot.platform:
|
||||||
|
|||||||
@@ -926,7 +926,7 @@ class Prompt:
|
|||||||
person_info_manager = get_person_info_manager()
|
person_info_manager = get_person_info_manager()
|
||||||
person_id = await person_info_manager.get_person_id_by_person_name(sender)
|
person_id = await person_info_manager.get_person_id_by_person_name(sender)
|
||||||
if person_id:
|
if person_id:
|
||||||
user_id = person_info_manager.get_value(person_id, "user_id")
|
user_id = await person_info_manager.get_value(person_id, "user_id")
|
||||||
return str(user_id) if user_id else ""
|
return str(user_id) if user_id else ""
|
||||||
|
|
||||||
return ""
|
return ""
|
||||||
|
|||||||
@@ -178,7 +178,7 @@ class RelationshipBuilder:
|
|||||||
}
|
}
|
||||||
segments.append(new_segment)
|
segments.append(new_segment)
|
||||||
person_info_manager = get_person_info_manager()
|
person_info_manager = get_person_info_manager()
|
||||||
person_name = person_info_manager.get_value(person_id, "person_name") or person_id
|
person_name = await person_info_manager.get_value(person_id, "person_name") or person_id
|
||||||
logger.debug(
|
logger.debug(
|
||||||
f"{self.log_prefix} 重新眼熟用户 {person_name} 创建新消息段(超过10条消息间隔): {new_segment}"
|
f"{self.log_prefix} 重新眼熟用户 {person_name} 创建新消息段(超过10条消息间隔): {new_segment}"
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user