# -*- coding: utf-8 -*- # !/usr/bin/env python import datetime import logging from apps.web.constant import Const from apps.web.device.models import Group, Part, Device from apps.web.eventer.base import FaultEvent, WorkEvent from apps.web.eventer import EventBuilder from apps.web.south_intf.platform import notify_event_to_north from apps.web.south_intf.zhejiang_fire import send_event_to_zhejiang from apps.web.user.models import ServiceProgress, MyUser from apps.web.user.transaction_deprecated import refund_money logger = logging.getLogger(__name__) class builder(EventBuilder): def __getEvent__(self, device_event): if device_event['data'].get('cmd') == 120: return DELIXIAlertEvent(self.deviceAdapter, device_event) event_data = self.deviceAdapter.analyze_event_data(device_event['data']) if not event_data: return None if event_data['cmdCode'] == 100: return ChargingDLXWorkEvent(self.deviceAdapter, event_data) class DELIXIAlertEvent(FaultEvent): def __Analyze_alert_data(self, data): alertInfo = {'cmdCode': data['cmd'], 'logicalCode': self.device['logicalCode']} address = Group.get_group(self.device['groupId'])['address'] # 这里判断数据格式 if 'status' not in data: logger.error('Data arrays have no keywords status') return # 这里做漏电告警处理 if '5' in data['status']: electricityNum = str(int(data['values'][0:4], 16)) + 'mA' alertInfo['electricity'] = {'electricityNum': electricityNum, 'address': address, 'reasonCode': '12', 'reason': u'在{}编号为{}发生漏电,漏电量为{}' .format(address, self.device['logicalCode'], electricityNum)} # 这里做高温告警处理 if '6' in data['status']: temperatureAccess = [index for index, acces in enumerate(data['status'], 1) if acces == '6'] temperatureAlertList = [] for i in temperatureAccess: temperatureValue = str(int(data['values'][(i - 1) * 4:(i - 1) * 4 + 4], 16)) temperatureAlertList.append( {'temperatureValue': temperatureValue, 'address': address, 'reasonCode': '11', 'reason': u'在{}编号为{}的设备有高温预警,当前温度为{}摄氏度' .format(address, self.device['logicalCode'], temperatureValue)}) alertInfo['temperature'] = temperatureAlertList return alertInfo def do(self, **args): # 判断不存在的设备网上报 if not self.device['ownerId']: logger.error('This device cant find a dealer') return # 是否存在温感和电感 temperaturePart = Part.objects(logicalCode = self.device['logicalCode'], partType = '3001') electricityPart = Part.objects(logicalCode = self.device['logicalCode'], partType = '3002') if not temperaturePart.count() or not electricityPart.count(): logger.error( 'There are no transformers in the locigalcode {} equipment'.format(self.device['logicalCode'])) return # 处理数据 eventInfo = self.__Analyze_alert_data(self.event_data['data']) try: # 先处理高温情况 if eventInfo.has_key('temperature'): for InfoDetail in eventInfo['temperature']: send_event_to_zhejiang(self.dealer, self.device, InfoDetail, partId = temperaturePart[0].id) # 提示用户 group = Group.get_group(self.device['groupId']) self.notify_dealer('device_fault', **{ 'title': u'注意！注意！您的设备发生故障', 'device': u'组号：:%s, 二维码编号:%s' % (self.device['groupNumber'], self.device['logicalCode']), 'location': u'组名称：%s, 地址:%s' % (group['groupName'], group['address']), 'fault': InfoDetail['reason'], 'notifyTime': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') }) # 处理漏电情况 elif eventInfo.has_key('electricity'): # 获取漏电告警插件 send_event_to_zhejiang(self.dealer, self.device, eventInfo['electricity'], partId = electricityPart[0].id) # 提示用户 group = Group.get_group(self.device['groupId']) self.notify_dealer('device_fault', **{ 'title': u'注意！注意！您的设备发生故障', 'device': u'组号：:%s, 二维码编号:%s' % (self.device['groupNumber'], self.device['logicalCode']), 'location': u'组名称：%s, 地址:%s' % (group['groupName'], group['address']), 'fault': eventInfo['electricity']['reason'], 'notifyTime': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') }) except: logger.error('Array {} nonspecification'.format(eventInfo)) return self.record(detail = eventInfo) class ChargingDLXWorkEvent(WorkEvent): # 不处理 def do(self, **args): if self.event_data['chargeStatus'] == '01': return if self.event_data['reasonCode'] == '04': devNo = self.device['devNo'] try: lineInfo = Device.update_port_control_cache(devNo, self.event_data) backCoins = lineInfo['coins'] openId = lineInfo['openId'] group = Group.get_group(self.device['groupId']) title = u"\\n\\n结束原因：\\t\\t{reason}\\n\\n设备编号：\\t\\t{logicalCode}-{port}\\n\\n设备地址：\\t\\t{address}\\n\\n".format( reason = self.event_data["reason"], logicalCode = self.device["logicalCode"], port = lineInfo['port'], address = group["address"], ) consumeDict = {'chargeIndex': lineInfo['port'], 'reason': lineInfo['reason']} # 通知充电完成 user = MyUser.objects(openId = openId, groupId = self.device['groupId']).first() self.notify_user( managerialOpenId = user.managerialOpenId if user else "", templateName = "service_complete", title = title, service = u"充电服务", finishTime = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'), remark = u'谢谢您的支持') if not self.device.is_auto_refund: ServiceProgress.update_progress_and_consume_rcd( self.device['ownerId'], {'open_id': openId, 'device_imei': devNo, 'port': lineInfo['port'], 'isFinished': False}, consumeDict ) else: refund_money(self.device, backCoins, lineInfo['openId']) consumeDict.update({'refundedMoney': str(backCoins)}) ServiceProgress.update_progress_and_consume_rcd( self.device['ownerId'], {'open_id': openId, 'device_imei': devNo, 'port': lineInfo['port'], 'isFinished': False}, consumeDict) desc = u'您使用的%s号端口充电，共付款:%s金币，给您退款:%s金币' % ( lineInfo['port'], lineInfo['coins'], backCoins) self.notify_user(user.managerialOpenId if user else '', 'refund_coins', **{ 'title': desc, 'backCount': u'金币：%s' % backCoins, 'finishTime': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') }) except Exception as e: logger.error(e) finally: Device.clear_port_control_cache(devNo, str(self.event_data['port'])) notify_event_to_north(self.dealer, self.device, level = Const.EVENT_NORMAL, desc = self.event_data["reason"])