ShadowController.py 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148
  1. #!/usr/bin/env python3
  2. # -*- coding: utf-8 -*-
  3. """
  4. @Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
  5. @AUTHOR: ASJRD018
  6. @NAME: AnsjerPush
  7. @software: PyCharm
  8. @DATE: 2020/2/14 13:54
  9. @Version: python3.6
  10. @MODIFY DECORD:ansjer dev
  11. @file: ShadowController.py
  12. @Contact: chanjunkai@163.com
  13. """
  14. # 测试环境
  15. # test.shadow.dvema.com
  16. # 生产环境
  17. # shadow.dvema.com
  18. # 设备影子更新
  19. from Object.LogUtil import LogUtil
  20. from Object.ResponseObject import ResponseObject
  21. from Object.ETkObject import ETkObject
  22. import time
  23. from Model.models import Device_Info, UidSetModel, UID_Preview
  24. from Service.CommonService import CommonService
  25. from django.http import JsonResponse
  26. from Object.UidTokenObject import UidTokenObject
  27. def generate_utk(request):
  28. request.encoding = 'utf-8'
  29. response = ResponseObject()
  30. if request.method == 'GET':
  31. request_dict = request.GET
  32. elif request.method == 'POST':
  33. request_dict = request.POST
  34. else:
  35. return response.json(444,'wrong method')
  36. username = request_dict.get('username',None)
  37. password = request_dict.get('password',None)
  38. uid = request_dict.get('uid',None)
  39. if username and password:
  40. if username == 'debug_user' and password == 'debug_password':
  41. # utko = UidTokenObject()
  42. # # right
  43. # utko.generate(data={'uid': uid})
  44. etkObj = ETkObject(etk='')
  45. etk = etkObj.encrypt(uid)
  46. return response.json(0, {'etk': etk})
  47. else:
  48. return response.json(404)
  49. else:
  50. return response.json(444,'username password')
  51. # 设备影子更新
  52. def update_device_shadow(request):
  53. request.encoding = 'utf-8'
  54. response = ResponseObject()
  55. if request.method == 'POST':
  56. request_dict = request.POST
  57. elif request.method == 'GET':
  58. request_dict = request.GET
  59. else:
  60. return response.json(444)
  61. etk = request_dict.get('etk', None)
  62. eto = ETkObject(etk)
  63. uid = eto.uid
  64. if uid:
  65. # 重置按钮
  66. is_reset = request_dict.get('is_reset', None)
  67. # 传1则重置设备信息
  68. if is_reset == '1':
  69. UidSetModel.objects.filter(uid=uid).delete()
  70. # 重置设备,判断设备为已删除
  71. Device_Info.objects.filter(UID=uid).update(isExist=2)
  72. # 删除预览图
  73. uid_pre_qs = UID_Preview.objects.filter(uid=uid)
  74. if uid_pre_qs.exists():
  75. uid_pre_qs.delete()
  76. # return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
  77. ucode = request_dict.get('ucode', None)
  78. version = request_dict.get('version', None)
  79. p2p_region = request_dict.get('p2p_region', None)
  80. tz = request_dict.get('tz', None)
  81. video_code = request_dict.get('video_code', None)
  82. ip = CommonService.get_ip_address(request)
  83. channel = request_dict.get('channel', None)
  84. cloud_vod = request_dict.get('cloud_vod', None)
  85. push_status = request_dict.get('push_status', None)
  86. pwd = request_dict.get('pwd', None)
  87. resetTime = request_dict.get('resetTime', None)
  88. is_alexa = request_dict.get('is_alexa', None)
  89. is_human = request_dict.get('is_human', None)
  90. is_custom_voice = request_dict.get('is_custom', None)
  91. double_wifi = request_dict.get('double_wifi', None)
  92. us_qs = UidSetModel.objects.filter(uid=uid)
  93. # 更新
  94. nowTime = int(time.time())
  95. print('-------')
  96. print(resetTime)
  97. print('-------')
  98. qs_dict = {
  99. 'updTime': nowTime,
  100. 'ip': ip
  101. }
  102. if channel:
  103. qs_dict['channel'] = channel
  104. if p2p_region:
  105. qs_dict['p2p_region'] = p2p_region
  106. if ucode:
  107. qs_dict['ucode'] = ucode
  108. if version:
  109. qs_dict['version'] = version
  110. if tz:
  111. qs_dict['tz'] = tz
  112. if video_code:
  113. qs_dict['video_code'] = video_code
  114. if cloud_vod:
  115. qs_dict['cloud_vod'] = cloud_vod
  116. if push_status:
  117. qs_dict['detect_status'] = push_status
  118. if pwd:
  119. qs_dict['pwd'] = pwd
  120. if is_human:
  121. qs_dict['is_human'] = is_human
  122. if is_custom_voice:
  123. qs_dict['is_custom_voice'] = is_custom_voice
  124. if double_wifi:
  125. qs_dict['double_wifi'] = double_wifi
  126. if us_qs.exists():
  127. if is_alexa and us_qs[0].is_alexa == 0:
  128. qs_dict['is_alexa'] = is_alexa
  129. us_qs.update(**qs_dict)
  130. # 如果推送状态开启,返回推送url
  131. return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
  132. # 新增
  133. else:
  134. if is_alexa:
  135. qs_dict['is_alexa'] = is_alexa
  136. qs_dict['uid'] = uid
  137. qs_dict['addTime'] = nowTime
  138. UidSetModel.objects.create(**qs_dict)
  139. # 如果推送状态开启,返回推送url
  140. return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
  141. else:
  142. return JsonResponse(status=200, data={'code': 403, 'msg': 'error etk'})