ASJPush/Controller/ShadowController.py

import logging
import threading
import time

import requests
from django.http import JsonResponse
from ratelimit.decorators import ratelimit

from AnsjerPush.config import SERVER_TYPE
from Model.models import Device_Info, UidSetModel, UID_Preview, VoicePromptModel, UID_Bucket, UidChannelSetModel, \
    AiService, CountryModel
from Object.ETkObject import ETkObject
from Object.ResponseObject import ResponseObject
from Service.CommonService import CommonService


def generate_utk(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'GET':
        request_dict = request.GET
    elif request.method == 'POST':
        request_dict = request.POST
    else:
        return response.json(444, 'wrong method')
    username = request_dict.get('username', None)
    password = request_dict.get('password', None)
    uid = request_dict.get('uid', None)
    if username and password:
        if username == 'debug_user' and password == 'debug_password':
            etkObj = ETkObject(etk='')
            etk = etkObj.encrypt(uid)
            return response.json(0, {'etk': etk})
        else:
            return response.json(404)
    else:
        return response.json(444, 'username password')


# 更新设备影子
def update_device_shadow(request):
    return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})


def do_request_thread(domain_name_list, data):
    for domain_name in domain_name_list:
        url = 'http://{}/deviceShadow/update'.format(domain_name)
        requests.post(url=url, data=data, timeout=2)