mirror of
https://github.com/netcccyun/dnsmgr.git
synced 2026-02-21 15:31:12 +08:00
388 lines
14 KiB
PHP
388 lines
14 KiB
PHP
<?php
|
|
|
|
namespace app\lib\dns;
|
|
|
|
use app\lib\DnsInterface;
|
|
|
|
class qingcloud implements DnsInterface
|
|
{
|
|
private $access_key_id;
|
|
private $secret_access_key;
|
|
private $baseUrl = 'http://api.routewize.com';
|
|
private $error;
|
|
private $domain;
|
|
private $domainid;
|
|
private $proxy;
|
|
|
|
public function __construct($config)
|
|
{
|
|
$this->access_key_id = $config['access_key_id'];
|
|
$this->secret_access_key = $config['secret_access_key'];
|
|
$this->domain = $config['domain'];
|
|
$this->domainid = $config['domainid'];
|
|
$this->proxy = isset($config['proxy']) ? $config['proxy'] == 1 : false;
|
|
}
|
|
|
|
public function getError()
|
|
{
|
|
return $this->error;
|
|
}
|
|
|
|
public function check()
|
|
{
|
|
if ($this->getDomainList() != false) {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
//获取域名列表
|
|
public function getDomainList($KeyWord = null, $PageNumber = 1, $PageSize = 20)
|
|
{
|
|
$offset = ($PageNumber - 1) * $PageSize;
|
|
$param = ['offset' => $offset, 'limit' => $PageSize];
|
|
if (!empty($KeyWord)) {
|
|
$param['zone_name'] = $KeyWord;
|
|
}
|
|
$data = $this->execute('GET', '/v1/user/zones', $param);
|
|
if ($data) {
|
|
$list = [];
|
|
foreach ($data['zones'] as $row) {
|
|
$list[] = [
|
|
'DomainId' => $row['zone_name'],
|
|
'Domain' => rtrim($row['zone_name'], '.'),
|
|
'RecordCount' => 0,
|
|
];
|
|
}
|
|
return ['total' => $data['total_count'], 'list' => $list];
|
|
}
|
|
return false;
|
|
}
|
|
|
|
//获取解析记录列表
|
|
public function getDomainRecords($PageNumber = 1, $PageSize = 20, $KeyWord = null, $SubDomain = null, $Value = null, $Type = null, $Line = null, $Status = null)
|
|
{
|
|
if ($SubDomain) {
|
|
return $this->getHostRecords($SubDomain);
|
|
}
|
|
$offset = ($PageNumber - 1) * $PageSize;
|
|
$param = ['zone_name' => $this->domainid, 'offset' => $offset, 'limit' => $PageSize];
|
|
if (!isNullOrEmpty($KeyWord)) {
|
|
$param['search_word'] = $KeyWord;
|
|
}
|
|
$data = $this->execute('GET', '/v1/dns/host/', $param);
|
|
if ($data) {
|
|
$list = [];
|
|
foreach ($data['domains'] as $row) {
|
|
$name = substr($row['domain_name'], 0, -(strlen($row['zone_name']) + 1));
|
|
if ($name == '') $name = '@';
|
|
$list[] = [
|
|
'RecordId' => $row['domain_name'],
|
|
'Domain' => $this->domain,
|
|
'Name' => $name,
|
|
'Type' => null,
|
|
'Value' => null,
|
|
'Line' => null,
|
|
'TTL' => null,
|
|
'MX' => null,
|
|
'Status' => $row['status'] == 'enabled' ? '0' : '1',
|
|
'Weight' => null,
|
|
'Remark' => $row['description'],
|
|
'UpdateTime' => $row['create_time'],
|
|
'Count' => $row['count'],
|
|
];
|
|
}
|
|
return ['total' => $data['total_count'], 'list' => $list];
|
|
}
|
|
return false;
|
|
}
|
|
|
|
private function getHostRecords($SubDomain)
|
|
{
|
|
$param = ['zone_name' => $this->domainid, 'domain_name' => $SubDomain];
|
|
$data = $this->execute('GET', '/v1/dns/host_info/', $param);
|
|
if ($data) {
|
|
$list = [];
|
|
foreach ($data['records'] as $record) {
|
|
$name = substr($record['domain_name'], 0, -(strlen($record['zone_name']) + 1));
|
|
if ($name == '') $name = '@';
|
|
foreach ($record['record'] as $record_group) {
|
|
foreach ($record_group['data'] as $row) {
|
|
$mx = null;
|
|
if ($record['rd_type'] == 'MX') {
|
|
$value = explode(' ', $row['value'], 2);
|
|
$row['value'] = isset($value[1]) ? $value[1] : '';
|
|
$mx = intval($value[0]);
|
|
}
|
|
if ($record['rd_type'] == 'TXT') {
|
|
$row['value'] = trim($row['value'], '"');
|
|
}
|
|
$list[] = [
|
|
'RecordId' => $record['domain_record_id'].'_'.$row['record_value_id'],
|
|
'Domain' => $record['domain_name'],
|
|
'Name' => $name,
|
|
'Type' => $record['rd_type'],
|
|
'Mode' => $record['mode'],
|
|
'Value' => $row['value'],
|
|
'Line' => $record['view_id'],
|
|
'TTL' => $record['ttl'],
|
|
'MX' => $mx,
|
|
'Status' => $row['status'] == 1 ? '1' : '0',
|
|
'Weight' => $record_group['weight'] > 0 ? $record_group['weight'] : null,
|
|
'Remark' => null,
|
|
'UpdateTime' => $record['create_time'],
|
|
];
|
|
}
|
|
}
|
|
}
|
|
return ['total' => $data['total_count'], 'list' => $list];
|
|
}
|
|
return false;
|
|
}
|
|
|
|
//获取子域名解析记录列表
|
|
public function getSubDomainRecords($SubDomain, $PageNumber = 1, $PageSize = 20, $Type = null, $Line = null)
|
|
{
|
|
$SubDomain = $this->getHost($SubDomain);
|
|
return $this->getDomainRecords($PageNumber, $PageSize, null, $SubDomain, null, $Type, $Line);
|
|
}
|
|
|
|
//获取解析记录详细信息
|
|
public function getDomainRecordInfo($RecordId)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
//添加解析记录
|
|
public function addDomainRecord($Name, $Type, $Value, $Line = '0', $TTL = 600, $MX = 1, $Weight = null, $Remark = null)
|
|
{
|
|
$mode = input('post.mode', '1');
|
|
|
|
if ($Type == 'MX') {
|
|
$Value = intval($MX).' '.$Value;
|
|
} elseif ($Type == 'TXT' && substr($Value, 0, 1) != '"') {
|
|
$Value = '"'.$Value.'"';
|
|
}
|
|
|
|
$values = [];
|
|
foreach (explode(',', $Value) as $val) {
|
|
$values[] = ['value' => trim($val), 'status' => 1];
|
|
}
|
|
if (($Type == 'A' || $Type == 'CNAME') && $mode == '3') $Weight = intval($Weight);
|
|
else $Weight = 0;
|
|
$record = [['weight' => $Weight, 'values' => $values]];
|
|
|
|
$param = ['zone_name' => $this->domainid, 'domain_name' => $Name, 'view_id' => intval($Line), 'type' => $Type, 'ttl' => intval($TTL), 'record' => json_encode($record), 'mode' => intval($mode), 'auto_merge' => 2];
|
|
$data = $this->execute('POST', '/v1/record/', $param);
|
|
return is_array($data) ? $data['domain_record_id'] : false;
|
|
}
|
|
|
|
//修改解析记录
|
|
public function updateDomainRecord($RecordId, $Name, $Type, $Value, $Line = '0', $TTL = 600, $MX = 1, $Weight = null, $Remark = null)
|
|
{
|
|
$mode = input('post.mode', '1');
|
|
|
|
if ($Type == 'MX') {
|
|
$Value = intval($MX).' '.$Value;
|
|
} elseif ($Type == 'TXT' && substr($Value, 0, 1) != '"') {
|
|
$Value = '"'.$Value.'"';
|
|
}
|
|
|
|
$recordId = explode('_', $RecordId);
|
|
$domain_record_id = $recordId[0];
|
|
$record_value_id = $recordId[1];
|
|
$data = $this->execute('GET', '/v1/dr_id/'.$domain_record_id);
|
|
if (!$data) return false;
|
|
|
|
if (($Type == 'A' || $Type == 'CNAME') && $mode == '3') $Weight = intval($Weight);
|
|
else $Weight = 0;
|
|
$record = [];
|
|
foreach ($data['data']['record'] as $record_group) {
|
|
$values = [];
|
|
$flag = false;
|
|
foreach ($record_group['data'] as $row) {
|
|
if ($row['record_value_id'] == $record_value_id) {
|
|
$row['value'] = $Value;
|
|
$flag = true;
|
|
}
|
|
$values[] = ['value' => $row['value'], 'status' => $row['status']];
|
|
}
|
|
if (count($values) > 0) {
|
|
$record[] = ['weight' => $flag ? $Weight : $record_group['weight'], 'values' => $values];
|
|
}
|
|
}
|
|
|
|
$param = ['zone_name' => $this->domainid, 'domain_name' => $Name, 'view_id' => intval($Line), 'type' => $Type, 'ttl' => intval($TTL), 'record' => json_encode($record), 'mode' => intval($mode)];
|
|
$data = $this->execute('POST', '/v1/dr_id/'.$domain_record_id, $param);
|
|
return $data !== false;
|
|
}
|
|
|
|
//修改解析记录备注
|
|
public function updateDomainRecordRemark($RecordId, $Remark)
|
|
{
|
|
$param = ['zone_name' => $this->domainid, 'domain_name' => $RecordId, 'description' => $Remark];
|
|
$data = $this->execute('POST', '/v1/dns/host/', $param);
|
|
return $data !== false;
|
|
}
|
|
|
|
//删除解析记录
|
|
public function deleteDomainRecord($RecordId)
|
|
{
|
|
if (strpos($RecordId, $this->domainid) !== false) {
|
|
$param = ['domain_names' => json_encode([$RecordId]), 'zone_name' => $this->domainid];
|
|
$data = $this->execute('DELETE', '/v1/domain/', $param);
|
|
return $data !== false;
|
|
}
|
|
|
|
$recordId = explode('_', $RecordId);
|
|
$domain_record_id = $recordId[0];
|
|
$record_value_id = $recordId[1];
|
|
$data = $this->execute('GET', '/v1/dr_id/'.$domain_record_id);
|
|
if (!$data) return false;
|
|
|
|
$record = [];
|
|
foreach ($data['data']['record'] as $record_group) {
|
|
$values = [];
|
|
foreach ($record_group['data'] as $row) {
|
|
if ($row['record_value_id'] == $record_value_id) {
|
|
continue;
|
|
}
|
|
$values[] = ['value' => $row['value'], 'status' => $row['status']];
|
|
}
|
|
if (count($values) > 0) {
|
|
$record[] = ['weight' => $record_group['weight'], 'values' => $values];
|
|
}
|
|
}
|
|
|
|
if (count($record) == 0) {
|
|
$param = ['ids' => json_encode([$domain_record_id]), 'target' => 'record', 'action' => 'delete'];
|
|
$data = $this->execute('POST', '/v1/change_record_status/', $param);
|
|
return $data !== false;
|
|
}
|
|
|
|
$name = substr($data['data']['domain_name'], 0, -(strlen($data['data']['zone_name']) + 1));
|
|
if ($name == '') $name = '@';
|
|
$param = ['zone_name' => $this->domainid, 'domain_name' => $name, 'view_id' => $data['data']['view_id'], 'type' => $data['data']['rd_type'], 'ttl' => $data['data']['ttl'], 'record' => json_encode($record), 'mode' => $data['data']['mode']];
|
|
$data = $this->execute('POST', '/v1/dr_id/'.$domain_record_id, $param);
|
|
return $data !== false;
|
|
}
|
|
|
|
//设置解析记录状态
|
|
public function setDomainRecordStatus($RecordId, $Status)
|
|
{
|
|
$recordId = explode('_', $RecordId);
|
|
$record_value_id = $recordId[1];
|
|
$param = ['ids' => json_encode([$record_value_id]), 'target' => 'value', 'action' => $Status == '0' ? 'stop' : 'enable'];
|
|
$data = $this->execute('POST', '/v1/change_record_status/', $param);
|
|
return $data !== false;
|
|
}
|
|
|
|
//获取解析记录操作日志
|
|
public function getDomainRecordLog($PageNumber = 1, $PageSize = 20, $KeyWord = null, $StartDate = null, $endDate = null)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
//获取解析线路列表
|
|
public function getRecordLine()
|
|
{
|
|
$param = ['zone_name' => $this->domainid, 'type' => 'GET_FULL'];
|
|
$data = $this->execute('GET', '/v1/zone/view/', $param);
|
|
if ($data) {
|
|
$list = [];
|
|
foreach ($data['zone_views'] as $row) {
|
|
if ($row['name'] == '*') $row['name'] = '默认';
|
|
$list[$row['id']] = ['name' => $row['name'], 'parent' => null];
|
|
}
|
|
return $list;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
//获取域名信息
|
|
public function getDomainInfo()
|
|
{
|
|
return false;
|
|
}
|
|
|
|
//获取域名最低TTL
|
|
public function getMinTTL()
|
|
{
|
|
return 60;
|
|
}
|
|
|
|
public function addDomain($Domain)
|
|
{
|
|
$param = ['zone_name' => $Domain];
|
|
$data = $this->execute('POST', '/v1/zone/', $param);
|
|
if ($data) {
|
|
return ['id' => $data['zone_name'], 'name' => $Domain];
|
|
}
|
|
return false;
|
|
}
|
|
|
|
private function getHost($Name)
|
|
{
|
|
if ($Name == '@' || $Name == '') $Name = '';
|
|
else $Name .= '.';
|
|
$Name .= $this->domain . '.';
|
|
return $Name;
|
|
}
|
|
|
|
private function execute($method, $path, $params = null)
|
|
{
|
|
$date = gmdate('D, d M Y H:i:s \G\M\T');
|
|
$string_to_sign = $method."\n".$date."\n".$path;
|
|
if($method == 'GET' && $params){
|
|
ksort($params);
|
|
$string_to_sign .= '?'.http_build_query($params);
|
|
}
|
|
$signature = base64_encode(hash_hmac('sha256', $string_to_sign, $this->secret_access_key, true));
|
|
$authorization = 'QC-HMAC-SHA256 '.$this->access_key_id.':'.$signature;
|
|
$header = [
|
|
'Authorization' => $authorization,
|
|
'Date' => $date,
|
|
];
|
|
if ($method == 'POST' || $method == 'PUT' || $method == 'DELETE') {
|
|
$header['Content-Type'] = 'application/json; charset=utf-8';
|
|
$response = $this->curl($method, $path, $header, json_encode($params));
|
|
} else {
|
|
if ($params) {
|
|
$path .= '?'.http_build_query($params);
|
|
}
|
|
$response = $this->curl($method, $path, $header);
|
|
}
|
|
$arr = json_decode($response['body'], true);
|
|
if (isset($arr['code']) && $arr['code'] == 0 || isset($arr['domains']) || $method == 'DELETE' && $response['code'] == 204) {
|
|
return $arr;
|
|
} elseif(isset($arr['message'])) {
|
|
$this->setError($arr['message']);
|
|
return false;
|
|
} elseif(isset($arr['msg'])) {
|
|
$this->setError($arr['msg']);
|
|
return false;
|
|
} else {
|
|
$this->setError('返回数据解析失败');
|
|
return false;
|
|
}
|
|
}
|
|
|
|
private function curl($method, $path, $header, $body = null)
|
|
{
|
|
$url = $this->baseUrl . $path;
|
|
try {
|
|
$response = http_request($url, $body, null, null, $header, $this->proxy, $method);
|
|
} catch (\Exception $e) {
|
|
$this->setError($e->getMessage());
|
|
return false;
|
|
}
|
|
return $response;
|
|
}
|
|
|
|
private function setError($message)
|
|
{
|
|
$this->error = $message;
|
|
//file_put_contents('logs.txt',date('H:i:s').' '.$message."\r\n", FILE_APPEND);
|
|
}
|
|
}
|