| | |
| | | log.info("消费者:{}", new String(message.getBody())); |
| | | } |
| | | |
| | | @RabbitListener(queues = "hlm_queue_order_delay") |
| | | @RabbitListener(queues = "meye_queue_order_delay") |
| | | public void orderCancelDelay(String id) { |
| | | try { |
| | | orderInfoService.autoCancelOrder(Long.parseLong(id)); |
| | |
| | | |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.FORCE_VOUCHER_SALE) |
| | | public void forceVoucherSaleConsumer(String price) { |
| | | log.info("收到强制卖出消息,价格:{}",price); |
| | | try { |
| | | memberProfitService.selaHalfVoucher(price); |
| | | } catch (Exception e) { |
| | | log.error("强制卖出异常", e); |
| | | // todo 更新表 |
| | | |
| | | } |
| | | } |
| | | } |