调用mcp微服务测试通过

auth/token_auth_middleware.go

-package auth
-
-import (
-	"net/http"
-	"strings"
-
-	"git.x2erp.com/qdy/go-base/config"
-	"git.x2erp.com/qdy/go-base/ctx"
-	"git.x2erp.com/qdy/go-base/logger"
-)
-
-// // 全局配置（单例）
-// var appConfig config.IConfig
-
-// // ResponseFormat 响应格式
-// type ResponseFormat int
-
-// const (
-// 	FormatJSON ResponseFormat = iota
-// 	FormatCSV
-// )
-
-// // JWTAuthMiddlewareInit 初始化中间件配置
-// func JWTAuthMiddlewareInit(config config.IConfig) {
-// 	appConfig = config
-// }
-
-// JWT认证中间件（支持指定响应格式）
-func TokenAuth(next http.Handler) http.Handler {
-	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-
-		// 从Header获取Authorization
-		authHeader := r.Header.Get("Authorization")
-
-		// 检查Authorization头是否存在
-		if authHeader == "" {
-			unauthorized(w, "Authorization header is required")
-
-		}
-
-		// 检查Bearer格式
-		if !strings.HasPrefix(authHeader, "Bearer ") {
-			unauthorized(w, "Authorization header must start with 'Bearer '")
-
-		}
-
-		token := strings.TrimPrefix(authHeader, "Bearer ")
-
-		// 验证JWT令牌
-		if !isValidToken(token) {
-			unauthorized(w, "Invalid token")
-		}
-
-		appConfig := config.GetConfig()
-		//保存上下文
-		// 创建LoggerContext（从token解析用户信息）
-		requestContext := &ctx.RequestContext{
-			ServiceName:  appConfig.GetServiceConfig().ServiceName,
-			InstanceName: appConfig.GetServiceConfig().InstanceName,
-			TraceID:      "trace_id-123", // 生成追踪ID
-			TenantID:     "tenant-123",   // 从token解析
-			UserID:       "user-456",     // 从token解析
-		}
-
-		if logger.IsDebug() {
-			logger.DebugC(requestContext, "Before save requestContext: %+v", requestContext)
-		}
-
-		// 保存到请求
-		r = ctx.SaveContext(r, requestContext)
-		// 继续处理请求
-		next.ServeHTTP(w, r)
-	})
-}
-
-// 验证令牌（需要根据实际项目实现）
-func isValidToken(token string) bool {
-	// TODO: 实现真正的JWT验证逻辑
-	// 暂时简化处理
-	return token != ""
-}

auth/basic_auth_middewara.go → authbase/basic_auth_middewara.go

-package auth
+package authbase
 
 import (
 	"encoding/base64"

auth/error_unauthorized.go → authbase/error_unauthorized.go

-package auth
+package authbase
 
 import (
 	"encoding/json"
 	json.NewEncoder(w).Encode(response)
 
 	// 记录日志
-	logger.Warn("Basic认证失败: %s", message)
+	logger.Warn("认证失败: %s", message)
 }

authbase/token_auth_middleware.go

+package authbase
+
+import (
+	"fmt"
+	"net/http"
+	"strings"
+	"time"
+
+	"git.x2erp.com/qdy/go-base/config"
+	"git.x2erp.com/qdy/go-base/ctx"
+	"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) {
+		// 1. 检查认证头
+		authHeader := r.Header.Get("Authorization")
+		if authHeader == "" {
+			unauthorized(w, "缺少认证信息")
+			return
+		}
+
+		// 2. 检查Basic格式
+		if !strings.HasPrefix(authHeader, "Bearer ") {
+			unauthorized(w, "认证格式错误，请使用Bearer认证")
+			return
+		}
+
+		// 3. 解码凭证
+		token := strings.TrimPrefix(authHeader, "Bearer ")
+
+		// 验证JWT令牌
+		claims, err := validToken(token)
+		if err != nil {
+
+			unauthorized(w, fmt.Sprintf("Invalid token: %v", err))
+		}
+
+		// 6. 创建请求上下文
+		traceID := r.Header.Get("X-Trace-ID")
+		if traceID == "" {
+			// 生成简单的时间戳追踪ID
+			traceID = time.Now().Format("20060102150405.000")
+		}
+
+		cfg := config.GetConfig()
+
+		requestCtx := &ctx.RequestContext{
+			ServiceName:  cfg.GetServiceConfig().ServiceName,
+			InstanceName: cfg.GetServiceConfig().InstanceName,
+			TraceID:      traceID,
+			TenantID:     claims.TenantID,
+			UserID:       claims.UserID,
+			Username:     claims.Username,
+			ProjectID:    claims.ProjectID,
+		}
+
+		// 7. 保存到请求
+		r = ctx.SaveContext(r, requestCtx)
+
+		// 8. 继续处理
+		next.ServeHTTP(w, r)
+	})
+}
+
+// 验证令牌（需要根据实际项目实现）
+func validToken(token string) (*jwt.Claims, error) {
+	secretKey := config.GetServiceConfig().SecretKey
+	//logger.Debug("secretKey:%s", secretKey)
+	return jwt.ParseToken(token, secretKey)
+}

ctx/request_context.go

 	return &RequestContext{}
 }
 
+// FromContext 从 context.Context 中提取 RequestContext
+func FromContext(ctx context.Context) *RequestContext {
+	if ctx == nil {
+		return &RequestContext{}
+	}
+
+	if v := ctx.Value(loggerKey); v != nil {
+		if reqCtx, ok := v.(*RequestContext); ok {
+			return reqCtx
+		}
+	}
+
+	return &RequestContext{}
+}
+
 func GetContextTest() *RequestContext {
 
 	return &RequestContext{
 		InstanceName: "test-InstanceName",
 		UserID:       "test-UserID",
 		Username:     "test-Username",
+		ProjectID:    "test-ProjectID",
 	}
 }

model/request/configreq/config_requset_model.go

 	YamlName  string `json:"yaml_name," binding:"required"`
 	YamlValue string `json:"yaml_value" binding:"required"`
 }
+
+// ConfigTokenRequest 创建配置中心Token参数
+type ConfigTokenRequest struct {
+	ServiceName string `json:"service_name," binding:"required"`
+	ProjectID   string `json:"project_id," binding:"required"`
+	ExpiresDays int    `json:"expires_days" binding:"required"`
+}

util/jwt/jwt_util.go

 // expiresDays: 过期天数（优先使用）
 // secretKey: 密钥
 func CreateTokenDays(claims *Claims, expiresDays int, secretKey string) (string, error) {
+	//logger.Debug("secretKey:%s", secretKey)
 	return createTokenInternal(claims, expiresDays, 0, secretKey)
 }