添加生成优惠券消息队列

README.en.md

@@ -1,36 +0,0 @@
-# rabbitMQ公共结构体
-
-#### Description
-{**When you're done, you can delete the content in this README and update the file with details for others getting started with your repository**}
-
-#### Software Architecture
-Software architecture description
-
-#### Installation
-
-1.  xxxx
-2.  xxxx
-3.  xxxx
-
-#### Instructions
-
-1.  xxxx
-2.  xxxx
-3.  xxxx
-
-#### Contribution
-
-1.  Fork the repository
-2.  Create Feat_xxx branch
-3.  Commit your code
-4.  Create Pull Request
-
-
-#### Gitee Feature
-
-1.  You can use Readme\_XXX.md to support different languages, such as Readme\_en.md, Readme\_zh.md
-2.  Gitee blog [blog.gitee.com](https://blog.gitee.com)
-3.  Explore open source project [https://gitee.com/explore](https://gitee.com/explore)
-4.  The most valuable open source project [GVP](https://gitee.com/gvp)
-5.  The manual of Gitee [https://gitee.com/help](https://gitee.com/help)
-6.  The most popular members  [https://gitee.com/gitee-stars/](https://gitee.com/gitee-stars/)

README.md

@@ -1,39 +1,19 @@
 # rabbitMQ公共结构体
 
-#### 介绍
+## window开发者执行
-{**以下是 Gitee 平台说明，您可以替换此简介**
+```bash
-Gitee 是 OSCHINA 推出的基于 Git 的代码托管平台（同时支持 SVN）。专为开发者提供稳定、高效、安全的云端软件开发协作平台
+git config --global core.autocrlf true    # 提交时转 CRLF 为 LF，检出时转 LF 为 CRLF
-无论是个人、团队、或是企业，都能够用 Gitee 实现代码托管、项目管理、协作开发。企业项目请看 [https://gitee.com/enterprises](https://gitee.com/enterprises)}
+```
 
-#### 软件架构
+## mac开发者执行
-软件架构说明
+```bash
+git config --global core.autocrlf input   # 提交时转 CRLF 为 LF，检出时不转换
+```
 
-
+## 格式化
-#### 安装教程
+```bash
-
+gofumpt -l -w .
-1.  xxxx
+```
-2.  xxxx
+```bash
-3.  xxxx
+go install mvdan.cc/gofumpt@latest
-
+```
-#### 使用说明
-
-1.  xxxx
-2.  xxxx
-3.  xxxx
-
-#### 参与贡献
-
-1.  Fork 本仓库
-2.  新建 Feat_xxx 分支
-3.  提交代码
-4.  新建 Pull Request
-
-
-#### 特技
-
-1.  使用 Readme\_XXX.md 来支持不同的语言，例如 Readme\_en.md, Readme\_zh.md
-2.  Gitee 官方博客 [blog.gitee.com](https://blog.gitee.com)
-3.  你可以 [https://gitee.com/explore](https://gitee.com/explore) 这个地址来了解 Gitee 上的优秀开源项目
-4.  [GVP](https://gitee.com/gvp) 全称是 Gitee 最有价值开源项目，是综合评定出的优秀开源项目
-5.  Gitee 官方提供的使用手册 [https://gitee.com/help](https://gitee.com/help)
-6.  Gitee 封面人物是一档用来展示 Gitee 会员风采的栏目 [https://gitee.com/gitee-stars/](https://gitee.com/gitee-stars/)

go.mod

@@ -1,3 +1,10 @@
 module git.ssgfgtfy.com/public/common_structure
 
 go 1.18.0
+
+require (
+	github.com/dromara/carbon/v2 v2.6.4
+	go.uber.org/zap v1.27.0
+)
+
+require go.uber.org/multierr v1.10.0 // indirect

go.sum

@@ -0,0 +1,11 @@
+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/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=
+go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
+go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
+go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

log.go

@@ -1,30 +1,40 @@
 package common_structure
 
-import "time"
+import (
+	"fmt"
+
+	"github.com/dromara/carbon/v2"
+	"go.uber.org/zap"
+)
 
 type LogType = string
 
 const (
-	LogTypeOrder   LogType = "order"   // 订单
+	LogTypeOrder        LogType = "order"         // 订单
-	LogTypeProduct LogType = "product" // 商品
+	LogTypeProduct      LogType = "product"       // 商品
-	LogTypeGPS     LogType = "gps"     // gps
+	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"`   // 类型
+	InfoType   LogType     `json:"info_type"`             // 日志类型，按被操作对象划分
-	Operator   Operator    `json:"operator"`    // 操作人
+	Operator   *Operator   `json:"operator,omitempty"`    // 操作人，系统操作不用填写操作人，写日志类型就可以
-	ObjectorID int         `json:"objector_id"` // 被操作对象ID，如果是gps，短信等服务则为0
+	ObjectorID int         `json:"objector_id,omitempty"` // 被操作对象ID，如果是gps，短信等服务则为0
-	Title      string      `json:"title"`       // 标题，做什么事情
+	Title      string      `json:"title"`                 // 必填，标题，做什么事情
-	Param      interface{} `json:"param"`       // 参数，请求参数，函数、方法就是参数
+	Param      interface{} `json:"param,omitempty"`       // 参数，请求参数，传指针
-	Result     interface{} `json:"result"`      // 结果，返回值
+	Result     interface{} `json:"result,omitempty"`      // 结果，返回值，传指针，如果是报错，传err
-	ErrStr     string      `json:"err_str"`     // 错误信息，json转义error没有自动存储，需要手动转义
+	ErrStr     string      `json:"err_str,omitempty"`     // 错误信息
-	At         time.Time   `json:"at"`          // 记录时间
+	At         string      `json:"at"`                    // 记录时间，不用传入，自动记录
 }
 
 type OperatorType = string
 
 const (
-	SystemOperatorType   OperatorType = "system"   // 系统
 	AdminOperatorType    OperatorType = "admin"    // 管理员
 	MerchantOperatorType OperatorType = "merchant" // 商家
 	UserOperatorType     OperatorType = "user"     // 用户
@@ -35,17 +45,40 @@ type Operator struct {
 	OperatorType OperatorType
 }
 
-type ObjectorType = string
+func ZapDebug(logger *zap.Logger, log *LogInfo) {
-
+	handleLog(log)
-const (
+	logger.Debug("", zap.Any("log", log))
-	ObjectorTypeGPS     ObjectorType = "gps" // gps
+}
-	ObjectorTypeSMS     ObjectorType = "sms" // sms
+
-	ObjectorTypeProduct ObjectorType = "product"
+func ZapInfo(logger *zap.Logger, log *LogInfo) {
-	ObjectorTypeOrder   ObjectorType = "order"
+	handleLog(log)
-	ObjectorTypePay     ObjectorType = "pay"
+	logger.Info("", zap.Any("log", log))
-)
+}
-
+
-type Objector struct {
+func ZapWarn(logger *zap.Logger, log *LogInfo) {
-	ID           int // 系统ID设置0
+	handleLog(log)
-	ObjectorType ObjectorType
+	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
+	}
 }

rabbitmq_coupon.go

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

rabbitmq_order.go

@@ -12,10 +12,10 @@ const (
 	OrderCloseTypeMerchantClose         OrderCloseType = 30 // 商家关闭
 	OrderCloseTypeThirdOrderFailedClose OrderCloseType = 40 // 第三方订单下单失败关闭
 	OrderCloseTypeUser                  OrderCloseType = 50 // 用户主动关闭
-	OrderCloseTypeMerchantCancel        OrderCloseType = 60 //商家取消订单关闭
+	OrderCloseTypeMerchantCancel        OrderCloseType = 60 // 商家取消订单关闭
-	OrderCloseTypeDeliveryTimeout       OrderCloseType = 70 //发货超时关闭
+	OrderCloseTypeDeliveryTimeout       OrderCloseType = 70 // 发货超时关闭
-	OrderCloseTypePaymentFailed         OrderCloseType = 80 //创建支付失败
+	OrderCloseTypePaymentFailed         OrderCloseType = 80 // 创建支付失败
-	OrderCloseTypeAbandonPayment        OrderCloseType = 90 //放弃支付
+	OrderCloseTypeAbandonPayment        OrderCloseType = 90 // 放弃支付
 
 )
 

rabbitmq_product.go

@@ -17,8 +17,8 @@ type ProductsIncreaseSold struct {
 type StockState = string
 
 const (
-	StockStateIncrease StockState = "increase_inventory" //增加库存
+	StockStateIncrease StockState = "increase_inventory" // 增加库存
-	StockStateDecrease StockState = "reduce_inventory"   //减少库存
+	StockStateDecrease StockState = "reduce_inventory"   // 减少库存
 )
 
 type ProductsChangeStockType = int