周海龙 / globalso · 提交

转到一个项目

作者 刘锟
提交 d98ebd15a5d830226da875df6910b96e1d11e630 2 个父辈 6d99b166 cff7dd7c

合并分支 'akun' 到 'master' 

Akun



查看合并请求 !756
内嵌 并排对比
正在显示 2 个修改的文件 包含 113 行增加 和 14 行删除
... ... @@ -2,29 +2,124 @@
namespace App\Console\Commands\Domain;
use App\Models\Com\Notify;
use App\Models\Devops\ServersIp;
use App\Models\Domain\DomainCreateTask;
use App\Models\Domain\DomainInfo;
use App\Models\Project\Project;
use App\Models\Project\ProjectServerBackup;
use Illuminate\Console\Command;
use Symfony\Component\Process\Process;
class EmergencyRelieve extends Command
{
protected $signature = 'emergency_relieve';
protected $signature = 'emergency_relieve {server_id}';
protected $description = '危机解除，恢复项目服务器';
public function handle()
{
$backup_list = ProjectServerBackup::where('status', ProjectServerBackup::STATUS_NO)->get();
//需要恢复的服务器
$server_id = $this->argument('server_id');
//获取所有需要恢复的项目
$backup_model = new ProjectServerBackup();
$backup_list = $backup_model->where('server_id', $server_id)->where('status', ProjectServerBackup::STATUS_NO)->get();
$project_model = new Project();
if ($backup_list->count() > 0) {
foreach ($backup_list as $item) {
$project_model->edit(['serve_id' => $item->serve_id], ['id' => $item->project_id]);
$item->status = ProjectServerBackup::STATUS_YES;
$item->save();
$project_model = new Project();
$domain_model = new DomainInfo();
$create_model = new DomainCreateTask();
$notify_model = new Notify();
$server_ip_model = new ServersIp();
foreach ($backup_list as $value) {
$domain_info = $domain_model->read(['project_id' => $value->project_id, 'status' => 1], ['id', 'domain']);
if (!$domain_info) {
//过滤未绑定正式域名的项目
continue;
}
//判断域名是否已经解析到目标服务器
$target_server = $server_ip_model->select(['id', 'ip', 'domain'])->where('id', $value->server_ip_id)->first()->toArray();
if (!$this->check_cname($domain_info['domain'], $target_server)) {
$this->output($domain_info['domain'] . ' | 未解析到目标服务器');
continue;
}
//创建目标服务器建站任务
$map_create = [
'type' => DomainCreateTask::TYPE_MAIN,
'server_id' => $value->server_id,
'project_id' => $value->project_id,
'domain_id' => $domain_info['id'],
'status' => DomainCreateTask::STATUS_UN,
];
$task_info = $create_model->read($map_create, ['id']);
if (!$task_info) {
$create_model->add($map_create);
}
//创建目标服务器站点页面生成任务
$map_notify = [
'type' => Notify::TYPE_MASTER,
'server_id' => $value->server_id,
'project_id' => $value->project_id,
'status' => Notify::STATUS_INIT,
'route' => Notify::ROUTE_ALL,
];
$notify_info = $notify_model->read($map_notify);
if (!$notify_info) {
$map_notify['data'] = json_encode(['domain' => $domain_info['domain'], 'url' => [], 'language' => []]);
$map_notify['sort'] = 10;
$notify_model->add($map_notify);
}
//更改项目服务器
$project_model->edit(['serve_id' => $value->server_ip_id], ['id' => $value->project_id]);
//更改恢复状态
$value->status = ProjectServerBackup::STATUS_YES;
$value->save();
$this->output('项目ID：' . $item->project_id . '，恢复成功');
$this->output('项目ID：' . $value->project_id . ' | success');
}
}
}
/**
* 验证是否cname或者A记录解析到目标服务器
* @param $domain
* @param $server_info
* @return mixed
* @author zbj
* @date 2023/11/13
*/
public function check_cname($domain, $server_info)
{
$process = new Process(['nslookup', '-qt=a', $domain]);
$process->run();
$output = explode(PHP_EOL, $process->getOutput());
foreach ($output as $line) {
if ($line) {
$checkA = strpos($line, $server_info['ip']) !== false;
if ($checkA) {
return $domain;
}
}
}
//是否cname
$process = new Process(['nslookup', '-qt=cname', $domain]);
$process->run();
$output = explode(PHP_EOL, $process->getOutput());
foreach ($output as $line) {
if ($line) {
$checkCname = (strpos($line, $server_info['domain']) !== false);
if ($checkCname) {
return $domain;
}
}
}
return false;
}
/**
... ...
... ... @@ -13,18 +13,19 @@ use Symfony\Component\Process\Process;
class EmergencyRenewSite extends Command
{
protected $signature = 'emergency_renew_site';
protected $signature = 'emergency_renew_site {server_id}';
protected $description = '紧急重建站点';
public function handle()
{
//目标服务器
$target_server_id = 1;
$target_server = ServersIp::select(['id', 'ip', 'domain'])->where('servers_id', $target_server_id)->first()->toArray();
$server_ip_model = new ServersIp();
$target_server = $server_ip_model->select(['id', 'ip', 'domain'])->where('servers_id', $target_server_id)->first()->toArray();
//受灾服务器
$server_ids = [9, 13];
$server_ip_ids = ServersIp::whereIn('servers_id', $server_ids)->get()->pluck('id')->toArray();
$server_id = $this->argument('server_id');;
$server_ip_ids = $server_ip_model->where('servers_id', $server_id)->get()->pluck('id')->toArray();
//获取所有受灾项目
$project_list = Project::select(['id', 'serve_id', 'title'])->whereIn('serve_id', $server_ip_ids)->get();
... ... @@ -32,6 +33,7 @@ class EmergencyRenewSite extends Command
$create_model = new DomainCreateTask();
$notify_model = new Notify();
$backup_model = new ProjectServerBackup();
if ($project_list->count() > 0) {
foreach ($project_list as $value) {
$domain_info = $domain_model->read(['project_id' => $value->id, 'status' => 1], ['id', 'domain']);
if (!$domain_info) {
... ... @@ -42,6 +44,7 @@ class EmergencyRenewSite extends Command
//判断域名是否已经解析到目标服务器
if (!$this->check_cname($domain_info['domain'], $target_server)) {
$this->output($domain_info['domain'] . ' | 未解析到目标服务器');
continue;
}
//获取站点其他域名
... ... @@ -87,9 +90,9 @@ class EmergencyRenewSite extends Command
//备份项目原始服务器
$backup_info = $backup_model->read(['project_id' => $value->id, 'status' => ProjectServerBackup::STATUS_NO], ['id']);
if ($backup_info) {
$backup_model->edit(['serve_id' => $value->serve_id], ['id' => $backup_info['id']]);
$backup_model->edit(['server_id' => $server_id, 'server_ip_id' => $value->serve_id], ['id' => $backup_info['id']]);
} else {
$backup_model->add(['project_id' => $value->id, 'serve_id' => $value->serve_id]);
$backup_model->add(['project_id' => $value->id, 'server_id' => $server_id, 'server_ip_id' => $value->serve_id]);
}
//更改项目服务器
... ... @@ -99,6 +102,7 @@ class EmergencyRenewSite extends Command
$this->output($domain_info['domain'] . ' | success');
}
}
}
/**
* 验证是否cname或者A记录解析到目标服务器
... ...