From 4d0239bfc63f23d7999880808ee665dfd2dae8da Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 28 Mar 2024 16:02:51 +0800
Subject: [PATCH] 滑点

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java |   18 ++++++++----------
 1 files changed, 8 insertions(+), 10 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java
index 60988b2..08360d6 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java
@@ -95,22 +95,23 @@
                 BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_TFC.name()).balanceOf(e.from);
                 fromMember.setBalance(balance);
                 dappMemberService.updateById(fromMember);
+            } else {
+                fromMember = dappMemberService.insertMember(e.from, null);
             }
 
             BigInteger tokens = e.tokens;
-            BigDecimal amount = BigDecimal.valueOf(tokens.intValue()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);
+            BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);
 
-            // 如果转账对象地址不为源池地址,且对象地址在系统中存在并未激活,则激活用户
+            // 如果转账对象地址不为源池地址,注册该用户并绑定上下级关系
             if (!e.to.equals(ChainEnum.BSC_TFC_SOURCE.getAddress().toLowerCase())) {
                 DappMemberEntity toMember = dappMemberDao.selectByAddress(e.to, null);
                 if (toMember == null) {
-//                    toMember = dappMemberService.insertMember(e.to, fromMember.getInviteId());
-                    return;
+                    toMember = dappMemberService.insertMember(e.to, fromMember.getInviteId());
                 }
 
-                if (toMember.getActiveStatus() == 2) {
-                    toMember.setActiveStatus(1);
-                }
+//                if (toMember.getActiveStatus() == 2) {
+//                    toMember.setActiveStatus(1);
+//                }
                 // 更新余额
                 BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_TFC.name()).balanceOf(e.to);
                 toMember.setBalance(balance);
@@ -160,9 +161,6 @@
                 fundFlow.setStatus(2);
                 fundFlow.setTargetAmount(transferAmount);
                 dappFundFlowDao.updateById(fundFlow);
-
-                // 划点分配
-                chainProducer.sendDitribProfit(fundFlow.getId());
 
                 OnlineTransferUtil.addTransfer(e.from, transferAmount, fundFlow.getType(), 1, ChainEnum.BSC_USDT_SOURCE.name(), AppContants.SYMBOL_USDT, fundFlow.getId().toString());
 

--
Gitblit v1.9.1