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