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

 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
+import com.mongodb.DBObject;
 import com.spice.profitmandi.common.enumuration.CounterSize;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
+import com.spice.profitmandi.common.model.BrandStockPrice;
 import com.spice.profitmandi.common.model.CatalogListingModel;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.ItemIdAvailability;
 import com.spice.profitmandi.common.model.PlannedModel;
 import com.spice.profitmandi.common.model.StockAllocationModel;
 import com.spice.profitmandi.dao.repository.catalog.FocusedModelRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.MonthlyPlannedRepository;
 import com.spice.profitmandi.dao.repository.fofo.PlannedDetailRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
+import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.inventory.StockAllocationService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import com.spice.profitmandi.thrift.clients.PaymentClient;
 import com.spice.profitmandi.thrift.clients.TransactionClient;
 	@Autowired
 	RoleManager roleManager;
 	@Autowired
+	private Mongo mongoClient;
+	@Autowired
+	private InventoryService inventoryService;
+	@Autowired
 	CsService csService;
 	/*
 	 * @RequestMapping(value = "/open-indent/save", method = RequestMethod.POST)
 	 * public String saveOpenIndent(HttpServletRequest request, Model model,
+	}
 	@RequestMapping(value = "/indent/loadIndent")
 	public String loadOpenIndent(HttpServletRequest request, Model model,
 			@RequestParam(required = false, defaultValue = "0") int fofoId,
-			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws ProfitMandiBusinessException {
+			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Set<Integer> roleIds = loginDetails.getRoleIds();
 		LOGGER.info("Counter size is {}", counterSize);
 		LOGGER.info("Fofo Id is {}", fofoId);
-		boolean isAdmin = !roleManager.isAdmin(roleIds);
+		boolean isAdmin = roleManager.isAdmin(roleIds);
-		Map<Integer, ItemIdAvailability> itemCisMap = null;
+		Map<Integer, Integer> itemCisMap;
 		if (!isAdmin && fofoId == 0) {
 			fofoId = cookiesProcessor.getCookiesObject(request).getFofoId();
 			List<ItemIdAvailability> currentInventorySnapshots = currentInventorySnapshotRepository
 					.selectItemsStock(fofoId);
+			LOGGER.info("currentInventorySnapshots" + currentInventorySnapshots);
 			itemCisMap = currentInventorySnapshots.stream().filter(x -> x.getAvailability() > 0)
-					.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
+					.collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));
 		} else {
 			if (fofoId == 0) {
 				List<ItemIdAvailability> currentInventorySnapshots = currentInventorySnapshotRepository
 						.selectItemsStock();
+				LOGGER.info("currentInventorySnapshots2" + currentInventorySnapshots);
 				itemCisMap = currentInventorySnapshots.stream().filter(x -> x.getAvailability() > 0)
-						.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
+						.collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));
 			} else {
 				List<ItemIdAvailability> currentInventorySnapshots = currentInventorySnapshotRepository
 						.selectItemsStock(fofoId);
+				LOGGER.info("currentInventorySnapshots3" + currentInventorySnapshots);
 				itemCisMap = currentInventorySnapshots.stream().filter(x -> x.getAvailability() > 0)
-						.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
+						.collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));
+			}
+		}
+		Map<Integer, Integer> currentStock = null;
+		if (!itemCisMap.isEmpty()) {
+			currentStock = itemRepository.selectByIds(itemCisMap.keySet()).stream().collect(Collectors
+					.groupingBy(x -> x.getCatalogItemId(), Collectors.summingInt(x -> itemCisMap.get(x.getId()))));
+		}
 		List<StockAllocationModel> stockAllocationList;
 		if (fofoId > 0) {
 			stockAllocationList = stockAllocationService.getStockAllocation(fofoId, true);
 		} else {
 			stockAllocationList = stockAllocationService.getStockAllocation(counterSize, true);
 			TagListing tagListing = iterator.next();
 			Item item = items.get(tagListing.getItemId());
 			// itemRepository.select
 			// catalogTagListingMap
-			if (isAdmin) {
-				if (item.getBrand() == null || item.getCategoryId() != 10006) {
+			if (item.getBrand() == null || item.getCategoryId() != 10006) {
-					iterator.remove();
-					continue;
-				}
-			} else {
-				if (!(itemCisMap.containsKey(tagListing.getItemId())
-						|| itemStockAllocationMap.containsKey(tagListing.getItemId()))) {
-					iterator.remove();
+				iterator.remove();
-					continue;
+				continue;
-				}
+			}
 			int catalogId = item.getCatalogItemId();
 			CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);
+				}
 				catalogListingMap.put(catalogId, catalogListingModel);
+			}
+			int itemAvailability = 0;
+			if (currentStock != null) {
-			ItemIdAvailability itemIdAvailability = itemCisMap.get(tagListing.getItemId());
+				Integer qty = currentStock.get(catalogId);
-			int itemAvailability = itemIdAvailability == null ? 0 : itemIdAvailability.getAvailability();
+				itemAvailability = qty == null ? 0 : qty;
-			catalogListingModel.setStockInHand(catalogListingModel.getStockInHand() + itemAvailability);
+				catalogListingModel.setStockInHand(itemAvailability);
+			} else {
+				catalogListingModel.setStockInHand(0);
+			}
 			Integer inTransitQuantity = itemsInTransit.get(item.getId());
 			int inTransitQty = (inTransitQuantity == null ? 0 : inTransitQuantity);
 			catalogListingModel.setInTransitQuantity(catalogListingModel.getInTransitQuantity() + inTransitQty);
 			if (catalogListingModel.getAllocatedQuantity() > 0) {
 		Comparator<CatalogListingModel> firstCmp = Comparator.comparing(CatalogListingModel::getMinimumQty,
 				Comparator.reverseOrder());
 		LOGGER.info("monthlyPlanned" + monthlyPlanned);
 		model.addAttribute("catalogTagListings", catalogModel.stream().sorted(firstCmp).collect(Collectors.toList()));
 		model.addAttribute("isAdmin", roleManager.isAdmin(roleIds));
+		model.addAttribute("brandStockPrices",this.getBrandStockPrices(loginDetails.getFofoId()));
 		model.addAttribute("customRetailers", customRetailers);
 		model.addAttribute("totalAmount", totalAmount);
 		model.addAttribute("monthlyPlanned", monthlyPlanned);
 		model.addAttribute("totalPcs", totalPcs);
 		return "open-indent";
 	@RequestMapping(value = "/getFocusedModel", method = RequestMethod.GET)
 	public String getFocusedModel(HttpServletRequest request,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
+		long size = 0;
 		List<FocusedModel> focusedModels = focusedModelRepository.selectAll(offset, limit);
+		size = focusedModelRepository.selectAllCount();
+		if (!focusedModels.isEmpty()) {
+			Map<Integer, Item> itemMap = this.getItemByCatalogId(focusedModels);
+			model.addAttribute("focusedModels", focusedModels);
+			model.addAttribute("itemMap", itemMap);
+			model.addAttribute("start", offset + 1);
+			model.addAttribute("size", size);
-		Map<Integer, Item> itemMap = this.getItemByCatalogId(focusedModels);
+			model.addAttribute("url", "/getPaginatedFocusedModel");
+			if (focusedModels.size() < limit) {
+				model.addAttribute("end", offset + focusedModels.size());
+			} else {
+				model.addAttribute("end", offset + limit);
+			}
+		} else {
-		model.addAttribute("focusedModels", focusedModels);
+			model.addAttribute("walletRequest", focusedModels);
-		model.addAttribute("itemMap", itemMap);
+			model.addAttribute("size", size);
+		}
 		return "focused_model";
+	}
+	@RequestMapping(value = "/getPaginatedFocusedModel", method = RequestMethod.GET)
+	public String getPaginatedFocusedModel(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
+		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
+		List<FocusedModel> focusedModels = focusedModelRepository.selectAll(offset, limit);
+		if (!focusedModels.isEmpty()) {
+			Map<Integer, Item> itemMap = this.getItemByCatalogId(focusedModels);
+			model.addAttribute("focusedModels", focusedModels);
+			model.addAttribute("itemMap", itemMap);
+			model.addAttribute("url", "/getPaginatedFocusedModel");
+		} else {
+			model.addAttribute("focusedModels", focusedModels);
+		}
+		return "focused-model-paginated";
+	}
 	private Map<Integer, Item> getItemByCatalogId(List<FocusedModel> focusedModels) {
 		Map<Integer, Item> itemMap = new HashMap<>();
 		for (FocusedModel focusedModel : focusedModels) {
 			List<Item> items = itemRepository.selectAllByCatalogItemId(focusedModel.getCatalogId());
 			itemMap.put(items.get(0).getCatalogItemId(), items.get(0));
 		focusedModelRepository.deleteById(catalogId);
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws Exception {
+		Map<String, BrandStockPrice> brandStockPricesMap = inventoryService.getBrandWiseStockValue(fofoId);
+		List<DBObject> mobileBrands = mongoClient.getMongoBrands(fofoId, "", 3);
+		List<BrandStockPrice> brandStockPrices = new ArrayList<>();
+		mobileBrands.stream().forEach(x -> {
+			String brand = (String) x.get("name");
+			if (brandStockPricesMap.containsKey(brand)) {
+				BrandStockPrice brandStockPrice = brandStockPricesMap.get(brand);
+				brandStockPrice.setBrandUrl((String) x.get("url"));
+				brandStockPrice.setRank(((Double) x.get("rank")).intValue());
+				brandStockPrices.add(brandStockPrice);
+			}
+		});
+		return brandStockPrices.stream().filter(x -> x.getTotalQty() > 0).sorted((x, y) -> x.getRank() - y.getRank())
+				.collect(Collectors.toList());
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/IndentController.java – Rev 25732 → 25736