Subversion Repositories SmartDukaan

package com.spice.profitmandi.service.pricing;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import org.apache.commons.collections.CollectionUtils;

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

import org.springframework.stereotype.Component;

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

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

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

import com.spice.profitmandi.dao.entity.user.Address;

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

import com.spice.profitmandi.dao.repository.fofo.PinCodeTagRepository;

import com.spice.profitmandi.dao.repository.fofo.RetailerTagRepository;

import com.spice.profitmandi.dao.repository.fofo.TagListingRepository;

import com.spice.profitmandi.dao.repository.user.AddressRepository;

import com.spice.profitmandi.service.tag.TagService;

@Component

public class PricingServiceImpl implements PricingService{

	@Autowired

	RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;

	@Autowired

	AddressRepository addressRepository;

	@Autowired

	PinCodeTagRepository pinCodeTagRepository;

	@Autowired

	TagService tagService;

	@Autowired

	RetailerTagRepository retailerTagRepository;

	@Autowired

	TagListingRepository tagListingRepository;

	@SuppressWarnings("unchecked")

	@Override

	public Map<Integer, Float> getPrice(Set<Integer> itemIds, int retailerId) {

		Map<Integer, Float> itemIdPrice = this.preparePriceDefaultValues(itemIds);

		int addressId;

		try {

			addressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailerId);

			Address retailerAddress = addressRepository.selectById(addressId);

			Set<Integer> pinCodeTagIds = tagService.getFofoTagIdsByPinCode(retailerAddress.getPinCode());

			if(pinCodeTagIds.isEmpty()){

				return itemIdPrice;

			}

			Set<Integer> pinPositiveTagIds = tagService.getPinCodePositiveTagIds();

			if(pinPositiveTagIds.isEmpty()){

				return itemIdPrice;

			}

			Set<Integer> pinCodeIntersection = (Set<Integer>)CollectionUtils.intersection(pinCodeTagIds, pinPositiveTagIds);

			Set<Integer> pinCodeUnion = (Set<Integer>) CollectionUtils.union(pinCodeTagIds, pinPositiveTagIds);

			Set<Integer> filterPinCodeTagIds = (Set<Integer>)CollectionUtils.subtract(pinCodeUnion, pinCodeIntersection);

			if(filterPinCodeTagIds.isEmpty()){

				return itemIdPrice;

			}

			List<RetailerTag> retailerTags = retailerTagRepository.selectByTagIds(filterPinCodeTagIds);

			if(retailerTags.isEmpty()){

				return itemIdPrice;

			}

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

			for(RetailerTag retailerTag : retailerTags){

				retailerTagIds.add(retailerTag.getTagId());

			}

			Set<Integer> userPositiveTagIds = tagService.getUserPositiveTagIds();

			Set<Integer> userIntersection = (Set<Integer>)CollectionUtils.intersection(retailerTagIds, userPositiveTagIds);

			Set<Integer> userUnion = (Set<Integer>)CollectionUtils.union(retailerTagIds, userPositiveTagIds);

			Set<Integer> filterUserTagIds = (Set<Integer>)CollectionUtils.subtract(userUnion, userIntersection);

			if(filterUserTagIds.isEmpty()){

				return itemIdPrice;

			}

			List<TagListing> tagListings = tagListingRepository.selectByItemIdsAndTagIds(itemIds, filterUserTagIds);

			if(tagListings.isEmpty()){

				return itemIdPrice;

			}

			for(TagListing tagListing : tagListings){

				if(itemIdPrice.get(tagListing.getItemId()) > tagListing.getSellingPrice()){

					itemIdPrice.put(tagListing.getItemId(), tagListing.getSellingPrice());

				}

			}

		} catch (ProfitMandiBusinessException e) {

			e.printStackTrace();

		}

		return itemIdPrice;

	}

	private Map<Integer, Float> preparePriceDefaultValues(Set<Integer> itemIds){

		Map<Integer, Float> itemIdPrice = new HashMap<>(itemIds.size());

		for(int itemId : itemIds){

			itemIdPrice.put(itemId, Float.MAX_VALUE);

		}

		return itemIdPrice;

	}

}