blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-05-07 237dc82b539966a08fca13bbedbeaafd0822aff2 
 src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java


@@ -3,14 +3,15 @@


import cc.mrbird.febs.common.enumerates.FlowTypeEnum;


import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;


import cc.mrbird.febs.common.enumerates.ScoreFlowTypeEnum;


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


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


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


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


import cc.mrbird.febs.mall.mapper.MallMemberLevelMapper;


import cc.mrbird.febs.mall.mapper.MallMemberMapper;


import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper;


import cc.mrbird.febs.mall.service.IApiMallGoodsService;


import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;


import cc.mrbird.febs.mall.service.IApiMallOrderInfoService;


import cc.mrbird.febs.mall.service.IMallMoneyFlowService;


import cc.mrbird.febs.rabbit.producter.AgentProducer;


import cc.mrbird.febs.vip.entity.MallVipBenefits;


import cc.mrbird.febs.vip.entity.MallVipConfig;


import cc.mrbird.febs.vip.mapper.MallVipConfigMapper;


@@ -18,16 +19,23 @@


import cc.mrbird.febs.vip.service.IVipCommonService;


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.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.math.BigDecimal;


import java.math.RoundingMode;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.logging.Handler;


import java.util.stream.Collectors;




@Slf4j


@Service


@@ -40,6 +48,9 @@


    private final IApiMallMemberWalletService mallMemberWalletService;


    private final MallMemberMapper mallMemberMapper;


    private final MallVipConfigMapper mallVipConfigMapper;


    private final AgentProducer agentProducer;


    private final IApiMallGoodsService mallGoodsService;


    private final MallMemberLevelMapper mallMemberLevelMapper;




    @Override


    @Transactional(rollbackFor = Exception.class)


@@ -48,23 +59,61 @@


        if (mallOrderInfo == null) {


            return;


        }


        BigDecimal amount = mallOrderInfo.getAmount();




        Long memberId = mallOrderInfo.getMemberId();


        MallVipBenefits mallVipBenefits = mallVipConfigService.hasVipBenefits(memberId);


        MallMember member = mallMemberMapper.selectById(memberId);


        /**


         * 一级返佣


         */


        String referrerId = member.getReferrerId();


        if(StrUtil.isEmpty(referrerId)){


            return;


        }


        MallMember mallMemberRef = mallMemberMapper.selectInfoByInviteId(referrerId);


        QueryWrapper<MallMemberLevel> mallMemberLevelQueryWrapper = new QueryWrapper<>();


        mallMemberLevelQueryWrapper.eq("member_id",mallMemberRef.getId());


        MallMemberLevel mallMemberLevelRef = mallMemberLevelMapper.selectOne(mallMemberLevelQueryWrapper);


        if(ObjectUtil.isNotEmpty(mallMemberLevelRef)){


            BigDecimal levelPercent = mallMemberLevelRef.getLevelPercent();




        BigDecimal multiple = BigDecimal.ONE;


        String name = "";


        if (mallVipBenefits != null) {


            multiple = mallVipBenefits.getScoreMultiple();


            name = mallVipBenefits.getName();


            BigDecimal refAmount = amount.multiply(levelPercent.multiply(new BigDecimal(0.01))).setScale(2, BigDecimal.ROUND_DOWN);


            mallMemberWalletService.addBalance(refAmount,mallMemberRef.getId());


            mallMoneyFlowService.addMoneyFlow(


                    mallMemberRef.getId(),


                    refAmount,


                    ScoreFlowTypeEnum.LEVEL_PERK.getValue(),


                    mallOrderInfo.getOrderNo(),


                    FlowTypeEnum.BALANCE.getValue(),


                    StrUtil.format(ScoreFlowTypeEnum.LEVEL_PERK.getDesc(),mallOrderInfo.getOrderNo()),


                    2);


        }




        double sum = mallOrderInfo.getItems().stream().map(MallOrderItem::getAmount).mapToDouble(BigDecimal::doubleValue).sum();


        /**


         * 两级返佣


         */


        String referrerIdRef = mallMemberRef.getReferrerId();


        if(StrUtil.isEmpty(referrerIdRef)){


            return;


        }


        MallMember mallMemberRefTwo = mallMemberMapper.selectInfoByInviteId(referrerIdRef);


        QueryWrapper<MallMemberLevel> mallMemberLevelQueryWrapperTwo = new QueryWrapper<>();


        mallMemberLevelQueryWrapperTwo.eq("member_id",mallMemberRefTwo.getId());


        MallMemberLevel mallMemberLevelRefTwo = mallMemberLevelMapper.selectOne(mallMemberLevelQueryWrapperTwo);


        if(ObjectUtil.isNotEmpty(mallMemberLevelRefTwo)){


            BigDecimal levelPercentTwo = mallMemberLevelRefTwo.getLevelPercent();




        int score = multiple.multiply(BigDecimal.valueOf(sum)).intValue();




        mallMoneyFlowService.addMoneyFlow(memberId, new BigDecimal(score), ScoreFlowTypeEnum.BUY.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue(), name, 2);


        mallMemberWalletService.add(new BigDecimal(score), memberId, "prize_score");


            BigDecimal refAmountTwo = amount.multiply(levelPercentTwo.multiply(new BigDecimal(0.01))).setScale(2, BigDecimal.ROUND_DOWN);


            mallMemberWalletService.addBalance(refAmountTwo,mallMemberRefTwo.getId());


            mallMoneyFlowService.addMoneyFlow(


                    mallMemberRefTwo.getId(),


                    refAmountTwo,


                    ScoreFlowTypeEnum.LEVEL_PERK.getValue(),


                    mallOrderInfo.getOrderNo(),


                    FlowTypeEnum.BALANCE.getValue(),


                    StrUtil.format(ScoreFlowTypeEnum.LEVEL_PERK.getDesc(),mallOrderInfo.getOrderNo()),


                    2);


        }


    }




    @Override


@@ -141,6 +190,7 @@


            MallMember update = new MallMember();


            update.setId(member.getId());


            update.setLevel(nextLevelCode);


            update.setVipLevelTime(new Date());


            mallMemberMapper.updateById(update);


        }


    }