#!/usr/bin/env python3 # -*- coding: utf-8 -*- """ @Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved. @AUTHOR: ASJRD019 @NAME: AnsjerFormal @software: PyCharm @DATE: 2019/5/27 15:50 @Version: python3.6 @MODIFY DECORD:ansjer dev @file: AliPayObject.py @Contact: pzb3076@163.com """ import time import traceback import simplejson as json from django.utils.decorators import method_decorator from django.views.decorators.csrf import csrf_exempt from django.views.generic.base import View from Model.models import UidSetModel, Device_User, Device_Info, UidPushModel, Equipment_Info, UID_Preview, UID_Bucket, \ VodHlsModel, Order_Model, OssCrdModel,UidUserModel from Object.ResponseObject import ResponseObject from Object.TokenObject import TokenObject from Service.CommonService import CommonService from Service.ModelService import ModelService from django.db import transaction ''' # 管理员获取信息 http://192.168.136.39:8000/uidset/adminQuery?token=local&page=1&line=10 管理员删除信息 http://192.168.136.39:8000/uidset/adminDelete?token=local&id=2 管理员添加信息 http://192.168.136.39:8000/uidset/adminAdd?token=local&uid=JW3684H8BSHG9TTM111A 管理员编辑信息 http://192.168.136.39:8000/uidset/adminUpdate?token=local&id=6&content={"uid":"9999"} ''' # 设备信息添加 class UidSetView(View): @method_decorator(csrf_exempt) def dispatch(self, *args, **kwargs): return super(UidSetView, self).dispatch(*args, **kwargs) def get(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.GET, request, operation) def post(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.POST, request, operation) def validation(self, request_dict, request, operation): response = ResponseObject() if operation is None: return response.json(444, 'error path') token = request_dict.get('token', None) # 设备主键uid tko = TokenObject(token) response.lang = tko.lang if tko.code != 0: return response.json(tko.code) userID = tko.userID if operation == 'queryAll': return self.do_queryAll(request_dict, userID, response) elif operation == 'adminQueryAll': return self.do_admin_queryAll(request_dict, userID, response) elif operation == 'adminDelete': return self.do_admin_delete(request_dict, userID, response) elif operation == 'adminQuery': return self.do_admin_query(request_dict, userID, response) elif operation == 'adminAdd': return self.do_admin_add(request_dict, userID, response) elif operation == 'adminUpdate': return self.do_admin_update(request_dict, userID, response) elif operation == 'update': return self.do_update(request_dict, response) else: return response.json(444, 'error path') def do_queryAll(self, request_dict, userID, response): uid_list = Device_Info.objects.filter(userID_id=userID).values_list('UID', flat=True) uid_set_qs = UidSetModel.objects.filter(uid__in=uid_list).values('uid', 'detect_status', 'detect_interval', 'version', 'ucode', 'p2p_region', 'tz', 'video_code', 'channel', 'cloud_vod') if uid_set_qs.exists(): return response.json(0, list(uid_set_qs)) else: return response.json(0) def do_admin_queryAll(self, request_dict, userID, response): uid_list = Device_Info.objects.filter(userID_id=userID).values_list('UID', flat=True) id = request_dict.get('id', None) uid_set_qs = UidPushModel.objects.filter(uid_set__id=id).values('addTime', 'appBundleId','app_type','lang','m_code','push_type','token_val','tz','uid_set', 'updTime','userID','userID__username' , 'userID__userEmail', 'userID__NickName' , 'userID__is_active', 'userID__phone' ) return response.json(0, list(uid_set_qs)) # 管理员删除 def do_admin_delete(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID, 10) if own_perm is True: uid = request_dict.getlist('uid', None) id_list = request_dict.get('id_list', None) # 删除回滚 with transaction.atomic(): # 上下文格式，可以在python代码的任何位置使用 val = 1 if 'UidSetModel' in id_list: del_uid = UidSetModel.objects.filter(uid__in=uid) if del_uid.exists(): del_uid.delete() print ('删除UidSetModel') else: val = 1 print('UidSetModel表没有数据') if 'Equipment_Info' in id_list: del_uid = Equipment_Info.objects.filter(devUid__in=uid) if del_uid.exists(): del_uid.delete() # print('删除Equipment_Info') else: val = val+1 print('Equipment_Info表没有数据') if 'UID_Preview' in id_list: del_uid = UID_Preview.objects.filter(uid__in=uid) if del_uid.exists(): del_uid.delete() # print ('删除UID_Preview') else: val = val + 1 print('UID_Preview表没有数据') if 'UID_Bucket' in id_list: del_uid = UID_Bucket.objects.filter(uid__in=uid) if del_uid.exists(): del_uid.delete() # print ('删除UID_Bucket') else: val = val + 1 print('UID_Bucket表没有数据') if 'VodHlsModel' in id_list: del_uid = VodHlsModel.objects.filter(uid__in=uid) if del_uid.exists(): # del_uid.delete() print ('删除VodHlsModel') else: val = val + 1 print('VodHlsModel表没有数据') if 'Order_Model' in id_list: del_uid = Order_Model.objects.filter(UID__in=uid) if del_uid.exists(): del_uid.delete() # print ('删除Order_Model') else: val = val + 1 print('Order_Model表没有数据') if 'Device_Info' in id_list: del_uid = Device_Info.objects.filter(UID__in=uid) if del_uid.exists(): del_uid.delete() # print ('删除Device_Info') else: val = val + 1 print('Order_Model表没有数据') if 'OssCrdModel' in id_list: del_uid = OssCrdModel.objects.filter(uid__in=uid) if del_uid.exists(): del_uid.delete() # print ('删除OssCrdModel') else: val = val + 1 print('OssCrdModel表没有数据') if 'UidUserModel' in id_list: del_uid = UidUserModel.objects.filter(UID__in=uid) if del_uid.exists(): del_uid.delete() # print ('删除UidUserModel') else: val = val + 1 print('UidUserModel表没有数据') #有后台管理 设备配置表UidSetModel ---uid --本身， #有后台管理 设备关联用户推送表Equipment_Info --devUid --独立没有儿子的， #有后台管理 设备预览图表UID_Preview ---uid---孤立， #有后台管理 设备关联套餐表UID_Bucket ---uid---孤立， #有后台管理 云存回放信息表VodHlsModel ---uid---孤立， #有后台管理 订单信息表Order_Model --UID----独立没有儿子的， #有后台管理 用户设备信息表（最多信息量的表）Device_Info ---UID---孤立， # 设备证书OssCrdModel ---uid---孤立 # 有后台管理 设备ap表 UidUserModel #设备绑定UidPushModel---关联表---设备配置表UidSetModel---配置表的详情有显示 # raise DatabaseError #测试用，检测是否能捕捉错误 if val == 9: return response.json(173) else: return response.json(0) else: return response.json(404) # 管理员查询接口 def do_admin_query(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID, 20) if own_perm is True: page = request_dict.get('page', None) line = request_dict.get('line', None) page = int(page) line = int(line) deviceContent = request_dict.get('content', None) if deviceContent: try: searchCondition = json.loads(deviceContent) except Exception as e: return response.json(10, repr(e)) else: kwargs = CommonService.get_kwargs(data=searchCondition) omqs = UidSetModel.objects.filter(**kwargs).order_by('-id') if not omqs.exists(): return response.json(0, []) count = omqs.count() order_ql = omqs[(page - 1) * line:page * line] uidset_json = CommonService.qs_to_dict(order_ql) uidset_json['count'] = count return response.json(0, uidset_json) else: omqs = UidSetModel.objects.all().order_by('-id') if not omqs.exists(): return response.json(0, []) count = omqs.count() order_ql = omqs[(page - 1) * line:page * line] uidset_json = CommonService.qs_to_dict(order_ql) uidset_json['count'] = count return response.json(0, uidset_json) else: return response.json(404) # 管理员的添加 def do_admin_add(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID=userID, permID=40) if own_perm is not True: return response.json(404) uid = request_dict.get('uid', None) timestamp = int(time.time()) param_flag = CommonService.get_param_flag( data=[uid]) if param_flag is not True: return response.json(444) try: uidset = UidSetModel( uid=uid, addTime=timestamp, updTime=timestamp) uidset.save() return response.json(0) except Exception: errorInfo = traceback.format_exc() print(errorInfo) return response.json(500, {'details': errorInfo}) # 管理员的编辑 def do_admin_update(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID=userID, permID=50) if own_perm is not True: return response.json(404) deviceContent = request_dict.get('content', None) id = request_dict.get('id', None) if not deviceContent or not id: return response.json(444, 'content,id') try: timestamp = int(time.time()) deviceData = json.loads(deviceContent) uid_set = UidSetModel.objects.filter(id=id) if uid_set.exists(): uid_set.update(updTime=timestamp, **deviceData) return response.json(0) else: return response.json(173) except Exception: errorInfo = traceback.format_exc() print(errorInfo) return response.json(500, {'details': errorInfo}) def do_update(self, request_dict, response): uid = request_dict.get('uid', None) region_alexa = request_dict.get('region_alexa', None) is_alexa = request_dict.get('is_alexa', None) try: timestamp = int(time.time()) uid_set = UidSetModel.objects.filter(uid=uid) if uid_set.exists(): uid_set.update(updTime=timestamp,region_alexa=region_alexa,is_alexa=is_alexa) return response.json(0) else: return response.json(173) except Exception: errorInfo = traceback.format_exc() print(errorInfo) return response.json(500, {'details': errorInfo})