ASJPush/Controller/gatewayController.py

# -*- coding: utf-8 -*-
"""
@Time ： 2022/5/9 10:51
@Auth ： Locky
@File ：gatewayController.py
@IDE ：PyCharm
"""
import logging
import time

from django.views.generic.base import View

from Object.ResponseObject import ResponseObject
from Object.utils import LocalDateTimeUtil
from Service.CommonService import CommonService
from Service.EquipmentInfoService import EquipmentInfoService


class GatewayView(View):
    def get(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.GET, request, operation)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.POST, request, operation)

    def validation(self, request_dict, request, operation):
        response = ResponseObject()
        if operation == 'gatewayPush':  # 网关推送
            return self.gateway_push(request_dict, response)
        else:
            return response.json(414)

    def gateway_push(self, request_dict, response):
        logger = logging.getLogger('info')
        serial_number = request_dict.get('serial_number', None)
        src_addr = request_dict.get('src_addr', None)
        event_type = request_dict.get('event_type', None)
        alarm = request_dict.get('alarm', None)
        logger.info('---调用网关推送接口--- request_dict:{}'.format(request_dict))
        if not all([src_addr, event_type, alarm]):
            return response.json(444)

        equipment_info_list = []
        now_time = int(time.time())
        device_user_id = '160879593527813800138000'
        try:
            event_type = int(event_type)
            local_date_time = CommonService.get_now_time_str(n_time=now_time, tz=0, lang='cn')
            local_date_time = local_date_time[:10]
            equipment_info_list.append(EquipmentInfoService.get_equipment_info_obj(
                local_date_time,
                add_time=now_time,
                event_time=now_time,
                receive_time=now_time,
                device_uid=serial_number,
                event_type=event_type,
                alarm=alarm,
                device_nick_name=src_addr,
                device_user_id=device_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:
            return response.json(500, repr(e))