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

class FieldServiceTask(models.Model):
    _inherit = 'project.task'

    is_field_service = fields.Boolean(string="Field Service Engagement", default=True)
    digital_signature = fields.Binary(string="Client Touch Signature", attachment=True)
    signer_name = fields.Char(string="Signer Name")
    signer_designation = fields.Char(string="Signer Designation")
    signed_datetime = fields.Datetime(string="Signature Timestamp")
    transcribed_technician_notes = fields.Text(string="Voice-Transcribed Work Summary")
    
    # Geolocation Verification
    checkin_latitude = fields.Float(string="Check-In Latitude", digits=(10, 7))
    checkin_longitude = fields.Float(string="Check-In Longitude", digits=(10, 7))
    checkout_latitude = fields.Float(string="Check-Out Latitude", digits=(10, 7))
    checkout_longitude = fields.Float(string="Check-Out Longitude", digits=(10, 7))
    is_geofence_verified = fields.Boolean(string="Site Geofence Verified", default=False)

    def action_sync_field_service_completion(self, consumed_parts=None, labor_hours=0.0):
        """
        Idempotent endpoint processing mobile field service completions:
        1. Validates presence of client digital signature.
        2. Deducts consumed replacement parts from technician vehicle stock.
        3. Records timesheet labor hours against active project task.
        4. Triggers draft customer service invoice.
        """
        self.ensure_one()
        if not self.digital_signature:
            raise UserError(_("Cannot close field service task without client digital signature."))

        # 1. Deduct Spares from Technician Vehicle Location
        van_location = self.user_ids.property_warehouse_id.lot_stock_id
        customer_loc = self.env.ref('stock.stock_location_customers')

        if consumed_parts:
            for part in consumed_parts:
                product = self.env['product.product'].browse(part['product_id'])
                qty = part['quantity']
                
                # Execute internal inventory delivery
                stock_move = self.env['stock.move'].create({
                    'name': f"Field Consumption: {self.name}",
                    'product_id': product.id,
                    'product_uom_qty': qty,
                    'product_uom': product.uom_id.id,
                    'location_id': van_location.id,
                    'location_dest_id': customer_loc.id,
                })
                stock_move._action_confirm()
                stock_move._action_assign()
                stock_move._action_done()

        # 2. Book Labor Hours to Timesheets
        if labor_hours > 0:
            self.env['account.analytic.line'].create({
                'name': f"Field Service Labor: {self.name}",
                'task_id': self.id,
                'project_id': self.project_id.id,
                'unit_amount': labor_hours,
                'employee_id': self.env.user.employee_id.id,
            })

        # 3. Mark Task Completed and Log Signed Audit to Chatter
        self.write({
            'is_closed': True,
            'stage_id': self.env.ref('project.project_stage_2', raise_if_not_found=False).id or self.stage_id.id
        })

        self.message_post(
            body=f"Field Service Signed & Closed:
"
                 f"Signer: {self.signer_name} ({self.signer_designation})
"
                 f"Timestamp: {self.signed_datetime}
"
                 f"Geofence Verified: {self.is_geofence_verified}",
            message_type='notification'
        )
        return {'status': 'success', 'task_id': self.id}