send mqtt and neohub to new states-table

1 files changed, 7 insertions, 25 deletions

diff --git a/scripts/mqtt_listener.py b/scripts/mqtt_listener.py
index 6c617a5..48dfc6f 100644
--- a/scripts/mqtt_listener.py
+++ b/scripts/mqtt_listener.py
@@ -57,33 +57,15 @@ def on_message(client, userdata, msg):
                   data['voltage'],
                   data['linkquality'],
                   datetime.utcnow())
+        common.dbi(sql, values, verbose=True)
 
-    elif name in tempsensors and 'temperature' in data:
-        data['humidity'] = data['humidity'] if 'humidity' in data else None
-        data['voltage'] = data['voltage'] if 'voltage' in data else None
-        sql = """INSERT INTO mqtt_temps
-                        (sensor_id,
-                         temperature,
-                         humidity,
-                         battery,
-                         linkquality,
-                         voltage,
-                         time)
-                 SELECT sensors.id, %s, %s, %s, %s, %s, %s
-                    FROM sensors
-                    WHERE sensors.name = %s"""
-        values = (data['temperature'],
-                  data['humidity'],
-                  data['battery'],
-                  data['linkquality'],
-                  data['voltage'],
-                  datetime.utcnow(),
-                  name)
-
-    else:
-        return
+    if name in tempsensors:
+        if 'temperature' in data:
+            common.statein(name, data['temperature'], 'temperature', '°C', verbose=True)
+        if 'humidity' in data:
+            common.statein(name, data['humidity'], 'humidity', '%', verbose=True)
+        
 
-    common.dbi(sql, values, verbose=True)
 
 
 # mqtt