mcp测试通过

.gitignore

@@ -0,0 +1 @@
+logs/

gct.sh

@@ -0,0 +1,25 @@
+#!/bin/bash
+
+# 使用命令行参数，如果没有提供则使用默认值
+COMMIT_MSG="${1:-初始提交}"
+TAG_VERSION="${2:-v0.1.0}"
+
+echo "提交信息: $COMMIT_MSG"
+echo "标签版本: $TAG_VERSION"
+
+# 提交和推送
+git add .
+git commit -m "$COMMIT_MSG"
+git push -u origin master
+
+# 创建标签（关键修改在这里）
+# 方法1：使用注释标签（推荐，不会打开编辑器）
+git tag -a "$TAG_VERSION" -m "Release $TAG_VERSION"
+
+# 或者方法2：如果你需要GPG签名，使用这个
+# GIT_EDITOR=true git tag -s "$TAG_VERSION" -m "Release $TAG_VERSION"
+
+# 推送标签
+git push origin "$TAG_VERSION"
+
+echo "完成！"

go.mod

@@ -0,0 +1,34 @@
+module git.x2erp.com/qdy/go-svc-mcp
+
+go 1.25.4
+
+replace git.x2erp.com/qdy/go-base => ../go-base
+
+replace git.x2erp.com/qdy/go-db => ../go-db
+
+require (
+	git.x2erp.com/qdy/go-base v0.1.15
+	git.x2erp.com/qdy/go-db v0.0.0-00010101000000-000000000000
+	github.com/modelcontextprotocol/go-sdk v1.2.0
+)
+
+require (
+	filippo.io/edwards25519 v1.1.0 // indirect
+	github.com/go-sql-driver/mysql v1.9.3 // indirect
+	github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect
+	github.com/golang-sql/sqlexp v0.1.0 // indirect
+	github.com/google/jsonschema-go v0.3.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/jmoiron/sqlx v1.4.0 // indirect
+	github.com/lib/pq v1.10.9 // indirect
+	github.com/microsoft/go-mssqldb v1.9.4 // indirect
+	github.com/sijms/go-ora/v2 v2.9.0 // indirect
+	github.com/yosida95/uritemplate/v3 v3.0.2 // indirect
+	go.uber.org/multierr v1.10.0 // indirect
+	go.uber.org/zap v1.27.1 // indirect
+	golang.org/x/crypto v0.46.0 // indirect
+	golang.org/x/oauth2 v0.30.0 // indirect
+	golang.org/x/text v0.32.0 // indirect
+	gopkg.in/natefinch/lumberjack.v2 v2.2.1 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
+)

go.sum

@@ -0,0 +1,86 @@
+filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
+filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0 h1:Gt0j3wceWMwPmiazCa8MzMA0MfhmPIz0Qp0FJ6qcM0U=
+github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0/go.mod h1:Ot/6aikWnKWi4l9QB7qVSwa8iMphQNqkWALMoNT3rzM=
+github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.10.1 h1:B+blDbyVIG3WaikNxPnhPiJ1MThR03b3vKGtER95TP4=
+github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.10.1/go.mod h1:JdM5psgjfBf5fo2uWOZhflPWyDBZ/O/CNAH9CtsuZE4=
+github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.1 h1:FPKJS1T+clwv+OLGt13a8UjqeRuh0O4SJ3lUriThc+4=
+github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.1/go.mod h1:j2chePtV91HrC22tGoRX3sGY42uF13WzmmV80/OdVAA=
+github.com/Azure/azure-sdk-for-go/sdk/security/keyvault/azkeys v1.3.1 h1:Wgf5rZba3YZqeTNJPtvqZoBu1sBN/L4sry+u2U3Y75w=
+github.com/Azure/azure-sdk-for-go/sdk/security/keyvault/azkeys v1.3.1/go.mod h1:xxCBG/f/4Vbmh2XQJBsOmNdxWUY5j/s27jujKPbQf14=
+github.com/Azure/azure-sdk-for-go/sdk/security/keyvault/internal v1.1.1 h1:bFWuoEKg+gImo7pvkiQEFAc8ocibADgXeiLAxWhWmkI=
+github.com/Azure/azure-sdk-for-go/sdk/security/keyvault/internal v1.1.1/go.mod h1:Vih/3yc6yac2JzU4hzpaDupBJP0Flaia9rXXrU8xyww=
+github.com/AzureAD/microsoft-authentication-library-for-go v1.4.2 h1:oygO0locgZJe7PpYPXT5A29ZkwJaPqcva7BVeemZOZs=
+github.com/AzureAD/microsoft-authentication-library-for-go v1.4.2/go.mod h1:wP83P5OoQ5p6ip3ScPr0BAq0BvuPAvacpEuSzyouqAI=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg=
+github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1aweo=
+github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=
+github.com/golang-jwt/jwt/v5 v5.2.2 h1:Rl4B7itRWVtYIHFrSNd7vhTiz9UpLdi6gZhZ3wEeDy8=
+github.com/golang-jwt/jwt/v5 v5.2.2/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
+github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
+github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
+github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
+github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI=
+github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
+github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
+github.com/google/jsonschema-go v0.3.0 h1:6AH2TxVNtk3IlvkkhjrtbUc4S8AvO0Xii0DxIygDg+Q=
+github.com/google/jsonschema-go v0.3.0/go.mod h1:r5quNTdLOYEz95Ru18zA0ydNbBuYoo9tgaYcxEYhJVE=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/jmoiron/sqlx v1.4.0 h1:1PLqN7S1UYp5t4SrVVnt4nUVNemrDAtxlulVe+Qgm3o=
+github.com/jmoiron/sqlx v1.4.0/go.mod h1:ZrZ7UsYB/weZdl2Bxg6jCRO9c3YHl8r3ahlKmRT4JLY=
+github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
+github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc=
+github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
+github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
+github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
+github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU=
+github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
+github.com/microsoft/go-mssqldb v1.9.4 h1:sHrj3GcdgkxytZ09aZ3+ys72pMeyEXJowT44j74pNgs=
+github.com/microsoft/go-mssqldb v1.9.4/go.mod h1:GBbW9ASTiDC+mpgWDGKdm3FnFLTUsLYN3iFL90lQ+PA=
+github.com/modelcontextprotocol/go-sdk v1.2.0 h1:Y23co09300CEk8iZ/tMxIX1dVmKZkzoSBZOpJwUnc/s=
+github.com/modelcontextprotocol/go-sdk v1.2.0/go.mod h1:6fM3LCm3yV7pAs8isnKLn07oKtB0MP9LHd3DfAcKw10=
+github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c h1:+mdjkGKdHQG3305AYmdv1U2eRNDiU2ErMBj1gwrq8eQ=
+github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c/go.mod h1:7rwL4CYBLnjLxUqIJNnCWiEdr3bn6IUYi15bNlnbCCU=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
+github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
+github.com/sijms/go-ora/v2 v2.9.0 h1:+iQbUeTeCOFMb5BsOMgUhV8KWyrv9yjKpcK4x7+MFrg=
+github.com/sijms/go-ora/v2 v2.9.0/go.mod h1:QgFInVi3ZWyqAiJwzBQA+nbKYKH77tdp1PYoCqhR2dU=
+github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
+github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
+github.com/yosida95/uritemplate/v3 v3.0.2 h1:Ed3Oyj9yrmi9087+NczuL5BwkIc4wvTb5zIM+UJPGz4=
+github.com/yosida95/uritemplate/v3 v3.0.2/go.mod h1:ILOh0sOhIJR3+L/8afwt/kE++YT040gmv5BQTMR2HP4=
+go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
+go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
+go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
+go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/zap v1.27.1 h1:08RqriUEv8+ArZRYSTXy1LeBScaMpVSTBhCeaZYfMYc=
+go.uber.org/zap v1.27.1/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
+golang.org/x/crypto v0.46.0 h1:cKRW/pmt1pKAfetfu+RCEvjvZkA9RimPbh7bhFjGVBU=
+golang.org/x/crypto v0.46.0/go.mod h1:Evb/oLKmMraqjZ2iQTwDwvCtJkczlDuTmdJXoZVzqU0=
+golang.org/x/net v0.48.0 h1:zyQRTTrjc33Lhh0fBgT/H3oZq9WuvRR5gPC70xpDiQU=
+golang.org/x/net v0.48.0/go.mod h1:+ndRgGjkh8FGtu1w1FGbEC31if4VrNVMuKTgcAAnQRY=
+golang.org/x/oauth2 v0.30.0 h1:dnDm7JmhM45NNpd8FDDeLhK6FwqbOf4MLCM9zb1BOHI=
+golang.org/x/oauth2 v0.30.0/go.mod h1:B++QgG3ZKulg6sRPGD/mqlHQs5rB3Ml9erfeDY7xKlU=
+golang.org/x/sys v0.39.0 h1:CvCKL8MeisomCi6qNZ+wbb0DN9E5AATixKsvNtMoMFk=
+golang.org/x/sys v0.39.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
+golang.org/x/text v0.32.0 h1:ZD01bjUt1FQ9WJ0ClOL5vxgxOI/sVCNgX1YtKwcY0mU=
+golang.org/x/text v0.32.0/go.mod h1:o/rUWzghvpD5TXrTIBuJU77MTaN0ljMWE47kxGJQ7jY=
+golang.org/x/tools v0.40.0 h1:yLkxfA+Qnul4cs9QA3KnlFu0lVmd8JJfoq+E41uSutA=
+golang.org/x/tools v0.40.0/go.mod h1:Ik/tzLRlbscWpqqMRjyWYDisX8bG13FrdXp3o4Sr9lc=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
+gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST95x9zc=
+gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc=
+gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

internal/auth/auth_middleware.go

@@ -0,0 +1,31 @@
+package auth
+
+import (
+	"context"
+	"net/http"
+)
+
+// authMiddleware 验证 Authorization 头和项目 ID 头
+func AuthMiddleware(next http.Handler, authToken, projectIDHeader string) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		// 验证 Authorization 头
+		authHeader := r.Header.Get("Authorization")
+		if authHeader == "" {
+			http.Error(w, "Authorization header required", http.StatusUnauthorized)
+			return
+		}
+		expected := "Bearer " + authToken
+		if authHeader != expected {
+			http.Error(w, "Invalid authorization token", http.StatusUnauthorized)
+			return
+		}
+		// 提取项目 ID 头并存储到请求上下文中，供 extractRequestContext 使用
+		projectID := r.Header.Get(projectIDHeader)
+		if projectID != "" {
+			// 将项目 ID 存储到上下文中
+			ctx := context.WithValue(r.Context(), "projectID", projectID)
+			r = r.WithContext(ctx)
+		}
+		next.ServeHTTP(w, r)
+	})
+}

internal/mcp/registry.go

@@ -0,0 +1,111 @@
+package mcp
+
+import (
+	"encoding/json"
+	"fmt"
+	"reflect"
+	"sync"
+
+	"git.x2erp.com/qdy/go-base/ctx"
+	"git.x2erp.com/qdy/go-db/factory/database"
+)
+
+// Tool 接口，工具实现此接口以支持自动注册
+type Tool interface {
+	Name() string
+	Description() string
+	InputSchema() map[string]interface{}
+	Execute(input json.RawMessage, dep *ToolDependencies) (interface{}, error)
+}
+
+// ToolDefinition 定义 MCP 工具
+type ToolDefinition struct {
+	Name        string                 `json:"name"`
+	Description string                 `json:"description"`
+	InputSchema map[string]interface{} `json:"inputSchema"`
+	Execute     ToolExecuteFunc        `json:"-"`
+}
+
+// ToolExecuteFunc 工具执行函数签名
+type ToolExecuteFunc func(input json.RawMessage, dep *ToolDependencies) (interface{}, error)
+
+// ToolDependencies 工具执行依赖项
+type ToolDependencies struct {
+	DBFactory *database.DBFactory
+	ReqCtx    *ctx.RequestContext
+}
+
+// globalRegistry 全局工具注册表
+var (
+	globalRegistry   = make(map[string]ToolDefinition)
+	registryMu       sync.RWMutex
+	dependencies     *ToolDependencies
+	dependenciesOnce sync.Once
+)
+
+// Register 注册一个工具
+func Register(name, description string, inputSchema map[string]interface{}, execute ToolExecuteFunc) {
+	registryMu.Lock()
+	defer registryMu.Unlock()
+
+	if _, exists := globalRegistry[name]; exists {
+		panic(fmt.Sprintf("tool already registered: %s", name))
+	}
+
+	globalRegistry[name] = ToolDefinition{
+		Name:        name,
+		Description: description,
+		InputSchema: inputSchema,
+		Execute:     execute,
+	}
+}
+
+// GetTool 获取工具定义
+func GetTool(name string) (ToolDefinition, bool) {
+	registryMu.RLock()
+	defer registryMu.RUnlock()
+	tool, ok := globalRegistry[name]
+	return tool, ok
+}
+
+// ListTools 返回所有工具定义
+func ListTools() []ToolDefinition {
+	registryMu.RLock()
+	defer registryMu.RUnlock()
+	tools := make([]ToolDefinition, 0, len(globalRegistry))
+	for _, tool := range globalRegistry {
+		tools = append(tools, tool)
+	}
+	return tools
+}
+
+// SetDependencies 设置全局依赖项
+func SetDependencies(dbFactory *database.DBFactory, reqCtx *ctx.RequestContext) {
+	dependenciesOnce.Do(func() {
+		dependencies = &ToolDependencies{
+			DBFactory: dbFactory,
+			ReqCtx:    reqCtx,
+		}
+	})
+}
+
+// GetDependencies 获取依赖项（如果已设置）
+func GetDependencies() *ToolDependencies {
+	return dependencies
+}
+
+// AutoRegister 自动注册实现 Tool 接口的类型
+func AutoRegister(tool interface{}) {
+	val := reflect.ValueOf(tool)
+	typ := val.Type()
+
+	// 检查是否实现了 Tool 接口
+	if tool, ok := tool.(Tool); ok {
+		Register(tool.Name(), tool.Description(), tool.InputSchema(), tool.Execute)
+		return
+	}
+
+	// 检查是否具有适当方法的其他接口
+	// 这里可以根据需要扩展
+	panic(fmt.Sprintf("type %v does not implement Tool interface", typ))
+}

internal/mcp/server.go

@@ -0,0 +1,186 @@
+package mcp
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/http"
+	"os"
+
+	"git.x2erp.com/qdy/go-base/ctx"
+	"git.x2erp.com/qdy/go-db/factory/database"
+	mcpsdk "github.com/modelcontextprotocol/go-sdk/mcp"
+)
+
+// Server 包装 MCP SDK 服务器，提供自动注册和依赖注入
+type Server struct {
+	port        int
+	serviceName string
+	sdkServer   *mcpsdk.Server
+	transport   mcpsdk.Transport
+	dbFactory   *database.DBFactory
+	baseCtx     *ctx.RequestContext
+	httpServer  *http.Server
+	handler     http.Handler
+}
+
+// Config 服务器配置
+type Config struct {
+	Name        string
+	Version     string
+	Port        int
+	ServiceName string
+	Description string
+	DBFactory   *database.DBFactory
+	BaseCtx     *ctx.RequestContext
+}
+
+// NewServer 创建新的 MCP 服务器
+func NewServer(cfg Config) (*Server, error) {
+	impl := &mcpsdk.Implementation{
+		Name:    cfg.Name,
+		Version: cfg.Version,
+	}
+	sdkServer := mcpsdk.NewServer(impl, nil)
+
+	server := &Server{
+		sdkServer:   sdkServer,
+		dbFactory:   cfg.DBFactory,
+		baseCtx:     cfg.BaseCtx,
+		port:        cfg.Port,
+		serviceName: cfg.ServiceName,
+	}
+
+	// 自动注册所有已注册的工具
+	if err := server.registerAllTools(); err != nil {
+		return nil, fmt.Errorf("failed to register tools: %w", err)
+	}
+
+	return server, nil
+}
+
+// registerAllTools 将注册表中的所有工具注册到 MCP 服务器
+func (s *Server) registerAllTools() error {
+	tools := ListTools()
+	for _, tool := range tools {
+		if err := s.registerTool(tool); err != nil {
+			return fmt.Errorf("failed to register tool %s: %w", tool.Name, err)
+		}
+	}
+	log.Printf("Registered %d MCP tools", len(tools))
+	return nil
+}
+
+// registerTool 注册单个工具到 MCP 服务器
+func (s *Server) registerTool(tool ToolDefinition) error {
+	// 创建工具处理器
+	handler := s.createToolHandler(tool)
+
+	// 创建 MCP 工具
+	mcpTool := &mcpsdk.Tool{
+		Name:        tool.Name,
+		Description: tool.Description,
+		InputSchema: tool.InputSchema,
+	}
+
+	// 注册工具到服务器
+	mcpsdk.AddTool(s.sdkServer, mcpTool, handler)
+	return nil
+}
+
+// createToolHandler 创建 MCP 工具处理器
+func (s *Server) createToolHandler(tool ToolDefinition) mcpsdk.ToolHandlerFor[map[string]interface{}, interface{}] {
+	return func(_ context.Context, request *mcpsdk.CallToolRequest, input map[string]interface{}) (*mcpsdk.CallToolResult, interface{}, error) {
+		// 将输入转换为 JSON
+		inputJSON, err := json.Marshal(input)
+		if err != nil {
+			return nil, nil, fmt.Errorf("failed to marshal input: %w", err)
+		}
+
+		// 提取请求上下文信息
+		reqCtx := s.extractRequestContext(request)
+
+		// 创建工具依赖项
+		toolDeps := &ToolDependencies{
+			DBFactory: s.dbFactory,
+			ReqCtx:    reqCtx,
+		}
+
+		// 执行工具
+		result, err := tool.Execute(json.RawMessage(inputJSON), toolDeps)
+		if err != nil {
+			// 返回工具错误（非协议错误）
+			return &mcpsdk.CallToolResult{
+				IsError: true,
+				Content: []mcpsdk.Content{
+					&mcpsdk.TextContent{Text: fmt.Sprintf("tool error: %v", err)},
+				},
+			}, nil, nil
+		}
+
+		// 返回成功结果
+		return nil, result, nil
+	}
+}
+
+// extractRequestContext 从 MCP 请求中提取上下文信息
+func (s *Server) extractRequestContext(request *mcpsdk.CallToolRequest) *ctx.RequestContext {
+	reqCtx := &ctx.RequestContext{}
+	if s.baseCtx != nil {
+		// 复制基础上下文
+		*reqCtx = *s.baseCtx
+	}
+
+	// 从请求的 Extra 数据中提取自定义项目 ID
+	extra := request.GetExtra()
+	if extra != nil && extra.Header != nil {
+		// 确定项目 ID 头名称
+		projectIDHeader := os.Getenv("MCP_PROJECT_ID_HEADER")
+		if projectIDHeader == "" {
+			projectIDHeader = "X-Project-ID"
+		}
+		if projectID := extra.Header.Get(projectIDHeader); projectID != "" {
+			// 将项目 ID 存储在 TraceID 中
+			reqCtx.ProjectID = projectID
+		}
+	}
+
+	return reqCtx
+}
+
+// SetTransport 设置传输层
+func (s *Server) SetTransport(transport mcpsdk.Transport) {
+	s.transport = transport
+}
+
+// GetSDKServer 返回底层的 SDK 服务器实例
+func (s *Server) GetSDKServer() *mcpsdk.Server {
+	return s.sdkServer
+}
+
+// startHTTPServer 启动 HTTP 服务器
+func (s *Server) Run(handler http.Handler) {
+
+	s.handler = handler
+	addr := fmt.Sprintf(":%d", s.port)
+
+	s.httpServer = &http.Server{
+		Addr:    addr,
+		Handler: s.handler,
+	}
+
+	log.Printf("%s listening on %s", s.serviceName, addr)
+
+	// 在 goroutine 中启动服务器
+	go func() {
+		if err := s.httpServer.ListenAndServe(); err != nil && err != http.ErrServerClosed {
+			log.Fatalf("%s failed to start: %v", s.serviceName, err)
+		}
+	}()
+}
+
+// GetHTTPServer 返回内部的 HTTP 服务器实例
+func (s *Server) GetHTTPServer() *http.Server {
+	return s.httpServer
+}

internal/tools/echo.go

@@ -0,0 +1,67 @@
+package tools
+
+import (
+	"encoding/json"
+
+	"git.x2erp.com/qdy/go-svc-mcp/internal/mcp"
+)
+
+func init() {
+	mcp.Register("echo", "回显输入的消息，演示自动注册和依赖注入",
+		map[string]interface{}{
+			"type": "object",
+			"properties": map[string]interface{}{
+				"message": map[string]interface{}{
+					"type":        "string",
+					"description": "要回显的消息",
+				},
+				"repeat": map[string]interface{}{
+					"type":        "integer",
+					"description": "重复次数",
+					"default":     1,
+					"minimum":     1,
+					"maximum":     10,
+				},
+			},
+			"required": []string{"message"},
+		},
+		func(input json.RawMessage, deps *mcp.ToolDependencies) (interface{}, error) {
+			var params struct {
+				Message string `json:"message"`
+				Repeat  int    `json:"repeat"`
+			}
+			if len(input) > 0 {
+				if err := json.Unmarshal(input, &params); err != nil {
+					return nil, err
+				}
+			}
+
+			if params.Repeat == 0 {
+				params.Repeat = 1
+			}
+
+			// 使用依赖项（数据库工厂和上下文）记录日志或执行其他操作
+			if deps.DBFactory != nil {
+				// 可以记录到数据库或执行查询
+				// 示例：记录工具调用
+			}
+
+			// 构建回显结果
+			result := ""
+			for i := 0; i < params.Repeat; i++ {
+				if i > 0 {
+					result += " "
+				}
+				result += params.Message
+			}
+
+			return map[string]interface{}{
+				"tenant_id": deps.ReqCtx.TenantID,
+				"original":  params.Message,
+				"echo":      result,
+				"repeat":    params.Repeat,
+				"has_db":    deps.DBFactory != nil,
+			}, nil
+		},
+	)
+}

internal/tools/get_current_date.go

@@ -0,0 +1,32 @@
+package tools
+
+import (
+	"encoding/json"
+	"log"
+	"time"
+
+	"git.x2erp.com/qdy/go-svc-mcp/internal/mcp"
+)
+
+func init() {
+	mcp.Register("get_current_date", "获取当前服务器日期。所有以日期有关的计算，必须按此时间为基础计算。比如上年，最近7天等",
+		map[string]interface{}{
+			"type":       "object",
+			"properties": map[string]interface{}{},
+			"required":   []string{},
+		},
+		func(input json.RawMessage, deps *mcp.ToolDependencies) (interface{}, error) {
+			now := time.Now()
+			log.Printf("AI 调用工具-get_current_date： %s", now)
+			log.Printf("AI 项目ID： %s", deps.ReqCtx.ProjectID)
+			return map[string]interface{}{
+				"date":      now.Format("2006-01-02"),
+				"year":      now.Year(),
+				"month":     int(now.Month()),
+				"day":       now.Day(),
+				"iso_date":  now.Format(time.RFC3339),
+				"timestamp": now.Unix(),
+			}, nil
+		},
+	)
+}

internal/tools/get_date_range.go

@@ -0,0 +1,115 @@
+package tools
+
+import (
+	"encoding/json"
+	"log"
+	"time"
+
+	"git.x2erp.com/qdy/go-svc-mcp/internal/mcp"
+)
+
+func init() {
+	mcp.Register("get_date_range", "根据时间单位和偏移量计算日期范围",
+		map[string]interface{}{
+			"type": "object",
+			"properties": map[string]interface{}{
+				"unit": map[string]interface{}{
+					"type":        "string",
+					"description": "时间单位",
+					"enum":        []string{"day", "week", "month", "quarter", "year"},
+				},
+				"offset": map[string]interface{}{
+					"type":        "integer",
+					"description": "偏移量（负数表示过去，正数表示未来）",
+					"default":     0,
+				},
+			},
+			"required": []string{"unit", "offset"},
+		},
+		func(input json.RawMessage, deps *mcp.ToolDependencies) (interface{}, error) {
+			var params struct {
+				Unit   string `json:"unit"`
+				Offset int    `json:"offset"`
+			}
+			log.Printf("AI 调用工具-get_date_range： %s", time.Now())
+			if len(input) > 0 {
+				if err := json.Unmarshal(input, &params); err != nil {
+					return nil, err
+				}
+			}
+
+			now := time.Now()
+			var startDate, endDate time.Time
+
+			switch params.Unit {
+			case "day":
+				targetDate := now.AddDate(0, 0, params.Offset)
+				startDate = targetDate
+				endDate = targetDate
+
+			case "week":
+				weekStart := getWeekStart(now)
+				targetWeekStart := weekStart.AddDate(0, 0, params.Offset*7)
+				targetWeekEnd := targetWeekStart.AddDate(0, 0, 6)
+				startDate = targetWeekStart
+				endDate = targetWeekEnd
+
+			case "month":
+				targetMonth := now.AddDate(0, params.Offset, 0)
+				monthStart := time.Date(targetMonth.Year(), targetMonth.Month(), 1, 0, 0, 0, 0, targetMonth.Location())
+				monthEnd := monthStart.AddDate(0, 1, -1)
+				startDate = monthStart
+				endDate = monthEnd
+
+			case "quarter":
+				// 基于当前季度偏移
+				currentMonth := int(now.Month())
+				currentQuarter := (currentMonth-1)/3 + 1
+				targetQuarter := currentQuarter + params.Offset
+				targetYear := now.Year()
+
+				// 处理跨年
+				if targetQuarter < 1 {
+					yearsBack := (1 - targetQuarter + 3) / 4
+					targetYear -= yearsBack
+					targetQuarter += yearsBack * 4
+				} else if targetQuarter > 4 {
+					yearsForward := (targetQuarter - 1) / 4
+					targetYear += yearsForward
+					targetQuarter -= yearsForward * 4
+				}
+
+				// 计算季度范围
+				quarterStartMonth := time.Month((targetQuarter-1)*3 + 1)
+				startDate = time.Date(targetYear, quarterStartMonth, 1, 0, 0, 0, 0, now.Location())
+				endDate = time.Date(targetYear, quarterStartMonth+3, 0, 0, 0, 0, 0, now.Location())
+
+			case "year":
+				targetYear := now.AddDate(params.Offset, 0, 0)
+				yearStart := time.Date(targetYear.Year(), 1, 1, 0, 0, 0, 0, targetYear.Location())
+				yearEnd := time.Date(targetYear.Year(), 12, 31, 0, 0, 0, 0, targetYear.Location())
+				startDate = yearStart
+				endDate = yearEnd
+
+			default:
+				startDate = now
+				endDate = now
+			}
+
+			return map[string]interface{}{
+				"unit":       params.Unit,
+				"offset":     params.Offset,
+				"start_date": startDate.Format("2006-01-02"),
+				"end_date":   endDate.Format("2006-01-02"),
+			}, nil
+		},
+	)
+}
+
+func getWeekStart(t time.Time) time.Time {
+	weekday := int(t.Weekday())
+	if weekday == 0 {
+		return t.AddDate(0, 0, -6)
+	}
+	return t.AddDate(0, 0, -(weekday - 1))
+}

internal/tools/get_field_matcher.go

@@ -0,0 +1,379 @@
+package tools
+
+import (
+	"encoding/json"
+	"fmt"
+	"sync"
+	"time"
+
+	"git.x2erp.com/qdy/go-svc-mcp/internal/mcp"
+)
+
+// 数据库字典表结构
+type FieldDictionary struct {
+	TableNameCN  string `json:"table_name_cn"`
+	TableNameEN  string `json:"table_name_en"`
+	FieldNameCN  string `json:"field_name_cn"`
+	FieldNameEN  string `json:"field_name_en"`
+	FieldType    string `json:"field_type"`
+	StandardName string `json:"standard_name"`
+	Description  string `json:"description"`
+	Category     string `json:"category"`
+	IsCalculated bool   `json:"is_calculated"`
+	Aliases      string `json:"aliases"`
+}
+
+// 缓存结构，添加过期时间和最后访问时间
+type fieldDictionaryCache struct {
+	data           []FieldDictionary
+	expireTime     time.Time     // 缓存过期时间
+	lastAccessTime time.Time     // 最后访问时间
+	expireDuration time.Duration // 过期时长
+	mutex          sync.RWMutex  // 读写锁
+}
+
+// 全局缓存实例
+var cache *fieldDictionaryCache
+
+// 初始化缓存
+func initCache() {
+	if cache == nil {
+		cache = &fieldDictionaryCache{
+			expireDuration: 20 * time.Minute, // 20分钟过期
+			data:           make([]FieldDictionary, 0),
+		}
+	}
+}
+
+// 获取缓存数据（会更新最后访问时间）
+func getCache() ([]FieldDictionary, bool) {
+	initCache()
+
+	cache.mutex.RLock()
+	defer cache.mutex.RUnlock()
+
+	// 检查缓存是否有效
+	if len(cache.data) == 0 {
+		return nil, false
+	}
+
+	// 检查是否过期（20分钟没有被访问）
+	if time.Since(cache.lastAccessTime) > cache.expireDuration {
+		return nil, false
+	}
+
+	// 检查是否到达过期时间
+	if time.Now().After(cache.expireTime) {
+		return nil, false
+	}
+
+	return cache.data, true
+}
+
+// 设置缓存数据
+func setCache(data []FieldDictionary) {
+	initCache()
+
+	cache.mutex.Lock()
+	defer cache.mutex.Unlock()
+
+	cache.data = data
+	cache.lastAccessTime = time.Now()
+	cache.expireTime = time.Now().Add(cache.expireDuration)
+}
+
+// 清除缓存
+func clearCache() {
+	initCache()
+
+	cache.mutex.Lock()
+	defer cache.mutex.Unlock()
+
+	cache.data = make([]FieldDictionary, 0)
+	cache.lastAccessTime = time.Time{}
+	cache.expireTime = time.Time{}
+}
+
+// 更新最后访问时间
+func updateLastAccessTime() {
+	initCache()
+
+	cache.mutex.Lock()
+	defer cache.mutex.Unlock()
+
+	cache.lastAccessTime = time.Now()
+}
+
+// 从数据库读取字段字典的方法
+func getFieldDictionaryFromDB() ([]FieldDictionary, error) {
+	// TODO: 你来实现这个数据库查询
+	// 这里返回示例数据用于测试
+
+	// 示例查询SQL（根据你的实际表结构调整）：
+	/*
+		SELECT
+			table_name_cn,
+			table_name_en,
+			field_name_cn,
+			field_name_en,
+			field_type,
+			standard_name,
+			description,
+			category,
+			is_calculated,
+			aliases
+		FROM system_field_dictionary
+		WHERE tenant_id = ? AND is_active = true
+		ORDER BY category, table_name_cn, field_name_cn
+	*/
+
+	return []FieldDictionary{
+		// 销售相关字段
+		{
+			TableNameCN:  "销售订单",
+			TableNameEN:  "sales_order",
+			FieldNameCN:  "销售数量",
+			FieldNameEN:  "sales_quantity",
+			FieldType:    "decimal(10,2)",
+			StandardName: "销售数量",
+			Description:  "销售订单中的商品数量",
+			Category:     "销售",
+			IsCalculated: false,
+			Aliases:      "销量,销售数",
+		},
+		{
+			TableNameCN:  "销售订单",
+			TableNameEN:  "sales_order",
+			FieldNameCN:  "结算单价",
+			FieldNameEN:  "settlement_price",
+			FieldType:    "decimal(10,2)",
+			StandardName: "结算单价",
+			Description:  "销售结算时的单价",
+			Category:     "销售",
+			IsCalculated: false,
+			Aliases:      "单价,销售单价",
+		},
+		{
+			TableNameCN:  "销售订单",
+			TableNameEN:  "sales_order",
+			FieldNameCN:  "销售金额",
+			FieldNameEN:  "sales_amount",
+			FieldType:    "decimal(10,2)",
+			StandardName: "销售金额",
+			Description:  "销售总金额（计算字段：销售数量 × 结算单价）",
+			Category:     "销售",
+			IsCalculated: true,
+			Aliases:      "销售额,销售总额",
+		},
+		// 采购相关字段
+		{
+			TableNameCN:  "采购订单",
+			TableNameEN:  "purchase_order",
+			FieldNameCN:  "采购数量",
+			FieldNameEN:  "purchase_quantity",
+			FieldType:    "decimal(10,2)",
+			StandardName: "采购数量",
+			Description:  "采购订单中的商品数量",
+			Category:     "采购",
+			IsCalculated: false,
+			Aliases:      "进货数量,采购数",
+		},
+		{
+			TableNameCN:  "采购订单",
+			TableNameEN:  "purchase_order",
+			FieldNameCN:  "采购单价",
+			FieldNameEN:  "purchase_price",
+			FieldType:    "decimal(10,2)",
+			StandardName: "采购单价",
+			Description:  "采购商品单价",
+			Category:     "采购",
+			IsCalculated: false,
+			Aliases:      "进价,采购价",
+		},
+		// 库存相关字段
+		{
+			TableNameCN:  "库存表",
+			TableNameEN:  "inventory",
+			FieldNameCN:  "库存数量",
+			FieldNameEN:  "inventory_quantity",
+			FieldType:    "decimal(10,2)",
+			StandardName: "库存数量",
+			Description:  "当前库存数量",
+			Category:     "库存",
+			IsCalculated: false,
+			Aliases:      "库存,现存量",
+		},
+	}, nil
+}
+
+// 加载字段字典（带缓存）
+func loadFieldDictionary(refresh bool) ([]FieldDictionary, error) {
+	// 如果强制刷新，先清除缓存
+	if refresh {
+		clearCache()
+	}
+
+	// 尝试从缓存获取
+	if data, ok := getCache(); ok {
+		return data, nil
+	}
+
+	// 从数据库加载
+	dict, err := getFieldDictionaryFromDB()
+	if err != nil {
+		return nil, fmt.Errorf("加载字段字典失败: %v", err)
+	}
+
+	// 设置缓存
+	setCache(dict)
+
+	return dict, nil
+}
+
+// 查找字段匹配
+func findFieldMatch(fieldCN string, dictionary []FieldDictionary) (bool, *FieldDictionary, []string) {
+	// 精确匹配
+	for _, dict := range dictionary {
+		if dict.FieldNameCN == fieldCN {
+			return true, &dict, nil
+		}
+	}
+
+	// 别名匹配
+	var matchedDict *FieldDictionary
+	for _, dict := range dictionary {
+		if dict.Aliases != "" {
+			// 简单的别名匹配（实际使用时你可能需要解析逗号分隔的字符串）
+			if dict.Aliases == fieldCN {
+				matchedDict = &dict
+				break
+			}
+		}
+	}
+
+	if matchedDict != nil {
+		return true, matchedDict, nil
+	}
+
+	// 收集所有字段名作为建议
+	var suggestions []string
+	for _, dict := range dictionary {
+		suggestions = append(suggestions, dict.FieldNameCN)
+	}
+
+	return false, nil, suggestions
+}
+
+func init() {
+	mcp.Register("field_matcher", "根据中文字段名称匹配数据库字段信息，返回英文字段名、表名、类型等详细信息",
+		map[string]interface{}{
+			"type": "object",
+			"properties": map[string]interface{}{
+				"fields": map[string]interface{}{
+					"type": "array",
+					"items": map[string]interface{}{
+						"type": "string",
+					},
+					"description": "要匹配的中文字段名称数组",
+					"minItems":    1,
+				},
+				"refresh_cache": map[string]interface{}{
+					"type":        "boolean",
+					"description": "是否刷新字段字典缓存",
+					"default":     false,
+				},
+			},
+			"required": []string{"fields"},
+		},
+		func(input json.RawMessage, deps *mcp.ToolDependencies) (interface{}, error) {
+			var params struct {
+				Fields       []string `json:"fields"`
+				RefreshCache bool     `json:"refresh_cache"`
+			}
+
+			if len(input) > 0 {
+				if err := json.Unmarshal(input, &params); err != nil {
+					return nil, err
+				}
+			}
+
+			if len(params.Fields) == 0 {
+				return nil, fmt.Errorf("fields 参数不能为空")
+			}
+
+			// 加载字段字典（带缓存）
+			startTime := time.Now()
+			dictionary, err := loadFieldDictionary(params.RefreshCache)
+			if err != nil {
+				return nil, err
+			}
+			loadTime := time.Since(startTime)
+
+			// 更新缓存最后访问时间
+			updateLastAccessTime()
+
+			// 处理每个字段的匹配结果
+			matches := make([]map[string]interface{}, 0, len(params.Fields))
+			foundCount := 0
+
+			for _, fieldCN := range params.Fields {
+				isFound, fieldInfo, suggestions := findFieldMatch(fieldCN, dictionary)
+
+				matchResult := map[string]interface{}{
+					"input_field_cn": fieldCN,
+					"is_found":       isFound,
+				}
+
+				if isFound && fieldInfo != nil {
+					foundCount++
+					matchResult["match_info"] = map[string]interface{}{
+						"table_name_cn": fieldInfo.TableNameCN,
+						"table_name_en": fieldInfo.TableNameEN,
+						"field_name_en": fieldInfo.FieldNameEN,
+						"field_type":    fieldInfo.FieldType,
+						"standard_name": fieldInfo.StandardName,
+						"description":   fieldInfo.Description,
+						"category":      fieldInfo.Category,
+						"is_calculated": fieldInfo.IsCalculated,
+					}
+				} else {
+					matchResult["suggestions"] = suggestions
+					matchResult["note"] = "未找到匹配字段，请尝试其他名称或拆解字段"
+				}
+
+				matches = append(matches, matchResult)
+			}
+
+			// 获取缓存信息
+			cacheData, cacheValid := getCache()
+			cacheInfo := map[string]interface{}{
+				"is_valid":     cacheValid,
+				"total_fields": len(cacheData),
+			}
+
+			if cacheValid {
+				cacheInfo["last_access_time"] = cache.lastAccessTime.Format(time.RFC3339)
+				cacheInfo["expire_time"] = cache.expireTime.Format(time.RFC3339)
+				cacheInfo["will_expire_in"] = time.Until(cache.expireTime).String()
+			}
+
+			// 按照示例的返回格式
+			return map[string]interface{}{
+				"tenant_id":    deps.ReqCtx.TenantID,
+				"user_id":      deps.ReqCtx.UserID,
+				"input_fields": params.Fields,
+				"matches":      matches,
+				"summary": map[string]interface{}{
+					"total_fields":    len(params.Fields),
+					"found_count":     foundCount,
+					"not_found_count": len(params.Fields) - foundCount,
+					"success_rate":    fmt.Sprintf("%.1f%%", float64(foundCount)/float64(len(params.Fields))*100),
+				},
+				"cache_info": cacheInfo,
+				"load_time":  loadTime.String(),
+				"timestamp":  time.Now().Format(time.RFC3339),
+				"suggestion": "如果未找到匹配字段，请尝试将复合字段拆解为ERP常用基本字段再次查询",
+			}, nil
+		},
+	)
+}

internal/tools/user_count.go

@@ -0,0 +1,68 @@
+package tools
+
+import (
+	"encoding/json"
+
+	"git.x2erp.com/qdy/go-svc-mcp/internal/mcp"
+)
+
+func init() {
+	mcp.Register("get_user_count", "获取用户数量，演示数据库工厂和上下文注入",
+		map[string]interface{}{
+			"type": "object",
+			"properties": map[string]interface{}{
+				"active_only": map[string]interface{}{
+					"type":        "boolean",
+					"description": "是否只统计活跃用户",
+					"default":     false,
+				},
+			},
+			"required": []string{},
+		},
+		func(input json.RawMessage, deps *mcp.ToolDependencies) (interface{}, error) {
+			var params struct {
+				ActiveOnly bool `json:"active_only"`
+			}
+			if len(input) > 0 {
+				if err := json.Unmarshal(input, &params); err != nil {
+					return nil, err
+				}
+			}
+
+			// 使用数据库工厂执行查询（示例）
+			var count int64
+
+			if deps.DBFactory != nil {
+				// 实际项目中，这里会执行数据库查询
+				// 示例：假设我们有一个用户表
+				// db := deps.DBFactory.GetDB()
+				// query := "SELECT COUNT(*) FROM users WHERE tenant_id = ?"
+				// if params.ActiveOnly {
+				//     query += " AND status = 'active'"
+				// }
+				// err := db.QueryRow(query, deps.ReqCtx.TenantID).Scan(&count)
+
+				// 模拟查询结果
+
+				count = 42
+				if params.ActiveOnly {
+					count = 25
+				}
+			} else {
+				// 无数据库工厂，返回模拟数据
+				count = 100
+				if params.ActiveOnly {
+					count = 60
+				}
+			}
+
+			return map[string]interface{}{
+				"tenant_id":   deps.ReqCtx.TenantID,
+				"user_count":  count,
+				"active_only": params.ActiveOnly,
+				"has_db":      deps.DBFactory != nil,
+				"timestamp":   "2024-01-01T00:00:00Z", // 实际应使用 time.Now()
+			}, nil
+		},
+	)
+}

main.go

@@ -0,0 +1,90 @@
+package main
+
+import (
+	"log"
+	"net/http"
+	"os"
+
+	"git.x2erp.com/qdy/go-svc-mcp/internal/auth"
+	"git.x2erp.com/qdy/go-svc-mcp/internal/mcp"
+	_ "git.x2erp.com/qdy/go-svc-mcp/internal/tools" // 触发工具自动注册
+
+	"git.x2erp.com/qdy/go-base/config"
+	"git.x2erp.com/qdy/go-base/container"
+	"git.x2erp.com/qdy/go-base/ctx"
+	"git.x2erp.com/qdy/go-base/graceful"
+	"git.x2erp.com/qdy/go-base/logger"
+	"git.x2erp.com/qdy/go-db/factory/database"
+	mcpsdk "github.com/modelcontextprotocol/go-sdk/mcp"
+)
+
+var (
+	appName    = "svc-mcp"
+	appVersion = "1"
+)
+
+func main() {
+	// 0. 初始化日志
+	logBootFactory := logger.InitBootLog()
+
+	// 1. 获取配置文件
+	cfg := config.GetConfig()
+	cfg.SetAppName(appName)
+	cfg.SetAppVersion(appVersion)
+
+	// 2. 创建关闭容器
+	ctr := container.NewContainer(cfg)
+
+	// 注册日志，实现自动关闭
+	container.Reg(ctr, logBootFactory)
+
+	// 3. 创建数据库工厂
+	dbFactory := container.Create(ctr, database.CreateDBFactory)
+	dbFactory.TestConnection()
+
+	// 4. 创建基础请求上下文（可从配置或认证中提取）
+	baseCtx := &ctx.RequestContext{
+		TenantID: "default-tenant", // 实际应从认证中间件获取
+	}
+
+	// 5. 创建 MCP 服务器
+	mcpServer, err := mcp.NewServer(mcp.Config{
+		Name:        appName,
+		Version:     appVersion,
+		Description: "MCP 工具服务，提供自动注册发现和依赖注入",
+		DBFactory:   dbFactory,
+		BaseCtx:     baseCtx,
+		Port:        cfg.GetServiceConfig().Port,
+		ServiceName: cfg.GetServiceConfig().ServiceName,
+	})
+	if err != nil {
+		log.Fatalf("Failed to create MCP server: %v", err)
+	}
+	log.Printf("MCP server created with tools registered")
+
+	// 6. 获取 SDK 服务器实例
+	sdkServer := mcpServer.GetSDKServer()
+
+	// 7. 创建 HTTP 处理器（带验证中间件）
+	authToken := os.Getenv("MCP_AUTH_TOKEN")
+	if authToken == "" {
+		authToken = "123" // 仅用于开发，生产环境必须设置
+	}
+	projectIDHeader := os.Getenv("MCP_PROJECT_ID_HEADER")
+	if projectIDHeader == "" {
+		projectIDHeader = "X-Project-ID"
+	}
+	mcpHandler := mcpsdk.NewStreamableHTTPHandler(func(req *http.Request) *mcpsdk.Server {
+		return sdkServer
+	}, nil)
+	// 包装验证中间件
+	handler := auth.AuthMiddleware(mcpHandler, authToken, projectIDHeader)
+
+	mcpServer.Run(handler)
+
+	//启用运行日志
+	container.Create(ctr, logger.InitRuntimeLogger)
+
+	//等待关闭
+	graceful.WaitForShutdown(appName, mcpServer.GetHTTPServer(), ctr)
+}