FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-03-04 05:16:45 +00:00
Code Issues Releases Wiki Activity

CUL_MAX: spread out TimeInformation update

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@2746 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
mgehre 2013-02-16 17:33:26 +00:00
parent cc33e83f59
commit 593a16a8ec
1 changed files with 26 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
fhem/FHEM/14_CUL_MAX.pm
View File

@ -17,10 +17,6 @@ sub CUL_MAX_SendQueueHandler($);
my $pairmodeDuration = 60; #seconds my $pairmodeDuration = 60; #seconds
my $timeBroadcastInterval = 6*60*60; #= 6 hours, the same time that the cube uses
my $resendRetries = 0; #how often resend before giving up?
my $ackTimeout = 3; #seconds my $ackTimeout = 3; #seconds
sub sub
@ -458,6 +454,20 @@ CUL_MAX_BroadcastTime(@)
my $payload = CUL_MAX_GetTimeInformationPayload(); my $payload = CUL_MAX_GetTimeInformationPayload();
Log GetLogLevel($hash->{NAME}, 5), "CUL_MAX_BroadcastTime: payload $payload "; Log GetLogLevel($hash->{NAME}, 5), "CUL_MAX_BroadcastTime: payload $payload ";
my $i = 1; my $i = 1;
my @used_slots = ( 0, 0, 0, 0, 0, 0 );
# First, lookup all thermstats for their current TimeInformationHour
foreach my $addr (keys %{$modules{MAX}{defptr}}) {
my $dhash = $modules{MAX}{defptr}{$addr};
if(exists($dhash->{IODev}) && $dhash->{IODev} == $hash
&& $dhash->{type} =~ /.*Thermostat.*/ ) {
my $h = ReadingsVal($dhash->{NAME},"TimeInformationHour","");
$used_slots[$h]++ if( $h =~ /^[0-5]$/);
}
}
foreach my $addr (keys %{$modules{MAX}{defptr}}) { foreach my $addr (keys %{$modules{MAX}{defptr}}) {
my $dhash = $modules{MAX}{defptr}{$addr}; my $dhash = $modules{MAX}{defptr}{$addr};
#Check that #Check that
@ -465,14 +475,24 @@ CUL_MAX_BroadcastTime(@)
#2. the MAX device is a Wall/HeatingThermostat #2. the MAX device is a Wall/HeatingThermostat
if(exists($dhash->{IODev}) && $dhash->{IODev} == $hash if(exists($dhash->{IODev}) && $dhash->{IODev} == $hash
&& $dhash->{type} =~ /.*Thermostat.*/ ) { && $dhash->{type} =~ /.*Thermostat.*/ ) {
CUL_MAX_SendTimeInformation($hash, $addr, $payload);
my $h = ReadingsVal($dhash->{NAME},"TimeInformationHour","");
if( $h !~ /^[0-5]$/ ) {
#Find the used_slot with the smallest number of entries
$h = (sort { $used_slots[$a] cmp $used_slots[$b] } 0 .. 5)[0];
readingsSingleUpdate($dhash, "TimeInformationHour", $h, 1);
$used_slots[$h]++;
}
CUL_MAX_SendTimeInformation($hash, $addr, $payload) if( [gmtime()]->[2] % 6 == $h );
} }
else { else {
Log GetLogLevel($hash->{NAME}, 5), "Not sending to $addr, type $dhash->{type}, $dhash->{IODev}{NAME}" Log GetLogLevel($hash->{NAME}, 5), "Not sending to $addr, type $dhash->{type}, $dhash->{IODev}{NAME}"
} }
} }
InternalTimer(gettimeofday()+$timeBroadcastInterval, "CUL_MAX_BroadcastTime", $hash, 0) unless(defined($manual)); #Check again in 1 hour if some thermostats with the right TimeInformationHour need updating
InternalTimer(gettimeofday() + 3600, "CUL_MAX_BroadcastTime", $hash, 0) unless(defined($manual));
} }
1; 1;