<?php
declare(strict_types=1);

class Abrechnung extends IPSModule
{
public function Create()
{
    parent::Create();

    $this->RegisterPropertyString('Users', '[]');
    $this->RegisterPropertyString('PowerMeters', '[]');
    $this->RegisterPropertyString('WaterMeters', '[]');
    $this->RegisterPropertyString('Tariffs', '[]');

    $this->RegisterVariableInteger('FromDate', 'Startdatum', '~UnixTimestamp', 1);
    $this->RegisterVariableInteger('ToDate', 'Enddatum', '~UnixTimestamp', 2);
    $this->RegisterVariableString('LastResult', 'Letzte Abrechnung', '', 3);
    $this->EnableAction('FromDate');
    $this->EnableAction('ToDate');

    $this->RegisterScript('StartBilling', 'Abrechnung starten', "<?php IPS_RequestAction(" . $this->InstanceID . ", 'StartBilling', ''); ?>");

    // 🧾 Media-Objekt für PDF-Ergebnis anlegen (falls nicht vorhanden)
    $mediaID = @IPS_GetObjectIDByIdent('InvoicePDF', $this->InstanceID);
    if ($mediaID === false) {
        $mediaID = IPS_CreateMedia(3); // 3 = PDF
        IPS_SetParent($mediaID, $this->InstanceID);
        IPS_SetIdent($mediaID, 'InvoicePDF');
        IPS_SetName($mediaID, 'Letzte Rechnung');
        IPS_SetMediaCached($mediaID, false);
        $path = IPS_GetKernelDir() . 'media/Abrechnung_Letzte.pdf';
        IPS_SetMediaFile($mediaID, $path, false);
        IPS_LogMessage('Abrechnung', "Media-Datei erstellt: $path");
    }
}

    public function ApplyChanges()
    {
        parent::ApplyChanges();
        IPS_LogMessage('Abrechnung', 'ApplyChanges() ausgeführt');
    }

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...');
            $pdfPath = $this->GenerateInvoices();

            if ($pdfPath && file_exists($pdfPath)) {
                // 🔗 PDF in Media-Objekt speichern
                $mediaID = @IPS_GetObjectIDByIdent('InvoicePDF', $this->InstanceID);
                if ($mediaID) {
                    IPS_SetMediaFile($mediaID, $pdfPath, false);
                    IPS_LogMessage('Abrechnung', "✅ PDF in Media-Variable aktualisiert: $pdfPath");
                } else {
                    IPS_LogMessage('Abrechnung', "⚠️ Keine Media-Variable gefunden, PDF bleibt im Dateisystem");
                }

                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;
    }
}

    public function GenerateInvoices()
    {
        IPS_LogMessage('Abrechnung', 'GenerateInvoices() gestartet');

        $from = GetValue($this->GetIDForIdent('FromDate'));
        $to = GetValue($this->GetIDForIdent('ToDate'));
        IPS_LogMessage('Abrechnung', "Zeitraum: " . date('Y-m-d H:i', $from) . " bis " . date('Y-m-d H:i', $to));

        if ($from >= $to) {
            IPS_LogMessage('Abrechnung', '❌ Ungültiger Zeitraum');
            return false;
        }

        $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);
        IPS_LogMessage('Abrechnung', 'Daten geladen: Benutzer=' . count($users) . ', Power=' . count($power) . ', Water=' . count($water) . ', Tarife=' . count($tariffs));

        // TCPDF laden
        $lib = __DIR__ . '/libs/tcpdf/tcpdf.php';
        IPS_LogMessage('Abrechnung', "Suche TCPDF unter: $lib");
        if (!file_exists($lib)) {
            IPS_LogMessage('Abrechnung', '❌ TCPDF nicht gefunden!');
            return false;
        }

        try {
            require_once $lib;
            IPS_LogMessage('Abrechnung', '✅ TCPDF erfolgreich eingebunden');
        } catch (Throwable $e) {
            IPS_LogMessage('Abrechnung', '❌ Fehler beim Laden von TCPDF: ' . $e->getMessage());
            return false;
        }

        try {
            $pdf = new TCPDF();
            $pdf->SetCreator('IPSymcon Abrechnung');
            $pdf->SetAuthor('Abrechnung Modul');
            $pdf->SetTitle('Zählerabrechnung');
            $pdf->SetMargins(15, 15, 15);
            $pdf->SetAutoPageBreak(true, 20);

            foreach ($users as $user) {
                IPS_LogMessage('Abrechnung', 'Erstelle Seite für Benutzer: ' . $user['name']);

                $pdf->AddPage();
                $pdf->SetFont('helvetica', 'B', 14);
                $pdf->Cell(0, 10, 'Rechnung für ' . $user['name'], 0, 1);
                $pdf->SetFont('helvetica', '', 10);
                $pdf->Cell(0, 6, $user['address'] . ' - ' . $user['city'], 0, 1);
                $pdf->Ln(5);

                $userMeters = array_merge(
                    array_filter($power, fn($m) => $m['user_id'] == $user['id']),
                    array_filter($water, fn($m) => $m['user_id'] == $user['id'])
                );
                IPS_LogMessage('Abrechnung', 'Zähler gefunden: ' . count($userMeters));

                $total = 0.0;
                $pdf->SetFont('helvetica', 'B', 11);
                $pdf->Cell(60, 8, 'Zähler', 1);
                $pdf->Cell(35, 8, 'Start', 1);
                $pdf->Cell(35, 8, 'Ende', 1);
                $pdf->Cell(25, 8, 'Verbrauch', 1);
                $pdf->Cell(25, 8, 'Kosten', 1);
                $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';
            if (!is_dir($dir)) {
                mkdir($dir, 0777, true);
                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;
        }
    }

    private function GetValueAt(int $varId, int $timestamp)
    {
        IPS_LogMessage('Abrechnung', "GetValueAt() für VarID=$varId, Timestamp=$timestamp");
        try {
            $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);
            if (count($values) > 0) {
                IPS_LogMessage('Abrechnung', 'Archivwert gefunden: ' . $values[0]['Value']);
                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
    {
        $type = $meter['meter_type'] ?? 'Wärme';
        IPS_LogMessage('Abrechnung', "GetTariffForMeter() für Typ=$type");
        $tariff = 0.0;

        foreach ($tariffs as $t) {
            $start = strtotime($t['start']);
            $end = strtotime($t['end']);
            if ($from >= $start && $to <= $end && $t['unit_type'] == $type) {
                $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;
    }
}