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

 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collector;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import org.apache.logging.log4j.LogManager;
+		}
 		return "refferal-paginated";
+	}
+	@RequestMapping(value = "/getValidateRefferals", method = RequestMethod.GET)
+	public String getValidateRefferals(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
+		List<Refferal> refferals = null;
+		long size = 0;
+		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.validate);
+		LOGGER.info("refferals" + refferals);
+		size = refferalRepository.selectCountByStatus(RefferalStatus.validate);
+		if (!refferals.isEmpty()) {
+			model.addAttribute("refferals", refferals);
+			model.addAttribute("start", offset + 1);
+			model.addAttribute("rStatus", "validate");
+			model.addAttribute("size", size);
+			model.addAttribute("url", "/getPaginatedValidateRefferals");
+			if (refferals.size() < limit) {
+				model.addAttribute("end", offset + refferals.size());
+			} else {
+				model.addAttribute("end", offset + limit);
+			}
+		} else {
+			model.addAttribute("refferals", refferals);
+			model.addAttribute("size", size);
+		}
+		return "refferal";
+	}
+	@RequestMapping(value = "/getPaginatedValidateRefferals", method = RequestMethod.GET)
+	public String getPaginatedValidateRefferals(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
+		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
+		List<Refferal> refferals = null;
+		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.validate);
+		LOGGER.info("refferals" + refferals);
+		if (!refferals.isEmpty()) {
+			model.addAttribute("refferals", refferals);
+			model.addAttribute("rStatus", "validate");
+			model.addAttribute("url", "/getPaginatedValidateRefferals");
+		} else {
+			model.addAttribute("refferals", refferals);
+		}
+		return "refferal-paginated";
+	}
+	@RequestMapping(value = "/validateRefferal", method = RequestMethod.PUT)
+	public String validateRefferal(HttpServletRequest request,
+			@RequestParam(name = "refferalId", defaultValue = "0") int refferalId, Model model) throws Exception {
+		Refferal refferal = refferalRepository.selectById(refferalId);
+		if (refferal.getStatus().equals(RefferalStatus.pending)) {
+			refferal.setStatus(RefferalStatus.validate);
+			refferal.setUpdatedTimestamp(LocalDateTime.now());
+			refferalRepository.persist(refferal);
+			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		} else {
+			model.addAttribute("response", mvcResponseSender.createResponseString(false));
+		}
+		return "response";
+	}
 	@RequestMapping(value = "/approveRefferal", method = RequestMethod.PUT)
 	public String approveRefferal(HttpServletRequest request,
 			@RequestParam(name = "refferalId", defaultValue = "0") int refferalId, Model model) throws Exception {
 		Refferal refferal = refferalRepository.selectById(refferalId);
-		if (refferal.getStatus().equals(RefferalStatus.pending)) {
+		if (refferal.getStatus().equals(RefferalStatus.validate)) {
 			refferal.setStatus(RefferalStatus.approved);
 			refferal.setUpdatedTimestamp(LocalDateTime.now());
 			refferal.setApprovedTimestamp(LocalDateTime.now());
 			refferalRepository.persist(refferal);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
 	@RequestMapping(value = "/approvedRefferals", method = RequestMethod.GET)
 	public String approvedRefferals(HttpServletRequest request, Model model) throws Exception {
-		List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
-				.collect(Collectors.toList());
-		Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailerUserId(fofoIds);
-		String customRetailers = JSONObject.valueToString(customRetailersMap.values());
-		model.addAttribute("customRetailers", customRetailers);
-		return "refferal-approve";
-	}
-	@RequestMapping(value = "/getApprovedRefferals", method = RequestMethod.GET)
-	public String getApprovedRefferals(HttpServletRequest request, @RequestParam String refereeEmail, Model model)
-			throws Exception {
 		DateRangeModel drm = new DateRangeModel();
 		drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
 		drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
 		List<Refferal> previousMonthapprovedRefferal = refferalRepository
-				.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
+				.selectByStatusAndDateRanges(RefferalStatus.approved, drm);
 		drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
 		drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
-		List<Refferal> previousAndcurrentMonthapprovedRefferal = refferalRepository
-				.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
 		LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
-		List<Refferal> preCurrMonthapproved = previousAndcurrentMonthapprovedRefferal.stream()
+		List<Refferal> preCurrMonthapproved = refferalRepository
+				.selectByStatusAndDateRange(RefferalStatus.approved, drm).stream()
 				.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
+		preCurrMonthapproved.addAll(previousMonthapprovedRefferal);
-		long approvedRefferalCount = previousMonthapprovedRefferal.size() + preCurrMonthapproved.size();
-		List<Refferal> approvedRefferals = new ArrayList<>(previousMonthapprovedRefferal);
-		approvedRefferals.addAll(preCurrMonthapproved);
+		Map<String, Long> preApproved = preCurrMonthapproved.stream()
-		long refferalAmount = 0;
-		if (approvedRefferalCount <= 4) {
-			refferalAmount = approvedRefferalCount * 5000;
-		} else if (approvedRefferalCount >= 5 && approvedRefferalCount <= 9) {
+				.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
-			refferalAmount = approvedRefferalCount * 10000;
-		} else if (approvedRefferalCount > 10) {
-			refferalAmount = approvedRefferalCount * 200000;
-		}
 		drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(1));
 		drm.setEndDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
+		LocalDateTime previousMonthdate = LocalDateTime.now().minusMonths(1).withDayOfMonth(1);
-		List<Refferal> oldMonthapprovedRefferal = refferalRepository.selectByEmailIdAndStatusAndDateRanges(refereeEmail,
+		List<Refferal> oldMonthapprovedRefferal = refferalRepository
-				RefferalStatus.approved, drm);
+				.selectByStatusAndDateRanges(RefferalStatus.approved, drm);
 		drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
 		drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
-		List<Refferal> oldAndpreviousMonthapprovedRefferal = refferalRepository
-				.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
-		LocalDateTime previousMonthdate = LocalDateTime.now().minusMonths(1).withDayOfMonth(1);
-		List<Refferal> oldPreMonthapproved = oldAndpreviousMonthapprovedRefferal.stream()
-				.filter(x -> x.getCreatedTimestamp().isBefore(previousMonthdate)).collect(Collectors.toList());
-		long oldMonthapprovedRefferalCount = oldMonthapprovedRefferal.size() + oldPreMonthapproved.size();
-		List<Refferal> oldMonthapprovedRefferals = new ArrayList<>(oldMonthapprovedRefferal);
+		List<Refferal> oldPreMonthapproved = refferalRepository.selectByStatusAndDateRange(RefferalStatus.approved, drm)
-		oldMonthapprovedRefferals.addAll(oldPreMonthapproved);
-		long oldRefferalAmount = 0;
-		if (oldMonthapprovedRefferalCount <= 4) {
-			oldRefferalAmount = oldMonthapprovedRefferalCount * 5000;
-		} else if (oldMonthapprovedRefferalCount >= 5 && oldMonthapprovedRefferalCount <= 9) {
+				.stream().filter(x -> x.getCreatedTimestamp().isBefore(previousMonthdate)).collect(Collectors.toList());
-			oldRefferalAmount = oldMonthapprovedRefferalCount * 10000;
-		} else if (oldMonthapprovedRefferalCount > 10) {
-			oldRefferalAmount = oldMonthapprovedRefferalCount * 200000;
-		}
+		oldPreMonthapproved.addAll(oldMonthapprovedRefferal);
+		Map<String, Long> oldApproved = oldPreMonthapproved.stream()
+				.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
+		LOGGER.info("preApproved" + preApproved);
+		LOGGER.info("oldApproved" + oldApproved);
 		model.addAttribute("oldMonth", LocalDateTime.now().minusMonths(2).getMonth());
-		model.addAttribute("oldMonthapprovedRefferals", oldMonthapprovedRefferals);
-		model.addAttribute("oldMonthapprovedRefferalCount", oldMonthapprovedRefferalCount);
-		model.addAttribute("oldRefferalAmount", oldRefferalAmount);
+		model.addAttribute("oldApproved", oldApproved);
 		model.addAttribute("previousMonth", LocalDateTime.now().minusMonths(1).getMonth());
-		model.addAttribute("approvedRefferals", approvedRefferals);
-		model.addAttribute("approvedRefferalCount", approvedRefferalCount);
-		model.addAttribute("refferalAmount", refferalAmount);
+		model.addAttribute("preApproved", preApproved);
-		return "refferal-approve-info";
+		return "refferal-approve";
+	}
 	@RequestMapping(value = "/addMoneyToWallet", method = RequestMethod.POST)
 	public String addMoneyToWallet(HttpServletRequest request, @RequestParam String refereeEmail,
 			@RequestParam int count, @RequestParam int amount, @RequestParam String month, Model model)
 		User user = userRepository.selectByEmailId(refereeEmail);
 		if (user != null) {
 			RefferalMonthlyAmount rfm = new RefferalMonthlyAmount();
 			rfm.setAmount(amount);
 			rfm.setCount(count);
-			rfm.setRefereeEmail(refereeEmail);
+			rfm.setRefereeEmail(user.getEmailId());
 			rfm.setCreatedTimstamp(LocalDateTime.now());
 			refferalMonthlyAmountRepository.persist(rfm);
 			walletService.addAmountToWallet(user.getId(), rfm.getId(), WalletReferenceType.CASHBACK,
 					count + "refferal of" + month + "Month", amount);
 			DateRangeModel drm = new DateRangeModel();
 			drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
 			drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
 			List<Refferal> previousMonthapprovedRefferal = refferalRepository
-					.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
+					.selectByEmailIdAndStatusAndDateRanges(user.getEmailId(), RefferalStatus.approved, drm);
 			drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
 			drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
 			List<Refferal> previousAndcurrentMonthapprovedRefferal = refferalRepository
-					.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
+					.selectByEmailIdAndStatusAndDateRange(user.getEmailId(), RefferalStatus.approved, drm);
 			LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
 			List<Refferal> preCurrMonthapproved = previousAndcurrentMonthapprovedRefferal.stream()
 					.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
 			List<Refferal> approvedRefferals = new ArrayList<>(previousMonthapprovedRefferal);
 			approvedRefferals.addAll(preCurrMonthapproved);
 		User user = userRepository.selectByEmailId(refereeEmail);
 		if (user != null) {
 			RefferalMonthlyAmount rfm = new RefferalMonthlyAmount();
 			rfm.setAmount(amount);
 			rfm.setCount(count);
-			rfm.setRefereeEmail(refereeEmail);
+			rfm.setRefereeEmail(user.getEmailId());
 			rfm.setCreatedTimstamp(LocalDateTime.now());
 			refferalMonthlyAmountRepository.persist(rfm);
 			walletService.addAmountToWallet(user.getId(), rfm.getId(), WalletReferenceType.CASHBACK,
 					count + "refferal of" + month + "Month", amount);
 			DateRangeModel drm = new DateRangeModel();
 			drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(1));
 			drm.setEndDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
 			List<Refferal> oldMonthapprovedRefferal = refferalRepository
-					.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
+					.selectByEmailIdAndStatusAndDateRanges(user.getEmailId(), RefferalStatus.approved, drm);
+			LOGGER.info("oldMonthapprovedRefferal" + oldMonthapprovedRefferal);
 			drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
 			drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
 			List<Refferal> oldAndpreviousMonthapprovedRefferal = refferalRepository
-					.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
+					.selectByEmailIdAndStatusAndDateRange(user.getEmailId(), RefferalStatus.approved, drm);
 			LocalDateTime previousMonthdate = LocalDateTime.now().minusMonths(1).withDayOfMonth(1);
 			List<Refferal> oldPreMonthapproved = oldAndpreviousMonthapprovedRefferal.stream()
 					.filter(x -> x.getCreatedTimestamp().isBefore(previousMonthdate)).collect(Collectors.toList());
-			List<Refferal> oldMonthapprovedRefferals = new ArrayList<>(oldMonthapprovedRefferal);
-			oldMonthapprovedRefferals.addAll(oldPreMonthapproved);
+			oldPreMonthapproved.addAll(oldMonthapprovedRefferal);
+			LOGGER.info("oldPreMonthapproved" + oldPreMonthapproved);
-			for (Refferal refferl : oldMonthapprovedRefferals) {
+			for (Refferal refferl : oldPreMonthapproved) {
 				refferl.setStatus(RefferalStatus.transferred);
 				refferl.setUpdatedTimestamp(LocalDateTime.now());
+			}
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/RefferalController.java – Rev 25497 → 25587