import copy # Create your views here. import datetime import json import os import re import time import urllib.request import requests from django.http import FileResponse from django.http.response import HttpResponse from django.shortcuts import render from django.views.generic import ListView from django.views.generic.base import View from django.contrib.auth.hashers import make_password, check_password from PIL import Image from django.utils import timezone import xmltodict from requests.auth import HTTPBasicAuth from django.contrib.auth import get_user_model from apps.AppInfo.models import ( Article, CKArticle, Equip, Equip_type, FarmList, FarmUser, GardenManage, Hotel_Info, Hotel_Photo, JKdata, MyUser, Pick_Pub, Product, QXZdata, QXZdata_New, QXZstatus, QXZstatus_New, QXZswitchdata, QXZswitchstatus, Video_data,GardenArea,Store_Manage,Areacrop,Sell_Manage,Person_Pick,QXZAutoswitch,Sightsee_Info,Pic_Info, QXZ_Alarm_Log,Experts,Relations,QXZ_Alarm,QXZ_Conf,QXZ_Base_Info,QXZ_Default_Conf,QXZ_Info_Record,SystemPhoto) from apps.Equipment.all_dict import qxz_dict import xlwt from io import BytesIO # 地图 class Map_Test(View): def get(self,request): # current_user = request.session.get('username') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) try: pic_list = Pic_Info.objects.get(pic_user=current_user) except: pic_list = "" return render(request, 'backstageNet/map/map.html', context={"pic_list":pic_list}) def post(self,request): pass # 测试接口 class Equip_Test(View): def get(self,request): pass def post(self,request): qxz_data = QXZstatus.objects.get(equip_id="16054381") json_obj = qxz_data.qxz_status.replace("'", "\"") xml = xmltodict.unparse({'request':json_obj}) return HttpResponse(xml) # 监控界面 class JKview(ListView): def get(self,request): equip_id = request.GET.get('equip_id') token = "at.0izp4b188fna8vvk8j28o2l4a980qqex-1otrmuqf8l-1k26cbi-cletdiwkp" return render(request, 'backstageNet/jk/equipmanage_jk.html', context={"equip_id":equip_id,"token":token}) def post(self,request): pass # 监控列表 class JKlist(ListView): def get(self,request): # current_user = request.user.username # print("current_user:", current_user) username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) page = request.GET.get('page') page = int(page) f_id = request.GET.get('f_id') print("f_id:", f_id) if current_user.is_superuser != True and current_user.is_staff != True: # 用户 if f_id != "": equip_list = Equip.objects.filter(equip_type=6, equip_user=current_user, equip_id__contains=f_id) else: equip_list = Equip.objects.filter(equip_type=6, equip_user=current_user) else: # 管理员 if f_id != "": equip_list = Equip.objects.filter(equip_type=6, equip_id__contains=f_id) else: equip_list = Equip.objects.filter(equip_type=6) e_ids = [] for x in equip_list: n_d = {"equip_name":x.equip_name, "equip_id":x.equip_id} e_ids.append(n_d) nums = len(e_ids) # print(nums) ids = e_ids[(10*(page-1)):(page*10)] data = {'ids': ids, 'nums': nums} data = json.dumps(data) return HttpResponse(data) def post(self,request): pass # 视频详情 class JKManage_View(ListView): def get(self, request): live_list = [] j_id = request.GET.get("id") jk_list = JKdata.objects.filter(equip_id=j_id) for x in jk_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 = json.dumps(live_list) return HttpResponse(data) # return render(request, 'backstageNet/jk/equipmanage_jk.html', context={"data":data}) def post(self, request): jk_id = request.POST.get('id') ctrl = request.POST.get('ctrl') imei = request.POST.get('imei') accessToken = JKdata.objects.get(equip_id=jk_id).jk_token print("accessToken:",accessToken) if imei: if Equip.objects.filter(equip_id=imei).exists(): return HttpResponse("0") else: # 得到设备类型实例： equip_t = Equip_type.objects.get(type_id=6) try: e_id = Equip.objects.create(equip_id=imei, equip_type=equip_t) print("<-----监控设备添加成功!----->") return HttpResponse("1") except: print("<-----监控设备添加失败!----->") if ctrl == "takephoto": url = 'https://open.ys7.com/api/lapp/device/capture' channelNo = '1' data = {'accessToken':accessToken, 'deviceSerial':jk_id, 'channelNo':channelNo} res = requests.post(url,data=data) print("截图返回结果为:",json.loads(res.text)) return HttpResponse(res.text) # 操作命令：0-上，1-下，2-左，3-右，4-左上，5-左下，6-右上，7-右下，8-放大，9-缩小，10-近焦距，11-远焦距 if ctrl == "move": print("-------球机云台控制开始！") dire = request.POST.get('movenum') ctrl_url = 'https://open.ys7.com/api/lapp/device/ptz/start' channelNo = '1' speed = '1' data = {'accessToken':accessToken, 'deviceSerial':jk_id, 'channelNo':channelNo, 'speed':speed, 'direction':dire} res1 = requests.post(ctrl_url,data=data) elif ctrl == "stop": print("-------球机云台控制结束！") ctrl_url = 'https://open.ys7.com/api/lapp/device/ptz/stop' channelNo = '1' data = {'accessToken':accessToken, 'deviceSerial':jk_id, 'channelNo':channelNo} res2 = requests.post(ctrl_url,data=data) return HttpResponse("1") # 新闻列表 class Newslist_View(ListView): def get(self,request): con = request.GET.get("condition") page = int(request.GET.get("page")) try: art_type = int(request.GET.get("type")) art_list = CKArticle.objects.filter(art_type=art_type) if con: art_list = CKArticle.objects.filter(art_type=art_type,title__contains=con) except: art_list = CKArticle.objects.all() if con: art_list = CKArticle.objects.filter(title__contains=con) nums = art_list.count() art = art_list[(5*(page-1)):(page*5)] return render(request, 'outerNet/newsList.html', context={'art':art,"nums":nums,"con":con,"page":page}) def post(self,request): art_list = CKArticle.objects.all() data = [] for i in art_list: data.append({"id":i.id,"title":i.title,"content":i.content,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) data = json.dumps(data) return HttpResponse(data) # 新闻详情 class News_View(ListView): def get(self,request): f_id = request.GET.get("id") objs = CKArticle.objects.all().order_by("id") art = objs.get(id=f_id) on_art = objs.filter(id__lt=f_id,art_type=art.art_type) up_art = objs.filter(id__gt=f_id,art_type=art.art_type) return render(request, 'outerNet/newsDetail.html', context={"art":art,"on_art":on_art,"up_art":up_art}) def post(self,request): art_list = Article.objects.all() for i in art_list: print(i.title) return HttpResponse("1") # 产品展厅列表 class Equip_Show_List(ListView): def get(self,request): page = int(request.GET.get("page")) product_list = Product.objects.all() con = request.GET.get("condition") if con: product_list = Product.objects.filter(title__contains=con) nums = product_list.count() product = product_list[(20*(page-1)):(page*20)] return render(request, 'outerNet/exhibitionList.html', context={"nums":nums,"page":page,"con":con,"product":product}) def post(self,request): pass # 产品展厅详情 class Equip_Show_Detail(ListView): def get(self,request): e_id = request.GET.get("id") e_name = request.GET.get("name") if e_id: product = Product.objects.get(id=e_id) if e_name: product = Product.objects.get(title=e_name) return render(request, 'outerNet/exhibitionDetail.html', context={"product":product}) def post(self,request): pass # 四季采摘-园区列表 class Garden_List(ListView): def get(self,request): pass def post(self,request): page = int(request.POST.get("page")) farm_list = FarmList.objects.all() farm = [] for i in farm_list: farm.append({"name":i.name,"id":i.id}) nums = len(farm) farms = farm[(10*(page-1)):(page*10)] data = {"farms":farms,"nums":nums} data = json.dumps(data) return HttpResponse(data) # 四季采摘-主页 class Garden_View(ListView): def get(self,request): return render(request, 'outerNet/fourPick.html', context={}) def post(self,request): pass # 主页四级采摘进入的介绍页 class Garden_Intro(ListView): def get(self,request): pid = request.GET.get("id") pname = request.GET.get("name") if pid: pick = Pick_Pub.objects.get(id=pid) if pname: pick = Pick_Pub.objects.get(name=pname) return render(request, 'outerNet/pickIntro.html', context={"pick":pick}) def post(self,request): pass # 四季采摘-园区详情 class Garden_Detail(ListView): def get(self,request): pass def post(self,request): f_id = request.POST.get("id") page = int(request.POST.get("page")) farm = FarmList.objects.get(id=f_id) pick = Pick_Pub.objects.filter(farm=farm) pick_list = [] for i in pick: pick_list.append({"id":i.id,"farm":i.farm.name,"pick_s":i.pick_s,"pick_e":i.pick_e,"name":i.name,"time":i.upl_time,"company":i.company,"img":i.pick_img}) nums = len(pick_list) pick_list = pick_list[(12*(page-1)):(page*12)] data = {"pick":pick_list,"nums":nums} data = json.dumps(data) return HttpResponse(data) #旅游导览 class Tourist(ListView): def get(self,request): sid = request.GET.get("id") sname = request.GET.get("name") if sid: sightsee = Sightsee_Info.objects.get(id=sid) if sname: sightsee = Sightsee_Info.objects.get(name=sname) return render(request, 'outerNet/tourist.html', context={"sightsee":sightsee}) def post(self,request): pass #旅游导览 class Tourist_List(ListView): def get(self,request): page = int(request.GET.get("page")) con = request.GET.get("condition") sightsee = Sightsee_Info.objects.all() if con: sightsee = Sightsee_Info.objects.filter(name__contains=con) nums = sightsee.count() sightsee = sightsee[(10*(page-1)):(page*10)] return render(request, 'outerNet/touristList.html', context={"sightsee":sightsee,"nums":nums}) def post(self,request): pass # 民宿列表 class Dorm_List(ListView): def get(self,request): page = int(request.GET.get("page")) con = request.GET.get("condition") hotel_list = Hotel_Info.objects.all() if con: hotel_list = Hotel_Info.objects.filter(name__contains=con) nums = hotel_list.count() hotel = hotel_list[(10*(page-1)):(page*10)] return render(request, 'outerNet/hotelList.html', context={"nums":nums,"hotel":hotel,"page":page,"con":con}) def post(self,request): pass # 民宿详情 class Dorm_Detail(ListView): def get(self,request): hotel_id = request.GET.get("id") hotel_name = request.GET.get("name") if hotel_id: hotel = Hotel_Info.objects.get(id=hotel_id) if hotel_name: hotel = Hotel_Info.objects.get(name=hotel_name) photos = Hotel_Photo.objects.filter(hotel=hotel) return render(request, 'outerNet/hotelDetail.html', context={"hotel":hotel,"photos":photos}) def post(self,request): pass # 农场导览 class Farm_list(ListView): def get(self,request): page = int(request.GET.get("page")) con = request.GET.get("condition") garden_list = GardenArea.objects.filter(hidden=True) if con: garden_list = GardenArea.objects.filter(hidden=True,name__contains=con) nums = garden_list.count() garden_list = garden_list[(9*(page-1)):(page*9)] return render(request, 'outerNet/farmList.html', context={"nums":nums,"garden_list":garden_list,"page":page,"con":con}) def post(self,request): pass # 视频列表 class Video_List(ListView): def get(self,request): page = int(request.GET.get("page")) con = request.GET.get("condition") video_list = Video_data.objects.all() if con: video_list = Video_data.objects.filter(title__contains=con) nums = video_list.count() video = video_list[(12*(page-1)):(page*12)] return render(request, 'outerNet/videoList.html', context={"nums":nums,"video":video,"con":con,"page":page}) def post(self,request): pass # 视频详情 class Video_Detail(ListView): def get(self,request): v_id = request.GET.get("id") v_name = request.GET.get("name") if v_id: video = Video_data.objects.get(id=v_id) if v_name: print("name",v_name) video = Video_data.objects.get(title=v_name) return render(request, 'outerNet/videoDetail.html', context={"video":video}) def post(self,request): pass # 后台管理页面 class Back_Manage(ListView): def get(self,request): if request.user.is_authenticated(): current_user = request.user.username current_user = MyUser.objects.get(username=current_user) garden = GardenArea.objects.all() return render(request, 'backstageNet/home.html', context={"current_user":current_user,"garden":garden}) else: return render(request, 'outerNet/index2.html') def post(self,request): current_user = request.user.username print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) data = current_user.limit return HttpResponse(data) # 信息发布页面 class Info_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/infoPub.html', context={}) def post(self,request): # 文章标题 title = request.POST.get('title') # 文章简介 intro = request.POST.get('intro') # 文章内容 info = request.POST.get('info') # 文章图片 head_img = request.POST.get('upicture') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) if head_img: try: Article.objects.create(title=title,intro=intro,content=info,author=current_user,head_img=head_img) data = "1" except: data = "0" else: data = "0" return HttpResponse(data) # 信息维护页面 class Info_Manage(ListView): def get(self,request): return render(request, 'backstageNet/info/infoManage.html', context={}) def post(self,request): pass # 气象站分页接口 class QXZ_Page(ListView): def get(self,request): # current_user = request.user.username # print("current_user:", current_user) # current_user = MyUser.objects.get(username="admin") page = request.GET.get('page') page = int(page) # f_id = request.GET.get('f_id') # print("f_id:", f_id) # if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # # 用户 # if f_id != "": # equip_list = Equip.objects.filter(equip_type=5, equip_user=current_user, equip_id__contains=f_id) # else: # equip_list = Equip.objects.filter(equip_type=5, equip_user=current_user) # elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # # 代理商 # if f_id != "": # equip_list = Equip.objects.filter(equip_type=5, equip_agency=current_user.user_agency, equip_id__contains=f_id) # else: # equip_list = Equip.objects.filter(equip_type=5, equip_agency=current_user.user_agency) # else: # # 管理员 # if f_id != "": # equip_list = Equip.objects.filter(equip_type=5, equip_id__contains=f_id) # else: equip_list = Equip.objects.filter(equip_type=5) e_ids = [] for x in equip_list: n_d = {"equip_name":x.equip_name, "equip_id":x.equip_id} e_ids.append(n_d) nums = len(e_ids) # print(nums) ids = e_ids[(10*(page-1)):(page*10)] data = {'ids': ids, 'nums': nums} data = json.dumps(data) return HttpResponse(data) def post(self,request): pass # 气象站状态 class QXZ_Status(ListView): def get(self,request): return render(request, 'backstageNet/qxzctrl/qxzData.html', context={}) def post(self,request): e_id = request.POST.get("e_id") qxz_list = QXZstatus_New.objects.filter(equip_id=e_id) data = [] for i in qxz_list: data.append({"interval":i.interval,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"e1":i.e1,"e2":i.e2,"e3":i.e3, "e4":i.e4,"e5":i.e5,"e6":i.e6,"e7":i.e7,"e8":i.e8,"e9":i.e9,"e10":i.e10,"e11":i.e11,"e12":i.e12,"e13":i.e13,"e14":i.e14}) data = json.dumps(data) return HttpResponse(data) # 气象站状态测试 class QXZ_Status2(ListView): def get(self,request): return render(request, 'backstageNet/qxzctrl/qxzData.html', context={}) def post(self,request): e_id = request.POST.get("e_id") qxz_list = QXZstatus_New.objects.filter(equip_id=e_id) # data = [] for i in qxz_list: dat = {"e1":i.e1,"e2":i.e2,"e3":i.e3,"e4":i.e4,"e5":i.e5,"e6":i.e6,"e7":i.e7,"e8":i.e8,"e9":i.e9,"e10":i.e10,"e11":i.e11,"e12":i.e12,"e13":i.e13,"e14":i.e14} data = {"interval":i.interval,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"dat":dat} data = json.dumps(data) return HttpResponse(data) # 气象站控制 class QXZcontrol(ListView): def get(self,request): return render(request, 'backstageNet/qxzctrl/qxzctrl.html', context={}) def post(self,request): e_id = request.POST.get('e_id') try: switch_obj = QXZswitchstatus.objects.get(equip_id=e_id) qxz_switch = switch_obj.qxz_switch except: qxz_switch = "" try: switch_name_obj = QXZswitchdata.objects.get(equip_id=e_id) switch_name = switch_name_obj.qxz_switch_data except: switch_name = "" data = {'qxz_switch':qxz_switch, 'switch_name':switch_name} data = json.dumps(data) return HttpResponse(data) # 气象站数据 class QXZchart(ListView): def get(self,request): return render(request, 'backstageNet/qxzctrl/qxzchart.html', context={}) def post(self,request): qxz_dict_2 = copy.deepcopy(qxz_dict) equip_id = request.POST.get('id') print("equip_id:", equip_id) f_tbegin = request.POST.get('begin') f_tend = request.POST.get('end') print("f_tbegin:", f_tbegin) print("f_tend:", f_tend) current_equip = Equip.objects.get(equip_id=equip_id) dat = [] if f_tbegin: 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])) print("start_date:", start_date) print("end_date:", end_date) sta1 = QXZdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)).values() for x in sta1: sta = {"upl_time": x["upl_time"].strftime('%Y-%m-%d %H:%M:%S'),"e_len": len((eval(x["qxz_data"])["data"])), "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: qxz_dict_2[i["eNum"]][0] = i["eValue"] # 将气象站字典列表里的索引值替换为 数据的eValue d = copy.deepcopy(qxz_dict_2[i["eNum"]]) # 此处有坑 如果不深拷贝 后一次 qxz_dict[i["eNum"]][0] = i["eValue"] 赋值会把上次赋值替换掉 ek = i["eKey"] d.append(ek) d.append(i["eNum"]) sta["unit"].append(d) # qxz_dict[eval(x.qxz_data)['data'][0]["eNum"]] # print(sta["unit"]) dat.append(sta) # print(dat) data = {"e_name": current_equip.equip_name, "dat": dat} data = json.dumps(data) return HttpResponse(data) # 获取当前日期： now_time = datetime.datetime.now() print("当前日期为：",now_time) print("当前月为：",now_time.month) sta1 = QXZdata.objects.filter(equip_id=equip_id, upl_time__month=now_time.month).values() for x in sta1: sta = {"upl_time": x["upl_time"].strftime('%Y-%m-%d %H:%M:%S'),"e_len": len(eval(x["qxz_data"])["data"]), "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: qxz_dict_2[i["eNum"]][0] = i["eValue"] d = copy.deepcopy(qxz_dict_2[i["eNum"]]) # 此处有坑 如果不深拷贝 后一次 qxz_dict[i["eNum"]][0] = i["eValue"] 赋值会把上次赋值替换掉 ek = i["eKey"] d.append(ek) d.append(i["eNum"]) sta["unit"].append(d) # qxz_dict[eval(x.qxz_data)['data'][0]["eNum"]] dat.append(sta) # print(dat) data = {"e_name": current_equip.equip_name, "dat": dat} # print("------",data) data = json.dumps(data) return HttpResponse(data) # 气象站列表详情 class QXZ_Report_Detail(ListView): def get(self, request): qxz_dict_3 = copy.deepcopy(qxz_dict) page = int(request.GET.get('page')) print("page:", page) equip_id = request.GET.get('id') print("equip_id:", equip_id) f_tbegin = request.GET.get('begin') f_tend = request.GET.get('end') print("f_tbegin:", f_tbegin) print("f_tend:", f_tend) current_equip = Equip.objects.get(equip_id=equip_id) dat = [] if f_tbegin: 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])) print("start_date:", start_date) print("end_date:", end_date) sta1 = QXZdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)).values() for x in sta1: sta = {"upl_time": x["upl_time"].strftime('%Y-%m-%d %H:%M:%S'), "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: qxz_dict_3[i["eNum"]][0] = i["eValue"] d = copy.deepcopy(qxz_dict_3[i["eNum"]]) # 此处有坑 如果不深拷贝 后一次 qxz_dict[i["eNum"]][0] = i["eValue"] 赋值会把上次赋值替换掉 ek = i["eKey"] d.append(ek) sta["unit"].append(d) # qxz_dict[eval(x.qxz_data)['data'][0]["eNum"]] dat.append(sta) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {"dat": dat, "nums":nums} data = json.dumps(data) return HttpResponse(data) sta1 = QXZdata.objects.filter(equip_id=equip_id).values() for x in sta1: sta = {"upl_time": x["upl_time"].strftime('%Y-%m-%d %H:%M:%S'), "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: qxz_dict_3[i["eNum"]][0] = i["eValue"] d = copy.deepcopy(qxz_dict_3[i["eNum"]]) # 此处有坑 如果不深拷贝 后一次 qxz_dict[i["eNum"]][0] = i["eValue"] 赋值会把上次赋值替换掉 ek = i["eKey"] d.append(ek) sta["unit"].append(d) dat.append(sta) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {"dat": dat, "nums":nums} data = json.dumps(data) return HttpResponse(data) class QXZ_Report_Detail2(ListView): def get(self, request): pass def post(self,request): e_id = request.POST.get("e_id") page = int(request.POST.get("page")) qxz_list = QXZdata_New.objects.filter(equip_id=e_id) f_tbegin = request.POST.get('begin') f_tend = request.POST.get('end') if f_tbegin: print("f_tbegin:", f_tbegin) print("f_tend:", f_tend) 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])) print("start_date:", start_date) print("end_date:", end_date) qxz_list = QXZdata_New.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)) data = [] for i in qxz_list: dat = {"e1":i.e1,"e2":i.e2,"e3":i.e3,"e4":i.e4,"e5":i.e5,"e6":i.e6,"e7":i.e7,"e8":i.e8,"e9":i.e9,"e10":i.e10,"e11":i.e11,"e12":i.e12,"e13":i.e13,"e14":i.e14} data.append({"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"dat":dat}) nums = len(data) data = data[(10*(page-1)):(page*10)] datas = {"data":data,"nums":nums} datas = json.dumps(datas) return HttpResponse(datas) # 气象站开关名字 class QXZ_Switch_Name(ListView): def get(self,request): pass def post(self,request): imei = request.POST.get('imei') way = request.POST.get('way') sw_name = request.POST.get('sw_name') try: switch_obj = QXZswitchdata.objects.get(equip_id=imei) except: return HttpResponse("1") sw_name_list = eval(switch_obj.qxz_switch_data) for i in sw_name_list: if i["JK"] == int(way): 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_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"} elif req == "interval": time = int(request.POST.get('time')) payload = {"cmd": "config","ext": {"interval": time}} 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 News_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/newsManage.html', context={'role':'superuser'}) def post(self,request): news_id = request.POST.get('id') news_see_id = request.POST.get("ids") # 通过后删除 if news_id: try: news_sta = CKArticle.objects.get(id=news_id) news_sta.delete() return HttpResponse("1") except: return HttpResponse("0") # 通过查看详情 art_list = CKArticle.objects.filter(id=news_see_id) dat = [] for i in art_list: dat.append({ "title":i.title, "intro":i.intro, "time": i.upl_time.strftime('%Y-%m-%d %H:%M:%S'), "img": "%s"%i.head_img, "writer":i.writer, "author":i.author.username, "content":i.content, "art_type":i.art_type, }) data = json.dumps(dat) return HttpResponse(data) # 新闻审核页面 class News_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) art_list = CKArticle.objects.filter(art_type=5,hidden=hidden) nums = art_list.count() print(nums) art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/newsManageList.html', context={"art":art,"nums":nums}) def post(self,request): art_id = request.POST.get('id') req = request.POST.get('req') art_obj = CKArticle.objects.filter(id=art_id) # 编辑 if req == "edit": data = [] for i in art_obj: data.append({ "id":i.id, "title":i.title, "intro":i.intro, "head_img":i.head_img.name, "content":i.content, "art_type":i.art_type, "writer":i.writer, "upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'), "author":i.author.username }) # 未审核删除 elif req == "del": art_obj.delete() data = "1" # 通过审核 elif req == "check": art_obj = CKArticle.objects.get(id=art_id) art_obj.hidden = True art_obj.save() data = "1" data = json.dumps(data) return HttpResponse(data) # 新闻审核上传图片接口 class News_Photo(ListView): def get(self,request): pass def post(self,request): # e_id = request.POST.get('id') # news_sta = Article.objects.get(id=e_id) news_photo = request.FILES.get('upicture') if news_photo: print("新闻图片：", news_photo) news_photo_dir = 'hnews_photo/' end_name = news_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(news_photo_dir) == False: os.makedirs(news_photo_dir) img = Image.open(news_photo) # img = img.convert('RGB') now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(news_photo_dir + pic_name) news_photo = news_photo_dir + pic_name print("new_photo:",news_photo) data = {"code": 0,"msg": "","data": {"src": news_photo}} else: new_photo = "0" data = {"code": 404,"msg": "","data": {"src": news_photo}} data = json.dumps(data) return HttpResponse(data) # 新闻发布 class News_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/newsPub.html', context={'role':'superuser'}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) news_photo = request.POST.get('upload') art_type = request.POST.get('type') writer = request.POST.get('writer') intro = request.POST.get('intro') title = request.POST.get('title') content = request.POST.get('content') news_id = request.POST.get("id") if news_id: if CKArticle.objects.filter(id=news_id).exists(): CKArticle.objects.filter(id=news_id).update( art_type=art_type, writer = writer, intro = intro, title = title, content = content, head_img = news_photo ) data= "1" else: data = "0" else: try: CKArticle.objects.create(author=current_user,art_type=art_type,writer=writer,intro=intro,title=title,content=content,head_img=news_photo) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 视频发布 class Video_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/videoPub.html', context={}) def post(self,request): # 视频标题 title = request.POST.get('title') # 视频简介 intro = request.POST.get('intro') # 视频链接 video = request.POST.get('video_url') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) video_img = request.POST.get('video_img') video_id =request.POST.get('id') if video_id: if Video_data.objects.filter(id=video_id).exists(): Video_data.objects.filter(id=video_id).update( title=title, intro=intro, video_url=video, author=current_user, video_img=video_img, ) data = '1' else: data = '0' else: try: Video_data.objects.create(title=title,intro=intro,video_url=video,author=current_user,video_img=video_img) data = "1" except Exception as e: print("-------错误信息为----------") print(e) data = "0" # else: # data = "0" return HttpResponse(data) # 视频封面上传图片接口 class Video_Photo(ListView): def get(self,request): pass def post(self,request): # e_id = request.POST.get('id') # news_sta = Article.objects.get(id=e_id) video_photo = request.FILES.get('video_img') if video_photo: print("视频图片：", video_photo) video_photo_dir = 'hvideo_photo/' end_name = video_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(video_photo_dir) == False: os.makedirs(video_photo_dir) img = Image.open(video_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(video_photo_dir + pic_name) video_photo = video_photo_dir + pic_name print("new_photo:",video_photo) data = {"code": 0,"msg": "","data": {"src": video_photo}} else: video_photo = "0" data = {"code": 404,"msg": "","data": {"src": video_photo}} data = json.dumps(data) return HttpResponse(data) # 视频上传接口 class Video_Upload(ListView): def get(self,request): pass def post(self,request): obj = request.FILES.get('upload') f = os.path.join('hvideos',obj.name).replace('\\','/') print(f) if not obj: return HttpResponse("0") dest=open(f,"wb") try: for chunk in obj.chunks(): dest.write(chunk) finally: dest.close() video_dir = "hvideos/" + obj.name data = {"code": 0,"msg": "","data": {"src":video_dir}} data = json.dumps(data) return HttpResponse(data) # 产品发布 class Equip_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/productPub.html', context={}) def post(self,request): # 产品标题 title = request.POST.get('title') # 产品简介 intro = request.POST.get('intro') # 产品内容 content = request.POST.get('content') # 产品图片 head_img = request.POST.get('img_url') mobile = request.POST.get('mobile') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) equip_id = request.POST.get("id") if equip_id: if Product.objects.filter(id=equip_id).exists(): try: Product.objects.filter(id=equip_id).update( title=title, intro=intro, content=content, author=current_user, head_img=head_img, mobile=mobile ) data = "1" except Exception as e: print("-----------错误信息为-------------") print(e) data = "0" else: data = "0" else: if head_img: try: Product.objects.create(title=title,intro=intro,content=content,author=current_user,head_img=head_img,mobile=mobile) data = "1" except Exception as e: print("-----------错误信息为-------------") print(e) data = "0" else: data = "0" return HttpResponse(data) # 产品封面上传图片接口 class Equip_Photo(ListView): def get(self,request): pass def post(self,request): pro_photo = request.FILES.get('pro_img') if pro_photo: print("视频图片：", pro_photo) pro_photo_dir = 'product_photo/' # 判断如果路径不存在，即创建路径 end_name = pro_photo.name.split('.')[-1] if os.path.exists(pro_photo_dir) == False: os.makedirs(pro_photo_dir) img = Image.open(pro_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(pro_photo_dir + pic_name) pro_photo = pro_photo_dir + pic_name print("pro_photo:",pro_photo) data = {"code": 0,"msg": "","data": {"src": pro_photo}} else: pro_photo = "0" data = {"code": 404,"msg": "","data": {"src": pro_photo}} data = json.dumps(data) return HttpResponse(data) # 采摘农场选择 class Farm_Choice(ListView): def get(self,request): pass def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) if current_user.is_staff == True: farmlist = FarmList.objects.all() else: farmlist = FarmList.objects.filter(user=current_user) dat = [] for i in farmlist: dat.append({"name":i.name}) dat = json.dumps(dat) return HttpResponse(dat) # 四季采摘图片上传 class Pick_Photo(ListView): def get(self,request): pass def post(self,request): gar_photo = request.FILES.get('gar_img') if gar_photo: print("视频图片：", gar_photo) garden_photo_dir = 'garden_photo/' end_name = gar_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(garden_photo_dir) == False: os.makedirs(garden_photo_dir) img = Image.open(gar_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(garden_photo_dir + pic_name) gar_photo = garden_photo_dir + pic_name print("gar_photo:",gar_photo) data = {"code": 0,"msg": "","data": {"src": gar_photo}} else: pro_photo = "0" data = {"code": 404,"msg": "","data": {"src": gar_photo}} data = json.dumps(data) return HttpResponse(data) # 四季采摘发布 class Garden_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/gardenPub.html', context={}) def post(self,request): farm = request.POST.get('farm') name = request.POST.get('name') time = request.POST.get('time') pick_s = request.POST.get('start') pick_e = request.POST.get('end') ripe_time = request.POST.get('ripe') # 规模 scale = request.POST.get('scale') addr = request.POST.get('addr') company = request.POST.get('company') pick_img = request.POST.get('img_url') content = request.POST.get('content') garden_id = request.POST.get('id') print("garden_id:",garden_id) # begindate = re.findall(r"\d+\.?\d*", pick_s) # enddate = re.findall(r"\d+\.?\d*", pick_e) # 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])) # 编辑更新 if garden_id: if Pick_Pub.objects.filter(id=garden_id).exists(): farm_obj = FarmList.objects.get(name=farm) Pick_Pub.objects.filter(id=garden_id).update(pick_s=pick_s,pick_e=pick_e,ripe_time=ripe_time,content=content, scale=scale,addr=addr,farm=farm_obj,name=name,company=company,pick_img=pick_img,upl_time=time) data = "1" else: data = "0" return HttpResponse(data) else: try: farm_obj = FarmList.objects.get(name=farm) Pick_Pub.objects.create(pick_s=pick_s,pick_e=pick_e,ripe_time=ripe_time,content=content, scale=scale,addr=addr,farm=farm_obj,name=name,company=company,pick_img=pick_img,upl_time=time) data = "1" print(data) except Exception as e: print("-----------报错信息为-------------") print(e) data = "0" return HttpResponse(data) # 民宿封面 class Dorm_Img(ListView): def get(self,request): pass def post(self,request): hotel_photo = request.FILES.get('hotel_photo') if hotel_photo: print("视频图片：", hotel_photo) hotel_photo_dir = 'hotel_photo/' end_name = hotel_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(hotel_photo_dir) == False: os.makedirs(hotel_photo_dir) img = Image.open(hotel_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(hotel_photo_dir + pic_name) hotel_photo = hotel_photo_dir + pic_name print("hotel_photo:",hotel_photo) data = {"code": 0,"msg": "","data": {"src": hotel_photo}} else: hotel_photo = "0" data = {"code": 404,"msg": "","data": {"src": hotel_photo}} data = json.dumps(data) return HttpResponse(data) # 民宿介绍图 class Dorm_Photo(ListView): def get(self,request): pass def post(self,request): hotel_photos = request.FILES.get('hotel_photos') if hotel_photos: print("视频图片：", hotel_photos) hotel_photo_dir = 'hotel_photos/' end_name = hotel_photos.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(hotel_photo_dir) == False: os.makedirs(hotel_photo_dir) img = Image.open(hotel_photos) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(hotel_photo_dir + pic_name) hotel_photos = hotel_photo_dir + pic_name print("hotel_photos:",hotel_photos) data = {"code": 0,"msg": "","data": {"src": hotel_photos}} else: hotel_photos = "0" data = {"code": 404,"msg": "","data": {"src": hotel_photos}} data = json.dumps(data) return HttpResponse(data) # 民宿发布 class Dorm_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/dormPub.html', context={}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) name = request.POST.get('name') price = request.POST.get('price') person = request.POST.get('person') mobile = request.POST.get('mobile') img_url = request.POST.get('img_url') addr = request.POST.get('addr') location = request.POST.get('location') intro = request.POST.get('intro') content = request.POST.get('content') pic_list = request.POST.get('pic_list') Hotel_id= request.POST.get("id") if Hotel_id: if Hotel_Info.objects.filter(id=Hotel_id).exists(): try: Hotel_Info.objects.filter(id=Hotel_id).update( name=name, price=price, intro=intro, addr=addr, location=location, person=person, hotel_img=img_url, hotel_tel=mobile, content=content, author=current_user, ) data="1" except Exception as e: print("-----------报错信息为-------------") print(e) data = "0" if data == "1": try: hotel_obj = Hotel_Info.objects.get(name=name) pic_list = pic_list.split(',') for i in pic_list: Hotel_Photo.objects.filter(hotel=hotel_obj).update(hotel=hotel_obj,addr=i) except Exception as aa: print("滚动图保存错误") print(aa) else: data = "0" return HttpResponse(data) else: try: Hotel_Info.objects.create( name=name, price=price, intro=intro, addr=addr, location=location, person=person, hotel_img=img_url, hotel_tel=mobile, content=content, author=current_user) data = "1" except Exception as e: print("-----------报错信息为-------------") print(e) data = "0" if data == "1": try: hotel_obj = Hotel_Info.objects.get(name=name) pic_list = pic_list.split(',') for i in pic_list: Hotel_Photo.objects.create(hotel=hotel_obj,addr=i) except Exception as aa: print("滚动图保存错误") print(aa) return HttpResponse(data) # 旅游发布介绍图 class Sightsee_Photo(ListView): def get(self,request): pass def post(self,request): sightsee_photos = request.FILES.get('sightsee_photos') if sightsee_photos: print("视频图片：", sightsee_photos) sightsee_photos_dir = 'sightsee_photos/' end_name = sightsee_photos.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(sightsee_photos_dir) == False: os.makedirs(sightsee_photos_dir) img = Image.open(sightsee_photos) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(sightsee_photos_dir + pic_name) sightsee_photos = sightsee_photos_dir + pic_name print("sightsee_photos:",sightsee_photos) data = {"code": 0,"msg": "","data": {"src": sightsee_photos}} else: sightsee_photos = "0" data = {"code": 404,"msg": "","data": {"src": sightsee_photos}} data = json.dumps(data) return HttpResponse(data) # 旅游发布 class Sightsee_Pub(ListView): def get(self,request): return render(request, 'backstageNet/info/SightseePub.html', context={}) def post(self,request): name = request.POST.get('name') price = request.POST.get('price') sightsee_tel = request.POST.get('mobile') sightsee_img = request.POST.get('img_url') sightsee_stime = request.POST.get('stime') sightsee_etime = request.POST.get('etime') # begindate = re.findall(r"\d+\.?\d*", sightsee_stime) # enddate = re.findall(r"\d+\.?\d*", sightsee_etime) # 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])) # 位置 location = request.POST.get('location') addr = request.POST.get('addr') # 内容 content = request.POST.get('content') # 简介 desc = request.POST.get('desc') guide_img = request.POST.get('guide_img') s_id = request.POST.get('id') if s_id: sight_obj = Sightsee_Info.objects.get(id=s_id) sight_obj.name=name sight_obj.price=price sight_obj.location=location sight_obj.sightsee_stime=sightsee_stime sight_obj.sightsee_etime=sightsee_etime sight_obj.sightsee_img=sightsee_img sight_obj.sightsee_tel=sightsee_tel sight_obj.addr=addr sight_obj.guide_img=guide_img sight_obj.content=content sight_obj.desc=desc sight_obj.save() data = "1" return HttpResponse(data) try: Sightsee_Info.objects.create( name=name, price=price, location=location, sightsee_stime=sightsee_stime, sightsee_etime=sightsee_etime, sightsee_img=sightsee_img, sightsee_tel=sightsee_tel, addr=addr, guide_img=guide_img, content=content, desc=desc) data = "1" except: data = "0" return HttpResponse(data) #我的发布 class My_Pub(ListView): def get(self,request): return render(request, 'backstageNet/infoList/myPub.html', context={}) def post(self,request): pass #我的发布列表 class My_Pub_List(ListView): def get(self,request): page = int(request.GET.get("page",1)) hidden = request.GET.get("hidden") _type = request.GET.get("type") print("----->",_type) _list = CKArticle.objects.all() if _type: _list = _list.filter(art_type=_type) if _type == "5": pub_list = CKArticle.objects.filter(art_type="5") elif _type == "6": pub_list = Video_data.objects.all() elif _type == "7": pub_list = Product.objects.all() elif _type == "8": pub_list = Pick_Pub.objects.all() elif _type == "9": pub_list = Hotel_Info.objects.all() elif _type == "10": pub_list = Sightsee_Info.objects.all() if hidden: _list = _list.filter(hidden=hidden) pub_list = pub_list.filter(hidden=hidden) nums = pub_list.count() print("nums",nums) # nums = _list.count() pub_list = pub_list[(10*(page-1)):(page*10)] art_list = _list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoList/myPubList.html', context={"pub_list":pub_list,"art_list":art_list,"nums":nums,"type":_type}) def post(self,request): pass # 视频审核 class Video_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/videoManage.html', context={'role':'superuser'}) def post(self,request): video_id = request.POST.get('id') video_see_id = request.POST.get("ids") # 审核通过后删除 if video_id: try: video_sta = Video_data.objects.get(id=video_id) video_sta.delete() return HttpResponse("1") except: return HttpResponse("0") # 审核通过查看详情 art_list = Video_data.objects.filter(id=video_see_id) dat = [] for i in art_list: dat.append({ "title":i.title, "intro":i.intro, "video_url": i.video_url.name, "time": i.publish_date.strftime('%Y-%m-%d %H:%M:%S'), "video_img": "%s"%i.video_img.name, "author":i.author.username }) data = json.dumps(dat,ensure_ascii=False) return HttpResponse(data) # 视频审核页面 class Video_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) art_list = Video_data.objects.filter(hidden=hidden) nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/videoManageList.html', context={"art":art,"nums":nums}) def post(self,request): art_id = request.POST.get('id') req = request.POST.get('req') art_obj = Video_data.objects.filter(id=art_id) # 编辑 data = [] if req == "edit": for i in art_obj: data.append({ "id":i.id, "title":i.title, "intro":i.intro, "video_img":i.video_img.name, "video_url":i.video_url.name, "author":i.author.username, "time":i.publish_date.strftime('%Y-%m-%d %H:%M:%S'), }) #删除 elif req == "del": i = Video_data.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=i.title) ckobj.delete() art_obj.delete() data = "1" #保存 elif req == "check": art_obj = Video_data.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=art_obj.title) ckobj.hidden = True ckobj.save() art_obj.hidden = True art_obj.save() data = "1" data = json.dumps(data) return HttpResponse(data) # 产品审核 class Equip_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/productManage.html', context={'role':'superuser'}) def post(self,request): delete = request.POST.get('id') product_see_id = request.POST.get("ids") # 审核通过后删除 if delete: try: video_sta = Product.objects.get(id=delete) video_sta.delete() return HttpResponse("1") except: return HttpResponse("0") # 审核通过查看详情 art_list = Product.objects.filter(id=product_see_id) dat = [] for i in art_list: dat.append({ "title":i.title, "intro":i.intro, "content": i.content, "time": i.publish_date.strftime('%Y-%m-%d %H:%M:%S'), "head_img": "%s"%i.head_img, "mobile":i.mobile, "author":i.author.username }) data = json.dumps(dat) return HttpResponse(data) # 产品审核页面 class Equip_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) art_list = Product.objects.filter(hidden=hidden) nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/productManageList.html', context={"art":art,"nums":nums}) def post(self,request): art_id = request.POST.get('id') req = request.POST.get('req') art_obj = Product.objects.filter(id=art_id) # 编辑 if req == "edit": data = [] for i in art_obj: data.append({ "id":i.id, "title":i.title, "intro":i.intro, "head_img":i.head_img, "content":i.content, "mobile":i.mobile, "author":i.author.username, "time": i.publish_date.strftime('%Y-%m-%d %H:%M:%S'), }) #删除 elif req == "del": i = Product.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=i.title) ckobj.delete() art_obj.delete() data = "1" #审核通过 elif req == "check": art_obj = Product.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=art_obj.title) ckobj.hidden = True ckobj.save() art_obj.hidden = True art_obj.save() data = "1" data = json.dumps(data) return HttpResponse(data) # 四季采摘审核 class Garden_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/pickManage.html', context={'role':'superuser'}) def post(self,request): delete = request.POST.get('id') garden_see_id = request.POST.get("ids") if delete: try: garden_sta = Pick_Pub.objects.get(id=delete) garden_sta.delete() return HttpResponse("1") except: return HttpResponse("0") art_list = Pick_Pub.objects.filter(id=garden_see_id) dat = [] # 查看详情 for i in art_list: dat.append({ "name":i.name, "company":i.company, "time": i.upl_time, "img": "%s"%i.pick_img, "farm":i.farm.name }) data = json.dumps(dat) return HttpResponse(data) # 四季采摘审核页面 class Garden_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) art_list = Pick_Pub.objects.filter(hidden=hidden) nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/pickManageList.html', context={"art":art,"nums":nums}) def post(self,request): art_id = request.POST.get('id') req = request.POST.get('req') art_obj = Pick_Pub.objects.filter(id=art_id) # 编辑 if req == "edit": data = [] for i in art_obj: data.append({ "id":i.id, "name":i.name, "company":i.company, "pick_img":i.pick_img, "time": i.upl_time, "farm":i.farm.name, "scale":i.scale, "pick_s":i.pick_s, "pick_e":i.pick_e, "ripe_time":i.ripe_time, "addr":i.addr, "content":i.content }) #删除 elif req == "del": i = Pick_Pub.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=i.name) ckobj.delete() art_obj.delete() data = "1" #审核通过 elif req == "check": art_obj = Pick_Pub.objects.get(id=art_id) art_obj.hidden = True ckobj = CKArticle.objects.get(title=art_obj.name) ckobj.hidden = True ckobj.save() art_obj.save() data = "1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 民宿审核 class Dorm_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/dormManage.html', context={'role':'superuser'}) def post(self,request): hote_see_id = request.POST.get('ids') delete = request.POST.get('id') #已通过的删除 if delete: try: hote_sta = Hotel_Info.objects.get(id=delete) hote_sta.delete() return HttpResponse("1") except: return HttpResponse("0") art_list = Hotel_Info.objects.filter(id=hote_see_id) dat = [] # 通过后查看详情 for i in art_list: dat.append({ "name":i.name, "price":i.price, "intro":i.intro, "addr":i.addr, "person":i.person, "hotel_tel":i.hotel_tel, "author":i.author.username, "content":i.content, "location":i.location, # "time": i.upl_time.strftime('%Y-%m-%d %H:%M:%S'), "img": "%s"%i.hotel_img, }) data = json.dumps(dat,ensure_ascii=False) return HttpResponse(data) # 民宿审核页面 class Dorm_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) art_list = Hotel_Info.objects.filter(hidden=hidden) nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/dormManageList.html', context={"art":art,"nums":nums}) def post(self,request): art_id = request.POST.get('id') req = request.POST.get('req') art_obj = Hotel_Info.objects.filter(id=art_id) art = Hotel_Photo.objects.filter(hotel=art_id) data = [] # 编辑 if req == "edit": for i in art_obj: data.append({ "id":i.id, "name":i.name, "price":i.price, "intro":i.intro, "addr":i.addr, "location":i.location, "person":i.person, "hotel_img":i.hotel_img, "hotel_tel":i.hotel_tel, "content":i.content, # "upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'), }) for x in art: data.append({"addr_photo":x.addr}) # data.append(x.addr) #删除 elif req == "del": i = Hotel_Info.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=i.name) ckobj.delete() art_obj.delete() data = "1" #审核通过 elif req == "check": art_obj = Hotel_Info.objects.get(id=art_id) ckobj = CKArticle.objects.get(title=art_obj.name) ckobj.hidden = True ckobj.save() art_obj.hidden = True art_obj.save() data = "1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 农场审核 class Farm_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/farmManage.html', context={'role':'superuser'}) def post(self,request): delete = request.POST.get('id') garden_see_id = request.POST.get("ids") if delete: try: garden_sta = Pick_Pub.objects.get(id=delete) garden_sta.delete() return HttpResponse("1") except: return HttpResponse("0") art_list = Pick_Pub.objects.filter(id=garden_see_id) dat = [] # 查看详情 for i in art_list: dat.append({ "name":i.name, "company":i.company, "time": i.upl_time, "img": "%s"%i.pick_img, "farm":i.farm.name }) data = json.dumps(dat) return HttpResponse(data) # 农场审核页面 class Farm_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) art_list = GardenArea.objects.filter(hidden=hidden) nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/farmManageList.html', context={"art":art,"nums":nums}) def post(self,request): art_id = request.POST.get('id') req = request.POST.get('req') art_obj = GardenArea.objects.filter(id=art_id) #删除 if req == "del": i = GardenArea.objects.get(id=art_id) # ckobj = CKArticle.objects.get(title=i.name) # ckobj.delete() art_obj.delete() data = "1" #审核通过 elif req == "check1": art_obj = GardenArea.objects.get(id=art_id) # ckobj = CKArticle.objects.get(title=art_obj.name) # ckobj.hidden = True # ckobj.save() art_obj.hidden = True art_obj.save() data = "1" #审核通过 elif req == "check0": art_obj = GardenArea.objects.get(id=art_id) art_obj.hidden = False art_obj.save() data = "1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 景点审核 class Sightsee_Check(ListView): def get(self,request): return render(request, 'backstageNet/infoManage/sightseeManage.html', context={'role':'superuser'}) def post(self,request): delete = request.POST.get('id') garden_see_id = request.POST.get("ids") if delete: try: garden_sta = Pick_Pub.objects.get(id=delete) garden_sta.delete() return HttpResponse("1") except: return HttpResponse("0") art_list = Pick_Pub.objects.filter(id=garden_see_id) dat = [] # 查看详情 for i in art_list: dat.append({ "name":i.name, "company":i.company, "time": i.upl_time, "img": "%s"%i.pick_img, "farm":i.farm.name }) data = json.dumps(dat) return HttpResponse(data) # 景点审核页面 class Sightsee_Check_List(ListView): def get(self,request): hidden = request.GET.get('hidden') page = int(request.GET.get('page')) sightsee = Sightsee_Info.objects.filter(hidden=hidden) nums = sightsee.count() sightsee = sightsee[(10*(page-1)):(page*10)] return render(request, 'backstageNet/infoManage/sightseeManageList.html', context={"sightsee":sightsee,"nums":nums}) def post(self,request): s_id = request.POST.get('id') req = request.POST.get('req') i = Sightsee_Info.objects.get(id=s_id) if req == "edit": data = {"name":i.name,"price":i.price,"desc":i.desc,"location":i.location,"addr":i.addr,"sightsee_stime":i.sightsee_stime,"sightsee_etime":i.sightsee_etime, "sightsee_img":i.sightsee_img,"sightsee_tel":i.sightsee_tel,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'),"guide_img":i.guide_img,"content":i.content} data = json.dumps(data,ensure_ascii=False) elif req == "check": ckobj = CKArticle.objects.get(title=i.name) ckobj.hidden = True ckobj.save() i.hidden = True i.save() data = "1" elif req == "del": ckobj = CKArticle.objects.get(title=i.name) ckobj.delete() i.delete() data = "1" return HttpResponse(data) # 产品发布图片上传 class Product_Photo(ListView): def get(self,request): pass def post(self,request): pass # 新闻审核上传图片接口 class Test_Photo(ListView): def get(self,request): pass def post(self,request): # e_id = request.POST.get('id') # news_sta = Article.objects.get(id=e_id) news_photo = request.FILES['upload'] if news_photo: print("新闻图片：", news_photo) news_photo_dir = 'media/uploads/' end_name = news_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(news_photo_dir) == False: os.makedirs(news_photo_dir) img = Image.open(news_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(news_photo_dir + pic_name) news_photo = news_photo_dir + pic_name print("new_photo:",news_photo) data = {"uploaded": 1,"fileName": pic_name,"url": news_photo} else: new_photo = "0" data = {"code": 404,"msg": "","data": {"src": news_photo}} data = json.dumps(data) return HttpResponse(data) class Guide_Img(ListView): def get(self,request): pass def post(self,request): # e_id = request.POST.get('id') # news_sta = Article.objects.get(id=e_id) guide_photo = request.FILES['upload'] if guide_photo: print("新闻图片：", guide_photo) news_photo_dir = 'media/uploads/' end_name = guide_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(news_photo_dir) == False: os.makedirs(news_photo_dir) img = Image.open(guide_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(news_photo_dir + pic_name) news_photo = news_photo_dir + pic_name print("new_photo:",news_photo) data = {"code": 0,"msg": "","data": {"src": news_photo}} else: new_photo = "0" data = {"code": 404,"msg": "","data": {"src": news_photo}} data = json.dumps(data) return HttpResponse(data) class CKArticle_View(ListView): def get(self,request): pass def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) news_photo = request.POST.get('upload') writer = request.POST.get('writer') intro = request.POST.get('intro') title = request.POST.get('title') art_type = request.POST.get('art_type') content = request.POST.get('content') edit = request.POST.get('edit') if edit == "1": CKArticle.objects.filter(title=title).update( art_type=art_type, writer=writer, intro=intro, title=title, content=content, head_img=news_photo ) return HttpResponse("1") if CKArticle.objects.filter(title=title).exists(): return HttpResponse("2") try: # CKArticle.objects.create(auther=current_user.username,art_type=art_type,writer=writer,intro=intro,title=title,content=content,head_img=news_photo) if art_type == "5": return HttpResponse("1") CKArticle.objects.create(art_type=art_type,writer=writer,intro=intro,title=title,content=content,head_img=news_photo) data = "1" except Exception as e: print("错误信息为",e) data = "0" return HttpResponse(data) #园区筛选 class Park_Land(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) data = [] if current_user.is_superuser != True and current_user.is_staff != True: #用户 art_list = GardenArea.objects.filter(user=current_user) else: #管理员 art_list = GardenArea.objects.all() for i in art_list: data.append({"name":i.name,"id":i.id}) data = json.dumps(data) return HttpResponse(data) # 农场管理 class Garden_Manage_New(ListView): def get(self,request): gardenid = int(request.GET.get("ids")) username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) garden = GardenArea.objects.get(id=gardenid) art_list = FarmList.objects.filter(garden=garden) nums = len(art_list) page = int(request.GET.get('page')) art = art_list[(9*(page-1)):(page*9)] return render(request, 'backstageNet/production/gardenNew.html', context={"art":art,"nums":nums}) def post(self,request): req = request.POST.get("req") farm_id = request.POST.get('id') art_list=FarmList.objects.filter(id=farm_id) print(art_list) data = [] #编辑回显数据 if req =="edit": for i in art_list: if i.manage_user: data.append({ "id":i.id, "name":i.name, "user":i.user.username, "manage_user":i.manage_user.name, "area":i.area, "curr_var":i.curr_var, "farm_img":i.farm_img, "farm_desc":i.farm_desc }) else: data.append({ "id":i.id, "name":i.name, "user":i.user.username, "manage_user":"", "area":i.area, "curr_var":i.curr_var, "farm_img":i.farm_img, "farm_desc":i.farm_desc }) #删除数据 if req == 'del': try: Pick_Pub.objects.filter(farm=farm_id).delete() FarmList.objects.filter(id=farm_id).delete() data = "1" except: data = "0" # if len(pickid) == 0: # art.delete() # data="1" # elif len(pickid) != 0: # pickid.delete() # art.delete() # data="1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 修改农场管理 class Garden_Manage_View(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) if current_user.is_staff == True: garden = GardenArea.objects.all() elif current_user.is_staff != True: garden = GardenArea.objects.filter(user=current_user) return render(request, 'backstageNet/production/gardenManage.html', context={"garden":garden}) def post(self,request): #农场id farm_id = request.POST.get('id') #农场名称 name = request.POST.get('name') #农场介绍 farm_desc = request.POST.get('content') #农场面积 area = request.POST.get('area') #农场品种 curr_var = request.POST.get('curr_var') #农场图片 farm_img = request.POST.get('img_url') #园区id gardenid = request.POST.get("ids") #修改当前数据 username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) if farm_id: try: hote_sta = FarmList.objects.filter(id=farm_id).update( name=name, farm_desc=farm_desc, area=area, curr_var=curr_var, farm_img=farm_img, user=current_user, ) data="1" except Exception as e: print(e) data="0" else: try: gardens=GardenArea.objects.get(id=gardenid) if FarmList.objects.filter(name=name,user=current_user): data = "0" else: FarmList.objects.create( name=name, farm_desc=farm_desc, area=area, curr_var=curr_var, farm_img=farm_img, user=current_user, garden=gardens ) data="1" except Exception as e: print(e) data="0" return HttpResponse(data) # 新建人员管理 class Garden_User_View(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) gardenname = request.GET.get("name") if current_user.is_staff == True: garden = GardenArea.objects.all() elif current_user.is_staff != True: garden = GardenArea.objects.filter(user=current_user) if gardenname: garden = GardenArea.objects.filter(name=gardenname) farm = FarmList.objects.filter(garden=garden[0]) if current_user.is_staff == True: garden = GardenArea.objects.all() elif current_user.is_staff != True: garden = GardenArea.objects.filter(user=current_user) return render(request, 'backstageNet/production/workerManage.html', context={"garden":garden,"farm":farm}) def post(self,request): #管理者id farm_id = request.POST.get('id') #管理者名称 name = request.POST.get('name') #性别 gender = request.POST.get('sex') #联系方式 mobile = request.POST.get('mobile') #管理农场 farm_name = request.POST.get("city") #修改 if farm_id: try: hote_sta = FarmUser.objects.filter(id=farm_id).update( name=name, gender=gender, mobile=mobile, ) data="1" if data=="1": farms =FarmUser.objects.get(name=name) farm = FarmList.objects.filter(name=farm_name).update( manage_user=farms ) data="1" except Exception as e: print(e) data="0" else: #增加 try: FarmUser.objects.create( name=name, gender=gender, mobile=mobile, ) data="1" if data=="1": farms =FarmUser.objects.get(name=name) farm = FarmList.objects.filter(name=farm_name).update( manage_user=farms ) data="1" except Exception as e: print(e) data="0" return HttpResponse(data) # 人员管理 class Garden_User_New(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) farmid = request.GET.get('id') art_list = FarmUser.objects.get(id=farmid) FarmUser.objects.all() nums = art_list.count() page = int(request.GET.get('page')) art = art_list[(9*(page-1)):(page*9)] return render(request, 'backstageNet/production/workerNew.html', context={"art":art,"nums":nums}) def post(self,request): req = request.POST.get("req") farmuser_id = request.POST.get('id') art_list = FarmUser.objects.filter(id=farmuser_id) data = [] #编辑数据回显 if req == "edit": for i in art_list: data.append({ "id":i.id, "name":i.name, "gender":i.gender, "mobile":i.mobile }) #删除 elif req == 'del': art_list.delete() data = "1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 库存新建 class Repertory_View(ListView): def get(self,request): # page = request.GET.get("page") username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) data = [] if current_user.is_superuser != True and current_user.is_staff != True: #用户 art_list = GardenArea.objects.filter(user=current_user) else: #管理员 art_list = GardenArea.objects.all() return render(request, 'backstageNet/production/repertoryManage.html', context={"art_list":art_list}) def post(self,request): uid = request.user.id #库存id store_id = request.POST.get('id') #物料名称 name = request.POST.get('name') #物料类别 rtype = request.POST.get('rtype') #规格 spec = request.POST.get('spec') #库存 rese = request.POST.get('rese') #园区 gradenid = request.POST.get('graden') #修改 if store_id: try: hote_sta = Store_Manage.objects.filter(id=store_id).update( name=name, rtype=rtype, spec=spec, rese=rese, ) data = "1" except Exception as e: print(e) data = "0" else: #新增 try: gradens=GardenArea.objects.get(id=gradenid) Store_Manage.objects.create( name=name, rtype=rtype, spec=spec, rese=rese, graden=gradens ) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 库存管理 class Repertory_New(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) ids = int(request.GET.get('ids')) try: art = GardenArea.objects.get(id=ids) art_list = Store_Manage.objects.filter(graden=art) print(art_list) except Exception as e: print(e) art_list = "" nums = len(art_list) page = int(request.GET.get('page')) art = art_list[(9*(page-1)):(page*9)] return render(request, 'backstageNet/production/repertoryNew.html', context={"art":art,"nums":nums}) def post(self,request): req = request.POST.get("req") store_id = request.POST.get('id') art_list=Store_Manage.objects.filter(id=store_id) data = [] #编辑数据回显 if req == "edit": for i in art_list: data.append({ "id":i.id, "name":i.name, "rtype":i.rtype, "spec":i.spec, "rese":i.rese }) #删除 elif req == 'del': art_list.delete() data = "1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 库存管理(出库，入库) class Repertory_New_View(ListView): def get(self,request): pass def post(self,request): req = request.POST.get("req") store_id = request.POST.get('id') num = int(request.POST.get('num')) print("num",num) art_list = Store_Manage.objects.filter(id=store_id) #出库 if req == "see": for i in art_list: res = int(i.rese) r = res-num if r >0 or r == 0: Store_Manage.objects.filter(id=store_id).update(rese=r) data = "1" else: data = "0" return HttpResponse(data) #入库 elif req == "add": for i in art_list: res = int(i.rese) r = res+num if r: Store_Manage.objects.filter(id=store_id).update(rese=r) data = "1" else: data = "0" return HttpResponse(data) # 园区下地块 class Sell_Land(ListView): def get(self,request): username = request.user.username print('username:',username) data = [] current_user = MyUser.objects.get(username=username) if current_user.is_superuser != True and current_user.is_staff != True: farm_l = GardenArea.objects.filter(user=current_user) else: farm_l = GardenArea.objects.all() for i in farm_l: print(i.id) try: farm_list = FarmList.objects.get(garden=i.id) # print(farm_list.name) farm_list = farm_list.name except: farm_list = '' data.append({"garden":i.name,"farm_name":farm_list}) data = json.dumps(data) return HttpResponse(data) #销售图片 class Sell_Photo(ListView): def post(self,request): gar_photo = request.FILES.get('gar_img') if gar_photo: print("视频图片：", gar_photo) garden_photo_dir = 'sell_photo/' end_name = gar_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(garden_photo_dir) == False: os.makedirs(garden_photo_dir) img = Image.open(gar_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(garden_photo_dir + pic_name) gar_photo = garden_photo_dir + pic_name print("gar_photo:",gar_photo) data = {"code": 0,"msg": "","data": {"src": gar_photo}} else: pro_photo = "0" data = {"code": 404,"msg": "","data": {"src": gar_photo}} data = json.dumps(data) return HttpResponse(data) # 销售管理 class Sell_View(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) area_list = GardenArea.objects.all() area_obj = GardenArea.objects.all().first() farm_list = FarmList.objects.filter(garden=area_obj) return render(request, 'backstageNet/production/sellManage.html',context={"area_list":area_list,"farm_list":farm_list}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) page = int(request.POST.get("page")) dat = [] try: # user_gar = GardenArea.objects.get(user=current_user) # farm_list = FarmList.objects.filter(garden=user_gar) if current_user.is_superuser != True and current_user.is_staff != True: farm_list = FarmList.objects.filter(garden__user=current_user) else: farm_list = FarmList.objects.all() for i in farm_list: for x in Sell_Manage.objects.filter(farm=i): dat.append({ "id":x.id, "farm":x.farm.name,"name":x.name, "num":x.num,"money":x.money, "time":x.upl_time.strftime('%Y-%m-%d'), "sell_img":x.sell_img }) except Exception as e: print(e) dat = [] nums = len(dat) dat = dat[(9*(page-1)):(page*9)] data = json.dumps({"dat":dat,"nums":nums}) return HttpResponse(data) # 销售新建 class Sell_New(ListView): def get(self,request): pass def post(self,request): farm = request.POST.get("farm") name = request.POST.get("name") num = request.POST.get("num") money = request.POST.get("money") time = request.POST.get("time") s_id = request.POST.get("id") sell_img = request.POST.get("sell_img") username = request.user.id if s_id: try: farm_obj = FarmList.objects.get(name=farm,user=username) sell_obj = Sell_Manage.objects.get(id=s_id) sell_obj.farm = farm_obj sell_obj.name = name sell_obj.num = num sell_obj.money = money sell_obj.upl_time = time sell_obj.sell_img = sell_img sell_obj.save() data = "1" except Exception as e: print(e) data = "0" else: try: farm_obj = FarmList.objects.get(name=farm,user=username) Sell_Manage.objects.create(farm=farm_obj,name=name,num=num,money=money,upl_time=time,sell_img=sell_img) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 销售删除 class Sell_Del(ListView): def get(self,request): pass def post(self,request): s_id = request.POST.get("id") try: sell_obj = Sell_Manage.objects.get(id=s_id) sell_obj.delete() data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 数据分析 class Cropdata(ListView): def get(self,request): return render(request, 'backstageNet/production/cropdata.html', context={}) def post(self,request): pass # 种植统计 class CropCount(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) gardenname = request.GET.get("name") if current_user.is_staff == True: garden = GardenArea.objects.all() elif current_user.is_staff != True: garden = GardenArea.objects.filter(user=current_user) if gardenname: garden = GardenArea.objects.filter(name=gardenname) farm = FarmList.objects.filter(garden=garden[0]) if current_user.is_staff == True: garden = GardenArea.objects.all() elif current_user.is_staff != True: garden = GardenArea.objects.filter(user=current_user) return render(request, 'backstageNet/production/cropcount.html', context={"garden":garden,"farm":farm}) def post(self,request): username = request.user.username crop_count = request.POST.get('crop_count') area = request.POST.get('area') crop_id = request.POST.get('id') upl_time = request.POST.get("upl_time") cropname = request.POST.get('cropname') city = request.POST.get("city") crop_img = request.POST.get("crop_img") count=crop_count + city print(count) #修改 if crop_id: print("修改") try: crops =FarmList.objects.get(name=area) crop = Areacrop.objects.filter(id=crop_id).update( cropname=cropname, area=crops, upl_time=upl_time, crop_count=count, crop_img=crop_img, ) data = "1" except Exception as e: print(e) data = "0" else: print("新增") #新增 try: crops =FarmList.objects.get(name=area) Areacrop.objects.create( cropname=cropname, area=crops, upl_time=upl_time, crop_count=count, crop_img=crop_img, ) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) #种植管理 class CropCount_Photo(ListView): def get(self,request): pass def post(self,request): gar_photo = request.FILES.get('gar_img') if gar_photo: print("视频图片：", gar_photo) garden_photo_dir = 'cropcount_photo/' end_name = gar_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(garden_photo_dir) == False: os.makedirs(garden_photo_dir) img = Image.open(gar_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(garden_photo_dir + pic_name) gar_photo = garden_photo_dir + pic_name print("gar_photo:",gar_photo) data = {"code": 0,"msg": "","data": {"src": gar_photo}} else: pro_photo = "0" data = {"code": 404,"msg": "","data": {"src": gar_photo}} data = json.dumps(data) return HttpResponse(data) # 种植管理 class CropCount_View(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) gardenid = request.GET.get("ids") page = int(request.GET.get("page")) dat = [] art = FarmList.objects.filter(id=gardenid) if art: for i in art: art_list = Areacrop.objects.filter(area=i) for x in art_list: time = int(x.upl_time.strftime("%Y%m%d")) time_now = int(timezone.now().strftime("%Y%m%d")) data = time_now-time print(data) curro = "" h2 = {"cropname":x.cropname, "area":x.area.name, "crop_count":x.crop_count, "img":x.area.farm_img, "time":data, "id":x.id, "upl_time":x.upl_time.strftime('%Y-%m-%d'), "crop_img":x.crop_img, } dat.append({"data":h2,"curro":curro}) nums = len(dat) dat = dat[(9*(page-1)):(page*9)] data = json.dumps({"dat":dat,"nums":nums}) return HttpResponse(data) def post(self,request): req = request.POST.get("req") areacropid = request.POST.get("id") art_list = Areacrop.objects.filter(id=areacropid) data = [] #结束时间 if req == "end": for x in art_list: Areacrop.objects.filter(id=areacropid).update( end_time=datetime.datetime.now() ) data = "1" #编辑数据返现 elif req == "edit": for i in art_list: data.append({ "id":i.id, "area":i.area.name, "crop_count":i.crop_count, "cropname":i.cropname, "upl_time":i.upl_time.strftime('%Y-%m-%d'), "crop_img":i.crop_img, }) #删除 elif req == "del": art_list.delete() data = "1" data = json.dumps(data) return HttpResponse(data) # 个人采摘 class Pick(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) try: # user_gar = GardenArea.objects.get(user=current_user) farm_list = FarmList.objects.filter(garden__user=current_user) except Exception as e: print(e) farm_list = "" nums = farm_list.count() return render(request, 'backstageNet/production/pick.html', context={"farm_list":farm_list,"nums":nums}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) page = int(request.POST.get("page")) dat = [] try: farm_list = FarmList.objects.filter(garden__user=current_user) for i in farm_list: for x in Person_Pick.objects.filter(farm=i): dat.append({ "id":x.id, "farm":x.farm.name,"name":x.name, "num":x.num,"var":x.var, "time":x.upl_time.strftime('%Y-%m-%d') }) except Exception as e: print(e) dat = [] nums = len(dat) dat = dat[(9*(page-1)):(page*9)] data = json.dumps({"dat":dat,"nums":nums}) return HttpResponse(data) # 采摘新建 class Pick_New(ListView): def get(self,request): pass def post(self,request): farm = request.POST.get("farm") name = request.POST.get("name") num = request.POST.get("num") var = request.POST.get("var") time = request.POST.get("time") p_id = request.POST.get("id") if p_id: try: farm_obj = FarmList.objects.get(name=farm) pick_obj = Person_Pick.objects.get(id=p_id) pick_obj.farm = farm_obj pick_obj.name = name pick_obj.num = num pick_obj.var = var pick_obj.upl_time = time pick_obj.save() data = "1" except Exception as e: print(e) data = "0" else: try: farm_obj = FarmList.objects.get(name=farm) Person_Pick.objects.create(farm=farm_obj,name=name,num=num,var=var,upl_time=time) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 采摘删除 class Pick_Del(ListView): def get(self,request): pass def post(self,request): p_id = request.POST.get("id") try: pick_obj = Person_Pick.objects.get(id=p_id) pick_obj.delete() data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 类型分析 class Type_View(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) area_list = GardenArea.objects.all() return render(request, 'backstageNet/datacenter/cropdata.html', context={"area_list":area_list}) def post(self,request): area = request.POST.get("id") username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) year = datetime.datetime.now().year start_1 = datetime.date(year,1,1) end_1 = datetime.date(year,3,31) start_2 = datetime.date(year,4,1) end_2 = datetime.date(year,6,30) start_3 = datetime.date(year,7,1) end_3 = datetime.date(year,9,30) start_4 = datetime.date(year,10,1) end_4 = datetime.date(year,12,31) money = 0 dat = [] dat1 = [] dat2 = [] dat3 = [] dat4 = [] start_date = datetime.datetime.now().year start_date = datetime.date(start_date,1,1) end_date = datetime.datetime.now() if area: # area_obj = GardenArea.objects.get(id=area) for i in FarmList.objects.filter(garden_id=area): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_1, end_1)): money = money + int(x.money) dat1.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(garden_id=area): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_2, end_2)): money = money + int(x.money) dat2.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(garden_id=area): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_3, end_3)): money = money + int(x.money) dat3.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(garden_id=area): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_4, end_4)): money = money + int(x.money) dat4.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(garden_id=area): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_date, end_date)): money = money + int(x.money) dat.append({"area":i.area,"name":i.name,"money":money}) money = 0 data = json.dumps({"1":dat1,"2":dat2,"3":dat3,"4":dat4,"dat":dat}) return HttpResponse(data) # 对比分析 class Contrast_View(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) area_list = GardenArea.objects.all() area_obj = GardenArea.objects.all().first() farm_list = FarmList.objects.filter(garden=area_obj) return render(request, 'backstageNet/datacenter/contrast.html', context={"area_list":area_list,"farm_list":farm_list}) def post(self,request): area_id = request.POST.get("id") farm_list = FarmList.objects.filter(garden_id=area_id) dat= [] for i in farm_list: dat.append({"name":i.name,"id":i.id}) data = json.dumps(dat) return HttpResponse(data) # 对比分析详情 class Contrast_Detail(ListView): def get(self,request): pass def post(self,request): farm_id = request.POST.get("id") year = datetime.datetime.now().year start_1 = datetime.date(year,1,1) end_1 = datetime.date(year,12,31) start_2 = datetime.date(year-1,1,1) end_2 = datetime.date(year-1,12,31) start_3 = datetime.date(year-2,1,1) end_3 = datetime.date(year-2,12,31) start_4 = datetime.date(year-3,1,1) end_4 = datetime.date(year-3,12,31) dat1 = [] dat2 = [] dat3 = [] dat4 = [] money = 0 if farm_id != "": print("+++++++++++++++++") # area_obj = GardenArea.objects.get(id=area) for i in FarmList.objects.filter(id=farm_id): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_1, end_1)): money = money + int(x.money) dat1.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(id=farm_id): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_2, end_2)): money = money + int(x.money) dat2.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(id=farm_id): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_3, end_3)): money = money + int(x.money) dat3.append({"farm":i.name,"money":money}) money = 0 for i in FarmList.objects.filter(id=farm_id): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_4, end_4)): money = money + int(x.money) dat4.append({"farm":i.name,"money":money}) money = 0 elif farm_id == "": print("--------") dat1 = [] dat2 = [] dat3 = [] dat4 = [] data = json.dumps({"1":dat1,"2":dat2,"3":dat3,"4":dat4}) return HttpResponse(data) # 对比分析列表 class Contrast_List(ListView): def get(self,request): pass def post(self,request): area_id = request.POST.get("id") page = int(request.POST.get("page")) dat = [] farm_list = FarmList.objects.filter(garden_id=area_id) for i in farm_list: for x in Sell_Manage.objects.filter(farm=i): dat.append({"name":x.farm.name,"num":x.num,"area":x.farm.area,"money":x.money,"upl_time":x.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = json.dumps({"dat":dat,"nums":nums}) return HttpResponse(data) # 产业数据 class Industry_Data(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) area_list = GardenArea.objects.all() return render(request, 'backstageNet/datacenter/industrydata.html', context={"area_list":area_list}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) area = request.POST.get("id") page = int(request.POST.get("page")) dat = [] money = 0 start_date = datetime.datetime.now().year start_date = datetime.date(start_date,1,1) end_date = datetime.datetime.now() if area: # area_obj = GardenArea.objects.get(id=area) for i in FarmList.objects.filter(garden_id=area): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_date, end_date)): money = money + int(x.money) dat.append({"farm":i.name,"money":money,"manage":i.manage_user,"area":i.area}) money = 0 else: area_obj = GardenArea.objects.get(user=current_user) for i in FarmList.objects.filter(garden=area_obj): for x in Sell_Manage.objects.filter(farm=i,upl_time__range=(start_date, end_date)): money = money + int(x.money) dat.append({"farm":i.name,"money":money,"manage":i.manage_user,"area":i.area}) money = 0 nums = len(dat) dat_split = dat[(10*(page-1)):(page*10)] data = json.dumps({"dat":dat,"nums":nums,"dat_split":dat_split}) return HttpResponse(data) # 气象站阈值设置 class QXZ_Warning_View(ListView): def get(self,request): user_name = request.user.username print('user_name=', user_name) current_user = MyUser.objects.get(username=user_name) equip_list = Equip.objects.filter(equip_user=current_user,equip_type=5) if current_user.is_staff: equip_list = Equip.objects.filter(equip_type=5) return render(request, 'backstageNet/warn/warnSet.html', context={"equip_list":equip_list}) def post(self,request): equip_id = request.POST.get('equip_id') try: alarm = QXZ_Alarm.objects.get(equip_id=equip_id).conf except: alarm = "" x = QXZ_Conf.objects.get(equip_id=equip_id) conf = {"e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5, "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10, "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14, "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18, "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22, "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26, "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30} data = {"alarm":alarm,"conf":conf} data = json.dumps(data) return HttpResponse(data) # 气象站阈值记录 class QXZ_Warning_List(ListView): def get(self,request): return render(request, 'backstageNet/warn/warnRecord.html', context={}) def post(self,request): alarm = request.POST.get('alarm') print(alarm) print(eval(alarm)["equip_id"]) e_id = eval(alarm)["equip_id"] tel = eval(alarm)["tel"] equip_obj = Equip.objects.get(equip_id=e_id) if QXZ_Alarm.objects.filter(equip_id=e_id).exists(): alarm_obj = QXZ_Alarm.objects.get(equip_id=equip_obj) alarm_obj.conf = alarm alarm_obj.tel = tel alarm_obj.save() print("修改成功") else: QXZ_Alarm.objects.create(equip_id=equip_obj,conf=alarm,tel=tel) return HttpResponse("0") # 生产方式设置 class Production_Set(ListView): def get(self,request): user_name = request.user.username print('user_name=', user_name) current_user = MyUser.objects.get(username=user_name) equip_list = Equip.objects.filter(equip_user=current_user,equip_type=5) if current_user.is_staff: equip_list = Equip.objects.filter(equip_type=5) return render(request, 'backstageNet/warn/productionset.html', context={"equip_list":equip_list}) def post(self,request): pass # 农场划分 class Farm_Mark(ListView): def get(self,request): return render(request, 'backstageNet/basicSet/farmmark.html', context={}) def post(self,request): pass # 农场列表 class Farm_List(ListView): def get(self,request): return render(request, 'backstageNet/basicSet/farmlist.html', context={}) def post(self,request): pass # 交通指引 class Traffic_Line(ListView): def get(self,request): return render(request, 'backstageNet/trafficLine/trafficLine.html', context={}) def post(self,request): pass # 管理员新闻发布 class Policy_Pub(ListView): def get(self,request): return render(request, 'backstageNet/annunciate/policyPub.html', context={}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # news_photo = request.POST.get('upload') art_type = request.POST.get('type') # writer = request.POST.get('writer') # intro = request.POST.get('intro') title = request.POST.get('title') content = request.POST.get('content') policyid = request.POST.get("id") #修改 if policyid: try: CKArticle.objects.filter(id=policyid).update(art_type=art_type,title=title,content=content,hidden=True) data = "1" except Exception as e: print(e) data = "0" #创建 else: try: CKArticle.objects.create(author=current_user,art_type=art_type,title=title,content=content,hidden=True) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 管理员新闻列表 class Policy_List_View(ListView): def get(self,request): return render(request, 'backstageNet/annunciate/policyListView.html', context={}) def post(self,request): policyid = request.POST.get("id") req = request.POST.get("req") art_list = CKArticle.objects.filter(id=policyid) data = [] #查看 if req == "see": for i in art_list: data.append({ "art_type":i.art_type, "title":i.title, "content":i.content, "time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S'), "author":i.author.username }) elif req == "del": art_list.delete() data="1" data = json.dumps(data,ensure_ascii=False) return HttpResponse(data) # 管理员新闻列表 class Policy_List(ListView): def get(self,request): page = int(request.GET.get("page")) art_list = CKArticle.objects.all().exclude(art_type=5) nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/annunciate/policyList.html', context={"art":art,"nums":nums}) def post(self,request): data = [] req = request.POST.get("req") page = int(request.POST.get("page")) print(req) if req == "": art_list = CKArticle.objects.filter(art_type__lte=2) nums = art_list.count() else: art_list = CKArticle.objects.filter(art_type=req) #筛选 nums = art_list.count() art = art_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/annunciate/policyList.html', context={"art":art,"nums":nums}) # 个人农场主页 class Person_Farm(ListView): def get(self,request): uname = request.GET.get('name') current_user = MyUser.objects.get(username=uname) news = CKArticle.objects.filter(author=current_user) garden = GardenArea.objects.get(user=current_user) video = Video_data.objects.filter(author=current_user) product = Product.objects.filter(author=current_user) return render(request, 'outerNet/person_farm.html', context={"news":news,"garden":garden,"video":video,"product":product}) def post(self,request): pass # 农场管理界面 class Person_Farm_Edit(ListView): def get(self,request): username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) print("当前用户为：", username) return render(request, 'backstageNet/production/person_farm_edit.html', context={"current_user":user}) def post(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) try: gar_area = GardenArea.objects.get(user=current_user) data = {"id":current_user.id,"name":gar_area.name,"manage":gar_area.manage,"mobile":gar_area.mobile, "area":gar_area.area,"location":gar_area.location,"location_2":gar_area.location_2,"addr":gar_area.addr, "desc":gar_area.desc,"img":gar_area.img,"guide_img":gar_area.guide_img } except Exception as e: print(e) data = {"id":"","name":"","manage":"","mobile":"", "area":"","location":"","addr":"", "desc":"","img":"","guide_img":"" } data = json.dumps(data) return HttpResponse(data) # 园区发布 class Person_Area_Pub(ListView): def get(self,request): pass def post(self,request): # current_user = MyUser.objects.get(username='admin') username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) print("当前用户为：", username) # 农场名称 name = request.POST.get('name') # 负责人 manage = request.POST.get('manage') # 联系电话 mobile = request.POST.get('mobile') # 面积 area = request.POST.get('area') # 农场介绍 desc = request.POST.get('desc') # 图片 img = request.POST.get('img') img_1 = request.POST.get('img_1') location = request.POST.get('location') location_2 = request.POST.get('location_2') addr = request.POST.get('addr') guide_img = request.POST.get('guide_img') if GardenArea.objects.filter(user=user).exists(): try: gar_obj = GardenArea.objects.get(user=user) gar_obj.name = name gar_obj.manage = manage gar_obj.mobile = mobile gar_obj.area = area gar_obj.desc = desc gar_obj.img = img gar_obj.location = location gar_obj.location_2 = location_2 gar_obj.addr = addr gar_obj.guide_img = guide_img gar_obj.img_1 = img_1 gar_obj.save() data = "1" except Exception as e: print(e) data = "0" else: try: GardenArea.objects.create(user=user,name=name,manage=manage,mobile=mobile, area=area,desc=desc,img=img,guide_img=guide_img,img_1=img_1,location_2=location_2, location=location,addr=addr) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) class Person_View(ListView): def get(self,request): # 接收当前用户 # current_user = request.session.get('username') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) page = request.GET.get("page") uname = request.GET.get("uname") user_list = MyUser.objects.all() nums = user_list.count() return render(request, 'backstageNet/systemSet/userManage.html', context={"nums": nums,"page":page,"uname":uname}) def post(self, request): pass # 地图设置 class SetMap_View(ListView): def get(self,request): # 接收当前用户 # current_user = request.session.get('username') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) page = request.GET.get("page") uname = request.GET.get("uname") user_list = MyUser.objects.all() nums = user_list.count() pic_list = Pic_Info.objects.filter(pic_user=current_user) return render(request, 'backstageNet/systemSet/mapManage.html', context={"nums": nums,"page":page,"uname":uname,"pic_list":pic_list}) def post(self, request): map_photo = request.FILES.get('upicture') if map_photo: print("地图图片：", map_photo) map_photo_dir = 'map_photo/' end_name = map_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(map_photo_dir) == False: os.makedirs(map_photo_dir) img = Image.open(map_photo) # img = img.convert('RGB') now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(map_photo_dir + pic_name) news_photo = map_photo_dir + pic_name print("new_photo:",news_photo) data = {"code": 0,"msg": "","data": {"src": news_photo}} else: new_photo = "0" data = {"code": 404,"msg": "","data": {"src": news_photo}} data = json.dumps(data) return HttpResponse(data) class Person_List(ListView): def get(self,request): page = int(request.GET.get('page')) print("page=", page) uname = request.GET.get("uname") # 接收当前用户 # current_user = request.session.get('username') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) # if current_user.is_superuser == True: user_list = MyUser.objects.all().order_by( "-date_joined")[(10*(page-1)):(page*10)] if uname: user_list = MyUser.objects.filter(username__contains=uname).order_by( "-date_joined")[(10*(page-1)):(page*10)] return render(request, 'backstageNet/systemSet/user_list.html', context={'user_list': user_list}) def post(self,request): # current_user = request.session.get('username') # print("current_user:", current_user) username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) print("筛选：") f_name = request.POST.get('uname') page = int(request.POST.get('page')) print("page:", page) user_list = MyUser.objects.filter(username__contains=f_name) nums = user_list.count() user_list = user_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/systemSet/user_list.html', context={'user_list': user_list, "nums": nums}) class Area_Create(ListView): def get(self,request): username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) currpage = request.GET.get('currpage') uname = request.GET.get("uname") f_name = request.GET.get("f_name") c_id = request.GET.get("id") user_obj = MyUser.objects.get(username=uname) try: curr_area = GardenArea.objects.get(user=user_obj) # user_area = {"name":curr_area.name,"location":curr_area.location} except Exception as e: print(e) curr_area = "" # user_area = {"name":"","location":""} return render(request, 'backstageNet/systemSet/onlineSplit.html', context={"currpage":currpage,"uname":uname,"f_name":f_name,"curr_area":curr_area,"id":c_id}) def post(self,request): uname = request.POST.get("uname") name = request.POST.get("name") area = request.POST.get("area") location = request.POST.get("location") location_2 = request.POST.get("location_2") user_obj = MyUser.objects.get(username=uname) if GardenArea.objects.filter(user=user_obj).exists(): try: area_obj = GardenArea.objects.get(user=user_obj) area_obj.name = name area_obj.area = area area_obj.location = location area_obj.location_2 = location_2 area_obj.upl_time = datetime.datetime.now() area_obj.save() data = "1" except Exception as e: print(e) data = "0" else: try: GardenArea.objects.create(user=user_obj,name=name,area=area,location=location,location_2=location_2,upl_time=datetime.datetime.now()) data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) class Area_Map(ListView): def get(self,request): return render(request, 'backstageNet/systemSet/onlineSplitMap.html', context={}) def post(self,request): uname = request.POST.get("uname") user_obj = MyUser.objects.get(username=uname) all_area = [] area_list = GardenArea.objects.all().exclude(user=user_obj) for i in area_list: all_area.append({"name":i.name,"location_2":i.location_2}) try: curr_area = GardenArea.objects.get(user=user_obj) user_area = {"name":curr_area.name,"location_2":curr_area.location_2} except Exception as e: print(e) user_area = {"name":"","location_2":""} data = json.dumps({"all_area":all_area,"user_area":user_area}) return HttpResponse(data) # 菜单权限 class Limit(ListView): def get(self,request): currpage = request.GET.get('currpage') uname = request.GET.get("uname") f_name = request.GET.get("f_name") return render(request, 'backstageNet/limit/limit.html', context={"currpage":currpage,"uname":uname,"f_name":f_name}) def post(self,request): uname = request.POST.get("uname") user_obj = MyUser.objects.get(username=uname) return HttpResponse(user_obj.limit) class Limit_View(ListView): def get(self,request): # 接收当前用户 # current_user = request.session.get('username') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) page = request.GET.get("page") uname = request.GET.get("uname") user_list = MyUser.objects.all() nums = user_list.count() return render(request, 'backstageNet/limit/limitUserManage.html', context={"nums": nums,"page":page,"uname":uname}) def post(self, request): uname = request.POST.get("uname") limit = request.POST.get("limit") user_obj = MyUser.objects.get(username=uname) try: user_obj.limit = limit user_obj.save() data = "1" except Exception as e: print("错误信息为",e) data = "0" return HttpResponse(data) class Person_Limit(ListView): def get(self,request): page = int(request.GET.get('page')) print("page=", page) uname = request.GET.get("uname") # 接收当前用户 # current_user = request.session.get('username') username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) # if current_user.is_superuser == True: user_list = MyUser.objects.all().order_by( "-date_joined")[(10*(page-1)):(page*10)] if uname: user_list = MyUser.objects.filter(username__contains=uname).order_by( "-date_joined")[(10*(page-1)):(page*10)] return render(request, 'backstageNet/limit/limit_user_list.html', context={'user_list': user_list}) def post(self,request): # current_user = request.session.get('username') # print("current_user:", current_user) username = request.user.username print('username:',username) current_user = MyUser.objects.get(username=username) print("筛选：") f_name = request.POST.get('uname') page = int(request.POST.get('page')) print("page:", page) user_list = MyUser.objects.filter(username__contains=f_name) nums = user_list.count() user_list = user_list[(10*(page-1)):(page*10)] return render(request, 'backstageNet/limit/limit_user_list.html', context={'user_list': user_list, "nums": nums}) # 专家诊断 class Expert(ListView): def get(self,request): username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) role = "0" if user.is_staff == True: role = "1" return render(request, 'backstageNet/limit/expert.html', context={"role":role}) def post(self,request): pass class learnDepot(ListView): def get(self,request): return render(request, 'backstageNet/limit/learnDepot.html', context={}) def post(self,request): pass # 创建新用户 class Create_User(ListView): def get(self,request): currpage = request.GET.get("currpage") f_name = request.GET.get("f_name") userId = request.GET.get("userId") return render(request, 'backstageNet/systemSet/creatUser.html', context={"currpage":currpage,"f_name":f_name,"userId":userId}) def post(self,request): name = request.POST.get("name") email = request.POST.get("email") phone = request.POST.get("phone") role = request.POST.get("role") user_remark = request.POST.get("desc") uid = request.POST.get("id") if uid: userobj = MyUser.objects.get(id=uid) userobj.user_phone = phone userobj.is_staff = role userobj.user_remark = user_remark userobj.save() return HttpResponse("1") if MyUser.objects.extra(where=['binary username=%s'], params=[name]).exists(): # 用户已存在！！！ data = "3" return HttpResponse(data) elif MyUser.objects.filter(email = email).exists(): # 该邮箱已注册！！！ data = "2" return HttpResponse(data) else: UserModel = get_user_model() # 创建用户： try: user = UserModel.objects.create_user(username=name, email=email,\ user_phone=phone, password="yf123456",\ is_active = 1,is_staff = int(role),user_remark = user_remark,limit = [{ "id": 1, "title": "首页", "icon": "", "url": "map", "checked": "false", "children": [] }, { "id": 3, "title": "信息发布", "icon": "", "url": "", "children": [ { "id": 3.1, "title": "新闻资讯", "url": "news_pub", }, { "id": 3.2, "title": "视频资讯", "url": "video_pub", }, { "id": 3.2, "title": "产品展厅", "url": "equip_pub", }, { "id": 3.3, "title": "四季采摘", "url": "garden_pub", }, { "id": 3.4, "title": "民宿导览", "url": "dorm_pub", }, ] }, ]) user.save() data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 管理员修改密码 class Change_Pwd(ListView): def get(self,request): pass def post(self,request): uname = request.POST.get("uname") new_pwd = request.POST.get("userpassword") print("uname:",uname) print("new_pwd:",new_pwd) user = MyUser.objects.get(username=uname) user.set_password(new_pwd) try: user.save() data = "1" except: data = "0" return HttpResponse(data) # 删除用户 class Delete_User(ListView): def get(self,request): pass def post(self,request): uname = request.POST.get("uname") try: user_obj = MyUser.objects.get(username=uname) user_obj.delete() data = "1" except Exception as e: print(e) data = "0" return HttpResponse(data) # 用户修改自己密码 class User_Change_Pwd(ListView): def get(self,request): return render(request, 'backstageNet/systemSet/changePwd.html', context={}) def post(self,request): username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) print("当前用户为：", username) oldpassword = request.POST.get('oldpassword') password = request.POST.get('password') print("post的oldpassword:", oldpassword) print("post的password:", password) if(check_password(oldpassword, user.password)): user.set_password(password) user.save() data = "1" else: data = "0" return HttpResponse(data) # 用户信息 class User_Info(ListView): def get(self,request): pass def post(self,request): uid = request.POST.get('id') user = MyUser.objects.get(id=uid) data = {"name":user.username,"email":user.email,"phone":user.user_phone,"remark":user.user_remark,"role":user.is_staff} data = json.dumps(data) return HttpResponse(data) # 气象站阈值接口 class QXZ_Auto(ListView): def get(self,request): pass def post(self,request): imei = request.POST.get('imei') try: auto_list = QXZAutoswitch.objects.get(equip_id_id=imei) qxz_list = QXZstatus.objects.get(equip_id_id=imei) data = {"qxz_list":eval(qxz_list.qxz_status)['data'],"auto_list":auto_list.qxz_auto} except: data = {"qxz_list":[],"auto_list":[]} data = json.dumps(data) return HttpResponse(data) # 气象站阈值设置接口 class QXZ_Value_Mqtt(ListView): def get(self,request): pass def post(self,request): req = request.POST.get('req') jk = request.POST.get('JK') ekey = request.POST.get('eKey') upper = request.POST.get('upper') lower = request.POST.get('lower') method = request.POST.get('method') 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) return HttpResponse("0") # 保存图片信息 class Pic_locat(ListView): def get(self,request): pass def post(self,request): username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) print("当前用户为：", username) # 东北点 locat1 = request.POST.get('locat1') # 西南点 locat2 = request.POST.get('locat2') # 图片地址 addr = request.POST.get('addr') locat_info = request.POST.get('locat_info') pic_center = request.POST.get('pic_center') if Pic_Info.objects.filter(pic_user=user).exists(): pic_obj = Pic_Info.objects.get(pic_user=user) pic_obj.locat1=locat1 pic_obj.locat2=locat2 pic_obj.pic_center=pic_center pic_obj.addr=addr pic_obj.locat_info=locat_info pic_obj.save() return HttpResponse("1") try: Pic_Info.objects.create(pic_user=user,locat1=locat1,locat2=locat2,pic_center=pic_center,addr=addr,locat_info=locat_info) return HttpResponse("1") except Exception as e: print("--->>",e) return HttpResponse("0") class Home_Farm(ListView): def get(self,request): username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) print("当前用户为：", username) farm_list = FarmList.objects.all() return render(request, 'backstageNet/home.html', context={"farm_list":farm_list}) def post(self, request): pass class Alarm_Record(ListView): def get(self,request): pass def post(self, request): alarm_list = QXZ_Alarm_Log.objects.all() page = int(request.POST.get("page")) dat = [] for i in alarm_list: dat.append({"equip_id":i.equip_id_id,"logs":i.logs,"ekey":i.ekey,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {"dat":dat,"nums":nums} data = json.dumps(data) return HttpResponse(data) class Expert_Img(ListView): def get(self,request): pass def post(self,request): # e_id = request.POST.get('id') # news_sta = Article.objects.get(id=e_id) guide_photo = request.FILES['upload'] if guide_photo: print("新闻图片：", guide_photo) news_photo_dir = 'media/uploads/' end_name = guide_photo.name.split('.')[-1] # 判断如果路径不存在，即创建路径 if os.path.exists(news_photo_dir) == False: os.makedirs(news_photo_dir) img = Image.open(guide_photo) now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.' + end_name print("pic_name:", pic_name) img.save(news_photo_dir + pic_name) news_photo = news_photo_dir + pic_name print("new_photo:",news_photo) data = {"code": 0,"msg": "","data": {"src": news_photo}} else: new_photo = "0" data = {"code": 404,"msg": "","data": {"src": news_photo}} data = json.dumps(data) return HttpResponse(data) class Expert_Info(ListView): def get(self,request): page = int(request.GET.get("page")) expert = Experts.objects.all() nums = expert.count() username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) role = "0" if user.is_staff == True: role = "1" expert = expert[(9*(page-1)):(page*9)] return render(request, 'backstageNet/limit/expertList.html', context={"expert":expert,"nums":nums,"role":role}) def post(self, request): ex_id = request.POST.get('id') if ex_id: Experts.objects.get(id=ex_id).delete() return HttpResponse("1") name = request.POST.get('name') relation = request.POST.get('relation') desc = request.POST.get('desc') pic = request.POST.get('pic') Experts.objects.create(name=name,relation=relation,desc=desc,pic=pic) return HttpResponse("1") class Add_Relation(ListView): def get(self,request): return render(request, 'backstageNet/systemSet/partners.html', context={}) def post(self, request): ex_id = request.POST.get('id') if ex_id: Relations.objects.get(id=ex_id).delete() return HttpResponse("1") name = request.POST.get('name') relation = request.POST.get('relation') desc = request.POST.get('desc') pic = request.POST.get('pic') Relations.objects.create(name=name,relation=relation,pic=pic) return HttpResponse("1") class Add_Relation_List(ListView): def get(self,request): page = int(request.GET.get("page")) partner = Relations.objects.all() nums = partner.count() partner = partner[(10*(page-1)):(page*10)] return render(request, 'backstageNet/systemSet/partnersList.html', context={"partner":partner,"nums":nums}) def post(self, request): pass class Equip_Addr(ListView): def get(self,request): pass def post(self, request): username = request.user.username print('username:',username) user = MyUser.objects.get(username=username) if user.is_staff == True: equip_list = Equip.objects.all() else: equip_list = Equip.objects.filter(equip_user=user) data = [] for i in equip_list: data.append({"equip_id":i.equip_id,"lng":i.lng,"lat":i.lat,"equip_type":i.equip_type.type_id}) data = json.dumps(data) return HttpResponse(data) class Equip_Location(ListView): def get(self,request): pass def post(self, request): eid = request.POST.get("e_id") ename = request.POST.get("ename") lng = request.POST.get("lng") lat = request.POST.get("lat") if ename: if Equip.objects.filter(equip_name=ename).exists(): return HttpResponse("0") equip_obj = Equip.objects.get(equip_id=eid) equip_obj.equip_name = ename equip_obj.save() if lat: equip_obj = Equip.objects.get(equip_id=eid) equip_obj.lng = lng equip_obj.lat = lat equip_obj.save() return HttpResponse("1") import json class Add_Qxz_Test(ListView): def get(self,request): pass def post(self, request): payload = request.body payload = json.loads(payload.decode()) print("payload",payload) print("type",type(payload)) if payload.get("cmd") == "terminalData": print("<-----uploading data!----->") extdata = payload.get("ext") print(type(extdata)) qxzdata = extdata['data'] print(qxzdata) device_id = extdata['StationID'] print(device_id) e1 = '' e2 = '' e3 = '' e4 = '' e5 = '' e6 = '' e7 = '' e8 = '' e9 = '' e10 = '' e11 = '' e12 = '' e13 = '' e14 = '' e15 = '' e16 = '' e17 = '' e18 = '' e19 = '' e20 = '' e21 = '' e22 = '' e23 = '' e24 = '' e25 = '' e26 = '' e27 = '' e28 = '' e29 = '' e30 = '' conf1 = '' conf2 = '' conf3 = '' conf4 = '' conf5 = '' conf6 = '' conf7 = '' conf8 = '' conf9 = '' conf10 = '' conf11 = '' conf12 = '' conf13 = '' conf14 = '' conf15 = '' conf16 = '' conf17 = '' conf18 = '' conf19 = '' conf20 = '' conf21 = '' conf22 = '' conf23 = '' conf24 = '' conf25 = '' conf26 = '' conf27 = '' conf28 = '' conf29 = '' conf30 = '' for i in qxzdata: if i['eKey'] == 'e1': e1 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf1 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e1[0] == "#": continue elif i['eKey'] == 'e2': e2 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf2 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e2[0] == "#": continue elif i['eKey'] == 'e3': e3 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf3 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e3[0] == "#": continue elif i['eKey'] == 'e4': e4 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf4 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e4[0] == "#": continue elif i['eKey'] == 'e5': e5 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf5 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e5[0] == "#": continue elif i['eKey'] == 'e6': e6 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf6 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e6[0] == "#": continue elif i['eKey'] == 'e7': e7 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf7 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e7[0] == "#": continue elif i['eKey'] == 'e8': e8 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf8 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e8[0] == "#": continue elif i['eKey'] == 'e9': e9 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf9 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e9[0] == "#": continue elif i['eKey'] == 'e10': e10 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf10 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e10[0] == "#": continue elif i['eKey'] == 'e11': e11 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf11 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e11[0] == "#": continue elif i['eKey'] == 'e12': e12 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf12 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e12[0] == "#": continue elif i['eKey'] == 'e13': e13 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf13 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e13[0] == "#": continue elif i['eKey'] == 'e14': e14 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf14 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e14[0] == "#": continue elif i['eKey'] == 'e15': e15 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf15 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e15[0] == "#": continue elif i['eKey'] == 'e16': e16 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf16 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e16[0] == "#": continue elif i['eKey'] == 'e17': e17 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf17 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e17[0] == "#": continue elif i['eKey'] == 'e18': e18 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf18 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e18[0] == "#": continue elif i['eKey'] == 'e19': e19 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf19 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e19[0] == "#": continue elif i['eKey'] == 'e20': e20 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf20 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e20[0] == "#": continue elif i['eKey'] == 'e21': e21 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf21 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e21[0] == "#": continue elif i['eKey'] == 'e22': e22 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf22 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e22[0] == "#": continue elif i['eKey'] == 'e23': e23 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf23 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e23[0] == "#": continue elif i['eKey'] == 'e24': e24 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf24 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e24[0] == "#": continue elif i['eKey'] == 'e25': e25 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf25 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e25[0] == "#": continue elif i['eKey'] == 'e26': e26 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf26 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e26[0] == "#": continue elif i['eKey'] == 'e27': e27 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf27 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e27[0] == "#": continue elif i['eKey'] == 'e28': e28 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf28 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e28[0] == "#": continue elif i['eKey'] == 'e29': e29 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf29 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e29[0] == "#": continue elif i['eKey'] == 'e30': e30 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf30 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e30[0] == "#": continue qxz_exist = Equip.objects.filter(equip_id=device_id) # print("extdata:", extdata) # 设备存在，进一步判断状态表是否存在： times = datetime.datetime.now() if qxz_exist.exists(): print("<-----this equip is existed!----->") try: e_id = Equip.objects.get(equip_id=device_id) except: print("<-----this equip didn't exist!----->") try: # 设备数据表直接储存数据 # QXZdata.objects.create(equip_id=e_id, qxz_data=extdata) QXZdata_New.objects.create(equip_id=e_id, e1=e1,e2=e2,e3=e3,e4=e4,e5=e5,e6=e6,e7=e7,e8=e8,e9=e9,e10=e10, e11=e11,e12=e12,e13=e13,e14=e14,e15=e15,e16=e16,e17=e17,e18=e18,e19=e19,e20=e20, e21=e21,e22=e22,e23=e23,e24=e24,e25=e25,e26=e26,e27=e27,e28=e28,e29=e29,e30=e30) print("<-----data update success!----->") except: print("<-----data update failed!----->") if QXZstatus_New.objects.filter(equip_id=e_id).exists(): print("<-----this equip's status is existed!----->") try: sta = QXZstatus_New.objects.get(equip_id=e_id) sta.e1 = e1 sta.e2 = e2 sta.e3 = e3 sta.e4 = e4 sta.e5 = e5 sta.e6 = e6 sta.e7 = e7 sta.e8 = e8 sta.e9 = e9 sta.e10 = e10 sta.e11 = e11 sta.e12 = e12 sta.e13 = e13 sta.e14 = e14 sta.e15 = e15 sta.e16 = e16 sta.e17 = e17 sta.e18 = e18 sta.e19 = e19 sta.e20 = e20 sta.e21 = e21 sta.e22 = e22 sta.e23 = e23 sta.e24 = e24 sta.e25 = e25 sta.e26 = e26 sta.e27 = e27 sta.e28 = e28 sta.e29 = e29 sta.e30 = e30 sta.is_online = "1" sta.save() print("<-----status update success!----->") except: print("<-----status update failed!----->") else: # 设备状态表不存在、创建状态表： print("<-----this equip's status is not existed!----->") try: QXZstatus_New.objects.create(equip_id=e_id, e1=e1,e2=e2,e3=e3,e4=e4,e5=e5,e6=e6,e7=e7,e8=e8,e9=e9,e10=e10, e11=e11,e12=e12,e13=e13,e14=e14,e15=e15,e16=e16,e17=e17,e18=e18,e19=e19,e20=e20, e21=e21,e22=e22,e23=e23,e24=e24,e25=e25,e26=e26,e27=e27,e28=e28,e29=e29,e30=e30,is_online="1") # QXZstatus.objects.create(equip_id=e_id, qxz_status=extdata) print("<-----this equip's status table re-create successed!----->") except: print("<-----this equip's status table re-create failed!----->") # 判断标题配置表 if QXZ_Conf.objects.filter(equip_id=e_id).exists(): print("------conf create default-------") else: QXZ_Conf.objects.create(equip_id=e_id, e1=conf1,e2=conf2,e3=conf3,e4=conf4,e5=conf5,e6=conf6,e7=conf7,e8=conf8,e9=conf9,e10=conf10, e11=conf11,e12=conf12,e13=conf13,e14=conf14,e15=conf15,e16=conf16,e17=conf17,e18=conf18,e19=conf19,e20=conf20, e21=conf21,e22=conf22,e23=conf23,e24=conf24,e25=conf25,e26=conf26,e27=conf27,e28=conf28,e29=conf29,e30=conf30) QXZ_Default_Conf.objects.create(equip_id=e_id, e1=conf1,e2=conf2,e3=conf3,e4=conf4,e5=conf5,e6=conf6,e7=conf7,e8=conf8,e9=conf9,e10=conf10, e11=conf11,e12=conf12,e13=conf13,e14=conf14,e15=conf15,e16=conf16,e17=conf17,e18=conf18,e19=conf19,e20=conf20, e21=conf21,e22=conf22,e23=conf23,e24=conf24,e25=conf25,e26=conf26,e27=conf27,e28=conf28,e29=conf29,e30=conf30) print("------conf create success-------") # 设备状态表存在、刷新状态表： print("2222222") else: print("<-----this equip not existed!----->") # 设备不存在，在设备列表中创建： try: e_type = Equip_type.objects.get(type_id="5") e_id = Equip.objects.create(equip_id=device_id, equip_type=e_type) print("<-----this imei add successed!----->") try: # 设备数据表直接储存数据 QXZdata_New.objects.create(equip_id=e_id, e1=e1,e2=e2,e3=e3,e4=e4,e5=e5,e6=e6,e7=e7,e8=e8,e9=e9,e10=e10, e11=e11,e12=e12,e13=e13,e14=e14,e15=e15,e16=e16,e17=e17,e18=e18,e19=e19,e20=e20, e21=e21,e22=e22,e23=e23,e24=e24,e25=e25,e26=e26,e27=e27,e28=e28,e29=e29,e30=e30) # QXZdata.objects.create(equip_id=e_id, qxz_data=extdata) print("<-----data update success!----->") except: print("<-----data update failed!----->") try: QXZstatus_New.objects.create(equip_id=e_id, e1=e1,e2=e2,e3=e3,e4=e4,e5=e5,e6=e6,e7=e7,e8=e8,e9=e9,e10=e10, e11=e11,e12=e12,e13=e13,e14=e14,e15=e15,e16=e16,e17=e17,e18=e18,e19=e19,e20=e20, e21=e21,e22=e22,e23=e23,e24=e24,e25=e25,e26=e26,e27=e27,e28=e28,e29=e29,e30=e30,is_online="1") # QXZstatus.objects.create(equip_id=e_id, qxz_status=extdata) print("<-----this imei register successed!----->") except: print("<-----this imei register failed!----->") # 判断标题配置表 if QXZ_Conf.objects.filter(equip_id=e_id).exists(): print("------conf create default-------") else: QXZ_Conf.objects.create(equip_id=e_id, e1=conf1,e2=conf2,e3=conf3,e4=conf4,e5=conf5,e6=conf6,e7=conf7,e8=conf8,e9=conf9,e10=conf10, e11=conf11,e12=conf12,e13=conf13,e14=conf14,e15=conf15,e16=conf16,e17=conf17,e18=conf18,e19=conf19,e20=conf20, e21=conf21,e22=conf22,e23=conf23,e24=conf24,e25=conf25,e26=conf26,e27=conf27,e28=conf28,e29=conf29,e30=conf30) QXZ_Default_Conf.objects.create(equip_id=e_id, e1=conf1,e2=conf2,e3=conf3,e4=conf4,e5=conf5,e6=conf6,e7=conf7,e8=conf8,e9=conf9,e10=conf10, e11=conf11,e12=conf12,e13=conf13,e14=conf14,e15=conf15,e16=conf16,e17=conf17,e18=conf18,e19=conf19,e20=conf20, e21=conf21,e22=conf22,e23=conf23,e24=conf24,e25=conf25,e26=conf26,e27=conf27,e28=conf28,e29=conf29,e30=conf30) print("------conf create success-------") except Exception as e: print(e) print("<-----this imei add failed!----->") if payload.get("cmd") == "Status": extdata = payload.get("ext")['terminalStatus'] print(extdata) try: volt = extdata["VOLT"] rssi = extdata["RSSI"] iccid = extdata["ICCID"] lng = extdata["longitude"] lat = extdata["latitude"] led = extdata["Dotled"] except: pass try: dver = extdata["Version"] except: dver = "" if qxz_exist.exists(): print("<-----this equip is existed!----->") try: e_id = Equip.objects.get(equip_id=device_id) except: print("<-----this equip didn't exist!----->") QXZ_Info_Record.objects.create(equip_id=e_id, volt=volt,rssi=rssi) if QXZ_Base_Info.objects.filter(equip_id=e_id).exists(): print("<-----this qxz_base_info is existed!----->") try: sta = QXZ_Base_Info.objects.get(equip_id=device_id) sta.volt = volt sta.rssi = rssi sta.iccid = iccid sta.lng = lng sta.lat = lat sta.led = led sta.dver = dver sta.save() sta1 = Equip.objects.get(equip_id=device_id) sta1.lng = lng sta1.lat = lat sta1.save() print("<-----qxz_base_info update success!----->") except: print("<-----qxz_base_info update failed!----->") try: sta = QXZ_Base_Info.objects.get(equip_id=device_id) sta.volt = volt sta.rssi = rssi sta.save() print("<-----qxz_base_info update success!!!----->") except: pass else: # 设备阈值表不存在、创建阈值表： print("<-----this qxz_base_info is not existed!----->") try: QXZ_Base_Info.objects.create(equip_id=device_id, volt=volt,rssi=rssi,iccid=iccid,lng=lng,lat=lat,led=led) print("<-----this qxz_base_info table re-create successed!----->") except: print("<-----this qxz_base_info table re-create failed!----->") return HttpResponse("1") # 气象站数据导出接口 class QXZ_Data_Export(ListView): def get(self,request): equip_id = request.GET.get('id') print("请求数据的设备id:",equip_id) f_tbegin = request.GET.get('begin') f_tend = request.GET.get('end') filename = request.GET.get('filename') print("f_tbegin:", f_tbegin) print("f_tend:", f_tend) print("f_tbegin:", type(f_tbegin)) print("f_tend:", type(f_tend)) # 查询时间段 if f_tbegin: 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])) print("start_date:", start_date) print("end_date:", end_date) sta1 = QXZdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "qxz_data": eval(x.qxz_data)["data"], "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] # 查询全部 else: sta1 = QXZdata.objects.filter(equip_id=equip_id) print("sta1:",sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "qxz_data": eval(x.qxz_data)["data"], "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] # print(sta2) try: # 遍历标题 title = [] for aaa in sta2[0]['qxz_data']: # print(qxz_dict[aaa['eNum']][1]) title.append(qxz_dict[aaa['eNum']][1]+aaa['eKey']) title.append("上报时间") print(title) # print(sta2[0]['qxz_data']) except: book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 sheet.write(0,0,"错误的时间段") # 将title数组中的字段写入到0行i列中 # 写出到IO output = BytesIO() book.save(output) # 重新定位到开始 output.seek(0) response = HttpResponse(content_type='application/vnd.ms-excel') response['Content-Disposition'] = 'attachment;filename=%s.xls'%filename response.write(output.getvalue()) return response book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 for i in range(len(title)): # 遍历列 sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中 for x in range(len(sta2)): #　遍历列表 # print("行",x) for xx in range(len(title)): print("行",x+1,"列",xx) # print(sta2[x]["qxz_data"][xx-1]) if xx+1 == len(title): # print(x+1,xx,sta2[x]["upl_time"]) sheet.write(x+1,xx,sta2[x]["upl_time"]) break # print(x+1,xx,sta2[x]["qxz_data"][xx]["eValue"]+" "+qxz_dict[sta2[x]["qxz_data"][xx]["eNum"]][2]) sheet.write(x+1,xx,sta2[x]["qxz_data"][xx]["eValue"]+" "+qxz_dict[sta2[x]["qxz_data"][xx]["eNum"]][2]) # 写出到IO output = BytesIO() book.save(output) # 重新定位到开始 output.seek(0) response = HttpResponse(content_type='application/vnd.ms-excel') response['Content-Disposition'] = 'attachment;filename=%s.xls'%filename response.write(output.getvalue()) return response def post(self,request): pass # 系统管理上传图片 class System_Photo(ListView): def get(self,request): return render(request, 'backstageNet/systemSet/imageUpload.html', context={}) def post(self,request): upl_time = timezone.now() basestr = request.FILES.get("upload") basestr1 = request.FILES.get("upload1") now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) if basestr: base_dir = 'media/uploads/' img = Image.open(basestr) code = 1 else: base_dir = 'media/uploads1/' code = 2 img = Image.open(basestr1) if os.path.exists(base_dir) == False: os.makedirs(base_dir) img.save(base_dir + now_time +".png") pic_list = SystemPhoto.objects.filter(code=code).order_by("upl_time") if code == 1: if len(pic_list) <= 2: SystemPhoto.objects.create(code=code,pic_img=base_dir +now_time +".png") else: for i in pic_list[:1]: i.pic_img=base_dir +now_time +".png" i.upl_time=upl_time i.save() else: if len(pic_list) <=3: SystemPhoto.objects.create(code=code,pic_img=base_dir +now_time +".png") else: for i in pic_list[:1]: i.pic_img=base_dir +now_time +".png" i.upl_time=upl_time i.save() return HttpResponse("1") # 系统管理上传图片 class System_Photo_Save(ListView): def post(self,request): code = request.POST.get("code") data = [] if code != "1" and code != "2": return HttpResponse("0") else: pic_list = SystemPhoto.objects.filter(code=code) for i in pic_list: data.append({ "pic_img":i.pic_img }) data = json.dumps(data) return HttpResponse(data)