Compare commits

...

5 Commits

Author SHA1 Message Date
VivianDee 4e4dd23e0e Update loan_status.py 2025-12-11 06:03:09 -05:00
ameye d23a088c84 Merge branch 'fix_loan_limit_response' of DigiFi/digifi-BankToProductCore into master 2025-11-28 10:25:16 +00:00
VivianDee c2eb7fa21a Update eligibility_check.py 2025-11-25 15:52:18 +01:00
ameye 53555a178a Merge branch 'status_update' of DigiFi/digifi-BankToProductCore into master 2025-11-21 02:55:24 +00:00
Chinenye Nmoh e6d4a441b2 added loan_repayment_schedule 2025-11-20 21:17:32 +01:00
5 changed files with 20 additions and 9 deletions
+2 -1
View File
@@ -1,2 +1,3 @@
from .transaction_type import TransactionType
from .loan_status import LoanStatus
from .loan_status import LoanStatus
from .repayment_schedule_status import RepaymentScheduleStatus
@@ -0,0 +1,6 @@
from enum import Enum
class RepaymentScheduleStatus(str, Enum):
ACTIVE = "active"
PARTIALLY_PAID = "partially_paid"
REPAID = "repaid"
+7 -7
View File
@@ -56,13 +56,13 @@ class EligibilityCheckService(BaseService):
if current_loan:
logger.info(f"Account {current_loan.account_id} has active loan {current_loan}")
if current_loan.product_id =='3MPC':
return ResponseHelper.error(result_description="Max loan count for 3MPC reached")
return ResponseHelper.error(result_description="CUSTOMER HAS EXCEEDED THE NUMBER OF DISBURSALS: Disbursal Count 1")
# Determine Loan count
is_eligible = EligibilityCheckService.check_loan_limits(customer_id)
is_eligible, count = EligibilityCheckService.check_loan_limits(customer_id)
if not is_eligible:
return ResponseHelper.error(result_description="Max loan count reached")
return ResponseHelper.error(result_description=f"CUSTOMER HAS EXCEEDED THE NUMBER OF DISBURSALS FOR THE DAY: Disbursal Count Today {count}")
# Call RACCheck
response = SimbrellaIntegration.rac_check(
@@ -189,14 +189,14 @@ class EligibilityCheckService(BaseService):
loan = Loan.get_customer_last_loan(customer_id)
if not loan:
return True
return True, 0
offer_id = loan.offer_id[:5]
offer = Offer.get_offer_by_id(offer_id)
if not offer:
logger.error(f"Offer not found for offer_id: {offer_id} (customer_id: {customer_id})")
return False
return False, 0
daily_count = Loan.get_daily_loan_count(customer_id, offer.product_id)
@@ -204,7 +204,7 @@ class EligibilityCheckService(BaseService):
logger.info(f"daily_count: {daily_count}, Max: {offer.max_daily_loans}")
if offer.max_daily_loans is not None and daily_count >= offer.max_daily_loans:
return False
return False, daily_count
return True
return True, daily_count
+2 -1
View File
@@ -45,7 +45,8 @@ class LoanStatusService(BaseService):
# Get loans
customer_loans = customer.loans
loans = [
loan.to_dict()
{**loan.to_dict(), "status": LoanStatus.ACTIVE} if loan.status in [LoanStatus.START_REPAY, LoanStatus.ACTIVE_PARTIAL]
else loan.to_dict()
for loan in customer_loans
if loan.status in [LoanStatus.ACTIVE, LoanStatus.START_REPAY, LoanStatus.ACTIVE_PARTIAL]
]
+3
View File
@@ -3,6 +3,7 @@ from app.extensions import db
from sqlalchemy.orm import relationship
from dateutil.relativedelta import relativedelta
from sqlalchemy.sql import func
from app.api.enums.repayment_schedule_status import RepaymentScheduleStatus
class LoanRepaymentSchedule(db.Model):
__tablename__ = 'loan_repayment_schedules'
@@ -51,6 +52,7 @@ class LoanRepaymentSchedule(db.Model):
installment_amount=round(loan.installment_amount, 2),
product_id = loan.product_id,
transaction_id = transaction_id,
paid_status = RepaymentScheduleStatus.ACTIVE,
created_at=datetime.now(timezone.utc),
updated_at=datetime.now(timezone.utc)
)
@@ -70,6 +72,7 @@ class LoanRepaymentSchedule(db.Model):
'interestAmount': self.interest_amount,
'totalInstallment': self.total_installment,
'paid': self.paid,
'paidStatus': self.paid_status,
'paidAt': self.paid_at.isoformat() if self.paid_at else None
}