Преглед на файлове

保存令牌请求更新业务服务器的token

locky преди 1 година
родител
ревизия
2c9345261c
променени са 1 файла, в които са добавени 17 реда и са изтрити 3 реда
  1. 17 3
      controller/deviceStatus.py

+ 17 - 3
controller/deviceStatus.py

@@ -66,9 +66,9 @@ class deviceStatus(TemplateView):
         logger.info('--------认证登录,地区: {}, skill: {}--------'.format(alexa_region, skill_name))
 
         try:
-            alexAuth = AlexaAuthModel.objects.filter(token=token, skill_name=skill_name)
+            alex_auth_qs = AlexaAuthModel.objects.filter(token=token, skill_name=skill_name).values('userID')
             nowTime = int(time.time())
-            if not alexAuth.exists():
+            if not alex_auth_qs.exists():
                 AlexaAuthModel.objects.create(
                     token=token,
                     addTime=nowTime,
@@ -80,7 +80,7 @@ class deviceStatus(TemplateView):
                     skill_name=skill_name
                 )
             else:
-                alexAuth.update(
+                alex_auth_qs.update(
                     token=token,
                     updTime=nowTime,
                     alexa_region=alexa_region,
@@ -88,6 +88,20 @@ class deviceStatus(TemplateView):
                     refresh_token=refresh_token,
                     expiresTime=nowTime + 3200,
                 )
+                # 更新业务服务器的token
+                user_id = alex_auth_qs[0]['userID']
+                if alexa_region == 'US':
+                    base_url = SERVER_PREFIX_TEST  # SERVER_PREFIX
+                else:
+                    base_url = SERVER_PREFIX_EU
+                url = '{}/alexaApi/appToApp/updateToken'
+                data = {
+                    'user_id': user_id,
+                    'access_token': access_token,
+                    'refresh_token': refresh_token
+                }
+                r = requests.post(url=url, data=data, timeout=10)
+
             return JsonResponse({'code': 200, 'msg': 'success'})
         except Exception as e:
             logger.info('授权登录接口异常: error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))