added repayment_schedule
This commit was merged in pull request #43.
This commit is contained in:
Chinenye Nmoh
+66
-51
@@ -257,68 +257,83 @@ def report():
|
||||
logger.error(f"Error generating or sending report: {e}")
|
||||
return ResponseHelper.error("Failed to send report", status_code=500, error=str(e))
|
||||
|
||||
|
||||
@autocall_bp.route("/overdue-loans", methods=["GET"])
|
||||
def overdue_loans():
|
||||
try:
|
||||
# Step 1: Get all overdue loans
|
||||
loans = LoanService.get_overdue_loans()
|
||||
logger.info(f"Found {len(loans)} overdue loans.")
|
||||
|
||||
if not loans:
|
||||
return ResponseHelper.success(message="No overdue loans found", status_code=200)
|
||||
# Step 2: Create repayments for each loan
|
||||
|
||||
# Step 2: Process each loan
|
||||
for loan in loans:
|
||||
logger.info(f"Processing Loan ID: {loan.id}")
|
||||
try:
|
||||
repayment_data = {
|
||||
"customerId": loan.customer_id,
|
||||
"loanId": loan.id,
|
||||
"productId": loan.product_id,
|
||||
"transactionId": loan.transaction_id,
|
||||
"initiatedBy": "SYSTEM", #To be reviewed
|
||||
"salaryAmount": 0,
|
||||
"LoanStatus": loan.status,
|
||||
}
|
||||
process_overdue_loan(loan)
|
||||
|
||||
logger.info(f"Creating repayment with data: {repayment_data}")
|
||||
repayment = RepaymentService.create_repayment(repayment_data)
|
||||
|
||||
if not repayment or isinstance(repayment, dict) and "error" in repayment:
|
||||
db.session.rollback() # important in case create_repayment failed mid-way
|
||||
logger.error(f"Repayment creation failed for loan ID {loan.id}: {repayment}")
|
||||
continue
|
||||
|
||||
try:
|
||||
LoanService.update_status(loan_id=loan.id, status=LoanStatus.START_REPAY)
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
logger.error(f"Failed to update loan status for loan ID {loan.id}: {e}")
|
||||
|
||||
logger.info(f"Created repayment ID: {repayment.id}")
|
||||
|
||||
# Step 3: Call Simbrella
|
||||
try:
|
||||
simbrella_response = SimbrellaClient.collect_loan_user_due_payment(repayment.to_dict())
|
||||
|
||||
if isinstance(simbrella_response, tuple):
|
||||
simbrella_response, status_code = simbrella_response
|
||||
logger.warning(f"Simbrella returned tuple: status={status_code}, response={simbrella_response}")
|
||||
|
||||
if isinstance(simbrella_response, dict):
|
||||
if simbrella_response.get("status") != "success":
|
||||
logger.warning(f"Simbrella failed for repayment ID {repayment.id}: {simbrella_response}")
|
||||
else:
|
||||
logger.warning(f"Unexpected Simbrella response: {type(simbrella_response)}")
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Failed to call Simbrella for repayment ID {repayment.id}: {e}")
|
||||
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
logger.error(f"Error creating repayment for loan ID {loan.id}: {e}")
|
||||
continue
|
||||
|
||||
logger.info(f"Finished processing loan ID: {loan.id}")
|
||||
return ResponseHelper.success(message="Processed overdue loans successfully", status_code=200)
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Error fetching overdue loans: {e}")
|
||||
return ResponseHelper.error("Failed to fetch overdue loans", status_code=500, error=str(e))
|
||||
|
||||
|
||||
def process_overdue_loan(loan):
|
||||
"""
|
||||
Handles repayment creation, loan status update, and Simbrella call
|
||||
for a single overdue loan.
|
||||
"""
|
||||
logger.info(f"Processing Loan ID: {loan.id}")
|
||||
|
||||
try:
|
||||
repayment_data = {
|
||||
"customerId": loan.customer_id,
|
||||
"loanId": loan.id,
|
||||
"productId": loan.product_id,
|
||||
"transactionId": loan.transaction_id,
|
||||
"initiatedBy": "SYSTEM", # To be reviewed
|
||||
"salaryAmount": 0,
|
||||
"LoanStatus": loan.status,
|
||||
}
|
||||
|
||||
logger.info(f"Creating repayment with data: {repayment_data}")
|
||||
repayment = RepaymentService.create_repayment(repayment_data)
|
||||
|
||||
if not repayment or (isinstance(repayment, dict) and "error" in repayment):
|
||||
db.session.rollback() # important in case create_repayment failed mid-way
|
||||
logger.error(f"Repayment creation failed for loan ID {loan.id}: {repayment}")
|
||||
return
|
||||
|
||||
# Update loan status
|
||||
try:
|
||||
LoanService.update_status(loan_id=loan.id, status=LoanStatus.START_REPAY)
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
logger.error(f"Failed to update loan status for loan ID {loan.id}: {e}")
|
||||
|
||||
logger.info(f"Created repayment ID: {repayment.id}")
|
||||
|
||||
# Step 3: Call Simbrella
|
||||
try:
|
||||
simbrella_response = SimbrellaClient.collect_loan_user_due_payment(repayment.to_dict())
|
||||
|
||||
if isinstance(simbrella_response, tuple):
|
||||
simbrella_response, status_code = simbrella_response
|
||||
logger.warning(f"Simbrella returned tuple: status={status_code}, response={simbrella_response}")
|
||||
|
||||
if isinstance(simbrella_response, dict):
|
||||
if simbrella_response.get("status") != "success":
|
||||
logger.warning(f"Simbrella failed for repayment ID {repayment.id}: {simbrella_response}")
|
||||
else:
|
||||
logger.warning(f"Unexpected Simbrella response: {type(simbrella_response)}")
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Failed to call Simbrella for repayment ID {repayment.id}: {e}")
|
||||
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
logger.error(f"Error creating repayment for loan ID {loan.id}: {e}")
|
||||
|
||||
finally:
|
||||
logger.info(f"Finished processing loan ID: {loan.id}")
|
||||
|
||||
Reference in New Issue
Block a user