| " . $label . " |
" . $this->FormatCurrency($a['cost_solar'], false) . " |
" . $this->FormatCurrency($a['cost_grid'], false) . " |
" . $this->FormatCurrency($a['rev_feedin'], false) . " |
" . $this->FormatCurrency($a['rev_zev'], false) . " |
" . $this->FormatCurrency($subtotal, false) . " |
";
}
$html = "
| Zählpunkt |
Import kWh |
Export kWh |
Solarbezug kWh |
Netzbezug kWh |
Einspeisung kWh |
ZEV-Verkauf kWh |
" . $energyRows . "
| Total |
" . $this->FormatNumber($totals['imp'], 3) . " |
" . $this->FormatNumber($totals['exp'], 3) . " |
" . $this->FormatNumber($totals['solar_bezug'], 3) . " |
" . $this->FormatNumber($totals['netz_bezug'], 3) . " |
" . $this->FormatNumber($totals['solareinspeisung'], 3) . " |
" . $this->FormatNumber($totals['solarverkauf'], 3) . " |
| Zählpunkt |
Kauf Solar CHF |
Kauf Netz CHF |
Gutschrift Netz CHF |
Gutschrift ZEV CHF |
Total CHF |
" . $amountRows . "
| Zwischentotal Elektrizität |
" . $this->FormatCurrency($sum, false) . " |
";
return ['html' => $html, 'sum' => $sum];
}
// ====================== Nebenkosten Wasser/Wärme ======================
private function CalculateAdditionalCosts($waterMeters, $tariffs, $userId, $from, $to)
{
$html = "
| Zähler |
Typ |
Von |
Bis |
Start |
Ende |
Verbrauch |
Tarif |
Kosten CHF |
";
$total = 0.0;
$usedTariffs = [];
$hasRows = false;
foreach ($waterMeters as $m) {
if (($m['user_id'] ?? null) != $userId) {
continue;
}
$type = $m['meter_type'] ?? 'Warmwasser';
$cost = $this->AddMeterToPDFRow($m, $tariffs, $from, $to, $type);
if ($cost['row'] !== '') {
$hasRows = true;
}
$html .= $cost['row'];
$total += $cost['value'];
$usedTariffs = array_merge($usedTariffs, $cost['tariffs']);
}
if (!$hasRows) {
$html .= "| Keine Nebenkostenzähler für diesen Benutzer |
";
}
$html .= "
| Zwischentotal Nebenkosten |
" . $this->FormatCurrency($total) . " |
";
if (!empty($usedTariffs)) {
$html .= "Angewendete Nebenkostentarife
";
foreach ($usedTariffs as $t) {
if ($t['start'] === null || $t['end'] === null) {
continue;
}
$html .= "- " . $this->h($t['unit_type'] ?? '') . ': '
. date('d.m.Y', $t['start']) . ' - ' . date('d.m.Y', $t['end'])
. ' - ' . number_format($t['price'], 3, '.', "'") . " Rp/Einheit
";
}
$html .= "
";
}
return ['html' => $html, 'sum' => $total];
}
private function AddMeterToPDFRow($meter, $tariffs, $from, $to, $type)
{
$varId = (int)($meter['var_consumption'] ?? 0);
if ($varId <= 0 || !IPS_VariableExists($varId)) {
return ['row' => '', 'value' => 0, 'tariffs' => []];
}
$filteredTariffs = array_filter($tariffs, function ($t) use ($type) {
return strtolower(trim($t['unit_type'] ?? '')) === strtolower(trim($type));
});
$usedTariffs = [];
$activeTariff = null;
foreach ($filteredTariffs as $t) {
$startTs = $this->toUnixTs($t['start'] ?? 0, false);
$endTs = $this->toUnixTs($t['end'] ?? 0, true);
if ($startTs === null || $endTs === null) {
continue;
}
if ($endTs < $from || $startTs > $to) {
continue;
}
$activeTariff = [
'start' => $startTs,
'end' => $endTs,
'price' => (float)($t['price'] ?? 0),
'unit_type' => $t['unit_type'] ?? $type
];
$usedTariffs[] = $activeTariff;
break;
}
$tariffPrice = $activeTariff ? $activeTariff['price'] : 0.0;
$startValue = $this->GetValueAt($varId, $from, false);
$endValue = $this->GetValueAt($varId, $to, false);
if ($startValue === null || $endValue === null) {
return ['row' => '', 'value' => 0, 'tariffs' => []];
}
$verbrauch = max(0, $endValue - $startValue);
$kosten = round(($tariffPrice / 100) * $verbrauch, 2);
$row = "
| " . $this->h($meter['name'] ?? '') . " |
" . $this->h($type) . " |
" . date('d.m.Y', $from) . " |
" . date('d.m.Y', $to) . " |
" . $this->FormatNumber($startValue, 2) . " |
" . $this->FormatNumber($endValue, 2) . " |
" . $this->FormatNumber($verbrauch, 2) . " |
" . number_format($tariffPrice, 3, '.', "'") . " |
" . $this->FormatCurrency($kosten, false) . " |
";
return ['row' => $row, 'value' => $kosten, 'tariffs' => array_values($usedTariffs)];
}
// ====================== Hilfsfunktionen ======================
private function h($value)
{
return htmlspecialchars((string)$value, ENT_QUOTES | ENT_SUBSTITUTE, 'UTF-8');
}
private function FormatNumber($value, $digits = 2)
{
return number_format((float)$value, $digits, '.', "'");
}
private function FormatCurrency($value, $withCurrency = true)
{
$amount = number_format((float)$value, 2, '.', "'");
return $withCurrency ? 'CHF ' . $amount : $amount;
}
private function GetValueAt($varId, $timestamp, $nearestAfter = true)
{
$archiveID = @IPS_GetInstanceListByModuleID('{43192F0B-135B-4CE7-A0A7-1475603F3060}')[0];
if (!$archiveID || !IPS_VariableExists($varId)) {
return null;
}
if ($nearestAfter) {
// Erster Wert NACH oder GENAU ab Timestamp
$values = @AC_GetLoggedValues(
$archiveID,
$varId,
$timestamp, // start
time(), // end
1 // LIMIT
);
} else {
// Letzter Wert DAVOR oder GENAU bis Timestamp
$values = @AC_GetLoggedValues(
$archiveID,
$varId,
0, // start
$timestamp, // end
1 // LIMIT
);
}
if (!empty($values)) {
return (float)$values[0]['Value'];
}
// Fallback → Live-Wert
return (float)GetValue($varId);
}
private function getDeltaFromArchive(int $varId, int $tStart, int $tEnd): float
{
// Werte holen
$startValue = $this->GetValueAt($varId, $tStart, false);
$endValue = $this->GetValueAt($varId, $tEnd, false);
if ($startValue === null || $endValue === null) {
return 0.0;
}
// Delta berechnen
$diff = $endValue - $startValue;
if ($diff < 0) {
$diff = 0.0;
}
return (float)$diff;
}
private function toUnixTs($val, $endOfDay = false)
{
if (is_int($val)) {
return $endOfDay ? strtotime(date('Y-m-d 23:59:59', $val)) : $val;
}
if (is_numeric($val)) {
$ts = (int)$val;
return $endOfDay ? strtotime(date('Y-m-d 23:59:59', $ts)) : $ts;
}
if (is_array($val) && isset($val['year'], $val['month'], $val['day'])) {
$time = $endOfDay ? '23:59:59' : '00:00:00';
return strtotime(sprintf(
'%04d-%02d-%02d %s',
$val['year'],
$val['month'],
$val['day'],
$time
));
}
if (is_string($val)) {
$s = trim($val);
if ($s !== '' && $s[0] === '{') {
$obj = json_decode($s, true);
if (isset($obj['year'], $obj['month'], $obj['day'])) {
$time = $endOfDay ? '23:59:59' : '00:00:00';
return strtotime(sprintf(
'%04d-%02d-%02d %s',
$obj['year'],
$obj['month'],
$obj['day'],
$time
));
}
}
$ts = strtotime($s);
return $ts === false ? null : $ts;
}
return null;
}
private function getTariffPriceAt($tariffs, $typeSynonyms, $ts)
{
$wanted = array_map('strtolower', $typeSynonyms);
$cands = [];
foreach ($tariffs as $t) {
$u = strtolower(trim($t['unit_type'] ?? ''));
if (!in_array($u, $wanted, true)) {
continue;
}
$s = $this->toUnixTs($t['start'], false);
$e = $this->toUnixTs($t['end'], true);
if (!$s || !$e) {
continue;
}
if ($s <= $ts && $ts <= $e) {
$cands[] = (float)$t['price'];
}
}
if (empty($cands)) {
return null;
}
return end($cands);
}
private function CollectTariffsForUser($tariffs, $types)
{
$result = [];
$wanted = array_map('strtolower', $types);
foreach ($tariffs as $t) {
$type = strtolower(trim($t['unit_type'] ?? ''));
if (!in_array($type, $wanted, true)) {
continue;
}
$start = $this->toUnixTs($t['start'], false);
$end = $this->toUnixTs($t['end'], true);
$result[] = [
'start' => $start,
'end' => $end,
'price' => (float)$t['price'],
'unit_type' => $t['unit_type'] ?? ''
];
}
return $result;
}
private function GetLogoFile()
{
$mediaID = (int)$this->ReadPropertyInteger('LogoMediaID');
if ($mediaID <= 0 || !IPS_MediaExists($mediaID)) {
return null;
}
$media = IPS_GetMedia($mediaID);
$ext = 'png';
if (!empty($media['MediaFile'])) {
$extFromFile = pathinfo($media['MediaFile'], PATHINFO_EXTENSION);
if ($extFromFile !== '') {
$ext = $extFromFile;
}
}
$path = IPS_GetKernelDir() . 'media/logo_' . $mediaID . '.' . $ext;
// Bild aus der Symcon-Media-Datenbank extrahieren
$raw = IPS_GetMediaContent($mediaID); // base64
$bin = base64_decode($raw);
if ($bin === false) {
return null;
}
file_put_contents($path, $bin);
return $path;
}
}
?>