ASJServer/Controller/CDKController.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD018
@NAME: AnsjerFormal
@software: PyCharm
@DATE: 2018/12/5 9:30
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: cloudstorage.py
@Contact: chanjunkai@163.com
"""
import json
import time
import urllib
import uuid

import boto3
import oss2
import paypalrestsdk
import threading
from aliyunsdkcore import client
from aliyunsdksts.request.v20150401 import AssumeRoleRequest
from boto3.session import Session
from django.http import JsonResponse, HttpResponseRedirect, HttpResponse
from django.views.generic.base import View

from Ansjer.config import OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, OSS_ROLE_ARN, SERVER_DOMAIN, PAYPAL_CRD, \
    SERVER_DOMAIN_SSL
from Model.models import Device_Info, Order_Model, Store_Meal, VodHlsModel, OssCrdModel, UID_Bucket, StsCrdModel, ExperienceContextModel, CDKcontextModel
from Object.AliPayObject import AliPayObject
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Object.UidTokenObject import UidTokenObject
from Service.CommonService import CommonService
from Object.m3u8generate import PlaylistGenerator
from Object.WechatPayObject import WechatPayObject
from django.db.models import Q

SERVER_DOMAIN = 'http://test.dvema.com/'

# 设备信息添加
class CDKView(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()
        if operation is None:
            return response.json(444, 'error path')
        else:
            token = request_dict.get('token', None)
            # 设备主键uid
            tko = TokenObject(token)
            response.lang = tko.lang
            if tko.code != 0:
                return response.json(tko.code)
            userID = tko.userID

    def createCDK(self, request_dict, userID, response):
        cdknum = request_dict.get("cdknum",None)
        rank = request_dict.get('rank', None)
        book_list = []
        for i in cdknum:
            nowTime = int(time.time())
            cdmodel =CDKcontextModel.objects.create(
                cdk=uuid.uuid1(),
                create_time=nowTime,
                valid_time=0,
                is_activate=0,
                rank_id=rank
            )
            book_list.append(cdmodel)
        CDKcontextModel.objects.bulk_create(book_list)

        response = ResponseObject()
        return response.json(0)

    def createCDK(self, request_dict, userID, response):
        cdknum = request_dict.get("cdknum",None)
        rank = request_dict.get('rank', None)
        book_list = []
        for i in cdknum:
            nowTime = int(time.time())
            cdmodel =CDKcontextModel.objects.create(
                cdk=uuid.uuid1(),
                create_time=nowTime,
                valid_time=0,
                is_activate=0,
                rank_id=rank
            )
            book_list.append(cdmodel)
        CDKcontextModel.objects.bulk_create(book_list)

        response = ResponseObject()
        return response.json(0)

    def createCDK(self, request_dict, userID, response):
        cdknum = request_dict.get("cdknum",None)
        rank = request_dict.get('rank', None)
        book_list = []
        for i in cdknum:
            nowTime = int(time.time())
            cdmodel =CDKcontextModel.objects.create(
                cdk=uuid.uuid1(),
                create_time=nowTime,
                valid_time=0,
                is_activate=0,
                rank_id=rank
            )
            book_list.append(cdmodel)
        CDKcontextModel.objects.bulk_create(book_list)

        response = ResponseObject()
        return response.json(0)

    def createCDK(self, request_dict, userID, response):
        cdknum = request_dict.get("cdknum",None)
        rank = request_dict.get('rank', None)
        book_list = []
        for i in cdknum:
            nowTime = int(time.time())
            cdmodel =CDKcontextModel.objects.create(
                cdk=uuid.uuid1(),
                create_time=nowTime,
                valid_time=0,
                is_activate=0,
                rank_id=rank
            )
            book_list.append(cdmodel)
        CDKcontextModel.objects.bulk_create(book_list)

        response = ResponseObject()
        return response.json(0)

    def createCDK(self, request_dict, userID, response):
        cdknum = request_dict.get("cdknum",None)
        rank = request_dict.get('rank', None)
        book_list = []
        for i in cdknum:
            nowTime = int(time.time())
            cdmodel =CDKcontextModel.objects.create(
                cdk=uuid.uuid1(),
                create_time=nowTime,
                valid_time=0,
                is_activate=0,
                rank_id=rank
            )
            book_list.append(cdmodel)
        CDKcontextModel.objects.bulk_create(book_list)

        response = ResponseObject()
        return response.json(0)