WebSVN – SmartDukaan – Diff – //trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/offers/OfferServiceImpl.java

 package com.spice.profitmandi.service.offers;
-import java.io.FileInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.time.LocalDate;
 import java.time.YearMonth;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.Iterator;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 import org.apache.poi.ss.usermodel.Row.MissingCellPolicy;
 import org.apache.poi.xssf.usermodel.XSSFRow;
 import org.apache.poi.xssf.usermodel.XSSFSheet;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Component;
+import com.google.common.collect.Lists;
 import com.google.gson.Gson;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.PartnerTargetModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.dao.entity.catalog.ItemCriteria;
 import com.spice.profitmandi.dao.entity.catalog.Offer;
+import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.catalog.TargetSlab;
+import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.OfferSchemeType;
 import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.ItemCriteriaPayout;
 import com.spice.profitmandi.dao.repository.catalog.ItemCriteriaRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferTargetSlabRepository;
+import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.service.user.RetailerService;
 @Component
 public class OfferServiceImpl implements OfferService {
 	@Autowired
 	private ItemRepository itemRepository;
 	@Autowired
+	private TagListingRepository tagListingRepository;
+	@Autowired
 	private OfferTargetSlabRepository targetSlabRepository;
 	private static final Logger LOGGER = LogManager.getLogger(OfferServiceImpl.class);
 	@Override
 		createOfferRequest.setId(offer.getId());
+	}
 	@Override
 	public List<CreateOfferRequest> getPublishedOffers(int fofoId, YearMonth yearMonth) {
-		List<Offer> publishedOffers = offerRepository
-				.selectAllPublishedMapByPartner(yearMonth).get(fofoId);
+		List<Offer> publishedOffers = offerRepository.selectAllPublishedMapByPartner(yearMonth).get(fofoId);
 		List<CreateOfferRequest> createOfferRequests = new ArrayList<>();
 		if (publishedOffers != null) {
 			for (Offer offer : publishedOffers) {
-				List<com.spice.profitmandi.dao.model.TargetSlab> targetSlabs = targetSlabRepository
-						.getByOfferId(offer.getId());
 				CreateOfferRequest createOfferRequest = this.getCreateOfferRequest(offer);
-				createOfferRequest.getItemCriteria();
-				createOfferRequest.setTargetSlabs(targetSlabs);
 				createOfferRequests.add(createOfferRequest);
+				setCriteriaPayoutAchieved(fofoId, createOfferRequest);
+			}
-			for (CreateOfferRequest createOfferRequest : createOfferRequests) {
-				if (createOfferRequest.getSchemeType().equals(OfferSchemeType.SELLIN)) {
-				} else {
+		}
-					long amount = offerRepository.getPartnerWiseSalesSum(createOfferRequest).get(fofoId) == null ? 0
-							: offerRepository.getPartnerWiseSalesSum(createOfferRequest).get(fofoId);
+		return createOfferRequests;
+	}
-					com.spice.profitmandi.dao.model.TargetSlab currentSlab = createOfferRequest.getTargetSlabs()
+	private void setCriteriaPayoutAchieved(int fofoId, CreateOfferRequest createOfferRequest) {
-							.stream().filter(x -> x.getOnwardsAmount() <= amount)
+		Map<Integer, Long> criteriaTransactionMap = null;
+		if (createOfferRequest.getSchemeType().equals(OfferSchemeType.SELLIN)) {
+			criteriaTransactionMap = offerRepository.getPartnerWisePurchaseSum(createOfferRequest).get(fofoId);
+		} else {
+			criteriaTransactionMap = offerRepository.getPartnerWiseSalesSum(createOfferRequest).get(fofoId);
+		}
-							.max(Comparator.comparing(x -> x.getOnwardsAmount())).orElse(null);
+		LOGGER.info("I am here ------- {}", createOfferRequest.getId());
+		List<com.spice.profitmandi.dao.model.ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest
+				.getTargetSlabs().get(0).getItemCriteriaPayouts();
+		for (com.spice.profitmandi.dao.model.ItemCriteriaPayout itemCriteriaPayout : itemCriteriaPayouts) {
+			itemCriteriaPayout.setNextSlab(null);
+			LOGGER.info("I am here --- {}", itemCriteriaPayout.getPayoutSlabs());
+			long saleAmount = 0;
+			if (criteriaTransactionMap != null
+					&& criteriaTransactionMap.containsKey(itemCriteriaPayout.getItemCriteria().getId())) {
+				saleAmount = criteriaTransactionMap.get(itemCriteriaPayout.getItemCriteria().getId());
+			}
+			itemCriteriaPayout.setAchievedValue(saleAmount);
-					com.spice.profitmandi.dao.model.TargetSlab nextSlab = createOfferRequest.getTargetSlabs().stream()
+			List<com.spice.profitmandi.service.offers.PayoutSlab> payoutSlabs = itemCriteriaPayout.getPayoutSlabs();
+			for (int i = 0; i < payoutSlabs.size(); i++) {
+				com.spice.profitmandi.service.offers.PayoutSlab beginSlab = payoutSlabs.get(i);
+				com.spice.profitmandi.service.offers.PayoutSlab endSlab = null;
+				if (payoutSlabs.size() - 1 > i) {
+					endSlab = payoutSlabs.get(i + 1);
+				}
-							.filter(x -> x.getOnwardsAmount() > amount)
+				if (beginSlab.getOnwardsAmount() > saleAmount) {
-							.min(Comparator.comparing(x -> x.getOnwardsAmount())).orElse(null);
+					itemCriteriaPayout.setShortValue(beginSlab.getOnwardsAmount() - saleAmount);
-					createOfferRequest.setNextTargetSlab(nextSlab);
+					itemCriteriaPayout.setNextSlab(beginSlab);
-					if (nextSlab != null) {
+					LOGGER.info("I am here");
-						createOfferRequest
+					break;
-								.setNextTarget(targets.get(createOfferRequest.getTargetSlabs().indexOf(nextSlab)));
-					}
+				}
+				if (endSlab != null) {
+					if (beginSlab.getOnwardsAmount() <= saleAmount && endSlab.getOnwardsAmount() > saleAmount) {
-					createOfferRequest.setCurrentTargetSlab(currentSlab);
+						itemCriteriaPayout.setCurrentSlab(beginSlab);
-					if (currentSlab != null) {
+						beginSlab.setSelected(true);
-						createOfferRequest.setCurrentTarget(
+						itemCriteriaPayout.setNextSlab(endSlab);
-								targets.get(createOfferRequest.getTargetSlabs().indexOf(currentSlab)));
+						itemCriteriaPayout.setShortValue(endSlab.getOnwardsAmount() - saleAmount);
+						LOGGER.info("I am here");
+						break;
+					}
+					// Last loop
+				} else {
+					beginSlab.setSelected(true);
-					createOfferRequest.setEligibleSale((int) amount);
+					itemCriteriaPayout.setCurrentSlab(beginSlab);
+					LOGGER.info("I am here");
+				}
+			}
+			LOGGER.info("I am here --- {}", itemCriteriaPayout);
+		}
-		return createOfferRequests;
+	}
 	@Override
+	@Cacheable(value = "allOffers", cacheManager = "thirtyMinsTimeOutCacheManager")
-	public List<CreateOfferRequest> getAllOffers(YearMonth yearMonth) {
+	public Map<Integer, CreateOfferRequest> getAllOffers(YearMonth yearMonth) {
 		List<Offer> allOffers = offerRepository.selectAll(yearMonth, false);
 		List<CreateOfferRequest> createOfferRequests = new ArrayList<>();
 		for (Offer offer : allOffers) {
 			CreateOfferRequest createOfferRequest = this.getCreateOfferRequest(offer);
 			createOfferRequests.add(createOfferRequest);
+		}
-		return createOfferRequests;
+		return createOfferRequests.stream().collect(Collectors.toMap(CreateOfferRequest::getId, x -> x));
+	}
 	@Override
+	@Cacheable(value = "partnerOffers", cacheManager = "thirtyMinsTimeOutCacheManager")
-	public CreateOfferRequest getOffer(int offerId) {
+	public CreateOfferRequest getOffer(int fofoId, int offerId) {
 		Offer offer = offerRepository.selectById(offerId);
 		CreateOfferRequest createOfferRequest = this.getCreateOfferRequest(offer);
+		if (fofoId > 0) {
+			this.setCriteriaPayoutAchieved(fofoId, createOfferRequest);
+		}
 		return createOfferRequest;
+	}
 	private CreateOfferRequest getCreateOfferRequest(Offer fromOffer) {
 		CreateOfferRequest createOfferRequest = new CreateOfferRequest();
 		List<com.spice.profitmandi.dao.model.TargetSlab> targetSlabs = targetSlabRepository
 				.getByOfferId(fromOffer.getId());
 		createOfferRequest.setPartnerCriteriaString(
 				retailerService.getPartnerCriteriaString(createOfferRequest.getPartnerCriteria()));
 		createOfferRequest.setTargetSlabs(targetSlabs);
+		for (com.spice.profitmandi.dao.model.ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs()
+				.get(0).getItemCriteriaPayouts()) {
-		LOGGER.info("createOfferRequest {}", createOfferRequest);
+			itemCriteriaPayout.setNextSlab(itemCriteriaPayout.getPayoutSlabs().get(0));
+		}
 		return createOfferRequest;
+	}
 	private void createTargetSlabs(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
+			}
+		}
 		return createOfferRequests;
+	}
 	@Override
 	public void createOffers(InputStream fileInputStream) throws Exception {
 		Map<CreateOfferRequest, List<PartnerTargetModel>> offerPartnerTargetMap = this.parseFromExcel(fileInputStream);
-		for(Map.Entry<CreateOfferRequest, List<PartnerTargetModel>> partnerTargetEntry: offerPartnerTargetMap.entrySet()) {
+		for (Map.Entry<CreateOfferRequest, List<PartnerTargetModel>> partnerTargetEntry : offerPartnerTargetMap
+				.entrySet()) {
 			CreateOfferRequest createOfferRequest = partnerTargetEntry.getKey();
-			Map<List<Integer>, List<Integer>> targetPartnerMap = partnerTargetEntry.getValue().stream().collect(Collectors.groupingBy(PartnerTargetModel::getTargets, Collectors.mapping(PartnerTargetModel::getFofoId, Collectors.toList())));
+			Map<List<Integer>, List<Integer>> targetPartnerMap = partnerTargetEntry.getValue().stream()
+					.collect(Collectors.groupingBy(PartnerTargetModel::getTargets,
+							Collectors.mapping(PartnerTargetModel::getFofoId, Collectors.toList())));
-					for (Map.Entry<List<Integer>, List<Integer>> targetPartnersEntry : targetPartnerMap.entrySet()) {
+			for (Map.Entry<List<Integer>, List<Integer>> targetPartnersEntry : targetPartnerMap.entrySet()) {
-						List<Integer> fofoIds = createOfferRequest.getPartnerCriteria().getFofoIds();
+				List<Integer> fofoIds = createOfferRequest.getPartnerCriteria().getFofoIds();
-						List<Integer> filterFofoIds = targetPartnersEntry.getValue().stream().filter(x->!fofoIds.contains(x)).collect(Collectors.toList());
+				List<Integer> filterFofoIds = targetPartnersEntry.getValue().stream().filter(x -> !fofoIds.contains(x))
+						.collect(Collectors.toList());
-						List<Integer> targets = targetPartnersEntry.getKey();
+				List<Integer> targets = targetPartnersEntry.getKey();
-						createOfferRequest.getPartnerCriteria().setFofoIds(filterFofoIds);
+				createOfferRequest.getPartnerCriteria().setFofoIds(filterFofoIds);
-						int counter = 0;
+				int counter = 0;
-						for (com.spice.profitmandi.dao.model.TargetSlab targetSlab : createOfferRequest.getTargetSlabs()) {
+				ItemCriteriaPayout itemCriteriaPayout = createOfferRequest.getTargetSlabs().get(0)
+						.getItemCriteriaPayouts().get(0);
+				for (PayoutSlab payoutSlab : itemCriteriaPayout.getPayoutSlabs()) {
-							targetSlab.setOnwardsAmount(targets.get(counter));
+					payoutSlab.setOnwardsAmount(targets.get(counter));
-							counter++;
+					counter++;
-						}
+				}
+			}
-						this.addOfferService(createOfferRequest);
+			this.addOfferService(createOfferRequest);
-					}
+		}
+	}
-	private Map<CreateOfferRequest, List<PartnerTargetModel>> parseFromExcel(InputStream inputStream) throws ProfitMandiBusinessException {
+	private Map<CreateOfferRequest, List<PartnerTargetModel>> parseFromExcel(InputStream inputStream)
+			throws ProfitMandiBusinessException {
-		Map<CreateOfferRequest, List<PartnerTargetModel>> offerPartnerTargetMap =  new HashMap<>();
+		Map<CreateOfferRequest, List<PartnerTargetModel>> offerPartnerTargetMap = new HashMap<>();
 		XSSFWorkbook myWorkBook = null;
 		try {
 			myWorkBook = new XSSFWorkbook(inputStream);
 			myWorkBook.setMissingCellPolicy(MissingCellPolicy.RETURN_BLANK_AS_NULL);
-			for(int i=0; i< myWorkBook.getNumberOfSheets();i++) {
+			for (int i = 0; i < myWorkBook.getNumberOfSheets(); i++) {
 				XSSFSheet mySheet = myWorkBook.getSheetAt(i);
 				int offerId = Integer.parseInt(mySheet.getSheetName());
-				CreateOfferRequest existingOffer = this.getOffer(offerId);
+				CreateOfferRequest existingOffer = this.getOffer(0, offerId);
 				List<PartnerTargetModel> partnerTargetModels = new ArrayList<>();
 				offerPartnerTargetMap.put(existingOffer, partnerTargetModels);
 				this.printIterator(mySheet);
 				LOGGER.info("rowCellNum {}", mySheet.getLastRowNum());
 				for (int rowNumber = 1; rowNumber <= mySheet.getLastRowNum(); rowNumber++) {
 					partnerTargetModel.setTargets(targets);
 					partnerTargetModels.add(partnerTargetModel);
+				}
+			}
 			myWorkBook.close();
-		} catch ( ProfitMandiBusinessException pbse) {
+		} catch (ProfitMandiBusinessException pbse) {
 			throw pbse;
 		} catch (IOException ioException) {
 			ioException.printStackTrace();
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.EXCEL_FILE, ioException.getMessage(),
 					"EXL_VE_1000");
+			}
+		}
 		LOGGER.info("offerPartnerTargetMap {}", offerPartnerTargetMap);
 		return offerPartnerTargetMap;
+	}
-	private void printIterator (XSSFSheet sheet) {
+	private void printIterator(XSSFSheet sheet) {
-		 Iterator<Row> rowIterator = sheet.iterator();
+		Iterator<Row> rowIterator = sheet.iterator();
-         while (rowIterator.hasNext())
+		while (rowIterator.hasNext()) {
-         {
-             Row row = rowIterator.next();
+			Row row = rowIterator.next();
-             //For each row, iterate through all the columns
+			// For each row, iterate through all the columns
-             Iterator<Cell> cellIterator = row.cellIterator();
+			Iterator<Cell> cellIterator = row.cellIterator();
-             while (cellIterator.hasNext())
+			while (cellIterator.hasNext()) {
-             {
-                 Cell cell = cellIterator.next();
+				Cell cell = cellIterator.next();
-                 //Check the cell type and format accordingly
+				// Check the cell type and format accordingly
-                 switch (cell.getCellType())
+				switch (cell.getCellType()) {
-                 {
-                     case Cell.CELL_TYPE_NUMERIC:
+				case Cell.CELL_TYPE_NUMERIC:
-                         System.out.print(cell.getNumericCellValue() + "t");
+					System.out.print(cell.getNumericCellValue() + "t");
-                         break;
+					break;
-                     case Cell.CELL_TYPE_STRING:
+				case Cell.CELL_TYPE_STRING:
-                         System.out.print(cell.getStringCellValue() + "t");
+					System.out.print(cell.getStringCellValue() + "t");
-                         break;
+					break;
-                 }
+				}
-             }
+			}
-             System.out.println("");
+			System.out.println("");
+		}
+	}
-         }
+	@Override
+	public Map<Integer, CreateOfferRequest> getPublishedOffers(LocalDate date, int fofoId, String brand) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+	@Override
+	@Cacheable(value = "slabPayoutMap", cacheManager = "thirtyMinsTimeOutCacheManager")
+	public Map<Integer, Map<Integer, Long>> getSlabPayoutMap(CreateOfferRequest createOfferRequest) {
+		Map<Integer, Map<Integer, Long>> itemSlabPayoutMap = new HashMap<>();
+		List<com.spice.profitmandi.dao.model.TargetSlab> targetSlabs = createOfferRequest.getTargetSlabs();
+		com.spice.profitmandi.dao.model.TargetSlab targetSlab = targetSlabs.get(0);
+		List<ItemCriteriaPayout> payouts = targetSlab.getItemCriteriaPayouts();
+		for (ItemCriteriaPayout itemCriteriaPayout : payouts) {
+			com.spice.profitmandi.service.offers.ItemCriteria itemCriteria = itemCriteriaPayout.getItemCriteria();
+			List<Integer> itemIds = itemRepository.getItems(itemCriteria);
+			for (PayoutSlab payoutSlab : Lists.reverse(itemCriteriaPayout.getPayoutSlabs())) {
+				if (itemCriteriaPayout.getAmountType().equals(AmountType.FIXED)) {
+					for (Integer itemId : itemIds) {
+						if (!itemSlabPayoutMap.containsKey(itemId)) {
+							itemSlabPayoutMap.put(itemId, new LinkedHashMap<>());
+						}
+						itemSlabPayoutMap.get(itemId).put(payoutSlab.getOnwardsAmount(),
+								(long) payoutSlab.getPayoutAmount());
+					}
+				} else if (itemCriteriaPayout.getAmountType().equals(AmountType.SLAB_FIXED)) {
+					for (Integer itemId : itemIds) {
+						if (!itemSlabPayoutMap.containsKey(itemId)) {
+							itemSlabPayoutMap.put(itemId, new LinkedHashMap<>());
+						}
+						itemSlabPayoutMap.get(itemId).put(payoutSlab.getOnwardsAmount(),
+								(long) (payoutSlab.getPayoutAmount() / payoutSlab.getOnwardsAmount()));
+					}
+				} else if (itemCriteriaPayout.getAmountType().equals(AmountType.PERCENTAGE)) {
+					List<TagListing> tagListings = tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(itemIds),
+							null);
+					for (TagListing tagListing : tagListings) {
+						float taxableSellingPrice = tagListing.getSellingPrice() / (1 + 18f / 100);
+						if (!itemSlabPayoutMap.containsKey(tagListing.getItemId())) {
+							itemSlabPayoutMap.put(tagListing.getItemId(), new LinkedHashMap<>());
+						}
+						itemSlabPayoutMap.get(tagListing.getItemId()).put(payoutSlab.getOnwardsAmount(),
+								(long) (taxableSellingPrice * payoutSlab.getPayoutAmount() / 100));
+					}
+				}
+			}
+		}
+		return itemSlabPayoutMap;
+	}
+}

Subversion Repositories SmartDukaan

(root)//trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/offers/OfferServiceImpl.java – Rev 29686 → 29783