调用mcp微服务测试通过

internal/service/token/token_service.go

@@ -0,0 +1,32 @@
+package token
+
+import (
+	"fmt"
+
+	"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/model/request/configreq"
+	"git.x2erp.com/qdy/go-base/model/response"
+	"git.x2erp.com/qdy/go-base/util"
+	"git.x2erp.com/qdy/go-base/util/jwt"
+)
+
+// CreateConfigureToken 建立访问配置中心token
+func CreateConfigureToken(tokenRequest *configreq.ConfigTokenRequest, reqCtx *ctx.RequestContext) *response.QueryResult[string] {
+
+	claims := &jwt.Claims{
+		UserID:    tokenRequest.ServiceName,
+		ProjectID: tokenRequest.ProjectID,
+	}
+	secretKey := config.GetServiceConfig().SecretKey
+	token, err := jwt.CreateTokenDays(claims, tokenRequest.ExpiresDays, secretKey)
+
+	if err != nil {
+		logger.ErrorC(reqCtx, fmt.Sprintf("建立token产生错误: %v", err))
+		return util.CreateErrorResult[string](fmt.Sprintf("建立token产生错误: %v", err), reqCtx)
+	}
+
+	logger.Debug("建立token成功！")
+	return util.CreateSuccessResultData(token, reqCtx)
+}

main.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"log"
 
-	"git.x2erp.com/qdy/go-base/auth"
+	"git.x2erp.com/qdy/go-base/authbase"
 	"git.x2erp.com/qdy/go-base/config"
 	"git.x2erp.com/qdy/go-base/container"
 	"git.x2erp.com/qdy/go-base/ctx"
@@ -21,6 +21,7 @@ import (
 	"git.x2erp.com/qdy/go-svc-configure/internal/service/register"
 	"git.x2erp.com/qdy/go-svc-configure/internal/service/startup"
 	"git.x2erp.com/qdy/go-svc-configure/internal/service/svcstartup"
+	"git.x2erp.com/qdy/go-svc-configure/internal/service/token"
 	_ "git.x2erp.com/qdy/go-svc-configure/internal/tables" // 导入表定义包，触发 init() 函数
 )
 
@@ -76,39 +77,45 @@ func main() {
 
 // 注册所有路由
 func registerRoutes(ws *router.RouterService, dbFactory *database.DBFactory) {
+	// 建立访问配置中心Token
+	ws.POST("/api/create/config/token",
+		func(tokenRequest *configreq.ConfigTokenRequest, reqCtx *ctx.RequestContext) (*response.QueryResult[string], error) {
+			return token.CreateConfigureToken(tokenRequest, reqCtx), nil
+		},
+	).Use(authbase.BasicAuth).Desc("建立访问配置中心的token").Register()
 
 	// svc
 	ws.POST("/api/delete/config/startup/{servicename}",
 		func(servicename string, req *configreq.ConfigRequest, ctx context.Context, reqCtx *ctx.RequestContext) (*response.QueryResult[int64], error) {
 			return svcstartup.DeleteSVCtartupConfig(servicename, req, ctx, dbFactory, reqCtx), nil
 		},
-	).Use(auth.BasicAuth).Register()
+	).Use(authbase.BasicAuth).Register()
 
 	ws.POST("/api/create/config/startup/{servicename}",
 		func(servicename string, req *configreq.ConfigRequest, ctx context.Context, reqCtx *ctx.RequestContext) (*response.QueryResult[int64], error) {
 			return svcstartup.CreateStartupSVCConfig(servicename, req, ctx, dbFactory, reqCtx), nil
 		},
-	).Use(auth.TokenAuth).Register()
+	).Use(authbase.TokenAuth).Register()
 
 	// startup
 	ws.POST("/api/delete/config/startup",
 		func(req *configreq.ConfigRequest, ctx context.Context, reqCtx *ctx.RequestContext) (*response.QueryResult[int64], error) {
 			return startup.DeleteStartupConfig(req, ctx, dbFactory, reqCtx), nil
 		},
-	).Use(auth.BasicAuth).Register()
+	).Use(authbase.BasicAuth).Register()
 
 	ws.POST("/api/create/config/startup",
 		func(req *configreq.ConfigRequest, ctx context.Context, reqCtx *ctx.RequestContext) (*response.QueryResult[int64], error) {
 			return startup.CreateStartupConfig(req, ctx, dbFactory, reqCtx), nil
 		},
-	).Use(auth.TokenAuth).Register()
+	).Use(authbase.TokenAuth).Register()
 
 	//init
 	ws.POST("/api/init/config/meta",
 		func(ctx context.Context, reqCtx *ctx.RequestContext) (*response.QueryResult[map[string]interface{}], error) {
 			return register.RegisterConfigMeta(ctx, dbFactory, reqCtx), nil
 		},
-	).Use(auth.TokenAuth).Register()
+	).Use(authbase.TokenAuth).Register()
 
 }
 

test/my_config_token_test.go

@@ -0,0 +1,70 @@
+package main
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"log"
+	"net/http"
+	"os/exec"
+	"testing"
+
+	"git.x2erp.com/qdy/go-base/model/request/configreq"
+)
+
+// 建立访问配置中心的token
+func TestCreateConfigToken(t *testing.T) {
+
+	// token := "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyX2lkIjoic3ZjLW1jcCIsInVzZXJuYW1lIjoiIiwidGVuYW50X2lkIjoiIiwicHJvamVjdF9pZCI6Ing2IiwiaXNzIjoiand0LWFwcCIsInN1YiI6InN2Yy1tY3AiLCJleHAiOjE3NjkzNDg4NTksIm5iZiI6MTc2ODc0NDA1OSwiaWF0IjoxNzY4NzQ0MDU5fQ.llW4J4SZct06jXdjjmGpXKl5UYxYeayS5XOGdmrmh8c"
+
+	// c, err := jwt.ParseToken(token, "qwudndgzvxdypdoqd1bhdcdd1qqwzxpoew")
+	// if err != nil {
+	// 	t.Logf("token: %v", err)
+	// }
+	// t.Logf("token: %s", c.ProjectID)
+	// 清除测试缓存
+	cmd := exec.Command("go", "clean", "-testcache")
+	if err := cmd.Run(); err != nil {
+		t.Logf("清除测试缓存失败: %v", err)
+		// 继续执行测试
+	}
+	httpClient := &http.Client{}
+	url := "http://localhost:8080/api/create/config/token"
+
+	data := configreq.ConfigTokenRequest{
+		ProjectID:   "x6",
+		ServiceName: "svc-mcp",
+	}
+	jsonData, err := json.Marshal(data)
+
+	req, err := http.NewRequest("POST", url, bytes.NewReader(jsonData))
+	if err != nil {
+		log.Printf("NewRequest:%v", err)
+	}
+
+	// Basic Auth 认证
+	req.SetBasicAuth("admin", "123")
+
+	//req.Header.Set("Authorization", "Bearer 123")
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := httpClient.Do(req)
+
+	if err != nil {
+		fmt.Printf("发送请求失败: %v\n", err)
+		return
+	}
+	defer resp.Body.Close()
+
+	// 读取响应
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Printf("读取响应失败: %v\n", err)
+		return
+	}
+
+	fmt.Printf("状态码: %d\n", resp.StatusCode)
+	fmt.Printf("响应体: %s\n", string(body))
+
+}

test/my_vaildate_token_test.go

@@ -0,0 +1,20 @@
+package main
+
+import (
+	"testing"
+
+	"git.x2erp.com/qdy/go-base/util/jwt"
+)
+
+// 建立访问配置中心的token
+func TestVaildateConfigToken(t *testing.T) {
+
+	token := "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyX2lkIjoic3ZjLW1jcCIsInVzZXJuYW1lIjoiIiwidGVuYW50X2lkIjoiIiwicHJvamVjdF9pZCI6Ing2IiwiaXNzIjoiand0LWFwcCIsInN1YiI6InN2Yy1tY3AiLCJleHAiOjE3NjkzNDg4NTksIm5iZiI6MTc2ODc0NDA1OSwiaWF0IjoxNzY4NzQ0MDU5fQ.llW4J4SZct06jXdjjmGpXKl5UYxYeayS5XOGdmrmh8c"
+
+	c, err := jwt.ParseToken(token, "qwudndgzvxdypdoqd1bhdcdd1qqwzxpoew")
+	if err != nil {
+		t.Logf("token: %v", err)
+	}
+	t.Logf("token: %s", c.ProjectID)
+
+}