manyi/apps/web/api/dc/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 getPortStatusFromDc(request, dealer):
    # type: (WSGIRequest, Dealer)->JsonResponse
    payload = json.loads(request.body) if request.body else {}

    default_params_list = ['deviceCode']
    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 = 'apiGetPortStatusFromDc')

    return api_ok_response(payload = resultDict)


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

    default_params_list = ['deviceCode']
    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 = 'apiGetDevSettingsFromDc')

    return api_ok_response(payload = resultDict)


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

    default_params_list = [
        "deviceCode",
        "power1",
        "power2",
        "power3",
        "power1ratio",
        "power2ratio",
        "power3ratio",
        "fuchongTime",
        "fuchongPower",
        "maxPower",
        "icMoney",
        "time1",
        "time2",
        "time3"
    ]
    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 = 'apisetDevSettingsFromDc')

    return api_ok_response(payload = resultDict)


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

    default_params_list = ['deviceCode', 'port']
    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 = 'apiGetPortInfoFromDc')

    return api_ok_response(payload = resultDict)


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

    default_params_list = ['deviceCode', 'port', 'price', 'time']
    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 = 'apiStartDeviceForDc')

    return api_ok_response(payload = resultDict)