From 5e8cbc3dceda844d6cd0485dd5960a7f55225f48 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Daniel=20H=C3=A4fliger?= Date: Thu, 13 Nov 2025 07:57:53 +0100 Subject: [PATCH] no message --- Abrechnung/module.json | 15 +- Abrechnung/module.php | 512 ++++++----------------------------------- Int_VGT/README.md | 0 Int_VGT/form.json | 29 +++ Int_VGT/module.json | 12 + Int_VGT/module.php | 327 ++++++++++++++++++++++++++ 6 files changed, 448 insertions(+), 447 deletions(-) create mode 100644 Int_VGT/README.md create mode 100644 Int_VGT/form.json create mode 100644 Int_VGT/module.json create mode 100644 Int_VGT/module.php diff --git a/Abrechnung/module.json b/Abrechnung/module.json index 5bfa2fd..57124e8 100644 --- a/Abrechnung/module.json +++ b/Abrechnung/module.json @@ -1,12 +1,13 @@ { - "id": "{9DAC29C7-F381-F2A4-7CE2-F391C4123F38}", - "name": "Abrechnung", + "id": "{A2B4BC3E-1211-4A8A-8230-29DF46F33819}", + "name": "Int_VGT", "type": 3, - "vendor": "Belevo AG", - "aliases": [], - "parentRequirements": [], + "vendor": "", + "aliases": ["INT VGT Integration"], + "parentRequirements": [ + "{7F8A48DD-F8AD-4F9C-8E6B-9E4D92DDB8F9}" + ], "childRequirements": [], "implemented": [], - "prefix": "ABR", - "url": "" + "prefix": "INTVGT" } diff --git a/Abrechnung/module.php b/Abrechnung/module.php index bbc70fd..7feda2f 100644 --- a/Abrechnung/module.php +++ b/Abrechnung/module.php @@ -1,480 +1,112 @@ RegisterPropertyString('Users', '[]'); - $this->RegisterPropertyString('PowerMeters', '[]'); - $this->RegisterPropertyString('WaterMeters', '[]'); - $this->RegisterPropertyString('Tariffs', '[]'); + // Properties + $this->RegisterPropertyInteger("MQTTServer", 0); + $this->RegisterPropertyString("DeviceID", ""); - $this->RegisterVariableInteger('FromDate', 'Startdatum', '~UnixTimestamp', 1); - $this->RegisterVariableInteger('ToDate', 'Enddatum', '~UnixTimestamp', 2); - $this->RegisterVariableString('LastResult', 'Letzte Abrechnung', '', 3); - $this->EnableAction('FromDate'); - $this->EnableAction('ToDate'); + // Create script handler only once + if (!@$this->GetIDForIdent("ReceiveScript")) { + $scriptID = IPS_CreateScript(0); + IPS_SetName($scriptID, "INTVGT_ReceiveHandler"); + IPS_SetIdent($scriptID, "ReceiveScript"); + IPS_SetParent($scriptID, $this->InstanceID); - $this->RegisterScript('StartBilling', 'Abrechnung starten', "InstanceID . ", 'StartBilling', ''); ?>"); - $this->RegisterMediaDocument('InvoicePDF', 'Letzte Rechnung', 'pdf'); + IPS_SetScriptContent($scriptID, $this->GenerateReceiveScript()); + } } public function ApplyChanges() { parent::ApplyChanges(); + + $mqttServer = $this->ReadPropertyInteger("MQTTServer"); + $deviceId = $this->ReadPropertyString("DeviceID"); + + if ($mqttServer == 0 || $deviceId == "") { + $this->SetStatus(104); // missing config + return; + } + + // Create MQTT Server Devices + $this->RegisterMQTTDevice("FeedbackRequest", "feedback-request/" . $deviceId); + $this->RegisterMQTTDevice("RemoteControlResponse", "remote-control-response/" . $deviceId); + + $this->SetStatus(102); } - private function RegisterMediaDocument($Ident, $Name, $Extension, $Position = 0) + private function RegisterMQTTDevice(string $ident, string $topic) { - $mid = @IPS_GetObjectIDByIdent($Ident, $this->InstanceID); - if ($mid === false) { - $mid = IPS_CreateMedia(5); // 5 = Document - IPS_SetParent($mid, $this->InstanceID); - IPS_SetIdent($mid, $Ident); - IPS_SetName($mid, $Name); - IPS_SetPosition($mid, $Position); - IPS_SetMediaFile($mid, 'media/' . $mid . '.' . $Extension, false); + $instanceID = @$this->GetIDForIdent($ident); + + if ($instanceID === false) { + $instanceID = IPS_CreateInstance("{058A5647-0C2F-4D7D-9F4B-50A28C7D83BA}"); // MQTT Server Device + IPS_SetParent($instanceID, $this->InstanceID); + IPS_SetIdent($instanceID, $ident); + IPS_SetName($instanceID, "MQTT Device: " . $ident); } + + IPS_SetProperty($instanceID, "Topic", $topic); + IPS_SetProperty($instanceID, "Server", $this->ReadPropertyInteger("MQTTServer")); + IPS_SetProperty($instanceID, "Script", $this->GetIDForIdent("ReceiveScript")); + IPS_ApplyChanges($instanceID); + + return $instanceID; } - public function RequestAction($Ident, $Value) + /** Script to be executed when MQTT message is received */ + private function GenerateReceiveScript(): string { - switch ($Ident) { - case 'FromDate': - case 'ToDate': - SetValue($this->GetIDForIdent($Ident), $Value); - break; + return <<GenerateInvoices(); - if (!$pdfContent) { - echo "❌ Fehler bei der PDF-Erstellung"; - return; - } +\$parent = IPS_GetParent(\$_IPS['SELF']); +IPS_RequestAction(\$parent, "OnReceive", json_encode([ + "Topic" => \$_IPS['Topic'], + "Value" => \$_IPS['VALUE'] +])); - $mediaID = $this->GetIDForIdent('InvoicePDF'); - IPS_SetMediaContent($mediaID, base64_encode($pdfContent)); - SetValue($this->GetIDForIdent('LastResult'), 'Abrechnung vom ' . date('d.m.Y H:i')); - echo "✅ PDF erfolgreich erstellt."; - } catch (Throwable $e) { - echo "❌ Ausnahmefehler: " . $e->getMessage(); - } - break; - } +SCR; } - // ====================== PDF-Erstellung ====================== - - public function GenerateInvoices() + /** Called by ReceiveScript */ + public function RequestAction($ident, $value) { - $from = GetValue($this->GetIDForIdent('FromDate')); - $to = GetValue($this->GetIDForIdent('ToDate')); - - $users = json_decode($this->ReadPropertyString('Users'), true); - $power = json_decode($this->ReadPropertyString('PowerMeters'), true); - $water = json_decode($this->ReadPropertyString('WaterMeters'), true); - $tariffs = json_decode($this->ReadPropertyString('Tariffs'), true); - - if (!class_exists('TCPDF')) return false; - - $pdf = new TCPDF('P', 'mm', 'A4', true, 'UTF-8', false); - $pdf->SetCreator('IPSymcon Abrechnung'); - $pdf->SetMargins(15, 15, 15); - $pdf->SetAutoPageBreak(true, 20); - $pdf->SetFont('dejavusans', '', 9); - - foreach ($users as $user) { - $this->BuildUserInvoice($pdf, $user, $power, $water, $tariffs, $from, $to); + if ($ident == "OnReceive") { + $data = json_decode($value, true); + $this->OnReceiveMQTT($data["Topic"], $data["Value"]); } - - return $pdf->Output('Abrechnung.pdf', 'S'); } - private function BuildUserInvoice($pdf, $user, $power, $water, $tariffs, $from, $to) + /** THIS IS YOUR CALLBACK FOR INCOMING MQTT MESSAGES */ + private function OnReceiveMQTT(string $topic, string $value) { - $pdf->AddPage(); + IPS_LogMessage("Int_VGT", "Received on $topic: $value"); - $html = " -

Rechnung für {$user['name']}

-

{$user['address']}
{$user['city']}

-

Zeitraum: " . date('d.m.Y', $from) . " – " . date('d.m.Y', $to) . "


"; + // Here you implement later your handling logic + // Example: respond to feedback-request + $mqttServer = $this->ReadPropertyInteger("MQTTServer"); - // ⚡ Stromkosten - $html .= "

⚡ Stromkosten

"; - $powerResult = $this->CalculatePowerCosts($power, $tariffs, $user['id'], $from, $to); - $html .= $powerResult['html']; - $totalPower = $powerResult['sum']; - - // 💧 Nebenkosten - $html .= "

💧 Nebenkosten (Wasser/Wärme)

"; - $additionalResult = $this->CalculateAdditionalCosts($water, $tariffs, $user['id'], $from, $to); - $html .= $additionalResult['html']; - $totalAdditional = $additionalResult['sum']; - - $grandTotal = $totalPower + $totalAdditional; - $html .= "

Gesamttotal: " . number_format($grandTotal, 2) . " CHF

"; - - $pdf->writeHTML($html, true, false, true, false, ''); - } - - // ====================== Nebenkosten ====================== -private function CalculatePowerCosts($powerMeters, $tariffs, $userId, $from, $to) -{ - $html = " - - - - - - - - - - - - - "; - - $acc = []; - $meters = []; - - foreach ($powerMeters as $m) { - if ($m['user_id'] != $userId) continue; - $name = $m['name']; - $meters[$name] = [ - 'name' => $name, - 'imp' => $m['var_import'] ?? null, - 'exp' => $m['var_export'] ?? null - ]; - $acc[$name] = [ - 'imp'=>0.0,'exp'=>0.0, - 'solar_bezug'=>0.0,'netz_bezug'=>0.0, - 'solareinspeisung'=>0.0,'solarverkauf'=>0.0, - 'cost_solar'=>0.0,'cost_grid'=>0.0, - 'rev_feedin'=>0.0 - ]; - } - - if (empty($meters)) { - $html .= "
ZählerImport (kWh)Export (kWh)Solarbezug (kWh)Netzbezug (kWh)Solareinspeisung (kWh)Solarverkauf (kWh)Kosten Solar (CHF)Kosten Netz (CHF)Ertrag Einspeisung (CHF)Summe (CHF)
Keine Stromzähler für diesen Benutzer

"; - return ['html'=>$html, 'sum'=>0.0]; - } - - // 15-Minuten-Schritte - for ($ts = $from; $ts < $to; $ts += 900) { - $slotEnd = min($to, $ts + 900); - - $pGrid = $this->getTariffPriceAt($tariffs, ['Netztarif'], $ts); - $pSolar = $this->getTariffPriceAt($tariffs, ['Solartarif'], $ts); - $pFeed = $this->getTariffPriceAt($tariffs, ['Einspeisetarif'], $ts); - - $impTotal = 0.0; - $expTotal = 0.0; - $slot = []; - - foreach ($meters as $name => $mm) { - $impDelta = $expDelta = 0.0; - - if (!empty($mm['imp']) && IPS_VariableExists((int)$mm['imp'])) { - $impDelta = $this->readDelta((int)$mm['imp'], $ts, $slotEnd); - } - if (!empty($mm['exp']) && IPS_VariableExists((int)$mm['exp'])) { - $expDelta = $this->readDelta((int)$mm['exp'], $ts, $slotEnd); - } - - if ($impDelta > 0 || $expDelta > 0) { - $slot[$name] = ['imp' => $impDelta, 'exp' => $expDelta]; - $impTotal += $impDelta; - $expTotal += $expDelta; - } + if (str_contains($topic, "feedback-request")) { + $response = json_encode([ + "status" => "ok", + "timestamp" => time() + ]); + MQTT_Publish($mqttServer, str_replace("request", "response", $topic), $response, 0, false); } - // 🧠 --- AB HIER gezieltes Debug-Logging --- - IPS_LogMessage('Abrechnung', sprintf( - "INTERVALL %s – %s | impTotal=%.5f expTotal=%.5f grid=%.3f solar=%.3f feed=%.3f", - date('H:i', $ts), date('H:i', $slotEnd), - $impTotal, $expTotal, - $pGrid ?? 0, $pSolar ?? 0, $pFeed ?? 0 - )); - - if ($impTotal == 0 && $expTotal == 0) continue; - - if ($impTotal <= $expTotal && $expTotal > 0) { - $ratio = $impTotal / $expTotal; - IPS_LogMessage('Abrechnung', sprintf("→ Fall 1 (imp<=exp) ratio=%.4f", $ratio)); - } elseif ($impTotal > 0) { - $ratio = $expTotal / $impTotal; - IPS_LogMessage('Abrechnung', sprintf("→ Fall 2 (imp>exp) ratio=%.4f", $ratio)); - } else { - $ratio = 0; - } - - foreach ($slot as $name => $v) { - $imp = $v['imp']; - $exp = $v['exp']; - - if ($impTotal <= $expTotal) { - $acc[$name]['solar_bezug'] += $imp; - $acc[$name]['solareinspeisung']+= (1 - $ratio) * $exp; - $acc[$name]['solarverkauf'] += $ratio * $exp; - if ($pSolar !== null) $acc[$name]['cost_solar'] += ($imp * $pSolar) / 100; - if ($pFeed !== null) $acc[$name]['rev_feedin'] += ((1 - $ratio) * $exp * $pFeed) / 100; - } else { - $acc[$name]['solar_bezug'] += $ratio * $imp; - $acc[$name]['netz_bezug'] += (1 - $ratio) * $imp; - $acc[$name]['solarverkauf'] += $exp; - if ($pGrid !== null) $acc[$name]['cost_grid'] += ((1 - $ratio) * $imp * $pGrid) / 100; - if ($pSolar !== null) $acc[$name]['cost_solar'] += ($ratio * $imp * $pSolar) / 100; - if ($pFeed !== null) $acc[$name]['rev_feedin'] += ($exp * $pFeed) / 100; - } - - IPS_LogMessage('Abrechnung', sprintf( - " %s | imp=%.4f exp=%.4f ratio=%.4f → solarB=%.4f netzB=%.4f solarE=%.4f solarV=%.4f cGrid=%.4f cSolar=%.4f rFeed=%.4f", - $name, $imp, $exp, $ratio, - $acc[$name]['solar_bezug'], $acc[$name]['netz_bezug'], - $acc[$name]['solareinspeisung'], $acc[$name]['solarverkauf'], - $acc[$name]['cost_grid'], $acc[$name]['cost_solar'], $acc[$name]['rev_feedin'] - )); + if (str_contains($topic, "remote-control-response")) { + // Echo back the same payload + MQTT_Publish($mqttServer, str_replace("response", "feedback", $topic), $value, 0, false); } } - - // --- Tabelle am Ende aufbauen --- - $sum = 0.0; - foreach ($acc as $name => $a) { - $subtotal = $a['cost_grid'] + $a['cost_solar'] - $a['rev_feedin']; - $sum += $subtotal; - - $html .= " - {$name} - " . number_format($a['imp'], 3) . " - " . number_format($a['exp'], 3) . " - " . number_format($a['solar_bezug'], 3) . " - " . number_format($a['netz_bezug'], 3) . " - " . number_format($a['solareinspeisung'], 3) . " - " . number_format($a['solarverkauf'], 3) . " - " . number_format($a['cost_solar'], 2) . " - " . number_format($a['cost_grid'], 2) . " - " . number_format($a['rev_feedin'], 2) . " - " . number_format($subtotal, 2) . " - "; - } - - $html .= " - Total Stromkosten: - " . number_format($sum, 2) . " -
"; - - return ['html' => $html, 'sum' => $sum]; } - private function CalculateAdditionalCosts($waterMeters, $tariffs, $userId, $from, $to) - { - $html = " - - - - "; - - $total = 0.0; - $usedTariffs = []; - - foreach ($waterMeters as $m) { - if ($m['user_id'] != $userId) continue; - $type = $m['meter_type'] ?? 'Warmwasser'; - $cost = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, $type); - $html .= $cost['row']; - $total += $cost['value']; - $usedTariffs = array_merge($usedTariffs, $cost['tariffs']); - } - - $html .= " - - -
ZählerTypStartEndeZähler StartZähler EndeVerbrauchTarif (Rp)Kosten (CHF)
Total Nebenkosten:" . number_format($total, 2) . "

"; - - if (!empty($usedTariffs)) { - $html .= "

Angewendete Nebenkostentarife:


"; - } - - return ['html' => $html, 'sum' => $total]; - } - - // ====================== Kernlogik für Wasser/Wärme ====================== - - private function AddMeterToPDFRow($meter, $tariffs, $from, $to, $type) - { - $rows = ''; - $totalCost = 0.0; - $usedTariffs = []; - $varId = $meter['var_consumption']; - - if (!IPS_VariableExists($varId)) return ['row' => '', 'value' => 0, 'tariffs' => []]; - - $filteredTariffs = array_filter($tariffs, fn($t) => - strtolower(trim($t['unit_type'] ?? '')) === strtolower(trim($type)) - ); - - foreach ($filteredTariffs as &$t) { - $t['start_ts'] = $this->toUnixTs($t['start'], false); - $t['end_ts'] = $this->toUnixTs($t['end'], true); - } - unset($t); - usort($filteredTariffs, fn($a, $b) => ($a['start_ts'] ?? 0) <=> ($b['start_ts'] ?? 0)); - - $currentStart = $from; - while ($currentStart < $to) { - $activeTariff = null; - foreach ($filteredTariffs as $t) { - if (($t['start_ts'] ?? 0) <= $currentStart && $currentStart <= ($t['end_ts'] ?? 0)) { - $activeTariff = $t; - break; - } - } - - if (!$activeTariff) { - $activeTariff = ['start_ts' => $currentStart, 'end_ts' => $to, 'price' => 0.0]; - } - - $tariffEnd = intval($activeTariff['end_ts']); - $tariffPrice = floatval($activeTariff['price']); - - $key = $activeTariff['start_ts'] . '-' . $activeTariff['end_ts'] . '-' . $tariffPrice; - if (!isset($usedTariffs[$key])) { - $usedTariffs[$key] = [ - 'start' => $activeTariff['start_ts'], - 'end' => $activeTariff['end_ts'], - 'price' => $tariffPrice - ]; - } - - $startValue = $this->GetValueAt($varId, $currentStart, true); - $segmentEnd = ($tariffEnd < $to) ? $tariffEnd : $to; - $endValue = $this->GetValueAt($varId, $segmentEnd, true); - - if ($startValue === null || $endValue === null) break; - - $verbrauch = max(0, $endValue - $startValue); - $kosten = round(($tariffPrice / 100) * $verbrauch, 2); - $totalCost += $kosten; - - $rows .= " - {$meter['name']} - {$type} - " . date('d.m.Y', $currentStart) . " - " . date('d.m.Y', $segmentEnd) . " - " . number_format($startValue, 2) . " - " . number_format($endValue, 2) . " - " . number_format($verbrauch, 2) . " - " . number_format($tariffPrice, 2) . " - " . number_format($kosten, 2) . " - "; - - if ($tariffEnd < $to) $currentStart = $tariffEnd + 1; - else break; - } - - if ($rows === '') return ['row' => '', 'value' => 0, 'tariffs' => []]; - - return ['row' => $rows, 'value' => $totalCost, 'tariffs' => array_values($usedTariffs)]; - } - - // ====================== Hilfsfunktionen ====================== - - private function GetValueAt($varId, $timestamp, $nearestAfter = true) - { - $archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0]; - if (!$archiveID || !IPS_VariableExists($varId)) return null; - - $values = @AC_GetLoggedValues($archiveID, $varId, $timestamp - 30 * 86400, $timestamp + 30 * 86400, 0); - if (empty($values)) return floatval(GetValue($varId)); - - $closest = null; - foreach ($values as $v) { - if ($nearestAfter && $v['TimeStamp'] >= $timestamp) { - $closest = $v['Value']; - break; - } elseif (!$nearestAfter && $v['TimeStamp'] <= $timestamp) { - $closest = $v['Value']; - } - } - - return $closest ?? floatval(GetValue($varId)); - } - - private function toUnixTs($val, $endOfDay = false) - { - if (is_int($val)) return $val; - if (is_numeric($val)) return intval($val); - - if (is_string($val)) { - $s = trim($val); - if ($s !== '' && $s[0] === '{') { - $obj = json_decode($s, true); - if (isset($obj['year'], $obj['month'], $obj['day'])) { - $time = $endOfDay ? '23:59:59' : '00:00:00'; - return strtotime(sprintf('%04d-%02d-%02d %s', $obj['year'], $obj['month'], $obj['day'], $time)); - } - } - $ts = strtotime($s); - return $ts === false ? null : $ts; - } - return null; - } - - private function readDelta($varId, $tStart, $tEnd) - { - if (!is_int($tStart)) $tStart = strtotime($tStart); - if (!is_int($tEnd)) $tEnd = strtotime($tEnd); - - $archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0]; - if (!$archiveID || !IPS_VariableExists($varId)) return 0.0; - - $values = @AC_GetLoggedValues($archiveID, $varId, $tStart - 86400, $tEnd + 86400, 0); - if (empty($values)) return 0.0; - - usort($values, fn($a, $b) => intval($a['TimeStamp']) <=> intval($b['TimeStamp'])); - $vStart = null; - $vEnd = null; - - foreach ($values as $v) { - if ($v['TimeStamp'] <= $tStart) $vStart = $v['Value']; - if ($v['TimeStamp'] <= $tEnd) $vEnd = $v['Value']; - if ($v['TimeStamp'] > $tEnd) break; - } - - if ($vStart === null) $vStart = floatval(GetValue($varId)); - if ($vEnd === null) $vEnd = floatval(GetValue($varId)); - - $diff = $vEnd - $vStart; - return ($diff < 0) ? 0.0 : $diff; - } - - private function getTariffPriceAt($tariffs, $typeSynonyms, $ts) - { - $wanted = array_map('strtolower', $typeSynonyms); - $cands = []; - foreach ($tariffs as $t) { - $u = strtolower(trim($t['unit_type'] ?? '')); - if (!in_array($u, $wanted)) continue; - - $s = $this->toUnixTs($t['start'], false); - $e = $this->toUnixTs($t['end'], true); - if (!$s || !$e) continue; - if ($s <= $ts && $ts <= $e) $cands[] = floatval($t['price']); - } - if (empty($cands)) return null; - return end($cands); - } -} ?> diff --git a/Int_VGT/README.md b/Int_VGT/README.md new file mode 100644 index 0000000..e69de29 diff --git a/Int_VGT/form.json b/Int_VGT/form.json new file mode 100644 index 0000000..db8fe2b --- /dev/null +++ b/Int_VGT/form.json @@ -0,0 +1,29 @@ +{ + "elements": [ + { + "type": "SelectInstance", + "name": "MQTTServer", + "caption": "MQTT Server", + "filter": "moduleID:{043EA491-84DA-4DFD-B9D4-44B4E63F23D1}" + }, + { + "type": "ValidationTextBox", + "name": "DeviceID", + "caption": "Device ID" + } + ], + "actions": [ + { + "type": "Label", + "label": "Dieses Modul erzeugt automatisch MQTT Server Devices für die beiden Topics:" + }, + { + "type": "Label", + "label": "→ feedback-request/" + }, + { + "type": "Label", + "label": "→ remote-control-response/" + } + ] +} diff --git a/Int_VGT/module.json b/Int_VGT/module.json new file mode 100644 index 0000000..468e0f8 --- /dev/null +++ b/Int_VGT/module.json @@ -0,0 +1,12 @@ +{ + "id": "{F6C6A4B2-C5BB-4D94-2629-01D8B0D4CAF5}", + "name": "Batterie", + "type": 3, + "vendor": "Belevo AG", + "aliases": [], + "parentRequirements": [], + "childRequirements": [], + "implemented": [], + "prefix": "GEF", + "url": "" +} \ No newline at end of file diff --git a/Int_VGT/module.php b/Int_VGT/module.php new file mode 100644 index 0000000..418aaaf --- /dev/null +++ b/Int_VGT/module.php @@ -0,0 +1,327 @@ +RegisterPropertyInteger("MaxBatterieleistung", 0); + $this->RegisterPropertyInteger("Batteriespannung", 50); + $this->RegisterPropertyInteger("AufdasNachladen",0); + $this->RegisterPropertyInteger("MinimumEntladen",0); + $this->RegisterPropertyInteger("Batterieladezustand",0); + $this->RegisterPropertyInteger("Batteriemanagement", 1); + $this->RegisterPropertyInteger("MaxNachladen",0); + $this->RegisterPropertyInteger("Netzbezug", 0); // Initialisierung mit 0 + $this->RegisterPropertyInteger("Interval", 2); // Recheninterval + $this->RegisterPropertyInteger("Batterieleistung_Effektiv", 0); // Recheninterval + + // Variabeln für Kommunkation mit Manager + $this->RegisterVariableFloat("Entladeleistung","Entladeleistung", "",0); + $this->RegisterVariableInteger("Batteriemanagement_Variabel","Batteriemanagement_Variabel", "",0); + $this->RegisterVariableInteger("Laden3_Entladen4","Laden3_Entladen4", "",3); + $this->RegisterVariableFloat("Ladeleistung","Ladeleistung", "",0); + $this->RegisterVariableInteger("Aktuelle_Leistung", "Aktuelle_Leistung", "", 0); + $this->RegisterVariableString("PowerSteps", "PowerSteps"); + $this->RegisterVariableBoolean("Idle", "Idle", "", 0); + $this->RegisterVariableInteger("Sperre_Prio", "Sperre_Prio"); + $this->RegisterVariableInteger("PV_Prio", "PV_Prio"); + $this->RegisterVariableInteger("Power", "Power"); + $this->RegisterVariableBoolean("Is_Peak_Shaving", "Is_Peak_Shaving"); + $this->RegisterVariableInteger("Leistung_Delta", "Leistung_Delta", "", 0); + + $this->RegisterVariableBoolean("Hysterese", "Hysterese","",false); + + + + $this->RegisterVariableFloat("Bezogene_Energie", "Bezogene_Energie", "", 0); + + // Hilfsvariabeln für Idle zustand + $this->RegisterPropertyInteger("IdleCounterMax", 2); + $this->RegisterVariableInteger("IdleCounter", "IdleCounter", "", 0); + $this->SetValue("IdleCounter", 0); + + // Initialisiere Idle + $this->SetValue("Idle", true); + + $this->RegisterTimer("Timer_Do_UserCalc_Battery",$this->ReadPropertyInteger("Interval")*1000,"IPS_RequestAction(" .$this->InstanceID .', "Do_UserCalc", "");'); + + + } + + public function ApplyChanges() + { + parent::ApplyChanges(); + + $batterieManagement = $this->ReadPropertyInteger("Batteriemanagement"); + $this->SetValue("Batteriemanagement_Variabel", $batterieManagement); + $this->SetTimerInterval("Timer_Do_UserCalc_Battery",$this->ReadPropertyInteger("Interval")*1000); + } + + + private function GeneratePowerSteps($additionalValue) + { + $maxleistung = $this->ReadPropertyInteger("MaxBatterieleistung"); + $stepSize = 250; // Schrittgröße + $stepSizeSmall = 50; // Kleine Schrittgröße + + // Array direkt als Range erzeugen (schneller als Schleife) + $array_powersteps = range(-$maxleistung, $maxleistung, $stepSize); + + // Nächstgelegenen Wert direkt bestimmen (rundet auf den nächsten Step) + $closestValue = round($additionalValue / $stepSize) * $stepSize; + + // Falls der Wert nicht im Bereich liegt, abbrechen + if (!in_array($closestValue, $array_powersteps)) { + return $array_powersteps; + } + + // Index des gefundenen Werts suchen + $index = array_search($closestValue, $array_powersteps); + + // Zusätzliche Werte berechnen und auf MaxLeistung begrenzen + $newValues = array_filter([ + $closestValue - 4 * $stepSizeSmall, + $closestValue - 3 * $stepSizeSmall, + $closestValue - 2 * $stepSizeSmall, + $closestValue - $stepSizeSmall, + $closestValue, + $closestValue + $stepSizeSmall, + $closestValue + 2 * $stepSizeSmall, + $closestValue + 3 * $stepSizeSmall, + $closestValue + 4 * $stepSizeSmall, + ], function ($value) use ($maxleistung) { + return $value >= -$maxleistung && $value <= $maxleistung; + }); + + // Effizienteres Einfügen der Werte (direkt an der Stelle) + array_splice($array_powersteps, $index, 1, $newValues); + + return $array_powersteps; + } + + + + +public function RequestAction($Ident, $Value) +{ + switch ($Ident) { + + case "SetAktuelle_Leistung": + $this->SetValue("Power", (int)$Value); + break; + + case "GetCurrentData": + $this->SetValue("Is_Peak_Shaving", (bool)$Value); + break; + + + case "Do_UserCalc": + + $this->SetAktuelle_Leistung($this->GetValue("Power")); + $this->GetCurrentData($this->GetValue("Is_Peak_Shaving")); + break; + + default: + throw new Exception("Invalid Ident"); + } +} + + public function SetAktuelle_Leistung(int $power) + { + + $batterieManagement = $this->ReadPropertyInteger("Batteriemanagement"); + // Wechselrichter steuert das Laden/Entladen der Batterie + if ($batterieManagement == 1) { + $this->SetValue("Entladeleistung", 0); + $this->SetValue("Ladeleistung", 0); + return; + } + + + if($this->GetValue("Is_Peak_Shaving")==true){ + if ($power >= 0) { + $this->SetValue("Ladeleistung", $power); + $this->SetValue("Entladeleistung", 0); + $this->SetValue("Laden3_Entladen4", 3); + } else { + $this->SetValue("Entladeleistung", abs($power)); + $this->SetValue("Ladeleistung", 0); + $this->SetValue("Laden3_Entladen4", 4); + } + + }else{ + if ($power >= 0) { + $this->SetValue("Ladeleistung", $power); + $this->SetValue("Entladeleistung", 0); + $this->SetValue("Laden3_Entladen4", 3); + } else { + $this->SetValue("Entladeleistung", abs($power)); + $this->SetValue("Ladeleistung", 0); + $this->SetValue("Laden3_Entladen4", 4); + } + + } + + // Prüfe auf Änderung der Leistung im Vergleich zur letzten Einstellung + $lastPower = GetValue($this->GetIDForIdent("Aktuelle_Leistung")); + if ($power != $lastPower) { + $this->SetValue("Idle", false); + $this->SetValue( + "IdleCounter", + $this->ReadPropertyInteger("IdleCounterMax") + ); + } + + // Setze die neue aktuelle Leistung + $this->SetValue("Aktuelle_Leistung", $power); + $this->SetValue("Bezogene_Energie", ($this->GetValue("Bezogene_Energie") + ($this->GetValue("Aktuelle_Leistung")*($this->ReadPropertyInteger("Interval")/3600)))); + + // IdleCounter verarbeiten + $this->ProcessIdleCounter(); + + + } + + + public function GetCurrentData(bool $Peak) + { + IPS_LogMessage("Batterie", "Currentdata"); + + $array_powersteps = $this->GeneratePowerSteps($this->GetValue("Aktuelle_Leistung")); + $aufdasnachladen = $this->ReadPropertyInteger("AufdasNachladen"); + $minimumentladen = $this->ReadPropertyInteger("MinimumEntladen"); + $maxleistung = $this->ReadPropertyInteger("MaxBatterieleistung"); + $dummy_array = []; + $batterieladezustand = GetValue($this->ReadPropertyInteger("Batterieladezustand")); + $filtered_powersteps_entladen = []; + if ($this->ReadPropertyInteger("Batteriemanagement") == 1) { + $dummy_array[] = 0; + return $this->SetValue("PowerSteps", json_encode($dummy_array)); + } + + $netzbezug = GetValue($this->ReadPropertyInteger("Netzbezug")); + if (abs($netzbezug) > $maxleistung) { + $netzbezug = $maxleistung * (-1); + } + + if($batterieladezustand>(5+$aufdasnachladen)){ + + $this->SetValue("Hysterese", false); + + }elseif($batterieladezustand<=$aufdasnachladen){ + $this->SetValue("Hysterese", true); + } + + $hyst = $this->GetValue("Hysterese"); + + if($Peak){ + IPS_LogMessage("Batterie", "Im if teil"); + + if($batterieladezustand>$aufdasnachladen && $hyst==false){ + + $dummy_array[] = $netzbezug; + $this->SetValue("PowerSteps", json_encode($dummy_array)); + + }elseif($batterieladezustand>$aufdasnachladen && $hyst==true){ + + + $filtered_powersteps = array_filter($array_powersteps, function ($value) { + return $value <= 0; + }); + $filtered_powersteps_laden = array_values($filtered_powersteps); + $this->SetValue("PowerSteps", json_encode($filtered_powersteps_laden)); + + }elseif($batterieladezustand>$minimumentladen){ + + $this->SetValue("PowerSteps", json_encode($array_powersteps)); + } + else{ + + $filtered_powersteps = array_filter($array_powersteps, function ($value) { + return $value >= 0; + }); + $filtered_powersteps_laden = array_values($filtered_powersteps); + $this->SetValue("PowerSteps", json_encode($filtered_powersteps_laden)); + } + + }else{ + IPS_LogMessage("Batterie", "Im else teil"); + + + if($batterieladezustand>99){ + IPS_LogMessage("Batterie", "im 1"); + + $filtered_powersteps = array_filter($array_powersteps, function ($value) { + return $value <= 0; + }); + $filtered_powersteps_laden = array_values($filtered_powersteps); + $this->SetValue("PowerSteps", json_encode($filtered_powersteps_laden)); + + }elseif($batterieladezustand>$aufdasnachladen && $hyst==false){ + + $this->SetValue("PowerSteps", json_encode($array_powersteps)); + IPS_LogMessage("Batterie", "im 2"); + + + }elseif($batterieladezustand>=$aufdasnachladen && $hyst==true){ + + $filtered_powersteps = array_filter($array_powersteps, function ($value) { + return $value >= 0; + }); + $filtered_powersteps_laden = array_values($filtered_powersteps); + $this->SetValue("PowerSteps", json_encode($filtered_powersteps_laden)); + + + }elseif($batterieladezustand<$aufdasnachladen){ + + $dummy_array[] = $this->ReadPropertyInteger("MaxNachladen"); + $this->SetValue("PowerSteps", json_encode($dummy_array)); + IPS_LogMessage("Batterie", "im 3"); + + } + + } + + } + + + + + private function CheckIdle($power) + { + $lastpower = GetValue("Aktuelle_Leistung"); + if ($lastpower != GetValue("Aktuelle_Leistung")) { + $this->SetValue("Idle", false); + $this->SetValue( + "IdleCounter", + $this->ReadPropertyInteger("IdleCounterMax") + ); + } + // IdleCounter auslesen und verarbeiten + $idleCounter = $this->GetValue("IdleCounter"); + if ($idleCounter > 0) { + $this->SetValue("Idle", false); + $this->SetValue("IdleCounter", $idleCounter - 1); + } else { + $this->SetValue("Idle", true); + } + } + + + private function ProcessIdleCounter() + { + // IdleCounter auslesen und verarbeiten + $idleCounter = $this->GetValue("IdleCounter"); + if ($idleCounter > 0) { + $this->SetValue("Idle", false); + $this->SetValue("IdleCounter", $idleCounter - 1); + } else { + $this->SetValue("Idle", true); + } + } + +} +?>