From 80f97cc2d941cc39c416a87ee4e7441eafbb997b Mon Sep 17 00:00:00 2001
From: Wenjie Zhang <xerrors@163.com>
Date: Wed, 25 Feb 2026 11:42:31 +0800
Subject: [PATCH] =?UTF-8?q?fix(attachments):=20=E4=BC=98=E5=8C=96=E9=99=84?=
 =?UTF-8?q?=E4=BB=B6=E7=8A=B6=E6=80=81=E5=90=8C=E6=AD=A5=E9=80=BB=E8=BE=91?=
 =?UTF-8?q?=EF=BC=8C=E4=BF=AE=E5=A4=8D=20files=20=E8=A6=86=E7=9B=96?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 server/routers/chat_router.py        |  5 +++++
 src/services/conversation_service.py | 21 +++++++++++++++------
 2 files changed, 20 insertions(+), 6 deletions(-)

diff --git a/server/routers/chat_router.py b/server/routers/chat_router.py
index eb9343d5..95b41a01 100644
--- a/server/routers/chat_router.py
+++ b/server/routers/chat_router.py
@@ -658,6 +658,11 @@ async def update_thread(
     )
 
 
+
+# ================================
+# > === 附件管理分组 ===
+# ================================
+
 @chat.post("/thread/{thread_id}/attachments", response_model=AttachmentResponse)
 async def upload_thread_attachment(
     thread_id: str,
diff --git a/src/services/conversation_service.py b/src/services/conversation_service.py
index 3f44d101..bf41d805 100644
--- a/src/services/conversation_service.py
+++ b/src/services/conversation_service.py
@@ -2,6 +2,7 @@ import uuid
 from datetime import UTC, datetime
 
 from fastapi import HTTPException, UploadFile
+from langgraph.types import Command
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from src.agents import agent_manager
@@ -78,26 +79,34 @@ async def _sync_thread_attachment_state(
 
         graph = await agent.get_graph()
         config = {"configurable": {"thread_id": thread_id, "user_id": str(user_id)}}
+
+        # 先获取现有 state，保留非附件文件
         state = await graph.aget_state(config)
         state_values = getattr(state, "values", {}) if state else {}
         existing_files = state_values.get("files", {}) if isinstance(state_values, dict) else {}
         if not isinstance(existing_files, dict):
             existing_files = {}
 
-        attachment_files = _build_state_files(attachments)
+        # 保留非 /attachments/ 开头的现有文件（如 Agent 创建的 a.md）
         merged_files = {
             path: file_data
             for path, file_data in existing_files.items()
             if isinstance(path, str) and not path.startswith("/attachments/")
         }
+
+        # 添加附件文件
+        attachment_files = _build_state_files(attachments)
         merged_files.update(attachment_files)
 
+        # 使用 Command 确保 reducer 被正确应用
         await graph.aupdate_state(
             config=config,
-            values={
-                "attachments": attachments,
-                "files": merged_files,
-            },
+            values=Command(
+                update={
+                    "attachments": attachments,
+                    "files": merged_files,
+                }
+            ),
         )
     except Exception as e:
         logger.warning(f"Failed to sync attachment state for thread {thread_id}: {e}")
@@ -260,7 +269,7 @@ async def upload_thread_attachment_view(
         "uploaded_at": utc_isoformat(),
         "truncated": conversion.truncated,
         "file_path": file_path,  # 用于 StateBackend，前端不返回此字段
-        "minio_url": minio_url,
+        "minio_url": minio_url,  # 暂未使用
     }
     await conv_repo.add_attachment(conversation.id, attachment_record)
     all_attachments = await conv_repo.get_attachments(conversation.id)