From 5b05009123c82b65c299a39402ea016dfae8a6d6 Mon Sep 17 00:00:00 2001 From: lixinyue11 <94037597+lixinyue11@users.noreply.github.com> Date: Mon, 12 Jan 2026 17:40:49 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9BUG=EF=BC=8C=E8=AF=BB?= =?UTF-8?q?=E5=8F=96=E6=8E=A5=E5=8F=A3=E7=9A=84end=5Fuser=5Fid=E8=8E=B7?= =?UTF-8?q?=E5=8F=96=E4=B8=8D=E5=87=86=E7=A1=AE=E4=BF=AE=E5=A4=8D=EF=BC=8C?= =?UTF-8?q?statements=E6=A3=80=E7=B4=A2=E5=86=85=E5=AE=B9=E4=B8=BA?= =?UTF-8?q?=E7=A9=BA=E9=9C=80=E8=A6=81=E7=BB=99=E7=A9=BA=E5=88=97=E8=A1=A8?= =?UTF-8?q?=20(#75)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/app/services/memory_agent_service.py | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/api/app/services/memory_agent_service.py b/api/app/services/memory_agent_service.py index d44408fe..4b728412 100644 --- a/api/app/services/memory_agent_service.py +++ b/api/app/services/memory_agent_service.py @@ -396,6 +396,7 @@ class MemoryAgentService: import time start_time = time.time() ori_message=message + end_user_id=group_id # Resolve config_id if None using end_user's connected config if config_id is None: try: @@ -602,18 +603,24 @@ class MemoryAgentService: repo = ShortTermMemoryRepository(db) if str(search_switch)!="2": for intermediate in intermediate_outputs: + print(intermediate) intermediate_type=intermediate['type'] if intermediate_type=="search_result": query=intermediate['query'] raw_results=intermediate['raw_results'] reranked_results=raw_results.get('reranked_results',[]) - statements=[statement['statement'] for statement in reranked_results.get('statements', [])] + try: + statements=[statement['statement'] for statement in reranked_results.get('statements', [])] + except Exception as e: + statements=[] statements=list(set(statements)) retrieved_content.append({query:statements}) - if '信息不足，无法回答' in str(final_answer) or retrieved_content!=[]: + if retrieved_content==[]: + retrieved_content='' + if '信息不足，无法回答。' != str(final_answer) :#and retrieved_content!=[] # 使用 upsert 方法 repo.upsert( - end_user_id=group_id, # 确保这个变量在作用域内 + end_user_id=end_user_id, # 确保这个变量在作用域内 messages=ori_message, aimessages=final_answer, retrieved_content=retrieved_content,