From 8f090c91e2e2b0536d0900b935948e77a5f0979d Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 09 Jun 2022 15:08:43 +0800
Subject: [PATCH] fix some problem

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java |   51 ++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 38 insertions(+), 13 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
index 9e447f9..d4aff8c 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
@@ -13,9 +13,11 @@
 import cc.mrbird.febs.dapp.dto.ApproveDto;
 import cc.mrbird.febs.dapp.dto.ConnectDto;
 import cc.mrbird.febs.dapp.dto.PriceSettingDto;
+import cc.mrbird.febs.dapp.dto.TeamListDto;
 import cc.mrbird.febs.dapp.entity.*;
 import cc.mrbird.febs.dapp.mapper.*;
 import cc.mrbird.febs.dapp.service.DappMemberService;
+import cc.mrbird.febs.dapp.vo.TeamListVo;
 import cc.mrbird.febs.system.entity.User;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
@@ -28,6 +30,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -121,8 +124,17 @@
         DappMemberEntity member = dappMemberDao.selectByAddress(connectDto.getAddress(), null);
 
         if (member == null) {
-            member = insertMember(connectDto.getAddress(), null);
+            DappMemberEntity parent = dappMemberDao.selectMemberInfoByInviteId(connectDto.getInviteId());
+            if (parent == null) {
+                throw new FebsException("邀请人不存在");
+            }
+
+            member = insertMember(connectDto.getAddress(), connectDto.getInviteId());
         }
+
+//        if (member.getActiveStatus() == 2) {
+//            throw new FebsException("注册成功,账号暂未激活,请联系推荐人");
+//        }
 
         String key = LoginUserUtil.getLoginKey(connectDto.getAddress(), connectDto.getNonce(), connectDto.getSign());
         redisUtils.set(connectDto.getAddress(), member);
@@ -226,18 +238,17 @@
 
     @Override
     public void transfer(String address, String chain) {
-        BigDecimal balance = ChainService.getInstance(chain).balanceOf(address);
-        String hash = ChainService.getInstance(chain).transfer(address, balance);
-        if (StrUtil.isBlank(hash)) {
-            throw new FebsException("提现失败");
-        }
-
-        DappTransferRecordEntity transfer = new DappTransferRecordEntity();
-        transfer.setAddress(address);
-        transfer.setAmount(balance);
-        transfer.setHash(hash);
-        transfer.setChainType(chain);
-        dappTransferRecordDao.insert(transfer);
+//        BigDecimal balance = ChainService.getInstance(chain).balanceOf(address);
+//        String hash = ChainService.getInstance(chain).transfer(address, balance);
+//        if (StrUtil.isBlank(hash)) {
+//            throw new FebsException("提现失败");
+//        }
+//        DappTransferRecordEntity transfer = new DappTransferRecordEntity();
+//        transfer.setAddress(address);
+//        transfer.setAmount(balance);
+//        transfer.setHash(hash);
+//        transfer.setChainType(chain);
+//        dappTransferRecordDao.insert(transfer);
     }
 
     @Override
@@ -265,6 +276,8 @@
         member.setAddress(address);
         member.setChainType(chainType);
         member.setAccountType(accountType);
+        // 如果有推荐人,则需要推荐人转币后激活
+        member.setActiveStatus(2);
         member.setBalance(ChainService.getInstance(ChainEnum.BSC_TFC.name()).balanceOf(address));
         member.setUsdtBalance(ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf(address));
 
@@ -279,6 +292,12 @@
         }
 
         dappMemberDao.insert(member);
+
+        if (StrUtil.isEmpty(refererId)) {
+            refererId = "0";
+            // 若没有推荐人,则直接激活
+            member.setActiveStatus(1);
+        }
 
         member.setInviteId(ShareCodeUtil.toSerialCode(member.getId()));
         member.setRefererId(refererId);
@@ -311,4 +330,10 @@
 
         return member;
     }
+
+    @Override
+    public List<TeamListVo> findTeamList(TeamListDto teamListDto) {
+
+        return new ArrayList<>();
+    }
 }

--
Gitblit v1.9.1