| | |
| | | log.info("消费者:{}", new String(message.getBody())); |
| | | } |
| | | |
| | | @RabbitListener(queues = "queue_order_delay") |
| | | @RabbitListener(queues = "queue_order_delay_qay") |
| | | public void orderCancelDelay(String id) { |
| | | try { |
| | | orderInfoService.autoCancelOrder(Long.parseLong(id)); |
| | |
| | | @RabbitListener(queues = QueueConstants.ORDER_RETURN_MONEY) |
| | | public void orderReturnMoney(String orderId) { |
| | | log.info("收到订单返利消息:{}", orderId); |
| | | |
| | | try { |
| | | memberProfitService.dynamicProfit(Long.parseLong(orderId)); |
| | | } catch (Exception e) { |
| | | log.error("订单返利异常:{}", e); |
| | | log.error("订单返利异常:", e); |
| | | } |
| | | } |
| | | } |