CHIEFSOFT\ameye
202 lines
7.6 KiB
Python
202 lines
7.6 KiB
Python
from flask import Blueprint, request, jsonify, current_app
|
|
import requests
|
|
from app.config import settings
|
|
from app.helpers.response_helper import ResponseHelper
|
|
from app.utils.auth import get_headers
|
|
from app.utils.logger import logger
|
|
from app.integrations.simbrella import SimbrellaClient
|
|
from app.services.loan import LoanService
|
|
from app.services.repayment import RepaymentService
|
|
from app.services.salary import SalaryService
|
|
|
|
autocall_bp = Blueprint("autocall", __name__)
|
|
|
|
@autocall_bp.route("/refresh-verify-disbursement", methods=["GET"])
|
|
def verify_transaction():
|
|
logger.info(f"Calling VerifyTransaction Components")
|
|
|
|
loan = LoanService.get_latest_loan_with_disburse_date()
|
|
if not loan:
|
|
logger.info(f"No loan found without disbursement date")
|
|
return 0
|
|
logger.info(f"Calling VerifyTransaction endpoint with data: {loan}")
|
|
loan_data = loan.to_dict()
|
|
|
|
data = {
|
|
"transactionId": loan_data.get('transactionId'),
|
|
"FbnTransactionId": loan_data.get('transactionId'),
|
|
"debtId": str(loan_data.get('debtId')),
|
|
"customerId": loan_data.get('customerId'),
|
|
"accountId": loan_data.get('accountId'),
|
|
"productId": str(loan_data.get('productId', "")),
|
|
"provideAmount": loan_data.get('currentLoanAmount'),
|
|
}
|
|
response = SimbrellaClient.verify_transaction(data)
|
|
return response
|
|
|
|
@autocall_bp.route("/refresh-disbursement", methods=["GET"])
|
|
def disbursement():
|
|
# data = request.json()
|
|
logger.info(f"Calling Disbursement Components")
|
|
loan = LoanService.get_latest_loan_without_disburse_date()
|
|
if not loan:
|
|
logger.info(f"No loan found without disbursement date")
|
|
return 0
|
|
logger.info(f"Calling DisburseLoan endpoint with data: {loan}")
|
|
loan_data = loan.to_dict()
|
|
|
|
data = {
|
|
"transactionId": loan_data.get('transactionId'),
|
|
"FbnTransactionId": loan_data.get('transactionId'),
|
|
"debtId": str(loan_data.get('debtId')),
|
|
"customerId": loan_data.get('customerId'),
|
|
"accountId": loan_data.get('accountId'),
|
|
"productId": str(loan_data.get('productId', "")),
|
|
"provideAmount": loan_data.get('currentLoanAmount'),
|
|
}
|
|
response = SimbrellaClient.disburse_loan(data)
|
|
return response
|
|
|
|
|
|
@autocall_bp.route("/refresh-verify-collection", methods=["GET"])
|
|
def refresh_verify_collection():
|
|
data = request.get_json()
|
|
logger.info(f"Calling Verify Collection")
|
|
|
|
response = SimbrellaClient.collect_loan(data)
|
|
|
|
return response
|
|
|
|
@autocall_bp.route("/refresh-collection", methods=["GET"])
|
|
def refresh_collection():
|
|
#data = request.get_json()
|
|
logger.info(f"Calling Collection ")
|
|
#grab the last repayments with repay date is none
|
|
repayment = RepaymentService.get_latest_repayment_without_repay_date()
|
|
#repayment = RepaymentService.get_latest_repayment_with_loanId(13735)
|
|
if not repayment:
|
|
logger.info(f"No repayment found without repay date")
|
|
return 0
|
|
logger.info(f"Calling repay loan endpoint with data: {repayment}")
|
|
repayment_data = repayment.to_dict()
|
|
logger.info(f"here is the dict form of repayment {repayment_data}")
|
|
|
|
data = {
|
|
"transactionId": repayment_data['transactionId'],
|
|
"debtId": repayment_data['loanId'],
|
|
"customerId": repayment_data['customerId'],
|
|
"productId": repayment_data['productId'],
|
|
"Id":repayment_data['Id']
|
|
}
|
|
logger.info(f"Data being sent to Simbrella: {data}")
|
|
logger.info(f"calling simbrella")
|
|
response = SimbrellaClient.collect_loan_user_initiated(data)
|
|
|
|
return response
|
|
|
|
@autocall_bp.route("/payment-callback", methods=["POST"])
|
|
def payment_callback():
|
|
data = request.get_json()
|
|
logger.info(f"Calling Callback Components")
|
|
|
|
response = SimbrellaClient.payment_callback(data)
|
|
|
|
return response
|
|
|
|
@autocall_bp.route("/penal-charge", methods=["POST"])
|
|
def penal_charge():
|
|
data = request.get_json()
|
|
logger.info(f"Calling Penal Charge Endpoint")
|
|
|
|
try:
|
|
response = SimbrellaClient.penal_charge(data[0])
|
|
return response
|
|
except Exception as e:
|
|
logger.error(f"Error in Penal Charge: {e}")
|
|
return ResponseHelper.error("Penal charge failed")
|
|
|
|
|
|
@autocall_bp.route("/analytic-salary-detect", methods=["POST"])
|
|
def salary_detect():
|
|
payload = request.get_json()
|
|
logger.info("Calling Salary Detect endpoint")
|
|
|
|
if payload is None:
|
|
logger.warning("No payload received in request")
|
|
#- Sometimes no paylod return ResponseHelper.error("Missing request payload", status_code=400)
|
|
|
|
if payload:
|
|
# Step 1: Try to add new salary data
|
|
try:
|
|
new_salary = SalaryService.add_salary_data(payload)
|
|
if new_salary:
|
|
logger.info(f"Salary added: {new_salary.id}")
|
|
except Exception as e:
|
|
logger.error(f"Failed to save salary: {e}")
|
|
|
|
# Step 2: Get all pending salaries
|
|
pending_salaries = SalaryService.get_pending_salaries()
|
|
if not pending_salaries:
|
|
logger.info("No pending salaries found")
|
|
return ResponseHelper.success([], "No pending salaries")
|
|
|
|
logger.info(f"Found {len(pending_salaries)} pending salaries to process")
|
|
|
|
# Step 3: Process each salary
|
|
for pending_salary in pending_salaries:
|
|
logger.info(f"Processing salary ID: {pending_salary.id}")
|
|
|
|
# Step 3.1: Update status to PROCESSING
|
|
try:
|
|
SalaryService.update_status(pending_salary.id, "PROCESSING")
|
|
except Exception as e:
|
|
logger.warning(f"Could not update status for salary ID {pending_salary.id}: {e}")
|
|
continue
|
|
|
|
# Step 3.2: Get loans
|
|
try:
|
|
loans, total_amount = LoanService.get_customer_loans(pending_salary.customer_id)
|
|
if not loans:
|
|
logger.warning(f"No loans found for customer ID: {pending_salary.customer_id}")
|
|
continue
|
|
except Exception as e:
|
|
logger.error(f"Error fetching loans for customer ID {pending_salary.customer_id}: {e}")
|
|
continue
|
|
|
|
# Step 3.3: Create repayments
|
|
for loan in loans:
|
|
try:
|
|
loan_dict = loan.to_dict()
|
|
logger.info(f"loan_dict ==== Repayment Data:{loan_dict}")
|
|
repayment_data = {
|
|
"customerId": loan_dict["customerId"],
|
|
"loanId": loan_dict["debtId"],
|
|
"productId": loan_dict["productId"],
|
|
"transactionId": loan_dict["transactionId"],
|
|
"initiatedBy": "SALARY_DETECT",
|
|
"salaryAmount": pending_salary.amount,
|
|
}
|
|
logger.info(f"Saving/Creating Repayment Data:{repayment_data}")
|
|
#logger.info(f"Creating repayment for loan ID {loan_dict['debtId']}")
|
|
# repayment = RepaymentService.add_repayment(repayment_data)
|
|
repayment = RepaymentService.create_repayment(repayment_data)
|
|
Loan.update_status(loan_id=repayment_data.loanId,
|
|
status=LoanStatus.START_REPAY) # repay started
|
|
|
|
logger.info(f"Created repayment ID: {repayment.id}")
|
|
except Exception as e:
|
|
logger.error(f"Error creating repayment for loan ID {loan.id}: {e}")
|
|
continue
|
|
# Step 4: Simbrella integration call after all processing
|
|
try:
|
|
SimbrellaClient.collect_loan_user_salary_detect(repayment.to_dict())
|
|
except Exception as e:
|
|
logger.error(f"Failed to call Simbrella client: {e}")
|
|
|
|
|
|
|
|
logger.info(f"Finished processing salary ID: {pending_salary.id}")
|
|
return ResponseHelper.success([], "AutoCall Successful")
|
|
|
|
|