完善脚本中的问题

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

@@ -36,9 +36,13 @@ class Taskorderguquan
         // 1. 查询用户
         $userList = Db::name("user")
             ->where('is_del', 0)
+            //            ->whereIn('uid', [277, 1593])
             ->column('uid, spread_uid, contribute, per_contribute, pv', 'uid');
         // $userIds = array_keys($userList);
 
+        $oldUserList = Db::name("old_user_jbp")
+            ->column('id, amount');
+
         // 2. 查询老订单
         $userOfGoodsListRaw = Db::name("old_user_of_goods")
             ->where('status', 1)
@@ -62,7 +66,7 @@ class Taskorderguquan
             ->where('status', '<>', -1)
             // 优化: 如果记录非常多，可以分批查询或只查相关用户的
             // ->whereIn('uid', array_merge($userIds, array_column($userList, 'spread_uid'))) // 查询购买者和潜在推广者
-            ->field('uid, order_id, number, status')
+            ->field('uid, order_id, number, status, type')
             ->select()
             ->toArray();
 
@@ -77,11 +81,25 @@ class Taskorderguquan
 
         // --- 数据预处理部分
         $existingGongXian = [];
-        foreach ($gongXianListRaw as $gx) $existingGongXian[$gx['uid'] . '_' . $gx['order_id']] = ['number' => $gx['number'], 'status' => $gx['status']];
+        $existingGongXianByUid = [];
+        foreach ($gongXianListRaw as $gx) {
+            $existingGongXian[$gx['uid'] . '_' . $gx['order_id']] = ['number' => $gx['number'], 'status' => $gx['status'], 'type' => $gx['type']];
+            // TODO 目前老订单id 1-900 新订单ID 4868 - 6255 线下扫码订单 6870 - 8733
+            if ((1 <= $gx['order_id'] && $gx['order_id'] <= 900) || (4868 <= $gx['order_id'] && $gx['order_id'] <= 6869)) {
+                $existingGongXianByUid[$gx['uid']][] = $gx['order_id'];
+            }
+        }
         unset($gongXianListRaw);
 
         $existingPv = [];
-        foreach ($pvListRaw as $pv) $existingPv[$pv['uid'] . '_' . $pv['order_id']] = ['pv' => $pv['pv'], 'status' => $pv['status']];
+        $existingPvByUid = [];
+        foreach ($pvListRaw as $pv) {
+            $existingPv[$pv['uid'] . '_' . $pv['order_id']] = ['pv' => $pv['pv'], 'status' => $pv['status']];
+            // TODO 目前老订单id 1-900 新订单ID 4868 - 6255 线下扫码订单 6870 - 8733
+            if ((1 <= $pv['order_id'] && $pv['order_id'] <= 900) || (4868 <= $pv['order_id'] && $pv['order_id'] <= 6869)) {
+                $existingPvByUid[$pv['uid']][] = $pv['order_id'];
+            }
+        }
         unset($pvListRaw);
 
         $userOfGoodsByUid = [];
@@ -131,7 +149,8 @@ class Taskorderguquan
         // 遍历用户列表进行计算和数据收集
         foreach ($userList as $uid => $user) {
             $spreadUid = $user['spread_uid'];
-
+            $existingGongXianByUid[$uid] = $existingGongXianByUid[$uid] ?? [];
+            $existingPvByUid[$uid] = $existingPvByUid[$uid] ?? [];
             if (isset($userOfGoodsByUid[$uid])) {
                 foreach ($userOfGoodsByUid[$uid] as $oldOrder) {
                     switch ($oldOrder['money']) {
@@ -158,35 +177,47 @@ class Taskorderguquan
                     $settlementTimeOld = $oldOrder['create_time'] ? date('Y-m-d H:i:s', $oldOrder['create_time']) : strtotime($user['create_time']);
                     // --- 收集贡献值插入数据 ---
                     $orderKey = $uid . '_' . $oldOrder['order_id'];
+                    // 一个人 同一个订单 可能有多条记录 有问题
                     if (isset($existingGongXian[$orderKey])) {
                         $result['oldOrderExistGongXian'][] = ['uid' => $uid, 'order_id' => $oldOrder['order_id']];
+                        $existingGongXianByUid[$uid] = array_diff($existingGongXianByUid[$uid], [$oldOrder['order_id']]);
                         if ($existingGongXian[$orderKey]['status'] == 1) {
-                            $userUpdateData[$uid]['contribute'] += $existingGongXian[$orderKey]['number'];
+                            if ($existingGongXian[$orderKey]['type'] == 1) {
+                                $userUpdateData[$uid]['contribute'] += $existingGongXian[$orderKey]['number'];
+                            } else if ($existingGongXian[$orderKey]['type'] == 2) {
+                                $userUpdateData[$uid]['contribute'] -= $existingGongXian[$orderKey]['number'];
+                            }
                         }
                         if (!empty($spreadUid) && isset($userUpdateData[$spreadUid])) {
+                            $existingGongXianByUid[$spreadUid] = array_diff($existingGongXianByUid[$spreadUid], [$oldOrder['order_id']]);
                             if (isset($existingGongXian[$spreadUid . '_' . $oldOrder['order_id']])) {
                                 if ($existingGongXian[$spreadUid . '_' . $oldOrder['order_id']]['status'] == 1) {
-                                    $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $oldOrder['order_id']]['number'];
+                                    if ($existingGongXian[$spreadUid . '_' . $oldOrder['order_id']]['type'] == 1) {
+                                        $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $oldOrder['order_id']]['number'];
+                                    } else if ($existingGongXian[$spreadUid . '_' . $oldOrder['order_id']]['type'] == 2) {
+                                        $userUpdateData[$spreadUid]['per_contribute'] -= $existingGongXian[$spreadUid . '_' . $oldOrder['order_id']]['number'];
+                                    }
                                 }
                             }
                         }
                     } else {
                         if ($totalPv > 0) {
                             $userUpdateData[$uid]['contribute'] += $totalPv;
-
                             // --- 收集贡献值插入数据 ---
                             $gongXianBase = [
                                 "number" => $totalPv, "addtime" => strtotime($settlementTimeOld), "status" => 1,
-                                "order_type" => 1, "order_id" => $oldOrder['order_id'],
+                                "order_type" => 21, "order_id" => $oldOrder['order_id'],
                                 "desc" => '', "surplus" => 0, "type" => 1, 'settlement_time' => $settlementTimeOld
                             ];
                             // 本人
-                            $gongXianDataToInsert[] = array_merge(["uid" => $uid, "mark" => "1.0系统购买会员专区商品赠送贡献值"], $gongXianBase);
+                            $gongXianDataToInsert[] = array_merge(["uid" => $uid, "mark" => "购买会员专区商品赠送贡献值(1.0)"], $gongXianBase);
+                            $existingGongXianByUid[$uid] = array_diff($existingGongXianByUid[$uid], [$oldOrder['order_id']]);
                             // 推广人
                             if (!empty($user['spread_uid'])) {
                                 if (isset($userUpdateData[$spreadUid])) {
                                     $userUpdateData[$spreadUid]['per_contribute'] += $totalPv;
-                                    $gongXianDataToInsert[] = array_merge(["uid" => $spreadUid, "mark" => "1.0系统推广会员专区商品赠送贡献值"], $gongXianBase);
+                                    $gongXianDataToInsert[] = array_merge(["uid" => $spreadUid, "mark" => "推广会员专区商品赠送贡献值(1.0)"], $gongXianBase);
+                                    $existingGongXianByUid[$spreadUid] = array_diff($existingGongXianByUid[$spreadUid], [$oldOrder['order_id']]);
                                 }
                             }
                         }
@@ -201,11 +232,13 @@ class Taskorderguquan
                         $userUpdateData[$uid]['pv'] += $totalPv;
                         $pvDataToInsert[] = [
                             "uid" => $uid, "pv" => $totalPv, "addtime" => strtotime($settlementTimeOld), "status" => 1,
-                            "order_type" => 0, "order_id" => $oldOrder['order_id'],
-                            "mark" => "1.0系统购买会员专区商品赠送PV", 'settlement_time' => $settlementTimeOld
+                            "order_type" => 21, "order_id" => $oldOrder['order_id'],
+                            "mark" => "购买会员专区商品赠送PV(1.0)", 'settlement_time' => $settlementTimeOld
                         ];
                     }
-
+                    if (!empty($existingPvByUid[$uid])) {
+                        $existingPvByUid[$uid] = array_diff($existingPvByUid[$uid], [$oldOrder['order_id']]);
+                    }
                 }
             } // end if isset($userOfGoodsByUid[$uid])
 
@@ -244,35 +277,46 @@ class Taskorderguquan
                     // --- 收集贡献值插入数据 ---
                     if (isset($existingGongXian[$orderKey])) {
                         $result['orderExistGongXian'][] = ['uid' => $uid, 'order_id' => $order['order_id']];
+                        $existingGongXianByUid[$uid] = array_diff($existingGongXianByUid[$uid], [$order['order_id']]);
                         // 累加计算值
                         if ($existingGongXian[$orderKey]['status'] == 1) {
-                            $userUpdateData[$uid]['contribute'] += $existingGongXian[$orderKey]['number'];
+                            if ($existingGongXian[$orderKey]['type'] == 1) {
+                                $userUpdateData[$uid]['contribute'] += $existingGongXian[$orderKey]['number'];
+                            } else if ($existingGongXian[$orderKey]['type'] == 2) {
+                                $userUpdateData[$uid]['contribute'] -= $existingGongXian[$orderKey]['number'];
+                            }
                         }
                         if (!empty($spreadUid) && isset($userUpdateData[$spreadUid])) {
+                            $existingGongXianByUid[$spreadUid] = array_diff($existingGongXianByUid[$spreadUid], [$order['order_id']]);
                             if (isset($existingGongXian[$spreadUid . '_' . $order['order_id']])) {
                                 if ($existingGongXian[$spreadUid . '_' . $order['order_id']]['status'] == 1) {
-                                    $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $order['order_id']]['number'];
+                                    if ($existingGongXian[$spreadUid . '_' . $order['order_id']]['type'] == 1) {
+                                        $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $order['order_id']]['number'];
+                                    } else if ($existingGongXian[$spreadUid . '_' . $order['order_id']]['type'] == 2) {
+                                        $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $order['order_id']]['number'];
+                                    }
                                 }
                             }
                         }
 
                     } else {
                         if ($totalPv > 0) {
-                            // 累加计算值
                             $userUpdateData[$uid]['contribute'] += $totalPv;
                             $gongXianBase = [ // 优化: 提取公共字段
                                 "number" => $totalPv, "addtime" => strtotime($settlementTimeNew), "status" => 1,
-                                "order_type" => 1, "order_id" => $order['order_id'],
+                                "order_type" => 22, "order_id" => $order['order_id'],
                                 "desc" => '', "surplus" => 0, "type" => 1, 'settlement_time' => $settlementTimeNew
                             ];
                             // 本人
-                            $gongXianDataToInsert[] = array_merge(["uid" => $uid, "mark" => "2.0系统购买商品赠送贡献值"], $gongXianBase);
+                            $gongXianDataToInsert[] = array_merge(["uid" => $uid, "mark" => "购买商品赠送贡献值(2.0)"], $gongXianBase);
+                            $existingGongXianByUid[$uid] = array_diff($existingGongXianByUid[$uid], [$order['order_id']]);
                             // 推广人
                             if (!empty($user['spread_uid'])) {
                                 $spreadUid = $user['spread_uid'];
                                 if (isset($userUpdateData[$spreadUid])) { // 确保推广者存在
-                                    $gongXianDataToInsert[] = array_merge(["uid" => $spreadUid, "mark" => "2.0系统推广商品赠送贡献值"], $gongXianBase);
+                                    $gongXianDataToInsert[] = array_merge(["uid" => $spreadUid, "mark" => "推广商品赠送贡献值(2.0)"], $gongXianBase);
                                     $userUpdateData[$spreadUid]['per_contribute'] += $totalPv; // 累加推广者业绩
+                                    $existingGongXianByUid[$spreadUid] = array_diff($existingGongXianByUid[$spreadUid], [$order['order_id']]);
                                 }
                             }
                         }
@@ -288,12 +332,15 @@ class Taskorderguquan
                         $userUpdateData[$uid]['pv'] += $totalPv;
                         $pvDataToInsert[] = [
                             "uid" => $uid, "pv" => $totalPv, "addtime" => strtotime($settlementTimeNew), "status" => 1,
-                            "order_type" => 0, // 确认 PV log 的 order_type 是否与贡献一致或有区分
+                            "order_type" => 22, // 确认 PV log 的 order_type 是否与贡献一致或有区分
                             "order_id" => $order['order_id'],
-                            "mark" => "2.0系统购买商品赠送PV", // 标记调整为更通用
+                            "mark" => "购买商品赠送PV(2.0)", // 标记调整为更通用
                             'settlement_time' => $settlementTimeNew
                         ];
                     }
+                    if (!empty($existingPvByUid[$uid])) {
+                        $existingPvByUid[$uid] = array_diff($existingPvByUid[$uid], [$order['order_id']]);
+                    }
                 }
             }
             // end if isset($storeOrdersByUid[$uid])
@@ -324,6 +371,64 @@ class Taskorderguquan
         // 使用事务确保数据一致性
         Db::startTrans();
         try {
+            $bill = [];
+            foreach ($oldUserList as $item) {
+                $bill[] = [
+                    'uid' => $item['id'],
+                    'link_id' => 0,//关联订单id
+                    'pm' => 1,//0：支出，1：获得
+                    'title' => '佣金',//账单标题
+                    'category' => 'now_money',//明细种类
+                    'type' => 'commission',//明细类型
+                    'number' => $item['amount'],//明细数字
+                    'balance' => 0,//剩余
+                    'mark' => '1.0佣金记录',//备注
+                    'create_time' => '2025-02-04 00:00:00',//添加时间
+                    'status' => 1,//0待确定，1有效，-1无效
+                    'commission_type' => 21,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
+                    //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
+                    //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
+                    'order_sn' => 0,//订单号
+                    'tripartite' => 0,//
+                    'type_shop' => 0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
+                    'mer_id' => 0,//商户id
+                    'source' => 0,//1线下 0线上
+                    'order_type' => 1,//1自营  2 第三方  订单类型
+                    'is_red_brokerage' => 0,//1红积分对冲佣金 0正常佣金
+                    'gzc' => 3,//养老金是否已进入公证处log表0：未进入。1：已进入
+                    'take_time' => '',//结算时间
+                    'district_id' => '',//
+                    'street_id' => '',//
+                    'month' => '',//月份
+
+
+                ];
+            }
+            $chunkedBill = array_chunk($bill, 500);
+            foreach ($chunkedBill as $chunk) {
+                Db::name('user_bill')->insertAll($chunk);
+            }
+
+            if (!empty($existingGongXianByUid)) {
+                foreach ($existingGongXianByUid as $uid => $orderList) {
+                    if (!empty($orderList)) {
+                        Db::name("user_sign_gongxian")
+                            ->where('uid', $uid)
+                            ->whereIn('order_id', $orderList)
+                            ->update(['status' => 0]);
+                    }
+                }
+            }
+            if (!empty($existingPvByUid)) {
+                foreach ($existingPvByUid as $uid => $orderList) {
+                    if (!empty($orderList)) {
+                        Db::name("user_pv_log")
+                            ->where('uid', $uid)
+                            ->whereIn('order_id', $orderList)
+                            ->update(['status' => 0]);
+                    }
+                }
+            }
             // --- 批量插入贡献值 ---
             if (!empty($gongXianDataToInsert)) {
                 // 分块插入，避免单次插入过多数据 (例如一次500条)
@@ -453,109 +558,109 @@ class Taskorderguquan
 
         return json($result);
 
-        // 计算总业绩
-        $totalPv = [];
-        foreach ($user_team_amount as $order) {
-            if (!isset($totalPv[$order['user_id']])) {
-                $totalPv[$order['user_id']] = 0;
-            }
-            switch ($order['money']) {
-                case 1180:
-                    $totalPv[$order['user_id']] += 700;
-                    break;
-                case 11800:
-                    $totalPv[$order['user_id']] += 7000;
-                    break;
-                case 10620:
-                    $totalPv[$order['user_id']] += 6300;
-                    break;
-                case 2360:
-                    $totalPv[$order['user_id']] += 1400;
-                    break;
-                case 9440:
-                    $totalPv[$order['user_id']] += 5600;
-                    break;
-                default:
-                    if ($order['money'] == 2344.99) {
-                        break;
-                    }
-                    $totalPv[$order['user_id']] += round($order['money'] * 0.7, 2);
-                    break;
-            }
-        }
-        foreach ($totalPv as $uid => $pv) {
-            Db::name("user")->where('is_old', 1)->where("uid", $uid)->update(['pv' => $pv]);
-        }
-
-        return;
-        /**
-         * 周金花200(13959100621)
-         * 黄金花200(18603401312)
-         * 徐立苹100(13521438652)
-         * 李素红200(13701061395)
-         * 周行体200(13231658486)
-         * 刘银霞100(13161909228)
-         * 李卫东100(13911601230)
-         * 金    波100(13801358713)
-         * 王   玲 150(15810064711)
-         * 侯玉兰150(15232797965)
-         * 吕丽娣100(15960349667)
-         * 张传莲100(15332507711)
-         * 刘春梅100(18760167163)
-         * 付天如100(18863873000)
-         * 付绍先100(15324059286)
-         * 黄桂林100(15960196876)
-         * 温  煌100(18350134089)
-         * 谭英先100(13978627072)
-         * 陈玉珍100(19858353660)
-         * 黄雪云100(18650055445)
-         * 黄  玲100(13877193411)
-         * 邱佳珍100(13960379098)
-         * 隋彩云100（13601071082）
-         */
-        $data = [
-            '13959100621' => 200,
-            '18603401312' => 200,
-            '13521438652' => 100,
-            '13701061395' => 200,
-            '13231658486' => 200,
-            '13161909228' => 100,
-            '13911601230' => 100,
-            '13801358713' => 100,
-            '15810064711' => 150,
-            '15232797965' => 150,
-            '15960349667' => 100,
-            '15332507711' => 100,
-            '18760167163' => 100,
-            '18863873000' => 100,
-            '15324059286' => 100,
-            '15960196876' => 100,
-            '18350134089' => 100,
-            '13978627072' => 100,
-            '19858353660' => 100,
-            '18650055445' => 100,
-            '13877193411' => 100,
-            '13960379098' => 100,
-            '13601071082' => 100,
-        ];
-        $result = Db::name("user")
-            ->whereIn("account", array_keys($data))
-            ->where('is_del', 0)
-            ->field('uid, brokerage_price, account, nickname')
-            ->select();
-        $res = [];
-        foreach ($result as $v) {
-            Db::name("user")->where("uid", $v['uid'])->inc("brokerage_price", $data[$v['account']])->save();
-            $this->bill_user_log111111($v['uid'], "佣金补贴", $data[$v['account']], "佣金补贴", 8);//股权分佣明细2.0系统
-            $res[] = [
-                'uid' => $v['uid'],
-                'account' => $v['account'],
-                'brokerage_price_pre' => $v['brokerage_price'],
-                'brokerage_price' => $data[$v['account']],
-                'nickname' => $v['nickname']
-            ];
-        }
-        return json($res);
+        //        // 计算总业绩
+        //        $totalPv = [];
+        //        foreach ($user_team_amount as $order) {
+        //            if (!isset($totalPv[$order['user_id']])) {
+        //                $totalPv[$order['user_id']] = 0;
+        //            }
+        //            switch ($order['money']) {
+        //                case 1180:
+        //                    $totalPv[$order['user_id']] += 700;
+        //                    break;
+        //                case 11800:
+        //                    $totalPv[$order['user_id']] += 7000;
+        //                    break;
+        //                case 10620:
+        //                    $totalPv[$order['user_id']] += 6300;
+        //                    break;
+        //                case 2360:
+        //                    $totalPv[$order['user_id']] += 1400;
+        //                    break;
+        //                case 9440:
+        //                    $totalPv[$order['user_id']] += 5600;
+        //                    break;
+        //                default:
+        //                    if ($order['money'] == 2344.99) {
+        //                        break;
+        //                    }
+        //                    $totalPv[$order['user_id']] += round($order['money'] * 0.7, 2);
+        //                    break;
+        //            }
+        //        }
+        //        foreach ($totalPv as $uid => $pv) {
+        //            Db::name("user")->where('is_old', 1)->where("uid", $uid)->update(['pv' => $pv]);
+        //        }
+        //
+        //        return;
+        //        /**
+        //         * 周金花200(13959100621)
+        //         * 黄金花200(18603401312)
+        //         * 徐立苹100(13521438652)
+        //         * 李素红200(13701061395)
+        //         * 周行体200(13231658486)
+        //         * 刘银霞100(13161909228)
+        //         * 李卫东100(13911601230)
+        //         * 金    波100(13801358713)
+        //         * 王   玲 150(15810064711)
+        //         * 侯玉兰150(15232797965)
+        //         * 吕丽娣100(15960349667)
+        //         * 张传莲100(15332507711)
+        //         * 刘春梅100(18760167163)
+        //         * 付天如100(18863873000)
+        //         * 付绍先100(15324059286)
+        //         * 黄桂林100(15960196876)
+        //         * 温  煌100(18350134089)
+        //         * 谭英先100(13978627072)
+        //         * 陈玉珍100(19858353660)
+        //         * 黄雪云100(18650055445)
+        //         * 黄  玲100(13877193411)
+        //         * 邱佳珍100(13960379098)
+        //         * 隋彩云100（13601071082）
+        //         */
+        //        $data = [
+        //            '13959100621' => 200,
+        //            '18603401312' => 200,
+        //            '13521438652' => 100,
+        //            '13701061395' => 200,
+        //            '13231658486' => 200,
+        //            '13161909228' => 100,
+        //            '13911601230' => 100,
+        //            '13801358713' => 100,
+        //            '15810064711' => 150,
+        //            '15232797965' => 150,
+        //            '15960349667' => 100,
+        //            '15332507711' => 100,
+        //            '18760167163' => 100,
+        //            '18863873000' => 100,
+        //            '15324059286' => 100,
+        //            '15960196876' => 100,
+        //            '18350134089' => 100,
+        //            '13978627072' => 100,
+        //            '19858353660' => 100,
+        //            '18650055445' => 100,
+        //            '13877193411' => 100,
+        //            '13960379098' => 100,
+        //            '13601071082' => 100,
+        //        ];
+        //        $result = Db::name("user")
+        //            ->whereIn("account", array_keys($data))
+        //            ->where('is_del', 0)
+        //            ->field('uid, brokerage_price, account, nickname')
+        //            ->select();
+        //        $res = [];
+        //        foreach ($result as $v) {
+        //            Db::name("user")->where("uid", $v['uid'])->inc("brokerage_price", $data[$v['account']])->save();
+        //            $this->bill_user_log111111($v['uid'], "佣金补贴", $data[$v['account']], "佣金补贴", 8);//股权分佣明细2.0系统
+        //            $res[] = [
+        //                'uid' => $v['uid'],
+        //                'account' => $v['account'],
+        //                'brokerage_price_pre' => $v['brokerage_price'],
+        //                'brokerage_price' => $data[$v['account']],
+        //                'nickname' => $v['nickname']
+        //            ];
+        //        }
+        //        return json($res);
 
     }