diff --git a/Abrechnung/module.php b/Abrechnung/module.php index 6f8849a..3e8ab31 100644 --- a/Abrechnung/module.php +++ b/Abrechnung/module.php @@ -284,168 +284,131 @@ private function AddMeterToPDFRow($meter, $tariffs, $from, $to, $type) { $rows = ''; $totalCost = 0.0; - $varId = $meter['var_consumption']; - IPS_LogMessage('Abrechnung', "đ§ [AddMeterToPDFRow] Start fĂźr Zähler '{$meter['name']}' (Typ: {$type}), Zeitraum: " . date('d.m.Y H:i', $from) . " - " . date('d.m.Y H:i', $to) . ", VarID={$varId}"); + + 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', "â [AddMeterToPDFRow] Variable {$varId} fĂźr {$meter['name']} nicht gefunden"); + IPS_LogMessage('Abrechnung', "â Variable {$varId} fĂźr {$meter['name']} nicht gefunden"); return ['row' => '', 'value' => 0]; } - // --- Relevante Tarife nach Typ filtern (LOGGING ONLY) --- + // 1ď¸âŁ Relevante Tarife fĂźr diese Verbrauchsart finden $filteredTariffs = array_filter($tariffs, function ($t) use ($type) { - $tariffType = strtolower(trim($t['unit_type'] ?? '')); - $typeNorm = strtolower(trim($type)); - - $map = [ - 'strombezug' => ['strom', 'strombezug', 'stromzähler', 'stromverbrauch'], - 'warmwasser' => ['warmwasser', 'wasser', 'hww'], - 'kaltwasser' => ['kaltwasser', 'wasser', 'kww'], - 'wärme' => ['wärme', 'heizung', 'heat'] - ]; - return in_array($tariffType, $map[$typeNorm] ?? []) || $tariffType === $typeNorm; + return strtolower(trim($t['unit_type'] ?? '')) === strtolower(trim($type)); }); - IPS_LogMessage('Abrechnung', "đš [AddMeterToPDFRow] passende Tarife fĂźr '{$type}': " . count($filteredTariffs)); - if (empty($filteredTariffs)) { - IPS_LogMessage('Abrechnung', "â [AddMeterToPDFRow] Keine passenden Tarife fĂźr Typ '{$type}' gefunden â 0 Rp"); + IPS_LogMessage('Abrechnung', "â Keine passenden Tarife fĂźr {$type} gefunden"); return ['row' => '', 'value' => 0]; } - // --- Tarife sicher in Zeiträume umwandeln (LOGGING ONLY) --- + // 2ď¸âŁ Zeitlich sortieren foreach ($filteredTariffs as &$t) { $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']); - IPS_LogMessage('Abrechnung', sprintf( - " đ Tariffenster: %s â %s | Preis: %s Rp | unit_type='%s'", - $t['start_ts'] ? date('d.m.Y H:i', $t['start_ts']) : 'â', - $t['end_ts'] ? date('d.m.Y H:i', $t['end_ts']) : 'â', - isset($t['price']) ? str_replace('.', ',', (string)$t['price']) : 'â', - $t['unit_type'] ?? 'â' - )); } unset($t); - - // Sortiere Tarife nach Startzeit (unverändert) usort($filteredTariffs, fn($a, $b) => $a['start_ts'] <=> $b['start_ts']); - $current = $from; - $segIndex = 1; + // 3ď¸âŁ Startpunkt setzen + $currentStart = $from; + $segmentIndex = 1; - while ($current < $to) { - IPS_LogMessage('Abrechnung', "âĄď¸ [AddMeterToPDFRow] Segment {$segIndex} START: " . date('d.m.Y H:i', $current)); + // Schleife bis Abrechnungsende + while ($currentStart < $to) { - // Finde aktiven Tarif fĂźr diesen Zeitpunkt (unverändert) + IPS_LogMessage('Abrechnung', "âĄď¸ Segment $segmentIndex: Beginne bei " . date('d.m.Y H:i', $currentStart)); + + // đš Nächsten geloggten Wert nach Startzeit holen + $startValue = $this->GetValueAt($varId, $currentStart, true); + if ($startValue === null) { + IPS_LogMessage('Abrechnung', "â Kein Startwert gefunden bei " . date('d.m.Y H:i', $currentStart)); + break; + } + + // đš Aktiven Tarif bestimmen $activeTariff = null; foreach ($filteredTariffs as $t) { - if ($t['start_ts'] <= $current && $current <= $t['end_ts']) { + if ($t['start_ts'] <= $currentStart && $currentStart < $t['end_ts']) { $activeTariff = $t; break; } } - // Wenn kein aktiver Tarif, nimm nächsten oder rechne 0 Rp (unverändert) + // đš Falls kein Tarif aktiv â 0 Rp if (!$activeTariff) { - $nextStart = $to; - foreach ($filteredTariffs as $t) { - if ($t['start_ts'] > $current && $t['start_ts'] < $nextStart) { - $nextStart = $t['start_ts']; - } - } - $segmentEnd = min($nextStart, $to); - $tariffPrice = 0.0; - $tariffLabel = 'kein Tarif'; - IPS_LogMessage('Abrechnung', " â Kein aktiver Tarif â 0 Rp bis " . date('d.m.Y H:i', $segmentEnd)); - } else { - $segmentEnd = min($activeTariff['end_ts'], $to); - $tariffPrice = floatval($activeTariff['price']); - $tariffLabel = number_format($tariffPrice, 2, ',', ''); - IPS_LogMessage('Abrechnung', sprintf( - " â Aktiver Tarif: %.3f Rp | gĂźltig bis %s | SegmentEnd=%s", - $tariffPrice, - date('d.m.Y H:i', $activeTariff['end_ts']), - date('d.m.Y H:i', $segmentEnd) - )); + 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 + ]; } - // Sicherheitsnetz (unverändert) - if ($segmentEnd <= $current) { - IPS_LogMessage('Abrechnung', " â segmentEnd <= current (" . date('d.m.Y H:i', $segmentEnd) . " <= " . date('d.m.Y H:i', $current) . "), Abbruch der Schleife."); + $tariffEnd = $activeTariff['end_ts']; + $tariffPrice = floatval($activeTariff['price']); + $tariffLabel = number_format($tariffPrice, 2, ',', ''); + + IPS_LogMessage('Abrechnung', sprintf( + " đ§ž Aktiver Tarif: %.3f Rp (%s - %s)", + $tariffPrice, + date('d.m.Y H:i', $activeTariff['start_ts']), + date('d.m.Y H:i', $activeTariff['end_ts']) + )); + + // đš PrĂźfen, ob Tarif vor Abrechnungsende endet + if ($tariffEnd < $to) { + // Tarif endet vor Rechnungsende â Segment bis Tarifende abrechnen + $segmentEnd = $tariffEnd; + } else { + // Tarif reicht bis oder Ăźber Rechnungsende â letztes Segment + $segmentEnd = $to; + } + + // đš Nächsten Archivwert nach Segmentende lesen + $endValue = $this->GetValueAt($varId, $segmentEnd, true); + if ($endValue === null) { + IPS_LogMessage('Abrechnung', "â Kein Endwert gefunden bei " . date('d.m.Y H:i', $segmentEnd)); break; } - // --- Verbrauch fĂźr diesen Zeitraum (unverändert) --- - IPS_LogMessage('Abrechnung', " đ Hole Startwert @ " . date('d.m.Y H:i', $current) . " (nearestAfter=true)"); - $startVal = $this->GetValueAt($varId, $current, true); - - IPS_LogMessage('Abrechnung', " đ Hole Endwert @ " . date('d.m.Y H:i', $segmentEnd) . " (nearestAfter=true)"); - $endVal = $this->GetValueAt($varId, $segmentEnd, true); - - if ($startVal === null || $endVal === null) { - IPS_LogMessage('Abrechnung', " â Keine Werte gefunden (startVal=" . var_export($startVal, true) . ", endVal=" . var_export($endVal, true) . ") â Segment Ăźbersprungen"); - $current = $segmentEnd + 1; - $segIndex++; - continue; - } - - $diff = max(0, $endVal - $startVal); - $costCHF = round(($tariffPrice / 100) * $diff, 2); - $totalCost += $costCHF; + // đš Verbrauch und Kosten + $verbrauch = max(0, $endValue - $startValue); + $kosten = round(($tariffPrice / 100) * $verbrauch, 2); + $totalCost += $kosten; IPS_LogMessage('Abrechnung', sprintf( - " đ Segment %d: Start=%.3f, Ende=%.3f, Verbrauch=%.3f, Tarif=%s, Kosten=%.2f CHF", - $segIndex, $startVal, $endVal, $diff, $tariffLabel, $costCHF + " đ Segment %d: Start=%.3f, Ende=%.3f, Verbrauch=%.3f, Tarif=%.3f Rp â %.2f CHF", + $segmentIndex, $startValue, $endValue, $verbrauch, $tariffPrice, $kosten )); - // --- Ausgabezeile (unverändert) --- + // đš Zeile erzeugen $rows .= "