Fitur crud cart dan wishlist

Update struktur response product

3 files changed, 127 insertions, 1 deletions

diff --git a/indoteknik_api/controllers/api_v1/__init__.py b/indoteknik_api/controllers/api_v1/__init__.py
index c43a8bd0..d7efb524 100644
--- a/indoteknik_api/controllers/api_v1/__init__.py
+++ b/indoteknik_api/controllers/api_v1/__init__.py
@@ -1,8 +1,10 @@
 from . import banner
 from . import blog
+from . import cart
 from . import category
 from . import flash_sale
 from . import manufacture
 from . import product
 from . import promotion
-from . import sale_order
\ No newline at end of file
+from . import sale_order
+from . import wishlist
\ No newline at end of file
diff --git a/indoteknik_api/controllers/api_v1/cart.py b/indoteknik_api/controllers/api_v1/cart.py
new file mode 100644
index 00000000..29020d8b
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/cart.py
@@ -0,0 +1,71 @@
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+
+class Cart(controller.Controller):
+    prefix = '/api/v1/'
+    
+    @http.route(prefix + 'cart/<user_id>', auth='public', methods=['GET'])
+    def get_cart_by_user_id(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        user_id = int(kw.get('user_id'))
+        limit = int(kw.get('limit', 0))
+        offset = int(kw.get('offset', 0))
+        query = [
+            ('user_id', '=', user_id)
+        ]
+        carts = request.env['website.user.cart'].search(query, limit=limit, offset=offset, order='create_date desc')
+        data = {
+            'product_total': request.env['website.user.cart'].search_count(query),
+            'products': []
+        }
+        for cart in carts:
+            product = request.env['product.product'].api_single_response(cart.product_id)
+            product['template_id'] = cart.product_id.product_tmpl_id.id
+            product['quantity'] = cart.qty
+            data['products'].append(product)
+        return self.response(data)
+    
+    @http.route(prefix + 'cart/<user_id>/create-or-update', auth='public', methods=['POST'], csrf=False)
+    def create_or_update_cart(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        user_id = int(kw.get('user_id'))
+        product_id = int(kw.get('product_id', 0))
+        qty = int(kw.get('qty', 0))
+        
+        if not product_id or not qty:
+            return self.response(code=400, description='product_id and qty is required')
+        query = [('user_id', '=', user_id), ('product_id', '=', product_id)]
+        cart = request.env['website.user.cart'].search(query, limit=1)
+        result = {}
+        if cart:
+            cart.write({'qty': qty})
+            result['id'] = cart.id
+        else:
+            create = request.env['website.user.cart'].create({
+                'user_id': user_id,
+                'product_id': product_id,
+                'qty': qty
+            })
+            result['id'] = create.id
+        
+        return self.response(result)
+    
+    @http.route(prefix + 'cart/<user_id>', auth='public', methods=['DELETE'], csrf=False)
+    def delete_cart_by_user_id(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        user_id = int(kw.get('user_id'))
+        query = [('user_id', '=', user_id)]
+        product_ids = kw.get('product_ids')
+        if product_ids:
+            query += [('product_id', 'in', [int(x) for x in product_ids.split(',')])]
+        cart = request.env['website.user.cart'].search(query).unlink()
+        return self.response(cart)
+    
\ No newline at end of file
diff --git a/indoteknik_api/controllers/api_v1/wishlist.py b/indoteknik_api/controllers/api_v1/wishlist.py
new file mode 100644
index 00000000..c84d58b1
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/wishlist.py
@@ -0,0 +1,53 @@
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+
+class Wishlist(controller.Controller):
+    prefix = '/api/v1/'
+    
+    @http.route(prefix + 'wishlist/<user_id>', auth='public', methods=['GET'])
+    def get_wishlist_by_user_id(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        user_id = int(kw.get('user_id', 0))
+        product_id = kw.get('product_id', 0)
+        limit = int(kw.get('limit', 0))
+        offset = int(kw.get('offset', 0))
+        query = [('user_id', '=', user_id)]
+        if product_id:
+            query += [('product_id', '=', int(product_id))]
+        wishlists = request.env['website.user.wishlist'].search(query, limit=limit, offset=offset, order='create_date desc')
+        data = {
+            'product_total': request.env['website.user.wishlist'].search_count(query),
+            'products': [request.env['product.template'].api_single_response(wishlist.product_id) for wishlist in wishlists]
+        }
+        return self.response(data)
+    
+    @http.route(prefix + 'wishlist/<user_id>/toggle', auth='public', methods=['POST'], csrf=False)
+    def toggle_wishlist(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        user_id = int(kw.get('user_id', 0))
+        product_id = kw.get('product_id', 0)
+        if not product_id:
+            return self.response(code=400, description='product_id is required')
+        
+        query = [
+            ('user_id', '=', user_id),
+            ('product_id', '=', int(product_id))
+        ]
+        wishlist = request.env['website.user.wishlist'].search(query, limit=1)
+        result = {}
+        if wishlist:
+            wishlist.unlink()
+            result['id'] = wishlist.id
+        else:
+            create = request.env['website.user.wishlist'].create({
+                'user_id': user_id,
+                'product_id': product_id
+            })
+            result['id'] = create.id
+        return self.response(result)