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

 	@RequestMapping(value = "/schemes/update", method = RequestMethod.POST)
 	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
 			throws Exception {
 		for (int schemeId : schemeItems.getSchemeIds()) {
 			if (schemeRepository.selectById(schemeId) != null)
-				for (int itemId : schemeItems.getItemIds()) {
+				for (int catalogId : schemeItems.getCatalogIds()) {
-					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
+					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(catalogId)),
 							new HashSet<>(Arrays.asList(4, 7))).size() > 0) {
 						SchemeItem si = new SchemeItem();
-						si.setItemId(itemId);
+						si.setCatalogId(catalogId);
 						si.setSchemeId(schemeId);
 						si.setCreateTimestamp(LocalDateTime.now());
 						try {
 							schemeItemRepository.persist(si);
 						} catch (Exception e) {
 							LOGGER.info("Scheme aleady exist");
+						}
 						model.addAttribute("response", mvcResponseSender.createResponseString(true));
 					} else {
 						model.addAttribute("response", mvcResponseSender.createResponseString(false));
-						throw new ProfitMandiBusinessException("ItemId", itemId, "Invalid Item Id");
+						throw new ProfitMandiBusinessException("Catalog Id ", catalogId, "Invalid Catalog Id");
+					}
+				}
+		}
 		return "response";
+	}
 	@RequestMapping(value = "/addItemToScheme", method = RequestMethod.POST)
 	public String updateScheme(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
 			throws Exception {
 		for (int schemeId : schemeItems.getSchemeIds()) {
-			List<Integer> itemIds = schemeItemRepository.selectItemIdsBySchemeId(schemeId);
+			List<Integer> catalogIds = schemeItemRepository.selectCatalogIdsBySchemeId(schemeId);
 			if (schemeRepository.selectById(schemeId) != null)
-				for (int itemId : schemeItems.getItemIds()) {
+				for (int catalogId : schemeItems.getCatalogIds()) {
-					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
-							new HashSet<>(Arrays.asList(4, 7))).size() > 0 && (!(itemIds.contains(itemId)))) {
+					if (!(catalogIds.contains(catalogId))) {
 						SchemeItem si = new SchemeItem();
-						si.setItemId(itemId);
+						si.setCatalogId(catalogId);
 						si.setSchemeId(schemeId);
 						si.setCreateTimestamp(LocalDateTime.now());
 						try {
 							schemeItemRepository.persist(si);
 						} catch (Exception e) {
 							LOGGER.info("Scheme already exist");
+						}
 						model.addAttribute("response", mvcResponseSender.createResponseString(true));
 					} else {
-						model.addAttribute("response", mvcResponseSender.createResponseString(false));
+						throw new ProfitMandiBusinessException("Catalog exist for scheme", "SchemeId= " + schemeId + ", CatalogId= " + catalogId, "Catalog exist for scheme");
+					}
+				}
+		}
 		return "response";
+	}
 	@RequestMapping(value = "/schemes/delete", method = RequestMethod.DELETE)
 	public String deleteShcemes(HttpServletRequest request,
-			@RequestParam(name = "schemeId", required = false, defaultValue = "0") int schemeId,
+								@RequestParam(name = "schemeId", required = false, defaultValue = "0") int schemeId,
-			@RequestParam(name = "itemId", required = false, defaultValue = "0") int itemId, Model model)
+								@RequestParam(name = "catalogId", required = false, defaultValue = "0") int catalogId, Model model)
 			throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		if (!(schemeId == 0 && itemId == 0) || (!(schemeId == 0 || itemId == 0))) {
+		if (schemeId > 0 && catalogId > 0) {
-			schemeItemRepository.deletebyItemIdsandSchemeIds(itemId, schemeId);
+			schemeItemRepository.deleteByCatalogIdsAndSchemeIds(catalogId, schemeId);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
 			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
+	}
 	@RequestMapping(value = "/extendSchemeById", method = RequestMethod.POST)
 	public String extendSchemeById(HttpServletRequest request,
-			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+								   @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
-			@RequestBody LocalDateTime extendDatetime, Model model) throws Exception {
+								   @RequestBody LocalDateTime extendDatetime, Model model) throws Exception {
 		extendDatetime = LocalDateTime.of(extendDatetime.toLocalDate(), Utils.MAX_TIME);
 		Scheme scheme = schemeRepository.selectById(schemeId);
 		if ((!(scheme.getActiveTimestamp() == null)) && scheme.getExpireTimestamp() == null) {
 			scheme.setEndDateTime(extendDatetime);
 			schemeRepository.persist(scheme);
 		model.addAttribute("response", mvcResponseSender.createResponseString(false));
 		return "response";
+	}
 	@RequestMapping(value = "/createScheme", method = RequestMethod.POST)
-	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest,
+	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest, Model model)
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
-			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("CreateSchemeRequest {}", createSchemeRequest);
 		schemeService.saveScheme(loginDetails.getFofoId(), createSchemeRequest);
-		LOGGER.info("Scheme saved successfully");
+		return getDefaultSchemes(request, model);
-		long size = schemeRepository.selectAllCount();
-		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
+	}
+	private String getDefaultSchemes(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
+		return getSchemes(request, 0, null, 30, 0, 0, PartnerType.ALL, "", model);
+	}
-		if (!schemes.isEmpty()) {
+	private List<Scheme> setSchemeAmountModel(List<Scheme> schemes) {
-			for (Scheme scheme : schemes) {
+		for (Scheme scheme : schemes) {
-				if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
+			if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
-					scheme.setAmountModel(scheme.getAmount() + "%");
+				scheme.setAmountModel(scheme.getAmount() + "%");
-				} else {
+			} else {
-					scheme.setAmountModel(scheme.getAmount() + "");
+				scheme.setAmountModel(scheme.getAmount() + "");
-				}
+			}
+		}
-		model.addAttribute("schemes", schemes);
-		model.addAttribute("start", offset + 1);
-		model.addAttribute("size", size);
-		model.addAttribute("searchItem", searchItem);
-		model.addAttribute("searchTerm", searchTerm);
-		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-		if (schemes.size() < limit) {
-			model.addAttribute("end", offset + schemes.size());
-		} else {
-			model.addAttribute("end", offset + limit);
-		}
-		return "schemes";
+		return schemes;
+	}
+	//Show 20 recents
 	@RequestMapping(value = "/getSchemes", method = RequestMethod.GET)
 	public String getSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(required = false) LocalDate date,
+							 @RequestParam(required = false) LocalDate date,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
+							 @RequestParam(name = "limit", required = false, defaultValue = "30") int limit,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "0") int searchItem,
+							 @RequestParam(name = "searchModel", required = false, defaultValue = "0") int searchModel,
-			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
+							 @RequestParam(name = "searchScheme", required = false, defaultValue = "0") int searchScheme,
-			@RequestParam(name = "partnerType", required = false, defaultValue = "") PartnerType partnerType,
+							 @RequestParam(name = "partnerType", required = false, defaultValue = "ALL") PartnerType partnerType,
-			@RequestParam(name = "searchImei", required = false, defaultValue = "") String searchImei, Model model)
+							 @RequestParam(name = "searchImei", required = false, defaultValue = "") String searchImei, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
-		if (date == null) {
+		if (date != null) {
-			date = LocalDate.now();
+			date = date.isAfter(LocalDate.now()) ? LocalDate.now() : date;
+		}
-		model.addAttribute("date", date);
 		List<Scheme> schemes = null;
 		List<SchemeInOut> schemeInOut = null;
-		long size = 0;
-		date = date.isAfter(LocalDate.now()) ? LocalDate.now() : date;
+		boolean fullAccess = this.getAccess(loginDetails.getEmailId());
-		final LocalDate date1 = date;
-		if (partnerType == null) {
-			// TODO - SCHEME
+		model.addAttribute("fullAccess", fullAccess);
+		model.addAttribute("searchImei", searchImei);
+		model.addAttribute("isAdmin", isAdmin);
-			partnerType = partnerTypeChangeService.getTypeOnMonth(loginDetails.getFofoId(), YearMonth.from(date));
+		model.addAttribute("searchModel", searchModel);
+		model.addAttribute("searchScheme", searchScheme);
+		model.addAttribute("partnerType", partnerType);
+		model.addAttribute("date", date);
-			// partnerType =
+		final LocalDate date1 = date;
-			// partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(), date);
-		}
-		if (!(searchTerm.equals(""))) {
+		if (searchScheme > 0) {
-			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
+			schemes = Arrays.asList(schemeRepository.selectById(searchScheme));
-			for (Scheme scheme : schemes) {
+			this.setSchemeAmountModel(schemes);
-				if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
-					scheme.setAmountModel(scheme.getAmount() + "%");
-				} else {
-					scheme.setAmountModel(scheme.getAmount() + "");
-				}
-			}
 			if (schemes.size() > 0) {
-				size = schemeRepository.selectAllCount();
-				LOGGER.info("schemes" + schemes);
 				model.addAttribute("schemes", schemes);
-				model.addAttribute("start", offset + 1);
-				model.addAttribute("size", size);
+				return "schemes";
-				if (schemes.size() < limit) {
-					model.addAttribute("end", offset + schemes.size());
-				} else {
-					model.addAttribute("end", offset + limit);
-				}
 			} else {
-				throw new ProfitMandiBusinessException("SchemeId", searchTerm, "SchemeId Not Found");
+				throw new ProfitMandiBusinessException("SchemeId", searchScheme, "SchemeId Not Found");
+			}
-		} else if (searchItem > 0) {
+		} else if (searchModel > 0) {
 			TagListing tagListing = null;
+			Item item = itemRepository.selectAllByCatalogItemId(searchModel).get(0);
-			tagListing = tagListingRepository.selectByItemId(searchItem);
+			tagListing = tagListingRepository.selectByItemId(item.getId());
-			Item item = itemRepository.selectById(searchItem);
+			model.addAttribute("modelName", item.getItemDescriptionNoColor());
 			if (tagListing != null) {
 				model.addAttribute("dp", tagListing.getSellingPrice());
 				model.addAttribute("mop", tagListing.getMop());
+			}
-			schemes = schemeService.selectSchemeByPartnerType(partnerType, date, searchItem, isAdmin, offset, limit)
+			schemes = schemeService.selectSchemeByPartnerType(partnerType, date, searchModel, isAdmin, offset, limit)
 					.stream().filter(x -> {
 						return (x.getId() != 411 && x.getId() != 612) || date1.isBefore(LocalDate.of(2021, 12, 1));
 					}).collect(Collectors.toList());
 			// Remove 411 and 612
 			model.addAttribute("schemes", schemes);
-			if (schemes.size() == 0) {
-				if (isAdmin)
-					return "schemes";
-				else {
-					return "schemes-partner";
-				}
-			}
 			// For 7720(HR) remove investment
-			int nlc = this.getNlc(item, loginDetails.getFofoId(), schemes, tagListing, searchItem);
+			int nlc = this.getNlc(item, loginDetails.getFofoId(), schemes, tagListing, searchModel);
-			size = schemeService.selectSchemeCount(partnerType, date, searchItem, isAdmin);
-			model.addAttribute("start", offset + 1);
-			model.addAttribute("size", size);
-			if (schemes.size() < limit) {
-				model.addAttribute("end", offset + schemes.size());
-			} else {
-				model.addAttribute("end", offset + limit);
-			}
 			model.addAttribute("nlc", Math.round(nlc));
+			return "schemes";
-		} else if (!(searchImei.equals(""))) {
+		} else if (org.apache.commons.lang3.StringUtils.isNotEmpty(searchImei)) {
 			LOGGER.info("searchImei" + searchImei);
-			InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumberFofoId(searchImei,
+			InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumber(searchImei);
-					loginDetails.getFofoId());
 			Item item = itemRepository.selectById(inventoryItem.getItemId());
 			Map<Integer, Scheme> schemeMap = new HashMap<>();
 			if (inventoryItem != null) {
 				LOGGER.info("inventoryItem" + inventoryItem);
+				}
+			}
 			model.addAttribute("schemeMap", schemeMap);
 			model.addAttribute("item", item);
+			model.addAttribute("schemeInOut", schemeInOut);
+			return "schemes-partner";
+		}
-		model.addAttribute("schemeInOut", schemeInOut);
-		model.addAttribute("searchItem", searchItem);
-		model.addAttribute("searchTerm", searchTerm);
-		model.addAttribute("partnerType", partnerType);
-		model.addAttribute("isAdmin", isAdmin);
-		LOGGER.info("schemes" + schemes);
-		model.addAttribute("schemes", schemes != null ? schemes.stream().filter(x -> {
-			return (x.getId() != 411 && x.getId() != 612) || date1.isBefore(LocalDate.of(2021, 12, 1));
-		}).collect(Collectors.toList()) : null);
-		LOGGER.info("schemes" + schemes);
-		// model.addAttribute("roleTypes", loginDetails.getRoleTypes());
 		if (isAdmin) {
-			boolean fullAccess = this.getAccess(loginDetails.getEmailId());
+			schemes = schemeRepository.selectAll(0, 30);
+			this.setSchemeAmountModel(schemes);
-			model.addAttribute("fullAccess", fullAccess);
+			model.addAttribute("schemes", schemes);
 			return "schemes";
 		} else {
 			List<CreateOfferRequest> offers = null;
 			Map<Integer, Map<Integer, Long>> offerSlabPayoutMap = new HashMap<>();
 			List<PriceDropIMEI> priceDropImeis = new ArrayList<>();
-			if (searchItem > 0) {
+			if (searchModel > 0) {
-				offers = offerService.getPublishedOffers(date, loginDetails.getFofoId(), searchItem);
+				offers = offerService.getPublishedOffers(date, loginDetails.getFofoId(), searchModel);
 				for (CreateOfferRequest createOfferRequest : offers) {
 					Map<Integer, Map<Integer, Long>> itemSlabPayoutMap = offerService
 							.getSlabPayoutMap(createOfferRequest);
-					Map<Integer, Long> slabPayoutMap = itemSlabPayoutMap.get(searchItem);
+					Map<Integer, Long> slabPayoutMap = itemSlabPayoutMap.get(searchModel);
 					offerSlabPayoutMap.put(createOfferRequest.getId(), slabPayoutMap);
+				}
 			} else {
 				offers = new ArrayList<>();
+			}
-			if (!(searchImei.equals(""))) {
+			if (org.apache.commons.lang3.StringUtils.isNotEmpty(searchImei)) {
 				InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumberFofoId(searchImei,
 						loginDetails.getFofoId());
 				priceDropImeis = priceDropIMEIRepository.selectByFofoIdImei(loginDetails.getFofoId(), searchImei);
 				for (PriceDropIMEI priceDropIMEI : priceDropImeis) {
+			}
 			FofoStore fs = fofoStoreRepository.selectByRetailerId(loginDetails.getFofoId());
 			model.addAttribute("offers", offers);
 			model.addAttribute("offerSlabPayoutMap", offerSlabPayoutMap);
+			model.addAttribute("searchModel", searchModel);
+			model.addAttribute("searchScheme", searchScheme);
+			model.addAttribute("searchImei", searchImei);
 			model.addAttribute("partnerCode", fs.getCode());
 			model.addAttribute("fofoId", fs.getId());
 			model.addAttribute("priceDropImeis", priceDropImeis);
 			return "schemes-partner";
+		}
 		return "last-month-credited-income";
+	}
 	@RequestMapping(value = "/getLastMonthImeiWiseIncome", method = RequestMethod.GET)
 	public String getLastMonthImeiWiseIncome(HttpServletRequest request,
-			@RequestParam(name = "catalogItemId", required = false, defaultValue = "") int catalogItemId,
+											 @RequestParam(name = "catalogItemId", required = false, defaultValue = "") int catalogItemId,
-			@RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
+											 @RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
 			throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LocalDateTime lastMonthStart = LocalDate.now().minusMonths(month).withDayOfMonth(1).atStartOfDay();
 		return "last-month-imei-wise-income";
+	}
 	@RequestMapping(value = "/brandWiseIncome", method = RequestMethod.GET)
 	public String getBrandWiseIncome(HttpServletRequest request,
-			@RequestParam(name = "brand", required = false, defaultValue = "") String brand,
+									 @RequestParam(name = "brand", required = false, defaultValue = "") String brand,
-			@RequestParam(name = "status", required = false, defaultValue = "") String status,
+									 @RequestParam(name = "status", required = false, defaultValue = "") String status,
-			@RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
+									 @RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("loginDetails {}", loginDetails);
 		LOGGER.info("brand" + brand);
 		LOGGER.info("month {}", month);
 		LOGGER.info("lastMonthSaleMarginMap {}", lastMonthSaleMarginMap);
 		return "last-month-credited-income";
+	}
-	@RequestMapping(value = "/getPaginatedSchemes", method = RequestMethod.GET)
-	public String getPaginatedSchemes(HttpServletRequest request, @RequestParam(required = false) LocalDate date,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "partnerType", required = false, defaultValue = "ALL") PartnerType partnerType,
-			Model model) throws ProfitMandiBusinessException {
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
-		if (date == null) {
-			date = LocalDate.now();
-		}
-		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
-		List<Scheme> schemes = schemeRepository.selectAll();
-		int itemId = 0;
-		TagListing tagListing = null;
-		for (Scheme scheme : schemes) {
-			if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
-				if (itemId > 0) {
-					float taxRate = stateGstRateRepository.getIgstTaxRate(Arrays.asList(itemId)).get(itemId);
-					float taxableSellingPrice = tagListing.getSellingPrice() / (1 + taxRate / 100);
-					float amount = taxableSellingPrice * scheme.getAmount() / 100;
-					scheme.setAmountModel(FormattingUtils.formatDecimal(amount) + " (" + scheme.getAmount() + "%)");
-				} else {
-					scheme.setAmountModel(scheme.getAmount() + "%");
-				}
-			} else {
-				scheme.setAmountModel("" + scheme.getAmount());
-			}
-		}
-		model.addAttribute("schemes", schemes);
-		model.addAttribute("partnerType", partnerType);
-		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-		return "schemes-paginated";
-	}
 	@RequestMapping(value = "/schemes/downloadPage", method = RequestMethod.GET)
 	public String downloadPage(HttpServletRequest request, Model model) {
 		return "schemes-download";
+	}
 	@RequestMapping(value = "/schemes/download", method = RequestMethod.GET)
 	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request,
-			@RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString,
+																  @RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString,
-			@RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model)
+																  @RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model)
 			throws ProfitMandiBusinessException {
 		LocalDateTime startDateTime = StringUtils.toDateTime(startDateTimeString,
 				DateTimePattern.DD_MM_yyyy_T_HH_MM_SS);
 		LocalDateTime endDateTime = StringUtils.toDateTime(endDateTimeString, DateTimePattern.DD_MM_yyyy_T_HH_MM_SS);
 		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+	}
 	@RequestMapping(value = "/getSchemeById", method = RequestMethod.GET)
 	public String getSchemeById(HttpServletRequest request,
-			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
+								@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean fullAccess = this.getAccess(loginDetails.getEmailId());
 		Scheme scheme = schemeService.getSchemeById(schemeId);
 		model.addAttribute("fullAccess", fullAccess);
 		model.addAttribute("scheme", scheme);
 		model.addAttribute("isAdmin", roleManager.isAdmin(loginDetails.getRoleIds()));
 		return "scheme-details";
+	}
 	@RequestMapping(value = "/activeSchemeById", method = RequestMethod.PUT)
 	public String activeSchemeById(HttpServletRequest request,
-			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+								   @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
+								   @RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+								   @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
 		schemeService.activeSchemeById(schemeId);
 		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
 		for (Scheme scheme : schemes) {
 			if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
 				scheme.setAmountModel(scheme.getAmount() + "%");
 			} else {
 				scheme.setAmountModel(scheme.getAmount() + "");
+			}
+		}
-		model.addAttribute("schemes", schemes);
-		return "schemes-paginated";
+		return "schemes";
+	}
 	@RequestMapping(value = "/expireSchemeById", method = RequestMethod.PUT)
 	public String expireSchemeById(HttpServletRequest request,
-			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+								   @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
-			@RequestParam(name = ProfitMandiConstants.EXPIRE_TIMESTAMP) LocalDateTime expiryTimestamp,
+								   @RequestParam(name = ProfitMandiConstants.EXPIRE_TIMESTAMP) LocalDateTime expiryTimestamp,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+								   Model model)
 			throws ProfitMandiBusinessException {
 		expiryTimestamp = LocalDateTime.of(expiryTimestamp.toLocalDate(), Utils.MAX_TIME);
 		schemeService.expireSchemeById(schemeId, expiryTimestamp);
-		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
-		model.addAttribute("schemes", schemes);
-		return "schemes-paginated";
+		return getDefaultSchemes(request, model);
+	}
 	@RequestMapping(value = "/getSchemesJson", method = RequestMethod.GET)
 	public ResponseEntity<?> getSchemesJson(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
+											@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+											@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		return responseSender.ok(schemeService.getSchemes(loginDetails.getRoleIds(), offset, limit));
+	}
-	@RequestMapping(value = "/searchSchemeByCategory")
-	public String getSchemeByCategory(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
-			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
-			@RequestParam(name = "category", required = true, defaultValue = "") PartnerType category, Model model)
-			throws ProfitMandiBusinessException {
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		List<Scheme> schemes = null;
-		long size = 0;
-		schemes = schemeRepository.selectByPartnerType(category, offset, limit);
-		if (!(schemes.size() == 0)) {
-			size = schemeRepository.selectAllCount();
-			LOGGER.info("schemes" + schemes);
-			model.addAttribute("schemes", schemes);
-			model.addAttribute("start", offset + 1);
-			model.addAttribute("size", size);
-			model.addAttribute("searchTerm", searchTerm);
-			model.addAttribute("searchItem", searchItem);
-			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-			if (schemes.size() < limit) {
-				model.addAttribute("end", offset + schemes.size());
-			} else {
-				model.addAttribute("end", offset + limit);
-			}
-		}
-		return "schemes";
-	}
-	@RequestMapping(value = "/getSchemeByCategoryPaginated")
-	public String getSchemeByCategoryPaginated(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
-			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
-			@RequestParam(name = "category", required = true, defaultValue = "") PartnerType category, Model model)
-			throws ProfitMandiBusinessException {
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		LOGGER.info("In search Item....");
-		List<Scheme> schemes = null;
-		schemes = schemeRepository.selectByPartnerType(category, offset, limit);
-		model.addAttribute("schemes", schemes);
-		model.addAttribute("searchItem", searchItem);
-		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-		return "schemes-paginated";
-	}
-	@RequestMapping(value = "/searchScheme")
-	public String getSchemeBySchemeId(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
-			throws ProfitMandiBusinessException {
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		List<Scheme> schemes = null;
-		long size = 0;
-		if (!(searchTerm.equals("")) && searchItem.equals("")) {
-			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
-			if (!(schemes.size() == 0)) {
-				size = schemeRepository.selectAllCount();
-				LOGGER.info("schemes" + schemes);
-				model.addAttribute("schemes", schemes);
-				model.addAttribute("start", offset + 1);
-				model.addAttribute("size", size);
-				model.addAttribute("searchTerm", searchTerm);
-				model.addAttribute("searchItem", searchItem);
-				model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-				if (schemes.size() < limit) {
-					model.addAttribute("end", offset + schemes.size());
-				} else {
-					model.addAttribute("end", offset + limit);
-				}
-			} else {
-				throw new ProfitMandiBusinessException("SchemeId", searchTerm, "SchemeId Not Found");
-			}
-		} else if (!(searchItem.equals("")) && searchTerm.equals("")) {
-			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
-			if (!(schemeIds.size() == 0)) {
-				LOGGER.info("schemeIds in searchItemScheme" + schemeIds);
-				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
-				size = schemeIds.size();
-				LOGGER.info("Size" + size);
-				model.addAttribute("schemes", schemes);
-				model.addAttribute("start", offset + 1);
-				model.addAttribute("size", size);
-				model.addAttribute("searchItem", searchItem);
-				model.addAttribute("searchTerm", searchTerm);
-				model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-				if (schemes.size() < limit) {
-					model.addAttribute("end", offset + schemes.size());
-				} else {
-					model.addAttribute("end", offset + limit);
-				}
-			} else {
-				throw new ProfitMandiBusinessException("SchemeIds", searchItem, "SchemeId Not Found");
-			}
-		} else {
-			if (roleManager.isAdmin(loginDetails.getRoleIds())) {
-				schemes = schemeRepository.selectAll(offset, limit);
-				size = schemeRepository.selectAllCount();
-			} else {
-				schemes = schemeRepository.selectActiveAll(offset, limit);
-				size = schemeRepository.selectAllActiveCount();
-			}
-			model.addAttribute("schemes", schemes);
-			model.addAttribute("start", offset + 1);
-			model.addAttribute("size", size);
-			model.addAttribute("searchItem", searchItem);
-			model.addAttribute("searchTerm", searchTerm);
-			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-			if (schemes.size() < limit) {
-				model.addAttribute("end", offset + schemes.size());
-			} else {
-				model.addAttribute("end", offset + limit);
-			}
-		}
-		return "schemes";
-	}
-	@RequestMapping(value = "/searchItemSchemePanigated")
-	public String getSchemeByItemPanigated(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
-			throws ProfitMandiBusinessException {
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		LOGGER.info("In search Item....");
-		List<Scheme> schemes = null;
-		if (!searchItem.equals("")) {
-			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
-			if (schemeIds != null) {
-				LOGGER.info(schemeIds);
-				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
-			}
-		}
-		model.addAttribute("schemes", schemes);
-		model.addAttribute("searchItem", searchItem);
-		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
-		return "schemes-paginated";
-	}
 	@RequestMapping(value = "/getCustomerOffer", method = RequestMethod.GET)
 	public String getCustomerOffer(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
 		List<CustomerOffer> customerOffers = customerOfferRepository.selectAll();
+	}
 	@RequestMapping(value = "/createCustomerOffer", method = RequestMethod.POST)
 	public String createCustomerOffer(HttpServletRequest request, @RequestParam String offerName,
-			@RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model) throws Exception {
+									  @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model) throws Exception {
 		CustomerOffer co = new CustomerOffer();
 		co.setOfferName(offerName);
 		co.setStartDate(startDate);
 		co.setEndDate(endDate);
+	}
 	@RequestMapping(value = "/customerOfferItem/upload", method = RequestMethod.POST)
 	public String uploadCustomerOfferItem(HttpServletRequest request, Model model, @RequestParam int offerId,
-			HttpServletResponse response, @RequestPart MultipartFile file) throws Throwable {
+										  HttpServletResponse response, @RequestPart MultipartFile file) throws Throwable {
 		List<CSVRecord> records = FileUtil.readFile(file);
 		for (CSVRecord record : records) {
 			if (Integer.parseInt(record.get(0)) == 0) {
+	}
 	@RequestMapping(value = "/extendCustomerOffer", method = RequestMethod.POST)
 	public String extendCustomerOffer(HttpServletRequest request, @RequestParam int id,
-			@RequestParam LocalDateTime endDate, Model model) throws ProfitMandiBusinessException {
+									  @RequestParam LocalDateTime endDate, Model model) throws ProfitMandiBusinessException {
 		CustomerOffer co = customerOfferRepository.selectById(id);
 		co.setEndDate(endDate);
 		co.setUpdatedTimestamp(LocalDateTime.now());

Subversion Repositories SmartDukaan

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