<?php

declare(strict_types=1);

class PV_Visu extends IPSModule
{
    public function Create()
    {
        parent::Create();
        // Vier Zähler-Variablen
        $this->RegisterPropertyInteger('VarProduction', 0);
        $this->RegisterPropertyInteger('VarConsumption', 0);
        $this->RegisterPropertyInteger('VarFeedIn', 0);
        $this->RegisterPropertyInteger('VarGrid', 0);
        // HTML-SDK Tile aktivieren
        $this->SetVisualizationType(3);
    }


        public function ApplyChanges(): void
    {
        parent::ApplyChanges();
        // Auf Änderungen der Zähler-Variablen reagieren
        foreach (['VarProduction', 'VarConsumption', 'VarFeedIn', 'VarGrid'] as $prop) {
            $vid = $this->ReadPropertyInteger($prop);
            if ($vid > 0) {
                // Register event for variable update
                $this->RegisterMessage($vid, VM_UPDATE);
            }
        }
    }

    public function MessageSink(int $TimeStamp, int $SenderID, int $Message, $Data): void
    {
        if ($Message === VM_UPDATE) {
            // bei jeder Aktualisierung einer Zählervariable neu senden
            $this->UpdateData();
        }
    } 

    /**
     * Liefert das HTML-Template und injiziert initiale Daten
     */
    public function GetVisualizationTile(): string
    {
        // Initial senden
        $this->UpdateData();
        // HTML laden
        $htmlPath = __DIR__ . '/module.html';
        if (!file_exists($htmlPath)) {
            $this->LogMessage("module.html nicht gefunden in $htmlPath", KL_ERROR);
            return '';
        }
        return file_get_contents($htmlPath);
    }

    /**
     * Callback vom HTML: frische Daten senden
     */
    public function RequestAction(string $Ident, $Value): void
    {
        if ($Ident === 'update') {
            $this->UpdateData();
        } else {
            throw new \UnexpectedValueException("Unknown Ident $Ident");
        }
    }

    /**
     * Berechnet Tagesdaten und schickt sie an die Visualisierung
     */
    public function UpdateData(): void
    {
        $start = strtotime('today 00:00');
        $end   = time();

        $prod  = $this->GetDailyTotal($this->ReadPropertyInteger('VarProduction'),  $start, $end);
        $cons  = $this->GetDailyTotal($this->ReadPropertyInteger('VarConsumption'), $start, $end);
        $feed  = $this->GetDailyTotal($this->ReadPropertyInteger('VarFeedIn'),      $start, $end);
        $grid  = $this->GetDailyTotal($this->ReadPropertyInteger('VarGrid'),        $start, $end);

        $prodCons = $prod > 0 ? ($cons  / $prod) * 100 : 0;
        $prodFeed = $prod > 0 ? ($feed  / $prod) * 100 : 0;
        $consPV   = $cons > 0 ? (min($prod, $cons) / $cons) * 100 : 0;
        $consGrid = $cons > 0 ? ($grid  / $cons) * 100 : 0;

        $data = [
            'prodCons' => round($prodCons, 1),
            'prodFeed' => round($prodFeed, 1),
            'consPV'   => round($consPV,   1),
            'consGrid' => round($consGrid, 1),
            'value'    => [
                'prod' => round($prod,  2),
                'cons' => round($cons,  2),
                'feed' => round($feed,  2),
                'grid' => round($grid,  2),
            ],
        ];

        // Als JSON-String senden
        $this->UpdateVisualizationValue(json_encode($data));
    }

    /**
     * Holt aggregierte Tageswerte (Summe) aus dem Archiv
     */
    private function GetDailyTotal(int $varID, int $start, int $end): float
    {
        if ($varID <= 0) {
            return 0.0;
        }
        $archives = IPS_GetInstanceListByModuleID('{43192F11-5B02-4B5D-9B53-8B4DBD4769E9}');
        if (empty($archives)) {
            return 0.0;
        }
        $values = AC_GetAggregatedValues($archives[0], $varID, 1, $start, $end, 1);
        if (empty($values)) {
            return 0.0;
        }
        // Für Zähler den Summenwert nutzen
        return (float)$values[0]['Sum'];
    }
}
?>