# -*- coding: utf-8 -*- # File Name:mqtt_chat_client.py # Python Version:3.5.1 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() print("<-----python_mqtt_client_qxz is run----->") import paho.mqtt.client as mqtt import json from apps.AppInfoManage.models import Equip, Equip_type, MyUser, Alarm_record, QXZdata, QXZstatus, QXZswitchstatus, QXZswitchdata, QXZAutoswitch, QXZTimingswitch, QXZstatus_New, \ QXZdata_New, QXZ_Conf, QXZ_Default_Conf, QXZ_Base_Info, QXZ_Info_Record import re import datetime from apps.ReportManage.all_dict import qxz_dict class CJSONEncoder(json.JSONEncoder): def default(self, obj): if isinstance(obj, datetime): return obj.strftime('%Y-%m-%d %H:%M:%S') elif isinstance(obj, date): return obj.strftime('%Y-%m-%d') else: return json.JSONEncoder.default(self, obj) # 连接后的操作： 0为成功 def on_connect(client, userdata, flags, rc): # print("Connected with result code "+str(rc)) client.subscribe("/yfkj/qxz/pub/#") client.subscribe("/yfkj/qxz/offline/#") # *****成功发布****** def on_publish(msg, rc): if rc == 0: print("publish success,msg = "+msg) # 从服务器接受到消息后回调此函数 ： def on_message(client, userdata, msg): print('\r') print('=================================================') print('\r') print("<-----topic:\n" + msg.topic + ';\n') print("Message:\n" + str(msg.payload) + "----->\n") # 从主题中获取imei # imei = msg.topic[14:len(msg.topic)] imei = re.sub("\D", "", msg.topic) print("<-----imei:", imei, "----->") try: # 判断主题： if "pub" in msg.topic: # 将json字符串解析： payload = json.loads(msg.payload.decode()) qxz_exist = Equip.objects.filter(equip_id=imei) if payload.get("cmd") == "terminalData": print("<-----uploading data!----->") extdata = payload.get("ext") print(type(extdata)) qxzdata = extdata['data'] print(qxzdata) 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['eNum'] == "102" and float(i['eValue']) > 100: i['eValue'] = "100" 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 # 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!----->") 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) 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.is_online = "1" sta.upl_time = datetime.datetime.now() 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,is_online="1") # 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!----->") # 判断标题配置表 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) # 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,is_online="1") # 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!----->") # elif payload.get("cmd") == "control": # # extdata = eval(payload.get("ext"))["runStatus"] # extdata = payload.get("ext")['runStatus'] # 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!----->") # if QXZswitchstatus.objects.filter(equip_id=imei).exists(): # print("<-----this switch status is existed!----->") # try: # sta = QXZswitchstatus.objects.get(equip_id=imei) # sta.qxz_switch=extdata # sta.save() # print("<-----switchstatus update success!----->") # except: # print("<-----switchstatus update failed!----->") # else: # # 设备开关表不存在、创建开关表： # print("<-----this switch switchstatus is not existed!----->") # try: # QXZswitchstatus.objects.create(equip_id=e_id, qxz_switch=extdata) # print("<-----this switchstatus table re-create successed!----->") # except: # print("<-----this switchstatus table re-create failed!----->") # # 气象站开关自定义名字表 # if QXZswitchdata.objects.get(equip_id=imei).qxz_switch_data != "[]": # print("<-----this switchdata is existed!----->") # else: # # 设备开关配置表不存在、创建开关配置表： # print("<-----this switch switchdata is not existed!----->") # extdata = payload.get("ext")['runStatus'] # data = [] # for i in extdata: # print(i["JK"]) # data.append({"JK":i["JK"],"name":""}) # print(data) # try: # QXZswitchdata.objects.create(equip_id=e_id, qxz_switch_data=data) # print("<-----this switchdata table re-create successed!----->") # except Exception as e: # print(e) # print("<-----this switchdata table re-create failed!----->") # elif payload.get("cmd") == "auto": # # extdata = eval(payload.get("ext"))["runStatus"] # extdata = payload.get("ext")['runStatus'] # 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!----->") # if QXZAutoswitch.objects.filter(equip_id=imei).exists(): # print("<-----this autoswitch is existed!----->") # try: # sta = QXZAutoswitch.objects.get(equip_id=imei) # sta.qxz_auto=extdata # sta.save() # print("<-----switchstatus update success!----->") # except: # print("<-----switchstatus update failed!----->") # else: # # 设备阈值表不存在、创建阈值表： # print("<-----this switch autoswitch is not existed!----->") # try: # QXZAutoswitch.objects.create(equip_id=e_id, qxz_auto=extdata) # print("<-----this autoswitch table re-create successed!----->") # except: # print("<-----this autoswitch table re-create failed!----->") # elif payload.get("cmd") == "timing": # extdata = payload.get("ext")['setTime'] # 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!----->") # if QXZTimingswitch.objects.filter(equip_id=imei).exists(): # print("<-----this timingstatus is existed!----->") # try: # sta = QXZTimingswitch.objects.get(equip_id=imei) # sta.qxz_timing=extdata # sta.save() # print("<-----timingstatus update success!----->") # except: # print("<-----timingstatus update failed!----->") # else: # # 设备阈值表不存在、创建阈值表： # print("<-----this switch timingstatus is not existed!----->") # try: # QXZTimingswitch.objects.create(equip_id=e_id, qxz_timing=extdata) # print("<-----this timingstatus table re-create successed!----->") # except: # print("<-----this timingstatus table re-create failed!----->") elif payload.get("cmd") == "Status": extdata = payload.get("ext")['terminalStatus'] print(extdata) try: volt = extdata["VOLT"] rssi = extdata["RSSI"] iccid = extdata["ICCID"] lng = extdata["longitude"] lat = extdata["latitude"] led = extdata["Dotled"] except: pass try: dver = extdata["Version"] except: dver = "" 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!----->") QXZ_Info_Record.objects.create(equip_id=e_id, volt=volt,rssi=rssi) if QXZ_Base_Info.objects.filter(equip_id=imei).exists(): print("<-----this qxz_base_info is existed!----->") try: sta = QXZ_Base_Info.objects.get(equip_id=imei) sta.volt = volt sta.rssi = rssi sta.iccid = iccid sta.lng = lng sta.lat = lat sta.led = led sta.dver = dver sta.save() sta1 = QXZstatus.objects.get(equip_id=imei) sta1.lng = lng sta1.lat = lat sta1.save() print("<-----qxz_base_info update success!----->") except: print("<-----qxz_base_info update failed!----->") try: sta = QXZ_Base_Info.objects.get(equip_id=imei) sta.volt = volt sta.rssi = rssi sta.save() print("<-----qxz_base_info update success!!!----->") except: pass else: # 设备阈值表不存在、创建阈值表： print("<-----this qxz_base_info is not existed!----->") try: QXZ_Base_Info.objects.create(equip_id=e_id, volt=volt,rssi=rssi,iccid=iccid,lng=lng,lat=lat,led=led) print("<-----this qxz_base_info table re-create successed!----->") except: print("<-----this qxz_base_info table re-create failed!----->") # 离线消息： elif "offline" in msg.topic: try: # 将json字符串解析： payload = json.loads(msg.payload.decode()) if payload.get("cmd") == "offline": print("<-----离线消息!----->") print("%s is offline!" % imei) qxz_exist = Equip.objects.filter(equip_id=imei) # 设备存在，进一步判断状态表是否存在： if qxz_exist.exists(): try: e_id = Equip.objects.get(equip_id=imei) # now_time = json.dumps(datetime.datetime.now(), cls=CJSONEncoder) # 更新状态表中未离线状态： QXZstatus_New.objects.filter(equip_id=imei).update(is_online = '0',off_time = datetime.datetime.now()) # 创建预警记录： Alarm_record.objects.create(equip_id=e_id, alarm_desc="{'status':0,'type':'offline'}",e_type="2") print("update offline ok!") except: print("update offline failed!") else: print("this imei is not exist!") elif payload.get("cmd") == "online": print("<-----在线消息!----->") print("%s is offline!" % imei) qxz_exist = Equip.objects.filter(equip_id=imei) # 设备存在，进一步判断状态表是否存在： if qxz_exist.exists(): try: e_id = Equip.objects.get(equip_id=imei) # now_time = json.dumps(datetime.datetime.now(), cls=CJSONEncoder) # 更新状态表中未离线状态： QXZstatus_New.objects.filter(equip_id=imei).update(is_online = '1') # 创建预警记录： Alarm_record.objects.create(equip_id=e_id, alarm_desc="{'status': 'relink', 'type': 'dev_sta'}",e_type="5") print("update online ok!") except: print("update online failed!") else: print("this imei is not exist!") except: pass except Exception as e: print(e) pass if __name__ == '__main__': client = mqtt.Client( client_id="PY_MQTT_CLIENTC_QXZ_NEW", clean_session=True, userdata=None, # protocol=MQTTv311,# 数据库版本 ) # 必须设置，否则会返回「Connected with result code 4」 client.username_pw_set("admin", "password") client.on_connect = on_connect client.on_message = on_message HOST = "127.0.0.1" client.connect(HOST, 1883, 60) client.loop_forever()