feat: Gateway 优先对话 + SOUL.md 人设 fallback

image_daemon.py

@@ -15,6 +15,11 @@ API_BASE_URL = os.environ.get("API_BASE_URL", "https://asem12345-cliproxyapi.hf.
 API_KEY = os.environ.get("API_KEY", "")
 MODEL_NAME = os.environ.get("MODEL_NAME", "gemini-3-flash")
 
+# OpenClaw Gateway (本地)
+OPENCLAW_GATEWAY = "http://127.0.0.1:18789/v1"
+_use_gateway = False  # 启动时探测决定
+_soul_prompt = ""     # SOUL.md 内容
+
 # ---------- 日志 ----------
 def log(msg):
     ts = time.strftime("%H:%M:%S")
@@ -181,40 +186,85 @@ def handle_image_message(message_id, chat_id, image_key):
             f.write(img_data)
         log(f"⚠️ 图床全部失败，本地保存: {path}")
 
+# ---------- SOUL.md 加载 ----------
+def load_soul():
+    """读取人设文件，去除图片处理指令（由 Daemon 接管）"""
+    global _soul_prompt
+    soul_path = "/root/.openclaw/workspace/SOUL.md"
+    try:
+        with open(soul_path, "r", encoding="utf-8") as f:
+            content = f.read()
+        # 去除图片处理指令（Daemon 已接管，避免 LLM 产生幻觉）
+        if "## 图片处理" in content:
+            content = content[:content.index("## 图片处理")].rstrip()
+        _soul_prompt = content
+        log(f"✅ SOUL.md 已加载 ({len(_soul_prompt)} 字)")
+    except FileNotFoundError:
+        _soul_prompt = "You are MoltBot, a helpful AI assistant."
+        log("⚠️ SOUL.md 未找到，使用默认人设")
+    except Exception as e:
+        _soul_prompt = "You are MoltBot, a helpful AI assistant."
+        log(f"⚠️ SOUL.md 加载失败: {e}")
+
+# ---------- OpenClaw Gateway 探测 ----------
+def check_openclaw_gateway():
+    """探测本地 Gateway 是否可用"""
+    global _use_gateway
+    try:
+        resp = requests.post(
+            f"{OPENCLAW_GATEWAY}/chat/completions",
+            json={"model": "default", "messages": [{"role": "user", "content": "ping"}]},
+            timeout=5
+        )
+        if resp.status_code in (200, 201):
+            _use_gateway = True
+            log(f"✅ OpenClaw Gateway 可用 ({OPENCLAW_GATEWAY})")
+        else:
+            log(f"⚠️ Gateway 响应 {resp.status_code}，使用外部 LLM")
+    except Exception as e:
+        log(f"⚠️ Gateway 不可用 ({e})，使用外部 LLM + SOUL 人设")
+
 # ---------- LLM 对话 ----------
 def chat_with_llm(user_text):
-    """调用 LLM API 获取回复"""
-    if not API_KEY:
-        log("❌ API_KEY 未设置，无法对话")
-        return "抱歉，我的大脑连接中断了 (API_KEY missing)"
-
+    """优先转发给本地 OpenClaw Gateway（带人设+插件），Fallback 到外部 LLM+SOUL"""
     try:
+        if _use_gateway:
+            # 走 OpenClaw Gateway：人设和工具由它处理
+            resp = requests.post(
+                f"{OPENCLAW_GATEWAY}/chat/completions",
+                json={"model": "default", "messages": [{"role": "user", "content": user_text}], "stream": False},
+                timeout=120
+            )
+            if resp.status_code == 200:
+                data = resp.json()
+                reply = data["choices"][0]["message"]["content"]
+                log(f"🤖 Gateway 回复: {reply[:60]}...")
+                return reply
+            log(f"⚠️ Gateway 失败 ({resp.status_code})，Fallback 到外部 LLM")
+
+        # Fallback：外部 LLM + SOUL.md 人设
+        if not API_KEY:
+            return "抱歉，我的大脑连接中断了 (API_KEY missing)"
         url = f"{API_BASE_URL}/chat/completions"
-        headers = {
-            "Authorization": f"Bearer {API_KEY}",
-            "Content-Type": "application/json"
-        }
+        headers = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"}
         payload = {
             "model": MODEL_NAME,
             "messages": [
-                {"role": "system", "content": "You are MoltBot, a helpful AI assistant."},
+                {"role": "system", "content": _soul_prompt or "You are a helpful assistant."},
                 {"role": "user", "content": user_text}
             ],
             "stream": False
         }
-        log(f"🤖 调用 LLM: {user_text[:50]}...")
+        log(f"🤖 外部 LLM ({MODEL_NAME}): {user_text[:50]}...")
         resp = requests.post(url, headers=headers, json=payload, timeout=60)
-        
         if resp.status_code == 200:
-            data = resp.json()
-            reply = data["choices"][0]["message"]["content"]
-            log(f"🤖 LLM 回复: {reply[:50]}...")
+            reply = resp.json()["choices"][0]["message"]["content"]
+            log(f"🤖 LLM 回复: {reply[:60]}...")
             return reply
-        else:
-            log(f"❌ LLM 错误 {resp.status_code}: {resp.text}")
-            return f"思考时遇到错误 ({resp.status_code})"
+        log(f"❌ 外部 LLM 错误 {resp.status_code}: {resp.text[:100]}")
+        return f"思考时遇到错误 ({resp.status_code})"
     except Exception as e:
-        log(f"❌ LLM 异常: {e}")
+        log(f"❌ chat_with_llm 异常: {e}")
         return f"大脑短路了: {e}"
 
 # ---------- 处理文本消息 ----------
@@ -284,6 +334,9 @@ def main():
         log("❌ FEISHU_APP_ID 或 FEISHU_APP_SECRET 未设置，退出")
         sys.exit(1)
 
+    # 加载人设
+    load_soul()
+
     # 预热 token
     token = get_token()
     if token:
@@ -291,6 +344,12 @@ def main():
     else:
         log("⚠️ Token 获取失败，稍后重试")
 
+    # 延迟探测 OpenClaw Gateway（等 Gateway 先启动完成）
+    def delayed_gateway_check():
+        time.sleep(10)
+        check_openclaw_gateway()
+    threading.Thread(target=delayed_gateway_check, daemon=True).start()
+
     # 初始化 lark-oapi WebSocket 客户端
     try:
         import lark_oapi as lark