From 98167fce7f0fa4442472a92ab9962ada8d21a069 Mon Sep 17 00:00:00 2001 From: chris1284 <> Date: Tue, 12 Sep 2017 19:30:29 +0000 Subject: [PATCH] 93_RFHEM.pm: -added this modul git-svn-id: https://svn.fhem.de/fhem/trunk@15058 2b470e98-0d58-463d-a4d8-8e2adae1ed80 --- fhem/FHEM/93_RFHEM.pm | 237 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 237 insertions(+) create mode 100644 fhem/FHEM/93_RFHEM.pm diff --git a/fhem/FHEM/93_RFHEM.pm b/fhem/FHEM/93_RFHEM.pm new file mode 100644 index 000000000..60193d859 --- /dev/null +++ b/fhem/FHEM/93_RFHEM.pm @@ -0,0 +1,237 @@ +# $Id$ +######################################################### +# +# RFHEM +# Copyright by chris1284 +# +######################################################### +package main; + +use strict; +use warnings; + +sub RFHEM_GetUpdate($); +sub RFHEM_GetNet($$); +sub RFHEM_Set($@); +sub RFHEM_Define($$); +sub RFHEM_Undef($$); +sub RFHEM_Notify($$); + +my %sets = ( + "cmd" => "", +); +sub RFHEM_Initialize($) +{ + my ($hash) = @_; + + $hash->{DefFn} = "RFHEM_Define"; + $hash->{UndefFn} = "RFHEM_Undef"; + $hash->{SetFn} = "RFHEM_Set"; + $hash->{NotifyFn} = "RFHEM_Notify"; + $hash->{AttrList} = "dummy:1,0 " . + "RFHEMdevs " . + "RFHEMevents " . + $readingFnAttributes; +} +sub RFHEM_Define($$) +{ + my ($hash, $def) = @_; + my @a = split("[ \t][ \t]*", $def); + return "wrong syntax: define RFHEM host[:port] [pw]" if(@a < 2 || @a > 4 ) ; + my $name = $a[0]; + my $devstate = "created"; + my $inter = 900; + my $dev = $a[2]; + my $port = "7072" if($dev !~ m/^.+:[0-9]+$/); + if($dev =~ m/^.+:[0-9]+$/) + { + my @temp = split(":", $dev); + $port = $temp[1]; + $dev = $temp[0]; + } + $hash->{NAME} = $name; + $hash->{HOSTNAME} = $dev; + $hash->{PORT} = $port; + $hash->{PASSWORD} = $a[3] if(@a == 4); + $hash->{STATE} = $devstate; + $hash->{Interval} = $inter; + InternalTimer(gettimeofday()+2, "RFHEM_GetUpdate", $hash, 0); + return undef; +} +sub RFHEM_Undef($$) +{ + my ($hash, $arg) = @_; + RemoveInternalTimer($hash); + return undef; +} +sub RFHEM_Set($@) +{ + my ( $hash, @a ) = @_; + return "\"set RFHEM\" needs at least an argument" if ( @a < 2 ); + return "Unknown argument $a[1], choose one of ".join(" ", sort keys %sets) if(!defined($sets{$a[1]})); + my $name = shift @a; + shift @a; + my $command = join(" ",@a); + my $HOSTNAME = $hash->{HOSTNAME}; + my $HOSTPORT = $hash->{PORT}; + my $HOSTPW = $hash->{PASSWORD} if ($hash->{PASSWORD}); + #my $socket = IO::Socket::INET->new('PeerAddr' => $HOSTNAME,'PeerPort' => $HOSTPORT,'Proto' => 'tcp') or die Log3 $name, 3, "Can't create socket ($!)\n"; + my $socket = IO::Socket::INET->new('PeerAddr' => $HOSTNAME,'PeerPort' => $HOSTPORT,'Proto' => 'tcp') ; + my $msg = $command."\n" ; + #Log3 $name, 3, "$msg"; + my @values = RFHEM_GetNet($hash,$HOSTNAME); + if ( $values[1] eq "present") { + Log3 $name, 3, "Host present, executing command..."; + syswrite($socket, $HOSTPW . "\n")if($hash->{PASSWORD}); + print $socket $msg; + Log3 $name, 3, "Command executed."; } + else { Log3 $name, 3, "Error: host not present!"; } + #$socket->close(); + #Log3 $name, 3, "Connection closed"; +} +sub RFHEM_GetUpdate($) +{ + my ($hash) = @_; + my $hostname = $hash->{HOSTNAME}; + my $name = $hash->{NAME}; + InternalTimer(gettimeofday()+$hash->{Interval}, "RFHEM_GetUpdate", $hash, 1); + #Log3 $name, 3, "WINPC: GetUpdate called ..."; + my @values = RFHEM_GetNet($hash,$hostname); + readingsBeginUpdate($hash); #start update + readingsBulkUpdate($hash,"ipadress",$values[0]); #doit + readingsBulkUpdate($hash,"statedev",$values[1]); #doit + readingsEndUpdate($hash,1); #end update + #Log3 $name, 3, "WINPC: GetUpdate done."; +} +sub RFHEM_GetNet($$) +{ + my ($hash, $hostname) = @_; + my $name = $hash->{NAME}; + my $netstate ; + my @return ; + my @a ; + my $ip ; + my $erg = `ping -c 1 -w 2 $hostname` ; + #Log3 $name, 3, "NETPC: $erg"; + if( $erg =~ m/100%/) + { + $ip = "0.0.0.0"; + $netstate = "absent"; + @return =($ip,$netstate); + return @return; + } + elsif( $erg =~ m/ping: unknown host/) + { + $ip = "0.0.0.0"; + $netstate = "unknown"; + @return =($ip,$netstate); + return @return; + } + elsif( $erg =~ m/0%/ ) + { + @a = split(" ", $erg); + $ip = $a[2]; + $ip =~ tr/(//ds; + $ip =~ tr/)//ds; + $netstate = "present"; + @return =($ip,$netstate); + return @return; + } +} +sub RFHEM_Notify($$) +{ + my ($hash, $extDevHash) = @_; + my $name = $hash->{NAME}; # name RFHEM device + my $extDevName = $extDevHash->{NAME}; # name externes device + my @devnames = split( ",", AttrVal($name,"RFHEMdevs","")); + my @myevents = split( ",", AttrVal($name,"RFHEMevents",".*")); + my $event; + my $extevent; + return "" if(IsDisabled($name)); # wenn attr disabled keine reaktion + foreach my $devname (@devnames){ + if ($extDevName eq $devname) { #wenn devicename extern zu unserne überwachten passt ... + if ($myevents[0] eq ".*"){ + Log3 $name , 3, "RFHEM $name - triggered by Device:$extDevName (all events) ..."; + foreach $extevent (@{$extDevHash->{CHANGED}}) { #für jedes event des externen device / dort geänderte readings + my @eventparts = split (": ", $extevent); + Log3 $name , 3, "RFHEM $name - event: $eventparts[0] with value $eventparts[1] ..."; + my $setcmd = "set $name cmd setreading $extDevName $eventparts[0] $eventparts[1]"; + fhem( $setcmd ); + } + } + else { + foreach $extevent (@{$extDevHash->{CHANGED}}) { #für jedes event des externen device / dort geänderte readings + my @exteventparts = split (": ", $event); + foreach $event (@myevents) { # mit jedme event aus rhfme attribut + if ($event eq $exteventparts[0]) { + Log3 $name , 3, "RFHEM $name - triggered by Device:$extDevName with event ..."; + my @eventparts = split (": ", $extevent); + Log3 $name , 3, "RFHEM $name - event: $eventparts[0] with value $eventparts[1] ..."; + + + } + } + } + } + } + } +} + +1; +=pod +=item helper +=item summary RFHEM is a easy helper module to connect separate FHEM installations +=item summary_DE RFHEM ist ein einfaches Hilfsmodul um separate FHEM Installationen zu verbinden +=begin html + + +

RFHEM

+ + +Define +
+
+ +Set +
+ +Attribute +
  • RFHEMdevs
    + a list of devices separated by comma + all events of this devices will be set on the remote installation automatically + there must be device with the same nameon the other side (dummys) +

    • +
  • RFHEMevents
    + a list of events separated by comma + all events of RFHEMdevs will be set on the remote installation automatically +

    • + +
    +=end html + +=begin html_DE + + +

    RFHEM

    + + +Define +
    +
    + +Set +
    + +Attribute +
  • RFHEMdevs
    + Eine durch Komma getrennte Liste von Geräten. + Alle Events dieser Geräte werden autom. an die entfernte Installation gesendet. Auf der entfernten Seite muss es das Gerät mit selben Namen geben (zb ein Dummy). +

    • +
  • RFHEMevents
    + Eine durch Komma getrennte Liste von Events. + Alle diese Events ( der Geräte aus RFHEMdevs) werden autom. an die entfernte Installation gesendet +

    • + +
    +=end html_DE +=cut \ No newline at end of file