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

no message

Browse Source
This commit is contained in:
Daniel Häfliger
2025-11-06 10:40:51 +01:00
parent 1cd8eb9f60
commit cbefff8e4b
1 changed files with 185 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

206
Abrechnung/module.php
View File

@@ -141,42 +141,172 @@ class Abrechnung extends IPSModule
private function CalculatePowerCosts($powerMeters, $tariffs, $userId, $from, $to)
{
// Tabelle Kopf
$html = "<table border='1' cellspacing='0' cellpadding='3' width='100%' style='font-size:8px;'>
<tr style='background-color:#f0f0f0;'>
<th>Zähler</th><th>Typ</th><th>Start</th><th>Ende</th>
<th>Zähler Start</th><th>Zähler Ende</th><th>Verbrauch</th><th>Tarif (Rp)</th><th>Kosten (CHF)</th>
<th>Zähler</th>
<th>Import (kWh)</th>
<th>Export (kWh)</th>
<th>Solarbezug (kWh)</th>
<th>Netzbezug (kWh)</th>
<th>PV-Einspeisung (kWh)</th>
<th>PV-Verkauf (kWh)</th>
<th>Kosten Solar (CHF)</th>
<th>Kosten Netz (CHF)</th>
<th>Ertrag Einspeise (CHF)</th>
<th>Ertrag Verkauf (CHF)</th>
<th>Summe (CHF)</th>
</tr>";
$total = 0.0;
$usedTariffs = [];
// Sammler je Zähler
$acc = []; // name => arrays
// Index Zähler für User
$meters = [];
foreach ($powerMeters as $m) {
if ($m['user_id'] != $userId) continue;
$cost = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, 'Strombezug');
$html .= $cost['row'];
$total += $cost['value'];
$usedTariffs = array_merge($usedTariffs, $cost['tariffs']);
$name = $m['name'];
$meters[$name] = [
'name' => $name,
'imp' => $m['var_import'] ?? null,
'exp' => $m['var_export'] ?? null
];
$acc[$name] = [
'imp'=>0.0,'exp'=>0.0,
'solar_bezug'=>0.0,'netz_bezug'=>0.0,
'pv_einspeisung'=>0.0,'pv_verkauf'=>0.0,
'cost_solar'=>0.0,'cost_grid'=>0.0,
'rev_feedin'=>0.0,'rev_solar_sale'=>0.0
];
}
if (empty($meters)) {
$html .= "<tr><td colspan='12' align='center'>Keine Stromzähler für diesen Benutzer</td></tr></table><br>";
return ['html'=>$html, 'sum'=>0.0];
}
// 15-Minuten-Schritte
for ($ts = $from; $ts < $to; $ts += 900) {
$slotEnd = min($to, $ts + 900);
// Deltas pro Zähler & Summen
$impTotal = 0.0;
$expTotal = 0.0;
$slot = []; // name => ['imp'=>x,'exp'=>y]
foreach ($meters as $name => $mm) {
$impDelta = 0.0;
$expDelta = 0.0;
if (!empty($mm['imp']) && IPS_VariableExists((int)$mm['imp'])) {
$impDelta = $this->readDelta((int)$mm['imp'], $ts, $slotEnd);
}
if (!empty($mm['exp']) && IPS_VariableExists((int)$mm['exp'])) {
$expDelta = $this->readDelta((int)$mm['exp'], $ts, $slotEnd);
}
// kWh annehmen (oder deine Einheit – hier keine Umrechnung)
$impDelta = max(0.0, $impDelta);
$expDelta = max(0.0, $expDelta);
$slot[$name] = ['imp'=>$impDelta, 'exp'=>$expDelta];
$impTotal += $impDelta;
$expTotal += $expDelta;
}
// Tarife zum Slot-Start
$pGrid = $this->getTariffPriceAt($tariffs, ['netztarif','netzstrom','strombezug','netz'], $ts); // Rp/kWh
$pSolar = $this->getTariffPriceAt($tariffs, ['solar','solarstom','pv','eigenverbrauch'], $ts); // Rp/kWh
$pFeed = $this->getTariffPriceAt($tariffs, ['einspeisung','feedin','einspeisetarif'], $ts); // Rp/kWh
$pSolarSell = $this->getTariffPriceAt($tariffs, ['solarverkauf','pv-verkauf'], $ts); // Rp/kWh
if ($pSolarSell === null) $pSolarSell = $pSolar; // falls kein eigener Solarverkaufstarif
// Falls alles 0 – Slot überspringen
if ($impTotal <= 0.0 && $expTotal <= 0.0) continue;
// Case A: impTotal <= expTotal
if ($impTotal <= $expTotal) {
$ratio = ($expTotal > 0.0) ? ($impTotal / $expTotal) : 0.0;
foreach ($meters as $name => $_) {
$imp = $slot[$name]['imp'];
$exp = $slot[$name]['exp'];
// Energiemengen
$acc[$name]['imp'] += $imp;
$acc[$name]['exp'] += $exp;
$acc[$name]['solar_bezug'] += $imp; // kompletter Import deckt sich aus PV (bis exp reicht)
$acc[$name]['netz_bezug'] += 0.0;
$acc[$name]['pv_verkauf'] += $ratio * $exp; // Anteil Export, der im Haus bleibt (verkauft als Solar)
$acc[$name]['pv_einspeisung'] += max(0.0, (1.0 - $ratio) * $exp); // Überschuss ins Netz
// Kosten / Erträge (Rp → CHF)
$acc[$name]['cost_grid'] += 0.0;
if ($pSolarSell !== null) $acc[$name]['cost_solar'] += ($imp * $pSolarSell) / 100.0;
if ($pSolar !== null) $acc[$name]['rev_feedin'] += ($ratio * $exp * $pSolar) / 100.0;
if ($pFeed !== null) $acc[$name]['rev_solar_sale'] += (max(0.0, (1.0 - $ratio) * $exp) * $pFeed) / 100.0;
}
}
// Case B: impTotal > expTotal
else {
$ratio = ($impTotal > 0.0) ? ($expTotal / $impTotal) : 0.0;
foreach ($meters as $name => $_) {
$imp = $slot[$name]['imp'];
$exp = $slot[$name]['exp'];
// Energiemengen
$acc[$name]['imp'] += $imp;
$acc[$name]['exp'] += $exp;
$acc[$name]['solar_bezug'] += $ratio * $imp; // Teil des Imports aus PV
$acc[$name]['netz_bezug'] += max(0.0, (1.0 - $ratio) * $imp);
$acc[$name]['pv_verkauf'] += $exp; // gesamter Export wird intern verkauft
// keine Einspeisung in diesem Zweig lt. Vorgabe
// Kosten / Erträge
if ($pGrid !== null) $acc[$name]['cost_grid'] += (max(0.0, (1.0 - $ratio) * $imp) * $pGrid) / 100.0;
if ($pSolar !== null) $acc[$name]['cost_solar'] += (($ratio * $imp) * $pSolar) / 100.0;
if ($pSolarSell !== null) $acc[$name]['rev_feedin'] += ($exp * $pSolarSell) / 100.0; // „Solareinspeiseertrag“ laut Vorgabe
// Solarverkauf-Ertrag bleibt hier 0 (lt. Spezifikation)
}
}
}
// Ausgabe-Zeilen je Zähler
$grand = 0.0;
foreach ($acc as $name => $v) {
$sum = $v['cost_solar'] + $v['cost_grid'] - $v['rev_feedin'] - $v['rev_solar_sale'];
$grand += $sum;
$html .= "<tr>
<td>{$name}</td>
<td align='right'>" . number_format($v['imp'], 3) . "</td>
<td align='right'>" . number_format($v['exp'], 3) . "</td>
<td align='right'>" . number_format($v['solar_bezug'], 3) . "</td>
<td align='right'>" . number_format($v['netz_bezug'], 3) . "</td>
<td align='right'>" . number_format($v['pv_einspeisung'], 3) . "</td>
<td align='right'>" . number_format($v['pv_verkauf'], 3) . "</td>
<td align='right'>" . number_format($v['cost_solar'], 2) . "</td>
<td align='right'>" . number_format($v['cost_grid'], 2) . "</td>
<td align='right'>" . number_format($v['rev_feedin'], 2) . "</td>
<td align='right'>" . number_format($v['rev_solar_sale'], 2) . "</td>
<td align='right'>" . number_format($sum, 2) . "</td>
</tr>";
}
// Total
$html .= "<tr style='background-color:#f9f9f9; font-weight:bold;'>
<td colspan='8' align='right'>Total Stromkosten:</td>
<td align='right'>" . number_format($total, 2) . "</td>
<td colspan='11' align='right'>Total Stromkosten:</td>
<td align='right'>" . number_format($grand, 2) . "</td>
</tr></table><br>";
// 👇 Tarifliste anhängen
if (!empty($usedTariffs)) {
$html .= "<p><strong>Angewendete Stromtarife:</strong></p><ul>";
foreach ($usedTariffs as $t) {
$html .= "<li>" . date('d.m.Y', $t['start']) . " – " . date('d.m.Y', $t['end']) . ": " .
number_format($t['price'], 2) . " Rp/kWh</li>";
}
$html .= "</ul><br>";
}
return ['html' => $html, 'sum' => $total];
return ['html'=>$html, 'sum'=>$grand];
}
// ====================== Nebenkosten ======================
private function CalculateAdditionalCosts($waterMeters, $tariffs, $userId, $from, $to)
@@ -339,4 +469,38 @@ private function AddMeterToPDFRow($meter, $tariffs, $from, $to, $type)
}
return null;
}
private function readDelta($varId, $tStart, $tEnd)
{
// Start: erster Wert NACH/AB tStart
$vStart = $this->GetValueAt($varId, $tStart, true);
// Ende: letzter Wert VOR/ BIS tEnd
$vEnd = $this->GetValueAt($varId, $tEnd, false);
if ($vStart === null || $vEnd === null) return 0.0;
return max(0.0, floatval($vEnd) - floatval($vStart));
}
private function getTariffPriceAt($tariffs, $typeSynonyms, $ts)
{
// passender unit_type
$wanted = array_map('strtolower', $typeSynonyms);
$cands = [];
foreach ($tariffs as $t) {
$u = strtolower(trim($t['unit_type'] ?? ''));
if (!in_array($u, $wanted)) continue;
$s = $this->toUnixTs($t['start'], false);
$e = $this->toUnixTs($t['end'], true);
if (!$s || !$e) continue;
if ($s <= $ts && $ts <= $e) {
$cands[] = floatval($t['price']);
}
}
if (empty($cands)) return null;
// bei Überschneidungen: ersten / günstigsten / letzten – hier: letzten Eintrag priorisieren
return end($cands);
}
}