WebSVN – SmartDukaan – Diff – /trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/LeadController.java

     // AI leads are auto-assigned to a random active BGC L1 (the lead desk). Previously a hardcoded
     // round-robin between Khushbu (134) and Archana (126); before that a fixed 53 / Shankar Mushran.
     // 126/134 are themselves BGC L1, so they stay in the pool - it just widens to the whole desk.
     private static final int AI_ASSIGN_FALLBACK = 134;  // Khushbu Saxena - used only if no active BGC L1 resolves
+    // Ira channels the AI side sends in AiLeadRequest.source, stored on lead.ai_channel.
+    private static final String IRA_PHONE = "IRA_PHONE";
+    private static final String IRA_WEB = "IRA_WEB";
+    // AI leads from the Ira toll-free number all go to Meenakshi Mehta, and she is left out of the
+    // random pool for every other AI lead.
+    private static final int IRA_PHONE_LEAD_ASSIGNEE = 84;
     @Value("${ai.lead.intake.token:}")
     private String aiLeadIntakeToken;
     /**
      * AI-assistant lead intake, hosted in the fofo app so it deploys via {@code fofo_deploy}. Mirrors the
         String recordingUrl = aiLeadRequest.getRecordingUrl();
         if (recordingUrl != null && !recordingUrl.trim().isEmpty()) {
             lead.setRecordingUrl(recordingUrl.trim());
+        }
+        // Ira channel: IRA_PHONE from the toll-free number, everything else (IRA_WEB, no source, or an
+        // unknown value) is a web lead. A missing source is still accepted, as before.
+        String channel = aiLeadRequest.getSource() == null ? "" : aiLeadRequest.getSource().trim().toUpperCase();
+        if (!channel.isEmpty() && !IRA_PHONE.equals(channel) && !IRA_WEB.equals(channel)) {
+            LOGGER.warn("AI lead intake: unknown source '{}' for mobile {}, treating as web", aiLeadRequest.getSource(), mobile);
+        }
+        lead.setAiChannel(IRA_PHONE.equals(channel) ? IRA_PHONE : IRA_WEB);
-        // Random active BGC L1 - only on a real create, dedup hits return before this point.
+        // Only on a real create, dedup hits return before this point.
-        int assignTo = resolveAiLeadAssignee();
+        int assignTo = resolveAiLeadAssignee(lead);
         lead.setAssignTo(assignTo);
         lead.setAuthId(lead.getAssignTo());
         lead.setCreatedTimestamp(LocalDateTime.now());
         lead.setUpdatedTimestamp(LocalDateTime.now());
         // Stamp before the insert: region, owner, stage and an SLA clock. Without it the lead is
                 ProfitMandiConstants.TICKET_CATEGORY_BGC, EscalationType.L1);
         List<AuthUser> eligible = bgcL1 == null ? Collections.<AuthUser>emptyList()
                 : bgcL1.stream()
                         .filter(x -> Boolean.TRUE.equals(x.isActive()))
+                        .filter(x -> x.getId() != IRA_PHONE_LEAD_ASSIGNEE)
                         .collect(Collectors.toList());
         if (eligible.isEmpty()) {
             LOGGER.warn("AI lead intake: no active BGC L1 in cs.position, falling back to auth id {}",
                     AI_ASSIGN_FALLBACK);
         LOGGER.info("AI lead intake: assigned to BGC L1 {} ({}) picked from {} eligible",
                 assignee.getId(), assignee.getFullName(), eligible.size());
         return assignee.getId();
+    }
+    /** IRA_PHONE / IRA_WEB for AI Assistant leads (any AI lead not from the phone line is web), else null. */
+    private String aiChannelOf(Lead lead) {
+        if (!AI_LEAD_SOURCE.equals(lead.getSource())) {
+            return null;
+        }
+        return IRA_PHONE.equals(lead.getAiChannel()) ? IRA_PHONE : IRA_WEB;
+    }
+    /** Source as the Lead Dashboard shows it: "AI Assistant (Phone)" / "AI Assistant (Web)" for AI leads. */
+    private String displaySource(Lead lead) {
+        String channel = aiChannelOf(lead);
+        String source = lead.getSource() == null ? "" : lead.getSource();
+        return IRA_PHONE.equals(channel) ? source + " (Phone)" : IRA_WEB.equals(channel) ? source + " (Web)" : source;
+    }
+    /** Keeps only AI leads from one channel (IRA_PHONE / IRA_WEB); a blank channel keeps every lead. */
+    private List<Lead> filterByAiChannel(List<Lead> leads, String aiChannel) {
+        if (aiChannel == null || aiChannel.trim().isEmpty()) {
+            return leads;
+        }
+        return leads.stream().filter(l -> aiChannel.equals(aiChannelOf(l))).collect(Collectors.toList());
+    }
+    /**
+     * Ira phone leads go to Meenakshi; every other AI lead to a random active BGC L1. If she is ever
+     * deactivated, phone leads fall back to the pool rather than stranding with an inactive owner.
+     */
+    private int resolveAiLeadAssignee(Lead lead) {
+        if (IRA_PHONE.equals(lead.getAiChannel())) {
+            AuthUser phoneOwner = authRepository.selectById(IRA_PHONE_LEAD_ASSIGNEE);
+            if (phoneOwner != null && Boolean.TRUE.equals(phoneOwner.isActive())) {
+                return IRA_PHONE_LEAD_ASSIGNEE;
+            }
+            LOGGER.warn("AI lead intake: Ira phone owner {} is inactive, using the BGC L1 pool", IRA_PHONE_LEAD_ASSIGNEE);
+        }
+        return resolveAiLeadAssignee();
+    }
     private ResponseEntity<Map<String, Object>> aiLeadResponse(HttpStatus status, String statusCode,
                                                                String statusMessage, String responseStatus, Object response) {
         Map<String, Object> body = new HashMap<>();
         body.put("statusCode", statusCode);
         body.put("statusMessage", statusMessage);
                 .anyMatch(p -> p.getEscalationType() == null
                         || !p.getEscalationType().isGreaterThanEqualTo(EscalationType.L4));
+    }
     @RequestMapping(value = "/getOpenLead", method = RequestMethod.GET)
-    public String getOpenLead(HttpServletRequest request, @RequestParam(name = "leadStatus", required = false, defaultValue = "All") List<LeadStatus> leadStatus, @RequestParam(name = "color", required = false, defaultValue = "All") List<String> color, @RequestParam(name = "startDate", required = false) LocalDate startDate, @RequestParam(name = "endDate", required = false) LocalDate endDate, Model model) throws Exception {
+    public String getOpenLead(HttpServletRequest request, @RequestParam(name = "leadStatus", required = false, defaultValue = "All") List<LeadStatus> leadStatus, @RequestParam(name = "color", required = false, defaultValue = "All") List<String> color, @RequestParam(name = "startDate", required = false) LocalDate startDate, @RequestParam(name = "endDate", required = false) LocalDate endDate, @RequestParam(name = "aiChannel", required = false, defaultValue = "") String aiChannel, Model model) throws Exception {
         LocalDateTime startDateTime = startDate != null ? startDate.atStartOfDay() : null;
         LocalDateTime endDateTime = endDate != null ? endDate.atTime(23, 59, 59) : null;
         LOGGER.info("startDateTime: " + startDateTime + ", endDateTime: " + endDateTime);
             leadCreators.add("daily-sync");
             leadCreators.addAll(csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_SALES, Arrays.asList(EscalationType.L1, EscalationType.L2)).stream().map(x -> x.getFullName()).collect(Collectors.toList()));
             leadCreators.addAll(csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_BGC, Arrays.asList(EscalationType.L1, EscalationType.L2, EscalationType.L3)).stream().map(x -> x.getFullName()).collect(Collectors.toList()));
             model.addAttribute("leadCreators", leadCreators);
+        }
+        leads = filterByAiChannel(leads, aiChannel);
+        model.addAttribute("selectedAiChannel", aiChannel);
         List<Lead> weekLast = new ArrayList<>();
         List<Lead> weekThird = new ArrayList<>();
         List<Lead> weekSecond = new ArrayList<>();
         List<Lead> weekFirst = new ArrayList<>();
         LocalDateTime curDate = LocalDate.now().atStartOfDay();
     public ResponseEntity<?> getdownloadLeadDataByDate(HttpServletRequest request,
                                                        @RequestParam(name = "leadStatus", required = false, defaultValue = "All") List<LeadStatus> leadStatus,
                                                        @RequestParam(name = "color", required = false, defaultValue = "All") List<String> color,
                                                        @RequestParam(name = "startDate", required = false) LocalDate startDate,
                                                        @RequestParam(name = "endDate", required = false) LocalDate endDate,
+                                                       @RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
-                                                       @RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm) throws Exception {
+                                                       @RequestParam(name = "aiChannel", required = false, defaultValue = "") String aiChannel) throws Exception {
         LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
         String emailId = fofoDetails.getEmailId();
         LocalDateTime startDateTime = startDate != null ? startDate.atStartOfDay() : null;
         LocalDateTime endDateTime = endDate != null ? endDate.atTime(23, 59, 59) : null;
                     leads.addAll(withinCreatedRange(leadFollowUp, startDateTime, endDateTime));
+                }
+            }
+        }
+        leads = filterByAiChannel(leads, aiChannel);
         // Build activity map and auth map (SAME AS VIEW ENDPOINT)
         // Guard both lookups on a non-empty result: an empty list would generate an invalid
         // "IN ()" and 500 (e.g. a date range with no leads), so an empty range yields an empty CSV.
         Map<Integer, AuthUser> authIdAndAuthUserMap = new HashMap<>();
         if (!leads.isEmpty()) {
         List<List<?>> rows = new ArrayList<>();
         // Mirror the on-screen table's search box: keep only leads whose exported fields contain the term,
         // so the CSV matches what the user is looking at.
         if (searchTerm != null && !searchTerm.trim().isEmpty()) {
             String term = searchTerm.trim().toLowerCase();
-            leads = leads.stream().filter(l -> Stream.of(l.getId(), l.getSource(), l.getFullName(), l.getOutLetName(),
+            leads = leads.stream().filter(l -> Stream.of(l.getId(), displaySource(l), l.getFullName(), l.getOutLetName(),
                             l.getLeadMobile(), l.getAddress(), l.getCity(), l.getState(), l.getCreatedBy(), l.getStatus(), l.getColor())
                     .anyMatch(v -> v != null && String.valueOf(v).toLowerCase().contains(term)))
                     .collect(Collectors.toList());
+        }
                 assignTo = (user.getFirstName() + " " + user.getLastName()).trim();
+            }
             rows.add(Arrays.asList(
                     lead.getId(),
-                    lead.getSource(),
+                    displaySource(lead),
                     lead.getFullName(),
                     outLetName,
                     potential,
                     lead.getLeadMobile(),
                     lead.getAddress() != null ? lead.getAddress() : "",

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/LeadController.java – Rev 37836 → 37893