| | |
| | | @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT) |
| | | public void distrbProfit(String id) { |
| | | log.info("收到滑点分配消息:{}", id); |
| | | dappSystemService.tradeProfitDistribute(Long.parseLong(id)); |
| | | dappSystemService.tradeNftProfitDistribute(Long.parseLong(id)); |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.USER_BUY_REWARD) |
| | |
| | | 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)); |
| | | } |
| | | } |