Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.entity.inventory.SalesAchievements;

import com.spice.profitmandi.dao.entity.inventory.SalesTargets;

import com.spice.profitmandi.dao.repository.catalog.SalesAchievementsRepository;

import com.spice.profitmandi.dao.repository.catalog.SalesTargetsRepository;

    SalesTargetsRepository salesTargetsRepository;

    @Autowired

    SalesAchievementsRepository salesAchievementsRepository;

    @Autowired

    AuthService authService;

    @Autowired

    /**

     * Daily writer for Sales-hierarchy targets. Rolls up today's persisted

     * inventory.rbm_targets snapshots (produced by {@link #setMovementWiseRbmTargets})

     * to every active Sales person whose downline includes those RBMs, and

     * inserts one row per (sales, warehouse) into inventory.sales_targets.

     *

     * <p>Chain order matters: run this AFTER pushRbmTargets so today's RBM

     * snapshot rows exist when we roll up.

     */

    @Override

    public void setSalesTargets() {

        setSalesTargetsForDate(LocalDate.now());

    }

    @Override

    public void setSalesTargetsForDate(LocalDate date) {

        LocalDateTime dayStart = date.atStartOfDay();

        LocalDateTime dayEnd = date.plusDays(1).atStartOfDay();

        // Persisted RBM snapshots for the target date (one row per RBM × warehouse).

        List<RbmTargets> todayRbmSnapshots = rbmTargetsRepository.selectTargetsByDates(dayStart, dayEnd);

        if (todayRbmSnapshots.isEmpty()) {

            LOGGER.warn("setSalesTargetsForDate: no RBM snapshots for {}; run pushRbmTargets first", date);

            return;

        }

        // Index snapshots by (rbmAuthId, warehouseId) for O(1) roll-up.

        // rbm_auth_id → warehouseId → snapshot row.

        Map<Integer, Map<Integer, RbmTargets>> byRbmByWh = new HashMap<>();

        for (RbmTargets s : todayRbmSnapshots) {

            byRbmByWh.computeIfAbsent(s.getRbmAuthId(), k -> new HashMap<>()).put(s.getWarehouseId(), s);

        }

        Set<Integer> allSnapshotRbms = byRbmByWh.keySet();

        // Sales roles + their (categoryId, escalationType) mapping — mirrors

        // MonitorController /indent/today_po_table_fragment so both places agree.

        String[][] roles = {

                {"ASM", "4", "L1"}, {"CM", "4", "L2"}, {"DM", "4", "L3"},

                {"BM", "4", "L4"}, {"RSM", "4", "L5"}, {"NSM", "4", "L6"}

        };

        int written = 0;

        // Stamp rows within the target day so date-range queries pick them up

        // for the right day, even during backfill of a past date.

        LocalDate today = LocalDate.now();

        LocalDateTime stamp = date.equals(today) ? LocalDateTime.now() : date.atTime(java.time.LocalTime.NOON);

        for (String[] r : roles) {

            String role = r[0];

            int catId = Integer.parseInt(r[1]);

            EscalationType level = EscalationType.valueOf(r[2]);

            for (AuthUser sales : csService.getAuthUserByCategoryId(catId, level)) {

                if (!sales.isActive()) continue;

                // Downline authIds (includes self; we skip self since Sales users

                // aren't RBMs and won't appear in snapshot).

                Set<Integer> downline = new HashSet<>();

                downline.add(sales.getId());

                List<Integer> reportees = authService.getAllReportees(sales.getId());

                if (reportees != null) downline.addAll(reportees);

                downline.retainAll(allSnapshotRbms);  // keep only RBMs with today's snapshot

                if (downline.isEmpty()) continue;      // no RBMs under this Sales person today

                // Aggregate per warehouse across the downline RBMs.

                Map<Integer, float[]> perWh = new LinkedHashMap<>();  // wh → [hid, fast, run, slow, other]

                for (int rbmAuthId : downline) {

                    Map<Integer, RbmTargets> whMap = byRbmByWh.get(rbmAuthId);

                    if (whMap == null) continue;

                    for (Map.Entry<Integer, RbmTargets> e : whMap.entrySet()) {

                        RbmTargets t = e.getValue();

                        float[] acc = perWh.computeIfAbsent(e.getKey(), k -> new float[5]);

                        acc[0] += t.getHidTarget();

                        acc[1] += t.getFastMovingTarget();

                        acc[2] += t.getRunningtarget();

                        acc[3] += t.getSlowMovingtarget();

                        acc[4] += t.getOtherTarget();

                    }

                }

                for (Map.Entry<Integer, float[]> e : perWh.entrySet()) {

                    float[] acc = e.getValue();

                    SalesTargets st = new SalesTargets();

                    st.setSalesAuthId(sales.getId());

                    st.setSalesName(sales.getFullName());

                    st.setRole(role);

                    st.setWarehouseId(e.getKey());

                    st.setHidTarget(acc[0]);

                    st.setFastMovingTarget(acc[1]);

                    st.setRunningTarget(acc[2]);

                    st.setSlowMovingTarget(acc[3]);

                    st.setOtherTarget(acc[4]);

                    st.setCreateTimestamp(stamp);

                    salesTargetsRepository.persist(st);

                    written++;

                }

            }

        }

        LOGGER.info("setSalesTargetsForDate: wrote {} sales_targets rows for {}", written, date);

    }

    @Override

    public List<SalesTargets> getSalesTargetsByDates(LocalDate startDate, LocalDate endDate) {

        return salesTargetsRepository.selectTargetsByDates(startDate.atStartOfDay(), endDate.atStartOfDay());

    }

    @Override

    public void setSalesAchievements() {

        setSalesAchievementsForDate(LocalDate.now());

    }

    @Override

    public void setSalesAchievementsForDate(LocalDate date) {

        // ACH per (RBM authId × warehouse) for the target date, from the live

        // order SQL. Same source used everywhere else.

        List<TodayAchievedMovementModel> achModels =

                getMovementWiseAchievementByDate(date, date.plusDays(1));

        if (achModels.isEmpty()) {

            LOGGER.warn("setSalesAchievementsForDate: no orders on {}; nothing to snapshot", date);

            return;

        }

        // Sales roles + (categoryId, escalationType) — same mapping used elsewhere.

        String[][] roles = {

                {"ASM", "4", "L1"}, {"CM", "4", "L2"}, {"DM", "4", "L3"},

                {"BM", "4", "L4"}, {"RSM", "4", "L5"}, {"NSM", "4", "L6"}

        };

        // Stamp within the target date so date-range queries pick these rows

        // up for the correct day even during backfill.

        LocalDate today = LocalDate.now();

        LocalDateTime stamp = date.equals(today) ? LocalDateTime.now() : date.atTime(java.time.LocalTime.NOON);

        int written = 0;

        for (String[] r : roles) {

            String role = r[0];

            int catId = Integer.parseInt(r[1]);

            EscalationType level = EscalationType.valueOf(r[2]);

            for (AuthUser sales : csService.getAuthUserByCategoryId(catId, level)) {

                if (!sales.isActive()) continue;

                // Downline authIds (include self).

                Set<Integer> downline = new HashSet<>();

                downline.add(sales.getId());

                List<Integer> reportees = authService.getAllReportees(sales.getId());

                if (reportees != null) downline.addAll(reportees);

                // Aggregate ACH per warehouse across downline RBMs.

                Map<Integer, float[]> perWh = new LinkedHashMap<>();  // wh → [hid, fast, run, slow, other]

                for (TodayAchievedMovementModel a : achModels) {

                    if (!downline.contains(a.getAuthId())) continue;

                    float[] acc = perWh.computeIfAbsent(a.getWarehouseId(), k -> new float[5]);

                    acc[0] += a.getHidBilled();

                    acc[1] += a.getFastMovingBilled();

                    acc[2] += a.getRunningBilled() != null ? a.getRunningBilled() : 0f;

                    acc[3] += a.getSlowMovinBilled() != null ? a.getSlowMovinBilled() : 0f;

                    acc[4] += a.getOtherBilled() != null ? a.getOtherBilled() : 0f;

                }

                if (perWh.isEmpty()) continue;

                for (Map.Entry<Integer, float[]> e : perWh.entrySet()) {

                    float[] acc = e.getValue();

                    SalesAchievements sa = new SalesAchievements();

                    sa.setSalesAuthId(sales.getId());

                    sa.setSalesName(sales.getFullName());

                    sa.setRole(role);

                    sa.setWarehouseId(e.getKey());

                    sa.setAchievedHidTarget(acc[0]);

                    sa.setAchievedFastMovingTarget(acc[1]);

                    sa.setAchievedRunningTarget(acc[2]);

                    sa.setAchievedSlowMovingTarget(acc[3]);

                    sa.setAchievedOtherTarget(acc[4]);

                    sa.setCreateTimestamp(stamp);

                    salesAchievementsRepository.persist(sa);

                    written++;

                }

            }

        }

        LOGGER.info("setSalesAchievementsForDate: wrote {} sales_achievements rows for {}", written, date);

    }