WebSVN – SmartDukaan – Diff – //trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java

+    }
     /** Test recipient(s) for the RBM ranking probe email. Kept here (not in a config)
      *  because this whole flow is a Phase-1 probe — Phase 2 will move recipients into
      *  the shipped monthly-email cron. */
     private static final String[] RBM_RANK_PROBE_RECIPIENTS = {
-            "gaurav.mathur@smartdukaan.com",
+//            "gaurav.mathur@smartdukaan.com",
-            "kangan.monga@smartdukaan.com",
+//            "kangan.monga@smartdukaan.com",
-            "siddharth.chaturvedi@smartdukaan.com",
+//            "siddharth.chaturvedi@smartdukaan.com",
 //            "aquil.ahmad@smartdukaan.com",
-            "charu.sharma@smartdukaan.com",
+//            "charu.sharma@smartdukaan.com",
             "ranu.rajput@smartdukaan.com"
     };
     /**
      * Prints the composite RBM performance ranking for the given month to log
         LocalDate to   = month.atEndOfMonth();
         LOGGER.info("[RBM-RANK] === Composite ranking for {} ({} → {}) ===",
                 month, from, to);
         List<RbmPerformanceDashboardModel> ranked =
                 rbmPerformanceRankingService.buildRanking(from, to);
+        // Sep 2026: computed Aging% has a gap (warehouse close/reopen + stock
+        // transfers skew the live snapshot). Inject the 15-day aging values
+        // reported for 30-Sep for these RBMs, then re-score + re-rank with the
+        // same weights the service uses. Other metrics stay query-driven.
+        if (month.equals(java.time.YearMonth.of(2026, 9))) {
+            Map<String, Double> agingOverrideSep26 = new LinkedHashMap<>();
+            agingOverrideSep26.put("Akash",         146.7);
+            agingOverrideSep26.put("Vinay",         284.1);
+            agingOverrideSep26.put("Gurmeet",       242.0);
+            agingOverrideSep26.put("Shikha",        121.7);
+            agingOverrideSep26.put("Neha Dubey",     49.7);
+            agingOverrideSep26.put("Hariom Sharma", 129.3);
+            agingOverrideSep26.put("Sneha",         102.4);
+            agingOverrideSep26.put("Nikita",        146.8);
+            for (RbmPerformanceDashboardModel dm : ranked) {
+                String name = dm.getRbmName() == null ? "" : dm.getRbmName().toLowerCase();
+                for (Map.Entry<String, Double> e : agingOverrideSep26.entrySet()) {
+                    if (name.contains(e.getKey().toLowerCase())) {
+                        LOGGER.info("[RBM-RANK] Aging override for {}: {} -> {}",
+                                dm.getRbmName(),
+                                String.format("%.1f", dm.getAgingPct()), e.getValue());
+                        dm.setAgingPct(e.getValue());
+                        break;
+                    }
+                }
+            }
+            for (RbmPerformanceDashboardModel dm : ranked) {
+                double avgRatingScore = (dm.getPartnerRating() / 5.0) * 100;
+                double partnersRatedScore = dm.getPartnerCount() > 0
+                        ? (dm.getRatingPartnerCount() * 100.0 / dm.getPartnerCount()) : 0;
+                double composite = (dm.getTalkPct()    * 0.10)
+                                 + (dm.getDrrAchvPct() * 0.55)
+                                 + (dm.getAgingPct()   * 0.02)
+                                 + (dm.getAbove1LPct() * 0.29)
+                                 + (avgRatingScore     * 0.02)
+                                 + (partnersRatedScore * 0.02);
+                dm.setCompositeScore(composite);
+            }
+            ranked.sort((a, b) -> Double.compare(b.getCompositeScore(), a.getCompositeScore()));
+            int currentRank = 1;
+            for (int i = 0; i < ranked.size(); i++) {
+                if (i > 0 && ranked.get(i).getCompositeScore()
+                              < ranked.get(i - 1).getCompositeScore()) {
+                    currentRank = i + 1;
+                }
+                ranked.get(i).setRank(currentRank);
+            }
+        }
         LOGGER.info("[RBM-RANK] {} RBMs ranked", ranked.size());
         String header = String.format(
-                "%-4s %-25s %6s %8s %8s %10s %8s %6s %8s %8s",
+                "%-4s %-25s %6s %8s %28s %10s %8s %6s %8s %8s",
-                "RANK", "RBM NAME", "PART", "TALK%", "DRR%",
+                "RANK", "RBM NAME", "PART", "TALK%", "DRR%(SEC/TGT)",
                 "AGING%", ">1L%", "RATE", "RATED%", "SCORE");
         LOGGER.info("[RBM-RANK] {}", header);
         for (RbmPerformanceDashboardModel dm : ranked) {
             double ratedPct = dm.getPartnerCount() > 0
                     ? dm.getRatingPartnerCount() * 100.0 / dm.getPartnerCount() : 0;
             String rbmName = dm.getRbmName() == null ? "-" : dm.getRbmName();
             if (rbmName.length() > 25) rbmName = rbmName.substring(0, 24) + "…";
+            String drrCell = String.format("%.1f(%.1fL/%.1fL)",
+                    dm.getDrrAchvPct(),
+                    dm.getMtdAchieved() / 100000.0,
+                    dm.getMonthlyTarget() / 100000.0);
             LOGGER.info("[RBM-RANK] {}", String.format(
-                    "%-4d %-25s %6d %8.1f %8.1f %10.1f %8.1f %6.2f %8.1f %8.2f",
+                    "%-4d %-25s %6d %8.1f %28s %10.1f %8.1f %6.2f %8.1f %8.2f",
                     dm.getRank(), rbmName, dm.getPartnerCount(),
-                    dm.getTalkPct(), dm.getDrrAchvPct(), dm.getAgingPct(),
+                    dm.getTalkPct(), drrCell, dm.getAgingPct(),
                     dm.getAbove1LPct(), dm.getPartnerRating(), ratedPct,
                     dm.getCompositeScore()));
+        }
         LOGGER.info("[RBM-RANK] === End ranking for {} ===", month);
-        // Email the same table so the user can eyeball without tailing logs.
+        // Email disabled while verifying data gaps — check logs only.
-        try {
+        // try {
-            sendRbmRankingProbeEmail(month, from, to, ranked);
+        //     sendRbmRankingProbeEmail(month, from, to, ranked);
-        } catch (Exception e) {
+        // } catch (Exception e) {
-            LOGGER.error("[RBM-RANK] Email send FAILED (log-only fallback in place): {}", e.getMessage(), e);
+        //     LOGGER.error("[RBM-RANK] Email send FAILED (log-only fallback in place): {}", e.getMessage(), e);
-        }
+        // }
+    }
     /** Direct HTML send via googleMailSender — bypasses mail_outbox so dev delivers. */
     private void sendRbmRankingProbeEmail(java.time.YearMonth month, LocalDate from, LocalDate to,
                                           List<RbmPerformanceDashboardModel> ranked) throws Exception {

Subversion Repositories SmartDukaan

(root)//trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java – Rev 37862 → 37892