WebSVN – SmartDukaan – Diff – /trunk/profitmandi-fofo/src/main/webapp/resources/js/offer-circular-review.js

 $(function () {
     // The screen is an AJAX fragment injected into #main-content, so every handler
     // is delegated from document and state is re-initialised on each load.
     var state = { page: 1, rows: [], total: 0, pages: 1, pageSize: 50, brandsLoaded: false,
-                  decisions: [], huntTimer: null };
+                  decisions: [], huntTimer: null, documents: [], pollTimer: null };
     function ctx() {
         return (typeof context !== 'undefined' && context) ? context : (window.ocContext || '');
+    }
             state.total = payload.total || 0;
             state.pages = payload.pages || 1;
             state.page = payload.page || 1;
             state.pageSize = payload.pageSize || 50;
+            state.documents = payload.documents || state.documents || [];
             if (payload.documents) {
                 var docSel = root().find('[data-oc-doc]');
                 if (docSel.find('option').filter(function () { return this.value !== ''; }).length === 0) {
                     docSel.empty();
                     payload.documents.forEach(function (doc) {
                 select.val(current);
                 root().find('[data-oc-stat="brands"]').text(payload.brands.filter(Boolean).length);
                 state.brandsLoaded = true;
+            }
             render();
+            renderIngestState();
+            schedulePoll();
             // an empty result while circulars exist is nearly always a filter
             // mismatch, so name the months that actually hold rows
             if (state.total === 0 && payload.documents && payload.documents.length > 0) {
                 root().find('[data-oc-summary]').text(
                     'No rows matched these filters. Loaded circulars: ' +
     // sidebar entry / any trigger loads the fragment then initialises it
     function openOfferCircularReview(domId) {
         ocGet(ctx() + '/offerCircularReview', function (response) {
             $('#' + (domId || 'main-content')).html(response);
             state = { page: 1, rows: [], total: 0, pages: 1, pageSize: 50, brandsLoaded: false,
-                      decisions: [], huntTimer: null };
+                      decisions: [], huntTimer: null, documents: [], pollTimer: null };
             loadRows();
         });
+    }
     window.openOfferCircularReview = openOfferCircularReview;
             btn.prop('disabled', false).text('Re-ingest to apply');
             resolveMsg('Could not queue re-ingest: ' + failMessage(xhr));
         });
     });
+    // ------------------------------------------------------- ingest status polling
+    //
+    // Upload and parsing run in different processes: the portal stores the PDF as
+    // DRAFT, and the cron job claims and parses it on its own schedule. Without this
+    // the screen looks identical before and after a successful ingest, so a reviewer
+    // has no way to tell "not parsed yet" from "parsed and produced nothing".
+    var PENDING_STATES = { DRAFT: 'queued for parsing', PROCESSING: 'parsing now' };
+    function selectedDoc() {
+        var id = currentDocumentId();
+        if (!id) { return null; }
+        for (var i = 0; i < (state.documents || []).length; i++) {
+            if (String(state.documents[i].documentId) === String(id)) {
+                return state.documents[i];
+            }
+        }
+        return null;
+    }
+    function renderIngestState() {
+        var box = root().find('[data-oc-ingest-state]');
+        var doc = selectedDoc();
+        if (!doc) { box.empty(); return; }
+        if (PENDING_STATES[doc.status]) {
+            box.html('<span class="oc-pill oc-pill-warn">' + esc(PENDING_STATES[doc.status])
+                + '</span> <span class="oc-num">the ingest job runs every 5 minutes; '
+                + 'this refreshes itself</span>');
+        } else if (doc.status === 'FAILED') {
+            box.html('<span class="oc-pill oc-pill-danger">ingest failed</span> '
+                + '<span class="oc-num">' + esc(doc.ingestError || 'no reason recorded')
+                + '</span>');
+        } else if (doc.status === 'PUBLISHED') {
+            box.html('<span class="oc-pill oc-pill-ok">parsed</span> '
+                + '<span class="oc-num">' + esc(doc.ingestSummary || '') + '</span>');
+        } else {
+            box.html('<span class="oc-pill oc-pill-muted">' + esc(doc.status) + '</span>');
+        }
+    }
+    function schedulePoll() {
+        clearTimeout(state.pollTimer);
+        var doc = selectedDoc();
+        if (!doc || !PENDING_STATES[doc.status]) {
+            return;                      // settled - stop polling, do not spin forever
+        }
+        state.pollTimer = setTimeout(function () {
+            ocGet(ctx() + '/offerCircular/documents', function (response) {
+                var docs;
+                try { docs = typeof response === 'string' ? JSON.parse(response) : response; }
+                catch (e) { return; }
+                var was = selectedDoc();
+                state.documents = docs || [];
+                var now = selectedDoc();
+                renderIngestState();
+                // it just finished: pull in the rows the parse produced
+                if (was && now && was.status !== now.status && !PENDING_STATES[now.status]) {
+                    loadRows();
+                    return;
+                }
+                schedulePoll();
+            }, function () { schedulePoll(); });   // transient failure - keep waiting
+        }, 15000);
+    }
     // direct navigation: the fragment is already on the page
     if (root().length > 0) {
         loadRows();
+    }
 });

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/webapp/resources/js/offer-circular-review.js – Rev 37331 → 37335