Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;

import com.spice.profitmandi.service.transaction.SDCreditService;

import java.math.BigDecimal;

import java.math.RoundingMode;

		}

	}

	@Autowired

	private LoanRepository loanRepository;

	@Autowired

	private LoanStatementRepository loanStatementRepository;

	@Autowired

	private SDCreditService sdCreditService;

	@Autowired

	private SDCreditRequirementRepository sdCreditRequirementRepository;

	public void calculateInterestAccured() throws ProfitMandiBusinessException {

		List<Loan> loans = loanRepository.selectAllActiveLoan();

		if (!loans.isEmpty()) {

			for (Loan loan : loans) {

				List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());

				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);

					if (LocalDateTime.now().isAfter(freeDaysLimitDate)) {

						sdCreditService.calculateInterest(freeDaysLimitDate.toLocalDate(), LocalDate.now(), loan,

								loanStatusAmount);

					}

				} else {

					int loanStatementId = loanStatementRepository.selectLatestLoanSatement(loan.getFofoId(),

							loan.getId());

					LOGGER.info("loanStatementId {}", loanStatementId);

					LoanStatement loanStatement = loanStatementRepository.selectById(loanStatementId);

					if (loanStatement.getLoanId() == loan.getId()) {

						sdCreditService.calculateInterest(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()) {

			for (Loan loan : loans) {

				UserWallet userWallet = userWalletRepository.selectByRetailerId(loan.getFofoId());

				SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository

						.selectByFofoId(loan.getFofoId());

				if (userWallet.getAmount() >= 100) {

					List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());

					Map<LoanReferenceType, Double> loanStatusAmount = loanStatements.stream()

							.collect(Collectors.groupingBy(x -> x.getLoanReferenceType(),

									Collectors.summingDouble(x -> x.getAmount().doubleValue())));

					LOGGER.info("loanStatusAmount {}", loanStatusAmount);

					double interestAmount = loanStatusAmount.get(LoanReferenceType.INTEREST);

					double principalAmount = loanStatusAmount.get(LoanReferenceType.PRINCIPAL);

					double paidAmount = 0;

					if (userWallet.getAmount() > Math.abs(interestAmount)) {

						if (interestAmount != 0) {

							settledLoanStatement(LoanReferenceType.INTEREST, BigDecimal.valueOf(interestAmount),

									loan.getFofoId(), loan.getId(), "Amount adjusted against loan",

									LocalDateTime.now());

							loan.setInterestPaid(loan.getInterestPaid().add(BigDecimal.valueOf(interestAmount).abs()));

							paidAmount += Math.abs(interestAmount);

						}

						double userWalletAmount = userWallet.getAmount() - Math.abs(interestAmount);

						if (userWalletAmount > Math.abs(principalAmount) && principalAmount != 0) {

							settledLoanStatement(LoanReferenceType.PRINCIPAL, BigDecimal.valueOf(principalAmount),

									loan.getFofoId(), loan.getId(), "Amount adjusted against loan",

									LocalDateTime.now());

							double amount = userWalletAmount - Math.abs(principalAmount);

							paidAmount += Math.abs(principalAmount);

							userWallet.setAmount((int) amount);

							sdCreditRequirement.setAvailableLimit(sdCreditRequirement.getAvailableLimit()

									.add(BigDecimal.valueOf(principalAmount).abs()));

							sdCreditRequirement.setUtilizedAmount(sdCreditRequirement.getUtilizedAmount()

									.subtract(BigDecimal.valueOf(principalAmount).abs()));

							loan.setPendingAmount(BigDecimal.ZERO);

						} else if (principalAmount != 0) {

							settledLoanStatement(LoanReferenceType.PRINCIPAL, BigDecimal.valueOf(userWalletAmount),

									loan.getFofoId(), loan.getId(), "Amount adjusted against loan",

									LocalDateTime.now());

							paidAmount += Math.abs(userWalletAmount);

							sdCreditRequirement.setAvailableLimit(sdCreditRequirement.getAvailableLimit()

									.add(BigDecimal.valueOf(userWalletAmount)).abs());

							sdCreditRequirement.setUtilizedAmount(sdCreditRequirement.getUtilizedAmount()

									.subtract(BigDecimal.valueOf(userWalletAmount)).abs());

							userWallet.setAmount(0);

							loan.setPendingAmount(

									loan.getPendingAmount().subtract(BigDecimal.valueOf(userWalletAmount)));

						}

						createUserWalletHistory(userWallet.getId(), userWallet.getUserId(),

								WalletReferenceType.LOAN_REPAYMENT, loan.getId(), Math.abs(paidAmount));

					} else {

						settledLoanStatement(LoanReferenceType.INTEREST, BigDecimal.valueOf(userWallet.getAmount()),

								loan.getFofoId(), loan.getId(), "Amount adjusted against loan", LocalDateTime.now());

						paidAmount += Math.abs(userWallet.getAmount());

						createUserWalletHistory(userWallet.getId(), userWallet.getUserId(),

								WalletReferenceType.LOAN_REPAYMENT, loan.getId(), Math.abs(paidAmount));

						loan.setInterestPaid(

								loan.getInterestPaid().add(BigDecimal.valueOf(userWallet.getAmount()).abs()));

						userWallet.setAmount(0);

					}

				}

			}

	}

	private void settledLoanStatement(LoanReferenceType loanReferneceType, BigDecimal amount, int fofoId, int loanId,

			String description, LocalDateTime now) {

		sdCreditService.createLoanStatement(loanReferneceType, amount.abs(), fofoId, loanId, description,

				LocalDateTime.now());

	}

	private void createUserWalletHistory(int walletId, int userId, WalletReferenceType referenceType, int loanId,

			double interestAmount) {

		UserWalletHistory uwh = new UserWalletHistory();

		uwh.setWalletId(walletId);

		uwh.setFofoId(userId);

		uwh.setBusinessTimestamp(LocalDateTime.now());

		uwh.setReferenceType(referenceType);

		uwh.setReference(loanId);

		uwh.setTimestamp(LocalDateTime.now());

		uwh.setAmount((int) -(interestAmount));

		userWalletHistoryRepository.persist(uwh);

	}

	public void dailyLoanAlert() throws ProfitMandiBusinessException {

		List<Loan> loans = loanRepository.selectAllActiveLoan();

		Map<Integer, Double> partnerLoanAmount = new HashMap<>();

		if (!loans.isEmpty()) {

			for (Loan loan : loans) {

				List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());

				double amount = loanStatements.stream().map(x -> x.getAmount())

						.collect(Collectors.summingDouble(x -> x.doubleValue()));

				if (partnerLoanAmount.get(loan.getFofoId()) != null) {

					amount += partnerLoanAmount.get(loan.getFofoId());

					partnerLoanAmount.put(loan.getFofoId(), amount);

				} else {

					partnerLoanAmount.put(loan.getFofoId(), amount);

				}

			}

		}

		if (!partnerLoanAmount.isEmpty()) {

			for (Entry<Integer, Double> partnerLoanAmountEnrty : partnerLoanAmount.entrySet()) {

				int fofoId = partnerLoanAmountEnrty.getKey();

				String title = "Alert! Credit o/s";

				String url = "http://app.smartdukaan.com/pages/home/credit";

				String message = "Your total pending Loan amount is Rs."

						+ FormattingUtils.formatDecimal(Math.abs(partnerLoanAmountEnrty.getValue()));

				notificationService.sendNotification(fofoId, title, MessageType.notification, title, message, url);

			}

		}