Merge remote-tracking branch 'origin/sxb-dev' into sxb-dev

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

@@ -8,15 +8,114 @@ use think\facade\Db;
 
 class TaskPartnerProfits
 {
+    public function getTime($timePeriod)
+    {
+        // 定义时间区间
+        $now = time();
+        $startTime = '';
+        $endTime = '';
+        if ($timePeriod == 'last_week') {
+            // 上周的时间区间
+            $startTime = date('Y-m-d', strtotime('monday last week', $now)); // 上周星期一的开始时间
+            $endTime = date('Y-m-d', strtotime('sunday last week', $now)); // 上周星期日的结束时间
+        } elseif ($timePeriod == 'this_week') {
+            // 这周的时间区间
+            $startTime = date('Y-m-d', strtotime('monday this week', $now)); // 这周星期一的开始时间
+            $endTime = date('Y-m-d', strtotime('sunday this week', $now)); // 这周星期日的结束时间
+        }
+//        return ['startTime' => '2025-03-10', 'endTime' => '2025-03-23'];
+        return ['startTime' => $startTime, 'endTime' => $endTime];
+    }
+
+    public function getTeamPvByTime($timePeriod = 'last_week', $removeUserIdList = [])
+    {
+        $timeMap = $this->getTime($timePeriod);
+        $startTime = $timeMap['startTime'];
+        $endTime = $timeMap['endTime'];
+
+        // 查询指定时间区间内的所有订单，并排除 pay_time 为 NULL 的订单
+        $orders = Db::name("store_order")
+            ->where('mer_id', 496)
+            ->whereNotIn('uid', $removeUserIdList)
+            ->whereIn('status', [0, 1, 2, 3])
+            ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440])
+            ->whereBetween("pay_time", [$startTime . ' 00:00:00', $endTime . ' 23:59:59'])
+            ->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 getRedEnvelopeByTime($timePeriod = 'last_week', $removeUserIdList = [])
+    {
+        $timeMap = $this->getTime($timePeriod);
+        $startTime = $timeMap['startTime'];
+        $endTime = $timeMap['endTime'];
+
+        // 查询指定时间区间内的所有订单，并排除 pay_time 为 NULL 的订单
+        $redEnvelopeList = Db::name("user_sign_hongbao")
+            ->whereNotIn('uid', $removeUserIdList)
+            ->where('status', 1)
+            ->whereBetween("settlement_time", [$startTime . ' 00:00:00', $endTime . ' 23:59:59'])
+            ->select()
+            ->toArray();
+        return floor(array_sum(array_column($redEnvelopeList, 'number')) * 100) / 100;
+    }
+
     public function partnerProfits()
     {
+        // 查询测试人员账号信息
+        //18973958920
+        //15186694339
+        //18833633835
+        //19525470098
+        //17756507016
+        //18226705337
+        $testAccount = ['18973958920', '15186694339', '18833633835', '19525470098', '17756507016', '18226705337'];
+        $removeUserList = Db::name("user")
+            ->whereIn('account', $testAccount)
+            ->where("status", "<>", 0)
+            ->where('is_del', '<>', 1)
+            ->select()
+            ->toArray();
+        $removeUserIdList = array_column($removeUserList, 'uid');
         // 定义分红金额
-        $weekRecord = 10500 + 50000;
+        $weekRecord = $this->getTeamPvByTime('last_week', $removeUserIdList);
+        // 分红金额 - 红包金额
+        $redEnvelope = $this->getRedEnvelopeByTime('last_week', $removeUserIdList);
+
+        $weekRecord -= $redEnvelope;
+        if ($weekRecord <= 0) {
+            return json('无效分红金额');
+        }
+
 
         // 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,8 +125,10 @@ 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])
+//            ->whereNotIn('uid', $removeUserIdList)
+            ->where("user_group", "IN", [4, 5, 6])
             ->where("status", "<>", 0)
+            ->where('is_del', '<>', 1)
             ->select()
             ->toArray();
 
@@ -37,35 +138,36 @@ 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
-        $ids_to_remove_from_intermediate = array(49); // 从中级中移除的ID
-        // 查找初级并获取其divider_people
-        $junior = &$salesArr['初级']['divider_people']; // 使用引用，以便直接修改数组
-        // 查找中级并获取其divider_people
-        $intermediate = &$salesArr['中级']['divider_people']; // 使用引用，以便直接修改数组
-        // 从初级的divider_people中移除特定的ID
-        foreach ($ids_to_remove_from_junior as $id) {
-            $key = array_search($id, $junior);
-            if ($key !== false) {
-                unset($junior[$key]); // 移除初级中的特定ID
-            }
-        }
-        // 从中级的divider_people中移除特定的ID
-        foreach ($ids_to_remove_from_intermediate as $id) {
-            $key = array_search($id, $intermediate);
-            if ($key !== false) {
-                unset($intermediate[$key]); // 移除中级中的特定ID
-            }
-        }
-        // 重置数组的索引，因为unset会留下空位
-        $salesArr['初级']['divider_people'] = array_values($junior);
-        $salesArr['中级']['divider_people'] = array_values($intermediate);
+//        $ids_to_remove_from_junior = array(12, 69, 144); // 从初级中移除的ID
+//        $ids_to_remove_from_intermediate = array(49); // 从中级中移除的ID
+//        // 查找初级并获取其divider_people
+//        $junior = &$salesArr['初级']['divider_people']; // 使用引用，以便直接修改数组
+//        // 查找中级并获取其divider_people
+//        $intermediate = &$salesArr['中级']['divider_people']; // 使用引用，以便直接修改数组
+//        // 从初级的divider_people中移除特定的ID
+//        foreach ($ids_to_remove_from_junior as $id) {
+//            $key = array_search($id, $junior);
+//            if ($key !== false) {
+//                unset($junior[$key]); // 移除初级中的特定ID
+//            }
+//        }
+//        // 从中级的divider_people中移除特定的ID
+//        foreach ($ids_to_remove_from_intermediate as $id) {
+//            $key = array_search($id, $intermediate);
+//            if ($key !== false) {
+//                unset($intermediate[$key]); // 移除中级中的特定ID
+//            }
+//        }
+//        // 重置数组的索引，因为unset会留下空位
+//        $salesArr['初级']['divider_people'] = array_values($junior);
+//        $salesArr['中级']['divider_people'] = array_values($intermediate);
 
 
         // 6、执行分开发放
@@ -74,14 +176,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 查出分红人的所有部门 即 下级用户
@@ -94,8 +198,8 @@ class TaskPartnerProfits
                 $subordinatesBatch = $this->getSubordinatesBatch($spreadUserUidList[$v]);
                 // 6.2.3 获取所有部门（下线）的PV值
                 foreach ($subordinatesBatch as $k1 => $v1) {
-                    // 获取当前下线的PV值
-                    $pv = $this->getPv(array_merge($v1, [$k1]));
+                    // 获取当前下线的PV值, 忽略测试人员的账号
+                    $pv = $this->getPv(array_merge($v1, [$k1]), $removeUserIdList);
                     if (!empty($pv)) {
                         $partnerProfitsPvListByUid[$v][$k1] = $pv;
                     }
@@ -113,18 +217,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 +236,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;
@@ -154,7 +266,7 @@ class TaskPartnerProfits
 
                 $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,
+                    '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数据表中
@@ -189,7 +301,9 @@ class TaskPartnerProfits
                 $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 +341,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
@@ -375,11 +512,15 @@ class TaskPartnerProfits
     }
 
     // 获取用户PV值
-    public function getPv($userIdList)
+    public function getPv($userIdList, $removeUserIdList = [])
     {
+        if (!empty($removeUserIdList)) {
+            $userIdList = array_values(array_diff($userIdList, $removeUserIdList));
+        }
         // 基础查询构建器
         $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 +533,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 +544,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 +556,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 +567,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,16 +577,16 @@ class TaskPartnerProfits
         }
 
         // 计算除去特定值后的总和
-        //$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)
-            ->whereNotIn('money', [1180, 11800, 10620, 9440, 2360])
-            ->select();
+        $otherMoneyRecords = [];
+//        $otherMoneyRecords = Db::name("old_user_of_goods")
+//            ->whereIn("user_id", $userIdList)
+//            ->whereNotIn('money', [1180, 11800, 10620, 9440, 2360])
+//            ->select();
         $otherMoneySum = 0;
         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']);//释放佣金

cc.txt

@@ -0,0 +1 @@
+12

route/api.php

@@ -1291,6 +1291,10 @@ Route::group('api/', function () {
     ->middleware(\app\common\middleware\AllowOriginMiddleware::class)
     ->middleware(\app\common\middleware\InstallMiddleware::class)
     ->middleware(\app\common\middleware\CheckSiteOpenMiddleware::class);
+//Route::get('/sxb_test', 'api.store.merchant.TaskPartnerProfits/partnerProfits');
+Route::get('sxb_test', function () {
+    return 'hello,ThinkPHP6!';
+});
 Route::any('/share', function () {
     return view(app()->getRootPath() . 'public/share/register.html');
 });