# -*- coding: utf-8 -*- # !/usr/bin/env python import datetime import time from decimal import Decimal from apilib.monetary import RMB from apilib.utils_AES import EncryptDate from apps.web.constant import DeviceCmdCode, Const, MQTT_TIMEOUT, ErrorCode from apps.web.core.adapter.base import SmartBox from apps.web.core.exceptions import ServiceException from apps.web.core.networking import MessageSender from apps.web.device.models import Device, DeviceType from apps.web.user.models import Card, ServiceProgress, ConsumeRecord cardKey = 'FR4e1OFCnDdrYA7u' class ChargingSocketBox(SmartBox): def __init__(self, device): super(ChargingSocketBox, self).__init__(device) def translate_funcode(self, fun_code): fun_codeDict = { '01': u'查询所有端口状态', '02': u'查询端口详细信息', '03': u'上报投币充电事件', '04': u'上报刷卡事件', '05': u'上报充电结束事件', '06': u'远程停止充电', '07': u'远程启动充电', '08': u'查询投币总额', '09': u'清除投币总数', '0A': u'查询订单信息', } return fun_codeDict.get(fun_code, '') def translate_event_cmdcode(self, cmdCode): cmdDict = { } return cmdDict.get(cmdCode, '') def check_dev_status(self, attachParas=None): if attachParas.get('isTempPackage') == True: washConfig = self.device.get('tempWashConfig', {}) else: washConfig = self.device.get('washConfig', {}) packageId = attachParas.get('packageId') if not packageId: # 此时为快捷启动充电之前已经校验过一次 return package = washConfig.get(packageId) self._check_package(package) port = int(attachParas['chargeIndex']) port_stat = self.get_port_status_from_dev().get(str(port), {}) if port_stat.get('status') not in [Const.DEV_WORK_STATUS_CONNECTED, Const.DEV_WORK_STATUS_WORKING]: raise ServiceException({'result': 2, 'description': u'请先连接充电插座,再启动充电'}) if package.get('name') == '充满自停' and package.get('coins') == 0 and package.get('price') == 0: if port_stat.get('status') == Const.DEV_WORK_STATUS_WORKING: raise ServiceException({'result': 2, 'description': u'当前端口已处于工作状态,无法使用充满自停套餐, 请换个端口进行充电'}) def get_port_info(self, port): data = {'fun_code': 2, 'port': int(port)} devInfo = self.send_mqtt(data) portInfo = devInfo.get('data', {}) result = {} pay_unit = self.show_pay_unit exec_orders = portInfo.get('exec_orders', []) _wait = [] for exec_order in exec_orders: if exec_order['status'] == 'running': result['voltage'] = round(portInfo.get('volt', 0), 2) result['power'] = round(portInfo.get('watt', 0), 2) result['ampere'] = round((portInfo.get('ampr', 0) * 0.001), 2) result['coins'] = '{}'.format(round(exec_order['amount'] / 100.0, 2)) result['usedTime'] = round(exec_order.get('time', 0) / 60.0, 1) result['usedElec'] = round(exec_order.get('elec', 0) * 0.000001, 4) result['startTime'] = datetime.datetime.fromtimestamp(int(exec_order['exec_time'])).strftime( '%m-%d %H:%M:%S') if exec_order['chrmt'] == 'TIME': result['leftTime'] = round(exec_order.get('left_time', 0) / 60.0, 1) result['needTime'] = '{}分钟'.format(round(exec_order['amount_time'] / 60.0, 1)) elif exec_order['chrmt'] == 'ELEC': result['needElec'] = round(exec_order.get('amount_elec', 0) * 0.000001, 2) result['leftElec'] = round(exec_order.get('left_elec', 0) * 0.000001, 4) else: pass if exec_order['order_type'] == 'apps_start': result['consumeType'] = 'mobile' result['consumeMoney'] = '{}{}'.format(round(exec_order.get('money', 0) * 0.01, 2), pay_unit) result['leftMoney'] = '{}{}'.format(round(exec_order.get('left_money', 0) * 0.01, 2), pay_unit) try: orderNo = exec_order['id'] order = ConsumeRecord.objects.filter(orderNo=orderNo).first() if not order: result['nickName'] = '经销商上分' else: result['nickName'] = order.user.nickname package = order.package if package.get('name') == '充满自停' and package.get('coins') == 0 and package.get( 'price') == 0: # 后付费 result['consumeType'] = 'postpaid' result['needTime'] = '充满自停' result.pop('needElec', None) result.pop('leftMoney', None) result.pop('leftTime', None) result.pop('leftElec', None) except: pass if exec_order['order_type'] == 'card_start': result['consumeType'] = 'card' result['cardNo'] = exec_order['card_no'] result['cardConsumeMoney'] = '{}{}'.format(round(exec_order.get('money', 0) * 0.01, 2), pay_unit) result['cardLeftMoney'] = '{}{}'.format(round(exec_order.get('left_money', 0) * 0.01, 2), pay_unit) result['cardBalance'] = '{}{}'.format(round(exec_order['balance'] * 0.01, 2), pay_unit) try: card = Card.objects.get(cardNo=exec_order['card_no']) result['nickName'] = card.cardName or card.nickName except: pass else: pass if exec_order['status'] == 'waiting': _one = {} if exec_order['chrmt'] == 'TIME': _one['leftTime'] = round(exec_order.get('left_time', 0) / 60.0, 1) _one['needTime'] = '{}分钟'.format(round(exec_order['amount_time'] / 60.0, 1)) elif exec_order['chrmt'] == 'ELEC': _one['leftElec'] = round(exec_order.get('left_elec', 0) * 0.000001, 4) _one['needElec'] = round(exec_order.get('amount_elec', 0) * 0.000001, 2) else: pass if exec_order['order_type'] == 'apps_start': _one['consumeType'] = 'mobile' _one['coins'] = '{}{}'.format(round(exec_order['amount'] / 100.0, 2), pay_unit) try: order = ConsumeRecord.objects.filter(orderNo=exec_order['id']).first() if not order: _one['nickName'] = '经销商上分' else: _one['nickName'] = order.user.nickname except Exception: pass elif exec_order['order_type'] == 'card_start': _one['consumeType'] = 'card' _one['coins'] = '{}{}'.format(round(exec_order['amount'] / 100.0, 2), pay_unit) _one['cardNo'] = exec_order['card_no'] _one['cardBalance'] = '{}{}'.format(round(exec_order['balance'] * 0.01, 2), pay_unit) try: card = Card.objects.get(cardNo=exec_order['card_no']) _one['nickName'] = card.cardName or card.nickName except: pass else: pass _wait.append(_one) if _wait: result['waittingOrder'] = _wait return result def send_mqtt(self, data, cmd=DeviceCmdCode.OPERATE_DEV_SYNC, timeout=10): """ 发送mqtt 指令默认210 返回data """ payload = {'IMEI': self.device.devNo, 'data': data} result = MessageSender.send(self.device, cmd, payload=payload, timeout=timeout) if not result.has_key('rst'): raise ServiceException({'result': 2, 'description': u'报文异常'}) if result['rst'] == -1: raise ServiceException({'result': 2, 'description': u'充电桩正在玩命找网络,请您稍候再试'}) if result['rst'] == 1: raise ServiceException({'result': 2, 'description': u'串口通讯失败，您稍候再试，或者联系客服'}) if result['rst'] == 2: raise ServiceException({'result': 2, 'description': u'订单已满'}) if result['rst'] == 3: raise ServiceException({'result': 2, 'description': u'端口已被禁用'}) if result['rst'] == 4: raise ServiceException({'result': 2, 'description': u'检测插头未连接,请先插上插头后再使用'}) if result['rst'] == 5: raise ServiceException({'result': 2, 'description': u'计费类型无效'}) if result['rst'] == 7: raise ServiceException({'result': 2, 'description': u'端口计量故障'}) else: if cmd in [DeviceCmdCode.OPERATE_DEV_NO_RESPONSE, DeviceCmdCode.PASSTHROUGH_OPERATE_DEV_NO_RESPONSE]: return if result.get('data') == '00': raise ServiceException({'result': 2, 'description': u'设备操作失败.请重试'}) else: return result def check_params_range(self, params, minData=None, maxData=None, desc=''): # type:(str,float,float,str) -> str """ 检查参数,返回字符串参数 """ if params is None: raise ServiceException({'result': 2, 'description': u'{} 参数错误(值为空).'.format(desc)}) if not isinstance(params, Decimal): params = Decimal(params) if not minData and maxData: if not isinstance(maxData, Decimal): maxData = Decimal(maxData) if params <= maxData: return '%g' % params else: raise ServiceException( {'result': 2, 'description': u'%s超出可选范围(值为: %s),可选最大值为%g' % (desc, params, maxData)}) if not maxData and minData: if not isinstance(minData, Decimal): minData = Decimal(minData) if minData <= params: return '%g' % params else: raise ServiceException( {'result': 2, 'description': u'%s超出可选范围(值为: %s),可选最小值为%g' % (desc, params, minData)}) if not minData and not maxData: return '%g' % params else: if not isinstance(minData, Decimal): minData = Decimal(minData) if not isinstance(maxData, Decimal): maxData = Decimal(maxData) if minData <= params <= maxData: return '%g' % params else: raise ServiceException( {'result': 2, 'description': u'%s参数超出可选范围(值为: %s),可取范围为%g-%g' % (desc, params, minData, maxData)}) def test(self, coins): data = {'fun_code': 0x07, 'order_id': '1111', 'coins': coins, 'port': 1, 'time': 60} devInfo = self.send_mqtt(data) return devInfo def _check_package(self, package): """ 获取设备启动的发送数据 根据设备的当前模式以及套餐获取 :param package: :return: """ unit = package.get('unit') _time = package.get('time') chrmt = self.device['otherConf'].get('chrmt') if not chrmt: chrmt = self.get_dev_setting().get('chrmt') # 按时间计费 if chrmt == 'TIME' or chrmt == 'POWER': billingType = 'time' if unit == u'小时': _time = _time * 60 elif unit == u'天': _time = _time * 24 * 60 elif unit == u'秒': _time = _time / 60 elif unit == u'分钟': _time = _time else: raise ServiceException({'result': 2, 'description': u'套餐单位错误，应选取单位(时间)，请联系经销商'}) # 按电量计费 elif chrmt == 'ELEC': billingType = 'elec' if unit != u'度': raise ServiceException({'result': 2, 'description': u'套餐单位错误，应选取单位(度)，请联系经销商'}) else: _time = _time * 100 else: raise ServiceException({'result': 2, 'description': u'套餐单位错误，应选取单位(时间,度)，请联系经销商'}) return _time, unit, billingType # 访问设备，获取设备端口信息 def get_port_status_from_dev(self): data = {'fun_code': 0x01, 'all': True} devInfo = self.send_mqtt(data) portData = devInfo['data']['port_stat'] result = {} for k, v in portData.items(): if v == 'idle': result[k] = {'status': Const.DEV_WORK_STATUS_IDLE} elif v == 'link': result[k] = {'status': Const.DEV_WORK_STATUS_CONNECTED} elif v == 'busy': result[k] = {'status': Const.DEV_WORK_STATUS_WORKING} elif v == 'fault': result[k] = {'status': Const.DEV_WORK_STATUS_FAULT} elif v == 'forbid': result[k] = {'status': Const.DEV_WORK_STATUS_FORBIDDEN} else: result[k] = {'status': Const.DEV_WORK_STATUS_FAULT} allPorts, usedPorts, usePorts = self.get_port_static_info(result) Device.update_dev_control_cache(self._device['devNo'], {'allPorts': allPorts, 'usedPorts': usedPorts, 'usePorts': usePorts}) # 这里存在多线程更新缓存的场景，可能性比较低，但是必须先取出来，然后逐个更新状态，然后再记录缓存 ctrInfo = Device.get_dev_control_cache(self._device['devNo']) for strPort, info in result.items(): if ctrInfo.has_key(strPort): ctrInfo[strPort].update({'status': info['status']}) else: ctrInfo[strPort] = info Device.update_dev_control_cache(self._device['devNo'], ctrInfo) return result def get_port_status(self, force=False): if force: return self.get_port_status_from_dev() ctrInfo = Device.get_dev_control_cache(self._device['devNo']) if not ctrInfo.has_key('allPorts'): self.get_port_status_from_dev() ctrInfo = Device.get_dev_control_cache(self._device['devNo']) allPorts = ctrInfo.get('allPorts', 2) statusDict = {} for ii in range(allPorts): tempDict = ctrInfo.get(str(ii + 1), {}) if tempDict.has_key('status'): statusDict[str(ii + 1)] = {'status': tempDict.get('status')} elif tempDict.has_key('isStart'): if tempDict['isStart']: statusDict[str(ii + 1)] = {'status': Const.DEV_WORK_STATUS_WORKING} else: statusDict[str(ii + 1)] = {'status': Const.DEV_WORK_STATUS_IDLE} else: statusDict[str(ii + 1)] = {'status': Const.DEV_WORK_STATUS_IDLE} allPorts, usedPorts, usePorts = self.get_port_static_info(statusDict) Device.update_dev_control_cache(self._device['devNo'], {'allPorts': allPorts, 'usedPorts': usedPorts, 'usePorts': usePorts}) return statusDict def start_device(self, package, openId, attachParas): if attachParas is None: raise ServiceException({'result': 2, 'description': u'请您选择合适的充电线路、电池类型信息'}) if not attachParas.has_key('chargeIndex'): raise ServiceException({'result': 2, 'description': u'请您选择合适的充电线路'}) port = int(attachParas['chargeIndex']) _time, unit, billingType = self._check_package(package) if package.get('name') == '充满自停' and package.get('coins') == 0 and package.get('price') == 0: coins = 10 * 100 else: coins = int(float(package['coins']) * 100) # 单位为分 if attachParas.get('onPoints'): orderNo = ConsumeRecord.make_no() + self.device.owner.username else: orderNo = attachParas.get('orderNo') data = { 'fun_code': 0x07, 'port': port, 'amount': coins, 'order_id': orderNo } devInfo = self.send_mqtt(data, timeout=MQTT_TIMEOUT.START_DEVICE) ctrInfo = Device.get_dev_control_cache(self.device.devNo) lineInfo = ctrInfo.get(str(port), {}) if not lineInfo or lineInfo.get('status') == Const.DEV_WORK_STATUS_IDLE: lineInfo = { 'port': str(port), 'status': Const.DEV_WORK_STATUS_WORKING, 'order_type': 'apps_start', 'startTime': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'), 'orderNo': orderNo, } Device.update_port_control_cache(self._device['devNo'], lineInfo) devInfo['consumeOrderNo'] = orderNo devInfo['sequanceNo'] = orderNo if billingType == 'time': devInfo['finished_time'] = int(time.time()) + _time * 60 else: devInfo['finished_time'] = int(time.time()) + 3600 * 12 devInfo['ignoreService'] = True devInfo['servicedInfo'] = { 'chargeIndex': port } return devInfo def active_deactive_port(self, port, active): if active: raise ServiceException({'result': 2, 'description': u'该设备不支持直接打开端口'}) return self.stop_charging_port(port) # 停止该端口下的所有任务 def stop_charging_port(self, port): data = {'fun_code': 0x06, 'port': port} devInfo = self.send_mqtt(data) if devInfo['rst'] == 0: Device.update_dev_control_cache(self._device['devNo'], {str(port): {'status': Const.DEV_WORK_STATUS_IDLE}}) return True if devInfo['rst'] == 0 else False def analyze_event_data(self, data): if data['fun_code'] == '32': # 成功启动设备需要回复该事件 return data['order'] if data['fun_code'] == '34': # 如果是结束事件，需要把reason翻译出来 descDict = { 'outofmoney': u'购买的充电时间或电量用完了', 'userstop': u'用户远程结束充电', 'adminstop': u'管理员远程结束充电', 'dealerstop': u'经销商远程结束充电', 'unplug': u'未检测到充电器, 结束充电', 'wattoverload': u'功率过载, 结束充电', 'voltoverload': u'电压过载, 结束充电', 'amproverload': u'电流过载, 结束充电', 'machoverload': u'整机功率过载, 结束充电', 'tempexcursion': u'温度过载, 结束充电', 'stopforfull': u'充满自停, 结束充电' } order = data['order'] order['reasonDesc'] = descDict.get(str(order['cause_desc']), u'') data['order'] = order return data def ack_event(self, order_id, fun_code): data = {'order_id': order_id, 'fun_code': fun_code} self.send_mqtt(data) def get_card_pwd(self): devInfo = self.send_mqtt({'fun_code': 17}) data = devInfo.get('data', {}) card_cur_key = data.get('card_cur_key') enObj = EncryptDate(cardKey) card_cur_key = enObj.decrypt(card_cur_key) return {'card_pwd': card_cur_key} def set_device_function(self, request, lastSetConf): if request.POST.has_key('clearSum'): self.clear_dev_feecount() elif request.POST.has_key('reboot'): self.reboot_device() def set_device_function_param(self, request, lastSetConf): """ 设置参数 对于计费模式做一下转换 顺便服务器保留一份 :param request: :param lastSetConf: :return: """ # 服务器侧的参数 先处理掉 if request.POST.get('id_card_oncefee') is not None: id_card_oncefee = request.POST['id_card_oncefee'] if not id_card_oncefee: raise ServiceException({'result': 2, 'description': u'在线卡单次刷卡金额不能为0'}) Device.get_collection().update_one(filter={'devNo': self.device.devNo}, update={'$set': { 'otherConf.id_card_oncefee': round(float(id_card_oncefee), 2), }}) Device.invalid_device_cache(self.device.devNo) if request.POST.get('refundProtection') is not None: refundProtection = request.POST['refundProtection'] Device.get_collection().update_one(filter={'devNo': self.device.devNo}, update={'$set': { 'otherConf.refundProtection': round(float(refundProtection), 2), }}) Device.invalid_device_cache(self.device.devNo) if request.POST.get('minAfterStartCoins') is not None: minAfterStartCoins = request.POST['minAfterStartCoins'] Device.get_collection().update_one(filter={'devNo': self.device.devNo}, update={'$set': { 'otherConf.minAfterStartCoins': round(float(minAfterStartCoins), 2), }}) Device.invalid_device_cache(self.device.devNo) # 参数发向设备 11, 16指令 setconfig1 = {'fun_code': 11} setconfig2 = {'fun_code': 16} # 音量适配 if request.POST.get('volume_list'): volume_list = request.POST.get('volume_list') volumes = {} self.check_params_range(params=request.POST.get('volume'), minData=0.0, maxData=7.0, desc='语音音量参数') volumes.update({'default': int(request.POST.get('volume'))}) for obj in volume_list: self.check_params_range(params=obj['volume'], minData=0.0, maxData=7.0, desc='音量参数') volumes.update({'{}-{}'.format(obj['start'], obj['end']): int(obj['volume'])}) setconfig1.update({'volumes': volumes}) # 计价模式适配 chrmt = request.POST.get('chrmt') package_time = request.POST.get('package_time', []) package_elec = request.POST.get('package_elec', []) package_power = request.POST.get('package_power', []) if chrmt: price = {'ELEC': int(float(package_elec[0]['elec']) * 1000000)} # 组织功率收费价格参数 TIME = [] if chrmt == 'POWER': # 主板实际并没有power计费方式 实际为功率分档模式的换一种显示 for _item in package_power: if float(_item['price']) == 0: raise ServiceException({'result': 2, 'description': u'计费参数设置(按功率收费)价格不能为0'}) TIME.append( [int(_item['power']), round(1.0 / float(_item['price']) * 60 * 60, 1)] # 价格倍率 * 固定时间(60分钟) * 60秒 ) if not TIME: raise ServiceException({'result': 2, 'description': u'计费参数设置(按功率收费)缺少收费标准'}) setconfig1['chrmt'] = 'TIME' elif chrmt == 'TIME': # 时间模式下 的时间计费规则 for _item in package_time: TIME.append( [int(_item['power']), int(_item['time']) * 60] ) if not TIME: raise ServiceException({'result': 2, 'description': u'计费参数设置(按时间收费)缺少收费标准'}) price['TIME'] = TIME setconfig1['chrmt'] = 'TIME' elif chrmt == 'ELEC': # 同样也处理一次时间计费规则 用于下发给设备 for _item in package_time: TIME.append( [int(_item['power']), int(_item['time']) * 60] ) setconfig1['chrmt'] = 'ELEC' price['TIME'] = TIME setconfig1.update({'price': price}) if request.POST.get('auto_close') is not None: setconfig1.update({'auto_close': request.POST.get('auto_close')}) if request.POST.get('float_time') or request.POST.get('float_watt') or request.POST.get('check_time'): float_charge = {} if request.POST.get('float_time'): float_charge['float_time'] = int(request.POST.get('float_time')) if request.POST.get('float_watt'): float_charge['float_watt'] = int(request.POST.get('float_watt')) if request.POST.get('check_time'): float_charge['check_time'] = int(request.POST.get('check_time')) setconfig1.update({'float_charge': float_charge}) if request.POST.get('port_max_watt'): setconfig1.update({'port_max_watt': int(request.POST.get('port_max_watt'))}) if request.POST.get('port_max_ampr'): setconfig1.update({'port_max_ampr': int(request.POST.get('port_max_ampr'))}) if request.POST.get('mach_max_watt'): setconfig1.update({'mach_max_watt': int(request.POST.get('mach_max_watt'))}) if request.POST.get('mach_max_temp'): setconfig1.update({'mach_max_temp': int(request.POST.get('mach_max_temp'))}) if request.POST.get('mach_max_volt'): setconfig1.update({'mach_max_volt': int(request.POST.get('mach_max_volt'))}) if request.POST.get('noload_check_watt') or request.POST.get('noload_check_time'): noload_check = {} if request.POST.get('noload_check_watt'): noload_check['watt'] = int(request.POST.get('noload_check_watt')) if request.POST.get('noload_check_time'): noload_check['time'] = int(request.POST.get('noload_check_time')) setconfig1.update({'noload_check': noload_check}) if request.POST.get('card_pwd'): card_pwd = request.POST.get('card_pwd') card_pwd2 = request.POST.get('card_pwd2') if card_pwd != card_pwd2: raise ServiceException({'result': 2, 'description': u'两次密码输入不一致'}) self.check_pwd(card_pwd) enObj = EncryptDate(cardKey) setconfig2.update({'card_cur_key': enObj.encrypt(card_pwd)}) self.send_mqtt(setconfig1) unit_price = None if chrmt == 'TIME': unit_price = {'unit': '分钟', 'value': max(map(lambda _: _[1] / 60.0, setconfig1['price']['TIME']))} elif chrmt == 'POWER': unit_price = {'unit': '分钟', 'value': max(map(lambda _: _[1] / 60.0, setconfig1['price']['TIME']))} elif chrmt == 'ELEC': unit_price = {'unit': '度', 'value': round(setconfig1['price']['ELEC'] / 1000000.0, 2)} if unit_price: Device.get_collection().update_one(filter={'devNo': self.device.devNo}, update={'$set': { 'otherConf.unit_price': unit_price, 'otherConf.chrmt': chrmt, }}) Device.invalid_device_cache(self.device.devNo) if request.POST.get('card_refund', None) is not None: setconfig2.update({'card_refund': request.POST.get('card_refund')}) if request.POST.get('card_disable', None) is not None: setconfig2.update({'card_disable': request.POST.get('card_disable')}) if request.POST.get('card_timeout'): setconfig2.update({'card_timeout': int(request.POST.get('card_timeout'))}) if request.POST.get('card_oncefee'): setconfig2.update({'card_oncefee': int(float(request.POST.get('card_oncefee')) * 100)}) self.send_mqtt(setconfig2) def get_dev_setting(self): """ 获取参数显示在前台 :return: """ # 服务器侧的参数 otherConf = self.device['otherConf'] # 获取主板侧的参数 devInfo = self.send_mqtt({'fun_code': 12}) # 参数整合 data = dict() # ID卡刷卡一次的费用 data['id_card_oncefee'] = otherConf.get('id_card_oncefee', 1) data['refundProtection'] = otherConf.get('refundProtection', 5) data['minAfterStartCoins'] = otherConf.get('minAfterStartCoins', 0) configs = devInfo['data'] # 价格适配 price_for_time = configs['price']['TIME'] package_time = [] chrmt = configs.get('chrmt') # 按功率分档收费显示 for _item in price_for_time: package_time.append({'power': _item[0], 'time': round(_item[1] / 60.0, 1)}) # 按电量收费 price_for_elec = round(configs['price']['ELEC'] / 1000000.0, 4) package_elec = [{'elec': price_for_elec, 'price': 1}] # 电量的固定单位是1 # 按功率收费显示 package_power = [] for _item in price_for_time: package_power.append({'power': _item[0], 'price': round(1.0 / (_item[1] / 60.0 / 60.0), 2)}) # 计费规则的添加 有就显示服务器的， 没有就显示主板的 data.update({ 'package_time': package_time, 'package_elec': package_elec, 'package_power': package_power, 'chrmt': otherConf.get('chrmt', chrmt) # 以缓存的为准 }) # 浮充参数的添加 float_charge = configs.get('float_charge', {}) data.update(float_charge) data['auto_close'] = configs.get('auto_close', {}) data['mach_max_watt'] = configs.get('mach_max_watt', 0) data['port_max_ampr'] = configs.get('port_max_ampr', 0) data['port_max_watt'] = configs.get('port_max_watt', 0) data['mach_max_volt'] = configs.get('mach_max_volt', 0) data['mach_max_temp'] = configs.get('mach_max_temp', 0) # 空载适配 data.update({ 'noload_check_watt': int(configs['noload_check'].get('watt', 0)), 'noload_check_time': int(configs['noload_check'].get('time', 0)), }) # 音量适配 volume_list = [] for k, v in configs['volumes'].items(): item = {} if k == 'default': continue if '-' in k: item['start'], item['end'] = k.split('-') item['volume'] = v volume_list.append(item) data.update({ 'volume': configs['volumes']['default'], 'volume_list': volume_list }) # 17 指令 devInfo = self.send_mqtt({'fun_code': 17}) configs2 = devInfo.get('data') data['card_curmode'] = configs2['card_curmode'] data['card_refund'] = configs2['card_refund'] data['card_disable'] = configs2['card_disable'] # data['card_token'] = configs2['card_token'] data['card_timeout'] = configs2['card_timeout'] data['card_oncefee'] = round(configs2['card_oncefee'] / 100.0, 2) state = self.get_dev_consume_count() data.update(state) return data def get_dev_consume_count(self): data = {'fun_code': 8} devInfo = self.send_mqtt(data) total_card = round(devInfo.get('data', {}).get('total_card', 0) * 0.01, 2) return {'total_card': total_card} def reset_total_card(self): data = { 'fun_code': 9 } self.send_mqtt(data) def set_max_watt(self, max_watt): self.send_mqtt({'fun_code': 11, 'max_watt': int(max_watt)}) def lock_unlock_port(self, port, lock=True): portInfo = self.get_port_info(port) if portInfo and portInfo['status'] == Const.DEV_WORK_STATUS_WORKING and lock: raise ServiceException({'result': 2, 'description': u'端口正忙，请先关闭端口后，再禁止端口'}) typeStr = not lock self.send_mqtt({'port': int(port), 'enable': typeStr, 'fun_code': 13}) def check_pwd(self, pwd): if len(pwd) != 6: raise ServiceException({'result': 2, 'description': u'密码必须是6位纯数字密码'}) for char in pwd: if not (char >= '0' and char <= '9'): raise ServiceException({'result': 2, 'description': u'密码必须是6位纯数字密码'}) return def get_card_mode(self): devInfo = self.send_mqtt({'fun_code': 17}) MAP_MODE = { 'NORMAL': 0, 'ISSUE': 1, 'MODKEY': 2, } result = {} result['card_mode'] = MAP_MODE.get(devInfo['data']['card_curmode']) return result def set_card_mode(self, setConf): cardMode = int(setConf.get('card_mode')) data = {'fun_code': 16} if cardMode == 0: data.update({'card_curmode': {'mod': 'NORMAL'}}) elif cardMode == 1: # 格式化为离线卡 self.check_pwd(setConf['new_pwd']) newPwd = setConf['new_pwd'] if not str(setConf['balance']).isdigit(): raise ServiceException({'result': 2, 'description': u'余额必须是数字'}) balance = int(setConf['balance']) if not (balance >= 0 and balance <= 5000): raise ServiceException({'result': 2, 'description': u'余额必须在0和5000元之间'}) card_dft_val = balance * 100 # 硬件模块记录的单位是角 enObj = EncryptDate(cardKey) data.update({'card_curmode': {'mod': 'ISSUE', 'cfg': {'card_new_key': enObj.encrypt(str(newPwd)), 'card_dft_val': card_dft_val}}}) elif cardMode == 2: self.check_pwd(setConf['new_pwd']) oldPwd = setConf.get('old_pwd', '') newPwd = setConf.get('new_pwd', '') enObj = EncryptDate(cardKey) data.update({'card_curmode': {'mod': 'MODKEY', 'cfg': {'card_old_key': enObj.encrypt(str(oldPwd)), 'card_new_key': enObj.encrypt(str(newPwd))}}}) self.send_mqtt(data) def response_card_charge_result(self, cardNo, result): self.send_mqtt({'fun_code': 36, 'card_no': cardNo, 'result': result}) def recharge_card(self, cardNo, money, orderNo=None): self.send_mqtt( {'fun_code': 36, 'result': 1, 'card_no': cardNo, 'charge': int(money * 100), 'order_id': orderNo}) card = Card.objects.filter(cardNo=cardNo, dealerId=self.device.ownerId).first() balance = card.balance + money return { 'result': ErrorCode.SUCCESS, 'description': '' }, balance def response_card_balance(self, cardNo, amount, balance, result): return self.send_mqtt({'fun_code': 35, 'card_no': cardNo, 'balance': RMB.yuan_to_fen(balance), 'result': result, 'amount': RMB.yuan_to_fen(amount)}) def get_current_use(self, **kw): base_data = kw.get('base_data') spDict = kw.get('spDict') sp = ServiceProgress.objects.filter(device_imei=self.device.devNo, port=spDict['port']).first() data = {'fun_code': 2, 'port': spDict.get('port')} devInfo = self.send_mqtt(data) portInfo = devInfo.get('data', {}) exec_orders = portInfo.get('exec_orders', []) running_order = None waiting_order = [] for exec_order in exec_orders: # 第一层筛选 if exec_order['id'] not in sp.consumes: sp.consumes.remove(exec_order['id']) if exec_order['status'] == 'running': running_order = exec_order elif exec_order['status'] == 'waiting': waiting_order.append(exec_order) if len(sp.consumes) == 0: # 上一单没有正常结束 刷新此单的状态 if running_order: sp.consumes.append(running_order['id']) sp.start_time = running_order['exec_time'] sp.isFinished = False sp.finished_time = sp.start_time + running_order['amount_time'] if waiting_order: for wait_one in waiting_order: sp.consumes.append(wait_one['id']) sp.finished_time = sp.start_time + wait_one['amount_time'] sp.save() pay_unit = self.show_pay_unit result_list = [] # 数据整理返回 for exec_order in exec_orders: item = {} item.update(base_data) item['orderNo'] = exec_order['id'] item['port'] = exec_order['port'] if exec_order['status'] == 'running': item['voltage'] = round(portInfo.get('volt', 0), 2) item['power'] = round(portInfo.get('watt', 0), 2) item['ampere'] = round((portInfo.get('ampr', 0) * 0.001), 2) item['usedTime'] = round(exec_order.get('time', 0) / 60.0, 1) # item['elec'] = round(exec_order.get('elec', 0) * 0.000001, 4) if exec_order['chrmt'] == 'TIME': item['needTime'] = '{}分钟'.format(round(exec_order.get('amount_time', 0) / 60.0, 1)) item['leftTime'] = round(exec_order.get('left_time', 0) / 60.0, 1) elif exec_order['chrmt'] == 'ELEC': item['needElec'] = round(exec_order.get('amount_elec', 0) * 0.000001, 2) item['leftElec'] = round(exec_order.get('left_elec', 0) * 0.000001, 4) else: pass if exec_order['order_type'] == 'apps_start': item['consumeMoney'] = '{}{}'.format(round(exec_order.get('money', 0) * 0.01, 2), pay_unit) item['leftMoney'] = '{}{}'.format(round(exec_order.get('left_money', 0) * 0.01, 2), pay_unit) item['order'] = { 'orderNo': exec_order['id'], # 停止按钮传订单停单用 'coin': '{}{}'.format(round(exec_order.get('amount', 0) * 0.01, 2), pay_unit), 'port': exec_order['port'], 'consumeType': 'mobile', } try: orderNo = exec_order['id'] order = ConsumeRecord.objects.filter(orderNo=orderNo).first() package = order.package if package.get('name') == '充满自停' and package.get('coins') == 0 and package.get( 'price') == 0: # 后付费 item['order'] = { 'orderNo': exec_order['id'], # 停止按钮传订单停单用 'coin': '{}{}'.format(0, pay_unit), 'port': exec_order['port'], 'consumeType': 'postpaid' } item['needTime'] = '充满自停' item.pop('needElec', None) item.pop('leftMoney', None) item.pop('leftTime', None) item.pop('leftElec', None) elif order.attachParas.get('vCardId'): item['order']['consumeType'] = 'mobile_vcard' except: pass elif exec_order['order_type'] == 'card_start': item['cardNo'] = exec_order['card_no'] item['cardConsumeMoney'] = exec_order['card_no'] item['cardConsumeMoney'] = '{}{}'.format(round(exec_order.get('money', 0) * 0.01, 2), pay_unit) item['cardLeftMoney'] = '{}{}'.format(round(exec_order.get('left_money', 0) * 0.01, 2), pay_unit) item['order'] = { 'orderNo': exec_order['id'], # 停止按钮传订单停单用 'coin': '{}{}'.format(round(exec_order.get('amount', 0) * 0.01, 2), pay_unit), 'port': exec_order['port'], 'consumeType': 'card', } else: pass elif exec_order['status'] == 'waiting': if exec_order['chrmt'] == 'TIME': item['needTime'] = '{}分钟'.format(round(exec_order.get('amount_time', 0) / 60.0, 1)) item['leftTime'] = round(exec_order.get('left_time', 0) / 60.0, 1) elif exec_order['chrmt'] == 'ELEC': item['needElec'] = round(exec_order.get('amount_elec', 0) * 0.000001, 2) item['leftElec'] = round(exec_order.get('left_elec', 0) * 0.000001, 2) item['desc'] = '此订单已经下发到设备上，上一单运行完毕就会自动运行此订单' item['order'] = { 'orderNo': exec_order['id'], # 停止按钮传订单停单用 'coin': '{}币'.format(round(exec_order.get('amount', 0) * 0.01, 2)), 'port': exec_order['port'], 'consumeType': 'card' if 'cardNo' in exec_order else 'mobile', } if 'cardNo' in exec_order: item['cardNo'] = exec_order['card_no'] item.update(DeviceType.get_services_button(self.device['devType']['id'])) result_list.append(item) return result_list def isHaveStopEvent(self): return True def stop_by_order(self, port, orderNo): data = {'fun_code': 4, 'order_id': orderNo, 'operator': 'user'} self.send_mqtt(data) def clear_dev_feecount(self): data = {'fun_code': 0x09, 'total_coin': True, 'total_card': True} self.send_mqtt(data) def reboot_device(self): # 重启单片机 MessageSender.send(self.device, DeviceCmdCode.SET_DEVINFO, {'reset_mcu': True}) # 重启模块 MessageSender.send(self.device, DeviceCmdCode.SET_DEVINFO, {'restart': True}) @property def show_pay_unit(self): """ 前台显示付费的时候，目前有不同的客户希望 显示不同的单位 有的显示金币 有的显示元， 这个地方处理下 :return: """ if self.device['otherConf'].get('pay_unit'): return self.device['otherConf'].get('pay_unit') return u'币' def get_port_using_detail(self, port, ctrInfo, isLazy=False): return self.get_port_info(port) def stop(self, port=None): return self.stop_charging_port(int(port)) # def __translate_status_from_str(self, status): # dictConf = { # 'idle': Const.DEV_WORK_STATUS_IDLE, # 'busy': Const.DEV_WORK_STATUS_WORKING, # 'forbid': Const.DEV_WORK_STATUS_FORBIDDEN, # 'fault': Const.DEV_WORK_STATUS_FAULT, # 'running': Const.DEV_WORK_STATUS_WORKING # } # return dictConf.get(status, Const.DEV_WORK_STATUS_IDLE) # # def get_many_port_info(self, portList): # data = {'fun_code': 1, 'all': True} # devInfo = self.send_mqtt(data) # portInfo = devInfo['data'] # portParam = portInfo.get('port_param', {}) # exec_queue = portInfo.get('exec_queue', {}) # # pay_unit = self.show_pay_unit # resultDict = {} # for port, exec_orders in exec_queue.items(): # if port not in portList: # continue # result = {'index': port} # onePortParam = portParam.get(port, {}) # _wait = [] # for exec_order in exec_orders: # if exec_order['status'] == 'running': # # result['voltage'] = round(onePortParam.get('volt', 0), 2) # result['power'] = round(onePortParam.get('watt', 0), 2) # result['ampere'] = round((onePortParam.get('ampr', 0) * 0.001), 2) # result['devTemp'] = round((portInfo.get('mach_temp', 0)), 2) # result['status'] = self.__translate_status_from_str(exec_order['status']) # result['usedTime'] = round(exec_order.get('time', 0) / 60.0, 2) # result['usedElec'] = round(exec_order.get('elec', 0) * 0.000001, 4) # result['coins'] = '{}'.format(round(exec_order['amount'] / 100.0, 2)) # # if 'left_time' in exec_order: # result['leftTime'] = round(exec_order.get('left_time', 0) / 60.0, 2) # # elif 'left_elec' in exec_order: # result['leftElec'] = round(exec_order.get('left_elec', 0) * 0.000001, 4) # # if exec_order['order_type'] == 'apps_start': # result['consumeType'] = 'mobile' # result['consumeMoney'] = '{}{}'.format(round(exec_order.get('money', 0) * 0.01, 2), # pay_unit) # result['leftMoney'] = '{}{}'.format(round(exec_order.get('left_money', 0) * 0.01, 2), # pay_unit) # try: # orderNo = exec_order['id'] # order = ConsumeRecord.objects.filter(orderNo=orderNo).first() # if not order: # result['nickName'] = '经销商上分' # else: # result['nickName'] = order.user.nickname # except Exception: # pass # # if exec_order['order_type'] == 'card_start': # result['consumeType'] = 'card' # try: # card = Card.objects.get(cardNo=exec_order['card_no']) # result['nickName'] = card.cardName or card.nickName # except: # pass # result['cardNo'] = exec_order['card_no'] # result['cardConsumeMoney'] = '{}{}'.format(round(exec_order.get('money', 0) * 0.01, 2), # pay_unit) # result['cardLeftMoney'] = '{}{}'.format(round(exec_order.get('left_money', 0) * 0.01, 2), # pay_unit) # result['cardBalance'] = '{}{}'.format(round(exec_order['balance'] * 0.01, 2), pay_unit) # # # elif exec_order['status'] == 'waiting': # _one = {} # if exec_order['order_type'] == 'apps_start': # _one['consumeType'] = 'mobile' # try: # order = ConsumeRecord.objects.filter(orderNo=exec_order['id']).first() # if not order: # _one['nickName'] = '经销商上分' # else: # _one['nickName'] = order.user.nickname # except Exception: # pass # elif exec_order['order_type'] == 'card_start': # _one['consumeType'] = 'card' # _one['cardNo'] = exec_order['card_no'] # _one['cardBalance'] = '{}{}'.format(round(exec_order['balance'] * 0.01, 2), pay_unit) # # try: # card = Card.objects.get(cardNo=exec_order['card_no']) # _one['nickName'] = card.cardName or card.nickName # except Exception: # pass # # if 'amount_time' in exec_order: # _one['needTime'] = '{}分钟'.format(round(exec_order['amount_time'] / 60.0, 1)) # if 'amount_elec' in exec_order: # _one['needElec'] = '{}度'.format(round(exec_order['amount_elec'] / 1000000.0, 2)) # if 'amount' in exec_order: # _one['coins'] = '{}{}'.format(round(exec_order['amount'] / 100.0, 2), pay_unit) # if 'create_time' in exec_order: # _one['createTime'] = datetime.datetime.fromtimestamp( # int(exec_order['create_time'])).strftime('%m-%d %H:%M:%S') # # _wait.append(_one) # # if _wait: # result['waittingOrder'] = _wait # # resultDict[port] = result # # return resultDict