diff --git a/fhem/FHEM/70_EFR.pm b/fhem/FHEM/70_EFR.pm deleted file mode 100644 index e97c7dc0c..000000000 --- a/fhem/FHEM/70_EFR.pm +++ /dev/null @@ -1,364 +0,0 @@ -############################################################################## -# -# 70_EFR.pm -# -# a module to show smartmeter data -# -# written 2013 by Gabriel Bentele > -# -# $Id: 70_EFR.pm 3799 2013-08-26 18:15:33Z bentele $ -# -# Version = 0.8 -# -############################################################################## -# -# define EFR [ []] -# -# If is positive, new values are read every seconds. -# If is 0, new values are read whenever a get request is called -# on . The default for is 300 (i.e. 5 minutes). -# -# get -# -############################################################################## -# { "obis":"8181C78227FF","value":""}, [03] Kundennummer -# { "obis":"8181C78205FF","value":"xxxxx"}, [04] Vorname -# { "obis":"8181C78206FF","value":"xxxxx"}, [05] Nachname -# { "obis":"8181C78207FF","value":"xxxxx"}, [06] Anschrift -# { "obis":"0100000000FF","value":"xxxxx"}, [07] Eigentums- bzw. Zählernummer -# { "obis":"010000090B00","value":"dd.mm.yyyy,hh:mm"}], "values" : [ [08] Zeitangabe (Datum , Uhrzeit) -# {"obis":"0101010800FF","value":41.42,"unit":"kWh" }, [09] BEZUG Wirkleistung Energiezählwerk - Summenzählwerk abrechnungsrelevant (Tariflos) -# {"obis":"0101010801FF","value":33.53,"unit":"kWh"}, [10 BEZUG Wirkleistung Energiezählwerk NT -# {"obis":"0100010700FF","value":313.07,"unit":"W"}, [11] Momentanleistung über alle 3 Phasen saldierend -# {"obis":"0100150700FF","value":209.40,"unit":"W"}, [12] Momentanleistung Phase L1 -# {"obis":"0100290700FF","value":14.27,"unit":"W"}, [13] Momentanleistung Phase L2 -# {"obis":"01003D0700FF","value":89.40,"unit":"W"}, [14] Momentanleistung Phase L3 -# {"obis":"010020070000","value":237.06,"unit":"V"}, [15] Phasenspannung U1 -# {"obis":"010034070000","value":236.28,"unit":"V"}, [16] Phasenspannung U2 -# {"obis":"010048070000","value":236.90,"unit":"V"}, [17] Phasenspannung U3 -# {"obis":"01000E070000","value":49.950,"unit":"Hz"} ] }} [18] Netzfrequenz -############################################################################## - -package main; -use strict; -use IO::Socket::INET; -use Blocking; -use MIME::Base64; - -my @gets = ('lastPower','PowerTotal','Power_L1','Power_L2','Power_L3'); - -sub -EFR_Initialize($) -{ -my ($hash) = @_; - - $hash->{DefFn} = "energy_Define"; - $hash->{UndefFn} = "energy_Undef"; - $hash->{GetFn} = "energy_Get"; - $hash->{StateFn} = "energy_State"; - $hash->{SetFn} = "energy_Set"; - -} - -sub -energy_State($$$$) -{ - my ($hash, $tim, $vt, $val) = @_; - $hash->{READINGS}{$vt}{VAL} = $val; - $hash->{READINGS}{$vt}{TIME} = TimeNow(); - Log3 $hash, 4, "energy_State: time: $tim name: $vt value: $val"; - return undef; -} - -sub -energy_Set($$$$) -{ - my ($hash, $tim, $vt, $val) = @_; - Log3 $hash, 4, "SET device: $tim name: $vt value: $val"; - $hash->{READINGS}{$vt}{VAL} = $val; - $hash->{READINGS}{$vt}{TIME} = TimeNow(); - if ( $vt eq "?"){ - return "Unknown argument ?, choose one of Interval"; - } - if ( $vt eq "Interval"){ - $hash->{Interval} = $val; - } - return undef; -} - -sub -energy_Define($$) -{ - my ($hash, $def) = @_; - - my @args = split("[ \t]+", $def); - - if (int(@args) < 3) - { - return "energy_Define: too few arguments. Usage:\n" . - "define EFR [ []]"; - } - my $name = $args[0]; - $hash->{NAME} = $name; - - $hash->{Host} = $args[2]; - $hash->{Port} = 80; - $hash->{Interval} = int(@args) >= 4 ? int($args[3]) : 300; - $hash->{Timeout} = int(@args) >= 5 ? int($args[4]) : 4; - - Log3 $hash, 4, "$hash->{NAME} will read from EFR at $hash->{Host}:$hash->{Port} " ; - $hash->{Rereads} = 2; # number of retries when reading curPwr of 0 - $hash->{UseSVTime} = ''; # use the SV time as timestamp (else: TimeNow()) - - $hash->{STATE} = 'Initializing'; - - my $timenow = TimeNow(); - - for my $get (@gets) - { - $hash->{READINGS}{$get}{VAL} = -1 ; - $hash->{READINGS}{$get}{TIME} = $timenow; - } - - RemoveInternalTimer($hash); - InternalTimer(gettimeofday()+$hash->{Interval}, "energy_Update", $hash, 0); - - Log3 $hash, 3, "$hash->{NAME} will read from EFR at $hash->{Host}:$hash->{Port} " ; - return undef; -} - -sub -energy_Update($) -{ - my ($hash) = @_; - my $name = $hash->{NAME}; - - my $ip = $hash->{Host}; - my $port = $hash->{Port}; - my $interval = $hash->{Interval}; - -$hash->{helper}{RUNNING_PID} = BlockingCall("energy_DoUpdate", $name."|".$ip."|".$port."|".$interval, "energy_energyDone", 120, "energy_energyAborted", $hash) unless(exists($hash->{helper}{RUNNING_PID})); - -} - -sub -energy_DoUpdate($){ - - my ($string) = @_; - my ($name, $ip, $port,$interval) = split("\\|", $string); - my $success = 0; - my %readings = (); - my $timenow = TimeNow(); - my $timeout = 10; - my $counts = 0 ; - my $summary = 0 ; - my $url="/json.txt?LogName=user\&LogPSWD=user"; - #my $url="/efr/efr.txt"; - my $socket ; - my $buf ; - my $message ; - -$socket = new IO::Socket::INET ( - PeerAddr => $ip, - PeerPort => $port, - Proto => 'tcp', - Reuse => 0, - Timeout => $timeout - ); - -if (defined ($socket) and $socket and $socket->connected()) -{ - print $socket "GET $url HTTP/1.0\r\n\r\n"; - $socket->autoflush(1); - while ((read $socket, $buf, 1024) > 0) - { - $message .= $buf; - } - $socket->close(); - Log3 $name, 4, "Socket closed"; - $success = 0; -}else{ - Log3 $name, 3, "$name Cannot open socket ..."; - $success = 1; -} - - $message = encode_base64($message,""); - if ( $success == 0 ){ - my $back = $name ."|". $message; - return "$name|$message" ; - }else{ - return "$name|-1"; - } -} - -sub -energy_energyDone($) -{ - my ($string) = @_; - return unless(defined($string)); - my (@a) = split("\\|", $string); - my $hash = $defs{$a[0]}; - my $message = decode_base64($a[1]); - my @array; - my $log = ""; - my $timenow = TimeNow(); - - delete($hash->{helper}{RUNNING_PID}); - - if(!$hash->{LOCAL}) { - RemoveInternalTimer($hash); - InternalTimer(gettimeofday()+$hash->{Interval}, "energy_Update", $hash, 1); - } - if ($hash->{Interval} > 0) { - InternalTimer(gettimeofday() + $hash->{Interval}, "energy_Update", $hash, 0); - } - -if ( $message ne "-1" ) -{ - @array=split(/\{/,$message); - my $powernow = $array[11]; - $powernow =~ m/value":(.*),"unit":/; - $powernow = $1; - - $hash->{READINGS}{lastPower}{VAL} = $powernow; - $hash->{READINGS}{lastPower}{TIME} = $timenow; - - my $powercounter = $array[10]; - $powercounter =~ m/value":(.*),"unit":/; - $powercounter = $1; - - $hash->{READINGS}{PowerTotal}{VAL} = $powercounter; - $hash->{READINGS}{PowerTotal}{TIME} = $timenow; - - my $powerU1 = $array[12]; - $powerU1 =~ m/value":(.*),"unit":/; - $powerU1 = $1; - - $hash->{READINGS}{Power_L1}{VAL} = $powerU1; - $hash->{READINGS}{Power_L1}{TIME} = $timenow; - - my $powerU2 = $array[13]; - $powerU2 =~ m/value":(.*),"unit":/; - $powerU2 = $1; - - $hash->{READINGS}{Power_L2}{VAL} = $powerU2; - $hash->{READINGS}{Power_L2}{TIME} = $timenow; - - my $powerU3 = $array[14]; - $powerU3 =~ m/value":(.*),"unit":/; - $powerU3 = $1; - - $hash->{READINGS}{Power_L3}{VAL} = $powerU3; - $hash->{READINGS}{Power_L3}{TIME} = $timenow; - - $log = "PowerTotal: $powercounter lastPower: $powernow Power_L1: $powerU1 Power_L2: $powerU2 Power_L3: $powerU3"; - - push @{$hash->{CHANGED}}, $log; - DoTrigger($hash->{NAME}, undef) if ($init_done); - Log3 $hash, 4, "$hash->{NAME} write log file: $log"; - if ( $hash->{STATE} eq 'Initializing' || $hash->{STATE} eq 'disconnected' ){ - $hash->{STATE} = 'Connected'; - } -}else{ - $hash->{STATE} = 'disconnected'; - Log3 $hash, 3, "$hash->{NAME} can't update - device send a error"; -} - - Log3 $hash, 5, "$hash->{NAME} loop done " ; -return undef; -} - -sub -energy_energyAborted($) -{ - my ($hash) = @_; - - Log3 $hash, 3, "$hash->{NAME} energy_energyAborted"; - - delete($hash->{helper}{RUNNING_PID}); -} - -sub -energy_Get($@) -{ - -my ($hash, @args) = @_; - - return 'energy_Get needs two arguments' if (@args != 2); - -energy_Update($hash) unless $hash->{Interval}; - - my $get = $args[1]; - my $val = -1; - - if (defined($hash->{READINGS}{$get})) { - $val = $hash->{READINGS}{$get}{VAL}; - } else { - return "energy_Get: no such reading: $get"; - } - if ( $get eq "?"){ - return "Unknown argument ?, choose one of lastPower PowerTotal Power_L1 Power_L2 Power_L3"; - } - Log3 $hash, 3, "$args[0] $get => $val"; - - return $val; -} - -sub -energy_Undef($$) -{ - my ($hash, $args) = @_; - - RemoveInternalTimer($hash) if $hash->{Interval}; - - BlockingKill($hash->{helper}{RUNNING_PID}) if(defined($hash->{helper}{RUNNING_PID})); - - return undef; -} - -1; - -=pod -=begin html - - - -

EFR

-

    -This module supports EFR Power Meter.
    -The electricity meter will be polled in a defined interval for new values. -

    - Define
    - define <name> EFR <host> <port> [<interval> <timeout>]
    -

    - Example:
    - define StromZ1 EFR 192.168.178.20
    - define StromZ2 EFR 192.168.10.25 300 60
    -

    - - Set
    - set <name> <value> <nummber>
    where value is one of:

    -
      -
    • Interval
      • -
    -
    Example:
    - set <name> not implemented

    - - Get
    - get <name> <value>
    where value is one of:
    -
      -
    • lastPower
      • -
    • PowerTotal
      • -
    • Power_L1
      • -
    • Power_L2
      • -
    • Power_L3
      • -
    • Interval
      • -
    -
    Example:
    - get <name> lastPower

    - -
- -=end html -=cut -