Subversion Repositories SmartDukaan

import com.spice.profitmandi.common.enumuration.ActivationType;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;

import com.spice.profitmandi.dao.entity.auth.RbmCallSequenceLog;

import com.spice.profitmandi.dao.entity.cs.Position;

import com.spice.profitmandi.dao.entity.cs.Ticket;

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;

import com.spice.profitmandi.dao.repository.auth.RbmCallSequenceLogRepository;

import com.spice.profitmandi.dao.repository.cs.CsService;

import com.spice.profitmandi.dao.repository.cs.PositionRepository;

import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;

import com.spice.profitmandi.dao.repository.transaction.LoanRepository;

import com.spice.profitmandi.service.user.RetailerService;

import java.time.format.DateTimeFormatter;

    @Autowired

    RetailerService retailerService;

    @Autowired

    PositionRepository positionRepository;

    @Autowired

    CsService csService;

    @Autowired

    FofoStoreRepository fofoStoreRepository;

    @Autowired

    AuthRepository authRepository;

    @Autowired

    LoanRepository loanRepository;

    @Autowired

    PartnerCollectionService partnerCollectionService;

    @Autowired

    PartnerCollectionRemarkRepository partnerCollectionRemarkRepository;

    @Autowired

    RbmCallSequenceLogRepository rbmCallSequenceLogRepository;

    @Autowired

    com.spice.profitmandi.dao.repository.cs.TicketRepository ticketRepository;

    @Override

    public List<RbmCallTargetModel> getRbmCallTargetModels() throws Exception {

        long methodStart = System.currentTimeMillis();

        List<RbmCallTargetModel> rbmCallTargetModels = new ArrayList<>();

        // Get all RBM positions (L1 and L2)

        long start = System.currentTimeMillis();

        List<Position> allRbmPositions = positionRepository

                .selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()

                .filter(x -> Arrays.asList(EscalationType.L1, EscalationType.L2).contains(x.getEscalationType()))

                .collect(Collectors.toList());

        // Separate L1 and L2 auth IDs

        List<Integer> l1AuthIds = allRbmPositions.stream()

                .filter(p -> EscalationType.L1.equals(p.getEscalationType()))

                .map(Position::getAuthUserId).distinct().collect(Collectors.toList());

        List<Integer> l2AuthIds = allRbmPositions.stream()

                .filter(p -> EscalationType.L2.equals(p.getEscalationType()))

                .map(Position::getAuthUserId).distinct().collect(Collectors.toList());

        // Union of all auth IDs for batch fetching

        List<Integer> rbmPositionsAuthIds = allRbmPositions.stream()

                .map(Position::getAuthUserId).distinct().collect(Collectors.toList());

        LOGGER.info("RBM Call Target - RBM positions fetch: {}ms, L1: {}, L2: {}", System.currentTimeMillis() - start, l1AuthIds.size(), l2AuthIds.size());

        start = System.currentTimeMillis();

        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();

        LOGGER.info("RBM Call Target - StoreGuyMap fetch: {}ms", System.currentTimeMillis() - start);

        LocalDateTime startDate = LocalDate.now().atStartOfDay();

        LocalDate firstOfMonth = LocalDate.now().withDayOfMonth(1);

        LocalDate endOfMonth = LocalDate.now().withDayOfMonth(LocalDate.now().lengthOfMonth()).plusDays(1);

        // Get auth user map

        start = System.currentTimeMillis();

        Map<Integer, AuthUser> authUserMap = authRepository.selectByIds(rbmPositionsAuthIds).stream()

                .collect(Collectors.toMap(AuthUser::getId, au -> au));

        LOGGER.info("RBM Call Target - AuthUser fetch: {}ms", System.currentTimeMillis() - start);

        // Batch fetch positions by auth IDs (to check if RBM is L1)

        start = System.currentTimeMillis();

        Map<Integer, List<Position>> positionsByAuthId = positionRepository.selectPositionByAuthIds(rbmPositionsAuthIds).stream()

                .collect(Collectors.groupingBy(Position::getAuthUserId));

        LOGGER.info("RBM Call Target - Positions by AuthId fetch: {}ms", System.currentTimeMillis() - start);

        // Get all fofo IDs for all RBMs

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

        Map<Integer, List<Integer>> rbmToFofoIdsMap = new HashMap<>();

        for (int rbmAuthId : rbmPositionsAuthIds) {

            AuthUser au = authUserMap.get(rbmAuthId);

            if (au != null && storeGuyMap.containsKey(au.getEmailId())) {

                List<Integer> fofoIds = new ArrayList<>(storeGuyMap.get(au.getEmailId()));

                allFofoIds.addAll(fofoIds);

                rbmToFofoIdsMap.put(rbmAuthId, fofoIds);

            }

        }

        // Fetch escalated tickets for L2 early so their fofoIds are included in batch fetches

        List<Ticket> escalatedTickets = Collections.emptyList();

        Map<Integer, List<Integer>> l2AuthIdToFofoIds = new HashMap<>();

        if (!l2AuthIds.isEmpty()) {

            start = System.currentTimeMillis();

            escalatedTickets = ticketRepository.selectOpenEscalatedTicketsByAuthIds(l2AuthIds);

            LOGGER.info("RBM Call Target - Escalated tickets fetch: {}ms, count: {}", System.currentTimeMillis() - start, escalatedTickets.size());

            for (int l2AuthId : l2AuthIds) {

                List<Integer> l2FofoIds = escalatedTickets.stream()

                        .filter(t -> t.getL2AuthUser() == l2AuthId

                                || t.getL3AuthUser() == l2AuthId

                                || t.getL4AuthUser() == l2AuthId

                                || t.getL5AuthUser() == l2AuthId)

                        .map(Ticket::getFofoId)

                        .distinct()

                        .collect(Collectors.toList());

                l2AuthIdToFofoIds.put(l2AuthId, l2FofoIds);

                allFofoIds.addAll(l2FofoIds);

            }

        }

        LOGGER.info("RBM Call Target - Total fofo IDs to process: {}", allFofoIds.size());

        // Get only needed fofo stores (OPTIMIZED - was fetching ALL stores before)

        start = System.currentTimeMillis();

        Map<Integer, FofoStore> fofoStoresMap = new HashMap<>();

        if (!allFofoIds.isEmpty()) {

            try {

                fofoStoresMap = fofoStoreRepository.selectByRetailerIds(new ArrayList<>(allFofoIds)).stream()

                        .collect(Collectors.toMap(FofoStore::getId, x -> x, (a, b) -> a));

            } catch (ProfitMandiBusinessException e) {

                LOGGER.error("Error fetching fofo stores", e);

            }

        }

        LOGGER.info("RBM Call Target - FofoStores fetch (only needed): {}ms, count: {}", System.currentTimeMillis() - start, fofoStoresMap.size());

        // Batch fetch max remark ids for all fofoIds (for escalation filtering)

        start = System.currentTimeMillis();

        Map<Integer, PartnerCollectionRemark> allPartnerCollectionRemarks = new HashMap<>();

        if (!allFofoIds.isEmpty()) {

            List<Integer> allRemarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(new ArrayList<>(allFofoIds));

            if (!allRemarkIds.isEmpty()) {

                allPartnerCollectionRemarks = partnerCollectionRemarkRepository.selectByIds(allRemarkIds).stream()

                        .collect(Collectors.toMap(PartnerCollectionRemark::getFofoId, x -> x, (a, b) -> a));

            }

        }

        LOGGER.info("RBM Call Target - PartnerCollectionRemarks fetch: {}ms", System.currentTimeMillis() - start);

        // Batch fetch collection RANK map for all fofoIds (OPTIMIZED - only fetches rank, not full model)

        start = System.currentTimeMillis();

        Map<Integer, Integer> allCollectionRankMap = new HashMap<>();

        if (!allFofoIds.isEmpty()) {

            try {

                allCollectionRankMap = partnerCollectionService.getCollectionRankMap(new ArrayList<>(allFofoIds), startDate);

            } catch (ProfitMandiBusinessException e) {

                LOGGER.error("Error fetching collection rank map for all fofoIds", e);

            }

        }

        LOGGER.info("RBM Call Target - CollectionRankMap fetch (OPTIMIZED): {}ms", System.currentTimeMillis() - start);

        // Get MTD billing data for zero billing calculation

        start = System.currentTimeMillis();

        List<RbmWeeklyBillingModel> mtdBillingData = getWeeklyBillingDataForMonth(firstOfMonth, endOfMonth);

        Set<Integer> allMtdBilledFofoIds = mtdBillingData.stream()

                .filter(RbmWeeklyBillingModel::isMtdBilled)

                .map(RbmWeeklyBillingModel::getFofoId)

                .collect(Collectors.toSet());

        LOGGER.info("RBM Call Target - MTD Billing fetch: {}ms", System.currentTimeMillis() - start);

        // Batch fetch today's remarks for all auth IDs (to calculate Value Achieved)

        start = System.currentTimeMillis();

        Map<Integer, List<PartnerCollectionRemark>> remarksByAuthId = partnerCollectionRemarkRepository

                .selectAllByAuthIdsOnDate(rbmPositionsAuthIds, LocalDate.now()).stream()

                .collect(Collectors.groupingBy(PartnerCollectionRemark::getAuthId));

        LOGGER.info("RBM Call Target - Today Remarks fetch: {}ms", System.currentTimeMillis() - start);

        // Batch fetch today's out-of-sequence logs for all RBMs

        start = System.currentTimeMillis();

        LocalDateTime todayStart = LocalDate.now().atStartOfDay();

        LocalDateTime todayEnd = LocalDate.now().plusDays(1).atStartOfDay();

        List<RbmCallSequenceLog> outOfSequenceLogs = rbmCallSequenceLogRepository.selectOutOfSequenceByDateRange(todayStart, todayEnd);

        Map<Integer, Long> outOfSequenceCountByAuthId = outOfSequenceLogs.stream()

                .collect(Collectors.groupingBy(RbmCallSequenceLog::getAuthId, Collectors.counting()));

        LOGGER.info("RBM Call Target - Out of Sequence fetch: {}ms", System.currentTimeMillis() - start);

        // Process L1 RBMs (existing logic)

        for (int rbmAuthId : l1AuthIds) {

            AuthUser authUser = authUserMap.get(rbmAuthId);

            if (authUser == null || !storeGuyMap.containsKey(authUser.getEmailId())) {

                continue;

            }

            List<Integer> fofoIdList = rbmToFofoIdsMap.getOrDefault(rbmAuthId, Collections.emptyList());

            // Check if RBM is L1 (same logic as getSummaryModel)

            List<Position> positions = positionsByAuthId.getOrDefault(authUser.getId(), Collections.emptyList());

            boolean isRBMAndL1 = positions.stream()

                    .anyMatch(position ->

                            ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId()

                                    && EscalationType.L1.equals(position.getEscalationType()));

            // Filter escalated partners for L1 RBMs (same logic as getSummaryModel)

            List<Integer> fofoIds = fofoIdList;

            if (isRBMAndL1) {

                Map<Integer, PartnerCollectionRemark> partnerCollectionRemarks = new HashMap<>();

                for (Integer fofoId : fofoIdList) {

                    if (allPartnerCollectionRemarks.containsKey(fofoId)) {

                        partnerCollectionRemarks.put(fofoId, allPartnerCollectionRemarks.get(fofoId));

                    }

                }

                fofoIds = partnerCollectionRemarks.entrySet().stream()

                        .filter(entry -> {

                            PartnerCollectionRemark pcrMap = entry.getValue();

                            return !(CollectionRemark.RBM_L2_ESCALATION.equals(pcrMap.getRemark())

                                    || CollectionRemark.SALES_ESCALATION.equals(pcrMap.getRemark()));

                        })

                        .map(Map.Entry::getKey)

                        .collect(Collectors.toList());

            }

            // Filter to only external, ACTIVE stores with collection plan (like today_target Active section)

            Map<Integer, Integer> finalAllCollectionRankMap = allCollectionRankMap;

            Map<Integer, FofoStore> finalFofoStoresMap = fofoStoresMap;

            List<Integer> validFofoIds = fofoIds.stream()

                    .filter(fofoId -> {

                        FofoStore store = finalFofoStoresMap.get(fofoId);

                        if (store == null || store.isInternal()) {

                            return false;

                        }

                        // Only include ACTIVE partners (not Low Sale, not Disputed, not Billing Pending)

                        if (!ActivationType.ACTIVE.equals(store.getActivationType())) {

                            return false;

                        }

                        // Only include partners who have a collection plan (to match today_target Active section)

                        return finalAllCollectionRankMap.containsKey(fofoId);

                    })

                    .collect(Collectors.toList());

            if (validFofoIds.isEmpty()) {

                continue;

            }

            RbmCallTargetModel targetModel = new RbmCallTargetModel();

            targetModel.setAuthId(rbmAuthId);

            targetModel.setRbmName(authUser.getFullName());

            targetModel.setPartnerCount(validFofoIds.size());

            // Categorize each partner - each partner belongs to ONE category only

            // Priority: PlanToday > CarryForward > Untouched > ZeroBilling > FuturePlan > Normal

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

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

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

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

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

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

            for (Integer fofoId : validFofoIds) {

                // Get collection plan rank (from optimized rank map)

                int rank = allCollectionRankMap.getOrDefault(fofoId, 5); // default to Normal if no plan

                // Check if partner has zero billing in MTD

                boolean hasZeroBilling = !allMtdBilledFofoIds.contains(fofoId);

                // Assign to category based on priority

                if (rank == 1) {

                    planTodayPartners.add(fofoId);

                } else if (rank == 2) {

                    carryForwardPartners.add(fofoId);

                } else if (rank == 3) {

                    untouchedPartners.add(fofoId);

                } else if (hasZeroBilling) {

                    zeroBillingPartners.add(fofoId);

                } else if (rank == 4) {

                    futurePlanPartners.add(fofoId);

                } else {

                    normalPartners.add(fofoId);

                }

            }

            // Set counts

            targetModel.setCreditCollection(0); // Credit collection is handled in separate list

            targetModel.setPlanToday(planTodayPartners.size());

            targetModel.setCarryForward(carryForwardPartners.size());

            targetModel.setUntouched(untouchedPartners.size());

            targetModel.setZeroBilling(zeroBillingPartners.size());

            targetModel.setFuturePlan(futurePlanPartners.size());

            targetModel.setNormal(normalPartners.size());

            // Today Target = PlanToday + CarryForward + ZeroBilling + Untouched

            // These are mutually exclusive now, so we can sum them

            long todayTarget = planTodayPartners.size() +

                    carryForwardPartners.size() + zeroBillingPartners.size() + untouchedPartners.size();

            targetModel.setTodayTargetOfCall(todayTarget);

            // Create set of partners in Today Target categories

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

            todayTargetPartners.addAll(planTodayPartners);

            todayTargetPartners.addAll(carryForwardPartners);

            todayTargetPartners.addAll(zeroBillingPartners);

            todayTargetPartners.addAll(untouchedPartners);

            // Value Achieved = Partners from Today Target that have been contacted today (have remark today)

            List<PartnerCollectionRemark> todayRemarks = remarksByAuthId.getOrDefault(rbmAuthId, Collections.emptyList());

            long valueAchieved = todayRemarks.stream()

                    .map(PartnerCollectionRemark::getFofoId)

                    .filter(todayTargetPartners::contains)

                    .distinct()

                    .count();

            targetModel.setValueTargetAchieved(valueAchieved);

            // Moved to Future = Partners in Future Plan category who have a remark today

            // These are partners who were contacted today but moved to a future date

            Set<Integer> todayRemarkedFofoIds = todayRemarks.stream()

                    .map(PartnerCollectionRemark::getFofoId)

                    .collect(Collectors.toSet());

            long movedToFuture = futurePlanPartners.stream()

                    .filter(todayRemarkedFofoIds::contains)

                    .count();

            targetModel.setMovedToFuture(movedToFuture);

            // Set out of sequence count for this RBM

            targetModel.setOutOfSequenceCount(outOfSequenceCountByAuthId.getOrDefault(rbmAuthId, 0L));

            rbmCallTargetModels.add(targetModel);

        }

        // Process L2 RBMs (escalated ticket logic with categorization)

        for (int l2AuthId : l2AuthIds) {

            AuthUser authUser = authUserMap.get(l2AuthId);

            if (authUser == null) {

                continue;

            }

            List<Integer> l2FofoIdList = l2AuthIdToFofoIds.getOrDefault(l2AuthId, Collections.emptyList());

            if (l2FofoIdList.isEmpty()) {

                continue;

            }

            // Filter to only external, ACTIVE stores with collection plan

            Map<Integer, Integer> finalAllCollectionRankMap2 = allCollectionRankMap;

            Map<Integer, FofoStore> finalFofoStoresMap2 = fofoStoresMap;

            List<Integer> validL2FofoIds = l2FofoIdList.stream()

                    .filter(fofoId -> {

                        FofoStore store = finalFofoStoresMap2.get(fofoId);

                        if (store == null || store.isInternal()) {

                            return false;

                        }

                        if (!ActivationType.ACTIVE.equals(store.getActivationType())) {

                            return false;

                        }

                        return finalAllCollectionRankMap2.containsKey(fofoId);

                    })

                    .collect(Collectors.toList());

            RbmCallTargetModel l2Model = new RbmCallTargetModel();

            l2Model.setAuthId(l2AuthId);

            l2Model.setRbmName(authUser.getFullName() + " (L2)");

            l2Model.setL2Position(true);

            l2Model.setL2CallingList(l2FofoIdList.size());

            // Partner count = total assigned partners (same as L1 source)

            List<Integer> l2AssignedFofoIds = rbmToFofoIdsMap.getOrDefault(l2AuthId, Collections.emptyList());

            l2Model.setPartnerCount(l2AssignedFofoIds.size());

            if (!validL2FofoIds.isEmpty()) {

                // Categorize using same logic as L1

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

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

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

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

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

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

                for (Integer fofoId : validL2FofoIds) {

                    int rank = allCollectionRankMap.getOrDefault(fofoId, 5);

                    boolean hasZeroBilling = !allMtdBilledFofoIds.contains(fofoId);

                    if (rank == 1) {

                        l2PlanToday.add(fofoId);

                    } else if (rank == 2) {

                        l2CarryForward.add(fofoId);

                    } else if (rank == 3) {

                        l2Untouched.add(fofoId);

                    } else if (hasZeroBilling) {

                        l2ZeroBilling.add(fofoId);

                    } else if (rank == 4) {

                        l2FuturePlan.add(fofoId);

                    } else {

                        l2Normal.add(fofoId);

                    }

                }

                l2Model.setPlanToday(l2PlanToday.size());

                l2Model.setCarryForward(l2CarryForward.size());

                l2Model.setUntouched(l2Untouched.size());

                l2Model.setZeroBilling(l2ZeroBilling.size());

                l2Model.setFuturePlan(l2FuturePlan.size());

                l2Model.setNormal(l2Normal.size());

                long l2TodayTarget = l2PlanToday.size() + l2CarryForward.size()

                        + l2ZeroBilling.size() + l2Untouched.size();

                l2Model.setTodayTargetOfCall(l2TodayTarget);

                // Value Achieved

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

                l2TodayTargetPartners.addAll(l2PlanToday);

                l2TodayTargetPartners.addAll(l2CarryForward);

                l2TodayTargetPartners.addAll(l2ZeroBilling);

                l2TodayTargetPartners.addAll(l2Untouched);

                List<PartnerCollectionRemark> l2TodayRemarks = remarksByAuthId.getOrDefault(l2AuthId, Collections.emptyList());

                long l2ValueAchieved = l2TodayRemarks.stream()

                        .map(PartnerCollectionRemark::getFofoId)

                        .filter(l2TodayTargetPartners::contains)

                        .distinct()

                        .count();

                l2Model.setValueTargetAchieved(l2ValueAchieved);

                // Moved to Future

                Set<Integer> l2TodayRemarkedFofoIds = l2TodayRemarks.stream()

                        .map(PartnerCollectionRemark::getFofoId)

                        .collect(Collectors.toSet());

                long l2MovedToFuture = l2FuturePlan.stream()

                        .filter(l2TodayRemarkedFofoIds::contains)

                        .count();

                l2Model.setMovedToFuture(l2MovedToFuture);

            }

            l2Model.setOutOfSequenceCount(outOfSequenceCountByAuthId.getOrDefault(l2AuthId, 0L));

            rbmCallTargetModels.add(l2Model);

        }

        // Group L1 under their L2 manager using authUser.managerId

        Map<Integer, RbmCallTargetModel> l2ModelsByAuthId = new HashMap<>();

        Map<Integer, RbmCallTargetModel> l1ModelsByAuthId = new HashMap<>();

        for (RbmCallTargetModel m : rbmCallTargetModels) {

            if (m.isL2Position()) {

                l2ModelsByAuthId.put(m.getAuthId(), m);

            } else {

                l1ModelsByAuthId.put(m.getAuthId(), m);

            }

        }

        // Build L2 -> L1 team map using managerId from AuthUser

        Map<Integer, List<RbmCallTargetModel>> l2TeamMap = new LinkedHashMap<>();

        for (RbmCallTargetModel l2Model : l2ModelsByAuthId.values()) {

            l2TeamMap.put(l2Model.getAuthId(), new ArrayList<>());

        }

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

        for (RbmCallTargetModel l1Model : l1ModelsByAuthId.values()) {

            AuthUser l1User = authUserMap.get(l1Model.getAuthId());

            if (l1User != null && l2TeamMap.containsKey(l1User.getManagerId())) {

                l2TeamMap.get(l1User.getManagerId()).add(l1Model);

                addedL1AuthIds.add(l1Model.getAuthId());

            }

        }

        // Build sorted result: L2 row, then its L1 team (sorted by name)

        List<RbmCallTargetModel> sortedModels = new ArrayList<>();

        List<RbmCallTargetModel> l2Sorted = new ArrayList<>(l2ModelsByAuthId.values());

        l2Sorted.sort(Comparator.comparing(RbmCallTargetModel::getRbmName));

        for (RbmCallTargetModel l2Model : l2Sorted) {

            sortedModels.add(l2Model);

            List<RbmCallTargetModel> team = l2TeamMap.getOrDefault(l2Model.getAuthId(), Collections.emptyList());

            team.sort(Comparator.comparing(RbmCallTargetModel::getRbmName));

            sortedModels.addAll(team);

        }

        // Add any L1 RBMs not mapped to any L2 (sorted by name)

        List<RbmCallTargetModel> unmappedL1 = new ArrayList<>();

        for (RbmCallTargetModel m : l1ModelsByAuthId.values()) {

            if (!addedL1AuthIds.contains(m.getAuthId())) {

                unmappedL1.add(m);

            }

        }

        unmappedL1.sort(Comparator.comparing(RbmCallTargetModel::getRbmName));

        sortedModels.addAll(unmappedL1);

        LOGGER.info("RBM Call Target - TOTAL TIME: {}ms, RBM count: {}", System.currentTimeMillis() - methodStart, sortedModels.size());

        return sortedModels;

    }

    @Override

    public List<OutOfSequenceDetailModel> getOutOfSequenceDetails(int authId) {

        LocalDate today = LocalDate.now();

        LocalDateTime start = today.atStartOfDay();

        LocalDateTime end = today.plusDays(1).atStartOfDay();

        List<RbmCallSequenceLog> logs =

                rbmCallSequenceLogRepository.selectByAuthIdAndDateRange(authId, start, end);

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

        List<RbmCallSequenceLog> oosLogs = new ArrayList<>();

        for (RbmCallSequenceLog log : logs) {

            if (log.isOutOfSequence()) {

                oosLogs.add(log);

                fofoIds.add(log.getFofoId());

            }

        }

        if (oosLogs.isEmpty()) {

            return Collections.emptyList();

        }

        Map<Integer, CustomRetailer> retailerMap = Collections.emptyMap();

        try {

            retailerMap = retailerService.getFofoRetailers(new ArrayList<>(fofoIds));

        } catch (ProfitMandiBusinessException e) {

            LOGGER.error("Error fetching fofo stores", e);

        }

        DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("hh:mm a");

        List<OutOfSequenceDetailModel> result = new ArrayList<>();

        for (RbmCallSequenceLog log : oosLogs) {

            CustomRetailer retailer = retailerMap.get(log.getFofoId());

            String partyName = retailer != null

                    ? retailer.getBusinessName()

                    : "Unknown (" + log.getFofoId() + ")";

            String code = retailer != null

                    ? retailer.getCode()

                    : "-";

            String time = log.getCreateTimestamp() != null

                    ? log.getCreateTimestamp().format(timeFormatter)

                    : "-";

            result.add(new OutOfSequenceDetailModel(partyName, code, time));

        }

        return result;

    }