diff --git a/src/main/java/com/peanut/modules/mq/Consumer/OrderCancelConsumer.java b/src/main/java/com/peanut/modules/mq/Consumer/OrderCancelConsumer.java index ac3b3eab..891aa635 100644 --- a/src/main/java/com/peanut/modules/mq/Consumer/OrderCancelConsumer.java +++ b/src/main/java/com/peanut/modules/mq/Consumer/OrderCancelConsumer.java @@ -49,6 +49,8 @@ public class OrderCancelConsumer { } } buyOrderService.updateById(buyOrder); - buyOrderService.removeById(buyOrder); + if(Constants.ORDER_STATUS_OUT_OF_TIME.equals(buyOrder.getOrderStatus())){ + buyOrderService.removeById(buyOrder); + } } } \ No newline at end of file