he/DzzOffice
1
0
Fork 0
mirror of https://github.com/DzzXH/DzzOffice.git synced 2026-04-22 12:41:40 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

更新至V1.71，更新内容在笔记中查看

Browse Source
This commit is contained in:
小胡
2023-01-24 16:02:04 +08:00
Unverified
parent 1c98f32d5d
commit 98e7bbc108
96 changed files with 656 additions and 10798 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
install/data/install.sql
View File

@@ -1192,14 +1192,14 @@ CREATE TABLE dzz_user_profile (
PRIMARY KEY (uid,fieldid)
) ENGINE=MyISAM;
DROP TABLE IF EXISTS `dzz_user_qqconnect`;
CREATE TABLE `dzz_user_qqconnect` (
`openid` varchar(255) NOT NULL COMMENT 'Openid',
`uid` int(10) unsigned NOT NULL COMMENT '对应UID',
`dateline` int(10) NOT NULL DEFAULT '0' COMMENT '创建时间',
`unbind` tinyint(1) NOT NULL DEFAULT '0',
PRIMARY KEY (`openid`(20)),
KEY `uid` (`uid`)
DROP TABLE IF EXISTS dzz_user_qqconnect;
CREATE TABLE dzz_user_qqconnect (
openid varchar(255) NOT NULL COMMENT 'Openid',
uid int(10) unsigned NOT NULL COMMENT '对应UID',
dateline int(10) NOT NULL DEFAULT '0' COMMENT '创建时间',
unbind tinyint(1) NOT NULL DEFAULT '0',
PRIMARY KEY (openid(20)),
KEY uid (uid)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
DROP TABLE IF EXISTS dzz_user_profile_setting;
@@ -1226,6 +1226,19 @@ CREATE TABLE dzz_user_profile_setting (
PRIMARY KEY (fieldid)
) ENGINE=MyISAM;
DROP TABLE IF EXISTS dzz_user_login;
CREATE TABLE dzz_user_login (
Id int(11) NOT NULL AUTO_INCREMENT,
uid int(10) unsigned NOT NULL DEFAULT '0',
username text NOT NULL,
usergroup text NOT NULL,
dlsb text NOT NULL,
ip varchar(20) NOT NULL DEFAULT '',
dateline int(10) unsigned NOT NULL DEFAULT '0',
type text NOT NULL,
PRIMARY KEY (Id)
) ENGINE=MyISAM;
DROP TABLE IF EXISTS dzz_user_status;
CREATE TABLE dzz_user_status (
uid int(10) unsigned NOT NULL,

444
install/index.php
View File

@@ -1,444 +0,0 @@
<?php
/*
* @copyright Leyun internet Technology(Shanghai)Co.,Ltd
* @license http://www.dzzoffice.com/licenses/license.txt
* @package DzzOffice
* @link http://www.dzzoffice.com
* @author zyx(zyx@dzz.cc)
*/
error_reporting(E_ERROR);
@set_time_limit(1000);
if(function_exists('set_magic_quotes_runtime')) {
@set_magic_quotes_runtime(0);
}
define('IN_DZZ', TRUE);
define('IN_LEYUN', TRUE);
define('ROOT_PATH', dirname(__FILE__).'/../');
define('BS',DIRECTORY_SEPARATOR);//系统目录分割符
define('DZZ_ROOT', dirname(dirname(__FILE__)).BS);//系统根目录
define('CORE_NAME','core');//核心目录名
define('CORE_PATH',DZZ_ROOT.CORE_NAME.BS.'class');//核心类目录
define('APP_DIRNAME','dzz');//应用目录名
require ROOT_PATH.'./core/core_version.php';
require ROOT_PATH.'./install/include/install_var.php';
if(function_exists('mysqli_connect')) {
require ROOT_PATH.'./install/include/install_mysqli.php';
} else {
require ROOT_PATH.'./install/include/install_mysql.php';
}
require ROOT_PATH.'./install/include/install_function.php';
require ROOT_PATH.'./install/language/zh-cn/lang.php';
$view_off = getgpc('view_off');
define('VIEW_OFF', $view_off ? TRUE : FALSE);
$allow_method = array('show_license', 'env_check','dir_check', 'db_init', 'admin_init','ext_info', 'install_check', 'tablepre_check');
$step = intval(getgpc('step', 'R')) ? intval(getgpc('step', 'R')) : 0;
$method = getgpc('method');
if(empty($method) || !in_array($method, $allow_method)) {
$method = isset($allow_method[$step]) ? $allow_method[$step] : '';
}
if(empty($method)) {
show_msg('method_undefined', $method, 0);
}
if(file_exists($lockfile) && $method != 'ext_info') {
show_msg('install_locked', '', 0);
} elseif(!class_exists('dbstuff')) {
show_msg('database_nonexistence', '', 0);
}
timezone_set();
if(in_array($method, array('ext_info'))) {
$isHTTPS = ($_SERVER['HTTPS'] && strtolower($_SERVER['HTTPS']) != 'off') ? true : false;
$PHP_SELF = $_SERVER['PHP_SELF'] ? $_SERVER['PHP_SELF'] : $_SERVER['SCRIPT_NAME'];
$sitepath = substr($PHP_SELF, 0, strrpos($PHP_SELF, '/'));
$sitepath=preg_replace('/install$/i','',$sitepath);
$bbserver = 'http'.($isHTTPS ? 's' : '').'://'.preg_replace("/\:\d+/", '', $_SERVER['HTTP_HOST']).($_SERVER['SERVER_PORT'] && $_SERVER['SERVER_PORT'] != 80 && $_SERVER['SERVER_PORT'] != 443 ? ':'.$_SERVER['SERVER_PORT'] : '').($sitepath);
}
if($method == 'show_license') {
show_license();
} elseif($method == 'env_check') {
VIEW_OFF && function_check($func_items);
env_check($env_items);
show_env_result($env_items,$func_items, $filesock_items);
} elseif($method == 'dir_check') {
dirfile_check($dirfile_items);
show_dirfile_result($dirfile_items);
} elseif($method == 'db_init') {
$submit = true;
$default_config = $_config = array();
$default_configfile = './config/config_default.php';
if(!file_exists(ROOT_PATH.$default_configfile)) {
exit('config_default.php was lost, please reupload this file.');
} else {
include ROOT_PATH.$default_configfile;
$default_config = $_config;
}
/*if(file_exists(ROOT_PATH.CONFIG)) {//修改不调用已有的config.php内的信息
include ROOT_PATH.CONFIG;
} else {*/
$_config = $default_config;
//}
$dbhost = $_config['db'][1]['dbhost'];
$dbname = $_config['db'][1]['dbname'];
$dbpw = $_config['db'][1]['dbpw'];
$dbuser = $_config['db'][1]['dbuser'];
$tablepre = $_config['db'][1]['tablepre'];
$adminemail = 'admin@dzzoffice.com';
$error_msg = array();
if(isset($form_db_init_items) && is_array($form_db_init_items)) {
foreach($form_db_init_items as $key => $items) {
$$key = getgpc($key, 'p');
if(!isset($$key) || !is_array($$key)) {
$submit = false;
break;
}
foreach($items as $k => $v) {
$tmp = $$key;
$$k = $tmp[$k];
if(empty($$k) || !preg_match($v['reg'], $$k)) {
if(empty($$k) && !$v['required']) {
continue;
}
$submit = false;
VIEW_OFF or $error_msg[$key][$k] = 1;
}
}
}
} else {
$submit = false;
}
if($submit && !VIEW_OFF && $_SERVER['REQUEST_METHOD'] == 'POST') {
$forceinstall = isset($_POST['dbinfo']['forceinstall']) ? $_POST['dbinfo']['forceinstall'] : '';
$dbname_not_exists = true;
if(!empty($dbhost) && empty($forceinstall)) {
$dbname_not_exists = check_db($dbhost, $dbuser, $dbpw, $dbname, $tablepre);
if(!$dbname_not_exists) {
$form_db_init_items['dbinfo']['forceinstall'] = array('type' => 'checkbox', 'required' => 0, 'reg' => '/^.*+/');
$error_msg['dbinfo']['forceinstall'] = 1;
$submit = false;
$dbname_not_exists = false;
}
}
}
if($submit) {
$step = $step + 1;
if(empty($dbname)) {
show_msg('dbname_invalid', $dbname, 0);
} else {
$mysqlmode = function_exists("mysqli_connect") ? 'mysqli' : 'mysql';
if($mysqlmode=='mysqli'){
//兼容支持域名直接带有端口的情况
if(strpos($dbhost,':')!==false){
list($dbhost1,$port)=explode(':',$dbhost);
}elseif(strpos($dbhost,'.sock')!==false){//地址直接是socket地址
$unix_socket=$dbhost1;
$dbhost1='localhost';
}else{
$dbhost1=$dbhost;
}
if(empty($port)) $port='3306';
$link = new mysqli($dbhost1, $dbuser, $dbpw, '', $port, $unix_socket);
$errno = $link->connect_errno;
$error = $link->connect_error;
}else{
list($dbhost1,$port)=explode(':',$dbhost);
if(empty($port)) $port='3306';
$link = @mysql_connect($dbhost, $dbuser, $dbpw);
$errno = mysql_errno();
$error = mysql_error();
}
if($errno) {
if($errno == 1045) {
show_msg('database_errno_1045', $error, 0);
} elseif($errno == 2003 || $errno==2002) {
show_msg('database_errno_2003', $error, 0);
} else {
show_msg('database_connect_error', $error, 0);
}
}
$mysql_version = ($mysqlmode == 'mysqli') ? $link->server_info : mysql_get_server_info() ;
if($mysql_version > '4.1') {
if($mysqlmode == 'mysqli') {
$link->query("CREATE DATABASE IF NOT EXISTS `$dbname` DEFAULT CHARACTER SET ".DBCHARSET);
} else {
mysql_query("CREATE DATABASE IF NOT EXISTS `$dbname` DEFAULT CHARACTER SET ".DBCHARSET, $link);
}
} else {
if($mysqlmode == 'mysqli') {
$link->query("CREATE DATABASE IF NOT EXISTS `$dbname`");
} else {
mysql_query("CREATE DATABASE IF NOT EXISTS `$dbname`", $link);
}
}
if(($mysqlmode == 'mysqli') ? $link->errno : mysql_errno($link)) {
show_msg('database_errno_1044', ($mysqlmode == 'mysqli') ? $link->error: mysql_error($link) , 0,0);
}
if($mysqlmode == 'mysqli') {
$link->close();
} else {
mysql_close($link);
}
}
if(!preg_match("/^[a-z][a-z0-9]+_$/i",$tablepre)) {
show_msg('tablepre_invalid', $tablepre, 0);
}
$uid = 1 ;
$authkey = substr(md5($_SERVER['SERVER_ADDR'].$_SERVER['HTTP_USER_AGENT'].$dbhost.$dbuser.$dbpw.$dbname.$pconnect.substr($timestamp, 0, 6)), 8, 6).random(10);
$_config['db'][1]['dbhost'] = $dbhost;
$_config['db'][1]['dbname'] = $dbname;
$_config['db'][1]['dbpw'] = $dbpw;
$_config['db'][1]['dbuser'] = $dbuser;
$_config['db'][1]['port'] = $port?$port:'3306';
$_config['db'][1]['tablepre'] = $tablepre;
$_config['admincp']['founder'] = (string)$uid;
$_config['security']['authkey'] = $authkey;
$_config['cookie']['cookiepre'] = random(4).'_';
$_config['memory']['prefix'] = random(6).'_';
save_config_file(ROOT_PATH.CONFIG, $_config, $default_config);
$runqueryerror=0;
$db = new dbstuff;
$db->connect($dbhost, $dbuser, $dbpw, $dbname, DBCHARSET);
if(!VIEW_OFF) {
show_header();
show_install();
}
for($i=0; $i<5;$i++){
showjsmessage(lang('begin_establish_data_tables'));
}
$sql = file_get_contents($sqlfile);
$sql = str_replace("\r\n", "\n", $sql);
runquery($sql);
for($i=0; $i<5;$i++){
showjsmessage(lang('table_clear_success'));
}
runquery($extrasql);
for($i=0; $i<5;$i++){
showjsmessage(lang('start_importing_initialized_data'));
}
$sql = file_get_contents(ROOT_PATH.'./install/data/install_data.sql');
$sql = str_replace("\r\n", "\n", $sql);
runquery($sql);
for($i=0; $i<5;$i++){
showjsmessage(lang('start_importing_initialized_data1'));
}
for($i=0; $i<5;$i++){
showjsmessage(lang('set_system'));
}
$onlineip = $_SERVER['REMOTE_ADDR'];
$timestamp = time();
$backupdir = substr(md5($_SERVER['SERVER_ADDR'].$_SERVER['HTTP_USER_AGENT'].substr($timestamp, 0, 4)), 8, 6);
$ret = false;
if(is_dir(ROOT_PATH.'data/backup')) {
$ret = @rename(ROOT_PATH.'data/backup', ROOT_PATH.'data/backup_'.$backupdir);
}
if(!$ret) {
@mkdir(ROOT_PATH.'data/backup_'.$backupdir, 0777);
}
if(is_dir(ROOT_PATH.'data/backup_'.$backupdir)) {
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('backupdir', '$backupdir')");
}
$chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789abcdefghijklmnopqrstuvwxyz';
$siteuniqueid = 'DZZOFFICE'.$chars[date('y')%60].$chars[date('n')].$chars[date('j')].$chars[date('G')].$chars[date('i')].$chars[date('s')].substr(md5($onlineip.$timestamp), 0, 4).random(4);
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('authkey', '$authkey')");
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('siteuniqueid', '$siteuniqueid')");
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('adminemail', '$adminemail')");
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('backupdir', '".$backupdir."')");
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('verhash', '".random(3)."')");
//创建默认机构
if($company){
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('sitename', '".$company."')");
$db->query("REPLACE INTO {$tablepre}setting (skey, svalue) VALUES ('bbname', '".$company."')");
//插入默认机构
$db->query("INSERT INTO {$tablepre}organization (`orgid`,`orgname`, `forgid`, `fid`, `disp`, `dateline`, `usesize`, `maxspacesize`, `indesk`,`available`,`pathkey`,`syatemon`,`manageon`,`diron`)
VALUES( 1, '$company', 0, 1, 0, '$timestamp', 0, 0, 0,1,'_1_',1,1,1)");
//插入默认机构文件夹
$db->query("INSERT INTO {$tablepre}folder (`fid`,`pfid`, `uid`, `username`, `innav`, `fname`, `perm`, `perm_inherit`, `fsperm`,`disp`,`iconview`,`display`,`dateline`,`gid`,`flag`,`default`,`isdelete`,`deldateline`)
VALUES( 1, 0, 0, '', 1, '$company',7,7,0,0,4,0,'$timestamp', 1, 'organization','',0,0)");
//插入默认机构path路径
$db->query("INSERT INTO {$tablepre}resources_path (`fid`,`path`, `pathkey`) VALUES( 1, 'dzz:gid_1:$company/','_1_')");
//将管理员加入默认机构
$db->query("INSERT INTO {$tablepre}organization_user (`orgid`, `uid`,`jobid`, `dateline`) VALUES(1, 1, 0, '$timestamp')");
}
$db->query("UPDATE {$tablepre}cron SET lastrun='0', nextrun='".($timestamp + 3600)."'");
for($i=0; $i<5;$i++){
showjsmessage(lang('set_system1'));
}
for($i=0; $i<5;$i++){
showjsmessage(lang('import_division_data'));
}
install_districtdata();
for($i=0; $i<5;$i++){
showjsmessage(lang('import_division_data1'));
}
$yearmonth = date('Ym_', time());
loginit($yearmonth.'loginlog');
loginit($yearmonth.'cplog');
loginit($yearmonth.'errorlog');
dir_clear(ROOT_PATH.'./data/template');
dir_clear(ROOT_PATH.'./data/cache');
foreach($serialize_sql_setting as $k => $v) {
$v = addslashes(serialize($v));
$db->query("REPLACE INTO {$tablepre}setting VALUES ('$k', '$v')");
}
if($runqueryerror){
showjsmessage('<span class="red">'.lang('error_quit_msg').'</span>');
exit();
};
showjsmessage(lang('system_data_installation_successful'));
echo '<script type="text/javascript">function setlaststep() {document.getElementById("laststep").disabled=false;}</script><script type="text/javascript">setTimeout(function(){window.location=\'index.php?step=4\'}, 30000);setlaststep();</script>'."\r\n";
show_footer();
}
show_form($form_db_init_items, $error_msg);
} elseif($method == 'admin_init') {
$submit = true;
$adminemail = 'admin@dzzoffice.com';
$error_msg = array();
if(isset($form_admin_init_items) && is_array($form_admin_init_items)) {
foreach($form_admin_init_items as $key => $items) {
$$key = getgpc($key, 'p');
if(!isset($$key) || !is_array($$key)) {
$submit = false;
break;
}
foreach($items as $k => $v) {
$tmp = $$key;
$$k = $tmp[$k];
if(empty($$k) || !preg_match($v['reg'], $$k)) {
if(empty($$k) && !$v['required']) {
continue;
}
$submit = false;
VIEW_OFF or $error_msg[$key][$k] = 1;
}
}
}
} else {
$submit = false;
}
if($submit && !VIEW_OFF && $_SERVER['REQUEST_METHOD'] == 'POST') {
if($password != $password2) {
$error_msg['admininfo']['password2'] = 1;
$submit = false;
}
}
if($submit) {
$step = $step + 1;
if($username && $email && $password) {
if(strlen($username) > 30 || preg_match("/^$|^c:\\con\\con$|　|[,\"\s\t\<\>&]|^Guest/is", $username)) {
show_msg('admin_username_invalid', $username, 0);
} elseif(!strstr($email, '@') || $email != stripslashes($email) || $email != dhtmlspecialchars($email)) {
show_msg('admin_email_invalid', $email, 0);
}
}else {
show_msg('admininfo_invalid', '', 0);
}
$uid = 1 ;
$onlineip = $_SERVER['REMOTE_ADDR'];
$timestamp = time();
$salt=random(6);
$password = md5(md5($password).$salt);
$db = new dbstuff;
include ROOT_PATH.CONFIG;
$dbhost = $_config['db'][1]['dbhost'];
$dbname = $_config['db'][1]['dbname'];
$dbpw = $_config['db'][1]['dbpw'];
$dbuser = $_config['db'][1]['dbuser'];
$tablepre = $_config['db'][1]['tablepre'];
$db->connect($dbhost, $dbuser, $dbpw, $dbname, DBCHARSET);
$db->query("REPLACE INTO {$tablepre}user (uid, username,nickname, password, adminid, groupid, email, regdate,salt,authstr) VALUES ('$uid', '$username', '','$password', '1', '1', '$email', '".time()."','$salt','');");
$db->query("update {$tablepre}folder set `uid`=$uid,`username`='$username' where `fid` = 1");
$db->query("REPLACE INTO {$tablepre}user_status (uid, regip,lastip, lastvisit, lastactivity, lastsendmail, invisible, profileprogress) VALUES ('$uid', '', '','$timestamp', '$timestamp', '0', '0', '0');");
$query = $db->query("SELECT COUNT(*) FROM {$tablepre}user");
$totalmembers = $db->result($query, 0);
$userstats = array('totalmembers' => $totalmembers, 'newsetuser' => $username);
$ctype = 1;
$data = addslashes(serialize($userstats));
$db->query("REPLACE INTO {$tablepre}syscache (cname, ctype, dateline, data) VALUES ('userstats', '$ctype', '".time()."', '$data')");
header("location: index.php?step=5");
}
show_form($form_admin_init_items, $error_msg);
} elseif($method == 'ext_info') {
@touch($lockfile);
@unlink(ROOT_PATH.'./install/index.php');
@unlink(ROOT_PATH.'./install/update.php');
show_header();
echo '<iframe src="../misc.php?mod=syscache" style="display:none;"></iframe>';
echo '<h3>'.lang('install_successfully').'</h3>';
echo '<h4 class="red">'.lang('handwork_del').'"./install/index.php"</h4>';
echo '<div style="text-align:right;width:80%;padding-top:50px;"><a href="'.$bbserver.'" class="button" ><input type="button" value="'.lang('enter_desktop').'"></a></div>';
show_footer();
} elseif($method == 'install_check') {
if(file_exists($lockfile)) {
show_msg('installstate_succ');
} else {
show_msg('lock_file_not_touch', $lockfile, 0);
}
} elseif($method == 'tablepre_check') {
$dbinfo = getgpc('dbinfo');
extract($dbinfo);
if(check_db($dbhost, $dbuser, $dbpw, $dbname, $tablepre)) {
show_msg('tablepre_not_exists', 0);
} else {
show_msg('tablepre_exists', $tablepre, 0);
}
}

853
install/update.php
View File

@@ -1,853 +0,0 @@
<?php
/*
* @copyright Leyun Internet Technology(Shanghai) Co.,Ltd
* @license http://www.dzzoffice.com/licenses/license.txt
* @package DzzOffice
* @link http://www.dzzoffice.com
* @author zyx(zyx@dzz.cc)
*/
require '../core/coreBase.php';
@set_time_limit(0);
$cachelist = array();
$dzz = C::app();
$dzz->cachelist = $cachelist;
$dzz->init_cron = false;
$dzz->init_setting = true;
$dzz->init_user = false;
$dzz->init_session = false;
$dzz->init_misc = false;
$dzz->init();
$config = array(
'dbcharset' => $_G['config']['db']['1']['dbcharset'],
'charset' => $_G['config']['output']['charset'],
'tablepre' => $_G['config']['db']['1']['tablepre']
);
$theurl = 'update.php';
$_G['siteurl'] = preg_replace('/\/install\/$/i', '/', $_G['siteurl']);
if($_GET['from']) {
if(md5($_GET['from'].$_G['config']['security']['authkey']) != $_GET['frommd5']) {
$refererarr = parse_url(dreferer());
list($dbreturnurl, $dbreturnurlmd5) = explode("\t", authcode($_GET['from']));
if(md5($dbreturnurl) == $dbreturnurlmd5) {
$dbreturnurlarr = parse_url($dbreturnurl);
} else {
$dbreturnurlarr = parse_url($_GET['from']);
}
parse_str($dbreturnurlarr['query'], $dbreturnurlparamarr);
$operation = $dbreturnurlparamarr['operation'];
$version = $dbreturnurlparamarr['version'];
$release = $dbreturnurlparamarr['release'];
if(!$operation || !$version || !$release) {
show_msg('请求的参数不正确');
}
$time = $_G['timestamp'];
dheader('Location: '.$_G['siteurl'].basename($refererarr['path']).'?action=upgrade&operation='.$operation.'&version='.$version.'&release='.$release.'&ungetfrom='.$time.'&ungetfrommd5='.md5($time.$_G['config']['security']['authkey']));
}
}
$lockfile = DZZ_ROOT.'./data/update.lock';
if(file_exists($lockfile) && !$_GET['from']) {
show_msg('请您先手工删除 ./data/update.lock 文件，再次运行本文件进行升级。');
}
$sqlfile = 'data/install.sql';
if(!file_exists($sqlfile)) {
show_msg('SQL文件 '.$sqlfile.' 不存在');
}
if($_POST['delsubmit']) {
if(!empty($_POST['deltables'])) {
foreach ($_POST['deltables'] as $tname => $value) {
DB::query("DROP TABLE `".DB::table($tname)."`");
}
}
if(!empty($_POST['delcols'])) {
foreach ($_POST['delcols'] as $tname => $cols) {
foreach ($cols as $col => $indexs) {
if($col == 'PRIMARY') {
DB::query("ALTER TABLE ".DB::table($tname)." DROP PRIMARY KEY", 'SILENT');
} elseif($col == 'KEY' || $col == 'UNIQUE') {
foreach ($indexs as $index => $value) {
DB::query("ALTER TABLE ".DB::table($tname)." DROP INDEX `$index`", 'SILENT');
}
} else {
DB::query("ALTER TABLE ".DB::table($tname)." DROP `$col`");
}
}
}
}
show_msg('删除表和字段操作完成了', $theurl.'?step=cache');
}
function waitingdb($curstep, $sqlarray) {
global $theurl;
foreach($sqlarray as $key => $sql) {
$sqlurl .= '&sql[]='.md5($sql);
$sendsql .= '<img width="1" height="1" src="'.$theurl.'?step='.$curstep.'&waitingdb=1&sqlid='.$key.'">';
}
show_msg("优化数据表", $theurl.'?step=waitingdb&nextstep='.$curstep.$sqlurl.'&sendsql='.base64_encode($sendsql), 5000, 1);
}
if(empty($_GET['step'])) $_GET['step'] = 'start';
if($_GET['step'] == 'start') {
if(!C::t('setting')->fetch('bbclosed')) {
C::t('setting')->update('bbclosed', 1);
require_once libfile('function/cache');
updatecache('setting');
show_msg('您的站点未关闭，正在关闭，请稍后...', $theurl.'?step=start', 5000);
}
show_msg('说明：<br>本升级程序会参照最新的SQL文件，对数据库进行同步升级。<br>
请确保您已将最新版文件覆盖至本地文件。<br>升级会还原部分默认设置。<br><br>
<a href="'.$theurl.'?step=prepare'.($_GET['from'] ? '&from='.rawurlencode($_GET['from']).'&frommd5='.rawurlencode($_GET['frommd5']) : '').'">准备完毕，升级开始</a>');
} elseif ($_GET['step'] == 'waitingdb') {
$query = DB::fetch_all("SHOW FULL PROCESSLIST");
foreach($query as $row) {
if(in_array(md5($row['Info']), $_GET['sql'])) {
$list .= '[时长]:'.$row['Time'].'秒 [状态]:<b>'.$row['State'].'</b>[信息]:'.$row['Info'].'<br><br>';
}
}
if(empty($list) && empty($_GET['sendsql'])) {
$msg = '准备进入下一步操作，请稍后...';
$notice = '';
$url = "?step=$_GET[nextstep]";
$time = 5;
} else {
$msg = '正在升级数据，请稍后...';
$notice = '<br><br><b>以下是正在执行的数据库升级语句:</b><br>'.$list.base64_decode($_GET['sendsql']);
$sqlurl = implode('&sql[]=', $_GET['sql']);
$url = "?step=waitingdb&nextstep=$_GET[nextstep]&sql[]=".$sqlurl;
$time = 20;
}
show_msg($msg, $theurl.$url, $time*1000, 0, $notice);
} elseif ($_GET['step'] == 'prepare') {
$repeat=array();
/*//检查数据库表 app_market 中有无appurl重复的情况；
foreach(DB::fetch_all("select appid,appurl from ".DB::table('app_market')." where 1") as $value){
if(in_array($value['appurl'],$repeat)){
C::t('app_market')->update($value['appid'],array('appurl'=>$value['appurl'].'&appid='.$value['appid']));
}
$repeat[]=$value['appurl'];
}*/
show_msg('准备完毕，进入下一步数据库结构升级', $theurl.'?step=sql');
} elseif ($_GET['step'] == 'sql') {
$sql = implode('', file($sqlfile));
preg_match_all("/CREATE\s+TABLE.+?dzz\_(.+?)\s*\((.+?)\)\s*(ENGINE|TYPE)\s*=\s*(\w+)/is", $sql, $matches);
$newtables = empty($matches[1])?array():$matches[1];
$newsqls = empty($matches[0])?array():$matches[0];
if(empty($newtables) || empty($newsqls)) {
show_msg('SQL文件内容为空，请确认');
}
$i = empty($_GET['i'])?0:intval($_GET['i']);
$count_i = count($newtables);
if($i>=$count_i) {
show_msg('数据库结构升级完毕，进入下一步数据升级操作', $theurl.'?step=data');
}
$newtable = $newtables[$i];
$specid = intval($_GET['specid']);
$newcols = getcolumn($newsqls[$i]);
if(!$query = DB::query("SHOW CREATE TABLE ".DB::table($newtable), 'SILENT')) {
preg_match("/(CREATE TABLE .+?)\s*(ENGINE|TYPE)\s*=\s*(\w+)/is", $newsqls[$i], $maths);
$maths[3] = strtoupper($maths[3]);
if($maths[3] == 'MEMORY' || $maths[3] == 'HEAP') {
$type = " ENGINE=MEMORY".(empty($config['dbcharset'])?'':" DEFAULT CHARSET=$config[dbcharset]" );
} else {
$type =" ENGINE=MYISAM".(empty($config['dbcharset'])?'':" DEFAULT CHARSET=$config[dbcharset]" );
}
$usql = $maths[1].$type;
$usql = str_replace("CREATE TABLE IF NOT EXISTS dzz_", 'CREATE TABLE IF NOT EXISTS '.$config['tablepre'], $usql);
$usql = str_replace("CREATE TABLE dzz_", 'CREATE TABLE '.$config['tablepre'], $usql);
if(!DB::query($usql, 'SILENT')) {
show_msg('添加表 '.DB::table($newtable).' 出错,请手工执行以下SQL语句后,再重新运行本升级程序:<br><br>'.dhtmlspecialchars($usql));
} else {
$msg = '添加表 '.DB::table($newtable).' 完成';
}
} else {
$value = DB::fetch($query);
$oldcols = getcolumn($value['Create Table']);
$updates = array();
$allfileds =array_keys($newcols);
foreach ($newcols as $key => $value) {
if($key == 'PRIMARY') {
if($value != $oldcols[$key]) {
if(!empty($oldcols[$key])) {
$usql = "RENAME TABLE ".DB::table($newtable)." TO ".DB::table($newtable.'_bak');
if(!DB::query($usql, 'SILENT')) {
show_msg('升级表 '.DB::table($newtable).' 出错,请手工执行以下升级语句后,再重新运行本升级程序:<br><br><b>升级SQL语句</b>:<div style=\"position:absolute;font-size:11px;font-family:verdana,arial;background:#EBEBEB;padding:0.5em;\">'.dhtmlspecialchars($usql)."</div><br><b>Error</b>: ".DB::error()."<br><b>Errno.</b>: ".DB::errno());
} else {
$msg = '表改名 '.DB::table($newtable).' 完成！';
show_msg($msg, $theurl.'?step=sql&i='.$_GET['i']);
}
}
$updates[] = "ADD PRIMARY KEY $value";
}
} elseif ($key == 'KEY') {
foreach ($value as $subkey => $subvalue) {
if(!empty($oldcols['KEY'][$subkey])) {
if($subvalue != $oldcols['KEY'][$subkey]) {
$updates[] = "DROP INDEX `$subkey`";
$updates[] = "ADD INDEX `$subkey` $subvalue";
}
} else {
$updates[] = "ADD INDEX `$subkey` $subvalue";
}
}
} elseif ($key == 'UNIQUE') {
foreach ($value as $subkey => $subvalue) {
if(!empty($oldcols['UNIQUE'][$subkey])) {
if($subvalue != $oldcols['UNIQUE'][$subkey]) {
$updates[] = "DROP INDEX `$subkey`";
$updates[] = "ADD UNIQUE INDEX `$subkey` $subvalue";
}
} else {
$usql = "ALTER TABLE ".DB::table($newtable)." DROP INDEX `$subkey`";
DB::query($usql, 'SILENT');
$updates[] = "ADD UNIQUE INDEX `$subkey` $subvalue";
}
}
} else {
if(!empty($oldcols[$key])) {
if(strtolower($value) != strtolower($oldcols[$key])) {
$updates[] = "CHANGE `$key` `$key` $value";
}
} else {
$i = array_search($key, $allfileds);
$fieldposition = $i > 0 ? 'AFTER `'.$allfileds[$i-1].'`' : 'FIRST';
$updates[] = "ADD `$key` $value $fieldposition";
}
}
}
if(!empty($updates)) {
$usql = "ALTER TABLE ".DB::table($newtable)." ".implode(', ', $updates);
if(!DB::query($usql, 'SILENT')) {
show_msg('升级表 '.DB::table($newtable).' 出错,请手工执行以下升级语句后,再重新运行本升级程序:<br><br><b>升级SQL语句</b>:<div style=\"position:absolute;font-size:11px;font-family:verdana,arial;background:#EBEBEB;padding:0.5em;\">'.dhtmlspecialchars($usql)."</div><br><b>Error</b>: ".DB::error()."<br><b>Errno.</b>: ".DB::errno());
} else {
$msg = '升级表 '.DB::table($newtable).' 完成！';
}
} else {
$msg = '检查表 '.DB::table($newtable).' 完成，不需升级，跳过';
}
}
if($specid) {
$newtable = $spectable;
}
if(get_special_table_by_num($newtable, $specid+1)) {
$next = $theurl . '?step=sql&i='.($_GET['i']).'&specid='.($specid + 1);
} else {
$next = $theurl.'?step=sql&i='.($_GET['i']+1);
}
show_msg("[ $i / $count_i ] ".$msg, $next);
} elseif ($_GET['step'] == 'data') {
if(!$_GET['dp']){
if(!DB::result_first("select COUNT(*) from %t where skey=%s",array('setting','fileVersion'))){
C::t('setting')->update('fileVersion', '1');
}
if(!DB::result_first("select COUNT(*) from %t where skey=%s",array('setting','fileVersionNumber'))){
C::t('setting')->update('fileVersionNumber', '50');
}
if(!DB::result_first("select COUNT(*) from %t where skey=%s",array('setting','default_mod'))){
C::t('setting')->update('default_mod', 'index_simple');
}
if(!DB::result_first("select COUNT(*) from %t where skey=%s",array('setting','forbiddentime'))){
C::t('setting')->update('forbiddentime', '900');
}
if(!DB::result_first("select COUNT(*) from %t where skey=%s",array('setting','numberoflogins'))){
C::t('setting')->update('numberoflogins', '5');
}
if(!DB::result_first("select COUNT(*) from %t where skey=%s",array('setting','notification'))){
C::t('setting')->update('notification', '60');
}
if(!DB::result_first("select COUNT(*) from %t where appurl=%s",array('app_market','{adminscript}?mod=appmanagement'))){
DB::delete('app_market', array('appurl' => '{dzzscript}?mod=appmanagement'));
C::t('app_market')->insert(array('appname'=>'管理',
'appico'=>'appico/201712/21/184312rthhhg9oujti9tuu.png',
'appurl'=>'{adminscript}?mod=appmanagement',
'appdesc'=>'管理员应用集合，方便管理员管理各个管理应用',
'dateline'=>TIMESTAMP,
'disp'=>1,
'mid'=>1,
'vendor'=>'乐云网络',
'group'=>3,
'haveflash'=>0,
'isshow'=>1,
'havetask'=>0,
'hideInMarket'=>0,
'system'=>2,
'notdelete'=>1,
'position'=>1,
'open'=>1,
'app_path'=>'admin',
'identifier'=>'appmanagement',
'version'=>'2.0',
'check_upgrade_time'=>'20171115',
'available'=>1),0,1);
}
if(!DB::result_first("select COUNT(*) from %t where appurl=%s",array('app_market','{dzzscript}?mod=filemanage'))){
C::t('app_market')->insert(array('appname'=>'文件管理',
'appico'=>'appico/201712/21/175535t47bad99b7sssdwq.png',
'appurl'=>'{dzzscript}?mod=filemanage',
'appdesc'=>'管理和查看系统所有文件',
'dateline'=>TIMESTAMP,
'disp'=>6,
'mid'=>6,
'vendor'=>'乐云网络',
'haveflash'=>0,
'isshow'=>1,
'havetask'=>1,
'hideInMarket'=>0,
'group'=>1,
'position'=>1,
'system'=>2,
'notdelete'=>1,
'open'=>1,
'nodup'=>0,
'identifier'=>'filemanage',
'app_path'=>'dzz',
'available'=>1,
'version'=>'2.0',
'check_upgrade_time'=>'20180206'),0,1);
}else{
DB::delete('app_market', array('appurl' => '{adminscript}?mod=filemanage'));
}
if(!DB::result_first("select COUNT(*) from %t where appurl=%s",array('app_market','{dzzscript}?mod=share'))){
C::t('app_market')->insert(array('appname'=>'分享管理',
'appico'=>'appico/201712/21/165535t47bad99b7qqqdwq.png',
'appurl'=>'{dzzscript}?mod=share',
'appdesc'=>'管理和查阅所有分享',
'dateline'=>TIMESTAMP,
'disp'=>7,
'mid'=>7,
'vendor'=>'乐云网络',
'haveflash'=>0,
'isshow'=>1,
'havetask'=>1,
'hideInMarket'=>0,
'group'=>1,
'position'=>1,
'system'=>2,
'notdelete'=>1,
'open'=>1,
'nodup'=>0,
'identifier'=>'share',
'app_path'=>'dzz',
'available'=>1,
'version'=>'2.0',
'check_upgrade_time'=>'20180206'),0,1);
}else{
DB::delete('app_market', array('appurl' => '{adminscript}?mod=share'));
}
if(!DB::result_first("select COUNT(*) from %t where appurl=%s",array('app_market','{dzzscript}?mod=comment'))){
C::t('app_market')->insert(array('appname'=>'评论',
'appico'=>'appico/201712/21/128754pb0s666i6sjws1jc.png',
'appurl'=>'{dzzscript}?mod=comment',
'appdesc'=>'Dzz 系统评论组件，结合在其他应用使用，如新闻。其他开发者也可以为自己的应用调用这个通用评论插件',
'dateline'=>TIMESTAMP,
'disp'=>12,
'mid'=>12,
'vendor'=>'乐云网络',
'haveflash'=>0,
'isshow'=>1,
'havetask'=>1,
'hideInMarket'=>0,
'group'=>1,
'position'=>1,
'system'=>2,
'notdelete'=>1,
'open'=>1,
'nodup'=>0,
'identifier'=>'comment',
'app_path'=>'dzz',
'available'=>1,
'version'=>'2.0',
'check_upgrade_time'=>'20171115'),0,1);
}
//处理更新之后群组开关问题
DB::update('organization',array('manageon'=>1,'available'=>1,'syatemon'=>1),"1");
show_msg("基本设置修改完成", "$theurl?step=data&dp=1");
}elseif($_GET['dp']==1){ //转换机构和部门数据
$i = empty($_GET['i'])?0:intval($_GET['i']);
$count_i = DB::result_first("select COUNT(*) from %t where 1 ",array('organization'));
if($i>=$count_i) {
show_msg('部门数据升级完成，进入下一步操作', $theurl.'?step=data&dp=2');
}
if($orgid=DB::result_first("select orgid from %t where 1 order by orgid limit $i,1 ",array('organization'))){
C::t('organization')->setPathkeyByOrgid($orgid,1);
}
$i++;
$msg='部门数据转换完成';
$next=$theurl.'?step=data&dp=1&i='.$i;
show_msg("[ $i / $count_i ] ".$msg, $next);
}elseif($_GET['dp']==2){ //修复目录gid
$i = empty($_GET['i'])?0:intval($_GET['i']);
$count_i = DB::result_first("select COUNT(*) from %t where gid>0 ",array('folder'));
if($i>=$count_i) {
show_msg('开始修复继承权限...', $theurl.'?step=data&dp=3');
}
$arr=DB::fetch_first("select fid,pfid,gid,fname from %t where gid>0 order by fid limit $i,1",array('folder'));
$gid=C::t('folder')->fetch_gid_by_fid($arr['fid']);
if($gid!=$arr['gid']){
C::t('folder')->update($arr['fid'],array('gid'=>$gid));
DB::query("update %t set gid=%d where pfid=%d ",array('resources',$gid,$arr['fid']));
}
$i++;
$msg='部门文件夹修复完成';
$next=$theurl.'?step=data&dp=2&i='.$i;
show_msg("[ $i / $count_i ] ".$msg, $next);
}elseif($_GET['dp']==3){ //更新继承权限和路径
$i = empty($_GET['i'])?0:intval($_GET['i']);
$count_i = DB::result_first("select COUNT(*) from %t",array('folder'));
if($i>=$count_i) {
show_msg('开始修复回收站...', $theurl.'?step=data&dp=4');
}
$arr=DB::fetch_first("select fid from %t order by fid limit $i,1",array('folder'));
$pdata = C::t('folder')->create_pathinfo_by_fid($arr['fid']);
if($pdata){
if(!DB::result_first("select count(*) from %t where fid = %d",array('resources_path',$arr['fid']))){
$pdata['fid'] = $arr['fid'];
DB::insert('resources_path',$pdata);
}else{
DB::update('resources_path',$pdata,array('fid'=>$arr['fid']));
}
}
$perm_inherit=perm_check::getPerm1($arr['fid']);
DB::update('folder',array('perm_inherit'=>$perm_inherit),"fid='{$arr[fid]}'");
$i++;
$msg='继承权限修复';
$next=$theurl.'?step=data&dp=3&i='.$i;
show_msg("[ $i / $count_i ] ".$msg, $next);
}elseif($_GET['dp']==4){ //修改回收站相关
//回收站数据处理
$rids = $delfids = $delrids = array();
foreach(DB::fetch_all("select rid from %t where isdelete>0",array('resources')) as $v){
$delrids[] = $v['rid'];
if($v['type'] == 'folder' && $v['oid']){
$delfids[] = $v['oid'];
}
}
//更改resources表数据
if(count($delrids) > 0) DB::update("resources",array('pfid'=>-1),'rid in('.dimplode($delrids).')');
//更改folder表数据
if(count($delfids) > 0) DB::update("folder",array('pfid'=>-1),'fid in('.dimplode($delfids).')');
//清除回收站中的无用数据
DB::delete('resources_recyle','rid not in('.dimplode($delrids).')');
}
show_msg("数据升级结束", "$theurl?step=delete");
}elseif ($_GET['step'] == 'delete') {
$oldtables = array();
$query = DB::query("SHOW TABLES LIKE '$config[tablepre]%'");
while ($value = DB::fetch($query)) {
$values = array_values($value);
$oldtables[] = $values[0];
}
$sql = implode('', file($sqlfile));
preg_match_all("/CREATE\s+TABLE.+?dzz\_(.+?)\s+\((.+?)\)\s*(ENGINE|TYPE)\s*\=/is", $sql, $matches);
$newtables = empty($matches[1])?array():$matches[1];
$newsqls = empty($matches[0])?array():$matches[0];
$deltables = array();
$delcolumns = array();
foreach ($oldtables as $tname) {
$tname = substr($tname, strlen($config['tablepre']));
if(in_array($tname, $newtables)) {
$query = DB::query("SHOW CREATE TABLE ".DB::table($tname));
$cvalue = DB::fetch($query);
$oldcolumns = getcolumn($cvalue['Create Table']);
$i = array_search($tname, $newtables);
$newcolumns = getcolumn($newsqls[$i]);
foreach ($oldcolumns as $colname => $colstruct) {
if($colname == 'UNIQUE' || $colname == 'KEY') {
foreach ($colstruct as $key_index => $key_value) {
if(empty($newcolumns[$colname][$key_index])) {
$delcolumns[$tname][$colname][$key_index] = $key_value;
}
}
} else {
if(empty($newcolumns[$colname])) {
$delcolumns[$tname][] = $colname;
}
}
}
} else {
}
}
show_header();
echo '<form method="post" autocomplete="off" action="'.$theurl.'?step=delete'.($_GET['from'] ? '&from='.rawurlencode($_GET['from']).'&frommd5='.rawurlencode($_GET['frommd5']) : '').'">';
$deltablehtml = '';
if($deltables) {
$deltablehtml .= '<table>';
foreach ($deltables as $tablename) {
$deltablehtml .= "<tr><td><input type=\"checkbox\" name=\"deltables[$tablename]\" value=\"1\"></td><td>{$config['tablepre']}$tablename</td></tr>";
}
$deltablehtml .= '</table>';
echo "<p>以下 <strong>数据表</strong> 与标准数据库相比是多余的:<br>您可以根据需要自行决定是否删除</p>$deltablehtml";
}
$delcolumnhtml = '';
if($delcolumns) {
$delcolumnhtml .= '<table>';
foreach ($delcolumns as $tablename => $cols) {
foreach ($cols as $coltype => $col) {
if (is_array($col)) {
foreach ($col as $index => $indexvalue) {
$delcolumnhtml .= "<tr><td><input type=\"checkbox\" name=\"delcols[$tablename][$coltype][$index]\" value=\"1\"></td><td>{$config['tablepre']}$tablename</td><td>索引($coltype) $index $indexvalue</td></tr>";
}
} else {
$delcolumnhtml .= "<tr><td><input type=\"checkbox\" name=\"delcols[$tablename][$col]\" value=\"1\"></td><td>{$config['tablepre']}$tablename</td><td>字段 $col</td></tr>";
}
}
}
$delcolumnhtml .= '</table>';
echo "<p>以下 <strong>字段</strong> 与标准数据库相比是多余的:<br>您可以根据需要自行决定是否删除(建议删除)</p>$delcolumnhtml";
}
if(empty($deltables) && empty($delcolumns)) {
echo "<p>与标准数据库相比，没有需要删除的数据表和字段</p><a href=\"$theurl?step=cache".($_GET['from'] ? '&from='.rawurlencode($_GET['from']).'&frommd5='.rawurlencode($_GET['frommd5']) : '')."\">请点击进入下一步</a></p>";
} else {
echo "<p><input type=\"submit\" name=\"delsubmit\" value=\"提交删除\"></p><p>您也可以忽略多余的表和字段<br><a href=\"$theurl?step=cache".($_GET['from'] ? '&from='.rawurlencode($_GET['from']).'&frommd5='.rawurlencode($_GET['frommd5']) : '')."\">直接进入下一步</a></p>";
}
echo '</form>';
show_footer();
exit();
} elseif ($_GET['step'] == 'cache') {
if(@$fp = fopen($lockfile, 'w')) {
fwrite($fp, ' ');
fclose($fp);
}
//删除数据库恢复文件，防止一些安全问题；
@unlink(DZZ_ROOT.'./data/restore.php');
dir_clear(DZZ_ROOT.'./data/template');
dir_clear(DZZ_ROOT.'./data/cache');
savecache('setting', '');
if($_GET['from']) {
show_msg('<span id="finalmsg">缓存更新中，请稍候 ...</span><iframe src="../misc.php?mod=syscache" style="display:none;" onload="parent.window.location.href=\''.$_GET['from'].'\'"></iframe><iframe src="../misc.php?mod=setunrun" style="display:none;"></iframe>');
} else {
show_msg('<span id="finalmsg">缓存更新中，请稍候 ...</span><iframe src="../misc.php?mod=syscache" style="display:none;" onload="document.getElementById(\'finalmsg\').innerHTML = \'恭喜，数据库结构升级完成！为了数据安全，请删除本文件。'.$opensoso.'\'"></iframe><iframe src="../misc.php?mod=setunrun" style="display:none;"></iframe>');
}
}
function has_another_special_table($tablename, $key) {
if(!$key) {
return $tablename;
}
$tables_array = get_special_tables_array($tablename);
if($key > count($tables_array)) {
return FALSE;
} else {
return TRUE;
}
}
function converttodzzcode($aid){
return 'path='.dzzencode('attach::'.$aid);
}
function get_special_tables_array($tablename) {
$tablename = DB::table($tablename);
$tablename = str_replace('_', '\_', $tablename);
$query = DB::query("SHOW TABLES LIKE '{$tablename}\_%'");
$dbo = DB::object();
$tables_array = array();
while($row = $dbo->fetch_array($query, $dbo->drivertype == 'mysqli' ? MYSQLI_NUM : MYSQL_NUM)) {
if(preg_match("/^{$tablename}_(\\d+)$/i", $row[0])) {
$prefix_len = strlen($dbo->tablepre);
$row[0] = substr($row[0], $prefix_len);
$tables_array[] = $row[0];
}
}
return $tables_array;
}
function get_special_table_by_num($tablename, $num) {
$tables_array = get_special_tables_array($tablename);
$num --;
return isset($tables_array[$num]) ? $tables_array[$num] : FALSE;
}
function getcolumn($creatsql) {
$creatsql = preg_replace("/ COMMENT '.*?'/i", '', $creatsql);
preg_match("/\((.+)\)\s*(ENGINE|TYPE)\s*\=/is", $creatsql, $matchs);
$cols = explode("\n", $matchs[1]);
$newcols = array();
foreach ($cols as $value) {
$value = trim($value);
if(empty($value)) continue;
$value = remakesql($value);
if(substr($value, -1) == ',') $value = substr($value, 0, -1);
$vs = explode(' ', $value);
$cname = $vs[0];
if($cname == 'KEY' || $cname == 'INDEX' || $cname == 'UNIQUE') {
$name_length = strlen($cname);
if($cname == 'UNIQUE') $name_length = $name_length + 4;
$subvalue = trim(substr($value, $name_length));
$subvs = explode(' ', $subvalue);
$subcname = $subvs[0];
$newcols[$cname][$subcname] = trim(substr($value, ($name_length+2+strlen($subcname))));
} elseif($cname == 'PRIMARY') {
$newcols[$cname] = trim(substr($value, 11));
} else {
$newcols[$cname] = trim(substr($value, strlen($cname)));
}
}
return $newcols;
}
function remakesql($value) {
$value = trim(preg_replace("/\s+/", ' ', $value));
$value = str_replace(array('`',', ', ' ,', '( ' ,' )', 'mediumtext'), array('', ',', ',','(',')','text'), $value);
return $value;
}
function show_msg($message, $url_forward='', $time = 1, $noexit = 0, $notice = '') {
if($url_forward) {
$url_forward = $_GET['from'] ? $url_forward.'&from='.rawurlencode($_GET['from']).'&frommd5='.rawurlencode($_GET['frommd5']) : $url_forward;
$message = "<a href=\"$url_forward\">$message (跳转中...)</a><br>$notice<script>setTimeout(\"window.location.href ='$url_forward';\", $time);</script>";
}
show_header();
print<<<END
<table>
<tr><td>$message</td></tr>
</table>
END;
show_footer();
!$noexit && exit();
}
function show_header() {
global $config;
$nowarr = array($_GET['step'] => ' class="current"');
if(in_array($_GET['step'], array('waitingdb','prepare'))) {
$nowarr = array('sql' => ' class="current"');
}
print<<<END
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=$config[charset]" />
<title> 数据库升级程序 </title>
<style type="text/css">
* {font-size:12px; font-family: Verdana, Arial, Helvetica, sans-serif; line-height: 1.5em; word-break: break-all; }
body { text-align:center; margin: 0; padding: 0; background: #F5FBFF; }
.bodydiv { margin: 40px auto 0; width:720px; text-align:left; border: solid #86B9D6; border-width: 5px 1px 1px; background: #FFF; }
h1 { font-size: 18px; margin: 1px 0 0; line-height: 50px; height: 50px; background: #E8F7FC; color: #5086A5; padding-left: 10px; }
#menu {width: 100%; margin: 10px auto; text-align: center; }
#menu td { height: 30px; line-height: 30px; color: #999; border-bottom: 3px solid #EEE; }
.current { font-weight: bold; color: #090 !important; border-bottom-color: #F90 !important; }
input { border: 1px solid #B2C9D3; padding: 5px; background: #F5FCFF; }
#footer { font-size: 10px; line-height: 40px; background: #E8F7FC; text-align: center; height: 38px; overflow: hidden; color: #5086A5; margin-top: 20px; }
</style>
</head>
<body>
<div class="bodydiv">
<h1>DzzOffice 小胡版 数据库升级工具</h1>
<div style="width:90%;margin:0 auto;">
<table id="menu">
<tr>
<td{$nowarr[start]}>升级开始</td>
<td{$nowarr[sql]}>数据库结构添加与更新</td>
<td{$nowarr[data]}>数据更新</td>
<td{$nowarr[delete]}>数据库结构删除</td>
<td{$nowarr[cache]}>升级完成</td>
</tr>
</table>
<br>
END;
}
function show_footer() {
print<<<END
</div>
<div id="footer">Copyright © 2012-2017 DzzOffice.com All Rights Reserved.</div>
</div>
<br>
</body>
</html>
END;
}
function runquery($sql) {
global $_G;
$tablepre = $_G['config']['db'][1]['tablepre'];
$dbcharset = $_G['config']['db'][1]['dbcharset'];
$sql = str_replace("\r", "\n", str_replace(array(' {tablepre}', ' dzz_', ' `dzz_'), array(' '.$tablepre, ' '.$tablepre, ' `'.$tablepre), $sql));
$ret = array();
$num = 0;
foreach(explode(";\n", trim($sql)) as $query) {
$queries = explode("\n", trim($query));
foreach($queries as $query) {
$ret[$num] .= $query[0] == '#' || $query[0].$query[1] == '--' ? '' : $query;
}
$num++;
}
unset($sql);
foreach($ret as $query) {
$query = trim($query);
if($query) {
if(substr($query, 0, 12) == 'CREATE TABLE') {
$name = preg_replace("/CREATE TABLE ([a-z0-9_]+) .*/is", "\\1", $query);
DB::query(create_table($query, $dbcharset));
} else {
DB::query($query);
}
}
}
}
function save_config_file($filename, $config, $default, $deletevar) {
$config = setdefault($config, $default, $deletevar);
$date = gmdate("Y-m-d H:i:s", time() + 3600 * 8);
$content = <<<EOT
<?php
\$_config = array();
EOT;
$content .= getvars(array('_config' => $config));
$content .= "\r\n// ".str_pad(' THE END ', 50, '-', STR_PAD_BOTH)." //\r\n\r\n?>";
if(!is_writable($filename) || !($len = file_put_contents($filename, $content))) {
file_put_contents(DZZ_ROOT.'./data/config.php', $content);
return 0;
}
return 1;
}
function setdefault($var, $default, $deletevar) {
foreach ($default as $k => $v) {
if(!isset($var[$k])) {
$var[$k] = $default[$k];
} elseif(is_array($v)) {
$var[$k] = setdefault($var[$k], $default[$k]);
}
}
foreach ($deletevar as $k) {
unset($var[$k]);
}
return $var;
}
function getvars($data, $type = 'VAR') {
$evaluate = '';
foreach($data as $key => $val) {
if(!preg_match("/^[a-zA-Z_\x7f-\xff][a-zA-Z0-9_\x7f-\xff]*$/", $key)) {
continue;
}
if(is_array($val)) {
$evaluate .= buildarray($val, 0, "\${$key}")."\r\n";
} else {
$val = addcslashes($val, '\'\\');
$evaluate .= $type == 'VAR' ? "\$$key = '$val';\n" : "define('".strtoupper($key)."', '$val');\n";
}
}
return $evaluate;
}
function buildarray($array, $level = 0, $pre = '$_config') {
static $ks;
if($level == 0) {
$ks = array();
$return = '';
}
foreach ($array as $key => $val) {
if($level == 0) {
$newline = str_pad(' CONFIG '.strtoupper($key).' ', 70, '-', STR_PAD_BOTH);
$return .= "\r\n// $newline //\r\n";
if($key == 'admincp') {
$newline = str_pad(' Founders: $_config[\'admincp\'][\'founder\'] = \'1,2,3\'; ', 70, '-', STR_PAD_BOTH);
$return .= "// $newline //\r\n";
}
}
$ks[$level] = $ks[$level - 1]."['$key']";
if(is_array($val)) {
$ks[$level] = $ks[$level - 1]."['$key']";
$return .= buildarray($val, $level + 1, $pre);
} else {
$val = is_string($val) || strlen($val) > 12 || !preg_match("/^\-?[1-9]\d*$/", $val) ? '\''.addcslashes($val, '\'\\').'\'' : $val;
$return .= $pre.$ks[$level - 1]."['$key']"." = $val;\r\n";
}
}
return $return;
}
function dir_clear($dir) {
global $lang;
if($directory = @dir($dir)) {
while($entry = $directory->read()) {
$filename = $dir.'/'.$entry;
if(is_file($filename)) {
@unlink($filename);
}
}
$directory->close();
@touch($dir.'/index.htm');
}
}
function create_table($sql, $dbcharset) {
$type = strtoupper(preg_replace("/^\s*CREATE TABLE\s+.+\s+\(.+?\).*(ENGINE|TYPE)\s*=\s*([a-z]+?).*$/isU", "\\2", $sql));
$type = in_array($type, array('MYISAM', 'HEAP', 'MEMORY')) ? $type : 'MYISAM';
return preg_replace("/^\s*(CREATE TABLE\s+.+\s+\(.+?\)).*$/isU", "\\1", $sql).
(" ENGINE=$type DEFAULT CHARSET=".$dbcharset);
}
?>