Subversion Repositories SmartDukaan

Rev

Rev 29797 | Rev 29808 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 29797 Rev 29806
Line 13... Line 13...
13 
import java.util.LinkedHashMap;
 13 
import java.util.LinkedHashMap;
14 
import java.util.List;
 14 
import java.util.List;
15 
import java.util.Map;
 15 
import java.util.Map;
16 
import java.util.Set;
 16 
import java.util.Set;
17 
import java.util.stream.Collectors;
 17 
import java.util.stream.Collectors;
18 
import java.util.stream.Stream;
 - 
 
19 
 
 18 
 
20 
import org.apache.logging.log4j.LogManager;
 19 
import org.apache.logging.log4j.LogManager;
21 
import org.apache.logging.log4j.Logger;
 20 
import org.apache.logging.log4j.Logger;
22 
import org.apache.poi.ss.usermodel.Cell;
 21 
import org.apache.poi.ss.usermodel.Cell;
23 
import org.apache.poi.ss.usermodel.CellType;
 22 
import org.apache.poi.ss.usermodel.CellType;
Line 25... Line 24...
25 
import org.apache.poi.ss.usermodel.Row.MissingCellPolicy;
 24 
import org.apache.poi.ss.usermodel.Row.MissingCellPolicy;
26 
import org.apache.poi.xssf.usermodel.XSSFRow;
 25 
import org.apache.poi.xssf.usermodel.XSSFRow;
27 
import org.apache.poi.xssf.usermodel.XSSFSheet;
 26 
import org.apache.poi.xssf.usermodel.XSSFSheet;
28 
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 27 
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
29 
import org.springframework.beans.factory.annotation.Autowired;
 28 
import org.springframework.beans.factory.annotation.Autowired;
- 
 
 29 
import org.springframework.cache.CacheManager;
30 
import org.springframework.cache.annotation.Cacheable;
 30 
import org.springframework.cache.annotation.Cacheable;
31 
import org.springframework.stereotype.Component;
 31 
import org.springframework.stereotype.Component;
32 
 
 32 
 
33 
import com.google.common.collect.Lists;
 33 
import com.google.common.collect.Lists;
34 
import com.google.gson.Gson;
 34 
import com.google.gson.Gson;
Line 74... Line 74...
74 
	@Autowired
 74 
	@Autowired
75 
	private TagListingRepository tagListingRepository;
 75 
	private TagListingRepository tagListingRepository;
76 
 
 76 
 
77 
	@Autowired
 77 
	@Autowired
78 
	private OfferTargetSlabRepository targetSlabRepository;
 78 
	private OfferTargetSlabRepository targetSlabRepository;
- 
 
 79
- 
 
 80 
	@Autowired
- 
 
 81 
	CacheManager cacheManager;
- 
 
 82 
 
79 
 
 83 
 
80 
	private static final Logger LOGGER = LogManager.getLogger(OfferServiceImpl.class);
 84 
	private static final Logger LOGGER = LogManager.getLogger(OfferServiceImpl.class);
81 
 
 85 
 
82 
	@Override
 86 
	@Override
83 
	public void addOfferService(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
 87 
	public void addOfferService(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
84 
		LOGGER.info("createOfferRequest  -- {}", createOfferRequest);
 88 
		LOGGER.info("createOfferRequest  -- {}", createOfferRequest);
85 
		this.createOffer(createOfferRequest);
 89 
		this.createOffer(createOfferRequest);
86 
		this.createTargetSlabs(createOfferRequest);
 90 
		this.createTargetSlabs(createOfferRequest);
- 
 
 91 
		cacheManager.getCache("allOffers").clear();
- 
 
 92
87 
	}
 93 
	}
88 
 
 94 
 
89 
	private void createOffer(CreateOfferRequest createOfferRequest) {
 95 
	private void createOffer(CreateOfferRequest createOfferRequest) {
90 
		Offer offer = new Offer();
 96 
		Offer offer = new Offer();
91 
		offer.setName(createOfferRequest.getName());
 97 
		offer.setName(createOfferRequest.getName());
Line 320... Line 326...
320 
				List<Integer> targets = targetPartnersEntry.getKey();
 326 
				List<Integer> targets = targetPartnersEntry.getKey();
321 
				LOGGER.info("Targets  {}", targets);
 327 
				LOGGER.info("Targets  {}", targets);
322 
 
 328 
 
323 
				createOfferRequest.getPartnerCriteria().setFofoIds(filterFofoIds);
 329 
				createOfferRequest.getPartnerCriteria().setFofoIds(filterFofoIds);
324 
				int counter = 0;
 330 
				int counter = 0;
325 
				ItemCriteriaPayout itemCriteriaPayout = createOfferRequest.getTargetSlabs().get(0)
 331 
				List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0)
326 
						.getItemCriteriaPayouts().get(0);
 332 
						.getItemCriteriaPayouts();
- 
 
 333 
				List<PayoutSlab> payoutSlabs = itemCriteriaPayouts.stream().flatMap(x->x.getPayoutSlabs().stream()).collect(Collectors.toList());
327 
				for (PayoutSlab payoutSlab : itemCriteriaPayout.getPayoutSlabs()) {
 334 
				for (PayoutSlab payoutSlab : payoutSlabs) {
328 
					payoutSlab.setOnwardsAmount(targets.get(counter));
 335 
					payoutSlab.setOnwardsAmount(targets.get(counter));
329 
					counter++;
 336 
					counter++;
330 
				}
 337 
				}
331 
			}
 338 
			}
332 
			this.addOfferService(createOfferRequest);
 339 
			this.addOfferService(createOfferRequest);
333 
		}
 340 
		}
- 
 
 341 
		cacheManager.getCache("allOffers").clear();
- 
 
 342 
 
334 
	}
 343 
	}
335 
 
 344 
 
336 
	private Map<CreateOfferRequest, List<PartnerTargetModel>> parseFromExcel(InputStream inputStream)
 345 
	private Map<CreateOfferRequest, List<PartnerTargetModel>> parseFromExcel(InputStream inputStream)
337 
			throws ProfitMandiBusinessException {
 346 
			throws ProfitMandiBusinessException {
338 
 
 347