Merge branch '增加用户类型'

go.mod

@@ -5,6 +5,7 @@ go 1.18.0
 require (
 	github.com/dromara/carbon/v2 v2.6.4
 	go.uber.org/zap v1.27.0
+	github.com/gogf/gf/v2 v2.7.2
 )
 
 require go.uber.org/multierr v1.10.0 // indirect

go.sum

@@ -1,6 +1,7 @@
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/dromara/carbon/v2 v2.6.4 h1:cpIansyiEIEed3OlEIqo1IXj86qu0x6pf/E2keL2wYo=
 github.com/dromara/carbon/v2 v2.6.4/go.mod h1:Baj3A1uBBctJmpZWJd6/+WWnmIuY2pobR6IOpB6xigc=
+github.com/gogf/gf/v2 v2.7.2/go.mod h1:EBXneAg/wes86rfeh68XC0a2JBNQylmT7Sp6/8Axk88=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=

log.go

@@ -1,84 +0,0 @@
-package common_structure
-
-import (
-	"fmt"
-
-	"github.com/dromara/carbon/v2"
-	"go.uber.org/zap"
-)
-
-type LogType = string
-
-const (
-	LogTypeOrder        LogType = "order"         // 订单
-	LogTypeProduct      LogType = "product"       // 商品
-	LogTypeMerchant     LogType = "merchant"      // 商家
-	LogTypeMerchantUser LogType = "merchant_user" // 商家用户
-	LogTypePay          LogType = "pay"           // 支付
-	LogTypeUser         LogType = "user"          // 用户
-	LogTypeGPS          LogType = "gps"           // gps
-	LogTypeSMS          LogType = "sms"           // 短信
-	LogTypeSystem       LogType = "system"        // 系统、日志、定时任务初始化、定时任务、mq初始化等
-)
-
-type LogInfo struct {
-	InfoType   LogType     `json:"info_type"`             // 日志类型，按被操作对象划分
-	Operator   *Operator   `json:"operator,omitempty"`    // 操作人，系统操作不用填写操作人，写日志类型就可以
-	ObjectorID int         `json:"objector_id,omitempty"` // 被操作对象ID，如果是gps，短信等服务则为0
-	Title      string      `json:"title"`                 // 必填，标题，做什么事情
-	Param      interface{} `json:"param,omitempty"`       // 参数，请求参数，传指针
-	Result     interface{} `json:"result,omitempty"`      // 结果，返回值，传指针，如果是报错，传err
-	ErrStr     string      `json:"err_str,omitempty"`     // 错误信息
-	At         string      `json:"at"`                    // 记录时间，不用传入，自动记录
-}
-
-type OperatorType = string
-
-const (
-	AdminOperatorType    OperatorType = "admin"    // 管理员
-	MerchantOperatorType OperatorType = "merchant" // 商家
-	UserOperatorType     OperatorType = "user"     // 用户
-)
-
-type Operator struct {
-	ID           int // 系统ID设置0
-	OperatorType OperatorType
-}
-
-func ZapDebug(logger *zap.Logger, log *LogInfo) {
-	handleLog(log)
-	logger.Debug("", zap.Any("log", log))
-}
-
-func ZapInfo(logger *zap.Logger, log *LogInfo) {
-	handleLog(log)
-	logger.Info("", zap.Any("log", log))
-}
-
-func ZapWarn(logger *zap.Logger, log *LogInfo) {
-	handleLog(log)
-	logger.Warn("", zap.Any("log", log))
-}
-
-func ZapError(logger *zap.Logger, log *LogInfo) {
-	handleLog(log)
-	logger.Error("", zap.Any("log", log))
-}
-
-func ZapPanic(logger *zap.Logger, log *LogInfo) {
-	handleLog(log)
-	logger.Panic("", zap.Any("log", log))
-}
-
-func ZapFatal(logger *zap.Logger, log *LogInfo) {
-	handleLog(log)
-	logger.Fatal("", zap.Any("log", log))
-}
-
-func handleLog(log *LogInfo) {
-	log.At = carbon.Now().ToDateTimeString()
-	if _, ok := log.Result.(error); ok {
-		log.ErrStr = fmt.Sprintf("%+v", log.Result)
-		log.Result = nil
-	}
-}

log/log.go

@@ -0,0 +1,141 @@
+package log
+
+import (
+	"context"
+	"fmt"
+	"github.com/dromara/carbon/v2"
+	"github.com/gogf/gf/v2/frame/g"
+	"go.uber.org/zap"
+)
+
+type LogType = string
+
+const (
+	LogTypeOrder           LogType = "order"             // 订单
+	LogTypeProduct         LogType = "product"           // 商品
+	LogTypeMerchant        LogType = "merchant"          // 商家
+	LogTypeMerchantRedPack LogType = "merchant_red_pack" // 商家红包
+	LogTypePay             LogType = "pay"               // 支付
+	LogTypeUser            LogType = "user"              // 用户
+	LogTypeUserRedPack     LogType = "user_red_pack"     // 用户红包
+	LogTypeGPS             LogType = "gps"               // gps
+	LogTypeSMS             LogType = "sms"               // 短信
+	LogTypeIP              LogType = "ip"                // ip信息
+	LogTypeAdmin           LogType = "admin"             // 管理员操作，例如登录、退出、修改密码、修改用户信息、修改角色信息、审核等
+	LogTypeSystem          LogType = "system"            // 系统、日志、定时任务初始化、定时任务、mq初始化等
+	LogTypeSystemRedPack   LogType = "system_red_pack"   // 系统红包
+	LogTypeActivity        LogType = "activity"          // 活动
+	LogTypeJJT             LogType = "jjt"               // 交易所
+)
+
+type LogInfo struct {
+	LogType    LogType     `json:"log_type"`              // 日志类型，按被操作对象划分
+	Operator   *Operator   `json:"operator,omitempty"`    // 操作人，系统操作不用填写操作人，写日志类型就可以
+	ObjectorID int         `json:"objector_id,omitempty"` // 被操作对象ID，如果是gps，短信等服务则为0
+	Title      string      `json:"title"`                 // 必填，标题，做什么事情
+	Param      interface{} `json:"param,omitempty"`       // 参数，请求参数，传指针
+	Result     interface{} `json:"result,omitempty"`      // 结果，返回值，传指针，如果是报错，传err
+	ErrStr     string      `json:"err_str,omitempty"`     // 错误信息，不用传入，自动记录
+	At         string      `json:"at"`                    // 记录时间，不用传入，自动记录
+}
+
+type OperatorType = string
+
+const (
+	OperatorTypeAdmin    OperatorType = "admin"    // 管理员
+	OperatorTypeMerchant OperatorType = "merchant" // 商家
+	OperatorTypeUser     OperatorType = "user"     // 用户
+)
+
+type Operator struct {
+	ID           int // 系统ID设置0
+	OperatorType OperatorType
+}
+
+func ZapDebug(logger *zap.Logger, log *LogInfo) {
+	handleLog(log)
+	logger.Debug("", zap.Any("log", log))
+}
+
+func ZapInfo(logger *zap.Logger, log *LogInfo) {
+	handleLog(log)
+	logger.Info("", zap.Any("log", log))
+}
+
+func ZapWarn(logger *zap.Logger, log *LogInfo) {
+	handleLog(log)
+	logger.Warn("", zap.Any("log", log))
+}
+
+func ZapError(logger *zap.Logger, log *LogInfo) {
+	handleLog(log)
+	logger.Error("", zap.Any("log", log))
+}
+
+func ZapPanic(logger *zap.Logger, log *LogInfo) {
+	handleLog(log)
+	logger.Panic("", zap.Any("log", log))
+}
+
+func ZapFatal(logger *zap.Logger, log *LogInfo) {
+	handleLog(log)
+	logger.Fatal("", zap.Any("log", log))
+}
+
+func handleLog(log *LogInfo) {
+	log.At = carbon.Now().ToDateTimeString()
+	if _, ok := log.Result.(error); ok {
+		log.ErrStr = fmt.Sprintf("%+v", log.Result)
+		log.Result = nil
+	}
+}
+
+func GFInfo(ctx context.Context, log *LogInfo) {
+	handleLog(log)
+	g.Log().Info(ctx, log)
+}
+
+func GFWarning(ctx context.Context, log *LogInfo) {
+	handleLog(log)
+	g.Log().Warning(ctx, log)
+}
+
+func GFError(ctx context.Context, log *LogInfo) {
+	handleLog(log)
+	g.Log().Error(ctx, log)
+}
+
+func GFDebug(ctx context.Context, log *LogInfo) {
+	handleLog(log)
+	g.Log().Debug(ctx, log)
+}
+
+func GFPanic(ctx context.Context, log *LogInfo) {
+	handleLog(log)
+	g.Log().Panic(ctx, log)
+}
+
+func GFFatal(ctx context.Context, log *LogInfo) {
+	handleLog(log)
+	g.Log().Fatal(ctx, log)
+}
+
+func (l *LogInfo) GFCommonHandelResult(ctx context.Context, result interface{}, err error) {
+	if err != nil {
+		l.Result = err
+		GFError(ctx, l)
+	} else {
+		l.Result = result
+		GFInfo(ctx, l)
+	}
+}
+
+func (l *LogInfo) ZapCommonHandelResult(logger *zap.Logger, result interface{}, err error) {
+	if err != nil {
+		l.Result = err
+		ZapError(logger, l)
+	} else {
+		l.Result = result
+		ZapInfo(logger, l)
+	}
+}

rabbitmq_coupon.go

@@ -0,0 +1,5 @@
+package common_structure
+
+type CouponCode struct {
+	ID uint `json:"id"` // 优惠券ID
+}

rabbitmq_red_packet.go

@@ -0,0 +1,5 @@
+package common_structure
+
+type GiveRedPacketTask struct {
+	TaskID uint `json:"task_id"` // 任务ID
+}

rabbitmq_user.go

@@ -0,0 +1,5 @@
+package common_structure
+
+type UserLogout struct {
+	UserID uint `json:"user_id"`
+}