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

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

from apps.web.core.adapter.base import *
from apps.web.device.models import Device, StockRecord


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

    def analyze_event_data(self,data):
        if data['faultCode'] == 1:
            return {'status':Const.DEV_WORK_STATUS_FAULT,'statusInfo':u'缺纸告警'}
        elif data['faultCode'] ==Const.DEV_WORK_STATUS_FAULT:
            return {'status':Const.DEV_WORK_STATUS_FAULT,'statusInfo':u'电机故障'}
        return {'status':Const.DEV_WORK_STATUS_IDLE,'statusInfo':''}

    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

        devInfo = MessageSender.send(self.device, DeviceCmdCode.GET_DEVINFO, {'IMEI': self._device['devNo']},
                                     timeout = timeout, retry = retry)
        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'当前纸巾机忙,无响应,请您稍候再试'})

        if devInfo.get('isTissueEmpty', False):
            Device.update_field(
                dev_no = self._device['devNo'],
                update = True,
                quantity = 0)
            raise ServiceException(
                {'result': 2, 'description': u'您来迟了一步，当前纸巾机已经没有纸巾了，建议您试试周围其他机子哦'})


    #请求设备出纸巾,count表示出的数目
    def sendOutPaper(self,count):
        result = MessageSender.send(self.device, DeviceCmdCode.PAY_MONEY,
                                    {'app_pay': int(count), 'IMEI': self._device['devNo']}, timeout = MQTT_TIMEOUT.START_DEVICE)

        if result.has_key('rst')  and result['rst'] != 0:
            if result['rst'] == -1:
                description =   u'当前纸巾机开小差了，可能是网络信号差，您稍候试试，或者找找周边的其他纸巾机'
                raise ServiceException({'result': 2, 'description': description})
            elif result['rst'] == 1:
                description =   u'当前纸巾机繁忙无响应，您稍后再试'
                raise ServiceException({'result': 2, 'description': description})

        return {'rst':0,'IMEI':self._device['devNo'],'out':count}

    #免费领纸巾
    def start_free(self, token, count = 1):
        result = self.sendOutPaper(count)

        #更新设备的库存信息
        self._device['consumptionQuantity'] += result['out']
        self._device['quantity'] -= result['out']
        if self._device['quantity'] <= 0:
            self._device['quantity'] = 0

        Device.update_field(dev_no = self._device['devNo'],
                            update = True,
                            consumptionQuantity = self._device['consumptionQuantity'],
                            quantity = self._device['quantity'])

        # 用户成功消耗纸巾，需要把库存记录到数据库中
        payload = {
            'token': token,
            'logicCode': self._device['logicalCode'],
            'imei': self._device['devNo'],
            'stockType':'adFree',
            'stockTime': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
            'number':count,
            'more':u'免费送'
        }

        StockRecord(**payload).save()

        return result

    def start_device(self, package, openId, attachParas):
        #: 首先检查设备是否在线,是否有库存
        coins = int(package['coins'])

        devInfo = self.sendOutPaper(coins)

        # 更新设备的库存信息
        self._device['consumptionQuantity'] += devInfo['out']
        self._device['quantity'] -= devInfo['out']
        if self._device['quantity'] <= 0:
            self._device['quantity'] = 0

        Device.update_field(
            dev_no = self._device['devNo'],
            update = True,
            consumptionQuantity = self._device['consumptionQuantity'],
            quantity = self._device['quantity'])

        #用户成功消耗纸巾，需要把库存记录到数据库中
        try:
            stockTime = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
            StockRecord.get_collection().insert({'logicCode':self._device['logicalCode'],'imei':self._device['devNo'],
                                                 'stockType':'consume','stockTime':stockTime,'number':devInfo['out']})
        except Exception ,e:
            logger.info('record tissue device=%s consume record exception=%s' % (self._device['devNo'],e))

        Device.update_dev_control_cache(self._device['devNo'], {'openId':openId,'vCardId':self._vcard_id})

        return devInfo

    def get_dev_setting(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.GET_DEVINFO, {'IMEI': self._device['devNo']})

        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'当前纸巾机忙,无响应,请您稍候再试'})

        return {'stop_delay': devInfo['stop_delay'], 'tissue_timeout': devInfo['tissue_timeout']}


    def set_dev_setting(self, stop_delay, tissue_timeout):
        result = MessageSender.send(self.device, 202, {
            "cmd": 202,
            "IMEI": self._device['devNo'],
            "motor_set":
                {
                    "stop_delay": stop_delay,
                    "tissue_timeout": tissue_timeout
                }
        })

        if result['rst'] == -1:
            raise ServiceException(
                {'result': 2, 'description': u'当前纸巾机正在玩命找网络,请您稍候再试'})
        elif result['rst'] == 1:
            raise ServiceException(
                {'result': 2, 'description': u'当前纸巾机忙,无响应,请您稍候再试'})
        return
    
    def set_device_function_param(self,request,lastSetConf):
        setting = {
            'stop_delay': request.POST.get('stop_delay'),
            'tissue_timeout': request.POST.get('tissue_timeout')
        }

        from apps.web.device.validation import DeviceSettingSchema
        setting = DeviceSettingSchema.TISSUE_BOX(setting)
        self.set_dev_setting(**setting)