fix

Helius

2022-08-31 db8be7ac334e1297dcfc3111b926a598bf750002

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

@@ -292,6 +292,7 @@
        Map<String, Integer> cardCntMap = nfcCardMap();

        ContractChainService instance = ChainService.getInstance(ChainEnum.BSC_TFC.name());
        int decimals = instance.decimals();
        if (fundFlow.getType() == 1) {
            BigDecimal totalBalance = BigDecimal.ZERO;

@@ -307,62 +308,62 @@
            balanceMap.forEach((key, value) -> {
                DappMemberEntity member = dappMemberDao.selectByAddress(key, "BSC");

                BigDecimal rate = value.divide(finalTotalBalance, 2, RoundingMode.HALF_UP);
                BigDecimal rate = value.divide(finalTotalBalance, decimals, RoundingMode.HALF_UP);
                BigDecimal memberProfit = fundFlow.getFee().multiply(rate);
                DappFundFlowEntity distribFlow = new DappFundFlowEntity(member.getId(), memberProfit, 4, 2, BigDecimal.ZERO);
                dappFundFlowDao.insert(distribFlow);

                OnlineTransferUtil.addTransfer(key, memberProfit, 4, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
                if (memberProfit.compareTo(BigDecimal.ZERO) == 0) {
                    return;
                }

                DappSdeWithdrawFeeEntity sdeWithdrawFee = new DappSdeWithdrawFeeEntity(member.getId(), member.getAddress(), memberProfit, fundFlow.getId(), ChainEnum.BSC_TFC_SOURCE.name());
                dappSdeWithdrawFeeDao.insert(sdeWithdrawFee);
//                DappFundFlowEntity distribFlow = new DappFundFlowEntity(member.getId(), memberProfit, 4, 2, BigDecimal.ZERO);
//                dappFundFlowDao.insert(distribFlow);
//                OnlineTransferUtil.addTransfer(key, memberProfit, 4, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
            });

        } else if (fundFlow.getType() == 2) {
            BigDecimal destroyAmount = fundFlow.getFee().multiply(new BigDecimal("2").divide(new BigDecimal("7"), instance.decimals(), RoundingMode.HALF_UP));
            // 销毁
            OnlineTransferUtil.addTransfer(AppContants.DESTROY_ADDRESS, destroyAmount, fundFlow.getType(), 3, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
//            OnlineTransferUtil.addTransfer(AppContants.DESTROY_ADDRESS, destroyAmount, fundFlow.getType(), 3, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
            DappSdeWithdrawFeeEntity destroy = new DappSdeWithdrawFeeEntity(null, AppContants.DESTROY_ADDRESS, destroyAmount, fundFlow.getId(), ChainEnum.BSC_TFC_SOURCE.name());
            dappSdeWithdrawFeeDao.insert(destroy);

            BigDecimal remain = fundFlow.getFee().subtract(destroyAmount);
            BigDecimal preNftAmount = remain.divide(new BigDecimal(5000), 2, RoundingMode.HALF_UP);
            BigDecimal preNftAmount = remain.divide(new BigDecimal(5000), decimals, RoundingMode.HALF_UP);

            BigDecimal total = BigDecimal.ZERO;
            for (Map.Entry<String, Integer> entry : cardCntMap.entrySet()) {
                DappMemberEntity member = dappMemberDao.selectByAddress(entry.getKey(), "BSC");
                BigDecimal profit = new BigDecimal(entry.getValue()).multiply(preNftAmount);
                if (profit.compareTo(BigDecimal.ZERO) == 0) {
                    return;
                }

                DappFundFlowEntity distribFlow = new DappFundFlowEntity(member.getId(), profit, 4, 2, BigDecimal.ZERO);
                dappFundFlowDao.insert(distribFlow);
                OnlineTransferUtil.addTransfer(entry.getKey(), profit, 4, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
//                DappFundFlowEntity distribFlow = new DappFundFlowEntity(member.getId(), profit, 4, 2, BigDecimal.ZERO);
//                dappFundFlowDao.insert(distribFlow);
//                OnlineTransferUtil.addTransfer(entry.getKey(), profit, 4, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);

                DappSdeWithdrawFeeEntity sdeWithdrawFee = new DappSdeWithdrawFeeEntity(member.getId(), member.getAddress(), profit, fundFlow.getId(), ChainEnum.BSC_TFC_SOURCE.name());
                dappSdeWithdrawFeeDao.insert(sdeWithdrawFee);

                total = total.add(profit);
            }
            ;

            if (remain.subtract(total).compareTo(BigDecimal.ZERO) > 0) {
                OnlineTransferUtil.addTransfer(ChainEnum.BSC_TFC_FEE.getAddress(), remain.subtract(total), 4, 3, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
                DappSdeWithdrawFeeEntity sdeWithdrawFee = new DappSdeWithdrawFeeEntity(null, ChainEnum.BSC_TFC_FEE.getAddress(), remain.subtract(total), fundFlow.getId(), ChainEnum.BSC_TFC_SOURCE.name());
                dappSdeWithdrawFeeDao.insert(sdeWithdrawFee);
//                OnlineTransferUtil.addTransfer(ChainEnum.BSC_TFC_FEE.getAddress(), remain.subtract(total), 4, 3, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo);
            }

        } else {
            return;
        }

        Map<String, String> map = new HashMap<>();
        map.put("batchNo", batchNo);

        // 发送转账消息
        chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
//        Map<String, String> map = new HashMap<>();
//        map.put("batchNo", batchNo);
//        // 发送转账消息
//        chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
    }

//    public static void main(String[] args) throws IOException {
//        Document parse = Jsoup.parse(new URL("https://bscscan.com/token/generic-tokenholders2?a=0x03c7d3f141c5f03971604958170e253362e13be6"), 10000000);
//
//        Elements tbodys = parse.getElementsByTag("tbody");
//
//        Element tbody = tbodys.get(0);
//
//        Elements elements = tbody.getElementsMatchingOwnText("^0x.*$");
//
//        String text = elements.get(0).text();
//        System.out.println(1111);
//    }

    @Override
    public void mining() {
@@ -399,7 +400,6 @@
        if (CollUtil.isEmpty(allMembers)) {
            return;
        }
        DataDictionaryCustom miniHoldCoin = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_MINI_HOLD_COIN_LIMIT);

        String batchNo = RandomUtil.randomString(32);
        ContractChainService instance = ChainService.getInstance(ChainEnum.BSC_TFC.name());
@@ -409,7 +409,9 @@
            }

            BigDecimal balance = instance.balanceOf(member.getAddress());
            if (balance.compareTo(new BigDecimal(miniHoldCoin.getValue())) < 1) {

            // 判断用户是否满足持币价值达80U
            if (!hasProfit(member.getAddress())) {
                continue;
            }

@@ -498,35 +500,44 @@
        }

        DappFundFlowEntity fundFlow = dappFundFlowDao.selectById(id);

        DappMemberEntity member = dappMemberDao.selectById(fundFlow.getMemberId());
        DappMemberEntity referer = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
        if (referer == null || "admin".equals(referer.getAccountType())) {
            return;

        int i = 1;
        boolean flag = true;
        while (flag) {
            member = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
            if (member == null || "admin".equals(member.getAccountType())) {
                return;
            }

            if (!hasProfit(member.getAddress())) {
                return;
            }

            DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_USER_BUY_REWARD);
            BigDecimal prop = new BigDecimal(dic.getValue()).divide(new BigDecimal("100"), 2, RoundingMode.HALF_UP);
            BigDecimal reward = fundFlow.getAmount().multiply(prop);

            BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_TFC_REWARD.name()).balanceOf(ChainEnum.BSC_TFC_REWARD.getAddress());
            if (balance.compareTo(reward) < 1) {
                return;
            }

            DappFundFlowEntity rewardFlow = new DappFundFlowEntity(member.getId(), reward, 4, 2, BigDecimal.ZERO);
            dappFundFlowDao.insert(rewardFlow);

            OnlineTransferUtil.addTransfer(member.getAddress(), reward, 4, 1, ChainEnum.BSC_TFC_REWARD.name(), AppContants.SYMBOL_COIN, rewardFlow.getId().toString());

            Map<String, String> map = new HashMap<>();
            map.put("batchNo", rewardFlow.getId().toString());
            map.put("type", "flow");
            chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));

            i++;
            if (i > 2) {
                flag = false;
            }
        }

        if (!hasProfit(referer.getAddress())) {
            return;
        }

        DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_USER_BUY_REWARD);
        BigDecimal prop = new BigDecimal(dic.getValue()).divide(new BigDecimal("100"), 2, RoundingMode.HALF_UP);
        BigDecimal reward = fundFlow.getAmount().multiply(prop);

        BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_TFC_REWARD.name()).balanceOf(ChainEnum.BSC_TFC_REWARD.getAddress());
        if (balance.compareTo(reward) < 1) {
            return;
        }

        DappFundFlowEntity rewardFlow = new DappFundFlowEntity(referer.getId(), reward, 4, 2, BigDecimal.ZERO);
        dappFundFlowDao.insert(rewardFlow);

        OnlineTransferUtil.addTransfer(referer.getAddress(), reward, 4, 1, ChainEnum.BSC_TFC_REWARD.name(), AppContants.SYMBOL_COIN, rewardFlow.getId().toString());

        Map<String, String> map = new HashMap<>();
        map.put("batchNo", rewardFlow.getId().toString());
        map.put("type", "batch");
        chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
    }


@@ -534,15 +545,15 @@
    public void startSystem() {
        log.info("启动系统");

        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                transferPoolSetting();
                sourcePoolUsdtOutLimitSetting();
            }
        });
//        Thread thread = new Thread(new Runnable() {
//            @Override
//            public void run() {
//            }
//        });

        thread.start();
        transferPoolSetting();
        sourcePoolUsdtOutLimitSetting();
//        thread.start();
    }

    // 最低容量(百分比)
@@ -640,14 +651,7 @@
            lastDayPrice = new BigDecimal(dailyPrice);
        }

        ContractChainService tfcInstance = ChainService.getInstance(ChainEnum.BSC_TFC_SOURCE.name());
        // 源池币种数量
        BigDecimal tfcBalance = tfcInstance.balanceOf(ChainEnum.BSC_TFC_SOURCE.getAddress());

        // 源池USDT数量
        BigDecimal usdtBalance = ChainService.getInstance(ChainEnum.BSC_USDT_SOURCE.name()).balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());

        BigDecimal todayPrice = tfcBalance.divide(usdtBalance, tfcInstance.decimals(), RoundingMode.HALF_UP);
        BigDecimal todayPrice = newestPrice();

        DappSymbolDailyPriceEntity dailyPriceEntity = new DappSymbolDailyPriceEntity();
        dailyPriceEntity.setPrice(todayPrice);
@@ -732,8 +736,14 @@
    @Override
    public BigDecimal newestPrice() {
        if (systemHasStart()) {
            String dailyPrice = redisUtils.getString(AppContants.REDIS_KEY_SYMBOL_DAILY_PRICE);
            return StrUtil.isNotBlank(dailyPrice) ? new BigDecimal(dailyPrice) : BigDecimal.ZERO;
            ContractChainService tfcInstance = ChainService.getInstance(ChainEnum.BSC_TFC_SOURCE.name());
            // 源池币种数量
            BigDecimal tfcBalance = tfcInstance.balanceOf(ChainEnum.BSC_TFC_SOURCE.getAddress());

            // 源池USDT数量
            BigDecimal usdtBalance = ChainService.getInstance(ChainEnum.BSC_USDT_SOURCE.name()).balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());

            return tfcBalance.divide(usdtBalance, tfcInstance.decimals(), RoundingMode.HALF_UP);
        } else {
            return new BigDecimal("0.05");
        }
@@ -785,12 +795,12 @@
                    continue;
                }

                DappSdeWithdrawFeeEntity sdeWithdrawFee = new DappSdeWithdrawFeeEntity(member.getId(), member.getAddress(), amount, Long.parseLong(flowId));
                DappSdeWithdrawFeeEntity sdeWithdrawFee = new DappSdeWithdrawFeeEntity(member.getId(), member.getAddress(), amount, Long.parseLong(flowId), ChainEnum.BSC_TFC_FEE.name());
                dappSdeWithdrawFeeDao.insert(sdeWithdrawFee);
            }
        }

        DappSdeWithdrawFeeEntity destroyFee = new DappSdeWithdrawFeeEntity(null, AppContants.DESTROY_ADDRESS, destroy, Long.parseLong(flowId));
        DappSdeWithdrawFeeEntity destroyFee = new DappSdeWithdrawFeeEntity(null, AppContants.DESTROY_ADDRESS, destroy, Long.parseLong(flowId), ChainEnum.BSC_TFC_FEE.name());
        dappSdeWithdrawFeeDao.insert(destroyFee);
    }
//    @Override
@@ -843,7 +853,7 @@

        String batchNo = RandomUtil.randomString(16);
        list.forEach(item -> {
            if (!AppContants.DESTROY_ADDRESS.equals(item.getAddress())) {
            if (item.getMemberId() != null) {
                DappMemberEntity member = dappMemberDao.selectByAddress(item.getAddress(), "BSC");
                if (member == null) {
                    return;
@@ -853,7 +863,7 @@
                dappFundFlowDao.insert(fundFlow);
            }

            OnlineTransferUtil.addTransfer(item.getAddress(), item.getAmount(), 5, 1, ChainEnum.BSC_TFC_FEE.name(), AppContants.SYMBOL_COIN, batchNo);
            OnlineTransferUtil.addTransfer(item.getAddress(), item.getAmount(), 5, 1, item.getOutAddressName(), AppContants.SYMBOL_COIN, batchNo);
        });
        dappSdeWithdrawFeeDao.updateHasReturnToFinish();

@@ -881,21 +891,31 @@
        return cardCntMap;
    }

    @Autowired
    private DappPriceRecordDao dappPriceRecordDao;

    @Override
    public void tfcNewPrice() {
        BigDecimal newPrice;
        if (!systemHasStart()) {
            newPrice = new BigDecimal("0.05");
        } else {
            ContractChainService tfcInstance = ChainService.getInstance(ChainEnum.BSC_TFC.name());
            // u剩余数量
            BigDecimal sourceU = ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
            // 源池代币剩余数量
            BigDecimal sourceCoin = tfcInstance.balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
        BigDecimal newPrice = newestPrice();
//        if (!systemHasStart()) {
//            newPrice = new BigDecimal("0.05");
//        } else {
//            ContractChainService tfcInstance = ChainService.getInstance(ChainEnum.BSC_TFC.name());
//            // u剩余数量
//            BigDecimal sourceU = ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
//            // 源池代币剩余数量
//            BigDecimal sourceCoin = tfcInstance.balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
//
//            newPrice = sourceU.divide(sourceCoin, tfcInstance.decimals(), RoundingMode.HALF_UP);
//        }

            newPrice = sourceU.divide(sourceCoin, tfcInstance.decimals(), RoundingMode.HALF_UP);
        }
        DappPriceRecordEntity dappPriceRecord = new DappPriceRecordEntity();
        dappPriceRecord.setPrice(newPrice);
        dappPriceRecord.setCreateTime(new Date());
        dappPriceRecord.setTimestamp(System.currentTimeMillis());
        dappPriceRecordDao.insert(dappPriceRecord);

        // 给影子生态发送价格
        chainProducer.sendTfcNewPrice(newPrice.toPlainString());
    }
}