Subversion Repositories SmartDukaan

    public Map<Integer, Activity> getLastMessageActivitiesForTickets(List<Integer> ticketIds) {

        Map<Integer, Activity> lastMessageMap = new HashMap<>();

        if (ticketIds == null || ticketIds.isEmpty()) {

            return lastMessageMap;

        }

        Set<ActivityType> messageTypes = EnumSet.of(

                ActivityType.COMMUNICATION_IN, ActivityType.COMMUNICATION_OUT,

                ActivityType.COMMUNICATION_INTERNAL, ActivityType.OPENED);

        List<Activity> allActivities = activityRepository.selectAll(ticketIds);

        Map<Integer, List<Activity>> groupedByTicket = allActivities.stream()

                .filter(a -> messageTypes.contains(a.getType()))

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

        for (Map.Entry<Integer, List<Activity>> entry : groupedByTicket.entrySet()) {

            Activity lastMessage = entry.getValue().stream()

                    .max(Comparator.comparingInt(Activity::getId))

                    .orElse(null);

            if (lastMessage != null) {

                lastMessageMap.put(entry.getKey(), lastMessage);

            }

        }

        return lastMessageMap;

    }

    @Override