bug fix

2023-10-10 17:27:57 +08:00
parent f3df8b326b
commit 6e18e90467
3 changed files with 7 additions and 4 deletions
--- a/src/main/java/com/peanut/modules/mq/Consumer/OrderCancelConsumer.java
+++ b/src/main/java/com/peanut/modules/mq/Consumer/OrderCancelConsumer.java
@@ -21,7 +21,9 @@ public class OrderCancelConsumer {
    @RabbitListener(queues = DelayQueueConfig.ORDER_CANCEL_DEAD_LETTER_QUEUE)
    public void orderConsumer(String orderId) {
        BuyOrderEntity buyOrder = buyOrderService.getById(orderId);
-        buyOrder.setOrderStatus(Constants.ORDER_STATUS_OUT_OF_TIME);
+        if(Constants.ORDER_STATUS_TO_BE_PAID.equals(buyOrder.getOrderStatus())){
+            buyOrder.setOrderStatus(Constants.ORDER_STATUS_OUT_OF_TIME);
+        }
        buyOrderService.updateById(buyOrder);
    }
 }