ASJPush/Controller/gatewayController.py

# -*- 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))