From 676177dc1c4967b30470ee50df6fc30caf396aa9 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 17 Jun 2024 09:53:57 +0800
Subject: [PATCH] 节点限购200个
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 74 ++++++++++++++++++++++++++++++++++++-
1 files changed, 72 insertions(+), 2 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 de2a26b..806da59 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
@@ -59,7 +59,8 @@
DappMemberEntity memberInfo = dappMemberDao.selectById(member.getId());
WalletInfoVo walletInfo = new WalletInfoVo();
- List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 1, 1);
+// List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 1, 1);
+ List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(member.getInviteId(), 2, null);
DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId());
DappWalletMineEntity walletMine = dappWalletMineDao.selectByMemberId(member.getId());
@@ -69,7 +70,12 @@
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());
@@ -372,6 +378,21 @@
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);
+ int sum1 = dappMemberEntities.stream().mapToInt(DappMemberEntity::getBuyNode).sum();
+ if(perKNum < sum1 + 1){
+ throw new FebsException("节点已售完");
+ }
if (ObjectUtil.isEmpty(transferDto.getId())) {
DappFundFlowEntity fundFlow = new DappFundFlowEntity(
@@ -537,6 +558,55 @@
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.getFeeAmount(), 22, 2, null, null);
+ dappFundFlowDao.insert(feeFlow);
+ return new FebsResponse().success();
+ }
+
public MemberNodeVo buildTeamMatrix(DbMemberNode dbMemberNode) {
Long id = dbMemberNode.getId();
--
Gitblit v1.9.1