From 263ea1d50eb2b11df37fbc10ef235fbdda6857ef Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Daniel=20H=C3=A4fliger?= Date: Wed, 5 Nov 2025 13:48:05 +0100 Subject: [PATCH] no message --- Abrechnung/module.php | 390 +++++++++++++++++------------------------- 1 file changed, 153 insertions(+), 237 deletions(-) diff --git a/Abrechnung/module.php b/Abrechnung/module.php index c8a8dd2..226fd49 100644 --- a/Abrechnung/module.php +++ b/Abrechnung/module.php @@ -45,319 +45,235 @@ class Abrechnung extends IPSModule IPS_SetName($mid, $Name); IPS_SetPosition($mid, $Position); IPS_SetMediaFile($mid, 'media/' . $mid . '.' . $Extension, false); - IPS_LogMessage('Abrechnung', 'Media-Datei erstellt: media/' . $mid . '.' . $Extension); } } -public function RequestAction($Ident, $Value) -{ - IPS_LogMessage('Abrechnung', "RequestAction: $Ident"); + public function RequestAction($Ident, $Value) + { + switch ($Ident) { + case 'FromDate': + case 'ToDate': + SetValue($this->GetIDForIdent($Ident), $Value); + break; - switch ($Ident) { - case 'FromDate': - case 'ToDate': - SetValue($this->GetIDForIdent($Ident), $Value); - break; - - case 'StartBilling': - IPS_LogMessage('Abrechnung', 'Starte Abrechnung...'); - try { - $pdfContent = $this->GenerateInvoices(); - if ($pdfContent === false) { - IPS_LogMessage('Abrechnung', '❌ GenerateInvoices() lieferte false zurück'); - echo "❌ Fehler bei der PDF-Erstellung (GenerateInvoices)"; - return; + case 'StartBilling': + try { + $pdfContent = $this->GenerateInvoices(); + if ($pdfContent && strlen($pdfContent) > 100) { + $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."; + } else { + echo "❌ Fehler bei der PDF-Erstellung."; + } + } catch (Throwable $e) { + echo "❌ Ausnahmefehler: " . $e->getMessage(); } - if ($pdfContent === null) { - IPS_LogMessage('Abrechnung', '❌ GenerateInvoices() gab null zurück'); - echo "❌ Fehler bei der PDF-Erstellung (leer)"; - return; - } - if (strlen($pdfContent) < 100) { - IPS_LogMessage('Abrechnung', '❌ PDF-Inhalt zu kurz: ' . strlen($pdfContent)); - echo "❌ Fehler bei der PDF-Erstellung (leeres PDF)"; - return; - } - - $mediaID = $this->GetIDForIdent('InvoicePDF'); - if (!$mediaID) { - IPS_LogMessage('Abrechnung', '❌ Media-ID nicht gefunden'); - echo "❌ Kein Media-Objekt vorhanden"; - return; - } - - IPS_SetMediaContent($mediaID, base64_encode($pdfContent)); - SetValue($this->GetIDForIdent('LastResult'), 'Abrechnung vom ' . date('d.m.Y H:i')); - IPS_LogMessage('Abrechnung', '✅ Abrechnung erfolgreich gespeichert (' . strlen($pdfContent) . ' Bytes)'); - echo "✅ PDF erfolgreich erstellt."; - - } catch (Throwable $e) { - IPS_LogMessage('Abrechnung', '💥 Exception in StartBilling: ' . $e->getMessage()); - echo "❌ Ausnahmefehler: " . $e->getMessage(); - } - break; + break; + } } -} - // ====================== PDF-Logik ====================== -public function GenerateInvoices() -{ - $from = GetValue($this->GetIDForIdent('FromDate')); - $to = GetValue($this->GetIDForIdent('ToDate')); + public function GenerateInvoices() + { + $from = GetValue($this->GetIDForIdent('FromDate')); + $to = GetValue($this->GetIDForIdent('ToDate')); - IPS_LogMessage('Abrechnung', '🕒 Starte GenerateInvoices()'); - IPS_LogMessage('Abrechnung', 'Zeitraum von ' . date('d.m.Y H:i', $from) . ' bis ' . date('d.m.Y H:i', $to)); + $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); - $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; - if (!class_exists('TCPDF')) { - IPS_LogMessage('Abrechnung', '❌ TCPDF fehlt – prüfe libs/vendor/autoload.php'); - return false; - } - - try { $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', '', 10); + $pdf->SetFont('dejavusans', '', 9); foreach ($users as $user) { - IPS_LogMessage('Abrechnung', '→ Erstelle Seite für Benutzer: ' . $user['name']); $pdf->AddPage(); + $html = $this->BuildUserInvoice($user, $power, $water, $tariffs, $from, $to); + $pdf->writeHTML($html); + } - $html = " -

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

-

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

-

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

- "; + return $pdf->Output('Abrechnung.pdf', 'S'); + } - $stromRows = ''; - $stromTotal = 0.0; - $stromTariffsUsed = []; + // ====================================================== + // 🧱 Layout / PDF-Aufbau pro Benutzerseite + // ====================================================== + private function BuildUserInvoice($user, $power, $water, $tariffs, $from, $to) + { + $stromRows = ''; + $stromTotal = 0.0; + $stromTariffsUsed = []; - $nebenRows = ''; - $nebenTotal = 0.0; - $nebenTariffsUsed = []; + $nebenRows = ''; + $nebenTotal = 0.0; + $nebenTariffsUsed = []; - // --- Stromkosten --- - foreach ($power as $m) { - if ($m['user_id'] != $user['id']) continue; - $res = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, 'Strombezug'); - $stromRows .= $res['row']; - $stromTotal += $res['value']; + // ---------- Stromkosten ---------- + foreach ($power as $m) { + if ($m['user_id'] != $user['id']) continue; + $res = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, 'Strombezug'); + $stromRows .= $res['row']; + $stromTotal += $res['value']; - // relevante Tarife sammeln - foreach ($tariffs as $t) { - if (strtolower($t['unit_type']) == 'strombezug') { - $s = is_numeric($t['start']) ? date('d.m.Y', $t['start']) : date('d.m.Y', strtotime($t['start'])); - $e = is_numeric($t['end']) ? date('d.m.Y', $t['end']) : date('d.m.Y', strtotime($t['end'])); - $stromTariffsUsed[$s . ' - ' . $e] = number_format(floatval($t['price']), 2); - } + foreach ($tariffs as $t) { + if (strtolower($t['unit_type']) == 'strombezug') { + $s = is_numeric($t['start']) ? date('d.m.Y', $t['start']) : date('d.m.Y', strtotime($t['start'])); + $e = is_numeric($t['end']) ? date('d.m.Y', $t['end']) : date('d.m.Y', strtotime($t['end'])); + $stromTariffsUsed[$s . ' - ' . $e] = number_format(floatval($t['price']), 2); } } + } - // --- Nebenkosten (Wasser/Wärme) --- - foreach ($water as $m) { - if ($m['user_id'] != $user['id']) continue; - $type = $m['meter_type'] ?? 'Warmwasser'; - $res = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, $type); - $nebenRows .= $res['row']; - $nebenTotal += $res['value']; + // ---------- Nebenkosten ---------- + foreach ($water as $m) { + if ($m['user_id'] != $user['id']) continue; + $type = $m['meter_type'] ?? 'Warmwasser'; + $res = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, $type); + $nebenRows .= $res['row']; + $nebenTotal += $res['value']; - // relevante Tarife sammeln - foreach ($tariffs as $t) { - if (in_array(strtolower($t['unit_type']), ['warmwasser', 'kaltwasser', 'wärme'])) { - $s = is_numeric($t['start']) ? date('d.m.Y', $t['start']) : date('d.m.Y', strtotime($t['start'])); - $e = is_numeric($t['end']) ? date('d.m.Y', $t['end']) : date('d.m.Y', strtotime($t['end'])); - $nebenTariffsUsed[$s . ' - ' . $e] = number_format(floatval($t['price']), 2); - } + foreach ($tariffs as $t) { + if (in_array(strtolower($t['unit_type']), ['warmwasser', 'kaltwasser', 'wärme'])) { + $s = is_numeric($t['start']) ? date('d.m.Y', $t['start']) : date('d.m.Y', strtotime($t['start'])); + $e = is_numeric($t['end']) ? date('d.m.Y', $t['end']) : date('d.m.Y', strtotime($t['end'])); + $nebenTariffsUsed[$s . ' - ' . $e] = number_format(floatval($t['price']), 2); } } + } - // Tabellenstil mit Linien - $tableStyle = "border-collapse:collapse;width:100%;font-size:8px;"; - $cellStyle = "border:0.3px solid #999;padding:2px;"; + $gesamtTotal = $stromTotal + $nebenTotal; + $tableStyle = "border-collapse:collapse;width:100%;font-size:8px;"; + $cellStyle = "border:0.3px solid #999;padding:2px;"; - // ---------- Stromkosten ---------- - $html .= "

⚡ Stromkosten

"; - $html .= " + $html = " +

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

+

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

+

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

+ +

⚡ Stromkosten

+
- - + + - {$stromRows} + + {$stromRows} -
Zähler Typ Startzeit EndzeitZählerstartZählerendeStartEnde Verbrauch Tarif (Rp) Kosten (CHF)
Total Stromkosten: " . number_format($stromTotal, 2) . "
"; + + "; - if (!empty($stromTariffsUsed)) { - $html .= "

Angewendete Tarife:
"; - foreach ($stromTariffsUsed as $period => $price) { - $html .= "  {$period}: {$price} Rp/kWh
"; - } - $html .= "

"; + if (!empty($stromTariffsUsed)) { + $html .= "

Angewendete Tarife:
"; + foreach ($stromTariffsUsed as $period => $price) { + $html .= "  {$period}: {$price} Rp/kWh
"; } + $html .= "

"; + } - // ---------- Nebenkosten ---------- - $html .= "

💧 Nebenkosten (Wasser & Wärme)

"; - $html .= " + $html .= " +

💧 Nebenkosten (Wasser & Wärme)

+
- - + + - {$nebenRows} + + {$nebenRows} -
Zähler Typ Startzeit EndzeitZählerstartZählerendeStartEnde Verbrauch Tarif (Rp) Kosten (CHF)
Total Nebenkosten: " . number_format($nebenTotal, 2) . "
"; + + "; - if (!empty($nebenTariffsUsed)) { - $html .= "

Angewendete Tarife:
"; - foreach ($nebenTariffsUsed as $period => $price) { - $html .= "  {$period}: {$price} Rp/m³ oder kWh
"; - } - $html .= "

"; + if (!empty($nebenTariffsUsed)) { + $html .= "

Angewendete Tarife:
"; + foreach ($nebenTariffsUsed as $period => $price) { + $html .= "  {$period}: {$price} Rp/m³ oder kWh
"; } - - // ---------- Gesamttotal ---------- - $gesamtTotal = $stromTotal + $nebenTotal; - $html .= "

💰 Gesamttotal: " . number_format($gesamtTotal, 2) . " CHF

"; - - $pdf->writeHTML($html); + $html .= "

"; } + + $html .= "

💰 Gesamttotal: " . number_format($gesamtTotal, 2) . " CHF

"; + + return $html; } - - - IPS_LogMessage('Abrechnung', '✅ PDF-Daten fertiggestellt'); - return $pdf->Output('Abrechnung.pdf', 'S'); - - } catch (Throwable $e) { - IPS_LogMessage('Abrechnung', '💥 Exception in TCPDF: ' . $e->getMessage()); - return false; - } -} - - - private function AddMeterToPDF($pdf, $meter, $tariffs, $from, $to, $type) + // ====================================================== + // Archivwert-Funktion + Tarif-Logik (aus deinem funktionierenden Code) + // ====================================================== + private function GetValueAt(int $varId, int $timestamp, bool $nearestAfter = true) { - $start = $this->GetValueAt($meter['var_consumption'], $from); - $end = $this->GetValueAt($meter['var_consumption'], $to); - if ($start === null || $end === null) return 0; - - $diff = max(0, $end - $start); - $tariffRp = $this->GetTariff($tariffs, $type, $from, $to); - $cost = ($tariffRp / 100) * $diff; - - $pdf->writeHTML(" - - {$meter['name']} - $type - $start - $end - $diff - $tariffRp - " . number_format($cost, 2) . " - ", false, false, false, false, ''); - - return $cost; - } - - private function GetTariff(array $tariffs, string $type, int $from, int $to): float - { - foreach ($tariffs as $t) { - $start = strtotime($t['start']); - $end = strtotime($t['end']); - if ($from >= $start && $to <= $end && strtolower($t['unit_type']) == strtolower($type)) { - return floatval($t['price']); - } + $archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0]; + if (!$archiveID || !IPS_VariableExists($varId)) { + return null; } - // Kein passender Tarif gefunden - return 0.0; - } -private function GetValueAt(int $varId, int $timestamp, bool $nearestAfter = true) -{ - $archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0]; - if (!$archiveID || !IPS_VariableExists($varId)) { - IPS_LogMessage('Abrechnung', "❌ Variable $varId oder Archiv $archiveID nicht gefunden"); - return null; - } + $maxDays = 365; + $stepDays = 30; + $valueFound = null; - $maxDays = 365; // maximal 1 Jahr suchen - $stepDays = 30; // in 30-Tage-Blöcken durchsuchen - $valueFound = null; - - if ($nearestAfter) { - // 🔹 Suche den ersten Wert NACH dem gewünschten Zeitpunkt - for ($offset = 0; $offset < $maxDays; $offset += $stepDays) { - $from = $timestamp + $offset * 86400; - $to = $from + $stepDays * 86400; - $values = @AC_GetLoggedValues($archiveID, $varId, $from, $to, 0); - if (!empty($values)) { - // ersten Wert nach Timestamp nehmen - foreach ($values as $v) { - if ($v['TimeStamp'] >= $timestamp) { - $valueFound = floatval($v['Value']); - break 2; + if ($nearestAfter) { + for ($offset = 0; $offset < $maxDays; $offset += $stepDays) { + $from = $timestamp + $offset * 86400; + $to = $from + $stepDays * 86400; + $values = @AC_GetLoggedValues($archiveID, $varId, $from, $to, 0); + if (!empty($values)) { + foreach ($values as $v) { + if ($v['TimeStamp'] >= $timestamp) { + $valueFound = floatval($v['Value']); + break 2; + } } } } - } - } else { - // 🔹 Suche den letzten Wert VOR dem gewünschten Zeitpunkt - for ($offset = 0; $offset < $maxDays; $offset += $stepDays) { - $from = $timestamp - ($offset + $stepDays) * 86400; - $to = $timestamp - $offset * 86400; - $values = @AC_GetLoggedValues($archiveID, $varId, $from, $to, 0); - if (!empty($values)) { - // letzten Wert vor Timestamp nehmen - $last = null; - foreach ($values as $v) { - if ($v['TimeStamp'] <= $timestamp) { - $last = $v; - } else { + } else { + for ($offset = 0; $offset < $maxDays; $offset += $stepDays) { + $from = $timestamp - ($offset + $stepDays) * 86400; + $to = $timestamp - $offset * 86400; + $values = @AC_GetLoggedValues($archiveID, $varId, $from, $to, 0); + if (!empty($values)) { + $last = null; + foreach ($values as $v) { + if ($v['TimeStamp'] <= $timestamp) { + $last = $v; + } else break; + } + if ($last !== null) { + $valueFound = floatval($last['Value']); break; } } - if ($last !== null) { - $valueFound = floatval($last['Value']); - break; - } } } + + if ($valueFound === null) { + return floatval(GetValue($varId)); + } + return $valueFound; } - // 🔹 Falls nichts im Archiv: aktuellen Variablenwert nehmen - if ($valueFound === null) { - $fallback = floatval(GetValue($varId)); - IPS_LogMessage('Abrechnung', "⚠ Kein Archivwert für $varId gefunden – nutze aktuellen Wert ($fallback)"); - return $fallback; - } - - return $valueFound; -} - - private function AddMeterToPDFRow($meter, $tariffs, $from, $to, $type) { $rows = '';