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

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

import logging
import simplejson as json

from apps.web.constant import FAULT_LEVEL, DeviceCmdCode, ErrorCode, DeviceErrorCodeDesc, FAULT_CODE
from apps.web.core.adapter.base import SmartBox, fill_2_hexByte
from apps.web.core.exceptions import ServiceException, DeviceNetworkTimeoutError
from apps.web.core.networking import MessageSender

logger = logging.getLogger(__name__)

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

    # 只需要处理抓到娃娃以及NG的消息。
    def analyze_event_data(self, data):
        if data.has_key('messageType') and data['messageType'] == 'PUT_ITEM':
            return {'funCode':'96'} 
        
        if not data.has_key('data'):
            return None
        
        funCode = data['data'][4:6]
        if funCode == '8B':
            if data['data'][6:8] != '31':
                return None
            errCode = data['data'][8:10]
            errInfo = self.translate_error_desc(errCode)
            return {'funCode':'8B','faultName':errInfo.get('desc',''),'faultCode':FAULT_CODE.WAWAJI_WUMAHANG_NG,
                    'level':FAULT_LEVEL.NORMAL,
                    'desc':errInfo.get('oper','')
                    }
        elif funCode == '96':
            if int(data['data'][12:14],16) > 1:
                return None
            return {'funCode':'96'} 
        
        return None
    
    def translate_error_desc(self,errCode):
        errDict = {
                   '01':{'desc':u'CPU故障','oper':u'1.更换U1 CPU。\n2.PCB故障。'},
                   '02':{'desc':u'收线故障','oper':u'1.检查当收线时，上停SW是否确实弹开。\n2.检查上停SW是否故障。\n3.天车组的空中接头是否有接触不良的情形？\n4.主板上的J9 PIN是否有松脱接触不良情形？\n5.主板故障。'},
                   '03':{'desc':u'防线故障','oper':u'1.检查绕线机的线是否有乱线的情形？\n2.检查上停SW是否故障。\n3.天车组的空中接头是否有接触不良的情形？\n4.主板上的J9 PIN是否有松脱接触不良情形？\n5.主板故障。'},
                   '04':{'desc':u'出货SENSOR故障','oper':u'1.请检查是否灵敏度过高？请调整灵敏度VR，使排电的LED处于“暗”的状态\n2.J5电眼线是否脱落？\n3.电眼故障。\n4.主板故障。'},
                   '05':{'desc':u'前停SW或后停SW故障','oper':u'1.检查前停SW或后停SW是否故障？\n2.天车组的空中接头是否有接触不良的情形？\n3.主板上的J9 PIN是否有松动接触不良的情形？\n4.主板故障。'},
                   '06':{'desc':u'左停SW故障','oper':u'1.检查左停SW是否故障？\n2.天车组的空中接头是否有接触不良的情形？\n3.主板上的J9 PIN是否有松动接触不良的情形？\n4.主板故障。'},
                   '07':{'desc':u'Coin1(投币1)表故障','oper':u'1.检查J5的插PIN是否有接触不良的情形\n2.计数器是否有故障？插PIN是否有松动？\n3.主板故障。'},
                   '09':{'desc':u'出货表离线','oper':u'1.检查J5的插PIN是否有接触不良的情形\n2.计数器是否有故障？插PIN是否有松动？\n3.主板故障。'},
                   '11':{'desc':u'Coin1(投币1)投币超时','oper':u'1.投币器故障。\n2.玩家钓鱼。'},
                   '14':{'desc':u'93C66故障','oper':u'1.更换93C66。'}
                   }
        return errDict.get(errCode,None)
    
    def check_result(self,devInfo):
        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'娃娃机忙,无响应,请您稍候再试。也可能是您的设备版本过低，暂时不支持此功能'})
        
    def check_dev_status(self, attachParas = None):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'8B','data':'000000'})
        self.check_result(devInfo)
        
        if devInfo['data'][6:8] == '31':
            errInfo = self.translate_error_desc(devInfo['data'][8:10])
            raise ServiceException({'result': 0, 'description': u'设备故障：%s，暂时无法使用' % errInfo.get('desc','')})
        
    def test(self, coins):
        return MessageSender.net_pay(self.device, 1, timeout = 120)

    def start_device(self, package, openId, attachParas):
        pay_count = int(package['coins'])

        result = MessageSender.net_pay(self.device, pay_count, timeout = 120)

        if result['rst'] == ErrorCode.DEVICE_CONN_FAIL:
            raise DeviceNetworkTimeoutError()
        elif result['rst'] != ErrorCode.DEVICE_SUCCESS:
            logger.debug('WawajiMaichongBox() failed to start, result was=%s' % (json.dumps(result),))
            raise ServiceException({'result': 2, 'description': DeviceErrorCodeDesc.get(result['rst'])})

        return result

    def get_total_coin(self):
        result = MessageSender.send(self.device, DeviceCmdCode.GET_DEVINFO,
                                    {'cmd': DeviceCmdCode.GET_DEVINFO, 'IMEI': self._device['devNo']})
        if result['rst'] != ErrorCode.DEVICE_SUCCESS:
            logger.debug('WawajiMaichongBox() failed to get total coin, result was=%s' % (json.dumps(result),))

            description = u'当前设备信号弱没有响应，请您稍后重试。'
            raise ServiceException({'result': 2, 'description': description})

        if not result.has_key('total_coin'):
            raise ServiceException({'result': 2, 'description': u'当前设备暂时不支持获取总的硬币数目，待版本自动升级后，会支持'})

        return result['total_coin']

    # 基类函数，检查告警状态，只能做一个简单的检查，设备是否在线
    def check_alarm(self, alarm):
        if alarm.faultCode == FAULT_CODE.OFFLINE:
            dev_info = MessageSender.send(device = self.device,
                                          cmd = DeviceCmdCode.GET_DEVINFO,
                                          payload = {'IMEI': self.device.devNo, 'fields': []},
                                          timeout = 15)
            if dev_info['rst'] == 0:
                return u'设备状态检查在线，网络通畅，网络可能出现闪断'
            else:
                raise ServiceException({'result': 2, 'description': u'设备玩命也无法找到网络，设备可能不在线'})
        elif alarm.faultCode == FAULT_CODE.WAWAJI_WUMAHANG_NG:
            self.check_dev_status()
            return u'设备状态正常，故障已经恢复'
        else:
            return u'无法检查该设备的告警状态，建议您用其他方式确认此告警是否正常'

    def get_claw_values(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'07','data':'C1C2C3C4'})
        self.check_result(devInfo)
        data = devInfo['data']
        return {'c1':int(data[6:8],16),'c2':int(data[8:10],16),'c3':int(data[10:12],16),'c4':int(data[12:14],16)}
    
    def set_claw_value(self,c1,c2,c3,c4):
        if c1<0 or c1 >48:
            raise ServiceException({'result': 2, 'description': u'c1的抓力范围为0-48'})
        if c2<0 or c2 >48:
            raise ServiceException({'result': 2, 'description': u'c2的抓力范围为0-48'})
        if c3<0 or c3 >48:
            raise ServiceException({'result': 2, 'description': u'c3的抓力范围为0-48'})
        if c4<0 or c4 >48:
            raise ServiceException({'result': 2, 'description': u'c4的抓力范围为0-48'})
        
        data = fill_2_hexByte(hex(c1), 2)
        data += fill_2_hexByte(hex(c2), 2)
        data += fill_2_hexByte(hex(c3), 2)
        data += fill_2_hexByte(hex(c4), 2)
        
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'01','data':data})
        self.check_result(devInfo)
    
    def get_claw_maxcount(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'08','data':'00000000'})
        self.check_result(devInfo)
        data = devInfo['data']
        return {'greaterForceCount':int(data[6:10],16),'remainingGreaterForceCount':int(data[10:14],16)}
    
    def set_claw_maxcount(self,remainingGreaterForceCount):
        if remainingGreaterForceCount<1 or remainingGreaterForceCount >999:
            raise ServiceException({'result': 2, 'description': u'大力次数范围为1-999'})
        
        data = fill_2_hexByte(hex(remainingGreaterForceCount), 4)
        data += '0000'
        
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'08','data':data})
        self.check_result(devInfo)
        
    def set_next_claw_by_max(self):
        
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'02','data':'00000000'})
        self.check_result(devInfo)
    
    def get_game_time_line_lenth(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'05','data':'00000000'})
        self.check_result(devInfo)
        data = devInfo['data']
        return {'gameDuration':int(data[6:10],16),'lineOfDefense':int(data[12:14],16)}
    
    def set_game_time_line_lenth(self,gameDuration,lineOfDefense):
        data = fill_2_hexByte(hex(gameDuration), 4)
        data += fill_2_hexByte(hex(lineOfDefense), 4)
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'05','data':data})
        self.check_result(devInfo)
        
    def get_ng_status(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'0B','data':'00000000'})
        self.check_result(devInfo)
        data = devInfo['data']
        code = ''
        errDesc,suggestion = u'系统处于正常状态',''
        if data[6:8] == '31':
            code = int(data[8:10],16)
            errInfoDict = self.translate_error_desc(code)
            errDesc = errInfoDict.get('desc','')
            suggestion = errInfoDict.get('oper','')
        
        return {'ngCode':[{'code':code,'desc':errDesc,'suggestion':suggestion}]}
        
    
    def get_device_function_by_key(self, key):
        if 'c1' in key:
            return self.get_claw_values()
        elif 'greaterForceCount' in key:
            return self.get_claw_maxcount()
        elif 'gameDuration' in key:
            return self.get_game_time_line_lenth()
        elif 'ngCode' in key:
            return self.get_ng_status()
        
    def set_device_function_param(self,request, lastSetConf):
        if request.POST.has_key('c1'):
            c1 = int(request.POST.get('c1', None))
            c2 = int(request.POST.get('c2', None))
            c3 = int(request.POST.get('c3', None))
            c4 = int(request.POST.get('c4', None))
            self.set_claw_value(c1, c2, c3, c4)
        elif request.POST.has_key('remainingGreaterForceCount'):
            greaterForceCount = int(request.POST.get('remainingGreaterForceCount', None))
            self.set_claw_maxcount(greaterForceCount)
        elif request.POST.has_key('gameDuration'):
            gameDuration = int(request.POST.get('gameDuration', None))
            lineOfDefense = int(request.POST.get('lineOfDefense', None))
            self.set_game_time_line_lenth(gameDuration, lineOfDefense)
    
    def reboot_device(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'06','data':'0A0B0C0D'})
        self.check_result(devInfo)

    def set_device_function(self,request, lastSetConf):
        if request.POST.has_key('greaterForce'):
            self.set_next_claw_by_max()
        elif request.POST.has_key('reboot'):
            self.reboot_device()