diff --git a/fhem/CHANGED b/fhem/CHANGED index 36c36b076..2d8a3ca2c 100644 --- a/fhem/CHANGED +++ b/fhem/CHANGED @@ -1,5 +1,7 @@ # Add changes at the top of the list. Keep it in ASCII, and 80-char wide. # Do not insert empty lines here, update check depends on it. + - update: 97_TrashCal.pm: fetches shared dates at an public webpage + of waste disposal - bugfix: 73_GasCalculator: Corrected month of annual reading - bugfix: 73_ElectricityCalculator: Corrected month of annual reading - update: 98_Text2Speech.pm: (thanks to Ellert) diff --git a/fhem/FHEM/97_TrashCal.pm b/fhem/FHEM/97_TrashCal.pm new file mode 100644 index 000000000..be976f0b2 --- /dev/null +++ b/fhem/FHEM/97_TrashCal.pm @@ -0,0 +1,419 @@ +############################################## +# $Id$ +# +# 97_TrashCal.pm +# +# written by Tobias Faust 2013-10-23 +# e-mail: tobias dot faust at online dot de +# +############################################## +# +############################################## +# +# Log-Levels +# 0 - server start/stop +# 1 - error messages or unknown packets +# 2 - major events/alarms. +# 3 - commands sent out will be logged. +# 4 - you'll see whats received by the different devices. +# 5 - debugging. + +############################################## + + +############################################### +# parser for the Trash +package MyTrashCalParser; +use base qw(HTML::Parser); +our %dates = (); +my $lookupTag = "td"; +my $curTag = ""; +my $category = "--"; + +# here HTML::text/start/end are overridden +sub text +{ + my ( $self, $text ) = @_; + if ( $curTag eq $lookupTag ) + { + #print "MyTrashCalParser_Text: original: $text \n"; + $text =~ s/[^0-9]*([0-9]{1,2}\.[0-9]{1,2}\.[0-9]{4}).*/$1/; + #print "MyTrashCalParser_Text: Modifiziert: $text \n"; + + if($category ne "" && $text =~ m/([0-9]{1,2}\.[0-9]{1,2}\.[0-9]{4})/) { + push(@{$dates{$category}}, $text); + #print "MyTrashCalParser_Text: Values of $category: ". keys(%{$data{$category}}) ."\n"; + } + + } elsif ($curTag eq "h3") { + $category = $text; + #print "MyTrashCalParser_Text: neue Kategorie: $text \n"; + } +} + +sub start +{ + my ( $self, $tagname, $attr, $attrseq, $origtext ) = @_; + $curTag = $tagname; + #print "MyTrashCalParser_Start: $tagname, $attr, $attrseq, $origtext"; +} + +sub end +{ + $curTag = ""; + #print "MyTrashCalParser_End: ----- done -----"; +} + + + +############################################## +package main; +use strict; +use feature qw/say switch/; +use warnings; +use Data::Dumper; +use LWP::UserAgent; +use HTTP::Request; +require 'Blocking.pm'; +require 'HttpUtils.pm'; +use vars qw($readingFnAttributes); + +# use vars qw(%attr); +use vars qw(%defs); +my $MODUL = "TrashCal"; + + +################################### +sub TrashCal_Initialize($) +{ + my ($hash) = @_; + $hash->{DefFn} = "TrashCal_Define"; + $hash->{UndefFn} = "TrashCal_Undef"; + $hash->{AttrList} = " TrashCal_Link". + " TrashCal_Interval". + " disable:0,1". + " ".$readingFnAttributes; +} +################################### +sub TrashCal_Define($$) +{ + my ( $hash, $def ) = @_; + my $name = $hash->{NAME}; + my @a = split( "[ \t][ \t]*", $def ); + my $type = $a[2]; + if ( int(@a) < 3 ) + { + return "Wrong syntax: use define TrashCal "; + } + + my $nt = time; + $nt += 20; # aquire in 20sec + my @lt = localtime($nt); + my $ntm = sprintf("%02d.%02d.%04d %02d:%02d:%02d", $lt[3], ($lt[4]+1), ($lt[5]+1900), $lt[2], $lt[1], $lt[0]); + $hash->{TriggerTime_FMT} = $ntm; + $hash->{TriggerTime} = $nt; + + InternalTimer( $nt, "TrashCal_Timer", $hash, 0 ); + Log3 $hash, 4, "TrashCal_Define: InternalTimer auf in 20sek gesetzt: $ntm"; + return undef; +} + +##################################### +sub TrashCal_Undef($$) +{ + my ( $hash, $arg ) = @_; + + RemoveInternalTimer( $hash ); + BlockingKill( $hash->{helper}{RUNNING_PID} ) if ( defined( $hash->{helper}{RUNNING_PID} ) ); + + Log3 $hash, 4, "TrashCal_Undef: --- done ---"; + return undef; +} + + +##################################### +sub TrashCal_Timer(@) +{ + my ($hash) = @_; + my $me = $hash->{NAME}; + + Log3 $hash, 4, "TrashCal_Timer: GrTimer aufgerufen....."; + return unless (defined($hash->{NAME})); + Log3 $hash, 4, "TrashCal_Timer: --- started ---"; + + $hash->{helper}{TimerGRInterval} = AttrVal( $me, "TrashCal_Interval", 3600 ); + + TrashCal_Start($hash) if(!IsDisabled($me)); + + # setup timer + RemoveInternalTimer( $hash ); + + my $nt = time; + $nt += $hash->{helper}{TimerGRInterval}; + my @lt = localtime($nt); + my $ntm = sprintf("%02d.%02d.%04d %02d:%02d:%02d", $lt[3], ($lt[4]+1), ($lt[5]+1900), $lt[2], $lt[1], $lt[0]); + $hash->{TriggerTime_FMT} = $ntm; + $hash->{TriggerTime} = $nt; + + InternalTimer($nt, "TrashCal_Timer", $hash, 0 ); + + Log3 $hash, 4, "TrashCal_Timer: --- done ---"; +} + +##################################### +# acquires the html page +sub TrashCal_HtmlAcquire($) +{ + my ($hash) = @_; + my $name = $hash->{NAME}; + return unless (defined($hash->{NAME})); + + my $URL = AttrVal( $name, 'TrashCal_Link', "" ); + + # abbrechen, wenn wichtig parameter nicht definiert sind + return "" if ( !defined($URL) ); + return "" if ( $URL eq "" ); + + my $err_log = ""; + my $agent = LWP::UserAgent->new( env_proxy => 1, keep_alive => 1, timeout => 3 ); + my $header = HTTP::Request->new( GET => $URL ); + my $request = HTTP::Request->new( 'GET', $URL, $header ); + my $response = $agent->request($request); + $err_log = "Can't get $URL -- " . $response->status_line + unless $response->is_success; + + if ( $err_log ne "" ) + { + Log3 $hash, 1, "TrashCal_HtmlAcquire: Error: $err_log"; + return ""; + } + + return $response->content; +} + + +##################################### +sub TrashCal_Start($) +{ + my ($hash) = @_; + return unless (defined($hash->{NAME})); + my $me = $hash->{NAME}; + + if (AttrVal( $me, 'TrashCal_Link', "" ) eq "") { + Log3 $hash, 3, "$me: Kein Link im Attribut 'TrashCal_Link' angebeben, breche Ausführung ab."; + return; + } + + while (1) + { + Log3 $hash, 4, "TrashCal_Start: --- started ---"; + + $hash->{helper}{RUNNING_PID} = + BlockingCall( + "TrashCal_Run", # callback worker task + $me, # name of the device + "TrashCal_Done", # callback result method + 50, # timeout seconds + "TrashCal_Aborted", # callback for abortion + $hash ); # parameter for abortion + + last; + } + Log3 $hash, 4, "TrashCal_Start: --- done ---"; +} + +##################################### +sub TrashCal_Run($) { + my ($string) = @_; + my ( $me, $server ) = split( "\\|", $string ); + my $ptext = $me ."+"; + + return unless ( defined($me) ); + + my $hash = $defs{$me}; + return unless (defined($hash->{NAME})); + + Log3 $hash, 4, "TrashCal_Run: --- started ---"; + while (1) + { + # acquire the html-page + my $response = TrashCal_HtmlAcquire($hash); + last if ($response eq ""); + + my $parser = MyTrashCalParser->new; + %MyTrashCalParser::dates = (); + # parsing the complete html-page-response, needs some time + # only tags will be regarded + $parser->parse($response); + Log3 $hash, 4, "TrashCal_Run: parsed terms:" . keys(%MyTrashCalParser::dates); + + foreach my $cat (keys(%MyTrashCalParser::dates) ) { + $ptext .= $cat . '|'; + #Log3 $hash, 4, "TrashCal_Run: Values of $cat: ". keys(%{$MyTrashCalParser::data{$cat}}); + #foreach my $dat (keys(%{$MyTrashCalParser::dates{$cat}}) ) { + # $ptext .= "|".$dat; + #} + $ptext .= join('|', @{$MyTrashCalParser::dates{$cat}}); + $ptext .= "+"; + } + + last; + } + + Log3 $hash, 4, "TrashCal_Run: return value: $ptext"; + Log3 $hash, 4, "TrashCal_Run: --- done ---"; + return $ptext; + #return "TrashCal|Altpapier|12.09.2014|07.11.2014|05.12.2014|18.07.2014|10.10.2014|15.08.2014"; +} + +##################################### +# assyncronous callback by blocking +sub TrashCal_Done($) { + my ($string) = @_; + Log3 undef, 4, "TrashCal_Done: --- begin ---"; + return unless ( defined($string) ); + + # all term are separated by "#" , the first is the name of the instance + my ( $me, @values ) = split("\\+", $string ); + my $hash = $defs{$me}; + return unless (defined($hash->{NAME})); + + # delete the marker for running process + delete( $hash->{helper}{RUNNING_PID} ); + + Log3 $hash, 4, "TrashCal_Done: --- started ---"; + #Log3 $hash, 5, "TrashCal_Done: values:".join(', ', @values); + + # Aktualisierung der Readings + my $category; + my $tstamp; + my $NextEvent_Tstamp = time() + (28*86400); #hoher Initialwert + my $NextEvent_Cat = ""; + my $NextEvent_Dat = ""; + my %hashValues = (); + + # Durch jede Kategorie + for(my $i=0; $i time()) && ($tstamp < $hashValues{$category}{TSTAMP}))) { + # nur den zeitlich nächsten Wert in die Readings pro Categorie uebernehmen + $hashValues{$category}{DATE} = $dates[$j]; + $hashValues{$category}{TSTAMP} = $tstamp; + } + } + + # show the values + Log3 $hash, 5, "TrashCal_Done: category:$category - date: ".$dates[$j]; + } + } + + readingsBeginUpdate($hash); + foreach my $xxx ( sort keys %hashValues ) { + #my $daysleft = ($hashValues{$xxx}{TSTAMP} - time()) / 60 / 24; + readingsBulkUpdate( $hash, $xxx, $hashValues{$xxx}{DATE} ); + readingsBulkUpdate( $hash, $xxx."_Tstamp", $hashValues{$xxx}{TSTAMP} ); + #readingsBulkUpdate( $hash, $xxx."_DaysLeft", $daysleft); + } + + readingsBulkUpdate( $hash, "NextEvent Category", $NextEvent_Cat ); + readingsBulkUpdate( $hash, "NextEvent Date", $NextEvent_Dat ); + readingsBulkUpdate( $hash, "NextEvent Tstamp", $NextEvent_Tstamp ); + + readingsBulkUpdate( $hash, "state", $NextEvent_Cat .": ". $NextEvent_Dat ); + readingsEndUpdate( $hash, 1 ); + + Log3 $hash, 4, "TrashCal_Done: --- done ---"; +} + +##################################### +sub TrashCal_Aborted($) +{ + my ($hash) = @_; + delete( $hash->{helper}{RUNNING_PID} ); + Log3 $hash, 3, "TrashCal_Aborted: --- done ---"; +} + + +##################################### +1; + +=pod +=item helper +=item summary fetches shared dates at an public webpage of waste disposal +=item summary_DE holt auf einer Webseite bereitgestellte Abfalltermine ab +=begin html + + +

TrashCal

+
    + Note: this module needs the HTTP::Request,HTML::Parser and LWP::UserAgent perl modules. +
    + At this moment only city "Magdeburg" is supported at this site:
    + http://sab.metageneric.de/app/sab_i_tp/index.php +

    + + Define +
      + define <name> TrashCal <type> +

      + Defines a new instanze of Trashcalendar. At this time the <type> is not used +
      + Examples: +
        + define MyTrashCal TrashCal Restabfall
        +
      +
    +
    + + + Set +
      N/A

    + + + Get +
      N/A

    + + + Attributes +
      +
    • TrashCal_Link
      + setting up the URL to grab the Trashcalendar +
      Example: +
        + http://sab.metageneric.de/app/sab_i_tp/index.php?r=getHausnummerInfo&strasse=Torplatz&hausnummer=1&stadtteil_id=1609&dsd_behaelter_value=b120_b240 +
        +
      +
      • + +
    • readingFnAttributes

      • + +
    • disable
      + If this attribute is activated, the module will be disabled.
      + Possible values: 0 => not disabled , 1 => disabled
      + Default Value is 0 (not disabled)

      +
      • + +
    • verbose
      + 4: each major step will be logged
      + 5: Additionally some minor steps will be logged +
      • + +
    +
+ +=end html +=cut diff --git a/fhem/MAINTAINER.txt b/fhem/MAINTAINER.txt index 2c2674d1d..fac581dab 100644 --- a/fhem/MAINTAINER.txt +++ b/fhem/MAINTAINER.txt @@ -338,6 +338,7 @@ FHEM/95_Dashboard.pm svenson08 http://forum.fhem.de Frontends FHEM/95_PachLog.pm rudolfkoenig/orphan http://forum.fhem.de Sonstiges FHEM/95_holiday.pm rudolfkoenig http://forum.fhem.de Sonstiges FHEM/95_remotecontrol.pm ulimaass http://forum.fhem.de Frontends +FHEM/97_TrashCal.pm Tobias http://forum.fhem.de Unterstuetzende Dienste FHEM/97_SprinkleControl.pm Tobias http://forum.fhem.de Unterstuetzende Dienste FHEM/98_Text2Speech.pm Tobias http://forum.fhem.de Unterstuetzende Dienste FHEM/98_MediaList.pm Tobias http://forum.fhem.de Multimedia