ASJPush/Controller/gatewayController.py

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

from django.views.generic.base import View

from Object.ResponseObject import ResponseObject


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.gatewayPush(request_dict, response)
        else:
            return response.json(414)

    def gatewayPush(self, request_dict, response):
        logger = logging.getLogger('info')
        serial_number = request_dict.get('serial_number', None)
        zbsrc = request_dict.get('zbsrc', None)
        zbstatus = request_dict.get('zbstatus', None)
        time_stamp = request_dict.get('time_stamp', None)
        time_stamp_token = request_dict.get('time_stamp_token', None)
        logger.info(
            '---调用网关推送接口--- zbsrc:{},zbstatus:{},time_stamp:{},time_stamp_token:{}'.format(
                zbsrc,
                zbstatus,
                time_stamp,
                time_stamp_token))
        try:
            return response.json(0)
        except Exception as e:
            return response.json(500, repr(e))