Subversion Repositories SmartDukaan

    @Cacheable(value = "authUserEmailInactivePartnerIdMapping", cacheManager = "thirtyMinsTimeOutCacheManager")

    public Map<String, Set<Integer>> getAuthUserInactivePartnerIdMapping() throws ProfitMandiBusinessException {

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

        Set<Integer> activeFofoIds = fofoStoreRepository.selectInActiveStore().stream().map(x -> x.getId()).collect(Collectors.toSet());

        // Batch fetch positions by category IDs instead of multiple calls

        List<Position> categoryPositions = positionRepository.selectPositionByCategoryIds(Arrays.asList(

                ProfitMandiConstants.TICKET_CATEGORY_SALES,

                ProfitMandiConstants.TICKET_CATEGORY_RBM,

                ProfitMandiConstants.TICKET_CATEGORY_ABM,

                ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT,

                ProfitMandiConstants.TICKET_CATEGORY_TRAINING));

        Map<Integer, Position> positionsMap = categoryPositions.stream().collect(Collectors.toMap(x -> x.getId(), x -> x));

        // Batch fetch all AuthUsers upfront to avoid N+1 queries

        Set<Integer> authUserIds = categoryPositions.stream().map(Position::getAuthUserId).collect(Collectors.toSet());

        Map<Integer, AuthUser> authUserMap = authRepository.selectByIds(new ArrayList<>(authUserIds)).stream()

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

        Map<Integer, List<CustomRetailer>> positonPartnerMap = this.getPositionCustomRetailerMap(categoryPositions);

        for (Map.Entry<Integer, List<CustomRetailer>> positionPartnerEntry : positonPartnerMap.entrySet()) {

            int authUserId = positionsMap.get(positionPartnerEntry.getKey()).getAuthUserId();

            Set<Integer> partnerIds = positionPartnerEntry.getValue().stream().filter(x -> activeFofoIds.contains(x.getPartnerId())).map(x -> x.getPartnerId()).collect(Collectors.toSet());

            AuthUser authUser = authUserMap.get(authUserId);

            if (authUser != null && authUser.isActive()) {

                if (!storeGuyMap.containsKey(authUser.getEmailId())) {

                    storeGuyMap.put(authUser.getEmailId(), partnerIds);

                } else {

                    storeGuyMap.get(authUser.getEmailId()).addAll(partnerIds);

                }

            }

        }

        return storeGuyMap;

    }

    @Override