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

 package com.spice.profitmandi.web.controller;
 import java.io.Serializable;
+import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Map.Entry;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
+import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.ImeiDropSummaryModel;
 import com.spice.profitmandi.common.model.ItemDescriptionModel;
 import com.spice.profitmandi.common.model.PriceDropImeisModel;
 import com.spice.profitmandi.common.model.PriceDropModel;
 import com.spice.profitmandi.common.model.PriceDropProcessModel;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
+import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.inventory.ItemPricingHistory;
 import com.spice.profitmandi.dao.entity.inventory.VendorItemPricing;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
+import com.spice.profitmandi.dao.model.PriceCircularModel;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
+import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.dao.repository.inventory.ItemPricingHistoryRepository;
 import com.spice.profitmandi.dao.repository.inventory.VendorItemPricingRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropIMEIRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.transaction.TransactionService;
+import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
+import com.spice.profitmandi.web.model.LoginDetails;
+import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class PriceDropController {
 	ReporticoService reporticoService;
 	@Autowired
 	LineItemImeisRepository lineItemImeisRepository;
+	@Autowired
+	private Mongo mongoClient;
+	@Autowired
+	private CookiesProcessor cookiesProcessor;
+	@Autowired
+	private PartnerTypeChangeService partnerTypeChangeService;
+	@Autowired
+	private RetailerService retailerService;
 	@RequestMapping(value = "/getItemDescription", method = RequestMethod.GET)
 	public String getItemDescription(HttpServletRequest request, Model model) throws Throwable {
 		List<PriceDrop> priceDrops = priceDropRepository.selectAll();
 		Set<Integer> catalogIds = priceDrops.stream().map(x -> x.getCatalogItemId()).collect(Collectors.toSet());
 		List<Item> items = itemRepository.selectAllByCatalogIds(catalogIds);
 		model.addAttribute("response", mvcResponseSender.createResponseString(pm));
 		return "response";
+	}
 	@RequestMapping(value = "/item", method = RequestMethod.GET)
-	public String getItemPricing(HttpServletRequest request, Model model, @RequestParam String query,@RequestParam boolean anyColor) throws Throwable {
+	public String getItemPricing(HttpServletRequest request, Model model, @RequestParam String query,
+			@RequestParam boolean anyColor) throws Throwable {
 		String query1 = query.toLowerCase();
-		List<ItemDescriptionModel> partnersItemDescription = inventoryService.getAllPartnerItemStringDescription(anyColor)
+		List<ItemDescriptionModel> partnersItemDescription = inventoryService
+				.getAllPartnerItemStringDescription(anyColor).parallelStream()
-				.parallelStream().filter(x -> x.getItemDescription().toLowerCase().matches(".*?" + query1 + ".*?"))
+				.filter(x -> x.getItemDescription().toLowerCase().matches(".*?" + query1 + ".*?"))
 				.collect(Collectors.toList());
-		LOGGER.info("partnersItemDescription"+partnersItemDescription);
+		LOGGER.info("partnersItemDescription" + partnersItemDescription);
 		model.addAttribute("response", mvcResponseSender.createResponseString(partnersItemDescription));
 		return "response";
+	}
 	@RequestMapping(value = "/processPriceDrop", method = RequestMethod.POST)
 	public String processPriceDrop(HttpServletRequest request, @RequestBody PriceDropProcessModel priceDropProcessModel,
 			Model model) throws Exception {
 		PriceDrop priceDrop = priceDropRepository.selectById(priceDropProcessModel.getPriceDropId());
 		boolean response = false;
-		if(priceDrop.getPartnerPayout()==0) {
+		if (priceDrop.getPartnerPayout() == 0) {
 			priceDrop.setPartnerPayout(priceDropProcessModel.getPartnerPayout());
+		}
 		priceDrop.setProcessTimestamp(LocalDateTime.now());
 		priceDropRepository.persist(priceDrop);
 		priceDropService.processPriceDrop(priceDrop.getId(), priceDropProcessModel.isActivatedOnly());
-			response = true;
+		response = true;
 		model.addAttribute("response", mvcResponseSender.createResponseString(response));
 		return "response";
+	}
 	@RequestMapping(value = "/priceDrop", method = RequestMethod.POST)
 			return true;
+		}
 		return false;
+	}
+	@RequestMapping(value = "/priceCircular")
+	public String priceCircular(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
+		int fofoId = Utils.SYSTEM_PARTNER_ID;
+		Set<String> brands = mongoClient.getMongoBrands(fofoId, null, 3).stream().map(x -> (String) x.get("name"))
+				.collect(Collectors.toSet());
+		Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
+		Map<Integer, PartnerType> fofoIdPartnerTypeMap = new HashMap<>();
+		for (Entry<Integer, CustomRetailer> customRetailer : customRetailers.entrySet()) {
+			PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(customRetailer.getKey(), LocalDate.now());
+			fofoIdPartnerTypeMap.put(customRetailer.getKey(), partnerType);
+		}
+		Map<PartnerType, List<Integer>> partnerTypePartnersMap = fofoIdPartnerTypeMap.entrySet().stream().collect(
+				Collectors.groupingBy(x -> x.getValue(), Collectors.mapping(x -> x.getKey(), Collectors.toList())));
+		model.addAttribute("brands", brands);
+		return "price-circular";
+	}
+	@RequestMapping(value = "/partnerPriceCircular")
+	public String partnerPriceCircular(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
+		int fofoId = Utils.SYSTEM_PARTNER_ID;
+		Set<String> brands = mongoClient.getMongoBrands(fofoId, null, 3).stream().map(x -> (String) x.get("name"))
+				.collect(Collectors.toSet());
+		brands.addAll(mongoClient.getMongoBrands(fofoId, null, 6).stream().map(x -> (String) x.get("name"))
+				.collect(Collectors.toSet()));
+		model.addAttribute("brands", brands);
+		model.addAttribute("date", LocalDate.now());
+		return "partner-price-circular";
+	}
+	@RequestMapping(value = "/priceCircularByBrand")
+	public String priceCircularByBrand(HttpServletRequest request, @RequestParam String brand, Model model)
+			throws ProfitMandiBusinessException {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(), LocalDate.now());
+		List<PartnerType> partnerTypes = new ArrayList<>();
+		partnerTypes.add(partnerType);
+		partnerTypes.add(PartnerType.ALL);
+		List<PriceCircularModel> priceCircular = tagListingRepository.getPriceCircularByBrandAndType(partnerTypes,
+				brand, LocalDateTime.now(), LocalDateTime.now().plusDays(1).toLocalDate().atStartOfDay());
+		for (PriceCircularModel pc : priceCircular) {
+			Long totalScheme = pc.getBasePayout() + pc.getCashDiscount() + pc.getTertiaryPayout()
+					+ pc.getHygienePayout() + pc.getCategoryPayout() + pc.getInvestmentPayout() + pc.getModelSpecfic();
+			pc.setTotalScheme(totalScheme);
+			long netprice = pc.getSellingPrice() - pc.getTotalScheme();
+			pc.setNetPrice(netprice);
+			int mopdpdiff = pc.getMop() - pc.getSellingPrice();
+			pc.setMopdp(mopdpdiff);
+			pc.setNetPrice2((int) pc.getNetPrice() - pc.getMopdp());
+			long totalProfit = totalScheme + mopdpdiff;
+			double rouoff = totalProfit / (pc.getSellingPrice() / 1.18) * 100;
+			double roundOff = Math.round(rouoff * 100.0) / 100.0;
+			pc.setNetMargin(roundOff);
+		}
+		LOGGER.info("priceCircular" + priceCircular);
+		model.addAttribute("priceCircular", priceCircular);
+		return "price-circular-detail";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/PriceDropController.java – Rev 27618 → 28102