|  |  |  | 
|---|
|  |  |  | package cc.mrbird.febs.mall.service.impl; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import cc.mrbird.febs.common.enumerates.*; | 
|---|
|  |  |  | import cc.mrbird.febs.common.utils.AppContants; | 
|---|
|  |  |  | import cc.mrbird.febs.common.utils.MallUtils; | 
|---|
|  |  |  | import cc.mrbird.febs.mall.entity.*; | 
|---|
|  |  |  | import cc.mrbird.febs.mall.mapper.*; | 
|---|
|  |  |  | 
|---|
|  |  |  | import cc.mrbird.febs.mall.vo.AdminTeamEqualsPerkVo; | 
|---|
|  |  |  | import cc.mrbird.febs.system.mapper.UserMapper; | 
|---|
|  |  |  | import cn.hutool.core.collection.CollUtil; | 
|---|
|  |  |  | import cn.hutool.core.math.MathUtil; | 
|---|
|  |  |  | import cn.hutool.core.util.ObjectUtil; | 
|---|
|  |  |  | import cn.hutool.core.util.StrUtil; | 
|---|
|  |  |  | import cn.hutool.json.JSONUtil; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private final DataDictionaryCustomMapper dataDictionaryCustomMapper; | 
|---|
|  |  |  | private final MallMemberMapper memberMapper; | 
|---|
|  |  |  | private final MallAchieveRecordMapper mallAchieveRecordMapper; | 
|---|
|  |  |  | private final MallOrderInfoMapper mallOrderInfoMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private final IApiMallMemberWalletService iApiMallMemberWalletService; | 
|---|
|  |  |  | 
|---|
|  |  |  | private final SqlSessionTemplate sqlSessionTemplate; | 
|---|
|  |  |  | private final IApiMallMemberWalletService memberWalletService; | 
|---|
|  |  |  | private final MallMoneyFlowMapper mallMoneyFlowMapper; | 
|---|
|  |  |  | private final MallMqRecordMapper mallMqRecordMapper; | 
|---|
|  |  |  | private final MallGoodsMapper mallGoodsMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private final ICommonService commonService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | 
|---|
|  |  |  | if(ObjectUtil.isEmpty(mallOrderInfo)){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(2 != mallOrderInfo.getStatus()){ | 
|---|
|  |  |  | //        if(2 != mallOrderInfo.getStatus()){ | 
|---|
|  |  |  | //            return; | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | BigDecimal amount = BigDecimal.ZERO; | 
|---|
|  |  |  | List<MallOrderItem> orderItems = this.mallOrderInfoMapper.getMallOrderItemByOrderId(orderId); | 
|---|
|  |  |  | if (CollUtil.isNotEmpty(orderItems)) { | 
|---|
|  |  |  | for (MallOrderItem orderItem : orderItems) { | 
|---|
|  |  |  | MallGoods mallGoods = mallGoodsMapper.selectById(orderItem.getGoodsId()); | 
|---|
|  |  |  | if (mallGoods.getIsNormal() == 2) { | 
|---|
|  |  |  | amount = amount.add( | 
|---|
|  |  |  | new BigDecimal(mallGoods.getPresentPrice()) | 
|---|
|  |  |  | .multiply(new BigDecimal(orderItem.getCnt())) | 
|---|
|  |  |  | .abs() | 
|---|
|  |  |  | .setScale(2,BigDecimal.ROUND_DOWN)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | amount = amount.subtract(mallOrderInfo.getScoreAmount()); | 
|---|
|  |  |  | if(BigDecimal.ZERO.compareTo(amount) >= 0){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 分享补贴 直推消费额10% | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | BigDecimal amount = mallOrderInfo.getAmount().subtract(mallOrderInfo.getScoreAmount()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Long memberId = mallOrderInfo.getMemberId(); | 
|---|
|  |  |  | MallMember mallMember = memberMapper.selectById(memberId); | 
|---|
|  |  |  | //补贴对象 直属上级 | 
|---|
|  |  |  | 
|---|
|  |  |  | //减少补贴额度 | 
|---|
|  |  |  | mallMemberWalletMapper.reduceTotalScoreById(sharePerkAmount, mallMemberWallet.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | reduceStar(mallMemberUp.getId(),sharePerkAmount); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | mallMemberWalletMapper.addBalanceById(sharePerkAmount, mallMemberWallet.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | mallMoneyFlowService.addMoneyFlow( | 
|---|
|  |  |  | 
|---|
|  |  |  | *  从最顶级级别的合伙人开始补贴 | 
|---|
|  |  |  | *      补贴完,把已经补贴的合伙人加入下一个级别 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | List<MallMember> sevenLevelRecord = getStarRecord(null,  MemberLevelEnum.SEVEN_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_SEVEN.getValue()); | 
|---|
|  |  |  | List<MallMember> sixLevelRecord = getStarRecord(sevenLevelRecord,  MemberLevelEnum.SIX_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_SIX.getValue()); | 
|---|
|  |  |  | List<MallMember> fifthLevelRecord = getStarRecord(sixLevelRecord,  MemberLevelEnum.FIFTH_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_FIVE.getValue()); | 
|---|
|  |  |  | List<MallMember> fourLevelRecord = getStarRecord(fifthLevelRecord,  MemberLevelEnum.FOUR_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_FOUR.getValue()); | 
|---|
|  |  |  | List<MallMember> thirdLevelRecord = getStarRecord(fourLevelRecord,  MemberLevelEnum.THIRD_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_THREE.getValue()); | 
|---|
|  |  |  | List<MallMember> secondLevelRecord = getStarRecord(thirdLevelRecord,  MemberLevelEnum.SECOND_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_TWO.getValue()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | DataDictionaryCustom perkAgentAchieveTotalDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_TOTAL.getType(), | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_TOTAL.getCode()); | 
|---|
|  |  |  | BigDecimal perkAgentAchieveTotal = new BigDecimal(perkAgentAchieveTotalDic.getValue()); | 
|---|
|  |  |  | //星级奖励百分比等于每个级别的累计之和 | 
|---|
|  |  |  | List<DataDictionaryCustom> starPerkDics = dataDictionaryCustomMapper.selectDicByType( | 
|---|
|  |  |  | "AGENT_LEVEL_REQUIRE"); | 
|---|
|  |  |  | BigDecimal totalProfitProp = BigDecimal.ZERO; | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(starPerkDics)){ | 
|---|
|  |  |  | for(DataDictionaryCustom starPerkDic : starPerkDics){ | 
|---|
|  |  |  | String starPerkStr = starPerkDic.getValue(); | 
|---|
|  |  |  | AgentInfo agentInfo = JSONObject.parseObject(starPerkStr, AgentInfo.class); | 
|---|
|  |  |  | BigDecimal profitProp = agentInfo.getProfitProp().abs().divide(new BigDecimal(100)); | 
|---|
|  |  |  | String code = starPerkDic.getCode(); | 
|---|
|  |  |  | //存在当前级别的会员,则加上这个比例的补贴 | 
|---|
|  |  |  | List<MallMember> mallMembers = memberMapper.selectByLevel(code); | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(mallMembers)){ | 
|---|
|  |  |  | totalProfitProp = totalProfitProp.add(profitProp); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(totalProfitProp.compareTo(BigDecimal.ZERO) > 0){ | 
|---|
|  |  |  | BigDecimal perkTotal = amount.multiply(totalProfitProp).setScale(2,BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  | perkAgentAchieveTotal = perkAgentAchieveTotal.add(perkTotal); | 
|---|
|  |  |  | perkAgentAchieveTotalDic.setValue(perkAgentAchieveTotal.toString()); | 
|---|
|  |  |  | dataDictionaryCustomMapper.updateById(perkAgentAchieveTotalDic); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        List<MallMember> sevenLevelRecord = getStarRecord(null,  MemberLevelEnum.SEVEN_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_SEVEN.getValue()); | 
|---|
|  |  |  | //        List<MallMember> sixLevelRecord = getStarRecord(sevenLevelRecord,  MemberLevelEnum.SIX_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_SIX.getValue()); | 
|---|
|  |  |  | //        List<MallMember> fifthLevelRecord = getStarRecord(sixLevelRecord,  MemberLevelEnum.FIFTH_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_FIVE.getValue()); | 
|---|
|  |  |  | //        List<MallMember> fourLevelRecord = getStarRecord(fifthLevelRecord,  MemberLevelEnum.FOUR_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_FOUR.getValue()); | 
|---|
|  |  |  | //        List<MallMember> thirdLevelRecord = getStarRecord(fourLevelRecord,  MemberLevelEnum.THIRD_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_THREE.getValue()); | 
|---|
|  |  |  | //        List<MallMember> secondLevelRecord = getStarRecord(thirdLevelRecord,  MemberLevelEnum.SECOND_LEVEL.name(), amount, mallOrderInfo.getOrderNo(), memberId,MoneyFlowTypeEnum.STAR_PERK_TWO.getValue()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 团队补贴 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | long end = System.currentTimeMillis(); | 
|---|
|  |  |  | log.info("============订单:{},时间:{}===========",mallOrderInfo.getOrderNo(),(end - start)/1000); | 
|---|
|  |  |  | MallMqRecord mallMqRecord = mallMqRecordMapper.selectByOrderId(orderId); | 
|---|
|  |  |  | if(ObjectUtil.isNotEmpty(mallMqRecord)){ | 
|---|
|  |  |  | mallMqRecord.setState(1); | 
|---|
|  |  |  | mallMqRecordMapper.updateById(mallMqRecord); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public List<MallMember> getStarRecord(List<MallMember> mallMembersOlds,String LevelParam,BigDecimal amount,String orderNo,Long memberId,int starPerkType){ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //实际补贴总金额 | 
|---|
|  |  |  | BigDecimal totalPerkAgentAmount = BigDecimal.ZERO; | 
|---|
|  |  |  | //根据用户的level获取用户 | 
|---|
|  |  |  | List<MallMember> mallMemberStars = memberMapper.selectMemberWithLevel(LevelParam); | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(mallMembersOlds)){ | 
|---|
|  |  |  | 
|---|
|  |  |  | List<Long> mallMemberStarIds = mallMemberStars.stream().map(MallMember::getId).collect(Collectors.toList()); | 
|---|
|  |  |  | //排除掉本身 | 
|---|
|  |  |  | mallMemberStarIds.remove(memberId); | 
|---|
|  |  |  | if(CollUtil.isEmpty(mallMemberStarIds)){ | 
|---|
|  |  |  | return mallMemberStars; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //当前等级的总贡献点 | 
|---|
|  |  |  | List<MallMemberWallet> mallMemberWallets = mallMemberWalletMapper.selectMemberWalletsByIds(mallMemberStarIds); | 
|---|
|  |  |  | Integer starSum = mallMemberWallets.stream().mapToInt(MallMemberWallet::getStar).sum(); | 
|---|
|  |  |  | if(starSum <= 0){ | 
|---|
|  |  |  | return mallMemberStars; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | BigDecimal totalProfitProp = BigDecimal.ZERO; | 
|---|
|  |  |  | List<DataDictionaryCustom> agentLevelRequireDics = dataDictionaryCustomMapper.selectDicByType("AGENT_LEVEL_REQUIRE"); | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(agentLevelRequireDics)){ | 
|---|
|  |  |  | for(DataDictionaryCustom dic : agentLevelRequireDics){ | 
|---|
|  |  |  | String starPerkStr = dic.getValue(); | 
|---|
|  |  |  | AgentInfo agentInfo = JSONObject.parseObject(starPerkStr, AgentInfo.class); | 
|---|
|  |  |  | //当前星级所占份数 | 
|---|
|  |  |  | BigDecimal profitProp = agentInfo.getProfitProp().abs(); | 
|---|
|  |  |  | List<MallMember> mallMembers = memberMapper.selectByLevel(dic.getCode()); | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(mallMembers)){ | 
|---|
|  |  |  | totalProfitProp = profitProp.add(totalProfitProp); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //星级补贴比例 | 
|---|
|  |  |  | DataDictionaryCustom starPerkDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( | 
|---|
|  |  |  | "AGENT_LEVEL_REQUIRE", | 
|---|
|  |  |  | LevelParam); | 
|---|
|  |  |  | String starPerkStr = starPerkDic.getValue(); | 
|---|
|  |  |  | AgentInfo agentInfo = JSONObject.parseObject(starPerkStr, AgentInfo.class); | 
|---|
|  |  |  | BigDecimal profitProp = agentInfo.getProfitProp().abs().divide(new BigDecimal(100)); | 
|---|
|  |  |  | //            BigDecimal profitProp = agentInfo.getProfitProp().abs().divide(new BigDecimal(100)); | 
|---|
|  |  |  | //当前星级所占份数 | 
|---|
|  |  |  | BigDecimal profitProp = agentInfo.getProfitProp().abs(); | 
|---|
|  |  |  | //每一份多少钱 | 
|---|
|  |  |  | amount = amount.divide(totalProfitProp,4,BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  | //当前等级的星级补贴 | 
|---|
|  |  |  | BigDecimal starPerkAmountSum = amount.multiply(profitProp); | 
|---|
|  |  |  | //当前等级的每一个贡献点的补贴金额 | 
|---|
|  |  |  | 
|---|
|  |  |  | mallMoneyFlow.setRemark("补贴额度:"+mallMemberWallet.getTotalScore()); | 
|---|
|  |  |  | mallMoneyFlow.setFlowType(FlowTypeEnum.BALANCE.getValue()); | 
|---|
|  |  |  | mallMoneyFlows.add(mallMoneyFlow); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | reduceStar(mallMemberWallet.getMemberId(),starPerkAmount); | 
|---|
|  |  |  | totalPerkAgentAmount = totalPerkAgentAmount.add(starPerkAmount); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | count = count + 1; | 
|---|
|  |  |  | if (count % 1000 == 0 || count == mallMemberWallets.size()) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | log.info("============实际补贴金额:{}",totalPerkAgentAmount.setScale(2,BigDecimal.ROUND_DOWN)); | 
|---|
|  |  |  | DataDictionaryCustom totalPerkAgentAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_TOTAL.getType(), | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_TOTAL.getCode() | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | totalPerkAgentAmountDic.setValue( | 
|---|
|  |  |  | new BigDecimal(totalPerkAgentAmountDic.getValue()).subtract(totalPerkAgentAmount).setScale(2,BigDecimal.ROUND_DOWN).toString() | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | dataDictionaryCustomMapper.updateById(totalPerkAgentAmountDic); | 
|---|
|  |  |  | return mallMemberStars; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | mallMoneyFlow.setRemark("补贴额度:"+mallMemberWallet.getTotalScore()); | 
|---|
|  |  |  | mallMoneyFlow.setFlowType(FlowTypeEnum.BALANCE.getValue()); | 
|---|
|  |  |  | mallMoneyFlows.add(mallMoneyFlow); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | reduceStar(mallMemberWallet.getMemberId(),amount); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | count = count + 1; | 
|---|
|  |  |  | if (count % 1000 == 0 || count == mallMemberWallets.size()) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void reduceStar(Long memberId,BigDecimal totalScore) { | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | *获取用户的全部未用完的补贴额度流水 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId); | 
|---|
|  |  |  | List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectMoneyFlowByMemberIdAndIsRetrun(memberId,2); | 
|---|
|  |  |  | //如果补贴额度全部用完则更新用户的贡献点为零 | 
|---|
|  |  |  | if(CollUtil.isEmpty(mallMoneyFlows)){ | 
|---|
|  |  |  | mallMemberWalletMapper.reduceStarByMemberId(mallMemberWallet.getStar(), memberId); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){ | 
|---|
|  |  |  | String remark = mallMoneyFlow.getRemark(); | 
|---|
|  |  |  | BigDecimal remarkNum = new BigDecimal(remark); | 
|---|
|  |  |  | //如果补贴额度小于记录的剩余补贴额度 | 
|---|
|  |  |  | if(totalScore.compareTo(remarkNum) < 0){ | 
|---|
|  |  |  | remarkNum = remarkNum.subtract(totalScore).setScale(2,BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  | mallMoneyFlowMapper.updateRemarkById(remarkNum.toString(),mallMoneyFlow.getId()); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //如果补贴额度等于等于记录的剩余补贴额度 | 
|---|
|  |  |  | if(totalScore.compareTo(remarkNum) == 0){ | 
|---|
|  |  |  | remarkNum = remarkNum.subtract(totalScore).setScale(2,BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  | mallMoneyFlowMapper.updateRemarkAndIsReturnById(remarkNum.toString(),mallMoneyFlow.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //减少用户的贡献点 | 
|---|
|  |  |  | String orderNo = mallMoneyFlow.getOrderNo(); | 
|---|
|  |  |  | MallMoneyFlow mallMoneyFlowStar = mallMoneyFlowMapper.selectByOrderNoAndMemberId(orderNo,memberId,2); | 
|---|
|  |  |  | BigDecimal amount = mallMoneyFlowStar.getAmount(); | 
|---|
|  |  |  | mallMemberWalletMapper.reduceStarByMemberId(amount.intValue(), memberId); | 
|---|
|  |  |  | //更新记录的返利状态为已返利 | 
|---|
|  |  |  | mallMoneyFlowMapper.updateRemarkAndIsReturnById("0",mallMoneyFlowStar.getId()); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //如果补贴额度大于记录的剩余补贴额度 | 
|---|
|  |  |  | if(totalScore.compareTo(remarkNum) > 0){ | 
|---|
|  |  |  | mallMoneyFlowMapper.updateRemarkAndIsReturnById("0",mallMoneyFlow.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //减少用户的贡献点 | 
|---|
|  |  |  | String orderNo = mallMoneyFlow.getOrderNo(); | 
|---|
|  |  |  | MallMoneyFlow mallMoneyFlowStar = mallMoneyFlowMapper.selectByOrderNoAndMemberId(orderNo,memberId,2); | 
|---|
|  |  |  | BigDecimal amount = mallMoneyFlowStar.getAmount(); | 
|---|
|  |  |  | mallMemberWalletMapper.reduceStarByMemberId(amount.intValue(), memberId); | 
|---|
|  |  |  | //更新记录的返利状态为已返利 | 
|---|
|  |  |  | mallMoneyFlowMapper.updateRemarkAndIsReturnById("0",mallMoneyFlowStar.getId()); | 
|---|
|  |  |  | totalScore = totalScore.subtract(remarkNum); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void achieveReleasePercent() { | 
|---|
|  |  |  | DataDictionaryCustom jobAchieveReleasePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( | 
|---|
|  |  |  | GreenScoreEnum.JOB_ACHIEVE_RELEASE_PERCENT.getType(), | 
|---|
|  |  |  | GreenScoreEnum.JOB_ACHIEVE_RELEASE_PERCENT.getCode() | 
|---|
|  |  |  | ); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<MallMember> mallMembers = memberMapper.selectByLevel(MemberLevelEnum.SECOND_LEVEL.getType()); | 
|---|
|  |  |  | BigDecimal jobAchieveReleasePercent = new BigDecimal(jobAchieveReleasePercentDic.getValue()) | 
|---|
|  |  |  | .multiply(new BigDecimal(0.001)); | 
|---|
|  |  |  | BigDecimal totalAchieve = BigDecimal.ZERO; | 
|---|
|  |  |  | Integer totalStar = 0; | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(mallMembers)){ | 
|---|
|  |  |  | for(MallMember mallMember : mallMembers){ | 
|---|
|  |  |  | //总业绩 | 
|---|
|  |  |  | BigDecimal achieve = mallAchieveRecordMapper.selectSumAchieveByMemberId(mallMember.getId()); | 
|---|
|  |  |  | totalAchieve = totalAchieve.add(achieve); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(mallMember.getId()); | 
|---|
|  |  |  | Integer star = mallMemberWallet.getStar(); | 
|---|
|  |  |  | totalStar = totalStar + star; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(BigDecimal.ZERO.compareTo(totalAchieve) >= 0){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //总释放=总业绩*一星每日业绩每日释放业绩到余额的千分比 | 
|---|
|  |  |  | totalAchieve = totalAchieve.multiply(jobAchieveReleasePercent); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(totalStar <= 0){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //一个贡献点的价值 | 
|---|
|  |  |  | BigDecimal divide = totalAchieve.divide(new BigDecimal(totalStar), 2, BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(CollUtil.isNotEmpty(mallMembers)){ | 
|---|
|  |  |  | for(MallMember mallMember : mallMembers){ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(mallMember.getId()); | 
|---|
|  |  |  | Integer star = mallMemberWallet.getStar(); | 
|---|
|  |  |  | //每个人贡献值数量*一个贡献点的价值=获取的收益 | 
|---|
|  |  |  | BigDecimal multiply = divide.multiply(new BigDecimal(star)).setScale(2,BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | BigDecimal totalScore = mallMemberWallet.getTotalScore(); | 
|---|
|  |  |  | if(BigDecimal.ZERO.compareTo(multiply) < 0){ | 
|---|
|  |  |  | if(BigDecimal.ZERO.compareTo(totalScore) < 0){ | 
|---|
|  |  |  | if(totalScore.compareTo(multiply) < 0){ | 
|---|
|  |  |  | multiply = totalScore; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //减少补贴额度 | 
|---|
|  |  |  | mallMemberWalletMapper.reduceTotalScoreById(multiply, mallMemberWallet.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | reduceStar(mallMember.getId(),multiply); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | mallMemberWalletMapper.addBalanceById(multiply, mallMemberWallet.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | mallMoneyFlowService.addMoneyFlow( | 
|---|
|  |  |  | mallMember.getId(), | 
|---|
|  |  |  | multiply, | 
|---|
|  |  |  | MoneyFlowTypeEnum.STATIC_BONUS.getValue(), | 
|---|
|  |  |  | MallUtils.getOrderNum(), | 
|---|
|  |  |  | FlowTypeEnum.BALANCE.getValue()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //        if(CollUtil.isNotEmpty(mallMembers)){ | 
|---|
|  |  |  | //            for(MallMember mallMember : mallMembers){ | 
|---|
|  |  |  | //                //总业绩 | 
|---|
|  |  |  | //                BigDecimal sumAchieve = mallAchieveRecordMapper.selectSumAchieveByMemberId(mallMember.getId()); | 
|---|
|  |  |  | //                //每个人的补贴额度 | 
|---|
|  |  |  | //                BigDecimal multiply = sumAchieve.multiply(jobAchieveReleasePercent); | 
|---|
|  |  |  | //                MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(mallMember.getId()); | 
|---|
|  |  |  | //                BigDecimal totalScore = mallMemberWallet.getTotalScore(); | 
|---|
|  |  |  | //                if(BigDecimal.ZERO.compareTo(multiply) < 0){ | 
|---|
|  |  |  | //                    if(BigDecimal.ZERO.compareTo(totalScore) < 0){ | 
|---|
|  |  |  | //                        if(totalScore.compareTo(multiply) < 0){ | 
|---|
|  |  |  | //                            multiply = totalScore; | 
|---|
|  |  |  | //                        } | 
|---|
|  |  |  | //                        //减少补贴额度 | 
|---|
|  |  |  | //                        mallMemberWalletMapper.reduceTotalScoreById(multiply, mallMemberWallet.getId()); | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //                        reduceStar(mallMember.getId(),multiply); | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //                        mallMemberWalletMapper.addBalanceById(multiply, mallMemberWallet.getId()); | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //                        mallMoneyFlowService.addMoneyFlow( | 
|---|
|  |  |  | //                                mallMember.getId(), | 
|---|
|  |  |  | //                                multiply, | 
|---|
|  |  |  | //                                MoneyFlowTypeEnum.STATIC_BONUS.getValue(), | 
|---|
|  |  |  | //                                MallUtils.getOrderNum(), | 
|---|
|  |  |  | //                                FlowTypeEnum.BALANCE.getValue()); | 
|---|
|  |  |  | //                    } | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void perkAgent() { | 
|---|
|  |  |  | DataDictionaryCustom totalAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_TOTAL.getType(), | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_TOTAL.getCode() | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(ObjectUtil.isEmpty(totalAmountDic)){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //星级补贴总数 | 
|---|
|  |  |  | BigDecimal totalAmount = new BigDecimal(totalAmountDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); | 
|---|
|  |  |  | if(BigDecimal.ZERO.compareTo(totalAmount) >= 0){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | DataDictionaryCustom perkAgentPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_PERCENT.getType(), | 
|---|
|  |  |  | DataDictionaryEnum.PERK_AGENT_ACHIEVE_PERCENT.getCode() | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(ObjectUtil.isEmpty(perkAgentPercentDic)){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //星级补贴百分比 | 
|---|
|  |  |  | BigDecimal perkAgentPercent = new BigDecimal(perkAgentPercentDic.getValue()).abs().divide(new BigDecimal(100)); | 
|---|
|  |  |  | BigDecimal amount = totalAmount.multiply(perkAgentPercent); | 
|---|
|  |  |  | if(BigDecimal.ZERO.compareTo(amount) >= 0){ | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        //星级补贴总数 | 
|---|
|  |  |  | //        totalAmountDic.setValue(totalAmount.subtract(amount).setScale(2,BigDecimal.ROUND_DOWN).toString()); | 
|---|
|  |  |  | //        dataDictionaryCustomMapper.updateById(totalAmountDic); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String orderNo = MallUtils.getOrderNum("SPA"); | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 星级奖励 | 
|---|
|  |  |  | *  从最顶级级别的合伙人开始补贴 | 
|---|
|  |  |  | *      补贴完,把已经补贴的合伙人加入下一个级别 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | List<MallMember> sevenLevelRecord = getStarRecord(null,  MemberLevelEnum.SEVEN_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_SEVEN.getValue()); | 
|---|
|  |  |  | List<MallMember> sixLevelRecord = getStarRecord(sevenLevelRecord,  MemberLevelEnum.SIX_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_SIX.getValue()); | 
|---|
|  |  |  | List<MallMember> fifthLevelRecord = getStarRecord(sixLevelRecord,  MemberLevelEnum.FIFTH_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_FIVE.getValue()); | 
|---|
|  |  |  | List<MallMember> fourLevelRecord = getStarRecord(fifthLevelRecord,  MemberLevelEnum.FOUR_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_FOUR.getValue()); | 
|---|
|  |  |  | List<MallMember> thirdLevelRecord = getStarRecord(fourLevelRecord,  MemberLevelEnum.THIRD_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_THREE.getValue()); | 
|---|
|  |  |  | List<MallMember> secondLevelRecord = getStarRecord(thirdLevelRecord,  MemberLevelEnum.SECOND_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_TWO.getValue()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|