| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740 | import base64import datetimeimport ipdbimport timefrom base64 import encodebytesfrom pathlib import Pathfrom random import Randomimport OpenSSL.crypto as ctimport requestsimport simplejson as jsonfrom dateutil.relativedelta import relativedeltafrom django.core import serializersfrom django.utils import timezonefrom pyipip import IPIPDatabasefrom Ansjer.config import BASE_DIR, SERVER_DOMAIN_SSL, CONFIG_INFO, CONFIG_TEST, CONFIG_CN, SERVER_DOMAIN_TEST, \    SERVER_DOMAIN_CN, SERVER_DOMAIN_US, CONFIG_US, CONFIG_EUR, SERVER_DOMAIN_LIST, SERVER_DOMAIN_EURfrom Controller.CheckUserData import RandomStrfrom Model.models import iotdeviceInfoModel, Device_Info, UIDModelfrom Object.ResponseObject import ResponseObjectfrom Object.TokenObject import TokenObjectclass CommonService:    # 高复用性函数类    @staticmethod    def get_kwargs(data=None):        # 添加模糊搜索        if data is None:            data = {}        kwargs = {}        for (k, v) in data.items():            if v is not None and v != u'':                kwargs[k + '__icontains'] = v        return kwargs    @staticmethod    def qs_to_dict(query_set):        # 格式化query_set转dict        sqlJSON = serializers.serialize('json', query_set)        sqlList = json.loads(sqlJSON)        sqlDict = dict(zip(["datas"], [sqlList]))        return sqlDict    # 格式化query_set转dict    @staticmethod    def request_dict_to_dict(request_dict):        # 传参格式转换,键包含meta获取meta[]中的值,值'true'/'false'转为True,False        key_list = []        value_list = []        for k, v in request_dict.items():            key_list.append(k[k.index('[') + 1:k.index(']')] if 'meta' in k else k)            if v == 'true':                v = True            elif v == 'false':                v = False            value_list.append(v)        data_dict = dict(zip(key_list, value_list))        print(data_dict)        return data_dict    # 获取文件大小    @staticmethod    def get_file_size(file_path='', suffix_type='', decimal_point=0):        # for x in ['bytes', 'KB', 'MB', 'GB', 'TB']:        # path = Path() / 'D:/TestServer/123444.mp4'        path = Path() / file_path        size = path.stat().st_size        mb_size = 0.0        if suffix_type == 'MB':            mb_size = size / 1024.0 / 1024.0        if decimal_point != 0:            mb_size = round(mb_size, decimal_point)        return mb_size    @staticmethod    def get_param_flag(data=None):        # print(data)        if data is None:            data = []        flag = True        for v in data:            if v is None:                flag = False                break        return flag    @staticmethod    def get_ip_address(request):        """        获取ip地址        :param request:        :return:        """        try:            real_ip = request.META['HTTP_X_FORWARDED_FOR']            clientIP = real_ip.split(",")[0]        except:            try:                clientIP = request.META['REMOTE_ADDR']            except Exception as e:                clientIP = ''        return clientIP    # @获取一天每个小时的datetime.datetime    @staticmethod    def getTimeDict(times):        time_dict = {}        t = 0        for x in range(24):            if x < 10:                x = '0' + str(x)            else:                x = str(x)            a = times.strftime("%Y-%m-%d") + " " + x + ":00:00"            time_dict[t] = timezone.datetime.strptime(a, '%Y-%m-%d %H:%M:%S')            t += 1        return time_dict    # 根据ip获取地址    @staticmethod    def getAddr(ip):        print('start_time=' + str(time.time()))        base_dir = BASE_DIR        # ip数据库        db = IPIPDatabase(base_dir + '/DB/17monipdb.dat')        addr = db.lookup(ip)        # ModelService.add_tmp_log(addr)        ts = addr.split('\t')[0]        print('end_time=' + str(time.time()))        return ts    # 通过ip检索ipip指定信息 lang为CN或EN    @staticmethod    def getIpIpInfo(ip, lang, update=False):        ipbd_dir = BASE_DIR + "/DB/mydata4vipday2.ipdb"        db = ipdb.City(ipbd_dir)        if update:            rr = db.reload(ipbd_dir)        info = db.find_map(ip, lang)        return info    @staticmethod    def getUserID(userPhone='13800138000', getUser=True, setOTAID=False, μs=True):        if μs == True:            if getUser == True:                timeID = str(round(time.time() * 1000000))                userID = timeID + userPhone                return userID            else:                if setOTAID == False:                    timeID = str(round(time.time() * 1000000))                    ID = userPhone + timeID                    return ID                else:                    timeID = str(round(time.time() * 1000000))                    eID = '13800' + timeID + '138000'                    return eID        else:            if getUser == True:                timeID = str(round(time.time() * 1000))                userID = timeID + userPhone                return userID            else:                if setOTAID == False:                    timeID = str(round(time.time() * 1000))                    ID = userPhone + timeID                    return ID                else:                    timeID = str(round(time.time() * 1000))                    eID = '13800' + timeID + '138000'                    return eID    # 生成随机数    @staticmethod    def RandomStr(randomlength=8, number=True):        str = ''        if number == False:            characterSet = 'AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsT' \                           'tUuVvWwXxYyZz0123456789'        else:            characterSet = '0123456789'        length = len(characterSet) - 1        random = Random()        for index in range(randomlength):            str += characterSet[random.randint(0, length)]        return str    # 生成订单好    @staticmethod    def createOrderID():        random_id = CommonService.RandomStr(6, True)        order_id = datetime.datetime.now().strftime('%Y%m%d%H%M%S') + str(random_id)        print('orderID:')        print(order_id)        return order_id    # qs转换list datetime处理    @staticmethod    def qs_to_list(qs):        res = []        # print(qs)        for ps in qs:            try:                if 'time' in ps:                    ps['time'] = ps['time'].strftime("%Y-%m-%d %H:%M:%S")                if 'add_time' in ps:                    ps['add_time'] = ps['add_time'].strftime("%Y-%m-%d %H:%M:%S")                if 'update_time' in ps:                    ps['update_time'] = ps['update_time'].strftime("%Y-%m-%d %H:%M:%S")                if 'end_time' in ps:                    ps['end_time'] = ps['end_time'].strftime("%Y-%m-%d %H:%M:%S")                if 'data_joined' in ps:                    if ps['data_joined']:                        ps['data_joined'] = ps['data_joined'].strftime("%Y-%m-%d %H:%M:%S")                    else:                        ps['data_joined'] = ''                if 'userID__data_joined' in ps:                    if ps['userID__data_joined']:                        ps['userID__data_joined'] = ps['userID__data_joined'].strftime("%Y-%m-%d %H:%M:%S")                    else:                        ps['userID__data_joined'] = ''            except Exception as e:                pass            res.append(ps)        return res    # 获取当前时间    @staticmethod    def get_now_time_str(n_time, tz, lang):        print(n_time)        print(tz)        print(lang)        n_time = int(n_time) + 3600 * float(tz)        if lang == 'cn':            return time.strftime('%Y-%m-%d %H:%M:%S', time.gmtime(int(n_time)))        else:            return time.strftime('%m-%d-%Y %H:%M:%S', time.gmtime(int(n_time)))    # 生成随机数    @staticmethod    def encrypt_data(randomlength=8, number=False):        str = ''        if number == False:            characterSet = 'AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsT' \                           'tUuVvWwXxYyZz0123456789'        else:            characterSet = '0123456789'        length = len(characterSet) - 1        random = Random()        for index in range(randomlength):            str += characterSet[random.randint(0, length)]        return str    @staticmethod    def encode_data(content, start=1, end=4):        """        数据加密        @param content: 数据内容        @param start: 起始长度        @param end: 结束长度        @return content: 加密的数据        """        if not content:            return ''        for i in range(start, end):            length = end - i            content = RandomStr(length, False) + content + RandomStr(length, False)            content = base64.b64encode(str(content).encode('utf-8')).decode('utf8')        return content    @staticmethod    def decode_data(content, start=1, end=4):        """        数据解密        @param content: 数据内容        @param start: 起始长度        @param end: 结束长度        @return content: 解密的数据        """        if not content:            return ''        for i in range(start, end):            content = base64.b64decode(content)            content = content.decode('utf-8')            content = content[i:-i]        return content    # 把格式化时间转换成时间戳    @staticmethod    def str_to_timestamp(str_time=None, format='%Y-%m-%d %H:%M:%S'):        if str_time:            time_tuple = time.strptime(str_time, format)  # 把格式化好的时间转换成元祖            result = time.mktime(time_tuple)  # 把时间元祖转换成时间戳            return int(result)        return int(time.time())    # 把时间戳转换成格式化    @staticmethod    def timestamp_to_str(timestamp=None, format='%Y-%m-%d %H:%M:%S'):        if timestamp:            time_tuple = time.localtime(timestamp)  # 把时间戳转换成时间元祖            result = time.strftime(format, time_tuple)  # 把时间元祖转换成格式化好的时间            return result        else:            return time.strptime(format)    # 计算N个月后的时间戳    @staticmethod    def calcMonthLater(addMonth, unix_timestamp=None):        if unix_timestamp:            now_year = time.localtime(unix_timestamp).tm_year            now_month = time.localtime(unix_timestamp).tm_mon            now_day = time.localtime(unix_timestamp).tm_mday            now_hour = time.localtime(unix_timestamp).tm_hour            now_min = time.localtime(unix_timestamp).tm_min            now_second = time.localtime(unix_timestamp).tm_sec        else:            now_year = datetime.datetime.now().year            now_month = datetime.datetime.now().month            now_day = datetime.datetime.now().day            now_hour = datetime.datetime.now().hour            now_min = datetime.datetime.now().minute            now_second = datetime.datetime.now().second        for add in range(addMonth):            if now_month == 12:                now_year += 1                now_month = 1            else:                now_month += 1        timestamps = 0        for is_format in range(4):            try:                date_format = '{now_year}-{now_month}-{now_day} {now_hour}:{now_min}:{now_second}' \                    .format(now_year=now_year, now_month=now_month, now_day=now_day, now_hour=now_hour,                            now_min=now_min, now_second=now_second)                timestamps = CommonService.str_to_timestamp(date_format)            except Exception as e:                if str(e) == 'day is out of range for month':                    now_day = now_day - 1        return timestamps    @staticmethod    def updateMac(mac: str):        macArray = mac.split(':')        macArray[0] = int(macArray[0], 16)        macArray[1] = int(macArray[1], 16)        macArray[2] = int(macArray[2], 16)        first = int(macArray[5], 16)        second = int(macArray[4], 16)        three = int(macArray[3], 16)        if first == 255 and second == 255 and three == 255:            return None        first += 1        if first / 256 == 1:            second += 1            first = first % 256        if second / 256 == 1:            three += 1            second = second % 256        macArray[3] = three        macArray[4] = second        macArray[5] = first        tmp = ':'.join(map(lambda x: "%02x" % x, macArray))        return tmp.upper()    @staticmethod    def encode_data_without_salt(content):        return base64.b64encode(str(content).encode("utf-8")).decode('utf8')    @staticmethod    def check_time_stamp_token(token, time_stamp):        # 时间戳token校验        if not all([token, time_stamp]):            return False        try:            token = int(CommonService.decode_data(token))            time_stamp = int(time_stamp)            now_time = int(time.time())            distance = now_time - time_stamp            if token != time_stamp or distance > 60000 or distance < -60000:  # 为了全球化时间控制在一天内                return False            return True        except Exception as e:            print(e)            return False    @staticmethod    def check_time_stamp_token_without_distance(time_stamp_token, time_stamp):        """        用于没有RTC设备的时间戳token校验        @param time_stamp: 时间戳        @param time_stamp_token: 时间戳token        @return: boolean True/False        """        if not all([time_stamp_token, time_stamp]):            return False        try:            token = CommonService.decode_data(time_stamp_token)            if token != time_stamp:                return False            return True        except Exception as e:            print(e)            return False    @staticmethod    def req_publish_mqtt_msg(identification_code, topic_name, msg, qos=1):        """        通用发布MQTT消息函数        @param identification_code: 标识码        @param topic_name: 主题名        @param msg: 消息内容        @param qos: mqtt qos等级        @return: boolean        """        if not all([identification_code, topic_name]):            return False        if identification_code.endswith('11L'):            thing_name = 'LC_' + identification_code        else:            thing_name = 'Ansjer_Device_' + identification_code        try:            # 获取数据组织将要请求的url            iot = iotdeviceInfoModel.objects.filter(                thing_name=thing_name).values(                'endpoint', 'token_iot_number')            if not iot.exists():                return False            endpoint = iot[0]['endpoint']            Token = iot[0]['token_iot_number']            # api doc: https://docs.aws.amazon.com/zh_cn/iot/latest/developerguide/http.html            # url: https://IoT_data_endpoint/topics/url_encoded_topic_name?qos=1            # post请求url发布MQTT消息            url = 'https://{}/topics/{}?qos={}'.format(endpoint, topic_name, qos)            authorizer_name = 'Ansjer_Iot_Auth'            signature = CommonService.rsa_sign(Token)  # Token签名            headers = {                'x-amz-customauthorizer-name': authorizer_name,                'Token': Token,                'x-amz-customauthorizer-signature': signature}            r = requests.post(url=url, headers=headers, json=msg, timeout=2)            if r.status_code == 200:                res = r.json()                if res['message'] == 'OK':                    return True                return False            else:                return False        except Exception as e:            return False    @staticmethod    def rsa_sign(Token):        # 私钥签名Token        if not Token:            return ''        private_key_file = '''-----BEGIN RSA PRIVATE KEY-----MIIEpQIBAAKCAQEA5iJzEDPqtGmFMggekVro6C0lrjuC2BjunGkrFNJWpDYzxCzEX5jf4/Fq7hcIaQd5sqHugDxPVollSLPe9zNilbrd0sZfU+Ed8gRVuKW9KwfE9XFrL0pt6bKRQ0IIRfiZ9TuR0tsQysvcO1GZSXcYfPue3tGM1zOnWFThWDqZ06+sOxztRMRl4yNfbpCG4MfxG3itNXOfrjZv2OMLSXrxmzubSvRpUYSvQPs4fm9302SAnySY0MKzx6H6528ZQm/IDDSZy6EmNBIyTRDfxC56vnYcXvqedAQh7jJnjdvt6Q4MhASHeIYi1FBSdu2NT6wgpnrqXzx5pq9kR/lnsLID0wIDAQABAoIBAQCiF4GT1/1oNSprouxk1PNXFPWFUsVGD8mAwVJmx//eiY7MjfuCmdqYYmI+cFqsH2fIOeYSzGfVO9Dq9EYHN1oovAWhf7eFDPpajFMUSyiCNmazub8VAAeKowtNpCTPo9pMsDh1m3aoYA4uebrN0+Sbo16y8kWRDgDAZoiR7DSMs8lczk16hwfv5mw8XpNDbaL3Coi4Koe2S1Yh2SX3vWFlpd7qF1ZYXuZIp+b8JPrV7n9eUKoFgzj0gqgwQK80CoexIjiOrNMPvkQaq+8kCvFjAzKxOK7e8gjM8lMRiGodb61kmYZkkJzFwWO4EaGbl34lfVECd1Ixp3tFbe0OWAGBAoGBAPSteXDzzToD8ovM7LL11x0jWwI6HOiHu89kZtW566rIezjWBuA2TxrcYKM3h9jQRXS3CsMdoIv6XGk5lqM8ADtjn23FBWe/THYLh8bm8JOgh5RRWQDgSvkLfi9Ih2mM4NJfmuuDOh3Nze2efLM7+kOZWUQwF2Zx9mL5jvRBk351AoGBAPDIsYmT2Li+i5+0vykA2m5uPF8ZOW8BGtAfCZv0suW7BNzSgin78g9WapRd/4p0NNiL/nVMqPPCpd1akCUpV+GDWQt0hV+HZjxANE0KWhciQRyo2qvo51j8SWILJSgh0tXCaTF8qt6oGw3VN3m57vKhbrlDaz0J/NDJFci6msAnAoGBAOuG6bXPGijUj+//DYKfn7jOxdZ49kboEePrtAncdHzri6IEdI3z+WXT6bpzw/LzWUimwldb96WHFNm9s8HiCh8hIODbnP5naUTgiIzw1XhmONyPCewL/F+LrqX5XVA/alNX8JrwsUrrR2WLAGLQQ3I69XDsEjptTU2tCO0bCs3ZAoGBAJ2lCHfm0JHET230zONvp5N9oREyVqQSuRdh+syc3TQDyh85w/bw+X6JOaaCFHj1tFPC9Iqf8k4GNspCLPXnp54CfR4+38O3xnvUHWoDSRC0YKT++IxtJGriYrlKSr2Hx54kdvLriIPW1D+uRW/xCDza7L9nIKMKEvgvb4/IfOEpAoGAeKM9Te7T1VzlAkS0CJOwanzwYV/zrex84WuXxlsGgPQ871lTs5APH1QLfLfFXH+UVrCEC2yv4eml/cqFkpB3gE5i4MQ8GPVIOSs5tsIyl8YUA03vdNdBGCqvlyw5dfxNA+EtxNE2wCW/LW7ENJlACgcfgPlBZtpLheWoZB/maw4=-----END RSA PRIVATE KEY-----'''        # 使用密钥文件方式        # private_key_file_path = os.path.join(BASE_DIR, 'static/iotCore/private.pem')#.replace('\\', '/')        # private_key_file = open(private_key_file_path, 'r')        private_key = ct.load_privatekey(ct.FILETYPE_PEM, private_key_file)        signature = ct.sign(private_key, Token.encode('utf8'), 'sha256')        signature = encodebytes(signature).decode('utf8').replace('\n', '')        # print('signature:', signature)        return signature    @staticmethod    def get_payment_status_url(lang, payment_status):        # 返回相应的支付状态url        if lang == 'cn':            file_name = 'success.html' if payment_status == 'success' else 'fail.html'        else:            file_name = 'en_success.html' if payment_status == 'success' else 'en_fail.html'        pay_failed_url = "{}web/paid2/{}".format(SERVER_DOMAIN_SSL, file_name)        return pay_failed_url    # 根据uid查询序列号,存在则返回序列号,否则返uid    @staticmethod    def query_serial_with_uid(uid):        device_info_qs = Device_Info.objects.filter(UID=uid).values('serial_number')        if device_info_qs.exists():            serial_number = device_info_qs[0]['serial_number']            if serial_number:                return serial_number        return uid    # 根据序列号查询uid,存在则返回uid,否则返回序列号    @staticmethod    def query_uid_with_serial(serial_number):        device_info_qs = Device_Info.objects.filter(serial_number=serial_number).values('UID')        if device_info_qs.exists():            uid = device_info_qs[0]['UID']            if uid:                return uid        return serial_number    @staticmethod    def get_full_serial_number(uid, serial_number, device_type):        """        根据uid查询返回完整序列号        @param uid: uid        @param serial_number: 序列号        @param device_type: 设备类型        @return: full_serial_number        """        p2p_type = str(UIDModel.objects.filter(uid=uid).values('p2p_type')[0]['p2p_type'])        # 设备类型转为16进制并补齐4位        device_type = hex(device_type)[2:]        device_type = (4 - len(device_type)) * '0' + device_type        full_serial_number = serial_number + p2p_type + device_type        return full_serial_number    # 根据企业标识返回物品名    @staticmethod    def get_thing_name(company_mark, thing_name_suffix):        if company_mark == '11A':            return 'Ansjer_Device_' + thing_name_suffix        elif company_mark == '11L':            return 'LC_' + thing_name_suffix        else:            return thing_name_suffix    @staticmethod    def confirm_region_id():        """        根据配置信息确定region_id        @return: region_id        """        region_id = 3        if CONFIG_INFO == CONFIG_US:  # 美洲            region_id = 3        elif CONFIG_INFO == CONFIG_EUR:  # 欧洲            region_id = 4        elif CONFIG_INFO == CONFIG_CN:  # 中国            region_id = 1        elif CONFIG_INFO == CONFIG_TEST:  # 测试            region_id = 5        return region_id    @staticmethod    def verify_token_get_user_id(request_dict, request):        """        认证token,获取user id        @param request_dict: 请求参数        @param request: 请求体        @return: token_obj.code, token_obj.userID, response        """        try:            token_obj = TokenObject(request.META.get('HTTP_AUTHORIZATION'))            lang = request_dict.get('lang', None)            response = ResponseObject(lang if lang else token_obj.lang)            return token_obj.code, token_obj.userID, response        except Exception as e:            print(e)            return 309, None, None    @staticmethod    def cutting_time(start_time, end_time, time_unit):        """        按时间单位切割时间段        @param start_time: 开始时间        @param end_time: 结束时间        @param time_unit: 时间单位        @return: time_list 切割后的时间列表        """        time_list = []        while True:            if time_unit == 'day':                temp_time = start_time + relativedelta(days=1)            elif time_unit == 'week':                temp_time = start_time + relativedelta(days=7)            elif time_unit == 'month':                temp_time = start_time + relativedelta(months=1)            elif time_unit == 'quarter':                temp_time = start_time + relativedelta(months=3)            elif time_unit == 'year':                temp_time = start_time + relativedelta(years=1)            else:                break            if temp_time < end_time:                time_tuple = (CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S')),                              CommonService.str_to_timestamp(temp_time.strftime('%Y-%m-%d %H:%M:%S')))                time_list.append(time_tuple)                start_time = temp_time            else:                time_tuple = (CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S')),                              CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S')))                if time_tuple not in time_list:                    time_list.append(time_tuple)                break        if not time_list:            time_tuple = (CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S')),                          CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S')))            time_list = [time_tuple]        return time_list    @staticmethod    def cutting_time_stamp(start_time, end_time):        """        按天切割时间段        @param start_time: 开始时间        @param end_time: 结束时间        @return: time_list 切割后的时间列表        """        time_list = []        while True:            mid_time = datetime.datetime(start_time.year, start_time.month, start_time.day)+relativedelta(days=1)            if mid_time < end_time:                time_tuple = (CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S')),                              CommonService.str_to_timestamp(mid_time.strftime('%Y-%m-%d %H:%M:%S')))                time_list.append(time_tuple)                start_time = mid_time            else:                time_tuple = (CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S')),                              CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S')))                if time_tuple not in time_list:                    time_list.append(time_tuple)                break        if not time_list:            time_tuple = (CommonService.str_to_timestamp(start_time.strftime('%Y-%m-%d %H:%M:%S')),                          CommonService.str_to_timestamp(end_time.strftime('%Y-%m-%d %H:%M:%S')))            time_list = [time_tuple]        return time_list    @staticmethod    def get_domain_name():        """        获取域名        @return: domain_name_list 域名列表        """        if CONFIG_INFO == CONFIG_TEST:            domain_name_list = [SERVER_DOMAIN_TEST[:-1]]        elif CONFIG_INFO == CONFIG_CN or CONFIG_INFO == CONFIG_US:            domain_name_list = [SERVER_DOMAIN_US[:-1], SERVER_DOMAIN_CN[:-1]]        else:            domain_name_list = []        return domain_name_list    @staticmethod    def get_orders_domain_name_list():        """        获取其他服务器域名列表        @return: orders_domain_name_list 其他服务器域名列表        """        orders_domain_name_list = SERVER_DOMAIN_LIST        if CONFIG_INFO == CONFIG_TEST:            orders_domain_name_list = [SERVER_DOMAIN_CN, SERVER_DOMAIN_US, SERVER_DOMAIN_EUR]        elif CONFIG_INFO == CONFIG_CN:            orders_domain_name_list = [SERVER_DOMAIN_TEST, SERVER_DOMAIN_US, SERVER_DOMAIN_EUR]        elif CONFIG_INFO == CONFIG_US:            orders_domain_name_list = [SERVER_DOMAIN_TEST, SERVER_DOMAIN_CN, SERVER_DOMAIN_EUR]        elif CONFIG_INFO == CONFIG_EUR:            orders_domain_name_list = [SERVER_DOMAIN_TEST, SERVER_DOMAIN_CN, SERVER_DOMAIN_US]        return orders_domain_name_list    @staticmethod    def list_sort(e):        """        列表排序        @param e: 列表元素        """        return sorted(e, key=lambda item: -item['count'])    @staticmethod    def Package_Type(order_type, content):        """        套餐类型        """        if order_type == 0:            content = content + '(' + '云存' + ')'            return content        elif order_type == 1:            content = content + '(' + 'AI' + ')'            return content        elif order_type == 2:            pass    @staticmethod    def negative_number_judgment(number_list):        """        判断正负数        @param number_list: float或int类型列表        """        if any(i < 0 for i in number_list):            return False        else:            return True
 |