修正取消订单时重复消费问题3

2024-08-23 16:25:30 +08:00 · 2024-08-23 16:25:30 +08:00 · 93328dac02
commit 93328dac02
parent 101a28ca78
1 changed files with 6 additions and 2 deletions
--- 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()