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

KKSU

2024-05-20 487436c06905bf5599d062990c90d5cc4b383733

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

 src/main/java/cc/mrbird/febs/mall/service/IMemberProfitService.java

@@ -1,5 +1,8 @@
package cc.mrbird.febs.mall.service;

import cc.mrbird.febs.mall.entity.MallMember;

import java.math.BigDecimal;
import java.util.Date;

/**
@@ -61,4 +64,6 @@
    void fcmOrderSellInsureMsg(Long sellRecordId);

    void fcmOrderBuyCancelMsg(Long buyRecordId);

    void createPerk(MallMember mallMember, BigDecimal basicPerkDirect);
}

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

@@ -1298,10 +1298,26 @@
                        /**
                         * 如果用户是冻结，则直接销毁
                         */
                        Integer isFrozen = directMember.getIsFrozen();
                        if(ProductEnum.MEMBER_FROZEN.getValue() == isFrozen){
                        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)));
                        }
                    }
                }
            }
        }
    }

                            MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(directMember.getId());

    @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;
                            }
@@ -1310,7 +1326,7 @@
                            //插入一条流水记录
                            String orderNo = MallUtils.getOrderNum("FNFTW");
                            mallMoneyFlowService.addMoneyFlow(
                                    directMember.getId(),
                    mallMember.getId(),
                                    basicPerkDirect.negate(),
                                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
                                    orderNo,
@@ -1320,22 +1336,21 @@
                                    AppContants.MEMBER_FLOW_ING);

                        }else {

                            MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(directMember.getId());
            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(directMember.getId());
            MallMemberAmount mallMemberAmountNft = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
                            mallMemberAmountNft.setTrendsNft(mallMemberAmountNft.getTrendsNft().add(basicPerkDirect));
                            mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountNft);

                            //插入一条流水记录
                            String orderNo = MallUtils.getOrderNum("NFT");
                            mallMoneyFlowService.addMoneyFlow(
                                    directMember.getId(),
                    mallMember.getId(),
                                    basicPerkDirect,
                                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getValue(),
                                    orderNo,
@@ -1343,10 +1358,6 @@
                                    FlowTypeNewEnum.NFT.getValue(),
                                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getDescrition(),
                                    AppContants.MEMBER_FLOW_DONE);
                        }
                    }
                }
            }
        }
    }