LP1787636: Sort Libraries without Holdings In Holdings View
[working/Evergreen.git] / Open-ILS / web / js / ui / default / staff / cat / services / holdings.js
1 angular.module('egHoldingsMod', ['egCoreMod','egGridMod'])
2
3 .factory('holdingsSvc', 
4        ['egCore','$q',
5 function(egCore , $q) {
6
7     var service = function() {
8         this.ongoing = false;
9         this.copies = []; // record search results
10         this.index = 0; // search grid index
11         this.org = null;
12         this.rid = null;
13     };
14
15     service.prototype.flesh = {   
16         flesh : 3,
17         flesh_fields : {
18             acp : ['status','location','circ_lib','parts','age_protect','copy_alerts', 'latest_inventory'],
19             acn : ['prefix','suffix','copies','label_class','record'],
20             bre : ['simple_record'],
21             alci : ['inventory_workstation']
22         }
23     }
24
25     service.prototype.fetchAgain = function() {
26         return this.fetch({
27             rid: this.rid,
28             org: this.org,
29             copy: this.copy,
30             vol: this.vol,
31             empty: this.empty,
32             empty_org: this.empty_org
33         })
34     };
35
36     // resolved with the last received copy
37     service.prototype.fetch = function(opts) {
38         var svc = this;
39
40         if (svc.ongoing && svc.p) {
41             svc.p.cancel = true;
42             console.log('Canceling fetch for org '+ svc.org.id());
43             if (svc.p.reject) svc.p.reject();
44         }
45
46         var rid = opts.rid;
47         var empty_org = opts.empty_org;
48         var org = opts.org;
49         var copy = opts.copy;
50         var vol = opts.vol;
51         var empty = opts.empty;
52
53         if (!rid) return $q.when();
54         if (!org) return $q.when();
55
56         svc.ongoing = true;
57
58         svc.rid = rid;
59         svc.empty_org = opts.empty_org;
60         svc.org = org;
61         svc.copy = opts.copy;
62         svc.vol = opts.vol;
63         svc.empty = opts.empty;
64
65         svc.copies = [];
66         svc.index = 0;
67
68         var org_list = egCore.org.descendants(org.id(), true);
69         console.log('Holdings fetch with: rid='+rid+' org='+org_list+' copy='+copy+' vol='+vol+' empty='+empty);
70
71         svc.org_use_map = {};
72         org_list.map(function(o){svc.org_use_map[''+o]=0;})
73
74         var p = egCore.pcrud.search(
75             'acn',
76             {record : rid, owning_lib : org_list, deleted : 'f', label : {'!=' : '##URI##'}},
77             svc.flesh
78         ).then(
79             function() { // finished
80                 if (p.cancel) return;
81
82                 // create virtual field for displaying active parts
83                 angular.forEach(svc.copies, function (cp) {
84                     cp.monograph_parts = '';
85                     if (cp.parts && cp.parts.length > 0) {
86                         cp.monograph_parts = cp.parts.map(function(obj) { return obj.label; }).join(', ');
87                         cp.monograph_parts_sortkeys = cp.parts.map(function(obj) { return obj.label_sortkey; }).join();
88                     }
89                 });
90
91                 if (empty_org) {
92
93                     var empty_org_list = [];
94                     angular.forEach(svc.org_use_map,function(v,k){
95                         if (v == 0) empty_org_list.push(k);
96                     });
97
98                     angular.forEach(empty_org_list, function (oid) {
99                         var owner = egCore.org.get(oid);
100                         if (owner.ou_type().can_have_vols() != 't') return;
101
102                         var owner_list = [];
103                         while (owner.parent_ou()) { // we're going to skip the top of the tree...
104                             owner_list.unshift(owner.shortname());
105                             owner = egCore.org.get(owner.parent_ou());
106                         }
107
108                         var owner_label = owner_list.join(' ... ');
109
110                         svc.copies.push({
111                             index      : index++,
112                             id_list    : [],
113                             call_number: { label : '' },
114                             barcode    : '',
115                             owner_id   : oid,
116                             owner_list : owner_list,
117                             owner_label: owner_label,
118                             copy_count : 0,
119                             cn_count   : 0,
120                             copy_alert_count : 0
121                         });
122                     });
123                 }
124
125                 svc.ongoing = false;
126
127
128                 svc.copies = svc.copies.sort(
129                     function (a, b) {
130                         function compare_array (x, y, i) {
131                             if (x[i] && y[i]) { // both have values
132                                 if (x[i] == y[i]) { // need to look deeper
133                                     return compare_array(x, y, ++i);
134                                 }
135
136                                 if (x[i] < y[i]) { // x is first
137                                     return -1;
138                                 } else if (x[i] > y[i]) { // y is first
139                                     return 1;
140                                 }
141
142                             } else { // no orgs to compare ...
143                                 if (x[i]) return -1;
144                                 if (y[i]) return 1;
145                             }
146                             return 0;
147                         }
148
149                         var owner_order = compare_array(a.owner_list, b.owner_list, 0);
150                         if (!owner_order) {
151                             // now compare on CN label
152                             if (a.call_number.label < b.call_number.label) return -1;
153                             if (a.call_number.label > b.call_number.label) return 1;
154
155                             // also parts sortkeys combined string
156                             if (a.monograph_parts_sortkeys < b.monograph_parts_sortkeys) return -1;
157                             if (a.monograph_parts_sortkeys > b.monograph_parts_sortkeys) return 1;
158
159                             // try copy number
160                             if (a.copy_number < b.copy_number) return -1;
161                             if (a.copy_number > b.copy_number) return 1;
162
163                             // finally, barcode
164                             if (a.barcode < b.barcode) return -1;
165                             if (a.barcode > b.barcode) return 1;
166                         }
167                         return owner_order;
168                     }
169                 );
170
171                 // create virtual fields for copy alert count and most recent circ
172                 angular.forEach(svc.copies, function (cp) {
173                     if (cp.copy_alerts) {
174                         cp.copy_alert_count = cp.copy_alerts.filter(function(aca) { return aca.ack_time == null ;}).length;
175                     }
176                     else cp.copy_alert_count = 0;
177                 });
178
179                 // Grab the open circulation (i.e. checkin_time=null) for
180                 // all of the copies we're rendering so we can display
181                 // due date info.  There should only ever be one circulation
182                 // at most with checkin_time=null for any copy.
183                 var copyIds = svc.copies.map(function(cp) {return cp.id})
184                     .filter(function(id) {return Boolean(id)}); // avoid nulls
185
186                 egCore.pcrud.search('circ', 
187                     {target_copy: copyIds, checkin_time: null}
188                 ).then(
189                     null, // complete
190                     null, // error
191                     function(circ) {
192                         var cp = svc.copies.filter(function(c) { 
193                             return c.id == circ.target_copy() })[0];
194                         cp._circ = egCore.idl.toHash(circ, true);
195                         cp._circ_lib = circ.circ_lib();
196                         cp._duration = circ.duration();
197                     }
198                 );
199
200                 // create a label using just the unique part of the owner list
201                 var index = 0;
202                 var prev_owner_list;
203                 angular.forEach(svc.copies, function (cp) {
204                     if (!prev_owner_list) {
205                         cp.owner_label = cp.owner_list.join(' ... ');
206                     } else {
207                         var current_owner_list = cp.owner_list.slice();
208                         while (current_owner_list[1] && prev_owner_list[1] && current_owner_list[0] == prev_owner_list[0]) {
209                             current_owner_list.shift();
210                             prev_owner_list.shift();
211                         }
212                         cp.owner_label = current_owner_list.join(' ... ');
213                     }
214
215                     cp.index = index++;
216                     prev_owner_list = cp.owner_list.slice();
217                 });
218
219                 var new_list = svc.copies;
220                 if (!copy || !vol) { // collapse copy rows, supply a count instead
221
222                     index = 0;
223                     var cp_list = [];
224                     var prev_key;
225                     var current_blob = { copy_count : 0 };
226                     angular.forEach(new_list, function (cp) {
227                         if (!prev_key) {
228                             prev_key = cp.owner_list.join('') + cp.call_number.label;
229                             if (cp.barcode) current_blob.copy_count = 1;
230                             current_blob.index = index++;
231                             current_blob.id_list = cp.id_list;
232                             if (cp.raw) current_blob.raw = cp.raw;
233                             current_blob.call_number = cp.call_number;
234                             current_blob.owner_list = cp.owner_list;
235                             current_blob.owner_label = cp.owner_label;
236                             current_blob.owner_id = cp.owner_id;
237                         } else {
238                             var current_key = cp.owner_list.join('') + cp.call_number.label;
239                             if (prev_key == current_key) { // collapse into current_blob
240                                 current_blob.copy_count++;
241                                 current_blob.id_list = current_blob.id_list.concat(cp.id_list);
242                                 current_blob.raw = current_blob.raw.concat(cp.raw);
243                             } else {
244                                 current_blob.barcode = current_blob.copy_count;
245                                 cp_list.push(current_blob);
246                                 prev_key = current_key;
247                                 current_blob = { copy_count : 0 };
248                                 if (cp.barcode) current_blob.copy_count = 1;
249                                 current_blob.index = index++;
250                                 current_blob.id_list = cp.id_list;
251                                 if (cp.raw) current_blob.raw = cp.raw;
252                                 current_blob.owner_label = cp.owner_label;
253                                 current_blob.owner_id = cp.owner_id;
254                                 current_blob.call_number = cp.call_number;
255                                 current_blob.owner_list = cp.owner_list;
256                             }
257                         }
258                     });
259
260                     current_blob.barcode = current_blob.copy_count;
261                     cp_list.push(current_blob);
262                     new_list = cp_list;
263
264                     if (!vol) { // do the same for vol rows
265
266                         index = 0;
267                         var cn_list = [];
268                         prev_key = '';
269                         current_blob = { copy_count : 0 };
270                         angular.forEach(cp_list, function (cp) {
271                             if (!prev_key) {
272                                 prev_key = cp.owner_list.join('');
273                                 current_blob.index = index++;
274                                 current_blob.id_list = cp.id_list;
275                                 if (cp.raw) current_blob.raw = cp.raw;
276                                 current_blob.cn_count = 1;
277                                 current_blob.copy_count = cp.copy_count;
278                                 current_blob.owner_list = cp.owner_list;
279                                 current_blob.owner_label = cp.owner_label;
280                                 current_blob.owner_id = cp.owner_id;
281                             } else {
282                                 var current_key = cp.owner_list.join('');
283                                 if (prev_key == current_key) { // collapse into current_blob
284                                     current_blob.cn_count++;
285                                     current_blob.copy_count += cp.copy_count;
286                                     current_blob.id_list = current_blob.id_list.concat(cp.id_list);
287                                     if (cp.raw) {
288                                         if (current_blob.raw) current_blob.raw = current_blob.raw.concat(cp.raw);
289                                         else current_blob.raw = cp.raw;
290                                     }
291                                 } else {
292                                     current_blob.barcode = current_blob.copy_count;
293                                     current_blob.call_number = { label : current_blob.cn_count };
294                                     cn_list.push(current_blob);
295                                     prev_key = current_key;
296                                     current_blob = { copy_count : 0 };
297                                     current_blob.index = index++;
298                                     current_blob.id_list = cp.id_list;
299                                     if (cp.raw) current_blob.raw = cp.raw;
300                                     current_blob.owner_label = cp.owner_label;
301                                     current_blob.owner_id = cp.owner_id;
302                                     current_blob.cn_count = 1;
303                                     current_blob.copy_count = cp.copy_count;
304                                     current_blob.owner_list = cp.owner_list;
305                                 }
306                             }
307                         });
308     
309                         current_blob.barcode = current_blob.copy_count;
310                         current_blob.call_number = { label : current_blob.cn_count };
311                         cn_list.push(current_blob);
312                         new_list = cn_list;
313     
314                     }
315                 }
316
317                 svc.copies = new_list;
318                 svc.ongoing = false;
319             },
320
321             null, // error
322
323             // notify reads the stream of copies, one at a time.
324             function(cn) {
325                 if (p.cancel) return;
326
327                 var copies = cn.copies().filter(function(cp){ return cp.deleted() == 'f' });
328                 cn.copies([]);
329
330                 angular.forEach(copies, function (cp) {
331                     cp.call_number(cn);
332                 });
333
334                 var owner_id = cn.owning_lib();
335                 var owner = egCore.org.get(owner_id);
336                 svc.org_use_map[''+owner_id] += 1;
337
338                 var owner_name_list = [];
339                 while (owner.parent_ou()) { // we're going to skip the top of the tree...
340                     owner_name_list.unshift(owner.shortname());
341                     owner = egCore.org.get(owner.parent_ou());
342                 }
343
344                 if (copies[0]) {
345                     var flat = [];
346                     angular.forEach(copies, function (cp) {
347                         var flat_cp = egCore.idl.toHash(cp);
348                         flat_cp.owner_id = owner_id;
349                         flat_cp.owner_list = owner_name_list;
350                         flat_cp.id_list = [flat_cp.id];
351                         flat_cp.raw = [cp];
352                         flat.push(flat_cp);
353                     });
354
355                     svc.copies = svc.copies.concat(flat);
356                 } else if (empty) {
357                     svc.copies.push({
358                         id_list    : [],
359                         owner_id   : owner_id,
360                         owner_list : owner_name_list,
361                         call_number: egCore.idl.toHash(cn),
362                         raw_call_number: cn
363                     });
364                 }
365
366                 return cn;
367             }
368         );
369
370         return svc.p = p;
371     };
372
373     return service;
374 }])
375 .directive("egVolumeList", function () {
376     return {
377         restrict:   'AE',
378         scope: {
379             recordId : '=',
380             editVolumes : '@',
381             editCopies  : '@'
382         },
383         templateUrl: './cat/share/t_volume_list',
384         controller:
385                    ['$scope','holdingsSvc','egCore','egGridDataProvider','$uibModal',
386             function($scope , holdingsSvc , egCore , egGridDataProvider,  $uibModal) {
387                 var holdingsSvcInst = new holdingsSvc();
388
389                 $scope.holdingsGridControls = {};
390                 $scope.holdingsGridDataProvider = egGridDataProvider.instance({
391                     get : function(offset, count) {
392                         return this.arrayNotifier(holdingsSvcInst.copies, offset, count);
393                     }
394                 });
395
396                 function gatherHoldingsIds () {
397                     var cp_id_list = [];
398                     angular.forEach(
399                         $scope.holdingsGridControls.allItems(),
400                         function (item) { cp_id_list = cp_id_list.concat(item.id_list) }
401                     );
402                     return cp_id_list;
403                 }
404
405                 var spawn_volume_editor = function (copies_too) {
406                     egCore.net.request(
407                         'open-ils.actor',
408                         'open-ils.actor.anon_cache.set_value',
409                         null, 'edit-these-copies', {
410                             record_id: $scope.recordId,
411                             copies: gatherHoldingsIds(),
412                             hide_vols : false,
413                             hide_copies : ((copies_too) ? false : true)
414                         }
415                     ).then(function(key) {
416                         if (key) {
417                             $uibModal.open({
418                                 templateUrl: './cat/share/t_embedded_volcopy',
419                                 backdrop: 'static',
420                                 size: 'lg',
421                                 windowClass: 'eg-wide-modal',
422                                 controller:
423                                     ['$scope', '$uibModalInstance', function($scope, $uibModalInstance) {
424                                     $scope.volcopy_url = 
425                                         egCore.env.basePath + 'cat/volcopy/' + key + '/embedded';
426                                     $scope.ok = function(args) { $uibModalInstance.close(args) }
427                                     $scope.cancel = function () { $uibModalInstance.dismiss() }
428                                 }]
429                             }).result.then(function() {
430                                 load_holdings();
431                             });
432                         }
433                     });
434                 }
435                 $scope.edit_volumes = function() {
436                     spawn_volume_editor(false);
437                 }
438                 $scope.edit_copies = function() {
439                     spawn_volume_editor(true);
440                 }
441
442                 function load_holdings() {
443                     holdingsSvcInst.fetch({
444                         rid   : $scope.recordId,
445                         org   : egCore.org.root(),
446                         copy  : false,
447                         vol   : true,
448                         empty : true
449                     }).then(function() {
450                         $scope.holdingsGridDataProvider.refresh();
451                     });
452                 };
453                 $scope.$watch('recordId',
454                     function(newVal, oldVal) {
455                         if (newVal && newVal !== oldVal) {
456                             load_holdings();
457                         }
458                     }
459                 );
460                 load_holdings();
461             }]
462     }
463 })
464 .filter('string_pick', function() { return function(i){ return arguments[i] || ''; }; })
465 ;