[add]: db sessions

app/api/services/repayment.py

@@ -25,14 +25,15 @@ class RepaymentService(BaseService):
             dict: A standardized response.
         """
         try:
-            validated_data = RepaymentService.validate_data(data, RepaymentSchema())
-            customer_id =  validated_data.get('customerId')
-            request_id =  validated_data.get('requestId')
-            loan_id = validated_data.get('debtId')
-            product_id = validated_data.get('productId')
-
-  
             with db.session.begin():
+                validated_data = RepaymentService.validate_data(data, RepaymentSchema())
+                customer_id =  validated_data.get('customerId')
+                request_id =  validated_data.get('requestId')
+                loan_id = validated_data.get('debtId')
+                product_id = validated_data.get('productId')
+
+    
+        
             # Save the repayment details  
                 repayment = Repayment.create_repayment(
                     customer_id = customer_id,
@@ -47,6 +48,8 @@ class RepaymentService(BaseService):
                         "message": "Failed to save repayment details."
                     }), 400
                 
+                db.session.flush()
+                
                 validated_data['refId'] = repayment.id
                 validated_data['refModel'] = "repayment"
                 
@@ -62,29 +65,31 @@ class RepaymentService(BaseService):
                     }), 400
 
 
-            # Simulated processing logic
-            response_data = {
-                "customerId": customer_id,
-                "productId": product_id,
-                "debtId": loan_id,
-                "resultCode": "00",
-                "resultDescription": "Successful"
-            }
+                # Simulated processing logic
+                response_data = {
+                    "customerId": customer_id,
+                    "productId": product_id,
+                    "debtId": loan_id,
+                    "resultCode": "00",
+                    "resultDescription": "Successful"
+                }
 
-            # return ResponseHelper.success(
-            #     data=response_data,
-            #     message="Repayment processed successfully"
-            # )
+                # return ResponseHelper.success(
+                #     data=response_data,
+                #     message="Repayment processed successfully"
+                # )
 
-            # Call Kafka in a background thread
-            thread = Thread(target=RepaymentService.async_send_to_kafka, args=(response_data, request_id, "LOAN_REPAYMENT"))
-            thread.start()
+                # Call Kafka in a background thread
+                thread = Thread(target=RepaymentService.async_send_to_kafka, args=(response_data, request_id, "LOAN_REPAYMENT"))
+                thread.start()
 
-            return response_data
+                db.session.commit()
+                return response_data
 
         except ValidationError as err:
 
             logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
+            db.session.rollback() 
 
             return jsonify({
                 "message": "Validation exception"
@@ -92,6 +97,7 @@ class RepaymentService(BaseService):
         
         except  ValueError as err:
             logger.error(f"{getattr(err, 'messages', str(err))}")
+            db.session.rollback() 
 
             return jsonify({
                 "message": str(err)
@@ -99,6 +105,7 @@ class RepaymentService(BaseService):
 
         except Exception as e:
             logger.error(f"An error occurred: {str(e)}", exc_info=True)
+            db.session.rollback() 
             return jsonify({
                 "message": "Internal Server Error"
                 }) , 500