tov6/index.php

<?php

/**
 * @version        $Id: index.php 2020-11-18 tianya $
 * @copyright      Copyright (c) 2020, DedeBIZ.COM
 * @license        https://www.dedebiz.com/license
 * @link           https://www.dedebiz.com
 */
// 把大象装冰箱，总共分几步？
// 1.数据库转码
// 2.文件选择性覆盖
$cfg_NotPrintHead = "Y";
require_once(dirname(__FILE__) . "/../include/common.inc.php");
require_once(dirname(__FILE__) . "/common.func.php");

define("TOV6LOCK", DEDEDATA . "/cache/tov6.lock.txt");

$bkdir = DEDEDATA . '/' . $cfg_backup_dir . "/tov6";
MkdirAll($bkdir, $GLOBALS['cfg_dir_purview']);

$step = isset($step) ? intval($step) : 0;

//跳转到一下页的JS
$gotojs = "function GotoNextPage(){
    document.gonext." . "submit();
}" . "\r\nset" . "Timeout('GotoNextPage()',500);";

$dojs = "<script language='javascript'>$gotojs</script>";

if (empty($tablearr)) {
	$dsql->SetQuery("SHOW TABLES");
	$dsql->Execute('t');
	while ($row = $dsql->GetArray('t', MYSQL_BOTH)) {
		if (preg_match("#^{$cfg_dbprefix}#", $row[0]) || in_array($row[0], $channelTables)) {
			$dedeSysTables[] = $row[0];
		}
	}
	$tablearr = implode(",", $dedeSysTables);
}

if (empty($bakfiles)) {
	$dh = dir($bkdir);
	$structfile = "";
	while (($filename = $dh->read()) !== false) {
		if (!preg_match("#txt$#", $filename)) {
			continue;
		}
		if (preg_match("#tables_struct#", $filename)) {
			$structfile = $filename;
		} else if (filesize("$bkdir/$filename") > 0) {
			$filelists[] = $filename;
		}
	}
	$dh->close();
	$bakfiles = implode(",", $filelists);
}

if (file_exists(TOV6LOCK)) {
	ShowMsgV6("<p>已经成功执行升级程序，无需重复执行。</p><p>如果您需要获取升级服务，可以<a target='_blank' href='https://www.dedebiz.com/contact#contact'>联系官方</a>协助升级。</p>", "javascript:;");
}

if ($step == 0) {
	ShowMsgV6("<p>执行升级程序之前，您需要<font color=red>备份站点数据库及文件</font>，如果已经完成备份，可以点击下面“开始升级到V6”进行升级！<br><a target='_blank' class='btn btn-outline-success' href='https://www.dedebiz.com/help/tov6.md'>升级文档</a> <a class='btn btn-success' href='index.php?step=1'>开始升级到V6</a></p><p>如果您需要获取升级服务，也可以<a target='_blank' href='https://www.dedebiz.com/contact#contact'>联系官方</a>协助升级。</p>", "javascript:;");
}

// 对数据库进行编码转换
else if ($step == 1) {
	if ($cfg_soft_lang === "gb2312") {
		//初始化使用到的变量
		$tables = explode(',', $tablearr);
		$isstruct = 1;
		if (!isset($startpos)) {
			$startpos = 0;
		}
		if (!isset($iszip)) {
			$iszip = 0;
		}
		if (empty($nowtable)) {
			$nowtable = '';
		}
		if (empty($fsize)) {
			$fsize = 2048;
		}
		$fsizeb = $fsize * 1024;

		//第一页的操作
		if ($nowtable == '') {
			$tmsg = '';
			$dh = dir($bkdir);
			while ($filename = $dh->read()) {
				if (!preg_match("#txt$#", $filename)) {
					continue;
				}
				$filename = $bkdir . "/$filename";
				if (!is_dir($filename)) {
					unlink($filename);
				}
			}
			$dh->close();
			$tmsg .= "发现是GBK编码系统，需要进行数据库转码...<br />";

			if ($isstruct == 1) {
				$bkfile = $bkdir . "/tables_struct_" . substr(md5(time() . mt_rand(1000, 5000) . $cfg_cookie_encode), 0, 16) . ".txt";
				$mysql_version = $dsql->GetVersion();
				$fp = fopen($bkfile, "w");
				foreach ($tables as $t) {
					$ttt = str_replace($cfg_dbprefix, $cfg_dbprefix . "v6_", $t);
					fwrite($fp, "DROP TABLE IF EXISTS `$ttt`;\r\n\r\n");
					$dsql->SetQuery("SHOW CREATE TABLE " . $dsql->dbName . "." . $t);
					$dsql->Execute('me');
					$row = $dsql->GetArray('me', MYSQL_BOTH);

					//去除AUTO_INCREMENT
					$row[1] = preg_replace("#AUTO_INCREMENT=([0-9]{1,})[ \r\n\t]{1,}#i", "", $row[1]);
					$eng1 = "#ENGINE=MyISAM[ \r\n\t]{1,}DEFAULT[ \r\n\t]{1,}CHARSET=gbk#i";
					$row[1] = preg_replace($eng1, "ENGINE=MyISAM CHARSET=utf8", $row[1]);

					$row[1] = str_replace("CREATE TABLE `" . $cfg_dbprefix, "CREATE TABLE `" . $cfg_dbprefix . "v6_", $row[1]);

					$tableStruct = $row[1];

					$tableStruct = gb2utf8($tableStruct);

					fwrite($fp, '' . $tableStruct . ";\r\n\r\n");
				}
				fclose($fp);
				$tmsg .= "转化数据表结构信息完成...<br />";
			}
			$tmsg .= "<font color='red'>正在进行数据转化的初始化工作，请稍后...</font>";
			$doneForm = "<form name='gonext' method='post' action='index.php'>
	           <input type='hidden' name='isstruct' value='$isstruct' />
	           <input type='hidden' name='step' value='1' />
	           <input type='hidden' name='fsize' value='$fsize' />
	           <input type='hidden' name='tablearr' value='$tablearr' />
	           <input type='hidden' name='nowtable' value='{$tables[0]}' />
	           <input type='hidden' name='startpos' value='0' />
	           <input type='hidden' name='iszip' value='$iszip' />\r\n</form>\r\n{$dojs}\r\n";
			PutInfo($tmsg, $doneForm);
			exit();
		}
		//执行分页备份
		else {
			$j = 0;
			$fs = array();
			$bakStr = '';

			//分析表里的字段信息
			$dsql->GetTableFields($nowtable);
			$tmpNowtable = str_replace($cfg_dbprefix, $cfg_dbprefix . "v6_", $nowtable);
			$intable = "INSERT INTO `$tmpNowtable` VALUES(";
			while ($r = $dsql->GetFieldObject()) {
				$fs[$j] = trim($r->name);
				$j++;
			}

			$fsd = $j - 1;

			//读取表的内容
			$dsql->SetQuery("SELECT * FROM `$nowtable` ");
			$dsql->Execute();
			$m = 0;
			$bakfilename = "$bkdir/{$nowtable}_{$startpos}_" . substr(md5(time() . mt_rand(1000, 5000) . $cfg_cookie_encode), 0, 16) . ".txt";

			while ($row2 = $dsql->GetArray()) {

				if ($m < $startpos) {
					$m++;
					continue;
				}

				//检测数据是否达到规定大小
				if (strlen($bakStr) > $fsizeb) {
					$fp = fopen($bakfilename, "w");
					$bakStr = gb2utf8($bakStr);
					fwrite($fp, $bakStr);
					fclose($fp);
					$tmsg = "<font color='red'>完成到{$m}条记录的转化，继续转化{$nowtable}...</font>";
					$doneForm = "<form name='gonext' method='post' action='index.php'>
	                <input type='hidden' name='step' value='1' />
	                <input type='hidden' name='isstruct' value='$isstruct' />
	                <input type='hidden' name='dopost' value='bak' />
	                <input type='hidden' name='fsize' value='$fsize' />
	                <input type='hidden' name='tablearr' value='$tablearr' />
	                <input type='hidden' name='nowtable' value='$nowtable' />
	                <input type='hidden' name='startpos' value='$m' />
	                <input type='hidden' name='iszip' value='$iszip' />\r\n</form>\r\n{$dojs}\r\n";
					PutInfo($tmsg, $doneForm);
					exit();
				}

				//正常情况
				$line = $intable;
				for ($j = 0; $j <= $fsd; $j++) {
					if ($j < $fsd) {
						$line .= "'" . RpLine(addslashes($row2[$fs[$j]])) . "',";
					} else {
						$line .= "'" . RpLine(addslashes($row2[$fs[$j]])) . "');\r\n";
					}
				}
				$m++;
				$bakStr .= $line;
			}

			//如果数据比卷设置值小
			if ($bakStr != '') {
				$fp = fopen($bakfilename, "w");
				$bakStr = gb2utf8($bakStr);
				fwrite($fp, $bakStr);
				fclose($fp);
			}
			for ($i = 0; $i < count($tables); $i++) {
				if ($tables[$i] == $nowtable) {
					if (isset($tables[$i + 1])) {
						$nowtable = $tables[$i + 1];
						$startpos = 0;
						break;
					} else {
						ShowMsgV6('完成数据备份转码，下面进行还原……', 'index.php?step=2');
						exit();
					}
				}
			}
			$tmsg = "<font color='red'>完成到{$m}条记录的转码，继续转码{$nowtable}...</font>";
			$doneForm = "<form name='gonext' method='post' action='index.php'>
	          <input type='hidden' name='isstruct' value='$isstruct' />
	          <input type='hidden' name='step' value='1' />
	          <input type='hidden' name='fsize' value='$fsize' />
	          <input type='hidden' name='tablearr' value='$tablearr' />
	          <input type='hidden' name='nowtable' value='$nowtable' />
	          <input type='hidden' name='startpos' value='$startpos'>\r\n</form>\r\n{$dojs}\r\n";
			PutInfo($tmsg, $doneForm);
			exit();
		}
		//分页备份代码结束
	} else {
		ShowMsgV6('当前系统就是UTF8程序，无需数据库编码转换，进行DedeCMSV6升级……', 'index.php?step=3');
		exit();
	}
}
// 还原为UTF8编码的文件
else if ($step == 2) {
	if ($cfg_soft_lang === "gb2312") {
		@list($dbhost, $dbport) = explode(':', $GLOBALS['cfg_dbhost']);
		!$dbport && $dbport = 3306;
		$conn = mysqli_init();
		mysqli_real_connect($conn, $dbhost, $GLOBALS['cfg_dbuser'], $GLOBALS['cfg_dbpwd'], false, $dbport) or die("无法连接数据库");
		mysqli_query($conn, "SET character_set_connection=utf8,character_set_results=utf8,character_set_client=binary");
		mysqli_select_db($conn, $GLOBALS['cfg_dbname']);
		$bakfilesTmp = $bakfiles;
		$bakfiles = explode(',', $bakfiles);
		if (empty($structfile)) {
			$structfile = "";
		}
		if (empty($delfile)) {
			$delfile = 1;
		}
		if (empty($startgo)) {
			$startgo = 0;
		}
		if ($startgo == 0 && $structfile != '') {
			$tbdata = '';
			$fp = fopen("$bkdir/$structfile", 'r');
			while (!feof($fp)) {
				$tbdata .= fgets($fp, 1024);
			}
			fclose($fp);
			$querys = explode(';', $tbdata);

			foreach ($querys as $q) {
				$rs = mysqli_query($conn, trim($q) . ';');
				if (!$rs) {
					//$str = mysqli_error($conn);
					//var_dump($str);
				}
				//$str = mysqli_error($conn);
				//var_dump($str);
				//$dsql->ExecuteNoneQuery(trim($q).';');
			}
			if ($delfile == 1) {
				@unlink("$bkdir/$structfile");
			}
			$tmsg = "<font color='red'>完成数据表编码，准备转化数据...</font>";
			$doneForm = "<form name='gonext' method='post' action='index.php'>
	        <input type='hidden' name='step' value='2' />
	        <input type='hidden' name='startgo' value='1' />
	        <input type='hidden' name='delfile' value='$delfile' />
	        <input type='hidden' name='bakfiles' value='$bakfilesTmp' />
	        </form>\r\n{$dojs}\r\n";
			PutInfo($tmsg, $doneForm);
			exit();
		} else {
			$nowfile = $bakfiles[0];
			$bakfilesTmp = preg_replace("#" . $nowfile . "[,]{0,1}#", "", $bakfilesTmp);
			$oknum = 0;
			if (filesize("$bkdir/$nowfile") > 0) {
				$fp = fopen("$bkdir/$nowfile", 'r');
				while (!feof($fp)) {
					$line = trim(fgets($fp, 512 * 1024));
					if ($line == "") continue;
					//$rs = $dsql->ExecuteNoneQuery($line);
					//var_dump($line);
					$rs = mysqli_query($conn, $line);
					if ($rs) $oknum++;
				}
				fclose($fp);
			}
			if ($delfile == 1) {
				@unlink("$bkdir/$nowfile");
			}
			if ($bakfilesTmp == "") {
				ShowMsgV6('成功转化所有数据，下面进行DedeCMSV6升级……', 'index.php?step=3');
				exit();
			}
			$tmsg = "成功转化{$nowfile}的{$oknum}条记录<br/><br/>正在准备转化其它数据...";
			$doneForm = "<form name='gonext' method='post' action='index.php'>
	        <input type='hidden' name='step' value='2' />
	        <input type='hidden' name='startgo' value='1' />
	        <input type='hidden' name='delfile' value='$delfile' />
	        <input type='hidden' name='bakfiles' value='$bakfilesTmp' />
	        </form>\r\n{$dojs}\r\n";
			PutInfo($tmsg, $doneForm);
			exit();
		}
	} else {
		ShowMsgV6('当前系统就是UTF8程序，无需数据库编码转换，继续DedeCMSV6升级……', 'index.php?step=3');
		exit();
	}
}
// 执行DedeCMSV6增量SQL
else if ($step == 3) {
	@list($dbhost, $dbport) = explode(':', $GLOBALS['cfg_dbhost']);
	!$dbport && $dbport = 3306;
	$conn = mysqli_init();
	mysqli_real_connect($conn, $dbhost, $GLOBALS['cfg_dbuser'], $GLOBALS['cfg_dbpwd'], false, $dbport) or die("无法连接数据库");
	mysqli_query($conn, "SET character_set_connection=utf8,character_set_results=utf8,character_set_client=binary");
	mysqli_select_db($conn, $GLOBALS['cfg_dbname']);

	$querys = explode(';', $v6sql);

	foreach ($querys as $key => $q) {
		$prefix = "#@__";
		$q = str_replace($prefix, $GLOBALS['cfg_dbprefix'] . "v6_", $q);
		$q = str_replace("TYPE=MyISAM", "ENGINE=MyISAM", $q);
		$rs = mysqli_query($conn, trim($q) . ';');
		if (!$rs) {
			// $str = mysqli_error($conn);
			// var_dump($str);
		}
	}

	// 重写配置
	ReWriteConfig($conn);

	// 数据库连接文件
	$sqlconn = file_get_contents(dirname(__FILE__) . "/common.inc.txt");
	$sqlconn = str_replace("~dbtype~", "mysql", $sqlconn);
	$sqlconn = str_replace("~dbhost~", $GLOBALS['cfg_dbhost'], $sqlconn);
	$sqlconn = str_replace("~dbname~", $GLOBALS['cfg_dbname'], $sqlconn);
	$sqlconn = str_replace("~dbuser~", $GLOBALS['cfg_dbuser'], $sqlconn);
	$sqlconn = str_replace("~dbpwd~", $GLOBALS['cfg_dbpwd'], $sqlconn);
	$sqlconn = str_replace("~dbprefix~", $GLOBALS['cfg_dbprefix'] . "v6_", $sqlconn);
	$sqlconn = str_replace("~dblang~", "utf8", $sqlconn);

	file_put_contents(DEDEDATA . "/common.inc.php", $sqlconn);

	file_put_contents(TOV6LOCK, "www.dedebiz.com");

	// rename(dirname(__FILE__)."/index.php",dirname(__FILE__)."/index.php.bak");

	ShowMsgV6('完成系统数据库转换升级，下载DedeCMSV6系统，解压后将<code>./src</code>目录下的文件选择性替换即可完成升级。<br><a class=\'btn btn-success\' target=\'_blank\' href=\'https://www.dedebiz.com/download\'>下载DedeCMSV6</a> ', 'javascript:;');
	exit();
}