添加建立配置文件默认值

models/Config_template_builder.go

@@ -0,0 +1,263 @@
+package models
+
+import (
+	"encoding/json"
+	"time"
+)
+
+// ConfigTemplateBuilder 配置模板建造者
+type ConfigTemplateBuilder struct {
+	templates []*ConfigTemplate
+	current   *ConfigTemplate
+}
+
+// NewConfigTemplateBuilder 创建配置模板建造者
+func NewConfigTemplateBuilder() *ConfigTemplateBuilder {
+	return &ConfigTemplateBuilder{
+		templates: make([]*ConfigTemplate, 0),
+	}
+}
+
+// StartTemplate 开始创建新模板
+func (b *ConfigTemplateBuilder) StartTemplate(name, rootKey, description string) *ConfigTemplateBuilder {
+	b.current = &ConfigTemplate{
+		TemplateName: name,
+		YamlRootKey:  rootKey,
+		Description:  description,
+		IsDefault:    true,
+		SortOrder:    len(b.templates) + 1,
+		Creator:      "system",
+		CreatedAt:    time.Now(),
+		UpdatedAt:    time.Now(),
+		Details:      make([]ConfigTemplateDetail, 0),
+	}
+	return b
+}
+
+// AddInt 添加整型配置项
+func (b *ConfigTemplateBuilder) AddInt(key, description string) *DetailBuilder {
+	return b.addDetail(key, description, "number", "int")
+}
+
+// AddString 添加字符串配置项
+func (b *ConfigTemplateBuilder) AddString(key, description string) *DetailBuilder {
+	return b.addDetail(key, description, "string", "string")
+}
+
+// AddBoolean 添加布尔型配置项
+func (b *ConfigTemplateBuilder) AddBoolean(key, description string) *DetailBuilder {
+	return b.addDetail(key, description, "boolean", "boolean")
+}
+
+// AddEnum 添加枚举型配置项
+func (b *ConfigTemplateBuilder) AddEnum(key, description string, enumValues []string) *DetailBuilder {
+	db := b.addDetail(key, description, "string", "string")
+	db.detail.ValidationRules = func() string {
+		rules := ValidationRules{
+			EnumValues: enumValues,
+		}
+		b, _ := json.Marshal(rules)
+		return string(b)
+	}()
+	return db
+}
+
+// FinishTemplate 完成当前模板创建
+func (b *ConfigTemplateBuilder) FinishTemplate() *ConfigTemplateBuilder {
+	if b.current != nil {
+		b.templates = append(b.templates, b.current)
+		b.current = nil
+	}
+	return b
+}
+
+// GetTemplates 获取所有模板
+func (b *ConfigTemplateBuilder) GetTemplates() []*ConfigTemplate {
+	return b.templates
+}
+
+// // BuildSampleTemplates 构建示例模板
+// func (b *ConfigTemplateBuilder) BuildSampleTemplates() *ConfigTemplateBuilder {
+// 	// Service模板
+// 	b.StartTemplate("Service配置", "service", "服务基础配置").
+// 		AddInt("port", "服务监听端口").Default("8080").Min(1024).Max(65535).Required().FinishDetail().
+// 		AddString("service_name", "服务名称").Default("svc-configure").Pattern("^[a-zA-Z][a-zA-Z0-9_-]*$").Required().FinishDetail().
+// 		AddString("instance_name", "实例名称").Default("svc-configure-01").Required().FinishDetail().
+// 		AddInt("read_timeout", "读取超时时间（秒）").Default("30").Min(1).Max(300).Required().FinishDetail().
+// 		AddInt("write_timeout", "写入超时时间（秒）").Default("30").Min(1).Max(300).Required().FinishDetail().
+// 		AddInt("idle_timeout", "空闲超时时间（秒）").Default("60").Min(10).Max(600).Required().FinishDetail().
+// 		FinishTemplate()
+
+// 	// Log模板
+// 	b.StartTemplate("日志配置", "log", "日志相关配置").
+// 		AddEnum("level", "日志级别", []string{"debug", "info", "warn", "error", "fatal"}).Default("debug").Required().FinishDetail().
+// 		AddString("output", "日志输出目标").Default("console,file").FinishDetail().
+// 		AddBoolean("json_format", "是否以JSON格式输出日志").Default("true").FinishDetail().
+// 		FinishTemplate()
+
+// 	// Doris模板
+// 	b.StartTemplate("Doris配置", "doris", "Doris数据库连接配置").
+// 		AddString("fe_host", "Doris FE节点主机地址").Default("161.189.89.196").Pattern(`^(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$`).Required().FinishDetail().
+// 		AddInt("fe_port", "Doris FE端口号").Default("8040").Min(1).Max(65535).Required().FinishDetail().
+// 		AddString("fe_username", "Doris FE用户名").Default("root").Required().FinishDetail().
+// 		AddString("fe_password", "Doris FE密码").Default("mos8555").Sensitive().Required().MinLength(6).MaxLength(100).FinishDetail().
+// 		AddInt("stream_load_timeout", "Stream Load超时时间（秒）").Default("300").Min(10).Max(3600).FinishDetail().
+// 		AddInt("batch_size", "批量大小").Default("1000").Min(1).Max(10000).FinishDetail().
+// 		FinishTemplate()
+
+// 	return b
+// }
+
+// 私有方法
+func (b *ConfigTemplateBuilder) addDetail(key, description, valueType, dataType string) *DetailBuilder {
+	if b.current == nil {
+		b.StartTemplate("未命名模板", "untitled", "未描述模板")
+	}
+
+	detail := ConfigTemplateDetail{
+		ConfigKey:   key,
+		Description: description,
+		ValueType:   valueType,
+		DataType:    dataType,
+		IsRequired:  false,
+		IsSensitive: false,
+		IsReadonly:  false,
+		SortOrder:   len(b.current.Details) + 1,
+		Creator:     "system",
+		CreatedAt:   time.Now(),
+		UpdatedAt:   time.Now(),
+	}
+
+	return &DetailBuilder{
+		builder: b,
+		detail:  detail,
+	}
+}
+
+// DetailBuilder 配置详情建造者
+type DetailBuilder struct {
+	builder *ConfigTemplateBuilder
+	detail  ConfigTemplateDetail
+}
+
+// Default 设置默认值
+func (db *DetailBuilder) Default(value string) *DetailBuilder {
+	db.detail.DefaultValue = value
+	db.detail.ConfigValue = value
+	return db
+}
+
+// Required 设置为必填项
+func (db *DetailBuilder) Required() *DetailBuilder {
+	db.detail.IsRequired = true
+	return db
+}
+
+// Sensitive 设置为敏感信息
+func (db *DetailBuilder) Sensitive() *DetailBuilder {
+	db.detail.IsSensitive = true
+	return db
+}
+
+// Readonly 设置为只读
+func (db *DetailBuilder) Readonly() *DetailBuilder {
+	db.detail.IsReadonly = true
+	return db
+}
+
+// Min 设置最小值
+func (db *DetailBuilder) Min(min float64) *DetailBuilder {
+	db.addValidation(func(r *ValidationRules) {
+		r.Min = &min
+	})
+	return db
+}
+
+// Max 设置最大值
+func (db *DetailBuilder) Max(max float64) *DetailBuilder {
+	db.addValidation(func(r *ValidationRules) {
+		r.Max = &max
+	})
+	return db
+}
+
+// MinLength 设置最小长度
+func (db *DetailBuilder) MinLength(length int) *DetailBuilder {
+	db.addValidation(func(r *ValidationRules) {
+		r.MinLength = &length
+	})
+	return db
+}
+
+// MaxLength 设置最大长度
+func (db *DetailBuilder) MaxLength(length int) *DetailBuilder {
+	db.addValidation(func(r *ValidationRules) {
+		r.MaxLength = &length
+	})
+	return db
+}
+
+// Pattern 设置正则表达式
+func (db *DetailBuilder) Pattern(pattern string) *DetailBuilder {
+	db.addValidation(func(r *ValidationRules) {
+		r.Pattern = pattern
+	})
+	return db
+}
+
+// Message 设置验证错误消息
+func (db *DetailBuilder) Message(msg string) *DetailBuilder {
+	db.addValidation(func(r *ValidationRules) {
+		r.Message = msg
+	})
+	return db
+}
+
+// FinishDetail 完成当前详情项
+func (db *DetailBuilder) FinishDetail() *ConfigTemplateBuilder {
+	db.builder.current.Details = append(db.builder.current.Details, db.detail)
+	return db.builder
+}
+
+// 私有方法
+func (db *DetailBuilder) addValidation(fn func(*ValidationRules)) {
+	var rules ValidationRules
+	if db.detail.ValidationRules != "" {
+		json.Unmarshal([]byte(db.detail.ValidationRules), &rules)
+	}
+	fn(&rules)
+	b, _ := json.Marshal(rules)
+	db.detail.ValidationRules = string(b)
+}
+
+// 使用示例
+func CreateSampleConfigTemplates() []*ConfigTemplate {
+	builder := NewConfigTemplateBuilder()
+	//builder.BuildSampleTemplates()
+	return builder.GetTemplates()
+}
+
+// 更简洁的使用示例
+func CreateConfigTemplates() []*ConfigTemplate {
+	builder := NewConfigTemplateBuilder()
+
+	// Service模板 - 更简洁的写法
+	builder.StartTemplate("Service配置", "service", "服务基础配置")
+	builder.AddInt("port", "服务监听端口").Default("8080").Min(1024).Max(65535).Required().FinishDetail()
+	builder.AddString("service_name", "服务名称").Default("svc-configure").Required().FinishDetail()
+	builder.FinishTemplate()
+
+	// Log模板
+	builder.StartTemplate("日志配置", "log", "日志相关配置")
+	builder.AddEnum("level", "日志级别", []string{"debug", "info", "warn", "error", "fatal"}).Default("debug").Required().FinishDetail()
+	builder.AddString("output", "日志输出").Default("console,file").FinishDetail()
+	builder.FinishTemplate()
+
+	// Doris模板
+	builder.StartTemplate("Doris配置", "doris", "Doris连接配置")
+	builder.AddString("fe_host", "FE主机").Default("localhost").Required().FinishDetail()
+	builder.AddString("fe_password", "密码").Sensitive().Required().FinishDetail()
+	builder.FinishTemplate()
+
+	return builder.GetTemplates()
+}

models/config_template.go

@@ -1,40 +1,63 @@
 package models
 
 import (
-	"database/sql"
-	"encoding/json"
-	"strings"
 	"time"
 )
 
-// ConfigTemplate 配置模板表
+// 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"`               // 创建时间
+	ConfigTemplateID int64     `gorm:"column:config_template_id;primaryKey;autoIncrement" json:"config_template_id"`
+	TemplateName     string    `gorm:"column:template_name;type:varchar(100);not null;uniqueIndex;comment:模板名称" json:"template_name"`
+	YamlRootKey      string    `gorm:"column:yaml_root_key;type:varchar(100);comment:YAML根键名" json:"yaml_root_key"`
+	IsDefault        bool      `gorm:"column:is_default;type:boolean;default:false;comment:是否为默认模板" json:"is_default"`
+	SortOrder        int       `gorm:"column:sort_order;type:integer;default:0;comment:排序序号" json:"sort_order"`
+	Description      string    `gorm:"column:description;type:text;comment:模板描述" json:"description"`
+	Creator          string    `gorm:"column:creator;type:varchar(100);not null;comment:创建者" json:"creator"`
+	CreatedAt        time.Time `gorm:"column:created_at;type:timestamp;default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt        time.Time `gorm:"column:updated_at;type:timestamp;default:CURRENT_TIMESTAMP;autoUpdateTime" json:"updated_at"`
+
+	// 关联关系
+	Details []ConfigTemplateDetail `gorm:"foreignKey:ConfigTemplateID;references:ConfigTemplateID" json:"details,omitempty"`
 }
 
-// TableName 返回表名
+// TableName 设置表名
 func (ConfigTemplate) TableName() string {
 	return "config_template"
 }
 
-// TemplateKey 返回业务键：type_code.name
-func (c *ConfigTemplate) TemplateKey() string {
-	return c.TypeCode + "." + c.Name
+// ConfigTemplateDetail 配置模板详情
+type ConfigTemplateDetail struct {
+	ConfigTemplateDetailID int64     `gorm:"column:config_template_detail_id;primaryKey;autoIncrement" json:"config_template_detail_id"`
+	ConfigTemplateID       int64     `gorm:"column:config_template_id;not null;index" json:"config_template_id"`
+	ConfigKey              string    `gorm:"column:config_key;type:varchar(100);not null;index" json:"config_key"`
+	ConfigValue            string    `gorm:"column:config_value;type:text" json:"config_value"`
+	ValueType              string    `gorm:"column:value_type;type:varchar(20);not null;default:'string';comment:值类型：string,number,boolean,json,array" json:"value_type"`
+	DataType               string    `gorm:"column:data_type;type:varchar(50);comment:数据类型：int,float,string,boolean,date,datetime" json:"data_type"`
+	IsRequired             bool      `gorm:"column:is_required;type:boolean;default:false" json:"is_required"`
+	DefaultValue           string    `gorm:"column:default_value;type:text" json:"default_value"`
+	ValidationRules        string    `gorm:"column:validation_rules;type:jsonb;comment:验证规则JSON" json:"validation_rules"`
+	Description            string    `gorm:"column:description;type:text" json:"description"`
+	SortOrder              int       `gorm:"column:sort_order;type:integer;default:0" json:"sort_order"`
+	IsSensitive            bool      `gorm:"column:is_sensitive;type:boolean;default:false;comment:是否为敏感信息，敏感信息会加密存储" json:"is_sensitive"`
+	IsReadonly             bool      `gorm:"column:is_readonly;type:boolean;default:false" json:"is_readonly"`
+	Creator                string    `gorm:"column:creator;type:varchar(100);not null" json:"creator"`
+	CreatedAt              time.Time `gorm:"column:created_at;type:timestamp;default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt              time.Time `gorm:"column:updated_at;type:timestamp;default:CURRENT_TIMESTAMP;autoUpdateTime" json:"updated_at"`
+}
+
+// TableName 设置表名
+func (ConfigTemplateDetail) TableName() string {
+	return "config_template_detail"
 }
 
-// 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
+// ValidationRulesStruct 验证规则结构体
+type ValidationRules struct {
+	Min        *float64 `json:"min,omitempty"`         // 最小值
+	Max        *float64 `json:"max,omitempty"`         // 最大值
+	MinLength  *int     `json:"min_length,omitempty"`  // 最小长度
+	MaxLength  *int     `json:"max_length,omitempty"`  // 最大长度
+	Pattern    string   `json:"pattern,omitempty"`     // 正则表达式
+	Required   *bool    `json:"required,omitempty"`    // 是否必填
+	EnumValues []string `json:"enum_values,omitempty"` // 枚举值
+	Message    string   `json:"message,omitempty"`     // 验证失败提示信息
 }

models/service_profile.go

@@ -1,25 +0,0 @@
-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

@@ -1,54 +0,0 @@
-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

@@ -1,22 +0,0 @@
-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"
-}

service/create_config_template.go

@@ -0,0 +1,327 @@
+package service
+
+import (
+	"fmt"
+	"time"
+
+	"git.x2erp.com/qdy/go-svc-configure/models"
+	"github.com/jmoiron/sqlx"
+)
+
+// InitConfigTemplates 初始化默认配置信息
+func InitConfigTemplates(db *sqlx.DB) error {
+
+	builder := models.NewConfigTemplateBuilder()
+
+	templates := builder.
+		// Service模板
+		StartTemplate("Service配置", "service", "服务基础配置").
+		AddInt("port", "服务监听端口").Default("8080").Min(1024).Max(65535).Required().FinishDetail().
+		AddString("service_name", "服务名称").Default("svc-configure").Pattern("^[a-zA-Z][a-zA-Z0-9_-]*$").Required().FinishDetail().
+		AddString("instance_name", "实例名称").Default("svc-configure-01").Required().FinishDetail().
+		AddInt("read_timeout", "读取超时时间（秒）").Default("30").Min(1).Max(300).Required().FinishDetail().
+		AddInt("write_timeout", "写入超时时间（秒）").Default("30").Min(1).Max(300).Required().FinishDetail().
+		AddInt("idle_timeout", "空闲超时时间（秒）").Default("60").Min(10).Max(600).Required().FinishDetail().
+		FinishTemplate().
+
+		// Log模板
+		StartTemplate("日志增强配置", "log", "增强版日志配置").
+		AddEnum("level", "日志级别", []string{"debug", "info", "warn", "error", "fatal"}).Default("debug").Required().FinishDetail().
+		AddString("output", "日志输出目标").Default("console,es").FinishDetail().
+		//AddBoolean("json_format", "JSON格式输出").Default("true").FinishDetail().
+		AddString("file_path", "日志文件路径").Default("./logs/app-%s.log").FinishDetail().
+		AddInt("max_size", "最大文件大小(MB)").Default("100").FinishDetail().
+		AddInt("max_backups", "最大备份文件数").Default("30").FinishDetail().
+		AddInt("max_age", "最大保存天数").Default("7").FinishDetail().
+		AddBoolean("compress", "压缩备份文件").Default("true").FinishDetail().
+		AddString("es_path", "ES地址").Default("http://x3cloudb.x2erp.com:9200").FinishDetail().
+		AddString("es_username", "ES用户名").Default("").FinishDetail().
+		AddString("es_password", "ES密码").Default("").Sensitive().FinishDetail().
+		FinishTemplate().
+
+		// Doris模板
+		StartTemplate("Doris配置", "doris", "Doris数据库连接配置").
+		AddString("fe_host", "Doris FE节点主机地址").Default("161.189.89.196").Pattern(`^(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$`).Required().FinishDetail().
+		AddInt("fe_port", "Doris FE端口号").Default("8040").Min(1).Max(65535).Required().FinishDetail().
+		AddString("fe_username", "Doris FE用户名").Default("root").Required().FinishDetail().
+		AddString("fe_password", "Doris FE密码").Default("").Sensitive().Required().MinLength(6).MaxLength(100).FinishDetail().
+		AddInt("stream_load_timeout", "Stream Load超时时间（秒）").Default("300").Min(10).Max(3600).FinishDetail().
+		AddInt("batch_size", "批量大小").Default("1000").Min(1).Max(10000).FinishDetail().
+		FinishTemplate().
+
+		// micro 注册发现配置
+		StartTemplate("Micro服务配置", "micro", "Micro服务基础配置").
+		AddString("service_name", "服务名称").Default("svc-worker").Required().FinishDetail().
+		AddString("service_address", "服务地址").Default(":7070").Required().FinishDetail().
+		AddString("registry_address", "注册中心地址").Default("localhost:8500").Required().FinishDetail().
+		AddString("registry_type", "注册中心类型").Default("consul").Required().FinishDetail().
+		AddInt("registry_timeout", "注册中心超时时间").Default("10").Required().FinishDetail().
+		FinishTemplate().
+
+		// rabbitmq
+		StartTemplate("RabbitMQ配置", "rabbitmq", "RabbitMQ消息队列配置").
+		AddString("host", "主机地址").Default("localhost").Required().FinishDetail().
+		AddInt("port", "端口").Default("5672").Required().FinishDetail().
+		AddString("username", "用户名").Default("guest").Required().FinishDetail().
+		AddString("password", "密码").Default("guest").Sensitive().Required().FinishDetail().
+		AddString("vhost", "虚拟主机").Default("/").FinishDetail().
+		AddBoolean("use_tls", "启用TLS").Default("false").FinishDetail().
+		AddString("ca_cert", "CA证书").Default("").FinishDetail().
+		AddString("cert_file", "证书文件").Default("").FinishDetail().
+		AddString("key_file", "密钥文件").Default("").FinishDetail().
+		AddInt("max_open_channels", "最大通道数").Default("10").FinishDetail().
+		AddInt("reconnect_delay", "重连延迟(ms)").Default("5000").FinishDetail().
+		AddInt("max_reconnect_attempts", "最大重试次数").Default("10").FinishDetail().
+		AddInt("heartbeat", "心跳间隔(s)").Default("30").FinishDetail().
+		AddInt("channel_size", "通道大小").Default("100").FinishDetail().
+		AddString("default_exchange", "默认交换机").Default("amq.direct").FinishDetail().
+		AddString("default_queue", "默认队列").Default("").FinishDetail().
+		AddBoolean("auto_ack", "自动确认").Default("false").FinishDetail().
+		AddBoolean("mandatory", "强制路由").Default("false").FinishDetail().
+		AddBoolean("immediate", "立即发送").Default("false").FinishDetail().
+		AddInt("prefetch_count", "预取数量").Default("1").FinishDetail().
+		AddInt("prefetch_size", "预取大小").Default("0").FinishDetail().
+		AddBoolean("global", "全局设置").Default("false").FinishDetail().
+		AddBoolean("publisher_confirms", "发布确认").Default("false").FinishDetail().
+		AddInt("confirm_timeout", "确认超时(s)").Default("5").FinishDetail().
+		FinishTemplate().
+		GetTemplates()
+
+	return CreateOrUpdateConfigTemplates(db, templates)
+}
+
+// CreateOrUpdateConfigTemplates 创建或更新配置模板（支持部分更新）
+func CreateOrUpdateConfigTemplates(db *sqlx.DB, templates []*models.ConfigTemplate) error {
+	if db == nil {
+		return fmt.Errorf("database connection is nil")
+	}
+
+	// 开始事务
+	tx, err := db.Beginx()
+	if err != nil {
+		return fmt.Errorf("begin transaction failed: %v", err)
+	}
+	defer func() {
+		if err != nil {
+			tx.Rollback()
+		}
+	}()
+
+	now := time.Now()
+
+	for _, template := range templates {
+		// 设置时间
+		if template.CreatedAt.IsZero() {
+			template.CreatedAt = now
+		}
+		template.UpdatedAt = now
+
+		// 1. 插入或更新模板主表
+		templateID, err := upsertTemplate(tx, template, now)
+		if err != nil {
+			return err
+		}
+
+		// 2. 处理模板详情（部分更新）
+		if len(template.Details) > 0 {
+			err = upsertTemplateDetails(tx, templateID, template.Details, now)
+			if err != nil {
+				return err
+			}
+		}
+	}
+
+	return tx.Commit()
+}
+
+// upsertTemplate 插入或更新模板主表
+func upsertTemplate(tx *sqlx.Tx, template *models.ConfigTemplate, now time.Time) (int64, error) {
+	sqlStr := `
+		INSERT INTO config_template (
+			template_name, 
+			yaml_root_key, 
+			is_default, 
+			sort_order, 
+			description, 
+			creator, 
+			created_at, 
+			updated_at
+		) VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
+		ON CONFLICT (template_name) DO UPDATE SET
+			yaml_root_key = EXCLUDED.yaml_root_key,
+			is_default = EXCLUDED.is_default,
+			sort_order = EXCLUDED.sort_order,
+			description = EXCLUDED.description,
+			creator = EXCLUDED.creator,
+			updated_at = $8
+		RETURNING config_template_id`
+
+	var templateID int64
+	err := tx.QueryRow(sqlStr,
+		template.TemplateName,
+		template.YamlRootKey,
+		template.IsDefault,
+		template.SortOrder,
+		template.Description,
+		template.Creator,
+		template.CreatedAt,
+		now, // 使用事务中的时间
+	).Scan(&templateID)
+
+	if err != nil {
+		return 0, fmt.Errorf("upsert template failed: %v", err)
+	}
+
+	return templateID, nil
+}
+
+// upsertTemplateDetails 插入或更新模板详情（基于config_key唯一性）
+func upsertTemplateDetails(tx *sqlx.Tx, templateID int64, details []models.ConfigTemplateDetail, now time.Time) error {
+	for _, detail := range details {
+		// 设置时间和模板ID
+		if detail.CreatedAt.IsZero() {
+			detail.CreatedAt = now
+		}
+		detail.UpdatedAt = now
+		detail.ConfigTemplateID = templateID
+
+		sqlStr := `
+			INSERT INTO config_template_detail (
+				config_template_id,
+				config_key,
+				config_value,
+				value_type,
+				data_type,
+				is_required,
+				default_value,
+				validation_rules,
+				description,
+				sort_order,
+				is_sensitive,
+				is_readonly,
+				creator,
+				created_at,
+				updated_at
+			) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15)
+			ON CONFLICT (config_template_id, config_key) DO UPDATE SET
+				config_value = EXCLUDED.config_value,
+				value_type = EXCLUDED.value_type,
+				data_type = EXCLUDED.data_type,
+				is_required = EXCLUDED.is_required,
+				default_value = EXCLUDED.default_value,
+				validation_rules = EXCLUDED.validation_rules,
+				description = EXCLUDED.description,
+				sort_order = EXCLUDED.sort_order,
+				is_sensitive = EXCLUDED.is_sensitive,
+				is_readonly = EXCLUDED.is_readonly,
+				creator = EXCLUDED.creator,
+				updated_at = $15`
+
+		_, err := tx.Exec(sqlStr,
+			detail.ConfigTemplateID,
+			detail.ConfigKey,
+			detail.ConfigValue,
+			detail.ValueType,
+			detail.DataType,
+			detail.IsRequired,
+			detail.DefaultValue,
+			detail.ValidationRules,
+			detail.Description,
+			detail.SortOrder,
+			detail.IsSensitive,
+			detail.IsReadonly,
+			detail.Creator,
+			detail.CreatedAt,
+			now,
+		)
+
+		if err != nil {
+			return fmt.Errorf("upsert template detail failed (key: %s): %v", detail.ConfigKey, err)
+		}
+	}
+
+	return nil
+}
+
+// 批量版本（如果需要更高性能）
+func batchUpsertTemplateDetails(tx *sqlx.Tx, templateID int64, details []models.ConfigTemplateDetail, now time.Time) error {
+	if len(details) == 0 {
+		return nil
+	}
+
+	// 使用临时表进行批量操作
+	_, err := tx.Exec(`
+		CREATE TEMP TABLE temp_config_details (
+			config_key VARCHAR(100),
+			config_value TEXT,
+			value_type VARCHAR(20),
+			data_type VARCHAR(50),
+			is_required BOOLEAN,
+			default_value TEXT,
+			validation_rules JSONB,
+			description TEXT,
+			sort_order INTEGER,
+			is_sensitive BOOLEAN,
+			is_readonly BOOLEAN,
+			creator VARCHAR(100)
+		) ON COMMIT DROP`)
+	if err != nil {
+		return fmt.Errorf("create temp table failed: %v", err)
+	}
+
+	// 批量插入到临时表
+	stmt, err := tx.Prepare(`
+		INSERT INTO temp_config_details VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12)`)
+	if err != nil {
+		return err
+	}
+	defer stmt.Close()
+
+	for _, detail := range details {
+		_, err = stmt.Exec(
+			detail.ConfigKey,
+			detail.ConfigValue,
+			detail.ValueType,
+			detail.DataType,
+			detail.IsRequired,
+			detail.DefaultValue,
+			detail.ValidationRules,
+			detail.Description,
+			detail.SortOrder,
+			detail.IsSensitive,
+			detail.IsReadonly,
+			detail.Creator,
+		)
+		if err != nil {
+			return err
+		}
+	}
+
+	// 使用临时表进行批量UPSERT
+	_, err = tx.Exec(`
+		INSERT INTO config_template_detail (
+			config_template_id, config_key, config_value, value_type, data_type,
+			is_required, default_value, validation_rules, description, sort_order,
+			is_sensitive, is_readonly, creator, created_at, updated_at
+		)
+		SELECT $1, config_key, config_value, value_type, data_type,
+			is_required, default_value, validation_rules, description, sort_order,
+			is_sensitive, is_readonly, creator, $2, $3
+		FROM temp_config_details
+		ON CONFLICT (config_template_id, config_key) DO UPDATE SET
+			config_value = EXCLUDED.config_value,
+			value_type = EXCLUDED.value_type,
+			data_type = EXCLUDED.data_type,
+			is_required = EXCLUDED.is_required,
+			default_value = EXCLUDED.default_value,
+			validation_rules = EXCLUDED.validation_rules,
+			description = EXCLUDED.description,
+			sort_order = EXCLUDED.sort_order,
+			is_sensitive = EXCLUDED.is_sensitive,
+			is_readonly = EXCLUDED.is_readonly,
+			creator = EXCLUDED.creator,
+			updated_at = EXCLUDED.updated_at`,
+		templateID, now, now)
+
+	return err
+}