fix(core): 修正因异步改造遗漏的 await 调用

在最近的数据库异步化重构后,部分函数的调用处忘记添加 `await` 关键字,导致协程未被正确执行。

本次提交修复了以下模块中的问题:
- `ExpressionLearner`
- `ChatMessageBuilder`
- `EmojiAction
This commit is contained in:
tt-P607
2025-09-20 22:04:43 +08:00
committed by Windpicker-owo
parent 79baac2797
commit 26b9d02476
3 changed files with 6 additions and 6 deletions

View File

@@ -145,7 +145,7 @@ class ExpressionLearner:
Returns: Returns:
bool: 是否成功触发学习 bool: 是否成功触发学习
""" """
if not self.should_trigger_learning(): if not await self.should_trigger_learning():
return False return False
try: try:

View File

@@ -1227,7 +1227,7 @@ async def build_anonymous_messages(messages: List[Dict[str, Any]]) -> str:
# 在最前面添加图片映射信息 # 在最前面添加图片映射信息
final_output_lines = [] final_output_lines = []
pic_mapping_info = build_pic_mapping_info(pic_id_mapping) pic_mapping_info = await build_pic_mapping_info(pic_id_mapping)
if pic_mapping_info: if pic_mapping_info:
final_output_lines.append(pic_mapping_info) final_output_lines.append(pic_mapping_info)
final_output_lines.append("\n\n") final_output_lines.append("\n\n")

View File

@@ -77,7 +77,7 @@ class EmojiAction(BaseAction):
# 3. 根据历史记录筛选表情 # 3. 根据历史记录筛选表情
try: try:
recent_emojis_desc = get_recent_emojis(self.chat_id, limit=10) recent_emojis_desc = await get_recent_emojis(self.chat_id, limit=10)
if recent_emojis_desc: if recent_emojis_desc:
filtered_emojis = [emoji for emoji in all_emojis_obj if emoji.description not in recent_emojis_desc] filtered_emojis = [emoji for emoji in all_emojis_obj if emoji.description not in recent_emojis_desc]
if filtered_emojis: if filtered_emojis:
@@ -122,7 +122,7 @@ class EmojiAction(BaseAction):
emoji_base64, emoji_description = random.choice(all_emojis_data) emoji_base64, emoji_description = random.choice(all_emojis_data)
else: else:
# 获取最近的5条消息内容用于判断 # 获取最近的5条消息内容用于判断
recent_messages = message_api.get_recent_messages(chat_id=self.chat_id, limit=5) recent_messages = await message_api.get_recent_messages(chat_id=self.chat_id, limit=5)
messages_text = "" messages_text = ""
if recent_messages: if recent_messages:
messages_text = await message_api.build_readable_messages( messages_text = await message_api.build_readable_messages(
@@ -181,7 +181,7 @@ class EmojiAction(BaseAction):
elif global_config.emoji.emoji_selection_mode == "description": elif global_config.emoji.emoji_selection_mode == "description":
# --- 详细描述选择模式 --- # --- 详细描述选择模式 ---
# 获取最近的5条消息内容用于判断 # 获取最近的5条消息内容用于判断
recent_messages = message_api.get_recent_messages(chat_id=self.chat_id, limit=5) recent_messages = await message_api.get_recent_messages(chat_id=self.chat_id, limit=5)
messages_text = "" messages_text = ""
if recent_messages: if recent_messages:
messages_text = await message_api.build_readable_messages( messages_text = await message_api.build_readable_messages(
@@ -260,7 +260,7 @@ class EmojiAction(BaseAction):
# 发送成功后,记录到历史 # 发送成功后,记录到历史
try: try:
add_emoji_to_history(self.chat_id, emoji_description) await add_emoji_to_history(self.chat_id, emoji_description)
except Exception as e: except Exception as e:
logger.error(f"{self.log_prefix} 添加表情到历史记录时出错: {e}") logger.error(f"{self.log_prefix} 添加表情到历史记录时出错: {e}")