Subversion Repositories SmartDukaan

package com.spice.profitmandi.service.catalog;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.util.Utils;

import com.spice.profitmandi.dao.entity.catalog.BrandCatalog;

import com.spice.profitmandi.dao.entity.catalog.BrandCategory;

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.entity.fofo.PartnerDealerMapping;

import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;

import com.spice.profitmandi.dao.repository.catalog.BrandCategoryRepository;

import com.spice.profitmandi.dao.repository.catalog.BrandsRepository;

import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;

import com.spice.profitmandi.dao.repository.dtr.PartnerDealerRepository;

import com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository;

import com.spice.profitmandi.dao.repository.dtr.RetailerBlockBrandsRepository;

import com.spice.profitmandi.dao.repository.onboarding.BrandCommitRepository;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

@Component

public class BrandsServiceImpl implements BrandsService {

	@Autowired

	private BrandCategoryRepository brandCategoryRepository;

	@Autowired

	private BrandsRepository brandCatalogRepository;

	@Autowired

	private RetailerBlockBrandsRepository retailerBlockBrandsRepository;

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	@Autowired

	private PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;

	@Autowired

	private PartnerDealerRepository partnerDealerRepository;

	@Autowired

	private BrandCommitRepository brandCommitRepository;

	@Override

    public List<BrandCatalog> getBrands(int fofoId, String email, int categoryId) throws ProfitMandiBusinessException {

		List<BrandCatalog> brandsDisplay = this.getBrandsToDisplay(categoryId);

		if (fofoId == Utils.SYSTEM_PARTNER_ID) {

			return brandsDisplay;

		}

		List<String> blockedBrands = retailerBlockBrandsRepository.selectAllByRetailer(fofoId).stream()

				.map(x -> x.getBlockBrands()).collect(Collectors.toList());

		brandsDisplay = brandsDisplay.stream().filter(x -> !blockedBrands.contains(x.getName()))

				.collect(Collectors.toList());

		return brandsDisplay;

	}

	@Override

    public List<BrandCatalog> getBrandsToDisplay(int categoryId) throws ProfitMandiBusinessException {

		List<BrandCategory> brandCategories = brandCategoryRepository.selectByCategoryId(categoryId).stream()

				.filter(x -> x.isActive()).collect(Collectors.toList());

		Map<Integer, BrandCategory> brandCategoryMap = brandCategories.stream()

				.collect(Collectors.toMap(x -> x.getBrandId(), x -> x));

		List<Integer> brandIds = brandCategories.stream().map(x -> x.getBrandId()).collect(Collectors.toList());

		List<BrandCatalog> brands = brandCatalogRepository.selectByIds(brandIds);

		for (BrandCatalog brand : brands) {

			brand.setBrandCategory(brandCategoryMap.get(brand.getId()));

		}

		return brands;

	}

	@Override

	public List<String> partnerIneligibleBrands(int fofoId) throws ProfitMandiBusinessException {

		FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);

		PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fofoStore.getCode());

		List<PartnerDealerMapping> partnerDealerMappingList = new ArrayList<>();

		List<String> wodRequiredBrands = new ArrayList<>();

		if (partnerOnBoardingPanel != null) {

			partnerDealerMappingList = partnerDealerRepository.selectByOnboardingId(partnerOnBoardingPanel.getId());

			if (partnerDealerMappingList != null && partnerDealerMappingList.size() > 0) {

				//working brands -> Partner only work with brands that having 'Dealer Code'

				wodRequiredBrands = partnerDealerMappingList.stream().filter(x -> x.getBrandCode().trim().length() == 0).map(x -> x.getBrand()).collect(Collectors.toList());

			}

		}

		//brandsToBeCheck

		List<String> nocRequiredBrand = brandCommitRepository.selectAllActiveBrand().stream().filter(x -> x.isNocRequired()).map(x -> x.getBrand()).collect(Collectors.toList());

		List<String> ineligibleBrands = nocRequiredBrand.stream()

				.filter(wodRequiredBrands::contains)

				.collect(Collectors.toList());

		return ineligibleBrands;

	}

}