Solar Forecast and PV-Aware Smart Charging Optimization for Battery and EV

This flow uses the forecast.solar API combined with Tibber electricity price data and Home Assistant entities to optimize the charging strategy for both home batteries (e.g., BYD) and EV wallboxes.

The flow dynamically generates a charging schedule based on solar production forecasts, state of charge (SOC), and dynamic energy prices, using a genetic algorithm optimizer for intelligent charging decisions.

✅ Main Features: Forecast.Solar API Integration: Fetches hourly solar production forecasts based on your specific location and PV system parameters.

Tibber Dynamic Price Integration: Uses live energy price data from Tibber and stores it globally for reuse.

Battery Charging Strategy (Genetic Optimization): Optimizes charge/discharge schedule for your home battery using a genetic algorithm that considers solar forecasts and energy prices.

EV Wallbox Smart Scheduling: Coordinates wallbox charging with solar surplus and electricity prices.

SOC Awareness: Uses the current state of charge from your Home Assistant battery sensors for decision making.

Web Dashboard Chart: Optional chart showing the solar forecast via Node-RED Dashboard UI.

Rate Limit Handling: Built-in rate-limiting to avoid API bans from forecast.solar.

Multi-day Forecast & Flexible Resolution: Supports day-wise forecasts, resolution adjustment (hourly, 15 min, etc.), and dynamic handling of graph outputs.

State Saving: Caches solar forecast and Tibber price data in Node-RED global context for cross-flow usage.

[{"id":"93f485839dfa27a8","type":"subflow","name":"Solar forecast","info":"This subflow uses the http request node to fetch solar forecasts for geographical positions, using the API from https://forecast.solar/. Please check their website and consider getting a paid account.\n\nDo note that, on a free account, you are limited in the number of requests to do. Also note that the data only gets updated once every 15 minutes, so there is no reason to query more often. There is rate limiting built in the subflow not to perform requests more than once every 15 minutes.\n\n# Configuration\n\nIt uses the parameters as described on: http://doc.forecast.solar/doku.php\n\n - `:apikey` - personal API key for registered users\n - `:lat` - latitude of location, -90 (south) … 90 (north); Internal precission is 0.0001 or abt. 10 m\n - `:lon` - longitude of location, -180 (west) … 180 (east); Internal precission is 0.0001 or abt. 10 m\n - `:dec` - plane declination, 0 (horizontal) … 90 (vertical); Internal precission is integer\n - `:az` - plane azimuth, -180 … 180 (-180 = north, -90 = east, 0 = south, 90 = west, 180 = north); Internal precission is integer\n - `:kwp` - installed modules power in kilo watt peak (kWp)\n\nYou can choose between 3 different type of requests. Note that only `estimate` is available on the free plan.\n\n- `estimate` - this is the forecasted estimate that your panels should produce (given the right parameter settings)\n- `history` - historycal data\n- `clear sky` - estimate given if there would be a clear sky tomorrow\n\nIn case of estimates, one of the following options can be selected:\n- `watts` - Watts (power) average for the period\n- `watthours/period` - Watt hours (energy) for the period\n- `watthours` - Watt hours (energy) summarized over the day\n- `watthours/day` - Watt hours (energy) summarized for each day\n\nFor the graph output there are some extra settings available:\n\n- _Output in kWh_ - when checked output can be set to kWh instead of Wh\n- _Show todays forecast_ - whether or not to include todays forecast\n- _Days to forecast_ - the number of days to forecast (excluding today). Note that you can not get more days forecasted than your API key allows.\n- _Widen graph_ - widen the graph to only show non-zero values\n- _Show day instead of date_ - Show the day instead of the date in the series and labels\n\n# Input \n\nThe input is for triggering the solar forecast request. \nIt triggers when injecting a message into the node.\n\n# Output\n\nThere are two outputs. The first output is an object with the result and a status message stored into the `msg.payload`.\n\nMost important is the `msg.payload.result`, which contains the estimated production of the panels. E.g.:\n\n```\npayload: object\n  result: object\n    2022-11-28: 23\n    2022-11-29: 35\n```\n\nThe `msg.payload.message` gives information on how successful the query was, the exitcode of the query and the status of the rate limit (how many queries you have left).\n\nThe **second** output can be directly linked to a line or a bar chart, quickly giving a once-glance overview for the predicted forecast.\n\n# Status\n\nInitially the status of the note will be a blue dot, showing \"_Unknown limit_\", as it is unaware of the set ratelmits. After the first request, the returned ratelimit will be put in the text in the form of `remaining/limit`. If more than half the limit is remaining, the dot will be green. If less then half the limit is remaining, the dot will be yellow. If no limit is left, the dot will turn red.\nPlease keep in mind that the ratelimit will be reset after one hour, so you can send a new request after that hour.\n\nIf something is wrong in the API request, the dot will turn red\nand the message will contain the msg.payload with the error. This\nhappens typically when the API is temporally down for maintenance.","category":"","in":[{"x":240,"y":100,"wires":[{"id":"c8dc6aa14b9f3e92"}]}],"out":[{"x":760,"y":260,"wires":[{"id":"2f42837904c91d73","port":0},{"id":"fcc8d69a3ab88e6d","port":0}]},{"x":770,"y":340,"wires":[{"id":"5b0a430fb61e70e7","port":0}]}],"env":[{"name":"latitude","type":"num","value":"51.3","ui":{"icon":"font-awesome/fa-location-arrow","label":{"en-US":"Latitude"},"type":"input","opts":{"types":["num"]}}},{"name":"longitude","type":"num","value":"5.6","ui":{"icon":"font-awesome/fa-location-arrow","label":{"en-US":"Longitude"},"type":"input","opts":{"types":["num"]}}},{"name":"declination","type":"num","value":"37","ui":{"icon":"font-awesome/fa-chevron-up","label":{"en-US":"Declination"},"type":"input","opts":{"types":["num"]}}},{"name":"azimuth","type":"num","value":"0","ui":{"icon":"font-awesome/fa-compass","label":{"en-US":"Azimuth"},"type":"spinner","opts":{"min":-180,"max":180}}},{"name":"modules power","type":"num","value":"1","ui":{"icon":"font-awesome/fa-power-off","label":{"en-US":"Modules power (kWp)"},"type":"input","opts":{"types":["num"]}}},{"name":"apikey","type":"cred","ui":{"icon":"font-awesome/fa-key","label":{"en-US":"API key"},"type":"input","opts":{"types":["cred"]}}},{"name":"type","type":"str","value":"estimate","ui":{"label":{"en-US":"Type"},"type":"select","opts":{"opts":[{"l":{"en-US":"Estimate"},"v":"estimate"},{"l":{"en-US":"History"},"v":"history"},{"l":{"en-US":"Clear sky"},"v":"clearsky"}]}}},{"name":"watt","type":"str","value":"watts","ui":{"icon":"font-awesome/fa-question-circle-o","label":{"en-US":"Watt"},"type":"select","opts":{"opts":[{"l":{"en-US":"Watts (power) average for the period"},"v":"watts"},{"l":{"en-US":"Watt hours (energy) for the period"},"v":"watthours/period"},{"l":{"en-US":"Watt hours (energy) summarized over the day"},"v":"watthours"},{"l":{"en-US":"Watt hours (energy) summarized for each day"},"v":"watthours/day"}]}}},{"name":"kwhoutput","type":"bool","value":"false","ui":{"label":{"en-US":"Output in kWh (in the graph)"},"type":"checkbox"}},{"name":"showtoday","type":"bool","value":"true","ui":{"label":{"en-US":"Show todays forecast"},"type":"checkbox"}},{"name":"daystoforecast","type":"str","value":"-1","ui":{"label":{"en-US":"Days to forecast"},"type":"select","opts":{"opts":[{"l":{"en-US":"Max"},"v":"-1"},{"l":{"en-US":"0"},"v":"0"},{"l":{"en-US":"1"},"v":"1"},{"l":{"en-US":"2"},"v":"2"},{"l":{"en-US":"3"},"v":"3"},{"l":{"en-US":"4"},"v":"4"},{"l":{"en-US":"5"},"v":"5"},{"l":{"en-US":"6"},"v":"6"}]}}},{"name":"widengraph","type":"bool","value":"true","ui":{"label":{"en-US":"Widen graph"},"type":"checkbox"}},{"name":"showday","type":"bool","value":"false","ui":{"label":{"en-US":"Show day instead of date"},"type":"checkbox"}}],"meta":{"module":"Solar Forecast","version":"0.0.12","author":"[email protected]","desc":"Get solar forecasting per location","keywords":"solar,forecast,api","license":"GPL-3.0"},"color":"#FFCC66","inputLabels":["trigger"],"outputLabels":["output","graph"],"icon":"font-awesome/fa-sun-o","status":{"x":680,"y":560,"wires":[{"id":"1bfc1cde3ee94e4b","port":0},{"id":"a798fbe66cf133d5","port":0}]}},{"id":"c706820c0d61f023","type":"http request","z":"93f485839dfa27a8","name":"","method":"GET","ret":"txt","paytoqs":"ignore","url":"","tls":"","persist":false,"proxy":"","insecureHTTPParser":false,"authType":"","senderr":false,"headers":[],"x":390,"y":180,"wires":[["1b5ccaa05d54f7c3"]]},{"id":"b9488734852cd0ca","type":"function","z":"93f485839dfa27a8","name":"create forecast.solar url","func":"msg.url = 'https://api.forecast.solar/';\n\nif (env.get('apikey')) {\n    msg.url += env.get('apikey') + '/';\n    }\n\nmsg.url += env.get('type') + '/';\n\nmsg.url += env.get('watt') + '/';\n\nmsg.url += env.get('latitude') + '/' +\n           env.get('longitude') + '/' +\n           env.get('declination') + '/' +\n           env.get('azimuth') + '/' +\n           env.get('modules power');\n\nmsg.topic = 'solar forecast: '+(env.get('type') || '');\nmsg.topic += (' '+env.get('watt') || '');\nif (env.get('kwhoutput')) {\n    msg.topic += ' (kWh)';\n}\nreturn msg;","outputs":1,"timeout":"","noerr":0,"initialize":"","finalize":"","libs":[],"x":630,"y":100,"wires":[["975daf96f15cfb61"]]},{"id":"1b5ccaa05d54f7c3","type":"json","z":"93f485839dfa27a8","name":"Convert to json","property":"payload","action":"","pretty":false,"x":680,"y":180,"wires":[["e718a22973cc2864"]]},{"id":"559391d1288f762a","type":"function","z":"93f485839dfa27a8","name":"update ratelimit","func":"var remaining = msg.payload.message.ratelimit.remaining || 0;\nvar limit = msg.payload.message.ratelimit.limit;\n\nflow.set('forecast.solar.ratelimit.remaining', remaining)\nflow.set('forecast.solar.ratelimit.limit', limit)\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":520,"y":480,"wires":[["e56826252134b93a"]]},{"id":"e718a22973cc2864","type":"link out","z":"93f485839dfa27a8","name":"link out 1","mode":"link","links":["3fa24f2d08195961","0a20e852662c8cec"],"x":815,"y":180,"wires":[]},{"id":"3fa24f2d08195961","type":"link in","z":"93f485839dfa27a8","name":"link in 1","links":["e718a22973cc2864"],"x":385,"y":480,"wires":[["559391d1288f762a"]]},{"id":"0a20e852662c8cec","type":"link in","z":"93f485839dfa27a8","name":"link in 2","links":["e718a22973cc2864"],"x":225,"y":260,"wires":[["fcc8d69a3ab88e6d"]]},{"id":"4734b6f403e1f03e","type":"inject","z":"93f485839dfa27a8","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":true,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":530,"y":440,"wires":[["e56826252134b93a"]]},{"id":"c8dc6aa14b9f3e92","type":"delay","z":"93f485839dfa27a8","name":"1 msg/15 minutes","pauseType":"rate","timeout":"5","timeoutUnits":"seconds","rate":"1","nbRateUnits":"15","rateUnits":"minute","randomFirst":"1","randomLast":"5","randomUnits":"seconds","drop":false,"allowrate":false,"outputs":1,"x":390,"y":100,"wires":[["b9488734852cd0ca"]]},{"id":"1bfc1cde3ee94e4b","type":"function","z":"93f485839dfa27a8","name":"update status","func":"var remaining = flow.get('forecast.solar.ratelimit.remaining') || -1;\nvar limit = flow.get('forecast.solar.ratelimit.limit') || -1\n\nvar text = remaining.toString() + '/' + limit.toString();\nvar fill = \"green\";\n\nif (remaining == 0) {\n    fill = \"red\";\n    text = \"Limit used\";\n}\n\nif (remaining > 0 && remaining < limit / 2) {\n    fill = \"yellow\"\n}\n\nif (remaining == -1 ) {\n    fill = \"blue\"\n    text = \"Limits unknown\"\n}\n\nmsg.payload = ({ fill: fill, text: text });\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":520,"y":580,"wires":[[]]},{"id":"a18e96179ec2d987","type":"function","z":"93f485839dfa27a8","name":"Create graph output","func":"var m = {};\nm.labels = [];\nm.data = [];\n\nm.series = [];\nm.data = [];\nm.labels = [];\n\nfor (let j = 0; j <= msg.days; j++) {\n    m.data[j] = [];\n}\n\nif (msg.watt === 'watt_hours_day') {\n    var i = 0;\n    if (msg.kwhoutput) {\n        m.series.push(\"kWh per day\");\n    } else {\n        m.series.push(\"Watt hours per day\");\n    }\n    for (const key in msg.payload.result) {\n        m.labels.push(key);\n        if (msg.kwhoutput) {\n            m.data[i] = +(Math.round(msg.payload.result[key]/100)*.1).toFixed(1);\n        } else {\n            m.data[i] = msg.payload.result[key];\n        }\n        i++;\n    }\n    m.data = [m.data];\n    return { payload: [m] };\n}\n\nfor (let i = 0; i <= 23; i++) {\n\n    m.labels.push(i.toString()+':00');\n    if (msg.resolution === 4) {\n       m.labels.push(i.toString()+':15');\n    }\n    if (msg.resolution === 2 || msg.resolution == 4) {\n       m.labels.push(i.toString()+':30');\n    }\n    if (msg.resolution === 4) {\n       m.labels.push(i.toString()+':45');\n    }\n\n    for (let j = 0; j <= msg.days; j++) {\n        m.data[j].push(0);\n        if (msg.resolution === 4) {\n           m.data[j].push(0)\n        }\n        if (msg.resolution === 2 || msg.resolution == 4) {\n           m.data[j].push(0)\n        }\n        if (msg.resolution === 4) {\n           m.data[j].push(0)\n        }\n\n    }\n}\n\nvar offset = 0;\nfor (const key in msg.payload.result) {\n    var d = new Date(key)\n    if (m.series.indexOf(d.toISOString().split('T')[0]) === -1) {\n        m.series.push(d.toISOString().split('T')[0])\n    }\n\n    var h = d.getHours();\n    var minutes = d.getMinutes();\n\n    if (minutes === 0 ) {\n        offset = 0;\n    } else {\n        offset++;\n    }\n\n    if (msg.kwhoutput) {\n        m.data[m.series.length - 1][h*msg.resolution+offset] = +(Math.round(msg.payload.result[key]/100)*.1).toFixed(1);\n    } else {\n        m.data[m.series.length - 1][h*msg.resolution+offset] = msg.payload.result[key];\n    }\n}\n\nif (msg.watt === 'watt_hours') {\n    for (const i in m.data) {\n        let x = m.data[i][0]\n        for (const d in m.data[i]) {\n            if ( x > m.data[i][d]) {\n                m.data[i][d] = x \n            }\n            x = m.data[i][d]\n        }\n    }\n}\n\nreturn { payload: [m] };\n","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":360,"y":340,"wires":[["5b0a430fb61e70e7"]]},{"id":"975daf96f15cfb61","type":"link out","z":"93f485839dfa27a8","name":"link out 7","mode":"link","links":["14f2e68e572f4ef8"],"x":805,"y":100,"wires":[]},{"id":"14f2e68e572f4ef8","type":"link in","z":"93f485839dfa27a8","name":"link in 18","links":["975daf96f15cfb61"],"x":245,"y":180,"wires":[["c706820c0d61f023"]]},{"id":"c4307905e114824f","type":"catch","z":"93f485839dfa27a8","name":"","scope":null,"uncaught":false,"x":260,"y":440,"wires":[["f427f19392c399ce"]]},{"id":"e56826252134b93a","type":"link out","z":"93f485839dfa27a8","name":"link out 8","mode":"link","links":["dbaf8f5f5a920686"],"x":685,"y":480,"wires":[]},{"id":"dbaf8f5f5a920686","type":"link in","z":"93f485839dfa27a8","name":"link in 19","links":["e56826252134b93a"],"x":385,"y":580,"wires":[["1bfc1cde3ee94e4b"]]},{"id":"f427f19392c399ce","type":"link out","z":"93f485839dfa27a8","name":"link out 9","mode":"link","links":["2ded0c14a222b4d9","2f42837904c91d73"],"x":375,"y":440,"wires":[]},{"id":"2ded0c14a222b4d9","type":"link in","z":"93f485839dfa27a8","name":"link in 20","links":["f427f19392c399ce"],"x":385,"y":540,"wires":[["a798fbe66cf133d5"]]},{"id":"a798fbe66cf133d5","type":"function","z":"93f485839dfa27a8","name":"Set error status","func":"node.warn(msg.payload)\nmsg.payload = ({ fill: \"red\", text: msg.payload });\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":520,"y":540,"wires":[[]]},{"id":"2f42837904c91d73","type":"link in","z":"93f485839dfa27a8","name":"link in 21","links":["f427f19392c399ce"],"x":665,"y":280,"wires":[[]]},{"id":"fcc8d69a3ab88e6d","type":"function","z":"93f485839dfa27a8","name":"Processed info","func":"msg.resolution = 60;\nmsg.days = 1;\nmsg.type = env.get('type');\nmsg.watt = env.get('watt');\nmsg.kwhoutput = env.get('kwhoutput');\n\nvar key1 = Object.keys(msg.payload.result)[1];\nvar key2 = Object.keys(msg.payload.result)[2];\nvar key3 = Object.keys(msg.payload.result)[Object.keys(msg.payload.result).length-1];\n\nvar d1 = new Date(key1);\nvar d2 = new Date(key2); \nvar d3 = new Date(key3);\nmsg.resolution = 3600000 / (d2.getTime() - d1.getTime());\n\nmsg.days = Math.floor((d3.getTime() - d1.getTime()) / (1000 * 3600 * 24));\n\nif (msg.watt === 'watt_hours_day') {\n    msg.resolution = null;\n}\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":360,"y":260,"wires":[["a18e96179ec2d987"]],"info":"Function to process the result from forecast.solar to add\nextra information, which is handy for either graphing or\nto store in a database.\n\n\nThe extra values added:\n- `msg.resolution` - The number of measurements per hour. If\nno API key is used, this will be 1. Other values may be 2 or 4.\n- `msg.days` - The number of days in the forcast. If no API\n- key is used this will be 1. Other values may be 3 or 6."},{"id":"5b0a430fb61e70e7","type":"function","z":"93f485839dfa27a8","name":"Filter graph","func":"var forecasted = msg.payload[0].series.length;\n\nif ((Number(env.get('daystoforecast')) > -1) && (Number(env.get('daystoforecast')) < forecasted)) {\n    for (let i = 1; i <= (forecasted - Number(env.get('daystoforecast'))); i++ ) {\n        msg.payload[0].data.pop();\n        msg.payload[0].series.pop();\n    }\n}\n\nif (!env.get('showtoday')) {\n    msg.payload[0].data.shift();\n    msg.payload[0].series.shift();\n}\n\nif (env.get('showday')) {\n    const weekday = [\"Sunday\", \"Monday\", \"Tuesday\", \"Wednesday\", \"Thursday\", \"Friday\", \"Saturday\"];\n    msg.payload[0].labels.forEach(function (/** @type {string | number | Date} */ date, /** @type {string | number} */ index, /** @type {{ [x: string]: string; }} */ array) {\n        const d = new Date(date)\n        if (!isNaN(d)) {\n            array[index] = weekday[d.getDay()]\n        }\n    })\n    msg.payload[0].series.forEach(function (/** @type {string | number | Date} */ date, /** @type {string | number} */ index, /** @type {{ [x: string]: string; }} */ array) {\n        const d = new Date(date)\n        if (!isNaN(d)) {\n            array[index] = weekday[d.getDay()]\n        }\n    })\n}\n\nif (env.get('widengraph')) {\n    var c = msg.payload[0].labels.length;\n    var x = 0;\n    for (let i = 0; i < c; i++) {\n        var remove = true;\n        for (let d = 0; d < msg.payload[0].data.length; d++) {\n            if (msg.payload[0].data[d][x] > 0) {\n                remove = false;\n            }\n        }\n        if (remove) {\n            msg.payload[0].labels.splice(x, 1);\n            for (let d = 0; d < msg.payload[0].data.length; d++) {\n                 msg.payload[0].data[d].splice(x, 1);\n            }\n            x--;\n        }\n        x++;\n    }\n    // Still the first and last datapoints should be zero, so\n    // add those again\n    msg.payload[0].labels.unshift('');\n    msg.payload[0].labels.push('');\n    for (let d = 0; d < msg.payload[0].data.length; d++) {\n         msg.payload[0].data[d].unshift(0);\n         msg.payload[0].data[d].push(0);\n    }   \n}\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":590,"y":340,"wires":[[]]},{"id":"493ea9baec1082c1","type":"debug","z":"3ab217fef43e55c3","name":"IQ V1 Akku-PV debug","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"payload","targetType":"msg","statusVal":"payload","statusType":"auto","x":1810,"y":600,"wires":[]},{"id":"26b101e163f651cd","type":"enell-strategy-genetic-charging","z":"3ab217fef43e55c3","name":"Test IQ V1 Akku-PV","populationSize":"50","generations":"150","mutationRate":3,"numberOfPricePeriods":8,"batteryMaxEnergy":5,"batteryMaxInputPower":"4","averageConsumption":"1","x":1590,"y":600,"wires":[["493ea9baec1082c1"]]},{"id":"03d33c3f2b1a672e","type":"debug","z":"3ab217fef43e55c3","name":"Solar Forecast debug","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"true","targetType":"full","statusVal":"payload","statusType":"auto","x":770,"y":280,"wires":[]},{"id":"1a02845e699fa805","type":"debug","z":"3ab217fef43e55c3","name":"IQ V2 Akku-PV debug","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"payload","targetType":"msg","statusVal":"payload","statusType":"auto","x":1890,"y":380,"wires":[]},{"id":"8e95ebbbbd2286e1","type":"comment","z":"3ab217fef43e55c3","name":"Solarberechnung für den nächsten Tag","info":"","x":270,"y":220,"wires":[]},{"id":"34d80ecd05f50979","type":"comment","z":"3ab217fef43e55c3","name":"Steuerungsversuch über IQ Lademodule","info":"","x":1160,"y":300,"wires":[]},{"id":"414845545e77cfe2","type":"inject","z":"3ab217fef43e55c3","name":"Tibber 1 Nachts Tages Solar forecast","props":[{"p":"payload"}],"repeat":"","crontab":"00 01 * * *","once":false,"onceDelay":"1","topic":"","payload":"","payloadType":"date","x":230,"y":440,"wires":[["77dbb6adc1e8ac35","db874263ab657cc6"]]},{"id":"e7d4fe295ca44226","type":"function","z":"3ab217fef43e55c3","name":"SolarForecast save global","func":"// Überschreiben Sie die globale Variable mit dem neuen Array\nglobal.set('SolarForecast', msg.payload);\n\n// Senden Sie den gespeicherten Array für den nächsten Node weiter (optional)\nmsg.payload = global.get(\"SolarForecast\");\nreturn msg;\n\n","outputs":1,"timeout":0,"noerr":0,"initialize":"","finalize":"","libs":[],"x":790,"y":400,"wires":[[]]},{"id":"f19f42b9065d284d","type":"inject","z":"3ab217fef43e55c3","name":"Täglich 13:16 Uhr","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"16 13 * * *","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":1090,"y":340,"wires":[["db874263ab657cc6"]]},{"id":"77dbb6adc1e8ac35","type":"subflow:93f485839dfa27a8","z":"3ab217fef43e55c3","name":"","env":[{"name":"latitude","value":"","type":"num"},{"name":"longitude","value":"","type":"num"},{"name":"declination","value":"0","type":"num"},{"name":"azimuth","value":"-8","type":"num"},{"name":"modules power","value":"8","type":"num"},{"name":"apikey","type":"cred"},{"name":"watt","value":"watthours/period","type":"str"},{"name":"kwhoutput","type":"bool","value":"true"},{"name":"daystoforecast","value":"1","type":"str"},{"name":"widengraph","type":"bool","value":"false"}],"x":560,"y":340,"wires":[["03d33c3f2b1a672e","e7d4fe295ca44226"],["4352b6fee281df49"]]},{"id":"4352b6fee281df49","type":"ui_chart","z":"3ab217fef43e55c3","name":"","group":"f0c1f0a0.0c7a9","order":0,"width":0,"height":0,"label":"Solar Power Forecast Chart","chartType":"line","legend":"false","xformat":"HH:mm:ss","interpolate":"linear","nodata":"","dot":false,"ymin":"","ymax":"","removeOlder":1,"removeOlderPoints":"","removeOlderUnit":"3600","cutout":0,"useOneColor":false,"useUTC":false,"colors":["#1f77b4","#aec7e8","#ff7f0e","#2ca02c","#98df8a","#d62728","#ff9896","#9467bd","#c5b0d5"],"outputs":1,"useDifferentColor":false,"className":"","x":800,"y":340,"wires":[[]]},{"id":"6db9f243d4b2cb46","type":"debug","z":"3ab217fef43e55c3","name":"Quell IQ V2 Akku-PV","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"true","targetType":"full","statusVal":"payload","statusType":"auto","x":1610,"y":540,"wires":[]},{"id":"27abd157ef01f354","type":"function","z":"3ab217fef43e55c3","name":"TibberPriceReceiver get global SolarForecast SOC","func":"// Senden Sie den gespeicherten Array für den nächsten Node weiter (optional)\nvar forecast = global.get(\"SolarForecast\").result;\nvar arrayForecast = Object.entries(forecast).map(([start, value]) => ({ start, value }));\n\nvar now = new Date(); // Aktuelles Datum und Uhrzeit\n\n// Funktion, um Daten ab der aktuellen Zeit zu filtern\nfunction filterCurrentAndFutureData(data) {\n    return data.filter(item => {\n        var startTime = new Date(item.start);\n        return startTime >= now;\n    });\n}\n\n// Daten ab der aktuellen Zeit filtern\nvar filteredPriceData = filterCurrentAndFutureData(global.get(\"TibberPriceReceiver\"));\nvar filteredProductionForecast = filterCurrentAndFutureData(arrayForecast);\n\n// Angepasstes Payload-Objekt\nmsg.payload = {\n    priceData: filteredPriceData,\n    productionForecast: filteredProductionForecast,\n    soc: msg.soc\n};\n\nreturn msg;\n","outputs":1,"timeout":0,"noerr":0,"initialize":"","finalize":"","libs":[],"x":1270,"y":500,"wires":[["6db9f243d4b2cb46","26b101e163f651cd","66205a1c02a60778"]]},{"id":"2441bf4d6dfecf41","type":"debug","z":"3ab217fef43e55c3","name":"IQ-V2-Akku-PV-Planung","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"payload","targetType":"msg","statusVal":"payload","statusType":"auto","x":2380,"y":440,"wires":[]},{"id":"58aa873e486de080","type":"ha-sensor","z":"3ab217fef43e55c3","name":"IQ V2 Akku-PV Planung","entityConfig":"5e74c5861a24044b","version":0,"state":"payload","stateType":"str","attributes":[{"property":"Schedule","value":"payload.schedule","valueType":"msg"}],"inputOverride":"allow","outputProperties":[],"x":2130,"y":440,"wires":[["2441bf4d6dfecf41"]]},{"id":"66205a1c02a60778","type":"strategy-genetic-charging","z":"3ab217fef43e55c3","name":"IQ V2 Akku-PV","populationSize":50,"generations":150,"mutationRate":3,"batteryMaxEnergy":5,"batteryMaxInputPower":"4.5","batteryMaxOutputPower":"4.5","averageConsumption":"1.3","excessPvEnergyUse":"1","batteryCost":0,"efficiency":90,"minPrice":"0.10","x":1580,"y":480,"wires":[["1a02845e699fa805","aea7e904246e7c4e","55b5d9419ce146be"]]},{"id":"063ea21c55ee2891","type":"debug","z":"3ab217fef43e55c3","name":"debug 24","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"payload","targetType":"msg","statusVal":"payload","statusType":"auto","x":2150,"y":380,"wires":[]},{"id":"aea7e904246e7c4e","type":"function","z":"3ab217fef43e55c3","name":"calculate schedule","func":"function addMinutes(date, minutes) {\n    return new Date(date.getTime() + minutes * 60 * 1000);\n}\n\n// Get variables from the new payload\nconst newPayload = msg.payload; // replace this with your new data\nconst scheduleData = newPayload.schedule; // This is an array\n// node.warn(\"scheduleData: \" + JSON.stringify(scheduleData));\nconst productionForecast = newPayload.productionForecast; // This is an array\n// node.warn(\"productionForecast: \" + JSON.stringify(productionForecast));\n\nlet schedule = []\nfor (let i = 0; i < scheduleData.length; i++) {\n    let startAt = new Date(scheduleData[i].start);\n    let fixed_setpoint = scheduleData[i].socStart;\n    let adjustments = scheduleData[i].socStart;\n\n    // Find the matching productionForecast for this startAt time\n    let matchingForecast = productionForecast.find(forecast => new Date(forecast.start).getTime() === startAt.getTime());\n\n    // Add data to schedule\nschedule.push({\n    \"startAt\": startAt,\n    \"price\": newPayload.priceData[i].value, // Assuming priceData is in the same order and length as schedule\n    \"SOCstart\": adjustments,\n    \"setpoint\": fixed_setpoint,\n    \"productionForecast\": matchingForecast ? matchingForecast.value : 0 // This will be null if no matching forecast was found\n});\n\n}\n\n// What is the setpoint now?\nconst now = new Date();\nconst currentSchedule = scheduleData.find(item => new Date(item.start) <= now && new Date(item.end) > now);\nconst setpoint_now = currentSchedule ? currentSchedule.activity + currentSchedule.socStart : null;\n\nmsg = {\n    \"payload\": {\n        \"setpoint_now\": setpoint_now,\n        \"schedule\": schedule\n    }\n}\n\nreturn msg;\n","outputs":1,"timeout":"","noerr":0,"initialize":"","finalize":"","libs":[],"x":1870,"y":440,"wires":[["58aa873e486de080","063ea21c55ee2891"]]},{"id":"d743c99e3bf3e01f","type":"inject","z":"3ab217fef43e55c3","name":"Tibber 0:30 Nachts Tages Solar forecast","props":[{"p":"payload"}],"repeat":"","crontab":"30 00 * * *","once":true,"onceDelay":"55","topic":"","payload":"","payloadType":"date","x":240,"y":340,"wires":[["77dbb6adc1e8ac35","db874263ab657cc6"]]},{"id":"db874263ab657cc6","type":"api-current-state","z":"3ab217fef43e55c3","name":"BYD Ladezustand aktuell SOC","server":"xxx","version":3,"outputs":1,"halt_if":"","halt_if_type":"str","halt_if_compare":"is","entity_id":"sensor.byd_battery_box_premium_hv_ladezustand","state_type":"num","blockInputOverrides":false,"outputProperties":[{"property":"soc","propertyType":"msg","value":"","valueType":"entityState"},{"property":"data","propertyType":"msg","value":"","valueType":"entity"}],"for":"0","forType":"num","forUnits":"minutes","override_topic":false,"state_location":"payload","override_payload":"msg","entity_location":"data","override_data":"msg","x":1210,"y":440,"wires":[["27abd157ef01f354"]]},{"id":"2343ecb023072e7c","type":"inject","z":"3ab217fef43e55c3","name":"Test SOC 90","props":[{"p":"soc","v":"10","vt":"num"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","x":970,"y":500,"wires":[["27abd157ef01f354"]]},{"id":"55b5d9419ce146be","type":"function","z":"3ab217fef43e55c3","name":"Ausgabe nur EndSoc Zahl aktuell","func":"// Node-RED Function Node Code\n\n// Stellen Sie sicher, dass das 'schedule' Array verfügbar ist und der erste Eintrag existiert\nif (msg.payload && msg.payload.schedule && msg.payload.schedule.length > 0) {\n    var firstSocEnd = msg.payload.schedule[0].socEnd;\n\n    // Sicherstellen, dass der Wert mindestens 5 und maximal 90 ist\n    firstSocEnd = Math.max(5, Math.min(90, firstSocEnd));\n\n    // Umwandeln des Wertes in eine Ganzzahl, falls notwendig\n    firstSocEnd = Math.floor(firstSocEnd);\n\n    // node.warn(\"Korrigierter und ganzzahliger endSoc: \" + firstSocEnd);\n\n    // Setzen des korrigierten und ganzzahligen Ergebnisses in msg.payload für die Ausgabe\n    msg.payload = firstSocEnd;\n} else {\n    // Loggen eines Fehlers, wenn die Datenstruktur nicht wie erwartet ist\n    node.error(\"schedule Daten sind nicht verfügbar oder das Array ist leer.\");\n    return null; // Rückgabe von null, wenn keine gültigen Daten vorhanden sind\n}\n\nreturn msg;\n","outputs":1,"timeout":0,"noerr":0,"initialize":"","finalize":"","libs":[],"x":1880,"y":500,"wires":[["5fe4f5e2e62e6796"]]},{"id":"5fe4f5e2e62e6796","type":"debug","z":"3ab217fef43e55c3","name":"EndSoc aktuell","active":false,"tosidebar":true,"console":true,"tostatus":true,"complete":"payload","targetType":"msg","statusVal":"payload","statusType":"auto","x":2190,"y":500,"wires":[]},{"id":"f0c1f0a0.0c7a9","type":"ui_group","name":"Solar Power","tab":"0cedae54fbdb9437","order":1,"disp":true,"width":"6","collapse":false,"className":""},{"id":"5e74c5861a24044b","type":"ha-entity-config","server":"xxx","deviceConfig":"079e69c706821a7d","name":"IQ V2 Akku-PV Planung","version":"6","entityType":"sensor","haConfig":[{"property":"name","value":"IQ-V2-Akku-PV-Planung"},{"property":"icon","value":""},{"property":"entity_picture","value":""},{"property":"entity_category","value":""},{"property":"device_class","value":""},{"property":"unit_of_measurement","value":""},{"property":"state_class","value":""}],"resend":false,"debugEnabled":false},{"id":"xxx","type":"server","name":"Home Assistant Friek","version":5,"addon":true,"rejectUnauthorizedCerts":true,"ha_boolean":"y|yes|true|on|home|open","connectionDelay":false,"cacheJson":false,"heartbeat":false,"heartbeatInterval":"30","areaSelector":"friendlyName","deviceSelector":"friendlyName","entitySelector":"friendlyName","statusSeparator":": ","statusYear":"hidden","statusMonth":"short","statusDay":"numeric","statusHourCycle":"default","statusTimeFormat":"h:m","enableGlobalContextStore":false},{"id":"0cedae54fbdb9437","type":"ui_tab","name":"Solar Power Forecast","icon":"dashboard","disabled":false,"hidden":false},{"id":"079e69c706821a7d","type":"ha-device-config","name":"IQ-V2-Akku-PV-Planung","hwVersion":"","manufacturer":"Node-RED","model":"","swVersion":""}]

Flow Info

Created 2 weeks, 3 days ago
Rating: not yet rated

Owner

Actions

Rate:

Node Types

Core
  • catch (x1)
  • comment (x2)
  • debug (x7)
  • delay (x1)
  • function (x11)
  • http request (x1)
  • inject (x5)
  • json (x1)
  • link in (x6)
  • link out (x4)
Other

Tags

  • solar
  • forecast
  • home-assistant
  • tibber
  • ev-charging
  • battery-storage
  • pv-optimization
  • energy-management
  • dynamic-pricing
  • load-scheduling
  • soc-based-charging
  • forecast.solar
  • smart-grid
  • energy-forecast
Copy this flow JSON to your clipboard and then import into Node-RED using the Import From > Clipboard (Ctrl-I) menu option