From 04ce6c60196edfe164d19beb2693e61535589cc0 Mon Sep 17 00:00:00 2001 From: Tian jianyong <11429339@qq.com> Date: Wed, 24 Dec 2025 19:28:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-fastapi-backend/utils/semantic_cache_service.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/ruoyi-fastapi-backend/utils/semantic_cache_service.py b/ruoyi-fastapi-backend/utils/semantic_cache_service.py index d65339c..bcb5a80 100644 --- a/ruoyi-fastapi-backend/utils/semantic_cache_service.py +++ b/ruoyi-fastapi-backend/utils/semantic_cache_service.py @@ -256,7 +256,11 @@ class SemanticCacheService: ex=self.CACHE_TTL_HOURS * 3600 ) - logger.info(f"[SemanticCache] 已缓存: {question[:30]}...") + logger.info(f"[SemanticCache] 已缓存 | key={cache_key} | question={question[:30]}...") + + # 验证存储是否成功 + verify = await redis.get(cache_key) + logger.info(f"[SemanticCache] 存储验证 | key={cache_key} | found={verify is not None}") return True except Exception as e: @@ -415,8 +419,11 @@ def get_semantic_cache_service() -> SemanticCacheService: # 便捷函数 async def lookup_question(chat_id: str, question: str, redis_client=None) -> Optional[Tuple[str, float]]: """查找缓存问题""" + logger.info(f"[SemanticCache.lookup_question] 入参 | chat_id={chat_id} | question={question}") service = get_semantic_cache_service() - return await service.lookup(chat_id, question, redis_client) + result = await service.lookup(chat_id, question, redis_client) + logger.info(f"[SemanticCache.lookup_question] 返回 | result={result is not None}") + return result async def store_qa_pair(chat_id: str, question: str, answer: str, redis_client=None) -> bool: