yfwlwCut/apps/PestPC/views.py

import json
import random
import re
from io import BytesIO
import hashlib
import requests
import xlwt
from django.contrib.auth.hashers import check_password, make_password
# Create your views here.
from django.http import HttpResponse, JsonResponse, StreamingHttpResponse
from django.shortcuts import redirect, render
from django.views.generic import ListView
from django.views.generic.base import View

from apps.AppInfoManage.models import *
from apps.EquipManage.views import CJSONEncoder
from apps.Pestapp.views import verification_code
from django.db.models import Q
import os
import time
import datetime
from PIL import Image



#判断当前登录用户类型
class Judge_User(ListView):
    def get(self, request):
        name = request.session.get("username")
        # name = "admin"
        user_name = MyUser.objects.get(username=name)
        if user_name.is_superuser == True and user_name.is_staff == True and user_name.is_active == True:
            data = 1
            print("管理员")
        else:
            consumer = Purchase.objects.filter(userid=user_name)
            if consumer.exists():
                data = 2
                print("用户已购买")
            else:
                data = 3
        return HttpResponse(data)
    #筛选未购买的用户
    def post(self, request):
        page = int(request.POST.get("page"))
        ret = request.POST.get("ret")
        user_list = MyUser.objects.all()
        data = [] #未分配
        date = [] #已分配
        for i in user_list:
            buy_user = Purchase.objects.filter(userid=i.id)
            if buy_user.exists():
               date.append({
                     "username":i.username,"email":i.email,"time":i.date_joined.strftime("%Y-%m-%d %H:%M:%S"),
                "phone":i.user_phone,"ret":"2"
                })
            else:
                data.append({
                     "username":i.username,"email":i.email,"time":i.date_joined.strftime("%Y-%m-%d %H:%M:%S"),
                "phone":i.user_phone,"ret":"1"
                })
        if ret == "now": # 以购买用户
            num = len(date)
            dat = date[(10*(page-1)):(page*10)]
        elif ret == "off": #未购买用户
            num = len(data)
            dat = data[(10*(page-1)):(page*10)]
        elif ret == "all": # 全部用户
            dats = date + data
            num = len(dats)
            dat = dats[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)
            

#分配账号页面
class Allocation(ListView):
    def get(self, request):
         return render(request, "pestDiagnosis/insect_allocation.html", context={})


#取消分配：
class Cancel_Branch(ListView):
    def post(self, request):
        name = request.POST.get("name")
        ret = request.POST.get("ret")
        data = []
        names = MyUser.objects.get(username=name)
        if ret == "del": #取消分配
            p_user = Purchase.objects.filter(userid=names)
            if p_user.exists():
                Purchase.objects.get(userid__username=name).delete()
                data = 1
            else:
                data = 3
        elif ret == "screen": # 按用户名字进行筛选
            user_list = MyUser.objects.filter(username=name)
            for i in user_list:
                data.append({
                "username":i.username,"email":i.email,"time":i.date_joined.strftime("%Y-%m-%d %H:%M:%S"),
                "phone":i.user_phone
            })
        elif ret == "dist": #分配账号
            p_user = Purchase.objects.filter(userid=names)
            if p_user.exists():
                data = 2
            else:
                Purchase.objects.create(userid=names)
                data = 0
                print("分配账号")
        data = json.dumps(data)
        return HttpResponse(data)


#查看采集数据详情和当前账号下所有测报员信息
class Look_User(ListView):
    def get(self, request):
        return render(request, "pestDiagnosis/pestDiagnosisList.html", context={})

    def post(self, request):
        name = request.session.get("username")
        user_name = MyUser.objects.get(username=name)
        page = int(request.POST.get("page"))

        data = []
        if user_name.is_superuser == True and user_name.is_staff == True and user_name.is_active == True:
            print("管理员")
            account = User_Reporter.objects.all()
        else:
            print("普通用户")
            account = User_Reporter.objects.filter(user_id=user_name)
        num = account.count()
        for i in account:
            data.append({
                "name": i.name,
                "phone": i.phone,
                "time": i.time.strftime("%Y-%m-%d %H:%M:%S"),
                "addr": i.addr,
                "id": i.id,
                "user_id": i.user_id.username
            })
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)


#新增数据省市县三级联动
class Cate_Insect(ListView):
    def get(self, request):
        name = request.session.get("username")
        print("name", name)
        user_name = MyUser.objects.get(username=name)
        addr = Address_Province.objects.filter(id__lt=35)
        insect = Insect_Plant.objects.filter(ids=user_name)
        return render(request, "pestDiagnosis/newPestDiagnosis.html", context={"addr": addr, "insect": insect})

    def post(self, request):
        code = request.POST.get("code")
        if code:
            city = Address_Province.objects.filter(parent_code=code)
            citys = []
            for i in city:
                citys.append(
                    {"name": i.name, "parent_code": i.parent_code, "code": i.code})
            new_s = []
            for x in citys:
                if x not in new_s:
                    new_s.append(x)
            data = json.dumps(new_s)
        else:
            data = 0
        return HttpResponse(data)


#分配子账号秘钥
class New_Code(ListView):
    def get(self, request):
        word = verification_code().encode("utf-8")
        password = hashlib.sha1(word).hexdigest()
        pass_word = password[8:]
        data = {"dat": pass_word}
        data = json.dumps(data)
        return HttpResponse(data)


#分配测报员账号接口
class New_Reporter(ListView):
    def post(self, request):
        names = request.POST.get("username")
        password = request.POST.get("password")
        phone = request.POST.get("phone")
        addr = request.POST.get("addr")
        user_por = request.POST.get("user_por")
        user_city = request.POST.get("user_city")
        user_area = request.POST.get("user_area")
        code = request.POST.get("code")

        name = request.session.get("username")
        user_name = MyUser.objects.get(username=name)
        if not all([names,password,user_area,user_city,user_por,code,name,user_name]):
            data = 0
            return HttpResponse(data)
        prov = Address_Province.objects.get(code=user_por)  # 省
        prov = str(prov)
        citys = Address_Province.objects.get(code=user_city)  # 市
        citys = str(citys)
        areaes = Address_Province.objects.get(code=user_area)  # 区
        areaes = str(areaes)
        addrs = prov + citys + areaes + addr

        reporter = User_Reporter.objects.filter(user_id=user_name)
        num = reporter.count()
        if num == 3:
            data = 2
            return HttpResponse(data)
        else:
            if reporter:
                for i in reporter:
                    if i.name == names:
                        data = 0
                        print("该{}账号下已存在{}".format(i.name, names))
                        return HttpResponse(data)
                    else:
                        password = make_password(password)
                        User_Reporter.objects.create(
                            user_id=user_name, name=names, password=password, phone=phone, addr=addrs)
                        Encryption.objects.create(cipher=code)
                        data = 1
                        return HttpResponse(data)
            else:
                password = make_password(password)
                User_Reporter.objects.create(
                    user_id=user_name, name=names, password=password, phone=phone, addr=addrs)
                Encryption.objects.create(cipher=code)
                data = 1
                return HttpResponse(data)
        


#生成激活码主账号激活码
class Activation_Code(ListView):
    def get(self, request):
        name = request.session.get("username")
        print("name:", name)
        uid = MyUser.objects.get(username=name)
        if uid.is_superuser == True and uid.is_staff == True and uid.is_active == True:
            print("管理员")
            word = verification_code().encode("utf-8")
            password = hashlib.sha1(word).hexdigest()
            pass_word = password[8:]
            print(pass_word)
            Encryption.objects.create(cipher=pass_word)
            data = pass_word
        else:
            print("普通用户")
            data = 0
        return HttpResponse(data)


#查看主账号下测报员信息
class User_Account(ListView):
    def get(self, request):
        name = request.session.get("username")
        uid = MyUser.objects.get(username=name)
        data = []
        account = User_Account.objects.filter(user_id=uid)
        for i in account:
            data.append({
                "name": i.name,
                "phone": i.phone,
                "time": i.time.strftime("%Y-%m-%d %H:%M:%S"),
                "addr": i.addr,
                "id": i.id,
                "user_id": i.user_id.username
            })
        data = json.dumps(data)
        return HttpResponse(data)

    #重置测报员密码
    def post(self, request):
        password = request.POST.get("password")
        password1 = request.POST.get("password1")
        cbyid = request.POST.get("id")

        if not all([password,password1,cbyid]):
            data = 0
            return HttpResponse(data)

        user_list = User_Reporter.objects.get(id=cbyid)
        if password == password1:
            password = make_password(password)
            user_list.password = password
            user_list.save()
            data = 1
        else:
            data = 0
        return HttpResponse(data)


#查看主用户下所有的测报员的信息,所有的识别记录 、已录信息
class Check_Account(ListView):
    def get(self, request):
        ret = request.GET.get("ret")
        req = request.GET.get("req")
        page = int(request.GET.get("page"))

        name = request.session.get("username")
        # name = "admin"
        print("name", name)
        user_name = MyUser.objects.get(username=name)

        if not all([ret,req,page,name,user_name]):
            data = 0
            return HttpResponse(data)
        data = []
        gly = ''
        if user_name.is_superuser == True and user_name.is_staff == True and user_name.is_active == True:
            print("管理员")
            if ret == "2":
                insects = App_Insect.objects.filter(~Q(name=None))
            elif ret == "1":
                insects = App_Plant.objects.filter(~Q(name=None))
            gly = 1
        else:
            print("普通用户")
            if ret == "2":
                insects = App_Insect.objects.filter(~Q(name=None), userid=user_name)
            elif ret == "1":
                insects = App_Plant.objects.filter(~Q(name=None), userid=user_name)
        if gly == 1: #指明是登录身份是管理员
            insect = User_Data_Table_New.objects.filter(harm_id__pest_sort=ret) 
        else:
            insect = User_Data_Table_New.objects.filter(user_id__user_id=user_name,harm_id__pest_sort=ret)        
        if req == "cord":  # 已录信息
            for i in insect:
                data.append({"user_name":i.user_id.name,"growth_stages":i.growth_stages,"area":i.area,"pest_name":i.harm_id.pest_name,"month":i.harm_id.month_id.month,
                    "pest":i.harm_id.pest,"crop_sort":i.harm_id.crop_sort,"cens_method":i.cens_method,"city":i.harm_id.month_id.addr_id.name,"id":i.id,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')
                    ,"city_id":i.harm_id.month_id.addr_id.id,"harm_id":i.harm_id.id,"pest_sort":i.harm_id.pest_sort,"username":i.user_id.user_id.username,
            })
            num = insect.count()
        elif req == "disc": #识别信息
            for x in insects:
                data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course,
                                "name": x.name, "addr": x.addr, "id": x.id, "ret": ret, "req": req})
            num = insects.count()
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)
    

    #查看已录和识别数据详情信息
    def post(self, request):
        account_id = request.POST.get("id")
        ret = request.POST.get("ret")
        req = request.POST.get("req")

        dats = [] #病虫害照片列表
        date = [] # 病虫害值
        data = [] #数据列表
        if ret == "2":
            insect = App_Insect.objects.filter(id=account_id)
        elif ret == "1":
            insect = App_Plant.objects.filter(id=account_id)
        if req == "cord":
            user_list = User_Data_Table_New.objects.filter(id=account_id)
            for i in user_list:
                #病害级别转换成list
                pestname = eval(i.pestname)
                key = list(pestname)
                valu = list(pestname.values())
                for x in range(len(key)):
                        date.append({key[x]: valu[x]})
                # da.append(i.pestname)
                #判断用户上传的图片是多张还是一张进行切割
                if i.addr_photo.find(",") != -1:
                    prc_list = i.addr_photo.split(",")
                    for y in prc_list:
                        dats.append(y)
                else:
                    dats.append(i.addr_photo)
                data.append({"user_name":i.user_id.name,"growth_stages":i.growth_stages,"addr_photo":dats,"pestname":date,"area":i.area,"pest_name":i.harm_id.pest_name,"month":i.harm_id.month_id.month,
                    "pest":i.harm_id.pest,"crop_sort":i.harm_id.crop_sort,"cens_method":i.cens_method,"city":i.harm_id.month_id.addr_id.name,"id":i.id,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')
                    ,"city_id":i.harm_id.month_id.addr_id.id,"harm_id":i.harm_id.id,"pest_sort":i.harm_id.pest_sort,"username":i.user_id.user_id.username,
                        })
        elif req == "disc":
            for x in insect:
                data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course,
                             "name": x.name, "addr": x.addr, "img": x.img.name, "img_urls": x.img_urls, "prevention": x.prevention, "id": x.id, "ret": ret, "req": req,"lat": x.lat, "lng": x.lng,
                             })
        data = json.dumps(data)
        return HttpResponse(data)


#删除测报员账号
class Del_Account(ListView):
    def post(self, request):
        cbyid = request.POST.get("id")
        if not all([cbyid]):
            data = 0
            return HttpResponse(data)
        try:
            user_list = User_Reporter.objects.get(id=cbyid).delete()
            data = 1
        except Exception as e:
            print(e)
            data = 0
        return HttpResponse(data)


#删除指定数据 只删除数据，但是图片保留
class Del_Mation(ListView):
    def post(self,request):
        ids = request.POST.get("id")
        ret = request.POST.get("ret")
        data = []
        try:
            if ret == "2":
                insects = App_Insect.objects.get(id=ids)
                if os.path.exists(insects.img):
                    os.remove(insects.img)
            elif ret == "1":
                insects = App_Plant.objects.get(id=ids)
                if os.path.exists(insects.img):
                    os.remove(insects.img)
            else:
                insects = User_Data_Table_New.objects.get(id=ids)
                if insects.addr_photo.find(",") != -1:
                        pic_list = insects.addr_photo.split(",")
                        for x in pic_list:
                            if os.path.exists(x):
                                os.remove(x)
                else:
                    print(insects.addr_photo)
                    if os.path.exists(insects.addr_photo):
                        os.remove(insects.addr_photo)
            insects.delete()
            data = 1 
        except Exception as e:
            data = 0
            print(e)
        return HttpResponse(data)


#测报员数据页面
class See_Account(ListView):
    def get(self, request):
        return render(request, "pestDiagnosis/dataList.html", context={})



#测报员数据详情页面
class See_Mation(ListView):
    def get(self, request):
        return render(request, "pestDiagnosis/details.html", context={})
    


#查看指定测报员下的数据,
class Look_Account(ListView):
    def post(self, request):
        ret = request.POST.get("ret")
        print("ret",ret)
        req = request.POST.get("req")
        print("req",req)
        reporter_id = request.POST.get("id")
        print(reporter_id)
        page = int(request.POST.get("page"))
        dat = []
        da = []
        data = []
        if ret == "2":
            insect = App_Insect.objects.filter(~Q(name=None),reporter_id=reporter_id)
        elif ret == "1":
            insect = App_Plant.objects.filter(~Q(name=None),reporter_id=reporter_id)
        if req == "cord":  # 已录信息
            insect = User_Data_Table_New.objects.filter(harm_id__pest_sort=ret, user_id=reporter_id)
            for i in insect:
                    data.append({"user_name":i.user_id.name,"growth_stages":i.growth_stages,"area":i.area,"pest_name":i.harm_id.pest_name,"month":i.harm_id.month_id.month,
                    "pest":i.harm_id.pest,"crop_sort":i.harm_id.crop_sort,"cens_method":i.cens_method,"city":i.harm_id.month_id.addr_id.name,"id":i.id,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')
                    ,"city_id":i.harm_id.month_id.addr_id.id,"harm_id":i.harm_id.id,"pest_sort":i.harm_id.pest_sort,"username":i.user_id.user_id.username,
                    })
        elif req == "disc": #识别记录
            for x in insect:
                data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course, "name": x.name,
                             "addr": x.addr, "id": x.id, "ret": ret, "req": req
                             })
        num = insect.count()
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        print("data",data)
        return HttpResponse(data)


#按病虫害名字进行筛选和筛选某一测报员下病虫害名字数据
class Screen_Name(ListView):
    def post(self, request):
        ret = request.POST.get("ret")
        req = request.POST.get("req")
        plant_name = request.POST.get("name")
        page = int(request.POST.get("page"))
        name = request.session.get("username")

        repor_id = request.POST.get("id") 
        print("name", name)
        # name = "admin"
        user_name = MyUser.objects.get(username=name)
        print(user_name)
        data = []
        #__contains 模糊查询
        if ret == "2":
            insects = App_Insect.objects.filter(Q(name__contains=plant_name,userid=user_name) | Q(name__contains=plant_name,reporter_id=repor_id) )
        elif ret == "1":
            insects = App_Plant.objects.filter(Q(name__contains=plant_name,userid=user_name) | Q(name__contains=plant_name,reporter_id=repor_id))

        if req == "cord": #已录数据
            insects = User_Data_Table_New.objects.filter(Q(harm_id__pest_name__contains=plant_name,harm_id__pest_sort=ret,user_id__user_id__username=user_name) | Q (harm_id__pest_name__contains=plant_name,harm_id__pest_sort=ret,user_id=repor_id))
            for i in insects:
                    data.append({"user_name":i.user_id.name,"growth_stages":i.growth_stages,"area":i.area,"pest_name":i.harm_id.pest_name,"month":i.harm_id.month_id.month,
                    "pest":i.harm_id.pest,"crop_sort":i.harm_id.crop_sort,"cens_method":i.cens_method,"city":i.harm_id.month_id.addr_id.name,"id":i.id,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')
                    ,"city_id":i.harm_id.month_id.addr_id.id,"harm_id":i.harm_id.id,"pest_sort":i.harm_id.pest_sort,"username":i.user_id.user_id.username,
                    })
        elif req == "disc": #识别信息
            for x in insects:
                data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course,
                                "name": x.name, "addr": x.addr, "id": x.id, "ret": ret, "req": req})
        num = insects.count()
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)



#按时间段筛选
class Screen_Hour(ListView):
    def post(self, request):
        ret = request.POST.get("ret")
        req = request.POST.get("req")
        start_time = request.POST.get("stat_time")
        end_time = request.POST.get("end_time")
        page = int(request.POST.get("page"))
        data = []
        name = request.session.get("username")
        print("name", name)
        # name = "admin"
        user_name = MyUser.objects.get(username=name)

        if ret == "2":
            insects = App_Insect.objects.filter(~Q(name=None),userid=user_name,time__range=(start_time,end_time))
        elif ret == "1":
            insects = App_Plant.objects.filter(~Q(name=None),userid=user_name,time__range=(start_time,end_time))

        if req == "cord":
            inseects = User_Data_Table_New.objects.filter(user_id__user_id__username=user_name,upl_time__range=(start_time,end_time))
            for i in insects:
                data.append({"user_name":i.user_id.name,"growth_stages":i.growth_stages,"area":i.area,"pest_name":i.harm_id.pest_name,"month":i.harm_id.month_id.month,
                    "pest":i.harm_id.pest,"crop_sort":i.harm_id.crop_sort,"cens_method":i.cens_method,"city":i.harm_id.month_id.addr_id.name,"id":i.id,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')
                    ,"city_id":i.harm_id.month_id.addr_id.id,"harm_id":i.harm_id.id,"pest_sort":i.harm_id.pest_sort,"username":i.user_id.user_id.username,
                    })
        elif req == "disc": 
            for x in insects:
                data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course,
                                "name": x.name, "addr": x.addr, "id": x.id, "ret": ret, "req": req})
        num = insects.count()
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)



# #测报员下病虫害名字筛选
# class Screen_Pests_Name(ListView):
#     def post(self, request):
#         ret = request.POST.get("ret")
#         req = request.POST.get("req")
#         bch_name = request.POST.get("name")
#         page = int(request.POST.get("page"))
#         cby_id = request.POST.get("id")
#         data = []
#         if not all ([ret,bch_name,cby_id,req,page]):
#             data = 0
#             return HttpResponse(data)
#         #__contains 模糊查询
#         if ret == "insect":
#             types = "2"
#             genre = "虫害"
#             insects = App_Insect.objects.filter(name__contains=bch_name,reporter_id=cby_id)
#         elif ret == "plant":
#             types = "1"
#             genre = "病害"
#             insects = App_Plant.objects.filter(name__contains=bch_name,reporter_id=cby_id)

#         if req == "cord":
#             insects = User_Data_Table.objects.filter(names__contains=bch_name,statistical=types,reporter_id=cby_id)
#             for i in insects:
#                 data.append({"user_id": i.user_id.username, "reporter_id": i.reporter_id.name, "time": i.time.strftime("%Y-%m-%d %H:%M:%S"),
#                                 "user_city": i.user_city, "insect_sort": i.insect_sort, "area": i.area, "names": i.names, "genre": genre, "statistical_method": i.statistical_method,
#                                 "id": i.id, "ret": ret, "req": req})
#         elif req == "disc": 
#             for x in insects:
#                 data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course,
#                                 "name": x.name, "addr": x.addr, "id": x.id, "ret": ret, "req": req,"genre":genre})
#         num = insects.count()
#         dat = data[(10*(page-1)):(page*10)]
#         data = {"dat": dat, "num": num}
#         data = json.dumps(data)
#         return HttpResponse(data)



#测报员下时间段筛选
class Screen_Extent_Time(ListView):
    def post(self, request):
        ret = request.POST.get("ret")
        req = request.POST.get("req")
        start_time = request.POST.get("stat_time")
        end_time = request.POST.get("end_time")
        page = int(request.POST.get("page"))
        reporter_id = request.POST.get("id")
        data = []   

        if ret == "2":
            insects = App_Insect.objects.filter(~Q(name=None),reporter_id=reporter_id,time__range=(start_time,end_time))
        elif ret == "1":
            insects = App_Plant.objects.filter(~Q(name=None),reporter_id=reporter_id,time__range=(start_time,end_time))

        if req == "cord":
            inseects = User_Data_Table_New.objects.filter(user_id=reporter_id,upl_time__range=(start_time,end_time))
            for i in insects:
                data.append({"user_name":i.user_id.name,"growth_stages":i.growth_stages,"area":i.area,"pest_name":i.harm_id.pest_name,"month":i.harm_id.month_id.month,
                    "pest":i.harm_id.pest,"crop_sort":i.harm_id.crop_sort,"cens_method":i.cens_method,"city":i.harm_id.month_id.addr_id.name,"id":i.id,"upl_time":i.upl_time.strftime('%Y-%m-%d %H:%M:%S')
                    ,"city_id":i.harm_id.month_id.addr_id.id,"harm_id":i.harm_id.id,"pest_sort":i.harm_id.pest_sort,"username":i.user_id.user_id.username,
                    })
        elif req == "disc": 
            for x in insects:
                data.append({"username": x.userid.username, "reporter": x.reporter_id.name, "time": x.time.strftime("%Y-%m-%d %H:%M:%S"), "course": x.course,
                                "name": x.name, "addr": x.addr, "id": x.id, "ret": ret, "req": req})
        num = insects.count()
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)



# 导出excel文件指定测报员下虫害、病害、指定数据
class Export_Excel(ListView):
    def get(self, request):
        reporter_id = request.GET.get("id")
        ret = request.GET.get("ret")
        
        name = request.session.get("username")
        print("name", name)
        # name = "admin"
        user_name = MyUser.objects.get(username=name)
        # 创建一个文件对象
        wb = xlwt.Workbook(encoding="utf8")
        # 创建一个sheet对象
        sheet = wb.add_sheet("sheet1",cell_overwrite_ok=True) 

        # 设置文件头的样式,这个不是必须的可以根据自己的需求进行更改
        style_heading = xlwt.easyxf("""
                font:
                    name Arial,
                    colour_index white,
                    bold on,
                    height 0xA0;
                align:
                    wrap off,
                    vert center,
                    horiz center;
                pattern:
                    pattern solid,
                    fore-colour 0x19;
                borders:
                    left THIN,
                    right THIN,
                    top THIN,
                    bottom THIN;
                """)

        # 写入文件标题
        sheet.write(0, 0, "测报员", style_heading)
        sheet.write(0, 1, "创建时间", style_heading)
        sheet.write(0, 2, "详细地址", style_heading)
        sheet.write(0, 3, "所属分类", style_heading)
        sheet.write(0, 4, "统计面积", style_heading)
        sheet.write(0, 5, "病害虫害名称", style_heading)
        sheet.write(0, 6, "病害值", style_heading)
        sheet.write(0, 7, "统计种类", style_heading)
        sheet.write(0, 8, "统计方法", style_heading)
        sheet.write(0, 9, "生育期", style_heading)
        sheet.write(0, 10, "月份", style_heading)
        data_row = 1
        date = []

        # if ret == "insect": #虫害
        #     types = "2"
        #     user_list = User_Data_Table.objects.filter(reporter_id=cbyid,statistical=types)
        # elif ret == "plant": # 病害
        #     types = "1"
        #     user_list = User_Data_Table.objects.filter(reporter_id=cbyid, statistical=types)
        if  ret == "addr": #单条
            user_list = User_Data_Table_New.objects.filter(id=reporter_id)
        elif ret == "whole": #该测报员下所有已录数据
            user_list = User_Data_Table_New.objects.filter(user_id=reporter_id)
        else:
            user_list = User_Data_Table_New.objects.filter(user_id=reporter_id,harm_id__pest_sort=ret)
        # else:
        #     data = 0
        #     return HttpResponse(data)
        for i in user_list:
            if i.harm_id.pest_sort == "1":
                pest_sort = "病害"
            elif i.harm_id.pest_sort == "2":
                pest_sort = "虫害"
            pestname = eval(i.pestname)
            key = list(pestname)
            valu = list(pestname.values())
            for x in range(len(key)):
                    date.append(key[x] + ":" + valu[x])
            # date.append(i.pestname)
            pri_time = i.upl_time.strftime("%Y-%m-%d")
            sheet.write(data_row, 0, i.user_id.name)
            sheet.write(data_row, 1, pri_time)
            sheet.write(data_row, 2, i.harm_id.month_id.addr_id.name)
            sheet.write(data_row, 3, i.harm_id.pest)
            sheet.write(data_row, 4, i.area)
            sheet.write(data_row, 5, i.harm_id.pest_name)
            sheet.write(data_row, 6, date)
            sheet.write(data_row, 7, i.harm_id.pest_sort)
            sheet.write(data_row, 8, i.cens_method)
            sheet.write(data_row, 9, i.growth_stages)
            sheet.write(data_row, 10, i.harm_id.month_id.month)
            data_row = data_row + 1
        output = BytesIO()
        wb.save(output)
        output.seek(0)
        # 后端进行保存，前端进行下载
        # 设置HTTPResponse的类型
        response = HttpResponse(content_type="application/vnd.ms-excel")
        response["Content-Disposition"] = "attachment;filename={}.xls".format(user_name)
        response.write(output.getvalue())
        return response



#导出主账号下所有已录信息
class Export_Mation(ListView):
    def get(self, request):
        ret = request.GET.get("ret")
        name = request.session.get("username")
        print("name", name)
        # name = "admin"
        user_name = MyUser.objects.get(username=name)
        # 创建一个文件对象
        wb = xlwt.Workbook(encoding="utf8")
        # 创建一个sheet对象
        sheet = wb.add_sheet("sheet1",cell_overwrite_ok=True) 

        # 设置文件头的样式,这个不是必须的可以根据自己的需求进行更改
        style_heading = xlwt.easyxf("""
                font:
                    name Arial,
                    colour_index white,
                    bold on,
                    height 0xA0;
                align:
                    wrap off,
                    vert center,
                    horiz center;
                pattern:
                    pattern solid,
                    fore-colour 0x19;
                borders:
                    left THIN,
                    right THIN,
                    top THIN,
                    bottom THIN;
                """)

        # 写入文件标题
        sheet.write(0, 0, "测报员", style_heading)
        sheet.write(0, 1, "创建时间", style_heading)
        sheet.write(0, 2, "详细地址", style_heading)
        sheet.write(0, 3, "所属分类", style_heading)
        sheet.write(0, 4, "统计面积", style_heading)
        sheet.write(0, 5, "病害虫害名称", style_heading)
        sheet.write(0, 6, "病害值", style_heading)
        sheet.write(0, 7, "统计种类", style_heading)
        sheet.write(0, 8, "统计方法", style_heading)
        sheet.write(0, 9, "生育期", style_heading)
        sheet.write(0, 10, "月份", style_heading)
        data_row = 1
        date = []
        if  ret == "user": #全部
            user_list = User_Data_Table_New.objects.filter(user_id__user_id=user_name)
        else:
            user_list = User_Data_Table_New.objects.filter(user_id__user_id=user_name, harm_id__pest_sort=ret)
        for i in user_list:
            if i.harm_id.pest_sort == "1":
                pest_sort = "病害"
            elif i.harm_id.pest_sort == "2":
                pest_sort = "虫害"
            pestname = eval(i.pestname)
            key = list(pestname)
            valu = list(pestname.values())
            for x in range(len(key)):
                    date.append(key[x] + ":" + valu[x])
            # date.append(i.pestname)
            pri_time = i.upl_time.strftime("%Y-%m-%d")
            sheet.write(data_row, 0, i.user_id.name)
            sheet.write(data_row, 1, pri_time)
            sheet.write(data_row, 2, i.harm_id.month_id.addr_id.name)
            sheet.write(data_row, 3, i.harm_id.pest)
            sheet.write(data_row, 4, i.area)
            sheet.write(data_row, 5, i.harm_id.pest_name)
            sheet.write(data_row, 6, date)
            sheet.write(data_row, 7, i.harm_id.pest_sort)
            sheet.write(data_row, 8, i.cens_method)
            sheet.write(data_row, 9, i.growth_stages)
            sheet.write(data_row, 10, i.harm_id.month_id.month)
            data_row = data_row + 1
        output = BytesIO()
        wb.save(output)
        output.seek(0)
        # 后端进行保存，前端进行下载
        # 设置HTTPResponse的类型
        response = HttpResponse(content_type="application/vnd.ms-excel")
        response["Content-Disposition"] = "attachment;filename={}.xls".format(user_name)
        response.write(output.getvalue())
        return response



#扫码下载
class App_Upder(ListView):
    def get(self, request):
        return render(request, "home/appDownload.html")


#扫码下载(针对赵珍统计器)
class App_Upder2(ListView):
    def get(self, request):
        return render(request, "home/appDownload2.html")




#已录信息饼状图统计页面
class Pie_Chart(ListView):
    def  get(self, request):
        return render(request,"pestDiagnosis/insectStatistics.html", context={})



#已录信息饼状图数据展示
class Show_Pie_Chart(ListView):
    def get(self, request):
        ret = request.GET.get("ret")
        name = request.session.get("username")
        print("name", name)
        # name = "admin"
        user_name = MyUser.objects.get(username=name) 
        data = []
        date = []
        user_list = User_Data_Table_New.objects.filter(user_id__user_id=user_name,harm_id__pest_sort=ret)
        if user_list:
            for i in user_list:
                num = user_list.objects.filter(harm_id__pest_name=i.names).count()
                date.append({"name":i.names,"value":num})
            for x in date:
                if x not in data:
                    data.append(x)
        data = json.dumps(data)
        return HttpResponse(data)


#已录信息柱状图
class Line_Chart(ListView):
    def get(self,request):
        name = request.session.get("username")
        # name = "admin"
        user_name = MyUser.objects.get(username=name) 
        data = []
        user_list = User_Reporter.objects.filter(user_id=user_name)
        for i in user_list:
            plant = str(User_Data_Table_New.objects.filter(user_id=i.id,harm_id__pest_sort="1").count())
            insect = str(User_Data_Table_New.objects.filter(user_id=i.id,harm_id__pest_sort="2").count())
            data.append({"name":i.name,"cby_plant":plant,"cby_insect":insect})
        data = json.dumps(data)
        return HttpResponse(data)



#已录信息害虫统计报表
class Reporting(ListView):
    def get(self, request):
        name = request.session.get("username")
        user_name = MyUser.objects.get(username=name) 
        data = []
        user_list = User_Reporter.objects.filter(user_id=user_name)
        for i in user_list:
            data.append({"id":i.id,"name":i.name})
        data = json.dumps(data)
        return HttpResponse(data)

    def post(self, request):
        ret = request.POST.get("ret")
        reporter_id = request.POST.get("id")
        page = int(request.POST.get("page"))
        data = []
        user_list = User_Data_Table_New.objects.filter(user_id=reporter_id,harm_id__pest_sort=ret)
        for i in user_list:
            data.append({"name":i.harm_id.pest_name,"cby_name":i.user_id.name,"time":i.upl_time.strftime("%Y-%m-%d %H:%M:%S")})
        num = user_list.count()
        dat = data[(10*(page-1)):(page*10)]
        data = {"dat": dat, "num": num}
        data = json.dumps(data)
        return HttpResponse(data)




#数据重传
class again_data(View):
    def post(self,request):
        username = request.POST.get("username")
        start_time = request.POST.get('start_time')
        end_time = request.POST.get('end_time')
        imei = request.POST.get("imei")
        data_url = request.POST.get("data_url")
        img_url = request.POST.get("img_url")
        ret = int(request.POST.get("ret"))
        #时间切割
        begindate = re.findall(r"\d+\.?\d*", start_time)
        enddate = re.findall(r"\d+\.?\d*", end_time)
        start_date = datetime.date(int(begindate[0]), int(begindate[1]), int(begindate[2]))
        end_date = datetime.date(int(enddate[0]), int(enddate[1]), int(enddate[2]))

        if username == "admin":
            if ret == 2:
                scd_sta = SCDstatus_all.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                scd_dat = SCDdata.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                for i in scd_sta:  #状态数据
                    data = eval(i.scd_status)
                    data = json.dumps(data)
                    res = requests.post(data_url,data=data,timeout=(50,100))
                    print(res.status_code)
                for x in scd_dat: #全部数据
                    data = eval(x.scd_data)
                    data = json.dumps(data)
                    res = requests.post(data_url,data=data,timeout=(50,100))
                    print(res.status_code)
            elif  ret == 3:
                cbd_sta = CBDstatus_all.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                cbd_dat = CBDdata.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                requests.adapters.DEFAULT_RETRIES = 5 # 增加重连次数
                s = requests.session()
                s.keep_alive = False # 关闭多余连接
                if data_url:
                    for i in cbd_sta:  #状态数据
                        data = eval(i.cbd_status)
                        datt = {"topic": "/yfkj/cbd/pub/868956044831620", "payload":{"cmd":"status", "ext":data}}
                        data = json.dumps(datt)
                        time.sleep(0.1)
                        res = requests.post(data_url,data=data,timeout=(50,100))
                        print(res.status_code)
                    for x in cbd_dat: #全部数据
                        data = eval(x.cbd_data)
                        datt = {"topic": "/yfkj/cbd/pub/868956044831620", "payload":{"cmd":"data", "ext":data}}
                        data = json.dumps(datt)
                        time.sleep(0.2)
                        res = requests.post(data_url,data=data,timeout=(50,100))
                        print(res.status_code)
                else:
                    cbd_img_list = CBDphoto.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                    equip = Equip.objects.get(equip_id=imei)
                    if equip.ftp_addr:
                        # http://120.27.222.26/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":  #带识别
                            for i in cbd_img_list:
                                # print("1111111111111111111",i.indentify_photo)
                                img_addr_1 = "http://www.yfzhwlw.com/" + i.addr
                                if i.indentify_photo:
                                    indentify_photo_1 = "http://www.yfzhwlw.com/" + i.indentify_photo
                                else:
                                    indentify_photo_1 = None
                                data = {
                                    "Image":img_addr_1,
                                    "Result_image":indentify_photo_1,
                                    "Result":i.indentify_result,
                                    "imei":imei
                                }
                                data = json.dumps(data, cls=CJSONEncoder)
                                print("data:",data)
                                time.sleep(0.1)
                                res_1 = requests.post(img_url,data=data,timeout=(50,100))
                                print("res_1:",res_1)
                                print("------------------识别结果发送成功！！！")
                        else: #不带识别
                            for i in cbd_img_list:
                                img_addr_1 = "http://www.yfzhwlw.com/" + i.addr
                                print("img_addr_1:",img_addr_1)
                                data = {
                                    "Image":img_addr_1,
                                    "imei":imei
                                }
                                data = json.dumps(data, cls=CJSONEncoder)
                                print("data:",data)
                                time.sleep(0.1)
                                res_1 = requests.post(img_url,data=data,timeout=(50,100))
                                print("res_1:",res_1.text)
            elif ret == 7:
                bzy_dat = BZYdata.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                if data_url:
                    for x in bzy_dat: #全部数据
                        data = eval(x.bzy_data)
                        data = json.dumps(data)
                        headers = {"Content-Type": "application/json; charset=UTF-8", 'Connection': 'close'}
                        res = requests.post(data_url,data=data,timeout=3,headers=headers)
                        print(res.status_code)
                else:
                    bzy_img_list = BZYphoto.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                    for i in bzy_img_list:
                        img_addr_1 = "http://www.yfzhwlw.com/bzy/" + i.addr
                        data = {
                                    "Image":img_addr_1,
                                    "imei":imei
                                }
                        data = json.dumps(data, cls=CJSONEncoder)
                        print("data:",data)
                        res_1 = requests.post(img_url,data=data,timeout=2)
                        print("res_1:",res_1.text)
            elif ret == 5:
                qxz_list = QXZdata_New.objects.filter(equip_id__equip_id=imei,upl_time__range=(start_date,end_date))
                for i in qxz_list:
                    data = [i.e1,qxz_list.e2,i.e3,i.e4,i.e5,i.e6,i.e7,i.e8,i.e9,i.e10,i.e11,i.e12,i.e13,i.e14,
                            i.e15,i.e16,i.e17,i.e18,
                            i.e19,i.e20,i.e21,i.e22,
                            i.e23,i.e24,i.e25,i.e26,
                            i.e27,i.e28,i.e29,i.e30]
                test = [i for i in data if i != '']
        return HttpResponse("0")

import random
 

#韩英磊曹县测报灯图片上传
class down_img(View):
    def post(self,request):
        imgs = request.FILES.get("img")
        print(imgs)
        imei = request.POST.get("imei")
        harm_photo_dir = "cbd_img/"+imei+"/2020/06/"
        if os.path.exists(harm_photo_dir) == False:
                os.makedirs(harm_photo_dir)
        img = Image.open(imgs)
        end_name = imgs.name.split('.')[-1]
        now_time = time.strftime(
            '%Y%m%d%H%M%S', time.localtime(time.time()))
        pic_name = now_time + '.' + end_name
        print("pic_name:", pic_name)
        img.save(harm_photo_dir + pic_name)
        harm_photos = harm_photo_dir + pic_name
       
        ah = random.randint(100,700)
        at = random.randint(100,400)
        try:
            equip_id = Equip.objects.get(equip_id=imei)
            CBDphoto.objects.create(equip_id=equip_id,addr=harm_photos,at=at,ah=ah)
            data = {"code":200,"img_path":harm_photos}
        except Exception as e:
            data = {"code":400,"img_path":harm_photos}
            print(e)
        data = json.dumps(data)
        return HttpResponse(data)


# import qrcode
# # from apps.SystemManage.forms import AddUserForm

# # '''
# # qrcode.make(str):str为二维码包含的文字信息,也可以是网页链接，返回二维码对象
# # qrcode.save(str):将二维码以str为名保存到本地目录（注意文件的扩展名）
# # qrcode.show()：运行时展示二维码图案
# # '''
# # #创建包含信息的二维码对象
# # img = qrcode.make("http://baidu.com?id=1")
# # #二维码保存
# # img.save('hello.png')
# # #展示二维码
# # img.show()

# #生成二维码，请求登录接口
# class qr_code(View):
#     def get(self,request):
#         img = qrcode.make("http://192.168.1.4:8000/test_log?username=admin&password=yf654321")
#         path = "qr_code/"
#         qr_name = "123.jpg"
#         if os.path.exists(path) == False:
#             os.makedirs(path)
#         print()
#         img.save(path + qr_name)
#         data = {"qr_code":path+qr_name}
#         data = json.dumps(data)
#         return  HttpResponse(data)



# #登录接口
# class test_log(View):
#     def get(self,request):
#         user_name = request.GET.get("username")
#         pass_word = request.GET.get("password")
#         print("user_name",user_name)
#         print("pass_word",pass_word)
#         HTTP_HOST=request.META['HTTP_HOST']
#         print('HTTP_HOST:',HTTP_HOST)
#         dat = 0
#         try:
#             current_user = MyUser.objects.get(username=user_name)
#             dat = 1
#         except Exception as e:
#             print(e)
#         if dat:
#             if check_password(pass_word, current_user.password) != True:
#                 data = {"code":1001,"nums":"密码错误"}
#             else:
#                 print('登陆成功')
#                 # 将当前登录的用户名写入session
#                 if current_user.is_superuser:
#                         role = "superuser"
#                 elif current_user.is_staff:
#                         role = "staff"
#                 elif current_user.is_agency:
#                         role = "agency"
#                 else:
#                         role = "user"
#                 request.session['username'] = user_name
#                 data = {"code":1000,"nums":"登录成功","auth":role}
#         else:
#             data = {"code":1001,"nums":"当前用户不存在"}
#         data = json.dumps(data,ensure_ascii=False)
#         return HttpResponse(data)
#                     # num = 1
                    # if current_user.is_superuser:
                    #     role = "superuser"
                    # elif current_user.is_staff:
                    #     role = "staff"
                    # elif current_user.is_agency:
                    #     role = "agency"
                    #     if  Purchase.objects.filter(userid=current_user).exists():
                    #         pass
                    #     else:
                    #         print(current_user.user_agency)
                    #         if current_user.user_agency:
                    #             purchase_list = Purchase.objects.filter(userid__user_agency=current_user.user_agency).count()
                    #             if purchase_list:
                    #                 pass
                    #             else:
                    #                 num = 0
                    #         else:
                    #             num = 0
                    # else:
                    #     role = "user"
                    #     num = Purchase.objects.filter(userid=current_user).count()


                    # # 获取用户所有组：
                    # groups = Group.objects.filter(user=current_user)
                    # print("groups:", groups)
                    # for i in groups:
                    #     print("##############:",i.name)

                    # print("当前用户类型：是否为超级管理员", current_user.is_superuser)


                    # # 获取用户的logo组
                    # logos = Logo.objects.filter(myuser=current_user)
                    # print("logos:",logos)

                    # for i in groups:
                    #     print("##############:",i.name)
                    
                    # print("当前用户类型：是否为超级管理员", current_user.is_superuser)
                    # print("---------len:",len(logos))
                    # if len(logos) == "0":
                    #     logos == ""
                    # else:
                    #     pass

                    # # 超级管理员没有到期时间 提取不到参数时会报错
                    # try:
                    #     # remaining_days=账户还剩多少天
                    #     remaining_days = (current_user.expire_date - datetime.datetime.now()).days
                    #     # 账户的具体到期时间
                    #     user_date = current_user.expire_date
                    #     # 将账户的具体到期时间转字符串，取年-月-日
                    #     user_date = datetime.date.strftime(user_date,"%Y-%m-%d %H:%M:%S")[0:10]
                    # except:
                    #     return render(request, 'home/home.html', context={'current_user': current_user, 'role': role, 'groups': groups, 'logos':logos,'have':num})
                    # return render(request, 'home/home.html', context={'current_user': current_user, 'role': role, 'groups': groups, 
                    #                                                 'remaining_days':remaining_days, 'user_date':user_date, 'logos':logos,'have':num})
                    #     # return render(request, 'home/home.html', context={'user_name': user_name, 'role': role, 'groups': groups})
#         else:
#             form = AddUserForm()
#             # # 读取cookie：
#             # try:
#             #     user_name = request.COOKIES.get('uname')
#             #     # 从cookie中读出的upwd p1为str：
#             #     p1 = request.COOKIES.get('upwd')
#             #     # print("type(p1):", type(p1))
#             #     # 将str类型的p1转为bytes：p2
#             #     p2 = bytes(p1, encoding='utf-8')
#             #     # 将p2解密，得到bytes的p3：
#             #     p3 = base64.decodestring(p2)
#             #     # 将p3转为str：
#             #     p4 = str(p3, encoding="utf8")
#             #     pass_word = p4
#             #     print("读取cookie：用户名：", user_name)
#             #     print("读取cookie：用户密码：", pass_word)
#             # except:
#             #     user_name = pass_word = None

#             if HTTP_HOST == "www.yfzhwlw.com" or HTTP_HOST == "yfzhwlw.com" or HTTP_HOST == "120.27.222.26":
#                 return render(request, 'home/login.html', context={'form': form})
#                 # return render(request, 'home/common_login.html', context={'form': form})
#             elif HTTP_HOST == "www.zgzhwlw.com" or HTTP_HOST == "zgzhwlw.com":
#                 return render(request, 'home/common_login.html', context={'form': form})
#             elif HTTP_HOST == "127.0.0.1:8000":
#                 return render(request, 'home/login.html', context={'form': form})
#                 # return render(request, 'home/common_login.html', context={'form': form})
#             elif HTTP_HOST == "localhost:8000":
#                 # return render(request, 'home/common_login.html', context={'form': form})
#                 return render(request, 'home/common_login.html', context={'form': form})
#             else:
#                 return render(request, 'home/login.html', context={'form': form})