a

ReadMe.md

@@ -12,13 +12,13 @@ Welkom bij ons project genaamd "GoodGarden". Wij hebben besloten om er een monol
 
 Zorg dat je in de hoofdmap "GoodGarden" zit. Kijk in je path: "/GoodGarden". Als je in de correcte map zit moet je de volgende items installeren:
 
-    - npm install electron
+     npm install electron
-    - npm install express
+     npm install express
-    - npm install body-parser
+     npm install body-parser
-    - npm install python-shell
+     npm install python-shell
 
-    - pip install mysql-connector-python
+     pip install mysql-connector-python
-    - pip install requests
+     pip install requests
 
 ## Gebruik
 

battery_voltage_events.py

@@ -1,246 +0,0 @@
-import mysql.connector
-import requests
-from datetime import datetime, timezone, timedelta
-import time
-import GoodGarden.servermqtt as servermqtt
-
-# Function to make a connection to the database
-def database_connect():
-    return mysql.connector.connect(
-        host="localhost",
-        user="root",
-        password="",
-        database="goodgarden"
-    )
-
-def calculate_timestamp(gateway_receive_time):
-    # Converteer de stringrepresentatie naar een datetime-object in UTC
-    datetime_obj_utc = datetime.strptime(gateway_receive_time, "%Y-%m-%dT%H:%M:%SZ").replace(tzinfo=timezone.utc)
-    
-    # Voeg het tijdsverschil van 1 uur toe voor de Nederlandse tijdzone (UTC+1)
-    datetime_obj_nl = datetime_obj_utc + timedelta(hours=1)
-
-    # Formateer het datetime-object als een leesbare datumstring
-    formatted_date = datetime_obj_nl.strftime("%Y-%m-%d %H:%M:%S")
-    return formatted_date
-
-# Functie voor het aanmaken van gegevens in de database
-# ...
-
-# Functie voor het aanmaken van gegevens in de database
-# Functie voor het aanmaken van gegevens in de database
-def create_data(url, access_token, repeat_count=5):
-    for _ in range(repeat_count):
-        try:
-            headers = {"Authorization": f"Token {access_token}"}
-            response = requests.get(url, headers=headers)
-            response.raise_for_status()
-
-            data = response.json()
-            print(f"Data from {url}:\n")
-
-            # Check if data is a list (records directly under the root)
-            if isinstance(data, list):
-                records = data
-            elif isinstance(data, dict) and 'results' in data:
-                records = data['results']
-            else:
-                print(f"Unexpected data format received: {data}")
-                continue
-
-            for record in records:
-                # Now, record is assumed to be a dictionary
-                timestamp = record.get('timestamp', '')
-                gateway_receive_time = record.get('gateway_receive_time', '')
-                device = record.get('device', '')
-                value = record.get('value', '')
-
-                # Voeg de timestamp-berekening toe
-                calculated_timestamp = calculate_timestamp(gateway_receive_time)
-
-                print(f"\nInserted data: Timestamp: {calculated_timestamp}, Device: {device}, Battery Voltage: {value}V\n")
-                if float(value) < 3.0:
-                    print("Waarschuwing: Batterijspanning is lager dan 3.0 volt. Opladen aanbevolen.\n")
-                # Controleer of de batterijspanning hoger is dan 4.2 volt en geef een melding
-                elif float(value) > 4.2:
-                    print("Melding: Batterijspanning is hoger dan 4.2 volt. Batterij is vol.\n")
-                else:
-                    print("Melding: Batterijspanning is binnen het gewenste bereik.\n\n")
-
-                # Insert data into the database
-                insert_data(record)
-
-        except requests.exceptions.RequestException as e:
-            print(f"Error fetching data from {url}: {e}")
-
-        print("Waiting for the next create action...\n")
-        time.sleep(1)
-
-
-# Functie voor het invoegen van gegevens in de database
-def insert_data(record):
-    mydb = database_connect()
-    if mydb.is_connected():
-        mycursor = mydb.cursor()
-
-        # Hier moet je de juiste kolomnamen en gegevensindeling aanpassen op basis van de API-respons
-        insert_query = """
-        INSERT INTO goodgarden.battery_voltage_events (timestamp, gateway_receive_time, device, value)
-        VALUES (%s, %s, %s, %s)
-        """
-        # Pas dit aan op basis van de werkelijke structuur van de JSON
-        timestamp = calculate_timestamp(record.get('gateway_receive_time', ''))
-        gateway_receive_time = record.get('gateway_receive_time', '')
-        device = record.get('device', '')
-        value = record.get('value', '')
-
-        print(f"Inserting data: timestamp={timestamp}, gateway_receive_time={gateway_receive_time}, device={device}, value={value}")  # Print de ingevoerde gegevens
-
-        # Voer de query uit
-        mycursor.execute(insert_query, (timestamp, gateway_receive_time, device, value))
-
-        # Bevestig de wijzigingen
-        mydb.commit()
-
-        # Sluit cursor en verbinding
-        mycursor.close()
-        mydb.close()
-
-        print("Data inserted into the database.")
-
-
-
-# Functie voor het lezen van gegevens uit de database
-def read_data(url, access_token, repeat_count=5):
-    for _ in range(repeat_count):
-        try:
-            headers = {"Authorization": f"Token {access_token}"}
-            response = requests.get(url, headers=headers)
-            response.raise_for_status()
-            
-            data = response.json()
-            print(f"Data from {url}:\n")
-            
-            for record in data['results']:
-                timestamp = record.get('timestamp', '')
-                device = record.get('device', '')
-                value = record.get('value', '')
-                print(f"Timestamp: {timestamp}, Device: {device}, Battery Voltage: {value}V\n")
-
-                if float(value) < 3.0:
-                    print("Waarschuwing: Batterijspanning is lager dan 3.0 volt. Opladen aanbevolen.\n")
-                # Controleer of de batterijspanning hoger is dan 4.2 volt en geef een melding
-                elif float(value) > 4.2:
-                    print("Melding: Batterijspanning is hoger dan 4.2 volt. Batterij is vol.\n")
-                else:
-                    print("Melding: Batterijspanning is binnen het gewenste bereik.\n\n")
-
-        except requests.exceptions.RequestException as e:
-            print(f"Error fetching data from {url}: {e}")
-
-        print("Waiting for the next read action...\n")
-        time.sleep(300)
-
-# Functie voor het bijwerken van gegevens in de database
-def update_data(record_id):
-    try:
-        mydb = database_connect()
-
-        if mydb.is_connected():
-            mycursor = mydb.cursor()
-
-            # Controleer of het record bestaat voordat je het bijwerkt
-            mycursor.execute("SELECT * FROM goodgarden.battery_voltage_events WHERE id = %s", (record_id,))
-            existing_record = mycursor.fetchone()
-
-            if not existing_record:
-                print(f"Record with ID {record_id} not found. Update operation aborted.")
-                return
-
-            # Vraag de gebruiker om nieuwe waarden voor de andere velden
-            new_timestamp = input("Enter new timestamp: ")
-            new_gateway_receive_time = input("Enter new gateway_receive_time: ")
-            new_device = input("Enter new device: ")
-            new_value = input("Enter new value: ")
-
-            # Hier moet je de juiste kolomnamen aanpassen op basis van de structuur van je database
-            update_query = """
-            UPDATE goodgarden.battery_voltage_events
-            SET timestamp = %s, gateway_receive_time = %s, device = %s, value = %s
-            WHERE id = %s
-            """
-
-            # Voer de query uit
-            print(f"Executing update query: {update_query}")
-            print(f"Updating record with ID {record_id} to new values - timestamp: {new_timestamp}, gateway_receive_time: {new_gateway_receive_time}, device: {new_device}, value: {new_value}")
-
-            mycursor.execute(update_query, (new_timestamp, new_gateway_receive_time, new_device, new_value, record_id))
-
-            # Bevestig de wijzigingen
-            mydb.commit()
-
-            print(f"Update executed. Rowcount: {mycursor.rowcount}")
-
-    except mysql.connector.Error as update_err:
-        print(f"Error updating data: {update_err}")
-    finally:
-        # Zorg ervoor dat je altijd de cursor en de databaseverbinding sluit
-        if 'mycursor' in locals() and mycursor is not None:
-            mycursor.close()
-        if 'mydb' in locals() and mydb.is_connected():
-            mydb.close()
-
-# Functie voor het verwijderen van gegevens uit de database
-def delete_data(record_id):
-    mydb = database_connect()
-    if mydb.is_connected():
-        mycursor = mydb.cursor()
-
-        # Hier moet je de juiste kolomnamen aanpassen op basis van de structuur van je database
-        delete_query = """
-        DELETE FROM goodgarden.battery_voltage_events
-        WHERE id = %s
-        """
-
-        # Voer de query uit
-        mycursor.execute(delete_query, (record_id,))
-
-        # Bevestig de wijzigingen
-        mydb.commit()
-
-        # Sluit cursor en verbinding
-        mycursor.close()
-        mydb.close()
-
-        print(f"Data with ID {record_id} deleted.")
-
-# Functie voor het aanmaken van gegevens in de database op basis van batterijspanningsinformatie
-
-if __name__ == "__main__":
-    url = "https://garden.inajar.nl/api/battery_voltage_events/?format=json"
-    access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c"  # Vervang dit door je werkelijke toegangstoken
-    
-    # Je kunt repeat_count wijzigen om te bepalen hoe vaak je de bewerking wilt herhalen
-    repeat_count = 10
-    
-    # Keuze voor de bewerking
-    operation_choice = input("Choose operation (C for Create, R for Read, U for Update, D for Delete): ").upper()
-
-    if operation_choice == "C":
-        # Maak gegevens aan
-        create_data(url, access_token, repeat_count)
-    elif operation_choice == "R":
-        # Lees gegevens
-        read_data(url, access_token, repeat_count)
-    elif operation_choice == "U":
-        # Update gegevens
-        record_id = int(input("Enter record ID to update: "))
-        # Call the update_data function without additional arguments
-        update_data(record_id)
-    elif operation_choice == "D":
-        # Verwijder gegevens
-        record_id = int(input("Enter record ID to delete: "))
-        delete_data(record_id)
-    else:
-        print("Invalid operation choice. Please choose C, R, U, or D.")
-

src/package.json

@@ -14,7 +14,7 @@
   "dependencies": {
     "body-parser": "^1.20.2",
     "elctron": "^0.0.1-security",
-    "express": "^4.18.2",
+    "express": "^4.18.3",
     "mysql2": "^3.9.1",
     "python-shell": "^5.0.0"
   }

src/py/script/app.py

@@ -19,7 +19,7 @@ def get_api_data():
 
 @app.route('/')
 def index():
-    return render_template('index.html')
+    return render_template('kas_informatie.html')
 
 @app.route('/battery_voltage_events')
 def battery_voltage_events():

src/py/script/battery_voltage_events.py

@@ -181,8 +181,9 @@ import mysql.connector
 import requests
 from datetime import datetime, timezone, timedelta
 import time
+import GoodGarden.src.py.servermqtt as servermqtt
 
-# Functie om verbinding te maken met de database
+# Function to make a connection to the database
 def database_connect():
     return mysql.connector.connect(
         host="localhost",
@@ -196,12 +197,16 @@ def calculate_timestamp(gateway_receive_time):
     datetime_obj_utc = datetime.strptime(gateway_receive_time, "%Y-%m-%dT%H:%M:%SZ").replace(tzinfo=timezone.utc)
     
     # Voeg het tijdsverschil van 1 uur toe voor de Nederlandse tijdzone (UTC+1)
-    datetime_obj_nl = datetime_obj_utc + timedelta(hours=0)
+    datetime_obj_nl = datetime_obj_utc + timedelta(hours=1)
 
     # Formateer het datetime-object als een leesbare datumstring
     formatted_date = datetime_obj_nl.strftime("%Y-%m-%d %H:%M:%S")
     return formatted_date
 
+# Functie voor het aanmaken van gegevens in de database
+# ...
+
+# Functie voor het aanmaken van gegevens in de database
 # Functie voor het aanmaken van gegevens in de database
 def create_data(url, access_token, repeat_count=5):
     for _ in range(repeat_count):
@@ -232,7 +237,7 @@ def create_data(url, access_token, repeat_count=5):
                 # Voeg de timestamp-berekening toe
                 calculated_timestamp = calculate_timestamp(gateway_receive_time)
 
-                print(f"\nInserted data: Timestamp: {calculated_timestamp}, Device: {device}, Battery Voltage: {value}V")
+                print(f"\nInserted data: Timestamp: {calculated_timestamp}, Device: {device}, Battery Voltage: {value}V\n")
                 if float(value) < 3.0:
                     print("Waarschuwing: Batterijspanning is lager dan 3.0 volt. Opladen aanbevolen.\n")
                 # Controleer of de batterijspanning hoger is dan 4.2 volt en geef een melding
@@ -248,7 +253,8 @@ def create_data(url, access_token, repeat_count=5):
             print(f"Error fetching data from {url}: {e}")
 
         print("Waiting for the next create action...\n")
-        time.sleep(2)
+        time.sleep(1)
+
 
 # Functie voor het invoegen van gegevens in de database
 def insert_data(record):
@@ -267,7 +273,7 @@ def insert_data(record):
         device = record.get('device', '')
         value = record.get('value', '')
 
-        print(f"Inserting data: timestamp={timestamp}, gateway_receive_time={gateway_receive_time}, device={device}, value={value}\n\n")  # Print de ingevoerde gegevens
+        print(f"Inserting data: timestamp={timestamp}, gateway_receive_time={gateway_receive_time}, device={device}, value={value}")  # Print de ingevoerde gegevens
 
         # Voer de query uit
         mycursor.execute(insert_query, (timestamp, gateway_receive_time, device, value))
@@ -281,6 +287,8 @@ def insert_data(record):
 
         print("Data inserted into the database.")
 
+
+
 # Functie voor het lezen van gegevens uit de database
 def read_data(url, access_token, repeat_count=5):
     for _ in range(repeat_count):
@@ -386,6 +394,7 @@ def delete_data(record_id):
         print(f"Data with ID {record_id} deleted.")
 
 # Functie voor het aanmaken van gegevens in de database op basis van batterijspanningsinformatie
+
 if __name__ == "__main__":
     url = "https://garden.inajar.nl/api/battery_voltage_events/?format=json"
     access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c"  # Vervang dit door je werkelijke toegangstoken
@@ -413,3 +422,4 @@ if __name__ == "__main__":
         delete_data(record_id)
     else:
         print("Invalid operation choice. Please choose C, R, U, or D.")
+

static/index.js

@@ -1,17 +0,0 @@
-function executeOperation(operationChoice) {
-    fetch(`/battery_voltage_events?operation=${operationChoice}`)
-        .then(response => {
-            if (!response.ok) {
-                throw new Error(`HTTP error! Status: ${response.status}`);
-            }
-            return response.json();  // Gebruik response.json() om JSON-gegevens te parsen
-        })
-        .then(data => {
-            // Verwerk de gegevens zoals nodig
-            console.log(data);  // Bekijk de gegevens in de console
-        })
-        .catch(error => {
-            console.error('Error:', error);
-            alert(`An error occurred: ${error.message}`);
-        });
-}

templates/index.html

@@ -1,15 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Python Script Interaction</title>
-    <script src="{{ url_for('static', filename='index.js') }}"></script>
-</head>
-<body>
-    <h1>Choose Operation</h1>
-    <label for="operation_choice">Choose operation (C for Create, R for Read, U for Update, D for Delete): </label>
-    <input type="text" id="operation_choice" name="operation_choice" required>
-    <button onclick="executeOperation(document.getElementById('operation_choice').value)">Submit</button>
-</body>
-</html>