团队数据优化

app/controller/api/user/User.php

@@ -1113,7 +1113,7 @@ class User extends BaseController
     /**
      * 一壶茶-团队列表
      */
-    public function team_list()
+    public function team_list_1()
     {
         $teamid = $this->request->uid();
 
@@ -1193,7 +1193,7 @@ class User extends BaseController
             $data['person_nums_pv'] = min( $team_userinfo_old_jbp1['common_nums_pv'],$team_userinfo_old_jbp1['person_nums_pv']);//个人联盟PV
             // $data['effective_fans_num'] = DB::name('enterprise_user')
         }
-
+        //var_dump($data);
         //把新表中的新增邀请用户加到数组中
         //$spread_usersdata = Db::name('user')->where("spread_uid",$teamid)->select();//查询旗下会员
 
@@ -1245,6 +1245,21 @@ class User extends BaseController
         //获取团队总数量
         $team_count_total = 0;
 
+        $small_count = 0;//小部门人数
+
+
+
+        //var_dump($this->calculatePerformance($subordinate_members));
+
+//获取大小部门数据(新表)
+        $get_big_small_datas = $this->getbig_samll_datas($subordinate_members);//下标0是大部门
+//var_dump( $get_big_small_datas);
+//判断大小部门的人数(根据业绩多的就是大部门，业绩小的就是小部门来计算展示的部门人数);
+        $big_team_count = $get_big_small_datas[0]['team_count'];
+        $smallteam_count = $get_big_small_datas[1]['team_count'];
+        //end
+
+
 
 
         // 遍历分页数据，构造每个会员的详细信息
@@ -1253,11 +1268,7 @@ class User extends BaseController
             //计算自己和旗下的业绩
             $t_teams_pv = $this->calculatePerformance($v['uid']);
 
-            //获取团队数量总人数
-            // foreach($t_teams_pv as $k=>$v){
-            //  var_dump($t_teams_pv['team_count']);
-            //$team_count_total += $k['team_count'];
-            //}
+
 
             $total_amount_pv_team += $t_teams_pv['total_performance'];
 
@@ -1297,13 +1308,13 @@ class User extends BaseController
         // 构造最终返回的数据
         $data = [
             'team_list' => $data1,
-            'fans_num' => $total_members, // 粉丝数
-            'new_performance' =>  $total_amount_pv_team, // 新增业绩
-            'total_performance' =>  $total_amount_pv_team, // 总业绩
-            'person_nums' =>  $team_count_total, // 个人联盟
-            'common_nums' =>  $team_count_total, // 共建联盟
-            'common_nums_pv' => 5, // 公共联盟PV
-            'person_nums_pv' => 6, // 个人联盟PV
+            'fans_num' => $get_big_small_datas[0]['team_count'] + $get_big_small_datas[1]['team_count'], // 粉丝数
+            'new_performance' =>  $get_big_small_datas[0]['total_performance'] + $get_big_small_datas[1]['total_performance'], // 新增业绩
+            'total_performance' =>  $get_big_small_datas[0]['total_performance'] + $get_big_small_datas[1]['total_performance'], // 总业绩
+            'person_nums' =>   $big_team_count, // 大部门人数
+            'common_nums' =>  $smallteam_count, // 小部门人数
+            'common_nums_pv' => $get_big_small_datas[0]['total_performance'], // 公共联盟PV
+            'person_nums_pv' => $get_big_small_datas[1]['total_performance'], // 个人联盟PV
         ];
 
 
@@ -1314,9 +1325,321 @@ class User extends BaseController
 
     }
 
+    /**
+     * 一壶茶-团队列表
+     */
+    public function team_list()
+    {
+        $teamid = $this->request->uid();
+
+
+        $teamid =  $this->request->param('teamid');//测试ID
+        //$teamid = 17;
+
+        $datas_jbp = Db::name('old_user_jbp')->where("id",$teamid)->find();//查询旧系统是否有当前会员
+        $type = $this->request->param('type',0);//1：大部门，0：小部门,2:直推
+// 初始化最终返回的数据
+        $data = [
+            'team_list' => [],
+            'fans_num' => 0, // 粉丝数
+            'new_performance' => 0, // 新增业绩
+            'total_performance' => 0, // 总业绩
+            'person_nums' => 0, // 个人联盟人数
+            'common_nums' => 0, // 公共联盟人数
+            'common_nums_pv' => 0, // 公共联盟PV
+            'person_nums_pv' => 0, // 个人联盟PV
+        ];
+
+// 如果在旧系统中有数据
+        if (!empty($datas_jbp)) {
+            $team_userinfo_old_jbp1 = $this->getPerformance($teamid);
+            $tes = $this->teamPeople($teamid, $type); // 1:团队, 2:个人
+
+            $data1 = [
+                "total" => 100,
+                "per_page" => 10,
+                "current_page" => 1,
+                "last_page" => 1,
+                "data" => []
+            ];
+
+            if ($type != 2) {
+                foreach ($tes as $k => $v) {
+                    $curr_pv = '';
+                    if ($v['curr_type'] == 0) {
+                        $curr_pv = $team_userinfo_old_jbp1['person_nums_pv'];
+                    } elseif ($v['curr_type'] == 1) {
+                        $curr_pv = $team_userinfo_old_jbp1['common_nums_pv'];
+                    } else {
+                        $curr_pv = 0;
+                    }
+
+                    $data1['data'][$k] = [
+                        "uid" => $v["id"],
+                        "nickname" => $v['user_name'] . $curr_pv,
+                        "phone" => "137****3315",
+                        "avatar" => "https://cdn.bjtdba.com/vod/image/2025-01-20/20250120125206881.png",
+                        "create_time" => "2025-01-25 11:00:18",
+                        "identity" => "11",
+                        "level" => "40002",
+                        "partnership" => "22",
+                        "total_performance" => $curr_pv,
+                        "new_performance" => 0,
+                        "team_count" => $v["performance"]['common_nums'] + $v["performance"]['person_nums'] + 1,
+                    ];
+                }
+            } else {
+                foreach ($tes as $k => $v) {
+                    $data1['data'][$k] = [
+                        "uid" => $v["uid"],
+                        "nickname" => $v['nickname'],
+                        "avatar" => $v['avatar'],
+                        "create_time" => "2025-01-25 11:00:18",
+                    ];
+                }
+            }
+
+            // 旧系统中的公共部分数据
+            $data['team_list'] = $data1;
+            $data['fans_num'] = $team_userinfo_old_jbp1['person_nums'] + $team_userinfo_old_jbp1['common_nums'];
+            $data['new_performance'] = 0;
+            $data['total_performance'] = $team_userinfo_old_jbp1['sum_nums_pv'];
+            $data['person_nums'] = $team_userinfo_old_jbp1['person_nums'];
+            $data['common_nums'] = $team_userinfo_old_jbp1['common_nums'];
+            $data['common_nums_pv'] = max($team_userinfo_old_jbp1['common_nums_pv'], $team_userinfo_old_jbp1['person_nums_pv']);
+            $data['person_nums_pv'] = min($team_userinfo_old_jbp1['common_nums_pv'], $team_userinfo_old_jbp1['person_nums_pv']);
+        }
+
+// 查询当前会员旗下的会员数据（分页）
+        [$page, $limit] = $this->getPage();
+        $subordinate_members = Db::name('user')
+            ->alias('u')
+            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
+            ->where("u.spread_uid", $teamid)
+            ->where("so.mer_id", 496)
+            ->group('u.uid')
+            ->page($page, $limit)
+            ->select();
+
+        $total_members = Db::name('user')
+            ->alias('u')
+            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
+            ->where("u.spread_uid", $teamid)
+            ->where("so.mer_id", 496)
+            ->group('u.uid')
+            ->count();
+
+        $data1 = [
+            "total" => $total_members,
+            "per_page" => $limit,
+            "current_page" => $page,
+            "last_page" => ceil($total_members / $limit),
+            "data" => []
+        ];
+
+        $total_amount_pv_team = 0;
+        $team_count_total = 0;
+
+        foreach ($subordinate_members as $k => $v) {
+            $t_teams_pv = $this->calculatePerformance($v['uid']);
+            $total_amount_pv_team += $t_teams_pv['total_performance'];
+            $team_count_total += $t_teams_pv['team_count'];
+
+            $data1['data'][$k] = [
+                "uid" => $v["uid"],
+                "nickname" => $v['nickname'],
+                "phone" => substr_replace($v['phone'], '****', 3, 4),
+                "avatar" => $v['avatar'],
+                "create_time" => $v['create_time'],
+                "total_performance" => $t_teams_pv['total_performance'],
+                "new_performance" => $t_teams_pv['total_performance'],
+                "team_count" => $t_teams_pv['team_count'],
+            ];
+        }
+
+// 获取大小部门数据
+        $get_big_small_datas = $this->getbig_samll_datas($subordinate_members);
+
+// 判断大小部门的人数
+        $big_team_count = $get_big_small_datas[0]['team_count'];
+        $small_team_count = $get_big_small_datas[1]['team_count'];
+
+// 根据 type 参数处理数据
+        if ($type == 1) {
+            usort($data1['data'], function ($a, $b) {
+                return $b['total_performance'] <=> $a['total_performance'];
+            });
+            $data1['data'] = array_slice($data1['data'], 0, 1);
+        } elseif ($type == 0) {
+            usort($data1['data'], function ($a, $b) {
+                return $b['total_performance'] <=> $a['total_performance'];
+            });
+            $data1['data'] = array_slice($data1['data'], 1);
+        }
+
+// 合并数据
+        if (!empty($datas_jbp)) {
+            // 如果旧系统中有数据，合并新旧数据
+            $data['team_list']['data'] = array_merge($data['team_list']['data'], $data1['data']);
+            $data['fans_num'] += $team_count_total;
+            $data['new_performance'] += $total_amount_pv_team;
+            $data['total_performance'] += $total_amount_pv_team;
+            $data['person_nums'] += $big_team_count;
+            $data['common_nums'] += $small_team_count;
+            $data['common_nums_pv'] += $get_big_small_datas[0]['total_performance'];
+            $data['person_nums_pv'] += $get_big_small_datas[1]['total_performance'];
+        } else {
+            // 如果旧系统中没有数据，直接使用新数据
+            $data['team_list'] = $data1;
+            $data['fans_num'] = $team_count_total;
+            $data['new_performance'] = $total_amount_pv_team;
+            $data['total_performance'] = $total_amount_pv_team;
+            $data['person_nums'] = $big_team_count;
+            $data['common_nums'] = $small_team_count;
+            $data['common_nums_pv'] = $get_big_small_datas[0]['total_performance'];
+            $data['person_nums_pv'] = $get_big_small_datas[1]['total_performance'];
+        }
+
+        return app("json")->success($data);
+
+    }
+
     //计算自己和自己团队下面的业绩。新表
+//计算自己和自己团队下面的业绩。新表
     public function calculatePerformance($uid)
     {
+        // 初始化业绩数组
+        $performance = [
+
+            'personal_performance' => 0, // 个人业绩
+            'team_performance' => 0, // 团队业绩
+            'total_performance' => 0, // 总业绩
+            'team_count' => 0, // 加上自己的团队数量
+
+        ];
+
+        // 定义业绩换算规则
+        $performanceMapping = [
+            1180 => 700,
+            10620 => 6300,
+            11800 => 7000
+        ];
+
+        // 计算个人业绩
+        $personalOrder = Db::name('store_order')->where("uid", $uid)->find();
+
+        if ($personalOrder) {
+            // 将浮点数转换为整数
+            $totalPrice = (int)$personalOrder['total_price'];
+            if (isset($performanceMapping[$totalPrice])) {
+                $performance['personal_performance'] = $performanceMapping[$totalPrice];
+            }
+        }
+
+        // 计算旗下团队成员的业绩
+        $teamOrders = Db::name('user')
+            ->alias('u')
+            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
+            ->where("u.spread_uid", $uid) // 查询旗下会员
+            ->where("so.mer_id", 496)
+            // ->where("so.douhuomall", 1)
+            // ->where("so.douhuomall_status", 9)
+            // ->where("so.status", 0)
+            ->select();
+
+        $teamOrders_count = Db::name('user')
+            ->alias('u')
+            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
+            ->where("u.spread_uid", $uid) // 查询旗下会员
+            ->where("so.mer_id", 496)
+            // ->where("so.douhuomall", 1)
+            // ->where("so.douhuomall_status", 9)
+            // ->where("so.status", 0)
+            ->count();
+
+        $performance['team_count'] = $teamOrders_count + 1; // 赋值团队数量
+
+        foreach ($teamOrders as $order) {
+            if ($order['total_price']) {
+                // 将浮点数转换为整数
+                $totalPrice = (int)$order['total_price'];
+                if (isset($performanceMapping[$totalPrice])) {
+                    $performance['team_performance'] += $performanceMapping[$totalPrice];
+                }
+            }
+        }
+
+        // 计算总业绩
+        $performance['total_performance'] = $performance['personal_performance'] + $performance['team_performance'];
+
+        // 假设总业绩最大值需要通过后续逻辑判断，这里暂时设置为 false
+        return $performance;
+    }
+
+//获取大小部门业绩（新表）
+    public function getbig_samll_datas($subordinate_members){
+        //单独写一个方法获取大小部门的数据
+        $arr_team = [];
+        foreach ($subordinate_members as $k => $v) {
+
+            //计算自己和旗下的业绩
+            $arr_team[] = $this->calculatePerformance($v['uid']);
+        }
+
+        // 初始化变量
+        $maxPerformance = 0;
+        $maxIndex = -1;
+
+        // 找出 total_performance 最高的记录
+        foreach ($arr_team as $index => $item) {
+            if ($item['total_performance'] > $maxPerformance) {
+                $maxPerformance = $item['total_performance'];
+                $maxIndex = $index;
+            }
+        }
+
+        // 如果找到了最高记录
+        if ($maxIndex !== -1) {
+            // 提取最高记录
+            $maxRecord = $arr_team[$maxIndex];
+            // 从原数组中移除该记录
+            unset($arr_team[$maxIndex]);
+            // 重新索引数组
+            $arr_team = array_values($arr_team);
+        } else {
+            // 如果没有找到记录，可以设置一个默认值
+            $maxRecord = null;
+        }
+
+        // 计算大部门和小部门的汇总信息
+        $majorDepartmentSummary = [
+            "total_person_performance" => $maxRecord ? $maxRecord['personal_performance'] : 0,
+            "total_team_performance" => $maxRecord ? $maxRecord['team_performance'] : 0,
+            "total_performance" => $maxRecord ? $maxRecord['total_performance'] : 0,
+            "team_count" => $maxRecord ? $maxRecord['team_count'] : 0,
+            "data" => $maxRecord ? [$maxRecord] : []
+        ];
+
+        $minorDepartmentSummary = [
+            "total_person_performance" => array_sum(array_column($arr_team, 'personal_performance')),
+            "total_team_performance" => array_sum(array_column($arr_team, 'team_performance')),
+            "total_performance" => array_sum(array_column($arr_team, 'total_performance')),
+            "team_count" => array_sum(array_column($arr_team, 'team_count')),
+            "data" => $arr_team
+        ];
+
+        // 输出结果
+        // echo "大部门汇总信息:\n";
+        // print_r($majorDepartmentSummary);
+        // echo "小部门汇总信息:\n";
+        // print_r($minorDepartmentSummary);
+
+        return array($majorDepartmentSummary,$minorDepartmentSummary);
+    }
+
+    //计算自己和自己团队下面的业绩。新表
+    public function calculatePerformance_copy($uid)
+    {
 
         // 初始化业绩数组
         $performance = [