amp批量建站脚本

@@ -6,10 +6,16 @@ use App\Helper\Arr;
 use App\Models\Collect\CollectTask;
 use App\Models\Com\UpdateLog;
 use App\Models\Com\UpdateVisit;
+use App\Models\Devops\ServerConfig;
+use App\Models\Domain\DomainInfo;
 use App\Models\Product\Product;
+use App\Models\Project\Project;
 use App\Services\ProjectServer;
+use App\Utils\HttpUtils;
+use GuzzleHttp\Exception\GuzzleException;
 use Illuminate\Console\Command;
 use Illuminate\Support\Facades\DB;
+use Symfony\Component\Process\Process;
 
 class Temp extends Command
 {
@@ -30,17 +36,106 @@ class Temp extends Command
 
     public function handle()
     {
-        $project = ProjectServer::useProject(626);
-        if ($project) {
-            CollectTask::select(['id', 'language'])->where('status', 0)->chunk(1000, function ($query) {
+        $domain_model = new DomainInfo();
+        $server_model = new ServerConfig();
+        $project_model = new Project();
 
-                foreach ($query as $item) {
-                    $item->domain = 'lecusostreetlight.quanqiusou.cn/' . $item->language;
-                    $item->save();
+        $domain_list = $domain_model->list(['domain' => ['like', 'www.%']], 'id', ['id', 'domain', 'project_id'], 'asc');
+        foreach ($domain_list as $info) {
+            $this->output('domain:' . $info['domain'] . ',开始');
+
+            $project_info = $project_model->read(['id' => $info['project_id']], 'serve_id');
+            if ($project_info === false) {
+                $this->output('获取项目数据失败');
+                continue;
+            }
+
+            $server_info = $server_model->read(['id' => $project_info['serve_id']], ['init_domain', 'host']);
+            if ($server_info === false) {
+                $this->output('获取服务器数据失败');
+                continue;
             }
-            });
+
+            $domain_array = parse_url($info['domain']);
+            $host = $domain_array['host'] ?? $domain_array['path'];
+            $host_array = explode('.', $host);
+            if (count($host_array) <= 2) {
+                array_unshift($host_array, 'm');
+            } else {
+                $host_array[0] = 'm';
             }
-        DB::disconnect('custom_mysql');
+            $amp_domain = implode('.', $host_array);
+            if (!$this->check_cname($amp_domain, $server_info)) {
+                $this->output('AMP站点域名' . $amp_domain . '未解析至目标服务器');
+                continue;
+            }
+
+            $api_url = 'http://' . $server_info['init_domain'] . '/api/createSiteAmp';
+            $api_param = [
+                'domain' => $info['domain'],
+                'private_key' => '',
+                'cert' => ''
+            ];
+
+            try {
+                $rs = HttpUtils::get($api_url, $api_param);
+                $rs = json_decode($rs, true);
+                if (isset($rs['status']) && $rs['status'] == 200) {
+                    $this->output('创建AMP站点成功');
+                } else {
+                    $this->output($rs['message'] ?? '');
+                    continue;
+                }
+            } catch (\Exception | GuzzleException $e) {
+                errorLog('创建AMP站点', $api_param, $e);
+                $this->output('创建AMP站点失败');
+                continue;
+            }
+
+            $data = [
+                'amp_status' => 1,
+                'amp_type' => 1,
+            ];
+            $domain_model->edit($data, ['id' => $info['id']]);
+        }
+
         echo '成功' . PHP_EOL;
     }
+
+    public function check_cname($domain, $server_info)
+    {
+        $checkA = false;
+        $checkCname = false;
+
+        $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['host']) !== 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['init_domain']) !== false);
+                if ($checkCname) {
+                    return $domain;
+                }
+            }
+        }
+        return false;
+    }
+
+    public function output($msg)
+    {
+        echo $msg . PHP_EOL;
+    }
 }

@@ -42,7 +42,7 @@ class HttpUtils
     public static function get($url, $data, $headers = [])
     {
         LogUtils::info("HttpUtils-GET请求URL:" . $url);
-        $response = Http::timeout(20)->withHeaders($headers)->get($url, $data);
+        $response = Http::timeout(60)->withHeaders($headers)->get($url, $data);
         self::checkSuccess($response);
         return $response->getBody()->getContents();
     }
@@ -50,7 +50,7 @@ class HttpUtils
     public static function post($url, $data, $headers = [])
     {
         LogUtils::info("HttpUtils-POST请求URL:" . $url);
-        $response = Http::timeout(20)->withHeaders($headers)->post($url, $data);
+        $response = Http::timeout(60)->withHeaders($headers)->post($url, $data);
         self::checkSuccess($response);
         return $response->getBody()->getContents();
     }