初始提交

.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,17 @@
+module git.x2erp.com/qdy/go-svc-configure
+
+go 1.25.4
+
+require (
+	git.x2erp.com/qdy/go-base v0.1.70
+	git.x2erp.com/qdy/go-db v0.1.70
+	go-micro.dev/v4 v4.11.0
+)
+
+require (
+	github.com/kr/pretty v0.3.1 // indirect
+	github.com/rogpeppe/go-internal v1.14.1 // indirect
+	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
+)
+
+require gopkg.in/yaml.v2 v2.4.0 // indirect

go.sum

@@ -0,0 +1,14 @@
+git.x2erp.com/qdy/go-base v0.1.44 h1:xHpMppSNj79lqdUc+lmgGXOgEvHyNotUayoe5/hHWr4=
+git.x2erp.com/qdy/go-base v0.1.44/go.mod h1:Q+YLwpCoU8CVSnzATLdz2LAzVMlz/CEGzo8DePf7cug=
+github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
+github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
+go-micro.dev/v4 v4.11.0 h1:DZ2xcr0pnZJDlp6MJiCLhw4tXRxLw9xrJlPT91kubr0=
+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/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=

main.go

@@ -0,0 +1,80 @@
+package main
+
+import (
+	"log"
+	"net/http"
+
+	"git.x2erp.com/qdy/go-base/bootstraps"
+	"git.x2erp.com/qdy/go-base/middleware"
+	"git.x2erp.com/qdy/go-db/factory/database"
+	"git.x2erp.com/qdy/go-db/myhandle"
+	"git.x2erp.com/qdy/go-db/sqldef"
+	"git.x2erp.com/qdy/go-svc-agent/functions"
+	"go-micro.dev/v4/web"
+
+	// 导入表定义包，触发 init() 函数
+	_ "git.x2erp.com/qdy/go-svc-configure/tables" // 确保这里的路径正确
+)
+
+var (
+	serviceName    = "svc-agent"
+	serviceVersion = "1.0.0"
+)
+
+func main() {
+
+	// 创建服务启动器
+	bootstrapper := bootstraps.NewServiceBootstrapper(serviceName, serviceVersion)
+
+	//加载配置
+	bootstrapper.InitConfig()
+
+	//构建数据库工厂
+	bootstrapper.InitDatabase()
+	defer bootstrapper.CleanupDatabase()
+
+	//创建表到数据库
+	cretetabel(bootstrapper.DbFactory)
+
+	// 启动服务，传入路由注册函数
+	bootstrapper.Run(registerRoutes)
+
+}
+
+// 注册所有路由
+func registerRoutes(webService web.Service, dbFactory *database.DBFactory) {
+
+	// 查询接口 - JSON
+	webService.Handle("/api/query/json", middleware.JWTAuthMiddleware(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		myhandle.QueryHandlerJson(w, r, dbFactory, functions.QueryToJSON)
+	})))
+
+	// 查询接口 - CSV
+	webService.Handle("/api/query/csv", middleware.JWTAuthMiddleware(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		myhandle.QueryHandlerBytes(w, r, dbFactory, functions.QueryToCSV)
+	})))
+
+	// 查询接口 - CSV with positional params
+	webService.Handle("/api/query/csv/param", middleware.JWTAuthMiddleware(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		myhandle.QueryHandlerBytes(w, r, dbFactory, functions.QueryPositionalToCSV)
+	})))
+}
+
+func cretetabel(factory *database.DBFactory) {
+	// 获取数据库连接和类型
+	db := factory.GetDB()
+	dbType := factory.GetDBType()
+
+	// 创建表同步器
+	syncer, err := sqldef.NewTableSyncer(db, dbType)
+	if err != nil {
+		log.Fatalf("创建 - 建立器失败: %v", err)
+	}
+
+	// 创建表
+	if err := syncer.RecreateTables(); err != nil {
+		log.Fatalf("建表失败: %v", err)
+	}
+
+	log.Println("数据库表建立完成！")
+}

models/config_template.go

@@ -0,0 +1,40 @@
+package models
+
+import (
+	"database/sql"
+	"encoding/json"
+	"strings"
+	"time"
+)
+
+// ConfigTemplate 配置模板表
+type ConfigTemplate struct {
+	ID          int64           `json:"id" db:"id"`                               // 技术主键
+	Name        string          `json:"name" db:"name"`                           // 模板名称
+	TypeCode    string          `json:"type_code" db:"type_code"`                 // 类型编码，关联template_type.code
+	Content     json.RawMessage `json:"content" db:"content"`                     // 模板内容JSON
+	ServiceType sql.NullString  `json:"service_type,omitempty" db:"service_type"` // 适用服务类型
+	IsDefault   bool            `json:"is_default" db:"is_default"`               // 是否默认模板
+	SortOrder   int             `json:"sort_order" db:"sort_order"`               // 排序号
+	Creator     string          `json:"creator" db:"creator"`                     // 创建人
+	CreatedAt   time.Time       `json:"created_at" db:"created_at"`               // 创建时间
+}
+
+// TableName 返回表名
+func (ConfigTemplate) TableName() string {
+	return "config_template"
+}
+
+// TemplateKey 返回业务键：type_code.name
+func (c *ConfigTemplate) TemplateKey() string {
+	return c.TypeCode + "." + c.Name
+}
+
+// ParseTemplateKey 解析业务键
+func ParseTemplateKey(key string) (typeCode, name string, ok bool) {
+	parts := strings.SplitN(key, ".", 2)
+	if len(parts) != 2 {
+		return "", "", false
+	}
+	return parts[0], parts[1], true
+}

models/service_profile.go

@@ -0,0 +1,25 @@
+package models
+
+import (
+	"database/sql"
+	"time"
+)
+
+// ServiceProfile 微服务档案表
+type ServiceProfile struct {
+	ServiceCode string         `json:"service_code" db:"service_code"` // 主键，服务编码
+	ServiceName string         `json:"service_name" db:"service_name"` // 服务名称
+	ServiceType string         `json:"service_type" db:"service_type"` // 服务类型：api/auth/order等
+	Version     string         `json:"version" db:"version"`           // 当前版本
+	Language    string         `json:"language" db:"language"`         // 开发语言
+	Owner       string         `json:"owner" db:"owner"`               // 负责人
+	OwnerPhone  sql.NullString `json:"owner_phone,omitempty" db:"owner_phone"`
+	Status      string         `json:"status" db:"status"`         // 状态：active/inactive
+	Creator     string         `json:"creator" db:"creator"`       // 创建人
+	CreatedAt   time.Time      `json:"created_at" db:"created_at"` // 创建时间
+}
+
+// TableName 返回表名
+func (ServiceProfile) TableName() string {
+	return "service_profile"
+}

models/startup_config.go

@@ -0,0 +1,54 @@
+package models
+
+import (
+	"database/sql"
+	"encoding/json"
+	"fmt"
+	"strconv"
+	"strings"
+	"time"
+)
+
+// StartupConfig 启动配置表
+type StartupConfig struct {
+	ID          int64           `json:"id" db:"id"`                           // 技术主键
+	ServiceName string          `json:"service_name" db:"service_name"`       // 服务名称
+	Environment string          `json:"environment" db:"environment"`         // 环境：dev/test/prod
+	Version     int             `json:"version" db:"version"`                 // 配置版本
+	ConfigJSON  json.RawMessage `json:"config_json" db:"config_json"`         // 配置内容JSON
+	IsActive    bool            `json:"is_active" db:"is_active"`             // 是否生效
+	Creator     string          `json:"creator" db:"creator"`                 // 创建人
+	CreatedAt   time.Time       `json:"created_at" db:"created_at"`           // 创建时间
+	UpdatedAt   sql.NullTime    `json:"updated_at,omitempty" db:"updated_at"` // 更新时间
+}
+
+// TableName 返回表名
+func (StartupConfig) TableName() string {
+	return "startup_config"
+}
+
+// ConfigKey 返回业务键：service_name.environment.vversion
+func (c *StartupConfig) ConfigKey() string {
+	return fmt.Sprintf("%s.%s.v%d", c.ServiceName, c.Environment, c.Version)
+}
+
+// ParseConfigKey 解析业务键
+func ParseConfigKey(key string) (service, env string, version int, ok bool) {
+	parts := strings.Split(key, ".")
+	if len(parts) != 3 {
+		return "", "", 0, false
+	}
+
+	// 检查版本格式
+	if !strings.HasPrefix(parts[2], "v") {
+		return "", "", 0, false
+	}
+
+	verStr := strings.TrimPrefix(parts[2], "v")
+	version, err := strconv.Atoi(verStr)
+	if err != nil {
+		return "", "", 0, false
+	}
+
+	return parts[0], parts[1], version, true
+}

models/template_type.go

@@ -0,0 +1,22 @@
+package models
+
+import (
+	"database/sql"
+	"time"
+)
+
+// TemplateType 模板类型表
+type TemplateType struct {
+	Code        string         `json:"code" db:"code"` // 主键，如：db, redis, auth
+	Name        string         `json:"name" db:"name"` // 类型名称
+	Description sql.NullString `json:"description,omitempty" db:"description"`
+	SortOrder   int            `json:"sort_order" db:"sort_order"` // 排序号
+	IsSystem    bool           `json:"is_system" db:"is_system"`   // 是否系统类型
+	Creator     string         `json:"creator" db:"creator"`       // 创建人
+	CreatedAt   time.Time      `json:"created_at" db:"created_at"` // 创建时间
+}
+
+// TableName 返回表名
+func (TemplateType) TableName() string {
+	return "template_type"
+}

tables/config_environment.go

@@ -0,0 +1,22 @@
+package tables
+
+import (
+	"git.x2erp.com/qdy/go-db/sqldef"
+)
+
+func init() {
+
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		// 环境表
+		tb := sqldef.NewTable("config_environment", "环境表").
+			ID("config_environment_id", 8).NotNull().Comment("环境编码，主键").End().
+			String("env_name", 64).NotNull().Comment("环境名称").End().
+			String("description", 64).Comment("环境描述").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+
+		// 注册表
+		r.RegisterTable(tb.Build())
+	})
+}

tables/config_service.go

@@ -0,0 +1,19 @@
+// 微服务登记表。保存整个项目有哪些微服务
+package tables
+
+import "git.x2erp.com/qdy/go-db/sqldef"
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		// 微服务档案表
+		tb := sqldef.NewTable("config_service", "微服务档案表").
+			ID("config_service_id", 32).NotNull().Comment("服务编码，主键").End().
+			String("service_name", 64).NotNull().Comment("服务名称").End().
+			String("service_version", 32).NotNull().Default("'1.0.0'").Comment("当前版本").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End()
+
+		// 注册表
+		r.RegisterTable(tb.Build())
+	})
+}

tables/config_startup.go

@@ -0,0 +1,26 @@
+package tables
+
+import "git.x2erp.com/qdy/go-db/sqldef"
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		// 启动配置表
+		tb := sqldef.NewTable("config_startup", "启动配置表").
+			ID("config_startup_id", 128).NotNull().Comment("主键ID").End(). // 默认VARCHAR(64)
+			String("config_template_id", 64).NotNull().Comment("模板ID，关联config_template表").End().
+			String("config_service_id", 64).NotNull().Comment("服务名称").End().
+			String("config_environment_id", 8).NotNull().Default("'dev'").Comment("环境ID").End(). //dev/test
+			Int("version").NotNull().Default("1").Comment("版本号").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+
+		// 添加唯一约束和索引
+		tb.AddIndex("idx_service_id", "config_service_id").
+			AddIndex("idx_template_id", "config_template_id").
+			AddIndex("idx_env_id", "config_environment_id")
+
+		// 注册表
+		r.RegisterTable(tb.Build())
+	})
+}

tables/config_startup_detail.go

@@ -0,0 +1,26 @@
+package tables
+
+import "git.x2erp.com/qdy/go-db/sqldef"
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		// ✅ 修正表名拼写：detall → detail
+		tb := sqldef.NewTable("config_startup_detail", "启动配置明细表").
+			ID("config_startup_detail_id", 258).NotNull().Comment("主键ID").End().                  // 默认VARCHAR(64)
+			String("config_template_detail_id", 128).NotNull().Comment("模版子表主键ID").End().         // ✅ 修正注释
+			String("config_startup_id", 128).NotNull().Comment("启动配置ID，关联config_startup表").End(). // ✅ 修正注释
+			String("config_key", 64).NotNull().Comment("配置键名").End().
+			String("config_value", 512).NotNull().Comment("配置值").End(). // ✅ 修正长度注释
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+
+		// ✅ 正确的索引
+		tb.AddIndex("idx_startup_id", "config_startup_id").
+			AddIndex("idx_config_key", "config_key") // 按key查询
+		//AddUniqueIndex("uk_startup_key", "config_startup_id", "config_key") // 防止重复key
+
+		// 注册表
+		r.RegisterTable(tb.Build())
+	})
+}

tables/config_template.go

@@ -0,0 +1,30 @@
+// config_template.go
+package tables
+
+import "git.x2erp.com/qdy/go-db/sqldef"
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		// 配置模版表
+		tb := sqldef.NewTable("config_template", "配置模版").
+			ID("config_template_id", 128).NotNull().Comment("主键ID").End().
+			String("template_name", 64).NotNull().Comment("模版名称").End().
+			String("yaml_root_key", 32).NotNull().Comment("YAML配置的根节点名称").End().
+			//String("service_type", 32).Comment("适用服务类型，如：auth/order/payment").End().
+			Bool("is_default").NotNull().Default("0").Comment("是否默认模版").End().
+			Int("sort_order").NotNull().Default("0").Comment("排序号，小的在前").End().
+			Text("description").Comment("模版说明").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+
+		// 添加索引
+		tb.AddIndex("idx_type_code", "yaml_root_key")
+		//AddIndex("idx_service_type", "service_type").
+		//AddIndex("idx_sort_order", "sort_order")
+		//AddUniqueIndex("uk_name_type", "template_name", "yaml_root_key")
+
+		// 注册表
+		r.RegisterTable(tb.Build())
+	})
+}

tables/config_template_detail.go

@@ -0,0 +1,38 @@
+package tables
+
+import "git.x2erp.com/qdy/go-db/sqldef"
+
+func init() {
+	sqldef.AddRegistration(func(r *sqldef.Registry) {
+		// 配置模板明细表（K-V格式）
+		tb := sqldef.NewTable("config_template_detail", "配置模板明细表").
+			ID("config_template_detail_id", 256).NotNull().Comment("主键ID").End().
+			String("config_template_id", 128).NotNull().Comment("模板ID，关联config_template表").End().
+			String("config_key", 64).NotNull().Comment("配置键名").End().
+			Text("config_value").NotNull().Comment("配置值").End().
+			String("value_type", 32).NotNull().Default("'string'").Comment("值类型: string/int/bool/float/json").End().
+			String("data_type", 32).Comment("数据类型: text/number/boolean/select/array/object").End().
+			Bool("is_required").NotNull().Default("0").Comment("是否必填").End().
+			Text("default_value").Comment("默认值").End().
+			Text("validation_rules").Comment("验证规则JSON").End().
+			Text("description").Comment("配置项说明").End().
+			Int("sort_order").NotNull().Default("0").Comment("排序号").End().
+			Bool("is_sensitive").NotNull().Default("0").Comment("是否敏感数据（如密码）").End().
+			Bool("is_readonly").NotNull().Default("0").Comment("是否只读").End().
+			String("creator", 32).NotNull().Comment("创建人").End().
+			DateTime("created_at").NotNull().Default("CURRENT_TIMESTAMP").Comment("创建时间").End().
+			DateTime("updated_at").Default("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP").Comment("更新时间").End()
+
+		// 添加索引和约束
+		tb.AddUniqueIndex("uk_template_key", "config_template_id", "config_key").
+			AddIndex("idx_template_id", "config_template_id").
+			AddIndex("idx_sort_order", "sort_order").
+			AddIndex("idx_is_sensitive", "is_sensitive")
+
+		// 可选：添加外键约束（如果数据库支持）
+		// tb.AddForeignKey("fk_template_detail_template", "template_id", "config_template", "template_id")
+
+		// 注册表
+		r.RegisterTable(tb.Build())
+	})
+}