from odoo import fields, models, api, tools
import logging

_logger = logging.getLogger(__name__)

class SaleMonitoring(models.Model):
    _name = 'sale.monitoring'
    _auto = False
    _rec_name = 'sale_order_id'

    id = fields.Integer()
    sale_order_id = fields.Many2one("sale.order", string="Sale Order")
    partner_id = fields.Many2one("res.partner", string="Customer")
    user_id = fields.Many2one("res.users", string="Salesperson")
    qty_so = fields.Integer(string="Qty SO")
    qty_po = fields.Integer(string="Qty PO")
    qty_po_received = fields.Integer(string="Qty PO Received")
    qty_so_delivered = fields.Integer(string="Qty SO Delivered")
    qty_so_invoiced = fields.Integer(string="Qty SO Invoiced")
    date_order = fields.Datetime(string="Date Order")
    status = fields.Char(string="Status")
    po_number = fields.Char(string="PO Number")
    qty_reserved = fields.Integer(string="Qty Reserved")
    note_so_line = fields.Selection([
        ('eta', 'ETA'),
        ('info_sales', 'Info Sales'),
        ('info_vendor', 'Info Vendor'),
        ('penggabungan', 'Penggabungan'),
    ], string="Note", compute='compute_note')
    note = fields.Char(string="Note Detail", compute='compute_note_detail')
    purchase_representative_id = fields.Many2one('res.users', string="Purchase Representative", readonly=True, compute='compute_purchase_representative')

    def compute_purchase_representative(self):
        for sale in self:
            po = self.env['purchase.order'].search([
                ('sale_order_id', '=', sale.sale_order_id.id),
                ('user_id', '!=', False)
            ])

            user_id = False
            
            if po:
                user_id = po[0].user_id

            sale.purchase_representative_id = user_id

    def compute_note(self):
        for sale in self:
            lines = self.env['sale.order.line'].search([
                ('order_id', '=', sale.sale_order_id.id),
                ('note', '!=', False)
            ], limit=1)
           
            sale.note_so_line = lines.note

    def compute_note_detail(self):
        for sale in self:
            lines = self.env['sale.order.line'].search([
                ('order_id', '=', sale.sale_order_id.id),
                ('note_procurement', '!=', False)
            ])
            
            note_procurement = ', '.join(lines.mapped('note_procurement') or [''])

            sale.note = note_procurement

    def init(self):
        tools.drop_view_if_exists(self.env.cr, self._table)
        self.env.cr.execute("""
            CREATE OR REPLACE VIEW %s AS (
                SELECT 
                    smd.sale_order_id AS id,
                    smd.date_order, 
                    smd.sale_order_id,
                    smd.partner_id,
                    smd.user_id,
                    SUM(smd.qty_so) AS qty_so, 
                    SUM(smd.qty_po) AS qty_po, 
                    SUM(smd.qty_po_received) AS qty_po_received, 
                    SUM(smd.qty_so_delivered) AS qty_so_delivered, 
                    SUM(smd.qty_so_invoiced) AS qty_so_invoiced,
                    sum(smd.qty_reserved) as qty_reserved,
                    CASE
                        when sum(qty_so_delivered) = sum(qty_so) then 'Delivered'
                        when sum(qty_reserved) >= sum(qty_so) then 'Siap kirim'
                        when sum(qty_po) + sum(qty_reserved) - sum(qty_po_received) < sum(qty_so) then 'Belum/Kurang PO'
                        when sum(qty_po_received) = 0 then 'Belum terima'
                        when sum(qty_po_received) < sum(qty_po) then 'Terima sebagian'
                        when sum(qty_so_invoiced) = sum(qty_so) then 'Invoiced'
                    END AS status,
                    get_po_number(smd.sale_order_id) as po_number
                FROM sale_monitoring_detail smd
                GROUP BY smd.date_order, smd.sale_order_id, smd.partner_id, smd.user_id
            )
        """ % self._table)

    def action_refresh(self):
        _logger.info("Refresh %s View Starting..." % self._table)
        self.env.cr.execute("REFRESH MATERIALIZED VIEW sale_monitoring_detail")
        _logger.info("Refresh %s View Success" % self._table)