作者 刘锟

update

@@ -261,26 +261,23 @@ class DomainInfoLogic extends BaseLogic @@ -261,26 +261,23 @@ class DomainInfoLogic extends BaseLogic
261 $this->fail('获取项目数据失败'); 261 $this->fail('获取项目数据失败');
262 } 262 }
263 $serverIpModel = new ServersIp(); 263 $serverIpModel = new ServersIp();
264 - $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip']); 264 + $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip','domain']);
265 if($serversIpInfo === false){ 265 if($serversIpInfo === false){
266 $this->fail('获取服务器数据失败'); 266 $this->fail('获取服务器数据失败');
267 } 267 }
268 - $serverModel = new Servers();  
269 - $serverInfo = $serverModel->read(['id'=>$serversIpInfo['servers_id']],['init_domain']);  
270 - $server_info = ['domain'=>$serverInfo['init_domain'],'ip'=>$serversIpInfo['ip']];  
271 - if($serversIpInfo['servers_id'] == 7){ 268 + if($serversIpInfo['servers_id'] == ServerConfig::SELF_TEST_ID){
272 $this->fail('请切换服务器,生成站点不能使用测试服务器'); 269 $this->fail('请切换服务器,生成站点不能使用测试服务器');
273 } 270 }
274 if($serversIpInfo['servers_id'] == ServerConfig::SELF_SITE_ID){ 271 if($serversIpInfo['servers_id'] == ServerConfig::SELF_SITE_ID){
275 - $this->model->edit(['amp_status' => $this->param['amp_status'] ?? 0,],['id'=>$this->param['id']]); 272 + $this->model->edit(['amp_status' => $this->param['amp_status'] ?? 0],['id'=>$this->param['id']]);
276 $this->fail('自建站服务器无法生成站点'); 273 $this->fail('自建站服务器无法生成站点');
277 } 274 }
278 //域名是否都已经解析 275 //域名是否都已经解析
279 - if(!empty($info['domain']) && !$this->check_cname($info['domain'], $server_info)){ 276 + if(!empty($info['domain']) && !$this->check_cname($info['domain'], $serversIpInfo)){
280 $this->fail('域名' . $info['domain'] . '未解析至目标服务器'); 277 $this->fail('域名' . $info['domain'] . '未解析至目标服务器');
281 } 278 }
282 foreach ($this->param['other_domain']??[] as $other_domain){ 279 foreach ($this->param['other_domain']??[] as $other_domain){
283 - if($other_domain && !$this->check_cname($other_domain, $server_info)){ 280 + if($other_domain && !$this->check_cname($other_domain, $serversIpInfo)){
284 $this->fail('域名' . $other_domain . '未解析至目标服务器'); 281 $this->fail('域名' . $other_domain . '未解析至目标服务器');
285 } 282 }
286 } 283 }
@@ -296,7 +293,7 @@ class DomainInfoLogic extends BaseLogic @@ -296,7 +293,7 @@ class DomainInfoLogic extends BaseLogic
296 $host_array[0] = 'm'; 293 $host_array[0] = 'm';
297 } 294 }
298 $amp_domain = implode('.',$host_array); 295 $amp_domain = implode('.',$host_array);
299 - if(!$this->check_cname($amp_domain, $server_info)){ 296 + if(!$this->check_cname($amp_domain, $serversIpInfo)){
300 $this->fail('AMP站点域名' . $amp_domain . '未解析至目标服务器'); 297 $this->fail('AMP站点域名' . $amp_domain . '未解析至目标服务器');
301 } 298 }
302 } 299 }
@@ -385,14 +382,11 @@ class DomainInfoLogic extends BaseLogic @@ -385,14 +382,11 @@ class DomainInfoLogic extends BaseLogic
385 if($this->param['is_create']){ 382 if($this->param['is_create']){
386 //需要创建站点 383 //需要创建站点
387 $serverIpModel = new ServersIp(); 384 $serverIpModel = new ServersIp();
388 - $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip']); 385 + $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip','domain']);
389 if($serversIpInfo === false){ 386 if($serversIpInfo === false){
390 $this->fail('获取服务器数据失败'); 387 $this->fail('获取服务器数据失败');
391 } 388 }
392 - $serverModel = new Servers();  
393 - $serverInfo = $serverModel->read(['id'=>$serversIpInfo['servers_id']],['init_domain']);  
394 - $server_info = ['domain'=>$serverInfo['init_domain'],'ip'=>$serversIpInfo['ip']];  
395 - if($serversIpInfo['servers_id'] == 7){ 389 + if($serversIpInfo['servers_id'] == ServerConfig::SELF_TEST_ID){
396 $this->fail('请切换服务器,生成站点不能使用测试服务器'); 390 $this->fail('请切换服务器,生成站点不能使用测试服务器');
397 } 391 }
398 if($serversIpInfo['servers_id'] == ServerConfig::SELF_SITE_ID){ 392 if($serversIpInfo['servers_id'] == ServerConfig::SELF_SITE_ID){
@@ -412,7 +406,7 @@ class DomainInfoLogic extends BaseLogic @@ -412,7 +406,7 @@ class DomainInfoLogic extends BaseLogic
412 if($has_info && ($has_info['project_id'] != $project_id || $has_info['language_id'] != $this->param['language_id'])){ 406 if($has_info && ($has_info['project_id'] != $project_id || $has_info['language_id'] != $this->param['language_id'])){
413 $this->fail('自定义域名已被使用'); 407 $this->fail('自定义域名已被使用');
414 } 408 }
415 - if(!$this->check_cname($this->param['custom_domain'], $server_info)){ 409 + if(!$this->check_cname($this->param['custom_domain'], $serversIpInfo)){
416 $this->fail('域名' . $this->param['custom_domain'] . '未解析至目标服务器'); 410 $this->fail('域名' . $this->param['custom_domain'] . '未解析至目标服务器');
417 } 411 }
418 }else{ 412 }else{
@@ -53,17 +53,21 @@ class EditAmpDomainBt implements ShouldQueue @@ -53,17 +53,21 @@ class EditAmpDomainBt implements ShouldQueue
53 if ($project_info === false) { 53 if ($project_info === false) {
54 return $this->output($domain_info['domain'] . ':获取项目数据失败'); 54 return $this->output($domain_info['domain'] . ':获取项目数据失败');
55 } 55 }
  56 +
56 //获取服务器数据 57 //获取服务器数据
57 $serverIpModel = new ServersIp(); 58 $serverIpModel = new ServersIp();
58 - $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip']); 59 + $serversIpInfo = $serverIpModel->read(['id' => $project_info['serve_id']], ['servers_id']);
59 if ($serversIpInfo === false) { 60 if ($serversIpInfo === false) {
60 return $this->output($domain_info['domain'] . ':获取服务器数据失败'); 61 return $this->output($domain_info['domain'] . ':获取服务器数据失败');
61 } 62 }
62 $serverModel = new Servers(); 63 $serverModel = new Servers();
63 - $serverInfo = $serverModel->read(['id'=>$serversIpInfo['servers_id']],['init_domain']);  
64 - $server_info = ['domain'=>$serverInfo['init_domain'],'ip'=>$serversIpInfo['ip']]; 64 + $serverInfo = $serverModel->read(['id' => $serversIpInfo['servers_id']], ['init_domain']);
  65 + if ($serverInfo === false) {
  66 + return $this->output($domain_info['domain'] . ':获取服务器数据失败');
  67 + }
  68 +
65 //编辑amp站 69 //编辑amp站
66 - $api_url_amp = 'http://' . $server_info['domain'] . '/api/createSiteAmp'; 70 + $api_url_amp = 'http://' . $serverInfo['init_domain'] . '/api/createSiteAmp';
67 $api_param_amp = [ 71 $api_param_amp = [
68 'domain' => $domain_info['domain'], 72 'domain' => $domain_info['domain'],
69 'not_allow_country' => $domain_info['not_allow_country'], 73 'not_allow_country' => $domain_info['not_allow_country'],
@@ -46,24 +46,26 @@ class EditCustomDomainBt implements ShouldQueue @@ -46,24 +46,26 @@ class EditCustomDomainBt implements ShouldQueue
46 if ($domain_info === false) { 46 if ($domain_info === false) {
47 return $this->output($domain_info['custom_domain'] . ':获取域名数据失败'); 47 return $this->output($domain_info['custom_domain'] . ':获取域名数据失败');
48 } 48 }
  49 +
49 //获取项目数据 50 //获取项目数据
50 $project_model = new Project(); 51 $project_model = new Project();
51 $project_info = $project_model->read(['id' => $domain_info['project_id']], 'serve_id'); 52 $project_info = $project_model->read(['id' => $domain_info['project_id']], 'serve_id');
52 if ($project_info === false) { 53 if ($project_info === false) {
53 return $this->output($domain_info['custom_domain'] . ':获取项目数据失败'); 54 return $this->output($domain_info['custom_domain'] . ':获取项目数据失败');
54 } 55 }
  56 +
55 //获取服务器数据 57 //获取服务器数据
56 $serverIpModel = new ServersIp(); 58 $serverIpModel = new ServersIp();
57 - $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip']); 59 + $serversIpInfo = $serverIpModel->read(['id' => $project_info['serve_id']], ['servers_id']);
58 if ($serversIpInfo === false) { 60 if ($serversIpInfo === false) {
59 return $this->output($domain_info['custom_domain'] . ':获取服务器数据失败'); 61 return $this->output($domain_info['custom_domain'] . ':获取服务器数据失败');
60 } 62 }
61 $serverModel = new Servers(); 63 $serverModel = new Servers();
62 - $serverInfo = $serverModel->read(['id'=>$serversIpInfo['servers_id']],['init_domain']);  
63 - $server_info = ['domain'=>$serverInfo['init_domain'],'ip'=>$serversIpInfo['ip']]; 64 + $serverInfo = $serverModel->read(['id' => $serversIpInfo['servers_id']], ['init_domain']);
  65 +
64 //编辑站点 66 //编辑站点
65 if ($domain_info['type'] == 2) { 67 if ($domain_info['type'] == 2) {
66 - $api_url = 'http://' . $server_info['domain'] . '/api/setSsl'; 68 + $api_url = 'http://' . $serverInfo['init_domain'] . '/api/setSsl';
67 $api_param = [ 69 $api_param = [
68 'domain' => $domain_info['custom_domain'], 70 'domain' => $domain_info['custom_domain'],
69 'private_key' => $domain_info['private_key'], 71 'private_key' => $domain_info['private_key'],
@@ -73,7 +75,7 @@ class EditCustomDomainBt implements ShouldQueue @@ -73,7 +75,7 @@ class EditCustomDomainBt implements ShouldQueue
73 'is_https' => 1 75 'is_https' => 1
74 ]; 76 ];
75 } else { 77 } else {
76 - $api_url = 'http://' . $server_info['domain'] . '/api/applySsl'; 78 + $api_url = 'http://' . $serverInfo['init_domain'] . '/api/applySsl';
77 $api_param = [ 79 $api_param = [
78 'domain' => $domain_info['custom_domain'], 80 'domain' => $domain_info['custom_domain'],
79 'rewrite' => [], 81 'rewrite' => [],
@@ -56,16 +56,19 @@ class EditDomainBt implements ShouldQueue @@ -56,16 +56,19 @@ class EditDomainBt implements ShouldQueue
56 56
57 //获取服务器数据 57 //获取服务器数据
58 $serverIpModel = new ServersIp(); 58 $serverIpModel = new ServersIp();
59 - $serversIpInfo = $serverIpModel->read(['id'=>$project_info['serve_id']],['servers_id','ip']); 59 + $serversIpInfo = $serverIpModel->read(['id' => $project_info['serve_id']], ['servers_id']);
60 if ($serversIpInfo === false) { 60 if ($serversIpInfo === false) {
61 return $this->output($domain_info['domain'] . ':获取服务器数据失败'); 61 return $this->output($domain_info['domain'] . ':获取服务器数据失败');
62 } 62 }
63 $serverModel = new Servers(); 63 $serverModel = new Servers();
64 - $serverInfo = $serverModel->read(['id'=>$serversIpInfo['servers_id']],['init_domain']);  
65 - $server_info = ['domain'=>$serverInfo['init_domain'],'ip'=>$serversIpInfo['ip']]; 64 + $serverInfo = $serverModel->read(['id' => $serversIpInfo['servers_id']], ['init_domain']);
  65 + if ($serverInfo === false) {
  66 + return $this->output($domain_info['domain'] . ':获取服务器数据失败');
  67 + }
  68 +
66 //编辑主站 69 //编辑主站
67 if ($domain_info['type'] == 2) { 70 if ($domain_info['type'] == 2) {
68 - $api_url = 'http://' . $server_info['domain'] . '/api/setSsl'; 71 + $api_url = 'http://' . $serverInfo['init_domain'] . '/api/setSsl';
69 $api_param = [ 72 $api_param = [
70 'domain' => $domain_info['domain'], 73 'domain' => $domain_info['domain'],
71 'private_key' => $domain_info['private_key'], 74 'private_key' => $domain_info['private_key'],
@@ -78,7 +81,7 @@ class EditDomainBt implements ShouldQueue @@ -78,7 +81,7 @@ class EditDomainBt implements ShouldQueue
78 'is_redirect' => $domain_info['is_redirect'] 81 'is_redirect' => $domain_info['is_redirect']
79 ]; 82 ];
80 } else { 83 } else {
81 - $api_url = 'http://' . $server_info['domain'] . '/api/applySsl'; 84 + $api_url = 'http://' . $serverInfo['init_domain'] . '/api/applySsl';
82 $api_param = [ 85 $api_param = [
83 'domain' => $domain_info['domain'], 86 'domain' => $domain_info['domain'],
84 'rewrite' => $domain_info['extend_config'], 87 'rewrite' => $domain_info['extend_config'],
@@ -35,6 +35,7 @@ class ServerConfig extends Base @@ -35,6 +35,7 @@ class ServerConfig extends Base
35 const STATUS_ONE = 1; 35 const STATUS_ONE = 1;
36 36
37 const SELF_SITE_ID = 6;//自建站服务器ID 37 const SELF_SITE_ID = 6;//自建站服务器ID
  38 + const SELF_TEST_ID = 7;//测试服务器ID
38 39
39 /** 40 /**
40 * @remark :获取数据用户名解密 41 * @remark :获取数据用户名解密