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())