init commit

7 files changed, 162 insertions, 19 deletions

diff --git a/indoteknik_api/controllers/__init__.py b/indoteknik_api/controllers/__init__.py
index 4c317fdc..f56b2612 100644
--- a/indoteknik_api/controllers/__init__.py
+++ b/indoteknik_api/controllers/__init__.py
@@ -1,3 +1,3 @@
 from . import controller
 from . import product_controller
-from . import sale_order_controller
+from . import api_v1
\ No newline at end of file
diff --git a/indoteknik_api/controllers/api_v1/__init__.py b/indoteknik_api/controllers/api_v1/__init__.py
new file mode 100644
index 00000000..9bcb4f31
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/__init__.py
@@ -0,0 +1,3 @@
+from . import flash_sale
+from . import product
+from . import sale_order
\ No newline at end of file
diff --git a/indoteknik_api/controllers/api_v1/flash_sale.py b/indoteknik_api/controllers/api_v1/flash_sale.py
new file mode 100644
index 00000000..5addd7fe
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/flash_sale.py
@@ -0,0 +1,39 @@
+from datetime import datetime
+import logging
+from urllib import response
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+_logger = logging.getLogger(__name__)
+
+
+class FlashSale(controller.Controller):
+    prefix = '/api/v1/'
+    
+    @http.route(prefix + 'flash_sale', auth='public', methods=['GET'])
+    def get_flash_sale(self, **kw):
+        try:    
+            self.authenticate()
+            base_url = request.env['ir.config_parameter'].get_param('web.base.url')
+            active_flash_sale = request.env['product.pricelist'].get_active_flash_sale()
+            data = {}
+            if active_flash_sale:
+                product_variant_ids = [x.product_id.id for x in active_flash_sale.item_ids]
+                query = [('product_variant_ids', 'in', product_variant_ids)]
+                product_templates = self.search_filter('product.template', kw, query)
+                data = {
+                    'flash_sale': {
+                        'banner': base_url + 'api/image/product.pricelist/banner/' + str(active_flash_sale.id) if active_flash_sale.banner else '',
+                        'duration': round((active_flash_sale.end_date - datetime.now()).total_seconds()),
+                        'product_total': request.env['product.template'].search_count(query),
+                        'products': [request.env['product.template'].api_single_response(x) for x in product_templates]
+                    }
+                }
+                return self.response(data)
+            else:
+                return self.response(code=404, description='Data not found')
+        except Exception as e:
+            _logger.info(self.prefix_url + '/flash_sale: ' + str(e))
+            return self.response(code=500, description='Internal server error')
+    
\ No newline at end of file
diff --git a/indoteknik_api/controllers/api_v1/product.py b/indoteknik_api/controllers/api_v1/product.py
new file mode 100644
index 00000000..068a54b6
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/product.py
@@ -0,0 +1,82 @@
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+
+class Product(controller.Controller):
+    prefix = '/api/v1/'
+    
+    @http.route(prefix + 'product', auth='public', methods=['GET'])
+    def get_product(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        name = kw.get('name')
+        manufactures = kw.get('manufactures')
+        categories = kw.get('categories')
+        
+        require_betweens = ['name', 'manufactures', 'categories']
+        is_fulfill =  False
+        for required in require_betweens:
+            if kw.get(required):
+                is_fulfill = True
+        
+        # If not fulfill in require_between
+        if not is_fulfill:
+            return self.response(code=400, description='name or manufactures or categories is required')
+        
+        query = [('sale_ok', '=', True)]
+        
+        if name:
+            name = '%' + name.replace(' ', '%') + '%'
+            query += [
+                '|',
+                ('default_code', 'ilike', name),
+                ('name', 'ilike', name),
+            ]
+        
+        if manufactures:
+            query.append(('x_manufacture', 'in', [int(x) for x in manufactures.split(',')]))
+        
+        if categories:
+            query.append(('public_categ_ids', 'child_of', [int(x) for x in categories.split(',')]))
+        
+        product_variants = request.env['product.product'].search(query)
+        product_variant_ids = [x.id for x in product_variants]
+        
+        query = [('product_variant_ids', 'in', product_variant_ids)]
+        limit = int(kw.get('limit', 0))
+        offset = int(kw.get('offset', 0))
+        order = kw.get('order')
+        if order == 'price-desc': 
+            order = 'web_price_sorting desc'
+        elif order == 'price-asc': 
+            order = 'web_price_sorting asc'
+        elif order == 'latest': 
+            order = 'create_date desc'
+        else:
+            order = 'product_rating desc'
+        product_templates = request.env['product.template'].search(query, limit=limit, offset=offset, order=order)
+        data = {
+            'product_total': request.env['product.template'].search_count(query),
+            'products': [request.env['product.template'].api_single_response(x) for x in product_templates]
+        }
+        return self.response(data)
+        
+    @http.route(prefix + 'product/<id>', auth='public', methods=['GET'])
+    def get_product_by_id(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        id = kw.get('id')
+        if not id:
+            return self.response(code=400, description='id is required')
+        
+        data = []
+        id = [int(x) for x in id.split(',')]
+        product_templates = request.env['product.template'].search([('id', 'in', id)])
+        if product_templates:
+            data = [request.env['product.template'].api_single_response(x, with_detail=True) for x in product_templates]
+        
+        return self.response(data)
+        
\ No newline at end of file
diff --git a/indoteknik_api/controllers/sale_order_controller.py b/indoteknik_api/controllers/api_v1/sale_order.py
index 741d4bf8..99302a66 100644
--- a/indoteknik_api/controllers/sale_order_controller.py
+++ b/indoteknik_api/controllers/api_v1/sale_order.py
@@ -1,12 +1,12 @@
-from . import controller
+from .. import controller
 from odoo import http
 from odoo.http import request
 
 
-class SaleOrderController(controller.Controller):
+class SaleOrder(controller.Controller):
     @http.route('/api/sale_order/invoiced', auth='public', methods=['GET'])
     def get_sale_order_invoiced_by_partner_id(self, **kw):
-        self.authenticate(kw)
+        self.authenticate()
         partner_id = kw.get('partner_id')
         if not partner_id:
             return self.response(code=400, description='Field partner_id is required')
@@ -25,7 +25,7 @@ class SaleOrderController(controller.Controller):
             ('invoice_status', '=', 'invoiced'),
             ('invoice_status', '=', 'to_invoice')
         ]
-        sale_orders = self.search_with_api_params('sale.order', kw, default_domain)
+        sale_orders = self.search_filter('sale.order', kw, default_domain)
         for sale_order in sale_orders:
             pickings = []
             for picking in sale_order.picking_ids:
@@ -71,7 +71,7 @@ class SaleOrderController(controller.Controller):
         partner_child_ids = [v['id'] for v in partner_childs] + [int(partner_id)]
         default_domain.append(('partner_id', 'in', partner_child_ids))
 
-        sale_order = self.search_with_api_params('sale.order', kw, default_domain)
+        sale_order = self.search_filter('sale.order', kw, default_domain)
         orders = []
         for order in sale_order.order_line:
             orders.append({
diff --git a/indoteknik_api/controllers/controller.py b/indoteknik_api/controllers/controller.py
index fb5f1fce..c02f6b60 100644
--- a/indoteknik_api/controllers/controller.py
+++ b/indoteknik_api/controllers/controller.py
@@ -1,3 +1,4 @@
+from array import array
 import datetime
 import base64
 import json
@@ -8,11 +9,29 @@ from pytz import timezone
 
 
 class Controller(http.Controller):
-    def authenticate(self, kw):
-        db = kw.get('db')
-        username = kw.get('username')
-        password = kw.get('password')
-        request.session.authenticate(db, username, password)
+    def authenticate(self):
+        try:
+            wsgienv = request.httprequest.environ
+            db = wsgienv['HTTP_DB']
+            username = wsgienv['HTTP_USERNAME']
+            password = wsgienv['HTTP_PASSWORD']
+            request.session.authenticate(db, username, password)
+            return True
+        except:
+            return False
+
+    def validate_request(self, rules: dict, kw: dict):
+        validation = {
+            'status': True,
+            'reason': []
+        }
+        for key in rules:
+            values = rules[key]
+            for value in values:
+                if value == 'required' and not kw.get(key):
+                    validation['status'] = False
+                    validation['reason'].append(key + ' is ' + value)
+        return validation
 
     def time_to_str(self, object, format):
         time = ''
@@ -33,13 +52,13 @@ class Controller(http.Controller):
         response = json.dumps(response)
         return request.make_response(response, [('Content-Type', 'application/json')])
 
-    def search_with_api_params(self, model: str, kw, domain=[]):
+    def search_filter(self, model: str, kw: dict, query: array = []):
         """ To search data by default API Params if exist """
         limit = kw.get('limit', 0)
         offset = kw.get('offset', 0)
         order = kw.get('order', '')
 
-        return request.env[model].search(domain, limit=int(limit), offset=int(offset), order=order)
+        return request.env[model].search(query, limit=int(limit), offset=int(offset), order=order)
 
     @http.route('/api/image/<model>/<field>/<id>', auth='public', methods=['GET'])
     def get_image(self, model, field, id):
diff --git a/indoteknik_api/controllers/product_controller.py b/indoteknik_api/controllers/product_controller.py
index a57cf0a5..abb48f7d 100644
--- a/indoteknik_api/controllers/product_controller.py
+++ b/indoteknik_api/controllers/product_controller.py
@@ -13,7 +13,7 @@ class ProductController(controller.Controller):
     # TODO: separate function for get manufacture and promotion by product_id
     @http.route(prefix_url + '/search', auth='public', methods=['GET'])
     def search_product(self, **kw):
-        self.authenticate(kw)
+        self.authenticate()
         base_url = request.env['ir.config_parameter'].sudo().get_param('web.base.url')
 
         query = kw.get('query')
@@ -42,7 +42,7 @@ class ProductController(controller.Controller):
         product_variant_ids = [x.id for x in product_variants]
 
         domain = [('product_variant_ids', 'in', product_variant_ids)]
-        product_templates = self.search_with_api_params('product.template', kw, domain)
+        product_templates = self.search_filter('product.template', kw, domain)
         data = {
             'total_records': len(request.env['product.template'].search(domain)),
             'products': []
@@ -51,9 +51,9 @@ class ProductController(controller.Controller):
             discount_price = 0
             price = product_template.web_price
             if price > 0:
-                if product_template.taxes_id:
-                    if not product_template.taxes_id.price_include:
-                        price += (price * product_template.taxes_id.amount / 100)
+                if product_template.web_tax_id:
+                    if not product_template.web_tax_id.price_include:
+                        price += (price * product_template.web_tax_id.amount / 100)
                 else:
                     price += (price * 11 / 100)
 
@@ -95,7 +95,7 @@ class ProductController(controller.Controller):
                 }
                 product_pricelist_item = request.env['product.pricelist.item'].search([('pricelist_id', '=', active_flash_sale.id)])
                 product_variant_ids = [x.product_id.id for x in product_pricelist_item]
-                product_templates = self.search_with_api_params('product.template', kw, [('product_variant_ids', 'in', product_variant_ids)])
+                product_templates = self.search_filter('product.template', kw, [('product_variant_ids', 'in', product_variant_ids)])
                 for product in product_templates:
                     flash_sale['products'].append({
                         'id': product.id,