Thread: [Openautomation-svn] SF.net SVN: openautomation:[348] wiregate

SourceForge Headquarters 1320 Columbia Street Suite 310 San Diego, CA 92101 +1 (858) 422-6466

Revision: 348
          http://openautomation.svn.sourceforge.net/openautomation/?rev=348&view=rev
Author:   makki1
Date:     2011-05-28 23:19:24 +0000 (Sat, 28 May 2011)

Log Message:
-----------
commit WireGate-Plugins, incomplete..

Added Paths:
-----------
    wiregate/
    wiregate/plugin/
    wiregate/plugin/generic/
    wiregate/plugin/generic/Alarmanlage
    wiregate/plugin/generic/Atmolight.pl
    wiregate/plugin/generic/Blinker
    wiregate/plugin/generic/DMX-Plugin.pl
    wiregate/plugin/generic/DaemonStartStop
    wiregate/plugin/generic/Datenlogger-PV-Kaco-Prolog
    wiregate/plugin/generic/Denon-Plugin.pl
    wiregate/plugin/generic/Dreambox-Text
    wiregate/plugin/generic/EIB-Watchdog
    wiregate/plugin/generic/EiWoMiSa
    wiregate/plugin/generic/Googleweather
    wiregate/plugin/generic/Highspeed
    wiregate/plugin/generic/M-Bus
    wiregate/plugin/generic/Nacht-Nachdimmen
    wiregate/plugin/generic/PI-Regler
    wiregate/plugin/generic/Ping-check
    wiregate/plugin/generic/Prowl.pl
    wiregate/plugin/generic/RFID-Leser
    wiregate/plugin/generic/Roomba-Graph
    wiregate/plugin/generic/Schwellwert
    wiregate/plugin/generic/Taupunkt.pl
    wiregate/plugin/generic/Uhrzeit-vom-Bus
    wiregate/plugin/generic/WOL-1
    wiregate/plugin/generic/XBMC-Radio
    wiregate/plugin/generic/cul868
    wiregate/plugin/generic/mpg123_start
    wiregate/plugin/generic/mpg123_volume
    wiregate/plugin/generic/weather-denro1

Added: wiregate/plugin/generic/Alarmanlage
===================================================================

--- wiregate/plugin/generic/Alarmanlage	                        (rev 0)
+++ wiregate/plugin/generic/Alarmanlage	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,22 @@
+# Eigenen Aufruf-Zyklus auf 1T Sekunden setzen
+# Alarmanlage für arme ;)
+$plugin_info{$plugname.'_cycle'} = 86400; # egal..
+return;
+
+my $scharf_ga = "1/1/1";
+my $allowed_pa = "1.1.20";
+my $alarm_ga = "1/1/111";
+### Ende Definitionen
+
+if ($msg{'apci'} eq "A_GroupValue_Write" and $msg{'dst'} eq $scharf_ga) {
+   if (! $msg{'src'} eq $allowed_pa) {
+      # böser Bube hat von falscher Quelladresse gesendet
+      knx_write($alarm_ga,1,1);
+      return "Alarm! $msg{'src'} hat auf $scharf_ga gesendet";
+   }
+} else { # zyklischer Aufruf
+   # Plugin an Gruppenadresse "anmelden"
+   $plugin_subscribe{$scharf_ga}{$plugname} = 1;
+}
+
+return;

Added: wiregate/plugin/generic/Atmolight.pl
===================================================================
--- wiregate/plugin/generic/Atmolight.pl	                        (rev 0)
+++ wiregate/plugin/generic/Atmolight.pl	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,93 @@
+# Plugin Atmolight
+# Kommunikation via UDP - socat separat, muss an einen USB
+# Version: 0.1 2011-02-03
+
+# Eigenen Aufruf-Zyklus setzen (Initialisierung/zyklisches pr\xFCfen)
+$plugin_info{$plugname.'_cycle'} = 600;
+#return "broken";
+#if ($socket[$socknum]->opened) { $socket[$socknum]->close(); }
+#undef $socket[$socknum];
+
+##################
+### DEFINITION ###
+##################
+
+my $socknum = 121;                # Eindeutige Nummer des Sockets
+
+my $send_ip = "172.17.2.68"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $send_port = "50118"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $recv_ip = "172.17.2.203"; # Empfangsport (UDP, sie in Socket-Einstellungen)
+my $recv_port = "50117"; # Empfangsport (UDP, sie in Socket-Einstellungen)
+
+my $basega = "10/0/110";
+my $numgas = 15;
+# Startadresse
+# 0-2 alle(center?), 3-5 left 6-8 right, 9-11 = oben, 12-14 unten
+
+#######################
+### ENDE DEFINITION ###
+#######################
+
+# Hauptverarbeitung
+if (!$socket[$socknum]) { # socket erstellen
+    $socket[$socknum] = IO::Socket::INET->new(LocalPort => $recv_port,
+                              Proto => "udp",
+                              LocalAddr => $recv_ip,
+                              PeerPort  => $send_port,
+                              PeerAddr  => $send_ip,
+                              ReuseAddr => 1,
+                              Blocking => 0
+                               )
+             or return ("open of $recv_ip : $recv_port failed: $!");
+
+    $socksel->add($socket[$socknum]); # add socket to select
+
+    $plugin_socket_subscribe{$socket[$socknum]} = $plugname; # subscribe plugin
+    for my $chan ("center","left","right","top","bottom") {
+        $plugin_info{$plugname.'_R_'.$chan} = "00" unless $plugin_info{$plugname.'_R_'.$chan};
+        $plugin_info{$plugname.'_G_'.$chan} = "00" unless $plugin_info{$plugname.'_G_'.$chan};
+        $plugin_info{$plugname.'_B_'.$chan} = "00" unless $plugin_info{$plugname.'_B_'.$chan};
+    }
+    # fall through! return "opened Socket $socknum";
+} 
+
+if (%msg) { # telegramm vom KNX
+  if ($msg{'apci'} eq "A_GroupValue_Write") {
+     my $idx = str2addr($msg{'dst'}) - str2addr($basega);
+     my @col = ("R","G","B");
+     my @chan = ("center","left","right","top","bottom");
+     my $ret;
+     $plugin_info{$plugname.'_'.$col[$msg{'data'}%3].'_'.$chan[%3]} = $msg{'data'};
+     if ($idx==0) {
+            return "null";
+      } else {
+    for my $chan ("center","left","right","top","bottom") {
+        $ret = $plugin_info{$plugname.'_R_'.$chan} = "00" unless $plugin_info{$plugname.'_R_'.$chan};
+        $ret .= $plugin_info{$plugname.'_G_'.$chan} = "00" unless $plugin_info{$plugname.'_G_'.$chan};
+        $ret .= $plugin_info{$plugname.'_B_'.$chan} = "00" unless $plugin_info{$plugname.'_B_'.$chan};
+    }
+
+          return "dunno? recv KNX $msg{'dst'} $msg{'data'} $ret";
+      }
+  }
+  return "recv $msg{'dst'} ". hex($msg{'data'});
+} elsif ($fh) { # incoming dgram
+    my $buf; # not linewise! = <$fh>;
+    $socket[$socknum]->recv($buf,1024);
+
+    my $bufhex = unpack("H*",$buf);
+    chomp $buf;
+    my $fn = substr($buf,0,2);
+    # this is still very dumb
+    return "dunno recv $buf ($bufhex)";
+}
+
+for (my $i=0; $i<$numgas;$i++) {
+    $plugin_subscribe{$basega}{$plugname} = 1;
+    $basega = addr2str(str2addr($basega)+1,1);
+}
+
+# insert all commands to be sent cyclic
+# syswrite($socket[$socknum],"PW?\r");
+
+return "cycle";

Added: wiregate/plugin/generic/Blinker
===================================================================
--- wiregate/plugin/generic/Blinker	                        (rev 0)
+++ wiregate/plugin/generic/Blinker	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,23 @@
+### Definitionen
+# Eigenen Aufruf-Zyklus auf 300 Sekunden setzen
+$plugin_info{$plugname.'_cycle'} = 86400; # egal..
+
+my $aktiv_ga = "14/6/111";  # Gruppenadresse zum aktivieren
+my $schalt_ga = "1/6/26";     # GA zu schalten
+my $blinkpause = 2;  # Frequenz in sek.
+### Ende Definitionen
+
+if ($msg{'apci'} eq "A_GroupValue_Write" and $msg{'dst'} eq $aktiv_ga) {
+   $plugin_info{$plugname.'_aktiv'} = int($msg{'data'});
+   knx_write($schalt_ga,int($msg{'data'}),1);
+   $plugin_info{$plugname.'_cycle'} = $blinkpause;
+} else { # zyklischer Aufruf
+   # Plugin an Gruppenadresse "anmelden"
+   $plugin_subscribe{$aktiv_ga}{$plugname} = 1;
+   if ($plugin_info{$plugname.'_aktiv'}) {
+   	knx_write($schalt_ga,knx_read($schalt_ga,0,1)^1,1); # read&write last value - logical OR
+	$plugin_info{$plugname.'_cycle'} = $blinkpause;
+   }
+}
+
+return;

Added: wiregate/plugin/generic/DMX-Plugin.pl
===================================================================
--- wiregate/plugin/generic/DMX-Plugin.pl	                        (rev 0)
+++ wiregate/plugin/generic/DMX-Plugin.pl	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,90 @@
+# Plugin DMX-Gateway
+# Version: 0.3 2011-05-28
+# Ben\xF6tigt DMX USB-Interface
+
+##################
+### DEFINITION ###
+##################
+
+my $socknum = 6;                # Eindeutige Nummer des Sockets +1
+
+# Eigenen Aufruf-Zyklus setzen (Initialisierung/zyklisches pr\xFCfen)
+$plugin_info{$plugname.'_cycle'} = 300;
+# Gruppenadressen DMX - leer um Versand zu unterbinden
+# 8Bit/1Byte Dimmwerte werden 1:1 auf DMX-Adressen \xFCbersetzt
+my $knx_startGA = "11/1/0"; #DMX-Kanal 1, DMX-Kanal 256=1/1/255, DMX-Kanal 257..512=1/2/0..255
+my $dmx_channels = 512;     # Anzahl der DMX-Kan\xE4le
+# oder for XXX in array
+
+my $dmx_send_ip = "localhost"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $dmx_send_port = "50012"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $dmx_recv_ip = "localhost"; # Empfangsport (UDP, sie in Socket-Einstellungen)
+my $dmx_recv_port = "50011"; # Empfangsport (UDP, sie in Socket-Einstellungen)
+
+#######################
+### ENDE DEFINITION ###
+#######################
+
+my @dimcurve = (  0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,
+                  0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   0,   1,   1,   1,   1,   1,
+                  1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,
+                  1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,   1,
+                  1,   1,   1,   2,   2,   2,   2,   2,   2,   2,   2,   2,   2,   2,   2,   2,
+                  2,   2,   2,   2,   2,   2,   3,   3,   3,   3,   3,   3,   3,   3,   3,   3,
+                  3,   3,   4,   4,   4,   4,   4,   4,   4,   4,   4,   4,   5,   5,   5,   5,
+                  5,   5,   5,   6,   6,   6,   6,   6,   6,   7,   7,   7,   7,   7,   8,   8,
+                  8,   8,   8,   9,   9,   9,   9,  10,  10,  10,  10,  11,  11,  11,  12,  12,
+                 12,  13,  13,  13,  14,  14,  14,  15,  15,  16,  16,  17,  17,  18,  18,  19,
+                 19,  20,  20,  21,  21,  22,  22,  23,  24,  24,  25,  26,  26,  27,  28,  29,
+                 29,  30,  31,  32,  33,  34,  35,  36,  37,  38,  39,  40,  41,  42,  43,  44,
+                 46,  47,  48,  50,  51,  52,  54,  55,  57,  58,  60,  62,  63,  65,  67,  69,
+                 71,  73,  75,  77,  79,  81,  83,  86,  88,  90,  93,  95,  98, 101, 104, 106,
+                109, 112, 115, 119, 122, 125, 129, 132, 136, 140, 144, 148, 152, 156, 160, 165,
+                169, 174, 179, 184, 189, 194, 199, 205, 211, 216, 222, 228, 235, 241, 248, 255);
+
+# Hauptverarbeitung
+if (!$socket[$socknum]) { # socket erstellen
+    if (defined $socket[$socknum]) { #debug
+        if ($socket[$socknum]->opened) { $socket[$socknum]->close(); }
+        undef $socket[$socknum];
+    }  #debug      my $dgram = sprintf("C%03dL%03d\r\n",$dmxchan,hex($msg{'data'}));
+
+    $socksel->remove($socket[$socknum]);
+    $socket[$socknum] = IO::Socket::INET->new(LocalPort => $dmx_recv_port,
+                              Proto => "udp",
+                              LocalAddr => $dmx_recv_ip,
+                              PeerPort  => $dmx_send_port,
+                              PeerAddr  => $dmx_send_ip,
+                              ReuseAddr => 1
+                               )
+	     or return ("open of $dmx_recv_ip : $dmx_recv_port failed: $!");
+    $socksel->add($socket[$socknum]); # add socket to select
+    $plugin_socket_subscribe{$socket[$socknum]} = $plugname; # subscribe plugin
+    for (my $i=0; $i<$dmx_channels;$i++) {
+    	$plugin_subscribe{$knx_startGA}{$plugname} = 1;
+    	$knx_startGA = addr2str(str2addr($knx_startGA)+1,1);
+    }
+    return "opened UDP-Socket $socknum";
+} 
+if (%msg) { # telegramm vom KNX
+	my $destN = str2addr($msg{'dst'});
+	my $startN = str2addr($knx_startGA);
+	my $dmxchan = $destN - $startN;
+  if ($msg{'apci'} eq "A_GroupValue_Write" and $destN >= $startN and $destN <= $startN+$dmx_channels) {
+    	# send $dmxchan -> UDP as CaaaLvvv
+        my $dgram = sprintf("C%03dL%03d\r\n",$dmxchan,$dimcurve[hex($msg{'data'})]);
+    	$socket[$socknum]->send($dgram) or return "send failed: $!";
+      # debug chop($dgram);chop($dgram); # debug
+      # debug return "sent $msg{'dst'} $msg{'value'} $dgram to DMX $dmxchan"; # debug
+      return;
+ 	}
+} elsif ($fh) {
+    my $buf;
+    recv($fh,$buf,255,0);
+    my $bufhex = $buf;
+    $bufhex =~ s/(.)/sprintf("0x%x ",ord($1))/eg;
+    #debug return "recv $buf $bufhex";
+    return;
+}
+
+return;

Added: wiregate/plugin/generic/DaemonStartStop
===================================================================
--- wiregate/plugin/generic/DaemonStartStop	                        (rev 0)
+++ wiregate/plugin/generic/DaemonStartStop	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,32 @@
+# Plugin um daemons (Dienste) per KNX Gruppenadresse zu starten/beenden
+# pptpd in diesem Beispiel, geht natuerlich auch fuer alle anderen
+# Eigenen Aufruf-Zyklus auf taeglich setzen
+$plugin_info{$plugname.'_cycle'} = 86400;
+
+##############################################################################
+### Definitionen
+##############################################################################
+my $daemon = "pptpd";  # Name des dienstes
+my $ga = "0/7/254";      # Gruppenadresse, die ihn starten/beenden soll
+
+##############################################################################
+### Ende Definitionen
+##############################################################################
+
+my $dummy;
+if (%msg) {
+  if ($msg{'apci'} eq "A_GroupValue_Write" and $ga eq $msg{'dst'}) {
+	if($msg{'data'}+0) {
+		$dummy = `/etc/init.d/$daemon restart`;
+		return; # "started $daemon
+	} else {
+		$dummy = `/etc/init.d/$daemon stop`;
+		return; # "stopped $daemon
+	}
+  }
+} else {
+    # cyclic/init/change
+    # subscribe GA's
+      $plugin_subscribe{$ga}{$plugname} = 1;
+}
+return;
\ No newline at end of file

Added: wiregate/plugin/generic/Datenlogger-PV-Kaco-Prolog
===================================================================
--- wiregate/plugin/generic/Datenlogger-PV-Kaco-Prolog	                        (rev 0)
+++ wiregate/plugin/generic/Datenlogger-PV-Kaco-Prolog	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,151 @@
+# Monitoring a PV system with Kaco ProLOG
+# v0.1
+
+use LWP::Simple;
+
+# Configuration 
+# ****************************
+
+my $myProLogIP       = "192.168.178.116";  # IP address of Kaco ProLOG
+my $myCurrentPowerGA = "0/4/236";          # GA for sending current power [W], DPT 14.056
+# ToDo
+my $myEnergy15minGA  = "0/4/231";          # GA for sending energy produced in last 15min [Wh], DPT 13.010
+my $myEnergy60minGA  = "0/4/232";          # GA for sending energy produced in last 60min [Wh], DPT 13.010
+
+# Arrays to hold GAs for detailed values from the single power converters
+# Use their RS485 bus address as array index
+# If a GA is left empty, it is not send to the bus
+my @myDcVoltageGA;         # DC voltage in [V], DPT 14.027
+my @myDcCurrentGA;        # DC current in [A], DPT 14.019
+my @myDcPowerGA;        # DC power [W], DPT 13.010
+my @myAcVoltageGA;        # AC voltage in [V], DPT 14.027
+my @myAcCurrentGA;        # AC current in [A], DPT 14.019
+my @myAcPowerGA;        # AC power in [W], DPT 13.010
+my @myAcDailyEnergyGA;        # Energy output, daily accumulation in [kWh], DPT 13.013
+my @myTemperatureGA;        # Temperature of inverter in [°C], DPT 9.001
+my @myStatusGA;            # Status of inverter, DPT 5.010
+
+# WR1 Powador 6002
+$myDcVoltageGA[1]     = "0/4/237";
+$myDcCurrentGA[1]     = "0/4/238";
+$myDcPowerGA[1]       = "0/4/239";
+$myAcVoltageGA[1]     = "0/4/240";
+$myAcCurrentGA[1]     = "0/4/241";
+$myAcPowerGA[1]       = "0/4/242";
+$myAcDailyEnergyGA[1] = "0/4/243";
+$myTemperatureGA[1]   = "0/4/244";
+$myStatusGA[1]        = "0/4/245";
+# WR2 Powador 2002
+$myDcVoltageGA[2]     = "0/4/246";
+$myDcCurrentGA[2]     = "0/4/247";
+$myDcPowerGA[2]       = "0/4/248";
+$myAcVoltageGA[2]     = "0/4/249";
+$myAcCurrentGA[2]     = "0/4/250";
+$myAcPowerGA[2]       = "0/4/251";
+$myAcDailyEnergyGA[2] = "0/4/252";
+$myTemperatureGA[2]   = "0/4/253";
+$myStatusGA[2]        = "0/4/254";
+
+
+# End Configuration
+# *****************************
+# Do not change below here
+
+my $mySummaryDataDownloadPath = "/html/de/locale_live_standard.html";
+my $myDetailedDataDownloadPath = "/get_online_wr.cgi?q=U_DC_0;I_DC_0;P_DC_WR;U_AC_0;I_AC_0;P_AC_WR;T_WR;E_D_WR;S";
+my @myWRStatusMsg;
+
+$myWRStatusMsg[ 0] = 'WR gerade eingeschaltet';
+$myWRStatusMsg[ 1] = 'Warten auf Start';
+$myWRStatusMsg[ 2] = 'Warten auf Ausschalten';
+$myWRStatusMsg[ 3] = 'Konstantspannungsregler';
+$myWRStatusMsg[ 5] = 'Einspeisung (MPP-Tracker)';
+$myWRStatusMsg[ 8] = 'Selbsttest';
+$myWRStatusMsg[ 9] = 'Testbetrieb';
+$myWRStatusMsg[10] = 'Gerätetemperatur zu hoch';
+$myWRStatusMsg[11] = 'Leistungsbegrenzung';
+$myWRStatusMsg[29] = 'Erdschluss Sicherung prüfen!';
+$myWRStatusMsg[30] = 'Störung Messwandler';
+$myWRStatusMsg[32] = 'Fehler Selbsttest';
+$myWRStatusMsg[33] = 'Fehler DC-Einspeisung';
+$myWRStatusMsg[34] = 'Fehler Kommunikation';
+$myWRStatusMsg[35] = 'Schutzabschaltung (SW)';
+$myWRStatusMsg[36] = 'Schutzabschaltung (HW)';
+$myWRStatusMsg[38] = 'Fehler PV-Überspannung';
+$myWRStatusMsg[41] = 'Netzstörung Unterspannung';
+$myWRStatusMsg[42] = 'Netzstörung Überspannung';
+$myWRStatusMsg[48] = 'Netzstörung Unterfrequenz';
+$myWRStatusMsg[49] = 'Netzstörung Überfrequenz';
+$myWRStatusMsg[50] = 'Netzstörung Mittelwert Spg';
+$myWRStatusMsg[51] = 'Netzstörung Überspannung L1';
+$myWRStatusMsg[52] = 'Netzstörung Unterspannung L1';
+$myWRStatusMsg[53] = 'Netzstörung Überspannung L2';
+$myWRStatusMsg[54] = 'Netzstörung Unterspannung L2';
+$myWRStatusMsg[55] = 'Fehler Zwischenkreis';
+$myWRStatusMsg[57] = 'Warten auf Wiederzuschalten';
+$myWRStatusMsg[58] = 'Übertemperatur Steuerkarte';
+$myWRStatusMsg[59] = 'Fehler Selbsttest';
+$myWRStatusMsg[60] = 'PV-Spannung zu hoch';
+$myWRStatusMsg[61] = 'Power-Control';
+$myWRStatusMsg[62] = 'Inselbetrieb';
+$myWRStatusMsg[63] = 'Frequenzabhängige Leistungsreduzierung';
+$myWRStatusMsg[64] = 'Ausgangsstrombegrenzung';
+$myWRStatusMsg[''] = 'Nicht verfügbar/ausgeschaltet';
+
+$plugin_info{$plugname.'_cycle'} = 30;
+
+my $content = get( "http://$myProLogIP$mySummaryDataDownloadPath" );
+return "Übersichts-Webabfrage fehlgeschlagen" unless defined $content;
+
+my @myOverview = split( /\|/, $content );
+
+# calculate W from kW
+$myOverview[0] *= 1000;
+
+knx_write( $myCurrentPowerGA , $myOverview[0], 14 );
+update_rrd("PV", "P_total", $myOverview[0] );
+
+
+# more detailed data are requested here
+
+$content = get( "http://$myProLogIP$myDetailedDataDownloadPath" );
+return "Detail-Webabfrage fehlgeschlagen" unless defined $content;
+
+my @myDetails = split( /\n/, $content ); 
+my $myWRStatusChanges = '';
+
+for my $i (2 .. $#myDetails - 1) {
+    $myDetails[$i] =~ s/\r//g;    # remove carrige return
+    my @myWRDetails = split( /;/, $myDetails[$i] );
+    
+    # only process if system supplies values
+    if( $myWRDetails[2] != '' ) {
+        # store and send values
+        update_rrd( 'PV', "DcVoltage_WR$myWRDetails[1]", $myWRDetails[2] );
+        if( $myDcVoltageGA[ $myWRDetails[1] ] ) { knx_write( $myDcVoltageGA[ $myWRDetails[1] ], $myWRDetails[2], 14 ); }
+        update_rrd( 'PV', "DcCurrent_WR$myWRDetails[1]", $myWRDetails[3] );
+        if( $myDcCurrentGA[ $myWRDetails[1] ] ) { knx_write( $myDcCurrentGA[ $myWRDetails[1] ], $myWRDetails[3], 14 ); }
+        update_rrd( 'PV', "DcPower_WR$myWRDetails[1]", $myWRDetails[4] );
+        if( $myDcPowerGA[ $myWRDetails[1] ] ) { knx_write( $myDcPowerGA[ $myWRDetails[1] ], $myWRDetails[4], 13 ); }
+        update_rrd( 'PV', "AcVoltage_WR$myWRDetails[1]", $myWRDetails[5] );
+        if( $myAcVoltageGA[ $myWRDetails[1] ] ) { knx_write( $myAcVoltageGA[ $myWRDetails[1] ], $myWRDetails[5], 14 ); }
+        update_rrd( 'PV', "AcCurrent_WR$myWRDetails[1]", $myWRDetails[6] );
+        if( $myAcCurrentGA[ $myWRDetails[1] ] ) { knx_write( $myAcCurrentGA[ $myWRDetails[1] ], $myWRDetails[6], 14 ); }
+        update_rrd( 'PV', "AcPower_WR$myWRDetails[1]", $myWRDetails[7] );
+        if( $myAcPowerGA[ $myWRDetails[1] ] ) { knx_write( $myAcPowerGA[ $myWRDetails[1] ], $myWRDetails[7], 13 ); }
+        update_rrd( 'PV', "Temperature_WR$myWRDetails[1]", $myWRDetails[8] );
+        if( $myTemperatureGA[ $myWRDetails[1] ] ) { knx_write( $myTemperatureGA[ $myWRDetails[1] ], $myWRDetails[8], 9 ); }
+        update_rrd( 'PV', "DailyEnergy_WR$myWRDetails[1]", $myWRDetails[9] / 1000 );
+        if( $myAcDailyEnergyGA[ $myWRDetails[1] ] ) { knx_write( $myAcDailyEnergyGA[ $myWRDetails[1] ], $myWRDetails[9]/1000, 13 ); }    
+        update_rrd( 'PV', "Status_WR$myWRDetails[1]", $myWRDetails[10] );
+        if( $myStatusGA[ $myWRDetails[1] ] ) { knx_write( $myStatusGA[ $myWRDetails[1] ], $myWRDetails[10], 5 ); }
+            
+        # save last status of inverter
+        if ( $myWRDetails[10] != $plugin_info{$plugname."_WRState$myWRDetails[1]"} ) {
+            $myWRStatusChanges .= "WR$myWRDetails[1] Status ".$plugin_info{$plugname."_WRState$myWRDetails[1]"}." (".$myWRStatusMsg[$plugin_info{$plugname."_WRState$myWRDetails[1]"}].") -> ".$myWRDetails[10]." ($myWRStatusMsg[$myWRDetails[10]]) , ";
+            $plugin_info{$plugname."_WRState$myWRDetails[1]"} = $myWRDetails[10];
+        }
+    }
+}
+return $myWRStatusChanges;
+

Added: wiregate/plugin/generic/Denon-Plugin.pl
===================================================================
--- wiregate/plugin/generic/Denon-Plugin.pl	                        (rev 0)
+++ wiregate/plugin/generic/Denon-Plugin.pl	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,112 @@
+# Plugin Denon-AVR
+# Kommunikation via UDP - socat separat einzurichten
+# Version: 0.1 2011-01-31
+
+##################
+### DEFINITION ###
+##################
+
+my $socknum = 118;                # Eindeutige Nummer des Sockets +1
+
+# Eigenen Aufruf-Zyklus setzen (Initialisierung/zyklisches pruefen)
+$plugin_info{$plugname.'_cycle'} = 600;
+
+my $send_ip = "localhost"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $send_port = "50106"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $recv_ip = "localhost"; # Empfangsport (UDP, sie in Socket-Einstellungen)
+my $recv_port = "50105"; # Empfangsport (UDP, sie in Socket-Einstellungen)
+
+my $denon_ip;
+#$denon_ip = "172.17.2.89:23";  # uncomment to use direct telnet without socat
+
+my $basega = "10/0/0";
+my $numgas = 20;
+# Startadresse
+# 0=PW 1=PWStatus
+
+#######################
+### ENDE DEFINITION ###
+#######################
+
+# Hauptverarbeitung
+if (!$socket[$socknum]) { # socket erstellen
+    if ($denon_ip) {
+        $socket[$socknum] = IO::Socket::INET->new(PeerAddr => $denon_ip, Timeout => 120, Blocking => 0)
+             or return ("open of $denon_ip  failed: $!");
+    } else {
+        $socket[$socknum] = IO::Socket::INET->new(LocalPort => $recv_port,
+                                  Proto => "udp",
+                                  LocalAddr => $recv_ip,
+                                  PeerPort  => $send_port,
+                                  PeerAddr  => $send_ip,
+                                  ReuseAddr => 1
+                                   )
+                 or return ("open of $recv_ip : $recv_port failed: $!");
+    }
+
+    $socksel->add($socket[$socknum]); # add socket to select
+
+    $plugin_socket_subscribe{$socket[$socknum]} = $plugname; # subscribe plugin
+    return "opened Socket $socknum";
+} 
+
+if (%msg) { # telegramm vom KNX
+  if ($msg{'apci'} eq "A_GroupValue_Write") {
+      my $idx = str2addr($msg{'dst'}) - str2addr($basega);
+      if ($idx==0) {
+          my @vals = qw/PWSTANDBY PWON/; #1bit on/off
+          syswrite($socket[$socknum], $vals[$msg{'data'}]."\r");
+      #1=PW?
+      } elsif ($idx==2) { 
+          my @vals = qw /MVDOWN MVUP/; #1bit master-vol
+          syswrite($socket[$socknum], $vals[$msg{'data'}]."\r");
+      } elsif ($idx==3) { # 1byte 0-99
+          syswrite($socket[$socknum], sprintf("MV%02d\r",$msg{'data'}));
+      #4=MV?
+      } elsif ($idx==5) {
+          my @vals = qw /MUOFF MUON/; #1bit mute
+          syswrite($socket[$socknum], $vals[$msg{'data'}]."\r");
+      #6=MU?
+      } elsif ($idx==7) { #1byte source 5=TV 11=ipod 19=usb
+          my @vals = qw /PHONO CD TUNER DVD BD TV SAT\/CBL DVR GAME V.AUX DOCK IPOD NET\/USB NAPSTER LASTFM FLICKR FAVORITES IRADIO SERVER USB\/IPOD/;
+          syswrite($socket[$socknum], "SI".$vals[$msg{'data'}]."\r");
+      #8=SI?
+      } elsif ($idx==9) { #1byte sourround mode 2=ST 6=MCHST 10=Matrix
+          my @vals = ("DIRECT","PURE DIRECT","STEREO","STANDARD","DOLBY DIGITAL","DTS SUROUND","MCH STEREO","ROCK ARENA","JAZZ CLUB","MONO MOVIE","MATRIX","VIDEO GAME","VIRTUAL");
+          syswrite($socket[$socknum], "MS".$vals[$msg{'data'}]."\r");
+      #10=MS?
+      } else {
+          return "dunno? recv KNX $msg{'dst'} $msg{'data'}";
+      }
+  }
+  return;
+} elsif ($fh) { # incoming dgram
+    my $buf = <$fh>;
+    my $bufhex = unpack("H*",$buf);
+    chomp $buf;
+    my $fn = substr($buf,0,2);
+    # this is still very dumb
+    if ($fn eq "PW") {
+        my @vals = qw/PWSTANDBY PWON/; #1bit on/off
+        my( $val )= grep { $vals[$_] eq $buf } 0..$#vals;
+        knx_write(addr2str(str2addr($basega)+1) ,$val,1);
+        return "$val - @vals - $buf";
+    } elsif ($fn eq "MV" and $buf !~ /^MVMAX/) { # MVMAX is undocumented?
+        # broken, just sends every 2, .5 isn't considered
+        knx_write(addr2str(str2addr($basega)+4),substr($buf,2,2),5.010);
+        return "recv $buf ($bufhex)";
+    } else {
+        return "dunno recv $buf ($bufhex)";
+    }
+    return;
+}
+
+for (my $i=0; $i<$numgas;$i++) {
+    $plugin_subscribe{$basega}{$plugname} = 1;
+    $basega = addr2str(str2addr($basega)+1,1);
+}
+
+# insert all commands to be sent cyclic
+syswrite($socket[$socknum],"PW?\r");
+
+return "cycle";

Added: wiregate/plugin/generic/Dreambox-Text
===================================================================
--- wiregate/plugin/generic/Dreambox-Text	                        (rev 0)
+++ wiregate/plugin/generic/Dreambox-Text	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,43 @@
+# Plugin zum versenden von Textmeldungen an die Dreambox
+# Version 0.1 13.03.2011
+# Copyright: swiss (http://knx-user-forum.de/members/swiss.html)
+# License: GPL (v2)
+# Aufbau möglichst so, dass man unterhalb der Einstellungen nichts verändern muss!
+
+
+####################
+###Einstellungen:###
+####################
+
+
+my $aufrufende_ga = '1/1/1';
+my $dreambox_ip = '192.168.1.11';
+my $text = 'Zeile1&Zeile2&Zeile3&usw...'; #Für mehrere Zeilen einfach zwischen den Zeilen ein & einfügen
+
+my $timeout = 10; #Zeit in sekunden in der die Meldung angezeigt wird
+my $type = 2; #Meldungstyp: 1=Info, 2=Neutral, 3=Fehler
+
+
+######################
+##ENDE Einstellungen##
+######################
+
+
+# Eigenen Aufruf-Zyklus auf 1T setzen
+$plugin_info{$plugname.'_cycle'} = 86400; 
+# Zyklischer Aufruf nach restart und alle 86400 sek., dient dem anmelden an die Gruppenadresse, einmalig (0) würde in diesem Fall auch genügen
+
+
+
+if ($msg{'apci'} eq "A_GroupValue_Write" and $msg{'dst'} eq $aufrufende_ga) {
+
+while($text =~ /&/) {
+$text =~ s/&/%20%5Cn/;
+}
+
+get( "http://".$dreambox_ip."/web/message?text=".$text."&type=".$type."&timeout=".$timeout );
+} else { # zyklischer Aufruf
+   # Plugin an Gruppenadresse "anmelden", hierdurch wird das Plugin im folgenden bei jedem eintreffen eines Telegramms auf die GA aufgerufen und der obere Teil dieser if-Schleife durchlaufen
+   $plugin_subscribe{$aufrufende_ga}{$plugname} = 1;
+}
+

Added: wiregate/plugin/generic/EIB-Watchdog
===================================================================
--- wiregate/plugin/generic/EIB-Watchdog	                        (rev 0)
+++ wiregate/plugin/generic/EIB-Watchdog	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,18 @@
+# Watchdog fuer KNX-Schnittstelle
+# relevant nur bei USB und evtl. FT1.2 !
+### Config
+my $check_ga = "5/7/5";
+my $check_time = 60;
+### ENDE config
+
+
+# Eigenen Aufruf-Zyklus setzen
+$plugin_info{$plugname.'_cycle'} = $check_time;
+
+if (!knx_read($check_ga,$check_time)) {
+	my $dummy = `/etc/init.d/eibd restart`;
+	return "EIB-Lesefehler! res: $dummy";
+	}
+
+#return "alles paletti";
+return 0;
\ No newline at end of file

Added: wiregate/plugin/generic/EiWoMiSa
===================================================================
--- wiregate/plugin/generic/EiWoMiSa	                        (rev 0)
+++ wiregate/plugin/generic/EiWoMiSa	2011-05-28 23:19:24 UTC (rev 348)
@@ -0,0 +1,131 @@
+# Plugin Eiwomisa RGB DMX-Controller
+# Version: 0.1 2011-01-21
+# Benötigt Eiwomisa RGB DMX Controller und socat Eintrag für USB-RS232 Wandler
+
+##################
+### DEFINITION ###
+##################
+
+my $socknum = 9;                # Eindeutige Nummer des Sockets +1
+
+# Eigenen Aufruf-Zyklus setzen (Initialisierung/zyklisches prüfen)
+$plugin_info{$plugname.'_cycle'} = 300;
+# Gruppenadressen <-> DMX 
+# 8Bit/1Byte Dimmwerte werden 1:1 auf DMX-Adressen übersetzt
+my $knx_startGA = "11/1/0"; # DMX-Kanal 0, DMX-Kanal 256=11/1/255, DMX-Kanal 257..512=11/2/0..255
+my $dmx_channels = 8;       # Anzahl der DMX-Kanäle, hier 4 für RGBW Eiwomisa, +3 für externen RGB DMX Empfänger [+1, da 0 nicht benutzt]
+
+
+my $dmx_send_ip = "localhost"; # Sendeport (UDP, sie in Socket-Einstellungen)
+my $dmx_send_port = "50015";   # Sendeport (UDP, sie in Socket-Einstellungen)
+
+# pre-defining bytes for serial data stream to Eiwomisa DMX controller
+my $byte1 = 0;
+my $byte2 = 0;
+my $byte3 = 0;
+my $byte4 = 0;
+my $byte5 = 0;
+my $byte6 = 0;
+
+#######################
+### ENDE DEFINITION ###
+#######################
+
+# Hauptverarbeitung
+if (!$socket[$socknum]) { # socket erstellen
+    if (defined $socket[$socknum]) { #debug
+        if ($socket[$socknum]->opened) { $socket[$socknum]->close(); }
+        undef $socket[$socknum];
+    }  #debug
+    $socksel->remove($socket[$socknum]);
+    $socket[$socknum] = IO::Socket::INET->new(
+                              Proto => "udp",
+                              PeerPort  => $dmx_send_port,
+                              PeerAddr  => $dmx_send_ip,
+                              ReuseAddr => 1
+                               )
+         or return ("open of $dmx_send_ip : $dmx_send_port failed: $!");
+    $socksel->add($socket[$socknum]); # add socket to select
+    
+    $plugin_socket_subscribe{$socket[$socknum]} = $plugname; # subscribe plugin
+    for (my $i=0; $i<$dmx_channels;$i++) {
+        $plugin_subscribe{$knx_startGA}{$plugn...
 
[truncated message content]

Thread: [Openautomation-svn] SF.net SVN: openautomation:[348] wiregate

Building automation (like KNX or OpenHAB) software (like CometVisu).

openautomation-svn