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

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

# 支持比较通用类型的娃娃机协议
import random

from apps.web.constant import DeviceCmdCode
from apps.web.core.adapter.base import SmartBox, fill_2_hexByte
from apps.web.core.exceptions import ServiceException
from apps.web.core.networking import MessageSender


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

    # 只需要处理抓到娃娃以及NG的消息。
    def analyze_event_data(self, data):
        funCode = data[6:8]
        if funCode == '13':
            randomCode = data[8:10]
            faultCode = data[10:12]
            coinCount = int(data[12:14],16)
            itemCount = int(data[14:16],16)
            money = int(data[16:18],16)
            return {'funCode':'13','randomCode':randomCode,'faultCode':faultCode,
                    'coinCount':coinCount,
                    'itemCount':itemCount,
                    'money':money
                    }
        return 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_result_by_version(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':'D1','data':'01000000000000'})
        self.check_result(devInfo)
        
        if devInfo['data'][22:24] != '01':
            raise ServiceException({'result': 0, 'description': u'设备当前不处于待支付状态，请您稍后再用' })
        
    def test(self, coins):
        # 注意订单唯一编号全为0，表示测试命令
        data = fill_2_hexByte(hex(random.randint(0,255)), 2)
        data += '0101'
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'03','data':data})
        self.check_result(devInfo)
        result = devInfo['data'][8:10] 
        if result != '01':
            raise ServiceException({'result': 0, 'description': u'设备启动失败，请您重试操作吧' })
        

    def start_device(self, package, openId, attachParas):
        money = int(package['coins'])
        data = fill_2_hexByte(hex(random.randint(0,255)), 2)
        data += fill_2_hexByte(hex(money), 2)
        data += fill_2_hexByte(hex(money), 2)
        
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'03','data':data})
        
        self.check_result(devInfo)
        result = devInfo['data'][8:10] 
        if result != '01':
            raise ServiceException({'result': 0, 'description': u'设备启动失败，请您重试操作吧' })
        
        return devInfo

    def get_terminal_account(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'04','data':''})
        
        self.check_result(devInfo)
        
        data = devInfo['data'][8:-4]
        return {
                'faultCode':int(data[0:2],16),
                'allAccount':int(data[2:6],16),
                'allItemCount':int(data[6:10],16),
                'allMoney':int(data[10:14],16),
                'allCoinCount':int(data[14:18],16),
                }
        
    def get_paras_from_device(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'05','data':''})
        
        self.check_result(devInfo)
        
        data = devInfo['data'][8:-4]
        result = {
                'youximoshi':int(data[0:2],16),
                'zhongjianggailv':int(data[2:6],16),
                'qianglidianya':int(data[6:10],16),
                'ruolidianya':int(data[10:14],16),
                'qiangzhuanruoshijian':int(data[14:18],16),
                'daodingzhuanruozhuali ':int(data[18:20],16),
                'jibiyiwan':int(data[20:22],16),
                'youxishijian':int(data[22:24],16),
                'beijinyinyue':int(data[24:26],16),
                'zhuabudaobubi':int(data[26:28],16),
                'anjianzhuawu':int(data[28:30],16),
                'liantouzengbi ':int(data[30:32],16),
                'youxizhidongjieshu':int(data[32:34],16),
                }
        if len(data)>34:
            result.update({'qianhousudu':int(data[34:36],16),
                            'zuoyoushudu':int(data[36:38],16),
                            'shangxiashudu':int(data[38:40],16),
                            'fangxianchangdu':int(data[40:42],16)})
        
        return result
        
    def set_device_paras(self,conf):
        data = fill_2_hexByte(hex(int(conf['youximoshi'])), 2)
        data += fill_2_hexByte(hex(int(conf['zhongjianggailv'])), 4)
        data += fill_2_hexByte(hex(int(conf['qianglidianya'])), 4)
        data += fill_2_hexByte(hex(int(conf['ruolidianya'])), 4)
        data += fill_2_hexByte(hex(int(conf['qiangzhuanruoshijian'])), 4)
        data += fill_2_hexByte(hex(int(conf['daodingzhuanruozhuali'])), 2)
        data += fill_2_hexByte(hex(int(conf['jibiyiwan'])), 2)
        data += fill_2_hexByte(hex(int(conf['youxishijian'])), 2)
        data += fill_2_hexByte(hex(int(conf['beijinyinyue'])), 2)
        data += fill_2_hexByte(hex(int(conf['zhuabudaobubi'])), 2)
        data += fill_2_hexByte(hex(int(conf['anjianzhuawu'])), 2)
        data += fill_2_hexByte(hex(int(conf['liantouzengbi'])), 2)
        data += fill_2_hexByte(hex(int(conf['youxizhidongjieshu'])), 2)
        
        if conf.has_key('qianhousudu'):
            data += fill_2_hexByte(hex(int(conf['qianhousudu'])), 2)
            data += fill_2_hexByte(hex(int(conf['zuoyoushudu'])), 2)
            data += fill_2_hexByte(hex(int(conf['shangxiashudu'])), 2) 
            data += fill_2_hexByte(hex(int(conf['fangxianchangdu'])), 2)
            
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'06','data':data})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def clear_pannel_account(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_SYNC,
                                    {'cmd': DeviceCmdCode.OPERATE_DEV_SYNC, 'IMEI': self._device['devNo'],'funCode':'07','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
        
    def clear_back_account(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'08','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def recover_factory_setting(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'0B','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def clear_local_account(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'0C','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def clear_prize(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'1C','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def clear_this_account(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'1E','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def reboot_device(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'1F','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def stop_service(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'31','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def start_service(self):
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'32','data':''})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
    
    def set_local_account(self,conf):
        data = fill_2_hexByte(hex(int(conf['offlineCoins'])), 4)
        data += fill_2_hexByte(hex(int(conf['itemCount'])), 4)
        data = fill_2_hexByte(hex(int(conf['onlineCoins'])), 4)
        data = fill_2_hexByte(hex(int(conf['daibiCount'])), 4)
        
        devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
                           {'cmd': DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, 'IMEI': self._device['devNo'],'funCode':'1D','data':data})
        
        self.check_result(devInfo)
        
        if devInfo['data'][8:10] == '00':
            raise ServiceException({'result': 0, 'description': u'设备参数配置失败，请重试，或者联系客服' })
        
    
    def translate_fault_desc(self,faultCode):
        faultDict = {
                     '01':u'错误：概率队列溢出错误。原因：光眼板感应故障。解决：维修光眼板，清零概率队列',
                     '02':u'错误：存储器故障。解决：更换主板存储器或者直接换主板',
                     '41':u'错误：投币器1故障。原因：投币器坏了或者投币器拨到了NC电平。解决：更换投币器。投币器拨到NO',
                     '42':u'错误：投币器2故障。原因：投币器坏了或者投币器拨到了NC电平。解决：更换投币器。投币器拨到NO',
                     '05':u'错误：光眼板故障。原因：光眼板坏或者接线断或者系统设置电平与光眼板电平不匹配。解决：更换光眼板，接好线，设置系统里面的感应板电平',
                     '06':u'错误：天车回到礼品口故障。原因：礼品口处的微动故障。解决：维修或更换微动',
                     '07':u'错误：天车回到起始位置故障。原因：起始位置处的微动故障。解决：维修或更换微动',
                     '81':u'关机天车自检时，前微动故障',
                     '82':u'关机天车自检时，后微动故障',
                     '83':u'关机天车自检时，上微动故障',
                     '84':u'关机天车自检时，下微动故障',
                     '85':u'关机天车自检时，左微动故障',
                     '86':u'关机天车自检时，右微动故障',
                     }
        return faultDict.get(faultCode,'')
    
    def get_device_function_by_key(self,key):
        result = {}
        if 'status' in key or 'account' in key:
#             return {'status':u'阿迪发顺丰是','account':u'sddfeaweffs'}
            data = self.get_terminal_account()
            
            if data['faultCode'] != '00':
                faultDesc = self.translate_fault_desc(data['faultCode'])
                result.update({'status':faultDesc})
            else:
                result.update({'status':''})
            
            accountInfo = u'本地营收总账:%s,退礼总账:%s,线上投币数:%s' % (data['allAccount'],data['allItemCount'],data['allCoinCount'])
            result.update({'account':accountInfo})
            
            return result
        if 'zhongjianggailv' in key:
            data = self.get_paras_from_device()
            result.update(data)
            return result
        
        return None
    
    def set_device_function(self,request,conf):
        if request.POST.has_key('recover'):
            self.recover_factory_setting()
        elif request.POST.has_key('reboot'):
            self.reboot_device()