update, duplicate
This commit is contained in:
13
.hintrc
Normal file
13
.hintrc
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
{
|
||||||
|
"extends": [
|
||||||
|
"development"
|
||||||
|
],
|
||||||
|
"hints": {
|
||||||
|
"axe/text-alternatives": [
|
||||||
|
"default",
|
||||||
|
{
|
||||||
|
"image-alt": "off"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -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
50
src/get_data.php
Normal 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();
|
||||||
@@ -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>
|
</html>
|
||||||
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
Reference in New Issue
Block a user