快递同步修改

app/Services/OrderPackageReceivedSyncService.php

@@ -97,7 +97,7 @@ class OrderPackageReceivedSyncService
             });
         $query = $query->where('sent_at', '>=', now()->subDays(20))
             ->whereNull('received_at');
-        $query->chunk(200, function ($orderPackages) {
+        $query->chunkById(200, function ($orderPackages) {
             LogService::log(OrderPackageReceivedSyncService::class, "同步快递信息定时方法-阿里公用接口", json_encode($orderPackages));
             foreach ($orderPackages as $orderPackage){
                 if ($orderPackage && $orderPackage->logistic_number)LogisticAliJiSuSync::dispatch($orderPackage->logistic_number);
@@ -116,7 +116,7 @@ class OrderPackageReceivedSyncService
             });
         $query = $query->where('created_at', '>=', now()->subDays(20))
             ->whereNull('received_at')->where('logistic_number','like','JD%');
-        $query->chunk(200, function ($orderPackages) {
+        $query->chunkById(200, function ($orderPackages) {
             LogService::log(OrderPackageReceivedSyncService::class, "同步快递信息定时方法-JD", json_encode($orderPackages));
             foreach ($orderPackages as $orderPackage){
                 if ($orderPackage && $orderPackage->logistic_number)LogisticAliJiSuSync::dispatch($orderPackage->logistic_number);
@@ -134,7 +134,7 @@ class OrderPackageReceivedSyncService
             });
         $query = $query->where('sent_at', '>=', now()->subDays(20))
             ->whereNull('received_at');
-        $query->chunk(1000, function ($orderPackages) {
+        $query->chunkById(1000, function ($orderPackages) {
             LogService::log(OrderPackageReceivedSyncService::class, "同步快递信息定时方法-YTO", json_encode($orderPackages));
             foreach ($orderPackages as $orderPackage){
                 if ($orderPackage && $orderPackage->logistic_number)LogisticYTOSync::dispatch($orderPackage->logistic_number);