Subversion Repositories SmartDukaan

    @Override

    public Set<Integer> getPartnerIdsByAuthUserId(int authUserId) throws ProfitMandiBusinessException {

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

        // Get all positions for this auth user

        List<Position> userPositions = positionRepository.selectAllByAuthUserId(authUserId);

        // Filter to relevant categories (SALES, RBM, ABM, BI, TRAINING)

        List<Integer> relevantCategoryIds = Arrays.asList(

                ProfitMandiConstants.TICKET_CATEGORY_SALES,

                ProfitMandiConstants.TICKET_CATEGORY_RBM,

                ProfitMandiConstants.TICKET_CATEGORY_ABM,

                ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT,

                ProfitMandiConstants.TICKET_CATEGORY_TRAINING);

        List<Position> filteredPositions = userPositions.stream()

                .filter(p -> relevantCategoryIds.contains(p.getCategoryId()))

                .collect(Collectors.toList());

        if (filteredPositions.isEmpty()) {

            return partnerIds;

        }

        // Get position IDs

        List<Integer> positionIds = filteredPositions.stream()

                .map(Position::getId)

                .collect(Collectors.toList());

        // Get partner positions for these positions

        List<PartnerPosition> partnerPositions = partnerPositionRepository.selectByPositionIds(positionIds);

        // Check if any position has partnerId = 0 (means all active partners)

        boolean hasAllPartnersAccess = partnerPositions.stream().anyMatch(pp -> pp.getFofoId() == 0);

        if (hasAllPartnersAccess) {

            // Return all active partner IDs

            partnerIds = fofoStoreRepository.selectActiveStores().stream()

                    .map(FofoStore::getId)

                    .collect(Collectors.toSet());

        } else {

            // Get partner IDs from direct assignments

            Set<Integer> directPartnerIds = partnerPositions.stream()

                    .filter(pp -> pp.getFofoId() != 0)

                    .map(PartnerPosition::getFofoId)

                    .collect(Collectors.toSet());

            partnerIds.addAll(directPartnerIds);

            // Get partner IDs from region assignments

            Set<Integer> regionIds = partnerPositions.stream()

                    .filter(pp -> pp.getRegionId() > 0)

                    .map(PartnerPosition::getRegionId)

                    .collect(Collectors.toSet());

            if (!regionIds.isEmpty()) {

                List<PartnerRegion> partnerRegions = partnerRegionRepository.selectAllByRegionIds(new ArrayList<>(regionIds));

                Set<Integer> regionPartnerIds = partnerRegions.stream()

                        .map(PartnerRegion::getFofoId)

                        .collect(Collectors.toSet());

                partnerIds.addAll(regionPartnerIds);

            }

        }

        // Filter to only active partners

        Set<Integer> activeFofoIds = fofoStoreRepository.selectActiveStores().stream()

                .map(FofoStore::getId)

                .collect(Collectors.toSet());

        partnerIds.retainAll(activeFofoIds);

        return partnerIds;

    }