hydrz/vd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

allOnQueue

Browse Source
This commit is contained in:
邓皓元 2019-01-16 13:40:47 +08:00
parent d4bb8305b2
commit eca9f1d9be
3 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/Domains/Real/Commands/Sync/MongoSync.php
View File

@ -47,13 +47,15 @@ class MongoSync extends Command
break;
}
$jobs->push((new MongoSyncJob($page, $this->limit, $utcDateTime))->onQueue('sync'));
$jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime));
}
app(ConfigService::class)->set(self::CURSOR_KEY, intval($nextMicrotime));
if ($total) {
MongoSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $utcDateTime);
}
$total && dispatch($job);
$total && MongoSyncJob::withChain($jobs->toArray())
->dispatch(1, $this->limit, $utcDateTime)
->allOnQueue('sync');
}
}

6
app/Domains/Virtual/Commands/Sync/CardSync.php
View File

@ -50,11 +50,13 @@ class CardSync extends Command
break;
}
$jobs->push((new CardSyncJob($page, $this->limit, $maxId))->onQueue('sync'));
$jobs->push(new CardSyncJob($page, $this->limit, $maxId));
}
$nextId && app(ConfigService::class)->set(self::CURSOR_KEY, $nextId);
$total && CardSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId);
$total && CardSyncJob::withChain($jobs->toArray())
->dispatch(1, $this->limit, $maxId)
->allOnQueue('sync');
}
}

6
app/Domains/Virtual/Commands/Sync/LogSync.php
View File

@ -56,11 +56,13 @@ class LogSync extends Command
break;
}
$jobs->push((new LogSyncJob($page, $this->limit, $maxId))->onQueue('sync'));
$jobs->push(new LogSyncJob($page, $this->limit, $maxId));
}
$nextId && app(ConfigService::class)->set(self::CURSOR_KEY, $nextId);
$total && LogSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId);
$total && LogSyncJob::withChain($jobs->toArray())
->dispatch(1, $this->limit, $maxId)
->allOnQueue('sync');
}
}