合伙人分红重写-1.1.0

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

@@ -8,15 +8,69 @@ use think\facade\Db;
 
 class TaskPartnerProfits
 {
+
+    public function getTeamPvByTime($timePeriod = 'last_week')
+    {
+        // 定义时间区间
+        $startTime = '';
+        $endTime = '';
+
+        if ($timePeriod == 'last_week') {
+            // 上周的时间区间
+            $startTime = '2025-03-17 00:00:00'; // 上周星期一的开始时间
+            $endTime = '2025-03-23 23:59:59'; // 上周星期日的结束时间
+        } elseif ($timePeriod == 'this_week') {
+            // 这周的时间区间
+            $startTime = '2025-02-17 00:00:00'; // 这周星期一的开始时间
+            $endTime = '2025-02-23 23:59:59'; // 这周星期日的结束时间
+        } else {
+            return "Invalid time period specified.";
+        }
+
+        // 查询指定时间区间内的所有订单，并排除 pay_time 为 NULL 的订单
+        $orders = Db::name("store_order")
+            ->whereIn('status', [0, 1, 2, 3])
+            ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440])
+            ->whereBetween("pay_time", [$startTime, $endTime])
+            ->whereNotNull("pay_time") // 排除 pay_time 为 NULL 的订单
+            ->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 partnerProfits()
     {
+//        $a = $this->getSpreadUserUidAccountListByUidList(1);
+//        return json($a);
         // 定义分红金额
-        $weekRecord = 10500 + 50000;
+        $weekRecord = $this->getTeamPvByTime('last_week');
 
         // 1、获取用户星级信息
         //$star_list = Db::name("user_star")->order("statement_all_num desc")->select()->toArray();//旧星级等级
         $starList = Db::name("old_user_starlevel")
-            ->whereIn('title', ['初级', '中级'])
+            ->whereIn('title', ['初级', '中级', '高级'])
             ->order("statement_all_num desc")
             ->select()
             ->toArray();//星级等级
@@ -26,7 +80,7 @@ class TaskPartnerProfits
 
         // 3、获取 分红用户 信息 （`user_group` tinyint(1) DEFAULT '1' COMMENT '1消费者 2,推广业务员 3，业务经理 4初级合伙人5中级合伙人 6高级合伙人 7.懂事',）
         $list = Db::name("user")
-            ->where("user_group", "IN", [4, 5])
+            ->where("user_group", "IN", [4, 5, 6])
             ->where("status", "<>", 0)
             ->select()
             ->toArray();
@@ -37,10 +91,11 @@ class TaskPartnerProfits
                 $salesArr['初级']['divider_people'][] = $value['uid'];
             } else if ($value['user_group'] == 5) {
                 $salesArr['中级']['divider_people'][] = $value['uid'];
+            } else if ($value['user_group'] == 6) {
+                $salesArr['高级']['divider_people'][] = $value['uid'];
             }
         }
 
-
         // 5、移除特定人员
         // 要移动的ID数组
         $ids_to_remove_from_junior = array(12, 69, 144); // 从初级中移除的ID
@@ -74,14 +129,16 @@ class TaskPartnerProfits
             // 6.1 计算可分红金额
             //比如这个周的总业绩是 8400
             //周总业绩(8400) * 合伙人级别的分佣比例(15%) = 可分红的佣金(1260)
-            $salesArr[$key]['fs_money_nums'] = round($weekRecord * $value['profit_rate'], 2);
+//            $salesArr[$key]['fs_money_nums'] = round($weekRecord * $value['profit_rate'], 2);
+            $salesArr[$key]['fs_money_nums'] = floor(($weekRecord * ($value['profit_rate'] / 100)) * 100) / 100;
             //可分红的业绩(分为两半，各50%，一部分是分给双联盟比例，一部分是小业绩比例)
             //把本周的业绩(8400) * 合伙人级别的分佣比例(15%) * 0.5 = 630（可分红佣金的 50%）
-            $salesArr[$key]['fs_money'] = round($salesArr[$key]['fs_money_nums'] / 2, 2);
+//            $salesArr[$key]['fs_money'] = round($salesArr[$key]['fs_money_nums'] / 2, 2);
+            $salesArr[$key]['fs_money'] = floor(($salesArr[$key]['fs_money_nums'] / 2) * 100) / 100;
 
             // 6.2 计算所有人的 PV值
             $salesArr[$key]['maxValueAll'] = 0;
-            $salesArr[$key]['sumOfOthers'] = 0;
+            $salesArr[$key]['sumOfOthersAll'] = 0;
             $salesArr[$key]['dividerPeoplePv'] = [];
             foreach ($value['divider_people'] as $k => $v) {
                 // 6.2.1 查出分红人的所有部门 即 下级用户
@@ -113,18 +170,18 @@ class TaskPartnerProfits
                     $salesArr[$key]['dividerPeoplePv'][$v]['maxValue'] = $maxValue;
                     $salesArr[$key]['dividerPeoplePv'][$v]['sumOfOthers'] = $sumOfOthers;
                     $salesArr[$key]['maxValueAll'] += $maxValue;
-                    $salesArr[$key]['sumOfOthers'] += $sumOfOthers;
+                    $salesArr[$key]['sumOfOthersAll'] += $sumOfOthers;
                 }
             }
         }
-        // return app('json')->success([]);
 
         // 7、执行分红
+        $testRecord = [];
         foreach ($salesArr as $key => $value) {
             $amount = $value['fs_money'];//可分红的总佣金，分红佣金的一半,中级合伙61.95
             $fsMoneyNums = $value['fs_money_nums'];//中级合伙人级别，可分红的总佣金
             $maxValueAll = $value['maxValueAll'];//当前级别合伙人下面所有的双联盟业绩
-            $sumOfOthers = $value['sumOfOthers'];//当前级别合伙人下面所有的小区(业绩小的部分)总业绩
+            $sumOfOthersAll = $value['sumOfOthersAll'];//当前级别合伙人下面所有的小区(业绩小的部分)总业绩
 
             if (count($value['divider_people']) <= 0) {
                 continue;
@@ -132,17 +189,25 @@ class TaskPartnerProfits
             //每人分红金额
             foreach ($value['divider_people'] as $v) {
 
+                //个人小区(佣金少的一部分) 权重 计算权重
+                //返回是数组，下标0是最小的值(业绩小的)，下标1是最大的值(业绩大的)
+                $userPvSmallNum = $value['dividerPeoplePv'][$v]['sumOfOthers'] ?? 0;
+//                $myMixMoney = round($amount * ($userPvSmallNum / $sumOfOthersAll), 2);
+                $myMixMoney = floor(($amount * (floor(($userPvSmallNum / $sumOfOthersAll) * 100) / 100)) * 100) / 100;
+
                 //个人双区总佣金 权重 计算
-                $myBill = $value['dividerPeoplePv'][$v]['maxValue'];//比如uerid是12，他的双区总业绩就是287742
+                $myBill = $value['dividerPeoplePv'][$v]['maxValue'] ?? 0;
                 //中级合伙人。userid=17可以分到双区可分红的金额
                 //可分红的佣金 * (中级合伙人个人的双区总业绩 / 当前等级所有合伙人的双联盟业绩) = 当前用户可以获取到的分红佣金(双区联盟总业绩加权佣金),287742 * (61.95/431032)=41.36
-                $myWeightMoney = round($amount * ($myBill / $maxValueAll), 2);
+//                $myWeightMoney = round($amount * ($myBill / $maxValueAll), 2);
+                $myWeightMoney = floor(($amount * (floor((($myBill + $userPvSmallNum) / ($maxValueAll + $sumOfOthersAll)) * 100) / 100)) * 100) / 100;
 
-                //个人小区(佣金少的一部分) 权重 计算权重
-                //返回是数组，下标0是最小的值(业绩小的)，下标1是最大的值(业绩大的)
-                $userPvSmallNum = $value['dividerPeoplePv'][$v]['sumOfOthers'];
-                $myMixMoney = round($amount * ($userPvSmallNum / $sumOfOthers), 2);
 
+                $salesArr[$key]['dividerPeoplePv'][$v]['myWeightMoney'] = $myWeightMoney;
+                $salesArr[$key]['dividerPeoplePv'][$v]['myMixMoney'] = $myMixMoney;
+                $salesArr[$key]['dividerPeoplePv'][$v]['maxValueAll'] = $maxValueAll;
+                $salesArr[$key]['dividerPeoplePv'][$v]['sumOfOthersAll'] = $sumOfOthersAll;
+                $salesArr[$key]['dividerPeoplePv'][$v]['weekRecord'] = $weekRecord;
 
                 # code...
                 $allAward = $myWeightMoney + $myMixMoney;
@@ -152,44 +217,47 @@ class TaskPartnerProfits
                 $fg_10 = $allAward * 0.1;
 
 
-                $userdatassss = db::name("old_user_jbp")->where("id", $v)->find();
-                $datas_log = [
-                    'note' => "名称:" . $userdatassss['nick_name'] . " 用户:" . $v . " 双联盟总业绩:" . $maxValueAll . " 我的双区业绩:" . $myBill . " 小区总业绩:" . $sumOfOthers . " 我的业绩小的:" . $userPvSmallNum[0] . "  可分红佣金:" . $amount . "  可分红总佣金:" . $fsMoneyNums . "  小区业绩可分红:" . $myMixMoney . " 大区业绩可分红:" . $myWeightMoney . " 实际分得:" . $yj_90,
-                    'create_time' => date('Y-m-d H:i:s')
-                ];
-                $con_data = Db::name('test_log')->insert($datas_log);   //数据存到2.0数据表中
-
-                # code...
-                $res = Db::name("user")->where("uid", $v)->inc("total_amount_old", $yj_90)->save();
-
-                Db::name("user")->where("uid", $v)->inc("amount_old", $yj_90)->save();//不用冻结金额和提现额度来限制佣金发放
-                Db::name("user")->where("uid", $v)->inc("brokerage_price", $yj_90)->save();
-
-                Db::name("user")->where("uid", $v)->inc("fugou", $fg_10)->save();
-
-
-                //if($res) {
-                $this->change_user_log($v, 'amount_old', 1, $yj_90, "member_award", "星级分红入账" . "-" . $value['title']);//释放佣金
-                //入账星级分红记录表
-                $week_data = [];
-                $week_data['user_id'] = $v;
-                $week_data['user_star_id'] = $key;
-                $week_data['award_num'] = $myWeightMoney;
-                $week_data['award_num_sm'] = $myMixMoney;
-                $week_data['remark'] = "星级分红主动执行:" . $yj_90;
-                $week_data['week_record'] = $weekRecord;
-                $week_data['all_amount'] = $fsMoneyNums;
-                $week_data['radio'] = 2;
-                $week_data['owner_bill'] = $maxValueAll;  //总流水金额
-                $week_data['my_bill'] = $myBill;  //我的流水
-                $week_data['create_time'] = time();
-
-                Db::name("old_user_weekaward")->insert($week_data);
-
-                $this->bill_user_log111111($v, "合伙人分佣", $yj_90, "合伙人分佣明细入账", 11);//联创分佣明细2.0系统
-                $this->fugou_user_log($v, $fg_10, 16, 1, 1);//复购金明细入账
+//                $userdatassss = db::name("old_user_jbp")->where("id", $v)->find();
+//                $datas_log = [
+//                    'note' => "名称:" . $userdatassss['nick_name'] . " 用户:" . $v . " 双联盟总业绩:" . $maxValueAll . " 我的双区业绩:" . $myBill . " 小区总业绩:" . $sumOfOthersAll . " 我的业绩小的:" . $userPvSmallNum[0] . "  可分红佣金:" . $amount . "  可分红总佣金:" . $fsMoneyNums . "  小区业绩可分红:" . $myMixMoney . " 大区业绩可分红:" . $myWeightMoney . " 实际分得:" . $yj_90,
+//                    'create_time' => date('Y-m-d H:i:s')
+//                ];
+//                $con_data = Db::name('test_log')->insert($datas_log);   //数据存到2.0数据表中
+//
+//                # code...
+//                $res = Db::name("user")->where("uid", $v)->inc("total_amount_old", $yj_90)->save();
+//
+//                Db::name("user")->where("uid", $v)->inc("amount_old", $yj_90)->save();//不用冻结金额和提现额度来限制佣金发放
+//                Db::name("user")->where("uid", $v)->inc("brokerage_price", $yj_90)->save();
+//
+//                Db::name("user")->where("uid", $v)->inc("fugou", $fg_10)->save();
+//
+//
+//                //if($res) {
+//                $this->change_user_log($v, 'amount_old', 1, $yj_90, "member_award", "星级分红入账" . "-" . $value['title']);//释放佣金
+//                //入账星级分红记录表
+//                $week_data = [];
+//                $week_data['user_id'] = $v;
+//                $week_data['user_star_id'] = $key;
+//                $week_data['award_num'] = $myWeightMoney;
+//                $week_data['award_num_sm'] = $myMixMoney;
+//                $week_data['remark'] = "星级分红主动执行:" . $yj_90;
+//                $week_data['week_record'] = $weekRecord;
+//                $week_data['all_amount'] = $fsMoneyNums;
+//                $week_data['radio'] = 2;
+//                $week_data['owner_bill'] = $maxValueAll;  //总流水金额
+//                $week_data['my_bill'] = $myBill;  //我的流水
+//                $week_data['create_time'] = time();
+//
+//                Db::name("old_user_weekaward")->insert($week_data);
+//
+//                $this->bill_user_log111111($v, "合伙人分佣", $yj_90, "合伙人分佣明细入账", 11);//联创分佣明细2.0系统
+//                $this->fugou_user_log($v, $fg_10, 16, 1, 1);//复购金明细入账
             }
+
         }
+        return json($salesArr);
+
     }
 
     /**
@@ -227,6 +295,29 @@ class TaskPartnerProfits
     }
 
     /**
+     * 获取该会员的所有下级会员
+     */
+    public function getSpreadUserUidAccountListByUidList($uid, $account = '')
+    {
+        $son_ids = Db::name("user")
+            ->where("spread_uid", $uid)
+            ->field("uid,spread_uid,account")
+            ->select()
+            ->toArray();
+        $new_array_ids = [];
+        foreach ($son_ids as $key => $value) {
+            $childList = $this->getSpreadUserUidAccountListByUidList($value['uid'], $value['account']);
+            $new_array_ids[] = [
+                '当前用户ID' => $value['uid'],
+                '当前用户的上级用户ID' => $value['spread_uid'],
+                '用户账号（手机号）' => $value['account'],
+                '当前用户的下级用户列表' => $childList
+            ];
+        }
+        return $new_array_ids;
+    }
+
+    /**
      * 递归查询单个用户的下级用户
      *
      * @param int $uid 用户ID
@@ -380,6 +471,7 @@ class TaskPartnerProfits
         // 基础查询构建器
         $user_team_amount = Db::name("old_user_of_goods")
             ->whereIn("user_id", $userIdList)
+            ->where('status', 1)
             ->where('money', 1180)
             ->select();
         //$money1180Records = $this->old_user_of_goods->where('status', 1)->where('money', 1180)->select();
@@ -392,6 +484,7 @@ class TaskPartnerProfits
         // 获取 status 为 1 且 money 为 11800 的记录集合
         $money11800Records = Db::name("old_user_of_goods")
             ->whereIn("user_id", $userIdList)
+            ->where('status', 1)
             ->where('money', 11800)
             ->select();
         // 计算 status 为 1 且 money 为 11800 的记录总和（减去相应值后）
@@ -402,6 +495,7 @@ class TaskPartnerProfits
 
         $money10620Records = Db::name("old_user_of_goods")
             ->whereIn("user_id", $userIdList)
+            ->where('status', 1)
             ->where('money', 10620)
             ->select();
         // 计算 status 为 1 且 money 为 10620 的记录总和（减去相应值后）
@@ -413,6 +507,7 @@ class TaskPartnerProfits
 
         $money9440Records = Db::name("old_user_of_goods")
             ->whereIn("user_id", $userIdList)
+            ->where('status', 1)
             ->where('money', 9440)
             ->select();
         // 计算 status 为 1 且 money 为 9440 的记录总和（减去相应值后）
@@ -423,6 +518,7 @@ class TaskPartnerProfits
 
         $money2360Records = Db::name("old_user_of_goods")
             ->whereIn("user_id", $userIdList)
+            ->where('status', 1)
             ->where('money', 2360)
             ->select();
         // 计算 status 为 1 且 money 为 2360 的记录总和（减去相应值后）
@@ -432,6 +528,7 @@ class TaskPartnerProfits
         }
 
         // 计算除去特定值后的总和
+        $otherMoneyRecords = [];
         //$otherMoneyRecords = $this->old_user_of_goods->where('status', 1)->whereNotIn('money', [1180, 11800])->select();
         $otherMoneyRecords = Db::name("old_user_of_goods")
             ->whereIn("user_id", $userIdList)
@@ -441,7 +538,7 @@ class TaskPartnerProfits
         foreach ($otherMoneyRecords as $record) {
             $otherMoneySum += $record['money'];
         }
-        return $money1180Sum + $money11800Sum + $money10620Sum + $money9440Sum + $money2360Sum + round($otherMoneySum * 0.7, 2);
+        return $money1180Sum + $money11800Sum + $money10620Sum + $money9440Sum + $money2360Sum + (floor($otherMoneySum * 70) / 100);
     }
 
     //发放佣金 示例: $this->change_user_log($v,'amount',1,$all_award,"member_award","星级分红入账"."-".$value['title']);//释放佣金