qxzSy/yfwlw/script_file/test.py

from qcloudsms_py import SmsSingleSender
from qcloudsms_py.httpclient import HTTPError
from qcloudsms_py import SmsMultiSender
import os
import django
import sys

BASE_DIR = os.path.dirname(os.path.abspath(__file__))  # 定位到你的django根目录
sys.path.append(os.path.abspath(os.path.join(BASE_DIR, os.pardir)))

os.environ.setdefault("DJANGO_SETTINGS_MODULE",
                      "yfwlw_pro.settings")  # project_name 项目名称
django.setup()
import json
import time
import requests
import datetime

from apps.ReportManage.all_dict import mobile_list, insect_dict_new, qxz_dict
from apps.AppInfoManage.models import Equip, Equip_type, CBDphoto, Msg_Send, Msg_Conf, Equip_SimInfo, SCDstatus, CBDstatus, RecentCBDdata, MyUser,JKphoto, BZYdata, QXZstatus,QXZdata,\
QXZstatus_New, QXZ_Conf, QXZ_Default_Conf, JKphoto, Alarm_record, SCDdata, SCDstatus_all, QXZdata_New, CBDphoto_desc,BZYphoto, JKdata, User_Log, CBDstatus_all,\
SCDstatus_all, YBQstatus, YBQphoto
from apps.SimInfo.views import get_siminfo
import paho.mqtt.client as mqtt

# 短信应用 SDK AppID
appid = 1400227496  # SDK AppID 以1400开头
# 短信应用 SDK AppKey
appkey = "c9aba961bd30072f1e1b9272077abaea"

from requests.auth import HTTPBasicAuth
from imutils import paths
import cv2
import shutil
import random
from django.db import transaction
# print(random.randint(10,30))
# 测试1
import xlrd
import xlwt
import socket
import re
import random
from PIL import Image
from io import BytesIO
from django.db.models import Q
from operator import itemgetter



def TimeStampToTime(timestamp):
    timeStruct = time.localtime(timestamp)
    str_p = time.strftime('%Y-%m-%d %H:%M:%S',timeStruct)
    dateTime_p = datetime.datetime.strptime(str_p,'%Y-%m-%d %H:%M:%S')
    return dateTime_p


def get_FileCreateTime(filePath):
    # filePath = unicode(filePath,'utf8')
    t = os.path.getmtime(filePath)
    return TimeStampToTime(t)

# aa = "/data/yfwlw/pyftp/ftp_file/ykm_cbd/868575028856005/20190317/03:22:36.jpg"
# print(get_FileCreateTime(aa))
imei = "868575028856005"
equip_obj = Equip.objects.get(equip_id=imei)
print(CBDphoto.objects.filter(equip_id=equip_obj).count())
for i in CBDphoto.objects.filter(equip_id=equip_obj):
    print(i.addr)
    if "pyftp" in i.addr:
        print("---------->>",i.addr)



# 9.24号查找出所有的害虫种类、和害虫数据
# data = []
# equip_list = Equip.objects.filter(equip_type="3")
# for x in equip_list:
#     data.append(x.equip_id)

# print(len(data))
# # print(data)


# pes_dp = [] # 害虫种类
# pests_num = [] # 害虫数量
# # data = ["868956044831316"]
# # sum = 0
# num = 0
# for i in data:
#     pest_photo = CBDphoto.objects.filter(equip_id=i)
#     if pest_photo:
#         pests = [] # 害虫种类
#         pests_num = [] # 害虫数量
#         sum = 0
#         num = 0
#         for y in pest_photo:
#             if y.indentify_result:
#                 if  y.indentify_result.find("#") != -1:
#                     xx_result =  y.indentify_result.split("#")
#                     for yy in xx_result:
#                         yy_result = yy.split(",")
#                         if yy_result[0] not in pests:
#                             pests.append(yy_result[0])
#                             sum = sum + int(yy_result[1])
#                 else:
#                     yy_result = y.indentify_result.split(",")
#                     if len(yy_result) >= 2:
#                         # print(yy_result[1])
#                         if yy_result[0] not in pests:
#                             pests.append(yy_result[0])
#                             num = num + int(yy_result[1])
#         sp = {"equip_id":y.equip_id,"spt":sum+num}
#         pes_dp.append(sp)
# nums = 0
# print(pes_dp[:5])
# for xx in pes_dp:
#     nums = nums + int(xx["spt"])
# print(nums)
# sum = 0
# cbd_photo = CBDphoto.objects.all()
# for yy in cbd_photo:
#     # 判断识别不未空的数据
#     if yy.indentify_result:
#         pest_photo = yy.indentify_result.split("#")
#         for xx in pest_photo:
#             xx_result = xx.split(',')
#             if xx_result[0] not in pests:
#                 pests.append(xx_result[0])
#             sum = sum + int(xx_result[1])

# st = {"equip_id":y,"dat":len(pests)}
# sp = {"equip_id":y,"spt":sum}
# pes_da.append(st)
# pes_dp.append(sp)
# rows = sorted(pes_da, key=itemgetter("dat"),reverse=True)[:20]
# num = sorted(pes_dp, key=itemgetter("spt"),reverse=True)[:20]
# print("害虫种类",rows)
# print("害虫数量",num)


# etype = "4.0测报灯"
# sta1 = CBDstatus.objects.filter(etype=etype)
# is_online = "0"
# sta3 = []
# # sta1 = sta1.filter(etype=etype)
# for i in sta1:
#     fir_v = eval(i.cbd_status)["dver"]
#     if i.is_online == is_online:
#         sta3.append({"equip_id":i.equip_id_id,"lng":i.lng,"lat":i.lat, "fir_v":fir_v,
#             "is_online":i.is_online,"off_time":i.off_time})
# print(sta3)
# data1 = []
# for x in sta3:
#     if x["lat"]:
#         res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(x["lat"],x["lng"]))
#     try:
#         print(eval(res.text))
#         print((eval(res.text))["result"]["addressComponent"]["province"])
#         # print((eval(res.text))["result"]["formatted_address"])
#     except:
#         continue
#     location = (eval(res.text))["result"]["addressComponent"]["province"] + (eval(res.text))["result"]["addressComponent"]["city"] + (eval(res.text))["result"]["addressComponent"]["district"]

#     data1.append({"equip_id":x["equip_id"],"fir_v":x["fir_v"],"location":location,"is_online":x["is_online"],"off_time":x["off_time"]})
# # print("=============>>",sta3)

# title = ["设备id","设备版本","设备位置","是否在线","离线时间"]
# book = xlwt.Workbook() # 创建一个excel对象
# sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页
# for i in range(len(title)): # 遍历列
#     # sheet.write(0,i,title[i],style) # 将title数组中的字段写入到0行i列中
#     sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中
# # print(sta2)
# for xx in range(len(data1)): #　遍历列表
#     if data1[xx]['is_online'] == "0":
#         is_online = "离线"
#         off_time = datetime.datetime.strftime(data1[xx]['off_time'],'%Y-%m-%d %H:%M:%S')
#     else:
#         is_online = "在线"
#         off_time = ""
#     sheet.write(xx+1,0,data1[xx]['equip_id']) #　将equip_id写入到第x+1行，第0列中
#     sheet.write(xx+1,1,data1[xx]['fir_v'])
#     sheet.write(xx+1,2,data1[xx]['location'])
#     sheet.write(xx+1,3,is_online)
#     sheet.write(xx+1,4,off_time)

    
# sheet.col(0).width = 256 * 18
# sheet.col(1).width = 256 * 11
# sheet.col(2).width = 256 * 24
# sheet.col(3).width = 256 * 8
# sheet.col(4).width = 256 * 11
# book.save("654321.xlsx")



# 9.21号
# 查找害虫种类最多

#1、查找区分设备是圆盘还是方形盘
# equip_list = Equip.objects.filter(equip_type__type_id="3")
# print(len(equip_list))
# data = [] # 海康圆盘
# date = [] # 方盘
# cbd_status = CBDstatus.objects.all()
# for x in cbd_status:
#     dver = eval(x.cbd_status)["dver"]

#     if dver.startswith("5") and dver.endswith("HK"):
#         data.append(x.equip_id)
#     else:
#         date.append(x.equip_id)
# #2、查看圆盘种类数量最多的设备
# #害虫种类
# da = [] 
# dp = []

# # data = ["868956044831316","862991419825259"]
# # 害虫数量
# pes_da = []
# pes_dp = []

# # pests = [] # 害虫种类
# # pests_num = [] # 害虫数量
# for y in date:
#     cbd_photo = CBDphoto.objects.filter(equip_id=y)
#     pests = [] # 害虫种类
#     pests_num = [] # 害虫数量
#     sum = 0
#     for yy in cbd_photo:
#         # 判断识别不未空的数据
#         if yy.indentify_result:
#             #判断识别结果包含多个的
#             # pest_dat = [] # 害虫种类
#             # pest_num = [] # 害虫数量\
#             # pests = [] # 害虫种类
#             # pests_num = [] # 害虫数量
#             pest_photo = yy.indentify_result.split("#")
#             for xx in pest_photo:
#                 xx_result = xx.split(',')
#                 if xx_result[0] not in pests:
#                     pests.append(xx_result[0])
#                 sum = sum + int(xx_result[1])
#     st = {"equip_id":y,"dat":len(pests)}
#     sp = {"equip_id":y,"spt":sum}
#     pes_da.append(st)
#     pes_dp.append(sp)
# rows = sorted(pes_da, key=itemgetter("dat"),reverse=True)[:20]
# num = sorted(pes_dp, key=itemgetter("spt"),reverse=True)[:20]
# print("害虫种类",rows)
# print("害虫数量",num)



#     #排序 害虫种类
#     rows = sorted(pests, key=itemgetter("dat"),reverse=True)
#     for x in rows:
#         if x["equip_id"] not in da:
#             da.append(x["equip_id"])
#             dp.append(x)
#     # print(pests_num)
#     #排序害虫数量
#     rowss = sorted(pests_num, key=itemgetter("sp"),reverse=True)
#     # print(rowss)
#     for x in rowss:
#         if x["equip_id"] not in pes_da:
#             pes_da.append(x["equip_id"])
#             pes_dp.append(x)
# num = sorted(dp, key=itemgetter("dat"),reverse=True)[:20]
# nums = sorted(pes_dp, key=itemgetter("sp"),reverse=True)[:20] 
# print("害虫种类",num)
# print("害虫数量",nums)

            # pests.append(st)
    # print(num)
    # pest.append(pests)
    # pests = []
    # else:
    #     print("11")
                    # pests.append(xx_result[0])
        # print(pests)
                    
        # pest.append(pests)
# print(pest)             





# cbd_photo = CBDphoto.objects.all()
# for i in cbd_photo:



# import oss2

# print(CBDphoto.objects.filter(addr__contains="cbd_img").count())
# print(datetime.datetime.now())


# 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)

# print(Equip.objects.values('equip_type_id').distinct())



# path = "/data/yfwlw/pyftp/ftp_file/bzy_photo"
# # path = "/home/web/yfwlw/pyftp/ftp_file/bzy_test"
# dirs = os.walk(path)
# for root,dir1,files in dirs:
#     # print("root",root)
#     # print("dir1",dir1)
#     # print("files",files)
#     if files != [] and "jpg" in files[0]:
#         for i in files:
#             imgaddr = root + "/" + i
#             print("------->>",imgaddr)
#             print(imgaddr.split('/')[6])

#9.11号测试sim入库剩余流量和已用流量保存两位小数
# iccid = "89860439101880591280"
# imei = "860344048805221"
# res = get_siminfo(iccid)
# sim_res = res.text.encode('utf-8').decode('unicode_escape')
# print(sim_res)
# data_usage = float('%.2f' % eval(sim_res)["data"]["data_usage"])
# data_balance =  float('%.2f' % eval(sim_res)["data"]["data_balance"])
# print(data_balance)
# print(data_usage)
# print(type(data_usage))



# # 9.10号分配邱玲195台设备

# username = MyUser.objects.get(username="南京睿泽生物技术有限公司")
# book=xlrd.open_workbook('邱玲.xlsx')

# sheet=book.sheet_by_name('Sheet1')
# lists = sheet.col_values(0)#获取到整列的内容
# datt = [] #已绑定用户
# dat = [] #未找到设备号
# for i in lists:
#     equip_list = Equip.objects.filter(equip_id=str(int(i)))
#     if equip_list:
#         for x in equip_list:
#             if x.equip_user:
#                 datt.append(x.equip_id)
#             else:
#                 x.equip_user = username
#                 x.save()
#     else:
#         dat.append(str(int(i)))
# print("设备已绑定用户=====",datt)
# print("未找到设备号=====",dat)


# auth = oss2.Auth('LTAI4G7tFh5Nk4KXZoSPk1D8', 'RV4S2SfbLPoFNjlI4uIOoA0J1LQPQc')
# # Endpoint以杭州为例，其它Region请按实际情况填写。
# # bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourBucketName>')
# # bucket = oss2.Bucket(auth, 'https://cbdphoto.oss-cn-hangzhou.aliyuncs.com', 'cbdphoto')
# bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', 'bzypic')


# def TimeStampToTime(timestamp):
#     timeStruct = time.localtime(timestamp)
#     str_p = time.strftime('%Y-%m-%d %H:%M:%S',timeStruct)
#     dateTime_p = datetime.datetime.strptime(str_p,'%Y-%m-%d %H:%M:%S')
#     return dateTime_p


# def get_FileCreateTime(filePath):
#     # filePath = unicode(filePath,'utf8')
#     t = os.path.getctime(filePath)
#     return TimeStampToTime(t)

# #8.31好删除害虫编号为36的识别结果

# imei = "866262040450529"
# equip_obj = Equip.objects.get(equip_id=imei)
# file_dir = "../pyftp/ftp_file/bzy_photo/%s"%imei
# for root, dirs, file in os.walk(file_dir):
#     if file != [] and "jpg" in file[0]:
#         # print("当前路径下所有非目录子文件>>",file)
#         for i in file:
#             pic_addr_1 = root + "/" + i
            
#             pic_addr = pic_addr_1.replace("../","")
#             picname_1 = get_FileCreateTime(pic_addr_1)
#             print("文件时间为",picname_1)
#             # now = datetime.datetime.now()
#             strnow = datetime.datetime.strftime(picname_1,'%Y%m')
#             picname = datetime.datetime.strftime(picname_1,'%Y%m%d%H%M%S')
#             # bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1)
#             print("图片数据库路径为pic_addr",pic_addr)
#             new_addr = "https://bzypic.oss-cn-hangzhou.aliyuncs.com/" + strnow + '/' + imei + '/'+ picname + '.jpg'
#             exist = bucket.object_exists(strnow + '/' + imei + '/'+ picname + '.jpg')
#             if BZYphoto.objects.filter(addr=pic_addr).exists():
#                 print("照片存在")
#                 print("新的照片路径为",new_addr)
#                 # 返回值为true表示文件存在，false表示文件不存在。
#                 if exist:
#                     if BZYphoto.objects.filter(addr=new_addr).exists():
#                         BZYphoto.objects.filter(addr=new_addr).update(equip_id=equip_obj,upl_time=picname_1)
#                     print('object exist')
#                     BZYphoto.objects.filter(addr=pic_addr).update(equip_id=equip_obj,addr=new_addr,upl_time=picname_1)
#                 else:
#                     BZYphoto.objects.filter(addr=pic_addr).update(equip_id=equip_obj,addr=new_addr,upl_time=picname_1)
#                     bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1)
#                     print("oss传输成功")
#                     print('object not exist')
#             else:
#                 print("照片不存在")
#                 # print("图片时间为",get_FileCreateTime(picname))
#                 if exist:
#                     if BZYphoto.objects.filter(addr=new_addr).exists():
#                         BZYphoto.objects.filter(addr=new_addr).update(equip_id=equip_obj,upl_time=_time)
#                     else:
#                         print('object exist')
#                         BZYphoto.objects.create(equip_id=imei,addr=new_addr,upl_time=picname_1)
#                 else:
#                     if BZYphoto.objects.filter(addr=new_addr).exists():
#                         print("新照片链接存在更新时间")
#                         BZYphoto.objects.filter(addr=new_addr).update(equip_id=equip_obj,upl_time=picname_1)
#                     else:
#                         print("新照片链接不存在新建")
#                         print('object exist')
#                         BZYphoto.objects.create(equip_id=imei,addr=new_addr,upl_time=picname_1)
#                     # BZYphoto.objects.create(equip_id=imei,addr=new_addr,upl_time=picname)
#                     bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1)
#                     print("oss传输成功")
#                     print('object not exist')


# equip = "867814040037125"
# equip_list = CBDphoto.objects.filter(equip_id=equip)
# # equip_lists = CBDphoto.objects.filter(~Q(indentify_result=None) and ~Q(indentify_result=),equip_id=equip)
# data = []
# date = []
# da = []
# d = []
# print("总数",equip_list.count())
# # print(len(equip_lists))
# for i in equip_list:
#     if i.indentify_result:
#         if i.indentify_result.find("#") >=0:
#             pest = i.indentify_result.split("#")
#         else:
#             pest = []
#             pest.append(i.indentify_result)
#         print("删除前",pest)
#         for x in pest:
#             if x.find("36") >=0:
#                 pest.remove(x)
#             else:
#                 print("88")
#         # pest.append("89")
#         # print("#".join(pest))
#         print("删除后",pest)
#         i.indentify_result = "#".join(pest)
#         i.save()
    #     da.append(i.indentify_result)
    #     if i.indentify_result.find("#") >=0:
    #         pest = i.indentify_result.split("#")
    #     else:
    #         pest = []
    #         pest.append(i.indentify_result)
    #     # print("删除前",pest)
    #     for x in pest:
    #         if x.find("36") >=0:
    #             # pest.remove(x)
    #             date.append(x)
    #         else:
    #             data.append(x)
    # else:
    #     d.append(i.indentify_result)
# print("不为空的总数",len(da))
# print("包含36",len(date))
# print("不包含36",len(data))
# print("空总数",len(d))



        # if i.indentify_result.find("#") >=0:
        #     pest = i.indentify_result.split("#")
        # else:
        #     pest = []
        #     pest.append(i.indentify_result)
        # print("删除前",pest)
        # for x in pest:
        #     if x.find("36") >=0:
        #         pest.remove(x)
        #     else:
        #         print("88")
        # # pest.append("89")
        # # print("#".join(pest))
        # print("删除后",pest)
        # i.indentify_result = "#".join(pest)
        # i.save()
        
# print(len(data))

# #8.12号生成测报灯识别图片

# equip_list = [
#     "868956044806713",
#     "868956044823551",
# ]

# url = 'http://60.166.14.184:9143/upload'
# for i in equip_list:
#     cbd_list = CBDphoto.objects.filter(equip_id=i)
#     lng = CBDstatus.objects.get(equip_id=i).lng
#     lat = CBDstatus.objects.get(equip_id=i).lat
#     for x in cbd_list:
#         print("原图",x.addr)
#         print("识别后的图片",x.indentify_photo)
#         if x.indentify_photo:
#             tes = x.indentify_photo.split("/")
#             try:
#                 # print("/home/web/yfwlw/" + x.addr)
#                 print("/data/yfwlw/" + x.addr)
#                 # 测试服务器路径
#                 # imageFile = {'imageFile':('pic.jpg',open("/home/web/yfwlw/" + x.addr,'rb'),'image/jpeg')}
#                 imageFile = {'imageFile':('pic.jpg',open("/data/yfwlw/" + x.addr,'rb'),'image/jpeg')}
#                 data = {'longitude':lng,'latitude':lat}
#                 print('data:',data)
#                 res = requests.post(url,data=data,files=imageFile,timeout=10)
#                 print("res:",res.text)
#                 resp = json.loads(res.text)
#                 print("resp------------",resp)
#                 img_src = resp["returnResult"]["returnImageUrl"]
#                 response = requests.get(img_src)
#                 print("img_src-------------",img_src)
#                 print(response)
#                 code = 1
#             except Exception as e:
#                 print(e)
#                 code = 0
#             if code == 1:
#                 try:
#                     if resp["returnResult"]["returnStatus"] == "0":
#                         print("识别结果为空，不进行保存")
#                     else:
#                         # 将识别结果中的链接中的图片存入本地    测试服务器
#                         # pic_dir_1 = "/home/web/yfwlw/result_pyftp/ftp_file/ykm_cbd/" + i  + "/"
#                         #正式服务器
#                         pic_dir_1 = "/data/yfwlw/result_pyftp/ftp_file/ykm_cbd/" + i  + "/"
#                         print("pic_dir_1:",pic_dir_1)
#                         if os.path.exists(pic_dir_1) == False:
#                             os.makedirs(pic_dir_1)
#                         response = requests.get(img_src)
#                         image = Image.open(BytesIO(response.content))
#                         insect_image_addr = pic_dir_1 + tes[-1]
#                         print("insect_image_addr:",insect_image_addr)
#                         image.save(insect_image_addr)
#                         print("------------------图片保存成功")
#                 except Exception as e:
#                     print(e)





# equip_obj = Equip.objects.get(equip_id="867814040037125")
# cbd_photo_list = CBDphoto.objects.filter(equip_id="869300039253749")
# for i in cbd_photo_list:
#     addr = i.addr.replace("869300039253749","867814040037125")
#     i.equip_id = equip_obj
#     i.addr = addr
#     i.save()





# _list = YBQstatus.objects.all()
# for i in _list:
#     # print(eval(i.ybq_status)['iccid'])
#     iccid = eval(i.ybq_status)['iccid']
#     if len(iccid) == 20:
#         print(iccid)


# sta1 = RecentCBDdata.objects.all().values()
# for x in sta1:
#     print("lng",eval(x['cbd_data'])['lng'])
#     print("lat",eval(x['cbd_data'])['lat'])
    # 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']
    #             })



# dver = "5.9.9-03(1)HK"

# _list = "5.9.9-03HK"

# a = re.sub('\\(.*?\\)','',_list)

# print(a)

#7.3号 分配账号脚本


#     equip_list = Equip.objects.filter(equip_id=i)
#     if equip_list:
#         for x in equip_list:
#             if x.equip_user:
#                 datt.append(x.equip_id)
#             else:
#                 x.equip_user = username
#                 x.save()
#     else:
#         dat.append(i)
# print("设备已绑定用户=====",datt)
# print("未找到设备号=====",dat)



# start_time = '2020-01-01'
# end_time = '2020-05-30'
# start_time = datetime.datetime.strptime(start_time,'%Y-%m-%d')
# end_time = datetime.datetime.strptime(end_time,'%Y-%m-%d')
# print(start_time)
# _list = []
# equip_list = Equip.objects.filter(equip_type=3,equip_add_time__range=(start_time,end_time))
# for i in equip_list:
#     if CBDphoto.objects.filter(equip_id=i,upl_time__range=(start_time,end_time)).exists():
#         print("有照片")
#         _list.append(i.equip_id)
#     print("====>>",i.equip_id)
# print(_list)

# start_time = '2020-04-20'
# end_time = '2020-05-30'
# start_time = datetime.datetime.strptime(start_time,'%Y-%m-%d')
# end_time = datetime.datetime.strptime(end_time,'%Y-%m-%d')


# Equip.objects.get(equip_id=866714042686849).delete()
# print("操作成功")


# 物联网自动虫情信息采集设备（4.0）  对应的版本是5版本带HK的,如5.9.9HK
# 物联网自动虫情信息采集设备（3.0）  对应的版本是4版本带re,hk的,如4.2.37re,4.1HK
# 物联网自动虫情信息采集设备（2.0）  对应版本是1,2,3版本，如1.0.0;2.2.14;3.2.0
# 自动虫情测报灯（1.0）             对应有4版本,5版本带ZP
# 高空测报灯（1.0）                 对应4版本带GK,5版本的高空和转盘使用同一版本号，无法区分.
# 糖醋测报                          对应1版本带TC，
# 简易高空                          对应5版本带gk（区分大小写）
# 定制版本                          其他版本
# _list = CBDstatus.objects.all()
# for i in _list:
#     print("equip_id",i.equip_id)
#     try:
#         cbddataobj = RecentCBDdata.objects.get(equip_id=i.equip_id)
#     except:
#         continue
#     # print(eval(i.cbd_status)['dver'])
#     dver = eval(i.cbd_status)['dver']
#     if dver.startswith("5") and dver.endswith("HK"):
#         i.etype = "4.0测报灯"
#         i.save()
#         cbddataobj.etype = "4.0测报灯"
#         cbddataobj.save()
#         print("4.0测报灯",dver)
#     elif dver.startswith("4") and dver.endswith("HK"):
#         i.etype = "3.0测报灯"
#         i.save()
#         cbddataobj.etype = "3.0测报灯"
#         cbddataobj.save()
#         print("3.0测报灯",dver)
#     elif dver.startswith("4") and dver.endswith("re"):
#         i.etype = "3.0测报灯"
#         i.save()
#         cbddataobj.etype = "3.0测报灯"
#         cbddataobj.save()
#         print("3.0测报灯",dver)
#     elif dver.startswith("1") or dver.startswith("2") or dver.startswith("3"):
#         i.etype = "2.0测报灯"
#         i.save()
#         cbddataobj.etype = "2.0测报灯"
#         cbddataobj.save()
#         print("2.0测报灯",dver)
#     elif dver.endswith("ZP"):
#         i.etype = "1.0测报灯"
#         i.save()
#         cbddataobj.etype = "1.0测报灯"
#         cbddataobj.save()
#         print("1.0测报灯",dver)
#     elif dver.startswith("4") and dver.endswith("GK"):
#         i.etype = "高空测报灯"
#         i.save()
#         cbddataobj.etype = "高空测报灯"
#         cbddataobj.save()
#         print("高空测报灯",dver)
#     elif dver.endswith("TC"):
#         i.etype = "糖醋测报灯"
#         i.save()
#         cbddataobj.etype = "糖醋测报灯"
#         cbddataobj.save()
#         print("糖醋测报灯",dver)
#     elif dver.startswith("5") and dver.endswith("gk"):
#         i.etype = "简易高空测报灯"
#         i.save()
#         cbddataobj.etype = "简易高空测报灯"
#         cbddataobj.save()
#         print("简易高空测报灯",dver)
        
        
        
# def on_connect(client, userdata, flags, rc):
#     print("Connected with result code "+str(rc))
#     client.subscribe("api/v1/iot/dragon/868956044807455")         # 订阅消息


# def on_message(client, userdata, msg):
#     print("主题:"+msg.topic+" 消息:"+str(msg.payload.decode('utf-8')))


# def on_subscribe(client, userdata, mid, granted_qos):
#     print("On Subscribed: qos = %d" % granted_qos)


# def on_disconnect(client, userdata, rc):
#     if rc != 0:
#         print("Unexpected disconnection %s" % rc)

# for i in YBQphoto.objects.all():
#     i.real_time = i.upl_time
#     i.save()
# print("---处理完毕")


# # HOST = "aftrnmynhcbc5elv-master-nlb-FI.jvessel-open-hb.jdcloud.com"
# # HOST = "120.27.222.26"
# HOST = "39.104.94.153"
# PORT = 1883
# # client_id = "1083421xxxxx"                       # 没有就不写，此处部分内容用xxx代替原内容，下同
# client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
# imei = "868956044830994"
# data = {
#     "devId": imei,
#     "ossPath": "http://120.27.222.26/" + "pyftp/ftp_file/ykm_cbd/868956044830994/192.168.1.100_01_20200601022407693_ALARM_INPUT.jpg",
#     "collectDT": time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())),
#     "manuCode": "10014",
#     "result": "",
#     "resultImage": ""
#     }



# TASK_TOPIC = "api/v1/iot/dragon/" + imei + "/telemetry"  # 客户端发布消息主题
# """
# 客户端发布消息
# :param message: 消息主体
# :return:
# """
# payload = data
# # publish(主题：Topic; 消息内容)
# client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
# client = mqtt.Client(client_id, transport='tcp')
# client.username_pw_set(imei, imei)
# client.connect("aftrnmynhcbc5elv-master-nlb-FI.jvessel-open-hb.jdcloud.com", 1883, 60)  # 此处端口默认为1883，通信端口期keepalive默认60
# # client.connect("120.27.222.26", 1883, 60)  # 此处端口默认为1883，通信端口期keepalive默认60
# bb = client.loop_start()
# aa = client.publish(TASK_TOPIC, json.dumps(payload, ensure_ascii=False),qos=0)
# print("aa",aa)
# print("bb",bb)
# print("京东信息发送成功",data)
# print(datetime.datetime.now())



# data = {
# 	"devId": "868956044807455",
# 	"ossPath": "http:\/\/120.27.222.26\/pyftp\/ftp_file\/ykm_cbd\/868956044807455\/192.168.1.100_01_20200612104405264_ALARM_INPUT.jpg",
# 	"collectDT": "2020-06-12 10:43:05",
# 	"manuCode": "10014",
# 	"result": "",
# 	"resultImage": ""
#     }

# param = json.dumps(data)
# client = mqtt.Client(client_id)
# client.username_pw_set("868956044807455", "")
# client.on_connect = on_connect
# client.on_message = on_message
# client.on_subscribe = on_subscribe
# client.on_disconnect = on_disconnect
# aa = client.connect(HOST, PORT, 60)
# print("---------->>",aa)
# client.publish("api/v1/iot/dragon/868956044807455", payload=param, qos=0)     # 发送消息
# client.loop_start()
# print("执行完毕")






# data = {
# 	"devId": "868956044807455",
# 	"ossPath": "http:\/\/120.27.222.26\/pyftp\/ftp_file\/ykm_cbd\/868956044807455\/192.168.1.100_01_20200612104405263_ALARM_INPUT.jpg",
# 	"collectDT": "2020-06-12 10:43:05",
# 	"manuCode": "10014",
# 	"result": "",
# 	"resultImage": ""
#     }
# TASK_TOPIC = 'api/v1/iot/dragon/868956044807455'  # 客户端发布消息主题
# """
# 客户端发布消息
# :param message: 消息主体
# :return:
# """
# payload = data
# # publish(主题：Topic; 消息内容)
# client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
# client = mqtt.Client(client_id, transport='tcp')
# client.username_pw_set("868956044807455", "868956044807455")
# # client.connect("aftrnmynhcbc5elv-master-nlb-FI.jvessel-open-hb.jdcloud.com", 1883, 60)  # 此处端口默认为1883，通信端口期keepalive默认60
# client.connect("120.27.222.26", 1883, 60)  # 此处端口默认为1883，通信端口期keepalive默认60
# aa = client.publish(TASK_TOPIC, json.dumps(payload, ensure_ascii=False, qos=0))
# bb = client.loop_start()
# print(bb)
# print(aa)
# print("京东信息发送成功",data)
# print(datetime.datetime.now())


# data = []
# data1 = []
# simlist = Equip_SimInfo.objects.filter(data_plan="10",account_status="3")
# for i in simlist:
#     print("------->>",i.iccid)
#     data1.append({"equip_id":i.equip_id_id,"equip_type":i.equip_type,"iccid":i.iccid,"data_usage":i.data_usage,"data_balance":i.data_balance})

# title = ["设备id","设备类型","iccid","已用","剩余"]
# book = xlwt.Workbook() # 创建一个excel对象
# sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页
# for i in range(len(title)): # 遍历列
#     # sheet.write(0,i,title[i],style) # 将title数组中的字段写入到0行i列中
#     sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中
# # print(sta2)
# for xx in range(len(data1)): #　遍历列表
#     if data1[xx]['equip_type'] == "3":
#         _type = "测报灯"
#         # off_time = datetime.datetime.strftime(data1[xx]['off_time'],'%Y-%m-%d')
#     else:
#         _type = "杀虫灯"
#         # off_time = ""
#     # creat_time = datetime.datetime.strftime(data1[xx]['creat_time'],'%Y-%m-%d')
#     sheet.write(xx+1,0,data1[xx]['equip_id']) #　将equip_id写入到第x+1行，第0列中
#     sheet.write(xx+1,1,_type)
#     sheet.write(xx+1,2,data1[xx]['iccid'])
#     sheet.write(xx+1,3,data1[xx]['data_usage'])
#     sheet.write(xx+1,4,data1[xx]['data_balance'])
# book.save("654321.xlsx")


# one_month = datetime.timedelta(days=30)
# nowtime = datetime.datetime.now()

# end_time = nowtime
# start_time = nowtime - one_month

# print(start_time)

# aabbcc = Alarm_record.objects.all().exclude(alarm_time__range=(start_time,end_time)).delete()
# for i in aabbcc:
#     i.delete()
#     print(i.alarm_time)

# print(CBDstatus.objects.get(equip_id_id="865650044552954").rtuinfo)


# def mkdir(path):
    
#     # 去除首位空格
#     path=path.strip()
#     # 去除尾部 \ 符号
#     path=path.rstrip("\\")
 
#     # 判断路径是否存在
#     # 存在     True
#     # 不存在   False
#     isExists=os.path.exists(path)
 
#     # 判断结果
#     if not isExists:
# 		# 如果不存在则创建目录
# 		# 创建目录操作函数
#         os.makedirs(path) 
#         print(path+' 创建成功')
#         return True
#     else:
#         # 如果目录存在则不创建，并提示目录已存在
#         print(path+' 目录已存在')
#         return False


# def variance_of_laplacian(image):
#     # 拉普拉斯的方差
# 	return cv2.Laplacian(image, cv2.CV_64F).var()



# imei = "865650043208251"
# print('=================================================')
# print("<-----imei:\n" + imei + ';\n')
# print("Message:\n" + "http:bzyphoto" + "----->\n")
# print("%s"%datetime.datetime.now())
# print('=================================================')

# pic_name = datetime.datetime.now().strftime('%Y%m')
# try:
#     pic_name = datetime.datetime.now().strftime('%Y%m')
#     args = "pyftp/ftp_file/bzy_test/" + imei
#     cv_num_list = []
#     file_list1 = list(paths.list_images(args))
#     print("\n===========================")
#     print("file_list1:",file_list1)
#     print("type file_list1:",type(file_list1))
#     cv_num_list1 = []
#     for imagePath1 in file_list1[::]:
#         # fm = get_value(imagePath)
#         # 孢子仪图片过小删除
#         if os.path.getsize(imagePath1) <= 10:
#             file_list1.remove(imagePath1)
#         img1 = cv2.imread(imagePath1)
#         img1 = cv2.resize(img1, (800, 600))
#         gray = cv2.cvtColor(img1, cv2.COLOR_BGR2GRAY)
#         # 创建SIFT对象
#         sift = cv2.xfeatures2d.SIFT_create()
#         keypoints, descriptor = sift.detectAndCompute(gray, None)
#         img1 = cv2.drawKeypoints(image=img1, outImage=img1, keypoints=keypoints,flags=cv2.DRAW_MATCHES_FLAGS_DEFAULT, color=(0, 0, 255))
#         fm1 = len(keypoints)
#         cv_num_list1.append(fm1)
#         # 打印清晰度值：
#         print("fm1",fm1)
#         # 打印文件路径
#         print("imagePath1",imagePath1)
#     file_cv_tuple1 = tuple(zip(cv_num_list1,file_list1))
#     print("file_cv_tuple1:\n",file_cv_tuple1)
#     print("=========================================/n")
#     file_cv_tuple_list1 = list(file_cv_tuple1)
#     print("file_cv_tuple_list1:\n",file_cv_tuple_list1)
#     print("*****************************************/n")
#     # 按照清晰度排序：, reverse=True降序
#     result1 = sorted(file_cv_tuple_list1, key=lambda s: s[0],reverse=True)
#     print("result1:\n",result1)

#     # 切片取清晰度最高的前五张图片：
#     result1_5 = result1[0:3]
#     # result5 = result[0:1]
#     print("result1_5:\n",result1_5)


#     pic_name = datetime.datetime.now().strftime('%Y%m')
#     # 定义要创建的目录：
#     mkpath="./pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name
#     # 调用函数,创建目录：
#     mkdir(mkpath)
#     for i in result1_5:
#     # for i in result5:
#         #i值：(137.06453470539032, 'images\\192.168.2.64_01_20190802095315882_ALARM_INPUT.jpg')
#         print("file path:",i[1])
#         #复制文件：
#         shutil.copy(i[1],mkpath)
#     # os.system("rm ./pyftp/ftp_file/bzy_test/%s/*.jpg -rf"%imei)
#     os.system("mv ./pyftp/ftp_file/bzy_test/%s ./pyftp/ftp_file/bzy_test/%s_%s"%(imei,imei,datetime.datetime.now().strftime("%Y%m%d%H%M%S")))
#     print("-----------------image move success----------------------")

#     equip = Equip.objects.get(equip_id=imei)
#     file_dir="pyftp/ftp_file/bzy_photo/" + imei + "/" + pic_name

#     for root, dirs, files in os.walk(file_dir):
#         print("当前目录为=========>>",root) #当前目录路径
#         print("当前子目录为=========>>",dirs) #当前路径下所有子目录
#         print("当前目录文件为=========>>",files) #当前路径下所有非目录子文件
#         for i in files:
#             photo_addr = file_dir + "/" + i
#             print("文件夹图片路径===========》》",photo_addr)
#             if BZYphoto.objects.filter(addr=photo_addr).exists():
#                 print("照片存在")
#             else:
#                 BZYphoto.objects.create(equip_id=equip, addr=photo_addr)
#                 print("照片不存在")
# except Exception as a:
#     print('=================================================')
#     print("<-----imei:\n" + imei + ';\n')
#     print("Message:\n" + "http:bzyphoto" + "----->\n")
#     print("%s"%datetime.datetime.now())
#     print("==========%s========"%a)
#     print("-----------------image move default----------------------")




# lat = "37.56"
# lng = "115.28"


# data = []
# data1 = []
# # res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(lat,lng))
# # location = (eval(res.text))["result"]["addressComponent"]["province"]+eval(res.text)["result"]["addressComponent"]["district"]
# # print(location)
# # 大新县农业农村局
# # user_obj = MyUser.objects.get(username="大新县农业农村局")
# for i in CBDstatus.objects.all().values():
#     try:
#         lng = i["lng"]
#         lat = i["lat"]
#     except:
#         lng = ""
#         lat = ""
#     print("设备版本号",eval(i["cbd_status"])["dver"].split(".")[0])
#     print("照片是否存在",CBDphoto.objects.filter(equip_id=i["equip_id_id"]).exists())
#     if eval(i["cbd_status"])["dver"].split(".")[0] == "5" and CBDphoto.objects.filter(equip_id=i["equip_id_id"]).exists():
#         data.append({"equip_id":i["equip_id_id"],"lng":lng,"lat":lat,"is_online":i["is_online"],"off_time":i["off_time"],"creat_time":Equip.objects.get(equip_id=i["equip_id_id"]).equip_add_time})
# # print(data)
# for x in data:
#     if x["lat"]:
#         res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(x["lat"],x["lng"]))
#         try:
#             print(eval(res.text))
#             print((eval(res.text))["result"]["addressComponent"]["province"])
#             # print((eval(res.text))["result"]["formatted_address"])
#         except:
#             continue
#         # if (eval(res.text))["result"]["addressComponent"]["province"] == "河南省":
#         location = (eval(res.text))["result"]["addressComponent"]["province"] + (eval(res.text))["result"]["addressComponent"]["city"] + (eval(res.text))["result"]["addressComponent"]["district"]
#         # location = (eval(res.text))["result"]["formatted_address"]
#         data1.append({"equip_id":x["equip_id"],"location":location,"is_online":x["is_online"],"off_time":x["off_time"],"creat_time":x["creat_time"]})
# # print(data1)


# title = ["设备id","设备位置","是否在线","离线时间","设备创建时间"]
# book = xlwt.Workbook() # 创建一个excel对象
# sheet = book.add_sheet('Sheet1',cell_overwrite_ok=True) # 添加一个sheet页
# for i in range(len(title)): # 遍历列
#     # sheet.write(0,i,title[i],style) # 将title数组中的字段写入到0行i列中
#     sheet.write(0,i,title[i]) # 将title数组中的字段写入到0行i列中
# # print(sta2)
# for xx in range(len(data1)): #　遍历列表
#     if data1[xx]['is_online'] == "0":
#         is_online = "离线"
#         off_time = datetime.datetime.strftime(data1[xx]['off_time'],'%Y-%m-%d')
#     else:
#         is_online = "在线"
#         off_time = ""
#     creat_time = datetime.datetime.strftime(data1[xx]['creat_time'],'%Y-%m-%d')
#     sheet.write(xx+1,0,data1[xx]['equip_id']) #　将equip_id写入到第x+1行，第0列中
#     sheet.write(xx+1,1,data1[xx]['location'])
#     sheet.write(xx+1,2,is_online)
#     sheet.write(xx+1,3,off_time)
#     sheet.write(xx+1,4,creat_time)
# book.save("654321.xlsx")



# sta = [{'equip_id': '865650043164355', 'location': '河北省易县'}, {'equip_id': '865650042837811', 'location': '河北省桥西区'}, {'equip_id': '860344048820691', 'location': '河北省武强县'}, {'equip_id': '865650041090206', 'location': '河北省武强县'}, {'equip_id': '865650041021268', 'location': '河北省武强县'}, {'equip_id': '868575028847277', 'location': '河北省赤城县'}, {'equip_id': '865650041020971', 'location': '河北省深州市'}, {'equip_id': '865650041089497', 'location': '河北省迁安市'}, {'equip_id': '868575028850214', 'location': '河北省涉县'}, {'equip_id': '860344048805221', 'location': '河北省易县'}, {'equip_id': '868575028846592', 'location': '河北省围场满族蒙古族自治县'}, {'equip_id': '868575028857953', 'location': '河北省曲周县'}, {'equip_id': '868575028850917', 'location': '河北省围场满族蒙古族自治县'}, {'equip_id': '868575028847798', 'location': '河北省曹妃甸区'}, {'equip_id': '869300039255967', 'location': '河北省晋州市'}, {'equip_id': '868575028855387', 'location': '河北省曹妃甸区'}, {'equip_id': '868575028869040', 'location': '河北省平泉县'}, {'equip_id': '868575028850925', 'location': '河北省隆尧县'}, {'equip_id': '868575028868927', 'location': '河北省隆尧县'}, {'equip_id': '868575028855148', 'location': '河北省玉田县'}, {'equip_id': '868575028845875', 'location': '河北省辛集市'}, {'equip_id': '868575028850479', 'location': '河北省赵县'}, {'equip_id': '868575028846048', 'location': '河北省围场满族蒙古族自治县'}, {'equip_id': '868575028847640', 'location': '河北省曲周县'}, {'equip_id': '868575028846089', 'location': '河北省香河县'}, {'equip_id': '868575028858035', 'location': '河北省围场满族蒙古族自治县'}, {'equip_id': '868575028857656', 'location': '河北省阜城县'}, {'equip_id': '868575028810101', 'location': '河北省永清县'}, {'equip_id': '868575028868463', 'location': '河北省赤城县'}, {'equip_id': '869300039256064', 'location': '河北省玉田县'}, {'equip_id': '869300039255900', 'location': '河北省迁西县'}, {'equip_id': '868575028857318', 'location': '河北省辛集市'}, {'equip_id': '868575028850727', 'location': '河北省承德县'}]
# print(len(sta))

# imei = "D75675201"
# file_dir = "../pyftp/ftp_file/jk_photo1/%s"%imei
# print("file_dir",file_dir)
# for root, dirs, files in os.walk(file_dir):
#     for i in files:
#         file = root + "/" + i
#         # st = root.split("/")[-1] + i.split(".")[0]
#         file = file[3:]
#         st = i.split(".")[3].split("_")[2][0:14]
#         print("st",st)
#         print("file====>>",file)
#         try:
#             pic_time = datetime.datetime.strptime(st,"%Y%m%d%H%M%S")
#         except Exception as eeex:
#             print("错误信息为",eeex)
#             continue
#         if JKphoto.objects.filter(addr=file).exists():
#             photoobj = JKphoto.objects.get(addr=file)
#             photoobj.upl_time = pic_time
#             photoobj.save()
#             print("照片存在")
#         else:
#             print("照片不存在")
#             try:
#                 imei_obj = Equip.objects.get(equip_id=imei)
#                 JKphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time)
#             except Exception as e:
#                 print("错误信息为",e)




# equip_obj = Equip.objects.get(equip_id=160648091112227)
# equip_obj2 = QXZstatus_New.objects.get(equip_id=16064809)
# conf_obj = QXZ_Conf.objects.get(equip_id=16064809)
# conf_obj2 = QXZ_Default_Conf.objects.get(equip_id=16064809)
# aa = QXZstatus_New.objects.create(equip_id=equip_obj,e1=equip_obj2.e1,e2=equip_obj2.e2,e3=equip_obj2.e3,e4=equip_obj2.e4,e5=equip_obj2.e5,e6=equip_obj2.e6,e7=equip_obj2.e7,e8=equip_obj2.e8,e9=equip_obj2.e9,e10=equip_obj2.e10,e11=equip_obj2.e11,e12=equip_obj2.e12,e13=equip_obj2.e13,e14=equip_obj2.e14,e15=equip_obj2.e15,e16=equip_obj2.e16)
# bb = QXZdata_New.objects.create(equip_id=equip_obj,e1=equip_obj2.e1,e2=equip_obj2.e2,e3=equip_obj2.e3,e4=equip_obj2.e4,e5=equip_obj2.e5,e6=equip_obj2.e6,e7=equip_obj2.e7,e8=equip_obj2.e8,e9=equip_obj2.e9,e10=equip_obj2.e10,e11=equip_obj2.e11,e12=equip_obj2.e12,e13=equip_obj2.e13,e14=equip_obj2.e14,e15=equip_obj2.e15,e16=equip_obj2.e16)
# cc = QXZ_Conf.objects.create(equip_id=equip_obj,e1=conf_obj.e1,e2=conf_obj.e2,e3=conf_obj.e3,e4=conf_obj.e4,e5=conf_obj.e5,e6=conf_obj.e6,e7=conf_obj.e7,e8=conf_obj.e8,e9=conf_obj.e9,e10=conf_obj.e10,e11=conf_obj.e11,e12=conf_obj.e12,e13=conf_obj.e13,e14=conf_obj.e14,e15=conf_obj.e15,e16=conf_obj.e16)
# dd = QXZ_Default_Conf.objects.create(equip_id=equip_obj,e1=conf_obj2.e1,e2=conf_obj2.e2,e3=conf_obj2.e3,e4=conf_obj2.e4,e5=conf_obj2.e5,e6=conf_obj2.e6,e7=conf_obj2.e7,e8=conf_obj2.e8,e9=conf_obj2.e9,e10=conf_obj2.e10,e11=conf_obj2.e11,e12=conf_obj2.e12,e13=conf_obj2.e13,e14=conf_obj2.e14,e15=conf_obj2.e15,e16=conf_obj2.e16)
# print("操作完毕")




# print(QXZstatus_New.objects.get(equip_id_id=16064808).upl_time)
# workbook = xlrd.open_workbook('物联网杀虫灯发货统计(2).xlsx')
# print(workbook.sheet_names())
# sheet11 = workbook.sheet_by_name('11 月发货统计')
# nro = sheet11.nrows
# print(nro)
# list_e = []
# user_obj = MyUser.objects.get(username="大新县农业农村局")
# cell_a = sheet11.cell(0,2).value    # 括号内第一位数字为行，第二位为列
# for i in range(146):
#     cell_a = sheet11.cell(i,2).value
#     # print(cell_a)
#     try:
#         equip_obj = Equip.objects.get(equip_id=cell_a)
#         equip_obj.equip_user = user_obj
#         equip_obj.save()
#         print("分配成功")
#     except:
#         print("设备不存在")
#         print(cell_a)
#         list_e.append(cell_a)
# print(list_e)


# list_e = []
# for i in CBDstatus.objects.all():
#     is_hk = eval(i.cbd_status)["dver"]
#     # print(is_hk)
#     if "HK" in is_hk:
#         print(is_hk)
#         list_e.append(i)
#     # else:
#     #     print("不是hk")
# # print(list_e)
# list_n = []
# for x in list_e:
#     # print(x.simid)
#     if x.simid:
#         print("===>>",x.equip_id_id)
#         equip_obj2 = RecentCBDdata.objects.get(equip_id_id=x.equip_id_id)
#         equip_obj = CBDstatus.objects.filter(equip_id_id=x.equip_id_id).update(upl_time=equip_obj2.upl_time)
#         print("操作成功")
#     else:
#         # print("为空的设备",x.equip_id_id)
#         # list_n.append(x.equip_id_id)
#         # x.simid = '12345678901234567890'
#         # x.save()
#         equip_obj2 = RecentCBDdata.objects.get(equip_id_id=x.equip_id_id)
#         equip_obj = CBDstatus.objects.filter(equip_id_id=x.equip_id_id).update(upl_time=equip_obj2.upl_time)
#         print("操作成功")
# print(list_n)
#     equip_obj2 = RecentCBDdata.objects.get(equip_id_id=i)
#     equip_obj = CBDstatus.objects.filter(equip_id_id=i).update(upl_time=equip_obj2.upl_time)

# e1 = ''
# e2 = ''
# e3 = ''
# e4 = ''
# e5 = ''
# e6 = ''
# e7 = ''
# e8 = ''
# e9 = ''
# e10 = ''
# e11 = ''
# e12 = ''
# e13 = ''
# e14 = ''
# e15 = ''
# e16 = ''
# e17 = ''
# e18 = ''
# e19 = ''
# e20 = ''
# e21 = ''
# e22 = ''
# e23 = ''
# e24 = ''
# e25 = ''
# e26 = ''
# e27 = ''
# e28 = ''
# e29 = ''
# e30 = ''


# conf1 = ''
# conf2 = ''
# conf3 = ''
# conf4 = ''
# conf5 = ''
# conf6 = ''
# conf7 = ''
# conf8 = ''
# conf9 = ''
# conf10 = ''
# conf11 = ''
# conf12 = ''
# conf13 = ''
# conf14 = ''
# conf15 = ''
# conf16 = ''
# conf17 = ''
# conf18 = ''
# conf19 = ''
# conf20 = ''
# conf21 = ''
# conf22 = ''
# conf23 = ''
# conf24 = ''
# conf25 = ''
# conf26 = ''
# conf27 = ''
# conf28 = ''
# conf29 = ''
# conf30 = ''
# for x in QXZstatus.objects.all():
#     e_id = x.equip_id_id
#     upl_time = QXZstatus.objects.get(equip_id=e_id).upl_time
#     qxz_picture = QXZstatus.objects.get(equip_id=e_id).qxz_picture
#     qxzstatus = eval(QXZstatus.objects.get(equip_id=e_id).qxz_status)['data']
#     for i in qxzstatus:
#         if i['eKey'] == 'e1':
#             e1 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf1 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e2':
#             e2 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf2 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e3':
#             e3 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf3 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e4':
#             e4 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf4 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e5':
#             e5 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf5 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e6':
#             e6 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf6 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e7':
#             e7 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf7 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e8':
#             e8 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf8 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e9':
#             e9 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf9 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e10':
#             e10 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf10 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e11':
#             e11 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf11 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e12':
#             e12 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf12 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e13':
#             e13 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf13 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e14':
#             e14 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf14 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e15':
#             e15 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf15 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e16':
#             e16 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf16 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e17':
#             e17 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf17 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e18':
#             e18 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf18 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e19':
#             e19 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf19 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e20':
#             e20 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf20 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e21':
#             e21 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf21 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e22':
#             e22 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf22 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e23':
#             e23 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf23 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e24':
#             e24 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf24 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e25':
#             e25 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf25 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e26':
#             e26 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf26 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e27':
#             e27 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf27 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e28':
#             e28 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf28 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e29':
#             e29 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf29 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#         elif i['eKey'] == 'e30':
#             e30 = i['eValue'] + '#' + i['eNum'] + '#' + i['eKey']
#             conf30 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2]
#     if QXZstatus_New.objects.filter(equip_id=e_id).exists():
#         print("------create default-------")
#     else:
#         QXZstatus_New.objects.create(equip_id_id=e_id,
#             e1=e1,e2=e2,e3=e3,e4=e4,e5=e5,e6=e6,e7=e7,e8=e8,e9=e9,e10=e10,
#             e11=e11,e12=e12,e13=e13,e14=e14,e15=e15,e16=e16,e17=e17,e18=e18,e19=e19,e20=e20,
#             e21=e21,e22=e22,e23=e23,e24=e24,e25=e25,e26=e26,e27=e27,e28=e28,e29=e29,e30=e30,
#             upl_time=upl_time,qxz_picture=qxz_picture)
#         print("------create success-------")
    
#     e1 = ''
#     e2 = ''
#     e3 = ''
#     e4 = ''
#     e5 = ''
#     e6 = ''
#     e7 = ''
#     e8 = ''
#     e9 = ''
#     e10 = ''
#     e11 = ''
#     e12 = ''
#     e13 = ''
#     e14 = ''
#     e15 = ''
#     e16 = ''
#     e17 = ''
#     e18 = ''
#     e19 = ''
#     e20 = ''
#     e21 = ''
#     e22 = ''
#     e23 = ''
#     e24 = ''
#     e25 = ''
#     e26 = ''
#     e27 = ''
#     e28 = ''
#     e29 = ''
#     e30 = ''




#     if QXZ_Conf.objects.filter(equip_id=e_id).exists():
#         print("------conf create default-------")
#     else:
#         QXZ_Conf.objects.create(equip_id_id=e_id,
#             e1=conf1,e2=conf2,e3=conf3,e4=conf4,e5=conf5,e6=conf6,e7=conf7,e8=conf8,e9=conf9,e10=conf10,
#             e11=conf11,e12=conf12,e13=conf13,e14=conf14,e15=conf15,e16=conf16,e17=conf17,e18=conf18,e19=conf19,e20=conf20,
#             e21=conf21,e22=conf22,e23=conf23,e24=conf24,e25=conf25,e26=conf26,e27=conf27,e28=conf28,e29=conf29,e30=conf30)
#         QXZ_Default_Conf.objects.create(equip_id_id=e_id,
#             e1=conf1,e2=conf2,e3=conf3,e4=conf4,e5=conf5,e6=conf6,e7=conf7,e8=conf8,e9=conf9,e10=conf10,
#             e11=conf11,e12=conf12,e13=conf13,e14=conf14,e15=conf15,e16=conf16,e17=conf17,e18=conf18,e19=conf19,e20=conf20,
#             e21=conf21,e22=conf22,e23=conf23,e24=conf24,e25=conf25,e26=conf26,e27=conf27,e28=conf28,e29=conf29,e30=conf30)
#         print("------conf create success-------")

#     conf1 = ''
#     conf2 = ''
#     conf3 = ''
#     conf4 = ''
#     conf5 = ''
#     conf6 = ''
#     conf7 = ''
#     conf8 = ''
#     conf9 = ''
#     conf10 = ''
#     conf11 = ''
#     conf12 = ''
#     conf13 = ''
#     conf14 = ''
#     conf15 = ''
#     conf16 = ''
#     conf17 = ''
#     conf18 = ''
#     conf19 = ''
#     conf20 = ''
#     conf21 = ''
#     conf22 = ''
#     conf23 = ''
#     conf24 = ''
#     conf25 = ''
#     conf26 = ''
#     conf27 = ''
#     conf28 = ''
#     conf29 = ''
#     conf30 = ''


# -------------------------------------------------------MQTT TEST-------------------------------------
# import threading
# def cbdthread(e_id):
#     i = 0
#     TASK_TOPIC = '/yfkj/cbd/pub/%s'%e_id  # 客户端发布消息主题
#     client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
#     client = mqtt.Client(client_id, transport='tcp')
#     client.connect("39.104.94.153", 1883, 60)  # 此处端口默认为1883，通信端口期keepalive默认60
#     client.loop_start()
#     # print("子线程名称输出",threading.currentThread().name)
#     """
#     客户端发布消息
#     :param message: 消息主体
#     :return:
#     """
#     payload = {"cmd": "status", "ext": {"lux": 0, "lng": "113.61237910001185", "ts": 1, "upds": 0, "lps": 0, "csq": 31, "dver": "5.2HK", "hs": 0, "ws": 0, "rps": 1, "tps": 0, "proj": "DCCBD-2_HK", "stamp": "20200107151511", "vs": 201, "dtype": 3, "imei": "%s"%e_id, "lamp": 0, "lat": "34.80817089999999", "dnds": 0, "gs": 0, "iccid": "898602B62518C0046484"}}
#     # publish(主题：Topic; 消息内容)
#     while True:
#         client.publish(TASK_TOPIC, json.dumps(payload, ensure_ascii=False))
#         print("Successful send message!",e_id)
#         time.sleep(1)
#         print("=============",i)
#         i = i + 1



# e_id = 10000
# for i in range(10):
#     t = threading.Thread(target=cbdthread,args=(e_id,))
#     #打印出当前线程的名称和id
#     # print(threading.currentThread().name)
#     # t.setDaemon(True)
#     t.start()
#     e_id = e_id + 1
#     if e_id == 10009:
#         while True:
#             print("主线程名称输出",threading.currentThread().name)
#             thread_num = len(threading.enumerate())
#             print("线程数量是%d" % thread_num)
#             time.sleep(1)
# -------------------------------------------------------MQTT TEST-------------------------------------


    

        

# print(type(os.path.getsize('F:\\1111.jpg')))


# msg_conf_list = Msg_Conf.objects.all()
# for i in msg_conf_list:
#     cbd_obj = Equip.objects.get(equip_id=i.equip_id)
#     equip_name = ""
#     if cbd_obj.equip_name == "" or cbd_obj.equip_name == None:
#         equip_name = cbd_obj.equip_id
#     else:
#         equip_name = cbd_obj.equip_name
#     msgconf = eval(i.conf)
#     # 需要发送短信的手机号码
#     phone_numbers = msgconf["phone"]
#     # 短信模板ID，需要在短信控制台中申请
#     template_id = 431378  # NOTE: 这里的模板 ID`7839`只是示例，真实的模板 ID 需要在短信控制台中申请
#     # 签名
#     sms_sign = "云飞科技"  # NOTE: 签名参数使用的是`签名内容`，而不是`签名ID`。这里的签名"腾讯云"只是示例，真实的签名需要在短信控制台中申请

#     ssender = SmsSingleSender(appid, appkey)
#     params = ["","","由于入冬无虫子，暂时停止短信发送服务，将于明年三月份开启"]  # 当模板没有参数时，`params = []`
#     try:
#         result = ssender.send_with_param(86, phone_numbers,
#             template_id, params, sign=sms_sign, extend="", ext="")  # 签名参数未提供或者为空时，会使用默认签名发送短信
#     except HTTPError as e:
#         print(e)
#     except Exception as e:
#         print(e)
#     print(result)
#     Msg_Send.objects.create(mobile=msgconf["phone"],equip_id=i.equip_id,send_dec=params,result_desc=result)
#     pest_name = []
#     print("----发送成功",phone_numbers)


# 账号有效期设置
# user_obj = MyUser.objects.all()
# for i in user_obj:
#     if i.date_joined.year == 2019 and i.date_joined.month >= 10:
#         print(i.date_joined)
#         print(i.username)
#         i.expire_date = i.date_joined + datetime.timedelta(days=730)
#         i.save()
# print("操作成功")

# # 查看最近有虫子的测报灯
# one_month = datetime.timedelta(days=30)
# now_time = datetime.datetime.now()
# photo_list = CBDphoto.objects.all()
# for i in photo_list:
#     if now_time - i.upl_time <= one_month and i.indentify_result:
#         print(i.equip_id_id)

# book=xlrd.open_workbook('F:\\12.2河南云飞恢复续费.xlsx')
# sheet=book.sheet_by_index(0)  #根据sheet编号来
# # sheet=book.sheet_by_name('sheet1')   #根据 sheet名称来
# # print(sheet.nrows)  #excel里面有多少行
# # print(sheet.ncols)  #excel里面有多少列
# # print(sheet.cell(0,0).value)  #获取第0行第0列的值
# # print(sheet.row_values(0))  #获取到整行的内容
# # print(sheet.col_values(1)) #获取到整列的内容
# iccid_list = sheet.col_values(1)
# for i in range(len(iccid_list)):
#     if i == 0:
#         continue
#     print(iccid_list[i])
#     # print(iccid_list[i])
# # for i in range(sheet.nrows):  #循环获取每行的内容
# #     print(sheet.row_values(i))




# equip_list = Equip.objects.all()
# for i in equip_list:
#     print(type(i.equip_type_id))


# datalist = RecentCBDdata.objects.all()
# for i in datalist:
#     if i.discern == False:
#         i.disc = 1
#         i.save()
#     elif i.discern == True:
#         i.disc = 0
#         i.save()
# print("数据导入完毕")




# 判断测报灯流量卡充值停用账号
# simlist = Equip_SimInfo.objects.all()
# for i in simlist:
#     dateTime_p = datetime.datetime.strptime(i.expiry_date,'%Y-%m-%d %H:%M:%S')
#     # 判断sim卡是否30天到期
#     if dateTime_p - datetime.datetime.now() > datetime.timedelta(days=30):
#         pass
#     elif datetime.timedelta(days=0) > dateTime_p - datetime.datetime.now() > datetime.timedelta(days=0):
#         print("发送短信通知")
#     elif dateTime_p - datetime.datetime.now() < datetime.timedelta(days=0):
#         if i.equip_id.equip_type_id == 2:
#             print("杀虫灯")
#             # 判断杀虫灯状态30天内是否有数据
#             if datetime.datetime.now() - SCDstatus.objects.get(equip_id=i.equip_id).upl_time > datetime.timedelta(days=30):
#                 pass
#             else:
#                 print("停用账号")
#         elif i.equip_id.equip_type_id == 3:
#             print("测报灯")
#             # 判断测报灯状态30天内是否有数据
#             if datetime.datetime.now() - CBDstatus.objects.get(equip_id=i.equip_id).upl_time > datetime.timedelta(days=30):
#                 pass
#             else:
#                 print("停用账号")







# end_date = datetime.datetime.now()
# one_day = datetime.timedelta(days=1)
# one_day_later = datetime.datetime.now() - one_day
# print(one_day_later)
# new_time = "%s-%s-%s %s:%s:%s" %(one_day_later.year,one_day_later.month,one_day_later.day,"19","00","00")
# start_date = datetime.datetime.strptime(new_time,"%Y-%m-%d %H:%M:%S")



# cbd_obj = Equip.objects.get(equip_id='86123456789')
# equip_name = ""
# if cbd_obj.equip_name == "" or cbd_obj.equip_name == None:
#     equip_name = cbd_obj.equip_id
# else:
#     equip_name = cbd_obj.equip_name
# msg_conf_list = Msg_Conf.objects.get(equip_id=cbd_obj)
# msgconf = eval(msg_conf_list.conf)


# if msgconf["appointPest"] == "on":
#     pest_num = 0
#     pest_name = []
#     pest_nums = []
#     pest_dict = {}
#     pest_dict_new = {}

#     cbd_list = CBDphoto.objects.filter(equip_id=cbd_obj)
#     for x in cbd_list:
#         if x.indentify_result == None or x.indentify_result == "":
#             pass
#         else:
#             for a in x.indentify_result.split("#"):
#                 pest_num = pest_num + int(a.split(",")[1])
#                 pest_name.append(int(a.split(",")[0]))
#                 pest_nums.append(int(a.split(",")[1]))
#     for xx in range(len(pest_name)):
#         c = {pest_name[xx]:pest_nums[xx]}
#         for d in c:
#             if d in pest_dict:
#                 pest_dict[d] = pest_dict[d] + c[d]
#             else:
#                 pest_dict.update(c)
#     print(pest_dict)
#     send_dict = {}
#     print(msgconf["appointPestName"].split("#"))
#     print(msgconf["appointPestNum"].split("#"))
#     msg_name = msgconf["appointPestName"].split("#")
#     msg_num = msgconf["appointPestNum"].split("#")
#     for i in range(len(msg_name)):
#         if pest_dict[int(msg_name[i])] > int(msg_num[i]):
#             aaa = {insect_dict_new[msg_name[i]]:"%s头"%int(msg_num[i])}
#             send_dict.update(aaa)
#     print(send_dict)
    # if pest_dict[int(msgconf["appointPestName"])] >= int(msgconf["appointPestNum"]):
    #     pass
    # pest_num = 0
    # pest_name = []
    # pest_nums = []
    # pest_dict = {}
    # pest_dict_new = {}




# equip_obj = Equip.objects.get(equip_id="868575028850321")
# file_dir = "pyftp/ftp_file/bzy_photo/%s"%868575028850321
# print("file_dir",file_dir)
# sta1 = BZYstatus.objects.all()
# sta3 = []
# photo_list = []
# for i in sta1:
#     sta3.append(i.equip_id.equip_id)
# for imei in sta3:
#     equip_obj = Equip.objects.get(equip_id=imei)
#     file_dir = "pyftp/ftp_file/bzy_photo/%s"%imei
#     # print("file_dir",file_dir)
#     for root, dirs, files in os.walk(file_dir):
#         # print("当前目录为=========>>",root) #当前目录路径
#         # print("当前子目录为=========>>",dirs) #当前路径下所有子目录
#         if root.endswith(imei):
#             pass
#         else:
#             # print("当前目录------->>",root)
#             for roots, dirss, file in os.walk(root):
#                 # print(roots) #当前目录路径
#                 # print(dirs) #当前路径下所有子目录
#                 # print(file) #当前路径下所有非目录子文件
#                 if file != []:
#                     for i in file:
#                         photo_addr = roots + "/" + i
#                         # print(photo_addr)
#                         if BZYphoto.objects.filter(addr=photo_addr).exists():
#                             # print("照片存在")
#                             # print(i[17:29])
#                             # print("-----")
#                             # sp = datetime.datetime.now().year
#                             # sp_str = i.split(str(sp))[1]
#                             # # print(sp_str[0:8])
#                             # st = str(sp) + sp_str[0:8]
#                             # print(st)
#                             pass
#                         else:
#                             print("-----")
#                             sp = datetime.datetime.now().year
#                             sp_str = i.split(str(sp))[1]
#                             # print(sp_str[0:8])
#                             st = str(sp) + sp_str[0:8]
#                             # st = i[17:29]
#                             # print(st)
#                             pic_time = datetime.datetime.strptime(st,"%Y%m%d%H%M%S")
#                             print(pic_time)
#                             BZYphoto.objects.create(equip_id=equip_obj,addr=photo_addr,upl_time=pic_time)



# sta1 = BZYstatus.objects.all()
# sta3 = []
# photo_list = []
# for i in sta1:
#     sta3.append(i.equip_id.equip_id)
# for imei in sta3:
#     equip_obj = Equip.objects.get(equip_id=imei)
#     file_dir = "pyftp/ftp_file/bzy_photo/%s"%imei
#     # print("file_dir",file_dir)
#     for root, dirs, files in os.walk(file_dir):
#         # print("当前目录为=========>>",root) #当前目录路径
#         # print("当前子目录为=========>>",dirs) #当前路径下所有子目录
#         if root.endswith(imei):
#             pass
#         else:
#             # print("当前目录------->>",root)
#             for roots, dirss, file in os.walk(root):
#                 # print(roots) #当前目录路径
#                 # print(dirs) #当前路径下所有子目录
#                 # print(file) #当前路径下所有非目录子文件
#                 if file != []:
#                     for i in file:
#                         photo_addr = roots + "/" + i
#                         # print(photo_addr)
#                         if BZYphoto.objects.filter(addr=photo_addr).exists():
#                             print("照片存在")
#                             print(i[16:34])
#                         else:
#                             # os.path.getctime(photo_addr) # 输出文件的创建时间
#                             # print("文件创建时间",os.path.getctime(photo_addr))
#                             # timeStamp = os.path.getctime(photo_addr)
#                             # timeArray = time.localtime(timeStamp)
#                             # otherStyleTime = time.strftime("%Y-%m-%d %H:%M:%S", timeArray)
#                             # print(otherStyleTime)
#                             # BZYphoto.objects.create(equip_id=equip_obj,addr=photo_addr)
#                             print("-----")

# print("=========================")
# # print(photo_list)
# print("=========================")








# 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))

# print('all iccids :',iccids)
# print('all equip_ids :',equip_ids)
# print('all equip_names :',equip_names)


# print('iccids :',iccids)
# print('equip_ids :',equip_ids)
# print('equip_names :',equip_names)

# # 调用api查到的iccid号：
# for i in range(len(iccids)):
#     if iccids[i] != "":
#         # print("------",i)
#         # print('iccids :',iccids[i])
#         # print('equip_ids :',equip_ids[i])
#         # print('equip_names :',equip_names[i])
#         res = get_siminfo(iccids[i])
#         sim_res = res.text.encode('utf-8').decode('unicode_escape')
#         if eval(sim_res)["code"] == 0:

#             timeStamp = eval(sim_res)["data"]["expiry_date"]
#             dateArray = datetime.datetime.utcfromtimestamp(timeStamp)
#             otherStyleTime = dateArray.strftime("%Y-%m-%d %H:%M:%S")
            
#             timeStamp1 = eval(sim_res)["data"]["active_date"]
#             dateArray1 = datetime.datetime.utcfromtimestamp(timeStamp1)
#             otherStyleTime1 = dateArray1.strftime("%Y-%m-%d %H:%M:%S")

#             if Equip_SimInfo.objects.filter(equip_id=equip_ids[i]).exists():
#                 siminfo_obj = Equip_SimInfo.objects.get(equip_id=equip_ids[i])
#                 siminfo_obj.equip_name = equip_names[i]
#                 siminfo_obj.iccid = eval(sim_res)["data"]["iccid"]
#                 siminfo_obj.msisdn = eval(sim_res)["data"]["msisdn"]
#                 siminfo_obj.imsi = eval(sim_res)["data"]["imsi"]
#                 siminfo_obj.sp_code = eval(sim_res)["data"]["sp_code"]
#                 siminfo_obj.carrier = eval(sim_res)["data"]["carrier"]
#                 siminfo_obj.data_plan = eval(sim_res)["data"]["data_plan"]
#                 siminfo_obj.data_usage = eval(sim_res)["data"]["data_usage"]
#                 siminfo_obj.account_status = eval(sim_res)["data"]["account_status"]
#                 siminfo_obj.expiry_date = otherStyleTime
#                 siminfo_obj.active = eval(sim_res)["data"]["active"]
#                 siminfo_obj.test_valid_date = eval(sim_res)["data"]["test_valid_date"]
#                 siminfo_obj.silent_valid_date = eval(sim_res)["data"]["silent_valid_date"]
#                 siminfo_obj.test_used_data_usage = eval(sim_res)["data"]["test_used_data_usage"]
#                 siminfo_obj.active_date = otherStyleTime1
#                 siminfo_obj.data_balance = eval(sim_res)["data"]["data_balance"]
#                 siminfo_obj.outbound_date = eval(sim_res)["data"]["outbound_date"]
#                 siminfo_obj.support_sms = eval(sim_res)["data"]["support_sms"]
#                 siminfo_obj.upl_time = datetime.datetime.now()
#                 siminfo_obj.save()
#             else:
#                 Equip_SimInfo.objects.create(
#                     equip_id = Equip.objects.get(equip_id=equip_ids[i]),
#                     equip_name = equip_names[i],
#                     iccid = eval(sim_res)["data"]["iccid"],
#                     msisdn = eval(sim_res)["data"]["msisdn"],
#                     imsi = eval(sim_res)["data"]["imsi"],
#                     sp_code = eval(sim_res)["data"]["sp_code"],
#                     carrier = eval(sim_res)["data"]["carrier"],
#                     data_plan = eval(sim_res)["data"]["data_plan"],
#                     data_usage = eval(sim_res)["data"]["data_usage"],
#                     account_status = eval(sim_res)["data"]["account_status"],
#                     expiry_date = otherStyleTime,
#                     active = eval(sim_res)["data"]["active"],
#                     test_valid_date = eval(sim_res)["data"]["test_valid_date"],
#                     silent_valid_date = eval(sim_res)["data"]["silent_valid_date"],
#                     test_used_data_usage = eval(sim_res)["data"]["test_used_data_usage"],
#                     active_date = otherStyleTime1,
#                     data_balance = eval(sim_res)["data"]["data_balance"],
#                     outbound_date = eval(sim_res)["data"]["outbound_date"],
#                     support_sms = eval(sim_res)["data"]["support_sms"]
#                 )
# print("-----sim卡信息更新成功------")





# 保存调用查询流量的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)

# print("dat:",dat)



# ----------------------------------测报灯图片存在与否判断-----------------------------------
# sta1 = CBDstatus.objects.all()
# sta3 = []
# photo_list = []
# for i in sta1:
#     sta3.append(i.equip_id.equip_id)
# for imei in sta3:
#     file_dir = "pyftp/ftp_file/ykm_cbd/%s"%imei
#     # print("file_dir",file_dir)
#     for root, dirs, files in os.walk(file_dir):
#         # print("当前目录为=========>>",root) #当前目录路径
#         # print("当前子目录为=========>>",dirs) #当前路径下所有子目录
#         if root.endswith(imei):
#             pass
#         else:
#             # print("当前目录------->>",root)
#             for roots, dirss, file in os.walk(root):
#                 # print(roots) #当前目录路径
#                 # print(dirs) #当前路径下所有子目录
#                 # print(file) #当前路径下所有非目录子文件
#                 if file != []:
#                     for i in file:
#                         photo_addr = roots + "/" + i
#                         # print(photo_addr)
#                         if CBDphoto.objects.filter(addr=photo_addr).exists():
#                             print("照片存在")
#                         else:
#                             photo_list.append(photo_addr)

# print("=========================")
# print(photo_list)
# print("=========================")
# -----------------------------------------------------------------------------------------------

# sta1 = BZYstatus.objects.all()
# sta3 = []
# photo_list = []
# for i in sta1:
#     sta3.append(i.equip_id.equip_id)
# for imei in sta3:
#     file_dir = "pyftp/ftp_file/ykm_cbd/%s"%imei
#     # print("file_dir",file_dir)
#     for root, dirs, files in os.walk(file_dir):
#         # print("当前目录为=========>>",root) #当前目录路径
#         # print("当前子目录为=========>>",dirs) #当前路径下所有子目录
#         if root.endswith(imei):
#             pass
#         else:
#             # print("当前目录------->>",root)
#             for roots, dirss, file in os.walk(root):
#                 # print(roots) #当前目录路径
#                 # print(dirs) #当前路径下所有子目录
#                 # print(file) #当前路径下所有非目录子文件
#                 if file != []:
#                     for i in file:
#                         photo_addr = roots + "/" + i
#                         # print(photo_addr)
#                         if CBDphoto.objects.filter(addr=photo_addr).exists():
#                             print("照片存在")
#                         else:
#                             photo_list.append(photo_addr)

# print("=========================")
# print(photo_list)
# print("=========================")











        
    # try:
    #     path = "pyftp/ftp_file/ykm_cbd/%s"%imei
    #     lsdir = os.listdir(path)
    #     dirs = [i for i in lsdir if os.path.isdir(os.path.join(path, i))]
    #     if dirs:
    #         for i in dirs:
    #             print_files(os.path.join(path, i))
    #     files = [i for i in lsdir if os.path.isfile(os.path.join(path,i))]
    #     for f in files:
    #         print(os.path.join(path, f))
    # except Exception as e:
    #     print("=================>>",e)
    #     print("文件夹不存在")


# file_dir = "pyftp/ftp_file/ykm_cbd/%s"%imei
# print("file_dir",file_dir)
# for root, dirs, files in os.walk(file_dir):
#     print(root) #当前目录路径
#     print(dirs) #当前路径下所有子目录
#     print(files) #当前路径下所有非目录子文件
#     for i in files:
#         file = file_dir + "/" + i
#         jpg_time = time.ctime(os.path.getctime(file))
#         print("jpg_time",jpg_time)
#         st = s_time+jpg_time[11:19]
#         print("-------------------",i.split(".")[0])
#         pic_time_1 = s_time+i.split(".")[0]
#         pic_time_1 = datetime.datetime.strptime(pic_time_1,"%Y%m%d%H-%M-%S")
#         print("-------------------->",pic_time_1)
#         print("-------------------->",type(pic_time_1))
#         pic_time = datetime.datetime.strptime(st,"%Y%m%d%H:%M:%S")
#         print("类型查看",type(pic_time))
#         print("把字符串转成datetime: ", datetime.datetime.strptime(st,"%Y%m%d%H:%M:%S"))
#         if CBDphoto.objects.filter(addr=file).exists():
#             photoobj = CBDphoto.objects.get(addr=file)
#             photoobj.upl_time = pic_time_1
#             photoobj.save()
#             print("照片存在")
#         else:
#             print("照片不存在")
#             try:
#                 imei_obj = Equip.objects.get(equip_id=imei)
#                 CBDphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time)
#             except Exception as e:
#                 print("错误信息为",e)

# a = 0
# qxz_obj = QXZdata.objects.filter(equip_id="16062023")
# for i in qxz_obj:
#     a = a + 1
#     i.delete()
#     print("----删除成功%s"%a)

# =========================================================================================================
# equip_list = Equip.objects.all()
# bbb = 0
# for i in equip_list:
#     photo_list = CBDphoto.objects.filter(equip_id=i.equip_id)
#     status_list = CBDdata.objects.filter(equip_id=i.equip_id)
#     for x in photo_list:
#         for a in status_list:
#             if x.at == None:
#                 if a.upl_time.year == x.upl_time.year and a.upl_time.month == x.upl_time.month and a.upl_time.day == x.upl_time.day and a.upl_time.hour == x.upl_time.hour:
#                     # print("数据时间==================>",a.upl_time)
#                     # print("设备温度==================>",eval(a.cbd_data)["at"])
#                     # print("设备湿度==================>",eval(a.cbd_data)["ah"])
#                     # print("照片时间==================>",x.upl_time)
#                     x.at = eval(a.cbd_data)["at"]
#                     x.ah = eval(a.cbd_data)["ah"]
#                     x.save()
#                     bbb = bbb + 1
#                     print(bbb)
#                     print("========操作成功=======")
# =========================================================================================================

# file_dir="pyftp/ftp_file/bzy_photo/865650042816310/201909"
# # print("file_dir",file_dir)
# # bzy_obj = Equip.objects.get(equip_id=imei)
# for root, dirs, files in os.walk(file_dir):
#     print("当前目录为=========>>",root) #当前目录路径
#     print("当前子目录为=========>>",dirs) #当前路径下所有子目录
#     print("当前目录文件为=========>>",files) #当前路径下所有非目录子文件
#     for i in files:
#         photo_addr = file_dir + "/" + i
#         print("文件夹图片路径===========》》",photo_addr)
#         if BZYphoto.objects.filter(addr=photo_addr).exists():
#             print("照片存在")
#         else:
#             print("照片不存在")
            # BZYphoto.objects.create(equip_id=bzy_obj,addr=photo_addr)
    # if root.endswith(imei):
    #     pass
    # else:
    #     # print("当前目录------->>",root)
    #     for roots, dirss, file in os.walk(root):
    #         # print(roots) #当前目录路径
    #         # print(dirs) #当前路径下所有子目录
    #         # print(file) #当前路径下所有非目录子文件
    #         if file != []:
    #             for i in file:
    #                 photo_addr = roots + "/" + i
    #                 # print(photo_addr)
    #                 if BZYphoto.objects.filter(addr=photo_addr).exists():
    #                     print("照片存在")
    #                 else:
    #                     BZYphoto.objects.create(equip_id=bzy_obj,addr=photo_addr)


# ---------------------------丁艳青定制设备----------------------------------------------------------
# one_day = datetime.timedelta(days=1)
# minut = datetime.timedelta(minutes=random.choice(range(20,34)))
# start_time = '2019-07-29 19:00:08'
# start_time = datetime.datetime.strptime(start_time,'%Y-%m-%d %H:%M:%S')
# a = 1
# b = 1

# photo_list = CBDphoto.objects.filter(equip_id="865650040895753")
# for i in photo_list:
#     i.upl_time = start_time + datetime.timedelta(days=b) + datetime.timedelta(minutes=random.choice(range(20,34))) * a
#     i.save()
#     a = a + 1
#     print("修改次数",a)
#     if a == 5:
#         print("---跨天")
#         b = b + 1
#         i.upl_time = start_time + datetime.timedelta(days=b) + datetime.timedelta(minutes=random.choice(range(20,34)))
#         i.save()
#         a = 0


# data_obj = RecentCBDdata.objects.get(equip_id="865650042837894")
# print(eval(data_obj.cbd_data)['at'])
# scd_list = RecentSCDdata.objects.all().values()
# for i in scd_list:
#     try:
#         if eval(i['scd_data'])['lng'] == 0:
#             print(i['equip_id_id'])
#     except:
#         print("---报错设备号为:",i['equip_id_id'])
    # print("-----lng-------",eval(i['scd_data'])['lng'])