src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -120,4 +120,25 @@ } } @RabbitListener(queues = QueueConstants.QUEUE_FCM_ORDER_BUY_CANCEL) public void fcmOrderBuyCancelMsg(Long buyRecordId) { log.info("收到买单取消确认:{}",buyRecordId); try { memberProfitService.fcmOrderBuyCancelMsg(buyRecordId); } catch (Exception e) { log.error("收到买单取消确认异常", e); // todo 更新表 } } @RabbitListener(queues = QueueConstants.QUEUE_FCMPAY_BUY_TIME) public void fcmPayBuyTimeTTLMsg(Long id) { try { orderInfoService.fcmPayBuyTimeTTLMsg(id); } catch (Exception e) { log.error("订单待收款异常", e); } } }