|
...
|
...
|
@@ -49,7 +49,7 @@ class DevopsTask extends Command |
|
|
|
while (true){
|
|
|
|
$tasks = DevopsTaskModel::where('status', DevopsTaskModel::STATUS_PENDING)->get();
|
|
|
|
foreach ($tasks as $task){
|
|
|
|
echo "Start task " . $task->id . PHP_EOL;
|
|
|
|
echo "Start task " . $task->id;
|
|
|
|
if($task->type == DevopsTaskModel::TYPE_MYSQL){
|
|
|
|
$this->updateTable($task);
|
|
|
|
}
|
|
...
|
...
|
@@ -62,9 +62,10 @@ class DevopsTask extends Command |
|
|
|
public function updateTable($task){
|
|
|
|
$projects = Project::all();
|
|
|
|
foreach ($projects as $project){
|
|
|
|
echo "project " . $project->id;
|
|
|
|
echo "project " . $project->id . PHP_EOL;
|
|
|
|
$log = DevopsTaskLog::addLog($task->id, $project->id);
|
|
|
|
if($log->status == DevopsTaskModel::STATUS_ACTIVE){
|
|
|
|
echo 'continue' . PHP_EOL;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if(!$project->mysqlConfig){
|
|
...
|
...
|
@@ -84,7 +85,7 @@ class DevopsTask extends Command |
|
|
|
$encrypt->unlock_url($project->mysqlConfig->port),
|
|
|
|
);
|
|
|
|
}catch (\Exception $e){
|
|
|
|
$log->remark = mb_substr('数据库连接失败:' . $e->getMessage(), 500);
|
|
|
|
$log->remark = mb_substr('数据库连接失败:' . $e->getMessage(), 0, 500);
|
|
|
|
$log->status = DevopsTaskLog::STATUS_ERROR;
|
|
|
|
$log->save();
|
|
|
|
echo '-->' . $log->remark . PHP_EOL;
|
...
|
...
|
|