| | |
| | | log.info("收到链上转账消息:{}", batchNo); |
| | | dappSystemService.onlineTransfer(batchNo); |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT) |
| | | public void distrbProfit(String id) { |
| | | log.info("收到滑点分配消息:{}", id); |
| | | dappSystemService.tradeNftProfitDistribute(Long.parseLong(id)); |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.USER_BUY_REWARD) |
| | | public void userBuyReward(String id) { |
| | | log.info("收到用户购买奖励消息:{}", id); |
| | | dappSystemService.userBuyReward(Long.parseLong(id)); |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.NFT_BOX) |
| | | public void nftBox(String id) { |
| | | log.info("收到nft盲盒消息:{}", id); |
| | | dappSystemService.boxCnt(Long.parseLong(id)); |
| | | } |
| | | } |