DigiFi/digifi-BankToProductCore
1
1
Fork 1
Code Issues Pull Requests 2 Releases Activity

repayment updates

Browse Source
This commit is contained in:
CHIEFSOFT\ameye
2025-11-11 07:27:04 -05:00
parent 2a184d134d
commit 771e8c00ed
2 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/api/routes/routes.py
+2 -2
View File
@@ -93,8 +93,8 @@ def loan_status():
@jwt_required() @jwt_required()
def repayment(): def repayment():
data = request.get_json() data = request.get_json()
logger.error(f"HERE 0000a **** ") # logger.error(f"Loan Repayment Data: {data} ")
# logger.info(f"Repayment request received: {data}") logger.info(f"Repayment request received: {data}")
response = RepaymentService.process_request(data) response = RepaymentService.process_request(data)
return response return response
app/api/services/repayment.py
+8 -5
View File
@@ -39,16 +39,17 @@ class RepaymentService(BaseService):
# customer = Customer.get_customer_with_loan_list(customer_id) # customer = Customer.get_customer_with_loan_list(customer_id)
transaction_id = validated_data.get('transactionId') transaction_id = validated_data.get('transactionId')
initiated_by = validated_data.get('initiatedBy') 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)): if(RepaymentService.validate_account_ownership(account_id = account_id, customer_id = customer_id)):
logger.error(f"HERE 0001a **** ") logger.error(f"HERE 0001a **** ")
# Check loan exists # 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 # Save the repayment details
repayment = Repayment.create_repayment( repayment = Repayment.create_repayment(
customer_id = customer_id, customer_id = customer_id,
loan = loan, loan = load_loan,
transaction_id = transaction_id transaction_id = transaction_id
) )
@@ -56,6 +57,8 @@ class RepaymentService(BaseService):
logger.error(f"Failed to save repayment details") logger.error(f"Failed to save repayment details")
return ResponseHelper.error(result_description="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 #Update Loan status
Loan.update_status(loan_id = loan_id, status = LoanStatus.START_REPAY) # repay started by user Loan.update_status(loan_id = loan_id, status = LoanStatus.START_REPAY) # repay started by user
transaction = RepaymentService.log_transaction(validated_data = validated_data) transaction = RepaymentService.log_transaction(validated_data = validated_data)
@@ -73,14 +76,14 @@ class RepaymentService(BaseService):
"Id": repayment.id, "Id": repayment.id,
"repayment_id": repayment.id, "repayment_id": repayment.id,
"initiated_by": repayment.initiated_by, "initiated_by": repayment.initiated_by,
"transactionId": transaction_id, "transactionId": loan_transaction_id,
"customerId": customer_id, "customerId": customer_id,
"productId": loan.product_id, "productId": loan.product_id,
"loanRef": loan_ref, "loanRef": loan_ref,
"debtId": loan_id "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() event_thread.start()
# Call Kafka in a background thread # Call Kafka in a background thread