diff --git a/MQTT_MySQL.py b/MQTT_MySQL.py index d2c0443a26c28fe9339615e1226e96a8030036a2..7814e50c0acbd8598ae44fba659fabb64efbb3cc 100644 --- a/MQTT_MySQL.py +++ b/MQTT_MySQL.py @@ -2,6 +2,7 @@ import MySQLdb import paho.mqtt.client as mqtt import time import sys +from datetime import datetime db = MySQLdb.connect(host="pil-09.univlehavre.lan", user="firediag", @@ -44,9 +45,9 @@ def on_message(client, userdata, msg): if capteur[0] == message_topic: try: cursor.execute("INSERT INTO `valeur` (`temps`, `valeur`, `idCapteur`) VALUES ('"+ - time.strftime('%Y-%m-%d %H:%M:%S')+"', '"+str(message_valeur)+"', '"+str(capteur[1])+"')"); + datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')+"', '"+str(message_valeur)+"', '"+str(capteur[1])+"')"); - print("Nouvelle valeur ('"+time.strftime('%Y-%m-%d %H:%M:%S')+"', '"+str(message_valeur)+"', '"+str(capteur[1])+"')"); + print("Nouvelle valeur ('"+datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')+"', '"+str(message_valeur)+"', '"+str(capteur[1])+"')"); if unicode(str(message_valeur).strip(), 'utf-8').isnumeric(): # Si c'est une valeur numerique # Gestion des notifications des utilisateurs (ajout des alertes) @@ -76,7 +77,7 @@ def on_message(client, userdata, msg): message += str(int(seuil[2]))+")" ; cursorNotif.execute("INSERT INTO `notification` (`temps`, `titre`, `message`, `idUser`, `idCapteur`, `vu`) VALUES ('"+ - time.strftime('%Y-%m-%d %H:%M:%S')+"', '"+titre+"', '"+message+"', '"+str(capteur[2])+"', '"+str(capteur[1])+"', false)") + datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')+"', '"+titre+"', '"+message+"', '"+str(capteur[2])+"', '"+str(capteur[1])+"', false)") # notification du changement client.publish("/system/notification/"+str(capteur[2]), str(capteur[4])+"/"+str(capteur[1])); diff --git a/application/models/Valeur_model.php b/application/models/Valeur_model.php index 0aa90b1f27b216a179a66d76cb66753b3cdd93de..b41821940b2dda54314844e0fbdca3501512fd4b 100644 --- a/application/models/Valeur_model.php +++ b/application/models/Valeur_model.php @@ -9,8 +9,12 @@ class Valeur_model extends CI_Model { $this->db->set('idCapteur', $idCapteur); $this->db->set('valeur', $valeur); + $t = microtime(true); + $micro = sprintf("%06d",($t - floor($t)) * 1000000); + $d = new DateTime( date('Y-m-d H:i:s.'.$micro, $t) ); + // Ces données ne seront pas échappées - $this->db->set('temps', 'NOW()', false); + $this->db->set('temps', $d->format("Y-m-d H:i:s.u")); // Une fois que tous les champs ont bien été définis, on "insert" le tout return $this->db->insert($this->table);