dh/Symcon_Belevo_Energiemanagement_testing
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
dh
2025-11-04 07:26:07 +01:00
parent 1c67b9f50b
commit 78dd81f961
1 changed files with 120 additions and 159 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Abrechnung/module.php
+120 -159
View File
@@ -3,76 +3,81 @@ declare(strict_types=1);
class Abrechnung extends IPSModule class Abrechnung extends IPSModule
{ {
public function Create() public function Create()
{ {
parent::Create(); parent::Create();
$this->RegisterPropertyString('Users', '[]'); // Eigenschaften
$this->RegisterPropertyString('PowerMeters', '[]'); $this->RegisterPropertyString('Users', '[]');
$this->RegisterPropertyString('WaterMeters', '[]'); $this->RegisterPropertyString('PowerMeters', '[]');
$this->RegisterPropertyString('Tariffs', '[]'); $this->RegisterPropertyString('WaterMeters', '[]');
$this->RegisterPropertyString('Tariffs', '[]');
$this->RegisterVariableInteger('FromDate', 'Startdatum', '~UnixTimestamp', 1); // Variablen für Zeitraum + Status
$this->RegisterVariableInteger('ToDate', 'Enddatum', '~UnixTimestamp', 2); $this->RegisterVariableInteger('FromDate', 'Startdatum', '~UnixTimestamp', 1);
$this->RegisterVariableString('LastResult', 'Letzte Abrechnung', '', 3); $this->RegisterVariableInteger('ToDate', 'Enddatum', '~UnixTimestamp', 2);
$this->EnableAction('FromDate'); $this->RegisterVariableString('LastResult', 'Letzte Abrechnung', '', 3);
$this->EnableAction('ToDate'); $this->EnableAction('FromDate');
$this->EnableAction('ToDate');
$this->RegisterScript('StartBilling', 'Abrechnung starten', "<?php IPS_RequestAction(" . $this->InstanceID . ", 'StartBilling', ''); ?>"); // Abrechnungs-Button
$this->RegisterScript('StartBilling', 'Abrechnung starten', "<?php IPS_RequestAction(" . $this->InstanceID . ", 'StartBilling', ''); ?>");
// 🧾 Media-Objekt für PDF-Ergebnis anlegen (falls nicht vorhanden) // 📄 Media-Objekt für PDF anlegen (falls nicht vorhanden)
$mediaID = @IPS_GetObjectIDByIdent('InvoicePDF', $this->InstanceID); $mediaID = @IPS_GetObjectIDByIdent('InvoicePDF', $this->InstanceID);
if ($mediaID === false) { if ($mediaID === false) {
$mediaID = IPS_CreateMedia(3); // 3 = PDF $mediaID = IPS_CreateMedia(3); // 3 = Dokument (PDF)
IPS_SetParent($mediaID, $this->InstanceID); IPS_SetParent($mediaID, $this->InstanceID);
IPS_SetIdent($mediaID, 'InvoicePDF'); IPS_SetIdent($mediaID, 'InvoicePDF');
IPS_SetName($mediaID, 'Letzte Rechnung'); IPS_SetName($mediaID, 'Letzte Rechnung');
IPS_SetMediaCached($mediaID, false); IPS_SetMediaCached($mediaID, false);
$path = IPS_GetKernelDir() . 'media/Abrechnung_Letzte.pdf'; IPS_LogMessage('Abrechnung', 'Media-Objekt "Letzte Rechnung" angelegt');
IPS_SetMediaFile($mediaID, $path, false); }
IPS_LogMessage('Abrechnung', "Media-Datei erstellt: $path");
} }
}
public function ApplyChanges() public function ApplyChanges()
{ {
parent::ApplyChanges(); parent::ApplyChanges();
IPS_LogMessage('Abrechnung', 'ApplyChanges() ausgeführt');
} }
public function RequestAction($Ident, $Value) public function RequestAction($Ident, $Value)
{ {
IPS_LogMessage('Abrechnung', "RequestAction: $Ident"); IPS_LogMessage('Abrechnung', "RequestAction: $Ident");
switch ($Ident) {
case 'FromDate':
case 'ToDate':
SetValue($this->GetIDForIdent($Ident), $Value);
break;
case 'StartBilling': switch ($Ident) {
IPS_LogMessage('Abrechnung', 'Starte Abrechnung...'); case 'FromDate':
$pdfPath = $this->GenerateInvoices(); case 'ToDate':
SetValue($this->GetIDForIdent($Ident), $Value);
break;
if ($pdfPath && file_exists($pdfPath)) { case 'StartBilling':
// 🔗 PDF in Media-Objekt speichern IPS_LogMessage('Abrechnung', 'Starte Abrechnung...');
$mediaID = @IPS_GetObjectIDByIdent('InvoicePDF', $this->InstanceID); $pdfPath = $this->GenerateInvoices();
if ($mediaID) {
IPS_SetMediaFile($mediaID, $pdfPath, false); if ($pdfPath && file_exists($pdfPath)) {
IPS_LogMessage('Abrechnung', "✅ PDF in Media-Variable aktualisiert: $pdfPath"); $mediaID = @IPS_GetObjectIDByIdent('InvoicePDF', $this->InstanceID);
if ($mediaID) {
// 🧩 PDF-Inhalt direkt ins Media-Objekt laden
$content = file_get_contents($pdfPath);
if ($content !== false && strlen($content) > 100) {
IPS_SetMediaContent($mediaID, base64_encode($content));
IPS_LogMessage('Abrechnung', "✅ PDF erfolgreich in Media-Variable gespeichert ($pdfPath)");
} else {
IPS_LogMessage('Abrechnung', "⚠️ PDF-Datei leer oder fehlerhaft: $pdfPath");
}
}
SetValue($this->GetIDForIdent('LastResult'), basename($pdfPath));
echo "✅ Abrechnung erstellt: " . basename($pdfPath);
} else { } else {
IPS_LogMessage('Abrechnung', "⚠️ Keine Media-Variable gefunden, PDF bleibt im Dateisystem"); IPS_LogMessage('Abrechnung', '❌ Fehler bei der PDF-Erstellung');
echo "❌ Fehler bei der PDF-Erstellung";
} }
break;
SetValue($this->GetIDForIdent('LastResult'), basename($pdfPath)); }
echo "✅ Abrechnung erstellt: " . basename($pdfPath);
} else {
IPS_LogMessage('Abrechnung', '❌ Fehler bei der PDF-Erstellung');
echo "❌ Fehler bei der PDF-Erstellung";
}
break;
} }
}
// 🧾 Hauptfunktion: PDF generieren
public function GenerateInvoices() public function GenerateInvoices()
{ {
IPS_LogMessage('Abrechnung', 'GenerateInvoices() gestartet'); IPS_LogMessage('Abrechnung', 'GenerateInvoices() gestartet');
@@ -90,145 +95,101 @@ public function RequestAction($Ident, $Value)
$power = json_decode($this->ReadPropertyString('PowerMeters'), true); $power = json_decode($this->ReadPropertyString('PowerMeters'), true);
$water = json_decode($this->ReadPropertyString('WaterMeters'), true); $water = json_decode($this->ReadPropertyString('WaterMeters'), true);
$tariffs = json_decode($this->ReadPropertyString('Tariffs'), true); $tariffs = json_decode($this->ReadPropertyString('Tariffs'), true);
IPS_LogMessage('Abrechnung', 'Daten geladen: Benutzer=' . count($users) . ', Power=' . count($power) . ', Water=' . count($water) . ', Tarife=' . count($tariffs));
// TCPDF laden IPS_LogMessage('Abrechnung', "Benutzer=" . count($users) . ", Power=" . count($power) . ", Water=" . count($water) . ", Tarife=" . count($tariffs));
// 🔧 TCPDF einbinden
$lib = __DIR__ . '/libs/tcpdf/tcpdf.php'; $lib = __DIR__ . '/libs/tcpdf/tcpdf.php';
IPS_LogMessage('Abrechnung', "Suche TCPDF unter: $lib");
if (!file_exists($lib)) { if (!file_exists($lib)) {
IPS_LogMessage('Abrechnung', '❌ TCPDF nicht gefunden!'); IPS_LogMessage('Abrechnung', "❌ TCPDF nicht gefunden unter $lib");
return false; return false;
} }
require_once $lib;
try { $pdf = new TCPDF();
require_once $lib; $pdf->SetCreator('IPSymcon Abrechnung');
IPS_LogMessage('Abrechnung', '✅ TCPDF erfolgreich eingebunden'); $pdf->SetAuthor('Abrechnung Modul');
} catch (Throwable $e) { $pdf->SetTitle('Zählerabrechnung');
IPS_LogMessage('Abrechnung', '❌ Fehler beim Laden von TCPDF: ' . $e->getMessage()); $pdf->SetMargins(15, 15, 15);
return false; $pdf->SetAutoPageBreak(true, 20);
}
try { foreach ($users as $user) {
$pdf = new TCPDF(); $pdf->AddPage();
$pdf->SetCreator('IPSymcon Abrechnung'); $pdf->SetFont('helvetica', 'B', 14);
$pdf->SetAuthor('Abrechnung Modul'); $pdf->Cell(0, 10, 'Rechnung für ' . $user['name'], 0, 1);
$pdf->SetTitle('Zählerabrechnung'); $pdf->SetFont('helvetica', '', 10);
$pdf->SetMargins(15, 15, 15); $pdf->Cell(0, 6, $user['address'] . ' - ' . $user['city'], 0, 1);
$pdf->SetAutoPageBreak(true, 20); $pdf->Ln(5);
foreach ($users as $user) { $userMeters = array_merge(
IPS_LogMessage('Abrechnung', 'Erstelle Seite für Benutzer: ' . $user['name']); array_filter($power, fn($m) => $m['user_id'] == $user['id']),
array_filter($water, fn($m) => $m['user_id'] == $user['id'])
);
$total = 0.0;
$pdf->AddPage(); $pdf->SetFont('helvetica', 'B', 11);
$pdf->SetFont('helvetica', 'B', 14); $pdf->Cell(60, 8, 'Zähler', 1);
$pdf->Cell(0, 10, 'Rechnung für ' . $user['name'], 0, 1); $pdf->Cell(35, 8, 'Start', 1);
$pdf->SetFont('helvetica', '', 10); $pdf->Cell(35, 8, 'Ende', 1);
$pdf->Cell(0, 6, $user['address'] . ' - ' . $user['city'], 0, 1); $pdf->Cell(25, 8, 'Verbrauch', 1);
$pdf->Ln(5); $pdf->Cell(25, 8, 'Kosten', 1);
$pdf->Ln();
$userMeters = array_merge( $pdf->SetFont('helvetica', '', 9);
array_filter($power, fn($m) => $m['user_id'] == $user['id']), foreach ($userMeters as $m) {
array_filter($water, fn($m) => $m['user_id'] == $user['id']) $start = $this->GetValueAt($m['var_consumption'], $from);
); $end = $this->GetValueAt($m['var_consumption'], $to);
IPS_LogMessage('Abrechnung', 'Zähler gefunden: ' . count($userMeters)); if ($start === null || $end === null) continue;
$total = 0.0; $diff = max(0, $end - $start);
$pdf->SetFont('helvetica', 'B', 11); $price = $this->GetTariffForMeter($tariffs, $from, $to, $m);
$pdf->Cell(60, 8, 'Zähler', 1); $cost = $diff * $price;
$pdf->Cell(35, 8, 'Start', 1); $total += $cost;
$pdf->Cell(35, 8, 'Ende', 1);
$pdf->Cell(25, 8, 'Verbrauch', 1); $pdf->Cell(60, 7, $m['name'], 1);
$pdf->Cell(25, 8, 'Kosten', 1); $pdf->Cell(35, 7, number_format($start, 2), 1);
$pdf->Cell(35, 7, number_format($end, 2), 1);
$pdf->Cell(25, 7, number_format($diff, 2), 1);
$pdf->Cell(25, 7, number_format($cost, 2), 1);
$pdf->Ln(); $pdf->Ln();
$pdf->SetFont('helvetica', '', 9);
foreach ($userMeters as $m) {
$start = $this->GetValueAt($m['var_consumption'], $from);
$end = $this->GetValueAt($m['var_consumption'], $to);
IPS_LogMessage('Abrechnung', "Zähler {$m['name']} Start=$start Ende=$end");
if ($start === null || $end === null) {
IPS_LogMessage('Abrechnung', "⚠️ Keine Werte für {$m['name']}");
continue;
}
$diff = max(0, $end - $start);
$price = $this->GetTariffForMeter($tariffs, $from, $to, $m);
$cost = $diff * $price;
$total += $cost;
IPS_LogMessage('Abrechnung', "{$m['name']} Verbrauch=$diff, Preis=$price, Kosten=$cost");
$pdf->Cell(60, 7, $m['name'], 1);
$pdf->Cell(35, 7, number_format($start, 2), 1);
$pdf->Cell(35, 7, number_format($end, 2), 1);
$pdf->Cell(25, 7, number_format($diff, 2), 1);
$pdf->Cell(25, 7, number_format($cost, 2), 1);
$pdf->Ln();
}
$pdf->Ln(4);
$pdf->SetFont('helvetica', 'B', 11);
$pdf->Cell(0, 8, 'Gesamtbetrag: ' . number_format($total, 2) . ' CHF', 0, 1, 'R');
} }
$dir = IPS_GetKernelDir() . 'media/Abrechnung'; $pdf->Ln(4);
if (!is_dir($dir)) { $pdf->SetFont('helvetica', 'B', 11);
mkdir($dir, 0777, true); $pdf->Cell(0, 8, 'Gesamtbetrag: ' . number_format($total, 2) . ' CHF', 0, 1, 'R');
IPS_LogMessage('Abrechnung', "Verzeichnis erstellt: $dir");
}
$filename = 'Abrechnung_' . date('Ymd_His', $from) . '.pdf';
$path = $dir . '/' . $filename;
$pdf->Output($path, 'F');
IPS_LogMessage('Abrechnung', "✅ PDF erfolgreich gespeichert: $path");
return $path;
} catch (Throwable $e) {
IPS_LogMessage('Abrechnung', '❌ Fehler in GenerateInvoices(): ' . $e->getMessage());
return false;
} }
// 💾 PDF im temporären Ordner speichern
$dir = sys_get_temp_dir();
$filename = 'Abrechnung_' . date('Ymd_His') . '.pdf';
$path = $dir . '/' . $filename;
$pdf->Output($path, 'F');
IPS_LogMessage('Abrechnung', "PDF gespeichert unter: $path");
return $path;
} }
private function GetValueAt(int $varId, int $timestamp) private function GetValueAt(int $varId, int $timestamp)
{ {
IPS_LogMessage('Abrechnung', "GetValueAt() für VarID=$varId, Timestamp=$timestamp"); $archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0];
try { if (!$archiveID) return GetValue($varId);
$archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0];
if (!$archiveID) {
IPS_LogMessage('Abrechnung', '⚠️ Kein Archivmodul gefunden, nutze aktuellen Wert');
return GetValue($varId);
}
$values = AC_GetLoggedValues($archiveID, $varId, $timestamp - 3600, $timestamp + 3600, 1); $values = AC_GetLoggedValues($archiveID, $varId, $timestamp - 3600, $timestamp + 3600, 1);
if (count($values) > 0) { if (count($values) > 0) return floatval($values[0]['Value']);
IPS_LogMessage('Abrechnung', 'Archivwert gefunden: ' . $values[0]['Value']); return GetValue($varId);
return floatval($values[0]['Value']);
}
IPS_LogMessage('Abrechnung', '⚠️ Keine archivierten Werte, nehme aktuellen Wert');
return GetValue($varId);
} catch (Throwable $e) {
IPS_LogMessage('Abrechnung', '❌ Fehler in GetValueAt(): ' . $e->getMessage());
return null;
}
} }
private function GetTariffForMeter(array $tariffs, int $from, int $to, array $meter): float private function GetTariffForMeter(array $tariffs, int $from, int $to, array $meter): float
{ {
$type = $meter['meter_type'] ?? 'Wärme'; $type = $meter['meter_type'] ?? 'Wärme';
IPS_LogMessage('Abrechnung', "GetTariffForMeter() für Typ=$type");
$tariff = 0.0; $tariff = 0.0;
foreach ($tariffs as $t) { foreach ($tariffs as $t) {
$start = strtotime($t['start']); $start = strtotime($t['start']);
$end = strtotime($t['end']); $end = strtotime($t['end']);
if ($from >= $start && $to <= $end && $t['unit_type'] == $type) { if ($from >= $start && $to <= $end && $t['unit_type'] == $type) {
$tariff = floatval($t['price']) / 100.0; $tariff = floatval($t['price']) / 100.0;
IPS_LogMessage('Abrechnung', "Passender Tarif gefunden: {$tariff} CHF/$type");
} }
} }
if ($tariff == 0.0)
IPS_LogMessage('Abrechnung', "⚠️ Kein passender Tarif für $type gefunden");
return $tariff; return $tariff;
} }
} }