From 212cf48a0b07843b675da8a1e623052d61921e04 Mon Sep 17 00:00:00 2001
From: Dan Wells <dbw2@calvin.edu>
Date: Thu, 25 Feb 2016 11:44:23 -0500
Subject: [PATCH] LP#1548147 Quick Export Feature for Vandelay Queues

When we import records into Vandelay, sometimes some of the records
are not what we expected, so they get rejected.  These records often
need to be loaded using a different set of options, so this link makes
it convenient to get a new file of just the rejects.

Signed-off-by: Dan Wells <dbw2@calvin.edu>
Signed-off-by: Galen Charlton <gmc@esilibrary.com>
---
 .../src/perlmods/lib/OpenILS/WWW/Exporter.pm  | 45 ++++++++++++++++++-
 Open-ILS/src/templates/vandelay/inc/queue.tt2 |  1 +
 .../web/js/ui/default/vandelay/vandelay.js    | 30 ++++++++++++-
 3 files changed, 73 insertions(+), 3 deletions(-)

diff --git a/Open-ILS/src/perlmods/lib/OpenILS/WWW/Exporter.pm b/Open-ILS/src/perlmods/lib/OpenILS/WWW/Exporter.pm
index 058f7a3649..bf2fa367ca 100644
--- a/Open-ILS/src/perlmods/lib/OpenILS/WWW/Exporter.pm
+++ b/Open-ILS/src/perlmods/lib/OpenILS/WWW/Exporter.pm
@@ -105,9 +105,50 @@ sub handler {
         @records = map { ($_->target_biblio_record_entry) } @$recs;
     }
 
+    my $type = $cgi->param('rectype') || 'biblio';
+    my $retrieve_func;
+    # STILL no records ...
+    my $queue_id = $cgi->param('queueid');
+    if ($queue_id) {
+        # check that we're logged in -- XXX necessary? conservative for now
+        my $authid = $cgi->cookie('ses') || $cgi->param('ses');
+        my $auth = verify_login($authid);
+        if (!$auth) {
+            return 403;
+        }
+
+        # validate type
+        my $queue_type;
+        if ($type eq 'biblio') {
+            $queue_type = 'bib';
+        } elsif ($type eq 'authority') {
+            $queue_type = $type;
+        } else {
+            return 400;
+        }
+
+        # does queue exist?  This check is really just for better error logging
+        my $queue = $ses->request( "open-ils.cstore.direct.vandelay.${queue_type}_queue.retrieve", $queue_id )->gather(1);
+        unless($queue) {
+            $r->log->error("No such queue $queue_id");
+            $logger->error("No such queue $queue_id");
+            return Apache2::Const::NOT_FOUND;
+        }
+
+        # fetch the records
+        my $query = {queue => $queue_id};
+        if ($cgi->param('nonimported')) {
+            $query->{import_time} = undef;
+        }
+        $retrieve_func = "vandelay.queued_${queue_type}_record";
+        my $recs = $ses->request( "open-ils.cstore.direct.${retrieve_func}.id_list.atomic", $query )->gather(1);
+        @records = @$recs;
+    } else {
+        $retrieve_func = "$type.record_entry";
+    }
+
     return show_template($r) unless (@records);
 
-    my $type = $cgi->param('rectype') || 'biblio';
     if ($type ne 'biblio' && $type ne 'authority') {
         return 400;
     }
@@ -197,7 +238,7 @@ sub handler {
             try {
                 local $SIG{ALRM} = sub { die "TIMEOUT\n" };
                 alarm(1);
-                $bib = $ses->request( "open-ils.cstore.direct.$type.record_entry.retrieve", $i, $flesh )->gather(1);
+                $bib = $ses->request( "open-ils.cstore.direct.$retrieve_func.retrieve", $i, $flesh )->gather(1);
                 alarm(0);
             } otherwise {
                 warn "\n!!!!!! Timed out trying to read record $i\n";
diff --git a/Open-ILS/src/templates/vandelay/inc/queue.tt2 b/Open-ILS/src/templates/vandelay/inc/queue.tt2
index cce9a7351b..b2c8655456 100644
--- a/Open-ILS/src/templates/vandelay/inc/queue.tt2
+++ b/Open-ILS/src/templates/vandelay/inc/queue.tt2
@@ -15,6 +15,7 @@
                                 <tr><td><a href='javascript:;' onclick='vlHandleQueueItemsAction("import")'>[% l('Import Selected Records') %]</a></td></tr>
                                 <tr><td><a href='javascript:;' onclick='vlHandleQueueItemsAction("import_all")'>[% l('Import All  Records') %]</a></td></tr>
                                 <tr><td><a href='javascript:;' onclick='vlLoadErrorUIAll();'>[% l('View Import Items') %]</a></td></tr>
+                                <tr><td><a href='javascript:;' onclick='vlExportRecordQueue({"nonimported":1})'>[% l('Export Non-Imported Records') %]</a></td></tr>
                                 <tr><td><a href='javascript:;' onclick='
                                     if(confirm("[% l('Are you sure you want to delete this queue?') %]")) {
                                         vlDeleteQueue(currentType, currentQueueId, 
diff --git a/Open-ILS/web/js/ui/default/vandelay/vandelay.js b/Open-ILS/web/js/ui/default/vandelay/vandelay.js
index 682bade3be..8e349215b1 100644
--- a/Open-ILS/web/js/ui/default/vandelay/vandelay.js
+++ b/Open-ILS/web/js/ui/default/vandelay/vandelay.js
@@ -74,6 +74,7 @@ var authAttrsFetched = false;
 var attrDefMap = {}; // maps attr def code names to attr def ids
 var currentType;
 var currentQueueId = null;
+var currentQueueName = null;
 var userCache = {};
 var currentMatchedRecords; // set of loaded matched bib records
 var currentOverlayRecordsMap; // map of import record to overlay record
@@ -561,6 +562,32 @@ function exportHandler(type, response) {
     }
 }
 
+/* export all (or just non-imported) queue records */
+function vlExportRecordQueue(opts) {
+    /* conform type to exporter */
+    var type = currentType == 'auth' ? 'auth' : 'biblio';
+    var url = '/exporter?format=xml&type='+type+'&queueid='+currentQueueId;
+    if (opts.nonimported) {
+        url += '&nonimported=1';
+    }
+
+    var req = new XMLHttpRequest();
+    req.open('GET',url,true);
+    req.send(null);
+    req.onreadystatechange = function () {
+        if (req.readyState == 4) {
+            var file_tag = opts.nonimported ? '_nonimported' : '';
+            openils.XUL.contentToFileSaveDialog(req.responseText, null, {
+                defaultString : currentQueueName + file_tag + '.xml',
+                defaultExtension : '.xml',
+                filterName : 'XML',
+                filterExtension : '*.xml',
+                filterAll : true
+            } );
+        }
+    }
+}
+
 function retrieveQueuedRecords(type, queueId, onload, doExport) {
     displayGlobalDiv('vl-generic-progress');
     queuedRecords = [];
@@ -1178,7 +1205,8 @@ var handleRetrieveRecords = function() {
     }
     vlFetchQueueSummary(currentQueueId, currentType, 
         function(summary) {
-            dojo.byId('vl-queue-summary-name').innerHTML = summary.queue.name();
+            currentQueueName = summary.queue.name();
+            dojo.byId('vl-queue-summary-name').innerHTML = currentQueueName;
             dojo.byId('vl-queue-summary-total-count').innerHTML = summary.total +'';
             dojo.byId('vl-queue-summary-import-count').innerHTML = summary.imported + '';
             dojo.byId('vl-queue-summary-import-item-count').innerHTML = summary.total_items + '';
-- 
2.43.2