From b3b3baf9a3b0147ca38476450ca1823c291abd20 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 21 Jun 2024 23:02:46 +0800
Subject: [PATCH] 后台矩阵列表

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java |  229 +++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 197 insertions(+), 32 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
index c03d789..13c2722 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
@@ -5,8 +5,6 @@
 import cc.mrbird.febs.common.exception.FebsException;
 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.dto.*;
 import cc.mrbird.febs.dapp.entity.*;
 import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
@@ -29,8 +27,8 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
-import java.math.RoundingMode;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -62,17 +60,28 @@
 
         DappMemberEntity memberInfo = dappMemberDao.selectById(member.getId());
         WalletInfoVo walletInfo = new WalletInfoVo();
-        List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 1, 1);
+        List<DappMemberEntity> inviteList = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 1, null);
+        List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 2, null);
         DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId());
         DappWalletMineEntity walletMine = dappWalletMineDao.selectByMemberId(member.getId());
 
         DappMineDataEntity mineData = dappSystemDao.selectMineDataForOne();
-        walletInfo.setDirectCnt(direct.size());
+        walletInfo.setDirectCnt(CollUtil.isEmpty(direct) ? 0 : direct.size());
+        walletInfo.setInviteCnt(CollUtil.isEmpty(inviteList) ? 0 : inviteList.size());
+
+        List<DappMemberEntity> collect = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 2, 1);
+//        List<DappMemberEntity> collect = direct.stream().filter(dappMemberEntity -> dappMemberEntity.getActiveStatus() == 1).collect(Collectors.toList());
+        walletInfo.setActiveCnt(CollUtil.isEmpty(collect) ? 0 : collect.size());
 //        walletInfo.setInviteId(member.getActiveStatus() == 1 ? member.getInviteId() : "-");
         walletInfo.setInviteId(member.getInviteId());
         walletInfo.setBalance(walletCoin.getAvailableAmount());
         walletInfo.setHasBuy(memberInfo.getActiveStatus());
-        walletInfo.setOutCnt(memberInfo.getOutCnt());
+        QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
+        nodeQueryWrapper.eq("member_id",member.getId());
+        nodeQueryWrapper.eq("work_state", DbMemberNode.STATE_TWO);
+        List<DbMemberNode> dbMemberNodes = dbMemberNodeMapper.selectList(nodeQueryWrapper);
+        walletInfo.setOutCnt(CollUtil.isEmpty(dbMemberNodes) ? 0 : dbMemberNodes.size());
+//        walletInfo.setOutCnt(memberInfo.getOutCnt());
         walletInfo.setProfit(dappFundFlowDao.selectProfitAmountByMemberId(member.getId()));
         walletInfo.setTfcBalance(walletMine.getAvailableAmount());
         walletInfo.setSafePool(mineData.getSafePool());
@@ -94,6 +103,27 @@
 
         BigDecimal bigDecimal = dappFundFlowDao.selectSumAmountByMemberIdAndType(member.getId(), 14);
         walletInfo.setBuyNodePerk(bigDecimal);
+
+        int i = memberInfo.getBuyNode() * 2000;
+        int teamCnt = CollUtil.isEmpty(direct) ? 0 : direct.size();
+        int i1 = teamCnt * 15;
+        QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("member_id",member.getId());
+        List<DbMemberNode> dbMemberNodes1 = dbMemberNodeMapper.selectList(objectQueryWrapper);
+        walletInfo.setScoreCnt(i+i1+(CollUtil.isEmpty(dbMemberNodes1) ? 0 : dbMemberNodes1.size())*300);
+//        Integer activeStatus = ObjectUtil.isEmpty(member.getActiveStatus()) ? 2 : member.getActiveStatus();
+//        if(1 == activeStatus){
+//            int i = memberInfo.getBuyNode() * 2000;
+//            int teamCnt = CollUtil.isEmpty(direct) ? 0 : direct.size();
+//            int i1 = teamCnt * 15;
+//            QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
+//            objectQueryWrapper.eq("member_id",member.getId());
+//            List<DbMemberNode> dbMemberNodes1 = dbMemberNodeMapper.selectList(objectQueryWrapper);
+//            walletInfo.setScoreCnt(i+i1+(CollUtil.isEmpty(dbMemberNodes1) ? 0 : dbMemberNodes1.size())*300);
+//        }else{
+//            walletInfo.setScoreCnt(0);
+//        }
+
         return walletInfo;
     }
 
@@ -193,15 +223,29 @@
 
     @Override
     public BigDecimal calPrice(PriceDto priceDto) {
-//        String priceStr = redisUtils.getString(AppContants.REDIS_KEY_TFC_NEW_PRICE);
-        DataDictionaryCustom symbolPrice = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.SYMBOL_PRICE.getType(), DataDictionaryEnum.SYMBOL_PRICE.getCode());
-        DataDictionaryCustom serviceFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WITHDRAW_SERVICE_FEE.getType(), DataDictionaryEnum.WITHDRAW_SERVICE_FEE.getCode());
-
-        BigDecimal amount = priceDto.getAmount();
-        if (priceDto.getAmount() == null) {
-            amount = BigDecimal.ZERO;
+        DappMemberEntity member = LoginUserUtil.getAppUser();
+        //手续费率
+        DataDictionaryCustom feePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                DataDictionaryEnum.CHARGE_FEE_PERCENT.getType(),
+                DataDictionaryEnum.CHARGE_FEE_PERCENT.getCode());
+        BigDecimal feePercent = new BigDecimal(feePercentDic.getValue()).multiply(new BigDecimal("0.01"));
+        //提现金额
+        BigDecimal withdrawCnt = BigDecimal.ZERO;
+        if (ObjectUtil.isEmpty(priceDto.getWithdrawCnt())) {
+            withdrawCnt = BigDecimal.ZERO;
+        }else{
+            withdrawCnt = priceDto.getWithdrawCnt();
         }
-        return amount.multiply(new BigDecimal(serviceFeeDic.getValue()).divide(BigDecimal.valueOf(100), 8, RoundingMode.HALF_DOWN)).divide(new BigDecimal(symbolPrice.getValue()), 2, RoundingMode.HALF_UP);
+        if(BigDecimal.ZERO.compareTo(withdrawCnt) >= 0){
+            throw new FebsException("请输入正确的金额");
+        }
+        DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId());
+        if (priceDto.getWithdrawCnt().compareTo(walletCoin.getAvailableAmount()) > 0) {
+            throw new FebsException("可提现不足");
+        }
+        BigDecimal feeUsdt = withdrawCnt.multiply(feePercent).setScale(2, BigDecimal.ROUND_DOWN);
+
+        return feeUsdt.divide(priceDto.getAmount(), 2, BigDecimal.ROUND_DOWN);
     }
 
     @Override
@@ -214,19 +258,19 @@
             throw new FebsException("Balance Not Enough");
         }
 
-        DappWalletMineEntity walletMine = dappWalletMineDao.selectByMemberId(member.getId());
-        if (walletMine.getAvailableAmount().compareTo(withdrawDto.getFee()) < 0) {
-            throw new FebsException("DMD Not Enough");
-        }
+//        DappWalletMineEntity walletMine = dappWalletMineDao.selectByMemberId(member.getId());
+//        if (walletMine.getAvailableAmount().compareTo(withdrawDto.getFee()) < 0) {
+//            throw new FebsException("Fee Not Enough");
+//        }
 
         updateWalletCoinWithLock(withdrawDto.getAmount(), member.getId(), 2);
-        updateWalletMineWithLock(withdrawDto.getFee(), member.getId(), 2);
+//        updateWalletMineWithLock(withdrawDto.getFee(), member.getId(), 2);
 
 
-        DappFundFlowEntity feeFlow = new DappFundFlowEntity(member.getId(), withdrawDto.getFee().negate(), 7, 2, null, null);
+        DappFundFlowEntity feeFlow = new DappFundFlowEntity(member.getId(), withdrawDto.getFee().negate(), 20, 2, null, null);
         dappFundFlowDao.insert(feeFlow);
 
-        DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), withdrawDto.getAmount().negate(), 5, 2, withdrawDto.getFee(), null);
+        DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), withdrawDto.getAmount().negate(), 21, 2, withdrawDto.getFee(), null);
         dappFundFlowDao.insert(fundFlow);
 
         MemberCoinWithdrawEntity memberCoinWithdraw = new MemberCoinWithdrawEntity();
@@ -234,21 +278,11 @@
         memberCoinWithdraw.setAddress(member.getAddress());
         memberCoinWithdraw.setAmount(withdrawDto.getAmount());
         memberCoinWithdraw.setFeeAmount(withdrawDto.getFee());
-        memberCoinWithdraw.setStatus(MemberCoinWithdrawEntity.STATUS_YES);
+        memberCoinWithdraw.setStatus(MemberCoinWithdrawEntity.STATUS_DOING);
         memberCoinWithdraw.setSymbol("USDT");
         memberCoinWithdraw.setFlowId(fundFlow.getId());
         memberCoinWithdrawDao.insert(memberCoinWithdraw);
 
-        String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(member.getAddress(), withdrawDto.getAmount());
-        fundFlow.setToHash(hash);
-        dappFundFlowDao.updateById(fundFlow);
-
-        chainProducer.sendFeeDistributeMsg(fundFlow.getId());
-//        Map<String, Object> map = new HashMap<>();
-//        map.put("fee", withdrawDto.getFee());
-//        map.put("address", ChainEnum.BSC_TFC_FEE.getAddress());
-//        map.put("flow", feeFlow.getId());
-//        chainProducer.sendTfcFee(JSONObject.toJSONString(map));
     }
 
     @Override
@@ -371,6 +405,23 @@
         if (buyNode >= Integer.parseInt(buyNodeCodeCntDic.getValue())) {
             throw new FebsException("Do not repeat purchase");
         }
+        /**
+         * 限购总数200
+         */
+
+        DataDictionaryCustom perKNumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                DataDictionaryEnum.PERK_NUM.getType(),
+                DataDictionaryEnum.PERK_NUM.getCode()
+        );
+        int perKNum = Integer.parseInt(ObjectUtil.isEmpty(perKNumDic) ? "200" : perKNumDic.getValue());
+
+        List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectList(null);
+        if(CollUtil.isNotEmpty(dappMemberEntities)){
+            int sum1 = dappMemberEntities.stream().mapToInt(DappMemberEntity::getBuyNode).sum();
+            if(perKNum < sum1 + 1){
+                throw new FebsException("节点已售完");
+            }
+        }
 
         if (ObjectUtil.isEmpty(transferDto.getId())) {
             DappFundFlowEntity fundFlow = new DappFundFlowEntity(
@@ -411,8 +462,15 @@
 
         /**
          * 买入先验证当前星团是否已经买入
+         *      如果不是购买一星,则验证前一新团是否购买
          */
+        if(ObjectUtil.isEmpty(buyStarDto.getNodeType())){
+            throw new FebsException("选择购买的星团");
+        }
         Integer nodeType = buyStarDto.getNodeType();
+        if(NodeType.NODE_13.getNodeType() < nodeType || nodeType < NodeType.NODE_1.getNodeType()){
+            throw new FebsException("选择购买的星团");
+        }
         QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
         nodeQueryWrapper.eq("member_id",member.getId());
         nodeQueryWrapper.eq("type", nodeType);
@@ -421,8 +479,31 @@
         if(CollUtil.isNotEmpty(dbMemberNodes)){
             throw new FebsException("已购买");
         }
+        if(NodeType.NODE_1.getNodeType() != buyStarDto.getNodeType()){
+            Integer nextNodeType = nodeType - 1;
+            QueryWrapper<DbMemberNode> nextWrapper = new QueryWrapper<>();
+            nextWrapper.eq("member_id",member.getId());
+            nextWrapper.eq("type", nextNodeType);
+            nextWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+            List<DbMemberNode> nextNode = dbMemberNodeMapper.selectList(nextWrapper);
+            if(CollUtil.isEmpty(nextNode)){
+                throw new FebsException("请先购买上一星团");
+            }
+        }
 
         if (ObjectUtil.isEmpty(buyStarDto.getId())) {//第一次
+            List<DbMemberNode> dbMemberNodesDone = dbMemberNodeMapper.selectListByDate(new Date());
+            if(CollUtil.isNotEmpty(dbMemberNodesDone)){
+                DataDictionaryCustom buyNodeNumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                        DataDictionaryEnum.BUY_NODE_NUM.getType(),
+                        DataDictionaryEnum.BUY_NODE_NUM.getCode()
+                );
+                int buyNodeNum = Integer.parseInt(buyNodeNumDic.getValue());
+                if(buyNodeNum < dbMemberNodesDone.size()){
+                    throw new FebsException("今日已满,请明日再来");
+                }
+            };
+
             DappFundFlowEntity fundFlow = new DappFundFlowEntity(
                     member.getId(),
                     buyStarDto.getAmount().negate(),
@@ -483,6 +564,90 @@
         return buildTeamMatrix(dbMemberNode);
     }
 
+    @Override
+    public Long chargeFee(ChargeFeeDto chargeFeeDto) {
+        DappMemberEntity member = LoginUserUtil.getAppUser();
+
+        String upgrade = redisUtils.getString("APP_UPGRADE");
+        if ("upgrade".equals(upgrade)) {
+            throw new FebsException("功能升级中");
+        }
+        if (ObjectUtil.isEmpty(chargeFeeDto.getId())) {//第一次
+            DappFundFlowEntity fundFlow = new DappFundFlowEntity(
+                    member.getId(),
+                    chargeFeeDto.getAmount().negate(),
+                    19,
+                    1,
+                    BigDecimal.ZERO,
+                    chargeFeeDto.getTxHash());
+            dappFundFlowDao.insert(fundFlow);
+            return fundFlow.getId();
+        } else {//第二次
+            DappFundFlowEntity flow = dappFundFlowDao.selectById(chargeFeeDto.getId());
+            if(ObjectUtil.isEmpty(flow)){
+                return null;
+            }
+            if ("success".equals(chargeFeeDto.getFlag())) {
+                flow.setFromHash(chargeFeeDto.getTxHash());
+                dappFundFlowDao.updateById(flow);
+            } else {
+                if (flow.getStatus() == 1) {
+                    dappFundFlowDao.deleteById(chargeFeeDto.getId());
+                }
+            }
+        }
+        return null;
+    }
+
+    @Override
+    public FebsResponse agreeWithdraw(Long id) {
+        MemberCoinWithdrawEntity memberCoinWithdrawEntity = memberCoinWithdrawDao.selectById(id);
+        if(ObjectUtil.isEmpty(memberCoinWithdrawEntity)){
+            throw new FebsException("刷新页面重试");
+        }
+
+        if (MemberCoinWithdrawEntity.STATUS_DOING != memberCoinWithdrawEntity.getStatus()) {
+            throw new FebsException("非可审核状态");
+        }
+        memberCoinWithdrawEntity.setStatus(MemberCoinWithdrawEntity.STATUS_YES);
+        memberCoinWithdrawDao.updateById(memberCoinWithdrawEntity);
+
+        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(memberCoinWithdrawEntity.getFlowId());
+        dappFundFlowEntity.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_AGREE);
+        dappFundFlowDao.updateById(dappFundFlowEntity);
+
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse disagreeWithdraw(Long id) {
+        MemberCoinWithdrawEntity memberCoinWithdrawEntity = memberCoinWithdrawDao.selectById(id);
+        if(ObjectUtil.isEmpty(memberCoinWithdrawEntity)){
+            throw new FebsException("刷新页面重试");
+        }
+
+        if (MemberCoinWithdrawEntity.STATUS_DOING != memberCoinWithdrawEntity.getStatus()) {
+            throw new FebsException("非可审核状态");
+        }
+
+        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(memberCoinWithdrawEntity.getFlowId());
+        if (dappFundFlowEntity == null) {
+            throw new FebsException("审核失败,联系管理员");
+        }
+        memberCoinWithdrawEntity.setStatus(MemberCoinWithdrawEntity.STATUS_NO);
+        memberCoinWithdrawDao.updateById(memberCoinWithdrawEntity);
+
+        dappFundFlowEntity.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_DISAGREE);
+        dappFundFlowDao.updateById(dappFundFlowEntity);
+
+        this.updateWalletCoinWithLock(memberCoinWithdrawEntity.getAmount(), memberCoinWithdrawEntity.getMemberId(), 1);
+//        this.updateWalletMineWithLock(memberCoinWithdrawEntity.getFeeAmount(), memberCoinWithdrawEntity.getMemberId(), 1);
+
+        DappFundFlowEntity feeFlow = new DappFundFlowEntity(memberCoinWithdrawEntity.getMemberId(), memberCoinWithdrawEntity.getAmount(), 22, 2, null, null);
+        dappFundFlowDao.insert(feeFlow);
+        return new FebsResponse().success();
+    }
+
     public MemberNodeVo buildTeamMatrix(DbMemberNode dbMemberNode) {
         Long id = dbMemberNode.getId();
 

--
Gitblit v1.9.1