Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| e5b2d6e7b6 | |||
| 2a184d134d | |||
| 5e5f1b83ad | |||
| 2413446107 | |||
| ff5cbcc49d | |||
| 9f2daad7c8 |
@@ -51,6 +51,13 @@ class EligibilityCheckService(BaseService):
|
||||
|
||||
db.session.flush()
|
||||
|
||||
# Determine if there is any loan of 3MPC active
|
||||
current_loan = EligibilityCheckService.get_current_active_loans_by_account_id(account_id = account_id)
|
||||
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")
|
||||
|
||||
# Determine Loan count
|
||||
is_eligible = EligibilityCheckService.check_loan_limits(customer_id)
|
||||
|
||||
@@ -167,7 +174,12 @@ class EligibilityCheckService(BaseService):
|
||||
logger.error(f"An error occurred: {str(e)}", exc_info=True)
|
||||
db.session.rollback()
|
||||
return ResponseHelper.internal_server_error()
|
||||
|
||||
|
||||
@staticmethod
|
||||
def get_current_active_loans_by_account_id(account_id):
|
||||
current_loan = Loan.get_current_active_loans_by_account_id(account_id)
|
||||
return current_loan
|
||||
|
||||
|
||||
@staticmethod
|
||||
def check_loan_limits(customer_id):
|
||||
|
||||
@@ -18,6 +18,7 @@ from app.api.integrations import EventServiceIntegration
|
||||
from app.models import LoanRepaymentSchedule
|
||||
from app.api.services.offer_analysis import OfferAnalysis
|
||||
from app.api.helpers.response_helper import ResponseHelper
|
||||
from datetime import datetime
|
||||
|
||||
class ProvideLoanService(BaseService):
|
||||
TRANSACTION_TYPE = TransactionType.PROVIDE_LOAN
|
||||
@@ -113,9 +114,12 @@ class ProvideLoanService(BaseService):
|
||||
management = charges["management"]
|
||||
insurance = charges["insurance"]
|
||||
vat = charges["vat"]
|
||||
|
||||
# Generate Loan Reference
|
||||
loan_ref = f"SIM{datetime.now().strftime('%Y%m%d%H%M%S%f')}"
|
||||
|
||||
padded_id = str(transaction_id).zfill(12)
|
||||
loan_ref = f"{padded_id}{channel}{offer.product_id}"
|
||||
# padded_id = str(transaction_id).zfill(12)
|
||||
# loan_ref = f"{padded_id}{channel}{offer.product_id}"
|
||||
|
||||
|
||||
# Save the loan details
|
||||
|
||||
@@ -204,6 +204,21 @@ class Loan(db.Model):
|
||||
|
||||
return active_loans
|
||||
|
||||
@classmethod
|
||||
def get_current_active_loans_by_account_id(cls, account_id):
|
||||
"""
|
||||
Get the first active loan based on the accountID.
|
||||
"""
|
||||
first_active_loan = cls.query.filter(
|
||||
cls.account_id == account_id,
|
||||
or_(
|
||||
cls.status == LoanStatus.ACTIVE.value,
|
||||
cls.status == LoanStatus.START_REPAY.value,
|
||||
cls.status == LoanStatus.ACTIVE_PARTIAL.value,
|
||||
)
|
||||
).order_by(cls.id.desc()).first()
|
||||
|
||||
return first_active_loan
|
||||
|
||||
@classmethod
|
||||
def update_status(cls, loan_id, status):
|
||||
|
||||
Reference in New Issue
Block a user