From ebdf4e4c5e33fd36d495e9cb453fe84f45fca9f6 Mon Sep 17 00:00:00 2001
From: Mark <zhuwenhui5566@163.com>
Date: Mon, 5 Jan 2026 19:03:28 +0800
Subject: [PATCH] [fix] converfsation message duplicate entry problem

---
 api/app/services/draft_run_service.py        | 5 +++--
 api/app/services/multi_agent_orchestrator.py | 3 ++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/api/app/services/draft_run_service.py b/api/app/services/draft_run_service.py
index c0d2e3ff..eefc71c5 100644
--- a/api/app/services/draft_run_service.py
+++ b/api/app/services/draft_run_service.py
@@ -454,7 +454,8 @@ class DraftRunService:
         storage_type: Optional[str] = None,
         user_rag_memory_id: Optional[str] = None,
         web_search: bool = True,  # 布尔类型默认值
-        memory: bool = True  # 布尔类型默认值
+        memory: bool = True,  # 布尔类型默认值
+        sub_agent: bool = False # 是否是作为子Agent运行
 
     ) -> AsyncGenerator[str, None]:
         """执行试运行（流式返回，使用 LangChain Agent）
@@ -619,7 +620,7 @@ class DraftRunService:
             elapsed_time = time.time() - start_time
 
             # 10. 保存会话消息
-            if agent_config.memory and agent_config.memory.get("enabled"):
+            if not sub_agent and agent_config.memory and agent_config.memory.get("enabled"):
                 await self._save_conversation_message(
                     conversation_id=conversation_id,
                     user_message=message,
diff --git a/api/app/services/multi_agent_orchestrator.py b/api/app/services/multi_agent_orchestrator.py
index 85eaaad2..08ae7e57 100644
--- a/api/app/services/multi_agent_orchestrator.py
+++ b/api/app/services/multi_agent_orchestrator.py
@@ -1267,7 +1267,8 @@ class MultiAgentOrchestrator:
             storage_type=storage_type,
             user_rag_memory_id=user_rag_memory_id,
             web_search=web_search,
-            memory=memory
+            memory=memory,
+            sub_agent=True
         ):
             yield event