<?php
|
error_reporting(E_ALL & ~E_NOTICE);
|
defined('IN_IA') or exit('Access Denied');
|
require __DIR__ . '/vendor/jdorn/sql-formatter/lib/SqlFormatter.php';
|
ini_set('max_execution_time', 1800);
|
|
/***
|
* 记录日志
|
* @param $content
|
* @return bool
|
*/
|
function upgrade_log($content)
|
{
|
$logFile = __DIR__ . '/upgrade.log';
|
$handle = fopen($logFile, 'a');
|
if (!$handle) {
|
return false;
|
}
|
$nowDateTime = date('Y-m-d H:i:s');
|
$string = <<<EOF
|
{$nowDateTime}:
|
--------->
|
{$content}
|
<---------
|
|
|
EOF;
|
$result = fwrite($handle, $string);
|
fclose($handle);
|
return $result ? true : false;
|
}
|
|
/**
|
* 执行SQL
|
* @param string $sql 要运行的SQL
|
* @param bool $split 自动拆分SQL
|
* @param bool $continueOnError 遇到错误继续执行
|
* @throws Exception
|
*/
|
function sql_execute($sql, $split = true, $continueOnError = true)
|
{
|
if ($split) {
|
$list = SqlFormatter::splitQuery($sql);
|
} else {
|
$list = [$sql];
|
}
|
foreach ($list as $item) {
|
try {
|
set_error_handler(function ($errno, $errstr) {
|
upgrade_log($errstr);
|
});
|
pdo_run($item);
|
restore_error_handler();
|
} catch (Exception $exception) {
|
upgrade_log($exception->getMessage());
|
if (!$continueOnError) {
|
throw $exception;
|
}
|
}
|
}
|
}
|
|
/**
|
* 检查数据表是否存在
|
* @param $tableName
|
* @return bool
|
*/
|
function sql_table_exists($tableName)
|
{
|
$sql = "SHOW TABLES LIKE '{$tableName}';";
|
$result = pdo_fetch($sql);
|
if (is_array($result) && count($result)) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
$dbConfigFile = __DIR__ . '/config/db.php';
|
if (!file_exists($dbConfigFile)) {
|
file_put_contents($dbConfigFile, <<<EOF
|
<?php
|
function getWe7DbConfig()
|
{
|
require __DIR__ . '/../../../data/config.php';
|
if (!empty(\$config['db']['master'])) {
|
\$we7DbConfig = \$config['db']['master'];
|
} else {
|
\$we7DbConfig = \$config['db'];
|
}
|
return [
|
'host' => \$we7DbConfig['host'],
|
'port' => \$we7DbConfig['port'],
|
'dbname' => \$we7DbConfig['database'],
|
'username' => \$we7DbConfig['username'],
|
'password' => \$we7DbConfig['password'],
|
];
|
}
|
|
\$we7DbConfig = getWe7DbConfig();
|
return [
|
'host' => \$we7DbConfig['host'],
|
'port' => \$we7DbConfig['port'],
|
'dbname' => \$we7DbConfig['dbname'],
|
'username' => \$we7DbConfig['username'],
|
'password' => \$we7DbConfig['password'],
|
'tablePrefix' => 'zjhj_bd_',
|
];
|
|
EOF
|
);
|
}
|
|
$optionTableName = 'zjhj_bd_option';
|
|
try {
|
if (sql_table_exists($optionTableName)) {
|
$result = pdo_fetch("SELECT * FROM `{$optionTableName}` WHERE `name`='version' ORDER BY `id` DESC LIMIT 1;");
|
if (is_array($result) && count($result)) {
|
$currentVersion = isset($result['value']) ? json_decode($result['value']) : null;
|
} else {
|
$currentVersion = null;
|
}
|
} else {
|
$currentVersion = null;
|
}
|
} catch (Exception $exception) {
|
$currentVersion = null;
|
}
|
$isNewInstall = $currentVersion ? false : true;
|
$currentVersion = $currentVersion ? $currentVersion : '0.0.0';
|
$lastVersion = $currentVersion;
|
|
// 运行各个版本的升级脚本
|
$versions = require __DIR__ . '/versions.php';
|
foreach ($versions as $v => $f) {
|
$lastVersion = $v;
|
if (version_compare($v, $currentVersion) > 0) {
|
if ($f instanceof \Closure) {
|
$f();
|
}
|
}
|
}
|
|
if (sql_table_exists($optionTableName)) { // 结束，更新数据库标记的版本号
|
$nowDateTime = date('Y-m-d H:i:s');
|
if ($isNewInstall) {
|
$updateVersionSql = <<<EOF
|
INSERT INTO `{$optionTableName}` (`mall_id`, `mch_id`, `group`, `name`, `value`, `created_at`, `updated_at`) VALUES
|
(0, 0, '', 'version', '\"{$lastVersion}\"', '{$nowDateTime}', '{$nowDateTime}');
|
EOF;
|
} else {
|
$updateVersionSql = <<<EOF
|
UPDATE `{$optionTableName}` SET
|
`value` = '\"{$lastVersion}\"',
|
`updated_at` = '{$nowDateTime}'
|
WHERE `name` = 'version';
|
EOF;
|
}
|
sql_execute($updateVersionSql);
|
}
|
