Commit 093d643d authored by Bruno Thomazi Zanette's avatar Bruno Thomazi Zanette 🎱
Browse files

Update Programa_inicial_server.py

parent bf53c87f
...@@ -56,6 +56,22 @@ def on_message(client, userdata, message): # Funcao que roda toda vez que se rec ...@@ -56,6 +56,22 @@ def on_message(client, userdata, message): # Funcao que roda toda vez que se rec
colunas="hora,local,intensidade" colunas="hora,local,intensidade"
valores= str(hora)+","+str(loca)+","+str(inte) valores= str(hora)+","+str(loca)+","+str(inte)
today = datetime.now()
hoje = " " + today.strftime("%Y|%m|%d %H:%M:%S")
# Checa o usuario
usuarios_cadastrados = check_usuario()
for x in usuarios_cadastrados:
d=0
usuario_comparacao= str(usua)[1:-1]
if (usuario_comparacao == str(x)[2:-3]):
d=1
break
if ( d == 0 ):
mensag = "usuario não cadastrado: "+usua
print( mensag+ str(hoje),file = open(output,'a'))
client.publish("feedback", mensag)
# Checa o Hash # Checa o Hash
string = str(hora)+str(loca)+str(inte)+str(temp)+str(umid)+str(pres)+usua string = str(hora)+str(loca)+str(inte)+str(temp)+str(umid)+str(pres)+usua
result = hashlib.md5(string.encode()) result = hashlib.md5(string.encode())
...@@ -65,28 +81,44 @@ def on_message(client, userdata, message): # Funcao que roda toda vez que se rec ...@@ -65,28 +81,44 @@ def on_message(client, userdata, message): # Funcao que roda toda vez que se rec
if (hash2==hash1): # só manda para o BD se o HASH for igual if (hash2==hash1): # só manda para o BD se o HASH for igual
client.publish("feedback","dadosHASH confere") client.publish("feedback","dadosHASH confere")
# intensidade > 0
if (inte<0):
mensag = "intensidade menor que zero"
print( mensag+str(hoje),file = open(output,'a'))
client.publish("feedback",mensag)
else:
colunas += ",intensidade"
valores += "," + str(inte)
# Checa se temp está entre o zero absoluto e um número grande para todas escalas (C° K F°) # Checa se temp está entre o zero absoluto e um número grande para todas escalas (C° K F°)
if (-274>temp or umid>1000): if (-274>temp or umid>1000):
client.publish("feedback","temperatura errada") mensag = "temperatura errada"
print( mensag+str(hoje),file = open(output,'a'))
client.publish("feedback",mensag)
else: else:
colunas += ",temperatura" colunas += ",temperatura"
valores += "," + str(temp) valores += "," + str(temp)
# Checa se umidade está entre 0% e 100% # Checa se umidade está entre 0% e 100%
if (0>umid or umid>100): if (0>umid or umid>100):
client.publish("feedback","umidade errada") mensag= "umidade errada"
print( mensag+str(hoje),file = open(output,'a'))
client.publish("feedback",mensag)
else: else:
colunas += ",umidade" colunas += ",umidade"
valores += "," + str(umid) valores += "," + str(umid)
# Pressao > 0 # Pressao > 0
if (pres<=0): if (pres<=0):
client.publish("feedback","pressao menor que zero") mensag = "pressao menor que zero"
print( mensag+str(hoje),file = open(output,'a'))
client.publish("feedback",mensag)
else: else:
colunas += ",pressao" colunas += ",pressao"
valores += "," + str(pres) valores += "," + str(pres)
#valores que completam a string
colunas += ",usuario,HASH" colunas += ",usuario,HASH"
valores += ","+usua+","+hash valores += ","+usua+","+hash
...@@ -96,8 +128,10 @@ def on_message(client, userdata, message): # Funcao que roda toda vez que se rec ...@@ -96,8 +128,10 @@ def on_message(client, userdata, message): # Funcao que roda toda vez que se rec
db_connection.commit() # executa o comando do curso db_connection.commit() # executa o comando do curso
else: #caso hash não confira elif(d==1): #caso hash não confira
client.publish("feedback", "HASH diferentes hash1: "+hash1+"hash2: "+hash2) mensag = "HASH diferentes hash1: "+hash1+"hash2: "+hash2
print( mensag+str(hoje),file = open(output,'a'))
client.publish("feedback", mensag)
############ Subscribe ao tópico ############ ############ Subscribe ao tópico ############
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment