Subversion Repositories SmartDukaan

    public Map<Integer, Integer> getAuthUserIdsWithoutTicketAssigneeByFofoIds(int categoryId, EscalationType escalationType, Set<Integer> fofoIds) throws ProfitMandiBusinessException {

        Map<Integer, Integer> result = new HashMap<>();

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

            return result;

        }

        for (Integer fofoId : fofoIds) {

            result.put(fofoId, 0);

        }

        List<Position> positions = positionRepository.selectPositionbyCategoryIdAndEscalationType(categoryId, escalationType);

        if (positions.isEmpty()) {

            return result;

        }

        Set<Integer> positionIds = positions.stream().map(Position::getId).collect(Collectors.toSet());

        Map<Integer, Integer> positionToAuthUser = new HashMap<>();

        positions.forEach(p -> positionToAuthUser.put(p.getId(), p.getAuthUserId()));

        List<Integer> fofoIdList = new ArrayList<>(fofoIds);

        fofoIdList.add(0);

        List<PartnerRegion> allPartnerRegions = partnerRegionRepository.selectByfofoIds(fofoIdList);

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

        for (Integer fofoId : fofoIds) {

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

            regions.add(ALL_PARTNERS_REGION);

            fofoRegionMap.put(fofoId, regions);

        }

        for (PartnerRegion pr : allPartnerRegions) {

            int fofoId = pr.getFofoId();

            if (fofoId == 0) {

                for (Integer fid : fofoIds) {

                    fofoRegionMap.get(fid).add(pr.getRegionId());

                }

            } else if (fofoIds.contains(fofoId)) {

                fofoRegionMap.get(fofoId).add(pr.getRegionId());

            }

        }

        Set<Integer> allRegionIds = fofoRegionMap.values().stream()

                .flatMap(Set::stream).collect(Collectors.toSet());

        List<PartnerPosition> allPartnerPositions = partnerPositionRepository.selectByRegionIdAndPostionId(

                new ArrayList<>(allRegionIds), new ArrayList<>(positionIds));

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

        Set<Integer> activeAuthUserIds = authRepository.selectByIds(new ArrayList<>(allAuthUserIds))

                .stream().filter(AuthUser::isActive).map(AuthUser::getId).collect(Collectors.toSet());

        for (Integer fofoId : fofoIds) {

            Set<Integer> regionIds = fofoRegionMap.get(fofoId);

            for (PartnerPosition pp : allPartnerPositions) {

                if (!regionIds.contains(pp.getRegionId())) continue;

                if (pp.getFofoId() != 0 && pp.getFofoId() != fofoId) continue;

                Integer authUserId = positionToAuthUser.get(pp.getPositionId());

                if (authUserId != null && activeAuthUserIds.contains(authUserId)) {

                    result.put(fofoId, authUserId);

                    break;

                }

            }

        }

        return result;

    }

    @Override