From daaee63bd590ff069ed4d50bce45e38e976426cd Mon Sep 17 00:00:00 2001
From: Timebomb2018 <18868801967@163.com>
Date: Wed, 15 Apr 2026 12:15:16 +0800
Subject: [PATCH] refactor(custom-tools): coerce query and request body
 parameters to schema types

---
 api/app/core/tools/custom/base.py | 27 ++++++++++++++++++++-------
 1 file changed, 20 insertions(+), 7 deletions(-)

diff --git a/api/app/core/tools/custom/base.py b/api/app/core/tools/custom/base.py
index c03fe206..93ad03a7 100644
--- a/api/app/core/tools/custom/base.py
+++ b/api/app/core/tools/custom/base.py
@@ -221,7 +221,7 @@ class CustomTool(BaseTool):
         query_params = {}
         for param_name, param_info in operation.get("parameters", {}).items():
             if param_info.get("in") == "query" and param_name in params:
-                query_params[param_name] = params[param_name]
+                query_params[param_name] = self._coerce_param(params[param_name], param_info.get("type", "string"))
         
         if query_params:
             from urllib.parse import urlencode
@@ -251,21 +251,34 @@ class CustomTool(BaseTool):
         return headers
 
     @staticmethod
-    def _build_request_data(operation: Dict[str, Any], params: Dict[str, Any]) -> Optional[Dict[str, Any]]:
+    def _coerce_param(value: Any, schema_type: str) -> Any:
+        """根据 schema 类型转换参数值"""
+        if value is None:
+            return value
+        try:
+            if schema_type == "integer":
+                return int(value)
+            elif schema_type == "number":
+                return float(value)
+            elif schema_type == "boolean":
+                if isinstance(value, str):
+                    return value.lower() not in ("false", "0", "")
+                return bool(value)
+        except (ValueError, TypeError):
+            pass
+        return value
+
+    def _build_request_data(self, operation: Dict[str, Any], params: Dict[str, Any]) -> Optional[Dict[str, Any]]:
         """构建请求数据"""
         if operation["method"] in ["POST", "PUT", "PATCH"]:
             request_body = operation.get("request_body")
             if request_body:
-                # 构建请求体数据
                 data = {}
                 properties = request_body.get("properties", {})
-                
                 for prop_name, prop_schema in properties.items():
                     if prop_name in params:
-                        data[prop_name] = params[prop_name]
-                
+                        data[prop_name] = self._coerce_param(params[prop_name], prop_schema.get("type", "string"))
                 return data if data else None
-        
         return None
     
     async def _send_http_request(