twoCoin项目修改

xiaoyong931011

2023-06-08 52a7fcbe3f824dfc4cf8b0eedcb3a498f2618a56

twoCoin项目修改

 src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java

@@ -96,4 +96,6 @@
    void antKLineMsg(int type);

    void antKLineABMsg(Long id);

    void allMemberPerkAvaMsg(Long id);
}

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java

@@ -836,18 +836,19 @@
        /**
         * 20%全网加权平分，按照个人投资占比全网的比例去平分
         */
        BigDecimal poolAllMemberAPercentCntAva = allMemberPerk(poolAllMemberAPercentCnt, FundFlowEnum.POOL_MEMBER_A_CNT.getCode());
        DappFundFlowEntity poolAllMemberAFundFlowAva = new DappFundFlowEntity(
                294L,
                poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
                FundFlowEnum.POOL_MEMBER_A_CNT.getCode(),
                2,
                BigDecimal.ZERO,
                null,
                chergeRecordId);
        dappFundFlowDao.insert(poolAllMemberAFundFlowAva);
        dappWalletService.updateWalletMineWithLock(poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
                294L,1);
        chainProducer.sendAllMemberPerkAvaMsg(poolAllMemberAFundFlow.getId());
//        BigDecimal poolAllMemberAPercentCntAva = allMemberPerk(poolAllMemberAPercentCnt, FundFlowEnum.POOL_MEMBER_A_CNT.getCode());
//        DappFundFlowEntity poolAllMemberAFundFlowAva = new DappFundFlowEntity(
//                294L,
//                poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
//                FundFlowEnum.POOL_MEMBER_A_CNT.getCode(),
//                2,
//                BigDecimal.ZERO,
//                null,
//                chergeRecordId);
//        dappFundFlowDao.insert(poolAllMemberAFundFlowAva);
//        dappWalletService.updateWalletMineWithLock(poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
//                294L,1);

        /**
         * 10%直推
@@ -2062,6 +2063,29 @@

    }

    @Override
    public void allMemberPerkAvaMsg(Long id) {
        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id);
        if(ObjectUtil.isEmpty(dappFundFlowEntity)){
            return;
        }

        BigDecimal poolAllMemberAPercentCnt = dappFundFlowEntity.getAmount();
        BigDecimal poolAllMemberAPercentCntAva = allMemberPerk(poolAllMemberAPercentCnt, FundFlowEnum.POOL_MEMBER_A_CNT.getCode());
        DappFundFlowEntity poolAllMemberAFundFlowAva = new DappFundFlowEntity(
                294L,
                poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
                FundFlowEnum.POOL_MEMBER_A_CNT.getCode(),
                2,
                BigDecimal.ZERO,
                null,
                dappFundFlowEntity.getSystemProfitId());
        dappFundFlowDao.insert(poolAllMemberAFundFlowAva);
        dappWalletService.updateWalletMineWithLock(poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
                294L,1);

    }

    public static void main(String[] args) {
        System.out.println(ChainEnum.BSC_USDT_W_POOL.getAddress());
    }

 src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java

@@ -54,4 +54,8 @@
     * A k线数据
     */
    public static final String QUEUE_ANT_K_LINE_AB = "queue_ant_k_line_test_ab";
    /**
     * A k线数据
     */
    public static final String QUEUE_ALL_MEMBER_PERK_AVA = "queue_all_member_perk_ava";
}

 src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java

@@ -5,6 +5,8 @@

@Getter
public enum QueueEnum {
    //A 每人平分
    ALL_MEMBER_PERK_AVA("exchange_all_member_perk_ava", "route_key_all_member_perk_ava", QueueConstants.QUEUE_ALL_MEMBER_PERK_AVA),
    //A k线数据
    ANT_K_LINE_AB("exchange_ant_k_line_test_ab", "route_key_ant_k_line_test_ab", QueueConstants.QUEUE_ANT_K_LINE_AB),
    //A k线数据

 src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java

@@ -358,4 +358,22 @@
        return BindingBuilder.bind(antKLineABQueue()).to(antKLineABExchange()).with(QueueEnum.ANT_K_LINE_AB.getRoute());
    }
    // === A k线数据  end ===


    // === A k线数据  start ===
    @Bean
    public DirectExchange allMemberPerkAvaExchange() {
        return new DirectExchange(QueueEnum.ALL_MEMBER_PERK_AVA.getExchange());
    }

    @Bean
    public Queue allMemberPerkAvaQueue() {
        return new Queue(QueueEnum.ALL_MEMBER_PERK_AVA.getQueue());
    }

    @Bean
    public Binding allMemberPerkAvaBind() {
        return BindingBuilder.bind(allMemberPerkAvaQueue()).to(allMemberPerkAvaExchange()).with(QueueEnum.ALL_MEMBER_PERK_AVA.getRoute());
    }
    // === A k线数据  end ===
}

 src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java

@@ -179,4 +179,13 @@
        log.info("消费转账拨币第二步:{}", id);
        dappSystemService.antKLineABMsg(id);
    }

    /**转账拨币
     * @param id
     */
    @RabbitListener(queues = QueueConstants.QUEUE_ALL_MEMBER_PERK_AVA)
    public void allMemberPerkAvaMsg(Long id) {
        log.info("全体平分:{}", id);
        dappSystemService.allMemberPerkAvaMsg(id);
    }
}

 src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java

@@ -198,4 +198,13 @@
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.ANT_K_LINE_AB.getExchange(), QueueEnum.ANT_K_LINE_AB.getRoute(), id, correlationData);
    }

    /**
     * 转账拨币
     */
    public void sendAllMemberPerkAvaMsg(Long id) {
        log.info("开始全体平分:{}", id);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.ALL_MEMBER_PERK_AVA.getExchange(), QueueEnum.ALL_MEMBER_PERK_AVA.getRoute(), id, correlationData);
    }
}