o

class/core/db.py

@@ -0,0 +1,276 @@
+# coding: utf-8
+
+
+import sqlite3
+import os
+
+
+class Sql():
+    #------------------------------
+    # 数据库操作类 For sqlite3
+    #------------------------------
+    __DB_FILE = None            # 数据库文件
+    __DB_CONN = None            # 数据库连接对象
+    __DB_TABLE = ""              # 被操作的表名称
+    __OPT_WHERE = ""              # where条件
+    __OPT_LIMIT = ""              # limit条件
+    __OPT_ORDER = ""              # order条件
+    __OPT_FIELD = "*"             # field条件
+    __OPT_PARAM = ()              # where值
+
+    def __init__(self):
+        self.__DB_FILE = 'data/default.db'
+
+    def __GetConn(self):
+        # 取数据库对象
+        try:
+            if self.__DB_CONN == None:
+                self.__DB_CONN = sqlite3.connect(self.__DB_FILE)
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def dbfile(self, name):
+        self.__DB_FILE = 'data/' + name + '.db'
+        return self
+
+    def table(self, table):
+        # 设置表名
+        self.__DB_TABLE = table
+        return self
+
+    def where(self, where, param):
+        # WHERE条件
+        if where:
+            self.__OPT_WHERE = " WHERE " + where
+            self.__OPT_PARAM = param
+        return self
+
+    def order(self, order):
+        # ORDER条件
+        if len(order):
+            self.__OPT_ORDER = " ORDER BY " + order
+        return self
+
+    def limit(self, limit):
+        # LIMIT条件
+        if len(limit):
+            self.__OPT_LIMIT = " LIMIT " + limit
+        return self
+
+    def field(self, field):
+        # FIELD条件
+        if len(field):
+            self.__OPT_FIELD = field
+        return self
+
+    def select(self):
+        # 查询数据集
+        self.__GetConn()
+        try:
+            sql = "SELECT " + self.__OPT_FIELD + " FROM " + self.__DB_TABLE + \
+                self.__OPT_WHERE + self.__OPT_ORDER + self.__OPT_LIMIT
+            result = self.__DB_CONN.execute(sql, self.__OPT_PARAM)
+            data = result.fetchall()
+            # 构造字曲系列
+            if self.__OPT_FIELD != "*":
+                field = self.__OPT_FIELD.split(',')
+                tmp = []
+                for row in data:
+                    i = 0
+                    tmp1 = {}
+                    for key in field:
+                        tmp1[key] = row[i]
+                        i += 1
+                    tmp.append(tmp1)
+                    del(tmp1)
+                data = tmp
+                del(tmp)
+            else:
+                # 将元组转换成列表
+                tmp = map(list, data)
+                data = tmp
+                del(tmp)
+            self.__close()
+            return data
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def getField(self, keyName):
+        # 取回指定字段
+        result = self.field(keyName).select()
+        if len(result) == 1:
+            return result[0][keyName]
+        return result
+
+    def setField(self, keyName, keyValue):
+        # 更新指定字段
+        return self.save(keyName, (keyValue,))
+
+    def find(self):
+        # 取一行数据
+        result = self.limit("1").select()
+        if len(result) == 1:
+            return result[0]
+        return result
+
+    def count(self):
+        # 取行数
+        key = "COUNT(*)"
+        data = self.field(key).select()
+        try:
+            return int(data[0][key])
+        except:
+            return 0
+
+    def add(self, keys, param):
+        # 插入数据
+        self.__GetConn()
+        self.__DB_CONN.text_factory = str
+        try:
+            values = ""
+            for key in keys.split(','):
+                values += "?,"
+            values = self.checkInput(values[0:len(values) - 1])
+            sql = "INSERT INTO " + self.__DB_TABLE + \
+                "(" + keys + ") " + "VALUES(" + values + ")"
+            result = self.__DB_CONN.execute(sql, param)
+            id = result.lastrowid
+            self.__close()
+            self.__DB_CONN.commit()
+            return id
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def checkInput(self, data):
+        if not data:
+            return data
+        if type(data) != str:
+            return data
+        checkList = [
+            {'d': '<', 'r': '＜'},
+            {'d': '>', 'r': '＞'},
+            {'d': '\'', 'r': '‘'},
+            {'d': '"', 'r': '“'},
+            {'d': '&', 'r': '＆'},
+            {'d': '#', 'r': '＃'},
+            {'d': '<', 'r': '＜'}
+        ]
+        for v in checkList:
+            data = data.replace(v['d'], v['r'])
+        return data
+
+    def addAll(self, keys, param):
+        # 插入数据
+        self.__GetConn()
+        self.__DB_CONN.text_factory = str
+        try:
+            values = ""
+            for key in keys.split(','):
+                values += "?,"
+            values = values[0:len(values) - 1]
+            sql = "INSERT INTO " + self.__DB_TABLE + \
+                "(" + keys + ") " + "VALUES(" + values + ")"
+            result = self.__DB_CONN.execute(sql, param)
+            return True
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def commit(self):
+        self.__close()
+        self.__DB_CONN.commit()
+
+    def save(self, keys, param):
+        # 更新数据
+        self.__GetConn()
+        self.__DB_CONN.text_factory = str
+        try:
+            opt = ""
+            for key in keys.split(','):
+                opt += key + "=?,"
+            opt = opt[0:len(opt) - 1]
+            sql = "UPDATE " + self.__DB_TABLE + " SET " + opt + self.__OPT_WHERE
+
+            import public
+            public.writeFile('/tmp/test.pl', sql)
+
+            # 处理拼接WHERE与UPDATE参数
+            tmp = list(param)
+            for arg in self.__OPT_PARAM:
+                tmp.append(arg)
+            self.__OPT_PARAM = tuple(tmp)
+            result = self.__DB_CONN.execute(sql, self.__OPT_PARAM)
+            self.__close()
+            self.__DB_CONN.commit()
+            return result.rowcount
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def delete(self, id=None):
+        # 删除数据
+        self.__GetConn()
+        try:
+            if id:
+                self.__OPT_WHERE = " WHERE id=?"
+                self.__OPT_PARAM = (id,)
+            sql = "DELETE FROM " + self.__DB_TABLE + self.__OPT_WHERE
+            result = self.__DB_CONN.execute(sql, self.__OPT_PARAM)
+            self.__close()
+            self.__DB_CONN.commit()
+            return result.rowcount
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def execute(self, sql, param):
+        # 执行SQL语句返回受影响行
+        self.__GetConn()
+        try:
+            result = self.__DB_CONN.execute(sql, param)
+            self.__DB_CONN.commit()
+            return result.rowcount
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def query(self, sql, param):
+        # 执行SQL语句返回数据集
+        self.__GetConn()
+        try:
+            result = self.__DB_CONN.execute(sql, param)
+            # 将元组转换成列表
+            data = map(list, result)
+            return data
+        except Exception, ex:
+            return "error: " + str(ex)
+
+    def create(self, name):
+        # 创建数据表
+        self.__GetConn()
+        import public
+        script = public.readFile('data/' + name + '.sql')
+        result = self.__DB_CONN.executescript(script)
+        self.__DB_CONN.commit()
+        return result.rowcount
+
+    def fofile(self, filename):
+        # 执行脚本
+        self.__GetConn()
+        import public
+        script = public.readFile(filename)
+        result = self.__DB_CONN.executescript(script)
+        self.__DB_CONN.commit()
+        return result.rowcount
+
+    def __close(self):
+        # 清理条件属性
+        self.__OPT_WHERE = ""
+        self.__OPT_FIELD = "*"
+        self.__OPT_ORDER = ""
+        self.__OPT_LIMIT = ""
+        self.__OPT_PARAM = ()
+
+    def close(self):
+        # 释放资源
+        try:
+            self.__DB_CONN.close()
+            self.__DB_CONN = None
+        except:
+            pass

class/core/page.py

@@ -0,0 +1,222 @@
+# coding: utf-8
+
+import math
+import string
+import public
+
+
+class Page():
+    #--------------------------
+    # 分页类 - JS回调版
+    #--------------------------
+    __PREV = '上一页'
+    __NEXT = '下一页'
+    __START = '首页'
+    __END = '尾页'
+    __COUNT_START = '共'
+    __COUNT_END = '条数据'
+    __FO = '从'
+    __LINE = '条'
+    __LIST_NUM = 4
+    SHIFT = None  # 偏移量
+    ROW = None  # 每页行数
+    __C_PAGE = None  # 当前页
+    __COUNT_PAGE = None  # 总页数
+    __COUNT_ROW = None  # 总行数
+    __URI = None  # URI
+    __RTURN_JS = False  # 是否返回JS回调
+    __START_NUM = None  # 起始行
+    __END_NUM = None  # 结束行
+
+    def __init__(self):
+        tmp = public.getMsg('PAGE')
+        if tmp:
+            self.__PREV = tmp['PREV']
+            self.__NEXT = tmp['NEXT']
+            self.__START = tmp['START']
+            self.__END = tmp['END']
+            self.__COUNT_START = tmp['COUNT_START']
+            self.__COUNT_END = tmp['COUNT_END']
+            self.__FO = tmp['FO']
+            self.__LINE = tmp['LINE']
+
+    def GetPage(self, pageInfo, limit='1,2,3,4,5,6,7,8'):
+        # 取分页信息
+        # @param pageInfo 传入分页参数字典
+        # @param limit 返回系列
+        self.__RTURN_JS = pageInfo['return_js']
+        self.__COUNT_ROW = pageInfo['count']
+        self.ROW = pageInfo['row']
+        self.__C_PAGE = self.__GetCpage(pageInfo['p'])
+        self.__START_NUM = self.__StartRow()
+        self.__END_NUM = self.__EndRow()
+        self.__COUNT_PAGE = self.__GetCountPage()
+        self.__URI = self.__SetUri(pageInfo['uri'])
+        self.SHIFT = self.__START_NUM - 1
+
+        keys = limit.split(',')
+
+        pages = {}
+        # 起始页
+        pages['1'] = self.__GetStart()
+        # 上一页
+        pages['2'] = self.__GetPrev()
+        # 分页
+        pages['3'] = self.__GetPages()
+        # 下一页
+        pages['4'] = self.__GetNext()
+        # 尾页
+        pages['5'] = self.__GetEnd()
+
+        # 当前显示页与总页数
+        pages['6'] = "<span class='Pnumber'>" + \
+            bytes(self.__C_PAGE) + "/" + bytes(self.__COUNT_PAGE) + "</span>"
+        # 本页显示开始与结束行
+        pages['7'] = "<span class='Pline'>" + self.__FO + \
+            bytes(self.__START_NUM) + "-" + \
+            bytes(self.__END_NUM) + self.__LINE + "</span>"
+        # 行数
+        pages['8'] = "<span class='Pcount'>" + self.__COUNT_START + \
+            bytes(self.__COUNT_ROW) + self.__COUNT_END + "</span>"
+
+        # 构造返回数据
+        retuls = '<div>'
+        for value in keys:
+            retuls += pages[value]
+        retuls += '</div>'
+
+        # 返回分页数据
+        return retuls
+
+    def __GetEnd(self):
+        # 构造尾页
+        endStr = ""
+        if self.__C_PAGE >= self.__COUNT_PAGE:
+            endStr = ''
+        else:
+            if self.__RTURN_JS == "":
+                endStr = "<a class='Pend' href='" + self.__URI + "p=" + \
+                    bytes(self.__COUNT_PAGE) + "'>" + self.__END + "</a>"
+            else:
+                endStr = "<a class='Pend' onclick='" + self.__RTURN_JS + \
+                    "(" + bytes(self.__COUNT_PAGE) + ")'>" + self.__END + "</a>"
+        return endStr
+
+    def __GetNext(self):
+        # 构造下一页
+        nextStr = ""
+        if self.__C_PAGE >= self.__COUNT_PAGE:
+            nextStr = ''
+        else:
+            if self.__RTURN_JS == "":
+                nextStr = "<a class='Pnext' href='" + self.__URI + "p=" + \
+                    bytes(self.__C_PAGE + 1) + "'>" + self.__NEXT + "</a>"
+            else:
+                nextStr = "<a class='Pnext' onclick='" + self.__RTURN_JS + \
+                    "(" + bytes(self.__C_PAGE + 1) + ")'>" + self.__NEXT + "</a>"
+
+        return nextStr
+
+    def __GetPages(self):
+        # 构造分页
+        pages = ''
+        num = 0
+        # 当前页之前
+        if (self.__COUNT_PAGE - self.__C_PAGE) < self.__LIST_NUM:
+            num = self.__LIST_NUM + \
+                (self.__LIST_NUM - (self.__COUNT_PAGE - self.__C_PAGE))
+        else:
+            num = self.__LIST_NUM
+        n = 0
+        for i in range(num):
+            n = num - i
+            page = self.__C_PAGE - n
+            if page > 0:
+                if self.__RTURN_JS == "":
+                    pages += "<a class='Pnum' href='" + self.__URI + \
+                        "p=" + bytes(page) + "'>" + bytes(page) + "</a>"
+                else:
+                    pages += "<a class='Pnum' onclick='" + self.__RTURN_JS + \
+                        "(" + bytes(page) + ")'>" + bytes(page) + "</a>"
+
+        # 当前页
+        if self.__C_PAGE > 0:
+            pages += "<span class='Pcurrent'>" + \
+                bytes(self.__C_PAGE) + "</span>"
+
+        # 当前页之后
+        if self.__C_PAGE <= self.__LIST_NUM:
+            num = self.__LIST_NUM + (self.__LIST_NUM - self.__C_PAGE) + 1
+        else:
+            num = self.__LIST_NUM
+        for i in range(num):
+            if i == 0:
+                continue
+            page = self.__C_PAGE + i
+            if page > self.__COUNT_PAGE:
+                break
+            if self.__RTURN_JS == "":
+                pages += "<a class='Pnum' href='" + self.__URI + \
+                    "p=" + bytes(page) + "'>" + bytes(page) + "</a>"
+            else:
+                pages += "<a class='Pnum' onclick='" + self.__RTURN_JS + \
+                    "(" + bytes(page) + ")'>" + bytes(page) + "</a>"
+
+        return pages
+
+    def __GetPrev(self):
+        # 构造上一页
+        startStr = ''
+        if self.__C_PAGE == 1:
+            startStr = ''
+        else:
+            if self.__RTURN_JS == "":
+                startStr = "<a class='Ppren' href='" + self.__URI + "p=" + \
+                    bytes(self.__C_PAGE - 1) + "'>" + self.__PREV + "</a>"
+            else:
+                startStr = "<a class='Ppren' onclick='" + self.__RTURN_JS + \
+                    "(" + bytes(self.__C_PAGE - 1) + ")'>" + self.__PREV + "</a>"
+        return startStr
+
+    def __GetStart(self):
+        # 构造起始分页
+        startStr = ''
+        if self.__C_PAGE == 1:
+            startStr = ''
+        else:
+            if self.__RTURN_JS == "":
+                startStr = "<a class='Pstart' href='" + \
+                    self.__URI + "p=1'>" + self.__START + "</a>"
+            else:
+                startStr = "<a class='Pstart' onclick='" + \
+                    self.__RTURN_JS + "(1)'>" + self.__START + "</a>"
+        return startStr
+
+    def __GetCpage(self, p):
+        # 取当前页
+        if p:
+            return p
+        return 1
+
+    def __StartRow(self):
+        # 从多少行开始
+        return (self.__C_PAGE - 1) * self.ROW + 1
+
+    def __EndRow(self):
+        # 从多少行结束
+        if self.ROW > self.__COUNT_ROW:
+            return self.__COUNT_ROW
+        return self.__C_PAGE * self.ROW
+
+    def __GetCountPage(self):
+        # 取总页数
+        return int(math.ceil(self.__COUNT_ROW / float(self.ROW)))
+
+    def __SetUri(self, input):
+        # 构造URI
+        uri = '?'
+        for key in input:
+            if key == 'p':
+                continue
+            uri += key + '=' + input[key] + '&'
+        return str(uri)

class/core/public.py

@@ -0,0 +1,872 @@
+# coding: utf-8
+
+import os
+import sys
+import time
+import string
+import json
+import hashlib
+import shlex
+import datetime
+import subprocess
+import re
+import hashlib
+
+
+sys.path.append(os.getcwd() + "/class/")
+import db
+
+from random import Random
+
+
+def getRunDir():
+    # 运行目录
+    return os.getcwd()
+
+
+def getBinDir():
+    # 安装软件
+    pass
+
+
+def M(table):
+    sql = db.Sql()
+    return sql.table(table)
+
+
+def getWebPage(data, args):
+    # 取分页
+    import page
+    # 实例化分页类
+    page = page.Page()
+    info = {}
+    info['count'] = len(data)
+
+    info['row'] = 10
+    if hasattr(args, 'row'):
+        info['row'] = args['row']
+
+    info['p'] = 1
+    if hasattr(args, 'p'):
+        info['p'] = int(get['p'])
+    info['uri'] = {}
+    info['return_js'] = ''
+    if hasattr(args, 'tojs'):
+        info['return_js'] = args.tojs
+
+    # 获取分页数据
+    result = {}
+    result['page'] = page.GetPage(info)
+    return result
+
+
+def md5(str):
+    # 生成MD5
+    try:
+        m = hashlib.md5()
+        m.update(str)
+        return m.hexdigest()
+    except:
+        return False
+
+
+def GetFileMd5(filename):
+    # 文件的MD5值
+    if not os.path.isfile(filename):
+        return False
+
+    myhash = hashlib.md5()
+    f = file(filename, 'rb')
+    while True:
+        b = f.read(8096)
+        if not b:
+            break
+        myhash.update(b)
+    f.close()
+    return myhash.hexdigest()
+
+
+def GetRandomString(length):
+    # 取随机字符串
+    str = ''
+    chars = 'AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz0123456789'
+    chrlen = len(chars) - 1
+    random = Random()
+    for i in range(length):
+        str += chars[random.randint(0, chrlen)]
+    return str
+
+
+def getJson(data):
+    import json
+    return json.dumps(data)
+
+
+def returnJson(status, msg, args=()):
+    # 取通用Json返回
+    return getJson(returnMsg(status, msg, args))
+
+
+def returnMsg(status, msg, args=()):
+    # 取通用字曲返回
+    logMessage = json.loads(
+        readFile('static/language/' + get_language() + '/public.json'))
+    keys = logMessage.keys()
+    if msg in keys:
+        msg = logMessage[msg]
+        for i in range(len(args)):
+            rep = '{' + str(i + 1) + '}'
+            msg = msg.replace(rep, args[i])
+    return {'status': status, 'msg': msg}
+
+
+def getMsg(key, args=()):
+    # 取提示消息
+    try:
+        logMessage = json.loads(
+            readFile('static/language/' + get_language() + '/public.json'))
+        keys = logMessage.keys()
+        msg = None
+        if key in keys:
+            msg = logMessage[key]
+            for i in range(len(args)):
+                rep = '{' + str(i + 1) + '}'
+                msg = msg.replace(rep, args[i])
+        return msg
+    except:
+        return key
+
+
+def getLan(key):
+    # 取提示消息
+
+    logMessage = json.loads(
+        readFile('static/language/' + get_language() + '/template.json'))
+    keys = logMessage.keys()
+    msg = None
+    if key in keys:
+        msg = logMessage[key]
+    return msg
+
+
+def readFile(filename):
+    # 读文件内容
+    try:
+        fp = open(filename, 'r')
+        fBody = fp.read()
+        fp.close()
+        return fBody
+    except:
+        return False
+
+
+def getDate():
+    # 取格式时间
+    import time
+    return time.strftime('%Y-%m-%d %X', time.localtime())
+
+
+def get_language():
+    path = 'data/language.pl'
+    if not os.path.exists(path):
+        return 'Simplified_Chinese'
+    return readFile(path).strip()
+
+
+def writeLog(type, logMsg, args=()):
+    # 写日志
+    try:
+        import time
+        import db
+        import json
+        logMessage = json.loads(
+            readFile('static/language/' + get_language() + '/log.json'))
+        keys = logMessage.keys()
+        if logMsg in keys:
+            logMsg = logMessage[logMsg]
+            for i in range(len(args)):
+                rep = '{' + str(i + 1) + '}'
+                logMsg = logMsg.replace(rep, args[i])
+        if type in keys:
+            type = logMessage[type]
+        sql = db.Sql()
+        mDate = time.strftime('%Y-%m-%d %X', time.localtime())
+        data = (type, logMsg, mDate)
+        result = sql.table('logs').add('type,log,addtime', data)
+    except:
+        pass
+
+
+def writeFile(filename, str):
+    # 写文件内容
+    try:
+        fp = open(filename, 'w+')
+        fp.write(str)
+        fp.close()
+        return True
+    except:
+        return False
+
+
+def httpGet(url, timeout=30):
+    # 发送GET请求
+    try:
+        import urllib2
+        import ssl
+        try:
+            ssl._create_default_https_context = ssl._create_unverified_context
+        except:
+            pass
+        response = urllib2.urlopen(url, timeout=timeout)
+        return response.read()
+    except Exception, ex:
+        # WriteLog('网络诊断',str(ex) + '['+url+']');
+        return str(ex)
+
+
+def httpPost(url, data, timeout=30):
+    # 发送POST请求
+    try:
+        import urllib
+        import urllib2
+        import ssl
+        try:
+            ssl._create_default_https_context = ssl._create_unverified_context
+        except:
+            pass
+        data = urllib.urlencode(data)
+        req = urllib2.Request(url, data)
+        response = urllib2.urlopen(req, timeout=timeout)
+        return response.read()
+    except Exception, ex:
+        # WriteLog('网络诊断',str(ex) + '['+url+']');
+        return str(ex)
+
+
+def writeSpeed(title, used, total, speed=0):
+    # 写进度
+    if not title:
+        data = {'title': None, 'progress': 0,
+                'total': 0, 'used': 0, 'speed': 0}
+    else:
+        progress = int((100.0 * used / total))
+        data = {'title': title, 'progress': progress,
+                'total': total, 'used': used, 'speed': speed}
+    writeFile('/tmp/panelSpeed.pl', json.dumps(data))
+    return True
+
+
+def getSpeed():
+    # 取进度
+    data = readFile('/tmp/panelSpeed.pl')
+    if not data:
+        data = json.dumps({'title': None, 'progress': 0,
+                           'total': 0, 'used': 0, 'speed': 0})
+        writeFile('/tmp/panelSpeed.pl', data)
+    return json.loads(data)
+
+
+def getLastLine(inputfile, lineNum):
+    # 读文件指定倒数行数
+    try:
+        fp = open(inputfile, 'r')
+        lastLine = ""
+
+        lines = fp.readlines()
+        count = len(lines)
+        if count > lineNum:
+            num = lineNum
+        else:
+            num = count
+        i = 1
+        lastre = []
+        for i in range(1, (num + 1)):
+            if lines:
+                n = -i
+                lastLine = lines[n].strip()
+                fp.close()
+                lastre.append(lastLine)
+
+        result = ''
+        num -= 1
+        while num >= 0:
+            result += lastre[num] + "\n"
+            num -= 1
+        return result
+    except:
+        return getMsg('TASK_SLEEP')
+
+
+def ExecShell(cmdstring, cwd=None, timeout=None, shell=True):
+
+    if shell:
+        cmdstring_list = cmdstring
+    else:
+        cmdstring_list = shlex.split(cmdstring)
+    if timeout:
+        end_time = datetime.datetime.now() + datetime.timedelta(seconds=timeout)
+
+    sub = subprocess.Popen(cmdstring_list, cwd=cwd, stdin=subprocess.PIPE,
+                           shell=shell, bufsize=4096, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+
+    while sub.poll() is None:
+        time.sleep(0.1)
+        if timeout:
+            if end_time <= datetime.datetime.now():
+                raise Exception("Timeout：%s" % cmdstring)
+
+    return sub.communicate()
+
+
+def serviceReload():
+    # 重载Web服务配置
+    if os.path.exists('/www/server/nginx/sbin/nginx'):
+        result = ExecShell('/etc/init.d/nginx reload')
+        if result[1].find('nginx.pid') != -1:
+            ExecShell('pkill -9 nginx && sleep 1')
+            ExecShell('/etc/init.d/nginx start')
+    else:
+        result = ExecShell('/etc/init.d/httpd reload')
+    return result
+
+
+def phpReload(version):
+    # 重载PHP配置
+    import os
+    if os.path.exists('/www/server/php/' + version + '/libphp5.so'):
+        ExecShell('/etc/init.d/httpd reload')
+    else:
+        ExecShell('/etc/init.d/php-fpm-' + version + ' reload')
+
+
+def downloadFile(url, filename):
+    import urllib
+    urllib.urlretrieve(url, filename=filename, reporthook=downloadHook)
+
+
+def downloadHook(count, blockSize, totalSize):
+    speed = {'total': totalSize, 'block': blockSize, 'count': count}
+    print speed
+    print '%02d%%' % (100.0 * count * blockSize / totalSize)
+
+
+def GetLocalIp():
+    # 取本地外网IP
+    try:
+        import re
+        filename = 'data/iplist.txt'
+        ipaddress = readFile(filename)
+        if not ipaddress:
+            import urllib2
+            url = 'http://pv.sohu.com/cityjson?ie=utf-8'
+            opener = urllib2.urlopen(url)
+            str = opener.read()
+            ipaddress = re.search('\d+.\d+.\d+.\d+', str).group(0)
+            writeFile(filename, ipaddress)
+
+        ipaddress = re.search('\d+.\d+.\d+.\d+', ipaddress).group(0)
+        return ipaddress
+    except:
+        pass
+        # try:
+        #     url = web.ctx.session.home + '/Api/getIpAddress'
+        #     opener = urllib2.urlopen(url)
+        #     return opener.read()
+        # except:
+        #     return web.ctx.host.split(':')[0]
+
+
+def inArray(arrays, searchStr):
+    # 搜索数据中是否存在
+    for key in arrays:
+        if key == searchStr:
+            return True
+
+    return False
+
+
+def checkWebConfig():
+    # 检查Web服务器配置文件是否有错误
+    if get_webserver() == 'nginx':
+        result = ExecShell(
+            "ulimit -n 10240 && /www/server/nginx/sbin/nginx -t -c /www/server/nginx/conf/nginx.conf")
+        searchStr = 'successful'
+    else:
+        result = ExecShell(
+            "ulimit -n 10240 && /www/server/apache/bin/apachectl -t")
+        searchStr = 'Syntax OK'
+
+    if result[1].find(searchStr) == -1:
+        WriteLog("TYPE_SOFT", 'CONF_CHECK_ERR', (result[1],))
+        return result[1]
+    return True
+
+
+def checkIp(ip):
+    # 检查是否为IPv4地址
+    import re
+    p = re.compile(
+        '^((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}(25[0-5]|2[0-4]\d|[01]?\d\d?)$')
+    if p.match(ip):
+        return True
+    else:
+        return False
+
+
+def checkPort(port):
+    # 检查端口是否合法
+    ports = ['21', '25', '443', '8080', '888', '8888', '8443']
+    if port in ports:
+        return False
+    intport = int(port)
+    if intport < 1 or intport > 65535:
+        return False
+    return True
+
+
+def getStrBetween(startStr, endStr, srcStr):
+    # 字符串取中间
+    start = srcStr.find(startStr)
+    if start == -1:
+        return None
+    end = srcStr.find(endStr)
+    if end == -1:
+        return None
+    return srcStr[start + 1:end]
+
+
+def getCpuType():
+    # 取CPU类型
+    cpuinfo = open('/proc/cpuinfo', 'r').read()
+    rep = "model\s+name\s+:\s+(.+)"
+    tmp = re.search(rep, cpuinfo)
+    cpuType = None
+    if tmp:
+        cpuType = tmp.groups()[0]
+    return cpuType
+
+
+def IsRestart():
+    # 检查是否允许重启
+    num = M('tasks').where('status!=?', ('1',)).count()
+    if num > 0:
+        return False
+    return True
+
+
+def hasPwd(password):
+    # 加密密码字符
+    import crypt
+    return crypt.crypt(password, password)
+
+
+def CheckMyCnf():
+    # 处理MySQL配置文件
+    import os
+    confFile = '/etc/my.cnf'
+    if os.path.exists(confFile):
+        conf = readFile(confFile)
+        if len(conf) > 100:
+            return True
+    versionFile = '/www/server/mysql/version.pl'
+    if not os.path.exists(versionFile):
+        return False
+
+    versions = ['5.1', '5.5', '5.6', '5.7', 'AliSQL']
+    version = readFile(versionFile)
+    for key in versions:
+        if key in version:
+            version = key
+            break
+
+    shellStr = '''
+#!/bin/bash
+PATH=/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin:~/bin
+export PATH
+
+CN='125.88.182.172'
+HK='download.bt.cn'
+HK2='103.224.251.67'
+US='174.139.221.74'
+sleep 0.5;
+CN_PING=`ping -c 1 -w 1 $CN|grep time=|awk '{print $7}'|sed "s/time=//"`
+HK_PING=`ping -c 1 -w 1 $HK|grep time=|awk '{print $7}'|sed "s/time=//"`
+HK2_PING=`ping -c 1 -w 1 $HK2|grep time=|awk '{print $7}'|sed "s/time=//"`
+US_PING=`ping -c 1 -w 1 $US|grep time=|awk '{print $7}'|sed "s/time=//"`
+
+echo "$HK_PING $HK" > ping.pl
+echo "$HK2_PING $HK2" >> ping.pl
+echo "$US_PING $US" >> ping.pl
+echo "$CN_PING $CN" >> ping.pl
+nodeAddr=`sort -V ping.pl|sed -n '1p'|awk '{print $2}'`
+if [ "$nodeAddr" == "" ];then
+    nodeAddr=$HK
+fi
+
+Download_Url=http://$nodeAddr:5880
+
+
+MySQL_Opt()
+{
+    MemTotal=`free -m | grep Mem | awk '{print  $2}'`
+    if [[ ${MemTotal} -gt 1024 && ${MemTotal} -lt 2048 ]]; then
+        sed -i "s#^key_buffer_size.*#key_buffer_size = 32M#" /etc/my.cnf
+        sed -i "s#^table_open_cache.*#table_open_cache = 128#" /etc/my.cnf
+        sed -i "s#^sort_buffer_size.*#sort_buffer_size = 768K#" /etc/my.cnf
+        sed -i "s#^read_buffer_size.*#read_buffer_size = 768K#" /etc/my.cnf
+        sed -i "s#^myisam_sort_buffer_size.*#myisam_sort_buffer_size = 8M#" /etc/my.cnf
+        sed -i "s#^thread_cache_size.*#thread_cache_size = 16#" /etc/my.cnf
+        sed -i "s#^query_cache_size.*#query_cache_size = 16M#" /etc/my.cnf
+        sed -i "s#^tmp_table_size.*#tmp_table_size = 32M#" /etc/my.cnf
+        sed -i "s#^innodb_buffer_pool_size.*#innodb_buffer_pool_size = 128M#" /etc/my.cnf
+        sed -i "s#^innodb_log_file_size.*#innodb_log_file_size = 32M#" /etc/my.cnf
+    elif [[ ${MemTotal} -ge 2048 && ${MemTotal} -lt 4096 ]]; then
+        sed -i "s#^key_buffer_size.*#key_buffer_size = 64M#" /etc/my.cnf
+        sed -i "s#^table_open_cache.*#table_open_cache = 256#" /etc/my.cnf
+        sed -i "s#^sort_buffer_size.*#sort_buffer_size = 1M#" /etc/my.cnf
+        sed -i "s#^read_buffer_size.*#read_buffer_size = 1M#" /etc/my.cnf
+        sed -i "s#^myisam_sort_buffer_size.*#myisam_sort_buffer_size = 16M#" /etc/my.cnf
+        sed -i "s#^thread_cache_size.*#thread_cache_size = 32#" /etc/my.cnf
+        sed -i "s#^query_cache_size.*#query_cache_size = 32M#" /etc/my.cnf
+        sed -i "s#^tmp_table_size.*#tmp_table_size = 64M#" /etc/my.cnf
+        sed -i "s#^innodb_buffer_pool_size.*#innodb_buffer_pool_size = 256M#" /etc/my.cnf
+        sed -i "s#^innodb_log_file_size.*#innodb_log_file_size = 64M#" /etc/my.cnf
+    elif [[ ${MemTotal} -ge 4096 && ${MemTotal} -lt 8192 ]]; then
+        sed -i "s#^key_buffer_size.*#key_buffer_size = 128M#" /etc/my.cnf
+        sed -i "s#^table_open_cache.*#table_open_cache = 512#" /etc/my.cnf
+        sed -i "s#^sort_buffer_size.*#sort_buffer_size = 2M#" /etc/my.cnf
+        sed -i "s#^read_buffer_size.*#read_buffer_size = 2M#" /etc/my.cnf
+        sed -i "s#^myisam_sort_buffer_size.*#myisam_sort_buffer_size = 32M#" /etc/my.cnf
+        sed -i "s#^thread_cache_size.*#thread_cache_size = 64#" /etc/my.cnf
+        sed -i "s#^query_cache_size.*#query_cache_size = 64M#" /etc/my.cnf
+        sed -i "s#^tmp_table_size.*#tmp_table_size = 64M#" /etc/my.cnf
+        sed -i "s#^innodb_buffer_pool_size.*#innodb_buffer_pool_size = 512M#" /etc/my.cnf
+        sed -i "s#^innodb_log_file_size.*#innodb_log_file_size = 128M#" /etc/my.cnf
+    elif [[ ${MemTotal} -ge 8192 && ${MemTotal} -lt 16384 ]]; then
+        sed -i "s#^key_buffer_size.*#key_buffer_size = 256M#" /etc/my.cnf
+        sed -i "s#^table_open_cache.*#table_open_cache = 1024#" /etc/my.cnf
+        sed -i "s#^sort_buffer_size.*#sort_buffer_size = 4M#" /etc/my.cnf
+        sed -i "s#^read_buffer_size.*#read_buffer_size = 4M#" /etc/my.cnf
+        sed -i "s#^myisam_sort_buffer_size.*#myisam_sort_buffer_size = 64M#" /etc/my.cnf
+        sed -i "s#^thread_cache_size.*#thread_cache_size = 128#" /etc/my.cnf
+        sed -i "s#^query_cache_size.*#query_cache_size = 128M#" /etc/my.cnf
+        sed -i "s#^tmp_table_size.*#tmp_table_size = 128M#" /etc/my.cnf
+        sed -i "s#^innodb_buffer_pool_size.*#innodb_buffer_pool_size = 1024M#" /etc/my.cnf
+        sed -i "s#^innodb_log_file_size.*#innodb_log_file_size = 256M#" /etc/my.cnf
+    elif [[ ${MemTotal} -ge 16384 && ${MemTotal} -lt 32768 ]]; then
+        sed -i "s#^key_buffer_size.*#key_buffer_size = 512M#" /etc/my.cnf
+        sed -i "s#^table_open_cache.*#table_open_cache = 2048#" /etc/my.cnf
+        sed -i "s#^sort_buffer_size.*#sort_buffer_size = 8M#" /etc/my.cnf
+        sed -i "s#^read_buffer_size.*#read_buffer_size = 8M#" /etc/my.cnf
+        sed -i "s#^myisam_sort_buffer_size.*#myisam_sort_buffer_size = 128M#" /etc/my.cnf
+        sed -i "s#^thread_cache_size.*#thread_cache_size = 256#" /etc/my.cnf
+        sed -i "s#^query_cache_size.*#query_cache_size = 256M#" /etc/my.cnf
+        sed -i "s#^tmp_table_size.*#tmp_table_size = 256M#" /etc/my.cnf
+        sed -i "s#^innodb_buffer_pool_size.*#innodb_buffer_pool_size = 2048M#" /etc/my.cnf
+        sed -i "s#^innodb_log_file_size.*#innodb_log_file_size = 512M#" /etc/my.cnf
+    elif [[ ${MemTotal} -ge 32768 ]]; then
+        sed -i "s#^key_buffer_size.*#key_buffer_size = 1024M#" /etc/my.cnf
+        sed -i "s#^table_open_cache.*#table_open_cache = 4096#" /etc/my.cnf
+        sed -i "s#^sort_buffer_size.*#sort_buffer_size = 16M#" /etc/my.cnf
+        sed -i "s#^read_buffer_size.*#read_buffer_size = 16M#" /etc/my.cnf
+        sed -i "s#^myisam_sort_buffer_size.*#myisam_sort_buffer_size = 256M#" /etc/my.cnf
+        sed -i "s#^thread_cache_size.*#thread_cache_size = 512#" /etc/my.cnf
+        sed -i "s#^query_cache_size.*#query_cache_size = 512M#" /etc/my.cnf
+        sed -i "s#^tmp_table_size.*#tmp_table_size = 512M#" /etc/my.cnf
+        sed -i "s#^innodb_buffer_pool_size.*#innodb_buffer_pool_size = 4096M#" /etc/my.cnf
+        sed -i "s#^innodb_log_file_size.*#innodb_log_file_size = 1024M#" /etc/my.cnf
+    fi
+}
+
+wget -O /etc/my.cnf $Download_Url/install/conf/mysql-%s.conf -T 5
+MySQL_Opt
+''' % (version,)
+    # 判断是否迁移目录
+    if os.path.exists('data/datadir.pl'):
+        newPath = public.readFile('data/datadir.pl')
+        mycnf = public.readFile('/etc/my.cnf')
+        mycnf = mycnf.replace('/www/server/data', newPath)
+        public.writeFile('/etc/my.cnf', mycnf)
+
+    os.system(shellStr)
+    WriteLog('TYPE_SOFE', 'MYSQL_CHECK_ERR')
+    return True
+
+
+def get_url(timeout=0.5):
+    import json
+    try:
+        nodeFile = '/www/server/panel/data/node.json'
+        node_list = json.loads(readFile(nodeFile))
+        mnode = None
+        for node in node_list:
+            node['ping'] = get_timeout(
+                node['protocol'] + node['address'] + ':' + node['port'] + '/check.txt')
+            if not node['ping']:
+                continue
+            if not mnode:
+                mnode = node
+            if node['ping'] < mnode['ping']:
+                mnode = node
+        return mnode['protocol'] + mnode['address'] + ':' + mnode['port']
+    except:
+        return 'http://download.bt.cn'
+
+
+def get_timeout(url):
+    start = time.time()
+    result = httpGet(url)
+    if result != 'True':
+        return False
+    return int((time.time() - start) * 1000)
+
+
+# 获取Token
+def GetToken():
+    try:
+        from json import loads
+        tokenFile = 'data/token.json'
+        if not os.path.exists(tokenFile):
+            return False
+        token = loads(public.readFile(tokenFile))
+        return token
+    except:
+        return False
+
+# 解密数据
+
+
+def auth_decode(data):
+    token = GetToken()
+    # 是否有生成Token
+    if not token:
+        return returnMsg(False, 'REQUEST_ERR')
+
+    # 校验access_key是否正确
+    if token['access_key'] != data['btauth_key']:
+        return returnMsg(False, 'REQUEST_ERR')
+
+    # 解码数据
+    import binascii
+    import hashlib
+    import urllib
+    import hmac
+    import json
+    tdata = binascii.unhexlify(data['data'])
+
+    # 校验signature是否正确
+    signature = binascii.hexlify(
+        hmac.new(token['secret_key'], tdata, digestmod=hashlib.sha256).digest())
+    if signature != data['signature']:
+        return returnMsg(False, 'REQUEST_ERR')
+
+    # 返回
+    return json.loads(urllib.unquote(tdata))
+
+
+# 数据加密
+def auth_encode(data):
+    token = GetToken()
+    pdata = {}
+
+    # 是否有生成Token
+    if not token:
+        return returnMsg(False, 'REQUEST_ERR')
+
+    # 生成signature
+    import binascii
+    import hashlib
+    import urllib
+    import hmac
+    import json
+    tdata = urllib.quote(json.dumps(data))
+    # 公式  hex(hmac_sha256(data))
+    pdata['signature'] = binascii.hexlify(
+        hmac.new(token['secret_key'], tdata, digestmod=hashlib.sha256).digest())
+
+    # 加密数据
+    pdata['btauth_key'] = token['access_key']
+    pdata['data'] = binascii.hexlify(tdata)
+    pdata['timestamp'] = time.time()
+
+    # 返回
+    return pdata
+
+# 检查Token
+
+
+def checkToken(get):
+    tempFile = 'data/tempToken.json'
+    if not os.path.exists(tempFile):
+        return False
+    import json
+    import time
+    tempToken = json.loads(readFile(tempFile))
+    if time.time() > tempToken['timeout']:
+        return False
+    if get.token != tempToken['token']:
+        return False
+    return True
+
+
+def get_webserver():
+    # 获取Web服务器
+    webserver = 'nginx'
+    if not os.path.exists('/www/server/nginx/sbin/nginx'):
+        webserver = 'apache'
+    return webserver
+
+
+def checkInput(data):
+    # 过滤输入
+    if not data:
+        return data
+    if type(data) != str:
+        return data
+    checkList = [
+        {'d': '<', 'r': '＜'},
+        {'d': '>', 'r': '＞'},
+        {'d': '\'', 'r': '‘'},
+        {'d': '"', 'r': '“'},
+        {'d': '&', 'r': '＆'},
+        {'d': '#', 'r': '＃'},
+        {'d': '<', 'r': '＜'}
+    ]
+    for v in checkList:
+        data = data.replace(v['d'], v['r'])
+    return data
+
+
+def GetNumLines(path, num, p=1):
+    # 取文件指定尾行数
+    try:
+        import cgi
+        if not os.path.exists(path):
+            return ""
+        start_line = (p - 1) * num
+        count = start_line + num
+        fp = open(path)
+        buf = ""
+        fp.seek(-1, 2)
+        if fp.read(1) == "\n":
+            fp.seek(-1, 2)
+        data = []
+        b = True
+        n = 0
+        for i in range(count):
+            while True:
+                newline_pos = string.rfind(buf, "\n")
+                pos = fp.tell()
+                if newline_pos != -1:
+                    if n >= start_line:
+                        line = buf[newline_pos + 1:]
+                        try:
+                            data.insert(0, cgi.escape(line))
+                        except:
+                            pass
+                    buf = buf[:newline_pos]
+                    n += 1
+                    break
+                else:
+                    if pos == 0:
+                        b = False
+                        break
+                    to_read = min(4096, pos)
+                    fp.seek(-to_read, 1)
+                    buf = fp.read(to_read) + buf
+                    fp.seek(-to_read, 1)
+                    if pos - to_read == 0:
+                        buf = "\n" + buf
+            if not b:
+                break
+        fp.close()
+    except:
+        data = []
+    return "\n".join(data)
+
+
+def CheckCert(certPath='ssl/certificate.pem'):
+    # 验证证书
+    openssl = '/usr/local/openssl/bin/openssl'
+    if not os.path.exists(openssl):
+        openssl = 'openssl'
+    certPem = readFile(certPath)
+    s = "\n-----BEGIN CERTIFICATE-----"
+    tmp = certPem.strip().split(s)
+    for tmp1 in tmp:
+        if tmp1.find('-----BEGIN CERTIFICATE-----') == -1:
+            tmp1 = s + tmp1
+        writeFile(certPath, tmp1)
+        result = ExecShell(openssl + " x509 -in " +
+                           certPath + " -noout -subject")
+        if result[1].find('-bash:') != -1:
+            return True
+        if len(result[1]) > 2:
+            return False
+        if result[0].find('error:') != -1:
+            return False
+    return True
+
+ # 获取面板地址
+
+
+# def getPanelAddr():
+#     import web
+#     protocol = 'https://' if os.path.exists("data/ssl.pl") else 'http://'
+#     h = web.ctx.host.split(':')
+#     try:
+#         result = protocol + h[0] + ':' + h[1]
+#     except:
+#         result = protocol + h[0] + ':' + readFile('data/port.pl').strip()
+#     return result
+
+
+def to_size(size):
+    # 字节单位转换
+    d = ('b', 'KB', 'MB', 'GB', 'TB')
+    s = d[0]
+    for b in d:
+        if size < 1024:
+            return str(size) + ' ' + b
+        size = size / 1024
+        s = b
+    return str(size) + ' ' + b
+
+
+def get_string(t):
+    if t != -1:
+        max = 126
+        m_types = [{'m': 122, 'n': 97}, {'m': 90, 'n': 65}, {'m': 57, 'n': 48}, {
+            'm': 47, 'n': 32}, {'m': 64, 'n': 58}, {'m': 96, 'n': 91}, {'m': 125, 'n': 123}]
+    else:
+        max = 256
+        t = 0
+        m_types = [{'m': 255, 'n': 0}]
+    arr = []
+    for i in range(max):
+        if i < m_types[t]['n'] or i > m_types[t]['m']:
+            continue
+        arr.append(chr(i))
+    return arr
+
+
+def get_string_find(t):
+    if type(t) != list:
+        t = [t]
+    return_str = ''
+    for s1 in t:
+        return_str += get_string(int(s1[0]))[int(s1[1:])]
+    return return_str
+
+
+def get_string_arr(t):
+    s_arr = {}
+    t_arr = []
+    for s1 in t:
+        for i in range(6):
+            if not i in s_arr:
+                s_arr[i] = get_string(i)
+            for j in range(len(s_arr[i])):
+                if s1 == s_arr[i][j]:
+                    t_arr.append(str(i) + str(j))
+    return t_arr

class/core/system.py

@@ -0,0 +1,700 @@
+# coding: utf-8
+
+import psutil
+import time
+import os
+import public
+import re
+
+
+class system:
+    setupPath = None
+    pids = None
+
+    def __init__(self):
+        self.setupPath = '/www/server'
+
+    def GetConcifInfo(self, get=None):
+        # 取环境配置信息
+        if not hasattr(web.ctx.session, 'config'):
+            web.ctx.session.config = public.M('config').where("id=?", ('1',)).field(
+                'webserver,sites_path,backup_path,status,mysql_root').find()
+        if not hasattr(web.ctx.session.config, 'email'):
+            web.ctx.session.config['email'] = public.M(
+                'users').where("id=?", ('1',)).getField('email')
+        data = {}
+        data = web.ctx.session.config
+        data['webserver'] = web.ctx.session.config['webserver']
+        # PHP版本
+        phpVersions = ('52', '53', '54', '55', '56',
+                       '70', '71', '72', '73', '74')
+
+        data['php'] = []
+
+        for version in phpVersions:
+            tmp = {}
+            tmp['setup'] = os.path.exists(
+                self.setupPath + '/php/' + version + '/bin/php')
+            if tmp['setup']:
+                phpConfig = self.GetPHPConfig(version)
+                tmp['version'] = version
+                tmp['max'] = phpConfig['max']
+                tmp['maxTime'] = phpConfig['maxTime']
+                tmp['pathinfo'] = phpConfig['pathinfo']
+                tmp['status'] = os.path.exists(
+                    '/tmp/php-cgi-' + version + '.sock')
+                data['php'].append(tmp)
+
+        tmp = {}
+        data['webserver'] = ''
+        serviceName = 'nginx'
+        tmp['setup'] = False
+        phpversion = "54"
+        phpport = '888'
+        pstatus = False
+        pauth = False
+        if os.path.exists(self.setupPath + '/nginx'):
+            data['webserver'] = 'nginx'
+            serviceName = 'nginx'
+            tmp['setup'] = os.path.exists(self.setupPath + '/nginx/sbin/nginx')
+            configFile = self.setupPath + '/nginx/conf/nginx.conf'
+            try:
+                if os.path.exists(configFile):
+                    conf = public.readFile(configFile)
+                    rep = "listen\s+([0-9]+)\s*;"
+                    rtmp = re.search(rep, conf)
+                    if rtmp:
+                        phpport = rtmp.groups()[0]
+
+                    if conf.find('AUTH_START') != -1:
+                        pauth = True
+                    if conf.find(self.setupPath + '/stop') == -1:
+                        pstatus = True
+                    configFile = self.setupPath + '/nginx/conf/enable-php.conf'
+                    conf = public.readFile(configFile)
+                    rep = "php-cgi-([0-9]+)\.sock"
+                    rtmp = re.search(rep, conf)
+                    if rtmp:
+                        phpversion = rtmp.groups()[0]
+            except:
+                pass
+
+        elif os.path.exists(self.setupPath + '/apache'):
+            data['webserver'] = 'apache'
+            serviceName = 'httpd'
+            tmp['setup'] = os.path.exists(self.setupPath + '/apache/bin/httpd')
+            configFile = self.setupPath + '/apache/conf/extra/httpd-vhosts.conf'
+            try:
+                if os.path.exists(configFile):
+                    conf = public.readFile(configFile)
+                    rep = "php-cgi-([0-9]+)\.sock"
+                    rtmp = re.search(rep, conf)
+                    if rtmp:
+                        phpversion = rtmp.groups()[0]
+                    rep = "Listen\s+([0-9]+)\s*\n"
+                    rtmp = re.search(rep, conf)
+                    if rtmp:
+                        phpport = rtmp.groups()[0]
+                    if conf.find('AUTH_START') != -1:
+                        pauth = True
+                    if conf.find(self.setupPath + '/stop') == -1:
+                        pstatus = True
+            except:
+                pass
+
+        tmp['type'] = data['webserver']
+        tmp['version'] = public.readFile(
+            self.setupPath + '/' + data['webserver'] + '/version.pl')
+        tmp['status'] = False
+        result = public.ExecShell('/etc/init.d/' + serviceName + ' status')
+        if result[0].find('running') != -1:
+            tmp['status'] = True
+        data['web'] = tmp
+
+        tmp = {}
+        vfile = self.setupPath + '/phpmyadmin/version.pl'
+        tmp['version'] = public.readFile(vfile)
+        tmp['setup'] = os.path.exists(vfile)
+        tmp['status'] = pstatus
+        tmp['phpversion'] = phpversion
+        tmp['port'] = phpport
+        tmp['auth'] = pauth
+        data['phpmyadmin'] = tmp
+
+        tmp = {}
+        tmp['setup'] = os.path.exists('/etc/init.d/tomcat')
+        tmp['status'] = False
+        if tmp['setup']:
+            if os.path.exists('/www/server/tomcat/logs/catalina-daemon.pid'):
+                tmp['status'] = self.getPid('jsvc')
+            if not tmp['status']:
+                tmp['status'] = self.getPid('java')
+        tmp['version'] = public.readFile(self.setupPath + '/tomcat/version.pl')
+        data['tomcat'] = tmp
+
+        tmp = {}
+        tmp['setup'] = os.path.exists(self.setupPath + '/mysql/bin/mysql')
+        tmp['version'] = public.readFile(self.setupPath + '/mysql/version.pl')
+        tmp['status'] = os.path.exists('/tmp/mysql.sock')
+        data['mysql'] = tmp
+
+        tmp = {}
+        tmp['setup'] = os.path.exists(self.setupPath + '/redis/runtest')
+        tmp['status'] = os.path.exists('/var/run/redis_6379.pid')
+        data['redis'] = tmp
+
+        tmp = {}
+        tmp['setup'] = os.path.exists('/usr/local/memcached/bin/memcached')
+        tmp['status'] = os.path.exists('/var/run/memcached.pid')
+        data['memcached'] = tmp
+
+        tmp = {}
+        tmp['setup'] = os.path.exists(
+            self.setupPath + '/pure-ftpd/bin/pure-pw')
+        tmp['version'] = public.readFile(
+            self.setupPath + '/pure-ftpd/version.pl')
+        tmp['status'] = os.path.exists('/var/run/pure-ftpd.pid')
+        data['pure-ftpd'] = tmp
+        data['panel'] = self.GetPanelInfo()
+        data['systemdate'] = public.ExecShell(
+            'date +"%Y-%m-%d %H:%M:%S %Z %z"')[0].strip()
+
+        return data
+
+    # 名取PID
+    def getPid(self, pname):
+        try:
+            if not self.pids:
+                self.pids = psutil.pids()
+            for pid in self.pids:
+                if psutil.Process(pid).name() == pname:
+                    return True
+            return False
+        except:
+            return False
+
+    # 检测指定进程是否存活
+    def checkProcess(self, pid):
+        try:
+            if not self.pids:
+                self.pids = psutil.pids()
+            if int(pid) in self.pids:
+                return True
+            return False
+        except:
+            return False
+
+    def GetPanelInfo(self, get=None):
+        # 取面板配置
+        address = public.GetLocalIp()
+        try:
+            try:
+                port = web.ctx.host.split(':')[1]
+            except:
+                port = public.readFile('data/port.pl')
+        except:
+            port = '8888'
+        domain = ''
+        if os.path.exists('data/domain.conf'):
+            domain = public.readFile('data/domain.conf')
+
+        autoUpdate = ''
+        if os.path.exists('data/autoUpdate.pl'):
+            autoUpdate = 'checked'
+        limitip = ''
+        if os.path.exists('data/limitip.conf'):
+            limitip = public.readFile('data/limitip.conf')
+
+        templates = []
+        for template in os.listdir('templates/'):
+            if os.path.isdir('templates/' + template):
+                templates.append(template)
+        template = public.readFile('data/templates.pl')
+
+        check502 = ''
+        if os.path.exists('data/502Task.pl'):
+            check502 = 'checked'
+        return {'port': port, 'address': address, 'domain': domain, 'auto': autoUpdate, '502': check502, 'limitip': limitip, 'templates': templates, 'template': template}
+
+    def GetPHPConfig(self, version):
+        # 取PHP配置
+        file = self.setupPath + "/php/" + version + "/etc/php.ini"
+        phpini = public.readFile(file)
+        file = self.setupPath + "/php/" + version + "/etc/php-fpm.conf"
+        phpfpm = public.readFile(file)
+        data = {}
+        try:
+            rep = "upload_max_filesize\s*=\s*([0-9]+)M"
+            tmp = re.search(rep, phpini).groups()
+            data['max'] = tmp[0]
+        except:
+            data['max'] = '50'
+        try:
+            rep = "request_terminate_timeout\s*=\s*([0-9]+)\n"
+            tmp = re.search(rep, phpfpm).groups()
+            data['maxTime'] = tmp[0]
+        except:
+            data['maxTime'] = 0
+
+        try:
+            rep = ur"\n;*\s*cgi\.fix_pathinfo\s*=\s*([0-9]+)\s*\n"
+            tmp = re.search(rep, phpini).groups()
+
+            if tmp[0] == '1':
+                data['pathinfo'] = True
+            else:
+                data['pathinfo'] = False
+        except:
+            data['pathinfo'] = False
+
+        return data
+
+    def GetSystemTotal(self, get, interval=1):
+        # 取系统统计信息
+        data = self.GetMemInfo()
+        cpu = self.GetCpuInfo(interval)
+        data['cpuNum'] = cpu[1]
+        data['cpuRealUsed'] = cpu[0]
+        data['time'] = self.GetBootTime()
+        data['system'] = self.GetSystemVersion()
+        data['isuser'] = public.M('users').where(
+            'username=?', ('admin',)).count()
+        data['version'] = web.ctx.session.version
+        return data
+
+    def GetLoadAverage(self, get):
+        c = os.getloadavg()
+        data = {}
+        data['one'] = float(c[0])
+        data['five'] = float(c[1])
+        data['fifteen'] = float(c[2])
+        data['max'] = psutil.cpu_count() * 2
+        data['limit'] = data['max']
+        data['safe'] = data['max'] * 0.75
+        return data
+
+    def GetAllInfo(self, get):
+        data = {}
+        data['load_average'] = self.GetLoadAverage(get)
+        data['title'] = self.GetTitle()
+        data['network'] = self.GetNetWorkApi(get)
+        data['panel_status'] = not os.path.exists(
+            '/www/server/panel/data/close.pl')
+        import firewalls
+        ssh_info = firewalls.firewalls().GetSshInfo(None)
+        data['enable_ssh_status'] = ssh_info['status']
+        data['disable_ping_status'] = not ssh_info['ping']
+        data['time'] = self.GetBootTime()
+        #data['system'] = self.GetSystemVersion();
+        #data['mem'] = self.GetMemInfo();
+        data['version'] = web.ctx.session.version
+        return data
+
+    def GetTitle(self):
+        titlePl = 'data/title.pl'
+        title = '宝塔Linux面板'
+        if os.path.exists(titlePl):
+            title = public.readFile(titlePl).strip()
+        return title
+
+    def GetSystemVersion(self):
+        # 取操作系统版本
+        import public
+        version = public.readFile('/etc/redhat-release')
+        if not version:
+            version = public.readFile(
+                '/etc/issue').strip().split("\n")[0].replace('\\n', '').replace('\l', '').strip()
+        else:
+            version = version.replace('release ', '').strip()
+        return version
+
+    def GetBootTime(self):
+        # 取系统启动时间
+        import public
+        import math
+        conf = public.readFile('/proc/uptime').split()
+        tStr = float(conf[0])
+        min = tStr / 60
+        hours = min / 60
+        days = math.floor(hours / 24)
+        hours = math.floor(hours - (days * 24))
+        min = math.floor(min - (days * 60 * 24) - (hours * 60))
+        return public.getMsg('SYS_BOOT_TIME', (str(int(days)), str(int(hours)), str(int(min))))
+
+    def GetCpuInfo(self, interval=1):
+        # 取CPU信息
+        cpuCount = psutil.cpu_count()
+        used = psutil.cpu_percent(interval=interval)
+        return used, cpuCount
+
+    def GetMemInfo(self, get=None):
+        # 取内存信息
+        mem = psutil.virtual_memory()
+        memInfo = {'memTotal': mem.total / 1024 / 1024, 'memFree': mem.free / 1024 / 1024,
+                   'memBuffers': mem.buffers / 1024 / 1024, 'memCached': mem.cached / 1024 / 1024}
+        memInfo['memRealUsed'] = memInfo['memTotal'] - \
+            memInfo['memFree'] - memInfo['memBuffers'] - memInfo['memCached']
+        return memInfo
+
+    def GetDiskInfo(self, get=None):
+        return self.GetDiskInfo2()
+        # 取磁盘分区信息
+        diskIo = psutil.disk_partitions()
+        diskInfo = []
+
+        for disk in diskIo:
+            if disk[1] == '/mnt/cdrom':
+                continue
+            if disk[1] == '/boot':
+                continue
+            tmp = {}
+            tmp['path'] = disk[1]
+            tmp['size'] = psutil.disk_usage(disk[1])
+            diskInfo.append(tmp)
+        return diskInfo
+
+    def GetDiskInfo2(self):
+        # 取磁盘分区信息
+        temp = public.ExecShell("df -h -P|grep '/'|grep -v tmpfs")[0]
+        tempInodes = public.ExecShell("df -i -P|grep '/'|grep -v tmpfs")[0]
+        temp1 = temp.split('\n')
+        tempInodes1 = tempInodes.split('\n')
+        diskInfo = []
+        n = 0
+        cuts = ['/mnt/cdrom', '/boot', '/boot/efi', '/dev',
+                '/dev/shm', '/run/lock', '/run', '/run/shm', '/run/user']
+        for tmp in temp1:
+            n += 1
+            inodes = tempInodes1[n - 1].split()
+            disk = tmp.split()
+            if len(disk) < 5:
+                continue
+            if disk[1].find('M') != -1:
+                continue
+            if disk[1].find('K') != -1:
+                continue
+            if len(disk[5].split('/')) > 4:
+                continue
+            if disk[5] in cuts:
+                continue
+            arr = {}
+            arr['path'] = disk[5]
+            tmp1 = [disk[1], disk[2], disk[3], disk[4]]
+            arr['size'] = tmp1
+            arr['inodes'] = [inodes[1], inodes[2], inodes[3], inodes[4]]
+            if disk[5] == '/':
+                bootLog = '/tmp/panelBoot.pl'
+                if disk[2].find('M') != -1:
+                    if os.path.exists(bootLog):
+                        os.system('rm -f ' + bootLog)
+                else:
+                    if not os.path.exists(bootLog):
+                        os.system('sleep 1 && /etc/init.d/bt reload &')
+            diskInfo.append(arr)
+        return diskInfo
+
+    # 清理系统垃圾
+    def ClearSystem(self, get):
+        count = total = 0
+        tmp_total, tmp_count = self.ClearMail()
+        count += tmp_count
+        total += tmp_total
+        tmp_total, tmp_count = self.ClearOther()
+        count += tmp_count
+        total += tmp_total
+        return count, total
+
+    # 清理邮件日志
+    def ClearMail(self):
+        rpath = '/var/spool'
+        total = count = 0
+        import shutil
+        con = ['cron', 'anacron', 'mail']
+        for d in os.listdir(rpath):
+            if d in con:
+                continue
+            dpath = rpath + '/' + d
+            time.sleep(0.2)
+            num = size = 0
+            for n in os.listdir(dpath):
+                filename = dpath + '/' + n
+                fsize = os.path.getsize(filename)
+                size += fsize
+                if os.path.isdir(filename):
+                    shutil.rmtree(filename)
+                else:
+                    os.remove(filename)
+                print '\t\033[1;32m[OK]\033[0m'
+                num += 1
+            total += size
+            count += num
+        return total, count
+
+    # 清理其它
+    def ClearOther(self):
+        clearPath = [
+            {'path': '/www/server/panel', 'find': 'testDisk_'},
+            {'path': '/www/wwwlogs', 'find': 'log'},
+            {'path': '/tmp', 'find': 'panelBoot.pl'},
+            {'path': '/www/server/panel/install', 'find': '.rpm'}
+        ]
+
+        total = count = 0
+        for c in clearPath:
+            for d in os.listdir(c['path']):
+                if d.find(c['find']) == -1:
+                    continue
+                filename = c['path'] + '/' + d
+                fsize = os.path.getsize(filename)
+                total += fsize
+                if os.path.isdir(filename):
+                    shutil.rmtree(filename)
+                else:
+                    os.remove(filename)
+                count += 1
+        public.serviceReload()
+        os.system('echo > /tmp/panelBoot.pl')
+        return total, count
+
+    def GetNetWork(self, get=None):
+        # return self.GetNetWorkApi(get);
+        # 取网络流量信息
+        try:
+            networkIo = psutil.net_io_counters()[:4]
+            if not hasattr(web.ctx.session, 'otime'):
+                web.ctx.session.up = networkIo[0]
+                web.ctx.session.down = networkIo[1]
+                web.ctx.session.otime = time.time()
+
+            ntime = time.time()
+            networkInfo = {}
+            networkInfo['upTotal'] = networkIo[0]
+            networkInfo['downTotal'] = networkIo[1]
+            networkInfo['up'] = round(float(
+                networkIo[0] - web.ctx.session.up) / 1024 / (ntime - web.ctx.session.otime), 2)
+            networkInfo['down'] = round(float(
+                networkIo[1] - web.ctx.session.down) / 1024 / (ntime - web.ctx.session.otime), 2)
+            networkInfo['downPackets'] = networkIo[3]
+            networkInfo['upPackets'] = networkIo[2]
+
+            web.ctx.session.up = networkIo[0]
+            web.ctx.session.down = networkIo[1]
+            web.ctx.session.otime = ntime
+
+            networkInfo['cpu'] = self.GetCpuInfo()
+            networkInfo['load'] = self.GetLoadAverage(get)
+            return networkInfo
+        except:
+            return None
+
+    def GetNetWorkApi(self, get=None):
+        # 取网络流量信息
+        try:
+            tmpfile = 'data/network.temp'
+            networkIo = psutil.net_io_counters()[:4]
+
+            if not os.path.exists(tmpfile):
+                public.writeFile(tmpfile, str(
+                    networkIo[0]) + '|' + str(networkIo[1]) + '|' + str(int(time.time())))
+
+            lastValue = public.readFile(tmpfile).split('|')
+
+            ntime = time.time()
+            networkInfo = {}
+            networkInfo['upTotal'] = networkIo[0]
+            networkInfo['downTotal'] = networkIo[1]
+            networkInfo['up'] = round(
+                float(networkIo[0] - int(lastValue[0])) / 1024 / (ntime - int(lastValue[2])), 2)
+            networkInfo['down'] = round(
+                float(networkIo[1] - int(lastValue[1])) / 1024 / (ntime - int(lastValue[2])), 2)
+            networkInfo['downPackets'] = networkIo[3]
+            networkInfo['upPackets'] = networkIo[2]
+
+            public.writeFile(tmpfile, str(
+                networkIo[0]) + '|' + str(networkIo[1]) + '|' + str(int(time.time())))
+
+            #networkInfo['cpu'] = self.GetCpuInfo(0.1)
+            return networkInfo
+        except:
+            return None
+
+    def GetNetWorkOld(self):
+        # 取网络流量信息
+        import time
+        pnet = public.readFile('/proc/net/dev')
+        rep = '([^\s]+):[\s]{0,}(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)\s+(\d+)'
+        pnetall = re.findall(rep, pnet)
+        networkInfo = {}
+        networkInfo['upTotal'] = networkInfo['downTotal'] = networkInfo['up'] = networkInfo[
+            'down'] = networkInfo['downPackets'] = networkInfo['upPackets'] = 0
+        for pnetInfo in pnetall:
+            if pnetInfo[0] == 'io':
+                continue
+            networkInfo['downTotal'] += int(pnetInfo[1])
+            networkInfo['downPackets'] += int(pnetInfo[2])
+            networkInfo['upTotal'] += int(pnetInfo[9])
+            networkInfo['upPackets'] += int(pnetInfo[10])
+
+        if not hasattr(web.ctx.session, 'otime'):
+            web.ctx.session.up = networkInfo['upTotal']
+            web.ctx.session.down = networkInfo['downTotal']
+            web.ctx.session.otime = time.time()
+        ntime = time.time()
+        tmpDown = networkInfo['downTotal'] - web.ctx.session.down
+        tmpUp = networkInfo['upTotal'] - web.ctx.session.up
+        networkInfo['down'] = str(
+            round(float(tmpDown) / 1024 / (ntime - web.ctx.session.otime), 2))
+        networkInfo['up'] = str(
+            round(float(tmpUp) / 1024 / (ntime - web.ctx.session.otime), 2))
+        if networkInfo['down'] < 0:
+            networkInfo['down'] = 0
+        if networkInfo['up'] < 0:
+            networkInfo['up'] = 0
+
+        web.ctx.session.up = networkInfo['upTotal']
+        web.ctx.session.down = networkInfo['downTotal']
+        web.ctx.session.otime = ntime
+        networkInfo['cpu'] = self.GetCpuInfo()
+        return networkInfo
+
+    def ServiceAdmin(self, get=None):
+        # 服务管理
+
+        if get.name == 'mysqld':
+            public.CheckMyCnf()
+
+        if get.name == 'phpmyadmin':
+            import ajax
+            get.status = 'True'
+            ajax.ajax().setPHPMyAdmin(get)
+            return public.returnMsg(True, 'SYS_EXEC_SUCCESS')
+
+        # 检查httpd配置文件
+        if get.name == 'apache' or get.name == 'httpd':
+            get.name = 'httpd'
+            if not os.path.exists(self.setupPath + '/apache/bin/apachectl'):
+                return public.returnMsg(True, 'SYS_NOT_INSTALL_APACHE')
+            vhostPath = self.setupPath + '/panel/vhost/apache'
+            if not os.path.exists(vhostPath):
+                public.ExecShell('mkdir ' + vhostPath)
+                public.ExecShell('/etc/init.d/httpd start')
+
+            if get.type == 'start':
+                public.ExecShell('/etc/init.d/httpd stop')
+                public.ExecShell('pkill -9 httpd')
+
+            result = public.ExecShell(
+                'ulimit -n 10240 && ' + self.setupPath + '/apache/bin/apachectl -t')
+            if result[1].find('Syntax OK') == -1:
+                public.WriteLog("TYPE_SOFT", 'SYS_EXEC_ERR', (str(result),))
+                return public.returnMsg(False, 'SYS_CONF_APACHE_ERR', (result[1].replace("\n", '<br>'),))
+
+            if get.type == 'restart':
+                public.ExecShell('pkill -9 httpd')
+                public.ExecShell('/etc/init.d/httpd start')
+
+        # 检查nginx配置文件
+        elif get.name == 'nginx':
+            vhostPath = self.setupPath + '/panel/vhost/rewrite'
+            if not os.path.exists(vhostPath):
+                public.ExecShell('mkdir ' + vhostPath)
+            vhostPath = self.setupPath + '/panel/vhost/nginx'
+            if not os.path.exists(vhostPath):
+                public.ExecShell('mkdir ' + vhostPath)
+                public.ExecShell('/etc/init.d/nginx start')
+
+            result = public.ExecShell(
+                'ulimit -n 10240 && nginx -t -c ' + self.setupPath + '/nginx/conf/nginx.conf')
+            if result[1].find('perserver') != -1:
+                limit = self.setupPath + '/nginx/conf/nginx.conf'
+                nginxConf = public.readFile(limit)
+                limitConf = "limit_conn_zone $binary_remote_addr zone=perip:10m;\n\t\tlimit_conn_zone $server_name zone=perserver:10m;"
+                nginxConf = nginxConf.replace(
+                    "#limit_conn_zone $binary_remote_addr zone=perip:10m;", limitConf)
+                public.writeFile(limit, nginxConf)
+                public.ExecShell('/etc/init.d/nginx start')
+                return public.returnMsg(True, 'SYS_CONF_NGINX_REP')
+
+            if result[1].find('proxy') != -1:
+                import panelSite
+                panelSite.panelSite().CheckProxy(get)
+                public.ExecShell('/etc/init.d/nginx start')
+                return public.returnMsg(True, 'SYS_CONF_NGINX_REP')
+
+            # return result
+            if result[1].find('successful') == -1:
+                public.WriteLog("TYPE_SOFT", 'SYS_EXEC_ERR', (str(result),))
+                return public.returnMsg(False, 'SYS_CONF_NGINX_ERR', (result[1].replace("\n", '<br>'),))
+
+        # 执行
+        execStr = "/etc/init.d/" + get.name + " " + get.type
+        if execStr == '/etc/init.d/pure-ftpd reload':
+            execStr = self.setupPath + '/pure-ftpd/bin/pure-pw mkdb ' + \
+                self.setupPath + '/pure-ftpd/etc/pureftpd.pdb'
+        if execStr == '/etc/init.d/pure-ftpd start':
+            os.system('pkill -9 pure-ftpd')
+        if execStr == '/etc/init.d/tomcat reload':
+            execStr = '/etc/init.d/tomcat stop && /etc/init.d/tomcat start'
+        if execStr == '/etc/init.d/tomcat restart':
+            execStr = '/etc/init.d/tomcat stop && /etc/init.d/tomcat start'
+
+        if get.name != 'mysqld':
+            result = public.ExecShell(execStr)
+        else:
+            os.system(execStr)
+            result = []
+            result.append('')
+            result.append('')
+
+        if result[1].find('nginx.pid') != -1:
+            public.ExecShell('pkill -9 nginx && sleep 1')
+            public.ExecShell('/etc/init.d/nginx start')
+        if get.type != 'test':
+            public.WriteLog("TYPE_SOFT", 'SYS_EXEC_SUCCESS', (execStr,))
+
+        if len(result[1]) > 1 and get.name != 'pure-ftpd':
+            return public.returnMsg(False, '<p>警告消息： <p>' + result[1].replace('\n', '<br>'))
+        return public.returnMsg(True, 'SYS_EXEC_SUCCESS')
+
+    def RestartServer(self, get):
+        if not public.IsRestart():
+            return public.returnMsg(False, 'EXEC_ERR_TASK')
+        public.ExecShell("sync && /etc/init.d/bt stop && init 6 &")
+        return public.returnMsg(True, 'SYS_REBOOT')
+
+    # 释放内存
+    def ReMemory(self, get):
+        os.system('sync')
+        scriptFile = 'script/rememory.sh'
+        if not os.path.exists(scriptFile):
+            public.downloadFile(web.ctx.session.home +
+                                '/script/rememory.sh', scriptFile)
+        public.ExecShell("/bin/bash " + self.setupPath +
+                         '/panel/' + scriptFile)
+        return self.GetMemInfo()
+
+    # 重启面板
+    def ReWeb(self, get):
+        # if not public.IsRestart(): return
+        # public.returnMsg(False,'EXEC_ERR_TASK');
+        public.ExecShell('/etc/init.d/bt restart &')
+        return True
+
+    # 修复面板
+    def RepPanel(self, get):
+        vp = ''
+        if public.readFile('/www/server/panel/class/common.py').find('checkSafe') != -1:
+            vp = '_pro'
+        public.ExecShell("wget -O update.sh " + public.get_url() +
+                         "/install/update" + vp + ".sh && bash update.sh")
+        if hasattr(web.ctx.session, 'getCloudPlugin'):
+            del(web.ctx.session['getCloudPlugin'])
+        return True
+
+    # 升级到专业版
+    def UpdatePro(self, get):
+        public.ExecShell("wget -O update.sh " + public.get_url() +
+                         "/install/update_pro.sh && bash update.sh pro")
+        if hasattr(web.ctx.session, 'getCloudPlugin'):
+            del(web.ctx.session['getCloudPlugin'])
+        return True

class/core/vilidate.py

@@ -0,0 +1,132 @@
+#!/usr/bin/env python
+# coding: utf-8
+
+
+import random
+import math
+from PIL import Image, ImageDraw, ImageFont, ImageFilter
+
+
+class vieCode:
+    __fontSize = 20  # 字体大小
+    __width = 120  # 画布宽度
+    __heigth = 45  # 画布高度
+    __length = 4  # 验证码长度
+    __draw = None  # 画布
+    __img = None  # 图片资源
+    __code = None  # 验证码字符
+    __str = None  # 自定义验证码字符集
+    __inCurve = True  # 是否画干扰线
+    __inNoise = True  # 是否画干扰点
+    __type = 2  # 验证码类型 1、纯字母  2、数字字母混合
+    __fontPatn = 'class/fonts/2.ttf'  # 字体
+
+    def GetCodeImage(self, size=80, length=4):
+        '''获取验证码图片
+           @param int size 验证码大小
+           @param int length 验证码长度
+        '''
+        # 准备基础数据
+        self.__length = length
+        self.__fontSize = size
+        self.__width = self.__fontSize * self.__length
+        self.__heigth = int(self.__fontSize * 1.5)
+
+        # 生成验证码图片
+        self.__createCode()
+        self.__createImage()
+        self.__createNoise()
+        self.__printString()
+        self.__cerateFilter()
+
+        return self.__img, self.__code
+
+    def __cerateFilter(self):
+        '''模糊处理'''
+        self.__img = self.__img.filter(ImageFilter.BLUR)
+        filter = ImageFilter.ModeFilter(8)
+        self.__img = self.__img.filter(filter)
+
+    def __createCode(self):
+        '''创建验证码字符'''
+        # 是否自定义字符集合
+        if not self.__str:
+            # 源文本
+            number = "3456789"
+            srcLetter = "qwertyuipasdfghjkzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM"
+            srcUpper = srcLetter.upper()
+            if self.__type == 1:
+                self.__str = number
+            else:
+                self.__str = srcLetter + srcUpper + number
+
+        # 构造验证码
+        self.__code = random.sample(self.__str, self.__length)
+
+    def __createImage(self):
+        '''创建画布'''
+        bgColor = (random.randint(200, 255), random.randint(
+            200, 255), random.randint(200, 255))
+        self.__img = Image.new('RGB', (self.__width, self.__heigth), bgColor)
+        self.__draw = ImageDraw.Draw(self.__img)
+
+    def __createNoise(self):
+        '''画干扰点'''
+        if not self.__inNoise:
+            return
+        font = ImageFont.truetype(self.__fontPatn, int(self.__fontSize / 1.5))
+        for i in xrange(5):
+            # 杂点颜色
+            noiseColor = (random.randint(150, 200), random.randint(
+                150, 200), random.randint(150, 200))
+            putStr = random.sample(self.__str, 2)
+            for j in range(2):
+                # 绘杂点
+                size = (random.randint(-10, self.__width),
+                        random.randint(-10, self.__heigth))
+                self.__draw.text(size, putStr[j], font=font, fill=noiseColor)
+        pass
+
+    def __createCurve(self):
+        '''画干扰线'''
+        if not self.__inCurve:
+            return
+        x = y = 0
+
+        # 计算曲线系数
+        a = random.uniform(1, self.__heigth / 2)
+        b = random.uniform(-self.__width / 4, self.__heigth / 4)
+        f = random.uniform(-self.__heigth / 4, self.__heigth / 4)
+        t = random.uniform(self.__heigth, self.__width * 2)
+        xend = random.randint(self.__width / 2, self.__width * 2)
+        w = (2 * math.pi) / t
+
+        # 画曲线
+        color = (random.randint(30, 150), random.randint(
+            30, 150), random.randint(30, 150))
+        for x in xrange(xend):
+            if w != 0:
+                for k in xrange(int(self.__heigth / 10)):
+                    y = a * math.sin(w * x + f) + b + self.__heigth / 2
+                    i = int(self.__fontSize / 5)
+                    while i > 0:
+                        px = x + i
+                        py = y + i + k
+                        self.__draw.point((px, py), color)
+                        i -= i
+
+    def __printString(self):
+        '''打印验证码字符串'''
+        font = ImageFont.truetype(self.__fontPatn, self.__fontSize)
+        x = 0
+        # 打印字符到画板
+        for i in xrange(self.__length):
+            # 设置字体随机颜色
+            color = (random.randint(30, 150), random.randint(
+                30, 150), random.randint(30, 150))
+            # 计算座标
+            x = random.uniform(self.__fontSize * i * 0.95,
+                               self.__fontSize * i * 1.1)
+            y = self.__fontSize * random.uniform(0.3, 0.5)
+            # 打印字符
+            self.__draw.text((x, y), self.__code[i], font=font, fill=color)