根据贡献值的发放升级用户身份

app/command/PensionTasks.php

@@ -12,6 +12,7 @@ use app\common\repositories\merchant\order\OrderMerchantRepository;
 use app\common\repositories\store\order\StoreOrderStatusRepository;
 use app\common\repositories\store\product\ProductRepository;
 use app\common\repositories\user\UserBillRepository;
+use app\common\repositories\user\UserRepository;
 use app\traits\GzcApiRequest;
 use Carbon\Carbon;
 use think\console\Command;
@@ -524,6 +525,9 @@ class PensionTasks extends Command
                             'status'          => 1,
                             'settlement_time' => date('Y-m-d H:i:s')
                         ]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($user_sign_gongxian['uid']);
                 }
 
             });
@@ -772,6 +776,9 @@ class PensionTasks extends Command
                             'status'          => 1,
                             'settlement_time' => date('Y-m-d H:i:s')
                         ]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($user_sign_gongxian['uid']);
                 }
 
                 

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

@@ -7435,9 +7435,13 @@ class StoreOrderRepository extends BaseRepository
                 ->whereIn('status', [0, 1, 2, 3])
                 ->sum('pay_price');
 //            if ($pay_price >= 365) {
-            Db::name('user')->where('uid', $uid)->whereNotIn('user_group', [3, 4, 5, 6])->update([
-                'user_group' => 2
-            ]);
+//            Db::name('user')->where('uid', $uid)->whereNotIn('user_group', [3, 4, 5, 6])->update([
+//                'user_group' => 2
+//            ]);
+            // 设置用户 身份
+            /** @var UserRepository $userRepository */
+            $userRepository = app()->make(UserRepository::class);
+            $userRepository->setUserIdentity($uid);
         }
 
         $shouxufei = systemConfig('online_yanglao');
@@ -7466,9 +7470,12 @@ class StoreOrderRepository extends BaseRepository
         }
 
         if ($product_id == 15323) {
-            Db::name('user')->where('uid', $uid)->whereNotIn('user_group', [3, 4, 5, 6])->update([
-                'user_group' => 4//升級創客
-            ]);
+//            Db::name('user')->where('uid', $uid)->whereNotIn('user_group', [3, 4, 5, 6])->update([
+//                'user_group' => 4//升級創客
+//            ]);
+            /** @var UserRepository $userRepository */
+            $userRepository = app()->make(UserRepository::class);
+            $userRepository->setUserIdentity($uid);
         }
 
         Db::name('store_order')->where('order_id', $order_id)
@@ -10036,12 +10043,18 @@ class StoreOrderRepository extends BaseRepository
             if ($totalPayPrice >= 1180 && $totalPayPrice < 11800) {
 
                 if ($userdata['user_group'] <= 1) {
-                    Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 2]);
+//                    Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 2]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($store_order_data['uid']);
                 }
 
             } else if ($totalPayPrice >= 11800) {
                 if ($userdata['user_group'] <= 2) {
-                    Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 3]);
+//                    Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 3]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($store_order_data['uid']);
                 }
             }
 

app/common/repositories/user/UserIdentityRepository.php

@@ -94,4 +94,17 @@ class UserIdentityRepository extends BaseRepository
     {
         return $this->form($id, $this->dao->get($id)->toArray());
     }
+
+    /**
+     * @param array $where
+     * @return array
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     */
+    public function getIdentityList(array $where = [])
+    {
+        $query = $this->dao->search($where);
+        return $query->select()->toArray();
+    }
 }

app/common/repositories/user/UserRepository.php

@@ -3225,4 +3225,206 @@ class UserRepository extends BaseRepository
         $resultArray = array_diff($originalArray, [$uid]);
         return $resultArray;
     }
+
+
+    /**
+     * 设置用户 身份
+     * @param $uid
+     * @param $identityId
+     * @return int|mixed|null
+     * @throws DbException
+     */
+    public function setUserIdentity($uid, $identityId = null)
+    {
+        $result = null;
+        if (empty($identityId)) {
+            $identityId = $this->getUserIdentity($uid);
+        }
+        $this->dao->update($uid, ['user_group' => $identityId]);
+        return $identityId;
+    }
+
+    /**
+     * 获取用户 身份
+     * @param $uid
+     * @return int|mixed
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     */
+    public function getUserIdentity($uid)
+    {
+        // 1、获取所有等级信息
+        /** @var UserIdentityRepository $identityRepository */
+        $identityRepository = app()->make(UserIdentityRepository::class);
+        $identityList = $identityRepository->getIdentityList();
+
+        // 2、获取身份需要的最深等级
+        $lowerLevelNumList = array_column($identityList, 'lower_level_num');
+        $lowerLevelNumMax = max($lowerLevelNumList);
+        $lowerLevelNumMin = min($lowerLevelNumList);
+        $needLower = $lowerLevelNumMax;
+        if($lowerLevelNumMin == 0) {
+            $needLower = $lowerLevelNumMin;
+        }
+
+        // 3、获取下级用户 贡献值
+        $userContributionSumMap = [];
+        $uidContributeList = $this->getUidContributeListBySpreadUidList([$uid]);
+        foreach ($uidContributeList as $uidContribute) {
+            $userContributionSumMap[$uidContribute['uid']] = $this->getContributionSumByLevel([$uidContribute['uid']], $needLower);
+            $userContributionSumMap[$uidContribute['uid']][0] = $uidContribute['contribute'];
+        }
+
+        // 4、获取个人贡献值
+        $userData = $this->dao->get($uid)->toArray();
+
+        // 5、当前用户等级
+        $identityId = 0;
+        usort($identityList, function ($a, $b) {
+            return $b['user_group_id'] <=> $a['user_group_id'];  // 反转顺序，倒序排列
+        });
+        foreach ($identityList as $item) {
+            $lowerLevelNum = $item['lower_level_num']??0;
+
+            $arriveNumOwn = $userData['contribute'];
+            $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;
+                        }
+                    }
+                } else {
+                    $subordinateContribution[$key] = array_sum($value);
+                }
+            }
+            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'];
+                break;
+            }
+        }
+        return $identityId;
+    }
+
+    /**
+     * 获取该会员的所有下级会员
+     */
+    public function getUidContributeListBySpreadUidList(array $uidList)
+    {
+        return Db::name("user")
+            ->whereIn("spread_uid", $uidList)
+            ->field("uid, contribute, spread_uid")
+            ->select()
+            ->toArray();
+    }
+
+    /**
+     * 计算指定用户下属每一层级的总贡献值。
+     *
+     * @param array $initialUserIds 初始用户ID列表 (视为第0层)。
+     * @param int $maxDepth 需要查询的最大深度（相对于初始列表）。
+     *                      0 表示查询所有层级直到末端。
+     *                      1 表示只计算第1层（直接下级）的总贡献。
+     *                      N 表示计算到第 N 层（包含第N层）的总贡献。
+     * @return array 返回一个数组，键是层级号（从1开始），值是该层级所有用户的贡献值总和。
+     *               例如：[ 1 => 600, 2 => 1300 ]
+     */
+    public function getContributionSumByLevel(array $initialUserIds, int $maxDepth = 0): array
+    {
+        $levelContributions = []; // 结果数组 [level => total_contribution]
+        if (empty($initialUserIds)) {
+            return $levelContributions;
+        }
+
+        $currentLevelIds = $initialUserIds; // 当前层级的用户ID (初始为第0层)
+        $currentLevel = 0; // 当前层级号
+
+        // 使用一个集合跟踪所有已处理过的下级用户ID，防止重复计算和循环
+        $processedSubordinateIds = [];
+
+        while (!empty($currentLevelIds)) {
+            // 计算下一层级的编号
+            $nextLevel = $currentLevel + 1;
+
+            // 检查是否达到最大深度限制
+            if ($maxDepth > 0 && $nextLevel > $maxDepth) {
+                break; // 停止查询更深的层级
+            }
+
+            // 批量查询当前层级用户的直接下级
+            // 使用 array_chunk 防止 WHERE IN 子句过长 (根据数据库限制调整 chunkSize)
+            $chunkSize = 500;
+            $subordinatesOfCurrentLevel = [];
+            foreach(array_chunk($currentLevelIds, $chunkSize) as $chunk) {
+                $subordinatesChunk = Db::name('user')
+                    ->field('uid, contribute') // 只需要下级的uid和贡献值
+                    ->whereIn('spread_uid', $chunk) // spread_uid 在当前层级用户块中
+                    ->select()
+                    ->toArray();
+                $subordinatesOfCurrentLevel = array_merge($subordinatesOfCurrentLevel, $subordinatesChunk);
+            }
+
+            // 如果没有找到任何下级，结束循环
+            if (empty($subordinatesOfCurrentLevel)) {
+                break;
+            }
+
+            $nextLevelTotalContribution = 0;
+            $nextLevelIds = []; // 存储下一轮需要查询的用户ID
+
+            // 遍历找到的所有下级
+            foreach ($subordinatesOfCurrentLevel as $subordinate) {
+                $subordinateId = $subordinate['uid'];
+                $subordinateContribution = $subordinate['contribute'] ?? 0; // 安全获取，默认为0
+
+                // 累加下一层级的总贡献值
+                // 注意：这里简单累加，如果一个下级同时被当前层多个用户推荐，其贡献会被计算多次
+                // 如果要求每个下级只贡献一次（即使有多个上级），需要调整逻辑，
+                // 例如在累加前检查 $processedSubordinateIds
+
+                // --- 修改点：确保每个下级贡献只被计算一次 ---
+                // if (!isset($processedSubordinateIds[$subordinateId])) { // 如果这个下级还没被处理过
+                $nextLevelTotalContribution += (float)$subordinateContribution;
+                // }
+                // 注释掉上面的检查，因为用户描述似乎是按层级直接累加，不管这个下级是否被上层处理过。
+                // 如果A1和A2都属于第1层，他们各自的下级B1和B2都属于第2层，B1和B2的贡献值直接加到第2层的总和里。
+                // 如果需要严格按“人”计算，即使一个人出现在多层或被多人推荐也只算一次，则需要解开注释并调整
+
+                // 收集下一轮需要查询的用户ID，同样需要防止重复处理
+                if (!isset($processedSubordinateIds[$subordinateId])) {
+                    $nextLevelIds[] = $subordinateId;
+                    // 标记这个下级ID已处理过，避免在更深层级中再次将其加入查询队列
+                    $processedSubordinateIds[$subordinateId] = true;
+                }
+
+            }
+
+            // 存储下一层级的总贡献值 (只有当贡献值大于0或你想记录空层级时)
+            // 根据例子，我们只记录有贡献的层级，或者至少有用户的层级
+            if (!empty($subordinatesOfCurrentLevel)) { // 只要找到了下级就记录该层
+                $levelContributions[$nextLevel] = $nextLevelTotalContribution;
+            }
+
+            // 准备下一轮迭代
+            $currentLevelIds = array_unique($nextLevelIds); // 去重下一层的用户ID
+            $currentLevel = $nextLevel; // 更新当前层级
+        }
+
+        return $levelContributions;
+    }
 }

app/controller/api/Notify.php

@@ -3,6 +3,7 @@ namespace app\controller\api;
 
 use AdaPaySdk\AdapayTools;
 use app\common\repositories\store\order\StoreRefundOrderRepository;
+use app\common\repositories\user\UserRepository;
 use app\controller\api\merchant\sxy\Access;
 use app\controller\api\store\service\Huafei;
 use think\facade\Db;
@@ -1410,6 +1411,9 @@ class Notify
 
                 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) {
@@ -1466,6 +1470,9 @@ class Notify
                 // 检查是否包含“购买”
                 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);
                 }