Endpoint to fetch delinquent payments for a loan

dao/src/main/java/org/corefin/dao/LoanInstallmentDao.java

@@ -2,11 +2,10 @@
 
 import org.corefin.dao.mappers.LoanInstallmentMapper;
 import org.corefin.dto.LoanInstallmentDto;
+import org.corefin.model.common.InstallmentStatus;
 import org.jdbi.v3.core.Handle;
 import org.jdbi.v3.core.Jdbi;
 
-import java.time.ZonedDateTime;
-import java.util.ArrayList;
 import java.util.List;
 
 public class LoanInstallmentDao implements BaseDao<LoanInstallmentDto> {
@@ -74,6 +73,16 @@ public List<LoanInstallmentDto> findByLoanId(String loanId) {
                         .list()
         );
     }
+
+    public List<LoanInstallmentDto> findPastDueByLoanIdAndStatus(String loanId, InstallmentStatus status) {
+        return jdbi.withHandle(
+                handle -> handle.createQuery("SELECT * FROM loan_installment WHERE loan_id= :loan_id AND status = :status AND due_date < CURDATE()")
+                        .bind("loan_id", loanId)
+                        .bind("status", status.toString())
+                        .mapTo(LoanInstallmentDto.class)
+                        .list()
+        );
+    }
     public void updateInstallmentForPayment(LoanInstallmentDto loanInstallmentDto) {
         String updateQuery = """
                 UPDATE loan_installment set

dao/src/main/java/org/corefin/dao/PaymentDao.java

@@ -1,8 +1,6 @@
 package org.corefin.dao;
 
-import org.corefin.calculator.model.Payment;
 import org.corefin.dao.mappers.PaymentMapper;
-import org.corefin.dto.LoanInstallmentDto;
 import org.corefin.dto.PaymentDto;
 import org.jdbi.v3.core.Jdbi;
 
@@ -33,7 +31,7 @@ INSERT INTO payment(
         jdbi.useHandle(
                 handle -> {
                     handle.createUpdate(insertQuery)
-                            .bind("loan_id", dto.loandId())
+                            .bind("loan_id", dto.loanId())
                             .bind("amount", dto.amount())
                             .bind("payment_type", dto.paymentType().toString())
                             .bind("payment_datetime", dto.paymentDateTime())

dao/src/main/java/org/corefin/dto/PaymentDto.java

@@ -8,7 +8,7 @@
 
 public record PaymentDto(
         String paymentId,
-        String loandId,
+        String loanId,
         BigDecimal amount,
         PaymentType paymentType,
         ZonedDateTime paymentDateTime

server/src/main/java/com/corefin/server/v1/LoanResource.java

@@ -1,7 +1,7 @@
 package com.corefin.server.v1;
 
 import com.corefin.server.v1.request.CreateLoanRequest;
-import com.corefin.server.v1.request.MakePaymentRequest;
+import com.corefin.server.v1.response.GetInstallmentsResponse;
 import com.corefin.server.v1.response.GetLoanResponse;
 import com.corefin.server.v1.response.GetLoansResponse;
 import org.springframework.stereotype.Component;
@@ -51,4 +51,11 @@ public GetLoanResponse getLoan(@PathParam("loanId") String loanId) {
         LOGGER.info("getLoan called for loan with id %s".formatted(loanId));
         return loanResourceManager.doGetLoan(loanId);
     }
+
+    @GET
+    @Path("/{loanId}/installments/pastDue")
+    public GetInstallmentsResponse getPastDueInstallments(@PathParam("loanId") String loanId) {
+        LOGGER.info("getPastDueInstallments called for loan with id %s".formatted(loanId));
+        return loanResourceManager.doGetPastDueInstallments(loanId);
+    }
 }

server/src/main/java/com/corefin/server/v1/LoanResourceManager.java

@@ -4,6 +4,7 @@
 import com.corefin.server.transform.LoanTransformer;
 import com.corefin.server.v1.model.LoanInfo;
 import com.corefin.server.v1.request.CreateLoanRequest;
+import com.corefin.server.v1.response.GetInstallmentsResponse;
 import com.corefin.server.v1.response.GetLoanResponse;
 import com.corefin.server.v1.response.GetLoansResponse;
 import org.corefin.calculator.Actuarial365Calculator;
@@ -12,6 +13,7 @@
 import org.corefin.dao.LoanInstallmentDao;
 import org.corefin.dto.LoanDto;
 import org.corefin.dto.LoanInstallmentDto;
+import org.corefin.model.common.InstallmentStatus;
 import org.corefin.model.common.LoanStatus;
 import org.springframework.stereotype.Service;
 
@@ -20,7 +22,6 @@
 import java.util.UUID;
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 @Service
 public class LoanResourceManager {
@@ -64,6 +65,11 @@ public GetLoansResponse doGetLoans() {
         );
     }
 
+    public GetInstallmentsResponse doGetPastDueInstallments(String loanId) {
+        List<LoanInstallmentDto> dueInstallments = loanInstallmentDao.findPastDueByLoanIdAndStatus(loanId, InstallmentStatus.OWED);
+        return new GetInstallmentsResponse(dueInstallments);
+    }
+
     public GetLoanResponse createLoan(CreateLoanRequest createLoanRequest) {
         String loanId = UUID.randomUUID().toString();
         LoanDto loanDto = new LoanDto(

server/src/main/java/com/corefin/server/v1/response/GetInstallmentsResponse.java

@@ -0,0 +1,9 @@
+package com.corefin.server.v1.response;
+
+import org.corefin.dto.LoanInstallmentDto;
+
+import java.util.List;
+
+public record GetInstallmentsResponse(
+        List<LoanInstallmentDto> installments
+) {}