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.http import HttpResponse, JsonResponse
from django.views.generic.base import View

from Model.models import UnicomDeviceInfo, UnicomCombo, Pay_Type, Order_Model, Store_Meal, AiStoreMeal, \
    UnicomComboOrderInfo, UnicomComboExperienceHistory, UnicomDeviceStatusChangePush, SysMsgModel, UnicomFlowPush
from Object.RedisObject import RedisObject
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Object.UnicomObject import UnicomObjeect
from Object.utils import LocalDateTimeUtil
from Object.utils.PayUtil import PayService
from Service.CommonService import CommonService


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 == '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':
            return self.device_status_change_push(request_dict, request)
        elif operation == 'device-bind':
            return self.device_add(request_dict, response)
        elif operation == 'device-status':
            return self.update_device_status(request_dict, response)
        elif operation == 'update-card':
            return self.update_device_card_type(request_dict, response)
        elif operation == 'xxx-sign':
            return self.get_test_sign(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':
                return self.get_device_info(request_dict, response)
            elif operation == 'user-combo-query':
                return self.user_combo_query(user_id, request_dict, response)

    @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)
            now_time = int(time.time())
            if not unicom_device_info_qs[0].user_id:
                unicom_device_info_qs.update(user_id=user_id, updated_time=now_time)
            unicom_api = UnicomObjeect()
            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': combo_order['expire_time'],
                    'year': combo_order['year'],
                    'month': combo_order['month'],
                }
                activate_flow = float(flow_details['flowTotalUsage'])
                flow_total_usage = unicom_api.get_flow_usage_total(iccid)
                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:
            print(e.args)
            ex = traceback.format_exc()
            print(ex)
            return response.json(177, ex)

    @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('sort')
        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': item['combo__expiration_days'],
                'expirationType': item['combo__expiration_type'],
                'expireTime': 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_dict, response):
        """
        修改绑定设备状态,如产生免费套餐用量则删除
        @param request_dict:
        @param response:
        @return:
        """
        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工具进入重置ICCID{}'.format(serial_no))
        try:
            if not CommonService.check_time_stamp_token(sign, time_stamp):
                return response.json(13)
            now_time = int(time.time())
            redis = RedisObject()
            with transaction.atomic():
                device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no)
                if device_info_qs.exists():
                    iccid = device_info_qs.first().iccid
                    if device_info_qs.first().card_type == 1:
                        cls.reset_telecom_user(serial_no)
                        device_info_qs.update(updated_time=now_time, user_id='')
                        return response.json(0)
                    key = 'ASJ:UNICOM:RESET:{}'.format(serial_no)
                    flow_push_qs = UnicomFlowPush.objects.filter(serial_no=serial_no)
                    if flow_push_qs.exists():
                        flow_push_qs.delete()
                    sys_msg_qs = SysMsgModel.objects.filter(uid=serial_no)
                    if sys_msg_qs.exists():
                        sys_msg_qs.delete()
                    device_info_qs.update(status=1, updated_time=now_time, user_id='')
                    combo_order_qs = UnicomComboOrderInfo.objects.filter(iccid=iccid)
                    if combo_order_qs.exists():
                        combo_order_qs.delete()
                    combo_experience_history_qs = UnicomComboExperienceHistory.objects.filter(iccid=iccid)
                    if combo_experience_history_qs.exists():
                        combo_experience_history_qs.delete()
                    redis.set_data(key, iccid, 60 * 30)
                    UnicomObjeect().change_device_to_activate(iccid)
                return response.json(0)
        except Exception as e:
            print(e.args)
            ex = traceback.format_exc()
            print(ex)
            logger.info('PC工具重置异常ICCID{}，msg={}'.format(iccid, 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 device_add(cls, request_dict, response):
        """
        设备绑定iccid
        @param request_dict:
        @param response:
        @return:
        """
        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注册接口')
        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:
            logger.info('--->参数验证通过，sign验证通过')
            redis = RedisObject()
            with transaction.atomic():
                # 待完善代码 根据uid与用户id验证系统设备
                unicom_device_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_no)
                if unicom_device_qs.exists():
                    if unicom_device_qs.first().status == 1:
                        key = 'ASJ:UNICOM:RESET:{}'.format(serial_no)
                        reset_cache = redis.get_data(key)
                        if reset_cache:
                            logger.info('--->三十分后再次访问接口生效赠送流量套餐')
                            return response.json(0, 'Thirty minutes later to visit again take effect')
                        cls.user_activate_flow(iccid)
                    unicom_device_qs.update(main_card=sim, updated_time=n_time)
                    return response.json(0)
                if sim == 0:
                    return response.json(0, '外置卡不保存相关信息{}'.format(serial_no))
                unicom_obj = UnicomObjeect()
                params = {'iccid': iccid, 'serial_no': serial_no, 'updated_time': n_time,
                          'created_time': n_time, 'main_card': sim}
                if cls.check_iccid(iccid):
                    params['card_type'] = 1
                    params['status'] = 2
                    UnicomDeviceInfo.objects.create(**params)
                    return response.json(0)
                result = unicom_obj.verify_device(iccid=iccid)
                if result.status_code == 200 and result.text:
                    res_dict = json.loads(result.text)
                    if res_dict['success']:
                        if res_dict['data']['status'] == 0:
                            logger.info('--->设备请求绑定{}验证不存在{}'.format(iccid, res_dict))
                            return response.json(173)
                        unicom_obj.change_device_to_activate(iccid)
                        UnicomDeviceInfo.objects.create(**params)
                    return response.json(0)
                else:
                    logger.info('--->设备请求绑定{}验证失败'.format(iccid))
                    return response.json(173)
        except Exception as e:
            print(e)
            ex = traceback.format_exc()
            logger.info('--->设备调用4G注册接口异常:{}'.format(ex))
            return response.json(177, repr(e))

    @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')
                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.query_uid_with_serial(unicom_device_qs['serial_no'])
                order_id = CommonService.createOrderID()
                rank_id, ai_rank_id = cls.get_cloud_or_ai_combo()

                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': 2,
                              'store_meal_name': unicom_combo_qs['combo_name']
                              }

                params = 'lang=cn' + '&activateType=' + activate_type
                logger.info('激活类型：{}'.format(activate_type))
                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}
                elif pay_type == 3:  # 微信支付
                    notify_url = 'unicom/wap/pay/wechat-notify'
                    ip = CommonService.get_ip_address(request)
                    params = 'activateType=' + activate_type
                    sign_params = PayService.create_wechat_payment(params, order_id,
                                                                   price, ip,
                                                                   notify_url,
                                                                   unicom_combo_qs['remark'],
                                                                   response)
                    result['result'] = sign_params
                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, repr(e))

    @staticmethod
    def get_cloud_or_ai_combo():
        """
        获取云存或者AI套餐id
        @return:
        """
        rank_id = Store_Meal.objects.all().order_by('sort').values().first()['id']
        ai_rank_id = AiStoreMeal.objects.all().values().first()['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)
        unicom_api = UnicomObjeect()
        flow = unicom_api.get_flow_usage_total(iccid)
        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:
                        unicom_api.change_device_to_activate(iccid)
                        flow_total_usage = unicom_api.get_flow_usage_total(iccid)
                        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:
            print(e)
            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})