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

.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/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/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/customs/views.py

@@ -23,7 +23,7 @@ from api.customs.models import (
     EDocument,
     Cove,
     Importador,
-    Partida
+    Partida,
 )
 from api.customs.serializers import (
     PedimentoSerializer,
@@ -44,11 +44,11 @@ import zipfile
 import tempfile
 import shutil
 import subprocess
-from datetime import datetime
+from datetime import date, datetime
 from django.core.files.base import ContentFile
 from django.db import transaction
 from rest_framework.parsers import MultiPartParser, FormParser
-from api.record.models import Document, DocumentType
+from api.record.models import Document, DocumentType, Fuente
 
 # Importar rarfile de manera opcional
 try:
@@ -57,6 +57,25 @@ try:
 except ImportError:
     RAR_SUPPORT = False
 
+# Importar tarea de procesamiento de pedimento (Celery)
+from api.customs.tasks.microservice import procesar_pedimento_completo_individual
+
+def get_available_extractors():
+    """
+    Devuelve lista de extractores disponibles en orden de preferencia
+    """
+    extractors = []
+    if RAR_SUPPORT:
+        extractors.append('rarfile')
+    # Verificar si 'unrar' está disponible
+    if shutil.which('unrar'):
+        extractors.append('unrar')
+    # Verificar si '7z' o '7za' están disponibles
+    if shutil.which('7z'):
+        extractors.append('7z')
+    elif shutil.which('7za'):
+        extractors.append('7za')
+    return extractors
 
 def extract_rar_to_dir(rar_path, dest_dir):
     """
@@ -67,12 +86,29 @@ def extract_rar_to_dir(rar_path, dest_dir):
 
     Lanza Exception con mensaje explicativo si falla.
     """
-    # Intento con rarfile (Python)
+
-    if RAR_SUPPORT:
+    # Versión que primero verifica herramientas disponibles
+    available = get_available_extractors()
+    if not available:
+        raise Exception("No hay herramientas de extracción disponibles.")
+
+    print(f"Extractores disponibles (en orden de preferencia): {available}")
+
+    # Intento con rarfile primero si está disponible
+    # if RAR_SUPPORT:
+    if 'rarfile' in available and RAR_SUPPORT:
         try:
             # rarfile puede trabajar con rutas en disco mejor que con file-like
             with rarfile.RarFile(rar_path) as rf:
                 rf.extractall(dest_dir)
+
+                try:
+                    if os.path.exists(rar_path):
+                        os.remove(rar_path)
+                        print(f"Archivo original eliminado: {rar_path}")
+                except OSError as remove_error:
+                    print(f"Advertencia: No se pudo eliminar '{rar_path}': {remove_error}")
+
             return
         except Exception as e:
             # Si rarfile falla (por ejemplo RarCannotExec), seguimos con herramientas externas
@@ -87,18 +123,49 @@ def extract_rar_to_dir(rar_path, dest_dir):
         ['7za', 'x', rar_path, f'-o{dest_dir}', '-y']
     ]
 
-    for cmd in external_cmds:
+    # for cmd in external_cmds:
-        try:
+    #     try:
-            subprocess.run(cmd, check=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+    #         subprocess.run(cmd, check=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-            return
+
-        except FileNotFoundError:
+    #         try:
-            # El ejecutable no existe en PATH, intentar siguiente
+    #             if os.path.exists(rar_path):
-            continue
+    #                 os.remove(rar_path)
-        except subprocess.CalledProcessError as e:
+    #                 print(f"Archivo original eliminado: {rar_path}")
-            # El comando falló en la extracción; intentar siguiente
+    #         except OSError as remove_error:
-            print(f"External extractor failed ({cmd[0]}): {e}")
+    #             print(f"Advertencia: No se pudo eliminar '{rar_path}': {remove_error}")
+
+    #         return
+    #     except FileNotFoundError:
+    #         # El ejecutable no existe en PATH, intentar siguiente
+    #         continue
+    #     except subprocess.CalledProcessError as e:
+    #         # El comando falló en la extracción; intentar siguiente
+    #         print(f"External extractor failed ({cmd[0]}): {e}")
+    #         continue
+    
+    for extractor_name in available:
+        if extractor_name in external_cmds:
+            cmd = external_cmds[extractor_name]
+            try:
+                subprocess.run(cmd, check=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+                
+                try:
+                    if os.path.exists(rar_path):
+                        os.remove(rar_path)
+                        print(f"Archivo original eliminado: {rar_path}")
+                except OSError as remove_error:
+                    print(f"Advertencia: No se pudo eliminar '{rar_path}': {remove_error}")
+
+                return
+            except FileNotFoundError:
+                # El ejecutable no existe en PATH, intentar siguiente
+                continue
+            except subprocess.CalledProcessError as e:
+                # El comando falló en la extracción; intentar siguiente
+                print(f"External extractor {extractor_name} failed ({cmd[0]}): {e}")
             continue
 
+    # Si llegamos aquí, ningún método funcionó
     raise Exception("No se encontró una herramienta válida para extraer RAR (rarfile sin backend, 'unrar' o '7z' no disponibles o extracción fallida). Instale 'unrar' o 'p7zip' y asegúrese de que estén en PATH, o configure rarfile con un backend.")
 
 from .tasks.microservice_v2 import *
@@ -212,9 +279,21 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
 
     filterset_fields = ['patente', 'aduana', 'tipo_operacion', 'clave_pedimento', 'pedimento', 'existe_expediente', 'contribuyente', 'curp_apoderado', 'fecha_pago', 'pedimento_app']
     search_fields = ['pedimento', 'pedimento_app', 'agente_aduanal', 'clave_pedimento']
-    
+    # AGREGAR ESTOS CAMPOS PARA ORDENACIÓN
+    ordering_fields = ['created_at', 'pedimento', 'fecha_pago', 'aduana', 'patente']
+    ordering = ['-created_at']  # Orden descendente por fecha de creación por defecto
+
     def get_queryset(self):
-        return self.get_queryset_filtrado_por_organizacion() # Tambien filtra por importador
+        
+        queryset = self.get_queryset_filtrado_por_organizacion() # Tambien filtra por importador
+
+        # pedimento_app_filter = self.request.GET.get('pedimento_app', None)
+
+        # if pedimento_app_filter:
+        #     print(f"Filtro por pedimento_app: {pedimento_app_filter}")
+        #     queryset = queryset.filter(pedimento_app__icontains=pedimento_app_filter)
+
+        return queryset 
 
     def perform_create(self, serializer):
         """
@@ -293,6 +372,25 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
                 ]
             }
 
+    @action(detail=True, methods=['post'], url_path='procesar-completo')
+    def procesar_completo(self, request, pk=None):
+        """
+        Acción para disparar el procesamiento completo de un pedimento existente.
+        Dispara la tarea `procesar_pedimento_completo_individual` de forma asíncrona
+        y devuelve el `task_id`.
+        """
+        pedimento = self.get_object()
+        try:
+           # Usar el nombre del servicio de Docker Compose en lugar de localhost
+            task = procesar_pedimento_completo_individual.delay(pedimento.id, pedimento.organizacion.id)
+            # Verificar si la respuesta fue exitosa
+            if task.id:
+                return Response({"status": "Recurso creado exitosamente en API", "task_id": task.id}, status=status.HTTP_202_ACCEPTED)
+            else:
+                return Response({"status": "Servicio API respondió con error", "task_id": 0}, status=status.HTTP_202_ACCEPTED)
+        except Exception as e:
+            return Response({"error": f"Error inesperado al llamar al servicio API: {str(e)}"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
     @action(detail=False, methods=['post'], url_path='bulk-delete')
     def bulk_delete(self, request):
         """
@@ -444,6 +542,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
         
         # Regex para validar nomenclatura: anio-aduana-patente-pedimento
         nomenclatura_pattern = re.compile(r'^(\d{2})-(\d{2,3})-(\d{4})-(\d{7})$')
+        nomenclatura_pattern_sin_anio = re.compile(r'^(\d{2,3})-(\d{4})-(\d{7})$')
         
         created_pedimentos = []
         failed_files = []
@@ -591,7 +690,9 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
                         
                         # Validar nomenclatura
                         match = nomenclatura_pattern.match(folder_name)
-                        if not match:
+                        match_sin_anio = nomenclatura_pattern_sin_anio.match(folder_name)
+                        
+                        if not match and not match_sin_anio:
                             print(f"Nomenclatura inválida: {folder_name}")
                             # Determinar el archivo original basado en el subdirectorio
                             archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
@@ -602,25 +703,60 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
                             })
                             continue
                         
-                        print(f"Nomenclatura válida: {folder_name}")
+                        if match:
-                        anio, aduana, patente, pedimento_num = match.groups()
+
-                        print(f"Extraído - Año: {anio}, Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
+                            print(f"Nomenclatura válida: {folder_name}")
-                        
+                            anio, aduana, patente, pedimento_num = match.groups()
-                        # Crear fecha_pago basada en el año
+                            print(f"Extraído - Año: {anio}, Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
-                        try:
+                            # Formato original: anio-aduana-patente-pedimento
-                            # Convertir año de 2 dígitos a 4 dígitos
+                            # Crear fecha_pago basada en el año
-                            anio_completo = 2000 + int(anio) if int(anio) < 50 else 1900 + int(anio)
+                            try:
-                            fecha_pago = datetime(anio_completo, 1, 1).date()
+                                # Convertir año de 2 dígitos a 4 dígitos
-                            print(f"Fecha de pago calculada: {fecha_pago}")
+                                anio_completo = 2000 + int(anio) if int(anio) < 50 else 1900 + int(anio)
-                        except ValueError:
+                                fecha_pago = datetime(anio_completo, 1, 1).date()
-                            archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
+                                print(f"Fecha de pago calculada: {fecha_pago}")
-                            failed_files.append({
+                            except ValueError:
-                                "file": relative_path,
+                                archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
-                                "archivo_original": archivo_original,
+                                failed_files.append({
-                                "error": f"Año inválido: {anio}"
+                                    "file": relative_path,
-                            })
+                                    "archivo_original": archivo_original,
-                            continue
+                                    "error": f"Año inválido: {anio}"
+                                })
+                                continue
+
+                        elif match_sin_anio:
+
+                            print(f"Nomenclatura válida sin año: {folder_name}")
                         
+                            # Formato sin año: aduana-patente-pedimento
+                            aduana, patente, pedimento_num = match_sin_anio.groups()
+                            print(f"Extraído - Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
+
+                            # Obtener el primer dígito del pedimento
+                            primer_digito_pedimento = int(pedimento_num[0]) if pedimento_num else 0
+
+                            # Usar año actual para fecha_pago y ajustar según el dígito del pedimento
+                            año_actual  = datetime.now().year
+
+                            # Crear año con el dígito del pedimento (reemplazando el último dígito)
+                            año_con_digito = int(str(año_actual)[:-1] + str(primer_digito_pedimento))
+
+                            # Aplicar lógica de comparación
+                            if año_con_digito <= año_actual:
+                                # Si el año con dígito es menor o igual al año actual
+                                año_final = año_con_digito
+                            else:
+                                # Si el año con dígito es mayor al año actual, restar 10
+                                año_final = año_con_digito - 10
+
+                            # Tomar los últimos 2 dígitos del año final
+                            anio = año_final % 100
+
+                             # Crear fecha de pago (primer día del año)
+                            fecha_pago = datetime(año_final , 1, 1).date()
+
+                            print(f"Fecha de pago (año actual) calculada: {fecha_pago}")     
+
                         # Generar pedimento_app
                         pedimento_app = f"{anio}-{aduana.zfill(2)}-{patente}-{pedimento_num}"
                         print(f"Pedimento_app generado: {pedimento_app}")
@@ -628,7 +764,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
                         # Verificar si el pedimento ya existe
                         existing_pedimento = Pedimento.objects.filter(
                             pedimento_app=pedimento_app,
-                            organizacion=organizacion
+                           # organizacion=organizacion
                         ).first()
 
                         print(f"Pedimento existente: {existing_pedimento is not None}")
@@ -700,12 +836,32 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
                             # Crear ContentFile que Django puede manejar correctamente
                             django_file = ContentFile(file_content, name=file_name)
                             
+                            # # Verificar si el documento ya existe para este pedimento y archivo
+                            # print("🔍 Verificando existencia previa del documento...")
+
+                            # # Reemplazar múltiples caracteres
+                            # normalized_file_name = file_name.replace(" ", "_")
+
+                            # file_name_without_extension = normalized_file_name.rsplit('.', 1)[0]
+                            # extension_file = os.path.splitext(normalized_file_name)[1].lower().lstrip('.')
+
+                            # existing_document = Document.objects.filter(
+                            #     pedimento_id=pedimento.id,
+                            #     archivo__contains=file_name_without_extension,
+                            #     extension=extension_file
+                            # ).first()
+
+                            # if existing_document:
+                            #     print(f"Documento existente encontrado, omitiendo creación: ID {existing_document.id}")
+                            #     continue
+
                             print(f"Creando documento para archivo: {file_name}")
                             # Crear documento - Django automáticamente guardará el archivo en media/documents/
                             document = Document.objects.create(
                                 organizacion=organizacion,
                                 pedimento_id=pedimento.id,
                                 document_type=document_type,
+                                fuente_id=4,  # Fuente: Carga Plataforma
                                 archivo=django_file,
                                 size=len(file_content),
                                 extension=os.path.splitext(file_name)[1].lower().lstrip('.')
@@ -758,6 +914,548 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
         
         return Response(response_data, status=response_status)
 
+    @action(detail=False, methods=['post'], url_path='bulk-create-pedimento_desk', parser_classes=[MultiPartParser, FormParser])
+    def bulk_create_pedimento_desk(self, request):
+        """
+        Endpoint para crear múltiples pedimentos desde EFC APP Desk.
+        
+        FormData esperado:
+        - contribuyente: string (nombre del contribuyente)
+        - archivos: files (pueden ser múltiples archivos: zip, rar o individuales)
+        
+        Nomenclatura esperada de archivos: anio-aduana-patente-pedimento
+        - anio: 2 dígitos (ej: 24)
+        - aduana: 2 o 3 dígitos (ej: 01, 123)
+        - patente: 4 dígitos (ej: 3420)
+        - pedimento: 7 dígitos (ej: 1234567)
+        
+        Ejemplo: 24-01-3420-1234567
+        
+        Nota: Cada archivo ZIP/RAR se procesa independientemente en su propio subdirectorio.
+        
+        Respuesta exitosa:
+        {
+            "message": "Pedimentos creados exitosamente",
+            "created_count": 5,
+            "created_pedimentos": [...],
+            "documents_created": 15,
+            "processed_files": 3,
+            "summary": "Procesados 3 archivo(s): 5 pedimento(s) creado(s), 15 documento(s) asociado(s)",
+            "failed_files": [],
+            "errors": []
+        }
+        """
+        print(request.data)
+        # Validar datos requeridos
+        contribuyente = request.data.get('contribuyente')
+        fecha_pago_input = request.data.get('fecha_pago')
+        clave_pedimento_input = request.data.get('clave_pedimento')
+        patente_input = request.data.get('patente')
+        tipo_operacion_input = request.data.get('tipo_operacion')
+        aduana_input = request.data.get('aduana')
+        contribuyente_input = request.data.get('contribuyente')
+        curp_apoderado_input = request.data.get('curp_apoderado')
+        partidas_input = request.data.get('partidas')
+        fuente_archivos = request.data.get('partidas')
+
+        archivos = request.FILES.getlist('archivos')
+        
+        # if not contribuyente:
+        #     return Response(
+        #         {"error": "Se requiere el campo 'contribuyente'"},
+        #         status=status.HTTP_400_BAD_REQUEST
+        #     )
+        
+        if not archivos:
+            return Response(
+                {
+                    "tieneError": True,
+                    "error": "Se requiere al menos un archivo"
+                },
+                status=status.HTTP_400_BAD_REQUEST
+            )
+        
+        # Validar organización del usuario
+        if not request.user.is_authenticated or not hasattr(request.user, 'organizacion'):
+            return Response(
+                {
+                    "tieneError": True,
+                    "error": "Usuario no autenticado o sin organización"
+                    },
+                status=status.HTTP_400_BAD_REQUEST
+            )
+        
+        organizacion = request.user.organizacion
+        
+        # Regex para validar nomenclatura: anio-aduana-patente-pedimento
+        nomenclatura_pattern = re.compile(r'^(\d{2})-(\d{2,3})-(\d{4})-(\d{7})$')
+        nomenclatura_pattern_sin_anio = re.compile(r'^(\d{2,3})-(\d{4})-(\d{7})$')
+
+        created_pedimentos = []
+        failed_files = []
+        errors = []
+        documents_created = 0
+        temp_dir = None
+        
+        # Obtener DocumentType ANTES de la transacción atómica
+        # print("Intentando obtener o crear DocumentType...")
+        try:
+            # Primero intentar obtener si ya existe
+            try:
+                document_type = DocumentType.objects.get(nombre="Pedimento")
+                # print(f"DocumentType obtenido existente: {document_type.nombre} (ID: {document_type.id})")
+            except DocumentType.DoesNotExist:
+                # Si no existe, crear uno nuevo
+                document_type = DocumentType.objects.create(
+                    nombre="Pedimento",
+                    descripcion="Documento de pedimento"
+                )
+                # print(f"DocumentType creado nuevo: {document_type.nombre} (ID: {document_type.id})")
+                
+        except Exception as e:
+           # print(f"Error al obtener/crear DocumentType: {str(e)}")
+            # Como fallback, intentar obtener cualquier DocumentType existente
+            try:
+                # document_type = DocumentType.objects.first()
+                # if document_type:
+                #     print(f"Usando DocumentType existente como fallback: {document_type.nombre} (ID: {document_type.id})")
+                # else:
+                #     print("No hay DocumentType disponible")
+                #     return Response(
+                #         {"error": "No se pudo configurar el tipo de documento y no hay tipos existentes"},
+                #         status=status.HTTP_500_INTERNAL_SERVER_ERROR
+                #     )
+                document_type = DocumentType.objects.first()
+                if not document_type:
+                    return Response(
+                        {"error": "No se pudo configurar el tipo de documento y no hay tipos existentes"},
+                        status=status.HTTP_500_INTERNAL_SERVER_ERROR
+                    )
+            except Exception as fallback_error:
+                # print(f"Error en fallback: {str(fallback_error)}")
+                return Response(
+                    {
+                        "tieneError": True,
+                        "error": f"Error crítico al configurar tipo de documento: {str(e)}"
+                    },
+                    status=status.HTTP_500_INTERNAL_SERVER_ERROR
+                )
+        
+        try:
+            # print("Iniciando transacción atómica...")
+            with transaction.atomic():
+                # Crear directorio temporal
+                temp_dir = tempfile.mkdtemp()
+                # print(f"Directorio temporal creado: {temp_dir}")
+                
+                # Procesar cada archivo enviado
+                for idx, archivo in enumerate(archivos):
+                    archivo_name = archivo.name.lower()
+                    # print(f"Procesando archivo {idx + 1}/{len(archivos)}: {archivo_name}")
+                    
+                    # Crear subdirectorio para cada archivo usando el nombre del archivo sin extensión
+                    archivo_name_sin_extension = os.path.splitext(archivo.name)[0]
+                    sub_dir = os.path.join(temp_dir, archivo_name_sin_extension)
+                    os.makedirs(sub_dir, exist_ok=True)
+                    # print(f"Subdirectorio creado: {sub_dir}")
+                    
+                    if archivo_name.endswith('.zip'):
+                        # Manejar archivo ZIP
+                        # print("Es un archivo ZIP")
+                        try:
+                            with zipfile.ZipFile(archivo, 'r') as zip_ref:
+                                zip_ref.extractall(sub_dir)
+                            # print("Archivo ZIP extraído exitosamente")
+                        except zipfile.BadZipFile as e:
+                            return Response(
+                                {
+                                    "tieneError": True,
+                                    "error": f"Archivo ZIP corrupto o inválido: {archivo.name} - {str(e)}"
+                                 },
+                                status=status.HTTP_400_BAD_REQUEST
+                            )
+                        except Exception as e:
+                            return Response(
+                                {
+                                    "tieneError": True,
+                                    "error": f"Error al extraer ZIP {archivo.name}: {str(e)}"
+                                },
+                                status=status.HTTP_400_BAD_REQUEST
+                            )
+                    elif archivo_name.endswith('.rar'):
+                        # Manejar archivo RAR: guardar el archivo en disco y usar helper con fallbacks
+                        # Guardar el archivo subido en un path temporal dentro del sub_dir
+                        archivo_temp_path = os.path.join(sub_dir, archivo.name)
+                        with open(archivo_temp_path, 'wb') as f:
+                            for chunk in archivo.chunks():
+                                f.write(chunk)
+                        try:
+                            extract_rar_to_dir(archivo_temp_path, sub_dir)
+                            # print(f"Archivo RAR {archivo.name} extraído en {sub_dir}")
+                        except Exception as e:
+                            error_msg = str(e)
+                            help_msg = "Instale 'unrar' o 'p7zip' (7z) y asegúrese de que estén en PATH, o instale y configure 'rarfile' con un backend."
+                            return Response(
+                                {
+                                    "tieneError": True,
+                                    "error": f"Error al extraer archivo RAR {archivo.name}: {error_msg}. {help_msg}"
+                                },
+                                status=status.HTTP_400_BAD_REQUEST
+                            )
+                    else:
+                        # Asumir que es un archivo individual
+                        # Crear el archivo en el subdirectorio
+                        archivo_path = os.path.join(sub_dir, archivo.name)
+                        with open(archivo_path, 'wb') as f:
+                            for chunk in archivo.chunks():
+                                f.write(chunk)
+                        # print(f"Archivo individual {archivo.name} guardado en sub_dir:", archivo_path)
+                
+                # Recorrer todos los archivos extraídos o el directorio
+                print("Iniciando recorrido de archivos...")
+                for root, dirs, files in os.walk(temp_dir):
+                    # print(f"Revisando directorio: {root}")
+                    # print(f"Archivos encontrados: {files}")
+                    
+                    for file_name in files:
+                        # print(f"Procesando archivo: {file_name}")
+                        file_path = os.path.join(root, file_name)
+                        
+                        # Obtener la ruta relativa para determinar la estructura de carpetas
+                        relative_path = os.path.relpath(file_path, temp_dir)
+                        # print(f"Ruta relativa: {relative_path}")
+                        
+                        # Determinar si el archivo está en una carpeta que sigue la nomenclatura
+                        folder_name = None
+                        if os.path.dirname(relative_path):
+                            # El archivo está dentro de una carpeta
+                            folder_parts = relative_path.split(os.sep)
+                            folder_name = folder_parts[0]  # Primera carpeta (nombre del archivo ZIP/RAR sin extensión)
+                        else:
+                            # El archivo está en la raíz, usar el nombre del archivo sin extensión
+                            folder_name = os.path.splitext(file_name)[0]
+                        
+                        # print(f"Folder name para validación: {folder_name}")
+                        
+                        # Validar nomenclatura
+                        match = nomenclatura_pattern.match(folder_name)
+                        match_sin_anio = nomenclatura_pattern_sin_anio.match(folder_name)
+                        
+                        if not match and not match_sin_anio:
+                            # print(f"Nomenclatura inválida: {folder_name}")
+                            # Determinar el archivo original basado en el subdirectorio
+                            archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
+                            failed_files.append({
+                                "file": relative_path,
+                                "archivo_original": archivo_original,
+                                "error": f"Nomenclatura inválida: {folder_name}. Esperado: anio-aduana-patente-pedimento"
+                            })
+                            continue
+                        
+                        if match:
+
+                            # print(f"Nomenclatura válida: {folder_name}")
+                            anio, aduana, patente, pedimento_num = match.groups()
+                            # print(f"Extraído - Año: {anio}, Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
+                            # Formato original: anio-aduana-patente-pedimento
+                            # Crear fecha_pago basada en el año
+                            try:
+                                # Convertir año de 2 dígitos a 4 dígitos
+                                anio_completo = 2000 + int(anio) if int(anio) < 50 else 1900 + int(anio)
+                                fecha_pago = datetime(anio_completo, 1, 1).date()
+                                # print(f"Fecha de pago calculada: {fecha_pago}")
+                            except ValueError:
+                                archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
+                                failed_files.append({
+                                    "file": relative_path,
+                                    "archivo_original": archivo_original,
+                                    "error": f"Año inválido: {anio}"
+                                })
+                                continue
+
+                        elif match_sin_anio:
+
+                            # print(f"Nomenclatura válida sin año: {folder_name}")
+                        
+                            # Formato sin año: aduana-patente-pedimento
+                            aduana, patente, pedimento_num = match_sin_anio.groups()
+                            # print(f"Extraído - Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
+
+                            # Obtener el primer dígito del pedimento
+                            primer_digito_pedimento = int(pedimento_num[0]) if pedimento_num else 0
+
+                            # Usar año actual para fecha_pago y ajustar según el dígito del pedimento
+                            año_actual  = datetime.now().year
+
+                            # Crear año con el dígito del pedimento (reemplazando el último dígito)
+                            año_con_digito = int(str(año_actual)[:-1] + str(primer_digito_pedimento))
+
+                            # Aplicar lógica de comparación
+                            if año_con_digito <= año_actual:
+                                # Si el año con dígito es menor o igual al año actual
+                                año_final = año_con_digito
+                            else:
+                                # Si el año con dígito es mayor al año actual, restar 10
+                                año_final = año_con_digito - 10
+
+                            # Tomar los últimos 2 dígitos del año final
+                            anio = año_final % 100
+
+                             # Crear fecha de pago (primer día del año)
+                            fecha_pago = datetime(año_final , 1, 1).date()
+
+                            # print(f"Fecha de pago (año actual) calculada: {fecha_pago}")     
+
+                        # Generar pedimento_app
+                        pedimento_app = f"{anio}-{aduana.zfill(2)}-{patente}-{pedimento_num}"
+                        # print(f"Pedimento_app generado: {pedimento_app}")
+                        # print(f"Buscando pedimento existente con pedimento_app: {pedimento_app} y organización ID: {organizacion.id}")
+                        # Verificar si el pedimento ya existe
+                        existing_pedimento = Pedimento.objects.filter(
+                            pedimento=int(pedimento_num),
+                           # pedimento_app=pedimento_app,
+                            organizacion=organizacion
+                        ).first()
+
+                        # print(f"Pedimento existente: {existing_pedimento is not None}")
+                        
+                        if not existing_pedimento:
+                            # print("📝 Pedimento no existe, creando nuevo...")
+                            # Crear nuevo pedimento
+                            try:
+                                # print("🔄 Iniciando creación de pedimento...")
+                                importador = None
+
+                                if contribuyente:
+                                    # Obtener o crear el importador
+                                    # print(f"🏢 Buscando/creando importador con RFC: {contribuyente}")
+                                    importador, created = Importador.objects.get_or_create(
+                                        rfc=contribuyente,
+                                        defaults={
+                                        'nombre': f"Importador {contribuyente}",
+                                        'organizacion': organizacion
+                                        }
+                                    )
+                                    # if created:
+                                    #     print(f"✅ Importador creado: {importador.rfc} - {importador.nombre}")
+                                    # else:
+                                    #     print(f"♻️ Importador existente: {importador.rfc} - {importador.nombre}")
+                                
+                                if tipo_operacion_input:
+                                    tipo_operacion_input = TipoOperacion.objects.get(id=tipo_operacion_input)
+
+
+                                pedimento = Pedimento.objects.create(
+                                    organizacion=organizacion,
+                                    contribuyente=importador if importador else None,
+                                    pedimento=int(pedimento_num),
+                                    aduana=int(aduana),
+                                    patente=int(patente),
+                                    fecha_pago=fecha_pago_input if fecha_pago_input else fecha_pago,
+                                    curp_apoderado=curp_apoderado_input if curp_apoderado_input else "",
+                                    numero_partidas=partidas_input if partidas_input else 0,
+                                    tipo_operacion=tipo_operacion_input if tipo_operacion_input else None, 
+                                    pedimento_app=pedimento_app,
+                                    agente_aduanal=f"Agente {patente}",  # Valor por defecto
+                                    clave_pedimento=clave_pedimento_input if clave_pedimento_input else "A1"  # Valor por defecto
+                                )
+                                
+                                # print(f"✅ Pedimento creado exitosamente: ID {pedimento.id}, pedimento_app: {pedimento_app}")
+                                
+                                created_pedimentos.append({
+                                    "id": str(pedimento.id),
+                                    "pedimento_app": pedimento_app,
+                                    "contribuyente": getattr(importador, 'rfc', None),
+                                    "contribuyente_nombre": getattr(importador, 'nombre', None)
+                                })
+                                
+                            except Exception as e:
+                               # print(f"❌ Error al crear pedimento: {str(e)}")
+                                archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
+                                failed_files.append({
+                                    "file": relative_path,
+                                    "archivo_original": archivo_original,
+                                    "error": f"Error al crear pedimento: {str(e)}"
+                                })
+                                continue
+                        else:
+                           # print(f"♻️ Usando pedimento existente: ID {existing_pedimento.id}")
+                            # Usar pedimento existente
+                            # # Actualizar Importador
+                            if contribuyente:
+                                importador, created = Importador.objects.get_or_create(
+                                    rfc=contribuyente,
+                                    defaults={
+                                        'nombre': f"Importador {contribuyente}",
+                                        'organizacion': organizacion
+                                    }
+                                )
+
+                                importador_db = existing_pedimento.contribuyente
+                                if importador_db:
+                                    if importador_db != importador:
+                                        existing_pedimento.contribuyente = importador
+                                else:
+                                    existing_pedimento.contribuyente = importador
+
+                                existing_pedimento.save()
+                                      
+                            # Actualizar Tipo Operacion
+                            if tipo_operacion_input:
+                                tipo_operacion_input = TipoOperacion.objects.get(id=tipo_operacion_input)
+                                if tipo_operacion_input:
+                                    tipo_operacion_db = existing_pedimento.tipo_operacion
+                                    if not tipo_operacion_db:
+                                        existing_pedimento.tipo_operacion = tipo_operacion_input
+                                        existing_pedimento.save()
+
+                            # Actualizar fecha de pago solo cuando aun no esta actualizado
+                            if fecha_pago_input:
+                                fecha_db = existing_pedimento.fecha_pago
+
+                                # Verificar si hay fecha en BD
+                                if fecha_db:
+                                    # Asegurar que trabajamos con date
+                                    if isinstance(fecha_db, datetime):
+                                        fecha_db = fecha_db.date()
+
+                                    # Si la fecha existe y es 1 de enero, actualizar
+                                    if fecha_db.month == 1 and fecha_db.day == 1:
+                                        # Actualizar Fecha
+                                        existing_pedimento.fecha_pago = fecha_pago_input
+                                        existing_pedimento.save()
+                                else:
+                                    existing_pedimento.fecha_pago = fecha_pago_input
+                                    existing_pedimento.save()
+
+                                
+                            if clave_pedimento_input:
+                                clavePedimento = existing_pedimento.clave_pedimento
+
+                                if not clavePedimento:
+                                    existing_pedimento.clave_pedimento = clave_pedimento_input
+                                    existing_pedimento.save()
+                            
+                            if curp_apoderado_input:
+                                curp = existing_pedimento.curp_apoderado
+                                if not curp:
+                                    existing_pedimento.curp_apoderado = curp_apoderado_input
+                                    existing_pedimento.save()
+
+                            if partidas_input:
+                                numPartidas = existing_pedimento.numero_partidas
+                                if not numPartidas:
+                                    existing_pedimento.numero_partidas = partidas_input
+                                    existing_pedimento.save()
+                                elif numPartidas <= 0:
+                                    existing_pedimento.numero_partidas = partidas_input
+                                    existing_pedimento.save()
+
+                            pedimento = existing_pedimento
+                        
+                        # print(f"🔄 Iniciando creación de documento para pedimento ID: {pedimento.id}")
+                        # Crear documento asociado al pedimento
+                        try:
+                           # print("📖 Leyendo archivo desde directorio temporal...")
+                            # Leer el archivo desde el directorio temporal
+                            with open(file_path, 'rb') as f:
+                                file_content = f.read()
+                            
+                            # print(f"📄 Archivo leído: {len(file_content)} bytes")
+                            # Crear ContentFile que Django puede manejar correctamente
+                            django_file = ContentFile(file_content, name=file_name)
+                            
+                            # # Verificar si el documento ya existe para este pedimento y archivo
+                            # print("🔍 Verificando existencia previa del documento...")
+
+                            # # Reemplazar múltiples caracteres
+                            # normalized_file_name = file_name.replace(" ", "_")
+
+                            # file_name_without_extension = normalized_file_name.rsplit('.', 1)[0]
+                            # extension_file = os.path.splitext(normalized_file_name)[1].lower().lstrip('.')
+
+                            # existing_document = Document.objects.filter(
+                            #     pedimento_id=pedimento.id,
+                            #     archivo__contains=file_name_without_extension,
+                            #     extension=extension_file
+                            # ).first()
+
+                            # if existing_document:
+                            #     print(f"Documento existente encontrado, omitiendo creación: ID {existing_document.id}")
+                            #     continue
+
+                            # try:
+                            #     fuente = Fuente.objects.get(nombre="APP-EFC")
+                            # except Fuente.DoesNotExist:
+                            #     fuente = Fuente.objects.create(
+                            #         nombre="APP-EFC",
+                            #         descripcion='Transmitido por la app de escritorio'
+                            #     )
+
+                            fuente, created  = Fuente.objects.get_or_create(
+                               nombre="APP-EFC",
+                               descripcion='Transmitido por la app de escritorio'
+                            )
+                            
+                            # print(f"Creando documento para archivo: {file_name}")
+                            # Crear documento - Django automáticamente guardará el archivo en media/documents/
+                            document = Document.objects.create(
+                                organizacion=organizacion,
+                                pedimento_id=pedimento.id,
+                                document_type=document_type,
+                                fuente_id=fuente.id,
+                                archivo=django_file,
+                                size=len(file_content),
+                                extension=os.path.splitext(file_name)[1].lower().lstrip('.')
+                            )
+                            # print(f"Documento creado exitosamente: {document.id}")
+                            
+                            documents_created += 1
+                            # print(f"📊 Total documentos creados hasta ahora: {documents_created}")
+                            
+                        except Exception as e:
+                            # print(f"❌ Error al crear documento: {str(e)}")
+                            archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
+                            failed_files.append({
+                                "file": relative_path,
+                                "archivo_original": archivo_original,
+                                "error": f"Error al crear documento: {str(e)}"
+                            })
+                            continue
+                
+                # print(f"🏁 Procesamiento completado. Archivos procesados en este directorio.")
+        except Exception as e:
+            return Response(
+                {   "tieneError": True,
+                    "error": f"Error durante el procesamiento: {str(e)}"
+                },
+                status=status.HTTP_500_INTERNAL_SERVER_ERROR
+            )
+        finally:
+            # Limpiar directorio temporal
+            if temp_dir and os.path.exists(temp_dir):
+                shutil.rmtree(temp_dir)
+        
+        # Preparar respuesta
+        response_data = {
+            "tieneError": False,
+            "failed_files": failed_files,
+            "processed_files": len(archivos),
+        }
+        
+        if failed_files:
+            response_data["tieneError"] = True
+            response_data.update({
+                "message": "Procesamiento completado con algunos errores",
+                "errors": [item["error"] for item in failed_files]
+            })
+            response_status = status.HTTP_207_MULTI_STATUS
+        else:
+            response_data["message"] = "Pedimentos creados exitosamente"
+            response_status = status.HTTP_201_CREATED
+        
+        return Response(response_data, status=response_status)
+
 
     my_tags = ['Pedimentos']
 

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,7 +4,17 @@ 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, ExpedienteZipDownloadView, MultiPedimentoZipDownloadView
+from .views import  (DocumentViewSet
+                     , ProtectedDocumentDownloadView
+                     , BulkDownloadZipView
+                     , GetFuenteView
+                     , DocumentTypeView
+                     , ExpedienteZipDownloadView
+                     , MultiPedimentoZipDownloadView
+                     , PedimentoDocumentViewSet
+                     , TriggerPedimentoCompletoView)
+
+
 # Create a router and register your viewsets with it
 
 router = DefaultRouter()
@@ -25,5 +35,7 @@ urlpatterns = [
     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

@@ -14,6 +14,7 @@ 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
@@ -35,9 +36,91 @@ 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):
 
     """
@@ -63,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
@@ -71,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)
@@ -116,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(
+        try:
-            organizacion=organizacion,
+
-            size=archivo.size,
+            pedimento_id = serializer.validated_data.get('pedimento').id if serializer.validated_data.get('pedimento') else None
-            extension=archivo.name.split('.')[-1].lower()
+            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()
@@ -762,6 +906,157 @@ class MultiPedimentoZipDownloadView(APIView):
 
         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)
+        
+