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

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

@@ -17,6 +17,7 @@ use app\utils\TimeUtil;
 use http\Exception;
 use think\facade\Db;
 use think\facade\Log;
+use think\Request;
 use function GuzzleHttp\Promise\iter_for;
 
 /**
@@ -216,7 +217,7 @@ class DaTaoKe
 
 
     //订单查询接口(20分钟一个时间段)
-    public function getOrder()
+    public function getOrder(Request $request)
     {
         // // 立即返回响应，断开客户端连接
         // header('Content-Length: 0');
@@ -238,6 +239,7 @@ class DaTaoKe
         // 从这里开始，客户端已经断开，脚本可以长时间运行
         ignore_user_abort(true); // 忽略用户中断
         set_time_limit(0); // 取消时间限制
+        $scene = $request->get('scene', 1);
 
         try {
             $url = 'https://openapi.dataoke.com/api/tb-service/get-order-details';
@@ -248,8 +250,10 @@ class DaTaoKe
             $orders = array_merge($orders, $recentOrders);
 
             // 场景2：分批次查询历史订单（避免时间范围过大） 平时只需要开场景1 场景二主要目的是 指定时间内（比如10天内） 有漏掉的订单，可以开启执行一次；注意执行一次后再给关闭，防止资源浪费
-            // $refundOrders = $this->queryOrdersByBatch($url);
-            // $orders = array_merge($orders, $refundOrders);
+            if ($scene == 2) {
+                $refundOrders = $this->queryOrdersByBatch($url);
+                $orders = array_merge($orders, $refundOrders);
+            }
 
             if ($orders) {
                 // 去重处理