From c54f0c60faae496e0fd989b281b776b69b65a87a Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Sat, 27 Aug 2022 22:29:30 +0800
Subject: [PATCH] finish sde

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java |  235 +++++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 173 insertions(+), 62 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 03de9eb..1d60942 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
@@ -5,29 +5,47 @@
 import cc.mrbird.febs.common.utils.RedisUtils;
 import cc.mrbird.febs.dapp.chain.ChainEnum;
 import cc.mrbird.febs.dapp.chain.ChainService;
+import cc.mrbird.febs.dapp.chain.ContractChainService;
 import cc.mrbird.febs.dapp.dto.SystemDto;
-import cc.mrbird.febs.dapp.entity.DappMemberEntity;
-import cc.mrbird.febs.dapp.entity.DappMineDataEntity;
-import cc.mrbird.febs.dapp.entity.DappReturnRatioEntity;
-import cc.mrbird.febs.dapp.mapper.DappReturnRatioDao;
-import cc.mrbird.febs.dapp.mapper.DappSystemDao;
+import cc.mrbird.febs.dapp.entity.*;
+import cc.mrbird.febs.dapp.enumerate.CardPeriod;
+import cc.mrbird.febs.dapp.mapper.*;
 import cc.mrbird.febs.dapp.service.DappSystemService;
+import cc.mrbird.febs.dapp.service.DappWalletService;
+import cc.mrbird.febs.dapp.utils.OnlineTransferUtil;
 import cc.mrbird.febs.dapp.vo.RedisTransferPoolVo;
+import cc.mrbird.febs.dapp.vo.SlipSettingVo;
+import cc.mrbird.febs.job.SystemTradeJob;
+import cc.mrbird.febs.rabbit.producer.ChainProducer;
+import cc.mrbird.febs.tree.MatrixTree;
+import cc.mrbird.febs.tree.MemberNode;
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUnit;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.RandomUtil;
 import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.jsoup.Jsoup;
+import org.jsoup.nodes.Document;
+import org.jsoup.nodes.Element;
+import org.jsoup.select.Elements;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
+import java.io.IOException;
 import java.math.BigDecimal;
+import java.math.BigInteger;
 import java.math.RoundingMode;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.*;
 
 /**
- * @author 
+ * @author
  * @date 2022-03-24
  **/
 @Slf4j
@@ -38,66 +56,159 @@
     private final DappSystemDao dappSystemDao;
     private final DappReturnRatioDao dappReturnRatioDao;
     private final RedisUtils redisUtils;
+    private final DappFundFlowDao dappFundFlowDao;
+    private final DappMemberDao dappMemberDao;
+    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
+    private final DappOnlineTransferDao dappOnlineTransferDao;
+    private final ChainProducer chainProducer;
+    private final DappSymbolDailyPriceMapper dappSymbolDailyPriceMapper;
+    private final DappMemberBoxRecordMapper dappMemberBoxRecordMapper;
+    private final DappWalletCoinDao dappWalletCoinDao;
 
-    private final String[] ADDRESS_PREFIX = {"T", "0x"};
-    @Override
-    public Map<String, Object> findTotalInComeAndList() {
-        DappMineDataEntity dataMine = dappSystemDao.selectMineDataForOne();
+    private final DappAchieveTreeDao dappAchieveTreeDao;
+    private final DappAchieveMemberTreeDao dappAchieveMemberTreeDao;
+    private final DappWalletService dappWalletService;
 
-
-        Map<String, Object> result = new HashMap<>();
-        result.put("total", 6000);
-        result.put("addreessCnt", 1234);
-        result.put("coinCnt", 4000);
-        return result;
-    }
-
-    @Override
-    public Map<String, Object> globalSetting() {
-        BigDecimal newPrice = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_ETH_NEW_PRICE);
-        Integer changeFee = (Integer) redisUtils.get(AppContants.REDIS_KEY_CHANGE_FEE);
-
-        List<DappReturnRatioEntity> ratios = dappReturnRatioDao.selectList(null);
-        Map<String, Object> result = new HashMap<>();
-        result.put("newPrice", newPrice);
-        result.put("changeFee", changeFee);
-        result.put("ratio", ratios);
-        return result;
-    }
 
     @Override
     public SystemDto system() {
         DappMemberEntity member = LoginUserUtil.getAppUser();
 
         SystemDto system = new SystemDto();
-
-        RedisTransferPoolVo transferPool = (RedisTransferPoolVo) redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL);
-        BigDecimal poolRemain = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN);
-        // 买币数量
-        system.setBuyTotal(transferPool.getTodayVol());
-        system.setBuyRemain(poolRemain);
-
-        BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_TFC.name()).balanceOf(member.getAddress());
-        Object o = redisUtils.get(AppContants.REDIS_KEY_USDT_OUT_LIMIT_REMAIN);
-        BigDecimal remain;
-        if (o == null) {
-            remain = balance.multiply(BigDecimal.valueOf(0.3));
-            redisUtils.set(AppContants.REDIS_KEY_USDT_OUT_LIMIT_REMAIN, remain);
-        } else {
-            remain = (BigDecimal) o;
-        }
-        // 卖币数量
-        system.setSaleTotal(balance.multiply(BigDecimal.valueOf(0.3)));
-        system.setSaleRemain(remain);
-
-        BigDecimal usdtRemain = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_USDT_OUT_LIMIT_REMAIN);
-        BigDecimal usdtTotal = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_USDT_OUT_LIMIT);
-
-        // usdt数量
-        system.setUsdtTotal(usdtTotal);
-        system.setUsdtRemain(usdtRemain);
-
-        system.setFeeRatio(BigDecimal.TEN);
+        system.setBuyAmount(new BigDecimal("100"));
         return system;
     }
+
+    // 最低容量(百分比)
+    private final BigDecimal volProp = new BigDecimal("2");
+    // 每日增/减百分比
+    private final BigDecimal changeProp = new BigDecimal("1");
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public synchronized void achieveTree(Long memberId) {
+        DappMemberEntity member = dappMemberDao.selectById(memberId);
+
+        // 在大树中,插入当前节点
+        DappAchieveTreeEntity achieveTree = new DappAchieveTreeEntity();
+        achieveTree.setMidNode(memberId);
+        achieveTree.setValidState(1);
+        dappAchieveTreeDao.insert(achieveTree);
+
+        // 在内存树(大树)中插入当前节点,并返回父节点
+        MemberNode node = new MemberNode(member.getId(), member.getAddress(), member.getInviteId(), member.getRefererId());
+        MatrixTree tree = MatrixTree.getInstance();
+        MemberNode parentNode = tree.addNode(node);
+
+        // 创建该节点的矩阵
+        DappAchieveMemberTreeEntity achieveMemberTree = new DappAchieveMemberTreeEntity();
+        achieveMemberTree.setTreeNode(memberId);
+        achieveMemberTree.setTopNode(memberId);
+        achieveMemberTree.setDeep(1);
+        achieveMemberTree.setHasMoney(1);
+        if (parentNode != null) {
+            achieveMemberTree.setParentNode(parentNode.getMemberId());
+        }
+        dappAchieveMemberTreeDao.insert(achieveMemberTree);
+
+        // 激活用户状态
+        member.setActiveStatus(1);
+        dappMemberDao.updateById(member);
+
+        putIntoProfit(memberId, 2);
+        if (parentNode == null) {
+            return;
+        }
+
+        // 修改父节点在数据库中的左/右节点数据
+        DappAchieveTreeEntity treeMidNode = dappAchieveTreeDao.selectByMidNode(parentNode.getMemberId());
+        boolean isLeft = false;
+        if (parentNode.getLeft() != null && memberId.equals(parentNode.getLeft().getMemberId())) {
+            treeMidNode.setLeftNode(memberId);
+            isLeft = true;
+        } else {
+            treeMidNode.setRightNode(memberId);
+        }
+        dappAchieveTreeDao.updateById(treeMidNode);
+
+        // 更新矩阵中的数据
+        List<DappAchieveMemberTreeEntity> matrixNodes = dappAchieveMemberTreeDao.selectNotBottomNodeInMatrix(parentNode.getMemberId());
+        for (DappAchieveMemberTreeEntity matrixNode : matrixNodes) {
+            if (isLeft) {
+                matrixNode.setLeftNode(memberId);
+            } else {
+                matrixNode.setRightNode(memberId);
+            }
+
+            dappAchieveMemberTreeDao.updateById(matrixNode);
+
+            DappAchieveMemberTreeEntity newMatrixNode = new DappAchieveMemberTreeEntity();
+            newMatrixNode.setTreeNode(memberId);
+            newMatrixNode.setTopNode(matrixNode.getTopNode());
+            newMatrixNode.setParentNode(parentNode.getMemberId());
+            newMatrixNode.setHasMoney(1);
+            newMatrixNode.setDeep(matrixNode.getDeep() + 1);
+            dappAchieveMemberTreeDao.insert(newMatrixNode);
+
+            if (matrixNode.getDeep() == 2) {
+                finishMatrixTree(matrixNode.getTopNode());
+            }
+        }
+    }
+
+    // 完成矩阵树,并重置矩阵且重入
+    public void finishMatrixTree(Long memberId) {
+        List<DappAchieveMemberTreeEntity> matrixTree = dappAchieveMemberTreeDao.selectMatrixTreeByTopNode(memberId, 1);
+        // 如果达到标准,则重置该矩阵树
+        if (matrixTree.size() == 7) {
+            dappAchieveMemberTreeDao.resetMatrixTree(memberId);
+            dappAchieveMemberTreeDao.reentryMoney(memberId);
+
+            putIntoProfit(memberId, 1);
+            DappAchieveMemberTreeEntity bottomNode = dappAchieveMemberTreeDao.selectNodeByDeep(memberId, 3);
+            if (bottomNode != null) {
+                finishMatrixTree(bottomNode.getTopNode());
+            }
+        }
+    }
+
+    @Override
+    public void putIntoProfit(Long memberId, int isReIn) {
+        DappMemberEntity member = dappMemberDao.selectById(memberId);
+        DappMemberEntity parent = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
+
+        member.setOutCnt(member.getOutCnt() + 1);
+        dappMemberDao.updateById(member);
+
+        if (parent != null) {
+            BigDecimal directProfit = new BigDecimal("100").multiply(new BigDecimal("0.15"));
+            dappWalletService.updateWalletCoinWithLock(directProfit, parent.getId());
+
+            DappFundFlowEntity fundFlow = new DappFundFlowEntity(parent.getId(), directProfit, 3, 2, null, null);
+            dappFundFlowDao.insert(fundFlow);
+        }
+
+        // 如果是复投的,则需奖励
+        if (isReIn == 1) {
+            dappWalletService.updateWalletCoinWithLock(new BigDecimal(190), member.getId());
+
+            DappFundFlowEntity matrixProfitFlow = new DappFundFlowEntity(memberId, new BigDecimal("190"), 2, 2, null, null);
+            dappFundFlowDao.insert(matrixProfitFlow);
+
+            DappFundFlowEntity rePutInFlow = new DappFundFlowEntity(memberId, new BigDecimal("100").negate(), 1, 2, null, null);
+            dappFundFlowDao.insert(rePutInFlow);
+
+            DappFundFlowEntity safePoolFlow = new DappFundFlowEntity(memberId, new BigDecimal("10").negate(), 4, 2, null, null);
+            dappFundFlowDao.insert(safePoolFlow);
+
+            DappMineDataEntity mineData = dappSystemDao.selectMineDataForOne();
+            mineData.setSafePool(mineData.getSafePool().add(BigDecimal.TEN));
+            dappSystemDao.updateMineData(mineData);
+        }
+    }
+
+    @Override
+    public void tfcNewPrice(String data) {
+        redisUtils.set(AppContants.REDIS_KEY_TFC_NEW_PRICE, new BigDecimal(data));
+    }
 }

--
Gitblit v1.9.1