fix
Helius
2022-09-15 6fea763316bd2b8d722ac59e5eea53f2e34412d0
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -17,6 +17,7 @@
import cc.mrbird.febs.job.SystemTradeJob;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
@@ -62,6 +63,7 @@
    private final DappMemberBoxRecordMapper dappMemberBoxRecordMapper;
    private final DappWalletCoinDao dappWalletCoinDao;
    private final DappSdeWithdrawFeeDao dappSdeWithdrawFeeDao;
    private final DappPriceRecordDao dappPriceRecordDao;
    @Override
@@ -80,6 +82,7 @@
//        int count = nftCount == null ? 0 : nftCount.intValue();
        result.put("cardCnt", 1000);
        result.put("nftPrice", AppContants.NFT_ACTIVE_PRICE);
        result.put("rewardPool", ChainService.getInstance(ChainEnum.BSC_TFC.name()).balanceOf(ChainEnum.BSC_TFC_REWARD.getAddress()));
        return result;
    }
@@ -144,12 +147,9 @@
        Object o = redisUtils.get(AppContants.REDIS_KEY_COIN_REMAIN + member.getAddress());
        BigDecimal minLimit = new BigDecimal(50);
        BigDecimal coinTotal;
        if (balance.compareTo(minLimit) > 0) {
        BigDecimal coinTotal = balance;
        if (this.hasProfit(member.getAddress())) {
            coinTotal = balance.multiply(BigDecimal.valueOf(0.3)).setScale(instance.decimals(), RoundingMode.HALF_DOWN);
        } else {
            coinTotal = new BigDecimal(50);
        }
        BigDecimal remain;
@@ -743,7 +743,7 @@
            // 源池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);
            return usdtBalance.divide(tfcBalance, tfcInstance.decimals(), RoundingMode.HALF_UP);
        } else {
            return new BigDecimal("0.05");
        }
@@ -891,9 +891,6 @@
        return cardCntMap;
    }
    @Autowired
    private DappPriceRecordDao dappPriceRecordDao;
    @Override
    public void tfcNewPrice() {
        BigDecimal newPrice = newestPrice();
@@ -918,4 +915,14 @@
        // 给影子生态发送价格
        chainProducer.sendTfcNewPrice(newPrice.toPlainString());
    }
    @Override
    public List<DappPriceRecordEntity> findPriceListIn24H() {
        DateTime startTime = DateUtil.offset(new Date(), DateField.HOUR, -24);
        List<DappPriceRecordEntity> list = dappPriceRecordDao.selectPriceListInStartTimeAndEndTime(startTime, new Date());
        list.forEach(item -> {
            item.setTime(DateUtil.format(item.getCreateTime(), "HH:mm"));
        });
        return list;
    }
}