Merge pull request 'fix: Se crean endpoints para mostrar la informacion de peticiones y respuestas de los webservices, en el area del auditor del sistema.' (#11) from Fix--Auditor-backend into main

Reviewed-on: #11

api/customs/views.py

@@ -59,6 +59,9 @@ try:
 except ImportError:
     RAR_SUPPORT = False
 
+# Importar tarea de procesamiento de pedimento (Celery)
+from api.customs.tasks.microservice import procesar_pedimento_completo_individual
+
 def get_available_extractors():
     """
     Devuelve lista de extractores disponibles en orden de preferencia
@@ -371,6 +374,25 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
                 ]
             }
 
+    @action(detail=True, methods=['post'], url_path='procesar-completo')
+    def procesar_completo(self, request, pk=None):
+        """
+        Acción para disparar el procesamiento completo de un pedimento existente.
+        Dispara la tarea `procesar_pedimento_completo_individual` de forma asíncrona
+        y devuelve el `task_id`.
+        """
+        pedimento = self.get_object()
+        try:
+           # Usar el nombre del servicio de Docker Compose en lugar de localhost
+            task = procesar_pedimento_completo_individual.delay(pedimento.id, pedimento.organizacion.id)
+            # Verificar si la respuesta fue exitosa
+            if task.id:
+                return Response({"status": "Recurso creado exitosamente en API", "task_id": task.id}, status=status.HTTP_202_ACCEPTED)
+            else:
+                return Response({"status": "Servicio API respondió con error", "task_id": 0}, status=status.HTTP_202_ACCEPTED)
+        except Exception as e:
+            return Response({"error": f"Error inesperado al llamar al servicio API: {str(e)}"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
     @action(detail=False, methods=['post'], url_path='bulk-delete')
     def bulk_delete(self, request):
         """