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