第三方-淘宝客-更换接入应用

app/controller/api/store/product/DaTaoKe.php

@@ -13,6 +13,7 @@ use app\common\repositories\store\product\ProductRepository;
 use app\common\repositories\user\UserThirdRepository;
 use app\model\common\TbOrderModel;
 use app\model\common\UserThirdModel;
+use app\utils\TimeUtil;
 use http\Exception;
 use think\facade\Db;
 use think\facade\Log;
@@ -217,47 +218,231 @@ class DaTaoKe
     //订单查询接口(20分钟一个时间段)
     public function getOrder()
     {
+        // // 立即返回响应，断开客户端连接
+        // header('Content-Length: 0');
+        // header('Connection: close');
+        // ob_end_clean();
+        // ob_start();
+        // echo 'Request accepted'; // 可选的初始响应
+        //
+        // // 获取内容长度并发送头部
+        // header('Content-Length: ' . ob_get_length());
+        // ob_end_flush();
+        // flush();
+        //
+        // // 如果是FastCGI，还需要额外的刷新
+        // if (function_exists('fastcgi_finish_request')) {
+        //     fastcgi_finish_request();
+        // }
+
+        // 从这里开始，客户端已经断开，脚本可以长时间运行
+        ignore_user_abort(true); // 忽略用户中断
+        set_time_limit(0); // 取消时间限制
+
         try {
-            $startTime = date("Y-m-d H:i:00", strtotime("-50 minutes"));
-            $endTime = date("Y-m-d H:i:00");
             $url = 'https://openapi.dataoke.com/api/tb-service/get-order-details';
-            $queryTypes = [1, 2, 3];//1：按照订单淘客创建时间查询，2:按照订单淘客付款时间查询，3:按照订单淘客结算时间查询
             $orders = [];
-            foreach ($queryTypes as $queryType) {
-                $queryData = [
-                    'appKey' => self::$appKey,
-                    'version' => 'v1.0.0',
-                    'queryType' => $queryType,
-                    'pageSize' => 100,
-                    'startTime' => $startTime,
-                    'endTime' => $endTime,
-                    //1:常规订单，2:渠道订单，3:会员运营订单 默认为1
-                    'orderScene' => 2,
-                    'tkStatus' => 3
-                ];
-                $queryData['sign'] = self::makeSign($queryData, self::$appSecret);
-                $fullUrl = "{$url}?" . http_build_query($queryData);
-                $response = self::sendCurl($fullUrl);
-                $isError = $response['data']['error_response'] ?? '';
-                if ($isError) {//查询订单出错
-                    return app('json')->fail("拉取淘宝客订单出错", $response);
-                }
-                $responseOrders = $response['data']['results']['publisher_order_dto'] ?? [];
-                if ($responseOrders) {
-                    $orders = array_merge($orders, $responseOrders);
-                }
-            }
+
+            // 场景1：实时同步最近20分钟内有更新的订单
+            // $recentOrders = $this->queryRecentOrders($url);
+            // $orders = array_merge($orders, $recentOrders);
+
+            // 场景2：分批次查询历史订单（避免时间范围过大）
+            $refundOrders = $this->queryOrdersByBatch($url);
+            $orders = array_merge($orders, $refundOrders);
+
             if ($orders) {
-                //格式化拉取到的订单列表
-                $formatLists = self::formatOrderList($orders);
-                //创建/更新淘宝订单
+                // 去重处理
+                $uniqueOrders = $this->removeDuplicateOrders($orders);
+
+                // 格式化拉取到的订单列表
+                $formatLists = self::formatOrderList($uniqueOrders);
+                // 创建/更新淘宝订单
                 self::operateOrder($formatLists);
+
+                Log::info("订单处理完成". json_encode([
+                    '总订单数' => count($orders),
+                    '去重后订单数' => count($uniqueOrders),
+                    '处理时间' => date('Y-m-d H:i:s')
+                ], JSON_UNESCAPED_UNICODE));
+            } else {
+                Log::info("未获取到新订单");
             }
+
             return app('json')->success("拉取并处理淘宝客订单成功");
+
         } catch (\Throwable $throwable) {
-            return app('json')->fail("拉取并处理淘宝客订单出错{$throwable->getMessage()}");
+            Log::error("拉取订单异常". json_encode([
+                '错误信息' => $throwable->getMessage(),
+                '堆栈' => $throwable->getTraceAsString()
+            ], JSON_UNESCAPED_UNICODE));
+            return app('json')->fail("拉取并处理淘宝客订单出错: {$throwable->getMessage()}");
+        }
+
+        // try {
+        //     $startTime = date("Y-m-d H:i:00", strtotime("-50 minutes"));
+        //     $endTime = date("Y-m-d H:i:00");
+        //     $url = 'https://openapi.dataoke.com/api/tb-service/get-order-details';
+        //     $queryTypes = [1, 2, 3];//1：按照订单淘客创建时间查询，2:按照订单淘客付款时间查询，3:按照订单淘客结算时间查询
+        //     $orders = [];
+        //     foreach ($queryTypes as $queryType) {
+        //         $queryData = [
+        //             'appKey' => self::$appKey,
+        //             'version' => 'v1.0.0',
+        //             'queryType' => $queryType,
+        //             'pageSize' => 100,
+        //             'startTime' => $startTime,
+        //             'endTime' => $endTime,
+        //             //1:常规订单，2:渠道订单，3:会员运营订单 默认为1
+        //             'orderScene' => 2,
+        //             'tkStatus' => 3
+        //         ];
+        //         $queryData['sign'] = self::makeSign($queryData, self::$appSecret);
+        //         $fullUrl = "{$url}?" . http_build_query($queryData);
+        //         $response = self::sendCurl($fullUrl);
+        //         $isError = $response['data']['error_response'] ?? '';
+        //         if ($isError) {//查询订单出错
+        //             return app('json')->fail("拉取淘宝客订单出错", $response);
+        //         }
+        //         $responseOrders = $response['data']['results']['publisher_order_dto'] ?? [];
+        //         if ($responseOrders) {
+        //             $orders = array_merge($orders, $responseOrders);
+        //         }
+        //     }
+        //     if ($orders) {
+        //         //格式化拉取到的订单列表
+        //         $formatLists = self::formatOrderList($orders);
+        //         //创建/更新淘宝订单
+        //         self::operateOrder($formatLists);
+        //     }
+        //     return app('json')->success("拉取并处理淘宝客订单成功");
+        // } catch (\Throwable $throwable) {
+        //     return app('json')->fail("拉取并处理淘宝客订单出错{$throwable->getMessage()}");
+        // }
+
+    }
+
+    /**
+     * 查询最近20分钟内有更新的订单
+     */
+    private function queryRecentOrders($url)
+    {
+        $endTime = date("Y-m-d H:i:00");
+        $startTime = date("Y-m-d H:i:00", strtotime("-20 minutes"));
+
+        $queryData = [
+            'appKey' => self::$appKey,
+            'version' => 'v1.0.0',
+            'queryType' => 4, // 按照订单更新时间查询
+            'pageSize' => 100,
+            'startTime' => $startTime,
+            'endTime' => $endTime,
+            'orderScene' => 2,
+        ];
+
+        $queryData['sign'] = self::makeSign($queryData, self::$appSecret);
+        $fullUrl = "{$url}?" . http_build_query($queryData);
+
+        Log::info("查询最近订单". json_encode(['时间范围' => "{$startTime} 至 {$endTime}"], JSON_UNESCAPED_UNICODE));
+
+        $response = self::sendCurl($fullUrl);
+        $isError = $response['data']['error_response'] ?? '';
+
+        if ($isError) {
+            Log::error("查询最近订单错误". json_encode(['错误' => $isError], JSON_UNESCAPED_UNICODE));
+            return [];
+        }
+
+        return $response['data']['results']['publisher_order_dto'] ?? [];
+    }
+
+    /**
+     * 分批查询退款订单
+     */
+    private function queryOrdersByBatch($url): array
+    {
+        $allRefundOrders = [];
+
+        // 定义查询的时间段 大促期间 只能查20分钟的
+        $batchIntervals = TimeUtil::generateTimeIntervals(
+            date("Y-m-d H:i:00", strtotime("-1 days")), // 开始时间：10天前
+            date("Y-m-d H:i:00"),   // 结束时间 当前
+            20
+        );
+
+        foreach ($batchIntervals as $interval) {
+            $orders = $this->queryOrdersInInterval($url, $interval['start'], $interval['end']);
+            $allRefundOrders = array_merge($allRefundOrders, $orders);
+
+            // 添加延迟，避免请求过于频繁
+            // usleep(5000); // 0.5秒延迟
+        }
+
+        Log::info("分批查询退款订单完成". json_encode([
+            '时间段数量' => count($batchIntervals),
+            '退款订单数' => count($allRefundOrders)
+        ], JSON_UNESCAPED_UNICODE));
+
+        return $allRefundOrders;
+    }
+
+    /**
+     * 在指定时间区间内查询退款订单
+     */
+    private function queryOrdersInInterval($url, $startTime, $endTime)
+    {
+        $queryData = [
+            'appKey' => self::$appKey,
+            'version' => 'v1.0.0',
+            'queryType' => 2, // 按照 付款时间查询
+            'pageSize' => 100,
+            'startTime' => $startTime,
+            'endTime' => $endTime,
+            'orderScene' => 2,
+            // 'tkStatus' => 13
+        ];
+
+        $queryData['sign'] = self::makeSign($queryData, self::$appSecret);
+        $fullUrl = "{$url}?" . http_build_query($queryData);
+
+        Log::debug("查询订单时间段". json_encode([
+            '开始时间' => $startTime,
+            '结束时间' => $endTime,
+            '时间差(分钟)' => round((strtotime($endTime) - strtotime($startTime)) / 60, 2)
+        ], JSON_UNESCAPED_UNICODE));
+
+        $response = self::sendCurl($fullUrl);
+        Log::debug("查询结果". json_encode($response, JSON_UNESCAPED_UNICODE));
+        $isError = $response['data']['error_response'] ?? '';
+
+        if ($isError) {
+            Log::warning("查询订单出错". json_encode([
+                '时间段' => "{$startTime} 至 {$endTime}",
+                '错误' => $isError
+            ], JSON_UNESCAPED_UNICODE));
+            return [];
+        }
+
+        return $response['data']['results']['publisher_order_dto'] ?? [];
+    }
+
+    /**
+     * 订单去重
+     */
+    private function removeDuplicateOrders($orders): array
+    {
+        $uniqueOrders = [];
+        $orderIds = [];
+
+        foreach ($orders as $order) {
+            $orderId = $order['trade_parent_id'] ?? '';
+            if ($orderId && !in_array($orderId, $orderIds)) {
+                $uniqueOrders[] = $order;
+                $orderIds[] = $orderId;
+            }
         }
 
+        return $uniqueOrders;
     }
 
     //订单查询接口(20分钟一个时间段)

app/utils/TimeUtil.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace app\utils;
+
+class TimeUtil
+{
+    /**
+     * 生成时间间隔数组
+     */
+    public static function generateTimeIntervals($startTime, $endTime, $intervalMinutes = 20): array
+    {
+        $intervals = [];
+        $currentStart = strtotime($startTime);
+        $endTimestamp = strtotime($endTime);
+
+        while ($currentStart < $endTimestamp) {
+            $currentEnd = $currentStart + ($intervalMinutes * 60);
+
+            // 确保不超过结束时间
+            if ($currentEnd > $endTimestamp) {
+                $currentEnd = $endTimestamp;
+            }
+
+            $intervals[] = [
+                'start' => date("Y-m-d H:i:00", $currentStart),
+                'end' => date("Y-m-d H:i:00", $currentEnd)
+            ];
+
+            $currentStart = $currentEnd;
+
+            // 如果已经到达结束时间，退出循环
+            if ($currentStart >= $endTimestamp) {
+                break;
+            }
+        }
+
+        return $intervals;
+    }
+
+}