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.*; import cc.mrbird.febs.dapp.mapper.*; import cc.mrbird.febs.dapp.service.DappMemberService; import cc.mrbird.febs.dapp.soccer.entity.SoccerLeagues; 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.DateTime; 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; private final DappAccountMoneyChangeDao dappAccountMoneyChangeDao; private final MallAddressInfoMapper mallAddressInfoMapper; private final MallGoodsCategoryMapper mallGoodsCategoryMapper; private final PlatformBannerMapper platformBannerMapper; private final MallGoodsImagesMapper goodsImagesMapper; private final MemberCoinWithdrawDao memberCoinWithdrawDao; @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.selectMemberInfoByInviteId(connectDto.getInviteId()); if (parent == null) { throw new FebsException("recommender is not exist"); } referenceID = parent.getInviteId(); } else { connectDto.setInviteId(null); } member = insertMember(connectDto.getAddress(), referenceID,nodeType); } DappMemberEntity dappMemberEntity = dappMemberDao.selectById(member.getId()); if(2 == dappMemberEntity.getChangeAble()){ throw new FebsException("账号已冻结"); } 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(); // List mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberId(memberId); List mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberIdAndScore(memberId); BigDecimal myShareAchieve = BigDecimal.ZERO; if(CollUtil.isNotEmpty(mallAchieveRecords)){ Date payTime = mallAchieveRecords.get(0).getPayTime(); //下第一单之后的共享区全部业绩 myShareAchieve = mallAchieveRecordMapper.selectAchieveTotalByCreateTime(payTime); } memberEntity.setMyShareAchieve(myShareAchieve); BigDecimal totalIncomeMember = dappMemberDao.selectAllAchieveByRefId(memberEntity.getInviteId()); memberEntity.setMyTeamAchieve(totalIncomeMember); BigDecimal withdrawAmount = memberCoinWithdrawDao.selectByMemberIdAndStatus(memberId, MemberCoinWithdrawEntity.STATUS_YES); memberEntity.setWithdrawAmount(withdrawAmount); } } 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()); } } myTeamVo.setTeam(list); } 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()); Integer waitPayCnt = dappMemberDao.selectOrderCntByMemberIdAndStatus(member.getId(),1); Integer payCnt = dappMemberDao.selectOrderCntByMemberIdAndStatus(member.getId(),2); Integer cancelCnt = dappMemberDao.selectOrderCntByMemberIdAndStatus(member.getId(),3); dappMemberInfoVo.setWaitPayCnt(waitPayCnt); dappMemberInfoVo.setPayCnt(payCnt); dappMemberInfoVo.setCancelCnt(cancelCnt); // List mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberId(member.getId()); List mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberIdAndScore(member.getId()); BigDecimal myShareAchieve = BigDecimal.ZERO; if(CollUtil.isNotEmpty(mallAchieveRecords)){ Date payTime = mallAchieveRecords.get(0).getPayTime(); //下第一单之后的共享区全部业绩 myShareAchieve = mallAchieveRecordMapper.selectAchieveTotalByCreateTime(payTime); } dappMemberInfoVo.setMyShareAchieve(myShareAchieve); 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.setActiveStatus(1); 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.setActiveStatus(2); dappMemberDao.updateById(dappMemberEntity); return new FebsResponse().success(); } @Override public List getAgentLevelOption() { List agentLevelOption = dataDictionaryCustomMapper.getAgentLevelOption(); AdminAgentLevelOptionTreeVo adminAgentLevelOptionTreeVo = new AdminAgentLevelOptionTreeVo(); adminAgentLevelOptionTreeVo.setId("MEMBER"); adminAgentLevelOptionTreeVo.setName("MEMBER"); agentLevelOption.add(adminAgentLevelOptionTreeVo); return agentLevelOption; } @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); long addressId = ObjectUtil.isEmpty(mallOrderListVo.getAddressId()) ? 0L : mallOrderListVo.getAddressId(); MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(addressId); if(ObjectUtil.isNotEmpty(mallAddressInfo)){ mallOrderListVo.setName(mallAddressInfo.getName()); mallOrderListVo.setPhone(mallAddressInfo.getPhone()); mallOrderListVo.setArea(mallAddressInfo.getArea()); mallOrderListVo.setAddress(mallAddressInfo.getAddress()); } return mallOrderListVo; } @Override public MallGoodsListVo findGoodsDetailsById(Long id) { DappMemberEntity member = LoginUserUtil.getAppUser(); MallGoodsListVo mallGoodsListVo = dappMemberDao.selectMallGoodsListVoById(id); List images = goodsImagesMapper.selectGoodsImagesByGoodsId(id); mallGoodsListVo.setImages(images); return mallGoodsListVo; } @Override @Transactional public Long createOrder(AddOrderDto addOrderDto) { DappMemberEntity member = LoginUserUtil.getAppUser(); DappMemberEntity dappMemberEntity = dappMemberDao.selectById(member.getId()); if(2 == dappMemberEntity.getChangeAble()){ throw new FebsException("账号已冻结"); } // DappMemberEntity member = dappMemberDao.selectById(1L); /** * 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.setDeliverType(addOrderDto.getDeliverType()); mallOrderInfo.setAddressId(addOrderDto.getAddressId()); // if(1 == addOrderDto.getDeliverType()){ // mallOrderInfo.setAddressId(addOrderDto.getAddressId()); // } 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(); DappMemberEntity member = dappMemberDao.selectById(1L); 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(); // DappMemberEntity member = dappMemberDao.selectById(1L); 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)); } 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(1); orderInfo.setStatus(MallOrderInfo.STATUS_PAY); orderInfo.setDeliverState(MallOrderInfo.DELIVER_STATUS_WAIT); mallOrderInfoMapper.updateById(orderInfo); /** * 更新用户余额 */ dappWalletCoinDao.reduceTotalAndAvailableByMemberId(member.getId(),totalAmount); DappFundFlowEntity donateScoreFlow = new DappFundFlowEntity( AccountFlowEnum.AMOUNT.getCode(), member.getId(), totalAmount.negate(), FundFlowEnum.PAY_ORDER.getCode(), 2, BigDecimal.ZERO, payOrderNo, id); dappFundFlowDao.insert(donateScoreFlow); /** * 支付成功，消费后成有效账户后可分享（有效用户可推广） */ 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(8, 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(); if(ObjectUtil.isEmpty(salePackageDto.getCnt())){ throw new FebsException("请输入正确的数量"); } DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); if(2 == dappMemberEntity.getChangeAble()){ throw new FebsException("账号已冻结"); } BigDecimal saleDoing = dappFundFlowDao.selectSumAmountByMemberIdAndTypeAndStatus(memberId, FundFlowEnum.SALE_PACKAGE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_ING); if(BigDecimal.ZERO.compareTo(saleDoing) < 0){ throw new FebsException("正在进行中，请稍后再试"); } BigDecimal balance = dappMemberEntity.getBalance(); if(BigDecimal.ZERO.compareTo(cnt) >= 0){ throw new FebsException("资产不足"); } if(cnt.compareTo(balance) > 0){ throw new FebsException("资产不足"); } //生成一条资金流水 DappFundFlowEntity scoreFlow = new DappFundFlowEntity( memberId, cnt, FundFlowEnum.SALE_PACKAGE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_ING, BigDecimal.ZERO); dappFundFlowDao.insert(scoreFlow); BigDecimal subtract = balance.subtract(cnt); dappMemberEntity.setBalance(subtract); dappMemberDao.updateById(dappMemberEntity); chainProducer.sendSalePackageMsg(scoreFlow.getId()); return new FebsResponse().success(); } @Override public FebsResponse updateSystemPay(MallSystemPayDto mallSystemPayDto) { Long memberId = mallSystemPayDto.getId(); DappMemberEntity mallMember = dappMemberDao.selectById(memberId); if(ObjectUtil.isEmpty(mallMember)){ return new FebsResponse().fail().message("系统繁忙，请刷新页面重试"); } BigDecimal bigDecimal = mallSystemPayDto.getAddBalance(); Integer type = mallSystemPayDto.getType(); if (type == 1) { dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,bigDecimal); //插入流水 DappFundFlowEntity amountFlow = new DappFundFlowEntity( memberId, bigDecimal, FundFlowEnum.SYSTEM_AMOUNT.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(amountFlow); } else if (type == 2) { dappWalletMineDao.addTotalAndaddAvailableById(bigDecimal,memberId); //插入流水 DappFundFlowEntity amountFlow = new DappFundFlowEntity( memberId, bigDecimal, FundFlowEnum.SYSTEM_SCORE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(amountFlow); } else if (type == 3) { BigDecimal balance = mallMember.getBalance(); balance = balance.add(bigDecimal); mallMember.setBalance(balance); dappMemberDao.updateById(mallMember); //插入流水 DappFundFlowEntity amountFlow = new DappFundFlowEntity( memberId, bigDecimal, FundFlowEnum.SYSTEM_PACKAGE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(amountFlow); } else { throw new FebsException("参数错误"); } return new FebsResponse().success(); } @Override public IPage memberMoneyFlow(QueryRequest request, DappMemberEntity dappMemberEntity) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage memberMoneyFlowVos = dappAccountMoneyChangeDao.selectMemberMoneyFlowInPage(page, dappMemberEntity); return memberMoneyFlowVos; } @Override public void delOrder(Long id) { Long memberId = LoginUserUtil.getAppUser().getId(); MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(id); if(MallOrderInfo.STATUS_PAY == mallOrderInfo.getStatus()){ throw new FebsException("当前订单不允许删除"); } mallOrderInfoMapper.deleteById(id); QueryWrapper objectQueryWrapper = new QueryWrapper<>(); objectQueryWrapper.eq("order_id", id); List mallOrderItems = mallOrderItemMapper.selectList(objectQueryWrapper); if(CollUtil.isNotEmpty(mallOrderItems)){ for(MallOrderItem mallOrderItem : mallOrderItems){ mallOrderItemMapper.deleteById(mallOrderItem.getId()); } } } @Override public void createAddress(CreateAddressDto createAddressDto) { Long memberId = LoginUserUtil.getAppUser().getId(); MallAddressInfo mallAddressInfo = new MallAddressInfo(); mallAddressInfo.setMemberId(memberId); mallAddressInfo.setName(createAddressDto.getName()); mallAddressInfo.setPhone(createAddressDto.getPhone()); mallAddressInfo.setArea(createAddressDto.getArea()); mallAddressInfo.setAddress(createAddressDto.getAddress()); mallAddressInfo.setIsDefault(1); mallAddressInfoMapper.insert(mallAddressInfo); } @Override public void delAddress(Long id) { Long memberId = LoginUserUtil.getAppUser().getId(); MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(id); if(ObjectUtil.isEmpty(mallAddressInfo)){ throw new FebsException("地址不存在"); } mallAddressInfo.setIsDefault(2); mallAddressInfoMapper.updateById(mallAddressInfo); } @Override public IPage findAddressList(MallGoodsQueryDto queryDto) { Long memberId = LoginUserUtil.getAppUser().getId(); Page page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize()); queryDto.setMemberId(memberId); return dappMemberDao.selectAddressListInPage(queryDto, page); } @Override public MallAddressInfo addressDetails(Long id) { Long memberId = LoginUserUtil.getAppUser().getId(); MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(id); return mallAddressInfo; } @Override public void updateAddress(CreateAddressDto createAddressDto) { Long memberId = LoginUserUtil.getAppUser().getId(); MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(createAddressDto.getId()); if(ObjectUtil.isEmpty(mallAddressInfo)){ throw new FebsException("地址不存在"); } mallAddressInfo.setName(createAddressDto.getName()); mallAddressInfo.setPhone(createAddressDto.getPhone()); mallAddressInfo.setArea(createAddressDto.getArea()); mallAddressInfo.setAddress(createAddressDto.getAddress()); mallAddressInfoMapper.updateById(mallAddressInfo); } @Override public List categoryList() { return mallGoodsCategoryMapper.selectRecommendCategoryList(); } @Override public FebsResponse balanceSystem() { List dappMemberEntities = dappMemberDao.selectAllMemberForInCome(); if(CollUtil.isNotEmpty(dappMemberEntities)){ //总划入 BigDecimal totalAdd = BigDecimal.ZERO; //资产包卖出划入底池比例 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); //资产包积分价格 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); //卖出积分直接销毁。 DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(), DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode() ); BigDecimal avaPackageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); 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); if(dappMemberEntities.size() <= 100){ for(DappMemberEntity dappMemberEntity : dappMemberEntities){ Long memberId = dappMemberEntity.getId(); BigDecimal balance = dappMemberEntity.getBalance(); //前一百卖出一半 BigDecimal cnt = balance.divide(new BigDecimal(2) , 2 ,BigDecimal.ROUND_DOWN); dappMemberEntity.setBalance(balance.subtract(cnt)); dappMemberDao.updateById(dappMemberEntity); //卖出资产乘以价格获取到预期获取的总额 BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN); //划入底池的金额 BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN); //实际获取的金额 BigDecimal realAmount = totalAmount.subtract(poorAmount); //生成一条资金流水 DappFundFlowEntity scoreFlow = new DappFundFlowEntity( memberId, realAmount, FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(scoreFlow); dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount); DappFundFlowEntity feeFlow = new DappFundFlowEntity( memberId, poorAmount.negate(), FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(feeFlow); totalAdd = totalAdd.add(poorAmount); } }else{ List mallAchieveRecordList = new ArrayList<>(); for(DappMemberEntity dappMemberEntity : dappMemberEntities){ //获取每个人的业绩 //业绩集合 List list = new ArrayList<>(); //所有直推团队，就是这个会员的所有区域的业绩。 BigDecimal teamIncomeMax = dappFundFlowDao.selectSumAmountByMemberIdAndTypeAndStatus(dappMemberEntity.getId(), FundFlowEnum.ADD_AMOUNT_REAL.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE); if(BigDecimal.ZERO.compareTo(teamIncomeMax) >= 0){ continue; } MallAchieveRecord mallAchieveRecord = new MallAchieveRecord(); mallAchieveRecord.setMemberId(dappMemberEntity.getId()); mallAchieveRecord.setAmount(teamIncomeMax); mallAchieveRecordList.add(mallAchieveRecord); // // 直推用户 // List childs = dappMemberDao.selectMemberInfoByRefererId(dappMemberEntity.getInviteId()); // List childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList()); // if(CollUtil.isNotEmpty(childsInviteIds)){ // for(String inviteId : childsInviteIds){ // BigDecimal totalIncomeMember = dappMemberDao.selectAchieveRecordByInviteId(inviteId); // teamIncomeMax = teamIncomeMax.add(totalIncomeMember); // list.add(totalIncomeMember); // } // //去掉一个最大区的业绩 // BigDecimal bigMax = list.stream().max(BigDecimal::compareTo).get(); // teamIncomeMax = teamIncomeMax.subtract(bigMax); // } } if(CollUtil.isNotEmpty(mallAchieveRecordList)){ //按照小区业绩的多少排名 List collect = mallAchieveRecordList .stream() .sorted(Comparator.comparing(MallAchieveRecord::getAmount)) .collect(Collectors.toList()); List top100Performances = collect.stream() .limit(100) .collect(Collectors.toList()); if(CollUtil.isNotEmpty(top100Performances)){ for(MallAchieveRecord mallAchieveRecord : top100Performances){ Long memberId = mallAchieveRecord.getMemberId(); DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); BigDecimal balance = dappMemberEntity.getBalance(); BigDecimal cnt = balance.divide(new BigDecimal(2) , 2 ,BigDecimal.ROUND_DOWN); dappMemberEntity.setBalance(balance.subtract(cnt)); dappMemberDao.updateById(dappMemberEntity); //卖出资产乘以价格获取到预期获取的总额 BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN); //划入底池的金额 BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN); //实际获取的金额 BigDecimal realAmount = totalAmount.subtract(poorAmount); //生成一条资金流水 DappFundFlowEntity scoreFlow = new DappFundFlowEntity( memberId, realAmount, FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(scoreFlow); dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount); DappFundFlowEntity feeFlow = new DappFundFlowEntity( memberId, poorAmount.negate(), FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(feeFlow); totalAdd = totalAdd.add(poorAmount); } } List remainingUsers = mallAchieveRecordList .stream() .sorted(Comparator.comparing(MallAchieveRecord::getAmount).reversed()) .skip(100) .collect(Collectors.toList()); if(CollUtil.isNotEmpty(remainingUsers)){ for(MallAchieveRecord mallAchieveRecord : remainingUsers){ Long memberId = mallAchieveRecord.getMemberId(); DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); BigDecimal balance = dappMemberEntity.getBalance(); BigDecimal cnt = balance; dappMemberEntity.setBalance(balance.subtract(cnt)); dappMemberDao.updateById(dappMemberEntity); //卖出资产乘以价格获取到预期获取的总额 BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN); //资产包卖出划入底池比例 //划入底池的金额 BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN); //实际获取的金额 BigDecimal realAmount = totalAmount.subtract(poorAmount); //生成一条资金流水 DappFundFlowEntity scoreFlow = new DappFundFlowEntity( memberId, realAmount, FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(scoreFlow); dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount); DappFundFlowEntity feeFlow = new DappFundFlowEntity( memberId, poorAmount.negate(), FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(feeFlow); totalAdd = totalAdd.add(poorAmount); } } } } BigDecimal avaPackagePoor = packagePoor.add(totalAdd); packagePoorDic.setValue(avaPackagePoor.toString()); dataDictionaryCustomMapper.updateById(packagePoorDic); //计算当前价格 BigDecimal divide = avaPackagePoor.divide(avaPackageTotalScore, 8, BigDecimal.ROUND_DOWN); packageScorePriceDic.setValue(divide.toString()); dataDictionaryCustomMapper.updateById(packageScorePriceDic); DappFundFlowEntity backFlow = new DappFundFlowEntity( 1L, totalAdd, FundFlowEnum.SYSTEM_SALE_PACKAGE_BACK.getCode(), DappFundFlowEntity.WITHDRAW_STATUS_AGREE, BigDecimal.ZERO); dappFundFlowDao.insert(backFlow); DappAKlineEntity dappAKlineEntity = new DappAKlineEntity(); dappAKlineEntity.setOpenPrice(divide); dappAKlineEntity.setType(1); dappAKlineMapper.insert(dappAKlineEntity); } return new FebsResponse().success(); } @Override public IPage shopAddressList(MallGoodsQueryDto queryDto) { Long memberId = LoginUserUtil.getAppUser().getId(); Page page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize()); queryDto.setMemberId(1L); return dappMemberDao.selectShopAddressListInPage(queryDto, page); } @Override public FebsResponse findAllBanner() { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.orderByAsc("is_top"); List paymentMethodList = platformBannerMapper.selectList(queryWrapper); return new FebsResponse().success().data(paymentMethodList); } @Override public void setDefaultAddress(Long id) { Long memberId = LoginUserUtil.getAppUser().getId(); MallAddressInfo addressInfo = mallAddressInfoMapper.selectById(id); if (addressInfo == null) { throw new FebsException("地址不存在"); } this.baseMapper.updateIsDefault(MallAddressInfo.IS_YOUR_N, memberId, null); this.baseMapper.updateIsDefault(MallAddressInfo.IS_YOUR_Y, memberId, id); } @Override public void confirmOrder(Long id) { Long memberId = LoginUserUtil.getAppUser().getId(); MallOrderInfo orderInfo = mallOrderInfoMapper.selectById(id); if (ObjectUtil.isEmpty(orderInfo)) { throw new FebsException("订单不存在"); } if (orderInfo.getStatus() != MallOrderInfo.STATUS_PAY) { throw new FebsException("该状态不能确认收货"); } if (orderInfo.getDeliverState() != MallOrderInfo.DELIVER_STATUS_DONE) { throw new FebsException("该状态不能确认收货"); } orderInfo.setDeliverState(MallOrderInfo.DELIVER_STATUS_OVER); mallOrderInfoMapper.updateById(orderInfo); } @Override public MallAddressInfo findAddress() { Long memberId = LoginUserUtil.getAppUser().getId(); MallAddressInfo mallAddressInfo = dappMemberDao.selectAddressOneByMemberId(memberId); return mallAddressInfo; } @Override public List packageRecord(PackageRecordDto packageRecordDto) { List packageRecordVos = new ArrayList<>(); Integer type = packageRecordDto.getType(); if(2 == type){ packageRecordVos = dappMemberDao.selectPackageRecordWeekInPage(DateUtil.beginOfWeek(DateUtil.date())); }else if(3 == type){ packageRecordVos = dappMemberDao.selectPackageRecordMonthInPage(DateUtil.date()); }else{ packageRecordVos = dappMemberDao.selectPackageRecordDayInPage(DateUtil.date()); } if(CollUtil.isNotEmpty(packageRecordVos)){ Integer packageNum = 0; for(PackageRecordVo packageRecordVo : packageRecordVos){ packageNum = packageNum + 1; packageRecordVo.setPackageNum(packageNum); } } return packageRecordVos; } @Override public List packageKline() { // return dappAKlineMapper.selectListByTypeAndLimit(2, 30); List akLineLimitVos = dappAKlineMapper.selectListByTypeAndLimitDesc(1, 60); List sortedList = akLineLimitVos.stream() .sorted((k1, k2) -> k1.getCreateTime().compareTo(k2.getCreateTime())) .collect(Collectors.toList()); return sortedList; } @Override public FebsResponse changeAbleYes(Long id) { DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id); if(ObjectUtil.isEmpty(dappMemberEntity)) { return new FebsResponse().fail().message("会员信息不存在"); } dappMemberEntity.setChangeAble(2); dappMemberDao.updateById(dappMemberEntity); return new FebsResponse().success(); } @Override public FebsResponse changeAbleNo(Long id) { DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id); if(ObjectUtil.isEmpty(dappMemberEntity)) { return new FebsResponse().fail().message("会员信息不存在"); } dappMemberEntity.setChangeAble(1); dappMemberDao.updateById(dappMemberEntity); redisUtils.hdel(AppContants.REDIS_KEY_SIGN, dappMemberEntity.getAddress()); redisUtils.hdel(AppContants.REDIS_KEY_MEMBER_INFO, dappMemberEntity.getAddress()); return new FebsResponse().success(); } @Override public IPage selectSoccerLeaguesInPage(SoccerLeagues soccerLeagues, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage soccerLeaguesIPage = dappMemberDao.selectSoccerLeaguesInPage(soccerLeagues, page); return soccerLeaguesIPage; } 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; // } }