Homepage 1 sensor doet eht met data

src/py/script/devices.py

@@ -1,36 +1,54 @@
 import json
-
+from db_connect import database_connect
 from paho.mqtt import subscribe
 
 def on_message(client, userdata, message):
     payload_str = message.payload.decode("utf-8")
     data = json.loads(payload_str)
 
-    device_256 = None
-    last_seen = None
-    last_battery_voltage = None
+    # Verbinding maken met de database
+    mydb = database_connect()
 
-    device_322 = None
-    last_seen = None
-    last_battery_voltage = None
+    if mydb.is_connected():
+        
+        # Creëren van een cursor object
+        mycursor = mydb.cursor()
 
-    for key in data["results"]:
-        if int(key["id"]) == 256:
-            device_256 = int(key["id"])
-            last_seen = int(key["last_seen"])
-            last_battery_voltage = float(key["last_battery_voltage"])
-            # print(f"{device_256}")
-            print(f"Het device {device_256} is voor het laatst geien op: {last_seen} met de voltage als {last_battery_voltage}")
+        # SQL query voor het invoegen van de gegevens
+        insert_query = """
+        INSERT INTO goodgarden.devices
+        (serial_number, name, label, last_seen, last_battery_voltage, device_id)
+        VALUES (%s, %s, %s, %s, %s, %s)
+        """
 
-        elif int(key["id"]) == 322:
-            device_322 = int(key["id"])
-            last_seen = int(key["last_seen"])
-            last_battery_voltage = float(key["last_battery_voltage"])
-            # print(f"{device_256}")
-            print(f"Het device {device_322} is voor het laatst gezien op: {last_seen} met de voltage als {last_battery_voltage}")
+        # Verwerken van de gegevens uit het bericht
+        for record in data['results']:
+            serial_number = record.get('serial_number', '')
+            name = record.get('name', '')
+            label = record.get('label', '')
+            last_seen = record.get('last_seen', '')
+            last_battery_voltage = record.get('last_battery_voltage', '')
+            device_id = record.get("id", "")
+
+            print(f"Inserting data: serial_number={serial_number}, name={name}, label={label}, last_seen={last_seen}, last_battery_voltage={last_battery_voltage}, device_id={device_id}")
+
+            # Uitvoeren van de SQL query
+            mycursor.execute(insert_query, (serial_number, name, label, last_seen, last_battery_voltage, device_id))
+
+        # Commit de transacties naar de database
+        mydb.commit()
+
+        # Sluiten van de cursor en de databaseconnectie
+        mycursor.close()
+        mydb.close()
+
+        print("Data inserted into the database.")
+
+    else:
+        print("Failed to connect to the database.")
 
     print(f"\033[92mMessage received on topic\033[0m {message.topic}: {data}")
 
 if __name__ == "__main__":
     topic = "goodgarden/devices"
-    subscribe.callback(on_message, topic)
+    subscribe.callback(on_message, topic)

src/py/script/planten.py

@@ -47,3 +47,5 @@ def fetch_plant_and_write_to_json():
 
 # Call the function to fetch data and write to JSON
 fetch_plant_and_write_to_json()
+# if __name__ == "__main__":
+#     fetch_plant_and_write_to_json()

src/py/script/plants.json

@@ -15,31 +15,25 @@
         "id": 50,
         "plant_naam": "Appel",
         "plantensoort": "Fruit",
-        "plant_geteelt": 1
+        "plant_geteelt": 0
     },
     {
         "id": 51,
         "plant_naam": "Sla",
         "plantensoort": "Groente",
-        "plant_geteelt": 1
-    },
-    {
-        "id": 52,
-        "plant_naam": "Wietplant",
-        "plantensoort": "Onkruid",
-        "plant_geteelt": 1
+        "plant_geteelt": 0
     },
     {
         "id": 53,
         "plant_naam": "Patat",
         "plantensoort": "Aarde",
-        "plant_geteelt": 1
+        "plant_geteelt": 0
     },
     {
         "id": 54,
         "plant_naam": "asfasfas",
         "plantensoort": "fasfasfsaf",
-        "plant_geteelt": 1
+        "plant_geteelt": 0
     },
     {
         "id": 55,

src/py/script/servermqtt.py

@@ -1,74 +0,0 @@
-import os
-import time
-import requests
-import paho.mqtt.client as mqtt
-from dotenv import load_dotenv
-
-load_dotenv()
-
-API_URL = os.getenv("API_URL")
-MQTT_HOST = os.getenv("MQTT_HOST")
-MQTT_PORT = int(os.getenv("MQTT_PORT", 1883))
-
-def get_data_from_api(request):
-    links = {
-        'battery': '/battery_voltage_events/',
-        'devices': '/devices/',
-        'parEvents': '/par_events/',
-        'humidity': '/relative_humidity_events/',
-        'soilConductifity': '/soil_electric_conductivity_events/',
-        'soilPermittivity' : '/soil_relative_permittivity_events/',
-        'soilTemperature': '/soil_temperature_events/'
-    }
-    headers = {
-        'accept': 'application/json',
-        'Authorization': f'Token {os.getenv("API_TOKEN")}'
-    }
-    url = API_URL + links[request]
-    try:
-        response = requests.get(url, headers=headers)
-        response.raise_for_status()
-    except requests.exceptions.HTTPError as errh:
-        print ("HTTP Error:",errh)
-        return None
-    except requests.exceptions.ConnectionError as errc:
-        print ("Error Connecting:",errc)
-        return None
-    except requests.exceptions.Timeout as errt:
-        print ("Timeout Error:",errt)
-        return None
-    except requests.exceptions.RequestException as err:
-        print ("Something went wrong",err)
-        return None
-
-    data = response.json()
-    return data['results']
-
-def publish_to_mqtt(topic, message):
-    client = mqtt.Client()
-    client.connect(MQTT_HOST, MQTT_PORT, 60)
-    try:
-        client.publish(topic, message)
-    except mqtt.MQTTException as e:
-        print(f"Failed to publish message: {e}")
-    finally:
-        client.disconnect()
-
-def process_results(link, results):
-    for result in results:
-        if 'timestamp' in result and 'gateway_receive_time' in result and 'device' in result and 'value' in result:
-            message = f"Timestamp: {result['timestamp']}, Gateway Receive Time: {result['gateway_receive_time']}, Device: {result['device']}, Value: {result['value']}"
-            print(message)
-            publish_to_mqtt(link, message)
-
-def main():
-    links = ['battery', 'devices', 'parEvents', 'humidity', 'soilConductifity', 'soilPermittivity', 'soilTemperature']
-    while True:
-        for link in links:
-            results = get_data_from_api(link)
-            if results is not None:
-                process_results(link, results)
-        time.sleep(5)
-
-if __name__ == "__main__":
-    main()