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