From df95b8a465bae8496e8c8c5f2248ec31b34f31a5 Mon Sep 17 00:00:00 2001 From: denghy Date: Fri, 8 Feb 2019 08:06:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Domains/Real/Commands/Sync/MongoSync.php | 4 ++-- app/Domains/Virtual/Commands/Sync/CardSync.php | 4 ++-- app/Domains/Virtual/Commands/Sync/LogSync.php | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/app/Domains/Real/Commands/Sync/MongoSync.php b/app/Domains/Real/Commands/Sync/MongoSync.php index b3b5f391..8d2f4279 100644 --- a/app/Domains/Real/Commands/Sync/MongoSync.php +++ b/app/Domains/Real/Commands/Sync/MongoSync.php @@ -43,11 +43,11 @@ class MongoSync extends Command while ($total) { $page++; + $jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime)); + if ($page * $this->limit >= $total) { break; } - - $jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime)); } $total && MongoSyncJob::withChain($jobs->toArray()) diff --git a/app/Domains/Virtual/Commands/Sync/CardSync.php b/app/Domains/Virtual/Commands/Sync/CardSync.php index 69646419..673772f7 100644 --- a/app/Domains/Virtual/Commands/Sync/CardSync.php +++ b/app/Domains/Virtual/Commands/Sync/CardSync.php @@ -45,11 +45,11 @@ class CardSync extends Command while ($total) { $page++; + $jobs->push(new CardSyncJob($page, $this->limit, $maxId)); + if ($page * $this->limit >= $total) { break; } - - $jobs->push(new CardSyncJob($page, $this->limit, $maxId)); } $total && CardSyncJob::withChain($jobs->toArray()) diff --git a/app/Domains/Virtual/Commands/Sync/LogSync.php b/app/Domains/Virtual/Commands/Sync/LogSync.php index 745160dc..d04f904d 100644 --- a/app/Domains/Virtual/Commands/Sync/LogSync.php +++ b/app/Domains/Virtual/Commands/Sync/LogSync.php @@ -51,11 +51,11 @@ class LogSync extends Command while ($total) { $page++; + $jobs->push(new LogSyncJob($page, $this->limit, $maxId)); + if ($page * $this->limit >= $total) { break; } - - $jobs->push(new LogSyncJob($page, $this->limit, $maxId)); } $total && LogSyncJob::withChain($jobs->toArray())