From 4a1e4abf6ed1deafdb293d3aa85d099ef5c63a1a Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 14 Jun 2022 11:28:23 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 41 ++++++++++++++++++++++++++++++++++++++--- 1 files changed, 38 insertions(+), 3 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java index 612a694..6ad55bb 100644 --- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java @@ -116,7 +116,14 @@ Object o = redisUtils.get(AppContants.REDIS_KEY_COIN_REMAIN + member.getAddress()); - BigDecimal coinTotal = balance.multiply(BigDecimal.valueOf(0.3)).setScale(instance.decimals(), RoundingMode.HALF_DOWN); + BigDecimal minLimit = new BigDecimal(50); + BigDecimal coinTotal; + if (balance.compareTo(minLimit) > 0) { + coinTotal = balance.multiply(BigDecimal.valueOf(0.3)).setScale(instance.decimals(), RoundingMode.HALF_DOWN); + } else { + coinTotal = new BigDecimal(50); + } + BigDecimal remain; if (o == null) { DateTime tomorrow = DateUtil.beginOfDay(DateUtil.tomorrow()); @@ -196,7 +203,6 @@ } BigDecimal total = distrbAmount.multiply(new BigDecimal(distribDic.getValue()).divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP)); - OnlineTransferUtil.addTransfer(parent.getAddress(), total, fundflow.getType(), 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo); DappFundFlowEntity distribFlow = new DappFundFlowEntity(parent.getId(), total, 4, 2, BigDecimal.ZERO); @@ -207,9 +213,38 @@ } } + // 铸池滑点金额 + BigDecimal makerAmount = distrbAmount.multiply(slipSetting.getMakeProp().divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP)); + log.info("铸池滑点金额:{}", makerAmount); + if (makerAmount.compareTo(BigDecimal.ZERO) > 0) { + List<DappMemberEntity> makerAddress = dappMemberDao.selectMakerAddress(); + if (CollUtil.isNotEmpty(makerAddress)) { + BigDecimal totalMaker = BigDecimal.ZERO; + Map<String, BigDecimal> map = new HashMap<>(); + Map<String, Long> addressAndId = new HashMap<>(); + for (DappMemberEntity maker : makerAddress) { + BigDecimal balance = instance.balanceOf(maker.getAddress()); + map.put(maker.getAddress(), balance); + addressAndId.put(maker.getAddress(), maker.getId()); + + totalMaker = totalMaker.add(balance); + } + + for (Map.Entry<String, BigDecimal> entry : map.entrySet()) { + BigDecimal target = makerAmount.multiply(entry.getValue().divide(totalMaker, 2, RoundingMode.HALF_UP)); + + OnlineTransferUtil.addTransfer(entry.getKey(), target, fundflow.getType(), 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo); + + DappFundFlowEntity distribFlow = new DappFundFlowEntity(addressAndId.get(entry.getKey()), target, 4, 2, BigDecimal.ZERO); + dappFundFlowDao.insert(distribFlow); + } + } + } + + // 若节点金额还有剩余,则进入技术金额 techAmount = techAmount.add(nodeAmount); - OnlineTransferUtil.addTransfer(ChainEnum.BSC_TFC_TECH.getAddress(), techAmount, fundflow.getType(), 2, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo); + OnlineTransferUtil.addTransfer(ChainEnum.BSC_TFC_TECH.getAddress(), techAmount, fundflow.getType(), 3, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, batchNo); Map<String, String> map = new HashMap<>(); map.put("batchNo", batchNo); -- Gitblit v1.9.1