update

@@ -9,10 +9,15 @@
 
 
 namespace App\Console\Commands\Ai;
 namespace App\Console\Commands\Ai;
 
 
+use App\Helper\Arr;
 use App\Models\Ai\AiBlog;
 use App\Models\Ai\AiBlog;
 use App\Models\Ai\AiBlogAuthor;
 use App\Models\Ai\AiBlogAuthor;
 use App\Models\Ai\AiBlogList;
 use App\Models\Ai\AiBlogList;
+use App\Models\Com\Notify;
+use App\Models\Devops\ServerConfig;
+use App\Models\Devops\ServersIp;
 use App\Models\Domain\DomainInfo;
 use App\Models\Domain\DomainInfo;
+use App\Models\Project\Project;
 use App\Models\Project\ProjectAiSetting;
 use App\Models\Project\ProjectAiSetting;
 use App\Models\RouteMap\RouteMap;
 use App\Models\RouteMap\RouteMap;
 use App\Services\AiBlogService;
 use App\Services\AiBlogService;
@@ -212,9 +217,41 @@ class AiBlogTask extends Command
         //获取项目域名
         //获取项目域名
         $domain = $domainModel->getProjectIdDomain($project_id);
         $domain = $domainModel->getProjectIdDomain($project_id);
         if(!empty($domain)){
         if(!empty($domain)){
-            $url = $domain.'api/update_page/?project_id='.$project_id.'&route=7';
-            $res = http_get($url);
-            echo '返回数据：'.json_encode($res,true).PHP_EOL;
+            //判断是否是自建站服务器，如果是，不请求C端接口，数据直接入库
+            $project_model = new Project();
+            $project_info = $project_model->read(['id'=>$project_id],['serve_id']);
+            if(!$project_info){
+                echo '项目不存在：' . $project_id . PHP_EOL . date('Y-m-d H:i:s');
+                return true;
+            }
+            $serve_ip_model = new ServersIp();
+            $serve_ip_info = $serve_ip_model->read(['id'=>$project_info['serve_id']],['servers_id']);
+            $servers_id = $serve_ip_info ? $serve_ip_info['servers_id'] : 0;
+            if($servers_id == ServerConfig::SELF_SITE_ID){
+                //判断是否已有更新进行中
+                $notify_model = new Notify();
+                $data = [
+                    'project_id' => $project_id,
+                    'type' => Notify::TYPE_MASTER,
+                    'route' => Notify::ROUTE_AI_BLOG,
+                    'server_id' => ServerConfig::SELF_SITE_ID,
+                    'status' => ['!=',Notify::STATUS_FINISH_SITEMAP]
+                ];
+                $notify = $notify_model->read($data,['id']);
+
+                if(!$notify){
+                    $domain_array = parse_url($domain);
+                    $data['data'] = Arr::a2s(['domain'=>$domain_array['host'],'url'=>[],'language'=>[]]);
+                    $data['status'] = Notify::STATUS_INIT;
+                    $data['sort'] = 2;
+                    $notify_model->add($data);
+                }
+                echo '自建站项目：'.$project_id.'更新';
+            }else{
+                $url = $domain.'api/update_page/?project_id='.$project_id.'&route=7';
+                $res = http_get($url);
+                echo '返回数据：'.json_encode($res,true).PHP_EOL;
+            }
         }else{
         }else{
             echo '域名不存在：' . $project_id . PHP_EOL . date('Y-m-d H:i:s');
             echo '域名不存在：' . $project_id . PHP_EOL . date('Y-m-d H:i:s');
         }
         }