From 53391a949929195b3341a683d64b82364fa8cf6e Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Thu, 22 Dec 2022 15:39:21 +0800 Subject: [PATCH] 20221221 --- src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java | 104 +++++++++++++++++++++++++++------------------------ 1 files changed, 55 insertions(+), 49 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java index e5448c6..2fea264 100644 --- a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java @@ -203,51 +203,55 @@ * 2、返利对象:下单人的直推上级 * 3、金额:返利比例乘以补贴金额 */ - //下单人的直推上级 - MallMember mallMemberOne = memberMapper.selectInfoByInviteId(mallMember.getReferrerId()); - DataDictionaryCustom rewardPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.REWARD_PERCENT.getType(), - DataDictionaryEnum.REWARD_PERCENT.getCode() - ); - BigDecimal rewardPercent = new BigDecimal(rewardPercentDic.getValue()).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN); - BigDecimal directRewardAmount = subsidyAmount.multiply(rewardPercent).setScale(2, BigDecimal.ROUND_DOWN); - - Long marketSubsidyFlowId = mallMoneyFlowService.addMoneyFlow( - mallMember.getId(), - orderInfo.getOrderNo(), - directRewardAmount, - MallMoneyFlowTypeEnum.DIRECT_REWARD.getCode(), - MallMoneyFlow.STATUS_SUCCESS, - MallMoneyFlow.IS_RETURN_Y, - mallMemberOne.getId(), - FlowTypeEnum.BALANCE.getValue(), - MallMoneyFlowTypeEnum.DIRECT_REWARD.getName() - ); - memberWalletService.addBalance(directRewardAmount,mallMemberOne.getId()); /** * 生成分享奖励的流水记录 * 1、待生效 * 2、返利对象:下单人的直推上级 10%,直推的直推 5% * 3、金额:补贴金额乘以分享奖励的比例 */ - DataDictionaryCustom shareOneDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.LEVEL_ONE.getType(), - DataDictionaryEnum.LEVEL_ONE.getCode() - ); - BigDecimal shareOne = new BigDecimal(shareOneDic.getValue()).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN); - BigDecimal shareOneAmount = subsidyAmount.multiply(shareOne).setScale(2, BigDecimal.ROUND_DOWN); - Long ShareOneFlowId = mallMoneyFlowService.addMoneyFlow( - mallMember.getId(), - orderInfo.getOrderNo(), - shareOneAmount, - MallMoneyFlowTypeEnum.SHARE_REWARD_ONE.getCode(), - MallMoneyFlow.STATUS_SUCCESS, - MallMoneyFlow.IS_RETURN_Y, - mallMemberOne.getId(), - FlowTypeEnum.BALANCE.getValue(), - MallMoneyFlowTypeEnum.SHARE_REWARD_ONE.getName() - ); - memberWalletService.addBalance(shareOneAmount,mallMemberOne.getId()); + //下单人的直推上级 + MallMember mallMemberOne = memberMapper.selectInfoByInviteId(mallMember.getReferrerId()); + //生成直推返利的流水记录 + if(ObjectUtil.isNotEmpty(mallMemberOne)){ + DataDictionaryCustom rewardPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( + DataDictionaryEnum.REWARD_PERCENT.getType(), + DataDictionaryEnum.REWARD_PERCENT.getCode() + ); + BigDecimal rewardPercent = new BigDecimal(rewardPercentDic.getValue()).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN); + BigDecimal directRewardAmount = subsidyAmount.multiply(rewardPercent).setScale(2, BigDecimal.ROUND_DOWN); + + Long marketSubsidyFlowId = mallMoneyFlowService.addMoneyFlow( + mallMember.getId(), + orderInfo.getOrderNo(), + directRewardAmount, + MallMoneyFlowTypeEnum.DIRECT_REWARD.getCode(), + MallMoneyFlow.STATUS_SUCCESS, + MallMoneyFlow.IS_RETURN_Y, + mallMemberOne.getId(), + FlowTypeEnum.BALANCE.getValue(), + MallMoneyFlowTypeEnum.DIRECT_REWARD.getName() + ); + memberWalletService.addBalance(directRewardAmount,mallMemberOne.getId()); + DataDictionaryCustom shareOneDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( + DataDictionaryEnum.LEVEL_ONE.getType(), + DataDictionaryEnum.LEVEL_ONE.getCode() + ); + //生成分享奖励的流水记录 + BigDecimal shareOne = new BigDecimal(shareOneDic.getValue()).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN); + BigDecimal shareOneAmount = subsidyAmount.multiply(shareOne).setScale(2, BigDecimal.ROUND_DOWN); + Long ShareOneFlowId = mallMoneyFlowService.addMoneyFlow( + mallMember.getId(), + orderInfo.getOrderNo(), + shareOneAmount, + MallMoneyFlowTypeEnum.SHARE_REWARD_ONE.getCode(), + MallMoneyFlow.STATUS_SUCCESS, + MallMoneyFlow.IS_RETURN_Y, + mallMemberOne.getId(), + FlowTypeEnum.BALANCE.getValue(), + MallMoneyFlowTypeEnum.SHARE_REWARD_ONE.getName() + ); + memberWalletService.addBalance(shareOneAmount,mallMemberOne.getId()); + } //下单人的直推上级的直推 MallMember mallMemberTwo = memberMapper.selectInfoByInviteId(mallMemberOne.getReferrerId()); if(ObjectUtil.isNotEmpty(mallMemberTwo)){ @@ -280,16 +284,18 @@ ArrayList<String> refererIdListUp = new ArrayList<>(); //初始级别即当前下单人的级别 String levelStart = mallMember.getLevel(); - for(String inviteId : refererIdList){ - MallMember mallMemberUp = memberMapper.selectInfoByInviteId(inviteId); - String levelUp = mallMemberUp.getLevel(); - //团队补贴从区代开始 - if(!MemberAgentLevelEnum.AGENT.getName().equals(levelUp)){ - //比较两个代理级别,同级别或者大于下单人的级别都保留 - int compareLevel = MemberAgentLevelEnum.AGENT_ONE.compareLevel(levelUp,levelStart); - if(0 < compareLevel){ - levelStart = levelUp; - refererIdListUp.add(inviteId); + if(CollUtil.isNotEmpty(refererIdList)){ + for(String inviteId : refererIdList){ + MallMember mallMemberUp = memberMapper.selectInfoByInviteId(inviteId); + String levelUp = mallMemberUp.getLevel(); + //团队补贴从区代开始 + if(!MemberAgentLevelEnum.AGENT.getName().equals(levelUp)){ + //比较两个代理级别,同级别或者大于下单人的级别都保留 + int compareLevel = MemberAgentLevelEnum.AGENT_ONE.compareLevel(levelUp,levelStart); + if(0 < compareLevel){ + levelStart = levelUp; + refererIdListUp.add(inviteId); + } } } } -- Gitblit v1.9.1