224 lines
8.8 KiB
PHP
224 lines
8.8 KiB
PHP
<?php
|
||
|
||
namespace app\index\controller;
|
||
|
||
use app\BaseController;
|
||
use app\common\traits\JumpTrait;
|
||
use think\facade\Db;
|
||
use think\Request;
|
||
|
||
class Install extends BaseController
|
||
{
|
||
|
||
use JumpTrait;
|
||
|
||
public function index(Request $request)
|
||
{
|
||
$isInstall = false;
|
||
$installPath = config_path() . DIRECTORY_SEPARATOR . 'install' . DIRECTORY_SEPARATOR;
|
||
$errorInfo = null;
|
||
if (is_file($installPath . 'lock' . DIRECTORY_SEPARATOR . 'install.lock')) {
|
||
// 如果你已经成功安装了后台系统 并且不想再次出现安装界面，可以把下面跳转注释取消
|
||
// $this->redirect('/');
|
||
$isInstall = true;
|
||
$errorInfo = '已安装系统，如需重新安装请删除文件：/config/install/lock/install.lock，或者删除 /install 路由';
|
||
}elseif (version_compare(phpversion(), '8.1.0', '<')) {
|
||
$errorInfo = 'PHP版本不能小于8.1.0';
|
||
}elseif (!extension_loaded("pdo_mysql")) {
|
||
$errorInfo = '当前未开启pdo_mysql，无法进行安装';
|
||
}
|
||
if (!is_file(root_path() . '.env')) {
|
||
$errorInfo = '.env 文件不存在，请先配置 .env 文件';
|
||
}
|
||
if (!$request->isAjax()) {
|
||
$envInfo = [
|
||
'DB_HOST' => $isInstall ? '' : env('DB_HOST', '127.0.0.1'),
|
||
'DB_NAME' => $isInstall ? '' : env('DB_NAME', 'easyadmin8'),
|
||
'DB_USER' => $isInstall ? '' : env('DB_USER', 'root'),
|
||
'DB_PASS' => $isInstall ? '' : env('DB_PASS', 'root'),
|
||
'DB_PORT' => $isInstall ? '' : env('DB_PORT', 3306),
|
||
'DB_PREFIX' => $isInstall ? '' : env('DB_PREFIX', 'ea8_'),
|
||
];
|
||
$currentHost = '://';
|
||
$result = compact('errorInfo', 'currentHost', 'isInstall', 'envInfo');
|
||
return view('index@install/index', $result);
|
||
}
|
||
if ($errorInfo) $this->error($errorInfo);
|
||
$charset = 'utf8mb4';
|
||
$post = $request->post();
|
||
$cover = $post['cover'] == 1;
|
||
$database = $post['database'];
|
||
$hostname = $post['hostname'];
|
||
$hostport = $post['hostport'];
|
||
$dbUsername = $post['db_username'];
|
||
$dbPassword = $post['db_password'];
|
||
$prefix = $post['prefix'];
|
||
$adminUrl = $post['admin_url'];
|
||
$username = $post['username'];
|
||
$password = $post['password'];
|
||
// 参数验证
|
||
$validateError = null;
|
||
// 判断是否有特殊字符
|
||
$check = preg_match('/[0-9a-zA-Z]+$/', $adminUrl, $matches);
|
||
if (!$check) {
|
||
$validateError = '后台地址不能含有特殊字符, 只能包含字母或数字。';
|
||
$this->error($validateError);
|
||
}
|
||
if (strlen($adminUrl) < 2) {
|
||
$validateError = '后台的地址不能小于2位数';
|
||
}elseif (strlen($password) < 5) {
|
||
$validateError = '管理员密码不能小于5位数';
|
||
}elseif (strlen($username) < 4) {
|
||
$validateError = '管理员账号不能小于4位数';
|
||
}
|
||
if (!empty($validateError)) $this->error($validateError);
|
||
$config = [
|
||
"driver" => 'mysql',
|
||
"host" => $hostname,
|
||
"database" => $database,
|
||
"port" => $hostport,
|
||
"username" => $dbUsername,
|
||
"password" => $dbPassword,
|
||
"prefix" => $prefix,
|
||
"charset" => $charset,
|
||
];
|
||
// 检测数据库连接
|
||
$this->checkConnect($config);
|
||
// 检测数据库是否存在
|
||
if (!$cover && $this->checkDatabase($database)) $this->error('数据库已存在，请选择覆盖安装或者修改数据库名');
|
||
// 创建数据库
|
||
$this->createDatabase($database, $config);
|
||
// 导入sql语句等等
|
||
$config = array_merge($config, ['database' => $database]);
|
||
$this->install($username, $password, $config, $adminUrl);
|
||
$this->success('系统安装成功，正在跳转登录页面');
|
||
}
|
||
|
||
protected function install(string $username, string $password, array $config): ?bool
|
||
{
|
||
$installPath = config_path() . DIRECTORY_SEPARATOR . 'install' . DIRECTORY_SEPARATOR;
|
||
$sqlPath = file_get_contents($installPath . 'sql' . DIRECTORY_SEPARATOR . 'install.sql');
|
||
$sqlArray = $this->parseSql($sqlPath, $config['prefix'], 'ea_');
|
||
$dsn = $this->pdoDsn($config, true);
|
||
try {
|
||
$pdo = new \PDO($dsn, $config['username'] ?? 'root', $config['password'] ?? '');
|
||
foreach ($sqlArray as $sql) {
|
||
$pdo->query($sql);
|
||
}
|
||
$hashedPassword = password_hash($password, PASSWORD_DEFAULT);
|
||
$tableName = 'system_admin';
|
||
$update = [
|
||
'username' => $username,
|
||
'head_img' => '/static/admin/images/head.jpg',
|
||
'password' => $hashedPassword,
|
||
'create_time' => time(),
|
||
'update_time' => time()
|
||
];
|
||
foreach ($update as $_k => $_up) {
|
||
$pdo->query("UPDATE {$config['prefix']}{$tableName} SET {$_k} = '{$_up}' WHERE id = 1");
|
||
}
|
||
// 处理安装文件
|
||
!is_dir($installPath) && @mkdir($installPath);
|
||
!is_dir($installPath . 'lock' . DIRECTORY_SEPARATOR) && @mkdir($installPath . 'lock' . DIRECTORY_SEPARATOR);
|
||
@file_put_contents($installPath . 'lock' . DIRECTORY_SEPARATOR . 'install.lock', date('Y-m-d H:i:s'));
|
||
}catch (\Exception|\PDOException|\Throwable $e) {
|
||
$this->error("系统安装失败：" . $e->getMessage());
|
||
}
|
||
return true;
|
||
}
|
||
|
||
protected function parseSql($sql = '', $to = '', $from = ''): array
|
||
{
|
||
list($pure_sql, $comment) = [[], false];
|
||
$sql = explode("\n", trim(str_replace(["\r\n", "\r"], "\n", $sql)));
|
||
foreach ($sql as $key => $line) {
|
||
if ($line == '') {
|
||
continue;
|
||
}
|
||
if (preg_match("/^(#|--)/", $line)) {
|
||
continue;
|
||
}
|
||
if (preg_match("/^\/\*(.*?)\*\//", $line)) {
|
||
continue;
|
||
}
|
||
if (str_starts_with($line, '/*')) {
|
||
$comment = true;
|
||
continue;
|
||
}
|
||
if (str_ends_with($line, '*/')) {
|
||
$comment = false;
|
||
continue;
|
||
}
|
||
if ($comment) {
|
||
continue;
|
||
}
|
||
if ($from != '') {
|
||
$line = str_replace('`' . $from, '`' . $to, $line);
|
||
}
|
||
if ($line == 'BEGIN;' || $line == 'COMMIT;') {
|
||
continue;
|
||
}
|
||
$pure_sql[] = $line;
|
||
}
|
||
//$pure_sql = implode($pure_sql, "\n");
|
||
$pure_sql = implode("\n", $pure_sql);
|
||
return explode(";\n", $pure_sql);
|
||
}
|
||
|
||
protected function createDatabase($database, $config): bool
|
||
{
|
||
$dsn = $this->pdoDsn($config);
|
||
try {
|
||
$pdo = new \PDO($dsn, $config['username'] ?? 'root', $config['password'] ?? '');
|
||
$pdo->query("CREATE DATABASE IF NOT EXISTS `{$database}` DEFAULT CHARACTER SET {$config['charset']} COLLATE=utf8mb4_general_ci");
|
||
}catch (\PDOException $e) {
|
||
return false;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
protected function checkDatabase($database): bool
|
||
{
|
||
try {
|
||
$check = Db::query("SELECT * FROM information_schema.schemata WHERE schema_name='{$database}'");
|
||
}catch (\Throwable $exception) {
|
||
$check = false;
|
||
}
|
||
if (empty($check)) {
|
||
return false;
|
||
}else {
|
||
return true;
|
||
}
|
||
}
|
||
|
||
protected function checkConnect(array $config): ?bool
|
||
{
|
||
$dsn = $this->pdoDsn($config);
|
||
try {
|
||
$pdo = new \PDO($dsn, $config['username'] ?? 'root', $config['password'] ?? '');
|
||
$res = $pdo->query('select VERSION()');
|
||
$_version = $res->fetch()[0] ?? 0;
|
||
if (version_compare($_version, '5.7.0', '<')) {
|
||
$this->error('mysql版本最低要求 5.7.x');
|
||
}
|
||
}catch (\PDOException $e) {
|
||
$this->error($e->getMessage());
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* @param array $config
|
||
* @param bool $needDatabase
|
||
* @return string
|
||
*/
|
||
protected function pdoDsn(array $config, bool $needDatabase = false): string
|
||
{
|
||
$host = $config['host'] ?? '127.0.0.1';
|
||
$database = $config['database'] ?? '';
|
||
$port = $config['port'] ?? '3306';
|
||
$charset = $config['charset'] ?? 'utf8mb4';
|
||
if ($needDatabase) return "mysql:host=$host;port=$port;dbname=$database;charset=$charset";
|
||
return "mysql:host=$host;port=$port;charset=$charset";
|
||
}
|
||
} |