[add]: eco models

This reverts commit 8bb5ce69e2.

.env.local.example

@@ -7,17 +7,26 @@ SWAGGER_URL="/documentation"
 API_URL="/swagger.json"
 
 # Database Configuration
-DATABASE_USER=firstadvance
-DATABASE_PASSWORD=FirstAdvance!
-DATABASE_HOST=dev-data.simbrellang.net
-DATABASE_PORT=10532
-DATABASE_NAME=firstadvancedev
-
-# DATABASE_HOST=10.20.30.60
 # DATABASE_USER=firstadvance
-# DATABASE_PASSWORD=firstadvance
+# DATABASE_PASSWORD=FirstAdvance!
+# DATABASE_HOST=dev-data.simbrellang.net
+# DATABASE_PORT=10532
 # DATABASE_NAME=firstadvancedev
-# DATABASE_PORT=5432
+
+
+# ECO_DATABASE_USER=username
+# ECO_DATABASE_PASSWORD=password
+# ECO_DATABASE_HOST=localhost
+# ECO_DATABASE_PORT=5432
+# ECO_DATABASE_NAME=eco_db
+
+
+DATABASE_USER=system
+DATABASE_PASSWORD=FIRSTADV_PASS
+DATABASE_HOST=209.195.2.27 
+# DATABASE_HOST=10.10.33.65
+DATABASE_PORT=1521
+DATABASE_SID=FREE
 
 # Flask Configuration
 FLASK_APP=wsgi.py

JUNK/send_report.py

@@ -0,0 +1,15 @@
+from flask import Flask
+from app.extensions import mail
+from app.utils.mail import send_report_email, get_report_data
+from app.config import settings
+
+app = Flask(__name__)
+app.config.from_object(settings)
+
+mail.init_app(app)
+
+with app.app_context():
+    report_data = get_report_data()
+    recipients = ["vdagbue@gmail.com"]
+    result = send_report_email(report_data, recipients)
+    print(result)

README.md

@@ -70,6 +70,7 @@ You can check if the Flask application is running by accessing the `/health` end
 
 ```bash
 curl http://localhost:4500/health
+curl http://localhost:4500/eco/health
 ```
 
 If the application is running properly, you should receive a response similar to this:
@@ -87,6 +88,7 @@ You can check the Swagger Doc by accessing the `/documentation` endpoint. Run th
 
 ```bash
 curl http://localhost:4500/documentation
+curl http://localhost:4500/eco/documentation
 ```
 
 

app/__init__.py

@@ -1,13 +1,16 @@
+from re import U
 from flask import Flask
+from flask_mail import Mail
 import os
 from flask_swagger_ui import get_swaggerui_blueprint
 from flask_cors import CORS
 from app.config import Config
 from app.api.routes import api
+from app.eco.routes import eco
 from app.errors import register_error_handlers
 from flask_sqlalchemy import SQLAlchemy
 from flask_migrate import Migrate
-from app.extensions import db, migrate
+from app.extensions import db, migrate, mail
 from flask_jwt_extended import (
     JWTManager,
     jwt_required,
@@ -18,6 +21,10 @@ from flask_jwt_extended import (
 
 def create_app():
     """Factory function to create a Flask app instance"""
+    # import oracledb
+    
+    # oracledb.init_oracle_client(lib_dir=None) 
+
     app = Flask(__name__)
 
     # Load configuration
@@ -34,15 +41,26 @@ def create_app():
 
     # Register blueprints
     app.register_blueprint(api)
+    app.register_blueprint(eco, url_prefix="/eco")
 
     swagger_ui_blueprint = get_swaggerui_blueprint(SWAGGER_URL, API_URL)
     app.register_blueprint(swagger_ui_blueprint, url_prefix=SWAGGER_URL)
 
+    # Second UI (ECO)
+    eco_docs = "/eco" + SWAGGER_URL
+    eco_api = "/eco" + API_URL
+    swagger_ui_eco = get_swaggerui_blueprint(eco_docs, eco_api)
+    swagger_ui_eco.name = 'swagger_ui_eco'  # Rename blueprint
+    app.register_blueprint(swagger_ui_eco, url_prefix=eco_docs)
+
     # Error Handlers
     register_error_handlers(app)
 
     from . import models
 
+    # Initialize Flask-Mail
+    mail.init_app(app)
+
     # Database and Migrations
     db.init_app(app)
 

app/api/enums/loan_status.py

@@ -3,5 +3,6 @@ from enum import Enum
 class LoanStatus(str, Enum):
     PENDING = "pending"
     ACTIVE = "active"
+    ACTIVE_PARTIAL = "active_partial"
     START_REPAY = "start_repay"
     REPAID = "repaid"

app/api/services/base_service.py

@@ -4,6 +4,7 @@ from flask import jsonify
 from marshmallow import ValidationError
 import logging
 from app.api.integrations import KafkaIntegration
+from app.utils.mail import send_report_email, get_report_data
 
 logger = logging.getLogger(__name__)
 
@@ -173,3 +174,6 @@ class BaseService:
        # return {"rate": 0, "fee": 0, "due_days": 0}
 
 
+    @classmethod
+    def send_mail(cls, report_data, recipients):
+            send_report_email(report_data, recipients)

app/api/services/offer_analysis.py

@@ -40,6 +40,7 @@ class OfferAnalysis:
         original_transaction =  transaction_id
 
         return transaction_offer, offer, eligible_amount, original_transaction
+    
     @staticmethod
     def _analyze_rack_checks(rack_response, offer):
         logger.info(f"This is PayLoad for ANALYSYS ***** : {str(rack_response)}", exc_info=True)
@@ -93,7 +94,7 @@ class OfferAnalysis:
         
 
 
-        logger.info(f"These are the salarie amounts ***** : {str(salaries)}", exc_info=True)
+        logger.info(f"These are the salary amounts ***** : {str(salaries)}", exc_info=True)
 
         #Least salary in the last 6 months
         min_salary = min(salaries)
@@ -113,7 +114,7 @@ class OfferAnalysis:
            
         else:  # Income is not consistent
             eligible_amount = 0
-            logger.info("Applying np percentage on least salary due unstable income.")
+            logger.info("Applying no percentage on least salary due unstable income.")
             
 
 

app/api/services/repayment.py

@@ -67,7 +67,11 @@ class RepaymentService(BaseService):
                     return ResponseHelper.error(result_description="Invalid Customer or Account")
 
                 # Simulated processing logic
+                # TODO start using repayment_id instead if id or Id
                 response_data = {
+                    "Id": repayment.id,
+                    "repayment_id": repayment.id,
+                    "initiated_by": repayment.initiated_by,
                     "transactionId": transaction_id,
                     "customerId": customer_id,
                     "productId": loan.product_id,

app/config.py

@@ -1,6 +1,7 @@
 import os
 from datetime import timedelta
 
+
 class Config:
     """Base configuration for Flask app"""
 
@@ -16,12 +17,30 @@ class Config:
     DATABASE_PASSWORD = os.environ.get("DATABASE_PASSWORD")
     DATABASE_HOST = os.environ.get("DATABASE_HOST")
     DATABASE_PORT = os.environ.get("DATABASE_PORT", 10532)
-    DATABASE_NAME = os.environ.get("DATABASE_NAME")
+    DATABASE_NAME = os.environ.get("DATABASE_NAME", "firstadvancedev")
+    DATABASE_SID = os.environ.get("DATABASE_SID", "FREE")
+    DNS = f"(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST={DATABASE_HOST})(PORT={DATABASE_PORT}))(CONNECT_DATA=(SID={DATABASE_SID})))"
+
+
+    # ECO Database Configuration
+    ECO_DATABASE_USER = os.environ.get("ECO_DATABASE_USER", "eco_user")
+    ECO_DATABASE_PASSWORD = os.environ.get("ECO_DATABASE_PASSWORD", "eco_pass")
+    ECO_DATABASE_HOST = os.environ.get("ECO_DATABASE_HOST", "localhost")
+    ECO_DATABASE_PORT = os.environ.get("ECO_DATABASE_PORT", 5432)
+    ECO_DATABASE_NAME = os.environ.get("ECO_DATABASE_NAME", "eco_db")
 
     # Database Connection
-    SQLALCHEMY_DATABASE_URI = f"postgresql+psycopg2://{DATABASE_USER}:{DATABASE_PASSWORD}@{DATABASE_HOST}:{DATABASE_PORT}/{DATABASE_NAME}"
-    SQLALCHEMY_TRACK_MODIFICATIONS = False
+    # SQLALCHEMY_DATABASE_URI = f"postgresql+psycopg2://{DATABASE_USER}:{DATABASE_PASSWORD}@{DATABASE_HOST}:{DATABASE_PORT}/{DATABASE_NAME}"
 
+    SQLALCHEMY_DATABASE_URI = (
+        f"oracle+oracledb://{DATABASE_USER}:{DATABASE_PASSWORD}@{DNS}"
+    )
+
+    SQLALCHEMY_BINDS = {
+        "eco": f"postgresql+psycopg2://{ECO_DATABASE_USER}:{ECO_DATABASE_PASSWORD}@{ECO_DATABASE_HOST}:{ECO_DATABASE_PORT}/{ECO_DATABASE_NAME}"
+    }
+
+    SQLALCHEMY_TRACK_MODIFICATIONS = False
 
     JWT_SECRET_KEY = os.getenv("JWT_SECRET_KEY", "secret-key")
     JWT_ACCESS_TOKEN_EXPIRES = os.getenv("JWT_ACCESS_TOKEN_EXPIRES", timedelta(hours=1))
@@ -32,15 +51,19 @@ class Config:
     # KAFKA_BROKER = 'dev-events.simbrellang.net:9085'
     KAFKA_BROKER = os.getenv("KAFKA_BROKER", "dev-events.simbrellang.net:9085")
 
-   # SIMBRELLA_ENDPOINT_RAC_CHECKS = os.getenv("SIMBRELLA_ENDPOINT_RAC_CHECKS", "RACCheck")
+    # SIMBRELLA_ENDPOINT_RAC_CHECKS = os.getenv("SIMBRELLA_ENDPOINT_RAC_CHECKS", "RACCheck")
     VALID_APP_ID = os.getenv("SIMBRELLA_APP_ID", "app1")
     VALID_API_KEY = os.getenv("SIMBRELLA_API_KEY", "test-api-key-12345")
     SIMBRELLA_BASE_URL = os.getenv("SIMBRELLA_BASE_URL", "http://127.0.0.1:6337")
-    SIMBRELLA_ENDPOINT_RAC_CHECKS = os.getenv("SIMBRELLA_ENDPOINT_RAC_CHECKS","api/rac-check")
+    SIMBRELLA_ENDPOINT_RAC_CHECKS = os.getenv(
+        "SIMBRELLA_ENDPOINT_RAC_CHECKS", "api/rac-check"
+    )
 
     RAC_RESULT_accountStatus = os.environ.get("RAC_RESULT_accountStatus", "true")
     RAC_RESULT_bvnValidated = os.environ.get("RAC_RESULT_bvnValidated", "true")
-    RAC_RESULT_creditBureauCheck = os.environ.get("RAC_RESULT_creditBureauCheck", "false")
+    RAC_RESULT_creditBureauCheck = os.environ.get(
+        "RAC_RESULT_creditBureauCheck", "false"
+    )
     RAC_RESULT_crmsCheck = os.environ.get("RAC_RESULT_crmsCheck", "true")
     RAC_RESULT_hasLien = os.environ.get("RAC_RESULT_hasLien", "false")
     RAC_RESULT_hasPastDueLoan = os.environ.get("RAC_RESULT_hasPastDueLoan", "false")
@@ -63,12 +86,10 @@ class Config:
         "rule12_CRMS_no_delinquency",
         "rule13_BVN_ignore",
         "rule14_no_lien",
-        "rule15_null_ignore"
+        "rule15_null_ignore",
     ]
-    
-    rac_false_rules = [
 
-    ]
+    rac_false_rules = []
 
     rac_salary_payments = [
         "salarypaymenT_1",
@@ -76,10 +97,17 @@ class Config:
         "salarypaymenT_3",
         "salarypaymenT_4",
         "salarypaymenT_5",
-        "salarypaymenT_6"
+        "salarypaymenT_6",
     ]
 
-
+    MAIL_SERVER = os.getenv("MAIL_SERVER", "smtp.zoho.com")
+    MAIL_PORT = 587
+    MAIL_USERNAME = os.getenv("MAIL_USERNAME", "firstadvance@dynamikservices.tech")
+    MAIL_PASSWORD = os.getenv("MAIL_PASSWORD")
+    MAIL_USE_TLS = True
+    MAIL_USE_SSL = False
+    MAIL_DEFAULT_SENDER = ("FirstAdvance", "firstadvance@dynamikservices.tech")
+    MAIL_RECEIVER = os.getenv("MAIL_RECEIVER", "vdagbue@gmail.com")
 
 
 settings = Config()

app/eco/enums/__init__.py

@@ -0,0 +1 @@
+from .transaction_type import TransactionType

app/eco/enums/installment_status.py

@@ -0,0 +1,7 @@
+from enum import Enum
+
+class InstallmentStatus(str, Enum):
+    PENDING = 'PENDING'
+    PAID = 'PAID'
+    OVERDUE = 'OVERDUE'
+    PARTIALLY_PAID = 'PARTIALLY_PAID'

app/eco/enums/loan_status.py

@@ -0,0 +1,8 @@
+from enum import Enum
+
+class LoanStatus(str, Enum):
+    PENDING = 'PENDING'
+    ACTIVE = 'ACTIVE'
+    PAID = 'PAID'
+    DEFAULTED = 'DEFAULTED'
+    CLOSED = 'CLOSED'

app/eco/enums/transaction_type.py

@@ -0,0 +1,10 @@
+from enum import Enum
+
+class TransactionType(str, Enum):
+    ELIGIBILITY_CHECK = "eligibility_check"
+    GET_OFFERS = "get_offers"
+    LOAN_INFORMATION = "loan_information"
+    INFLOW_NOTIFICATION = "inflow_notification"
+    LOW_BALANCE_NOTIFICATION = "low_balance_notification"
+    PROVIDE_LOAN = "provide_loan"
+    REPAYMENT = "repayment"

app/eco/helpers/response_helper.py

@@ -0,0 +1,112 @@
+from flask import jsonify
+from typing import Optional, Union, Dict, List, Any
+
+
+class ResponseHelper:
+    """
+    A helper class for building standardized JSON responses using resultCode and resultDescription.
+    """
+
+    @staticmethod
+    def build_response(
+        result_code: str,
+        result_description: str,
+        data: Optional[Union[Dict, List, str]] = None
+    ) -> Dict[str, Any]:
+        response = {
+            "resultCode": result_code,
+            "resultDescription": result_description
+        }
+
+        if isinstance(data, dict):
+            response.update(data)
+
+        return jsonify(response)
+
+    @staticmethod
+    def success(
+        result_description: str = "Successful",
+        result_code: str = "00",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def error(
+        result_description: str = "An error occurred",
+        result_code: str = "01",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def created(
+        result_description: str = "Resource created successfully",
+        result_code: str = "00",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def updated(
+        result_description: str = "Resource updated successfully",
+        result_code: str = "00",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def internal_server_error(
+        result_description: str = "Internal Server Error",
+        result_code: str = "500",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def unauthorized(
+        result_description: str = "Unauthorized",
+        result_code: str = "401",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def forbidden(
+        result_description: str = "Forbidden",
+        result_code: str = "403",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def not_found(
+        result_description: str = "Resource not found",
+        result_code: str = "404",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def unprocessable_entity(
+        result_description: str = "Unprocessable entity",
+        result_code: str = "422",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def method_not_allowed(
+        result_description: str = "Method Not Allowed",
+        result_code: str = "405",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)
+
+    @staticmethod
+    def bad_request(
+        result_description: str = "Bad Request",
+        result_code: str = "400",
+        data: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, Any]:
+        return ResponseHelper.build_response(result_code, result_description, data)

app/eco/routes/__init__.py

@@ -0,0 +1 @@
+from .routes import eco 

app/eco/routes/routes.py

@@ -0,0 +1,109 @@
+from flask import Blueprint, request, jsonify, send_from_directory
+from app.eco.services import (
+    AuthorizationService,
+    EligibilityCheckService,
+    GetOfferService,
+    ProvideLoanService,
+    LoanInformationService,
+    RepaymentService,
+    InflowNotificationService,
+    LowBalanceNotificationService
+)
+from app.utils.logger import logger
+from flask_jwt_extended import jwt_required
+import os
+
+eco = Blueprint("eco", __name__)
+
+# Swagger JSON file
+@eco.route("/swagger.json", methods=["GET"])
+def swagger_json():
+    swagger_dir = os.path.join("swagger")
+    return send_from_directory(swagger_dir, "digifi_swagger.json")
+
+@eco.route("/swagger/<path:filename>")
+def serve_paths(filename):
+    swagger_dir = os.path.join("swagger")
+    return send_from_directory(swagger_dir, filename)
+
+
+
+
+# Simbrella Request API Endpoints
+@eco.route("/EligibilityCheck", methods=["POST"])
+@jwt_required()
+def eligibility_check():
+    data = request.get_json()
+    response = EligibilityCheckService.process_request(data)
+    return jsonify(response)
+
+@eco.route("/GetOffers", methods=["POST"])
+@jwt_required()
+def get_offers():
+    data = request.get_json()
+    response = GetOfferService.process_request(data)
+    return jsonify(response)
+
+@eco.route("/ProvideLoan", methods=["POST"])
+@jwt_required()
+def provide_loan():
+    data = request.get_json()
+    response = ProvideLoanService.process_request(data)
+    return jsonify(response)
+
+@eco.route("/LoanInformation", methods=["POST"])
+@jwt_required()
+def loan_information():
+    data = request.get_json()
+    response = LoanInformationService.process_request(data)
+    return jsonify(response)
+
+@eco.route("/Repayment", methods=["POST"])
+@jwt_required()
+def repayment():
+    data = request.get_json()
+    response = RepaymentService.process_request(data)
+    return jsonify(response)
+
+@eco.route("/InflowNotification", methods=["POST"])
+@jwt_required()
+def inflow_notification():
+    data = request.get_json()
+    response = InflowNotificationService.process_request(data)
+    return jsonify(response)
+
+@eco.route("/LowBalanceNotification", methods=["POST"])
+@jwt_required()
+def low_balance_notification():
+    data = request.get_json()
+    response = LowBalanceNotificationService.process_request(data)
+    return jsonify(response)
+
+
+
+
+
+
+# Health Check
+@eco.route("/health", methods=["GET"])
+def health_check():
+    return jsonify({"status": "ok"}), 200
+
+
+
+
+
+# Authorize endpoint
+@eco.route("/Authorize", methods=["POST"])
+def authorize():
+    data = request.get_json()
+    response = AuthorizationService.process_request(data)
+    return response
+
+
+# Authorize refresh endpoint
+@eco.route("/AuthorizeRefresh", methods=["POST"])
+@jwt_required(refresh=True)
+def refresh():
+    response = AuthorizationService.process_refresh_request()
+    return response

app/eco/schemas/__init__.py

@@ -0,0 +1,8 @@
+from .authorization import AuthorizeRequestSchema
+from .eligibility_check import EligibilityCheckSchema
+from .get_offer import GetOfferSchema
+from .provide_loan import ProvideLoanSchema
+from .loan_information import LoanInformationSchema
+from .repayment import RepaymentSchema
+from .inflow_notification import InflowNotificationSchema
+from .low_balance_notification import LowBalanceNotificationSchema

app/eco/schemas/authorization.py

@@ -0,0 +1,6 @@
+from marshmallow import Schema, fields
+
+
+class AuthorizeRequestSchema(Schema):
+    username = fields.Str(required=True)
+    password = fields.Str(required=True)

app/eco/schemas/eligibility_check.py

@@ -0,0 +1,14 @@
+from marshmallow import Schema, fields, EXCLUDE
+
+
+class EligibilityCheckSchema(Schema):
+    requestId = fields.Str(required=True)
+    sessionId = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    customerId = fields.Str(required=True)
+    accountId = fields.Str(required=True)
+    msisdn = fields.Str(required=True)
+    lienAmount = fields.Str(required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/schemas/get_offer.py

@@ -0,0 +1,17 @@
+from marshmallow import Schema, fields, validate, validates_schema, EXCLUDE
+from marshmallow.validate import OneOf
+from datetime import datetime
+
+class GetOfferSchema(Schema):
+    requestId = fields.Str(required=True)
+    sessionId = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    customerId = fields.Str(required=True)
+    accountId = fields.Str(required=True)
+    msisdn = fields.Str(required=True)
+    lienAmount = fields.Decimal(required=True)
+    requestedAmount = fields.Decimal(required=True)
+    channel = fields.Str(required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/schemas/inflow_notification.py

@@ -0,0 +1,18 @@
+from marshmallow import Schema, fields, EXCLUDE
+from datetime import datetime
+
+class InflowItemSchema(Schema):
+    customerId = fields.Str(required=True)
+    accountId = fields.Str(required=True)
+    amount = fields.Decimal(required=True, places=2)
+    transactionId = fields.Str(required=True)
+    transactionDate = fields.Str(required=True)
+
+
+class InflowNotificationSchema(Schema):
+    batchTime = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    inflows = fields.List(fields.Nested(InflowItemSchema), required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/schemas/loan_information.py

@@ -0,0 +1,13 @@
+from marshmallow import Schema, fields, validate, EXCLUDE
+from marshmallow.validate import OneOf, Range
+
+class LoanInformationSchema(Schema):
+    requestId = fields.Str(required=True)
+    sessionId = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    customerId = fields.Str(required=True)
+    msisdn = fields.Str(required=True)
+    channel = fields.Str(required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/schemas/low_balance_notification.py

@@ -0,0 +1,16 @@
+from marshmallow import Schema, fields, validate, EXCLUDE
+
+class LowBalanceItemSchema(Schema):
+    customerId = fields.Str(required=True)
+    accountId = fields.Str(required=True)
+    balance = fields.Decimal(required=True, places=2)
+    transactionId = fields.Str(required=True)
+    transactionDate = fields.Str(required=True)
+
+class LowBalanceNotificationSchema(Schema):
+    batchTime = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    lbns = fields.List(fields.Nested(LowBalanceItemSchema), required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/schemas/provide_loan.py

@@ -0,0 +1,20 @@
+from marshmallow import Schema, fields, validate, EXCLUDE
+from marshmallow.validate import OneOf, Range
+
+class ProvideLoanSchema(Schema):
+    requestId = fields.Str(required=True)
+    sessionId = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    customerId = fields.Str(required=True)
+    accountId = fields.Str(required=True)
+    msisdn = fields.Str(required=True)
+    offerId = fields.Int(required=True, validate=Range(min=1))
+    upfrontPayment = fields.Decimal(required=True)
+    interestRate = fields.Decimal(required=True)
+    requestedAmount = fields.Decimal(required=True)
+    lienAmount = fields.Decimal(required=True)
+    productId = fields.Str( required=True)
+    channel = fields.Str(required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/schemas/repayment.py

@@ -0,0 +1,16 @@
+from marshmallow import Schema, fields, validate, EXCLUDE
+from marshmallow.validate import OneOf, Range
+
+class RepaymentSchema(Schema):
+    requestId = fields.Str(required=True)
+    sessionId = fields.Str(required=True)
+    affiliateCode = fields.Str(required=True)
+    customerId = fields.Str(required=True)
+    msisdn = fields.Str(required=True)
+    debtId = fields.Int(required=True, validate=Range(min=1))
+    repaymentAmount = fields.Decimal(required=False) # Optional, required for "Manual" repaymentType
+    repaymentType = fields.Str(required=True) # "Full", "Due", "Manual", "Overdue"
+    channel = fields.Str(required=True)
+
+    class Meta:
+        unknown = EXCLUDE 

app/eco/services/__init__.py

@@ -0,0 +1,8 @@
+from app.eco.services.authorization import AuthorizationService
+from app.eco.services.eligibility_check import EligibilityCheckService
+from app.eco.services.get_offer import GetOfferService
+from app.eco.services.provide_loan import ProvideLoanService
+from app.eco.services.loan_information import LoanInformationService
+from app.eco.services.repayment import RepaymentService
+from app.eco.services.inflow_notification import InflowNotificationService
+from app.eco.services.low_balance_notification import LowBalanceNotificationService

app/eco/services/authorization.py

@@ -0,0 +1,102 @@
+from flask import request, jsonify
+from marshmallow import ValidationError
+from app.eco.services.base_service import BaseService
+from app.utils.logger import logger
+from app.eco.schemas.authorization import AuthorizeRequestSchema
+from app.eco.helpers.response_helper import ResponseHelper
+from flask_jwt_extended import (
+    JWTManager,
+    jwt_required,
+    create_access_token,
+    create_refresh_token,
+    get_jwt_identity,
+)
+from app.config import Config
+
+USERNAME = Config.BASIC_AUTH_USERNAME
+PASSWORD = Config.BASIC_AUTH_PASSWORD
+
+
+class AuthorizationService(BaseService):
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the Authorization request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            logger.info("Processing Authorization request")
+
+            if not data:
+                return ResponseHelper.bad_request(result_description="Missing JSON in request")
+
+            # Validate input data using the Authorization schema
+            schema = AuthorizeRequestSchema()
+            validated_data = schema.load(data)  # Raises ValidationError if invalid
+
+            if (
+                validated_data["username"] != USERNAME
+                or validated_data["password"] != PASSWORD
+            ):
+                return ResponseHelper.unauthorized(result_description="Invalid credentials")
+
+            access_token = create_access_token(identity=validated_data["username"])
+            refresh_token = create_refresh_token(identity=validated_data["username"])
+
+            # Simulated processing logic
+            response_data = {
+                "access_token": access_token,
+                "refresh_token": refresh_token,
+            }
+
+            return ResponseHelper.success(
+                data={"data": response_data}, result_description="Authorization processed successfully"
+            )
+
+        except ValidationError as e:
+            logger.error(f"Validation error: {e}")
+            return ResponseHelper.bad_request(result_description=f"Validation error: {e}")
+
+        except Exception as e:
+            logger.error(f"Error processing Authorization request: {e}")
+            return ResponseHelper.internal_server_error(
+                result_description=f"Error processing Authorization request: {e}"
+            )
+
+    @staticmethod
+    def process_refresh_request():
+        """
+        Process the RefreshToken request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            logger.info("Processing RefreshToken request")
+
+            identity = get_jwt_identity()
+            access_token = create_access_token(identity=identity)
+
+            # Simulated processing logic
+            response_data = {
+                "access_token": access_token,
+            }
+
+            return ResponseHelper.success(
+                data={"data": response_data}, result_description="RefreshToken processed successfully"
+            )
+
+        except Exception as e:
+            logger.error(f"Error processing RefreshToken request: {e}")
+            return ResponseHelper.internal_server_error(
+                result_description=f"Error processing RefreshToken request: {e}"
+            )

app/eco/services/base_service.py

@@ -0,0 +1,37 @@
+from app.eco.enums import TransactionType
+from flask import jsonify
+from marshmallow import ValidationError
+import logging
+from app.utils.mail import send_report_email, get_report_data
+
+logger = logging.getLogger(__name__)
+
+class BaseService:
+    TRANSACTION_TYPE = None
+
+    @classmethod
+    def validate_data(cls, data, schema):
+        """
+        Validate input data based on the provided schema.
+        """
+        logger.info(f"Processing {cls.TRANSACTION_TYPE} request")
+        return schema.load(data)
+
+    @classmethod
+    def send_mail(cls, report_data, recipients):
+            send_report_email(report_data, recipients)
+
+    # @classmethod
+    # def log_session(cls, validated_data):
+    #     """
+    #     Create a new session.
+    #     """
+    #     channel = "USSD" if validated_data.get("channel") is None else validated_data.get("channel")
+
+    #     return Session.create_session(
+    #         session_id = validated_data.get("transactionId"),
+    #         customer_id =  validated_data.get('customerId', None),
+    #         account_id = validated_data.get("accountId", None),  
+    #         type = cls.TRANSACTION_TYPE,
+    #         channel = channel,
+    #     )

app/eco/services/eligibility_check.py

@@ -0,0 +1,63 @@
+from flask import session, jsonify
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.eligibility_check import EligibilityCheckSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+import random
+
+
+class EligibilityCheckService(BaseService):
+    TRANSACTION_TYPE = TransactionType.ELIGIBILITY_CHECK
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the EligibilityCheck request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            # with db.session.begin():
+
+            validated_data = EligibilityCheckService.validate_data(
+                data, EligibilityCheckSchema()
+            )
+
+            account_id = validated_data.get("accountId")
+            customer_id = validated_data.get("customerId")
+            sessionId = validated_data.get("sessionId")
+            msisdn = validated_data.get("msisdn")
+
+            # Simulate processing
+            response_data = {
+                "minEligibleAmount": 1000.0,
+                "maxEligibleAmount": 50000.0,
+                "outstandingDebtAmount": 1000.0,
+            }
+
+            return ResponseHelper.success(data=response_data)
+
+        except ValidationError as err:
+
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            # db.session.rollback()
+            return ResponseHelper.unprocessable_entity(
+                result_description="Validation exception"
+            )
+
+        except ValueError as err:
+            logger.error(f"{getattr(err, 'messages', str(err))}")
+            # db.session.rollback()
+            return ResponseHelper.error(result_description=str(err))
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            # db.session.rollback()
+            return ResponseHelper.internal_server_error()

app/eco/services/get_offer.py

@@ -0,0 +1,67 @@
+from urllib import response
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.get_offer import GetOfferSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+import random
+
+class GetOfferService(BaseService):
+    TRANSACTION_TYPE = TransactionType.GET_OFFERS
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the GetOffer request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            validated_data = GetOfferService.validate_data(
+                data, GetOfferSchema()
+            )
+
+            # Simulate processing
+            offers = [
+                {
+                    "offerId": 14451,
+                    "productId": "2030",
+                    "amount": 10000.0,
+                    "upfrontPayment": 1000.0,
+                    "interestRate": 10.0,
+                    "recommendedRepaymentDates": ["2022-11-30"],
+                    "installmentAmount": 11000.0,
+                    "totalRepaymentAmount": 11000.0
+                },
+                {
+                    "offerId": 16645,
+                    "productId": "2060",
+                    "amount": 10000.0,
+                    "upfrontPayment": 0.0,
+                    "interestRate": 10.0,
+                    "recommendedRepaymentDates": ["2022-11-30", "2023-12-30"],
+                    "installmentAmount": 5761.9,
+                    "totalRepaymentAmount": 11523.8
+                }
+            ]
+
+            response_data = {
+                "outstandingDebtAmount": 0,
+                "offers": offers
+            }
+
+            return ResponseHelper.success(data=response_data)
+
+        except ValidationError as err:
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            return ResponseHelper.unprocessable_entity(result_description="Validation exception")
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            return ResponseHelper.internal_server_error()

app/eco/services/inflow_notification.py

@@ -0,0 +1,38 @@
+from urllib import response
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.inflow_notification import InflowNotificationSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+import random
+
+class InflowNotificationService(BaseService):
+    TRANSACTION_TYPE = TransactionType.INFLOW_NOTIFICATION
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the InflowNotification request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            validated_data = InflowNotificationService.validate_data(
+                data, InflowNotificationSchema()
+            )
+
+            return ResponseHelper.success()
+
+        except ValidationError as err:
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            return ResponseHelper.unprocessable_entity(result_description="Validation exception")
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            return ResponseHelper.internal_server_error()

app/eco/services/loan_information.py

@@ -0,0 +1,50 @@
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.loan_information import LoanInformationSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+class LoanInformationService(BaseService):
+    TRANSACTION_TYPE = TransactionType.LOAN_INFORMATION
+
+    
+    @staticmethod
+    def process_request(data):
+        """
+        Process the LoanInformation request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            # Validate the input data
+            validated_data = LoanInformationService.validate_data(
+                data, LoanInformationSchema()
+            )
+
+            logger.info(f"Fetching loan information for customer {validated_data['customerId']}")
+
+            # Simulate fetching loan information
+            debts = LoanInformationService._generate_sample_debts(validated_data['customerId'])
+            
+            response_data = {
+                "debts": debts,
+                "totalCurrentPayment": sum(debt['currentPaymentAmount'] for debt in debts),
+                "totalDebtAmount": sum(debt['totalRepaymentAmount'] for debt in debts),
+                "resultCode": "00",
+                "resultDescription": "Successful"
+            }
+
+            return ResponseHelper.success(result=loan_data)
+
+        except ValidationError as err:
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            return ResponseHelper.unprocessable_entity(result_description="Validation exception")
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            return ResponseHelper.internal_server_error()

app/eco/services/low_balance_notification.py

@@ -0,0 +1,38 @@
+from urllib import response
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.low_balance_notification import LowBalanceNotificationSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+import random
+
+class LowBalanceNotificationService(BaseService):
+    TRANSACTION_TYPE = TransactionType.LOW_BALANCE_NOTIFICATION
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the LowBalanceNotification request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            validated_data = LowBalanceNotificationService.validate_data(
+                data, LowBalanceNotificationSchema()
+            )
+
+            return ResponseHelper.success()
+
+        except ValidationError as err:
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            return ResponseHelper.unprocessable_entity(result_description="Validation exception")
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            return ResponseHelper.internal_server_error()

app/eco/services/provide_loan.py

@@ -0,0 +1,38 @@
+from urllib import response
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.provide_loan import ProvideLoanSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+import random
+
+class ProvideLoanService(BaseService):
+    TRANSACTION_TYPE = TransactionType.PROVIDE_LOAN
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the ProvideLoan request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            validated_data = ProvideLoanService.validate_data(
+                data, ProvideLoanSchema()
+            )
+
+            return ResponseHelper.success()
+
+        except ValidationError as err:
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            return ResponseHelper.unprocessable_entity(result_description="Validation exception")
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            return ResponseHelper.internal_server_error()

app/eco/services/repayment.py

@@ -0,0 +1,38 @@
+from urllib import response
+from app.utils.logger import logger
+from app.eco.services.base_service import BaseService
+from app.eco.schemas.repayment import RepaymentSchema
+from marshmallow import ValidationError
+from app.eco.enums import TransactionType
+from app.eco.helpers.response_helper import ResponseHelper
+
+import random
+
+class RepaymentService(BaseService):
+    TRANSACTION_TYPE = TransactionType.REPAYMENT
+
+    @staticmethod
+    def process_request(data):
+        """
+        Process the Repayment request.
+
+        Args:
+            data (dict): The request data.
+
+        Returns:
+            dict: A standardized response.
+        """
+        try:
+            validated_data = RepaymentService.validate_data(
+                data, RepaymentSchema()
+            )
+
+            return ResponseHelper.success()
+
+        except ValidationError as err:
+            logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            return ResponseHelper.unprocessable_entity(result_description="Validation exception")
+
+        except Exception as e:
+            logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            return ResponseHelper.internal_server_error()

app/extensions.py

@@ -1,5 +1,7 @@
 from flask_sqlalchemy import SQLAlchemy
 from flask_migrate import Migrate
+from flask_mail import Mail
 
+mail = Mail()
 db = SQLAlchemy()
 migrate = Migrate()

app/models/__init__.py

@@ -10,6 +10,14 @@ from .rac_checks import RACCheck
 from .loan_repayment_schedule import LoanRepaymentSchedule
 from .transaction_offers import TransactionOffer
 from .repayments_data import RepaymentsData
+from .salary import Salary
+from .eco.account import EcoAccount
+from .eco.customer import EcoCustomer
+from .eco.loan import EcoLoan
+from .eco.session import EcoSession
+from .eco.installment import EcoInstallment
+from .eco.offer import EcoOffer
 
 
-__all__ = ['Customer', 'Account', 'Loan', 'Transaction', 'Repayment', 'LoanCharge', 'Offer', 'Charge', 'RACCheck', 'LoanRepaymentSchedule', 'TransactionOffer', 'RepaymentsData']
+
+__all__ = ['Customer', 'Account', 'Loan', 'Transaction', 'Repayment', 'LoanCharge', 'Offer', 'Charge', 'RACCheck', 'LoanRepaymentSchedule', 'TransactionOffer', 'RepaymentsData', 'Salary']

app/models/eco/account.py

@@ -0,0 +1,17 @@
+from sqlalchemy import Column, String, Date, Boolean, Integer
+from app.extensions import db
+
+class Account(db.Model):
+    __tablename__ = 'accounts'
+    __bind_key__ = 'eco'
+
+    id = Column(Integer, primary_key=True)
+    affiliate_code = Column(String(3), nullable=False)
+    customer_id = Column(String(9), nullable=False)
+    account_id = Column(String(10), unique=True, nullable=False)
+    registration_date = Column(Date, nullable=False)
+    account_currency_code = Column(String(3), nullable=False)
+    plastic_card_attached = Column(Boolean, default=False)
+    
+    def __repr__(self):
+        return f"<Account(id={self.id}, account_id={self.account_id}, customer_id={self.customer_id})>"

app/models/eco/customer.py

@@ -0,0 +1,18 @@
+from sqlalchemy import Column, String, Date, Integer
+from sqlalchemy.orm import relationship
+from app.extensions import db
+
+
+class Customer(db.Model):
+    __tablename__ = 'customers'
+    __bind_key__ = 'eco'
+
+    id = Column(Integer, primary_key=True)
+    affiliate_code = Column(String(3), nullable=False)
+    customer_id = Column(String(9), unique=True, nullable=False)
+    msisdn = Column(String(15), nullable=True)
+    created_at = Column(Date, nullable=False)
+
+
+    def __repr__(self):
+        return f"<Customer(id={self.id}, customer_id={self.customer_id}, msisdn={self.msisdn})>"

app/models/eco/installment.py

@@ -0,0 +1,21 @@
+from app.eco.enums.installment_status import InstallmentStatus
+from sqlalchemy import Column, String, Date, Numeric, ForeignKey, Enum, Integer, DateTime
+from app.extensions import db
+import enum
+
+class Installment(db.Model):
+    __tablename__ = 'installments'
+    __bind_key__ = 'eco'
+
+
+    id = Column(Integer, primary_key=True)
+    loan_id = Column(Integer, nullable=False)
+    installment_number = Column(Integer, nullable=False)
+    due_date = Column(Date, nullable=False)
+    amount = Column(Numeric(12, 2), nullable=False)
+    paid_amount = Column(Numeric(12, 2), default=0.00)
+    status = Column(Enum(InstallmentStatus), default=InstallmentStatus.PENDING)
+    penalty_amount = Column(Numeric(12, 2), default=0.00)
+    
+    def __repr__(self):
+        return f"<Installment(id={self.id}, loan_id={self.loan_id}, status={self.status})>"

app/models/eco/loan.py

@@ -0,0 +1,26 @@
+from app.eco.enums.loan_status import LoanStatus
+from sqlalchemy import Column, String, Date, Numeric, Enum
+from app.extensions import db
+import enum
+
+class Loan(db.Model):
+    __tablename__ = 'loans'
+    __bind_key__ = 'eco'
+
+    id = Column(Integer, primary_key=True)
+    request_id = Column(String(50), unique=True, nullable=False)
+    affiliate_code = Column(String(3), nullable=False)
+    customer_id = Column(String(9), nullable=False)
+    account_id = Column(String(10), nullable=False)
+    product_id = Column(String(4), nullable=False)
+    debt_id = Column(String(20), unique=True, nullable=False)
+    initial_credit_amount = Column(Numeric(12, 2), nullable=False)
+    current_balance = Column(Numeric(12, 2), nullable=False)
+    interest_rate = Column(Numeric(5, 2), nullable=False)
+    status = Column(Enum(LoanStatus), default=LoanStatus.PENDING)
+    disbursement_date = Column(Date, nullable=False)
+    due_date = Column(Date, nullable=False)
+    lien_amount = Column(Numeric(12, 2), default=0.00)
+    
+    def __repr__(self):
+        return f"<Loan(id={self.id}, debt_id={self.debt_id}, status={self.status})>"

app/models/eco/offer.py

@@ -0,0 +1,22 @@
+from sqlalchemy import Column, String, Numeric, Date, Integer
+from app.extensions import db
+
+class Offer(db.Model):
+    __tablename__ = 'offers'
+    __bind_key__ = 'eco'
+
+    id = Column(Integer, primary_key=True)
+    offer_id = Column(String(50), unique=True, nullable=False)
+    session_id = Column(String(50), nullable=False)
+    customer_id = Column(String(9), nullable=False)
+    product_id = Column(String(4), nullable=False)  
+    amount = Column(Numeric(12, 2), nullable=False)
+    upfront_payment = Column(Numeric(12, 2), nullable=False)
+    interest_rate = Column(Numeric(5, 2), nullable=False)
+    installment_amount = Column(Numeric(12, 2), nullable=False)
+    total_repayment_amount = Column(Numeric(12, 2), nullable=False)
+    expiration_date = Column(Date, nullable=False)
+    status = Column(String(20), default='AVAILABLE') 
+    
+    def __repr__(self):
+        return f"<Offer(id={self.id}, offer_id={self.offer_id}, status={self.status})>"

app/models/eco/session.py

@@ -0,0 +1,18 @@
+from sqlalchemy import Column, String, DateTime, Integer
+from app.extensions import db
+
+class Session(db.Model):
+    __tablename__ = 'sessions'
+    __bind_key__ = 'eco'
+
+    id = Column(Integer, primary_key=True)
+    session_id = Column(String(50), unique=True, nullable=False)
+    customer_id = Column(String(9), nullable=True)
+    account_id = Column(String(10), nullable=True)
+    msisdn = Column(String(15), nullable=False)
+    channel = Column(String(10), nullable=False) 
+    expires_at = Column(DateTime, nullable=False)
+    status = Column(String(20), default='ACTIVE') 
+    
+    def __repr__(self):
+        return f"<Session(id={self.id}, session_id={self.session_id}, status={self.status})>"

app/models/loan.py

@@ -35,6 +35,7 @@ class Loan(db.Model):
     continuous_fee = db.Column(db.Float, default=0)
     upfront_fee = db.Column(db.Float, nullable=True, default=0.0)
     repayment_amount = db.Column(db.Float, nullable=True, default=0.0)
+    balance = db.Column(db.Float, nullable=True, default=0.0)
     installment_amount = db.Column(db.Float, nullable=True, default=0.0)
     status = db.Column(db.String(20), default='pending')
     tenor = db.Column(db.Integer, nullable=True)
@@ -112,6 +113,7 @@ class Loan(db.Model):
             current_loan_amount = initial_loan_amount,
             upfront_fee = upfront_fee,
             repayment_amount = repayment_amount,
+            balance = repayment_amount,
             installment_amount = installment_amount,
             due_date=due_date,
             tenor = tenor,

app/models/offer.py

@@ -7,8 +7,8 @@ from sqlalchemy.sql import func
 class Offer(db.Model):
     __tablename__ = 'offers'
 
-    id = db.Column(db.String, primary_key=True)
-    product_id = db.Column(db.String, nullable=False)
+    id = db.Column(db.String(50), primary_key=True)
+    product_id = db.Column(db.String(50), nullable=False)
     min_amount = db.Column(db.Float, nullable=False)
     max_amount = db.Column(db.Float, nullable=False)
     tenor = db.Column(db.Integer, nullable=False)

app/models/rac_checks.py

@@ -3,6 +3,7 @@ from app.extensions import db
 from sqlalchemy.orm import relationship
 from sqlalchemy.exc import IntegrityError
 from uuid import uuid4
+import json
 from sqlalchemy.types import JSON
 from sqlalchemy.sql import func
 
@@ -11,11 +12,22 @@ class RACCheck(db.Model):
 
     id = db.Column(db.Integer, primary_key=True, autoincrement=True)
     transaction_id = db.Column(db.String(50), nullable=False)
-    customer_id = db.Column(db.String, nullable=False)
-    account_id = db.Column(db.String, nullable=False)
-    rac_response = db.Column(db.JSON, nullable=False)
+    customer_id = db.Column(db.String(50), nullable=False)
+    account_id = db.Column(db.String(50), nullable=False)
+    rac_response = db.Column(db.Text, nullable=False)
     created_at = db.Column(db.DateTime(timezone=True), server_default=func.now())
     updated_at = db.Column(db.DateTime(timezone=True), server_default=func.now(), onupdate=func.now())
+
+
+    @property
+    def rac_response_data(self):
+        return json.loads(self.rac_response)
+
+    @rac_response_data.setter
+    def rac_response_data(self, value):
+        self.rac_response = json.dumps(value)
+
+
     @classmethod
     def add_rac_check(cls, customer_id, account_id, transaction_id, data = None):
     
@@ -25,10 +37,11 @@ class RACCheck(db.Model):
             customer_id = customer_id,
             account_id = account_id,
             transaction_id = transaction_id,
-            rac_response = data,
             created_at=datetime.now(timezone.utc),
             updated_at=datetime.now(timezone.utc)
         )
+
+        rac_check.rac_response_data = data or {}
         
         try:
             db.session.add(rac_check)
@@ -66,7 +79,7 @@ class RACCheck(db.Model):
             "transactionId": str(self.transaction_id),
             "customerId": self.customer_id,
             "accountId": self.account_id,
-            "racResponse": self.rac_response,
+            "racResponse": self.rac_response_data,
             "createdAt": self.created_at.isoformat(),
             "updatedAt": self.updated_at.isoformat() if self.updated_at else None
         }

app/models/repayment.py

@@ -21,12 +21,16 @@ class Repayment(db.Model):
     created_at = db.Column(db.DateTime(timezone=True), server_default=func.now())
     updated_at = db.Column(db.DateTime(timezone=True), server_default=func.now(), onupdate=func.now())
     transaction_id = db.Column(db.String(50), nullable=True)
-    repay_date = db.Column(db.DateTime, default=datetime.now(timezone.utc))
+    # repay_date = db.Column(db.DateTime, default=datetime.now(timezone.utc))
+    repay_date = db.Column(db.DateTime, nullable=True)
     repay_result = db.Column(db.String(10), nullable=True)
     repay_description = db.Column(db.String(100), nullable=True)
-    verify_date = db.Column(db.DateTime, default=datetime.now(timezone.utc))
+    # verify_date = db.Column(db.DateTime, default=datetime.now(timezone.utc))
+    verify_date = db.Column(db.DateTime, nullable=True)
     verify_result = db.Column(db.String(10), nullable=True)
     verify_description = db.Column(db.String(100), nullable=True)
+    initiated_by = db.Column(db.String(50), nullable=True)
+    salary_amount = db.Column(db.Float, nullable=True, default=0.0)
 
     @classmethod
     def create_repayment(cls, customer_id, loan, transaction_id):
@@ -42,7 +46,8 @@ class Repayment(db.Model):
             product_id=loan.product_id,
             transaction_id = transaction_id,
             created_at=datetime.now(timezone.utc),
-            updated_at=datetime.now(timezone.utc)
+            updated_at=datetime.now(timezone.utc),
+            initiated_by='USER_INITIATED'
         )
 
         try:
@@ -51,6 +56,25 @@ class Repayment(db.Model):
             raise ValueError(f"Database integrity error: {err}")
 
         return repayment
+    
+    def to_dict(self):
+        return {
+            "id": self.id,
+            "loan_id": self.loan_id,
+            "customer_id": self.customer_id,
+            "product_id": self.product_id,
+            "created_at": self.created_at.isoformat() if self.created_at else None,
+            "updated_at": self.updated_at.isoformat() if self.updated_at else None,
+            "transaction_id": self.transaction_id,
+            "repay_date": self.repay_date.isoformat() if self.repay_date else None,
+            "repay_result": self.repay_result,
+            "repay_description": self.repay_description,
+            "verify_date": self.verify_date.isoformat() if self.verify_date else None,
+            "verify_result": self.verify_result,
+            "verify_description": self.verify_description,
+            "initiated_by": self.initiated_by,
+            "salary_amount": self.salary_amount
+        }
 
     def __repr__(self):
         return f'<Repayment {self.id}>'

app/models/repayments_data.py

@@ -15,6 +15,7 @@ class RepaymentsData(db.Model):
     added_date = db.Column(db.DateTime(timezone=True), default=datetime.now(timezone.utc), nullable=False)
     response_code = db.Column(db.String(10), nullable=True)
     response_descr = db.Column(db.String(255), nullable=True)
+    balance = db.Column(db.Float, nullable=True, default=0.0)
 
     def to_dict(self):
         return {
@@ -28,6 +29,7 @@ class RepaymentsData(db.Model):
             "added_date": self.added_date.isoformat() if self.added_date else None,
             "response_code": self.response_code,
             "response_descr": self.response_descr,
+            "balance": self.balance,
         }
 
     def __repr__(self):

app/models/salary.py

@@ -0,0 +1,31 @@
+from datetime import datetime, timezone
+from app.extensions import db
+from sqlalchemy.sql import func
+
+class Salary(db.Model):
+    __tablename__ = 'salaries'
+
+    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
+    customer_id = db.Column(db.String(50), nullable=False)
+    account_id = db.Column(db.String(50), nullable=True)
+    status = db.Column(db.String(20), default='active')
+    amount = db.Column(db.Float, nullable=False, default=0.0)
+    salary_date = db.Column(db.DateTime(timezone=False), server_default=func.now())
+    created_at = db.Column(db.DateTime(timezone=False), server_default=func.now())
+    updated_at = db.Column(db.DateTime(timezone=False), server_default=func.now(), onupdate=func.now())
+
+    def to_dict(self):
+        return {
+            "id": self.id,
+            "customer_id": self.customer_id,
+            "account_id": self.account_id,
+            "status": self.status,
+            "amount": self.amount,
+            "salary_date": self.salary_date.isoformat() if self.salary_date else None,
+            "created_at": self.created_at.isoformat() if self.created_at else None,
+            "updated_at": self.updated_at.isoformat() if self.updated_at else None
+        }
+
+    def __repr__(self):
+        return f'<Salary {self.id} - {self.amount}>'
+    

app/swagger/eco_digifi_swagger.json

@@ -0,0 +1,180 @@
+{
+  "openapi": "3.0.3",
+  "info": {
+    "title": "Swagger Bank Channel to Simbrella FirstAdvance - OpenAPI 3.0",
+    "description": "This is a Simbrella FirstAdvance Backend Server with the OpenAPI 3.0 specification.  \n\n\nSome useful links:\n- [Web Simulated Demo Page](https://digifi-salaryloan.chiefsoft.net/)\n- [Web Management Support Portal](https://digifi-office.chiefsoft.net/auth/login)",
+    "termsOfService": "http://swagger.io/terms/",
+    "contact": {
+      "email": "support@chiefsoft.com"
+    },
+    "license": {
+      "name": "Apache 2.0",
+      "url": "http://www.apache.org/licenses/LICENSE-2.0.html"
+    },
+    "version": "1.0.11"
+  },
+  "servers": [
+    {
+      "url": "http://localhost:4500"
+    },
+    {
+      "url": "http://api.dev.simbrellang.net:4500"
+    },
+        {
+      "url": "https://api.dev.simbrellang.net"
+    }
+  ],
+  "tags": [
+      {
+      "name": "Authorize",
+      "description": "This feature will be used for authorizing customers.",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    },
+    {
+      "name": "AuthorizeRefresh",
+      "description": "This feature will be used for refreshing authorized customers.",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    },
+    {
+      "name": "EligibilityCheck",
+      "description": "Eligibility Check Request",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    },
+    {
+      "name": "SelectOffer",
+      "description": "This method is used the send the offer the customer selected to Simbrella.",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    },
+    {
+      "name": "ProvideLoan",
+      "description": "Provide Loan Request.",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    },
+    {
+      "name": "LoanStatus",
+      "description": "Loan Information Request.",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    },
+    {
+      "name": "Repayment",
+      "description": "Repayment Request.",
+      "externalDocs": {
+        "description": "Find out more",
+        "url": "https://www.simbrellang.net"
+      }
+    }
+  ],
+  "paths": {
+    "/Authorize": {
+      "$ref": "swagger/paths/Authorize.json"
+    },
+    "/AuthorizeRefresh": {
+      "$ref": "swagger/paths/AuthorizeRefresh.json"
+    },
+    "/EligibilityCheck": {
+      "$ref": "swagger/paths/EligibilityCheck.json"
+    },
+    "/SelectOffer": {
+      "$ref": "swagger/paths/SelectOffer.json"
+    },
+    "/ProvideLoan": {
+      "$ref": "swagger/paths/ProvideLoan.json"
+    },
+    "/LoanStatus": {
+      "$ref": "swagger/paths/LoanStatus.json"
+    },
+    "/Repayment": {
+      "$ref": "swagger/paths/Repayment.json"
+    }
+  },
+  "components": {
+    "schemas": {
+      "EligibilityCheckRequest": {
+        "$ref": "swagger/schemas/EligibilityCheckRequest.json"
+      },
+      "EligibilityCheckResponse": {
+        "$ref": "swagger/schemas/EligibilityCheckResponse.json"
+      },
+      "SelectOfferRequest": {
+        "$ref": "swagger/schemas/SelectOfferRequest.json"
+      },
+      "SelectOfferResponse": {
+        "$ref": "swagger/schemas/SelectOfferResponse.json"
+      },
+      "LoanStatusRequest": {
+        "$ref": "swagger/schemas/LoanStatusRequest.json"
+      },
+      "LoanStatusResponse": {
+        "$ref": "swagger/schemas/LoanStatusResponse.json"
+      },
+      "RepaymentRequest": {
+        "$ref": "swagger/schemas/RepaymentRequest.json"
+      },
+      "RepaymentResponse": {
+        "$ref": "swagger/schemas/RepaymentResponse.json"
+      },
+      "CustomerConsentRequest": {
+        "$ref": "swagger/schemas/CustomerConsentRequest.json"
+      },
+      "CustomerConsentResponse": {
+        "$ref": "swagger/schemas/CustomerConsentResponse.json"
+      },
+      "NotificationCallbackRequest": {
+        "$ref": "swagger/schemas/NotificationCallbackRequest.json"
+      },
+      "NotificationCallbackResponse": {
+        "$ref": "swagger/schemas/NotificationCallbackResponse.json"
+      },
+      "ApiResponse": {
+        "$ref": "swagger/schemas/ApiResponse.json"
+      },
+      "AuthorizeResponse": {
+        "$ref": "swagger/schemas/AuthorizeResponse.json"
+      },
+      "AuthorizeRequest": {
+        "$ref": "swagger/schemas/AuthorizeRequest.json"
+      },
+      "AuthorizeRefreshResponse": {
+        "$ref": "swagger/schemas/AuthorizeRefreshResponse.json"
+      },
+      "AuthorizeRefreshRequest": {
+        "$ref": "swagger/schemas/AuthorizeRefreshRequest.json"
+      }
+    },
+    "securitySchemes": {
+      "basicAuth": {
+        "type": "http",
+        "scheme": "basic"
+      },
+      "bearerAuth": {
+        "type": "http",
+        "scheme": "bearer",
+        "bearerFormat": "JWT"
+      }
+    }
+  },
+  "security": [
+    {
+      "basicAuth": [],
+      "bearerAuth": []
+    }
+  ]
+}

app/utils/mail.py

@@ -0,0 +1,40 @@
+from flask_mail import Message
+from flask import current_app
+from app.extensions import mail
+import pandas as pd
+from io import BytesIO
+
+def get_report_data():
+    """
+    Fetch and return loan summary data.
+    """
+    return [
+        {"Type": "Disbursement", "Count": 45},
+        {"Type": "Repayment", "Count": 32},
+    ]
+def send_report_email(report_data: list, recipients: list):
+    """
+    Sends an HTML + Excel report to the given email recipients.
+    """
+    df = pd.DataFrame(report_data)
+    output = BytesIO()
+    df.to_excel(output, index=False)
+    output.seek(0)
+
+    html_table = df.to_html(index=False, border=1)
+
+    msg = Message(
+        subject="Loan Report Summary",
+        recipients=recipients,
+        html=f"<h3>Loan Report Summary</h3>{html_table}",
+    )
+    msg.attach(
+        "loan_report.xlsx",
+        "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
+        output.read()
+    )
+
+    with current_app.app_context():
+        mail.send(msg)
+
+    return "Report email sent"

migrations/versions/05b5494ad406_.py

@@ -0,0 +1,31 @@
+"""empty message
+
+Revision ID: 05b5494ad406
+Revises: 33e09efd85e3
+Create Date: 2025-07-06 09:28:26.264927
+
+"""
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision = "05b5494ad406"
+down_revision = "33e09efd85e3"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column("loans", sa.Column("balance", sa.Float(), nullable=True))
+
+
+# ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column("loans", "balance")
+    # ### end Alembic commands ###

migrations/versions/0acd553309a1_migration_on_tue_jun_10_08_41_00_wat_.py

@@ -1,35 +0,0 @@
-"""Migration on Tue Jun 10 08:41:00 WAT 2025
-
-Revision ID: 0acd553309a1
-Revises: 45790fd659fb
-Create Date: 2025-06-10 08:41:45.222513
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '0acd553309a1'
-down_revision = '45790fd659fb'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('repayments_data',
-    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-    sa.Column('transaction_id', sa.String(length=50), nullable=False),
-    sa.Column('added_date', sa.DateTime(timezone=True), nullable=False),
-    sa.Column('response_code', sa.String(length=10), nullable=True),
-    sa.Column('response_descr', sa.String(length=255), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_table('repayments_data')
-    # ### end Alembic commands ###

migrations/versions/1340e7e578b9_migration_on_thu_apr_10_21_50_01_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Thu Apr 10 21:50:01 UTC 2025
-
-Revision ID: 1340e7e578b9
-Revises: b8f6fd76ead8
-Create Date: 2025-04-10 21:50:32.113149
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '1340e7e578b9'
-down_revision = 'b8f6fd76ead8'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('ref_model', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.drop_column('ref_model')
-
-    # ### end Alembic commands ###

migrations/versions/173ea45db189_migration_on_sat_may_10_09_54_34_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Sat May 10 09:54:34 UTC 2025
-
-Revision ID: 173ea45db189
-Revises: 3105abd795d4
-Create Date: 2025-05-10 09:54:39.380499
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '173ea45db189'
-down_revision = '3105abd795d4'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transaction_offers', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('original_transaction', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transaction_offers', schema=None) as batch_op:
-        batch_op.drop_column('original_transaction')
-
-    # ### end Alembic commands ###

migrations/versions/1b2339f43824_migration_on_thu_apr_24_17_42_25_utc_.py

@@ -1,53 +0,0 @@
-"""Migration on Thu Apr 24 17:42:25 UTC 2025
-
-Revision ID: 1b2339f43824
-Revises: de9ad96ba34e
-Create Date: 2025-04-24 17:43:09.589626
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '1b2339f43824'
-down_revision = 'de9ad96ba34e'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('rac_checks',
-    sa.Column('id', sa.String(), nullable=False),
-    sa.Column('transaction_id', sa.String(length=50), nullable=False),
-    sa.Column('customer_id', sa.String(), nullable=False),
-    sa.Column('account_id', sa.String(), nullable=False),
-    sa.Column('rac_response', sa.JSON(), nullable=False),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.alter_column('amount',
-               existing_type=sa.NUMERIC(precision=10, scale=2),
-               type_=sa.Float(),
-               existing_nullable=True)
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('installment_amount')
-        batch_op.drop_column('repayment_amount')
-        batch_op.drop_column('upfront_fee')
-
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.alter_column('amount',
-               existing_type=sa.Float(),
-               type_=sa.NUMERIC(precision=10, scale=2),
-               existing_nullable=True)
-
-    op.drop_table('rac_checks')
-    # ### end Alembic commands ###

migrations/versions/287ecb02d3d7_migration_on_wed_apr_16_18_35_18_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Wed Apr 16 18:35:18 UTC 2025
-
-Revision ID: 287ecb02d3d7
-Revises: a4847b997191
-Create Date: 2025-04-16 18:36:04.632791
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '287ecb02d3d7'
-down_revision = 'a4847b997191'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.drop_column('transaction_id')
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('transaction_id', sa.VARCHAR(length=50), autoincrement=False, nullable=True))
-
-    # ### end Alembic commands ###

migrations/versions/2a45dd99c9cb_migration_on_fri_apr_25_15_01_00_utc_.py

@@ -1,42 +0,0 @@
-"""Migration on Fri Apr 25 15:01:00 UTC 2025
-
-Revision ID: 2a45dd99c9cb
-Revises: 2cf0c177ca02
-Create Date: 2025-04-25 15:01:51.129681
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '2a45dd99c9cb'
-down_revision = '2cf0c177ca02'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_repayment_schedules', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('product_id', sa.String(length=20), nullable=True))
-        batch_op.add_column(sa.Column('installment_amount', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('total_repayment_amount', sa.Float(), nullable=True))
-        batch_op.drop_column('principal_amount')
-        batch_op.drop_column('interest_amount')
-        batch_op.drop_column('total_installment')
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_repayment_schedules', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('total_installment', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
-        batch_op.add_column(sa.Column('interest_amount', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
-        batch_op.add_column(sa.Column('principal_amount', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
-        batch_op.drop_column('total_repayment_amount')
-        batch_op.drop_column('installment_amount')
-        batch_op.drop_column('product_id')
-
-    # ### end Alembic commands ###

migrations/versions/2cf0c177ca02_migration_on_fri_apr_25_14_02_01_utc_.py

@@ -1,41 +0,0 @@
-"""Migration on Fri Apr 25 14:02:01 UTC 2025
-
-Revision ID: 2cf0c177ca02
-Revises: 1b2339f43824
-Create Date: 2025-04-25 14:02:42.244146
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '2cf0c177ca02'
-down_revision = '1b2339f43824'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('loan_repayment_schedules',
-    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-    sa.Column('loan_id', sa.Integer(), nullable=False),
-    sa.Column('installment_number', sa.Integer(), nullable=False),
-    sa.Column('due_date', sa.DateTime(), nullable=False),
-    sa.Column('principal_amount', sa.Float(), nullable=True),
-    sa.Column('interest_amount', sa.Float(), nullable=True),
-    sa.Column('total_installment', sa.Float(), nullable=True),
-    sa.Column('paid', sa.Boolean(), nullable=True),
-    sa.Column('paid_at', sa.DateTime(), nullable=True),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_table('loan_repayment_schedules')
-    # ### end Alembic commands ###

migrations/versions/2eee4157505f_.py

@@ -1,250 +0,0 @@
-"""empty message
-
-Revision ID: 2eee4157505f
-Revises: 565bc3d0ba6e
-Create Date: 2025-05-16 13:24:41.914400
-
-"""
-from alembic import op
-import sqlalchemy as sa
-from sqlalchemy.dialects import postgresql
-
-# revision identifiers, used by Alembic.
-revision = '2eee4157505f'
-down_revision = '565bc3d0ba6e'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('accounts', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('charges', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('customers', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('loan_repayment_schedules', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('offers', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('rac_checks', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('repayments', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('transaction_offers', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True)
-
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(),
-               type_=sa.DateTime(timezone=True),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-
-    with op.batch_alter_table('transaction_offers', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('repayments', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('rac_checks', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('offers', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('loan_repayment_schedules', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('customers', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('charges', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    with op.batch_alter_table('accounts', schema=None) as batch_op:
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(timezone=True),
-               type_=postgresql.TIMESTAMP(),
-               existing_nullable=True)
-
-    # ### end Alembic commands ###

migrations/versions/3105abd795d4_.py

@@ -1,52 +0,0 @@
-"""empty message
-
-Revision ID: 3105abd795d4
-Revises: 95a52be203c4
-Create Date: 2025-05-07 11:44:18.483694
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '3105abd795d4'
-down_revision = '95a52be203c4'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('rac_checks', schema=None) as batch_op:
-        # Step 1: Drop the default value
-        batch_op.alter_column('id',
-            server_default=None,
-            existing_type=sa.VARCHAR(),
-            existing_nullable=False
-        )
-
-    with op.batch_alter_table('rac_checks', schema=None) as batch_op:
-        # Step 2: Change the column type
-        batch_op.alter_column('id',
-            existing_type=sa.VARCHAR(),
-            type_=sa.Integer(),
-            existing_nullable=False,
-            autoincrement=True,
-            postgresql_using='id::integer'
-        )
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('rac_checks', schema=None) as batch_op:
-        batch_op.alter_column('id',
-               existing_type=sa.Integer(),
-               type_=sa.VARCHAR(),
-               existing_nullable=False,
-               autoincrement=True,
-               existing_server_default=sa.text("''::character varying"))
-
-    # ### end Alembic commands ###

migrations/versions/33e09efd85e3_.py

@@ -0,0 +1,280 @@
+"""empty message
+
+Revision ID: 33e09efd85e3
+Revises: 
+Create Date: 2025-07-03 14:07:14.424548
+
+"""
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy import literal_column
+from sqlalchemy import text
+
+
+# revision identifiers, used by Alembic.
+revision = '33e09efd85e3'
+down_revision = None
+branch_labels = None
+depends_on = None
+sequences_and_triggers = [
+    ("transactions", "transactions_seq", "trg_transactions_id"),
+    ("transaction_offers", "transaction_offers_seq", "trg_transaction_offers_id"),
+    ("salaries", "salaries_seq", "trg_salaries_id"),
+    ("repayments_data", "repayments_data_seq", "trg_repayments_data_id"),
+    ("repayments", "repayments_seq", "trg_repayments_id"),
+    ("rac_checks", "rac_checks_seq", "trg_rac_checks_id"),
+    ("loans", "loans_seq", "trg_loans_id"),
+    (
+        "loan_repayment_schedules",
+        "loan_repayment_schedules_seq",
+        "trg_loan_repayment_schedules_id",
+    ),
+    ("loan_charges", "loan_charges_seq", "trg_loan_charges_id"),
+    ("charges", "charges_seq", "trg_charges_id"),
+]
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table('accounts',
+    sa.Column('id', sa.String(length=50), nullable=False),
+    sa.Column('customer_id', sa.String(length=50), nullable=False),
+    sa.Column('account_type', sa.String(length=50), nullable=True),
+    sa.Column('status', sa.String(length=20), nullable=True),
+    sa.Column('lien_amount', sa.Float(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('charges',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('offer_id', sa.String(length=50), nullable=False),
+    sa.Column('code', sa.String(length=50), nullable=False),
+    sa.Column('percent', sa.Float(), nullable=True),
+    sa.Column('description', sa.Text(), nullable=True),
+    sa.Column('due', sa.Integer(), nullable=False),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('customers',
+    sa.Column('id', sa.String(length=50), nullable=False),
+    sa.Column('msisdn', sa.String(length=20), nullable=False),
+    sa.Column('country_code', sa.String(length=3), nullable=False),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id'),
+    sa.UniqueConstraint('msisdn')
+    )
+    op.create_table('loan_charges',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('loan_id', sa.Integer(), nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=True),
+    sa.Column('code', sa.String(length=50), nullable=False),
+    sa.Column('amount', sa.Float(), nullable=True),
+    sa.Column('percent', sa.Float(), nullable=True),
+    sa.Column('description', sa.Text(), nullable=True),
+    sa.Column('due', sa.Integer(), nullable=False),
+    sa.Column('due_date', sa.DateTime(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('loan_repayment_schedules',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('loan_id', sa.Integer(), nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=True),
+    sa.Column('product_id', sa.String(length=20), nullable=True),
+    sa.Column('installment_number', sa.Integer(), nullable=False),
+    sa.Column('due_date', sa.DateTime(), nullable=False),
+    sa.Column('installment_amount', sa.Float(), nullable=True),
+    sa.Column('total_repayment_amount', sa.Float(), nullable=True),
+    sa.Column('paid', sa.Boolean(), nullable=True),
+    sa.Column('paid_at', sa.DateTime(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('loans',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('customer_id', sa.String(length=50), nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=True),
+    sa.Column('original_transaction', sa.String(length=50), nullable=True),
+    sa.Column('account_id', sa.String(length=50), nullable=False),
+    sa.Column('offer_id', sa.String(length=20), nullable=False),
+    sa.Column('product_id', sa.String(length=20), nullable=True),
+    sa.Column('collection_type', sa.String(length=20), nullable=True),
+    sa.Column('current_loan_amount', sa.Float(), nullable=True),
+    sa.Column('initial_loan_amount', sa.Float(), nullable=False),
+    sa.Column('default_penalty_fee', sa.Float(), nullable=True),
+    sa.Column('continuous_fee', sa.Float(), nullable=True),
+    sa.Column('upfront_fee', sa.Float(), nullable=True),
+    sa.Column('repayment_amount', sa.Float(), nullable=True),
+    sa.Column('installment_amount', sa.Float(), nullable=True),
+    sa.Column('status', sa.String(length=20), nullable=True),
+    sa.Column('tenor', sa.Integer(), nullable=True),
+    sa.Column('due_date', sa.DateTime(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('eligible_amount', sa.Float(), nullable=True),
+    sa.Column('disburse_date', sa.DateTime(), nullable=True),
+    sa.Column('disburse_verify', sa.DateTime(), nullable=True),
+    sa.Column('reference', sa.String(length=50), nullable=True),
+    sa.Column('disburse_result', sa.String(length=10), nullable=True),
+    sa.Column('disburse_description', sa.String(length=100), nullable=True),
+    sa.Column('verify_result', sa.String(length=10), nullable=True),
+    sa.Column('verify_description', sa.String(length=100), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('offers',
+    sa.Column('id', sa.String(length=50), nullable=False),
+    sa.Column('product_id', sa.String(length=50), nullable=False),
+    sa.Column('min_amount', sa.Float(), nullable=False),
+    sa.Column('max_amount', sa.Float(), nullable=False),
+    sa.Column('tenor', sa.Integer(), nullable=False),
+    sa.Column('schedule', sa.Integer(), nullable=True),
+    sa.Column('interest_rate', sa.Float(), nullable=True),
+    sa.Column('management_rate', sa.Float(), nullable=True),
+    sa.Column('insurance_rate', sa.Float(), nullable=True),
+    sa.Column('vat_rate', sa.Float(), nullable=True),
+    sa.Column('list_order', sa.Integer(), nullable=True),
+    sa.Column('max_daily_loans', sa.Integer(), nullable=True),
+    sa.Column('max_active_loans', sa.Integer(), nullable=True),
+    sa.Column('max_life_loans', sa.Integer(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('rac_checks',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=False),
+    sa.Column('customer_id', sa.String(length=50), nullable=False),
+    sa.Column('account_id', sa.String(length=50), nullable=False),
+    sa.Column('rac_response', sa.Text(), nullable=False),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('repayments',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('loan_id', sa.String(length=50), nullable=False),
+    sa.Column('customer_id', sa.String(length=50), nullable=False),
+    sa.Column('product_id', sa.String(length=20), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('transaction_id', sa.String(length=50), nullable=True),
+    sa.Column('repay_date', sa.DateTime(), nullable=True),
+    sa.Column('repay_result', sa.String(length=10), nullable=True),
+    sa.Column('repay_description', sa.String(length=100), nullable=True),
+    sa.Column('verify_date', sa.DateTime(), nullable=True),
+    sa.Column('verify_result', sa.String(length=10), nullable=True),
+    sa.Column('verify_description', sa.String(length=100), nullable=True),
+    sa.Column('initiated_by', sa.String(length=50), nullable=True),
+    sa.Column('salary_amount', sa.Float(), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('repayments_data',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=False),
+    sa.Column('fbn_transaction_id', sa.String(length=50), nullable=True),
+    sa.Column('customer_id', sa.String(length=50), nullable=True),
+    sa.Column('account_id', sa.String(length=50), nullable=True),
+    sa.Column('repayment_amount', sa.Float(), nullable=True),
+    sa.Column('amount_collected', sa.Float(), nullable=True),
+    sa.Column('added_date', sa.DateTime(timezone=True), nullable=False),
+    sa.Column('response_code', sa.String(length=10), nullable=True),
+    sa.Column('response_descr', sa.String(length=255), nullable=True),
+    sa.Column('balance', sa.Float(), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('salaries',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('customer_id', sa.String(length=50), nullable=False),
+    sa.Column('account_id', sa.String(length=50), nullable=True),
+    sa.Column('status', sa.String(length=20), nullable=True),
+    sa.Column('amount', sa.Float(), nullable=False),
+    sa.Column('salary_date', sa.DateTime(), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('created_at', sa.DateTime(), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('transaction_offers',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('customer_id', sa.String(length=50), nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=False),
+    sa.Column('original_transaction', sa.String(length=50), nullable=True),
+    sa.Column('offer_id', sa.String(length=20), nullable=False),
+    sa.Column('product_id', sa.String(length=20), nullable=True),
+    sa.Column('min_amount', sa.Float(), nullable=False),
+    sa.Column('max_amount', sa.Float(), nullable=False),
+    sa.Column('eligible_amount', sa.Float(), nullable=True),
+    sa.Column('tenor', sa.Integer(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('transactions',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('transaction_id', sa.String(length=50), nullable=False),
+    sa.Column('account_id', sa.String(length=50), nullable=True),
+    sa.Column('customer_id', sa.String(length=50), nullable=True),
+    sa.Column('type', sa.String(length=50), nullable=False),
+    sa.Column('channel', sa.String(length=50), nullable=False),
+    sa.Column('phone_number', sa.String(length=50), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+
+    for table, seq, trg in sequences_and_triggers:
+        op.execute(
+            text(
+                f"""
+                BEGIN
+                    EXECUTE IMMEDIATE 'CREATE SEQUENCE {seq} START WITH 1 INCREMENT BY 1 NOCACHE NOCYCLE';
+                EXCEPTION
+                    WHEN OTHERS THEN
+                        IF SQLCODE != -955 THEN RAISE; END IF;
+                END;
+                """
+            )
+        )
+
+        op.execute(
+            text(
+                f"""
+                CREATE OR REPLACE TRIGGER {trg}
+                BEFORE INSERT ON {table}
+                FOR EACH ROW
+                BEGIN
+                    IF ||':'||'NEW.id IS NULL THEN
+                        SELECT {seq}.NEXTVAL INTO '||':'||'NEW.id FROM dual;
+                    END IF;
+                END;
+                """
+            )
+        )
+
+
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('transactions')
+    op.drop_table('transaction_offers')
+    op.drop_table('salaries')
+    op.drop_table('repayments_data')
+    op.drop_table('repayments')
+    op.drop_table('rac_checks')
+    op.drop_table('offers')
+    op.drop_table('loans')
+    op.drop_table('loan_repayment_schedules')
+    op.drop_table('loan_charges')
+    op.drop_table('customers')
+    op.drop_table('charges')
+    op.drop_table('accounts')
+    # ### end Alembic commands ###
+
+    for table, seq, trg in sequences_and_triggers:
+        op.execute(text(f"DROP TRIGGER {trg}"))
+        op.execute(text(f"DROP SEQUENCE {seq}"))

migrations/versions/38acee611d55_migration_for_mloan_table.py

@@ -1,32 +0,0 @@
-"""Migration for mloan table
-
-Revision ID: 38acee611d55
-Revises: f1e83a993034
-Create Date: 2025-04-30 09:55:30.552838
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '38acee611d55'
-down_revision = 'f1e83a993034'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('tenor', sa.Integer(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('tenor')
-
-    # ### end Alembic commands ###

migrations/versions/45790fd659fb_.py

@@ -1,54 +0,0 @@
-"""empty message
-
-Revision ID: 45790fd659fb
-Revises: b3a5e10bc77e
-Create Date: 2025-06-04 12:37:48.180736
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '45790fd659fb'
-down_revision = 'b3a5e10bc77e'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('disburse_result', sa.String(length=10), nullable=True))
-        batch_op.add_column(sa.Column('disburse_description', sa.String(length=100), nullable=True))
-        batch_op.add_column(sa.Column('verify_result', sa.String(length=10), nullable=True))
-        batch_op.add_column(sa.Column('verify_description', sa.String(length=100), nullable=True))
-
-    with op.batch_alter_table('repayments', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('repay_date', sa.DateTime(), nullable=True))
-        batch_op.add_column(sa.Column('repay_result', sa.String(length=10), nullable=True))
-        batch_op.add_column(sa.Column('repay_description', sa.String(length=100), nullable=True))
-        batch_op.add_column(sa.Column('verify_date', sa.DateTime(), nullable=True))
-        batch_op.add_column(sa.Column('verify_result', sa.String(length=10), nullable=True))
-        batch_op.add_column(sa.Column('verify_description', sa.String(length=100), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('repayments', schema=None) as batch_op:
-        batch_op.drop_column('verify_description')
-        batch_op.drop_column('verify_result')
-        batch_op.drop_column('verify_date')
-        batch_op.drop_column('repay_description')
-        batch_op.drop_column('repay_result')
-        batch_op.drop_column('repay_date')
-
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('verify_description')
-        batch_op.drop_column('verify_result')
-        batch_op.drop_column('disburse_description')
-        batch_op.drop_column('disburse_result')
-
-    # ### end Alembic commands ###

migrations/versions/565bc3d0ba6e_migration_on_sat_may_10_12_54_52_utc_.py

@@ -1,34 +0,0 @@
-"""Migration on Sat May 10 12:54:52 UTC 2025
-
-Revision ID: 565bc3d0ba6e
-Revises: 173ea45db189
-Create Date: 2025-05-10 12:54:56.683215
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '565bc3d0ba6e'
-down_revision = '173ea45db189'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('disburse_date', sa.DateTime(), nullable=True))
-        batch_op.add_column(sa.Column('disburse_verify', sa.DateTime(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('disburse_verify')
-        batch_op.drop_column('disburse_date')
-
-    # ### end Alembic commands ###

migrations/versions/610b7e9d15a6_migration_on_fri_apr_11_14_15_19_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Fri Apr 11 14:15:19 UTC 2025
-
-Revision ID: 610b7e9d15a6
-Revises: 9bb0367eb486
-Create Date: 2025-04-11 14:16:12.533227
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '610b7e9d15a6'
-down_revision = '9bb0367eb486'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('transaction_id', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('transaction_id')
-
-    # ### end Alembic commands ###

migrations/versions/783a023a477f_migration_on_mon_apr_14_15_15_05_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Mon Apr 14 15:15:05 UTC 2025
-
-Revision ID: 783a023a477f
-Revises: f6cd1bfc8832
-Create Date: 2025-04-14 15:15:36.991148
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '783a023a477f'
-down_revision = 'f6cd1bfc8832'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('customer_id', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.drop_column('customer_id')
-
-    # ### end Alembic commands ###

migrations/versions/86e701febdda_.py

@@ -1,41 +0,0 @@
-"""empty message
-
-Revision ID: 86e701febdda
-Revises: eb99c7fb9e09
-Create Date: 2025-04-29 07:59:33.305967
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '86e701febdda'
-down_revision = 'eb99c7fb9e09'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('transaction_offers',
-    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-    sa.Column('customer_id', sa.String(length=50), nullable=False),
-    sa.Column('transaction_id', sa.String(length=50), nullable=False),
-    sa.Column('offer_id', sa.String(length=20), nullable=False),
-    sa.Column('product_id', sa.String(length=20), nullable=True),
-    sa.Column('min_amount', sa.Float(), nullable=False),
-    sa.Column('max_amount', sa.Float(), nullable=False),
-    sa.Column('eligible_amount', sa.Float(), nullable=True),
-    sa.Column('tenor', sa.Integer(), nullable=True),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_table('transaction_offers')
-    # ### end Alembic commands ###

migrations/versions/89759cebb9c6_migration_on_sat_apr_26_12_50_46_utc_.py

@@ -1,38 +0,0 @@
-"""Migration on Sat Apr 26 12:50:46 UTC 2025
-
-Revision ID: 89759cebb9c6
-Revises: 2a45dd99c9cb
-Create Date: 2025-04-26 12:50:49.771355
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '89759cebb9c6'
-down_revision = '2a45dd99c9cb'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('offers', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('interest_rate', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('management_rate', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('insurance_rate', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('vat_rate', sa.Float(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('offers', schema=None) as batch_op:
-        batch_op.drop_column('vat_rate')
-        batch_op.drop_column('insurance_rate')
-        batch_op.drop_column('management_rate')
-        batch_op.drop_column('interest_rate')
-
-    # ### end Alembic commands ###

migrations/versions/95a52be203c4_migration_on_sat_may_3_21_53_29_utc_2025.py

@@ -1,32 +0,0 @@
-"""Migration on Sat May  3 21:53:29 UTC 2025
-
-Revision ID: 95a52be203c4
-Revises: 38acee611d55
-Create Date: 2025-05-03 21:53:32.154029
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '95a52be203c4'
-down_revision = '38acee611d55'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('eligible_amount', sa.Float(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('eligible_amount')
-
-    # ### end Alembic commands ###

migrations/versions/9bb0367eb486_migration_on_fri_apr_11_12_48_01_utc_.py

@@ -1,40 +0,0 @@
-"""Migration on Fri Apr 11 12:48:01 UTC 2025
-
-Revision ID: 9bb0367eb486
-Revises: fd447d78b161
-Create Date: 2025-04-11 12:48:36.145311
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = '9bb0367eb486'
-down_revision = 'fd447d78b161'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('product_id', sa.String(length=20), nullable=True))
-        batch_op.add_column(sa.Column('current_loan_amount', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('default_penalty_fee', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('continuous_fee', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('due_date', sa.DateTime(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('due_date')
-        batch_op.drop_column('continuous_fee')
-        batch_op.drop_column('default_penalty_fee')
-        batch_op.drop_column('current_loan_amount')
-        batch_op.drop_column('product_id')
-
-    # ### end Alembic commands ###

migrations/versions/a4847b997191_migration_on_wed_apr_16_17_42_49_utc_.py

@@ -1,57 +0,0 @@
-"""Migration on Wed Apr 16 17:42:49 UTC 2025
-
-Revision ID: a4847b997191
-Revises: 783a023a477f
-Create Date: 2025-04-16 17:43:22.509659
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'a4847b997191'
-down_revision = '783a023a477f'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('loan_charges',
-    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-    sa.Column('loan_id', sa.Integer(), nullable=False),
-    sa.Column('transaction_id', sa.String(length=50), nullable=True),
-    sa.Column('code', sa.String(length=50), nullable=False),
-    sa.Column('amount', sa.Float(), nullable=True),
-    sa.Column('percent', sa.Float(), nullable=True),
-    sa.Column('description', sa.Text(), nullable=True),
-    sa.Column('due', sa.Integer(), nullable=False),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    op.create_table('offers',
-    sa.Column('id', sa.String(), nullable=False),
-    sa.Column('product_id', sa.String(), nullable=False),
-    sa.Column('min_amount', sa.Float(), nullable=False),
-    sa.Column('max_amount', sa.Float(), nullable=False),
-    sa.Column('tenor', sa.Integer(), nullable=False),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('product_id', sa.String(length=20), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('product_id')
-
-    op.drop_table('offers')
-    op.drop_table('loan_charges')
-    # ### end Alembic commands ###

migrations/versions/b3a5e10bc77e_.py

@@ -1,32 +0,0 @@
-"""empty message
-
-Revision ID: b3a5e10bc77e
-Revises: e8dd9b841ad7
-Create Date: 2025-05-27 01:52:48.538333
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'b3a5e10bc77e'
-down_revision = 'e8dd9b841ad7'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('reference', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('reference')
-
-    # ### end Alembic commands ###

migrations/versions/b54422fb31e0_.py

@@ -1,46 +0,0 @@
-"""empty message
-
-Revision ID: b54422fb31e0
-Revises: 0acd553309a1
-Create Date: 2025-06-16 12:24:09.159498
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'b54422fb31e0'
-down_revision = '0acd553309a1'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('repayments_data', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('fbn_transaction_id', sa.String(length=50), nullable=True))
-        batch_op.add_column(sa.Column('customer_id', sa.String(length=50), nullable=True))
-        batch_op.add_column(sa.Column('account_id', sa.String(length=50), nullable=True))
-        batch_op.add_column(sa.Column('repayment_amount', sa.Float(), nullable=True))
-        batch_op.add_column(sa.Column('amount_collected', sa.Float(), nullable=True))
-
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('phone_number', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.drop_column('phone_number')
-
-    with op.batch_alter_table('repayments_data', schema=None) as batch_op:
-        batch_op.drop_column('amount_collected')
-        batch_op.drop_column('repayment_amount')
-        batch_op.drop_column('account_id')
-        batch_op.drop_column('customer_id')
-        batch_op.drop_column('fbn_transaction_id')
-
-    # ### end Alembic commands ###

migrations/versions/b8f6fd76ead8_migration_on_thu_apr_10_16_21_45_utc_.py

@@ -1,86 +0,0 @@
-"""Migration on Thu Apr 10 16:21:45 UTC 2025
-
-Revision ID: b8f6fd76ead8
-Revises: 
-Create Date: 2025-04-10 16:22:15.946157
-
-"""
-from alembic import op
-import sqlalchemy as sa
-from sqlalchemy.dialects import postgresql
-
-# revision identifiers, used by Alembic.
-revision = 'b8f6fd76ead8'
-down_revision = None
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('repayments',
-    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-    sa.Column('loan_id', sa.String(length=50), nullable=False),
-    sa.Column('customer_id', sa.String(length=50), nullable=False),
-    sa.Column('product_id', sa.String(length=20), nullable=True),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.alter_column('id',
-               existing_type=sa.VARCHAR(length=50),
-               type_=sa.Integer(),
-               existing_nullable=False,
-               autoincrement=True,
-               existing_server_default=sa.text("nextval('loan_id_seq'::regclass)"))
-
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.alter_column('channel',
-               existing_type=sa.VARCHAR(length=8),
-               type_=sa.String(length=50),
-               existing_nullable=False)
-        batch_op.alter_column('created_at',
-               existing_type=postgresql.TIMESTAMP(timezone=True),
-               type_=sa.DateTime(),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-        batch_op.alter_column('updated_at',
-               existing_type=postgresql.TIMESTAMP(timezone=True),
-               type_=sa.DateTime(),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-        batch_op.drop_constraint('transactions_id_key', type_='unique')
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.create_unique_constraint('transactions_id_key', ['id'])
-        batch_op.alter_column('updated_at',
-               existing_type=sa.DateTime(),
-               type_=postgresql.TIMESTAMP(timezone=True),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-        batch_op.alter_column('created_at',
-               existing_type=sa.DateTime(),
-               type_=postgresql.TIMESTAMP(timezone=True),
-               existing_nullable=True,
-               existing_server_default=sa.text('now()'))
-        batch_op.alter_column('channel',
-               existing_type=sa.String(length=50),
-               type_=sa.VARCHAR(length=8),
-               existing_nullable=False)
-
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.alter_column('id',
-               existing_type=sa.Integer(),
-               type_=sa.VARCHAR(length=50),
-               existing_nullable=False,
-               autoincrement=True,
-               existing_server_default=sa.text("nextval('loan_id_seq'::regclass)"))
-
-    op.drop_table('repayments')
-    # ### end Alembic commands ###

migrations/versions/de9ad96ba34e_migration_on_thu_apr_17_14_15_36_utc_.py

@@ -1,38 +0,0 @@
-"""Migration on Thu Apr 17 14:15:36 UTC 2025
-
-Revision ID: de9ad96ba34e
-Revises: ec8d97f9b584
-Create Date: 2025-04-17 14:16:16.537466
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'de9ad96ba34e'
-down_revision = 'ec8d97f9b584'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('charges',
-    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
-    sa.Column('offer_id', sa.String(length=50), nullable=False),
-    sa.Column('code', sa.String(length=50), nullable=False),
-    sa.Column('percent', sa.Float(), nullable=True),
-    sa.Column('description', sa.Text(), nullable=True),
-    sa.Column('due', sa.Integer(), nullable=False),
-    sa.Column('created_at', sa.DateTime(), nullable=True),
-    sa.Column('updated_at', sa.DateTime(), nullable=True),
-    sa.PrimaryKeyConstraint('id')
-    )
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_table('charges')
-    # ### end Alembic commands ###

migrations/versions/e8dd9b841ad7_.py

@@ -1,36 +0,0 @@
-"""empty message
-
-Revision ID: e8dd9b841ad7
-Revises: 2eee4157505f
-Create Date: 2025-05-19 11:46:19.204637
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'e8dd9b841ad7'
-down_revision = '2eee4157505f'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('offers', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('max_daily_loans', sa.Integer(), nullable=True))
-        batch_op.add_column(sa.Column('max_active_loans', sa.Integer(), nullable=True))
-        batch_op.add_column(sa.Column('max_life_loans', sa.Integer(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('offers', schema=None) as batch_op:
-        batch_op.drop_column('max_life_loans')
-        batch_op.drop_column('max_active_loans')
-        batch_op.drop_column('max_daily_loans')
-
-    # ### end Alembic commands ###

migrations/versions/eb99c7fb9e09_migration_on_sat_apr_26_19_02_17_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Sat Apr 26 19:02:17 UTC 2025
-
-Revision ID: eb99c7fb9e09
-Revises: 89759cebb9c6
-Create Date: 2025-04-26 19:02:20.443678
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'eb99c7fb9e09'
-down_revision = '89759cebb9c6'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('original_transaction', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.drop_column('original_transaction')
-
-    # ### end Alembic commands ###

migrations/versions/ec8d97f9b584_migration_on_thu_apr_17_10_40_05_utc_.py

@@ -1,34 +0,0 @@
-"""Migration on Thu Apr 17 10:40:05 UTC 2025
-
-Revision ID: ec8d97f9b584
-Revises: 287ecb02d3d7
-Create Date: 2025-04-17 10:40:34.751272
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'ec8d97f9b584'
-down_revision = '287ecb02d3d7'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('transaction_id', sa.String(length=50), nullable=True))
-        batch_op.add_column(sa.Column('due_date', sa.DateTime(), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_charges', schema=None) as batch_op:
-        batch_op.drop_column('due_date')
-        batch_op.drop_column('transaction_id')
-
-    # ### end Alembic commands ###

migrations/versions/f1e83a993034_migration_on_tue_apr_29_20_43_35_utc_.py

@@ -1,32 +0,0 @@
-"""Migration on Tue Apr 29 20:43:35 UTC 2025
-
-Revision ID: f1e83a993034
-Revises: 86e701febdda
-Create Date: 2025-04-29 20:43:38.595543
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'f1e83a993034'
-down_revision = '86e701febdda'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_repayment_schedules', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('transaction_id', sa.String(length=50), nullable=True))
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loan_repayment_schedules', schema=None) as batch_op:
-        batch_op.drop_column('transaction_id')
-
-    # ### end Alembic commands ###

migrations/versions/f6cd1bfc8832_migration_on_fri_apr_11_14_34_36_utc_.py

@@ -1,34 +0,0 @@
-"""Migration on Fri Apr 11 14:34:36 UTC 2025
-
-Revision ID: f6cd1bfc8832
-Revises: 610b7e9d15a6
-Create Date: 2025-04-11 14:35:07.093967
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'f6cd1bfc8832'
-down_revision = '610b7e9d15a6'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('collection_type', sa.String(length=20), nullable=True))
-        batch_op.drop_column('product_id')
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('loans', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('product_id', sa.VARCHAR(length=20), autoincrement=False, nullable=True))
-        batch_op.drop_column('collection_type')
-
-    # ### end Alembic commands ###

migrations/versions/fd447d78b161_migration_on_fri_apr_11_12_02_45_utc_.py

@@ -1,38 +0,0 @@
-"""Migration on Fri Apr 11 12:02:45 UTC 2025
-
-Revision ID: fd447d78b161
-Revises: 1340e7e578b9
-Create Date: 2025-04-11 12:03:28.346671
-
-"""
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision = 'fd447d78b161'
-down_revision = '1340e7e578b9'
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.alter_column('account_id',
-               existing_type=sa.VARCHAR(length=50),
-               nullable=True)
-        batch_op.drop_column('ref_model')
-
-    # ### end Alembic commands ###
-
-
-def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    with op.batch_alter_table('transactions', schema=None) as batch_op:
-        batch_op.add_column(sa.Column('ref_model', sa.VARCHAR(length=50), autoincrement=False, nullable=True))
-        batch_op.alter_column('account_id',
-               existing_type=sa.VARCHAR(length=50),
-               nullable=False)
-
-    # ### end Alembic commands ###

requirements.txt

@@ -6,6 +6,7 @@ flask-sqlalchemy
 flask-migrate
 psycopg2-binary
 alembic
+oracledb
 
 # Schema for validations
 Flask-Marshmallow==0.15.0
@@ -39,3 +40,6 @@ confluent-kafka==1.9.2
 
 python-dateutil
 
+Flask-Mail==0.10.0
+pandas==2.1.3
+openpyxl==3.1.5