X-Git-Url: http://git.equinoxoli.org/?p=migration-tools.git;a=blobdiff_plain;f=extract_holdings;h=29bd56d093554b584ed9c75fd10d0302e714a98e;hp=b4115409a7fcafcf32d832f1ad81e45309fa3cfd;hb=5920a6497c3eeb26fd66cdeae6cb3386686a561a;hpb=07e09b509ccddb459137a98759781b6f8dcb396b diff --git a/extract_holdings b/extract_holdings index b411540..29bd56d 100755 --- a/extract_holdings +++ b/extract_holdings @@ -2,99 +2,120 @@ use strict; use warnings; -use XML::Twig; -use YAML; -use JSON; - -my $marcxml = shift || help(); - -open HOLDINGS, '>', "holdings"; -open X, '>', "holdings.x"; -open Z, '>', "holdings.z"; -open ALL852, '>', "holdings.all852"; - -$| = 1; -my $holdings = {}; -my $copyid = 0; -my $count = 0; -my %all852 = ( x => {}, z => {} ); # hash of all subfields in all 852s - -my $t = XML::Twig->new( twig_handlers => { record => \&record } ); -$t->parsefile($marcxml); -#print ALL852 to_json(\%all852); -print ALL852 Dump(%all852); - -sub record { - my($t, $r)= @_; - $holdings = { copies => [] }; - - my @dfields = $r->children('datafield'); - for my $d (@dfields) { - process_datafields($d) - } +use Getopt::Long; +use Equinox::Migration::MapDrivenMARCXMLProc; +use Equinox::Migration::MARCXMLSampler; - for my $copy (@{$holdings->{copies}}) - { print_reports($copy) } - $r->purge; - $count++; print "\r$count"; -} -sub process_datafields { - my ($d) = @_; - # get 903 - if ($d->{'att'}->{'tag'} == 903) { - my $s = $d->first_child('subfield'); - $holdings->{id} = $s->text;; - } +my $c = initialize(); - # and holdings data - if ($d->{'att'}->{'tag'} == 852) { - push @{$holdings->{copies}}, { x =>[], z => [] }; - $holdings->{copies}[-1]{copyid} = $copyid; - my @subs = $d->children('subfield'); - for my $s (@subs) - { process_subs($s) } - $copyid++; - } -} - -sub process_subs { - my ($s) = @_; - my $copy = $holdings->{copies}[-1]; +# run samples if we've been asked for them +run_samples($c) if ($c->{sample} or $c->{samplemap} or $c->{samplestr}); - my $code = $s->{'att'}->{'code'}; - my $value = $s->text; - if ($code eq 'x' or $code eq 'z') { - push @{$copy->{$code}}, $value; - my ($k,$v) = split /:/, $value; - $all852{$code}{$k} = $v; - } else { - $copy->{$code} = $value; - $all852{$code} = $value; +sub run_samples { + my ($c) = @_; + my $s; + if ($c->{samplemap}) { + $s = Equinox::Migration::MARCXMLSampler->new( marcfile => $c->{marcfile}, + mapfile => $c->{samplemap}); + } elsif ($c->{samplestr}) { + $s = Equinox::Migration::MARCXMLSampler->new( marcfile => $c->{marcfile}, + mapstring => $c->{samplestr}); + } else { + $s = Equinox::Migration::MARCXMLSampler->new( marcfile => $c->{marcfile} ); } + $s->parse_records; + + dump_sample_overview($c, $s) if $c->{sample}; + dump_sample_detail($c, $s) if ($c->{samplemap} or $c->{samplestr}); } -sub print_reports { - my ($copy) = @_; - my $note = 0; - for (@{$copy->{x}}) { - print X join("\t", $holdings->{id}, $copy->{copyid}, $note, $_), "\n"; - $note++; +sub dump_sample_detail { + my ($c, $s) = @_; + my $tags = $s->{data}{samp}; + my $count = $s->{data}{rcnt}; + + open DETAIL, '>', ($c->{prefix} . "-HOLDINGS-DETAIL.txt"); + select DETAIL; + for my $tag (sort keys %{$tags}) { + print ">>>>> TAG $tag\n"; + for my $subkey (sort keys %{$tags->{$tag}}) { + my $sub = $tags->{$tag}{$subkey}; + print " Subfield: $subkey\n"; + print " Sample: '", $sub->{value}, "'\n"; + print " Count: ", $sub->{count}, " in ", $sub->{tcnt}, " tags\n\n"; + #print "(", int($sub->{count} / $sub->{rcnt}), "%)\n"; + } } - $note = 0; - for (@{$copy->{z}}) { - print Z join("\t", $holdings->{id}, $copy->{copyid}, $note, $_), "\n"; - $note++; + select STDOUT; + close DETAIL; +} + +sub dump_sample_overview { + my ($c, $s) = @_; + my $tags = $s->{data}{tags}; + my $count = $s->{data}{rcnt}; + + my @tagsbyname = sort keys %{$tags}; + my @tagsbycount = reverse sort { $tags->{$a} <=> $tags->{$b} } keys %{$tags}; + + open SAMPLE, '>', ($c->{prefix} . "-HOLDINGS-OVERVIEW.txt"); + select SAMPLE; + print "FOUND TAGS (BY TAG) FOUND TAGS (BY COUNT)\n"; + print "------------------- ---------------------\n"; + for my $i (0 .. @tagsbyname - 1) { + print $tagsbyname[$i], (" " x (14 - length $tags->{ $tagsbyname[$i] })), + $tags->{ $tagsbyname[$i] }, " "; + print $tagsbycount[$i], (" " x (16 - length $tags->{ $tagsbycount[$i] })), + $tags->{ $tagsbycount[$i] }, "\n"; } - print HOLDINGS join("\t", $holdings->{id}, $copy->{copyid}, - $copy->{b}, $copy->{p}, $copy->{h}, $copy->{9}), "\n"; + select STDOUT; + close SAMPLE; } +#-------------------------- + +sub initialize { + my $c = {}; + my @missing = (); + + # set mode on existing filehandles + binmode(STDIN, ':utf8'); + + my $rc = GetOptions( $c, + 'sample|s', + 'samplemap|sm=s', + 'samplestr|ss=s', + 'marcfile|m=s', + 'ils|i=s', + 'library|l=s', + 'prefix|p=s', + 'help|h', + ); + show_help() unless $rc; + show_help() if ($c->{help}); + + my @keys = keys %{$c}; + for my $key ('prefix', 'ils') + { push @missing, $key unless $c->{$key} } + if (@missing) { + print "Required option: ", join(', ', @missing), " missing!\n"; + show_help(); + } + + return $c; +} -sub help { +sub show_help { print < + prefix p Prefix string for output filenames + map m Subfield map file to use + ils i Legacy ILS name (affects SQL generation) + + sample s Comma-delineated list of datafield tags to be sampled + library l Legacy library name (affects SQL generation) HELP exit; }