fix: Se crean endpoints para mostrar la informacion de peticiones y respuestas de los webservices, en el area del auditor del sistema.

Reviewed-on: #3

.env.example

@@ -17,4 +17,7 @@ EMAIL_HOST_PASSWORD=N036p7y!
 EMAIL_PORT=587
 EMAIL_HOST=secure.emailsrvr.com
 
-SERVICE_API_URL=http://localhost:8001/api/v1
+SERVICE_API_URL=http://host.docker.internal:8001/api/v1
+SERVICE_API_URL_V2=http://host.docker.internal:8001/api/v2
+CELERY_BROKER_URL=redis://redis_backend_dev:6379/0
+CELERY_RESULT_BACKEND=redis://redis_backend_dev:6379/0

.gitignore

@@ -178,4 +178,4 @@ cython_debug/
 #.idea/
 
 # End of https://www.toptal.com/developers/gitignore/api/django
-
+*.bak

Dockerfile

@@ -3,12 +3,17 @@ FROM python:3.11-slim
 
 WORKDIR /app
 
+# Instalar dependencias del sistema necesarias
+RUN apt-get update && apt-get install -y --no-install-recommends wget && \
+    wget https://www.rarlab.com/rar/rarlinux-x64-621.tar.gz && \
+    tar -xzvf rarlinux*.tar.gz && \
+    cp rar/unrar /usr/bin/unrar && \
+    rm -rf rarlinux*.tar.gz rar
+
 COPY requirements.txt ./
 RUN pip install --no-cache-dir -r requirements.txt
-
 RUN pip install flower
 
-
 COPY . .
 
 

Dockerfile.prod

@@ -3,8 +3,16 @@ FROM python:3.11-slim
 WORKDIR /app
 
 # Instalar dependencias del sistema
-RUN apt-get update && apt-get install -y \
+# RUN apt-get update && apt-get install -y \
+#     supervisor \
+#     && rm -rf /var/lib/apt/lists/*
+RUN apt-get update && apt-get install -y --no-install-recommends \
     supervisor \
+    wget \
+    && wget https://www.rarlab.com/rar/rarlinux-x64-621.tar.gz \
+    && tar -xzvf rarlinux*.tar.gz \
+    && cp rar/unrar /usr/bin/unrar \
+    && rm -rf rarlinux*.tar.gz rar \
     && rm -rf /var/lib/apt/lists/*
 
 # Copiar e instalar dependencias de Python

api/customs/management/commands/auditor.py

@@ -1,6 +1,5 @@
 from django.core.management.base import BaseCommand
 from api.customs.tasks.auditoria import (
-    auditar_procesamiento_remesas,
     auditar_coves,
     auditar_acuse_cove,
     auditar_edocuments,
@@ -15,7 +14,6 @@ class Command(BaseCommand):
 
     # Definir las tareas disponibles
     TAREAS_DISPONIBLES = {
-        'remesas': (auditar_procesamiento_remesas, "Auditoría de remesas"),
         'partidas': (crear_partidas, "Creación de partidas"),
         'coves': (auditar_coves, "Auditoría de COVEs"),
         'acuse-cove': (auditar_acuse_cove, "Auditoría de acuses de COVEs"),

api/customs/management/commands/microservicios.py

@@ -0,0 +1,44 @@
+from django.core.management.base import BaseCommand
+from api.organization.models import Organizacion
+from api.customs.tasks import microservice_v2
+
+class Command(BaseCommand):
+    help = 'Ejecuta tareas de microservicio por organización y procesamiento.'
+
+    def add_arguments(self, parser):
+        parser.add_argument(
+            '--organizacion_id',
+            type=str,
+            help='ID de la organización a procesar (opcional, si no se envía se procesan todas)'
+        )
+        parser.add_argument(
+            '--procesamiento',
+            type=str,
+            help='Tipo de procesamiento a ejecutar (opcional, si no se envía se ejecutan todos)'
+        )
+        parser.add_argument(
+            '--todos',
+            type=bool,
+            help='Ejecutar todos los procesos (opcional)'
+        )
+
+    def handle(self, *args, **options):
+        
+        todos = options.get('todos', False)
+        organizacion_id = options.get('organizacion_id')
+        procesamiento = options.get('procesamiento')
+        if todos:
+            organizaciones = Organizacion.objects.all()
+            for org in organizaciones:
+                microservice_v2.ejecutar_todos_por_organizacion(org.id)
+            self.stdout.write(self.style.SUCCESS('Se ejecutaron todos los procesos para todas las organizaciones.'))
+            return
+        
+        if organizacion_id:
+            if procesamiento:
+                microservice_v2.ejecutar_procesamiento_por_organizacion(organizacion_id, procesamiento)
+                self.stdout.write(self.style.SUCCESS(f'Se ejecutó el procesamiento {procesamiento} para la organización {organizacion_id}.'))
+            else:
+                microservice_v2.ejecutar_todos_por_organizacion(organizacion_id)
+                self.stdout.write(self.style.SUCCESS(f'Se ejecutaron todos los procesos para la organización {organizacion_id}.'))
+                

api/customs/serializers.py

@@ -9,6 +9,7 @@ from api.customs.models import (
     Partida
 )
 from django.db import models
+from django.db.models import Q
 from api.record.models import Document  # Asegúrate de importar el modelo Documento
 from api.record.serializers import DocumentSerializer  
 from api.vucem.serializers import VucemSerializer
@@ -43,6 +44,59 @@ class PedimentoSerializer(serializers.ModelSerializer):
         return rep
 
 class PartidaSerializer(serializers.ModelSerializer):
+    documentos = serializers.SerializerMethodField()
+
+    def get_documentos(self, obj):
+        """
+        Busca documentos en la tabla `document` que coincidan EXACTAMENTE con:
+        'documents/vu_PT_{pedimentoApp}_{numero}' al inicio del nombre del archivo.
+        """
+
+        if not obj or not getattr(obj, 'pedimento', None):
+            return []
+
+        if not obj or not getattr(obj, 'numero_partida', None):
+            return []
+
+        try:
+            pedimentoApp = str(obj.pedimento.pedimento_app).strip()
+            numero = str(obj.numero_partida).strip()
+
+            # Construir el patrón exacto de búsqueda
+            patron_exacto = f'documents/vu_PT_{pedimentoApp}_{numero}.xml'
+
+            # Buscar documentos que empiecen EXACTAMENTE con ese patrón
+            qs = Document.objects.filter(
+                archivo=patron_exacto
+            )
+
+            # Opción 2: Si puede tener diferentes extensiones
+            # patron_base = f'documents/vu_PT_{pedimentoApp}_{numero}'
+            # qs = Document.objects.filter(
+            #     archivo__startswith=patron_base
+            # ).filter(
+            #     archivo__in=[
+            #         f'{patron_base}.xml',
+            #         f'{patron_base}.pdf',
+            #         f'{patron_base}.zip'
+            #     ]
+            # )
+
+            # Filtro adicional por pedimento si el modelo Document tiene este campo
+            if hasattr(Document, 'pedimento'):
+                qs = qs.filter(pedimento=obj.pedimento)
+
+            # Filtro por organización
+            if hasattr(obj, 'organizacion') and obj.organizacion:
+                qs = qs.filter(organizacion=obj.organizacion)
+            
+            serializer = DocumentSerializer(qs, many=True, context=self.context)
+            return serializer.data
+            
+            #return []
+        except Exception:
+            # En caso de cualquier error (por ejemplo, importaciones circulares), devolver lista vacía
+            return []
     class Meta:
         model = Partida
         fields = '__all__'
@@ -129,6 +183,47 @@ class ProcesamientoPedimentoSerializer(serializers.ModelSerializer):
         return representation
     
 class EDocumentSerializer(serializers.ModelSerializer):
+    documentos = serializers.SerializerMethodField()
+
+    def get_documentos(self, obj):
+        """
+        Busca documentos en la tabla `document` que coincidan con el
+        `numero_edocument` dentro del nombre del archivo (`archivo`). Se
+        filtra por organización para evitar devolver documentos de otras orgs.
+        Devuelve la serialización completa de los documentos encontrados:
+        1. Empiecen con 'vu_EDOCUMENT' en el nombre del archivo
+        2. Terminen con el numero_edocument + .xml
+        3. Pertenezcan a la misma organización
+        """
+        if not obj or not getattr(obj, 'numero_edocument', None):
+            return []
+
+        if not obj or not getattr(obj, 'pedimento', None):
+            return []
+
+        # if not obj or not getattr(obj, 'pedimento_id', None):
+        #     return []
+
+        try:
+            numero = str(obj.numero_edocument).strip()
+            # id_pedimento = str(obj.pedimento_id).strip()
+
+            qs = Document.objects.filter(
+                pedimento=obj.pedimento,
+                archivo__icontains=numero,
+            )
+
+            # Filtro por organización si aplica
+            if hasattr(obj, 'organizacion') and obj.organizacion:
+                qs = qs.filter(organizacion=obj.organizacion)
+            
+            serializer = DocumentSerializer(qs, many=True, context=self.context)
+            return serializer.data
+        
+        except Exception:
+            # En caso de cualquier error (por ejemplo, importaciones circulares), devolver lista vacía
+            return []
+
     class Meta:
         model = EDocument
         fields = '__all__'
@@ -142,11 +237,48 @@ class EDocumentSerializer(serializers.ModelSerializer):
             self.fields['organizacion'].read_only = True
 
 class CoveSerializer(serializers.ModelSerializer):
+    documentos = serializers.SerializerMethodField()
+
     class Meta:
         model = Cove
         fields = '__all__'
         read_only_fields = ('created_at', 'updated_at')
 
+    def get_documentos(self, obj):
+        """
+        Busca documentos en la tabla `document` que coincidan con el
+        `numero_cove` dentro del nombre del archivo (`archivo`). Se
+        filtra por organización para evitar devolver documentos de otras orgs.
+        Devuelve la serialización completa de los documentos encontrados:
+        1. Empiecen con 'vu_COVE' en el nombre del archivo
+        2. Terminen con el numero_cove + .xml
+        3. Pertenezcan a la misma organización
+        """
+        if not obj or not getattr(obj, 'numero_cove', None):
+            return []
+
+        if not obj or not getattr(obj, 'pedimento', None):
+            return []
+
+        try:
+            numero = str(obj.numero_cove).strip()
+
+            qs = Document.objects.filter(
+                pedimento=obj.pedimento,
+                archivo__icontains=numero,
+            )
+
+            # Filtro por organización si aplica
+            if hasattr(obj, 'organizacion') and obj.organizacion:
+                qs = qs.filter(organizacion=obj.organizacion)
+            
+            serializer = DocumentSerializer(qs, many=True, context=self.context)
+            return serializer.data
+        
+        except Exception:
+            # En caso de cualquier error (por ejemplo, importaciones circulares), devolver lista vacía
+            return []
+
 class ImportadorSerializer(serializers.ModelSerializer):
     class Meta:
         model = Importador

api/customs/tasks/auditoria.py

@@ -1,3 +1,6 @@
+import os
+from datetime import datetime
+from django.db import models
 from celery import shared_task, group
 from api.customs.models import ProcesamientoPedimento, Pedimento, Cove, EDocument
 from core.utils import xml_controller
@@ -198,7 +201,7 @@ def auditar_coves(organizacion_id):
             pedimento, 
             servicio=8, 
             related_name='coves', 
-            variable='acuse_descargado', 
+            variable='cove_descargado', 
             mensaje='COVE'
         )
 
@@ -247,7 +250,7 @@ def auditar_cove_por_pedimento(pedimento_id):
             pedimento,
             servicio=8,
             related_name='coves',
-            variable='acuse_descargado',
+            variable='cove_descargado',
             mensaje='COVE'
         )
         return {'success': True, 'pedimento_id': str(pedimento_id)}
@@ -302,3 +305,154 @@ def auditar_acuse_por_pedimento(pedimento_id):
     except Exception as e:
         return {'success': False, 'error': str(e), 'pedimento_id': str(pedimento_id)}
 
+@shared_task
+def auditar_pedimento_por_id(pedimento_id):
+    """
+    Tarea para auditar un pedimento específico verificando todos sus documentos y datos.
+    """
+    try:
+        pedimento = Pedimento.objects.get(id=pedimento_id)
+        resultado = {
+            'pedimento_id': str(pedimento_id),
+            'pedimento': pedimento.pedimento,
+            'pedimento_app': pedimento.pedimento_app,
+            'organizacion': str(pedimento.organizacion.id),
+            'fecha_auditoria': datetime.now().isoformat(),
+            'estado_general': 'EN_PROGRESO',
+            'detalles': {}
+        }
+        
+        # 1. Verificar documentos XML
+        from api.record.models import Document
+        documentos_xml = Document.objects.filter(
+            pedimento=pedimento,
+            archivo__endswith='.xml'
+        )
+        
+        resultado['detalles']['documentos_xml'] = {
+            'total': documentos_xml.count(),
+            'archivos': []
+        }
+        
+        for doc in documentos_xml:
+            try:
+                xml_info = {
+                    'id': str(doc.id),
+                    'nombre': os.path.basename(doc.archivo.name),
+                    'tamanio': doc.size,
+                    'extension': doc.extension,
+                    'tipo': doc.document_type.descripcion if doc.document_type else 'Desconocido'
+                }
+                
+                # Verificar si el archivo existe físicamente
+                if os.path.exists(doc.archivo.path):
+                    xml_info['existe_fisicamente'] = True
+                    # Intentar leer el XML
+                    try:
+                        with open(doc.archivo.path, 'r', encoding='utf-8') as f:
+                            content = f.read()
+                        xml_info['es_xml_valido'] = '<?xml' in content[:100]
+                        xml_info['tamanio_bytes'] = len(content)
+                    except Exception as e:
+                        xml_info['error_lectura'] = str(e)
+                else:
+                    xml_info['existe_fisicamente'] = False
+                    
+            except Exception as e:
+                xml_info['error'] = str(e)
+                
+            resultado['detalles']['documentos_xml']['archivos'].append(xml_info)
+        
+        # 2. Verificar si hay documentos asociados
+        resultado['detalles']['documentos_totales'] = {
+            'total': pedimento.documents.count(),
+            'por_tipo': {}
+        }
+        
+        for doc_type in pedimento.documents.values('document_type__descripcion').annotate(total=models.Count('id')):
+            tipo = doc_type['document_type__descripcion'] or 'Sin tipo'
+            resultado['detalles']['documentos_totales']['por_tipo'][tipo] = doc_type['total']
+        
+        # 3. Verificar COVEs
+        resultado['detalles']['coves'] = {
+            'total': pedimento.coves.count(),
+            'descargados': pedimento.coves.filter(cove_descargado=True).count(),
+            'con_acuse': pedimento.coves.filter(acuse_cove_descargado=True).count()
+        }
+        
+        # 4. Verificar EDocuments
+        resultado['detalles']['edocuments'] = {
+            'total': pedimento.documentos.count(),
+            'descargados': pedimento.documentos.filter(edocument_descargado=True).count(),
+            'con_acuse': pedimento.documentos.filter(acuse_descargado=True).count()
+        }
+        
+        # 5. Verificar procesamientos
+        resultado['detalles']['procesamientos'] = {
+            'total': pedimento.procesamientos.count(),
+            'por_estado': {}
+        }
+        
+        for proc in pedimento.procesamientos.values('estado__estado').annotate(total=models.Count('id')):
+            estado = proc['estado__estado'] or 'Sin estado'
+            resultado['detalles']['procesamientos']['por_estado'][estado] = proc['total']
+        
+        # 6. Verificar campos importantes del pedimento
+        campos_revisados = {
+            'numero_operacion': bool(pedimento.numero_operacion),
+            'numero_partidas': bool(pedimento.numero_partidas),
+            'importe_total': bool(pedimento.importe_total),
+            'contribuyente': bool(pedimento.contribuyente),
+            'tiene_remesas': pedimento.remesas,
+            'partidas_creadas': pedimento.partidas.count() > 0,
+            'fecha_pago': bool(pedimento.fecha_pago)
+        }
+        
+        resultado['detalles']['campos_pedimento'] = campos_revisados
+        resultado['detalles']['campos_completos'] = sum(campos_revisados.values())
+        resultado['detalles']['campos_totales'] = len(campos_revisados)
+        
+        # 7. Determinar estado general
+        campos_completos = resultado['detalles']['campos_completos']
+        total_campos = resultado['detalles']['campos_totales']
+        
+        if documentos_xml.count() == 0:
+            resultado['estado_general'] = 'SIN_XML'
+            resultado['mensaje'] = 'No se encontraron documentos XML'
+        elif campos_completos == total_campos:
+            resultado['estado_general'] = 'COMPLETO'
+            resultado['mensaje'] = 'Pedimento completamente procesado'
+        elif campos_completos >= total_campos * 0.7:
+            resultado['estado_general'] = 'PARCIAL'
+            resultado['mensaje'] = 'Pedimento parcialmente procesado'
+        else:
+            resultado['estado_general'] = 'INCOMPLETO'
+            resultado['mensaje'] = 'Pedimento con información incompleta'
+        
+        resultado['porcentaje_completitud'] = (campos_completos / total_campos) * 100 if total_campos > 0 else 0
+        
+        # 8. Sugerencias
+        sugerencias = []
+        if not pedimento.numero_operacion:
+            sugerencias.append("Falta el número de operación")
+        if not pedimento.numero_partidas:
+            sugerencias.append("Falta el número de partidas")
+        if pedimento.numero_partidas and pedimento.numero_partidas > pedimento.partidas.count():
+            sugerencias.append(f"Faltan partidas: {pedimento.numero_partidas - pedimento.partidas.count()} de {pedimento.numero_partidas}")
+        if not pedimento.contribuyente:
+            sugerencias.append("Falta el contribuyente asociado")
+        
+        resultado['sugerencias'] = sugerencias
+        
+        return resultado
+        
+    except Pedimento.DoesNotExist:
+        return {
+            'error': f'Pedimento con ID {pedimento_id} no encontrado',
+            'pedimento_id': str(pedimento_id)
+        }
+    except Exception as e:
+        return {
+            'error': f'Error auditar pedimento {pedimento_id}: {str(e)}',
+            'pedimento_id': str(pedimento_id)
+        }

api/customs/tasks/auditoria_xml.py

@@ -0,0 +1,194 @@
+# auditoria_xml.py
+import xml.etree.ElementTree as ET
+from datetime import datetime
+
+def extraer_info_pedimento_xml(xml_content):
+    """
+    Extrae información específica de un XML de pedimento.
+    """
+    try:
+        # Parsear el XML
+        root = ET.fromstring(xml_content)
+        
+        # Buscar el namespace (puede variar)
+        namespaces = {
+            'S': 'http://schemas.xmlsoap.org/soap/envelope/',
+            'ns2': 'http://www.ventanillaunica.gob.mx/pedimentos/ws/oxml/consultarpedimentocompleto',
+            'ns3': 'http://www.ventanillaunica.gob.mx/common/ws/oxml/respuesta'
+        }
+        
+        resultado = {}
+        
+        # Extraer número de operación
+        num_op = root.find('.//ns2:numeroOperacion', namespaces)
+        if num_op is not None and num_op.text:
+            resultado['numero_operacion'] = num_op.text
+        
+        # Extraer información del pedimento
+        pedimento_elem = root.find('.//ns2:pedimento', namespaces)
+        if pedimento_elem is not None:
+            # Número de pedimento
+            ped_num = pedimento_elem.find('ns2:pedimento', namespaces)
+            if ped_num is not None and ped_num.text:
+                resultado['numero_pedimento'] = ped_num.text
+            
+            # Número de partidas
+            partidas = pedimento_elem.find('ns2:partidas', namespaces)
+            if partidas is not None and partidas.text:
+                try:
+                    resultado['numero_partidas'] = int(partidas.text)
+                except (ValueError, TypeError):
+                    pass
+            
+            # Tipo de operación clave
+            tipo_op_clave = pedimento_elem.find('.//ns2:tipoOperacion/ns2:clave', namespaces)
+            if tipo_op_clave is not None and tipo_op_clave.text:
+                if tipo_op_clave.text.strip() == '1':
+
+                    resultado['tipo_operacion'] = 'Importacion'
+                    resultado['tipo_operacion_descripcion'] = 'Indica operacion como Importaciones'
+
+                elif tipo_op_clave.text.strip() == '2':
+                    
+                    resultado['tipo_operacion'] = 'Exportacion'
+                    resultado['tipo_operacion_descripcion'] = 'Indica operacion de exportacion' 
+
+
+             # Clave del documento (clave_pedimento)
+            clave_doc = pedimento_elem.find('.//ns2:claveDocumento/ns2:clave', namespaces)
+            if clave_doc is not None and clave_doc.text:
+                resultado['clave_pedimento'] = clave_doc.text.strip()
+
+            # Aduana (patente)
+            aduana = pedimento_elem.find('.//ns2:aduanaEntradaSalida/ns2:clave', namespaces)
+            if aduana is not None and aduana.text:
+                resultado['aduana_clave'] = aduana.text.strip()
+
+            # Importador/Exportador
+            importador = pedimento_elem.find('.//ns2:importadorExportador', namespaces)
+            if importador is not None:
+                rfc = importador.find('ns2:rfc', namespaces)
+                if rfc is not None and rfc.text:
+                    resultado['contribuyente_rfc'] = rfc.text.strip()
+                
+                razon_social = importador.find('ns2:razonSocial', namespaces)
+                if razon_social is not None and razon_social.text:
+                    resultado['contribuyente_nombre'] = razon_social.text.strip()
+                
+                # Valor en dólares
+                valor_dolares = importador.find('ns2:valorDolares', namespaces)
+                if valor_dolares is not None and valor_dolares.text:
+                    try:
+                        resultado['valor_dolares'] = float(valor_dolares.text)
+                    except (ValueError, TypeError):
+                        pass
+
+                # Aduana de despacho
+                aduana_despacho = importador.find('ns2:aaduanaDespacho/ns2:clave', namespaces)
+                if aduana_despacho is not None and aduana_despacho.text:
+                    resultado['aduana_despacho'] = aduana_despacho.text.strip()
+            
+            # Encabezado del pedimento
+            encabezado = pedimento_elem.find('ns2:encabezado', namespaces)
+            if encabezado is not None:
+                # Aduana
+                aduana = encabezado.find('ns2:aduanaEntradaSalida/ns2:clave', namespaces)
+                if aduana is not None and aduana.text:
+                    resultado['aduana_clave'] = aduana.text.strip()
+                
+                # Tipo de cambio
+                tipo_cambio = encabezado.find('ns2:tipoCambio', namespaces)
+                if tipo_cambio is not None and tipo_cambio.text:
+                    try:
+                        resultado['tipo_cambio'] = float(tipo_cambio.text)
+                    except (ValueError, TypeError):
+                        pass
+                
+                # RFC Agente Aduanal
+                rfc_agente = encabezado.find('ns2:rfcAgenteAduanalSocFactura', namespaces)
+                if rfc_agente is not None and rfc_agente.text:
+                    resultado['rfc_agente_aduanal'] = rfc_agente.text.strip()
+
+                # CURP Apoderado
+                curp_apoderado = encabezado.find('ns2:curpApoderadomandatario', namespaces)
+                if curp_apoderado is not None and curp_apoderado.text:
+                    resultado['curp_apoderado'] = curp_apoderado.text.strip()
+
+                # Valor Aduanal Total
+                valor_aduanal = encabezado.find('ns2:valorAduanalTotal', namespaces)
+                if valor_aduanal is not None and valor_aduanal.text:
+                    try:
+                        resultado['valor_aduanal_total'] = float(valor_aduanal.text)
+                    except (ValueError, TypeError):
+                        pass
+
+                # Valor Comercial Total
+                valor_comercial = encabezado.find('ns2:valorComercialTotal', namespaces)
+                if valor_comercial is not None and valor_comercial.text:
+                    try:
+                        resultado['valor_comercial_total'] = float(valor_comercial.text)
+                    except (ValueError, TypeError):
+                        pass
+                    
+            # Fechas
+            fechas = pedimento_elem.findall('.//ns2:fechas', namespaces)
+            for fecha_elem in fechas:
+                fecha = fecha_elem.find('ns2:fecha', namespaces)
+                clave_fecha = fecha_elem.find('ns2:tipo/ns2:clave', namespaces)
+
+                if fecha is not None and fecha.text and clave_fecha is not None and clave_fecha.text:
+
+                    fecha_texto = fecha.text.strip()
+                    clave_fecha_texto = clave_fecha.text.strip()
+
+                    # Mapeo de claves según especificación
+                    if clave_fecha_texto == '1':  # Entrada
+                        resultado['fecha_entrada'] = fecha_texto
+                    elif clave_fecha_texto == '2':  # Pago
+                        resultado['fecha_pago'] = fecha_texto
+                    elif clave_fecha_texto == '3':  # Extracción
+                        resultado['fecha_extraccion'] = fecha_texto
+                    elif clave_fecha_texto == '5':  # Presentación
+                        resultado['fecha_presentacion'] = fecha_texto
+                    elif clave_fecha_texto == '6':  # Importación
+                        resultado['fecha_importacion'] = fecha_texto
+                    elif clave_fecha_texto == '7':  # Original
+                        resultado['fecha_original'] = fecha_texto
+                    else:
+                        resultado[f'fecha_clave_{clave_fecha_texto}'] = fecha_texto
+
+            # Facturas (para COVEs)
+            facturas = pedimento_elem.findall('.//ns2:facturas', namespaces)
+            coves_encontrados = []
+            for factura in facturas:
+                numero = factura.find('ns2:numero', namespaces)
+                if numero is not None and numero.text:
+                    coves_encontrados.append(numero.text.strip())
+            
+            if coves_encontrados:
+                resultado['coves_en_xml'] = coves_encontrados
+            
+            # E-Documents
+            identificadores = pedimento_elem.findall('.//ns2:identificadores/ns2:identificadores', namespaces)
+            edocs_encontrados = []
+            for ident in identificadores:
+                clave = ident.find('claveIdentificador/descripcion', namespaces)
+                complemento = ident.find('complemento1', namespaces)
+                if clave is not None and clave.text and 'E_DOCUMENT' in clave.text:
+                    if complemento is not None and complemento.text:
+                        edocs_encontrados.append(complemento.text.strip())
+            
+            if edocs_encontrados:
+                resultado['edocuments_en_xml'] = edocs_encontrados
+        
+        # Verificar si hay error en la respuesta
+        tiene_error = root.find('.//ns3:tieneError', namespaces)
+        if tiene_error is not None:
+            resultado['tiene_error'] = tiene_error.text.lower() == 'true'
+        
+        return resultado
+        
+    except ET.ParseError as e:
+        return {'error_parse': str(e)}
+    except Exception as e:
+        return {'error': str(e)}

api/customs/tasks/microservice_v2.py

@@ -427,6 +427,35 @@ def documentos_con_errores(organizacion_id):
             print(f"Documento con error: {doc.id} en organización {organizacion_id}")
             # Aquí puedes agregar lógica adicional para manejar documentos con errores
             # como enviar notificaciones, registrar en un log, etc.
-#    documentos = Document.objects.all() --- IGNORE ---
+            
+            
+def ejecutar_por_organizacion_y_procesamiento(organizacion_id, procesamiento):
+    if procesamiento == 'coves':
+        procesar_coves.delay(organizacion_id)
+    elif procesamiento == 'edocs':
+        procesar_edocs.delay(organizacion_id)
+    elif procesamiento == 'acuses':
+        procesar_acuses.delay(organizacion_id)
+    elif procesamiento == 'acuse_coves':
+        procesar_acuse_coves.delay(organizacion_id)
+    elif procesamiento == 'partidas':
+        procesar_partidas.delay(organizacion_id)
+    elif procesamiento == 'pedimentos_completos':
+        procesar_pedimentos_completos.delay(organizacion_id)
+    elif procesamiento == 'remesas':
+        procesar_remesas.delay(organizacion_id)
+
+    else:
+        # Procesamiento no reconocido
+        pass
+
+def ejecutar_todos_por_organizacion(organizacion_id):
+    procesar_coves.delay(organizacion_id)
+    procesar_edocs.delay(organizacion_id)
+    procesar_acuses.delay(organizacion_id)
+    procesar_acuse_coves.delay(organizacion_id)
+    procesar_partidas.delay(organizacion_id)
+    procesar_pedimentos_completos.delay(organizacion_id)
+    procesar_remesas.delay(organizacion_id)
 
 

api/customs/urls.py

@@ -42,7 +42,24 @@ from .views_auditor import (
     auditar_acuse_cove_pedimento_endpoint,
     auditar_edocument_pedimento_endpoint,
     auditar_acuse_pedimento_endpoint,
-    auditor_procesar_pedimentos_organizacion
+    auditar_procesamiento_remesa_pedimento_endpoint,
+    auditor_procesar_pedimentos_organizacion,
+    auditar_peticion_respuesta_pedimento_completo,
+    auditor_obtener_peticion_pedimento_vu,
+    auditor_obtener_respuesta_pedimento_vu,
+    auditor_obtener_peticion_remesa_vu,
+    auditor_obtener_respuesta_remesa_vu,
+    auditor_obtener_peticion_partidas_vu,
+    auditor_obtener_respuesta_partidas_vu,
+    auditor_obtener_peticion_acuse_vu,
+    auditor_obtener_respuesta_acuse_vu,
+    auditor_obtener_peticion_cove_vu,
+    auditor_obtener_respuesta_cove_vu,
+    auditor_obtener_peticion_acuse_cove_vu,
+    auditor_obtener_respuesta_acuse_cove_vu,
+    auditor_obtener_peticion_edocument_vu,
+    auditor_obtener_respuesta_edocument_vu,
+    auditar_pedimento_endpoint,
 )
 
 urlpatterns = [
@@ -58,5 +75,24 @@ urlpatterns = [
     path('auditor/auditar-acuse-cove/pedimento/', auditar_acuse_cove_pedimento_endpoint, name='auditar-acuse-cove-pedimento'),
     path('auditor/auditar-edocument/pedimento/', auditar_edocument_pedimento_endpoint, name='auditar-edocument-pedimento'),
     path('auditor/auditar-acuse/pedimento/', auditar_acuse_pedimento_endpoint, name='auditar-acuse-pedimento'),
+    path('auditor/auditar-remesa/pedimento/', auditar_procesamiento_remesa_pedimento_endpoint, name='auditar-remesa-pedimento'),
+    path('auditor/auditar-pedimento/', auditar_pedimento_endpoint, name='auditar-pedimento'),
+
     path('auditor/procesar-pedimentos/organizaciones/', auditor_procesar_pedimentos_organizacion, name='procesar-pedimentos-organizaciones'),
+    path('auditor/peticion-respuesta/pedimento-vu/', auditar_peticion_respuesta_pedimento_completo, name='peticion-respuesta-pedimento-vu'),
+
+    path('auditor/obtener-peticion/pedimento-vu/', auditor_obtener_peticion_pedimento_vu, name='obtener-peticion-pedimento-vu'),
+    path('auditor/obtener-respuesta/pedimento-vu/', auditor_obtener_respuesta_pedimento_vu, name='obtener-respuesta-pedimento-vu'),
+    path('auditor/obtener-peticion/remesa-vu/', auditor_obtener_peticion_remesa_vu, name='obtener-peticion-remesa-vu'),
+    path('auditor/obtener-respuesta/remesa-vu/', auditor_obtener_respuesta_remesa_vu, name='obtener-respuesta-remesa-vu'),
+    path('auditor/obtener-peticion/partidas-vu/', auditor_obtener_peticion_partidas_vu, name='obtener-peticion-partidas-vu'),
+    path('auditor/obtener-respuesta/partidas-vu/', auditor_obtener_respuesta_partidas_vu, name='obtener-respuesta-partidas-vu'),
+    path('auditor/obtener-peticion/acuse-vu/', auditor_obtener_peticion_acuse_vu, name='obtener-peticion-acuse-vu'),
+    path('auditor/obtener-respuesta/acuse-vu/', auditor_obtener_respuesta_acuse_vu, name='obtener-respuesta-acuse-vu'),
+    path('auditor/obtener-peticion/cove-vu/', auditor_obtener_peticion_cove_vu, name='obtener-peticion-cove-vu'),
+    path('auditor/obtener-respuesta/cove-vu/', auditor_obtener_respuesta_cove_vu, name='obtener-respuesta-cove-vu'),
+    path('auditor/obtener-peticion/acuse-cove-vu/', auditor_obtener_peticion_acuse_cove_vu, name='obtener-peticion-acuse-cove-vu'),
+    path('auditor/obtener-respuesta/acuse-cove-vu/', auditor_obtener_respuesta_acuse_cove_vu, name='obtener-respuesta-acuse-cove-vu'),
+    path('auditor/obtener-peticion/edocument-vu/', auditor_obtener_peticion_edocument_vu, name='obtener-peticion-edocument-vu'),
+    path('auditor/obtener-respuesta/edocument-vu/', auditor_obtener_respuesta_edocument_vu, name='obtener-respuesta-edocument-vu'),
 ]

api/record/serializers.py

@@ -9,10 +9,11 @@ from api.customs.models import Pedimento
 class DocumentSerializer(serializers.ModelSerializer):
     pedimento_numero = serializers.SerializerMethodField(read_only=True)
     pedimento = serializers.PrimaryKeyRelatedField(queryset=Pedimento.objects.all())
-
+    fuente_nombre = serializers.SerializerMethodField()
+    fuente = serializers.PrimaryKeyRelatedField(queryset=Fuente.objects.all())
     class Meta:
         model = Document
-        fields = ('id', 'organizacion', 'pedimento', 'pedimento_numero', 'archivo', 'document_type', 'size', 'extension', 'fuente','created_at', 'updated_at')
+        fields = ('id', 'organizacion', 'pedimento', 'pedimento_numero', 'archivo', 'document_type', 'size', 'extension', 'fuente','fuente_nombre','created_at', 'updated_at')
         read_only_fields = ('id', 'size', 'extension', 'created_at', 'updated_at', 'pedimento_numero')
 
     def get_pedimento_numero(self, obj):
@@ -26,6 +27,12 @@ class DocumentSerializer(serializers.ModelSerializer):
             raise serializers.ValidationError("Se requiere un archivo para subir")
         return value
 
+    def get_fuente_nombre(self, obj):
+        # Método 1: Si la fuente está precargada con select_related
+        if obj.fuente:
+            return obj.fuente.nombre
+        return "Desconocido"
+
 class FuenteSerializer(serializers.ModelSerializer):
     class Meta:
         model = Fuente

api/record/urls.py

@@ -4,12 +4,22 @@ from rest_framework.routers import DefaultRouter
 
 # import necessary viewsets
 # from .views import YourViewSet  # Import your viewsets here
-from .views import  DocumentViewSet, ProtectedDocumentDownloadView, BulkDownloadZipView, GetFuenteView, DocumentTypeView
+from .views import  (DocumentViewSet
+                     , ProtectedDocumentDownloadView
+                     , BulkDownloadZipView
+                     , GetFuenteView
+                     , DocumentTypeView
+                     , ExpedienteZipDownloadView
+                     , MultiPedimentoZipDownloadView
+                     , PedimentoDocumentViewSet
+                     , TriggerPedimentoCompletoView)
+
+
 # Create a router and register your viewsets with it
 
 router = DefaultRouter()
 
-# Register your viewsets with the router here
+# Register your viewsets with the router he -fre
 # Example:
 # from .views import MyViewSet
 # router.register(r'myviewset', MyViewSet, basename='myviewset')
@@ -23,5 +33,9 @@ urlpatterns = [
     path('documents/descargar/<uuid:pk>/', ProtectedDocumentDownloadView.as_view(), name='descargar-documento'),
     path('fuente/', GetFuenteView.as_view(), name='get-fuente'),
     path('document-type/', DocumentTypeView.as_view(), name='document-type-list-create'),
+    path('documents/expediente-zip/', ExpedienteZipDownloadView.as_view(), name='expediente-zip-download'),
+    path('documents/multi-pedimento-zip/', MultiPedimentoZipDownloadView.as_view(), name='multi-pedimento-zip-download'),
+    path('pedimento-documents/', PedimentoDocumentViewSet.as_view({'get': 'list'}), name='pedimento-document-list'),
+    path('microservice/pedimento-completo/', TriggerPedimentoCompletoView.as_view(), name='trigger-pedimento-completo'),
     path('', include(router.urls)),
 ]

api/record/views.py

@@ -13,6 +13,8 @@ from rest_framework.exceptions import ValidationError
 
 from .serializers import DocumentSerializer, FuenteSerializer, DocumentTypeSerializer
 from .models import Document, Fuente, DocumentType
+from ..customs.models import Pedimento
+from ..vucem.models import CredencialesImportador
 from api.organization.models import UsoAlmacenamiento
 from io import BytesIO
 import zipfile
@@ -32,8 +34,93 @@ from core.permissions import (
 import logging
 logger = logging.getLogger(__name__)
 
+import os
+from django.core.files.storage import default_storage
+from django.conf import settings
+import requests
+import re
+
 from mixins.filtrado_organizacion import DocumentosFiltradosMixin
 
+# Configuración de patrones y mapeos (definirlo fuera del try para reutilización)
+DOCUMENT_PATTERNS = {
+    'REQUEST': {
+        'VU_PC': (r".*VU_PC.*REQUEST\.xml$", 13, "Request Pedimento Completo VU"),
+        'VU_ED': (r".*VU_ED.*REQUEST\.xml$", 21, "Request E-Document VU"),
+        'VU_PT': (r".*VU_PT.*REQUEST\.xml$", 17, "Request Partidas VU"),
+        'VU_AC_COVE': (r".*VU_AC_COVE.*REQUEST\.xml$", 23, "Request Acuses COVES VU"),
+        'VU_COVE': (r".*VU_COVE.*REQUEST\.xml$", 19, "Request COVES VU"),
+        'VU_RM': (r".*VU_RM.*REQUEST\.xml$", 15, "Request Remesas VU"),
+        'VU_AC': (r".*VU_AC.*REQUEST\.xml$", 25, "Request Acuses VU"),
+    },
+    'ERROR': {
+        'VU_PC': (r".*VU_PC.*ERROR\.xml$", 14, "Error Pedimento Completo VU"),
+        'VU_ED': (r".*VU_ED.*ERROR\.xml$", 22, "Error E-Document VU"),
+        'VU_PT': (r".*VU_PT.*ERROR\.xml$", 18, "Error Partidas VU"),
+        'VU_AC_COVE': (r".*VU_AC_COVE.*ERROR\.xml$", 24, "Error Acuses COVES VU"),
+        'VU_COVE': (r".*VU_COVE.*ERROR\.xml$", 20, "Error COVES VU"),
+        'VU_RM': (r".*VU_RM.*ERROR\.xml$", 16, "Error Remesas VU"),
+        'VU_AC': (r".*VU_AC.*ERROR\.xml$", 26, "Error Acuses VU"),
+    }
+}
+
+def eliminar_documentos_existentes(organizacion, nombre_sin_extension, pedimento_id):
+
+    """Elimina documentos existentes con el mismo nombre base"""
+    documentos_existentes = Document.objects.filter(
+        archivo__icontains=nombre_sin_extension,
+        organizacion=organizacion,
+        pedimento_id=pedimento_id
+    )
+
+    if not documentos_existentes.exists():
+        return
+    
+    for doc_existente in documentos_existentes:
+        # Eliminar archivo físico si existe
+        if doc_existente.archivo and os.path.exists(doc_existente.archivo.path):
+            try:
+                os.remove(doc_existente.archivo.path)
+            except Exception as e:
+                logger.error(f"Error al eliminar archivo físico: {e}")
+
+    # Eliminar registros de la base de datos
+    documentos_existentes.delete()
+
+def obtener_tipo_documento_por_patron(nombre_archivo, organizacion, pedimento_id):
+    """Determina el tipo de documento basado en patrones de nombre"""
+    nombre_sin_extension = nombre_archivo.rsplit('.', 1)[0]
+
+     # Verificar patrones REQUEST
+    for doc_key, (patron, type_id, descripcion) in DOCUMENT_PATTERNS['REQUEST'].items():
+        if re.search(patron, nombre_archivo, re.IGNORECASE):
+            try:
+                # Eliminar documentos existentes
+                eliminar_documentos_existentes(organizacion, nombre_sin_extension, pedimento_id)
+                
+                # Obtener tipo de documento
+                return DocumentType.objects.get(id=type_id)
+            except DocumentType.DoesNotExist:
+                raise ValidationError({
+                    "error": f"El tipo de documento '{descripcion}' no existe. Por favor, créelo primero."
+                })
+            
+    # Verificar patrones ERROR (si es necesario procesarlos)
+    for doc_key, (patron, type_id, descripcion) in DOCUMENT_PATTERNS['ERROR'].items():
+        if re.search(patron, nombre_archivo, re.IGNORECASE):
+            try:
+                # Eliminar documentos existentes
+                eliminar_documentos_existentes(organizacion, nombre_sin_extension, pedimento_id)
+                
+                # Obtener tipo de documento
+                return DocumentType.objects.get(id=type_id)
+            except DocumentType.DoesNotExist:
+                raise ValidationError({
+                    "error": f"El tipo de documento '{descripcion}' no existe. Por favor, créelo primero."
+                })
+        
+    return None
+
 class CustomPagination(PageNumberPagination):
 
     """
@@ -59,7 +146,8 @@ class DocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
     pagination_class = CustomPagination
     serializer_class = DocumentSerializer
     # Habilitar filtro por pedimento (UUID) y pedimento_numero (campo pedimento del modelo relacionado)
-    filterset_fields = ['extension', 'size', 'document_type', 'pedimento', 'pedimento__pedimento']
+    filterset_fields = ['extension', 'size', 'document_type', 'pedimento', 'pedimento__pedimento', 'created_at']
+    # filterset_fields = ['extension', 'size', 'pedimento', 'pedimento__pedimento']
 
     # Puedes filtrar por pedimento usando: /api/record/documents/?pedimento=<id> o /api/record/documents/?pedimento__pedimento=<numero>
     # Ejemplo: /api/record/documents/?pedimento_numero=12345678
@@ -67,6 +155,33 @@ class DocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
 
     def get_queryset(self):
         queryset = self.get_queryset_filtrado_por_organizacion()
+
+        modulo_efc = self.request.query_params.get('modulo')
+        if modulo_efc:
+            if modulo_efc == 'expedientes-detalle-pedimentos':
+                queryset = queryset.exclude(document_type_id__in=['1','2','3','4','5','6','7','8','9','10'])
+                # Filtro personalizado por document_type
+                # document_type = self.request.query_params.get('document_type')
+                # if document_type:
+                #     # Puedes agregar lógica personalizada aquí si es necesario
+                #     if document_type == '1':
+                #         queryset = queryset.filter(document_type_id=document_type)
+                #     elif document_type == '2':
+                #         queryset = queryset.filter(document_type_id=document_type)
+                #     else:
+                #         queryset = queryset.filter(document_type_id=document_type)
+                # else:
+                #     queryset = queryset.filter(document_type_id='11')
+
+        fechaCreacion = self.request.query_params.get('created_at__date')
+        if fechaCreacion:
+            queryset = queryset.filter(created_at=fechaCreacion)
+
+        buscarArchivo = self.request.query_params.get('archivo__icontains')
+        if buscarArchivo:
+            queryset = queryset.filter(archivo__icontains=buscarArchivo)
+
+
         pedimento_numero = self.request.query_params.get('pedimento_numero')
         if pedimento_numero:
             queryset = queryset.filter(pedimento__pedimento_app=pedimento_numero)
@@ -112,12 +227,45 @@ class DocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
                 "codigo": "storage_limit_exceeded"
             }, code=status.HTTP_400_BAD_REQUEST)
 
-        # Guardar documento y actualizar espacio atómicamente
-        documento = serializer.save(
-            organizacion=organizacion,
-            size=archivo.size,
-            extension=archivo.name.split('.')[-1].lower()
-        )
+        
+        try:
+
+            pedimento_id = serializer.validated_data.get('pedimento').id if serializer.validated_data.get('pedimento') else None
+            document_type = serializer.validated_data.get('document_type')
+
+            # Determinar el tipo de documento basado en el nombre del archivo
+            detected_type = obtener_tipo_documento_por_patron(archivo.name, organizacion, pedimento_id)
+
+            if detected_type:
+                document_type = detected_type
+            else:
+                # Lógica para archivos que no coinciden con los patrones conocidos
+                logger.warning(f"No se encontró patrón para archivo: {archivo.name}")
+                # Puedes mantener el document_type original o manejarlo de otra forma
+
+        except ValidationError as ve:
+            raise ve
+        except Exception as e:
+            # Como fallback, intentar obtener cualquier DocumentType existente
+            logger.error(f"Error al determinar el tipo de documento basado en el nombre del archivo: {e}")
+        
+        try:
+            
+            # Guardar documento y actualizar espacio atómicamente
+            documento = serializer.save(
+                document_type=document_type,
+                organizacion=organizacion,
+                size=archivo.size,
+                extension=archivo.name.split('.')[-1].lower()
+            )
+
+        except Exception as e:
+            # Guardar documento y actualizar espacio atómicamente
+            documento = serializer.save(
+                organizacion=organizacion,
+                size=archivo.size,
+                extension=archivo.name.split('.')[-1].lower()
+            )
 
         uso.espacio_utilizado = nuevo_espacio_utilizado
         uso.save()
@@ -530,7 +678,6 @@ class ProtectedDocumentDownloadView(APIView, DocumentosFiltradosMixin):
     def get(self, request, pk):
         if not request.user.is_authenticated or not hasattr(request.user, 'organizacion'):
             raise Http404("Usuario no autenticado")
-        
 
         try:
             doc = Document.objects.get(pk=pk)
@@ -617,4 +764,299 @@ class DocumentTypeView(APIView):
         if not queryset.exists():
             return Response({"detail": "No hay tipos de documento disponibles."}, status=404)
         serializer = self.serializer_class(queryset, many=True)
-        return Response(serializer.data, status=200)
+        return Response(serializer.data, status=200)
+    
+class ExpedienteZipDownloadView(APIView, DocumentosFiltradosMixin):
+    permission_classes = [IsAuthenticated &  (IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper | IsSuperUser)]
+    my_tags = ['Documents']
+
+    def post(self, request):
+        """
+        Descarga todos los documentos de un pedimento (o filtrados) en un ZIP.
+        Body: { "pedimento_id": "<uuid>" }
+        """
+        pedimento_id = request.data.get('pedimento_id')
+        if not pedimento_id:
+            return Response({"error": "Falta pedimento_id"}, status=status.HTTP_400_BAD_REQUEST)
+
+        # Validar que el pedimento existe
+        try:
+            pedimento = Pedimento.objects.get(pk=pedimento_id)
+        except Pedimento.DoesNotExist:
+            raise Http404("Pedimento no encontrado")
+
+        # Filtrar documentos del pedimento (y de la org del usuario)
+        base_qs = Document.objects.filter(pedimento=pedimento)
+        if not request.user.is_superuser:
+            if not hasattr(request.user, 'organizacion') or request.user.organizacion != pedimento.organizacion:
+                return Response({"error": "No autorizado"}, status=status.HTTP_403_FORBIDDEN)
+            base_qs = base_qs.filter(organizacion=request.user.organizacion)
+
+        docs = base_qs.select_related('pedimento')
+        if not docs.exists():
+            return Response({"error": "No hay documentos para este pedimento"}, status=status.HTTP_404_NOT_FOUND)
+
+        # 1. Crear un único buffer y ZIP para todos los archivos
+        buffer = BytesIO()
+        missing_files = []  # opcional: para informar después
+        files_found = [] 
+
+        with zipfile.ZipFile(buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
+            for doc in docs:
+                # 2. Validaciones
+                if not doc.archivo.name:
+                    logger.warning("Documento %s no tiene archivo asociado", doc.id)
+                    missing_files.append(f"{doc.id} (sin archivo)")
+                    continue
+                if not default_storage.exists(doc.archivo.name):
+                    logger.warning("Archivo no encontrado en disco: %s", doc.archivo.path)
+                    missing_files.append(f"{doc.id} ({doc.archivo.name})")
+                    continue
+
+                files_found.append(f"{doc.id} ({doc.archivo.name})")
+
+                # 3. Nombre seguro para dentro del ZIP
+                file_name = slugify(doc.archivo.name.rsplit('/', 1)[-1].rsplit('.', 1)[0])
+                ext = doc.archivo.name.split('.')[-1]
+                name_inside_zip = f"{file_name}.{ext}"
+
+                # 4. Escribir el archivo dentro del ZIP
+                with doc.archivo.open('rb') as f:
+                    zip_file.writestr(name_inside_zip, f.read())
+
+        # 5. Preparar respuesta
+        buffer.seek(0)
+        zip_name = slugify(f"expediente_{pedimento.pedimento_app}")
+        response = HttpResponse(buffer, content_type='application/zip')
+        response['Content-Disposition'] = f'attachment; filename={zip_name or "documentos"}.zip'
+
+        if not files_found:
+            return Response({"error": f"No hay documentos para este pedimento: {pedimento.pedimento_app}"}, status=status.HTTP_404_NOT_FOUND)
+
+        # (Opcional) cabecera personalizada si faltaron archivos
+        # if missing_files:
+            # response['X-Missing-Files'] = ', '.join(missing_files)
+            # return Response({"error": f"No hay documentos para este pedimento: {pedimento.pedimento_app}"}, status=status.HTTP_404_NOT_FOUND)
+
+        return response
+
+class MultiPedimentoZipDownloadView(APIView):
+    permission_classes = [IsAuthenticated & (IsSuperUser | IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper)]
+    my_tags = ['Documents']
+
+    def post(self, request):
+        """
+        Descarga todos los documentos de VARIOS pedimentos en un solo ZIP.
+        Body: { "pedimento_ids": ["uuid1", "uuid2", ...] }
+        """
+        pedimento_ids = request.data.get('pedimento_ids', [])
+        if not isinstance(pedimento_ids, list) or not pedimento_ids:
+            return Response({"error": "Se requiere una lista de pedimento_ids"}, status=status.HTTP_400_BAD_REQUEST)
+
+        # Filtrar pedimentos visibles para el usuario
+        base_qs = Pedimento.objects.filter(id__in=pedimento_ids)
+        if not request.user.is_superuser:
+            if not hasattr(request.user, 'organizacion'):
+                return Response({"error": "No autorizado"}, status=status.HTTP_403_FORBIDDEN)
+            base_qs = base_qs.filter(organizacion=request.user.organizacion)
+
+        pedimentos = base_qs.select_related('organizacion')
+        if not pedimentos.exists():
+            return Response({"error": "Ningún pedimento encontrado o autorizado"}, status=status.HTTP_404_NOT_FOUND)
+
+        # Obtener todos los documentos de esos pedimentos
+        docs = Document.objects.filter(pedimento__in=pedimentos)
+        if not docs.exists():
+            return Response({"error": "No hay documentos para estos pedimentos"}, status=status.HTTP_404_NOT_FOUND)
+
+        # Crear ZIP único
+        buffer = BytesIO()
+        missing_files = []
+        summary = {}
+        with zipfile.ZipFile(buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
+            for doc in docs:
+
+                ped_key = doc.pedimento.pedimento_app
+
+                if not doc.archivo.name or not default_storage.exists(doc.archivo.name):
+                    missing_files.append(f"{doc.id} ({doc.archivo.name or 'sin archivo'})")
+                    logger.warning("Archivo faltante: %s", doc.id)
+                    continue
+
+                summary[ped_key] = summary.get(ped_key, 0) + 1
+
+                # Nombre seguro: pedimento_app + nombre del archivo
+                file_name = slugify(doc.archivo.name.rsplit('/', 1)[-1].rsplit('.', 1)[0])
+                ext = doc.archivo.name.split('.')[-1]
+                name_inside_zip = f"{doc.pedimento.pedimento_app}/{file_name}.{ext}"
+
+                with doc.archivo.open('rb') as f:
+                    zip_file.writestr(name_inside_zip, f.read())
+
+        buffer.seek(0)
+        zip_name = slugify(f"expedientes_{len(summary)}_pedimentos")
+
+        response = HttpResponse(buffer, content_type='application/zip')
+        response['Content-Disposition'] = f'attachment; filename={zip_name}.zip'
+        response['X-Zip-Filename'] = f"{zip_name}.zip"
+        response['Access-Control-Expose-Headers'] = 'X-Zip-Filename'
+
+        if missing_files:
+            response['X-Missing-Files'] = ', '.join(missing_files)
+
+        return response
+
+class PedimentoDocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
+    """
+    ViewSet for Document model.
+    """
+    permission_classes = [IsAuthenticated &  (IsSuperUser | IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper )]
+    model = Document
+    
+    pagination_class = CustomPagination
+    serializer_class = DocumentSerializer
+    # Habilitar filtro por pedimento (UUID) y pedimento_numero (campo pedimento del modelo relacionado)
+    # filterset_fields = ['extension', 'size', 'document_type', 'pedimento', 'pedimento__pedimento']
+    filterset_fields = ['extension', 'size', 'pedimento', 'pedimento__pedimento','fuente']
+
+    # Puedes filtrar por pedimento usando: /api/record/documents/?pedimento=<id> o /api/record/documents/?pedimento__pedimento=<numero>
+    # Ejemplo: /api/record/documents/?pedimento_numero=12345678
+    my_tags = ['Documents']
+
+    def get_queryset(self):
+        queryset = self.get_queryset_filtrado_por_organizacion()
+
+        # Tipos de documento permitidos (fijos en código, Pedimento completo y remesas) 
+        TIPOS_PERMITIDOS = ['2', '3']  # <-- Ajusta aquí tus tipos
+        tipo_documento = self.request.query_params.get('document_type')
+        if tipo_documento:
+            queryset = queryset.filter(document_type_id=tipo_documento)
+        else:
+            # Filtrar por tipos permitidos
+            queryset = queryset.filter(document_type_id__in=TIPOS_PERMITIDOS)
+
+        buscar_archivo = self.request.query_params.get('archivo__icontains')
+        if buscar_archivo:
+            queryset = queryset.filter(archivo__icontains=buscar_archivo)
+
+        created_at__date = self.request.query_params.get('created_at__date')
+        if created_at__date:
+            queryset = queryset.filter(created_at=created_at__date)
+
+        # Filtro adicional por pedimento_numero si se proporciona
+        pedimento_numero = self.request.query_params.get('pedimento_numero')
+        if pedimento_numero:
+            queryset = queryset.filter(pedimento__pedimento_app=pedimento_numero)
+
+        return queryset
+class TriggerPedimentoCompletoView(APIView):
+        """
+        Endpoint interno para disparar la descarga de pedimento completo
+        en el microservicio FastAPI. Reenvía el payload tal cual y devuelve
+        la respuesta del microservicio (normalmente un `task_id`).
+        """
+        # permission_classes = [IsAuthenticated]
+        permission_classes = [IsAuthenticated &  (IsSuperUser | IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper )]
+
+        my_tags = ['Microservice - Pedimento Completo']
+
+        def post(self, request):
+
+            if not request.user.is_authenticated or not hasattr(request.user, 'organizacion'):
+                return Response({"error": "Usuario no autenticado o sin organización"}, status=401)
+
+            # Validación mínima
+            # if not payload.get('credencial') or not payload.get('pedimento_id'):
+            #     return Response({"error": "Se requieren 'credencial' y 'pedimento'"}, status=status.HTTP_400_BAD_REQUEST)
+            
+            if not request.data.get('pedimento_id'):
+                return Response({"error": "Se requieren 'credencial' y 'pedimento'"}, status=status.HTTP_400_BAD_REQUEST)
+
+            pedimento_id = request.data.get('pedimento_id')
+            # Verificar que el pedimento existe y pertenece a la organización del usuario
+            try:
+                pedimento = Pedimento.objects.get(id=pedimento_id)
+
+                if not pedimento.contribuyente:
+                    return Response({"error": "El pedimento no tiene un contribuyente asociado"}, status=status.HTTP_400_BAD_REQUEST)
+                
+                contribuyente_rfc = pedimento.contribuyente.rfc
+
+                payload = {
+                        "pedimento": {
+                            "id": str(pedimento.id),
+                            "pedimento": pedimento.pedimento,
+                            "pedimento_app": pedimento.pedimento_app,
+                            "aduana": pedimento.aduana,
+                            "patente": pedimento.patente,
+                            "contribuyente": contribuyente_rfc,
+                            "organizacion": str(pedimento.organizacion.id)
+                        },
+                        "credencial": {
+                            "id": "",
+                            "user": "",
+                            "password": "",
+                            "efirma": "",
+                            "key": "",
+                            "cer": "",
+                            "is_active": False,
+                            "organizacion": ""
+                        }
+                    }
+            except Pedimento.DoesNotExist:
+                return Response({"error": "Pedimento no encontrado"}, status=status.HTTP_404_NOT_FOUND)
+            except Exception as e:
+                return Response({"error": f"Error al buscar pedimento: {str(e)}"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+            
+            try:
+                credenciales = CredencialesImportador.objects.get(rfc=contribuyente_rfc)
+                vucem = credenciales.vucem
+
+                # Obtener las rutas de los archivos, no los objetos FieldFile
+                key_path = vucem.key.path if vucem.key else ""
+                cer_path = vucem.cer.path if vucem.cer else ""
+
+                payload['credencial'] = {
+                    "id": str(credenciales.id),
+                    "user": vucem.usuario if vucem.usuario else "",
+                    "password": vucem.password if vucem.password else "",
+                    "efirma": vucem.efirma if vucem.efirma else "",
+                    "key": key_path,
+                    "cer": cer_path,
+                    "is_active": vucem.is_active if vucem.is_active else False,
+                    "organizacion": str(credenciales.organizacion.id) if credenciales.organizacion else ""
+                }
+            except CredencialesImportador.DoesNotExist:
+                return Response({"error": "No se encontró credencial VUCEM para la organización del pedimento"}, status=status.HTTP_404_NOT_FOUND)
+            except Exception as e:
+                return Response({"error": f"Error al buscar credencial VUCEM: {str(e)}"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
+            try:
+                # Obtener la URL desde las variables de entorno
+                api_url = os.getenv('SERVICE_API_URL_V2')
+                logger.info(f"Usando MICROSERVICE_BASE_URL: {api_url}")
+                endpoint = f"{api_url.rstrip('/')}/services/auditar_pedimento_completo"
+                # endpoint = "http://localhost:8001/api/v2/services/auditar_pedimento_completo"
+            except requests.exceptions.RequestException as e:
+                logger.error(f"Error obteniendo MICROSERVICE_BASE_URL: {e}")
+                return Response({"error": "Error obteniendo la URL del microservicio", "detail": str(e)}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+            except Exception as e:
+                logger.error(f"Error inesperado obteniendo MICROSERVICE_BASE_URL: {e}")
+                return Response({"error": "Error inesperado obteniendo la URL del microservicio", "detail": str(e)}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+            
+            try:
+                resp = requests.post(endpoint, json=payload, timeout=30)
+            except requests.exceptions.RequestException as e:
+                logger.error(f"Error comunicándose con microservice: {e}")
+                return Response({"error": "No se pudo conectar con el microservicio", "detail": str(e)}, status=status.HTTP_502_BAD_GATEWAY)
+
+            try:
+                content = resp.json()
+            except ValueError:
+                content = {"detail": resp.text}
+
+            return Response(content, status=resp.status_code)
+        
+
+
+        

api/reports/migrations/0001_initial.py

@@ -0,0 +1,30 @@
+# Generated by Django 5.2.3 on 2025-10-21 23:56
+
+import django.db.models.deletion
+from django.conf import settings
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='ReportDocument',
+            fields=[
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('filters', models.JSONField(blank=True, null=True)),
+                ('status', models.CharField(choices=[('pending', 'Pendiente'), ('processing', 'Procesando'), ('ready', 'Listo'), ('error', 'Error')], default='pending', max_length=20)),
+                ('file', models.FileField(blank=True, null=True, upload_to='reports/')),
+                ('error_message', models.TextField(blank=True, null=True)),
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+                ('finished_at', models.DateTimeField(blank=True, null=True)),
+                ('user', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='report_documents', to=settings.AUTH_USER_MODEL)),
+            ],
+        ),
+    ]

api/reports/models.py

@@ -1,3 +1,21 @@
-from django.db import models
 
-# Create your models here.
+from django.db import models
+from django.contrib.auth import get_user_model
+
+class ReportDocument(models.Model):
+	STATUS_CHOICES = [
+		('pending', 'Pendiente'),
+		('processing', 'Procesando'),
+		('ready', 'Listo'),
+		('error', 'Error'),
+	]
+	user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE, related_name='report_documents')
+	filters = models.JSONField(blank=True, null=True)
+	status = models.CharField(max_length=20, choices=STATUS_CHOICES, default='pending')
+	file = models.FileField(upload_to='reports/', blank=True, null=True)
+	error_message = models.TextField(blank=True, null=True)
+	created_at = models.DateTimeField(auto_now_add=True)
+	finished_at = models.DateTimeField(blank=True, null=True)
+
+	def __str__(self):
+		return f"Reporte {self.id} - {self.status}"

api/reports/tasks/report_document.py

@@ -0,0 +1,85 @@
+from celery import shared_task
+from django.core.files.base import ContentFile
+from django.utils import timezone
+from api.reports.models import ReportDocument
+from api.customs.models import Pedimento, Cove, EDocument, Partida
+from django.db.models import Q
+import csv
+import os
+from django.conf import settings
+
+@shared_task
+def generate_report_document(report_id):
+    try:
+        report = ReportDocument.objects.get(id=report_id)
+        report.status = 'processing'
+        report.save(update_fields=['status'])
+        filters = report.filters or {}
+        # Construir Q para filtros complejos
+        pedimentos_filters = Q()
+        if filters.get('organizacion_id'):
+            pedimentos_filters &= Q(organizacion_id=filters['organizacion_id'])
+        if filters.get('fecha_pago__gte'):
+            pedimentos_filters &= Q(fecha_pago__gte=filters['fecha_pago__gte'])
+        if filters.get('fecha_pago__lte'):
+            pedimentos_filters &= Q(fecha_pago__lte=filters['fecha_pago__lte'])
+        if filters.get('contribuyente__rfc'):
+            pedimentos_filters &= Q(contribuyente__rfc=filters['contribuyente__rfc'])
+        if filters.get('patente'):
+            pedimentos_filters &= Q(patente=filters['patente'])
+        if filters.get('aduana'):
+            pedimentos_filters &= Q(aduana=filters['aduana'])
+        if filters.get('pedimento'):
+            pedimentos_filters &= Q(pedimento=filters['pedimento'])
+        if filters.get('pedimento_app'):
+            pedimentos_filters &= Q(pedimento_app=filters['pedimento_app'])
+        if filters.get('regimen'):
+            pedimentos_filters &= Q(regimen=filters['regimen'])
+        if filters.get('tipo_operacion'):
+            pedimentos_filters &= Q(tipo_operacion_id=filters['tipo_operacion'])
+        # Consulta asíncrona de los modelos
+        pedimentos = Pedimento.objects.filter(pedimentos_filters)
+        filename = filters.get('filename')
+        if filename:
+            filename = f"{filename}.csv" if not filename.endswith('.csv') else filename
+        else:
+            filename = f"report_{report.id}_{timezone.now().strftime('%Y%m%d%H%M%S')}.csv"
+        file_path = os.path.join(settings.MEDIA_ROOT, 'reports', filename)
+        os.makedirs(os.path.dirname(file_path), exist_ok=True)
+        with open(file_path, 'w', newline='', encoding='utf-8') as f:
+            writer = csv.writer(f)
+            headers = [
+                'aduana', 'patente', 'regimen', 'pedimento', 'pedimento_app', 'clave_pedimento',
+                'tipo_operacion_id', 'contribuyente_id', 'tipo_documento', 'numero_documento', 'estado', 'acuse_estado'
+            ]
+            writer.writerow(headers)
+            for ped in pedimentos:
+                for cove in Cove.objects.filter(pedimento=ped):
+                    writer.writerow([
+                        ped.aduana, ped.patente, ped.regimen, ped.pedimento, ped.pedimento_app,
+                        ped.clave_pedimento, ped.tipo_operacion_id, ped.contribuyente_id,
+                        'COVE', cove.numero_cove, cove.cove_descargado, cove.acuse_cove_descargado
+                    ])
+                for edoc in EDocument.objects.filter(pedimento=ped):
+                    writer.writerow([
+                        ped.aduana, ped.patente, ped.regimen, ped.pedimento, ped.pedimento_app,
+                        ped.clave_pedimento, ped.tipo_operacion_id, ped.contribuyente_id,
+                        'EDOC', edoc.numero_edocument, edoc.edocument_descargado, edoc.acuse_descargado
+                    ])
+                for partida in Partida.objects.filter(pedimento=ped):
+                    writer.writerow([
+                        ped.aduana, ped.patente, ped.regimen, ped.pedimento, ped.pedimento_app,
+                        ped.clave_pedimento, ped.tipo_operacion_id, ped.contribuyente_id,
+                        'PARTIDA', partida.numero_partida, partida.descargado, ''
+                    ])
+        # Guardar el archivo en el modelo
+        with open(file_path, 'rb') as f:
+            report.file.save(filename, ContentFile(f.read()), save=True)
+        report.status = 'ready'
+        report.finished_at = timezone.now()
+        report.save(update_fields=['status', 'file', 'finished_at'])
+    except Exception as e:
+        report.status = 'error'
+        report.error_message = str(e)
+        report.finished_at = timezone.now()
+        report.save(update_fields=['status', 'error_message', 'finished_at'])

api/reports/urls.py

@@ -1,12 +1,14 @@
 from django.urls import path, include
 from .views import ExportModelView, dashboard_summary
 # from .views_stats import documentos_por_fecha
-# from .views_table import table_summary
+from .views_table import table_summary, report_document_status, report_document_list, report_document_download
 
 urlpatterns = [
     path('exportmodel/', ExportModelView.as_view(), name='export-model'),
     path('dashboard/summary/', dashboard_summary, name='dashboard-summary'),
     #path('documentos-por-fecha/', documentos_por_fecha, name='documentos-por-fecha'),
-    #path('table-summary/', table_summary, name='table-summary'),
-
+    path('table-summary/', table_summary, name='table-summary'),
+    path('report-document-status/<int:report_id>/', report_document_status, name='report_document_status'),
+    path('report-document-list/', report_document_list, name='report_document_list'),
+    path('report-document-download/<int:report_id>/', report_document_download, name='report_document_download'),
 ]

api/reports/views_table.py

@@ -1,27 +1,19 @@
+from api.reports.models import ReportDocument
+from api.reports.tasks.report_document import generate_report_document
+from django.http import FileResponse
 from rest_framework.decorators import api_view, permission_classes
 from rest_framework.permissions import IsAuthenticated
 from rest_framework.response import Response
-from rest_framework.pagination import PageNumberPagination
-from django.db.models import Value, CharField, Q, Exists, OuterRef, Subquery
-from django.db.models.functions import Cast
-from datetime import datetime, timedelta
-from api.customs.models import Pedimento, Cove, EDocument, Partida
-
-class CustomPagination(PageNumberPagination):
-    page_size = 50
-    page_size_query_param = 'page_size'
-    max_page_size = 1000
 
 @api_view(['GET'])
 @permission_classes([IsAuthenticated])
 def table_summary(request):
     """
-    Endpoint que devuelve un resumen tabulado de pedimentos y sus documentos asociados.
+    Solo dispara la tarea asíncrona para generar el reporte CSV. No consulta ni procesa datos.
     """
     org_id = request.query_params.get('organizacion_id')
     if not org_id:
         return Response({"error": "organizacion_id es requerido"}, status=400)
-
     # Obtener filtros de query params
     tipo_documento = request.query_params.get('tipo_documento')
     rfc = request.query_params.get('contribuyente__rfc')
@@ -33,137 +25,93 @@ def table_summary(request):
     pedimento_app = request.query_params.get('pedimento_app')
     regimen = request.query_params.get('regimen')
     tipo_operacion = request.query_params.get('tipo_operacion')
-
-    # Si no se proporcionan fechas, establecer un rango por defecto de los últimos 30 días
-    if not fecha_pago_gte and not fecha_pago_lte:
-        fecha_pago_lte = datetime.now().date()
-        fecha_pago_gte = fecha_pago_lte - timedelta(days=30)
-
-    # Construir filtros base para pedimentos
-    pedimentos_filters = Q(organizacion_id=org_id)
-    
-    # Añadir filtros de fecha siempre para limitar el conjunto de datos
-    pedimentos_filters &= Q(fecha_pago__gte=fecha_pago_gte)
-    pedimentos_filters &= Q(fecha_pago__lte=fecha_pago_lte)
-    
-    if rfc:
-        pedimentos_filters &= Q(contribuyente__rfc=rfc)
-    if patente:
-        pedimentos_filters &= Q(patente=patente)
-    if aduana:
-        pedimentos_filters &= Q(aduana=aduana)
-    if pedimento:
-        pedimentos_filters &= Q(pedimento=pedimento)
-    if pedimento_app:
-        pedimentos_filters &= Q(pedimento_app=pedimento_app)
-    if regimen:
-        pedimentos_filters &= Q(regimen=regimen)
-    if tipo_operacion:
-        pedimentos_filters &= Q(tipo_operacion_id=tipo_operacion)
-
-    # Query base desde pedimentos con todas las subconsultas necesarias
-    resultado = Pedimento.objects.filter(pedimentos_filters).values(
-        'aduana',
-        'patente',
-        'regimen',
-        'pedimento',
-        'pedimento_app',
-        'clave_pedimento',
-        'tipo_operacion_id',
-        'contribuyente_id'
+    filename_param = request.query_params.get('filename')
+    if filename_param:
+        filename = filename_param
+    else:
+        filename = None
+    # Si no se proporcionan fechas, no las incluyas en los filtros
+    if not fecha_pago_gte:
+        fecha_pago_gte_str = None
+    elif isinstance(fecha_pago_gte, str):
+        fecha_pago_gte_str = fecha_pago_gte
+    else:
+        fecha_pago_gte_str = fecha_pago_gte.isoformat()
+    if not fecha_pago_lte:
+        fecha_pago_lte_str = None
+    elif isinstance(fecha_pago_lte, str):
+        fecha_pago_lte_str = fecha_pago_lte
+    else:
+        fecha_pago_lte_str = fecha_pago_lte.isoformat()
+    filtros = {
+        "organizacion_id": org_id,
+        "tipo_documento": tipo_documento,
+        "contribuyente__rfc": rfc,
+        "fecha_pago__gte": fecha_pago_gte_str,
+        "fecha_pago__lte": fecha_pago_lte_str,
+        "patente": patente,
+        "aduana": aduana,
+        "pedimento": pedimento,
+        "pedimento_app": pedimento_app,
+        "regimen": regimen,
+        "tipo_operacion": tipo_operacion,
+        "filename": filename
+    }
+    report = ReportDocument.objects.create(
+        user=request.user,
+        filters=filtros,
+        status='pending'
     )
+    generate_report_document.delay(report.id)
+    return Response({
+        "report_id": report.id,
+        "status": report.status,
+        "created_at": report.created_at,
+        "download_url": report.file.url if report.file else None
+    }, status=202)
 
-    # Generar queries según el tipo de documento solicitado
-    queries = []
-    
-    if not tipo_documento or tipo_documento == 'ACUSE COVE':
-        coves_acuse = resultado.annotate(
-            identificador=Cast(Subquery(
-                Cove.objects.filter(pedimento_id=OuterRef('id')).values('numero_cove')[:1]
-            ), CharField()),
-            documento=Value('ACUSE COVE', CharField()),
-            estado=Cast(Subquery(
-                Cove.objects.filter(pedimento_id=OuterRef('id')).values('acuse_cove_descargado')[:1]
-            ), CharField())
-        ).filter(identificador__isnull=False)
-        queries.append(coves_acuse)
-
-    if not tipo_documento or tipo_documento == 'COVE':
-        coves = resultado.annotate(
-            identificador=Cast(Subquery(
-                Cove.objects.filter(pedimento_id=OuterRef('id')).values('numero_cove')[:1]
-            ), CharField()),
-            documento=Value('COVE', CharField()),
-            estado=Cast(Subquery(
-                Cove.objects.filter(pedimento_id=OuterRef('id')).values('cove_descargado')[:1]
-            ), CharField())
-        ).filter(identificador__isnull=False)
-        queries.append(coves)
-
-    if not tipo_documento or tipo_documento == 'ACUSE EDOC':
-        edocs_acuse = resultado.annotate(
-            identificador=Cast(Subquery(
-                EDocument.objects.filter(pedimento_id=OuterRef('id')).values('numero_edocument')[:1]
-            ), CharField()),
-            documento=Value('ACUSE EDOC', CharField()),
-            estado=Cast(Subquery(
-                EDocument.objects.filter(pedimento_id=OuterRef('id')).values('acuse_descargado')[:1]
-            ), CharField())
-        ).filter(identificador__isnull=False)
-        queries.append(edocs_acuse)
-
-    if not tipo_documento or tipo_documento == 'EDOC':
-        edocs = resultado.annotate(
-            identificador=Cast(Subquery(
-                EDocument.objects.filter(pedimento_id=OuterRef('id')).values('numero_edocument')[:1]
-            ), CharField()),
-            documento=Value('EDOC', CharField()),
-            estado=Cast(Subquery(
-                EDocument.objects.filter(pedimento_id=OuterRef('id')).values('edocument_descargado')[:1]
-            ), CharField())
-        ).filter(identificador__isnull=False)
-        queries.append(edocs)
-
-    if not tipo_documento or tipo_documento == 'PARTIDA':
-        partidas = resultado.annotate(
-            identificador=Cast(Subquery(
-                Partida.objects.filter(pedimento_id=OuterRef('id')).values('numero_partida')[:1]
-            ), CharField()),
-            documento=Value('PARTIDA', CharField()),
-            estado=Cast(Subquery(
-                Partida.objects.filter(pedimento_id=OuterRef('id')).values('descargado')[:1]
-            ), CharField())
-        ).filter(identificador__isnull=False)
-        queries.append(partidas)
-
-    # Unir los resultados usando UNION ALL para mejor rendimiento
-    if not queries:
-        return Response([])
-    
-    resultado_final = queries[0]
-    for query in queries[1:]:
-        resultado_final = resultado_final.union(query, all=True)
-
-    # Aplicar paginación
-    paginator = CustomPagination()
-    page = paginator.paginate_queryset(
-        resultado_final.order_by('pedimento', 'documento'), 
-        request
-    )
-
-    return paginator.get_paginated_response({
-        "results": page,
-        "filtros_aplicados": {
-            "organizacion_id": org_id,
-            "tipo_documento": tipo_documento,
-            "contribuyente__rfc": rfc,
-            "fecha_pago__gte": fecha_pago_gte,
-            "fecha_pago__lte": fecha_pago_lte,
-            "patente": patente,
-            "aduana": aduana,
-            "pedimento": pedimento,
-            "pedimento_app": pedimento_app,
-            "regimen": regimen,
-            "tipo_operacion": tipo_operacion
+@api_view(['GET'])
+@permission_classes([IsAuthenticated])
+def report_document_status(request, report_id):
+    try:
+        report = ReportDocument.objects.get(id=report_id, user=request.user)
+        data = {
+            "report_id": report.id,
+            "status": report.status,
+            "created_at": report.created_at,
+            "finished_at": report.finished_at,
+            "error_message": report.error_message,
+            "download_url": report.file.url if report.file else None
         }
-    })
+        return Response(data)
+    except ReportDocument.DoesNotExist:
+        return Response({"error": "Reporte no encontrado"}, status=404)
+
+@api_view(['GET'])
+@permission_classes([IsAuthenticated])
+def report_document_list(request):
+    reports = ReportDocument.objects.filter(user=request.user).order_by('-created_at')
+    data = [
+        {
+            "report_id": r.id,
+            "status": r.status,
+            "created_at": r.created_at,
+            "finished_at": r.finished_at,
+            "error_message": r.error_message,
+            "download_url": r.file.url if r.file else None
+        }
+        for r in reports
+    ]
+    return Response(data)
+
+@api_view(['GET'])
+@permission_classes([IsAuthenticated])
+def report_document_download(request, report_id):
+    try:
+        report = ReportDocument.objects.get(id=report_id, user=request.user)
+        if not report.file:
+            return Response({"error": "El archivo aún no está disponible"}, status=404)
+        response = FileResponse(report.file.open('rb'), as_attachment=True, filename=report.file.name)
+        return response
+    except ReportDocument.DoesNotExist:
+        return Response({"error": "Reporte no encontrado"}, status=404)

cleanup_all_media.sh

@@ -1,61 +0,0 @@
-#!/bin/bash
-
-echo "Iniciando limpieza completa de archivos media huérfanos..."
-
-# Función para ejecutar limpieza
-cleanup_batch() {
-    echo "Ejecutando limpieza de lote..."
-    docker exec -it EFC_backend_dev bash -c "cd /app && python manage.py cleanup_media_fast --quick-scan --verbose" 2>/dev/null
-    return $?
-}
-
-# Contador de iteraciones
-iteration=1
-total_cleaned=0
-
-while true; do
-    echo "=== Iteración $iteration ==="
-    
-    # Ejecutar dry-run para ver si hay archivos huérfanos
-    result=$(docker exec -it EFC_backend_dev bash -c "cd /app && python manage.py cleanup_media_fast --quick-scan --dry-run" 2>/dev/null)
-    
-    # Extraer número de archivos huérfanos
-    orphaned_count=$(echo "$result" | grep -o "Archivos huérfanos encontrados: [0-9]*" | grep -o "[0-9]*")
-    
-    if [ -z "$orphaned_count" ] || [ "$orphaned_count" -eq 0 ]; then
-        echo "✅ No se encontraron más archivos huérfanos."
-        echo "🎉 Limpieza completa finalizada después de $iteration iteraciones."
-        echo "📊 Total estimado de archivos eliminados: $total_cleaned"
-        break
-    fi
-    
-    echo "📁 Encontrados $orphaned_count archivos huérfanos en esta iteración"
-    
-    # Preguntar confirmación en la primera iteración
-    if [ $iteration -eq 1 ]; then
-        echo "¿Continuar con la limpieza automática? (s/N):"
-        read -r response
-        if [[ ! "$response" =~ ^[sS]([iI]|í)?$ ]]; then
-            echo "❌ Limpieza cancelada por el usuario."
-            exit 0
-        fi
-    fi
-    
-    # Ejecutar limpieza
-    cleanup_result=$(docker exec -it EFC_backend_dev bash -c "cd /app && echo 's' | python manage.py cleanup_media_fast --quick-scan --verbose" 2>/dev/null)
-    
-    # Extraer archivos eliminados
-    deleted_count=$(echo "$cleanup_result" | grep -o "Eliminados [0-9]* archivos" | grep -o "[0-9]*")
-    
-    if [ -n "$deleted_count" ]; then
-        total_cleaned=$((total_cleaned + deleted_count))
-        echo "✅ Eliminados $deleted_count archivos en esta iteración"
-    fi
-    
-    iteration=$((iteration + 1))
-    
-    # Pausa pequeña para evitar sobrecarga
-    sleep 2
-done
-
-echo "🏁 Proceso completado exitosamente."

config/settings.py

@@ -1,11 +1,5 @@
-# Celery Beat Schedule
-from celery.schedules import crontab
 
 
-CELERY_BEAT_SCHEDULE = {
-
-
-}
 """
 Django settings for config project.
 
@@ -31,6 +25,14 @@ smtplib.SMTP_SSL.default_context = ssl._create_unverified_context
 from dotenv import load_dotenv
 import re
 
+# Celery Beat Schedule
+from celery.schedules import crontab
+
+CELERY_BEAT_SCHEDULE = {
+
+
+}
+
 # Cargar variables de entorno desde un archivo .env
 load_dotenv()
 
@@ -266,7 +268,7 @@ AUTH_PASSWORD_VALIDATORS = [
 
 # Internationalization
 LANGUAGE_CODE = 'en-us'
-TIME_ZONE = 'America/Ojinaga'  # Zona horaria de Cd. Juárez, Chihuahua
+TIME_ZONE = 'America/Mexico_City' # Zona horaria de Cd. Juárez, Chihuahua
 USE_I18N = True
 USE_TZ = True
 

docs/Insomnia_2025-10-22.yaml

@@ -0,0 +1,577 @@
+type: collection.insomnia.rest/5.0
+name: EFC
+meta:
+  id: wrk_71a7fc7f009b45338f10d5aee912e90c
+  created: 1759368209169
+  modified: 1759415563572
+  description: ""
+collection:
+  - url: "{{ _.API_REST
+      }}customs/coves/?pedimento=7e199074-db14-4431-8ded-2028dcd7ba23&page=1&pa\
+      ge_size=10"
+    name: Coves
+    meta:
+      id: req_a90087be376f42eb846e9c0a080c1e0d
+      created: 1759368209176
+      modified: 1759368596683
+      isPrivate: false
+      description: ""
+      sortKey: -1759368209176
+    method: GET
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST
+      }}customs/edocuments/?pedimento=7e199074-db14-4431-8ded-2028dcd7ba23&page\
+      =1&page_size=10"
+    name: EDocs
+    meta:
+      id: req_40ed26a5256d49f0bfe05716237131dd
+      created: 1759368603480
+      modified: 1759368614527
+      isPrivate: false
+      description: ""
+      sortKey: -1759285093434.5
+    method: GET
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST
+      }}customs/procesamientopedimentos/?pedimento=7e199074-db14-4431-8ded-2028\
+      dcd7ba23&page=1&page_size=10"
+    name: Procesamientos del Pedimento
+    meta:
+      id: req_bba2280f3e894ada879b734a24c78414
+      created: 1759368715006
+      modified: 1759368736956
+      isPrivate: false
+      description: ""
+      sortKey: -1759243535563.75
+    method: GET
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: http://192.168.1.79:8000/api/v1/customs/partidas/?pedimento=5ed0a19a-8a42-4ab4-8627-1a614be7aee3
+    name: New Request
+    meta:
+      id: req_680b0285689f46d99857ca2765a36e30
+      created: 1759457224319
+      modified: 1759717890407
+      isPrivate: false
+      description: ""
+      sortKey: -1759457224319
+    method: GET
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_ea89b2c93a934f72ab8183aa7bcddfb3
+      - id: pair_be239987c9a648debc7c318ab3d9edd4
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}customs/partidas/771281/"
+    name: Partida
+    meta:
+      id: req_c911fa79111e45fc9d592a4dff98889a
+      created: 1759521825542
+      modified: 1759522450563
+      isPrivate: false
+      description: ""
+      sortKey: -1759326651305.25
+    method: PUT
+    body:
+      mimeType: application/json
+      text: "{
+
+        \t\"id\": 771281,
+
+        \t\"numero_partida\": 1,
+
+        \t\"descargado\": true,
+
+        \t\"pedimento\": \"0731973d-3929-43f5-805b-a8680fbadd30\",
+
+        \t\"organizacion\": \"4fea91c7-4a1d-40b3-a433-f0122b5ea43e\"
+
+        }
+
+        \t"
+    headers:
+      - name: Content-Type
+        value: application/json
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}vucem/vucem/?importador={{pedimento.contribuyente_id}}"
+    name: Vucem
+    meta:
+      id: req_4b049e9b11844f158762682b9118e572
+      created: 1759523330397
+      modified: 1759523405870
+      isPrivate: false
+      description: ""
+      sortKey: -1759264314499.125
+    method: GET
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}reports/dashboard/summary/"
+    name: dashboard_summary
+    meta:
+      id: req_0d68721909b54ae983f31f91c8acdd4c
+      created: 1759623976466
+      modified: 1759710185608
+      isPrivate: false
+      description: ""
+      sortKey: -1759253925031.4375
+    method: GET
+    parameters:
+      - id: pair_9805d9f69b664b9d903fd142a6a940fb
+        name: pedimento_app
+        value: 20-16-3910-1000
+        description: ""
+        disabled: false
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}reports/documentos-por-fecha/"
+    name: Documentos por fecha
+    meta:
+      id: req_733c9cae6cbe4ccca8ccebe2efa5c3ba
+      created: 1759628575231
+      modified: 1759634973470
+      isPrivate: false
+      description: ""
+      sortKey: -1759248730297.5938
+    method: GET
+    parameters:
+      - id: pair_ec4119b532f94b579dfc54ddc2ed8979
+        name: periodo
+        value: semana
+        description: ""
+        disabled: false
+      - id: pair_d10e813bf42a45038907b3658df2dbeb
+        name: start_date
+        value: 2010-01-01
+        description: ""
+        disabled: false
+      - id: pair_3ab5417081e34862b9d3cc80b7125432
+        name: end_date
+        value: 2026-01-01
+        description: ""
+        disabled: false
+      - id: pair_74805c59d3704db3893d424e6580110a
+        name: organizacion_id
+        value: 9d705e97-d3f2-4b6c-8d92-9f1af2b2d4b4
+        description: ""
+        disabled: false
+      - id: pair_fb9f6ce9c82f4db8834b6443f3fcea44
+        name: tipo_documento
+        value: "1"
+        description: ""
+        disabled: false
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}reports/table-summary/"
+    name: Summary Table
+    meta:
+      id: req_259a849b4a8e4a34b85f53644e7d5939
+      created: 1759634983441
+      modified: 1761103843982
+      isPrivate: false
+      description: ""
+      sortKey: -1759251327664.5156
+    method: GET
+    parameters:
+      - id: pair_320fbf127da544acae95eb8524daa1db
+        name: csv_async
+        value: "1"
+        description: ""
+        disabled: false
+      - id: pair_99f1f48e9db0439a950c706d5767657c
+        name: organizacion_id
+        value: 9d705e97-d3f2-4b6c-8d92-9f1af2b2d4b4
+        description: ""
+        disabled: false
+      - id: pair_8900c16ca9894ac8b559284dde8feca8
+        name: page
+        value: "1"
+        description: ""
+        disabled: true
+      - id: pair_9d3852c3e1bb4dd6b6ea838df070a65d
+        name: page_size
+        value: "100"
+        description: ""
+        disabled: true
+      - id: pair_7ea23e87e0874588bf4d17041eaaa3c6
+        name: fecha_pago__lte
+        value: 2024-01-01
+        description: ""
+        disabled: true
+      - id: pair_a3c85e2563d24ec0ba772a2f6e27804a
+        name: ultimos
+        value: "1"
+        description: ""
+        disabled: true
+      - id: pair_e013d47373884f99b3f4def8592b2f01
+        name: filename
+        value: test_kevin
+        description: ""
+        disabled: true
+      - id: pair_9ff11357a7044e5b8f40bb9bb33e6e12
+        name: contribuyente__rfc
+        value: TEC1406248Q2
+        description: ""
+        disabled: false
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}customs/pedimentos/"
+    name: Pedimento
+    meta:
+      id: req_9a679fe2a36b42949200a0cc93e7cc76
+      created: 1759717886641
+      modified: 1759718950361
+      isPrivate: false
+      description: ""
+      sortKey: -1759717886641
+    method: POST
+    body:
+      mimeType: application/json
+      text: |-
+        {
+          "pedimento": "946",
+          "patente": "3910",
+          "aduana": "160",
+          "regimen": "ITE",
+          "clave_pedimento": "IN",
+          "fecha_inicio": "2025-08-07",
+          "fecha_fin": "2025-08-07",
+          "fecha_pago": "2020-03-11",
+          "alerta": true,
+          "agente_aduanal": "AAC020726T77",
+          "curp_apoderado": "DAXS571117HNEVXR09",
+          "importe_total": 0.0,
+          "saldo_disponible": 0.0,
+          "importe_pedimento": 0.0,
+          "existe_expediente": true,
+          "remesas": true,
+          "numero_partidas": 0,
+          "numero_operacion": "string",
+          "tipo_operacion": 1,
+          "contribuyente": "TEC1406248Q2",
+        	"organizacion":"9d705e97-d3f2-4b6c-8d92-9f1af2b2d4b4"
+        }
+    headers:
+      - name: Content-Type
+        value: application/json
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_ed0ede3d111d469ea71b9c09f99134df
+      - id: pair_1db698171c6a4534a683351e27b61d9f
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: api.efc-aduanasoft.com/api/v1/customs/auditor/crear-partidas/pedimento/
+    name: Auditor Partidas
+    meta:
+      id: req_82ccc9ebce664984826063dd2e86bbc1
+      created: 1759720753371
+      modified: 1759721186316
+      isPrivate: false
+      description: ""
+      sortKey: -1759619270481.5
+    method: POST
+    body:
+      mimeType: application/json
+      text: |-
+        {
+        	"pedimento_id": "54ed7616-aea9-46ca-887e-3185feb35d09"
+        }
+    headers:
+      - name: Content-Type
+        value: application/json
+        id: pair_5afd216181cd4050a683cc050a15f8af
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_ed0ede3d111d469ea71b9c09f99134df
+      - id: pair_1db698171c6a4534a683351e27b61d9f
+        name: Authorization
+        value: Token 27ad1a1a7a1e7a64e7f452e89265b54b5b3ef4c2
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}reports/report-document-list/"
+    name: Reports List
+    meta:
+      id: req_7a951a204e8b454e81b25c059ad8ff18
+      created: 1761091292956
+      modified: 1761094591411
+      isPrivate: false
+      description: ""
+      sortKey: -1759250028981.0547
+    method: GET
+    parameters:
+      - id: pair_320fbf127da544acae95eb8524daa1db
+        name: csv_async
+        value: "1"
+        description: ""
+        disabled: false
+      - id: pair_99f1f48e9db0439a950c706d5767657c
+        name: organizacion_id
+        value: 9d705e97-d3f2-4b6c-8d92-9f1af2b2d4b4
+        description: ""
+        disabled: false
+      - id: pair_8900c16ca9894ac8b559284dde8feca8
+        name: page
+        value: "1"
+        description: ""
+        disabled: true
+      - id: pair_9d3852c3e1bb4dd6b6ea838df070a65d
+        name: page_size
+        value: "100"
+        description: ""
+        disabled: true
+      - id: pair_7ea23e87e0874588bf4d17041eaaa3c6
+        name: fecha_pago__lte
+        value: 2024-01-01
+        description: ""
+        disabled: false
+      - id: pair_a3c85e2563d24ec0ba772a2f6e27804a
+        name: ultimos
+        value: "1"
+        description: ""
+        disabled: true
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+  - url: "{{ _.API_REST }}reports/report-document-download/11/"
+    name: Download Report
+    meta:
+      id: req_11dc9145994b43798c69ee3ecebe8ba8
+      created: 1761092998357
+      modified: 1761093919398
+      isPrivate: false
+      description: ""
+      sortKey: -1759249379639.3242
+    method: GET
+    parameters:
+      - id: pair_320fbf127da544acae95eb8524daa1db
+        name: csv_async
+        value: "1"
+        description: ""
+        disabled: false
+      - id: pair_99f1f48e9db0439a950c706d5767657c
+        name: organizacion_id
+        value: 9d705e97-d3f2-4b6c-8d92-9f1af2b2d4b4
+        description: ""
+        disabled: false
+      - id: pair_8900c16ca9894ac8b559284dde8feca8
+        name: page
+        value: "1"
+        description: ""
+        disabled: true
+      - id: pair_9d3852c3e1bb4dd6b6ea838df070a65d
+        name: page_size
+        value: "100"
+        description: ""
+        disabled: true
+      - id: pair_7ea23e87e0874588bf4d17041eaaa3c6
+        name: fecha_pago__lte
+        value: 2024-01-01
+        description: ""
+        disabled: false
+      - id: pair_a3c85e2563d24ec0ba772a2f6e27804a
+        name: ultimos
+        value: "1"
+        description: ""
+        disabled: false
+      - id: pair_ab1873fdc82f4b8d898a5f0004cae1fe
+        name: "rfc "
+        value: MTK861014317
+        description: ""
+        disabled: false
+    headers:
+      - name: User-Agent
+        value: insomnia/11.6.1
+        id: pair_586f587a78b540bd9f69c70966a3b12c
+      - id: pair_14420e46d71e4aa98a60238d96b520b3
+        name: Authorization
+        value: Token {{ _.Token }}
+        description: ""
+        disabled: false
+    settings:
+      renderRequestBody: true
+      encodeUrl: true
+      followRedirects: global
+      cookies:
+        send: true
+        store: true
+      rebuildPath: true
+cookieJar:
+  name: Default Jar
+  meta:
+    id: jar_7ef8f609d3e9f73da7feb30ab71eb8baaaf31c81
+    created: 1759368209171
+    modified: 1759368209171
+environments:
+  name: Base Environment
+  meta:
+    id: env_7ef8f609d3e9f73da7feb30ab71eb8baaaf31c81
+    created: 1759368209170
+    modified: 1759719172699
+    isPrivate: false
+  data:
+    API_REST: http://192.168.1.79:8000/api/v1/
+    Token: 27ad1a1a7a1e7a64e7f452e89265b54b5b3ef4c2

docs/commands/README_microservicios.md

@@ -0,0 +1,52 @@
+# Comando de Microservicios
+
+Este comando permite disparar tareas de procesamiento masivo por organización o por pedimento en el sistema EFC.
+
+## Uso básico
+
+```bash
+python manage.py microservicios [--organizacion_id=<id>] [--procesamiento=<tipo>] [--todos]
+```
+
+## Opciones
+
+- `--organizacion_id <id>`: Ejecuta los procesamientos solo para la organización indicada. Si se omite, se procesan todas las organizaciones.
+- `--procesamiento <tipo>`: Ejecuta solo el tipo de procesamiento indicado para la organización. Si se omite, se ejecutan todos los procesamientos.
+- `--todos`: Ejecuta todos los procesos para todas las organizaciones.
+
+## Tipos de procesamiento disponibles
+
+- `coves`: Procesa COVEs por organización/pedimento
+- `edocs`: Procesa E-Documents por organización/pedimento
+- `acuses`: Procesa acuses por organización/pedimento
+- `acuse_coves`: Procesa acuse de COVEs por organización/pedimento
+- `partidas`: Procesa partidas por organización/pedimento
+- `pedimentos_completos`: Procesa pedimentos completos por organización/pedimento
+- `remesas`: Procesa remesas por organización/pedimento
+
+## Ejemplos
+
+### Procesar todos los tipos para todas las organizaciones
+```bash
+python manage.py microservicios --todos
+```
+
+### Procesar solo COVEs para una organización
+```bash
+python manage.py microservicios --organizacion_id=ID_ORG --procesamiento=coves
+```
+
+### Procesar todos los tipos para una organización
+```bash
+python manage.py microservicios --organizacion_id=ID_ORG
+```
+
+### Procesar todos los tipos para un pedimento específico
+```bash
+python manage.py microservicios --pedimento_id=ID_PEDIMENTO
+```
+
+## Notas
+- El comando dispara las tareas de Celery de forma asíncrona.
+- Revisa los logs y el estado de las tareas en el panel de administración de Celery o en los logs del sistema.
+- Si agregas nuevos tipos de procesamiento, actualiza la función `ejecutar_procesamiento_por_organizacion` en `microservice_v2.py`.