bingyi/shopxo
1
0
Fork 0
mirror of https://gitee.com/zongzhige/shopxo.git synced 2026-07-08 06:35:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

安装程序

Browse Source
This commit is contained in:
devil_gong
2018-12-28 15:55:39 +08:00
parent e17699161a
commit aa1491d22c
75 changed files with 1543 additions and 324 deletions
Download Patch File Download Diff File Expand all files Collapse all files

434
application/install/controller/Index.php Normal file
View File

@ -0,0 +1,434 @@
<?php
namespace app\install\controller;
use think\Db;
/**
* 安装程序
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-11-30
* @desc description
*/
class Index extends Common
{
/**
* 构造方法
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-11-30
* @desc description
*/
public function __construct()
{
parent::__construct();
}
/**
* 协议
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
*/
public function Index()
{
return $this->fetch();
}
/**
* 检查
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
*/
public function Check()
{
return $this->fetch();
}
/**
* 创建数据库
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
*/
public function Create()
{
return $this->fetch();
}
/**
* 完成
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
*/
public function Successful()
{
return $this->fetch();
}
/**
* 安装
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
*/
public function Add()
{
// 参数
$params = input('post.');
$ret = $this->ParamsCheck($params);
if($ret['code'] != 0)
{
return $ret;
}
// 配置文件校验
if(file_exists(ROOT.'config/database.php'))
{
if(!is_writable(ROOT.'config/database.php'))
{
return DataReturn('配置文件没有权限', -1);
}
}
// 开始安装
$db = $this->DbObj($params);
if(!is_object($db))
{
return DataReturn('数据库连接失败', -1);
}
// mysql版本
$ret = $this->IsVersion($db);
if($ret['code'] != 0)
{
return $ret;
}
// 检查数据表是否存在
if(!$this->IsDbExist($db, $params['DB_NAME']))
{
if($this->DbNameCreate($db, $params['DB_NAME']))
{
$db = $this->DbObj($params, $params['DB_NAME']);
} else {
return DataReturn('数据库创建失败', -1);
}
} else {
$db = $this->DbObj($params, $params['DB_NAME']);
}
if(!is_object($db))
{
return DataReturn('数据库连接失败', -1);
}
// 创建数据表
$ret = $this->CreateTable($db);
if($ret['code'] != 0)
{
return $ret;
}
// 生成配置文件
return $this->CreateConfig($params);
}
/**
* 生成配置文件
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param [array] $params [输入参数]
*/
private function CreateConfig($params = [])
{
// 配置文件信息处理
$db_str=<<<php
<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006~2018 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------
return [
// 数据库类型
'type' => '{$params['DB_TYPE']}',
// 服务器地址
'hostname' => '{$params['DB_HOST']}',
// 数据库名
'database' => '{$params['DB_NAME']}',
// 用户名
'username' => '{$params['DB_USER']}',
// 密码
'password' => '{$params['DB_PWD']}',
// 端口
'hostport' => '{$params['DB_PORT']}',
// 连接dsn
'dsn' => '',
// 数据库连接参数
'params' => [],
// 数据库编码默认采用utf8
'charset' => 'utf8mb4',
// 数据库表前缀
'prefix' => '{$params['DB_PREFIX']}',
// 数据库调试模式
'debug' => true,
// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
'deploy' => 0,
// 数据库读写是否分离 主从式有效
'rw_separate' => false,
// 读写分离后 主服务器数量
'master_num' => 1,
// 指定从服务器序号
'slave_no' => '',
// 自动读取主库数据
'read_master' => false,
// 是否严格检查字段是否存在
'fields_strict' => true,
// 数据集返回类型
'resultset_type' => 'array',
// 自动写入时间戳字段
'auto_timestamp' => false,
// 时间字段取出后的默认时间格式
'datetime_format' => 'Y-m-d H:i:s',
// 是否需要进行SQL性能分析
'sql_explain' => false,
// Builder类
'builder' => '',
// Query类
'query' => '\\think\\db\\Query',
// 是否需要断线重连
'break_reconnect' => false,
// 断线标识字符串
'break_match_str' => [],
];
?>
php;
if(@file_put_contents(ROOT.'config/database.php', $db_str) === false)
{
return DataReturn('配置文件创建失败', -1);
}
return DataReturn('success', 0);
}
/**
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param [object] $db [db对象]
*/
private function CreateTable($db)
{
if(!file_exists(ROOT.'public/install/shopxo.sql'))
{
return DataReturn('数据库sql文件不存在', -1);
}
// 导入sql数据并创建表
$sql_array = preg_split("/;[\r\n]+/", str_replace('`s_', '`'.$params['DB_PREFIX'], file_get_contents(ROOT.'public/install/shopxo.sql')));
$success = 0;
$failure = 0;
foreach($sql_array as $v)
{
if (!empty($v))
{
if($db->query($v))
{
$success++;
} else {
$failure++;
}
}
}
$result = [
'success' => $success,
'failure' => $failure,
];
if($failure > 0)
{
return DataReturn('sql运行失败['.$failure.']条', -1);
}
// 创建成功标记文件
@file_put_contents(ROOT.'public/install/install.lock');
return DataReturn('success', 0, $result);
}
/**
* 数据库版本校验
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param [object] $db [db对象]
*/
private function IsVersion($db)
{
$data = $db->query("select version() AS version");
if(empty($data[0]['version']))
{
return DataReturn('查询数据库版本失败', -1);
} else {
if($data[0]['version'] < 5.0)
{
return DataReturn('数据库版本过低', -1);
}
}
return DataReturn('success', 0);
}
/**
* 数据库创建
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param [object] $db [db对象]
* @param [string] $db_name [数据库名称]
*/
private function DbNameCreate($db, $db_name)
{
$sql = "CREATE DATABASE IF NOT EXISTS {$db_name} DEFAULT CHARSET utf8mb4 COLLATE utf8mb4_general_ci";
if($db->query($sql) !== false)
{
return $this->IsDbExist($db, $db_name);
}
return false;
}
/**
* 检查数据库是否存在
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param [object] $db [db对象]
* @param [string] $db_name [数据库名称]
*/
private function IsDbExist($db, $db_name)
{
$temp = $db->query("show databases like '{$db_name}'");
return !empty($temp);
}
/**
* 获取数据库操作对象
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param array $params [输入参数]
* @param string $db_name [数据库名称]
*/
private function DbObj($params = [], $db_name = '')
{
return Db::connect([
// 数据库类型
'type' => $params['DB_TYPE'],
// 数据库连接DSN配置
'dsn' => '',
// 服务器地址
'hostname' => $params['DB_HOST'],
// 数据库名
'database' => $db_name,
// 数据库用户名
'username' => $params['DB_USER'],
// 数据库密码
'password' => $params['DB_PWD'],
// 数据库连接端口
'hostport' => $params['DB_PORT'],
// 数据库连接参数
'params' => [],
// 数据库编码默认采用utf8
'charset' => 'utf8',
// 数据库表前缀
'prefix' => $params['DB_PREFIX'],
]);
}
/**
* 参数校验
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2018-12-28
* @desc description
* @param [array] $params [输入参数]
*/
private function ParamsCheck($params = [])
{
// 请求类型
$p = [
[
'checked_type' => 'empty',
'key_name' => 'DB_TYPE',
'error_msg' => '请选择数据库类型',
],
[
'checked_type' => 'empty',
'key_name' => 'DB_HOST',
'error_msg' => '请填写数据库服务器地址',
],
[
'checked_type' => 'empty',
'key_name' => 'DB_PORT',
'error_msg' => '请填写数据库端口',
],
[
'checked_type' => 'empty',
'key_name' => 'DB_NAME',
'error_msg' => '请填写数据库名',
],
[
'checked_type' => 'empty',
'key_name' => 'DB_USER',
'error_msg' => '请填写数据库用户名',
],
[
'checked_type' => 'empty',
'key_name' => 'DB_PWD',
'error_msg' => '请填写数据库密码',
],
[
'checked_type' => 'empty',
'key_name' => 'DB_PREFIX',
'error_msg' => '请填写数据表前缀',
],
];
$ret = ParamsChecked($params, $p);
if($ret !== true)
{
return DataReturn($ret, -1);
}
return DataReturn('success', 0);
}
}
?>