Merged in feature/rest-api (pull request #9)

Feature/rest api

6 files changed, 329 insertions, 0 deletions

diff --git a/indoteknik_api/controllers/api_v1/__init__.py b/indoteknik_api/controllers/api_v1/__init__.py
new file mode 100644
index 00000000..b569a012
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/__init__.py
@@ -0,0 +1,5 @@
+from . import category
+from . import flash_sale
+from . import manufacture
+from . import product
+from . import sale_order
\ No newline at end of file
diff --git a/indoteknik_api/controllers/api_v1/category.py b/indoteknik_api/controllers/api_v1/category.py
new file mode 100644
index 00000000..585e3eda
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/category.py
@@ -0,0 +1,37 @@
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+
+class Category(controller.Controller):
+    prefix = '/api/v1/'
+    
+    @http.route(prefix + 'category/page/<page>', auth='public', methods=['GET'])
+    def get_category(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        category_ids = []
+        page = kw.get('page')
+        if page == 'flash-sale':
+            active_flash_sale = request.env['product.pricelist'].get_active_flash_sale()
+            if active_flash_sale:
+                category_ids = [x.id for item in active_flash_sale.item_ids for x in item.product_id.public_categ_ids]
+        elif page == 'manufacture':
+            manufacture_id = kw.get('manufacture_id')
+            if not manufacture_id:
+                return self.response(code=400, description='manufacture_id is required')
+            product_variants = request.env['product.product'].search([('x_manufacture', '=', int(manufacture_id))])
+            category_ids = [x.id for variant in product_variants for x in variant.public_categ_ids]
+        else:
+            return self.response(code=400, description='page possible value is flash-sale, manufacture')
+        
+        categories = request.env['product.public.category'].search([('id', 'in', category_ids)])
+        data = []
+        for category in categories:
+            data.append({
+                'id': category.id,
+                'name': category.name
+            })
+        return self.response(data)
+    
\ 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..7f0166ee
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/flash_sale.py
@@ -0,0 +1,57 @@
+from datetime import datetime
+import logging
+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:    
+            if not self.authenticate():
+                return self.response(code=401, description='Unauthorized')
+            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:
+                flash_sale_product_variant_ids = [x.product_id.id for x in active_flash_sale.item_ids]
+                query = [('id', 'in', flash_sale_product_variant_ids)]
+                
+                product_name = kw.get('product_name')
+                if product_name:
+                    product_name = '%' + product_name.replace(' ', '%') + '%'
+                    query += ['|', ('name', 'ilike', product_name), ('default_code', 'ilike', product_name)]
+                
+                manufactures = kw.get('manufactures')
+                if manufactures:
+                    query += [('x_manufacture', 'in', [int(x) for x in manufactures.split(',')])]
+                
+                categories = kw.get('categories')
+                if categories:
+                    query += [('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)]
+                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/manufacture.py b/indoteknik_api/controllers/api_v1/manufacture.py
new file mode 100644
index 00000000..ba2e3be9
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/manufacture.py
@@ -0,0 +1,37 @@
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+
+class Manufacture(controller.Controller):
+    prefix = '/api/v1/'
+    
+    @http.route(prefix + 'manufacture/page/<page>', auth='public', methods=['GET'])
+    def get_manufacture(self, **kw):
+        if not self.authenticate():
+            return self.response(code=401, description='Unauthorized')
+        
+        manufacture_ids = []
+        page = kw.get('page')
+        if page == 'flash-sale':
+            active_flash_sale = request.env['product.pricelist'].get_active_flash_sale()
+            if active_flash_sale:
+                manufacture_ids = [x.product_id.x_manufacture.id for x in active_flash_sale.item_ids]
+        elif page == 'category':
+            category_id = kw.get('category_id')
+            if not category_id:
+                return self.response(code=400, description='category_id is required')
+            product_variants = request.env['product.product'].search([('public_categ_ids', '=', int(category_id))])
+            manufacture_ids = [x.x_manufacture.id for x in product_variants]
+        else:
+            return self.response(code=400, description='page possible value is flash-sale, category')
+        
+        manufactures = request.env['x_manufactures'].search([('id', 'in', manufacture_ids)])
+        data = []
+        for manufacture in manufactures:
+            data.append({
+                'id': manufacture.id,
+                'name': manufacture.x_name
+            })
+        return self.response(data)
+    
\ 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..493677fd
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/product.py
@@ -0,0 +1,83 @@
+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')
+        
+        orders = ['product_rating desc']
+        if order != 'price-asc':
+            orders.append('web_price_sorting desc')
+        if order == 'price-asc': 
+            orders.append('web_price_sorting asc')
+        elif order == 'latest': 
+            orders.append('create_date desc')
+        orders = ','.join(orders)
+        product_templates = request.env['product.template'].search(query, limit=limit, offset=offset, order=orders)
+        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/api_v1/sale_order.py b/indoteknik_api/controllers/api_v1/sale_order.py
new file mode 100644
index 00000000..99302a66
--- /dev/null
+++ b/indoteknik_api/controllers/api_v1/sale_order.py
@@ -0,0 +1,110 @@
+from .. import controller
+from odoo import http
+from odoo.http import request
+
+
+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()
+        partner_id = kw.get('partner_id')
+        if not partner_id:
+            return self.response(code=400, description='Field partner_id is required')
+
+        partner_id = int(partner_id)
+        # Get company member by partner_id
+        parent_partner_id = request.env['res.partner'].search([('id', '=', partner_id)], limit=1).parent_id.id
+        partner_childs = request.env['res.partner'].search([('parent_id', '=', int(parent_partner_id))])
+        partner_child_ids = [v['id'] for v in partner_childs] + [partner_id]
+
+        # Get sale order by company member and invoiced
+        data = []
+        default_domain = [
+            ('partner_id', 'in', partner_child_ids),
+            '|',
+            ('invoice_status', '=', 'invoiced'),
+            ('invoice_status', '=', 'to_invoice')
+        ]
+        sale_orders = self.search_filter('sale.order', kw, default_domain)
+        for sale_order in sale_orders:
+            pickings = []
+            for picking in sale_order.picking_ids:
+                if picking.state in ['confirmed', 'assigned', 'done']:
+                    pickings.append({
+                        'id': picking.id,
+                        'name': picking.name,
+                        'delivery_address': picking.partner_id.street,
+                        'delivery_tracking_no': picking.delivery_tracking_no,
+                        'delivery_status': picking.delivery_status
+                    })
+
+            data.append({
+                'id': sale_order.id,
+                'name': sale_order.name,
+                'amount_total': sale_order.amount_total,
+                'salesperson': sale_order.user_id.name,
+                'date_order': self.time_to_str(sale_order.date_order, '%d/%m/%Y'),
+                'pickings': pickings,
+                'access_token': sale_order.access_token
+            })
+        return self.response(data)
+
+    @http.route('/api/sale_order/invoiced/detail', auth='public', methods=['GET'])
+    def get_sale_order_invoiced_detail_by_partner(self, **kw):
+        self.authenticate(kw)
+
+        id = kw.get('id')
+        partner_id = kw.get('partner_id')
+        if not id:
+            return self.response(code=400, description='Field id is required')
+        if not partner_id:
+            return self.response(code=400, description='Field partner_id is required')
+
+        default_domain = [
+            ('id', '=', id),
+            '|',
+            ('invoice_status', '=', 'invoiced'),
+            ('invoice_status', '=', 'to_invoice')
+        ]
+        parent_partner_id = request.env['res.partner'].search([('id', '=', int(partner_id))], limit=1).parent_id.id
+        partner_childs = request.env['res.partner'].search([('parent_id', '=', int(parent_partner_id))])
+        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_filter('sale.order', kw, default_domain)
+        orders = []
+        for order in sale_order.order_line:
+            orders.append({
+                'name': order.name,
+                'product_qty': order.product_qty,
+                'price_unit': order.price_unit,
+                'price_tax': order.price_tax,
+                'price_total': order.price_total,
+                'price_subtotal': order.price_subtotal,
+                'tax': order.tax_id.name,
+                'discount': order.discount,
+            })
+
+        data = {
+            'id': sale_order.id,
+            'name': sale_order.name,
+            'carrier': sale_order.carrier_id.name,
+            'partner': {
+                'id': sale_order.partner_id.id,
+                'name': sale_order.partner_id.name,
+                'mobile': sale_order.partner_id.mobile,
+                'email': sale_order.partner_id.email
+            },
+            'delivery_address': sale_order.partner_shipping_id.street,
+            'delivery_method': sale_order.carrier_id.name,
+            'payment_term': sale_order.payment_term_id.name,
+            'salesperson': sale_order.user_id.name,
+            'date_order': self.time_to_str(sale_order.date_order, '%d/%m/%Y %H:%M:%S'),
+            'note': sale_order.note,
+            'amount_untaxed': sale_order.amount_untaxed,
+            'amount_tax': sale_order.amount_tax,
+            'amount_total': sale_order.amount_total,
+            'orders': orders
+        }
+
+        return self.response(data)