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 qxz_dict, ql_qxz from apps.AppInfoManage.models import Equip, Equip_type, QXZstatus_New, QXZdata_New, QXZ_Default_Conf, QXZ_Conf print("--------qxz_http start!-----------") # url = 'http://cloud.cqyoushuo.com/api/GetNewData?uid=1EF0&key=99F1322FB10D93C49B6EA9583E4101D6' # r = requests.get(url) # rec = r.text # print(rec) # while True: for imei in ql_qxz: key = ql_qxz[imei] url = 'http://cloud.cqyoushuo.com/api/GetNewData?uid=%s&key=%s'%(imei,key) r = requests.get(url) rec = r.text # print(rec) qxzdata = eval(rec)["data"] time1 = eval(rec)["time1"] time1 = datetime.datetime.strptime(time1,'%Y-%m-%d %H:%M:%S') 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 i in qxzdata: if i['eKey'] == 'e1': e1 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf1 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e1[0] == "#": continue elif i['eKey'] == 'e2': e2 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf2 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e2[0] == "#": continue elif i['eKey'] == 'e3': e3 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf3 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e3[0] == "#": continue elif i['eKey'] == 'e4': e4 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf4 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e4[0] == "#": continue elif i['eKey'] == 'e5': e5 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf5 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e5[0] == "#": continue elif i['eKey'] == 'e6': e6 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf6 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e6[0] == "#": continue elif i['eKey'] == 'e7': e7 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf7 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e7[0] == "#": continue elif i['eKey'] == 'e8': e8 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf8 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e8[0] == "#": continue elif i['eKey'] == 'e9': e9 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf9 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e9[0] == "#": continue elif i['eKey'] == 'e10': e10 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf10 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e10[0] == "#": continue elif i['eKey'] == 'e11': e11 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf11 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e11[0] == "#": continue elif i['eKey'] == 'e12': e12 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf12 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e12[0] == "#": continue elif i['eKey'] == 'e13': e13 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf13 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e13[0] == "#": continue elif i['eKey'] == 'e14': e14 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf14 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e14[0] == "#": continue elif i['eKey'] == 'e15': e15 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf15 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e15[0] == "#": continue elif i['eKey'] == 'e16': e16 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf16 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e16[0] == "#": continue elif i['eKey'] == 'e17': e17 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf17 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e17[0] == "#": continue elif i['eKey'] == 'e18': e18 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf18 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e18[0] == "#": continue elif i['eKey'] == 'e19': e19 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf19 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e19[0] == "#": continue elif i['eKey'] == 'e20': e20 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf20 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e20[0] == "#": continue elif i['eKey'] == 'e21': e21 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf21 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e21[0] == "#": continue elif i['eKey'] == 'e22': e22 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf22 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e22[0] == "#": continue elif i['eKey'] == 'e23': e23 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf23 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e23[0] == "#": continue elif i['eKey'] == 'e24': e24 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf24 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e24[0] == "#": continue elif i['eKey'] == 'e25': e25 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf25 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e25[0] == "#": continue elif i['eKey'] == 'e26': e26 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf26 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e26[0] == "#": continue elif i['eKey'] == 'e27': e27 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf27 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e27[0] == "#": continue elif i['eKey'] == 'e28': e28 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf28 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e28[0] == "#": continue elif i['eKey'] == 'e29': e29 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf29 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e29[0] == "#": continue elif i['eKey'] == 'e30': e30 = str(i['eValue']) + '#' + str(i['eNum']) + '#' + str(i['eKey']) conf30 = qxz_dict[i['eNum']][1] + '#' + qxz_dict[i['eNum']][2] if e30[0] == "#": continue qxz_exist = Equip.objects.filter(equip_id=imei) # print("extdata:", extdata) # 设备存在，进一步判断状态表是否存在： if qxz_exist.exists(): print("<-----this equip is existed!----->") try: e_id = Equip.objects.get(equip_id=imei) except: print("<-----this equip didn't exist!----->") print("================>>time1",time1) if QXZstatus_New.objects.get(equip_id=imei).upl_time == time1: print("===========暂未更新") else: try: # 设备数据表直接储存数据 # QXZdata.objects.create(equip_id=e_id, qxz_data=extdata) 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=time1) print("<-----data update success!----->") except: print("<-----data update failed!----->") if QXZstatus_New.objects.filter(equip_id=imei).exists(): print("<-----this equip's status is existed!----->") try: sta = QXZstatus_New.objects.get(equip_id=imei) sta.e1 = e1 sta.e2 = e2 sta.e3 = e3 sta.e4 = e4 sta.e5 = e5 sta.e6 = e6 sta.e7 = e7 sta.e8 = e8 sta.e9 = e9 sta.e10 = e10 sta.e11 = e11 sta.e12 = e12 sta.e13 = e13 sta.e14 = e14 sta.e15 = e15 sta.e16 = e16 sta.e17 = e17 sta.e18 = e18 sta.e19 = e19 sta.e20 = e20 sta.e21 = e21 sta.e22 = e22 sta.e23 = e23 sta.e24 = e24 sta.e25 = e25 sta.e26 = e26 sta.e27 = e27 sta.e28 = e28 sta.e29 = e29 sta.e30 = e30 sta.upl_time = time1 sta.save() print("<-----status update success!----->") except: print("<-----status update failed!----->") else: # 设备状态表不存在、创建状态表： print("<-----this equip's status is not existed!----->") try: 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=time1) # QXZstatus.objects.create(equip_id=e_id, qxz_status=extdata) print("<-----this equip's status table re-create successed!----->") except: print("<-----this equip's status table re-create failed!----->") print("1111111111") # 判断标题配置表 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-------") # 设备状态表存在、刷新状态表： print("2222222") else: print("<-----this equip not existed!----->") # 设备不存在，在设备列表中创建： equip_t = Equip_type.objects.get(type_id=5) try: e_id = Equip.objects.create(equip_id=imei, equip_type=equip_t) print("<-----this imei add successed!----->") try: # 设备数据表直接储存数据 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=time1) # QXZdata.objects.create(equip_id=e_id, qxz_data=extdata) print("<-----data update success!----->") except: print("<-----data update failed!----->") try: 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=time1) # QXZstatus.objects.create(equip_id=e_id, qxz_status=extdata) print("<-----this imei register successed!----->") except: print("<-----this imei register failed!----->") # 判断标题配置表 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-------") except Exception as e: print(e) print("<-----this imei add failed!----->") # time.sleep(1800)