marko/easee
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

added some historic data

Browse Source
This commit is contained in:
Matthias Sandmann 2022-03-20 00:03:46 +01:00
parent 4f7350cc3e
commit a6a6105a6e
1 changed files with 52 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
98_EaseeWallbox.pm
View File

@ -83,6 +83,7 @@ BEGIN {
readingsEndUpdate readingsEndUpdate
readingsBulkUpdate readingsBulkUpdate
readingsSingleUpdate readingsSingleUpdate
readingsDelete
InternalVal InternalVal
ReadingsVal ReadingsVal
RemoveInternalTimer RemoveInternalTimer
@ -502,6 +503,8 @@ sub RefreshData{
WriteToCloudAPI($hash, 'getChargerSite', 'GET'); WriteToCloudAPI($hash, 'getChargerSite', 'GET');
WriteToCloudAPI($hash, 'getChargerState', 'GET'); WriteToCloudAPI($hash, 'getChargerState', 'GET');
WriteToCloudAPI($hash, 'getCurrentSession', 'GET'); WriteToCloudAPI($hash, 'getCurrentSession', 'GET');
WriteToCloudAPI($hash, 'getChargerSessionsMonthly', 'GET');
WriteToCloudAPI($hash, 'getChargerSessionsDaily', 'GET');
} }
sub UpdateDueToTimer($) { sub UpdateDueToTimer($) {
@ -606,6 +609,19 @@ sub ResponseHandling {
} }
my $code = $param->{code}; my $code = $param->{code};
if ($code eq 404 and $param->{dpoint} eq 'getCurrentSession'){
readingsDelete($hash, 'session_energy' );
readingsDelete($hash, 'session_start' );
readingsDelete($hash, 'session_end' );
readingsDelete($hash, 'session_chargeDurationInSeconds' );
readingsDelete($hash, 'session_firstEnergyTransfer' );
readingsDelete($hash, 'session_lastEnergyTransfer' );
readingsDelete($hash, 'session_pricePerKWH' );
readingsDelete($hash, 'session_chargingCost' );
readingsDelete($hash, 'session_id' );
return undef;
}
if ($code >= 400){ if ($code >= 400){
Log3 $name, 3,"HTTPS error while requesting ". $param->{url}. " - $code"; # Eintrag fürs Log Log3 $name, 3,"HTTPS error while requesting ". $param->{url}. " - $code"; # Eintrag fürs Log
readingsSingleUpdate( $hash, "lastResponse", "ERROR: HTTP Code $code", 1 ); readingsSingleUpdate( $hash, "lastResponse", "ERROR: HTTP Code $code", 1 );
@ -629,12 +645,11 @@ sub ResponseHandling {
my $d = decode_json($data); my $d = decode_json($data);
Log3 $name, 5, 'Decoded: ' . Dumper($d); Log3 $name, 5, 'Decoded: ' . Dumper($d);
Log3 $name, 5, 'Ref of d: ' . ref($d); Log3 $name, 5, 'Ref of d: ' . ref($d);
$d = $d->[0] if ref($d) eq "ARRAY";
if ( defined $d and $d ne '' and ref($d) eq "HASH") {
if ( defined $d and $d ne '' and ref($d) eq "HASH" or (ref($d) eq "ARRAY" and $d gt 0)) {
if($param->{dpoint} eq 'getChargers') if($param->{dpoint} eq 'getChargers')
{ {
my $site = $d; my $site = $d->[0];
my $circuit = $site->{circuits}->[0]; my $circuit = $site->{circuits}->[0];
my $charger = $circuit->{chargers}->[0]; my $charger = $circuit->{chargers}->[0];
@ -650,6 +665,37 @@ sub ResponseHandling {
return; return;
} }
if($param->{dpoint} eq 'getChargerSessionsDaily')
{
Log3 $name, 5, 'Evaluating getChargerSessionsDaily';
my @x = $d;
my @a = (-5..-1);
readingsBeginUpdate($hash);
for(@a){
Log3 $name, 5, 'laeuft noch: '. $_;
readingsBulkUpdate( $hash, "daily_".($_ +1)."_energy", sprintf("%.2f",$d->[$_]->{'totalEnergyUsage'}) );
readingsBulkUpdate( $hash, "daily_".($_ +1)."_cost", sprintf("%.2f",$d->[$_]->{'totalCost'}) );
}
readingsEndUpdate( $hash, 1 );
return;
}
if($param->{dpoint} eq 'getChargerSessionsMonthly')
{
Log3 $name, 5, 'Evaluating getChargerSessionsMonthly';
my @x = $d;
my @a = (-6..-1);
readingsBeginUpdate($hash);
for(@a){
Log3 $name, 5, 'laeuft noch: '. $_;
readingsBulkUpdate( $hash, "monthly_".($_ +1)."_energy", sprintf("%.2f",$d->[$_]->{'totalEnergyUsage'}) );
readingsBulkUpdate( $hash, "monthly_".($_ +1)."_cost", sprintf("%.2f",$d->[$_]->{'totalCost'}) );
}
readingsEndUpdate( $hash, 1 );
return;
}
if($param->{dpoint} eq 'getChargerConfiguration') if($param->{dpoint} eq 'getChargerConfiguration')
{ {
readingsBeginUpdate($hash); readingsBeginUpdate($hash);
@ -766,6 +812,8 @@ sub ResponseHandling {
readingsEndUpdate( $hash, 1 ); readingsEndUpdate( $hash, 1 );
return undef; return undef;
} }
$d = $d->[0] if ref($d) eq "ARRAY";
readingsSingleUpdate( $hash, "lastResponse", 'OK - Action: '. $commandCodes{$d->{commandId}}, 1 ) if defined $d->{commandId}; readingsSingleUpdate( $hash, "lastResponse", 'OK - Action: '. $commandCodes{$d->{commandId}}, 1 ) if defined $d->{commandId};
readingsSingleUpdate( $hash, "lastResponse", 'ERROR: '. $d->{title}.' ('.$d->{status}.')', 1 ) if defined $d->{status} and defined $d->{title}; readingsSingleUpdate( $hash, "lastResponse", 'ERROR: '. $d->{title}.' ('.$d->{status}.')', 1 ) if defined $d->{status} and defined $d->{title};
return undef; return undef;
@ -774,6 +822,7 @@ sub ResponseHandling {
return undef; return undef;
} }
}; };
if ($@) { if ($@) {
readingsSingleUpdate( $hash, "lastResponse", 'ERROR while deconding response: '. $@, 1 ); readingsSingleUpdate( $hash, "lastResponse", 'ERROR while deconding response: '. $@, 1 );
Log3 $name, 5, 'Failure decoding: ' . $@; Log3 $name, 5, 'Failure decoding: ' . $@;