直推和间接直推的奖励各50%

KKSU

2024-05-20 464fd8a591958004fc45659cacd8a1f0f599866a

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

@@ -1205,10 +1205,10 @@
            );
            BigDecimal fcmPrice = new BigDecimal(fcmPriceDic.getValue());
            fcmPrice = fcmPrice.add(AppContants.FCM_BASIC_ADD_PRICE.multiply(divide));
            commonService.updateDataDic(
                    DataDictionaryEnum.FCM_PRICE.getType(),
                    DataDictionaryEnum.FCM_PRICE.getCode(),
                    fcmPrice.toString());
//            commonService.updateDataDic(
//                    DataDictionaryEnum.FCM_PRICE.getType(),
//                    DataDictionaryEnum.FCM_PRICE.getCode(),
//                    fcmPrice.toString());
        }
    }

@@ -1274,10 +1274,93 @@
                mallProductBuy.setPayTime(DateUtil.date());
                mallProductBuyMapper.updateById(mallProductBuy);

                MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(mallProductBuy.getMemberId());
                mallMemberAmount.setTotalPerk(mallMemberAmount.getTotalPerk().add(totalPerk));
                mallMemberAmountMapper.updateTotalPerkById(mallMemberAmount);

                /**
                 * 更新用户上级收益，冻结7天，7天时间到期自动释放到动态钱包
                 */
                Long memberId = mallProductBuy.getMemberId();
                MallMember mallMember = mallMemberMapper.selectById(memberId);
                if(ObjectUtil.isNotEmpty(mallMember)){
                    //直推
                    String referrerId = mallMember.getReferrerId();
                    MallMember directMember = mallMemberMapper.selectInfoByInviteId(referrerId);
                    if(ObjectUtil.isNotEmpty(directMember)){
                        BigDecimal basicPerkDirectPercent = new BigDecimal(dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                                DataDictionaryEnum.BASIC_PERK_DIRECT.getType(),
                                DataDictionaryEnum.BASIC_PERK_DIRECT.getCode()
                        ).getValue()).multiply(new BigDecimal("0.01"));

                        BigDecimal nftTotal = mallProductBuy.getNftTotal();
                        BigDecimal basicPerkDirect = nftTotal.multiply(basicPerkDirectPercent).setScale(2, BigDecimal.ROUND_DOWN);
                        /**
                         * 如果用户是冻结，则直接销毁
                         */
                        createPerk(directMember,basicPerkDirect.multiply(new BigDecimal("0.5")));
                        if(StrUtil.isNotEmpty(directMember.getReferrerId())){
                            MallMember directMemberDirect = mallMemberMapper.selectInfoByInviteId(directMember.getReferrerId());
                            createPerk(directMemberDirect,basicPerkDirect.multiply(new BigDecimal("0.5")));
                        }
                    }
                }
            }
        }
    }


    @Override
    public void createPerk(MallMember mallMember,BigDecimal basicPerkDirect){
        /**
         * 如果用户是冻结，则直接销毁
         */
        Integer isFrozen = mallMember.getIsFrozen();
        if(ProductEnum.MEMBER_FROZEN.getValue() == isFrozen){
            MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
            if(BigDecimal.ZERO.compareTo(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect)) >= 0){
                return;
            }
            mallMemberAmountMine.setTotalPerk(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect));
            mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmountMine);
            //插入一条流水记录
            String orderNo = MallUtils.getOrderNum("FNFTW");
            mallMoneyFlowService.addMoneyFlow(
                    mallMember.getId(),
                    basicPerkDirect.negate(),
                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
                    orderNo,
                    null,
                    FlowTypeNewEnum.NFT.getValue(),
                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
                    AppContants.MEMBER_FLOW_ING);

        }else {
            MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
            if(BigDecimal.ZERO.compareTo(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect)) >= 0){
                return;
            }
            mallMemberAmountMine.setTotalPerk(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect));
            mallMemberAmountMapper.updateTotalPerkById(mallMemberAmountMine);

            MallMemberAmount mallMemberAmountNft = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
            mallMemberAmountNft.setTrendsNft(mallMemberAmountNft.getTrendsNft().add(basicPerkDirect));
            mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountNft);

            //插入一条流水记录
            String orderNo = MallUtils.getOrderNum("NFT");
            mallMoneyFlowService.addMoneyFlow(
                    mallMember.getId(),
                    basicPerkDirect,
                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getValue(),
                    orderNo,
                    null,
                    FlowTypeNewEnum.NFT.getValue(),
                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getDescrition(),
                    AppContants.MEMBER_FLOW_DONE);
        }
    }

    @Override
    public void fcmOrderBuyCancelMsg(Long buyRecordId) {
        MallProductBuyRecord mallProductBuyRecord = mallProductBuyRecordMapper.selectById(buyRecordId);