diff --git a/src/chat/express/expression_learner.py b/src/chat/express/expression_learner.py index 4ca25d2c4..f219bcac5 100644 --- a/src/chat/express/expression_learner.py +++ b/src/chat/express/expression_learner.py @@ -232,7 +232,6 @@ class ExpressionLearner: logger.error(f"为聊天流 {self.chat_name} 触发学习失败: {e}") return False - @cached(ttl=600, key_prefix="chat_expressions") async def get_expression_by_chat_id(self) -> tuple[list[dict[str, float]], list[dict[str, float]]]: """ 获取指定chat_id的style和grammar表达方式(带10分钟缓存) @@ -240,12 +239,19 @@ class ExpressionLearner: 优化: 使用CRUD和缓存,减少数据库访问 """ + # 使用静态方法以正确处理缓存键 + return await self._get_expressions_by_chat_id_cached(self.chat_id) + + @staticmethod + @cached(ttl=600, key_prefix="chat_expressions") + async def _get_expressions_by_chat_id_cached(chat_id: str) -> tuple[list[dict[str, float]], list[dict[str, float]]]: + """内部方法:从数据库获取表达方式(带缓存)""" learnt_style_expressions = [] learnt_grammar_expressions = [] # 使用CRUD查询 crud = CRUDBase(Expression) - all_expressions = await crud.get_all_by(chat_id=self.chat_id) + all_expressions = await crud.get_all_by(chat_id=chat_id) for expr in all_expressions: # 确保create_date存在,如果不存在则使用last_active_time @@ -256,7 +262,7 @@ class ExpressionLearner: "style": expr.style, "count": expr.count, "last_active_time": expr.last_active_time, - "source_id": self.chat_id, + "source_id": chat_id, "type": expr.type, "create_date": create_date, } diff --git a/src/chat/message_receive/chat_stream.py b/src/chat/message_receive/chat_stream.py index 9ca750fef..b20892623 100644 --- a/src/chat/message_receive/chat_stream.py +++ b/src/chat/message_receive/chat_stream.py @@ -450,8 +450,8 @@ class ChatManager: defaults={ "user_platform": user_info.platform if user_info else platform, "user_id": user_info.user_id if user_info else "", - "user_nickname": user_info.nickname if user_info else "", - "user_cardname": user_info.cardname if user_info else "", + "user_nickname": user_info.user_nickname if user_info else "", + "user_cardname": user_info.user_cardname if user_info else "", "group_platform": group_info.platform if group_info else None, "group_id": group_info.group_id if group_info else None, "group_name": group_info.group_name if group_info else None, diff --git a/src/person_info/person_info.py b/src/person_info/person_info.py index 793c7f498..931b43720 100644 --- a/src/person_info/person_info.py +++ b/src/person_info/person_info.py @@ -539,14 +539,9 @@ class PersonInfoManager: if record: await crud.delete(record.id) - # 清除相关缓存 - from src.common.database.optimization.cache_manager import get_cache - from src.common.database.utils.decorators import generate_cache_key - cache = await get_cache() - - # 清除所有相关的person缓存 - await cache.delete(generate_cache_key("person_known", p_id)) - await cache.delete(generate_cache_key("person_field", p_id)) + # 注意: 删除操作很少发生,缓存会在TTL过期后自动清除 + # 无法从person_id反向得到platform和user_id,因此无法精确清除缓存 + # 删除后的查询仍会返回正确结果(None/False) return 1 return 0 except Exception as e: