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
+
| Zähler |
Typ |
Startzeit |
Endzeit |
- Zählerstart |
- Zählerende |
+ Start |
+ Ende |
Verbrauch |
Tarif (Rp) |
Kosten (CHF) |
-
{$stromRows}
+
+ {$stromRows}
| 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)
+
| Zähler |
Typ |
Startzeit |
Endzeit |
- Zählerstart |
- Zählerende |
+ Start |
+ Ende |
Verbrauch |
Tarif (Rp) |
Kosten (CHF) |
-
{$nebenRows}
+
+ {$nebenRows}
| 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 = '';