From 16f80b3100a988d1857367aa6ae199a8b00c89a3 Mon Sep 17 00:00:00 2001
From: Tian jianyong <11429339@qq.com>
Date: Wed, 17 Dec 2025 17:11:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=A9=BA=E5=80=BC=E6=A3=80?=
 =?UTF-8?q?=E6=9F=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../module_admin/controller/ragflow_controller.py        | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py b/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py
index aa19f86..538d9ad 100644
--- a/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py
+++ b/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py
@@ -169,6 +169,15 @@ def stream_ragflow_response(result: Generator, chat_id: str, start_time: float)
             if isinstance(body, dict) and 'answer' in body:
                 current_answer = body['answer']
                 
+                # 安全检查：确保current_answer不为None且为字符串
+                if current_answer is None:
+                    logger.warning(f"[RAG_SERVER {chunk_time:.3f}] ⚠️ current_answer为None，跳过处理")
+                    continue
+                
+                if not isinstance(current_answer, str):
+                    logger.warning(f"[RAG_SERVER {chunk_time:.3f}] ⚠️ current_answer不是字符串，类型: {type(current_answer)}")
+                    current_answer = str(current_answer)
+                
                 # 计算增量内容
                 if current_answer.startswith(last_answer):
                     delta = current_answer[len(last_answer):]