src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -19,7 +19,7 @@ * @date 2021-09-25 **/ @Slf4j //@Component @Component public class AgentConsumer { @Autowired @@ -58,4 +58,14 @@ } } @RabbitListener(queues = QueueConstants.ORDER_BONUS) public void calOrderBonus(String orderId) { log.info("收到订单分红消息:{}", orderId); try { memberProfitService.orderBonus(Long.parseLong(orderId)); } catch (Exception e) { log.error("订单分红消息异常:", e); } } }