合伙人分红重写-1.2.0

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

@@ -8,30 +8,38 @@ use think\facade\Db;
 
 class TaskPartnerProfits
 {
-
-    public function getTeamPvByTime($timePeriod = 'last_week')
+    public function getTime($timePeriod)
     {
         // 定义时间区间
+        $now = time();
         $startTime = '';
         $endTime = '';
-
         if ($timePeriod == 'last_week') {
             // 上周的时间区间
-            $startTime = '2025-03-17 00:00:00'; // 上周星期一的开始时间
-            $endTime = '2025-03-23 23:59:59'; // 上周星期日的结束时间
+            $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 = '2025-02-17 00:00:00'; // 这周星期一的开始时间
-            $endTime = '2025-02-23 23:59:59'; // 这周星期日的结束时间
-        } else {
-            return "Invalid time period specified.";
+            $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, $endTime])
+            ->whereBetween("pay_time", [$startTime . ' 00:00:00', $endTime . ' 23:59:59'])
             ->whereNotNull("pay_time") // 排除 pay_time 为 NULL 的订单
             ->select();
 
@@ -60,12 +68,49 @@ class TaskPartnerProfits
         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()
     {
-//        $a = $this->getSpreadUserUidAccountListByUidList(1);
-//        return json($a);
+        // 查询测试人员账号信息
+        //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 = $this->getTeamPvByTime('last_week');
+        $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();//旧星级等级
@@ -80,8 +125,10 @@ class TaskPartnerProfits
 
         // 3、获取 分红用户 信息 （`user_group` tinyint(1) DEFAULT '1' COMMENT '1消费者 2,推广业务员 3，业务经理 4初级合伙人5中级合伙人 6高级合伙人 7.懂事',）
         $list = Db::name("user")
+//            ->whereNotIn('uid', $removeUserIdList)
             ->where("user_group", "IN", [4, 5, 6])
             ->where("status", "<>", 0)
+            ->where('is_del', '<>', 1)
             ->select()
             ->toArray();
 
@@ -98,29 +145,29 @@ class TaskPartnerProfits
 
         // 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、执行分开发放
@@ -151,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;
                     }
@@ -217,47 +264,46 @@ 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 . " 小区总业绩:" . $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);//复购金明细入账
+                $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);
-
     }
 
     /**
@@ -466,8 +512,11 @@ 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)
@@ -529,11 +578,10 @@ 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)
-            ->whereNotIn('money', [1180, 11800, 10620, 9440, 2360])
-            ->select();
+//        $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'];

route/api.php

@@ -1289,6 +1289,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');
 });