src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -72,4 +72,16 @@ log.error("订单返利异常:", e); } } @RabbitListener(queues = QueueConstants.PERK_MONEY) public void perkMoneyConsumer(String id) { log.info("收到补贴消息:{}", id); try { agentService.perkMoneyConsumer(Long.parseLong(id)); } catch (Exception e) { log.error("用户补贴异常", e); // todo 更新表 } } }