163 lines
4.9 KiB
Python
Executable file
163 lines
4.9 KiB
Python
Executable file
#!/usr/bin/env python3
|
|
"""Heizraum I/O Zeilen am Heizung-Dashboard (idempotent)."""
|
|
import json
|
|
import subprocess
|
|
|
|
BASE = "http://100.66.78.56:3000"
|
|
DS_UID = "ffptl25vzylfke" # InfluxDB-sensors
|
|
ROW_IN = "⚡ Heizraum Eingänge (Optokoppler)"
|
|
ROW_OUT = "🔌 Heizraum Ausgänge"
|
|
PANEL_IDS = list(range(910, 920))
|
|
|
|
|
|
def curl(path, method="GET", body=None):
|
|
cmd = ["curl", "-s", "-u", "admin:astral66", "-X", method, f"{BASE}{path}"]
|
|
if body is not None:
|
|
cmd += ["-H", "Content-Type: application/json", "-d", json.dumps(body)]
|
|
r = subprocess.run(cmd, capture_output=True, text=True, timeout=30)
|
|
return json.loads(r.stdout) if r.stdout.startswith(("{", "[")) else r.stdout
|
|
|
|
|
|
def io_stat(pid, title, signal, x, y, w=4, h=4, on_text="AN", off_text="AUS"):
|
|
return {
|
|
"id": pid,
|
|
"type": "stat",
|
|
"title": title,
|
|
"description": (
|
|
f"Heizraum-Knoten Eingang `{signal}` (GPIO Optokoppler, active-low). "
|
|
f"MQTT: heizraum/io/{signal}" if signal != "kessel" else
|
|
"Kessel-Schaltausgang GPIO16 (Relais). 1=abgeschaltet, 0=freigegeben. "
|
|
"MQTT: heizraum/state/kessel"
|
|
),
|
|
"datasource": {"type": "influxdb", "uid": DS_UID},
|
|
"gridPos": {"h": h, "w": w, "x": x, "y": y},
|
|
"fieldConfig": {
|
|
"defaults": {
|
|
"mappings": [
|
|
{
|
|
"type": "value",
|
|
"options": {
|
|
"1": {"text": on_text, "color": "green" if signal != "kessel" else "red", "index": 0},
|
|
"0": {"text": off_text, "color": "red" if signal != "kessel" else "green", "index": 1},
|
|
},
|
|
},
|
|
],
|
|
"noValue": off_text,
|
|
"color": {"mode": "thresholds"},
|
|
"thresholds": {
|
|
"mode": "absolute",
|
|
"steps": [
|
|
{"color": "red" if signal != "kessel" else "green", "value": None},
|
|
{"color": "green" if signal != "kessel" else "red", "value": 1},
|
|
],
|
|
},
|
|
}
|
|
},
|
|
"options": {
|
|
"reduceOptions": {"values": False, "calcs": ["lastNotNull"]},
|
|
"colorMode": "background",
|
|
"graphMode": "none",
|
|
},
|
|
"targets": [{
|
|
"refId": "A",
|
|
"rawQuery": True,
|
|
"query": (
|
|
f'SELECT last("value") FROM "io_state" '
|
|
f"WHERE \"node\"='heizraum' AND \"signal\"='{signal}'"
|
|
),
|
|
}],
|
|
}
|
|
|
|
|
|
d = curl("/api/dashboards/uid/heizung")
|
|
dash = d["dashboard"]
|
|
|
|
remove_titles = {
|
|
ROW_IN, ROW_OUT,
|
|
"Pumpe 1", "Pumpe 2", "Pumpe 3", "Pumpe 4", "Brenner",
|
|
"Kessel (Ausgang)",
|
|
}
|
|
dash["panels"] = [
|
|
p for p in dash["panels"]
|
|
if p.get("title") not in remove_titles and p.get("id") not in PANEL_IDS
|
|
]
|
|
|
|
max_y = 0
|
|
for p in dash["panels"]:
|
|
gp = p.get("gridPos", {})
|
|
max_y = max(max_y, gp.get("y", 0) + gp.get("h", 0))
|
|
|
|
y = max_y
|
|
|
|
# --- Eingänge ---
|
|
dash["panels"].append({
|
|
"id": 910,
|
|
"type": "row",
|
|
"title": ROW_IN,
|
|
"gridPos": {"h": 1, "w": 24, "x": 0, "y": y},
|
|
"collapsed": False,
|
|
})
|
|
y += 1
|
|
|
|
inputs = [
|
|
(911, "Pumpe 1", "pumpe1", 0),
|
|
(912, "Pumpe 2", "pumpe2", 4),
|
|
(913, "Pumpe 3", "pumpe3", 8),
|
|
(914, "Pumpe 4", "pumpe4", 12),
|
|
(915, "Brenner", "brenner", 16),
|
|
]
|
|
for pid, title, signal, x in inputs:
|
|
dash["panels"].append(io_stat(pid, title, signal, x, y))
|
|
y += 4
|
|
|
|
# --- Ausgänge ---
|
|
dash["panels"].append({
|
|
"id": 916,
|
|
"type": "row",
|
|
"title": ROW_OUT,
|
|
"gridPos": {"h": 1, "w": 24, "x": 0, "y": y},
|
|
"collapsed": False,
|
|
})
|
|
y += 1
|
|
|
|
dash["panels"].append(
|
|
io_stat(917, "Kessel (Ausgang)", "kessel", 0, y, on_text="ABGESCHALTET", off_text="FREIGEGEBEN")
|
|
)
|
|
|
|
# Verlauf aller IO-Signale
|
|
dash["panels"].append({
|
|
"id": 918,
|
|
"type": "timeseries",
|
|
"title": "Heizraum I/O Verlauf",
|
|
"description": "Eingänge (Pumpen/Brenner) und Kessel-Ausgang über Zeit.",
|
|
"datasource": {"type": "influxdb", "uid": DS_UID},
|
|
"gridPos": {"h": 8, "w": 24, "x": 0, "y": y + 4},
|
|
"fieldConfig": {
|
|
"defaults": {
|
|
"custom": {"drawStyle": "line", "lineWidth": 2, "spanNulls": 60000, "showPoints": "never"},
|
|
"min": 0,
|
|
"max": 1,
|
|
}
|
|
},
|
|
"options": {
|
|
"legend": {"displayMode": "table", "placement": "bottom", "calcs": ["last"]},
|
|
},
|
|
"targets": [{
|
|
"refId": "A",
|
|
"rawQuery": True,
|
|
"query": (
|
|
'SELECT mean("value") FROM "io_state" '
|
|
"WHERE \"node\"='heizraum' AND $timeFilter "
|
|
"GROUP BY time($__interval), \"signal\" fill(null)"
|
|
),
|
|
}],
|
|
})
|
|
|
|
dash["version"] = dash.get("version", 0) + 1
|
|
resp = curl("/api/dashboards/db", "POST", {
|
|
"dashboard": dash,
|
|
"folderId": 0,
|
|
"overwrite": True,
|
|
"message": "Heizraum I/O Eingänge und Ausgänge",
|
|
})
|
|
print(json.dumps(resp, indent=2)[:600])
|