# -*- coding: utf-8 -*- import array from django.shortcuts import render from django.views.generic.base import View from itertools import chain import requests from requests.auth import HTTPBasicAuth from django.core.exceptions import ObjectDoesNotExist from django.http import JsonResponse, HttpResponse from django.views.generic import ListView from django.core import serializers from datetime import datetime, date from PIL import Image import time import json from io import BytesIO from apps.AppInfoManage.models import MyUser, User_Log, Equip, SCDdata, SCDstatus, CBDdata, CBDstatus, YBQdata, YBQstatus, JKdata, BZYstatus, BZYdata, SCDstatus_all, CBDstatus_all,\ QXZswitchstatus, QXZswitchdata, QXZAutoswitch, QXZstatus, QXZTimingswitch, Msg_Conf, CBDphoto, Equip_SimInfo # 引用查询流量接口 from apps.SimInfo.views import get_siminfo # 引用全局变量 from django.conf import settings from django.views.decorators.csrf import csrf_exempt # 测报灯管理视图： class CBDMsg_View(ListView): def get(self, request): # x_forwarded_for = request.META.get('HTTP_X_FORWARDED_FOR') # if x_forwarded_for: # ip = x_forwarded_for.split(',')[0]#所以这里是真实的ip # print("------------real ip") # else: # ip = request.META.get('REMOTE_ADDR')#这里获得代理ip # print("------------unreal ip") # 获取主机名 # hostname = socket.gethostname() # #获取IP # ip = socket.gethostbyname(hostname) # print("获取的IP为:",ip) current_user = request.session.get('username') current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---用户") role = "user" nums = CBDstatus.objects.filter( equip_id__equip_user=current_user).count() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") role = "user" nums = CBDstatus.objects.filter( equip_id__equip_agency=current_user.user_agency).count() else: print("---管理员") role = "superuser" nums = CBDstatus.objects.all().count() return render(request, 'warnmanage/cbd_list.html', context={"nums": nums,"role": role}) def post(self, request): if request.is_ajax(): print("ajax-post!") req = request.POST.get('req') print("req:", req) # 请求数据： if req == "dat": print("---请求数据的post！") page = int(request.POST.get('page')) print("page:", page) current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") # sta1 = CBDstatus.objects.filter( # equip_id__equip_user=current_user, equip_id__equip_type=3)[(10*(page-1)):(page*10)] # .order_by("-equip_id__equip_add_time") sta1 = CBDstatus.objects.filter(equip_id__equip_user=current_user)[(10*(page-1)):(page*10)] elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") # sta1 = CBDstatus.objects.filter( # equip_id__equip_agency=current_user.user_agency, equip_id__equip_type=3)[(10*(page-1)):(page*10)] sta1 = CBDstatus.objects.filter(equip_id__equip_agency=current_user.user_agency)[(10*(page-1)):(page*10)] else: print("---管理员") # sta1 = CBDstatus.objects.filter(equip_id__equip_type=3)[( # 10*(page-1)):(page*10)] # .order_by("-equip_id__equip_add_time") sta1 = CBDstatus.objects.all()[(10*(page-1)):(page*10)] sta2 = [{"cbd_status": x.cbd_status, "upl_time": x.upl_time, "paramconf": x.paramconf, "serverconf": x.serverconf, "equip_name": x.equip_id.equip_name, "equip_desc": x.equip_id.equip_desc, "is_online": x.is_online, "off_time": x.off_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder, indent=4) # print("data:",data) return HttpResponse(data) elif req == "filter": f_name = request.POST.get('ename') print("f_name:", f_name) f_id = request.POST.get('f_id') print("f_id:", f_id) page = int(request.POST.get('page')) print("page:", page) dver = request.POST.get('dver') print("dver",dver) is_online = request.POST.get('is_online') print("is_online",is_online) # 读取当前用户： current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") if f_name == "" and f_id == '': sta1 = CBDstatus.objects.filter( equip_id__equip_user=current_user) elif f_name == "" and f_id != '': sta1 = CBDstatus.objects.filter( equip_id__equip_user=current_user, equip_id__equip_id__contains=f_id) elif f_name != "" and f_id == '': sta1 = CBDstatus.objects.filter( equip_id__equip_user=current_user, equip_id__equip_name__contains=f_name) elif f_name != "" and f_id != '': sta1 = CBDstatus.objects.filter( equip_id__equip_user=current_user, equip_id__equip_name__contains=f_name, equip_id__equip_id__contains=f_id) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") if f_name == "" and f_id == '': sta1 = CBDstatus.objects.filter( equip_id__equip_agency=current_user.user_agency) elif f_name == "" and f_id != '': sta1 = CBDstatus.objects.filter( equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=f_id) elif f_name != "" and f_id == '': sta1 = CBDstatus.objects.filter( equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=f_name) elif f_name != "" and f_id != '': sta1 = CBDstatus.objects.filter( equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=f_name, equip_id__equip_id__contains=f_id) else: print("---管理员") if f_name == "" and f_id == '': sta1 = CBDstatus.objects.all() elif f_name == "" and f_id != '': sta1 = CBDstatus.objects.filter( equip_id__equip_id__contains=f_id) elif f_name != "" and f_id == '': sta1 = CBDstatus.objects.filter( equip_id__equip_name__contains=f_name) elif f_name != "" and f_id != '': sta1 = CBDstatus.objects.filter( equip_id__equip_name__contains=f_name, equip_id__equip_id__contains=f_id) print("在线状态------------>",is_online) # ----------------------------------------------------------------------------------------- # 版本号筛选设备 if dver != "" and is_online == "": sta3 = [] for i in sta1: fir_v = eval(i.cbd_status)["dver"].split(".") if fir_v[0] == dver: sta3.append({"cbd_status": i.cbd_status, "upl_time": i.upl_time, "paramconf": i.paramconf, "serverconf": i.serverconf, "equip_name": i.equip_id.equip_name, "equip_desc": i.equip_id.equip_desc, "is_online": i.is_online, "off_time": i.off_time}) data = {"dat": sta3[(10*(page-1)):(page*10)], "nums": len(sta3)} print("-------------",len(sta3)) data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # ----------------------------------------------------------------------------------------- # 在线状态筛选设备 elif is_online != "" and dver == "": sta4 = [] for i in sta1: if is_online == i.is_online: sta4.append({"cbd_status": i.cbd_status, "upl_time": i.upl_time, "paramconf": i.paramconf, "serverconf": i.serverconf, "equip_name": i.equip_id.equip_name, "equip_desc": i.equip_id.equip_desc, "is_online": i.is_online, "off_time": i.off_time}) data = {"dat": sta4[(10*(page-1)):(page*10)], "nums": len(sta4)} print("-------------",len(sta4)) data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # ----------------------------------------------------------------------------------------- # 版本号和在线状态同时筛选设备 elif is_online != "" and dver != "": sta3 = [] for i in sta1: fir_v = eval(i.cbd_status)["dver"].split(".") if fir_v[0] == dver and i.is_online == is_online: sta3.append({"cbd_status": i.cbd_status, "upl_time": i.upl_time, "paramconf": i.paramconf, "serverconf": i.serverconf, "equip_name": i.equip_id.equip_name, "equip_desc": i.equip_id.equip_desc, "is_online": i.is_online, "off_time": i.off_time}) data = {"dat": sta3[(10*(page-1)):(page*10)], "nums": len(sta3)} print("-------------",len(sta3)) data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # ----------------------------------------------------------------------------------------- sta2 = [{"cbd_status": x.cbd_status, "upl_time": x.upl_time, "paramconf": x.paramconf, "serverconf": x.serverconf, "equip_name": x.equip_id.equip_name, "equip_desc": x.equip_id.equip_desc, "is_online": x.is_online, "off_time": x.off_time} for x in sta1] data = {"dat": sta2[(10*(page-1)):(page*10)], "nums": sta1.count()} data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) elif req == "paramconf": equip_id = request.POST.get('id') print("equip_id:", equip_id) # 读取当前设备的参数配置信息： sta1 = CBDstatus.objects.filter(equip_id=equip_id) for x in sta1: sta2 = {"paramconf": x.paramconf} data = json.dumps(sta2, cls=CJSONEncoder) print("配置信息的data:", data) return HttpResponse(data) elif req == "change": equip_id = request.POST.get('id') print("equip_id:", equip_id) equip_desc = request.POST.get('desc') equip_obj = Equip.objects.get(equip_id=equip_id) try: equip_obj.equip_desc = equip_desc equip_obj.save() data = "0" except: data = "1" return HttpResponse(data) # 测报灯短信配置 class CBDMsg_Conf(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get("e_id") try: msgconf = Msg_Conf.objects.get(equip_id=e_id) data = msgconf.conf except: data = "" return HttpResponse(data) # 测报灯短信配置保存 class MsgConf_Save(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get("e_id") e_conf = request.POST.get("conf") equip_obj = Equip.objects.get(equip_id=e_id) if Msg_Conf.objects.filter(equip_id=equip_obj).exists(): msgconf = Msg_Conf.objects.get(equip_id=equip_obj) msgconf.conf = e_conf msgconf.save() else: Msg_Conf.objects.create(equip_id=equip_obj,conf=e_conf) return HttpResponse("0") class AlarmRange_View(View): def get(self, request): e_id = request.GET.get("e_id") return render(request, 'warnmanage/alarm_range.html', context={"e_id":e_id}) def post(self, request): e_id = request.POST.get("e_id") pest_num = 0 pest_name = [] pest_nums = [] pest_dict = {} pest_dict_new = {} cbd_list = CBDphoto.objects.filter(equip_id=e_id) for x in cbd_list: if x.indentify_result == None or x.indentify_result == "": pass else: for a in x.indentify_result.split("#"): pest_num = pest_num + int(a.split(",")[1]) pest_name.append(int(a.split(",")[0])) pest_nums.append(int(a.split(",")[1])) for xx in range(len(pest_name)): c = {pest_name[xx]:pest_nums[xx]} for d in c: if d in pest_dict: pest_dict[d] = pest_dict[d] + c[d] else: pest_dict.update(c) print(pest_dict) pest_list = [] for i in pest_dict: pest_list.append(i) data = {"pest_list":pest_list} data = json.dumps(data) return HttpResponse(data) class AlarmHistory_View(View): def get(self, request): current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser != True and current_user.is_staff != True: # __username print("---不是管理员") alarm_record = Alarm_record.objects.filter(equip_id__equip_user=current_user)[0:10] else: print("---管理员") alarm_record = Alarm_record.objects.all() return render(request, 'warnmanage/alarm_history.html', context={'alarm_record':alarm_record}) def alarm_map(request): return render(request, 'warnmanage/alarm_map.html', context={}) # sim卡流量提醒 class Sim_Flow(ListView): def get(self,request): return render(request, 'warnmanage/sim_list.html', context={}) class Sim_Flow_View(ListView): def get(self,request): current_user = request.session.get('username') current_user = MyUser.objects.get(username=current_user) page = int(request.GET.get("page")) e_id = request.GET.get("e_id") iccid = request.GET.get("iccid") status = request.GET.get("status") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---用户") if e_id: simlist = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user,equip_id__equip_id__contains=e_id)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user,equip_id__equip_id__contains=e_id).count() elif iccid: simlist = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user,iccid__contains=iccid)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user,iccid__contains=iccid).count() elif status: status = int(status) simlist = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user,account_status=status)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user,account_status=status).count() else: simlist = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user).count() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") if e_id: simlist = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency,equip_id__equip_id__contains=e_id)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency,equip_id__equip_id__contains=e_id).count() elif iccid: simlist = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency,iccid__contains=iccid)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency,iccid__contains=iccid).count() elif status: status = int(status) simlist = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency,account_status=status)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency,account_status=status).count() else: simlist = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency).count() else: print("---管理员") if e_id: simlist = Equip_SimInfo.objects.filter(equip_id__equip_id__contains=e_id)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(equip_id__equip_id__contains=e_id).count() elif iccid: simlist = Equip_SimInfo.objects.filter(iccid__contains=iccid)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(iccid__contains=iccid).count() elif status: status = int(status) simlist = Equip_SimInfo.objects.filter(account_status=status)[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.filter(account_status=status).count() else: simlist = Equip_SimInfo.objects.all()[(10*(page-1)):(page*10)] nums = Equip_SimInfo.objects.all().count() return render(request, 'warnmanage/siminfoList.html', context={"simlist":simlist,"nums":nums}) # 手机号保存 class Sim_Save(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get("e_id") mobile = request.POST.get("mobile") try: sim_obj = Equip_SimInfo.objects.get(equip_id=e_id) sim_obj.sim_alarm = mobile sim_obj.save() except Exception as e: print(e) return HttpResponse("1") return HttpResponse("0")