增加自动获取所有配置文件方法，增加微服务配置插入删除方法

model/request/configreq/config_requset_model.go

@@ -0,0 +1,12 @@
+package configreq
+
+// ConfigRequest 配置参数请求
+type ConfigRequest struct {
+	YamlRoot     string                  `json:"yaml_boot" binding:"required"`
+	ConfigFields map[string]*ConfigField `json:"config_info,omitempty"`
+}
+
+type ConfigField struct {
+	YamlName  string `json:"yaml_name," binding:"required"`
+	YamlValue string `json:"yaml_value" binding:"required"`
+}

model/request/dbreq/db_requset_model.go

@@ -0,0 +1,36 @@
+package dbreq
+
+// TableRequest 表字典
+type TableRequest struct {
+	TableName           string `json:"table_name"`
+	TableNameCN         string `json:"table_name_cn"`
+	Description         string `json:"description"`
+	PrimaryKeyFieldName string `json:"primary_key_field_name"`
+}
+
+// TablesRequest 表字典集合
+type TablesRequest struct {
+	TableNames []*TableRequest `json:"table_names"`
+	FieldInfos []*FieldInfo    `json:"field_names"`
+}
+
+// FieldInfo 字段信息
+type FieldInfo struct {
+	TableName string `json:"table_name"`
+	// 字段名称（英文/数据库字段名）
+	FieldName string `json:"field_name"`
+	// 字段中文名称
+	FieldNameCN string `json:"field_name_cn"`
+	// 字段描述
+	Description string `json:"description"`
+	// 字段类型（如：varchar, int, datetime等）
+	FieldType string `json:"field_type"`
+	// 字段长度/精度
+	FieldLength *int `json:"field_length,omitempty"`
+	// 是否为主键
+	IsPrimaryKey bool `json:"is_primary_key"`
+	// 是否允许为空
+	IsNullable bool `json:"is_nullable"`
+	// 小数位数（对于decimal类型）
+	DecimalPlaces *int `json:"decimal_places,omitempty"`
+}

model/request/dorisreq/doris_requset_model.go

@@ -0,0 +1,14 @@
+package dorisreq
+
+// QueryRequest 查询请求
+type QueryRequest struct {
+	SQL              string                 `json:"sql" binding:"required"`
+	Params           map[string]interface{} `json:"params,omitempty"`           //名称参数
+	PositionalParams []interface{}          `json:"positionalParams,omitempty"` // 位置参数
+	WriterHeader     bool                   `json:"writerHeader,omitempty"`     //如果查询返回cvs格式时候，包含表头还是不包含。true包含。第一行是表头
+	AgentUrl         string                 `json:"agentUrl,omitempty"`         //远程服务器地址
+	AgentToken       string                 `json:"agentToken,omitempty"`       //远程代理服务器token
+	DorisDatabase    string                 `json:"dorisDatabase,omitempty"`    //doris数据库名称
+	DorisTable       string                 `json:"dorisTable,omitempty"`       //doris数据库里的表名称
+
+}

model/request/requset_model.go → model/request/mqreq/mq_requset_model.go

@@ -1,4 +1,4 @@
-package request
+package mqreq
 
 import (
 	"time"
@@ -75,64 +75,3 @@ type QueueInfoRequest struct {
 	ChannelName string `json:"channel_name,omitempty"`
 	QueueName   string `json:"queue_name,omitempty"`
 }
-
-// RabbitMQResult RabbitMQ操作结果
-// type RabbitMQResult struct {
-// 	Success   bool        `json:"success"`
-// 	Error     string      `json:"error,omitempty"`
-// 	Data      interface{} `json:"data,omitempty"`
-// 	Message   string      `json:"message,omitempty"`
-// 	Time      string      `json:"time"`
-// 	Exchange  string      `json:"exchange,omitempty"`
-// 	Queue     string      `json:"queue,omitempty"`
-// 	MessageID string      `json:"message_id,omitempty"`
-// 	QueueInfo interface{} `json:"queue_info,omitempty"`
-// }
-
-// QueryRequest 查询请求
-type QueryRequest struct {
-	SQL              string                 `json:"sql" binding:"required"`
-	Params           map[string]interface{} `json:"params,omitempty"`           //名称参数
-	PositionalParams []interface{}          `json:"positionalParams,omitempty"` // 位置参数
-	WriterHeader     bool                   `json:"writerHeader,omitempty"`     //如果查询返回cvs格式时候，包含表头还是不包含。true包含。第一行是表头
-	AgentUrl         string                 `json:"agentUrl,omitempty"`         //远程服务器地址
-	AgentToken       string                 `json:"agentToken,omitempty"`       //远程代理服务器token
-	DorisDatabase    string                 `json:"dorisDatabase,omitempty"`    //doris数据库名称
-	DorisTable       string                 `json:"dorisTable,omitempty"`       //doris数据库里的表名称
-
-}
-
-// TableRequest 表字典
-type TableRequest struct {
-	TableName           string `json:"table_name"`
-	TableNameCN         string `json:"table_name_cn"`
-	Description         string `json:"description"`
-	PrimaryKeyFieldName string `json:"primary_key_field_name"`
-}
-
-// TablesRequest 表字典集合
-type TablesRequest struct {
-	TableNames []*TableRequest `json:"table_names"`
-	FieldInfos []*FieldInfo    `json:"field_names"`
-}
-
-// FieldInfo 字段信息
-type FieldInfo struct {
-	TableName string `json:"table_name"`
-	// 字段名称（英文/数据库字段名）
-	FieldName string `json:"field_name"`
-	// 字段中文名称
-	FieldNameCN string `json:"field_name_cn"`
-	// 字段描述
-	Description string `json:"description"`
-	// 字段类型（如：varchar, int, datetime等）
-	FieldType string `json:"field_type"`
-	// 字段长度/精度
-	FieldLength *int `json:"field_length,omitempty"`
-	// 是否为主键
-	IsPrimaryKey bool `json:"is_primary_key"`
-	// 是否允许为空
-	IsNullable bool `json:"is_nullable"`
-	// 小数位数（对于decimal类型）
-	DecimalPlaces *int `json:"decimal_places,omitempty"`
-}

util/crypto_service.go → util/crypto/crypto_service.go

@@ -1,4 +1,4 @@
-package util
+package crypto
 
 import (
 	"crypto/aes"

util/jwt_util.go → util/jwt/jwt_util.go

@@ -1,4 +1,4 @@
-package util
+package jwt
 
 import (
 	"fmt"

util/modle_util.go → util/model/modle_util.go

@@ -1,4 +1,4 @@
-package util
+package model
 
 import (
 	"reflect"

util/valid/string_valid.go

@@ -0,0 +1,120 @@
+package valid
+
+import (
+	"encoding/json"
+	"fmt"
+	"strconv"
+	"strings"
+)
+
+// ValidateAndConvert 验证并转换配置值（纯函数模式）
+func ValidateAndConvert(fieldType, yamlValue string) (string, error) {
+	if fieldType == "" {
+		// 如果没有指定类型，按字符串处理
+		return yamlValue, nil
+	}
+
+	switch fieldType {
+	case "bool":
+		return ValidateBool(yamlValue)
+	case "int":
+		return ValidateInt(yamlValue)
+	case "string":
+		return ValidateString(yamlValue)
+	case "uint64":
+		return ValidateUint64(yamlValue)
+	default:
+		// 检查是否是 map 类型
+		if strings.HasPrefix(fieldType, "map[") {
+			return ValidateMap(fieldType, yamlValue)
+		}
+		// 未知类型，按原样返回（可能是自定义类型）
+		return yamlValue, nil
+	}
+}
+
+// validateBool 验证布尔值（纯函数模式）
+func ValidateBool(value string) (string, error) {
+	if value == "" {
+		return "false", nil // 空值默认为 false
+	}
+
+	// 支持多种布尔表示形式
+	switch strings.ToLower(value) {
+	case "true", "1", "yes", "y", "on":
+		return "true", nil
+	case "false", "0", "no", "n", "off":
+		return "false", nil
+	default:
+		// 尝试解析
+		if b, err := strconv.ParseBool(value); err == nil {
+			return strconv.FormatBool(b), nil
+		}
+		return "", fmt.Errorf("无效的布尔值: %s，可接受值: true/false, 1/0, yes/no, on/off", value)
+	}
+}
+
+// validateInt 验证整数值（纯函数模式）
+func ValidateInt(value string) (string, error) {
+	if value == "" {
+		return "0", nil // 空值默认为 0
+	}
+
+	// 尝试解析为整数
+	_, err := strconv.Atoi(value)
+	if err != nil {
+		// 也尝试解析为浮点数然后取整
+		if f, err := strconv.ParseFloat(value, 64); err == nil {
+			return strconv.Itoa(int(f)), nil
+		}
+		return "", fmt.Errorf("无效的整数值: %s", value)
+	}
+
+	return value, nil
+}
+
+// validateUint64 验证无符号64位整数（纯函数模式）
+func ValidateUint64(value string) (string, error) {
+	if value == "" {
+		return "0", nil // 空值默认为 0
+	}
+
+	// 尝试解析为 uint64
+	_, err := strconv.ParseUint(value, 10, 64)
+	if err != nil {
+		return "", fmt.Errorf("无效的uint64值: %s", value)
+	}
+
+	return value, nil
+}
+
+// validateString 验证字符串（纯函数模式）
+func ValidateString(value string) (string, error) {
+	// 字符串类型不需要特殊验证
+	return value, nil
+}
+
+// validateMap 验证 map 类型（纯函数模式）
+func ValidateMap(fieldType, value string) (string, error) {
+	if value == "" {
+		return "{}", nil // 空值返回空对象
+	}
+
+	// 检查是否是期望的 map[string]*subconfigs.DbConfig 类型
+	if fieldType != "map[string]*subconfigs.DbConfig" {
+		return "", fmt.Errorf("不支持的map类型: %s", fieldType)
+	}
+
+	// 验证是否为有效的 JSON
+	if !IsValidJSON(value) {
+		return "", fmt.Errorf("map类型需要有效的JSON格式")
+	}
+
+	return value, nil
+}
+
+// isValidJSON 检查是否为有效的 JSON（纯函数模式）
+func IsValidJSON(s string) bool {
+	var js interface{}
+	return json.Unmarshal([]byte(s), &js) == nil
+}