123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142 |
- # -*- coding: utf-8 -*-
- # !/usr/bin/env python
- import time
- from apilib.utils_json import JsonResponse
- from apps.web.constant import Const, DeviceCmdCode, MQTT_TIMEOUT
- 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
- from apps.web.device.models import Device
- class PedicureHongPaiBox(SmartBox):
- def __init__(self, device):
- super(PedicureHongPaiBox, self).__init__(device)
- def analyze_event_data(self, data):
- pass
- def support_count_down(self, openId = None, port = None):
- return True
- def send_dev_runtime(self, openId, duration):
- hexTime = fill_2_hexByte(hex(int(duration / 60)), 2)
- devInfo = MessageSender.send(self.device, self.make_random_cmdcode(),
- {'IMEI': self._device['devNo'], "funCode": '05', 'data': hexTime})
- 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['data'][4:6] == '00':
- raise ServiceException({'result': 2, 'description': u'足疗机启动失败,金币还在,请您稍后重试'})
- Device.update_dev_control_cache(
- self._device['devNo'],
- {
- 'needTime': duration,
- 'status': Const.DEV_WORK_STATUS_WORKING,
- 'finishedTime': int(time.time()) + duration
- })
- return devInfo
- def start_from_api(self, record):
- return super(PedicureHongPaiBox, self).start_from_api(record)
- def start_device(self, package, openId, attachParas): # 微信支付
- # 先检查足疗机是否正在运行,如果正在运行,就返回错误
- devInfo = MessageSender.send(device = self.device, cmd = DeviceCmdCode.GET_DEVINFO, payload = {
- 'IMEI': self._device['devNo']
- }, 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'足疗机正在忙,无响应,请稍后再试哦'})
- if not devInfo.has_key('hongpai_status'):
- raise ServiceException({'result': 2, 'description': u'当前足疗机没有返回正确的结果,可能是内部接触不良,请您重试,或者联系客服解决'})
- if devInfo['hongpai_status'][4:6] == '01':
- raise ServiceException({'result': 2, 'description': u'当前足疗机正在工作中,不能操作哦,等设备空闲后,您再试试吧'})
- needTime = int(package['time'])
- hexTime = fill_2_hexByte(hex(needTime), 2)
- devInfo = MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
- {'IMEI': self._device['devNo'], "funCode": '05', 'data': hexTime})
- 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'足疗机正在忙,无响应,您的金币还在,请试试其他线路,或者请稍后再试哦'})
- Device.update_dev_control_cache(
- self._device['devNo'],
- {
- 'needTime': needTime * 60,
- 'status': Const.DEV_WORK_STATUS_WORKING,
- 'finishedTime': int(time.time()) + needTime * 60
- })
- return devInfo
- def test(self, coins):
- return MessageSender.send(self.device, DeviceCmdCode.OPERATE_DEV_NO_RESPONSE,
- {'IMEI': self._device['devNo'], "funCode": '05', 'data': '02'})
- def get_left_time(self):
- serviceInfo = Device.get_dev_control_cache(self._device['devNo'])
- if (serviceInfo is None) or (not serviceInfo.has_key('status')) or (
- serviceInfo['status'] == Const.DEV_WORK_STATUS_IDLE):
- return 0.0, 0.0
- nowTime = int(time.time())
- leftTime = (serviceInfo['finishedTime'] - nowTime) / 60.0
- needTime = serviceInfo['needTime'] / 60.0
- if leftTime <= 0:
- return needTime, 0.0
- 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 = True
- 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 get_dev_setting(self):
- devObj = Device.objects.get(devNo = self._device['devNo'])
- return {'freeHours': devObj.otherConf.get('freeHours', 10)}
- def set_device_function_param(self, request, lastSetConf):
- if request.POST.has_key('freeHours'):
- devObj = Device.objects.get(devNo = self._device['devNo'])
- devObj.otherConf['freeHours'] = int(request.POST.get('freeHours', 10))
- devObj.save()
|