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

 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.io.ByteArrayResource;
 import org.springframework.core.io.InputStreamSource;
-import org.springframework.data.redis.cache.RedisCacheManager;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.mail.javamail.MimeMessageHelper;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
     public void resetHardLimit() {
         sdCreditService.resetHardLimit();
+    }
+    /*public void processCashDiscount() throws ProfitMandiBusinessException {
+        System.out.println("processing cash discount");
+        List<Loan> loansSettledYesterday = loanRepository.selectLoansSettledOn(LocalDate.now().minusDays(1));
+        loansSettledYesterday.addAll(loanRepository.selectLoansSettledOn(LocalDate.now()));
+        Map<Integer, List<Loan>> partnerSettledLoans = loansSettledYesterday.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
+        for (Entry<Integer, List<Loan>> partnerLoans : partnerSettledLoans.entrySet()) {
+            List<Loan> fullCdLoans = partnerLoans.getValue().stream().filter(x -> x.getInvoiceNumber() != null && x.getDays() <= ProfitMandiConstants.LOAN_PARTIAL_CREDIT_DAYS).collect(toList());
+            List<Loan> partialCdLoans = partnerLoans.getValue().stream().filter(x -> x.getInvoiceNumber() != null && x.getDays() > ProfitMandiConstants.LOAN_PARTIAL_CREDIT_DAYS &&
+                    x.getDays() <= ProfitMandiConstants.LOAN_FULL_CREDIT_DAYS).collect(toList());
+            //List<Loan> noCdLoans = loanRepository.selectLoansDueByDays()
+            //
+            for (Loan fullCdLoan : fullCdLoans) {
+                LOGGER.info("FullCdLoan - {}", fullCdLoan);
+                schemeService.processFullCD(fullCdLoan.getInvoiceNumber());
+            }
+            for (Loan partialCdLoan : partialCdLoans) {
+                schemeService.processPartialCD(partialCdLoan.getInvoiceNumber());
+            }
+            *//*for (Loan noCdLoan : noCdLoans) {
+                schemeService.processNoCD(noCdLoan.getInvoiceNumber());
+            }*//*
+        }
+    }*/
     private class SaleRoles {
         private List<String> l1;
         private List<String> l2;
+        }
+    }
     public void test() throws Exception {
+        //Utils.sendMailWithAttachments( mailSender,"amit.gupta@smartdukaan.com", null, "Hello World!", "Test Mail", null);
+        //sdCreditService.updateRisk();
+        PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(175139309,
+                YearMonth.of(2025, 5).atDay(1));
+        System.out.println(partnerType);
+        System.out.println(partnerType.nextPartnerTypes());
-        this.whatsappTest();
+        //this.whatsappTest();
-        //this.reverseOppoPayout();
+        //this.reve();
         //this.rolloutOppoPayout();
         //this.debitLoanAmountFromWallet();
         //List<TotalLoanAmountDueModel> totalLoanAmountDueModels = loanRepository.getDueLoansByFofoId(175139438);
         //System.out.println(totalLoanAmountDueModels);
         //runOnceTasks.findCNDiff();
         System.out.println(getSuggestedLimit(600000d));
         System.out.println(getSuggestedLimit(700000d));
         System.out.println(getSuggestedLimit(1500000d));
         System.out.println(getSuggestedLimit(2000000d));
         System.out.println(getSuggestedLimit(2500000d));*/
+        //System.setProperty("https.protocols", "TLSv1.2");
+        /*URL url = new URL("https://www.howsmyssl.com/a/check");
+        HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
+        InputStream inputStream = conn.getInputStream();
+        byte[] responseBytes = toByteArray(inputStream);
+        String response = new String(responseBytes, "UTF-8");
+        System.out.println(response);
-        //Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@smartdukaan.com"}, null, "DTDC AWb", "PFA");
+        Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@smartdukaan.com"}, null, "DTDC AWb", "PFA");*/
+    }
+    public static byte[] toByteArray(InputStream input) throws IOException {
+        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+        int nRead;
+        byte[] data = new byte[16384];
+        while ((nRead = input.read(data, 0, data.length)) != -1) {
+            buffer.write(data, 0, nRead);
+        }
+        return buffer.toByteArray();
+    }
     private void whatsappTest() throws Exception {
         //liquidationService.processBids(ProfitMandiConstants.BID_CRON_ENUM.TODAY);
         Utils.sendMailWithAttachments(googleMailSender, new String[]{"ranu.rajput@smartdukaan.com"}, null, "Test Mail", "Mail is working");
     @Autowired
     private SanctionRequestRepository sanctionRequestRepository;
     public void calculateInterestAccured() throws ProfitMandiBusinessException {
-        List<Loan> loans = loanRepository.selectAllActiveLoan();
+        //List<Loan> loans = loanRepository.selectAllActiveLoan();
+        List<Loan> loans = Arrays.asList(loanRepository.selectByLoanId(52669));
         for (Loan loan : loans) {
             List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
             Map<LoanReferenceType, Double> loanStatusAmount = loanStatements.stream().collect(groupingBy(
                     x -> x.getLoanReferenceType(), Collectors.summingDouble(x -> x.getAmount().doubleValue())));
             int freeDays = loan.getFreeDays();
-            LocalDateTime freeDaysLimitDate = loan.getCreatedOn().plusDays(freeDays);
+            LocalDate freeDaysLimitDate = loan.getCreatedOn().plusDays(freeDays).toLocalDate();
-            LOGGER.info("freeDaysLimitDate {}", freeDaysLimitDate);
+            LOGGER.info("Loan id - {}, freeDaysLimitDate {}", loan.getId(), freeDaysLimitDate);
-            if (LocalDateTime.now().isAfter(freeDaysLimitDate)) {
+            if (LocalDate.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.addInterest(freeDaysLimitDate.toLocalDate(), LocalDate.now(), loan, loanStatusAmount);
+                    sdCreditService.addInterest(freeDaysLimitDate, LocalDate.now(), loan, loanStatusAmount);
+                }
+            }
+        }
+    }
     @Autowired
     FofoPaymentRepository fofoPaymentRepository;
     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);
+            sdCreditService.addInterest(loanStatement.getCreatedAt().toLocalDate().plusDays(1), LocalDate.now(), loan, loanStatusAmount);
         } else {
             throw new ProfitMandiBusinessException("loanstament", loanStatement.getLoanId(), "Invalid LoanId");
+        }
+    }
     public void loanSettlement() throws Exception {
-//        List<Loan> blockedLoans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.getFreeDays() >= 365).collect(toList());
-        List<Loan> loans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.getFreeDays() < 365).collect(toList());
+        List<Loan> loans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.canBeSettled()).collect(toList());
-        //Settle blocked loans only when normal loans are settled
-//        loans.addAll(blockedLoans);
-        //TODO:Remove this code
-        Loan specificLoan = loanRepository.selectByLoanId(20073);
-        loans.add(0, specificLoan);
         //TODO:Upto here
         if (!loans.isEmpty()) {
             for (Loan loan : loans) {
+                LOGGER.info("Loan - {},  {}", loan.getId(), loan.canBeSettled());
                 double settledAmount = sdCreditService.settleLoan(loan);
                 List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
                 for (SanctionRequest sanctionRequest : sanctionRequests) {
+            }
+        }
         String messageText = this.getMessageForDueDateCross(dueDateCrossLoans);
-        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com","sdtech@smartdukaan.com"}, messageText, null, "Due Date Cross");
+        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com", "sdtech@smartdukaan.com"}, messageText, null, "Due Date Cross");
         if (!dueDateCrossLoans.isEmpty()) {
             for (Loan loan : dueDateCrossLoans) {

Subversion Repositories SmartDukaan

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