[add]: Penal Charges

# Conflicts:
#	app/config.py

app/api/routes/routes.py

@@ -111,8 +111,8 @@ def get_dashboard():
 def get_loans():
     # Extract query parameters for filtering
     filters = {
-        'id': request.args.get('id'),
-        'customer_id': request.args.get('customer_id'),
+        'username': request.args.get('id'),
+        'email': request.args.get('customer_id'),
         'account_id': request.args.get('account_id'),
         'status': request.args.get('status'),
         'tenor': request.args.get('tenor'),
@@ -132,6 +132,35 @@ def get_loans():
     response = LoanService.process_request(filters)
     return response
 
+
+@api.route('/recent-loans', methods=['GET'])
+# @token_required
+def get_recent_loans():
+    # Extract query parameters for filtering
+    filters = {
+        'username': request.args.get('id'),
+        'email': request.args.get('customer_id'),
+        'account_id': request.args.get('account_id'),
+        'status': request.args.get('status'),
+        'tenor': request.args.get('tenor'),
+        'offer_id': request.args.get('offer_id'),
+        'product_id': request.args.get('product_id'),
+        'transaction_id': request.args.get('transaction_id'),
+        'original_transaction': request.args.get('original_transaction'),
+        'start_date': request.args.get('start_date'),
+        'end_date': request.args.get('end_date'),
+        'due_before': request.args.get('due_before'),
+        'due_after': request.args.get('due_after'),
+        'page': request.args.get('page', 1),
+        'limit': request.args.get('limit', 20)
+    }
+    # logger.info(f"Get loans request received with filters: {filters}")
+
+    response = LoanService.process_request(filters, True)
+    return response
+
+
+
 @api.route('/transactions', methods=['GET'])
 # @token_required
 def get_transactions():

app/api/services/loan_repayment_schedule_service.py

@@ -82,6 +82,9 @@ class LoanRepaymentScheduleService:
                     'total_repayment_amount': schedule.total_repayment_amount,
                     'paid': schedule.paid,
                     'paid_at': schedule.paid_at.isoformat() if schedule.paid_at else None,
+                    'penal_charge': schedule.penal_charge,
+                    'penal_count': schedule.penal_count,
+                    'last_penal_date': schedule.last_penal_date.isoformat() if schedule.last_penal_date else None,
                     'created_at': schedule.created_at.isoformat() if schedule.created_at else None,
                     'updated_at': schedule.updated_at.isoformat() if schedule.updated_at else None
                 })

app/api/services/loan_service.py

@@ -13,7 +13,7 @@ class LoanService:
     """
 
     @staticmethod
-    def process_request(filters=None):
+    def process_request(filters=None, recent_only=False):
         """
         Process the get loans request.
 
@@ -78,7 +78,8 @@ class LoanService:
                 due_before=due_before,
                 due_after=due_after,
                 page=page,
-                limit=limit
+                limit=limit,
+                recent_only=recent_only,
             )
 
             logger.info(f"Result from loans model cme back ")
@@ -115,6 +116,8 @@ class LoanService:
                     'verifyDescription': loan.verify_description,
                     'disburseDate': loan.disburse_date.isoformat() if loan.disburse_date else None,
                     'disburseVerify': loan.disburse_verify.isoformat() if loan.disburse_verify else None,
+                    'totalPenalCharge': loan.total_penal_charge,
+                    'lastPenalDate': loan.last_penal_date.isoformat() if loan.last_penal_date else None,
                 })
 
             # Calculate total pages

app/config.py

@@ -24,7 +24,9 @@ class Config:
 
 
     # 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_DATABASE_URI_INTERNAL = (f"oracle+oracledb://{DATABASE_USER}:{DATABASE_PASSWORD}@{DNS}")
+    SQLALCHEMY_DATABASE_URI = os.getenv("SQLALCHEMY_DATABASE_URI_FULL", SQLALCHEMY_DATABASE_URI_INTERNAL)
+
 
     SQLALCHEMY_TRACK_MODIFICATIONS = False
     SIMBRELLA_BASE_URL = os.getenv("SIMBRELLA_BASE_URL", "http://127.0.0.1:6337")

app/models/loan.py

@@ -45,6 +45,10 @@ class Loan(db.Model):
     reference = db.Column(db.String(50), nullable=True)
     balance = db.Column(db.Float, nullable=True, default=0.0)
 
+    total_penal_charge = db.Column(db.Float, default=0.0)
+    last_penal_date = db.Column(db.DateTime, nullable=True)
+
+
     customer = relationship(
         "Customer",
         primaryjoin="Customer.id == Loan.customer_id",
@@ -55,7 +59,7 @@ class Loan(db.Model):
     @classmethod
     def get_all_loans(cls, id=None, customer_id=None, account_id=None, status=None, tenor=None, offer_id=None,
                       product_id=None, start_date=None, end_date=None, due_before=None, due_after=None,
-                      transaction_id=None, original_transaction=None, page=1, limit=20):
+                      transaction_id=None, original_transaction=None, page=1, limit=20, recent_only= False):
         """
         Get all loans with optional filtering
 
@@ -79,55 +83,60 @@ class Loan(db.Model):
         """
         query = cls.query
         logger.info(f"Get all loan models from loans model cme back")
-        # Apply filters if provided
-        if id:
-            query = query.filter(cls.id == id)
+        if recent_only:
+            query = query.order_by(cls.created_at.desc()).limit(10)
+            # Get total count before pagination
+            total_count = query.count()
+        else:
+            # Apply filters if provided
+            if id:
+                query = query.filter(cls.id == id)
 
-        if customer_id:
-            query = query.filter(cls.customer_id == customer_id)
+            if customer_id:
+                query = query.filter(cls.customer_id == customer_id)
 
-        if account_id:
-            query = query.filter(cls.account_id == account_id)
+            if account_id:
+                query = query.filter(cls.account_id == account_id)
 
-        if status:
-            query = query.filter(cls.status == status)
+            if status:
+                query = query.filter(cls.status == status)
 
-        if tenor:
-            query = query.filter(cls.tenor == tenor)
+            if tenor:
+                query = query.filter(cls.tenor == tenor)
 
-        if offer_id:
-            query = query.filter(cls.offer_id == offer_id)
+            if offer_id:
+                query = query.filter(cls.offer_id == offer_id)
 
-        if product_id:
-            query = query.filter(cls.product_id == product_id)
+            if product_id:
+                query = query.filter(cls.product_id == product_id)
 
-        if transaction_id:
-            query = query.filter(cls.transaction_id == transaction_id)
+            if transaction_id:
+                query = query.filter(cls.transaction_id == transaction_id)
 
-        if original_transaction:
-            query = query.filter(cls.original_transaction == original_transaction)
+            if original_transaction:
+                query = query.filter(cls.original_transaction == original_transaction)
 
-        if start_date:
-            query = query.filter(cls.created_at >= start_date)
+            if start_date:
+                query = query.filter(cls.created_at >= start_date)
 
-        if end_date:
-            query = query.filter(cls.created_at <= end_date)
+            if end_date:
+                query = query.filter(cls.created_at <= end_date)
 
-        if due_before:
-            query = query.filter(cls.due_date <= due_before)
+            if due_before:
+                query = query.filter(cls.due_date <= due_before)
 
-        if due_after:
-            query = query.filter(cls.due_date >= due_after)
+            if due_after:
+                query = query.filter(cls.due_date >= due_after)
 
-        # Order by created_at descending (newest first)
-        query = query.order_by(cls.created_at.desc())
+            # Order by created_at descending (newest first)
+            query = query.order_by(cls.created_at.desc())
 
-        # Get total count before pagination
-        total_count = query.count()
+            # Get total count before pagination
+            total_count = query.count()
 
-        # Apply pagination
-        offset = (page - 1) * limit
-        query = query.limit(limit).offset(offset)
+            # Apply pagination
+            offset = (page - 1) * limit
+            query = query.limit(limit).offset(offset)
 
         return query.all(), total_count
 
@@ -164,6 +173,8 @@ class Loan(db.Model):
             'disburseVerify': self.disburse_verify.isoformat() if self.disburse_verify else None,
             'reference': self.reference,
             'balance': self.balance,
+            'totalPenalCharge': self.total_penal_charge,
+            'lastPenalDate': self.last_penal_date.isoformat() if self.last_penal_date else None,
         }
 
     def __repr__(self):

app/models/loan_repayment_schedule.py

@@ -20,6 +20,12 @@ class LoanRepaymentSchedule(db.Model):
     created_at = db.Column(db.DateTime, default=datetime.now(timezone.utc))
     updated_at = db.Column(db.DateTime, default=datetime.now(timezone.utc), onupdate=datetime.now(timezone.utc))
 
+
+    penal_charge = db.Column(db.Float, default=0.0)
+    penal_count = db.Column(db.Integer, default=0)
+    last_penal_date = db.Column(db.DateTime, nullable=True)
+
+
     # loan = relationship(
     #     "Loan",
     #     primaryjoin="LoanRepaymentSchedule.loan_id == Loan.id",
@@ -96,6 +102,9 @@ class LoanRepaymentSchedule(db.Model):
             'total_repayment_amount': self.total_repayment_amount,
             'paid': self.paid,
             'paid_at': self.paid_at.isoformat() if self.paid_at else None,
+            'penal_charge': self.penal_charge,
+            'penal_count': self.penal_count,
+            'last_penal_date': self.last_penal_date.isoformat() if self.last_penal_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
         }

app/swagger/digifi_swagger.json

@@ -33,14 +33,17 @@
       "url": "http://www.simbrellang.net:14700"
     },
     {
-      "url" : "http://10.10.11.17:4300"
+      "url": "http://10.10.11.17:4300"
     },
     {
-      "url" : "http://10.10.11.17:4700"
+      "url": "http://10.10.11.17:4700"
+    },
+    {
+      "url": "http://10.2.249.133:4700"
     }
   ],
   "tags": [
-      {
+    {
       "name": "Authorize",
       "description": "This feature will be used for authorizing customers.",
       "externalDocs": {
@@ -145,7 +148,9 @@
     },
     "/health": {
       "get": {
-        "tags": ["Health"],
+        "tags": [
+          "Health"
+        ],
         "summary": "Health Check",
         "description": "Returns service health information including DB connection status.",
         "responses": {
@@ -168,7 +173,9 @@
                 "example": {
                   "status": "ok",
                   "db_status": "Connection Failed",
-                  "error":["could not connect to server: Connection refused"]
+                  "error": [
+                    "could not connect to server: Connection refused"
+                  ]
                 }
               }
             }