Subversion Repositories SmartDukaan

import com.itextpdf.text.pdf.PdfStructTreeController.returnType;

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

	public Map<String, Set<Integer>> getAuthUserPartnerIdMappingByCategoryIds(List<Integer> categoryIds) {

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

		Set<Integer> activeFofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())

				.collect(Collectors.toSet());

		List<Position> categoryPositions = positionRepository.selectPositionByCategoryIds(categoryIds);

		Map<Integer, Position> positionsMap = categoryPositions.stream()

				.collect(Collectors.toMap(x -> x.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 = authRepository.selectById(authUserId);

			if (authUser.isActive()) {

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

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

				} else {

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

				}

			}

		}

		return authUserPartnerMap;

	}

	@Override

	@Override

	public Set<Integer> getAuthFofoIds(String email) throws ProfitMandiBusinessException {

		List<Integer> categoryIds = ticketCategoryRepository.selectAll().stream().map(x -> x.getId())

				.collect(Collectors.toList());

		Map<String, Set<Integer>> storeGuyMap = this.getAuthUserPartnerIdMappingByCategoryIds(categoryIds);

		Set<Integer> authfofoIds = storeGuyMap.get(email);

		AuthUser authUser = authRepository.selectByEmailOrMobile(email);

		if (authfofoIds == null) {

			List<Position> positions1 = positionRepository.selectAll(authUser.getId());

			if (positions1.stream().filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_MASTER)

					.count() > 0) {

				authfofoIds = this.getPositionCustomRetailerMap(positions1).values().stream().flatMap(x -> x.stream())

						.map(x -> x.getPartnerId()).collect(Collectors.toSet());

			}

		}

		return authfofoIds;

	}