From 276e8657ea8499cc87db1dd9abcbb105e48c2d3b Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 13 Jul 2022 15:44:33 +0800
Subject: [PATCH] fix

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java |   14 +++-----------
 1 files changed, 3 insertions(+), 11 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
index 806f0fc..5743c8b 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
@@ -5,10 +5,7 @@
 import cc.mrbird.febs.common.utils.ShareCodeUtil;
 import cc.mrbird.febs.dapp.chain.*;
 import cc.mrbird.febs.dapp.entity.*;
-import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
-import cc.mrbird.febs.dapp.mapper.DappMemberDao;
-import cc.mrbird.febs.dapp.mapper.DappOnlineTransferDao;
-import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
+import cc.mrbird.febs.dapp.mapper.*;
 import cc.mrbird.febs.dapp.service.DappMemberService;
 import cc.mrbird.febs.dapp.service.DappSystemService;
 import cc.mrbird.febs.dapp.utils.OnlineTransferUtil;
@@ -44,12 +41,10 @@
 
     @Resource
     private ChainProducer chainProducer;
-
     @Resource
     private DappOnlineTransferDao dappOnlineTransferDao;
     @Resource
     private DataDictionaryCustomMapper dataDictionaryCustomMapper;
-
     @Autowired
     private DappSystemService dappSystemService;
 
@@ -84,8 +79,6 @@
                 return;
             }
 
-            String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
-
             BigInteger tokens = e.tokens;
             BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);
 
@@ -105,7 +98,7 @@
                 boolean hasFlow = false;
                 for (DappFundFlowEntity flow : flows) {
                     if (flow.getStatus() == 1) {
-                        if (amount.compareTo(flow.getAmount().multiply(flow.getNewestPrice()).setScale(4, RoundingMode.HALF_UP)) == 0) {
+                        if (amount.compareTo(flow.getAmount()) == 0) {
                             hasFlow = true;
                             fundFlow = flow;
                             fundFlow.setFromHash(e.log.getTransactionHash());
@@ -127,8 +120,7 @@
             fundFlow.setTargetAmount(amount);
             dappFundFlowDao.updateById(fundFlow);
 
-            // 查找直推,并判断自身是否大于50,若大于50则,上级推荐则+1
-
+            dappSystemService.idoBuy(fromMember, amount);
         }
     }
 }

--
Gitblit v1.9.1