| | |
| | | BigDecimal newestPrice(); |
| | | |
| | | boolean hasProfit(String address); |
| | | |
| | | void sdmWithdrawFee(String data); |
| | | } |
| | |
| | | |
| | | return true; |
| | | } |
| | | |
| | | @Override |
| | | public void sdmWithdrawFee(String data) { |
| | | |
| | | } |
| | | } |
| | |
| | | public static final String DISTRIB_PROFIT = "queue_tfc_distrib_profit"; |
| | | public static final String USER_BUY_REWARD = "queue_tfc_user_buy_reward"; |
| | | public static final String NFT_BOX = "queue_tfc_nft_box"; |
| | | public static final String WITHDRAW_FEE = "queue_withdraw_fee"; |
| | | } |
| | |
| | | ONLINE_TRANSFER("exchange_online_transfer", "route_key_online_transfer", "queue_tfc_online_transfer"), |
| | | DISTRIB_PROFIT("exchange_distrib_profit", "route_key_distrib_profit", "queue_tfc_distrib_profit"), |
| | | USER_BUY_REWARD("exchange_user_buy_reward", "route_key_user_buy_reward", "queue_tfc_user_buy_reward"), |
| | | NFT_BOX("exchange_nft_box", "route_key_nft_box", "queue_tfc_nft_box"); |
| | | NFT_BOX("exchange_nft_box", "route_key_nft_box", "queue_tfc_nft_box"), |
| | | WITHDRAW_FEE("exchange_withdraw_fee", "route_key_withdraw_fee", "queue_withdraw_fee"); |
| | | |
| | | private String exchange; |
| | | |
| | |
| | | return BindingBuilder.bind(nftBoxQueue()).to(nftBoxExchange()).with(QueueEnum.NFT_BOX.getRoute()); |
| | | } |
| | | // === nft卡牌盲盒 end === |
| | | |
| | | // === 提现手续费 start === |
| | | @Bean |
| | | public DirectExchange withdrawFeeExchange() { |
| | | return new DirectExchange(QueueEnum.WITHDRAW_FEE.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue withdrawFeeQueue() { |
| | | return new Queue(QueueEnum.WITHDRAW_FEE.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding withdrawFeeBind() { |
| | | return BindingBuilder.bind(withdrawFeeQueue()).to(withdrawFeeExchange()).with(QueueEnum.WITHDRAW_FEE.getRoute()); |
| | | } |
| | | // === 提现手续费 end === |
| | | } |
| | |
| | | log.info("收到nft盲盒消息:{}", id); |
| | | dappSystemService.boxCnt(Long.parseLong(id)); |
| | | } |
| | | |
| | | /** |
| | | * 生产者在影子生态(矩阵)项目 |
| | | * @param data |
| | | */ |
| | | @RabbitListener(queues = QueueConstants.WITHDRAW_FEE) |
| | | public void withdrawFeeMsg(String data) { |
| | | log.info("收到影子生态手续费消息:{}", data); |
| | | } |
| | | } |