manyi/apps/web/api/ymd/views.py

# -*- coding: utf-8 -*-
# !/usr/bin/env python

import logging

import simplejson as json
from typing import TYPE_CHECKING

from apps.web.api.exceptions import ApiParameterError
from apps.web.api.utils import api_call, api_ok_response, api_exception_response
from apps.web.api.views import send_api_order

logger = logging.getLogger(__name__)

if TYPE_CHECKING:
    from django.core.handlers.wsgi import WSGIRequest
    from apps.web.dealer.models import Dealer
    from apilib.utils_json import JsonResponse


@api_call(logger = logger, nil = api_exception_response())
def getPortStatusFromAx(request, dealer):
    # type: (WSGIRequest, Dealer)->JsonResponse
    payload = json.loads(request.body) if request.body else {}

    default_params_list = ['deviceCode', 'createTime', 'orderNo']
    params_list = payload.keys()

    # 1. 判断差集
    different_params_list = list(set(default_params_list) - set(params_list))
    if len(different_params_list) != 0:
        raise ApiParameterError(errmsg = u'参数内容错误')

    # 2. 判断个数
    if len(params_list) != len(default_params_list):
        raise ApiParameterError(errmsg = u'参数错误')

    # 3. 调用api
    resultDict = send_api_order(payload = payload, dealer = dealer, func = 'apiGetPortStatusFromAx')

    return api_ok_response(payload = resultDict)


@api_call(logger = logger, nil = api_exception_response())
def stopAxPort(request, dealer):
    # type: (WSGIRequest, Dealer)->JsonResponse
    payload = json.loads(request.body) if request.body else {}

    default_params_list = ['deviceCode', 'createTime', 'orderNo', 'chargeIndex']
    params_list = payload.keys()

    # 1. 判断差集
    different_params_list = list(set(default_params_list) - set(params_list))
    if len(different_params_list) != 0:
        raise ApiParameterError(errmsg = u'参数内容错误')

    # 2. 判断个数
    if len(params_list) != len(default_params_list):
        raise ApiParameterError(errmsg = u'参数错误')

    # 3. 调用api
    resultDict = send_api_order(payload = payload, dealer = dealer, func = 'apiStopAxPort')

    return api_ok_response(payload = resultDict)