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

 package com.spice.profitmandi.web.controller;
-import java.math.BigDecimal;
-import java.math.RoundingMode;
-import java.time.Duration;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.time.temporal.ChronoUnit;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Set;
-import java.util.stream.Collectors;
-import javax.servlet.http.HttpServletRequest;
-import javax.transaction.Transactional;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.mail.javamail.JavaMailSender;
-import org.springframework.stereotype.Controller;
-import org.springframework.ui.Model;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.dtr.CreditAccount;
 import com.spice.profitmandi.dao.entity.dtr.CreditStatus;
 import com.spice.profitmandi.dao.entity.fofo.CurrentPartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
-import com.spice.profitmandi.dao.entity.transaction.Loan;
+import com.spice.profitmandi.dao.entity.transaction.*;
-import com.spice.profitmandi.dao.entity.transaction.Order;
-import com.spice.profitmandi.dao.entity.transaction.SDCreditRequirement;
-import com.spice.profitmandi.dao.entity.transaction.SanctionRequest;
-import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.user.Address;
 import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
 import com.spice.profitmandi.dao.enumuration.transaction.LoanSummaryType;
 import com.spice.profitmandi.dao.enumuration.transaction.SanctionStatus;
-import com.spice.profitmandi.dao.model.FofoReportingModel;
+import com.spice.profitmandi.dao.model.*;
-import com.spice.profitmandi.dao.model.SDCreditResponseOut;
-import com.spice.profitmandi.dao.model.SanctionRequestModel;
-import com.spice.profitmandi.dao.model.SdCreditRequirementModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.cs.CsService1;
 import com.spice.profitmandi.dao.repository.dtr.CreditAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentPartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
-import com.spice.profitmandi.dao.repository.transaction.LoanRepository;
+import com.spice.profitmandi.dao.repository.transaction.*;
-import com.spice.profitmandi.dao.repository.transaction.LoanStatementRepository;
-import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
-import com.spice.profitmandi.dao.repository.transaction.SDCreditRequirementRepository;
-import com.spice.profitmandi.dao.repository.transaction.SanctionRequestRepository;
-import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.transaction.SDCreditService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.user.UserService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import javax.servlet.http.HttpServletRequest;
+import javax.transaction.Transactional;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.time.Duration;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.temporal.ChronoUnit;
+import java.util.*;
+import java.util.Map.Entry;
+import java.util.stream.Collectors;
 @Controller
 @Transactional(rollbackOn = Throwable.class)
 public class SDCreditController {
             List<Integer> fofoIds = sanctionRequests.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
             Map<Integer, Long> partnerCreditDaysMap = new HashMap<>();
             Map<Integer, Integer> partnerActiveLoanMap = new HashMap<>();
+            Map<Integer, Integer> partnerAverageCreditDaysMap = new HashMap<>();
             LocalDateTime curDate = LocalDate.now().atStartOfDay();
             Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
                     curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
             Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), 0, false);
             Map<Integer, Double> lmsSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
                     curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), 0, false);
+            List<Loan> loans = loanRepository.selectAllLoans(fofoIds, DateRangeModel.withStartDate(curDate.minusYears(2)));
+            Map<Integer, List<Loan>> partnerClosedLoansMap = loans.stream().filter(x -> x.getPendingAmount().equals(BigDecimal.ZERO)).collect(Collectors.groupingBy(x -> x.getFofoId()));
-            for (Integer fofoId : fofoIds) {
-                List<Loan> loans = loanRepository.selectActiveLoan(fofoId);
+            Map<Integer, List<Loan>> activeLoansMap = loans.stream().filter(x -> !x.getPendingAmount().equals(BigDecimal.ZERO)).collect(Collectors.groupingBy(x -> x.getFofoId()));
+            for (Integer fofoId : fofoIds) {
+                List<Loan> activeLoans = activeLoansMap.get(fofoId);
-                if (!loans.isEmpty()) {
+                if (activeLoans != null) {
-                    partnerActiveLoanMap.put(fofoId, loans.size());
+                    partnerActiveLoanMap.put(fofoId, activeLoans.size());
-                    Loan loan = loans.get(loans.size() - 1);
+                    Loan loan = activeLoans.get(0);
                     long daysBetween = Duration.between(loan.getCreatedOn(), LocalDateTime.now()).toDays();
                     partnerCreditDaysMap.put(fofoId, daysBetween);
+                }
-                model.addAttribute("partnerCreditDaysMap", partnerCreditDaysMap);
+                List<Loan> closedLoans = partnerClosedLoansMap.get(fofoId);
+                if (closedLoans != null) {
+                    long averageCreditDays = Math.round(closedLoans.stream().mapToLong(x -> Duration.between(x.getCreatedOn(),
+                            x.getSettledOn() == null ? x.getCreatedOn().plusDays(10) : x.getSettledOn()).toDays()).average().orElse(0.0));
-                model.addAttribute("partnerActiveLoanMap", partnerActiveLoanMap);
+                    partnerAverageCreditDaysMap.put(fofoId, (int) averageCreditDays);
+                }
+            }
+            model.addAttribute("partnerActiveLoanMap", partnerActiveLoanMap);
+            model.addAttribute("partnerCreditDaysMap", partnerCreditDaysMap);
+            model.addAttribute("partnerAverageCreditDaysMap", partnerAverageCreditDaysMap);
             Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
             Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/SDCreditController.java – Rev 32528 → 32681