Merge branch 'master' into huangfamily

app/controller/api/Auth.php

@@ -2041,18 +2041,23 @@ class Auth extends BaseController
 
     
     public function getconlev(){
-        $userid = 17;
-        $datas = $this->getPerformance22($userid);
+        // $userid = 17;
+        // $datas = $this->getPerformance_getcon($userid);
+
+        // var_dump($datas);
+
+        $dats = db::name("store_order")->whereIn("status",[0,1,2,3])->select();
+        var_dump($dats);
+
 
-        var_dump($datas);
     }
 
 
 
     /**
-     * 获取当前用户业绩
+     * 获取当前用户大小部门贡献值
      */
-    public function getPerformance22($user_id) {
+    public function getPerformance_getcon($user_id) {
 
       
 
@@ -2063,7 +2068,7 @@ class Auth extends BaseController
         $result_big_team_arr = [];
         $get_teams_comm_datas = [];//在2.0中获取父级下面的所有团队数据
         //共建联盟业绩 个人联盟业绩 共建联盟总pv 个人联盟业绩pv
-        $common_nums = $this->getCommonNums($user_id);
+        $common_nums = $this->getCommonNums_getcon($user_id);
       
         //var_dump($common_nums);
         $get_teams_comm_num = 0;
@@ -2080,7 +2085,7 @@ class Auth extends BaseController
          
             //获取当前用户
             foreach($common_nums as $v){
-                $child_nums[] = $this->getRecursiveChildren($v);
+                $child_nums[] = $this->getRecursiveChildren_getcon($v);
             }
            
          
@@ -2097,7 +2102,7 @@ class Auth extends BaseController
             //var_dump($result_big_team_arr);
             //获取当前用户下面在2.0中的下级所有PV
             //$get_teams_comm_pv = $this->getteampv($result_big_team_arr);
-            $t_pv = $this->getteampv($result_big_team_arr);
+            $t_pv = $this->getteampv_getcon($result_big_team_arr);
             $get_teams_comm_pv = $t_pv;
             //var_dump($get_teams_comm_pv);echo "ttt";
 
@@ -2105,15 +2110,15 @@ class Auth extends BaseController
         }else{
           
                //当前用户在1.0没有下级，那直接在新系统2.0找下级获取数据，并区分大小部门
-              $child_nums = $this->getChildren($user_id);
+              $child_nums = $this->getChildren_getcon($user_id);
              
               //获取父级子级下面的个人
-              $num_teams = $this->getTeamSize($child_nums);
+              $num_teams = $this->getTeamSize_getcon($child_nums);
           
               //var_dump($num_teams);
               foreach($child_nums as $v){
                 
-                   $get_teams_comm_datas[] = $this->getTeamPv11($v);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
+                   $get_teams_comm_datas[] = $this->getTeamPv11_getcon($v);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
               }
 
               //$s = $this->getparents_child_pv($user_id);
@@ -2129,7 +2134,7 @@ class Auth extends BaseController
 
                     // var_dump( $get_teams_comm_datas);
                     //获取一个最大值，设为大部门，其他的加载一块是小部门
-                    $getss = $this->processArray($get_teams_comm_datas);
+                    $getss = $this->processArray_getcon($get_teams_comm_datas);
                  //var_dump($getss);
                     $max_value_count = $num_teams[$getss['max_index']]['total_count'];
 
@@ -2149,8 +2154,7 @@ class Auth extends BaseController
                     $person_amount = $getss['remaining_sum'];
                     $get_teams_comm_pv = $getss['max_value'];
               }
-              
-              
+          
         }
         //var_dump($get_teams_comm_pv);
         //合并业绩和人数
@@ -2158,7 +2162,7 @@ class Auth extends BaseController
            
         //var_dump($team_amount);
         //1.0获取小区业绩
-        $person_nums = $this->getPersonageNums($user_id);
+        $person_nums = $this->getPersonageNums_getcon($user_id);
         //var_dump($person_nums);
         $result_small_team_arr = [];
           //1.0系统中有下级，需要在2.0中再加下级数据
@@ -2170,7 +2174,7 @@ class Auth extends BaseController
 
               //获取当前用户
             foreach($person_nums as $v){
-                $child_nums_mix[] = $this->getRecursiveChildren($v);
+                $child_nums_mix[] = $this->getRecursiveChildren_getcon($v);
             }
        
             //去除空数组，并重新组合有数据的数组
@@ -2188,7 +2192,7 @@ class Auth extends BaseController
             //var_dump($result_small_team_arr);
             //获取当前用户下面在2.0中的下级所有PV
            // $get_teams_per_pv = $this->getteampv($result_small_team_arr);
-           $t_pv = $this->getteampv($result_small_team_arr);
+           $t_pv = $this->getteampv_getcon($result_small_team_arr);
            $get_teams_per_pv =$t_pv;
            //var_dump(  $get_teams_per_pv);
           
@@ -2196,40 +2200,19 @@ class Auth extends BaseController
         
         
           //获取当前用户下面在2.0中的下级所有人数
-            $get_teams_per_num += count($result_small_team_arr);
+           // $get_teams_per_num += count($result_small_team_arr);
             //合并业绩和人数
             $person_amount += $get_teams_per_pv;
 
-            
-        //     if($user_id == 593){
-        //         $person_amount = 2800;
-               
-        //    }
-
-        //var_dump($common_nums);
-        //用户小部门所有在2.0系统下面的业绩和人数 end
-
-      //var_dump($team_amount);
-        // $common_nums[] = $user_id;
-        // foreach ($common_nums as $key => $value) {
-        //     # code...
-        //     $amount = $this->getPerformance1($value);
-        //     $team_amount += $amount;
-        // }
-        // foreach ($person_nums as $key => $value) {
-        //     # code...
-        //     $amount = $this->getPerformance1($value);
-        //     $person_amount += $amount;
-        // }
-        
+      
         //当前会员直属的业绩（1.0大部门）
-        $t_pv = $this->getteampv($common_nums);
+        $t_pv = $this->getteampv_getcon($common_nums);
         $team_amount += $t_pv;
 
          //当前会员直属的业绩（1.0大部门）
-        $p_pv = $this->getteampv($person_nums);
+        $p_pv = $this->getteampv_getcon($person_nums);
         $person_amount += $p_pv;
-       
+    
 
       
     //var_dump($team_amount,$person_amount);
@@ -2238,21 +2221,12 @@ class Auth extends BaseController
         
             //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
             //例子:17所有下面uid是speard_uid都是17的，和所有伞下的业绩。分出大小部门，加到1.0的大小部门中
-            $b_s = $this->getparents_child_pv11($user_id,$team_amount,$person_amount);
-            
-            //var_dump($b_s);
-            // var_dump($team_amount,$person_amount);
-            // var_dump(count($common_nums)+ $get_teams_comm_num,count($person_nums)+ $get_teams_per_num);
-            //var_dump( $b_s);echo "yyyyyyyyyyyyy";
+            $b_s = $this->getparents_child_pv11_getcon($user_id,$team_amount,$person_amount);
+         
             $team_amount = $b_s[0];
-            // $teams_num = $b_s['big_department']['count'];
-              //var_dump($b_s);
-            //       var_dump($b_s['per_pv']);
-
+          
             $person_amount = $b_s[1];
 
-            // $per_num = $b_s['small_department']['count'];//小部门人数
-            //var_dump( $b_s['team_num'],$b_s['per_num']);
         }
 
 
@@ -2271,7 +2245,7 @@ class Auth extends BaseController
      /**
      * 获取该用户共建联盟
      */
-    public function getCommonNums($user_id){
+    public function getCommonNums_getcon($user_id){
 
 
 
@@ -2295,7 +2269,7 @@ class Auth extends BaseController
     /**
      * 获取该用户个人联盟
      */
-    public function getPersonageNums($user_id){
+    public function getPersonageNums_getcon($user_id){
 
         $son_ids = Db::name("old_user_jbp")->where("spread",$user_id)->where("is_team",0)->field("id")->select();
         $new_array_ids =[];
@@ -2316,7 +2290,7 @@ class Auth extends BaseController
     }
 
         // 根据父级uid,递归获取所有子级UID数组
-    public function getRecursiveChildren($parentUid) {
+    public function getRecursiveChildren_getcon($parentUid) {
         $result = []; // 用于存储所有子级的 uid
 
         // 定义递归函数
@@ -2345,7 +2319,7 @@ class Auth extends BaseController
     }
 
     //只获取数组中的业绩
-    public function getteampv($common_nums) {
+    public function getteampv_getcon($common_nums) {
 
          // // 查询当前用户及其子级的所有订单
         $orders_gongxian = Db::name("user_sign_gongxian")
@@ -2353,7 +2327,7 @@ class Auth extends BaseController
                     ->whereIn("uid", $common_nums)
                   
                     ->select();
-
+        //var_dump( $common_nums);
 
         $total_gongxian = 0;
         // // 遍历订单计算业绩
@@ -2363,9 +2337,9 @@ class Auth extends BaseController
             }
         }    
 
-        return $total_gongxian;
+         return $total_gongxian;
 
-        // // 查询当前用户及其子级的所有订单
+        // // // 查询当前用户及其子级的所有订单
         // $orders = Db::name("store_order")
         //             ->whereIn('status', [0, 1, 2, 3])
         //             ->whereIn("uid", $common_nums)
@@ -2400,7 +2374,7 @@ class Auth extends BaseController
 
 
         // 2.0 根据父级uid,找到当前用户下面的UID
-    public function getChildren($parentUid) {
+    public function getChildren_getcon($parentUid) {
         $result = []; // 用于存储所有子级的 uid
 
     
@@ -2414,7 +2388,7 @@ class Auth extends BaseController
 
 
       // 递归获取所有子级 UID 的业绩
-    public function getTeamPv11($parentUid) {
+    public function getTeamPv11_getcon($parentUid) {
     
         $getRecursiveChildren = function ($parentUid) use (&$getRecursiveChildren) {
             $children = Db::name("user")
@@ -2482,7 +2456,7 @@ class Auth extends BaseController
     }
 
     //根据传递的父级数组，返回他的对应子级的个数
-    public function getTeamSize($parentUids) {
+    public function getTeamSize_getcon($parentUids) {
         // 初始化结果数组
         $result = [];
 
@@ -2523,7 +2497,7 @@ class Auth extends BaseController
         return $result;
     }
 
-    public function processArray($array) {
+    public function processArray_getcon($array) {
         // 初始化结果数组
         $result = [
             'max_value' => null,     // 最大值
@@ -2565,7 +2539,7 @@ class Auth extends BaseController
        /**
      * 获取流水信息
      */
-    public function getPerformance1($user_id) {
+    public function getPerformance1_getcon($user_id) {
         // $amount = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->sum("money");
 
         // $amount = isset($amount) ? round($amount*0.7,2) : 0;
@@ -2615,56 +2589,69 @@ class Auth extends BaseController
     }
 
         //1.0用户直属的部门和2.0直属的部门，进行比较，获取大部门和小部门数据
-        public function getparents_child_pv11($user_id, $bigamount, $smallamount) {
-        // 获取直接下级的 UID 列表
+        public function getparents_child_pv11_getcon($user_id, $bigamount, $smallamount) {
+
+            // 获取直接下级的 UID 列表
             $get_childs = Db::name("user")
             ->where("spread_uid", $user_id)
             ->column("uid");
 
-            // 如果没有直属下级，直接返回 [0, 0]
-            if (empty($get_childs)) {
-                return [0, 0];
-            }
-
-            // 初始化数组存储直属下级的业绩
-            $all_departments = [];
+            // 初始化变量
+            $all_departments = []; // 用于存储所有直属下级的业绩
 
             // 遍历每个直属下级
             foreach ($get_childs as $child) {
                 // 获取当前下级及其子级
                 $child_group = [$child];
-                $recursive_children = $this->getRecursiveChildren($child);
+                $recursive_children = $this->getRecursiveChildren_getcon($child);
                 $child_group = array_merge($child_group, $recursive_children);
 
                 // 获取当前分组的业绩
-                $result = $this->getteampv($child_group);
-
-                // 如果返回的业绩为 null 或 0，直接返回 [0, 0]
-                if ($result === null || $result['totalPv'] == 0) {
-                    return [0, 0];
-                }
+                $result = $this->getteampv_getcon($child_group);
 
                 // 将直属下级的业绩加入数组
-                $all_departments[] = $result['totalPv'];
+                $all_departments[] = $result;
             }
 
-            // 将传入的 $bigamount 和 $smallamount 也加入数组
+            // 将传入的 $bigamount 和 $smallamount 加入数组
             $all_departments[] = $bigamount;
             $all_departments[] = $smallamount;
 
-            // 找出最大业绩
-            $max_department = max($all_departments);
+            // 检查是否所有业绩都是 0
+            if (count(array_filter($all_departments, function($value) { return $value != 0; })) == 0) {
+                return [0, 0];
+            }
 
-            // 计算小部门业绩：总和 - 最大值
-            $small_department = array_sum($all_departments) - $max_department;
-var_dump($max_department);
-            // 返回结果
-            return [$max_department, $small_department];
+            // 初始化最大部门和小部门
+            $max_department = 0;
+            $small_department = 0;
+
+            // 遍历 $all_departments，找出最大值并累加小部门的值
+            foreach ($all_departments as $department) {
+                if ($department > $max_department) {
+                    // 如果当前部门的业绩大于最大部门的业绩，更新最大部门
+                    if ($max_department != 0) {
+                        $small_department += $max_department; // 将旧的最大值累加到小部门
+                    }
+                    $max_department = $department; // 更新最大部门
+                } else {
+                    // 如果当前部门的业绩小于或等于最大部门的业绩，累加到小部门
+                    $small_department += $department;
+                }
+            }
 
+            // 返回结果
+            return [
+                $max_department, // 大部门业绩
+                $small_department // 小部门业绩
+            ];
+            //拿$bigamount, $smallamount业绩和get_childs产生的result业绩去对比。如果都是0.说明没有大小部门了，直接返回0，0如果只有一个数组有数据，
+            // 说明只有大部门，默认返回大部门数据，小部门返回0，如果有多条数组数据是一样的，那么就是选一个，设为大部门。剩下的数据叠加设为小部门
+          
         }
 
         //获取当前uesr_id下面在2.0中是否还有直接下级，并计算她的大部门和小部门
-        public function getparents_child_pv($user_id){
+        public function getparents_child_pv_getcon($user_id){
         // 获取直接下级的 UID 列表
         //$user_id = 593;
         // $get_childs = $this->getRecursiveChildren($user_id);

app/controller/api/merchant/sxy/Access.php

@@ -821,6 +821,7 @@ class Access
             if($oid == '')
                 return app('json')->fail("请检查参数是否正确");
             $groupOrder = $groupOrderRepository->detail_noUid((int)$oid);
+            db::name("test_log")->insert(["note"=>json_encode($groupOrder)]);
             if (!$groupOrder)
                 return app('json')->fail('订单不存在或已支付');
 
@@ -2208,6 +2209,8 @@ class Access
 
 
             if ($groupOrder['order_type'] = "marketing"){
+
+                db::name("test_log")->insert(["note"=>"pay_huifu" . json_encode($groupOrder)]);
                 // 创富宝 分账
                 //创富宝
                 $cfb = sprintf("%01.2f",round(bcmul($groupOrder['pay_price'],'0.094',5),2));//9.4%的分账

app/controller/api/user/User.php

@@ -252,12 +252,15 @@ class User extends BaseController
             }
            
             
-            $getteamscon = $this->getPerformance($user->uid);
+           // $getteamscon = $this->getPerformance($user->uid);
+
+            $getcon = $this->getPerformance_getcon( $user->uid);
+
             //我的团队贡献值
-            $data['team_gongxian_num'] = $getteamscon['sum_nums_pv'];
+            $data['team_gongxian_num'] = $getcon['common_nums_pv'] + $getcon['person_nums_pv'];
 
             //为生贡献值
-            $data['no_total_source']=Db::name('user_sign_gongxian')->where('status', -1)->where('uid', $user->uid)->sum('number');;
+            $data['no_total_source']=Db::name('user_sign_gongxian')->where('status', -1)->where('uid', $user->uid)->sum('number');
             log::info("====spread_info_yhc=={$data['total_source']}======={$data['no_total_source']}");
             return app('json')->success($data);
 
@@ -1403,7 +1406,7 @@ class User extends BaseController
 
 
         if($teamid == 592){
-             $teamid = 222;//593
+             $teamid = 454;//593
 
            // $ss=  $this->userupdates($teamid);
            // var_dump($ss);
@@ -3781,27 +3784,28 @@ return app("json")->success($data);
     }
 
     //1.0用户直属的部门和2.0直属的部门，进行比较，获取大部门和小部门数据
-    public function getparents_child_pv11($user_id, $bigamount, $smallamount,$common_nums,$person_nums) {
+    public function getparents_child_pv11($user_id, $bigamount, $smallamount, $common_nums, $person_nums) {
         // 获取直接下级的 UID 列表
         $get_childs = Db::name("user")
-        ->where("spread_uid", $user_id)
-        ->column("uid");
-
-        // var_dump($get_childs);
+            ->where("spread_uid", $user_id)
+            ->column("uid");
+    
         // 初始化变量
         $all_departments = []; // 用于存储所有直属下级的业绩和人数
-
+    
         // 遍历每个直属下级
         foreach ($get_childs as $child) {
             // 获取当前下级及其子级
             $child_group = [$child];
             $recursive_children = $this->getRecursiveChildren($child);
-        
             $child_group = array_merge($child_group, $recursive_children);
-
+    
             // 获取当前分组的业绩和人数
             $result = $this->getteampv($child_group);
-
+            // if($user_id == 593){
+            //     var_dump($result);
+            // }
+    
             // 将直属下级的业绩和人数加入数组
             $all_departments[] = [
                 'value' => $result['totalPv'],
@@ -3814,39 +3818,39 @@ return app("json")->success($data);
             'value' => $bigamount,
             'count' => $common_nums // 大部门的人数
         ];
+    
         $all_departments[] = [
             'value' => $smallamount,
             'count' => $person_nums // 小部门的人数
         ];
     
-        //
-        // 找出最大业绩及其对应的人数
+        // 初始化最大部门和小部门
         $max_department = null;
-        foreach ($all_departments as $department) {
-            if ($max_department === null || $department['value'] > $max_department['value']) {
-                $max_department = $department;
-            }
-        }
-
-        // 计算小部门业绩和人数：总和 - 最大值
         $small_department = [
             'value' => 0,
             'count' => 0
         ];
+    
+        // 遍历 $all_departments，找出最大值并累加小部门的值
         foreach ($all_departments as $department) {
-            if ($department['value'] !== $max_department['value']) {
+            if ($max_department === null || $department['value'] > $max_department['value']) {
+                // 如果当前部门的业绩大于最大部门的业绩，更新最大部门
+                $small_department['value'] += $max_department['value'] ?? 0; // 将旧的最大值累加到小部门
+                $small_department['count'] += $max_department['count'] ?? 0;
+    
+                $max_department = $department; // 更新最大部门
+            } else {
+                // 如果当前部门的业绩小于或等于最大部门的业绩，累加到小部门
                 $small_department['value'] += $department['value'];
                 $small_department['count'] += $department['count'];
             }
         }
-    //var_dump($max_department,$small_department);
+    
         // 返回结果
         return [
             'big_department' => $max_department,
             'small_department' => $small_department
         ];
-
-    
     }
 
     //根据父级IDS获取伞下的所有子级ID
@@ -3940,7 +3944,7 @@ return app("json")->success($data);
 
         $team_amount = 0;
         $person_amount = 0;
-        $user_id = 780; //598 523 536
+        $user_id = 454; //598 523 536
         
         $result_big_team_arr = [];
         $get_teams_comm_datas = [];//在2.0中获取父级下面的所有团队数据
@@ -4044,7 +4048,7 @@ return app("json")->success($data);
         //var_dump($team_amount);
         //1.0获取小区业绩
         $person_nums = $this->getPersonageNums($user_id);
-      // var_dump($person_nums);
+       //var_dump($person_nums);
         $result_small_team_arr = [];
           //1.0系统中有下级，需要在2.0中再加下级数据
      
@@ -4106,8 +4110,8 @@ return app("json")->success($data);
             $amount = $this->getPerformance1($value);
             $person_amount += $amount;
         }
-       // var_dump($team_amount);
-        //var_dump($person_amount);
+        // var_dump($team_amount);
+        // var_dump($person_amount);
 
         //
          
@@ -4212,6 +4216,9 @@ return app("json")->success($data);
         $per_num = count($person_nums) + $get_teams_per_num;
 
 
+        //  var_dump($team_amount);
+        // var_dump($person_amount);
+
         //如果当前用户是1.0用户，找到其直推所有的业绩，根据业绩找到大小部门的同时，还要比对1.0中大小部门的业绩，摘出一个最大业绩的部门是大部门，其余都是小部门()
         if($user_id < 611){
          
@@ -4222,16 +4229,16 @@ return app("json")->success($data);
             //例子:17所有下面uid是speard_uid都是17的，和所有伞下的业绩。分出大小部门，加到1.0的大小部门中
             $b_s = $this->getparents_child_pv11($user_id,$team_amount,$person_amount,count($common_nums)+ $get_teams_comm_num,count($person_nums)+ $get_teams_per_num);
             
-            var_dump($b_s);
+            //var_dump($b_s);
             // var_dump($team_amount,$person_amount);
             // var_dump(count($common_nums)+ $get_teams_comm_num,count($person_nums)+ $get_teams_per_num);
             //var_dump( $b_s);echo "yyyyyyyyyyyyy";
             $team_amount = $b_s['big_department']['value'];
-             $teams_num = $b_s['big_department']['count'];
-        //       var_dump($b_s['team_pv']);
-        //       var_dump($b_s['per_pv']);
+            $teams_num = $b_s['big_department']['count'];
+            //       var_dump($b_s['team_pv']);
+            //       var_dump($b_s['per_pv']);
 
-         $person_amount = $b_s['small_department']['value'];
+            $person_amount = $b_s['small_department']['value'];
 
             $per_num = $b_s['small_department']['count'];//小部门人数
            //var_dump( $b_s['team_num'],$b_s['per_num']);
@@ -5321,6 +5328,656 @@ return app("json")->success($data);
     // }
 
 
+    //获取大小部门贡献值
+    /**
+     * 获取当前用户大小部门贡献值
+     */
+    public function getPerformance_getcon($user_id) {
+
+      
+
+        $team_amount = 0;
+        $person_amount = 0;
+       // $user_id = 593; //598 523 536
+        
+        $result_big_team_arr = [];
+        $get_teams_comm_datas = [];//在2.0中获取父级下面的所有团队数据
+        //共建联盟业绩 个人联盟业绩 共建联盟总pv 个人联盟业绩pv
+        $common_nums = $this->getCommonNums_getcon($user_id);
+      
+        //var_dump($common_nums);
+        $get_teams_comm_num = 0;
+        $get_teams_comm_pv = 0;
+
+        $get_teams_per_num = 0;//小部门人数
+        //1.0系统中有下级，需要在2.0中再加下级数据
+        if($user_id < 611){
+             //梅红在2.0中的ID是780
+           
+         //var_dump( $common_nums);
+            //用户三峡所有在2.0系统下面的业绩和人数 start
+            $child_nums = [];
+         
+            //获取当前用户
+            foreach($common_nums as $v){
+                $child_nums[] = $this->getRecursiveChildren_getcon($v);
+            }
+           
+         
+            //去除空数组，并重新组合有数据的数组
+            $filteredData = array_filter($child_nums, function($array) {
+                return !empty($array); // 如果数组不为空，则保留
+            });
+
+            // 合并所有非空数组
+           
+            foreach ($filteredData as $array) {
+                $result_big_team_arr = array_merge($result_big_team_arr, $array);
+            }
+            //var_dump($result_big_team_arr);
+            //获取当前用户下面在2.0中的下级所有PV
+            //$get_teams_comm_pv = $this->getteampv($result_big_team_arr);
+            $t_pv = $this->getteampv_getcon($result_big_team_arr);
+            $get_teams_comm_pv = $t_pv;
+            //var_dump($get_teams_comm_pv);echo "ttt";
+
+            //用户伞下小部门所有在2.0系统下面的业绩和人数 end
+        }else{
+          
+               //当前用户在1.0没有下级，那直接在新系统2.0找下级获取数据，并区分大小部门
+              $child_nums = $this->getChildren_getcon($user_id);
+             
+              //获取父级子级下面的个人
+              $num_teams = $this->getTeamSize_getcon($child_nums);
+          
+              //var_dump($num_teams);
+              foreach($child_nums as $v){
+                
+                   $get_teams_comm_datas[] = $this->getTeamPv11_getcon($v);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
+              }
+
+              //$s = $this->getparents_child_pv($user_id);
+
+              //var_dump($get_teams_comm_datas);
+              //如果只有一个部门，就是默认大部门
+              if( count($get_teams_comm_datas) ==1 ){
+                  
+                  $get_teams_comm_pv =$get_teams_comm_datas[0];
+                  $get_teams_comm_num = $num_teams[0]['total_count'];
+                  
+              }else if(count($get_teams_comm_datas) >1){
+
+                    // var_dump( $get_teams_comm_datas);
+                    //获取一个最大值，设为大部门，其他的加载一块是小部门
+                    $getss = $this->processArray_getcon($get_teams_comm_datas);
+                 //var_dump($getss);
+                    $max_value_count = $num_teams[$getss['max_index']]['total_count'];
+
+                    unset($num_teams[$getss['max_index']]);
+
+                       //获取小部门的人数
+                       $per_num = 0;
+                       foreach($num_teams as $k=>$v){
+                        $per_num +=$v['total_count'];
+                       }
+        
+                    //找到最大值的(大部门)
+                    //$get_teams_comm_num = $max_value_count;
+                    //小部门的数量
+                   // $get_teams_per_num =  $per_num;
+                    //var_dump($getss['max_value']);
+                    $person_amount = $getss['remaining_sum'];
+                    $get_teams_comm_pv = $getss['max_value'];
+              }
+          
+        }
+        //var_dump($get_teams_comm_pv);
+        //合并业绩和人数
+        $team_amount += $get_teams_comm_pv;
+           
+        //var_dump($team_amount);
+        //1.0获取小区业绩
+        $person_nums = $this->getPersonageNums_getcon($user_id);
+        //var_dump($person_nums);
+        $result_small_team_arr = [];
+          //1.0系统中有下级，需要在2.0中再加下级数据
+     
+      
+      
+           //用户三峡所有在2.0系统下面的业绩和人数 start
+            $child_nums_mix = [];
+
+              //获取当前用户
+            foreach($person_nums as $v){
+                $child_nums_mix[] = $this->getRecursiveChildren_getcon($v);
+            }
+       
+            //去除空数组，并重新组合有数据的数组
+            $filteredData_1 = array_filter($child_nums_mix, function($array) {
+                return !empty($array); // 如果数组不为空，则保留
+            });
+            
+            // 合并所有非空数组
+            $result_small_team_arr = [];
+            foreach ($filteredData_1 as $array) {
+                $result_small_team_arr = array_merge($result_small_team_arr, $array);
+            }
+
+
+            //var_dump($result_small_team_arr);
+            //获取当前用户下面在2.0中的下级所有PV
+           // $get_teams_per_pv = $this->getteampv($result_small_team_arr);
+           $t_pv = $this->getteampv_getcon($result_small_team_arr);
+           $get_teams_per_pv =$t_pv;
+           //var_dump(  $get_teams_per_pv);
+          
+       
+        
+        
+          //获取当前用户下面在2.0中的下级所有人数
+           // $get_teams_per_num += count($result_small_team_arr);
+            //合并业绩和人数
+            $person_amount += $get_teams_per_pv;
+
+      
+        //当前会员直属的业绩（1.0大部门）
+        $t_pv = $this->getteampv_getcon($common_nums);
+        $team_amount += $t_pv;
+
+         //当前会员直属的业绩（1.0大部门）
+        $p_pv = $this->getteampv_getcon($person_nums);
+        $person_amount += $p_pv;
+    
+
+      
+    //var_dump($team_amount,$person_amount);
+        //如果当前用户是1.0用户，找到其直推所有的业绩，根据业绩找到大小部门的同时，还要比对1.0中大小部门的业绩，摘出一个最大业绩的部门是大部门，其余都是小部门()
+        if($user_id < 611){
+        
+            //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
+            //例子:17所有下面uid是speard_uid都是17的，和所有伞下的业绩。分出大小部门，加到1.0的大小部门中
+            $b_s = $this->getparents_child_pv11_getcon($user_id,$team_amount,$person_amount);
+         
+            $team_amount = $b_s[0];
+          
+            $person_amount = $b_s[1];
+
+        }
+
+
+
+        $return_data = [
+           
+            'common_nums_pv'=> $team_amount,
+            'person_nums_pv'=> $person_amount,
+          
+        ];
+
+        return $return_data;
+
+    }
+
+     /**
+     * 获取该用户共建联盟
+     */
+    public function getCommonNums_getcon($user_id){
+
+
+
+        //先获取共建联盟下用户的id
+        $son_ids = Db::name("old_user_jbp")->where("spread",$user_id)->where("is_team",1)->select()->toArray();
+        $new_array_ids =[];
+        foreach ($son_ids as $key => $value) {
+            # code...
+            $son_id = $value['id'];
+            $new_array_ids = array_merge($new_array_ids,[$son_id]);
+            $son_value_ids = Db::name("old_user_jbp")->whereRaw("FIND_IN_SET('$son_id',parent_ids)")->field("id")->select()->toArray();
+
+            if(count($son_value_ids) > 0) {
+                $son_value_ids = array_column($son_value_ids,"id");
+                $new_array_ids = array_merge($new_array_ids,$son_value_ids);
+            }
+
+        }
+        return $new_array_ids;
+    }
+    /**
+     * 获取该用户个人联盟
+     */
+    public function getPersonageNums_getcon($user_id){
+
+        $son_ids = Db::name("old_user_jbp")->where("spread",$user_id)->where("is_team",0)->field("id")->select();
+        $new_array_ids =[];
+        // return 3343;
+        foreach ($son_ids as $key => $value) {
+            # code...
+            $son_id = $value['id'];
+            $new_array_ids = array_merge($new_array_ids,[$son_id]);
+            $son_value_ids = Db::name("old_user_jbp")->whereRaw("FIND_IN_SET('$son_id',parent_ids)")->field("id")->select()->toArray();
+
+            if(count($son_value_ids) > 0) {
+                $son_value_ids = array_column($son_value_ids,"id");
+                $new_array_ids = array_merge($new_array_ids,$son_value_ids);
+            }
+
+        }
+        return $new_array_ids;
+    }
+
+        // 根据父级uid,递归获取所有子级UID数组
+    public function getRecursiveChildren_getcon($parentUid) {
+        $result = []; // 用于存储所有子级的 uid
+
+        // 定义递归函数
+        $recursion = function ($parentUid) use (&$result, &$recursion) {
+            // 查询当前父级的所有直接子级
+            $children = Db::name("user")
+                        ->where("spread_uid", $parentUid)
+                        ->column("uid"); // 获取子级的 uid 列表
+
+            // 如果没有子级，直接返回
+            if (empty($children)) {
+                return;
+            }
+
+            // 遍历每个子级
+            foreach ($children as $childUid) {
+                $result[] = $childUid; // 将子级的 uid 添加到结果数组
+                $recursion($childUid); // 递归查询子级的子级
+            }
+        };
+
+        // 从初始父级开始递归查询
+        $recursion($parentUid);
+
+        return array_unique($result); // 返回结果数组，并去重
+    }
+
+    //只获取数组中的业绩
+    public function getteampv_getcon($common_nums) {
+
+         // // 查询当前用户及其子级的所有订单
+        $orders_gongxian = Db::name("user_sign_gongxian")
+                    ->whereIn('status', [1])
+                    ->whereIn("uid", $common_nums)
+                  
+                    ->select();
+        //var_dump( $common_nums);
+
+        $total_gongxian = 0;
+        // // 遍历订单计算业绩
+         foreach ($orders_gongxian as $order) {
+            if (strpos($order['mark'], "购买") !== false) {
+                $total_gongxian += $order['number'];
+            }
+        }    
+
+         return $total_gongxian;
+
+        // // // 查询当前用户及其子级的所有订单
+        // $orders = Db::name("store_order")
+        //             ->whereIn('status', [0, 1, 2, 3])
+        //             ->whereIn("uid", $common_nums)
+        //             ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440])
+        //             ->select();
+
+        // // 初始化业绩和人数
+        // $totalPv = 0;
+        // $totalUsers = count($common_nums); // 初始化人数为子级总数
+
+        // // 遍历订单计算业绩
+        // foreach ($orders as $order) {
+        //     if ($order['total_price'] == 1180) {
+        //         $totalPv += 700;
+        //     } else if ($order['total_price'] == 11800) {
+        //         $totalPv += 7000;
+        //     } else if ($order['total_price'] == 10620) {
+        //         $totalPv += 6300;
+        //     } else if ($order['total_price'] == 2360) {
+        //         $totalPv += 1400;
+        //     } else if ($order['total_price'] == 9440) {
+        //         $totalPv += 5600;
+        //     }
+        // }
+
+        // // 返回业绩和人数
+        // return [
+        //     'totalPv' => $totalPv,
+        //     'totalUsers' => $totalUsers
+        // ];
+    }
+
+
+        // 2.0 根据父级uid,找到当前用户下面的UID
+    public function getChildren_getcon($parentUid) {
+        $result = []; // 用于存储所有子级的 uid
+
+    
+            $children = Db::name("user")
+                        ->where("spread_uid", $parentUid)
+                        ->column("uid"); // 获取子级的 uid 列表
+
+        
+        return $children; // 返回结果数组，并去重
+    }
+
+
+      // 递归获取所有子级 UID 的业绩
+    public function getTeamPv11_getcon($parentUid) {
+    
+        $getRecursiveChildren = function ($parentUid) use (&$getRecursiveChildren) {
+            $children = Db::name("user")
+                        ->where("spread_uid", $parentUid)
+                        ->column("uid");
+            $allChildren = [];
+            foreach ($children as $childUid) {
+                $allChildren[] = $childUid;
+                $allChildren = array_merge($allChildren, $getRecursiveChildren($childUid));
+            }
+            return $allChildren;
+        };
+
+        // 获取当前用户及其所有子级的 UID
+        $allUids = array_merge([$parentUid], $getRecursiveChildren($parentUid));
+
+
+        $orders_gongxian = Db::name("user_sign_gongxian")
+                    ->whereIn('status', [1])
+                    ->whereIn("uid", $allUids)
+                  
+                    ->select();
+
+
+        $total_gongxian = 0;
+        // // 遍历订单计算业绩
+        foreach ($orders_gongxian as $order) {
+            if (strpos($order['mark'], "购买") !== false) {
+                $total_gongxian += $order['number'];
+            }
+           
+        }    
+
+        return $total_gongxian;
+        // // 查询当前用户及其子级的所有订单
+        // $orders = Db::name("store_order")
+        //             ->whereIn('status', [0, 1, 2, 3])
+        //             ->whereIn("uid", $allUids)
+        //             ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440])
+        //             ->select();
+
+        // // 计算总业绩
+        // $totalPv = 0;
+        // foreach ($orders as $order) {
+        //     switch ($order['total_price']) {
+        //         case 1180:
+        //             $totalPv += 700;
+        //             break;
+        //         case 11800:
+        //             $totalPv += 7000;
+        //             break;
+        //         case 10620:
+        //             $totalPv += 6300;
+        //             break;
+        //         case 2360:
+        //             $totalPv += 1400;
+        //             break;
+        //         case 9440:
+        //             $totalPv += 5600;
+        //             break;
+        //     }
+        // }
+
+       // return $totalPv;
+    }
+
+    //根据传递的父级数组，返回他的对应子级的个数
+    public function getTeamSize_getcon($parentUids) {
+        // 初始化结果数组
+        $result = [];
+
+        // 遍历每个父级ID
+        foreach ($parentUids as $parentUid) {
+            // 递归获取所有子级 UID
+            $getRecursiveChildren = function ($parentUid) use (&$getRecursiveChildren) {
+                $children = Db::name("user")
+                            ->where("spread_uid", $parentUid)
+                            ->column("uid");
+
+                // 确保返回的是数组
+                if (!is_array($children)) {
+                    return [];
+                }
+
+                $allChildren = [];
+                foreach ($children as $childUid) {
+                    $allChildren[] = $childUid;
+                    $allChildren = array_merge($allChildren, $getRecursiveChildren($childUid));
+                }
+                return $allChildren;
+            };
+
+            // 获取当前父级及其所有子级的 UID
+            $allUids = array_merge([$parentUid], $getRecursiveChildren($parentUid));
+
+            // 计算总个数（包括父级自身）
+            $totalUids = count($allUids);
+
+            // 将结果存入数组
+            $result[] = [
+                'parent_uid' => $parentUid,
+                'total_count' => $totalUids
+            ];
+        }
+
+        return $result;
+    }
+
+    public function processArray_getcon($array) {
+        // 初始化结果数组
+        $result = [
+            'max_value' => null,     // 最大值
+            'max_index' => null,     // 最大值的下标
+            'remaining_sum' => 0     // 剩余值的总和
+        ];
+    
+        // 检查数组是否为空
+        if (empty($array)) {
+            return $result;
+        }
+    
+        // 找出最大值及其下标
+        $maxValue = $array[0];
+        $maxIndex = 0;
+        for ($i = 1; $i < count($array); $i++) {
+            if ($array[$i] > $maxValue) {
+                $maxValue = $array[$i];
+                $maxIndex = $i;
+            }
+        }
+    
+        // 计算剩余值的总和
+        $remainingSum = 0;
+        for ($i = 0; $i < count($array); $i++) {
+            if ($i != $maxIndex) {
+                $remainingSum += $array[$i];
+            }
+        }
+    
+        // 将结果存入数组
+        $result['max_value'] = $maxValue;
+        $result['max_index'] = $maxIndex;
+        $result['remaining_sum'] = $remainingSum;
+    
+        return $result;
+    }
+
+       /**
+     * 获取流水信息
+     */
+    public function getPerformance1_getcon($user_id) {
+        // $amount = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->sum("money");
+
+        // $amount = isset($amount) ? round($amount*0.7,2) : 0;
+        // return $amount;
+
+        $money1180Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("money",1180)->where("status",1)->select();
+
+        $money1180Sum = 0;
+
+        foreach ($money1180Records as $record) {
+            $money1180Sum += $record['money'] - 300 - 180;
+        }
+        // var_dump($money1180Sum);
+        $money11800Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("money",11800)->where("status",1)->select();
+
+        //var_dump($person_nums);
+        //计算个人的11800单价的业绩 集合
+        $money11800Sum = 0;
+
+        foreach ($money11800Records as $record) {
+            $money11800Sum += $record['money'] - 3000 - 1800;
+        }
+
+        $money10620Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("money",10620)->where("status",1)->select();
+
+        //var_dump($person_nums);
+        //计算个人的11800单价的业绩 集合
+        $money10620Sum = 0;
+
+        foreach ($money10620Records as $record) {
+            $money10620Sum += $record['money'] - 2700 - 1620;
+        }
+
+        // 计算除去特定值后的总和
+        $otherMoneyRecords = Db::name("old_user_of_goods")->where("node_id",$user_id)->where('status', 1)->whereNotIn('money', [1180, 11800 ,10620])->select();
+        $otherMoneySum = 0;
+        foreach ($otherMoneyRecords as $record) {
+            $otherMoneySum += $record['money'];
+        }
+
+        // 分别处理特定值的情况并加上其他值的总和
+        $user_person_amount = $money1180Sum + $money11800Sum + $money10620Sum + round($otherMoneySum * 0.7,2);
+
+        return $user_person_amount;
+
+
+    }
+
+        //1.0用户直属的部门和2.0直属的部门，进行比较，获取大部门和小部门数据
+        public function getparents_child_pv11_getcon($user_id, $bigamount, $smallamount) {
+
+            // 获取直接下级的 UID 列表
+            $get_childs = Db::name("user")
+            ->where("spread_uid", $user_id)
+            ->column("uid");
+
+            // 初始化变量
+            $all_departments = []; // 用于存储所有直属下级的业绩
+
+            // 遍历每个直属下级
+            foreach ($get_childs as $child) {
+                // 获取当前下级及其子级
+                $child_group = [$child];
+                $recursive_children = $this->getRecursiveChildren_getcon($child);
+                $child_group = array_merge($child_group, $recursive_children);
+
+                // 获取当前分组的业绩
+                $result = $this->getteampv_getcon($child_group);
+
+                // 将直属下级的业绩加入数组
+                $all_departments[] = $result;
+            }
+
+            // 将传入的 $bigamount 和 $smallamount 加入数组
+            $all_departments[] = $bigamount;
+            $all_departments[] = $smallamount;
+
+            // 检查是否所有业绩都是 0
+            if (count(array_filter($all_departments, function($value) { return $value != 0; })) == 0) {
+                return [0, 0];
+            }
+
+            // 初始化最大部门和小部门
+            $max_department = 0;
+            $small_department = 0;
+
+            // 遍历 $all_departments，找出最大值并累加小部门的值
+            foreach ($all_departments as $department) {
+                if ($department > $max_department) {
+                    // 如果当前部门的业绩大于最大部门的业绩，更新最大部门
+                    if ($max_department != 0) {
+                        $small_department += $max_department; // 将旧的最大值累加到小部门
+                    }
+                    $max_department = $department; // 更新最大部门
+                } else {
+                    // 如果当前部门的业绩小于或等于最大部门的业绩，累加到小部门
+                    $small_department += $department;
+                }
+            }
+
+            // 返回结果
+            return [
+                $max_department, // 大部门业绩
+                $small_department // 小部门业绩
+            ];
+            //拿$bigamount, $smallamount业绩和get_childs产生的result业绩去对比。如果都是0.说明没有大小部门了，直接返回0，0如果只有一个数组有数据，
+            // 说明只有大部门，默认返回大部门数据，小部门返回0，如果有多条数组数据是一样的，那么就是选一个，设为大部门。剩下的数据叠加设为小部门
+          
+        }
+
+        //获取当前uesr_id下面在2.0中是否还有直接下级，并计算她的大部门和小部门
+        public function getparents_child_pv_getcon($user_id){
+        // 获取直接下级的 UID 列表
+        //$user_id = 593;
+        // $get_childs = $this->getRecursiveChildren($user_id);
+        $get_childs = Db::name("user")
+        ->where("spread_uid", $user_id)
+        ->column("uid"); // 获取子级的 uid 列表
+        //根据获得的直接推荐下级2.0，来获取他们和她伞下的子级PV。对比拿一个最大的值，设为大部门，其余的是小部门
+
+        //获取直接下级
+        $children_group = []; // 用于存储每个直接下级及其子级的分组
+
+        // 遍历每个直接下级
+        foreach ($get_childs as $child) {
+            $child_group = [$child]; // 将直接下级加入分组
+            $recursive_children = $this->getRecursiveChildren($child); // 获取直接下级的所有子级
+            $child_group = array_merge($child_group, $recursive_children); // 将子级加入分组
+            $children_group[] = $child_group; // 将分组加入最终结果
+        }
+
+
+        $get_teams_comm_datas = [];
+        foreach($children_group as $v){
+                    
+            $get_teams_comm_datas[] = $this->getteampv($v);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
+        }
+
+        if(count($get_teams_comm_datas)  > 0){
+
+
+            // 找到最大值作为大部门
+            $max_value = max($get_teams_comm_datas);
+            $total_sum = array_sum($get_teams_comm_datas); // 计算数组的总和
+
+            // 小部门为总和减去最大值
+            $small_department = $total_sum - $max_value;
+
+            //返回大部门和小部门
+            return [
+                $max_value,
+                $small_department
+            ];
+
+        }else{
+        return [
+        0,
+        0
+        ];
+        }
+    
+    }
+