Public/fhem-mirror
1
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-05-01 20:20:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

32_TechemHKV.pm: add fw version 94 and stackable_cc (#80145)

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@15731 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
herrmannj 2017-12-30 21:10:18 +00:00
parent 0a9c8c7772
commit f90c0ed02d
1 changed files with 79 additions and 80 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

159
fhem/FHEM/32_TechemHKV.pm
View File

@ -16,7 +16,7 @@ use warnings;
use Time::HiRes qw(time); use Time::HiRes qw(time);
my %typeText = ( my %typeText = (
'80' => 'Funkheizkostenverteiler data IIl' '80' => 'Funkheizkostenverteiler data III'
); );
sub sub
@ -27,7 +27,7 @@ TechemHKV_Initialize(@) {
# TECHEM HKV # TECHEM HKV
# 61, 64 without T1 and T2 # 61, 64 without T1 and T2
$hash->{Match} = "^b..446850[\\d]{8}(61|64|69)80....A0.*"; $hash->{Match} = "^b..446850[\\d]{8}(61|64|69|94)80.*";
$hash->{DefFn} = "TechemHKV_Define"; $hash->{DefFn} = "TechemHKV_Define";
$hash->{UndefFn} = "TechemHKV_Undef"; $hash->{UndefFn} = "TechemHKV_Undef";
@ -49,18 +49,17 @@ TechemHKV_Define(@) {
return "ID must have 4 or 8 digits" if ($id !~ /^\d{4}(?:\d{4})?$/); return "ID must have 4 or 8 digits" if ($id !~ /^\d{4}(?:\d{4})?$/);
my $lid = (length($id) == 8)?$id:undef;
$id = (length($id) == 8)?substr($id,-4):$id;
$modules{TechemHKV}{defptr}{$id} = $hash; $modules{TechemHKV}{defptr}{$id} = $hash;
$hash->{FRIENDLY} = $def if (defined($def)); $hash->{FRIENDLY} = $def if (defined($def));
$hash->{LID} = $id if (length($id) == 8); $hash->{LONGID} = $id if (length($id) == 8);
# create crc table if required # create crc table if required
$data{WMBUS}{crc_table_13757} = TechemHKV_createCrcTable() unless (exists($data{WMBUS}{crc_table_13757})); $data{WMBUS}{crc_table_13757} = TechemHKV_createCrcTable() unless (exists($data{WMBUS}{crc_table_13757}));
# subscribe broadcast channels # subscribe broadcast channels
# TechemHKV_subscribe($hash, 'foo'); # TechemHKV_subscribe($hash, 'foo');
# TechemHKV_Parse($hash, 'b334468500180560094804C3AA20F9F211202B038E80411FD0B81104E6D6265006554261A1B000000000000000001DCBC1706085875BCFADDBEC0F25480');
TechemHKV_Run($hash) if $init_done; TechemHKV_Run($hash) if $init_done;
return undef; return undef;
} }
@ -69,7 +68,7 @@ sub
TechemHKV_Undef(@) { TechemHKV_Undef(@) {
my ($hash) = @_; my ($hash) = @_;
return undef; return undef;
} };
sub sub
TechemHKV_Set(@) { TechemHKV_Set(@) {
@ -77,19 +76,19 @@ TechemHKV_Set(@) {
my $cnt = @args; my $cnt = @args;
return undef; return undef;
} };
sub sub
TechemHKV_Get(@) { TechemHKV_Get(@) {
my ($hash) = @_; my ($hash) = @_;
return undef; return undef;
} };
sub sub
TechemHKV_Notify (@) { TechemHKV_Notify (@) {
my ($hash, $ntfyDev) = @_; my ($hash, $ntfyDev) = @_;
return unless (($ntfyDev->{TYPE} eq 'CUL') || ($ntfyDev->{TYPE} eq 'Global')); return unless (($ntfyDev->{TYPE} =~ /CUL|STACKABLE/) || ($ntfyDev->{TYPE} eq 'Global'));
foreach my $event (@{$ntfyDev->{CHANGED}}) { foreach my $event (@{$ntfyDev->{CHANGED}}) {
my @e = split(' ', $event); my @e = split(' ', $event);
next unless defined($e[0]); next unless defined($e[0]);
@ -103,16 +102,16 @@ TechemHKV_Notify (@) {
readingsBulkUpdate($hash, "temp1", "--.--") if exists($hash->{READINGS}->{'temp1'}); # exlude versions without t1,t2 readingsBulkUpdate($hash, "temp1", "--.--") if exists($hash->{READINGS}->{'temp1'}); # exlude versions without t1,t2
readingsBulkUpdate($hash, "temp2", "--.--") if exists($hash->{READINGS}->{'temp2'}); readingsBulkUpdate($hash, "temp2", "--.--") if exists($hash->{READINGS}->{'temp2'});
readingsEndUpdate($hash, 1); readingsEndUpdate($hash, 1);
} };
} };
return undef; return undef;
} };
sub sub
TechemHKV_Receive(@) { TechemHKV_Receive(@) {
my ($hash, $msg) = @_; my ($hash, $msg) = @_;
$hash->{longID} = $msg->{long} unless defined($hash->{longID}); $hash->{LONGID} = $msg->{long} unless defined($hash->{LONGID});
# TODO log collision if any ... # TODO log collision if any ...
my @t = localtime(time); my @t = localtime(time);
@ -122,12 +121,12 @@ TechemHKV_Receive(@) {
$hash->{METER} = $typeText{$msg->{type}}; $hash->{METER} = $typeText{$msg->{type}};
delete $hash->{CHANGETIME}; # clean up, workaround for fhem prior http://forum.fhem.de/index.php/topic,47474.msg391964.html#msg391964 delete $hash->{CHANGETIME}; # clean up, workaround for fhem prior http://forum.fhem.de/index.php/topic,47474.msg391964.html#msg391964
if (($msg->{version} || '') eq '69') { if (($msg->{version} || '') =~ /69|94/) {
readingsBeginUpdate($hash); readingsBeginUpdate($hash);
readingsBulkUpdate($hash, "temp1", $msg->{temp1}); readingsBulkUpdate($hash, "temp1", $msg->{temp1});
readingsBulkUpdate($hash, "temp2", $msg->{temp2}); readingsBulkUpdate($hash, "temp2", $msg->{temp2});
readingsEndUpdate($hash, 1); readingsEndUpdate($hash, 1);
} };
# day period changed # day period changed
$ats = ReadingsTimestamp($hash->{NAME},"current_period", "0"); $ats = ReadingsTimestamp($hash->{NAME},"current_period", "0");
@ -140,7 +139,7 @@ TechemHKV_Receive(@) {
readingsBulkUpdate($hash, "current_period", $msg->{actualVal}); readingsBulkUpdate($hash, "current_period", $msg->{actualVal});
$hash->{CHANGETIME}->[$#{ $hash->{CHANGED} }] = $ts if ($#{ $hash->{CHANGED} } != $i ); # only add ts if there is a event to $hash->{CHANGETIME}->[$#{ $hash->{CHANGED} }] = $ts if ($#{ $hash->{CHANGED} } != $i ); # only add ts if there is a event to
readingsEndUpdate($hash, 1); readingsEndUpdate($hash, 1);
} };
# billing period changed # billing period changed
$ats = ReadingsTimestamp($hash->{NAME},"previous_period", "0"); $ats = ReadingsTimestamp($hash->{NAME},"previous_period", "0");
@ -153,10 +152,9 @@ TechemHKV_Receive(@) {
readingsBulkUpdate($hash, "previous_period", $msg->{lastVal}); readingsBulkUpdate($hash, "previous_period", $msg->{lastVal});
$hash->{CHANGETIME}->[$#{ $hash->{CHANGED} }] = $ts if ($#{ $hash->{CHANGED} } != $i ); # only add ts if there is a event to $hash->{CHANGETIME}->[$#{ $hash->{CHANGED} }] = $ts if ($#{ $hash->{CHANGED} } != $i ); # only add ts if there is a event to
readingsEndUpdate($hash, 1); readingsEndUpdate($hash, 1);
} };
return undef; return undef;
} };
sub sub
TechemHKV_Run(@) { TechemHKV_Run(@) {
@ -164,7 +162,7 @@ TechemHKV_Run(@) {
# find a CUL # find a CUL
foreach my $d (keys %defs) { foreach my $d (keys %defs) {
# live patch CUL.pm # live patch CUL.pm
TechemHKV_IOPatch($hash, $d) if ($defs{$d}{TYPE} eq "CUL"); TechemHKV_IOPatch($hash, $d) if ($defs{$d}{TYPE} =~ /CUL|STACKABLE/);
} }
return undef; return undef;
} }
@ -191,22 +189,64 @@ TechemHKV_Parse(@) {
$msg = TechemHKV_SanityCheck($msg); $msg = TechemHKV_SanityCheck($msg);
return ('') unless $msg; return ('') unless $msg;
my @m = ($msg =~ m/../g); $message->{long} = join '', reverse split /(..)/, substr $msg, 6, 8;
$message->{short} = substr $message->{long}, 4, 4;
# parse $message->{version} = substr $msg, 14, 2;
($message->{long}, $message->{short}) = TechemHKV_ParseID(@m); $message->{type} = substr $msg, 16, 2;
$message->{type} = TechemHKV_ParseSubType(@m);
$message->{version} = TechemHKV_ParseSubVersion(@m); # last_date
$message->{lastVal} = TechemHKV_ParseLastPeriod(@m); #if ($message->{version} eq '94') {
$message->{actualVal} = TechemHKV_ParseActualPeriod(@m); # ($message->{last}->{year}, $message->{last}->{month}, $message->{last}->{day})
$message->{temp1} = TechemHKV_ParseT1(@m); # = TechemHKV_ParseLastDate(join '', reverse split /(..)/, substr $msg, 24, 4);
$message->{temp2} = TechemHKV_ParseT2(@m); #} else {
($message->{actual}->{year}, $message->{actual}->{month}, $message->{actual}->{day}) = TechemHKV_ParseActualDate(@m); ($message->{last}->{year}, $message->{last}->{month}, $message->{last}->{day})
($message->{last}->{year}, $message->{last}->{month}, $message->{last}->{day}) = TechemHKV_ParseLastDate(@m); = TechemHKV_ParseLastDate(join '', reverse split /(..)/, substr $msg, 22, 4);
#}
# previous_period
#if ($message->{version} eq '94') {
# $message->{lastVal} = hex(join '', reverse split /(..)/, substr $msg, 28, 4);
#} else {
$message->{lastVal} = hex(join '', reverse split /(..)/, substr $msg, 26, 4);
#}
# actual_date
#if ($message->{version} eq '94') {
# ($message->{actual}->{year}, $message->{actual}->{month}, $message->{actual}->{day})
# = TechemHKV_ParseActualDate(join '', reverse split /(..)/, substr $msg, 32, 4);
#} else {
($message->{actual}->{year}, $message->{actual}->{month}, $message->{actual}->{day})
= TechemHKV_ParseActualDate(join '', reverse split /(..)/, substr $msg, 30, 4);
#}
# actual_period
#if ($message->{version} eq '94') {
# $message->{actualVal} = hex(join '', reverse split /(..)/, substr $msg, 36, 4);
#} else {
$message->{actualVal} = hex(join '', reverse split /(..)/, substr $msg, 34, 4);
#}
# temp sensor 1
if ($message->{version} eq '94') {
$message->{temp1} = sprintf "%.2f", (hex(join '', reverse split /(..)/, substr $msg, 40, 4) / 100);
} elsif ($message->{version} eq '69') {
$message->{temp1} = sprintf "%.2f", (hex(join '', reverse split /(..)/, substr $msg, 38, 4) / 100);
}
# temp sensor 2
if ($message->{version} eq '94') {
$message->{temp2} = sprintf "%.2f", (hex(join '', reverse split /(..)/, substr $msg, 44, 4) / 100);
} elsif ($message->{version} eq '69') {
$message->{temp2} = sprintf "%.2f", (hex(join '', reverse split /(..)/, substr $msg, 42, 4) / 100);
}
# dispatch # dispatch
if (exists($modules{TechemHKV}{defptr}{$message->{short}})) { if (exists($modules{TechemHKV}{defptr}{$message->{long}})) {
my $deviceHash = $modules{TechemHKV}{defptr}{$message->{long}};
TechemHKV_Receive($deviceHash, $message);
return ($deviceHash->{NAME});
} elsif (exists($modules{TechemHKV}{defptr}{$message->{short}})) {
my $deviceHash = $modules{TechemHKV}{defptr}{$message->{short}}; my $deviceHash = $modules{TechemHKV}{defptr}{$message->{short}};
$modules{TechemHKV}{defptr}{$message->{long}} = $deviceHash;
delete($modules{TechemHKV}{defptr}{$message->{short}});
TechemHKV_Receive($deviceHash, $message); TechemHKV_Receive($deviceHash, $message);
return ($deviceHash->{NAME}); return ($deviceHash->{NAME});
} }
@ -267,56 +307,14 @@ TechemHKV_SanityCheck(@) {
$t .= substr $msg, 25 + ($fb * 36), ($rb * 2); $t .= substr $msg, 25 + ($fb * 36), ($rb * 2);
} }
} }
Log3 ("TechemHKV", $dbg, "ok $t");
return $t; return $t;
} }
sub
TechemHKV_ParseID(@) {
my @m = @_;
return ("$m[6]$m[5]$m[4]$m[3]", "$m[4]$m[3]");
}
sub
TechemHKV_ParseSubType(@) {
my @m = @_;
return "$m[8]";
}
sub
TechemHKV_ParseSubVersion(@) {
my @m = @_;
return "$m[7]";
}
sub
TechemHKV_ParseLastPeriod(@) {
my @m = @_;
return hex("$m[14]$m[13]");
}
sub
TechemHKV_ParseActualPeriod(@) {
my @m = @_;
return hex("$m[18]$m[17]");
}
sub
TechemHKV_ParseT1(@) {
my @m = @_;
return sprintf "%.2f", (hex("$m[20]$m[19]") / 100);
}
sub
TechemHKV_ParseT2(@) {
my @m = @_;
return sprintf "%.2f", (hex("$m[22]$m[21]") / 100);
}
sub sub
TechemHKV_ParseActualDate(@) { TechemHKV_ParseActualDate(@) {
my @m = @_; my $b = hex($_[0]);
my @t = localtime(time); my @t = localtime(time);
my $b = hex("$m[16]$m[15]");
my $d = ($b >> 4) & 0x1F; my $d = ($b >> 4) & 0x1F;
my $m = ($b >> 9) & 0x0F; my $m = ($b >> 9) & 0x0F;
my $y = $t[5] + 1900; my $y = $t[5] + 1900;
@ -325,8 +323,7 @@ TechemHKV_ParseActualDate(@) {
sub sub
TechemHKV_ParseLastDate(@) { TechemHKV_ParseLastDate(@) {
my @m = @_; my $b = hex($_[0]);
my $b = hex("$m[12]$m[11]");
my $d = ($b >> 0) & 0x1F; my $d = ($b >> 0) & 0x1F;
my $m = ($b >> 5) & 0x0F; my $m = ($b >> 5) & 0x0F;
my $y = ($b >> 9) & 0x3F; my $y = ($b >> 9) & 0x3F;
@ -397,6 +394,8 @@ TechemHKV_crc16_13757(@) {
1; 1;
=pod =pod
=item summary read techem data meter for heating device.
=item summary_DE Anbindung von Techem Heizkostenverteilern.
=begin html =begin html
<a name="TechemHKV"></a> <a name="TechemHKV"></a>