From 4b89b2a9d66d875769a36551dbd4bef1192dfbd0 Mon Sep 17 00:00:00 2001
From: martsforever <martsforever@aliyun.com>
Date: Tue, 2 Dec 2025 22:12:29 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=E7=9F=A5=E8=AF=86?=
 =?UTF-8?q?=E5=BA=93=E5=8F=AC=E5=9B=9E=E6=8E=A5=E5=8F=A3=EF=BC=8C=E5=B0=86?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6=E5=90=8D=E4=B9=9F=E4=BD=9C=E4=B8=BA=E4=B8=8A?=
 =?UTF-8?q?=E4=B8=8B=E6=96=87=E4=BD=9C=E4=B8=BA=E5=8F=AC=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/utils/milvus_utils.py | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/app/utils/milvus_utils.py b/app/utils/milvus_utils.py
index 18cb8e3..66c99e4 100644
--- a/app/utils/milvus_utils.py
+++ b/app/utils/milvus_utils.py
@@ -111,8 +111,17 @@ class MilvusService:
         用户的问题是：{question}
       """) | create_llm(disable_streaming=True) | StrOutputParser()
 
-    chain_input = {"context": "\n".join([node.node.text for node in result_nodes]), "question": param.question}
+    rag_context = "\n-----------------分隔符------------------\n".join([
+      f"""
+文件名：{node.node.metadata.get('name', "未命名文件.txt")}
+文件内容:
+{node.node.text}
+    """ for node in result_nodes
+    ])
 
+    chain_input = {"context": rag_context, "question": param.question}
+
+    print("chain_input", chain_input)
     relative_content = await chain.ainvoke(chain_input)
 
     # print("milvus search answer", relative_content)