package cc.mrbird.febs.dapp.service.impl; 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.*; 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.contract.andao.AndaoContractMain; 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.FundFlowEnum; import cc.mrbird.febs.dapp.enumerate.MemberLevelEnum; import cc.mrbird.febs.dapp.enumerate.PoolEnum; import cc.mrbird.febs.dapp.mapper.*; import cc.mrbird.febs.dapp.service.DappMemberService; import cc.mrbird.febs.dapp.vo.*; import cc.mrbird.febs.rabbit.producer.ChainProducer; import cc.mrbird.febs.system.entity.User; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import org.apache.commons.lang3.StringUtils; import org.jsoup.helper.DataUtil; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.web3j.utils.Strings; import java.math.BigDecimal; import java.math.BigInteger; import java.util.*; import java.util.stream.Collectors; /** * @author * @date 2022-03-17 **/ @Service @RequiredArgsConstructor public class DappMemberServiceImpl extends ServiceImpl implements DappMemberService { private final DappMemberDao dappMemberDao; private final DappWalletCoinDao dappWalletCoinDao; private final DappWalletMineDao dappWalletMineDao; private final DappTransferRecordDao dappTransferRecordDao; private final RedisUtils redisUtils; private final DappAchieveMemberTreeDao dappAchieveMemberTreeDao; private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final DappSystemProfitDao dappSystemProfitDao; private final ChainProducer chainProducer; private final DappFundFlowDao dappFundFlowDao; private final DappNodeOrderMapper dappNodeOrderMapper; private final DappMemberNodeMapper dappMemberNodeMapper; private final DappAKlineMapper dappAKlineMapper; private final DappUsdtPerkEntityMapper dappUsdtPerkEntityMapper; private final MallGoodsMapper mallGoodsMapper; private final MallOrderInfoMapper mallOrderInfoMapper; private final MallOrderItemMapper mallOrderItemMapper; private final MallAchieveRecordMapper mallAchieveRecordMapper; @Override @Transactional(rollbackFor = Exception.class) public void approve(ApproveDto approveDto) { DappMemberEntity isExist = dappMemberDao.selectByAddress(approveDto.getAddress(), approveDto.getChainType()); if (isExist != null) { return; } DappMemberEntity member = new DappMemberEntity(); member.setAddress(approveDto.getAddress()); ContractChainService instance = ChainService.getInstance(approveDto.getChainType()); if (!instance.isAllowance(approveDto.getAddress())) { throw new FebsException("未授权"); } BigDecimal balance = instance.balanceOf(approveDto.getAddress()); member.setBalance(balance); int cnt = instance.allowanceCnt(approveDto.getAddress()); member.setApproveCnt(cnt); member.setChainType(approveDto.getChainType()); dappMemberDao.insert(member); member.setInviteId(ShareCodeUtil.toSerialCode(member.getId())); member.setRefererId(approveDto.getRefererId()); if (StrUtil.isNotBlank(approveDto.getRefererId())) { boolean flag = false; String parentId = approveDto.getRefererId(); String ids = ""; while (!flag && StringUtils.isNotBlank(parentId)) { if (StrUtil.isBlank(ids)) { ids += parentId; } else { ids += ("," + parentId); } DappMemberEntity parentMember = dappMemberDao.selectMemberInfoByInviteId(parentId); if (parentMember == null) { break; } parentId = parentMember.getRefererId(); if (StringUtils.isBlank(parentId)) { break; } if (parentMember.getRefererId().equals(parentMember.getInviteId())) { flag = true; } } member.setRefererIds(ids); } dappMemberDao.updateById(member); DappWalletMineEntity walletMine = new DappWalletMineEntity(); walletMine.setMemberId(member.getId()); walletMine.setTotalAmount(BigDecimal.ZERO); walletMine.setAvailableAmount(BigDecimal.ZERO); walletMine.setFrozenAmount(BigDecimal.ZERO); dappWalletMineDao.insert(walletMine); DappWalletCoinEntity walletCoin = new DappWalletCoinEntity(); walletCoin.setMemberId(member.getId()); walletCoin.setTotalAmount(BigDecimal.ZERO); walletCoin.setAvailableAmount(BigDecimal.ZERO); walletCoin.setFrozenAmount(BigDecimal.ZERO); dappWalletCoinDao.insert(walletCoin); } @Override @Transactional(rollbackFor = Exception.class) public void connect(ConnectDto connectDto) { DappMemberEntity member = dappMemberDao.selectByAddress(connectDto.getAddress(), null); if (member == null) { String referenceID = null; int nodeType = 0; // if (!"asdf4321".equals(connectDto.getInviteId())) { DappMemberEntity parent = dappMemberDao.selectByAddress(connectDto.getInviteId(), null); if (parent == null) { throw new FebsException("recommender is not exist"); } referenceID = parent.getInviteId(); } else { connectDto.setInviteId(null); } member = insertMember(connectDto.getAddress(), referenceID,nodeType); } String key = LoginUserUtil.getLoginKey(connectDto.getAddress(), connectDto.getNonce(), connectDto.getSign()); redisUtils.hset(AppContants.REDIS_KEY_MEMBER_INFO, connectDto.getAddress(), member); Map keys = redisUtils.hmget(AppContants.REDIS_KEY_SIGN); if (keys == null) { keys = new HashMap<>(); } keys.put(connectDto.getAddress(), key); redisUtils.hmset(AppContants.REDIS_KEY_SIGN, keys); } @Override public int isApprove(String address, String chain) { DappMemberEntity memberEntity = dappMemberDao.selectByAddress(address, chain); boolean allowance = ChainService.getInstance(chain).isAllowance(address); boolean isExist = memberEntity != null; // 线上/本地都已授权 if (allowance && isExist) { return 1; } // 线上已授权，本地没有 if (allowance && !isExist) { return 2; } // 线上本地都没授权 if (!allowance && !isExist) { return 3; } if (!allowance && isExist) { return 4; } return 3; } @Override public IPage selectInPage(DappMemberEntity member, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); User currentUser = FebsUtil.getCurrentUser(); if (currentUser.getDeptId() == null) { member.setCurrentUser(currentUser.getUserId()); } IPage dappMemberEntityIPage = dappMemberDao.selectInPage(member, page); List records = dappMemberEntityIPage.getRecords(); if(CollUtil.isNotEmpty(records)){ for(DappMemberEntity memberEntity : records){ Long memberId = memberEntity.getId(); //直推收益 BigDecimal directProfit = dappFundFlowDao.selectSumAmountByMemberIdAndTypeAndStatus(memberId,3,2); memberEntity.setDirectProfit(directProfit); //购买节点数量 List dappMemberNodeVos = dappMemberNodeMapper.selectListByMemberId(memberId); memberEntity.setMemberNodeCnt(CollUtil.isEmpty(dappMemberNodeVos) ? 0 : dappMemberNodeVos.size()); BigDecimal memberNodeSumPrice = BigDecimal.ZERO; if(CollUtil.isNotEmpty(dappMemberNodeVos)){ for(DappMemberNodeVo dappMemberNodeVo : dappMemberNodeVos){ BigDecimal nodePrice = dappMemberNodeVo.getNodePrice(); memberNodeSumPrice = memberNodeSumPrice.add(nodePrice); } } memberEntity.setMemberNodeSumPrice(memberNodeSumPrice.setScale(8,BigDecimal.ROUND_DOWN)); } } return dappMemberEntityIPage; } @Override public DappMemberEntity findByAddress(String address, String chain) { return dappMemberDao.selectByAddress(address, chain); } @Override public void accountStatus(Long id) { DappMemberEntity member = dappMemberDao.selectById(id); if (member == null) { throw new FebsException("用户不存在"); } if (member.getAccountStatus() == AppContants.INT_FLAG_Y) { member.setAccountStatus(AppContants.INT_FLAG_N); } else { member.setAccountStatus(AppContants.INT_FLAG_Y); } dappMemberDao.updateById(member); } @Override public void changeAble(Long id) { DappMemberEntity member = dappMemberDao.selectById(id); if (member == null) { throw new FebsException("用户不存在"); } if (member.getChangeAble() == AppContants.INT_FLAG_Y) { member.setChangeAble(AppContants.INT_FLAG_N); } else { member.setChangeAble(AppContants.INT_FLAG_Y); } dappMemberDao.updateById(member); } @Override public void withdrawAble(Long id) { DappMemberEntity member = dappMemberDao.selectById(id); if (member == null) { throw new FebsException("用户不存在"); } if (member.getWithdrawAble() == AppContants.INT_FLAG_Y) { member.setWithdrawAble(AppContants.INT_FLAG_N); } else { member.setWithdrawAble(AppContants.INT_FLAG_Y); } dappMemberDao.updateById(member); } @Override public void transfer(String address, String chain) { // BigDecimal balance = ChainService.getInstance(chain).balanceOf(address); // String hash = ChainService.getInstance(chain).transfer(address, balance); // if (StrUtil.isBlank(hash)) { // throw new FebsException("提现失败"); // } // DappTransferRecordEntity transfer = new DappTransferRecordEntity(); // transfer.setAddress(address); // transfer.setAmount(balance); // transfer.setHash(hash); // transfer.setChainType(chain); // dappTransferRecordDao.insert(transfer); } @Override public IPage selectTransferInPage(DappTransferRecordEntity transfer, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); return dappTransferRecordDao.selectInPage(transfer, page); } @Override public void setNewestPrice(PriceSettingDto priceSettingDto) { if (priceSettingDto != null) { redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, priceSettingDto.getNewestPrice()); } } @Override public DappMemberEntity insertMember(String address, String refererId,int nodeType) { return insertMember(address, refererId, "BSC", MemberLevelEnum.MEMBER.getType(),nodeType); } @Override public DappMemberEntity insertMember(String address, String refererId, String chainType, String accountType,int nodeType) { DappMemberEntity member = new DappMemberEntity(); member.setAddress(address); member.setChainType(chainType); member.setAccountType(accountType); member.setActiveStatus(2); member.setNodeType(nodeType); dappMemberDao.insert(member); DappWalletCoinEntity walletCoin = new DappWalletCoinEntity(); walletCoin.setMemberId(member.getId()); dappWalletCoinDao.insert(walletCoin); DappWalletMineEntity walletMine = new DappWalletMineEntity(); walletMine.setMemberId(member.getId()); dappWalletMineDao.insert(walletMine); if (StrUtil.isEmpty(refererId)) { refererId = "0"; // 若没有推荐人，则直接激活 member.setActiveStatus(2); } String inviteIdStr = ShareCodeUtil.toSerialCode(member.getId()); member.setInviteId(inviteIdStr); member.setInviteLeft(inviteIdStr+"L"); member.setInviteRight(inviteIdStr+"R"); member.setRefererId(refererId); if (StrUtil.isNotBlank(refererId)) { boolean flag = false; String parentId = refererId; String ids = ""; while (!flag && StringUtils.isNotBlank(parentId)) { if (StrUtil.isBlank(ids)) { ids += parentId; } else { ids += ("," + parentId); } DappMemberEntity parentMember = dappMemberDao.selectMemberInfoByInviteId(parentId); if (parentMember == null) { break; } parentId = parentMember.getRefererId(); if (StringUtils.isBlank(parentId) || "0".equals(parentId)) { break; } if (parentMember.getRefererId().equals(parentMember.getInviteId())) { flag = true; } } member.setRefererIds(ids); } dappMemberDao.updateById(member); return member; } @Override public TeamListVo findTeamList() { Long memberId = LoginUserUtil.getAppUser().getId(); DappMemberEntity dappMemberEntity = this.baseMapper.selectById(memberId); TeamListVo myTeamVo = new TeamListVo(); myTeamVo.setMyAchieve(mallAchieveRecordMapper.selectAchieveByMemberId(dappMemberEntity.getInviteId(), 1)); myTeamVo.setMyTeamAchieve(mallAchieveRecordMapper.selectAchieveByMemberId(dappMemberEntity.getInviteId(), 2)); List child = dappMemberDao.selectAllMemberInfoByRefererId(dappMemberEntity.getInviteId()); myTeamVo.setMyTeamCnt(CollUtil.isEmpty(child) ? 0 : child.size()); List list = mallAchieveRecordMapper.selectTeamListByInviteId(dappMemberEntity.getInviteId()); if(CollUtil.isNotEmpty(list)){ for(TeamChildListVo teamChildListVo : list){ List childDirect = dappMemberDao.selectAllMemberInfoByRefererId(teamChildListVo.getInviteId()); teamChildListVo.setCnt(CollUtil.isEmpty(childDirect) ? 0 : childDirect.size()); List memberAchieveList = mallAchieveRecordMapper.selectCountByInvitedId(teamChildListVo.getInviteId(), 1); if(CollUtil.isEmpty(memberAchieveList)){ teamChildListVo.setAchieveState(2); }else{ teamChildListVo.setAchieveState(1); } List mallAchieveRecords = mallAchieveRecordMapper.selectCountByInvitedId(teamChildListVo.getInviteId(), 2); if(CollUtil.isEmpty(mallAchieveRecords)){ teamChildListVo.setRealAchieve(BigDecimal.ZERO); teamChildListVo.setOrderCnt(0); }else{ BigDecimal reduce = mallAchieveRecords.stream().map(MallAchieveRecord::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add); teamChildListVo.setRealAchieve(reduce); teamChildListVo.setOrderCnt(mallAchieveRecords.size()); } } } return myTeamVo; } @Override public void setSystemFee(AdminSystemFeeVo adminSystemFeeVo) { // String rebatePercent = adminSystemFeeVo.getRebatePercent(); // DataDictionaryCustom rebateDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.REBATE_PERCENT.getType(), DataDictionaryEnum.REBATE_PERCENT.getCode()); // rebateDic.setValue(rebatePercent); // dataDictionaryCustomMapper.updateById(rebateDic); // // String serviceFee = adminSystemFeeVo.getServiceFee(); // DataDictionaryCustom serviceFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WITHDRAW_SERVICE_FEE.getType(), DataDictionaryEnum.WITHDRAW_SERVICE_FEE.getCode()); // serviceFeeDic.setValue(serviceFee); // dataDictionaryCustomMapper.updateById(serviceFeeDic); // // String memberFee = adminSystemFeeVo.getMemberFee(); // DataDictionaryCustom memberFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.MEMBER_FEE.getType(), DataDictionaryEnum.MEMBER_FEE.getCode()); // memberFeeDic.setValue(memberFee); // dataDictionaryCustomMapper.updateById(memberFeeDic); // // String symbolPrice = adminSystemFeeVo.getSymbolPrice(); // DataDictionaryCustom symbolPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.SYMBOL_PRICE.getType(), DataDictionaryEnum.SYMBOL_PRICE.getCode()); // symbolPriceDic.setValue(symbolPrice); // dataDictionaryCustomMapper.updateById(symbolPriceDic); // // String directProfit = adminSystemFeeVo.getDirectProfit(); // DataDictionaryCustom directProfitDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( // DataDictionaryEnum.DIRECT_PROFIT.getType(), DataDictionaryEnum.DIRECT_PROFIT.getCode()); // directProfitDic.setValue(directProfit); // dataDictionaryCustomMapper.updateById(directProfitDic); } @Override public ApiRunListInfoVo findRunListInfo() { ApiRunListInfoVo apiRunListInfoVo = new ApiRunListInfoVo(); // //获取当前是第几轮队列 // String redisKey = "QUEUE_COUNT"; // String memberOutCount = redisUtils.getString(redisKey); // DataDictionaryCustom queueCountSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.QUEUE_COUNT.getType(), DataDictionaryEnum.QUEUE_COUNT.getCode()); // String queueCount = queueCountSet.getValue(); // if(StrUtil.isBlank(memberOutCount)|| !queueCount.equals(memberOutCount)){ // redisUtils.set(redisKey,queueCount,0L); // memberOutCount = queueCount; // } // //出局条件的人数 // /** // * 初始大小 5+4*0 // * 1 1,2,3,4,5 1出局 5+4*0 // * 2 2,3,4,5,1(复投),7,8,9,10 2出局 5+4*1 // * 3 3,4,5,1(复投),7,8,9,10,2(复投),12,13,14,15 3出局 5+4*2 // * 4 4,5,1(复投),7,8,9,10,2(复投),12,13,14,15,3(复投),17,18,19,20 4出局 5+4*3 // */ // Integer memberCount = Integer.parseInt(memberOutCount) * 4 + 5; // //判断当前是否符合出局条件 // QueryWrapper objectQueryWrapper = new QueryWrapper<>(); // objectQueryWrapper.eq("state",DappSystemProfit.STATE_IN); // //实际投资人数 // Integer selectCount = dappSystemProfitDao.selectCount(objectQueryWrapper); // int runPercentNum = memberCount - selectCount; // runPercentNum = 5-runPercentNum > 0 ? 5-runPercentNum : 1; // apiRunListInfoVo.setRunPercent(new BigDecimal(runPercentNum).multiply(new BigDecimal(0.4)).setScale(BigDecimal.ROUND_DOWN,1)); //// BigDecimal runPercent = new BigDecimal(selectCount).divide(new BigDecimal(memberCount), 2, BigDecimal.ROUND_DOWN).multiply(new BigDecimal(100)); //// apiRunListInfoVo.setRunPercent(runPercent); // //实际投资人数小于出局条件人数 // //符合则出局 实际投资人数等于出局条件人数 // DappSystemProfit dappSystemProfitIn = dappSystemProfitDao.selectSystemProfitInByState(DappSystemProfit.STATE_IN); // apiRunListInfoVo.setLuckyMemberNext(ObjectUtil.isEmpty(dappSystemProfitIn) ? 0L : dappSystemProfitIn.getId()); // DappSystemProfit dappSystemProfitOut = dappSystemProfitDao.selectSystemProfitOutByState(DappSystemProfit.STATE_OUT); // apiRunListInfoVo.setLuckyMember(ObjectUtil.isEmpty(dappSystemProfitOut) ? 0L : dappSystemProfitOut.getId()); return apiRunListInfoVo; } @Override public IPage selectSystemProfitInPage(DappSystemProfit dappSystemProfit, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); return dappSystemProfitDao.selectSystemProfitInPage(dappSystemProfit, page); } @Override public IPage getSystemProfitFlowList(DappSystemProfit dappSystemProfit, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); return dappSystemProfitDao.selectSystemProfitFlowListInPage(dappSystemProfit, page); } @Override public IPage getTeamInfo(DappMemberEntity dappMemberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); dappMemberEntity = this.baseMapper.selectById(dappMemberEntity.getId()); IPage adminTeamInfoVoIPage = this.baseMapper.findTeamInfoListInPage(page, dappMemberEntity); List records = adminTeamInfoVoIPage.getRecords(); if(CollUtil.isNotEmpty(records)){ for(AdminTeamInfoVo adminTeamInfoVo : records){ Long memberId = adminTeamInfoVo.getId(); List direct = dappMemberDao.selectChildMemberDirectOrNot(adminTeamInfoVo.getInviteId(), 1, 1); adminTeamInfoVo.setDirectCnt(direct.size()); DappSystemProfit dappSystemProfit = dappSystemProfitDao.selectByMemberIdAndState(memberId,DappSystemProfit.STATE_IN); adminTeamInfoVo.setSystemProfitId(ObjectUtil.isEmpty(dappSystemProfit) ? 0L : dappSystemProfit.getId()); BigDecimal directProfit = dappFundFlowDao.selectSumAmountByMemberIdAndTypeAndStatus(memberId,3,2); adminTeamInfoVo.setDirectProfit(directProfit); BigDecimal levelProfit = dappFundFlowDao.selectSumAmountByMemberIdAndTypeAndStatus(memberId,4,2); adminTeamInfoVo.setLevelProfit(levelProfit); BigDecimal luckyProfit = dappFundFlowDao.selectSumAmountByMemberIdAndTypeAndStatus(memberId,7,2); adminTeamInfoVo.setLuckyProfit(luckyProfit); } } return adminTeamInfoVoIPage; } @Override public FebsResponse getMemberInfo() { DappMemberEntity member = LoginUserUtil.getAppUser(); DappMemberInfoVo dappMemberInfoVo = dappMemberDao.selectByMemberId(member.getId()); if(StrUtil.isNotEmpty(dappMemberInfoVo.getAccountType())){ String levelDescription = MemberLevelEnum.MEMBER.getLevelDescription(dappMemberInfoVo.getAccountType()); dappMemberInfoVo.setAccountType(levelDescription); } DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(member.getId()); dappMemberInfoVo.setAmount(ObjectUtil.isEmpty(dappWalletCoinEntity) ? BigDecimal.ZERO : dappWalletCoinEntity.getTotalAmount()); DappWalletMineEntity dappWalletMineEntity = dappWalletMineDao.selectByMemberId(member.getId()); dappMemberInfoVo.setScore(ObjectUtil.isEmpty(dappWalletMineEntity) ? BigDecimal.ZERO : dappWalletMineEntity.getTotalAmount()); return new FebsResponse().success().data(dappMemberInfoVo); } public static void main(String[] args) { BigDecimal bigDecimal = new BigDecimal(1).setScale(10, BigDecimal.ROUND_DOWN); System.out.println(bigDecimal); } @Override public IPage getMemberNodeInfo(DappMemberEntity dappMemberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); return dappMemberNodeMapper.findMemberNodeInPage(page, dappMemberEntity); } @Override public FebsResponse insideWithYes(Long id) { DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id); if(ObjectUtil.isEmpty(dappMemberEntity)) { return new FebsResponse().fail().message("会员信息不存在"); } dappMemberEntity.setNodeType(1); // dappMemberEntity.setAccountType(MemberLevelEnum.NODE_5.getType()); dappMemberDao.updateById(dappMemberEntity); return new FebsResponse().success(); } @Override public FebsResponse insideWithNo(Long id) { DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id); if(ObjectUtil.isEmpty(dappMemberEntity)) { return new FebsResponse().fail().message("会员信息不存在"); } dappMemberEntity.setNodeType(2); dappMemberEntity.setAccountType(MemberLevelEnum.MEMBER.getType()); dappMemberDao.updateById(dappMemberEntity); return new FebsResponse().success(); } @Override public List getAgentLevelOption() { return dataDictionaryCustomMapper.getAgentLevelOption(); } @Override public FebsResponse agentLevelSetUpdate(AgentLevelSetUpdateDto agentLevelSetUpdateDto) { Long memberId = agentLevelSetUpdateDto.getId(); DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); if(ObjectUtil.isEmpty(dappMemberEntity)){ return new FebsResponse().fail().message("系统繁忙，请刷新页面重试"); } dappMemberEntity.setAccountType(agentLevelSetUpdateDto.getLevelCode()); dappMemberDao.updateById(dappMemberEntity); return new FebsResponse().success(); } @Override public IPage findMallGoodsListInPage(MallGoodsQueryDto queryDto) { Page page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize()); return dappMemberDao.selectMallGoodsListQueryInPage(queryDto, page); } @Override public IPage findMallOrderListInPage(MallOrderQueryDto queryDto) { DappMemberEntity member = LoginUserUtil.getAppUser(); queryDto.setMemberId(member.getId()); Page page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize()); return dappMemberDao.selectMallOrderListQueryInPage(queryDto, page); } @Override public MallOrderListVo findOrderDetailsById(Long id) { DappMemberEntity member = LoginUserUtil.getAppUser(); MallOrderListVo mallOrderListVo = dappMemberDao.selectMallOrderListVoById(id); List mallOrderItemVoList = dappMemberDao.selectMallOrderItemVoByOrderId(id); mallOrderListVo.setItems(mallOrderItemVoList); return mallOrderListVo; } @Override public MallGoodsListVo findGoodsDetailsById(Long id) { DappMemberEntity member = LoginUserUtil.getAppUser(); MallGoodsListVo mallGoodsListVo = dappMemberDao.selectMallGoodsListVoById(id); return mallGoodsListVo; } @Override @Transactional public Long createOrder(AddOrderDto addOrderDto) { DappMemberEntity member = LoginUserUtil.getAppUser(); /** * 1、商品是否上架 * 2、用户余额是否足够 */ MallGoods mallGoods = mallGoodsMapper.selectById(addOrderDto.getGoodsId()); if(ObjectUtil.isEmpty(mallGoods)){ throw new FebsException("商品不存在"); } if(MallGoods.ISSALE_STATUS_DISABLED == mallGoods.getIsSale()){ throw new FebsException("商品已下架"); } DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(member.getId()); if(ObjectUtil.isEmpty(dappWalletCoinEntity)){ throw new FebsException("余额不足"); } BigDecimal presentPrice = new BigDecimal(mallGoods.getPresentPrice()); BigDecimal totalAmount = presentPrice.multiply(new BigDecimal(addOrderDto.getGoodsCnt())).setScale(2,BigDecimal.ROUND_DOWN); if(BigDecimal.ZERO.compareTo(totalAmount) >= 0){ throw new FebsException("商品异常"); } BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount(); if(totalAmount.compareTo(availableAmount) > 0){ throw new FebsException("余额不足"); } /** * 生成一条待支付的订单 */ String orderNo = MallUtils.getOrderNum(); MallOrderInfo mallOrderInfo = new MallOrderInfo(); mallOrderInfo.setOrderNo(orderNo); mallOrderInfo.setMemberId(member.getId()); mallOrderInfo.setOrderTime(DateUtil.date()); mallOrderInfo.setAmount(totalAmount); mallOrderInfo.setStatus(MallOrderInfo.STATUS_WAIT); mallOrderInfo.setOrderType(1); mallOrderInfoMapper.insert(mallOrderInfo); MallOrderItem mallOrderItem = new MallOrderItem(); mallOrderItem.setOrderId(mallOrderInfo.getId()); mallOrderItem.setGoodsId(addOrderDto.getGoodsId()); mallOrderItem.setGoodsName(mallGoods.getGoodsName()); mallOrderItem.setCnt(addOrderDto.getGoodsCnt()); mallOrderItem.setPrice(presentPrice); mallOrderItem.setAmount(totalAmount); mallOrderItemMapper.insert(mallOrderItem); return mallOrderInfo.getId(); } @Override @Transactional public void cancelOrder(Long id) { DappMemberEntity member = LoginUserUtil.getAppUser(); MallOrderInfo orderInfo = mallOrderInfoMapper.selectById(id); if (ObjectUtil.isEmpty(orderInfo)) { throw new FebsException("订单异常"); } if (MallOrderInfo.STATUS_WAIT != orderInfo.getStatus()) { throw new FebsException("只能取消待支付的订单"); } orderInfo.setStatus(MallOrderInfo.STATUS_CANCEL); orderInfo.setCancelType(MallOrderInfo.CANCEL_BY_SELF); mallOrderInfoMapper.updateById(orderInfo); } @Override @Transactional public void payOrder(Long id) { DappMemberEntity member = LoginUserUtil.getAppUser(); MallOrderInfo orderInfo = mallOrderInfoMapper.selectById(id); if (ObjectUtil.isEmpty(orderInfo)) { throw new FebsException("订单异常"); } if (MallOrderInfo.STATUS_WAIT != orderInfo.getStatus()) { throw new FebsException("只能支付待支付的订单"); } /** * 限制用户的购买总量 */ //实际可购买数量 BigDecimal achieveAva = BigDecimal.ZERO; DappMemberEntity dappMemberEntity = dappMemberDao.selectById(member.getId()); String accountType = dappMemberEntity.getAccountType(); //普通会员的购买上线 if(MemberLevelEnum.MEMBER.getType().equals(accountType)){ DataDictionaryCustom memberBuyMaxAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.MEMBER_BUY_MAX_AMOUNT.getType(), DataDictionaryEnum.MEMBER_BUY_MAX_AMOUNT.getCode() ); achieveAva = new BigDecimal(ObjectUtil.isEmpty(memberBuyMaxAmountDic) ? "1000" : memberBuyMaxAmountDic.getValue()); }else{ DataDictionaryCustom memberBuyMaxAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( "TEAM_LEVEL",accountType ); if(ObjectUtil.isEmpty(memberBuyMaxAmountDic)){ achieveAva = new BigDecimal("1000"); }else{ TeamLevelPerk adminAgentInfo = JSONObject.parseObject(memberBuyMaxAmountDic.getValue(), TeamLevelPerk.class); BigDecimal buyMaxAmount = adminAgentInfo.getBuyMaxAmount(); achieveAva = buyMaxAmount; } } List mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberId(dappMemberEntity.getId()); if(CollUtil.isNotEmpty(mallAchieveRecords)){ BigDecimal reduce = mallAchieveRecords.stream().map(MallAchieveRecord::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add); achieveAva = achieveAva.subtract(reduce); } if(BigDecimal.ZERO.compareTo(achieveAva) >= 0){ throw new FebsException("用户无法购买"); } BigDecimal totalAmount = orderInfo.getAmount(); if(achieveAva.compareTo(totalAmount) < 0){ throw new FebsException("用户最多购买"+achieveAva.setScale(2,BigDecimal.ROUND_DOWN)+"USDT"); } DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(member.getId()); BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount(); if(totalAmount.compareTo(availableAmount) > 0){ throw new FebsException("余额不足"); } orderInfo.setPayTime(DateUtil.date()); String payOrderNo = MallUtils.getOrderNum("PAY"); orderInfo.setPayOrderNo(payOrderNo); orderInfo.setPayMethod("余额支付"); orderInfo.setPayResult("成功"); orderInfo.setStatus(MallOrderInfo.STATUS_PAY); mallOrderInfoMapper.updateById(orderInfo); /** * 更新用户余额 */ dappWalletCoinDao.reduceTotalAndAvailableByMemberId(member.getId(),totalAmount); DappFundFlowEntity donateScoreFlow = new DappFundFlowEntity( member.getId(), totalAmount.negate(), FundFlowEnum.PAY_ORDER.getCode(), 2, BigDecimal.ZERO, payOrderNo, id); /** * 支付成功，消费后成有效账户后可分享（有效用户可推广） */ if(2 == dappMemberEntity.getActiveStatus()){ dappMemberEntity.setActiveStatus(1); dappMemberDao.updateById(dappMemberEntity); } /** * todo 发送一条订单出的消息 */ chainProducer.sendSpeedPayOrderMsg(id); chainProducer.sendAutoLevelUpTeamMsg(member.getId()); } @Override public FebsResponse packageInfo() { Long memberId = LoginUserUtil.getAppUser().getId(); PackageInfoVo packageInfoVo = new PackageInfoVo(); DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(), DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode() ); BigDecimal packageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "0" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); packageInfoVo.setPackageTotalScore(packageTotalScore); DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(), DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode() ); BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); packageInfoVo.setPackageScorePrice(packageScorePrice); DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); BigDecimal balance = dappMemberEntity.getBalance(); packageInfoVo.setPackageMemberScore(balance); return new FebsResponse().success().data(packageInfoVo); } @Override public FebsResponse salePackage(SalePackageDto salePackageDto) { Long memberId = LoginUserUtil.getAppUser().getId(); BigDecimal cnt = salePackageDto.getCnt(); DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); BigDecimal balance = dappMemberEntity.getBalance(); if(BigDecimal.ZERO.compareTo(cnt) >= 0){ throw new FebsException("资产不足"); } if(cnt.compareTo(balance) > 0){ throw new FebsException("资产不足"); } DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(), DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode() ); BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); //卖出资产乘以价格获取到预期获取的总额 BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN); //资产包卖出划入底池比例 DataDictionaryCustom packageToPoorPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getType(), DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getCode() ); BigDecimal packageToPoorPercent = new BigDecimal(ObjectUtil.isEmpty(packageToPoorPercentDic) ? "0.1" : packageToPoorPercentDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); //划入底池的金额 BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN); //生成一条资金流水 DappFundFlowEntity scoreFlow = new DappFundFlowEntity( memberId, totalAmount.subtract(poorAmount), FundFlowEnum.SALE_PACKAGE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_ING, poorAmount); dappFundFlowDao.insert(scoreFlow); //卖出积分直接销毁。 DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(), DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode() ); BigDecimal packageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); BigDecimal avaPackageTotalScore = packageTotalScore.subtract(cnt); packageTotalScoreDic.setValue(avaPackageTotalScore.toString()); dataDictionaryCustomMapper.updateById(packageTotalScoreDic); //更新USDT底池 DataDictionaryCustom packagePoorDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_POOR.getType(), DataDictionaryEnum.PACKAGE_POOR.getCode() ); BigDecimal packagePoor = new BigDecimal(ObjectUtil.isEmpty(packagePoorDic) ? "0" : packagePoorDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); BigDecimal avaPackagePoor = packagePoor.add(poorAmount); packagePoorDic.setValue(avaPackagePoor.toString()); dataDictionaryCustomMapper.updateById(packagePoorDic); //计算当前价格 BigDecimal divide = avaPackagePoor.divide(avaPackageTotalScore, 2, BigDecimal.ROUND_DOWN); packageScorePriceDic.setValue(divide.toString()); dataDictionaryCustomMapper.updateById(packageScorePriceDic); return null; } public static List> partitionList(List originalList, int partitionSize) { List> partitionedList = new ArrayList<>(); int size = originalList.size(); for (int i = 0; i < size; i += partitionSize) { int end = Math.min(size, i + partitionSize); List sublist = originalList.subList(i, end); partitionedList.add(sublist); } return partitionedList; } /** * 获取用户的大小区业绩 * @param memberId * @return */ private HashMap getMaxMinAchieve(Long memberId) { //业绩集合 List list = new ArrayList<>(); //总业绩 BigDecimal teamIncomeMax = BigDecimal.ZERO; //所有直推团队，就是这个会员的所有区域的业绩。 DappMemberEntity member = dappMemberDao.selectById(memberId); // 直推用户 List childs = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId()); List childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList()); for(String inviteId : childsInviteIds){ BigDecimal totalIncomeMember = dappMemberDao.selectAllAchieveByInviteId(inviteId); teamIncomeMax = teamIncomeMax.add(totalIncomeMember); list.add(totalIncomeMember); } HashMap objectObjectHashMap = new HashMap<>(); if(CollUtil.isNotEmpty(list)){ //最大区的业绩 BigDecimal maxAchieve = list.stream().max(BigDecimal::compareTo).get(); BigDecimal minAchieve = teamIncomeMax.subtract(maxAchieve); objectObjectHashMap.put(AppContants.MAXACHIEVE,maxAchieve); objectObjectHashMap.put(AppContants.MINACHIEVE,minAchieve); }else{ objectObjectHashMap.put(AppContants.MAXACHIEVE,BigDecimal.ZERO); objectObjectHashMap.put(AppContants.MINACHIEVE,BigDecimal.ZERO); } return objectObjectHashMap; } // public TeamListVo buildTeamMatrix(Long memberId) { // DappMemberEntity member = dappMemberDao.selectById(memberId); // TeamListVo teamListVo = new TeamListVo(); // teamListVo.setAddress(member.getAddress()); // teamListVo.setAccountType(member.getAccountType()); // List dappMemberEntities = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId()); // teamListVo.setDirectCnt(dappMemberEntities.size()); // DappUsdtPerkEntity dappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(memberId); // teamListVo.setAchieve(ObjectUtil.isEmpty(dappUsdtPerkEntity) ? BigDecimal.ZERO : dappUsdtPerkEntity.getAchieveAmount()); // // if (CollUtil.isEmpty(dappMemberEntities)) { // return teamListVo; // } // // List list = new ArrayList<>(); // for (DappMemberEntity childNode : dappMemberEntities) { // list.add(buildTeamMatrix(childNode.getId())); // } // teamListVo.setChildren(list); // return teamListVo; // } }