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