# -*- coding: utf-8 -*- from django.shortcuts import render from apps.AppInfoManage.models import Equip, User_Log, MyUser from apps.AppInfoManage.models import SCDdata, SCDstatus, RecentSCDdata, YBQdata, YBQstatus, QXZstatus, QXZdata, Trapstatus, Trapdata, Trapphoto, Equip_SimInfo from apps.AppInfoManage.models import BZYdata, BZYphoto, BZYstatus, CBDdata, CBDpest, CBDphoto, CBDphoto_desc, CBDstatus, Msg_Conf, QXZAutoswitch, QXZTimingswitch, QXZ_Conf, QXZdata_New, QXZstatus_New, QXZswitchdata, QXZswitchstatus, RecentCBDdata, Spore_Exist, YBQphoto, YBQphoto from itertools import chain from django.views.generic import ListView import json # from apps.AppInfoManage.common import CJSONEncoder from apps.EquipManage.views import CJSONEncoder from django.http.response import HttpResponse from django.core import serializers import random # from io import BytesIO, StringIO import os from imutils import paths import stat import time import datetime import re import copy from django.utils.decorators import method_decorator from django.views.decorators.csrf import csrf_exempt # import xlrd from apps.SimInfo.views import get_siminfo import requests from io import BytesIO import sys from PIL import Image import argparse import cv2 import shutil import glob from .tasks import test from apps.ReportManage.all_dict import qxz_dict, insect_dict, insect_dict_new # 杀虫灯报表管理：多设备，每个设备的最新记录 def SCD_Report(request): if request.method == 'GET': # current_user = request.session.get('username') current_user = request.user.username print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # if current_user.is_superuser != True and current_user.is_staff != True: # print("---不是管理员") # equip_list = Equip.objects.filter( # equip_type=2, equip_user=current_user) # else: # print("---管理员") # equip_list = Equip.objects.filter(equip_type=2) # data = [] # for i in equip_list: # # 关键步骤：从杀虫灯数据列表模型中，筛选出当前用户所拥有的设备的设备id的数据记录，然后进行倒叙排列，最后切片操作，只取第一条数据，即为最新； # # sta1 = SCDdata.objects.filter( # # equip_id=i.equip_id).order_by('-upl_time')[:1] # # 11月22日修改,添加新的杀虫灯数据表RecentSCDdata，此表只保存最新一条数据 # sta1 = RecentSCDdata.objects.filter( # equip_id=i.equip_id) # for x in sta1: # sta2 = {"scd_data": x.scd_data, "ds": x.ds, "upl_time": x.upl_time, # "equip_name": x.equip_id.equip_name,"equip_id": x.equip_id.equip_id} # # print("sta2:",sta2) # data.append(sta2) # # print("data:",data) data = [] if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") sta1 = RecentSCDdata.objects.filter(equip_id__equip_user=current_user).values() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values() # 此句查询省级代理商下省份等于省级代理商，且市字段不为空的下属用户 # aabbcc = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, # equip_id__equip_user__user_pro=current_user.user_pro).exclude(equip_id__equip_user__user_city="") # for i in aabbcc: # print("sadsadasdasdasdasdsadas",i.equip_id) # print("46464646798981321313265465747",aabbcc) else: print("---管理员") # sta1 = RecentSCDdata.objects.filter(equip_id__equip_type=2) sta1 = RecentSCDdata.objects.all().values() print("sta1",sta1) for x in sta1: sta2 = {"scd_data": x['scd_data'], "ds": x['ds'], "upl_time": x['upl_time'], "equip_name": x['equip_name'],"equip_id": x['equip_id_id']} # sta2 = {"scd_data": x["scd_data"], "ds": x["ds"], "upl_time": x["upl_time"], # "equip_name": "无","equip_id": x["equip_id_id"]} # print("sta2:",sta2) data.append(sta2) # print("data:",data) if request.is_ajax(): req = request.GET.get('req') print("req:", req) if req == "reqdat": print("---post 请求数据！") page = int(request.GET.get('page')) print("page:", page) data = data[(10*(page-1)):(page*10)] data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) else: nums = len(data) User_Log.objects.create(log_user=current_user, log_ip=request.META['REMOTE_ADDR'], log_desc='报表管理-杀虫灯') return render(request, 'reportmanage/scd_report.html', context={"nums": nums}) if request.method == 'POST': req = request.POST.get('req') print("req:", req) if req == "filter": print("---筛选！") page = int(request.POST.get('page')) print("page:", page) ename = request.POST.get('ename') print("ename:", ename) f_id = request.POST.get('f_id') print("f_id:", f_id) current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # print("---不是管理员") # if ename == "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user) # elif ename == "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user, equip_id__contains=f_id) # elif ename != "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user, equip_name__contains=ename) # elif ename != "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user, equip_name__contains=ename,equip_id__contains=f_id) # elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # print("---代理商") # if ename == "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user) # elif ename == "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user, equip_id__contains=f_id) # elif ename != "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user, equip_name__contains=ename) # elif ename != "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=2, equip_user=current_user, equip_name__contains=ename,equip_id__contains=f_id) # else: # print("---管理员") # if ename == "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=2) # elif ename == "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=2,equip_id__contains=f_id) # elif ename != "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=2, equip_name__contains=ename) # elif ename != "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=2, equip_name__contains=ename,equip_id__contains=f_id) # dat = [] # for i in equip_list: # # 关键步骤：从杀虫灯数据列表模型中，筛选出当前用户所拥有的设备的设备id的数据记录，然后进行倒叙排列，最后切片操作，只取第一条数据，即为最新； # # sta1 = SCDdata.objects.filter( # # equip_id=i.equip_id).order_by('-upl_time')[:1] # # 11月22日修改 添加新的杀虫灯数据表RecentSCDdata，此表只保存最新一条数据 # sta1 = RecentSCDdata.objects.filter( # equip_id=i.equip_id) # for x in sta1: # sta2 = {"scd_data": x.scd_data, "ds": x.ds, "upl_time": x.upl_time, # "equip_name": x.equip_id.equip_name,"equip_id": x.equip_id.equip_id} # dat.append(sta2) dat = [] if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") if ename == "" and f_id == "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_user=current_user).values() elif ename == "" and f_id != "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_id__contains=f_id).values() elif ename != "" and f_id == "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_name__contains=ename).values() elif ename != "" and f_id != "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_name__contains=ename,equip_id__equip_id__contains=f_id).values() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") if ename == "" and f_id == "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values() elif ename == "" and f_id != "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=f_id).values() elif ename != "" and f_id == "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=ename).values() elif ename != "" and f_id != "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=ename,equip_id__equip_id__contains=f_id).values() else: print("---管理员") if ename == "" and f_id == "": sta1 = RecentSCDdata.objects.all().values() elif ename == "" and f_id != "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_id__contains=f_id).values() elif ename != "" and f_id == "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_name__contains=ename).values() elif ename != "" and f_id != "": sta1 = RecentSCDdata.objects.filter(equip_id__equip_name__contains=ename,equip_id__equip_id__contains=f_id).values() for x in sta1: sta2 = {"scd_data": x['scd_data'], "ds": x['ds'], "upl_time": x['upl_time'], "equip_name": x['equip_name'],"equip_id": x['equip_id_id']} dat.append(sta2) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 杀虫灯单个设备的表格数据筛选、分页接口： class SCD_Report_Detail(ListView): def get(self, request): equip_id = request.GET.get('id') print("请求数据，设备id：", equip_id) User_Log.objects.create(log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='报表管理-杀虫灯报表详情') # 数据总条数： nums = SCDdata.objects.filter(equip_id=equip_id).count() print("nums:", nums) ename = Equip.objects.get(equip_id=equip_id).equip_name if ename == "": ename = "无" lat = SCDstatus.objects.get(equip_id=equip_id).lat lng = SCDstatus.objects.get(equip_id=equip_id).lng return render(request, 'reportmanage/scd_report_detail.html', context={"equip_id": equip_id, "nums": nums,"ename":ename,"lat":lat,"lng":lng}) def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("equip_id:", equip_id) print("page:", page) print("请求数据的设备id：", equip_id) sta1 = SCDdata.objects.filter(equip_id=equip_id).values()[(10*(page-1)):(page*10)] print("sta1:", sta1) sta2 = [{"equip_name": "", "scd_data": x['scd_data'], "upl_time": x['upl_time']} for x in sta1] # print("sta2:",sta2) data = json.dumps(sta2, cls=CJSONEncoder) return HttpResponse(data) elif req == "filter": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("equip_id:", equip_id) print("page:", page) print("请求数据的设备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) 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 = SCDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)).values() print("sta1:", sta1) sta2 = [{"scd_data": x['scd_data'], "upl_time": x['upl_time']} for x in sta1] nums = len(sta2) dat = sta2[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # elif req == "export": # equip_id = request.POST.get('id') # print("请求数据的设备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) # 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 = SCDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) # print("sta1:", sta1) # sta2 = [{"equip_name": x.equip_id.equip_name, # "scd_data": x.scd_data, # "upl_time": x.upl_time} for x in sta1] # data = json.dumps(sta2, cls=CJSONEncoder) # # 查询全部 # else: # sta1 = SCDdata.objects.filter(equip_id=equip_id) # print("sta1:",sta1) # sta2 = [{"equip_name": x.equip_id.equip_name, # "scd_data": x.scd_data, # "upl_time": x.upl_time} for x in sta1] # data = json.dumps(sta2, cls=CJSONEncoder) # return HttpResponse(data) # 杀虫灯报表详情折线图： class SCD_Report_Detail_Chart(ListView): def get(self, request): pass def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') print("equip_id:", equip_id) # 获取当前日期： now_time = datetime.datetime.now() print("当前日期为：",now_time) print("当前月为：",now_time.month) sta1 = SCDdata.objects.filter(equip_id=equip_id,upl_time__month=now_time.month).values() sta2 = [{"at": eval(x['scd_data'])['at'], "ah": eval(x['scd_data'])['ah'], "cv": eval(x['scd_data'])['cv'], "bv": eval(x['scd_data'])['bv'], "ct": eval(x['scd_data'])['ct'], "tim": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:", data) return HttpResponse(data) elif req == "filter": 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) 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 = SCDdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)).values() sta2 = [{"at": eval(x['scd_data'])['at'], "ah": eval(x['scd_data'])['ah'], "cv": eval(x['scd_data'])['cv'], "bv": eval(x['scd_data'])['bv'], "ct": eval(x['scd_data'])['ct'], "tim": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 杀虫灯报表详情柱状图： class SCD_Report_Detail_Bar(ListView): def get(self, request): pass def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') print("equip_id:", equip_id) # 获取当前日期： now_time = datetime.datetime.now() print("now_time:", now_time) # # 测试： # now_time = datetime.datetime(2018, 1, 1,17,38) # 获取前一天日期： # 此方法bug：如果为1月1号，1减1 1减1 日减1 月减1 年再减1，太过麻烦； # last_day_now = now_time.replace(day = now_time.day-1) # 往前推一天： last_day_now = now_time + datetime.timedelta(days=-1) print("last_day_now:", last_day_now) # 格式化输出: last_day_now = json.dumps(last_day_now, cls=CJSONEncoder) print("格式化为json的last_day_now:", last_day_now) # 注意，当前日期这一天也要算上：所以天数加1 # 此方法不可取，每个月最后一天不同： # now_time = json.dumps(now_time.replace(day = now_time.day+1), cls=CJSONEncoder) # 往后推迟一天： now_time = json.dumps( now_time + datetime.timedelta(days=+1), cls=CJSONEncoder) print("格式化为json的now_time:", now_time) begindate = re.findall(r"\d+\.?\d*", last_day_now) enddate = re.findall(r"\d+\.?\d*", now_time) print("begindate:", begindate) print("enddate:", enddate) 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 = SCDdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)) sta2 = [{"at": eval(x.scd_data)['at'], "ah": eval(x.scd_data)['ah'], "cv": eval(x.scd_data)['cv'], "bv": eval(x.scd_data)['bv'], "ct": eval(x.scd_data)['ct'], "tim": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:", data) return HttpResponse(data) elif req == "filter": 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) 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 = SCDdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)) sta2 = [{ # "ct": eval(x.scd_data)['ct'], "tim": x.upl_time} for x in sta1] nums = len(sta2) # dat = sta2[(10*(page-1)):(page*10)] dat = sta2 data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) ##---------------------------诱捕器接口--------------------------- # 诱捕器报表管理：多设备，每个设备的最新记录 def YBQ_Report(request): if request.method == 'GET': # current_user = request.session.get('username') current_user = request.user.username print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) data = [] if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # print("---不是管理员") # sta1 = YBQdata.objects.filter(equip_id__equip_user=current_user) equip_list = Equip.objects.filter( equip_type=4, equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # print("---代理商") # sta1 = YBQdata.objects.filter(equip_id__equip_agency=current_user.user_agency) equip_list = Equip.objects.filter( equip_type=4, equip_agency=current_user.user_agency) else: # print("---管理员") # sta1 = YBQdata.objects.all() equip_list = Equip.objects.filter( equip_type=4) for i in equip_list: sta1 = YBQdata.objects.filter( equip_id=i.equip_id).order_by('-upl_time')[:1] for x in sta1: sta2 = {"ybq_data": x.ybq_data, "ds": x.ds, "upl_time": x.upl_time, "equip_name": x.equip_id.equip_name,"equip_id": x.equip_id.equip_id} # print("sta2:",sta2) data.append(sta2) # print("data:",data) if request.is_ajax(): req = request.GET.get('req') print("req:", req) if req == "reqdat": print("---post 请求数据！") page = int(request.GET.get('page')) print("page:", page) data = data[(10*(page-1)):(page*10)] data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) else: nums = len(data) User_Log.objects.create(log_user=current_user, log_ip=request.META['REMOTE_ADDR'], log_desc='报表管理-诱捕器') return render(request, 'reportmanage/ybq_report.html', context={"nums": nums}) if request.method == 'POST': req = request.POST.get('req') print("req:", req) if req == "filter": print("---筛选！") page = int(request.POST.get('page')) print("page:", page) ename = request.POST.get('ename') print("ename:", ename) f_id = request.POST.get('f_id') print("f_id:", f_id) current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") if ename == "" and f_id == "": equip_list = Equip.objects.filter(equip_type=4, equip_user=current_user) elif ename == "" and f_id != "": equip_list = Equip.objects.filter(equip_type=4, equip_user=current_user, equip_id__contains=f_id) elif ename != "" and f_id == "": equip_list = Equip.objects.filter(equip_type=4, equip_user=current_user, equip_name__contains=ename) elif ename != "" and f_id != "": equip_list = Equip.objects.filter(equip_type=4, equip_user=current_user, equip_name__contains=ename,equip_id__contains=f_id) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") if ename == "" and f_id == "": equip_list = Equip.objects.filter(equip_type=4, equip_agency=current_user.user_agency) elif ename == "" and f_id != "": equip_list = Equip.objects.filter(equip_type=4, equip_agency=current_user.user_agency, equip_id__contains=f_id) elif ename != "" and f_id == "": equip_list = Equip.objects.filter(equip_type=4, equip_agency=current_user.user_agency, equip_name__contains=ename) elif ename != "" and f_id != "": equip_list = Equip.objects.filter(equip_type=4, equip_agency=current_user.user_agency, equip_name__contains=ename,equip_id__contains=f_id) else: print("---管理员") if ename == "" and f_id == "": equip_list = Equip.objects.filter(equip_type=4) elif ename == "" and f_id != "": equip_list = Equip.objects.filter(equip_type=4, equip_id__contains=f_id) elif ename != "" and f_id == "": equip_list = Equip.objects.filter(equip_type=4, equip_name__contains=ename) elif ename != "" and f_id != "": equip_list = Equip.objects.filter(equip_type=4, equip_name__contains=ename, equip_id__contains=f_id) dat = [] for i in equip_list: # 关键步骤：从诱捕器数据列表模型中，筛选出当前用户所拥有的设备的设备id的数据记录，然后进行倒叙排列，最后切片操作，只取第一条数据，即为最新； sta1 = YBQdata.objects.filter( equip_id=i.equip_id).order_by('-upl_time')[:1] for x in sta1: sta2 = {"ybq_data": x.ybq_data, "ds": x.ds, "upl_time": x.upl_time, "equip_name": x.equip_id.equip_name,"equip_id": x.equip_id.equip_id} dat.append(sta2) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 诱捕器单个设备的表格数据筛选、分页接口： class YBQ_Report_Detail(ListView): def get(self, request): equip_id = request.GET.get('id') print("请求数据，设备id：", equip_id) User_Log.objects.create(log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='报表管理-诱捕器报表详情') # 数据总条数： nums = YBQdata.objects.filter(equip_id=equip_id).count() print("nums:", nums) ename = Equip.objects.get(equip_id=equip_id).equip_name if ename == "": ename = "无" lat = YBQstatus.objects.get(equip_id=equip_id).lat lng = YBQstatus.objects.get(equip_id=equip_id).lng return render(request, 'reportmanage/ybq_report_detail.html', context={"equip_id": equip_id, "nums": nums, "ename":ename, "lat":lat, "lng":lng}) def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("equip_id:", equip_id) print("page:", page) print("请求数据的设备id：", equip_id) sta1 = YBQdata.objects.filter(equip_id=equip_id)[ (10*(page-1)):(page*10)] print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "ybq_data": x.ybq_data, "upl_time": x.upl_time} for x in sta1] # print("sta2:",sta2) data = json.dumps(sta2, cls=CJSONEncoder) return HttpResponse(data) elif req == "filter": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("equip_id:", equip_id) print("page:", page) print("请求数据的设备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) 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 = YBQdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "ybq_data": x.ybq_data, "upl_time": x.upl_time} for x in sta1] nums = len(sta2) dat = sta2[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) elif req == "export": equip_id = request.POST.get('id') print("请求数据的设备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) 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 = YBQdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "ybq_data": x.ybq_data, "upl_time": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # 查询全部 else: sta1 = YBQdata.objects.filter(equip_id=equip_id) print("sta1:",sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "ybq_data": x.ybq_data, "upl_time": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) return HttpResponse(data) # 诱捕器报表详情折线图： class YBQ_Report_Detail_Chart(ListView): def get(self, request): pass def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') print("equip_id:", equip_id) # 获取当前日期： now_time = datetime.datetime.now() print("当前日期为：",now_time) print("当前月为：",now_time.month) sta1 = YBQdata.objects.filter(equip_id=equip_id,upl_time__month=now_time.month) sta2 = [{"at": eval(x.ybq_data)['at'], "ah": eval(x.ybq_data)['ah'], "cv": eval(x.ybq_data)['cv'], "bv": eval(x.ybq_data)['bv'], "ct": eval(x.ybq_data)['ct'], "tim": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:", data) return HttpResponse(data) elif req == "filter": 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) 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 = YBQdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)) sta2 = [{"at": eval(x.ybq_data)['at'], "ah": eval(x.ybq_data)['ah'], "cv": eval(x.ybq_data)['cv'], "bv": eval(x.ybq_data)['bv'], "ct": eval(x.ybq_data)['ct'], "tim": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 诱捕器报表详情柱状图： class YBQ_Report_Detail_Bar(ListView): def get(self, request): pass def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') print("equip_id:", equip_id) # 获取当前日期： now_time = datetime.datetime.now() print("now_time:", now_time) # # 测试： # now_time = datetime.datetime(2018, 1, 1,17,38) # 获取前一天日期： # 此方法bug：如果为1月1号，1减1 1减1 日减1 月减1 年再减1，太过麻烦； # last_day_now = now_time.replace(day = now_time.day-1) # 往前推一天： last_day_now = now_time + datetime.timedelta(days=-1) print("last_day_now:", last_day_now) # 格式化输出: last_day_now = json.dumps(last_day_now, cls=CJSONEncoder) print("格式化为json的last_day_now:", last_day_now) # 注意，当前日期这一天也要算上：所以天数加1 # 此方法不可取，每个月最后一天不同： # now_time = json.dumps(now_time.replace(day = now_time.day+1), cls=CJSONEncoder) # 往后推迟一天： now_time = json.dumps( now_time + datetime.timedelta(days=+1), cls=CJSONEncoder) print("格式化为json的now_time:", now_time) begindate = re.findall(r"\d+\.?\d*", last_day_now) enddate = re.findall(r"\d+\.?\d*", now_time) print("begindate:", begindate) print("enddate:", enddate) start_date = datetime.date( int(begindate[0]), int(begindate[1]), int(begindate[2])) end_date = datetime.date( int(enddate[0]), int(enddate[1]), int(enddate[2])) print("start_date:", start_date) print("end_date:", end_date) sta1 = YBQdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)) sta2 = [{"at": eval(x.ybq_data)['at'], "ah": eval(x.ybq_data)['ah'], "cv": eval(x.ybq_data)['cv'], "bv": eval(x.ybq_data)['bv'], "ct": eval(x.ybq_data)['ct'], "tim": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:", data) return HttpResponse(data) elif req == "filter": 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) 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 = YBQdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)) sta2 = [{ # "ct": eval(x.scd_data)['ct'], "tim": x.upl_time} for x in sta1] nums = len(sta2) # dat = sta2[(10*(page-1)):(page*10)] dat = sta2 data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 诱捕器上传图片测试页面： @method_decorator(csrf_exempt, name='dispatch') def ybq_imageview(request): if request.method == 'GET': print("-----image preview!-----") imei = request.GET.get('imei') print("imei:", imei) nums = YBQphoto.objects.filter(equip_id=imei).count() print("nums:", nums) return render(request, 'reportmanage/ybq_image.html', context={"nums": nums, "imei": imei}) if request.method == 'POST': print("-----image upload request!-----") imei = request.GET.get('imei') print("imei:", imei) # 判断设备是否存在： if Equip.objects.filter(equip_id=imei).exists(): length = request.META['CONTENT_LENGTH'] print("length:", length) # 以当前时间命名图片 pic_name = time.strftime( '%Y%m%d%H%M%S', time.localtime(time.time())) + '.jpg' print("pic_name:", pic_name) pic_dir = 'ybq_img/' + imei + '/' + \ pic_name[0:4] + '/' + pic_name[4:6] + '/' if os.path.exists(pic_dir) == False: # 文件夹加权限 os.makedirs(pic_dir) # os.chmod(pic_dir, stat.S_IRWXU|stat.S_IRWXG|stat.S_IRWXO) print("图片路径:", pic_dir + pic_name) # img.save(pic_dir+pic_name) with open(pic_dir + pic_name, "wb") as file: file.write(request.body) # print("request.body：", request.body) # 数据库关联设备，并在照片的表中存入路径： equip = Equip.objects.get(equip_id=imei) YBQphoto.objects.create(equip_id=equip, addr=pic_dir + pic_name) return HttpResponse("-----image upload success!-----") else: return HttpResponse("-----image upload failed because this imei is not exists!-----") # 诱捕器图片列表视图： @csrf_exempt def ybq_imagelistview(request): if request.method == 'GET': print("-----image list view!-----") imei = request.GET.get('imei') print("imei:", imei) # 获得当前页： page = int(request.GET.get('page')) print("page:", page) equip_name = Equip.objects.get(equip_id=imei).equip_name # 当前用户：返回用户，前端判断是否显示删除图片按钮 current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # 从数据库中取出照片在服务器存放路径： img = YBQphoto.objects.filter(equip_id=imei)[(8*(page-1)):(page*8)] equip_name = Equip.objects.get(equip_id=imei).equip_name return render(request, 'reportmanage/ybq_imageList.html', context={"img": img, "equip_name": equip_name, "current_user": current_user,'imei':imei}) # 删除图片接口： class YBQ_Image_Delete(ListView): def get(self, request): pass def post(self, request): print("-----image delete!-----") imei = request.POST.get('imei') img_name = request.POST.get('addr') allpic = request.POST.get('allpic') print("img_name:",img_name) if allpic == "1": all_photo = YBQphoto.objects.filter(equip_id=imei) print("-----image delete ok!-----") for i in all_photo: if os.path.exists(i.addr) == True: # 删除图片文件 os.remove(i.addr) # 删除数据库照片列表中，照片路径： try: YBQphoto.objects.filter(equip_id=imei, addr=i.addr).delete() print("-----image delete ok!-----") except: print("-----image delete failed!-----") else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: YBQphoto.objects.filter(equip_id=imei, addr=i.addr).delete() except Exception as e: print("========>>",e) print("-----image not exist!-----") return HttpResponse("0") if os.path.exists(img_name) == True: # 删除图片文件 os.remove(img_name) # 删除数据库照片列表中，照片路径： try: YBQphoto.objects.filter(equip_id=imei, addr=img_name).delete() print("-----image delete ok!-----") data = "0" return HttpResponse(data) except: print("-----image delete failed!-----") data = "1" return HttpResponse(data) else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: YBQphoto.objects.filter(equip_id=imei, addr=img_name).delete() except: pass print("-----image not exist!-----") data = "0" return HttpResponse(data) ##---------------------------测报灯接口--------------------------- # 测报灯报表管理视图： @csrf_exempt def CBD_Report(request): # current_user = request.session.get('username') # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) current_user = request.user.username print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) try: current_user = MyUser.objects.get(username=current_user) except: current_user = MyUser.objects.get(username="public") data = [] if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") role = "user" sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user).values() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") role = "agency" sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values() else: role = "superuser" print("---管理员") sta1 = RecentCBDdata.objects.all().values() for x in sta1: if CBDphoto.objects.filter(equip_id_id=x['equip_id_id']).exists(): have_photo = "1" else: have_photo = "0" sta2 = {"equip_name": x['equip_name'],"etype":x['etype'], "cbd_data": x['cbd_data'], "upl_time": x['upl_time'],"equip_id":x['equip_id_id'],"scene": x['scene'],"disc":x['disc'],"have_photo":have_photo} data.append(sta2) # if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # print("---不是管理员") # equip_list = Equip.objects.filter( # equip_type=3, equip_user=current_user).values() # elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # print("---代理商") # equip_list = Equip.objects.filter( # equip_type=3, equip_agency=current_user.user_agency).values() # else: # print("---管理员") # equip_list = Equip.objects.filter(equip_type=3).values() # data = [] # for i in equip_list: # sta1 = RecentCBDdata.objects.filter( # equip_id=i['equip_id']) # for x in sta1: # sta2 = {"equip_name": x.equip_id.equip_name, # "cbd_data": x.cbd_data, "upl_time": x.upl_time,"equip_id":x.equip_id.equip_id} # # sta1 = RecentCBDdata.objects.filter( # # equip_id=i['equip_id']).values() # # for x in sta1: # # sta2 = {"equip_name":"", # # "cbd_data": x['cbd_data'], "upl_time": x['upl_time'],"equip_id":x['equip_id_id']} # data.append(sta2) if request.method == 'GET': if request.is_ajax(): req = request.GET.get('req') print("req:", req) if req == "reqdat": print("---post 请求数据！") page = int(request.GET.get('page')) print("page:", page) data = data[(10*(page-1)):(page*10)] # data = serializers.serialize("json", equip_list) # print("data:", data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) else: nums = len(data) User_Log.objects.create(log_user=current_user, log_ip=request.META['REMOTE_ADDR'], log_desc='报表管理-测报灯') return render(request, 'reportmanage/cbd_report.html', context={"nums": nums,"role":role}) if request.method == 'POST': req = request.POST.get('req') print("req:", req) if req == "filter": print("---筛选！") page = int(request.POST.get('page')) print("page:", page) ename = request.POST.get('ename') print("ename:", ename) f_id = request.POST.get('f_id') print("f_id:", f_id) etype = request.POST.get('etype') print("etype:", etype) current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # print("---不是管理员") # if ename == "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=3, equip_user=current_user) # elif ename == "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=3, equip_user=current_user, equip_id__contains=f_id) # elif ename != "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=3, equip_user=current_user, equip_name__contains=ename) # elif ename != "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=3, equip_user=current_user, equip_name__contains=ename,equip_id__contains=f_id) # elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # print("---代理商") # if ename == "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=3, equip_agency=current_user.user_agency) # elif ename == "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=3, equip_agency=current_user.user_agency, equip_id__contains=f_id) # elif ename != "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=3, equip_agency=current_user.user_agency, equip_name__contains=ename) # elif ename != "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=3, equip_agency=current_user.user_agency, equip_name__contains=ename,equip_id__contains=f_id) # else: # print("---管理员") # if ename == "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=3) # elif ename == "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=3,equip_id__contains=f_id) # elif ename != "" and f_id == "": # equip_list = Equip.objects.filter(equip_type=3, equip_name__contains=ename) # elif ename != "" and f_id != "": # equip_list = Equip.objects.filter(equip_type=3, equip_name__contains=ename,equip_id__contains=f_id) # dat = [] # for i in equip_list: # sta1 = CBDdata.objects.filter( # equip_id=i.equip_id).order_by('-upl_time')[:1] # for x in sta1: # sta2 = {"equip_name": x.equip_id.equip_name, # "cbd_data": x.cbd_data, "upl_time": x.upl_time,"equip_id":x.equip_id.equip_id} # dat.append(sta2) dat = [] if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") if ename == "" and f_id == "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user).values() elif ename == "" and f_id != "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_id__contains=f_id).values() elif ename != "" and f_id == "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_name__contains=ename).values() elif ename != "" and f_id != "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_name__contains=ename,equip_id__equip_id__contains=f_id).values() elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") if ename == "" and f_id == "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values() elif ename == "" and f_id != "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=f_id).values() elif ename != "" and f_id == "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=ename).values() elif ename != "" and f_id != "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=ename,equip_id__equip_id__contains=f_id).values() else: print("---管理员") if ename == "" and f_id == "": sta1 = RecentCBDdata.objects.all().values() elif ename == "" and f_id != "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_id__contains=f_id).values() elif ename != "" and f_id == "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_name__contains=ename).values() elif ename != "" and f_id != "": sta1 = RecentCBDdata.objects.filter(equip_id__equip_name__contains=ename,equip_id__equip_id__contains=f_id).values() photoday = request.POST.get('photoday') dish = request.POST.get('dish') # 设备类型筛选设备 if etype != "": if etype == "全部" or etype == "" or etype == None: pass elif etype == "其他": sta1 = sta1.filter(etype=None) else: sta1 = sta1.filter(etype=etype) if dish == "square": pass elif dish == "circle": pass # print("photoday================>>",photoday) # if photoday == "": # print("全部") if photoday: now_time = datetime.datetime.now() start_time = now_time - datetime.timedelta(days=int(photoday)) for x in sta1: if CBDphoto.objects.filter(equip_id_id=x['equip_id_id'],upl_time__range=(start_time, now_time)).exists(): sta2 = {"cbd_data": x['cbd_data'],"upl_time": x['upl_time'],"scene":x['scene'],"etype":x['etype'], "equip_name": x['equip_name'],"equip_id": x['equip_id_id'],"disc":x['disc'],"have_photo":"1"} dat.append(sta2) else: for x in sta1: if CBDphoto.objects.filter(equip_id_id=x['equip_id_id']).exists(): have_photo = "1" else: have_photo = "0" sta2 = {"cbd_data": x['cbd_data'],"upl_time": x['upl_time'],"scene":x['scene'],"etype":x['etype'], "equip_name": x['equip_name'],"equip_id": x['equip_id_id'],"disc":x['disc'],"have_photo":have_photo} dat.append(sta2) # print('-----------------------',x.equip_id.equip_id) nums = len(dat) print("nums:", nums) dat = dat[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 报表详情视图： @method_decorator(csrf_exempt, name='dispatch') class CBD_Report_Detail(ListView): def get(self, request): equip_id = request.GET.get('id') print("请求数据，设备id：", equip_id) nums = CBDdata.objects.filter(equip_id=equip_id).count() print("nums:", nums) return render(request, 'reportmanage/cbd_report_detail.html', context={"equip_id": equip_id, "nums": nums}) def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("page:", page) print("请求数据的设备id：", equip_id) # data = {'dat':"",'pages':""} sta1 = CBDdata.objects.filter(equip_id=equip_id).values()[(10*(page-1)):(page*10)] sta2 = [{"equip_name": "", "cbd_data": x['cbd_data'], "upl_time": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # data['dat'] = sta2 # data['pages'] = pages # data = json.dumps(data, cls=CJSONEncoder) # print(data) return HttpResponse(data) elif req == "filter": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("equip_id:", equip_id) print("page:", page) print("请求数据的设备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) 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 = CBDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)).values() print("sta1:", sta1) sta2 = [{"equip_name":"", "cbd_data": x['cbd_data'], "upl_time": x['upl_time']} for x in sta1] nums = len(sta2) dat = sta2[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # elif req == "export": # equip_id = request.POST.get('id') # print("请求数据的设备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) # 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 = CBDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) # print("sta1:", sta1) # sta2 = [{"equip_name": x.equip_id.equip_name, # "cbd_data": x.cbd_data, # "upl_time": x.upl_time} for x in sta1] # data = json.dumps(sta2, cls=CJSONEncoder) # # 查询全部 # else: # sta1 = CBDdata.objects.filter(equip_id=equip_id) # print("sta1:",sta1) # sta2 = [{"equip_name": x.equip_id.equip_name, # "cbd_data": x.cbd_data, # "upl_time": x.upl_time} for x in sta1] # data = json.dumps(sta2, cls=CJSONEncoder) # return HttpResponse(data) # 测报灯报表详情图表视图： @method_decorator(csrf_exempt, name='dispatch') class CBD_Report_Detail_Chart(ListView): def get(self, request): pass def post(self, request): req = request.POST.get('req') print("req:", req) equip_id = request.POST.get('id') print("equip_id:", equip_id) if req == "data": # 获取当天日期： # today = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) # print("today:",today) now_time = datetime.datetime.now() # print("type now_time:",type(now_time)) # # 测试： # now_time = datetime.datetime(2018, 2, 28,17,38) # print("now_time:",now_time) # print("type now_time:",type(now_time)) # now_time2 = now_time + datetime.timedelta(days=+1) #后一天 # print("now_time2:",now_time2) # print("type now_time2:",type(now_time2)) # 上月的这一天日期： if now_time.month == 1: last_month_now = now_time.replace(year=now_time.year-1, month=12) else: try: last_month_now = now_time.replace(month=now_time.month-1) except ValueError: last_month_now = now_time.replace(month=now_time.month-1,day=now_time.day-3) print("last_month_now:", last_month_now) # 格式化输出: # last_month_now = last_month_now.strftime('%Y%m%d') last_month_now = json.dumps(last_month_now, cls=CJSONEncoder) print("格式化为json的last_month_now:", last_month_now) now_time = json.dumps( now_time + datetime.timedelta(days=+1), cls=CJSONEncoder) print("格式化为json的now_time:", now_time) begindate = re.findall(r"\d+\.?\d*", last_month_now) enddate = re.findall(r"\d+\.?\d*", now_time) print("begindate:", begindate) print("enddate:", enddate) 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 = CBDdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)).values() sta2 = [{"at": eval(x['cbd_data'])['at'], "ah": eval(x['cbd_data'])['ah'], "tim": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) elif req == "filter": f_tbegin = request.POST.get('begin') f_tend = request.POST.get('end') print("f_tbegin:", f_tbegin) print("f_tend:", 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 = CBDdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)).values() sta2 = [{"at": eval(x['cbd_data'])['at'], "ah": eval(x['cbd_data'])['ah'], "tim": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) else: sta1 = CBDdata.objects.filter( equip_id=equip_id).values() sta2 = [{"at": eval(x['cbd_data'])['at'], "ah": eval(x['cbd_data'])['ah'], "tim": x['upl_time']} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 测报灯上传图片测试页面： @method_decorator(csrf_exempt, name='dispatch') def imageview(request): if request.method == 'GET': print("-----image preview!-----") imei = request.GET.get('imei') print("imei:", imei) disc = request.GET.get('disc') nums = CBDphoto.objects.filter(equip_id=imei).count() print("nums:", nums) simid = CBDstatus.objects.get(equip_id=imei).simid dver = eval(CBDstatus.objects.get(equip_id=imei).cbd_status)["dver"] user_name = request.user.username print('user_name=', user_name) current_user = MyUser.objects.get(username=user_name) if current_user.is_superuser: role = "superuser" elif current_user.is_staff: role = "staff" elif current_user.is_agency: role = "agency" else: role = "user" end_t = datetime.datetime.now() start_t = end_t + datetime.timedelta(days=-2) # 865650044618094 rain = "0" datalist = CBDdata.objects.filter(equip_id=imei,upl_time__range=(start_t, end_t)) for i in datalist: if eval(i.cbd_data)['rps'] == 1: rain = "1" break return render(request, 'reportmanage/image.html', context={"nums": nums, "imei": imei, "disc":disc, "simid":simid, "dver":dver, "role":role,"rain":rain}) if request.method == 'POST': print("-----image upload request!-----") imei = request.GET.get('imei') print("imei:", imei) # 判断设备是否存在： if Equip.objects.filter(equip_id=imei).exists(): length = request.META['CONTENT_LENGTH'] print("length:", length) # 以当前时间命名图片 now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.jpg' print("pic_name:", pic_name) pic_dir = 'cbd_img/' + imei + '/' + \ pic_name[0:4] + '/' + pic_name[4:6] + '/' if os.path.exists(pic_dir) == False: # 文件夹加权限 os.makedirs(pic_dir) # os.chmod(pic_dir, stat.S_IRWXU|stat.S_IRWXG|stat.S_IRWXO) print("图片路径:", pic_dir + pic_name) # img.save(pic_dir+pic_name) with open(pic_dir + pic_name, "wb") as file: file.write(request.body) # print("request.body：", request.body) # 数据库关联设备，并在照片的表中存入路径： equip = Equip.objects.get(equip_id=imei) CBDphoto.objects.create(equip_id=equip, addr=pic_dir + pic_name) try: print("------------------------------------") time.sleep(3) # insect_indentify 昆虫识别 # # 保存图片之后调用害虫识别接口 img_addr = pic_dir + pic_name # img_addr = "cbd_img/862991419825259/2018/05/20180511201853.jpg" # pic_name = "862991419825259" # 正则切割文件名 去掉.jpg后缀 pattern = r'[.]' res = img_addr result = re.split(pattern, res) insect_pic_name = result[0] + 'result' + '.jpg' # 调用识别接口并获取识别结果 # url = 'http://60.166.14.184:9143/upload' url = 'http://60.166.14.184:9143/upload' # imageFile = {'imageFile':('pic.jpg',open("/home/web/yfwlw/" + img_addr,'rb'),'image/jpeg')} imageFile = {'imageFile':('pic.jpg',open("/data/yfwlw/" + img_addr,'rb'),'image/jpeg')} data = {'longitude':'118.279643','latitude':'31.221456'} print('data:',data) res = requests.post(url,data=data,files=imageFile) print("res:",res.text) resp = json.loads(res.text) print("insect_pic_name:", insect_pic_name) print("-------------------------识别成功") except Exception as e: print(e) print("---------------------识别失败") try: # 将识别结果中的链接中的图片存入本地 # pic_dir_1 = "/home/web/yfwlw/result_cbd_img/" + imei + '/' + pic_name[0:4] + '/' + pic_name[4:6] + '/' pic_dir_1 = "/data/yfwlw/result_cbd_img/" + imei + '/' + pic_name[0:4] + '/' + pic_name[4:6] + '/' print("pic_dir_1:",pic_dir_1) if os.path.exists(pic_dir_1) == False: os.makedirs(pic_dir_1) img_src = resp["returnResult"]["returnImageUrl"] response = requests.get(img_src) image = Image.open(BytesIO(response.content)) insect_image_addr = pic_dir_1 + insect_pic_name image.save(insect_image_addr) print("------------------图片保存成功") try: # 将识别结果存入数据库 pic_dir = "result_pyftp/" + os.path.join(event.path, insect_pic_name) photo_obj = CBDphoto.objects.get(addr=img_addr) photo_obj.indentify_photo = pic_dir photo_obj.indentify_result = resp["returnResult"]["returnString"] photo_obj.save() print("图片路径:", pic_dir) print("---------------数据库保存识别结果成功") except Exception as ex: print(ex) print("---------------数据库保存识别结果失败") except Exception as exc: print(exc) print("----------------识别结果图片保存失败") try: # equip = Equip.objects.get(equip_id=imei) if equip.ftp_addr: # http://www.yfzhwlw.com/cbd/pyftp/ftp_file/ykm_cbd/868575028845867/20190305/20:56:15.jpg ftp_addr = equip.ftp_addr pattern = r'[#]' split_result = re.split(pattern, ftp_addr) print("split_result:",split_result) try: need_result = split_result[1] except: print("对接设备的地址填写有误！请检查！") need_result = "0" if need_result == "1": try: r_photo = CBDphoto.objects.get(addr=img_addr).indentify_photo indentify_result_1 = CBDphoto.objects.get(addr=img_addr).indentify_result img_addr_1 = "http://120.27.222.26/" + img_addr indentify_photo_1 = "http://120.27.222.26/" + r_photo print("img_addr_1:",img_addr_1) print("indentify_photo_1:",indentify_photo_1) print("indentify_result_1:",indentify_result_1) data = { "Image":img_addr_1, "Result_image":indentify_photo_1, "Result":indentify_result_1, "imei":imei } data = json.dumps(data, cls=CJSONEncoder) print("data:",data) res_1 = requests.post(split_result[0],data=data,timeout=2) print("res_1:",res_1) print("------------------识别结果发送成功！！！") except Exception as aex: print(aex) try: img_addr_1 = "http://120.27.222.26/" + img_addr print("img_addr_1:",img_addr_1) data = { "Image":img_addr_1, "imei":imei } data = json.dumps(data, cls=CJSONEncoder) print("data:",data) print("url:",split_result[0]) res_1 = requests.post(split_result[0],data=data) except: pass print("------------------识别结果发送失败！！！") else: try: # img_addr_1 = "http://www.yfznscd.com/" + img_addr img_addr_1 = "http://120.27.222.26/" + img_addr print("img_addr_1:",img_addr_1) data = { "Image":img_addr_1, "imei":imei } data = json.dumps(data, cls=CJSONEncoder) # 14:00设备会上传一张未开启闪光灯的照片 # 照片为黑色，所以在此做处理，判断时间 为 14:00的 不往对接用户发送 # pic_time = photo_obj.upl_time # pic_time = pic_time.strftime("%Y-%m-%d %H:%M:%S") # print("图片时间为：",pic_time,type(pic_time)) # if "14:00:" in pic_time: # print("图片上传时间为14:00，所以不对外发送") # else: # data = json.dumps(data, cls=CJSONEncoder) print("data:",data) print("url:",split_result[0]) res_1 = requests.post(split_result[0],data=data) print("res_1:",res_1.text) # 判断文件大小的方法 # path = 'F:\YFWLW\yfwlw\\16_19_21.jpg' # size = os.path.getsize(path)/1024 得到结果的单位为k print("------------------对接设备图片发送成功！！！") except Exception as aexc: print(aexc) print("------------------对接设备图片发送失败！！！") except Exception as exce: print(exce) print("!!!") return HttpResponse("-----image upload success!-----") else: return HttpResponse("-----image upload failed because this imei is not exists!-----") # 测报灯上传图片测试页面2： @method_decorator(csrf_exempt, name='dispatch') def imageview2(request): if request.method == 'POST': print("-----image upload request!-----") imei = request.GET.get('imei') print("imei:", imei) if Equip.objects.filter(equip_id=imei).exists(): length = request.META['CONTENT_LENGTH'] print("length:", length) # 以当前时间命名图片 pic_name = time.strftime( '%Y%m%d%H%M%S', time.localtime(time.time())) + '.jpg' print("pic_name:", pic_name) pic_dir = 'cbd_img/' + imei + '/' + \ pic_name[0:4] + '/' + pic_name[4:6] + '/' if os.path.exists(pic_dir) == False: # 文件夹加权限 os.makedirs(pic_dir) # os.chmod(pic_dir, stat.S_IRWXU|stat.S_IRWXG|stat.S_IRWXO) print("图片路径:", pic_dir + pic_name) pic = request.FILES['img'] print("pic:",pic) img = Image.open(pic).convert('RGB') img.save('cbd_img/test.jpg') return HttpResponse("-----image upload success!-----") else: return HttpResponse("-----image upload failed because this imei is not exists!-----") # 测报灯图片列表视图： @csrf_exempt def imagelistview(request): if request.method == 'GET': print("-----image list view!-----") imei = request.GET.get('imei') print("imei:", imei) user_name = request.user.username print('user_name=', user_name) disc = request.GET.get('disc') current_user = MyUser.objects.get(username=user_name) f_begin = request.GET.get('begin') f_end = request.GET.get('end') if current_user.is_superuser: role = "superuser" elif current_user.is_staff: role = "staff" elif current_user.is_agency: role = "agency" else: role = "user" # 获得当前页： page = int(request.GET.get('page')) print("page:", page) equip_name = Equip.objects.get(equip_id=imei).equip_name # 当前用户：返回用户，前端判断是否显示删除图片按钮 current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) img = CBDphoto.objects.filter(equip_id=imei)[(8*(page-1)):(page*8)] equip_name = Equip.objects.get(equip_id=imei).equip_name nums = "" if f_begin: img = CBDphoto.objects.filter(equip_id=imei)[(8*(page-1)):(page*8)] begindate = re.findall(r"\d+\.?\d*", f_begin) enddate = re.findall(r"\d+\.?\d*", f_end) 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) img = CBDphoto.objects.filter(equip_id=imei, upl_time__range=(start_date, end_date)) nums = img.count() img = img[(8*(page-1)):(page*8)] end_t = datetime.datetime.now() start_t = end_t + datetime.timedelta(days=-2) # 865650044618094 rain = "0" datalist = CBDdata.objects.filter(equip_id=imei,upl_time__range=(start_t, end_t)) for i in datalist: if eval(i.cbd_data)['rps'] == 1: rain = "1" break return render(request, 'reportmanage/imageList.html', context={"img": img, "equip_name": equip_name, "current_user": current_user,'imei':imei,'role':role, 'disc':disc,'nums':nums,'rain':rain}) # 删除图片接口： class Image_Delete(ListView): def get(self, request): pass def post(self, request): print("-----image delete!-----") imei = request.POST.get('imei') img_name = request.POST.get('addr') img_list = request.POST.get('addrlist') allpic = request.POST.get('allpic') print("img_name:",img_name) if allpic == "1": all_photo = CBDphoto.objects.filter(equip_id=imei) print("-----image delete ok!-----") for i in all_photo: if os.path.exists(i.addr) == True: # 删除图片文件 os.remove(i.addr) # 删除数据库照片列表中，照片路径： try: CBDphoto.objects.filter(equip_id=imei, addr=i.addr).delete() print("-----image delete ok!-----") except: print("-----image delete failed!-----") else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: CBDphoto.objects.filter(equip_id=imei, addr=i.addr).delete() except Exception as e: print("========>>",e) print("-----image not exist!-----") return HttpResponse("0") if img_list: print("img_list:",type(eval(img_list))) print("img_list:",eval(img_list)) for i in eval(img_list): if os.path.exists(i) == True: # 删除图片文件 os.remove(i) # 删除数据库照片列表中，照片路径： try: CBDphoto.objects.filter(equip_id=imei, addr=i).delete() print("-----image delete ok!-----") except: print("-----image delete failed!-----") else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: CBDphoto.objects.filter(equip_id=imei, addr=i).delete() except Exception as e: print("========>>",e) print("-----image not exist!-----") data = "0" return HttpResponse(data) if os.path.exists(img_name) == True: # 删除图片文件 os.remove(img_name) # 删除数据库照片列表中，照片路径： try: CBDphoto.objects.filter(equip_id=imei, addr=img_name).delete() print("-----image delete ok!-----") data = "1" return HttpResponse(data) except: print("-----image delete failed!-----") data = "0" return HttpResponse(data) else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: CBDphoto.objects.filter(equip_id=imei, addr=img_name).delete() except: pass print("-----image not exist!-----") data = "0" return HttpResponse(data) # 图片描述接口： @method_decorator(csrf_exempt, name='dispatch') class Image_Desc(ListView): def get(self, request): req = request.GET.get('req') print('req:',req) current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # 请求害虫种类列表： if req == "pest_kind": print("-----get req:pestkind !-----") pest_kinds = CBDpest.objects.filter(user=current_user) data = [{"pest_name": x.pest_name,} for x in pest_kinds] data = json.dumps(data) print('data:',data) return HttpResponse(data) # 请求图片描述： elif req == "desc": print("-----get req:desc !-----") img_name = request.GET.get('addr') print("img_name:",img_name) print("type img_name:",type(img_name)) descs = CBDphoto_desc.objects.filter(photo_id=CBDphoto.objects.get(addr=img_name),desc_user=current_user) data = [{"crop_name": x.crop_name, "pest_case": x.pest_case, "pest_name": x.pest_name.pest_name, "pest_num":x.pest_num} for x in descs] print("data:",data) data = json.dumps(data) return HttpResponse(data) # 增加害虫种类： elif req == "add_pest": print("-----get req:add_pest !-----") pest = request.GET.get('pest') print("pest:",pest) # 如果该用户下的该害虫名称已经存在！ if CBDpest.objects.filter(user=current_user,pest_name=pest).exists(): data = '1' return HttpResponse(data) try: CBDpest.objects.create(user=current_user,pest_name=pest) pest_kinds = CBDpest.objects.filter(user=current_user) data = [{"pest_name": x.pest_name,} for x in pest_kinds] data = json.dumps(data) print('data:',data) return HttpResponse(data) except: data = '2' return HttpResponse(data) # 删除害虫种类： elif req == "del_pest": print("-----get req:del_pest !-----") pests = request.GET.get('pest') pests = json.loads(pests) for i in pests: CBDpest.objects.filter(user=current_user,pest_name=i).delete() pest_kinds = CBDpest.objects.filter(user=current_user) data = [{"pest_name": x.pest_name,} for x in pest_kinds] data = json.dumps(data) print('data:',data) return HttpResponse(data) def post(self, request): req = request.POST.get('req') print('req:',req) current_user = request.session.get('username') current_user = MyUser.objects.get(username=current_user) img_name = request.POST.get('addr') print('img_name:',img_name) photo_time = request.POST.get('photo_time') desc = request.POST.get('describe') # print("json的desc：",desc) desc = json.loads(desc) # print("转为dict的desc：",desc) # 增加描述： if req == "add_save": print("-----add image describe --post!-----") print("desc['pest_name']:",desc['pest_name']) print("desc['pest_num']:",desc['pest_num']) print("desc['crop_name']:",desc['crop_name']) print("desc['pest_case']:",desc['pest_case']) if CBDphoto_desc.objects.filter(desc_user=current_user, photo_id = CBDphoto.objects.get(addr=img_name), pest_name=CBDpest.objects.get(user=current_user, pest_name=desc['pest_name'])).exists(): data = '2' return HttpResponse(data) try: CBDphoto_desc.objects.create( desc_user = current_user, photo_id = CBDphoto.objects.get(addr=img_name), pest_name = CBDpest.objects.get(user=current_user,pest_name=desc['pest_name']), pest_num = desc['pest_num'], crop_name = desc['crop_name'], pest_case = desc['pest_case'], pest_name2 = desc['pest_name'], photo_time = photo_time, photo_time1 = CBDphoto.objects.get(addr=img_name).upl_time, equip_id = CBDphoto.objects.get(addr=img_name).equip_id_id ) print("-----image add describe ok!-----") data = "0" return HttpResponse(data) except: print("-----image add describe failed!-----") data = "1" return HttpResponse(data) # 修改描述： elif req == "change_save": print("-----change image describe --post!-----") print("desc['pest_name']:",desc['pest_name']) print("desc['pest_num']:",desc['pest_num']) print("desc['crop_name']:",desc['crop_name']) print("desc['pest_case']:",desc['pest_case']) try: CBDphoto_desc.objects.filter(desc_user = current_user ,photo_id = CBDphoto.objects.get(addr=img_name) # ,pest_name = CBDpest.objects.get(pest_name=desc['pest_name']) ,pest_name = CBDpest.objects.get(user=current_user,pest_name=desc['pest_name']) ).update(pest_num = desc['pest_num'] ,crop_name = desc['crop_name'] ,pest_case = desc['pest_case'] ,pest_name2 = desc['pest_name']) print("-----change image describe ok!-----") data = "0" return HttpResponse(data) except: print("-----change image describe failed!-----") data = "1" return HttpResponse(data) # 删除描述： elif req == "del_desc": print("-----del image describe --post!-----") print("desc['pest_name']:",desc['pest_name']) try: CBDphoto_desc.objects.filter(desc_user = current_user ,photo_id = CBDphoto.objects.get(addr=img_name) # ,pest_name = CBDpest.objects.get(pest_name=desc['pest_name']) ,pest_name = CBDpest.objects.get(user=current_user,pest_name=desc['pest_name']) ).delete() print("-----delete image describe ok!-----") data = "0" return HttpResponse(data) except: print("-----delete image describe failed!-----") data = "1" return HttpResponse(data) # 图片害虫数据统计接口： @method_decorator(csrf_exempt, name='dispatch') class Pest_Data(ListView): def get(self, request): return render(request, 'reportmanage/cbd_pest_data.html', context={}) def post(self, request): current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # 先通过imei：查到时间段的照片： # imei = '012345' imei = request.POST.get('imei') print("============>>",imei) tbegin = request.POST.get('tbegin') tend = request.POST.get('tend') # 首次查看统计，默认为最近一个月的照片描述： if tbegin: begindate = re.findall(r"\d+\.?\d*", tbegin) enddate = re.findall(r"\d+\.?\d*", tend) print("begindate:", begindate) print("enddate:", enddate) 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])) # photos = CBDphoto.objects.filter(equip_id=Equip.objects.get(equip_id=imei),upl_time__range=(start_date, end_date)) des = CBDphoto_desc.objects.filter(equip_id=imei,desc_user=current_user,photo_time1__range=(start_date, end_date)).values() else: # 获取当前日期： now_time = datetime.datetime.now() # 往前推一个月： if now_time.month == 1: last_month_now = now_time.replace(year=now_time.year-1, month=12) else: try: last_month_now = now_time.replace(month=now_time.month-1) except ValueError: last_month_now = now_time.replace(month=now_time.month-1,day=now_time.day-3) tbegin = last_month_now tend = now_time + datetime.timedelta(days=+1) # photos = CBDphoto.objects.filter(equip_id=Equip.objects.get(equip_id=imei),upl_time__range=(tbegin, tend)) des = CBDphoto_desc.objects.filter(equip_id=imei,desc_user=current_user,photo_time1__range=(tbegin, tend)).values() data = [] des = CBDphoto_desc.objects.filter(equip_id=imei,desc_user=current_user).values() for ii in des: # 遍历一条描述，获取描述的信息： desc = { "pest_num":ii['pest_num'], "pest_name":ii['pest_name2'], "crop_name":ii['crop_name'], "pest_case":ii['pest_case'], "add_time":ii['photo_time1'] } data.append(desc) print('data:',data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 害虫统计的表格数据： @method_decorator(csrf_exempt, name='dispatch') class Pest_TableData(ListView): def get(self, request): pass def post(self, request): current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) # 得到imei imei = request.POST.get('imei') print("imei:", imei) pest_name = request.POST.get("pest_name") tbegin = request.POST.get("tbegin") tend = request.POST.get("tend") # photos = CBDphoto.objects.filter(equip_id_id=imei).values() # if tbegin: # photos = CBDphoto.objects.filter(equip_id=Equip.objects.get(equip_id=imei),upl_time__range=(tbegin, tend)).values() # descs=[] # for i in photos: # print("i.addr:",i['addr']) # # 查描述列表： # desc = CBDphoto_desc.objects.filter(desc_user=current_user,photo_id = CBDphoto.objects.get(addr=i['addr'])).values() # descs.append(desc) # print("descs:",descs) dat = [] # for i in descs: # for ii in i: # dat.append({ # "pest_num":ii['pest_num'], # "pest_name":ii['pest_name2'], # "crop_name":ii['crop_name'], # "pest_case":ii['pest_case'], # "add_time":ii['photo_time'] # }) if tbegin: begindate = re.findall(r"\d+\.?\d*", tbegin) enddate = re.findall(r"\d+\.?\d*", 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])) desc = CBDphoto_desc.objects.filter(equip_id=imei,desc_user=current_user,photo_time1__range=(start_date, end_date)).values() desc = CBDphoto_desc.objects.filter(equip_id=imei,desc_user=current_user).values() for ii in desc: # if ii['photo_time1']: dat.append({ "pest_num":ii['pest_num'], "pest_name":ii['pest_name2'], "crop_name":ii['crop_name'], "pest_case":ii['pest_case'], "add_time":ii['photo_time1'] }) if pest_name: dat = [] for ii in desc: if pest_name == ii['pest_name2']: dat.append({ "pest_num":ii['pest_num'], "pest_name":ii['pest_name2'], "crop_name":ii['crop_name'], "pest_case":ii['pest_case'], "add_time":ii['photo_time1'] }) page = int(request.POST.get('page')) print("当前页为：",page) nums = len(dat) print('nums:',nums) dat = dat[(10*(page-1)):(page*10)] data = {"nums":nums,"dat":dat} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 识别统计页面 class Manual_Pest_Data(ListView): def get(self,request): e_id = request.GET.get("e_id") disc = RecentCBDdata.objects.get(equip_id=e_id).disc current_user = request.user.username print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) try: current_user = MyUser.objects.get(username=current_user) except: current_user = MyUser.objects.get(username="public") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") role = "user" elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") role = "agency" else: role = "superuser" print("---管理员") return render(request, 'reportmanage/cbd_manual_pest_data.html', context={"e_id": e_id, "disc": disc,"role":role}) def post(self,request): pass import xlwt # 杀虫灯数据导出接口 class SCD_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("filename:", 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 = SCDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "scd_data": eval(x.scd_data), "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] # 查询全部 else: sta1 = SCDdata.objects.filter(equip_id=equip_id) print("sta1:",sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "scd_data": eval(x.scd_data), "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] title = ["设备ID","设备名称","设备开关","工作状态","灯管状态","雨控状态", "温控状态","倾倒状态","定时(h)","电击次数","温度(℃)","湿度(%)","充电电压(V)","电池电压(V)","经度","纬度","上报时间"] book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 # -------------------------------------- # pattern_top = xlwt.Pattern() # pattern_top.pattern = xlwt.Pattern.SOLID_PATTERN # pattern_top.pattern_fore_colour = 14 # style = xlwt.XFStyle() # style.pattern = pattern_top # --------------------------------------- for i in range(len(title)): # 遍历列 # sheet.write(0,i,title[i],style) # 将title数组中的字段写入到0行i列中 sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中 print(sta2) for x in range(len(sta2)): #　遍历列表 if sta2[x]["equip_name"] == "": equip_name = "无" elif sta2[x]["equip_name"] != "": equip_name = sta2[x]["equip_name"] if sta2[x]["scd_data"]["ds"] == 0: ds = "关" elif sta2[x]["scd_data"]["ds"] != 0: ds = "开" if sta2[x]["scd_data"]["ws"] == 0: ws = "待机" elif sta2[x]["scd_data"]["ws"] == 1: ws = "工作" elif sta2[x]["scd_data"]["ws"] == 2: ws = "充电" if sta2[x]["scd_data"]["tbs"] == 0: tbs = "正常" elif sta2[x]["scd_data"]["tbs"] != 0: tbs = "保护" if sta2[x]["scd_data"]["rps"] == 0: rps = "正常" elif sta2[x]["scd_data"]["rps"] != 0: rps = "保护" if sta2[x]["scd_data"]["tps"] == 0: tps = "正常" elif sta2[x]["scd_data"]["tps"] != 0: tps = "保护" if sta2[x]["scd_data"]["dps"] == 0: dps = "正常" elif sta2[x]["scd_data"]["dps"] != 0: dps = "保护" if sta2[x]["scd_data"]["tt"] == 0: tt = "常亮" elif sta2[x]["scd_data"]["tt"] != 0: tt = sta2[x]["scd_data"]["tt"] sheet.write(x+1,0,equip_id) #　将equip_id写入到第x+1行，第0列中 sheet.write(x+1,1,equip_name) sheet.write(x+1,2,ds) # 设备开关 sheet.write(x+1,3,ws) # 工作状态 sheet.write(x+1,4,tbs) # 灯管状态 sheet.write(x+1,5,rps) # 雨控状态 sheet.write(x+1,6,tps) # 温控状态 sheet.write(x+1,7,dps) # 倾倒状态 sheet.write(x+1,8,tt) # 定时 sheet.write(x+1,9,sta2[x]["scd_data"]["ct"]) # 电击次数 sheet.write(x+1,10,sta2[x]["scd_data"]["at"]) # 温度 sheet.write(x+1,11,sta2[x]["scd_data"]["ah"]) # 湿度 sheet.write(x+1,12,"%.2f"%(sta2[x]["scd_data"]["cv"]/1000)) # 充电电压 sheet.write(x+1,13,"%.2f"%(sta2[x]["scd_data"]["bv"]/1000)) # 电池电压 sheet.write(x+1,14,sta2[x]["scd_data"]["lng"]) # 经度 sheet.write(x+1,15,sta2[x]["scd_data"]["lat"]) # 纬度 sheet.write(x+1,16,sta2[x]["upl_time"]) # 上报时间 sheet.col(0).width = 256 * 18 sheet.col(12).width = 256 * 11 sheet.col(13).width = 256 * 11 sheet.col(16).width = 256 * 20 # 写出到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.save('demo.xls') # return HttpResponse(book) def post(self,request): pass # 测报灯数据导出接口 class CBD_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 = CBDdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "cbd_data": eval(x.cbd_data), "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] # 查询全部 else: sta1 = CBDdata.objects.filter(equip_id=equip_id) print("sta1:",sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "cbd_data": eval(x.cbd_data), "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] title = ["设备ID","设备名称","环境温度(℃)","环境湿度(%)","加热仓温度(℃)","雨控状态", "温控状态","光控状态","经度","纬度","上报时间"] 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列中 print(sta2) for x in range(len(sta2)): #　遍历列表 if sta2[x]["equip_name"] == "": equip_name = "无" elif sta2[x]["equip_name"] != "": equip_name = sta2[x]["equip_name"] if sta2[x]["cbd_data"]["rps"] == 0: rps = "正常" elif sta2[x]["cbd_data"]["rps"] != 0: rps = "雨控" if sta2[x]["cbd_data"]["tps"] == 0: tps = "正常" elif sta2[x]["cbd_data"]["tps"] != 0: tps = "温控" if sta2[x]["cbd_data"]["lps"] == 0: lps = "正常" elif sta2[x]["cbd_data"]["lps"] != 0: lps = "光控" sheet.write(x+1,0,equip_id) #　将equip_id写入到第x+1行，第0列中 sheet.write(x+1,1,equip_name) sheet.write(x+1,2,"%.1f"%(int(sta2[x]["cbd_data"]["at"])/10)) # 环境温度 sheet.write(x+1,3,"%.1f"%(int(sta2[x]["cbd_data"]["ah"])/10)) # 环境湿度 sheet.write(x+1,4,sta2[x]["cbd_data"]["hrt"]) # 加热仓温度 sheet.write(x+1,5,rps) # 雨控状态 sheet.write(x+1,6,tps) # 温控状态 sheet.write(x+1,7,lps) # 光控状态 sheet.write(x+1,8,sta2[x]["cbd_data"]["lng"]) # 经度 sheet.write(x+1,9,sta2[x]["cbd_data"]["lat"]) # 纬度 sheet.write(x+1,10,sta2[x]["upl_time"]) # 上报时间 sheet.col(0).width = 256 * 18 sheet.col(2).width = 256 * 11 sheet.col(3).width = 256 * 11 sheet.col(4).width = 256 * 13 sheet.col(8).width = 256 * 11 sheet.col(9).width = 256 * 11 sheet.col(10).width = 256 * 20 # 写出到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.save('demo.xls') # return HttpResponse(book) def post(self,request): pass # 害虫识别接口 class Pests_Identification(ListView): def get(self,request): pass def post(self,request): # img_addr = request.POST.get('img_addr') # photo_obj = CBDphoto.objects.get(addr=img_addr) # try: # data = {"result":photo_obj.indentify_result, # "image_addr":photo_obj.indentify_photo} # except: # data = {"result":"", # "image_addr":""} # data = json.dumps(data, cls=CJSONEncoder) # return HttpResponse(data) img_addr = request.POST.get('img_addr') photo_obj = CBDphoto.objects.get(addr=img_addr) url = 'http://60.166.14.184:9146/upload' # 2019-3-18测试用接口 # url = 'http://60.166.14.184:9143/upload' imageFile = {'imageFile':('pic.jpg',open(img_addr,'rb'),'image/jpeg')} data = {'longitude':'118.279643','latitude':'31.221456'} print('data:',data) res = requests.post(url,data=data,files=imageFile) print("res:",res.text) try: resp = json.loads(res.text) except Exception as e: print(e) print("识别失败") data = "1" return HttpResponse(data) print(resp["returnResult"]["returnString"]) data = {"image":resp["returnResult"]["returnImageUrl"], "result":resp["returnResult"]["returnString"]} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 害虫识别接口丨新 class Pests_Identification_New(ListView): def get(self,request): pass # C:\线上\yfwlw\cbd_img\868575027787516\2020\06\20200611095458.jpg def post(self,request): # img_addr = request.POST.get('img_addr') # photo_obj = CBDphoto.objects.get(addr=img_addr) # try: # data = {"result":photo_obj.indentify_result, # "image_addr":photo_obj.indentify_photo} # except: # data = {"result":"", # "image_addr":""} # data = json.dumps(data, cls=CJSONEncoder) # return HttpResponse(data) img_addr = request.POST.get('img_addr') photo_obj = CBDphoto.objects.get(addr=img_addr) # url = 'http://60.166.14.184:9143/upload' url = 'http://60.166.14.184:9143/upload' imageFile = {'imageFile':('pic.jpg',open(img_addr,'rb'),'image/jpeg')} data = {'longitude':'118.279643','latitude':'31.221456'} print('data:',data) res = requests.post(url,data=data,files=imageFile) print("res:",res.text) try: resp = json.loads(res.text) print("pest",resp["returnResult"]["returnString"]) photo_obj.indentify_result = resp["returnResult"]["returnString"] photo_obj.save() except Exception as e: print(e) print("识别失败") data = "1" return HttpResponse(data) print(resp["returnResult"]["returnString"]) data = {"image":resp["returnResult"]["returnImageUrl"], "result":resp["returnResult"]["returnString"]} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 气象站报表管理类视图： class QXZreport_View(ListView): def get(self, request): current_user = request.session.get('username') current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser == True: role = "superuser" else: role = "user" return render(request, 'reportmanage/qxz_report.html', context={"role":role}) # 气象站分页接口 class QXZ_Page(ListView): def get(self,request): current_user = request.user.username print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) page = request.GET.get('page') page = int(page) f_id = request.GET.get('f_id') print("f_id:", f_id) is_online = request.GET.get('is_online') etype = request.GET.get('etype') print("is_online------>>",is_online) print("etype------>>",etype) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: # 用户 if f_id != "" and is_online != "": # equip_list = Equip.objects.filter(equip_type=5,equip_user=current_user, equip_id__contains=f_id).values() equip_list = QXZstatus_New.objects.filter(equip_id__equip_user=current_user, equip_id__equip_id__contains=f_id, is_online=is_online) elif f_id == "" and is_online != "": equip_list = QXZstatus_New.objects.filter(equip_id__equip_user=current_user, is_online=is_online) elif f_id != "" and is_online == "": equip_list = QXZstatus_New.objects.filter(equip_id__equip_user=current_user, equip_id__equip_id__contains=f_id) elif f_id == "" and is_online == "": # equip_list = Equip.objects.filter(equip_type=5,equip_user=current_user).values() equip_list = QXZstatus_New.objects.filter(equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: # 代理商 if f_id != "" and is_online != "": # equip_list = Equip.objects.filter(equip_type=5,equip_agency=current_user.user_agency, equip_id__contains=f_id).values() equip_list = QXZstatus_New.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=f_id, is_online=is_online) elif f_id == "" and is_online != "": equip_list = QXZstatus_New.objects.filter(equip_id__equip_agency=current_user.user_agency, is_online=is_online) elif f_id != "" and is_online == "": equip_list = QXZstatus_New.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=f_id) elif f_id == "" and is_online == "": # equip_list = Equip.objects.filter(equip_type=5,equip_agency=current_user.user_agency).values() equip_list = QXZstatus_New.objects.filter(equip_id__equip_agency=current_user.user_agency) else: # 管理员 if f_id != "" and is_online != "": # equip_list = Equip.objects.filter(equip_type=5,equip_agency=current_user.user_agency, equip_id__contains=f_id).values() equip_list = QXZstatus_New.objects.filter(equip_id__equip_id__contains=f_id, is_online=is_online) elif f_id == "" and is_online != "": print("触发！！！") equip_list = QXZstatus_New.objects.filter(is_online=is_online) elif f_id != "" and is_online == "": equip_list = QXZstatus_New.objects.filter(equip_id__equip_id__contains=f_id) elif f_id == "" and is_online == "": equip_list = QXZstatus_New.objects.all() e_ids = [] for x in equip_list: if etype != "": if len(x.equip_id_id) == int(etype): n_d = {"equip_name":x.equip_id.equip_name, "equip_id":x.equip_id_id, "is_online":x.is_online,"off_time":x.off_time} e_ids.append(n_d) else: n_d = {"equip_name":x.equip_id.equip_name, "equip_id":x.equip_id_id, "is_online":x.is_online,"off_time":x.off_time} e_ids.append(n_d) nums = len(e_ids) # print(nums) ids = e_ids[(10*(page-1)):(page*10)] data = {'ids': ids, 'nums': nums} print("!!!",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) def post(self,request): pass # 气象站修改图片接口 class QXZ_Photo(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get('id') qxz_sta = QXZstatus.objects.get(equip_id=e_id) qxz_photo = request.FILES['upicture'] print("气象站图片：", qxz_photo) qxz_photo_dir = 'qxz_photo/' # 判断如果路径不存在，即创建路径 if os.path.exists(qxz_photo_dir) == False: os.makedirs(qxz_photo_dir) img = Image.open(qxz_photo) img.save(qxz_photo_dir + e_id+".png") new_photo = qxz_photo_dir + e_id +".png" print("new_photo:",new_photo) # 数据库关联设备，并在照片的表中存入路径： qxz_sta.qxz_picture = new_photo qxz_sta.save() data = "0" return HttpResponse(data) # 气象站详情接口 class QXZ_Detail(ListView): def get(self,request): qxz_dict_1 = copy.deepcopy(qxz_dict) # 如果不拷贝 后面折线图修改字典会导致字典内容变化 从而造成数据错误 current_user = request.user.username print("current_user:", current_user) try: current_user = MyUser.objects.get(username=current_user) except: current_user = MyUser.objects.get(username="public") start_date = datetime.datetime.now() - datetime.timedelta(days=1) end_date = datetime.datetime.now() print("start_date:", start_date) print("end_date:", end_date) e_id = request.GET.get('id') sta1 = QXZdata.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)).values() # print(len(eval(sta1[0]['qxz_data'])['data'])) p_data = {"values":[], "times":[]} all_data = [] # 所有数据 try: # 先遍历有几种类型的数据 for a in range(len(eval(sta1[0]["qxz_data"])["data"])): # 再遍历24小时内的每条数据 for x in sta1: # sta = {"qxz_data": x['qxz_data'], "upl_time": x['upl_time'], # "equip_id": x['equip_id_id']} qxzdata = eval(x["qxz_data"]) # print(qxzdata['data'][a]['eValue']) p_data["name"]=qxzdata["data"][a]["eName"] p_data["values"].append(eval(qxzdata["data"][a]["eValue"])) # print(type(eval(qxzdata['data'][a]['eValue']))) p_data["ekey"]=qxzdata['data'][a]["eKey"] p_data["unit"] = qxz_dict_1[qxzdata["data"][a]["eNum"]] # print('p_data["unit"]',p_data["unit"]) tt = json.dumps(x['upl_time'], cls=CJSONEncoder) p_data["times"].append(tt) p_data["min"] = min(p_data["values"]) p_data["max"] = max(p_data["values"]) p_data["min_time"] = p_data["times"][p_data["values"].index(min(p_data["values"]))] p_data["max_time"] = p_data["times"][p_data["values"].index(max(p_data["values"]))] all_data.append(p_data) p_data = {"values":[], "times":[]} except Exception as e: print(e) # print('-------------------',all_data) # print(sta2) dat1 = [] try: sta2 = QXZstatus.objects.get(equip_id=e_id) for i in range(len((eval(sta2.qxz_status)["data"]))): if eval(sta2.qxz_status)['data'][i]["eNum"] == "163": continue dat1.append({"unit": qxz_dict_1[eval(sta2.qxz_status)['data'][i]["eNum"]],"equip_name": sta2.equip_id.equip_name, "upl_time": sta2.upl_time, "equip_id": sta2.equip_id_id, "eValue": eval(sta2.qxz_status)["data"][i]["eValue"], "eKey": eval(sta2.qxz_status)["data"][i]["eKey"], "qxz_picture": "%s"%(sta2.qxz_picture)}) # print(eval(sta2.qxz_status)['data'][i]['eNum']) # print("dat1:",dat1) except Exception as exc: # dat1 = {"unit": "","equip_name": "", # "upl_time": "", "equip_id": "", "eValue": "", # "eKey": ""} # dat1 = [] print(exc) print("dat1:",dat1) # imei = request.POST.get('imei') 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 = "" try: timing_list = QXZTimingswitch.objects.get(equip_id=e_id).qxz_timing except: timing_list = "" try: auto_list = QXZAutoswitch.objects.get(equip_id_id=e_id).qxz_auto except: auto_list = "" data = {'new_data': dat1, 'all_data':all_data, 'qxz_switch':qxz_switch, 'switch_name':switch_name, 'timing_list':timing_list, 'auto_list':auto_list} data = json.dumps(data, cls=CJSONEncoder) User_Log.objects.create(log_user=current_user, log_ip=request.META['REMOTE_ADDR'], log_desc='设备管理-气象站') return HttpResponse(data) def post(self,request): pass # 气象站报表详情折线图： class QXZ_Report_Detail_Chart(ListView): def get(self, request): pass 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"],"e_len": len((eval(x["qxz_data"])["data"])), "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: if i["eNum"] == "163": continue 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, cls=CJSONEncoder) 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"],"e_len": len((eval(x["qxz_data"])["data"])), "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: if i["eNum"] == "163": continue 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, cls=CJSONEncoder) 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"], "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: if i["eNum"] == "163": continue 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, cls=CJSONEncoder) return HttpResponse(data) sta1 = QXZdata.objects.filter(equip_id=equip_id).values() for x in sta1: sta = {"upl_time": x["upl_time"], "unit": [], "equip_id": x["equip_id_id"]} for i in eval(x["qxz_data"])["data"]: if i["eNum"] == "163": continue 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, cls=CJSONEncoder) return HttpResponse(data) # 孢子仪报表管理视图： @csrf_exempt def BZY_Report(request): # current_user = request.session.get('username') # print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) current_user = request.user.username print("current_user:", current_user) # current_user = MyUser.objects.get(username=current_user) try: current_user = MyUser.objects.get(username=current_user) except: current_user = MyUser.objects.get(username="public") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") equip_list = Equip.objects.filter( equip_type=7, equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") equip_list = Equip.objects.filter( equip_type=7, equip_agency=current_user.user_agency) else: print("---管理员") equip_list = Equip.objects.filter(equip_type=7) data = [] for i in equip_list: sta1 = BZYstatus.objects.filter( equip_id=i.equip_id) for x in sta1: sta2 = {"equip_name": x.equip_id.equip_name, "bzy_status": x.bzy_status, "upl_time": x.upl_time,"equip_id":x.equip_id.equip_id} data.append(sta2) if request.method == 'GET': if request.is_ajax(): req = request.GET.get('req') print("req:", req) if req == "reqdat": print("---post 请求数据！") page = int(request.GET.get('page')) print("page:", page) data = data[(10*(page-1)):(page*10)] # data = serializers.serialize("json", equip_list) # print("data:", data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) else: nums = len(data) User_Log.objects.create(log_user=current_user, log_ip=request.META['REMOTE_ADDR'], log_desc='报表管理-孢子仪') return render(request, 'reportmanage/bzy_report.html', context={"nums": nums}) elif request.method == 'POST': req = request.POST.get('req') print("req:", req) if req == "filter": print("---筛选！") page = int(request.POST.get('page')) print("page:", page) ename = request.POST.get('ename') print("ename:", ename) f_id = request.POST.get('f_id') print("f_id:", f_id) current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") if ename == "" and f_id == "": equip_list = Equip.objects.filter(equip_type=7, equip_user=current_user) elif ename == "" and f_id != "": equip_list = Equip.objects.filter(equip_type=7, equip_user=current_user, equip_id__contains=f_id) elif ename != "" and f_id == "": equip_list = Equip.objects.filter(equip_type=7, equip_user=current_user, equip_name__contains=ename) elif ename != "" and f_id != "": equip_list = Equip.objects.filter(equip_type=7, equip_user=current_user, equip_name__contains=ename,equip_id__contains=f_id) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") if ename == "" and f_id == "": equip_list = Equip.objects.filter(equip_type=7, equip_agency=current_user.user_agency) elif ename == "" and f_id != "": equip_list = Equip.objects.filter(equip_type=7, equip_agency=current_user.user_agency, equip_id__contains=f_id) elif ename != "" and f_id == "": equip_list = Equip.objects.filter(equip_type=7, equip_agency=current_user.user_agency, equip_name__contains=ename) elif ename != "" and f_id != "": equip_list = Equip.objects.filter(equip_type=7, equip_agency=current_user.user_agency, equip_name__contains=ename,equip_id__contains=f_id) else: print("---管理员") if ename == "" and f_id == "": equip_list = Equip.objects.filter(equip_type=7) elif ename == "" and f_id != "": equip_list = Equip.objects.filter(equip_type=7, equip_id__contains=f_id) elif ename != "" and f_id == "": equip_list = Equip.objects.filter(equip_type=7, equip_name__contains=ename) elif ename != "" and f_id != "": equip_list = Equip.objects.filter(equip_type=7, equip_name__contains=ename,equip_id__contains=f_id) dat = [] for i in equip_list: sta1 = BZYstatus.objects.filter( equip_id=i.equip_id) for x in sta1: sta2 = {"equip_name": x.equip_id.equip_name, "bzy_status": x.bzy_status, "upl_time": x.upl_time,"equip_id":x.equip_id.equip_id} dat.append(sta2) # print('-----------------------',x.equip_id.equip_id) nums = len(dat) print("nums:", nums) dat = dat[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 孢子仪上传图片测试页面： @method_decorator(csrf_exempt, name='dispatch') def bzy_photoview(request): if request.method == 'GET': print("-----image preview!-----") imei = request.GET.get('imei') print("imei:", imei) nums = BZYphoto.objects.filter(equip_id=imei).count() print("nums:", nums) iccid = BZYstatus.objects.get(equip_id=imei).simid dver = eval(BZYstatus.objects.get(equip_id=imei).bzy_status)["dver"] return render(request, 'reportmanage/bzy_image.html', context={"nums": nums, "imei": imei, "iccid":iccid, "dver":dver}) if request.method == 'POST': print("-----image upload request!-----") imei = request.GET.get('imei') print("imei:", imei) # 判断设备是否存在： if Equip.objects.filter(equip_id=imei).exists(): length = request.META['CONTENT_LENGTH'] print("length:", length) # 以当前时间命名图片 now_time = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) pic_name = now_time + '.jpg' print("pic_name:", pic_name) pic_dir = 'bzy_img/' + imei + '/' + \ pic_name[0:4] + '/' + pic_name[4:6] + '/' if os.path.exists(pic_dir) == False: # 文件夹加权限 os.makedirs(pic_dir) # os.chmod(pic_dir, stat.S_IRWXU|stat.S_IRWXG|stat.S_IRWXO) print("图片路径:", pic_dir + pic_name) # img.save(pic_dir+pic_name) with open(pic_dir + pic_name, "wb") as file: file.write(request.body) # print("request.body：", request.body) # 数据库关联设备，并在照片的表中存入路径： equip = Equip.objects.get(equip_id=imei) BZYphoto.objects.create(equip_id=equip, addr=pic_dir + pic_name) return HttpResponse("-----image upload success!-----") else: return HttpResponse("-----image upload failed because this imei is not exists!-----") # 孢子仪报表详视图： @method_decorator(csrf_exempt, name='dispatch') class BZY_Report_Detail(ListView): def get(self, request): equip_id = request.GET.get('id') print("请求数据，设备id：", equip_id) nums = BZYdata.objects.filter(equip_id=equip_id).count() print("nums:", nums) lng = eval(BZYstatus.objects.get(equip_id=equip_id).bzy_status)["lng"] lat = eval(BZYstatus.objects.get(equip_id=equip_id).bzy_status)["lat"] return render(request, 'reportmanage/bzy_report_detail.html', context={"equip_id": equip_id, "nums": nums, "lng":lng, "lat":lat}) def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("page:", page) print("请求数据的设备id：", equip_id) # data = {'dat':"",'pages':""} sta1 = BZYdata.objects.filter(equip_id=equip_id)[ (10*(page-1)):(page*10)] sta2 = [{"equip_name": x.equip_id.equip_name, "bzy_data": x.bzy_data, "upl_time": x.upl_time} for x in sta1] data = json.dumps(sta2, cls=CJSONEncoder) # data['dat'] = sta2 # data['pages'] = pages # data = json.dumps(data, cls=CJSONEncoder) # print(data) return HttpResponse(data) elif req == "filter": equip_id = request.POST.get('id') page = int(request.POST.get('page')) print("equip_id:", equip_id) print("page:", page) print("请求数据的设备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) 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 = BZYdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "bzy_data": x.bzy_data, "upl_time": x.upl_time} for x in sta1] nums = len(sta2) dat = sta2[(10*(page-1)):(page*10)] data = {'dat': dat, 'nums': nums} # print("data:",data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) #孢子仪孢子统计页面 class BZY_Report_Statistics(ListView): def get(self, request): equip_id = request.GET.get('id') return render(request, 'reportmanage/bzy_report_statistics.html', context={"equip_id": equip_id}) # 孢子仪报表详情折线图： class BZY_Report_Detail_Chart(ListView): def get(self, request): pass def post(self, request): req = request.POST.get('req') if req == "data": equip_id = request.POST.get('id') print("equip_id:", equip_id) # 获取当前日期： now_time = datetime.datetime.now() print("当前日期为：",now_time) print("当前月为：",now_time.month) sta1 = BZYdata.objects.filter(equip_id=equip_id,upl_time__month=now_time.month) sta2 = [] for x in sta1: # if eval(x.bzy_data)['pre_temp'] > 100 or eval(x.bzy_data)['pre_temp'] < 0: # pre_temp = 20 # else: pre_temp = eval(x.bzy_data)['pre_temp'] sta2.append({"pre_temp": pre_temp, "ah": eval(x.bzy_data)['ah'], "at": eval(x.bzy_data)['at'], "tim": x.upl_time}) data = json.dumps(sta2, cls=CJSONEncoder) # print("data:", data) return HttpResponse(data) elif req == "filter": 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) 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 = BZYdata.objects.filter( equip_id=equip_id, upl_time__range=(start_date, end_date)) sta2 = [] for x in sta1: pre_temp = eval(x.bzy_data)['pre_temp'] sta2.append({"pre_temp": pre_temp, "ah": eval(x.bzy_data)['ah'], "at": eval(x.bzy_data)['at'], "tim": x.upl_time}) data = json.dumps(sta2, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 孢子仪图片列表视图： @csrf_exempt def bzy_imagelistview(request): if request.method == 'GET': print("-----image list view!-----") imei = request.GET.get('imei') print("imei:", imei) # 获得当前页： page = int(request.GET.get('page')) print("page:", page) equip_name = Equip.objects.get(equip_id=imei).equip_name # 当前用户：返回用户，前端判断是否显示删除图片按钮 current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) img = BZYphoto.objects.filter(equip_id=imei)[(8*(page-1)):(page*8)] equip_name = Equip.objects.get(equip_id=imei).equip_name return render(request, 'reportmanage/bzy_imageList.html', context={"img": img, "equip_name": equip_name, "current_user": current_user,'imei':imei}) # 孢子仪删除图片接口： class BZY_Image_Delete(ListView): def get(self, request): pass def post(self, request): print("-----image delete!-----") imei = request.POST.get('imei') img_name = request.POST.get('addr') img_name = img_name.replace('bzy/', '') print("img_name:",img_name) print("imei:",imei) if os.path.exists(img_name) == True: # 删除图片文件 os.remove(img_name) # 删除数据库照片列表中，照片路径： try: BZYphoto.objects.filter(equip_id=imei, addr=img_name).delete() print("-----image delete ok!-----") data = "1" return HttpResponse(data) except: print("-----image delete failed!-----") data = "0" return HttpResponse(data) else: # 照片在数据库里不存在，但是数据库有路径的情况会删除不掉 # 因此不管何时都删除数据库路径 try: BZYphoto.objects.filter(equip_id=imei, addr=img_name).delete() print("-----image delete ok!-----") except: pass print("-----image not exist!-----") data = "0" return HttpResponse(data) # 孢子仪图片描述接口： @method_decorator(csrf_exempt, name='dispatch') class BZY_Image_Desc(ListView): def get(self, request): img_name = request.POST.get('addr') print('img_name:',img_name) try: obj = BZYphoto.objects.get(addr=img_name) data = obj.describe except Exception as e: print(e) data = "" data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) def post(self, request): img_name = request.POST.get('addr') print('img_name:',img_name) desc = request.POST.get('describe') print("desc：",desc) try: obj = BZYphoto.objects.get(addr=img_name) obj.describe = desc obj.save() print("-----image add describe ok!-----") data = "0" return HttpResponse(data) except Exception as e: print("-----image add describe failed!-----") print("=========",e) data = "1" return HttpResponse(data) # 孢子仪数据导出接口 class BZY_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 = BZYdata.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "bzy_data": eval(x.bzy_data), "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] # 查询全部 else: sta1 = BZYdata.objects.filter(equip_id=equip_id) print("sta1:",sta1) sta2 = [{"equip_name": x.equip_id.equip_name, "bzy_data": eval(x.bzy_data), "upl_time": x.upl_time.strftime("%Y-%m-%d %H:%M:%S")} for x in sta1] title = ["环境温度(℃)","环境湿度(%)","保温仓设定温度(℃)","保温仓当前温度(℃)","设备开关","电池状态","摄像头状态", "电压(V)","海拔高度","信号强度","设备版本","上报时间"] book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 sheet.write_merge(0, 0, 0, 11, '%s设备数据'%equip_id) for i in range(len(title)): # 遍历列 sheet.write(1,i,title[i]) # 将title数组中的字段写入到0行i列中 print(sta2) for x in range(len(sta2)): #　遍历列表 if sta2[x]["equip_name"] == "": equip_name = "无" elif sta2[x]["equip_name"] != "": equip_name = sta2[x]["equip_name"] if sta2[x]["bzy_data"]["on_off"] == 0: on_off = "关闭" elif sta2[x]["bzy_data"]["on_off"] != 0: on_off = "开启" if sta2[x]["bzy_data"]["bat_sta"] == 0: bat_sta = "正常" elif sta2[x]["bzy_data"]["bat_sta"] != 0: bat_sta = "电量过低" if sta2[x]["bzy_data"]["usb_sta"] == 0: usb_sta = "正常" elif sta2[x]["bzy_data"]["usb_sta"] != 0: usb_sta = "异常" if sta2[x]["bzy_data"]["alti"] != "": alti = sta2[x]["bzy_data"]["alti"] elif sta2[x]["bzy_data"]["alti"] == "": alti = "暂无" sheet.write(x+2,0,sta2[x]["bzy_data"]["at"]) #　将环境温度写入到第x+1行，第0列中 sheet.write(x+2,1,sta2[x]["bzy_data"]["ah"]) sheet.write(x+2,2,sta2[x]["bzy_data"]["set_temp"]) # 保温仓设定温度 sheet.write(x+2,3,sta2[x]["bzy_data"]["pre_temp"]) # 保温仓当前温度 sheet.write(x+2,4,on_off) # 设备开关 sheet.write(x+2,5,bat_sta) # 电池状态 sheet.write(x+2,6,usb_sta) # 摄像头状态 sheet.write(x+2,7,sta2[x]["bzy_data"]["v_bat"]) # 电压 sheet.write(x+2,8,alti) # 海拔高度 sheet.write(x+2,9,sta2[x]["bzy_data"]["csq"]) # 信号强度 sheet.write(x+2,10,sta2[x]["bzy_data"]["dver"]) # 设备版本 sheet.write(x+2,11,sta2[x]["upl_time"]) # 上报时间 sheet.col(2).width = 256 * 18 sheet.col(3).width = 256 * 18 sheet.col(6).width = 256 * 11 sheet.col(11).width = 256 * 18 # 写出到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 # 自动识别后的害虫统计接口： @method_decorator(csrf_exempt, name='dispatch') class Pest_Statis(ListView): def get(self,request): equip_id = request.GET.get('id') nums = CBDphoto.objects.filter(equip_id=equip_id).count() print("nums:", nums) current_user = request.session.get('username') return render(request, 'reportmanage/cbd_pest_data.html', context={"equip_id":equip_id,"nums":nums,"username":current_user}) def post(self,request): e_id = request.POST.get('e_id') tbegin = request.POST.get('tbegin') tend = request.POST.get('tend') req = request.POST.get('req') print('e_id:',e_id) print("---折线图") one_month = datetime.timedelta(days=30) one_month_later = datetime.datetime.now() - one_month now_time = datetime.datetime.now() print("当前日期为：",now_time) sta1 = CBDphoto.objects.filter(equip_id=e_id, upl_time__range=(one_month_later, now_time)) sta3 = CBDdata.objects.filter(equip_id=e_id, upl_time__range=(one_month_later, now_time)) if req == "filter": if tbegin: print("-------按日期筛选!") print("tbegin:", tbegin) print("tend:", tend) # page = request.POST.get('page') begindate = re.findall(r"\d+\.?\d*", tbegin) enddate = re.findall(r"\d+\.?\d*", 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 = CBDphoto.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)) print("!!!!!",sta1.count()) dat = [] tim = [] cbd_data = [] pest_kind = [] for x in sta1: # print(x.indentify_result) if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') # print(i_result) if i_result[0] not in pest_kind: # print(i[0]) pest_kind.append(i_result[0]) sta2 = {"time":x.upl_time,"result":x.indentify_result} tim.append(x.upl_time.strftime("%Y-%m-%d %H:%M:%S")) # if x.indentify_result: dat.append(sta2) # for i in sta3: for i in sta1: # sta4 = {"at":eval(i.cbd_data)["at"],"ah":eval(i.cbd_data)["ah"],"upl_time":i.upl_time} sta4 = {"at":i.at,"ah":i.ah,"upl_time":i.upl_time} tim.append(i.upl_time.strftime("%Y-%m-%d %H:%M:%S")) cbd_data.append(sta4) tim = sorted(tim) data = {"dat":dat,"kind":pest_kind,"cbd_data":cbd_data,"tim":tim} # print("!!!!!!!!!!!!!!!",pest_kind) data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 自动识别后的害虫统计接口： @method_decorator(csrf_exempt, name='dispatch') class Pest_Statis_Form(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get('e_id') tbegin = request.POST.get('tbegin') tend = request.POST.get('tend') req = request.POST.get('req') pest = request.POST.get('pestCategory') print('e_id:',e_id) print('-=-=-=-=-=-=-=-') # 统计图 print("---统计图") page = request.POST.get('page') page = int(request.POST.get('page')) print("page:", page) sta1 = CBDphoto.objects.filter(equip_id=e_id) if req == "filter": page = int(request.POST.get('page')) if tbegin: print("-------按日期筛选!") print("tbegin:", tbegin) print("tend:", tend) begindate = re.findall(r"\d+\.?\d*", tbegin) enddate = re.findall(r"\d+\.?\d*", 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 = CBDphoto.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)) print("!!!!!",sta1.count()) dat = [] pest_kind = [] for x in sta1: # print(x.indentify_result) if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') # print(i_result) if i_result[0] not in pest_kind: # print(i[0]) pest_kind.append(i_result[0]) sta2 = {"time":x.upl_time,"pest":i_result[0],"pestnum":i_result[1]} dat.append(sta2) if pest: dat = [] print("-------------pest",pest) for x in sta1: if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') if i_result[0] == pest: sta2 = {"time":x.upl_time,"pest":i_result[0],"pestnum":i_result[1]} dat.append(sta2) nums = len(dat) print("-------------------------",type(page)) dat = dat[(10*(page-1)):(page*10)] data = {"dat":dat,"kind":pest_kind,"nums":nums} data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 害虫统计数据导出接口 class Pest_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 = CBDphoto.objects.filter(equip_id=equip_id, upl_time__range=(start_date, end_date)) print("sta1:", sta1) # 查询全部 else: sta1 = CBDphoto.objects.filter(equip_id=equip_id) print("sta1:",sta1) sta2 = {} for x in sta1: if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') if insect_dict_new[i_result[0]] not in sta2: sta2[insect_dict_new[i_result[0]]] = int(i_result[1]) else: sta2[insect_dict_new[i_result[0]]] = sta2[insect_dict_new[i_result[0]]] + int(i_result[1]) # sta2.append({"pest":insect_dict_new[i_result[0]],"pest_num":i_result[1],"time":x.upl_time.strftime('%Y-%m-%d %H:%M:%S')}) title = ["害虫名称","害虫数量"] book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 sheet.write_merge(0, 0, 0, 3, '%s设备数据'%equip_id) if f_tbegin: sheet.write_merge(1, 1, 0, 3, "%s-%s"%(start_date,end_date)) else: sheet.write_merge(1, 1, 0, 3, "该设备全部数据") for i in range(len(title)): # 遍历列 sheet.write(2,i,title[i]) # 将title数组中的字段写入到0行i列中 # print(sta2) a = 0 for x in sta2: #　遍历列表 sheet.write(a+3,0,x) sheet.write(a+3,1,sta2[x]) a += 1 sheet.col(0).width = 256 * 18 # 写出到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 Pest_At_Ah(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get("e_id") tbegin = request.POST.get('tbegin') tend = request.POST.get('tend') sta1 = CBDphoto.objects.filter(equip_id=e_id) if tbegin: print("-------按日期筛选!") print("tbegin:", tbegin) print("tend:", tend) begindate = re.findall(r"\d+\.?\d*", tbegin) enddate = re.findall(r"\d+\.?\d*", 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 = CBDphoto.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)) print("!!!!!",sta1.count()) dat = [] pest_kind = [] for x in sta1: # print(x.indentify_result) if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') # print(i_result) if i_result[0] not in pest_kind: # print(i[0]) pest_kind.append(i_result[0]) sta2 = {"time":x.upl_time,"result":x.indentify_result,"at":x.at,"ah":x.ah} # if x.indentify_result: dat.append(sta2) try: msg_conf = Msg_Conf.objects.get(equip_id=e_id).conf except: msg_conf = "" nums = len(dat) data = {"dat":dat,"kind":pest_kind,"nums":nums,"msg_conf":msg_conf} # print("!!!!!!!!!!!!!!!",pest_kind) data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) return HttpResponse(data) # 害虫统计和温湿度对应折线图 class Pest_At_Ah_1(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get("e_id") tbegin = request.POST.get('tbegin') tend = request.POST.get('tend') one_month = datetime.timedelta(days=30) one_month_later = datetime.datetime.now() - one_month now_time = datetime.datetime.now() # xy_list = Trapdata.objects.filter(equip_id=e_id, upl_time__range=(one_month_later, now_time)) sta1 = CBDphoto.objects.filter(equip_id=e_id, upl_time__range=(one_month_later, now_time)) sta3 = CBDdata.objects.filter(equip_id=e_id, upl_time__range=(one_month_later, now_time)) # sta1 = CBDphoto.objects.filter(equip_id=e_id) # sta3 = CBDdata.objects.filter(equip_id=e_id) if tbegin: print("-------按日期筛选!") print("tbegin:", tbegin) print("tend:", tend) begindate = re.findall(r"\d+\.?\d*", tbegin) enddate = re.findall(r"\d+\.?\d*", 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 = CBDphoto.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)) print("!!!!!",sta1.count()) sta3 = CBDdata.objects.filter(equip_id=e_id, upl_time__range=(start_date, end_date)) dat = [] pest_kind = [] for x in sta1: # print(x.indentify_result) if x.indentify_result != None and x.indentify_result != "": pest_reslut = x.indentify_result.split('#') for i in pest_reslut: i_result = i.split(',') # print(i_result) if i_result[0] not in pest_kind: # print(i[0]) pest_kind.append(i_result[0]) sta2 = {"time":x.upl_time,"result":x.indentify_result} # if x.indentify_result: dat.append(sta2) dat1 = [] for xx in sta1: # print("at",eval(xx.cbd_data)['at']) # print("ah",xx.cbd_data) sta4 = {"at":xx.at,"ah":xx.ah,"time":xx.upl_time} dat1.append(sta4) try: msg_conf = Msg_Conf.objects.get(equip_id=e_id).conf except Exception as e: print("报错信息为",e) msg_conf = "" nums = len(dat) data = {"dat":dat,"dat1":dat1,"kind":pest_kind,"nums":nums,"msg_conf":msg_conf} # print("!!!!!!!!!!!!!!!",pest_kind) data = json.dumps(data, cls=CJSONEncoder) print("data:",data) return HttpResponse(data) @method_decorator(csrf_exempt, name='dispatch') class Test(ListView): def get(self, request): pass def post(self, request): # e_type = request.POST.get("type") # # print("imei",imei) # print("s_time",s_time) # sta1 = CBDstatus.objects.all() # sta3 = [] # for i in sta1: # fir_v = eval(i.cbd_status)["dver"].split(".") # if fir_v[0] == e_type: # sta3.append(i.equip_id.equip_id) # print(sta3) # for imei in sta3: # file_dir = "pyftp/ftp_file/ykm_cbd/%s/%s"%(imei,s_time) # print("file_dir",file_dir) # for root, dirs, files in os.walk(file_dir): # print(root) #当前目录路径 # print(dirs) #当前路径下所有子目录 # print(files) #当前路径下所有非目录子文件 # for i in files: # file = file_dir + "/" + i # jpg_time = time.ctime(os.path.getctime(file)) # print("jpg_time",jpg_time) # st = s_time+jpg_time[11:19] # pic_time = datetime.datetime.strptime(st,"%Y%m%d%H:%M:%S") # print("类型查看",type(pic_time)) # print("把字符串转成datetime: ", datetime.datetime.strptime(st,"%Y%m%d%H:%M:%S")) # if CBDphoto.objects.filter(addr=file).exists(): # print("照片存在") # else: # print("照片不存在") # try: # imei_obj = Equip.objects.get(equip_id=imei) # CBDphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time) # except Exception as e: # print("错误信息为",e) # -------------------------------------------------------------------------------- # sta1 = CBDstatus.objects.all() # sta3 = [] # for i in sta1: # fir_v = eval(i.cbd_status)["dver"].split(".") # if fir_v[0] == e_type: # sta3.append(i.equip_id.equip_id) # for imei in sta3: # path = "pyftp/ftp_file/ykm_cbd/%s"%imei # lsdir = os.listdir(path) #     dirs = [i for i in lsdir if os.path.isdir(os.path.join(path, i))] #     if dirs: #         for i in dirs: #             print_files(os.path.join(path, i)) #     files = [i for i in lsdir if os.path.isfile(os.path.join(path,i))] #     for f in files: #        print(os.path.join(path, f)) # -------------------------------------------------------------------------------- # imei = request.POST.get("imei") # s_time = request.POST.get("time") # file_dir = "pyftp/ftp_file/ykm_cbd/%s/%s"%(imei,s_time) # print("file_dir",file_dir) # for root, dirs, files in os.walk(file_dir): # print(root) #当前目录路径 # print(dirs) #当前路径下所有子目录 # print(files) #当前路径下所有非目录子文件 # for i in files: # file = file_dir + "/" + i # jpg_time = time.ctime(os.path.getctime(file)) # print("jpg_time",jpg_time) # st = s_time+jpg_time[11:19] # print("-------------------",i.split(".")[0]) # pic_time_1 = s_time+i.split(".")[0] # pic_time_1 = datetime.datetime.strptime(pic_time_1,"%Y%m%d%H-%M-%S") # print("-------------------->",pic_time_1) # print("-------------------->",type(pic_time_1)) # pic_time = datetime.datetime.strptime(st,"%Y%m%d%H:%M:%S") # print("类型查看",type(pic_time)) # print("把字符串转成datetime: ", datetime.datetime.strptime(st,"%Y%m%d%H:%M:%S")) # if CBDphoto.objects.filter(addr=file).exists(): # photoobj = CBDphoto.objects.get(addr=file) # photoobj.upl_time = pic_time_1 # photoobj.save() # print("照片存在") # else: # print("照片不存在") # try: # imei_obj = Equip.objects.get(equip_id=imei) # CBDphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time) # except Exception as e: # print("错误信息为",e) # ---------------------------------------------------------------------------------- # data = { # "Image":"http://www.yfzhwlw.com/cbd_img/86123456789/2018/03/20180329135742.jpg", # "Result_image":"http://www.yfzhwlw.com/result_cbd_img/86123456789/2018/03/20180329135742result.jpg", # "Result":"22,15", # "imei":"868575028869313" # } # url = "http://tp.gw.airag.cn/yunfeikeji/insect/result/b2uanxyihkamjb5n5uydgdxvoi5chqhy" # data = json.dumps(data, cls=CJSONEncoder) # print("data:",data) # res_1 = requests.post(url=url,data=data) # url = "http://ip.360.cn/IPShare/info" # res = requests.post(url=url) # print(res.text) # data = res.text # aea = request.body # print(type(aea)) # print(aea) # dat = [] # equip_list = SCDstatus.objects.all() # for i in equip_list: # dat.append({"imei":i.equip_id_id,"lng":i.lng,"lat":i.lat}) # # print(dat) # dat = json.dumps(dat) # res = requests.post("http://127.0.0.1:8080/test",data=dat) # 清除气象站数据 # imeistr = request.body # print(type(imeistr)) # if imeistr: # imei = eval(imeistr)["imei"] # return HttpResponse(imei) # dat = [] # e_id = request.POST.get("imei") # qxz_list = QXZdata.objects.filter(equip_id_id=e_id) # for i in qxz_list: # qxz_time = i.upl_time # # str_p = datetime.datetime.strftime(qxz_time,'%Y-%m-%d') # time_int = qxz_time.minute # # print(str(time_int)) # if "7" not in str(time_int): # i.delete() # username = request.POST.get('username') # current_user = MyUser.objects.get(username="admin") # sta1 = CBDstatus.objects.filter(equip_id__equip_user=current_user) # sta1 = CBDstatus.objects.all() # print(len(sta1)) # # print("data:",data) # sta2 = [] # for a in sta1: # if a.is_online == "1": # sta2.append([a.equip_id_id,a.lng,a.lat]) # else: # pass # print(len(sta2)) # filename = "设备经纬度" # title = ["设备ID","经度","纬度"] # 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)): #　遍历列表 # sheet.write(x+1,0,sta2[x][0]) # sheet.write(x+1,1,sta2[x][1]) # sheet.write(x+1,2,sta2[x][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 # equip_list = Equip.objects.all() # bbb = 0 # for i in equip_list: # photo_list = CBDphoto.objects.filter(equip_id=i.equip_id) # status_list = CBDdata.objects.filter(equip_id=i.equip_id) # for x in photo_list: # for a in status_list: # if x.at == None: # if a.upl_time.year == x.upl_time.year and a.upl_time.month == x.upl_time.month and a.upl_time.day == x.upl_time.day and a.upl_time.hour == x.upl_time.hour: # # print("数据时间==================>",a.upl_time) # # print("设备温度==================>",eval(a.cbd_data)["at"]) # # print("设备湿度==================>",eval(a.cbd_data)["ah"]) # # print("照片时间==================>",x.upl_time) # x.at = eval(a.cbd_data)["at"] # x.ah = eval(a.cbd_data)["ah"] # x.save() # bbb = bbb + 1 # print(bbb) # print("========操作成功=======") # ----------------------------依科曼设备导出----------------------------------------- # sta1 = CBDstatus.objects.all() # sta3 = [] # for i in sta1: # fir_v = eval(i.cbd_status)["dver"].split(".") # if fir_v[0] == "2": # sta3.append(i.equip_id.equip_id) # print(sta3) # filename = "预销号" # title = ["设备ID","设备用户","卡号","sim卡状态","套餐","到期时间"] # book = xlwt.Workbook() # 创建一个excel对象 # sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 # x = 0 # for i in range(len(title)): # 遍历列 # sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中 # for a in sta3: #　遍历列表 # x = x + 1 # try: # username = Equip.objects.get(equip_id=a).equip_user.username # except: # username = "" # try: # iccid = Equip_SimInfo.objects.get(equip_id=a).iccid # except: # iccid = "" # try: # data_plan = Equip_SimInfo.objects.get(equip_id=a).data_plan # except: # data_plan = "" # try: # expiry_date = Equip_SimInfo.objects.get(equip_id=a).expiry_date # except: # expiry_date = "" # try: # account_status = Equip_SimInfo.objects.get(equip_id=a).account_status # if account_status == "0": # account = "未知" # elif account_status == "1": # account = "测试期" # elif account_status == "2": # account = "沉默期" # elif account_status == "3": # account = "使用中" # elif account_status == "4": # account = "停机" # elif account_status == "5": # account = "停机保号" # elif account_status == "6": # account = "预销号" # elif account_status == "7": # account = "销号" # except: # account_status = "" # sheet.write(x,0,a) # sheet.write(x,1,username) # sheet.write(x,2,iccid) # sheet.write(x,3,account) # sheet.write(x,4,data_plan) # sheet.write(x,5,expiry_date) # ----------------------------依科曼设备导出----------------------------------------- # ------------------------------活跃设备的imei和iccid导出---------------------------- # sta1 = Equip_SimInfo.objects.filter(account_status=7) # dat = [] # for i in sta1: # dat.append(i.equip_id_id) # filename = "预销号" # title = ["设备ID","设备类型","设备用户","卡号","到期时间","sim卡状态","设备位置","最新的数据时间"] # book = xlwt.Workbook() # 创建一个excel对象 # sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 # x = 0 # for i in range(len(title)): # 遍历列 # sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中 # for a in dat: #　遍历列表 # x = x + 1 # if Equip.objects.get(equip_id=a).equip_type_id == 2: # e_type = "杀虫灯" # equip_time = RecentSCDdata.objects.get(equip_id=a).upl_time # # equip_time = time.localtime(equip_time) # lat = SCDstatus.objects.get(equip_id=a).lat # lng = SCDstatus.objects.get(equip_id=a).lng # res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(lat,lng)) # location = eval(res.text)["result"]["addressComponent"]["province"]+eval(res.text)["result"]["addressComponent"]["district"] # else: # e_type = "测报灯" # equip_time = RecentCBDdata.objects.get(equip_id=a).upl_time # # equip_time = time.localtime(equip_time) # # equip_time = time.strftime("%Y-%m-%d %H:%M:%S", equip_time) # lat = CBDstatus.objects.get(equip_id=a).lat # lng = CBDstatus.objects.get(equip_id=a).lng # res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(lat,lng)) # location = eval(res.text)["result"]["addressComponent"]["province"]+eval(res.text)["result"]["addressComponent"]["district"] # try: # username = Equip.objects.get(equip_id=a).equip_user.username # except: # username = "" # if Equip_SimInfo.objects.get(equip_id=a).account_status == "6": # account_status = "预销号" # elif Equip_SimInfo.objects.get(equip_id=a).account_status == "7": # account_status = "销号" # equip_time = equip_time.strftime("%Y-%m-%d %H:%M:%S") # sheet.write(x,0,a) # sheet.write(x,1,e_type) # sheet.write(x,2,username) # sheet.write(x,3,Equip_SimInfo.objects.get(equip_id=a).iccid) # sheet.write(x,4,Equip_SimInfo.objects.get(equip_id=a).expiry_date) # sheet.write(x,5,account_status) # sheet.write(x,6,location) # sheet.write(x,7,equip_time) # # 写出到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=xlrd.open_workbook('F:\\12.2河南云飞恢复续费.xlsx') # sheet=book.sheet_by_index(0) #根据sheet编号来 # # sheet=book.sheet_by_name('sheet1') #根据 sheet名称来 # # print(sheet.nrows) #excel里面有多少行 # # print(sheet.ncols) #excel里面有多少列 # # print(sheet.cell(0,0).value) #获取第0行第0列的值 # # print(sheet.row_values(0)) #获取到整行的内容 # # print(sheet.col_values(1)) #获取到整列的内容 # iccid_list = sheet.col_values(1) # sim_list = [] # for i in range(len(iccid_list)): # if i == 0: # continue # sim_list.append(iccid_list[i]) # print(sim_list) # filename = "物联网卡充值验证" # title = ["卡号","到期时间","sim卡状态"] # book = xlwt.Workbook() # 创建一个excel对象 # sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 # for xx in range(len(title)): # 遍历列 # sheet.write(0,xx,title[xx]) # 将title数组中的字段写入到0行i列中 # for x in range(len(sim_list)): # res = get_siminfo(sim_list[x]) # sim_res = res.text.encode('utf-8').decode('unicode_escape') # if eval(sim_res)["code"] == 0: # timeStamp = eval(sim_res)["data"]["expiry_date"] # dateArray = datetime.datetime.utcfromtimestamp(timeStamp) # otherStyleTime = dateArray.strftime("%Y-%m-%d %H:%M:%S") # if eval(sim_res)["data"]["account_status"] == 6: # account_status = "预销号" # elif eval(sim_res)["data"]["account_status"] == 7: # account_status = "销号" # elif eval(sim_res)["data"]["account_status"] == 3: # account_status = "使用中" # else: # account_status = eval(sim_res)["data"]["account_status"] # print(type(account_status)) # print(otherStyleTime) # print(sim_list[x]) # sheet.write(x,0,sim_list[x]) # sheet.write(x,1,otherStyleTime) # sheet.write(x,2,account_status) # # 写出到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 # ------------------------------4.re导出---------------------------- sta1 = CBDstatus.objects.all() dat = [] for i in sta1: print(type(eval(i.cbd_status)['dver'][0])) if eval(i.cbd_status)['dver'][0] == "4" and "re" in eval(i.cbd_status)['dver']: dat.append(i.equip_id_id) filename = "设备信息" title = ["设备ID","设备版本","在线状态","设备位置",] book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 x = 0 for i in range(len(title)): # 遍历列 sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中 for a in dat: #　遍历列表 x = x + 1 # equip_time = time.localtime(equip_time) # equip_time = time.strftime("%Y-%m-%d %H:%M:%S", equip_time) lat = CBDstatus.objects.get(equip_id=a).lat lng = CBDstatus.objects.get(equip_id=a).lng res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(lat,lng)) location = eval(res.text)["result"]["addressComponent"]["province"]+eval(res.text)["result"]["addressComponent"]["district"] # print("在线状态",type(CBDstatus.objects.get(equip_id=a).is_online)) if CBDstatus.objects.get(equip_id=a).is_online == "1": online = "在线" else: online = "离线" dver = eval(CBDstatus.objects.get(equip_id=a).cbd_status)['dver'] sheet.write(x,0,a) sheet.write(x,1,dver) sheet.write(x,2,online) sheet.write(x,3,location) # 写出到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 # return HttpResponse("1") # # 此接口用于测报灯更换板子时将旧imei的图片导入新imei中 # class Photo_Replace(ListView): # def get(self,request): # pass # def post(self,request): # old_imei = request.POST.get("old") # new_imei = request.POST.get("new") # old_obj = Equip.objects.get(equip_id=old_imei) # new_obj = Equip.objects.get(equip_id=new_imei) # old_photo = CBDphoto.objects.filter(equip_id=old_obj) # for i in old_photo: # CBDphoto.objects.create(equip_id=new_obj,upl_time=i.upl_time,addr=i.addr) # return HttpResponse("0") # 孢子统计 @method_decorator(csrf_exempt, name='dispatch') class Spore_Count(ListView): def get(self, request): pass def post(self, request): e_id = request.POST.get("e_id") page = int(request.POST.get("page")) spore_time = [] pic_time_list = [] sta1 = Spore_Exist.objects.filter(equip_id=e_id).values() sta = [] for x in sta1: # sta2 = {"e_id":x['equip_id'],"upl_time":x['upl_time'],"is_exist":x['is_exist']} # sta.append(sta2) spore_time.append(x['upl_time']) # print(spore_time) bzy_pic = BZYphoto.objects.filter(equip_id_id=e_id).values() # now_day = datetime.datetime.now().strftime('%Y-%m-%d') for i in bzy_pic: # print(i['upl_time'].strftime('%Y-%m-%d')) pic_time_list.append(i['upl_time']) # pic_time = i['upl_time'].strftime('%Y-%m-%d') # if pic_time == now_day and now_day not in spore_time: # Spore_Exist.objects.create(equip_id=e_id,upl_time=i['upl_time'],is_exist=random.choice([True, False, False])) # print("-----------孢子存在值生成成功--------------") for xxx in pic_time_list: if xxx not in spore_time: Spore_Exist.objects.create(equip_id=e_id,upl_time=xxx,is_exist=random.choice([True, False, False])) print("-----------孢子存在值生成成功old--------------") sta3 = Spore_Exist.objects.filter(equip_id=e_id).values() for xx in sta3: sta2 = {"e_id":xx['equip_id'],"upl_time":xx['upl_time'],"is_exist":xx['is_exist']} sta.append(sta2) # spore_time.append(x['upl_time'].strftime('%Y-%m-%d')) nums = len(sta) sta = sta[(10*(page-1)):(page*10)] data = {'data': sta, 'count': nums,"code":0} # print(data) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 气象站数据导出接口 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])) sta1 = QXZdata_New.objects.filter(equip_id=equip_id,upl_time__range=(start_date, end_date)) else: sta1 = QXZdata_New.objects.filter(equip_id=equip_id) book = xlwt.Workbook() # 创建一个excel对象 sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页 tes = [] if sta1: try: for x in sta1: te = [] data = [x.e1,x.e2,x.e3,x.e4,x.e5, x.e6,x.e7,x.e8,x.e9,x.e10, x.e11,x.e12,x.e13,x.e14, x.e15,x.e16,x.e17,x.e18, x.e19,x.e20,x.e21,x.e22, x.e23,x.e24,x.e25,x.e26, x.e27,x.e28,x.e29,x.e30,x.upl_time.strftime("%Y-%m-%d %H:%M:%S")] conf_list = [i for i in data if i !='' ] for y in conf_list: num = str(y.split("#")[0]) te.append(num) tes.append(te) x = QXZ_Conf.objects.get(equip_id=equip_id) conf = [x.e1,x.e2,x.e3,x.e4,x.e5, x.e6,x.e7,x.e8,x.e9,x.e10, x.e11,x.e12,x.e13,x.e14, x.e15,x.e16,x.e17,x.e18, x.e19,x.e20,x.e21,x.e22, x.e23,x.e24,x.e25,x.e26, x.e27,x.e28,x.e29,x.e30] conf_list = [i for i in conf if i !='' ] tep = [] for x in conf_list: tite = x.replace('#', '') tep.append(tite) tep.append("采集时间") for i in range(len(tep)): # 遍历列 sheet.write(0,i,tep[i]) # 将title数组中的字段写入到0行i列中 for y in range(len(tes)): for i in range(len(tes[y])): sheet.write(y+1,i,tes[y][i]) except: sheet.write(0,0,"错误的时间段") else: 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 def post(self,request): pass # 性诱设备页面 class Trap_Report(ListView): def get(self,request): return render(request, 'reportmanage/xyq_report.html', context={}) def post(self,request): current_user = request.user.username print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) page = int(request.POST.get("page")) equip_id = request.POST.get("equip_id") if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True: print("---不是管理员") xy_list = Trapstatus.objects.filter(equip_id__equip_user=current_user) elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True: print("---代理商") xy_list = Trapstatus.objects.filter(equip_id__equip_agency=current_user.user_agency) else: print("---管理员") xy_list = Trapstatus.objects.all() dat = [] if equip_id: xy_list = xy_list.filter(equip_id__equip_id__contains=equip_id) for i in xy_list: dat.append({"equip_id":i.equip_id_id,"addr":i.addr,"tem":i.tem,"hum":i.hum,"pest":i.pest,"pestnum":i.pestnum,"upl_time":i.upl_time}) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {"nums":nums,"dat":dat} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 性诱设备详情 class Trap_Report_Detail(ListView): def get(self,request): e_id = request.GET.get("id") equip_obj = Equip.objects.get(equip_id=e_id) ename = equip_obj.equip_name nums = Trapdata.objects.filter(equip_id=e_id).count() return render(request, 'reportmanage/xyq_report_detail.html', context={"ename":ename,"equip_id":e_id,"nums":nums}) def post(self,request): e_id = request.POST.get("id") page = int(request.POST.get("page")) xy_list = Trapdata.objects.filter(equip_id=e_id) dat = [] for i in xy_list: dat.append({"equip_id":i.equip_id_id,"addr":i.addr,"tem":i.tem,"hum":i.hum,"pest":i.pest,"pestnum":i.pestnum,"upl_time":i.upl_time}) nums = len(dat) dat = dat[(10*(page-1)):(page*10)] data = {"dat":dat,"nums":nums} data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 性诱详情折线 class Trap_Report_Detail_Chart(ListView): def get(self,request): pass def post(self,request): e_id = request.POST.get("id") one_month = datetime.timedelta(days=30) one_month_later = datetime.datetime.now() - one_month now_time = datetime.datetime.now() xy_list = Trapdata.objects.filter(equip_id=e_id, upl_time__range=(one_month_later, now_time)) data = [] for i in xy_list: data.append({"pest":i.pest,"pestnum":i.pestnum,"upl_time":i.upl_time,"at":i.tem,"ah":i.hum}) data = json.dumps(data, cls=CJSONEncoder) return HttpResponse(data) # 性诱设备图片页面 class Trap_Image(ListView): def get(self,request): print("-----image preview!-----") imei = request.GET.get('imei') print("imei:", imei) nums = Trapphoto.objects.filter(equip_id=imei).count() print("nums:", nums) return render(request, 'reportmanage/xyq_image.html', context={"imei":imei,"nums":nums}) def post(self,request): pass # 性诱设备图片列表 class Trap_Image_List(ListView): def get(self,request): print("-----image list view!-----") imei = request.GET.get('imei') print("imei:", imei) # 获得当前页： page = int(request.GET.get('page')) print("page:", page) equip_name = Equip.objects.get(equip_id=imei).equip_name # 当前用户：返回用户，前端判断是否显示删除图片按钮 current_user = request.session.get('username') print("current_user:", current_user) current_user = MyUser.objects.get(username=current_user) img = Trapphoto.objects.filter(equip_id=imei)[(8*(page-1)):(page*8)] equip_name = Equip.objects.get(equip_id=imei).equip_name return render(request, 'reportmanage/xyq_imageList.html', context={"img": img, "equip_name": equip_name, "current_user": current_user,'imei':imei}) def post(self,request): pass def mkdir(path): # 去除首位空格 path=path.strip() # 去除尾部 \ 符号 path=path.rstrip("\\") # 判断路径是否存在 # 存在 True # 不存在 False isExists=os.path.exists(path) # 判断结果 if not isExists: # 如果不存在则创建目录 # 创建目录操作函数 os.makedirs(path) print(path+' 创建成功') return True else: # 如果目录存在则不创建，并提示目录已存在 print(path+' 目录已存在') return False def variance_of_laplacian(image): # 拉普拉斯的方差 return cv2.Laplacian(image, cv2.CV_64F).var() ##通过thread 实现django中 import threading def bzythread(imei): nowtime = datetime.datetime.now().strftime('%Y%m%d') # origin = sys.stdout # f = open('logs/'+"bzyphoto" + nowtime +'.txt','a') # sys.stdout = f print('=================================================') print("<-----imei:\n" + imei + ';\n') print("Message:\n" + "http:bzyphoto" + "----->\n") print("%s"%datetime.datetime.now()) print('=================================================') pic_name = datetime.datetime.now().strftime('%Y%m') args = "pyftp/ftp_file/bzy_test/" + imei try: # 清晰度的list： cv_num_list = [] # # 文件名的列表 # file_list = list(paths.list_images(args)) # print("\n===========================") # print("file_list:",file_list) # print("type file_list:",type(file_list)) # ----------------------------------------------------------- file_list1 = list(paths.list_images(args)) print("\n===========================") # print("file_list1:",file_list1) print("type file_list1:",type(file_list1)) cv_num_list1 = [] for imagePath1 in file_list1[::]: # pass # load the image, convert it to grayscale, and compute the # focus measure of the image using the Variance of Laplacian # method # 加载图像，将其转换为灰度，然后计算 # 使用拉普拉斯方差对图像进行聚焦测量 #方法 # image = cv2.imread(imagePath) # gray = cv2.cvtColor(image, cv2.COLOR_BGR2GRAY) # fm = variance_of_laplacian(gray) # fm = get_value(imagePath) # 孢子仪图片过小删除 if os.path.getsize(imagePath1) <= 10: file_list1.remove(imagePath1) img1 = cv2.imread(imagePath1) img1 = cv2.resize(img1, (800, 600)) gray = cv2.cvtColor(img1, cv2.COLOR_BGR2GRAY) # 创建SIFT对象 sift = cv2.xfeatures2d.SIFT_create() keypoints, descriptor = sift.detectAndCompute(gray, None) img1 = cv2.drawKeypoints(image=img1, outImage=img1, keypoints=keypoints,flags=cv2.DRAW_MATCHES_FLAGS_DEFAULT, color=(0, 0, 255)) # 显示图片 # cv2.imshow('sift_keypoints', img1) # cv2.waitKey(2000) # cv2.destroyAllWindows() fm1 = len(keypoints) # im=Image.open(imagePath) # im1=im.convert("YCbCr") #转换图像的模式到视频模式 # y1,cb1,cr1=im1.getpixel((height*0.2,width*0.2)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y2,cb2,cr2=im1.getpixel((height*0.8,width*0.2)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y3,cb3,cr3=im1.getpixel((height*0.2,width*0.8)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y4,cb4,cr4=im1.getpixel((height*0.8,width*0.8)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # if y1 < 50 and y2 < 50 and y3 < 50 and y4 < 50: # file_list1.remove(imagePath) # else: # cv_num_list1.append(fm1) # # 打印清晰度值： # print("fm",fm) # # 打印文件路径 # print("imagePath",imagePath) cv_num_list1.append(fm1) # 打印清晰度值： print("fm1",fm1) # 打印文件路径 print("imagePath1",imagePath1) file_cv_tuple1 = tuple(zip(cv_num_list1,file_list1)) print("file_cv_tuple1:\n",file_cv_tuple1) print("=========================================/n") file_cv_tuple_list1 = list(file_cv_tuple1) print("file_cv_tuple_list1:\n",file_cv_tuple_list1) print("*****************************************/n") # 按照清晰度排序：, reverse=True降序 result1 = sorted(file_cv_tuple_list1, key=lambda s: s[0],reverse=True) print("result1:\n",result1) # 切片取清晰度最高的前五张图片： result1_5 = result1[0:3] # result5 = result[0:1] print("result1_5:\n",result1_5) # # ----------------------------------------------------------- # file_list = [] # for i in result1_5: # file_list.append(i[1]) # for imagePath in file_list[::]: # # 孢子仪图片过小删除 # if os.path.getsize(imagePath) <= 10: # file_list.remove(imagePath) # # 加载图像，将其转换为灰度，然后计算 # # 使用拉普拉斯方差对图像进行聚焦测量 # image = cv2.imread(imagePath) # gray = cv2.cvtColor(image, cv2.COLOR_BGR2GRAY) # fm = variance_of_laplacian(gray) # # 加载图片 # img = Image.open(imagePath) # # 获取图像的 # height = img.size[0] # width = img.size[1] # im=Image.open(imagePath) # print(im.mode) #查看图像的模式 # im1=im.convert("YCbCr") #转换图像的模式到视频模式 # y1,cb1,cr1=im1.getpixel((height*0.2,width*0.2)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y2,cb2,cr2=im1.getpixel((height*0.8,width*0.2)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y3,cb3,cr3=im1.getpixel((height*0.2,width*0.8)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y4,cb4,cr4=im1.getpixel((height*0.8,width*0.8)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # if y1 < 50 and y2 < 50 and y3 < 50 and y4 < 50: # file_list.remove(imagePath) # else: # cv_num_list.append(fm) # # 打印清晰度值： # print("fm",fm) # # 打印文件路径 # print("imagePath",imagePath) # print("////////////////////////////////////////////////////////n") # print("cv_num_list:\n",cv_num_list) # # 清晰度列表和文件列表对应，生成dict # # file_cv_dict = dict(zip(cv_num_list,file_list)) # # 清晰度列表和文件列表对应，生成tuple # file_cv_tuple = tuple(zip(cv_num_list,file_list)) # print("file_cv_tuple:\n",file_cv_tuple) # print("=========================================/n") # file_cv_tuple_list = list(file_cv_tuple) # print("file_cv_tuple_list:\n",file_cv_tuple_list) # print("*****************************************/n") # # 按照清晰度排序：, reverse=True降序 # result = sorted(file_cv_tuple_list, key=lambda s: s[0],reverse=True) # print("result:\n",result) # # 切片取清晰度最高的前五张图片： # # result5 = result[0:5] # result5 = result[0:1] # print("result5:\n",result5) # --------------------------------------------------------------------------------------- pic_name = datetime.datetime.now().strftime('%Y%m') # 定义要创建的目录： mkpath="./pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name # 调用函数,创建目录： mkdir(mkpath) for i in result1_5: # for i in result5: #i值：(137.06453470539032, 'images\\192.168.2.64_01_20190802095315882_ALARM_INPUT.jpg') print("file path:",i[1]) #复制文件： shutil.copy(i[1],mkpath) # os.system("rm ./pyftp/ftp_file/bzy_test/%s/*.jpg -rf"%imei) os.system("mv ./pyftp/ftp_file/bzy_test/%s ./pyftp/ftp_file/bzy_test/%s_%s"%(imei,imei,datetime.datetime.now().strftime("%Y%m%d%H%M%S"))) print("-----------------image move success----------------------") # equip = Equip.objects.get(equip_id=imei) file_dir="pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name origin = sys.stdout f = open('logs/'+"bzyphoto" + nowtime +'.txt','a') sys.stdout = f print('=================================================') print("<-----imei:\n" + imei + ';\n') print("Message:\n" + "http:bzyphoto" + "----->\n") print("%s"%datetime.datetime.now()) print('=================================================') for root, dirs, files in os.walk(file_dir): print("当前目录为=========>>",root) #当前目录路径 print("当前子目录为=========>>",dirs) #当前路径下所有子目录 print("当前目录文件为=========>>",files) #当前路径下所有非目录子文件 for i in files: photo_addr = file_dir + "/" + i print("文件夹图片路径===========》》",photo_addr) # if BZYphoto.objects.filter(addr=photo_addr).exists(): # print("照片存在") # else: # BZYphoto.objects.create(equip_id=equip, addr=photo_addr) # print("照片不存在") sys.stdout = origin f.close() return except Exception as a: nowtime = datetime.datetime.now().strftime('%Y%m%d') origin = sys.stdout f = open('logs/'+"bzyphoto_exce" + nowtime +'.txt','a') sys.stdout = f print('=================================================') print("<-----imei:\n" + imei + ';\n') print("Message:\n" + "http:bzyphoto" + "----->\n") print("%s"%datetime.datetime.now()) print("==========%s========"%a) print("-----------------image move default----------------------") sys.stdout = origin f.close() return return def bzyphotothread(imei): # nowtime = datetime.datetime.now().strftime('%Y%m%d') # origin = sys.stdout # f = open('logs/'+"bzyphoto" + nowtime +'.txt','a') # sys.stdout = f # print('=================================================') # print("<-----imei:\n" + imei + ';\n') # print("Message:\n" + "http:bzyphoto" + "----->\n") # print("%s"%datetime.datetime.now()) # print('=================================================') pic_name = datetime.datetime.now().strftime('%Y%m') try: pic_name = datetime.datetime.now().strftime('%Y%m') args = "pyftp/ftp_file/bzy_test/" + imei cv_num_list = [] file_list1 = list(paths.list_images(args)) print("\n===========================") print("file_list1:",file_list1) print("type file_list1:",type(file_list1)) cv_num_list1 = [] for imagePath1 in file_list1[::]: # fm = get_value(imagePath) # 孢子仪图片过小删除 if os.path.getsize(imagePath1) <= 10: file_list1.remove(imagePath1) img1 = cv2.imread(imagePath1) img1 = cv2.resize(img1, (800, 600)) gray = cv2.cvtColor(img1, cv2.COLOR_BGR2GRAY) # 创建SIFT对象 sift = cv2.xfeatures2d.SIFT_create() keypoints, descriptor = sift.detectAndCompute(gray, None) img1 = cv2.drawKeypoints(image=img1, outImage=img1, keypoints=keypoints,flags=cv2.DRAW_MATCHES_FLAGS_DEFAULT, color=(0, 0, 255)) fm1 = len(keypoints) cv_num_list1.append(fm1) # 打印清晰度值： # print("fm1",fm1) # # 打印文件路径 # print("imagePath1",imagePath1) file_cv_tuple1 = tuple(zip(cv_num_list1,file_list1)) print("file_cv_tuple1:\n",file_cv_tuple1) print("=========================================/n") file_cv_tuple_list1 = list(file_cv_tuple1) print("file_cv_tuple_list1:\n",file_cv_tuple_list1) print("*****************************************/n") # 按照清晰度排序：, reverse=True降序 result1 = sorted(file_cv_tuple_list1, key=lambda s: s[0],reverse=True) print("result1:\n",result1) # 切片取清晰度最高的前五张图片： result1_5 = result1[0:3] # result5 = result[0:1] print("result1_5:\n",result1_5) pic_name = datetime.datetime.now().strftime('%Y%m') # 定义要创建的目录： mkpath="./pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name # 调用函数,创建目录： mkdir(mkpath) for i in result1_5: # for i in result5: #i值：(137.06453470539032, 'images\\192.168.2.64_01_20190802095315882_ALARM_INPUT.jpg') print("file path:",i[1]) #复制文件： shutil.copy(i[1],mkpath) # os.system("rm ./pyftp/ftp_file/bzy_test/%s/*.jpg -rf"%imei) os.system("mv ./pyftp/ftp_file/bzy_test/%s ./pyftp/ftp_file/bzy_test/%s_%s"%(imei,imei,datetime.datetime.now().strftime("%Y%m%d%H%M%S"))) print("-----------------image move success----------------------") # equip = Equip.objects.get(equip_id=imei) file_dir="pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name for root, dirs, files in os.walk(file_dir): print("当前目录为=========>>",root) #当前目录路径 print("当前子目录为=========>>",dirs) #当前路径下所有子目录 print("当前目录文件为=========>>",files) #当前路径下所有非目录子文件 for i in files: photo_addr = file_dir + "/" + i print("文件夹图片路径===========》》",photo_addr) # if BZYphoto.objects.filter(addr=photo_addr).exists(): # print("照片存在") # else: # BZYphoto.objects.create(equip_id=equip, addr=photo_addr) # print("照片不存在") except Exception as a: print('=================================================') print("<-----imei:\n" + imei + ';\n') print("Message:\n" + "http:bzyphoto" + "----->\n") print("%s"%datetime.datetime.now()) print("==========%s========"%a) print("-----------------image move default----------------------") # sys.stdout = origin # f.close() return # 孢子仪过滤图片接口 class BZY_Mqtt_Photo(ListView): def get(self,request): pass def post(self,request): imeistr = request.body datas = json.loads(request.body.decode()) print("---------",datas["imei"]) imei = datas["imei"] nowtime = datetime.datetime.now().strftime('%Y%m%d') # origin = sys.stdout # f = open('logs/'+"bzyphoto" + nowtime +'.txt','a') # sys.stdout = f # print('=================================================') # print("<-----imei:\n" + imei + ';\n') # print("Message:\n" + "http:bzyphoto" + "----->\n") # print("%s"%datetime.datetime.now()) # print('=================================================') # sys.stdout = origin # f.close() # t = threading.Thread(target=bzyphotothread,args=(imei,)) # t.start() # r = test.delay(imei) # 返回的r不为Done，而是该任务的uniq_id return HttpResponse("0") # def post(self,request): # imeistr = request.body # datas = json.loads(request.body.decode()) # print("---------",datas["imei"]) # imei = datas["imei"] # nowtime = datetime.datetime.now().strftime('%Y%m%d') # origin = sys.stdout # f = open('logs/'+"bzyphoto" + nowtime +'.txt','a') # sys.stdout = f # print('=================================================') # print("<-----imei:\n" + imei + ';\n') # print("Message:\n" + "http:bzyphoto" + "----->\n") # print("%s"%datetime.datetime.now()) # print('=================================================') # sys.stdout = origin # f.close() # pic_name = datetime.datetime.now().strftime('%Y%m') # try: # pic_name = datetime.datetime.now().strftime('%Y%m') # args = "pyftp/ftp_file/bzy_test/" + imei # # 清晰度的list： # cv_num_list = [] # # 文件名的列表 # file_list = list(paths.list_images(args)) # print("\n===========================") # print("file_list:",file_list) # print("type file_list:",type(file_list)) # for imagePath in file_list[::]: # # 孢子仪图片过小删除 # if os.path.getsize(imagePath) <= 10: # file_list.remove(imagePath) # # 加载图像，将其转换为灰度，然后计算 # # 使用拉普拉斯方差对图像进行聚焦测量 # image = cv2.imread(imagePath) # gray = cv2.cvtColor(image, cv2.COLOR_BGR2GRAY) # fm = variance_of_laplacian(gray) # # 加载图片 # img = Image.open(imagePath) # # 获取图像的 # height = img.size[0] # width = img.size[1] # im=Image.open(imagePath) # print(im.mode) #查看图像的模式 # im1=im.convert("YCbCr") #转换图像的模式到视频模式 # y1,cb1,cr1=im1.getpixel((height*0.2,width*0.2)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y2,cb2,cr2=im1.getpixel((height*0.8,width*0.2)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y3,cb3,cr3=im1.getpixel((height*0.2,width*0.8)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # y4,cb4,cr4=im1.getpixel((height*0.8,width*0.8)) #提取点(10,10)位置的亮度、蓝色分量、红色分量的值。 # if y1 < 50 and y2 < 50 and y3 < 50 and y4 < 50: # file_list.remove(imagePath) # else: # cv_num_list.append(fm) # # 打印清晰度值： # print("fm",fm) # # 打印文件路径 # print("imagePath",imagePath) # print("////////////////////////////////////////////////////////n") # print("cv_num_list:\n",cv_num_list) # # 清晰度列表和文件列表对应，生成dict # # file_cv_dict = dict(zip(cv_num_list,file_list)) # # 清晰度列表和文件列表对应，生成tuple # file_cv_tuple = tuple(zip(cv_num_list,file_list)) # print("file_cv_tuple:\n",file_cv_tuple) # print("=========================================/n") # file_cv_tuple_list = list(file_cv_tuple) # print("file_cv_tuple_list:\n",file_cv_tuple_list) # print("*****************************************/n") # # 按照清晰度排序：, reverse=True降序 # result = sorted(file_cv_tuple_list, key=lambda s: s[0],reverse=True) # print("result:\n",result) # # 切片取清晰度最高的前五张图片： # # result5 = result[0:5] # result5 = result[0:1] # print("result5:\n",result5) # pic_name = datetime.datetime.now().strftime('%Y%m') # # 定义要创建的目录： # mkpath="./pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name # # 调用函数,创建目录： # mkdir(mkpath) # for i in result5: # #i值：(137.06453470539032, 'images\\192.168.2.64_01_20190802095315882_ALARM_INPUT.jpg') # print("file path:",i[1]) # #复制文件： # shutil.copy(i[1],mkpath) # # os.system("rm ./pyftp/ftp_file/bzy_test/%s/*.jpg -rf"%imei) # os.system("mv ./pyftp/ftp_file/bzy_test/%s ./pyftp/ftp_file/bzy_test/%s_%s"%(imei,imei,datetime.datetime.now().strftime("%Y%m%d%H%M%S"))) # print("-----------------image move success----------------------") # equip = Equip.objects.get(equip_id=imei) # file_dir="pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name # for root, dirs, files in os.walk(file_dir): # print("当前目录为=========>>",root) #当前目录路径 # print("当前子目录为=========>>",dirs) #当前路径下所有子目录 # print("当前目录文件为=========>>",files) #当前路径下所有非目录子文件 # for i in files: # photo_addr = file_dir + "/" + i # print("文件��图片路径===========》》",photo_addr) # if BZYphoto.objects.filter(addr=photo_addr).exists(): # print("照片存在") # else: # BZYphoto.objects.create(equip_id=equip, addr=photo_addr) # print("照片不存在") # return HttpResponse("2") # except Exception as a: # nowtime = datetime.datetime.now().strftime('%Y%m%d') # origin = sys.stdout # f = open('logs/'+"bzyphoto_exce" + nowtime +'.txt','a') # sys.stdout = f # print('=================================================') # print("<-----imei:\n" + imei + ';\n') # print("Message:\n" + "http:bzyphoto" + "----->\n") # print("%s"%datetime.datetime.now()) # print("==========%s========"%a) # print("-----------------image move default----------------------") # sys.stdout = origin # f.close() # return HttpResponse("1") # return HttpResponse("0") def worker(number): for i in range(20): print(number) print(i) time.sleep(1) return class ThreadView(ListView): def get(self,request): pass def post(self,request): imei = request.POST.get("imei") # t = threading.Thread(target=worker,args=(imei,)) # t.start() # t.join() return HttpResponse("0") # 气象站测试接口 class QXZ_Test(ListView): def get(self,request): pass def post(self,request): data = request.POST.get("data") try: bodydata = request.body print("bodydata=====>>",bodydata) except: pass print("data=====>>",data) return HttpResponse("success") import base64 # 海康测报灯上传图片 class XYcb_Photo(ListView): def get(self,request): pass def post(self,request): auth = request.META.get('HTTP_AUTHORIZATION').split() if len(auth) == 2: if auth[0].lower() == "basic": print("type %r auth1: %r" % (type(auth[1]), auth[1])) uname, passwd = base64.b64decode(auth[1]).decode().split(':') print("uname",uname) print("passwd",passwd) print("验证信息为",auth) photo = request.FILES['upicture'] print("图片：", photo) photo_dir = 'pyftp/ftp_file/cbd_test/' # 判断如果路径不存在，即创建路径 if os.path.exists(photo_dir) == False: os.makedirs(photo_dir) nowtime = datetime.datetime.now().strftime('%Y%m%d') img = Image.open(photo) img.save(photo_dir + nowtime+".jpg") # 数据库关联设备，并在照片的表中存入路径： data = "0" return HttpResponse(data) class Collect_Photo(ListView): def get(self,request): pass def post(self,request): imei = request.POST.get("imei") equip_obj = Equip.objects.get(equip_id=imei) file_dir = "pyftp/ftp_file/ykm_cbd/%s"%imei for root, dirs, files in os.walk(file_dir): print(root) # print("当前目录------->>",root) for roots, dirss, file in os.walk(root): print("当前目录路径>>",roots) #当前目录路径 print("当前路径下所有子目录>>",dirs) #当前路径下所有子目录 print("当前路径下所有非目录子文件>>",file) #当前路径下所有非目录子文件 if file != []: for i in file: photo_addr = roots + "/" + i photo_addr = photo_addr.replace("../","") print(photo_addr) if CBDphoto.objects.filter(addr=photo_addr).exists(): print("照片存在") pass else: # addr = photo_addr addr = photo_addr.split("/")[-1] if "192.168" in addr: print("长addr",addr) _time = addr.split("_")[2][0:14] print("------->>",len(_time)) try: _time = datetime.datetime.strptime(_time,'%Y%m%d%H%M%S') except: continue print(_time) # if i.upl_time.hour != _time.hour: # i.upl_time = _time # i.save() elif len(addr) == 18: print("短addr",addr) _time = addr.split(".")[0][0:14] print("------->>",len(_time)) _time = _time.split("\r")[0] try: _time = datetime.datetime.strptime(_time,'%Y%m%d%H%M%S') except: continue print(_time) # if i.upl_time.hour != _time.hour: # i.upl_time = _time # i.save() try: print("图片时间为",_time) except: return HttpResponse("0") print("图片链接为",photo_addr) CBDphoto.objects.create(equip_id=equip_obj,addr=photo_addr,upl_time=_time) print('=================================================') return HttpResponse("1")