初始化

auth/authentication.go

@@ -0,0 +1,55 @@
+package auth
+
+import (
+	"net/http"
+	"strings"
+
+	"github.com/gin-gonic/gin"
+
+	"git.x2erp.com/qdy/go-base/config"
+)
+
+func AuthMiddleware() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		// 从 Header 中获取 token
+		authHeader := c.GetHeader("Authorization")
+		if authHeader == "" {
+			c.JSON(http.StatusUnauthorized, gin.H{
+				"success": false,
+				"error":   "Authorization header is required",
+			})
+			c.Abort()
+			return
+		}
+
+		// 检查 Bearer token 格式
+		parts := strings.Split(authHeader, " ")
+		if len(parts) != 2 || parts[0] != "Bearer" {
+			c.JSON(http.StatusUnauthorized, gin.H{
+				"success": false,
+				"error":   "Authorization header format must be Bearer {token}",
+			})
+			c.Abort()
+			return
+		}
+
+		tokenString := parts[1]
+		configTokenString := config.GetConfig().GetAuth().Token
+
+		// 比较 token 是否相等
+		if tokenString != configTokenString {
+			c.JSON(http.StatusUnauthorized, gin.H{
+				"success": false,
+				"error":   "Invalid token",
+			})
+			c.Abort()
+			return
+		}
+
+		// Token 验证通过，可以存储一些上下文信息
+		c.Set("authenticated", true)
+		c.Set("authType", "token")
+
+		c.Next()
+	}
+}

gct.sh

@@ -0,0 +1,82 @@
+#!/bin/bash
+
+# 脚本用法：./git-commit-and-tag.sh "你的提交描述" "版本号"
+
+# 检查参数数量
+if [ $# -ne 2 ]; then
+    echo "错误: 脚本需要2个参数。"
+    echo "用法: $0 \"提交描述\" \"版本号\""
+    echo "示例: $0 \"修复了登录问题\" \"v1.2.3\""
+    exit 1
+fi
+
+# 分配参数
+COMMIT_MESSAGE="$1"
+VERSION_TAG="$2"
+
+# 检查当前目录是否为Git仓库
+if ! git rev-parse --git-dir > /dev/null 2>&1; then
+    echo "错误: 当前目录不是一个Git仓库。"
+    exit 1
+fi
+
+echo "开始处理提交和版本标签..."
+echo "提交描述: $COMMIT_MESSAGE"
+echo "版本标签: $VERSION_TAG"
+
+# 检查是否有未提交的更改
+if [ -n "$(git status --porcelain)" ]; then
+    echo "检测到未提交的更改，正在提交..."
+    
+    # 添加所有更改到暂存区
+    git add .
+    
+    # 进行提交
+    git commit -m "$COMMIT_MESSAGE"
+    if [ $? -ne 0 ]; then
+        echo "错误: 提交失败。"
+        exit 1
+    fi
+    echo "✅ 更改已提交"
+else
+    echo "提示: 没有未提交的更改，跳过提交步骤"
+    
+    # 检查是否有未提交的commit但未推送
+    LOCAL_COMMITS=$(git log @{u}..HEAD --oneline 2>/dev/null | wc -l)
+    if [ $LOCAL_COMMITS -eq 0 ]; then
+        echo "错误: 没有需要推送的提交。"
+        exit 1
+    else
+        echo "检测到 $LOCAL_COMMITS 个本地提交等待推送"
+    fi
+fi
+
+# 检查标签是否已存在
+if git rev-parse "$VERSION_TAG" >/dev/null 2>&1; then
+    echo "错误: 标签 '$VERSION_TAG' 已经存在。"
+    exit 1
+fi
+
+# 创建标签
+git tag "$VERSION_TAG"
+if [ $? -ne 0 ]; then
+    echo "错误: 创建标签失败。"
+    exit 1
+fi
+echo "✅ 标签 '$VERSION_TAG' 已创建"
+
+# 推送到远程仓库并推送标签
+echo "正在推送到远程仓库..."
+git push
+if [ $? -ne 0 ]; then
+    echo "错误: 推送提交失败。"
+    exit 1
+fi
+
+git push origin "$VERSION_TAG"
+if [ $? -ne 0 ]; then
+    echo "错误: 推送标签失败。"
+    exit 1
+fi
+
+echo "✅ 完成！提交已推送，版本标签 $VERSION_TAG 已创建并推送。"

go.mod

@@ -0,0 +1,54 @@
+module git.x2erp.com/qdy/go-service-vbdx
+
+go 1.25.4
+
+require (
+	git.x2erp.com/qdy/go-base v0.1.9
+	git.x2erp.com/qdy/go-db v0.1.13
+	github.com/gin-gonic/gin v1.11.0
+	github.com/gorilla/mux v1.8.1
+)
+
+require (
+	filippo.io/edwards25519 v1.1.0 // indirect
+	git.x2erp.com/qdy/go-service-agent v0.1.13
+	github.com/bytedance/sonic v1.14.0 // indirect
+	github.com/bytedance/sonic/loader v0.3.0 // indirect
+	github.com/cloudwego/base64x v0.1.6 // indirect
+	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
+	github.com/gin-contrib/sse v1.1.0 // indirect
+	github.com/go-playground/locales v0.14.1 // indirect
+	github.com/go-playground/universal-translator v0.18.1 // indirect
+	github.com/go-playground/validator/v10 v10.27.0 // indirect
+	github.com/go-sql-driver/mysql v1.9.3 // indirect
+	github.com/goccy/go-json v0.10.2 // indirect
+	github.com/goccy/go-yaml v1.18.0 // indirect
+	github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect
+	github.com/golang-sql/sqlexp v0.1.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/klauspost/cpuid/v2 v2.3.0 // indirect
+	github.com/leodido/go-urn v1.4.0 // indirect
+	github.com/lib/pq v1.10.9 // indirect
+	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/microsoft/go-mssqldb v1.9.4 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/pelletier/go-toml/v2 v2.2.4 // indirect
+	github.com/quic-go/qpack v0.5.1 // indirect
+	github.com/quic-go/quic-go v0.54.0 // indirect
+	github.com/sijms/go-ora/v2 v2.9.0 // indirect
+	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
+	github.com/ugorji/go/codec v1.3.0 // indirect
+	go.uber.org/mock v0.5.0 // indirect
+	golang.org/x/arch v0.20.0 // indirect
+	golang.org/x/crypto v0.45.0 // indirect
+	golang.org/x/mod v0.29.0 // indirect
+	golang.org/x/net v0.47.0 // indirect
+	golang.org/x/sync v0.18.0 // indirect
+	golang.org/x/sys v0.38.0 // indirect
+	golang.org/x/text v0.31.0 // indirect
+	golang.org/x/tools v0.38.0 // indirect
+	google.golang.org/protobuf v1.36.9 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
+)

go.sum

@@ -0,0 +1,135 @@
+filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
+filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+git.x2erp.com/qdy/go-base v0.1.9 h1:SuyYSt3Gp7aXiUQRCBNwhrusJ53wlCnagiTYs5eITlY=
+git.x2erp.com/qdy/go-base v0.1.9/go.mod h1:Q+YLwpCoU8CVSnzATLdz2LAzVMlz/CEGzo8DePf7cug=
+git.x2erp.com/qdy/go-db v0.1.12 h1:z4VfTbIMNhBbpPmjRRtSjEkXet7nvVRjTd92+IFsGbw=
+git.x2erp.com/qdy/go-db v0.1.12/go.mod h1:tcHV7sqEFYWbL/196NZxVnbdHevefRppggMTARVXQtE=
+git.x2erp.com/qdy/go-db v0.1.13 h1:gx1Ld+b3QRaO7VvyBm4fipafGkl0Yl+4ERzromAtck4=
+git.x2erp.com/qdy/go-db v0.1.13/go.mod h1:tcHV7sqEFYWbL/196NZxVnbdHevefRppggMTARVXQtE=
+git.x2erp.com/qdy/go-service-agent v0.1.13 h1:h5kMd9bGu6HcTQ60j/mqdtHC1HfJ7uxwOaYas3EjQZY=
+git.x2erp.com/qdy/go-service-agent v0.1.13/go.mod h1:51jbunlX5YI+LyUYaScojAGhra1dhnQL85QkbgVfnts=
+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/bytedance/sonic v1.14.0 h1:/OfKt8HFw0kh2rj8N0F6C/qPGRESq0BbaNZgcNXXzQQ=
+github.com/bytedance/sonic v1.14.0/go.mod h1:WoEbx8WTcFJfzCe0hbmyTGrfjt8PzNEBdxlNUO24NhA=
+github.com/bytedance/sonic/loader v0.3.0 h1:dskwH8edlzNMctoruo8FPTJDF3vLtDT0sXZwvZJyqeA=
+github.com/bytedance/sonic/loader v0.3.0/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI=
+github.com/cloudwego/base64x v0.1.6 h1:t11wG9AECkCDk5fMSoxmufanudBtJ+/HemLstXDLI2M=
+github.com/cloudwego/base64x v0.1.6/go.mod h1:OFcloc187FXDaYHvrNIjxSe8ncn0OOM8gEHfghB2IPU=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+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/gabriel-vasile/mimetype v1.4.8 h1:FfZ3gj38NjllZIeJAmMhr+qKL8Wu+nOoI3GqacKw1NM=
+github.com/gabriel-vasile/mimetype v1.4.8/go.mod h1:ByKUIKGjh1ODkGM1asKUbQZOLGrPjydw3hYPU2YU9t8=
+github.com/gin-contrib/sse v1.1.0 h1:n0w2GMuUpWDVp7qSpvze6fAu9iRxJY4Hmj6AmBOU05w=
+github.com/gin-contrib/sse v1.1.0/go.mod h1:hxRZ5gVpWMT7Z0B0gSNYqqsSCNIJMjzvm6fqCz9vjwM=
+github.com/gin-gonic/gin v1.11.0 h1:OW/6PLjyusp2PPXtyxKHU0RbX6I/l28FTdDlae5ueWk=
+github.com/gin-gonic/gin v1.11.0/go.mod h1:+iq/FyxlGzII0KHiBGjuNn4UNENUlKbGlNmc+W50Dls=
+github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
+github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
+github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
+github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
+github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY=
+github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
+github.com/go-playground/validator/v10 v10.27.0 h1:w8+XrWVMhGkxOaaowyKH35gFydVHOvC0/uWoy2Fzwn4=
+github.com/go-playground/validator/v10 v10.27.0/go.mod h1:I5QpIEbmr8On7W0TktmJAumgzX4CA1XNl4ZmDuVHKKo=
+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/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU=
+github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
+github.com/goccy/go-yaml v1.18.0 h1:8W7wMFS12Pcas7KU+VVkaiCng+kG8QiFeFwzFb+rwuw=
+github.com/goccy/go-yaml v1.18.0/go.mod h1:XBurs7gK8ATbW4ZPGKgcbrY1Br56PdM69F7LkFRi1kA=
+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/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+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/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
+github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
+github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
+github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
+github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y=
+github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
+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/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
+github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
+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-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
+github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+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/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 h1:ZqeYNhU3OHLH3mGKHDcjJRFFRrJa6eAM5H+CtDdOsPc=
+github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
+github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
+github.com/pelletier/go-toml/v2 v2.2.4 h1:mye9XuhQ6gvn5h28+VilKrrPoQVanw5PMw/TB0t5Ec4=
+github.com/pelletier/go-toml/v2 v2.2.4/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY=
+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/quic-go/qpack v0.5.1 h1:giqksBPnT/HDtZ6VhtFKgoLOWmlyo9Ei6u9PqzIMbhI=
+github.com/quic-go/qpack v0.5.1/go.mod h1:+PC4XFrEskIVkcLzpEkbLqq1uCoxPhQuvK5rH1ZgaEg=
+github.com/quic-go/quic-go v0.54.0 h1:6s1YB9QotYI6Ospeiguknbp2Znb/jZYjZLRXn9kMQBg=
+github.com/quic-go/quic-go v0.54.0/go.mod h1:e68ZEaCdyviluZmy44P6Iey98v/Wfz6HCjQEm+l8zTY=
+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/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
+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/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
+github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
+github.com/ugorji/go/codec v1.3.0 h1:Qd2W2sQawAfG8XSvzwhBeoGq71zXOC/Q1E9y/wUcsUA=
+github.com/ugorji/go/codec v1.3.0/go.mod h1:pRBVtBSKl77K30Bv8R2P+cLSGaTtex6fsA2Wjqmfxj4=
+go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU=
+go.uber.org/mock v0.5.0/go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM=
+golang.org/x/arch v0.20.0 h1:dx1zTU0MAE98U+TQ8BLl7XsJbgze2WnNKF/8tGp/Q6c=
+golang.org/x/arch v0.20.0/go.mod h1:bdwinDaKcfZUGpH09BB7ZmOfhalA8lQdzl62l8gGWsk=
+golang.org/x/crypto v0.45.0 h1:jMBrvKuj23MTlT0bQEOBcAE0mjg8mK9RXFhRH6nyF3Q=
+golang.org/x/crypto v0.45.0/go.mod h1:XTGrrkGJve7CYK7J8PEww4aY7gM3qMCElcJQ8n8JdX4=
+golang.org/x/mod v0.29.0 h1:HV8lRxZC4l2cr3Zq1LvtOsi/ThTgWnUk/y64QSs8GwA=
+golang.org/x/mod v0.29.0/go.mod h1:NyhrlYXJ2H4eJiRy/WDBO6HMqZQ6q9nk4JzS3NuCK+w=
+golang.org/x/net v0.47.0 h1:Mx+4dIFzqraBXUugkia1OOvlD6LemFo1ALMHjrXDOhY=
+golang.org/x/net v0.47.0/go.mod h1:/jNxtkgq5yWUGYkaZGqo27cfGZ1c5Nen03aYrrKpVRU=
+golang.org/x/sync v0.18.0 h1:kr88TuHDroi+UVf+0hZnirlk8o8T+4MrK6mr60WkH/I=
+golang.org/x/sync v0.18.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
+golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.38.0 h1:3yZWxaJjBmCWXqhN1qh02AkOnCQ1poK6oF+a7xWL6Gc=
+golang.org/x/sys v0.38.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
+golang.org/x/text v0.31.0 h1:aC8ghyu4JhP8VojJ2lEHBnochRno1sgL6nEi9WGFGMM=
+golang.org/x/text v0.31.0/go.mod h1:tKRAlv61yKIjGGHX/4tP1LTbc13YSec1pxVEWXzfoeM=
+golang.org/x/tools v0.38.0 h1:Hx2Xv8hISq8Lm16jvBZ2VQf+RLmbd7wVUsALibYI/IQ=
+golang.org/x/tools v0.38.0/go.mod h1:yEsQ/d/YK8cjh0L6rZlY8tgtlKiBNTL14pGDJPJpYQs=
+google.golang.org/protobuf v1.36.9 h1:w2gp2mA27hUeUzj9Ex9FBjsBm40zfaDtEWow293U7Iw=
+google.golang.org/protobuf v1.36.9/go.mod h1:fuxRtAxBytpl4zzqUh6/eyUujkJdNiuEkXntxiD/uRU=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+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.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

main.go

@@ -0,0 +1,174 @@
+package main
+
+import (
+	"database/sql"
+	"fmt"
+	"log"
+	"net/http"
+	"strings"
+	"time"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"git.x2erp.com/qdy/go-db/factory"
+	"git.x2erp.com/qdy/go-service-vbdx/auth"
+	"git.x2erp.com/qdy/go-service-vbdx/routes"
+	"github.com/gin-gonic/gin"
+)
+
+// 单例实例
+var (
+	dbFactory *factory.DBFactory
+	db        *sql.DB
+)
+
+// initDB 初始化数据库连接（单例）
+func initDB() error {
+	var err error
+
+	// 创建数据库工厂（单例）
+	if dbFactory == nil {
+		dbFactory, err = factory.NewDBFactory()
+		if err != nil {
+			return fmt.Errorf("failed to create DB factory: %v", err)
+		}
+	}
+
+	// 创建数据库连接（单例）
+	if db == nil {
+		db, err = dbFactory.CreateDB()
+		if err != nil {
+			return fmt.Errorf("failed to create database connection: %v", err)
+		}
+	}
+
+	// 测试连接
+	config := dbFactory.GetConfig()
+	if err := factory.TestConnection(db, config.GetDatabase().Type); err != nil {
+		return fmt.Errorf("database connection test failed: %v", err)
+	}
+
+	return nil
+}
+
+func main() {
+	// 1. 初始化数据库（单例）
+	if err := initDB(); err != nil {
+		log.Fatalf("Database initialization failed: %v", err)
+	}
+
+	// 2. 显示基础信息
+	drivers := dbFactory.GetAvailableDrivers()
+	config := dbFactory.GetConfig()
+
+	log.Printf("Service Port: %d", config.GetService().Port)
+	log.Printf("Service IdleTimeout: %d", config.GetService().IdleTimeout)
+	log.Printf("Service ReadTimeout: %d", config.GetService().ReadTimeout)
+	log.Printf("Service WriteTimeout: %d", config.GetService().WriteTimeout)
+	log.Printf("Service TrustedProxies: %s", config.GetService().TrustedProxies)
+
+	log.Printf("Available database drivers: %v", drivers)
+	log.Printf("Using database type: %s", config.GetDatabase().Type)
+	log.Printf("Database host: %s:%d", config.GetDatabase().Host, config.GetDatabase().Port)
+	log.Printf("Database name: %s", config.GetDatabase().Database)
+	log.Println("Database connection test passed!")
+
+	// 3. 启动Gin HTTP服务
+	startHTTPServer()
+}
+
+// 启动HTTP服务器
+func startHTTPServer() {
+	//建立路由
+	router := gin.Default()
+	config := dbFactory.GetConfig()
+	serviceConfig := config.GetService()
+
+	// 核心路由
+	router.GET("/api/health", routes.HealthHandler(db, config.GetDatabase().Type))
+	router.POST("/api/init/table", auth.AuthMiddleware(), routes.ExecuteDDLHandler(db))
+	//router.POST("/api/query/csv", auth.AuthMiddleware(), withQueryRequest(routes.QueryHandlerCSV(db)))
+	router.GET("/api/info", routes.InfoHandler(dbFactory))
+
+	// 日志输出配置信息
+	log.Printf("Service Port: %d", serviceConfig.Port)
+	log.Printf("Service IdleTimeout: %d", serviceConfig.IdleTimeout)
+	log.Printf("Service ReadTimeout: %d", serviceConfig.ReadTimeout)
+	log.Printf("Service WriteTimeout: %d", serviceConfig.WriteTimeout)
+	log.Printf("Service TrustedProxies: %s", serviceConfig.TrustedProxies)
+
+	// 设置可信代理
+	setupTrustedProxies(router, serviceConfig.TrustedProxies)
+
+	// 启动服务
+	log.Println("POST /api/query  - Execute SQL query to JSON")
+	log.Println("POST /api/query/csv  - Execute SQL query to CSV")
+	log.Println("GET  /api/health - Health check")
+	log.Println("GET  /api/info   - Database info")
+
+	// 创建HTTP服务器配置
+	server := &http.Server{
+		Addr:         fmt.Sprintf(":%d", serviceConfig.Port),
+		Handler:      router,
+		IdleTimeout:  time.Duration(serviceConfig.IdleTimeout) * time.Second,
+		ReadTimeout:  time.Duration(serviceConfig.ReadTimeout) * time.Second,
+		WriteTimeout: time.Duration(serviceConfig.WriteTimeout) * time.Second,
+	}
+
+	log.Printf("Starting HTTP server on port %d", serviceConfig.Port)
+	if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
+		log.Fatalf("Failed to start server: %v", err)
+	}
+}
+
+// 参数绑定包装器
+func withQueryRequest(handler func(c *gin.Context, req types.QueryRequest)) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		var req types.QueryRequest
+		if err := c.ShouldBindJSON(&req); err != nil {
+			c.JSON(400, &types.QueryResult{
+				Success: false,
+				Error:   "Invalid request: " + err.Error(),
+				Data:    nil,
+			})
+			return
+		}
+
+		handler(c, req)
+	}
+}
+
+// 设置可信代理
+func setupTrustedProxies(router *gin.Engine, trustedProxiesStr string) {
+	if trustedProxiesStr == "" {
+		setupTrustedProxiesRouter(router, nil)
+		return
+	}
+
+	// 按逗号分割字符串，并去除空格
+	proxies := strings.Split(trustedProxiesStr, ",")
+	trimmedProxies := make([]string, 0, len(proxies))
+
+	for _, proxy := range proxies {
+		trimmed := strings.TrimSpace(proxy)
+		if trimmed != "" {
+			trimmedProxies = append(trimmedProxies, trimmed)
+		}
+	}
+
+	if len(trimmedProxies) > 0 {
+		setupTrustedProxiesRouter(router, trimmedProxies)
+	} else {
+		setupTrustedProxiesRouter(router, nil)
+	}
+}
+
+func setupTrustedProxiesRouter(router *gin.Engine, trimmedProxies []string) {
+
+	err := router.SetTrustedProxies(trimmedProxies)
+	if err != nil {
+		log.Printf("Warning: Failed to set trusted proxies: %v", err)
+	} else {
+		log.Printf("Trusted proxies set: %v", trimmedProxies)
+	}
+
+}

routes/heath.go

@@ -0,0 +1,41 @@
+package routes
+
+import (
+	"database/sql"
+	"time"
+
+	"github.com/gin-gonic/gin"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"git.x2erp.com/qdy/go-db/factory"
+)
+
+// HealthHandler 返回一个处理函数
+func HealthHandler(db *sql.DB, dbType string) gin.HandlerFunc {
+	return func(c *gin.Context) {
+
+		err := factory.TestConnection(db, dbType)
+		success := err == nil
+
+		status := "DOWN"
+		if success {
+			status = "UP"
+		}
+
+		c.JSON(200, &types.QueryResult{
+			Success: success,
+			Data: map[string]interface{}{
+				"status":         status,
+				"time":           time.Now().Format(time.RFC3339),
+				"database":       dbType,
+				"databaseStatus": status,
+			},
+			Error: func() string {
+				if err != nil {
+					return err.Error()
+				}
+				return ""
+			}(),
+		})
+	}
+}

routes/info.go

@@ -0,0 +1,31 @@
+package routes
+
+import (
+	"time"
+
+	"github.com/gin-gonic/gin"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"git.x2erp.com/qdy/go-db/factory"
+)
+
+// InfoHandler 数据库信息
+func InfoHandler(dbFactory *factory.DBFactory) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		config := dbFactory.GetConfig()
+		drivers := dbFactory.GetAvailableDrivers()
+
+		c.JSON(200, &types.QueryResult{
+			Success: true,
+			Data: map[string]interface{}{
+				"database_type":     config.GetDatabase().Type,
+				"database_host":     config.GetDatabase().Host,
+				"database_port":     config.GetDatabase().Port,
+				"database_name":     config.GetDatabase().Database,
+				"available_drivers": drivers,
+				"service_time":      time.Now().Format(time.RFC3339),
+			},
+			Error: "",
+		})
+	}
+}

routes/init_table.go

@@ -0,0 +1,84 @@
+package routes
+
+import (
+	"database/sql"
+	"log"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"git.x2erp.com/qdy/go-db/factory"
+	"github.com/gin-gonic/gin"
+)
+
+// 定义表结构
+type tableDDL struct {
+	TableName string
+	SQL       string
+}
+
+// 最简单的使用方式 - 直接在代码中维护
+func ExecuteDDLHandler(db *sql.DB) func(c *gin.Context) {
+	return func(c *gin.Context) {
+
+		tables := getTableDDLs()
+
+		success := []string{}
+		failures := map[string]string{}
+
+		// 直接遍历 tables 切片
+		for _, table := range tables {
+			if err := factory.ExecuteDDL(db, table.SQL); err != nil {
+				failures[table.TableName] = err.Error()
+				log.Printf("[%s] 失败: %v", table.TableName, err)
+			} else {
+				success = append(success, table.TableName)
+				log.Printf("[%s] 成功", table.TableName)
+			}
+		}
+
+		successState := true
+		if len(failures) > 0 {
+			successState = false // 这里用 = 赋值，不是 :=
+		}
+
+		c.JSON(200, types.QueryResult{
+			Success: successState,
+
+			Data: gin.H{
+				"success":  success,
+				"failures": failures,
+			},
+		})
+
+	}
+}
+
+// 获取所有表定义
+func getTableDDLs() []tableDDL {
+	return []tableDDL{
+		{
+			TableName: "etl_service",
+			SQL: `
+                CREATE TABLE IF NOT EXISTS etl_service (
+                    etl_service_name VARCHAR(255) PRIMARY KEY,
+                    etl_ip VARCHAR(50) NOT NULL,
+                    etl_port INTEGER NOT NULL,
+                    create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+                );
+            `,
+		},
+		{
+			TableName: "etl_agent",
+			SQL: `
+                CREATE TABLE IF NOT EXISTS etl_agent (
+                    agent_id  VARCHAR(50) PRIMARY KEY,
+                    agent_name VARCHAR(100) NOT NULL,
+                    agent_url VARCHAR(512)  NOT NULL,
+					agent_token VARCHAR(512)  NOT NULL,
+                    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+                );
+            `,
+		},
+
+		// 添加新表在这里插入新的 TableDDL
+	}
+}