wzy
2022-08-27 fb6c882e19ea2d5a7d6ee6bbb7664bdb8b2f2503
add sdm withdraw fee
6 files modified
37 ■■■■■ changed files
src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java 2 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java 5 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java 1 ●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java 3 ●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java 17 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java 9 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java
@@ -55,4 +55,6 @@
    BigDecimal newestPrice();
    boolean hasProfit(String address);
    void sdmWithdrawFee(String data);
}
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -730,4 +730,9 @@
        return true;
    }
    @Override
    public void sdmWithdrawFee(String data) {
    }
}
src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java
@@ -10,4 +10,5 @@
    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";
}
src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java
@@ -9,7 +9,8 @@
    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;
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
@@ -93,4 +93,21 @@
        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 ===
}
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -45,4 +45,13 @@
        log.info("收到nft盲盒消息:{}", id);
        dappSystemService.boxCnt(Long.parseLong(id));
    }
    /**
     * 生产者在影子生态(矩阵)项目
     * @param data
     */
    @RabbitListener(queues = QueueConstants.WITHDRAW_FEE)
    public void withdrawFeeMsg(String data) {
        log.info("收到影子生态手续费消息:{}", data);
    }
}