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



	@Autowired
	SaholicCISTableRepository saholicCISTableRepository;
 
	@RequestMapping(value = "/open-indent/save", method = RequestMethod.POST)
	public String saveOpenIndent(HttpServletRequest request, Model model, @RequestParam int catalogId,
			@RequestParam int itemQty, @RequestParam int fofoId) throws Exception {
		if (fofoId == 0) {
 
			LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
			fofoId = loginDetails.getFofoId();
 

		model.addAttribute("response1", mvcResponseSender.createResponseString(false));
		return "response";
	}
 
	private void saveMonthlyPlanned(MonthlyPlanned monthlyPlanned, int fofoId, LocalDate currentMonthDate,
			int catalogId, int itemQty) {
		if (monthlyPlanned == null) {
			monthlyPlanned = new MonthlyPlanned();
			monthlyPlanned.setFofoId(fofoId);
			monthlyPlanned.setYearMonth(currentMonthDate);
			monthlyPlannedRepository.persist(monthlyPlanned);

 
	}
 
	@RequestMapping(value = "/open-indent/confirm", method = RequestMethod.POST)
	public String confirmOpenIndent(HttpServletRequest request,
			@RequestParam(required = false, defaultValue = "0") int fofoId, Model model) throws Exception {
 
		if (fofoId == 0) {
			LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
			fofoId = loginDetails.getFofoId();
		}

				Arrays.asList("Partner Id", "Partner Name", "Model Name", "Qty"),
				plannedModel.stream()
						.map(x -> Arrays.asList(x.getFofoId(), x.getStoreName(), x.getItemDescription(), x.getQty()))
						.collect(Collectors.toList()));
		LOGGER.info("baos" + baos);
		Utils.sendMailWithAttachments(googleMailSender, new String[] { customRetailer.getEmail() },
				ccemails.toArray(new String[ccemails.size()]), bccemails.toArray(new String[bccemails.size()]),
				"Planned Indent", "PFA",
				new Attachment[] { new Attachment("PlannedIndent.csv", new ByteArrayResource(baos.toByteArray())), });
 
	}
 
	@RequestMapping(value = "/indent/download", method = RequestMethod.GET)
	public ResponseEntity<ByteArrayResource> downloadIndent(HttpServletRequest request, Model model,
			@RequestParam(required = false, defaultValue = "0") int fofoId,
			@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);
 

 
	}
 
	@RequestMapping(value = "/itemsByCatalogId")
	public String getItemsByCatalogId(HttpServletRequest request, Model model,
			@RequestParam(required = false) int catalogId, @RequestParam(required = false) int itemId)
			throws ProfitMandiBusinessException {
		if (catalogId == 0) {
			catalogId = itemRepository.selectById(itemId).getCatalogItemId();
		}
		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);

 
	}
 
	@RequestMapping(value = "/hotdealsitemsByCatalogId")
	public String getHotdealsitemsByCatalogId(HttpServletRequest request, Model model,
			@RequestParam(required = false) int catalogId, @RequestParam(required = false) int itemId)
			throws ProfitMandiBusinessException {
		if (catalogId == 0) {
			catalogId = itemRepository.selectById(itemId).getCatalogItemId();
		}
		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);

		}
		LOGGER.info("Order removed count is {}", orderRemovedCount);
		return lastOrdersList;
	}
 
	// Clean up the saholic cis table
	@RequestMapping(value = "/indent/confirm-pause", method = RequestMethod.POST)
	public String updateTagListing(HttpServletRequest request, Model model, @RequestBody String jsonArrayString)
			throws Exception {
		JSONArray jsonArray = new JSONArray(jsonArrayString);
		for (int i = 0; i < jsonArray.length(); i++) {

			if (tl == null) {
				continue;
			} else {
				tl.setActive(obj.getBoolean("active"));
				if (!tl.isActive()) {
					saholicCISTableRepository.selectAllByItemId(tl.getItemId()).stream()
							.forEach(x -> saholicCISTableRepository.delete(x));
				}
			}
		}
		model.addAttribute("response1", true);
		return "response";

				PaymentStatus.SUCCESS, null, paymentAttributes);
	}
 
	@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 Exception {
 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
		Set<Integer> roleIds = loginDetails.getRoleIds();
		LOGGER.info("Counter size is {}", counterSize);
		LOGGER.info("Fofo Id is {}", fofoId);

		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(PLANNING_OPEN_DAY))) {
			planningMonthDate = LocalDate.now().plusMonths(1).withDayOfMonth(1);
			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, planningMonthDate);
			LOGGER.info("monthlyPlanned2" + monthlyPlanned);
			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
					LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
					.collect(Collectors.toList());
 
			model.addAttribute("planningMonth", LocalDate.now().plusMonths(1).getMonth());
		} else {
			planningMonthDate = LocalDate.now().withDayOfMonth(1);

			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, planningMonthDate);
			model.addAttribute("planningMonth", planningMonthDate.getMonth());
			model.addAttribute("mtd", true);
			model.addAttribute("freezed", true);
			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
					curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX)).stream().map(x -> x.getId())
					.collect(Collectors.toList());
			LOGGER.info("monthlyPlanned1" + monthlyPlanned);
		}
 
		Map<Integer, Integer> plannedDetailMap = null;

 
	}
 
	@RequestMapping(value = "/indent/loadIndentPreviousMonth")
	public String previousMonthLoadOpenIndent(HttpServletRequest request, Model model,
			@RequestParam(required = false, defaultValue = "0") int fofoId,
			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
		LocalDate planMonthStart = null;
		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(PLANNING_OPEN_DAY))) {
			planMonthStart = LocalDate.now().plusMonths(1).withDayOfMonth(1);
		} else {
			planMonthStart = LocalDate.now().withDayOfMonth(1);

		return regionMap;
	}
 
	@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);
 

		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()) {

 
	}
 
	@RequestMapping(value = "/focusedModel", method = RequestMethod.POST)
	public String focusedModel(HttpServletRequest request, @RequestParam int catalogId,
			@RequestParam(name = "recommended", defaultValue = "0") int recommended,
			@RequestParam(name = "minimumQty", defaultValue = "0") int minimumQty,
			@RequestParam(name = "obvrecommend", defaultValue = "0") int obvrecommend,
			@RequestParam(name = "obvminimum", defaultValue = "0") int obvminimum, @RequestParam int regionId,
			Model model) throws ProfitMandiBusinessException {
 
		FocusedModel fm = new FocusedModel();
		fm.setCatalogId(catalogId);
		fm.setMinimumQty(minimumQty);
		fm.setRecommendedQty(recommended);

		return "focused_model";
	}
 
	@RequestMapping(value = "/removeItem", method = RequestMethod.DELETE)
	public String removeFocusedModelItem(HttpServletRequest request,
			@RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
 
		focusedModelRepository.deleteById(id);
		model.addAttribute("response1", mvcResponseSender.createResponseString(true));
		return "response";
	}
 
	@RequestMapping(value = "/getPartnerloadContent")
	public String getPartnerloadContent(HttpServletRequest request, Model model,
			@RequestParam(required = false, defaultValue = "0") int fofoId,
			@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);

		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(PLANNING_OPEN_DAY))) {
			currentMonthDate = LocalDate.now().plusMonths(1).withDayOfMonth(1);
			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, currentMonthDate);
			LOGGER.info("monthlyPlanned2" + monthlyPlanned);
			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
					LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
					.collect(Collectors.toList());
 
			model.addAttribute("planningMonth", LocalDate.now().plusMonths(1).getMonth());
		} else {
			currentMonthDate = LocalDate.now().withDayOfMonth(1);

			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, currentMonthDate);
			model.addAttribute("planningMonth", currentMonthDate.getMonth());
			model.addAttribute("mtd", true);
			model.addAttribute("freezed", true);
			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
					curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX)).stream().map(x -> x.getId())
					.collect(Collectors.toList());
			LOGGER.info("monthlyPlanned1" + monthlyPlanned);
		}
 
		Map<Integer, Integer> plannedDetailMap = null;

						Collectors.mapping(y -> y.getId(), Collectors.toList())));
		for (Entry<Integer, List<Integer>> catalogItem : catalogItemIdMap.entrySet()) {
			List<Integer> itemIds = catalogItem.getValue();
			int availability = 0;
			for (Integer itemId : itemIds) {
				List<SaholicCISTable> saholicCISTableList = saholicCISTableRepository.selectByItemWarehouse(itemId,
						fofoStore.getWarehouseId());
				if (saholicCISTableList != null) {
					availability += saholicCISTableList.stream()
							.collect(Collectors.summingInt(x -> x.getAvailability()));
				}
			}
			Integer catalogItemId = catalogItem.getKey();
			ourStockAvailability.put(catalogItemId, availability);
		}

 
		List<String> brands = Arrays.asList("Vivo", "Samsung", "Oppo", "Tecno", "Itel", "OnePlus", "Lava", "Realme",
				"Xiaomi", "Nokia");
 
		AuthUser authUser = authRepository.selectByEmailOrMobile(email);
 
 
		Set<Integer> fofoIds = csService.getAuthFofoIds(email);
 
 
 
 
 
 
		Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
 
		Map<Integer, Map<String, Double>> fofoIdBrandAmountMap = new HashMap<>();
 

		return "partner-brandwise-detail";
	}
 
	@RequestMapping(value = "/changeActivationType", method = RequestMethod.POST)
	public String changeActivationType(HttpServletRequest request, @RequestParam String code,
			@RequestParam ActivationType activationType, Model model) throws Exception {
 
		FofoStore fofoStore = fofoStoreRepository.selectByStoreCode(code);
 
		fofoStore.setActivationType(activationType);
 

		return "response";
	}
 
	@RequestMapping(value = "/getPartnerShortageStock", method = RequestMethod.GET)
	public String getPartnerShortageStock(HttpServletRequest request,
			@RequestParam(required = false, defaultValue = "") String brand, @RequestParam int fofoId, Model model)
			throws Exception {
 
 
		Map<Integer, Map<Integer, List<SaholicPOItem>>> warehousePoItemAvailabilityMap = saholicInventoryService
				.getSaholicPOItems();
 
		List<FocusedModelShortageModel> focusedModelShortageList = new ArrayList<>();
		CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);

			List<Item> items = itemRepository.selectAllByCatalogItemId(entry.getKey());
 
			if (brand.equals("undefined") || items.get(0).getBrand().equals(brand)) {
 
				FocusedModelShortageModel fm = this.getFocusedModelShortage(entry.getValue().get(), entry.getKey(),
						processingOrderMap, grnPendingOrdersMap, catalogIdAndQtyMap, fofoId,
						warehousePoItemAvailabilityMap, items, customRetailer);
 
				focusedModelShortageList.add(fm);
			} else if (brand.equals("accessories")) {
 
				if (items.get(0).getCategoryId() != ProfitMandiConstants.MOBILE_CATEGORY_ID) {
					if (items.get(0).getCategoryId() != 0) {
						Category category = categoryRepository.selectById(items.get(0).getCategoryId());
 
						if (category.getParentCategoryId() == 10011) {
							FocusedModelShortageModel fm = this.getFocusedModelShortage(entry.getValue().get(),
									entry.getKey(), processingOrderMap, grnPendingOrdersMap, catalogIdAndQtyMap, fofoId,
									warehousePoItemAvailabilityMap, items, customRetailer);
 
 
							focusedModelShortageList.add(fm);
 
						}
					}

						Category category = categoryRepository.selectById(items.get(0).getCategoryId());
 
						if (category.getParentCategoryId() == 14200) {
							FocusedModelShortageModel fm = this.getFocusedModelShortage(entry.getValue().get(),
									entry.getKey(), processingOrderMap, grnPendingOrdersMap, catalogIdAndQtyMap, fofoId,
									warehousePoItemAvailabilityMap, items, customRetailer);
 
 
							focusedModelShortageList.add(fm);
 
						}
					}

		return "partner-stock";
 
	}
 
	private List<PartnerStockDescriptionModel> getBrandItemwiseDescription(String brand,
			Map<Integer, Integer> catalogIdAndQtyMap) throws ProfitMandiBusinessException {
		List<PartnerStockDescriptionModel> inStocks = new ArrayList<>();
 
		for (Entry<Integer, Integer> inStock : catalogIdAndQtyMap.entrySet()) {
			List<Item> items = itemRepository.selectAllByCatalogItemId(inStock.getKey());
 

 
		return inStocks;
	}
 
	private FocusedModelShortageModel getFocusedModelShortage(int qty, int catalogId,
			Map<Integer, Integer> processingOrderMap, Map<Integer, Integer> grnPendingOrdersMap,
			Map<Integer, Integer> catalogIdAndQtyMap, int fofoId,
			Map<Integer, Map<Integer, List<SaholicPOItem>>> warehousePoItemAvailabilityMap, List<Item> items,
			CustomRetailer customRetailer) throws ProfitMandiBusinessException {
 
		int minQty = qty;
		int inStockQty = 0;
		int processingQty = 0;
		int grnPendingQty = 0;

		int totalQty = processingQty + grnPendingQty + inStockQty;
 
		int shortageQty = minQty - totalQty;
		FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
 
 
		Map<Integer, List<SaholicPOItem>> poItemAvailabilityMap = warehousePoItemAvailabilityMap
				.get(fofoStore.getWarehouseId());
 
		for (Item it : items) {
			List<SaholicCISTable> currentAvailability = saholicCISTableRepository.selectByItemWarehouse(it.getId(),
					fofoStore.getWarehouseId());
			List<SaholicPOItem> poItemAvailability = null;
 
			if (poItemAvailabilityMap != null) {
				poItemAvailability = poItemAvailabilityMap.get(it.getId());
			}

		return "send-po-notification";
	}
 
	@RequestMapping(value = "/indent/send-po-notification", method = RequestMethod.POST)
	public String sendPONotification(HttpServletRequest request, @RequestBody POItemWarehouseModel poItemWarehouseModel,
			Model model) throws Exception {
 
		Map<Integer, Item> selectedCatalogItemMap = itemRepository
				.selectAllByCatalogIds(new HashSet<>(poItemWarehouseModel.getCatalogIds())).stream()
				.collect(Collectors.toMap(x -> x.getCatalogItemId(), x -> x, (existing, replacement) -> existing));
 

Subversion Repositories SmartDukaan

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

Rev 31238		Rev 31317
Line 223...		Line 223...
223	`@Autowired`	223	`@Autowired`
224	`SaholicCISTableRepository saholicCISTableRepository;`	224	`SaholicCISTableRepository saholicCISTableRepository;`
225		225
226	`@RequestMapping(value = "/open-indent/save", method = RequestMethod.POST)`	226	`@RequestMapping(value = "/open-indent/save", method = RequestMethod.POST)`
227	`public String saveOpenIndent(HttpServletRequest request, Model model, @RequestParam int catalogId,`	227	`public String saveOpenIndent(HttpServletRequest request, Model model, @RequestParam int catalogId,`
228	`@RequestParam int itemQty, @RequestParam int fofoId) throws Exception {`	228	`@RequestParam int itemQty, @RequestParam int fofoId) throws Exception {`
229	`if (fofoId == 0) {`	229	`if (fofoId == 0) {`
230		230
231	`LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);`	231	`LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);`
232	`fofoId = loginDetails.getFofoId();`	232	`fofoId = loginDetails.getFofoId();`
233		233
Line 245...		Line 245...
245	`model.addAttribute("response1", mvcResponseSender.createResponseString(false));`	245	`model.addAttribute("response1", mvcResponseSender.createResponseString(false));`
246	`return "response";`	246	`return "response";`
247	`}`	247	`}`
248		248
249	`private void saveMonthlyPlanned(MonthlyPlanned monthlyPlanned, int fofoId, LocalDate currentMonthDate,`	249	`private void saveMonthlyPlanned(MonthlyPlanned monthlyPlanned, int fofoId, LocalDate currentMonthDate,`
250	`int catalogId, int itemQty) {`	250	`int catalogId, int itemQty) {`
251	`if (monthlyPlanned == null) {`	251	`if (monthlyPlanned == null) {`
252	`monthlyPlanned = new MonthlyPlanned();`	252	`monthlyPlanned = new MonthlyPlanned();`
253	`monthlyPlanned.setFofoId(fofoId);`	253	`monthlyPlanned.setFofoId(fofoId);`
254	`monthlyPlanned.setYearMonth(currentMonthDate);`	254	`monthlyPlanned.setYearMonth(currentMonthDate);`
255	`monthlyPlannedRepository.persist(monthlyPlanned);`	255	`monthlyPlannedRepository.persist(monthlyPlanned);`
Line 283...		Line 283...
283		283
284	`}`	284	`}`
285		285
286	`@RequestMapping(value = "/open-indent/confirm", method = RequestMethod.POST)`	286	`@RequestMapping(value = "/open-indent/confirm", method = RequestMethod.POST)`
287	`public String confirmOpenIndent(HttpServletRequest request,`	287	`public String confirmOpenIndent(HttpServletRequest request,`
288	`@RequestParam(required = false, defaultValue = "0") int fofoId, Model model) throws Exception {`	288	`@RequestParam(required = false, defaultValue = "0") int fofoId, Model model) throws Exception {`
289		289
290	`if (fofoId == 0) {`	290	`if (fofoId == 0) {`
291	`LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);`	291	`LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);`
292	`fofoId = loginDetails.getFofoId();`	292	`fofoId = loginDetails.getFofoId();`
293	`}`	293	`}`
Line 339...		Line 339...
339	`Arrays.asList("Partner Id", "Partner Name", "Model Name", "Qty"),`	339	`Arrays.asList("Partner Id", "Partner Name", "Model Name", "Qty"),`
340	`plannedModel.stream()`	340	`plannedModel.stream()`
341	`.map(x -> Arrays.asList(x.getFofoId(), x.getStoreName(), x.getItemDescription(), x.getQty()))`	341	`.map(x -> Arrays.asList(x.getFofoId(), x.getStoreName(), x.getItemDescription(), x.getQty()))`