ShadowController.py 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205
  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. import logging
  20. import threading
  21. import time
  22. import requests
  23. from django.http import JsonResponse
  24. from AnsjerPush.config import SERVER_TYPE
  25. from Model.models import Device_Info, UidSetModel, UID_Preview, VoicePromptModel, UID_Bucket, UidChannelSetModel, \
  26. AiService
  27. from Object.ETkObject import ETkObject
  28. from Object.ResponseObject import ResponseObject
  29. from Service.CommonService import CommonService
  30. def generate_utk(request):
  31. request.encoding = 'utf-8'
  32. response = ResponseObject()
  33. if request.method == 'GET':
  34. request_dict = request.GET
  35. elif request.method == 'POST':
  36. request_dict = request.POST
  37. else:
  38. return response.json(444, 'wrong method')
  39. username = request_dict.get('username', None)
  40. password = request_dict.get('password', None)
  41. uid = request_dict.get('uid', None)
  42. if username and password:
  43. if username == 'debug_user' and password == 'debug_password':
  44. # utko = UidTokenObject()
  45. # # right
  46. # utko.generate(data={'uid': uid})
  47. etkObj = ETkObject(etk='')
  48. etk = etkObj.encrypt(uid)
  49. return response.json(0, {'etk': etk})
  50. else:
  51. return response.json(404)
  52. else:
  53. return response.json(444, 'username password')
  54. # 设备影子更新
  55. def update_device_shadow(request):
  56. request.encoding = 'utf-8'
  57. response = ResponseObject()
  58. if request.method == 'POST':
  59. request_dict = request.POST
  60. elif request.method == 'GET':
  61. request_dict = request.GET
  62. else:
  63. return response.json(444)
  64. logger = logging.getLogger('info')
  65. try:
  66. asy = threading.Thread(target=async_device_shadow,
  67. args=(request_dict, request))
  68. asy.start()
  69. return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
  70. except Exception as e:
  71. logger.info('更新设备影子异常: {}'.format(repr(e)))
  72. return JsonResponse(status=200, data={'code': 0, 'update_shadow_error': repr(e)})
  73. def async_device_shadow(request_dict, request):
  74. try:
  75. logger = logging.getLogger('info')
  76. etk = request_dict.get('etk', None)
  77. eto = ETkObject(etk)
  78. uid = eto.uid
  79. if not uid:
  80. return False
  81. logger.info('使用配置: {}'.format(SERVER_TYPE))
  82. logger.info('data: {}'.format(request_dict.dict()))
  83. if SERVER_TYPE != 'Ansjer.test_settings':
  84. if SERVER_TYPE != 'Ansjer.cn_formal_settings': # 同步更新国内数据
  85. requests.post(url='http://shadow.zositechc.cn/deviceShadow/update', data=request_dict.dict(), timeout=2)
  86. nowTime = int(time.time())
  87. # 重置按钮
  88. is_reset = request_dict.get('is_reset', None)
  89. # 传1则重置设备信息
  90. if is_reset == '1':
  91. logger.info('设备重置: {}'.format(uid))
  92. # 重置语音提示
  93. uid_channel_qs = UidChannelSetModel.objects.filter(uid__uid=uid)
  94. if uid_channel_qs.exists():
  95. uid_channel_qs.update(voice_prompt_intelligent_mute=0, voice_prompt_status=0, voice_prompt_enter=0,
  96. voice_prompt_leave=0, voice_repeat_day=127, voice_start_time=0, voice_end_time=0,
  97. voice_start_x=0, voice_start_y=18, voice_end_x=44, voice_end_y=18,
  98. voice_direction=0)
  99. # 购买云存套餐的设备isExist置为2
  100. uid_bucket = UID_Bucket.objects.filter(uid=uid, endTime__gte=nowTime).values('id', 'has_unused').order_by(
  101. 'addTime')
  102. if not uid_bucket.exists():
  103. Device_Info.objects.filter(UID=uid).update(isExist=2)
  104. # 删除预览图
  105. uid_pre_qs = UID_Preview.objects.filter(uid=uid)
  106. if uid_pre_qs.exists():
  107. uid_pre_qs.delete()
  108. # 删除语音提示
  109. voice_qs = VoicePromptModel.objects.filter(uid=uid)
  110. if voice_qs.exists():
  111. voice_qs.delete()
  112. # 关闭移动侦测的消息提醒
  113. Device_Info.objects.filter(UID=uid).update(NotificationMode=0)
  114. # 关闭AI
  115. AiService.objects.filter(uid=uid, use_status=1).update(detect_status=0, detect_group='')
  116. logger.info('{}重置成功'.format(uid))
  117. ucode = request_dict.get('ucode', None)
  118. version = request_dict.get('version', None)
  119. p2p_region = request_dict.get('p2p_region', None)
  120. tz = request_dict.get('tz', None)
  121. video_code = request_dict.get('video_code', None)
  122. ip = CommonService.get_ip_address(request)
  123. channel = request_dict.get('channel', None)
  124. cloud_vod = request_dict.get('cloud_vod', None)
  125. push_status = request_dict.get('push_status', None)
  126. pwd = request_dict.get('pwd', None)
  127. is_alexa = request_dict.get('is_alexa', None)
  128. is_human = request_dict.get('is_human', None)
  129. is_custom_voice = request_dict.get('is_custom', None)
  130. double_wifi = request_dict.get('double_wifi', None)
  131. mobile_4g = request_dict.get('mobile4G', None)
  132. is_ptz = request_dict.get('is_ptz', None)
  133. is_ai = request_dict.get('is_ai', None)
  134. # 更新
  135. qs_dict = {
  136. 'updTime': nowTime,
  137. 'ip': ip
  138. }
  139. if channel:
  140. qs_dict['channel'] = channel
  141. if p2p_region:
  142. qs_dict['p2p_region'] = p2p_region
  143. if ucode:
  144. qs_dict['ucode'] = ucode
  145. if version:
  146. qs_dict['version'] = version
  147. if tz:
  148. qs_dict['tz'] = tz
  149. if video_code:
  150. qs_dict['video_code'] = video_code
  151. if cloud_vod:
  152. qs_dict['cloud_vod'] = cloud_vod
  153. if push_status:
  154. # 复位重置推送消息提醒
  155. qs_dict['detect_status'] = 0 if is_reset == '1' else push_status
  156. if pwd:
  157. qs_dict['pwd'] = pwd
  158. if is_human:
  159. qs_dict['is_human'] = is_human
  160. if is_custom_voice:
  161. qs_dict['is_custom_voice'] = is_custom_voice
  162. if double_wifi:
  163. qs_dict['double_wifi'] = double_wifi
  164. if mobile_4g:
  165. qs_dict['mobile_4g'] = int(mobile_4g)
  166. if is_ptz:
  167. qs_dict['is_ptz'] = is_ptz
  168. if is_ai:
  169. qs_dict['is_ai'] = is_ai
  170. logger.info('{} qs_dict: {}'.format(uid, qs_dict))
  171. us_qs = UidSetModel.objects.filter(uid=uid)
  172. if us_qs.exists():
  173. if is_alexa and us_qs[0].is_alexa == 0:
  174. qs_dict['is_alexa'] = is_alexa
  175. us_qs.update(**qs_dict)
  176. # 新增
  177. else:
  178. if is_alexa:
  179. qs_dict['is_alexa'] = is_alexa
  180. qs_dict['uid'] = uid
  181. qs_dict['addTime'] = nowTime
  182. UidSetModel.objects.create(**qs_dict)
  183. logger.info('***设备影子保存成功{}'.format(uid))
  184. except Exception as e:
  185. print(repr(e))
  186. print('异步保存设备影子信息报错,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))