From 87775c9fb1ec5f79d312871f624da0a633779a0a Mon Sep 17 00:00:00 2001
From: KevinLiao <kevinlyhan@gmail.com>
Date: Sun, 10 Aug 2025 08:46:26 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8DClaude=20Console?=
 =?UTF-8?q?=E8=B4=A6=E5=8F=B7=E6=A8=A1=E5=9E=8B=E6=98=A0=E5=B0=84=E7=9A=84?=
 =?UTF-8?q?=E7=9A=84=E6=B5=81=E5=BC=8F=E5=93=8D=E5=BA=94?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/services/claudeConsoleRelayService.js | 25 ++++++++++++++++++++++-
 1 file changed, 24 insertions(+), 1 deletion(-)

diff --git a/src/services/claudeConsoleRelayService.js b/src/services/claudeConsoleRelayService.js
index ec54e287..d59eea11 100644
--- a/src/services/claudeConsoleRelayService.js
+++ b/src/services/claudeConsoleRelayService.js
@@ -229,6 +229,29 @@ class ClaudeConsoleRelayService {
       )
       logger.debug(`🌐 Account API URL: ${account.apiUrl}`)
 
+      // 处理模型映射
+      let mappedModel = requestBody.model
+      if (
+        account.supportedModels &&
+        typeof account.supportedModels === 'object' &&
+        !Array.isArray(account.supportedModels)
+      ) {
+        const newModel = claudeConsoleAccountService.getMappedModel(
+          account.supportedModels,
+          requestBody.model
+        )
+        if (newModel !== requestBody.model) {
+          logger.info(`🔄 [Stream] Mapping model from ${requestBody.model} to ${newModel}`)
+          mappedModel = newModel
+        }
+      }
+
+      // 创建修改后的请求体
+      const modifiedRequestBody = {
+        ...requestBody,
+        model: mappedModel
+      }
+
       // 模型兼容性检查已经在调度器中完成，这里不需要再检查
 
       // 创建代理agent
@@ -236,7 +259,7 @@ class ClaudeConsoleRelayService {
 
       // 发送流式请求
       await this._makeClaudeConsoleStreamRequest(
-        requestBody,
+        modifiedRequestBody,
         account,
         proxyAgent,
         clientHeaders,