|
|
|
<?php
|
|
|
|
|
|
|
|
namespace App\Console\Commands\Sync;
|
|
|
|
|
|
|
|
|
|
|
|
use App\Exceptions\InquiryFilterException;
|
|
|
|
use App\Models\Project\Project;
|
|
|
|
use App\Models\SyncSubmitTask\SyncSubmitTask as SyncSubmitTaskModel;
|
|
|
|
use App\Services\SyncSubmitTaskService;
|
|
|
|
use Illuminate\Console\Command;
|
|
|
|
use Illuminate\Support\Facades\Cache;
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
use Illuminate\Support\Facades\Redis;
|
|
|
|
use Illuminate\Support\Facades\Schema;
|
|
|
|
use Illuminate\Support\Str;
|
|
|
|
|
|
|
|
/**
|
|
|
|
*
|
|
|
|
* Class SyncSubmitTask
|
|
|
|
* @package App\Console\Commands
|
|
|
|
* @author zbj
|
|
|
|
* @date 2023/11/28
|
|
|
|
*/
|
|
|
|
class SyncSubmitTaskDistribution extends Command
|
|
|
|
{
|
|
|
|
|
|
|
|
protected $signature = 'sync_submit_task_distribution';
|
|
|
|
protected $description = '询盘、访问异步任务分发';
|
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sleep(3);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 输出处理日志
|
|
|
|
*/
|
|
|
|
public function output($message): bool
|
|
|
|
{
|
|
|
|
echo date('Y-m-d H:i:s') . ' | ' . $message . PHP_EOL;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 备份数据
|
|
|
|
* @author zbj
|
|
|
|
* @date 2024/1/23
|
|
|
|
*/
|
|
|
|
public function backup()
|
|
|
|
{
|
|
|
|
DB::beginTransaction();
|
|
|
|
try {
|
|
|
|
$table = (new SyncSubmitTaskModel())->getTable();
|
|
|
|
$new_table = $table . '_backup_' . date('Ymd');
|
|
|
|
|
|
|
|
//重命名当前表
|
|
|
|
Schema::rename($table, $new_table);
|
|
|
|
//克隆表数据
|
|
|
|
DB::statement('CREATE TABLE ' . $table . ' LIKE ' . $new_table);
|
|
|
|
|
|
|
|
//未入队的写到新表
|
|
|
|
$list = DB::table($new_table)->where('status', 0)->get();
|
|
|
|
$data = [];
|
|
|
|
foreach ($list as $task) {
|
|
|
|
$data[] = [
|
|
|
|
'type' => $task->type,
|
|
|
|
'data' => json_encode($task->data),
|
|
|
|
'created_at' => $task['created_at'],
|
|
|
|
'updated_at' => $task['updated_at'],
|
|
|
|
];
|
|
|
|
}
|
|
|
|
$data && SyncSubmitTaskModel::insert($data);
|
|
|
|
|
|
|
|
DB::commit();
|
|
|
|
|
|
|
|
$this->output('数据备份成功');
|
|
|
|
} catch (\Exception $e) {
|
|
|
|
$this->output('数据备份失败' . $e->getMessage());
|
|
|
|
DB::rollBack();
|
|
|
|
}
|
|
|
|
return $new_table ?? '';
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|
