WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/LmsDashboardService.java

 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadStage;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.cs.RegionRepository;
+import com.spice.profitmandi.dao.entity.user.LeadDnd;
+import com.spice.profitmandi.dao.entity.user.LeadLiveLocation;
 import com.spice.profitmandi.dao.repository.dtr.LeadActivityRepository;
+import com.spice.profitmandi.dao.entity.user.LeadCall;
+import com.spice.profitmandi.dao.repository.dtr.LeadCallRepository;
+import com.spice.profitmandi.dao.repository.dtr.LeadDndRepository;
+import com.spice.profitmandi.dao.repository.dtr.LeadLiveLocationRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
     private static final Logger LOGGER = LogManager.getLogger(LmsDashboardService.class);
     /** Ordered happy-path for cumulative "reached" funnel math. */
     private static final LeadStage[] FUNNEL = LeadStage.HAPPY_PATH;
+    /** Hard ceiling on one page of the pipeline table — a caller asking for 10,000 rows gets 500. */
+    private static final int MAX_PAGE_SIZE = 500;
     /** Leads not touched for this many days count as "ageing" (SOP §18.2). */
     private static final int AGEING_DAYS = 7;
     /** Most-recent weeks shown in the SLA owner heat-map. */
     private static final int HEATMAP_WEEKS = 6;
     private LmsAssignmentService lmsAssignmentService;
     @Autowired
     private LeadActivityRepository leadActivityRepository;
+    @Autowired
+    private LeadCallRepository leadCallRepository;
+    @Autowired
+    private LeadDndRepository leadDndRepository;
+    @Autowired
+    private LeadLiveLocationRepository leadLiveLocationRepository;
     // ---- Command Center + shared summary ----------------------------------------------------
     /** KPIs + lifecycle funnel + attention queue for the given region / created-date window. */
     public Map<String, Object> summary(Integer regionId, LocalDateTime from, LocalDateTime to) {
         Map<String, Long> stage = toCountMap(leadRepository.countByDerivedStage(regionId, from, to));
+        }
         return toRows(ordered);
+    }
     /**
+     * The Lead-pipeline table: every matching lead, not a client-side slice of the first page.
+     *
+     * <p>Returns the page plus the true total, so the table can report "50 of 229" rather than
+     * implying the twelve rows it drew are all there are. A non-empty {@code q} searches across all
+     * leads and ignores the date window — see {@code LeadRepository.selectPipeline}.
+     */
+    public Map<String, Object> pipeline(String q, Integer regionId, LocalDateTime from, LocalDateTime to,
+                                        String sort, String dir, int page, int pageSize) {
+        int size = Math.min(Math.max(pageSize, 1), MAX_PAGE_SIZE);
+        int p = Math.max(page, 1);
+        boolean searching = q != null && !q.trim().isEmpty();
+        long total = leadRepository.countPipeline(q, regionId, from, to);
+        List<Lead> leads = leadRepository.selectPipeline(q, regionId, from, to, sort, dir, (p - 1) * size, size);
+        Map<String, Object> out = new LinkedHashMap<>();
+        out.put("rows", toRows(leads));
+        out.put("total", total);
+        out.put("page", p);
+        out.put("pageSize", size);
+        out.put("pages", (int) Math.ceil(total / (double) size));
+        out.put("sort", sort);
+        out.put("dir", dir);
+        // The caller renders a different caption when the date filter is not in play, so it has to
+        // be told which mode the server actually used rather than inferring it.
+        out.put("searching", searching);
+        return out;
+    }
+    /**
      * Free-text lookup for the dashboard search box: LMS id / retailer / business / mobile / city.
      * Same row shape as {@link #drill}, so results render in the same drawer table.
      */
     public List<Map<String, Object>> search(String term) {
         if (term == null || term.trim().isEmpty()) {
             r.put("stage", eff != null ? eff.name() : null);
             r.put("stageLabel", pretty(eff));
             r.put("owner", owner != null ? owner.getFullName() : (l.getAssignTo() > 0 ? "#" + l.getAssignTo() : "—"));
             r.put("slaState", lmsAssignmentService.slaState(l));
             r.put("value", l.getPotential());
+            // Both are sortable columns on the pipeline table, so the row has to carry them.
+            r.put("city", l.getCity());
+            r.put("createdBy", l.getCreatedBy());
             out.add(r);
+        }
         return out;
+    }
         if (!ids.isEmpty()) {
             for (AuthUser u : authRepository.selectByIds(new ArrayList<>(ids))) {
                 actors.put(u.getId(), u);
+            }
+        }
+        // Calls keyed by id, so a disposition in the trail can carry the recording of the call it came
+        // from. A disposition is the agent's account of the conversation; having to hunt for the audio
+        // in a separate list to check it against the recording is the friction worth removing.
+        Map<Integer, LeadCall> callById = new HashMap<>();
+        List<LeadCall> calls = leadCallRepository.selectByLeadId(leadId);
+        if (calls != null) {
+            for (LeadCall c : calls) {
+                callById.put(c.getId(), c);
+            }
+        }
         List<Map<String, Object>> trail = new ArrayList<>();
         for (LeadActivity a : acts) {
             AuthUser act = actors.get(a.getAuthId());
             Map<String, Object> t = new LinkedHashMap<>();
             t.put("when", a.getCreatedTimestamp() == null ? null : a.getCreatedTimestamp().toString());
             t.put("actor", act != null ? act.getFullName() : (a.getAuthId() > 0 ? "#" + a.getAuthId() : "System"));
             t.put("type", a.getCommunicationType() == null ? null : a.getCommunicationType().name());
             t.put("body", a.getRemark());
             t.put("scheduled", a.getSchelduleTimestamp() == null ? null : a.getSchelduleTimestamp().toString());
+            // Either handle is enough to play: the gated endpoint serves our archived copy when there
+            // is one and proxies the vendor's otherwise, so an agent is not made to wait on the
+            // archival sweep to hear a call. The URL is never the raw vendor one — playback goes
+            // through /lms/recording/{id}, which enforces the §15 matrix and logs the open.
+            LeadCall call = a.getLeadCallId() == null ? null : callById.get(a.getLeadCallId());
+            if (call != null && (call.getRecordingObjectKey() != null || call.getRecordingUuid() != null)) {
+                t.put("callId", call.getId());
+                t.put("durationSeconds", call.getDurationSeconds());
+                t.put("archived", call.getRecordingObjectKey() != null);
+            }
             trail.add(t);
+        }
         Map<String, Object> m = new LinkedHashMap<>();
         m.put("id", l.getId());
         m.put("assignmentStatus", l.getAssignmentStatus());
         m.put("slaState", lmsAssignmentService.slaState(l));
         m.put("firstContactDue", l.getFirstContactDue() == null ? null : l.getFirstContactDue().toString());
         m.put("firstContactedAt", l.getFirstContactedAt() == null ? null : l.getFirstContactedAt().toString());
         m.put("unreachableCount", l.getUnreachableCount());
+        // The dashboard's record tab acts on the lead rather than only displaying it, so it needs
+        // the same three things the in-app screen reads before it offers a control:
+        //   - the parts of the address, not just the joined string, or an edit would have to
+        //     re-split "addr, city, state" and would corrupt any value containing a comma;
+        //   - the region id, so the edit form can preselect it (regionCode alone cannot);
+        //   - whether the number is blocked and whether the geo-pin is approved, so the call and
+        //     beat controls can say why they are unavailable instead of failing on submit.
+        m.put("regionId", l.getRegionId());
+        m.put("address", l.getAddress());
+        m.put("city", l.getCity());
+        m.put("state", l.getState());
+        LeadDnd dnd = leadDndRepository.selectByMobile(l.getLeadMobile());
+        m.put("dnd", dnd != null);
+        m.put("dndReason", dnd == null ? null : dnd.getReason());
+        // The pin itself, not just a yes/no: the record card offers a map link when it is approved
+        // and pre-fills the manual-verify form with the existing coords when it is not, so nudging
+        // a slightly-off pin does not mean typing it from scratch.
+        LeadLiveLocation geo = leadLiveLocationRepository.selectByLeadId(leadId);
+        m.put("geoApproved", geo != null && geo.getStatus() != null
+                && "APPROVED".equalsIgnoreCase(geo.getStatus().toString()));
+        m.put("geoStatus", geo == null || geo.getStatus() == null ? null : geo.getStatus().toString());
+        if (geo != null && (geo.getLatitude() != 0 || geo.getLongitude() != 0)) {
+            m.put("geoLat", geo.getLatitude());
+            m.put("geoLng", geo.getLongitude());
+        }
+        m.put("geoPhotoId", geo == null ? 0 : geo.getImageDocumentId());
         m.put("trail", trail);
         return m;
+    }
     private String joinLoc(String a, String c, String s) {

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/LmsDashboardService.java – Rev 37651 → 37692