401\s-\sUnauthorized:.(.*)?<\/h2>.*?(.*)?<\/h3>/sx;
$state = ($p1 // "")." ".($p2 // "");
}
$njdat = encode("utf8", $ad->decoded_content);
Log3 ($name, 5, "$name - No JSON Data received:\n ".$njdat);
if($rescode != 302 && $addon !~ /noJSONdata/x) { # 302 -> HTTP-Antwort liefert zusätzlich eine URL im Header-Feld Location. Es soll eine zweite, ansonsten identische Anfrage an die in Location angegebene neue URL gestellt werden.
$errstate = 1;
$state = "ERROR - see logfile for further information";
}
}
return ($reread,$retry,$errstate,$state);
}
################################################################
# Cookie Daten analysieren & extrahieren
# Die extract_cookies()-Methode sucht im HTTP::Response-Objekt,
# das als Argument übergeben wird, nach Set-Cookie: und
# Set-Cookie2: Headern.
################################################################
sub ___extractCookie {
my $paref = shift;
my $ua = $paref->{ua};
my $data = $paref->{data}; # empfangene Rohdaten
eval { $ua->cookie_jar->extract_cookies($data) } or return;
return;
}
################################################################
## Verarbeitung empfangene Daten, setzen Readings
################################################################
sub ParseData {
my $string = shift;
my @a = split("\\|",$string);
my $hash = $defs{$a[0]};
my $name = $hash->{NAME};
my @da = ();
my $lc;
my $exceed = $a[1];
my $newcycle = $a[2];
my $errstate = $a[3];
my $getp = $a[4];
my $setp = $a[5];
my $ac = $hash->{HELPER}{ACTCYCLE};
my $maxcycles = (controlParams $name)[1];
if($exceed) {
delete($hash->{HELPER}{RUNNING_PID});
delcookiefile ($hash);
$hash->{HELPER}{GETTER} = $getp;
$hash->{HELPER}{SETTER} = $setp;
CallInfo($hash,1,1); # neuer Versuch (nach Threshold exceed) im gleichen Cycle mit gelöschtem Cookie
return;
}
if($newcycle && $ac < $maxcycles) {
delete($hash->{HELPER}{RUNNING_PID});
delcookiefile ($hash);
$hash->{HELPER}{GETTER} = $getp;
$hash->{HELPER}{SETTER} = $setp;
$hash->{HELPER}{ACTCYCLE}++;
CallInfo($hash,1,0); # neuer Abrufcycle
return;
}
# Laufzeit für einen Cycle berechnen
my $btime = $hash->{HELPER}{CYCLEBTIME};
my $etime = (gettimeofday())[0];
my $cycles = $hash->{HELPER}{ACTCYCLE};
my $ctime = int(($etime - $btime) / $cycles); # durchschnittliche Laufzeit für einen Zyklus
my $state = decode_base64($a[6]);
if($a[7]) {
$lc = decode_base64($a[7]);
@da = split "###", $lc;
}
deleteData($hash, 1) if($getp ne "none"); # Daten nur löschen wenn Datenabruf (kein Verbraucher schalten)
readingsBeginUpdate($hash);
for my $elem (@da) {
my ($rn,$rval) = split ":", $elem, 2;
readingsBulkUpdate($hash, $rn, $rval);
}
readingsEndUpdate($hash, 1);
my $ldlv = $stpl{liveData}{level};
# my $cclv = $stpl{consumerCurrentdata}{level};
my $lddo = $subs{$name}{liveData}{doit};
my $pv = ReadingsNum($name, "${ldlv}_PV" , 0);
my $fi = ReadingsNum($name, "${ldlv}_FeedIn" , 0);
my $gc = ReadingsNum($name, "${ldlv}_GridConsumption", 0);
my $sum = $fi-$gc;
my $ts = strftime('%Y-%m-%d %H:%M:%S', localtime);
if(AttrVal("global", "language", "EN") eq "DE") {
$ts = strftime('%d.%m.%Y %H:%M:%S', localtime);
}
readingsBeginUpdate($hash);
if(!$errstate) {
# if($setp ne "none") {
# my ($d,$susyid,$op) = split(":",$setp);
# $op = ($op eq "auto") ? "off (automatic)" : $op;
# readingsBulkUpdate($hash, "${cclv}_${d}_Switch", $op) if($susyid == 191);
# }
readingsBulkUpdate($hash, "lastCycleTime", $ctime ) if($ctime > 0);
readingsBulkUpdate($hash, "summary", $sum." W") if($subs{$name}{liveData}{doit});
readingsBulkUpdate($hash, "lastSuccessTime", $ts );
}
readingsBulkUpdate($hash, "state", $state);
readingsEndUpdate($hash, 1);
finalCleanup($hash);
SPGRefresh($hash,0,1);
return;
}
################################################################
## Timeout BlockingCall
################################################################
sub ParseAborted {
my ($hash,$cause) = @_;
my $name = $hash->{NAME};
$cause = $cause // "Timeout >process terminated<";
Log3 ($name, 1, "$name - BlockingCall $hash->{HELPER}{RUNNING_PID}{fn} pid:$hash->{HELPER}{RUNNING_PID}{pid} $cause");
readingsSingleUpdate($hash, "state", "broken: ".$cause, 1);
finalCleanup($hash);
return;
}
################################################################
## Final cleanup of an execution
################################################################
sub finalCleanup {
my $hash = shift;
my $name = $hash->{NAME};
delete($hash->{HELPER}{RUNNING_PID});
$hash->{HELPER}{GETTER} = "all";
$hash->{HELPER}{SETTER} = "none";
if(AttrVal($name, "cookieDelete", "auto") =~ /Run/x) {
Log3 ($name, 3, "$name - force delete cookie file");
delcookiefile ($hash);
}
return;
}
################################################################
# Cookie-Datei löschen
################################################################
sub delcookiefile {
my $hash = shift;
my $source = shift;;
my $name = $hash->{NAME};
my $err = "";
my $cookieLocation = AttrVal($name, "cookieLocation", "./log/".$name."_cookie.txt");
my $delfile = unlink ($cookieLocation) or $err = $!;
if($delfile) {
Log3 $name, 3, "$name - Cookie file deleted: $cookieLocation";
}
return ($err);
}
################################################################
## Auswertung Live Daten
################################################################
sub extractLiveData { ## no critic 'complexity'
my $hash = shift;
my $daref = shift;
my $live = shift;
my $name = $hash->{NAME};
my $val = "";
Log3 ($name, 4, "$name - ##### extracting live data #### ");
$live = eval{decode_json($live)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my ($errMsg,$warnMsg,$infoMsg) = (0,0,0);
my $lv = $stpl{liveData}{level};
my $lang = AttrVal ("global", "language", "EN");
my %hm = ( # Header Messages sprachenabhängig
"DE" => "Nachricht von SMA Sunny Portal erhalten:",
"EN" => "Message got from SMA Sunny Portal:"
);
if (ref $live eq "HASH") {
push @$daref, "${lv}_FeedIn:" .$live->{FeedIn}." W" if(defined $live->{FeedIn});
push @$daref, "${lv}_GridConsumption:" .$live->{GridConsumption}." W" if(defined $live->{GridConsumption});
push @$daref, "${lv}_PV:" .$live->{PV}." W" if(defined $live->{PV});
push @$daref, "${lv}_AutarkyQuote:" .$live->{AutarkyQuote}." %" if(defined $live->{AutarkyQuote});
push @$daref, "${lv}_SelfConsumption:" .$live->{SelfConsumption}." W" if(defined $live->{SelfConsumption});
push @$daref, "${lv}_SelfConsumptionQuote:" .$live->{SelfConsumptionQuote}." %" if(defined $live->{SelfConsumptionQuote});
push @$daref, "${lv}_SelfSupply:" .$live->{SelfSupply}." W" if(defined $live->{SelfSupply});
push @$daref, "${lv}_TotalConsumption:" .$live->{TotalConsumption}." W" if(defined $live->{TotalConsumption});
push @$daref, "${lv}_BatteryIn:" .$live->{BatteryIn}. " W" if(defined $live->{BatteryIn});
push @$daref, "${lv}_BatteryOut:" .$live->{BatteryOut}." W" if(defined $live->{BatteryOut});
push @$daref, "${lv}_BatteryMode:" .$live->{BatteryMode}."" if(defined $live->{BatteryMode});
push @$daref, "${lv}_BatteryStateOfHealth:" .$live->{BatteryStateOfHealth}."" if(defined $live->{BatteryStateOfHealth});
push @$daref, "${lv}_BatteryChargeStatus:" .$live->{BatteryChargeStatus}." %" if(defined $live->{BatteryChargeStatus});
push @$daref, "${lv}_DirectConsumption:" .$live->{DirectConsumption}." W" if(defined $live->{DirectConsumption});
push @$daref, "${lv}_DirectConsumptionQuote:" .$live->{DirectConsumptionQuote}." %" if(defined $live->{DirectConsumptionQuote});
push @$daref, "${lv}_ModuleTemperature:" .$live->{ModuleTemperature}."" if(defined $live->{ModuleTemperature});
push @$daref, "${lv}_Insolation:" .$live->{Insolation}."" if(defined $live->{Insolation});
push @$daref, "${lv}_WindSpeed:" .$live->{WindSpeed}."" if(defined $live->{WindSpeed});
push @$daref, "${lv}_EnvironmentTemperature:" .$live->{EnvironmentTemperature}."" if(defined $live->{EnvironmentTemperature});
if($live->{OperationHealth}) {
my $o = "Ok: " .$live->{OperationHealth}{Ok};
my $w = "Warning: ".$live->{OperationHealth}{Warning};
my $e = "Error: " .$live->{OperationHealth}{Error};
my $u = "Unknown: ".$live->{OperationHealth}{Unknown};
push @$daref, "${lv}_OperationHealth: $o, $w, $e, $u";
}
if($live->{ErrorMessages}[0]) {
my @em;
$errMsg = 1;
for my $a (@{$live->{ErrorMessages}}) {
push @em, encode ("utf8", $a);
}
$val = join " ", @em if(@em);
push @$daref, "${lv}_ErrorMessages:".qq{$hm{$lang}
$val};
}
if($live->{WarningMessages}[0]) {
my @wm;
$warnMsg = 1;
for my $a (@{$live->{WarningMessages}}) {
push @wm, encode ("utf8", $a);
}
$val = join " ", @wm if(@wm);
push @$daref, "${lv}_WarningMessages:".qq{$hm{$lang}
$val};
}
if($live->{InfoMessages}[0]) {
my @im;
$infoMsg = 1;
for my $a (@{$live->{InfoMessages}}) {
push @im, encode ("utf8", $a);
}
$val = join " ", @im if(@im);
push @$daref, "${lv}_InfoMessages:".qq{$hm{$lang}
$val};
}
}
BlockingInformParent("FHEM::SMAPortal::delReadingFromBlocking", [$name, "${lv}_ErrorMessages"] , 1) if(!$errMsg);
BlockingInformParent("FHEM::SMAPortal::delReadingFromBlocking", [$name, "${lv}_WarningMessages"], 1) if(!$warnMsg);
BlockingInformParent("FHEM::SMAPortal::delReadingFromBlocking", [$name, "${lv}_InfoMessages"] , 1) if(!$infoMsg);
return;
}
################################################################
## Auswertung Forecast Daten
################################################################
sub extractForecastData { ## no critic 'complexity'
my $hash = shift;
my $daref = shift;
my $forecast = shift;
my $name = $hash->{NAME};
Log3 ($name, 4, "$name - ##### extracting forecast data #### ");
$forecast = eval{decode_json($forecast)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time);
$year += 1900;
$mon += 1;
my $today = "$year-".sprintf("%02d", $mon)."-".sprintf("%02d", $mday)."T";
my $lv = $stpl{forecastData}{level};
my $PV_sum = 0;
my $consum_sum = 0;
my $sum = 0;
# Counter for forecast objects
my $obj_nr = 0;
# The next few hours...
my %nextFewHoursSum = ("PV" => 0, "Consumption" => 0, "Total" => 0, "ConsumpRcmd" => 0);
# Rest of the day...
my %restOfDaySum = ("PV" => 0, "Consumption" => 0, "Total" => 0, "ConsumpRcmd" => 0);
# Tomorrow...
my %tomorrowSum = ("PV" => 0, "Consumption" => 0, "Total" => 0, "ConsumpRcmd" => 0);
# Get the current day (for 2016-02-26, this is 26)
my $current_day = (localtime)[3];
# Loop through all forecast objects
# Energie wird als "J" geliefert, Wh = J / 3600
for my $fc_obj (@{$forecast->{'ForecastSeries'}}) {
my $fc_datetime = $fc_obj->{'TimeStamp'}->{'DateTime'}; # Example for DateTime: 2016-02-15T23:00:00
my $tkind = $fc_obj->{'TimeStamp'}->{'Kind'}; # Zeitart: Unspecified, Utc
# Calculate Unix timestamp (month begins at 0, year at 1900)
my ($fc_year, $fc_month, $fc_day, $fc_hour) = $fc_datetime =~ /^(\d\d\d\d)-(\d\d)-(\d\d)T(\d\d):00:00$/x;
my $fc_uts = POSIX::mktime( 0, 0, $fc_hour, $fc_day, $fc_month - 1, $fc_year - 1900 );
my $fc_diff_seconds = $fc_uts - time + 3600; # So we go above 0 for the current hour
my $fc_diff_hours = int( $fc_diff_seconds / 3600 );
# Use also old data to integrate daily PV and Consumption
if ($current_day == $fc_day) {
$PV_sum += int($fc_obj->{'PvMeanPower'}->{'Amount'}); # integrator of daily PV in Wh
$consum_sum += int($fc_obj->{'ConsumptionForecast'}->{'Amount'}/3600); # integrator of daily Consumption forecast in Wh
}
# Don't use old data
next if $fc_diff_seconds < 0;
# Sum up for the next few hours (4 hours total, this is current hour plus the next 3 hours)
if ($obj_nr < 4) {
$nextFewHoursSum{'PV'} += $fc_obj->{'PvMeanPower'}->{'Amount'}; # Wh
$nextFewHoursSum{'Consumption'} += $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh
$nextFewHoursSum{'Total'} += $fc_obj->{'PvMeanPower'}->{'Amount'} - $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh
$nextFewHoursSum{'ConsumpRcmd'} += $fc_obj->{'IsConsumptionRecommended'} ? 1 : 0;
}
# If data is for the rest of the current day
if ( $current_day == $fc_day ) {
$restOfDaySum{'PV'} += $fc_obj->{'PvMeanPower'}->{'Amount'}; # Wh
$restOfDaySum{'Consumption'} += $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh
$restOfDaySum{'Total'} += $fc_obj->{'PvMeanPower'}->{'Amount'} - $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh
$restOfDaySum{'ConsumpRcmd'} += $fc_obj->{'IsConsumptionRecommended'} ? 1 : 0;
}
# If data is for the next day (quick and dirty: current day different from this object's day)
# Assuming only the current day and the next day are returned from Sunny Portal
if ( $current_day != $fc_day ) {
$tomorrowSum{'PV'} += $fc_obj->{'PvMeanPower'}->{'Amount'} if(exists($fc_obj->{'PvMeanPower'}->{'Amount'})); # Wh
$tomorrowSum{'Consumption'} += $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh
$tomorrowSum{'Total'} += $fc_obj->{'PvMeanPower'}->{'Amount'} - $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600 if ($fc_obj->{'PvMeanPower'}->{'Amount'}); # Wh
$tomorrowSum{'ConsumpRcmd'} += $fc_obj->{'IsConsumptionRecommended'} ? 1 : 0;
}
# Update values in Fhem if less than 24 hours in the future
# TimeStamp Kind: "Unspecified"
if ($obj_nr < 24) {
my $time_str = "ThisHour";
$time_str = "NextHour".sprintf("%02d", $obj_nr) if($fc_diff_hours>0);
if($time_str =~ /NextHour/x) {
push @$daref, "${lv}_${time_str}_Time:". TimeAdjust($hash,$fc_obj->{'TimeStamp'}->{'DateTime'},$tkind);
push @$daref, "${lv}_${time_str}_PvMeanPower:". int( $fc_obj->{'PvMeanPower'}->{'Amount'} )." Wh"; # in W als Durchschnitt geliefet, d.h. eine Stunde -> Wh
push @$daref, "${lv}_${time_str}_Consumption:". int( $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600 )." Wh"; # {'ConsumptionForecast'}->{'Amount'} wird als J = Ws geliefert
push @$daref, "${lv}_${time_str}_IsConsumptionRecommended:". ($fc_obj->{'IsConsumptionRecommended'} ? "yes" : "no");
push @$daref, "${lv}_${time_str}_Total:". (int($fc_obj->{'PvMeanPower'}->{'Amount'}) - int($fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600))." Wh";
# add WeatherId Helper to show weather icon
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "${lv}_".${time_str}."_WeatherId:".int($fc_obj->{'WeatherId'}) ], 1) if(defined $fc_obj->{'WeatherId'});
}
if($time_str =~ /ThisHour/x) {
push @$daref, "${lv}_${time_str}_Time:". TimeAdjust($hash,$fc_obj->{'TimeStamp'}->{'DateTime'},$tkind);
push @$daref, "${lv}_${time_str}_PvMeanPower:". int( $fc_obj->{'PvMeanPower'}->{'Amount'} )." Wh"; # in W als Durchschnitt geliefet, d.h. eine Stunde -> Wh
push @$daref, "${lv}_${time_str}_Consumption:". int( $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600 )." Wh"; # {'ConsumptionForecast'}->{'Amount'} wird als J = Ws geliefert
push @$daref, "${lv}_${time_str}_IsConsumptionRecommended:". ($fc_obj->{'IsConsumptionRecommended'} ? "yes" : "no");
push @$daref, "${lv}_${time_str}_Total:". (int($fc_obj->{'PvMeanPower'}->{'Amount'}) - int($fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600))." Wh";
# add WeatherId Helper to show weather icon
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "${lv}_".${time_str}."_WeatherId:".int($fc_obj->{'WeatherId'}) ], 1) if(defined $fc_obj->{'WeatherId'});
}
}
# Increment object counter
$obj_nr++;
}
push @$daref, "${lv}_Next04Hours_Consumption:". int( $nextFewHoursSum{'Consumption'} )." Wh";
push @$daref, "${lv}_Next04Hours_PV:". int( $nextFewHoursSum{'PV'} )." Wh";
push @$daref, "${lv}_Next04Hours_Total:". int( $nextFewHoursSum{'Total'} )." Wh";
push @$daref, "${lv}_Next04Hours_IsConsumptionRecommended:". int( $nextFewHoursSum{'ConsumpRcmd'} )." h";
push @$daref, "${lv}_ForecastToday_Consumption:". $consum_sum." Wh";
push @$daref, "${lv}_ForecastToday_PV:". $PV_sum." Wh";
push @$daref, "${lv}_RestOfDay_Consumption:". int( $restOfDaySum{'Consumption'} )." Wh";
push @$daref, "${lv}_RestOfDay_PV:". int( $restOfDaySum{'PV'} )." Wh";
push @$daref, "${lv}_RestOfDay_Total:". int( $restOfDaySum{'Total'} )." Wh";
push @$daref, "${lv}_RestOfDay_IsConsumptionRecommended:". int( $restOfDaySum{'ConsumpRcmd'} )." h";
push @$daref, "${lv}_Tomorrow_Consumption:". int( $tomorrowSum{'Consumption'} )." Wh";
push @$daref, "${lv}_Tomorrow_PV:". int( $tomorrowSum{'PV'} )." Wh";
push @$daref, "${lv}_Tomorrow_Total:". int( $tomorrowSum{'Total'} )." Wh";
push @$daref, "${lv}_Tomorrow_IsConsumptionRecommended:". int( $tomorrowSum{'ConsumpRcmd'} )." h";
return;
}
################################################################
## Auswertung Wetterdaten
################################################################
sub extractWeatherData {
my $hash = shift;
my $daref = shift;
my $weather = shift;
my $name = $hash->{NAME};
Log3 ($name, 4, "$name - ##### extracting weather data #### ");
$weather = eval{decode_json($weather)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $lv = $stpl{weatherData}{level};
for my $k (keys %$weather) {
next if(!$k);
Log3 ($name, 4, qq{$name - Weatherdata content "$k": }.Dumper $weather->{$k});
if (ref $weather->{$k} eq "HASH") {
my $ih = $weather->{$k};
my $day = $k;
my $symbol = encode("utf8", $weather->{$k}{TemperatureSymbol});
my $temp = sprintf("%.1f", $weather->{$k}{Temperature});
my $wdesc = encode ("utf8", $weather->{$k}{WeatherDescription});
$wdesc =~ s/t/T/x if($wdesc =~ /^t/x);
$day =~ s/t/T/x;
push @$daref, "${lv}_${day}_Temperature:$temp $symbol";
push @$daref, "${lv}_${day}_WeatherDescription:$wdesc";
}
}
return;
}
################################################################
# Auswertung Statistic Daten
# $period = Day[_] |
# Month[_] |
# Year[_] |
# Total
################################################################
sub extractStatisticData {
my $paref = shift;
my $hash = $paref->{hash};
my $daref = $paref->{daref};
my $data_cont = $paref->{data_cont}; # empfangene Daten decoded Content
my $data = $paref->{data}; # empfangene Rohdaten
my $period = $paref->{addon};
my $tag = $paref->{tag};
my $name = $hash->{NAME};
my $sd;
Log3 ($name, 4, "$name - extracting balance data ");
$data_cont = eval{decode_json($data_cont)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $lv = $stpl{$tag}{level};
if(ref $data_cont eq "HASH") {
$sd = decode_json ( encode('UTF-8', $data_cont->{d}) );
}
if($sd && ref $sd eq "ARRAY") {
for my $a (@$sd) { # jedes ARRAY-Element ist ein HASH
my $k = $a->{Key};
my $v = $a->{Value};
push @$daref, "${lv}_${period}_${k}:$v" if(defined $statkeys{$k});
}
}
return;
}
################################################################
## Auswertung Anlagendaten
################################################################
sub extractPlantMasterData {
my $hash = shift;
my $daref = shift;
my $forecast = shift;
my $addon = shift;
my $data = shift; # gelieferte Rohdaten
my $name = $hash->{NAME};
my ($amount,$unit);
Log3 ($name, 4, "$name - ##### extracting plant master data #### ");
$forecast = eval{decode_json($forecast)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $lv = $stpl{plantMasterData}{level};
my $plantOid = $forecast->{'ForecastTimeframes'}->{'PlantOid'}; # Plant ID aus JSON filtern
if(!$plantOid) { # Plant ID aus Cookie Header extrhieren wenn nicht mi JSON geliefert (kommt vor)
Log3 ($name, 4, "$name - Plant ID not set in data, get it from cookie ...");
my $sc = $data->header('Set-Cookie') // "";
($plantOid) = $sc =~ /plantOid=([0-9a-z-]*);/x;
}
if ($plantOid) { # wichtig für erweiterte Selektionen
Log3 ($name, 4, "$name - Plant ID: ".$plantOid);
$hash->{HELPER}{PLANTOID} = $plantOid;
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "PLANTOID:$plantOid"], 1);
}
else {
Log3 ($name, 4, "$name - Plant ID not set !");
}
my $ppp = $forecast->{'PlantPeakPower'};
if($ppp) {
$amount = $forecast->{'PlantPeakPower'}{'Amount'};
$unit = $forecast->{'PlantPeakPower'}{'StandardUnit'}{'Symbol'};
push @$daref, "${lv}_PlantPeakPower:$amount $unit";
Log3 $name, 4, "$name - plantMasterData \"PlantPeakPower Amount\": $amount";
Log3 $name, 4, "$name - plantMasterData \"PlantPeakPower Symbol\": $unit";
}
return;
}
################################################################
## Auswertung Anlagenlogbuch
################################################################
sub extractPlantLogbook {
my $hash = shift;
my $daref = shift;
my $logdata = shift;
my $name = $hash->{NAME};
Log3 ($name, 4, "$name - ##### extracting plant logbook data #### ");
$logdata = eval{decode_json($logdata)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $lv = $stpl{plantLogbook}{level};
my %colors = ( # Farben Highlighting
"Info" => qq{},
"Warning" => qq{},
"Warnung" => qq{},
"Disturbance" => qq{},
"Störung" => qq{},
"Error" => qq{},
"Fehler" => qq{},
"Unknown" => qq{},
);
my $eh = ""; # Endestring Highlighting
if(ref $logdata->{aaData} eq "ARRAY") {
my @ld = @{$logdata->{aaData}};
for my $ae (@ld) { # jedes ARRAY-Element ist ein HASH
my $dn = encode("utf8", $ae->{DeviceName} );
my $ts = $ae->{Timestamp};
my $dc = encode("utf8", $ae->{Description} );
my $id = $ae->{MessageId};
my ($mt) = $ae->{MessageType} =~ /alt='(.*?)'/x;
$mt = encode("utf8", $mt) // "Unknown";
my $bh = $colors{$mt};
my $v = qq{$bh $mt $eh
$dn : $ts
$dc};
push @$daref, "${lv}_LogbookEntry_${id}:$v";
}
}
return;
}
################################################################
## Auswertung Consumer Plan Data (aus forecastData)
################################################################
sub extractConsumerPlanData {
my $hash = shift;
my $daref = shift;
my $forecast = shift;
my $name = $hash->{NAME};
my %consumers;
my ($key,$val);
Log3 ($name, 4, "$name - ##### extracting consumer plan data #### ");
$forecast = eval{decode_json($forecast)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $lv = $stpl{forecastData}{level};
# Schleife über alle Consumer Objekte
my $i = 0;
for my $c (@{$forecast->{'Consumers'}}) {
$consumers{"${i}_ConsumerName"} = $c->{'ConsumerName'};
$consumers{"${i}_ConsumerOid"} = $c->{'ConsumerOid'};
$i++;
}
if(%consumers && $forecast->{'ForecastTimeframes'}) {
# es sind Vorhersagen zu geplanten Verbraucherschaltzeiten vorhanden
# TimeFrameStart/End Kind: "Utc"
for my $c (@{$forecast->{'ForecastTimeframes'}{'PlannedTimeFrames'}}) {
my $tkind = $c->{'TimeFrameStart'}->{'Kind'}; # Zeitart: Unspecified, Utc
my $deviceOid = $c->{'DeviceOid'};
my $timeFrameStart = TimeAdjust($hash,$c->{'TimeFrameStart'}{'DateTime'},$tkind); # wandele UTC
my $timeFrameEnd = TimeAdjust($hash,$c->{'TimeFrameEnd'}{'DateTime'},$tkind); # wandele UTC
my $tz = $c->{'TimeFrameStart'}{'Kind'};
for my $k (keys(%consumers)) {
$val = $consumers{$k};
if($val eq $deviceOid && $k =~ /^(\d+)_.*$/x) {
my $lfn = $1;
$consumers{"${lfn}_PlannedOpTimeStart"} = $timeFrameStart;
$consumers{"${lfn}_PlannedOpTimeEnd"} = $timeFrameEnd;
}
}
}
}
if(%consumers) {
for my $key (keys(%consumers)) {
Log3 $name, 4, "$name - Consumer data \"$key\": ".encode("utf8", $consumers{$key});
if($key =~ /ConsumerName/x && $key =~ /^(\d+)_.*$/x) {
my $lfn = $1;
my $cn = $consumers{"${lfn}_ConsumerName"}; # Verbrauchername
next if(!$cn);
$cn = replaceJunkSigns($cn); # evtl. Umlaute/Leerzeichen im Verbrauchernamen ersetzen
my $pos = $consumers{"${lfn}_PlannedOpTimeStart"}; # geplanter Start
my $poe = $consumers{"${lfn}_PlannedOpTimeEnd"}; # geplantes Ende
my $rb = "${lv}_${cn}_PlannedOpTimeBegin";
my $re = "${lv}_${cn}_PlannedOpTimeEnd";
my $rp = "${lv}_${cn}_Planned";
if($pos) {
push @$daref, "$rb:$pos";
push @$daref, "$rp:yes";
}
else {
push @$daref, "$rb:undefined";
push @$daref, "$rp:no";
}
if($poe) {
push @$daref, "$re:$poe";
}
else {
push @$daref, "$re:undefined";
}
}
}
}
return;
}
################################################################
## Auswertung Consumer Stammdaten
################################################################
sub extractConsumerMasterdata {
my $hash = shift;
my $daref = shift;
my $cdata = shift;
my $name = $hash->{NAME};
my %consumers;
my %hcon;
my ($i,$res);
Log3 ($name, 4, "$name - ##### extracting consumer master data #### ");
$cdata = eval{decode_json($cdata)} or do { Log3 ($name, 4, "$name - No JSON Data were delivered from SMA. Possibly you haven't any consumer integrated.");
return;
};
my $lv = $stpl{consumerMasterdata}{level};
# allen Consumer Objekten die ID zuordnen
$i = 0;
for my $c (@{$cdata->{'MeasurementData'}}) {
$consumers{"${i}_ConsumerName"} = $c->{'DeviceName'};
$consumers{"${i}_ConsumerOid"} = $c->{'Consume'}{'ConsumerOid'};
$consumers{"${i}_ConsumerLfd"} = $i;
my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername
next if(!$cn);
$cn = replaceJunkSigns($cn); # Verbrauchername gemäß Readingreguarien anpassen
$hcon{$i}{DeviceName} = $cn;
$hcon{$i}{DeviceOrigName} = encode("utf8", $c->{'DeviceName'}); # der originale Verbrauchername
$hcon{$i}{ConsumerOid} = $consumers{"${i}_ConsumerOid"};
$hcon{$i}{SerialNumber} = $c->{'SerialNumber'};
$hcon{$i}{SUSyID} = $c->{'SUSyID'};
$i++;
}
for my $key (keys %hcon) {
for my $parname (keys %{$hcon{$key}}) {
my $val = $hcon{$key}{$parname};
next if(!$val);
Log3 ($name, 4, "$name - CONSUMER master data: $key -> $parname = $val");
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "CONSUMER:$key:$parname:$val"], 1);
}
}
return;
}
################################################################
## Auswertung Consumer Current Data
################################################################
sub extractConsumerCurrentdata {
my $hash = shift;
my $daref = shift;
my $clivedata = shift;
my $name = $hash->{NAME};
my %consumers;
my ($i,$res);
Log3 ($name, 4, "$name - ##### extracting consumer current data #### ");
$clivedata = eval{decode_json($clivedata)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $lv = $stpl{consumerCurrentdata}{level};
# allen Consumer Objekten die ID zuordnen
$i = 0;
for my $c (@{$clivedata->{'MeasurementData'}}) {
$consumers{"${i}_ConsumerName"} = $c->{'DeviceName'};
$consumers{"${i}_ConsumerOid"} = $c->{'Consume'}{'ConsumerOid'};
$consumers{"${i}_ConsumerLfd"} = $i;
my $cpower = $c->{'Consume'}{'Measurement'}; # aktueller Energieverbrauch in W
my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername
next if(!$cn);
$cn = replaceJunkSigns($cn);
push @$daref, "${lv}_${cn}_Power:".$cpower." W" if(defined $cpower);
$i++;
}
if(%consumers && $clivedata->{'ParameterData'}) {
# es sind Daten zu den Verbrauchern vorhanden
# Kind: "Utc" ?
$i = 0;
for my $c (@{$clivedata->{'ParameterData'}}) {
my $tkind = $c->{'Parameters'}[0]{'Timestamp'}{'Kind'}; # Zeitart: Unspecified, Utc
my $GriSwStt = $c->{'Parameters'}[0]{'Value'}; # on: 1, off: 0
my $GriSwAuto = $c->{'Parameters'}[1]{'Value'}; # automatic = 1
my $OperationAutoEna = $c->{'Parameters'}[2]{'Value'}; # Automatic Betrieb erlaubt ?
my $ltchange = TimeAdjust($hash,$c->{'Parameters'}[0]{'Timestamp'}{'DateTime'},$tkind); # letzter Schaltzeitpunkt der Bluetooth-Steckdose (Verbraucher)
my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername
next if(!$cn);
$cn = replaceJunkSigns($cn); # evtl. Umlaute/Leerzeichen im Verbrauchernamen ersetzen
if(!$GriSwStt && $GriSwAuto) {
$res = "off (automatic)";
}
elsif (!$GriSwStt && !$GriSwAuto) {
$res = "off";
}
elsif ($GriSwStt) {
$res = "on";
}
else {
$res = "undefined";
}
push @$daref, "${lv}_${cn}_Switch:$res";
push @$daref, "${lv}_${cn}_SwitchLastTime:$ltchange";
$i++;
}
}
return;
}
################################################################
## Auswertung Consumer History Energy Data
## $tf = Time Frame
################################################################
sub extractConsumerHistData { ## no critic 'complexity'
my $hash = shift;
my $daref = shift;
my $chdata = shift;
my $tf = shift;
my $name = $hash->{NAME};
my %consumers;
my ($i,$gcr,$gct,$pcr,$pct,$tct,$bcr,$bct);
Log3 ($name, 4, "$name - ##### extracting consumer history data #### ");
$chdata = eval{decode_json($chdata)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
my $livelvl = $stpl{liveData}{level};
my $bataval = (defined(ReadingsNum($name,"${livelvl}_BatteryIn", undef)) || defined(ReadingsNum($name,"${livelvl}_BatteryOut", undef)))?1:0; # Identifikation ist Battery vorhanden ?
my $dlvl = $stpl{consumerDayData}{level};
my $mlvl = $stpl{consumerMonthData}{level};
my $ylvl = $stpl{consumerYearData}{level};
# allen Consumer Objekte die ID zuordnen
$i = 0;
for my $c (@{$chdata->{'Consumers'}}) {
$consumers{"${i}_ConsumerName"} = $c->{'DeviceName'};
$consumers{"${i}_ConsumerOid"} = $c->{'ConsumerOid'};
$consumers{"${i}_ConsumerLfd"} = $i;
my $cpower = $c->{'TotalEnergy'}{'Measurement'}; # Energieverbrauch im Timeframe in Wh
my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername
next if(!$cn);
$cn = replaceJunkSigns($cn);
if($tf =~ /month|year/x) {
$tct = $c->{'TotalEnergyMix'}{'TotalConsumptionTotal'}; # Gesamtverbrauch im Timeframe in Wh
$gcr = $c->{'TotalEnergyMix'}{'GridConsumptionRelative'}; # Anteil des Netzbezugs im Timeframe am Gesamtverbrauch in %
$gct = $c->{'TotalEnergyMix'}{'GridConsumptionTotal'}; # Anteil des Netzbezugs im Timeframe am Gesamtverbrauch in Wh
$pcr = $c->{'TotalEnergyMix'}{'PvConsumptionRelative'}; # Anteil des PV-Nutzung im Timeframe am Gesamtverbrauch in %
$pct = $c->{'TotalEnergyMix'}{'PvConsumptionTotal'}; # Anteil des PV-Nutzung im Timeframe am Gesamtverbrauch in Wh
$bcr = $c->{'TotalEnergyMix'}{'BatteryConsumptionRelative'}; # Anteil der Batterie-Nutzung im Timeframe am Gesamtverbrauch in %
$bct = $c->{'TotalEnergyMix'}{'BatteryConsumptionTotal'}; # Anteil der Batterie-Nutzung im Timeframe am Gesamtverbrauch in Wh
}
push @$daref, "${dlvl}_${cn}_EnergyTotalDay:". sprintf("%.0f", $cpower). " Wh" if(defined($cpower) && $tf eq "day");
push @$daref, "${mlvl}_${cn}_EnergyTotalMonth:". sprintf("%.0f", $cpower). " Wh" if(defined($cpower) && $tf eq "month");
push @$daref, "${ylvl}_${cn}_EnergyTotalYear:". sprintf("%.0f", $cpower). " Wh" if(defined($cpower) && $tf eq "year");
push @$daref, "${mlvl}_${cn}_EnergyRelativeMonthGrid:". sprintf("%.0f", $gcr). " %" if(defined($gcr) && $tf eq "month");
push @$daref, "${mlvl}_${cn}_EnergyTotalMonthGrid:". sprintf("%.0f", $gct). " Wh" if(defined($gct) && $tf eq "month");
push @$daref, "${mlvl}_${cn}_EnergyRelativeMonthPV:". sprintf("%.0f", $pcr). " %" if(defined($pcr) && $tf eq "month");
push @$daref, "${mlvl}_${cn}_EnergyTotalMonthPV:". sprintf("%.0f", $pct). " Wh" if(defined($pct) && $tf eq "month");
push @$daref, "${mlvl}_${cn}_EnergyRelativeMonthBatt:". sprintf("%.0f", $bcr). " %" if(defined($bcr) && $bataval && $tf eq "month");
push @$daref, "${mlvl}_${cn}_EnergyTotalMonthBatt:". sprintf("%.0f", $bct). " Wh" if(defined($bct) && $bataval && $tf eq "month");
push @$daref, "${ylvl}_${cn}_EnergyRelativeYearGrid:". sprintf("%.0f", $gcr). " %" if(defined($gcr) && $tf eq "year");
push @$daref, "${ylvl}_${cn}_EnergyTotalYearGrid:". sprintf("%.0f", $gct). " Wh" if(defined($gct) && $tf eq "year");
push @$daref, "${ylvl}_${cn}_EnergyRelativeYearPV:". sprintf("%.0f", $pcr). " %" if(defined($pcr) && $tf eq "year");
push @$daref, "${ylvl}_${cn}_EnergyTotalYearPV:". sprintf("%.0f", $pct). " Wh" if(defined($pct) && $tf eq "year");
push @$daref, "${ylvl}_${cn}_EnergyRelativeYearBatt:". sprintf("%.0f", $bcr). " %" if(defined($bcr) && $bataval && $tf eq "year");
push @$daref, "${ylvl}_${cn}_EnergyTotalYearBatt:". sprintf("%.0f", $bct). " Wh" if(defined($bct) && $bataval && $tf eq "year");
$i++;
}
return;
}
################################################################
# Auswertung Ergebnis aus Switch Consumer
################################################################
sub extractSwitchConsumerData {
my $paref = shift;
my $hash = $paref->{hash};
my $daref = $paref->{daref}; # Referenz zum Datenarray
my $data_cont = $paref->{data_cont}; # Daten decoded Content
my $data = $paref->{data}; # empfangene Rohdaten
my $addon = $paref->{addon}; # ein optionales AddOn
my $tag = $paref->{tag}; # Kennzeichen der abgerufenen Daten/ der Abrufroutine
my $name = $hash->{NAME};
Log3 ($name, 4, "$name - extracting Switch Consumer result ");
my ($d,$susyid,$op) = split(":",$addon); # $op -> Verbraucher Manage Operation
Log3 ($name, 3, qq{$name - Set "$d $op" result: $data_cont});
my $state;
if($data_cont eq "true") {
$state = "ok - switched consumer $d to $op";
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "GETTER:all" ], 1);
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "SETTER:none"], 1);
my $cclv = $stpl{consumerCurrentdata}{level};
$op = ($op eq "auto") ? "off (automatic)" : $op;
push @$daref, "${cclv}_${d}_Switch:$op";
}
else {
$state = "ERROR - couldn't switch consumer $d to $op";
}
return $state;
}
################################################################
# Auswertung Ergebnis aus Manage Consumer
# By Energy
################################################################
sub extractManageConsumerByEnergy {
my $paref = shift;
my $hash = $paref->{hash};
my $ua = $paref->{ua}; # LWP Useragent
my $daref = $paref->{daref}; # Referenz zum Datenarray
my $data_cont = $paref->{data_cont}; # Daten decoded Content
my $data = $paref->{data}; # empfangene Rohdaten
my $addon = $paref->{addon}; # ein optionales AddOn
my $tag = $paref->{tag}; # Kennzeichen der abgerufenen Daten/ der Abrufroutine
my $name = $hash->{NAME};
my ($errstate,$reread,$retry) = (0,0,0);
Log3 ($name, 4, "$name - extracting manage Consumer by energy result ");
my $rescode = $data->code; # HTML Code der Antwort (sollte 302 sein bei Erfolg)
my ($d,$susyid,$op) = split(":",$addon); # $op -> eingestellter Gridconsomption Schwellenwert
my $pvlog = 100-$op;
my $state;
if($rescode == 302) {
my $location = $data->header('Location');
$state = qq{ok - Consumer "$d" set to condition: switch on if GridConsumption=$op% (PV=$pvlog%) is fulfilled};
Log3 ($name, 3, qq{$name - $state});
Log3 ($name, 3, qq{$name - next step: GET "$location" to read the new values are set });
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "GETTER:all" ], 1);
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "SETTER:none"], 1);
for my $key (keys %{$hash->{HELPER}{CONSUMER}}) {
my $h = $hash->{HELPER}{CONSUMER}{$key}{DeviceName};
if($h && $h eq $d) {
$paref->{oid} = $hash->{HELPER}{CONSUMER}{$key}{ConsumerOid};
}
}
$paref->{name} = $name;
$paref->{state} = $state;
$paref->{addon} = "$d:noJSONdata"; # das gemanagte Device in addon mitgeben
($errstate,$state,$reread,$retry) = _getConsumerEnergySetting ($paref);
}
else {
$state = qq{ERROR - couldn't set Consumer "$d" set to condition: switch on if GridConsumption=$op% (PV=$pvlog%)};
}
return $state;
}
################################################################
# Abruf der aktuell eingestellten Energy Management Settings
# von Verbrauchern des Typs 315 (z.B. SMA EV Charger)
################################################################
sub extractConsumerEnergySetting {
my $hash = shift;
my $daref = shift;
my $data_cont = shift; # gelieferter data content
my $addon = shift;
my $data = shift; # gelieferte Rohdaten
my $name = $hash->{NAME};
my ($errstate,$reread,$retry) = (0,0,0);
Log3 ($name, 4, "$name - extracting current Consumer energy settings ");
my ($d) = split ":", $addon;
my $cclv = $stpl{consumerCurrentdata}{level};
my $dcont = encode("utf8", $data->decoded_content);
my ($gcval) = $dcont =~ /var\sgridConsumptionValue\s=\s(.*?);/x;
my ($pvval) = $dcont =~ /var\spvValue\s=\s(.*?);/x;
$gcval = sprintf("%.2f",$gcval) * 100;
$pvval = sprintf("%.2f",$pvval) * 100;
push @$daref, "${cclv}_${d}_SwitchCondition:GridConsumption=$gcval% PV=$pvval%";
return;
}
################################################################
# Auswertung Daten aus Hilfsroutinen
################################################################
sub extractHelperData {
my $paref = shift;
my $hash = $paref->{hash};
my $daref = $paref->{daref}; # Referenz zum Datenarray
my $data_cont = $paref->{data_cont}; # Daten decoded Content
my $data = $paref->{data}; # empfangene Rohdaten
my $addon = $paref->{addon}; # ein optionales AddOn
my $tag = $paref->{tag}; # Kennzeichen der abgerufenen Daten/ der Abrufroutine
my $name = $hash->{NAME};
my $sd;
Log3 ($name, 4, "$name - extracting Helper data ");
my $decd = eval{decode_json($data_cont)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data");
return;
};
if(ref $decd eq "HASH") {
while (my ($k,$v) = each %$decd) {
push @$daref, "$tag:$v";
}
}
return;
}
################################################################
# sortiert eine Liste von Versionsnummern x.x.x
# Schwartzian Transform and the GRT transform
# Übergabe: "asc | desc",
################################################################
sub sortVersionNum {
my ($sseq,@versions) = @_;
my @sorted = map {$_->[0]}
sort {$a->[1] cmp $b->[1]}
map {[$_, pack "C*", split /\./x]} @versions;
@sorted = map {join ".", unpack "C*", $_}
sort
map {pack "C*", split /\./x} @versions;
if($sseq eq "desc") {
@sorted = reverse @sorted;
}
return @sorted;
}
################################################################
# Versionierungen des Moduls setzen
# Die Verwendung von Meta.pm und Packages wird berücksichtigt
################################################################
sub setVersionInfo {
my ($hash) = @_;
my $name = $hash->{NAME};
my $v = (sortTopicNum("desc",keys %vNotesIntern))[0];
my $type = $hash->{TYPE};
$hash->{HELPER}{PACKAGE} = __PACKAGE__;
$hash->{HELPER}{VERSION} = $v;
if($modules{$type}{META}{x_prereqs_src} && !$hash->{HELPER}{MODMETAABSENT}) {
# META-Daten sind vorhanden
$modules{$type}{META}{version} = "v".$v; # Version aus META.json überschreiben, Anzeige mit {Dumper $modules{SMAPortal}{META}}
if($modules{$type}{META}{x_version}) { # {x_version} ( nur gesetzt wenn $Id: 76_SMAPortal.pm 23272 2020-12-01 20:51:52Z DS_Starter $ im Kopf komplett! vorhanden )
$modules{$type}{META}{x_version} =~ s/1\.1\.1/$v/gx;
}
else {
$modules{$type}{META}{x_version} = $v;
}
return $@ unless (FHEM::Meta::SetInternals($hash)); # FVERSION wird gesetzt ( nur gesetzt wenn $Id: 76_SMAPortal.pm 23272 2020-12-01 20:51:52Z DS_Starter $ im Kopf komplett! vorhanden )
if(__PACKAGE__ eq "FHEM::$type" || __PACKAGE__ eq $type) {
# es wird mit Packages gearbeitet -> Perl übliche Modulversion setzen
# mit {->VERSION()} im FHEMWEB kann Modulversion abgefragt werden
use version 0.77; our $VERSION = FHEM::Meta::Get( $hash, 'version' ); ## no critic 'VERSION'
}
}
else {
# herkömmliche Modulstruktur
$hash->{VERSION} = $v;
}
return;
}
################################################################
# delete Readings und Hash HELPER-Daten
# $conspl = providerLevel berücksichtigen
################################################################
sub deleteData {
my $hash = shift;
my $conspl = shift;
my $name = $hash->{NAME};
my @allrds = keys%{$defs{$name}{READINGS}};
my $bl = "state|lastCycleTime|Counter|loginState|usedUserAgent"; # Blacklist
my $pblvl = $stpl{plantLogbook}{level}; # Logbuch Level
my $ballvl = $stpl{balanceDayData}{level} ."|". # Level von balanceDayData, balanceMonthData, balanceYearData
$stpl{balanceMonthData}{level}."|".
$stpl{balanceYearData}{level};
if(!$subs{$name}{forecastData}{doit}) { # wenn forecastData nicht abgerufen werden sollen -> Wetterdaten im HELPER löschen
my $fclvl = $stpl{forecastData}{level};
delete $hash->{HELPER}{"${fclvl}_ThisHour_WeatherId"};
for my $i (1..23) {
$i = sprintf("%02d",$i);
delete $hash->{HELPER}{"${fclvl}_NextHour${i}_WeatherId"};
}
}
if($conspl) { # Readings löschen wenn nicht im providerLevel enthalten
my $pbl = q{};
for my $prl (keys %{$mandatory{$name}}) { # mandatory Provider die abgerufen wurden
my $lvlm = $mandatory{$name}{$prl}{level}; # Forum: https://forum.fhem.de/index.php/topic,102112.msg1078990.html#msg1078990
if ($lvlm) {
$pbl .= "|^".$lvlm."_";
}
}
for my $prl (keys %{$subs{$name}}) { # Provider die abgerufen wurden
my $lvl;
if($subs{$name}{$prl}{doit}) {
$lvl = $subs{$name}{$prl}{level}; # Forum: https://forum.fhem.de/index.php/topic,102112.msg1078990.html#msg1078990
}
if ($lvl) {
$pbl .= "|^".$lvl."_";
}
}
$bl .= $pbl; # Blacklist ergänzen
for my $key(@allrds) {
delete $defs{$name}{READINGS}{$key} if($key !~ /$bl/x);
delete $defs{$name}{READINGS}{$key} if($key =~ /^$pblvl/x); # Logbuchreadings immer löschen
delete $defs{$name}{READINGS}{$key} if($key =~ /^$ballvl/x); # balance(Day|Month)Data Readings immer löschen wegen möglicher Relativverschiebung
}
return;
}
for my $key(@allrds) { # alle Readings löschen bis auf Standard-Blacklist
delete($defs{$name}{READINGS}{$key}) if($key !~ /$bl/x);
}
return;
}
################################################################
# erstelle addon als relative oder reale Datumangabe
################################################################
sub createDateAddon {
my $paref = shift;
my $name = $paref->{name};
my $bal = $paref->{bal};
my $tag = $paref->{tag};
my $daref = $paref->{daref};
my $addon = $paref->{addon};
my $addon1 = $paref->{addon1};
if(AttrVal($name,"useRelativeNames", 0)) { # current-x verwenden statt effektives Datum
$addon .= $bal;
my $lv = $stpl{$tag}{level};
push @$daref, "${lv}_${addon}_Date:$addon1";
}
else {
$addon .= $addon1;
}
return $addon;
}
################################################################
# statistische Counter managen
# $name = Name Device
# $rd = Name des Zählerreadings
################################################################
sub handleCounter {
my $name = shift;
my $rd = shift;
my $cstring = ReadingsVal($name, $rd, "");
my ($day,$count) = split(":", $cstring);
my $mday = (localtime(time))[3];
if(!$day || $day != $mday) {
$count = 0;
$day = $mday;
Log3 ($name, 2, qq{$name - reset counter "$rd" to >0< }) if(!$defs{$name}->{HELPER}{$rd});
$defs{$name}->{HELPER}{$rd} = 1; # nur im fork setzen um doppelten Logeintrag zu vermeiden
}
$count++;
$cstring = "$rd:$day:$count";
BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, $cstring, "NULL"], 1);
return;
}
###################################################################
# Werte aus BlockingCall heraus setzen
# Erwartete Liste:
# @setl = $name,$setread,$retries,$helper
###################################################################
sub setFromBlocking {
my $name = shift;
my $setread = shift // "NULL";
my $helper = shift // "NULL";
my $hash = $defs{$name};
if($setread ne "NULL") {
my @cparts = split ":", $setread, 2;
readingsSingleUpdate($hash, $cparts[0], $cparts[1], 1);
}
if($helper ne "NULL") {
my ($hnam,$k1,$k2,$k3) = split ":", $helper, 4;
if(defined $k3) {
$hash->{HELPER}{"$hnam"}{"$k1"}{"$k2"} = $k3;
}
elsif (defined $k2) {
$hash->{HELPER}{"$hnam"}{"$k1"} = $k2;
}
else {
$hash->{HELPER}{"$hnam"} = $k1;
}
}
return 1;
}
################################################################
# Reading aus BlockingCall heraus löschen
# Erwartete Liste:
# @params = $name,$reading
################################################################
sub delReadingFromBlocking {
my $name = shift;
my $reading = shift;
my $hash = $defs{$name};
readingsDelete($hash, $reading);
return 1;
}
################################################################
# errechnet wieviel Tage ein gegebener Monat eines
# bestimmten Jahres hat
# $m: realer Monat (1..12)
# $y: reales Jahr (2020)
################################################################
sub daysInMonth {
my $m = shift;
my $y = shift;
my $dim = $m-2?30+($m*3%7<4):28+!($y%4||$y%400*!($y%100));
return $dim;
}
################################################################
# Timestamp korrigieren
################################################################
sub TimeAdjust {
my ($hash,$t,$tkind) = @_;
$t =~ s/T/ /x;
my ($datehour, $rest) = split(/:/x,$t,2);
my ($year, $month, $day, $hour) = $datehour =~ /(\d+)-(\d\d)-(\d\d)\s+(\d\d)/x;
# Time::timegm - a UTC version of mktime()
# proto: $time = timegm($sec,$min,$hour,$mday,$mon,$year);
my $epoch = timegm(0,0,$hour,$day,$month-1,$year);
# proto: ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time);
my $isdst = (localtime($epoch))[8];
if(lc($tkind) =~ /unspecified/x) {
if($isdst) {
$epoch = $epoch - 7200;
}
else {
$epoch = $epoch - 3600;
}
}
my ($lyear,$lmonth,$lday,$lhour) = (localtime($epoch))[5,4,3,2];
$lyear += 1900; # year is 1900 based
$lmonth++; # month number is zero based
if(AttrVal("global","language","EN") eq "DE") {
return (sprintf("%02d.%02d.%04d %02d:%s", $lday,$lmonth,$lyear,$lhour,$rest));
}
else {
return (sprintf("%04d-%02d-%02d %02d:%s", $lyear,$lmonth,$lday,$lhour,$rest));
}
}
###############################################################################
# Umlaute und ungültige Zeichen für Readingerstellung ersetzen
###############################################################################
sub replaceJunkSigns {
my ($rn) = @_;
$rn =~ s/ß/ss/gx;
$rn =~ s/ä/ae/gx;
$rn =~ s/ö/oe/gx;
$rn =~ s/ü/ue/gx;
$rn =~ s/Ä/Ae/gx;
$rn =~ s/Ö/Oe/gx;
$rn =~ s/Ü/Ue/gx;
$rn = makeReadingName($rn);
return($rn);
}
###############################################################################
# JSON Boolean Test und Mapping
# $var = Variante der boolean Auswertung:
# "char": Rückgabe von true / false für wahr / falsch
# "bin" : Rückgabe von 1 / 0 für wahr / falsch
###############################################################################
sub jboolmap {
my $bool = shift;
my $var = shift // "char";
my $true = ($var eq "char") ? "true" : 1;
my $false = ($var eq "char") ? "false" : 0;
my $is_boolean = JSON::is_bool($bool);
if($is_boolean) {
$bool = $bool ? $true : $false;
}
return $bool;
}
###############################################################################
# Subroutine für Portalgrafik
###############################################################################
sub PortalAsHtml { ## no critic 'complexity'
my ($name,$wlname,$ftui) = @_;
my $hash = $defs{$name};
my $ret = "";
my ($icon,$colorv,$colorc,$maxhours,$hourstyle,$header,$legend,$legend_txt,$legend_style);
my ($val,$height,$fsize,$html_start,$html_end,$wlalias,$weather,$colorw,$maxVal,$show_night,$type,$kw);
my ($maxDif,$minDif,$maxCon,$v,$z2,$z3,$z4,$show_diff,$width,$w,$hdrDetail,$hdrAlign);
my $he; # Balkenhöhe
my (%pv,%is,%t,%we,%di,%co);
my @pgCDev;
# Kontext des aufrufenden SMAPortalSPG-Devices speichern für Refresh
$hash->{HELPER}{SPGDEV} = $wlname; # Name des aufrufenden SMAPortalSPG-Devices
$hash->{HELPER}{SPGROOM} = $FW_room ? $FW_room : ""; # Raum aus dem das SMAPortalSPG-Device die Funktion aufrief
$hash->{HELPER}{SPGDETAIL} = $FW_detail ? $FW_detail : ""; # Name des SMAPortalSPG-Devices (wenn Detailansicht)
my $fdo = $subs{$name}{forecastData}{doit};
my $fmin = $subs{$name}{forecastData}{level}; # LXX Level
my $fmaj = $subs{$name}{forecastData}{level};
my $ldlv = $subs{$name}{liveData}{level};
my $cclv = $subs{$name}{consumerCurrentdata}{level};
my ($pv0,$pv1);
$pv0 = ReadingsNum($name, "${fmin}_ThisHour_PvMeanPower", undef) if($fmin);
$pv1 = ReadingsNum($name, "${fmaj}_NextHour01_PvMeanPower", undef) if($fmaj);
if(!$hash || !defined($defs{$wlname}) || !$fdo || !defined $pv0 || !defined $pv1) {
$height = AttrNum($wlname, 'beamHeight', 200);
$ret .= "";
$ret .= "";
$ret .= "";
if(!$hash) { ## no critic "Cascading"
$ret .= "Device \"$name\" doesn't exist !";
}
elsif (!defined($defs{$wlname})) {
$ret .= "Graphic device \"$wlname\" doesn't exist !";
}
elsif (!$fdo) {
$ret .= qq{The attribute "providerLevel" of device "$name" must contain the level "forecastData" and data must be retrieved !};
}
elsif (!defined $pv0) {
$ret .= "Awaiting minor level forecast data ...";
}
elsif (!defined $pv1) {
$ret .= "Awaiting major level forecast data ...";
}
$ret .= " ";
$ret .= " ";
$ret .= "
";
return $ret;
}
@pgCDev = split(',',AttrVal($wlname,"consumerList","")); # definierte Verbraucher ermitteln
($legend_style, $legend) = split('_',AttrVal($wlname,'consumerLegend','icon_top'));
$legend = '' if(($legend_style eq 'none') || (!int(@pgCDev)));
# Verbraucherlegende und Steuerung
if ($legend) {
for (@pgCDev) {
my($txt,$im) = split(':',$_); # $txt ist der Verbrauchername
my $cmdon = "\"FW_cmd('$FW_ME$FW_subdir?XHR=1&cmd=set $name $txt on')\"";
my $cmdoff = "\"FW_cmd('$FW_ME$FW_subdir?XHR=1&cmd=set $name $txt off')\"";
my $cmdauto = "\"FW_cmd('$FW_ME$FW_subdir?XHR=1&cmd=set $name $txt auto')\"";
if ($ftui && $ftui eq "ftui") {
$cmdon = "\"ftui.setFhemStatus('set $name $txt on')\"";
$cmdoff = "\"ftui.setFhemStatus('set $name $txt off')\"";
$cmdauto = "\"ftui.setFhemStatus('set $name $txt auto')\"";
}
my $swstate = ReadingsVal($name,"${cclv}_".$txt."_Switch", "undef");
my $swicon = "![](\"$FW_ME/www/images/default/1px-spacer.png\")
";
if($swstate eq "off") {
$swicon = "![](\"$FW_ME/www/images/default/10px-kreis-rot.png\")
";
}
elsif ($swstate eq "on") {
$swicon = "![](\"$FW_ME/www/images/default/10px-kreis-gruen.png\")
";
}
elsif ($swstate =~ /off.*automatic.*/ix) {
$swicon = "![](\"$FW_ME/www/images/default/10px-kreis-gelb.png\")
";
}
if ($legend_style eq 'icon') { # mögliche Umbruchstellen mit normalen Blanks vorsehen !
$legend_txt .= $txt.' '.FW_makeImage($im).' '.$swicon.' ';
}
else {
my (undef,$co) = split('\@',$im);
$co = '#cccccc' if (!$co); # Farbe per default
$legend_txt .= ''.$txt.' '.$swicon.' '; # hier auch Umbruch erlauben
}
}
}
# Parameter f. Anzeige extrahieren
$maxhours = AttrNum($wlname, 'hourCount', 24);
$hourstyle = AttrVal($wlname, 'hourStyle', undef);
$colorv = AttrVal($wlname, 'beamColor', undef);
$colorc = AttrVal($wlname, 'beamColor2', '000000'); # schwarz wenn keine Userauswahl;
$icon = AttrVal($wlname, 'consumerAdviceIcon', undef);
$html_start = AttrVal($wlname, 'htmlStart', undef); # beliebige HTML Strings die vor der Grafik ausgegeben werden
$html_end = AttrVal($wlname, 'htmlEnd', undef); # beliebige HTML Strings die nach der Grafik ausgegeben werden
$type = AttrVal($wlname, 'layoutType', 'pv');
$kw = AttrVal($wlname, 'Wh/kWh', 'Wh');
$height = AttrNum($wlname, 'beamHeight', 200);
$width = AttrNum($wlname, 'beamWidth', 6); # zu klein ist nicht problematisch
$w = $width*$maxhours; # gesammte Breite der Ausgabe , WetterIcon braucht ca. 34px
$fsize = AttrNum($wlname, 'spaceSize', 24);
$maxVal = AttrNum($wlname, 'maxPV', 0); # dyn. Anpassung der Balkenhöhe oder statisch ?
$show_night = AttrNum($wlname, 'showNight', 0); # alle Balken (Spalten) anzeigen ?
$show_diff = AttrVal($wlname, 'showDiff', 'no'); # zusätzliche Anzeige $di{} in allen Typen
$weather = AttrNum($wlname, 'showWeather', 1);
$colorw = AttrVal($wlname, 'weatherColor', undef);
$wlalias = AttrVal($wlname, 'alias', $wlname);
$header = AttrNum($wlname, 'showHeader', 1);
$hdrAlign = AttrVal($wlname, 'headerAlignment', 'center'); # ermöglicht per attr die Ausrichtung der Tabelle zu setzen
$hdrDetail = AttrVal($wlname, 'headerDetail', 'all'); # ermöglicht den Inhalt zu begrenzen, um bspw. passgenau in ftui einzubetten
# Icon Erstellung, mit @ ergänzen falls einfärben
# Beispiel mit Farbe: $icon = FW_makeImage('light_light_dim_100.svg@green');
$icon = FW_makeImage($icon) if (defined($icon));
my $co4h = ReadingsNum ($name,"${fmin}_Next04Hours_Consumption", 0);
my $coRe = ReadingsNum ($name,"${fmin}_RestOfDay_Consumption", 0);
my $coTo = ReadingsNum ($name,"${fmin}_Tomorrow_Consumption", 0);
my $coCu = ReadingsNum ($name,"${ldlv}_GridConsumption", 0);
my $pv4h = ReadingsNum ($name,"${fmin}_Next04Hours_PV", 0);
my $pvRe = ReadingsNum ($name,"${fmin}_RestOfDay_PV", 0);
my $pvTo = ReadingsNum ($name,"${fmin}_Tomorrow_PV", 0);
my $pvCu = ReadingsNum ($name,"${ldlv}_PV", 0);
if ($kw eq 'kWh') {
$co4h = sprintf("%.1f" , $co4h/1000)." kWh";
$coRe = sprintf("%.1f" , $coRe/1000)." kWh";
$coTo = sprintf("%.1f" , $coTo/1000)." kWh";
$coCu = sprintf("%.1f" , $coCu/1000)." kW";
$pv4h = sprintf("%.1f" , $pv4h/1000)." kWh";
$pvRe = sprintf("%.1f" , $pvRe/1000)." kWh";
$pvTo = sprintf("%.1f" , $pvTo/1000)." kWh";
$pvCu = sprintf("%.1f" , $pvCu/1000)." kW";
}
else {
$co4h .= " Wh";
$coRe .= " Wh";
$coTo .= " Wh";
$coCu .= " W";
$pv4h .= " Wh";
$pvRe .= " Wh";
$pvTo .= " Wh";
$pvCu .= " W";
}
# Headerzeile generieren
if ($header) {
my $lang = AttrVal("global", "language", "EN");
my $alias = AttrVal($name, "alias", "SMA Sunny Portal"); # Linktext als Aliasname oder "SMA Sunny Portal"
my $dlink = "$alias";
my $lup = ReadingsTimestamp($name, "${fmin}_ForecastToday_Consumption", "0000-00-00 00:00:00"); # letzter Forecast Update
my $lupt = "last update:";
my $lblPv4h = "next 4h:";
my $lblPvRe = "today:";
my $lblPvTo = "tomorrow:";
my $lblPvCu = "actual";
if(AttrVal("global","language","EN") eq "DE") { # Header globales Sprachschema Deutsch
$lupt = "Stand:";
$lblPv4h = encode("utf8", "nächste 4h:");
$lblPvRe = "heute:";
$lblPvTo = "morgen:";
$lblPvCu = "aktuell";
}
$header = "";
# Header Link + Status + Update Button
if($hdrDetail eq "all" || $hdrDetail eq "statusLink") {
my ($year, $month, $day, $time) = $lup =~ /(\d{4})-(\d{2})-(\d{2})\s+(.*)/x;
if(AttrVal("global","language","EN") eq "DE") {
$lup = "$day.$month.$year $time";
}
else {
$lup = "$year-$month-$day $time";
}
my $cmdupdate = "\"FW_cmd('$FW_ME$FW_subdir?XHR=1&cmd=set $name getData')\""; # Update Button generieren
if ($ftui && $ftui eq "ftui") {
$cmdupdate = "\"ftui.setFhemStatus('set $name getData')\"";
}
my $upstate = ReadingsVal($name,"state", "undef");
my $upicon = "";
if ($upstate =~ /ok/ix) {
$upicon = "";
}
elsif ($upstate =~ /running/ix) {
$upicon = "";
}
else {
$upicon = "";
}
$header .= "".$dlink." (".$lupt." ".$lup.") ".$upicon." ";
$header .= "PV => ";
$header .= "$lblPvCu $pvCu " if($subs{$name}{liveData}{doit});
$header .= "$lblPv4h $pv4h ";
$header .= "$lblPvRe $pvRe ";
$header .= "$lblPvTo $pvTo ";
$header .= " ";
}
# Header Information co
if($hdrDetail eq "all" || $hdrDetail eq "co" || $hdrDetail eq "pvco") {
$header .= "";
$header .= "CO => ";
$header .= "$lblPvCu $coCu " if($subs{$name}{liveData}{doit});
$header .= "$lblPv4h $co4h ";
$header .= "$lblPvRe $coRe ";
$header .= "$lblPvTo $coTo ";
$header .= " ";
}
$header .= "
";
}
# Werte aktuelle Stunde
$pv{0} = ReadingsNum($name,"${fmin}_ThisHour_PvMeanPower", 0);
$co{0} = ReadingsNum($name,"${fmin}_ThisHour_Consumption", 0);
$di{0} = $pv{0} - $co{0};
$is{0} = (ReadingsVal($name,"${fmin}_ThisHour_IsConsumptionRecommended",'no') eq 'yes' ) ? $icon : undef;
$we{0} = $hash->{HELPER}{"${fmin}_ThisHour_WeatherId"} if($weather); # für Wettericons
$we{0} = $we{0} // 999;
if(AttrVal("global","language","EN") eq "DE") {
(undef,undef,undef,$t{0}) = ReadingsVal($name,"${fmin}_ThisHour_Time",'0') =~ m/(\d{2}).(\d{2}).(\d{4})\s(\d{2})/x;
}
else {
(undef,undef,undef,$t{0}) = ReadingsVal($name,"${fmin}_ThisHour_Time",'0') =~ m/(\d{4})-(\d{2})-(\d{2})\s(\d{2})/x;
}
$t{0} = int($t{0}); # zum Rechnen Integer ohne führende Null
###########################################################
# get consumer list and display it in portalGraphics
for (@pgCDev) {
my ($itemName, undef) = split(':',$_);
$itemName =~ s/^\s+|\s+$//gx; #trim it, if blanks were used
$_ =~ s/^\s+|\s+$//gx; #trim it, if blanks were used
#check if listed device is planned
if (ReadingsVal($name, "${fmaj}_".$itemName."_Planned", "no") eq "yes") {
#get start and end hour
my ($start, $end); # werden auf Balken Pos 0 - 23 umgerechnet, nicht auf Stunde !!, Pos = 24 -> ungültige Pos = keine Anzeige
if(AttrVal("global","language","EN") eq "DE") {
(undef,undef,undef,$start) = ReadingsVal($name,"${fmaj}_".$itemName."_PlannedOpTimeBegin",'00.00.0000 24') =~ m/(\d{2}).(\d{2}).(\d{4})\s(\d{2})/x;
(undef,undef,undef,$end) = ReadingsVal($name,"${fmaj}_".$itemName."_PlannedOpTimeEnd",'00.00.0000 24') =~ m/(\d{2}).(\d{2}).(\d{4})\s(\d{2})/x;
}
else {
(undef,undef,undef,$start) = ReadingsVal($name,"${fmaj}_".$itemName."_PlannedOpTimeBegin",'0000-00-00 24') =~ m/(\d{4})-(\d{2})-(\d{2})\s(\d{2})/x;
(undef,undef,undef,$end) = ReadingsVal($name,"${fmaj}_".$itemName."_PlannedOpTimeEnd",'0000-00-00 24') =~ m/(\d{4})-(\d{2})-(\d{2})\s(\d{2})/x;
}
$start = int($start);
$end = int($end);
my $flag = 0; # default kein Tagesverschieber
#correct the hour for accurate display
if ($start < $t{0}) { # consumption seems to be tomorrow
$start = 24-$t{0}+$start;
$flag = 1;
}
else {
$start -= $t{0};
}
if ($flag) { # consumption seems to be tomorrow
$end = 24-$t{0}+$end;
}
else {
$end -= $t{0};
}
$_ .= ":".$start.":".$end;
}
else {
$_ .= ":24:24";
}
Log3($name, 4, "$name - Consumer planned data: $_");
}
$maxVal = (!$maxVal) ? $pv{0} : $maxVal; # Startwert wenn kein Wert bereits via attr vorgegeben ist
$maxCon = $co{0}; # für Typ co
$maxDif = $di{0}; # für Typ diff
$minDif = $di{0}; # für Typ diff
for my $i (1..$maxhours-1) {
$pv{$i} = ReadingsNum($name,"${fmaj}_NextHour".sprintf("%02d",$i)."_PvMeanPower",0); # Erzeugung
$co{$i} = ReadingsNum($name,"${fmaj}_NextHour".sprintf("%02d",$i)."_Consumption",0); # Verbrauch
$di{$i} = $pv{$i} - $co{$i};
$maxVal = $pv{$i} if ($pv{$i} > $maxVal);
$maxCon = $co{$i} if ($co{$i} > $maxCon);
$maxDif = $di{$i} if ($di{$i} > $maxDif);
$minDif = $di{$i} if ($di{$i} < $minDif);
$is{$i} = (ReadingsVal($name,"${fmaj}_NextHour".sprintf("%02d",$i)."_IsConsumptionRecommended",'no') eq 'yes') ? $icon : undef;
$we{$i} = $hash->{HELPER}{"${fmaj}_NextHour".sprintf("%02d",$i)."_WeatherId"} if($weather); # für Wettericons
$we{$i} = $we{$i} // 999;
if(AttrVal("global","language","EN") eq "DE") {
(undef,undef,undef,$t{$i}) = ReadingsVal($name,"${fmaj}_NextHour".sprintf("%02d",$i)."_Time",'0') =~ m/(\d{2}).(\d{2}).(\d{4})\s(\d{2})/x;
}
else {
(undef,undef,undef,$t{$i}) = ReadingsVal($name,"${fmaj}_NextHour".sprintf("%02d",$i)."_Time",'0') =~ m/(\d{4})-(\d{2})-(\d{2})\s(\d{2})/x;
}
$t{$i} = int($t{$i}); # keine führende 0
}
######################################
# Tabellen Ausgabe erzeugen
# Wenn Table class=block alleine steht, zieht es bei manchen Styles die Ausgabe auf 100% Seitenbreite
# lässt sich durch einbetten in eine zusätzliche Table roomoverview eindämmen
# Die Tabelle ist recht schmal angelegt, aber nur so lassen sich Umbrüche erzwingen
$ret = "";
$ret .= $html_start if (defined($html_start));
$ret .= "";
$ret .= "";
$ret .= "\n"; # das \n erleichtert das Lesen der debug Quelltextausgabe
if ($header) { # Header ausgeben
$ret .= "";
# mit einem extra $header ";
}
if ($legend_txt && ($legend eq 'top')) {
$ret .= "";
$ret .= "$legend_txt ";
}
if ($weather) {
$ret .= "$val ";
}
else { # Kein Ertrag oder show_night = 0
$ret .= "$val ";
}
$ret .= "\n";
if (($type eq 'pv') || ($type eq 'co')) {
$v = ($type eq 'co') ? $co{$i} : $pv{$i} ;
$v = 0 if (($type eq 'co') && !$pv{$i} && !$show_night); # auch bei type co die Nacht ggf. unterdrücken
$val = formatVal6($v,$kw,$we{$i});
$ret .=""; # mit width=100% etwas bessere Füllung der Balken
$ret .="";
$ret .="".$val." ";
if ($v || $show_night) {
# Balken nur einfärben wenn der User via Attr eine Farbe vorgibt, sonst bestimmt class odd von TR alleine die Farbe
my $style = "style=\"padding-bottom:0px; vertical-align:top; margin-left:auto; margin-right:auto;";
$style .= (defined($colorv)) ? " background-color:#$colorv\"" : '"'; # Syntaxhilight
$ret .= "";
$ret .= "";
my $sicon = 1;
$ret .= $is{$i} if (defined ($is{$i}) && $sicon);
##################################
# inject the new icon if defined
$ret .= consinject($hash,$i,@pgCDev) if($ret);
$ret .= " ";
}
}
elsif ($type eq 'pvco') {
my ($color1, $color2, $style1, $style2);
$ret .="\n"; # mit width=100% etwas bessere Füllung der Balken
if ($he) { # der Freiraum oben kann beim größten Balken ganz entfallen
$ret .="";
$ret .= "$val";
$ret .= $is{$i} if (defined $is{$i});
##################################
# inject the new icon if defined
$ret .= consinject($hash,$i,@pgCDev) if($ret);
$ret .= " ";
if ($z3) { # die Zone 3 lassen wir bei zu kleinen Werten auch ganz weg
$ret .= "";
$ret .= "$v ";
}
}
else { # Type dif
my $style = "style=\"padding-bottom:0px; padding-top:1px; vertical-align:top; margin-left:auto; margin-right:auto;";
$ret .="\n"; # Tipp : das nachfolgende border=0 auf 1 setzen hilft sehr Ausgabefehler zu endecken
$val = ($di{$i} >= 0) ? formatVal6($di{$i},$kw,$we{$i}) : '';
$val = ' 0 ' if ($di{$i} == 0); # Sonderfall , hier wird die 0 gebraucht !
if ($val) {
$ret .="";
$ret .="".$val." ";
}
if ($di{$i} >= 0) { # mit Farbe 1 colorv füllen
$style .= (defined($colorv)) ? " background-color:#$colorv\"" : '"';
$z2 = 1 if ($di{$i} == 0); # Sonderfall , 1px dünnen Strich ausgeben
$ret .= "";
$ret .= "";
$ret .= $is{$i} if (defined $is{$i});
$ret .=" ";
}
else { # ohne Farbe
$z2 = 2 if ($di{$i} == 0); # Sonderfall, hier wird die 0 gebraucht !
if ($z2 && $val) { # z2 weglassen wenn nicht unbedigt nötig bzw. wenn zuvor he mit val keinen Wert hatte
$ret .= "";
$ret .=" ";
}
}
if ($di{$i} < 0) { # Negativ Balken anzeigen ?
$style .= (defined($colorc)) ? " background-color:#$colorc\"" : '"'; # mit Farbe 2 colorc füllen
$ret .= "";
$ret .= " ";
}
elsif ($z3) { # ohne Farbe
$ret .="";
$ret .=" ";
}
if ($z4) { # kann entfallen wenn auch z3 0 ist
$val = ($di{$i} < 0) ? formatVal6($di{$i},$kw,$we{$i}) : ' ';
$ret .="";
$ret .="".$val." ";
}
}
if ($show_diff eq 'bottom') { # zusätzliche diff Anzeige
$val = formatVal6($di{$i},$kw,$we{$i});
$val = ($di{$i} < 0) ? ''.$val.'' : '+'.$val; # Kommentar siehe oben bei show_diff eq top
$ret .= "$val ";
$t{$i} = $t{$i}.$hourstyle if(defined($hourstyle)); # z.B. 10:00 statt 10
$ret .= $t{$i}."
"; # Stundenwerte ohne führende 0
}
$ret .= "";
$ret .= "";
$ret .= "$legend_txt ";
}
$ret .= "
";
$ret .= $html_end if (defined($html_end));
$ret .= "";
return $ret;
}
################################################################
# Inject consumer icon
################################################################
sub consinject {
my ($hash,$i,@pgCDev) = @_;
my $name = $hash->{NAME};
my $ret = "";
for (@pgCDev) {
if ($_) {
my ($cons,$im,$start,$end) = split (':', $_);
Log3($name, 4, "$name - Consumer to show -> $cons, relative to current time -> start: $start, end: $end") if($i<1);
if ($im && ($i >= $start) && ($i <= $end)) {
$ret .= FW_makeImage($im);
}
}
}
return $ret;
}
###############################################################################
# Balkenbreite normieren
#
# Die Balkenbreite wird bestimmt durch den Wert.
# Damit alle Balken die gleiche Breite bekommen, müssen die Werte auf
# 6 Ausgabezeichen angeglichen werden.
# "align=center" gleicht gleicht es aus, alternativ könnte man sie auch
# komplett rechtsbündig ausgeben.
# Es ergibt bei fast allen Styles gute Ergebnisse, Ausnahme IOS12 & 6, da diese
# beiden Styles einen recht großen Font benutzen.
# Wird Wetter benutzt, wird die Balkenbreite durch das Icon bestimmt
###############################################################################
sub formatVal6 {
my ($v,$kw,$w) = @_;
my $n = ' '; # positive Zahl
if ($v < 0) {
$n = '-'; # negatives Vorzeichen merken
$v = abs($v);
}
if ($kw eq 'kWh') { # bei Anzeige in kWh muss weniger aufgefüllt werden
$v = sprintf('%.1f',($v/1000));
$v += 0; # keine 0.0 oder 6.0 etc
return ($n eq '-') ? ($v*-1) : $v if defined($w) ;
my $t = $v - int($v); # Nachkommstelle ?
if (!$t) { # glatte Zahl ohne Nachkommastelle
if(!$v) {
return ' '; # 0 nicht anzeigen, passt eigentlich immer bis auf einen Fall im Typ diff
}
elsif ($v < 10) {
return ' '.$n.$v.' ';
}
else {
return ' '.$n.$v.' ';
}
}
else { # mit Nachkommastelle -> zwei Zeichen mehr .X
if ($v < 10) {
return ' '.$n.$v.' ';
}
else {
return $n.$v.' ';
}
}
}
return ($n eq '-')?($v*-1):$v if defined($w);
# Werte bleiben in Watt
if (!$v) { return ' '; } ## no critic "Cascading" # keine Anzeige bei Null
elsif ($v < 10) { return ' '.$n.$v.' '; } # z.B. 0
elsif ($v < 100) { return ' '.$n.$v.' '; }
elsif ($v < 1000) { return ' '.$n.$v.' '; }
elsif ($v < 10000) { return $n.$v.' '; }
else { return $n.$v; } # mehr als 10.000 W :)
}
###############################################################################
# Zuordungstabelle "WeatherId" angepasst auf FHEM Icons
###############################################################################
sub weather_icon {
my $id = shift;
my %weather_ids = (
'0' => 'weather_sun', # Sonne (klar) # vorhanden
'1' => 'weather_cloudy_light', # leichte Bewölkung (1/3) # vorhanden
'2' => 'weather_cloudy', # mittlere Bewölkung (2/3) # vorhanden
'3' => 'weather_cloudy_heavy', # starke Bewölkung (3/3) # vorhanden
'10' => 'weather_fog', # Nebel # neu
'11' => 'weather_rain_fog', # Nebel mit Regen # neu
'20' => 'weather_rain_heavy', # Regen (viel) # vorhanden
'21' => 'weather_rain_snow_heavy', # Regen (viel) mit Schneefall # neu
'30' => 'weather_rain_light', # leichter Regen (1 Tropfen) # vorhanden
'31' => 'weather_rain', # leichter Regen (2 Tropfen) # vorhanden
'32' => 'weather_rain_heavy', # leichter Regen (3 Tropfen) # vorhanden
'40' => 'weather_rain_snow_light', # leichter Regen mit Schneefall (1 Tropfen) # neu
'41' => 'weather_rain_snow', # leichter Regen mit Schneefall (3 Tropfen) # neu
'50' => 'weather_snow_light', # bewölkt mit Schneefall (1 Flocke) # vorhanden
'51' => 'weather_snow', # bewölkt mit Schneefall (2 Flocken) # vorhanden
'52' => 'weather_snow_heavy', # bewölkt mit Schneefall (3 Flocken) # vorhanden
'60' => 'weather_rain_light', # Sonne, Wolke mit Regen (1 Tropfen) # vorhanden
'61' => 'weather_rain', # Sonne, Wolke mit Regen (2 Tropfen) # vorhanden
'62' => 'weather_rain_heavy', # Sonne, Wolke mit Regen (3 Tropfen) # vorhanden
'70' => 'weather_snow_light', # Sonne, Wolke mit Schnee (1 Flocke) # vorhanden
'71' => 'weather_snow_heavy', # Sonne, Wolke mit Schnee (3 Flocken) # vorhanden
'80' => 'weather_thunderstorm', # Wolke mit Blitz # vorhanden
'81' => 'weather_storm', # Wolke mit Blitz und Starkregen # vorhanden
'90' => 'weather_sun', # Sonne (klar) # vorhanden
'91' => 'weather_sun', # Sonne (klar) wie 90 # vorhanden
'100' => 'weather_night', # Mond - Nacht # neu
'101' => 'weather_night_cloudy_light', # Mond mit Wolken - # neu
'102' => 'weather_night_cloudy', # Wolken mittel (2/2) - Nacht # neu
'103' => 'weather_night_cloudy_heavy', # Wolken stark (3/3) - Nacht # neu
'110' => 'weather_night_fog', # Nebel - Nacht # neu
'111' => 'weather_night_rain_fog', # Nebel mit Regen (3 Tropfen) - Nacht # neu
'120' => 'weather_night_rain_heavy', # Regen (viel) - Nacht # neu
'121' => 'weather_night_snow_rain_heavy', # Regen (viel) mit Schneefall - Nacht # neu
'130' => 'weather_night_rain_light', # leichter Regen (1 Tropfen) - Nacht # neu
'131' => 'weather_night_rain', # leichter Regen (2 Tropfen) - Nacht # neu
'132' => 'weather_night_rain_heavy', # leichter Regen (3 Tropfen) - Nacht # neu
'140' => 'weather_night_snow_rain_light', # leichter Regen mit Schneefall (1 Tropfen) - Nacht # neu
'141' => 'weather_night_snow_rain_heavy', # leichter Regen mit Schneefall (3 Tropfen) - Nacht # neu
'150' => 'weather_night_snow_light', # bewölkt mit Schneefall (1 Flocke) - Nacht # neu
'151' => 'weather_night_snow', # bewölkt mit Schneefall (2 Flocken) - Nacht # neu
'152' => 'weather_night_snow_heavy', # bewölkt mit Schneefall (3 Flocken) - Nacht # neu
'160' => 'weather_night_rain_light', # Mond, Wolke mit Regen (1 Tropfen) - Nacht # neu
'161' => 'weather_night_rain', # Mond, Wolke mit Regen (2 Tropfen) - Nacht # neu
'162' => 'weather_night_rain_heavy', # Mond, Wolke mit Regen (3 Tropfen) - Nacht # neu
'170' => 'weather_night_snow_rain', # Mond, Wolke mit Schnee (1 Flocke) - Nacht # neu
'171' => 'weather_night_snow_heavy', # Mond, Wolke mit Schnee (3 Flocken) - Nacht # neu
'180' => 'weather_night_thunderstorm_light', # Wolke mit Blitz - Nacht # neu
'181' => 'weather_night_thunderstorm', # Wolke mit Blitz und Starkregen - Nacht # neu
'999' => '1px-spacer' # Dummy - keine Anzeige Wettericon # vorhanden
);
return $weather_ids{$id} if(defined($weather_ids{$id}));
return 'unknown';
}
######################################################################################################
# Refresh eines Raumes aus $hash->{HELPER}{SPGROOM}
# bzw. Longpoll von SMAPortal bzw. eines SMAPortalSPG Devices wenn $hash->{HELPER}{SPGDEV} gefüllt
# $hash, $pload (1=Page reload), SMAPortalSPG-Event (1=Event)
######################################################################################################
sub SPGRefresh {
my ($hash,$pload,$lpollspg) = @_;
my $name;
if (ref $hash ne "HASH") {
($name,$pload,$lpollspg) = split ",",$hash;
$hash = $defs{$name};
}
else {
$name = $hash->{NAME};
}
my $fpr = 0;
# Kontext des SMAPortalSPG-Devices speichern für Refresh
my $sd = $hash->{HELPER}{SPGDEV} ? $hash->{HELPER}{SPGDEV} : "\"n.a.\""; # Name des aufrufenden SMAPortalSPG-Devices
my $sr = $hash->{HELPER}{SPGROOM} ? $hash->{HELPER}{SPGROOM} : "\"n.a.\""; # Raum aus dem das SMAPortalSPG-Device die Funktion aufrief
my $sl = $hash->{HELPER}{SPGDETAIL} ? $hash->{HELPER}{SPGDETAIL} : "\"n.a.\""; # Name des SMAPortalSPG-Devices (wenn Detailansicht)
$fpr = AttrVal($hash->{HELPER}{SPGDEV},"forcePageRefresh",0) if($hash->{HELPER}{SPGDEV});
Log3($name, 4, "$name - Refresh - caller: $sd, callerroom: $sr, detail: $sl, pload: $pload, forcePageRefresh: $fpr, event_Spgdev: $lpollspg");
# Page-Reload
if($pload && ($hash->{HELPER}{SPGROOM} && !$hash->{HELPER}{SPGDETAIL} && !$fpr)) {
# trifft zu wenn in einer Raumansicht
my @rooms = split(",",$hash->{HELPER}{SPGROOM});
for (@rooms) {
my $room = $_;
{ map { FW_directNotify("FILTER=room=$room", "#FHEMWEB:$_", "location.reload('true')", "") } devspec2array("TYPE=FHEMWEB") } ## no critic 'void context';
}
}
elsif ($pload && (!$hash->{HELPER}{SPGROOM} || $hash->{HELPER}{SPGDETAIL})) {
# trifft zu bei Detailansicht oder im FLOORPLAN bzw. Dashboard oder wenn Seitenrefresh mit dem
# SMAPortalSPG-Attribut "forcePageRefresh" erzwungen wird
{ map { FW_directNotify("#FHEMWEB:$_", "location.reload('true')", "") } devspec2array("TYPE=FHEMWEB") } ## no critic 'void context';
}
else {
if($fpr) {
{ map { FW_directNotify("#FHEMWEB:$_", "location.reload('true')", "") } devspec2array("TYPE=FHEMWEB") } ## no critic 'void context';
}
}
# parentState des SMAPortalSPG-Device updaten
my @spgs = devspec2array("TYPE=SMAPortalSPG");
my $st = ReadingsVal($name, "state", "initialized");
for(@spgs) {
if($defs{$_}{PARENT} eq $name) {
next if(IsDisabled($defs{$_}{NAME}));
readingsBeginUpdate($defs{$_});
readingsBulkUpdate($defs{$_},"parentState", $st);
readingsBulkUpdate($defs{$_},"state", "updated");
readingsEndUpdate($defs{$_}, 1);
}
}
return;
}
1;
=pod
=encoding utf8
=item summary Module for communication with the SMA Sunny Portal
=item summary_DE Modul zur Kommunikation mit dem SMA Sunny Portal
=begin html
SMAPortal
With this module, data can be retrieved from the SMA Sunny Portal and
devices which are registered in the SMA Portal can be controlled.
- Live data (Consumption and PV-Generation)
- Battery data (In/Out) and usage data of consumers
- Various balance data and statistical data (also of the consumers connected to the SMA Sunny Homemanager)
- Weather data delivered from SMA for the facility location
- Forecast data (Consumption and PV-Generation) inclusive suggestion times to switch comsumers on
- the planned times by the Sunny Home Manager to switch consumers on and the current state of consumers (if present)
- Control of devices registered with SMA Home Manager or SMA Portal
Graphic data can also be integrated into FHEM Tablet UI with the
"SMAPortalSPG Widget".
Preparation
This module use the Perl module JSON which has typically to be installed discrete.
On Debian linux based systems that can be done by command:
sudo apt-get install libjson-perl
Subsequent there are an overview of used Perl modules:
POSIX
JSON
Data::Dumper
Time::HiRes
Time::Local
Blocking (FHEM-Modul)
GPUtils (FHEM-Modul)
FHEM::Meta (FHEM-Modul)
LWP::UserAgent
HTTP::Cookies
MIME::Base64
Encode
utf8
Definition
A SMAPortal device will be defined by:
define <name> SMAPortal
After the definition of the device the credentials for the SMA Sunny Portal must be saved with the
following command:
set <name> credentials <Username> <Password>
After a successful login, only the asset master data are retrieved.
The attribute providerLevel is used to set the data suppliers its data
the device should retrieve. If no Sunny Home Manager is installed, the attribute
noHomeManager must be set.
Set
- createPortalGraphic <Generation | Consumption | Generation_Consumption | Differential>
Creates graphical devices to show the SMA Sunny Portal forecast data in several layouts.
The attribute "providerLevel" must contain "forecastData".
With the "attributes of the graphic device" the appearance and coloration of the forecast
data in the created graphic device can be adjusted.
- credentials <username> <password>
Set Username / Password used for the login into the SMA Sunny Portal.
- getData
Identical to the "get data" command. Simplifies the use of the attribute "webCmd" in the FHEMWEB.
- <consumer name> <on | off | auto | GC>
The consumers connected to the SMA Sunny Homemanager are offered as soon as they are detected by the module.
Different types of consumers are recognized by the module and consumer specific actions are offered.
SMA Bluetoth Sockets on switch on, off switch off, auto control by the Sunny Home Manager SMA EV Charger GC Percentage of grid reference to be accepted for charging the electric vehicle (0..100)
Get
Attributes
- balanceDay <YYYY-MM-DD> [current current-x <YYYY-MM-DD> <YYYY-MM-DD> ...]
Defines from which days the data provider "balanceDayData" delivers the data.
In the relative specification current-x is x the number of days that are subtracted from the current day.
The days are separated by spaces, current = current day.
(default: current day)
Examples:
attr <name> balanceDay current 2020-08-07 2020-08-06 2020-08-05
attr <name> balanceDay current current-1 current-2
- balanceMonth <YYYY-MM> [current current-x <YYYY-MM> <YYYY-MM> ...]
Defines from which months the data provider "balanceMonthData" delivers the data.
In the relative specification current-x is x the number of months subtracted from the current month.
The month data is separated by spaces, current = current month.
(default: current month)
Examples:
attr <name> balanceMonth current 2019-07 2019-06 2019-05
attr <name> balanceMonth current current-12 current-24
- balanceYear <YYYY> [current current-x <YYYY> <YYYY> <YYYY> ...]
Defines from which years the data provider "balanceYearData" delivers the data.
In the relative specification current-x, x is the number of years that are subtracted from the current year.
The years are separated by spaces, current = current year.
(default: current year)
Examples:
attr <name> balanceYear current 2019 2018 2017
attr <name> balanceYear current current-1 current-2
- cookieDelete
Defines the method of cookie management (deletion).
(default: auto)
auto - Cookie file is managed according to an internal procedure afterAttempt - Cookie file is deleted after each failed read attempt afterCycle - Cookie file is deleted after each read cycle (covers several attempts) afterRun - Cookie file is deleted after each pass of a data retrieval afterAttempt&Run - Cookie file is deleted after each failed read attempt and run through a data retrieval
- cookieLocation <Pfad/File>
The path and filename of received Cookies.
(default: ./log/<name>_cookie.txt)
Example:
attr <name> cookieLocation ./log/cookies.txt
- disable
Deactivate/activate the device.
- interval <seconds>
Time interval for continuous data retrieval from the aus dem SMA Sunny Portal (default: 300 seconds).
if the interval is set to "0", no continuous data retrieval is executed and has to be triggered manually by the
"get <name> data" command.
Note:
The retrieval interval must not be less than 180 seconds. As of previous experiences SMA suffers an interval of
120 seconds although the SMA terms and conditions don't permit an automatic data fetch by computer programs.
- noHomeManager
Must be set if no Sunny Home Manager is installed.
- plantLogbookApprovalState
With this attribute the entries are filtered according to their status.
(default: Any)
Any - all messages NotApproved - unconfirmed messages
- plantLogbookTypes
This attribute defines the message types of the asset logbook to be selected.
A maximum of the latest 25 logbook entries of all set types are displayed.
(default: Warning,Disturbance,Error)
- providerLevel
The scope of the data to be generated is set. Asset and consumer master data is always retrieved.
liveData - generates readings of the current generation and consumption data weatherData - Weather data offered by SMA are retrieved forecastData - Forecast data of generation/consumption and consumer planning data are generated (an SMA Home Manager must be available) consumerCurrentdata - current consumer data are generated consumerDayData - consumer data day are generated consumerMonthData - consumer data month are generated consumerYearData - consumer data year are generated plantLogbook - the maximum of 25 most recent entries of the plant logbook are retrieved balanceDayData - Statistics data of the day are retrieved (see attribute balanceDay) balanceMonthData - Statistics data of the month are retrieved (see attribute balanceMonth) balanceYearData - Statistical data of the year are retrieved (see attribute balanceYear) balanceTotalData - Total statistics data are retrieved
- showPassInLog
If set, the used password will be displayed in Logfile output.
(default: 0)
- userAgent <identifier>
An user agent identifier for identifikation against the SMA Sunny Portal can be specified.
Example:
attr <name> userAgent Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:65.0) Gecko/20100101 Firefox/65.0
- useRelativeNames
When using relative dates current-x (see balance.* attributes) the created reading name contains
also the relative instead of the real date.
(default: real date)
- verbose5Data
The attribute value verbose 5 is used to generate very large amounts of data.
The verbose 5 outputs of interest can be selected specifically.
(default: none)
=end html
=begin html_DE
SMAPortal
Mit diesem Modul können Daten aus dem SMA Sunny Portal abgerufen und die am SMA
Home Manager bzw. im SMA Portal registrierten Geräte gesteuert werden.
- Live-Daten (Verbrauch und PV-Erzeugung)
- verschiedene Bilanzdaten und Statistikdaten (auch der an den SMA Sunny Homemanager angeschlossenen Verbraucher)
- Batteriedaten (In/Out) sowie Nutzungsdaten durch Verbraucher
- Wetter-Daten von SMA für den Anlagenstandort
- Prognosedaten (Verbrauch und PV-Erzeugung) inklusive Verbraucherempfehlung
- die durch den Sunny Home Manager geplanten Schaltzeiten und aktuellen Status von Verbrauchern (sofern vorhanden)
- Steuerung von am SMA Home Manager bzw. SMA Portal registrierten Geräten
Die Portalgrafik kann ebenfalls in FHEM Tablet UI mit dem
"SMAPortalSPG Widget" integriert werden.
Vorbereitung
Dieses Modul nutzt das Perl-Modul JSON welches üblicherweise nachinstalliert werden muss.
Auf Debian-Linux basierenden Systemen kann es installiert werden mit:
sudo apt-get install libjson-perl
Überblick über die Perl-Module welche von SMAPortal genutzt werden:
POSIX
JSON
Data::Dumper
Time::HiRes
Time::Local
Blocking (FHEM-Modul)
GPUtils (FHEM-Modul)
FHEM::Meta (FHEM-Modul)
LWP::UserAgent
HTTP::Cookies
MIME::Base64
Encode
utf8
Definition
Ein SMAPortal-Device wird definiert mit:
define <Name> SMAPortal
Nach der Definition des Devices müssen die Zugangsparameter für das SMA Sunny Portal gespeichert werden
mit dem Befehl:
set <Name> credentials <Username> <Passwort>
Nach einem erfolgreichen Login werden nur die Anlagenstammdaten abgerufen.
Mit dem Attribut providerLevel werden die Datenlieferanten eingestellt, die durch das
Device abgerufen werden sollen. Ist kein Sunny Home Manager installiert, muss das Attribut
noHomeManager gesetzt werden.
Set
- createPortalGraphic <Generation | Consumption | Generation_Consumption | Differential>
Erstellt Devices zur grafischen Anzeige der SMA Sunny Portal Prognosedaten in verschiedenen Layouts.
Das Attribut "providerLevel" muss auf den Level "forecastData" enthalten.
Mit den "Attributen des Grafikdevices" können Erscheinungsbild und
Farbgebung der Prognosedaten in den erstellten Grafik-Devices angepasst werden.
- getData
Identisch zum "get data" Befehl. Vereinfacht die Benutzung des Attributs "webCmd" im FHEMWEB.
- <Verbrauchername> <on | off | auto | GC>
Es werden die an den SMA Sunny Homemanager angeschlossene Verbraucher angeboten sobald sie vom
Modul erkannt wurden. Es werden verschiedene Arten von Verbrauchern durch das Modul erkannt und auf den Verbrauchertyp
angepasste Aktionen angeboten.
SMA Bluetoth Steckdosen on einschalten, off ausschalten, auto Steuerung durch den Sunny Home Manager SMA EV Charger GC Anteil des Netzbezugs in Prozent, der für das Laden des E-Fahrzeugs akzeptiert werden soll (0..100)
Get
Attribute
- balanceDay <YYYY-MM-DD> [current current-x <YYYY-MM-DD> <YYYY-MM-DD> ...]
Legt fest, von welchen Tagen der Datenprovider "balanceDayData" die Daten liefert.
In der Relativangabe current-x ist x die Anzahl Tage die vom aktuellen Tag subtrahiert werden.
Die Tagesangaben werden durch Leerzeichen getrennt, current = aktueller Tag.
(default: aktueller Tag)
Beispiele:
attr <name> balanceDay current 2020-08-07 2020-08-06 2020-08-05
attr <name> balanceDay current current-1 current-2
- balanceMonth <YYYY-MM> [current current-x <YYYY-MM> <YYYY-MM> ...]
Legt fest, von welchen Monaten der Datenprovider "balanceMonthData" die Daten liefert.
In der Relativangabe current-x ist x die Anzahl Monate die vom aktuellen Monat subtrahiert werden.
Die Monatsangaben werden durch Leerzeichen getrennt, current = aktueller Monat.
(default: aktueller Monat)
Beispiele:
attr <name> balanceMonth current 2019-07 2019-06 2019-05
attr <name> balanceMonth current current-12 current-24
- balanceYear <YYYY> [current current-x <YYYY> <YYYY> <YYYY> ...]
Legt fest, von welchen Jahren der Datenprovider "balanceYearData" die Daten liefert.
In der Relativangabe current-x ist x die Anzahl Jahre die vom aktuellen Jahr subtrahiert werden.
Die Jahresangaben werden durch Leerzeichen getrennt, current = aktuelles Jahr.
(default: aktuelles Jahr)
Beispiele:
attr <name> balanceYear current 2019 2018 2017
attr <name> balanceYear current current-1 current-2
- cookieDelete
Legt die Methode der Cookie Verwaltung (Löschung) fest.
(default: auto)
auto - Cookie File wird nach einem internen Verfahren verwaltet afterAttempt - Cookie File wird nach jedem fehlerhaften Leseversuch gelöscht afterCycle - Cookie File wird nach jedem Lesezyklus gelöscht (umfasst mehrere Versuche) afterRun - Cookie File wird nach jedem Durchlauf eines Datenabrufs gelöscht afterAttempt&Run - Cookie File wird nach jedem fehlerhaften Leseversuch und Durchlauf eines Datenabrufs gelöscht
- cookieLocation <Pfad/File>
Angabe von Pfad und Datei zur Abspeicherung des empfangenen Cookies.
(default: ./log/<name>_cookie.txt)
Beispiel:
attr <name> cookieLocation ./log/cookies.txt
- disable
Deaktiviert das Device.
- interval <Sekunden>
Zeitintervall zum kontinuierlichen Datenabruf aus dem SMA Sunny Portal (Default: 300 Sekunden).
Ist interval explizit auf "0" gesetzt, erfolgt kein automatischer Datenabruf und muss mit "get <name> data" manuell
erfolgen.
Hinweis:
Das Abfrageintervall darf nicht kleiner 180 Sekunden sein. Nach bisherigen Erfahrungen toleriert SMA ein
Intervall von 180 Sekunden obwohl lt. SMA AGB der automatische Datenabruf untersagt ist.
- noHomeManager
Muss gesetzt werden wenn kein Sunny Home Manager installiert ist.
- plantLogbookApprovalState
Mit diesem Attribut werden die Einträge entsprechend ihres Status gefiltert.
(default: Any)
Any - alle Mitteilungen NotApproved - nicht bestätigte Mitteilungen
- plantLogbookTypes
Mit diesem Attribut werden die zu selektierenden Mitteilungstypen des Anlagenlogbuchs festgelegt.
Es werden maximal die aktuellsten 25 Logbucheinträge aller eingestellten Typen angezeigt.
(default: Warning,Disturbance,Error)
- providerLevel
Es wird der Umfang der zu generierenden Daten eingestellt. Anlagen- und Verbraucherstammdaten werden immer abgerufen.
liveData - erzeugt Readings der aktuellen Erzeugungs- und Verbrauchsdaten weatherData - von SMA angebotene Wetterdaten werden abgerufen forecastData - Vorhersagedaten der Erzeugung / Verbrauch und Verbraucherplanungsdaten werden erzeugt (ein SMA Home Manager muss vorhanden sein) consumerCurrentdata - aktuelle Verbraucherdaten werden erzeugt consumerDayData - Verbraucherdaten Tag werden erzeugt consumerMonthData - Verbraucherdaten Monat werden erzeugt consumerYearData - Verbraucherdaten Jahr werden erzeugt plantLogbook - die maximal 25 aktuellsten Einträge des Anlagenlogbuchs werden abgerufen balanceDayData - Statistikdaten des Tages werden abgerufen (siehe Attribut balanceDay) balanceMonthData - Statistikdaten des Monats werden abgerufen (siehe Attribut balanceMonth) balanceYearData - Statistikdaten des Jahres werden abgerufen (siehe Attribut balanceYear) balanceTotalData - Statistikdaten Gesamt werden abgerufen
- showPassInLog
Wenn gesetzt, wird das verwendete Passwort im Logfile angezeigt.
(default: 0)
- userAgent <Kennung>
Es kann die User-Agent-Kennung zur Identifikation gegenüber dem SMA Sunny Portal angegeben werden.
Beispiel:
attr <name> userAgent Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:65.0) Gecko/20100101 Firefox/65.0
- useRelativeNames
Bei Verwendung von relativen Datumangaben current-x (siehe balance.*-Attribute) enthält der erstellte Readingname
ebenfalls die relative anstatt der realen Datumangabe.
(default: reale Datumangabe)
- verbose5Data
Mit dem Attributwert verbose 5 werden sehr große Datenmengen generiert.
Es können gezielt die interessierenden verbose 5 Ausgaben selektiert werden.
(default: none)
=end html_DE
=for :application/json;q=META.json 76_SMAPortal.pm
{
"abstract": "Module for communication with the SMA Sunny Portal",
"x_lang": {
"de": {
"abstract": "Modul zur Kommunikation mit dem SMA Sunny Portal"
}
},
"keywords": [
"sma",
"photovoltaik",
"electricity",
"portal",
"smaportal"
],
"version": "v1.1.1",
"release_status": "stable",
"author": [
"Heiko Maaz ",
"Wzut",
"XGuide",
null
],
"x_fhem_maintainer": [
"DS_Starter"
],
"x_fhem_maintainer_github": [
"nasseeder1"
],
"prereqs": {
"runtime": {
"requires": {
"FHEM": 5.00918799,
"perl": 5.014,
"JSON": 0,
"Encode": 0,
"POSIX": 0,
"Data::Dumper": 0,
"Blocking": 0,
"GPUtils": 0,
"Time::HiRes": 0,
"Time::Local": 0,
"LWP": 0,
"HTTP::Cookies": 0,
"MIME::Base64": 0,
"utf8": 0
},
"recommends": {
"FHEM::Meta": 0
},
"suggests": {
}
}
}
}
=end :application/json;q=META.json
=cut
$val}; } if($live->{WarningMessages}[0]) { my @wm; $warnMsg = 1; for my $a (@{$live->{WarningMessages}}) { push @wm, encode ("utf8", $a); } $val = join " ", @wm if(@wm); push @$daref, "${lv}_WarningMessages:".qq{$hm{$lang}
$val}; } if($live->{InfoMessages}[0]) { my @im; $infoMsg = 1; for my $a (@{$live->{InfoMessages}}) { push @im, encode ("utf8", $a); } $val = join " ", @im if(@im); push @$daref, "${lv}_InfoMessages:".qq{$hm{$lang}
$val}; } } BlockingInformParent("FHEM::SMAPortal::delReadingFromBlocking", [$name, "${lv}_ErrorMessages"] , 1) if(!$errMsg); BlockingInformParent("FHEM::SMAPortal::delReadingFromBlocking", [$name, "${lv}_WarningMessages"], 1) if(!$warnMsg); BlockingInformParent("FHEM::SMAPortal::delReadingFromBlocking", [$name, "${lv}_InfoMessages"] , 1) if(!$infoMsg); return; } ################################################################ ## Auswertung Forecast Daten ################################################################ sub extractForecastData { ## no critic 'complexity' my $hash = shift; my $daref = shift; my $forecast = shift; my $name = $hash->{NAME}; Log3 ($name, 4, "$name - ##### extracting forecast data #### "); $forecast = eval{decode_json($forecast)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data"); return; }; my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time); $year += 1900; $mon += 1; my $today = "$year-".sprintf("%02d", $mon)."-".sprintf("%02d", $mday)."T"; my $lv = $stpl{forecastData}{level}; my $PV_sum = 0; my $consum_sum = 0; my $sum = 0; # Counter for forecast objects my $obj_nr = 0; # The next few hours... my %nextFewHoursSum = ("PV" => 0, "Consumption" => 0, "Total" => 0, "ConsumpRcmd" => 0); # Rest of the day... my %restOfDaySum = ("PV" => 0, "Consumption" => 0, "Total" => 0, "ConsumpRcmd" => 0); # Tomorrow... my %tomorrowSum = ("PV" => 0, "Consumption" => 0, "Total" => 0, "ConsumpRcmd" => 0); # Get the current day (for 2016-02-26, this is 26) my $current_day = (localtime)[3]; # Loop through all forecast objects # Energie wird als "J" geliefert, Wh = J / 3600 for my $fc_obj (@{$forecast->{'ForecastSeries'}}) { my $fc_datetime = $fc_obj->{'TimeStamp'}->{'DateTime'}; # Example for DateTime: 2016-02-15T23:00:00 my $tkind = $fc_obj->{'TimeStamp'}->{'Kind'}; # Zeitart: Unspecified, Utc # Calculate Unix timestamp (month begins at 0, year at 1900) my ($fc_year, $fc_month, $fc_day, $fc_hour) = $fc_datetime =~ /^(\d\d\d\d)-(\d\d)-(\d\d)T(\d\d):00:00$/x; my $fc_uts = POSIX::mktime( 0, 0, $fc_hour, $fc_day, $fc_month - 1, $fc_year - 1900 ); my $fc_diff_seconds = $fc_uts - time + 3600; # So we go above 0 for the current hour my $fc_diff_hours = int( $fc_diff_seconds / 3600 ); # Use also old data to integrate daily PV and Consumption if ($current_day == $fc_day) { $PV_sum += int($fc_obj->{'PvMeanPower'}->{'Amount'}); # integrator of daily PV in Wh $consum_sum += int($fc_obj->{'ConsumptionForecast'}->{'Amount'}/3600); # integrator of daily Consumption forecast in Wh } # Don't use old data next if $fc_diff_seconds < 0; # Sum up for the next few hours (4 hours total, this is current hour plus the next 3 hours) if ($obj_nr < 4) { $nextFewHoursSum{'PV'} += $fc_obj->{'PvMeanPower'}->{'Amount'}; # Wh $nextFewHoursSum{'Consumption'} += $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh $nextFewHoursSum{'Total'} += $fc_obj->{'PvMeanPower'}->{'Amount'} - $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh $nextFewHoursSum{'ConsumpRcmd'} += $fc_obj->{'IsConsumptionRecommended'} ? 1 : 0; } # If data is for the rest of the current day if ( $current_day == $fc_day ) { $restOfDaySum{'PV'} += $fc_obj->{'PvMeanPower'}->{'Amount'}; # Wh $restOfDaySum{'Consumption'} += $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh $restOfDaySum{'Total'} += $fc_obj->{'PvMeanPower'}->{'Amount'} - $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh $restOfDaySum{'ConsumpRcmd'} += $fc_obj->{'IsConsumptionRecommended'} ? 1 : 0; } # If data is for the next day (quick and dirty: current day different from this object's day) # Assuming only the current day and the next day are returned from Sunny Portal if ( $current_day != $fc_day ) { $tomorrowSum{'PV'} += $fc_obj->{'PvMeanPower'}->{'Amount'} if(exists($fc_obj->{'PvMeanPower'}->{'Amount'})); # Wh $tomorrowSum{'Consumption'} += $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600; # Wh $tomorrowSum{'Total'} += $fc_obj->{'PvMeanPower'}->{'Amount'} - $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600 if ($fc_obj->{'PvMeanPower'}->{'Amount'}); # Wh $tomorrowSum{'ConsumpRcmd'} += $fc_obj->{'IsConsumptionRecommended'} ? 1 : 0; } # Update values in Fhem if less than 24 hours in the future # TimeStamp Kind: "Unspecified" if ($obj_nr < 24) { my $time_str = "ThisHour"; $time_str = "NextHour".sprintf("%02d", $obj_nr) if($fc_diff_hours>0); if($time_str =~ /NextHour/x) { push @$daref, "${lv}_${time_str}_Time:". TimeAdjust($hash,$fc_obj->{'TimeStamp'}->{'DateTime'},$tkind); push @$daref, "${lv}_${time_str}_PvMeanPower:". int( $fc_obj->{'PvMeanPower'}->{'Amount'} )." Wh"; # in W als Durchschnitt geliefet, d.h. eine Stunde -> Wh push @$daref, "${lv}_${time_str}_Consumption:". int( $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600 )." Wh"; # {'ConsumptionForecast'}->{'Amount'} wird als J = Ws geliefert push @$daref, "${lv}_${time_str}_IsConsumptionRecommended:". ($fc_obj->{'IsConsumptionRecommended'} ? "yes" : "no"); push @$daref, "${lv}_${time_str}_Total:". (int($fc_obj->{'PvMeanPower'}->{'Amount'}) - int($fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600))." Wh"; # add WeatherId Helper to show weather icon BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "${lv}_".${time_str}."_WeatherId:".int($fc_obj->{'WeatherId'}) ], 1) if(defined $fc_obj->{'WeatherId'}); } if($time_str =~ /ThisHour/x) { push @$daref, "${lv}_${time_str}_Time:". TimeAdjust($hash,$fc_obj->{'TimeStamp'}->{'DateTime'},$tkind); push @$daref, "${lv}_${time_str}_PvMeanPower:". int( $fc_obj->{'PvMeanPower'}->{'Amount'} )." Wh"; # in W als Durchschnitt geliefet, d.h. eine Stunde -> Wh push @$daref, "${lv}_${time_str}_Consumption:". int( $fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600 )." Wh"; # {'ConsumptionForecast'}->{'Amount'} wird als J = Ws geliefert push @$daref, "${lv}_${time_str}_IsConsumptionRecommended:". ($fc_obj->{'IsConsumptionRecommended'} ? "yes" : "no"); push @$daref, "${lv}_${time_str}_Total:". (int($fc_obj->{'PvMeanPower'}->{'Amount'}) - int($fc_obj->{'ConsumptionForecast'}->{'Amount'} / 3600))." Wh"; # add WeatherId Helper to show weather icon BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "${lv}_".${time_str}."_WeatherId:".int($fc_obj->{'WeatherId'}) ], 1) if(defined $fc_obj->{'WeatherId'}); } } # Increment object counter $obj_nr++; } push @$daref, "${lv}_Next04Hours_Consumption:". int( $nextFewHoursSum{'Consumption'} )." Wh"; push @$daref, "${lv}_Next04Hours_PV:". int( $nextFewHoursSum{'PV'} )." Wh"; push @$daref, "${lv}_Next04Hours_Total:". int( $nextFewHoursSum{'Total'} )." Wh"; push @$daref, "${lv}_Next04Hours_IsConsumptionRecommended:". int( $nextFewHoursSum{'ConsumpRcmd'} )." h"; push @$daref, "${lv}_ForecastToday_Consumption:". $consum_sum." Wh"; push @$daref, "${lv}_ForecastToday_PV:". $PV_sum." Wh"; push @$daref, "${lv}_RestOfDay_Consumption:". int( $restOfDaySum{'Consumption'} )." Wh"; push @$daref, "${lv}_RestOfDay_PV:". int( $restOfDaySum{'PV'} )." Wh"; push @$daref, "${lv}_RestOfDay_Total:". int( $restOfDaySum{'Total'} )." Wh"; push @$daref, "${lv}_RestOfDay_IsConsumptionRecommended:". int( $restOfDaySum{'ConsumpRcmd'} )." h"; push @$daref, "${lv}_Tomorrow_Consumption:". int( $tomorrowSum{'Consumption'} )." Wh"; push @$daref, "${lv}_Tomorrow_PV:". int( $tomorrowSum{'PV'} )." Wh"; push @$daref, "${lv}_Tomorrow_Total:". int( $tomorrowSum{'Total'} )." Wh"; push @$daref, "${lv}_Tomorrow_IsConsumptionRecommended:". int( $tomorrowSum{'ConsumpRcmd'} )." h"; return; } ################################################################ ## Auswertung Wetterdaten ################################################################ sub extractWeatherData { my $hash = shift; my $daref = shift; my $weather = shift; my $name = $hash->{NAME}; Log3 ($name, 4, "$name - ##### extracting weather data #### "); $weather = eval{decode_json($weather)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data"); return; }; my $lv = $stpl{weatherData}{level}; for my $k (keys %$weather) { next if(!$k); Log3 ($name, 4, qq{$name - Weatherdata content "$k": }.Dumper $weather->{$k}); if (ref $weather->{$k} eq "HASH") { my $ih = $weather->{$k}; my $day = $k; my $symbol = encode("utf8", $weather->{$k}{TemperatureSymbol}); my $temp = sprintf("%.1f", $weather->{$k}{Temperature}); my $wdesc = encode ("utf8", $weather->{$k}{WeatherDescription}); $wdesc =~ s/t/T/x if($wdesc =~ /^t/x); $day =~ s/t/T/x; push @$daref, "${lv}_${day}_Temperature:$temp $symbol"; push @$daref, "${lv}_${day}_WeatherDescription:$wdesc"; } } return; } ################################################################ # Auswertung Statistic Daten # $period = Day[_
$dn : $ts
$dc}; push @$daref, "${lv}_LogbookEntry_${id}:$v"; } } return; } ################################################################ ## Auswertung Consumer Plan Data (aus forecastData) ################################################################ sub extractConsumerPlanData { my $hash = shift; my $daref = shift; my $forecast = shift; my $name = $hash->{NAME}; my %consumers; my ($key,$val); Log3 ($name, 4, "$name - ##### extracting consumer plan data #### "); $forecast = eval{decode_json($forecast)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data"); return; }; my $lv = $stpl{forecastData}{level}; # Schleife über alle Consumer Objekte my $i = 0; for my $c (@{$forecast->{'Consumers'}}) { $consumers{"${i}_ConsumerName"} = $c->{'ConsumerName'}; $consumers{"${i}_ConsumerOid"} = $c->{'ConsumerOid'}; $i++; } if(%consumers && $forecast->{'ForecastTimeframes'}) { # es sind Vorhersagen zu geplanten Verbraucherschaltzeiten vorhanden # TimeFrameStart/End Kind: "Utc" for my $c (@{$forecast->{'ForecastTimeframes'}{'PlannedTimeFrames'}}) { my $tkind = $c->{'TimeFrameStart'}->{'Kind'}; # Zeitart: Unspecified, Utc my $deviceOid = $c->{'DeviceOid'}; my $timeFrameStart = TimeAdjust($hash,$c->{'TimeFrameStart'}{'DateTime'},$tkind); # wandele UTC my $timeFrameEnd = TimeAdjust($hash,$c->{'TimeFrameEnd'}{'DateTime'},$tkind); # wandele UTC my $tz = $c->{'TimeFrameStart'}{'Kind'}; for my $k (keys(%consumers)) { $val = $consumers{$k}; if($val eq $deviceOid && $k =~ /^(\d+)_.*$/x) { my $lfn = $1; $consumers{"${lfn}_PlannedOpTimeStart"} = $timeFrameStart; $consumers{"${lfn}_PlannedOpTimeEnd"} = $timeFrameEnd; } } } } if(%consumers) { for my $key (keys(%consumers)) { Log3 $name, 4, "$name - Consumer data \"$key\": ".encode("utf8", $consumers{$key}); if($key =~ /ConsumerName/x && $key =~ /^(\d+)_.*$/x) { my $lfn = $1; my $cn = $consumers{"${lfn}_ConsumerName"}; # Verbrauchername next if(!$cn); $cn = replaceJunkSigns($cn); # evtl. Umlaute/Leerzeichen im Verbrauchernamen ersetzen my $pos = $consumers{"${lfn}_PlannedOpTimeStart"}; # geplanter Start my $poe = $consumers{"${lfn}_PlannedOpTimeEnd"}; # geplantes Ende my $rb = "${lv}_${cn}_PlannedOpTimeBegin"; my $re = "${lv}_${cn}_PlannedOpTimeEnd"; my $rp = "${lv}_${cn}_Planned"; if($pos) { push @$daref, "$rb:$pos"; push @$daref, "$rp:yes"; } else { push @$daref, "$rb:undefined"; push @$daref, "$rp:no"; } if($poe) { push @$daref, "$re:$poe"; } else { push @$daref, "$re:undefined"; } } } } return; } ################################################################ ## Auswertung Consumer Stammdaten ################################################################ sub extractConsumerMasterdata { my $hash = shift; my $daref = shift; my $cdata = shift; my $name = $hash->{NAME}; my %consumers; my %hcon; my ($i,$res); Log3 ($name, 4, "$name - ##### extracting consumer master data #### "); $cdata = eval{decode_json($cdata)} or do { Log3 ($name, 4, "$name - No JSON Data were delivered from SMA. Possibly you haven't any consumer integrated."); return; }; my $lv = $stpl{consumerMasterdata}{level}; # allen Consumer Objekten die ID zuordnen $i = 0; for my $c (@{$cdata->{'MeasurementData'}}) { $consumers{"${i}_ConsumerName"} = $c->{'DeviceName'}; $consumers{"${i}_ConsumerOid"} = $c->{'Consume'}{'ConsumerOid'}; $consumers{"${i}_ConsumerLfd"} = $i; my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername next if(!$cn); $cn = replaceJunkSigns($cn); # Verbrauchername gemäß Readingreguarien anpassen $hcon{$i}{DeviceName} = $cn; $hcon{$i}{DeviceOrigName} = encode("utf8", $c->{'DeviceName'}); # der originale Verbrauchername $hcon{$i}{ConsumerOid} = $consumers{"${i}_ConsumerOid"}; $hcon{$i}{SerialNumber} = $c->{'SerialNumber'}; $hcon{$i}{SUSyID} = $c->{'SUSyID'}; $i++; } for my $key (keys %hcon) { for my $parname (keys %{$hcon{$key}}) { my $val = $hcon{$key}{$parname}; next if(!$val); Log3 ($name, 4, "$name - CONSUMER master data: $key -> $parname = $val"); BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "CONSUMER:$key:$parname:$val"], 1); } } return; } ################################################################ ## Auswertung Consumer Current Data ################################################################ sub extractConsumerCurrentdata { my $hash = shift; my $daref = shift; my $clivedata = shift; my $name = $hash->{NAME}; my %consumers; my ($i,$res); Log3 ($name, 4, "$name - ##### extracting consumer current data #### "); $clivedata = eval{decode_json($clivedata)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data"); return; }; my $lv = $stpl{consumerCurrentdata}{level}; # allen Consumer Objekten die ID zuordnen $i = 0; for my $c (@{$clivedata->{'MeasurementData'}}) { $consumers{"${i}_ConsumerName"} = $c->{'DeviceName'}; $consumers{"${i}_ConsumerOid"} = $c->{'Consume'}{'ConsumerOid'}; $consumers{"${i}_ConsumerLfd"} = $i; my $cpower = $c->{'Consume'}{'Measurement'}; # aktueller Energieverbrauch in W my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername next if(!$cn); $cn = replaceJunkSigns($cn); push @$daref, "${lv}_${cn}_Power:".$cpower." W" if(defined $cpower); $i++; } if(%consumers && $clivedata->{'ParameterData'}) { # es sind Daten zu den Verbrauchern vorhanden # Kind: "Utc" ? $i = 0; for my $c (@{$clivedata->{'ParameterData'}}) { my $tkind = $c->{'Parameters'}[0]{'Timestamp'}{'Kind'}; # Zeitart: Unspecified, Utc my $GriSwStt = $c->{'Parameters'}[0]{'Value'}; # on: 1, off: 0 my $GriSwAuto = $c->{'Parameters'}[1]{'Value'}; # automatic = 1 my $OperationAutoEna = $c->{'Parameters'}[2]{'Value'}; # Automatic Betrieb erlaubt ? my $ltchange = TimeAdjust($hash,$c->{'Parameters'}[0]{'Timestamp'}{'DateTime'},$tkind); # letzter Schaltzeitpunkt der Bluetooth-Steckdose (Verbraucher) my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername next if(!$cn); $cn = replaceJunkSigns($cn); # evtl. Umlaute/Leerzeichen im Verbrauchernamen ersetzen if(!$GriSwStt && $GriSwAuto) { $res = "off (automatic)"; } elsif (!$GriSwStt && !$GriSwAuto) { $res = "off"; } elsif ($GriSwStt) { $res = "on"; } else { $res = "undefined"; } push @$daref, "${lv}_${cn}_Switch:$res"; push @$daref, "${lv}_${cn}_SwitchLastTime:$ltchange"; $i++; } } return; } ################################################################ ## Auswertung Consumer History Energy Data ## $tf = Time Frame ################################################################ sub extractConsumerHistData { ## no critic 'complexity' my $hash = shift; my $daref = shift; my $chdata = shift; my $tf = shift; my $name = $hash->{NAME}; my %consumers; my ($i,$gcr,$gct,$pcr,$pct,$tct,$bcr,$bct); Log3 ($name, 4, "$name - ##### extracting consumer history data #### "); $chdata = eval{decode_json($chdata)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data"); return; }; my $livelvl = $stpl{liveData}{level}; my $bataval = (defined(ReadingsNum($name,"${livelvl}_BatteryIn", undef)) || defined(ReadingsNum($name,"${livelvl}_BatteryOut", undef)))?1:0; # Identifikation ist Battery vorhanden ? my $dlvl = $stpl{consumerDayData}{level}; my $mlvl = $stpl{consumerMonthData}{level}; my $ylvl = $stpl{consumerYearData}{level}; # allen Consumer Objekte die ID zuordnen $i = 0; for my $c (@{$chdata->{'Consumers'}}) { $consumers{"${i}_ConsumerName"} = $c->{'DeviceName'}; $consumers{"${i}_ConsumerOid"} = $c->{'ConsumerOid'}; $consumers{"${i}_ConsumerLfd"} = $i; my $cpower = $c->{'TotalEnergy'}{'Measurement'}; # Energieverbrauch im Timeframe in Wh my $cn = $consumers{"${i}_ConsumerName"}; # Verbrauchername next if(!$cn); $cn = replaceJunkSigns($cn); if($tf =~ /month|year/x) { $tct = $c->{'TotalEnergyMix'}{'TotalConsumptionTotal'}; # Gesamtverbrauch im Timeframe in Wh $gcr = $c->{'TotalEnergyMix'}{'GridConsumptionRelative'}; # Anteil des Netzbezugs im Timeframe am Gesamtverbrauch in % $gct = $c->{'TotalEnergyMix'}{'GridConsumptionTotal'}; # Anteil des Netzbezugs im Timeframe am Gesamtverbrauch in Wh $pcr = $c->{'TotalEnergyMix'}{'PvConsumptionRelative'}; # Anteil des PV-Nutzung im Timeframe am Gesamtverbrauch in % $pct = $c->{'TotalEnergyMix'}{'PvConsumptionTotal'}; # Anteil des PV-Nutzung im Timeframe am Gesamtverbrauch in Wh $bcr = $c->{'TotalEnergyMix'}{'BatteryConsumptionRelative'}; # Anteil der Batterie-Nutzung im Timeframe am Gesamtverbrauch in % $bct = $c->{'TotalEnergyMix'}{'BatteryConsumptionTotal'}; # Anteil der Batterie-Nutzung im Timeframe am Gesamtverbrauch in Wh } push @$daref, "${dlvl}_${cn}_EnergyTotalDay:". sprintf("%.0f", $cpower). " Wh" if(defined($cpower) && $tf eq "day"); push @$daref, "${mlvl}_${cn}_EnergyTotalMonth:". sprintf("%.0f", $cpower). " Wh" if(defined($cpower) && $tf eq "month"); push @$daref, "${ylvl}_${cn}_EnergyTotalYear:". sprintf("%.0f", $cpower). " Wh" if(defined($cpower) && $tf eq "year"); push @$daref, "${mlvl}_${cn}_EnergyRelativeMonthGrid:". sprintf("%.0f", $gcr). " %" if(defined($gcr) && $tf eq "month"); push @$daref, "${mlvl}_${cn}_EnergyTotalMonthGrid:". sprintf("%.0f", $gct). " Wh" if(defined($gct) && $tf eq "month"); push @$daref, "${mlvl}_${cn}_EnergyRelativeMonthPV:". sprintf("%.0f", $pcr). " %" if(defined($pcr) && $tf eq "month"); push @$daref, "${mlvl}_${cn}_EnergyTotalMonthPV:". sprintf("%.0f", $pct). " Wh" if(defined($pct) && $tf eq "month"); push @$daref, "${mlvl}_${cn}_EnergyRelativeMonthBatt:". sprintf("%.0f", $bcr). " %" if(defined($bcr) && $bataval && $tf eq "month"); push @$daref, "${mlvl}_${cn}_EnergyTotalMonthBatt:". sprintf("%.0f", $bct). " Wh" if(defined($bct) && $bataval && $tf eq "month"); push @$daref, "${ylvl}_${cn}_EnergyRelativeYearGrid:". sprintf("%.0f", $gcr). " %" if(defined($gcr) && $tf eq "year"); push @$daref, "${ylvl}_${cn}_EnergyTotalYearGrid:". sprintf("%.0f", $gct). " Wh" if(defined($gct) && $tf eq "year"); push @$daref, "${ylvl}_${cn}_EnergyRelativeYearPV:". sprintf("%.0f", $pcr). " %" if(defined($pcr) && $tf eq "year"); push @$daref, "${ylvl}_${cn}_EnergyTotalYearPV:". sprintf("%.0f", $pct). " Wh" if(defined($pct) && $tf eq "year"); push @$daref, "${ylvl}_${cn}_EnergyRelativeYearBatt:". sprintf("%.0f", $bcr). " %" if(defined($bcr) && $bataval && $tf eq "year"); push @$daref, "${ylvl}_${cn}_EnergyTotalYearBatt:". sprintf("%.0f", $bct). " Wh" if(defined($bct) && $bataval && $tf eq "year"); $i++; } return; } ################################################################ # Auswertung Ergebnis aus Switch Consumer ################################################################ sub extractSwitchConsumerData { my $paref = shift; my $hash = $paref->{hash}; my $daref = $paref->{daref}; # Referenz zum Datenarray my $data_cont = $paref->{data_cont}; # Daten decoded Content my $data = $paref->{data}; # empfangene Rohdaten my $addon = $paref->{addon}; # ein optionales AddOn my $tag = $paref->{tag}; # Kennzeichen der abgerufenen Daten/ der Abrufroutine my $name = $hash->{NAME}; Log3 ($name, 4, "$name - extracting Switch Consumer result "); my ($d,$susyid,$op) = split(":",$addon); # $op -> Verbraucher Manage Operation Log3 ($name, 3, qq{$name - Set "$d $op" result: $data_cont}); my $state; if($data_cont eq "true") { $state = "ok - switched consumer $d to $op"; BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "GETTER:all" ], 1); BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "SETTER:none"], 1); my $cclv = $stpl{consumerCurrentdata}{level}; $op = ($op eq "auto") ? "off (automatic)" : $op; push @$daref, "${cclv}_${d}_Switch:$op"; } else { $state = "ERROR - couldn't switch consumer $d to $op"; } return $state; } ################################################################ # Auswertung Ergebnis aus Manage Consumer # By Energy ################################################################ sub extractManageConsumerByEnergy { my $paref = shift; my $hash = $paref->{hash}; my $ua = $paref->{ua}; # LWP Useragent my $daref = $paref->{daref}; # Referenz zum Datenarray my $data_cont = $paref->{data_cont}; # Daten decoded Content my $data = $paref->{data}; # empfangene Rohdaten my $addon = $paref->{addon}; # ein optionales AddOn my $tag = $paref->{tag}; # Kennzeichen der abgerufenen Daten/ der Abrufroutine my $name = $hash->{NAME}; my ($errstate,$reread,$retry) = (0,0,0); Log3 ($name, 4, "$name - extracting manage Consumer by energy result "); my $rescode = $data->code; # HTML Code der Antwort (sollte 302 sein bei Erfolg) my ($d,$susyid,$op) = split(":",$addon); # $op -> eingestellter Gridconsomption Schwellenwert my $pvlog = 100-$op; my $state; if($rescode == 302) { my $location = $data->header('Location'); $state = qq{ok - Consumer "$d" set to condition: switch on if GridConsumption=$op% (PV=$pvlog%) is fulfilled}; Log3 ($name, 3, qq{$name - $state}); Log3 ($name, 3, qq{$name - next step: GET "$location" to read the new values are set }); BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "GETTER:all" ], 1); BlockingInformParent("FHEM::SMAPortal::setFromBlocking", [$name, "NULL", "SETTER:none"], 1); for my $key (keys %{$hash->{HELPER}{CONSUMER}}) { my $h = $hash->{HELPER}{CONSUMER}{$key}{DeviceName}; if($h && $h eq $d) { $paref->{oid} = $hash->{HELPER}{CONSUMER}{$key}{ConsumerOid}; } } $paref->{name} = $name; $paref->{state} = $state; $paref->{addon} = "$d:noJSONdata"; # das gemanagte Device in addon mitgeben ($errstate,$state,$reread,$retry) = _getConsumerEnergySetting ($paref); } else { $state = qq{ERROR - couldn't set Consumer "$d" set to condition: switch on if GridConsumption=$op% (PV=$pvlog%)}; } return $state; } ################################################################ # Abruf der aktuell eingestellten Energy Management Settings # von Verbrauchern des Typs 315 (z.B. SMA EV Charger) ################################################################ sub extractConsumerEnergySetting { my $hash = shift; my $daref = shift; my $data_cont = shift; # gelieferter data content my $addon = shift; my $data = shift; # gelieferte Rohdaten my $name = $hash->{NAME}; my ($errstate,$reread,$retry) = (0,0,0); Log3 ($name, 4, "$name - extracting current Consumer energy settings "); my ($d) = split ":", $addon; my $cclv = $stpl{consumerCurrentdata}{level}; my $dcont = encode("utf8", $data->decoded_content); my ($gcval) = $dcont =~ /var\sgridConsumptionValue\s=\s(.*?);/x; my ($pvval) = $dcont =~ /var\spvValue\s=\s(.*?);/x; $gcval = sprintf("%.2f",$gcval) * 100; $pvval = sprintf("%.2f",$pvval) * 100; push @$daref, "${cclv}_${d}_SwitchCondition:GridConsumption=$gcval% PV=$pvval%"; return; } ################################################################ # Auswertung Daten aus Hilfsroutinen ################################################################ sub extractHelperData { my $paref = shift; my $hash = $paref->{hash}; my $daref = $paref->{daref}; # Referenz zum Datenarray my $data_cont = $paref->{data_cont}; # Daten decoded Content my $data = $paref->{data}; # empfangene Rohdaten my $addon = $paref->{addon}; # ein optionales AddOn my $tag = $paref->{tag}; # Kennzeichen der abgerufenen Daten/ der Abrufroutine my $name = $hash->{NAME}; my $sd; Log3 ($name, 4, "$name - extracting Helper data "); my $decd = eval{decode_json($data_cont)} or do { Log3 ($name, 2, "$name - ERROR - can't decode JSON Data"); return; }; if(ref $decd eq "HASH") { while (my ($k,$v) = each %$decd) { push @$daref, "$tag:$v"; } } return; } ################################################################ # sortiert eine Liste von Versionsnummern x.x.x # Schwartzian Transform and the GRT transform # Übergabe: "asc | desc",
| "; if(!$hash) { ## no critic "Cascading" $ret .= "Device \"$name\" doesn't exist !"; } elsif (!defined($defs{$wlname})) { $ret .= "Graphic device \"$wlname\" doesn't exist !"; } elsif (!$fdo) { $ret .= qq{The attribute "providerLevel" of device "$name" must contain the level "forecastData" and data must be retrieved !}; } elsif (!defined $pv0) { $ret .= "Awaiting minor level forecast data ..."; } elsif (!defined $pv1) { $ret .= "Awaiting major level forecast data ..."; } $ret .= " | "; $ret .= "
";
if($swstate eq "off") {
$swicon = "";
}
elsif ($swstate eq "on") {
$swicon = "";
}
elsif ($swstate =~ /off.*automatic.*/ix) {
$swicon = "";
}
if ($legend_style eq 'icon') { # mögliche Umbruchstellen mit normalen Blanks vorsehen !
$legend_txt .= $txt.' '.FW_makeImage($im).' '.$swicon.' ';
}
else {
my (undef,$co) = split('\@',$im);
$co = '#cccccc' if (!$co); # Farbe per default
$legend_txt .= ''.$txt.' '.$swicon.' '; # hier auch Umbruch erlauben
}
}
}
# Parameter f. Anzeige extrahieren
$maxhours = AttrNum($wlname, 'hourCount', 24);
$hourstyle = AttrVal($wlname, 'hourStyle', undef);
$colorv = AttrVal($wlname, 'beamColor', undef);
$colorc = AttrVal($wlname, 'beamColor2', '000000'); # schwarz wenn keine Userauswahl;
$icon = AttrVal($wlname, 'consumerAdviceIcon', undef);
$html_start = AttrVal($wlname, 'htmlStart', undef); # beliebige HTML Strings die vor der Grafik ausgegeben werden
$html_end = AttrVal($wlname, 'htmlEnd', undef); # beliebige HTML Strings die nach der Grafik ausgegeben werden
$type = AttrVal($wlname, 'layoutType', 'pv');
$kw = AttrVal($wlname, 'Wh/kWh', 'Wh');
$height = AttrNum($wlname, 'beamHeight', 200);
$width = AttrNum($wlname, 'beamWidth', 6); # zu klein ist nicht problematisch
$w = $width*$maxhours; # gesammte Breite der Ausgabe , WetterIcon braucht ca. 34px
$fsize = AttrNum($wlname, 'spaceSize', 24);
$maxVal = AttrNum($wlname, 'maxPV', 0); # dyn. Anpassung der Balkenhöhe oder statisch ?
$show_night = AttrNum($wlname, 'showNight', 0); # alle Balken (Spalten) anzeigen ?
$show_diff = AttrVal($wlname, 'showDiff', 'no'); # zusätzliche Anzeige $di{} in allen Typen
$weather = AttrNum($wlname, 'showWeather', 1);
$colorw = AttrVal($wlname, 'weatherColor', undef);
$wlalias = AttrVal($wlname, 'alias', $wlname);
$header = AttrNum($wlname, 'showHeader', 1);
$hdrAlign = AttrVal($wlname, 'headerAlignment', 'center'); # ermöglicht per attr die Ausrichtung der Tabelle zu setzen
$hdrDetail = AttrVal($wlname, 'headerDetail', 'all'); # ermöglicht den Inhalt zu begrenzen, um bspw. passgenau in ftui einzubetten
# Icon Erstellung, mit @| ".$dlink." | (".$lupt." ".$lup.") ".$upicon." | |||||||
| PV => | "; $header .= "$lblPvCu | $pvCu | " if($subs{$name}{liveData}{doit}); $header .= "$lblPv4h | $pv4h | "; $header .= "$lblPvRe | $pvRe | "; $header .= "$lblPvTo | $pvTo | "; $header .= "
| CO => | "; $header .= "$lblPvCu | $coCu | " if($subs{$name}{liveData}{doit}); $header .= "$lblPv4h | $co4h | "; $header .= "$lblPvRe | $coRe | "; $header .= "$lblPvTo | $coTo | "; $header .= "
";
$ret .= "\n
|