ASJServer/Controller/UnicomCombo/UnicomComboController.py

# -*- encoding: utf-8 -*-
"""
@File    : UnicomComboController.py
@Time    : 2022/6/23 9:18
@Author  : stephen
@Email   : zhangdongming@asj6.wecom.work
@Software: PyCharm
"""
import datetime
import json
import logging
import time
import traceback
from decimal import Decimal

from django.db import transaction
from django.db.models import Q
from django.http import HttpResponse, JsonResponse
from django.views.generic.base import View

from Ansjer.config import LOGGER
from Model.models import UnicomDeviceInfo, UnicomCombo, Pay_Type, Order_Model, Store_Meal, AiStoreMeal, \
    UnicomComboOrderInfo, UnicomComboExperienceHistory, UnicomDeviceStatusChangePush, SysMsgModel, LogModel, \
    DeviceLiveRestrict, OrderPayLog
from Object.EIoTClubObject import EIoTClubObject
from Object.Enums.WXOperatorEnum import WXOperatorEnum
from Object.RedisObject import RedisObject
from Object.ResponseObject import ResponseObject
from Object.TelecomObject import TelecomObject
from Object.TokenObject import TokenObject
from Object.UnicomObject import UnicomObjeect
from Object.WXTechObject import WXTechObject
from Object.utils import LocalDateTimeUtil
from Object.utils.PayUtil import PayService
from Service.CommonService import CommonService
from Service.QuecCloudService import QuecCloudService

# 三大运营商ICCID前6位前缀字典（key：运营商名称，value：前缀集合）
OPERATOR_ICCID_PREFIX = {
    "中国移动": {'898600', '898602', '898604', '898607'},
    "中国联通": {'898601', '898606', '898609'},
    "中国电信": {'898603', '898611'}
}

# 单独提取各运营商前缀（按需使用，保持原代码兼容性）
CHINA_MOBILE_ICCID_PREFIX = OPERATOR_ICCID_PREFIX["中国移动"]  # 中国移动前缀集合
CHINA_UNICOM_ICCID_PREFIX = OPERATOR_ICCID_PREFIX["中国联通"]  # 中国联通前缀集合
CHINA_TELECOM_ICCID_PREFIX = OPERATOR_ICCID_PREFIX["中国电信"]  # 中国电信前缀集合


class UnicomComboView(View):
    def get(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.GET, request, operation)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.POST, request, operation)

    def validation(self, request_dict, request, operation):
        response = ResponseObject('cn')
        if operation == 'query-usage-history':
            return self.query_device_usage_history(request_dict, response)
        elif operation == 'sim-order':  # 用户套餐信息查询
            return self.create_experience_order(response)
        elif operation == 'test-notify':
            order_id = request_dict.get('orderId', None)
            activate_type = request_dict.get('activateType', 0)
            iccid = request_dict.get('iccid', None)
            combo_id = request_dict.get('comboId', None)
            self.create_combo_order_info(order_id, int(activate_type), iccid, int(combo_id))
            return HttpResponse('SUCCESS')
        elif operation == 'device-queue-monitoring':
            return self.device_queue_monitoring_push(request_dict, request)
        elif operation == 'device-status-change':  # SIM卡修改状态，异步通知接口
            return self.device_status_change_push(request_dict, request)
        elif operation == 'device-bind':  # 服务器保存设备的ICCID
            return self.iccid_bind_serial_no(request, request_dict, response)
        elif operation == 'device-status':  # PC调用解绑SIM卡用户,清除流量套餐数据
            return self.update_device_status(request, request_dict, response)
        elif operation == 'update-card':  # 更新SIM类型
            return self.update_device_card_type(request_dict, response)
        elif operation == 'xxx-sign':  # 获取签名用于测试
            return self.get_test_sign(request_dict, response)
        elif operation == 'getTimestamp':
            return self.get_test_sign(request_dict, response)
        elif operation == 'getSimBySerialNumber':
            return self.get_sim_by_serial_number(request_dict, response)
        else:
            token = TokenObject(request.META.get('HTTP_AUTHORIZATION'))
            lang = request_dict.get('lang', token.lang)
            response = ResponseObject(lang)
            if token.code != 0:
                return response.json(token.code)
            user_id = token.userID
            if operation == 'combo-save':  # 创建套餐
                return self.save_unicom_combo(request_dict, response)
            elif operation == 'combo-pay':  # 套餐支付
                return self.buy_unicom_combo(user_id, request_dict, request, response)
            elif operation == 'combo-list':  # 获取套餐列表
                return self.query_package_list(response)
            elif operation == 'get-device-info':  # 获取SIM卡信息
                return self.get_device_info(request_dict, response)
            elif operation == 'user-combo-query':  # 用户套餐信息查询
                return self.user_combo_query(user_id, request_dict, response)
            elif operation == 'getDeviceLiveRestrictList':
                return self.get_device_live_restrict_list(request_dict, response)
            elif operation == 'getDevice4GPackage':
                return self.get_device_4G_package(request_dict, response)
            else:
                return response.json(0)

    @classmethod
    def get_device_live_restrict_list(cls, request_dict, response):
        """
        获取直播限制表
        @return: 直播限制列表
        """
        live_restrict_qs = DeviceLiveRestrict.objects.filter(is_del=False)
        live_restrict_list = []
        if not live_restrict_qs.exists():
            return response.json(0, live_restrict_list)
        for item in live_restrict_qs:
            live_restrict_list.append({
                'deviceName': item.device_name,
                'deviceType': item.device_type,
                'deviceInfo': item.device_info,
                'createdTime': item.created_time
            })
        return response.json(0, live_restrict_list)

    @classmethod
    def user_combo_query(cls, user_id, request_dict, response):
        """
        查询套餐流量列表与正在使用流量详情
        @param user_id:
        @param request_dict:
        @param response:
        @return:
        """
        try:
            iccid = request_dict.get('iccid', None)
            if not iccid:
                return response.json(444)
            unicom_device_info_qs = UnicomDeviceInfo.objects.filter(iccid=iccid)
            if not unicom_device_info_qs.exists():
                return response.json(173)
            if not unicom_device_info_qs[0].user_id:  # 用户SIM卡未绑定用户则进行自动绑定
                serial_no = unicom_device_info_qs[0].serial_no
                cls.experience_order_4G(iccid, serial_no, user_id)  # 生成4G体验订单
            unicom_api = UnicomObjeect()
            card_type = unicom_device_info_qs[0].card_type

            # 查询正在生效套餐
            combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid, status=1, is_del=False) \
                .values('iccid', 'status', 'combo__status', 'combo__combo_name', 'combo__combo_type',
                        'combo__flow_total', 'combo__remark', 'combo__expiration_days', 'combo__expiration_type',
                        'year', 'month', 'flow_total_usage', 'expire_time', 'activation_time', 'combo__is_unlimited')

            if combo_order_qs.exists():
                combo_order = combo_order_qs.first()
                flow_details = {
                    'flowInvalid': 0,
                    'iccid': iccid,
                    'status': combo_order['status'],
                    'isUnlimited': combo_order['combo__is_unlimited'],
                    'comboName': combo_order['combo__combo_name'],
                    'comboType': combo_order['combo__combo_type'],
                    'flowTotal': combo_order['combo__flow_total'],
                    'comboRemark': combo_order['combo__remark'],
                    'expirationDays': combo_order['combo__expiration_days'],
                    'expirationType': combo_order['combo__expiration_type'],
                    'flowTotalUsage': combo_order['flow_total_usage'],
                    'activationTime': combo_order['activation_time'],
                    'expireTime': -1 if combo_order['combo__remark'] == 'LIFETIME_FREE' else combo_order['expire_time'],
                    'year': combo_order['year'],
                    'month': combo_order['month'],
                }
                activate_flow = float(flow_details['flowTotalUsage'])
                # 获取卡号历史总流量
                flow_total_usage = float(unicom_api.get_flow_usage_total(iccid, card_type))
                flow = 0 if flow_total_usage <= 0 else flow_total_usage - activate_flow
                # 因APP问题，usableFlow可用流量替换为，已用流量值
                flow_details['usableFlow'] = 0 if flow == 0 else flow
                flow_details['usableFlow'] = flow_details['flowTotal'] \
                    if flow_details['usableFlow'] > flow_details['flowTotal'] \
                    else flow_details['usableFlow']
                flow_details['usableFlow'] = Decimal(flow_details['usableFlow']).quantize(Decimal('0.00'))
                flow_details.pop('flowTotalUsage')

                cls.update_combo_order_sort(iccid)  # 排序

                flow_details['comboList'] = cls.get_combo_order_list(iccid)  # 获取当前上架套餐
                return response.json(0, flow_details)
            else:
                flow_details = {'iccid': iccid, 'flowInvalid': 1, 'comboList': cls.get_combo_order_list(iccid)}
                cls.update_combo_order_sort(iccid)
                return response.json(0, flow_details)
        except Exception as e:
            logging.info('异常错误,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(177, e)

    @classmethod
    def experience_order_4G(cls, icc_id, serial_no, user_id, is_user=True):
        """
        保存订单信息
        @param is_user: 是否真实用户
        @param icc_id: SIM卡20位iccid
        @param serial_no: 序列号
        @param user_id: userID
        @return: True | False
        """
        try:
            while transaction.atomic():
                n_time = int(time.time())
                # 获取套餐信息
                combo_info_qs = UnicomCombo.objects.filter(combo_type=1, status=0, is_del=False) \
                    .values('id', 'combo_name', 'price', 'virtual_price', 'remark').order_by('sort')
                if not combo_info_qs.exists():
                    return False
                combo_info_vo = combo_info_qs[0]
                # 获取套餐订单信息
                combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=icc_id, combo_id=combo_info_vo['id'])
                if not combo_order_qs.exists():
                    return False
                c_time = combo_order_qs[0].created_time
                # 根据序列号获取UID
                uid = CommonService.get_uid_by_serial_number(serial_no)
                order_id = CommonService.createOrderID()
                rank_id, ai_rank_id = cls.get_cloud_or_ai_combo()  # 生成订单必须添加该字段
                order_dict = {'orderID': order_id, 'UID': uid, 'rank_id': rank_id, 'ai_rank_id': ai_rank_id,
                              'userID_id': user_id, 'desc': combo_info_vo['combo_name'], 'payType': 10,
                              'payTime': c_time, 'price': combo_info_vo['price'], 'addTime': c_time,
                              'updTime': c_time, 'status': 1,
                              'unify_combo_id': str(combo_info_vo['id']), 'order_type': 2,
                              'store_meal_name': combo_info_vo['combo_name']
                              }
                order_qs = Order_Model.objects.filter(UID=uid, userID=user_id, order_type=2,
                                                      unify_combo_id=str(combo_info_vo['id']))
                if not order_qs.exists():
                    Order_Model.objects.create(**order_dict)
                    combo_order_qs.update(order_id=order_id)
                if is_user:
                    UnicomDeviceInfo.objects.filter(iccid=icc_id).update(user_id=user_id, updated_time=n_time)
                return True
        except Exception as e:
            print('生成4G体验订单异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            logging.info('生成4G体验订单异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def get_combo_order_list(cls, iccid):
        """
        查询套餐列表
        @param iccid:
        @return:
        """
        combo_list = []
        now_time = int(time.time())
        before_days = LocalDateTimeUtil.get_before_days_timestamp(now_time, 90)
        combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid, is_del=False, created_time__gt=before_days) \
            .values('iccid', 'status', 'combo__combo_name', 'combo__flow_total',
                    'combo__remark', 'combo__expiration_days', 'combo__expiration_type', 'flow_total_usage',
                    'expire_time', 'combo__is_unlimited').order_by('-expire_time')
        for item in combo_order_qs:
            combo_list.append({
                'iccid': iccid,
                'status': item['status'],
                'comboName': item['combo__combo_name'],
                'isUnlimited': item['combo__is_unlimited'],
                'flowTotal': item['combo__flow_total'],
                'comboRemark': item['combo__remark'],
                'expirationDays': 0,
                'expirationType': item['combo__expiration_type'],
                'expireTime': -1 if item['combo__remark'] == 'LIFETIME_FREE' else item['expire_time']
            })
        return combo_list

    @classmethod
    def update_combo_order_sort(cls, iccd):
        """
        修改套餐排序
        @param iccd: 联通20位ICCID
        @return:
        """
        combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccd, is_del=False)
        if combo_order_qs.exists():
            unused_qs = combo_order_qs.filter(status=0)
            if unused_qs.exists():
                unused_qs.update(sort=50)
            used_qs = combo_order_qs.filter(status=1)
            if used_qs.exists():
                used_qs.update(sort=1)
            expire_qs = combo_order_qs.filter(status=2)
            if expire_qs.exists():
                expire_qs.update(sort=100)

    @classmethod
    def update_device_status(cls, request, request_dict, response):
        """
        重置SIM卡绑定状态修改为测试完成，以及重置流量，删除订单信息、删除系统消息
        """
        logger = logging.getLogger('info')
        serial_no = request_dict.get('serialNo', None)
        time_stamp = request_dict.get('timeStamp', None)
        sign = request_dict.get('sign', None)
        if not all([serial_no, sign, time_stamp]):
            return response.json(444)
        logger.info('PC工具进入重置SIM卡{}'.format(serial_no))
        try:
            return response.json(10072)
        except Exception as e:
            print(e.args)
            ex = traceback.format_exc()
            print(ex)
            logger.info('PC工具重置异常ICCID{}，msg={}'.format(serial_no, ex))
            return response.json(177, ex)

    @staticmethod
    def reset_telecom_user(serial_no):
        """
        重置电信用户 消息记录
        @param serial_no:
        @return:
        """
        sys_msg_qs = SysMsgModel.objects.filter(uid=serial_no)
        if sys_msg_qs.exists():
            sys_msg_qs.delete()
        return True

    @classmethod
    def update_device_card_type(cls, request_dict, response):
        """
        修改设备卡类型(0:内置卡，1：外插卡)
        """
        serial_no = request_dict.get('serialNo', None)
        time_stamp = request_dict.get('timeStamp', None)
        sign = request_dict.get('sign', None)
        main_card = request_dict.get('type', None)
        if not all([serial_no, main_card, sign, time_stamp]):
            return response.json(444)
        try:
            if not CommonService.check_time_stamp_token(sign, time_stamp):
                return response.json(13)
            now_time = int(time.time())
            with transaction.atomic():
                unicom_device_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no)
                if not unicom_device_qs.exists():
                    return response.json(173)
                unicom_device_qs.update(main_card=int(main_card), updated_time=now_time)
                return response.json(0)
        except Exception as e:
            print(e.args)
            ex = traceback.format_exc()
            print(ex)
            return response.json(177, ex)

    @classmethod
    def get_device_info(cls, request_dict, response):
        """
        获取设备信息
        @param request_dict:
        @param response:
        @return:
        """
        iccid = request_dict.get('iccid', None)
        if not iccid:
            return response.json(444)
        unicom_device_info_qs = UnicomDeviceInfo.objects.filter(iccid=iccid).values()
        if not unicom_device_info_qs.exists():
            return response.json(173)
        return response.json(0, dict(unicom_device_info_qs.first()))

    @classmethod
    def iccid_bind_serial_no(cls, request, request_dict, response):
        """
        iccid绑定设备序列号
        """
        iccid = request_dict.get('iccid', None)
        serial_no = request_dict.get('serialNo', None)
        time_stamp = request_dict.get('timeStamp', None)
        sign = request_dict.get('sign', None)
        sim = int(request_dict.get('sim', 1))
        logger = logging.getLogger('info')
        logger.info('--->设备调用4G注册接口{}'.format(request_dict))
        logger.info('iccid:{},serial_no:{}'.format(iccid, serial_no))
        if not all([iccid, serial_no, sign, time_stamp]):
            return response.json(444)
            # 时间戳token校验
        if not CommonService.check_time_stamp_token(sign, time_stamp):
            return response.json(13)
        n_time = int(time.time())
        try:
            ip = CommonService.get_ip_address(request)
            logger.info('--->参数验证通过，sign验证通过{}:{}'.format(serial_no, ip))
            # 待完善代码 根据uid与用户id验证系统设备mdcmd
            unicom_device_qs = UnicomDeviceInfo.objects.filter(iccid=iccid)
            if unicom_device_qs.exists():
                if unicom_device_qs.first().serial_no != serial_no:
                    unicom_device_qs.update(main_card=sim, updated_time=n_time, serial_no=serial_no)
                    cls.create_operation_log('unicom/api/device-bind',
                                             ip, request_dict, '4G序列号{}新绑定{}'.format(serial_no, iccid))
                elif unicom_device_qs.first().main_card != sim:
                    unicom_device_qs.update(main_card=sim, updated_time=n_time)
                return response.json(0)
            params = {'iccid': iccid, 'serial_no': serial_no, 'updated_time': n_time,
                      'created_time': n_time, 'main_card': sim}
            if sim == 0:  # 1：贴片卡，0：拔插卡
                if cls.is_dingxin_iot(iccid):  # 鼎芯物联卡
                    params['card_type'] = 5
                    params['status'] = 2
                    UnicomDeviceInfo.objects.create(**params)
                    cls.create_operation_log('unicom/api/device-bind',
                                             ip, request_dict, '4G序列号{}新绑定鼎芯{}'.format(serial_no, iccid))
                    return response.json(0)
                logger.error("{}外置卡或判断鼎芯国际卡异常".format(serial_no))
                return response.json(0, '外置卡不保存相关信息{}'.format(serial_no))

            if cls.is_unicom_sim(iccid):  # 联通卡
                UnicomDeviceInfo.objects.create(**params)
                result = cls.activate_test_flow_package(serial_no)
                cls.create_operation_log('unicom/api/device-bind',
                                         ip, request_dict,
                                         '4G序列号{}绑定{},testFlowPackage{}'.format(serial_no, iccid, result))
                return response.json(0)
            elif (len(iccid) >= 6 and iccid[:6] in CHINA_TELECOM_ICCID_PREFIX
                  and QuecCloudService.is_quec_cloud_sim(iccid)):  # 移远电信
                params['card_type'] = 6
                params['status'] = 2
                params['iccid'] = iccid[0:19]
                UnicomDeviceInfo.objects.create(**params)
                result = cls.activate_test_flow_package(serial_no)
                cls.create_operation_log('unicom/api/device-bind',
                                         ip, request_dict,
                                         f"移远电信4G序列号{serial_no}绑定{iccid},testFlowPackage{result}")
                return response.json(0)
            elif cls.is_telecom_sim(iccid):  # 鼎芯电信
                params['card_type'] = 3
                params['status'] = 2
                access_number = cls.get_access_number(iccid)
                if access_number:
                    params['access_number'] = access_number
                UnicomDeviceInfo.objects.create(**params)

                result = cls.activate_test_flow_package(serial_no)  # 激活测试流量套餐
                cls.create_operation_log('unicom/api/device-bind',
                                         ip, request_dict,
                                         '4G序列号{}绑定{},testFlowPackage{}'.format(serial_no, iccid, result))
                return response.json(0)
            elif cls.is_dingxin_iot(iccid):  # 鼎芯物联卡
                params['card_type'] = 5  # 国际
                params['status'] = 2
                UnicomDeviceInfo.objects.create(**params)
                return response.json(0)
            elif cls.check_iccid(iccid):  # 五兴物联卡
                params['card_type'] = 1
                params['status'] = 2
                UnicomDeviceInfo.objects.create(**params)
                return response.json(0)
            else:
                logger.info('--->设备请求绑定{}验证失败'.format(iccid))
                return response.json(173)
        except Exception as e:
            LOGGER.info('*****UnicomComboView.iccid_bind_serial_no:serial_number:{}, errLine:{}, errMsg:{}'
                        .format(serial_no, e.__traceback__.tb_lineno, repr(e)))
            return response.json(177, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    @classmethod
    def get_access_number(cls, iccid):
        """
        根据19位数ICCID查询接入号码
        @param iccid: 20位ICCID
        @return: 11位接入号码
        """
        telecom = TelecomObject()
        result = telecom.get_telephone(iccid[0:19])
        if not result:
            return None
        if result['RESULT'] == '0':
            return result['SMSG']
        return None

    @classmethod
    def is_telecom_sim(cls, iccid):
        """
        判断是否电信SIM卡
        @param iccid: iccid
        @return: 是否鼎芯电信卡
        """
        try:
            telecom = TelecomObject()
            result = telecom.query_card_main_status(iccid[0:19])
            return result['resultCode'] == '0'
        except Exception as e:
            LOGGER.info('*****UnicomComboView.is_telecom_sim*****error_line:{}, error_msg:{}'
                        .format(e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def is_unicom_sim(cls, iccid):
        """
        判断是否联通SIM卡
        @param iccid: iccid
        @return: 是否联通卡结果
        """
        result = UnicomObjeect().verify_device(iccid=iccid)
        if result.status_code == 200 and result.text:
            res_dict = json.loads(result.text)
            if res_dict['success'] and res_dict['data']['status'] != 0:
                return True
        return False

    @classmethod
    def is_dingxin_iot(cls, iccid):
        """
        根据iccid判断是否鼎芯国际卡
        """
        try:
            dx_iot = EIoTClubObject()
            params = {'iccid': iccid[0:19]}
            result = dx_iot.get_cards_info('v3', **params)
            if result['code'] == '900911' and len(iccid) == 20:
                params = {'iccid': iccid}
                result = dx_iot.get_cards_info('v3', **params)
            assert result['code'] == '200'
            return True
        except Exception as e:
            LOGGER.error("{}iccid判断是否鼎芯国际卡异常{}".format(iccid, repr(e)))
            return False

    @classmethod
    def check_iccid(cls, iccid):
        """
        检查ICCID是否是五兴科技卡
        @return: True or False
        """
        if not iccid:
            return False
        iccid = iccid[0:6]
        arr_list = ['898603', '898611']
        if iccid in arr_list:
            return True
        return False

    @classmethod
    def user_activate_flow(cls, iccid):
        """
        用户激活初始化流量套餐
        @param iccid:
        @return:
        """
        logger = logging.getLogger('info')
        try:
            while transaction.atomic():
                now_time = int(time.time())
                unicom_device_info_qs = UnicomDeviceInfo.objects.filter(iccid=iccid)
                if not unicom_device_info_qs.exists():
                    return False
                unicom_device_info_qs = unicom_device_info_qs.first()
                if unicom_device_info_qs.status != 1:
                    logger.info('---->用户激活iccid={}，业务系统状态为{}'.format(iccid, unicom_device_info_qs.status))
                    return False
                # 联通业务逻辑
                unicom_api = UnicomObjeect()
                unicom_api.change_device_to_activate(iccid)
                # 查看是否体验过免费套餐
                experience_history_qs = UnicomComboExperienceHistory.objects.filter(iccid=iccid)
                if not experience_history_qs.exists():
                    logger.info('---->用户首次激活iccid={}'.format(iccid))
                    combo_qs = UnicomCombo.objects.filter(combo_type=1, status=0, is_del=False) \
                        .values('id', 'expiration_type', 'expiration_days', 'combo_type')
                    if combo_qs.exists():
                        combo_qs = combo_qs.first()
                        # 保存体验记录
                        experience_history_vo = {'iccid': iccid, 'experience_type': 0, 'do_time': now_time}
                        UnicomComboExperienceHistory.objects.create(**experience_history_vo)
                        # 保存套餐激活信息
                        cls.create_combo_order_info('', 0, iccid, combo_qs['id'])
                # 修改业务联通卡设备激活信息
                UnicomDeviceInfo.objects.filter(iccid=iccid).update(status=2, updated_time=now_time,
                                                                    created_time=now_time)
                return True
        except Exception as e:
            print(e)
            ex = traceback.format_exc()
            logger.info('--->用户首次激活异常:{}'.format(ex))
            return False

    @classmethod
    def save_unicom_combo(cls, request_dict, response):
        """
        联通套餐保存
        @param request_dict:
        @param response:
        @return:
        """
        combo_id = request_dict.get('id', None)
        combo_name = request_dict.get('comboName', None)
        flow_total = request_dict.get('flowTotal', None)
        expiration_days = request_dict.get('expirationDays', None)
        expiration_type = request_dict.get('expirationType', None)
        price = request_dict.get('price', None)
        remark = request_dict.get('remark', None)
        pay_type = request_dict.get('payType', '').split(',')
        if not all([pay_type, combo_name, flow_total, expiration_days, expiration_type, price]):
            return response.json(444)
        try:
            flow_total = int(flow_total)
            expiration_days = int(expiration_days)
            expiration_type = int(expiration_type)
            with transaction.atomic():
                re_data = {
                    'combo_name': combo_name,
                    'flow_total': flow_total,
                    'expiration_days': expiration_days,
                    'expiration_type': expiration_type,
                    'price': price,
                }
                if remark:
                    re_data['remark'] = remark
                if combo_id:
                    UnicomCombo.objects.filter(id=combo_id).update(**re_data)
                    UnicomCombo.objects.get(id=combo_id).pay_type.set(pay_type)
                    return response.json(0)
                UnicomCombo.objects.create(**re_data).pay_type.set(pay_type)
                return response.json(0)
        except Exception as e:
            print(e)
            return response.json(177, repr(e))

    @classmethod
    def query_package_list(cls, response):
        """
        查询套餐列表
        @return:
        """
        try:
            combo_qs = UnicomCombo.objects.filter(is_show=1, status=0, is_del=False) \
                .order_by('sort').values('id', 'combo_name',
                                         'flow_total',
                                         'expiration_days',
                                         'expiration_type', 'price',
                                         'remark', 'virtual_price')
            if not combo_qs.exists():
                return response.json(0, [])
            combo_list = []
            for item in combo_qs:
                # 获取支付方式列表
                pay_type_qs = Pay_Type.objects.filter(unicomcombo=item['id']).values('id', 'payment')
                combo_list.append({
                    'id': item['id'],
                    'comboName': item['combo_name'],
                    'flowTotal': item['flow_total'],
                    'expirationDays': item['expiration_days'],
                    'expirationType': item['expiration_type'],
                    'price': item['price'],
                    'virtualPrice': item['virtual_price'] if item['virtual_price'] else '',
                    'remark': item['remark'],
                    'payTypes': list(pay_type_qs),
                })
            return response.json(0, combo_list)
        except Exception as e:
            print(e)
            return response.json(177, repr(e))

    @classmethod
    def buy_unicom_combo(cls, user_id, request_dict, request, response):
        """
        购买联通套餐
        @return:
        """
        logger = logging.getLogger('info')
        try:
            with transaction.atomic():
                iccid = request_dict.get('iccid', None)
                combo_id = request_dict.get('id', None)
                pay_type = request_dict.get('payType', None)
                activate_type = request_dict.get('activateType', 0)
                if not all([iccid, combo_id, pay_type]):
                    return response.json(444)
                combo_id = int(combo_id)
                pay_type = int(pay_type)
                now_time = int(time.time())
                unicom_combo_qs = UnicomCombo.objects.filter(id=combo_id, pay_type=pay_type, is_show=1, is_del=False,
                                                             status=0) \
                    .values('id', 'combo_name', 'price', 'remark')
                if not unicom_combo_qs.exists():
                    return response.json(173)
                unicom_device_qs = UnicomDeviceInfo.objects.filter(iccid=iccid) \
                    .values('serial_no', 'card_type')
                if not unicom_device_qs.exists():
                    return response.json(173)
                unicom_combo_qs = unicom_combo_qs.first()
                price = unicom_combo_qs['price']
                if not price:
                    return response.json(173)
                unicom_device_qs = unicom_device_qs.first()
                device_uid = CommonService.get_uid_by_serial_number(unicom_device_qs['serial_no'])
                order_id = CommonService.createOrderID()
                rank_id, ai_rank_id = cls.get_cloud_or_ai_combo()

                CARD_TO_ORDER_TYPE = {
                    0: 2,
                    6: 6
                }
                # 从字典获取，默认返回5（处理其他所有情况）
                order_type = CARD_TO_ORDER_TYPE.get(unicom_device_qs['card_type'], 5)
                order_dict = {'rank_id': rank_id, 'ai_rank_id': ai_rank_id, 'orderID': order_id, 'UID': device_uid,
                              'userID_id': user_id, 'desc': unicom_combo_qs['combo_name'], 'payType': pay_type,
                              'payTime': now_time, 'price': price, 'currency': 'CNY', 'addTime': now_time,
                              'updTime': now_time,
                              'unify_combo_id': str(unicom_combo_qs['id']), 'order_type': order_type,
                              'store_meal_name': unicom_combo_qs['combo_name']
                              }

                params = 'lang=cn' + '&activateType=' + activate_type
                logger.info('激活类型：{}'.format(activate_type))
                serial_number = unicom_device_qs['serial_no']

                result = {'result_code': 0, 'reason': 'success', 'error_code': 0}
                if pay_type == 2:  # 支付宝
                    pay_price = PayService.get_two_float(price, 2)
                    notify_url = 'unicom/wap/pay/ali-notify'

                    order_dict['pay_url'] = PayService.create_alipay_payment(params, order_id, pay_price,
                                                                             unicom_combo_qs['combo_name'],
                                                                             notify_url,
                                                                             unicom_combo_qs['remark'], response)
                    res_data = {'redirectUrl': order_dict['pay_url'], 'orderID': order_id}
                    cls.create_order_pay_log(order_id, f'{serial_number}购买联通4G套餐', notify_url, 'aliPay',
                                             'SUCCESS')
                elif pay_type == 3:  # 微信支付
                    notify_url = 'unicom/wap/pay/wechat-notify'
                    ip = CommonService.get_ip_address(request)
                    params = 'activateType=' + activate_type
                    product_name = unicom_combo_qs['combo_name'] + unicom_combo_qs['remark']
                    sign_params = PayService.create_wechat_payment(params, order_id,
                                                                   price, ip,
                                                                   notify_url,
                                                                   product_name,
                                                                   response)
                    result['result'] = sign_params
                    cls.create_order_pay_log(order_id, f'{serial_number}购买联通4G套餐', notify_url, 'wechatPay',
                                             'SUCCESS')
                else:
                    return response.json(444, {'param': 'pay_type'})

                Order_Model.objects.create(**order_dict)
                if pay_type == 3:
                    return JsonResponse(status=200, data=result)
                return response.json(0, res_data)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    @staticmethod
    def get_cloud_or_ai_combo():
        """
        获取云存或者AI套餐id
        @return:
        """
        rank_id = Store_Meal.objects.all().order_by('sort').values('id')[0]['id']
        ai_rank_id = AiStoreMeal.objects.all().values('id')[0]['id']
        return rank_id, ai_rank_id

    @classmethod
    def query_device_usage_history(cls, request_dict, response):
        """
        查询实时已用总流量API
        @return:
        """
        iccid = request_dict.get('iccid', None)
        if not iccid:
            return response.json(444)
        sim_card_qs = UnicomDeviceInfo.objects.filter(iccid=iccid).values('card_type')
        card_type = 0
        if sim_card_qs.exists():
            card_type = sim_card_qs[0]['card_type']
        unicom_api = UnicomObjeect()
        flow = unicom_api.get_flow_usage_total(iccid, card_type)
        return response.json(0, flow)

    @staticmethod
    def package_callback_notify(request_dict, request):
        """
        异步套餐订购回调
        @param request_dict:
        @param request:
        @return:
        """
        logger = logging.getLogger('info')
        try:
            logger.info('联通异步套餐订购回调参数{}'.format(request_dict))
            body = request.body.decode("utf-8")
            if body:
                dict_data = json.loads(body)
                sign = dict_data['sign']
                logger.info('设备订购异步回调请求参数{}'.format(dict_data))
                dict_data.pop('sign')
                unicom_obj = UnicomObjeect()
                generate_sign = unicom_obj.createSign(**dict_data)
                logger.info('设备订购请求签名{}'.format(sign))
                logger.info('设备订购生成签名{}'.format(generate_sign))
            r_data = {'success': True, 'msg': '成功'}
            return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
        except Exception as e:
            print(repr(e))
            r_data = {'success': False, 'msg': '失败'}
            return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")

    @staticmethod
    def device_queue_monitoring_push(request_dict, request):
        """
        设备套餐队列用完或者到期推送
        @param request_dict:
        @param request:
        @return:
        """
        logger = logging.getLogger('info')
        try:
            logger.info('设备套餐队列推送{}'.format(request_dict))
            body = request.body.decode("utf-8")
            if body:
                dict_data = json.loads(body)
                sign = dict_data['sign']
                logger.info('设备套餐队列回调请求参数{}'.format(dict_data))
                dict_data.pop('sign')
                unicom_obj = UnicomObjeect()
                generate_sign = unicom_obj.createSign(**dict_data)
                logger.info('设备套餐队列请求签名{}'.format(sign))
                logger.info('设备套餐队列生成签名{}'.format(generate_sign))
            r_data = {'success': True, 'msg': '成功'}
            return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
        except Exception as e:
            print(repr(e))
            r_data = {'success': False, 'msg': '失败'}
            return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")

    @staticmethod
    def device_status_change_push(request_dict, request):
        """
        设备状态变更推送执行场景说明
        @param request_dict:
        @param request:
        @return:
        """
        logger = logging.getLogger('info')
        try:
            logger.info('设备状态变更推送{}'.format(request_dict))
            body = request.body.decode("utf-8")
            if body:
                dict_data = json.loads(body)
                sign = dict_data['sign']
                logger.info('设备状态变更推送请求参数{}'.format(dict_data))
                dict_data.pop('sign')
                unicom_obj = UnicomObjeect()
                generate_sign = unicom_obj.createSign(**dict_data)
                logger.info('联通设备状态变更推送请求签名{}'.format(sign))
                logger.info('联通设备状态变更推送生成签名{}'.format(generate_sign))
                # assert generate_sign == sign
                now_time = int(time.time())
                re_data = {
                    'iccid': dict_data['iccid'],
                    'sign': sign,
                    'type': dict_data['status'],
                    'time': dict_data['time'],
                    'serial_no': dict_data['operationId'],
                    'updated_time': now_time,
                    'created_time': now_time
                }
                UnicomDeviceStatusChangePush.objects.create(**re_data)
            r_data = {'success': True, 'msg': '成功'}
            return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")
        except Exception as e:
            logger.info('异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            r_data = {'success': False, 'msg': '失败'}
            return HttpResponse(json.dumps(r_data, ensure_ascii=False), content_type="application/json,charset=utf-8")

    @classmethod
    def create_combo_order_info(cls, order_id, activate_type, iccid, combo_id):
        """
        创建套餐生效记录
        @param order_id: 订单id
        @param activate_type: 激活类型
        @param iccid: 联通20位iccid
        @param combo_id: 套餐id
        @return: True Or False
        """
        logger = logging.getLogger('info')
        logger.info('创建联通订单套餐信息，订单id{}'.format(order_id))
        try:
            today = datetime.datetime.today()
            year = today.year
            month = today.month
            with transaction.atomic():
                unicom_combo_qs = UnicomCombo.objects.filter(id=int(combo_id)).values()
                if unicom_combo_qs.exists():
                    unicom_combo = unicom_combo_qs.first()
                    now_time = int(time.time())
                    combo_order_qs = UnicomComboOrderInfo.objects.filter(status=1, iccid=iccid)
                    status = 0
                    if not combo_order_qs.exists():
                        status = 1
                    combo_order_data = {'iccid': iccid, 'status': status, 'combo_id': int(combo_id),
                                        'updated_time': now_time,
                                        'created_time': now_time,
                                        'year': year, 'month': month}
                    if order_id:
                        combo_order_data['order_id'] = order_id
                    # 有效期类型 1 等于自然月，0天数
                    if unicom_combo['expiration_type'] == 1:
                        # 激活类型 1=下月激活 否则等于当月激活
                        if activate_type == 1:
                            combo_order_data['next_month_activate'] = True
                            next_start_time, end_time = cls.get_next_month_data_time()
                            combo_order_data['activation_time'] = next_start_time
                            combo_order_data['expire_time'] = end_time
                            combo_order_data['status'] = 0
                        else:
                            start_time, month_end_time = cls.get_month_start_and_end_time()
                            combo_order_data['activation_time'] = now_time
                            combo_order_data['expire_time'] = month_end_time

                    elif unicom_combo['expiration_type'] == 0:
                        days = unicom_combo['expiration_days']
                        if activate_type == 1:
                            combo_order_data['next_month_activate'] = True
                            start_time, end_time = cls.get_times(days)
                            combo_order_data['activation_time'] = start_time
                            combo_order_data['expire_time'] = end_time
                            combo_order_data['status'] = 0
                        else:
                            zero_today, end_time = cls.get_data_time(days)
                            combo_order_data['activation_time'] = now_time
                            combo_order_data['expire_time'] = end_time
                        logger.info('激活类型{}'.format(activate_type))
                    # 调用联通API查询物联卡是否已激活，未激活则修改为激活状态
                    unicom_api = UnicomObjeect()
                    if status == 1:  # 激活当前使用的套餐，检查卡商网络状态是否为激活
                        card_info = UnicomDeviceInfo.objects.filter(iccid=iccid).values('card_type', 'access_number')
                        if card_info[0]['card_type'] == 3:
                            reason = '激活' + unicom_combo['combo_name']
                            unicom_api.change_device_to_activate(iccid, 3, card_info[0]['access_number'], reason)
                        elif card_info[0]['card_type'] == 6:  # 判断移远卡状态
                            QuecCloudService.resume_card(iccid=iccid)
                        else:
                            unicom_api.change_device_to_activate(iccid)
                        flow_total_usage = unicom_api.get_flow_usage_total(iccid, card_info[0]['card_type'])  # 获取套餐总流量
                        if flow_total_usage > 0:
                            flow_total_usage = Decimal(flow_total_usage)
                            flow_total_usage = flow_total_usage.quantize(Decimal('0.00'))
                        else:
                            flow_total_usage = 0
                        combo_order_data['flow_total_usage'] = str(flow_total_usage)
                    UnicomComboOrderInfo.objects.create(**combo_order_data)
                    logger.info('保存套餐支付信息success')
                return True
        except Exception as e:
            error_msg = f"{iccid}创建4G订单套餐记录失败: {str(e)}"
            LOGGER.error(f"{error_msg} 行号: {e.__traceback__.tb_lineno}")
            return False

    @staticmethod
    def get_next_month_data_time():
        """
        获取下个月开始时间与结束时间戳
        @return: next_start_time,end_time
        """
        next_month_start = LocalDateTimeUtil.get_next_month_start()
        next_start_time, next_end_time = LocalDateTimeUtil.get_start_and_end_time(next_month_start, '%Y-%m-%d')
        next_month_end = LocalDateTimeUtil.get_next_month_end()
        start_time, end_time = LocalDateTimeUtil.get_start_and_end_time(next_month_end, '%Y-%m-%d')
        return next_start_time, end_time

    @staticmethod
    def get_data_time(days):
        """
        获取今天开始时间以及days后日期结束时间戳
        @return: next_start_time,end_time
        """
        zero_today, last_today = LocalDateTimeUtil.get_today_date(True)
        now_time = int(time.time())
        after_time = LocalDateTimeUtil.get_after_days_timestamp(now_time, days)
        time_array = time.localtime(after_time)
        start_time, end_time = LocalDateTimeUtil.get_start_and_end_time(time.strftime("%Y-%m-%d", time_array),
                                                                        '%Y-%m-%d')
        return zero_today, end_time

    @staticmethod
    def get_times(days_after):
        """
        获取下月开始时间与指定天数后结束时间
        @return:
        """
        next_start_time, end_time = UnicomComboView.get_next_month_data_time()
        after_time = LocalDateTimeUtil.get_after_days_timestamp(next_start_time, days_after)
        time_array = time.localtime(after_time)
        start_time, end_time = LocalDateTimeUtil.get_start_and_end_time(time.strftime("%Y-%m-%d", time_array),
                                                                        '%Y-%m-%d')
        return next_start_time, end_time

    @staticmethod
    def get_month_start_and_end_time():
        """
        获取当天开始时间与当月结束时间戳
        @return:
        """
        zero_today, last_today = LocalDateTimeUtil.get_today_date(True)
        month_end = LocalDateTimeUtil.get_cur_month_end()
        start_time, month_end_time = LocalDateTimeUtil.get_start_and_end_time(month_end, '%Y-%m-%d')
        return zero_today, month_end_time

    @classmethod
    def get_test_sign(cls, request_dict, response):
        """
        测试盐加密解密
        @param request_dict:
        @param response:
        @return:
        """
        verify = request_dict.get('verify', False)
        if verify:
            sign = request_dict.get('sign')
            time_stamp = request_dict.get('timeStamp')
            sign = CommonService.check_time_stamp_token(sign, time_stamp)
            if not sign:
                return response.json(13)
            return response.json(0)
        now_time = int(time.time())
        sign = CommonService.encode_data(str(now_time))
        return response.json(0, {'sign': sign, 'timeStamp': now_time})

    @classmethod
    def create_experience_order(cls, response):
        """
        创建体验订单
        """
        u_order_qs = UnicomComboOrderInfo.objects.filter(Q(order_id__isnull=True) | Q(order_id=''))
        u_order_qs = u_order_qs.filter(combo__combo_type=1).values('id', 'iccid')
        if not u_order_qs.exists():
            return response.json(0)
        for item in u_order_qs:
            u_device_qs = UnicomDeviceInfo.objects.filter(iccid=item['iccid'], status=2) \
                .values('serial_no', 'user_id')
            if not u_device_qs.exists() or not u_device_qs[0]['user_id']:
                continue
            cls.experience_order_4G(item['iccid'], u_device_qs[0]['serial_no'], u_device_qs[0]['user_id'], False)
        return response.json(0)

    @classmethod
    def create_operation_log(cls, url, ip, request_dict, describe):
        """
        创建操作日志
        @param url: 请求路径
        @param describe: 描述
        @param ip: 当前IP
        @param request_dict: 请求参数
        @return: True | False
        """
        try:
            # 记录操作日志
            content = json.loads(json.dumps(request_dict))
            log = {
                'ip': ip,
                'user_id': 1,
                'status': 200,
                'time': int(time.time()),
                'content': json.dumps(content),
                'url': url,
                'operation': describe,
            }
            LogModel.objects.create(**log)
            return True
        except Exception as e:
            print('日志异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def get_device_4G_package(cls, request_dict, response):
        """
        获取设备流量套餐
        """
        try:
            serial_number = request_dict.get('serialNumber')
            if not serial_number:
                return response.json(0)
            card_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number)
            if not card_qs.exists():
                return response.json(0)
            card_info = card_qs.first()
            if card_info.card_type == 0:  # 联通
                card_order_qs = UnicomComboOrderInfo.objects.filter(iccid=card_info.iccid, status=1)
                if not card_order_qs:
                    LOGGER.info(f'error{card_info.serial_no}该设备没有有效套餐')
                    return response.json(10069)
                return response.json(0)
            elif card_info.card_type == 1:  # 电信
                wx_tech = WXTechObject()
                data = {'iccid': card_info.iccid, 'operator': WXOperatorEnum.TELECOM}
                result = wx_tech.get_package_order_record(**data)
                if not result:
                    return response.json(0)
                data = result['data']
                status = any(item['state'] == 1 for item in data)
                return response.json(10069) if not status else response.json(0)
            return response.json(0)
        except Exception as e:
            print('日志异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(0)

    @classmethod
    def activate_test_flow_package(cls, serial_number):
        """
        激活测试流量套餐（100M）
        @return: 成功 | 失败
        """
        flow_combo_qs = UnicomCombo.objects.filter(combo_type=4, is_del=False)
        if not flow_combo_qs:
            return False
        package_id = flow_combo_qs.first().id
        return cls.generate_flow_package(serial_number, package_id, '151564262337939513800138001')

    @classmethod
    def generate_flow_package(cls, serial_number, package_id, user_id):
        """
        生成联通流量套餐包
        @param serial_number: 序列号
        @param package_id: 套餐id
        @param user_id: 用户id
        @return: True | False
        """
        try:
            # 查询珠海联通与鼎芯电信4G卡
            u_device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number, card_type__in=[0, 3, 6])
            if not u_device_info_qs.exists():
                LOGGER.info(f'{serial_number}生成联通流量套餐iccid未绑定')
                return False
            combo_qs = UnicomCombo.objects.filter(id=package_id) \
                .values('id', 'combo_name', 'price', 'virtual_price', 'remark').order_by('sort')
            if not combo_qs.exists():
                LOGGER.info(f'{serial_number}生成联通流量套餐不存在')
                return False

            # 创建订单信息记录
            now_time = int(time.time())
            combo_info_vo = combo_qs[0]
            u_device_info = u_device_info_qs.first()
            rank_id, ai_rank_id = UnicomComboView.get_cloud_or_ai_combo()  # 生成订单必须添加该字段
            uid = CommonService.get_uid_by_serial_number(serial_number)
            if u_device_info.user_id:
                user_id = u_device_info.user_id
            order_id = CommonService.createOrderID()
            # 定义映射关系，键为card_type，值为对应的order_type
            CARD_TO_ORDER_TYPE = {
                0: 2,
                6: 6
            }
            # 从字典获取，默认返回5（处理其他所有情况）
            order_type = CARD_TO_ORDER_TYPE.get(u_device_info.card_type, 5)

            order_dict = {'orderID': order_id, 'UID': uid, 'rank_id': rank_id, 'ai_rank_id': ai_rank_id,
                          'userID_id': user_id, 'desc': combo_info_vo['combo_name'], 'payType': 10,
                          'payTime': now_time, 'price': combo_info_vo['price'], 'addTime': now_time,
                          'updTime': now_time, 'status': 1,
                          'unify_combo_id': str(combo_info_vo['id']), 'order_type': order_type,
                          'store_meal_name': combo_info_vo['combo_name']
                          }

            orderID = Order_Model.objects.create(**order_dict)
            LOGGER.info(f'4G套餐订单创建成功 orderID:{orderID}, orders表写入数据')

            # 创建4G套餐信息记录
            UnicomComboView.create_combo_order_info(order_id, 0, u_device_info.iccid, package_id)
            if u_device_info.status != 2:
                UnicomDeviceInfo.objects.filter(iccid=u_device_info.iccid).update(status=2, updated_time=now_time)
            LOGGER.info(f'{serial_number}生成流量套餐包成功,createdBy：{user_id}')
            return True

        except Exception as e:
            LOGGER.info('UnicomManageControllerView.order_flow_package,{}errLine:{}, errMsg:{}'
                        .format(serial_number, e.__traceback__.tb_lineno, repr(e)))
            return False

    @staticmethod
    def is_4g_device(serial_number, request_dict, request):
        """
        序列号未绑定UID时调用
        判断是否4G设备（如卡停用，判断是否符合激活测试流量）
        为了解决序列号解绑UID后，测试流量用完客户出现无法添加
        增加赠送5M测试流量
        """
        try:
            serial_no = serial_number[0:9]
            key = f'ASJ:UNICOM:CARD:ACTIVATE:{serial_no}'
            redis = RedisObject()
            LOGGER.info(f'UnicomComboView.is_4g_device:{serial_no}')
            if redis.get_data(key):
                return True
            # 根据序列号查询联通iccid
            unicom_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no, card_type=0) \
                .values('iccid', 'status')
            if not unicom_qs.exists():
                return False
            # 针对库存设备，此步骤激活测试流量
            unicom_qs = unicom_qs[0]

            order_package = UnicomComboOrderInfo.objects.filter(iccid=unicom_qs['iccid'], status=1)
            if not order_package:  # 当前iccid不存在正在使用的套餐
                # 查询出厂其它测试流量（特殊套餐5M为了解决客户停卡添加设备）
                flow_combo_qs = UnicomCombo.objects.filter(combo_type=5, is_del=False)
                if not flow_combo_qs:
                    return False

                package_id = flow_combo_qs.first().id
                UnicomComboView().generate_flow_package(serial_no, package_id, '151564262337939513800138001')
                redis.CONN.setnx(key, str(unicom_qs['iccid']))
                redis.CONN.expire(key, 3600)  # 当天赠送过测试流量的设备缓存24小时
                ip = CommonService.get_ip_address(request)
                describe = '{}获取uid请求激活4G卡,{}'.format(serial_no, unicom_qs['iccid'])
                UnicomComboView().create_operation_log('serialNumber/get-uid', ip, request_dict, describe)
                return True
            LOGGER.info(f'{serial_no}有正在使用的套餐')
            return True
        except Exception as e:
            LOGGER.info(
                '{}判断是否4G设备异常,errLine:{}, errMsg:{}'.format(serial_number, e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def update_package_order(cls, request_dict, response):
        iccid = request_dict.get('iccid', None)
        result = cls.update_flow_package_order_by_iccid(iccid)
        print(result)
        return response.json(0)

    @classmethod
    def update_flow_package_order_by_iccid(cls, iccid):
        """
        延长无限流量套餐
        """
        try:
            LOGGER.info(f'更新流量套餐包有效期：iccid={iccid}')
            package_info_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid) \
                .filter(~Q(combo__combo_type=4), ~Q(status=2)).order_by('created_time')
            if not package_info_qs.exists():
                return False
            if package_info_qs.count() > 1:
                a_time = 0
                is_unlimited = 0
                for item in package_info_qs:
                    if is_unlimited == 1 and item.combo.is_unlimited == 1:
                        activate_time = a_time - (3600 * 12)
                        expire_time = LocalDateTimeUtil.get_after_days_timestamp(a_time, item.combo.expiration_days)
                        UnicomComboOrderInfo.objects.filter(id=item.id) \
                            .update(activation_time=activate_time, expire_time=expire_time,
                                    updated_time=int(time.time()))
                        LOGGER.info(f'有更新：iccid={iccid}')
                    is_unlimited = item.combo.is_unlimited
                    a_time = item.expire_time
            return True

        except Exception as e:
            LOGGER.info(
                '{}update_flow_package_order_by_iccid,errLine:{}, errMsg:{}'.format(iccid, e.__traceback__.tb_lineno,
                                                                                    repr(e)))
            return False

    @staticmethod
    def create_order_pay_log(order_id, business_name, api_url, sender, access_result):
        """
        订单支付日志
        @param order_id: 订单ID
        @param business_name: 业务名称
        @param api_url: 回调api地址
        @param sender: 发送方/调用方
        @param access_result: 获取支付请求结果
        @return: True | False
        """
        try:
            LOGGER.info(f'***创建订单支付日志order_id={order_id}')
            now_time = int(time.time())
            params = {
                'order_id': order_id,
                'business_name': business_name,
                'api_url': api_url, 'sender': sender, 'access_result': access_result, 'created_time': now_time,
                'updated_time': now_time,
            }
            OrderPayLog.objects.create(**params)
            return True
        except Exception as e:
            LOGGER.info('{}create_order_pay_log,errLine:{}, errMsg:{}'.
                        format(order_id, e.__traceback__.tb_lineno, repr(e)))
            return False

    @staticmethod
    def save_order_pay_log(order_id, trade_no, api_url, sender, access_result, response_content):
        """
        保存订单支付日志
        @param order_id: 订单ID
        @param trade_no: 交易流水号
        @param api_url: 异步回调API
        @param sender: 发送方/调用方
        @param access_result: 调用结果
        @param response_content: 响应内容
        @return: True | False
        """
        try:
            LOGGER.info(f'***保存支付回调记录order_id={order_id},流水号={trade_no}')
            now_time = int(time.time())
            params = {
                'access_result': access_result,
                'updated_time': now_time,
                'trans_serial_no': trade_no,
                'response_content': response_content
            }
            pay_log_qs = OrderPayLog.objects.filter(order_id=order_id)
            if pay_log_qs.exists():
                pay_log_qs.update(**params)
                return True
            params['order_id'] = order_id
            params['api_url'] = api_url
            params['sender'] = sender
            params['created_time'] = now_time
            OrderPayLog.objects.create(**params)
            return True
        except Exception as e:
            LOGGER.info('{}save_order_pay_log,errLine:{}, errMsg:{}'.
                        format(order_id, e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def get_sim_by_serial_number(cls, request_dict, response):
        try:
            serial_number = request_dict.get('serialNumber', None)
            if not serial_number:
                return response.json(444)
            sim_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number[:9])
            if not sim_info_qs.exists():
                return response.json(173)
            if sim_info_qs.count() > 1:
                return response.json(15)
            return response.json(0)
        except Exception as e:
            LOGGER.info('get_sim_by_serial_number,errLine:{}, errMsg:{}'.
                        format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(503)