修改贡献值和团队业绩修改

app/controller/api/store/merchant/Taskorder.php

@@ -71,7 +71,7 @@ class Taskorder extends BaseController
   
     public function lst1()
     {
-       return;
+     
         // $user_datas = Db::name("user")->select();//星级等级
         // foreach($user_datas as $k=>$v){
         //     if($v['user_level_id_old']==2){
@@ -87,9 +87,9 @@ class Taskorder extends BaseController
     
     //    var_dump($totalPv);return;    
     
-        //$ss = $this->getbig_samll_datas(17);
-       // var_dump($ss);
-
+        $ss = $this->getbig_samll_datas(17);
+        var_dump($ss);
+  return;
         // return;
      
         // $store_product_datas = Db::name('old_user_of_goods_old')->select();
@@ -98,7 +98,7 @@ class Taskorder extends BaseController
         $week_record =23800 + 60000; //20250222
 
    
-//return;
+return;
 
        // $stock_comm = round($week_record * 0.05 ,2);
      //var_dump($week_record);return;
@@ -572,19 +572,21 @@ public function getWeekStartEnd()
      */
     public function getCommonNums($user_id){
         //先获取共建联盟下用户的id
-        $son_ids = Db::name("user")->where("spread_old",$user_id)->where("is_team_old",1)->select()->toArray();
+        //$son_ids = Db::name("user")->where("spread_old",$user_id)->where("is_team_old",1)->select()->toArray();
+        //先获取共建联盟下用户的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['uid'];
+            $son_id = $value['id'];
             $new_array_ids = array_merge($new_array_ids,[$son_id]);
-            $son_value_ids = Db::name("user")->whereRaw("FIND_IN_SET('$son_id',parent_ids_old)")->field("uid")->select()->toArray();
-            
+            $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,"uid");
+                $son_value_ids = array_column($son_value_ids,"id");
                 $new_array_ids = array_merge($new_array_ids,$son_value_ids);
             }
-            
+
         }
         return $new_array_ids;
     }
@@ -1081,16 +1083,19 @@ function getRecursiveChildren($parentUid) {
 
 //挑出大小值
 function getMaxAndSumRest($array) {
-    // 检查数组是否为空
-    if (empty($array)) {
+     // 检查数组是否为空
+     if (empty($array)) {
         return null; // 如果数组为空，返回 null 或其他默认值
     }
 
     // 找出数组中的最大值
     $maxValue = max($array);
 
-    // 移除最大值
-    $array = array_diff($array, [$maxValue]);
+    // 找到第一个最大值的键
+    $maxKey = array_search($maxValue, $array);
+
+    // 移除第一个最大值
+    unset($array[$maxKey]);
 
     // 将剩下的值相加
     $sumRest = array_sum($array);
@@ -1105,12 +1110,13 @@ function getMaxAndSumRest($array) {
 //获取大小部门业绩（新表小标0是大部门，下标1是小部门）
 public function getbig_samll_datas($user_id) {
 
-       
+    //$user_id = 593;
 
          $common_nums = $this->getCommonNums($user_id);
+         //var_dump(  $common_nums);
          $child_nums = [];
          $result_big_team_arr = [];
-         $get_teams_per_pv = [];//获取当前用户在2.0中小部门的总业绩
+         $get_teams_per_pv = 0;//获取当前用户在2.0中小部门的总业绩
          $get_teams_comm_pv=0;
         //1.0系统中有下级，需要在2.0中再加下级数据
         if($user_id < 611){
@@ -1120,15 +1126,15 @@ public function getbig_samll_datas($user_id) {
             $child_nums = [];
 
               //再加上当前用户直属的子级
-              $common_ns = $common_nums;
-              $common_ns[] = $user_id;
+            //   $common_ns = $common_nums;
+            //   $common_ns[] = $user_id;
 
 
               //获取当前用户
-            foreach($common_ns as $v){
+            foreach($common_nums as $v){
                 $child_nums[] = $this->getRecursiveChildren($v);
             }
-           //  var_dump($child_nums);
+            // var_dump($child_nums);
              //去除空数组，并重新组合有数据的数组
             $filteredData = array_filter($child_nums, function($array) {
                 return !empty($array); // 如果数组不为空，则保留
@@ -1139,15 +1145,15 @@ public function getbig_samll_datas($user_id) {
             foreach ($filteredData as $array) {
                 $result_big_team_arr = array_merge($result_big_team_arr, $array);
             }
-            // var_dump($result_big_team_arr);
+           // var_dump($result_big_team_arr);
             //获取当前用户下面在2.0中的下级所有PV
             $get_teams_comm_pv = $this->getteampv($result_big_team_arr);
-//var_dump("大区业绩:" .  $get_teams_comm_pv );
+    //var_dump("大区业绩:" .  $get_teams_comm_pv );
 
 
             //获取当前用户在2.0中小区的业绩
             $person_nums = $this->getPersonageNums($user_id);
-           
+           //var_dump($person_nums);
             $result_small_team_arr = [];
             //用户三峡所有在2.0系统下面的业绩和人数 start
             $child_nums_mix = [];
@@ -1166,10 +1172,10 @@ public function getbig_samll_datas($user_id) {
             foreach ($filteredData_1 as $array) {
                 $result_small_team_arr = array_merge($result_small_team_arr, $array);
             }
-             // var_dump($result_small_team_arr);
+            //var_dump($result_small_team_arr);
             //获取当前用户下面在2.0中的下级所有PV
             $get_teams_per_pv = $this->getteampv($result_small_team_arr);
-
+           // var_dump($get_teams_per_pv);
             //获取当前用户在2.0中小区的业绩 end
 
         }else{
@@ -1177,37 +1183,62 @@ public function getbig_samll_datas($user_id) {
             $get_teams_comm_datas = [];
             //当前用户在1.0没有下级，那直接在新系统2.0找下级获取数据，并区分大小部门
             $child_nums = $this->getChildren($user_id);
-            //如果当前用户只有一个子级，那么就是默认一个大部门
-            if(count($child_nums)==1){
-                //var_dump($child_nums);
-                //获取父级子级下面的个人
-                $get_teams_comm_pv = $this->getTeamPv11($child_nums[0]);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
-                // var_dump($get_teams_comm_pv);
-                
-            }else if(count($child_nums) > 1){
-                
-                foreach($child_nums as $v){
+          
+            if(count($child_nums) > 0){
+                if(count($child_nums)==1){
+                    //var_dump($child_nums);
+                    //获取父级子级下面的个人
+                    $get_teams_comm_pv = $this->getTeamPv11($child_nums[0]);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
+                    // var_dump($get_teams_comm_pv);
+                    
+                }else if(count($child_nums) > 1){
                 
-                    $get_teams_comm_datas[] = $this->getTeamPv11($v);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
+                    foreach($child_nums as $v){
+                    
+                        $get_teams_comm_datas[] = $this->getTeamPv11($v);//如果有多个父级ID，需要获取他们伞下的子级，所有的业绩进行
+                    }
+
+
+
+                    $get_big_small_pv = $this->getMaxAndSumRest($get_teams_comm_datas);//区分大小部门业绩
+
+                // var_dump($get_big_small_pv );
+                    //var_dump($get_big_small_pv);
+                    $get_teams_comm_pv =  $get_big_small_pv['maxValue'];
+                    $get_teams_per_pv  =  $get_big_small_pv['sumRest'];
                 }
-                $get_big_small_pv = $this->getMaxAndSumRest($get_teams_comm_datas);//区分大小部门业绩
-                //var_dump($get_big_small_pv);
-                $get_teams_comm_pv =  $get_big_small_pv['maxValue'];
-                $get_teams_per_pv  =  $get_big_small_pv['sumRest'];
             }
+                //如果当前用户只有一个子级，那么就是默认一个大部门
+           
        
         }
 
-    //var_dump("小区业绩:".$get_teams_per_pv);
+        $team_amount   = 0;
+        $person_amount = 0;
+
+        if($user_id < 611){
+         
+            //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
+            //例子:17所有下面uid是speard_uid都是17的，和所有伞下的业绩。分出大小部门，加到1.0的大小部门中
+            $b_s = $this->getparents_child_pv($user_id);
+            
+            //var_dump( $b_s);echo "yyyyyyyyyyyyy";
+            $team_amount = $b_s[0];
+            $person_amount = $b_s[1];
 
+          
+        }
 
+    //var_dump("小区业绩:".$get_teams_per_pv);
+
+        //var_dump($team_amount, $person_amount);
     // 计算大部门和小部门的汇总信息
     $majorDepartmentSummary = [
-        "total_performance" =>  $get_teams_comm_pv,
+        "total_performance" =>  $get_teams_comm_pv +  $team_amount,
     ];
 
     $minorDepartmentSummary = [
-        "total_performance" => $get_teams_per_pv,
+        "total_performance" => $get_teams_per_pv  + $person_amount,
     ];
 
     // 返回所需的结果
@@ -1217,6 +1248,60 @@ public function getbig_samll_datas($user_id) {
     ];
 }
 
+//获取当前uesr_id下面在2.0中是否还有直接下级，并计算她的大部门和小部门
+public function getparents_child_pv($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
+    ];
+   }
+
+
+}
+
     
 
 //获取大小部门业绩（新表小标0是大部门，下标1是小部门）

app/controller/api/user/User.php

@@ -1370,11 +1370,11 @@ class User extends BaseController
 
 
         if($teamid == 592){
-             $teamid = 593;//593
+             $teamid = 17;//593
 
             
 
-                $team_userinfo_old_jbp1 = $this->getPerformance($teamid);
+                $team_userinfo_old_jbp1 = $this->getPerformance22($teamid);
 
            
                 var_dump($team_userinfo_old_jbp1);return;
@@ -3526,45 +3526,37 @@ public function getNewTeamPv($common_nums) {
 public function getteampv($common_nums) {
 
 
-        // 查询当前用户及其子级的所有订单
-        $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;
-        foreach ($orders as $order) {
-            
-           // var_dump($order['uid']."订单:".$order['total_price']);
-            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;
-            }
-        }
-
-        //除了会员专区的其他区所有订单产生的业绩汇总在user表中的pv中
-        // $user_datas = Db::name("user")
-      
-        // ->whereIn("uid", $common_nums)
-       
-        // ->select();
+    // 查询当前用户及其子级的所有订单
+    $orders = Db::name("store_order")
+                ->whereIn('status', [0, 1, 2, 3])
+                ->whereIn("uid", $common_nums)
+                ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440])
+                ->select();
 
-        // foreach ($user_datas as $v) {
-        //     $totalPv += $v['pv'];
-        // }
+    // 初始化业绩和人数
+    $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;
+    // 返回业绩和人数
+    return [
+        'totalPv' => $totalPv,
+        'totalUsers' => $totalUsers
+    ];
 }
 
   // 递归获取所有子级 UID 的业绩
@@ -3698,6 +3690,406 @@ public function processArray($array) {
     return $result;
 }
 
+
+//获取当前uesr_id下面在2.0中是否还有直接下级，并计算她的大部门和小部门
+public function getparents_child_pv($user_id){
+        // 获取直接下级的 UID 列表
+    $get_childs = Db::name("user")
+    ->where("spread_uid", $user_id)
+    ->column("uid");
+
+// 初始化总业绩和总人数
+$total_value = 0;
+$total_count = 0;
+$max_value = 0;
+$max_count = 0;
+
+// 遍历每个直接下级
+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);
+    $group_pv = $result['totalPv'];
+    $group_count = $result['totalUsers'];
+
+    // 累加总业绩和总人数
+    $total_value += $group_pv;
+    $total_count += $group_count;
+
+    // 更新最大业绩及其对应的人数
+    if ($group_pv > $max_value) {
+        $max_value = $group_pv;
+        $max_count = $group_count;
+    }
+}
+
+// 计算小部门的业绩和人数
+$small_department_value = $total_value - $max_value;
+$small_department_count = $total_count - $max_count;
+
+// 返回结果
+return [
+    'team_pv' => $max_value,
+    'team_num' => $max_count,
+    'per_pv' => $small_department_value,
+    'per_num' => $small_department_count
+];
+    
+  
+}
+
+//根据父级IDS获取伞下的所有子级ID
+function getRecursiveChildren_s($parentUid) {
+    $result = []; // 用于存储所有子级的 uid
+
+    // 定义递归函数
+    $recursion = function ($currentUid) use (&$result, &$recursion) {
+        // 查询当前父级的所有直接子级
+        $children = Db::name("user")
+                      ->where("spread_uid", $currentUid)
+                      ->column("uid"); // 获取子级的 uid 列表
+
+        // 如果没有子级，直接返回
+        if (empty($children)) {
+            return;
+        }
+
+        // 遍历每个子级
+        foreach ($children as $childUid) {
+            $result[] = $childUid; // 将子级的 uid 添加到结果数组
+            $recursion($childUid); // 递归查询子级的子级
+        }
+    };
+
+    // 从初始父级开始递归查询
+    $recursion($parentUid);
+
+    return array_unique($result); // 返回结果数组，并去重
+}
+
+ /**
+     * 获取当前用户业绩
+     */
+    public function getPerformance22($user_id) {
+        $team_amount = 0;
+        $person_amount = 0;
+        //$user_id = 17;
+        
+         $result_big_team_arr = [];
+         $get_teams_comm_datas = [];//在2.0中获取父级下面的所有团队数据
+        //共建联盟业绩 个人联盟业绩 共建联盟总pv 个人联盟业绩pv
+        $common_nums = $this->getCommonNums($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
+           
+         
+            //用户三峡所有在2.0系统下面的业绩和人数 start
+            $child_nums = [];
+         
+            //获取当前用户
+            foreach($common_nums as $v){
+                $child_nums[] = $this->getRecursiveChildren($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($result_big_team_arr);
+            $get_teams_comm_pv =$t_pv['totalPv'];
+            //var_dump($get_teams_comm_pv);
+
+            //获取当前用户下面在2.0中的下级所有人数
+            $get_teams_comm_num = count($result_big_team_arr);
+           
+            //用户伞下小部门所有在2.0系统下面的业绩和人数 end
+        }else{
+          
+               //当前用户在1.0没有下级，那直接在新系统2.0找下级获取数据，并区分大小部门
+              $child_nums = $this->getChildren($user_id);
+             
+              //获取父级子级下面的个人
+              $num_teams = $this->getTeamSize($child_nums);
+          
+              
+              foreach($child_nums as $v){
+                
+                   $get_teams_comm_datas[] = $this->getTeamPv11($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($get_teams_comm_datas);
+                 
+                    $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'];
+              }
+              
+              
+        }
+        
+        //合并业绩和人数
+        $team_amount += $get_teams_comm_pv;
+           
+        //var_dump($team_amount);
+        //1.0获取小区业绩
+        $person_nums = $this->getPersonageNums($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($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($result_small_team_arr);
+           $get_teams_per_pv =$t_pv['totalPv'];
+            //var_dump(  $get_teams_per_pv);
+          
+       
+        
+        
+          //获取当前用户下面在2.0中的下级所有人数
+            $get_teams_per_num += count($result_small_team_arr);
+            //合并业绩和人数
+            $person_amount += $get_teams_per_pv;
+
+            
+        //     if($user_id == 593){
+        //         $person_amount = 2800;
+               
+        //    }
+
+        //var_dump($person_amount);
+        //用户小部门所有在2.0系统下面的业绩和人数 end
+
+      
+        // $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;
+        }
+        //var_dump($team_amount);
+
+        //
+         
+        if($user_id < 611){
+         
+            //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
+            //例子:17所有下面uid是speard_uid都是17的，和所有伞下的业绩。分出大小部门，加到1.0的大小部门中
+            $b_s = $this->getparents_child_pv($user_id);
+            
+            //var_dump( $b_s);echo "yyyyyyyyyyyyy";
+            $team_amount += $b_s['team_pv'];
+            $get_teams_comm_num += $b_s['team_num'];
+
+
+           $person_amount += $b_s['per_pv'];
+
+           $get_teams_per_num += $b_s['per_num'];//小部门人数
+           //var_dump( $b_s['team_num'],$b_s['per_num']);
+        }
+       
+
+
+        $user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 1180)->select();
+
+        //$money1180Records = $this->old_user_of_goods->where('status', 1)->where('money', 1180)->select();
+// 计算 status 为 1 且 money 为 1180 的记录总和（减去相应值后）
+        $money1180Sum = 0;
+        foreach ($user_team_amount as $record) {
+            $money1180Sum += $record['money'] - 300 - 180;
+        }
+
+// 获取 status 为 1 且 money 为 11800 的记录集合
+
+        $money11800Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 11800)->select();
+
+// 计算 status 为 1 且 money 为 11800 的记录总和（减去相应值后）
+        $money11800Sum = 0;
+        foreach ($money11800Records as $record) {
+            $money11800Sum += $record['money'] - 3000 - 1800;
+        }
+
+        $money10620Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 10620)->select();
+
+// 计算 status 为 1 且 money 为 11800 的记录总和（减去相应值后）
+        $money10620Sum = 0;
+        foreach ($money10620Records as $record) {
+            $money10620Sum += $record['money'] - 2700 - 1620;
+        }
+
+// 计算除去特定值后的总和
+//$otherMoneyRecords = $this->old_user_of_goods->where('status', 1)->whereNotIn('money', [1180, 11800])->select();
+        $otherMoneyRecords = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->whereNotIn('money', [1180, 11800 ,10620])->select();
+        $otherMoneySum = 0;
+        foreach ($otherMoneyRecords as $record) {
+            $otherMoneySum += $record['money'];
+        }
+     
+
+// 分别处理特定值的情况并加上其他值的总和
+        $all_record_nums = $money1180Sum + $money11800Sum + $money10620Sum + round($otherMoneySum * 0.7,2);
+        // var_dump($all_record_nums);
+        $team_amount += $all_record_nums;
+       // var_dump($user_team_amount);
+        //计算自己的个人联盟总流水
+   
+        // // //计算自己的个人联盟总流水
+        // $user_person_amount = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->where('status',1)->sum("money");
+        // $user_person_amount = empty($user_person_amount) ? 0 : round($user_person_amount * 0.7,2);
+        // $person_amount += $user_person_amount;
+        //计算个人的1180单价的业绩 集合
+        $money1180Records = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->where("money",1180)->select();
+
+        $money1180Sum = 0;
+
+        foreach ($money1180Records as $record) {
+            $money1180Sum += $record['money'] - 300 - 180;
+        }
+
+        $money11800Records = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->where("money",11800)->select();
+
+        //var_dump($person_nums);
+        //计算个人的11800单价的业绩 集合
+        $money11800Sum = 0;
+
+        foreach ($money11800Records as $record) {
+            $money11800Sum += $record['money'] - 3000 - 1800;
+        }
+
+
+        $money10620Records = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->where("money",10620)->select();
+
+        //var_dump($person_nums);
+        //计算个人的10620单价的业绩 集合
+        $money10620Sum = 0;
+
+        foreach ($money10620Records as $record) {
+            $money10620Sum += $record['money'] - 2700 - 1620;
+        }
+
+
+        // 计算除去特定值后的总和
+        $otherMoneyRecords = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->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);
+
+
+        $person_amount += $user_person_amount;
+
+
+        //级别信息
+        $userInfo = Db::name("user")->find($user_id);//
+        $zk_level = 4;
+        $is_zk = false;
+        if($userInfo['user_level_id_old'] == $zk_level) {
+            $is_zk = true;
+            $sales_incentive_info = $this->getStarLevel($user_id,$team_amount,$person_amount);
+            $sales_incentive = isset($sales_incentive_info['title']) ? $sales_incentive_info['title'] : '';
+        } else{
+            $sales_incentive = 0;
+        }
+
+
+        $return_data = [
+            'common_nums'=>count($common_nums) + $get_teams_comm_num,
+            'person_nums'=>count($person_nums) + $get_teams_per_num,
+            'common_nums_pv'=> $team_amount,
+            'person_nums_pv'=> $person_amount,
+            'sum_nums_pv' =>$team_amount + $person_amount,
+            'sales_incentive' => $sales_incentive,
+            "is_zk"=>$is_zk
+        ];
+        return $return_data;
+
+
+
+
+
+    }
+
+
     /**
      * 获取当前用户业绩
      */
@@ -3714,13 +4106,15 @@ public function processArray($array) {
         //var_dump($user_id);
         $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
-            if($user_id == 593){
-                 $common_nums[] = 780;
-                 unset($common_nums[0]);
-            }
+            // if($user_id == 593){
+            //      $common_nums[] = 780;
+            //      unset($common_nums[0]);
+            // }
             //var_dump($common_nums);
             //用户三峡所有在2.0系统下面的业绩和人数 start
             $child_nums = [];
@@ -3729,15 +4123,15 @@ public function processArray($array) {
             $common_ns[] = $user_id;
             //var_dump($common_ns);return;
               //获取当前用户
-            foreach($common_ns as $v){
+            foreach($common_nums as $v){
                 $child_nums[] = $this->getRecursiveChildren($v);
             }
           
               //梅红在2.0中的ID是780
-            if($user_id == 593){
-                 $child_nums[0][] = 780;
+            // if($user_id == 593){
+            //      $child_nums[0][] = 780;
                 
-            }
+            // }
           
 
             //去除空数组，并重新组合有数据的数组
@@ -3753,7 +4147,14 @@ public function processArray($array) {
           
             //var_dump($result_big_team_arr);echo "ppppppppppppppppp";
             //获取当前用户下面在2.0中的下级所有PV
-            $get_teams_comm_pv = $this->getteampv($result_big_team_arr);
+            $t_pv = $this->getteampv($result_big_team_arr);
+            $get_teams_comm_pv =$t_pv['totalPv'];
+          
+        //     if($user_id == 593){
+        //         $get_teams_comm_pv = 7000;
+               
+        //    }
+
            //var_dump($get_teams_comm_pv);
             //获取当前用户下面在2.0中的下级所有人数
             $get_teams_comm_num = count($result_big_team_arr);
@@ -3778,9 +4179,31 @@ public function processArray($array) {
                   $get_teams_comm_num = $num_teams[0]['total_count'];
                   
               }else if(count($get_teams_comm_datas) >1){
+                //     $getss = $this->processArray($get_teams_comm_datas);
+                  
+                //    $team_datas = $num_teams[$getss['max_index']];
+
+                  // var_dump( $get_teams_comm_datas);
+                    //获取一个最大值，设为大部门，其他的加载一块是小部门
                     $getss = $this->processArray($get_teams_comm_datas);
-                    //var_dump($getss);
-                   $team_datas = $num_teams[$getss['max_index']];
+                 
+                    $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'];
               }
               
               
@@ -3822,16 +4245,24 @@ public function processArray($array) {
             }
            
             //获取当前用户下面在2.0中的下级所有PV
-            $get_teams_per_pv = $this->getteampv($result_small_team_arr);
-          
+           // $get_teams_per_pv = $this->getteampv($result_small_team_arr);
+            $t_pv = $this->getteampv($result_small_team_arr);
+            $get_teams_per_pv =$t_pv['totalPv'];
           
        
         
         
           //获取当前用户下面在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($person_amount);
         //用户小部门所有在2.0系统下面的业绩和人数 end
 
@@ -3849,6 +4280,27 @@ public function processArray($array) {
         }
         //var_dump($team_amount);
 
+            
+        if($user_id < 611){
+         
+            //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
+            //例子:17所有下面uid是speard_uid都是17的，和所有伞下的业绩。分出大小部门，加到1.0的大小部门中
+            $b_s = $this->getparents_child_pv($user_id);
+            
+            //var_dump( $b_s);echo "yyyyyyyyyyyyy";
+           $team_amount += $b_s['team_pv'];
+            $get_teams_comm_num += $b_s['team_num'];
+
+
+           $person_amount += $b_s['per_pv'];
+
+           $get_teams_per_num += $b_s['per_num'];//小部门人数
+           
+
+
+            //var_dump($team_amount,$person_amount );
+        }
+
 
 
         $user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 1180)->select();
@@ -3860,6 +4312,13 @@ public function processArray($array) {
             $money1180Sum += $record['money'] - 300 - 180;
         }
 
+             
+            if($user_id == 593){
+                $money1180Sum -= 700;
+               
+           }
+
+
 // 获取 status 为 1 且 money 为 11800 的记录集合
 
         $money11800Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 11800)->select();