yfwlwCut/apps/Home/views.py

# -*- coding: utf-8 -*-

from django.shortcuts import render, redirect
from apps.SystemManage.forms import AddUserForm
from django.http import HttpResponse
from django.template import RequestContext
from django.contrib import auth
from django.contrib.auth import authenticate, login as auth_login, logout
from django.contrib.auth import get_user_model
from django.contrib.auth.models import User, Group, Permission
from django.contrib.auth.hashers import make_password, check_password

from django.contrib.auth.decorators import login_required
from django.views.decorators.csrf import csrf_exempt

from django.views.generic import ListView
from django.views.generic.base import View
import datetime
from PIL import Image

import json
import base64
import redis
from django.core.cache import cache

# from xadmin.models import Log
from apps.AppInfoManage.models import Help, MyUser, User_Group, User_Log, Equip, Equip_type, CBDdata, CBDstatus, SCDstatus, Logo, RecentCBDdata, RecentSCDdata, Equip_SimInfo,\
BZYstatus, CBDphoto, BZYphoto, QXZdata, QXZstatus, VR_Photo, APP_Img, YBQstatus, Purchase, QXZ_Base_Info, Alarm_record
from .forms import LoginForm, ChangePwdForm, UserRegisterForm
from apps.EquipManage.views import CJSONEncoder
from apps.ReportManage.all_dict import qxz_dict, insect_dict, insect_dict_new
import copy

import os

from yfwlw_pro.settings import get_client_ip

# cach = redis.StrictRedis('127.0.0.1',6379)
# cach.set("k1","v1",nx=False)
# kv1 = cach.get("k1")
# print("kv1:",kv1)


#from django.core.exceptions import ObjectDoesNotExist
#from django.utils.datastructures import MultiValueDictKeyError

# from django.conf import settings

# def global_setting(request):#注意有request参数
#     CURRENTUSER = settings.CURRENTUSER
#     print("全局变量：！")
#     print("CURRENTUSER:",CURRENTUSER)
#     return locals()

from django.views.decorators.csrf import csrf_exempt

from django.utils.decorators import method_decorator


# 用户登录
@method_decorator(csrf_exempt, name='dispatch')
class Login_View(View):
    def get(self, request):
        HTTP_HOST=request.META['HTTP_HOST']
        print('HTTP_HOST:',HTTP_HOST)
        # form = AddUserForm()
        # return render(request, 'home/login.html', context={'form': form})
        if request.user.is_authenticated():
            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"

            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={'user_name': user_name, 'current_user': current_user, 'role': role, 'groups': groups, 'logos':logos,'have':num})
            return render(request, 'home/home.html', context={'user_name': user_name, '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})
                # return render(request, 'home/common_login.html', context={'form': form})
                    
    def post(self, request):
        user_name = request.POST.get('username')
        pass_word = request.POST.get('password')
        print('输入的用户名：', user_name)
        user = MyUser.objects.extra(
            where=['binary username=%s'], params=[user_name])
        print("user.exists():", user.exists())
        if user.exists() == False:
            data = "1"
            return HttpResponse(data)
        else:
            user = MyUser.objects.get(username=user_name)
            if user.is_active != True:
                data = "2"
                return HttpResponse(data)
            else:
                if check_password(pass_word, user.password) != True:
                    data = "3"
                    return HttpResponse(data)
                else:
                    print('登陆成功')
                    try:
                        current_user = MyUser.objects.get(username=user_name)
                        remaining_days = (current_user.expire_date - datetime.datetime.now()).days
                        print("账号剩余天数:",remaining_days)
                        if remaining_days < 30 and remaining_days > 0:
                            print("账号剩余时间过少，请及时充值")
                        elif remaining_days <= 0:
                            return HttpResponse("4")
                    except Exception as e:
                        pass
                    
                    user_has_perm = user.has_perm('apps.EquipList.add_equip')
                    print('user_has_perm=', user_has_perm)
                    print("头像：", user.user_picture)
                    auth_user = authenticate(
                        username=user_name, password=pass_word)
                    auth_login(request, auth_user)

                    # 将当前登录的用户名写入session
                    request.session['username'] = user_name

                    if user.is_superuser:
                        role = "superuser"
                    elif user.is_staff:
                        role = "staff"
                    elif user.is_agency:
                        role = "agency"
                    else:
                        role = "user"
                    # 记录用户操作记录：
                    User_Log.objects.create(
                        log_user=request.user.username, log_ip=get_client_ip(request), log_desc='登录')
                    data = "0"
                    returnUrl = request.POST.get('returnUrl')
                    print("returnUrl:",returnUrl)
                    if returnUrl == None:
                        print("returnUrl is none!!!!!!!!")
                        return HttpResponse(data)
                    else:
                        if returnUrl == "":
                            print("returnUrl is empty")
                            return render(request, 'reportmanage/cbd_report.html')
                        elif returnUrl != "":
                            print("returnUrl is not empty")
                            return render(request, 'reportmanage/cbd_report.html')


                    # response = HttpResponse(data)
                    # response['Access-Control-Allow-Origin'] = '*'
                    # response['Access-Control-Allow-Methods'] = 'POST, GET, OPTIONS'
                    # response['Access-Control-Max-Age'] = '1000'
                    # response['Access-Control-Allow-Headers'] = '*' 
                    # return response
                    # return HttpResponse(data)
                    # if is_remember_pwd == "remember":
                    #     print("记住密码")
                    #     data = "0"
                    #     re = HttpResponse(data)
                    #     re.set_cookie('uname', user_name, 3600)
                    #     # 保存密码：先加密
                    #     bpwd = base64.encodestring(
                    #         bytes(pass_word, encoding='utf-8'))
                    #     re.set_cookie('upwd', bpwd, 3600)
                    #     return re

                    # elif is_remember_pwd == "no":
                    #     print("不记住密码，删除密码")
                    #     data = "0"
                    #     re = HttpResponse(data)
                    #     re.delete_cookie("uname")
                    #     re.delete_cookie("upwd")
                    #     return re



# 首页视图函数
from django.core import serializers


def home(request):
    if request.user.is_authenticated():
        user_name = request.user.username
        current_user = MyUser.objects.get(username=user_name)
        print('user_name=', user_name)
        print('current_user=', current_user.username)
        groups = User_Group.objects.filter(user=current_user)

        print("groups:", groups)

        # 获取用户的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
        # groups_list=[]
        # for i in groups:
        #     groups_list.append(i.name)
        # groups_list = ','.join(groups_list)
        # print("groups_list:", groups_list)

        # 如果是依科曼的用户：
        # if "scd" in groups_list:
        #     if "cbd" in groups_list:
        #         #杀虫灯和测报灯用户：
        #         group = "scd+cbd"
        #     else:
        #         # 杀虫灯用户：
        #         group = "scd"
        # elif "cbd" in groups_list:
        #     # 测报灯用户：
        #     group = "cbd"
        # elif "ykm" in groups_list:
        # if "ykm" in groups_list:
        #     # 依科曼测报灯用户：
        #     group = "ykm"
        # else:
        #     group = "yfkj"
        print("当前用户类型：是否为超级管理员", current_user.is_superuser)
        if current_user.is_superuser:
            role = "superuser"
            num = 1
        elif current_user.is_staff:
            role = "staff"
            num = 1
        elif current_user.is_agency:
            role = "agency"
            if  Purchase.objects.filter(userid=current_user).exists():
                num = 1
            else:
                print(current_user.user_agency)
                if current_user.user_agency:
                    hh = Purchase.objects.filter(userid__user_agency=current_user.user_agency).count()
                    if hh:
                        num = 1
                    else:
                        num = 0
                else:
                    num = 0
        else:
            role = "user"
            num = Purchase.objects.filter(userid=current_user).count()
        print("num",num)
        current_user = MyUser.objects.get(username=user_name)
        # 超级管理员没有到期时间 提取不到参数时会报错
        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})
    else:
        return redirect('/login')


# 用户注册
from django.utils.decorators import method_decorator
@method_decorator(csrf_exempt, name='dispatch')
class Register_View(View):
    def post(self, request):
        user_name = request.POST.get('username')
        email = request.POST.get('email')
        user_phone = request.POST.get('user_phone')
        password = request.POST.get('password')
        password2 = request.POST.get('password2')
        print(user_name)
        print(email)
        print(user_phone)
        print(password)
        print(password2)
        if(MyUser.objects.extra(where=['binary username=%s'], params=[user_name]).exists() == True):
            data = "1"
            return HttpResponse(data)
        UserModel = get_user_model()
        user = UserModel.objects.create_user(
            username=user_name, email=email, password=password, user_phone=user_phone)
        user.save()
        data = "0"
        return HttpResponse(data)


@login_required
def home_map(request):
    User_Log.objects.create(log_user=request.user.username,
                            log_ip=get_client_ip(request), log_desc='首页')
    current_user = request.session.get('username')
    print("请求定位信息！！！")
    print("current_user:", current_user)
    current_user = MyUser.objects.get(username=current_user)
    print("请求杀虫灯定位！")
    if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
        print("---不是管理员")
        sta1 = SCDstatus.objects.filter(
            equip_id__equip_user=current_user)
    elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
        print("---代理商")
        sta1 = SCDstatus.objects.filter(equip_id__equip_agency=current_user.user_agency)
    else:
        print("---管理员")
        sta1 = SCDstatus.objects.all()


    return render(request, 'home/home_map.html', context={"scdlist":sta1})


# 根据用户来进行定位
class User_Location(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        try:
            user_pro = current_user.user_pro
        except:
            user_pro = ""
        try:
            user_city = current_user.user_city
        except:
            user_city = ""
        try:
            user_area = current_user.user_area
        except:
            user_area = ""
        data = {"user_pro":user_pro,"user_city":user_city,"user_area":user_area}
        data = json.dumps(data)
        return HttpResponse(data)


# 地图定位请求接口：
class Map_Scd_All(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        print("请求定位信息！！！")
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        print("请求杀虫灯定位！")
        if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
            print("---不是管理员")
            sta1 = RecentSCDdata.objects.filter(
                equip_id__equip_user=current_user).values()
        elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
            print("---代理商")
            sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values()
        else:
            print("---管理员")
            sta1 = RecentSCDdata.objects.all().values()
        nums = sta1.count()
        data = {"nums":nums}
        data = json.dumps(data)
        return HttpResponse(data)

# 地图定位请求接口：
class Map_Locat_View(ListView):
    def get(self, request):
        pass

    def post(self, request):
        current_user = request.session.get('username')
        print("请求定位信息！！！")
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)

        req = request.POST.get('req')
        print("req:", req)
        # page = int(request.POST.get('page'))
        # print("page",page)
        if req == "cbd":
            print("请求测报灯定位！")
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = RecentCBDdata.objects.filter(equip_id__equip_user=current_user).values()
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---代理商")
                sta1 = RecentCBDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values()
            else:
                print("---管理员")
                sta1 = RecentCBDdata.objects.all().values()
            sta2 = []
            for x in sta1:
                try:
                    sta2.append({
                            "equip_id": x['equip_id_id'],
                            "equip_type": 3,
                            "equip_name": x['equip_name'],
                            "gps": eval(x['cbd_data'])['gps'],
                            "lng": eval(x['cbd_data'])['lng'],
                            "lat": eval(x['cbd_data'])['lat']
                            })
                except:
                    sta2.append({
                            "equip_id": x['equip_id_id'],
                            "equip_type": 3,
                            "equip_name": x['equip_name'],
                            "gps": 2,
                            "lng": eval(x['cbd_data'])['lng'],
                            "lat": eval(x['cbd_data'])['lat']
                            })
                    
            # sta2 = [{
            #         "equip_id": x['equip_id_id'],
            #         "equip_type": 3,
            #         "equip_name": x['equip_name'],
            #         "lng": eval(x['cbd_data'])['lng'],
            #         "lat": eval(x['cbd_data'])['lat']
            #         } for x in sta1]
            data = json.dumps(sta2)
            # print("data:", data)
            return HttpResponse(data)
        elif req == "scd":
            print("请求杀虫灯定位！")
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = RecentSCDdata.objects.filter(
                    equip_id__equip_user=current_user).values()
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---代理商")
                sta1 = RecentSCDdata.objects.filter(equip_id__equip_agency=current_user.user_agency).values()
            else:
                print("---管理员")
                sta1 = RecentSCDdata.objects.all().values()
            sta2 = []
            a = datetime.datetime.now()
            for x in sta1:
                try:
                    sta2.append({
                            "equip_id": x['equip_id_id'],
                            "equip_type": 2,
                            "equip_name": x['equip_name'],
                            "gps": eval(x['scd_data'])['gps'],
                            "lng": eval(x['scd_data'])['lng'],
                            "lat": eval(x['scd_data'])['lat']
                            })
                except:
                    sta2.append({
                            "equip_id": x['equip_id_id'],
                            "equip_type": 2,
                            "equip_name": x['equip_name'],
                            "gps": 2,
                            "lng": 113,
                            "lat": 34
                            })
            print("消耗时间为",datetime.datetime.now()-a)
            data = json.dumps(sta2)
            # print("data:", data)
            return HttpResponse(data)
        elif req == "qxz":
            print("请求气象站定位！")
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = QXZ_Base_Info.objects.filter(
                    equip_id__equip_user=current_user)
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---代理商")
                sta1 = QXZ_Base_Info.objects.filter(equip_id__equip_agency=current_user.user_agency)
            else:
                print("---管理员")
                sta1 = QXZ_Base_Info.objects.all()
            sta2 = [{
                    "equip_id": x.equip_id_id,
                    "equip_type": 5,
                    "equip_name": x.equip_id.equip_name,
                    "lng": x.lng,
                    "lat": x.lat
                    } for x in sta1]
            data = json.dumps(sta2)
            # print("data:", data)
            return HttpResponse(data)
        elif req == "bzy":
            print("请求孢子仪定位！")
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = BZYstatus.objects.filter(
                    equip_id__equip_user=current_user)
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---代理商")
                sta1 = BZYstatus.objects.filter(equip_id__equip_agency=current_user.user_agency)
            else:
                print("---管理员")
                sta1 = BZYstatus.objects.all()
            sta2 = [{
                    "equip_id": x.equip_id_id,
                    "equip_type": 7,
                    "equip_name": x.equip_id.equip_name,
                    "lng": eval(x.bzy_status)['lng'],
                    "lat": eval(x.bzy_status)['lat']
                    } for x in sta1]
            data = json.dumps(sta2)
            # print("data:", data)
            return HttpResponse(data)
        elif req == "xyq":
            print("请求性诱设备定位！")
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = YBQstatus.objects.filter(
                    equip_id__equip_user=current_user)
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---代理商")
                sta1 = YBQstatus.objects.filter(equip_id__equip_agency=current_user.user_agency)
            else:
                print("---管理员")
                sta1 = YBQstatus.objects.all()
            sta2 = [{
                    "equip_id": x.equip_id_id,
                    "equip_type": 4,
                    "equip_code": x.equip_code,
                    "lng": eval(x.ybq_status)['lng'],
                    "lat": eval(x.ybq_status)['lat']
                    } for x in sta1]
            data = json.dumps(sta2)
            # print("data:", data)
            return HttpResponse(data)
        elif req == "imei":
            print("imei搜索定位！")
            equip_id = request.POST.get('equip_id')
            print("equip_id:", equip_id)

            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                # 非管理员筛选出当前用户：
                scd_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='2'))
                cbd_equips = Equip.objects.filter(equip_user=current_user,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='3'))
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                # 代理商用户
                scd_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='2'))
                cbd_equips = Equip.objects.filter(equip_agency=current_user.user_agency,equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='3'))
            else:
                # 管理员用户
                scd_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='2'))
                cbd_equips = Equip.objects.filter(equip_id__contains=equip_id, equip_type=Equip_type.objects.get(type_id='3'))
            
            if not scd_equips and not cbd_equips:
                sta5 = 0
                data = json.dumps(sta5)
                return HttpResponse(data)
            # print("scd_equips:", scd_equips)
            # print("cbd_equips:", cbd_equips)
            else:
                sta2 = []
                if scd_equips:
                    for i in scd_equips:
                        sta1 = SCDstatus.objects.filter(
                            equip_id__equip_id__contains=equip_id)
                    for x in sta1:
                        try:
                            sta2.append({
                                    "equip_id": x.equip_id.equip_id,
                                    "equip_type": x.equip_id.equip_type.type_id,
                                    "equip_name": x.equip_id.equip_name,
                                    "gps": eval(x.scd_status)['gps'],
                                    "lng": x.lng,
                                    "lat": x.lat,
                                    "equip_location": x.equip_location
                                    })
                        except:
                            sta2.append({
                                    "equip_id": x.equip_id.equip_id,
                                    "equip_type": x.equip_id.equip_type.type_id,
                                    "equip_name": x.equip_id.equip_name,
                                    "gps": 2,
                                    "lng": x.lng,
                                    "lat": x.lat,
                                    "equip_location": x.equip_location
                                    })
                if cbd_equips:
                    for i in cbd_equips:
                        sta3 = CBDstatus.objects.filter(
                            equip_id__equip_id__contains=equip_id)
                    sta4 = []
                    for x in sta3:
                        try:
                            sta4.append({
                                    "equip_id": x.equip_id.equip_id,
                                    "equip_type": 3,
                                    "equip_name": x.equip_id.equip_name,
                                    "gps": eval(x.cbd_status)['gps'],
                                    "lng": x.lng,
                                    "lat": x.lat,
                                    "equip_location": x.equip_location
                                    })
                        except:
                            sta4.append({
                                    "equip_id": x.equip_id.equip_id,
                                    "equip_type": 3,
                                    "equip_name": x.equip_id.equip_name,
                                    "gps": 2,
                                    "lng": x.lng,
                                    "lat": x.lat,
                                    "equip_location": x.equip_location
                                    })

                    # sta4 = [{
                    #         "equip_id": x.equip_id.equip_id,
                    #         "equip_type": x.equip_id.equip_type.type_id,
                    #         "equip_name": x.equip_id.equip_name,
                    #         "lng": x.lng,
                    #         "lat": x.lat,
                    #         "equip_location": x.equip_location
                    #         } for x in sta3]

                if scd_equips and cbd_equips:
                    sta5 = sta2+sta4
                elif scd_equips and not cbd_equips:
                    sta5 = sta2
                elif not scd_equips and cbd_equips:
                    sta5 = sta4
                data = json.dumps(sta5)
                return HttpResponse(data)


# 个人信息 视图函数

class Personal_Info_View(View):
    def get(self, request):
        user_name = request.user.username
        user = MyUser.objects.get(username=user_name)
        if user.is_superuser:
            role = "superuser"
        elif user.is_staff:
            role = "staff"
        elif user.is_agency:
            role = "agency"
        else:
            role = "user"
        User_Log.objects.create(log_user=request.user.username,
                                log_ip=request.META['REMOTE_ADDR'], log_desc='个人信息')
        return render(request, 'home/personal_info.html', context={'user': user, 'role': role})

    def post(self, request):
        username = request.user.username
        print('username:',username)
        user = MyUser.objects.get(username=username)
        req = request.POST.get('req')
        if req == "info":
            user.user_phone = request.POST.get('phone')
            user.user_pro = request.POST.get('province')
            user.user_city = request.POST.get('city')
            user.user_area = request.POST.get('area')
            print("phone:", request.POST.get('phone'))
            print("province:", request.POST.get('province'))
            print("city:", request.POST.get('city'))
            print("area:", request.POST.get('area'))
            try:
                user.save()
                User_Log.objects.create(log_user=request.user.username,
                                        log_ip=request.META['REMOTE_ADDR'], log_desc='修改个人信息')
                data = "0"
                return HttpResponse(data)
            except:
                data = "1"
                return HttpResponse(data)
            
        # 修改头像：
        elif req == "photo":
            user_photo = request.FILES['upicture']
            print("用户头像：", user_photo)
            user_photo_dir = 'user_photo/'
            # 判断如果路径不存在，即创建路径
            if os.path.exists(user_photo_dir) == False:
                os.makedirs(user_photo_dir)

            img = Image.open(user_photo)
            img.save(user_photo_dir + username+".png")

            new_photo = user_photo_dir + username+".png"
            # 数据库关联设备，并在照片的表中存入路径：
            user.user_picture = new_photo
            user.save()
            data = "0"
            return HttpResponse(data)


# 修改密码 视图函数

def change_pwd(request):
    if request.method == 'GET':
        user_name = request.user.username
        print("当前用户为：", user_name)
        return render(request, 'home/change_pwd.html')

    if request.method == 'POST':
        user_name = request.POST.get('username')
        print('user_name:',user_name)
        user = MyUser.objects.get(username=user_name)
        print("当前用户为：", user_name)

        oldpassword = request.POST.get('oldpassword')
        password = request.POST.get('password')
        print("post的oldpassword:", oldpassword)
        print("post的password:", password)
        
        if(check_password(oldpassword, user.password)):
            user.set_password(password)
            user.save()
            User_Log.objects.create(log_user=request.user.username,
                                    log_ip=request.META['REMOTE_ADDR'], log_desc='修改密码')
            data = "0"
            return HttpResponse(data)
        else:
            data = "1"
            return HttpResponse(data)


# 用户退出 
@login_required
def logout(request):
    print("用户退出")
    del request.session['username']# 删除session
    auth.logout(request)
    return redirect('/login')




# 用户账户有效期
class User_Remaining_Days(View):
    def get(self, request):
        current_user = request.session.get('username')
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        if current_user.is_superuser == True:
            pass
        else:
            # remaining_days为账号还剩xx天，user_date为xxxx年xx月xx日到期
            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]
            # data = {"remaining_days":remaining_days, "user_date":user_date}
            # data = json.dumps(data)
            return render(request, 'home/renew.html', context={'remaining_days': remaining_days, 'user_date': user_date})


# 主页提示设备流量卡过期
class SCD_Alarm(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
            print("---用户")
            _list = Equip.objects.filter(equip_user=current_user,equip_type=2).values()
        elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
            print("---代理商")
            _list = Equip.objects.filter(equip_agency=current_user.user_agency,equip_type=2).values()
        dat = []
        data = []
        for i in _list:
            dat.append(i['equip_id'])
        for x in Alarm_record.objects.filter(alarm_desc__contains="Dump").values():
            if x['equip_id_id'] in dat:
                data.append({"equip_id":x['equip_id_id'],"time":x['alarm_time']})
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)






class Big_Data(ListView):
    def get(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        return render(request, 'home/bigScreen.html', context={"current_user":current_user})
    def post(self, request):
        pass



# 主页提示设备流量卡过期
class Equip_Sim(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
            print("---用户")
            simlist = Equip_SimInfo.objects.filter(equip_id__equip_user=current_user)
        elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
            print("---代理商")
            simlist = Equip_SimInfo.objects.filter(equip_id__equip_agency=current_user.user_agency)
        else:
            print("---管理员")
            simlist = Equip_SimInfo.objects.all()
        dat = []
        for i in simlist:
            dat.append({"equip_id":i.equip_id_id,"expiry_date":i.expiry_date})
        data = dat
        data = json.dumps(data)
        return HttpResponse(data)


# 展示页面判断是不是四情用户
class User_Judge(ListView):
    def get(self,request):
        pass
    def post(self,request):
        user_name = request.POST.get('username')
        pass_word = request.POST.get('password')
        print('输入的用户名：', user_name)
        user = MyUser.objects.extra(
            where=['binary username=%s'], params=[user_name])
        print("user.exists():", user.exists())
        if user.exists() == False:
            data = "1"
            return HttpResponse(data)
        else:
            user = MyUser.objects.get(username=user_name)
            if user.is_active != True:
                data = "2"
                return HttpResponse(data)
            else:
                if check_password(pass_word, user.password) != True:
                    data = "3"
                    return HttpResponse(data)
                else:
                    print('登陆成功')
                    user_obj = MyUser.objects.get(username=user_name)
                    equip_list = Equip.objects.filter(equip_user=user_obj)
                    type_list = []
                    for i in equip_list:
                        type_list.append(i.equip_type_id)
                    if user_obj.is_superuser:
                        auth_user = authenticate(
                            username=user_name, password=pass_word)
                        auth_login(request, auth_user)
                        # 将当前登录的用户名写入session
                        request.session['username'] = user_name
                        data = "0"
                        return HttpResponse(data)
                    elif 3 and 5 and 6 and 7 in type_list:
                        auth_user = authenticate(
                            username=user_name, password=pass_word)
                        auth_login(request, auth_user)
                        # 将当前登录的用户名写入session
                        request.session['username'] = user_name
                        data = "0"
                    else:
                        data = "5"
                    return HttpResponse(data)


# 用户基地展示图
class User_Display(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        print('current_user')
        print(current_user)
        current_user = MyUser.objects.get(username=current_user)
        equip_list = Equip.objects.filter(equip_user=current_user)
        if current_user.is_superuser:
            equip_list = Equip.objects.all()
        dat = []
        for i in equip_list:
            if i.equip_type_id == 3:
                dat.append({"e_id":i.equip_id,"equip_type":"3"})
            elif i.equip_type_id == 5:
                dat.append({"e_id":i.equip_id,"equip_type":"5"})
            elif i.equip_type_id == 6:
                dat.append({"e_id":i.equip_id,"equip_type":"6"})
            elif i.equip_type_id == 7:
                dat.append({"e_id":i.equip_id,"equip_type":"7"})
        data = {"basename":current_user.base_name,"basephoto":"%s"%current_user.base_show,"dat":dat}
        data = json.dumps(data)
        return HttpResponse(data)


# 测报灯数据展示页面
class CBD_Display(ListView):
    def get(self,request):
        pass
    def post(self,request):
        e_id = request.POST.get("imei")
        cbd_obj = CBDstatus.objects.get(equip_id=e_id)
        cbd_photo = CBDphoto.objects.filter(equip_id=e_id)
        photo_list = []
        for x in cbd_photo:
            photo_list.append(x.addr)
            if len(photo_list) >= 10:
                break
        pest_list = []
        for i in CBDphoto.objects.filter(equip_id=e_id):
            if i.indentify_result:
                pest_list.append({"pest":i.indentify_result,"time":i.upl_time,"at":i.at,"ah":i.ah})
                if len(pest_list) >= 10:
                    break
        data = {"photolist":photo_list,"pestlist":pest_list,"status":cbd_obj.cbd_status,"is_online":cbd_obj.is_online}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)



# 孢子仪数据展示页面
class BZY_Display(ListView):
    def get(self,request):
        pass
    def post(self,request):
        e_id = request.POST.get("imei")
        bzy_obj = BZYstatus.objects.get(equip_id=e_id)
        bzy_photo = BZYphoto.objects.filter(equip_id=e_id)
        photo_list = []
        for x in bzy_photo:
            photo_list.append(x.addr)
            if len(photo_list) >= 10:
                break
        data = {"photolist":photo_list,"status":bzy_obj.bzy_status,"is_online":bzy_obj.is_online}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)


# 气象站数据展示页面
class QXZ_Display(ListView):
    def get(self,request):
        pass
    def post(self,request):
        e_id = request.POST.get("imei")
        qxz_dict_3 = copy.deepcopy(qxz_dict)
        sta1 = QXZdata.objects.filter(equip_id=e_id).values()
        dat = []
        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"]:
                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)
                d.append(i["eNum"])
                sta["unit"].append(d)
                # qxz_dict[eval(x.qxz_data)['data'][0]["eNum"]]
            dat.append(sta)
            if len(dat) >= 10:
                break
        data = {"dat": dat}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)


# 展示页面地图
class Display_Map(ListView):
    def get(self,request):
        e_type = request.GET.get("type")
        return render(request, 'home/bigScreenMap.html', context={"type":e_type})
    def post(self,request):
        current_user = request.session.get('username')
        e_type = request.POST.get("type")
        print('current_user')
        print(current_user)
        current_user = MyUser.objects.get(username=current_user)
        equip_list = Equip.objects.filter(equip_user=current_user)
        if current_user.is_superuser:
            equip_list = Equip.objects.all()
        dat = []
        if e_type == "all":
            for i in equip_list:
                if i.equip_type_id == 3:
                    lat = CBDstatus.objects.get(equip_id=i).lat
                    lng = CBDstatus.objects.get(equip_id=i).lng
                    # dat.append({"e_id":i.equip_id_id,"lat":lat,"lng":lng})
                    dat.append({"e_id":i.equip_id,"lat":lat,"lng":lng,"equip_type":"3"})
                elif i.equip_type_id == 5:
                    lat = ""
                    lng = ""
                    # dat.append({"e_id":i.equip_id_id,"lat":lat,"lng":lng})
                    dat.append({"e_id":i.equip_id,"lat":lat,"lng":lng,"equip_type":"5"})
                elif i.equip_type_id == 6:
                    lat = ""
                    lng = ""
                    # dat.append({"e_id":i.equip_id_id,"lat":lat,"lng":lng})
                    dat.append({"e_id":i.equip_id,"lat":lat,"lng":lng,"equip_type":"6"})
                elif i.equip_type_id == 7:
                    try:
                        lat = eval(BZYstatus.objects.get(equip_id=i).bzy_status)["lat"]
                        lng = eval(BZYstatus.objects.get(equip_id=i).bzy_status)["lng"]
                    except Exception as e:
                        print("错误信息为:",e)
                        lat = ""
                        lng = ""
                    # dat.append({"e_id":i.equip_id_id,"lat":lat,"lng":lng})
                    dat.append({"e_id":i.equip_id,"lat":lat,"lng":lng,"equip_type":"7"})
        elif e_type == "3":
            for i in equip_list:
                if i.equip_type_id == 3:
                    lat = CBDstatus.objects.get(equip_id=i).lat
                    lng = CBDstatus.objects.get(equip_id=i).lng
                    # dat.append({"e_id":i.equip_id_id,"lat":lat,"lng":lng})
                    dat.append({"e_id":i.equip_id,"lat":lat,"lng":lng,"equip_type":"3"})
        elif e_type == "7":
            for i in equip_list:
                if i.equip_type_id == 7:
                    try:
                        lat = eval(BZYstatus.objects.get(equip_id=i).bzy_status)["lat"]
                        lng = eval(BZYstatus.objects.get(equip_id=i).bzy_status)["lng"]
                    except Exception as e:
                        print("错误信息为:",e)
                        lat = ""
                        lng = ""
                    # dat.append({"e_id":i.equip_id_id,"lat":lat,"lng":lng})
                    dat.append({"e_id":i.equip_id,"lat":lat,"lng":lng,"equip_type":"7"})
        data = {"dat":dat}
        data = json.dumps(data)
        return HttpResponse(data)


# 用户基地展示
class User_Base(ListView):
    def get(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        base_name = current_user.base_name
        base_show = current_user.base_show
        return render(request, 'home/baseEdit.html', context={"base_name":base_name,"base_photo":base_show})
    def post(self,request):
        pass


# 用户基地保存
class User_Base_Save(ListView):
    def get(self,request):
        pass
    def post(self,request):
        basestr = request.FILES.get("basephoto")
        basename = request.POST.get("basename")
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        base_dir = "base_show/"
        if basestr:
            img = Image.open(basestr)
            img.save(base_dir + current_user.username +".png")
            current_user.base_show = base_dir + current_user.username +".png"
        current_user.base_name = basename
        current_user.save()
        return HttpResponse("0")


class VR_List(ListView):
    def get(self, request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        if current_user.is_superuser:
            role = "superuser"
        elif current_user.is_staff:
            role = "staff"
        elif current_user.is_agency:
            role = "agency"
        else:
            role = "user"
        user_list = MyUser.objects.all()
        user_name = []
        for i in user_list:
            user_name.append(i.username)
        return render(request, 'vr/panoramaList.html', context={"role":role,"user_name":user_name})
    def post(self, request):
        pass


class VR_Display(ListView):
    def get(self, request):
        e_id = request.GET.get('id')
        img = VR_Photo.objects.get(id=e_id).photo
        return render(request, 'vr/panorama.html', context={"img":img})
    def post(self, request):
        pass


class Home_VR(ListView):
    def get(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        vr_obj = VR_Photo.objects.filter(user=current_user)
        if current_user.is_superuser or current_user.is_staff:
            vr_obj = VR_Photo.objects.all()
        data = []
        for i in vr_obj:
            data.append({"id":i.id,"name":i.name,"user":i.user.username,"photo":i.photo})
        data = json.dumps(data)
        return HttpResponse(data)
    def post(self,request):
        pass




# VR图片上传
class VR_Upload(ListView):
    def get(self,request):
        pass
    def post(self,request):
        e_id = request.POST.get('id')
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        name = request.POST.get('name')
        uname = request.POST.get('uname')
        vruser = MyUser.objects.get(username=uname)
        # vr_display = request.FILES['display']
        vr_photo = request.FILES['photo']
        print("vr图片：", vr_photo)
        vr_photo_dir = 'vr_photo/'
        now_time = datetime.datetime.now().strftime("%Y%m%d%H%M%S")
        # new_display = vr_photo_dir + current_user.username + "dis" + now_time +".png"
        new_photo = vr_photo_dir + current_user.username + "pho" + now_time +".png"
        if os.path.exists(vr_photo_dir) == False:
            os.makedirs(vr_photo_dir)
            # img1 = Image.open(vr_display)
            # img1.save(new_display)
            img2 = Image.open(vr_photo)
            img2.save(new_photo)
        else:
            # img1 = Image.open(vr_display)
            # img1.save(new_display)
            img2 = Image.open(vr_photo)
            img2.save(new_photo)
        # 判断如果路径不存在，即创建路径
        if e_id:
            vr_obj = VR_Photo.objects.get(id=e_id)
            # 数据库关联设备，并在照片的表中存入路径：
            vr_obj.name = name
            vr_obj.user = vruser
            # vr_obj.display = new_display
            vr_obj.photo = new_photo
            vr_obj.save()
            data = "0"
        else:
            print("new_photo:",new_photo)
            VR_Photo.objects.create(user=vruser,name=name,photo=new_photo)
            data = "0"
        return HttpResponse(data)


# vr图片删除
class VR_Delete(ListView):
    def get(self,request):
        pass
    def post(self,request):
        print("-----vr image delete!-----")
        e_id = request.POST.get('id')
        photo_obj = VR_Photo.objects.get(id=e_id)
        if os.path.exists(photo_obj.photo) == True:
            # 删除图片文件
            # os.remove(photo_obj.display)
            os.remove(photo_obj.photo)
            # 删除数据库照片列表中，照片路径：
            try:
                VR_Photo.objects.filter(id=e_id).delete()
                print("-----image delete ok!-----")
                data = "1"
                return HttpResponse(data)
            except:
                print("-----image delete failed!-----")
                data = "0"
                return HttpResponse(data)
        else:
            # 照片不存在，但是数据库有路径的情况会删除不掉
            # 因此不管何时都删除数据库路径
            try:
                VR_Photo.objects.filter(id=e_id).delete()
                print("-----image delete ok!-----")
            except:
                print("-----image not exist!-----")
                pass
            data = "1"
            return HttpResponse(data)



# APP轮播图
class App_Img(ListView):
    def get(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        app_img = APP_Img.objects.filter(user=current_user)
        return render(request, 'home/appBannerManage.html', context={"app_img":app_img})
    def post(self,request):
        pass


# APP轮播图上传
class App_Img_Upload(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        # vr_display = request.FILES['display']
        img = request.FILES['photo']
        print("vr图片：", img)
        vr_photo_dir = 'app_file/app_img/'
        now_time = datetime.datetime.now().strftime("%Y%m%d%H%M%S")
        # new_display = vr_photo_dir + current_user.username + "dis" + now_time +".png"
        new_photo = vr_photo_dir + current_user.username + now_time +".png"
        if os.path.exists(vr_photo_dir) == False:
            os.makedirs(vr_photo_dir)
            # img1 = Image.open(vr_display)
            # img1.save(new_display)
            img2 = Image.open(img)
            img2.save(new_photo)
        else:
            # img1 = Image.open(vr_display)
            # img1.save(new_display)
            img2 = Image.open(img)
            img2.save(new_photo)

        APP_Img.objects.create(user=current_user,img=new_photo)
        data = "0"
        return HttpResponse(data)


# app轮播图删除
class App_Img_Delete(ListView):
    def get(self,request):
        pass
    def post(self,request):
        print("-----app image delete!-----")
        e_id = request.POST.get('id')
        photo_obj = APP_Img.objects.get(id=e_id)
        if os.path.exists(photo_obj.img) == True:
            # 删除图片文件
            # os.remove(photo_obj.display)
            os.remove(photo_obj.img)
            # 删除数据库照片列表中，照片路径：
            try:
                APP_Img.objects.filter(id=e_id).delete()
                print("-----image delete ok!-----")
                data = "1"
                return HttpResponse(data)
            except:
                print("-----image delete failed!-----")
                data = "0"
                return HttpResponse(data)
        else:
            # 照片不存在，但是数据库有路径的情况会删除不掉
            # 因此不管何时都删除数据库路径
            try:
                APP_Img.objects.filter(id=e_id).delete()
                print("-----image delete ok!-----")
            except:
                print("-----image not exist!-----")
                pass
            data = "1"
            return HttpResponse(data)