rasz/telecar
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfixes

Browse Source
This commit is contained in:
fabricio-rasz 2022-12-04 22:05:24 -03:00 committed by GitHub
parent 39feb3407e
commit e147e69d4b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
py/python-obd-device.py
View File

@ -77,17 +77,18 @@ class freeze_frame:
# Para criar o cliente mqtt: # Para criar o cliente mqtt:
# hostname, porta, topico, client_id, usuario, senha # hostname, porta, topico, client_id, usuario, senha
cliente_mqtt = mqtt_handle("XXXXXX", 1883, "XXXXXX/XXXXXX", "XXXXXX", "XXXXXX", "XXXXXX") cliente_mqtt = mqtt_handle("XXXXXXXXXXX", 1883, "XXXX/XXXXX", "XXXXXXXXXXX", "XXXXXXXXXXX", "XXXXXXXXXXX")
cliente_mqtt.connect() cliente_mqtt.connect()
#porta OBD #porta OBD
porta = "XXXXXX" porta = "XXXXXXXXXXX"
con = obd.OBD(porta) con = obd.OBD(porta)
while True: while True:
print(con.status()) print(con.status())
if con.status() == OBDStatus.CAR_CONNECTED: if con.status() == OBDStatus.CAR_CONNECTED:
data = dados() data = dados()
print("Coletando dados...") print("Coletando dados...")
try: try:
rpm = con.query(obd.commands.RPM) rpm = con.query(obd.commands.RPM)
speed = con.query(obd.commands.SPEED) speed = con.query(obd.commands.SPEED)
@ -102,25 +103,29 @@ while True:
continue continue
if not rpm.is_null(): if not rpm.is_null():
dados.RPM = rpm.value.magnitude data.RPM = rpm.value.magnitude
else:
con.close()
con = obd.OBD(porta)
continue
if not speed.is_null(): if not speed.is_null():
dados.VELOCIDADE = speed.value.magnitude data.VELOCIDADE = speed.value.magnitude
if not pedal.is_null(): if not pedal.is_null():
dados.PEDAL_ACELERADOR = pedal.value.magnitude data.PEDAL_ACELERADOR = pedal.value.magnitude
if not trouble.is_null(): if not trouble.is_null():
dados.MIL = trouble.value.MIL data.MIL = trouble.value.MIL
if not coolant.is_null(): if not coolant.is_null():
dados.TEMPERATURA_ARREFECIMENTO = coolant.value.magnitude data.TEMPERATURA_ARREFECIMENTO = coolant.value.magnitude
if not intake.is_null(): if not intake.is_null():
dados.TEMPERATURA_INTAKE = intake.value.magnitude data.TEMPERATURA_INTAKE = intake.value.magnitude
if dados.MIL == True: if data.MIL == True:
frame = freeze_frame() frame = freeze_frame()
try: try:
errors = con.query(obd.commands.GET_DTC) errors = con.query(obd.commands.GET_DTC)
@ -138,22 +143,24 @@ while True:
frame.TEMPERATURA_INTAKE = errors.value.magnitude frame.TEMPERATURA_INTAKE = errors.value.magnitude
errors = con.query(obd.commands.DTC_COOLANT_TEMP) errors = con.query(obd.commands.DTC_COOLANT_TEMP)
frame.TEMPERATURA_ARREFECIMENTO = errors.value.magnitude frame.TEMPERATURA_ARREFECIMENTO = errors.value.magnitude
dados.FREEZE_FRAME = frame data.FREEZE_FRAME = frame
except: except:
print("FAIL RECV DATA") print("FAIL RECV DATA")
con.close() con.close()
con = obd.OBD(porta) con = obd.OBD(porta)
continue continue
dados.timestamp = int(time.time()) data.timestamp = int(time.time())
try: try:
cliente_mqtt.publish(dados.toJson) cliente_mqtt.publish(data.toJson())
except: except:
print("FAIL SEND") print("FAIL SEND")
else: else:
print("FAIL CONNECT CAR") print("FAIL CONNECT CAR")
con.close() con.close()
con = obd.OBD(porta) con = obd.OBD(porta)
time.sleep(2)
con.close() con.close()