DigiFi/digifi-EventManager
1
0
Fork 0
Code Issues Pull Requests 1 Releases Activity

Merge branch 'oluyemi' of DigiFi/digifi-EventManager into master

Browse Source
This commit is contained in:
Olusesan Ameye
2025-04-14 17:10:34 +00:00
committed by Gogs
parent 0e641d20a9 62352ed740
commit 46ba285b99
3 changed files with 25 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/integrations/kafka.py
+1 -1
View File
@@ -51,7 +51,7 @@ class KafkaIntegration:
:return: The message value (decoded) or None if no message is received
"""
consumer = KafkaIntegration._get_consumer()
# consumer.subscribe(["LOAN_REPAYMENT"])
# consumer.subscribe(["PROCESS_PAYMENT"])
# consumer.subscribe([topic])
consumer.subscribe(['LOAN_REPAYMENT', 'PROCESS_PAYMENT'])
app/integrations/simbrella.py
+20 -27
View File
@@ -14,16 +14,6 @@ class SimbrellaClient:
logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
logger.info(f"Calling Disbursement endpoint with data: {data}")
data={
"requestId": "RQID1743987402764",
"transactionId": "24",
"customerId": "CN437703",
"accountId": "ACN2167485",
"msisdn": "3451342",
"resultCode": "00",
"resultDescription": "Successful"
}
disbursement_data ={
"requestId": data['requestId'],
"transactionId": data['transactionId'],
@@ -61,10 +51,10 @@ class SimbrellaClient:
collect_loan_data = {
"transactionId": "T002",
"fbnTransactionId": "FBN20231123",
"debtId": "273194670",
"customerId": "CN621868",
"debtId": data['debtId'],
"customerId": data['customerId'],
"accountId": "2017821799",
"productId": "101",
"productId": data['productId'],
"collectAmount": 80000,
"penalCharge": 0,
"collectionMethod": 1,
@@ -85,17 +75,20 @@ class SimbrellaClient:
return 1
@staticmethod
def verify_transaction(data):
api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/TransactionVerify"
logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
logger.info(f"Calling TransactionVerify endpoint with data: {data}")
def verify_transaction():
# api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/TransactionVerify"
# logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
# logger.info(f"Calling TransactionVerify endpoint with data: {data}")
try:
logger.info(f"Here is your TransactionVerify Request data ***** : {data}")
response = requests.post(api_url, json=data, headers=get_headers())
logger.info(f"TransactionVerify response: {response.json()}")
# logger.info(f"Here is your TransactionVerify Request data ***** : {data}")
# response = requests.post(api_url, json=data, headers=get_headers())
# logger.info(f"TransactionVerify response: {response.json()}")
return response.json()
return {
"status": "00",
"message": "Transaction verified"
}
except Exception as e:
logger.info(f"Failed to call TransactionVerify endpoint: {e}")
@@ -103,9 +96,9 @@ class SimbrellaClient:
@staticmethod
def refresh_disbursement(data):
api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Disbursement"
logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
logger.info(f"Calling Disbursement endpoint with data: {data}")
# api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Disbursement"
# logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
# logger.info(f"Calling Disbursement endpoint with data: {data}")
try:
logger.info(f"Here is your Disbursement Request data ***** : {data}")
@@ -122,9 +115,9 @@ class SimbrellaClient:
@staticmethod
def payment_callback(data):
api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Payment"
logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
logger.info(f"Calling Payment Callback endpoint with data: {data}")
# api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Payment"
# logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
# logger.info(f"Calling Payment Callback endpoint with data: {data}")
try:
logger.info(f"Here is your Payment Callback Request data ***** : {data}")
app/routes/autocall.py
+4 -4
View File
@@ -9,19 +9,19 @@ autocall_bp = Blueprint("autocall", __name__)
@autocall_bp.route("/refresh-verify-disbursement", methods=["GET"])
def verify_transaction():
data = request.json()
# data = request.json()
logger.info(f"Calling VerifyTransaction Components")
response = SimbrellaClient.verify_transaction(data)
response = SimbrellaClient.verify_transaction()
return jsonify(response), 200
@autocall_bp.route("/refresh-disbursement", methods=["GET"])
def disbursement():
data = request.json()
# data = request.json()
logger.info(f"Calling Disbursement Components")
response = SimbrellaClient.verify_transaction(data)
response = SimbrellaClient.verify_transaction()
return jsonify(response), 200