<event code='1648' textcode='PERMISSION_USR_WORK_OU_MAP_NOT_FOUND'>
<desc xml:lang='en-US'>The requested permission_usr_work_ou_map was not found</desc>
</event>
+ <event code='1649' textcode='VANDELAY_IMPORT_ITEM_NOT_FOUND'>
+ <desc xml:lang='en-US'>The requested vandelay.import_item was not found</desc>
+ </event>
use OpenILS::Application::Cat::Merge;
use OpenILS::Application::Cat::Authority;
use OpenILS::Application::Cat::BibCommon;
+use OpenILS::Application::Cat::AssetCommon;
use base qw/OpenILS::Application/;
use Time::HiRes qw(time);
use OpenSRF::EX qw(:try);
return $evt if $evt;
my $editor = new_editor(requestor => $reqr, xact => 1);
my $override = $self->api_name =~ /override/;
- $evt = update_fleshed_copies($editor, $override, undef, $copies, $delete_stats);
+ $evt = OpenILS::Application::Cat::AssetCommon->update_fleshed_copies(
+ $editor, $override, undef, $copies, $delete_stats);
if( $evt ) {
$logger->info("fleshed copy update failed with event: ".OpenSRF::Utils::JSON->perl2JSON($evt));
$editor->rollback;
} elsif( $vol->isnew ) {
$logger->info("vol-update: creating volume");
- $evt = create_volume( $override, $editor, $vol );
+ $evt = OpenILS::Application::Cat::AssetCommon->create_volume( $override, $editor, $vol );
return $evt if $evt;
} elsif( $vol->ischanged ) {
# now update any attached copies
if( $copies and @$copies and !$vol->isdeleted ) {
$_->call_number($vol->id) for @$copies;
- $evt = update_fleshed_copies( $editor, $override, $vol, $copies, $delete_stats );
+ $evt = OpenILS::Application::Cat::AssetCommon->update_fleshed_copies(
+ $editor, $override, $vol, $copies, $delete_stats);
return $evt if $evt;
}
}
my $editor = shift;
my $evt;
- return $evt if ( $evt = org_cannot_have_vols($editor, $vol->owning_lib) );
+ return $evt if ( $evt = OpenILS::Application::Cat::AssetCommon->org_cannot_have_vols($editor, $vol->owning_lib) );
my $vols = $editor->search_asset_call_number( {
owning_lib => $vol->owning_lib,
}
-# this does the actual work
-sub update_fleshed_copies {
- my( $editor, $override, $vol, $copies, $delete_stats ) = @_;
-
- my $evt;
- my $fetchvol = ($vol) ? 0 : 1;
-
- my %cache;
- $cache{$vol->id} = $vol if $vol;
-
- for my $copy (@$copies) {
-
- my $copyid = $copy->id;
- $logger->info("vol-update: inspecting copy $copyid");
-
- if( !($vol = $cache{$copy->call_number}) ) {
- $vol = $cache{$copy->call_number} =
- $editor->retrieve_asset_call_number($copy->call_number);
- return $editor->event unless $vol;
- }
-
- return $editor->event unless
- $editor->allowed('UPDATE_COPY', copy_perm_org($vol, $copy));
-
- $copy->editor($editor->requestor->id);
- $copy->edit_date('now');
-
- $copy->status( $copy->status->id ) if ref($copy->status);
- $copy->location( $copy->location->id ) if ref($copy->location);
- $copy->circ_lib( $copy->circ_lib->id ) if ref($copy->circ_lib);
-
- my $sc_entries = $copy->stat_cat_entries;
- $copy->clear_stat_cat_entries;
-
- if( $copy->isdeleted ) {
- $evt = delete_copy($editor, $override, $vol, $copy);
- return $evt if $evt;
-
- } elsif( $copy->isnew ) {
- $evt = create_copy( $editor, $vol, $copy );
- return $evt if $evt;
-
- } elsif( $copy->ischanged ) {
-
- $evt = update_copy( $editor, $override, $vol, $copy );
- return $evt if $evt;
- }
-
- $copy->stat_cat_entries( $sc_entries );
- $evt = update_copy_stat_entries($editor, $copy, $delete_stats);
- return $evt if $evt;
- }
-
- $logger->debug("vol-update: done updating copy batch");
-
- return undef;
-}
-
-sub fix_copy_price {
- my $copy = shift;
-
- if(defined $copy->price) {
- my $p = $copy->price || 0;
- $p =~ s/\$//og;
- $copy->price($p);
- }
-
- my $d = $copy->deposit_amount || 0;
- $d =~ s/\$//og;
- $copy->deposit_amount($d);
-}
-
-
-sub update_copy {
- my( $editor, $override, $vol, $copy ) = @_;
-
- my $evt;
- my $org = (ref $copy->circ_lib) ? $copy->circ_lib->id : $copy->circ_lib;
- return $evt if ( $evt = org_cannot_have_vols($editor, $org) );
-
- $logger->info("vol-update: updating copy ".$copy->id);
- my $orig_copy = $editor->retrieve_asset_copy($copy->id);
- my $orig_vol = $editor->retrieve_asset_call_number($copy->call_number);
-
- $copy->editor($editor->requestor->id);
- $copy->edit_date('now');
-
- $copy->age_protect( $copy->age_protect->id )
- if ref $copy->age_protect;
-
- fix_copy_price($copy);
-
- return $editor->event unless $editor->update_asset_copy($copy);
- return remove_empty_objects($editor, $override, $orig_vol);
-}
-
-
sub remove_empty_objects {
my( $editor, $override, $vol ) = @_;
}
-sub create_copy {
- my( $editor, $vol, $copy ) = @_;
-
- my $existing = $editor->search_asset_copy(
- { barcode => $copy->barcode, deleted => 'f' } );
-
- return OpenILS::Event->new('ITEM_BARCODE_EXISTS') if @$existing;
-
- # see if the volume this copy references is marked as deleted
- my $evol = $editor->retrieve_asset_call_number($copy->call_number)
- or return $editor->event;
- return OpenILS::Event->new('VOLUME_DELETED', vol => $evol->id)
- if $U->is_true($evol->deleted);
-
- my $evt;
- my $org = (ref $copy->circ_lib) ? $copy->circ_lib->id : $copy->circ_lib;
- return $evt if ( $evt = org_cannot_have_vols($editor, $org) );
-
- $copy->clear_id;
- $copy->creator($editor->requestor->id);
- $copy->create_date('now');
- fix_copy_price($copy);
-
- $editor->create_asset_copy($copy) or return $editor->event;
- return undef;
-}
-
-# if 'delete_stats' is true, the copy->stat_cat_entries data is
-# treated as the authoritative list for the copy. existing entries
-# that are not in said list will be deleted from the DB
-sub update_copy_stat_entries {
- my( $editor, $copy, $delete_stats ) = @_;
-
- return undef if $copy->isdeleted;
- return undef unless $copy->ischanged or $copy->isnew;
-
- my $evt;
- my $entries = $copy->stat_cat_entries;
-
- if( $delete_stats ) {
- $entries = ($entries and @$entries) ? $entries : [];
- } else {
- return undef unless ($entries and @$entries);
- }
-
- my $maps = $editor->search_asset_stat_cat_entry_copy_map({owning_copy=>$copy->id});
-
- if(!$copy->isnew) {
- # if there is no stat cat entry on the copy who's id matches the
- # current map's id, remove the map from the database
- for my $map (@$maps) {
- if(! grep { $_->id == $map->stat_cat_entry } @$entries ) {
-
- $logger->info("copy update found stale ".
- "stat cat entry map ".$map->id. " on copy ".$copy->id);
-
- $editor->delete_asset_stat_cat_entry_copy_map($map)
- or return $editor->event;
- }
- }
- }
-
- # go through the stat cat update/create process
- for my $entry (@$entries) {
- next unless $entry;
-
- # if this link already exists in the DB, don't attempt to re-create it
- next if( grep{$_->stat_cat_entry == $entry->id} @$maps );
-
- my $new_map = Fieldmapper::asset::stat_cat_entry_copy_map->new();
-
- my $sc = ref($entry->stat_cat) ? $entry->stat_cat->id : $entry->stat_cat;
-
- $new_map->stat_cat( $sc );
- $new_map->stat_cat_entry( $entry->id );
- $new_map->owning_copy( $copy->id );
-
- $editor->create_asset_stat_cat_entry_copy_map($new_map)
- or return $editor->event;
-
- $logger->info("copy update created new stat cat entry map ".$editor->data);
- }
-
- return undef;
-}
-
-
-sub create_volume {
- my( $override, $editor, $vol ) = @_;
- my $evt;
-
- return $evt if ( $evt = org_cannot_have_vols($editor, $vol->owning_lib) );
-
- # see if the record this volume references is marked as deleted
- my $rec = $editor->retrieve_biblio_record_entry($vol->record)
- or return $editor->event;
- return OpenILS::Event->new('BIB_RECORD_DELETED', rec => $rec->id)
- if $U->is_true($rec->deleted);
-
- # first lets see if there are any collisions
- my $vols = $editor->search_asset_call_number( {
- owning_lib => $vol->owning_lib,
- record => $vol->record,
- label => $vol->label,
- deleted => 'f'
- }
- );
-
- my $label = undef;
- if(@$vols) {
- # we've found an exising volume
- if($override) {
- $label = $vol->label;
- } else {
- return OpenILS::Event->new(
- 'VOLUME_LABEL_EXISTS', payload => $vol->id);
- }
- }
-
- # create a temp label so we can create the new volume,
- # then de-dup it with the existing volume
- $vol->label( "__SYSTEM_TMP_$$".time) if $label;
-
- $vol->creator($editor->requestor->id);
- $vol->create_date('now');
- $vol->editor($editor->requestor->id);
- $vol->edit_date('now');
- $vol->clear_id;
-
- $editor->create_asset_call_number($vol) or return $editor->event;
-
- if($label) {
- # now restore the label and merge into the existing record
- $vol->label($label);
- (undef, $evt) =
- OpenILS::Application::Cat::Merge::merge_volumes($editor, [$vol], $$vols[0]);
- return $evt if $evt;
- }
-
- return undef;
-}
__PACKAGE__->register_method (
my $ou_type = $e->retrieve_actor_org_unit_type($dorg->ou_type)
or return $e->event;
- return $evt if ( $evt = org_cannot_have_vols($e, $o_lib) );
+ return $evt if ( $evt = OpenILS::Application::Cat::AssetCommon->org_cannot_have_vols($e, $o_lib) );
my $vols = $e->batch_retrieve_asset_call_number($vol_ids);
my @seen;
-sub org_cannot_have_vols {
- my $e = shift;
- my $org_id = shift;
-
- my $org = $e->retrieve_actor_org_unit($org_id)
- or return $e->event;
-
- my $ou_type = $e->retrieve_actor_org_unit_type($org->ou_type)
- or return $e->event;
-
- return OpenILS::Event->new('ORG_CANNOT_HAVE_VOLS')
- unless $U->is_true($ou_type->can_have_vols);
-
- return 0;
-}
-
-
-
__PACKAGE__->register_method(
api_name => 'open-ils.cat.call_number.find_or_create',
my( $self, $conn, $auth, $label, $record_id, $org_id ) = @_;
my $e = new_editor(authtoken=>$auth, xact=>1);
return $e->die_event unless $e->checkauth;
-
- my $vol;
-
- if($record_id == OILS_PRECAT_RECORD) {
-
- $vol = $e->retrieve_asset_call_number(OILS_PRECAT_CALL_NUMBER)
- or return $e->die_event;
-
- } else {
-
- $vol = $e->search_asset_call_number(
- {label => $label, record => $record_id, owning_lib => $org_id, deleted => 'f'},
- {idlist=>1}
- )->[0];
- }
-
- # If the volume exists, return the ID
- if( $vol ) { $e->rollback; return $vol; }
-
- # -----------------------------------------------------------------
- # Otherwise, create a new volume with the given attributes
- # -----------------------------------------------------------------
-
- return $e->die_event unless $e->allowed('UPDATE_VOLUME', $org_id);
-
- $vol = Fieldmapper::asset::call_number->new;
- $vol->owning_lib($org_id);
- $vol->label($label);
- $vol->record($record_id);
-
- my $evt = create_volume( 0, $e, $vol );
- return $evt if $evt;
-
- $e->commit;
- return $vol->id;
+ my ($vol, $evt, $exists) =
+ OpenILS::Application::Cat::AssetCommon->find_or_create_volume($label, $e, $record_id, $org_id);
+ return $evt if $evt;
+ $e->rollback if $exists;
+ $e->commit if $vol;
+ return $vol->id;
}
--- /dev/null
+package OpenILS::Application::Cat::AssetCommon;
+use strict; use warnings;
+use OpenILS::Utils::CStoreEditor q/:funcs/;
+use OpenSRF::Utils::Logger qw($logger);
+use OpenILS::Application::Cat::Merge;
+use OpenILS::Application::AppUtils;
+use OpenILS::Utils::Fieldmapper;
+use OpenILS::Const qw/:const/;
+use OpenSRF::AppSession;
+use OpenILS::Event;
+my $U = 'OpenILS::Application::AppUtils';
+
+
+# ---------------------------------------------------------------------------
+# Shared copy mangling code. Do not publish methods from here.
+# ---------------------------------------------------------------------------
+
+sub org_cannot_have_vols {
+ my($class, $e, $org_id) = @_;
+ my $org = $e->retrieve_actor_org_unit([
+ $org_id,
+ { flesh => 1,
+ flesh_fields => {aou => ['ou_type']}
+ }]) or return $e->event;
+
+ return OpenILS::Event->new('ORG_CANNOT_HAVE_VOLS')
+ unless $U->is_true($org->ou_type->can_have_vols);
+
+ return 0;
+}
+
+sub fix_copy_price {
+ my $class = shift;
+ my $copy = shift;
+
+ if(defined $copy->price) {
+ my $p = $copy->price || 0;
+ $p =~ s/\$//og;
+ $copy->price($p);
+ }
+
+ my $d = $copy->deposit_amount || 0;
+ $d =~ s/\$//og;
+ $copy->deposit_amount($d);
+}
+
+sub create_copy {
+ my($class, $editor, $vol, $copy) = @_;
+
+ my $existing = $editor->search_asset_copy(
+ { barcode => $copy->barcode, deleted => 'f' } );
+
+ return OpenILS::Event->new('ITEM_BARCODE_EXISTS') if @$existing;
+
+ # see if the volume this copy references is marked as deleted
+ return OpenILS::Event->new('VOLUME_DELETED', vol => $vol->id)
+ if $U->is_true($vol->deleted);
+
+ my $evt;
+ my $org = (ref $copy->circ_lib) ? $copy->circ_lib->id : $copy->circ_lib;
+ return $evt if ($evt = OpenILS::Application::Cat::AssetCommon->org_cannot_have_vols($editor, $org));
+
+ $copy->clear_id;
+ $copy->editor($editor->requestor->id);
+ $copy->creator($editor->requestor->id);
+ $copy->create_date('now');
+ $copy->call_number($vol->id);
+ $class->fix_copy_price($copy);
+
+ $editor->create_asset_copy($copy) or return $editor->die_event;
+ return undef;
+}
+
+
+# if 'delete_stats' is true, the copy->stat_cat_entries data is
+# treated as the authoritative list for the copy. existing entries
+# that are not in said list will be deleted from the DB
+sub update_copy_stat_entries {
+ my($class, $editor, $copy, $delete_stats) = @_;
+
+ return undef if $copy->isdeleted;
+ return undef unless $copy->ischanged or $copy->isnew;
+
+ my $evt;
+ my $entries = $copy->stat_cat_entries;
+
+ if( $delete_stats ) {
+ $entries = ($entries and @$entries) ? $entries : [];
+ } else {
+ return undef unless ($entries and @$entries);
+ }
+
+ my $maps = $editor->search_asset_stat_cat_entry_copy_map({owning_copy=>$copy->id});
+
+ if(!$copy->isnew) {
+ # if there is no stat cat entry on the copy who's id matches the
+ # current map's id, remove the map from the database
+ for my $map (@$maps) {
+ if(! grep { $_->id == $map->stat_cat_entry } @$entries ) {
+
+ $logger->info("copy update found stale ".
+ "stat cat entry map ".$map->id. " on copy ".$copy->id);
+
+ $editor->delete_asset_stat_cat_entry_copy_map($map)
+ or return $editor->event;
+ }
+ }
+ }
+
+ # go through the stat cat update/create process
+ for my $entry (@$entries) {
+ next unless $entry;
+
+ # if this link already exists in the DB, don't attempt to re-create it
+ next if( grep{$_->stat_cat_entry == $entry->id} @$maps );
+
+ my $new_map = Fieldmapper::asset::stat_cat_entry_copy_map->new();
+
+ my $sc = ref($entry->stat_cat) ? $entry->stat_cat->id : $entry->stat_cat;
+
+ $new_map->stat_cat( $sc );
+ $new_map->stat_cat_entry( $entry->id );
+ $new_map->owning_copy( $copy->id );
+
+ $editor->create_asset_stat_cat_entry_copy_map($new_map)
+ or return $editor->event;
+
+ $logger->info("copy update created new stat cat entry map ".$editor->data);
+ }
+
+ return undef;
+}
+
+
+sub update_copy {
+ my($class, $editor, $override, $vol, $copy) = @_;
+
+ my $evt;
+ my $org = (ref $copy->circ_lib) ? $copy->circ_lib->id : $copy->circ_lib;
+ return $evt if ( $evt = OpenILS::Application::Cat::AssetCommon->org_cannot_have_vols($editor, $org) );
+
+ $logger->info("vol-update: updating copy ".$copy->id);
+ my $orig_copy = $editor->retrieve_asset_copy($copy->id);
+ my $orig_vol = $editor->retrieve_asset_call_number($copy->call_number);
+
+ $copy->editor($editor->requestor->id);
+ $copy->edit_date('now');
+
+ $copy->age_protect( $copy->age_protect->id )
+ if ref $copy->age_protect;
+
+ $class->fix_copy_price($copy);
+
+ return $editor->event unless $editor->update_asset_copy($copy);
+ return remove_empty_objects($editor, $override, $orig_vol);
+}
+
+
+# this does the actual work
+sub update_fleshed_copies {
+ my($class, $editor, $override, $vol, $copies, $delete_stats) = @_;
+
+ my $evt;
+ my $fetchvol = ($vol) ? 0 : 1;
+
+ my %cache;
+ $cache{$vol->id} = $vol if $vol;
+
+ for my $copy (@$copies) {
+
+ my $copyid = $copy->id;
+ $logger->info("vol-update: inspecting copy $copyid");
+
+ if( !($vol = $cache{$copy->call_number}) ) {
+ $vol = $cache{$copy->call_number} =
+ $editor->retrieve_asset_call_number($copy->call_number);
+ return $editor->event unless $vol;
+ }
+
+ return $editor->event unless
+ $editor->allowed('UPDATE_COPY', copy_perm_org($vol, $copy));
+
+ $copy->editor($editor->requestor->id);
+ $copy->edit_date('now');
+
+ $copy->status( $copy->status->id ) if ref($copy->status);
+ $copy->location( $copy->location->id ) if ref($copy->location);
+ $copy->circ_lib( $copy->circ_lib->id ) if ref($copy->circ_lib);
+
+ my $sc_entries = $copy->stat_cat_entries;
+ $copy->clear_stat_cat_entries;
+
+ if( $copy->isdeleted ) {
+ $evt = delete_copy($editor, $override, $vol, $copy);
+ return $evt if $evt;
+
+ } elsif( $copy->isnew ) {
+ $evt = $class->create_copy( $editor, $vol, $copy );
+ return $evt if $evt;
+
+ } elsif( $copy->ischanged ) {
+
+ $evt = $class->update_copy( $editor, $override, $vol, $copy );
+ return $evt if $evt;
+ }
+
+ $copy->stat_cat_entries( $sc_entries );
+ $evt = $class->update_copy_stat_entries($editor, $copy, $delete_stats);
+ return $evt if $evt;
+ }
+
+ $logger->debug("vol-update: done updating copy batch");
+
+ return undef;
+}
+
+sub create_volume {
+ my($class, $override, $editor, $vol) = @_;
+ my $evt;
+
+ return $evt if ( $evt = $class->org_cannot_have_vols($editor, $vol->owning_lib) );
+
+ # see if the record this volume references is marked as deleted
+ my $rec = $editor->retrieve_biblio_record_entry($vol->record)
+ or return $editor->die_event;
+ return OpenILS::Event->new('BIB_RECORD_DELETED', rec => $rec->id)
+ if $U->is_true($rec->deleted);
+
+ # first lets see if there are any collisions
+ my $vols = $editor->search_asset_call_number( {
+ owning_lib => $vol->owning_lib,
+ record => $vol->record,
+ label => $vol->label,
+ deleted => 'f'
+ }
+ );
+
+ my $label = undef;
+ if(@$vols) {
+ # we've found an exising volume
+ if($override) {
+ $label = $vol->label;
+ } else {
+ return OpenILS::Event->new(
+ 'VOLUME_LABEL_EXISTS', payload => $vol->id);
+ }
+ }
+
+ # create a temp label so we can create the new volume,
+ # then de-dup it with the existing volume
+ $vol->label( "__SYSTEM_TMP_$$".time) if $label;
+
+ $vol->creator($editor->requestor->id);
+ $vol->create_date('now');
+ $vol->editor($editor->requestor->id);
+ $vol->edit_date('now');
+ $vol->clear_id;
+
+ $editor->create_asset_call_number($vol) or return $editor->die_event;
+
+ if($label) {
+ # now restore the label and merge into the existing record
+ $vol->label($label);
+ (undef, $evt) =
+ OpenILS::Application::Cat::Merge::merge_volumes($editor, [$vol], $$vols[0]);
+ return $evt if $evt;
+ }
+
+ return undef;
+}
+
+# returns the volume if it exists
+sub volume_exists {
+ my($class, $e, $rec_id, $label, $owning_lib) = @_;
+ return $e->search_asset_call_number(
+ {label => $label, record => $rec_id, owning_lib => $owning_lib, deleted => 'f'})->[0];
+}
+
+sub find_or_create_volume {
+ my($class, $e, $label, $record_id, $org_id) = @_;
+
+ my $vol;
+
+ if($record_id == OILS_PRECAT_RECORD) {
+ $vol = $e->retrieve_asset_call_number(OILS_PRECAT_CALL_NUMBER)
+ or return (undef, $e->die_event);
+
+ } else {
+ $vol = $class->volume_exists($e, $record_id, $label, $org_id);
+ }
+
+ # If the volume exists, return the ID
+ return ($vol, undef, 1) if $vol;
+
+ # -----------------------------------------------------------------
+ # Otherwise, create a new volume with the given attributes
+ # -----------------------------------------------------------------
+ return (undef, $e->die_event) unless $e->allowed('UPDATE_VOLUME', $org_id);
+
+ $vol = Fieldmapper::asset::call_number->new;
+ $vol->owning_lib($org_id);
+ $vol->label($label);
+ $vol->record($record_id);
+
+ my $evt = OpenILS::Application::Cat::AssetCommon->create_volume(0, $e, $vol);
+ return (undef, $evt) if $evt;
+
+ return ($vol);
+}
+
+
+sub create_copy_note {
+ my($class, $e, $copy, $title, $value, $pub) = @_;
+ my $note = Fieldmapper::asset::copy_note->new;
+ $note->owning_copy($copy->id);
+ $note->creator($e->requestor->id);
+ $note->pub('t');
+ $note->value($value);
+ $note->title($title);
+ $e->create_asset_copy_note($note) or return $e->die_event;
+ return undef;
+}
+
+
+
use Time::HiRes qw(time);
use OpenSRF::Utils::Logger qw/$logger/;
use MIME::Base64;
+use OpenILS::Const qw/:const/;
use OpenILS::Application::AppUtils;
use OpenILS::Application::Cat::BibCommon;
use OpenILS::Application::Cat::AuthCommon;
+use OpenILS::Application::Cat::AssetCommon;
my $U = 'OpenILS::Application::AppUtils';
sub initialize {}
} else {
_add_auth_rec( $e, $xml, $queue_id, $purpose ) or return $e->die_event;
}
- $count++;
-
- $client->respond( $count );
+ $client->respond($count) if (++$count % 10) == 0;
} catch Error with {
my $error = shift;
$logger->warn("Encountered a bad record at Vandelay ingest: ".$error);
}
$e->commit;
- $conn->respond({total => $total, progress => ++$count, imported => $rec_id});
+ $conn->respond({total => $total, progress => $count, imported => $rec_id}) if (++$count % 10) == 0;
}
# see if we need to mark any queues as complete
}
+__PACKAGE__->register_method(
+ api_name => "open-ils.vandelay.bib_record.asset.list.import",
+ method => 'import_record_asset_list',
+ api_level => 1,
+ argc => 2,
+ stream => 1,
+ record_type => 'bib'
+);
+
+sub import_record_asset_list {
+ my($self, $conn, $auth, $rec_ids) = @_;
+ my $e = new_editor(authtoken => $auth);
+ return $e->event unless $e->checkauth;
+ my $err = import_record_asset_list_impl($conn, $rec_ids, $e->requestor);
+ return $err if $err;
+ return {complete => 1};
+}
+
+# --------------------------------------------------------------------------------
+# Given a list of queued record IDs, imports all items attached to those records
+# --------------------------------------------------------------------------------
+sub import_record_asset_list_impl {
+ my($conn, $rec_ids, $requestor) = @_;
+
+ my $total = @$rec_ids;
+ my $try_count = 0;
+ my $in_count = 0;
+ my $roe = new_editor(requestor => $requestor);
+
+ for my $rec_id (@$rec_ids) {
+ my $rec = $roe->retrieve_vandelay_queued_bib_record($rec_id);
+ next unless $rec and $rec->import_time;
+ my $item_ids = $roe->search_vandelay_import_item({record => $rec->id}, {idlist=>1});
+
+ for my $item_id (@$item_ids) {
+ my $e = new_editor(requestor => $requestor, xact => 1);
+ my $item = $e->retrieve_vandelay_import_item($item_id);
+ $try_count++;
+
+ # --------------------------------------------------------------------------------
+ # Find or create the volume
+ # --------------------------------------------------------------------------------
+ my ($vol, $evt) =
+ OpenILS::Application::Cat::AssetCommon->find_or_create_volume(
+ $e, $item->call_number, $rec->imported_as, $item->owning_lib);
+
+ if($evt) {
+ respond_with_status($conn, $total, $try_count, $in_count, $evt);
+ $e->rollback;
+ next;
+ }
+
+ # --------------------------------------------------------------------------------
+ # Create the new copy
+ # --------------------------------------------------------------------------------
+ my $copy = Fieldmapper::asset::copy->new;
+ $copy->loan_duration(2);
+ $copy->fine_level(2);
+ $copy->barcode($item->barcode);
+ $copy->location($item->location);
+ $copy->circ_lib($item->circ_lib || $item->owning_lib);
+ $copy->status($item->status || OILS_COPY_STATUS_IN_PROCESS);
+ $copy->circulate($item->circulate);
+ $copy->deposit($item->deposit);
+ $copy->deposit_amount($item->deposit_amount);
+ $copy->ref($item->ref);
+ $copy->holdable($item->holdable);
+ $copy->price($item->price);
+ $copy->circ_as_type($item->circ_as_type);
+ $copy->alert_message($item->alert_message);
+ $copy->opac_visible($item->opac_visible);
+ $copy->circ_modifier($item->circ_modifier);
+
+ # --------------------------------------------------------------------------------
+ # see if a valid circ_modifier was provided
+ # --------------------------------------------------------------------------------
+ #if($copy->circ_modifier and not $e->retrieve_config_circ_modifier($item->circ_modifier)) {
+ if($copy->circ_modifier and not $e->search_config_circ_modifier({code=>$item->circ_modifier})->[0]) {
+ respond_with_status($conn, $total, $try_count, $in_count, $e->die_event);
+ $e->rollback;
+ next;
+ }
+
+ if($evt = OpenILS::Application::Cat::AssetCommon->create_copy($e, $vol, $copy)) {
+ $e->rollback;
+ respond_with_status($conn, $total, $try_count, $in_count, $evt);
+ next;
+ }
+
+ # --------------------------------------------------------------------------------
+ # create copy notes
+ # --------------------------------------------------------------------------------
+ $evt = OpenILS::Application::Cat::AssetCommon->create_copy_note(
+ $e, $copy, '', $item->pub_note, 1) if $item->pub_note;
+
+ if($evt) {
+ respond_with_status($conn, $total, $try_count, $in_count, $evt);
+ $e->rollback;
+ next;
+ }
+
+ $evt = OpenILS::Application::Cat::AssetCommon->create_copy_note(
+ $e, $copy, '', $item->priv_note, 1) if $item->priv_note;
+
+ if($evt) {
+ respond_with_status($conn, $total, $try_count, $in_count, $evt);
+ $e->rollback;
+ next;
+ }
+
+ # --------------------------------------------------------------------------------
+ # Item import succeeded
+ # --------------------------------------------------------------------------------
+ $e->commit;
+ respond_with_status($conn, $total, $try_count, ++$in_count, undef, imported_as => $copy->id);
+ }
+ }
+ return undef;
+}
+
+
+sub respond_with_status {
+ my($conn, $total, $try_count, $success_count, $err, %args) = @_;
+ $conn->respond({
+ total => $total,
+ progress => $try_count,
+ err_event => $err,
+ success_count => $success_count, %args }) if $err or ($try_count % 5 == 0);
+}
+
+
1;
projects / Evergreen.git / commitdiff