WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

 import javax.mail.MessagingException;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
 import java.io.*;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.sql.Timestamp;
+import java.text.DecimalFormat;
 import java.time.*;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoField;
 import java.time.temporal.ChronoUnit;
 import java.util.*;
 	private SDCreditService sdCreditService;
 	@Autowired
 	private SDCreditRequirementRepository sdCreditRequirementRepository;
+	@Autowired
+	private CurrentPartnerDailyInvestmentRepository currentPartnerDailyInvestmentRepository;
+	@Autowired
+	private TransactionRepository transactionRepository;
+	@Autowired
+	private CreditAccountRepository crediRepository;
 	public void calculateInterestAccured() throws ProfitMandiBusinessException {
 		List<Loan> loans = loanRepository.selectAllActiveLoan();
 		if (!loans.isEmpty()) {
 				Map<LoanReferenceType, Double> loanStatusAmount = loanStatements.stream().collect(Collectors.groupingBy(
 						x -> x.getLoanReferenceType(), Collectors.summingDouble(x -> x.getAmount().doubleValue())));
 				if (loan.getFreeDays() > 0) {
 					LocalDateTime freeDaysLimitDate = loan.getCreatedOn().plusDays(loan.getFreeDays() - 1);
+					LOGGER.info("freeDaysLimitDate {}", freeDaysLimitDate);
 					if (LocalDateTime.now().isAfter(freeDaysLimitDate)) {
+						int loanStatementId = loanStatementRepository.selectLatestLoanSatement(loan.getFofoId(),
+								loan.getId());
+						LOGGER.info("loanStatementId {}", loanStatementId);
+						if (loanStatementId != 0) {
+							this.calculateInterest(loan, loanStatusAmount, loanStatementId);
+						} else {
-						sdCreditService.calculateInterest(freeDaysLimitDate.toLocalDate(), LocalDate.now(), loan,
+							sdCreditService.addInterest(freeDaysLimitDate.toLocalDate(), LocalDate.now(), loan,
-								loanStatusAmount);
+									loanStatusAmount);
+						}
+					}
 				} else {
 					int loanStatementId = loanStatementRepository.selectLatestLoanSatement(loan.getFofoId(),
 							loan.getId());
-					LOGGER.info("loanStatementId {}", loanStatementId);
+					LOGGER.info("loanStatementId2 {}", loanStatementId);
-					LoanStatement loanStatement = loanStatementRepository.selectById(loanStatementId);
-					if (loanStatement.getLoanId() == loan.getId()) {
-						sdCreditService.calculateInterest(loanStatement.getCreatedAt().toLocalDate(), LocalDate.now(),
+					this.calculateInterest(loan, loanStatusAmount, loanStatementId);
-								loan, loanStatusAmount);
-					} else {
-						throw new ProfitMandiBusinessException("loanstament", loanStatement.getLoanId(),
-								"Invalid LoanId");
-					}
+				}
+			}
+		}
+	}
+	private void calculateInterest(Loan loan, Map<LoanReferenceType, Double> loanStatusAmount, int loanStatementId)
+			throws ProfitMandiBusinessException {
+		LoanStatement loanStatement = loanStatementRepository.selectById(loanStatementId);
+		if (loanStatement.getLoanId() == loan.getId()) {
+			sdCreditService.addInterest(loanStatement.getCreatedAt().toLocalDate(), LocalDate.now(), loan,
+					loanStatusAmount);
+		} else {
+			throw new ProfitMandiBusinessException("loanstament", loanStatement.getLoanId(), "Invalid LoanId");
+		}
+	}
 	public void loanSettlement() throws ProfitMandiBusinessException {
 		List<Loan> loans = loanRepository.selectAllActiveLoan();
 		if (!loans.isEmpty()) {
 	public void processActivatedImeisForSchemes() throws ProfitMandiBusinessException {
 		schemeService.processActivatedImeisForSchemes();
+	}
-	@Autowired
-	private CurrentPartnerDailyInvestmentRepository currentPartnerDailyInvestmentRepository;
-	@Autowired
-	private TransactionRepository transactionRepository;
-	@Autowired
-	private CreditAccountRepository crediRepository;
 	public void updatePartnerLimit() throws ProfitMandiBusinessException {
 		Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
 		Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream()
 				.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
 				sdCreditRequirement.setCreateTimestamp(LocalDateTime.now());
 				sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
 				sdCreditRequirementRepository.persist(sdCreditRequirement);
+			}
-			CreditRisk creditRisk = getCurrentRisk(sdCreditRequirement, firstBillingDate);
+			CreditRisk creditRisk = sdCreditService.getCurrentRisk(sdCreditRequirement, firstBillingDate);
 			sdCreditRequirement.setRisk(creditRisk);
 			sdCreditRequirement.setSuggestedLimit(suggestedAmount);
 			sdCreditRequirement.setLimit(suggestedAmount);
+		}
+	}
-	private static final List<CreditRisk> ORDERED_RISKS = Arrays.asList(CreditRisk.HIGH_RISK, CreditRisk.LOW_RISK,
-			CreditRisk.NO_RISK);
-	private CreditRisk getCurrentRisk(SDCreditRequirement sdCreditRequirement, LocalDateTime firstBillingDate) {
+	public void notifyDefaultLoans() throws ProfitMandiBusinessException, MessagingException, IOException {
-		CreditRisk currentRisk = sdCreditRequirement.getRisk();
-		long noOfDaysBetween = 0;
-		LocalDateTime riskDate = sdCreditRequirement.getRiskTimestamp() == null ? firstBillingDate
-				: sdCreditRequirement.getRiskTimestamp();
-		if (riskDate == null) {
-			return CreditRisk.HIGH_RISK;
-		} else {
-			noOfDaysBetween = ChronoUnit.DAYS.between(riskDate, LocalDateTime.now());
-			if (noOfDaysBetween < 90) {
-				return currentRisk;
-			} else if (noOfDaysBetween >= 90 && noOfDaysBetween < 180) {
-				return currentRisk.decrease();
-			} else {
-				return currentRisk.decrease();
-			}
+		sdCreditService.updateRisk();
+		List<Loan> defaultLoans = sdCreditService.getDefaultLoan();
+		if (!defaultLoans.isEmpty()) {
+			this.sendDefaultLoanAlert(defaultLoans);
+		}
+	}
-	public void setDefaultPartnersRisk()
+	public void sendDefaultLoanAlert(List<Loan> defaultLoans)
-			throws ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
+			throws ProfitMandiBusinessException, MessagingException, IOException {
-		List<Loan> loans = loanRepository.selectAllActiveLoan().stream()
+		String subject = "Default Partners";
-				.filter(x -> x.getDueDate().isBefore(LocalDateTime.now())).collect(Collectors.toList());
-		List<Loan> defaulterLoan = new ArrayList<>();
+		List<AuthUser> authUsers = csService
+				.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES);
+		if (!authUsers.isEmpty()) {
+			List<String> financeEmails = authUsers.stream().map(x -> x.getEmailId()).collect(Collectors.toList());
+			String messageText = this.getMessageForDueDateExtend(defaultLoans);
-		if (!loans.isEmpty()) {
-			for (Loan loan : loans) {
+			String[] email = financeEmails.toArray(new String[financeEmails.size()]);
-				SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository
+			this.sendMailHtmlFormat(email, messageText, null, subject);
-						.selectByFofoId(loan.getFofoId());
-				long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDateTime.now());
-				LOGGER.info("noOfdaysBetween {} ", noOfdaysBetween);
+		}
-				if (noOfdaysBetween > 30) {
-					CreditAccount creditAccount = crediRepository.selectByFofoIdAndGateway(loan.getFofoId(),
-							Gateway.SDDIRECT);
-					creditAccount.setActive(false);
-					sdCreditRequirement.setRisk(CreditRisk.HIGH_RISK);
-					sdCreditRequirement.setRiskTimestamp(LocalDateTime.now());
+		for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
+			List<Loan> filteredRows = new ArrayList<>();
-					defaulterLoan.add(loan);
+			for (Loan loan : defaultLoans) {
-				} else {
+				if (storeGuyEntry.getValue().contains(loan.getFofoId())) {
+					filteredRows.add(loan);
+				}
+			}
+			if (!filteredRows.isEmpty()) {
-					sdCreditRequirement.setRisk(sdCreditRequirement.getRisk().increase());
+				String messageText = this.getMessageForDueDateExtend(filteredRows);
+				String[] email = new String[] { storeGuyEntry.getKey() };
-					sdCreditRequirement.setRiskTimestamp(LocalDateTime.now());
+				this.sendMailHtmlFormat(email, messageText, null, subject);
-				}
+			}
+		}
-		if (!defaulterLoan.isEmpty()) {
+		for (Loan defaultLoan : defaultLoans) {
+			List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(defaultLoan.getId());
-			List<AuthUser> authUsers = csService
-					.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES);
-			List<String> allEmails = new ArrayList<>();
-			if (!authUsers.isEmpty()) {
-				List<String> financeEmails = authUsers.stream().map(x -> x.getEmailId()).collect(Collectors.toList());
+			double amount = loanStatements.stream().map(x -> x.getAmount())
-				allEmails.addAll(financeEmails);
+					.collect(Collectors.summingDouble(x -> x.doubleValue()));
-			}
-			for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
-				allEmails.add(storeGuyEntry.getKey());
+			String title = "Loan amount overdue!";
-				String subject = "Time Limit Cross";
+			String url = "http://app.smartdukaan.com/pages/home/credit";
-				String messageText = this.getMessageForDueDateExtend(defaulterLoan);
+			String message = "Your loan due date ("
-				MimeMessage message = mailSender.createMimeMessage();
+					+ defaultLoan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))
-				MimeMessageHelper helper = new MimeMessageHelper(message, true);
+					+ ") has been exceeded. Additional penal interest of " + defaultLoan.getInterestRate()
-				String[] email = allEmails.toArray(new String[allEmails.size()]);
+					+ "%  + Rs.100 shall be levied on daily basis. " + "Your total pending Loan amount is Rs."
-				helper.setSubject(subject);
-				helper.setText(messageText, true);
+					+ FormattingUtils.formatDecimal(Math.abs(amount)) + ". !!Pay Now!!";
-				helper.setTo(email);
-				InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
+			notificationService.sendNotification(defaultLoan.getFofoId(), title, MessageType.notification, title,
-				helper.setFrom(senderAddress);
-				mailSender.send(message);
+					message, url);
-			}
+		}
+	}
 	private String getMessageForDueDateExtend(List<Loan> loans) throws ProfitMandiBusinessException {
 		StringBuilder sb = new StringBuilder();
+		sb.append(
-		sb.append("<html><body><p>Alert</p><p>Time Limit Cross :-</p>"
+				"<html><body><p>Alert</p><p>Default Partners :-</p>" + "<br/><p>EveryDay Rs.100 charged as Penalty</p>"
-				+ "<br/><table style='border:1px solid black ;padding: 5px';>");
+						+ "<br/><table style='border:1px solid black ;padding: 5px';>");
 		sb.append("<tbody>\n" + "	    				<tr>\n"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>PartnerName</th>\n"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>due date</th>\n"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>Days</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Pending Amount</th>\n"
 				+ "	    				</tr>");
 		for (Loan entry : loans) {
+			List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(entry.getId());
+			double amount = loanStatements.stream().map(x -> x.getAmount())
+					.collect(Collectors.summingDouble(x -> x.doubleValue()));
 			long noOfdaysBetween = ChronoUnit.DAYS.between(entry.getDueDate().toLocalDate(), LocalDateTime.now());
 			CustomRetailer customRetailer = retailerService.getFofoRetailer(entry.getFofoId());
 			sb.append("<tr>");
 					+ customRetailer.getCode() + ")" + "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>"
 					+ entry.getDueDate().format(DateTimeFormatter.ofPattern("dd/MM/yyyy")) + "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>" + noOfdaysBetween + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>"
+					+ new DecimalFormat("#.##").format(Math.abs(amount)) + "</td>");
 			sb.append("</tr>");
+		}
 		sb.append("</tbody></table></body></html>");
 		return sb.toString();
+	}
+	public void notifyLoanDueDateCross() throws ProfitMandiBusinessException, MessagingException, IOException {
+		List<Loan> loans = loanRepository.selectAllActiveLoan().stream()
+				.filter(x -> x.getDueDate().isBefore(LocalDateTime.now())).collect(Collectors.toList());
+		if (!loans.isEmpty()) {
+			for (Loan loan : loans) {
+				long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDate.now());
+				LOGGER.info("noOfdaysBetween {} ", noOfdaysBetween);
+				if (noOfdaysBetween <= 15 && noOfdaysBetween >= 0) {
+					List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
+					double amount = loanStatements.stream().map(x -> x.getAmount())
+							.collect(Collectors.summingDouble(x -> x.doubleValue()));
+					String title = "Alert! Credit o/s";
+					String url = "http://app.smartdukaan.com/pages/home/credit";
+					String message = "Your loan due date ("
+							+ loan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))
+							+ ") has been exceeded. Additional penal interest of " + loan.getInterestRate()
+							+ "% shall be levied on daily basis. Your total pending Loan amount is Rs."
+							+ FormattingUtils.formatDecimal(Math.abs(amount)) + ". !!Pay Now!!";
+					notificationService.sendNotification(loan.getFofoId(), title, MessageType.notification, title,
+							message, url);
+				}
+			}
+		}
+	}
+	public void alertForDueDate() throws ProfitMandiBusinessException, MessagingException, IOException {
+		List<Loan> loans = loanRepository.selectAllActiveLoan();
+		if (!loans.isEmpty()) {
+			for (Loan loan : loans) {
+				long noOfdaysBetween = ChronoUnit.DAYS.between(LocalDate.now(), loan.getDueDate().toLocalDate());
+				LOGGER.info("noOfdaysBetween {} ", noOfdaysBetween);
+				if (noOfdaysBetween <= 4 && noOfdaysBetween >= 0) {
+					List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
+					double amount = loanStatements.stream().map(x -> x.getAmount())
+							.collect(Collectors.summingDouble(x -> x.doubleValue()));
+					String title = "Alert! Credit o/s";
+					String url = "http://app.smartdukaan.com/pages/home/credit";
+					String message = null;
+					if (noOfdaysBetween == 0) {
+						message = "Your total pending Loan amount is Rs."
+								+ FormattingUtils.formatDecimal(Math.abs(amount)) + " is due for Today, Pay Now!!";
+					} else {
+						message = "Your total pending Loan amount is Rs."
+								+ FormattingUtils.formatDecimal(Math.abs(amount)) + " is due by "
+								+ loan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))
+								+ ", Pay Now!!";
+					}
+					notificationService.sendNotification(loan.getFofoId(), title, MessageType.notification, title,
+							message, url);
+				}
+			}
+		}
+	}
+}
 //2284

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 30934 → 30936