From c2161abb343a3492016262cf0177633be5172385 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Daniel=20H=C3=A4fliger?= Date: Thu, 13 Nov 2025 08:01:22 +0100 Subject: [PATCH] no message --- Abrechnung/module.json | 15 +- Abrechnung/module.php | 512 +++++++++++++++++++++++++++++++++++------ Int_VGT/module.json | 23 +- Int_VGT/module.php | 381 +++++++----------------------- 4 files changed, 542 insertions(+), 389 deletions(-) diff --git a/Abrechnung/module.json b/Abrechnung/module.json index 57124e8..5bfa2fd 100644 --- a/Abrechnung/module.json +++ b/Abrechnung/module.json @@ -1,13 +1,12 @@ { - "id": "{A2B4BC3E-1211-4A8A-8230-29DF46F33819}", - "name": "Int_VGT", + "id": "{9DAC29C7-F381-F2A4-7CE2-F391C4123F38}", + "name": "Abrechnung", "type": 3, - "vendor": "", - "aliases": ["INT VGT Integration"], - "parentRequirements": [ - "{7F8A48DD-F8AD-4F9C-8E6B-9E4D92DDB8F9}" - ], + "vendor": "Belevo AG", + "aliases": [], + "parentRequirements": [], "childRequirements": [], "implemented": [], - "prefix": "INTVGT" + "prefix": "ABR", + "url": "" } diff --git a/Abrechnung/module.php b/Abrechnung/module.php index 7feda2f..bbc70fd 100644 --- a/Abrechnung/module.php +++ b/Abrechnung/module.php @@ -1,112 +1,480 @@ RegisterPropertyInteger("MQTTServer", 0); - $this->RegisterPropertyString("DeviceID", ""); + $this->RegisterPropertyString('Users', '[]'); + $this->RegisterPropertyString('PowerMeters', '[]'); + $this->RegisterPropertyString('WaterMeters', '[]'); + $this->RegisterPropertyString('Tariffs', '[]'); - // 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->RegisterVariableInteger('FromDate', 'Startdatum', '~UnixTimestamp', 1); + $this->RegisterVariableInteger('ToDate', 'Enddatum', '~UnixTimestamp', 2); + $this->RegisterVariableString('LastResult', 'Letzte Abrechnung', '', 3); + $this->EnableAction('FromDate'); + $this->EnableAction('ToDate'); - IPS_SetScriptContent($scriptID, $this->GenerateReceiveScript()); - } + $this->RegisterScript('StartBilling', 'Abrechnung starten', "InstanceID . ", 'StartBilling', ''); ?>"); + $this->RegisterMediaDocument('InvoicePDF', 'Letzte Rechnung', 'pdf'); } 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 RegisterMQTTDevice(string $ident, string $topic) + private function RegisterMediaDocument($Ident, $Name, $Extension, $Position = 0) { - $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); + $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); } - - IPS_SetProperty($instanceID, "Topic", $topic); - IPS_SetProperty($instanceID, "Server", $this->ReadPropertyInteger("MQTTServer")); - IPS_SetProperty($instanceID, "Script", $this->GetIDForIdent("ReceiveScript")); - IPS_ApplyChanges($instanceID); - - return $instanceID; } - /** Script to be executed when MQTT message is received */ - private function GenerateReceiveScript(): string + public function RequestAction($Ident, $Value) { - return <<GetIDForIdent($Ident), $Value); + break; -\$parent = IPS_GetParent(\$_IPS['SELF']); -IPS_RequestAction(\$parent, "OnReceive", json_encode([ - "Topic" => \$_IPS['Topic'], - "Value" => \$_IPS['VALUE'] -])); + case 'StartBilling': + try { + $pdfContent = $this->GenerateInvoices(); + if (!$pdfContent) { + echo "❌ Fehler bei der PDF-Erstellung"; + return; + } -SCR; + $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; + } } - /** Called by ReceiveScript */ - public function RequestAction($ident, $value) + // ====================== PDF-Erstellung ====================== + + public function GenerateInvoices() { - if ($ident == "OnReceive") { - $data = json_decode($value, true); - $this->OnReceiveMQTT($data["Topic"], $data["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); } + + return $pdf->Output('Abrechnung.pdf', 'S'); } - /** THIS IS YOUR CALLBACK FOR INCOMING MQTT MESSAGES */ - private function OnReceiveMQTT(string $topic, string $value) + private function BuildUserInvoice($pdf, $user, $power, $water, $tariffs, $from, $to) { - IPS_LogMessage("Int_VGT", "Received on $topic: $value"); + $pdf->AddPage(); - // Here you implement later your handling logic - // Example: respond to feedback-request - $mqttServer = $this->ReadPropertyInteger("MQTTServer"); + $html = " +

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

+

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

+

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


"; - if (str_contains($topic, "feedback-request")) { - $response = json_encode([ - "status" => "ok", - "timestamp" => time() - ]); - MQTT_Publish($mqttServer, str_replace("request", "response", $topic), $response, 0, false); + // ⚡ 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, "remote-control-response")) { - // Echo back the same payload - MQTT_Publish($mqttServer, str_replace("response", "feedback", $topic), $value, 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'] + )); } } + + // --- 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/module.json b/Int_VGT/module.json index 468e0f8..57124e8 100644 --- a/Int_VGT/module.json +++ b/Int_VGT/module.json @@ -1,12 +1,13 @@ { - "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 + "id": "{A2B4BC3E-1211-4A8A-8230-29DF46F33819}", + "name": "Int_VGT", + "type": 3, + "vendor": "", + "aliases": ["INT VGT Integration"], + "parentRequirements": [ + "{7F8A48DD-F8AD-4F9C-8E6B-9E4D92DDB8F9}" + ], + "childRequirements": [], + "implemented": [], + "prefix": "INTVGT" +} diff --git a/Int_VGT/module.php b/Int_VGT/module.php index 418aaaf..7feda2f 100644 --- a/Int_VGT/module.php +++ b/Int_VGT/module.php @@ -1,327 +1,112 @@ 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", "");'); + // Properties + $this->RegisterPropertyInteger("MQTTServer", 0); + $this->RegisterPropertyString("DeviceID", ""); + // 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); + IPS_SetScriptContent($scriptID, $this->GenerateReceiveScript()); + } } public function ApplyChanges() { parent::ApplyChanges(); - $batterieManagement = $this->ReadPropertyInteger("Batteriemanagement"); - $this->SetValue("Batteriemanagement_Variabel", $batterieManagement); - $this->SetTimerInterval("Timer_Do_UserCalc_Battery",$this->ReadPropertyInteger("Interval")*1000); - } + $mqttServer = $this->ReadPropertyInteger("MQTTServer"); + $deviceId = $this->ReadPropertyString("DeviceID"); - - 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; + if ($mqttServer == 0 || $deviceId == "") { + $this->SetStatus(104); // missing config + return; } - - // 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; + + // Create MQTT Server Devices + $this->RegisterMQTTDevice("FeedbackRequest", "feedback-request/" . $deviceId); + $this->RegisterMQTTDevice("RemoteControlResponse", "remote-control-response/" . $deviceId); + + $this->SetStatus(102); } - + private function RegisterMQTTDevice(string $ident, string $topic) + { + $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); + } -public function RequestAction($Ident, $Value) -{ - switch ($Ident) { - - case "SetAktuelle_Leistung": - $this->SetValue("Power", (int)$Value); - break; + IPS_SetProperty($instanceID, "Topic", $topic); + IPS_SetProperty($instanceID, "Server", $this->ReadPropertyInteger("MQTTServer")); + IPS_SetProperty($instanceID, "Script", $this->GetIDForIdent("ReceiveScript")); + IPS_ApplyChanges($instanceID); - case "GetCurrentData": - $this->SetValue("Is_Peak_Shaving", (bool)$Value); - break; + return $instanceID; + } - - case "Do_UserCalc": + /** Script to be executed when MQTT message is received */ + private function GenerateReceiveScript(): string + { + return <<SetAktuelle_Leistung($this->GetValue("Power")); - $this->GetCurrentData($this->GetValue("Is_Peak_Shaving")); - break; +\$parent = IPS_GetParent(\$_IPS['SELF']); +IPS_RequestAction(\$parent, "OnReceive", json_encode([ + "Topic" => \$_IPS['Topic'], + "Value" => \$_IPS['VALUE'] +])); - default: - throw new Exception("Invalid Ident"); +SCR; + } + + /** Called by ReceiveScript */ + public function RequestAction($ident, $value) + { + if ($ident == "OnReceive") { + $data = json_decode($value, true); + $this->OnReceiveMQTT($data["Topic"], $data["Value"]); + } + } + + /** THIS IS YOUR CALLBACK FOR INCOMING MQTT MESSAGES */ + private function OnReceiveMQTT(string $topic, string $value) + { + IPS_LogMessage("Int_VGT", "Received on $topic: $value"); + + // Here you implement later your handling logic + // Example: respond to feedback-request + $mqttServer = $this->ReadPropertyInteger("MQTTServer"); + + if (str_contains($topic, "feedback-request")) { + $response = json_encode([ + "status" => "ok", + "timestamp" => time() + ]); + MQTT_Publish($mqttServer, str_replace("request", "response", $topic), $response, 0, false); + } + + if (str_contains($topic, "remote-control-response")) { + // Echo back the same payload + MQTT_Publish($mqttServer, str_replace("response", "feedback", $topic), $value, 0, false); + } } } - 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); - } - } - -} ?>