完善合伙人分红功能

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

@@ -78,8 +78,36 @@ class TaskPartnerProfits
 
     public function partnerProfits($startTime = '', $endTime = '')
     {
-        $startTime = '2025-03-10';
-        $endTime = '2025-03-30';
+
+        // 由于分红错误 需要对数据进行撤回
+        //        $user_bill_list = Db::name("user_bill")
+        //            ->where("title", '合伙人分佣')
+        //            ->where("status", 1)
+        //            ->whereBetween('create_time', ['2025-04-07 16:46:56', '2025-04-07 16:47:02'])
+        //            ->select()
+        //            ->toArray();
+        //        $user_bill_uid_list = array_column($user_bill_list, null, 'uid');
+        //
+        //        $user_sign_fugou_list = Db::name("user_sign_fugou")
+        //            ->where("mark", '复购金')
+        //            ->where("status", 1)
+        //            ->whereBetween('settlement_time', ['2025-04-07 16:46:56', '2025-04-07 16:47:02'])
+        //            ->select()
+        //            ->toArray();
+        //        $user_sign_fugou_uid_list = array_column($user_sign_fugou_list, null, 'uid');
+        //
+        //        $old_user_weekaward_list = Db::name("old_user_weekaward")
+        ////            ->where("mark", '复购金')
+        ////            ->where("status", 1)
+        //            ->whereBetween('create_time', [1744015616, 1744015622])
+        //            ->select()
+        //            ->toArray();
+        //        $old_user_weekaward_list = array_column($old_user_weekaward_list, null, 'uid');
+
+        //        return json($user_bill_list);
+
+        $startTime = '2025-03-31';
+        $endTime = '2025-04-06';
         // 查询测试人员账号信息
         //18973958920
         //15186694339
@@ -250,14 +278,14 @@ class TaskPartnerProfits
                 //返回是数组，下标0是最小的值(业绩小的)，下标1是最大的值(业绩大的)
                 $userPvSmallNum = $value['dividerPeoplePv'][$v]['sumOfOthers'] ?? 0;
                 //                $myMixMoney = round($amount * ($userPvSmallNum / $sumOfOthersAll), 2);
-                $myMixMoney = floor(($amount * (floor(($userPvSmallNum / $sumOfOthersAll) * 1000) / 1000)) * 100) / 100;
+                $myMixMoney = floor(($amount * (floor(($userPvSmallNum / $sumOfOthersAll) * 100000) / 100000)) * 100) / 100;
 
                 //个人双区总佣金 权重 计算
                 $myBill = $value['dividerPeoplePv'][$v]['maxValue'] ?? 0;
                 //中级合伙人。userid=17可以分到双区可分红的金额
                 //可分红的佣金 * (中级合伙人个人的双区总业绩 / 当前等级所有合伙人的双联盟业绩) = 当前用户可以获取到的分红佣金(双区联盟总业绩加权佣金),287742 * (61.95/431032)=41.36
                 //                $myWeightMoney = round($amount * ($myBill / $maxValueAll), 2);
-                $myWeightMoney = floor(($amount * (floor((($myBill + $userPvSmallNum) / ($maxValueAll + $sumOfOthersAll)) * 1000) / 1000)) * 100) / 100;
+                $myWeightMoney = floor(($amount * (floor((($myBill + $userPvSmallNum) / ($maxValueAll + $sumOfOthersAll)) * 100000) / 100000)) * 100) / 100;
 
 
                 $salesArr[$key]['dividerPeoplePv'][$v]['myWeightMoney'] = $myWeightMoney;
@@ -269,8 +297,19 @@ class TaskPartnerProfits
                 $allAward = $myWeightMoney + $myMixMoney;
 
                 //90%给佣金，10给复购金
-                $yj_90 = $allAward * 0.9;
-                $fg_10 = $allAward * 0.1;
+                $yj_90 = floor($allAward * 0.9 * 100) / 100;
+                $fg_10 = floor($allAward * 0.1 * 100) / 100;
+
+                //                $yj_90 = bcsub($yj_90, $user_bill_uid_list[$v]['number'] ?? 0.00, 2);
+                //
+                //                $fg_10 = bcsub($fg_10, $user_sign_fugou_uid_list[$v]['number'] ?? 0.00, 2);
+                //
+                //                if ($yj_90 < 0) {
+                //                    $testRecord['yj_fushu'][] = ['uid' => $v, 'num' => floor($allAward * 0.9 * 100) / 100, 'exist' => $user_bill_uid_list[$v]['number'] ?? 0.00, 'yj' => $yj_90];
+                //                }
+                //                if ($fg_10 < 0) {
+                //                    $testRecord['fg_fushu'][] = ['uid' => $v, 'num' => floor($allAward * 0.1 * 100) / 100, 'exist' => $user_sign_fugou_uid_list[$v]['number'] ?? 0.00, 'fg' => $fg_10];
+                //                }
 
 
                 $userdatassss = db::name("old_user_jbp")->where("id", $v)->find();
@@ -309,7 +348,7 @@ class TaskPartnerProfits
                 $this->bill_user_log111111($v, "合伙人分佣", $yj_90, "合伙人分佣明细入账", 11);//联创分佣明细2.0系统
                 $this->fugou_user_log($v, $fg_10, 16, 1, 1);//复购金明细入账
             }
-
+            $salesArr['cs'] = $testRecord;
         }
         return json($salesArr);
     }
@@ -320,13 +359,13 @@ class TaskPartnerProfits
     public function getSpreadUserUidListByUidList(array $uidList)
     {
         $son_ids = Db::name("user")
-            ->whereIn("spread_uid", $uidList)
-            ->field("uid,spread_uid")
+            ->whereIn("level_id", $uidList)
+            ->field("uid,level_id")
             ->select()
             ->toArray();
         $new_array_ids = [];
         foreach ($son_ids as $key => $value) {
-            $new_array_ids[$value['spread_uid']][] = $value['uid'];
+            $new_array_ids[$value['level_id']][] = $value['uid'];
         }
         return $new_array_ids;
     }
@@ -354,8 +393,8 @@ class TaskPartnerProfits
     public function getSpreadUserUidAccountListByUidList($uid, $account = '')
     {
         $son_ids = Db::name("user")
-            ->where("spread_uid", $uid)
-            ->field("uid,spread_uid,account")
+            ->where("level_id", $uid)
+            ->field("uid,level_id,account")
             ->select()
             ->toArray();
         $new_array_ids = [];
@@ -363,7 +402,7 @@ class TaskPartnerProfits
             $childList = $this->getSpreadUserUidAccountListByUidList($value['uid'], $value['account']);
             $new_array_ids[] = [
                 '当前用户ID' => $value['uid'],
-                '当前用户的上级用户ID' => $value['spread_uid'],
+                '当前用户的上级用户ID' => $value['level_id'],
                 '用户账号（手机号）' => $value['account'],
                 '当前用户的下级用户列表' => $childList
             ];
@@ -381,7 +420,7 @@ class TaskPartnerProfits
     private function getSubordinatesRecursively(int $uid, array &$subordinates = []): array
     {
         $subUidList = Db::name("user")
-            ->where("spread_uid", $uid)  // 直接使用 $uid, 不需要 whereIn
+            ->where("level_id", $uid)  // 直接使用 $uid, 不需要 whereIn
             ->field("uid") //只需要查询uid
             ->select()
             ->toArray();
@@ -405,7 +444,7 @@ class TaskPartnerProfits
     public function getAllSubordinates(int $uid, array &$allSubordinates = []): array
     {
         $subUidList = Db::name("user")
-            ->where("spread_uid", $uid)
+            ->where("level_id", $uid)
             ->column("uid");  // 使用 column 方法直接获取 uid 数组
 
         if (!empty($subUidList)) {
@@ -439,7 +478,7 @@ class TaskPartnerProfits
                 }
                 $processed[] = $currentUid;
                 $subUidList = Db::name("user")
-                    ->where("spread_uid", $currentUid)
+                    ->where("level_id", $currentUid)
                     ->column("uid");
 
                 if (!empty($subUidList)) {
@@ -470,8 +509,8 @@ class TaskPartnerProfits
             if (empty($currentUids)) continue;  //没有新的需要处理的
             $processed = array_merge($processed, $currentUids);//记录
             $subUidList = Db::name("user")
-                ->whereIn("spread_uid", $currentUids)
-                ->field("uid,spread_uid") // 需要查询 spread_uid 用于后续分组
+                ->whereIn("level_id", $currentUids)
+                ->field("uid,level_id") // 需要查询 level_id 用于后续分组
                 ->select()
                 ->toArray();
 
@@ -487,7 +526,7 @@ class TaskPartnerProfits
         }
         $allSubordinatesMap = [];
         foreach ($allSubordinates as $item) {
-            $allSubordinatesMap[$item['spread_uid']][] = $item['uid'];
+            $allSubordinatesMap[$item['level_id']][] = $item['uid'];
         }
 
         //3. 递归的将查到的下级进行分组