mirror of
https://github.com/fhem/fhem-mirror.git
synced 2025-01-31 18:59:33 +00:00
47_OBIS:First release - Module for smartmeters
git-svn-id: https://svn.fhem.de/fhem/trunk@10826 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
icinger
parent
e3c25e4f8f
commit
2a481a78be
369
fhem/FHEM/47_OBIS.pm
Normal file
369
fhem/FHEM/47_OBIS.pm
Normal file
@ -0,0 +1,369 @@
|
||||
###############################################
|
||||
#
|
||||
# 47_OBIS.pm
|
||||
#
|
||||
#
|
||||
# $Id$
|
||||
|
||||
package main;
|
||||
use strict;
|
||||
use warnings;
|
||||
use Time::HiRes qw(gettimeofday usleep);
|
||||
|
||||
my $buffer = "";
|
||||
my $Zeit = 0;
|
||||
my $speed=0;
|
||||
my %channels = ( "21"=>"energy_L1",
|
||||
"41"=>"energy_L2",
|
||||
"61"=>"energy_L3",
|
||||
"32"=>"voltage_L1",
|
||||
"52"=>"voltage_L2",
|
||||
"72"=>"voltage_L3",
|
||||
"31"=>"power_L1",
|
||||
"51"=>"power_L2",
|
||||
"71"=>"power_L3",
|
||||
"2"=>"feed_L1",
|
||||
"4"=>"feed_L2",
|
||||
"6"=>"feed_L3",
|
||||
"1"=>"energy_current");
|
||||
|
||||
my %devices ;
|
||||
|
||||
#####################################
|
||||
sub OBIS_Initialize($)
|
||||
{
|
||||
my ($hash) = @_;
|
||||
|
||||
require "$attr{global}{modpath}/FHEM/DevIo.pm";
|
||||
|
||||
$hash->{Match} = ".*";
|
||||
$hash->{ReadFn} = "OBIS_Read";
|
||||
$hash->{ReadyFn} = "OBIS_Ready";
|
||||
$hash->{DefFn} = "OBIS_Define";
|
||||
$hash->{ParseFn} = "OBIS_Parse";
|
||||
$hash->{UndefFn} = "OBIS_Undef";
|
||||
$hash->{AttrFn} = "OBIS_Attr";
|
||||
$hash->{AttrList}= "do_not_notify:1,0 interval offset_feed offset_energy IODev channels ".
|
||||
$readingFnAttributes;
|
||||
Log3 $hash,3,"Initialize done...";
|
||||
}
|
||||
|
||||
#####################################
|
||||
sub OBIS_Define($$)
|
||||
{
|
||||
my ($hash, $def) = @_;
|
||||
my @a = split("[ \t][ \t]*", $def);
|
||||
|
||||
return 'wrong syntax: define <name> OBIS devicename@baudrate[,databits,parity,stopbits]|none [MeterType]'
|
||||
if(@a < 3);
|
||||
|
||||
Log3 $hash,3,"Define called...";
|
||||
DevIo_CloseDev($hash);
|
||||
RemoveInternalTimer($hash);
|
||||
my $name = $a[0];
|
||||
my $dev = $a[2];
|
||||
my $type = $a[3]//"Unknown";
|
||||
$hash->{DeviceName} = $dev;
|
||||
$hash->{MeterType}=$type if (defined($type));
|
||||
my $device_name = "OBIS_".$name;
|
||||
$modules{OBIS}{defptr}{$device_name} = $hash;
|
||||
Log3 $hash,4,"Starting $name with Device $dev (Type $type).";
|
||||
|
||||
if($dev eq "none") {
|
||||
AssignIoPort($hash);
|
||||
Log3 ($hash,1, "OBIS device is none, commands will be echoed only");
|
||||
return undef;
|
||||
}
|
||||
my $baudrate;
|
||||
my $devi;
|
||||
($devi, $baudrate) = split("@", $dev);
|
||||
if($baudrate =~ m/(\d+)(,([78])(,([NEO])(,([012]))?)?)?/) {
|
||||
$baudrate = $1 if(defined($1));
|
||||
}
|
||||
if ($baudrate==300) {$speed="0"}
|
||||
if ($baudrate==600) {$speed="1"}
|
||||
if ($baudrate==1200) {$speed="2"}
|
||||
if ($baudrate==2400) {$speed="3"}
|
||||
if ($baudrate==4800) {$speed="4"}
|
||||
if ($baudrate==9600) {$speed="5"}
|
||||
|
||||
%devices = (
|
||||
# Name, Init-String, repeat,2ndInit
|
||||
"Unknown"=>[ "", -1,""],
|
||||
"MT681"=>[ "", -1,""],
|
||||
# Voltcraft VSM 102
|
||||
"VSM102"=>["/?!".chr(13).chr(10), 1,chr(6)."0".$speed."0".chr(13).chr(10)],
|
||||
# Landis & Gyr E110
|
||||
"E110"=>["/?!".chr(13).chr(10), 1,chr(6)."0".$speed."0".chr(13).chr(10)],
|
||||
);
|
||||
Log3 $hash,4,"Baudrate is $baudrate";
|
||||
|
||||
InternalTimer(gettimeofday()+2, "GetUpdate", $hash, 0) if (exists $devices{$type});
|
||||
Log3 ($hash,4,"Internal timer set.") if (exists $devices{$type});
|
||||
|
||||
Log3 $hash,4,"Opening device...";
|
||||
return DevIo_OpenDev($hash, 0, "OBIS_Init");
|
||||
}
|
||||
|
||||
# Update-Routine
|
||||
sub GetUpdate($)
|
||||
{
|
||||
my ($hash) = @_;
|
||||
my $name = $hash->{NAME};
|
||||
my $type= $hash->{MeterType};
|
||||
if (!exists $devices{$type}) {return undef;}
|
||||
DevIo_SimpleWrite($hash,$devices{$type}[0],undef) ;
|
||||
InternalTimer(gettimeofday()+AttrVal($name,"interval",600), "GetUpdate", $hash, 1) if ($devices{$type}[1]!=-1);
|
||||
}
|
||||
|
||||
sub OBIS_Init($)
|
||||
{
|
||||
#nothing here yet
|
||||
my ($hash) = @_;
|
||||
my $name = $hash->{NAME};
|
||||
my $type= $hash->{MeterType};
|
||||
my $dev= $hash->{DeviceName};
|
||||
($dev, undef) = split("@", $dev);
|
||||
Log 4,"Device opened and initialized...";
|
||||
return undef;
|
||||
}
|
||||
#####################################
|
||||
sub OBIS_Undef($$)
|
||||
{
|
||||
my ($hash, $arg) = @_;
|
||||
RemoveInternalTimer($hash);
|
||||
DevIo_CloseDev($hash) if $hash->{DeviceName} != "none";
|
||||
return undef;
|
||||
}
|
||||
|
||||
#####################################
|
||||
sub OBIS_Read($)
|
||||
{
|
||||
my ($hash) = @_;
|
||||
my $name = $hash->{NAME};
|
||||
my $tn = TimeNow();
|
||||
|
||||
my $buf = DevIo_SimpleRead($hash);
|
||||
OBIS_Parse($hash,$buf);
|
||||
return(undef);
|
||||
}
|
||||
|
||||
sub OBIS_Parse($$)
|
||||
{
|
||||
my ($hash, $buf) = @_;
|
||||
$buffer .= $buf;
|
||||
return undef if(index($buffer,chr(13).chr(10)) == -1);
|
||||
my $type= $hash->{MeterType};
|
||||
my $name = $hash->{NAME};
|
||||
readingsBeginUpdate($hash);
|
||||
while(index($buffer,chr(13).chr(10)) ne -1)
|
||||
{
|
||||
my $rmsg="";
|
||||
$rmsg = substr($buffer, 0, index($buffer,chr(13).chr(10)));
|
||||
Log3 $hash,5,"Msg-Parse: $rmsg";
|
||||
if ($rmsg=~ /.*\/(.*)/) {
|
||||
DevIo_SimpleWrite($hash,$devices{$type}[2],undef) if (!$devices{$type}[2] eq "");
|
||||
}
|
||||
|
||||
if($rmsg=~/^([23456789]+)-.*/) {
|
||||
Log3 $hash,3,"Unknown OBIS-Message, please report: $rmsg";
|
||||
}
|
||||
# Summe eingespeister Phase: 1-0:2.1.7*255(07568.01*kWh)
|
||||
if ($rmsg=~ /1-0:([246])\.1\.7\*255\((-?\d+\.?\d*).*/) {
|
||||
my $L=$1;
|
||||
if (exists $channels{$1}) {$L="sum_".$channels{$1}} else {$L="Unknown_Channel"};
|
||||
Log3 $hash,5,"Set reading ".$L." to value ".($2+0);
|
||||
readingsBulkUpdate($hash, $L,$2+0);
|
||||
};
|
||||
|
||||
# Einspeisung und Bezug der einzelnen Phasen
|
||||
if ($rmsg=~ /1-0:(\d+)\.7\.\d*\*\d*\((-?\d+\.?\d*).*/) {
|
||||
my $L=$1;
|
||||
if (exists $channels{$1}) {$L=$channels{$1}} else {$L="Unknown_Channel"};
|
||||
Log3 $hash,5,"Set reading ".$L." to value ".($2+0);
|
||||
readingsBulkUpdate($hash, $L,$2+0);
|
||||
};
|
||||
|
||||
# Seriennummer
|
||||
if ($rmsg=~ /0-0:96\.1\.255\*255\((.*?)\).*/) {
|
||||
Log3 $hash,5,"Set reading Serial to value ".$1;
|
||||
readingsBulkUpdate($hash, "Serial" ,$1); }
|
||||
|
||||
# Eigentumsnummer --> 1-0:0.0.0*255(GETTONE)
|
||||
if ($rmsg=~ /1-0:0\.0\.0\*255\((.*?)\).*/) {
|
||||
Log3 $hash,5,"Set reading Owner to value ".$1;
|
||||
readingsBulkUpdate($hash, "Owner" ,$1); }
|
||||
|
||||
# Statusbyte
|
||||
if ($rmsg=~ /1-0:96\.5\.5\*255\((.*?)\).*/) {
|
||||
Log3 $hash,5,"Set reading Status to value ".$1;
|
||||
readingsBulkUpdate($hash, "Status" ,$1); }
|
||||
|
||||
#Version
|
||||
if ($rmsg=~ /\/(.*)/) {
|
||||
Log3 $hash,5,"Set reading Version to value ".$1;
|
||||
readingsBulkUpdate($hash, "Version" ,$1); }
|
||||
|
||||
# Zählerstand --> 1-0:1.8.0*255(17483.88*kWh)
|
||||
if ($rmsg=~ /1-0:([12])\.8\.\d\*255\((-?\d+\.?\d*).*/) {
|
||||
if($1==1) {
|
||||
Log3 $hash,5,"Set reading energy_total to value ".$2." with offset ".AttrVal($name,"offset_energy",0);
|
||||
readingsBulkUpdate($hash, "energy_total" ,$2 +AttrVal($name,"offset_energy",0));
|
||||
} elsif ($1==2) {
|
||||
Log3 $hash,5,"Set reading feed_total to value ".$2." with offset ".AttrVal($name,"offset_energy",0);
|
||||
readingsBulkUpdate($hash, "feed_total" ,$2 +AttrVal($name,"offset_feed",0));
|
||||
}
|
||||
}
|
||||
$buffer = substr($buffer, index($buffer,chr(13).chr(10))+2);;
|
||||
}
|
||||
readingsEndUpdate($hash,1);
|
||||
return $name;
|
||||
}
|
||||
|
||||
#####################################
|
||||
sub OBIS_Ready($)
|
||||
{
|
||||
my ($hash) = @_;
|
||||
|
||||
return DevIo_OpenDev($hash, 1, "OBIS_Init")
|
||||
if($hash->{STATE} eq "disconnected");
|
||||
|
||||
# This is relevant for windows/USB only
|
||||
my $po = $hash->{USBDev};
|
||||
my ($BlockingFlags, $InBytes, $OutBytes, $ErrorFlags) = $po->status;
|
||||
return ($InBytes>0);
|
||||
}
|
||||
|
||||
sub OBIS_Attr(@)
|
||||
{
|
||||
my ($cmd,$name,$aName,$aVal) = @_;
|
||||
# $cmd can be "del" or "set"
|
||||
# $name is device name
|
||||
# aName and aVal are Attribute name and value
|
||||
my $hash = $defs{$name};
|
||||
|
||||
if ($cmd eq "set") {
|
||||
if ($aName eq "channels") {
|
||||
%channels = eval $aVal;
|
||||
if ($@) {
|
||||
Log3 $name, 3, "X: Invalid regex in attr $name $aName $aVal: $@";
|
||||
}
|
||||
}
|
||||
if ($aName eq "interval") {
|
||||
if ($aVal=~/^[1-9][0-9]*$/) {
|
||||
RemoveInternalTimer($hash);
|
||||
my $type= $hash->{MeterType};
|
||||
InternalTimer(gettimeofday()+2, "GetUpdate", $hash, 1) if ($devices{$type}[1]!=-1);
|
||||
} else {
|
||||
Log3 $name, 3, "$name: attr interval must be a number -> $aVal";
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
return undef;
|
||||
}
|
||||
|
||||
#####################################
|
||||
|
||||
"Cogito, ergo sum.";
|
||||
|
||||
=pod
|
||||
=item device
|
||||
=begin html
|
||||
|
||||
<a name="OBIS"></a>
|
||||
<h3>OBIS</h3>
|
||||
This module is for SmartMeter, that report thier data in OBIS-Standard.
|
||||
<br>
|
||||
<b>Define</b>
|
||||
<code>define <name> OBIS device|none [MeterType] </code><br>
|
||||
<br>
|
||||
<device> specifies the serial port to communicate with the smartmeter.
|
||||
Normally on Linux the device will be named /dev/ttyUSBx, where x is a number.
|
||||
For example /dev/ttyUSB0. You may specify the baudrate used after the @ char.<br>
|
||||
<br><br>
|
||||
Optional:MeterType can be of
|
||||
<ul><li>VSM102 -> Voltcraft VSM102</li>
|
||||
<li>E110 -> Landis&&;Gyr E110</li></ul>
|
||||
<br>
|
||||
Example: <br>
|
||||
<code>define myPowerMeter OBIS /dev/ttyPlugwise@@9600,7,E,1 VSM102</code>
|
||||
<br>
|
||||
<br>
|
||||
|
||||
<b>Attributes</b>
|
||||
<ul><li>
|
||||
<code>offset_feed <br>offset_energy</code><br>
|
||||
If your smartmeter is BEHIND the meter of your powersupplier, then you can hereby adjust
|
||||
the total-reading of your SM to that of your official one.
|
||||
<br><br>
|
||||
</li>
|
||||
<li>
|
||||
<code>channels</code><br>
|
||||
With this, you can adjust the reported channels.
|
||||
OBIS-Standard is
|
||||
<ul>
|
||||
<li>1-->Sum of all phases</li>
|
||||
<li>21-->Phase 1</li>
|
||||
<li>41-->Phase 2</li>
|
||||
<li>61-->Phase 3</li></ul>
|
||||
You can change that for example to:
|
||||
<code>attr myOBIS channels "2"=>"L1", "4"=>"L2", "6"=>"L3"></code>
|
||||
<br><br></li><li>
|
||||
<code>interval</code><br>
|
||||
The polling-interval in seconds (only if metertype is set)
|
||||
</li>
|
||||
<br>
|
||||
</ul>
|
||||
|
||||
=end html
|
||||
|
||||
=begin html
|
||||
|
||||
|
||||
<a name="OBIS"></a>
|
||||
<h3>OBIS</h3>
|
||||
Modul für Smartmeter, die ihre Daten im OBIS-Standard senden.
|
||||
<br>
|
||||
<b>Define</b>
|
||||
<code>define <name> OBIS device|none [MeterType] </code><br>
|
||||
<br>
|
||||
<device> gibt den seriellen Port an.
|
||||
<br><br>
|
||||
Optional:MeterType kann sein:
|
||||
<ul><li>VSM102 -> Voltcraft VSM102</li>
|
||||
<li>E110 -> Landis&&;Gyr E110</li></ul>
|
||||
<br>
|
||||
Beispiel: <br>
|
||||
<code>define myPowerMeter OBIS /dev/ttyPlugwise@@9600,7,E,1 VSM102</code>
|
||||
<br>
|
||||
<br>
|
||||
|
||||
<b>Attribute</b>
|
||||
<ul><li>
|
||||
<code>offset_feed <br>offset_energy</code><br>
|
||||
Wenn das Smartmeter hinter einem Zähler des EVU's sitzt, kann hiermit der Zähler des
|
||||
Smartmeters an den des EVU's angepasst werden.
|
||||
<br><br>
|
||||
</li>
|
||||
<li>
|
||||
<code>channels</code><br>
|
||||
Hiermit können die einzelnen Kanal-Readings angepasst werden.
|
||||
OBIS-Standard ist
|
||||
<ul>
|
||||
<li>1-->Summe aller Phasen</li>
|
||||
<li>21-->Phase 1</li>
|
||||
<li>41-->Phase 2</li>
|
||||
<li>61-->Phase 3</li></ul>
|
||||
Beispiel:
|
||||
<code>attr myOBIS channels "2"=>"L1", "4"=>"L2", "6"=>"L3"></code>
|
||||
<br><br></li><li>
|
||||
<code>interval</code><br>
|
||||
Abrufinterval der Daten. (greift nur, wenn ein metertype angegeben wurde)
|
||||
</li>
|
||||
<br>
|
||||
</ul>
|
||||
|
||||
=end html_DE
|
||||
|
||||
=cut
|
||||
Loading…
Reference in New Issue
Block a user