From f11d0031708f942bfc69c7e76364b2d1275b8652 Mon Sep 17 00:00:00 2001
From: wucongxing8150 <815046773@qq.com>
Date: Tue, 27 Aug 2024 17:35:33 +0800
Subject: [PATCH] 1

---
 api/amqp/consumer/CancelUnPayOrder.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/api/amqp/consumer/CancelUnPayOrder.go b/api/amqp/consumer/CancelUnPayOrder.go
index ee7e2dc..3284f1e 100644
--- a/api/amqp/consumer/CancelUnPayOrder.go
+++ b/api/amqp/consumer/CancelUnPayOrder.go
@@ -76,7 +76,7 @@ func CancelUnPayOrder(msg amqp091.Delivery) {
 		if err != nil {
 			tx.Rollback()
 			utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
-			_ = msg.Reject(true)
+			_ = msg.Ack(false)
 			return
 		}
 
@@ -101,7 +101,7 @@ func CancelUnPayOrder(msg amqp091.Delivery) {
 		if err != nil {
 			tx.Rollback()
 			utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
-			_ = msg.Reject(true)
+			_ = msg.Ack(false)
 			return
 		}