# -*- coding: utf-8 -*-
from odoo import models, fields, api, _
from odoo.exceptions import UserError

class MaintenanceEquipmentAsset(models.Model):
    _inherit = 'maintenance.equipment'

    asset_qr_tag = fields.Char(string="Laser QR Identifier", required=True, index=True, copy=False)
    current_bay_location = fields.Char(string="Active Shop Floor Bay", default="Central Toolroom", tracking=True)
    current_custodian_id = fields.Many2one('res.users', string="Current Responsible Custodian", tracking=True)
    
    # Statutory Metrology & Calibration
    last_calibration_date = fields.Date(string="Last Calibration Date", tracking=True)
    calibration_validity_months = fields.Integer(string="Calibration Interval (Months)", default=12)
    next_calibration_due = fields.Date(
        string="Next Calibration Due Date", 
        compute="_compute_next_calibration", 
        store=True, 
        tracking=True
    )
    calibration_status = fields.Selection([
        ('valid', 'Certified & In Service'),
        ('due_soon', 'Calibration Due in <= 15 Days'),
        ('expired', 'EXPIRED - Locked Out of Service'),
        ('verification', 'Under External Lab Verification')
    ], compute="_compute_calibration_status", store=True, tracking=True)
    
    # Active Hard Quality Lockout
    is_quality_locked = fields.Boolean(
        string="Quality Lockout Active", 
        compute="_compute_quality_lockout", 
        store=True
    )
    
    # Heavy Tooling / Die & Mold Lifecycle
    is_tooling_mold = fields.Boolean(string="Is Die or Mold", default=False)
    total_shots = fields.Integer(string="Cumulative Operating Shots / Strokes", default=0)
    service_shot_threshold = fields.Integer(string="Service Threshold (Shots)", default=500000)
    active_cavities = fields.Integer(string="Active Working Cavities", default=8)
    blocked_cavities = fields.Integer(string="Blocked / Damaged Cavities", default=0)

    # Relational Logs & Audit Dossier
    movement_log_ids = fields.One2many('asset.movement.log', 'equipment_id', string="Movement Ledger")
    certificate_ids = fields.One2many('asset.calibration.certificate', 'equipment_id', string="Linked Certificates")

    @api.depends('last_calibration_date', 'calibration_validity_months')
    def _compute_next_calibration(self):
        for eq in self:
            if eq.last_calibration_date and eq.calibration_validity_months:
                eq.next_calibration_due = fields.Date.add(eq.last_calibration_date, months=eq.calibration_validity_months)
            else:
                eq.next_calibration_due = False

    @api.depends('next_calibration_due')
    def _compute_calibration_status(self):
        today = fields.Date.today()
        for eq in self:
            if not eq.next_calibration_due:
                eq.calibration_status = 'expired'
                continue
            days_left = (eq.next_calibration_due - today).days
            if days_left < 0:
                eq.calibration_status = 'expired'
            elif days_left ≤ 15:
                eq.calibration_status = 'due_soon'
            else:
                eq.calibration_status = 'valid'

    @api.depends('calibration_status')
    def _compute_quality_lockout(self):
        for eq in self:
            eq.is_quality_locked = (eq.calibration_status == 'expired')

    def action_register_movement(self, target_bay, custodian_id, notes=False):
        """Executed via Mobile Scanner JSON-RPC Endpoint"""
        self.ensure_one()
        self.env['asset.movement.log'].create({
            'equipment_id': self.id,
            'source_bay': self.current_bay_location,
            'target_bay': target_bay,
            'custodian_id': custodian_id,
            'user_id': self.env.uid,
            'notes': notes or _('Scanned via Handheld Scanner')
        })
        self.write({
            'current_bay_location': target_bay,
            'current_custodian_id': custodian_id
        })
        return {'status': 'success', 'new_location': target_bay}