mirror of
https://github.com/netcccyun/dnsmgr.git
synced 2026-02-21 15:31:12 +08:00
514 lines
16 KiB
PHP
514 lines
16 KiB
PHP
<?php
|
||
// 应用公共文件
|
||
use think\facade\Db;
|
||
use think\facade\Config;
|
||
use think\facade\Request;
|
||
|
||
function get_curl($url, $post = 0, $referer = 0, $cookie = 0, $header = 0, $ua = 0, $nobody = 0, $addheader = 0)
|
||
{
|
||
$ch = curl_init();
|
||
curl_setopt($ch, CURLOPT_URL, $url);
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
||
$httpheader[] = "Accept: */*";
|
||
$httpheader[] = "Accept-Encoding: gzip,deflate,sdch";
|
||
$httpheader[] = "Accept-Language: zh-CN,zh;q=0.8";
|
||
$httpheader[] = "Connection: close";
|
||
if ($addheader) {
|
||
$httpheader = array_merge($httpheader, $addheader);
|
||
}
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, $httpheader);
|
||
if ($post) {
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, $post);
|
||
}
|
||
if ($header) {
|
||
curl_setopt($ch, CURLOPT_HEADER, true);
|
||
}
|
||
if ($cookie) {
|
||
curl_setopt($ch, CURLOPT_COOKIE, $cookie);
|
||
}
|
||
if ($referer) {
|
||
curl_setopt($ch, CURLOPT_REFERER, $referer);
|
||
}
|
||
if ($ua) {
|
||
curl_setopt($ch, CURLOPT_USERAGENT, $ua);
|
||
} else {
|
||
curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Linux; U; Android 4.0.4; es-mx; HTC_One_X Build/IMM76D) AppleWebKit/534.30 (KHTML, like Gecko) Version/4.0");
|
||
}
|
||
if ($nobody) {
|
||
curl_setopt($ch, CURLOPT_NOBODY, 1);
|
||
}
|
||
curl_setopt($ch, CURLOPT_ENCODING, "gzip");
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
||
$ret = curl_exec($ch);
|
||
curl_close($ch);
|
||
return $ret;
|
||
}
|
||
|
||
function real_ip($type = 0)
|
||
{
|
||
$ip = $_SERVER['REMOTE_ADDR'];
|
||
if ($type <= 0 && isset($_SERVER['HTTP_X_FORWARDED_FOR']) && preg_match_all('#\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}#s', $_SERVER['HTTP_X_FORWARDED_FOR'], $matches)) {
|
||
foreach ($matches[0] as $xip) {
|
||
if (filter_var($xip, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4 | FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE)) {
|
||
$ip = $xip;
|
||
break;
|
||
}
|
||
}
|
||
} elseif ($type <= 0 && isset($_SERVER['HTTP_CLIENT_IP']) && filter_var($_SERVER['HTTP_CLIENT_IP'], FILTER_VALIDATE_IP, FILTER_FLAG_IPV4 | FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE)) {
|
||
$ip = $_SERVER['HTTP_CLIENT_IP'];
|
||
} elseif ($type <= 1 && isset($_SERVER['HTTP_CF_CONNECTING_IP']) && filter_var($_SERVER['HTTP_CF_CONNECTING_IP'], FILTER_VALIDATE_IP, FILTER_FLAG_IPV4 | FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE)) {
|
||
$ip = $_SERVER['HTTP_CF_CONNECTING_IP'];
|
||
} elseif ($type <= 1 && isset($_SERVER['HTTP_X_REAL_IP']) && filter_var($_SERVER['HTTP_X_REAL_IP'], FILTER_VALIDATE_IP, FILTER_FLAG_IPV4 | FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE)) {
|
||
$ip = $_SERVER['HTTP_X_REAL_IP'];
|
||
}
|
||
return $ip;
|
||
}
|
||
|
||
function strexists($string, $find)
|
||
{
|
||
return !(strpos($string, $find) === FALSE);
|
||
}
|
||
|
||
function dstrpos($string, $arr)
|
||
{
|
||
if (empty($string)) return false;
|
||
foreach ((array)$arr as $v) {
|
||
if (strpos($string, $v) !== false) {
|
||
return true;
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
function checkmobile()
|
||
{
|
||
$useragent = strtolower($_SERVER['HTTP_USER_AGENT']);
|
||
$ualist = array('android', 'midp', 'nokia', 'mobile', 'iphone', 'ipod', 'blackberry', 'windows phone');
|
||
if ((dstrpos($useragent, $ualist) || strexists($_SERVER['HTTP_ACCEPT'], "VND.WAP") || strexists($_SERVER['HTTP_VIA'], "wap"))) {
|
||
return true;
|
||
} else {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function authcode($string, $operation = 'DECODE', $key = '', $expiry = 0)
|
||
{
|
||
$ckey_length = 4;
|
||
$key = md5($key);
|
||
$keya = md5(substr($key, 0, 16));
|
||
$keyb = md5(substr($key, 16, 16));
|
||
$keyc = $ckey_length ? ($operation == 'DECODE' ? substr($string, 0, $ckey_length) : substr(md5(microtime()), -$ckey_length)) : '';
|
||
$cryptkey = $keya.md5($keya.$keyc);
|
||
$key_length = strlen($cryptkey);
|
||
$string = $operation == 'DECODE' ? base64_decode(substr($string, $ckey_length)) : sprintf('%010d', $expiry ? $expiry + time() : 0).substr(md5($string.$keyb), 0, 16).$string;
|
||
$string_length = strlen($string);
|
||
$result = '';
|
||
$box = range(0, 255);
|
||
$rndkey = array();
|
||
for ($i = 0; $i <= 255; $i++) {
|
||
$rndkey[$i] = ord($cryptkey[$i % $key_length]);
|
||
}
|
||
for ($j = $i = 0; $i < 256; $i++) {
|
||
$j = ($j + $box[$i] + $rndkey[$i]) % 256;
|
||
$tmp = $box[$i];
|
||
$box[$i] = $box[$j];
|
||
$box[$j] = $tmp;
|
||
}
|
||
for ($a = $j = $i = 0; $i < $string_length; $i++) {
|
||
$a = ($a + 1) % 256;
|
||
$j = ($j + $box[$a]) % 256;
|
||
$tmp = $box[$a];
|
||
$box[$a] = $box[$j];
|
||
$box[$j] = $tmp;
|
||
$result .= chr(ord($string[$i]) ^ ($box[($box[$a] + $box[$j]) % 256]));
|
||
}
|
||
if ($operation == 'DECODE') {
|
||
if (((int)substr($result, 0, 10) == 0 || (int)substr($result, 0, 10) - time() > 0) && substr($result, 10, 16) == substr(md5(substr($result, 26).$keyb), 0, 16)) {
|
||
return substr($result, 26);
|
||
} else {
|
||
return '';
|
||
}
|
||
} else {
|
||
return $keyc.base64_encode($result);
|
||
}
|
||
}
|
||
|
||
function random($length, $numeric = 0)
|
||
{
|
||
$seed = base_convert(md5(microtime().$_SERVER['DOCUMENT_ROOT']), 16, $numeric ? 10 : 35);
|
||
$seed = $numeric ? (str_replace('0', '', $seed).'012340567890') : ($seed.'zZ'.strtoupper($seed));
|
||
$hash = '';
|
||
$max = strlen($seed) - 1;
|
||
for ($i = 0; $i < $length; $i++) {
|
||
$hash .= $seed[mt_rand(0, $max)];
|
||
}
|
||
return $hash;
|
||
}
|
||
|
||
function checkDomain($domain)
|
||
{
|
||
if (empty($domain) || !preg_match('/^[-$a-z0-9_*.]{2,512}$/i', $domain) || (stripos($domain, '.') === false) || substr($domain, -1) == '.' || substr($domain, 0, 1) == '.' || substr($domain, 0, 1) == '*' && substr($domain, 1, 1) != '.' || substr_count($domain, '*') > 1 || strpos($domain, '*') > 0 || strlen($domain) < 4) return false;
|
||
return true;
|
||
}
|
||
|
||
function getSubstr($str, $leftStr, $rightStr)
|
||
{
|
||
$left = strpos($str, $leftStr);
|
||
$start = $left + strlen($leftStr);
|
||
$right = strpos($str, $rightStr, $start);
|
||
if ($left < 0) return '';
|
||
if ($right > 0) {
|
||
return substr($str, $start, $right - $start);
|
||
} else {
|
||
return substr($str, $start);
|
||
}
|
||
}
|
||
|
||
function arrays_are_equal($array1, $array2)
|
||
{
|
||
return empty(array_diff($array1, $array2)) && empty(array_diff($array2, $array1));
|
||
}
|
||
|
||
function checkRefererHost()
|
||
{
|
||
if (!Request::header('referer')) {
|
||
return false;
|
||
}
|
||
$url_arr = parse_url(Request::header('referer'));
|
||
$http_host = Request::header('host');
|
||
if (strpos($http_host, ':')) {
|
||
$http_host = substr($http_host, 0, strpos($http_host, ':'));
|
||
}
|
||
return $url_arr['host'] === $http_host;
|
||
}
|
||
|
||
function checkIfActive($string)
|
||
{
|
||
$array = explode(',', $string);
|
||
$action = Request::action();
|
||
if (in_array($action, $array)) {
|
||
return 'active';
|
||
} else {
|
||
return null;
|
||
}
|
||
}
|
||
|
||
function getSid()
|
||
{
|
||
return md5(uniqid(mt_rand(), true) . microtime());
|
||
}
|
||
function getMd5Pwd($pwd, $salt = null)
|
||
{
|
||
return md5(md5($pwd) . md5('1277180438'.$salt));
|
||
}
|
||
|
||
function isNullOrEmpty($str)
|
||
{
|
||
return $str === null || $str === '';
|
||
}
|
||
|
||
function checkPermission($type, $domain = null)
|
||
{
|
||
$user = Request()->user;
|
||
if (empty($user)) {
|
||
return false;
|
||
}
|
||
if ($user['level'] == 2) {
|
||
return true;
|
||
}
|
||
if ($type == 1 && $user['level'] == 1 || $type == 0 && $user['level'] >= 0) {
|
||
if ($domain == null) {
|
||
return true;
|
||
}
|
||
if (in_array($domain, $user['permission'])) {
|
||
return true;
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
function getAdminSkin()
|
||
{
|
||
$skin = cookie('admin_skin');
|
||
if (empty($skin)) {
|
||
$skin = config_get('admin_skin');
|
||
}
|
||
if (empty($skin)) {
|
||
$skin = 'skin-black-blue';
|
||
}
|
||
return $skin;
|
||
}
|
||
|
||
function config_get($key, $default = null, $force = false)
|
||
{
|
||
if ($force) {
|
||
$value = Db::name('config')->where('key', $key)->value('value');
|
||
} else {
|
||
$value = config('sys.' . $key);
|
||
}
|
||
return $value ?: $default;
|
||
}
|
||
|
||
function config_set($key, $value)
|
||
{
|
||
$res = Db::name('config')->replace()->insert(['key' => $key, 'value' => $value]);
|
||
return $res !== false;
|
||
}
|
||
|
||
function getMillisecond()
|
||
{
|
||
list($s1, $s2) = explode(' ', microtime());
|
||
return (int)sprintf('%.0f', (floatval($s1) + floatval($s2)) * 1000);
|
||
}
|
||
|
||
function getDnsType($value)
|
||
{
|
||
if (filter_var($value, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)) {
|
||
return 'A';
|
||
} elseif (filter_var($value, FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)) {
|
||
return 'AAAA';
|
||
} else {
|
||
return 'CNAME';
|
||
}
|
||
}
|
||
|
||
function convert_second($s)
|
||
{
|
||
$m = floor($s / 60);
|
||
if ($m == 0) {
|
||
return $s.'秒';
|
||
} else {
|
||
$s = $s % 60;
|
||
$h = floor($m / 60);
|
||
if ($h == 0) {
|
||
return $m.'分钟'.$s.'秒';
|
||
} else {
|
||
$m = $m % 60;
|
||
return $h.'小时'.$m.'分钟'.$s.'秒';
|
||
}
|
||
}
|
||
}
|
||
|
||
function getMainDomain($host)
|
||
{
|
||
if (filter_var($host, FILTER_VALIDATE_IP)) return $host;
|
||
$domains = config('temp.domains');
|
||
if (!$domains) {
|
||
$domains = Db::name('domain')->column('name');
|
||
config(['domains'=>$domains], 'temp');
|
||
}
|
||
foreach ($domains as $domain) {
|
||
if (str_ends_with($host, $domain)) {
|
||
return $domain;
|
||
}
|
||
}
|
||
$domain_root = file_get_contents(app()->getBasePath() . 'data' . DIRECTORY_SEPARATOR . 'domain_root.txt');
|
||
$domain_root = explode("\r\n", $domain_root);
|
||
$data = explode('.', $host);
|
||
$co_ta = count($data);
|
||
if ($co_ta <= 2) return $host;
|
||
$domain_name = $data[$co_ta - 2] . '.' . $data[$co_ta - 1];
|
||
if (in_array($domain_name, $domain_root) && $co_ta > 2) {
|
||
$domain_name = $data[$co_ta - 3] . '.' . $domain_name;
|
||
}
|
||
return $domain_name;
|
||
}
|
||
|
||
function check_proxy($url, $proxy_server, $proxy_port, $type, $proxy_user, $proxy_pwd)
|
||
{
|
||
$ch = curl_init($url);
|
||
if ($type == 'https') {
|
||
$proxy_type = CURLPROXY_HTTPS;
|
||
} elseif ($type == 'sock4') {
|
||
$proxy_type = CURLPROXY_SOCKS4;
|
||
} elseif ($type == 'sock5') {
|
||
$proxy_type = CURLPROXY_SOCKS5;
|
||
} elseif ($type == 'sock5h') {
|
||
$proxy_type = CURLPROXY_SOCKS5_HOSTNAME;
|
||
} else {
|
||
$proxy_type = CURLPROXY_HTTP;
|
||
}
|
||
curl_setopt($ch, CURLOPT_PROXYAUTH, CURLAUTH_BASIC);
|
||
curl_setopt($ch, CURLOPT_PROXY, $proxy_server);
|
||
curl_setopt($ch, CURLOPT_PROXYPORT, intval($proxy_port));
|
||
if (!empty($proxy_user) && !empty($proxy_pwd)) {
|
||
curl_setopt($ch, CURLOPT_PROXYUSERPWD, $proxy_user . ':' . $proxy_pwd);
|
||
}
|
||
curl_setopt($ch, CURLOPT_PROXYTYPE, $proxy_type);
|
||
$httpheader[] = "Accept: */*";
|
||
$httpheader[] = "Accept-Language: zh-CN,zh;q=0.8";
|
||
$httpheader[] = "Connection: close";
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, $httpheader);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||
curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36');
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, 3);
|
||
curl_exec($ch);
|
||
$errno = curl_errno($ch);
|
||
if ($errno) {
|
||
$errmsg = curl_error($ch);
|
||
curl_close($ch);
|
||
throw new Exception($errmsg);
|
||
}
|
||
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
|
||
curl_close($ch);
|
||
if ($httpCode >= 200 && $httpCode < 400) {
|
||
return true;
|
||
} else {
|
||
throw new Exception('HTTP状态码异常：' . $httpCode);
|
||
}
|
||
}
|
||
|
||
function clearDirectory($dir): bool
|
||
{
|
||
// 确保路径是目录
|
||
if (!is_dir($dir)) {
|
||
return false;
|
||
}
|
||
|
||
// 打开目录
|
||
$items = scandir($dir);
|
||
foreach ($items as $item) {
|
||
// 跳过 '.' 和 '..'
|
||
if ($item == '.' || $item == '..') {
|
||
continue;
|
||
}
|
||
|
||
// 完整路径
|
||
$path = $dir . DIRECTORY_SEPARATOR . $item;
|
||
|
||
// 如果是目录，递归删除其内容
|
||
if (is_dir($path)) {
|
||
clearDirectory($path);
|
||
// 删除空目录
|
||
rmdir($path);
|
||
} else {
|
||
// 删除文件
|
||
unlink($path);
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
|
||
function curl_client($url, $data = null, $referer = null, $cookie = null, $headers = null, $proxy = false, $method = null, $timeout = 5, $default_headers = true)
|
||
{
|
||
$ch = curl_init();
|
||
curl_setopt($ch, CURLOPT_URL, $url);
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
||
if ($default_headers === true) {
|
||
$httpheader[] = "Accept: */*";
|
||
$httpheader[] = "Accept-Language: zh-CN,zh;q=0.8";
|
||
$httpheader[] = "Connection: close";
|
||
if ($headers) {
|
||
$httpheader = array_merge($headers, $httpheader);
|
||
}
|
||
} else {
|
||
$httpheader = $headers;
|
||
}
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, $httpheader);
|
||
curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.6261.95 Safari/537.36");
|
||
curl_setopt($ch, CURLOPT_HEADER, true);
|
||
if ($data) {
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
|
||
}
|
||
if ($cookie) {
|
||
curl_setopt($ch, CURLOPT_COOKIE, $cookie);
|
||
}
|
||
if ($referer) {
|
||
curl_setopt($ch, CURLOPT_REFERER, $referer);
|
||
}
|
||
if ($method) {
|
||
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
|
||
}
|
||
|
||
if ($proxy) {
|
||
curl_set_proxy($ch);
|
||
}
|
||
|
||
$ret = curl_exec($ch);
|
||
$errno = curl_errno($ch);
|
||
if ($errno) {
|
||
$errmsg = curl_error($ch);
|
||
curl_close($ch);
|
||
throw new Exception('Curl error: ' . $errmsg);
|
||
}
|
||
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
|
||
$headerSize = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
|
||
$redirect_url = curl_getinfo($ch, CURLINFO_REDIRECT_URL);
|
||
curl_close($ch);
|
||
$header = substr($ret, 0, $headerSize);
|
||
$body = substr($ret, $headerSize);
|
||
return ['code' => $httpCode, 'redirect_url' => $redirect_url, 'header' => $header, 'body' => $body];
|
||
}
|
||
|
||
function curl_set_proxy(&$ch)
|
||
{
|
||
$proxy_server = config_get('proxy_server');
|
||
$proxy_port = intval(config_get('proxy_port'));
|
||
$proxy_userpwd = config_get('proxy_user') . ':' . config_get('proxy_pwd');
|
||
$proxy_type = config_get('proxy_type');
|
||
if (empty($proxy_server) || empty($proxy_port)) {
|
||
return;
|
||
}
|
||
if ($proxy_type == 'https') {
|
||
$proxy_type = CURLPROXY_HTTPS;
|
||
} elseif ($proxy_type == 'sock4') {
|
||
$proxy_type = CURLPROXY_SOCKS4;
|
||
} elseif ($proxy_type == 'sock5') {
|
||
$proxy_type = CURLPROXY_SOCKS5;
|
||
} elseif ($proxy_type == 'sock5h') {
|
||
$proxy_type = CURLPROXY_SOCKS5_HOSTNAME;
|
||
} else {
|
||
$proxy_type = CURLPROXY_HTTP;
|
||
}
|
||
curl_setopt($ch, CURLOPT_PROXYAUTH, CURLAUTH_BASIC);
|
||
curl_setopt($ch, CURLOPT_PROXY, $proxy_server);
|
||
curl_setopt($ch, CURLOPT_PROXYPORT, $proxy_port);
|
||
if ($proxy_userpwd != ':') {
|
||
curl_setopt($ch, CURLOPT_PROXYUSERPWD, $proxy_userpwd);
|
||
}
|
||
curl_setopt($ch, CURLOPT_PROXYTYPE, $proxy_type);
|
||
}
|
||
|
||
function convertDomainToAscii($domain) {
|
||
if (preg_match('/[\x{4e00}-\x{9fa5}]/u', $domain)) {
|
||
return idn_to_ascii($domain);
|
||
} else {
|
||
return $domain;
|
||
}
|
||
}
|
||
function convertDomainToUtf8($domain) {
|
||
if (preg_match('/^xn--/', $domain)) {
|
||
return idn_to_utf8($domain);
|
||
} else {
|
||
return $domain;
|
||
}
|
||
}
|
||
|
||
function getDomainDate($domain)
|
||
{
|
||
try {
|
||
$whois = \Iodev\Whois\Factory::get()->createWhois();
|
||
$info = $whois->loadDomainInfo($domain);
|
||
if ($info) {
|
||
if ($info->expirationDate > 0) {
|
||
return [date('Y-m-d H:i:s', $info->creationDate), date('Y-m-d H:i:s', $info->expirationDate)];
|
||
} else {
|
||
throw new Exception('域名到期时间未知');
|
||
}
|
||
} else {
|
||
throw new Exception('域名信息未找到');
|
||
}
|
||
} catch (Exception $e) {
|
||
throw new Exception('查询域名whois失败: ' . $e->getMessage());
|
||
}
|
||
}
|