diff --git a/task.py b/task.py deleted file mode 100755 index 71691f088..000000000 --- a/task.py +++ /dev/null @@ -1,633 +0,0 @@ -# coding: utf-8 - -# --------------------------------------------------------------------------------- -# MW-Linux面板 -# --------------------------------------------------------------------------------- -# copyright (c) 2018-∞(https://github.com/midoks/mdserver-web) All rights reserved. -# --------------------------------------------------------------------------------- -# Author: midoks -# --------------------------------------------------------------------------------- - -# --------------------------------------------------------------------------------- -# 计划任务 -# --------------------------------------------------------------------------------- - -import sys -import os -import json -import time -import threading -import psutil - -if sys.version_info[0] == 2: - reload(sys) - sys.setdefaultencoding('utf-8') - - -sys.path.append(os.getcwd() + "/class/core") -import mw -import db - -# print sys.path - -# cmd = 'ls /usr/local/lib/ | grep python | cut -d \\ -f 1 | awk \'END {print}\'' -# info = mw.execShell(cmd) -# p = "/usr/local/lib/" + info[0].strip() + "/site-packages" -# sys.path.append(p) - - -global pre, timeoutCount, logPath, isTask, oldEdate, isCheck -pre = 0 -timeoutCount = 0 -isCheck = 0 -oldEdate = None - -logPath = os.getcwd() + '/tmp/panelExec.log' -isTask = os.getcwd() + '/tmp/panelTask.pl' - -if not os.path.exists(os.getcwd() + "/tmp"): - os.system('mkdir -p ' + os.getcwd() + "/tmp") - -if not os.path.exists(logPath): - os.system("touch " + logPath) - - -def service_cmd(method): - cmd = '/etc/init.d/mw' - if os.path.exists(cmd): - execShell(cmd + ' ' + method) - return - - cmd = mw.getRunDir() + '/scripts/init.d/mw' - if os.path.exists(cmd): - execShell(cmd + ' ' + method) - return - - -def openresty_cmd(method = 'reload'): - # 检查是否安装 - odir = mw.getServerDir() + '/openresty' - if not os.path.exists(odir): - return False - - # systemd - systemd = mw.systemdCfgDir()+'/openresty.service' - if os.path.exists(systemd): - execShell('systemctl ' + method + ' openresty') - return True - - sys_initd = '/etc/init.d/openresty' - if os.path.exists(sys_initd): - os.system(sys_initd + ' ' + method) - return True - - install_initd = mw.getServerDir()+'/openresty/init.d/openresty' - if os.path.exists(install_initd): - os.system(install_initd + ' ' + method) - return True - return False - -def mw_async(f): - def wrapper(*args, **kwargs): - thr = threading.Thread(target=f, args=args, kwargs=kwargs) - thr.start() - return wrapper - - -@mw_async -def restartMw(): - time.sleep(1) - cmd = mw.getRunDir() + '/scripts/init.d/mw reload &' - mw.execShell(cmd) - - -def execShell(cmdstring, cwd=None, timeout=None, shell=True): - try: - global logPath - import shlex - import datetime - import subprocess - - if timeout: - end_time = datetime.datetime.now() + datetime.timedelta(seconds=timeout) - - cmd = cmdstring + ' > ' + logPath + ' 2>&1' - sub = subprocess.Popen( - cmd, cwd=cwd, stdin=subprocess.PIPE, shell=shell, bufsize=4096) - while sub.poll() is None: - time.sleep(0.1) - - data = sub.communicate() - # python3 fix 返回byte数据 - if isinstance(data[0], bytes): - t1 = str(data[0], encoding='utf-8') - - if isinstance(data[1], bytes): - t2 = str(data[1], encoding='utf-8') - return (t1, t2) - except Exception as e: - return (None, None) - - -def downloadFile(url, filename): - # 下载文件 - try: - import urllib - import socket - socket.setdefaulttimeout(300) - - headers = ( - 'User-Agent', 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.88 Safari/537.36') - opener = urllib.request.build_opener() - opener.addheaders = [headers] - urllib.request.install_opener(opener) - - urllib.request.urlretrieve( - url, filename=filename, reporthook=downloadHook) - - if not mw.isAppleSystem(): - os.system('chown www.www ' + filename) - - writeLogs('done') - except Exception as e: - writeLogs(str(e)) - - -def downloadHook(count, blockSize, totalSize): - # 下载文件进度回调 - global pre - used = count * blockSize - pre1 = int((100.0 * used / totalSize)) - if pre == (100 - pre1): - return - speed = {'total': totalSize, 'used': used, 'pre': pre1} - writeLogs(json.dumps(speed)) - - -def writeLogs(logMsg): - # 写输出日志 - try: - global logPath - fp = open(logPath, 'w+') - fp.write(logMsg) - fp.close() - except: - pass - - -def runTask(): - global isTask - try: - if os.path.exists(isTask): - sql = db.Sql() - sql.table('tasks').where( - "status=?", ('-1',)).setField('status', '0') - taskArr = sql.table('tasks').where("status=?", ('0',)).field( - 'id,type,execstr').order("id asc").select() - for value in taskArr: - start = int(time.time()) - if not sql.table('tasks').where("id=?", (value['id'],)).count(): - continue - sql.table('tasks').where("id=?", (value['id'],)).save( - 'status,start', ('-1', start)) - if value['type'] == 'download': - argv = value['execstr'].split('|mw|') - downloadFile(argv[0], argv[1]) - elif value['type'] == 'execshell': - execShell(value['execstr']) - end = int(time.time()) - sql.table('tasks').where("id=?", (value['id'],)).save( - 'status,end', ('1', end)) - - if(sql.table('tasks').where("status=?", ('0')).count() < 1): - os.system('rm -f ' + isTask) - - sql.close() - except Exception as e: - print(str(e)) - - # 站点过期检查 - siteEdate() - - -def startTask(): - # 任务队列 - try: - while True: - runTask() - time.sleep(2) - except Exception as e: - time.sleep(60) - startTask() - - -def siteEdate(): - # 网站到期处理 - global oldEdate - try: - if not oldEdate: - oldEdate = mw.readFile('data/edate.pl') - if not oldEdate: - oldEdate = '0000-00-00' - mEdate = time.strftime('%Y-%m-%d', time.localtime()) - if oldEdate == mEdate: - return False - edateSites = mw.M('sites').where('edate>? AND edate 80: - panel_title = mw.getConfig('title') - ip = mw.getHostAddr() - now_time = mw.getDateFromNow() - msg = now_time + '|节点[' + panel_title + ':' + ip + \ - ']处于高负载[' + str(tmp['used']) + '],请排查原因!' - mw.notifyMessage(msg, '面板监控', 600) - - if not cpuInfo: - tmp['mem'] = sm.getMemUsed() - cpuInfo = tmp - - if cpuInfo['used'] < tmp['used']: - tmp['mem'] = sm.getMemUsed() - cpuInfo = tmp - - # 取当前网络Io - networkIo = sm.psutilNetIoCounters() - if not network_up: - network_up = networkIo[0] - network_down = networkIo[1] - tmp = {} - tmp['upTotal'] = networkIo[0] - tmp['downTotal'] = networkIo[1] - tmp['up'] = round(float((networkIo[0] - network_up) / 1024), 2) - tmp['down'] = round(float((networkIo[1] - network_down) / 1024), 2) - tmp['downPackets'] = networkIo[3] - tmp['upPackets'] = networkIo[2] - - network_up = networkIo[0] - network_down = networkIo[1] - - if not networkInfo: - networkInfo = tmp - if (tmp['up'] + tmp['down']) > (networkInfo['up'] + networkInfo['down']): - networkInfo = tmp - # 取磁盘Io - # if os.path.exists('/proc/diskstats'): - diskio_2 = psutil.disk_io_counters() - if not diskio_1: - diskio_1 = diskio_2 - tmp = {} - tmp['read_count'] = diskio_2.read_count - diskio_1.read_count - tmp['write_count'] = diskio_2.write_count - diskio_1.write_count - tmp['read_bytes'] = diskio_2.read_bytes - diskio_1.read_bytes - tmp['write_bytes'] = diskio_2.write_bytes - diskio_1.write_bytes - tmp['read_time'] = diskio_2.read_time - diskio_1.read_time - tmp['write_time'] = diskio_2.write_time - diskio_1.write_time - - if not diskInfo: - diskInfo = tmp - else: - diskInfo['read_count'] += tmp['read_count'] - diskInfo['write_count'] += tmp['write_count'] - diskInfo['read_bytes'] += tmp['read_bytes'] - diskInfo['write_bytes'] += tmp['write_bytes'] - diskInfo['read_time'] += tmp['read_time'] - diskInfo['write_time'] += tmp['write_time'] - diskio_1 = diskio_2 - - # print diskInfo - if count >= 12: - try: - addtime = int(time.time()) - deltime = addtime - (day * 86400) - - data = (cpuInfo['used'], cpuInfo['mem'], addtime) - sql.table('cpuio').add('pro,mem,addtime', data) - sql.table('cpuio').where("addtime 100: - lpro = 100 - sql.table('load_average').add('pro,one,five,fifteen,addtime', (lpro, load_average[ - 'one'], load_average['five'], load_average['fifteen'], addtime)) - - lpro = None - load_average = None - cpuInfo = None - networkInfo = None - diskInfo = None - count = 0 - reloadNum += 1 - if reloadNum > 1440: - reloadNum = 0 - mw.writeFile('logs/sys_interrupt.pl', - "reload num:" + str(reloadNum)) - restartMw() - except Exception as ex: - print(str(ex)) - mw.writeFile('logs/sys_interrupt.pl', str(ex)) - - del(tmp) - time.sleep(5) - count += 1 - except Exception as ex: - print(str(ex)) - mw.writeFile('logs/sys_interrupt.pl', str(ex)) - - restartMw() - - time.sleep(30) - systemTask() - - -# -------------------------------------- PHP监控 start --------------------------------------------- # -# 502错误检查线程 -def check502Task(): - try: - while True: - if os.path.exists(mw.getRunDir() + '/data/502Task.pl'): - check502() - time.sleep(30) - except: - time.sleep(30) - check502Task() - - -def check502(): - try: - verlist = [ - '52', '53', '54', '55', '56', '70', - '71', '72', '73', '74', '80', '81', - '82', '83' - ] - for ver in verlist: - sdir = mw.getServerDir() - php_path = sdir + '/php/' + ver + '/sbin/php-fpm' - if not os.path.exists(php_path): - continue - if checkPHPVersion(ver): - continue - if startPHPVersion(ver): - print('检测到PHP-' + ver + '处理异常,已自动修复!') - mw.writeLog('PHP守护程序', '检测到PHP-' + ver + '处理异常,已自动修复!') - except Exception as e: - print(str(e)) - - -# 处理指定PHP版本 -def startPHPVersion(version): - sdir = mw.getServerDir() - try: - # system - phpService = mw.systemdCfgDir() + '/php' + version + '.service' - if os.path.exists(phpService): - mw.execShell("systemctl restart php" + version) - if checkPHPVersion(version): - return True - - # initd - fpm = sdir + '/php/init.d/php' + version - php_path = sdir + '/php/' + version + '/sbin/php-fpm' - if not os.path.exists(php_path): - if os.path.exists(fpm): - os.remove(fpm) - return False - - if not os.path.exists(fpm): - return False - - # 尝试重载服务 - os.system(fpm + ' reload') - if checkPHPVersion(version): - return True - - # 尝试重启服务 - cgi = '/tmp/php-cgi-' + version + '.sock' - pid = sdir + '/php/' + version + '/var/run/php-fpm.pid' - data = mw.execShell("ps -ef | grep php/" + version +" | grep -v grep|grep -v python |awk '{print $2}'") - if data[0] != '': - os.system("ps -ef | grep php/" + version + " | grep -v grep|grep -v python |awk '{print $2}' | xargs kill ") - time.sleep(0.5) - if not os.path.exists(cgi): - os.system('rm -f ' + cgi) - if not os.path.exists(pid): - os.system('rm -f ' + pid) - os.system(fpm + ' start') - if checkPHPVersion(version): - return True - - # 检查是否正确启动 - if os.path.exists(cgi): - return True - except Exception as e: - print(str(e)) - return True - - -def getFpmConfFile(version): - return mw.getServerDir() + '/php/' + version + '/etc/php-fpm.d/www.conf' - - -def getFpmAddress(version): - fpm_address = '/tmp/php-cgi-{}.sock'.format(version) - php_fpm_file = getFpmConfFile(version) - try: - content = readFile(php_fpm_file) - tmp = re.findall(r"listen\s*=\s*(.+)", content) - if not tmp: - return fpm_address - if tmp[0].find('sock') != -1: - return fpm_address - if tmp[0].find(':') != -1: - listen_tmp = tmp[0].split(':') - if bind: - fpm_address = (listen_tmp[0], int(listen_tmp[1])) - else: - fpm_address = ('127.0.0.1', int(listen_tmp[1])) - else: - fpm_address = ('127.0.0.1', int(tmp[0])) - return fpm_address - except: - return fpm_address - - -def checkPHPVersion(version): - # 检查指定PHP版本 - try: - sock = getFpmAddress(version) - data = mw.requestFcgiPHP(sock, '/phpfpm_status_' + version + '?json') - result = str(data, encoding='utf-8') - except Exception as e: - result = 'Bad Gateway' - - # print(version,result) - # 检查openresty - if result.find('Bad Gateway') != -1: - return False - if result.find('HTTP Error 404: Not Found') != -1: - return False - - # 检查Web服务是否启动 - if result.find('Connection refused') != -1: - return False - # global isTask - # if os.path.exists(isTask): - # isStatus = mw.readFile(isTask) - # if isStatus == 'True': - # return True - - # # systemd - # systemd = mw.systemdCfgDir() + '/openresty.service' - # if os.path.exists(systemd): - # execShell('systemctl reload openresty') - # return True - # # initd - # initd = '/etc/init.d/openresty' - # if os.path.exists(initd): - # os.system(initd + ' reload') - return True - -# --------------------------------------PHP监控 end--------------------------------------------- # - - -# --------------------------------------OpenResty Auto Restart Start --------------------------------------------- # -# 解决acme.sh续签后,未起效。 -def openrestyAutoRestart(): - try: - while True: - # 检查是否安装 - odir = mw.getServerDir() + '/openresty' - if not os.path.exists(odir): - time.sleep(86400) - continue - - openresty_cmd('reload') - time.sleep(86400) - except Exception as e: - print(str(e)) - time.sleep(86400) - -# --------------------------------------OpenResty Auto Restart End --------------------------------------------- # - -# ------------------------------------ OpenResty Restart At Once Start ------------------------------------------ # - - -def openrestyRestartAtOnce(): - restart_nginx_tip = 'data/restart_nginx.pl' - while True: - if os.path.exists(restart_nginx_tip): - os.remove(restart_nginx_tip) - openresty_cmd('reload') - time.sleep(1) -# ----------------------------------- OpenResty Restart At Once End ------------------------------------------ # - - -# --------------------------------------Panel Restart Start --------------------------------------------- # -def restartPanelService(): - restartTip = 'data/restart.pl' - while True: - if os.path.exists(restartTip): - os.remove(restartTip) - service_cmd('restart_panel') - time.sleep(1) -# --------------------------------------Panel Restart End --------------------------------------------- # - - -def setDaemon(t): - if sys.version_info.major == 3 and sys.version_info.minor >= 10: - t.daemon = True - else: - t.setDaemon(True) - return t - -if __name__ == "__main__": - - # 系统监控 - sysTask = threading.Thread(target=systemTask) - sysTask = setDaemon(sysTask) - sysTask.start() - - # PHP 502错误检查线程 - php502 = threading.Thread(target=check502Task) - php502 = setDaemon(php502) - php502.start() - - # OpenResty Restart At Once Start - oraos = threading.Thread(target=openrestyRestartAtOnce) - oraos = setDaemon(oraos) - oraos.start() - - - # OpenResty Auto Restart Start - oar = threading.Thread(target=openrestyAutoRestart) - oar = setDaemon(oar) - oar.start() - - - # Panel Restart Start - rps = threading.Thread(target=restartPanelService) - rps = setDaemon(rps) - rps.start() - - startTask() diff --git a/tools.py b/tools.py deleted file mode 100755 index 6a050f9d9..000000000 --- a/tools.py +++ /dev/null @@ -1,303 +0,0 @@ -# coding: utf-8 - -# --------------------------------------------------------------------------------- -# MW-Linux面板 -# --------------------------------------------------------------------------------- -# copyright (c) 2018-∞(https://github.com/midoks/mdserver-web) All rights reserved. -# --------------------------------------------------------------------------------- -# Author: midoks -# --------------------------------------------------------------------------------- - -# --------------------------------------------------------------------------------- -# 工具箱 -# --------------------------------------------------------------------------------- - - -import sys -import os -import json -import time -import re - -sys.path.append(os.getcwd() + "/class/core") -import mw -import db - -# cmd = 'ls /usr/local/lib/ | grep python | cut -d \\ -f 1 | awk \'END {print}\'' -# info = mw.execShell(cmd) -# p = "/usr/local/lib/" + info[0].strip() + "/site-packages" -# sys.path.append(p) - -INIT_DIR = "/etc/rc.d/init.d" -if mw.isAppleSystem(): - INIT_DIR = mw.getRunDir() + "/scripts/init.d" - -INIT_CMD = INIT_DIR + "/mw" - - -def mw_input_cmd(msg): - if sys.version_info[0] == 2: - in_val = raw_input(msg) - else: - in_val = input(msg) - return in_val - - -def mwcli(mw_input=0): - raw_tip = "======================================================" - if not mw_input: - print("===============mdserver-web cli tools=================") - print("(1) 重启面板服务") - print("(2) 停止面板服务") - print("(3) 启动面板服务") - print("(4) 重载面板服务") - print("(5) 修改面板端口") - print("(10) 查看面板默认信息") - print("(11) 修改面板密码") - print("(12) 修改面板用户名") - print("(13) 显示面板错误日志") - print("(20) 关闭BasicAuth认证") - print("(21) 解除域名绑定") - print("(22) 解除面板SSL绑定") - print("(23) 开启IPV6支持") - print("(24) 关闭IPV6支持") - print("(25) 开启防火墙SSH端口") - print("(26) 关闭二次验证") - print("(27) 查看防火墙信息") - print("(100) 开启PHP52显示") - print("(101) 关闭PHP52显示") - print("(200) 切换Linux系统软件源") - print("(201) 简单速度测试") - print("(0) 取消") - print(raw_tip) - try: - mw_input = input("请输入命令编号：") - if sys.version_info[0] == 3: - mw_input = int(mw_input) - except: - mw_input = 0 - - nums = [ - 1, 2, 3, 4, 5, 10, 11, 12, 13, - 20, 21, 22, 23, 24, 25, 26, 27, - 100, 101, - 200, 201 - ] - if not mw_input in nums: - print(raw_tip) - print("已取消!") - exit() - - if mw_input == 1: - os.system(INIT_CMD + " restart") - elif mw_input == 2: - os.system(INIT_CMD + " stop") - elif mw_input == 3: - os.system(INIT_CMD + " start") - elif mw_input == 4: - os.system(INIT_CMD + " reload") - elif mw_input == 5: - in_port = mw_input_cmd("请输入新的面板端口：") - in_port_int = int(in_port.strip()) - if in_port_int < 65536 and in_port_int > 0: - import firewall_api - firewall_api.firewall_api().addAcceptPortArgs( - in_port, 'WEB面板[TOOLS修改]', 'port') - mw.writeFile('data/port.pl', in_port) - os.system(INIT_CMD + " restart_panel") - os.system(INIT_CMD + " default") - else: - print("|-端口范围在0-65536之间") - return - elif mw_input == 10: - os.system(INIT_CMD + " default") - elif mw_input == 11: - input_pwd = mw_input_cmd("请输入新的面板密码：") - if len(input_pwd.strip()) < 5: - print("|-错误，密码长度不能小于5位") - return - set_panel_pwd(input_pwd.strip(), True) - elif mw_input == 12: - input_user = mw_input_cmd("请输入新的面板用户名(>=5位)：") - set_panel_username(input_user.strip()) - elif mw_input == 13: - os.system('tail -100 ' + mw.getRunDir() + '/logs/error.log') - elif mw_input == 20: - basic_auth = 'data/basic_auth.json' - if os.path.exists(basic_auth): - os.remove(basic_auth) - os.system(INIT_CMD + " restart") - print("|-关闭basic_auth成功") - elif mw_input == 21: - bind_domain = 'data/bind_domain.pl' - if os.path.exists(bind_domain): - os.remove(bind_domain) - os.system(INIT_CMD + " unbind_domain") - print("|-解除域名绑定成功") - elif mw_input == 22: - ssl_choose = 'ssl/choose.pl' - if os.path.exists(ssl_choose): - os.remove(ssl_choose) - os.system(INIT_CMD + " unbind_ssl") - print("|-解除面板SSL绑定成功") - elif mw_input == 23: - listen_ipv6 = 'data/ipv6.pl' - if not os.path.exists(listen_ipv6): - mw.writeFile(listen_ipv6,'True') - os.system(INIT_CMD + " restart") - print("|-开启IPv6支持了") - else: - print("|-已开启IPv6支持!") - elif mw_input == 24: - listen_ipv6 = 'data/ipv6.pl' - if not os.path.exists(listen_ipv6): - print("|-已关闭IPv6支持!") - else: - os.remove(listen_ipv6) - os.system(INIT_CMD + " restart") - print("|-关闭IPv6支持了") - elif mw_input == 25: - open_ssh_port() - print("|-已开启!") - elif mw_input == 26: - auth_secret = 'data/auth_secret.pl' - if os.path.exists(auth_secret): - os.remove(auth_secret) - print("|-关闭二次验证成功!") - else: - print("|-二次验证已关闭!") - elif mw_input == 27: - cmd = 'which ufw' - run_cmd = False - find_cmd = mw.execShell(cmd) - if find_cmd[0].strip() != '': - run_cmd = True - os.system('ufw status') - - cmd = 'which firewall-cmd' - find_cmd = mw.execShell(cmd) - if find_cmd[0].strip() != '': - run_cmd = True - os.system('firewall-cmd --list-all') - if not run_cmd: - mw.echoInfo("未检测到防火墙!") - elif mw_input == 100: - php_conf = 'plugins/php/info.json' - if os.path.exists(php_conf): - cont = mw.readFile(php_conf) - cont = re.sub("\"53\"", "\"52\",\"53\"", cont) - cont = re.sub("\"5.3.29\"", "\"5.2.17\",\"5.3.29\"", cont) - mw.writeFile(php_conf, cont) - print("|-执行PHP52显示成功!") - elif mw_input == 101: - php_conf = 'plugins/php/info.json' - if os.path.exists(php_conf): - cont = mw.readFile(php_conf) - cont = re.sub("\"52\",", "", cont) - cont = re.sub("\"5.2.17\",", cont) - mw.writeFile(php_conf, cont) - print("|-执行PHP52隐藏成功!") - elif mw_input == 200: - os.system(INIT_CMD + " mirror") - elif mw_input == 201: - os.system('curl -Lso- bench.sh | bash') - - -def open_ssh_port(): - import firewall_api - find_ssh_port_cmd = "cat /etc/ssh/sshd_config | grep '^Port \\d*' | tail -1" - cmd_data = mw.execShell(find_ssh_port_cmd) - ssh_port = cmd_data[0].replace("Port ", '').strip() - if ssh_port == '': - ssh_port = '22' - - print("|-SSH端口: "+ str(ssh_port)) - firewall_api.firewall_api().addAcceptPortArgs(ssh_port, 'SSH远程管理服务', 'port') - return True - - -def set_panel_pwd(password, ncli=False): - # 设置面板密码 - import db - sql = db.Sql() - result = sql.table('users').where('id=?', (1,)).setField( - 'password', mw.md5(password)) - username = sql.table('users').where('id=?', (1,)).getField('username') - if ncli: - print("|-用户名: " + username) - print("|-新密码: " + password) - else: - print(username) - - -def show_panel_pwd(): - # 设置面板密码 - import db - sql = db.Sql() - password = sql.table('users').where('id=?', (1,)).getField('password') - - file_pwd = '' - if os.path.exists('data/default.pl'): - file_pwd = mw.readFile('data/default.pl').strip() - - if mw.md5(file_pwd) == password: - print('password: ' + file_pwd) - return - print("password has been changed!") - - -def set_panel_username(username=None): - # 随机面板用户名 - import db - sql = db.Sql() - if username: - if len(username) < 5: - print("|-错误，用户名长度不能少于5位") - return - if username in ['admin', 'root']: - print("|-错误，不能使用过于简单的用户名") - return - - sql.table('users').where('id=?', (1,)).setField('username', username) - print("|-新用户名: %s" % username) - return - - username = sql.table('users').where('id=?', (1,)).getField('username') - if username == 'admin': - username = mw.getRandomString(8).lower() - sql.table('users').where('id=?', (1,)).setField('username', username) - print('username: ' + username) - - -def getServerIp(): - version = sys.argv[2] - # ip = mw.execShell( - # "curl --insecure -{} -sS --connect-timeout 5 -m 60 https://v6r.ipip.net/?format=text".format(version)) - ip = mw.execShell( - "curl --insecure -{} -sS --connect-timeout 5 -m 60 https://ip.cachecha.com/?format=text".format(version)) - print(ip[0]) - - -if __name__ == "__main__": - method = sys.argv[1] - if method == 'panel': - set_panel_pwd(sys.argv[2]) - elif method == 'username': - if len(sys.argv) > 2: - set_panel_username(sys.argv[2]) - else: - set_panel_username() - elif method == 'password': - show_panel_pwd() - elif method == 'getServerIp': - getServerIp() - elif method == "cli": - clinum = 0 - try: - if len(sys.argv) > 2: - clinum = int(sys.argv[2]) if sys.argv[2][:6] else sys.argv[2] - except: - clinum = sys.argv[2] - mwcli(clinum) - else: - print('ERROR: Parameter error')