# -*- coding: utf-8 -*- import copy import datetime import json import os import re import time import requests from django.conf.urls import url from django.contrib import auth from django.contrib.auth import authenticate from django.contrib.auth import login as auth_login from django.contrib.auth import logout from django.contrib.auth.decorators import login_required from django.contrib.auth.hashers import check_password, make_password from django.db.models import Q from django.http import HttpResponse, response from django.shortcuts import redirect, render from django.views.generic import ListView from django.views.generic.base import View from PIL import Image from requests.auth import HTTPBasicAuth from apps.AppInfoManage.models import * from apps.EquipManage.views import CJSONEncoder, equip_validation from apps.ReportManage.all_dict import api_code, insect_dict_new, qxz_dict from apps.SimInfo.views import get_siminfo, get_simsinfo from yfwlw_pro.settings import get_client_ip # 微信小程序登录： class wechat_login(View): def post(self, request): user_name = request.POST.get("username") pass_word = request.POST.get("password") #校验用户和密码 if MyUser.objects.filter(username=user_name).exists(): account = MyUser.objects.get(username=user_name) ret = check_password(pass_word, account.password) if ret: auth_obj = auth.authenticate(username=user_name, password=pass_word) if auth_obj: print("写入登陆状态成功") auth.login(request, auth_obj) #将当前登录的用户名写入session request.session['username'] = user_name # name1 = request.session["username"] # print("name",name1) # name2 = request.session.get("username","") # print("name2",name2) data = {"code":"0","username":user_name} else: data = {"code":"1","username":""} else: data = {"code":"2","username":""} data = json.dumps(data) return HttpResponse(data) # 退出APP登录： class wechat_logout(View): def get(self, request): # username = request.POST.get('username') del request.session["username"] data = {"code":"0"} data = json.dumps(data) return HttpResponse(data) #用户设备类型 class wechat_user_equip_list(View): def post(self,request): user_name = request.POST.get("username") # user_name = request.user.username print("-------------------->>",request.user) print("username",user_name) # print("current_user",current_user) try: current_user = MyUser.objects.get(username=user_name) except: return HttpResponse("0") equip_type_list = [] if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("普通用户") user_equip_list = Equip.objects.filter(equip_user=current_user) for i in user_equip_list: equip_type_list.append(i.equip_type.type_id) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("代理商") user_equip_list = Equip.objects.filter(equip_agency=current_user.user_agency) for i in user_equip_list: equip_type_list.append(i.equip_type.type_id) # 新增 elif current_user.is_superuser == True or current_user.is_staff == True: print("管理员") user_equip_list = Equip_type.objects.all() for i in user_equip_list: equip_type_list.append(i.type_id) else: return HttpResponse("0") equip_type_list = list(set(equip_type_list)) data = {'dat':equip_type_list} data = json.dumps(data) print(data) return HttpResponse(data) # 个人信息： class wechat_user_info(View): def get(self, request): uname = request.GET.get("username") try: user_name = MyUser.objects.get(username=uname) if user_name.is_superuser == 1 and user_name.is_staff == 1: # 超级管理员 role = 0 elif user_name.is_superuser == 0 and user_name.is_staff == 1: # 管理员 role = 1 elif user_name.is_superuser == 0 and user_name.is_staff == 0: # 普通用户 role = 2 except Exception as e: print(e) role = 3 data = {"data":role} data = json.dumps(data) return HttpResponse(data) def post(self, request): req = request.POST.get('req') name = request.POST.get('username') print("req",req) print("name","name") if req == "info": user = MyUser.objects.filter(username=name) print(user) for x in user: data = {"username": x.username, "email": x.email, "user_phone": x.user_phone, "user_pro": x.user_pro, "user_city": x.user_city, "user_area": x.user_area, "user_picture":str(x.user_picture) } data = json.dumps(data) print("data:",data) return HttpResponse(data) elif req == "change_info": user = MyUser.objects.get(username=name) user.user_phone = request.POST.get('phone') user.user_pro = request.POST.get('province') user.user_city = request.POST.get('city') user.user_area = request.POST.get('area') print("phone:", request.POST.get('phone')) print("province:", request.POST.get('province')) print("city:", request.POST.get('city')) print("area:", request.POST.get('area')) try: user.save() User_Log.objects.create(log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='修改个人信息') data = "0" return HttpResponse(data) except: data = "1" return HttpResponse(data) # 修改头像： elif req == "change_photo": user = MyUser.objects.get(username=name) user_photo = request.FILES.get('file') print("APP修改用户头像：", user_photo) user_photo_dir = 'user_photo/' # 判断如果路径不存在，即创建路径 if os.path.exists(user_photo_dir) == False: os.makedirs(user_photo_dir) img = Image.open(user_photo) img.save(user_photo_dir + name+".png") new_photo = user_photo_dir + name+".png" # 数据库关联设备，并在照片的表中存入路径： user.user_picture = new_photo user.save() data = "0" return HttpResponse(data) # 设备管理列表： class wechat_equip_list(View): def post(self, request): types = int(request.POST.get('type')) print("types:", types) page = int(request.POST.get('page')) print("page:", page) current_user = request.POST.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) equip_id = request.POST.get("equip_id") #杀虫灯 if types == 2: equips = SCDstatus #测报灯 elif types == 3: equips = CBDstatus #孢子仪 elif types == 7: equips = BZYstatus #气象站 elif types == 5: equips = QXZstatus_New #依科曼性诱设备 elif types == 8: equips = Trapstatus #智能性诱 elif types == 4: equips = YBQstatus # 糖醋测报 elif types == 9: equips = TCCBstatus # 测报RTU elif types == 10: equips = RTUstatus else: return HttpResponse("参数不对") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") equip_list = Equip.objects.filter(equip_user=current_user,equip_type__type_id=types) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---经销商") equip_list = Equip.objects.filter(equip_agency=current_user.user_agency,equip_type__type_id=types) else: print("---管理员") equip_list = Equip.objects.filter(equip_type__type_id=types) if equip_id: equip_list = equip_list.filter(equip_id__contains=equip_id) nums = len(equip_list) equip_list = equip_list[(10*(page-1)):(page*10)] data = {'nums': nums, 'dat': ""} dat = [] cbd_img = 0 sex_type = "" iccid = "" for i in equip_list: equip_location = i.equip_location if types == 3: cbd_photo = CBDphoto.objects.filter(equip_id=i.equip_id) if cbd_photo.exists(): cbd_img = 1 if types == 5: qxz_status = QXZ_Base_Info.objects.filter(equip_id=i.equip_id) if qxz_status: for y in qxz_status: iccid = y.iccid sta1 = equips.objects.filter(equip_id=i.equip_id).select_related() for x in sta1: try: if types == 2: iccid = eval(x.scd_status)["iccid"] elif types == 3: iccid = eval(x.cbd_status)["iccid"] elif types == 7: iccid = eval(x.bzy_status)["iccid"] elif types == 4: iccid = eval(x.ybq_status)["iccid"] #性诱类型 sex_type = x.sex_type except: iccid = '' try: sta2 = {"equip_id": x.equip_id.equip_id, "equip_user": x.equip_id.equip_user.username, "equip_name": x.equip_id.equip_name, "equip_type": types, "equip_desc":x.equip_id.equip_desc, "equip_add_time":x.upl_time, "cbd_img":cbd_img, "is_online":x.is_online, "equip_location":equip_location, "iccid":iccid, "sex_type":sex_type} except AttributeError: sta2 = {"equip_id": x.equip_id.equip_id, "equip_user": "", "equip_name": x.equip_id.equip_name, "equip_type": types, "equip_desc":x.equip_id.equip_desc, "equip_add_time":x.upl_time, "cbd_img":cbd_img, "is_online":x.is_online, "equip_location":equip_location, "iccid":"", "sex_type":""} dat.append(sta2) User_Log.objects.create(log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='设备列表') data['dat'] = dat data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #设备修改名称，修改位置 class wechat_equip_set(View): def post (self,request): equip_id = request.POST.get("equip_id") ret = request.POST.get("ret") try: equip_list = Equip.objects.get(equip_id=equip_id) if ret == "name": name = request.POST.get("name") equip_list.equip_name = name equip_list.save() elif ret == "site": site = request.POST.get("site") equip_list.equip_location = site equip_list.save() data = {"code":"0"} except Exception as e: print("e") data = {"code":"1"} data = json.dumps(data) return HttpResponse(data) # #设备搜索接口(弃用) # class wechat_equip_search(View): # def post(self, request): # equip_id = request.POST.get('equip_id') # types = int(request.POST.get('type')) # current_user = request.POST.get('username') # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) # print("equip_id:", equip_id) # equip_list = Equip.objects.filter(equip_id__contains=equip_id,equip_type__type_id=types,equip_user=current_user) # data = {'dat': ""} # dat = [] # for i in equip_list: # cbd_photo = CBDphoto.objects.filter(equip_id=i.equip_id) # if cbd_photo.exists(): # cbd_img = 1 # else: # cbd_img = 0 # sta1 = Equip.objects.filter(equip_id=i.equip_id).select_related() # for x in sta1: # try: # sta2 = {"equip_id": x.equip_id, # "equip_user": x.equip_user.username, # "equip_name": x.equip_name, # "equip_type": x.equip_type.type_id, # "equip_desc":x.equip_desc, # "equip_add_time":x.equip_add_time, # "cbd_img":cbd_img} # except AttributeError: # sta2 = {"equip_id": x.equip_id, # "equip_user": "", # "equip_name": x.equip_name, # "equip_type": x.equip_type.type_id, # "equip_desc":x.equip_desc, # "equip_add_time":x.equip_add_time, # "cbd_img":cbd_img} # dat.append(sta2) # User_Log.objects.create(log_user=request.user.username, # log_ip=request.META['REMOTE_ADDR'], log_desc='设备列表') # data['dat'] = dat # data = json.dumps(data, cls=CJSONEncoder) # return HttpResponse(data) # 设备管理详情： class wechat_equip_detail(View): def post(self, request): etype = request.POST.get('etype') print("etype:", etype) equip_id = request.POST.get('equip_id') print("equip_id:", equip_id) if etype == "scd": x = SCDstatus.objects.get(equip_id__equip_id=equip_id) scd = eval(x.scd_status) if x.equip_id.equip_user: user_name = x.equip_id.equip_user.username else: user_name = "" print(user_name) sta2 = {"scd_status": scd, "ds": x.ds, "upl_time": x.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"user_name":user_name, "equip_name": x.equip_id.equip_name,"equip_location":x.equip_location, "is_online": x.is_online, "off_time": x.off_time.strftime('%Y-%m-%d %H:%M:%S')} elif etype == "cbd": x = CBDstatus.objects.get(equip_id=equip_id) if x.equip_id.equip_user: user_name = x.equip_id.equip_user.username else: user_name = "" print(user_name) cbd = eval(x.cbd_status) sta2 = {"cbd_status": cbd, "upl_time": x.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"equip_location":x.equip_location, "paramconf": x.paramconf, "equip_name": x.equip_id.equip_name,"user_name":user_name, "is_online": x.is_online, "off_time": x.off_time.strftime('%Y-%m-%d %H:%M:%S')} elif etype == "qxz": qxz_list = QXZstatus_New.objects.get(equip_id=equip_id) switch = QXZswitchstatus.objects.filter(equip_id=equip_id) if switch: switch = 1 else: switch = 0 data = [qxz_list.e1,qxz_list.e2,qxz_list.e3,qxz_list.e4,qxz_list.e5,qxz_list.e6,qxz_list.e7,qxz_list.e8,qxz_list.e9,qxz_list.e10, qxz_list.e11,qxz_list.e12,qxz_list.e13,qxz_list.e14, qxz_list.e15,qxz_list.e16,qxz_list.e17,qxz_list.e18, qxz_list.e19,qxz_list.e20,qxz_list.e21,qxz_list.e22, qxz_list.e23,qxz_list.e24,qxz_list.e25,qxz_list.e26, qxz_list.e27,qxz_list.e28,qxz_list.e29,qxz_list.e30] test = [i for i in data if i != ''] sta = [] try: for i in test: qxz = i.split("#") qw = qxz_dict[qxz[1]] qxz_num = [qxz[2],qxz[0],qw] sta.append(qxz_num) except Exception as e : print(e) if qxz_list.equip_id.equip_user: user_name = qxz_list.equip_id.equip_user.username else: user_name = "" print(user_name) sta2 = {"data":sta,"qxz_picture":qxz_list.qxz_picture.name,"user_name":user_name, "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"switch":switch} elif etype == "bzy": x = BZYstatus.objects.get(equip_id=equip_id) if x.equip_id.equip_user: user_name = x.equip_id.equip_user.username else: user_name = "" print(user_name) bzy = eval(x.bzy_status) sta2 = {"bzy_status": bzy, "upl_time": x.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"user_name":user_name, "equip_name": x.equip_id.equip_name, "glass": x.glass, "liquid":x.liquid, "is_online": x.is_online, "off_time": x.off_time.strftime('%Y-%m-%d %H:%M:%S')} data = json.dumps(sta2) return HttpResponse(data) #设备时间筛选 class equip_time_list(View): def post(self,request): equip_id = request.POST.get("equip_id") page = int(request.POST.get("page")) req = request.POST.get("req") start_time = request.POST.get('start_time') end_time = request.POST.get('end_time') now_time = datetime.datetime.now() print("当前日期为：",now_time) print("当前月为：",now_time.month) print("当前月为：",now_time.year) if req == "scd": equips = SCDdata elif req == "cbd": equips = CBDdata elif req == "bzy": equips = BZYdata elif req == "qxz": equips = QXZdata_New elif req == "xy": equips = Trapdata if start_time: begindate = re.findall(r"\d+\.?\d*", start_time) enddate = re.findall(r"\d+\.?\d*", end_time) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2])) print("start_date:", start_date) print("end_date:", end_date) time_list = equips.objects.filter(equip_id=equip_id,upl_time__range=(start_date,end_date)).values() else: time_list = equips.objects.filter(equip_id=equip_id,upl_time__month=now_time.month,upl_time__year=now_time.year).values() date = [] for i in time_list: date.append({"time":i["upl_time"].strftime('%Y-%m-%d %H:%M:%S'),"id":i["id"]}) nums = len(date) dat = date[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} data = json.dumps(data) return HttpResponse(data) # #杀虫灯报设备详情(弃用) # class scd_equip_details(View): # def post(self,request): # equip_id = request.POST.get("equip_id") # scd_list = SCDstatus.objects.filter(equip_id=equip_id).first() # try: # scd_data = eval(scd_list.scd_status) # imei = scd_data["imei"] # upl_time = scd_list.upl_time.strftime('%Y-%m-%d %H:%M:%S') # dver = scd_data["dver"] # csq = scd_data["csq"] # ws = scd_data["ws"] # if ws == 0: # ws = "待机" # elif ws == 1: # ws = "工作" # tt = scd_data["tt"] # lps = scd_data['lps'] # if lps == 0: # lps = "正常" # elif lps == 1: # lps = "保护" # else: # lps = '' # tbs = scd_data['tbs'] # if tbs == 0: # tbs = "正常" # elif tbs == 1: # tbs = "保护" # else: # tbs = '' # rps= scd_data['rps'] # if rps == 0: # rps = "正常" # elif rps == 1: # rps = "保护" # else: # rps = '' # tps = scd_data['tps'] # if tps == 0: # tps = "正常" # elif tps == 1: # tps = "保护" # else: # tps = '' # dps = scd_data['dps'] # if dps == 0: # dps = "正常" # elif dps == 1: # dps = "保护" # else: # dps = '' # data = {"imei":imei,"time":upl_time,"dver":dver,"csp":csq, # "ds":scd_list.ds,"ws":ws,"tt":tt,"lps":lps,"tbs":tbs,"rps":rps,"tps":tps,"dps":dps} # except Exception as e: # print("报错信息为:",e) # data = {"code":"1"} # data = json.dumps(data) # return HttpResponse(data) # #测报灯配置接口 # class scd_equip_paramconf(View): # def post(self,request): # 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":eval(x.paramconf)} # data = json.dumps(sta2, cls=CJSONEncoder) # print("配置信息的data:", data) # return HttpResponse(data) #杀虫灯报表管理详情 class scd_equip_report(View): def post(self,request): equip_id = request.POST.get("equip_id") req = request.POST.get("req") print("req",req) scd_date = SCDdata.objects.filter(equip_id=equip_id) if req == "new_time": scd_list = scd_date[:1] elif req == "time": scd_id = request.POST.get("id") scd_list = scd_date.filter(id=scd_id) elif req == "times": start_time = request.POST.get('start_time') end_time = request.POST.get('end_time') scd_list = scd_date.filter(upl_time__range=(start_time,end_time)) else: return HttpResponse("参数错误") scd_status = SCDstatus.objects.filter(equip_id=equip_id) data = [] #设备数据信息 date = [] # 设备状态信息 for x in scd_status: print(x.scd_status) date_status = eval(x.scd_status) try: clt = date_status["clt"] except: clt = "" date.append({ "iccid": date_status["iccid"], "dver": date_status["dver"], "csq": date_status["csq"], "clt":clt, "equip_location":x.equip_location, "dattim":date_status["dattim"], "lps":date_status["lps"], }) try: for i in scd_list: scd_data = eval(i.scd_data) print(scd_data) imei = scd_data["imei"] tt = scd_data["tt"] #定时时长 upl_time = i.upl_time.strftime('%Y-%m-%d %H:%M:%S') ds = scd_data["ds"] #设备开关 if ds == 0: ds = "关机" else: ds = "开机" ws = scd_data["ws"] #工作状态 if ws == 0: ws = "待机" elif ws == 1: ws = "工作" else: ws = "充电" tbs = scd_data["tbs"] #灯管状态 if tbs == 0: tbs = "正常" else : tbs = "保护" lps = scd_data["lps"] #光控 if lps == 0: lps = "正常" else: lps = "保护" rps = scd_data["rps"] #雨控 if rps == 0: rps = "正常" else: rps = "保护" tps = scd_data['tps'] #温控 if tps == 0: tps = "正常" else: tps = "保护" dps = scd_data['dps'] #倾倒 if dps == 0: dps = "正常" else: dps = "保护" cv = scd_data["cv"] #充电电压 bv = scd_data["bv"] #电池电压 at = scd_data["at"] #环境温度 ah = scd_data["ah"] #环境湿度 ct = scd_data["ct"] #电击次数 lng = scd_data["lng"] lat = scd_data["lat"] data.append({"imei":imei,"tt":tt,"time":upl_time,"ds":ds,"ws":ws,"tbs":tbs, "lps":lps,"rps":rps,"tps":tps,"dps":dps,"cv":cv,"bv":bv, "at":at,"ah":ah,"ct":ct,"lng":lng,"lat":lat,}) except: data = "" data = {"data":data,"date":date} data = json.dumps(data) print("data",data) return HttpResponse(data) #杀虫灯折线图(24小时数据) class scd_line_chart(View): def post(self, request): equip_id = request.POST.get('equip_id') start_time = request.POST.get('start_time') end_time = request.POST.get('end_time') start_date = datetime.datetime.now() - datetime.timedelta(days=2) end_date = datetime.datetime.now() if start_time: # 时间筛选 begindate = re.findall(r"\d+\.?\d*", start_time) enddate = re.findall(r"\d+\.?\d*", end_time) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2])) scd_list = SCDdata.objects.filter(equip_id=equip_id,upl_time__range=(start_date, end_date)).values() data = [] for i in scd_list: scd_list = eval(i["scd_data"]) data.append({"cv":scd_list["cv"],"bv":scd_list["bv"],"at":scd_list["at"],"ah":scd_list["ah"],"ct":scd_list["ct"], "time":i["upl_time"].strftime('%Y-%m-%d %H:%M:%S')}) data = {"data":data} data = json.dumps(data) print("data",data) return HttpResponse(data) # #杀虫灯击杀折线图 # class scd_ct_chart(View): # def post (self,request): # equip_id = request.POST.get('equip_id') # end_time = datetime.datetime.now() # start_date = end_time - datetime.timedelta(days=2) # scd_list = SCDdata.objects.filter(equip_id=equip_id) # data = [] # # if ret == "day": # # start_date = datetime.datetime.now() - datetime.timedelta(days=2) # # scd_list = scd_list.filter(upl_time__range=(start_date, end_time)).values() # # elif ret == "one": # # start_date = datetime.datetime.now() - datetime.timedelta(days=1) # # scd_list = scd_list.filter(upl_time__range=(start_date, end_time)).values() # # elif ret == "month": # # scd_list = scd_list.filter(upl_time__month=end_time.month,upl_time__year=end_time.year).values() # # for i in scd_list: # # scd_list = eval(i["scd_data"]) # # data.append({"ct":scd_list["ct"],"time":i["upl_time"].strftime('%Y-%m-%d %H:%M:%S')}) # data = json.dumps(data) # print("data",data) # return HttpResponse(data) #杀虫灯查询最新数据，最新状态 class scd_wechat_mqtt_read(View): def post(self,request): uid = request.POST.get('username') print("uid",uid) imei = request.POST.get('imei') print("imei",imei) print("下发查询") kind = request.POST.get("kind") if kind == "status" or kind == "data" or "paramconf": print("imei",imei) payload = {"cmd": "read", "ext": kind} topic = "/yfkj/scd/sub/"+imei cmd = {"topic": topic, "payload": json.dumps( payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[1] data = json.dumps(data) print(data) return HttpResponse(data) #杀虫灯下发开关 class scd_wechat_mqtt_switch(View): def post(self,request): uid = request.POST.get('username') print("uid",uid) imei = request.POST.get('imei') try: ds = int(request.POST.get('ds')) except Exception as e: print(e) data = api_code[1] if ds == 0 or ds == 1: # 控制设备开关 print("下发开关！！！") payload = {"cmd": "power", "ext": {"ds": ds}} else: data = api_code[3] data = json.dumps(data) print(data) return HttpResponse(data) topic = "/yfkj/scd/sub/"+imei #[1:-1] cmd = {"topic": topic, "payload": json.dumps( payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) print("res.status_code:", res.status_code) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) #杀虫灯下发控制 class scd_wechat_mqtt_set(View): def post(self,request): uid = request.POST.get('username') imei = request.POST.get('imei') # 用户验证 topic = "/yfkj/scd/sub/"+imei try: ts = request.POST.get('ts') except Exception as e: print(e) ts = "" # ts = timeSwitch 0光控 1时控 startBar 开始时间 stopBar 结束时间 print("ts",ts) if ts == '0': # 光控 try: hours = int(request.POST.get('hours')) except: data = api_code[1] data = json.dumps(data) print(data) return HttpResponse(data) if 0 <= hours < 24: payload = {"cmd": "timer", "ext": {"tt": hours}} cmd = {"topic": topic, "payload": json.dumps( payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[3] data = json.dumps(data) print(data) return HttpResponse(data) elif ts == '1': # 时控 try: begin = int(request.POST.get('begin')) end = int(request.POST.get('end')) except: data = api_code[1] data = json.dumps(data) return HttpResponse(data) if 0 <= begin <= 24 and 0 <= end <= 24: payload = {"cmd": "timeconf","ext": {"timeSwitch": int(ts),"startBar": begin,"stopBar": end}} cmd = {"topic": topic, "payload": json.dumps( payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[3] data = json.dumps(data) return HttpResponse(data) elif ts == "datt": print("下发上传时间间隔") dattim = int(request.POST.get('dattim')) payload = {"cmd":"dattim","ext":{"dattim":dattim}} cmd = {"topic": topic, "payload": json.dumps( payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) # else: # res = requests.post("http://www.yfznscd.com:8080/api/v2/mqtt/publish", # data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[3] data = json.dumps(data) print(data) return HttpResponse(data) #测报灯配置接口 class cbd_equip_paramconf(View): def post(self,request): equip_id = request.POST.get('id') print("equip_id:", equip_id) sta2 = 0 # 读取当前设备的参数配置信息： sta1 = CBDstatus.objects.filter(equip_id=equip_id) for x in sta1: if x.paramconf: sta2 = {"is_online":x.is_online,"paramconf":eval(x.paramconf)} data = json.dumps(sta2, cls=CJSONEncoder) print("配置信息的data:", data) return HttpResponse(data) # #测报灯设备详情(弃用) # class cbd_equip_details(View): # def post(self,request): # equip_id = request.POST.get("equip_id") # print(equip_id) # cbd_list = CBDstatus.objects.filter(equip_id=equip_id).first() # print(cbd_list) # try: # cbd_data = eval(cbd_list.cbd_status) # imei = cbd_data["imei"] # upl_time = cbd_list.upl_time.strftime('%Y-%m-%d %H:%M:%S') # dver = cbd_data["dver"] # csq = cbd_data["csq"] # iccid = cbd_data["iccid"] # is_online = cbd_list.is_online # if is_online == 0 : # is_online = "离线" # else: # is_online = "在线" # rps= cbd_data['rps'] # if rps == 0: # rps = "正常" # else: # rps = "雨控" # lps = cbd_data['lps'] # if lps == 0: # lps = "正常" # else: # lps = "光控" # tps = cbd_data['tps'] # if tps == 0: # tps = "正常" # else: # tps = "温控" # gs = cbd_data["gs"] # if gs == 0: # gs = "排水" # else: # gs = "落虫" # upds = cbd_data['upds'] # if upds == 0: # upds = "关闭" # else: # tcs = "打开" # dnds = cbd_data["dnds"] # if dnds == 0: # dnds = "关闭" # else: # dnds = "打开" # hs = cbd_data["hs"] # if hs == 0: # hs = "正常" # else: # hs = "加热" # ts = cbd_data['ts'] # if ts == 0: # ts = "光控" # else: # ts = "时控" # data = {"imei":imei,"time":upl_time,"dver":dver,"csp":csq,"iccid":iccid, # "rps":rps,"lps":lps,"tps":tps,"gs":gs,"upds":upds,"dnds":dnds, # "hs":hs,"ts":ts,"is_online":is_online} # except Exception as e: # print("报错信息为:",e) # data = {"code":"1"} # data = json.dumps(data) # return HttpResponse(data) #测报灯报表管理详情页面 class cbd_equip_report(View): def post(self,request): equip_id = request.POST.get("equip_id") req = request.POST.get("req") cbd_list = CBDdata.objects.filter(equip_id=equip_id) if req == "new_time": cbd_list = cbd_list[:1] elif req == "time": cbd_id = request.POST.get("id") cbd_lsit = cbd_list.filter(id=cbd_id) elif req == "times": start_time = request.POST.get('start_time') end_time = request.POST.get('end_time') begindate = re.findall(r"\d+\.?\d*", start_time) enddate = re.findall(r"\d+\.?\d*", end_time) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2])) print("start_date:", start_date) print("end_date:", end_date) cbd_list = cbd_list.filter(upl_time__range=(start_date,end_date)) data = [] #设备数据信息 date = [] # 设备状态信息 cbd_status = CBDstatus.objects.filter(equip_id=equip_id) for x in cbd_status: if x.paramconf: data_paramconf = eval(x.paramconf) tph = data_paramconf["tph"] # 高温保护值 tpl = data_paramconf["tpl"] # 低温保护值 else: tph = "" tpl = "" data_status = eval(x.cbd_status) try: ws = data_status["ws"] except: ws = "" try: lamp = data_status["lamp"] except: lamp = "" print("ws",ws) date.append( { "ws":ws, "gs":data_status["gs"], "hs":data_status["hs"], "csq":data_status["csq"], "dver":data_status["dver"], "lamp":lamp, "upds":data_status["upds"], "dnds":data_status["dnds"], "tph":tph, "tpl":tpl, "equip_location":x.equip_location } ) try: for i in cbd_list: cbd_data = eval(i.cbd_data) imei = cbd_data["imei"] upl_time = i.upl_time.strftime('%Y-%m-%d %H:%M:%S') at = cbd_data["at"] ah = cbd_data["ah"] hrt = cbd_data["hrt"] rps= cbd_data['rps'] lng = cbd_data["lng"] lat = cbd_data["lat"] vbat = cbd_data["vbat"] # lamp = cbd_data["lamp"] if rps == 0: rps = "正常" else: rps = "雨控" lps = cbd_data['lps'] if lps == 0: lps = "正常" else: lps = "光控" tps = cbd_data['tps'] if tps == 0: tps = "正常" else: tps = "温控" data.append({"imei":imei,"time":upl_time,"at":at,"ah":ah,"vbat":vbat, "rps":rps,"lps":lps,"tps":tps,"hrt":hrt,"lng":lng,"lat":lat}) except: data = [] data = {"data":data,"date":date} data = json.dumps(data) return HttpResponse(data) #测报灯折线图 class cbd_line_chart(View): def post(self,request): equip_id = request.POST.get("equip_id") start_time = request.POST.get("start_time") end_time = request.POST.get("end_time") start_date = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime('%Y-%m-%d') end_date = (datetime.datetime.now() + datetime.timedelta(days=1) ).strftime('%Y-%m-%d') print("start_date",start_date) print("end_date",end_date) cbd_list = CBDdata.objects.filter(equip_id=equip_id,upl_time__range=(start_date,end_date)) print(len(cbd_list)) if start_time: cbd_list = CBDdata.objects.filter(equip_id=equip_id,upl_time__range=(start_time,end_time)) data = [] for i in cbd_list: cbd_data = eval(i.cbd_data) at = cbd_data["at"] ah = cbd_data["ah"] data.append({"at":at,"ah":ah,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) data = json.dumps(data) print("data",data) return HttpResponse(data) #测报灯删除图片(查看图片列表) class cbd_photo_list(View): def get(self, request): equip_id = request.GET.get("equip_id") print("equip_id",equip_id) page = int(request.GET.get("page")) cbd_photo = CBDphoto.objects.filter(equip_id=equip_id).values() data =[] for i in cbd_photo: data.append({"addr":i['addr'],"describe":i["describe"],"upl_time":i["upl_time"].strftime('%Y-%m-%d %H:%M:%S')}) num = cbd_photo.count() dat = data[(10*(page-1)):(page*10)] data = {'dat': dat, 'num': num} data = json.dumps(data) print("data",data) return HttpResponse(data) def post(self,request): equip_id = request.POST.get("equip_id") photo = request.POST.get("photo") if os.path.exists(photo) == True: #删除图片路经 os.remove(photo) try: CBDphoto.objects.filter(addr=photo,equip_id=equip_id).delete() data = 1 except Exception as e: print(e) data = 0 else: try: CBDphoto.objects.filter(addr=photo,equip_id=equip_id).delete() data = 1 except Exception as e: print(e) data = 0 return HttpResponse(data) #判断测报灯是否具有害虫识别功能 class cbd_pest_img_discern(View): def get (self,request): equip_id = request.GET.get("equip_id") cbd_pest = RecentCBDdata.objects.get(equip_id=equip_id) data = {"disc":cbd_pest.disc,"equip_id":cbd_pest.equip_id.equip_id} data = json.dumps(data) return HttpResponse(data) #测报灯添加图片描述信息 class cbd_add_photo_describe(View): def post(self,request): req = request.POST.get("req") user_name = request.POST.get("username") # user_name = 'admin' current_user = MyUser.objects.get(username=user_name) # 请求害虫种类列表： if req == "pest_list": pest_kinds = CBDpest.objects.filter(user=current_user) nums = len(pest_kinds) dat = [{"pest_name": x.pest_name} for x in pest_kinds] data = {"num":nums,"data":dat} # 请求图片描述： elif req == "photo_desc": img_name = request.POST.get('addr') descs = CBDphoto_desc.objects.filter(photo_id=CBDphoto.objects.get(addr=img_name),desc_user=current_user) data = [{"crop_name": x.crop_name, "pest_case": x.pest_case, "pest_name": x.pest_name.pest_name, "pest_num":x.pest_num} for x in descs] # 增加害虫种类： elif req == "add_pest": pest = request.POST.get('pest') print("pest:",pest) # 如果该用户下的该害虫名称已经存在！ if CBDpest.objects.filter(user=current_user,pest_name=pest).exists(): data = '1' try: CBDpest.objects.create(user=current_user,pest_name=pest) pest_kinds = CBDpest.objects.filter(user=current_user) data = [{"pest_name": x.pest_name,} for x in pest_kinds] except: data = '2' # 删除害虫种类： elif req == "del_pest": pests = request.POST.get('pest') CBDpest.objects.filter(user=current_user,pest_name=pests).delete() pest_kinds = CBDpest.objects.filter(user=current_user) data = [{"pest_name": x.pest_name,} for x in pest_kinds] data = json.dumps(data) return HttpResponse(data) #测报灯图片描述信息 class cbd_see_photo_describe(View): def post(self,request): req = request.POST.get('req') user_name = request.POST.get("username") img_name = request.POST.get('addr') photo_time = request.POST.get('photo_time') desc = request.POST.get('describe') equip_id = request.POST.get("equip_id") current_user = MyUser.objects.get(username=user_name) desc = json.loads(desc) # 增加描述： if req == "add_desc": if CBDphoto_desc.objects.filter(desc_user=current_user, photo_id = CBDphoto.objects.get(addr=img_name), pest_name=CBDpest.objects.get(user=current_user, pest_name=desc['pest_name'])).exists(): data = '2' try: CBDphoto_desc.objects.create( desc_user = current_user ,photo_id = CBDphoto.objects.get(addr=img_name) ,pest_name = CBDpest.objects.get(user=current_user,pest_name=desc['pest_name']) ,pest_num = desc['pest_num'] ,crop_name = desc['crop_name'] ,pest_case = desc['pest_case'] ,pest_name2 = CBDpest.objects.get(user=current_user,pest_name=desc['pest_name']) ,equip_id= equip_id ,photo_time = photo_time) data = "0" except Exception as e: print("保错信息为:",e) data = "1" # 修改描述： elif req == "change_dsec": try: CBDphoto_desc.objects.filter(desc_user = current_user ,photo_id = CBDphoto.objects.get(addr=img_name) ).update(pest_num = desc['pest_num'] ,crop_name = desc['crop_name'] ,pest_case = desc['pest_case']) data = "0" except Exception as e: print("保错信息为:",e) data = "1" # 删除描述： elif req == "del_desc": try: CBDphoto_desc.objects.filter(desc_user = current_user ,photo_id = CBDphoto.objects.get(addr=img_name) ,pest_name = CBDpest.objects.get(user=current_user,pest_name=desc['pest_name']) ).delete() data = "0" except Exception as e: print("保错信息为:",e) data = "1" return HttpResponse(data) #测报灯害虫识别统计图 class cbd_pest_report_chart(View): def post(self,request): equip_id = request.POST.get('equip_id') name = request.POST.get('name') print('equip_id:',equip_id) sta1 = CBDphoto.objects.filter(equip_id=equip_id) pest_kind = [] pests = [] dat = [] for x in sta1: if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') dat.append({"nums":i_result[0],"test":i_result[1]}) if i_result[0] not in pest_kind: pest_kind.append(i_result[0]) #采集害虫种类 if pest_kind: for i in pest_kind: date = [] for x in dat: if x["nums"] == i: date.append(x["test"]) numbers = list(map(int, date)) nums = sum(numbers) pests.append({"name":insect_dict_new[i],"data":nums}) data = {"nums":pests} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #测报灯自动统计病虫害折线图 class cbd_pest_from_chart(View): def post(self,request): equip_id = request.POST.get('equip_id') tbegin = request.POST.get('tbegin') print("tbegin",tbegin) tend = request.POST.get('tend') print("tend",tend) pest = request.POST.get("pest") print('equip_id:',equip_id) start_date = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime('%Y-%m-%d') end_date = (datetime.datetime.now() + datetime.timedelta(days=1)).strftime('%Y-%m-%d') sta1 = CBDphoto.objects.filter(equip_id=equip_id,upl_time__range=(start_date, end_date)) sta3 = CBDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) if tbegin: sta1 = CBDphoto.objects.filter(equip_id=equip_id, upl_time__range=(tbegin, tend)) sta3 = CBDdata.objects.filter(equip_id=equip_id, upl_time__range=(tbegin, tend)) dat = [] cbd_data = [] pest_kind = [] pests = [] for x in sta1: if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') if i_result[0] not in pest_kind: pest_kind.append(i_result[0]) #采集害虫种类 if pest_kind: for i in pest_kind: st = {"name":insect_dict_new[i]} pests.append(st) for i in sta3: sta4 = {"at":eval(i.cbd_data)["at"],"ah":eval(i.cbd_data)["ah"],"upl_time":i.upl_time} cbd_data.append(sta4) if pest: for x in sta1: if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') if insect_dict_new[i_result[0]] == pest: sta2 = {"time":x.upl_time,"pest":insect_dict_new[i_result[0]],"pestnum":i_result[1]} dat.append(sta2) data = {"kind":pests,"cbd_data":cbd_data,"dat":dat} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #测报灯害虫图片识别 class cbd_pest_discern(View): def post (self,request): img_addr = request.POST.get('img_addr') print(img_addr) photo_obj = CBDphoto.objects.get(addr=img_addr) # url = 'http://60.166.14.184:9143/upload' url = 'http://60.166.14.184:9143/upload' imageFile = {'imageFile':('pic.jpg',open(img_addr,'rb'),'image/jpeg')} data = {'longitude':'118.279643','latitude':'31.221456'} print('data:',data) res = requests.post(url,data=data,files=imageFile) print("res:",res.text) try: resp = json.loads(res.text) except Exception as e: print(e) print("识别失败") data = "1" return HttpResponse(data) result_list = "code" nums = "404" date = [] try: if resp["returnResult"]["returnString"]: result = resp["returnResult"]["returnString"].split("#") print("result",result) for i in result: res = i.split(",") nums = res[1] #数量 results = res[0] #编号 result_list = insect_dict_new[res[0]] date.append({ "nums":nums,"result_list":result_list }) print("date",date) resp = resp["returnResult"]["returnImageUrl"] except Exception as e: print(e) data = {"image":resp, "result":date} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #测报灯下发命令 class cbd_wechat_mqtt_read(View): def post(self,request): uid = request.POST.get('username') imei = request.POST.get('imei') ret = request.POST.get("ret") print("uid",uid) print("imei",imei) if ret == "read": #下发查询 kind = request.POST.get('kind') print("kind",kind) print("验证成功") print("下发查询!") try: # 读取参数： if kind == "status" or kind == "data" or "paramconf": payload = {"cmd": "read", "ext": {"type": kind}} print("payload",payload) except Exception as e: print(e) data = api_code[1] data = json.dumps(data) print(data) return HttpResponse(data) elif ret == "set": #下发设置 print("下发设备设置!") try: ts = int(request.POST.get("ts")) # 定时模式 tt = int(request.POST.get("tt")) # 定时时长 # imgres = int(request.POST.get('imgres')) # 图片分辨率 st = int(request.POST.get('st')) # 开始时间 et = int(request.POST.get('et')) # 结束时间 collt = int(request.POST.get('collt')) # 落虫时间 htim = int(request.POST.get('htim')) # 加热时间 hst = int(request.POST.get('hst')) # 加热温度 tph = int(request.POST.get('tph')) # 加热仓温度上限 tpl = int(request.POST.get('tpl')) # 加热仓温度下限加热仓温度下限 datt = int(request.POST.get('datt')) # 数据上传时间间隔 shake_sec = int(request.POST.get('shake_sec')) # 震动时间间隔 print("定时模式ts:", ts) # print("图片分辨率imgres:", imgres) print("开始时间st:", st) print("结束时间et:", et) print("落虫时间collt:", collt) print("加热时间htim:", htim) print("加热温度hst:", hst) print("加热仓温度上限tph:", tph) print("加热仓温度下限tpl:", tpl) print("数据上传时间间隔datt:", datt) # 参数范围判断 if st not in range(0,25) or et not in range(0,25) or collt not in range(5,21) or htim not in range(5,21) \ or hst not in range(75,126) or tph not in range(40,71) or tpl not in range(-5,11) or datt not in range(5,61): data = api_code[3] data = json.dumps(data) print(data) return HttpResponse(data) if shake_sec != None: payload = {"cmd": "paramconf", "ext": {"ts": ts, "tt": tt, "st": st, "et": et, "collt": collt,"shake_sec":shake_sec, "htim": htim, "hst": hst, "tph": tph, "tpl": tpl, "datt": datt, "imgres": 0}} elif shake_sec == None: payload = {"cmd": "paramconf", "ext": {"ts": ts, "tt": tt, "st": st, "et": et, "collt": collt, "htim": htim, "hst": hst, "tph": tph, "tpl": tpl, "datt": datt, "imgres": 0}} print("payload",payload) except Exception as e: print(e) data = api_code[1] data = json.dumps(data) print(data) return HttpResponse(data) elif ret == "workmode": # 下发设备工作模式  节能（0），常规（1），加强（2） {"asleep":1,"common":0,"power":0} print("下发设置工作模块！") try: work_type = int(request.POST.get('type')) if work_type == 0: payload = {"cmd":"workmode","ext":{"asleep":1,"common":0,"power":0}} elif work_type == 1: payload = {"cmd":"workmode","ext":{"asleep":0,"common":1,"power":0}} elif work_type == 2: payload = {"cmd":"workmode","ext":{"asleep":0,"common":0,"power":1}} print("payload",payload) except Exception as e: print(e) data = api_code[1] data = json.dumps(data) print(data) return HttpResponse(data) elif ret == "sim": print("下发查询流量信息！") iccid = request.POST.get('iccid') resp = get_siminfo(iccid) print("查询流量信息为:",resp) return HttpResponse(resp) topic = "/yfkj/cbd/sub/"+imei cmd = {"topic": topic, "payload": json.dumps(payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) # #孢子仪设备详情接口 # class bzy_equip_details(View): # def post(self,request): # equip_id = request.POST.get("equip_id") # bzy_list = BZYstatus.objects.filter(equip_id=equip_id).first() # try: # bzy_data = eval(bzy_list.bzy_status) # imei = bzy_data["imei"] # iccid = bzy_data["iccid"] # upl_time = bzy_list.upl_time.strftime('%Y-%m-%d %H:%M:%S') # csq = bzy_data["csq"] #信号强度 # dver = bzy_data["dver"] #版本号 # v_bat = bzy_data["v_bat"] #电压 # is_online = bzy_list.is_online # if is_online == 0 : # is_online = "离线" # else: # is_online = "在线" # on_off = bzy_data["on_off"] # if on_off == 0: #设备开关 # on_off = "关闭" # else: # on_off = "开启" # bat_sta = bzy_data["bat_sta"] # if bat_sta == 0: #电池状态 # bat_sta = "正常" # else: # bat_sta = "电量过低" # usb_sta = bzy_data["usb_sta"] # if usb_sta == 0: #摄像头状态 # usb_sta = "正常" # else: # usb_sta = "异常" # pre_temp = bzy_data["pre_temp"] #保温仓当前温度 # lat = bzy_data["lat"] # lng = bzy_data["lng"] # staytime = bzy_data["staytime"] #培养时间 # cul_time = bzy_data["cul_time"] # print(cul_time) # data = {"imei":imei,"upl_time":upl_time,"is_online":is_online,"csq":csq,"dver":dver, # "v_bat":v_bat,"on_off":on_off,"bat_sta":bat_sta,"usb_sta":usb_sta,"pre_temp":pre_temp, # "lat":lat,"lng":lng,"staytime":staytime,"iccid":iccid} # except Exception as e: # print("报错信息为:",e) # data = {"code":"1"} # data = json.dumps(data) # return HttpResponse(data) #孢子仪报表管理详情 class bzy_equip_report(View): def post (self,request): equip_id = request.POST.get("equip_id") req = request.POST.get("req") print("req",req) bzy_list = BZYdata.objects.filter(equip_id=equip_id) if req == "new_time": bzy_list = bzy_list[:1] elif req == "time": bzy_id = request.POST.get("id") bzy_list = bzy_list.filter(equip_id=equip_id,id=bzy_id) elif req == "times": start_time = request.POST.get('start_time') end_time = request.POST.get('end_time') begindate = re.findall(r"\d+\.?\d*", start_time) enddate = re.findall(r"\d+\.?\d*", end_time) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2])) bzy_list = bzy_list.filter(equip_id=equip_id,upl_time__range=(start_date,end_date)) else: return HttpResponse("参数错误") date = [] #设备状态信息 data = [] #设备数据信息 bzy_status = BZYstatus.objects.filter(equip_id=equip_id) for x in bzy_status: date.append( { "glass":x.glass, "liquid":x.liquid, } ) try: for i in bzy_list: bzy_data = eval(i.bzy_data) imei= bzy_data["imei"] upl_time = i.upl_time.strftime('%Y-%m-%d %H:%M:%S') # equip_location = i.netconf on_off = bzy_data["on_off"] #设备开关 if on_off == 0 : on_off = "关闭" else: on_off = "开启" bat_sta = bzy_data["bat_sta"] #电池状态 if bat_sta == 0: bat_sta = "正常" else: bat_sta = "电量过低" usb_sta = bzy_data["usb_sta"] #摄像头状态 if usb_sta == 0: usb_sta = "正常" else: usb_sta = "异常" rps = bzy_data['rps'] #雨控 if rps == 0: rps = "正常" else: rps = "雨控" v_bat = bzy_data["v_bat"] #电压 alti = bzy_data["alti"] #海拔高度 csq = bzy_data['csq'] #信号强度 set_temp = bzy_data["set_temp"] #保温仓设定温度 dver = bzy_data["dver"] #版本号 pre_temp = bzy_data["pre_temp"] #保温仓当前温度 ah = bzy_data["ah"] at = bzy_data['at'] lng = bzy_data['lng'] lat = bzy_data['lat'] staytime = bzy_data['staytime'] data.append({"imei":imei,"time":upl_time,"on_off":on_off,"lng":lng,"lat":lat,"staytime":staytime, "bat_sta":bat_sta,"usb_sta":usb_sta,"rps":rps,"v_bat":v_bat,"alti":alti, "csq":csq,"set_temp":set_temp,"dver":dver,'ah':ah,"at":at,"pre_temp":pre_temp,}) except: data = [] # print("报错信息为:",e) # data = {"code":"1"} data = {"data":data,"date":date} data = json.dumps(data) return HttpResponse(data) #孢子仪图片列表 class bzy_photo_list(View): def get(self,request): equip_id = request.GET.get("equip_id") page = int(request.GET.get("page")) bzy_photo = BZYphoto.objects.filter(equip_id=equip_id).values() data =[] for i in bzy_photo: data.append({"addr":i['addr'],"describe":i["describe"],"upl_time":i["upl_time"].strftime('%Y-%m-%d %H:%M:%S')}) nums = len(data) dat = data[(10*(page-1)):(page*10)] data = {"dat":dat,"nums":nums} data = json.dumps(data) return HttpResponse(data) def post(self,request): equip_id = request.POST.get("equip_id") photo = request.POST.get("photo") if os.path.exists(photo) == True: #删除图片路经 os.remove(photo) try: BZYphoto.objects.get(addr=photo,equip_id=equip_id).delete() data = 1 except Exception as e: print(e) data = 0 else: try: BZYphoto.objects.get(addr=photo,equip_id=equip_id).delete() data = 1 except Exception as e: print(e) data = 0 return HttpResponse(data) #孢子仪图片描述接口 class bzy_photo_desc(View): def get(self,request): addr = request.GET.get("addr") try: obj = BZYphoto.objects.get(addr=addr) data = obj.describe except Exception as e: print(e) data = "" data = {"code":data} # ensure_ascii=False 去除中文转义 data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) def post(self, request): img_name = request.POST.get('addr') print('img_name:',img_name) desc = request.POST.get('describe') print("desc：",desc) try: obj = BZYphoto.objects.get(addr=img_name) obj.describe = desc obj.save() data = "0" except Exception as e: print(e) data = "1" return HttpResponse(data) #孢子仪折线图 class bzy_from_chart(View): def post(self,request): req = request.POST.get('req') equip_id = request.POST.get('equip_id') if req == "data": # 获取当前日期：(这个月时间) now_time = datetime.datetime.now() sta1 = BZYdata.objects.filter(equip_id=equip_id,upl_time__month=now_time.month,upl_time__year=now_time.year) elif req == "filter": #获取指定日期 f_tbegin = request.POST.get('begin') f_tend = request.POST.get('end') begindate = re.findall(r"\d+\.?\d*", f_tbegin) enddate = re.findall(r"\d+\.?\d*", f_tend) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1] ), int(enddate[2])) sta1 = BZYdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) data = [] for x in sta1: pre_temp = eval(x.bzy_data)['pre_temp'] data.append({"pre_temp": pre_temp, "ah": eval(x.bzy_data)['ah'], "at": eval(x.bzy_data)['at'], "tim": x.upl_time}) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #孢子仪配置信息接口 class bzy_equip_paramconf(View): def post(self, request): equip_id = request.POST.get('id') print("请求数据的设备id：", equip_id) # 最新数据: status sta = BZYstatus.objects.filter(equip_id__equip_id=equip_id) for x in sta: new_sta = {"bzy_status":eval(x.bzy_status), "upl_time": x.upl_time, "equip_name": x.equip_id.equip_name, "glass": x.glass, "liquid":x.liquid, "is_online": x.is_online, "off_time": x.off_time} data = json.dumps(new_sta, cls=CJSONEncoder, indent=4) print("data:",data) return HttpResponse(data) # 孢子仪通信接口： class bzy_wechat_mqtt_read(ListView): def post(self, request): uid = request.POST.get('username') imei = request.POST.get('imei') ret = request.POST.get('ret') print("ret:", ret) print("username",uid) print("imei",imei) if ret == "set": wind_sw = int(request.POST.get('wind')) # 风机开关 coll_time = request.POST.get('coll_time') # 采集孢子时间段 drop_time = int(request.POST.get('drop')) # 采集孢子时间段 set_temp = int(request.POST.get('stemp')) # 保温仓设定温度 # imgres = int(request.POST.get('imgres')) # 图片分辨率 datt = int(request.POST.get('takt')) # 数据上传时间间隔 try: cul_time = int(request.POST.get('culTime')) # 设置培养时间 except: cul_time = 12 print("设备ID:", imei) print("风机开关:", wind_sw) print("采集孢子时间段:", coll_time) print("保温仓设定温度:", set_temp) print("培养时间:", cul_time) print("上传时间间隔:",datt) coll_time = eval(coll_time) print("采集shijain:", coll_time) topic = "/yfkj/bzy/s2c/"+ imei # [1:-1] print("topic:", topic) payload = {"cmd": "paramconf","ext": {"wind_sw": wind_sw,"coll_time": coll_time,"set_temp": set_temp,"imgres": 7,"drop_time": drop_time,"datt": datt,"cul_time":cul_time}} cmd = {"topic": topic, "payload": json.dumps(payload), 'qos': 1} print(json.dumps(payload, indent=1)) elif ret == "read": print("下发查询！") payload = {"cmd": "read","type": "status"} topic = "/yfkj/bzy/s2c/"+ imei cmd = {"topic": topic, "payload": json.dumps(payload), 'qos': 1} print(json.dumps(payload, indent=1)) elif ret == "ctrl": print("下发控制！") print("imei",imei) topic = "/yfkj/bzy/s2c/"+ imei # 读取参数： cmd = request.POST.get('cmd') print("cmd",cmd) if cmd == "update" or cmd == "reboot" or cmd == "poweroff" or cmd == "poweron" or cmd == "coldoff" or cmd == "coldon": payload = {"cmd":cmd} elif cmd == "ctrl": ctrl_type = request.POST.get('type') print("type",ctrl_type) if ctrl_type == "takephoto": payload = {"cmd": cmd, "ext": {"type": ctrl_type}} cmd = {"topic": topic, "payload": json.dumps(payload), 'qos': 1} print(json.dumps(payload, indent=1)) # 此项修改载玻片和培养液更换时间，只存数据库 不做下发处理！！！ elif ret == "glass": # 获取载玻片更换时间 glass = request.POST.get('glass') print("载玻片更换时间:", glass) sta = BZYstatus.objects.get(equip_id__equip_id=imei) if glass != "": # temporary临时变量 temporary = sta.glass sta.glass = temporary + "#" + glass # 只保存最近五次的更换时间 if len(sta.glass)>55: sta.glass = sta.glass[11:] sta.save() print("载玻片更换时间保存成功") data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) elif ret == "liquid": # 获取培养液更换时间 liquid = request.POST.get('liquid') print("培养液更换时间:", liquid) sta = BZYstatus.objects.get(equip_id__equip_id=imei) if liquid != "": # temporary临时变量 temporary_1 = sta.liquid sta.liquid = temporary_1 + "#" + liquid # 只保存最近五次的更换时间 if len(sta.liquid)>55: sta.liquid = sta.liquid[11:] sta.save() print("培养液更换时间保存成功") data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) # 查询sim卡信息 elif ret == "sim": iccid = request.POST.get('iccid') resp = get_siminfo(iccid) print("查询流量信息为:",resp) return HttpResponse(resp) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) if res.status_code == 200: data = api_code[0] data = json.dumps(data) print(data) return HttpResponse(data) else: data = api_code[4] data = json.dumps(data) print(data) return HttpResponse(data) #性诱设备列表(依科曼) class xy_equip_list(View): def get (self,request): page = int(request.GET.get("page")) user_name = request.GET.get("username") current_user = MyUser.objects.get(username=user_name) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # __username print("---不是管理员") xy_list = Trapstatus.objects.filter(equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") xy_list = Trapstatus.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") xy_list = Trapstatus.objects.all() data = [] for x in xy_list: data.append({"addr": x.addr, "tem": x.tem,"equip_id":x.equip_id.equip_id, "hum": x.hum, "pest": x.pest, "equip_name": x.equip_id.equip_name, "pestnum": x.pestnum, "upl_time": x.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) num = xy_list.count() dat = data[(10*(page-1)):(page*10)] data = {'dat': dat, 'num': num} data = json.dumps(data) return HttpResponse(data) def post(self,request): ret = request.POST.get("ret") equip_id = request.POST.get("equip_id") page = int(request.POST.get("page")) data = [] if ret == "filter": #设备信息 xy_list = Trapstatus.objects.filter(equip_id=equip_id) elif ret == "record": #历史记录 xy_list = Trapdata.objects.filter(equip_id=equip_id) for x in xy_list: data.append({"addr": x.addr, "tem": x.tem,"equip_id":x.equip_id.equip_id, "hum": x.hum, "pest": x.pest, "equip_name": x.equip_id.equip_name, "pestnum": x.pestnum, "upl_time": x.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) num = xy_list.count() dat = data[(10*(page-1)):(page*10)] data = {'dat': dat, 'num': num} data = json.dumps(data) return HttpResponse(data) #性诱图片页面 class xy_photo_list(View): def post(self,request): ret = request.POST.get("ret") equip_id = request.POST.get("equip_id") page = int(request.POST.get("page",1)) print(equip_id) data = [] if ret == "photo": xy_list = Trapphoto.objects.filter(equip_id=equip_id) if xy_list: for x in xy_list: data.append({"upl_time":x.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"addr":x.addr}) data = data[(10*(page-1)):(page*10)] elif ret == "chart": start_time = request.POST.get('start_time') end_time = request.POST.get('end_time') if start_time: xy_list = Trapdata.objects.filter(equip_id=equip_id, upl_time__range=(start_time,end_time)) else: start_date = (datetime.datetime.now() - datetime.timedelta(days=2)).strftime('%Y-%m-%d') end_date = (datetime.datetime.now() + datetime.timedelta(days=1) ).strftime('%Y-%m-%d') xy_list = Trapdata.objects.filter(equip_id=equip_id,upl_time__range=(start_date,end_date)) if xy_list: for i in xy_list: data.append({"pest":i.pest,"pestnum":i.pestnum,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"tem":i.tem,"hum":i.hum}) num = len(xy_list) print("num",num) data = {'dat': data, 'num': num} data = json.dumps(data) return HttpResponse(data) #气象站状态数据 class qxz_status_base(View): def post(self,request): equip_id = request.POST.get("equip_id") data = [] qxz_base = QXZ_Base_Info.objects.filter(equip_id=equip_id) try: qxz_list = QXZstatus_New.objects.get(equip_id=equip_id).is_online except: return HttpResponse("0") if qxz_base: for x in qxz_base: data.append({ "is_online": qxz_list, "volt": x.volt, "rssi": x.rssi, "equip_id": x.equip_id.equip_id }) else: data.append({ "is_online": qxz_list, "volt": "", "rssi": "", "equip_id": equip_id }) data = json.dumps(data) return HttpResponse(data) #气象站报表折线图(时间段筛选) class qxz_line_chart(View): def get(self,request): imei = request.GET.get('imei') equip_id = request.GET.get('equip_id') qxz_list = QXZdata_New.objects.get(equip_id=imei,id=equip_id) data = [qxz_list.e1,qxz_list.e2,qxz_list.e3,qxz_list.e4,qxz_list.e5,qxz_list.e6,qxz_list.e7,qxz_list.e8,qxz_list.e9,qxz_list.e10, qxz_list.e11,qxz_list.e12,qxz_list.e13,qxz_list.e14, qxz_list.e15,qxz_list.e16,qxz_list.e17,qxz_list.e18, qxz_list.e19,qxz_list.e20,qxz_list.e21,qxz_list.e22, qxz_list.e23,qxz_list.e24,qxz_list.e25,qxz_list.e26, qxz_list.e27,qxz_list.e28,qxz_list.e29,qxz_list.e30] test = [i for i in data if i != ''] sta = [] try: for i in test: qxz = i.split("#") qw = qxz_dict[qxz[1]] qxz_num = [qxz[2],qxz[0],qw] sta.append(qxz_num) except Exception as e : print(e) sta2 = {"data":sta,"upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')} data = json.dumps(sta2) return HttpResponse(data) def post(self,request): equip_id = request.POST.get("equip_id") start_time = request.POST.get("start_time") end_time = request.POST.get("end_time") start_date = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime('%Y-%m-%d') end_date = (datetime.datetime.now() + datetime.timedelta(days=1) ).strftime('%Y-%m-%d') print("equip_id",equip_id) print("start_time",start_time) print("end_time",end_time) qxz_list = QXZdata_New.objects.filter( equip_id=equip_id, upl_time__range=(start_date,end_date)) if start_time: qxz_list = QXZdata_New.objects.filter( equip_id=equip_id, upl_time__range=(start_time,end_time)) data = [] for i in qxz_list: data.append({"dat":[i.e1,i.e2,i.e3,i.e4,i.e5, i.e6,i.e7,i.e8,i.e9,i.e10, i.e11,i.e12,i.e13,i.e14, i.e15,i.e16,i.e17,i.e18, i.e19,i.e20,i.e21,i.e22, i.e23,i.e24,i.e25,i.e26, i.e27,i.e28,i.e29,i.e30], "time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) sta2 = [] # print(data) for x in data: sta = [] test = [i for i in x["dat"] if i !=''] try: for i in test: qxz = i.split("#") qxz_num = {"name":qxz[2],"num":float(qxz[0])} sta.append(qxz_num) except Exception as e : print(e) sta2.append({"data":sta,"time":x["time"]}) try: conf = [] qxz_num = [] x = QXZ_Conf.objects.get(equip_id=equip_id) conf.append([x.e1,x.e2,x.e3,x.e4,x.e5, x.e6,x.e7,x.e8,x.e9,x.e10, x.e11,x.e12,x.e13,x.e14, x.e15,x.e16,x.e17,x.e18, x.e19,x.e20,x.e21,x.e22, x.e23,x.e24,x.e25,x.e26, x.e27,x.e28,x.e29,x.e30]) conf_list = [i for i in conf[0] if i !='' ] for i in conf_list: qxz_conf = i.split("#") qxz_list = {"name":qxz_conf[0],"num":qxz_conf[1]} qxz_num.append(qxz_list) except: qxz_num = [] data = {"data":sta2,"conf":qxz_num} data = json.dumps(data) print("data",data) return HttpResponse(data) #气象站二十四小时最新数据 class qxz_new_data(View): def post (self,request): qxz_dict_1 = copy.deepcopy(qxz_dict) start_date = (datetime.datetime.now() - datetime.timedelta(days=2)).strftime('%Y-%m-%d') end_date = (datetime.datetime.now() + datetime.timedelta(days=1) ).strftime('%Y-%m-%d') print("start_date:", start_date) print("end_date:", end_date) equip_id = request.POST.get('equip_id') sta1 = QXZdata_New.objects.filter(equip_id=equip_id, upl_time__range=(start_date,end_date)).values() e1 = [] e1_time = [] e2 = [] e2_time = [] e3 = [] e3_time = [] e4 = [] e4_time = [] e5 = [] e5_time = [] e6 = [] e6_time = [] e7 = [] e7_time = [] e8 = [] e8_time = [] e9 = [] e9_time = [] e10 = [] e10_time = [] e11 = [] e11_time = [] e12 = [] e12_time = [] e13 = [] e13_time = [] e14 = [] e14_time = [] e15 = [] e15_time = [] e16 = [] e16_time = [] e17 = [] e17_time = [] e18 = [] e18_time = [] e19 = [] e19_time = [] e20 = [] e20_time = [] e21 = [] e21_time = [] e22 = [] e22_time = [] e23 = [] e23_time = [] e24 = [] e24_time = [] e25 = [] e25_time = [] e26 = [] e26_time = [] e27 = [] e27_time = [] e28 = [] e28_time = [] e29 = [] e29_time = [] e30 = [] e30_time = [] for i in sta1: if i['e1'] != "": e1.append(i['e1'].split('#')[0]) e1_time.append(i['upl_time']) if i['e2'] != "": e2.append(i['e2'].split('#')[0]) e2_time.append(i['upl_time']) if i['e3'] != "": e3.append(i['e3'].split('#')[0]) e3_time.append(i['upl_time']) if i['e4'] != "": e4.append(i['e4'].split('#')[0]) e4_time.append(i['upl_time']) if i['e5'] != "": e5.append(i['e5'].split('#')[0]) e5_time.append(i['upl_time']) if i['e6'] != "": e6.append(i['e6'].split('#')[0]) e6_time.append(i['upl_time']) if i['e7'] != "": e7.append(i['e7'].split('#')[0]) e7_time.append(i['upl_time']) if i['e8'] != "": e8.append(i['e8'].split('#')[0]) e8_time.append(i['upl_time']) if i['e9'] != "": e9.append(i['e9'].split('#')[0]) e9_time.append(i['upl_time']) if i['e10'] != "": e10.append(i['e10'].split('#')[0]) e10_time.append(i['upl_time']) if i['e11'] != "": e11.append(i['e11'].split('#')[0]) e11_time.append(i['upl_time']) if i['e12'] != "": e12.append(i['e12'].split('#')[0]) e12_time.append(i['upl_time']) if i['e13'] != "": e13.append(i['e13'].split('#')[0]) e13_time.append(i['upl_time']) if i['e14'] != "": e14.append(i['e14'].split('#')[0]) e14_time.append(i['upl_time']) if i['e15'] != "": e15.append(i['e15'].split('#')[0]) e15_time.append(i['upl_time']) if i['e16'] != "": e16.append(i['e16'].split('#')[0]) e16_time.append(i['upl_time']) if i['e17'] != "": e17.append(i['e17'].split('#')[0]) e17_time.append(i['upl_time']) if i['e18'] != "": e18.append(i['e18'].split('#')[0]) e18_time.append(i['upl_time']) if i['e19'] != "": e19.append(i['e19'].split('#')[0]) e19_time.append(i['upl_time']) if i['e20'] != "": e20.append(i['e20'].split('#')[0]) e20_time.append(i['upl_time']) if i['e21'] != "": e21.append(i['e21'].split('#')[0]) e21_time.append(i['upl_time']) if i['e22'] != "": e22.append(i['e22'].split('#')[0]) e22_time.append(i['upl_time']) if i['e23'] != "": e23.append(i['e23'].split('#')[0]) e23_time.append(i['upl_time']) if i['e24'] != "": e12.append(i['e12'].split('#')[0]) e12_time.append(i['upl_time']) if i['e25'] != "": e25.append(i['e25'].split('#')[0]) e25_time.append(i['upl_time']) if i['e26'] != "": e26.append(i['e26'].split('#')[0]) e26_time.append(i['upl_time']) if i['e27'] != "": e27.append(i['e27'].split('#')[0]) e27_time.append(i['upl_time']) if i['e28'] != "": e28.append(i['e28'].split('#')[0]) e28_time.append(i['upl_time']) if i['e29'] != "": e29.append(i['e29'].split('#')[0]) e29_time.append(i['upl_time']) if i['e30'] != "": e30.append(i['e30'].split('#')[0]) e30_time.append(i['upl_time']) data = [] try: if e1 != []: data.append({"max":max(e1),"maxtime":e1_time[e1.index(max(e1))],"min":min(e1),"mintime":e1_time[e1.index(min(e1))],"enum":qxz_dict_1[i['e1'].split('#')[1]],"ekey":i['e1'].split('#')[2]}) if e2 != []: data.append({"max":max(e2),"maxtime":e2_time[e2.index(max(e2))],"min":min(e2),"mintime":e2_time[e2.index(min(e2))],"enum":qxz_dict_1[i['e2'].split('#')[1]],"ekey":i['e2'].split('#')[2]}) if e3 != []: data.append({"max":max(e3),"maxtime":e3_time[e3.index(max(e3))],"min":min(e3),"mintime":e3_time[e3.index(min(e3))],"enum":qxz_dict_1[i['e3'].split('#')[1]],"ekey":i['e3'].split('#')[2]}) if e4 != []: data.append({"max":max(e4),"maxtime":e4_time[e4.index(max(e4))],"min":min(e4),"mintime":e4_time[e4.index(min(e4))],"enum":qxz_dict_1[i['e4'].split('#')[1]],"ekey":i['e4'].split('#')[2]}) if e5 != []: data.append({"max":max(e5),"maxtime":e5_time[e5.index(max(e5))],"min":min(e5),"mintime":e5_time[e5.index(min(e5))],"enum":qxz_dict_1[i['e5'].split('#')[1]],"ekey":i['e5'].split('#')[2]}) if e6 != []: data.append({"max":max(e6),"maxtime":e6_time[e6.index(max(e6))],"min":min(e6),"mintime":e6_time[e6.index(min(e6))],"enum":qxz_dict_1[i['e6'].split('#')[1]],"ekey":i['e6'].split('#')[2]}) if e7 != []: data.append({"max":max(e7),"maxtime":e7_time[e7.index(max(e7))],"min":min(e7),"mintime":e7_time[e7.index(min(e7))],"enum":qxz_dict_1[i['e7'].split('#')[1]],"ekey":i['e7'].split('#')[2]}) if e8 != []: data.append({"max":max(e8),"maxtime":e8_time[e8.index(max(e8))],"min":min(e8),"mintime":e8_time[e8.index(min(e8))],"enum":qxz_dict_1[i['e8'].split('#')[1]],"ekey":i['e8'].split('#')[2]}) if e9 != []: data.append({"max":max(e9),"maxtime":e9_time[e9.index(max(e9))],"min":min(e9),"mintime":e9_time[e9.index(min(e9))],"enum":qxz_dict_1[i['e9'].split('#')[1]],"ekey":i['e9'].split('#')[2]}) if e10 != []: data.append({"max":max(e10),"maxtime":e10_time[e10.index(max(e10))],"min":min(e10),"mintime":e10_time[e10.index(min(e10))],"enum":qxz_dict_1[i['e10'].split('#')[1]],"ekey":i['e10'].split('#')[2]}) if e11 != []: data.append({"max":max(e11),"maxtime":e11_time[e11.index(max(e11))],"min":min(e11),"mintime":e11_time[e11.index(min(e11))],"enum":qxz_dict_1[i['e11'].split('#')[1]],"ekey":i['e11'].split('#')[2]}) if e12 != []: data.append({"max":max(e12),"maxtime":e12_time[e12.index(max(e12))],"min":min(e12),"mintime":e12_time[e12.index(min(e12))],"enum":qxz_dict_1[i['e12'].split('#')[1]],"ekey":i['e12'].split('#')[2]}) if e13 != []: data.append({"max":max(e13),"maxtime":e13_time[e13.index(max(e13))],"min":min(e13),"mintime":e13_time[e13.index(min(e13))],"enum":qxz_dict_1[i['e13'].split('#')[1]],"ekey":i['e13'].split('#')[2]}) if e14 != []: data.append({"max":max(e14),"maxtime":e14_time[e14.index(max(e14))],"min":min(e14),"mintime":e14_time[e14.index(min(e14))],"enum":qxz_dict_1[i['e14'].split('#')[1]],"ekey":i['e14'].split('#')[2]}) if e15 != []: data.append({"max":max(e15),"maxtime":e15_time[e15.index(max(e15))],"min":min(e15),"mintime":e15_time[e15.index(min(e15))],"enum":qxz_dict_1[i['e15'].split('#')[1]],"ekey":i['e15'].split('#')[2]}) if e16 != []: data.append({"max":max(e16),"maxtime":e16_time[e16.index(max(e16))],"min":min(e16),"mintime":e16_time[e16.index(min(e16))],"enum":qxz_dict_1[i['e16'].split('#')[1]],"ekey":i['e16'].split('#')[2]}) if e17 != []: data.append({"max":max(e17),"maxtime":e17_time[e17.index(max(e17))],"min":min(e17),"mintime":e17_time[e17.index(min(e17))],"enum":qxz_dict_1[i['e17'].split('#')[1]],"ekey":i['e17'].split('#')[2]}) if e18 != []: data.append({"max":max(e18),"maxtime":e18_time[e18.index(max(e18))],"min":min(e18),"mintime":e18_time[e18.index(min(e18))],"enum":qxz_dict_1[i['e18'].split('#')[1]],"ekey":i['e18'].split('#')[2]}) if e19 != []: data.append({"max":max(e19),"maxtime":e19_time[e19.index(max(e19))],"min":min(e19),"mintime":e19_time[e19.index(min(e19))],"enum":qxz_dict_1[i['e19'].split('#')[1]],"ekey":i['e19'].split('#')[2]}) if e20 != []: data.append({"max":max(e20),"maxtime":e20_time[e20.index(max(e20))],"min":min(e20),"mintime":e20_time[e20.index(min(e20))],"enum":qxz_dict_1[i['e20'].split('#')[1]],"ekey":i['e20'].split('#')[2]}) if e21 != []: data.append({"max":max(e21),"maxtime":e21_time[e21.index(max(e21))],"min":min(e21),"mintime":e21_time[e21.index(min(e21))],"enum":qxz_dict_1[i['e21'].split('#')[1]],"ekey":i['e21'].split('#')[2]}) if e22 != []: data.append({"max":max(e22),"maxtime":e22_time[e22.index(max(e22))],"min":min(e22),"mintime":e22_time[e22.index(min(e22))],"enum":qxz_dict_1[i['e22'].split('#')[1]],"ekey":i['e22'].split('#')[2]}) if e23 != []: data.append({"max":max(e23),"maxtime":e23_time[e23.index(max(e23))],"min":min(e23),"mintime":e23_time[e23.index(min(e23))],"enum":qxz_dict_1[i['e23'].split('#')[1]],"ekey":i['e23'].split('#')[2]}) if e24 != []: data.append({"max":max(e24),"maxtime":e24_time[e24.index(max(e24))],"min":min(e24),"mintime":e24_time[e24.index(min(e24))],"enum":qxz_dict_1[i['e24'].split('#')[1]],"ekey":i['e24'].split('#')[2]}) if e25 != []: data.append({"max":max(e25),"maxtime":e25_time[e25.index(max(e25))],"min":min(e25),"mintime":e25_time[e25.index(min(e25))],"enum":qxz_dict_1[i['e25'].split('#')[1]],"ekey":i['e25'].split('#')[2]}) if e26 != []: data.append({"max":max(e26),"maxtime":e26_time[e26.index(max(e26))],"min":min(e26),"mintime":e26_time[e26.index(min(e26))],"enum":qxz_dict_1[i['e26'].split('#')[1]],"ekey":i['e26'].split('#')[2]}) if e27 != []: data.append({"max":max(e27),"maxtime":e27_time[e27.index(max(e27))],"min":min(e27),"mintime":e27_time[e27.index(min(e27))],"enum":qxz_dict_1[i['e27'].split('#')[1]],"ekey":i['e27'].split('#')[2]}) if e28 != []: data.append({"max":max(e28),"maxtime":e28_time[e28.index(max(e28))],"min":min(e28),"mintime":e28_time[e28.index(min(e28))],"enum":qxz_dict_1[i['e28'].split('#')[1]],"ekey":i['e28'].split('#')[2]}) if e29 != []: data.append({"max":max(e29),"maxtime":e29_time[e29.index(max(e29))],"min":min(e29),"mintime":e29_time[e29.index(min(e29))],"enum":qxz_dict_1[i['e29'].split('#')[1]],"ekey":i['e29'].split('#')[2]}) if e30 != []: data.append({"max":max(e30),"maxtime":e30_time[e30.index(max(e30))],"min":min(e30),"mintime":e30_time[e30.index(min(e30))],"enum":qxz_dict_1[i['e30'].split('#')[1]],"ekey":i['e30'].split('#')[2]}) except Exception as e: print("报错信息为:",e) dat = json.dumps(data,cls=CJSONEncoder) return HttpResponse(dat) #气象站开关； class qxz_wechat_switch(View): def get(self,request): equip_id = request.GET.get("equip_id") qxz_switch_list = QXZswitchstatus.objects.get(equip_id=equip_id) qxz_switch_name_list = QXZswitchdata.objects.get(equip_id=equip_id) # print(type(qxz_switch_list.qxz_switch)) data_list = eval(qxz_switch_list.qxz_switch) data_name_list = eval(qxz_switch_name_list.qxz_switch_data) dat = [] da = [] name_list = [] if data_list: for i in data_list: da.append(i["status"]) dat.append(i['JK']) if data_name_list: for i in data_name_list: name_list.append(i["name"]) data = {"status":da,"JK":dat,"name":name_list} data = json.dumps(data) return HttpResponse(data) def post(self,request): equip_id = request.POST.get('equip_id') JK = request.POST.get('JK') sw_name = request.POST.get('sw_name') try: switch_obj = QXZswitchdata.objects.get(equip_id=equip_id) except: return HttpResponse("1") sw_name_list = eval(switch_obj.qxz_switch_data) for i in sw_name_list: if i["JK"] == int(JK): i["name"] = sw_name print(sw_name_list) try: switch_obj.qxz_switch_data = sw_name_list switch_obj.save() except: return HttpResponse("1") data = "0" return HttpResponse(data) # 气象站下发接口 class qxz_wechat_mqtt(ListView): def get(self,request): pass def post(self,request): req = request.POST.get('req') imei = request.POST.get('imei') topic = "/yfkj/qxz/sub/"+imei if req == "read": payload = {"ext":{"type":"status"},"cmd":"read"} elif req == "set": way = int(request.POST.get('way')) switch = int(request.POST.get('switch')) payload = {"cmd":"control","ext":{"JK":way,"status":switch}} elif req == "conf": payload = {"ext":{"type":"jkStatus"},"cmd":"read"} cmd = {"topic":topic,"payload":json.dumps(payload),'qos':0} res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) if res.status_code == 200: data = "0" return HttpResponse(data) else: data = "1" return HttpResponse(data) #监控设备列表页面 class jk_wechat_list(View): def get(self,request): equip_id = request.GET.get("equip_id") user_name = request.GET.get("username") current_user = MyUser.objects.get(username=user_name) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: equip_list = Equip.objects.filter(equip_type=6, equip_user=current_user,equip_id=equip_id) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: equip_list = Equip.objects.filter(equip_type=6, equip_agency=current_user.user_agency,equip_id=equip_id) else: equip_list = Equip.objects.filter(equip_type=6,equip_id=equip_id) data = [] for x in equip_list: data.append({"equip_name":x.equip_name, "equip_id":x.equip_id}) data = json.dumps(data) return HttpResponse(data) def post(self,request): user_name = request.POST.get("username") current_user = MyUser.objects.get(username=user_name) page = int(request.POST.get('page')) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: equip_list = Equip.objects.filter(equip_type=6, equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # 代理商 equip_list = Equip.objects.filter(equip_type=6, equip_agency=current_user.user_agency) else: equip_list = Equip.objects.filter(equip_type=6) data = [] jk_token = JKtoken.objects.get(id=2) for x in equip_list: data.append({"equip_name":x.equip_name, "equip_id":x.equip_id + ":1","equip_token":jk_token.token}) nums = len(data) ids = data[(10*(page-1)):(page*10)] data = {'data': data, 'nums': nums} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 获取监控播放地址视图： class jk_equip_list(View): def post(self, request): equip_id = request.POST.get('equip_id') x = JKdata.objects.get(equip_id_id=equip_id) print(x.id) live_list = [] # 用token和设备id获取直播地址 live_url = 'https://open.ys7.com/api/lapp/live/address/get' live_data = {"accessToken":x.jk_token, "source":"%s:1"%x.equip_id} print("=================live_data:",live_data) live_res = requests.post(live_url,data=live_data) # print("-------------------------------:",type(live_res.text)) live_res = eval(live_res.text) print("live_res:",live_res) # 如果返回200 则返回直播地址 if live_res['code'] == "200": print("token获取成功") live_list.append(live_res) # 如果返回其他 则调用获取token之后重新获取直播地址并返回 else: print("token过期重新获取") token_url = 'https://open.ys7.com/api/lapp/token/get' token_data = {"appKey":"e8ec0d52b4b14628a3daf4b88cbcca2a", "appSecret":"d4565abea1cd0b90b59917111dcb37bd"} token_res = requests.post(token_url,data=token_data) print("token_res1:",token_res.text) token_res = eval(token_res.text) if token_res["code"] == "200": token_res["data"]["accessToken"] x.jk_token = token_res["data"]["accessToken"] x.upl_time = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time())) x.save() token = x.jk_token print("-----------------token保存成功") live_url = 'https://open.ys7.com/api/lapp/live/address/get' live_data = {"accessToken":x.jk_token, "source":"%s:1"%x.equip_id} live_res = requests.post(live_url,data=live_data) live_res = eval(live_res.text) print("live_res2:",live_res) live_list.append(live_res) data = live_list print("-----------============data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #监控图片列表 class jk_wechat_img(View): def post(self, request): ret = request.POST.get('ret') if ret == "del": imei = request.POST.get('id') img = JKphoto.objects.filter(id=imei) if img: img.delete() # jk_photo = request.POST.get('jk_photo') # if os.path.exists(img.addr) == True: # # 删除图片文件 # os.remove(img.addr) data = {"code":200} else: data = {"code":400} data = json.dumps(data) return HttpResponse(data) else: # 获得当前页： page = int(request.POST.get('page')) print("page:", page) # 从数据库中取出照片在服务器存放路径： imei = request.POST.get('equip_id') img = JKphoto.objects.filter(equip_id=imei) nums = img.count() img = img[(10*(page-1)):(page*10)] equip_name = Equip.objects.get(equip_id=imei) # 当前用户：返回用户，前端判断是否显示删除图片按钮 current_user = request.session.get('username') print("current_user:", current_user) img_dat = [{"upl_time": x.upl_time, "addr": x.addr}for x in img] dat = {'img':img_dat, 'nums':nums, 'equip_name':equip_name.equip_name, 'equip_id':imei, 'id':equip_name.id } data = json.dumps(dat, cls=CJSONEncoder, indent=4) print("data:",data) return HttpResponse(data) #诱捕器设备列表 class ybq_equip_list(View): def post(self, request): page = int(request.POST.get('page')) print("page:", page) equip_name = request.POST.get("equip_name") print("equip_name:", equip_name) equip_id = request.POST.get("equip_id") print("equip_id:", equip_id) # 读取当前用户： current_user = request.POST.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: # __username print("---不是管理员") sta1 = YBQstatus.objects.filter(equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = YBQstatus.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") sta1 = YBQstatus.objects.all() if equip_id or equip_name: if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") # 000: if equip_name == "" and equip_id == "": sta1 = YBQstatus.objects.filter( equip_id__equip_user=current_user) # 010: elif equip_name == "" and equip_id != "": sta1 = YBQstatus.objects.filter( equip_id__equip_user=current_user, equip_id__equip_id__contains=equip_id) # 100: elif equip_name != "" and equip_id == "": sta1 = YBQstatus.objects.filter( equip_id__equip_user=current_user, equip_id__equip_name__contains=equip_name) # 110: elif equip_name != "" and equip_id != "": sta1 = YBQstatus.objects.filter( equip_id__equip_user=current_user, equip_id__equip_name__contains=equip_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("---代理商") # 000: if equip_name == "" and equip_id == "": sta1 = YBQstatus.objects.filter(equip_id__equip_agency=current_user.user_agency) # 010: elif equip_name == "" and equip_id != "": sta1 = YBQstatus.objects.filter( equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=equip_id) # 100: elif equip_name != "" and equip_id == "": sta1 = YBQstatus.objects.filter( equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=equip_name) # 110: elif equip_name != "" and equip_id != "": sta1 = YBQstatus.objects.filter( equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=equip_name, equip_id__equip_id__contains=equip_id) else: print("---管理员") # 000: if equip_name == "" and equip_id == "": sta1 = YBQstatus.objects.all() # 010: elif equip_name == "" and equip_id != "": sta1 = YBQstatus.objects.filter( equip_id__equip_id__contains=equip_id) # 100: elif equip_name != "" and equip_id == "": sta1 = YBQstatus.objects.filter( equip_id__equip_name__contains=equip_name) # 110: elif equip_name != "" and equip_id != "": sta1 = YBQstatus.objects.filter( equip_id__equip_name__contains=equip_name, equip_id__equip_id__contains=equip_id) dat = [{"sex_trap": eval(x.ybq_status), "upl_time": x.upl_time, "equip_name": x.equip_id.equip_name,"is_online": x.is_online, "off_time": x.off_time} for x in sta1] data = {"nums":sta1.count(),"dat":dat[(10*(page-1)):(page*10)]} data = json.dumps(data, cls=CJSONEncoder, indent=4) # print("data:",data) return HttpResponse(data) # 诱捕器详情页面： class ybq_equip_detail(View): def post(self,request): equip_id = request.POST.get("equip_id") ret = request.POST.get("ret") if ret == "detail": #数据详情 ybq_list = YBQstatus.objects.get(equip_id_id=equip_id) data = {"sex_trap": eval(ybq_list.ybq_status) , "upl_time": ybq_list.upl_time, "equip_name": ybq_list.equip_id.equip_name,"is_online": ybq_list.is_online, "off_time": ybq_list.off_time} elif ret == "history": #历史记录 page = int(request.POST.get("page")) ybq_list = YBQdata.objects.filter(equip_id_id=equip_id) begin_time = request.POST.get('begin_time') end_time = request.POST.get('end_time') if begin_time: #时间转换 begindate = re.findall(r"\d+\.?\d*", begin_time) enddate = re.findall(r"\d+\.?\d*", end_time) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2])) print("start_date:", start_date) print("end_date:", end_date) ybq_list = YBQdata.objects.filter(equip_id_id=equip_id, upl_time__range=(start_date, end_date)) nums = ybq_list.count() dat = [] # 获得当前页： print("page:", page) for i in ybq_list: dat.append({"sex_trap": i.ybq_data, "upl_time": i.upl_time}) data = {"dat":dat[(10*(page-1)):(page*10)],"nums":nums} elif ret == "photo": #照片列表 ybq_list = YBQphoto.objects.filter(equip_id=equip_id) page = int(request.POST.get("page")) dat = [] for i in ybq_list: dat.append({ "equip_id":i.equip_id,"time":i.upl_time,"addr":i.addr,"describe":i.describe }) data = {"nums":len(dat),"dat":dat[(10*(page-1)):(page*10)]} elif ret == "del_img": #删除图片 img_list = request.POST.get('addrlist') if img_list: print("img_list:",type(eval(img_list))) print("img_list:",eval(img_list)) for i in eval(img_list): if os.path.exists(i) == True: # 删除图片文件 os.remove(i) # 删除数据库照片列表中，照片路径： try: CBDphoto.objects.filter(equip_id=equip_id, addr=i).delete() print("-----image delete ok!-----") except: print("-----image delete failed!-----") else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: CBDphoto.objects.filter(equip_id=equip_id, addr=i).delete() except Exception as e: print("========>>",e) print("-----image not exist!-----") data = {"code":200} data = json.dumps(data, cls=CJSONEncoder, indent=4) return HttpResponse(data) # 诱捕器一型mqtt下发控制： class ybq_equip_mqtt_v1(View): def post(self, request): ret = request.POST.get('ret') imei = request.POST.get('equip_id') # 刷新 if ret == "data": payload = {"cmd":"read","ext":"data"} # 查询服务器配置 elif ret == "serverconf": payload = {"cmd":"read","ext":"serverconf"} # 设置上传时间间隔 elif ret == "data_tim": dat_f = request.POST.get('dat_f') payload = {"cmd":"set","ext":{"type":"data_tim","dat_f":int(dat_f)}} # 清网 elif ret == "clearnet": payload = {"cmd":"ctrl","ext":"clearnet"} # 开启时控 elif ret == "work_tim1": st = request.POST.get('st') et = request.POST.get('et') payload = {"cmd":"set","ext":{"type":"work_tim","timctrl":1,"st":int(st),"et":int(et)}} # 关闭时控 elif ret == "work_tim0": payload = {"cmd":"set","ext":{"type":"work_tim","timctrl":0,"st":20,"et":2}} # 关闭 elif ret == "ds0": payload = {"cmd":"ctrl","ext":{"type":"power","ds":0}} # 开启 elif ret == "ds1": payload = {"cmd":"ctrl","ext":{"type":"power","ds":1}} # 重启 elif ret == "reboot": payload = {"cmd":"reboot"} # 升级 elif ret == "update": payload = {"cmd":"update"} topic = "yfkj/xycb/s2c/"+imei cmd = {"topic": topic, "payload": json.dumps(payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) # data = json.dumps(data) return HttpResponse(res.status_code) #诱捕器二型mqtt下发控制 class ybq_equip_mqtt_v2(View): def post(self, request): ret = request.POST.get('ret') imei = request.POST.get('equip_id') # 刷新 if ret == "data": payload = {"cmd":"read","ext":"data"} # 查询mqtt网络配置 elif ret == "mqttconf": payload = {"cmd":"read","ext":"mqttconf"} # 拍照 elif ret == "takephoto": payload = {"cmd":"ctrl","ext":{"takephoto":"1"}} # 卷沾虫板： elif ret == "turn": payload = {"cmd":"ctrl","ext":{"turn":"1"}} # 测试性诱剂 elif ret == "move": payload = {"cmd":"ctrl","ext":{"move":"1"}} # 下发12V重新上电： elif ret == "repower": payload = {"cmd":"repower"} # 关闭： elif ret == "ds0": payload = {"cmd":"ctrl","ext":{"ds":"0"}} # 开启： elif ret == "ds1": payload = {"cmd":"ctrl","ext":{"ds":"1"}} # 重启 elif ret == "reboot": payload = {"cmd":"reboot"} # 升级 elif ret == "update": payload = {"cmd":"update"} # 下发设置循环工作模式-间隔时间： elif ret == "photoset": pic_t = request.POST.get('pic_t') pic_f = request.POST.get('pic_f') payload = {"cmd":"set","ext":{"type":"photo","pic_t":pic_t,"pic_f":pic_f}} # 设置定时卷沾虫板： elif ret == "turnset": turn_t = request.POST.get('turn_t') payload = {"cmd":"set","ext":{"type":"turn","turn_t":turn_t}} topic = "yfkj/xycb/s2c/"+imei #[1:-1] cmd = {"topic": topic, "payload": json.dumps(payload), 'qos': 1} print(json.dumps(payload, indent=1)) res = requests.post("http://www.yfzhwlw.com:8080/api/v2/mqtt/publish", data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) # res = requests.post("http://www.yfznscd.com:8080/api/v2/mqtt/publish", # data=json.dumps(cmd, indent=1), auth=HTTPBasicAuth("admin", "yfkj_6019")) print("res.status_code:", type(res.status_code)) return HttpResponse(res.status_code) # 诱捕器温湿度图 class ybq_line_chart(View): def post(self, request): begin_time = request.POST.get('begin_time') end_time = request.POST.get('end_time') print("begin_time:", begin_time) print("end_time:", end_time) equip_id = request.POST.get('e_id') print("equip_id:", equip_id) # 获取当前日期： now_time = datetime.datetime.now() print("当前日期为：",now_time) print("当前月为：",now_time.month) sta1 = YBQdata.objects.filter(equip_id=equip_id,upl_time__month=now_time.month).values() if begin_time: begindate = re.findall(r"\d+\.?\d*", begin_time) enddate = re.findall(r"\d+\.?\d*", end_time) start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2])) print("start_date:", start_date) print("end_date:", end_date) sta1 = YBQdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)).values() sta2 = [{"at": eval(x['ybq_data'])['at'], "ah": eval(x['ybq_data'])['ah'], "cpu_tmp": eval(x['ybq_data'])['cpu_tmp'], "tim": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) return HttpResponse(data) #微信虫害识别 class wechat_insect_discern(View): def post(self,request): imageFile = request.FILES.get('imagefile') imageFile = {"imageFile":imageFile} print("imageFile",imageFile) username = 'yunfei' uniqueKey = '84e6eb40f3a616dd14b1fefc75425006' url = 'http://47.99.110.100:8080/recognizationSys/api/recognization' data = {'imageType':'1','gis':'118.279643#31.221456','username':username,'uniqueKey':uniqueKey} res = requests.post(url,data=data,files=imageFile) return HttpResponse(res.text) #微信病害识别 class wechat_plant_discern(View): def post(self,request): imageFile = request.FILES.get('imagefile') imageFile = {"imageFile":imageFile} username = 'yunfei' uniqueKey = '84e6eb40f3a616dd14b1fefc75425006' url = 'http://47.99.110.100:8080/recognizationSys/api/recognization' data = {'imageType':'2','gis':'118.279643#31.221456','username':username,'uniqueKey':uniqueKey} res = requests.post(url,data=data,files=imageFile) return HttpResponse(res.text) #测报灯害虫短新预警设置 class wechat_pest(View): def get(self,request): pest_list = copy.deepcopy(insect_dict_new) valus = list(pest_list.values()) keys = list(pest_list.keys()) data = [] for i in range(len(valus)): dicts = {"name":"","vauls":""} dicts["name"] = valus[i] dicts["vauls"]= keys[i] data.append(dicts) data = json.dumps(data) return HttpResponse(data) def post (self,request): pestCategory = request.POST.get("pestCategory") pestCategoryNum = request.POST.get("pestCategoryNum") appointPest = request.POST.get("appointPest") appointPestName1 = request.POST.get("appointPestName1") appointPestNum1 = request.POST.get("appointPestNum1") pestTotal = request.POST.get("pestTotal") pestTotalNum = request.POST.get("pestTotalNum") pestWarn = request.POST.get("pestWarn") phone = request.POST.get("phone") print("phone",phone) equip_id = request.POST.get("equip_id") print("equip_id",equip_id) mobile_pat = re.compile('^(13\d|14[5|7]|15\d|166|17\d|18\d)\d{8}$') res = re.search(mobile_pat,phone) if res: if appointPestName1: appointPestName1 = "".join(appointPestName1.split(","))[:-1] if appointPestNum1: appointPestNum1 = "".join(appointPestNum1.split(","))[:-1] dat = {"pestCategory":pestCategory,"pestCategoryNum":pestCategoryNum,"appointPest":appointPest, "appointPestName":appointPestName1,"appointPestNum":appointPestNum1,"pestTotal":pestTotal, "pestTotalNum":pestTotalNum,"pestWarn":pestWarn,"phone":phone} dat = json.dumps(dat) equip_id = Equip.objects.get(equip_id=equip_id) if Msg_Conf.objects.filter(equip_id=equip_id).exists(): msgconf = Msg_Conf.objects.get(equip_id=equip_id) msgconf.conf = dat msgconf.save() else: Msg_Conf.objects.create(equip_id=equip_id,conf=dat) data = 0 else: data = 1 return HttpResponse(data) #测报灯害虫短新预警数据返现 class wechat_pest_list(View): def post (self,request): equip_id = request.POST.get("equip_id") cbd_pest = Msg_Conf.objects.filter(equip_id=equip_id).values() data = [] date = [] if cbd_pest: for i in cbd_pest : dat = eval(i["conf"]) appointPestName = dat["appointPestName"] appointPestNum = dat["appointPestNum"] if appointPestName.find("#") != -1: pic_list = appointPestName.split("#") for x in pic_list: data.append(insect_dict_new[x]) else: if appointPestName != "0" and appointPestName != '': data.append(insect_dict_new[appointPestName]) else: data.append(appointPestName) if appointPestNum.find("#") != -1: pic_list = appointPestNum.split("#") for x in pic_list: date.append(x) else: if appointPestNum != "0" and appointPestNum != '': date.append(appointPestNum) else: date.append(appointPestNum) data = {"pestCategory":dat["pestCategory"],"pestCategoryNum":dat["pestCategoryNum"], "appointPest":dat["appointPest"],"appointPestName":data,"appointPestNum":date, "pestTotal":dat["pestTotal"],"pestTotalNum":dat["pestTotalNum"],"pestWarn":dat["pestWarn"],"phone":dat["phone"]} else: data = {"data":0} data = json.dumps(data) return HttpResponse(data) #sim信息 class scd_sim_list(View): def post(self,request): user_name = request.POST.get("username") page = int(request.POST.get("page")) current_user = MyUser.objects.get(username=user_name) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---用户") sta = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") sta = Equip_SimInfo.objects.all() siminfos = [] nums = len(sta) for i in sta: siminfos.append({ "equip_id":i.equip_id.equip_id, "equip_name":i.equip_name, "equip_type":i.equip_type, "iccid":i.iccid, "carrier":i.carrier, "data_plan":i.data_plan, "data_usage":i.data_usage, "account_status":i.account_status, "expiry_date":i.expiry_date, "data_balance":i.data_balance }) equip_ids=siminfos[(10*(page-1)):(page*10)] data = {"dat":equip_ids,"nums":nums} data = json.dumps(data,indent=4) return HttpResponse(data) #地图设备分布 class wechat_equip_map(View): def post(self, request): current_user = request.POST.get('username') print("请求定位信息！！！") print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) ret = request.POST.get('ret') print("ret:", ret) # page = int(request.POST.get('page')) # print("page",page) if ret == "cbd": print("请求测报灯定位！") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user).values() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values() else: print("---管理员") sta1 = RecentCBDdata.objects.all().values() sta2 = [] for x in sta1: try: sta2.append({ "equip_id": x['equip_id_id'], "equip_type": 3, "equip_name": x['equip_name'], "gps": eval(x['cbd_data'])['gps'], "lng": eval(x['cbd_data'])['lng'], "lat": eval(x['cbd_data'])['lat'] }) except: sta2.append({ "equip_id": x['equip_id_id'], "equip_type": 3, "equip_name": x['equip_name'], "gps": 2, "lng": eval(x['cbd_data'])['lng'], "lat": eval(x['cbd_data'])['lat'] }) # sta2 = [{ # "equip_id": x['equip_id_id'], # "equip_type": 3, # "equip_name": x['equip_name'], # "lng": eval(x['cbd_data'])['lng'], # "lat": eval(x['cbd_data'])['lat'] # } for x in sta1] data = json.dumps(sta2) # print("data:", data) return HttpResponse(data) elif ret == "scd": print("请求杀虫灯定位！") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") sta1 = RecentSCDdata.objects.filter( equip_id__equip_user=current_user).values() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values() else: print("---管理员") sta1 = RecentSCDdata.objects.all().values() sta2 = [] a = datetime.datetime.now() for x in sta1: try: sta2.append({ "equip_id": x['equip_id_id'], "equip_type": 2, "equip_name": x['equip_name'], "gps": eval(x['scd_data'])['gps'], "lng": eval(x['scd_data'])['lng'], "lat": eval(x['scd_data'])['lat'] }) except: sta2.append({ "equip_id": x['equip_id_id'], "equip_type": 2, "equip_name": x['equip_name'], "gps": 2, "lng": 113, "lat": 34 }) print("消耗时间为",datetime.datetime.now()-a) data = json.dumps(sta2) # print("data:", data) return HttpResponse(data) elif ret == "qxz": print("请求气象站定位！") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") sta1 = QXZ_Base_Info.objects.filter( equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = QXZ_Base_Info.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") sta1 = QXZ_Base_Info.objects.all() sta2 = [{ "equip_id": x.equip_id_id, "equip_type": 5, "equip_name": x.equip_id.equip_name, "lng": x.lng, "lat": x.lat } for x in sta1] data = json.dumps(sta2) # print("data:", data) return HttpResponse(data) elif ret == "bzy": print("请求孢子仪定位！") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") sta1 = BZYstatus.objects.filter( equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = BZYstatus.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") sta1 = BZYstatus.objects.all() sta2 = [{ "equip_id": x.equip_id_id, "equip_type": 7, "equip_name": x.equip_id.equip_name, "lng": eval(x.bzy_status)['lng'], "lat": eval(x.bzy_status)['lat'] } for x in sta1] data = json.dumps(sta2) # print("data:", data) return HttpResponse(data) elif ret == "xyq": print("请求性诱设备定位！") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") sta1 = YBQstatus.objects.filter( equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = YBQstatus.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") sta1 = YBQstatus.objects.all() sta2 = [] for x in sta1: try: sta2.append({ "equip_id": x.equip_id.equip_id, "equip_type": 4, "equip_name": x.equip_id.equip_name, "gps": eval(x.ybq_status)['gps'], "lng": x.lng, "lat": x.lat }) except: sta2.append({ "equip_id": x.equip_id.equip_id, "equip_type": 4, "equip_name": x.equip_id.equip_name, "gps": 2, "lng": x.lng, "lat": x.lat }) # sta2 = [{ # "equip_id": x.equip_id_id, # "equip_type": 4, # "equip_code": x.equip_code, # "lng": eval(x.ybq_status)['lng'], # "lat": eval(x.ybq_status)['lat'] # } for x in sta1] data = json.dumps(sta2) # print("data:", data) return HttpResponse(data) elif ret == "imei": print("imei搜索定位！") equip_id = request.POST.get('equip_id') print("equip_id:", equip_id) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # 非管理员筛选出当前用户： scd_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='2')) cbd_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='3')) bzy_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='7')) qxz_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='5')) xyq_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='4')) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # 代理商用户 scd_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='2')) cbd_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='3')) bzy_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='7')) qxz_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='5')) xyq_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='4')) else: # 管理员用户 scd_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='2')) cbd_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='3')) bzy_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='7')) qxz_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='5')) xyq_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='4')) if not scd_equips and not cbd_equips and not bzy_equips and not qxz_equips and not xyq_equips: sta5 = 0 data = json.dumps(sta5) return HttpResponse(data) # print("scd_equips:", scd_equips) # print("cbd_equips:", cbd_equips) else: sta2 = [] if scd_equips: for i in scd_equips: sta1 = SCDstatus.objects.filter( equip_id__equip_id__contains=equip_id) for x in sta1: try: sta2.append({ "equip_id": x.equip_id.equip_id, "equip_type": x.equip_id.equip_type.type_id, "equip_name": x.equip_id.equip_name, "gps": eval(x.scd_status)['gps'], "lng": x.lng, "lat": x.lat, "equip_location": x.equip_location }) except: sta2.append({ "equip_id": x.equip_id.equip_id, "equip_type": x.equip_id.equip_type.type_id, "equip_name": x.equip_id.equip_name, "gps": 2, "lng": x.lng, "lat": x.lat, "equip_location": x.equip_location }) sta4 = [] if cbd_equips: for i in cbd_equips: sta3 = CBDstatus.objects.filter( equip_id__equip_id__contains=equip_id) for x in sta3: try: sta4.append({ "equip_id": x.equip_id.equip_id, "equip_type": 3, "equip_name": x.equip_id.equip_name, "gps": eval(x.cbd_status)['gps'], "lng": x.lng, "lat": x.lat, "equip_location": x.equip_location }) except: sta4.append({ "equip_id": x.equip_id.equip_id, "equip_type": 3, "equip_name": x.equip_id.equip_name, "gps": 2, "lng": x.lng, "lat": x.lat, "equip_location": x.equip_location }) sta7 = [] if bzy_equips: for i in bzy_equips: sta6 = BZYstatus.objects.filter( equip_id__equip_id__contains=equip_id) for x in sta6: try: sta7.append({ "equip_id": x.equip_id.equip_id, "equip_type": 7, "equip_name": x.equip_id.equip_name, "lng": eval(x.bzy_status)['lng'], "lat": eval(x.bzy_status)['lat'], # "equip_location": x.equip_location }) except: sta7.append({ "equip_id": x.equip_id.equip_id, "equip_type": 7, "equip_name": x.equip_id.equip_name, "lng": 113, "lat": 34 # "lng": eval(x.bzy_status)['lng'], # "lat": eval(x.bzy_status)['lat'], # "equip_location": x.equip_location }) sta9 = [] if qxz_equips: for i in qxz_equips: sta8 = QXZ_Base_Info.objects.filter( equip_id__equip_id__contains=equip_id) for x in sta8: try: sta9.append({ "equip_id": x.equip_id.equip_id, "equip_type": 5, "equip_name": x.equip_id.equip_name, "lng": x.lng, "lat": x.lat, # "equip_location": x.equip_location }) except: sta9.append({ "equip_id": x.equip_id.equip_id, "equip_type": 5, "equip_name": x.equip_id.equip_name, "lng": x.lng, "lat": x.lat, # "equip_location": x.equip_location }) sta11 = [] if xyq_equips: for i in xyq_equips: sta10 = YBQstatus.objects.filter( equip_id__equip_id__contains=equip_id) for x in sta10: try: sta11.append({ "equip_id": x.equip_id.equip_id, "equip_type": 4, "equip_name": x.equip_id.equip_name, "gps": eval(x.ybq_status)['gps'], "lng": x.lng, "lat": x.lat, "equip_location": x.equip_location }) except: sta11.append({ "equip_id": x.equip_id.equip_id, "equip_type": 4, "equip_name": x.equip_id.equip_name, "gps": 2, "lng": x.lng, "lat": x.lat, "equip_location": x.equip_location }) # sta4 = [{ # "equip_id": x.equip_id.equip_id, # "equip_type": x.equip_id.equip_type.type_id, # "equip_name": x.equip_id.equip_name, # "lng": x.lng, # "lat": x.lat, # "equip_location": x.equip_location # } for x in sta3] sta5 = sta2+sta4+sta7+sta9+sta11 data = json.dumps(sta5) return HttpResponse(data) #用户管理，用户页面 class wechat_user_list(View): def post(self,request): user_name = request.POST.get("username") page = int(request.POST.get('page')) print("page:", page) ret = request.POST.get("ret") print("user_name",user_name) user_list = [] try: current_user = MyUser.objects.get(username=user_name) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: pass elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("----代理商") # 搜索条件为空，获取所有用户 if ret == '': user_list = MyUser.objects.filter(user_agency=current_user.user_agency) # 搜索条件存在，根据用户名搜索用户 elif ret != '': user_list = MyUser.objects.filter(user_agency=current_user.user_agency,username__contains=ret) else: print("----管理员") # 搜索条件为空，获取所有用户 if ret == '': user_list = MyUser.objects.all() # 搜索条件存在，根据用户名搜索用户 elif ret != '': user_list = MyUser.objects.filter(username__contains=ret) except Exception as e: print(e) dat = [] nums = len(user_list) for i in user_list[(10*(page-1)):(page*10)]: sta1 = MyUser.objects.filter(username=i.username) try: for x in sta1: if x.is_superuser == 1 and x.is_staff == 1: role = "超级管理员" elif x.is_superuser == 0 and x.is_staff == 1: role = "管理员" elif x.is_superuser == 0 and x.is_staff == 0: role = "用户" sta2 = {"userId": x.id, "user_name": x.username, "user_email": x.email, "user_type": role} except AttributeError: for x in sta1: if x.is_superuser == 1 and x.is_staff == 1: role = "超级管理员" elif x.is_superuser == 0 and x.is_staff == 1: role = "管理员" elif x.is_superuser == 0 and x.is_staff == 0: role = "用户" sta2 = {"userId": x.id, "user_name": x.username, "user_email": x.email, "user_type": role} dat.append(sta2) data = {"nums":nums,"dat":dat} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #用户详情页面 class wechat_user_detail(View): def get(self,request): user_group_list = User_Group.objects.all().values() data = [] for i in user_group_list: data.append({ "id":i["id"], "name":i["name"] }) data = json.dumps(data) return HttpResponse(data) def post(self,request): userId = request.POST.get("id") user_name = MyUser.objects.get(id=userId) groups = User_Group.objects.all() group_list = [] for i in groups: group_list.append(i.name) group = Group.objects.filter(user=user_name) if group.count() == 0: group_name = "" else: group_name = group[0].name try: if user_name.is_superuser == 1 and user_name.is_staff == 1: # 超级管理员 role = 0 elif user_name.is_superuser == 0 and user_name.is_staff == 1: # 管理员 role = 1 elif user_name.is_superuser == 0 and user_name.is_staff == 0: # 普通用户 role = 2 dat = {"userId":user_name.id, "username":user_name.username, "email":user_name.email, "tel":user_name.user_phone, "province":user_name.user_pro, # 省 "city":user_name.user_city, # 市 "area":user_name.user_area, # 县/区 "usertype":role, "latestTime":user_name.last_login, "creatTime":user_name.date_joined, "user_groups":group_list, "user_group":group_name, "user_remark":user_name.user_remark, "active":user_name.is_active} except AttributeError: if user_name.is_superuser == 1 and user_name.is_staff == 1: role = 0 elif user_name.is_superuser == 0 and user_name.is_staff == 1: role = 1 elif user_name.is_superuser == 0 and user_name.is_staff == 0: role = 2 dat = {"userId":user_name.id, "username":user_name.username, "email":user_name.email, "tel":user_name.user_phone, "province":user_name.user_pro, "city":user_name.user_city, "area":user_name.user_area, "usertype":role, "latestTime":user_name.last_login, "creatTime":user_name.date_joined, "user_groups":group_list, "user_group":group_name, "user_remark":user_name.user_remark, "active":user_name.is_active} data = json.dumps(dat,cls=CJSONEncoder) print("data:",data) return HttpResponse(data) #禁用用户 class wechat_user_prohibit(View): def post(self,request): ret = request.POST.get("ret") current_user = request.POST.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) if ret == "state": # 禁用和启用： state = request.POST.get("state") print("state:",state) try: current_user.is_active = state current_user.save() data = "0" except: data = "1" return HttpResponse(data) elif ret == "pwd": # 重置密码： new_pwd = request.POST.get("password") print("new_pwd:",new_pwd) try: current_user.set_password(new_pwd) current_user.save() data = "0" except: data = "1" return HttpResponse(data) # 设备分配页面 class wechat_equip_allot(View): def post(self,request): uname = request.POST.get('username') print(uname) page = int(request.POST.get('page')) ret = request.POST.get("ret") print(ret) print("page=",page) user_list = [] if ret: user_list = MyUser.objects.filter(username__contains=ret) else: # 接收当前用户 # current_user = request.session.get('username') # print("current_user:", current_user) current_user = MyUser.objects.get(username=uname) # 判断是经销商还是超级管理员 if current_user.is_superuser == True or current_user.is_staff == True: user_list = MyUser.objects.all().order_by( "-date_joined")[(10*(page-1)):(page*10)] elif current_user.is_agency: user_list = MyUser.objects.filter(user_agency=current_user.user_agency).order_by( "-date_joined")[(10*(page-1)):(page*10)] # user_list = MyUser.objects.all() nums = len(user_list) user_list = user_list[(10*(page-1)):(page*10)] dat = [] for x in user_list: try: sta = {"userid":x.id,"username":x.username,"email":x.email} except AttributeError: sta = {"userid":x.id,"username":x.username,"email":x.email} dat.append(sta) data = {'nums':nums,'dat':dat} data = json.dumps(data, cls=CJSONEncoder) User_Log.objects.create(log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='设备分配') return HttpResponse(data) # 未分配设备列表 class wechat_equip_allot_list(View): def post(self,request): userid = request.POST.get('userid') print("userid:",userid) current_user = MyUser.objects.get(id=userid) f_id = request.POST.get('f_id') page = int(request.POST.get('page')) equip_list = [] print("page=",page) print("current_user",current_user) if f_id: equip_list = Equip.objects.filter( Q(equip_user=None, equip_id__contains=f_id) | Q(equip_user=current_user, equip_id__contains=f_id)) else: # 判断是经销商还是超级管理员 if current_user.is_superuser == True or current_user.is_staff == True: equip_list = Equip.objects.filter( Q(equip_user=None) | Q(equip_user=current_user)) elif current_user.is_agency: equip_list = Equip.objects.filter( Q(equip_agency=current_user.user_agency, equip_user=None) | Q(equip_agency=current_user.user_agency, equip_user=current_user)) # equip_list = Equip.objects.filter( # Q(equip_user=None) | Q(equip_user=user_obj)) nums = len(equip_list) equip_list = equip_list[(10*(page-1)):(page*10)] dat = [] for x in equip_list: if x.equip_user == current_user: checked = "1" else: checked = "0" try: sta = {"checked":checked, "equipid":x.equip_id, "equipname":x.equip_name, "equiptype":'%s'%x.equip_type, "equip_add_time":x.equip_add_time, "equip_user":'%s'%x.equip_user} except AttributeError: sta = {"checked":checked, "equipid":x.equip_id, "equipname":x.equip_name, "equiptype":'%s'%x.equip_type, "equip_add_time":x.equip_add_time, "equip_user":'%s'%x.equip_user} dat.append(sta) data = {'nums':nums,'dat':dat} data = json.dumps(data, cls=CJSONEncoder,sort_keys=True)# sort_keys = True 排序 return HttpResponse(data) # 确认分配 class wechat_equip_allot_confirm(View): def post(self,request): userid = request.POST.get('userid') user_obj = MyUser.objects.get(id=userid) equip_ids = request.POST.get('equip_ids') print("equip_ids=", equip_ids) equip_ids = json.loads(equip_ids) # equip_ids = equip_ids.split(',') # print("当前页的所有设备id：equip_ids=", equip_ids) # 获得选中的复选框: print("user_obj",user_obj) check_box_list = request.POST.get('check_box_list') print('check_box_list:', check_box_list) check_box_list = json.loads(check_box_list) no_check_box_list = [] for i in equip_ids: if i in check_box_list: pass else: no_check_box_list.append(i) print('no_check_box_list=', no_check_box_list) try: for checked_id in check_box_list: choose_equip = Equip.objects.get(equip_id=checked_id) print(choose_equip.equip_user) # 如果选中的设备没有用户：即选中的设备 设备用户为None： if choose_equip.equip_user == None: # 只有当选中的设备id对应的设备 没有用户时才分配 choose_equip.equip_user = user_obj choose_equip.save() # 保存到数据库 # 取消分配:给当前用户取消已分配的设备； for a in no_check_box_list: choose_equip = Equip.objects.get(equip_id=a) choose_equip.equip_user = None # 把设备的设备用户改为None，表示取消分配 choose_equip.save() except Exception as e: print(e) data = "1" data = "0" User_Log.objects.create(log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='设备分配--分配设备') return HttpResponse(data) #用户反馈 class wechat_feedback(View): def post(self,request): name = request.POST.get("name") phone = request.POST.get("phone") email = request.POST.get("email") try: countent = request.POST.get("countent") Fdb.objects.create( fdb_name = name, fdb_phone = phone, fdb_email = email, fdb_content = countent, ) data = 0 except Exception as e : print(e) data = 1 return HttpResponse(data) # 病虫害库 class wechat_plant(View): def get(self,request): data = json.dumps(insect_dict_new,ensure_ascii=False) return HttpResponse(data) class tests(View): def get(self,request): pass def post(self,request): try: now_time = datetime.datetime.now().strftime('%Y%m%d') nowtime = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') post_list = request.body.decode() # print("接收到的数据-------->>>>>>",post_list) pos = json.loads(post_list) print(pos) if pos["payload"]["cmd"] == "data" or pos["payload"]["cmd"] == "status" or pos["StationID"] !="" : try: imei = pos["payload"]["ext"]["imei"] except: imei = pos["imei"] else: imei = pos["StationID"] print(type(pos)) path = "logs/"+ imei if os.path.exists(path) == False: os.makedirs(path) f = open('logs/%s/'%imei + now_time +'.txt','a') # with open(path,"a") as file: #只需要将之前的”w"改为“a"即可，代表追加内容 f.write(post_list+"\n") f.write(nowtime +"\r\n") f.close() data = 0 return HttpResponse(data) except Exception as e: print(e) data = 0 return HttpResponse(data) from apps.ReportManage.all_dict import transpont_equip_cbd,transpont_equip_qxz_li,qxz_dict_li,transpont_equip_qxz_params # from nt import mkdir # import xlrd, xlwt class tbest(View): def post(self,request): # print(insect_dict_new) # post_list = json.loads(request.body.decode()) imie = "235185770" qxz_list = QXZstatus_New.objects.get(equip_id=imie) qxz_base = QXZ_Base_Info.objects.get(equip_id=imie) if imie in transpont_equip_qxz_li.keys(): if qxz_list.is_online == "1": is_online = "正常" else: is_online = "异常" info = {"sbid":imie,"time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"status":is_online,"type":"环境监测"} data = [qxz_list.e1,qxz_list.e2,qxz_list.e3,qxz_list.e4,qxz_list.e5,qxz_list.e6,qxz_list.e7,qxz_list.e8,qxz_list.e9,qxz_list.e10,qxz_list.e11,qxz_list.e12,qxz_list.e13,qxz_list.e14, qxz_list.e15,qxz_list.e16,qxz_list.e17,qxz_list.e18, qxz_list.e19,qxz_list.e20,qxz_list.e21,qxz_list.e22, qxz_list.e23,qxz_list.e24,qxz_list.e25,qxz_list.e26, qxz_list.e27,qxz_list.e28,qxz_list.e29,qxz_list.e30] test = [i for i in data if i != ''] iotdata = [] for i in test: qxz = i.split("#") qxz_title = qxz_dict_li[qxz[1]] iotdata.append({ "name":qxz_title[1],"value":qxz[0],"unit":qxz_title[2], }) iotdata.append({"name":"dl","value":qxz_base.volt,"unit":"%","name":"xhqd","value":qxz_base.rssi,"unit":""}) data = {"info":info,"iotdata":iotdata,"Params":transpont_equip_qxz_params[imie]} data = json.dumps(data) return HttpResponse(data)