src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -96,4 +96,16 @@ } } @RabbitListener(queues = QueueConstants.QUEUE_FCM_NFT_EXCHANGE) public void fcmNFTExchangeMsg(String cnt) { log.info("收到FCM实时兑换销毁数量:{}",cnt); try { memberProfitService.fcmNFTExchangeMsg(cnt); } catch (Exception e) { log.error("强制卖出异常", e); // todo 更新表 } } }