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

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


class DepartmentShower(SmartBox):

    def __init__(self, device):
        super(DepartmentShower, self).__init__(device)
    
    # 设备上报事件
    def analyze_event_data(self, data):
        pass
    
    def support_count_down(self,openId=None,port=None):
        return True
    
    def test(self, coins):
        return MessageSender.send(self.device, DeviceCmdCode.PAY_MONEY, {'IMEI': self._device['devNo'], 'duration': 60})

    def start_device(self, package, openId, attachParas):

        devInfo = MessageSender.send(self.device, DeviceCmdCode.GET_DEVINFO, {'IMEI': self._device['devNo']})
        
        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            raise ServiceException({'result': 2, 'description': u'淋浴器正在玩命找网络，建议您稍后再试或者试试刷卡使用'})
        
        if devInfo['remainder_time'] > 0 and devInfo.has_key('startMode') and devInfo['startMode'] == 'card':
            raise ServiceException({'result': 2, 'description': u'淋浴器正在忙，并且使用的是卡，不允许刷卡的时候再扫码使用！'})
        
        lastRemainderTime = devInfo['remainder_time']
        duration = int(package['time']*60)
        coins = float(package['coins'])
        
        devInfo = MessageSender.send(device = self.device,
                                     cmd = DeviceCmdCode.PAY_MONEY,
                                     payload = {
                                         'IMEI': self._device['devNo'], 'duration': duration
                                     },
                                     timeout = MQTT_TIMEOUT.START_DEVICE)

        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            if devInfo['rst'] == 3:
                raise ServiceException({'result': 2, 'description': u'淋浴器正在刷卡使用，,请您等刷卡使用结束后，再使用'})
            
            raise ServiceException({'result': 2, 'description': u'淋浴器正在玩命找网络，您的金币还在，重试不会扣款，建议您稍后再试或者试试刷卡使用'})
        
        devCtrInfo = Device.get_dev_control_cache(devNo = self._device['devNo'])

        if devCtrInfo.has_key('openId') and devCtrInfo['openId'] != openId:
            devCtrInfo['coins'] = coins
            devCtrInfo['needTime'] = duration/60.0
        else:    
            if ( not devCtrInfo.has_key('coins') ) or ( lastRemainderTime == 0.0 ): 
                devCtrInfo['coins'] = coins
            else:
                devCtrInfo['coins'] += coins
            
            if ( not devCtrInfo.has_key('needTime') ) or ( lastRemainderTime == 0.0 ):
                devCtrInfo['needTime'] = duration/60.0
            else:
                devCtrInfo['needTime'] += duration/60.0

        devCtrInfo.update({
            'openId': openId,
            'status': Const.DEV_WORK_STATUS_WORKING,
            'finishedTime': int(time.time()) + devInfo['remainder_time']
        })
        
        Device.update_dev_control_cache(self._device['devNo'], devCtrInfo)

        return devInfo
    
    def recharge_card(self, cardNo, money, orderNo=None):
        try:
            devInfo = MessageSender.send(self.device, 303,
                                         {'IMEI': self._device['devNo'], "cardNo": cardNo, 'balance': money * 100})

            if devInfo['rst'] != 0:
                if devInfo['rst'] == ErrorCode.DEVICE_CONN_FAIL:
                    return {
                               'result': ErrorCode.DEVICE_CONN_FAIL,
                               'description': u'当前淋浴器正在玩命找网络,请您稍候再试'
                           }, None
                else:
                    return {
                               'result': ErrorCode.IC_RECHARGE_FAIL,
                               'description': u'当前充值的卡正在淋浴器上使用,无法进行充值'
                           }, None

            return {
                       'result': ErrorCode.SUCCESS,
                       'description': ''
                   }, None
        except Exception as e:
            logger.exception(e)
            return {
                       'result': ErrorCode.EXCEPTION,
                       'description': e.message
                   }, None
    
    def set_dev_setting(self,setConf):
        minuteFee = setConf['minuteFee']
        devInfo = MessageSender.send(self.device, 306, {'IMEI': self._device['devNo'], "minuteFee": minuteFee})
 
        if 'rst' in devInfo and devInfo['rst'] != 0:
            if devInfo['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'当前淋浴器正在玩命找网络,请您稍候再试'})
            else:
                raise ServiceException({'result': 2, 'description': u'当前淋浴器忙,无法进行充值'})
        
        devObj = Device.objects.get(devNo = self._device['devNo'])
        devObj.otherConf['minuteFee'] = minuteFee
        devObj.save()
        
        return devInfo
    
    def get_dev_setting(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.GET_DEVINFO, {'IMEI': self._device['devNo']})

        if 'rst' in devInfo and devInfo['rst'] != 0:
            if devInfo['rst'] == -1:
                raise ServiceException({'result': 2, 'description': u'当前淋浴器正在玩命找网络,请您稍候再试'})
            else:
                raise ServiceException({'result': 2, 'description': u'当前淋浴器忙,无法进行充值'})
        
        return {'minuteFee':devInfo['minuteFee']}
    
    def set_device_function_param(self,request,lastSetConf):
        if request.POST.has_key('minuteFee'):
            lastSetConf.update({'minuteFee': int(request.POST.get('minuteFee', 0))})
            self.set_dev_setting(lastSetConf)
    
    def get_left_time(self):
        devCtrInfo = Device.get_dev_control_cache(devNo = self._device['devNo'])

        if (devCtrInfo is None) or (not devCtrInfo.has_key('status')) or (devCtrInfo['status'] == Const.DEV_WORK_STATUS_IDLE):
            return 0.0,0.0

        if not devCtrInfo.has_key('needTime'):
            return 0.0,0.0
        
        needTime = devCtrInfo['needTime']
        
        devInfo = MessageSender.send(self.device, DeviceCmdCode.GET_DEVINFO, {'IMEI': self._device['devNo']})

        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            raise ServiceException({'result': 2, 'description': u'淋浴器正在玩命找网络，建议您稍后再试或者试试刷卡使用'})
        
        leftTime = devInfo['remainder_time']/60.0
        if leftTime <= 0:
            return 0.0,needTime
        
        return leftTime,needTime
    
    def count_down(self,request,dev,agent,group,devType,lastOpenId,port=None):
        surplus, sumtime = self.get_left_time()
        orderProcessing = False
        if surplus == 0.0 and sumtime == 0.0:
            orderProcessing = False

        return JsonResponse(
            {
                'result': 1,
                'description': '',
                'payload': {
                    'surplus': surplus,
                    'sum': sumtime,
                    'name': group['groupName'],
                    'address': group['address'],
                    'code': devType.get('code'),
                    'orderProcessing': orderProcessing,
                    'logicalCode': dev['logicalCode'],
                    'user': 'me' if lastOpenId == request.user.openId else 'notme',
                    'agentFeatures': agent.features,
                }
            })
    
    def stop(self,port=None):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.STOP_DEVICE, {'IMEI': self._device['devNo']})
        if devInfo.has_key('rst') and devInfo['rst'] != 0:
            return JsonResponse({"result": 0, "description": u'网络连接异常，停止设备失败，请您重新尝试停掉设备', "payload": ''})
        devInfo['remainder_time'] = int(devInfo['remainder_time'] / 60.0)
        return devInfo
    
    #按照秒来退费
    def calc_stop_back_coins(self,totalFee,remainderTime,totalTime):
        refundFee = round(totalFee * (float(remainderTime) / (totalTime*60.0)),2)
        if refundFee > totalFee:
            refundFee = totalFee

        if refundFee <= 0.0:
            refundFee = 0.00
        
        return refundFee