Subversion Repositories SmartDukaan

import com.spice.profitmandi.service.monitors.RbmPerformanceRankingService;

import com.spice.profitmandi.service.warehouse.PoStockApprovalDigestService;

    @Autowired

    private PoStockApprovalDigestService poStockApprovalDigestService;

    @Autowired

    private RbmPerformanceRankingService rbmPerformanceRankingService;

    public void poStockApprovalDailyDigest() throws Exception{

        LOGGER.info("poStockApprovalDailyDigest startTime {}", LocalDateTime.now());

        String summary = poStockApprovalDigestService.sendStockApprovalListForDate(LocalDate.now());

        LOGGER.info("poStockApprovalDailyDigest result: {}", summary);

    }

    /** 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 = {

            "ranu.rajput@smartdukaan.com"

    };

    /**

     * Prints the composite RBM performance ranking for the given month to log

     * AND sends an HTML table by email (direct via googleMailSender — bypasses

     * mail_outbox so dev sends actually deliver). Read-only otherwise: no DB writes.

     * Used to verify the ranking calc reproduces correctly for a completed past

     * month before we wire the monthly-email cron.

     */

    public void printRbmRankingForMonth(java.time.YearMonth month) {

        LocalDate from = month.atDay(1);

        LocalDate to   = month.atEndOfMonth();

        LOGGER.info("[RBM-RANK] === Composite ranking for {} ({} → {}) ===",

                month, from, to);

        List<RbmPerformanceDashboardModel> ranked =

                rbmPerformanceRankingService.buildRanking(from, to);

        LOGGER.info("[RBM-RANK] {} RBMs ranked", ranked.size());

        String header = String.format(

                "%-4s %-25s %6s %8s %8s %10s %8s %6s %8s %8s",

                "RANK", "RBM NAME", "PART", "TALK%", "DRR%",

                "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) + "…";

            LOGGER.info("[RBM-RANK] {}", String.format(

                    "%-4d %-25s %6d %8.1f %8.1f %10.1f %8.1f %6.2f %8.1f %8.2f",

                    dm.getRank(), rbmName, dm.getPartnerCount(),

                    dm.getTalkPct(), dm.getDrrAchvPct(), 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.

        try {

            sendRbmRankingProbeEmail(month, from, to, ranked);

        } catch (Exception 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 {

        java.time.format.DateTimeFormatter fmt = java.time.format.DateTimeFormatter.ofPattern("MMMM yyyy");

        String monthLabel = month.atDay(1).format(fmt);

        String subject = "RBM Composite Ranking — " + monthLabel + " (" + ranked.size() + " RBMs)";

        StringBuilder body = new StringBuilder();

        body.append("<p>Composite RBM ranking probe for <b>").append(monthLabel)

            .append("</b> (").append(from).append(" → ").append(to).append(").</p>");

        body.append("<p style='color:#555;font-size:12px'>Score formula: Talk(10%) + DRR(55%) + Aging(2%) + &gt;1L(29%) + Rating(2%) + Rated(2%).</p>");

        body.append("<table border='1' cellpadding='6' cellspacing='0' style='border-collapse:collapse;font-size:12px'>");

        body.append("<thead><tr style='background:#343a40;color:#fff'>")

            .append("<th>Rank</th><th style='text-align:left'>RBM</th><th>Partners</th>")

            .append("<th style='background:#28a745'>Talk%<br><small>(10%)</small></th>")

            .append("<th style='background:#17a2b8'>DRR%<br><small>(55%)</small></th>")

            .append("<th style='background:#fd7e14'>Aging%<br><small>(2%)</small></th>")

            .append("<th style='background:#6f42c1'>&gt;1L%<br><small>(29%)</small></th>")

            .append("<th style='background:#ffc107;color:#000'>Rating<br><small>(2%)</small></th>")

            .append("<th style='background:#e67e22'>Rated%<br><small>(2%)</small></th>")

            .append("<th style='background:#dc3545'>Score</th>")

            .append("</tr></thead><tbody>");

        for (RbmPerformanceDashboardModel dm : ranked) {

            double ratedPct = dm.getPartnerCount() > 0

                    ? dm.getRatingPartnerCount() * 100.0 / dm.getPartnerCount() : 0;

            String rowStyle = dm.getRank() == 1 ? "background:#fff8e1" :

                              dm.getRank() == 2 ? "background:#f5f5f5" :

                              dm.getRank() == 3 ? "background:#fff3e0" : "";

            body.append("<tr style='").append(rowStyle).append("'>")

                .append("<td style='text-align:center'>").append(dm.getRank()).append("</td>")

                .append("<td>").append(escapeHtml(dm.getRbmName())).append("</td>")

                .append("<td style='text-align:center'>").append(dm.getPartnerCount()).append("</td>")

                .append("<td style='text-align:right'>").append(String.format("%.1f%%", dm.getTalkPct())).append("</td>")

                .append("<td style='text-align:right'>").append(String.format("%.1f%%", dm.getDrrAchvPct())).append("</td>")

                .append("<td style='text-align:right'>").append(String.format("%.1f%%", dm.getAgingPct())).append("</td>")

                .append("<td style='text-align:right'>").append(String.format("%.1f%%", dm.getAbove1LPct())).append("</td>")

                .append("<td style='text-align:center'>").append(String.format("%.2f", dm.getPartnerRating())).append(" ★</td>")

                .append("<td style='text-align:right'>").append(String.format("%.1f%%", ratedPct)).append("</td>")

                .append("<td style='text-align:right;font-weight:600'>").append(String.format("%.2f", dm.getCompositeScore())).append("</td>")

                .append("</tr>");

        }

        body.append("</tbody></table>");

        body.append("<p style='color:#888;font-size:11px;margin-top:20px'>Phase-1 probe — sent direct (not queued). ")

            .append("Note: for past months, DRR% denominator reads the current month's target snapshot (limitation of the live query).</p>");

        javax.mail.internet.MimeMessage message = googleMailSender.createMimeMessage();

        org.springframework.mail.javamail.MimeMessageHelper helper =

                new org.springframework.mail.javamail.MimeMessageHelper(message, false, "UTF-8");

        helper.setTo(RBM_RANK_PROBE_RECIPIENTS);

        helper.setSubject(subject);

        helper.setText(body.toString(), true);

        helper.setFrom(new javax.mail.internet.InternetAddress("sdtech@smartdukaan.com", "SmartDukaan Care"));

        googleMailSender.send(message);

        LOGGER.info("[RBM-RANK] Emailed probe to {}", String.join(", ", RBM_RANK_PROBE_RECIPIENTS));

    }

    private static String escapeHtml(String s) {

        if (s == null || s.isEmpty()) return "-";

        return s.replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;")

                .replace("\"", """).replace("'", "'");

    }