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