# -*- coding: utf-8 -*- # !/usr/bin/env python """ web.device.views ~~~~~~~~~ """ import datetime import itertools import logging from collections import Counter import simplejson as json from bson.objectid import ObjectId from django.conf import settings from django.core.cache import cache from django.core.handlers.wsgi import WSGIRequest from mongoengine.errors import NotUniqueError, DoesNotExist from typing import List, TYPE_CHECKING, Dict, Union from voluptuous import MultipleInvalid from apilib.utils import alphanum_key, natural_sort from apilib.utils_json import JsonResponse from apps.dispatch.commands import TopicCommand from apps.web.agent.models import Agent from apps.web.common.models import AddressType from apps.web.common.models import District from apps.web.constant import Const, DeviceCmdCode, DeviceOnlineStatus, support_policy_weifule, \ support_policy_device from apps.web.core import ROLE from apps.web.core.exceptions import ServiceException from apps.web.core.helpers import ActionDeviceBuilder from apps.web.core.models import DriverCode, DriverAdapter, DriverEventer from apps.web.core.networking import MessageSender from apps.web.core.utils import JsonErrorResponse, JsonOkResponse from apps.web.dealer.models import Dealer from apps.web.device.define import DeviceChannelType from apps.web.device.models import Device, DeviceType, Group, MajorDeviceType, DeviceCommand, Cell, Town, \ ManagerInputDev, SwapGroup, FaultRecord from apps.web.device.timescale import OfflineCoinsManager from apps.web.device.validation import equipGroupSchema from apps.web.exceptions import CustomizedValidationError from apps.web.helpers import DeviceTypeVisitor, get_user_manager_agent from apps.web.management.models import Manager from apps.web.south_intf.swap_carcharger import SwapContract from apps.web.south_intf.yuhuan_fire import YuhuanNorther from apps.web.user.models import MyUser, Card from apps.web.utils import ( translate_sendmsg_error, permission_required, pluckPayload, error_tolerate, check_role, record_operation_behavior, concat_user_login_entry_url, concat_user_center_entry_url ) from apps.web.wrapper import request_limit_by_user from taskmanager.mediator import task_caller logger = logging.getLogger(__name__) if TYPE_CHECKING: from apps.web.device.models import GroupDict from apps.web.device.models import DeviceDict from apps.web.dealer.models import SubAccount @permission_required(ROLE.dealer, ROLE.subaccount) def updateEquipmentRemarks(request): # type: (WSGIRequest)->JsonResponse curr_user = request.user # type: Union[Dealer, SubAccount] if not curr_user.normal: return JsonErrorResponse(description = u'账号异常，不能进行该操作') ownerId = str(request.user.bossId) devNo = request.POST.get('eValue', None) remarks = request.POST.get('remarks', None) if devNo is None or remarks is None: return JsonResponse({"result": 0, "description": u"缺少参数", 'payload': {}}) dev = Device.get_dev(devNo) if dev is None: return JsonResponse({"result": 0, "description": u"找不到设备", 'payload': {}}) if dev['remarks'] == remarks: # 已经改了 return JsonResponse({"result": 1, "description": None, 'payload': {}}) try: dev['remarks'] = remarks Device.get_collection().update_one({'devNo': devNo}, {'$set': {'remarks': remarks}}) Device.invalid_device_cache(dev['devNo']) return JsonResponse({"result": 1, "description": None, 'payload': {}}) except Exception, e: logger.exception('update collection error=%s,devNo=%s,ownerId=%s' % (e, devNo, ownerId)) return JsonResponse({"result": 0, "description": u'修改失败', 'payload': {}}) @permission_required(ROLE.dealer, ROLE.subaccount) def batchUpdateEquipment(request): # type: (WSGIRequest)->JsonResponse curr_user = request.user # type: Union[Dealer, SubAccount] if not curr_user.normal: return JsonErrorResponse(description = u'账号异常，不能进行该操作') if 'value[]' in request.POST: instructions = request.POST.get('instructions') devNoList = request.POST.getlist('value[]') else: payload = json.loads(request.body) instructions = payload.get('instructions') devNoList = payload.get('value') if not devNoList: return JsonResponse({'result': 0, 'description': u'请选择设备', 'payload': {}}) filterDevNoList = [] for devNo in devNoList: device = Device.get_dev(devNo) if not device: continue group = Group.get_group(device['groupId']) if group['ownerId'] != str(request.user.bossId): return JsonResponse({'result': 0, 'description': u'不能修改合伙人设备', 'payload': {}}) filterDevNoList.append(devNo) if not filterDevNoList: return JsonResponse({'result': 0, 'description': u'设备不存在，请刷新后再试', 'payload': {}}) Device.get_collection().update({'devNo': {'$in': filterDevNoList}}, {'$set': {'instructions': instructions}}, multi = True, upsert = False) Device.invalid_many_device_cache(devNoList) return JsonResponse({'result': 1, 'description': None, 'payload': {}}) @permission_required(ROLE.dealer, ROLE.subaccount) def batchUpdateEquipmentPriceDescription(request): # type: (WSGIRequest)->JsonResponse curr_user = request.user # type: Union[Dealer, SubAccount] if not curr_user.normal: return JsonErrorResponse(description = u'账号异常，不能进行该操作') if 'logicalCode[]' in request.POST: priceDescription = request.POST.get('priceDescription') logicalCodeList = request.POST.getlist('logicalCode[]') else: payload = json.loads(request.body) priceDescription = payload.get('priceDescription') logicalCodeList = payload.get('logicalCode') if not logicalCodeList: return JsonResponse({'result': 0, 'description': u'请选择设备', 'payload': {}}) filterDevNoList = [] devNos = [] for logicalCode in logicalCodeList: device = Device.get_dev_by_l(logicalCode) if not device: continue else: devNos.append(device.devNo) group = Group.get_group(device['groupId']) if group['ownerId'] != str(request.user.bossId): return JsonResponse({'result': 0, 'description': u'不能修改合伙人设备', 'payload': {}}) filterDevNoList.append(logicalCode) if not filterDevNoList: return JsonResponse({'result': 0, 'description': u'设备不存在，请刷新后再试', 'payload': {}}) Device.get_collection().update({'devNo': {'$in': devNos}}, {'$set': {'priceDescription': priceDescription}}, multi = True, upsert = False) Device.invalid_many_device_cache(devNos) return JsonResponse({'result': 1, 'description': None, 'payload': {}}) @permission_required(ROLE.dealer, ROLE.agent, ROLE.subaccount) def getEquipmentNumAndAddressList(request): # type: (WSGIRequest)->JsonResponse ownerId = request.POST.get('dealerId') or str(request.user.bossId) groupIds = Group.get_group_ids_of_dealer(ownerId) partnerGroupIds = Group.get_group_ids_of_partner(ownerId) groupIds.extend(partnerGroupIds) groupList = Group.get_groups_by_group_ids(groupIds).values() for group in groupList: group['name'] = group['groupName'] if group['groupId'] not in partnerGroupIds: group['isManager'] = True else: group['isManager'] = False return JsonResponse({ "result": 1, "description": None, 'payload': { "groups": sorted(groupList, key = lambda d: alphanum_key(d["name"])) } }) @permission_required(ROLE.dealer, ROLE.subaccount) def placeInfo(request): # type: (WSGIRequest)->JsonResponse ownerId = str(request.user.bossId) groupIds = Group.get_group_ids_of_dealer(ownerId) groupPartnerList = Group.get_group_ids_of_partner(ownerId) groupIds.extend(groupPartnerList) groupList = Group.get_groups_by_group_ids(groupIds).values() dataList = [] for group in groupList: item = { 'address': group['address'], 'name': group['groupName'], 'groupId': group['groupId'], 'ownerId': group['ownerId'] } if group['groupId'] in groupPartnerList: item.update({ 'isManager': False }) return JsonResponse({"result": 1, "description": None, 'payload': dataList}) @permission_required(ROLE.dealer, ROLE.subaccount) def devices(request): # type: (WSGIRequest)->JsonResponse groupId = request.GET.get('groupId', None) if groupId is None: return JsonResponse({"result": 0, "description": u'没有传入正确的参数', 'payload': {}}) devNoList = Device.get_devNos_by_group([groupId]) devDict = Device.get_dev_by_nos(devNoList) dataList = [] for devNo, dev in devDict.items(): dataList.append({ 'logicalCode': dev['logicalCode'], 'devNo': dev['devNo'], 'ownerId': dev['ownerId'], 'groupNum': dev['groupNumber'], 'equipmentId': dev['devNo'], 'equipmentType': dev['devType']['name'], 'equipmentValue': dev['groupNumber']}) return JsonResponse({"result": 1, "description": None, 'payload': dataList}) @permission_required(ROLE.dealer, ROLE.subaccount) def getEquipmentsByGroupId(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) if request.body else {} groupId = payload.get('groupId', None) if not groupId: return JsonErrorResponse(description = u'参数错误，请刷新') groupId = groupId.split("###")[0] devNoList = Device.get_devNos_by_group([groupId]) devDict = Device.get_dev_by_nos(devNoList) # type: Dict[str, DeviceDict] dataList = [ { 'ownerId': device['ownerId'], 'groupNumber': device['groupNumber'], 'remarks': device['remarks'], 'devType': device.devTypeName, 'logicalCode': device.logicalCode, 'devNo': device.devNo, 'groupId': device.groupId, 'online': device.online, 'status': device.status, 'statusInfo': device.statusInfo } for devNo, device in devDict.items() ] return JsonOkResponse(payload = dataList) @permission_required(ROLE.dealer, ROLE.subaccount) def readNewEquipment(request): # type: (WSGIRequest)->JsonResponse logicalCode = request.GET.get('logicalCode', None) devNo = Device.get_devNo_by_logicalCode(logicalCode) if devNo is None: return JsonResponse({'result': 0, 'description': u"设备号对应错误", 'payload': {}}) # 因为需要获取电平信息，必须从数据库中获取 dev = Device.get_dev(devNo) if dev is None: return JsonResponse({'result': 0, 'description': u"找不到设备", 'payload': {}}) return JsonResponse({ "result": 1, "description": None, 'payload': { 'battery': dev.get('battery', 1), 'pulseInterval1': dev.get('pulseInterval1', 200), 'pulseWidth1': dev.get('pulseWidth1', 50) } }) @permission_required(ROLE.dealer, ROLE.subaccount) def setEquipmentGroupNumber(request): # type: (WSGIRequest)->JsonResponse logicalCode = request.POST.get('logicalCode', None) # todo groupNumber必须得填 groupNumber = request.POST.get('groupNumber', None) if logicalCode is None or groupNumber is None: return JsonResponse({'result': 0, 'description': u'输入的参数非法', 'payload': {}}) dev = Device.get_dev_by_l(logicalCode) dev['groupNumber'] = groupNumber try: Device.get_collection().update_one({'logicalCode': logicalCode}, {'$set': {'groupNumber': groupNumber}}) Device.invalid_device_cache(dev['devNo']) except Exception, e: logger.exception('update device groupNumber error=%s,logicalCode=%s,groupNumber=%s' % (e, logicalCode, groupNumber)) return JsonResponse({"result": 0, "description": u'保存编号出错，请稍候再试', 'payload': {}}) YuhuanNorther.send_dev_info(dev) return JsonResponse({"result": 1, "description": None, 'payload': {}}) @permission_required(ROLE.dealer, ROLE.subaccount) def szNewEquipment(request): # type: (WSGIRequest)->JsonResponse logicalCode = request.POST.get('logicalCode', None) pulseInterval1 = request.POST.get('pulseInterval1', None) pulseWidth1 = request.POST.get('pulseWidth1', None) battery = request.POST.get('battery', None) devNo = Device.get_devNo_by_logicalCode(logicalCode) if devNo is None or pulseWidth1 is None or pulseInterval1 is None or battery is None: return JsonResponse({'result': 0, 'description': u'输入的参数非法', 'payload': {}}) dev = Device.get_dev(devNo) # type: DeviceDict if not dev: return JsonResponse({'result': 0, 'description': u'找不到该设备', 'payload': {}}) if not dev.online: return JsonResponse({'result': 0, 'description': u'当前设备不在线，无法进行设置', 'payload': {}}) result = {'rst': 0} if dev.channelType != DeviceChannelType.Channel_BT: result = MessageSender.send(dev, DeviceCmdCode.SET_DEVINFO, { 'IMEI': devNo, 'pulse_set': { 'pwm_inter': int(pulseInterval1), 'pwm_wid': int(pulseWidth1), 'pwm_idle': int(battery) } }) if result['rst'] == 0: try: Device.get_collection().update_one( {'devNo': devNo}, {'$set': { 'pulseInterval1': pulseInterval1, 'pulseWidth1': pulseWidth1, 'battery': battery } } ) Device.invalid_device_cache(devNo) except Exception as e: logger.exception(e) return JsonResponse({'result': 0, 'description': u'数据库操作异常，请稍候重试', 'payload': {}}) else: return JsonResponse({'result': 0, 'description': translate_sendmsg_error(result['rst']), 'payload': {}}) return JsonResponse({'result': 1, 'description': None, 'payload': {}}) @permission_required(ROLE.dealer, ROLE.subaccount) def equipmentInfoDetail(request): # type: (WSGIRequest)->JsonResponse logicalCode = request.GET.get('logicalCode', None) ownerId = str(request.user.bossId) agentId = str(request.user.agentId) dealer = Dealer.objects(id = ownerId).first() if dealer is None: return JsonErrorResponse(description = u'不存在的经销商') if logicalCode is None: return JsonErrorResponse(description = u"缺少参数devNo") dev = Device.get_dev_by_logicalCode(logicalCode) # type: DeviceDict if dev is None: return JsonErrorResponse(description = u"找不到设备") device = dev.my_obj # type: Device if device is None: return JsonErrorResponse(description = u"设备不存在") tempElecPrice = device.otherConf.get('tempElecPrice', '') item = { 'devNo': dev.devNo, 'logicalCode': dev.logicalCode, 'groupNumber': dev['groupNumber'], 'online': dev.online, 'url': concat_user_login_entry_url(l=logicalCode), 'agentId': agentId, 'iccid': dev.iccid, 'sim': dev.imsi, 'simStatus': dev.simStatus, 'isFault': dev['isFault'], 'isDND': dev.get('isDND', False), 'isRent': dev.get("isRent", False), 'isDNDTimeInterval': dev.get('isDNDTimeInterval', []), 'autoRefund': dev.is_auto_refund, 'status': dev.status, 'statusInfo': dev.statusInfo, 'dateTimeAdded': dev['dateTimeAdded'], 'remarks': dev['remarks'], 'instructions': dev['instructions'], 'priceDescription': dev.get('priceDescription', ''), 'channelType': dev.channelType, 'lng': dev.lng, 'lat': dev.lat, 'isManager': True if dev.ownerId == ownerId else False, 'devType': dev.devType, 'remoteOperationOrder': dev.devTypeFeatures.get('remoteOperationOrder', False), 'tempElecPrice': tempElecPrice, 'quantity': getattr(device, 'quantity', 0), 'consumptionQuantity': getattr(device, 'consumptionQuantity', 0), 'itemType': getattr(device, 'itemType', 0), 'simChargeAuto': getattr(device, 'simChargeAuto', False), 'deviceWarning': dev.is_warning } item.update({'simExpireDate': dev.formatSimExpireDate}) if dev.devTypeCode in [Const.DEVICE_TYPE_CODE_WEIFULE_POLICY_CLASSIC]: item.update({'hasTempPackage': False}) elif dev.devTypeCode in support_policy_device + support_policy_weifule: item.update({'hasTempPackage': True}) else: item.update({'hasTempPackage': dealer.hasTempPackage}) item.update({'liveUrl': device.otherConf.get('liveUrl', '#')}) item.update({'liveLimitedPrice': device.otherConf.get('liveLimitedPrice', '0.0')}) if device.devType.get('code') in support_policy_weifule: pass elif device.devType.get('code') in support_policy_device: pass else: # TODO 根据主类型判断是否需要显示临时电价(只有jndz在用) if (u"电" in dev["majorDeviceType"]) and (u'电吹风' not in dev["majorDeviceType"]): item.update({"hasTempElecPrice": dealer.hasTempPackage}) # 特殊处理网关一体化设备 if dev.devTypeCode == Const.DEVICE_TYPE_CODE_CHARGING_BL_GATEWAYPLUG: rcd = Device.get_collection().find({'logicalCode':logicalCode})[0] item['gatewayImei'] = rcd['gateImei'] if not dev.groupId: item['address'] = '' else: group = Group.get_group(dev.groupId) item['groupId'] = dev.groupId item['address'] = group['address'] item['name'] = group['groupName'] item['groupName'] = group['groupName'] item['defaultInstructions'] = dev.devType.get('instructions', '') item['autoRefundEnable'] = dev.devType.get('autoRefundEnable', DeviceType.autoRefundEnable.default) item['devTypeName'] = dev.devTypeName try: devTypeDriver = DriverCode.objects.get(code=dev.devTypeCode) dev.update(devTypeDriver.features) except Exception as e: logger.exception('get driver error,dev=%s, e=%s' % (dev, e)) if dev.devTypeCode == Const.DEVICE_TYPE_CODE_TIMESWITCH7: item['pricePerHour'] = dev['otherConf'].get('pricePerHour', 2.0) if dev.bill_as_service_feature.support: item['billAsService'] = dict(dev.bill_as_service_feature) return JsonOkResponse(payload=item) @permission_required(ROLE.dealer, ROLE.agent, ROLE.subaccount) def groupUsedNumber(request): # type: (WSGIRequest)->JsonResponse groupId = request.GET.get('groupId', None) if groupId is None: return JsonErrorResponse(description = u"缺少参数groupId") devNoList = Device.get_devNos_by_group([groupId]) devs = Device.get_dev_by_nos(devNoList).values() para = [{'groupNumber': dev['groupNumber']} for dev in devs] return JsonOkResponse(payload = sorted(para, key = lambda d: alphanum_key(str(d['groupNumber'])))) @permission_required(ROLE.dealer, ROLE.subaccount) def groupEquipmentTransfer(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) toGroupId = payload.get('toGroupId', None) devNo = payload.get('equipmentId', None) groupNumber = payload.get('groupNumber', None) if toGroupId is None or devNo is None or groupNumber is None: return JsonResponse({"result": 0, "description": u"缺少参数", 'payload': {}}) dev = Device.get_dev(devNo) if dev is None: return JsonResponse({"result": 0, "description": u"找不到设备", 'payload': {}}) group = Group.get_group(toGroupId) if group is None: return JsonResponse({"result": 0, "description": u"无法找到您想要修改到的组", 'payload': devNo}) if dev['groupId'] == toGroupId and dev['groupNumber'] == groupNumber: return JsonResponse({"result": 1, "description": u"数据一模一样，不需要更新", 'payload': devNo}) # 更新数据库中的数据 try: Device.get_collection() \ .update_one({'devNo': devNo}, {'$set': {'groupId': toGroupId, 'groupNumber': groupNumber}}) except Exception, e: logger.exception('update device error=%s,devNo=%s,togroupId=%s,newgroupNumber=%s' % (e, devNo, toGroupId, groupNumber)) finally: Device.invalid_device_cache(devNo) Device.invalid_group_device_list_cache([dev['groupId'], toGroupId]) return JsonResponse({"result": 1, "description": None, 'payload': devNo}) @permission_required(ROLE.dealer, ROLE.subaccount) def delGroup(request): # type: (WSGIRequest)->JsonResponse ownerId = str(request.user.bossId) groupId = request.POST.get('groupId', None) if groupId is None: return JsonErrorResponse(description = u"缺少参数") group = Group.get_group(groupId) if group.ownerId != ownerId: return JsonErrorResponse(description = u"参数错误") devNos = Device.get_devNos_by_group([groupId]) if len(devNos) > 0: return JsonErrorResponse(description = u"该地址下还有设备，请您转移设备到其他地址后，再删除该地址") userCount = MyUser.get_collection().find({'groupId': groupId}).count() if userCount > 0: return JsonErrorResponse(description = u"该地址下还有用户的充值，无法删除地址，建议编辑地址") card = Card.objects(groupId = groupId).first() if card: return JsonErrorResponse(description = u"该地址下还有用户绑定的实体卡，无法删除地址，建议编辑地址") # 对接丰图平台 if request.user.myBoss.supports('supportFengTu'): from apps.web.api.ft_north.utils import deleteStationReport deleteStationReport(groupId) # 北京丰台平台删除组 if request.user.myBoss.supports('supportBeiJingFengTai'): from apps.web.south_intf.bj_north.api import delete_station_info delete_station_info(groupId) if group.get('swapFlag',False): SwapGroup.delete_group(groupId) result = Group.delete_Group(ownerId, groupId) if not result: return JsonErrorResponse(description = u'删除地址失败') return JsonOkResponse() @permission_required(ROLE.dealer, ROLE.agent, ROLE.subaccount) def saveEquipmentGroup(request): """ 地址的修改 :param request: :return: """ payload = json.loads(request.body) try: data = equipGroupSchema(payload) except MultipleInvalid as me: return JsonErrorResponse(description=u"参数校验异常【】".format(me.path[0])) logger.info("[saveEquipmentGroupDefault], request user = {}; payload = {}".format(request.user.id, data)) # TODO zjl 这个场景需要详细测试 if "customerId" not in payload: ownerId = str(request.user.bossId) else: ownerId = str(payload.get("customerId")) groupId = data.get('groupId', None) dealer = Dealer.objects.get(id=ownerId) # 最后去更新组地址的信息 if groupId is None: success, description, group_id = Group.add_group( ownerId=ownerId, name=data["name"], districtId=data["districtId"], address=data["address"], addressType=data["addressType"], isDefault=data["isDefault"], discountRuleDict=dealer.format_default_discount, discountCardRuleDict=dealer.format_card_discount, country=data["country"], tag=data["tag"], beforeCharge=data["beforeCharge"] ) else: success, description, group_id = Group.update_group( group_id=groupId, ownerId=ownerId, groupName=data["name"], districtId=data["districtId"], address=data["address"], addressType=data["addressType"], isDefault=data["isDefault"], beforeCharge=data["beforeCharge"], popPriceDescriptionButton=data.get("popPriceDescriptionButton", False), country=data["country"], tag=data["tag"], ) return JsonOkResponse() if success else JsonErrorResponse( description=description, payload={'groupId': group_id} ) # 经销商扫描设备 @permission_required(ROLE.dealer, ROLE.agent, ROLE.subaccount) def checkEquipment(request): # type: (WSGIRequest)->JsonResponse scannedURL = request.GET.get('uniqueCode', None) if not scannedURL: return JsonResponse({'result': 100, 'description': u'错误的二维码或二维码已损坏'}) logger.debug('scan url is {}'.format(scannedURL)) try: from urlparse import urlparse, parse_qs if urlparse(scannedURL).hostname != settings.MY_DOMAIN: return JsonResponse({'result': 100, 'description': u'二维码错误'}) parsedQueryParams = parse_qs(urlparse(scannedURL).query) if ('l' not in parsedQueryParams) and ('devNo' not in parsedQueryParams): return JsonResponse({'result': 100, 'description': u'错误的二维码或二维码已损坏'}) devNo = logicalCode = None if 'l' in parsedQueryParams: logicalCode = parsedQueryParams['l'][0].strip() devNo = Device.get_devNo_by_logicalCode(logicalCode) elif 'devNo' in parsedQueryParams: # 通过devNo扫描进入系统的为遗留设备，这里做兼容处理，devNo == logicalCode devNo = logicalCode = parsedQueryParams['devNo'][0].strip() if devNo is None: return JsonResponse({'result': 101, 'description': u'该机器尚未与软件绑定，请联系客服完成绑定之后再操作'}) dev = Device.get_dev(devNo) if dev and dev.get('groupId', None): return JsonResponse( {'result': 102, 'description': u'设备已经注册', 'payload': {'logicalCode': logicalCode, 'devNo': devNo}}) #: 防止跨代理商绑定，防止串货 #: 暂时停止限制 # if dev and dev.get('ownerId',None): # oldDealer = Dealer.objects(id=str(dev['ownerId'])).first() # if oldDealer and request.user.agentId != oldDealer.agentId: # return JsonResponse({'result': 101, 'description': u'该设备移动支付模块不允许更换到其他代理商名下'}) return JsonResponse({'result': 1, 'description': u'开始注册', 'payload': {'devNo': devNo, 'logicalCode': logicalCode, 'typeId': '', 'eType': ''}}) except Exception as e: logger.exception(e) return JsonResponse({'result': 0, 'description': u'获取设备出错'}) # 设备未注册，获取默认地址 @permission_required(ROLE.dealer, ROLE.agent, ROLE.subaccount) def defaultEquipmentGroup(request): # type: (WSGIRequest)->JsonResponse # 如果获取的到customerId,即为代理商为经销商注册设备场景 ownerId = request.GET.get('customerId', None) if ownerId is None: ownerId = str(request.user.bossId) group = Group.get_default_group(ownerId) if not group: return JsonResponse({"result": 0, "description": u"您还没有设置默认地址喔", 'payload': {}}) district = District.get_district(group['districtId']) group['district'] = district data = {'gid': str(group['groupId']), 'name': group['groupName'], 'districtId': group['districtId'], 'district': group['district'], 'address': group['address'], 'addressType': group['addressType'], 'isDefault': group['isDefault']} return JsonResponse({"result": 1, "description": None, 'payload': data}) @permission_required(ROLE.agent, ROLE.dealer, ROLE.subaccount) @request_limit_by_user(operation='registerEquipment', limit=100, period=8 * 60 * 60, logger=logger) def registerEquipment(request): return registerEquipmentDefault(request) def registerEquipmentDefault(request): # type: (WSGIRequest)->JsonResponse """ 注册设备 :param request: :return: """ payload = json.loads(request.body) logger.debug('registerEquipmentDefault: {}'.format(payload)) if check_role(request.user, ROLE.agent): ownerId = payload.get('customerId') else: ownerId = str(request.user.bossId) logicalCode = payload.get('logicalCode', None) devNo = payload.get('devNo') or None logger.debug('devNo is: {}'.format(devNo)) if devNo is None and logicalCode is not None: devNo = Device.get_devNo_by_logicalCode(logicalCode) logger.debug('devNo from cache is: {}'.format(devNo)) if not devNo: return JsonErrorResponse(description = u'设备绑定关系不存在') dealer = Dealer.get_dealer(ownerId) if dealer is None: return JsonErrorResponse(description = u'经销商不存在') agent = Agent.get_agent(dealer.get("agentId")) if agent is None: return JsonErrorResponse(description = u'代理商不存在') # 温州郎鑫经销商注册需要 设备必须先被郎鑫录入 manager = Manager.objects.filter(id = agent.get("managerId")).first() if manager is None: return JsonErrorResponse(description = u'厂商不存在') if "inputDevice" in manager.features: if not ManagerInputDev.objects.filter(devNo = devNo, managerId = str(manager.id)): return JsonErrorResponse(description = u'设备不存在，请联系厂家') else: # 只要是录入的设备, 没有inputDevice特性的厂家所属经销商, 都不允许注册 if ManagerInputDev.objects.filter(devNo=devNo).first() is not None: return JsonErrorResponse(description=u'设备不允许注册，请联系厂家') groupId = payload.get('groupId', None) groupNumber = payload.get('groupNumber', '') remarks = payload.get('remarks', '') washConfigs = payload.get('washConfigs', None) devTypeId = payload.get('typeId', '') qrCodeUrl = payload.get('qrCodeUrl', '') policyTemp = payload.get('policyTemp', {}) if not all([devNo, groupId, washConfigs, devTypeId]): return JsonErrorResponse(description = u"缺少参数") if qrCodeUrl and settings.MY_DOMAIN not in qrCodeUrl: return JsonErrorResponse(description = u"不能识别的二维码") # 获取设备类型和逻辑编码 devType = DeviceType.objects(id = str(devTypeId)).first() # type: DeviceType if not devType: return JsonErrorResponse(description = u"设备类型不识别") devType.update(inc__popularity = 1) dev = Device.get_dev(devNo) # type: DeviceDict if not dev: return JsonErrorResponse(description = u"设备尚未与软件绑定，请联系软件开发公司") if dev.is_registered: return JsonErrorResponse(description = u'设备已经注册') driverCode = DriverCode.objects(code = devType.code).first() if not driverCode: return JsonErrorResponse(description = u"设备驱动错误, 请联系软件开发公司") if devType.autoRefundEnable != driverCode.features.get('autoRefundEnable', True): devType.update(autoRefundEnable=driverCode.features.get('autoRefundEnable', True)) group = Group.get_group(groupId) # type: GroupDict if not group: return JsonErrorResponse(description = u"选择的地址不存在，请刷新后再试") if group['ownerId'] != ownerId: return JsonErrorResponse(description = u"必须选择经销商自己创建的地址") dealer = Dealer.objects(id = ownerId).first() devCount = len(dealer.get_own_devices()) if devCount >= dealer.limitDevNum: return JsonErrorResponse(description = u'您已达到最大设备注册数量') districtId = group.get('districtId', '') result, description = Device.register_device( dealer, devNo, dev['logicalCode'], groupId, districtId, groupNumber, remarks, washConfigs, devType, agentId = request.user.id if check_role(request.user, ROLE.agent) else None, policyTemp=policyTemp) if not result: return JsonErrorResponse(description = description) # 更新otherConf开关字段,以及自动充值字段 displaySwitchs = payload.get('displaySwitchs', {}) simChargeAuto = payload.get('simChargeAuto', False) devObj = Device.objects.get(devNo = devNo) devObj.otherConf.update({"displaySwitchs": displaySwitchs}) devObj.simChargeAuto = simChargeAuto devObj.save() dealer.devCount = devCount + 1 dealer.save() # 如果经销商支持丰图平台，在注册设备时添加到丰图平台 if dealer.supports("supportFengTu"): from apps.web.api.ft_north.utils import addDeviceReport addDeviceReport(devNo) # 如果经销商支持北京丰台平台，在注册设备时添加到丰图平台 if dealer.supports('supportBeiJingFengTai'): from apps.web.south_intf.bj_north.api import push_device_info push_device_info(devNo) # 如果地址属于互联互通，就更新下相关时间 if group.get('swapFlag',False): devNum = 0 if u'直流' in devType.majorDeviceType or u'交流' in devType.majorDeviceType: devNum = 1 SwapGroup.update_swap_time_and_num(groupId,devNum) SwapContract.update_swap_time_and_num(groupId, ownerId, agent.id, agent.managerId, devNum) return JsonOkResponse() @permission_required(ROLE.agent, ROLE.dealer, ROLE.manager, ROLE.subaccount) def sendSignal(request): # type: (WSGIRequest)->JsonResponse logicalCode = request.GET.get('logicalCode', None) devNo = Device.get_devNo_by_logicalCode(logicalCode) if devNo is None: return JsonErrorResponse(description = u"无法获取IMEI") dev = Device.get_dev(devNo) if not dev: return JsonErrorResponse(description = u'找不到该设备') try: box = ActionDeviceBuilder.create_action_device(dev) except Exception, e: return JsonErrorResponse(description = u'设备异常，无法通讯，请检查网络情况') result = box.get_signal() if result['rst'] == -1: return JsonErrorResponse(description = u'设备离线，无法获取网络信号情况') elif result['rst'] != 0: return JsonErrorResponse(description = translate_sendmsg_error(result['rst'])) signal = result.get('signal', 0) return JsonOkResponse(description = signal, payload = signal) @permission_required(ROLE.dealer, ROLE.subaccount) def getLastDistrict(request): # type: (WSGIRequest)->JsonResponse ownerId = str(request.user.bossId) lastDistrict = cache.get('%s_lastDistrict' % ownerId, None) if lastDistrict: return JsonOkResponse(payload = json.loads(lastDistrict)) else: group = Group.get_default_group(ownerId) if group: return JsonOkResponse(payload = { 'districtId': group['districtId'], 'district': District.get_district(group['districtId']) }) else: return JsonOkResponse() @permission_required(ROLE.supermanager, ROLE.manager) def editDevType(request): # type: (WSGIRequest)->JsonResponse def check_package_unit(package): dic = map(lambda x: {'unit': x.get('unit'), }, package) res = reduce(lambda x, y: x if x == y else None, dic) return res try: payload = json.loads(request.body) # TODO 校验传入的package package = payload.get('package') if not package: return JsonErrorResponse(description = u"缺少套餐信息") if not check_package_unit(package): return JsonErrorResponse(description = u"修改失败,套餐计量单位填写错误") result = DeviceType.objects(id = payload['id']).update_one(**payload) if not result: return JsonErrorResponse(description = u"编辑错误") else: return JsonOkResponse() except CustomizedValidationError, e: return JsonErrorResponse(description = e.message) except Exception as e: logger.exception('edit devType error=%s' % e) return JsonErrorResponse(description = u"系统错误") @error_tolerate(logger = logger, nil = JsonErrorResponse(u'删除设备类型列表失败，请重试')) @permission_required(ROLE.supermanager, ROLE.manager) def deleteDevType(request): # type: (WSGIRequest)->JsonResponse ids = json.loads(request.body)['ids'] for _ in ids: devType = DeviceType.objects(id = str(_)).first() if not devType: return JsonErrorResponse(description = u"没有找到设备类型") if devType.popularity != 0: return JsonErrorResponse(description = u"无法删除已经注册的设备类型") map(lambda _: _.delete(), DeviceType.get_by_ids(ids)) return JsonOkResponse() @permission_required(ROLE.supermanager, ROLE.manager) def addDevType(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) editId = payload['id'] if payload['role'] == 'manager': manager = Manager.objects(id = editId).first() if not manager: return JsonErrorResponse(description = u"该厂商不存在") payload['agentId'] = str(manager.primeAgentId) elif payload['role'] == 'agent': agent = Agent.objects(id = editId).first() if not agent: return JsonErrorResponse(description = u"该代理商不存在") payload['agentId'] = str(agent.id) try: payload.pop('id') DeviceType(**payload).save() except NotUniqueError: return JsonErrorResponse(description = u"该条数据已经存在，请检查") return JsonOkResponse() @error_tolerate(logger = logger, nil = JsonErrorResponse(u'获取设备类型列表失败，请重试')) @permission_required(ROLE.dealer, ROLE.agent, ROLE.manager, ROLE.advertisement, ROLE.advertiser, ROLE.supermanager, ROLE.subaccount) def getDevTypeList(request): # type: (WSGIRequest)->JsonResponse """ 分两种情况获取 1、超级管理员获取厂商或者代理商的设备类型列表, 或者厂商获取代理商的设备类型列表 2、各角色获取自己的设备类型列表 :param request: :return: """ def visit(user): try: devTypes = DeviceTypeVisitor().visit(user) return JsonOkResponse(payload = {"total": len(devTypes), "dataList": [_.to_dict() for _ in devTypes]}) except DoesNotExist: return JsonErrorResponse(description = u'用户不存在或配置错误') currentUser = request.user role = request.GET.get('role') if role: if role == 'agent': agentId = request.GET.get('id') if not agentId: return JsonErrorResponse(description = u'未选择代理商') model = request.GET.get('model') if model != 'parent': return visit(Agent.objects(id = str(agentId)).get()) else: agent = Agent.objects(id = str(agentId)).get() return visit(agent.primary_agent) elif role == 'manager': managerId = request.GET.get('id') if managerId is None: return JsonErrorResponse(description = u'未选择厂商') else: manager = Manager.objects(id = managerId).get() return visit(manager) else: return visit(currentUser) @permission_required(ROLE.manager) def getDevMapChart(request): # type: (WSGIRequest)->JsonResponse """ 查看设备全国分布情况 :param request: :return: """ mid = str(request.user.id) agentIds = [str(agent.id) for agent in Agent.objects(managerId = mid)] dealerIds = [str(dealer.id) for dealer in Dealer.objects(agentId__in = agentIds)] registered_devices_devNos = [str(_.devNo) for _ in Device.objects(ownerId__in = dealerIds).only('devNo')] devices = Device.get_dev_by_nos(registered_devices_devNos).values() # type: List[DeviceDict] device_count = len(devices) offline_device_count = len([d.online == DeviceOnlineStatus.DEV_STATUS_OFFLINE for d in devices]) online_device_count = device_count - offline_device_count sanitize = lambda city_name: city_name.strip(u'市') if u'市' in city_name else city_name registered_devices_groupIds = [ObjectId(d['groupId']) for d in Device.objects(ownerId__in = dealerIds)] districts = dict(Counter( [District.get_district(g.districtId).split(' ')[1] for g in Group.objects(id__in = registered_devices_groupIds)])) dataList = [{'name': sanitize(city_name), 'value': count} for city_name, count in districts.items()] return JsonResponse({ "result": 1, "description": "", "payload": { "online": online_device_count, "offline": offline_device_count, "dataList": dataList } }) @permission_required(ROLE.dealer, ROLE.agent, ROLE.subaccount) def groupList(request): # type: (WSGIRequest)->JsonResponse # 如果获取的到customerId,即为代理商为经销商注册设备场景 ownerId = request.GET.get('dealerId', None) if ownerId is None: ownerId = str(request.user.bossId) openId = request.GET.get('userId', None) pageIndex = int(request.GET.get('pageIndex', 1)) pageSize = int(request.GET.get('pageSize', 10)) searchKey = str(request.GET.get('searchKey', '')) groupIds = Group.get_group_ids_of_dealer(ownerId) # 过滤下只显示用户的groupId if openId: users = MyUser.objects.filter(openId = openId, groupId__in = groupIds).only('groupId') groupIds = [user.groupId for user in users] groupList = Group.get_groups_by_group_ids(groupIds).values() groupList = natural_sort(groupList, 'groupName', False) dataList = [] # 把addressLabel翻译好 objs = AddressType.objects.all() typeDict = {} for obj in objs: typeDict[obj.value] = obj.label for grp in groupList: if searchKey not in grp['groupName']: continue devNos = Device.get_devNos_by_group([grp['groupId']]) grp['equipmentCount'] = len(devNos) grp['isManager'] = True if grp['isDefault']: dataList.insert(0, grp) else: dataList.append(grp) groupIds = Group.get_group_ids_of_partner(ownerId) groupList = Group.get_groups_by_group_ids(groupIds).values() groupList = natural_sort(groupList, 'groupName', False) for grp in groupList: if searchKey not in grp['groupName']: continue devNos = Device.get_devNos_by_group([grp['groupId']]) grp['equipmentCount'] = len(devNos) grp['isManager'] = False grp['isDefault'] = False grp['addressLabel'] = typeDict.get(grp['addressType'], u'其他') if 'swapFlag' not in grp: grp['swapFlag'] = False dataList.append(grp) return JsonResponse({ "result": 1, "description": None, 'payload': { "total": len(dataList) or 1, "dataList": dataList[(pageIndex - 1) * pageSize: pageIndex * pageSize] } }) @permission_required(ROLE.manager) def getGroupListByDealer(request): # type: (WSGIRequest)->JsonResponse """ :param request: :return: """ dealerIds = json.loads(request.body).get('dealerIds', []) dealers = {str(_.id): _.nickname for _ in Dealer.objects(id__in = dealerIds)} if not dealers: return JsonResponse({'result': 1, 'payload': []}) dataList = [ { 'dealerName': dealers[str(group['ownerId'])], 'dealerId': group['ownerId'], 'groupId': group['groupId'], 'groupName': group['groupName'] } for group in itertools.ifilter( lambda _: bool(all(_) and _), itertools.imap( lambda _: Group.get_groups_of_dealer(_), dealerIds)) ] return JsonResponse({'result': 1, 'payload': {'dataList': dataList, 'total': len(dataList)}}) @permission_required(ROLE.dealer, ROLE.subaccount) def getInstructionsByType(request): # type: (WSGIRequest)->JsonResponse """ :param request: :return: """ typeId = request.GET.get('typeId') devType = DeviceType.objects(id = typeId).first() instructions = devType.instructions if devType is not None else '' return JsonResponse({ "result": 1, "description": None, 'payload': instructions }) @record_operation_behavior() @permission_required(ROLE.dealer, ROLE.subaccount) def setDevSwitch(request): # type: (WSGIRequest)->JsonResponse data = {} lc = request.POST.get('logicalCode') if lc is None: data = json.loads(request.body) if request.body else {} lc = data.get('logicalCode') dev = Device.get_dev_by_logicalCode(lc) # type: DeviceDict if 'autoRefund' in request.POST: strAutoRefund = request.POST.get('autoRefund', 'false') autoRefund = True if strAutoRefund == 'true' else False try: obj = Device.objects.get(logicalCode = lc) obj.autoRefundLeftMoney = autoRefund obj.save() except Exception as e: logger.info('set dev=%s switch error=%s' % (lc, e)) return JsonResponse({"result": 0, "description": u"操作出现异常，请您重试", "payload": {}}) elif 'isFault' in request.POST: isFault = request.POST.get('isFault', False) try: obj = Device.objects.get(logicalCode = lc) obj.isFault = True if isFault == 'true' else False obj.save() Device.invalid_device_cache(obj.devNo) box = ActionDeviceBuilder.create_action_device(dev) box.set_dev_fault(isFault) except Exception as e: logger.info('set dev=%s switch error=%s' % (lc, e)) return JsonResponse({"result": 0, "description": u"操作出现异常，请您重试", "payload": {}}) elif 'simChargeAuto' in request.POST: strAuto = request.POST.get('simChargeAuto', 'false') simChargeAuto = True if strAuto == 'true' else False try: obj = Device.objects.get(logicalCode = lc) obj.simChargeAuto = simChargeAuto obj.save() except Exception as e: logger.info('set dev=%s switch error=%s' % (lc, e)) return JsonResponse({"result": 0, "description": u"操作出现异常，请您重试", "payload": {}}) elif 'billAsServiceSwitch' in request.POST: billAsServiceSwitch = request.POST.get('billAsServiceSwitch') billAsServiceSwitch = True if billAsServiceSwitch == 'true' else False dev.deviceAdapter.switch_bill_as_service(billAsServiceSwitch) return JsonResponse({"result": 1, "description": "", "payload": {}}) @permission_required(ROLE.dealer, ROLE.subaccount) def setBatchDNDSwitch(request): data = json.loads(request.body) if request.body else {} logicalCodes = data.get('logicalCodes', []) isDND = data.get('isDND', False) DNDRange = data.get('isDNDTimeInterval', []) for t in DNDRange: if 'isDNDEndTime' not in t or 'isDNDStartTime' not in t: return JsonErrorResponse(description = u'必须同时指定起始时间和结束时间') start_time = t['isDNDStartTime'] end_time = t['isDNDEndTime'] if start_time > end_time: return JsonErrorResponse(description = u'时间设置错误, 开始时间不能大于结束时间') try: for _ in logicalCodes: d = Device.objects(logicalCode = _).first() d.isDND = isDND d.isDNDTimeInterval = DNDRange d.save() Device.invalid_device_cache(d.devNo) except Exception as e: logger.info('set DND switch error=%s' % (e)) return JsonErrorResponse(description = u'操作出现异常, 请刷新重试') return JsonOkResponse() def updateLocation(request): # type: (WSGIRequest)->JsonResponse try: lc = request.POST.get('logicalCode', None) devNo = Device.get_devNo_by_logicalCode(lc) lng = float(request.POST.get('lng')) lat = float(request.POST.get('lat')) logger.debug('get lbs succeed. devNo = %s; lng = %s; lat = %s' % (devNo, lng, lat)) dev = Device.get_dev(devNo) if dev is None: return JsonResponse({'result': 0, 'description': u'设备不存在'}) Device.get_collection().update({'devNo': devNo}, {'$set': {'location': { 'type': 'Point', 'coordinates': [lng, lat] }, 'dateTimeUpdated': datetime.datetime.now()}}) Device.invalid_device_cache(devNo) YuhuanNorther.send_dev_info(dev) return JsonResponse({'result': 1, 'description': None, 'payload': None}) except Exception as e: logger.exception(e) return JsonResponse({'result': 0, 'description': u'更新设备位置出错'}) @record_operation_behavior() @error_tolerate(logger = logger, nil = JsonErrorResponse(u'系统错误')) def operDevicePort(request): # type: (WSGIRequest)->JsonResponse lc = request.POST.get('logicalCode', None) devNo = Device.get_devNo_by_logicalCode(lc) if request.POST.has_key('active'): strActive = request.POST.get('active', 'false') lock = False if strActive == 'true' else True if str(request.POST.get('portIndex', None)).isdigit(): portIndex = int(request.POST.get('portIndex', None)) else: portIndex = request.POST.get('portIndex', None) dev = Device.get_dev(devNo) if dev is None: return JsonResponse({'result': 0, 'description': u'设备不存在'}) smartBox = ActionDeviceBuilder.create_action_device(dev) try: smartBox.lock_unlock_port(portIndex, lock) except ServiceException, e: return JsonResponse({'result': 0, 'description': e.result.get('description'), 'payload': None}) return JsonResponse({'result': 1, 'description': None, 'payload': None}) elif request.POST.has_key('stop'): strStop = request.POST.get('stop', 'false') active = False if strStop == 'true' else True if str(request.POST.get('portIndex', None)).isdigit(): portIndex = int(request.POST.get('portIndex', None)) else: portIndex = request.POST.get('portIndex', None) dev = Device.get_dev(devNo) if dev is None: return JsonResponse({'result': 0, 'description': u'设备不存在'}) stopType = request.POST.get('type', '') if stopType != '': Device.update_dev_control_cache(devNo, {str(portIndex): {'stopType': stopType}}) smartBox = ActionDeviceBuilder.create_action_device(dev) try: smartBox.active_deactive_port(portIndex, active) except ServiceException, e: return JsonResponse({'result': 0, 'description': e.result.get('description'), 'payload': None}) return JsonResponse({'result': 1, 'description': None, 'payload': None}) # 换电柜独有的 elif request.POST.has_key('charge'): strCharge = request.POST.get('charge', 'false') charge = strCharge == 'true' if str(request.POST.get('portIndex', None)).isdigit(): portIndex = int(request.POST.get('portIndex', None)) else: portIndex = request.POST.get('portIndex', None) dev = Device.get_dev(devNo) if dev is None: return JsonResponse({'result': 0, 'description': u'设备不存在'}) smartBox = ActionDeviceBuilder.create_action_device(dev) try: smartBox.active_deactive_port(portIndex, charge) except ServiceException, e: return JsonResponse({'result': 0, 'description': e.result.get('description'), 'payload': None}) return JsonResponse({'result': 1, 'description': None, 'payload': None}) return JsonResponse({'result': 0, 'description': u'缺少合法参数', 'payload': None}) def getDeviceFunctionByKey(request): # type: (WSGIRequest)->JsonResponse try: # key = request.GET.get('key', None) # logicalCode = request.GET.get('logicalCode', None) # if logicalCode: # logicalCode = json.loads(logicalCode)[0] payload = json.loads(request.body) key = payload.get("key") logicalCode = payload.get("logicalCode") if isinstance(logicalCode, list) and len(logicalCode): logicalCode = logicalCode[0] else: return JsonErrorResponse(description = u"错误的设备编号") devNo = Device.get_devNo_by_logicalCode(logicalCode) dev = Device.get_dev(devNo) box = ActionDeviceBuilder.create_action_device(dev) value = box.get_device_function_by_key(key) payload = {key: value} except ServiceException as e: return JsonResponse({"result": 0, "description": e.result.get('description', ''), "payload": {}}) except Exception as e: logger.exception(e) return JsonResponse({"result": 0, "description": u'未知错误', "payload": {}}) return JsonResponse({"result": 1, "description": "", "payload": payload}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'系统错误')) def setDeviceFunctionByKey(request): # type: (WSGIRequest)->JsonResponse try: data = json.loads(request.body) logicalCode = data.get('logicalCode', None) if isinstance(logicalCode, list) and len(logicalCode): logicalCode = logicalCode[0] else: return JsonErrorResponse(description = u"错误的设备编号") devNo = Device.get_devNo_by_logicalCode(logicalCode) dev = Device.get_dev(devNo) config = data.get('config', None) for key, value in config.items(): box = ActionDeviceBuilder.create_action_device(dev) box.press_down_key(key, value) return JsonResponse({"result": 1, "description": '', "payload": {}}) except ServiceException, e: return JsonResponse({"result": 0, "description": e.result.get('description', ''), "payload": {}}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'系统错误')) def getTotalCoins(request): # type: (WSGIRequest)->JsonResponse logicalCode = request.GET.get('logicalCode', None) devNo = Device.get_devNo_by_logicalCode(logicalCode) dev = Device.get_dev(devNo) try: device_adapter = ActionDeviceBuilder.create_action_device(dev) total = device_adapter.get_total_coin() return JsonResponse({"result": 1, "description": '', "payload": total}) except ServiceException, e: return JsonResponse({"result": 0, "description": e.result.get('description'), "payload": {}}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'系统错误')) def getMajorDevTypeList(request): # type: (WSGIRequest)->JsonResponse majorDevTypeList = [a.to_dict() for a in MajorDeviceType.objects.all()] return JsonResponse( { 'result': 1, 'description': '', 'payload': { 'total': len(majorDevTypeList), 'dataList': majorDevTypeList } }) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'设置价格失败，请刷新页面重新试试')) @permission_required(ROLE.dealer, ROLE.subaccount) def setPricePerHour(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) lc = payload.get('logicalCode') pricePerHour = float(payload.get('pricePerHour')) dev = Device.objects.get(logicalCode = lc) dev.otherConf['pricePerHour'] = pricePerHour dev.save() return JsonOkResponse(description = u'设置成功') ############# ## Commands # ############# @error_tolerate(logger = logger, nil = JsonErrorResponse(u'获取诊断设备命令列表失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def getDiagCommands(request): # type: (WSGIRequest)->JsonResponse # TODO zjl 需要搞清楚这个接口是否有用 哪里有用 logicalCode = request.GET.get('logicalCode') if not logicalCode: return JsonErrorResponse(description = u'逻辑码为空') dev = Device.get_dev_by_l(logicalCode) commands = DeviceCommand.objects(devTypeCode = dev.devType['code']) return JsonOkResponse(payload = [command.to_dict() for command in commands]) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'发送失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def diagDevice(request): # type: (WSGIRequest)->JsonResponse # TODO zjl 需要搞清楚这个接口是否有用 哪里有用 if not request.body: return JsonErrorResponse(description = u'传入数据为空') currentDealer = request.user # type: Dealer payload = json.loads(request.body) logicalCode = payload.get('logicalCode') commandId = payload.get('commandId') params = payload.get('params') command = DeviceCommand.objects(id = commandId).first() # type: DeviceCommand if not command: return JsonErrorResponse(description = u'未找到命令') device = Device.get_dev_by_l(logicalCode) if not device: return JsonErrorResponse(description = u'未找到设备') if not command.supports(device): return JsonErrorResponse(description = u'该设备不支持所提供命令') topic_command = TopicCommand(cmdNo = command.cmd, devNo = device['devNo'], params = params, prefix = 'diag') task_caller('send_topic_command', cmdNo = command.cmd, devNo = device['devNo'], params = params, prefix = 'diag') return JsonOkResponse(payload = {'topic': topic_command.result_topic, 'pushBrokerUrl': currentDealer.pushBrokerUrl}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'查询格子失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def getDeviceCells(request): payload = json.loads(request.body) logicalCode = payload.get('logicalCode') objs = Cell.objects.filter(logicalCode = logicalCode) dev = Device.get_dev_by_logicalCode(logicalCode) box = ActionDeviceBuilder.create_action_device(dev) lockStatusDict = box.get_all_lock_status() dataList = [{'id': str(obj.id), 'cellNo': obj.cellNo, 'boardNo': obj.boardNo, 'lockNo': obj.lockNo, 'itemTitle': obj.itemTitle, 'itemDesc': obj.itemDesc, 'itemPicUrl': obj.itemPicUrl, 'itemPrice': round(obj.itemPrice / 100.0, 2), 'lockStatus': lockStatusDict.get(obj.cellNo, 'close')} for obj in objs] return JsonResponse({'result': 1, 'description': '', 'payload': {'dataList': dataList}}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'编辑格子失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def addEditCell(request): payload = json.loads(request.body) logicalCode = payload.get('logicalCode') cellId = payload.get('id', None) cellNo = payload.get('cellNo') boardNo = payload.get('boardNo') lockNo = payload.get('lockNo') itemTitle = payload.get('itemTitle') itemDesc = payload.get('itemDesc') itemPicUrl = payload.get('itemPicUrl') itemPrice = payload.get('itemPrice') try: obj = Cell.objects.get(id = cellId) obj.cellNo, obj.boardNo, obj.lockNo, obj.itemTitle, obj.itemDesc, obj.itemPicUrl, obj.itemPrice = cellNo, boardNo, lockNo, itemTitle, itemDesc, itemPicUrl, itemPrice obj.save() except DoesNotExist, e: newObj = Cell(logicalCode = logicalCode, cellNo = cellNo, boardNo = boardNo, lockNo = lockNo, itemTitle = itemTitle, itemDesc = itemDesc, itemPicUrl = itemPicUrl, itemPrice = itemPrice) newObj.save() except Exception, e: return JsonErrorResponse(description = u'未知错误') return JsonResponse({"result": 1, "description": '', "payload": None}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def deleteCell(request): payload = json.loads(request.body) cellId = payload.get('id') Cell.objects.delete(id = cellId) return JsonResponse({"result": 1, "description": '', "payload": None}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def getElecMeterReading(request): logicalCode = request.GET.get('logicalCode') dev = Device.get_dev_by_logicalCode(logicalCode) box = ActionDeviceBuilder.create_action_device(dev) result = box.get_elec_meter() meter = result['meter'] return JsonResponse({"result": 1, "description": '', "payload": meter}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) def getDeviceSlave(request): def cmp_by_port(x, y): if int(x['index']) < int(y['index']): return -1 elif int(x['index']) > int(y['index']): return 1 return 0 def cmd_by_sortIndex(x, y): if int(x['sortIndex']) < int(y['sortIndex']): return -1 elif int(x['sortIndex']) > int(y['sortIndex']): return 1 return 0 logicalCode = request.GET.get('logicalCode') dev = Device.get_dev_by_logicalCode(logicalCode) box = ActionDeviceBuilder.create_action_device(dev) portDict = box.get_port_status() smartBox = ActionDeviceBuilder.create_action_device(dev) statsMap = {str(Const.DEV_WORK_STATUS_IDLE): 'idle', str(Const.DEV_WORK_STATUS_WORKING): 'busy', str(Const.DEV_WORK_STATUS_FAULT): 'fault', str(Const.DEV_WORK_STATUS_FORBIDDEN): 'ban'} portList = [] ctrInfo = Device.get_dev_control_cache(dev['devNo']) for port, valueDict in portDict.items(): vStatus = valueDict.get('status', None) if vStatus == Const.DEV_WORK_STATUS_WORKING: portDetail = smartBox.get_port_using_detail(port, ctrInfo) portDetail.update({"id": str(port), "index": str(port), "status": 'busy'}) tempList = [] for k, v in portDetail.items(): if not Const.TRANS_DICT.has_key(k): continue kConfigDict = Const.TRANS_DICT.get(k) attrDict = {'key': k, 'value': v, 'name': kConfigDict['name'], 'sortIndex': kConfigDict['sortIndex']} if kConfigDict.has_key('unit'): attrDict.update({'unit': kConfigDict.get('unit')}) tempList.append(attrDict) tempList.sort(cmp = cmd_by_sortIndex) portDetail['attr'] = tempList portList.append(portDetail) else: portList.append({"id": str(port), 'index': str(port), 'status': statsMap[str(vStatus)]}) portList.sort(cmp = cmp_by_port) return JsonResponse({"result": 1, "description": "", "payload": {"total": len(portList), "dataList": portList}}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def editDeviceSlave(request): payload = json.loads(request.body) logicalCode = payload['logicalCode'] slaveIndex = int(payload['slaveIndex']) dev = Device.get_dev_by_logicalCode(logicalCode) box = ActionDeviceBuilder.create_action_device(dev) slaveId = payload.get('slaveId', None) try: if slaveId is not None: box.edit_address(int(slaveId), slaveIndex) else: box.add_address(slaveIndex) except ServiceException, e: return JsonResponse({'result': 0, 'description': e.result.get('description'), 'payload': None}) return JsonResponse({"result": 1, "description": '', "payload": {"id": slaveIndex}}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def operDeviceSlave(request): payload = json.loads(request.body) logicalCode = payload.get('logicalCode', None) portIndex = payload.get('index') devNo = Device.get_devNo_by_logicalCode(logicalCode) dev = Device.get_dev_by_logicalCode(logicalCode) if payload.has_key('status'): status = payload.get('status') devObj = Device.objects.get(devNo = devNo) portDict = devObj.otherConf.get('portDict', {}) if status == 'ban': portDict.update({portIndex: Const.DEV_WORK_STATUS_FORBIDDEN}) else: portDict.update({portIndex: Const.DEV_WORK_STATUS_IDLE}) devObj.save() return JsonResponse({'result': 1, 'description': None, 'payload': None}) elif payload.has_key('stop') and payload['stop']: box = ActionDeviceBuilder.create_action_device(dev) try: box.stop(portIndex) except ServiceException, e: return JsonResponse({'result': 0, 'description': e.result.get('description'), 'payload': None}) return JsonResponse({'result': 1, 'description': u'停止指令已经下发，请您稍后刷新页面，检查端口实时数据，以确定是否停止成功', 'payload': None}) return JsonResponse({'result': 0, 'description': u'缺少合法参数', 'payload': None}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) @permission_required(ROLE.dealer, ROLE.subaccount) def deleteSlave(request): payload = json.loads(request.body) ids = payload.get('ids', []) logicalCode = payload.get('logicalCode') devObj = Device.objects.get(logicalCode = logicalCode) for slaveId in ids: try: devObj.otherConf['portDict'].pop(slaveId) except Exception, e: continue devObj.save() return JsonResponse({'result': 0, 'description': u'缺少合法参数', 'payload': None}) @permission_required(ROLE.dealer, ROLE.subaccount) def setDevAutoRefund(request): # type: (WSGIRequest)->JsonResponse """ 1. 设备注册 -> 通过DriverCode 给 DeviceType 里面加 auto 字段, 并记录到 dev 缓存里面的 devType 中 2. 设备详情 -> 通过查到 dev 缓存中的 devType 里面的 auto 字段来控制自动退款的显示与不显示 3. 批量设置自动退款 -> 通过 dev 缓存中的 devType 中的 auto 为 true 来控制批量设置显示不显示 4. 设置批量的自动退款 -> 直接设置 Device 中的 autoRefundLeftMoney 来控制设备是否支持自动退款 5. autoRefundLeftMoney -> 可以全部都设置, 不会影响不退款的设备, 也不会影响不退款设备的自动退款显示 :param request: :return: """ data = json.loads(request.body) if request.body else {} if not data: return JsonErrorResponse(u'数据为空，请重试') devNos = data['logicalCodes'] autoRefundStatus = True if data['autoRefund'] == 1 else False objs = Device.objects.filter(devNo__in = devNos) for obj in objs: obj.autoRefundLeftMoney = autoRefundStatus try: obj.save() except Exception as e: logger.exception(e) continue return JsonResponse({"result": 1, "description": u"操作成功", "payload": {}}) def viewOfflineCoinStatistics(request): pageIndex = int(request.GET.get('pageIndex', 1)) pageSize = int(request.GET.get('pageSize', 10)) l = request.GET['logicalCode'] devNo = Device.get_devNo_by_logicalCode(logicalCode = l) now_time = datetime.datetime.now() before_seven = now_time - datetime.timedelta(days = 7) rv = OfflineCoinsManager.instence().get(devNo = devNo, sTime = before_seven, eTime = now_time) total = len(rv) return JsonResponse({'result': 1, 'description': '', 'payload': {'total': total, 'dataList': rv[(pageIndex - 1) * pageSize: pageIndex * pageSize]}}) @permission_required(ROLE.dealer, ROLE.subaccount) def setTempElecPrice(request): data = json.loads(request.body) if request.body else {} if not data: return JsonErrorResponse(u'数据为空，请重试') logicalCode = data['logicalCode'] tempElecPrice = data['tempElecPrice'] device = Device.objects(logicalCode = logicalCode).first() if device is None: return JsonErrorResponse(u'设备不存在, 系统错误') device.otherConf['tempElecPrice'] = tempElecPrice try: device.save() except Exception as e: logger.exception(e) return JsonResponse({"result": 1, "description": u"操作成功", "payload": {}}) @permission_required(ROLE.dealer) def unlockPort(request): payload = request.POST logicalCode = payload.get("logicalCode") portIndex = payload.get("portIndex") if not portIndex: return JsonResponse({"result": 2, "description": "数据有误", }) dev = Device.get_dev_by_l(logicalCode) box = ActionDeviceBuilder.create_action_device(dev) try: box.unlockPort(portIndex) except ServiceException: return JsonResponse({"result": 2, "description": "连接设备失败,请重试", }) return JsonResponse({"result": 1, "description": ""}) @permission_required(ROLE.dealer) def saveLiveConfig(request): payload = json.loads(request.body) logicalCode = payload.get('logicalCode', '') liveUrl = payload.get('liveUrl', '#') liveLimitedPrice = payload.get('liveLimitedPrice', '0.0') if logicalCode == '': return JsonResponse({"result": 2, "description": "系统异常"}) try: device = Device.objects(logicalCode=logicalCode).first() device.otherConf.update({'liveUrl': liveUrl}) device.otherConf.update({'liveLimitedPrice': liveLimitedPrice}) device.save() Device.invalid_device_cache(device.devNo) except Exception as e: return JsonResponse({"result": 2, "description": "参数设置失败，请重试"}) return JsonResponse({"result": 1, "description": ""}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'操作失败')) @permission_required(ROLE.manager) def getDevicePort(request): # type: (WSGIRequest)->JsonResponse def cmp_by_port(x, y): if (str(x['index']).isdigit() and str(y['index']).isdigit()): if int(x['index']) < int(y['index']): return -1 elif int(x['index']) > int(y['index']): return 1 return 0 else: if x['index'] < y['index']: return -1 elif x['index'] > y['index']: return 1 return 0 def charge_pay_coin_unit(p, u): """ 给端口信息中的付费添加上单位 :param p: :param u: :return: """ _coins = p.get("coins") if not _coins: return p.update({"coins": "{}{}".format(_coins, u)}) currentDealer = request.user dev = Device.get_dev_by_logicalCode(request.GET.get('logicalCode')) # type: DeviceDict group = dev.group # type: GroupDict devTypeCode = dev.devType['code'] smartBox = dev.deviceAdapter if hasattr(smartBox, 'dealer_get_device_port'): portList = getattr(smartBox, 'dealer_get_device_port')() return JsonResponse({"result": 1, "description": "", "payload": {"portList": portList}}) if devTypeCode in [Const.DEVICE_TYPE_CODE_GEZIGUI_485, Const.DEVICE_TYPE_CODE_CHARGE_ZHONGSHAN,Const.DEVICE_TYPE_CODE_CHARGE_WEIFULE_CAR, Const.DEVICE_TYPE_CODE_CAR_WEIFULE_CHARGING_DOUB, Const.DEVICE_TYPE_CODE_CAR_WEIFULE_21KW, Const.DEVICE_TYPE_CODE_CAR_WEIFILE_HOME_JFPG, Const.DEVICE_TYPE_CODE_CAR_WEIFILE_HOME_DOUB_JFPG, Const.DEVICE_TYPE_CODE_CHARGE_ZHONGSHAN_BILLASSERVICE]: portList = smartBox.get_port_status_from_dev() return JsonResponse({"result": 1, "description": "", "payload": {"portList": portList}}) if devTypeCode == Const.DEVICE_TYPE_CODE_WATER_DISPENSER: ctrInfo = Device.get_dev_control_cache(dev.devNo) if ctrInfo is None or ('1' not in ctrInfo and '2' not in ctrInfo): portList = {} else: statusDict = {} statusInfoDict = {} for _ in range(1, 3): tempPort = str(_) if ctrInfo[tempPort].get('status', 0) == 0: statusDict[tempPort] = 'idle' statusInfoDict[tempPort] = ctrInfo[tempPort].get('statusErrorInfo', u'无') elif ctrInfo[tempPort].get('status', 0) == 1: statusDict[tempPort] = 'busy' statusInfoDict[tempPort] = ctrInfo[tempPort].get('statusErrorInfo', u'无') elif ctrInfo[tempPort].get('status', 0) == 3: statusDict[tempPort] = 'fault' statusInfoDict[tempPort] = ctrInfo[tempPort].get('statusErrorInfo', u'无') else: statusDict[tempPort] = 'fault' statusInfoDict[tempPort] = ctrInfo[tempPort].get('statusErrorInfo', u'无') portList = [ {'index': '1', 'status': statusDict['1'], 'statusErrorInfo': statusInfoDict.get('1', u'无')}, {'index': '2', 'status': statusDict['2'], 'statusErrorInfo': statusInfoDict.get('2', u'无')} ] return JsonResponse({"result": 1, "description": "", "payload": {"portList": portList}}) try: # 先从设备上取信息，然后从缓存中取信息 portDict = smartBox.dealer_get_port_status() smartBox.async_update_portinfo_from_dev() except ServiceException as e: logger.exception(e) return JsonResponse({'result': 0, 'description': e.result.get('description'), 'payload': None}) except Exception as e: logger.exception(e) return JsonResponse({"result": 0, "description": u"从设备上获取端口信息失败，请您重试", "payload": {}}) portList = [] unit = smartBox.show_pay_unit statsMap = {str(Const.DEV_WORK_STATUS_IDLE): 'idle', str(Const.DEV_WORK_STATUS_WORKING): 'busy', str(Const.DEV_WORK_STATUS_FAULT): 'fault', str(Const.DEV_WORK_STATUS_FORBIDDEN): 'ban', str(Const.DEV_WORK_STATUS_CONNECTED): 'connected', str(Const.DEV_WORK_STATUS_FINISHED): 'finished'} # TODO zjl get_port_using_detail 这块太复杂 后续一定要整改！！！ 目前先做if分支处理 if devTypeCode in [Const.DEVICE_TYPE_CODE_CHARGING_AQKJ, Const.DEVICE_TYPE_CODE_CHARGING_AQKJ_NEW]: elecInfo = smartBox._query_elec() for port, valueDict in portDict.items(): voltage = "{:.2f}".format(float(valueDict.get("voltage", "0"))) batteryImei = valueDict.get("batteryImei", "") doorStatus = valueDict.get("doorStatus") doorStatus = smartBox.translate_door_status_to_unicode(doorStatus) tempStatus = statsMap.get(str(valueDict.get("status"))) elecPoint = valueDict.get("elec") tempDict = { "index": port, "status": tempStatus, "doorStatus": doorStatus, "voltage": voltage, "batteryImei": batteryImei if batteryImei else u"无电池", "elecPoint": elecPoint } tempDict.update(elecInfo.get(port)) portList.append(tempDict) portList.sort(cmp=cmp_by_port) return JsonResponse({"result": 1, "description": "", "payload": {"portList": portList}}) if devTypeCode in [Const.DEVICE_TYPE_CODE_CABINET_NEW]: doorStatus = smartBox._get_door_status() for port, valueDict in portDict.items(): voltage = "{:.2f}".format(float(valueDict.get("voltage", "0"))) tempDict = { "index": port, "status": valueDict["status"], "doorStatus": doorStatus.get(port, u"未知"), } valueDict.update(tempDict) portList.append(valueDict) portList.sort( key=lambda x: int(x['index']) if isinstance(x['index'], str) and x["index"].isdigit() else x['index']) return JsonResponse({"result": 1, "description": "", "payload": {"portList": portList}}) if devTypeCode in [Const.DEVICE_TYPE_CODE_CABINET]: for port, valueDict in portDict.items(): tempStatus = statsMap.get(str(valueDict.get("status"))) tempDict = { "index": port, "status": tempStatus, } valueDict.update(tempDict) portList.append(valueDict) portList.sort(cmp=cmp_by_port) return JsonResponse({"result": 1, "description": "", "payload": {"portList": portList}}) busyPortList = [] for port, valueDict in portDict.items(): vStatus = valueDict.get('status', None) if vStatus == Const.DEV_WORK_STATUS_WORKING: busyPortList.append(port) else: portList.append({'index': str(port), 'status': statsMap.get(str(vStatus), "idle")}) busyPortInfoDict = smartBox.get_many_port_info(busyPortList) if devTypeCode in [Const.DEVICE_TYPE_CODE_CHARGING_HAINIAO_DOUBLE]: ctrInfo = Device.get_dev_control_cache(dev.devNo) for port, valueDict in portDict.items(): vStatus = valueDict.get('status', None) if vStatus == Const.DEV_WORK_STATUS_WORKING: portDetail = smartBox.get_port_using_detail(port, ctrInfo) if portDetail.get('timeUnit',None)==u'秒': portDetail.update({'needTime':str(portDetail['needTime'][:-2])+'秒'}) portDetail.update({"index": str(port), "status": 'busy'}) portList.append(portDetail) portList.sort( key=lambda x: int(x['index']) if isinstance(x['index'], str) and x["index"].isdigit() else x['index']) map(charge_pay_coin_unit, portList, [unit for x in xrange(len(portList))]) for _ in portList: if 'elec' in _: _.pop('elec') portList.sort(cmp=cmp_by_port) return JsonOkResponse(payload={"isManager": False, "portList": portList}) if busyPortInfoDict: for info in busyPortInfoDict.values(): if info['status'] == Const.DEV_WORK_STATUS_WORKING: info.update({'status':statsMap[str(info['status'])]}) if info.has_key('needTime') and str(info['needTime']).isdigit(): info.update({'needTime':u'%s分钟' % info['needTime']}) else: info = {'status':'idle','index':str(info['index'])} portList.append(info) else: ctrInfo = Device.get_dev_control_cache(dev.devNo) for port, valueDict in portDict.items(): vStatus = valueDict.get('status', None) if vStatus == Const.DEV_WORK_STATUS_WORKING: portDetail = smartBox.get_port_using_detail(port, ctrInfo) portDetail.update({"index": str(port), "status": 'busy'}) portList.append(portDetail) portList.sort(key=lambda x: int(x['index']) if isinstance(x['index'], str) and x["index"].isdigit() else x['index']) map(charge_pay_coin_unit, portList, [unit for x in xrange(len(portList))]) # todo 删掉已充电量, 只保留订购电量 (微付乐的板子需要电量，不能去掉。按道理，这个是业务自己不返回elec，不能放在公共代码这里改) if devTypeCode not in [Const.DEVICE_TYPE_CODE_CHANGING_WEIFULE, Const.DEVICE_TYPE_CODE_CHANGING_WEIFULE2,Const.DEVICE_TYPE_CODE_CHANGING_DIANCHUANCARCHARGING]: for _ in portList: if 'elec' in _: _.pop('elec') if dev.support_power_graph and ( 'showPG_in_port_detail' in dev.owner.features or dev.driverCode in [Const.DEVICE_TYPE_CODE_WEIFULE_ANJIAN]): for item in portList: item['showPG'] = True portList.sort(cmp=cmp_by_port) return JsonOkResponse(payload={"isManager": False, "portList": portList}) @permission_required(ROLE.manager) @error_tolerate(logger=logger, nil=JsonErrorResponse(u'系统错误，请稍后再试')) def getAlarmList(request): # type: (WSGIRequest)->JsonResponse pageIndex = int(request.GET.get('pageIndex', 1)) pageSize = int(request.GET.get('pageSize', 10)) searchKey = request.GET.get('searchKey', '') agentIds = [str(_.id) for _ in Agent.objects(managerId = str(request.user.id))] dealerIds = [str(_.id) for _ in Dealer.objects(agentId__in = agentIds)] if searchKey: queryset = FaultRecord.objects(logicalCode = searchKey,dealerId__in=dealerIds).order_by('-createdTime') else: queryset = FaultRecord.objects(dealerId__in=dealerIds).order_by('-createdTime') records = queryset.paginate(pageIndex = pageIndex, pageSize = pageSize) # type: Iterable[FaultRecord] total = queryset.count() return JsonOkResponse(payload={'dataList': [ _.to_dict() for _ in records ], 'total': total}) @permission_required(ROLE.dealer, ROLE.subaccount) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'系统错误，请稍后再试')) def findDevTypeCandidate(request): logicalCode = request.GET.get('logicalCode') devObj = Device.objects(logicalCode = logicalCode).first() # type: Device if not devObj: return JsonErrorResponse(description = u'设备不存在，请扫正确的设备二维码') recommend, all = DeviceType.find_candidate(devObj, request.user) return JsonOkResponse(payload = {'recommend': recommend, 'all': all}) @permission_required(ROLE.supermanager, ROLE.manager) def getDriverCodeList(request): # type: (WSGIRequest)->JsonResponse devTypes = [d.to_dict() for d in DriverCode.objects()] # type: List[DriverCode] return JsonResponse( { 'result': 1, 'description': "", 'payload': { 'total': len(devTypes), 'dataList': devTypes } } ) @permission_required(ROLE.supermanager) def addDriverCode(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) # type: dict try: DriverCode(code = payload['code'], name = payload['name'], description = payload['description']).save() except NotUniqueError: return JsonErrorResponse(description = u'重复数据') return JsonResponse({'result': 1, 'description': u'保存成功'}) @permission_required(ROLE.supermanager) def editDriverCode(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) # type: dict try: DriverCode.objects(id = payload.pop('id')).update(**payload) except NotUniqueError: return JsonErrorResponse(description = u'重复数据') return JsonResponse({'result': 1, 'description': u'保存成功'}) @error_tolerate(logger = logger, nil = JsonErrorResponse(u'删除设备类型列表失败，请重试')) @permission_required(ROLE.supermanager) def deleteDriverCode(request): # type: (WSGIRequest)->JsonResponse ids = json.loads(request.body)['ids'] for _ in ids: driverCode = DriverCode.objects(id = str(_)).first() if not driverCode: return JsonErrorResponse(description = u"没有找到设备驱动编码{}".format(driverCode.code)) refDevType = DeviceType.objects(code = driverCode.code).first() if refDevType: return JsonErrorResponse(description = u"{}已经被使用，无法删除".format(driverCode.code)) map(lambda _: _.delete(), DriverCode.objects(id__in = ids).all()) return JsonOkResponse() @permission_required(ROLE.supermanager) def getDriverAdapterList(request): # type: (WSGIRequest)->JsonResponse rv = [d.to_dict() for d in DriverAdapter.objects()] return JsonResponse( { 'result': 1, 'description': "", 'payload': { 'total': len(rv), 'dataList': rv } } ) @permission_required(ROLE.supermanager) def addDriverAdapter(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) # type: dict if not payload['adapterFile'] or not payload['adapter'] or not payload['adapterVer']: return JsonErrorResponse(description = u'参数错误') try: DriverAdapter( adapterFile = payload['adapterFile'], adapter = payload['adapter'], adapterVer = payload['adapterVer']).save() except NotUniqueError: return JsonErrorResponse(description = u'重复数据') return JsonResponse({'result': 1, 'description': u'保存成功'}) @permission_required(ROLE.supermanager) def editDriverAdapter(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) # type: dict if not payload['adapterFile'] or not payload['adapter'] or not payload['adapterVer']: return JsonErrorResponse(description = u'参数错误') try: DriverAdapter.objects(id = payload.pop('id')).update(**payload) except NotUniqueError: return JsonErrorResponse(description = u'重复数据') return JsonResponse({'result': 1, 'description': u'保存成功'}) @permission_required(ROLE.supermanager) def deleteDriverAdapter(request): # type: (WSGIRequest)->JsonResponse ids = json.loads(request.body)['ids'] for _ in ids: driverAdapter = DriverAdapter.objects(id = str(_)).first() if not driverAdapter: return JsonErrorResponse(description = u"没有找到设备适配器{}".format(driverAdapter.adapterFile)) if not driverAdapter.adapterFile: continue refDriverCode = DriverCode.objects(adapterFile = driverAdapter.adapterFile).first() if refDriverCode: return JsonErrorResponse(description = u"{}已经被使用，无法删除".format(driverAdapter.adapterFile)) map(lambda _: _.delete(), DriverAdapter.objects(id__in = ids).all()) return JsonOkResponse() @permission_required(ROLE.supermanager) def getDriverEventerList(request): # type: (WSGIRequest)->JsonResponse rv = [d.to_dict() for d in DriverEventer.objects()] return JsonResponse( { 'result': 1, 'description': "", 'payload': { 'total': len(rv), 'dataList': rv } } ) @permission_required(ROLE.supermanager) def addDriverEventer(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) # type: dict if not payload['eventerFile'] or not payload['eventerVer']: return JsonErrorResponse(description = u'参数错误') try: DriverAdapter( eventerFile = payload['eventerFile'], eventerVer = payload['eventerVer']).save() except NotUniqueError: return JsonErrorResponse(description = u'重复数据') return JsonResponse({'result': 1, 'description': u'保存成功'}) @permission_required(ROLE.supermanager) def editDriverEventer(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) # type: dict if not payload['eventerFile'] or not payload['eventerVer']: return JsonErrorResponse(description = u'参数错误') try: DriverEventer.objects(id = payload.pop('id')).update(**payload) except NotUniqueError: return JsonErrorResponse(description = u'重复数据') return JsonResponse({'result': 1, 'description': u'保存成功'}) @permission_required(ROLE.supermanager) def deleteDriverEventer(request): # type: (WSGIRequest)->JsonResponse ids = json.loads(request.body)['ids'] for _ in ids: driverEventer = DriverEventer.objects(id = str(_)).first() if not driverEventer: return JsonErrorResponse(description = u"没有找到设备适配器{}".format(driverEventer.eventerFile)) if not driverEventer.eventerFile: continue refDriverCode = DriverCode.objects(eventerFile = driverEventer.eventerFile).first() if refDriverCode: return JsonErrorResponse(description = u"{}已经被使用，无法删除".format(driverEventer.eventerFile)) map(lambda _: _.delete(), DriverEventer.objects(id__in = ids).all()) return JsonOkResponse() @permission_required(ROLE.manager, ROLE.supermanager) def assignDeviceTypeToAgent(request): # type: (WSGIRequest)->JsonResponse payload = json.loads(request.body) agent = Agent.objects(id = payload['id']).first() if not agent: return JsonResponse({'result': 0, 'description': u'该代理商用户不存在'}) for deviceType in payload['deviceType']: deviceType['agentId'] = str(agent.id) deviceType.pop('id') DeviceType(**deviceType).save() return JsonResponse({'result': 1, 'description': u'配置成功'}) @permission_required(ROLE.dealer, ROLE.subaccount) def getDeviceVirtualQrCode(request): """ 生成设备的二维码推广码 """ logicalCode = request.GET.get('logicalCode') dev = Device.get_dev_by_l(logicalCode) # type: DeviceDict if not dev: return JsonErrorResponse(description=u"生成二维码错误（10001）") deviceOwner = dev.owner if not deviceOwner: return JsonErrorResponse(description=u"生成二维码错误（10002）") productionAgent = get_user_manager_agent(deviceOwner) redirect = '/user/index.html#?path=ticket&logicalCode={}&groupId={}'.format(dev.logicalCode, dev.groupId) url = concat_user_center_entry_url(str(productionAgent.id), redirect=redirect) logger.debug('{} virtual qr code is: {}'.format(dev, url)) return JsonOkResponse(payload={'url': url})