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';
16 return unless ($cp && $org);
18 $cp = $cp->id if (ref $cp);
19 $cp = asset::copy->retrieve($cp);
20 return 999 unless $copy;
21 my $ol = $cp->call_number->owning_lib;
23 return asset::copy->db_Main->selectcol_arrayref('SELECT actor.org_unit_proximity(?,?)',{},"$ol","$org")->[0];
25 __PACKAGE__->register_method(
26 method => 'copy_proximity',
27 api_name => 'open-ils.storage.asset.copy.proximity',
32 sub asset_copy_location_all {
36 for my $rec ( asset::copy_location->retrieve_all ) {
37 $client->respond( $rec->to_fieldmapper );
42 __PACKAGE__->register_method(
43 method => 'asset_copy_location_all',
44 api_name => 'open-ils.storage.direct.asset.copy_location.retrieve.all',
54 return undef unless (@ids);
56 @ids = ($ids[0]) unless ($self->api_name =~ /batch/o);
60 my $cp = asset::copy->retrieve($id);
62 my $cp_fm = $cp->to_fieldmapper;
63 $cp_fm->circ_lib( $cp->circ_lib->to_fieldmapper );
64 $cp_fm->location( $cp->location->to_fieldmapper );
65 $cp_fm->status( $cp->status->to_fieldmapper );
66 $cp_fm->stat_cat_entries( [ map { $_->to_fieldmapper } $cp->stat_cat_entries ] );
68 $client->respond( $cp_fm );
73 __PACKAGE__->register_method(
74 api_name => 'open-ils.storage.fleshed.asset.copy.batch.retrieve',
75 method => 'fleshed_copy',
79 __PACKAGE__->register_method(
80 api_name => 'open-ils.storage.fleshed.asset.copy.retrieve',
81 method => 'fleshed_copy',
85 sub fleshed_copy_by_barcode {
90 my ($cp) = asset::copy->search( { barcode => $bc } );
92 return undef unless ($cp);
94 my $cp_fm = $cp->to_fieldmapper;
95 $cp_fm->circ_lib( $cp->circ_lib->to_fieldmapper );
96 $cp_fm->location( $cp->location->to_fieldmapper );
97 $cp_fm->status( $cp->status->to_fieldmapper );
101 __PACKAGE__->register_method(
102 api_name => 'open-ils.storage.fleshed.asset.copy.search.barcode',
103 method => 'fleshed_copy_by_barcode',
108 #XXX Fix stored proc calls
109 sub ranged_asset_stat_cat {
114 return undef unless ($ou);
115 my $s_table = asset::stat_cat->table;
117 my $select = <<" SQL";
120 JOIN actor.org_unit_full_path(?) p ON (p.id = s.owner)
125 $fleshed = 1 if ($self->api_name =~ /fleshed/o);
127 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
130 for my $sc ( map { asset::stat_cat->construct($_) } $sth->fetchall_hash ) {
131 my $sc_fm = $sc->to_fieldmapper;
133 [ $self->method_lookup( 'open-ils.storage.ranged.asset.stat_cat_entry.search.stat_cat' )->run($ou,$sc->id) ]
135 $client->respond( $sc_fm );
140 __PACKAGE__->register_method(
141 api_name => 'open-ils.storage.ranged.fleshed.asset.stat_cat.all',
144 method => 'ranged_asset_stat_cat',
147 __PACKAGE__->register_method(
148 api_name => 'open-ils.storage.ranged.asset.stat_cat.all',
151 method => 'ranged_asset_stat_cat',
155 #XXX Fix stored proc calls
156 sub multiranged_asset_stat_cat {
161 return undef unless (defined($ous) and @$ous);
162 my $s_table = asset::stat_cat->table;
164 my $select = <<" SQL";
167 WHERE s.owner IN ( XXX )
171 my $collector = ' INTERSECT ';
172 my $entry_method = 'open-ils.storage.multiranged.intersect.asset.stat_cat_entry.search.stat_cat';
173 if ($self->api_name =~ /union/o) {
174 $collector = ' UNION ';
175 $entry_method = 'open-ils.storage.multiranged.union.asset.stat_cat_entry.search.stat_cat';
178 my $binds = join($collector, map { 'SELECT id FROM actor.org_unit_full_path(?)' } grep {defined} @$ous);
179 $select =~ s/XXX/$binds/so;
182 $fleshed = 1 if ($self->api_name =~ /fleshed/o);
184 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
185 $sth->execute(map { "$_" } grep {defined} @$ous);
187 for my $sc ( map { asset::stat_cat->construct($_) } $sth->fetchall_hash ) {
188 my $sc_fm = $sc->to_fieldmapper;
190 [ $self->method_lookup( $entry_method )->run($ous, $sc->id) ]
192 $client->respond( $sc_fm );
197 __PACKAGE__->register_method(
198 api_name => 'open-ils.storage.multiranged.intersect.fleshed.asset.stat_cat.all',
201 method => 'multiranged_asset_stat_cat',
203 __PACKAGE__->register_method(
204 api_name => 'open-ils.storage.multiranged.union.fleshed.asset.stat_cat.all',
207 method => 'multiranged_asset_stat_cat',
210 #XXX Fix stored proc calls
211 sub ranged_asset_stat_cat_entry {
217 return undef unless ($ou);
218 my $s_table = asset::stat_cat_entry->table;
220 my $select = <<" SQL";
223 JOIN actor.org_unit_full_path(?) p ON (p.id = s.owner)
228 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
229 $sth->execute($ou,$sc);
231 for my $sce ( map { asset::stat_cat_entry->construct($_) } $sth->fetchall_hash ) {
232 $client->respond( $sce->to_fieldmapper );
237 __PACKAGE__->register_method(
238 api_name => 'open-ils.storage.ranged.asset.stat_cat_entry.search.stat_cat',
241 method => 'ranged_asset_stat_cat_entry',
244 #XXX Fix stored proc calls
245 sub multiranged_asset_stat_cat_entry {
251 return undef unless (defined($ous) and @$ous);
252 my $s_table = asset::stat_cat_entry->table;
254 my $collector = ' INTERSECT ';
255 $collector = ' UNION ' if ($self->api_name =~ /union/o);
257 my $select = <<" SQL";
260 WHERE s.owner IN ( XXX ) and s.stat_cat = ?
264 my $binds = join($collector, map { 'SELECT id FROM actor.org_unit_full_path(?)' } grep {defined} @$ous);
265 $select =~ s/XXX/$binds/so;
267 my $sth = asset::stat_cat->db_Main->prepare_cached($select);
268 $sth->execute(map {"$_"} @$ous,$sc);
270 for my $sce ( map { asset::stat_cat_entry->construct($_) } $sth->fetchall_hash ) {
271 $client->respond( $sce->to_fieldmapper );
276 __PACKAGE__->register_method(
277 api_name => 'open-ils.storage.multiranged.intersect.asset.stat_cat_entry.search.stat_cat',
280 method => 'multiranged_asset_stat_cat_entry',
282 __PACKAGE__->register_method(
283 api_name => 'open-ils.storage.multiranged.union.asset.stat_cat_entry.search.stat_cat',
286 method => 'multiranged_asset_stat_cat_entry',