fix(core): 修正因异步改造遗漏的 await 调用
在最近的数据库异步化重构后,部分函数的调用处忘记添加 `await` 关键字,导致协程未被正确执行。 本次提交修复了以下模块中的问题: - `ExpressionLearner` - `ChatMessageBuilder` - `EmojiAction
This commit is contained in:
@@ -167,7 +167,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:
|
||||||
|
|||||||
@@ -1232,7 +1232,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")
|
||||||
|
|||||||
@@ -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}")
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user