From 5519fb3a19df1bb839d29d23abc3f320c5c77baa Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 21 Jun 2024 14:30:29 +0800
Subject: [PATCH] 限制每日参与矩阵的人数
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 45 +++++++++++++++++++++++++++++++++------------
1 files changed, 33 insertions(+), 12 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 5160cb4..3b6c926 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
@@ -28,6 +28,7 @@
import java.math.BigDecimal;
import java.util.ArrayList;
+import java.util.Date;
import java.util.List;
/**
@@ -102,18 +103,26 @@
BigDecimal bigDecimal = dappFundFlowDao.selectSumAmountByMemberIdAndType(member.getId(), 14);
walletInfo.setBuyNodePerk(bigDecimal);
- 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);
- }
+
+ 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;
}
@@ -483,6 +492,18 @@
}
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(),
--
Gitblit v1.9.1