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

 import java.time.YearMonth;
 import java.time.ZoneOffset;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
+import com.spice.profitmandi.dao.entity.fofo.PurchaseReturnItem;
 import com.spice.profitmandi.dao.entity.inventory.ReporticoCacheTable;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.enumuration.catalog.ItemCriteriaType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
+		}
 		return String.valueOf(finalval);
+	}
+	/*
-	private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws Exception {
+	 * private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws
+	 * Exception { Map<String, BrandStockPrice> brandStockPricesMap =
-		Map<String, BrandStockPrice> brandStockPricesMap = inventoryService.getBrandWiseStockValue(fofoId);
+	 * inventoryService.getBrandWiseStockValue(fofoId);
+	 *
-		List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
+	 * List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
-		List<BrandStockPrice> brandStockPrices = new ArrayList<>();
+	 * List<BrandStockPrice> brandStockPrices = new ArrayList<>();
+	 *
-		mobileBrands.stream().forEach(x -> {
-			String brand = (String) x.get("name");
+	 * mobileBrands.stream().forEach(x -> { String brand = (String) x.get("name");
-			if (brandStockPricesMap.containsKey(brand)) {
+	 * if (brandStockPricesMap.containsKey(brand)) { BrandStockPrice brandStockPrice
-				BrandStockPrice brandStockPrice = brandStockPricesMap.get(brand);
+	 * = brandStockPricesMap.get(brand); brandStockPrice.setBrandUrl((String)
-				brandStockPrice.setBrandUrl((String) x.get("url"));
-				brandStockPrice.setRank(((Double) x.get("rank")).intValue());
+	 * x.get("url")); brandStockPrice.setRank(((Double) x.get("rank")).intValue());
-				brandStockPrices.add(brandStockPrice);
+	 * brandStockPrices.add(brandStockPrice); } });
-			}
+	 *
-		});
-		return brandStockPrices.stream().filter(x -> x.getTotalQty() > 0).sorted((x, y) -> x.getRank() - y.getRank())
+	 * return brandStockPrices.stream().filter(x -> x.getTotalQty() > 0).sorted((x,
-				.collect(Collectors.toList());
+	 * y) -> x.getRank() - y.getRank()) .collect(Collectors.toList()); }
-	}
+	 */
 	@RequestMapping(value = "/dashboard", method = RequestMethod.GET)
 	public String dashboard(HttpServletRequest request, Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		String email = loginDetails.getEmailId();
 						inventoryItemRepository.selectCountByActivatedNotSold(loginDetails.getFofoId()));
 				LocalDateTime curDate = LocalDate.now().atStartOfDay();
 				Map<Integer, Double> accesoriesmtdsale = fofoOrderRepository
 						.selectSumSaleGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(),
 								curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false));
-				LOGGER.info("accesoriesmtdsale" + accesoriesmtdsale);
 				Double accesoriesStock = currentInventorySnapshotRepository
 						.selectSumStockGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(),
 								Optional.of(false))
 						.get(loginDetails.getFofoId());
 				model.addAttribute("accesoriesStock", String.format("%.0f", accesoriesStock));
+				// model.addAttribute("brandStockPrices",
-				model.addAttribute("brandStockPrices", this.getBrandStockPrices(loginDetails.getFofoId()));
+				// this.getBrandStockPrices(loginDetails.getFofoId()));
 				model.addAttribute("salesMap", this.getSales(loginDetails.getFofoId()));
 				ChartModel cm = this.getBrandChart(loginDetails.getFofoId());
 				LOGGER.info("chartMap" + gson.toJson(cm));
 				model.addAttribute("chartMap", gson.toJson(cm));
-				// this.setInvestments
-				//
 				model.addAttribute("investments", this.getInvestments(loginDetails.getFofoId()));
 				model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(loginDetails.getFofoId(),
 , ProfitMandiConstants.CUTOFF_INVESTMENT));
-				// Hardcoded for valentine
-				// Hardcoded for valentine
 				List<Offer> offers = offerRepository.selectOfferByStatus(true);
 				if (!offers.isEmpty()) {
 					List<CreateOfferRequest> cors = new ArrayList<>();
 					for (Offer offer : offers) {
 			Map<Integer, PartnerDetailModel> warehousePartnerDetailMap = null;
 			ReporticoCacheTable rctSaholic = null;
 			ReporticoCacheTable rctPartneStat = null;
 			Map<Integer, WarehouseWiseStockModel> warehouseStockMap = new HashMap<>();
+			LinkedHashMap<Integer, WarehouseWiseStockModel> warehouseStockSortedMap = new LinkedHashMap<>();
 			Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
 			LinkedHashMap<Integer, String> wm = new LinkedHashMap<Integer, String>();
 			Map<String, BrandWisePartnerSaleModel> partnersBrandSaleMap = null;
 			List<BrandWisePartnerSaleModel> accessoriesBrandSales = null;
 			for (Map.Entry<Integer, String> entry : warehouseMap.entrySet()) {
 				wm.put(entry.getKey(), entry.getValue());
+			}
 			wm.put(0, "Total Values");
 			long stockValue = 0;
 			long stockQty = 0;
 			long pendingIndent = 0;
 			long tertiary = 0;
-			if (positions.size() > 0) {
-				if (positions.stream()
-						.filter(x -> x.getEscalationType().equals(EscalationType.L3)
-								|| x.getEscalationType().equals(EscalationType.L4)
-								|| x.getEscalationType().equals(EscalationType.L5))
-						.count() > 0) {
-					List<WarehouseWiseStockModel> warehouseStocks = saholicInventoryCISRepository
-							.selectGroupByWarehouse();
-					warehouseStockMap = warehouseStocks.stream()
-							.collect(Collectors.toMap(x -> x.getWarehouseId(), x -> x));
-					if (!warehouseStocks.isEmpty()) {
-						for (WarehouseWiseStockModel warehouseStock : warehouseStocks) {
-							stockValue += warehouseStock.getStockValue();
-							stockQty += warehouseStock.getStockQty();
-							pendingIndent += warehouseStock.getPendingIndent();
-							tertiary += warehouseStock.getTertiary();
-						}
-						WarehouseWiseStockModel ws = new WarehouseWiseStockModel();
-						ws.setStockQty(stockQty);
-						ws.setStockValue(stockValue);
-						ws.setPendingIndent(pendingIndent);
-						ws.setTertiary(tertiary);
-						ws.setWarehouseId(0);
-						warehouseStockMap.put(0, ws);
+			Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+			Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
+			LOGGER.info("fofoIds" + fofoIds);
+			if (fofoIds != null) {
+				Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository
+						.selectActivePartnersByRetailerIds(new ArrayList<>(fofoIds)).stream()
+						.collect(Collectors.groupingBy(FofoStore::getWarehouseId,
+								Collectors.mapping(FofoStore::getId, Collectors.toList())));
+				// warehouseStock
+				List<WarehouseWiseStockModel> warehouseStocks = saholicInventoryCISRepository
+						.selectGroupByWarehouse(new ArrayList<>(warehouseIdFofoIdMap.keySet()));
+				warehouseStockMap = warehouseStocks.stream().collect(Collectors.toMap(x -> x.getWarehouseId(), x -> x));
+				if (!warehouseStockMap.isEmpty()) {
+					for (Entry<Integer, WarehouseWiseStockModel> warehouseStock : warehouseStockMap.entrySet()) {
+						stockValue += warehouseStock.getValue().getStockValue();
+						stockQty += warehouseStock.getValue().getStockQty();
+						pendingIndent += warehouseStock.getValue().getPendingIndent();
+						tertiary += warehouseStock.getValue().getTertiary();
+					}
+					WarehouseWiseStockModel ws = new WarehouseWiseStockModel();
+					ws.setStockQty(stockQty);
+					ws.setStockValue(stockValue);
+					ws.setPendingIndent(pendingIndent);
+					ws.setTertiary(tertiary);
+					ws.setWarehouseId(0);
+					warehouseStockMap.put(0, ws);
+				}
-					warehousePartnerDetailMap = this.getWarehousePartnerDetail();
+				warehouseStockMap.entrySet().stream().sorted(Map.Entry.comparingByKey(Comparator.reverseOrder()))
+						.forEachOrdered(x -> warehouseStockSortedMap.put(x.getKey(), x.getValue()));
-					rctSaholic = reporticoCacheTableRepository.selectByTableName("SaholicInventoryCIS");
+				rctSaholic = reporticoCacheTableRepository.selectByTableName("SaholicInventoryCIS");
+				// warehouseStock
+				warehousePartnerDetailMap = this.getWarehousePartnerDetail(warehouseIdFofoIdMap);
-					rctPartneStat = reporticoCacheTableRepository.selectByTableName("partnerStat");
+				rctPartneStat = reporticoCacheTableRepository.selectByTableName("partnerStat");
-					partnersBrandSaleMap = fofoStoreRepository.selectGroupByBrandWarehousePartnerSale().stream()
+				partnersBrandSaleMap = fofoStoreRepository
+						.selectGroupByBrandWarehousePartnerSale(new ArrayList<>(fofoIds)).stream()
-							.collect(Collectors.toMap(x -> x.getBrand(), x -> x));
+						.collect(Collectors.toMap(x -> x.getBrand(), x -> x));
-					List<BrandWiseUnbilledActivateStockModel> unbilledActivatedStock = fofoStoreRepository
+				List<BrandWiseUnbilledActivateStockModel> unbilledActivatedStock = fofoStoreRepository
-							.selectUnbilledActivateStockGroupByBrand();
+						.selectUnbilledActivateStockGroupByBrand(new ArrayList<>(fofoIds));
-					for (BrandWiseUnbilledActivateStockModel un : unbilledActivatedStock) {
+				for (BrandWiseUnbilledActivateStockModel un : unbilledActivatedStock) {
-						BrandWisePartnerSaleModel bpt = partnersBrandSaleMap.get(un.getBrand());
+					BrandWisePartnerSaleModel bpt = partnersBrandSaleMap.get(un.getBrand());
-						if (bpt != null) {
+					if (bpt != null) {
-							bpt.setAmtd(un.getUnbilledMtd());
+						bpt.setAmtd(un.getUnbilledMtd());
-							bpt.setUamtdQty(un.getUnbilledMTDQty());
+						bpt.setUamtdQty(un.getUnbilledMTDQty());
-						} else {
+					} else {
-							bpt = new BrandWisePartnerSaleModel();
+						bpt = new BrandWisePartnerSaleModel();
-							bpt.setBrand(un.getBrand());
+						bpt.setBrand(un.getBrand());
-							bpt.setAmtd(un.getUnbilledMtd());
+						bpt.setAmtd(un.getUnbilledMtd());
-							bpt.setUamtdQty(un.getUnbilledMTDQty());
+						bpt.setUamtdQty(un.getUnbilledMTDQty());
-							bpt.setLms(0);
+						bpt.setLms(0);
-							bpt.setLmtd(0);
+						bpt.setLmtd(0);
-							bpt.setMtd(0);
+						bpt.setMtd(0);
-							bpt.setMtdQty(0);
+						bpt.setMtdQty(0);
-							bpt.setLmtd(0);
+						bpt.setLmtd(0);
-							bpt.setLmtdQty(0);
+						bpt.setLmtdQty(0);
-							partnersBrandSaleMap.put(un.getBrand(), bpt);
+						partnersBrandSaleMap.put(un.getBrand(), bpt);
-						}
+					}
-					accessoriesBrandSales = fofoStoreRepository.selectGroupByBrandAccesoriesWarehousePartnerSale();
+				}
+				accessoriesBrandSales = fofoStoreRepository
+						.selectGroupByBrandAccesoriesWarehousePartnerSale(new ArrayList<>(fofoIds));
+			}
 			if (Arrays.asList("amit.gupta@shop2020.in", "tejbeer.kaur@shop2020.in", "manish.tiwari@smartdukaan.com")
-					.contains(email)) {
+					.contains(email))
+			{
 				menus = menuRepository.selectAll();
 			} else if (positions.size() > 0) {
 				if (positions.stream().filter(x -> x.getEscalationType().equals(EscalationType.L5)).count() > 0) {
 					menus = menuRepository.selectAll();
 				} else {
 			model.addAttribute("rctPartneStat", rctPartneStat);
 			model.addAttribute("reporticoDate", rctSaholic);
 			model.addAttribute("warehousePartnerDetailMap", warehousePartnerDetailMap);
 			model.addAttribute("warehouseMap", wm);
-			model.addAttribute("warehouseStockMap", warehouseStockMap);
+			model.addAttribute("warehouseStockMap", warehouseStockSortedMap);
 			model.addAttribute("brandSalesMap", partnersBrandSaleMap);
 			model.addAttribute("accessoriesBrandSales", accessoriesBrandSales);
 		} catch (ProfitMandiBusinessException e) {
 		LOGGER.info("menu" + menuList);
 		model.addAttribute("menu", menuList);
 		return "admin";
+	}
-	/*
-	 * @RequestMapping(value = "/getL1AuthUser", method = RequestMethod.GET) public
-	 * String L1AuthUsersDetail(HttpServletRequest request, Model
-	 * model, @RequestParam int authId) throws Exception {
-	 *
-	 * Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();
-	 *
-	 * LocalDateTime curDate = LocalDate.now().atStartOfDay(); Map<Integer, Double>
-	 * lmtdSale = fofoOrderItemRepository.selectSumAmountGroupByRetailer(
-	 * curDate.withDayOfMonth(1).minusMonths(1),
-	 * curDate.with(LocalTime.MAX).minusMonths(1), 0, false); Map<Integer, Double>
-	 * mtdSale =
-	 * fofoOrderItemRepository.selectSumAmountGroupByRetailer(curDate.withDayOfMonth
-	 * (1), curDate.with(LocalTime.MAX), 0, false); Map<Integer, List<Integer>>
-	 * L2L1Mapping = csService.getL1L2Mapping();
-	 *
-	 * LOGGER.info("L2L1Mapping" + L2L1Mapping); List<Integer> l1authIds =
-	 * L2L1Mapping.get(authId);
-	 *
-	 * Map<Integer, Object> authIdAndallValues = new LinkedHashMap<>(); Map<Integer,
-	 * Object> authIdAndAuthUserMap = new LinkedHashMap<>();
-	 *
-	 * Map<Integer, Long> ticketMap =
-	 * ticketRepository.selectAllNotClosedTicketsGroupByRetailer(); for (Integer
-	 * l1AuthId : l1authIds) {
-	 *
-	 * double totallmtdAmount = 0; double totalmtdAmount = 0; int totalTicketCount =
-	 * 0; float totalTodayInvestment = 0; float totalStockInInvestment = 0; double
-	 * currentMonthRatingAllPartners = 0; Map<Integer, Long> leadCount =
-	 * leadRepository.selectByAssignAuthIdAndStatus(l1AuthId, LeadStatus.followUp)
-	 * .stream().collect(Collectors.groupingBy(Lead::getAssignTo,
-	 * Collectors.counting()));
-	 *
-	 * AuthUser authUser = authRepository.selectById(l1AuthId);
-	 *
-	 * authIdAndAuthUserMap.put(l1AuthId, authUser);
-	 *
-	 * List<Integer> fofoIds = pp.get(l1AuthId);
-	 *
-	 * Map<Integer, PartnerDailyInvestment> partnerInvestentMap =
-	 * partnerInvestmentService .getInvestment(fofoIds,
-	 * 0).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
-	 *
-	 * for (Integer fId : fofoIds) { try { PartnerDailyInvestment investment =
-	 * partnerInvestentMap.get(fId); totalTodayInvestment +=
-	 * investment.getTotalInvestment(); totalStockInInvestment +=
-	 * investment.getInStockAmount(); } catch (Exception e) { }
-	 *
-	 * double currentMonthRating = hygieneDataRepository.selectRatingAvg(fId,
-	 * curDate.withDayOfMonth(1).minusMonths(1),
-	 * curDate.plusMonths(1).withDayOfMonth(1));
-	 *
-	 * currentMonthRatingAllPartners += currentMonthRating;
-	 *
-	 * fofoIds.size();
-	 *
-	 * Double lmtdAmount = lmtdSale.get(fId); Double mtdAmount = mtdSale.get(fId);
-	 * Long ticketCount = ticketMap.get(fId); if (ticketCount != null) {
-	 * totalTicketCount += ticketCount; }
-	 *
-	 * if (lmtdAmount != null) { totallmtdAmount += lmtdAmount; }
-	 *
-	 * if (mtdAmount != null) { totalmtdAmount += mtdAmount; }
-	 *
-	 * } LOGGER.info("currentMonthRatingAllPartners" +
-	 * currentMonthRatingAllPartners); LOGGER.info("size" + fofoIds.size()); double
-	 * totalHygieneRating = currentMonthRatingAllPartners / fofoIds.size();
-	 *
-	 * LOGGER.info("totalHygieneRating" + totalHygieneRating);
-	 *
-	 * PartnerDetailModel pm = new PartnerDetailModel();
-	 * pm.setLmtd(totallmtdAmount); pm.setMtd(totalmtdAmount); if
-	 * (leadCount.get(l1AuthId) != null) {
-	 * pm.setLeads(leadCount.get(l1AuthId).intValue()); } else { pm.setLeads(0); }
-	 *
-	 * pm.setInvestment(totalTodayInvestment);
-	 * pm.setStockInInvestment(totalStockInInvestment);
-	 * pm.setTicket(totalTicketCount); pm.setHygiene((double)
-	 * Math.round(totalHygieneRating)); authIdAndallValues.put(l1AuthId, pm);
-	 *
-	 * } model.addAttribute("authIdAndallValues", authIdAndallValues);
-	 * model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
-	 * LOGGER.info("authIdAndallValues" + authIdAndallValues);
-	 *
-	 * return "auth_user_detail"; }
-	 */
 	@RequestMapping(value = "/getAuthUserPartners", method = RequestMethod.GET)
 	public String AuthUserPartnersDetail(HttpServletRequest request, Model model, @RequestParam int authId)
 			throws Exception {
 		Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();
+	}
 	@RequestMapping(value = "/getWarehousePartners", method = RequestMethod.GET)
 	public String warehousePartnersDetail(HttpServletRequest request, Model model, @RequestParam int warehouseId)
 			throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		Set<Integer> authfofoIds = storeGuyMap.get(email);
+		Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository
+				.selectActivePartnersByRetailerIds(new ArrayList<>(authfofoIds)).stream().collect(Collectors.groupingBy(
+						FofoStore::getWarehouseId, Collectors.mapping(FofoStore::getId, Collectors.toList())));
 		Map<Integer, CustomRetailer> fofoIdAndPartnerMap = retailerService.getFofoRetailers(false);
 		Map<Integer, PartnerDetailModel> fofoIdAndallValues = this.getPartnersStatDataFromFile();
 		if (warehouseId != 0) {
+			List<Integer> fofoIds = warehouseIdFofoIdMap.get(warehouseId);
+			/*
+			 * List<Integer> fofoIds =
-			List<Integer> fofoIds = fofoStoreRepository.selectActivePartnerByWarehouse(warehouseId).stream()
+			 * fofoStoreRepository.selectActivePartnerByWarehouse(warehouseId).stream()
-					.map(x -> x.getId()).collect(Collectors.toList());
+			 * .map(x -> x.getId()).collect(Collectors.toList());
+			 */
 			fofoIdAndallValues = fofoIdAndallValues.entrySet().stream().filter(x -> fofoIds.contains(x.getKey()))
 					.collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
 		} else {
+			fofoIdAndallValues = fofoIdAndallValues.entrySet().stream()
+					.filter(x -> new ArrayList<>(authfofoIds).contains(x.getKey()))
+					.collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
+		}
 		model.addAttribute("fofoIdAndallValues", fofoIdAndallValues);
 		model.addAttribute("fofoIdAndPartnerMap", fofoIdAndPartnerMap);
 		return "auth_user_partner_detail";
+	}
 	@RequestMapping(value = "/getWarehouseWiseBrandStock", method = RequestMethod.GET)
-	public String getWarehouseWiseBrandStock(HttpServletRequest request, Model model, @RequestParam int warehouseId)
+	public String getWarehouseWiseBrandStock(HttpServletRequest request, Model model,
-			throws Exception {
+			@RequestParam List<Integer> warehouseId) throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		Set<Integer> authfofoIds = storeGuyMap.get(email);
+		Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository
+				.selectActivePartnersByRetailerIds(new ArrayList<>(authfofoIds)).stream().collect(Collectors.groupingBy(
+						FofoStore::getWarehouseId, Collectors.mapping(FofoStore::getId, Collectors.toList())));
-		List<WarehouseWiseBrandStockModel> warehouseWiseBrandStock = saholicInventoryCISRepository
+		List<WarehouseWiseBrandStockModel> warehouseWiseBrandStock = new ArrayList<>();
+		if (!warehouseId.contains(0)) {
+			warehouseWiseBrandStock = saholicInventoryCISRepository.selectGroupByWarehouseAndBrand(warehouseId);
+		} else {
+			LOGGER.info("warehouseIdFofoIdMap" + warehouseIdFofoIdMap.keySet());
+			warehouseWiseBrandStock = saholicInventoryCISRepository
-				.selectGroupByWarehouseAndBrand(warehouseId);
+					.selectGroupByWarehouseAndBrand(new ArrayList<>(warehouseIdFofoIdMap.keySet()));
+		}
 		Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
 		model.addAttribute("warehouseWiseBrandStock", warehouseWiseBrandStock);
 		model.addAttribute("warehouseId", warehouseId);
 		model.addAttribute("warehouseMap", warehouseMap);
 		inventoryService.getItemAvailabilityAndIndent();
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
-	public Map<Integer, PartnerDetailModel> getWarehousePartnerDetail() throws Exception {
+	public Map<Integer, PartnerDetailModel> getWarehousePartnerDetail(Map<Integer, List<Integer>> warehousePartnerMap)
+			throws Exception {
 		Map<Integer, PartnerDetailModel> warehouseIdAndallValues = new LinkedHashMap<>();
-		Map<Integer, List<FofoStore>> warehousePartnerMap = fofoStoreRepository.getWarehousePartnerMap();
+		// Map<Integer, List<FofoStore>> warehousePartnerMap =
+		// fofoStoreRepository.getWarehousePartnerMap();
 		Map<Integer, PartnerDetailModel> partnerStats = this.getPartnersStatDataFromFile();
+		List<Integer> allfofoIds = new ArrayList<>();
 		if (partnerStats != null) {
-			for (Entry<Integer, List<FofoStore>> warehouse : warehousePartnerMap.entrySet()) {
+			for (Entry<Integer, List<Integer>> warehouse : warehousePartnerMap.entrySet()) {
-				List<Integer> fofoIds = warehouse.getValue().stream().map(x -> x.getId()).collect(Collectors.toList());
+				List<Integer> fofoIds = warehouse.getValue().stream().map(x -> x).collect(Collectors.toList());
+				allfofoIds.addAll(fofoIds);
 				List<PartnerDetailModel> partnerDetails = fofoIds.stream().map(x -> partnerStats.get(x))
 						.collect(Collectors.toList());
 				if (partnerDetails != null && !partnerDetails.isEmpty()) {
 					PartnerDetailModel partnerDetailModel = partnerStatsService.getAggregateStats(partnerDetails);
 					warehouseIdAndallValues.put(warehouse.getKey(), partnerDetailModel);
+				}
+			}
+			List<PartnerDetailModel> allPartnerDetails = allfofoIds.stream().map(x -> partnerStats.get(x))
+					.collect(Collectors.toList());
+			LOGGER.info("allPartnerDetails" + allPartnerDetails);
 			PartnerDetailModel partnerDetailModel = partnerStatsService
-					.getAggregateStats(new ArrayList<>(partnerStats.values()));
+					.getAggregateStats(new ArrayList<>(allPartnerDetails));
 			warehouseIdAndallValues.put(0, partnerDetailModel);
+		}
 		return warehouseIdAndallValues;
+	}
+	}
 	@RequestMapping(value = "/getWarehouseWiseBrandPartnerSale", method = RequestMethod.GET)
 	public String getWarehouseWiseBrandPartnerSale(HttpServletRequest request, Model model, @RequestParam String brand)
 			throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		Set<Integer> authfofoIds = storeGuyMap.get(email);
 		Map<Integer, WarehouseWiseBrandSaleModel> warehouseWiseBrandPartnerSales = fofoStoreRepository
-				.selectGroupByWarehouseBrandWisePartnerSale(brand).stream()
+				.selectGroupByWarehouseBrandWisePartnerSale(brand, new ArrayList<>(authfofoIds)).stream()
 				.collect(Collectors.toMap(x -> x.getWarehouseId(), x -> x));
 		List<WarehouseWiseBrandUnbilledActivatedModel> unbilledStock = fofoStoreRepository
-				.selectUnbilledActivateStockGroupByWarehouse(brand);
+				.selectUnbilledActivateStockGroupByWarehouse(brand, new ArrayList<>(authfofoIds));
 		for (WarehouseWiseBrandUnbilledActivatedModel un : unbilledStock) {
 			WarehouseWiseBrandSaleModel bpt = warehouseWiseBrandPartnerSales.get(un.getWarehouseId());
 			if (bpt != null) {
 				bpt.setAmtd(un.getUnbilledMtd());
+	}
 	@RequestMapping(value = "/getWarehouseWiseAccesoriesBrandPartnerSale", method = RequestMethod.GET)
 	public String getWarehouseWiseAccesoriesBrandPartnerSale(HttpServletRequest request, Model model,
 			@RequestParam String brand) throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		Set<Integer> authfofoIds = storeGuyMap.get(email);
 		List<WarehouseWiseBrandSaleModel> warehouseWiseBrandPartnerSales = fofoStoreRepository
-				.selectGroupByWarehouseAccesoriesBrandWisePartnerSale(brand);
+				.selectGroupByWarehouseAccesoriesBrandWisePartnerSale(brand, new ArrayList<>(authfofoIds));
 		Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
 		Set<String> brands = inventoryService.getAllTagListingBrands();
 		model.addAttribute("warehouseWiseBrandPartnerSales", warehouseWiseBrandPartnerSales);
 		model.addAttribute("warehouseMap", warehouseMap);
 	@RequestMapping(value = "/getWarehouseBrandWiseItemSale", method = RequestMethod.GET)
 	public String getWarehouseBrandWiseItemSale(HttpServletRequest request, Model model,
 			@RequestParam List<Integer> warehouseId, @RequestParam String brand) throws Exception {
 		Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		Set<Integer> authfofoIds = storeGuyMap.get(email);
 		Map<Integer, WarehouseBrandWiseItemSaleModel> branditemSalesMap = fofoStoreRepository
-				.selectWarehouseBrandItemSale(warehouseId, brand).stream()
+				.selectWarehouseBrandItemSale(warehouseId, brand, new ArrayList<>(authfofoIds)).stream()
 				.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
-		;
 		List<WarehouseBrandItemUnbilledActivatedModel> unbilledItems = fofoStoreRepository
-				.selectWarehouseBrandItemUnbilledActivateStock(warehouseId, brand);
+				.selectWarehouseBrandItemUnbilledActivateStock(warehouseId, brand, new ArrayList<>(authfofoIds));
 		for (WarehouseBrandItemUnbilledActivatedModel un : unbilledItems) {
 			WarehouseBrandWiseItemSaleModel bpt = branditemSalesMap.get(un.getItemId());
 			if (bpt != null) {
 				bpt.setAmtd(un.getAmtd());
 	@RequestMapping(value = "/getWarehouseAccesoriesBrandWiseItemSale", method = RequestMethod.GET)
 	public String getWarehouseAccesoriesBrandWiseItemSale(HttpServletRequest request, Model model,
 			@RequestParam List<Integer> warehouseId, @RequestParam String brand) throws Exception {
 		Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		Set<Integer> authfofoIds = storeGuyMap.get(email);
 		List<WarehouseBrandWiseItemSaleModel> branditemSales = fofoStoreRepository
-				.selectWarehouseAccesoriesBrandItemSale(warehouseId, brand);
+				.selectWarehouseAccesoriesBrandItemSale(warehouseId, brand, new ArrayList<>(authfofoIds));
 		model.addAttribute("branditemSales", branditemSales);
 		model.addAttribute("warehouseMap", warehouseMap);
 		return "warehouse_accessories_itemwsie_sale";
+	}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/DashboardController.java – Rev 27677 → 27701