From fdd856ebf43d3180f2a2a5137980b56563eb4b7b Mon Sep 17 00:00:00 2001 From: miker Date: Thu, 19 Apr 2007 06:03:21 +0000 Subject: [PATCH] some reporting and error protection git-svn-id: svn://svn.open-ils.org/ILS/trunk@7153 dcc99617-32d9-48b4-a31d-7c20da2025e4 --- Open-ILS/src/support-scripts/marc_export | 130 +++++++++++++++++-------------- 1 file changed, 71 insertions(+), 59 deletions(-) diff --git a/Open-ILS/src/support-scripts/marc_export b/Open-ILS/src/support-scripts/marc_export index 91afffd9ed..6dc7bed45c 100755 --- a/Open-ILS/src/support-scripts/marc_export +++ b/Open-ILS/src/support-scripts/marc_export @@ -70,8 +70,10 @@ if ($format ne 'XML') { } OpenSRF::System->bootstrap_client( config_file => $config ); -my $sc = OpenSRF::Utils::SettingsClient->new; -$idl ||= $sc->config_value("IDL"); + +if (!$idl) { + $idl = OpenSRF::Utils::SettingsClient->new->config_value("IDL"); +} Fieldmapper->import(IDL => $idl); @@ -83,79 +85,89 @@ print <
request( 'open-ils.cstore.direct.actor.org_unit.search.atomic', { id => { '!=' => undef } } )->gather(1); %orgs = map { ( $_->id => $_ ) } @$o; -} -my %shelves; -if ($holdings) { my $s = $ses->request( 'open-ils.cstore.direct.asset.copy_location.search.atomic', { id => { '!=' => undef } } )->gather(1); %shelves = map { ( $_->id => $_ ) } @$s; } +my $start = time; +my $count = 1; while ( my $i = <> ) { my $bib = $ses->request( 'open-ils.cstore.direct.biblio.record_entry.retrieve', $i )->gather(1); next unless $bib; - my $r = MARC::Record->new_from_xml( $bib->marc, $encoding, $format ); - $r->delete_field( $_ ) for ($r->field(901)); - - $r->append_fields( - MARC::Field->new( - 901, '', '', - a => $bib->tcn_value, - b => $bib->tcn_source - ) - ); - - if ($holdings) { - my $cn_list = $ses->request( - 'open-ils.cstore.direct.asset.call_number.search.atomic', - { record => $i, deleted => 'f' } - )->gather(1); - - - my $cp_list = $ses->request( - 'open-ils.cstore.direct.asset.copy.search.atomic', - { call_number => [ map { $_->id } @$cn_list ], deleted => 'f' } - )->gather(1); - - my %cn_map; - push @{$cn_map{$_->call_number}}, $_ for (@$cp_list); - - for my $cn ( @$cn_list ) { - my $cn_map_list = $cn_map{$cn->id}; - for my $cp ( @$cn_map_list ) { - $r->append_fields( - MARC::Field->new( - 852, '4', '', - a => $location, - b => $orgs{$cn->owning_lib}->shortname, - b => $orgs{$cp->circ_lib}->shortname, - c => $shelves{$cp->location}->name, - j => $cn->label, - ($cp->circ_modifier ? ( g => $cp->circ_modifier ) : ()), - p => $cp->barcode, - ($cp->price ? ( y => $dollarsign.$cp->price ) : ()), - ($cp->copy_number ? ( t => $cp->copy_number ) : ()), - ($cp->ref eq 't' ? ( x => 'reference' ) : ()), - ($cp->holdable eq 'f' ? ( x => 'unholdable' ) : ()), - ($cp->circulate eq 'f' ? ( x => 'noncirculating' ) : ()), - ($cp->opac_visible eq 'f' ? ( x => 'hidden' ) : ()), - ) - ); + try { + my $r = MARC::Record->new_from_xml( $bib->marc, $encoding, $format ); + $r->delete_field( $_ ) for ($r->field(901)); + + $r->append_fields( + MARC::Field->new( + 901, '', '', + a => $bib->tcn_value, + b => $bib->tcn_source + ) + ); + + if ($holdings) { + my $cn_list = $ses->request( + 'open-ils.cstore.direct.asset.call_number.search.atomic', + { record => $i, deleted => 'f' } + )->gather(1); + + + my $cp_list = $ses->request( + 'open-ils.cstore.direct.asset.copy.search.atomic', + { call_number => [ map { $_->id } @$cn_list ], deleted => 'f' } + )->gather(1); + + my %cn_map; + push @{$cn_map{$_->call_number}}, $_ for (@$cp_list); + + for my $cn ( @$cn_list ) { + my $cn_map_list = $cn_map{$cn->id}; + for my $cp ( @$cn_map_list ) { + $r->append_fields( + MARC::Field->new( + 852, '4', '', + a => $location, + b => $orgs{$cn->owning_lib}->shortname, + b => $orgs{$cp->circ_lib}->shortname, + c => $shelves{$cp->location}->name, + j => $cn->label, + ($cp->circ_modifier ? ( g => $cp->circ_modifier ) : ()), + p => $cp->barcode, + ($cp->price ? ( y => $dollarsign.$cp->price ) : ()), + ($cp->copy_number ? ( t => $cp->copy_number ) : ()), + ($cp->ref eq 't' ? ( x => 'reference' ) : ()), + ($cp->holdable eq 'f' ? ( x => 'unholdable' ) : ()), + ($cp->circulate eq 'f' ? ( x => 'noncirculating' ) : ()), + ($cp->opac_visible eq 'f' ? ( x => 'hidden' ) : ()), + ) + ); + } } } - } - if (uc($format) eq 'XML') { - print $r->as_xml_record; - } elsif (uc($format) eq 'UNIMARC') { - print $r->as_unimarc - } elsif (uc($format) eq 'USMARC') { - print $r->as_usmarc + if (uc($format) eq 'XML') { + print $r->as_xml_record; + } elsif (uc($format) eq 'UNIMARC') { + print $r->as_unimarc + } elsif (uc($format) eq 'USMARC') { + print $r->as_usmarc + } + } catch { + my $e = shift; + warn "\n$e\n"; + }; + + if (! ($count % 50 )) { + my $speed = sprintf( '%0.4f', $count / time - $start ); + print STDERR "\r $speed / second \r"; } } -- 2.11.0