whatsapp_web_groups/whatsapp_web/models/whatsapp_message.py

from odoo import models, fields, api
from odoo.tools import groupby
from odoo.exceptions import ValidationError
import logging
import markupsafe
import requests
import json
import time
import random
import re
import html
import base64

_logger = logging.getLogger(__name__)

class WhatsAppMessage(models.Model):
    _inherit = 'whatsapp.message'

    # Campos para soporte básico de grupos (solo por ID string, sin Many2one)
    # La funcionalidad completa de grupos con Many2one está en whatsapp_web_groups
    recipient_type = fields.Selection([
        ('phone', 'Phone Number'),
        ('group', 'WhatsApp Group')
    ], string='Recipient Type', default='phone', help="Type of recipient: phone number or WhatsApp group")
    
    @api.depends('recipient_type', 'mobile_number')
    def _compute_final_recipient(self):
        """Compute the final recipient based on type"""
        for record in self:
            # Si es grupo y mobile_number termina en @g.us, usarlo directamente
            if record.recipient_type == 'group' and record.mobile_number and record.mobile_number.endswith('@g.us'):
                record.final_recipient = record.mobile_number
            else:
                record.final_recipient = record.mobile_number
    
    final_recipient = fields.Char('Final Recipient', compute='_compute_final_recipient', 
                                  help="Final recipient (phone or group ID)")
    
    @api.depends('mobile_number', 'recipient_type')
    def _compute_mobile_number_formatted(self):
        """Override SOLO para casos específicos de grupos con WhatsApp Web"""
        for message in self:
            # SOLO intervenir si es grupo CON WhatsApp Web configurado
            if (hasattr(message, 'recipient_type') and message.recipient_type == 'group' and
                message.wa_account_id and message.wa_account_id.whatsapp_web_url and
                message.mobile_number and message.mobile_number.endswith('@g.us')):
                
                message.mobile_number_formatted = message.mobile_number
            else:
                # TODOS LOS DEMÁS CASOS: usar lógica original sin modificar
                super(WhatsAppMessage, message)._compute_mobile_number_formatted()
    
    @api.constrains('recipient_type', 'mobile_number')
    def _check_recipient_configuration(self):
        """Validar configuración de destinatario"""
        for record in self:
            if record.recipient_type == 'group':
                if not (record.mobile_number and record.mobile_number.endswith('@g.us')):
                    raise ValidationError("Para mensajes a grupos, debe proporcionar un ID de grupo válido (@g.us)")
            elif record.recipient_type == 'phone':
                if not record.mobile_number or record.mobile_number.endswith('@g.us'):
                    raise ValidationError("Para mensajes a teléfonos, debe proporcionar un número telefónico válido")
    
    def _whatsapp_phone_format(self, fpath=None, number=None, raise_on_format_error=False):
        """Override SOLO para casos específicos de grupos - NO interferir con funcionalidad nativa"""
        self.ensure_one()
        
        # SOLO intervenir en casos muy específicos de grupos
        # Si es un mensaje a grupo Y tiene WhatsApp Web configurado
        if (hasattr(self, 'recipient_type') and self.recipient_type == 'group' and 
            self.wa_account_id and self.wa_account_id.whatsapp_web_url):
            
            # Si el número es un ID de grupo (termina en @g.us), retornarlo sin validar
            if number and number.endswith('@g.us'):
                return number
            elif self.mobile_number and self.mobile_number.endswith('@g.us'):
                return self.mobile_number
            
        # TODOS LOS DEMÁS CASOS: usar validación original sin modificar
        return super()._whatsapp_phone_format(fpath, number, raise_on_format_error)
    
    def _get_final_destination(self):
        """Método mejorado para obtener destino final (grupo o teléfono)"""
        self.ensure_one()
        
        # Si el mobile_number es un ID de grupo (termina en @g.us)
        if self.mobile_number and self.mobile_number.endswith('@g.us'):
            return self.mobile_number
            
        return False
    
    def _send_message(self, with_commit=False):

        url = ''
        session_name = ''
        api_key = ''

        if self.wa_account_id and self.wa_account_id.whatsapp_web_url:
            url = self.wa_account_id.whatsapp_web_url
            session_name = self.wa_account_id.whatsapp_web_login or ''
            api_key = self.wa_account_id.whatsapp_web_api_key or ''
            _logger.info('WHATSAPP WEB SEND MESSAGE - URL: %s, Session: %s', url, session_name)

        group = ''
        
        if not url or not session_name or not api_key:
            # Si no hay configuración de WhatsApp Web, usar método original
            super()._send_message(with_commit)
            return
            
        for whatsapp_message in self:
            # Determinar destinatario final usando solo la nueva lógica
            final_destination = whatsapp_message._get_final_destination()
            
            if final_destination:
                group = final_destination
            
            attachment = False

            if whatsapp_message.wa_template_id:
                record = self.env[whatsapp_message.wa_template_id.model].browse(whatsapp_message.mail_message_id.res_id)
                #codigo con base a whatsapp.message y whatsapp.template para generacion de adjuntos
                RecordModel = self.env[whatsapp_message.mail_message_id.model].with_user(whatsapp_message.create_uid)
                from_record = RecordModel.browse(whatsapp_message.mail_message_id.res_id)

                # if retrying message then we need to unlink previous attachment
                # in case of header with report in order to generate it again
                if whatsapp_message.wa_template_id.report_id and whatsapp_message.wa_template_id.header_type == 'document' and whatsapp_message.mail_message_id.attachment_ids:
                    whatsapp_message.mail_message_id.attachment_ids.unlink()

                if not attachment and whatsapp_message.wa_template_id.report_id:
                    attachment = whatsapp_message.wa_template_id._generate_attachment_from_report(record)
                if not attachment and whatsapp_message.wa_template_id.header_attachment_ids:
                    attachment = whatsapp_message.wa_template_id.header_attachment_ids[0]
                
                if attachment and attachment not in whatsapp_message.mail_message_id.attachment_ids:
                    whatsapp_message.mail_message_id.attachment_ids = [(4, attachment.id)]
             # no template
            elif whatsapp_message.mail_message_id.attachment_ids:
                attachment = whatsapp_message.mail_message_id.attachment_ids[0]

            #codigo para limpiar body y numero
            body = whatsapp_message.body
            
            # Asegurar que body sea string y limpiar HTML
            if body:
                if isinstance(body, markupsafe.Markup):
                    text = html.unescape(str(body))
                else:
                    text = str(body)
                
                # Reemplazamos las etiquetas BR y P
                text = re.sub(r'<br\s*/?>|<BR\s*/?>', '\n', text)
                text = re.sub(r'<p>|<P>', '\n\n', text)
                text = re.sub(r'</p>|</P>', '', text)
                
                # Eliminamos el resto de etiquetas HTML
                text = re.sub(r'<[^>]+>', '', text)
                
                # Limpiamos múltiples saltos de línea
                text = re.sub(r'\n\s*\n\s*\n', '\n\n', text)
                
                # Limpiamos espacios en blanco al inicio y final
                body = text.strip()
                
                # Asegurar que no esté vacío
                if not body:
                    body = "Mensaje de WhatsApp"
            else:
                body = "Mensaje de WhatsApp"

            # Determinar número/destinatario final
            if group:
                # Si ya hay un grupo determinado, usarlo
                number = group
            else:
                # Formatear número según el tipo de destinatario
                if whatsapp_message.recipient_type == 'group':
                    if whatsapp_message.mobile_number and whatsapp_message.mobile_number.endswith('@g.us'):
                        number = whatsapp_message.mobile_number
                    else:
                        _logger.error("Mensaje configurado como grupo pero sin destinatario válido")
                        continue
                else:
                    # Lógica original para números de teléfono
                    number = whatsapp_message.mobile_number
                    if number:
                        number = number.replace(' ', '').replace('+','').replace('-','')

                        if number.startswith("52") and len(number) == 12:
                            number = "521" + number[2:]
                        
                        if len(number) == 10:
                            number = "521" + number
                        
                        number = number + '@c.us'

            # ENVIO DE MENSAJE - Nueva API Gateway
            parent_message_id = ''
            if whatsapp_message.mail_message_id and whatsapp_message.mail_message_id.parent_id:
                    parent_id = whatsapp_message.mail_message_id.parent_id.wa_message_ids
                    if parent_id:
                        parent_message_id = parent_id[0].msg_uid
            
            # Validar que tenemos un destinatario válido
            if not number:
                _logger.error("No se pudo determinar el destinatario para el mensaje")
                continue
                
            # Validar que tenemos un cuerpo de mensaje válido
            if not body or not isinstance(body, str):
                _logger.error("Cuerpo del mensaje inválido: %s", body)
                body = "Mensaje de WhatsApp"
            
            # Determinar si es grupo
            is_group = number.endswith('@g.us') if number else False
            
            # Construir URL base
            base_url = url.rstrip('/')
            endpoint = 'send-message'
            
            # Headers con autenticación
            headers = {
                "Content-Type": "application/json",
                "X-API-Key": api_key
            }
            
            # Preparar payload según tipo de mensaje
            if attachment:
                # Determinar endpoint según tipo de archivo
                mimetype = attachment.mimetype or 'application/octet-stream'
                if mimetype.startswith('image/'):
                    endpoint = 'send-image'
                elif mimetype.startswith('video/'):
                    endpoint = 'send-video'
                elif mimetype.startswith('audio/'):
                    endpoint = 'send-voice'
                else:
                    endpoint = 'send-file'
                
                # Convertir archivo a base64 con prefijo data URI
                file_base64 = base64.b64encode(attachment.raw).decode('utf-8')
                base64_with_prefix = f"data:{mimetype};base64,{file_base64}"
                
                payload = {
                    "phone": [number],  # Array para send-image/send-file
                    "base64": base64_with_prefix,
                    "filename": attachment.name or "file",
                    "caption": body,
                    "isGroup": is_group
                }
                
                if parent_message_id:
                    payload["quotedMessageId"] = parent_message_id
            else:
                # Mensaje de texto
                payload = {
                    "phone": number,  # String para send-message
                    "message": body,
                    "isGroup": is_group
                }
                
                if parent_message_id:
                    payload["quotedMessageId"] = parent_message_id
            
            # Construir URL completa
            full_url = f"{base_url}/api/v1/{session_name}/{endpoint}"
            
            # Log del payload para debugging
            _logger.info("Enviando mensaje a %s (%s) usando endpoint %s", number, "grupo" if is_group else "contacto", endpoint)
            
            # Realizar petición POST
            try:
                response = requests.post(full_url, json=payload, headers=headers, timeout=60)
                
                # Procesar respuesta
                if response.status_code == 200:
                    try:
                        response_json = response.json()
                        
                        # La nueva API puede devolver jobId (mensaje encolado) o id (enviado directamente)
                        if 'jobId' in response_json:
                            # Mensaje encolado - si la API devuelve jobId, significa que el mensaje fue aceptado
                            # y está en proceso de envío, por lo que lo marcamos como 'sent'
                            job_id = response_json.get('jobId')
                            _logger.info("Mensaje aceptado por la API. Job ID: %s - Marcando como enviado", job_id)
                            whatsapp_message.write({
                                'state': 'sent',  # Marcar como enviado ya que fue aceptado por la API
                                'msg_uid': job_id
                            })
                            self._cr.commit()
                        elif 'id' in response_json:
                            # Mensaje enviado directamente
                            msg_id = response_json.get('id')
                            if isinstance(msg_id, dict) and '_serialized' in msg_id:
                                msg_uid = msg_id['_serialized']
                            elif isinstance(msg_id, str):
                                msg_uid = msg_id
                            else:
                                msg_uid = str(msg_id)
                            
                            _logger.info("Mensaje enviado exitosamente. ID: %s", msg_uid)
                            whatsapp_message.write({
                                'state': 'sent',
                                'msg_uid': msg_uid
                            })
                            self._cr.commit()
                        else:
                            _logger.warning("Respuesta exitosa pero sin jobId ni id: %s", response_json)
                            whatsapp_message.write({
                                'state': 'outgoing'
                            })
                            self._cr.commit()
                    except ValueError:
                        _logger.error("La respuesta no es JSON válido: %s", response.text)
                        whatsapp_message.write({
                            'state': 'error'
                        })
                        self._cr.commit()
                else:
                    _logger.error("Error en la petición. Código: %s, Respuesta: %s", response.status_code, response.text)
                    whatsapp_message.write({
                        'state': 'error'
                    })
                    self._cr.commit()
            except requests.exceptions.RequestException as e:
                _logger.error("Error de conexión al enviar mensaje: %s", str(e))
                whatsapp_message.write({
                    'state': 'error'
                })
                self._cr.commit()

            time.sleep(random.randint(3, 7))