yfwlwCut/apps/Webapp/views.py

# -*- coding: utf-8 -*-
from django.shortcuts import render, redirect
from django.conf.urls import url
from django.http import HttpResponse
from django.views.generic.base import View
from django.views.generic import ListView
from django.contrib import auth
from django.contrib.auth.hashers import make_password, check_password
from django.contrib.auth import authenticate, login as auth_login, logout
from yfwlw_pro.settings import get_client_ip
# from apps.AppInfoManage.models import Help, MyUser, User_Group,User_Log
from apps.AppInfoManage.models import *
from django.contrib.auth.decorators import login_required
from django.db.models import Q
import json
from apps.EquipManage.views import CJSONEncoder
from apps.SimInfo.views import get_simsinfo, get_siminfo
import re
import time
import datetime,os
from PIL import Image
from apps.ReportManage.all_dict import qxz_dict

# app登录：


class app_login(View):
    def get(self, request):
        pass

    def post(self, request):
        user_name = request.POST.get('username')
        pass_word = request.POST.get('password')
        print('输入的用户名：', user_name)
        print('输入的密码：', pass_word)
        user = MyUser.objects.extra(
            where=['binary username=%s'], params=[user_name])
        print("user.exists():", user.exists())
        data = {"role":"","code":"0"}
        if user.exists() == False:
            data = {"role":"","code":"1"}
            data = json.dumps(data)
            return HttpResponse(data)
        else:
            user = MyUser.objects.get(username=user_name)
            if user.is_active != True:
                data = {"role":"","code":"2"}
                data = json.dumps(data)
                return HttpResponse(data)
            else:
                if check_password(pass_word, user.password) != True:
                    data = {"role":"","code":"3"}
                    print('密码错误')
                    data = json.dumps(data)
                    return HttpResponse(data)
                else:
                    print('登陆成功')
                    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='app登录')
                    data = {"role":role,"code":"0"}
                    data = json.dumps(data)
                    print("data:",data)
                    return HttpResponse(data)


# 退出APP登录：
@login_required
def app_logout(request):
    username = request.POST.get('username')
    print("用户退出")
    # 删除session
    del request.session['username']
    auth.logout(request)
    data = "0"
    return HttpResponse(data)

# 个人信息：
class app_user_info(View):
    def get(self, request):
        pass
    def post(self, request):
        req = request.POST.get('req')
        user_name = request.user.username
        if req == "info":
            user = MyUser.objects.filter(username=user_name)
            for x in user:
                data = {"username": x.username, 
                        "email": x.email, 
                        "user_phone": x.user_phone, 
                        "user_pro": x.user_pro,
                        "user_city": x.user_city,
                        "user_area": x.user_area,
                        "user_picture":str(x.user_picture)
                        } 
            data = json.dumps(data)
            print("data:",data)
            return HttpResponse(data)

        elif req == "change_info":
            user = MyUser.objects.get(username=user_name)

            user.user_phone = request.POST.get('phone')

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

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

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


# 设备列表：
class app_equip_list(View):
    def get(self, request):
        pass

    def post(self, request):
        filt = request.POST.get('filter')
        print("filt:", filt)
        page = int(request.POST.get('page'))
        print("page:", page)
        current_user = request.session.get('username')
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        if filt == "":
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                equip_list = Equip.objects.filter(equip_user=current_user)
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---经销商")
                equip_list = Equip.objects.filter(equip_agency=current_user.user_agency)
            else:
                print("---管理员")
                equip_list = Equip.objects.all()
        else:
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                equip_list = Equip.objects.filter(Q(equip_user=current_user, equip_id__contains=filt) | Q(
                    equip_user=current_user, equip_name__contains=filt))
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---经销商")
                equip_list = Equip.objects.filter(Q(equip_agency=current_user.user_agency, equip_id__contains=filt) | Q(
                    equip_agency=current_user.user_agency, equip_name__contains=filt))
            else:
                print("---管理员")
                equip_list = Equip.objects.filter(
                    Q(equip_id__contains=filt) | Q(equip_name__contains=filt))

        nums = equip_list.count()
        equip_list = equip_list[(10*(page-1)):(page*10)]
        data = {'nums': nums, 'dat': ""}
        dat = []
        for i in equip_list:
            sta1 = Equip.objects.filter(equip_id=i.equip_id).select_related()
            for x in sta1:
                try:
                    sta2 = {"equip_id": x.equip_id,
                            "equip_user": x.equip_user.username,
                            "equip_name": x.equip_name,
                            "equip_type": x.equip_type.type_id}
                except AttributeError:
                    sta2 = {"equip_id": x.equip_id,
                            "equip_user": "",
                            "equip_name": x.equip_name,
                            "equip_type": x.equip_type.type_id}
                dat.append(sta2)
        User_Log.objects.create(log_user=request.user.username,
                                log_ip=request.META['REMOTE_ADDR'], log_desc='设备列表')
        data['dat'] = dat
        data = json.dumps(data, cls=CJSONEncoder)
        print("data:", data)
        return HttpResponse(data)


# 设备列表详情：
class app_equip_list_detail(View):
    def post(self, request):
        equip_id = request.POST.get('equip_id')
        x = Equip.objects.get(equip_id=equip_id)
        try:
            dat = {"equip_id": x.equip_id,
                   "equip_user": x.equip_user.username,
                   "equip_name": x.equip_name,
                   "equip_add_time": x.equip_add_time,
                   "equip_type": x.equip_type.type_id,
                   "equip_location": x.equip_location}
        except AttributeError:
            dat = {"equip_id": x.equip_id,
                   "equip_user": "",
                   "equip_name": x.equip_name,
                   "equip_add_time": x.equip_add_time,
                   "equip_type": x.equip_type.type_id,
                   "equip_location": x.equip_location}
        # User_Log.objects.create(
        #     log_user=request.user.username, log_ip=request.META['REMOTE_ADDR'], log_desc='设备列表')
        data = json.dumps(dat, cls=CJSONEncoder)
        print("data:", data)
        return HttpResponse(data)


# 设备管理：
class app_equipmanage(View):
    def post(self, request):
        etype = request.POST.get('etype')
        print("etype:", etype)
        if etype == "scd":
            etype = SCDstatus
        elif etype == "cbd":
            etype = CBDstatus
        elif etype == "qxz":
            etype = QXZstatus
        elif etype == "bzy":
            etype = BZYstatus
        elif etype == "xycb":
            etype = YBQstatus

        filt = request.POST.get('filter')
        print("filt:", filt)
        page = int(request.POST.get('page'))
        print("page:", page)
        # 读取当前用户：
        current_user = request.session.get('username')
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        data = {'nums': "", 'dat': ""}
        if filt == "":
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = etype.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 = etype.objects.filter(
                    equip_id__equip_agency=current_user.user_agency)
            else:
                print("---管理员")
                sta1 = etype.objects.all()
        else:
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                sta1 = etype.objects.filter(Q(equip_id__equip_user=current_user, equip_id__equip_id__contains=filt) | Q(
                    equip_id__equip_user=current_user, equip_id__equip_name__contains=filt))
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---经销商")
                sta1 = etype.objects.filter(Q(equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=filt) | Q(
                    equip_id__equip_agency=current_user.user_agency, equip_id__equip_name__contains=filt))
            else:
                print("---管理员")
                sta1 = etype.objects.filter(
                    Q(equip_id__equip_id__contains=filt) | Q(equip_id__equip_name__contains=filt))

        nums = sta1.count()
        sta1 = sta1[(10*(page-1)):(page*10)]
        # if etype == "qxz":
        #     sta2 = [{"equip_id": x.equip_id.equip_id, "upl_time": x.upl_time,
        #          "equip_name": x.equip_id.equip_name} for x in sta1]
        #     data['nums'] = nums
        #     data['dat'] = sta2
        #     data = json.dumps(data, cls=CJSONEncoder, indent=4)
        #     # print("data:",data)
        #     return HttpResponse(data)
        if request.POST.get('etype') == "xycb":
            try:
                sta2 = [{"equip_id": x.equip_id.equip_id, "upl_time": x.upl_time,
                        "equip_name": x.equip_id.equip_name,"equip_code":x.equip_code,"type":x.sex_type,
                        "is_online": x.is_online, "off_time": x.off_time} for x in sta1]
            except:
                sta2 = [{"equip_id": x.equip_id.equip_id, "upl_time": x.upl_time,
                    "equip_name": x.equip_id.equip_name,"equip_code":x.equip_code,"type":x.sex_type} for x in sta1]
            data['nums'] = nums
            data['dat'] = sta2
            data = json.dumps(data, cls=CJSONEncoder, indent=4)
            # print("data:",data)
            return HttpResponse(data)
        try:
            sta2 = [{"equip_id": x.equip_id.equip_id, "upl_time": x.upl_time,
                    "equip_name": x.equip_id.equip_name,
                    "is_online": x.is_online, "off_time": x.off_time} for x in sta1]
        except:
            sta2 = [{"equip_id": x.equip_id.equip_id, "upl_time": x.upl_time,
                 "equip_name": x.equip_id.equip_name} for x in sta1]
        data['nums'] = nums
        data['dat'] = sta2
        data = json.dumps(data, cls=CJSONEncoder, indent=4)
        # print("data:",data)
        return HttpResponse(data)


# 设备管理详情：
class app_equipmanage_detail(View):
    def post(self, request):
        etype = request.POST.get('etype')
        print("etype:", etype)
        equip_id = request.POST.get('equip_id')
        print("equip_id:", equip_id)
        if etype == "scd":
            x = SCDstatus.objects.get(equip_id__equip_id=equip_id)
            sta2 = {"scd_status": x.scd_status, "ds": x.ds, "upl_time": x.upl_time,
                    "equip_name": x.equip_id.equip_name,
                    "is_online": x.is_online, "off_time": x.off_time}
        elif etype == "cbd":
            x = CBDstatus.objects.get(equip_id__equip_id=equip_id)
            sta2 = {"cbd_status": x.cbd_status, "upl_time": x.upl_time,
                    "paramconf": x.paramconf, "equip_name": x.equip_id.equip_name,
                    "is_online": x.is_online, "off_time": x.off_time}
        elif etype == "qxz":
            sta2 = []
            try:
                sta = QXZstatus.objects.get(equip_id=equip_id)
                for i in range(len((eval(sta.qxz_status)["data"]))):
                    sta2.append({"unit": qxz_dict[eval(sta.qxz_status)['data'][i]["eNum"]],"equip_name": sta.equip_id.equip_name,
                            "upl_time": sta.upl_time, "equip_id": sta.equip_id_id, "eValue": eval(sta.qxz_status)["data"][i]["eValue"],
                            "eKey": eval(sta.qxz_status)["data"][i]["eKey"]})
            except Exception as exc:
                print(exc)
        elif etype == "bzy":
            x = BZYstatus.objects.get(equip_id__equip_id=equip_id)
            # sta2 = {"bzy_status": x.bzy_status, "upl_time": x.upl_time,
            #         "equip_name": x.equip_id.equip_name,"is_online": x.is_online, "off_time": x.off_time}
            sta2 = {"bzy_status": x.bzy_status, "upl_time": x.upl_time,
                         "equip_name": x.equip_id.equip_name,
                         "glass": x.glass, "liquid":x.liquid, "is_online": x.is_online,
                         "off_time": x.off_time}
        elif etype == "xycb":
            x = YBQstatus.objects.get(equip_id__equip_id=equip_id)
            sta2 = {"ybq_status": x.ybq_status, "upl_time": x.upl_time,
                         "equip_name": x.equip_id.equip_name,"type":x.sex_type,
                         "is_online": x.is_online,"off_time": x.off_time}
        data = json.dumps(sta2, cls=CJSONEncoder, indent=4)
        # print("data:",data)
        return HttpResponse(data)


# 报表管理：
class app_reportmanage(View):
    def post(self, request):
        etype = request.POST.get('etype')
        print("etype:", etype)
        filt = request.POST.get('filter')
        print("filt:", filt)
        page = int(request.POST.get('page'))
        print("page:", page)
        # 读取当前用户：
        current_user = request.session.get('username')
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        data = {'nums': "", 'dat': ""}
        if filt == "":
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                if etype == "scd":
                    equip_list = Equip.objects.filter(
                        equip_type=2, equip_user=current_user).values()
                elif etype == "cbd":
                    equip_list = Equip.objects.filter(
                        equip_type=3, equip_user=current_user).values()
                elif etype == "qxz":
                    equip_list = Equip.objects.filter(
                        equip_type=5, equip_user=current_user).values()
                elif etype == "bzy":
                    equip_list = Equip.objects.filter(
                        equip_type=7, equip_user=current_user).values()
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---经销商")
                if etype == "scd":
                    equip_list = Equip.objects.filter(
                        equip_type=2, equip_agency=current_user.user_agency).values()
                elif etype == "cbd":
                    equip_list = Equip.objects.filter(
                        equip_type=3, equip_agency=current_user.user_agency).values()
                elif etype == "qxz":
                    equip_list = Equip.objects.filter(
                        equip_type=5, equip_agency=current_user.user_agency).values()
                elif etype == "bzy":
                    equip_list = Equip.objects.filter(
                        equip_type=7, equip_agency=current_user.user_agency).values()
            else:
                print("---管理员")
                if etype == "scd":
                    equip_list = Equip.objects.filter(equip_type=2).values()
                elif etype == "cbd":
                    equip_list = Equip.objects.filter(equip_type=3).values()
                elif etype == "qxz":
                    equip_list = Equip.objects.filter(equip_type=5).values()
                elif etype == "bzy":
                    equip_list = Equip.objects.filter(equip_type=7).values()
        else:
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                print("---不是管理员")
                if etype == "scd":
                    equip_list = Equip.objects.filter(Q(equip_type=2, equip_user=current_user, equip_id__contains=filt) | Q(
                        equip_type=2, equip_user=current_user, equip_name__contains=filt)).values()
                elif etype == "cbd":
                    equip_list = Equip.objects.filter(Q(equip_type=3, equip_user=current_user, equip_id__contains=filt) | Q(
                        equip_type=3, equip_user=current_user, equip_name__contains=filt)).values()
                elif etype == "qxz":
                    equip_list = Equip.objects.filter(Q(equip_type=5, equip_user=current_user, equip_id__contains=filt) | Q(
                        equip_type=5, equip_user=current_user, equip_name__contains=filt)).values()
                elif etype == "bzy":
                    equip_list = Equip.objects.filter(Q(equip_type=7, equip_user=current_user, equip_id__contains=filt) | Q(
                        equip_type=7, equip_user=current_user, equip_name__contains=filt)).values()
            elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
                print("---经销商")
                if etype == "scd":
                    equip_list = Equip.objects.filter(Q(equip_type=2, equip_agency=current_user.user_agency, equip_id__contains=filt) | Q(
                        equip_type=2, equip_agency=current_user.user_agency, equip_name__contains=filt)).values()
                elif etype == "cbd":
                    equip_list = Equip.objects.filter(Q(equip_type=3, equip_agency=current_user.user_agency, equip_id__contains=filt) | Q(
                        equip_type=3, equip_agency=current_user.user_agency, equip_name__contains=filt)).values()
                elif etype == "qxz":
                    equip_list = Equip.objects.filter(Q(equip_type=5, equip_agency=current_user.user_agency, equip_id__contains=filt) | Q(
                        equip_type=5, equip_agency=current_user.user_agency, equip_name__contains=filt)).values()
                elif etype == "bzy":
                    equip_list = Equip.objects.filter(Q(equip_type=7, equip_agency=current_user.user_agency, equip_id__contains=filt) | Q(
                        equip_type=7, equip_agency=current_user.user_agency, equip_name__contains=filt)).values()
            else:
                print("---管理员")
                if etype == "scd":
                    equip_list = Equip.objects.filter(Q(equip_type=2, equip_id__contains=filt) | Q(
                        equip_type=2, equip_name__contains=filt)).values()
                elif etype == "cbd":
                    equip_list = Equip.objects.filter(Q(equip_type=3, equip_id__contains=filt) | Q(
                        equip_type=3, equip_name__contains=filt)).values()
                elif etype == "qxz":
                    equip_list = Equip.objects.filter(Q(equip_type=5, equip_id__contains=filt) | Q(
                        equip_type=5, equip_name__contains=filt)).values()
                elif etype == "bzy":
                    equip_list = Equip.objects.filter(Q(equip_type=7, equip_id__contains=filt) | Q(
                        equip_type=7, equip_name__contains=filt)).values()
        dat = []
        for i in equip_list:
            # if etype == "scd":
            #     sta1 = RecentSCDdata.objects.filter(
            #         equip_id=i.equip_id)
            # # 关键步骤：从测报灯数据列表模型中，筛选出当前用户所拥有的设备的设备id的数据记录，然后进行倒叙排列，最后切片操作，只取第一条数据，即为最新
            # elif etype == "cbd":
            #     sta1 = CBDdata.objects.filter(
            #         equip_id=i.equip_id).order_by('-upl_time')[:1]
            # elif etype == "qxz":
            #     sta1 = QXZstatus.objects.filter(
            #         equip_id=i.equip_id)
            # elif etype == "bzy":
            #     sta1 = BZYstatus.objects.filter(
            #         equip_id=i.equip_id)
            # for x in sta1:
            #     sta2 = {"equip_id": x.equip_id.equip_id, "upl_time": x.upl_time,
            #             "equip_name": x.equip_id.equip_name}
            sta2 = {"equip_id": i["equip_id"],"equip_name": i["equip_name"]}
            dat.append(sta2)
        nums = len(dat)
        data['nums'] = nums
        data['dat'] = dat[(10*(page-1)):(page*10)]
        data = json.dumps(data, cls=CJSONEncoder, indent=4)
        # print("data:",data)
        return HttpResponse(data)


# 单个设备的报表展开：
class app_reportmanage_unflod(View):
    def post(self, request):
        etype = request.POST.get('etype')
        print("etype:", etype)
        equip_id = request.POST.get('equip_id')
        print("equip_id:", equip_id)
        if etype == "scd":
            sta1 = SCDdata.objects.filter(
                equip_id__equip_id=equip_id).order_by("-upl_time")[:1]
            for x in sta1:
                sta2 = {"equip_name": x.equip_id.equip_name,
                        "scd_data": x.scd_data, "ds": x.ds, "upl_time": x.upl_time}
        elif etype == "cbd":
            sta1 = RecentCBDdata.objects.filter(
                equip_id__equip_id=equip_id)
            for x in sta1:
                sta2 = {"equip_name": x.equip_id.equip_name,"discern":x.disc,
                        "cbd_data": x.cbd_data, "upl_time": x.upl_time}
        elif etype == "qxz":
            sta1 = QXZstatus.objects.filter(
                equip_id__equip_id=equip_id)
            for x in sta1:
                sta2 = {"equip_name": x.equip_id.equip_name,
                        "qxz_data": x.qxz_status, "upl_time": x.upl_time}
        elif etype == "bzy":
            sta1 = BZYstatus.objects.filter(
                equip_id__equip_id=equip_id)
            for x in sta1:
                sta2 = {"equip_name": x.equip_id.equip_name,
                        "bzy_data": x.bzy_status, "upl_time": x.upl_time}
        data = json.dumps(sta2, cls=CJSONEncoder, indent=4)
        # print("data:",data)
        return HttpResponse(data)


# 单个设备的详情报表：
class app_reportmanage_detail(View):
    def post(self, request):
        filter_begin = request.POST.get('filter_begin')
        print("filter_begin:", filter_begin)
        filter_end = request.POST.get('filter_end')
        print("filter_end:", filter_end)
        equip_id = request.POST.get('equip_id')
        print("equip_id:", equip_id)
        page = int(request.POST.get('page'))
        print("page:", page)
        etype = request.POST.get('etype')
        print("etype:", etype)
        if filter_begin == "":
            if etype == "scd":
                sta1 = SCDdata.objects.filter(equip_id=equip_id).values()
            elif etype == "cbd":
                sta1 = CBDdata.objects.filter(equip_id=equip_id)
            elif etype == "qxz":
                sta1 = QXZdata.objects.filter(equip_id=equip_id)
            elif etype == "bzy":
                sta1 = BZYdata.objects.filter(equip_id=equip_id)
            elif etype == "xycb":
                sta1 = YBQdata.objects.filter(equip_id=equip_id)
        else:
            begindate = re.findall(r"\d+\.?\d*", filter_begin)
            enddate = re.findall(r"\d+\.?\d*", filter_end)
            start_date = datetime.date(
                int(begindate[0]), int(begindate[1]), int(begindate[2]))
            end_date = datetime.date(
                int(enddate[0]), int(enddate[1]), int(enddate[2]))
            if etype == "scd":
                sta1 = SCDdata.objects.filter(
                    equip_id=equip_id, upl_time__range=(start_date, end_date)).values()
            elif etype == "cbd":
                sta1 = CBDdata.objects.filter(
                    equip_id=equip_id, upl_time__range=(start_date, end_date))
            elif etype == "qxz":
                sta1 = QXZdata.objects.filter(
                    equip_id=equip_id, upl_time__range=(start_date, end_date))
            elif etype == "bzy":
                sta1 = BZYdata.objects.filter(
                    equip_id=equip_id, upl_time__range=(start_date, end_date))
            elif etype == "xycb":
                sta1 = YBQdata.objects.filter(
                    equip_id=equip_id, upl_time__range=(start_date, end_date))

        if etype == "scd":
            sta2 = [{# "equip_name": x.equip_id.equip_name,
                     "scd_data": x["scd_data"],
                     "ds": x["ds"], "upl_time": x["upl_time"]}for x in sta1]
        elif etype == "cbd":
            sta2 = [{"equip_name": x.equip_id.equip_name,
                     "cbd_data": x.cbd_data,
                     "upl_time": x.upl_time}for x in sta1]
        elif etype == "qxz":
            sta2 = [{"equip_name": x.equip_id.equip_name,
                     "qxz_data": x.qxz_data,
                     "upl_time": x.upl_time}for x in sta1]
        elif etype == "bzy":
            sta2 = [{"equip_name": x.equip_id.equip_name,
                     "bzy_data": x.bzy_data,
                     "upl_time": x.upl_time}for x in sta1]
        elif etype == "xycb":
            sta2 = [{"equip_name": x.equip_id.equip_name,
                     "ybq_data": x.ybq_data,
                     "upl_time": x.upl_time}for x in sta1]

        data = {'nums': "", 'dat': ""}
        nums = len(sta2)
        data['nums'] = nums
        data['dat'] = sta2[(10*(page-1)):(page*10)]
        data = json.dumps(data, cls=CJSONEncoder, indent=4)
        # print("data:",data)
        return HttpResponse(data)


# ：
class app_cbd_img(View):
    def post(self, request):
        imei = request.POST.get('equip_id')
        print("imei:", imei)
        # 获得当前页：
        page = int(request.POST.get('page'))
        print("page:", page)
        # 从数据库中取出照片在服务器存放路径：
        img = CBDphoto.objects.filter(equip_id=imei)
        nums = img.count()
        img = img[(10*(page-1)):(page*10)]
        equip_name = Equip.objects.get(equip_id=imei).equip_name
        disc = RecentCBDdata.objects.get(equip_id=imei)
        # 当前用户：返回用户，前端判断是否显示删除图片按钮
        current_user = request.session.get('username')
        print("current_user:", current_user)
        img_dat = [{"upl_time": x.upl_time,
                    "addr": x.addr}for x in img]
        dat = {'img':img_dat,
                'nums':nums,
                'equip_name':equip_name,
                'disc':disc.disc,
                'equip_id':imei
            }
        data = json.dumps(dat, cls=CJSONEncoder, indent=4)
        print("data:",data)
        return HttpResponse(data)


# ：
class app_ybq_img(View):
    def post(self, request):
        imei = request.POST.get('equip_id')
        print("imei:", imei)
        # 获得当前页：
        page = int(request.POST.get('page'))
        print("page:", page)
        # 从数据库中取出照片在服务器存放路径：
        img = YBQphoto.objects.filter(equip_id=imei)
        nums = img.count()
        img = img[(10*(page-1)):(page*10)]
        equip_name = Equip.objects.get(equip_id=imei).equip_name
        # 当前用户：返回用户，前端判断是否显示删除图片按钮
        current_user = request.session.get('username')
        print("current_user:", current_user)
        img_dat = [{"upl_time": x.upl_time,
                    "addr": x.addr}for x in img]
        dat = {'img':img_dat,
                'nums':nums,
                'equip_name':equip_name,
                'equip_id':imei
            }
        data = json.dumps(dat, cls=CJSONEncoder, indent=4)
        print("data:",data)
        return HttpResponse(data)


# 孢子仪图片接口
class app_bzy_img(View):
    def post(self, request):
        imei = request.POST.get('equip_id')
        print("imei:", imei)
        # 获得当前页：
        page = int(request.POST.get('page'))
        print("page:", page)
        # 从数据库中取出照片在服务器存放路径：
        img = BZYphoto.objects.filter(equip_id=imei)
        nums = img.count()
        img = img[(5*(page-1)):(page*5)]
        equip_name = Equip.objects.get(equip_id=imei).equip_name
        # 当前用户：返回用户，前端判断是否显示删除图片按钮
        current_user = request.session.get('username')
        print("current_user:", current_user)
        img_dat = [{"upl_time": x.upl_time,
                    "addr": x.addr}for x in img]
        dat = {'img':img_dat,
                'nums':nums,
                'equip_name':equip_name,
                'equip_id':imei
            }
        data = json.dumps(dat, cls=CJSONEncoder, indent=4)
        print("data:",data)
        return HttpResponse(data)



# 用户页面
class app_usermanage_list(View):
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        nums = MyUser.objects.all().count()
        print("筛选")
        user_name = request.POST.get("username")
        page = int(request.POST.get('page'))
        print("user_name:",user_name)
        print("page:", page)
        if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
            pass
        elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
            print("----代理商")
            # 搜索条件为空，获取所有用户
            if user_name == '':
                user_list = MyUser.objects.filter(user_agency=current_user.user_agency)

            # 搜索条件存在，根据用户名搜索用户      
            elif user_name != '':
                user_list = MyUser.objects.filter(user_agency=current_user.user_agency,username__contains=user_name)
        else:
            print("----管理员")
            # 搜索条件为空，获取所有用户
            if user_name == '':
                user_list = MyUser.objects.all()

            # 搜索条件存在，根据用户名搜索用户      
            elif user_name != '':
                user_list = MyUser.objects.filter(username__contains=user_name)
        dat = []
        for i in user_list[(10*(page-1)):(page*10)]:
            sta1 = MyUser.objects.filter(username=i.username)
            try:
                for x in sta1:
                    if x.is_superuser == 1 and x.is_staff == 1:
                        role = "超级管理员"
                    elif x.is_superuser == 0 and x.is_staff == 1:
                        role = "管理员"
                    elif x.is_superuser == 0 and x.is_staff == 0:
                        role = "用户"
                    sta2 = {"userId": x.id, "user_name": x.username, "user_email": x.email,
                            "user_type": role}
            except AttributeError:
                for x in sta1:
                    if x.is_superuser == 1 and x.is_staff == 1:
                        role = "超级管理员"
                    elif x.is_superuser == 0 and x.is_staff == 1:
                        role = "管理员"
                    elif x.is_superuser == 0 and x.is_staff == 0:
                        role = "用户"
                    sta2 = {"userId": x.id, "user_name": x.username, "user_email": x.email,
                            "user_type": role}
            dat.append(sta2)
        data = {"nums":nums,"dat":dat}
        data = json.dumps(data, cls=CJSONEncoder)

        # print("++++++++++++++++++",data)  
        
        return HttpResponse(data)


# 用户详情页面
class app_usermanage_detail(View):
    def post(self,request):
        current_user = request.user.username
        userId = request.POST.get("userId")
        x = MyUser.objects.get(id=userId)
        groups = User_Group.objects.all()
        group_list = []
        for i in groups:
            group_list.append(i.name)
        group = Group.objects.filter(user=x)
        print("dskfsadfjkd",type(group))
        if group.count() == 0:
            group_name = ""
        else:
            group_name = group[0].name 
        try:
            if x.is_superuser == 1 and x.is_staff == 1:
                # 超级管理员
                role = 0
            elif x.is_superuser == 0 and x.is_staff == 1:
                # 管理员
                role = 1
            elif x.is_superuser == 0 and x.is_staff == 0:
                # 普通用户
                role = 2
            dat = {"userId":x.id,
                    "username":x.username,
                    "email":x.email,
                    "tel":x.user_phone,
                    "province":x.user_pro,  # 省
                    "city":x.user_city,     # 市
                    "area":x.user_area,     # 县/区
                    "usertype":role,
                    "latestTime":x.last_login,
                    "creatTime":x.date_joined,
                    "user_groups":group_list,
                    "user_group":group_name,
                    "user_remark":x.user_remark,
                    "active":x.is_active}
        except AttributeError:
            if x.is_superuser == 1 and x.is_staff == 1:
                role = 0
            elif x.is_superuser == 0 and x.is_staff == 1:
                role = 1
            elif x.is_superuser == 0 and x.is_staff == 0:
                role = 2
            dat = {"userId":x.id,
                    "username":x.username,
                    "email":x.email,
                    "tel":x.user_phone,
                    "province":x.user_pro,
                    "city":x.user_city,
                    "area":x.user_area,
                    "usertype":role,
                    "latestTime":x.last_login,
                    "creatTime":x.date_joined,
                    "user_groups":group_list,
                    "user_group":group_name,
                    "user_remark":x.user_remark,
                    "active":x.is_active}
        data = json.dumps(dat,cls=CJSONEncoder)
        print("data:",data)
        return HttpResponse(data)


# 用户编辑页面
class app_usermanage_edit(View):
    def post(self,request):
        # current_user = request.user.username
        postname = request.POST.get('username')
        uname = MyUser.objects.get(username=postname)
        uname.user_phone = request.POST.get('userphone')
        post_type = request.POST.get('user_type')
        # 角色：即用户组；
        
        post_groups = request.POST.get('user_groups')
        print("post_groups:", post_groups)
        if post_groups != '0':
            # 获取当前用户的组：
            post_groups = User_Group.objects.get(id=post_groups)
            print("post_groups:", post_groups)
            
            groups = Group.objects.filter(user=uname)
            uname.groups.clear()
            uname.groups.add(post_groups)

        # 省市区：
        uname.user_pro = request.POST.get('province')
        print(request.POST.get('province'))
        uname.user_city = request.POST.get('city')
        print(request.POST.get('city'))
        uname.user_area = request.POST.get('area')
        print(request.POST.get('area'))

        uname.user_remark = request.POST.get('user_remarks')

        print("post_type", post_type)
        if post_type == '0':
            uname.is_superuser = True
            uname.is_staff = True
            print("post_type")
        elif post_type == '1':
            uname.is_superuser = False
            uname.is_staff = True
            print("post_type")
        elif post_type == '2':
            uname.is_superuser = False
            uname.is_staff = False
            print("post_type")
        try:
            uname.save()
        except Exception as e:
            print("数据保存失败:",e)
            data = "1"
            return HttpResponse(data)
        # User_Log.objects.create(log_user=request.user.username,
        #                                log_ip=request.META['REMOTE_ADDR'], log_desc='系统管理-用户管理--编辑用户：修改用户'+username+"的信息")
        data = "0"
        return HttpResponse(data)


# 用户组列表管理
class app_user_group(View):        
    def post(self,request):
        f_name = request.POST.get('fName')
        page = int(request.POST.get('page'))
        # 如果搜索名存在
        if f_name:
            sta = User_Group.objects.filter(name__contains=f_name)[(10*(page-1)):(page*10)]
            nums = len(User_Group.objects.filter(name__contains=f_name))
        else:
            sta = User_Group.objects.all()[(10*(page-1)):(page*10)]
            nums = len(User_Group.objects.all())
        dat = []
        try:
            for x in sta:
                sta1 = {"group_name":x.name}
                dat.append(sta1)
        except AttributeError:
            for x in sta:
                sta1 = {"group_name":x.name}
                dat.append(sta1)
        data = {"nums":nums,"dat":dat}
        print("data:",data)
        data = json.dumps(data,cls=CJSONEncoder)
        return HttpResponse(data)



# 用户组列表详情
class app_user_group_details(View):
    def post(self,request):
        group_name = request.POST.get('name')
        x = User_Group.objects.get(name=group_name)
        data = {"logo":"%s"%x.role_logo,
                "username":x.name,
                "userremark":x.role_describe,
                "creatTime":x.role_cre_time,
                "copyright":x.role_footer}
        # print("data:",data)
        data = json.dumps(data,cls=CJSONEncoder)
        return HttpResponse(data)


# 用户组列表编辑
class app_user_group_edit(View):
    def post(self,request):
        current_group = request.POST.get('group')
        print("current_group:", current_group)
        group = User_Group.objects.get(name=current_group)
        footer = request.POST.get('footer')
        group_logo = request.FILES.get('upicture')
        if group_logo:
            group_logo_dir = 'home_logo/'
            # group_logo_dir = 'F:\\YFWLW\\yfwlw\\home_logo/'
            # 判断如果路径不存在，即创建路径
            if os.path.exists(group_logo_dir) == False:
                os.makedirs(group_logo_dir)

            img = Image.open(group_logo)
            img.save(group_logo_dir + current_group+".png")
            new_logo = group_logo_dir + current_group+".png"
            # new_logo = 'home_logo/'  + current_group+".png"
            print("组页logo路径：", new_logo)
            # 数据库关联设备，并在照片的表中存入路径：
            group.role_logo = new_logo
        group.role_footer = footer
        try:
            group.save()
        except Exception as e:
            print("保存失败:",e)
            data = "1"
            return HttpResponse(data)

        data = "0"
        return HttpResponse(data)



# 设备分配页面
class app_equip_allot(View):

    def post(self,request):
        uname = request.POST.get('uname')
        page = int(request.POST.get('page'))
        print("page=",page)
        if uname:
            user_list = MyUser.objects.filter(username__contains=uname)
        else:
            # 接收当前用户
            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 or current_user.is_staff == True:
                user_list = MyUser.objects.all().order_by(
                    "-date_joined")[(10*(page-1)):(page*10)]
            elif current_user.is_agency:
                user_list = MyUser.objects.filter(user_agency=current_user.user_agency).order_by(
                    "-date_joined")[(10*(page-1)):(page*10)]
            # user_list = MyUser.objects.all()
        nums = user_list.count()
        user_list = user_list[(10*(page-1)):(page*10)]
        dat = []
        for x in user_list:
            try:
                sta = {"userid":x.id,"username":x.username,"email":x.email}
            except AttributeError:
                sta = {"userid":x.id,"username":x.username,"email":x.email}
            dat.append(sta)
        data = {'nums':nums,'dat':dat}
        data = json.dumps(data, cls=CJSONEncoder)
        User_Log.objects.create(log_user=request.user.username,
                                log_ip=request.META['REMOTE_ADDR'], log_desc='设备分配')
        return HttpResponse(data)

# 未分配设备列表
class app_equip_allot_list(View):

    def post(self,request):
        userid = request.POST.get('userid')
        user_obj = MyUser.objects.get(id=userid)
        f_id = request.POST.get('f_id')
        page = int(request.POST.get('page'))
        print("page=",page)
        if f_id:
            equip_list = Equip.objects.filter(
                Q(equip_user=None, equip_id__contains=f_id) | Q(equip_user=user_obj, equip_id__contains=f_id))
        else:
            # 接收当前用户
            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 or current_user.is_staff == True:
                equip_list = Equip.objects.filter(
                    Q(equip_user=None) | Q(equip_user=user_obj))
            elif current_user.is_agency:
                equip_list = Equip.objects.filter(
                    Q(equip_agency=current_user.user_agency, equip_user=None) | Q(equip_agency=current_user.user_agency,
                    equip_user=user_obj))

            # equip_list = Equip.objects.filter(
            #         Q(equip_user=None) | Q(equip_user=user_obj))
        nums = equip_list.count()
        equip_list = equip_list[(10*(page-1)):(page*10)]
        dat = []
        for x in equip_list:
            if x.equip_user == user_obj:
                checked = "1"
            else:
                checked = "0"
            try:
                sta = {"checked":checked,
                       "equipid":x.equip_id,
                       "equipname":x.equip_name,
                       "equiptype":'%s'%x.equip_type,
                       "equip_add_time":x.equip_add_time,
                       "equip_user":'%s'%x.equip_user}
            except AttributeError:
                sta = {"checked":checked,
                       "equipid":x.equip_id,
                       "equipname":x.equip_name,
                       "equiptype":'%s'%x.equip_type,
                       "equip_add_time":x.equip_add_time,
                       "equip_user":'%s'%x.equip_user}
            dat.append(sta)
        data = {'nums':nums,'dat':dat}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)


class app_equip_allot_confirm(View):
    def post(self,request):
        userid = request.POST.get('userid')
        user_obj = MyUser.objects.get(id=userid)
        equip_ids = request.POST.get('equip_ids')
        print("equip_ids=", equip_ids)
        equip_ids = json.loads(equip_ids)
        # equip_ids = equip_ids.split(',')
        # print("当前页的所有设备id：equip_ids=", equip_ids)
        # 获得选中的复选框:
        check_box_list = request.POST.get('check_box_list')
        print('check_box_list:', check_box_list)
        check_box_list = json.loads(check_box_list)
        no_check_box_list = []
        for i in equip_ids:
            if i in check_box_list:
                pass
            else:
                no_check_box_list.append(i)
        print('no_check_box_list=', no_check_box_list)
        try:
            for checked_id in check_box_list:
                choose_equip = Equip.objects.get(equip_id=checked_id)
                # 如果选中的设备没有用户：即选中的设备 设备用户为None：
                if choose_equip.equip_user == None:  # 只有当选中的设备id对应的设备  没有用户时才分配
                    choose_equip.equip_user = user_obj
                    choose_equip.save()  # 保存到数据库

            # 取消分配:给当前用户取消已分配的设备；

            for a in no_check_box_list:
                choose_equip = Equip.objects.get(equip_id=a)
                choose_equip.equip_user = None  # 把设备的设备用户改为None，表示取消分配
                choose_equip.save()
        except Exception as e:
            print(e)
            data = "1"
        data = "0"

        User_Log.objects.create(log_user=request.user.username,
                                log_ip=request.META['REMOTE_ADDR'], log_desc='设备分配--分配设备')

        return HttpResponse(data)


# 害虫识别接口
import requests

class app_insect_discern(View):
    def post(self,request):
        imageFile = request.FILES.get('imagefile')
        imageFile = {"imageFile":imageFile}       
        username = 'yunfei'
        uniqueKey = '84e6eb40f3a616dd14b1fefc75425006'
        url = 'http://47.99.110.100:8080/recognizationSys/api/recognization'
       
        data = {'imageType':'1','gis':'118.279643#31.221456','username':username,'uniqueKey':uniqueKey}
        res = requests.post(url,data=data,files=imageFile)

        return HttpResponse(res.text)


# 监控设备分页接口
class app_moni_page(View):
    def post(self,request):
        current_user = request.user.username
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        page = request.POST.get('page')
        page = int(page)
        f_id = request.POST.get('f_id')
        print("f_id:", f_id)
        if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
            # 用户
            if f_id != "":
                # equip_list = Equip.objects.filter(equip_type=6, equip_user=current_user, equip_id__contains=f_id)
                equip_list = JKdata.objects.filter(equip_id__equip_user=current_user, equip_id__equip_id__contains=f_id)
            else:
                # equip_list = Equip.objects.filter(equip_type=6, equip_user=current_user)
                equip_list = JKdata.objects.filter(equip_id__equip_user=current_user)

        elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
            # 代理商
            if f_id != "":
                # equip_list = Equip.objects.filter(equip_type=6, equip_agency=current_user.user_agency, equip_id__contains=f_id)
                equip_list = JKdata.objects.filter(equip_id__equip_agency=current_user.user_agency, equip_id__equip_id__contains=f_id)
            else:
                # equip_list = Equip.objects.filter(equip_type=6, equip_agency=current_user.user_agency)
                equip_list = JKdata.objects.filter(equip_id__equip_agency=current_user.user_agency)

        else:
            # 管理员
            if f_id != "":
                # equip_list = Equip.objects.filter(equip_type=6, equip_id__contains=f_id)
                equip_list = JKdata.objects.filter(equip_id__equip_id__contains=f_id)
            else:
                # equip_list = Equip.objects.filter(equip_type=6)
                equip_list = JKdata.objects.all()
        e_ids = []
        for x in equip_list:
            n_d = {"equip_name":x.equip_id.equip_name, "equip_id":x.equip_id_id,"is_online":x.is_online}
            e_ids.append(n_d)
        nums = len(e_ids)
        # print(nums)
        ids = e_ids[(10*(page-1)):(page*10)]
        data = {'ids': ids, 'nums': nums}
        data = json.dumps(data)
        return HttpResponse(data)



# 监控设备接口
class app_moni(View):
    def post(self,request):
        e_id = request.POST.get('id')
        x = JKdata.objects.get(equip_id=e_id)
        live_list = []
        live_url = 'https://open.ys7.com/api/lapp/live/address/get'
        live_data = {"accessToken":x.jk_token,
                    "source":"%s:1"%x.equip_id}
        print("=================live_data:",live_data)
        live_res = requests.post(live_url,data=live_data)
        # print("-------------------------------:",type(live_res.text))
        live_res = eval(live_res.text)
        print("live_res:",live_res)
        # 如果返回200 则返回直播地址
        if live_res['code'] == "200":
            print("token获取成功___APP")
            live_list.append(live_res)
                
        # 如果返回其他 则调用获取token之后重新获取直播地址并返回
        else:
            print("token过期重新获取___APP")
            token_url = 'https://open.ys7.com/api/lapp/token/get'
            token_data = {"appKey":"e8ec0d52b4b14628a3daf4b88cbcca2a",
                    "appSecret":"d4565abea1cd0b90b59917111dcb37bd"}
            token_res = requests.post(token_url,data=token_data)
            print("token_res1:",token_res.text)
            token_res = eval(token_res.text)
            if token_res["code"] == "200":
                token_res["data"]["accessToken"]
                x.jk_token = token_res["data"]["accessToken"]
                x.upl_time = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
                x.save()
                token = x.jk_token
                print("-----------------token保存成功___APP")
            live_url = 'https://open.ys7.com/api/lapp/live/address/get'
            live_data = {"accessToken":x.jk_token,
                        "source":"%s:1"%x.equip_id}
            live_res = requests.post(live_url,data=live_data)
            live_res = eval(live_res.text)
            print("live_res2:",live_res)
            live_list.append(live_res)
        print("APP直播地址列表:",live_list)
        data = live_list
        print("-----------============data:",data)
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)



class app_download(View):
    def get(self,request):
        return render(request, 'home/download.html')
        # return redirect('app_download/yfApp.apk')


class app_download2(View):
    def get(self,request):
        return render(request, 'home/commonDownload.html')
        # return redirect('app_download/yfApp.apk')



class user_etype(View):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        equip_type_list = []
        if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
            print("普通用户")
            user_equip_list = Equip.objects.filter(equip_user=current_user)
            for i in user_equip_list:
                equip_type_list.append(i.equip_type.type_id)
        elif current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency == True:
            print("代理商")
            user_equip_list = Equip.objects.filter(equip_agency=current_user.user_agency)
            for i in user_equip_list:
                equip_type_list.append(i.equip_type.type_id)
        else:
            print("管理员")
            user_equip_list = Equip.objects.all()
            for i in user_equip_list:
                equip_type_list.append(i.equip_type.type_id)
        # 去除列表中重复的元素
        # equip_type_list = {}.fromkeys(equip_type_list).keys()
        equip_type_list = list(set(equip_type_list))
        print(equip_type_list)
        print(type(equip_type_list))
        data = {'dat':equip_type_list}
        data = json.dumps(data)
        return HttpResponse(data)



# 版本号判断
class edition(View):
    def get(self,request):
        pass
    def post(self,request):
        edition_obj = App_Edition.objects.all()
        edition = edition_obj.first()
        print(edition.edition_num)
        print(edition.edition_desc)
        data = {"edition_num":edition.edition_num,"edition_desc":edition.edition_desc,"upl_time":edition.upl_time}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)


# 版本更新历史
class edition_all(View):
    def get(self,request):
        pass
    def post(self,request):
        edition_list = App_Edition.objects.all()
        data = []
        for i in edition_list:
            data.append({"edition_num":i.edition_num,"edition_desc":i.edition_desc,"upl_time":i.upl_time})
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)



# APP轮播图
class Display_Photo(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        img_list = APP_Img.objects.filter(user=current_user)
        if img_list.count() == 0:
            data = [{"imgUrl":"app_file/app_img/banner1.jpg",
                    "path":""},
                    {"imgUrl":"app_file/app_img/banner2.jpg",
                    "path":""},
                    {"imgUrl":"app_file/app_img/banner4.jpg",
                    "path":""},
                    {"imgUrl":"app_file/app_img/autoDiscern.jpg",
                    "path":"autoDiscern.html"}]
        else:
            data = []
            for i in img_list:
                data.append({"imgUrl":i.img,
                    "path":""})
        data = json.dumps(data)
        return HttpResponse(data)

# 中性APP轮播图
class Display_Photo_Common(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        current_user = MyUser.objects.get(username=current_user)
        img_list = APP_Img.objects.filter(user=current_user)
        if img_list.count() == 0:
            data = [{"imgUrl":"app_file/app_img/banner1.jpg",
                    "path":""},
                    {"imgUrl":"app_file/app_img/banner2.jpg",
                    "path":""},
                    {"imgUrl":"app_file/app_img/banner4.jpg",
                    "path":""},
                    {"imgUrl":"app_file/app_img/autoDiscern.jpg",
                    "path":"autoDiscern.html"}]
        else:
            data = []
            for i in img_list:
                data.append({"imgUrl":i.img,
                    "path":""})
        data = json.dumps(data)
        return HttpResponse(data)


# SIM卡列表：
class APP_SimInfo(ListView):
    def get(self, request):
        pass

    def post(self, request):
        req = request.POST.get('req')
        print("req:", req)

        simid = request.POST.get('simid')
        if simid:
            res = get_siminfo(simid)
            return HttpResponse(res.text)
            

        if req == "reqdat":
            page = int(request.POST.get('page'))
            print("page:", page)
            current_user = request.session.get('username')
            print("current_user:", current_user)
            current_user = MyUser.objects.get(username=current_user)
            if current_user.is_superuser != True and current_user.is_staff != True and current_user.is_agency != True:
                sta1 = SCDstatus.objects.filter(equip_id__equip_user=current_user)
                sta2 = CBDstatus.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:
                sta1 = SCDstatus.objects.filter(equip_id__equip_agency=current_user.user_agency)
                sta2 = CBDstatus.objects.filter(equip_id__equip_agency=current_user.user_agency)
            else:
                sta1 = SCDstatus.objects.all()
                sta2 = CBDstatus.objects.all()
            # 获取设备列表中的SIM卡的iccid号码：
            iccids = []
            # 获取设备的id：
            equip_ids = []
            # 获取设备的名称：
            equip_names = []
            # 遍历查询流量信息：
            siminfos = []
            
            for i in sta1:
                try:
                    iccid = eval(i.scd_status)['iccid']
                except:
                    iccid = ""
                iccids.append(iccid)
                equip_ids.append(str(i.equip_id))
                equip_names.append(str(i.equip_id.equip_name))

            for i in sta2:
                try:
                    iccid = eval(i.cbd_status)['iccid']
                except:
                    iccid = ""
                iccids.append(iccid)
                equip_ids.append(str(i.equip_id))
                equip_names.append(str(i.equip_id.equip_name))


            nums = len(equip_ids)
            iccids=iccids[(10*(page-1)):(page*10)]
            equip_ids=equip_ids[(10*(page-1)):(page*10)]
            equip_names=equip_names[(10*(page-1)):(page*10)]

            # 调用api查到的iccid号：
            equip_iccids = []
            iccids_str = ",".join(iccids)
            print("iccids_str:",iccids_str)
            res = get_simsinfo(iccids_str).content
            print('res',res)
            siminfo_str=str(res, encoding = "utf-8")  
            siminfo_dict=eval(siminfo_str)

            # 保存调用查询流量的api返回的数据；
            dat = []
            for j in list(range(0,siminfo_dict['data']['count'])):
                equip_iccids.append(siminfo_dict['data']['card_list'][j]['iccid'])
            # print('equip_iccids:',equip_iccids)

            for j in list(range(0,len(iccids))):
                siminfo_dict=eval(siminfo_str)
                if (iccids[j] in equip_iccids) == True:
                    dat.append(siminfo_dict['data']['card_list'][equip_iccids.index(iccids[j])])
                else:
                    dat.append({})
                dat[j]['equip_id']=equip_ids[j]
                dat[j]['equip_name']=equip_names[j]
                # print("dat[%d]=%s" %(j,dat[j]))
                iccids[j] = ""# 每次判断完将该值清空，防止多个设备用一个SIM卡测试时显示异常；
                # print('----- iccids :',iccids)
            print("------------------------",dat)
            data = {"dat":dat,"nums":nums}
            data = json.dumps(data)
            print("data:",data)
            return HttpResponse(data)


# 性诱设备查看图片
class trap_photo(ListView):
    def get(self,request):
        pass
    def post(self,request):
        imei = request.POST.get('imei')
        page = int(request.POST.get('page'))
        print("imei:", imei)
        trap_photo = Trapphoto.objects.filter(equip_id=imei)
        nums = Trapphoto.objects.filter(equip_id=imei).count()
        print("nums:", nums)
        dat = []
        for i in trap_photo:
            dat.append({"addr":i.addr,"upl_time":i.upl_time})
        dat = dat[(5*(page-1)):(page*5)]
        data = {"dat":dat,"nums":nums}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)


# 性诱设备温湿度和虫子
class trap_pest(ListView):
    def get(self,request):
        pass
    def post(self,request):
        imei = request.POST.get('imei')
        page = int(request.POST.get('page'))
        print("imei:", imei)
        trap_data = Trapdata.objects.filter(equip_id=imei)
        nums = Trapdata.objects.filter(equip_id=imei).count()
        print("nums:", nums)
        dat = []
        for i in trap_data:
            dat.append({"pestnum":i.pestnum,"at":i.tem,"ah":i.hum,"upl_time":i.upl_time})
        dat = dat[(10*(page-1)):(page*10)]
        data = {"dat":dat,"nums":nums}
        data = json.dumps(data, cls=CJSONEncoder)
        return HttpResponse(data)



# 产品介绍
class product_view(ListView):
    def get(self,request):
        pass
    def post(self,request):
        current_user = request.session.get('username')
        print("current_user:", current_user)
        current_user = MyUser.objects.get(username=current_user)
        equip_list = Equip.objects.filter(equip_user=current_user)
        data = []
        for i in equip_list:
            if i.equip_type_id in data:
                continue
            data.append(i.equip_type_id)
        if current_user.is_superuser:
            data = []
            type_list = Equip_type.objects.all()
            for x in type_list:
                data.append(x.type_id)
        elif current_user.is_agency:
            data = []
            equip_list = Equip.objects.filter(equip_agency=current_user.user_agency)
            for i in equip_list:
                if i.equip_type_id in data:
                    continue
            data.append(i.equip_type_id)
        data = json.dumps(data)
        return HttpResponse(data)


# 监控设备查看图片
class app_jk_img(View):
    def post(self, request):
        imei = request.POST.get('equip_id')
        print("imei:", imei)
        # 获得当前页：
        page = int(request.POST.get('page'))
        print("page:", page)
        # 从数据库中取出照片在服务器存放路径：
        img = JKphoto.objects.filter(equip_id=imei)
        nums = img.count()
        img = img[(10*(page-1)):(page*10)]
        equip_name = Equip.objects.get(equip_id=imei).equip_name
        # 当前用户：返回用户，前端判断是否显示删除图片按钮
        current_user = request.session.get('username')
        print("current_user:", current_user)
        img_dat = [{"upl_time": x.upl_time,
                    "addr": x.addr}for x in img]
        dat = {'img':img_dat,
                'nums':nums,
                'equip_name':equip_name,
                'equip_id':imei
            }
        data = json.dumps(dat, cls=CJSONEncoder, indent=4)
        print("data:",data)
        return HttpResponse(data)