|
|
@@ -9,7 +9,7 @@ import uuid
|
|
|
from django.http import JsonResponse
|
|
|
from django.views import View
|
|
|
|
|
|
-from model.models import UserModel
|
|
|
+from model.models import UserModel, AlexaAuthModel
|
|
|
from object.ResObject import ResObject
|
|
|
from service.CommonService import CommonService
|
|
|
|
|
|
@@ -31,6 +31,8 @@ class Oa2View(View):
|
|
|
return self.get_auth_code_and_token(request_dict, response)
|
|
|
elif operation == 'getTokenWithAuthCode': # 根据用户验证码获取访问令牌
|
|
|
return self.get_token_with_auth_code(request_dict, response)
|
|
|
+ elif operation == 'updateAmazonToken': # 更新亚马逊令牌
|
|
|
+ return self.update_amazon_token(request_dict)
|
|
|
else:
|
|
|
return self.print_url(operation, request_dict, response)
|
|
|
|
|
|
@@ -87,6 +89,23 @@ class Oa2View(View):
|
|
|
}
|
|
|
return JsonResponse(res_json)
|
|
|
|
|
|
+ @staticmethod
|
|
|
+ def update_amazon_token(request_dict):
|
|
|
+ user_id = request_dict.get('user_id')
|
|
|
+ access_token = request_dict.get('access_token')
|
|
|
+ refresh_token = request_dict.get('refresh_token')
|
|
|
+
|
|
|
+ if not all([user_id, access_token, refresh_token]):
|
|
|
+ return JsonResponse({}, status=500)
|
|
|
+
|
|
|
+ try:
|
|
|
+ now_time = int(time.time())
|
|
|
+ AlexaAuthModel.objects.filter(userID=user_id).update(
|
|
|
+ access_token=access_token, refresh_token=refresh_token, expiresTime=now_time + 3000, updTime=now_time)
|
|
|
+ return JsonResponse({})
|
|
|
+ except Exception as e:
|
|
|
+ return JsonResponse({}, status=500)
|
|
|
+
|
|
|
@staticmethod
|
|
|
def print_url(operation, request_dict, response):
|
|
|
logger = logging.getLogger('django')
|
