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

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

import time

from apilib.utils_json import JsonResponse
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 TimeSwitchBox2(SmartBox):
    def test(self, coins):
        return MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                  {'IMEI': self._device['devNo'], "funCode": '01', 'data': '0101'})

    def start_device(self, package, openId, attachParas):
        infoDict = self.get_dev_status_from_dev()
        if infoDict['switch']:
            raise ServiceException({'result': 2, 'description': u'足疗机已经开机了哦！还有%s分钟结束' % infoDict['leftTime']})

        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                     {'IMEI': self._device['devNo'], "funCode": '55', 'data': '0101'},
                                     timeout = MQTT_TIMEOUT.START_DEVICE)

        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'足疗机正在忙，无响应，您的金币还在，请稍后再试哦'})

        data = devInfo['data'][6::]
        switch = True if data[0:2] == '01' else False
        if not switch:
            raise ServiceException({'result': 2, 'description': u'足疗机启动失败，您的金币还在，请您再重试看看吧'})

        shake = True if data[2:4] == '01' else False
        hot = True if data[4:6] == '01' else False
        mode = 'mode%s' % (int(data[6:8]))
        leftTime = int(data[8:10], 16)

        # 这款足疗机的运行时间固定是15分钟
        Device.update_dev_control_cache(
            self._device['devNo'],
            {
                'status': Const.DEV_WORK_STATUS_WORKING,
                'switch': switch,
                'shake': shake,
                'hot': hot,
                'mode': mode,
                'leftTime': leftTime,
                'finishedTime': int(time.time()) + leftTime * 60
            })
        return devInfo

    def get_dev_status_from_dev(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                     {'IMEI': self._device['devNo'], "funCode": '55', 'data': '010F'})

        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'足疗机正在忙，无响应，请稍后再试哦'})

        data = devInfo['data'][6::]
        switch = True if data[0:2] == '01' else False
        shake = True if data[2:4] == '01' else False
        hot = True if data[4:6] == '01' else False
        mode = 'mode%s' % (int(data[6:8]))
        leftTime = int(data[8:10], 16)
        if not switch:
            leftTime = 0
        return {'switch': switch, 'shake': shake, 'hot': hot, 'mode': mode, 'leftTime': leftTime}

    def get_left_time(self):
        infoDict = self.get_dev_status_from_dev()
        return infoDict['leftTime']

    def press_button(self, buttonName, value):
        if buttonName == 'mode':
            buttonName = value

        data = '01'
        cmdDict = {'start': '01', 'shake': '02', 'hot': '03', 'mode1': '04', 'mode2': '05', 'mode3': '06',
                   'mode4': '07'}
        data += cmdDict[buttonName]

        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                     {'IMEI': self._device['devNo'], "funCode": '55', 'data': 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'足疗机正在忙，无响应，您的金币还在，请稍后再试哦'})

        data = devInfo['data'][6::]
        switch = True if data[0:2] == '01' else False
        shake = True if data[2:4] == '01' else False
        hot = True if data[4:6] == '01' else False
        mode = 'mode%s' % (int(data[6:8]))
        leftTime = int(data[8:10], 16)

        # 这款足疗机的运行时间固定是15分钟
        Device.update_dev_control_cache(
            self._device['devNo'],
            {
                'status': Const.DEV_WORK_STATUS_WORKING if switch else Const.DEV_WORK_STATUS_IDLE,
                'switch': switch,
                'shake': shake,
                'hot': hot,
                'mode': mode,
                'leftTime': leftTime,
                'finishedTime': int(time.time()) + leftTime * 60
            })

        return {'switch': switch, 'shake': shake, 'hot': hot, 'mode': mode}

    def get_dev_status(self):
        infoDict = self.get_dev_status_from_dev()

        # 这款足疗机的运行时间固定是15分钟
        Device.update_dev_control_cache(
            self._device['devNo'],
            {'status': Const.DEV_WORK_STATUS_WORKING,
             'switch': infoDict['switch'],
             'shake': infoDict['shake'],
             'hot': infoDict['hot'],
             'mode': infoDict['mode'],
             'leftTime': infoDict['leftTime'],
             'finishedTime': int(time.time()) + infoDict['leftTime'] * 60
             })

        return infoDict

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

    def count_down(self, request, dev, agent, group, devType, lastOpenId, port = None):
        devInfo = self.get_dev_status()
        return JsonResponse(
            {
                'result': 1,
                'description': '',
                'payload': {
                    'surplus': devInfo['leftTime'],
                    'sum': 15,
                    '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,
                    'status': devInfo
                }
            })

    def stop(self, port = None):
        Device.invalid_device_control_cache(self.device.devNo)

        devInfo = MessageSender.send(device = self.device, cmd = DeviceCmdCode.STOP_DEVICE, payload = {
            't': int(time.time())
        })
        if devInfo['rst'] == 0:
            if 'left_time' in devInfo:
                devInfo['remainder_time'] = int(devInfo['left_time'] / 60.0)
            else:
                devInfo['remainder_time'] = int(devInfo['remainder_time'] / 60.0)

        return devInfo