Fix data

2025-07-06 20:16:34 -04:00
parent 6c2cc4273b
commit 5ef94d04b2
4 changed files with 65 additions and 7 deletions
@@ -18,12 +18,57 @@ class MyProductsService(BaseService):

    @staticmethod
    def process_subscription(data):
-        response_data = {
-            "subscription": "No ready",
-            "member_id": 1,
-            "uid": '',
-        }
-        return ResponseHelper.success(data=response_data)
+        try:
+            with db.session.begin():
+                logger.info(f"Incoming MyProduct data  ==>>>>  {data}")
+                validated_data = MyProductsService.validate_data(data, MyProductSchema())
+                token = validated_data.get('token')
+                uid = validated_data.get('uid')
+                member_data = Members.get_member_by_uid(uid)
+                member_id = member_data.id
+
+                product_id = validated_data.get('product_id')
+                product_data = Products.get_product_by_product_id(product_id)
+
+                if not product_data:
+                    return {
+                        "message": "Please provide product_id",
+                        "data": None,
+                        "error": "Bad request"
+                    }, 400
+
+                mumberSub =  MembersProducts.get_member_product_by_product__member_id(member_id, product_id)
+                if not mumberSub:
+                    logger.error(f"Ready to add data to tables")
+
+
+                response_data = {
+                    "subscription": "No ready",
+                    "member_id": 1,
+                    "uid": '',
+                }
+                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()
+
+
+
+



@@ -35,6 +80,8 @@ class MyProductsService(BaseService):
                validated_data = MyProductsService.validate_data(data, MyProductSchema())
                token = validated_data.get('token')
                uid = validated_data.get('uid')
+                member_data = Members.get_member_by_uid(uid)
+                member_id = member_data.id
                product_id = validated_data.get('product_id')

                '''