update

2025-10-17 16:44:52 +00:00 · 2022-08-15 18:39:40 +08:00
parent 605fe7a687
commit 6a66f3db07
13 changed files with 468 additions and 22 deletions
--- a/app/controller/Install.php
+++ b/app/controller/Install.php
@@ -0,0 +1,81 @@
+<?php
+namespace app\controller;
+
+use PDO;
+use Exception;
+use app\BaseController;
+use think\facade\View;
+use think\facade\Cache;
+
+class Install extends BaseController
+{
+    public function index()
+    {
+        if (file_exists(app()->getRootPath().'.env')){
+            return '当前已经安装成功，如果需要重新安装，请手动删除根目录.env文件';
+        }
+        if(request()->isPost()){
+            $mysql_host = input('post.mysql_host', null, 'trim');
+            $mysql_port = intval(input('post.mysql_port', '3306'));
+            $mysql_user = input('post.mysql_user', null, 'trim');
+            $mysql_pwd = input('post.mysql_pwd', null, 'trim');
+            $mysql_name = input('post.mysql_name', null, 'trim');
+            $mysql_prefix = input('post.mysql_prefix', 'cloud_', 'trim');
+            $admin_username = input('post.admin_username', null, 'trim');
+            $admin_password = input('post.admin_password', null, 'trim');
+
+            if(!$mysql_host || !$mysql_user || !$mysql_pwd || !$mysql_name || !$admin_username || !$admin_password){
+                return json(['code'=>0, 'msg'=>'必填项不能为空']);
+            }
+
+            $configdata = file_get_contents(app()->getRootPath().'.env.example');
+            $configdata = str_replace(['{dbhost}','{dbname}','{dbuser}','{dbpwd}','{dbport}','{dbprefix}'], [$mysql_host, $mysql_name, $mysql_user, $mysql_pwd, $mysql_port, $mysql_prefix], $configdata);
+
+            try{
+                $DB=new PDO("mysql:host=".$mysql_host.";dbname=".$mysql_name.";port=".$mysql_port,$mysql_user,$mysql_pwd);
+            }catch(Exception $e){
+                if($e->getCode() == 2002){
+                    $errorMsg='连接数据库失败：数据库地址填写错误！';
+                }elseif($e->getCode() == 1045){
+                    $errorMsg='连接数据库失败：数据库用户名或密码填写错误！';
+                }elseif($e->getCode() == 1049){
+                    $errorMsg='连接数据库失败：数据库名不存在！';
+                }else{
+                    $errorMsg='连接数据库失败：'.$e->getMessage();
+                }
+                return json(['code'=>0, 'msg'=>$errorMsg]);
+            }
+            $DB->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
+            $DB->exec("set sql_mode = ''");
+            $DB->exec("set names utf8");
+
+            $sqls=file_get_contents(app()->getRootPath().'install.sql');
+            $sqls=explode(';', $sqls);
+            $sqls[]="REPLACE INTO `".$mysql_prefix."config` VALUES ('syskey', '".random(16)."')";
+            $success=0;$error=0;$errorMsg=null;
+            foreach ($sqls as $value) {
+                $value=trim($value);
+                if(empty($value))continue;
+                $value = str_replace('cloud_',$mysql_prefix,$value);
+                if($DB->exec($value)===false){
+                    $error++;
+                    $dberror=$DB->errorInfo();
+                    $errorMsg.=$dberror[2]."\n";
+                }else{
+                    $success++;
+                }
+            }
+            if(empty($errorMsg)){
+                if(!file_put_contents(app()->getRootPath().'.env', $configdata)){
+                    return json(['code'=>0, 'msg'=>'保存失败，请确保网站根目录有写入权限']);
+                }
+                Cache::clear();
+                return json(['code'=>1, 'msg'=>'安装完成！成功执行SQL语句'.$success.'条']);
+            }else{
+                return json(['code'=>0, 'msg'=>$errorMsg]);
+            }
+        }
+        return view();
+    }
+    
+}