抽奖

KKSU

2024-03-18 57ac3a35ac056f0a09d8a013e8f3da2ecfe8a7c6

 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java

@@ -83,7 +83,8 @@
        if (mallMember != null) {
            throw new FebsException("账号已使用，请重新注册。");
        }
        String userKey = registerDto.getUserKey();
        Integer selectCount = this.baseMapper.selectCount(null);
        String userKey = ShareCodeUtil.toSerialNumberCode(selectCount);
        MallMember mallMemberKey = this.baseMapper.selectByUserKey(userKey);
        if (mallMemberKey != null) {
            throw new FebsException("账号已使用，请重新注册。");
@@ -109,6 +110,7 @@
        mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL);
        mallMember.setLevel(AgentLevelEnum.ZERO_LEVEL.getCode());
        mallMember.setIsFrozen(ProductEnum.MEMBER_UNFROZEN.getValue());
        mallMember.setPartner(2);
//        mallMember.setSex("男");
//        mallMember.setBindPhone(registerDto.getAccount());

@@ -282,11 +284,14 @@
        Integer insureMinute = Integer.parseInt(ObjectUtil.isEmpty(insureMinuteDic) ? "60" : insureMinuteDic.getValue());
        mallMemberVo.setMinuteCnt(insureMinute);

        DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.AGENT_LEVEL, mallMember.getLevel());
        DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(mallMember.getLevel(), mallMember.getLevel());
        if (dic != null) {
            mallMemberVo.setLevelName(dic.getDescription());
        }else{
            mallMemberVo.setLevelName("非会员");
        }
        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
        mallMemberVo.setGsd(mallMemberAmount.getGsd());
        mallMemberVo.setStaticNft(mallMemberAmount.getStaticNft());
        mallMemberVo.setTrendsNft(mallMemberAmount.getTrendsNft());
        mallMemberVo.setFrozenNft(mallMemberAmount.getFrozenNft());
@@ -307,6 +312,9 @@

        Integer pickCount = mallProductBuyMapper.selectListByMemberIdAndState(id);
        mallMemberVo.setPickCount(pickCount);

        BigDecimal totalPerk = mallProductBuyMapper.selectTotalPerkByMemberId(mallMember.getId());
        mallMemberVo.setTotalPerk(totalPerk);
        return new FebsResponse().success().data(mallMemberVo);
    }

@@ -375,9 +383,75 @@

        MyTeamVo myTeamVo = new MyTeamVo();
        myTeamVo.setTeam(list);
        myTeamVo.setMyAchieve(this.baseMapper.selectAchieveByMemberId(mallMember.getInviteId(), 1));
        myTeamVo.setMyTeamAchieve(this.baseMapper.selectAchieveByMemberId(mallMember.getInviteId(), 2));
        BigDecimal myAchieve = this.baseMapper.selectAchieveByMemberId(mallMember.getInviteId(), 1);
        myTeamVo.setMyAchieve(myAchieve);
        BigDecimal myTeamAchieve = this.baseMapper.selectAchieveByMemberId(mallMember.getInviteId(), 2);
        myTeamVo.setMyTeamAchieve(myTeamAchieve.add(myAchieve));
        myTeamVo.setMyTeamCnt(this.baseMapper.selectAllChildAgentListByInviteId(mallMember.getInviteId()).size());
        return new FebsResponse().success().data(myTeamVo);
    }

    @Override
    public FebsResponse teamFcmList(TeamListDto teamListDto) {
        Long memberId = null;
        if (ObjectUtil.isEmpty(teamListDto.getId())) {
            memberId = LoginUserUtil.getLoginUser().getId();
        } else {
            memberId = teamListDto.getId();
        }

        MallMember mallMember = this.baseMapper.selectById(memberId);

        MyFcmTeamVo myTeamVo = new MyFcmTeamVo();
        myTeamVo.setMemberId(mallMember.getId());
        myTeamVo.setAccountLogin(mallMember.getAccountLogin());
        myTeamVo.setIsFrozen(mallMember.getIsFrozen());
        myTeamVo.setLevelName(MemberLevelNewEnum.ZERO_LEVEL.getLevelName(mallMember.getLevel()));
        BigDecimal myAchieveBuy = this.baseMapper.selectAchieveBuyByMemberId(mallMember.getInviteId(), 1);
        myTeamVo.setMyAchieveBuy(myAchieveBuy);
        BigDecimal myAchieveSell = this.baseMapper.selectAchieveSellByMemberId(mallMember.getInviteId(), 1);
        myTeamVo.setMyAchieveSell(myAchieveSell);
        BigDecimal myTeamAchieveBuy = this.baseMapper.selectAchieveBuyByMemberId(mallMember.getInviteId(), 2);
        myTeamVo.setMyTeamAchieveBuy(myTeamAchieveBuy.add(myAchieveBuy));
        BigDecimal myTeamAchieveSell = this.baseMapper.selectAchieveSellByMemberId(mallMember.getInviteId(), 2);
        myTeamVo.setMyTeamAchieveSell(myTeamAchieveSell.add(myAchieveSell));
        myTeamVo.setMyTeamMemberCnt(this.baseMapper.selectAllChildAgentListByInviteId(mallMember.getInviteId()).size());
        Integer buyCnt = this.baseMapper.selectAchieveBuyOrderCntByMemberId(mallMember.getInviteId());
        Integer sellCnt = this.baseMapper.selectAchieveSellOrderCntByMemberId(mallMember.getInviteId());
        myTeamVo.setMyTeamOrderCnt(buyCnt+sellCnt);

        List<MallMember> mallMembersDirects = this.baseMapper.selectChildAgentListByInviteId(mallMember.getInviteId());
        List<MyFcmTeamVo> list = new ArrayList<>();
        if(CollUtil.isNotEmpty(mallMembersDirects)){
            for(MallMember mallMembersDirect : mallMembersDirects){
                MyFcmTeamVo myTeamDirectVo = new MyFcmTeamVo();
                myTeamDirectVo.setMemberId(mallMembersDirect.getId());
                myTeamDirectVo.setAccountLogin(mallMembersDirect.getAccountLogin());
                myTeamDirectVo.setIsFrozen(mallMembersDirect.getIsFrozen());
                myTeamDirectVo.setLevelName(
                        dataDictionaryCustomMapper.selectDicDataByTypeAndCode(mallMembersDirect.getLevel(),mallMembersDirect.getLevel()).getDescription()
                );

                BigDecimal myAchieveBuyDirect = this.baseMapper.selectAchieveBuyByMemberId(mallMembersDirect.getInviteId(), 1);
                myTeamDirectVo.setMyAchieveBuy(myAchieveBuyDirect);
                BigDecimal myAchieveSellDirect = this.baseMapper.selectAchieveSellByMemberId(mallMembersDirect.getInviteId(), 1);
                myTeamDirectVo.setMyAchieveSell(myAchieveSellDirect);
                BigDecimal myTeamAchieveBuyDirect = this.baseMapper.selectAchieveBuyByMemberId(mallMembersDirect.getInviteId(), 2);
                myTeamDirectVo.setMyTeamAchieveBuy(myTeamAchieveBuyDirect.add(myAchieveBuyDirect));
                BigDecimal myTeamAchieveSellDirect = this.baseMapper.selectAchieveSellByMemberId(mallMembersDirect.getInviteId(), 2);
                myTeamDirectVo.setMyTeamAchieveSell(myTeamAchieveSellDirect.add(myAchieveSellDirect));
                myTeamDirectVo.setMyTeamMemberCnt(this.baseMapper.selectAllChildAgentListByInviteId(mallMembersDirect.getInviteId()).size());
                Integer buyCntDirect = this.baseMapper.selectAchieveBuyOrderCntByMemberId(mallMembersDirect.getInviteId());
                Integer sellCntDirect = this.baseMapper.selectAchieveSellOrderCntByMemberId(mallMembersDirect.getInviteId());
                myTeamDirectVo.setMyTeamOrderCnt(buyCntDirect+sellCntDirect);
                list.add(myTeamDirectVo);
            }
        }

        myTeamVo.setTeam(list);



        return new FebsResponse().success().data(myTeamVo);
    }

@@ -419,7 +493,7 @@
        BigDecimal amount = transferDto.getAmount();
        int type = transferDto.getType();

        if(1 != type && 2 != type){
        if(1 != type && 2 != type && 3 != type){
            throw new FebsException("请选择互转类型");
        }
        Integer insideWith = loginMember.getInsideWith() == null ? 2 :loginMember.getInsideWith();
@@ -444,7 +518,6 @@
            throw new FebsException("交易密码错误");
        }

        BigDecimal avaAmount = transferDto.getAmount().setScale(2, BigDecimal.ROUND_DOWN);
        MallMemberAmount mallMemberAmountLogin = mallMemberAmountMapper.selectByMemberId(loginMember.getId());
        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
        if(1 == type){
@@ -475,7 +548,7 @@
        }
        if(2 == type){
            if (amount.compareTo(mallMemberAmountLogin.getTokenAva()) > 0) {
                throw new FebsException("门票不足");
                throw new FebsException("宝石不足");
            }
            mallMemberAmountLogin.setTokenAva(mallMemberAmountLogin.getTokenAva().subtract(amount));
            mallMemberAmountMapper.updateTokenAvaById(mallMemberAmountLogin);
@@ -498,6 +571,32 @@
                    loginMember.getId(),
                    FlowTypeNewEnum.TOKEN.getValue(),
                    MoneyFlowTypeNewEnum.TOKEN_INSIDE_IN.getDescrition());
        }
        if(3 == type){
            if (amount.compareTo(mallMemberAmountLogin.getTrendsNft()) > 0) {
                throw new FebsException("卡牌不足");
            }
            mallMemberAmountLogin.setTrendsNft(mallMemberAmountLogin.getTrendsNft().subtract(amount));
            mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountLogin);
            String orderNo = MallUtils.getOrderNum("NFT");
            mallMoneyFlowService.addMoneyFlow(
                    loginMember.getId(),
                    amount.negate(),
                    MoneyFlowTypeNewEnum.NFT_TRANS_OUT.getValue(),
                    orderNo,
                    mallMember.getId(),
                    FlowTypeNewEnum.NFT.getValue(),
                    MoneyFlowTypeNewEnum.NFT_TRANS_OUT.getDescrition());
            mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(amount));
            mallMemberAmountMapper.updateTrendsNftById(mallMemberAmount);
            mallMoneyFlowService.addMoneyFlow(
                    mallMember.getId(),
                    amount,
                    MoneyFlowTypeNewEnum.NFT_TRANS_IN.getValue(),
                    orderNo,
                    loginMember.getId(),
                    FlowTypeNewEnum.NFT.getValue(),
                    MoneyFlowTypeNewEnum.NFT_TRANS_IN.getDescrition());
        }
    }

@@ -791,10 +890,10 @@

        MallMemberPayment mallMemberPayment = mallMemberPaymentMapper.selectByMemberId(memberId);
        mallMemberPayment.setWxQrcode(updatePaymentDto.getWxQrcode());
        mallMemberPayment.setAliQrcode(updatePaymentDto.getAliQrcode());
//        mallMemberPayment.setAliQrcode(updatePaymentDto.getAliQrcode());
        mallMemberPayment.setBankName(updatePaymentDto.getBankName());
        mallMemberPayment.setBankNo(updatePaymentDto.getBankNo());
        mallMemberPayment.setBank(updatePaymentDto.getBank());
//        mallMemberPayment.setBankNo(updatePaymentDto.getBankNo());
//        mallMemberPayment.setBank(updatePaymentDto.getBank());
        mallMemberPayment.setPhone(updatePaymentDto.getPhone());
        mallMemberPayment.setUsdtTongdao(updatePaymentDto.getUsdtTongdao());
        mallMemberPayment.setUsdtAddress(updatePaymentDto.getUsdtAddress());
@@ -806,6 +905,7 @@
    @Override
    public FebsResponse unfreeze(UnfreezeDto unfreezeDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        MallMember loginMember = this.baseMapper.selectById(memberId);
        /**
         * 判断账号是否冻结
         * 判断账号FCM代币是否足够
@@ -825,31 +925,31 @@
                DataDictionaryEnum.MEMBER_FROZEN_FCM_CNT.getCode()
        );
        BigDecimal memberFrozenFcmCnt = new BigDecimal(memberFrozenFcmCntDic.getValue());
        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(unfreezeMemberId);
        BigDecimal fcmCntAva = mallMemberAmount.getFcmCntAva();
        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
        BigDecimal fcmCntAva = mallMemberAmount.getTokenAva();
        if(memberFrozenFcmCnt.compareTo(fcmCntAva) > 0){
            throw new FebsException("解除冻结需要FCM的数量为：" + fcmCntAva);
            throw new FebsException("激活需要宝石的数量为：" + fcmCntAva);
        }
        if(2 == unfreezeDto.getType()){
            List<MallMember> mallMembers = this.baseMapper.selectByRefererId(mallMember.getInviteId());
            List<MallMember> mallMembers = this.baseMapper.selectByRefererId(loginMember.getInviteId());
            List<Long> collectMemberIds = mallMembers.stream().map(MallMember::getId).collect(Collectors.toList());
            if(!collectMemberIds.contains(unfreezeMemberId)){
                throw new FebsException("直接推荐人才能解除账户的冻结状态");
            }
        }
        BigDecimal fcmCntAvaSub = fcmCntAva.subtract(memberFrozenFcmCnt);
        mallMemberAmount.setFcmCntAva(fcmCntAvaSub);
        mallMemberAmount.setTokenAva(fcmCntAvaSub);
        mallMemberAmountMapper.updateById(mallMemberAmount);
        mallMember.setIsFrozen(ProductEnum.MEMBER_UNFROZEN.getValue());
        this.baseMapper.updateById(mallMember);

        mallMoneyFlowService.addMoneyFlow(
                mallMember.getId(),
                memberId,
                memberFrozenFcmCnt.negate(),
                MoneyFlowTypeNewEnum.UNFREEZE_USER.getValue(),
                MallUtils.getOrderNum(),
                memberId,
                FlowTypeNewEnum.FCM_COIN.getValue(),
                FlowTypeNewEnum.TOKEN.getValue(),
                MoneyFlowTypeNewEnum.UNFREEZE_USER.getDescrition());

        return new FebsResponse().success().message("操作成功");