#!/usr/bin/env python3 # -*- coding: utf-8 -*- """ """ import json import time import requests import uuid import logging from django.views.generic import TemplateView from django.shortcuts import render_to_response from django.http import JsonResponse import http.client from urllib.parse import urlencode from object.ResObject import ResObject import subprocess # from gevent.pool import Pool from model.models import UserModel,UidRtspModel from object.ResponseObject import ResponseObject from object.tkObject import tkObject from service.CommonService import CommonService from model.models import AlexaAuthModel from object.RedisObject import RedisObject from django.utils.decorators import method_decorator from django.views.decorators.csrf import csrf_exempt rtspServer = "rtsp.zositech.org,3.16.66.144" class deviceStatus(TemplateView): @method_decorator(csrf_exempt) def dispatch(self, *args, **kwargs): return super(deviceStatus, self).dispatch(*args, **kwargs) def get(self, request, *args, **kwargs): logger = logging.getLogger('django') logger.info('get----------------------------------------') request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.GET, request, operation) def post(self, request, *args, **kwargs): logger = logging.getLogger('django') logger.info('post----------------------------------------') 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 JsonResponse({'code':404,'msg':'not found'}) if operation == 'saveAccessToken': return self.saveAccessToken(request_dict, response) if operation == 'addOrUpdate': logger = logging.getLogger('django') logger.info('in__________________________validation________') return self.addOrUpdate(request_dict, response) if operation == 'delete': return self.delete(request_dict, response) elif operation == 'test': return self.discover(request_dict, response) def saveAccessToken(self,request_dict, response): access_token = request_dict.get("access_token", '') refresh_token = request_dict.get("refresh_token", '') token = request_dict.get("token", '') logger = logging.getLogger('django') logger.info('login-------------begin---token') logger.info(access_token) logger.info(refresh_token) alexAuth = AlexaAuthModel.objects.filter(token=token) nowTime = int(time.time()) if not alexAuth.exists(): AlexaAuthModel.objects.create( access_token = access_token, refresh_token = refresh_token, token = token, expiresTime = nowTime + 3200, addTime=nowTime, updTime=nowTime) else: alexAuth.update( access_token = access_token, refresh_token = refresh_token, expiresTime = nowTime + 3200, token = token, updTime=nowTime ) return JsonResponse({'code':200,'msg':'success'}) def discover(self,request_dict, response): userID = 158943604783713800138000 # token = 'cGSOD01pi2BICtGd1SVdjegwrVKV1Kmn' token = 'cGSOD01pi2BICtGd1SVdjegwrVKV1Kmn' alexAuth = AlexaAuthModel.objects.filter(token=token) if alexAuth.exists(): res = alexAuth.values() access_token = res[0]['access_token'] refresh_token = res[0]['refresh_token'] token = res[0]['token'] expiresTime = res[0]['expiresTime'] AlexaAuthModel.objects.filter(userID = userID).delete() alexAuth.delete() AlexaAuthModel.objects.create( userID = userID, access_token = access_token, refresh_token = refresh_token, token = token, expiresTime = expiresTime, ) return JsonResponse({'code':200,'msg':'xxx'}) def addOrUpdate(self,request_dict, response): logger = logging.getLogger('django') logger.info('in__________________________first') UID = request_dict.get("UID", '') userID = request_dict.get("userID", '') uid_nick = request_dict.get("uid_nick", '') logger.info('class:deviceStatus-------function:addOrUpdate------------------') logger.info(UID) logger.info(userID) logger.info(uid_nick) if UID == '' or userID == '' or uid_nick == '': return JsonResponse({'code':101,'msg':'fail'}) alexAuth = AlexaAuthModel.objects.filter(userID=userID) if not alexAuth.exists(): return JsonResponse({'code':102,'msg':'not found user'}) info = alexAuth.values() expiresTime = info[0]['expiresTime'] now_time = int(time.time()) access_token = info[0]['access_token'] refresh_token = info[0]['refresh_token'] if now_time > expiresTime: res = self.getRefreshToken(refresh_token) if('error' not in res): alexAuth.update( access_token = res['access_token'], refresh_token = res['refresh_token'], expiresTime = now_time + 3000, updTime = now_time, ) access_token = res['access_token'] else: return JsonResponse({'code':102,'msg':'get refresh_token fail'}) api_uri = 'https://api.amazonalexa.com/v3/events' messageId = str(uuid.uuid4()).strip() bearer_access_token = "Bearer {access_token}".format(access_token=access_token) headers = {"content-type": "application/json", "Authorization": bearer_access_token} payload_json = { "event": { "header": { "namespace": "Alexa.Discovery", "name": "AddOrUpdateReport", "payloadVersion": "3", "messageId": messageId, }, "payload": { "endpoints": [ { "endpointId": UID, "manufacturerName": "zosi smart", "modelName": "P1425-LE", "friendlyName": uid_nick, "description": "Camera connected via zosi smart", "displayCategories": ["CAMERA"], "capabilities": [ { "type": "AlexaInterface", "interface": "Alexa.CameraStreamController", "version": "3", "cameraStreamConfigurations": [ { "protocols": ["RTSP"], "resolutions": [{"width": 1280, "height": 720}], "authorizationTypes": ["NONE"], "videoCodecs": ["H264"], "audioCodecs": ["ACC"], } ], } ], } ], "scope": { "type": "BearerToken", "token": 'sdf', }, }, } } response = requests.post(api_uri, json=payload_json, headers=headers) logger.info('--------addOrUpdate_response') logger.info(response) return JsonResponse({'res':'success'}) # return json.dumps('test',indent=4,sort_keys=True,ensure_ascii=False) #格式化返回内容 def delete(self,request_dict, response): UID = request_dict.get("UID", '') userID = request_dict.get("userID", '') logger = logging.getLogger('django') logger.info('class:deviceStatus-------function:delete------------------') logger.info(UID) logger.info(userID) if UID == '': return JsonResponse({'code':111,'msg':'fail'}) alexAuth = AlexaAuthModel.objects.filter(userID=userID) if not alexAuth.exists(): return JsonResponse({'code':102,'msg':'not found user'}) info = alexAuth.values() expiresTime = info[0]['expiresTime'] refresh_token = info[0]['refresh_token'] now_time = int(time.time()) access_token = info[0]['access_token'] if now_time > expiresTime: res = self.getRefreshToken(refresh_token) if('error' not in res): alexAuth.update( access_token = res['access_token'], refresh_token = res['refresh_token'], expiresTime = now_time + 300, updTime = now_time, ) access_token = res['access_token'] else: return JsonResponse({'code':102,'msg':'get refresh_token fail'}) messageId = str(uuid.uuid4()) headers = { "Authorization": "Bearer " + access_token, "Content-Type": "application/json;charset=UTF-8", "Cache-Control": "no-cache" } payload = { "event": { "header": { "namespace": "Alexa.Discovery", "name": "DeleteReport", "messageId": messageId, "payloadVersion": "3" }, "payload": { "endpoints": [ { "endpointId": UID } ], "scope": { "type": "BearerToken", "token": access_token } } } } # return JsonResponse({"res": headers}) api_uri = 'https://api.amazonalexa.com/v3/events' response = requests.post(api_uri, json=payload, headers=headers) logger.info('--------delete_response') logger.info(response) return JsonResponse({'res':'success'}) def getRefreshToken(self,refresh_token): payload = { 'grant_type': 'refresh_token', 'refresh_token': refresh_token, 'client_id': 'amzn1.application-oa2-client.efb07b51dd444f848b6f0598635da3cc', 'client_secret': '8a49390ebe362bfee153be87587f5673d0c1d8aeb6bc1ef736fda6c9d5d81c8f', } auth_request_url = 'https://api.amazon.com/auth/o2/token' headers = { 'content-type': "application/x-www-form-urlencoded", 'cache-control': "no-cache" } res = requests.post(auth_request_url, payload,headers) request_json = res.json() return request_json #请求alexa事件网关接口失败错误码 ''' 400 Bad Request INVALID_REQUEST_EXCEPTION 消息无效，可能是因为缺少字段、不正确的值或格式错误的 JSON。根据文档检查邮件以验证邮件是否包含所有必需的字段。 401 Unauthorized INVALID_ACCESS_TOKEN_EXCEPTION 访问令牌无效，因为它已过期或格式错误。刷新令牌并重试请求。如果用户禁用您的技能，这也会使访问令牌失效。这意味着用户已吊销授权，您可以停止为他们发送更改报告。 403 Forbidden SKILL_NEVER_ENABLED_EXCEPTION 请确保将事件发送到正确的区域终结点。例如，北美中的事件应发送到北美终结点。 403 Forbidden INSUFFICIENT_PERMISSION_EXCEPTION 令牌没有所需的权限。确保该技能具有发送 Alexa 事件的权限。请参阅异步消息身份验证的步骤。 404 Not Found SKILL_NOT_FOUND_EXCEPTION 找不到与此令牌关联的技能 ID。当技能处于不同阶段（如认证）时生成用户的访问令牌时，将发生此错误。尝试禁用并重新启用此用户的技能。 413 Payload Too Large REQUEST_ENTITY_TOO_LARGE_EXCEPTION 事件有效负载的大小太大。请求中允许的最大终结点数为 300。以较小的有效负载发送邮件。 429 Too Many Requests THROTTLING_EXCEPTION 请求数过高。重新发送消息最多三次，每次发送尝试之间至少有一秒的间隔。 500 Internal Server Error INTERNAL_SERVICE_EXCEPTION Alexa 发生错误，无法处理该消息。重新发送消息最多三次，每次发送尝试之间至少有一秒的间隔。如果问题仍然存在，请联系亚马逊支持。 503 Service Unavailable SERVICE_UNAVAILABLE_EXCEPTION 亚历克萨不能接受这条信息。重新发送消息最多三次，每次尝试之间至少有一秒的间隔。如果问题仍然存在，请联系亚马逊支持。 '''