yfwlwCut/script_file/test1.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, MyUser, JKphoto, BZYphoto, QXZdata_New, Group, CBDstatus_all, Alarm_record
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
import xlrd, xlwt
import random
from django.db import transaction
from django.db.models import Q
from django.db.models import Count

import math
import os
import urllib.parse
import urllib.request
import re
from collections import Counter
import datetime

i = CBDstatus.objects.get(equip_id="867814040037265")
# for i in CBDstatus.objects.all():
print("--->>lng",i.lng)
print("--->>lat",i.lat)

# bzy_list = BZYphoto.objects.filter(equip_id=865650043206644)
# for i in bzy_list:
#     if i.upl_time.hour == 17 and i.upl_time.minute == 0:
#         print(i.upl_time)
#         i.delete()

# for i in BZYphoto.objects.all():
#     addr = i.addr.split("/")[-1]
#     if "192.168" in addr:
#         print("长addr",addr)
#         _time = addr.split("_")[2][0:14]
#         print("------->>",len(_time))
#         try:
#             _time = datetime.datetime.strptime(_time,'%Y%m%d%H%M%S')
#         except:
#             continue
#         print(_time)
#         if i.upl_time.hour != _time.hour:
#             i.upl_time = _time
#             i.save()
#     elif len(addr) == 18:
#         print("短addr",addr)
#         _time = addr.split(".")[0][0:14]
#         print("------->>",len(_time))
#         _time = _time.split("\r")[0]
#         try:
#             _time = datetime.datetime.strptime(_time,'%Y%m%d%H%M%S')
#         except:
#             continue
#         print(_time)
#         if i.upl_time.hour != _time.hour:
#             i.upl_time = _time
#             i.save()

# qxz_list = QXZdata_New.objects.filter(equip_id=16064789)[0]
# # for i in qxz_list:
# print(qxz_list.upl_time)
# QXZstatus_New.objects.filter(equip_id=16064789).update(upl_time=qxz_list.upl_time)
# e_id = "868956048888824"

# alarm_list = Alarm_record.objects.all()
# for i in alarm_list:
#     # status = eval(i.cbd_status)
#     i.e_type = i.equip_id.equip_type.type_id
#     i.save()
# alarm_list = Alarm_record.objects.filter(alarm_desc="{'status':0,'type':'offline'}").values().annotate(count=Count('equip_id_id')).values('equip_id_id','count')
# for i in alarm_list:
#     print(i)
# _list = []

# equip_list = Equip.objects.filter(Q(equip_type="2") | Q(equip_type="3") | Q(equip_type="4") | Q(equip_type="5"))
# for i in equip_list:
#     a_list = Alarm_record.objects.filter(equip_id=i)
#     a_list.update(e_type=str(i.equip_type_id))
#     print("---------",i)
# print("---------")
# # print(type(alarm_list))
# # for i in alarm_list:
# #     _list.append(i['equip_id_id'])
# # print(alarm_list)
# # print(_list)
# b = Counter(alarm_list)
# # # for xx in b:
# # #     print(xx)
# # print(type(b))
# print(sorted(b.elements()))

# devices = Alarm_record.objects.filter(alarm_desc="{'status':0,'type':'offline'}")
# # print(devices)
# # print(devices.count())
# data = {}
# for i in devices:
#     data.setdefault(i.equip_id_id,[]).append(i.alarm_desc)
# values = {}
# for k,v in data.items():
#     values[k] = len(v)
# print(values)
    
    

    # print(i.equip_id.equip_type.type_id)



# cbd_list = CBDstatus.objects.all()
# for i in cbd_list:
#     if i.is_online == "1":
#         # print("上报时间",i.upl_time)
#         # print("数据时间",RecentCBDdata.objects.get(equip_id=i.equip_id).upl_time)
#         aa = i.upl_time
#         try:
#             bb = RecentCBDdata.objects.get(equip_id=i.equip_id).upl_time
#         except:
#             continue
#         print("状态时间",aa.year,aa.month,aa.day)
#         print("数据时间",bb.year,bb.month,bb.day)
#         if aa.year != 2020 or aa.month != 6 or aa.day != 28:
#             print("执行！")
#             staobj = CBDstatus.objects.filter(equip_id=Equip.objects.get(equip_id=i.equip_id))
#             # staobj.is_online = "0"
#             staobj.update(is_online="0")
#             staobj.update(off_time=RecentCBDdata.objects.get(equip_id=i.equip_id).upl_time)
        # if aa.year != bb.year or aa.month != bb.month or aa.day != bb.day:
        #     print("执行！")
        #     staobj = CBDstatus.objects.filter(equip_id=Equip.objects.get(equip_id=i.equip_id))
        #     staobj.update(upl_time=RecentCBDdata.objects.get(equip_id=i.equip_id).upl_time)
        # aa = CBDstatus.objects.filter(equip_id=Equip.objects.get(equip_id=i.equip_id))
        # aa.update(upl_time=i.off_time)
# lists = ["865650044457725"]


# equip = Equip.objects.get(equip_id="868956044831315")
# print(equip)
# photo_addr = "	pyftp/ftp_file/bzy_photo/865650043208251/202004/192.168.1.100_01_20200430170516558_ALARM_I.jpg"
# bzys = BZYphoto.objects.create(equip_id=equip, addr=photo_addr)
# print("照片不存在")
# if equip.ftb_addr:
#     data = {
#     "Image":bzys.addr,
#     "imei":bzys.equip_id,
#     }
#     data = json.dumps(data)
#     headers = {"Content-type":"application/json"}
#     bzy_photo = requests.post(equip.ftb_addr,data=data,headers=headers)


# book=xlrd.open_workbook('昆虫标定2020.xlsx')
# # book=xlrd.open_workbook('工作表.xlsx')
# # sheet=book.sheet_by_index(0) 
# # print(sheet.head())
# sheet=book.sheet_by_name('Sheet1')   #根据 sheet名称来
# print(sheet)
# # print(sheet.nrows)  #excel里面有多少行
# # print(sheet.ncols)  #excel里面有多少列
# # print(sheet.cell(0,12).value)  #获取第0行第0列的值
# # print(sheet.row_values(0))  #获取到整行的内容
# # lists = sheet.col_values(21)#获取到整列的内容
# lis = sheet.col_values(0)#获取到整列的内容
# data = []
# date = []
# nu = 0
# for i in lis:
#     nu += 1
#     lists = re.findall(r'\d+',i)
#     data.append(insect_dict_new[lists[0]])
#     date.append(lists[1])
#     # print(re.findall(r"\d+\.?\d*",i)
# wb = xlwt.Workbook(encoding='utf8')
# sheet = wb.add_sheet('order-sheet',cell_overwrite_ok=True)
# style_heading = xlwt.easyxf()

#     # 写入文件标题

# sheet.write(0, 0, '害虫名字', style_heading)
# sheet.write(0, 1, '害虫数量', style_heading)

# data_row = 1
# nu = 0
# for x in range(len(data)):
#     sheet.write(data_row, 0, data[x])
#     sheet.write(data_row, 1, date[x])


#     data_row += 1
#             # 写入数据 保存到本地
#     user_export = "sexport_file/"
#     if os.path.exists(user_export) == False:
#         os.makedirs(user_export)
#     wb.save(user_export + "昆虫统计表" + ".xls")


# now_time = datetime.datetime.now()
# data = ["865650043206719","865650043207865","865650043189378","865650043202718","865650043206834","865650043207329"]
# def test(imei):
#     print(imei)
#     # 创建一个文件对象
#     wb = xlwt.Workbook(encoding='utf8')
#     # 创建一个sheet对象
#     end_time = "2020-02-01"
#     sheet = wb.add_sheet('order-sheet',cell_overwrite_ok=True)
#     cbd_list = CBDphoto.objects.filter(equip_id=imei,upl_time__range=(end_time,now_time))
#     print(len(cbd_list))
#     #设置文件头的样式,这个不是必须的可以根据自己的需求进行更改
    # style_heading = xlwt.easyxf("""
    #         font:
    #             name Arial,
    #             colour_index white,
    #             bold on,
    #             height 0xA0;
    #         align:
    #             wrap off,
    #             vert center,
    #             horiz center;
    #         pattern:
    #             pattern solid,
    #             fore-colour 0x19;
    #         borders:
    #             left THIN,
    #             right THIN,
    #             top THIN,
    #             bottom THIN;
    #         """)

    # # 写入文件标题

    # sheet.write(0, 0, '设备id', style_heading)
    # sheet.write(0, 1, '上传时间', style_heading)
    # sheet.write(0, 2, '图片路径', style_heading)
    # sheet.write(0, 3, '识别结果', style_heading)
        
#     data_row = 1
#     for x in cbd_list:
#         pri_time = x.upl_time.strftime('%Y-%m-%d %H:%M:%S')
#         sheet.write(data_row, 0, x.equip_id.equip_id)
#         sheet.write(data_row, 1, pri_time)
#         sheet.write(data_row, 2, x.addr.split("/")[-1])
#         sheet.write(data_row, 3, x.indentify_result)

#         data_row += 1
#                 # 写入数据 保存到本地
#         user_export = "sexport_file/"
#         if os.path.exists(user_export) == False:
#             os.makedirs(user_export)
#         wb.save(user_export + imei + ".xls")
# if __name__ == '__main__':
#     for i in data:
#         test(i)

            # dat = []
        # user_data = user_export + user_name.username + ".xls"
        # dat.append({"file": user_data})
        # data = json.dumps(dat)
        # return HttpResponse(data)


# scd_list = SCDstatus.objects.all()
# cbd_list = CBDstatus.objects.all()

# _list = []

# for i in scd_list:
#     if i.lng:
#         try:
#             res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(i.lat,i.lng))
#             city = (eval(res.text))["result"]["addressComponent"]["city"]
#             district = (eval(res.text))["result"]["addressComponent"]["district"]
#             print(city)
#         except:
#             continue
#         _list.append({"name1":city,"name2":district,"type":2,"equipId":i.equip_id_id,"equipName":i.equip_id.equip_name,"lng":i.lng,"lat":i.lat})
# print(_list)

# title = ["name1","name2","type","equipId","equipName","lng","lat"]
# 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(_list)): #　遍历列表
#     sheet.write(xx+1,0,_list[xx]['name1']) #　将equip_id写入到第x+1行，第0列中
#     sheet.write(xx+1,1,_list[xx]['name2'])
#     sheet.write(xx+1,2,_list[xx]['type'])
#     sheet.write(xx+1,3,_list[xx]['equipId'])
#     sheet.write(xx+1,4,_list[xx]['equipName'])
#     sheet.write(xx+1,5,_list[xx]['lng'])
#     sheet.write(xx+1,6,_list[xx]['lat'])
# book.save("654321.xlsx")
# book = xlrd.open_workbook('2020.xlsx')
# sheet=book.sheet_by_name('Sheet2')
# lists = sheet.col_values(0)#获取到整列的内容
# # print(lists)
# user_name = MyUser.objects.get(username="sgnyj")
# list1 = []
# list2 = []
# for i in lists:
#     try:
#         equip_obj = Equip.objects.get(equip_id=i)
#         list1.append(i)
#     except Exception as e:
#         # print(e)
#         list2.append(i)
# print(len(list2))
# print(len(list1))
# lists = []
# for i in list1:
#     equip_obj = Equip.objects.get(equip_id=i)
#     if equip_obj.equip_user == user_name:
#         pass
#     elif equip_obj.equip_user:
#         print(equip_obj)
#         lists.append(equip_obj)
#     else:
#         equip_obj.equip_user = user_name
#         equip_obj.save()
# print(lists)
#     print(equip_obj)
#     if equip_obj.exists():
#         pass
#     else:
#         print(equip_obj.equip_user)
# # list3 = []
# for i in list2:
#     try:
#         equip_obj = Equip.objects.get(equip_id=i)
#         list3.append(i)
#     except Exception as e :

# for i in list1:

#     equip_obj = Equip.objects.filter(equip_id=i,equip_user=user_name)
#     if equip_obj:
#         pass
#     else:
#         pass


# data = []
# for x in Equip.objects.filter(equip_user=MyUser.objects.get(username="sgnyj")):
#     data.append(x.equip_id)
# print(len(data))
# print(len(_list1))
# for xx in _list1:
#     if xx not in data:
#         print(xx)


# cbdgroup = Group.objects.get(name='测报灯用户')
# # obj = Group.models.get(b_name='xxx')
# uname_obj = MyUser.objects.filter(groups=cbdgroup)
# # groups = Group.objects.filter(user=uname_obj)
# print(uname_obj)
# for i in uname_obj:
#     print(i.username)
# while True:
#     strtmp = os.popen("systemctl status py_ftp_server.service") 
#     #print(type(strtmp))
#     cmdback = strtmp.read()
#     # print("----->>",cmdback)

#     if "running" in cmdback:
#         print("服务正常运行")
#     elif "failed" in cmdback:

#         # 需要发送短信的手机号码
#         phone_numbers = ["13733763561","18258845915","15225155092"]
#         # 短信模板ID，需要在短信控制台中申请
#         template_id = 579944  # NOTE: 这里的模板 ID`7839`只是示例，真实的模板 ID 需要在短信控制台中申请
#         # 签名
#         sms_sign = "云飞科技"  # NOTE: 签名参数使用的是`签名内容`，而不是`签名ID`。这里的签名"腾讯云"只是示例，真实的签名需要在短信控制台中申请
#         msender = SmsMultiSender(appid, appkey)
#         params = ["ftp",]
#         try:
#             result = msender.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)

#         print("----发送成功")
#         print("服务异常！！！")
#     time.sleep(60)


# cbdgroup = Group.objects.get(name='测报灯用户')
# aobj = obj.author_set()
 
# # 如果你使用了如我上面的related_name='auth' 别名属性,就可以
# # user_list = cbdgroup.myuser.all()
# print(user_list)
# print(random.randint(10,30))

# cbd_list = CBDstatus.objects.all()
# for xx in cbd_list:
#     imei = xx.equip_id_id


# 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 = ''
# qxz_list = Equip.objects.filter(equip_type=5)
# for xx in qxz_list:
#     equip_id = xx.equip_id
# #     time.sleep(10)
# # equip_id = "16064781"
# # equip_id = "16064809"
# # equip_id = "18054384"
# # equip_id = "16064783"
# # equip_id = "16064789"
# # equip_id = "16064808"
# # equip_id = "16064784"
# # equip_id = "16064781"
#     for x in QXZdata.objects.filter(equip_id=equip_id):
#         e_id = eval(x.qxz_data)['StationID']
#         upl_time = x.upl_time
#         # qxz_picture = QXZdata.objects.get(equip_id=e_id).qxz_picture
#         qxzdata = eval(x.qxz_data)['data']
#         # print(qxzdata)
#         for i in qxzdata:
#             if i['eKey'] == 'e1':
#                 e1 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e1[0] == "#":
#                     continue
#             elif i['eKey'] == 'e2':
#                 e2 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e2[0] == "#":
#                     continue
#             elif i['eKey'] == 'e3':
#                 e3 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e3[0] == "#":
#                     continue
#             elif i['eKey'] == 'e4':
#                 e4 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e4[0] == "#":
#                     continue
#             elif i['eKey'] == 'e5':
#                 e5 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e5[0] == "#":
#                     continue
#             elif i['eKey'] == 'e6':
#                 e6 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e6[0] == "#":
#                     continue
#             elif i['eKey'] == 'e7':
#                 e7 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e7[0] == "#":
#                     continue
#             elif i['eKey'] == 'e8':
#                 e8 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e8[0] == "#":
#                     continue
#             elif i['eKey'] == 'e9':
#                 e9 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e9[0] == "#":
#                     continue
#             elif i['eKey'] == 'e10':
#                 e10 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e10[0] == "#":
#                     continue
#             elif i['eKey'] == 'e11':
#                 e11 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e11[0] == "#":
#                     continue
#             elif i['eKey'] == 'e12':
#                 e12 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e12[0] == "#":
#                     continue
#             elif i['eKey'] == 'e13':
#                 e13 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e13[0] == "#":
#                     continue
#             elif i['eKey'] == 'e14':
#                 e14 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e14[0] == "#":
#                     continue
#             elif i['eKey'] == 'e15':
#                 e15 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e15[0] == "#":
#                     continue
#             elif i['eKey'] == 'e16':
#                 e16 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e16[0] == "#":
#                     continue
#             elif i['eKey'] == 'e17':
#                 e17 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e17[0] == "#":
#                     continue
#             elif i['eKey'] == 'e18':
#                 e18 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e18[0] == "#":
#                     continue
#             elif i['eKey'] == 'e19':
#                 e19 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e19[0] == "#":
#                     continue
#             elif i['eKey'] == 'e20':
#                 e20 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e20[0] == "#":
#                     continue
#             elif i['eKey'] == 'e21':
#                 e21 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e21[0] == "#":
#                     continue
#             elif i['eKey'] == 'e22':
#                 e22 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e22[0] == "#":
#                     continue
#             elif i['eKey'] == 'e23':
#                 e23 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e23[0] == "#":
#                     continue
#             elif i['eKey'] == 'e24':
#                 e24 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e24[0] == "#":
#                     continue
#             elif i['eKey'] == 'e25':
#                 e25 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e25[0] == "#":
#                     continue
#             elif i['eKey'] == 'e26':
#                 e26 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e26[0] == "#":
#                     continue
#             elif i['eKey'] == 'e27':
#                 e27 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e27[0] == "#":
#                     continue
#             elif i['eKey'] == 'e28':
#                 e28 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e28[0] == "#":
#                     continue
#             elif i['eKey'] == 'e29':
#                 e29 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e29[0] == "#":
#                     continue
#             elif i['eKey'] == 'e30':
#                 e30 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey'])
#                 if e30[0] == "#":
#                     continue
#         if QXZdata_New.objects.filter(equip_id=e_id,upl_time=upl_time).exists():
#             print("------create default-------")
#         else:
#             QXZdata_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)
#             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 = ''



#--------------------------------------------------------------------------------------------------------------
# file_dir = "pyftp/ftp_file/bzy_photo/865650042816179"
# print("file_dir",file_dir)
# for root, dirs, files in os.walk(file_dir):
#     # print("root-------------->>",root) #当前目录路径
#     # print("子目录文件dirs=======>>",dirs) #当前路径下所有子目录
#     # print("非子目录文件files========>>",files) #当前路径下所有非目录子文件
#     for i in files:
#         # if len(i) == 45:
#         file = root + "/" + i
#         # st = root.split("/")[-1] + i.split(".")[0]
#         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=235185770)
#         #         JKphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time)
#         #     except Exception as e:
#         #         print("错误信息为",e)
#         if BZYphoto.objects.filter(addr=file).exists():
#             photoobj = BZYphoto.objects.get(addr=file)
#             photoobj.upl_time = pic_time
#             photoobj.save()
#             print("照片存在")
#         else:
#             print("照片不存在")
#             try:
#                 imei_obj = Equip.objects.get(equip_id=865650042816179)
#                 BZYphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time)
#             except Exception as e:
#                 print("错误信息为",e)
#--------------------------------------------------------------------------------------------------------------
                # print(root)
            # file = file_dir + "/" + i
            # jpg_time = time.ctime(os.path.getctime(file))
            # print("jpg_time",jpg_time)
            # # st = s_time+jpg_time[11:19]
            # st = i.split(".")[3].split("_")[2][0:12]
            # print("-------------------",i.split(".")[3].split("_")[2][0:14])
            # # 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"))
            # print("file:",file)
            # 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)


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



# def iccid_info(iccid):
#     cbd_obj = CBDstatus.objects.all().values()
#     scd_obj = SCDstatus.objects.all().values()
#     dat = []
#     for i in cbd_obj:
#         try:
#             if iccid == eval(i["cbd_status"])["iccid"]:
#                 # print(eval(i["cbd_status"])["iccid"])
#                 # print(i["off_time"])
#                 ic_eq = {"id":i["equip_id_id"],"lng":i["lng"],"lat":i["lat"],"offtime":i["off_time"]}
#                 dat.append(ic_eq)
#         except Exception as e:
#             pass
#     for x in scd_obj:
#         try:
#             if iccid == eval(x["scd_status"])["iccid"]:
#                 ic_eq = {"id":x["equip_id_id"],"lng":x["lng"],"lat":x["lat"],"offtime":x["off_time"]}
#                 dat.append(ic_eq)
#         except Exception as e:
#             pass
#     return dat
    

# book=xlrd.open_workbook('河南云飞科技发展有限公司.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 = []
# sta2 = []
# iccid_excel = sheet.col_values(1)
# for i in range(len(iccid_excel)):
#     if i == 0:
#         continue
#     # print(iccid_excel[i])
#     # iccid_list.append(iccid_excel[i])
#     # print(iccid_info(iccid_excel[i]))
#     if len(iccid_info(iccid_excel[i])) > 1:
#         # print("此卡用于多个设备需单独记录=====>>",iccid_excel[i])
#         equip_id = "999999"
#         location = ""
#         equip_type = ""
#         equip_user = ""

#     elif len(iccid_info(iccid_excel[i])) == 1:
#         try:
#             equip_id = iccid_info(iccid_excel[i])[0]["id"]
#         except:
#             equip_id = ""

#         try:
#             lat = iccid_info(iccid_excel[i])[0]["lat"]
#         except:
#             lat = ""

#         try:
#             lng = iccid_info(iccid_excel[i])[0]["lng"]
#         except:
#             lng = ""

#         try:
#             equip_type = Equip.objects.get(equip_id=equip_id).equip_type.type_name
#         except:
#             equip_type = ""
#         try:
#             equip_user = Equip.objects.get(equip_id=equip_id).equip_user.username
#         except:
#             equip_user = ""

#         if lat:
#             res = requests.post("http://api.map.baidu.com/geocoder?location=%s,%s&coord_type=gcj02&output=json"%(lat,lng))
#             location = (eval(res.text))["result"]["addressComponent"]["province"]+eval(res.text)["result"]["addressComponent"]["district"]
#         else:
#             location = ""
#     elif len(iccid_info(iccid_excel[i])) == 0:
#         equip_id = "000000"
#         location = ""
#         equip_type = ""
#         equip_user = ""
#     sta2.append({"iccid":iccid_excel[i],"equip_id":equip_id,"location":location,"equip_user":equip_user,"equip_type":equip_type})

# # print(sta2)

# title = ["iccid","设备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,15+i,title[i]) # 将title数组中的字段写入到0行i列中
# # print(sta2)
# for x in range(len(sta2)): #　遍历列表
#     sheet.write(x+1,15,sta2[x]['iccid']) #　将equip_id写入到第x+1行，第0列中
#     sheet.write(x+1,16,sta2[x]['equip_id'])
#     sheet.write(x+1,17,sta2[x]['equip_type'])
#     sheet.write(x+1,18,sta2[x]['location'])   # 设备开关
#     sheet.write(x+1,19,sta2[x]['equip_user'])
# book.save("123456.xlsx")




# print(iccid_list)
# for x in iccid_list:
#     print(x)
#     print(iccid_info(x))
#     time.sleep(1)



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