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

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

import time

from apps.web.constant import DeviceOnlineStatus, ErrorCode, Const, DeviceCmdCode, DeviceErrorCodeDesc, MQTT_TIMEOUT
from apps.web.core.adapter.base import fill_2_hexByte, SmartBox
from apps.web.core.exceptions import ServiceException
from apps.web.core.networking import MessageSender
from apps.web.device.models import Device

reason_dict = {
    0x00: u'待机可用',
    0x01: u'预约中',
    0x02: u'消毒清洁中',
    0x03: u'洗衣工作中',
    0x04: u'洗衣机洗涤结束',
    0x05: u'洗衣机自检中',
    0x06: u'进水超时，请检查进水阀或者水龙头',
    0x07: u'排水超时，请检查排水系统',
    0x08: u'脱水时撞桶，请调整衣服位置，然后关上门盖',
    0x09: u'脱水开盖，请关好门盖',
    0x0a: u'水位传感器异常，请检查水位传感器',
    0x0b: u'溢水报警，请检查进水阀或洗衣机控制器',
    0x0c: u'电机故障，请检查电机或洗衣机控制器',
    0x0d: u'通讯故障',
    0xfd: u'IMEI未配置，请重启模块',
    0xfe: u'投币金额不足'
}


class SimaierWasher(SmartBox):
    def get_port_status_from_dev(self):
        pass

    def check_dev_status(self, attachParas = None):
        if not self.device.need_fetch_online:
            raise ServiceException(
                {'result': 2, 'description': DeviceErrorCodeDesc.get(ErrorCode.DEVICE_CONN_CHECK_FAIL)})

        if self.device.online == DeviceOnlineStatus.DEV_STATUS_ONLINE:
            retry = 3
            timeout = 12
        else:
            retry = 2
            timeout = 10

        operation_result = self.get_dev_info(retry = retry, timeout = timeout)

        if operation_result['rst'] != ErrorCode.DEVICE_SUCCESS:
            if operation_result['rst'] == ErrorCode.DEVICE_CONN_FAIL:
                raise ServiceException(
                    {
                        'result': 2,
                        'description': DeviceErrorCodeDesc.get(ErrorCode.DEVICE_CONN_CHECK_FAIL)
                    })
            elif operation_result['rst'] == ErrorCode.BOARD_UART_TIMEOUT:
                raise ServiceException(
                    {
                        'result': 2,
                        'description': u'设备忙无响应，请您稍候再试。也可能是您的设备版本过低，暂时不支持此功能'
                    })
            else:
                raise ServiceException(
                    {
                        'result': 2,
                        'description': u'检查设备状态失败({})'.format(operation_result['rst'])
                    })

        _result = self.analyze_get_data(operation_result['data'])
        if _result['comm_result'] != 'SUCCESS':
            raise ServiceException(
                {'result': 2,
                 'description': _result['comm_desc']})

    def __init__(self, device):
        super(SimaierWasher, self).__init__(device)

    # 足疗机的事件报文和get上来的报文一样，直接调用即可
    def analyze_event_data(self, data):
        return self.analyze_get_data(data)

    # 解析get到的报文信息
    def analyze_get_data(self, data):
        result = {'comm_result': 'SUCCESS', 'comm_desc': 'SUCCESS', 'status': Const.DEV_WORK_STATUS_IDLE,
                  'statusInfo': '', 'left_time': 0}

        crc_result = int(data[2:4], 16)
        if crc_result != 0x06:
            result['comm_result'] = 'FAILURE'
            result['comm_desc'] = u'CRC校验错,请联系平台'
            return result

        status = int(data[8:10], 16)
        if status in reason_dict:
            if status == 0x01:
                result['status'] = Const.DEV_WORK_STATUS_APPOINTMENT
                result['statusInfo'] = reason_dict[status]
            elif status == 0x03:
                result['status'] = Const.DEV_WORK_STATUS_WORKING
                result['statusInfo'] = reason_dict[status]
            elif status in [0x06, 0x07, 0x08, 0x09, 0x0a, 0x0b, 0x0c, 0x0d, 0xfd]:
                result['status'] = Const.DEV_WORK_STATUS_FAULT
                result['statusInfo'] = reason_dict[status]
            elif status in [0x00, 0x04]:
                result['status'] = Const.DEV_WORK_STATUS_IDLE
                result['statusInfo'] = reason_dict[status]
            elif status in [0x02, 0x05]:
                result['status'] = Const.DEV_WORK_STATUS_MAINTENANCE
                result['statusInfo'] = reason_dict[status]
        else:
            result['status'] = Const.DEV_WORK_STATUS_FAULT
            result['statusInfo'] = u'未知状态'

        result['left_time'] = int(data[10:12], 16)
        return result

    def get_dev_info(self, retry, timeout):
        result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'IMEI': self._device['devNo'], 'funCode': '01', 'data': '00'}, timeout = timeout,
                                    retry = retry)
        if result['rst'] != 0:
            return {'rst': -1, 'isOffline': 1}

        result.update(self.analyze_get_data(result['data']))
        return result

    def start_device(self, package, openId, attachParas):
        MODE = {
            u'加强洗': 0x1,
            u'标准洗': 0x2,
            u'快速洗': 0x3,
            u'单脱水': 0x4,
            u'桶消毒': 0x5,
            u'洗衣机自检': 0x6,
        }

        mode = hex(int(MODE[package['name']]))

        operation_result = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                              {'IMEI': self._device['devNo'], 'funCode': '02',
                                               'data': fill_2_hexByte(mode, 2)}, timeout = MQTT_TIMEOUT.START_DEVICE)

        if operation_result['rst'] != ErrorCode.DEVICE_SUCCESS:
            if operation_result['rst'] == ErrorCode.DEVICE_CONN_FAIL:
                raise ServiceException(
                    {'result': 2, 'description': DeviceErrorCodeDesc.get(ErrorCode.DEVICE_START_CONN_FAIL)})
            elif operation_result['rst'] == ErrorCode.BOARD_UART_TIMEOUT:
                raise ServiceException(
                    {'result': 2,
                     'description': u'设备忙无响应,请您稍候再试。也可能是您的设备版本过低，暂时不支持此功能'})
            else:
                raise ServiceException(
                    {'result': 2,
                     'description': DeviceErrorCodeDesc.get(ErrorCode.DEVICE_START_FAILURE).format(operation_result['rst'])})

        _result = self.analyze_get_data(operation_result['data'])
        _result['rst'] = ErrorCode.DEVICE_SUCCESS

        if _result['comm_result'] != 'SUCCESS':
            raise ServiceException(
                {'result': 2,
                 'description': _result['comm_desc']})

        if _result['status'] != Const.DEV_WORK_STATUS_WORKING:
            raise ServiceException(
                {'result': 2,
                 'description': _result['statusInfo']})

        if _result['left_time'] == 0:
            Device.invalid_device_control_cache(self._device['devNo'])
            return _result

        left_time = _result['left_time']

        start_time = int(time.time())
        finished_time = start_time + left_time * 60
        Device.update_dev_control_cache(
            self._device['devNo'],
            {
                'openId': openId,
                'status': Const.DEV_WORK_STATUS_WORKING,
                'startTime': start_time,
                'finishedTime': finished_time
            })
        return _result

    def support_count_down(self, openId = None, port = None):
        return False