manyi/apps/web/core/adapter/DcFastCharge.py

# -*- coding: utf-8 -*-
# !/usr/bin/env python
import datetime
import re
from decimal import Decimal

from apps.web.constant import DeviceCmdCode, Const
from apps.web.core.adapter.base import SmartBox
from apps.web.core.exceptions import ServiceException
from apps.web.core.networking import MessageSender
from apps.web.device.models import Device
from apps.web.user.models import ConsumeRecord


class FastCharge(SmartBox):
    def __init__(self, device):
        super(FastCharge, self).__init__(device)

    def _check_package(self, package):
        """
        获取设备启动的发送数据 根据设备的当前模式以及套餐获取
        :param package:
        :return:
        """
        devConf = self.get_device_configs()
        coinElec = devConf.get('coinElec', 10)  # 单位是0.1度
        coinTime = devConf.get('coinMin', 240)

        maxTotalTime = devConf.get('maxTotalTime', 0) or 720
        coins = float(package.get('coins'))
        elec = coins * coinElec * 0.1
        _time = min(coins * coinTime, maxTotalTime)

        return _time, elec, coins

    def disable_app_device(self, switch=True):
        # type:(bool) -> None
        otherConf = self.device.get('otherConf', {})
        otherConf['disableDevice'] = switch
        Device.objects.filter(devNo=self.device['devNo']).update(otherConf=otherConf)
        Device.invalid_device_cache(self.device['devNo'])

    def reverse_hex(self, data):
        # type:(str) -> str
        if not isinstance(data, str):
            raise TypeError

        return ''.join(list(reversed(re.findall(r'.{2}', data))))

    def encode_str(self, data, length=2, ratio=1.0, base=16):
        # type:(any,int,float,int) -> str
        if not isinstance(data, Decimal):
            data = Decimal(data).quantize(Decimal('0.00'))
        if not isinstance(length, str):
            length = str(length)
        if not isinstance(ratio, Decimal):
            ratio = Decimal(ratio)
        end = 'X' if base == 16 else 'd'
        encodeStr = '%.' + length + end
        encodeStr = encodeStr % (data * ratio)
        return encodeStr

    def decode_str(self, data, ratio=1.0, base=16, reverse=False):
        # type:(str,float,int,bool) -> str
        """
            ratio:比率单位转换
        """
        if not isinstance(data, str):
            data = str(data)
        if reverse:
            data = ''.join(list(reversed(re.findall(r'.{2}', data))))

        return '%.10g' % (int(data, base) * ratio)

    def decode_long_hex_to_list(self, data, split=2, ratio=1.0, base=16):
        # type:(str,int,float,int) -> list
        """
            return: list
        """
        if len(data) % split != 0:
            raise Exception('Invalid data')

        pattern = r'.{%s}' % split
        hex_list = re.findall(pattern, data)
        hex_list = map(lambda x: self.decode_str(x, ratio=ratio, base=base), hex_list)
        return hex_list

    def check_params_range(self, params, minData=None, maxData=None, desc=''):
        # type:(str,float,float,str) -> str
        """
            检查参数,返回字符串参数
        """
        if params is None:
            raise ServiceException({'result': 2, 'description': u'参数错误.'})
        if not isinstance(params, Decimal):
            params = Decimal(params)
        if not minData and maxData:
            if not isinstance(maxData, Decimal):
                maxData = Decimal(maxData)
            if params <= maxData:
                return '%g' % params
            else:
                raise ServiceException({'result': 2, 'description': u'%s超出可选范围,可选最大值为%g' % (desc, maxData)})
        if not maxData and minData:
            if not isinstance(minData, Decimal):
                minData = Decimal(minData)
            if minData <= params:
                return '%g' % params
            else:
                raise ServiceException({'result': 2, 'description': u'%s超出可选范围,可选最小值为%g' % (desc, minData)})

        if not minData and not maxData:
            return '%g' % params

        else:
            if not isinstance(minData, Decimal):
                minData = Decimal(minData)
            if not isinstance(maxData, Decimal):
                maxData = Decimal(maxData)
            if minData <= params <= maxData:
                return '%g' % params
            else:
                raise ServiceException(
                    {'result': 2, 'description': u'%s参数超出可选范围,可取范围为%g-%g' % (desc, minData, maxData)})

    def send_mqtt(self, funCode, data, cmd=DeviceCmdCode.OPERATE_DEV_SYNC, order_id=None):
        """
            发送mqtt 指令210  返回data
        """
        if not isinstance(funCode, str):
            funCode = str(funCode)

        if not isinstance(data, str):
            data = str(data)
        payload = {'IMEI': self.device['devNo'], 'funCode': funCode, 'data': data}
        if order_id:
            payload.update({'order_id': order_id})
        result = MessageSender.send(self.device, cmd, payload)
        if 'rst' in result and result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException(
                    {'result': 2, 'description': u'该设备正在玩命找网络,请您稍候再试', 'rst': -1})
            elif result['rst'] == 1:
                raise ServiceException(
                    {'result': 2, 'description': u'该设备忙,无响应,请您稍候再试。也可能是您的设备版本过低，暂时不支持此功能', 'rst': 1})
        else:
            if cmd in [DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, DeviceCmdCode.PASSTHROUGH_OPERATE_DEV_NO_RESPONSE]:
                return

            if 'order_id' in result or 'order_info' in result:
                return result
            else:
                return result.get('data', '')

    @staticmethod
    def port_is_busy(port_dict):
        if not port_dict:
            return False

        if 'billingType' not in port_dict:
            return False

        if 'status' not in port_dict:
            return False

        if 'coins' not in port_dict:
            return False

        if port_dict['billingType'] not in ['time', 'elec']:
            return False

        if port_dict['billingType'] == 'time':
            if 'needTime' not in port_dict:
                return False
        else:
            if 'needElec' not in port_dict:
                return False

        if port_dict['status'] == Const.DEV_WORK_STATUS_WORKING:
            return True
        else:
            return False

    def do_update_configs(self, updateDict):
        dev = Device.objects.get(devNo=self.device.devNo)
        deviceConfigs = dev.otherConf.get('deviceConfigs', {})
        deviceConfigs.update(updateDict)
        dev.otherConf['deviceConfigs'] = deviceConfigs
        dev.save()
        Device.invalid_device_cache(self.device.devNo)

    def get_device_configs(self):
        dev = Device.get_dev(self.device.devNo)
        deviceConfigs = dev.get('otherConf', {}).get('deviceConfigs', {})
        return deviceConfigs

    def start_device_realiable(self, order):
        # type:(ConsumeRecord)->dict

        package = order.package
        coins = package.get('coins', 0)

        deviceType = '03'
        port = order.used_port
        userType = '01'
        userNum = '{:0>16s}'.format(order.orderNo)
        sequanceNo = '{:0>16s}'.format(order.orderNo) + datetime.datetime.now().strftime('%Y%m%d%H%M%S')
        balance = self.encode_str(coins, length=8, ratio=100.0)
        chargeType = '00'  # 00 为立即充电  01为 预约充电
        featureStr = 'FF'

        self.get_consumption_rules()


        return {}

    def get_dev_setting(self):
        deviceConfigs = self.get_device_configs()
        if not deviceConfigs:
            pass
        packages = [{'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '00:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '03:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '06:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '09:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '12:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '15:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '18:00'},
                    {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '21:00'}]

        return {'package': packages}

    def set_device_function_param(self, request, lastSetConf):
        print request, lastSetConf

    def get_consumption_rules(self):
        packages = [
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '00:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '03:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '06:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '09:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '12:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '15:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '18:00'},
            {'serviceFee': '2.5', 'parkingFee': '2.5', 'unitPrice': '2.5', 'startTime': '21:00'},

        ]
        data = ''
        count = 0
        for item in packages:
            count += 1
            hour, min = item['startTime'].split(':')
            data += self.encode_str(hour)
            data += self.encode_str(min)
            if count % 2 == 0:
                data += self.encode_str(item['unitPrice'])
                data += self.encode_str(item['serviceFee'])
                data += self.encode_str(item['parkingFee'])
        return data

    def stop(self, port=None):
        data = {
            'port': int(port),
            'remote_type': 0,
        }
        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    data)