依照老订单、新订单数据，补全缺失的贡献值和PV记录，以及更新用户表中的贡献值、直推贡献值、PV值

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

@@ -7,6 +7,7 @@
 
 namespace app\controller\api\store\merchant;
 
+use app\common\model\user\User;
 use think\facade\Db;
 
 class Taskorderguquan
@@ -14,8 +15,432 @@ class Taskorderguquan
 
     public function assignment()
     {
-        $user_team_amount = Db::name("old_user_of_goods")
-            ->select();
+        $result = [
+            'oldOrderExistGongXian' => [],
+            'orderExistGongXian' => [],
+            'oldOrderExistPv' => [],
+            'orderExistPv' => [],
+            'gongXianDataOldList' => [],
+            'gongXianDataList' => [],
+            'pvDataOldList' => [],
+            'pvDataList' => [],
+            'contributeNot' => [],
+            'pvNot' => [],
+            'userUpdateSummary' => ['success' => 0, 'failed' => 0, 'skipped' => 0], // 优化: 汇总用户更新结果
+            'insertGongXianSummary' => ['success' => 0, 'failed' => 0], // 优化: 汇总贡献插入结果
+            'insertPvSummary' => ['success' => 0, 'failed' => 0],         // 优化: 汇总PV插入结果
+            'errors' => [],               // 优化: 统一记录错误信息
+        ];
+        $currentTime = time();
+        $currentDateTime = date('Y-m-d H:i:s', $currentTime);
+
+        // --- 数据库查询部分 (保持不变，已优化) ---
+        // 1. 查询用户
+        $userList = Db::name("user")
+            ->where('is_del', 0)
+            ->column('uid, spread_uid, contribute, per_contribute, pv', 'uid');
+        // $userIds = array_keys($userList);
+
+        // 2. 查询老订单
+        $userOfGoodsListRaw = Db::name("old_user_of_goods")
+            ->where('status', 1)
+            // 优化: 如果用户量大，可以考虑只查相关用户的订单
+            // ->whereIn('user_id', $userIds)
+            ->field('user_id, money, order_id, create_time')
+            ->select()
+            ->toArray();
+
+        // 3. 查询新订单
+        $storeOrderListRaw = Db::name("store_order")
+            ->whereIn('status', [0, 1, 2, 3])
+            // 优化: 如果用户量大，可以考虑只查相关用户的订单
+            // ->whereIn('uid', $userIds)
+            ->field('uid, pay_price, mer_id, status, order_id, create_time')
+            ->select()
+            ->toArray();
+
+        // 4. 查询已存在的贡献值记录
+        $gongXianListRaw = Db::name("user_sign_gongxian")
+            // 优化: 如果记录非常多，可以分批查询或只查相关用户的
+            // ->whereIn('uid', array_merge($userIds, array_column($userList, 'spread_uid'))) // 查询购买者和潜在推广者
+            ->field('uid, order_id, number')
+            ->select()
+            ->toArray();
+
+        // 5. 查询已存在的PV记录
+        $pvListRaw = Db::name("user_pv_log")
+            // 优化: 同上
+            // ->whereIn('uid', $userIds)
+            ->field('uid, order_id, pv')
+            ->select()
+            ->toArray();
+
+        // --- 数据预处理部分
+        $existingGongXian = [];
+        foreach ($gongXianListRaw as $gx) $existingGongXian[$gx['uid'] . '_' . $gx['order_id']] = $gx['number'];
+        unset($gongXianListRaw);
+
+        $existingPv = [];
+        foreach ($pvListRaw as $pv) $existingPv[$pv['uid'] . '_' . $pv['order_id']] = $pv['pv'];
+        unset($pvListRaw);
+
+        $userOfGoodsByUid = [];
+        foreach ($userOfGoodsListRaw as $oldOrder) $userOfGoodsByUid[$oldOrder['user_id']][] = $oldOrder;
+        unset($userOfGoodsListRaw);
+
+        $storeOrdersByUid = [];
+        foreach ($storeOrderListRaw as $order) $storeOrdersByUid[$order['uid']][] = $order;
+        unset($storeOrderListRaw);
+
+        // *** 主逻辑处理与数据收集 ***
+        $gongXianDataToInsert = []; // 优化: 合并新旧贡献插入列表
+        $pvDataToInsert = [];       // 优化: 合并新旧PV插入列表
+        $userUpdateData = [];       // 优化: 收集所有需要更新的用户数据 [uid => ['contribute'=>float, 'pv'=>float, 'per_contribute'=>float]]
+
+        // 初始化所有用户的待更新数据
+        foreach ($userList as $uid => $user) {
+            // 预先设置初始值，确保即使没有订单的用户也能被包含在后续可能的更新逻辑中（如果需要）
+            // 如果用户没有任何订单，他们的 contribute 和 pv 应该保持数据库原始值或根据业务逻辑设为0
+            // 这里我们先假设如果没有订单，他们的计算值就是0
+            $userUpdateData[$uid] = [
+                'uid' => $uid,
+                'contribute' => 0.0,
+                'pv' => 0.0,
+                'per_contribute' => 0.0,
+            ];
+            // 初始化推广者的 per_contribute 累加器
+            if (!empty($user['spread_uid'])) {
+                $spreadUid = $user['spread_uid'];
+                if (!isset($userUpdateData[$spreadUid])) {
+                    if (isset($userList[$spreadUid])) {
+                        if (!isset($userUpdateData[$spreadUid]['per_contribute'])) {
+                            $userUpdateData[$spreadUid]['per_contribute'] = 0.0; // 初始化推广者的累加
+                        }
+                    } else {
+                        // 记录或处理推广者不在当前用户列表的情况
+                        $result['errors'][] = "执行{$uid}时，没找到 推荐人 {$spreadUid}";
+                        // 可以选择跳过给这个推广者增加 per_contribute
+                    }
+
+                } else if (!isset($userUpdateData[$spreadUid]['per_contribute'])) {
+                    $userUpdateData[$spreadUid]['per_contribute'] = 0.0; // 初始化推广者的累加
+                }
+            }
+        }
+
+        // 遍历用户列表进行计算和数据收集
+        foreach ($userList as $uid => $user) {
+            $spreadUid = $user['spread_uid'];
+
+            if (isset($userOfGoodsByUid[$uid])) {
+                foreach ($userOfGoodsByUid[$uid] as $oldOrder) {
+                    switch ($oldOrder['money']) {
+                        case 1180:
+                            $totalPv = 700.0;
+                            break;
+                        case 11800:
+                            $totalPv = 7000.0;
+                            break;
+                        case 10620:
+                            $totalPv = 6300.0;
+                            break;
+                        case 2360:
+                            $totalPv = 1400.0;
+                            break;
+                        case 9440:
+                            $totalPv = 5600.0;
+                            break;
+                        default:
+                            $totalPv = round($oldOrder['money'] * 0.7, 2);
+                            break;
+                    }
+
+                    // --- 收集贡献值插入数据 ---
+                    $orderKey = $uid . '_' . $oldOrder['order_id'];
+                    if (isset($existingGongXian[$orderKey])) {
+                        $result['oldOrderExistGongXian'][] = ['uid' => $uid, 'order_id' => $oldOrder['order_id']];
+                        $userUpdateData[$uid]['contribute'] += $existingGongXian[$orderKey];
+                        if (!empty($spreadUid) && isset($userUpdateData[$spreadUid])) {
+                            if (isset($existingGongXian[$spreadUid . '_' . $oldOrder['order_id']])) {
+                                $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $oldOrder['order_id']];
+                            }
+                        }
+                    } else {
+                        if ($totalPv > 0) {
+                            $userUpdateData[$uid]['contribute'] += $totalPv;
+
+                            $settlementTimeOld = $oldOrder['create_time'] ? date('Y-m-d H:i:s', $oldOrder['create_time']) : $currentDateTime;
+                            // --- 收集贡献值插入数据 ---
+                            $gongXianBase = [
+                                "number" => $totalPv, "addtime" => $currentTime, "status" => 1,
+                                "order_type" => 1, "order_id" => $oldOrder['order_id'],
+                                "desc" => '', "surplus" => 0, "type" => 1, 'settlement_time' => $settlementTimeOld
+                            ];
+                            // 本人
+                            $gongXianDataToInsert[] = array_merge(["uid" => $uid, "mark" => "1.0系统购买会员专区商品赠送贡献值"], $gongXianBase);
+                            // 推广人
+                            if (!empty($user['spread_uid'])) {
+                                if (isset($userUpdateData[$spreadUid])) {
+                                    $userUpdateData[$spreadUid]['per_contribute'] += $totalPv;
+                                    $gongXianDataToInsert[] = array_merge(["uid" => $spreadUid, "mark" => "1.0系统推广会员专区商品赠送贡献值"], $gongXianBase);
+                                }
+                            }
+                        }
+                    }
+                    // --- 收集 PV 插入数据 ---
+                    if (isset($existingPv[$orderKey])) {
+                        $result['oldOrderExistPv'][] = ['uid' => $uid, 'order_id' => $oldOrder['order_id']];
+                        $userUpdateData[$uid]['pv'] += $existingGongXian[$orderKey];
+
+                    } else {
+                        $userUpdateData[$uid]['pv'] += $totalPv;
+                        $pvDataToInsert[] = [
+                            "uid" => $uid, "pv" => $totalPv, "addtime" => $currentTime, "status" => 1,
+                            "order_type" => 0, "order_id" => $oldOrder['order_id'],
+                            "mark" => "1.0系统购买会员专区商品赠送PV", 'settlement_time' => $settlementTimeOld
+                        ];
+                    }
+
+                }
+            } // end if isset($userOfGoodsByUid[$uid])
+
+            // --- 处理新订单 ---
+            if (isset($storeOrdersByUid[$uid])) {
+                foreach ($storeOrdersByUid[$uid] as $order) {
+                    $totalPv = 0.0;
+                    // ... (if/else logic and switch case for $totalPv calculation - same as before)
+                    if ($order['mer_id'] == 496) {
+                        switch ($order['pay_price']) {
+                            case 1180:
+                                $totalPv = 700.0;
+                                break;
+                            case 11800:
+                                $totalPv = 7000.0;
+                                break;
+                            case 10620:
+                                $totalPv = 6300.0;
+                                break;
+                            case 2360:
+                                $totalPv = 1400.0;
+                                break;
+                            case 9440:
+                                $totalPv = 5600.0;
+                                break;
+                            default:
+                                $totalPv = round($order['pay_price'] * 0.7, 2);
+                                break;
+                        }
+                    } else if ($order['status'] == 3) {
+                        $totalPv = round($order['pay_price'] * 0.7, 2);
+                    }
+                    // --- 收集贡献值插入数据 ---
+                    $orderKey = $uid . '_' . $order['order_id'];
+                    $settlementTimeNew = $order['create_time'] ?: $currentDateTime;
+                    // --- 收集贡献值插入数据 ---
+                    if (isset($existingGongXian[$orderKey])) {
+                        $result['orderExistGongXian'][] = ['uid' => $uid, 'order_id' => $order['order_id']];
+                        // 累加计算值
+                        $userUpdateData[$uid]['contribute'] += $existingGongXian[$orderKey];
+                        if (!empty($spreadUid) && isset($userUpdateData[$spreadUid])) {
+                            if (isset($existingGongXian[$spreadUid . '_' . $order['order_id']])) {
+                                $userUpdateData[$spreadUid]['per_contribute'] += $existingGongXian[$spreadUid . '_' . $order['order_id']];
+                            }
+                        }
+
+                    } else {
+                        if ($totalPv > 0) {
+                            // 累加计算值
+                            $userUpdateData[$uid]['contribute'] += $totalPv;
+                            $gongXianBase = [ // 优化: 提取公共字段
+                                "number" => $totalPv, "addtime" => $currentTime, "status" => 1,
+                                "order_type" => 1, "order_id" => $order['order_id'],
+                                "desc" => '', "surplus" => 0, "type" => 1, 'settlement_time' => $settlementTimeNew
+                            ];
+                            // 本人
+                            $gongXianDataToInsert[] = array_merge(["uid" => $uid, "mark" => "2.0系统购买商品赠送贡献值"], $gongXianBase);
+                            // 推广人
+                            if (!empty($user['spread_uid'])) {
+                                $spreadUid = $user['spread_uid'];
+                                if (isset($userUpdateData[$spreadUid])) { // 确保推广者存在
+                                    $gongXianDataToInsert[] = array_merge(["uid" => $spreadUid, "mark" => "2.0系统推广商品赠送贡献值"], $gongXianBase);
+                                    $userUpdateData[$spreadUid]['per_contribute'] += $totalPv; // 累加推广者业绩
+                                }
+                            }
+                        }
+                    }
+
+                    // --- 收集 PV 插入数据 ---
+                    if (isset($existingPv[$orderKey])) {
+                        $result['orderExistPv'][] = ['uid' => $uid, 'order_id' => $order['order_id']];
+                        $userUpdateData[$uid]['pv'] += $existingPv[$orderKey];
+                    } else {
+                        $userUpdateData[$uid]['pv'] += $totalPv;
+                        $pvDataToInsert[] = [
+                            "uid" => $uid, "pv" => $totalPv, "addtime" => $currentTime, "status" => 1,
+                            "order_type" => 0, // 确认 PV log 的 order_type 是否与贡献一致或有区分
+                            "order_id" => $order['order_id'],
+                            "mark" => "2.0系统购买商品赠送PV", // 标记调整为更通用
+                            'settlement_time' => $settlementTimeNew
+                        ];
+                    }
+                }
+            }
+            // end if isset($storeOrdersByUid[$uid])
+
+            // --- 比较计算值与原值 (移到循环外处理) ---
+            // （在此处比较并记录到 $result['contributeNot'] / $result['pvNot']）
+            // 注意：浮点数比较可能需要容差
+            $tolerance = 0.001; // 定义一个小的容差值
+            if (abs($userUpdateData[$uid]['contribute'] - (float)$user['contribute']) > $tolerance) {
+                $result['contributeNot'][] = [
+                    'uid' => $uid,
+                    'contribute_old' => (float)$user['contribute'], // 显式转换
+                    'contribute_new' => $userUpdateData[$uid]['contribute']
+                ];
+            }
+            if (abs($userUpdateData[$uid]['pv'] - (float)$user['pv']) > $tolerance) {
+                $result['pvNot'][] = [
+                    'uid' => $uid,
+                    'pv_old' => (float)$user['pv'], // 显式转换
+                    'pv_new' => $userUpdateData[$uid]['pv']
+                ];
+            }
+            // per_contribute 是累加的，不需要与旧值比较，直接更新
+
+        } // end foreach ($userList as $uid => $user)
+
+        // *** 数据库批量操作 ***
+        // 使用事务确保数据一致性
+        Db::startTrans();
+        try {
+            // --- 批量插入贡献值 ---
+            if (!empty($gongXianDataToInsert)) {
+                // 分块插入，避免单次插入过多数据 (例如一次500条)
+                $chunkedGongXian = array_chunk($gongXianDataToInsert, 500);
+                foreach ($chunkedGongXian as $chunk) {
+                    $insertedGongXianCount = Db::name('user_sign_gongxian')->insertAll($chunk);
+                    $result['insertGongXianSummary']['success'] += $insertedGongXianCount;
+                }
+
+                if ($result['insertGongXianSummary']['success'] < count($gongXianDataToInsert)) {
+                    $result['insertGongXianSummary']['failed'] = count($gongXianDataToInsert) - $result['insertGongXianSummary']['success'];
+                    // 可以考虑记录更详细的失败信息，但这比较复杂，需要知道哪些失败了
+                    $result['errors'][] = "GongXian insertion partially failed or failed completely.";
+                    // 根据业务决定是否回滚
+                    // throw new Exception("GongXian insertion failed");
+                }
+            } else {
+                $result['insertGongXianSummary']['skipped'] = true; // 标记为跳过（无数据）
+            }
+
+            // --- 批量插入PV ---
+            if (!empty($pvDataToInsert)) {
+                $chunkedPv = array_chunk($pvDataToInsert, 500);
+                foreach ($chunkedPv as $chunk) {
+                    $insertedPvCount = Db::name('user_pv_log')->insertAll($chunk);
+                    $result['insertPvSummary']['success'] += $insertedPvCount;
+                }
+                if ($result['insertPvSummary']['success'] < count($pvDataToInsert)) {
+                    $result['insertPvSummary']['failed'] = count($pvDataToInsert) - $result['insertPvSummary']['success'];
+                    $result['errors'][] = "PV Log insertion partially failed or failed completely.";
+                    // throw new Exception("PV Log insertion failed");
+                }
+            } else {
+                $result['insertPvSummary']['skipped'] = true; // 标记为跳过（无数据）
+            }
+
+            // --- 批量更新用户信息 ---
+            $usersToUpdate = [];
+            // 筛选出实际需要更新的用户数据 (值有变化或 per_contribute > 0)
+            foreach ($userUpdateData as $uid => $updateInfo) {
+                $originalUser = $userList[$uid]; // 获取原始用户信息
+                // 检查 contribute 或 pv 是否变化（使用容差），或者 per_contribute 是否需要更新
+                $needsUpdate = false;
+                if (abs($updateInfo['contribute'] - (float)$originalUser['contribute']) > $tolerance) $needsUpdate = true;
+                if (abs($updateInfo['pv'] - (float)$originalUser['pv']) > $tolerance) $needsUpdate = true;
+                // per_contribute 始终更新，因为它是在现有基础上累加的（除非业务定义不同）
+                // 如果 per_contribute 数据库设计是直接覆盖，那只有 > 0 时才需要更新
+                // 假设是覆盖更新，且只有大于0时才需要更新变动（如果一直是0则不用更新）
+                if ($updateInfo['per_contribute'] > 0.0) { // 只有当推广业绩>0时才触发更新
+                    // 这里需要确认 per_contribute 是覆盖还是累加?
+                    // 如果是数据库累加: Db::name("user")->where('uid', $uid)->inc('per_contribute', $amount)->update(); 需要单独处理
+                    // 如果是覆盖: 直接放入 saveAll
+                    // 假设是覆盖，我们只更新有变化的或per_contribute > 0 的
+                    $needsUpdate = true;
+                } else {
+                    // 如果 per_contribute 计算结果为0，且 contribute 和 pv 也未变，则不需要更新 per_contribute 字段
+                    unset($updateInfo['per_contribute']); // 移除无需更新的 per_contribute
+                    if (empty($updateInfo)) $needsUpdate = false; // 如果移除后为空，则不更新
+                }
+
+                if ($needsUpdate) {
+                    // 确保只包含需要更新的字段，并且包含主键 'uid'
+                    $finalUpdateData = ['uid' => $uid];
+                    if (isset($updateInfo['contribute'])) $finalUpdateData['contribute'] = $updateInfo['contribute'];
+                    if (isset($updateInfo['pv'])) $finalUpdateData['pv'] = $updateInfo['pv'];
+                    if (isset($updateInfo['per_contribute']) && $updateInfo['per_contribute'] > 0.0) { // 再次确认只更新大于0的推广业绩
+                        $finalUpdateData['per_contribute'] = $updateInfo['per_contribute'];
+                    }
+
+                    if (count($finalUpdateData) > 1) { // 确保除了uid还有其他字段要更新
+                        $usersToUpdate[] = $finalUpdateData;
+                    } else {
+                        $result['userUpdateSummary']['skipped']++; // 记录跳过的更新（无变化）
+                    }
+
+                } else {
+                    $result['userUpdateSummary']['skipped']++; // 记录跳过的更新（无变化）
+                }
+            }
+
+            if (!empty($usersToUpdate)) {
+                // 使用 saveAll 进行批量更新 (要求 PHP >= 7.1.8 for MySQL)
+                // saveAll 会根据主键 'uid' 更新对应记录
+                $userModel = new User();
+                $updatedCount = $userModel->saveAll($usersToUpdate); // TP6 支持 saveAll
+
+                // 注意: saveAll 返回的是成功保存或更新的 *对象集合* 或 *布尔值*，不是影响的行数。
+                // 需要检查返回类型并判断成功数量。通常返回集合时 count(集合) 是成功数。
+                // 如果是 TP5，可能需要循环 update 或构造复杂 SQL。
+                // 假设 TP6 saveAll 成功会返回包含更新后数据的集合或true，失败是false
+                if ($updatedCount !== false) {
+                    // 这里需要一种方法来确定实际更新了多少条记录。
+                    // saveAll 的返回值可能需要进一步处理。
+                    // 简单假设：如果返回不是 false，就认为请求中的都成功了（可能不准确）
+                    // 更精确的方法是 saveAll 后再查询一次确认。
+                    // 这里我们暂时认为 saveAll 返回非 false 即为大部分成功
+                    $result['userUpdateSummary']['success'] = count($usersToUpdate); // 乐观估计
+                } else {
+                    $result['userUpdateSummary']['failed'] = count($usersToUpdate); // 全部失败
+                    $result['errors'][] = "User batch update failed using saveAll.";
+                    // throw new Exception("User batch update failed");
+                }
+            }
+            // 更新统计：失败数等于总数减去成功和跳过的
+            //$result['userUpdateSummary']['failed'] = count($userList) - $result['userUpdateSummary']['success'] - $result['userUpdateSummary']['skipped'];
+
+            // 如果所有操作都成功，提交事务
+            Db::commit();
+
+        } catch
+        (\Exception $e) {
+            // 如果任何数据库操作失败，回滚事务
+            Db::rollback();
+            // 记录错误信息
+            $result['errors'][] = "Transaction failed: " . $e->getMessage();
+            // 可以根据需要将 insert/update 摘要设置为失败
+            $result['userUpdateSummary']['failed'] = count($usersToUpdate); // 假设更新失败
+            $result['insertGongXianSummary']['failed'] = count($gongXianDataToInsert); // 假设插入失败
+            $result['insertPvSummary']['failed'] = count($pvDataToInsert);      // 假设插入失败
+        }
+
+        // --- 清理/最终结果赋值 (可选) ---
+        // $result['gongXianDataOldList'] = $gongXianDataOldList; // 这些已合并到 ToInsert
+        // $result['gongXianDataList'] = $gongXianDataList;
+        // $result['pvDataOldList'] = $pvDataOldList;
+        // $result['pvDataList'] = $pvDataList;
+
+        return json($result);
 
         // 计算总业绩
         $totalPv = [];
@@ -43,7 +468,7 @@ class Taskorderguquan
                     if ($order['money'] == 2344.99) {
                         break;
                     }
-                    $totalPv[$order['user_id']] += round($order['money'] * 0.7,2);
+                    $totalPv[$order['user_id']] += round($order['money'] * 0.7, 2);
                     break;
             }
         }