改回原代码

Controller/ShadowController.py

@@ -38,8 +38,150 @@ def generate_utk(request):
 
 
 # 更新设备影子
+@ratelimit(key='ip', rate='1/3s', block=True)
 def update_device_shadow(request):
-    return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
+    request.encoding = 'utf-8'
+    if request.method == 'POST':
+        request_dict = request.POST
+    elif request.method == 'GET':
+        request_dict = request.GET
+    else:
+        return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
+
+    logger = logging.getLogger('info')
+    logger.info('---更新设备影子---, 使用配置:{}, 参数:{}'.format(SERVER_TYPE, request_dict.dict()))
+    # 如果为美国配置,异步请求更新国内和欧洲数据
+    if SERVER_TYPE == 'Ansjer.formal_settings':
+        domain_name_list = ['push.zositechc.cn', 'push.zositeche.com']
+        request_thread = threading.Thread(target=do_request_thread, args=(domain_name_list, request_dict.dict()))
+        request_thread.start()
+
+    try:
+        etk = request_dict.get('etk', None)
+        eto = ETkObject(etk)
+        uid = eto.uid
+        if not uid:
+            return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
+
+        nowTime = int(time.time())
+
+        # 重置按钮
+        is_reset = request_dict.get('is_reset', None)
+        # 传1则重置设备信息
+        if is_reset == '1':
+            logger.info('设备重置: {}'.format(uid))
+
+            # 重置语音提示
+            uid_channel_qs = UidChannelSetModel.objects.filter(uid__uid=uid)
+            if uid_channel_qs.exists():
+                uid_channel_qs.update(voice_prompt_intelligent_mute=0, voice_prompt_status=0, voice_prompt_enter=0,
+                                      voice_prompt_leave=0, voice_repeat_day=127, voice_start_time=0, voice_end_time=0,
+                                      voice_start_x=0, voice_start_y=18, voice_end_x=44, voice_end_y=18,
+                                      voice_direction=0)
+
+            # 购买云存套餐的设备isExist置为2
+            uid_bucket = UID_Bucket.objects.filter(uid=uid, endTime__gte=nowTime).values('id', 'has_unused').order_by(
+                'addTime')
+            if not uid_bucket.exists():
+                Device_Info.objects.filter(UID=uid).update(isExist=2)
+            # 删除预览图
+            uid_pre_qs = UID_Preview.objects.filter(uid=uid)
+            if uid_pre_qs.exists():
+                uid_pre_qs.delete()
+
+            # 删除语音提示
+            voice_qs = VoicePromptModel.objects.filter(uid=uid)
+            if voice_qs.exists():
+                voice_qs.delete()
+
+            # 关闭移动侦测的消息提醒
+            Device_Info.objects.filter(UID=uid).update(NotificationMode=0)
+
+            # 关闭AI
+            AiService.objects.filter(uid=uid, use_status=1).update(detect_status=0, detect_group='')
+            logger.info('{}重置成功'.format(uid))
+
+        ucode = request_dict.get('ucode', None)
+        version = request_dict.get('version', None)
+        p2p_region = request_dict.get('p2p_region', None)
+        tz = request_dict.get('tz', None)
+        video_code = request_dict.get('video_code', None)
+        ip = CommonService.get_ip_address(request)
+        channel = request_dict.get('channel', None)
+        cloud_vod = request_dict.get('cloud_vod', None)
+        push_status = request_dict.get('push_status', None)
+        pwd = request_dict.get('pwd', None)
+        is_alexa = request_dict.get('is_alexa', None)
+        is_human = request_dict.get('is_human', None)
+        is_custom_voice = request_dict.get('is_custom', None)
+        double_wifi = request_dict.get('double_wifi', None)
+        mobile_4g = request_dict.get('mobile4G', None)
+        is_ptz = request_dict.get('is_ptz', None)
+        is_ai = request_dict.get('is_ai', None)
+        isSupportFourPoint = request_dict.get('isSupportFourPoint', None)
+
+        # 更新
+        qs_dict = {
+            'updTime': nowTime,
+            'ip': ip
+        }
+        if channel:
+            qs_dict['channel'] = channel
+        if p2p_region:
+            qs_dict['p2p_region'] = p2p_region
+        if ucode:
+            qs_dict['ucode'] = ucode
+        if version:
+            qs_dict['version'] = version
+        if tz:
+            qs_dict['tz'] = tz
+        if video_code:
+            qs_dict['video_code'] = video_code
+        if cloud_vod:
+            qs_dict['cloud_vod'] = cloud_vod
+        if push_status:
+            # 复位重置推送消息提醒
+            qs_dict['detect_status'] = 0 if is_reset == '1' else push_status
+        if pwd:
+            qs_dict['pwd'] = pwd
+        if is_human:
+            qs_dict['is_human'] = is_human
+        if is_custom_voice:
+            qs_dict['is_custom_voice'] = is_custom_voice
+        if double_wifi:
+            qs_dict['double_wifi'] = double_wifi
+        if mobile_4g:
+            qs_dict['mobile_4g'] = int(mobile_4g)
+        if is_ptz:
+            qs_dict['is_ptz'] = is_ptz
+        if is_ai:
+            qs_dict['is_ai'] = is_ai
+        if isSupportFourPoint:
+            qs_dict['isSupportFourPoint'] = isSupportFourPoint
+        ipInfo = CommonService.getIpIpInfo(ip, 'CN')
+        country_qs = CountryModel.objects.filter(country_code=ipInfo['country_code']).values('id')
+        if country_qs.exists():
+            country = country_qs[0]['id']
+            qs_dict['tb_country'] = country
+        logger.info('{} qs_dict: {}'.format(uid, qs_dict))
+
+        us_qs = UidSetModel.objects.filter(uid=uid)
+        if us_qs.exists():
+            if is_alexa and us_qs[0].is_alexa == 0:
+                qs_dict['is_alexa'] = is_alexa
+            us_qs.update(**qs_dict)
+        # 新增
+        else:
+            if is_alexa:
+                qs_dict['is_alexa'] = is_alexa
+            qs_dict['uid'] = uid
+            qs_dict['addTime'] = nowTime
+            UidSetModel.objects.create(**qs_dict)
+        logger.info('***设备影子保存成功{}'.format(uid))
+        return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
+    except Exception as e:
+        logger.info('更新设备影子异常: {}'.format(repr(e)))
+        return JsonResponse(status=200, data={'code': 0, 'update_shadow_error': repr(e)})
 
 
 def do_request_thread(domain_name_list, data):