diff --git a/api/amqp/consumer/CancelUnPayOrder.go b/api/amqp/consumer/CancelUnPayOrder.go index e9a86ed..2dd81aa 100644 --- a/api/amqp/consumer/CancelUnPayOrder.go +++ b/api/amqp/consumer/CancelUnPayOrder.go @@ -124,6 +124,8 @@ func CancelUnPayOrder(msg amqp091.Delivery) { } } + tx.Commit() + // 关闭支付订单 if data.PayChannel == 1 { // h5支付 @@ -141,7 +143,5 @@ func CancelUnPayOrder(msg amqp091.Delivery) { } } - tx.Commit() - _ = msg.Ack(false) } diff --git a/api/service/OrderMember.go b/api/service/OrderMember.go index 02728bf..ea8ad21 100644 --- a/api/service/OrderMember.go +++ b/api/service/OrderMember.go @@ -193,7 +193,7 @@ func (r *OrderMemberService) AddOrderMember(tx *gorm.DB, UserId, SystemMemberId delay := 30 * time.Minute if config.C.Env == "dev" { - delay = 1 * time.Minute + delay = 3 * time.Minute } data := make(map[string]interface{}) diff --git a/api/service/OrderSingle.go b/api/service/OrderSingle.go index b930430..e0a83e7 100644 --- a/api/service/OrderSingle.go +++ b/api/service/OrderSingle.go @@ -221,7 +221,7 @@ func (r *OrderSingleService) AddOrderSingle(tx *gorm.DB, UserId, QuestionId int6 delay := 30 * time.Minute if config.C.Env == "dev" { - delay = 1 * time.Minute + delay = 3 * time.Minute } data := make(map[string]interface{})