|
- <?php
- if (!defined('DEDEINC')) exit ('dedebiz');
- /**
- * 系统存放函数
- *
- * @version $id:common.func.php 4 16:39 2010年7月6日 tianya $
- * @package DedeBIZ.Libraries
- * @copyright Copyright (c) 2022 DedeBIZ.COM
- * @license GNU GPL v2 (https://www.dedebiz.com/license)
- * @link https://www.dedebiz.com
- */
- require_once DEDEINC."/archive/partview.class.php";
- if (version_compare(PHP_VERSION, '7.0.0', '>=')) {
- if (!function_exists('mysql_connect') and function_exists('mysqli_connect')) {
- function mysql_connect($server, $username, $password)
- {
- return mysqli_connect($server, $username, $password);
- }
- }
- if (!function_exists('mysql_query') and function_exists('mysqli_query')) {
- function mysql_query($query, $link)
- {
- return mysqli_query($link, $query);
- }
- }
- if (!function_exists('mysql_select_db') and function_exists('mysqli_select_db')) {
- function mysql_select_db($database_name, $link)
- {
- return mysqli_select_db($link, $database_name);
- }
- }
- if (!function_exists('mysql_fetch_array') and function_exists('mysqli_fetch_array')) {
- function mysql_fetch_array($result)
- {
- return mysqli_fetch_array($result);
- }
- }
- if (!function_exists('mysql_close') and function_exists('mysqli_close')) {
- function mysql_close($link)
- {
- if ($link) {
- return @mysqli_close($link);
- } else {
- return false;
- }
- }
- }
- if (!function_exists('mysql_error') and function_exists('mysqli_connect_error')) {
- function mysql_error($link)
- {
- if (mysqli_connect_errno()) {
- return mysqli_connect_error();
- }
- if ($link) {
- return @mysqli_error($link);
- } else {
- return false;
- }
- }
- }
- if (!function_exists('mysql_free_result') and function_exists('mysqli_free_result')) {
- function mysql_free_result($result)
- {
- return mysqli_free_result($result);
- }
- }
- if (!function_exists('split')) {
- function split($pattern, $string)
- {
- return explode($pattern, $string);
- }
- }
- }
- //一个支持在PHP Cli Server打印的方法
- function var_dump_cli($val,...$values)
- {
- ob_start();
- var_dump($val,$values);
- error_log(ob_get_clean(), 4);
- }
- function get_mime_type($filename)
- {
- if (!function_exists('finfo_open')) {
- return 'unknow/octet-stream';
- }
- $finfo = finfo_open(FILEINFO_MIME_TYPE);
- $mimeType = finfo_file($finfo, $filename);
- if (preg_match('#\.(php|pl|cgi|asp|aspx|jsp|php5|php4|php3|shtm|shtml|htm)$#i', trim($filename))) {
- return 'forbid/octet-stream';
- }
- finfo_close($finfo);
- return $mimeType;
- }
- function is_all_numeric(array $array)
- {
- foreach ($array as $item) {
- if (!is_numeric($item)) return false;
- }
- return true;
- }
- function make_hash()
- {
- $rand = dede_random_bytes(16);
- $_SESSION['token'] = ($rand === FALSE) ? md5(uniqid(mt_rand(), TRUE)) : bin2hex($rand);
- return $_SESSION['token'];
- }
- function dede_random_bytes($length)
- {
- if (empty($length) or !ctype_digit((string) $length)) {
- return FALSE;
- }
- if (function_exists('openssl_random_pseudo_bytes')) {
- return openssl_random_pseudo_bytes($length);
- }
- if (function_exists('random_bytes')) {
- try {
- return random_bytes((int) $length);
- } catch (Exception $e) {
- return FALSE;
- }
- }
- if (is_readable('/dev/urandom') && ($fp = fopen('/dev/urandom', 'rb')) !== FALSE) {
- version_compare(PHP_VERSION, '5.4.0', '>=') && stream_set_chunk_size($fp, $length);
- $output = fread($fp, $length);
- fclose($fp);
- if ($output !== FALSE) {
- return $output;
- }
- }
- return FALSE;
- }
- //SQL语句过滤程序,由80sec提供,这里作了适当的修改
- if (!function_exists('CheckSql')) {
- function CheckSql($db_string, $querytype = 'select')
- {
- global $cfg_cookie_encode;
- $clean = '';
- $error = '';
- $old_pos = 0;
- $pos = -1;
- $enkey = substr(md5(substr($cfg_cookie_encode.'dedebiz', 0, 5)), 0, 10);
- $log_file = DEDEDATA.'/checksql_'.$enkey.'_safe.txt';
- $userIP = GetIP();
- $getUrl = GetCurUrl();
- //如果是普通查询语句,直接过滤一些特殊语法
- if ($querytype == 'select') {
- $notallow1 = "[^0-9a-z@\._-]{1,}(union|sleep|benchmark|load_file|outfile)[^0-9a-z@\.-]{1,}";
- if (preg_match("/".$notallow1."/i", $db_string)) {
- fputs(fopen($log_file, 'a+'), "$userIP||$getUrl||$db_string||SelectBreak\r\n");
- exit("<span>Safe Alert: Request Error step 1 !</span>");
- }
- }
- //完整的SQL检查
- while (TRUE) {
- $pos = strpos($db_string, '\'', $pos + 1);
- if ($pos === FALSE) {
- break;
- }
- $clean .= substr($db_string, $old_pos, $pos - $old_pos);
- while (TRUE) {
- $pos1 = strpos($db_string, '\'', $pos + 1);
- $pos2 = strpos($db_string, '\\', $pos + 1);
- if ($pos1 === FALSE) {
- break;
- } elseif ($pos2 == FALSE || $pos2 > $pos1) {
- $pos = $pos1;
- break;
- }
- $pos = $pos2 + 1;
- }
- $clean .= '$s$';
- $old_pos = $pos + 1;
- }
- $clean .= substr($db_string, $old_pos);
- $clean = trim(strtolower(preg_replace(array('~\s+~s'), array(' '), $clean)));
- if (
- strpos($clean, '@') !== FALSE or strpos($clean, 'char(') !== FALSE or strpos($clean, '"') !== FALSE
- or strpos($clean, '$s$$s$') !== FALSE
- ) {
- $fail = TRUE;
- if (preg_match("#^create table#i", $clean)) $fail = FALSE;
- $error = "unusual character";
- }
- //老版本数据库不支持union,程序不使用union,但黑客使用它,所以检查它
- if (strpos($clean, 'union') !== FALSE && preg_match('~(^|[^a-z])union($|[^[a-z])~s', $clean) != 0) {
- $fail = TRUE;
- $error = "union detect";
- }
- //发布版本的程序比较少包括--,#这样的注释,但黑客经常使用它们
- elseif (strpos($clean, '/*') > 2 || strpos($clean, '--') !== FALSE || strpos($clean, '#') !== FALSE) {
- $fail = TRUE;
- $error = "comment detect";
- }
- //这些函数不会被使用,但是黑客会用它来操作文件,down掉数据库
- elseif (strpos($clean, 'sleep') !== FALSE && preg_match('~(^|[^a-z])sleep($|[^[a-z])~s', $clean) != 0) {
- $fail = TRUE;
- $error = "slown down detect";
- } elseif (strpos($clean, 'benchmark') !== FALSE && preg_match('~(^|[^a-z])benchmark($|[^[a-z])~s', $clean) != 0) {
- $fail = TRUE;
- $error = "slown down detect";
- } elseif (strpos($clean, 'load_file') !== FALSE && preg_match('~(^|[^a-z])load_file($|[^[a-z])~s', $clean) != 0) {
- $fail = TRUE;
- $error = "file fun detect";
- } elseif (strpos($clean, 'into outfile') !== FALSE && preg_match('~(^|[^a-z])into\s+outfile($|[^[a-z])~s', $clean) != 0) {
- $fail = TRUE;
- $error = "file fun detect";
- }
- //老版本数据库不支持子查询,该功能也用得少,但黑客可以使用它来查询数据库敏感信息
- elseif (preg_match('~\([^)]*?select~s', $clean) != 0) {
- $fail = TRUE;
- $error = "sub select detect";
- }
- if (!empty($fail)) {
- fputs(fopen($log_file, 'a+'), "$userIP||$getUrl||$db_string||$error\r\n");
- exit("<span>Safe Alert: Request Error step 2!</span>");
- } else {
- return $db_string;
- }
- }
- }
- /**
- * 载入助手,系统默认载入助手示例
- * <code>
- * if (!function_exists('HelloDede'))
- * {
- * function HelloDede()
- * {
- * echo "Hello! Dede";
- * }
- * }
- * </code>
- * 开发中使用这个助手的时候直接使用函数helper('test');初始化它,然后在文件中就可以直接使用:HelloDede();调用
- *
- * @access public
- * @param mixed $helpers 助手名称,可以是数组,可以是单个字符串
- * @return void
- */
- $_helpers = array();
- function helper($helpers)
- {
- //如果是数组,则进行递归操作
- if (is_array($helpers)) {
- foreach ($helpers as $dede) {
- helper($dede);
- }
- return;
- }
- if (isset($_helpers[$helpers])) {
- return;
- }
- if (file_exists(DEDEINC.'/helpers/'.$helpers.'.helper.php')) {
- include_once(DEDEINC.'/helpers/'.$helpers.'.helper.php');
- $_helpers[$helpers] = TRUE;
- }
- //无法载入助手
- if (!isset($_helpers[$helpers])) {
- exit('Unable to load the requested file: helpers/'.$helpers.'.helper.php');
- }
- }
- function dede_htmlspecialchars($str)
- {
- global $cfg_soft_lang;
- if (version_compare(PHP_VERSION, '5.4.0', '<')) return htmlspecialchars($str);
- if ($cfg_soft_lang == 'gb2312') return htmlspecialchars($str, ENT_COMPAT, 'ISO-8859-1');
- else return htmlspecialchars($str);
- }
- /**
- * 载入助手,这里会员载入用helps载入多个助手
- *
- * @access public
- * @param string
- * @return void
- */
- function helpers($helpers)
- {
- helper($helpers);
- }
- //兼容php4的file_put_contents
- if (!function_exists('file_put_contents')) {
- function file_put_contents($n, $d)
- {
- $f = @fopen($n, "w");
- if (!$f) {
- return FALSE;
- } else {
- fwrite($f, $d);
- fclose($f);
- return TRUE;
- }
- }
- }
- /**
- * 短消息函数,可以在某个动作处理后友好的系统提示
- *
- * @param string $msg 消息系统提示
- * @param string $gourl 跳转地址
- * @param int $onlymsg 仅显示信息
- * @param int $limittime 限制时间
- * @param string $btnmsg 按钮提示
- * @param string $target 跳转类型
- * @return void
- */
- function ShowMsg($msg, $gourl, $onlymsg = 0, $limittime = 0)
- {
- if (defined('DEDE_DIALOG_UPLOAD') && !isset($GLOBALS['noeditor'])) {
- echo json_encode(array(
- "uploaded"=>0,
- "error"=>array(
- "message" => $msg,
- ),
- ));
- return;
- }
- if (isset($GLOBALS['format']) && strtolower($GLOBALS['format'])==='json') {
- echo json_encode(array(
- "code"=>0,
- "msg"=>$msg,
- "gourl"=>$gourl,
- ));
- return;
- }
- if (empty($GLOBALS['cfg_plus_dir'])) $GLOBALS['cfg_plus_dir'] = '..';
- $htmlhead = "<!DOCTYPE html><html><head><meta charset='utf-8'><meta http-equiv='X-UA-Compatible' content='IE=Edge,chrome=1'><meta name='viewport' content='width=device-width,initial-scale=1'><title>系统提示</title><link rel='stylesheet' href='/static/web/css/bootstrap.min.css'><link rel='stylesheet' href='/static/web/css/admin.css'></head><base target='_self'><body>";
- $htmlfoot = "</body></html>";
- $litime = ($limittime == 0 ? 1000 : $limittime);
- $func = '';
- if ($gourl == '-1') {
- if ($limittime == 0) $litime = 3000;
- $gourl = "javascript:history.go(-1);";
- }
- if ($gourl == '' || $onlymsg == 1) {
- $msg = "<script>alert(\"".str_replace("\"", "“", $msg)."\");</script>";
- } else {
- //当网址为:close::objname时,关闭父框架的id=objname元素
- if (preg_match('/close::/', $gourl)) {
- $tgobj = trim(preg_replace('/close::/', '', $gourl));
- $gourl = 'javascript:;';
- $func .= "<script>window.parent.document.getElementById('{$tgobj}').style.display='none';</script>";
- }
- $func .= "<script>var pgo=0;function JumpUrl(){if (pgo==0) {location='$gourl'; pgo=1;}}</script>";
- $rmsg = $func;
- $rmsg .= "<div class='tips'><div class='tips-box shadow-sm'><div class='tips-head'><p>系统提示</p></div>";
- $rmsg .= "<div class='tips-body'>";
- $rmsg .= "".str_replace("\"", "“", $msg)."";
- $rmsg .= "";
- if ($onlymsg == 0) {
- if ($gourl != 'javascript:;' && $gourl != '') {
- $rmsg .= "<div class='text-center mt-3'><a href='{$gourl}' class='btn btn-success btn-sm'>点击反应</a></div>";
- $rmsg .= "<script>setTimeout('JumpUrl()', $litime);</script>";
- } else {
- $rmsg .= "</div>";
- }
- } else {
- $rmsg .= "</div></div>";
- }
- $msg = $htmlhead.$rmsg.$htmlfoot;
- }
- echo $msg;
- }
- /**
- * 表中是否存在某个字段
- *
- * @param mixed $tablename 表名称
- * @param mixed $field 字段名
- * @return bool
- */
- function TableHasField($tablename, $field)
- {
- global $dsql,$cfg_dbtype;
- if ($cfg_dbtype === 'mysql') {
- $dsql->GetTableFields($tablename,"tfd");
- while ($r = $dsql->GetFieldObject("tfd")) {
- if ($r->name === $field) {
- return true;
- }
- }
- return false;
- } elseif ($cfg_dbtype === 'sqlite') {
- $k = $dsql->GetTableFields($tablename);
- while ($r = $dsql->GetFieldObject($k)) {
- if ($r->name === $field) {
- return true;
- }
- }
- return false;
- } else {
- return false;
- }
- }
- function GetSimpleServerSoftware()
- {
- if (preg_match("#^php#i",$_SERVER["SERVER_SOFTWARE"])) {
- return 'PHP Server';
- } else if (preg_match("#^apache#i",$_SERVER["SERVER_SOFTWARE"])){
- return 'Apache';
- } else if (preg_match("#^nginx#i",$_SERVER["SERVER_SOFTWARE"])){
- return 'Nginx';
- } else if (preg_match("#^microsoft-iis#i",$_SERVER["SERVER_SOFTWARE"])){
- return 'IIS';
- } else if (preg_match("#^caddy#i",$_SERVER["SERVER_SOFTWARE"])){
- return 'Caddy';
- } else {
- return 'Other';
- }
- }
- /**
- * 获取验证码的session值
- *
- * @return string
- */
- function GetCkVdValue()
- {
- @session_id($_COOKIE['PHPSESSID']);
- @session_start();
- return isset($_SESSION['securimage_code_value']) ? $_SESSION['securimage_code_value'] : '';
- }
- /**
- * PHP某些版本有Bug,不能在同一作用域中同时读session并改注销它,因此调用后需执行本函数
- *
- * @return void
- */
- function ResetVdValue()
- {
- @session_start();
- $_SESSION['securimage_code_value'] = '';
- }
- function IndexSub($idx, $num)
- {
- return intval($idx) - intval($num) == 0 ? '0 ' : intval($idx) - intval($num);
- }
- /**
- * HideEmail隐藏邮箱
- *
- * @param mixed $email
- * @return string
- */
- function HideEmail($email)
- {
- if (empty($email)) return "暂无";
- $em = explode("@",$email);
- $name = implode('@', array_slice($em, 0, count($em)-1));
- $len = floor(strlen($name)/2);
- return substr($name,0, $len).str_repeat('*', $len)."@".end($em);
- }
- //用来返回index的active
- function IndexActive($idx)
- {
- if ($idx == 1) {
- return ' active';
- } else {
- return '';
- }
- }
- //是否是HTTPS
- function IsSSL()
- {
- if (@$_SERVER['HTTPS'] && ('1' == $_SERVER['HTTPS'] || 'on' == strtolower($_SERVER['HTTPS']))) {
- return true;
- } elseif ('https' == @$_SERVER['REQUEST_SCHEME']) {
- return true;
- } elseif ('443' == $_SERVER['SERVER_PORT']) {
- return true;
- } elseif ('https' == @$_SERVER['HTTP_X_FORWARDED_PROTO']) {
- return true;
- }
- return false;
- }
- //获取对应版本号的更新SQL
- function GetUpdateSQL()
- {
- global $cfg_dbprefix, $cfg_dbtype, $cfg_db_language;
- $result = array();
- $query = '';
- $sql4tmp = "ENGINE=MyISAM DEFAULT CHARSET=".$cfg_db_language;
- $fp = fopen(DEDEDATA.'/admin/update.txt','r');
- $sqls = array();
- $current_ver = '';
- while(!feof($fp))
- {
- $line = rtrim(fgets($fp,1024));
- if (preg_match("/\-\- ([\d\.]+)/",$line,$matches)) {
- if (count($sqls) > 0) {
- $result[$current_ver] = $sqls;
- }
- $sqls = array();
- $current_ver = $matches[1];
- }
- if (preg_match("#;$#", $line)) {
- $query .= $line."\n";
- $query = str_replace('#@__',$cfg_dbprefix,$query);
- if ($cfg_dbtype == 'sqlite') {
- $query = preg_replace('/character set (.*?) /i','',$query);
- $query = preg_replace('/unsigned/i','',$query);
- $query = str_replace('TYPE=MyISAM','',$query);
- $query = preg_replace ('/TINYINT\(([\d]+)\)/i','INTEGER',$query);
- $query = preg_replace ('/mediumint\(([\d]+)\)/i','INTEGER',$query);
- $query = preg_replace ('/smallint\(([\d]+)\)/i','INTEGER',$query);
- $query = preg_replace('/int\(([\d]+)\)/i','INTEGER',$query);
- $query = preg_replace('/auto_increment/i','PRIMARY KEY AUTOINCREMENT',$query);
- $query = preg_replace('/,([\t\s ]+)KEY(.*?)MyISAM;/','',$query);
- $query = preg_replace('/,([\t\s ]+)KEY(.*?);/',');',$query);
- $query = preg_replace('/,([\t\s ]+)UNIQUE KEY(.*?);/',');',$query);
- $query = preg_replace('/set\(([^\)]*?)\)/','varchar',$query);
- $query = preg_replace('/enum\(([^\)]*?)\)/','varchar',$query);
- if (preg_match("/PRIMARY KEY AUTOINCREMENT/",$query)) {
- $query = preg_replace('/,([\t\s ]+)PRIMARY KEY([\t\s ]+)\(`([0-9a-zA-Z]+)`\)/i','',$query);
- }
- $sqls[] = $query;
- } else {
- if (preg_match('#CREATE#i', $query)) {
- $sqls[] = preg_replace("#TYPE=MyISAM#i",$sql4tmp,$query);
- } else {
- $sqls[] = $query;
- }
- }
- $query='';
- } else if (!preg_match("#^(\/\/|--)#", $line)) {
- $query .= $line;
- }
- }
- if (count($sqls) > 0) {
- $result[$current_ver] = $sqls;
- }
- fclose($fp);
- return $result;
- }
- /**
- * GetMimeTypeOrExtension
- *
- * @param mixed $str 字符串
- * @param mixed $t 类型,0获取mime type,1获取扩展名
- * @return string
- */
- function GetMimeTypeOrExtension($str, $t = 0) {
- $mime_types = array(
- 'aac' => 'audio/aac',
- 'abw' => 'application/x-abiword',
- 'arc' => 'application/x-freearc',
- 'avi' => 'video/x-msvideo',
- 'azw' => 'application/vnd.amazon.ebook',
- 'bin' => 'application/octet-stream',
- 'bmp' => 'image/bmp',
- 'bz' => 'application/x-bzip',
- 'bz2' => 'application/x-bzip2',
- 'csh' => 'application/x-csh',
- 'css' => 'text/css',
- 'csv' => 'text/csv',
- 'doc' => 'application/msword',
- 'docx' => 'application/vnd.openxmlformats-officedocument.wordprocessingml.document',
- 'eot' => 'application/vnd.ms-fontobject',
- 'epub' => 'application/epub+zip',
- 'gif' => 'image/gif',
- 'htm' => 'text/html',
- 'html' => 'text/html',
- 'ico' => 'image/vnd.microsoft.icon',
- 'ics' => 'text/calendar',
- 'jar' => 'application/java-archive',
- 'jpeg' => 'image/jpeg',
- 'jpg' => 'image/jpeg',
- 'js' => 'text/javascript',
- 'json' => 'application/json',
- 'jsonld' => 'application/ld+json',
- 'mid' => 'audio/midi',
- 'midi' => 'audio/midi',
- 'mjs' => 'text/javascript',
- 'mp3' => 'audio/mpeg',
- 'mp4' => 'video/mp4',
- 'mpeg' => 'video/mpeg',
- 'mpkg' => 'application/vnd.apple.installer+xml',
- 'odp' => 'application/vnd.oasis.opendocument.presentation',
- 'ods' => 'application/vnd.oasis.opendocument.spreadsheet',
- 'odt' => 'application/vnd.oasis.opendocument.text',
- 'oga' => 'audio/ogg',
- 'ogv' => 'video/ogg',
- 'ogx' => 'application/ogg',
- 'otf' => 'font/otf',
- 'png' => 'image/png',
- 'pdf' => 'application/pdf',
- 'ppt' => 'application/vnd.ms-powerpoint',
- 'pptx' => 'application/vnd.openxmlformats-officedocument.presentationml.presentation',
- 'rar' => 'application/x-rar-compressed',
- 'rtf' => 'application/rtf',
- 'sh' => 'application/x-sh',
- 'svg' => 'image/svg+xml',
- 'swf' => 'application/x-shockwave-flash',
- 'tar' => 'application/x-tar',
- 'tif' => 'image/tiff',
- 'tiff' => 'image/tiff',
- 'ttf' => 'font/ttf',
- 'txt' => 'text/plain',
- 'vsd' => 'application/vnd.visio',
- 'wav' => 'audio/wav',
- 'weba' => 'audio/webm',
- 'webm' => 'video/webm',
- 'webp' => 'image/webp',
- 'woff' => 'font/woff',
- 'woff2' => 'font/woff2',
- 'xhtml' => 'application/xhtml+xml',
- 'xls' => 'application/vnd.ms-excel',
- 'xlsx' => 'application/vnd.ms-excel',
- 'xml' => 'application/xml',
- 'xul' => 'application/vnd.mozilla.xul+xml',
- 'zip' => 'application/zip',
- '3gp' => 'video/3gpp',
- '3g2' => 'video/3gpp2',
- '7z' => 'application/x-7z-compressed',
- 'wmv' => 'video/x-ms-asf',
- 'wma' => 'audio/x-ms-wma',
- 'mov' => 'video/quicktime',
- 'rm' => 'application/vnd.rn-realmedia',
- 'mpg' => 'video/mpeg',
- 'mpga' => 'audio/mpeg',
- );
- if ($t===0) {
- return isset($mime_types[$str])? $mime_types[$str] : 'application/octet-stream';
- } else {
- foreach ($mime_types as $key => $value) {
- if ($value == $str) return $key;
- }
- return "dedebiz";
- }
- }
- //用于实际请求接口并返回处理结果
- function DedeSearchDo($action, $parms=array()) {
- if ($action === 'update') {
- DedeSearchDo('delete', $parms);
- return DedeSearchDo('add', $parms);
- }
- //生成完整请求URL
- $url = DedeSearchAPIURL($action, $parms);
- //初始化cURL
- $ch = curl_init();
- curl_setopt($ch, CURLOPT_URL, $url); //设置请求URL
- curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); //返回结果而不是直接输出
- curl_setopt($ch, CURLOPT_TIMEOUT, 10); //设置超时时间(秒)
- curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5); //设置连接超时(秒)
- curl_setopt($ch, CURLOPT_USERAGENT, 'DedeSearchAPI/1.0'); //设置User-Agent
- curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); //支持https连接
- curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); //支持https连接
- //执行请求
- $response = curl_exec($ch);
- //获取HTTP状态码和错误信息
- $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
- $curlError = curl_error($ch);
- //关闭cURL资源
- curl_close($ch);
- //处理HTTP错误
- if ($response === false || $httpCode !== 200) {
- return array(
- 'code' => -1,
- 'message' => !empty($curlError) ? $curlError : "HTTP Error: $httpCode",
- 'data' => null,
- );
- }
- //解析返回的JSON数据
- $result = json_decode($response, true);
- if (json_last_error() !== JSON_ERROR_NONE) {
- return array(
- 'code' => -2,
- 'message' => 'Invalid JSON response',
- 'data' => null,
- );
- }
- //检查返回的业务逻辑中的code
- if (!isset($result['code']) || $result['code'] !== 0) {
- return array(
- 'code' => isset($result['code'])? $result['code'] : -3,
- 'message' => isset($result['message'])? $result['message'] : 'Unknown error',
- 'data' => null,
- );
- }
- //返回成功结果
- return array(
- 'code' => 0,
- 'message' => 'Success',
- 'data' => isset($result['data'])? $result['data'] : null,
- );
- }
- //获取接口地址
- function DedeSearchAPIURL($action, $parms=array())
- {
- $baseUrl = DEDEBIZSEARCHHOST."/api/$action"; //替换为实际的API地址
- //添加公共参数
- $timestamp = time(); //当前时间戳
- $parms['timestamp'] = $timestamp;
- $parms['pageSize'] = isset($parms['pageSize'])? $parms['pageSize']:10;
- $parms['page'] = isset($parms['page'])? $parms['page']:1;
- $parms['q'] = isset($parms['q'])? $parms['q']:"";
- if ($action == "delete" || $action == "add") {
- $parms['pageSize'] = 0;
- $parms['page'] = 0;
- $parms['q'] = isset($parms['id'])? $parms['id']:"";
- }
- //生成签名字符串
- $signBaseString = "key=" . DEDEBIZSEARCHKEY . "&q=".$parms['q']. "&pageSize=".$parms['pageSize']. "&page=".$parms['page']. "×tamp=".$parms['timestamp'];
- $parms['sign'] = md5($signBaseString); //使用MD5生成签名
- if ($action == "delete" || $action == "add") {
- unset($parms['q']);
- unset($parms['pageSize']);
- unset($parms['page']);
- }
- //拼接完整URL
- $finalQueryString = http_build_query($parms);
- $finalUrl = $baseUrl . '?' . $finalQueryString;
- return $finalUrl;
- }
- function ConvertMysqlToSqlite($mysqlQuery) {
- //移除CHARACTER SET和COLLATE
- $query = preg_replace('/character set \S+/i', '', $mysqlQuery);
- $query = preg_replace('/collate \S+/i', '', $query);
- //移除unsigned关键字
- $query = str_replace('unsigned', '', $query);
- //替换MySQL的整数类型为SQLite的INTEGER
- $query = preg_replace('/\b(TINY|SMALL|MEDIUM|BIG)?INT\(\d+\)/i', 'INTEGER', $query);
- //替换AUTO_INCREMENT为PRIMARY KEY AUTOINCREMENT (仅适用于INTEGER类型)
- $query = preg_replace('/\bINTEGER\s+NOT NULL\s+PRIMARY KEY AUTOINCREMENT/i', 'INTEGER PRIMARY KEY AUTOINCREMENT', $query);
- $query = preg_replace('/\bAUTO_INCREMENT\b/i', '', $query);
- //移除MySQL特有的ENGINE、CHARSET、COLLATE、TYPE选项
- $query = preg_replace('/ENGINE=\S+/i', '', $query);
- $query = preg_replace('/DEFAULT CHARSET=\S+/i', '', $query);
- $query = preg_replace('/COLLATE=\S+/i', '', $query);
- $query = preg_replace('/TYPE=MyISAM;/i', '', $query);
- //移除COMMENT语法(SQLite不支持)
- $query = preg_replace('/COMMENT\s+\'[^\']*\'/i', '', $query);
- //移除KEY和UNIQUE KEY定义(SQLite会自动管理索引),同时处理USING BTREE
- $query = preg_replace('/,?\s*KEY\s+\S+\s*\([^)]*\)\s*(USING BTREE)?/i', '', $query);
- $query = preg_replace('/,?\s*UNIQUE KEY\s+\S+\s*\([^)]*\)\s*(USING BTREE)?/i', '', $query);
- //移除不完整的UNIQUE定义
- $query = preg_replace('/,?\s*UNIQUE\s*(?!\()/', '', $query);
- //替换ENUM和SET为TEXT
- $query = preg_replace('/\b(ENUM|SET)\([^)]*\)/i', 'TEXT', $query);
- //替换MEDIUMTEXT为TEXT
- $query = preg_replace('/\bMEDIUMTEXT\b/i', 'TEXT', $query);
- //处理DEFAULT CURRENT_TIMESTAMP
- $query = preg_replace('/DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP/i', 'DEFAULT CURRENT_TIMESTAMP', $query);
- //处理DEFAULT值
- $query = preg_replace('/DEFAULT\s+\'([^\']+)\'/i', 'DEFAULT "$1"', $query);
- //处理PRIMARY KEY只能用于INTEGER
- if (preg_match('/PRIMARY KEY \(`(\w+)`\)/', $query, $matches)) {
- $primaryKeyColumn = $matches[1];
- $query = preg_replace('/,?\s*PRIMARY KEY\s*\(`' . $primaryKeyColumn . '`\)/i', '', $query);
- $query = preg_replace('/(`' . $primaryKeyColumn . '`\s+INTEGER)/i', '$1 PRIMARY KEY', $query);
- }
- //处理CONCAT替换为SQLite兼容形式
- if (preg_match('/CONCAT\(([^)]*?)\)/i', $query, $matches)) {
- $query = preg_replace('/CONCAT\(([^)]*?)\)/i', str_replace(",", "||", $matches[1]), $query);
- $query = str_replace("'||'", "','", $query);
- }
- //修正FIND_IN_SET替换
- $query = preg_replace("/FIND_IN_SET\('([\w]+)', arc.flag\)>0/i", "(',' || arc.flag || ',') LIKE '%,\\1,%'", $query);
- $query = preg_replace("/FIND_IN_SET\('([\w]+)', arc.flag\)<1/i", "(',' || arc.flag || ',') NOT LIKE '%,\\1,%'", $query);
- //修正FIND_IN_SET替换(允许列名包含点号)
- $query = preg_replace_callback(
- "/FIND_IN_SET\s*\(\s*'([^']+)'\s*,\s*([a-zA-Z0-9_`\.]+)\s*\)/i",
- function ($matches) {
- //返回SQLite兼容的LIKE语法
- return "(',' || " . $matches[2] . " || ',' LIKE '%," . $matches[1] . ",%')";
- },
- $query
- );
- //替换FIELD函数为CASE表达式
- $query = preg_replace_callback(
- '/\bFIELD\s*\(\s*([^,]+)\s*,\s*((?:\'[^\']+\'|`[^`]+`|[^),]+(?:,\s*)?)+)\s*\)/i',
- function ($matches) {
- $field = trim($matches[1]);
- $values = trim($matches[2]);
- //更精确分割值列表(支持带引号、反引号及无空格分隔的数值)
- preg_match_all('/\'[^\']+\'|`[^`]+`|\d+|\w+/', $values, $valueParts);
- $cases = [];
- $position = 1;
- foreach ($valueParts[0] as $value) {
- $cases[] = "WHEN $field = $value THEN $position";
- $position++;
- }
- return "(CASE " . implode(' ', $cases) . " ELSE 0 END)";
- },
- $query
- );
- //新增的转换逻辑
- $query = preg_replace("/SHOW fields FROM `([\w]+)`/i", "PRAGMA table_info('\\1') ", $query);
- $query = preg_replace("/SHOW CREATE TABLE `([\w]+)`/i", "SELECT 0,sql FROM sqlite_master WHERE name='\\1'; ", $query);
- $query = preg_replace("/Show Tables/i", "SELECT name FROM sqlite_master WHERE type = \"table\"", $query);
- $query = str_replace("\'", "\"", $query);
- $query = str_replace('\t\n', "", $query);
- $query = str_ireplace('rand', 'RANDOM', $query);
- return trim($query);
- }
- function ThemeInclude($path)
- {
- global $cfg_basedir, $cfg_templets_dir, $cfg_df_style;
- $tmpfile = $cfg_basedir.$cfg_templets_dir.'/'.$cfg_df_style.'/'.$path;
- $dtp = new PartView();
- $dtp->SetTemplet($tmpfile);
- $dtp->Display();
- }
- //自定义函数接口
- if (file_exists(DEDEINC.'/extend.func.php')) {
- require_once(DEDEINC.'/extend.func.php');
- }
- ?>
|