Subversion Repositories SmartDukaan

import com.spice.profitmandi.common.util.FileUtil;

import com.spice.profitmandi.service.order.OrderService;

import org.springframework.http.ResponseEntity;

    private OrderService orderService;

    @Autowired

    private static String nvl(String s) {

        return s == null ? "" : s;

    }

    // Download every ticket the user can see in the current filter (respects ticketStatus /

    // sortOrder / search — but ignores pagination) as CSV with the same 8 columns rendered

    // in ticket-content.vm: Ticket Id, Partner, Category, SubCategory, Message, Created By,

    // Assigned To, Created TimeStamp.

    @GetMapping(value = "/cs/downloadMyTickets")

    public ResponseEntity<?> downloadMyTickets(HttpServletRequest request,

                                               @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,

                                               @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,

                                               @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,

                                               @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,

                                               @RequestParam(name = "search", required = false) String searchText) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        boolean isAdmin = roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()));

        AuthUser currentAuthUser = isAdmin ? authRepository.selectByEmailOrMobile(loginDetails.getEmailId()) : null;

        boolean isCrmUser = isAdmin && currentAuthUser != null

                && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);

        List<Integer> userCategoryIds = isAdmin && currentAuthUser != null

                ? positionRepository.selectCategoryIdsByAuthUserId(currentAuthUser.getId())

                : Collections.emptyList();

        List<Ticket> tickets;

        if (isAdmin) {

            int authUserId = currentAuthUser.getId();

            Optional<Boolean> resolvedOpt = ticketStatus.equals(TicketStatus.RESOLVED)

                    ? Optional.empty()

                    : Optional.of(TicketStatus.CLOSED.equals(ticketStatus));

            long total;

            if (isCrmUser) {

                total = ticketRepository.selectAllTicketsPaginatedCount(

                        resolvedOpt, ticketSearchType, searchTerm, searchText, userCategoryIds);

                tickets = ticketRepository.selectAllTicketsPaginated(

                        resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,

                        userCategoryIds, 0, (int) Math.max(1L, total));

            } else {

                total = ticketRepository.selectAllByAssigneePaginatedCount(

                        authUserId, resolvedOpt, ticketSearchType, searchTerm, searchText);

                tickets = ticketRepository.selectAllByAssigneePaginated(

                        authUserId, resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,

                        0, (int) Math.max(1L, total));

            }

        } else {

            tickets = ticketRepository.selectAllByCreator(

                    loginDetails.getFofoId(),

                    Optional.of(TicketStatus.OPENED.equals(ticketStatus)),

                    sortOrder);

        }

        if (tickets == null) tickets = new ArrayList<>();

        List<Integer> subCategoryIds = tickets.stream().map(Ticket::getSubCategoryId).collect(Collectors.toList());

        Map<Integer, TicketSubCategory> subMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);

        if (subMap == null) subMap = new HashMap<>();

        Map<Integer, TicketCategory> catMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);

        if (catMap == null) catMap = new HashMap<>();

        Map<Integer, CustomRetailer> partnerMap = tickets.isEmpty()

                ? new HashMap<>()

                : csService.getPartnerByFofoIds(tickets);

        if (partnerMap == null) partnerMap = new HashMap<>();

        Map<Integer, List<AuthUser>> assigneeListMap = csService.getAssignedAuthList(tickets);

        if (assigneeListMap == null) assigneeListMap = new HashMap<>();

        Map<Integer, AuthUser> authUserIdMap = csService.getTicketIdAndAuthUserMapUsingTickets(tickets);

        if (authUserIdMap == null) authUserIdMap = new HashMap<>();

        List<Integer> ticketIds = tickets.stream().map(Ticket::getId).collect(Collectors.toList());

        Map<Integer, Activity> lastMessageMap = ticketIds.isEmpty()

                ? new HashMap<>()

                : csService.getLastMessageActivitiesForTickets(ticketIds);

        if (lastMessageMap == null) lastMessageMap = new HashMap<>();

        List<Activity> allActs = ticketIds.isEmpty()

                ? new ArrayList<>()

                : activityRepository.selectAll(ticketIds);

        Map<Integer, List<Activity>> activityByTicket = allActs.stream()

                .collect(Collectors.groupingBy(Activity::getTicketId));

        Map<Integer, Activity> activityById = allActs.stream()

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

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

        for (Activity a : allActs) if (a.getCreatedBy() > 0) creatorIds.add(a.getCreatedBy());

        for (Activity a : lastMessageMap.values()) if (a.getCreatedBy() > 0) creatorIds.add(a.getCreatedBy());

        Map<Integer, AuthUser> authUserMap = creatorIds.isEmpty()

                ? new HashMap<>()

                : authRepository.selectByIds(new ArrayList<>(creatorIds)).stream()

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

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

        for (Ticket t : tickets) {

            int id = t.getId();

            CustomRetailer cr = partnerMap.get(t.getFofoId());

            String partner = cr != null ? nvl(cr.getBusinessName()) : "";

            TicketCategory cat = catMap.get(t.getSubCategoryId());

            String category = cat != null ? nvl(cat.getName()) : "";

            TicketSubCategory sub = subMap.get(t.getSubCategoryId());

            String subCategory = sub != null ? nvl(sub.getName()) : "";

            String message = "-";

            Activity msgAct = lastMessageMap.get(id);

            if (msgAct == null) {

                List<Activity> list = activityByTicket.get(id);

                if (list != null && !list.isEmpty()) msgAct = list.get(0);

            }

            if (msgAct != null) {

                String prefix = "~Partner";

                if (msgAct.getCreatedBy() > 0 && authUserMap.get(msgAct.getCreatedBy()) != null) {

                    prefix = "~" + nvl(authUserMap.get(msgAct.getCreatedBy()).getFirstName());

                }

                message = prefix + " " + nvl(msgAct.getMessage());

            }

            String createdBy = "Partner";

            Activity firstAct = activityById.get(t.getFirstActivityId());

            if (firstAct != null && firstAct.getCreatedBy() > 0) {

                AuthUser u = authUserMap.get(firstAct.getCreatedBy());

                if (u != null) createdBy = (nvl(u.getFirstName()) + " " + nvl(u.getLastName())).trim();

            }

            String assignedTo = "";

            List<AuthUser> assignees = assigneeListMap.get(id);

            if (assignees != null && !assignees.isEmpty()) {

                assignedTo = assignees.stream()

                        .map(u -> (nvl(u.getFirstName()) + " " + nvl(u.getLastName())).trim())

                        .collect(Collectors.joining(", "));

            } else if (authUserIdMap.get(id) != null) {

                AuthUser a = authUserIdMap.get(id);

                assignedTo = (nvl(a.getFirstName()) + " " + nvl(a.getLastName())).trim();

            }

            String createdTs = t.getFormattedCreateTimestamp() != null ? t.getFormattedCreateTimestamp() : "";

            rows.add(Arrays.asList(id, partner, category, subCategory, message, createdBy, assignedTo, createdTs));

        }

        org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(

                Arrays.asList("Ticket Id", "Partner", "Category", "SubCategory", "Message",

                        "Created By", "Assigned To", "Created TimeStamp"),

                rows);

        return orderService.downloadReportInCsv(baos, rows, "Tickets_" + ticketStatus.name());

    }