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;
        }
        
}