# -*- coding: utf-8 -*- """ @Author ： Rocky @Time ： 2022/5/9 10:51 @File ：gatewayController.py """ import logging import time from django.views.generic.base import View from Model.models import SensorRecord, GatewaySubDevice, GatewayPush, Device_Info from Object.ResponseObject import ResponseObject from Object.utils import LocalDateTimeUtil from Service.CommonService import CommonService from Service.EquipmentInfoService import EquipmentInfoService from Service.GatewayService import GatewayPushService class GatewayView(View): def get(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.GET, operation) def post(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.POST, operation) def validation(self, request_dict, operation): response = ResponseObject() if operation == 'gatewayPush': # 网关推送 return self.gateway_push(request_dict, response) else: return response.json(414) @staticmethod def gateway_push(request_dict, response): """ 网关推送 @param request_dict: 请求参数 @request_dict serial_number: 序列号 @request_dict ieee_addr: 长地址 @request_dict src_addr: 短地址 @request_dict sensor_type: 传感器类型 @request_dict event_type: 事件类型 @request_dict alarm: 消息内容 @param response: 响应对象 @return: response """ logger = logging.getLogger('info') serial_number = request_dict.get('serial_number', None) ieee_addr = request_dict.get('ieee_addr', None) src_addr = request_dict.get('src_addr', None) sensor_type = int(request_dict.get('sensor_type', None)) event_type = int(request_dict.get('event_type', None)) alarm = request_dict.get('alarm', None) defense = int(request_dict.get('defense', None)) logger.info('---调用网关推送接口--- request_dict:{}'.format(request_dict)) if not all([serial_number, ieee_addr, src_addr, sensor_type, event_type, alarm]): return response.json(444) n_time = int(time.time()) try: nickname = serial_number # 查询子设备表id gateway_sub_device_qs = GatewaySubDevice.objects.filter(device__serial_number=serial_number, device_type=sensor_type, ieee_addr=ieee_addr, src_addr=src_addr).values('id', 'nickname') if gateway_sub_device_qs.exists(): gateway_sub_device_id = gateway_sub_device_qs[0]['id'] nickname = gateway_sub_device_qs[0]['nickname'] # 写入传感器记录数据 SensorRecord.objects.create(gateway_sub_device_id=gateway_sub_device_id, alarm=alarm, event_type=event_type, created_time=n_time) # (门磁,烟雾,人体)传感器被拆动/拆动恢复,修改拆动状态 if event_type == 2152 or event_type == 2182 or event_type == 2192: gateway_sub_device_qs.update(is_tampered=1) elif event_type == 2153 or event_type == 2183 or event_type == 2193: gateway_sub_device_qs.update(is_tampered=0) # 撤防状态不推送 if defense == 0: return response.json(0) device_info_qs = Device_Info.objects.filter(serial_number=serial_number).values('userID_id') if not device_info_qs.exists(): return response.json(173) local_date_time = '' equipment_info_list = [] for device_info in device_info_qs: user_id = device_info['userID_id'] # 查询推送配置数据 gateway_push_qs = GatewayPush.objects.filter(user_id=user_id, logout=False). \ values('user_id', 'app_bundle_id', 'app_type', 'push_type', 'token_val', 'm_code', 'lang', 'm_code', 'tz') if not gateway_push_qs.exists(): continue kwargs = { 'n_time': n_time, 'event_type': event_type, 'nickname': nickname, } # 推送到每台登录账号的手机 for gateway_push in gateway_push_qs: user_id = gateway_push['user_id'] app_bundle_id = gateway_push['app_bundle_id'] push_type = gateway_push['push_type'] token_val = gateway_push['token_val'] lang = gateway_push['lang'] tz = gateway_push['tz'] if gateway_push['tz'] else 0 # 获取推送所需数据 msg_title = GatewayPushService.get_msg_title(app_bundle_id, nickname) msg_text = GatewayPushService.get_msg_text(n_time, tz, lang, alarm) kwargs['msg_title'] = msg_title kwargs['msg_text'] = msg_text kwargs['app_bundle_id'] = app_bundle_id kwargs['token_val'] = token_val try: # 推送消息 if push_type == 0: # ios apns GatewayPushService.ios_apns_push(**kwargs) elif push_type == 1: # android gcm GatewayPushService.android_fcm_push(**kwargs) elif push_type == 2: # android 极光推送 GatewayPushService.android_jpush(**kwargs) except Exception as e: logger.info('网关推送消息异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e))) continue # 组织存储数据 local_date_time = CommonService.get_now_time_str(n_time=n_time, tz=0, lang='cn')[:10] equipment_info_list.append(EquipmentInfoService.get_equipment_info_obj( local_date_time, add_time=n_time, event_time=n_time, receive_time=n_time, device_uid=serial_number, device_nick_name=nickname, alarm=alarm, event_type=event_type, device_user_id=user_id, )) if equipment_info_list: # 根据日期获得星期几 week = LocalDateTimeUtil.date_to_week(local_date_time) EquipmentInfoService.equipment_info_bulk_create(week, equipment_info_list) return response.json(0) except Exception as e: logger.info('---网关推送接口异常--- {}'.format(repr(e))) return response.json(500, repr(e))