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 | 209 +++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 190 insertions(+), 19 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 e829087..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
@@ -1,19 +1,51 @@
package cc.mrbird.febs.dapp.service.impl;
-import cc.mrbird.febs.dapp.entity.DappMineDataEntity;
-import cc.mrbird.febs.dapp.mapper.DappSystemDao;
+import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.utils.LoginUserUtil;
+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.*;
+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.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.io.IOException;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.math.RoundingMode;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.*;
/**
- * @author wzy
+ * @author
* @date 2022-03-24
**/
@Slf4j
@@ -22,22 +54,161 @@
public class DappSystemServiceImpl implements DappSystemService {
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 DappAchieveTreeDao dappAchieveTreeDao;
+ private final DappAchieveMemberTreeDao dappAchieveMemberTreeDao;
+ private final DappWalletService dappWalletService;
+
@Override
- public Map<String, Object> findTotalInComeAndList() {
- DappMineDataEntity dataMine = dappSystemDao.selectMineDataForOne();
+ public SystemDto system() {
+ DappMemberEntity member = LoginUserUtil.getAppUser();
- List<Map<String, Object>> incomeList = new ArrayList<>();
- for (int i = 0; i < 15; i++) {
- Map<String, Object> incomeItem = new HashMap<>();
- incomeItem.put("address", "TUy8XwDmdsDKPLDGUrGuNRVMhwSEKtkDcD");
- incomeItem.put("income", 0.313241234);
- incomeList.add(incomeItem);
+ SystemDto system = new SystemDto();
+ 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;
}
- Map<String, Object> result = new HashMap<>();
- result.put("mineData", dataMine);
- result.put("userIncome", incomeList);
- return result;
+ // 修改父节点在数据库中的左/右节点数据
+ 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