--- trunk/all2xml.pl 2002/11/24 20:52:11 1 +++ trunk2/all2all.pl 2004/07/21 16:58:27 392 @@ -1,66 +1,107 @@ #!/usr/bin/perl -w +=head1 NAME + +all2all.pl - basic script for all WebPAC needs + +=cut + use strict; -use OpenIsis; -use Getopt::Std; use Data::Dumper; -use XML::Simple; +use Carp; -my $config=XMLin(); +use lib './lib'; +use WebPAC; +use WebPAC::jsFind; -print Dumper($config); +my $webpac = new WebPAC( + code_page => 'ISO-8859-2', + limit_mfn => 100, +# debug => 1, +) || die; -my %opts; +my $log = $webpac->_get_logger(); -getopts('d:m:q', \%opts); +my $index = new WebPAC::jsFind( + index_path => './out/index', +) || die; -my $db_dir = $opts{d}; +$|=1; -die "usage: $0 -d [database_dir] -m [database1,database2] " if (! %opts); +my $maxmfn = $webpac->open_isis( + filename => shift @ARGV || '/data/hidra/THS/THS', + lookup => [ + { 'key' => 'd:v900', 'val' => 'v250^a' }, +# { 'eval' => '"v901^a" eq "Područje"', 'key' => 'pa:v561^4:v562^4:v461^1', 'val' => 'v900' }, +# { 'eval '=> '"v901^a" eq "Mikrotezaurus"', 'key' => 'a:v561^4:v562^4:v461^1', 'val' => 'v900' }, +# { 'eval' => '"v901^a" eq "Deskriptor"', 'key' => 'a:v561^4:v562^4:v461^1', 'val' => 'v900' }, + { 'key' => 'a:v561^4:v562^4:v461^1', 'val' => 'v900' }, + { 'key' => '900_mfn:v900', 'val' => 'v000' }, + ], +); -#-------------------------------------------------------------------- +$log->info("rows: $maxmfn"); -my $last_tell=0; +$webpac->open_import_xml(type => 'isis_hidra_ths'); -my @isis_dirs = ( '.' ); # use dirname as database name - -if ($opts{m}) { - @isis_dirs = split(/,/,$opts{m}); -} +while (my $rec = $webpac->fetch_rec) { -my @isis_dbs; + my @ds = $webpac->data_structure($rec); -foreach (@isis_dirs) { - if (-e "$common::isis_data/$db_dir/$_/LIBRI") { - push @isis_dbs,"$common::isis_data/$db_dir/$_/LIBRI/LIBRI"; + if ($log->is_debug) { + $log->debug("rec = ",Dumper($rec)); + $log->debug("ds = ",Dumper(\@ds)); } - if (-e "$common::isis_data/$db_dir/$_/PERI") { - push @isis_dbs,"$common::isis_data/$db_dir/$_/PERI/PERI"; - } - if (-e "$common::isis_data/$db_dir/$_/AMS") { - push @isis_dbs,"$common::isis_data/$db_dir/$_/AMS/AMS"; - } - if (-e "$common::isis_data/$db_dir/$_/ARTI") { -# push @isis_dbs,"$common::isis_data/$db_dir/$_/ARTI/ARTI"; - } -} -foreach my $isis_db (@isis_dbs) { + next if (! @ds); - my $db = OpenIsis::open( "$isis_db" ) || warn "can't open '$isis_db'"; + my $filename = $webpac->{'current_filename'}; - my $max_rowid = OpenIsis::maxRowid( $db ); + if ($filename) { + open(OUT,"> $filename") || $log->logdie("can't open output '$filename': $!"); + print OUT $webpac->output( + template => 'html.tt', + data => \@ds, + ); + close(OUT); + } else { + print $webpac->output( + template => 'text.tt', + data => \@ds, + ); + } - my $last_pcnt = 0; + my $headline; + foreach my $ds (@ds) { + if ($ds->{'tag'} eq 'headline') { + $headline = join(" ",@{$ds->{'display'}}); + last; + } + } - for (my $row_id = 1; $row_id <= $max_rowid; $row_id++ ) { - my $row = OpenIsis::read( $db, $row_id ); + my $f = $filename; + $f =~ s!out/!!; - # output current process indicator - my $pcnt = int($row->{mfn} * 100 / $max_rowid); - if ($pcnt != $last_pcnt) { - printf STDERR ("%5d / %5d -- %-2d %%\n",$row->{mfn},$max_rowid,$pcnt) if (! $opts{q}); - $last_pcnt = $pcnt; - } + # save into index + foreach my $ds (@ds) { + next if (! $ds->{'swish'}); + + $index->insert( + index_name => $ds->{'tag'}, + path => $f, + headline => $headline, + words => join(" ",@{$ds->{'swish'}}) + ); } + +# print Dumper(\@ds); + } + +if ($log->is_debug) { + $log->debug("lookup hash: ",Dumper($webpac->{'lookup'})); + $log->debug("data hash: ",Dumper($webpac->{'data'})); +} + +$index->close; +