From c8553669f87a7bc4df3b2279ad4473b6b212a127 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Wed, 15 Mar 2023 14:46:42 +0800 Subject: [PATCH] 后台修改 --- src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java | 30 ++++++++++++++++++------------ 1 files changed, 18 insertions(+), 12 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 9f9d2c8..11214b8 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 @@ -59,18 +59,20 @@ List<String> ids = StrUtil.split(member.getReferrerIds(), ','); List<MallMember> parentMembers = memberMapper.selectByInviteIds(ids); for (MallMember parent : parentMembers) { - // 未激活用户无法升级 + // 没有购买套餐无法升级合伙人等级 if (AgentLevelEnum.ZERO_LEVEL.name().equals(member.getLevel())) { continue; } - - DataDictionaryCustom nextLevel = dataDictionaryCustomMapper.selectNextAgentLevelInfo(parent.getLevel()); - if (nextLevel == null) { + //合伙人的下一个层级 + String parentLevel = parent.getLevel(); + String nextLevel = MemberLevelEnum.SECOND_LEVEL.getNextLevel(parentLevel); + if (parentLevel.equals(nextLevel)) { log.info("当前层级无下一级:{}", parent.getLevel()); continue; } - AgentInfo agentInfo = JSONObject.parseObject(nextLevel.getValue(), AgentInfo.class); + DataDictionaryCustom nextLevelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode("AGENT_LEVEL_REQUIRE", nextLevel); + AgentInfo agentInfo = JSONObject.parseObject(nextLevelDic.getValue(), AgentInfo.class); if (!directMemberCnt(parent, agentInfo)) { continue; } @@ -83,7 +85,7 @@ continue; } - parent.setLevel(nextLevel.getCode()); + parent.setLevel(nextLevel); memberMapper.updateById(parent); } } @@ -104,7 +106,7 @@ return true; } - log.info("用户:{}直推数量未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getPhone(), member.getLevel(), childs.size(), agentInfo.getLastAgentCnt()); + log.info("用户:{}直推数量未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getPhone(), member.getLevel(), childs.size(), agentInfo.getDirectCnt()); return false; } @@ -142,20 +144,24 @@ } /** - * 团队业绩是否达标 + * 团队贡献点是否达标 * * @param agentInfo * @return */ private boolean teamIncome(MallMember member, AgentInfo agentInfo) { - BigDecimal totalIncome = memberMapper.selectAchieveByMemberId(member.getInviteId(), 2); - BigDecimal targetIncome = agentInfo.getTeamIncome().multiply(new BigDecimal("10000")); - if (totalIncome.compareTo(targetIncome) >= 0) { + List<MallMember> mallMembers = memberMapper.selectAllChildAgentListByInviteId(member.getInviteId()); + List<Long> ids = mallMembers.stream().map(MallMember::getId).collect(Collectors.toList()); + List<MallMemberWallet> mallMemberWallets = mallMemberWalletMapper.selectMemberWalletsByIds(ids); + + int starSum = mallMemberWallets.stream().mapToInt(MallMemberWallet::getStar).sum(); + BigDecimal teamIncome = agentInfo.getTeamIncome(); + if (teamIncome.compareTo(new BigDecimal(starSum)) <= 0) { return true; } - log.info("用户:{}团队业绩未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getPhone(), member.getLevel(), totalIncome, targetIncome); + log.info("用户:{}团队贡献点未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getPhone(), member.getLevel(), starSum, teamIncome); return false; } -- Gitblit v1.9.1