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

 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
+import com.spice.profitmandi.common.model.FocusedModelShortageModel;
 import com.spice.profitmandi.dao.entity.user.Refferal;
 import com.spice.profitmandi.dao.entity.user.RefferalMonthlyAmount;
 import com.spice.profitmandi.dao.entity.user.User;
 import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
 import com.spice.profitmandi.dao.model.DateRangeModel;
 			refferal.setStatus(RefferalStatus.validate);
 			refferal.setUpdatedTimestamp(LocalDateTime.now());
 			refferalRepository.persist(refferal);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+			String subject = "Referral Approval Request for " + refferal.getRefereeEmail();
+			String messageText = this.getMessageForReferral(refferal);
+			MimeMessage message = mailSender.createMimeMessage();
+			MimeMessageHelper helper = new MimeMessageHelper(message, true);
+			String[] email = { "tarun.verma@smartdukaan.com", "tejbeer.kaur@shop2020.in" };
+			helper.setSubject(subject);
+			helper.setText(messageText, true);
+			helper.setTo(email);
+			InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
+			helper.setFrom(senderAddress);
+			mailSender.send(message);
 		} else {
 			model.addAttribute("response", mvcResponseSender.createResponseString(false));
+		}
 		return "response";
+	}
+	private String getMessageForReferral(Refferal referral) {
+		StringBuilder sb = new StringBuilder();
+		sb.append("<html><body><p>Alert</p><p> Referral Requests:-</p>"
+				+ "<br/><table style='border:1px solid black ;padding: 5px';>");
+		sb.append("<tbody>\n" + "	    				<tr>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>RefereeName</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Referee Email</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Referral Name</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Refferal Mobile</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>city</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>state</th>\n"
+				+ "	    				</tr>");
+		sb.append("<tr>");
+		sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeName() + "</td>");
+		sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeEmail() + "</td>");
+		sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getFirstName() + "</td>");
+		sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getMobile() + "</td>");
+		sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getCity() + "</td>");
+		sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getState() + "</td>");
+		sb.append("</tr>");
+		sb.append("</tbody></table></body></html>");
+		return sb.toString();
+	}
 	@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);
 			refferal.setStatus(RefferalStatus.approved);
 			refferal.setUpdatedTimestamp(LocalDateTime.now());
 			refferal.setApprovedTimestamp(LocalDateTime.now());
 			refferalRepository.persist(refferal);
-			String subject = "Refferal Request Approved for " + refferal.getRefereeEmail();
+			String subject = "Referral Request Approved for " + refferal.getRefereeEmail();
-			String messageText = "Request Approved for" + refferal.getRefereeEmail();
+			String messageText = this.getMessageForReferral(refferal);
 			this.sendMailWithAttachments(subject, messageText);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		} else {
+	}
 	private void sendMailWithAttachments(String subject, String messageText) throws Exception {
 		MimeMessage message = mailSender.createMimeMessage();
 		MimeMessageHelper helper = new MimeMessageHelper(message, true);
-		String[] email = { "neerajgupta2021@gmail.com" };
+		String[] email = { "neeraj.gupta@smartdukaan.com" };
 		helper.setSubject(subject);
-		helper.setText(messageText);
+		helper.setText(messageText, true);
 		helper.setTo(email);
 		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
 		helper.setFrom(senderAddress);
 		mailSender.send(message);
+	}
 	@RequestMapping(value = "/approvedRefferals", method = RequestMethod.GET)
 	public String approvedRefferals(HttpServletRequest request, Model model) throws Exception {
-		Map<String, Long> pastApproved = null;
+		Map<String, Long> pastApprovedCountMap = null;
+		List<Refferal> pastrefferal = null;
 		DateRangeModel drm = new DateRangeModel();
 		drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
 		drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
 		List<Refferal> previousMonthapprovedRefferal = refferalRepository
 		List<Refferal> preCurrMonthapproved = refferalRepository
 				.selectByStatusAndDateRange(RefferalStatus.approved, drm).stream()
 				.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
 		preCurrMonthapproved.addAll(previousMonthapprovedRefferal);
+		LOGGER.info("preCurrMonthapproved" + preCurrMonthapproved);
 		Map<String, Long> preApproved = preCurrMonthapproved.stream()
 				.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
 		drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(1));
 		drm.setEndDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
 		List<Refferal> oldPreMonthapproved = refferalRepository.selectByStatusAndDateRange(RefferalStatus.approved, drm)
 				.stream().filter(x -> x.getCreatedTimestamp().isBefore(previousMonthdate)).collect(Collectors.toList());
 		oldPreMonthapproved.addAll(oldMonthapprovedRefferal);
+		LOGGER.info("oldPreMonthapproved" + oldPreMonthapproved);
 		Map<String, Long> oldApproved = oldPreMonthapproved.stream()
 				.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
 		LOGGER.info("preApproved" + preApproved);
 		if (preApproved.isEmpty() && oldApproved.isEmpty()) {
-			pastApproved = refferalRepository.selectByStatus(RefferalStatus.approved).stream()
+			pastrefferal = refferalRepository.selectByStatus(RefferalStatus.approved);
+			pastApprovedCountMap = pastrefferal.stream()
 					.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
+		}
+		LOGGER.info("refferal" + pastrefferal);
 		LOGGER.info("oldApproved" + oldApproved);
-		LOGGER.info("pastApproved" + pastApproved);
+		LOGGER.info("pastApproved" + pastApprovedCountMap);
 		model.addAttribute("oldMonth", LocalDateTime.now().minusMonths(2).getMonth());
 		model.addAttribute("oldApproved", oldApproved);
+		model.addAttribute("oldPreMonthapproved", oldPreMonthapproved);
 		model.addAttribute("previousMonth", LocalDateTime.now().minusMonths(1).getMonth());
-		model.addAttribute("pastApproved", pastApproved);
+		model.addAttribute("pastApproved", pastApprovedCountMap);
+		model.addAttribute("pastrefferal", pastrefferal);
 		model.addAttribute("preApproved", preApproved);
+		model.addAttribute("preCurrMonthapproved", preCurrMonthapproved);
 		return "refferal-approve";
+	}
 	@RequestMapping(value = "/addMoneyToWallet", method = RequestMethod.POST)
 			rfm.setAmount(amount);
 			rfm.setCount(count);
 			rfm.setRefereeEmail(user.getEmailId());
 			rfm.setCreatedTimstamp(LocalDateTime.now());
 			refferalMonthlyAmountRepository.persist(rfm);
-			walletService.addAmountToWallet(user.getId(), rfm.getId(), WalletReferenceType.CASHBACK,
+			walletService.addAmountToWallet(user.getId(), rfm.getId(), WalletReferenceType.REFERRAL_INCENTIVES,
 					count + "referral of" + month + "Month", amount, LocalDateTime.now());
 			DateRangeModel drm = new DateRangeModel();
 			drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
 			drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));

Subversion Repositories SmartDukaan

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