From dae117ce9bb219557c9a4fc995e93bc4a88ea03f Mon Sep 17 00:00:00 2001 From: IT Fixcomart Date: Tue, 11 Oct 2022 15:58:58 +0700 Subject: init commit --- indoteknik_api/controllers/__init__.py | 2 +- indoteknik_api/controllers/api_v1/__init__.py | 3 + indoteknik_api/controllers/api_v1/flash_sale.py | 39 ++++++++ indoteknik_api/controllers/api_v1/product.py | 82 +++++++++++++++ indoteknik_api/controllers/api_v1/sale_order.py | 110 +++++++++++++++++++++ indoteknik_api/controllers/controller.py | 33 +++++-- indoteknik_api/controllers/product_controller.py | 12 +-- .../controllers/sale_order_controller.py | 110 --------------------- indoteknik_api/models/product_pricelist.py | 21 ++-- indoteknik_api/models/product_template.py | 48 +++++++++ 10 files changed, 321 insertions(+), 139 deletions(-) create mode 100644 indoteknik_api/controllers/api_v1/__init__.py create mode 100644 indoteknik_api/controllers/api_v1/flash_sale.py create mode 100644 indoteknik_api/controllers/api_v1/product.py create mode 100644 indoteknik_api/controllers/api_v1/sale_order.py delete mode 100644 indoteknik_api/controllers/sale_order_controller.py (limited to 'indoteknik_api') 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/', 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) 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///', 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, diff --git a/indoteknik_api/controllers/sale_order_controller.py b/indoteknik_api/controllers/sale_order_controller.py deleted file mode 100644 index 741d4bf8..00000000 --- a/indoteknik_api/controllers/sale_order_controller.py +++ /dev/null @@ -1,110 +0,0 @@ -from . import controller -from odoo import http -from odoo.http import request - - -class SaleOrderController(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) - 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_with_api_params('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_with_api_params('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) diff --git a/indoteknik_api/models/product_pricelist.py b/indoteknik_api/models/product_pricelist.py index f40efd5d..a82fea1d 100644 --- a/indoteknik_api/models/product_pricelist.py +++ b/indoteknik_api/models/product_pricelist.py @@ -41,10 +41,10 @@ class ProductPricelist(models.Model): if price > 0: product = self.env['product.product'].browse(product_id) if product: - for tax in product.taxes_id: - if not tax.price_include: - price *= (100 + tax.amount) / 100 - + if product.web_tax_id and product.web_tax_id.price_include: + price *= (100 + product.web_tax_id.amount) / 100 + + price_discount = price for discount in discounts: price_discount *= (100 - discount) / 100 @@ -57,13 +57,12 @@ class ProductPricelist(models.Model): 'discount_percentage': discount_percentage } - def get_lowest_product_variant_price(self, product_id, pricelist_id): + def get_lowest_product_variant_price(self, product_template: dict, pricelist_id: int): """ - @param product_id: id of product.template + @param product_template: dict of product_template @param pricelist_id: id of pricelist which have default price @return price: object """ - product_template = self.env['product.template'].browse(product_id) product_variant_ids = [x.id for x in product_template.product_variant_ids] product = self.env['product.pricelist.item'].search([ ('pricelist_id', '=', pricelist_id), @@ -99,11 +98,3 @@ class ProductPricelist(models.Model): if product_id in pricelist_product_ids: return pricelist.id return False - - # TODO: need testing - def get_active_flash_sale_items(self): - pricelist = self.get_active_flash_sale() - pricelist_item = False - if pricelist: - pricelist_item = [x.product_id for x in pricelist.item_ids] - return pricelist_item diff --git a/indoteknik_api/models/product_template.py b/indoteknik_api/models/product_template.py index e69de29b..6b8973a2 100644 --- a/indoteknik_api/models/product_template.py +++ b/indoteknik_api/models/product_template.py @@ -0,0 +1,48 @@ +from odoo import models, fields + + +class ProductTemplate(models.Model): + _inherit = 'product.template' + + def api_single_response(self, product_template, with_detail=False): + base_url = self.env['ir.config_parameter'].get_param('web.base.url') + product_pricelist_default = self.env['ir.config_parameter'].get_param('product.pricelist.default') + product_pricelist_default = int(product_pricelist_default) + data = { + 'id': product_template.id, + 'image': base_url + 'api/image/product.template/image_128/' + str(product_template.id) if product_template.image_128 else '', + 'code': product_template.default_code, + 'name': product_template.name, + 'lowest_price': self.env['product.pricelist'].get_lowest_product_variant_price(product_template, product_pricelist_default), + 'variant_total': len(product_template.product_variant_ids), + 'stock_total': product_template.qty_stock_vendor, + 'manufacture': self.api_manufacture(product_template) + } + if with_detail: + detail_data = { + 'image': base_url + 'api/image/product.template/image_512/' + str(product_template.id) if product_template.image_512 else '', + 'variants': [], + 'description': product_template.website_description + } + for variant in product_template.product_variant_ids: + detail_data['variants'].append({ + 'id': variant.id, + 'code': variant.default_code, + 'name': variant.name, + 'price': self.env['product.pricelist'].compute_price(product_pricelist_default, variant.id), + 'stock': variant.qty_stock_vendor + }) + data.update(detail_data) + return data + + def api_manufacture(self, product_template): + base_url = self.env['ir.config_parameter'].get_param('web.base.url') + if product_template.x_manufacture: + manufacture = product_template.x_manufacture + return { + 'id': manufacture.id, + 'name': manufacture.x_name, + 'image_promotion_1': base_url + 'api/image/x_manufactures/image_promotion_1/' + str(manufacture.id) if manufacture.image_promotion_1 else '', + 'image_promotion_2': base_url + 'api/image/x_manufactures/image_promotion_2/' + str(manufacture.id) if manufacture.image_promotion_2 else '', + } + return {} \ No newline at end of file -- cgit v1.2.3