diff --git a/api/amqp/consumer/CancelUnPayOrder.go b/api/amqp/consumer/CancelUnPayOrder.go index 51e6dfa..ee7e2dc 100644 --- a/api/amqp/consumer/CancelUnPayOrder.go +++ b/api/amqp/consumer/CancelUnPayOrder.go @@ -119,13 +119,17 @@ func CancelUnPayOrder(msg amqp091.Delivery) { if data.PayChannel == 1 { // h5支付 err = weChat.CloseJsapiOrder(data.OrderNo) - utils.LogJsonErr("consumer.CancelUnPayOrder:", err) + if err != nil { + utils.LogJsonErr("consumer.CancelUnPayOrder:", err) + } } if data.PayChannel == 2 { // app支付 err = weChat.CloseAppOrder(data.OrderNo) - utils.LogJsonErr("consumer.CancelUnPayOrder:", err) + if err != nil { + utils.LogJsonErr("consumer.CancelUnPayOrder:", err) + } } tx.Commit()