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

# -*- coding: utf-8 -*-
from apps.web.core.adapter.base import *
from apps.web.device.models import Device


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

    def analyze_event_data(self,data):
        return self.analyze_get_data(data)

    def analyze_get_data(self,data):
        temp = data[6:8]
        status = Const.DEV_WORK_STATUS_IDLE
        tempStatus = ''
        if temp == '01':
            tempStatus = u'待机'
        elif temp == '02':
            status =Const.DEV_WORK_STATUS_WORKING
            tempStatus = u'运转'
        elif temp == '03':
            status =Const.DEV_WORK_STATUS_PAUSE
            tempStatus = u'暂停'
        elif temp == '04':
            status = Const.DEV_WORK_STATUS_FAULT
            tempStatus = u'故障'
        elif temp == '05':
            status =Const.DEV_WORK_STATUS_WORKING
            tempStatus = u'参数设置'
        elif temp == '06':
            status =Const.DEV_WORK_STATUS_WORKING
            tempStatus = u'自检'
        else:
            status =Const.DEV_WORK_STATUS_IDLE
            tempStatus = u'待机'

        temp = data[8:10]
        program = ''
        if temp == '01':
            program = u'单脱水'
        elif temp == '02':
            program = u'快速'
        elif temp == '03':
            program = u'标准'
        elif temp == '04':
            program = u'大物'
        elif temp == '05':
            program = u'加热快速'
        elif temp == '06':
            program = u'加热标准'
        elif temp == '07':
            program = u'加热大物'

        temp = data[10:12]
        process = ''
        if temp == '01':
            process = u'预约'
        elif temp == '02':
            process = u'浸泡'
        elif temp == '03':
            process = u'洗涤'
        elif temp == '04':
            process = u'漂洗'
        elif temp == '05':
            process = u'脱水'
        elif temp == '06':
            process = u'主进水'

        temp = data[14:16] + data[12:14]
        leftTime= int(temp,16)

        temp = data[16:18]
        binFault = hexbyte_2_bin(temp)
        faultStr = ''
        if binFault[0] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'进水超时'
        if binFault[1] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'排水超时'
        if binFault[2] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'脱水开盖'
        if binFault[3] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'脱水不平衡'
        if binFault[4] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'通讯故障'
        if binFault[5] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'童锁开盖'
        if binFault[6] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'溢水'
        if binFault[7] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'水位传感器故障'

        temp = data[18:20]
        binFault = hexbyte_2_bin(temp)
        if binFault[0] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'数据存储故障'
        if binFault[1] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'温度传感器故障'
        if binFault[2] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'无水加热故障'
        if binFault[3] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'电机堵转故障'
        if binFault[4] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'IPM温度过高故障'
        if binFault[5] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'电机过流故障'
        if binFault[6] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'电机缺相故障'
        if binFault[7] == '1':
            status = Const.DEV_WORK_STATUS_FAULT
            faultStr = u'驱动器故障'

        if status == Const.DEV_WORK_STATUS_FAULT:
            statusInfo = faultStr
        elif status == Const.DEV_WORK_STATUS_FORBIDDEN:
            statusInfo = u'禁用'
        elif status == Const.DEV_WORK_STATUS_IDLE:
            statusInfo = u'待机'
        elif status == Const.DEV_WORK_STATUS_PAUSE:
            statusInfo = u'暂停'
        else:
            statusInfo = u'%s   当前套餐:%s   当前环节:%s' % (tempStatus,program,process)

        return {'status':status,'statusInfo':statusInfo,'leftTime':leftTime}

    def get_dev_info(self):

        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                     {'IMEI': self._device['devNo'], "funCode": "A1", "data": ""})
        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            if devInfo['rst'] == -1:
                raise ServiceException(
                    {'result': 2, 'description': u'当前洗衣机正在玩命找网络,请您稍候再试'})
            elif devInfo['rst'] == 1:
                raise ServiceException(
                    {'result': 2, 'description': u'当前洗衣机忙,无响应,请您稍候再试'})
        info = self.analyze_get_data(devInfo['data'])
        return info

    def start_device(self, package, openId, attachParas):
        info = self.get_dev_info()

        if info['status'] == Const.DEV_WORK_STATUS_FAULT:
            raise ServiceException(
                {'result': 2, 'description': u'当前洗衣机故障：%s' % info['statusInfo']})

        if u'待机' not in info['statusInfo']:
            raise ServiceException(
                {'result': 2, 'description': u'当前洗衣机%s,请稍候使用' % info['statusInfo']})

        data = ''
        washName = package['name']
        temp = ''
        if washName == Const.WASHER_BOX_SET_TQJ:
            temp = '10'
        elif washName == Const.WASHER_BOX_SET_DTS:
            temp = '08'
        elif washName == Const.WASHER_BOX_SET_KSX:
            temp = '04'
        elif washName == Const.WASHER_BOX_SET_BZX:
            temp = '02'
        elif washName == Const.WASHER_BOX_SET_DWX:
            temp = '01'
        data = data + temp
        data = data + '00'

        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "81", "data": data},
                                    timeout = MQTT_TIMEOUT.START_DEVICE)
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，您的金币还在，重试不需要重新付款，建议您试试旁边其他设备，或者试试投硬币，或者稍后再试哦'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，您的金币还在，设备暂时不能网络支付，请尝试投币哦'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误，您的金币还在，款请尝试投币哦'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'主板见通讯失败，请试试投币，并报障给老板哦'})
        Device.update_dev_control_cache(self._device['devNo'], {'openId':openId})
        return result

    def get_device_function_by_key(self,keyName):
        if keyName == 'workingStatus':
            infoDict = self.get_dev_info()
            return {"workingStatus": infoDict['statusInfo']}
        return None

    def stop_pause_continue(self,state):
        cmd = ''
        if state == 'stop':
            cmd = '20'
        elif state == 'pause':
            cmd = '40'
        elif state == 'continue':
            cmd = '80'
        cmd += '00'

        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "81", "data": cmd})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，建议您试试旁边其他设备，或者试试投硬币，或者稍后再试哦'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，设备暂时不能网络支付，请尝试投币哦'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误，请尝试投币哦'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'主板见通讯失败，请试试投币，并报障给老板哦'})
        if state == 'stop':
            Device.update_dev_control_cache(self._device['devNo'], {'status':Const.DEV_WORK_STATUS_IDLE})
        else:
            Device.update_dev_control_cache(self._device['devNo'], {'status':Const.DEV_WORK_STATUS_WORKING})

        return result

    def get_wash_config(self):
        result = {
                    Const.WASHER_BOX_DTS :{'price':0,'time':0},
                    Const.WASHER_BOX_KS :{'price':0,'time':0},
                    Const.WASHER_BOX_BZ :{'price':0,'time':0},
                    Const.WASHER_BOX_DW:{'price':0,'time':0},
                    Const.WASHER_BOX_YEBENG:{'price':0,'time':0},
                    Const.WASHER_BOX_JRKS :{'price':0,'time':0},
                    Const.WASHER_BOX_JRBZ :{'price':0,'time':0},
                    Const.WASHER_BOX_JRDW :{'price':0,'time':0},
                }

        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                     {'IMEI': self._device['devNo'], "funCode": "A2", "data": ""})
        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            if devInfo['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，建议您试试旁边其他设备，或者试试投硬币，或者稍后再试哦'})
            elif devInfo['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，设备暂时不能网络支付，请尝试投币哦'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        priceData = devInfo['data'][6:20]
        result[Const.WASHER_BOX_DTS]['price'] = int(priceData[0:2],16)
        result[Const.WASHER_BOX_KS]['price'] = int(priceData[2:4],16)
        result[Const.WASHER_BOX_BZ]['price'] = int(priceData[4:6],16)
        result[Const.WASHER_BOX_DW]['price'] = int(priceData[6:8],16)
        result[Const.WASHER_BOX_JRKS]['price'] = int(priceData[8:10],16)
        result[Const.WASHER_BOX_JRBZ]['price'] = int(priceData[10:12],16)
        result[Const.WASHER_BOX_JRDW]['price'] = int(priceData[12:14],16)

        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                     {'IMEI': self._device['devNo'], "funCode": "A3", "data": ""})
        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            if devInfo['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，建议您试试旁边其他设备，或者试试投硬币，或者稍后再试哦'})
            elif devInfo['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，设备暂时不能网络支付，请尝试投币哦'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        timeData = devInfo['data'][6:22]
        result[Const.WASHER_BOX_DTS]['time'] = int(timeData[0:2],16)
        result[Const.WASHER_BOX_KS]['time'] = int(timeData[2:4],16)
        result[Const.WASHER_BOX_BZ]['time'] = int(timeData[4:6],16)
        result[Const.WASHER_BOX_DW]['time'] = int(timeData[6:8],16)
        result[Const.WASHER_BOX_YEBENG]['time'] = int(timeData[8:10],16)
        result[Const.WASHER_BOX_JRKS]['time'] = int(timeData[10:12],16)
        result[Const.WASHER_BOX_JRBZ]['time'] = int(timeData[12:14],16)
        result[Const.WASHER_BOX_JRDW]['time'] = int(timeData[14:16],16)

        return result

    def set_wash_config(self,washConfig):
        priceTemp,timeTemp = '',''

        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_DTS]['price'])
        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_KS]['price'])
        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_BZ]['price'])
        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_DW]['price'])
        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_JRKS]['price'])
        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_JRBZ]['price'])
        priceTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_JRDW]['price'])

        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_DTS]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_KS]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_BZ]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_DW]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_YEBENG]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_JRKS]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_JRBZ]['time'])
        timeTemp += decimal_2_hexByte(washConfig[Const.WASHER_BOX_JRDW]['time'])

        priceTemp += '00'

        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "82", "data": priceTemp})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'设置价格失败，主板间通讯失败，检查下是否GSM通讯模块和主板之间的连接'})

        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "83", "data": timeTemp})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'设置时间失败，主板间通讯失败，检查下是否GSM通讯模块和主板之间的连接'})

        return result

    #快速水位设定 标准水位设定 大物水位设定 脱水转速设定 温度设定
    def set_process_config(self,config):
        cmd = decimal_2_hexByte(config['kssw']) + decimal_2_hexByte(config['bzsw'])\
              + decimal_2_hexByte(config['dwsw']) + decimal_2_hexByte(config['tszs']) + decimal_2_hexByte(config['wdsz']) + '000000'

        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "84", "data": cmd})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'设置过程参数失败，主板间通讯失败，检查下是否GSM通讯模块和主板之间的连接'})

        return result

    def get_process_config(self):
        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": 'A4', "data": ""})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        temp = result['data'][6:16]
        result['kssw'] = int(temp[0:2],16)
        result['bzsw'] = int(temp[2:4],16)
        result['dwsw'] = int(temp[4:6],16)
        result['tszs'] = int(temp[6:8],16)
        result['wdsz'] = int(temp[8:10],16)

        return result

    def set_special_config(self,specialConfig):
        cmd = ''
        bConfig = '000000'+ str(specialConfig['qcbcbh']) + str(specialConfig['ddjy'])
        hexConfig = decimal_2_hexByte(int(bConfig,2))
        cmd =cmd + hexConfig +'00'
        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "85", "data": cmd})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'设置过程参数失败，主板间通讯失败，检查下是否GSM通讯模块和主板之间的连接'})

        return result

    def press_down_key(self,keyName):
        if keyName in ['stop','pause','continue']:
            return self.stop_pause_continue(keyName)

        self.set_control_config(keyName)

    def set_control_config(self,buttonName):
        cmd = ''
        if buttonName == 'ccms1' :
            cmd = '01'
        elif buttonName == 'ccms2':
            cmd = '02'
        elif buttonName == 'tz':
            cmd = '03'
        elif buttonName == 'js':
            cmd = '04'
        elif buttonName == 'ajkq':
            cmd = '05'
        elif buttonName == 'ajgb':
            cmd = '06'
        elif buttonName == 'tbkq':
            cmd = '07'
        elif buttonName == 'tbgb':
            cmd = '08'

        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "86", "data": cmd})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        resCode = result['data'][6:8]
        if resCode == '0F':
            raise ServiceException({'result': 2, 'description': u'设置过程参数失败，主板间通讯失败，检查下是否GSM通讯模块和主板之间的连接'})

        return result

    def get_special_config(self):
        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], "funCode": "A5", "data": ''})
        if result['rst'] != 0:
            if result['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'洗衣机正在玩命找网络，请稍候再试'})
            elif result['rst'] == 1:
                raise ServiceException({'result': 2, 'description': u'洗衣机主板连接故障，请检查下GSM模块和主板之间的连接'})
            else:
                raise ServiceException({'result': 2, 'description': u'系统错误'})

        temp = result['data'][6:8]
        binTemp = hexbyte_2_bin(temp)[::-1]
        result['ddjy'] = int(binTemp[0])
        result['qcbcbh'] = int(binTemp[1])

        return result

    def get_dev_setting(self):
        sConfig = self.get_special_config()
        wConfig = self.get_wash_config()
        pConfig = self.get_process_config()

        para = {}
        para.update(sConfig)
        para.update(wConfig)
        para.update(pConfig)

        #为了配合前台，还需要给他转义下
        para['kssw'] = pConfig['kssw']
        para['bzsw'] = pConfig['bzsw']
        para['dwsw'] = pConfig['dwsw']
        para['liquidPump'] = wConfig[Const.WASHER_BOX_YEBENG]['time']
        para['tszs'] = pConfig['tszs']
        para['wdsz'] = pConfig['wdsz']
        para['powerDownMemory'] = True if sConfig['ddjy'] == 1 else False
        para['protect'] = True if sConfig['qcbcbh'] == 1 else False

        return para    
    
    def set_device_function(self,request,lastSetConf):
        oldSConfig = {'ddjy': lastSetConf['ddjy'], 'qcbcbh': lastSetConf['qcbcbh']}

        if request.POST.has_key('powerDownMemory'):
            powerDownMemory = bool(request.POST.get('powerDownMemory'))
            ddjy = 1 if powerDownMemory else 0
            oldSConfig.update({'ddjy': ddjy})
            lastSetConf.update({'ddjy': ddjy})
            self.set_special_config(oldSConfig)

        if request.POST.has_key('protect'):
            protect = bool(request.POST.get('protect'))
            qcbcbh = 1 if protect else 0
            oldSConfig.update({'qcbcbh': qcbcbh})
            lastSetConf.update({'qcbcbh': qcbcbh})
            self.set_special_config(oldSConfig)
    
    def set_device_function_param(self,request,lastSetConf):
        oldPConfig = {'kssw': lastSetConf['kssw'], 'bzsw': lastSetConf['bzsw'], 'dwsw': lastSetConf['dwsw'],
                      'tszs': lastSetConf['tszs'], 'wdsz': lastSetConf['wdsz']}

        kssw = request.POST.get('kssw', None)
        if kssw:
            oldPConfig['kssw'] = int(kssw)
        bzsw = request.POST.get('bzsw', None)
        if bzsw:
            oldPConfig['bzsw'] = int(bzsw)
        dwsw = request.POST.get('dwsw', None)
        if dwsw:
            oldPConfig['dwsw'] = int(dwsw)
        tszs = request.POST.get('tszs', None)
        if tszs:
            oldPConfig['tszs'] = int(tszs)
        wdsz = request.POST.get('wdsz', None)
        if wdsz:
            oldPConfig['wdsz'] = int(wdsz)

        if kssw or bzsw or dwsw or tszs or wdsz:
            self.set_process_config(oldPConfig)

        if request.POST.has_key('nightPump'):
            oldWConfig = {
                Const.WASHER_BOX_DTS: lastSetConf[Const.WASHER_BOX_DTS],
                Const.WASHER_BOX_KS: lastSetConf[Const.WASHER_BOX_KS],
                Const.WASHER_BOX_BZ: lastSetConf[Const.WASHER_BOX_BZ],
                Const.WASHER_BOX_DW: lastSetConf[Const.WASHER_BOX_DW],
                Const.WASHER_BOX_YEBENG: lastSetConf[Const.WASHER_BOX_YEBENG],
                Const.WASHER_BOX_JRKS: lastSetConf[Const.WASHER_BOX_JRKS],
                Const.WASHER_BOX_JRBZ: lastSetConf[Const.WASHER_BOX_JRBZ],
                Const.WASHER_BOX_JRDW: lastSetConf[Const.WASHER_BOX_JRDW],
            }

            yebeng = request.POST.get('nightPump', None)
            if yebeng:
                oldWConfig[Const.WASHER_BOX_YEBENG]['time'] = yebeng
                
            self.set_wash_config(oldWConfig)
    
    def count_down(self,request,dev,agent,group,devType,lastOpenId,port=None):
        devInfo = self.get_dev_info()

        if devInfo['rst'] == -1:
            return JsonResponse({'result': 0, 'description':  u'洗衣机网络不太好，您试下投币，或者周边其他设备，或者稍后再试试哦'})
        if devInfo['rst'] == 1:
            return JsonResponse({'result': 0, 'description':  u'洗衣机设备主板连接故障，请投币试试'})

        if devInfo['status'] == Const.WASHER_BOX_GZ:
            statusDesc = Const.WASHER_STATUS_CODE_DESC[Const.WASHER_BOX_GZ]
            if len(devInfo['faultList']) > 0:
                faultDesc = Const.EVENT_CODE_DESC[devInfo['faultList'][0]]
                desc = '出现了%s,%s' % (statusDesc, faultDesc)
            else:
                desc = '出现了%s' % statusDesc
            return JsonResponse({'result': 0, 'description': u'洗衣机' + desc + u'。您联系下老板哦'})

        return JsonResponse(
            {
                'result': 1,
                'description': '',
                'payload': {
                    'surplus': devInfo['surplus'],
                    'sum': devInfo['surplus'],
                    'name': group['groupName'],
                    'address': group['address'],
                    'code': devType.get('code'),
                    'orderProcessing': False,
                    'logicalCode': dev['logicalCode'],
                    'user': 'me' if lastOpenId == request.user.openId else 'notme',
                    'agentFeatures': agent.features,
                }
            })