add conf.PrintInfo

cache/redis/redis.go

@@ -59,6 +59,6 @@ func New(dsn string, hashRadix string) *RedisClient {
 
 func Hash(s string) int {
 	h := fnv.New32a()
-	h.Write([]byte(s))
+	h.Write([]byte(strings.ToLower(s)))
 	return int(h.Sum32()) % vars.RedisShardings
 }

conf/new.go

@@ -12,6 +12,7 @@ import (
 
 	"git.apinb.com/bsm-sdk/core/env"
 	"git.apinb.com/bsm-sdk/core/print"
+	"git.apinb.com/bsm-sdk/core/utils"
 	"git.apinb.com/bsm-sdk/core/vars"
 	yaml "gopkg.in/yaml.v3"
 )
@@ -26,9 +27,11 @@ func New(srvKey string, cfg any) {
 	vars.HostName, _ = os.Hostname()
 
 	// 构造配置文件路径,输出配置文件信息
-	cfp := fmt.Sprintf("%s_%s.yaml", srvKey, env.Runtime.Mode)
+	cfp := fmt.Sprintf("%s_%s.yaml", strings.ToLower(srvKey), env.Runtime.Mode)
 	cfp = filepath.Join(env.Runtime.Prefix, "etc", cfp)
+
 	print.Info("[BSM - %s] Config File: %s", srvKey, cfp)
+	print.Info("[BSM - %s] Check Configure ...", vars.ServiceKey)
 
 	// 读取配置文件内容
 	yamlFile, err := os.ReadFile(cfp)
@@ -41,10 +44,6 @@ func New(srvKey string, cfg any) {
 		log.Fatalln("ERROR: Service Not Nil", cfp)
 	}
 
-	if !strings.Contains(string(yamlFile), "Port:") {
-		log.Fatalln("ERROR: Port Not Nil", cfp)
-	}
-
 	// 解析YAML
 	err = yaml.Unmarshal(yamlFile, cfg)
 	if err != nil {
@@ -55,11 +54,18 @@ func New(srvKey string, cfg any) {
 func NotNil(values ...string) {
 	for _, value := range values {
 		if strings.TrimSpace(value) == "" {
-			log.Fatalln("ERROR:Must config not nil")
+			log.Fatalln("ERROR:Must config key not nil")
 		}
 	}
 }
 
+func PrintInfo(port int) {
+	print.Success("[BSM - %s] Config Check Success.", vars.ServiceKey)
+	print.Info("[BSM - %s] Service Name: %s", vars.ServiceKey, vars.ServiceKey)
+	print.Info("[BSM - %s] Runtime Mode: %s", vars.ServiceKey, env.Runtime.Mode)
+	print.Info("[BSM - %s] Listen Addr: %s:%d", vars.ServiceKey, utils.GetLocationIP(), port)
+}
+
 func CheckPort(port int) int {
 	if port <= 0 || port >= 65535 {
 		r := rand.New(rand.NewPCG(1000, uint64(time.Now().UnixNano())))

database/sql/postgresql.go

@@ -8,6 +8,20 @@ import (
 	"gorm.io/gorm/schema"
 )
 
+func SetOptions(options *types.SqlOptions) *types.SqlOptions {
+	if options == nil {
+		options = &types.SqlOptions{
+			MaxIdleConns:    vars.SqlOptionMaxIdleConns,
+			MaxOpenConns:    vars.SqlOptionMaxIdleConns,
+			ConnMaxLifetime: vars.SqlOptionConnMaxLifetime,
+			LogStdout:       false,
+			Debug:           false,
+		}
+	}
+
+	return options
+}
+
 // new grom db.
 func NewPostgreSql(dsn string, options *types.SqlOptions) (*gorm.DB, error) {
 	var err error

errcode/errcode.go

@@ -10,10 +10,12 @@ var (
 	ErrHeaderRequestId     = NewError(101, "Header Request-Id Not Found")
 	ErrHeaderAuthorization = NewError(102, "Header Authorization Not Found")
 	ErrHeaderSecretKey     = NewError(103, "Header Secret-Key Not Found")
+	ErrHeaderMustParams    = NewError(104, "Header Must Params")
 )
 
 // standard error code ,start:110
 var (
+	ErrEmpty         = NewError(110, "Data Is Empty")
 	ErrRequestParse  = NewError(111, "Request Parse Fail")
 	ErrRequestMust   = NewError(112, "Request Params Required")
 	ErrPermission    = NewError(113, "Permission Denied")

go.mod

@@ -5,6 +5,7 @@ go 1.24
 require (
 	github.com/FishGoddess/cachego v0.6.1
 	github.com/elastic/go-elasticsearch/v8 v8.17.1
+	github.com/google/uuid v1.6.0
 	github.com/nats-io/nats.go v1.39.0
 	github.com/oklog/ulid/v2 v2.1.0
 	github.com/redis/go-redis/v9 v9.7.0

go.sum

@@ -23,12 +23,8 @@ 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/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
-github.com/elastic/elastic-transport-go/v8 v8.6.0 h1:Y2S/FBjx1LlCv5m6pWAF2kDJAHoSjSRSJCApolgfthA=
-github.com/elastic/elastic-transport-go/v8 v8.6.0/go.mod h1:YLHer5cj0csTzNFXoNQ8qhtGY1GTvSqPnKWKaqQE3Hk=
 github.com/elastic/elastic-transport-go/v8 v8.6.1 h1:h2jQRqH6eLGiBSN4eZbQnJLtL4bC5b4lfVFRjw2R4e4=
 github.com/elastic/elastic-transport-go/v8 v8.6.1/go.mod h1:YLHer5cj0csTzNFXoNQ8qhtGY1GTvSqPnKWKaqQE3Hk=
-github.com/elastic/go-elasticsearch/v8 v8.17.0 h1:e9cWksE/Fr7urDRmGPGp47Nsp4/mvNOrU8As1l2HQQ0=
-github.com/elastic/go-elasticsearch/v8 v8.17.0/go.mod h1:lGMlgKIbYoRvay3xWBeKahAiJOgmFDsjZC39nmO3H64=
 github.com/elastic/go-elasticsearch/v8 v8.17.1 h1:bOXChDoCMB4TIwwGqKd031U8OXssmWLT3UrAr9EGs3Q=
 github.com/elastic/go-elasticsearch/v8 v8.17.1/go.mod h1:MVJCtL+gJJ7x5jFeUmA20O7rvipX8GcQmo5iBcmaJn4=
 github.com/gabriel-vasile/mimetype v1.4.8 h1:FfZ3gj38NjllZIeJAmMhr+qKL8Wu+nOoI3GqacKw1NM=
@@ -51,8 +47,6 @@ github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/o
 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.24.0 h1:KHQckvo8G6hlWnrPX4NJJ+aBfWNAE/HH+qdL2cBpCmg=
-github.com/go-playground/validator/v10 v10.24.0/go.mod h1:GGzBIJMuE98Ic/kJsBXbz1x/7cByt++cQ+YOuDM5wus=
 github.com/go-playground/validator/v10 v10.25.0 h1:5Dh7cjvzR7BRZadnsVOzPhWsrwUr0nmsZJxEAnFLNO8=
 github.com/go-playground/validator/v10 v10.25.0/go.mod h1:GGzBIJMuE98Ic/kJsBXbz1x/7cByt++cQ+YOuDM5wus=
 github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
@@ -104,8 +98,6 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
 github.com/nats-io/nats.go v1.39.0 h1:2/yg2JQjiYYKLwDuBzV0FbB2sIV+eFNkEevlRi4n9lI=
 github.com/nats-io/nats.go v1.39.0/go.mod h1:MgRb8oOdigA6cYpEPhXJuRVH6UE/V4jblJ2jQ27IXYM=
-github.com/nats-io/nkeys v0.4.9 h1:qe9Faq2Gxwi6RZnZMXfmGMZkg3afLLOtrU+gDZJ35b0=
-github.com/nats-io/nkeys v0.4.9/go.mod h1:jcMqs+FLG+W5YO36OX6wFIFcmpdAns+w1Wm6D3I/evE=
 github.com/nats-io/nkeys v0.4.10 h1:glmRrpCmYLHByYcePvnTBEAwawwapjCPMjy2huw20wc=
 github.com/nats-io/nkeys v0.4.10/go.mod h1:OjRrnIKnWBFl+s4YK5ChQfvHP2fxqZexrKJoVVyWB3U=
 github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw=
@@ -176,8 +168,6 @@ golang.org/x/arch v0.14.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.32.0 h1:euUpcYgM8WcP71gNpTqQCn6rC2t6ULUPiOzfWaXVVfc=
-golang.org/x/crypto v0.32.0/go.mod h1:ZnnJkOaASj8g0AjIduWNlq2NRxL0PlBrbKVyZ6V/Ugc=
 golang.org/x/crypto v0.33.0 h1:IOBPskki6Lysi0lo9qQvbxiQ+FvsCC/YWOecCHAixus=
 golang.org/x/crypto v0.33.0/go.mod h1:bVdXmD7IV/4GdElGPozy6U7lWdRXA4qyRVGJV57uQ5M=
 golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
@@ -186,8 +176,6 @@ golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
-golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
-golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
 golang.org/x/net v0.35.0 h1:T5GQRQb2y08kTAByq9L4/bz8cipCdA8FbRTXewonqY8=
 golang.org/x/net v0.35.0/go.mod h1:EglIi67kWsHKlRzzVMUD93VMSWGFOMSZgxFjparz1Qk=
 golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -215,12 +203,8 @@ golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8T
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/genproto/googleapis/api v0.0.0-20250204164813-702378808489 h1:fCuMM4fowGzigT89NCIsW57Pk9k2D12MMi2ODn+Nk+o=
-google.golang.org/genproto/googleapis/api v0.0.0-20250204164813-702378808489/go.mod h1:iYONQfRdizDB8JJBybql13nArx91jcUk7zCXEsOofM4=
 google.golang.org/genproto/googleapis/api v0.0.0-20250212204824-5a70512c5d8b h1:i+d0RZa8Hs2L/MuaOQYI+krthcxdEbEM2N+Tf3kJ4zk=
 google.golang.org/genproto/googleapis/api v0.0.0-20250212204824-5a70512c5d8b/go.mod h1:iYONQfRdizDB8JJBybql13nArx91jcUk7zCXEsOofM4=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250204164813-702378808489 h1:5bKytslY8ViY0Cj/ewmRtrWHW64bNF03cAatUUFCdFI=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250204164813-702378808489/go.mod h1:8BS3B93F/U1juMFq9+EDk+qOT5CO1R9IzXxG3PTqiRk=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250212204824-5a70512c5d8b h1:FQtJ1MxbXoIIrZHZ33M+w5+dAP9o86rgpjoKr/ZmT7k=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250212204824-5a70512c5d8b/go.mod h1:8BS3B93F/U1juMFq9+EDk+qOT5CO1R9IzXxG3PTqiRk=
 google.golang.org/grpc v1.70.0 h1:pWFv03aZoHzlRKHWicjsZytKAiYCtNS0dHbXnIdq7jQ=

infra/response.go

@@ -16,6 +16,7 @@ type Reply struct {
 func (reply *Reply) Success(ctx *gin.Context, data any) {
 	reply.Code = 200
 	reply.Data = data
+	reply.Msg = ""
 	if data == nil {
 		reply.Data = ""
 	}
@@ -23,12 +24,12 @@ func (reply *Reply) Success(ctx *gin.Context, data any) {
 }
 func (reply *Reply) Error(ctx *gin.Context, err error) {
 	reply.Code = 500
+	reply.Data = ""
 	// Status code defaults to 500
 	e, ok := status.FromError(err)
 	if ok {
 		reply.Code = int(e.Code())
 	}
-
 	reply.Msg = e.Message()
 
 	// Send error

print/print.go

@@ -3,28 +3,36 @@ package print
 import (
 	"fmt"
 	"log"
+	"os"
 )
 
+var logger *log.Logger
+
+func init() {
+	logger = log.New(os.Stdout, "", 0) // 创建一个新的 Logger 实例，不带任何标志
+	logger.SetFlags(log.Ldate | log.Ltime)
+}
+
 // record INFO message. Color White
 func Info(format string, a ...interface{}) {
-	message := fmt.Sprintf("\033[37m[Info] "+format+"\033[0m\n", a...)
+	message := fmt.Sprintf("\033[37m[Info]    "+format+"\033[0m\n", a...)
-	log.Print(message)
+	logger.Print(message)
 }
 
 // record Warn message. Color Orange
 func Warn(format string, a ...interface{}) {
-	message := fmt.Sprintf("\033[33m[Warn] "+format+"\033[0m\n", a...)
+	message := fmt.Sprintf("\033[33m[Warn]    "+format+"\033[0m\n", a...)
-	log.Print(message)
+	logger.Print(message)
 }
 
 // record Success message. Color Green
 func Success(format string, a ...interface{}) {
 	message := fmt.Sprintf("\033[32m[Success] "+format+"\033[0m\n", a...)
-	log.Print(message)
+	logger.Print(message)
 }
 
 // record ERROR message. Color Red
 func Error(format string, a ...interface{}) {
-	message := fmt.Sprintf("\033[31m[Error] "+format+"\033[0m\n", a...)
+	message := fmt.Sprintf("\033[31m[Error]   "+format+"\033[0m\n", a...)
-	log.Print(message)
+	logger.Print(message)
 }

types/db.go

@@ -31,7 +31,7 @@ type (
 		CreatedAt time.Time      `json:"created_at"`
 		UpdatedAt time.Time      `json:"updated_at"`
 		DeletedAt gorm.DeletedAt `gorm:"index;" json:"deleted_at"`
-		Status    int8           `gorm:"default:0;index;" json:"status"` // 状态：默认为0，-1禁止，1为正常
+		Status    int64          `gorm:"default:0;index;" json:"status"` // 状态：默认为0，-1禁止，1为正常
 	}
 
 	// standard ID,Identity,Created,Updated,Deleted,Status definition.
@@ -66,6 +66,6 @@ type (
 
 	// standard Status definition.
 	Std_Status struct {
-		Status int8 `gorm:"default:0;index;" json:"status"` // 状态：默认为0，-1禁止，1为正常
+		Status int64 `gorm:"default:0;index;" json:"status"` // 状态：默认为0，-1禁止，1为正常
 	}
 )

utils/identity.go

@@ -1,9 +1,14 @@
 package utils
 
 import (
+	"github.com/google/uuid"
 	ulid "github.com/oklog/ulid/v2"
 )
 
+func UUID() string {
+	return uuid.Must(uuid.NewV7()).String()
+}
+
 // remove nanoid,uuid,replace to ulid
 func ULID() string {
 	return ulid.Make().String()