diff --git a/Abrechnung/module.php b/Abrechnung/module.php index 2112401..ec5a8fd 100644 --- a/Abrechnung/module.php +++ b/Abrechnung/module.php @@ -25,14 +25,14 @@ class Abrechnung extends IPSModule // Abrechnungs-Button $this->RegisterScript('StartBilling', 'Abrechnung starten', "InstanceID . ", 'StartBilling', ''); ?>"); - // 🧾 Media-Objekt für PDF-Ergebnis + // PDF-Media-Objekt $this->RegisterMediaDocument('InvoicePDF', 'Letzte Rechnung', 'pdf'); } public function ApplyChanges() { parent::ApplyChanges(); - IPS_LogMessage('Abrechnung', 'Modul geladen'); + IPS_LogMessage('Abrechnung', '✅ Modul geladen'); } private function RegisterMediaDocument($Ident, $Name, $Extension, $Position = 0) @@ -45,65 +45,40 @@ 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() -{ + // =========================================================== + // 🧾 Hauptlogik: Rechnungserstellung für alle Benutzer + // =========================================================== + public function GenerateInvoices() + { $from = GetValue($this->GetIDForIdent('FromDate')); $to = GetValue($this->GetIDForIdent('ToDate')); @@ -127,10 +102,12 @@ public function GenerateInvoices() } return $pdf->Output('Abrechnung.pdf', 'S'); - -} + } - private function BuildUserInvoice($user, $power, $water, $tariffs, $from, $to) + // =========================================================== + // 🧱 Layout / PDF-Aufbau pro Benutzerseite + // =========================================================== + private function BuildUserInvoice($user, $power, $water, $tariffs, $from, $to) { $stromRows = ''; $stromTotal = 0.0; @@ -149,9 +126,12 @@ public function GenerateInvoices() 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); + $sTs = $this->toUnixTs($t['start'], false); + $eTs = $this->toUnixTs($t['end'], true); + if ($sTs && $eTs) { + $period = date('d.m.Y', $sTs) . ' - ' . date('d.m.Y', $eTs); + $stromTariffsUsed[$period] = number_format(floatval($t['price']), 2); + } } } } @@ -165,10 +145,14 @@ public function GenerateInvoices() $nebenTotal += $res['value']; 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); + $u = strtolower($t['unit_type'] ?? ''); + if (in_array($u, ['warmwasser', 'kaltwasser', 'wärme'])) { + $sTs = $this->toUnixTs($t['start'], false); + $eTs = $this->toUnixTs($t['end'], true); + if ($sTs && $eTs) { + $period = date('d.m.Y', $sTs) . ' - ' . date('d.m.Y', $eTs); + $nebenTariffsUsed[$period] = number_format(floatval($t['price']), 2); + } } } } @@ -244,106 +228,68 @@ public function GenerateInvoices() return $html; } - private function AddMeterToPDF($pdf, $meter, $tariffs, $from, $to, $type) + // =========================================================== + // 🧮 Datumskonvertierung – robust für JSON, String, Timestamp + // =========================================================== + private function toUnixTs($val, bool $endOfDay = false): ?int { - $start = $this->GetValueAt($meter['var_consumption'], $from); - $end = $this->GetValueAt($meter['var_consumption'], $to); - if ($start === null || $end === null) return 0; + if (is_int($val)) return $val; + if (is_numeric($val)) return intval($val); - $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']); + if (is_string($val)) { + $s = trim($val); + if ($s !== '' && $s[0] === '{') { + $obj = json_decode($s, true); + if (is_array($obj) && 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; } - // 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; // maximal 1 Jahr suchen - $stepDays = 30; // in 30-Tage-Blöcken durchsuchen - $valueFound = null; + // =========================================================== + // 🔍 Archivwertsuche (deine getestete Version) + // =========================================================== + private function GetValueAt(int $varId, int $timestamp, bool $nearestAfter = true) + { + $archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0]; + if (!$archiveID || !IPS_VariableExists($varId)) return 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; + $maxDays = 365; + $stepDays = 30; + $valueFound = null; + + 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) { + return floatval($v['Value']); + } } } } - } - } 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 { - break; - } - } - if ($last !== null) { - $valueFound = floatval($last['Value']); - break; + } 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 = end($values); + return floatval($last['Value']); } } } + + return floatval(GetValue($varId)); } - - // 🔹 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 = ''; diff --git a/temp_head.txt b/temp_head.txt new file mode 100644 index 0000000..49e5f1f --- /dev/null +++ b/temp_head.txt @@ -0,0 +1,160 @@ +RegisterPropertyString('Users', '[]'); + $this->RegisterPropertyString('PowerMeters', '[]'); + $this->RegisterPropertyString('WaterMeters', '[]'); + $this->RegisterPropertyString('Tariffs', '[]'); + + // Variablen + $this->RegisterVariableInteger('FromDate', 'Startdatum', '~UnixTimestamp', 1); + $this->RegisterVariableInteger('ToDate', 'Enddatum', '~UnixTimestamp', 2); + $this->RegisterVariableString('LastResult', 'Letzte Abrechnung', '', 3); + $this->EnableAction('FromDate'); + $this->EnableAction('ToDate'); + + // Abrechnungs-Button + $this->RegisterScript('StartBilling', 'Abrechnung starten', "InstanceID . ", 'StartBilling', ''); ?>"); + + // 🧾 Media-Objekt für PDF-Ergebnis + $this->RegisterMediaDocument('InvoicePDF', 'Letzte Rechnung', 'pdf'); + } + + public function ApplyChanges() + { + parent::ApplyChanges(); + IPS_LogMessage('Abrechnung', 'Modul geladen'); + } + + private function RegisterMediaDocument($Ident, $Name, $Extension, $Position = 0) + { + $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_LogMessage('Abrechnung', 'Media-Datei erstellt: media/' . $mid . '.' . $Extension); + } + } + +public function RequestAction($Ident, $Value) +{ + IPS_LogMessage('Abrechnung', "RequestAction: $Ident"); + + 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; + } + 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; + } +} + + + // ====================== PDF-Logik ====================== + +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); + + 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); + + foreach ($users as $user) { + IPS_LogMessage('Abrechnung', '→ Erstelle Seite für Benutzer: ' . $user['name']); + $pdf->AddPage(); + + // 🔽 Hier fügst du den neuen HTML-Block ein: + $html = " +

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

+

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

+ + + + + + + + + + + + + "; + + $total = 0.0; + foreach ($power as $m) { + if ($m['user_id'] != $user['id']) continue; + $cost = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, 'Strombezug'); + $html .= $cost['row']; + $total += $cost['value']; + } + foreach ($water as $m) { + if ($m['user_id'] != $user['id']) continue; diff --git a/temp_mid.txt b/temp_mid.txt new file mode 100644 index 0000000..7e5c558 --- /dev/null +++ b/temp_mid.txt @@ -0,0 +1,190 @@ + $type = $m['meter_type'] ?? 'Warmwasser'; + $cost = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, $type); + $html .= $cost['row']; + $total += $cost['value']; + } + + $html .= "
ZählerTypStartzeitEndzeitZählerstand StartZählerstand EndeVerbrauchTarif (Rp)Kosten (CHF)

Gesamtsumme: " . number_format($total, 2) . " CHF

"; + $pdf->writeHTML($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) + { + $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']); + } + } + // 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; // 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; + } + } + } + } + } 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 { + break; + } + } + if ($last !== null) { + $valueFound = floatval($last['Value']); + break; + } + } + } + } + + // 🔹 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 = ''; + $totalCost = 0.0; + $varId = $meter['var_consumption']; + + IPS_LogMessage('Abrechnung', "🔧 [AddMeterToPDFRow] Starte für '{$meter['name']}' (Typ: {$type}) von " . date('d.m.Y H:i', $from) . " bis " . date('d.m.Y H:i', $to)); + + if (!IPS_VariableExists($varId)) { + IPS_LogMessage('Abrechnung', "❌ Variable {$varId} für {$meter['name']} nicht gefunden"); + return ['row' => '', 'value' => 0]; + } + + // Zeitzone setzen, um strtotime()-Abweichungen zu vermeiden + date_default_timezone_set('Europe/Zurich'); + + // 1️⃣ Relevante Tarife nach Typ filtern + $filteredTariffs = array_filter($tariffs, function ($t) use ($type) { + return strtolower(trim($t['unit_type'] ?? '')) === strtolower(trim($type)); + }); + + if (empty($filteredTariffs)) { + IPS_LogMessage('Abrechnung', "⚠ Keine passenden Tarife für {$type} gefunden"); + return ['row' => '', 'value' => 0]; + } + + // 2️⃣ Zeitstempel konvertieren, JSON-Objekte erkennen & sortieren + foreach ($filteredTariffs as &$t) { + // JSON-Fix: Start/Ende evtl. verschachtelt + if (is_string($t['start']) && str_starts_with(trim($t['start']), '{')) { + $s = json_decode($t['start'], true); + if (is_array($s)) { + $t['start'] = sprintf('%04d-%02d-%02d 00:00:00', $s['year'], $s['month'], $s['day']); + } + } + if (is_string($t['end']) && str_starts_with(trim($t['end']), '{')) { + $e = json_decode($t['end'], true); + if (is_array($e)) { + $t['end'] = sprintf('%04d-%02d-%02d 23:59:59', $e['year'], $e['month'], $e['day']); + } + } + + $t['start_ts'] = is_numeric($t['start']) ? intval($t['start']) : strtotime($t['start']); + $t['end_ts'] = is_numeric($t['end']) ? intval($t['end']) : strtotime($t['end']); + + if (!$t['start_ts'] || !$t['end_ts']) { + IPS_LogMessage('Abrechnung', "⚠ Ungültiger Tarifzeitraum: " . json_encode($t)); + } else { + IPS_LogMessage('Abrechnung', sprintf( + " 🕓 Tarif gültig von %s bis %s @ %.3f Rp", + date('d.m.Y H:i', $t['start_ts']), + date('d.m.Y H:i', $t['end_ts']), + floatval($t['price']) + )); + } + } + unset($t); + usort($filteredTariffs, fn($a, $b) => $a['start_ts'] <=> $b['start_ts']); + + // 3️⃣ Abrechnungslogik + $currentStart = $from; + $segmentIndex = 1; + + while ($currentStart < $to) { + IPS_LogMessage('Abrechnung', "➡️ Segment {$segmentIndex} Startzeit: " . date('d.m.Y H:i', $currentStart)); + + // 🔹 Aktiven Tarif bestimmen (FIX: <= auch am Ende erlaubt) + $activeTariff = null; diff --git a/temp_mid2.txt b/temp_mid2.txt new file mode 100644 index 0000000..3b3f2f4 --- /dev/null +++ b/temp_mid2.txt @@ -0,0 +1,106 @@ + foreach ($filteredTariffs as $t) { + $startTs = intval($t['start_ts']); + $endTs = intval($t['end_ts']); + if ($startTs === 0 || $endTs === 0) continue; + + if ($startTs <= $currentStart && $currentStart <= $endTs) { + $activeTariff = $t; + IPS_LogMessage('Abrechnung', sprintf( + " ✅ Tarif erkannt: %.2f Rp gültig %s → %s", + floatval($t['price']), + date('d.m.Y H:i', $startTs), + date('d.m.Y H:i', $endTs) + )); + break; + } + } + + // 🔹 Falls kein aktiver Tarif → 0 Rp + if (!$activeTariff) { + IPS_LogMessage('Abrechnung', "⚠ Kein Tarif aktiv bei " . date('d.m.Y H:i', $currentStart) . " → 0 Rp"); + $activeTariff = [ + 'start_ts' => $currentStart, + 'end_ts' => $to, + 'price' => 0.0, + 'unit_type'=> $type + ]; + } + + $tariffEnd = intval($activeTariff['end_ts']); + $tariffPrice = floatval($activeTariff['price']); + $tariffLabel = number_format($tariffPrice, 2, ',', ''); + + // 🔹 Start- & Endwerte aus Archiv + $startValue = $this->GetValueAt($varId, $currentStart, true); + if ($startValue === null) { + IPS_LogMessage('Abrechnung', "⚠ Kein Startwert für " . date('d.m.Y H:i', $currentStart)); + break; + } + + $segmentEnd = ($tariffEnd < $to) ? $tariffEnd : $to; + $endValue = $this->GetValueAt($varId, $segmentEnd, true); + if ($endValue === null) { + IPS_LogMessage('Abrechnung', "⚠ Kein Endwert für " . date('d.m.Y H:i', $segmentEnd)); + break; + } + + // 🔹 Verbrauch & Kosten + $verbrauch = max(0, $endValue - $startValue); + $kosten = round(($tariffPrice / 100) * $verbrauch, 2); + $totalCost += $kosten; + + IPS_LogMessage('Abrechnung', sprintf( + " 📊 Segment %d: %.3f → %.3f (Δ=%.3f) | Tarif=%.3f Rp | Kosten=%.2f CHF", + $segmentIndex, $startValue, $endValue, $verbrauch, $tariffPrice, $kosten + )); + + // 🔹 Tabellenzeile + $rows .= " + + {$meter['name']} + {$type} + " . date('d.m.Y H:i', $currentStart) . " + " . date('d.m.Y H:i', $segmentEnd) . " + " . number_format($startValue, 2) . " + " . number_format($endValue, 2) . " + " . number_format($verbrauch, 2) . " + {$tariffLabel} + " . number_format($kosten, 2) . " + "; + + // 🔹 Neuen Startpunkt setzen (FIX: +1 Sekunde nach Tarifende) + if ($tariffEnd < $to) { + $currentStart = $tariffEnd + 1; + } else { + break; + } + + $segmentIndex++; + } + + // Fallback, falls keine Segmente erzeugt wurden + if ($rows === '') { + IPS_LogMessage('Abrechnung', "⚠ Keine Segmente erzeugt, Fallback auf Gesamtzeitraum"); + $startValue = $this->GetValueAt($varId, $from, false); + $endValue = $this->GetValueAt($varId, $to, true); + $verbrauch = max(0, $endValue - $startValue); + $rows = " + + {$meter['name']} + {$type} + " . date('d.m.Y H:i', $from) . " + " . date('d.m.Y H:i', $to) . " + " . number_format($startValue, 2) . " + " . number_format($endValue, 2) . " + " . number_format($verbrauch, 2) . " + 0 + 0.00 + "; + } + + IPS_LogMessage('Abrechnung', sprintf("✅ [AddMeterToPDFRow] Fertig: %.2f CHF total, %d Segmente", $totalCost, $segmentIndex - 1)); + + return ['row' => $rows, 'value' => $totalCost]; +} + +}