|
...
|
...
|
@@ -13,7 +13,6 @@ use Illuminate\Support\Facades\DB; |
|
|
|
use Illuminate\Support\Facades\Redis;
|
|
|
|
use Illuminate\Support\Facades\Schema;
|
|
|
|
use Illuminate\Support\Str;
|
|
|
|
|
|
|
|
/**
|
|
|
|
*
|
|
|
|
* Class SyncSubmitTask
|
|
...
|
...
|
@@ -30,19 +29,24 @@ class SyncSubmitTaskDistribution extends Command |
|
|
|
public function handle()
|
|
|
|
{
|
|
|
|
while (true) {
|
|
|
|
$len = Redis::llen('sync_submit_task');
|
|
|
|
if (!$len) {
|
|
|
|
$max_id = SyncSubmitTaskModel::orderBy('id', 'desc')->value('id');
|
|
|
|
if ($max_id > 2000000) {
|
|
|
|
$this->backup();
|
|
|
|
} else {
|
|
|
|
$tasks = SyncSubmitTaskModel::where('status', 0)->limit(100)->get();
|
|
|
|
foreach ($tasks as $task) {
|
|
|
|
$task->status = 3;
|
|
|
|
$task->save();
|
|
|
|
Redis::lpush('sync_submit_task', $task->id);
|
|
|
|
try {
|
|
|
|
$len = Redis::llen('sync_submit_task');
|
|
|
|
if (!$len) {
|
|
|
|
$max_id = SyncSubmitTaskModel::orderBy('id', 'desc')->value('id');
|
|
|
|
if ($max_id > 2000000) {
|
|
|
|
$this->backup();
|
|
|
|
} else {
|
|
|
|
$tasks = SyncSubmitTaskModel::where('status', 0)->limit(100)->get();
|
|
|
|
foreach ($tasks as $task) {
|
|
|
|
$task->status = 3;
|
|
|
|
$task->save();
|
|
|
|
Redis::lpush('sync_submit_task', $task->id);
|
|
|
|
$this->output('分发:' . $task->id);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}catch (\Exception $e){
|
|
|
|
$this->output('异常:' . $e->getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
...
|
...
|
|