优化计算团队贡献值逻辑

app/common/repositories/user/UserRepository.php

@@ -2492,7 +2492,7 @@ class UserRepository extends BaseRepository
     }
     public function get_yanglao($member_id){
 
-       
+
         $data = Db::name("user")
             ->where("uid",$member_id)
             ->field("wechat_user_id,card_id,ali_user_id,annuity_frozen,annuity_num,annuity,create_time,birthday,birthday60,card_number,annuity_yiqu,pay_price")
@@ -2553,7 +2553,7 @@ class UserRepository extends BaseRepository
 //        $data["yinghang"]='https://app.bjtdba.com/uploads/def/20201021/8cb66944101287b8ac9c9b9fb1b13a79.png';
         $data["add_up"] = 0.00;
 
-     
+
 
         return $data;
     }
@@ -3273,9 +3273,9 @@ class UserRepository extends BaseRepository
         $lowerLevelNumMin = min($lowerLevelNumList);
         // 获取需要 递归最深的层数，比如 高级合伙人需要递归10层 普通用户需要递归一层
         $needLower = 0;
-        // 0 代表要递归无限极
-        if($lowerLevelNumMax > 0) {
-            $needLower = $lowerLevelNumMin - 1;
+        // 0 代表要递归无限极 -1 代表一级也不查
+        if($lowerLevelNumMin > 0) {
+            $needLower = $lowerLevelNumMax;
         }
         // 最大等级限制
         $maxLvRestrict = 0;
@@ -3287,28 +3287,17 @@ class UserRepository extends BaseRepository
         $determineResult = $this->determineUserUpgradeTime($uid);
         $userData['user_group'] = $determineResult['user_group'];
         $userData['identity_up_time'] = $determineResult['identity_up_time'];
-        if ($userData['user_group'] == 1) {
+        $startTime = $userData['identity_up_time'];
+        $endTime = date('Y-m-d H:i:s');
+
+        // 如果用户身份 为 用户 或者 升级成业务员的时间为空 则无法计算它的团队贡献值
+        if ($userData['user_group'] == 1 || empty($startTime)) {
             $maxLvRestrict = 2;
+            $needLower = -1;
         }
 
         // 4、获取下级用户 贡献值
-        $userContributionSumMap = [];
-        // 获取用户的直属下级
-        $uidContributeList = $this->getUidContributeListBySpreadUidList([$uid]);
-        foreach ($uidContributeList as $uidContribute) {
-            // 获取每个下级（部门）的个人贡献值
-            $userContributionSumMap[$uidContribute['uid']] = $this->getContributionSumByLevel(
-                [$uidContribute['uid']],
-                $needLower,
-                $userData['is_old'],
-                $userData['identity_up_time'] ?? null
-            );
-            $userContributionSumMap[$uidContribute['uid']][0] = $uidContribute['contribute'];
-            ksort($userContributionSumMap[$uidContribute['uid']]);
-            // 假设 老大的 下级是 张三和李四， 董事（最高级身份）需要循环最深的等级是 3 级    得出来的结果↓  这样是为了计算大小部门
-            // $userContributionSumMap[直属下级（部门）张三] =>[0 => 张三个人贡献值, 1 => 张三所有下级用户的个人贡献值, 2 => 张三所有下级用户的下级用户贡献值]
-            // $userContributionSumMap[直属下级（部门）李四] =>[0 => 李四个人贡献值, 1 => 李四所有下级用户的个人贡献值, 2 => 李四所有下级用户的下级用户贡献值]
-        }
+        $userContributionSumMap = $this->getSubordinateContributeByUid($uid, $startTime, $endTime, $needLower);
 
         // 5、将用户等级由低到高
         usort($identityList, function ($a, $b) {
@@ -3704,6 +3693,60 @@ class UserRepository extends BaseRepository
         return $subordinatesOfCurrentLevelUidList;
     }
 
+
+    /**
+     * 根据时间和递归层级 获取部门下 每一层级的 贡献值
+     *  假设 老大的 下级是 张三和李四， 董事（最高级身份）需要循环最深的等级是 3 级    得出来的结果↓  这样是为了计算大小部门
+     * $userContributionSumMap[直属下级（部门）张三] =>[0 => 张三个人贡献值, 1 => 张三所有下级用户的个人贡献值, 2 => 张三所有下级用户的下级用户贡献值]
+     * $userContributionSumMap[直属下级（部门）李四] =>[0 => 李四个人贡献值, 1 => 李四所有下级用户的个人贡献值, 2 => 李四所有下级用户的下级用户贡献值]
+     * @param $uid
+     * @param null $startTime
+     * @param null $endTime
+     * @param int $depth
+     * @return array
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     */
+    public function getSubordinateContributeByUid($uid, $startTime, $endTime, $depth = 10)
+    {
+        // 4、获取下级用户 贡献值
+        $userContributionSumMap = [];
+        if ($depth >= 0 && !empty($startTime)) {
+            // 获取用户的直属下级
+            $uidContributeList = $this->getUidContributeListBySpreadUidList([$uid]);
+            $uidContributeUidList = array_column($uidContributeList, 'uid');
+            $subordinatesOfCurrentLevelUidList = $this->getUserContributeByUidList($uidContributeUidList, $startTime, $endTime);
+
+            foreach ($uidContributeList as $uidContribute) {
+                $goOnDepth = $depth;
+                // 获取用户规定时间内 所产生的贡献值 第一级
+                $userContributionSumMap[$uidContribute['uid']][0] = $subordinatesOfCurrentLevelUidList[$uidContribute['uid']] ?? 0;
+                if ($depth == 1) {
+                    break;
+                } else if ($depth > 1){
+                    $goOnDepth = $depth - 1;
+                }
+                // 获取每个下级（部门）的个人贡献值 $goOnDepth = 0 时表示无限递归
+                $userContributionSumMap[$uidContribute['uid']] = $this->getContributionSumByLevel(
+                    [$uidContribute['uid']],
+                    $goOnDepth,
+                    0,
+                    $startTime,
+                    $endTime
+                );
+
+                if (!empty($userContributionSumMap[$uidContribute['uid']])) {
+                    ksort($userContributionSumMap[$uidContribute['uid']]);
+                }
+                // 假设 老大的 下级是 张三和李四， 董事（最高级身份）需要循环最深的等级是 3 级    得出来的结果↓  这样是为了计算大小部门
+                // $userContributionSumMap[直属下级（部门）张三] =>[0 => 张三个人贡献值, 1 => 张三所有下级用户的个人贡献值, 2 => 张三所有下级用户的下级用户贡献值]
+                // $userContributionSumMap[直属下级（部门）李四] =>[0 => 李四个人贡献值, 1 => 李四所有下级用户的个人贡献值, 2 => 李四所有下级用户的下级用户贡献值]
+            }
+        }
+        return $userContributionSumMap;
+    }
+
     /**
      * 获取用户 团队贡献值信息
      * @param $uid
@@ -3736,41 +3779,22 @@ class UserRepository extends BaseRepository
 
         // 如果用户身份是  用户  则
         /**
+         *  如果用户身份是 用户，则不计算团队贡献值，因计算团队贡献值 需要升级成业务员后 再进行进行统计
+         *  如用户也统计团队贡献值可能会导致： 用户进入系统后，不进行消费，团队贡献值确增长迅速，等某时刻 他只要 进行消费，身份就会快速跃迁，不公平
          * （1）达标贡献值=自己消费产生的贡献值
-         * （2）团队达标贡献值=小区团队的贡献值（用户的团队贡献值只统计一级）；如果团队只有一人，那团队贡献值就是0
+         * （2）团队达标贡献值= 不计算团队
          */
         if ($userData['user_group'] == 1) {
-            $depth = 1;
+            $depth = -1;
         }
 
         // 4、获取下级用户 贡献值
-        $userContributionSumMap = [];
-        // 获取用户的直属下级
-        $uidContributeList = $this->getUidContributeListBySpreadUidList([$uid]);
-        $uidContributeUidList = array_column($uidContributeList, 'uid');
-        // TODO 身份是用户的 $startTime = null
-        $subordinatesOfCurrentLevelUidList = $this->getUserContributeByUidList($uidContributeUidList, $startTime, $endTime);
-
-        foreach ($uidContributeList as $uidContribute) {
-            // 获取每个下级（部门）的个人贡献值
-            $userContributionSumMap[$uidContribute['uid']] = $this->getContributionSumByLevel(
-                [$uidContribute['uid']],
-                $depth,
-                $userData['is_old'],
-                $startTime,
-                $endTime
-            );
-            $userContributionSumMap[$uidContribute['uid']][0] = $subordinatesOfCurrentLevelUidList[$uidContribute['uid']];
-            ksort($userContributionSumMap[$uidContribute['uid']]);
-            // 假设 老大的 下级是 张三和李四， 董事（最高级身份）需要循环最深的等级是 3 级    得出来的结果↓  这样是为了计算大小部门
-            // $userContributionSumMap[直属下级（部门）张三] =>[0 => 张三个人贡献值, 1 => 张三所有下级用户的个人贡献值, 2 => 张三所有下级用户的下级用户贡献值]
-            // $userContributionSumMap[直属下级（部门）李四] =>[0 => 李四个人贡献值, 1 => 李四所有下级用户的个人贡献值, 2 => 李四所有下级用户的下级用户贡献值]
-        }
-
+        $userContributionSumMap = $this->getSubordinateContributeByUid($uid, $startTime, $endTime, $depth);
         $subordinateContribution = [];
         foreach ($userContributionSumMap as $key => $value) {
             $subordinateContribution[$key] = array_sum($value);
         }
+
         $dqYj = 0;
         $arriveNumTeam = 0;
         if (!empty($subordinateContribution)) {