Merge pull request #172 from midoks/dev

0.9.6

.gitignore

@@ -128,6 +128,7 @@ lib/python*
 bin
 pyvenv.cfg
 include
+share
 pip-selfcheck.json
 
 scripts/mdserver-web
@@ -141,15 +142,14 @@ data/ssl.pl
 data/edate.pl
 data/osname.pl
 data/system.db-journal
+data/hook_*.json
 
 plugins/l2tp
 plugins/openlitespeed
 plugins/gdrive
 plugins/mtproxy
 plugins/zimg
+plugins/bk_demo
 debug.out
 
 
-
-
-

README.md

@@ -1,4 +1,4 @@
-### mdserver-web 0.9.2
+### mdserver-web 0.9.6
 
 简单的Linux面板,感谢BT.CN写出如此好的web管理软件。我一看到，就知道这是我一直想要的页面化管理方式。
 复制了后台管理界面，按照自己想要的方式写了一版。
@@ -71,13 +71,12 @@ docker run -itd --name mw-server --privileged=true -p 7200:7200 -p 80:80 -p 443:
 ```
 
 
-### 版本更新 0.9.3
+### 版本更新 0.9.6
+
+* 增加插件备份功能.
+* supervisor增加错误日志查看.
+* MariaDB安装源优化.
 
-* 批量域名添加修复。
-* 常用命令说明。
-* 重写页面更新功能。
-* MySQL8.0安装地址修改。
-* 删除MySQL[Yum]插件。
 
 ### JSDelivr安装地址
 
@@ -126,13 +125,12 @@ curl -fsSL  https://raw.githubusercontent.com/midoks/mdserver-web/dev/scripts/up
 ```
 
 ### 微信赞助
-[![截图](/route/static/img/weixin_zz.jpg)](/route/static/img/weixin_zz.jpg)
+[![截图](https://cdn.jsdelivr.net/gh/midoks/mdserver-web@latest/route/static/img/weixin_zz.jpg)](https://cdn.jsdelivr.net/gh/midoks/mdserver-web@latest/route/static/img/weixin_zz.jpg)
 
 
 ### 无图不真相
 
-[![截图](/route/static/mdw.jpg)](/route/static/mdw.jpg)
-
+[![截图](https://cdn.jsdelivr.net/gh/midoks/mdserver-web@latest/route/static/mdw.jpg)](https://cdn.jsdelivr.net/gh/midoks/mdserver-web@latest/route/static/mdw.jpg)
 
 
 ### Stargazers over time

class/core/config_api.py

@@ -15,7 +15,7 @@ from flask import request
 
 class config_api:
 
-    __version = '0.9.3'
+    __version = '0.9.5'
 
     def __init__(self):
         pass

class/core/crontab_api.py

@@ -295,9 +295,18 @@ class crontab_api:
     # 取数据列表
     def getDataListApi(self):
         stype = request.form.get('type', '')
+
+        bak_data = []
+
+        if stype == 'sites' or stype == 'databases':
+            hookPath = mw.getPanelDataDir() + "/hook_backup.json"
+            if os.path.exists(hookPath):
+                t = mw.readFile(hookPath)
+                bak_data = json.loads(t)
+
         if stype == 'databases':
             db_list = {}
-            db_list['orderOpt'] = []
+            db_list['orderOpt'] = bak_data
             path = mw.getServerDir() + '/mysql'
             if not os.path.exists(path + '/mysql.db'):
                 db_list['data'] = []
@@ -307,8 +316,9 @@ class crontab_api:
             return mw.getJson(db_list)
 
         data = {}
+        data['orderOpt'] = bak_data
+
         data['data'] = mw.M(stype).field('name,ps').select()
-        data['orderOpt'] = []
         return mw.getJson(data)
     ##### ----- start ----- ###
 
@@ -411,16 +421,13 @@ class crontab_api:
                 'rememory': head + "/bin/bash " + script_dir + '/rememory.sh'
             }
             if param['backup_to'] != 'localhost':
-                cfile = mw.getServerDir() + "/mdserver-web/plugin/" + \
-                    param['backup_to'] + "/" + param['backup_to'] + "_main.py"
-                if not os.path.exists(cfile):
-                    cfile = script_dir + "/backup_" + \
-                        param['backup_to'] + ".py"
+                cfile = mw.getPluginDir() + "/" + \
+                    param['backup_to'] + "/index.py"
                 wheres = {
-                    'path': head + "python " + cfile + " path " + param['sname'] + " " + str(param['save']),
-                    'site':   head + "python " + cfile + " site " + param['sname'] + " " + str(param['save']),
-                    'database': head + "python " + cfile + " database " + param['sname'] + " " + str(param['save']),
-                    'logs':   head + "python " + script_dir + "/logs_backup.py " + param['sname'] + log + " " + str(param['save']),
+                    'path': head + "python3 " + cfile + " path " + param['sname'] + " " + str(param['save']),
+                    'site':   head + "python3 " + cfile + " site " + param['sname'] + " " + str(param['save']),
+                    'database': head + "python3 " + cfile + " database " + param['sname'] + " " + str(param['save']),
+                    'logs':   head + "python3 " + script_dir + "/logs_backup.py " + param['sname'] + log + " " + str(param['save']),
                     'rememory': head + "/bin/bash " + script_dir + '/rememory.sh'
                 }
             try:

class/core/files_api.py

@@ -676,8 +676,7 @@ class files_api:
                     data['encoding'] = 'utf-8'
                 if char['encoding'] == 'Big5':
                     data['encoding'] = 'BIG5'
-                if not char['encoding'] in ['GBK', 'utf-8',
-                                            'BIG5']:
+                if not char['encoding'] in ['GBK', 'utf-8', 'BIG5']:
                     data['encoding'] = 'utf-8'
                 try:
                     if sys.version_info[0] == 2:

class/core/mw.py

@@ -57,10 +57,22 @@ def getPluginDir():
     return getRunDir() + '/plugins'
 
 
+def getPanelDataDir():
+    return getRunDir() + '/data'
+
+
 def getServerDir():
     return getRootDir() + '/server'
 
 
+def getLogsDir():
+    return getRootDir() + '/wwwlogs'
+
+
+def getBackupDir():
+    return getRootDir() + '/backup'
+
+
 def getWwwDir():
     file = getRunDir() + '/data/site.pl'
     if os.path.exists(file):
@@ -73,14 +85,6 @@ def setWwwDir(wdir):
     return writeFile(file, wdir)
 
 
-def getLogsDir():
-    return getRootDir() + '/wwwlogs'
-
-
-def getBackupDir():
-    return getRootDir() + '/backup'
-
-
 def setBackupDir(bdir):
     file = getRunDir() + '/data/backup.pl'
     return writeFile(file, bdir)

class/core/plugins_api.py

@@ -114,6 +114,7 @@ class plugins_api:
             return mw.returnJson(False, '配置文件不存在!', ())
 
         pluginInfo = json.loads(mw.readFile(infoJsonPos))
+        self.hookInstall(pluginInfo)
 
         execstr = "cd " + os.getcwd() + "/plugins/" + \
             name + " && /bin/bash " + pluginInfo["shell"] \
@@ -131,6 +132,55 @@ class plugins_api:
         mw.triggerTask()
         return mw.returnJson(True, '已将安装任务添加到队列!')
 
+    def hookInstallFile(self, hook_name, info):
+        hookPath = mw.getPanelDataDir() + "/hook_" + hook_name + ".json"
+        data = []
+        if os.path.exists(hookPath):
+            t = mw.readFile(hookPath)
+            data = json.loads(t)
+
+        isNeedAdd = True
+        for x in range(len(data)):
+            if data[x]['title'] == info['title'] and data[x]['name'] == info['name']:
+                isNeedAdd = False
+
+        if isNeedAdd:
+            tmp = {}
+            tmp['title'] = info['title']
+            tmp['name'] = info['name']
+            data.append(tmp)
+        mw.writeFile(hookPath, json.dumps(data))
+
+    def hookUninstallFile(self, hook_name, info):
+        hookPath = mw.getPanelDataDir() + "/hook_" + hook_name + ".json"
+        data = []
+        if os.path.exists(hookPath):
+            t = mw.readFile(hookPath)
+            data = json.loads(t)
+
+        for idx in range(len(data)):
+            if data[idx]['title'] == info['title'] and data[idx]['name'] == info['name']:
+                data.remove(data[idx])
+        mw.writeFile(hookPath, json.dumps(data))
+
+    def hookInstall(self, info):
+        if 'hook' in info:
+            hooks = info['hook']
+            for x in hooks:
+                if x in ['backup']:
+                    self.hookInstallFile(x, info)
+                    return True
+        return False
+
+    def hookUninstall(self, info):
+        if 'hook' in info:
+            hooks = info['hook']
+            for x in hooks:
+                if x in ['backup']:
+                    self.hookUninstallFile(x, info)
+                    return True
+        return False
+
     def uninstallOldApi(self):
         rundir = mw.getRunDir()
         name = request.form.get('name', '')
@@ -147,7 +197,6 @@ class plugins_api:
             return mw.returnJson(False, "配置文件不存在!", ())
 
         pluginInfo = json.loads(mw.readFile(infoJsonPos))
-
         execstr = "cd " + os.getcwd() + "/plugins/" + \
             name + " && /bin/bash " + pluginInfo["shell"] \
             + " uninstall " + version
@@ -175,13 +224,13 @@ class plugins_api:
             return mw.returnJson(False, "配置文件不存在!", ())
 
         pluginInfo = json.loads(mw.readFile(infoJsonPos))
-
+        self.hookUninstall(pluginInfo)
         execstr = "cd " + os.getcwd() + "/plugins/" + \
             name + " && /bin/bash " + pluginInfo["shell"] \
             + " uninstall " + version
 
         data = mw.execShell(execstr)
-        if mw.isAppleSystem():
+        if mw.isDebugMode():
             print(execstr)
             print(data[0], data[1])
         self.removeIndex(name, version)
@@ -793,7 +842,7 @@ class plugins_api:
                     print('getIndexList:', e)
 
         # 使用gevent模式时,无法使用多进程
-        #plist = self.checkStatusMProcess(plist)
+        # plist = self.checkStatusMProcess(plist)
         plist = self.checkStatusMThreads(plist)
         return plist
 

class/core/site_api.py

@@ -1140,10 +1140,10 @@ class site_api:
             if conf.find(rep) == -1:
                 rep = '#error_page 404/404.html;'
             data = '''
-    # AUTH_START
+    #AUTH_START
     auth_basic "Authorization";
     auth_basic_user_file %s;
-    # AUTH_END''' % (filename,)
+    #AUTH_END''' % (filename,)
             conf = conf.replace(rep, rep + data)
             mw.writeFile(configFile, conf)
         # 写密码配置
@@ -2026,7 +2026,7 @@ location ^~ {from} {
            return 404;
         }
     }
-    # SECURITY-END
+    #SECURITY-END
     include %s/enable-php-''' % (fix.strip().replace(',', '|'), domains.strip().replace(',', ' '), pre_path)
                 conf = re.sub(re_path, rconf, conf)
                 mw.writeLog('网站管理', '站点[' + name + ']已开启防盗链!')

class/core/system_api.py

@@ -684,22 +684,23 @@ class system_api:
 
                 dist_mw = toPath + '/mw.zip'
                 if not os.path.exists(dist_mw):
-                    mw.execShell('wget -O ' + dist_mw + ' ' + newUrl)
+                    mw.execShell(
+                        'wget --no-check-certificate -O ' + dist_mw + ' ' + newUrl)
 
                 dist_to = toPath + "/mdserver-web-" + version
                 if not os.path.exists(dist_to):
-                    mw.execShell('unzip -o ' + toPath +
-                                 '/mw.zip' + ' -d ' + toPath)
+                    os.system('unzip -o ' + toPath +
+                              '/mw.zip' + ' -d ' + toPath)
 
-                cmd_cp = "cp -rf " + toPath + '/mdserver-web-' + \
-                    version + "/* " + mw.getServerDir() + "/mdserver-web"
+                cmd_cp = 'cp -rf ' + toPath + '/mdserver-web-' + \
+                    version + '/* ' + mw.getServerDir() + '/mdserver-web'
                 mw.execShell(cmd_cp)
 
                 mw.execShell('rm -rf ' + toPath + '/mdserver-web-' + version)
                 mw.execShell('rm -rf ' + toPath + '/mw.zip')
 
                 self.restartMw()
-                return mw.returnJson(True, '安装更新成功,需自己重启!')
+                return mw.returnJson(True, '安装更新成功!')
 
             return mw.returnJson(False, '已经是最新,无需更新!')
         except Exception as ex:

class/plugin/orm.py

@@ -11,6 +11,7 @@ class ORM:
     __DB_PASS = None
     __DB_USER = 'root'
     __DB_PORT = 3306
+    __DB_NAME = ''
     __DB_HOST = 'localhost'
     __DB_CONN = None
     __DB_CUR = None
@@ -27,21 +28,25 @@ class ORM:
             if os.path.exists(self.__DB_SOCKET):
                 try:
                     self.__DB_CONN = pymysql.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     database=self.__DB_NAME,
                                                      port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1,
                                                      unix_socket=self.__DB_SOCKET, cursorclass=pymysql.cursors.DictCursor)
                 except Exception as e:
                     self.__DB_HOST = '127.0.0.1'
                     self.__DB_CONN = pymysql.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     database=self.__DB_NAME,
                                                      port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1,
                                                      unix_socket=self.__DB_SOCKET, cursorclass=pymysql.cursors.DictCursor)
             else:
                 try:
                     self.__DB_CONN = pymysql.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     database=self.__DB_NAME,
                                                      port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1,
                                                      cursorclass=pymysql.cursors.DictCursor)
                 except Exception as e:
                     self.__DB_HOST = '127.0.0.1'
                     self.__DB_CONN = pymysql.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     database=self.__DB_NAME,
                                                      port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1,
                                                      cursorclass=pymysql.cursors.DictCursor)
 
@@ -69,6 +74,9 @@ class ORM:
     def getPwd(self):
         return self.__DB_PASS
 
+    def setDbName(self, name):
+        self.__DB_NAME = name
+
     def execute(self, sql):
         # 执行SQL语句返回受影响行
         if not self.__Conn():

mw-cli

@@ -48,6 +48,11 @@ def mw_reset_pwd():
 
 
 if __name__ == '__main__':
+
+    if os.geteuid() != 0:
+        print("请使用root账户执行该命令.")
+        sys.exit(1)
+
     os.chdir("/www/server/mdserver-web")
     sys.path.append(os.getcwd() + "/class/core")
 

plugins/gogs/index.py

@@ -388,7 +388,7 @@ def postReceiveLog():
 def getGogsConf():
     conf = getConf()
     if not os.path.exists(conf):
-        return mw.returnJson(False, "请先安装初始化!")
+        return mw.returnJson(False, "请先安装初始化!<br/>默认地址:http://" + mw.getLocalIp() + ":3000")
 
     gets = [
         {'name': 'DOMAIN', 'type': -1, 'ps': '服务器域名'},
@@ -455,7 +455,7 @@ def userList():
 
     conf = getConf()
     if not os.path.exists(conf):
-        return mw.returnJson(False, "请先安装初始化!")
+        return mw.returnJson(False, "请先安装初始化!<br/>默认地址:http://" + mw.getLocalIp() + ":3000")
 
     import math
     args = getArgs()

plugins/mariadb/conf/my.cnf

@@ -45,11 +45,11 @@ skip-name-resolve = on
 
 log-bin=mysql-bin
 binlog_format=mixed
-expire_logs_days = 10
 slow_query_log=1
 slow-query-log-file={$SERVER_APP_PATH}/data/mysql-slow.log
 long_query_time=3
 #log_queries_not_using_indexes=on
+binlog-expire-logs-seconds = 2592000
 
 relay-log=mdserver
 relay-log-index=mdserver

plugins/mariadb/index.py

@@ -150,7 +150,7 @@ def pSqliteDb(dbname='databases'):
     return conn
 
 
-def pMysqlDb():
+def pMysqlDb(name=''):
     # pymysql
     db = mw.getMyORM()
     # MySQLdb |
@@ -159,6 +159,7 @@ def pMysqlDb():
     db.setDbConf(getConf())
     db.setPort(getDbPort())
     db.setSocket(getSocketFile())
+    db.setDbName(name)
 
     pwd = pSqliteDb('config').where('id=?', (1,)).getField('mysql_root')
     db.setPwd(pwd)
@@ -631,7 +632,7 @@ def isSqlError(mysqlMsg):
 
 
 def __createUser(dbname, username, password, address):
-    pdb = pMysqlDb()
+    pdb = pMysqlDb('mysql')
 
     if username == 'root':
         dbname = '*'
@@ -691,8 +692,8 @@ def importDbBackup():
         mw.execShell(cmd)
 
     pwd = pSqliteDb('config').where('id=?', (1,)).getField('mysql_root')
-
-    mysql_cmd = mw.getRootDir() + '/server/mysql/bin/mysql -uroot -p' + pwd + \
+    sock = getSocketFile()
+    mysql_cmd = getServerDir() + '/bin/mysql -S ' + sock + ' -uroot -p' + pwd + \
         ' ' + name + ' < ' + file_path_sql
 
     # print(mysql_cmd)
@@ -797,7 +798,7 @@ def syncGetDatabases():
     if isError != None:
         return isError
     users = pdb.query(
-        "select User,Host from mysql.user where User!='root' AND Host!='localhost' AND Host!=''")
+        "select User,Host from user where User!='root' AND Host!='localhost' AND Host!=''")
     nameArr = ['information_schema', 'performance_schema', 'mysql', 'sys']
     n = 0
 
@@ -893,16 +894,19 @@ def setRootPwd(version=''):
 
     password = args['password']
     try:
-        pdb = pMysqlDb()
+        pdb = pMysqlDb('mysql')
         result = pdb.query("show databases")
         isError = isSqlError(result)
         if isError != None:
             return isError
 
-        result = pdb.execute(
-            "update mysql.user set Password=password('" + password + "') where User='root'")
-        pdb.execute("flush privileges")
+        cmd = "ALTER USER 'root'@'localhost' IDENTIFIED BY '" + password + "';"
+        r = pdb.execute(cmd)
+        # print(r)
+
         pSqliteDb('config').where('id=?', (1,)).save('mysql_root', (password,))
+        orm = pMysqlDb()
+        orm.execute("flush privileges")
         return mw.returnJson(True, '数据库root密码修改成功!')
     except Exception as ex:
         return mw.returnJson(False, '修改错误:' + str(ex))
@@ -910,7 +914,7 @@ def setRootPwd(version=''):
 
 def setUserPwd(version=''):
     args = getArgs()
-    data = checkArgs(args, ['password', 'name'])
+    data = checkArgs(args, ['password', 'name', 'id'])
     if not data[0]:
         return data[1]
 
@@ -920,16 +924,28 @@ def setUserPwd(version=''):
     try:
         pdb = pMysqlDb()
         psdb = pSqliteDb('databases')
-        name = psdb.where('id=?', (uid,)).getField('name')
+        data = psdb.field('id,name,accept').where('id=?', (uid,)).find()
 
-        result = pdb.execute("update mysql.user set Password=password('" +
-                             newpassword + "') where User='" + username + "'")
+        cmd = "SET PASSWORD FOR '" + username + \
+            "'@'localhost' = PASSWORD('" + newpassword + "')"
+        r = pdb.execute(cmd)
+        # print(cmd, r)
+
+        accept = data['accept']
+        alist = accept.split(',')
+        for x in alist:
+            cmd = "SET PASSWORD FOR '" + username + \
+                "'@'" + x + "' = PASSWORD('" + newpassword + "')"
+            r = pdb.execute(cmd)
+            # print(cmd, r)
 
-        pdb.execute("flush privileges")
         psdb.where("id=?", (uid,)).setField('password', newpassword)
-        return mw.returnJson(True, mw.getInfo('修改数据库[{1}]密码成功!', (name,)))
+
+        orm = pMysqlDb()
+        orm.execute("flush privileges")
+        return mw.returnJson(True, mw.getInfo('修改数据库[{1}]密码成功!', (data['name'],)))
     except Exception as ex:
-        return mw.returnJson(False, mw.getInfo('修改数据库[{1}]密码失败[{2}]!', (name, str(ex),)))
+        return mw.returnJson(False, mw.getInfo('修改数据库[{1}]密码失败[{2}]!', (data['name'], str(ex),)))
 
 
 def setDbPs():
@@ -1022,7 +1038,7 @@ def delDb():
         id = args['id']
         name = args['name']
         psdb = pSqliteDb('databases')
-        pdb = pMysqlDb()
+        pdb = pMysqlDb('mysql')
         find = psdb.where("id=?", (id,)).field(
             'id,pid,name,username,password,accept,ps,addtime').find()
         accept = find['accept']
@@ -1031,7 +1047,7 @@ def delDb():
         # 删除MYSQL
         result = pdb.execute("drop database `" + name + "`")
 
-        users = pdb.query("select Host from mysql.user where User='" +
+        users = pdb.query("select Host from user where User='" +
                           username + "' AND Host!='localhost'")
         pdb.execute("drop user '" + username + "'@'localhost'")
         for us in users:
@@ -1051,9 +1067,9 @@ def getDbAccess():
     if not data[0]:
         return data[1]
     username = args['username']
-    pdb = pMysqlDb()
+    pdb = pMysqlDb('mysql')
 
-    users = pdb.query("select Host from mysql.user where User='" +
+    users = pdb.query("select Host from user where User='" +
                       username + "' AND Host!='localhost'")
 
     if len(users) < 1:
@@ -1072,7 +1088,7 @@ def setDbAccess():
         return data[1]
     name = args['username']
     access = args['access']
-    pdb = pMysqlDb()
+    pdb = pMysqlDb('mysql')
     psdb = pSqliteDb('databases')
 
     dbname = psdb.where('username=?', (name,)).getField('name')
@@ -1083,7 +1099,7 @@ def setDbAccess():
     else:
         password = psdb.where("username=?", (name,)).getField('password')
 
-    users = pdb.query("select Host from mysql.user where User='" +
+    users = pdb.query("select Host from user where User='" +
                       name + "' AND Host!='localhost'")
 
     for us in users:
@@ -1105,11 +1121,11 @@ def setDbRw(version=''):
     uid = args['id']
     rw = args['rw']
 
-    pdb = pMysqlDb()
+    pdb = pMysqlDb('mysql')
     psdb = pSqliteDb('databases')
     dbname = psdb.where("id=?", (uid,)).getField('name')
     users = pdb.query(
-        "select Host from mysql.user where User='" + username + "'")
+        "select Host from user where User='" + username + "'")
 
     # show grants for demo@"127.0.0.1";
     for x in users:
@@ -1374,7 +1390,7 @@ def setDbMasterAccess():
     pdb = pMysqlDb()
     psdb = pSqliteDb('master_replication_user')
     password = psdb.where("username=?", (username,)).getField('password')
-    users = pdb.query("select Host from mysql.user where User='" +
+    users = pdb.query("select Host from user where User='" +
                       username + "' AND Host!='localhost'")
     for us in users:
         pdb.execute("drop user '" + username + "'@'" + us["Host"] + "'")
@@ -1706,7 +1722,7 @@ def delMasterRepSlaveUser(version=''):
     pdb.execute("drop user '" + name + "'@'%'")
     pdb.execute("drop user '" + name + "'@'localhost'")
 
-    users = pdb.query("select Host from mysql.user where User='" +
+    users = pdb.query("select Host from user where User='" +
                       name + "' AND Host!='localhost'")
     for us in users:
         pdb.execute("drop user '" + name + "'@'" + us["Host"] + "'")

plugins/mariadb/js/mariadb.js

@@ -445,10 +445,9 @@ function syncToDatabase(type){
 
 function setRootPwd(type, pwd){
     if (type==1){
-        var data = $("#mod_pwd").serialize();
-        myPost('set_root_pwd', data, function(data){
+        var password = $("#MyPassword").val();
+        myPost('set_root_pwd', {password:password}, function(data){
             var rdata = $.parseJSON(data.data);
-            // console.log(rdata);
             showMsg(rdata.msg,function(){
                 dbList();
                 $('.layui-layer-close1').click();
@@ -459,26 +458,23 @@ function setRootPwd(type, pwd){
 
     var index = layer.open({
         type: 1,
-        skin: 'demo-class',
         area: '500px',
         title: '修改数据库密码',
         closeBtn: 1,
         shift: 5,
+        btn:["提交","关闭"],
         shadeClose: true,
-        content: "<form class='bt-form pd20 pb70' id='mod_pwd'>\
+        content: "<form class='bt-form pd20' id='mod_pwd'>\
                     <div class='line'>\
-                    <span class='tname'>root密码</span>\
-                    <div class='info-r'><input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+pwd+"' /><span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span></div>\
-                    </div>\
-                    <div class='bt-form-submit-btn'>\
-                        <button id='my_mod_close' type='button' class='btn btn-danger btn-sm btn-title'>关闭</button>\
-                        <button type='button' class='btn btn-success btn-sm btn-title' onclick=\"setRootPwd(1)\" >提交</button>\
+                        <span class='tname'>root密码</span>\
+                        <div class='info-r'><input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+pwd+"' />\
+                            <span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span>\
+                        </div>\
                     </div>\
                   </form>",
-    });
-
-    $('#my_mod_close').click(function(){
-        $('.layui-layer-close1').click();
+        yes:function(){
+            setRootPwd(1);
+        }
     });
 }
 
@@ -632,12 +628,17 @@ function setDbPass(id, username, password){
                     </div>\
                     <div class='line'>\
                     <span class='tname'>密码</span>\
-                    <div class='info-r'><input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+password+"' /><span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span></div>\
+                    <div class='info-r'>\
+                        <input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+password+"' />\
+                        <span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span></div>\
                     </div>\
                     <input type='hidden' name='id' value='"+id+"'>\
                   </form>",
         yes:function(index){
-            var data = $("#mod_pwd").serialize();
+            var data = {};
+            data['name'] = $('input[name=name]').val();
+            data['password'] = $('#MyPassword').val();
+            data['id'] = $('input[name=id]').val();
             myPost('set_user_pwd', data, function(data){
                 var rdata = $.parseJSON(data.data);
                 showMsg(rdata.msg,function(){
@@ -809,7 +810,14 @@ function openPhpmyadmin(name,username,password){
         layer.msg('phpMyAdmin未启动',{icon:2,shade: [0.3, '#000']});
         return;
     }
-    // console.log(data);
+    
+    data = syncPost('/plugins/run',{'name':'phpmyadmin','func':'get_cfg'});
+    var rdata = $.parseJSON(data.data);
+    if (rdata.choose != 'mariadb'){
+        layer.msg('当前为['+rdata.choose+']模式,若要使用请切换模式.',{icon:2,shade: [0.3, '#000']});
+        return;
+    }
+
     data = syncPost('/plugins/run',{'name':'phpmyadmin','func':'get_home_page'});
     var rdata = $.parseJSON(data.data);
     if (!rdata.status){

plugins/mariadb/versions/10.6/install.sh

@@ -14,7 +14,7 @@ sysName=`uname`
 install_tmp=${rootPath}/tmp/mw_install.pl
 mariadbDir=${serverPath}/source/mariadb
 
-MY_VER=10.6.8
+MY_VER=10.6.9
 
 Install_app()
 {
@@ -57,10 +57,15 @@ Install_app()
 	fi
 	# ----- cpu end ------
 
+	# https://mirrors.aliyun.com/mariadb/mariadb-10.8.3/source/mariadb-10.8.3.tar.gz
 	if [ ! -f ${mariadbDir}/mariadb-${MY_VER}.tar.gz ];then
-		# https://mirrors.aliyun.com/mariadb/mariadb-10.8.3/source/mariadb-10.8.3.tar.gz
-		wget -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://mirrors.aliyun.com/mariadb/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
-		# wget -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://downloads.mariadb.org/interstitial/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
+		wget --no-check-certificate -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://mirrors.aliyun.com/mariadb/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
+		
+	fi
+
+	# https://downloads.mariadb.org/interstitial/mariadb-10.6.8/source/mariadb-10.6.8.tar.gz
+	if [ "$?" != "0" ];then
+		wget --no-check-certificate -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://downloads.mariadb.org/interstitial/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
 	fi
 
 	if [ ! -d ${mariadbDir}/mariadb-${MY_VER} ];then
@@ -71,10 +76,15 @@ Install_app()
 	if [ "$sysName" == "Darwin" ];then
 		OPTIONS='-DPLUGIN_TOKUDB=NO'
 	fi
-	
+
+	INSTALL_CMD=cmake
+	CMAKE3=`which cmake3`
+	if [ "$?" == "0" ];then
+		INSTALL_CMD=cmake3
+	fi
 
 	if [ ! -d $serverPath/mariadb ];then
-		cd ${mariadbDir}/mariadb-${MY_VER} && cmake \
+		cd ${mariadbDir}/mariadb-${MY_VER} && $INSTALL_CMD \
 		-DCMAKE_INSTALL_PREFIX=$serverPath/mariadb \
 		-DMYSQL_DATADIR=$serverPath/mariadb/data/ \
 		-DMYSQL_USER=mysql \

plugins/mariadb/versions/10.7/install.sh

@@ -14,7 +14,7 @@ sysName=`uname`
 install_tmp=${rootPath}/tmp/mw_install.pl
 mariadbDir=${serverPath}/source/mariadb
 
-MY_VER=10.7.4
+MY_VER=10.7.5
 
 Install_app()
 {
@@ -58,14 +58,16 @@ Install_app()
 	# ----- cpu end ------
 
 	if [ ! -f ${mariadbDir}/mariadb-${MY_VER}.tar.gz ];then
-		wget -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://mirrors.aliyun.com/mariadb/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
-		# wget -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://downloads.mariadb.org/interstitial/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
+		wget --no-check-certificate -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://mirrors.aliyun.com/mariadb/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
+	fi
+
+	if [ "$?" != "0" ];then
+		wget --no-check-certificate -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://downloads.mariadb.org/interstitial/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
 	fi
 
 	if [ ! -d ${mariadbDir}/mariadb-${MY_VER} ];then
 		 cd ${mariadbDir} && tar -zxvf  ${mariadbDir}/mariadb-${MY_VER}.tar.gz
 	fi
-	
 
 	if [ ! -d $serverPath/mariadb ];then
 		cd ${mariadbDir}/mariadb-${MY_VER} && cmake \

plugins/mariadb/versions/10.8/install.sh

@@ -14,7 +14,7 @@ sysName=`uname`
 install_tmp=${rootPath}/tmp/mw_install.pl
 mariadbDir=${serverPath}/source/mariadb
 
-MY_VER=10.8.3
+MY_VER=10.8.4
 
 Install_app()
 {
@@ -58,8 +58,11 @@ Install_app()
 	# ----- cpu end ------
 
 	if [ ! -f ${mariadbDir}/mariadb-${MY_VER}.tar.gz ];then
-		wget -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://mirrors.aliyun.com/mariadb/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
-		# wget -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://downloads.mariadb.org/interstitial/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
+		wget --no-check-certificate -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://mirrors.aliyun.com/mariadb/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
+	fi
+
+	if [ "$?" != "0" ];then
+		wget --no-check-certificate -O ${mariadbDir}/mariadb-${MY_VER}.tar.gz --tries=3 https://downloads.mariadb.org/interstitial/mariadb-${MY_VER}/source/mariadb-${MY_VER}.tar.gz
 	fi
 
 	if [ ! -d ${mariadbDir}/mariadb-${MY_VER} ];then
@@ -86,7 +89,7 @@ Install_app()
 		make -j${cpuCore} && make install && make clean
 
 		if [ -d $serverPath/mariadb ];then
-			echo '10.7' > $serverPath/mariadb/version.pl
+			echo '10.8' > $serverPath/mariadb/version.pl
 			echo '安装完成' > $install_tmp
 		else
 			# rm -rf ${mariadbDir}/mariadb-${MY_VER}

plugins/mysql/index.html

@@ -53,7 +53,7 @@
 .conf_p span {
     display: inline-block;
     margin-right: 10px;
-    width: 95px;
+    width: 135px;
     text-align: right;
 }
 </style>

plugins/mysql/index.py

@@ -821,8 +821,8 @@ def importDbBackup():
         mw.execShell(cmd)
 
     pwd = pSqliteDb('config').where('id=?', (1,)).getField('mysql_root')
-
-    mysql_cmd = mw.getRootDir() + '/server/mysql/bin/mysql -uroot -p' + pwd + \
+    sock = getSocketFile()
+    mysql_cmd = getServerDir() + '/bin/mysql -S ' + sock + ' -uroot -p' + pwd + \
         ' ' + name + ' < ' + file_path_sql
 
     # print(mysql_cmd)

plugins/mysql/js/mysql.js

@@ -445,10 +445,9 @@ function syncToDatabase(type){
 
 function setRootPwd(type, pwd){
     if (type==1){
-        var data = $("#mod_pwd").serialize();
-        myPost('set_root_pwd', data, function(data){
+        var password = $("#MyPassword").val();
+        myPost('set_root_pwd', {password:password}, function(data){
             var rdata = $.parseJSON(data.data);
-            // console.log(rdata);
             showMsg(rdata.msg,function(){
                 dbList();
                 $('.layui-layer-close1').click();
@@ -459,26 +458,23 @@ function setRootPwd(type, pwd){
 
     var index = layer.open({
         type: 1,
-        skin: 'demo-class',
         area: '500px',
         title: '修改数据库密码',
         closeBtn: 1,
         shift: 5,
+        btn:["提交","关闭"],
         shadeClose: true,
-        content: "<form class='bt-form pd20 pb70' id='mod_pwd'>\
+        content: "<form class='bt-form pd20' id='mod_pwd'>\
                     <div class='line'>\
-                    <span class='tname'>root密码</span>\
-                    <div class='info-r'><input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+pwd+"' /><span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span></div>\
-                    </div>\
-                    <div class='bt-form-submit-btn'>\
-                        <button id='my_mod_close' type='button' class='btn btn-danger btn-sm btn-title'>关闭</button>\
-                        <button type='button' class='btn btn-success btn-sm btn-title' onclick=\"setRootPwd(1)\" >提交</button>\
+                        <span class='tname'>root密码</span>\
+                        <div class='info-r'><input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+pwd+"' />\
+                            <span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span>\
+                        </div>\
                     </div>\
                   </form>",
-    });
-
-    $('#my_mod_close').click(function(){
-        $('.layui-layer-close1').click();
+        yes:function(){
+            setRootPwd(1);
+        }
     });
 }
 
@@ -632,12 +628,18 @@ function setDbPass(id, username, password){
                     </div>\
                     <div class='line'>\
                     <span class='tname'>密码</span>\
-                    <div class='info-r'><input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+password+"' /><span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span></div>\
+                    <div class='info-r'>\
+                        <input class='bt-input-text mr5' type='text' name='password' id='MyPassword' style='width:330px' value='"+password+"' />\
+                        <span title='随机密码' class='glyphicon glyphicon-repeat cursor' onclick='repeatPwd(16)'></span></div>\
                     </div>\
                     <input type='hidden' name='id' value='"+id+"'>\
                   </form>",
         yes:function(index){
-            var data = $("#mod_pwd").serialize();
+            // var data = $("#mod_pwd").serialize();
+            var data = {};
+            data['name'] = $('input[name=name]').val();
+            data['password'] = $('#MyPassword').val();
+            data['id'] = $('input[name=id]').val();
             myPost('set_user_pwd', data, function(data){
                 var rdata = $.parseJSON(data.data);
                 showMsg(rdata.msg,function(){
@@ -809,6 +811,14 @@ function openPhpmyadmin(name,username,password){
         layer.msg('phpMyAdmin未启动',{icon:2,shade: [0.3, '#000']});
         return;
     }
+
+    data = syncPost('/plugins/run',{'name':'phpmyadmin','func':'get_cfg'});
+    var rdata = $.parseJSON(data.data);
+    if (rdata.choose == 'mariadb'){
+        layer.msg('当前为[mariadb]模式,若要使用请切换模式.',{icon:2,shade: [0.3, '#000']});
+        return;
+    }
+    
     // console.log(data);
     data = syncPost('/plugins/run',{'name':'phpmyadmin','func':'get_home_page'});
     var rdata = $.parseJSON(data.data);

plugins/op_waf/waf/lua/init.lua

@@ -12,6 +12,37 @@ config = C:read_file_body_decode(cpath .. 'config.json')
 local site_config = C:read_file_body_decode(cpath .. 'site.json')
 C:setConfData(config, site_config)
 
+-- D func
+local function D(msg)
+    local _msg = ''
+    if type(msg) == 'table' then
+        for key, val in pairs(msg) do
+            _msg = key..':'..val.."\n"
+        end
+    elseif type(msg) == 'string' then
+        _msg = msg
+     elseif type(msg) == 'nil' then
+        _msg = 'nil'
+    else
+        _msg = msg
+    end
+
+    if not debug_mode then return true end
+    local fp = io.open(cpath..'debug.log', 'ab')
+    if fp == nil then
+        return nil
+    end
+    local localtime = os.date("%Y-%m-%d %H:%M:%S")
+    if server_name then
+        fp:write(tostring(_msg) .. "\n")
+    else
+        fp:write(localtime..":"..tostring(_msg) .. "\n")
+    end
+    fp:flush()
+    fp:close()
+    return true
+end
+
 function initParams()
     local data = {}
     data['ip'] = C:get_client_ip()
@@ -314,6 +345,7 @@ end
 function  post_data_chekc()
     if params['method'] =="POST" then
         if C:return_post_data() then return false end
+        ngx.req.read_body()
         request_args = ngx.req.get_post_args()
         if not request_args then return false end
 

plugins/php/index.py

@@ -146,7 +146,7 @@ def contentReplace(content, version):
 
 def makeOpenrestyConf():
     phpversions = ['00', '52', '53', '54', '55', '56',
-                   '70', '71', '72', '73', '74', '80', '81']
+                   '70', '71', '72', '73', '74', '80', '81', '82']
 
     sdir = mw.getServerDir()
 

plugins/php/versions/74/install.sh

@@ -39,7 +39,11 @@ if [ ! -d $sourcePath/php/php${PHP_VER} ];then
 	mv $sourcePath/php/php-${version} $sourcePath/php/php${PHP_VER}
 fi
 
-
+if [ ! -d $sourcePath/php/php${PHP_VER} ];then
+	rm -rf $sourcePath/php/php-${version}.tar.xz
+	echo "reinstall php${version}"
+	exit 1
+fi
 
 cd $sourcePath/php/php${PHP_VER}
 

plugins/php/versions/common/redis.sh

@@ -12,7 +12,7 @@ serverPath=$(dirname "$rootPath")
 sourcePath=${serverPath}/source/php
 
 LIBNAME=redis
-LIBV=5.3.7
+LIBV=5.3.6
 sysName=`uname`
 actionType=$1
 version=$2

plugins/phpmyadmin/conf/config.inc.php

@@ -2,10 +2,11 @@
 $cfg['blowfish_secret'] = '{$BLOWFISH_SECRET}';
 $i                      = 0;
 $i++;
+$cfg['Servers'][$i]['verbose']   = '{$CHOOSE_DB}';
 $cfg['Servers'][$i]['auth_type'] = 'cookie';
 // $cfg['Servers'][$i]['host']            = '127.0.0.1';
 // $cfg['Servers'][$i]['connect_type']    = 'tcp';
-$cfg['Servers'][$i]['socket']          = '{$SERVER_PATH}/mysql/mysql.sock';
+$cfg['Servers'][$i]['socket']          = '{$SERVER_PATH}/{$CHOOSE_DB_DIR}/mysql.sock';
 $cfg['Servers'][$i]['connect_type']    = 'socket';
 $cfg['Servers'][$i]['compress']        = false;
 $cfg['Servers'][$i]['AllowNoPassword'] = false;

plugins/phpmyadmin/conf/phpmyadmin.conf

@@ -8,6 +8,11 @@ server
     #error_page   404   /404.html;
     include {$PHP_CONF_PATH}/enable-php-{$PHP_VER}.conf;
 
+    #AUTH_START
+    auth_basic "Authorization";
+    auth_basic_user_file {$SERVER_PATH}/phpmyadmin/pma.pass;
+    #AUTH_END
+
     location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$
     {
         expires      30d;
@@ -18,7 +23,7 @@ server
         expires      12h;
     }
 
-    location ~ /.*\.log$ {
+    location ~ /.*\.(log|pass|json|pl)$ {
         deny all;
     }
 

plugins/phpmyadmin/index.py

@@ -5,6 +5,7 @@ import io
 import os
 import time
 import re
+import json
 
 sys.path.append(os.getcwd() + "/class/core")
 import mw
@@ -44,6 +45,13 @@ def getArgs():
     return tmp
 
 
+def checkArgs(data, ck=[]):
+    for i in range(len(ck)):
+        if not ck[i] in data:
+            return (False, mw.returnJson(False, '参数:(' + ck[i] + ')没有!'))
+    return (True, mw.returnJson(True, 'ok'))
+
+
 def getConf():
     return mw.getServerDir() + '/web_conf/nginx/vhost/phpmyadmin.conf'
 
@@ -107,9 +115,50 @@ def contentReplace(content):
     content = content.replace('{$PHP_CONF_PATH}', php_conf_dir)
     content = content.replace('{$PHP_VER}', php_ver)
     content = content.replace('{$BLOWFISH_SECRET}', blowfish_secret)
+
+    cfg = getCfg()
+    if (cfg['choose'] == ""):
+        content = content.replace('{$CHOOSE_DB}', 'mysql')
+        content = content.replace('{$CHOOSE_DB_DIR}', 'mysql')
+    else:
+        content = content.replace('{$CHOOSE_DB}', 'MariaDB')
+        content = content.replace('{$CHOOSE_DB_DIR}', 'mariadb')
+
     return content
 
 
+def initCfg():
+    cfg = getServerDir() + "/cfg.json"
+    if not os.path.exists(cfg):
+        data = {}
+        data['port'] = '888'
+        data['choose'] = ''
+        data['username'] = 'admin'
+        data['password'] = 'admin'
+        mw.writeFile(cfg, json.dumps(data))
+
+
+def setCfg(key, val):
+    cfg = getServerDir() + "/cfg.json"
+    data = mw.readFile(cfg)
+    data = json.loads(data)
+    data[key] = val
+    mw.writeFile(cfg, json.dumps(data))
+
+
+def getCfg():
+    cfg = getServerDir() + "/cfg.json"
+    data = mw.readFile(cfg)
+    data = json.loads(data)
+    return data
+
+
+def returnCfg():
+    cfg = getServerDir() + "/cfg.json"
+    data = mw.readFile(cfg)
+    return data
+
+
 def status():
     conf = getConf()
     conf_inc = getServerDir() + '/phpmyadmin/config.inc.php'
@@ -120,6 +169,8 @@ def status():
 
 
 def start():
+    initCfg()
+
     file_tpl = getPluginDir() + '/conf/phpmyadmin.conf'
     file_run = getConf()
 
@@ -128,6 +179,14 @@ def start():
         centent = contentReplace(centent)
         mw.writeFile(file_run, centent)
 
+    pma_path = getServerDir() + '/pma.pass'
+    if not os.path.exists(pma_path):
+        username = mw.getRandomString(10)
+        pass_cmd = username + ':' + mw.hasPwd(username)
+        setCfg('username', username)
+        setCfg('password', username)
+        mw.writeFile(pma_path, pass_cmd)
+
     tmp = getServerDir() + '/phpmyadmin/tmp'
     if not os.path.exists(tmp):
         os.mkdir(tmp)
@@ -179,12 +238,11 @@ def setPhpVer():
     file_tpl = getPluginDir() + '/conf/phpmyadmin.conf'
     file_run = getConf()
 
-    centent = mw.readFile(file_tpl)
-    centent = contentReplace(centent)
-    mw.writeFile(file_run, centent)
+    content = mw.readFile(file_tpl)
+    content = contentReplace(content)
+    mw.writeFile(file_run, content)
 
     mw.restartWeb()
-
     return 'ok'
 
 
@@ -195,6 +253,11 @@ def getSetPhpVer():
     return ''
 
 
+def getPmaOption():
+    data = getCfg()
+    return mw.returnJson(True, 'ok', data)
+
+
 def getPmaPort():
     try:
         port = getPort()
@@ -206,8 +269,9 @@ def getPmaPort():
 
 def setPmaPort():
     args = getArgs()
-    if not 'port' in args:
-        return mw.returnJson(False, 'port missing!')
+    data = checkArgs(args, ['port'])
+    if not data[0]:
+        return data[1]
 
     port = args['port']
     if port == '80':
@@ -224,6 +288,63 @@ def setPmaPort():
     return mw.returnJson(True, '修改成功!')
 
 
+def setPmaChoose():
+    args = getArgs()
+    data = checkArgs(args, ['choose'])
+    if not data[0]:
+        return data[1]
+
+    choose = args['choose']
+    setCfg('choose', choose)
+
+    conf_run = getServerDir() + '/phpmyadmin/config.inc.php'
+    conf_tpl = getPluginDir() + '/conf/config.inc.php'
+    centent = mw.readFile(conf_tpl)
+    centent = contentReplace(centent)
+    mw.writeFile(conf_run, centent)
+
+    mw.restartWeb()
+    return mw.returnJson(True, '修改成功!')
+
+
+def setPmaUsername():
+    args = getArgs()
+    data = checkArgs(args, ['username'])
+    if not data[0]:
+        return data[1]
+
+    username = args['username']
+    setCfg('username', username)
+
+    cfg = getCfg()
+    pma_path = getServerDir() + '/pma.pass'
+    username = mw.getRandomString(10)
+    pass_cmd = cfg['username'] + ':' + mw.hasPwd(cfg['password'])
+    mw.writeFile(pma_path, pass_cmd)
+
+    mw.restartWeb()
+    return mw.returnJson(True, '修改成功!')
+
+
+def setPmaPassword():
+    args = getArgs()
+    data = checkArgs(args, ['password'])
+    if not data[0]:
+        return data[1]
+
+    password = args['password']
+    setCfg('password', password)
+
+    cfg = getCfg()
+    pma_path = getServerDir() + '/pma.pass'
+    username = mw.getRandomString(10)
+    pass_cmd = cfg['username'] + ':' + mw.hasPwd(cfg['password'])
+    mw.writeFile(pma_path, pass_cmd)
+
+    mw.restartWeb()
+    return mw.returnJson(True, '修改成功!')
+
+
 def accessLog():
     return getServerDir() + '/access.log'
 
@@ -252,6 +373,8 @@ if __name__ == "__main__":
         print(getConf())
     elif func == 'version':
         print(Version())
+    elif func == 'get_cfg':
+        print(returnCfg())
     elif func == 'config_inc':
         print(getConfInc())
     elif func == 'get_home_page':
@@ -264,6 +387,14 @@ if __name__ == "__main__":
         print(getPmaPort())
     elif func == 'set_pma_port':
         print(setPmaPort())
+    elif func == 'get_pma_option':
+        print(getPmaOption())
+    elif func == 'set_pma_choose':
+        print(setPmaChoose())
+    elif func == 'set_pma_username':
+        print(setPmaUsername())
+    elif func == 'set_pma_password':
+        print(setPmaPassword())
     elif func == 'access_log':
         print(accessLog())
     elif func == 'error_log':

plugins/phpmyadmin/js/phpmyadmin.js

@@ -90,24 +90,68 @@ function phpVerChange(type, msg) {
 
 //phpmyadmin安全设置
 function safeConf() {
-    var data = pmaAsyncPost('get_pma_port');
-    var rdata = $.parseJSON(data.data);
-    if (!rdata.status){
-        layer.msg(rdata.msg,{icon:2,time:2000,shade: [0.3, '#000']});
-        return;
-    }
-    var con = '<div class="ver line">\
-                    <span style="margin-right:10px">访问端口</span>\
-                    <input class="bt-input-text phpmyadmindk mr20" name="Name" id="pmport" value="' + rdata['data'] + '" placeholder="phpmyadmin访问端口" maxlength="5" type="number">\
-                    <button class="btn btn-success btn-sm" onclick="phpmyadminPort()">保存</button>\
+    pmaPost('get_pma_option', {}, function(rdata){
+        var rdata = $.parseJSON(rdata.data);
+        if (!rdata.status){
+            layer.msg(rdata.msg,{icon:2,time:2000,shade: [0.3, '#000']});
+            return;
+        }
+
+        var cfg = rdata.data;
+        var con = '<div class="ver line">\
+                    <span class="tname">访问端口</span>\
+                    <input style="width:110px" class="bt-input-text phpmyadmindk mr20" name="Name" id="pmport" value="' + cfg['port'] + '" placeholder="phpmyadmin访问端口" maxlength="5" type="number">\
+                    <button class="btn btn-success btn-sm" onclick="setPamPort()">保存</button>\
+                </div>\
+                <div class="ver line">\
+                    <span class="tname">访问切换</span>\
+                    <select id="access_choose" class="bt-input-text mr20" name="choose" style="width:110px">\
+                        <option value="mariadb" '+(cfg['choose']=="mariadb"?"selected='selected'":"")+'>MariaDB</option>\
+                        <option value="mysql" '+ (cfg['choose']==""?"selected='selected'":"")+'>MySQL</option>\
+                    </select>\
+                    <button class="btn btn-success btn-sm" onclick="setPmaChoose()">保存</button>\
+                </div>\
+                <div class="ver line">\
+                    <span class="tname">用户名</span>\
+                    <input style="width:110px" class="bt-input-text mr20" name="username" id="pmport" value="' + cfg['username'] + '" placeholder="认证用户名" type="text">\
+                    <button class="btn btn-success btn-sm" onclick="setPmaUsername()">保存</button>\
+                </div>\
+                <div class="ver line">\
+                    <span class="tname">密码</span>\
+                    <input style="width:110px" class="bt-input-text mr20" name="password" id="pmport" value="' + cfg['password'] + '" placeholder="密码" type="text">\
+                    <button class="btn btn-success btn-sm" onclick="setPmaPassword()">保存</button>\
                 </div>';
-    $(".soft-man-con").html(con);
+        $(".soft-man-con").html(con);
+    });
 }
 
 
+function setPmaChoose(){
+    var choose = $("#access_choose").val();
+    pmaPost('set_pma_choose',{'choose':choose}, function(data){
+        var rdata = $.parseJSON(data.data);
+        layer.msg(rdata.msg, { icon: rdata.status ? 1 : 2 });
+    });
+}
+
+function setPmaUsername(){
+    var username = $("input[name=username]").val();
+    pmaPost('set_pma_username',{'username':username}, function(data){
+        var rdata = $.parseJSON(data.data);
+        layer.msg(rdata.msg, { icon: rdata.status ? 1 : 2 });
+    });
+}
+
+function setPmaPassword(){
+    var password = $("input[name=password]").val();
+    pmaPost('set_pma_password',{'password':password}, function(data){
+        var rdata = $.parseJSON(data.data);
+        layer.msg(rdata.msg, { icon: rdata.status ? 1 : 2 });
+    });
+}
 
 //修改phpmyadmin端口
-function phpmyadminPort() {
+function setPamPort() {
     var pmport = $("#pmport").val();
     if (pmport < 80 || pmport > 65535) {
         layer.msg('端口范围不合法!', { icon: 2 });

plugins/redis/info.json

@@ -4,8 +4,8 @@
 	"name": "redis",
 	"title": "Redis",
 	"shell": "install.sh",
-	"versions":["4.0.11","5.0.8","6.0.4","6.2.7"],
-	"updates":["4.0.11","5.0.8","6.0.4","6.2.7"],
+	"versions":["4.0.11","5.0.8","6.0.4","6.2.7","7.0.4"],
+	"updates":["4.0.11","5.0.8","6.0.4","6.2.7","7.0.4"],
 	"tip": "soft",
 	"checks": "server/redis",
 	"path": "server/redis",

plugins/rsyncd/js/rsyncd.js

@@ -339,7 +339,10 @@ function createSendTask(name = ''){
                     layer.msg(rdata.msg,{icon:rdata.status?1:2,time:2000,shade: [0.3, '#000']});
 
                     if (rdata.status){
-                         setTimeout(function(){layer.close(index);},2000);
+                         setTimeout(function(){
+                            layer.close(index);
+                            lsyncdSend();
+                         },2000);
                         return;
                     }
                 });

plugins/supervisor/index.py

@@ -56,7 +56,7 @@ def getArgs():
         tmp[t[0]] = t[1]
     elif args_len > 1:
         for i in range(len(args)):
-            t = args[i].split(':')
+            t = args[i].split(':', 1)
             tmp[t[0]] = t[1]
 
     return tmp
@@ -477,6 +477,28 @@ def readConfigLogTpl():
     return mw.returnJson(False, 'OK', '')
 
 
+def readConfigLogErrorTpl():
+    args = getArgs()
+    data = checkArgs(args, ['file'])
+    if not data[0]:
+        return data[1]
+    file_log = args['file']
+    line_log = args['line']
+
+    with open(file_log, "r") as fr:
+        infos = fr.readlines()
+
+    stderr_logfile = ''
+    for line in infos:
+        if "stderr_logfile=" in line.strip():
+            stderr_logfile = line.strip().split('=')[1]
+
+    if stderr_logfile != '':
+        data = mw.getNumLines(stderr_logfile, int(line_log))
+        return mw.returnJson(True, 'OK', data)
+    return mw.returnJson(False, 'OK', '')
+
+
 def supClearLog():
     args = getArgs()
     data = checkArgs(args, ['file'])
@@ -529,6 +551,8 @@ if __name__ == "__main__":
         print(readConfigTpl())
     elif func == 'read_config_log_tpl':
         print(readConfigLogTpl())
+    elif func == 'read_config_log_error_tpl':
+        print(readConfigLogErrorTpl())
     elif func == 'sup_clear_log':
         print(supClearLog())
     elif func == 'conf':

plugins/supervisor/js/supervisor.js

@@ -405,7 +405,7 @@ function supConfigTpl(_name, version, func, config_tpl_func, read_config_tpl_fun
 		                return;
 		            }
 
-    				$("#textBody").empty().text(rdata.data);
+    				$("#textBody").empty().html(rdata.data);
     				$(".CodeMirror").remove();
 		            var editor = CodeMirror.fromTextArea(document.getElementById("textBody"), {
 		                extraKeys: {
@@ -424,7 +424,7 @@ function supConfigTpl(_name, version, func, config_tpl_func, read_config_tpl_fun
 		            $(".CodeMirror-scroll").css({"height":"300px","margin":0,"padding":0});
 		            $("#onlineEditFileBtn").unbind('click');
 		            $("#onlineEditFileBtn").click(function(){
-		                $("#textBody").text(editor.getValue());
+		                $("#textBody").html(editor.getValue());
 		                pluginConfigSave(fileName);
 		            });
     			},'json');
@@ -474,6 +474,7 @@ function supLogs(_name, config_tpl_func, read_config_tpl_func,line){
 
     var con = '<div><select id="config_tpl" class="bt-input-text mr20" style="width:30%;margin-bottom: 3px;"><option value="0">请选择</option></select>\
     			<button id="sup_clear_log" class="btn btn-success btn-sm clear_logs mr5">清理日志</button>\
+    			<button id="sup_error_log" class="btn btn-success btn-sm clear_logs mr5">查看错误日志</button>\
     		</div>';
     con += '<textarea readonly="" style="margin: 0px;width: 100%;height: 520px;background-color: #333;color:#fff; padding:0 5px" id="info_log"></textarea>';
     $(".soft-man-con").html(con);
@@ -489,6 +490,21 @@ function supLogs(_name, config_tpl_func, read_config_tpl_func,line){
     	});
     }
 
+    function errorLog(file,file_line){
+    	$('#sup_error_log').click(function(){
+    		var _args = JSON.stringify({file:file,line:file_line});
+			$.post('/plugins/run', {name:_name, func:'read_config_log_error_tpl',args:_args}, function(data){
+				var rdata = $.parseJSON(data.data);
+				if (!rdata.status){
+	                layer.msg(rdata.msg,{icon:0,time:2000,shade: [0.3, '#000']});
+	                return;
+	            }
+
+				$("#info_log").empty().html(rdata.data);
+			},'json');
+    	});
+    }
+
     var loadT = layer.msg('日志路径获取中...',{icon:16,time:0,shade: [0.3, '#000']});
     $.post('/plugins/run', {name:_name, func:_config_tpl_func},function (data) {
         layer.close(loadT);
@@ -517,10 +533,11 @@ function supLogs(_name, config_tpl_func, read_config_tpl_func,line){
 	                return;
 	            }
 
-				$("#info_log").empty().text(rdata.data);
+				$("#info_log").empty().html(rdata.data);
 			},'json');
 
 			clearLog(selected);
+			errorLog(selected,file_line);
     	///
     	});
 

route/static/app/crontab.js

@@ -203,6 +203,7 @@ function planAdd(){
 	$("#set-Config input[name='type']").val(type);
 	
 	var where1 = $("#ptime input[name='where1']").val();
+	
 	var is1;
 	var is2 = 1;
 	switch(type){
@@ -226,6 +227,7 @@ function planAdd(){
 		return;
 	}
 	
+	where1 = $('#excode_week b').attr('val');
 	$("#set-Config input[name='where1']").val(where1);
 	
 	var hour = $("#ptime input[name='hour']").val();
@@ -305,7 +307,9 @@ function planAdd(){
 	
 	$("#set-Config input[name='sName']").val(sName);
 	layer.msg('正在添加,请稍候...!',{icon:16,time:0,shade: [0.3, '#000']});
-	var data= $("#set-Config").serialize() + '&sBody='+sBody + '&urladdress=' + urladdress;
+	var data = $("#set-Config").serialize() + '&sBody='+sBody + '&urladdress=' + urladdress;
+
+	console.log(data);
 	$.post('/crontab/add',data,function(rdata){
 		if(!rdata.status) {
 			layer.msg(rdata.msg,{icon:2, time:2000});
@@ -469,9 +473,9 @@ function toBackup(type){
 			sOpt += '<li><a role="menuitem" tabindex="-1" href="javascript:;" value="'+rdata.data[i].name+'">'+rdata.data[i].name+'['+rdata.data[i].ps+']</a></li>';			
 		}
 		
-		var orderOpt = ''
+		var orderOpt = '';
 		for (var i=0;i<rdata.orderOpt.length;i++){
-			orderOpt += '<li><a role="menuitem" tabindex="-1" href="javascript:;" value="'+rdata.orderOpt[i].value+'">'+rdata.orderOpt[i].name+'</a></li>'
+			orderOpt += '<li><a role="menuitem" tabindex="-1" href="javascript:;" value="'+rdata.orderOpt[i].name+'">'+rdata.orderOpt[i].title+'</a></li>'
 		}
 		
 
@@ -514,7 +518,7 @@ function editTaskInfo(id){
 	layer.msg('正在获取,请稍候...',{icon:16,time:0,shade: [0.3, '#000']});
 	$.post('/crontab/get_crond_find',{id:id},function(rdata){
 		layer.closeAll();
-		// console.log('init:', rdata);
+		// console.log('get_crond_find:', rdata);
 		var sTypeName = '',sTypeDom = '',cycleName = '',cycleDom = '',weekName = '',weekDom = '',sNameName ='',sNameDom = '',backupsName = '',backupsDom ='';
 		obj = {
 			from:{
@@ -557,10 +561,11 @@ function editTaskInfo(id){
 
 				if(obj.from.stype == 'site' || obj.from.stype == 'database' || obj.from.stype == 'path' || obj.from.stype == 'logs'){
 					$.post('/crontab/get_data_list',{type:obj.from.stype  == 'databases'?'database':'sites'},function(rdata){
+						// console.log(rdata);
 						obj.sNameArray = rdata.data;
 						obj.sNameArray.unshift({name:'ALL',ps:'所有'});
 						obj.backupsArray = rdata.orderOpt;
-						obj.backupsArray.unshift({name:'服务器磁盘',value:'localhost'});
+						obj.backupsArray.unshift({title:'服务器磁盘',name:'localhost'});
 						for(var i = 0; i <obj['sNameArray'].length; i++){
 							if(obj.from['sname'] == obj['sNameArray'][i]['name']){
 								sNameName  = obj['sNameArray'][i]['ps'];
@@ -568,10 +573,10 @@ function editTaskInfo(id){
 							sNameDom += '<li><a role="menuitem"  href="javascript:;" value="'+ obj['sNameArray'][i]['name'] +'">'+ obj['sNameArray'][i]['ps'] +'</a></li>';
 						}
 						for(var i = 0; i <obj['backupsArray'].length; i++){
-							if(obj.from['backup_to'] == obj['backupsArray'][i]['value'])  {
-								backupsName  = obj['backupsArray'][i]['name'];
+							if(obj.from['backup_to'] == obj['backupsArray'][i]['name'])  {
+								backupsName  = obj['backupsArray'][i]['title'];
 							}
-							backupsDom += '<li><a role="menuitem"  href="javascript:;" value="'+ obj['backupsArray'][i]['value'] +'">'+ obj['backupsArray'][i]['name'] +'</a></li>';
+							backupsDom += '<li><a role="menuitem"  href="javascript:;" value="'+ obj['backupsArray'][i]['name'] +'">'+ obj['backupsArray'][i]['title'] +'</a></li>';
 						}
 						callback();
 					},'json');
@@ -629,7 +634,7 @@ function editTaskInfo(id){
 								<span class="typename controls c4 pull-left f14 text-right mr20">'+ sTypeName  +'</span>\
 								<div style="line-height:34px"><div class="dropdown pull-left mr20 sName_btn" style="display:'+ (obj.from.sType != "path"?'block;':'none') +'">\
 									<button class="btn btn-default dropdown-toggle" type="button"  data-toggle="dropdown" style="width:auto" disabled="disabled">\
-										<b id="sName" val="'+ obj.from.sname +'">'+ sNameName +'</b>\
+										<b id="sName" val="'+ obj.from.sname +'">'+ obj.from.sname +'</b>\
 										<span class="caret"></span>\
 									</button>\
 									<ul class="dropdown-menu" role="menu" aria-labelledby="sName">'+ sNameDom +'</ul>\
@@ -835,10 +840,10 @@ function closeOpt(){
 //星期
 function toWeek(){
 	var mBody = '<div class="dropdown planweek pull-left mr20">\
-				  <button class="btn btn-default dropdown-toggle" type="button" id="excode" data-toggle="dropdown">\
+				  <button class="btn btn-default dropdown-toggle" type="button" id="excode_week" data-toggle="dropdown">\
 					<b val="1">周一</b> <span class="caret"></span>\
 				  </button>\
-				  <ul class="dropdown-menu" role="menu" aria-labelledby="excode">\
+				  <ul class="dropdown-menu" role="menu" aria-labelledby="excode_week">\
 					<li><a role="menuitem" tabindex="-1" href="javascript:;" value="1">周一</a></li>\
 					<li><a role="menuitem" tabindex="-1" href="javascript:;" value="2">周二</a></li>\
 					<li><a role="menuitem" tabindex="-1" href="javascript:;" value="3">周三</a></li>\

scripts/install/debian.sh

@@ -17,6 +17,7 @@ if grep -Eq "Debian" /etc/*-release; then
 fi
 
 apt update -y
+apt-get update -y 
 
 
 apt install -y wget curl lsof unzip

scripts/install/ubuntu.sh

@@ -10,6 +10,7 @@ fi
 
 
 apt update -y
+apt-get update -y 
 
 apt install -y wget curl lsof unzip
 apt install -y python3-pip