合伙人分红加入2.0分红计算

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

@@ -563,7 +563,7 @@ class Taskorder extends BaseController
 
         // $store_product_datas = Db::name('old_user_of_goods_old')->select();
 
-        $week_record = 7000;
+        $week_record = 139200;
         $stock_comm = round($week_record * 0.05 ,2);
 
         //获取股权分红的人
@@ -619,7 +619,6 @@ class Taskorder extends BaseController
 
 
 
-
         //var_dump($week_record);die;//9912  8400
         //$star_list = Db::name("user_star")->order("statement_all_num desc")->select()->toArray();//旧星级等级
         $star_list = Db::name("old_user_starlevel")->order("statement_all_num desc")->select()->toArray();//星级等级
@@ -704,15 +703,17 @@ class Taskorder extends BaseController
 
 
 
-//var_dump($sales_arr);die; //把初级中的   id是 12,69, 144从初级中去掉 ,id是49，从中级中去掉
+//var_dump($sales_arr);return; //把初级中的   id是 12,69, 144从初级中去掉 ,id是49，从中级中去掉
 
         //移动指定ID_end
 
-
         // var_dump($sales_arr);die;
         //$sales_arr获取分红的id和分红的比例
 
 
+
+
+
         //执行分开发放
         foreach($sales_arr as $key =>$value) {
             //比如这个周的总业绩是 8400
@@ -887,6 +888,9 @@ class Taskorder extends BaseController
 //     return [$monday_start,$sunday_end];
 // }
 
+
+
+
     /**
      * 获取用户星级
      */
@@ -905,13 +909,12 @@ class Taskorder extends BaseController
                 $team_money += $amount;
             }
             //计算自己的共建联盟流水
-            // $user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->sum("money");
-            // $user_team_amount = empty($user_team_amount) ? 0 : round($user_team_amount * 0.7,2);
+
             $user_team_amount = $this->getperteamcomm($common_nums,$user_id);
 
 
             $team_money += $user_team_amount;
-//return $team_money;//115500
+
 
         }else{
             $common_nums = $this->getCommonNums($user_id);
@@ -939,6 +942,15 @@ class Taskorder extends BaseController
             $person_nums = $this->getPersonageNums($user_id);
 
         }
+        //计算个人在2.0新表中的业绩 start
+
+        $team_small_big_amount = $this->getbig_samll_datas($user_id);//下标0是大部门，下标1是小部门
+        $person_money +=  $team_small_big_amount[1];
+        $team_money += $team_small_big_amount[0];
+
+        //end
+
+
 
         //默认是小联盟，如果大联盟业绩比小联盟低，那就谁选业绩低的
         $slow = $person_money;
@@ -946,12 +958,7 @@ class Taskorder extends BaseController
             $slow = $team_money;
         }
         $sum_money = $team_money + $person_money;
-        // $data = ['sum_money'=>$sum_money,"team_money"=>$team_money,"person_money"=>$person_money];
-        // $this->error(0,$data);
-        //$star_list = Db::name("user_star")->order("statement_all_num desc")->select();
 
-        // $sum_money = 1000000;
-        // $slow = 300000;
 
         // var_dump($sum_money);
         // var_dump($slow);
@@ -1141,9 +1148,151 @@ class Taskorder extends BaseController
 
         $sum_nums_pv = isset($sum_nums_pv) ? $sum_nums_pv :0;
 
+
+        //计算个人在2.0新表中的业绩 start
+
+        $team_small_big_amount = $this->getbig_samll_datas($user_id);//下标0是大部门，下标1是小部门
+        $total_team_amount3 =  $team_small_big_amount[0] +  $team_small_big_amount[1];
+        $sum_nums_pv += $total_team_amount3;
+
+        //end
+
         return $sum_nums_pv;
     }
 
+    //计算自己和自己团队下面的业绩。新表
+    public function calculatePerformance($uid)
+    {
+        // 初始化业绩数组
+        $performance = [
+
+            'personal_performance' => 0, // 个人业绩
+            'team_performance' => 0, // 团队业绩
+            'total_performance' => 0, // 总业绩
+            'team_count' => 0, // 加上自己的团队数量
+
+        ];
+
+        // 定义业绩换算规则
+        $performanceMapping = [
+            1180 => 700,
+            10620 => 6300,
+            11800 => 7000,
+            9440 => 5600,
+            2360 => 1400
+        ];
+
+        // 计算个人业绩
+        $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;
+    }
+
+//获取大小部门业绩（新表小标0是大部门，下标1是小部门）
+    public function getbig_samll_datas($user_id) {
+
+        $subordinate_members = Db::name('user')
+            ->alias('u')
+            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
+            ->where("u.spread_uid", $user_id)
+            ->where("so.mer_id", 496)
+            ->group('u.uid')
+
+            ->select();
+
+        // 单独写一个方法获取大小部门的数据
+        $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_performance" => $maxRecord ? $maxRecord['total_performance'] : 0,
+        ];
+
+        $minorDepartmentSummary = [
+            "total_performance" => array_sum(array_column($arr_team, 'total_performance')),
+        ];
+
+        // 返回所需的结果
+        return [
+            $majorDepartmentSummary['total_performance'],
+            $minorDepartmentSummary['total_performance']
+        ];
+    }
+
 
     /**
      * 释放待发放佣金
@@ -1272,25 +1421,31 @@ class Taskorder extends BaseController
         }
 
         //添加自己共建联盟的流水
-        // $user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->sum("money");
-        // $user_team_amount = empty($user_team_amount) ? 0 : round($user_team_amount * 0.7,2);
+
         $user_team_amount = $this->getperteamcomm($common_nums,$user_id);
         $team_amount += $user_team_amount;
 
         // //计算自己的个人联盟总流水
-        // $user_person_amount = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->sum("money");
-        // $user_person_amount = empty($user_person_amount) ? 0 : round($user_person_amount * 0.7,2);
+
         $user_person_amount = $this->getperteamcomm($person_nums,$user_id);
         $person_amount += $user_person_amount;
 
-        //var_dump($person_amount);
-        // var_dump($team_amount);
-
         //默认是小联盟，如果大联盟业绩比小联盟低，那就谁选业绩低的
         // 确定最小值和最大值
         $minValue = min($person_amount, $team_amount);
         $maxValue = max($person_amount, $team_amount);
-        //var_dump(array($minValue, $maxValue));
+
+
+        //计算个人在2.0新表中的业绩 start
+
+        $team_small_big_amount = $this->getbig_samll_datas($user_id);//下标0是大部门，下标1是小部门
+        $minValue  +=  $team_small_big_amount[1];
+        $maxValue  +=  $team_small_big_amount[0];
+
+
+        //end
+
+
 
         // 返回包含最小值和最大值的数组
         return array($minValue, $maxValue);