FHEM USB-WUE Zugriff auf ELV sensoren ASH2200


Das ELV Modul WUE ist nicht in FHEM unterstützt. Es war aber gar nicht so schwierig ein bestehendes Module anzupassen (siehe unten 70_USBWUE.pm) und schon kann ich nun auf meinem PC die Wetterdaten meiner 3 ASH2200 sensoren (Temperature und relative Feuchtigkeit) empfangen und den Taupunkt und die absolute Luftfeuchtigkeit berechnen..



In FHEM.CFG sind folgende Einträge:


define USBWUE USBWUE COM5

define FileLog_USBWUE_0001 FileLog ./log/USBWUE_0001-%Y.log USBWUE.*A:\s0(0|1|3)
attr FileLog_USBWUE_0001 logtype temp4relhum6:Plot,text
attr FileLog_USBWUE_0001 room USBWUE


define USBWUE_00 USBWUE 00
attr USBWUE_00 room USBWUE
define FileLog_USBWUE_00 FileLog ./log/USBWUE_00-%Y.log USBWUE.*A:\s00
attr FileLog_USBWUE_00 logtype temp4relhum6dew8:Plot,text
attr FileLog_USBWUE_00 room USBWUE


define USBWUE_01 USBWUE 01
attr USBWUE_01 room USBWUE
define FileLog_USBWUE_01 FileLog ./log/USBWUE_01-%Y.log USBWUE.*A:\s01
attr FileLog_USBWUE_01 logtype temp4relhum6dew8:Plot,text
attr FileLog_USBWUE_01 room USBWUE


define USBWUE_03 USBWUE 03
attr USBWUE_03 room USBWUE
define FileLog_USBWUE_03 FileLog ./log/USBWUE_03-%Y.log USBWUE.*A:\s03
attr FileLog_USBWUE_03 logtype temp4relhum6dew8:Plot,text
attr FileLog_USBWUE_03 room USBWUE

Mit Hilfe des plot files temp4relhum6dew8.gplot


#
# Display the measured temp and the humidity.
# FileLog definition: 
# define <filelogname> FileLog /var/log/fhem/hmsname-%Y.log <hmsname>:T:.*
#
# Logfile record example:
2012-12-18_21:27:47 USBWUE   T: 4.9  H: 87.3  D: 3.0  AH: 5.9  A: 01

# Attribute 'small' is useful for gnuplot/-scroll only,
# if plotsize is less than 800,400
#set terminal png transparent small size <SIZE> crop

set terminal png transparent truecolor rounded medium size <SIZE> enhanced

set output '<OUT>.png'
set xdata time
set timefmt "%Y-%m-%d_%H:%M:%S"
set xlabel " "
set ytics nomirror
set y2tics
#set ytics
set title '<L1>'
set grid xtics y2tics

set y2label "Temperature in C"
set ylabel "Humidity (%)"

  
#FileLog 4:T\x3a:0:
#FileLog 6:H\x3a:0:
#FileLog 8:D\x3a:0:

plot \
  "< awk '/T:\s01/ {print $1, $4}' <IN>" using 1:2 ls  8 axes x1y2 title 'Temperature' with lines, \
  "< awk '/D:\s01/ {print $1, $8}' <IN>" using 1:2                 title 'Dewpoint' with lines, \
  "< awk '/H:\s00/ {print $1, $6}' <IN>" using 1:2 ls 6 axes x1y1 title 'Humidity' with lines


zeige ich Temperatur, Taupunkt und relative Feuchtigkeit an:

Convert to weblink




Mit Hilfe des plot files temp4relhum6dew8.gplot
zeige ich die absolute Feuchtigkeit aller 3 Sensoren in einem Diagram:







#
# Display the measured temp and the humidity.
# FileLog definition: 
# define <filelogname> FileLog /var/log/fhem/hmsname-%Y.log <hmsname>:T:.*
#
# Logfile record example:
2012-12-18_21:27:47 USBWUE   T: 4.9  H: 87.3  D: 3.0  AH: 5.9  A: 01

# Attribute 'small' is useful for gnuplot/-scroll only,
# if plotsize is less than 800,400
#set terminal png transparent small size <SIZE> crop

set terminal png transparent truecolor rounded medium size <SIZE> enhanced

set output '<OUT>.png'
set xdata time
set timefmt "%Y-%m-%d_%H:%M:%S"
set xlabel " "
set ytics nomirror
set y2tics
#set ytics
set title '<L1>'
set grid xtics y2tics

set y2label "absolute Humidity in g per m^3"


#FileLog 10:A\x3a\s00:0:
#FileLog 10:A\x3a\s01:0:
#FileLog 10:A\x3a\s03:0:

plot \
  "< awk '/A:\s00/ {print $1, $10}' <IN>" using 1:2  axes x1y2 title 'Sensor 0' with lines, \
  "< awk '/A:\s01/ {print $1, $10}' <IN>" using 1:2  axes x1y2 title 'Sensor 1' with lines, \
  "< awk '/A:\s03/ {print $1, $10}' <IN>" using 1:2  axes x1y2 title 'Sensor 3' with lines






#################################################################################
# 70_USBWUE.pm
# Module for FHEM to receive sensors via ELV USB-WUE
#
# derived from previous 70_USBWX.pm version
#
# Daniel W. from Bern 2012
#
#  This script is distributed in the hope that it will be useful,
#  but WITHOUT ANY WARRANTY; without even the implied warranty of
#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
#
##############################################

package main;

use strict;
use warnings;
#use Device::SerialPort;
use Win32::SerialPort;

#####################################
sub
USBWUE_Initialize($)
{
  my ($hash) = @_;

  $hash->{ReadFn}  = "USBWUE_Read";
  $hash->{ReadyFn} = "USBWUE_Ready"; 
  # Normal devices 
  $hash->{DefFn}   = "USBWUE_Define";
  $hash->{UndefFn} = "USBWUE_Undef"; 

  $hash->{GetFn} = "USBWUE_Get";
  $hash->{SetFn} = "USBWUE_Set"; 


  $hash->{StateFn} = "USBWUE_SetState";

  #$hash->{Match}     = ".*";

  #$hash->{AttrList}= "model:USB-WDE1 loglevel:0,1,2,3,4,5,6";
  $hash->{AttrList}= "loglevel:0,1,2,3,4,5,6";

  $hash->{ShutdownFn} = "USBWUE_Shutdown";

}

#####################################
sub
USBWUE_Define($$)
{
  my ($hash, $def) = @_;
  my @a = split("[ \t][ \t]*", $def);
          
  return "wrong syntax: 'define <name> USBWUE <devicename>' or define <name> USBWUE <code> [<corr1>...<corr4>]"
    if(@a < 3);
          
  if ($a[2] =~/^[0-9].*/) {
# define <name> USBWUE <code> [<corr1>...<corr4>]
  return "wrong syntax: define <name> USBWUE <code> [corr1...corr4]"
            if(int(@a) < 3 || int(@a) > 7);
  return "Define $a[0]: wrong CODE format: valid is 0 - 8"
                if($a[2] !~ m/^0+[0-8]$/);

Log 1,"USBWUE_Define def=$def";

  my $name = $a[0];
  my $code = $a[2];

  $hash->{CODE} = $code;
  $hash->{corr1} = ((int(@a) > 3) ? $a[3] : 0);
  $hash->{corr2} = ((int(@a) > 4) ? $a[4] : 0);
  $hash->{corr3} = ((int(@a) > 5) ? $a[5] : 0);
  $hash->{corr4} = ((int(@a) > 6) ? $a[6] : 0);
  $modules{USBWUE}{defptr}{$code} = $hash;


  } else {
  # define <name> USBWUE <devicename>

  return "wrong syntax: define <name> USBWUE <devicename>"
     if(@a != 3);

  USBWUE_CloseDev($hash);

  my $name = $a[0];
  my $dev = $a[2];
          
 if($dev eq "none") {
   Log 1, "USBWUE $name device is none, commands will be echoed only";
    $attr{$name}{dummy} = 1;
    return undef;
  }

  $hash->{DeviceName} = $dev;
  my $ret = USBWUE_OpenDev($hash, 0);
return $ret;
  }
  return undef;


#####################################
sub
USBWUE_OpenDev($$)
{
  my ($hash, $reopen) = @_;
  my $dev = $hash->{DeviceName};
  my $name = $hash->{NAME};
  my $po;

  #Log 1, "USBWUE opening $name device $dev reopen = $reopen";

  Log 3, "USBWUE opening $name device $dev"
    if(!$reopen); 

  if ($^O=~/Win/) {
   require Win32::SerialPort;
   $po = new Win32::SerialPort ($dev);
  } else {
     require Device::SerialPort;
     $po = new Device::SerialPort ($dev);
  } 

  if(!$po) {
   return undef if($reopen);
   Log(2, "USBWUE Can't open $dev: $!");
   $readyfnlist{"$name.$dev"} = $hash;
   $hash->{STATE} = "disconnected";
   return "";
  }

  $hash->{USBWUE} = $po;

  if( $^O =~ /Win/ ) {
   $readyfnlist{"$name.$dev"} = $hash;
  } else {
   $hash->{FD} = $po->FILENO;
   delete($readyfnlist{"$name.$dev"});
   $selectlist{"$name.$dev"} = $hash;
  } 

  $po->baudrate(4800) || Log 1, "USBWUE could not set baudrate";
  $po->databits(8) || Log 1, "USBWUE could not set databits";
  $po->parity('none') || Log 1, "USBWUE could not set parity";
  $po->stopbits(1) || Log 1, "USBWUE could not set stopbits";
  $po->handshake('none') || Log 1, "USBWUE could not set handshake";

  $po->lookclear || Log 1, "USBWUE could not set lookclear";

  $po->are_match(pack( 'H[18]', '0000000000020ca201' ));

  $po->write_settings || Log 1, "USBWUE could not write_settings $dev";

  if($reopen) {
      Log 1, "USBWUE $dev reappeared ($name)";
  } else {
      Log 2, "USBWUE opened device $dev";
  } 

    $hash->{po} = $po;
    $hash->{socket} = 0;

  $hash->{STATE}=""; # Allow InitDev to set the state
  my $ret = USBWUE_DoInit($hash);

  if($ret) {
    # try again
    Log 1, "USBWUE Cannot init $dev, at first try. Trying again.";
    my $ret = USBWUE_DoInit($hash);
    if($ret) {
      USBWUE_CloseDev($hash);
      Log 1, "USBWUE Cannot init $dev, ignoring it";
      return "USBWUE Error Init string.";
    }
  } 

  DoTrigger($name, "CONNECTED") if($reopen);

  #return undef;
  return $ret;
}

########################
sub
USBWUE_CloseDev($)
{
  my ($hash) = @_;
  my $name = $hash->{NAME};
  my $dev = $hash->{DeviceName};

  return if(!$dev);

  Log 1, "USBWUE: closing $dev";

  $hash->{USBWUE}->close() ;
  delete($hash->{USBWUE});

  delete($selectlist{"$name.$dev"});
  delete($readyfnlist{"$name.$dev"});
  delete($hash->{FD});


#####################################
sub
USBWUE_Ready($)
{
  my ($hash) = @_;

  return USBWUE_OpenDev($hash, 1) if($hash->{STATE} eq "disconnected");

  # This is relevant for windows/USB only
  my $po = $hash->{USBWUE};
  my ($BlockingFlags, $InBytes, $OutBytes, $ErrorFlags) = $po->status;

  
  return ($InBytes>0);


#####################################
sub
USBWUE_SetState($$$$)
{
  my ($hash, $tim, $vt, $val) = @_;
  return undef;
}

#####################################
sub
USBWUE_Clear($)
{
my $hash = shift;
my $buf;

# clear buffer:
if($hash->{USBWUE}) 
   {
   while ($hash->{USBWUE}->lookfor()) 
      {
      $buf = USBWUE_SimpleRead($hash);
      }
   }

return $buf;


#####################################
sub
USBWUE_DoInit($)
{
my $hash = shift;
my $name = $hash->{NAME}; 
my $init;
my $buf;

USBWUE_Clear($hash); 

$init = pack( 'H[08]', '0202fb00' ); #hexmode
USBWUE_SimpleWrite($hash, $init); 
$init = pack( 'H[08]', '0202f201' ); #Wetterdaten sofort ausgeben
USBWUE_SimpleWrite($hash, $init); 

return undef; 
}

#####################################
sub USBWUE_Undef($$)
{
my ($hash, $arg) = @_;
my $name = $hash->{NAME};
delete $hash->{FD};
$hash->{STATE}='close';
$hash->{USBWUE}->close() if($hash->{USBWUE});
Log 2, "$name shutdown complete";
return undef;


#####################################
# called from the global loop, when the select for hash->{FD} reports data
sub
USBWUE_Read($)           
{
  my ($hash) = @_;
  my $name = $hash->{NAME};

  Log 4, "USBWUE Read State:$hash->{STATE}";
  
  
   my $c = $hash->{USBWUE}->lookfor();

   if (defined($c) && (length($c) > 0 )) {   
     Log 4,  " raw data: " . unpack("H[28]", $c);
   } 
   
   if (defined($c) && (length($c) == 5 )) {

     my $addr = unpack("H[2]", substr $c, 0, 1) ;
     my $temperature = unpack('s', pack( 'S', unpack("n", substr $c, 1, 2)))/10;
     my $humidity = unpack("n", substr $c, 3, 2)/10;
     my ($af, $td) = af_td($temperature, $humidity);


my $device_name = $addr;  

 
my $def = $modules{USBWUE}{defptr}{"$device_name"};
if(!$def) {
Log 3, "USBWUE: Unknown device USBWUE_$device_name, please define it";
#Log 1, "USBWUE: Unknown device USBWUE_$device_name, please define it";
    my $ret = "UNDEFINED USBWUE_$device_name USBWUE $device_name";
DoTrigger("global", $ret);
return undef;
  }  


my $tm = TimeNow();
my $sensor = "";
my $val = " ";
my $current;
my $n = 0;

$current = $temperature;
$val .= " T: ".$current."  ";
$sensor = "temperature";
$def->{READINGS}{$sensor}{TIME} = $tm;
$def->{READINGS}{$sensor}{VAL} = $current;
$def->{CHANGED}[$n++] = $sensor . ": " . $current;

$current = $humidity;
$val .= "H: ".$current."  ";
$sensor = "humidity";
$def->{READINGS}{$sensor}{TIME} = $tm;
$def->{READINGS}{$sensor}{VAL} = $current;
$def->{CHANGED}[$n++] = $sensor . ": " . $current;

my $dewpoint = $td;
$current = $dewpoint;
$val .= "D: ".$current."  ";
$sensor = "dewpoint";
$def->{READINGS}{$sensor}{TIME} = $tm;
$def->{READINGS}{$sensor}{VAL} = $current;
$def->{CHANGED}[$n++] = $sensor . ": " . $current;

my $absolute_humidity = $af;
$current = $absolute_humidity;
$val .= "AH: ".$current."  ";
$sensor = "abs_humidity";

$def->{READINGS}{$sensor}{TIME} = $tm;
$def->{READINGS}{$sensor}{VAL} = $current;
$def->{CHANGED}[$n++] = $sensor . ": " . $current;

$val .= "A: " . $addr;


$def->{STATE} = $val;
    $def->{TIME} = $tm;
    $def->{CHANGED}[$n++] = $val;

    # Log GetLogLevel($name,1), "USBWUE ". $hash->{NAME} . ": $val";
    addEvent($hash, $val);

  DoTrigger($name, undef); 
  }



#####################################
sub
USBWUE_Shutdown($)
{
  my ($hash) = @_;
  return undef;
}

#####################################
sub
USBWUE_Set($@)
{
my ($hash, @a) = @_;

my $msg;
my $name=$a[0];
my $reading= $a[1];
$msg="$name => No Set function ($reading) implemented";
return $msg;
}

#####################################
sub
USBWUE_Get($@)
{
my ($hash, @a) = @_;

my $msg;
my $name=$a[0];
my $reading= $a[1];
$msg="$name => No Get function ($reading) implemented";
Log 1,$msg;
return $msg;


########################
sub
USBWUE_SimpleRead($)
{
my ($hash) = @_;
my $buf;

if($hash->{USBWUE}) 
   {
   $buf = $hash->{USBWUE}->read(1) ;
   if (!defined($buf) || length($buf) == 0) 
      {
      $buf = $hash->{USBWUE}->read(1) ;
      }
#   Log 4, "USBWUE SimpleRead=>$buf";
   return $buf;
   }

return undef; 
}

########################
sub
USBWUE_SimpleWrite(@)
{
my ($hash, $msg) = @_;
return if(!$hash);
$hash->{USBWUE}->write($msg) if($hash->{USBWUE});
Log 4, "USBWUE SimpleWrite $msg";
select(undef, undef, undef, 0.001);






# -----------------------------
# Dewpoint calculation.
sub 
af_td ($$)
{
# Formeln von http://www.wettermail.de/wetter/feuchte.html

# r = relative Luftfeuchte
# T = Temperatur in °C
        my ($T, $rh) = @_;

# a = 7.5, b = 237.3 für T >= 0
# a = 9.5, b = 265.5 für T < 0 über Eis (Frostpunkt)  
        my $a = ($T > 0) ? 7.5 : 9.5;
        my $b = ($T > 0) ? 237.3 : 265.5;

# SDD = Sättigungsdampfdruck in hPa  
# SDD(T) = 6.1078 * 10^((a*T)/(b+T))
  my $SDD = 6.1078 * 10**(($a*$T)/($b+$T));
# DD = Dampfdruck in hPa
# DD(r,T) = r/100 * SDD(T)
  my $DD  = $rh/100 * $SDD;  
# AF(r,TK) = 10^5 * mw/R* * DD(r,T)/TK; AF(TD,TK) = 10^5 * mw/R* * SDD(TD)/TK
# R* = 8314.3 J/(kmol*K) (universelle Gaskonstante)
# mw = 18.016 kg (Molekulargewicht des Wasserdampfes)
# TK = Temperatur in Kelvin (TK = T + 273.15)
  my $AF  = (10**5) * (18.016 / 8314.3) * ($DD / (273.15 + $T));
  my $af  = sprintf( "%.1f",$AF); # Auf eine Nachkommastelle runden

# TD(r,T) = b*v/(a-v) mit v(r,T) = log10(DD(r,T)/6.1078)  
  my $v   =  log10($DD/6.1078);
  my $TD  = $b*$v/($a-$v);
  my $td  = sprintf( "%.1f",$TD); # Auf eine Nachkommastelle runden

# TD = Taupunkttemperatur in °C 
# AF = absolute Feuchte in g Wasserdampf pro m3 Luft 
        return($af, $td);
  
}

#####################################
sub
USBWUE_Disconnected($)
{
  my $hash = shift;
  my $dev = $hash->{DeviceName};
  my $name = $hash->{NAME};
 
  return if(!defined($hash->{FD})); # Already deleted

  Log 1, "USBWUE dev='$dev' name='$name' disconnected, waiting to reappear";
  USBWUE_CloseDev($hash);
  $readyfnlist{"$name.$dev"} = $hash; # Start polling
  $hash->{STATE} = "disconnected";

  # Without the following sleep the open of the device causes a SIGSEGV,
  # and following opens block infinitely. Only a reboot helps.
  sleep(5);

  DoTrigger($name, "DISCONNECTED");




1;

Keine Kommentare:

Kommentar veröffentlichen