1 package OpenILS::Application::Storage::Publisher::asset;
2 use base qw/OpenILS::Application::Storage/;
3 #use OpenILS::Application::Storage::CDBI::asset;
4 #use OpenSRF::Utils::Logger qw/:level/;
5 #use OpenILS::Utils::Fieldmapper;
7 #my $log = 'OpenSRF::Utils::Logger';
10 # see /home/miker/cn_browse-test.sql for page up and down sql ...
13 sub cn_browse_pagedown {
19 my $cn = uc($args{label});
20 my $org = $args{org_unit};
21 my $depth = $args{depth};
22 my $boundry_id = $args{boundry_id};
23 my $size = $args{page_size} || 20;
26 my $table = asset::call_number->table;
28 my $descendants = "actor.org_unit_descendants($org)";
30 $descendants = "actor.org_unit_descendants($org,$depth)";
42 on (d.id = cn.owning_lib)
45 or ( cn.id > ? and upper(label) = ? )
46 order by upper(label), 4, 2
50 my $sth = asset::call_number->db_Main->prepare($sql);
51 $sth->execute($cn, $boundry_id, $cn);
52 while ( my @row = $sth->fetchrow_array ) {
53 $client->respond([@row]);
59 __PACKAGE__->register_method(
60 method => 'cn_browse_pagedown',
61 api_name => 'open-ils.storage.asset.call_number.browse.page_down',
66 sub cn_browse_pageup {
72 my $cn = uc($args{label});
73 my $org = $args{org_unit};
74 my $depth = $args{depth};
75 my $boundry_id = $args{boundry_id};
76 my $size = $args{page_size} || 20;
79 my $table = asset::call_number->table;
81 my $descendants = "actor.org_unit_descendants($org)";
83 $descendants = "actor.org_unit_descendants($org,$depth)";
96 on (d.id = cn.owning_lib)
99 or ( cn.id < ? and upper(label) = ? )
100 order by upper(label) desc, 4 desc, 2 desc
106 my $sth = asset::call_number->db_Main->prepare($sql);
107 $sth->execute($cn, $boundry_id, $cn);
108 while ( my @row = $sth->fetchrow_array ) {
109 $client->respond([@row]);
115 __PACKAGE__->register_method(
116 method => 'cn_browse_pageup',
117 api_name => 'open-ils.storage.asset.call_number.browse.page_up',
122 sub cn_browse_target {
128 my $cn = uc($args{label});
129 my $org = $args{org_unit};
130 my $depth = $args{depth};
131 my $size = $args{page_size} || 20;
132 my $topsize = $size / 2;
133 $topsize = int($topsize);
134 $bottomsize = $size - $topsize;
136 my $table = asset::call_number->table;
138 my $descendants = "actor.org_unit_descendants($org)";
139 if (defined $depth) {
140 $descendants = "actor.org_unit_descendants($org,$depth)";
143 my $top_sql = <<" SQL";
153 on (d.id = cn.owning_lib)
156 order by upper(label) desc, 4 desc, 2 desc
162 my $bottom_sql = <<" SQL";
171 on (d.id = cn.owning_lib)
174 order by upper(label),4,2
178 my $sth = asset::call_number->db_Main->prepare($top_sql);
180 while ( my @row = $sth->fetchrow_array ) {
181 $client->respond([@row]);
185 $sth = asset::call_number->db_Main->prepare($bottom_sql);
187 while ( my @row = $sth->fetchrow_array ) {
188 $client->respond([@row]);
194 __PACKAGE__->register_method(
195 method => 'cn_browse_target',
196 api_name => 'open-ils.storage.asset.call_number.browse.target',
209 return unless ($cp && $org);
211 $cp = $cp->id if (ref $cp);
212 $cp = asset::copy->retrieve($cp);
214 my $ol = $cp->call_number->owning_lib;
216 return asset::copy->db_Main->selectcol_arrayref('SELECT actor.org_unit_proximity(?,?)',{},"$ol","$org")->[0];
218 __PACKAGE__->register_method(
219 method => 'copy_proximity',
220 api_name => 'open-ils.storage.asset.copy.proximity',
225 sub asset_copy_location_all {
229 for my $rec ( asset::copy_location->retrieve_all ) {
230 $client->respond( $rec->to_fieldmapper );
235 __PACKAGE__->register_method(
236 method => 'asset_copy_location_all',
237 api_name => 'open-ils.storage.direct.asset.copy_location.retrieve.all',
242 # XXX arg, with the descendancy SPs...
243 sub ranged_asset_copy_location {
248 my $ctable = asset::copy_location->table;
250 my $descendants = defined($binds[1]) ?
251 "actor.org_unit_full_path(?, ?)" :
252 "actor.org_unit_full_path(?)" ;
259 ON (d.id = c.owning_lib)
262 my $sth = asset::copy_location->db_Main->prepare($sql);
263 $sth->execute(@binds);
265 while ( my $rec = $sth->fetchrow_hashref ) {
267 my $cnct = new Fieldmapper::asset::copy_location;
268 map {$cnct->$_($$rec{$_})} keys %$rec;
269 $client->respond( $cnct );
274 __PACKAGE__->register_method(
275 method => 'ranged_asset_copy_location',
276 api_name => 'open-ils.storage.ranged.asset.copy_location.retrieve',
287 return undef unless (@ids);
289 @ids = ($ids[0]) unless ($self->api_name =~ /batch/o);
291 for my $id ( @ids ) {
293 my $cp = asset::copy->retrieve($id);
296 my $cp_fm = $cp->to_fieldmapper;
297 $cp_fm->circ_lib( $cp->circ_lib->to_fieldmapper );
298 $cp_fm->location( $cp->location->to_fieldmapper );
299 $cp_fm->status( $cp->status->to_fieldmapper );
300 $cp_fm->stat_cat_entries( [ map { $_->to_fieldmapper } $cp->stat_cat_entries ] );
302 $client->respond( $cp_fm );
307 __PACKAGE__->register_method(
308 api_name => 'open-ils.storage.fleshed.asset.copy.batch.retrieve',
309 method => 'fleshed_copy',
313 __PACKAGE__->register_method(
314 api_name => 'open-ils.storage.fleshed.asset.copy.retrieve',
315 method => 'fleshed_copy',
319 sub fleshed_copy_by_barcode {
324 my ($cp) = asset::copy->search( { barcode => $bc } );
326 return undef unless ($cp);
328 my $cp_fm = $cp->to_fieldmapper;
329 $cp_fm->circ_lib( $cp->circ_lib->to_fieldmapper );
330 $cp_fm->location( $cp->location->to_fieldmapper );
331 $cp_fm->status( $cp->status->to_fieldmapper );
335 __PACKAGE__->register_method(
336 api_name => 'open-ils.storage.fleshed.asset.copy.search.barcode',
337 method => 'fleshed_copy_by_barcode',
343 #XXX Fix stored proc calls
344 sub fleshed_asset_stat_cat {
349 @list = ($list[0]) unless ($self->api_name =~ /batch/o);
351 my $cat = asset::stat_cat->retrieve($sc);
355 my $sc_fm = $cat->to_fieldmapper;
356 $sc_fm->entries( [ map { $_->to_fieldmapper } $cat->entries ] );
357 $client->respond( $sc_fm );
362 __PACKAGE__->register_method(
363 api_name => 'open-ils.storage.fleshed.asset.stat_cat.retrieve',
365 method => 'fleshed_asset_stat_cat',
368 __PACKAGE__->register_method(
369 api_name => 'open-ils.storage.fleshed.asset.stat_cat.retrieve.batch',
372 method => 'fleshed_asset_stat_cat',
376 #XXX Fix stored proc calls
377 sub ranged_asset_stat_cat {
382 return undef unless ($ou);
383 my $s_table = asset::stat_cat->table;
385 my $select = <<" SQL";
388 JOIN actor.org_unit_full_path(?) p ON (p.id = s.owner)
393 $fleshed = 1 if ($self->api_name =~ /fleshed/o);
395 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
398 for my $sc ( map { asset::stat_cat->construct($_) } $sth->fetchall_hash ) {
399 my $sc_fm = $sc->to_fieldmapper;
401 [ $self->method_lookup( 'open-ils.storage.ranged.asset.stat_cat_entry.search.stat_cat' )->run($ou,$sc->id) ]
403 $client->respond( $sc_fm );
408 __PACKAGE__->register_method(
409 api_name => 'open-ils.storage.ranged.fleshed.asset.stat_cat.all',
412 method => 'ranged_asset_stat_cat',
415 __PACKAGE__->register_method(
416 api_name => 'open-ils.storage.ranged.asset.stat_cat.all',
419 method => 'ranged_asset_stat_cat',
423 #XXX Fix stored proc calls
424 sub multiranged_asset_stat_cat {
429 return undef unless (defined($ous) and @$ous);
430 my $s_table = asset::stat_cat->table;
432 my $select = <<" SQL";
435 WHERE s.owner IN ( XXX )
439 my $collector = ' INTERSECT ';
440 my $entry_method = 'open-ils.storage.multiranged.intersect.asset.stat_cat_entry.search.stat_cat';
441 if ($self->api_name =~ /union/o) {
442 $collector = ' UNION ';
443 $entry_method = 'open-ils.storage.multiranged.union.asset.stat_cat_entry.search.stat_cat';
446 my $binds = join($collector, map { 'SELECT id FROM actor.org_unit_full_path(?)' } grep {defined} @$ous);
447 $select =~ s/XXX/$binds/so;
450 $fleshed = 1 if ($self->api_name =~ /fleshed/o);
452 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
453 $sth->execute(map { "$_" } grep {defined} @$ous);
455 for my $sc ( map { asset::stat_cat->construct($_) } $sth->fetchall_hash ) {
456 my $sc_fm = $sc->to_fieldmapper;
458 [ $self->method_lookup( $entry_method )->run($ous, $sc->id) ]
460 $client->respond( $sc_fm );
465 __PACKAGE__->register_method(
466 api_name => 'open-ils.storage.multiranged.intersect.fleshed.asset.stat_cat.all',
469 method => 'multiranged_asset_stat_cat',
471 __PACKAGE__->register_method(
472 api_name => 'open-ils.storage.multiranged.union.fleshed.asset.stat_cat.all',
475 method => 'multiranged_asset_stat_cat',
478 #XXX Fix stored proc calls
479 sub ranged_asset_stat_cat_entry {
485 return undef unless ($ou);
486 my $s_table = asset::stat_cat_entry->table;
488 my $select = <<" SQL";
491 JOIN actor.org_unit_full_path(?) p ON (p.id = s.owner)
496 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
497 $sth->execute($ou,$sc);
499 for my $sce ( map { asset::stat_cat_entry->construct($_) } $sth->fetchall_hash ) {
500 $client->respond( $sce->to_fieldmapper );
505 __PACKAGE__->register_method(
506 api_name => 'open-ils.storage.ranged.asset.stat_cat_entry.search.stat_cat',
509 method => 'ranged_asset_stat_cat_entry',
512 #XXX Fix stored proc calls
513 sub multiranged_asset_stat_cat_entry {
519 return undef unless (defined($ous) and @$ous);
520 my $s_table = asset::stat_cat_entry->table;
522 my $collector = ' INTERSECT ';
523 $collector = ' UNION ' if ($self->api_name =~ /union/o);
525 my $select = <<" SQL";
528 WHERE s.owner IN ( XXX ) and s.stat_cat = ?
532 my $binds = join($collector, map { 'SELECT id FROM actor.org_unit_full_path(?)' } grep {defined} @$ous);
533 $select =~ s/XXX/$binds/so;
535 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
536 $sth->execute(map {"$_"} @$ous,$sc);
538 for my $sce ( map { asset::stat_cat_entry->construct($_) } $sth->fetchall_hash ) {
539 $client->respond( $sce->to_fieldmapper );
544 __PACKAGE__->register_method(
545 api_name => 'open-ils.storage.multiranged.intersect.asset.stat_cat_entry.search.stat_cat',
548 method => 'multiranged_asset_stat_cat_entry',
550 __PACKAGE__->register_method(
551 api_name => 'open-ils.storage.multiranged.union.asset.stat_cat_entry.search.stat_cat',
554 method => 'multiranged_asset_stat_cat_entry',
563 my $depth = shift || 0;
568 ->selectcol_arrayref(
569 'SELECT id FROM actor.org_unit_descendants(?,?)',
575 return undef unless ($ou_list and @$ou_list);
577 $cn = asset::call_number->retrieve( $cn );
578 return undef unless ($cn);
580 my $call_number = $cn->to_fieldmapper;
581 $call_number->copies([]);
583 $call_number->record( $cn->record->to_fieldmapper );
584 $call_number->record->fixed_fields( $cn->record->record_descriptor->next->to_fieldmapper );
586 for my $cp ( $cn->copies(circ_lib => $ou_list) ) {
587 my $copy = $cp->to_fieldmapper;
588 $copy->status( $cp->status->to_fieldmapper );
589 $copy->location( $cp->status->to_fieldmapper );
591 push @{ $call_number->copies }, $copy;
596 __PACKAGE__->register_method(
597 api_name => 'open-ils.storage.asset.call_number.ranged_tree',
598 method => 'cn_ranged_tree',