add react

document_processor.py

@@ -4,12 +4,9 @@
 """
 
 try:
-    from langchain_text_splitters import RecursiveCharacterTextSplitter
+    from langchain.text_splitter import RecursiveCharacterTextSplitter
 except ImportError:
-    try:
-        from langchain_text_splitters import RecursiveCharacterTextSplitter
-    except ImportError:
-        from langchain.text_splitter import RecursiveCharacterTextSplitter
+    from langchain_text_splitters import RecursiveCharacterTextSplitter
 
 from langchain_community.document_loaders import WebBaseLoader
 from langchain_community.vectorstores import Chroma

run_server.py

@@ -49,11 +49,17 @@ def start_ngrok():
 
 def start_cloudflared():
     try:
-        if not shutil.which("cloudflared"):
-            subprocess.check_call([sys.executable, "-m", "pip", "install", "cloudflared"])
-        proc = subprocess.Popen([
-            "cloudflared", "tunnel", "--url", "http://localhost:8000", "--no-autoupdate"
-        ], stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True)
+        cmd = None
+        if shutil.which("cloudflared"):
+            cmd = ["cloudflared", "tunnel", "--url", "http://localhost:8000", "--no-autoupdate"]
+        else:
+            try:
+                __import__("cloudflared")
+                cmd = [sys.executable, "-m", "cloudflared", "tunnel", "--url", "http://localhost:8000", "--no-autoupdate"]
+            except Exception:
+                print("⚠️ 未找到 cloudflared，可通过 'pip install cloudflared' 安装，或跳过穿透")
+                return
+        proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True)
         url = None
         while True:
             line = proc.stdout.readline()
@@ -98,6 +104,18 @@ if __name__ == "__main__":
     # 等待服务器启动
     time.sleep(3)
     
-    ok = start_ngrok()
-    if not ok:
-        start_cloudflared()
+    use_tunnel = os.environ.get("USE_TUNNEL", "true").lower() == "true"
+    if use_tunnel:
+        ok = start_ngrok()
+        if not ok:
+            start_cloudflared()
+    else:
+        print("\n" + "="*60)
+        print("✅ 服务器已启动，局域网访问地址:")
+        print("👉 http://127.0.0.1:8000")
+        print("="*60 + "\n")
+        try:
+            while True:
+                time.sleep(1)
+        except KeyboardInterrupt:
+            pass

server.py

@@ -26,13 +26,8 @@ import shutil
 sys.path.append(os.getcwd())
 
 try:
-    from main import AdaptiveRAGSystem
     from config import ENABLE_MULTIMODAL
-except ImportError:
-    # 模拟导入，防止在没有依赖的环境下报错
-    class AdaptiveRAGSystem:
-        def __init__(self, *args, **kwargs): pass
-        def query(self, _): return {"answer": "系统未正确初始化", "sources": []}
+except Exception:
     ENABLE_MULTIMODAL = False
 
 # ============================================================
@@ -62,6 +57,7 @@ def get_rag_system():
     if rag_system is None:
         try:
             print("🔄 初始化 RAG 系统...")
+            from main import AdaptiveRAGSystem
             rag_system = AdaptiveRAGSystem()
             print("✅ RAG 系统初始化完成")
         except Exception as e: