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 + 'flashsale/header', auth='public', methods=['GET', 'OPTIONS'])
    @controller.Controller.must_authorized()
    def _get_flash_sale_header(self, **kw):
        try:
            # base_url = request.env['ir.config_parameter'].get_param('web.base.url')
            active_flash_sale = request.env['product.pricelist'].get_is_show_program_flash_sale(is_show_program=kw.get('is_show_program'))
            data = []
            for pricelist in active_flash_sale:
                query = [
                    ('pricelist_id', '=', pricelist.id)
                ]
                formatted_end_date = pricelist.end_date.strftime('%Y-%m-%dT%H:%M:%S.%f')[:-3] + 'Z' if pricelist.end_date else None
                data.append({
                    'pricelist_id': pricelist.id,
                    'option': pricelist.flashsale_option,
                    'name': pricelist.name,
                    'is_show_program': pricelist.is_show_program,
                    'banner': request.env['ir.attachment'].api_image('product.pricelist', 'banner', pricelist.id),
                    'banner_mobile': request.env['ir.attachment'].api_image('product.pricelist', 'banner_mobile', pricelist.id),
                    'banner_top': request.env['ir.attachment'].api_image('product.pricelist', 'banner_top', pricelist.id),
                    'duration': pricelist._remaining_time_in_second(),
                    'end_date': formatted_end_date,
                    'product_total': request.env['product.pricelist.item'].search_count(query),
                })
            return self.response(data)
        except Exception as e:
            _logger.info(self.prefix + '/flashsale/header: ' + str(e))
            return self.response(code=500, description='Internal server error')
    
    @http.route(prefix + 'flashsale/line', auth='public', methods=['GET'])
    @controller.Controller.must_authorized()
    def _get_flash_sale_line(self, **kw):
        try:
            # base_url = request.env['ir.config_parameter'].get_param('web.base.url')
            pricelist_id = int(kw.get('pricelist_id'),0)
            limit = int(kw.get('limit'),0)
            offset = int(kw.get('offset'),0)

            if pricelist_id == 0 or limit == 0:
                return self.response(code=500, description='Internal Server error')
            
            pricelist_items = request.env['product.pricelist.item'].search([('pricelist_id', '=', pricelist_id)], limit=limit, offset=offset)
            data = {
                'total': request.env['product.pricelist.item'].search_count([('pricelist_id', '=', pricelist_id)]),
                'products': [request.env['product.pricelist.item'].api_single_response(x) for x in pricelist_items]
            }
            return self.response(data)

        except Exception as e:
            _logger.info(self.prefix + '/flashsale/line: ' + str(e))
            return self.response(code=500, description='Internal Server error')


    @http.route(prefix + 'flash_sale', auth='public', methods=['GET'])
    @controller.Controller.must_authorized()
    def get_flash_sale(self, **kw):
        try:
            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': {
                        'name': active_flash_sale.name,
                        'banner': base_url + 'api/image/product.pricelist/banner/' + str(active_flash_sale.id) if active_flash_sale.banner else '',
                        'banner_mobile': base_url + 'api/image/product.pricelist/banner_mobile/' + str(active_flash_sale.id) if active_flash_sale.banner_mobile else '',
                        'duration': active_flash_sale._remaining_time_in_second(),
                        'flashsale_option': active_flash_sale.flashsale_option,
                        '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 + '/flash_sale: ' + str(e))
            return self.response(code=500, description='Internal server error')