同步
This commit is contained in:
parent
bd5ed09cb6
commit
df95b8a465
@ -43,11 +43,11 @@ class MongoSync extends Command
|
|||||||
while ($total) {
|
while ($total) {
|
||||||
$page++;
|
$page++;
|
||||||
|
|
||||||
|
$jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime));
|
||||||
|
|
||||||
if ($page * $this->limit >= $total) {
|
if ($page * $this->limit >= $total) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
$jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
$total && MongoSyncJob::withChain($jobs->toArray())
|
$total && MongoSyncJob::withChain($jobs->toArray())
|
||||||
|
@ -45,11 +45,11 @@ class CardSync extends Command
|
|||||||
while ($total) {
|
while ($total) {
|
||||||
$page++;
|
$page++;
|
||||||
|
|
||||||
|
$jobs->push(new CardSyncJob($page, $this->limit, $maxId));
|
||||||
|
|
||||||
if ($page * $this->limit >= $total) {
|
if ($page * $this->limit >= $total) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
$jobs->push(new CardSyncJob($page, $this->limit, $maxId));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
$total && CardSyncJob::withChain($jobs->toArray())
|
$total && CardSyncJob::withChain($jobs->toArray())
|
||||||
|
@ -51,11 +51,11 @@ class LogSync extends Command
|
|||||||
while ($total) {
|
while ($total) {
|
||||||
$page++;
|
$page++;
|
||||||
|
|
||||||
|
$jobs->push(new LogSyncJob($page, $this->limit, $maxId));
|
||||||
|
|
||||||
if ($page * $this->limit >= $total) {
|
if ($page * $this->limit >= $total) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
$jobs->push(new LogSyncJob($page, $this->limit, $maxId));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
$total && LogSyncJob::withChain($jobs->toArray())
|
$total && LogSyncJob::withChain($jobs->toArray())
|
||||||
|
Loading…
x
Reference in New Issue
Block a user