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

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

from apps.common.utils import int_to_hex
from apps.web.constant import DeviceCmdCode, MQTT_TIMEOUT, 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


class WasherBox(SmartBox):

    WORK_MODE = {
        u"加强洗": "01",       # 工作46分钟
        u"标准洗": "02",       # 工作38分钟
        u"快速洗": "03",       # 工作22分钟
        u"单脱水": "04",       # 工作06分钟
        u"桶消毒": "05",       # 工作04分钟
        u"自检": "06"          # 工作30秒
    }

    STATUS_CODE_INFO = {
        '00': u'待机中',
        '01': u'预约中',
        '02': u'消毒清洁中',
        '03': u'洗衣工作中',
        '04': u'洗衣机洗涤结束',
        '05': u'洗衣机自检中',
        '06': u'进水超时',
        '07': u'排水超时',
        '08': u'脱水时撞桶',
        '09': u'脱水开盖',
        '0A': u'水位传感器异常',
        '0B': u'溢水报警',
        '0C': u'电机故障',
        '0D': u'通讯故障',
        'FD': u'IMEI',
        'FE': u'投币金额',
    }

    @staticmethod
    def _parse_status(status):
        return WasherBox.STATUS_CODE_INFO.get(status, u"未知状态")

    def _send_data(self, funCode, data, cmd=None, timeout=None):
        result = MessageSender.send(self.device, cmd or DeviceCmdCode.OPERATE_DEV_SYNC, {
            "IMEI": self.device.devNo,
            "data": data,
            "funCode": funCode
        }, timeout = timeout or MQTT_TIMEOUT.NORMAL)

        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'系统错误'})
        return result

    def _start(self, workMode):
        result = self._send_data("02", workMode, timeout = MQTT_TIMEOUT.START_DEVICE)
        data = result.get("data", "")
        if data[8:10] != "03":
            status = WasherBox._parse_status(data[8:10])
            raise ServiceException({"result": 2, "description": u"启动失败, {}".format(status)})

        return result

    def _occupy(self, _time):
        """
        预约洗衣机 时间不在8-20默认15分钟
        :param _time:
        :return:
        """
        if 8 < _time < 15:
            raise ServiceException({"result": 2, "description": u"预约时间范围在8-20分钟"})
        timeHex = int_to_hex(_time, lens=2)
        result = self._send_data("03", timeHex)
        data = result.get("data", "")
        if data[8:10] != "01":
            raise ServiceException({"result": 2, "description": u"预约失败"})

    def _cancel_occupy(self):
        """
        取消预约
        :return:
        """
        self._send_data("05", "00")

    def _query_work_status(self):
        result = self._send_data("01", "00")
        data = result.get("data", "")
        status = WasherBox._parse_status(data[8:10])
        leftTime = int(data[10:12], 16)

        return {
            "status": status,
            "leftTime": leftTime,
            "statusCode": data[8:10]
        }

    def start_device(self, package, openId, attachParas):
        # 首先校验洗衣机状态
        statusInfo = self._query_work_status()
        if statusInfo.get("statusCode") != "00":
            raise ServiceException({"result": 2, "description": u"洗衣机当前正在工作，请稍后重试"})

        # 然后 找套餐
        packName = package.get("name")
        workMode = WasherBox.WORK_MODE.get(packName)
        if not workMode:
            raise ServiceException({"result": 2, "description": "当前洗衣机不支持该启动模式，请联系相应经销商解决"})

        # 发指令
        result = self._start(workMode)

        # 写缓存
        data = result.get("data", "")
        leftTime = int(data[10:12], 16)
        devCache = {
            "openId": openId,
            "washName": packName
        }
        Device.update_dev_control_cache(self.device.devNo, devCache)

        result["finishedTime"] = int(time.time()) + 60 * leftTime
        return result

    #获取设备的当前状态信息，用于控制面板按钮
    def get_device_function_by_key(self, keyName):
        if keyName == 'workingStatus':
            status_info = self._query_work_status()
            leftTime = status_info['leftTime']
            code = status_info['statusCode']
            if code not in ['03','02']:
                leftTime = None
            if leftTime > 47:
                leftTime = None
            return {"workingStatus": status_info['status'],'leftTime': leftTime}
        return None

    # 控制面板
    def press_down_key(self, keyName):
        '''
            按钮控制面板
        '''
        cmd = 02
        #获取洗衣机状态
        status_info = self._query_work_status()

        # 自检
        if keyName == u'zjStart':
            if status_info['statusCode'] == '03' :
                raise ServiceException({"result": 2, "description": u"请停止洗衣机"})
            if status_info['statusCode'] == '02' :
                raise ServiceException({"result": 2, "description": u"请等待消毒完成"})
            mode = self.WORK_MODE[u'自检']
            return self._send_data(cmd, mode)

        #桶消毒过程点击停止后会进入一个假死的结束状态（04）,需要从新发送两次才能正常操作(屏蔽掉，让他自己正常结束)
        if status_info['statusCode'] == '02':
            raise ServiceException({"result": 2, "description": u"桶消毒正在工作中，请稍等"})


        #仅仅用于停止
        if keyName == u'stop':
            if status_info['statusCode'] == '00':
                raise ServiceException({"result": 2, "description": u"洗衣机未启动"})
            mode = self.WORK_MODE[u'自检']
            return self._send_data(cmd, mode)

        #洗衣机不在待机状态
        if status_info['statusCode'] != '00':
            raise ServiceException({"result": 2, "description": u"洗衣机正在工作中"})

        if keyName == u'dtStart':
            mode = self.WORK_MODE[u'单脱水']
        elif keyName == u'ksStart':
            mode = self.WORK_MODE[u'快速洗']
        elif keyName == u'bzStart':
            mode = self.WORK_MODE[u'标准洗']
        elif keyName == u'jqStart':
            mode = self.WORK_MODE[u'加强洗']
        elif keyName == u'xdStart':
            mode = self.WORK_MODE[u'桶消毒']
        else:
            raise ServiceException({"result": 2, "description": u"参数错误"})

        result = self._send_data(cmd, mode)
        data = result.get("data", "")
        status = WasherBox._parse_status(data[8:10])
        if status == u"未知状态":
            raise ServiceException({'result': 2, 'description': u'洗衣机出现未知错误，请停止后重试'})


        if keyName == '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