Subversion Repositories SmartDukaan

    @Override

    public List<List<String>> getAllCallDataByDate(LocalDate date) throws Exception {

        List<List<String>> rows = new ArrayList<>();

        // Add header row

        rows.add(Arrays.asList("RBM Name", "Partner Name", "Code", "Remark", "Call Status", "Call Duration", "Call Date Time", "Recording URL"));

        // Get all call logs for the date

        List<AgentCallLog> allCallLogs = agentCallLogRepository.findAllByDate(date);

        LOGGER.info("getAllCallDataByDate: Found {} call logs for date {}", allCallLogs.size(), date);

        if (allCallLogs.isEmpty()) {

            return rows;

        }

        // Get unique authIds from call logs

        Set<Long> authIds = allCallLogs.stream()

                .map(AgentCallLog::getAuthId)

                .collect(Collectors.toSet());

        // Get auth users for RBM names

        List<Integer> authIdInts = authIds.stream().map(Long::intValue).collect(Collectors.toList());

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

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

        // Build a map of normalized customer number -> fofoId

        Map<String, Integer> customerToFofoIdMap = new HashMap<>();

        Set<String> normalizedNumbers = new HashSet<>();

        for (AgentCallLog callLog : allCallLogs) {

            String customerNumber = callLog.getCustomerNumber();

            if (customerNumber != null) {

                String normalized = customerNumber.startsWith("+91") ? customerNumber.substring(3) : customerNumber;

                normalizedNumbers.add(normalized);

            }

        }

        // For each normalized number, find fofoId

        for (String mobile : normalizedNumbers) {

            Integer fofoId = findFofoIdByMobile(mobile);

            if (fofoId != null) {

                customerToFofoIdMap.put(mobile, fofoId);

            }

        }

        // Get unique fofoIds for retailer lookup

        Set<Integer> fofoIds = new HashSet<>(customerToFofoIdMap.values());

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

        if (!fofoIds.isEmpty()) {

            try {

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

            } catch (ProfitMandiBusinessException e) {

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

            }

        }

        // Get remarks for these fofoIds on this date

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

        if (!fofoIds.isEmpty()) {

            List<PartnerCollectionRemark> dateRemarks = partnerCollectionRemarkRepository

                    .selectAllByFofoIdsOnDate(new ArrayList<>(fofoIds), date);

            for (PartnerCollectionRemark remark : dateRemarks) {

                fofoRemarkMap.computeIfAbsent(remark.getFofoId(), k -> new ArrayList<>()).add(remark);

            }

        }

        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd-MM-yyyy hh:mm a");

        // Build rows

        for (AgentCallLog callLog : allCallLogs) {

            String customerNumber = callLog.getCustomerNumber();

            if (customerNumber == null) {

                continue;

            }

            // Get RBM Name

            AuthUser authUser = authUserMap.get((int) callLog.getAuthId());

            String rbmName = authUser != null ? authUser.getFullName() : "Unknown";

            String normalized = customerNumber.startsWith("+91") ? customerNumber.substring(3) : customerNumber;

            Integer fofoId = customerToFofoIdMap.get(normalized);

            String partyName = "Unknown";

            String code = "-";

            if (fofoId != null) {

                CustomRetailer retailer = retailerMap.get(fofoId);

                if (retailer != null) {

                    partyName = retailer.getBusinessName();

                    code = retailer.getCode();

                } else {

                    partyName = "Unknown (" + fofoId + ")";

                }

            } else {

                partyName = "Unknown (" + normalized + ")";

            }

            // Get remark if available

            String remarkValue = "-";

            if (fofoId != null && fofoRemarkMap.containsKey(fofoId)) {

                List<PartnerCollectionRemark> remarks = fofoRemarkMap.get(fofoId);

                if (!remarks.isEmpty()) {

                    PartnerCollectionRemark remark = remarks.get(0);

                    remarkValue = remark.getRemark() != null ? remark.getRemark().getValue() : "-";

                    if (remark.getMessage() != null && !remark.getMessage().isEmpty()) {

                        remarkValue = remarkValue + " - " + remark.getMessage();

                    }

                }

            }

            // Call status from customerStatus field

            String callStatus = callLog.getCustomerStatus() != null ? callLog.getCustomerStatus() : "-";

            String callDuration = callLog.getCallDuration() != null ? callLog.getCallDuration() : "-";

            String callDateTime = "-";

            if (callLog.getCallDate() != null && callLog.getCallTime() != null) {

                LocalDateTime callDateTimeObj = LocalDateTime.of(callLog.getCallDate(), callLog.getCallTime());

                callDateTime = callDateTimeObj.format(dateTimeFormatter);

            }

            String recordingUrl = callLog.getRecordingUrl() != null ? callLog.getRecordingUrl() : "-";

            rows.add(Arrays.asList(rbmName, partyName, code, remarkValue, callStatus, callDuration, callDateTime, recordingUrl));

        }

        return rows;

    }