mirror of
https://github.com/fhem/fhem-mirror.git
synced 2025-01-31 12:49:34 +00:00
856ce5a4fa
attribute, which is available from now on for all devices. git-svn-id: https://svn.fhem.de/fhem/trunk@3738 2b470e98-0d58-463d-a4d8-8e2adae1ed80
259 lines
7.3 KiB
Perl
259 lines
7.3 KiB
Perl
##############################################
|
|
# $Id$
|
|
# Avarage computing
|
|
|
|
package main;
|
|
use strict;
|
|
use warnings;
|
|
|
|
##########################
|
|
sub
|
|
average_Initialize($)
|
|
{
|
|
my ($hash) = @_;
|
|
$hash->{DefFn} = "average_Define";
|
|
$hash->{NotifyFn} = "average_Notify";
|
|
$hash->{NotifyOrderPrefix} = "10-"; # Want to be called before the rest
|
|
$hash->{AttrList} = "disable:0,1";
|
|
}
|
|
|
|
|
|
##########################
|
|
sub
|
|
average_Define($$$)
|
|
{
|
|
my ($hash, $def) = @_;
|
|
my ($name, $type, $re, $rest) = split("[ \t]+", $def, 4);
|
|
|
|
if(!$re || $rest) {
|
|
my $msg = "wrong syntax: define <name> average device[:event]";
|
|
return $msg;
|
|
}
|
|
|
|
# Checking for misleading regexps
|
|
eval { "Hallo" =~ m/^$re$/ };
|
|
return "Bad regexp: $@" if($@);
|
|
$hash->{REGEXP} = $re;
|
|
$hash->{STATE} = "active";
|
|
return undef;
|
|
}
|
|
|
|
##########################
|
|
sub
|
|
average_Notify($$)
|
|
{
|
|
my ($avg, $dev) = @_;
|
|
my $avgName = $avg->{NAME};
|
|
|
|
return "" if(AttrVal($avgName, "disable", undef));
|
|
|
|
my $devName = $dev->{NAME};
|
|
my $re = $avg->{REGEXP};
|
|
my $max = int(@{$dev->{CHANGED}});
|
|
my $tn;
|
|
my $myIdx = $max;
|
|
|
|
for (my $i = 0; $i < $max; $i++) {
|
|
my $s = $dev->{CHANGED}[$i];
|
|
|
|
################
|
|
# Filtering
|
|
next if(!defined($s));
|
|
my ($evName, $val) = split(" ", $s, 2); # resets $1
|
|
# Log3 $avgName, 1,"mytestavg pre-filter: ".$devName.$evName." s=".$s;
|
|
next if($devName !~ m/^$re$/ && "$devName:$s" !~ m/^$re$/ || $s =~ m/_avg_/);
|
|
if(defined($1)) {
|
|
my $reArg = $1;
|
|
if(defined($2)) {
|
|
$evName = $1;
|
|
$reArg = $2;
|
|
}
|
|
$val = $reArg if(defined($reArg) && $reArg =~ m/^(-?\d+\.?\d*)/);
|
|
}
|
|
next if(!defined($val) || $val !~ m/^(-?\d+\.?\d*)/);
|
|
$val = $1;
|
|
|
|
# Log3 $avgName, 1,"mytestavg pst-filter: ".$devName.$evName." val=".$val;
|
|
|
|
################
|
|
# Avg computing
|
|
$evName =~ s/[^A-Za-z_-].*//;
|
|
$tn = TimeNow() if(!$tn);
|
|
|
|
my $r = $dev->{READINGS};
|
|
my @dNow = split("[ :-]", $tn);
|
|
|
|
for(my $idx = 0; $idx <= 1; $idx++) {
|
|
|
|
my $secNow = 3600*$dNow[3] + 60*$dNow[4] + $dNow[5];
|
|
$secNow += $dNow[2]*86400 if($idx);
|
|
|
|
my $cumName = "${evName}_cum_" . ($idx ? "month" : "day");
|
|
my $avgName = "${evName}_avg_" . ($idx ? "month" : "day");
|
|
my $minName = "${evName}_min_" . ($idx ? "month" : "day"); ##MH
|
|
my $maxName = "${evName}_max_" . ($idx ? "month" : "day"); ##MH
|
|
|
|
if(!$r->{$cumName}) {
|
|
$r->{$cumName}{VAL} = $secNow*$val;
|
|
$r->{$avgName}{VAL} = $val;
|
|
$r->{$maxName}{VAL} = $val; ##MH
|
|
$r->{$minName}{VAL} = $val; ##MH
|
|
$r->{$cumName}{TIME} = $r->{$avgName}{TIME} = $tn;
|
|
next;
|
|
}
|
|
|
|
##MH take care of existing average definitions - just add this one..
|
|
if(!$r->{$maxName}) {
|
|
$r->{$maxName}{VAL} = $val;
|
|
$r->{$maxName}{TIME} = $tn;
|
|
}
|
|
##MH take care of existing average definitions - just add this one..
|
|
if(!$r->{$minName}) {
|
|
$r->{$minName}{VAL} = $val;
|
|
$r->{$minName}{TIME} = $tn;
|
|
}
|
|
|
|
my @dLast = split("[ :-]", $r->{$cumName}{TIME});
|
|
my $secLast = 3600*$dLast[3] + 60*$dLast[4] + $dLast[5];
|
|
$secLast += $dLast[2]*86400 if($idx);
|
|
|
|
if($idx == 0 && ($dLast[2] == $dNow[2]) ||
|
|
$idx == 1 && ($dLast[1] == $dNow[1])) {
|
|
my $cum = $r->{$cumName}{VAL} + ($secNow-$secLast) * $val;
|
|
$r->{$cumName}{VAL} = $cum;
|
|
my $div = ($secNow ? $secNow : 1);
|
|
$r->{$avgName}{VAL} = sprintf("%0.1f", $cum/$div);
|
|
##MH change only if current value bigger than maxvalue
|
|
if($r->{$maxName}{VAL} < $val) {
|
|
$r->{$maxName}{VAL} = sprintf("%0.1f", $val); ##MH
|
|
$r->{$maxName}{TIME} = $tn; ##MH
|
|
}
|
|
|
|
##MH change only if current value smaller than minvalue
|
|
if($r->{$minName}{VAL} > $val) {
|
|
$r->{$minName}{VAL} = sprintf("%0.1f", $val); ##MH
|
|
$r->{$minName}{TIME} = $tn; ##MH
|
|
}
|
|
} else {
|
|
$dev->{CHANGED}[$myIdx++] = "$avgName: ".$r->{$avgName}{VAL};
|
|
$dev->{CHANGED}[$myIdx++] = "$maxName: ".$r->{$maxName}{VAL}; ##MH
|
|
$dev->{CHANGED}[$myIdx++] = "$minName: ".$r->{$minName}{VAL}; ##MH
|
|
$r->{$cumName}{VAL} = $secNow*$val;
|
|
$r->{$avgName}{VAL} = $val;
|
|
|
|
##MH set to current value
|
|
$r->{$maxName}{VAL} = sprintf("%0.1f", $val); ##MH
|
|
$r->{$maxName}{TIME} = $tn; ##MH
|
|
$r->{$minName}{VAL} = sprintf("%0.1f", $val); ##MH
|
|
$r->{$minName}{TIME} = $tn; ##MH
|
|
}
|
|
$r->{$cumName}{TIME} = $r->{$avgName}{TIME} = $tn;
|
|
}
|
|
}
|
|
return undef;
|
|
}
|
|
|
|
1;
|
|
|
|
|
|
=pod
|
|
=begin html
|
|
|
|
<a name="average"></a>
|
|
<h3>average</h3>
|
|
<ul>
|
|
|
|
Compute additional average, minimum and maximum values for current day and
|
|
month.
|
|
|
|
<br>
|
|
|
|
<a name="averagedefine"></a>
|
|
<b>Define</b>
|
|
<ul>
|
|
<code>define <name> average <regexp></code><br>
|
|
<br>
|
|
<ul>
|
|
The syntax for <regexp> is the same as the
|
|
regexp for <a href="#notify">notify</a>.<br>
|
|
If it matches, and the event is of the form "eventname number", then this
|
|
module computes the daily and monthly average, maximum and minimum values
|
|
and generates events of the form
|
|
<ul>
|
|
<device> <eventname>_avg_day: <computed_average>
|
|
</ul>
|
|
<ul>
|
|
<device> <eventname>_min_day: <minimum day value>
|
|
</ul>
|
|
<ul>
|
|
<device> <eventname>_max_day: <maximum day value>
|
|
</ul>
|
|
and
|
|
<ul>
|
|
<device> <eventname>_avg_month: <computed_average>
|
|
</ul>
|
|
<ul>
|
|
<device> <eventname>_min_month: <minimum month value>
|
|
</ul>
|
|
<ul>
|
|
<device> <eventname>_max_month: <maximum month value>
|
|
</ul>
|
|
|
|
at the beginning of the next day or month respectively.<br>
|
|
The current average, minimum, maximum and the cumulated values are stored
|
|
in the device readings.
|
|
</ul>
|
|
<br>
|
|
|
|
Example:<PRE>
|
|
# Compute the average, minimum and maximum for the temperature events of
|
|
# the ws1 device
|
|
define avg_temp_ws1 average ws1:temperature.*
|
|
|
|
# Compute the average, minimum and maximum for each temperature event
|
|
define avg_temp_ws1 average .*:temperature.*
|
|
|
|
# Compute the average, minimum and maximum for all temperature and humidity events
|
|
# Events:
|
|
# ws1 temperature: 22.3
|
|
# ws1 humidity: 67.4
|
|
define avg_temp_ws1 average .*:(temperature|humidity).*
|
|
|
|
# Compute the same from a combined event. Note: we need two average
|
|
# definitions here, each of them defining the name with the first
|
|
# paranthesis, and the value with the second.
|
|
#
|
|
# Event: ws1 T: 52.3 H: 67.4
|
|
define avg_temp_ws1_t average ws1:(T):.([-\d\.]+).*
|
|
define avg_temp_ws1_h average ws1:.*(H):.([-\d\.]+).*
|
|
</PRE>
|
|
</ul>
|
|
|
|
<a name="averageset"></a>
|
|
<b>Set</b> <ul>N/A</ul><br>
|
|
|
|
<a name="averageget"></a>
|
|
<b>Get</b> <ul>N/A</ul><br>
|
|
|
|
<a name="averageattr"></a>
|
|
<b>Attributes</b>
|
|
<ul>
|
|
<li><a href="#disable">disable</a></li>
|
|
</ul>
|
|
|
|
<a name="averageevents"></a>
|
|
<b>Generated events:</b>
|
|
<ul>
|
|
<li><eventname>_avg_day: $avg_day</li>
|
|
<li><eventname>_avg_month: $avg_month</li>
|
|
<li><eventname>_min_day: $min_day</li>
|
|
<li><eventname>_min_month: $min_month</li>
|
|
<li><eventname>_max_day: $max_day</li>
|
|
<li><eventname>_max_month: $max_month</li>
|
|
</ul>
|
|
</ul>
|
|
|
|
|
|
=end html
|
|
=cut
|