X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FGeomag.pm;h=8f17eaf32000442462ca1bd1bbbf840e4e942dd9;hb=6ccc3a6e864a2fee18786a7070400c7c4f22cf7c;hp=d78ff2cd3f007fd67cd7b5233ec3db33551ff699;hpb=0542c1871c9563b7577a4b9a1282fd5d2c203047;p=spider.git diff --git a/perl/Geomag.pm b/perl/Geomag.pm index d78ff2cd..8f17eaf3 100644 --- a/perl/Geomag.pm +++ b/perl/Geomag.pm @@ -15,10 +15,20 @@ use DXUtil; use DXLog; use Julian; use IO::File; -use Carp; +use DXDebug; +use DXDupe; use strict; -use vars qw($date $sfi $k $a $r $forecast @allowed @denied $fp $node $from); + +use vars qw($VERSION $BRANCH); +$VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ ); +$BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/ ) || 0; +$main::build += $VERSION; +$main::branch += $BRANCH; + +use vars qw($date $sfi $k $a $r $forecast @allowed @denied $fp $node $from + $dirprefix $param + $duplth $dupage $filterdef); $fp = 0; # the DXLog fcb $date = 0; # the unix time of the WWV (notional) @@ -31,13 +41,28 @@ $node = ""; # originating node $from = ""; # who this came from @allowed = (); # if present only these callsigns are regarded as valid WWV updators @denied = (); # if present ignore any wwv from these callsigns -my $dirprefix = "$main::data/wwv"; -my $param = "$dirprefix/param"; +$duplth = 20; # the length of text to use in the deduping +$dupage = 12*3600; # the length of time to hold spot dups + +$dirprefix = "$main::data/wwv"; +$param = "$dirprefix/param"; + +$filterdef = bless ([ + # tag, sort, field, priv, special parser + ['by', 'c', 7], + ['origin', 'c', 8], + ['channel', 'c', 9], + ['by_dxcc', 'nc', 10], + ['by_itu', 'ni', 11], + ['by_zone', 'nz', 12], + ['origin_dxcc', 'nc', 13], + ['origin_itu', 'ni', 14], + ['origin_zone', 'nz', 15], + ], 'Filter::Cmd'); sub init { $fp = DXLog::new('wwv', 'dat', 'm'); - mkdir $dirprefix, 0777 if !-e $dirprefix; # now unnecessary DXLog will create it do "$param" if -e "$param"; confess $@ if $@; } @@ -73,8 +98,12 @@ sub update # my $trydate = cltounix($mydate, sprintf("%02d18Z", $mytime)); if ($mydate >= $date) { + if ($myr) { + $r = 0 + $myr; + } else { + $r = 0 unless abs ($mysfi - $sfi) > 3; + } $sfi = 0 + $mysfi; - $r = 0 + $myr unless !$r && $myk == $k; $k = 0 + $myk; $a = 0 + $mya; $forecast = $myforecast; @@ -153,7 +182,7 @@ sub search { my $from = shift; my $to = shift; - my @date = $fp->unixtoj(shift); + my $date = $fp->unixtoj(shift); my $pattern = shift; my $search; my @out; @@ -177,7 +206,7 @@ sub search $fp->close; # close any open files - my $fh = $fp->open(@date); + my $fh = $fp->open($date); for ($count = 0; $count < $to; ) { my @in = (); if ($fh) { @@ -221,8 +250,8 @@ sub print_item # sub readfile { - my @date = $fp->unixtoj(shift); - my $fh = $fp->open(@date); + my $date = $fp->unixtoj(shift); + my $fh = $fp->open($date); my @spots = (); my @in; @@ -234,5 +263,23 @@ sub readfile } return @in; } + +# enter the spot for dup checking and return true if it is already a dup +sub dup +{ + my ($d, $sfi, $k, $a, $text) = @_; + + # dump if too old + return 2 if $d < $main::systime - $dupage; + + my $dupkey = "W$d|$sfi|$k|$a"; + return DXDupe::check($dupkey, $main::systime+$dupage); +} + +sub listdups +{ + return DXDupe::listdups('W', $dupage, @_); +} 1; __END__; +