WebSVN – SmartDukaan – Diff – /trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/SchemeController.java

 package com.spice.profitmandi.web.controller;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.InputStream;
+import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.LinkedHashSet;
 import java.util.List;
+import java.util.ListIterator;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import com.spice.profitmandi.common.model.SchemeItems;
 import com.spice.profitmandi.common.model.SchemeModel;
 import com.spice.profitmandi.common.util.ExcelUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.web.util.ResponseSender;
+import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.Offer;
 import com.spice.profitmandi.dao.entity.catalog.OfferPartner;
 import com.spice.profitmandi.dao.entity.catalog.Offermargin;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
+import com.spice.profitmandi.dao.entity.fofo.PrebookingListing;
 import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.enumuration.catalog.ItemCriteriaType;
 import com.spice.profitmandi.dao.model.AmountMarginModel;
 import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.CreateSchemeRequest;
 import com.spice.profitmandi.dao.model.ItemTypeParams;
 import com.spice.profitmandi.dao.model.SimpleItemType;
+import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferMarginRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferPartnerRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.RoleRepository;
+import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 	@Autowired
 	private OfferPartnerRepository offerPartnerRepository;
 	@Autowired
+	private ItemRepository itemRepository;
+	@Autowired
 	private Gson gson;
 	@Autowired
 	private RetailerService retailerService;
 	@Autowired
 	private Mongo mongoClient;
+	@Autowired
+	private PartnerTypeChangeService partnerTypeChangeService;
 	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
 	public String createScheme(HttpServletRequest request, Model model) {
 		// Map<Integer, String> itemIdItemDescriptionMap =
 		// inventoryService.getAllItemIdItemDescriptionMap();
 		// model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
 		Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(fofoIds);
 		model.addAttribute("customRetailersMap", customRetailersMap);
 		model.addAttribute("itemCriteriaType", ItemCriteriaType.values());
+		model.addAttribute("partnerType", PartnerType.values());
 		model.addAttribute("brands", brands);
 		return "scheme_offer";
+	}
 		offer.setAmountType(createOfferRequest.getAmountType());
 		offer.setStartDateTime(createOfferRequest.getStartDate());
 		offer.setEndDateTime(createOfferRequest.getEndDate());
 		offer.setPrice(createOfferRequest.getPrice());
 		offer.setCreatedTimestamp(LocalDateTime.now());
+		offer.setCriteria(createOfferRequest.getCriteria());
+		offer.setPartnerType(createOfferRequest.getPartnerType());
 		if (createOfferRequest.getItemCriteria().equals(ItemCriteriaType.Item_Model)) {
 			ItemTypeParams itemTypeParams = new ItemTypeParams();
 			itemTypeParams.setCatalogId(createOfferRequest.getCatalogIds());
 			SimpleItemType sit = new SimpleItemType(itemTypeParams);
 			sit.setItemTypeParams(itemTypeParams);
 			offer.setItemParam(gson.toJson(itemTypeParams));
+		}
 		offerRepository.persist(offer);
+		if (createOfferRequest.getFofoIds().isEmpty()) {
+			List<Integer> fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())
+					.collect(Collectors.toList());
+			for (Integer fofoId : fofoIds) {
+				PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoId,
+						offer.getStartDateTime().toLocalDate());
+				if (offer.getPartnerType().equals(partnerType)) {
+					LOGGER.info("partnerType" + partnerType);
+					LOGGER.info("fofoId" + fofoId);
+					OfferPartner op = new OfferPartner();
+					op.setFofoId(fofoId);
+					op.setOfferId(offer.getId());
+					offerPartnerRepository.persist(op);
+				}
+			}
+		}
+		else {
-		for (Integer fofoId : createOfferRequest.getFofoIds()) {
+			for (Integer fofoId : createOfferRequest.getFofoIds()) {
-			OfferPartner op = new OfferPartner();
+				OfferPartner op = new OfferPartner();
-			op.setFofoId(fofoId);
+				op.setFofoId(fofoId);
-			op.setOfferId(offer.getId());
+				op.setOfferId(offer.getId());
-			offerPartnerRepository.persist(op);
+				offerPartnerRepository.persist(op);
+			}
+		}
 		for (AmountMarginModel amm : createOfferRequest.getAmountOffer()) {
 			Offermargin om = new Offermargin();
 			om.setValue(amm.getValue());
 			om.setMargin(amm.getMargin());
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	@RequestMapping(value = "/getOffers", method = RequestMethod.GET)
+	public String createOffer(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
+		List<Offer> offers = offerRepository.selectAll(offset, limit);
+		Map<Integer, String> statusMap = this.offerStatus(offers);
+		model.addAttribute("offers", offers);
+		model.addAttribute("statusMap", statusMap);
+		return "offer_history";
+	}
+	private Map<Integer, String> offerStatus(List<Offer> offers) {
+		Map<Integer, String> statusMap = new HashMap<>();
+		for (Offer offer : offers) {
+			LocalDateTime curDate = LocalDateTime.now();
+			if (offer.getStartDateTime().isAfter(curDate)) {
+				statusMap.put(offer.getId(), "Schedule");
+			} else if (offer.getEndDateTime().isBefore(curDate)) {
+				statusMap.put(offer.getId(), "Closed");
+			} else if (offer.getStartDateTime().isBefore(curDate) && offer.getEndDateTime().isAfter(curDate)) {
+				statusMap.put(offer.getId(), "Running");
+			}
+		}
+		return statusMap;
+	}
+	@RequestMapping(value = "/getOfferMargin", method = RequestMethod.GET)
+	public String getOfferMargin(HttpServletRequest request,
+			@RequestParam(name = "offerId", defaultValue = "0") int offerId, Model model) throws Exception {
+		Offer offer = offerRepository.selectById(offerId);
+		List<Integer> fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())
+				.collect(Collectors.toList());
+		Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(fofoIds);
+		List<OfferPartner> offerPartners = offerPartnerRepository.selectByOfferId(offerId);
+		LOGGER.info("offerId" + offer.getId());
+		Map<Integer, Double> value = offerRepository.selectSumOfferByRetailer(offer.getStartDateTime(),
+				offer.getEndDateTime(), 0, offer, true);
+		LOGGER.info("value" + value);
+		List<Offermargin> offerMargin = offerMarginRepository.selectByOfferId(offerId);
+		Map<Integer, Double> partnerValueMap = new HashMap<>();
+		Map<Integer, List<Integer>> partnerMarginMap = new HashMap<Integer, List<Integer>>();
+		Map<Integer, Integer> shortageAmount = new HashMap<>();
+		for (OfferPartner op : offerPartners) {
+			LOGGER.info("offerPartneer" + op.getFofoId());
+			if (value.containsKey(op.getFofoId())) {
+				partnerValueMap.put(op.getFofoId(), value.get(op.getFofoId()));
+			} else {
+				value.put(op.getFofoId(), 0d);
+				partnerValueMap.put(op.getFofoId(), 0d);
+			}
+			List<Integer> valSetOne = new ArrayList<Integer>();
+			for (Offermargin om : offerMargin) {
+				if (value.get(op.getFofoId()) <= om.getValue()) {
+					LOGGER.info("om1" + om.getMargin());
+					shortageAmount.put(op.getFofoId(), om.getValue() - value.get(op.getFofoId()).intValue());
+					valSetOne.add(om.getMargin());
+					partnerMarginMap.put(op.getFofoId(), valSetOne);
+					break;
+				} else {
+					LOGGER.info("om2" + om.getMargin());
+					valSetOne.add(om.getMargin());
+					int shortage = om.getValue() - value.get(op.getFofoId()).intValue();
+					if (shortage < 0) {
+						shortageAmount.put(op.getFofoId(), 0);
+					}
+					partnerMarginMap.put(op.getFofoId(), valSetOne);
+				}
+			}
+		}
+		LOGGER.info("partnerMarginMap" + partnerMarginMap);
+		LOGGER.info("partnerValueMap" + partnerValueMap);
+		LOGGER.info("shortageAmount" + shortageAmount);
+		ItemTypeParams scp = gson.fromJson(offer.getItemParam(), ItemTypeParams.class);
+		if (offer.getItemCriteria().equals(ItemCriteriaType.Multiple_Brand)) {
+			List<String> brands = scp.getBrands();
+			model.addAttribute("brands", brands);
+		}
+		if (offer.getItemCriteria().equals(ItemCriteriaType.Item_Model)) {
+			List<Integer> catalogIds = scp.getCatalogId();
+			List<Item> newList = new ArrayList<>();
+			Set<Integer> catalogId = new HashSet<>();
+			List<Item> items = itemRepository.selectAllByCatalogIds(catalogIds.stream().collect(Collectors.toSet()));
+			for (Item item : items) {
+				if (catalogId.add(item.getCatalogItemId())) {
+					newList.add(item);
+				}
+			}
+			model.addAttribute("items", newList);
+		}
+		model.addAttribute("partnerMarginMap", partnerMarginMap);
+		model.addAttribute("partnerValueMap", partnerValueMap);
+		model.addAttribute("customRetailersMap", customRetailersMap);
+		model.addAttribute("offerMargin", offerMargin);
+		model.addAttribute("offer", offer);
+		model.addAttribute("shortageAmount", shortageAmount);
+		return "offer_margin_detail";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/SchemeController.java – Rev 26588 → 26674