From 771e8c00eda7aef0adb72538f25a1bc0d6f1106f Mon Sep 17 00:00:00 2001 From: "CHIEFSOFT\\ameye" Date: Tue, 11 Nov 2025 07:27:04 -0500 Subject: [PATCH] repayment updates --- app/api/routes/routes.py | 4 ++-- app/api/services/repayment.py | 13 ++++++++----- 2 files changed, 10 insertions(+), 7 deletions(-) diff --git a/app/api/routes/routes.py b/app/api/routes/routes.py index 6e63009..9252b77 100644 --- a/app/api/routes/routes.py +++ b/app/api/routes/routes.py @@ -93,8 +93,8 @@ def loan_status(): @jwt_required() def repayment(): data = request.get_json() - logger.error(f"HERE 0000a **** ") - # logger.info(f"Repayment request received: {data}") + # logger.error(f"Loan Repayment Data: {data} ") + logger.info(f"Repayment request received: {data}") response = RepaymentService.process_request(data) return response diff --git a/app/api/services/repayment.py b/app/api/services/repayment.py index c3e5d4f..b11d543 100644 --- a/app/api/services/repayment.py +++ b/app/api/services/repayment.py @@ -39,16 +39,17 @@ class RepaymentService(BaseService): # customer = Customer.get_customer_with_loan_list(customer_id) transaction_id = validated_data.get('transactionId') initiated_by = validated_data.get('initiatedBy') - logger.error(f"HERE 0002a **** ") + logger.error(f"RepaymentService Received **** {data}") + if(RepaymentService.validate_account_ownership(account_id = account_id, customer_id = customer_id)): logger.error(f"HERE 0001a **** ") # Check loan exists - loan = Loan.get_customer_loan(loan_id = loan_id, customer_id = customer_id) + load_loan = Loan.get_customer_loan(loan_id = loan_id, customer_id = customer_id) # Save the repayment details repayment = Repayment.create_repayment( customer_id = customer_id, - loan = loan, + loan = load_loan, transaction_id = transaction_id ) @@ -56,6 +57,8 @@ class RepaymentService(BaseService): logger.error(f"Failed to save repayment details") return ResponseHelper.error(result_description="Failed to save repayment details.") + loan_transaction_id = load_loan.transaction_id + #Update Loan status Loan.update_status(loan_id = loan_id, status = LoanStatus.START_REPAY) # repay started by user transaction = RepaymentService.log_transaction(validated_data = validated_data) @@ -73,14 +76,14 @@ class RepaymentService(BaseService): "Id": repayment.id, "repayment_id": repayment.id, "initiated_by": repayment.initiated_by, - "transactionId": transaction_id, + "transactionId": loan_transaction_id, "customerId": customer_id, "productId": loan.product_id, "loanRef": loan_ref, "debtId": loan_id } - event_thread = Thread(target=RepaymentService.trigger_loan_repayment, args=(transaction_id,)) + event_thread = Thread(target=RepaymentService.trigger_loan_repayment, args=(loan_transaction_id,)) event_thread.start() # Call Kafka in a background thread