update, duplicate

This commit is contained in:
Burak
2024-03-12 12:01:42 +01:00
parent 0031bbe808
commit 0a8db9a840
4 changed files with 94 additions and 21 deletions

13
.hintrc Normal file
View File

@@ -0,0 +1,13 @@
{
"extends": [
"development"
],
"hints": {
"axe/text-alternatives": [
"default",
{
"image-alt": "off"
}
]
}
}

View File

@@ -17,12 +17,11 @@ def calculate_timestamp(gateway_receive_time):
datetime_obj_utc = datetime.strptime(gateway_receive_time, "%Y-%m-%dT%H:%M:%SZ").replace(tzinfo=timezone.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) # 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 # Formateer het datetime-object als een leesbare datumstring
formatted_date = datetime_obj_nl.strftime("%Y-%m-%d %H:%M:%S") formatted_date = datetime_obj_nl.strftime("%Y-%m-%d %H:%M:%S")
return formatted_date return formatted_date
# 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): def create_data(url, access_token, repeat_count=5):
for _ in range(repeat_count): for _ in range(repeat_count):
@@ -71,7 +70,6 @@ def create_data(url, access_token, repeat_count=5):
print("Waiting for the next create action...\n") print("Waiting for the next create action...\n")
time.sleep(2) time.sleep(2)
# Functie voor het invoegen van gegevens in de database
def insert_data(record): def insert_data(record):
mydb = database_connect() mydb = database_connect()
if mydb.is_connected(): if mydb.is_connected():
@@ -82,25 +80,30 @@ def insert_data(record):
INSERT INTO goodgarden.battery_voltage_events (timestamp, gateway_receive_time, device, value) INSERT INTO goodgarden.battery_voltage_events (timestamp, gateway_receive_time, device, value)
VALUES (%s, %s, %s, %s) 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}\n\n") # Print de ingevoerde gegevens try:
# Voer de query uit zonder de timestamp te berekenen
timestamp = record.get('timestamp', '')
gateway_receive_time = record.get('gateway_receive_time', '')
device = record.get('device', '')
value = record.get('value', '')
# Voer de query uit print(f"Inserting data: timestamp={timestamp}, gateway_receive_time={gateway_receive_time}, device={device}, value={value}\n") # Print de ingevoerde gegevens
mycursor.execute(insert_query, (timestamp, gateway_receive_time, device, value))
# Bevestig de wijzigingen mycursor.execute(insert_query, (timestamp, gateway_receive_time, device, value))
mydb.commit()
# Sluit cursor en verbinding # Bevestig de wijzigingen
mycursor.close() mydb.commit()
mydb.close()
print("Data inserted into the database.") print("Data inserted into the database.")
except mysql.connector.Error as err:
print(f"Error: {err}")
finally:
# Sluit cursor en verbinding
mycursor.close()
mydb.close()
# Functie voor het lezen van gegevens uit de database # Functie voor het lezen van gegevens uit de database
def read_data(url, access_token, repeat_count=5): def read_data(url, access_token, repeat_count=5):

50
src/get_data.php Normal file
View File

@@ -0,0 +1,50 @@
<?php
// Database-verbinding instellen (vervang deze gegevens door je eigen databasegegevens)
$servername = "localhost";
$username = "root";
$password = "";
$dbname = "goodgarden";
// Verbinding maken met de database
$conn = new mysqli($servername, $username, $password, $dbname);
// Controleren op een geslaagde verbinding
if ($conn->connect_error) {
die("Connection failed: " . $conn->connect_error);
}
// Query om gegevens op te halen uit de tabel devices
$query_devices = "SELECT * FROM devices";
$result_devices = $conn->query($query_devices);
// Query om gegevens op te halen uit de tabel battery_voltage_events
$query_battery_voltage = "SELECT * FROM battery_voltage_events";
$result_battery_voltage = $conn->query($query_battery_voltage);
// Query om gegevens op te halen uit de tabel fetch
$query_fetch = "SELECT * FROM fetch";
$result_fetch = $conn->query($query_fetch);
// Array om resultaten op te slaan
$data = array();
// Controleren of er resultaten zijn van de tabel devices
if ($result_devices->num_rows > 0) {
$data['devices'] = $result_devices->fetch_all(MYSQLI_ASSOC);
}
// Controleren of er resultaten zijn van de tabel battery_voltage_events
if ($result_battery_voltage->num_rows > 0) {
$data['battery_voltage_events'] = $result_battery_voltage->fetch_all(MYSQLI_ASSOC);
}
// Controleren of er resultaten zijn van de tabel fetch
if ($result_fetch->num_rows > 0) {
$data['fetch'] = $result_fetch->fetch_all(MYSQLI_ASSOC);
}
// Gegevens als JSON-uitvoer
echo json_encode($data);
// Verbinding sluiten
$conn->close();

View File

@@ -105,8 +105,15 @@
</article> </article>
</section> </section>
</section> </section>
<script>
// JavaScript-code om gegevens op te halen van het PHP-bestand
fetch('get_data.php')
.then(response => response.json())
.then(data => {
document.getElementById('totale_planten').innerHTML = data.totale_planten;
// Voeg andere velden toe op dezelfde manier
})
.catch(error => console.error('Error:', error));
</script>
</body> </body>
</html>
</body>
</html> </html>