调用mcp-调用工具测试通过

authbase/basic_auth_middewara.go

@@ -8,55 +8,106 @@ import (
 
 	"git.x2erp.com/qdy/go-base/config"
 	"git.x2erp.com/qdy/go-base/ctx"
+	"git.x2erp.com/qdy/go-base/logger"
 )
 
 // BasicAuth 简化的Basic认证中间件
 func BasicAuth(next http.Handler) http.Handler {
 	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if logger.IsDebug() {
+			logger.Debug("BasicAuth中间件开始处理请求: %s %s", r.Method, r.URL.Path)
+		}
 		// 1. 检查认证头
 		authHeader := r.Header.Get("Authorization")
 		if authHeader == "" {
+			if logger.IsDebug() {
+				logger.Debug("认证头缺失，请求未授权: %s %s", r.Method, r.URL.Path)
+			}
 			unauthorized(w, "缺少认证信息")
 			return
 		}
 
+		if logger.IsDebug() {
+			displayHeader := authHeader
+			if len(displayHeader) > 20 {
+				displayHeader = displayHeader[:20] + "..."
+			}
+			logger.Debug("收到认证头: %s", displayHeader)
+		}
+
 		// 2. 检查Basic格式
 		if !strings.HasPrefix(authHeader, "Basic ") {
+			if logger.IsDebug() {
+				displayHeader := authHeader
+				if len(displayHeader) > 20 {
+					displayHeader = displayHeader[:20] + "..."
+				}
+				logger.Debug("认证格式错误，需要Basic认证: %s", displayHeader)
+			}
 			unauthorized(w, "认证格式错误，请使用Basic认证")
 			return
 		}
 
 		// 3. 解码凭证
 		base64Creds := strings.TrimPrefix(authHeader, "Basic ")
+		if logger.IsDebug() {
+			logger.Debug("解码Base64凭证，长度: %d", len(base64Creds))
+		}
 		credsBytes, err := base64.StdEncoding.DecodeString(base64Creds)
 		if err != nil {
+			if logger.IsDebug() {
+				logger.Debug("Base64解码失败: %v", err)
+			}
 			unauthorized(w, "认证信息解码失败")
 			return
 		}
 
 		// 4. 分割用户名密码
 		creds := string(credsBytes)
+		if logger.IsDebug() {
+			logger.Debug("解码后凭证长度: %d", len(creds))
+		}
 		parts := strings.SplitN(creds, ":", 2)
 		if len(parts) != 2 {
+			if logger.IsDebug() {
+				logger.Debug("用户名密码格式错误，分割后部分数: %d", len(parts))
+			}
 			unauthorized(w, "用户名密码格式错误")
 			return
 		}
 
 		username := parts[0]
 		password := parts[1]
+		if logger.IsDebug() {
+			logger.Debug("提取用户名: %s，密码长度: %d", username, len(password))
+		}
 
 		// 5. 验证用户名密码
+		if logger.IsDebug() {
+			logger.Debug("开始验证用户名密码: %s", username)
+		}
 		userID, tenantID, ok := verifyCredentials(username, password)
 		if !ok {
+			if logger.IsDebug() {
+				logger.Debug("用户名密码验证失败: %s", username)
+			}
 			unauthorized(w, "用户名或密码错误")
 			return
 		}
+		if logger.IsDebug() {
+			logger.Debug("用户名密码验证成功: userID=%s, tenantID=%s", userID, tenantID)
+		}
 
 		// 6. 创建请求上下文
 		traceID := r.Header.Get("X-Trace-ID")
 		if traceID == "" {
 			// 生成简单的时间戳追踪ID
 			traceID = time.Now().Format("20060102150405.000")
+			if logger.IsDebug() {
+				logger.Debug("生成TraceID: %s", traceID)
+			}
+		} else if logger.IsDebug() {
+			logger.Debug("使用请求中的TraceID: %s", traceID)
 		}
 
 		cfg := config.GetConfig()
@@ -70,16 +121,27 @@ func BasicAuth(next http.Handler) http.Handler {
 			Username:     username,
 		}
 
+		if logger.IsDebug() {
+			logger.Debug("创建请求上下文: service=%s, instance=%s, tenant=%s, user=%s",
+				requestCtx.ServiceName, requestCtx.InstanceName, requestCtx.TenantID, requestCtx.UserID)
+		}
+
 		// 7. 保存到请求
 		r = ctx.SaveContext(r, requestCtx)
 
 		// 8. 继续处理
+		if logger.IsDebug() {
+			logger.Debug("BasicAuth中间件处理完成，继续下一个处理器")
+		}
 		next.ServeHTTP(w, r)
 	})
 }
 
 // 验证用户名密码（简单示例）
 func verifyCredentials(username, password string) (userID, tenantID string, ok bool) {
+	if logger.IsDebug() {
+		logger.Debug("验证凭据，用户名: %s", username)
+	}
 
 	// 这里替换为你的实际验证逻辑
 	cfg := config.GetConfig()
@@ -87,7 +149,13 @@ func verifyCredentials(username, password string) (userID, tenantID string, ok b
 	sysPassword := cfg.GetServiceConfig().Password
 
 	if username == sysUsername && password == sysPassword {
+		if logger.IsDebug() {
+			logger.Debug("凭据验证成功，用户名匹配系统用户")
+		}
 		return sysUsername, "tenant-admin", true
 	}
+	if logger.IsDebug() {
+		logger.Debug("凭据验证失败，用户名或密码不匹配")
+	}
 	return "", "", false
 }

authbase/token_auth_middleware.go

@@ -8,33 +8,64 @@ import (
 
 	"git.x2erp.com/qdy/go-base/config"
 	"git.x2erp.com/qdy/go-base/ctx"
+	"git.x2erp.com/qdy/go-base/logger"
 	"git.x2erp.com/qdy/go-base/util/jwt"
 )
 
 // TokenAuth 简化的Bearer认证中间件
 func TokenAuth(next http.Handler) http.Handler {
 	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if logger.IsDebug() {
+			logger.Debug("TokenAuth中间件开始处理请求: %s %s", r.Method, r.URL.Path)
+		}
 		// 1. 检查认证头
 		authHeader := r.Header.Get("Authorization")
 		if authHeader == "" {
+			if logger.IsDebug() {
+				logger.Debug("认证头缺失，请求未授权: %s %s", r.Method, r.URL.Path)
+			}
 			unauthorized(w, "缺少认证信息")
 			return
 		}
 
-		// 2. 检查Basic格式
+		if logger.IsDebug() {
+			displayHeader := authHeader
+			if len(displayHeader) > 20 {
+				displayHeader = displayHeader[:20] + "..."
+			}
+			logger.Debug("收到认证头: %s", displayHeader)
+		}
+
+		// 2. 检查Bearer格式
 		if !strings.HasPrefix(authHeader, "Bearer ") {
+			if logger.IsDebug() {
+				displayHeader := authHeader
+				if len(displayHeader) > 20 {
+					displayHeader = displayHeader[:20] + "..."
+				}
+				logger.Debug("认证格式错误，需要Bearer认证: %s", displayHeader)
+			}
 			unauthorized(w, "认证格式错误，请使用Bearer认证")
 			return
 		}
 
 		// 3. 解码凭证
 		token := strings.TrimPrefix(authHeader, "Bearer ")
+		if logger.IsDebug() {
+			logger.Debug("验证JWT令牌，令牌长度: %d", len(token))
+		}
 
 		// 验证JWT令牌
 		claims, err := validToken(token)
 		if err != nil {
-
+			if logger.IsDebug() {
+				logger.Debug("JWT令牌验证失败: %v", err)
+			}
 			unauthorized(w, fmt.Sprintf("Invalid token: %v", err))
+			return
+		}
+		if logger.IsDebug() {
+			logger.Debug("JWT令牌验证成功，用户: %s, 租户: %s", claims.Username, claims.TenantID)
 		}
 
 		// 6. 创建请求上下文
@@ -42,6 +73,11 @@ func TokenAuth(next http.Handler) http.Handler {
 		if traceID == "" {
 			// 生成简单的时间戳追踪ID
 			traceID = time.Now().Format("20060102150405.000")
+			if logger.IsDebug() {
+				logger.Debug("生成TraceID: %s", traceID)
+			}
+		} else if logger.IsDebug() {
+			logger.Debug("使用请求中的TraceID: %s", traceID)
 		}
 
 		cfg := config.GetConfig()
@@ -56,10 +92,18 @@ func TokenAuth(next http.Handler) http.Handler {
 			ProjectID:    claims.ProjectID,
 		}
 
+		if logger.IsDebug() {
+			logger.Debug("创建请求上下文: service=%s, instance=%s, tenant=%s, user=%s",
+				requestCtx.ServiceName, requestCtx.InstanceName, requestCtx.TenantID, requestCtx.UserID)
+		}
+
 		// 7. 保存到请求
 		r = ctx.SaveContext(r, requestCtx)
 
 		// 8. 继续处理
+		if logger.IsDebug() {
+			logger.Debug("TokenAuth中间件处理完成，继续下一个处理器")
+		}
 		next.ServeHTTP(w, r)
 	})
 }
@@ -67,6 +111,84 @@ func TokenAuth(next http.Handler) http.Handler {
 // 验证令牌（需要根据实际项目实现）
 func validToken(token string) (*jwt.Claims, error) {
 	secretKey := config.GetServiceConfig().SecretKey
-	//logger.Debug("secretKey:%s", secretKey)
+	if logger.IsDebug() {
+		logger.Debug("验证JWT令牌，secretKey长度: %d", len(secretKey))
+	}
 	return jwt.ParseToken(token, secretKey)
 }
+
+// PrintAllHeaders 打印HTTP请求的所有头部信息
+// func printAllHeaders(r *http.Request) {
+// 	if !logger.IsDebug() {
+// 		return
+// 	}
+// 	logger.Debug("=== HTTP 请求头 ===")
+// 	for name, values := range r.Header {
+// 		for _, value := range values {
+// 			logger.Debug("%s: %s", name, value)
+// 		}
+// 	}
+// 	logger.Debug("==================")
+// }
+
+// DebugPrintFullRequest 打印完整的HTTP请求信息（头+体），并确保请求体可被后续代码正常读取。
+// 将此函数在处理请求的最开始调用。
+// func debugPrintFullRequest(r *http.Request) {
+// 	if !logger.IsDebug() {
+// 		return
+// 	}
+// 	logger.Debug("🔍 [DEBUG] ====== 开始打印完整请求 ======")
+
+// 	// 1. 打印基本请求信息
+// 	logger.Debug("[DEBUG] 方法: %s, URL: %s, 协议: %s", r.Method, r.URL.String(), r.Proto)
+
+// 	// 2. 打印所有请求头
+// 	logger.Debug("[DEBUG] --- 请求头 ---")
+// 	// 按字母顺序排序输出，更易读
+// 	var headers []string
+// 	for key := range r.Header {
+// 		headers = append(headers, key)
+// 	}
+// 	sort.Strings(headers)
+// 	for _, key := range headers {
+// 		logger.Debug("[DEBUG] %s: %s", key, strings.Join(r.Header[key], ", "))
+// 	}
+
+// 	// 3. 【核心】读取、打印并恢复请求体
+// 	logger.Debug("[DEBUG] --- 请求体 (原始) ---")
+// 	if r.Body == nil || r.ContentLength == 0 {
+// 		logger.Debug("[DEBUG] 请求体为空")
+// 	} else {
+// 		// 读取原始Body内容
+// 		originalBodyBytes, err := io.ReadAll(r.Body)
+// 		if err != nil {
+// 			logger.Debug("[DEBUG] 读取请求体失败: %v", err)
+// 			// 即使失败，也要尝试恢复一个空Body，避免后续panic
+// 			r.Body = io.NopCloser(bytes.NewBuffer(nil))
+// 			return
+// 		}
+// 		// 重要：立即关闭原Body流
+// 		r.Body.Close()
+
+// 		// 打印原始内容
+// 		logger.Debug("[DEBUG] 内容长度: %d 字节", len(originalBodyBytes))
+// 		logger.Debug(string(originalBodyBytes))
+
+// 		// 【关键步骤】将读取的字节重新设置回 r.Body，供后续使用
+// 		r.Body = io.NopCloser(bytes.NewBuffer(originalBodyBytes))
+
+// 		// 4. （可选）尝试美化打印JSON，便于阅读
+// 		logger.Debug("[DEBUG] --- 请求体 (JSON美化) ---")
+// 		if len(originalBodyBytes) > 0 {
+// 			var prettyJSON bytes.Buffer
+// 			if err := json.Indent(&prettyJSON, originalBodyBytes, "", "  "); err == nil {
+// 				// 是有效的JSON
+// 				logger.Debug(prettyJSON.String())
+// 			} else {
+// 				// 不是JSON或格式错误，打印原始内容
+// 				logger.Debug("[DEBUG] 内容非JSON格式，上方已打印原始内容。")
+// 			}
+// 		}
+// 	}
+// 	logger.Debug("🔍 [DEBUG] ====== 结束打印 ======\n")
+// }

config/subconfigs/database_common.go

@@ -20,9 +20,7 @@ type DbConfig struct {
 
 // SetDbDefaults 设置数据库配置默认值
 func SetDbDefaults(c *DbConfig) {
-	if c.Type == "" {
-		c.Type = "mysql"
-	}
+
 	if c.Port == 0 {
 		c.Port = 3306
 	}

config/subconfigs/database_config.go

@@ -1,6 +1,8 @@
 package subconfigs
 
-import "git.x2erp.com/qdy/go-base/config/core"
+import (
+	"git.x2erp.com/qdy/go-base/config/core"
+)
 
 // DatabaseConfig 单个数据库配置
 type DatabaseConfig struct {
@@ -18,7 +20,9 @@ func (c *DatabaseConfig) SetDefaults() {
 }
 
 func (c *DatabaseConfig) Load(data map[string]interface{}) error {
+
 	return c.LoadFromYAML(data, c)
+
 }
 
 func (c *DatabaseConfig) Validate() error {