refactor(gateway): 重构网关服务并优化订单创建逻辑- 移除未使用的导入和消费者初始化代码

- 添加订单创建过程的日志记录
- 完善订单创建错误的响应信息- 更新 .gitignore 文件,忽略 gateway.exe
This commit is contained in:
danial
2025-02-09 17:59:22 +08:00
parent a4c3ded960
commit 7fb29dfa5c
3 changed files with 9 additions and 10 deletions

3
.gitignore vendored
View File

@@ -5,4 +5,5 @@
/static/
*.DS_Store
.DS_Store
.DS_Store?
.DS_Store?
/gateway.exe

View File

@@ -293,6 +293,7 @@ func (c *ScanController) GetAllowedMM() {
func (c *ScanController) CreateOrder() {
createdOrder := request.CreatedOrder{}
_ = c.Bind(&createdOrder)
logs.Info("创建订单:%+v", createdOrder)
valid := validation.Validation{}
b, err := valid.Valid(&createdOrder)
if err != nil || !b {
@@ -306,7 +307,7 @@ func (c *ScanController) CreateOrder() {
merchantInfo := merchant.GetMerchantByPasskey(createdOrder.PayKey)
if merchantInfo.Id == 0 {
logs.Error("创建订单错误:", err)
c.Data["json"] = response.CommonErr(-1, "创建订单错误")
c.Data["json"] = response.CommonErr(-1, "创建订单错误,商户不存在")
_ = c.ServeJSON()
return
}
@@ -356,7 +357,7 @@ func (c *ScanController) CreateOrder() {
// 创建订单记录
orderInfo, err = service.CreateOrderInfoAndOrderProfitInfo(createdOrder, merchantInfo)
if err != nil {
res := response.CommonErr(-1, "创建订单失败")
res := response.CommonErr(-1, "创建订单失败,创建订单记录失败")
logs.Info("创建订单错误:", err)
c.Data["json"] = res
_ = c.ServeJSON()

11
main.go
View File

@@ -2,12 +2,9 @@ package main
import (
_ "gateway/internal/entities/message"
"gateway/internal/entities/notify"
_ "gateway/internal/entities/supplier/third_party"
_ "gateway/internal/models"
_ "gateway/internal/routers"
"gateway/internal/schema/query"
"gateway/internal/service"
"github.com/beego/beego/v2/core/logs"
"github.com/beego/beego/v2/server/web"
_ "github.com/go-sql-driver/mysql"
@@ -30,10 +27,10 @@ func main() {
profile.MemProfileRate(1),
).Stop()
web.BConfig.WebConfig.Session.SessionOn = true
go notify.CreateOrderNotifyConsumer()
go query.CreatePayForQueryConsumer()
go service.OrderSettleInit()
go query.CreateSupplierOrderQueryCuConsumer()
//go notify.CreateOrderNotifyConsumer()
//go query.CreatePayForQueryConsumer()
//go service.OrderSettleInit()
//go query.CreateSupplierOrderQueryCuConsumer()
web.Run()
}