This commit is contained in:
Chinenye Nmoh
2025-06-26 13:36:49 +01:00
parent 9feab46016
commit 79109af695
3 changed files with 10 additions and 3 deletions
+2 -2
View File
@@ -247,9 +247,9 @@ class Loan(db.Model):
"""
Get customer's active loans and sum by customer_id.
"""
customer_loans = cls.query.filter_by( customer_id = customer_id).all()
customer_loans = cls.query.filter_by( customer_id = customer_id, status='active').all()
if not customer_loans:
raise ValueError(f"Customer with Id {customer_id} does not have any loan.")
raise ValueError(f"Customer with Id {customer_id} does not have any active loan.")
total_amount = (
cls.query.with_entities(func.coalesce(func.sum(cls.balance), 0.0))
+1 -1
View File
@@ -168,7 +168,7 @@ def process_salary_list():
# Step 3.2: Get loans
try:
loans, total_amount = LoanService.get_customer_loans(pending_salary.customer_id)
loans, total_amount = LoanService.get_customer_active_loans(pending_salary.customer_id)
if not loans:
logger.warning(f"No loans found for customer ID: {pending_salary.customer_id}")
continue
+7
View File
@@ -77,6 +77,13 @@ class LoanService:
Get customer's active loans by customer_id.
"""
return Loan.get_customer_loans(customer_id=customer_id)
@classmethod
def get_customer_active_loans(cls, customer_id):
"""
Get customer's active loans by customer_id.
"""
return Loan.get_customer_loans(customer_id=customer_id)
@classmethod