限制每日参与矩阵的人数

KKSU

2024-06-21 5519fb3a19df1bb839d29d23abc3f320c5c77baa

 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(),