EOS setup with solcast - tibber - energyforecast and EVCC - Guide & Issues

[XHalamaX]

Update 07.02.2025

I created a Node-Red flow and published it here
https://github.com/XHalamaX/EOS-EVCC-Node-Red-Integration

It's "working" but need some more fixes and optimizations. Most of this thread is outdated

---

Hi all,
I'm using EVCC to control my wallbox and my inverter to load the home battery today. This is working fine, but I would like to use EOS to get it more automated. Here I want to share the current status and ask for support to get this done. Maybe it helps others as well.

Basic Setup

Here is the planned setup

All these connections are working (technically).

Warning

Let me know if I missed any sensitive data in the text. This guide is still only for experienced users.
Please make sure to follow all security guidelines which are may be relevant.

Create all needed accounts

For this setup you need accounts on

Tibber

Tibber is used to get the next day "market" prices. The API can used more frequently but the available timespan is max 24h. That's why this "source" is not enough for me.
affiliate link - if I get any savings (in their shop) I will spent them to this project (mods can maybe also change the link if they want)
standard link

Create a API Token here

Energyforecast

Energyforcast fill the "tibber"-gap...a bit. Here we can get every day at around 15:00 a forecast for the next 48h which should reduce our issue. The API provides also the market prices but I want to consider the prices direct at 13:00, not 2h later.
Get a free account here
Get the API Key here

Solcast

I use Solcast to get the PV Power Forecast for my installation.
You can get a free account for "home hobbyist access" here
If you have more than 1 pv strings consider these workarounds. I have 4 pv strings and two inverter and that's why I created two sites and tried to combine the values.
You get the API Token here

Installation - EOS

Important

If docker is not installed, follow these guides

cd /opt
sudo git clone https://github.com/Akkudoktor-EOS/EOS.git
cd /opt/EOS
sudo docker compose up -d

Installation - Node-RED

Important

If docker is not installed, follow these guides

See here for running Node-RED via docker

If you can see the Node-RED interface on http://[YOUR-SERVER-IPADDRESS]:1880 you can proceed.

Installation - Influx DB

Important

If docker is not installed, follow these guides

See here for running Influx DB via docker

If you can see the Influx DB interface on http://[YOUR-SERVER-IPADDRESS]:8086 you can proceed.

Configuration - Influx DB

1. Login
2. Create some Buckets. I created a bucket per datasource (tibber,energyforecast,pvforecast,evcc)
3. Create a Telegraf config

You should adjust at least these values

YOUR-SERVER-IPADDRESS
YOUR-SOLCAST-SITE-ID-1
YOUR-SOLCAST-SITE-ID-2 (optional)
YOUR-SOLCAST-API-TOKEN
YOUR-ENERGYFORECAST-API-TOKEN
YOUR-TIBBER-HOME-ID
YOUR-TIBBER-API-TOKEN
YOUR-INFLUX-ORGANIZATION

click here to see the config

[global_tags]
  source = "unknown"
[agent]
  interval = "20s"
  round_interval = true
  metric_batch_size = 1000
  metric_buffer_limit = 10000
  collection_jitter = "0s"
  flush_interval = "10s"
  flush_jitter = "0s"
  precision = ""
  hostname = ""
  omit_hostname = false

[[outputs.influxdb_v2]]
  urls = ["http://YOUR-SERVER-IPADDRESS:8086"]
  token = "$INFLUX_TOKEN"
  organization = "YOUR-INFLUX-ORGANIZATION"
  bucket = "tibber"
  [outputs.influxdb_v2.tagpass]
    source = ["tibber"]

[[outputs.influxdb_v2]]
  urls = ["http://YOUR-SERVER-IPADDRESS:8086"]
  token = "$INFLUX_TOKEN"
  organization = "YOUR-INFLUX-ORGANIZATION"
  bucket = "energyforecast"
  [outputs.influxdb_v2.tagpass]
    source = ["energyforecast"]

[[outputs.influxdb_v2]]
  urls = ["http://YOUR-SERVER-IPADDRESS:8086"]
  token = "$INFLUX_TOKEN"
  organization = "YOUR-INFLUX-ORGANIZATION"
  bucket = "pvforecast"
  [outputs.influxdb_v2.tagpass]
    source = ["solcast"]

[[inputs.http]]
  name_override = "tibber"
  urls = ["https://api.tibber.com/v1-beta/gql"]
  method = "POST"
  timeout = "5s"
  interval = "30m"
  headers = { "Content-Type" = "application/json", "Authorization" = "Bearer YOUR-TIBBER-API-TOKEN" }
  body = '{ "query": "{viewer {home(id: \"YOUR-TIBBER-HOME-ID\") {currentSubscription {priceInfo {today {total energy tax startsAt }}}}}}" }'
  data_format = "json"
  json_query = "data.viewer.home.currentSubscription.priceInfo.today"
  json_time_key = "startsAt"
  json_time_format = "2006-01-02T15:04:05.000-07:00"
  [inputs.http.tags]
    source = "tibber"

[[inputs.http]]
  name_override = "tibber"
  urls = ["https://api.tibber.com/v1-beta/gql"]
  method = "POST"
  timeout = "5s"
  interval = "30m"
  headers = { "Content-Type" = "application/json", "Authorization" = "Bearer YOUR-TIBBER-API-TOKEN" }
  body = '{ "query": "{viewer {home(id: \"YOUR-TIBBER-HOME-ID\") {currentSubscription {priceInfo {tomorrow {total energy tax startsAt }}}}}}" }'
  data_format = "json"
  json_query = "data.viewer.home.currentSubscription.priceInfo.tomorrow"
  json_time_key = "startsAt"
  json_time_format = "2006-01-02T15:04:05.000-07:00"
  [inputs.http.tags]
    source = "tibber"

[[inputs.http]]
  name_override = "energyforecast"
  urls = ["https://www.energyforecast.de/api/v1/predictions/next_48_hours?token=YOUR-ENERGYFORECAST-API-TOKEN"]
  method = "GET"
  timeout = "5s"
  interval = "300m"
  data_format = "json"
  json_query = ""
  json_time_key = "start"
  json_time_format = "2006-01-02T15:04:05.000-07:00"
  tag_keys = ["price_origin"]
  [inputs.http.tags]
    source = "energyforecast"

[[inputs.http]]
  name_override = "solcast-SOUTH-EAST"
  urls = ["https://api.solcast.com.au/rooftop_sites/YOUR-SOLCAST-SITE-ID-1/forecasts?format=json"]
  method = "GET"
  headers = { "Authorization" = "Bearer YOUR-SOLCAST-API-TOKEN" }
  timeout = "5m"
  interval = "300m"
  data_format = "json"
  json_query = "forecasts"
  json_time_key = "period_end"
  json_time_format = "2006-01-02T15:04:05.0000000Z"
  [inputs.http.tags]
    source = "solcast"

[[inputs.http]]
  name_override = "solcast-WEST"
  urls = ["https://api.solcast.com.au/rooftop_sites/YOUR-SOLCAST-SITE-ID-2/forecasts?format=json"]
  method = "GET"
  headers = { "Authorization" = "Bearer YOUR-SOLCAST-API-TOKEN" }
  timeout = "5m"
  interval = "300m"
  data_format = "json"
  json_query = "forecasts"
  json_time_key = "period_end"
  json_time_format = "2006-01-02T15:04:05.0000000Z"
  [inputs.http.tags]
    source = "solcast"

5. Create a API which can read and write on these created (or all) buckets and read telegraf config you created above

Installation - Telegraf

See here

Run the following command to make the API Token accessabile for this session
export INFLUX_TOKEN=YOUR-INFLUX-API-TOKEN

Then you can check the config
telegraf --config http://YOUR-SERVER-IPADDRESS:8086/api/v2/telegrafs/YOUR-INFLUX-TELEGRAF-CONFIG-ID --test --debug

Then create a service file
sudo nano /etc/systemd/system/telegraf.service

with this content

click here

[Unit]
Description=Telegraf Service for collecting data for EOS
After=network-online.target
Wants=network-online.target

[Service]
User=YOUR-USER
ExecStart=/usr/bin/telegraf --config http://YOUR-SERVER-IPADDRESS:8086/api/v2/telegrafs/YOUR-INFLUX-TELEGRAF-CONFIG-ID
Environment="INFLUX_TOKEN=YOUR-INFLUX-API-TOKEN"
Restart=on-failure
RestartSec=5s
TimeoutStartSec=30

[Install]
WantedBy=multi-user.target

Installation - EVCC

See here
After that you need to configer and integrate your PV Installation (Smartmeter, Inverter, Wallbox etc). The documentation is very easy to understand. I have Kostal inverters & smartmeters, GO-e wallbox installed. For my setup, a sponsor token was needed. There is also a free one for limited time (enough to test the system).

Last step is the integration of the influx db. See here

EOS Usage

Goal - Start the first optimization

The goal is to sent a message body like this via POST to http://YOUR-SERVER-IPADDRESS:8503/optimize

To get such a body we collect the data from our Influx DB, slice, transform, merge and add some small configuration details and wait for the response which should be something like this and can also be viewed as PDF http://YOUR-SERVER-IPADDRESS:8503/visualization_results.pdf

Setup a Node-RED Flow to prepare the data

Go to your Node-RED instance http://YOUR-SERVER-IPADDRESS:1880

I used the template from meintechblog.de where I found this template. But I had to adjust this for various reasons (maybe wrong).

1. Changed InfluxDB request to Version 2 and Flux Requests
2. Changed json structure because this was not valid anymore
3. Removed the "take the data from midnight" stuff (this created array lenght mismatch issues)
4. Some other adjustments

The result is here

[
    {
        "id": "46d0f42657c51689",
        "type": "tab",
        "label": "EOS",
        "disabled": false,
        "info": "",
        "env": []
    },
    {
        "id": "31d21009fe6e6f10",
        "type": "http request",
        "z": "46d0f42657c51689",
        "name": "",
        "method": "POST",
        "ret": "obj",
        "paytoqs": "ignore",
        "url": "http://YOUR-SERVER-IPADDRESS:8503/optimize",
        "tls": "",
        "persist": false,
        "proxy": "",
        "insecureHTTPParser": false,
        "authType": "",
        "senderr": false,
        "headers": [],
        "x": 1890,
        "y": 420,
        "wires": [
            [
                "5254ac3b917dacf5",
                "ea0614b5142c9532",
                "fd454580c8bd3409"
            ]
        ]
    },
    {
        "id": "1d5c93541a0afea0",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "function rule them all",
        "func": "context.data = context.data || {};\nswitch (msg.topic) {\n    case \"soc\": \n        context.data.soc = msg.payload;\n        return null;\n    case \"strompreis\":\n        context.data.strompreis = msg.payload.map(p => p / 100); // Convert to euro/Wh\n        return null;        \n    case \"gesamtlast\":\n        context.data.gesamtlast = msg.payload; // Example multiplier for conversion\n        return null;               \n    case \"pv_forecast\":\n        context.data.temperature_forecast = msg.payload.map(t => t + 18); // Example adjustment for temperatures\n        context.data.pv_forecast = msg.payload.map(v => v * 1000); // Convert to Wh\n        return null;                \n    case \"soc_tesla\":\n        context.data.soc_tesla = msg.payload;\n        return null;\n    case \"akku_preis\":\n        context.data.akku_preis = parseFloat(msg.payload);\n        return null;          \n    case \"eauto_soc_ui\":\n        context.data.eauto_soc_ui = parseFloat(msg.payload);\n        return null;        \n    case \"pvpowernow\":\n        context.data.pvpowernow = parseFloat(msg.payload);\n        return null;                \n    case \"solution\":\n        context.data.start_solution = msg.payload.start_solution;\n        return null;           \n    case \"spuel\":\n        context.data.spuel = msg.payload;\n        return null;     \n    case \"spuel_onoff\":\n        context.data.spuel_onoff = msg.payload;\n        return null;                        \n               \n    default:\n        break;\n}\n\n// Defaults for missing data\nif (context.data.strompreis == null)\n    return null;\n\nif (context.data.akku_preis == null)\n    context.data.akku_preis = 7.0;\n\nif (context.data.eauto_soc_ui == null)\n    context.data.eauto_soc_ui = 20.0;\n\nif (context.data.pvpowernow == null)\n    context.data.pvpowernow = null;\n\nif (context.data.start_solution == null)\n    context.data.start_solution = null; // Example default solution\n\nif (context.data.soc == null || context.data.soc_tesla == null || context.data.eauto_soc_ui == null) {\n    return msg;\n}\n\nmsg.payload = {\n    ems: {\n        preis_euro_pro_wh_akku: context.data.akku_preis * (0.01 / 1000.0),\n        einspeiseverguetung_euro_pro_wh: 7 / (1000.0 * 100.0),\n        gesamtlast: context.data.gesamtlast,\n        pv_prognose_wh: context.data.pv_forecast,\n        strompreis_euro_pro_wh: context.data.strompreis\n    },\n    pv_akku: {\n        kapazitaet_wh: 10200,\n        max_ladeleistung_w: 5700,\n        start_soc_prozent: context.data.soc,\n        min_soc_prozent: 5\n    },\n    wechselrichter: {\n        max_leistung_wh: 15500\n    },\n    eauto: {\n        kapazitaet_wh: 64000,\n        lade_effizienz: 0.95,\n        entlade_effizienz: 1.0,\n        max_ladeleistung_w: 11040,\n        start_soc_prozent: context.data.soc_tesla,\n        min_soc_prozent: context.data.eauto_soc_ui\n    },\n    temperature_forecast: context.data.temperature_forecast,\n    start_solution: context.data.start_solution\n};\nreturn msg;\n",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1660,
        "y": 420,
        "wires": [
            [
                "b78f61a3b7ca6ca5",
                "31d21009fe6e6f10"
            ]
        ]
    },
    {
        "id": "5254ac3b917dacf5",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "function 11",
        "func": "let values = msg.payload.discharge_hours_bin; // Ihre 24 Stunden-Werte\nlet values_eauto = msg.payload.eautocharge_hours_float; // Ihre 24 Stunden-Werte\nlet spuelstart = msg.payload.spuelstart;\nlet currentDate = new Date(); // Aktuelles Datum und Zeit\n\n// Wir gehen davon aus, dass die lokale Zeit bereits korrekt vorliegt\nlet slqCommand = \"START TRANSACTION;\\n\"\nvalues.forEach((value, index) => {\n    // Erstellen eines neuen Datumsobjekts für jede Stunde des aktuellen Tages\n    let timestamp = new Date(currentDate);\n    timestamp.setHours(index);  // Setzen der Stunde\n    timestamp.setMinutes(0);    // Setzen der Minuten auf 0\n    timestamp.setSeconds(0);    // Setzen der Sekunden auf 0\n    let localTimestamp = timestamp;\n\n    // Manuelle Formatierung in das MariaDB-Format YYYY-MM-DD HH:MM:SS\n    let year = localTimestamp.getFullYear();\n    let month = ('0' + (localTimestamp.getMonth() + 1)).slice(-2);\n    let day = ('0' + localTimestamp.getDate()).slice(-2);\n    let hours = ('0' + localTimestamp.getHours()).slice(-2);\n    let minutes = ('0' + localTimestamp.getMinutes()).slice(-2);\n    let seconds = ('0' + localTimestamp.getSeconds()).slice(-2);\n\n    // Formatierung für MariaDB\n    let timestampStr = `${year}-${month}-${day} ${hours}:${minutes}:${seconds}`;\n\n    // Erstellen des SQL-Befehls\n    slqCommand += `DELETE FROM eos WHERE timestamp = '${timestampStr}';\\n`;\n    slqCommand += `INSERT INTO eos (timestamp, topic, data) VALUES ('${timestampStr}','pv_discharge_hours_bin', ${value});\\n`;\n    slqCommand += `INSERT INTO eos (timestamp, topic, data) VALUES ('${timestampStr}','eautocharge_hours_float', ${values_eauto[index]});\\n`;\n\n    // Hinzufügen des Spülstarts, falls die aktuelle Stunde dem Spülstart entspricht\n    if (spuelstart == index) {\n        slqCommand += `INSERT INTO eos (timestamp, topic, data) VALUES ('${timestampStr}','spuelstart_hours_bin', 1);\\n`;\n    } else {\n        slqCommand += `INSERT INTO eos (timestamp, topic, data) VALUES ('${timestampStr}','spuelstart_hours_bin', 0);\\n`;\n    }\n});\nslqCommand += \"COMMIT;\";\nmsg.topic = slqCommand;\nmsg.payload = slqCommand;\nreturn msg;\n",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 2110,
        "y": 320,
        "wires": [
            [
                "aee72bd84ce5b95b"
            ]
        ]
    },
    {
        "id": "7a4045925ed0d718",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Discharge OFF",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "No discharge",
        "payload": "No discharge",
        "payloadType": "str",
        "x": 1560,
        "y": 220,
        "wires": [
            [
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "965ba2575e965596",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Discharge On",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "Discharge",
        "payload": "Discharge",
        "payloadType": "str",
        "x": 1830,
        "y": 200,
        "wires": [
            []
        ]
    },
    {
        "id": "ea0614b5142c9532",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "simulation_data",
        "func": "// JSON-Daten aus dem Payload (für das Beispiel, ersetzen mit deinen Daten)\nlet data = msg.payload.simulation_data;\n\n// Ermittlung der maximalen Länge der Arrays\nlet maxLength = Math.max(data.Netzeinspeisung_Wh_pro_Stunde.length, data.Netzbezug_Wh_pro_Stunde.length, data.akku_soc_pro_stunde.length, data.Last_Wh_pro_Stunde.length);\n\n// Startzeitpunkt ab der jetzigen Stunde in der lokalen Zeitzone\nlet now = new Date();\nnow.setMinutes(0, 0, 0);  // Minuten und Sekunden auf Null setzen\n\n// Initialisierung des SQL-Statements\nlet sqlStatements = \"\";\n\n// Schleife über die Anzahl der Stunden\nfor (let i = 0; i < maxLength; i++) {\n    // Berechnung des Zeitstempels für jede Stunde in der lokalen Zeit\n    let localTimestamp = new Date(now.getTime() + i * 60 * 60 * 1000);\n\n    // Manuelle Formatierung in das MariaDB-Format YYYY-MM-DD HH:MM:SS\n    let year = localTimestamp.getFullYear();\n    let month = ('0' + (localTimestamp.getMonth() + 1)).slice(-2);\n    let day = ('0' + localTimestamp.getDate()).slice(-2);\n    let hours = ('0' + localTimestamp.getHours()).slice(-2);\n    let minutes = ('0' + localTimestamp.getMinutes()).slice(-2);\n    let seconds = ('0' + localTimestamp.getSeconds()).slice(-2);\n\n    // Formatierung für MariaDB\n    let timestamp = `${year}-${month}-${day} ${hours}:${minutes}:${seconds}`;\n    // Prüfen, ob es für diese Stunde überhaupt Daten gibt\n    let hasData = false;\n    let hourSqlStatements = \"\";\n\n    // Einfügen der Netzeinspeisung, wenn der Wert nicht null oder undefined ist\n    if (i < data.Netzeinspeisung_Wh_pro_Stunde.length && data.Netzeinspeisung_Wh_pro_Stunde[i] != null) {\n        hourSqlStatements += `INSERT INTO eos_simulation_data (topic, data, timestamp) VALUES ('Netzeinspeisung_Wh_pro_Stunde', ${data.Netzeinspeisung_Wh_pro_Stunde[i]}, '${timestamp}');\\n`;\n        hasData = true;\n    }\n\n    // Einfügen des Netzbezugs, wenn der Wert nicht null oder undefined ist\n    if (i < data.Netzbezug_Wh_pro_Stunde.length && data.Netzbezug_Wh_pro_Stunde[i] != null) {\n        hourSqlStatements += `INSERT INTO eos_simulation_data (topic, data, timestamp) VALUES ('Netzbezug_Wh_pro_Stunde', ${data.Netzbezug_Wh_pro_Stunde[i]}, '${timestamp}');\\n`;\n        hasData = true;\n    }\n\n    // Einfügen des Akkustands (SoC), wenn der Wert nicht null oder undefined ist nicht bei hasData berücksichtigen!\n    if (i < data.akku_soc_pro_stunde.length && data.akku_soc_pro_stunde[i] != null) {\n        hourSqlStatements += `INSERT INTO eos_simulation_data (topic, data, timestamp) VALUES ('akku_soc_pro_stunde', ${data.akku_soc_pro_stunde[i]}, '${timestamp}');\\n`;\n    }\n\n    // Einfügen der Last, wenn der Wert nicht null oder undefined ist\n    if (i < data.Last_Wh_pro_Stunde.length && data.Last_Wh_pro_Stunde[i] != null) {\n        hourSqlStatements += `INSERT INTO eos_simulation_data (topic, data, timestamp) VALUES ('last_pro_stunde', ${data.Last_Wh_pro_Stunde[i]}, '${timestamp}');\\n`;\n        hasData = true;\n    }\n\n    // Nur wenn für diese Stunde Daten vorhanden sind, die Anweisungen generieren\n    if (hasData) {\n        sqlStatements += `DELETE FROM eos_simulation_data WHERE timestamp = '${timestamp}';\\n`;\n        sqlStatements += hourSqlStatements;\n    }\n}\n\n// Das generierte SQL-Statement in msg.topic einfügen\nmsg.topic = sqlStatements;\n\nreturn msg;\n",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 2120,
        "y": 260,
        "wires": [
            []
        ]
    },
    {
        "id": "b78f61a3b7ca6ca5",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 35",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1860,
        "y": 280,
        "wires": []
    },
    {
        "id": "fd454580c8bd3409",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 38",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 2100,
        "y": 180,
        "wires": []
    },
    {
        "id": "aee72bd84ce5b95b",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 39",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 2380,
        "y": 200,
        "wires": []
    },
    {
        "id": "63712df5705ea59e",
        "type": "comment",
        "z": "46d0f42657c51689",
        "name": "PV-Forecast aus influxdb auslesen von -24h bis +47h",
        "info": "",
        "x": 1040,
        "y": 480,
        "wires": []
    },
    {
        "id": "4ba2079c60e7fe4e",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Trigger alle 5 Minuten",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "*/5 0-23 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "true",
        "payloadType": "bool",
        "x": 480,
        "y": 520,
        "wires": [
            [
                "359b7a298045a4f1"
            ]
        ]
    },
    {
        "id": "2e3a6a5c847191dc",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 1",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 520,
        "wires": []
    },
    {
        "id": "81edee556274b23a",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "filterAndFormatPVForecastFromMidnight",
        "func": "// Hole das aktuelle Datum\nlet now = new Date();\n\n// Erstelle ein neues Array, um die gefilterten Werte zu speichern\nlet filteredData = [];\n\n// Durchlaufe das ursprüngliche Array und filtere nur Werte ab Mitternacht\nmsg.payload.forEach(item => {\n    // Konvertiere den Zeitstempel in ein Datum\n    let itemDate = new Date(item._time);\n\n    // Prüfe, ob der Zeitstempel ab Mitternacht heute liegt\n    //if (itemDate >= new Date(now.getFullYear(), now.getMonth(), now.getDate())) {\n        filteredData.push(item);\n    //}\n});\n\n// Schneide die Werte auf maximal 48 Einträge\nlet limitedData = filteredData.slice(0, 48);\n\n// Extrahiere die \"last\"-Werte, runde auf 2 Nachkommastellen und speichere sie in einem neuen Array\nlet pv_forecast = limitedData.map(item => item._value !== null ? parseFloat(item._value.toFixed(2)) : 0);\n\n// Setze das neue Array als Payload im gewünschten Format\nmsg.payload = pv_forecast;\nmsg.topic = \"pv_forecast\";\nreturn msg;",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1340,
        "y": 520,
        "wires": [
            [
                "2e3a6a5c847191dc",
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "465f8eb10866bfdc",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Trigger alle 5 Minuten",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "*/5 0-23 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "true",
        "payloadType": "bool",
        "x": 480,
        "y": 620,
        "wires": [
            [
                "43799629815730e2"
            ]
        ]
    },
    {
        "id": "d032473ebee697a5",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 6",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 620,
        "wires": []
    },
    {
        "id": "00696f675c0ae068",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "formatpvPowerNow",
        "func": "let pvData = msg.payload; // Der aktuelle Payload, wie z.B. [{\"time\":\"1970-01-01T00:00:00.000Z\",\"total_pv\":2.85}]\n\n// Extrahiere den Wert von \"total_pv\" aus dem Payload\nlet totalPv = pvData[0]._value; // Annahme: Das erste Element des Arrays enthält den gewünschten Wert\n\n// Multipliziere den Wert mit 1000 und schneide die Nachkommastellen ab\nlet pvPowerNow = Math.floor(totalPv * 1000);\n\n// Setze den msg.payload so, dass er nur den Wert \"pvpowernow\" enthält\nmsg.payload = pvPowerNow;\nmsg.topic = \"total_pv\";\nreturn msg;",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1280,
        "y": 620,
        "wires": [
            [
                "d032473ebee697a5",
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "f1dcd34aa1dd01f6",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Trigger alle 5 Minuten",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "*/5 0-23 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "true",
        "payloadType": "bool",
        "x": 480,
        "y": 720,
        "wires": [
            [
                "f6104413bda045e1"
            ]
        ]
    },
    {
        "id": "3cd2a32e7ba17a8d",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 7",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 720,
        "wires": []
    },
    {
        "id": "093afd7f5525805d",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "formatSocNow",
        "func": "let pvData = msg.payload; // Der aktuelle Payload, z.B. [{\"time\":\"2024-09-05T15:28:29.000Z\",\"last\":39}]\n\n// Extrahiere den Wert von \"last\" aus dem Payload\nlet lastValue = pvData[0]._value; // Annahme: Das erste Element des Arrays enthält den gewünschten Wert\n\n// Setze den msg.payload so, dass er nur den Wert \"soc\" enthält\nmsg.payload = lastValue;\nmsg.topic = \"soc\";\nreturn msg;",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1260,
        "y": 720,
        "wires": [
            [
                "3cd2a32e7ba17a8d",
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "33e7607c2850426a",
        "type": "comment",
        "z": "46d0f42657c51689",
        "name": "aktuelle PV-Leistung aus influxdb auslesen",
        "info": "",
        "x": 1000,
        "y": 580,
        "wires": []
    },
    {
        "id": "f9750aeb307fcd4e",
        "type": "comment",
        "z": "46d0f42657c51689",
        "name": "aktuelles Batterie SOC aus influxdb auslesen",
        "info": "",
        "x": 1010,
        "y": 680,
        "wires": []
    },
    {
        "id": "bf1fd40d24cc20d6",
        "type": "comment",
        "z": "46d0f42657c51689",
        "name": "Börsenstrompreis aus influxdb auslesen von -24h bis +47h",
        "info": "",
        "x": 1050,
        "y": 780,
        "wires": []
    },
    {
        "id": "f2c65c725e511d9e",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Trigger alle 5 Minuten",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "*/6 0-23 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "true",
        "payloadType": "bool",
        "x": 480,
        "y": 820,
        "wires": [
            [
                "0eed085f93d7e84a"
            ]
        ]
    },
    {
        "id": "58142364777af7c4",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "filterAndFormatStompreisFromMidnight",
        "func": "// Hole das aktuelle Datum\nlet now = new Date();\n\n// Erstelle ein neues Array, um die gefilterten Werte zu speichern\nlet filteredData = [];\n\n// Durchlaufe das ursprüngliche Array und filtere nur Werte ab Mitternacht\nmsg.payload.forEach(item => {\n    // Konvertiere den Zeitstempel in ein Datum\n    let itemDate = new Date(item._time);\n\n    // Prüfe, ob der Zeitstempel ab Mitternacht heute liegt\n    //if (itemDate >= new Date(now.getFullYear(), now.getMonth(), now.getDate())) {\n        filteredData.push(item);\n    //}\n});\n\n// Schneide die Werte auf maximal 48 Einträge\nlet limitedData = filteredData.slice(0, 48);\n\n// Extrahiere die \"last\"-Werte, runde auf 2 Nachkommastellen, teile sie durch 100 und speichere sie in einem neuen Array\n//let strompreis = limitedData.map(item => item._value !== null ? parseFloat((item._value / 100000).toFixed(5)) : 0);\nlet strompreis = limitedData.map(item => item._value !== null ? parseFloat((item._value / 10).toFixed(5)) : 0);\n\n// Setze das neue Array als Payload im gewünschten Format\nmsg.payload = strompreis;\nmsg.topic = \"strompreis\";\nreturn msg;",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1340,
        "y": 820,
        "wires": [
            [
                "a54431ea5b0e3e63",
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "a54431ea5b0e3e63",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 8",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 820,
        "wires": []
    },
    {
        "id": "0eed085f93d7e84a",
        "type": "delay",
        "z": "46d0f42657c51689",
        "name": "",
        "pauseType": "delay",
        "timeout": "1",
        "timeoutUnits": "seconds",
        "rate": "1",
        "nbRateUnits": "1",
        "rateUnits": "second",
        "randomFirst": "1",
        "randomLast": "5",
        "randomUnits": "seconds",
        "drop": false,
        "outputs": 1,
        "x": 700,
        "y": 820,
        "wires": [
            [
                "791129e353dea0cf"
            ]
        ]
    },
    {
        "id": "359b7a298045a4f1",
        "type": "delay",
        "z": "46d0f42657c51689",
        "name": "",
        "pauseType": "delay",
        "timeout": "1",
        "timeoutUnits": "seconds",
        "rate": "1",
        "nbRateUnits": "1",
        "rateUnits": "second",
        "randomFirst": "1",
        "randomLast": "5",
        "randomUnits": "seconds",
        "drop": false,
        "allowrate": false,
        "outputs": 1,
        "x": 700,
        "y": 520,
        "wires": [
            [
                "1061bea547871cd5"
            ]
        ]
    },
    {
        "id": "52f21685b6bbeee8",
        "type": "comment",
        "z": "46d0f42657c51689",
        "name": "verbrauch aus influxdb auslesen von -24h bis +47h",
        "info": "",
        "x": 1030,
        "y": 900,
        "wires": []
    },
    {
        "id": "024776e80fe36c08",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Trigger alle 5 Minuten",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "*/6 0-23 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "true",
        "payloadType": "bool",
        "x": 480,
        "y": 940,
        "wires": [
            [
                "7a2d0c39aa031fdb"
            ]
        ]
    },
    {
        "id": "e806c7122204fcc5",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "filterAndFormatGesamtlastFromMidnight",
        "func": "// Hole das aktuelle Datum\nlet now = new Date();\n\n// Erstelle ein neues Array, um die gefilterten Werte zu speichern\nlet filteredData = [];\n\n// Durchlaufe das ursprüngliche Array und filtere nur Werte ab Mitternacht\nmsg.payload.forEach(item => {\n    // Konvertiere den Zeitstempel in ein Datum\n    let itemDate = new Date(item._time);\n\n    // Prüfe, ob der Zeitstempel ab Mitternacht heute liegt\n    //if (itemDate >= new Date(now.getFullYear(), now.getMonth(), now.getDate())) {\n        filteredData.push(item);\n    //}\n});\n\n// Schneide die Werte auf maximal 48 Einträge\nlet limitedData = filteredData.slice(0, 48);\n\n// Extrahiere die \"last\"-Werte, runde auf 2 Nachkommastellen, multipliziere sie mit 1000 und speichere sie in einem neuen Array\nlet gesamtlast = limitedData.map(item => item._value !== null ? parseFloat((item._value).toFixed(0)) : 0);\n\n// Setze das neue Array als Payload im gewünschten Format\nmsg.payload = gesamtlast;\nmsg.topic = \"gesamtlast\";\nreturn msg;",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1340,
        "y": 940,
        "wires": [
            [
                "2fd01ffcb7a97803",
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "2fd01ffcb7a97803",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 9",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "true",
        "targetType": "full",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 980,
        "wires": []
    },
    {
        "id": "7a2d0c39aa031fdb",
        "type": "delay",
        "z": "46d0f42657c51689",
        "name": "",
        "pauseType": "delay",
        "timeout": "1",
        "timeoutUnits": "seconds",
        "rate": "1",
        "nbRateUnits": "1",
        "rateUnits": "second",
        "randomFirst": "1",
        "randomLast": "5",
        "randomUnits": "seconds",
        "drop": false,
        "outputs": 1,
        "x": 700,
        "y": 940,
        "wires": [
            [
                "c9935e9e580aded5"
            ]
        ]
    },
    {
        "id": "01d8c57b72094eb5",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "Trigger alle 5 Minuten",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "*/5 0-23 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "true",
        "payloadType": "bool",
        "x": 480,
        "y": 1040,
        "wires": [
            [
                "61e4c4d90f20cf01"
            ]
        ]
    },
    {
        "id": "19c43d9bdcf9d59c",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 10",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 1040,
        "wires": []
    },
    {
        "id": "61e4c4d90f20cf01",
        "type": "function",
        "z": "46d0f42657c51689",
        "name": "formatSocteslaNow",
        "func": "let pvData = msg.payload; // Der aktuelle Payload, z.B. [{\"time\":\"2024-09-05T15:28:29.000Z\",\"last\":39}]\n\n// Extrahiere den Wert von \"last\" aus dem Payload\n//let lastValue = pvData[0].last; // Annahme: Das erste Element des Arrays enthält den gewünschten Wert\nlet lastValue = 10;\n// Setze den msg.payload so, dass er nur den Wert \"soc_tesla\" enthält\nmsg.payload = lastValue;\nmsg.topic = \"soc_tesla\";\nreturn msg;",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1280,
        "y": 1040,
        "wires": [
            [
                "19c43d9bdcf9d59c",
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "52d0f96563ac1d1c",
        "type": "comment",
        "z": "46d0f42657c51689",
        "name": "aktuelles shabyy_battery_level aus influxdb auslesen",
        "info": "",
        "x": 1030,
        "y": 1000,
        "wires": []
    },
    {
        "id": "5b21a211d2899332",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "",
        "props": [
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "go shorty",
        "payloadType": "str",
        "x": 1340,
        "y": 340,
        "wires": [
            [
                "1d5c93541a0afea0"
            ]
        ]
    },
    {
        "id": "f9fc8e0d1f8de064",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "",
        "props": [
            {
                "p": "topic",
                "vt": "str"
            },
            {
                "p": "payload"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "eauto_soc_ui",
        "payload": "60",
        "payloadType": "num",
        "x": 1320,
        "y": 420,
        "wires": [
            [
                "1d5c93541a0afea0",
                "8b7d35f80bcea1a0"
            ]
        ]
    },
    {
        "id": "8b7d35f80bcea1a0",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 40",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "true",
        "targetType": "full",
        "statusVal": "",
        "statusType": "auto",
        "x": 1620,
        "y": 340,
        "wires": []
    },
    {
        "id": "6c60f4d8bf5131c2",
        "type": "http request",
        "z": "46d0f42657c51689",
        "name": "",
        "method": "GET",
        "ret": "obj",
        "paytoqs": "ignore",
        "url": "http://YOUR-SERVER-IPADDRESS:5000/gesamtlast_simple?year_energy=10000000",
        "tls": "",
        "persist": false,
        "proxy": "",
        "insecureHTTPParser": false,
        "authType": "",
        "senderr": false,
        "headers": [],
        "x": 1410,
        "y": 1160,
        "wires": [
            []
        ]
    },
    {
        "id": "e4c8a59d76a901e4",
        "type": "inject",
        "z": "46d0f42657c51689",
        "name": "",
        "props": [
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "gesamtlast",
        "x": 970,
        "y": 1140,
        "wires": [
            [
                "6c60f4d8bf5131c2"
            ]
        ]
    },
    {
        "id": "1061bea547871cd5",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read PV-Forecast from db",
        "query": "from(bucket: \"pvforecast\")\n  |> range(start: -24h, stop: 47h)\n  |> filter(fn: (r) => r[\"_measurement\"] == \"solcast-HuetteOst\" or r[\"_measurement\"] == \"solcast-SüdWest\")\n  |> filter(fn: (r) => r[\"_field\"] == \"pv_estimate\")\n  |> group(columns: [\"_time\", \"pv_estimate\"])\n  |> sum()\n  |> group(columns: [\"pv_estimate\"])\n  |> sort(columns: [\"_time\"])\n  |> aggregateWindow(every: 1h, fn: last, createEmpty: false)\n  |> yield(name: \"mean\")",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "YOUR-INFLUX-ORGANIZATION",
        "x": 960,
        "y": 520,
        "wires": [
            [
                "81edee556274b23a"
            ]
        ]
    },
    {
        "id": "43799629815730e2",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read total_pv from db",
        "query": "from(bucket: \"evcc\")\n  |> range(start: -10m, stop: 0m)\n  |> filter(fn: (r) => r[\"_measurement\"] == \"pvPower\")\n  |> filter(fn: (r) => r[\"_field\"] == \"value\")\n  |> filter(fn: (r) => r[\"id\"] == \"1\" or r[\"id\"] == \"2\")\n  |> last()  // Selects the last value directly\n  |> group()\n  |> aggregateWindow(every: 1h, fn: sum, createEmpty: false)\n  |> yield(name: \"last\")",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "YOUR-INFLUX-ORGANIZATION",
        "x": 940,
        "y": 620,
        "wires": [
            [
                "00696f675c0ae068"
            ]
        ]
    },
    {
        "id": "f6104413bda045e1",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read \"soc\" from db",
        "query": "from(bucket: \"evcc\")\n  |> range(start: -10m, stop: 0m)\n  |> filter(fn: (r) => r[\"_measurement\"] == \"batterySoc\")\n  |> filter(fn: (r) => r[\"_field\"] == \"value\")\n  |> filter(fn: (r) => r[\"id\"] == \"1\")\n  |> last()  // Selects the last value directly\n  |> yield(name: \"mean\")",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "YOUR-INFLUX-ORGANIZATION",
        "x": 940,
        "y": 720,
        "wires": [
            [
                "093afd7f5525805d",
                "3cd2a32e7ba17a8d"
            ]
        ]
    },
    {
        "id": "b8ed3a940da754d1",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read awattar from db",
        "query": "from(bucket: \"tibber\")\n  |> range(start: -25h, stop: 47h)\n  |> filter(fn: (r) => r[\"_measurement\"] == \"tibber\")\n  |> filter(fn: (r) => r[\"_field\"] == \"total\")\n  |> aggregateWindow(every: 1h, fn: mean, createEmpty: false)\n  |> yield(name: \"mean\")",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "YOUR-INFLUX-ORGANIZATION",
        "x": 940,
        "y": 820,
        "wires": [
            []
        ]
    },
    {
        "id": "c9935e9e580aded5",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read verbrauch from db",
        "query": "from(bucket: \"evcc\")\n  |> range(start: -48h, stop: 0m)\n  |> filter(fn: (r) => r[\"_measurement\"] == \"homePower\")\n  |> filter(fn: (r) => r[\"_field\"] == \"value\")\n  |> aggregateWindow(every: 1h, fn: mean, createEmpty: false)\n  |> yield(name: \"mean\")",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "YOUR-INFLUX-ORGANIZATION",
        "x": 950,
        "y": 940,
        "wires": [
            [
                "e806c7122204fcc5",
                "04ec59621bd69609"
            ]
        ]
    },
    {
        "id": "307f8e2045d98a46",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read \"soc_tesla\" from db",
        "query": "SELECT last(\"shabyy_battery_level\")\nFROM \"tesla\"",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "",
        "x": 930,
        "y": 1080,
        "wires": [
            [
                "61e4c4d90f20cf01"
            ]
        ]
    },
    {
        "id": "04ec59621bd69609",
        "type": "debug",
        "z": "46d0f42657c51689",
        "name": "debug 41",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 1100,
        "y": 340,
        "wires": []
    },
    {
        "id": "791129e353dea0cf",
        "type": "influxdb in",
        "z": "46d0f42657c51689",
        "influxdb": "8bd5e454.7c7aa",
        "name": "Read awattar from db",
        "query": "union(\n  tables: [\n    from(bucket: \"tibber\")\n      |> range(start: -24h, stop: 48h)\n      |> filter(fn: (r) => r[\"_measurement\"] == \"tibber\")\n      |> filter(fn: (r) => r[\"_field\"] == \"total\")\n      |> aggregateWindow(every: 1h, fn: last, createEmpty: false),\n    from(bucket: \"energyforecast\")\n      |> range(start: -24h, stop: 48h)\n      |> filter(fn: (r) => r[\"source\"] == \"energyforecast\")\n      |> filter(fn: (r) => r[\"_field\"] == \"price\")\n      |> filter(fn: (r) => r[\"host\"] == \"pvanlage\")\n      |> filter(fn: (r) => r[\"price_origin\"] == \"forecast\")\n      |> aggregateWindow(every: 1h, fn: last, createEmpty: false)\n  ]\n)\n|> yield(name: \"last\")\n",
        "rawOutput": false,
        "precision": "",
        "retentionPolicy": "",
        "org": "YOUR-INFLUX-ORGANIZATION",
        "x": 940,
        "y": 860,
        "wires": [
            [
                "58142364777af7c4"
            ]
        ]
    },
    {
        "id": "8bd5e454.7c7aa",
        "type": "influxdb",
        "hostname": "YOUR-SERVER-IPADDRESS",
        "port": "8086",
        "protocol": "http",
        "database": "YOUR-INFLUX-ORGANIZATION",
        "name": "InfluxDB",
        "usetls": false,
        "tls": "",
        "influxdbVersion": "2.0",
        "url": "http://YOUR-SERVER-IPADDRESS:8086",
        "timeout": "",
        "rejectUnauthorized": false
    }
]

You should review all "Read xy" nodes and the "function rule them all" nodes especially the part at the bottom of the code. The "Tesla" stuff is hardcoded. I didn't integrated the car API yet. And I didn't touched the nodes after the optimization yet.

click here

msg.payload = {
    ems: {
        preis_euro_pro_wh_akku: context.data.akku_preis * (0.01 / 1000.0),
        einspeiseverguetung_euro_pro_wh: 7 / (1000.0 * 100.0),
        gesamtlast: context.data.gesamtlast,
        pv_prognose_wh: context.data.pv_forecast,
        strompreis_euro_pro_wh: context.data.strompreis
    },
    pv_akku: {
        kapazitaet_wh: 10200,
        max_ladeleistung_w: 5700,
        start_soc_prozent: context.data.soc,
        min_soc_prozent: 5
    },
    wechselrichter: {
        max_leistung_wh: 15500
    },
    eauto: {
        kapazitaet_wh: 64000,
        lade_effizienz: 0.95,
        entlade_effizienz: 1.0,
        max_ladeleistung_w: 11040,
        start_soc_prozent: context.data.soc_tesla,
        min_soc_prozent: context.data.eauto_soc_ui
    },
    temperature_forecast: context.data.temperature_forecast,
    start_solution: context.data.start_solution

Run the optimization

Click on "Go shorty" and wait for the response.

Questions

1. Is there a new/better Node-RED template?
2. Why was the "midnight"-Stuff in the Node-RED template. Is it still needed?
3. The "gesamtlast": from which timeframe and in which order is this needed?
4. Can I set the ev_available_charge_rates for the inverter as well?
5. Is there a overview of all available options and can they be set in the message body?
6. Why does the SOC graph starts with 20 on the x axis?
   
7. Is there a better explaination about this graphic. I think I still have issues in the input data so I should expect too much from the output. But I don't understand the result.
   

Open steps

1. Get the input correct
2. Test/Verify the result
3. Implement a trigger/job which uses the evcc API

[Lasall]

Pretty cool stuff! EOS actually already has the PV and elecricity price forecast part so all the third party accounts are not required. Currently we plan on a more straightforward integration with evcc (maybe via MQTT/HA). For the API docs, check out EOS OpenAPI Spec

[drbacke]

Thanks, thats really cool. Ist there a way to get this available for other Users? Maybe WE Could integrate a direct API?

Gesamtlast can be predicted by the inhouse Tool in EOS. You Just need some historical Data + yearly consumption (Look at the Open API in the readme bottom)

[XHalamaX]

First of all I want to thank you and everybody who is contributing to this great project!

I don't have a plug&play setup yet which I could easily share or I don't understand what you mean. In the description above are already some code/configuration snippets hidden in "click here" just in case you missed this. If other users are interested and try to follow the "guide" they will hopefully let me know where they have issues or what I missed so I can update the guide.

I didn't started with the EVCC integration yet. I still struggeling with the EOS setup and I need this before I get the motivation to start with a EVCC integration. It would be great if you or someone else could help me.

I migrated the the price forecast to your solution now and will do the same later for the pv forecast.

Questions

1. Is there a new/better Node-RED template?
2. Why was the "midnight"-Stuff in the Node-RED template. Is it still needed? In the test data I found the arrays with 48 entries testfile1. I found this in the forum https://akkudoktor.net/t/bekomme-keine-validen-werte-was-mache-ich-falsch/23721/2 . Is that really true? Why we are not using the "last" from the last 48h if we have this? Why should we not include the history when we run the optimization at 00:15? I worked on this one night and noticed this behaviour. I removed the filter because I thought it must be an issue :D
3. Can I set the ev_available_charge_rates for the inverter as well? I want to use EVCC and at the moment I can just switch the battery charging from grid on or off. If I switch it on I can load with 5,7kW. In the result I get entries of ac_charge between 0 and 1. I expects this is the indicator of when the battery should be loaded from grid. So either there is a EOS possibility to avoid the 0.25, 0.5, 0.75 values or I have to find an other solution.
4. Why does the SOC graph starts with 20 on the x axis?
5. I have two inverter and each of it has two strings. In the testfile I see that I can setup multiple strings and inverter but I can't combine two strings with a inverter, right?
6. Could you please check the optimization input and results and tell me if something is wrong or looks wrong?
   output_2024_12_20_11_50.json
   input_2024_12_20_11_50.json
   visualization_2024_12_20_11_50.pdf

Here is the current plan for a first EVCC integration

[drbacke]

1. I can provide my Personal node Red flow. If that is helpfull.
2. What do you mean with modnight stuff? The desribed Problem ist solved in the latest Version
3. No, but it's an Open issues. That is Not a Big deal, we can provide that in near future
4. Start_soc? But there was a small Timeshift in the soc calc. It's fixed now.
5. In the PV prediction this is Not possible right now. The solution is to Set No Limits in the PV prediction and an Overall inverter Limit in the EOS. It's Not such a big Problem If you dont fit your Inverter perfect. Just get as near as possible
6. Discharge hour Looks a little Strange, did you use a fresh Code? (Yesterday)
7. It would be really helpfull If WE Could use your Tutorial for our Wiki. If you are finished.

[Lasall]

4.: It starts with the start hour of the simulation (default is current hour of the day, e.g. 8pm = 20). Currently we are working on improved PDF-report #267 (which would start at 0 for the socs).

[unim0trix]

Hey, thank you very much! Works great.
That's how I imagined it.
I control everything (EV, Battery, Switches, etc.) via EVCC - automation via EOS would be perfect.

[XHalamaX]

Hi and sorry again,
I still struggle to understand the output from the optimization. I tried to visualize it for me

output_2025_01_23_23_50.json

How do I know when to load the battery from grid? I though it is ac_charge but I the output doesn't look right...

I read somewhere, that some input values should starting at 00:00 from the current day. Is that true and the if yes which ones and maybe why? I migrate to the new prediction API and as far as I see I don't need to care anymore. I put more data in measurements and prediction provides the correct data.

Just let me know if I should stop bothering you with my questions. I can also wait until the project is in a later phase.

[e-hirsch]

I'm currently also trying to understand the output of the optimization. As far as I understand ac_charge indicates when the battery is or should be charged from grid.

The value multiplied with the configuration value (or alternatively set in the input parameters under "pv_akku") "battery_max_charging_power" is the charging power in watt.

But because the array "ac_charge" and the arrays in "result" have a different size , you need to align the arrays to the right. The arrays in "result" start with the current hour, the array "ac_charge" starts at hour 0 of the day. So if you start the optimization e.g. between 8:00 and 9:00 o'clock the first value in "result" reflects 8:00 (or index 8 or 9th value - that's not what I would expect but it seems to be the case). You can validate that if you compare the load value in the input array with the load value in the result array. If you then pick the 9th value of the ac_charge array you would have the correct charging factor for that hour.

Hope that is correct, makes sense and helps a little bit.