', '\n').replace('
', '\n') + body_text = html2text(message.body) if message.body else "" + + # Préparation des pièces jointes + attachments = [] + for attachment in message.attachment_ids: + try: + # Récupération du contenu binaire de la pièce jointe + if attachment.datas: + attachment_data = { + 'name': attachment.name, + 'type': attachment.mimetype or 'application/octet-stream', + 'content': attachment.datas.decode('utf-8') if attachment.datas else '', + } + attachments.append(attachment_data) + except Exception as e: + _logger.warning("Impossible de traiter la pièce jointe %s: %s", attachment.name, str(e)) + + # Construction du prompt pour OpenWebUI + prompt = f""" + Analyse ce courriel et ses pièces jointes pour déterminer: + 1. Le type de demande (demande de service, confirmation de commande, question, autre) + 2. L'urgence (faible, moyenne, élevée) + 3. Les actions recommandées + 4. Le département concerné (ventes, support, comptabilité, autre) + 5. Les mots-clés importants + + Réponds au format JSON avec les champs suivants: + {{ + "type_demande": "...", + "urgence": "...", + "actions_recommandees": ["...", "..."], + "departement": "...", + "mots_cles": ["...", "..."], + "resume": "...", + "modele_suggere": "..." (sale.order, project.project, helpdesk.ticket, etc.), + "confiance": ... (valeur entre 0 et 1) + }} + + Courriel: + De: {message.email_from} + À: {message.email_to or 'Non spécifié'} + Sujet: {message.subject or 'Sans objet'} + Date: {message.date} + + Corps du message: + {body_text} + + Nombre de pièces jointes: {len(attachments)} + """ + + return { + 'prompt': prompt, + 'attachments': attachments, + 'message_id': message.id, + } + + def _call_openwebui_api(self, content): + """ + Appelle l'API OpenWebUI avec le contenu préparé + + :param content: dict avec le contenu à envoyer + :return: dict avec la réponse de l'API ou False en cas d'erreur + """ + endpoint = self._get_openwebui_endpoint() + api_key = self._get_openwebui_api_key() + + if not endpoint: + _logger.error("Endpoint OpenWebUI non configuré") + return False + + headers = { + 'Content-Type': 'application/json', + } + + if api_key: + headers['Authorization'] = f'Bearer {api_key}' + + try: + # Dans une implémentation réelle, nous enverrions réellement la requête + # Pour cette démonstration, nous simulons une réponse + + # requests.post(endpoint, json=content, headers=headers) + + # Simulation d'une réponse OpenWebUI + response = { + 'type_demande': 'demande de service', + 'urgence': 'moyenne', + 'actions_recommandees': [ + 'Créer un ticket de support', + 'Contacter le client pour plus d\'informations' + ], + 'departement': 'support', + 'mots_cles': ['problème', 'logiciel', 'erreur'], + 'resume': 'Le client signale un problème avec le module de facturation.', + 'modele_suggere': 'helpdesk.ticket', + 'confiance': 0.85 + } + + return response + + except Exception as e: + _logger.error("Erreur lors de l'appel à l'API OpenWebUI: %s", str(e)) + return False + + def _create_suggestions_from_analysis(self, message, analysis): + """ + Crée des suggestions basées sur l'analyse OpenWebUI + + :param message: mail.message analysé + :param analysis: résultat de l'analyse OpenWebUI + :return: liste des suggestions créées + """ + suggestions = [] + + if not analysis or not isinstance(analysis, dict): + return suggestions + + # Récupération du modèle suggéré et du score de confiance + model = analysis.get('modele_suggere') + confidence = analysis.get('confiance', 0.5) + + if model and model in self.env: + # Recherche des enregistrements récents de ce type + records = self.env[model].sudo().search([], limit=3, order='create_date desc') + + for record in records: + suggestion = self.env['mail.message.ai.suggestion'].create({ + 'message_id': message.id, + 'suggested_model': model, + 'suggested_record_id': record.id, + 'confidence_score': confidence * 0.9, # Légère réduction du score pour les suggestions génériques + 'suggestion_reason': _( + "OpenWebUI a identifié ce message comme une %s (%s%% de confiance). " + "Résumé: %s" + ) % ( + analysis.get('type_demande', 'demande'), + int(confidence * 100), + analysis.get('resume', 'Non disponible') + ), + }) + suggestions.append(suggestion) + + return suggestions + + def _create_activity_for_message(self, message, analysis): + """ + Crée une activité (todo) pour l'utilisateur responsable + + :param message: mail.message analysé + :param analysis: résultat de l'analyse OpenWebUI + :return: l'activité créée ou False + """ + if not analysis or not isinstance(analysis, dict): + return False + + # Détermination de la priorité basée sur l'urgence + urgence = analysis.get('urgence', 'moyenne').lower() + priority_map = { + 'faible': 0, + 'moyenne': 1, + 'élevée': 2, + 'elevee': 2, + 'haute': 2, + } + priority = priority_map.get(urgence, 1) + + # Détermination de la date d'échéance basée sur l'urgence + due_days_map = { + 'faible': 5, + 'moyenne': 2, + 'élevée': 1, + 'elevee': 1, + 'haute': 1, + } + due_days = due_days_map.get(urgence, 2) + date_deadline = fields.Date.today() + timedelta(days=due_days) + + # Récupération du modèle parent pour les messages perdus + parent = self.env['lost.message.parent'].sudo().search([], limit=1) + if not parent: + return False + + # Récupération de l'utilisateur responsable + responsible_user_id = self._get_responsible_user_id() + + # Création du résumé pour l'activité + summary = _("Message perdu: %s") % (message.subject or 'Sans objet') + + # Création de la note avec les détails de l'analyse + note = _(""" +Analyse IA du message perdu
+Actions recommandées:
+Mots-clés: %(mots_cles)s
+ + """) % { + 'type': analysis.get('type_demande', 'Non identifié'), + 'urgence': analysis.get('urgence', 'Non identifié'), + 'departement': analysis.get('departement', 'Non identifié'), + 'resume': analysis.get('resume', 'Non disponible'), + 'actions': ''.join([f"+ Aucune suggestion IA pour le moment +
++ Les suggestions apparaîtront ici après l'analyse des messages non routés. +
+