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 | 437 +++++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 392 insertions(+), 45 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 26758fc..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
@@ -1,32 +1,24 @@
package cc.mrbird.febs.dapp.service.impl;
-import cc.mrbird.febs.common.configure.i18n.MessageSourceUtils;
-import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.common.exception.FebsException;
-import cc.mrbird.febs.common.utils.FebsUtil;
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.*;
import cc.mrbird.febs.dapp.entity.*;
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
+import cc.mrbird.febs.dapp.enumerate.NodeType;
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappWalletService;
-import cc.mrbird.febs.dapp.utils.BoxUtil;
-import cc.mrbird.febs.dapp.vo.ActiveNftListVo;
+import cc.mrbird.febs.dapp.vo.MemberNodeVo;
+import cc.mrbird.febs.dapp.vo.NodeTypeVo;
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
-import cn.hutool.core.date.DateField;
-import cn.hutool.core.date.DateUnit;
-import cn.hutool.core.date.DateUtil;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor;
@@ -35,8 +27,9 @@
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
-import java.math.RoundingMode;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
/**
* @author
@@ -59,6 +52,7 @@
private final ChainProducer chainProducer;
private final DappSystemDao dappSystemDao;
+ private final DbMemberNodeMapper dbMemberNodeMapper;
@Override
public WalletInfoVo walletInfo() {
@@ -66,19 +60,70 @@
DappMemberEntity memberInfo = dappMemberDao.selectById(member.getId());
WalletInfoVo walletInfo = new WalletInfoVo();
- List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 1, null);
+ 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.setInviteId(member.getActiveStatus() == 1 ? member.getInviteId() : "-");
+ 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());
+
+ DataDictionaryCustom buyNodeAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.BUY_NODE_AMOUNT.getType(),
+ DataDictionaryEnum.BUY_NODE_AMOUNT.getCode()
+ );
+ BigDecimal buyNodeAmount = new BigDecimal(StrUtil.isEmpty(buyNodeAmountDic.getValue()) ? "100" : buyNodeAmountDic.getValue());
+ walletInfo.setBuyNodeAmount(buyNodeAmount);
+
+ DataDictionaryCustom buyNodeCodeCntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.BUY_NODE_CNT.getType(),
+ DataDictionaryEnum.BUY_NODE_CNT.getCode()
+ );
+ BigDecimal buyNodeCodeCnt = new BigDecimal(StrUtil.isEmpty(buyNodeCodeCntDic.getValue()) ? "3" : buyNodeCodeCntDic.getValue());
+ walletInfo.setBuyNodeCnt(buyNodeCodeCnt);
+ walletInfo.setBuyNode(ObjectUtil.isEmpty(memberInfo.getBuyNode()) ? 0 : memberInfo.getBuyNode());
+
+ 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;
}
@@ -149,7 +194,7 @@
DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), transferDto.getAmount().negate(), 1, 2, transferDto.getFee(), transferDto.getTxHash());
dappFundFlowDao.insert(fundFlow);
- chainProducer.sendAchieveTreeMsg(member.getId());
+// chainProducer.sendAchieveTreeMsg(member.getId());
} else {
int type = 1;
// 1-认购 2-充值tfc
@@ -178,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), 2, 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
@@ -199,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, 1, withdrawDto.getFee(), null);
+ DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), withdrawDto.getAmount().negate(), 21, 2, withdrawDto.getFee(), null);
dappFundFlowDao.insert(fundFlow);
MemberCoinWithdrawEntity memberCoinWithdraw = new MemberCoinWithdrawEntity();
@@ -224,15 +283,6 @@
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);
-
-// 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
@@ -335,4 +385,301 @@
public DappWalletCoinEntity findByMemberId(Long memberId) {
return dappWalletCoinDao.selectByMemberId(memberId);
}
+
+ @Override
+ public Long buyNode(BuyNodeDto transferDto) {
+ DappMemberEntity member = LoginUserUtil.getAppUser();
+
+ String upgrade = redisUtils.getString("APP_UPGRADE");
+ if ("upgrade".equals(upgrade)) {
+ throw new FebsException("功能升级中");
+ }
+
+ member = dappMemberDao.selectById(member.getId());
+// int buyNode = ObjectUtil.isEmpty(member.getBuyNode()) ? 0 : 1;
+ int buyNode = member.getBuyNode();
+ DataDictionaryCustom buyNodeCodeCntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.BUY_NODE_CNT.getType(),
+ DataDictionaryEnum.BUY_NODE_CNT.getCode()
+ );
+ 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(
+ member.getId(),
+ transferDto.getAmount().negate(),
+ 13,
+ 1,
+ BigDecimal.ZERO,
+ transferDto.getTxHash());
+ dappFundFlowDao.insert(fundFlow);
+ return fundFlow.getId();
+ } else {
+ DappFundFlowEntity flow = dappFundFlowDao.selectById(transferDto.getId());
+ if(ObjectUtil.isEmpty(flow)){
+ return null;
+ }
+ if ("success".equals(transferDto.getFlag())) {
+ flow.setFromHash(transferDto.getTxHash());
+ dappFundFlowDao.updateById(flow);
+
+ } else {
+ if (flow.getStatus() == 1) {
+ dappFundFlowDao.deleteById(transferDto.getId());
+ }
+ }
+ }
+ return null;
+ }
+
+ @Override
+ public Long buyStar(BuyStarDto buyStarDto) {
+ DappMemberEntity member = LoginUserUtil.getAppUser();
+
+ String upgrade = redisUtils.getString("APP_UPGRADE");
+ if ("upgrade".equals(upgrade)) {
+ throw new FebsException("功能升级中");
+ }
+
+ /**
+ * 买入先验证当前星团是否已经买入
+ * 如果不是购买一星,则验证前一新团是否购买
+ */
+ 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);
+ nodeQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+ List<DbMemberNode> dbMemberNodes = dbMemberNodeMapper.selectList(nodeQueryWrapper);
+ 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(),
+ 18,
+ 1,
+ BigDecimal.ZERO,
+ buyStarDto.getTxHash());
+ dappFundFlowDao.insert(fundFlow);
+ return fundFlow.getId();
+ } else {//第二次
+ DappFundFlowEntity flow = dappFundFlowDao.selectById(buyStarDto.getId());
+ if(ObjectUtil.isEmpty(flow)){
+ return null;
+ }
+ if ("success".equals(buyStarDto.getFlag())) {
+ flow.setFromHash(buyStarDto.getTxHash());
+ flow.setToHash(buyStarDto.getNodeType().toString());
+ dappFundFlowDao.updateById(flow);
+ } else {
+ if (flow.getStatus() == 1) {
+ dappFundFlowDao.deleteById(buyStarDto.getId());
+ }
+ }
+ }
+ return null;
+ }
+
+ @Override
+ public FebsResponse nodeList() {
+ List<NodeType> nodeList = NodeType.NODE_1.getNodeList();
+ List<NodeTypeVo> objects = new ArrayList<>();
+ if(CollUtil.isNotEmpty(nodeList)){
+ for(NodeType nodeType : nodeList){
+ NodeTypeVo nodeTypeVo = new NodeTypeVo();
+ nodeTypeVo.setNodeType(nodeType.getNodeType());
+ nodeTypeVo.setNodeAmount(nodeType.getNodeAmount());
+ nodeTypeVo.setNodePerk(nodeType.getNodePerk());
+ objects.add(nodeTypeVo);
+ }
+ }
+ return new FebsResponse().success().data(objects);
+ }
+
+ @Override
+ public MemberNodeVo memberNode(MemberNodeDto memberNodeDto) {
+ DappMemberEntity member = LoginUserUtil.getAppUser();
+ Integer type = memberNodeDto.getType();
+
+ QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
+ objectQueryWrapper.eq("member_id",member.getId());
+ objectQueryWrapper.eq("type", type);
+ objectQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+ DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(objectQueryWrapper);
+ if(ObjectUtil.isEmpty(dbMemberNode)){
+ return null;
+ }
+
+ 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();
+
+ MemberNodeVo memberNodeVo = new MemberNodeVo();
+ memberNodeVo.setInviteId(getInviteId(id));
+ memberNodeVo.setId(id);
+ memberNodeVo.setParentNode(ObjectUtil.isEmpty(dbMemberNode.getParentNode()) ? 0L : dbMemberNode.getParentNode());
+ memberNodeVo.setLeftNode(ObjectUtil.isEmpty(dbMemberNode.getLeftNode()) ? 0L : dbMemberNode.getLeftNode());
+ memberNodeVo.setRightNode(ObjectUtil.isEmpty(dbMemberNode.getRightNode()) ? 0L : dbMemberNode.getRightNode());
+ memberNodeVo.setLeftRight(ObjectUtil.isEmpty(dbMemberNode.getLeftRight()) ? 0 : dbMemberNode.getLeftRight());
+
+ QueryWrapper<DbMemberNode> childQuery = new QueryWrapper<>();
+ childQuery.eq("parent_node",id);
+ childQuery.eq("type", dbMemberNode.getType());
+ childQuery.eq("work_state", DbMemberNode.STATE_ONE);
+ List<DbMemberNode> childrenNode = dbMemberNodeMapper.selectList(childQuery);
+ if(CollUtil.isEmpty(childrenNode)){
+ return memberNodeVo;
+ }
+
+ List<MemberNodeVo> list = new ArrayList<>();
+ for (DbMemberNode childNode : childrenNode) {
+ list.add(buildTeamMatrix(childNode));
+ }
+ memberNodeVo.setChildren(list);
+ return memberNodeVo;
+ }
+
+ public String getInviteId(Long memberNodeId){
+ DbMemberNode dbMemberNode = dbMemberNodeMapper.selectById(memberNodeId);
+ Long memberId = dbMemberNode.getMemberId();
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ return dappMemberEntity.getInviteId();
+ }
}
--
Gitblit v1.9.1