用户升级功能整理

app/common/repositories/store/order/StoreOrderRepository.php

@@ -9308,6 +9308,9 @@ class StoreOrderRepository extends BaseRepository
 
                 if (strpos($mark, "购买") !== false) {
                     Db::name('user')->where("uid", $uid)->update(['contribute' => $con_data['contribute'] + $num]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($uid);
                 }
 
                 if (strpos($mark, "推广") !== false) {

app/common/repositories/user/UserRepository.php

@@ -3236,11 +3236,16 @@ class UserRepository extends BaseRepository
      */
     public function setUserIdentity($uid, $identityId = null)
     {
-        $result = null;
         if (empty($identityId)) {
             $identityId = $this->getUserIdentity($uid);
         }
-        $this->dao->update($uid, ['user_group' => $identityId]);
+
+        $userData = $this->dao->get($uid)->toArray();
+        $data = ['user_group' => $identityId];
+        if (empty($userData['identity_up_time'] ?? null) && $userData['user_group'] == 1 && $identityId > 1) {
+            $data['identity_up_time'] = date('Y-m-d H:i:s');
+        }
+        $this->dao->update($uid, $data);
         return $identityId;
     }
 
@@ -3263,27 +3268,53 @@ class UserRepository extends BaseRepository
         $lowerLevelNumList = array_column($identityList, 'lower_level_num');
         $lowerLevelNumMax = max($lowerLevelNumList);
         $lowerLevelNumMin = min($lowerLevelNumList);
-        $needLower = $lowerLevelNumMax;
-        if($lowerLevelNumMin == 0) {
-            $needLower = $lowerLevelNumMin;
+        // 获取需要 递归最深的层数，比如 高级合伙人需要递归10层 普通用户需要递归一层
+        $needLower = 0;
+        // 0 代表要递归无限极
+        if($lowerLevelNumMax > 0) {
+            $needLower = $lowerLevelNumMin - 1;
+        }
+        // 最大等级限制
+        $maxLvRestrict = 0;
+
+
+        // 3、获取个人贡献值
+        $userData = $this->dao->get($uid)->toArray();
+        if ($userData['is_old'] == 1 && $userData['user_group'] > 1 && empty($userData['identity_up_time'])) {
+            if (empty($userData['create_time'])) {
+                return $userData['user_group'];
+            }
+            $userData['identity_up_time'] = $userData['create_time'];
+            $this->dao->update($uid, ['identity_up_time' => $userData['identity_up_time']]);
+        }
+        if ($userData['user_group'] == 1) {
+            $maxLvRestrict = 2;
         }
 
-        // 3、获取下级用户 贡献值
+        // 4、获取下级用户 贡献值
         $userContributionSumMap = [];
+        // 获取用户的直属下级
         $uidContributeList = $this->getUidContributeListBySpreadUidList([$uid]);
         foreach ($uidContributeList as $uidContribute) {
-            $userContributionSumMap[$uidContribute['uid']] = $this->getContributionSumByLevel([$uidContribute['uid']], $needLower);
+            // 获取每个下级（部门）的个人贡献值
+            $userContributionSumMap[$uidContribute['uid']] = $this->getContributionSumByLevel(
+                [$uidContribute['uid']],
+                $needLower,
+                $userData['is_old'],
+                $userData['identity_up_time'] ?? null
+            );
             $userContributionSumMap[$uidContribute['uid']][0] = $uidContribute['contribute'];
+            // 假设 老大的 下级是 张三和李四， 董事（最高级身份）需要循环最深的等级是 3 级    得出来的结果↓  这样是为了计算大小部门
+            // $userContributionSumMap[直属下级（部门）张三] =>[0 => 张三个人贡献值, 1 => 张三所有下级用户的个人贡献值, 2 => 张三所有下级用户的下级用户贡献值]
+            // $userContributionSumMap[直属下级（部门）李四] =>[0 => 李四个人贡献值, 1 => 李四所有下级用户的个人贡献值, 2 => 李四所有下级用户的下级用户贡献值]
         }
 
-        // 4、获取个人贡献值
-        $userData = $this->dao->get($uid)->toArray();
-
-        // 5、当前用户等级
-        $identityId = 0;
+        // 5、将用户等级由低到高
         usort($identityList, function ($a, $b) {
-            return $b['user_group_id'] <=> $a['user_group_id'];  // 反转顺序，倒序排列
+            return $a['user_group_id'] <=> $b['user_group_id'];
         });
+        // 循环记录 如果贡献值 满足了初级合伙人身份 并记录该身份ID，继续下一阶段循环，下一阶段不满足 则该用户身份为初级合伙人
+        $identityId = 0;
         foreach ($identityList as $item) {
             $lowerLevelNum = $item['lower_level_num']??0;
 
@@ -3291,30 +3322,41 @@ class UserRepository extends BaseRepository
             $arriveNumTeam = 0;
             $subordinateContribution = [];
 
-            foreach ($userContributionSumMap as $key => $value) {
-                $subordinateContribution[$key] = 0;
-                if ($lowerLevelNum != 0) {
-                    foreach ($value as $k => $v) {
-                        if ($k <= $lowerLevelNum) {
-                            $subordinateContribution[$key] += $v;
-                        } else {
-                            break;
+            // 只有 业务员及以上才需要团队贡献值
+            if ($item['id'] > 1) {
+                foreach ($userContributionSumMap as $key => $value) {
+                    $subordinateContribution[$key] = 0;
+                    if ($lowerLevelNum != 0) {
+                        foreach ($value as $k => $v) {
+                            if ($k < $lowerLevelNum) {
+                                $subordinateContribution[$key] += $v;
+                            } else {
+                                break;
+                            }
                         }
+                    } else {
+                        $subordinateContribution[$key] = array_sum($value);
                     }
-                } else {
-                    $subordinateContribution[$key] = array_sum($value);
+                }
+                if (!empty($subordinateContribution)) {
+                    // 大区业绩
+                    $dqYj = max($subordinateContribution);
+                    // 总业绩
+                    $zYj = array_sum($subordinateContribution);
+                    // 小区团体业绩
+                    $arriveNumTeam = bcsub($zYj, $dqYj, 2);
                 }
             }
-            if (!empty($subordinateContribution)) {
-                // 大区业绩
-                $dqYj = max($subordinateContribution);
-                // 总业绩
-                $zYj = array_sum($subordinateContribution);
-                // 小区团体业绩
-                $arriveNumTeam = bcsub($zYj, $dqYj, 2);
-            }
+
+            // 从小向大循环，满足则去 下一等级继续验证，不满足 则 返回上次循环记录的值，并结束循环
             if ($item['arrive_num_own'] <= $arriveNumOwn && $item['arrive_num_team'] <= $arriveNumTeam) {
                 $identityId = $item['user_group_id'];
+
+                // 用户等级限制，本次获取身份 最大可获取什么身份，比如 用户没有 团队贡献值，他最高只能升到 2 级 即业务员
+                if ($identityId == $maxLvRestrict) {
+                    break;
+                }
+            } else {
                 break;
             }
         }
@@ -3341,10 +3383,15 @@ class UserRepository extends BaseRepository
      *                      0 表示查询所有层级直到末端。
      *                      1 表示只计算第1层（直接下级）的总贡献。
      *                      N 表示计算到第 N 层（包含第N层）的总贡献。
+     * @param int $is_old
+     * @param null $identity_up_time
      * @return array 返回一个数组，键是层级号（从1开始），值是该层级所有用户的贡献值总和。
      *               例如：[ 1 => 600, 2 => 1300 ]
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
      */
-    public function getContributionSumByLevel(array $initialUserIds, int $maxDepth = 0): array
+    public function getContributionSumByLevel(array $initialUserIds, int $maxDepth = 0, $is_old = 0, $identity_up_time = null): array
     {
         $levelContributions = []; // 结果数组 [level => total_contribution]
         if (empty($initialUserIds)) {
@@ -3372,8 +3419,9 @@ class UserRepository extends BaseRepository
             $subordinatesOfCurrentLevel = [];
             foreach(array_chunk($currentLevelIds, $chunkSize) as $chunk) {
                 $subordinatesChunk = Db::name('user')
-                    ->field('uid, contribute') // 只需要下级的uid和贡献值
+                    ->field('uid') // 只需要下级的uid
                     ->whereIn('spread_uid', $chunk) // spread_uid 在当前层级用户块中
+                    ->where('status', 1)
                     ->select()
                     ->toArray();
                 $subordinatesOfCurrentLevel = array_merge($subordinatesOfCurrentLevel, $subordinatesChunk);
@@ -3384,13 +3432,70 @@ class UserRepository extends BaseRepository
                 break;
             }
 
+            $subordinatesOfCurrentLevelUidList =[];
+            foreach ($subordinatesOfCurrentLevel as &$value){
+                $subordinatesOfCurrentLevelUidList[$value['uid']] = 0;
+                $value['contribute'] = 0;
+            }
+
+            // 如果 传入 $identity_up_time 不为空 证明当前在 确定身份的 用户已经是 业务员了
+            if (!empty($identity_up_time)) {
+                // 用户有贡献值记录，我们要根据 用户的身份 从普通消费者 升级 成业务员 的时间来 查询时间范围内产生的贡献值
+                $userSignGongxianList = Db::name('user_sign_gongxian')
+                    ->whereIn('uid', array_keys($subordinatesOfCurrentLevelUidList))
+                    ->where('addtime', '>=', strtotime($identity_up_time)) //   `addtime` int(10) NOT NULL COMMENT '添加时间'
+                    ->where('status', 1) // 贡献值状态1-有效 0-失效 -1待确认
+                    ->whereNotNull('settlement_time') // `settlement_time` datetime DEFAULT NULL COMMENT '结算时间',
+                    ->field('uid, number, type') // 只需要下级的uid和贡献值
+                    ->select()
+                    ->toArray();
+                foreach ($userSignGongxianList as $value) {
+                    if($value['type'] == 1) {
+                        $subordinatesOfCurrentLevelUidList[$value['uid']] += $value['number'];
+                    } else {
+                        $subordinatesOfCurrentLevelUidList[$value['uid']] -= $value['number'];
+                    }
+                }
+
+                if ($is_old == 1) {
+                    // 如果是老用户，除了通过贡献值记录表  还要计算 老订单 产生的贡献值
+                    $oldUserOfGoodsList = Db::name('old_user_of_goods')
+                        ->whereIn('user_id', array_keys($subordinatesOfCurrentLevelUidList))
+                        ->where('create_time', '>=', strtotime($identity_up_time)) //   `addtime` int(10) NOT NULL COMMENT '添加时间'
+                        ->where('status', 1) // '是否完成 0, 未完成 1 已完成',
+                        ->field('user_id, money, status, create_time') // 只需要下级的uid和贡献值
+                        ->select()
+                        ->toArray();
+
+                    foreach ($oldUserOfGoodsList as $storeProductData) {
+                        if ($storeProductData['money'] == 1180) {
+                            $subordinatesOfCurrentLevelUidList[$storeProductData['user_id']] += 700;
+                        } else if ($storeProductData['money'] == 10620) {
+                            $subordinatesOfCurrentLevelUidList[$storeProductData['user_id']] += 6300;
+                        } else if ($storeProductData['money'] == 11800) {
+                            $subordinatesOfCurrentLevelUidList[$storeProductData['user_id']] += 7000;
+                        } else if ($storeProductData['money'] == 9440) {
+                            $subordinatesOfCurrentLevelUidList[$storeProductData['user_id']] += 5600;
+                        } else if ($storeProductData['money'] == 2360) {
+                            $subordinatesOfCurrentLevelUidList[$storeProductData['user_id']] += 1400;
+                        } else {
+                            $subordinatesOfCurrentLevelUidList[$storeProductData['user_id']] += bcmul($storeProductData['money'], 0.7, 2);
+                        }
+                    }
+                }
+            } else {
+                // 如果传入的 $identity_up_time 为空，说明该用户只是一个普通用户（消费者），没有团队业绩
+                break;
+            }
+
+
             $nextLevelTotalContribution = 0;
             $nextLevelIds = []; // 存储下一轮需要查询的用户ID
 
             // 遍历找到的所有下级
             foreach ($subordinatesOfCurrentLevel as $subordinate) {
                 $subordinateId = $subordinate['uid'];
-                $subordinateContribution = $subordinate['contribute'] ?? 0; // 安全获取，默认为0
+                $subordinateContribution = $subordinatesOfCurrentLevelUidList[$subordinate['uid']] ?? 0; // 安全获取，默认为0
 
                 // 累加下一层级的总贡献值
                 // 注意：这里简单累加，如果一个下级同时被当前层多个用户推荐，其贡献会被计算多次