1
This commit is contained in:
parent
4011c39b78
commit
f11d003170
@ -76,7 +76,7 @@ func CancelUnPayOrder(msg amqp091.Delivery) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
tx.Rollback()
|
tx.Rollback()
|
||||||
utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
|
utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
|
||||||
_ = msg.Reject(true)
|
_ = msg.Ack(false)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -101,7 +101,7 @@ func CancelUnPayOrder(msg amqp091.Delivery) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
tx.Rollback()
|
tx.Rollback()
|
||||||
utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
|
utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
|
||||||
_ = msg.Reject(true)
|
_ = msg.Ack(false)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user