diff --git a/src/main/java/com/peanut/modules/book/controller/BuyOrderController.java b/src/main/java/com/peanut/modules/book/controller/BuyOrderController.java index 08291f93..f0141438 100644 --- a/src/main/java/com/peanut/modules/book/controller/BuyOrderController.java +++ b/src/main/java/com/peanut/modules/book/controller/BuyOrderController.java @@ -269,6 +269,7 @@ public class BuyOrderController { @RequestMapping("/appGetOrderInfo/{type}") public R appGetOrderInfo(@PathVariable String type, @RequestParam("orderId") Integer orderId) { BuyOrderEntity buyOrder = buyOrderService.getById(orderId); + buyOrder.setTimestamp(buyOrder.getCreateTime().getTime()/1000); List orderDetail = null; if ("1".equals(type)) { orderDetail = buyOrderDetailService.getBaseMapper().selectList(new QueryWrapper() @@ -547,8 +548,7 @@ public class BuyOrderController { private MessagePostProcessor messagePostProcessor() { return message -> { //设置有效期30分钟 - //message.getMessageProperties().setExpiration("1800000"); - message.getMessageProperties().setExpiration("30000"); + message.getMessageProperties().setExpiration(String.valueOf(30*60*1000)); return message; }; } 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 c2a3251b..6cf45aca 100644 --- 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); } } \ No newline at end of file