Compare commits
10 Commits
T2025-10-0
...
correccion
| Author | SHA1 | Date | |
|---|---|---|---|
|
a112d746f6 | ||
|
|
dad4fa2191 | ||
| 421aa0c0da | |||
| 48de6f8658 | |||
| 8349b85714 | |||
| 93f7445725 | |||
| a75e9d1ebc | |||
| 5042781fdd | |||
|
|
1a2909a5ac | ||
|
|
a765026075 |
@@ -23,7 +23,7 @@ from api.customs.models import (
|
|||||||
EDocument,
|
EDocument,
|
||||||
Cove,
|
Cove,
|
||||||
Importador,
|
Importador,
|
||||||
Partida,
|
Partida
|
||||||
)
|
)
|
||||||
from api.customs.serializers import (
|
from api.customs.serializers import (
|
||||||
PedimentoSerializer,
|
PedimentoSerializer,
|
||||||
@@ -44,11 +44,11 @@ import zipfile
|
|||||||
import tempfile
|
import tempfile
|
||||||
import shutil
|
import shutil
|
||||||
import subprocess
|
import subprocess
|
||||||
from datetime import date, datetime
|
from datetime import datetime
|
||||||
from django.core.files.base import ContentFile
|
from django.core.files.base import ContentFile
|
||||||
from django.db import transaction
|
from django.db import transaction
|
||||||
from rest_framework.parsers import MultiPartParser, FormParser
|
from rest_framework.parsers import MultiPartParser, FormParser
|
||||||
from api.record.models import Document, DocumentType, Fuente
|
from api.record.models import Document, DocumentType
|
||||||
|
|
||||||
# Importar rarfile de manera opcional
|
# Importar rarfile de manera opcional
|
||||||
try:
|
try:
|
||||||
@@ -281,16 +281,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
|
|||||||
ordering = ['-created_at'] # Orden descendente por fecha de creación por defecto
|
ordering = ['-created_at'] # Orden descendente por fecha de creación por defecto
|
||||||
|
|
||||||
def get_queryset(self):
|
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):
|
def perform_create(self, serializer):
|
||||||
"""
|
"""
|
||||||
@@ -892,542 +883,6 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
|
|||||||
|
|
||||||
return Response(response_data, status=response_status)
|
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
|
|
||||||
)
|
|
||||||
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']
|
my_tags = ['Pedimentos']
|
||||||
|
|
||||||
|
|||||||
85
api/datastage/tasks/report_document.py
Normal file
85
api/datastage/tasks/report_document.py
Normal file
@@ -0,0 +1,85 @@
|
|||||||
|
from celery import shared_task
|
||||||
|
from django.core.files.base import ContentFile
|
||||||
|
from django.utils import timezone
|
||||||
|
from api.reports.models import ReportDocument
|
||||||
|
from api.customs.models import Pedimento, Cove, EDocument, Partida
|
||||||
|
from django.db.models import Q
|
||||||
|
import csv
|
||||||
|
import os
|
||||||
|
from django.conf import settings
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logger = logging.getLogger()
|
||||||
|
|
||||||
|
@shared_task
|
||||||
|
def generate_report_document(report_id):
|
||||||
|
try:
|
||||||
|
report = ReportDocument.objects.get(id=report_id)
|
||||||
|
report.status = 'processing'
|
||||||
|
report.save(update_fields=['status'])
|
||||||
|
filters = report.filters or {}
|
||||||
|
pedimentos_filters = Q()
|
||||||
|
if filters.get('organizacion_id'):
|
||||||
|
pedimentos_filters &= Q(organizacion_id=filters['organizacion_id'])
|
||||||
|
if filters.get('fecha_pago__gte'):
|
||||||
|
pedimentos_filters &= Q(fecha_pago__gte=filters['fecha_pago__gte'])
|
||||||
|
if filters.get('fecha_pago__lte'):
|
||||||
|
pedimentos_filters &= Q(fecha_pago__lte=filters['fecha_pago__lte'])
|
||||||
|
if filters.get('contribuyente__rfc'):
|
||||||
|
pedimentos_filters &= Q(contribuyente__rfc=filters['contribuyente__rfc'])
|
||||||
|
if filters.get('patente'):
|
||||||
|
pedimentos_filters &= Q(patente=filters['patente'])
|
||||||
|
if filters.get('aduana'):
|
||||||
|
pedimentos_filters &= Q(aduana=filters['aduana'])
|
||||||
|
if filters.get('pedimento'):
|
||||||
|
pedimentos_filters &= Q(pedimento=filters['pedimento'])
|
||||||
|
if filters.get('pedimento_app'):
|
||||||
|
pedimentos_filters &= Q(pedimento_app=filters['pedimento_app'])
|
||||||
|
if filters.get('regimen'):
|
||||||
|
pedimentos_filters &= Q(regimen=filters['regimen'])
|
||||||
|
if filters.get('tipo_operacion'):
|
||||||
|
pedimentos_filters &= Q(tipo_operacion_id=filters['tipo_operacion'])
|
||||||
|
pedimentos = Pedimento.objects.filter(pedimentos_filters)
|
||||||
|
filename = filters.get('filename')
|
||||||
|
if filename:
|
||||||
|
filename = f"{filename}.csv" if not filename.endswith('.csv') else filename
|
||||||
|
else:
|
||||||
|
filename = f"report_{report.id}_{timezone.now().strftime('%Y%m%d%H%M%S')}.csv"
|
||||||
|
file_path = os.path.join(settings.MEDIA_ROOT, 'reports', filename)
|
||||||
|
os.makedirs(os.path.dirname(file_path), exist_ok=True)
|
||||||
|
with open(file_path, 'w', newline='', encoding='utf-8') as f:
|
||||||
|
writer = csv.writer(f)
|
||||||
|
headers = [
|
||||||
|
'aduana', 'patente', 'regimen', 'pedimento', 'pedimento_app', 'clave_pedimento',
|
||||||
|
'tipo_operacion_id', 'contribuyente_id', 'tipo_documento', 'numero_documento', 'estado', 'acuse_estado'
|
||||||
|
]
|
||||||
|
writer.writerow(headers)
|
||||||
|
for ped in pedimentos:
|
||||||
|
for cove in Cove.objects.filter(pedimento=ped):
|
||||||
|
writer.writerow([
|
||||||
|
ped.aduana, ped.patente, ped.regimen, ped.pedimento, ped.pedimento_app,
|
||||||
|
ped.clave_pedimento, ped.tipo_operacion_id, ped.contribuyente_id,
|
||||||
|
'COVE', cove.numero_cove, cove.cove_descargado, cove.acuse_cove_descargado
|
||||||
|
])
|
||||||
|
for edoc in EDocument.objects.filter(pedimento=ped):
|
||||||
|
writer.writerow([
|
||||||
|
ped.aduana, ped.patente, ped.regimen, ped.pedimento, ped.pedimento_app,
|
||||||
|
ped.clave_pedimento, ped.tipo_operacion_id, ped.contribuyente_id,
|
||||||
|
'EDOC', edoc.numero_edocument, edoc.edocument_descargado, edoc.acuse_descargado
|
||||||
|
])
|
||||||
|
for partida in Partida.objects.filter(pedimento=ped):
|
||||||
|
writer.writerow([
|
||||||
|
ped.aduana, ped.patente, ped.regimen, ped.pedimento, ped.pedimento_app,
|
||||||
|
ped.clave_pedimento, ped.tipo_operacion_id, ped.contribuyente_id,
|
||||||
|
'PARTIDA', partida.numero_partida, partida.descargado, ''
|
||||||
|
])
|
||||||
|
with open(file_path, 'rb') as f:
|
||||||
|
report.file.save(filename, ContentFile(f.read()), save=True)
|
||||||
|
report.status = 'ready'
|
||||||
|
report.finished_at = timezone.now()
|
||||||
|
report.save(update_fields=['status', 'file', 'finished_at'])
|
||||||
|
except Exception as e:
|
||||||
|
report.status = 'error'
|
||||||
|
report.error_message = str(e)
|
||||||
|
report.finished_at = timezone.now()
|
||||||
|
report.save(update_fields=['status', 'error_message', 'finished_at'])
|
||||||
@@ -27,7 +27,7 @@ class ViewSetOrganizacion(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltr
|
|||||||
|
|
||||||
queryset = Organizacion.objects.all()
|
queryset = Organizacion.objects.all()
|
||||||
serializer_class = OrganizacionSerializer
|
serializer_class = OrganizacionSerializer
|
||||||
filterset_fields = ['nombre', 'descripcion']
|
filterset_fields = ['nombre']
|
||||||
|
|
||||||
my_tags = ['Organizaciones']
|
my_tags = ['Organizaciones']
|
||||||
|
|
||||||
|
|||||||
@@ -9,11 +9,10 @@ from api.customs.models import Pedimento
|
|||||||
class DocumentSerializer(serializers.ModelSerializer):
|
class DocumentSerializer(serializers.ModelSerializer):
|
||||||
pedimento_numero = serializers.SerializerMethodField(read_only=True)
|
pedimento_numero = serializers.SerializerMethodField(read_only=True)
|
||||||
pedimento = serializers.PrimaryKeyRelatedField(queryset=Pedimento.objects.all())
|
pedimento = serializers.PrimaryKeyRelatedField(queryset=Pedimento.objects.all())
|
||||||
fuente_nombre = serializers.SerializerMethodField()
|
|
||||||
fuente = serializers.PrimaryKeyRelatedField(queryset=Fuente.objects.all())
|
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Document
|
model = Document
|
||||||
fields = ('id', 'organizacion', 'pedimento', 'pedimento_numero', 'archivo', 'document_type', 'size', 'extension', 'fuente','fuente_nombre','created_at', 'updated_at')
|
fields = ('id', 'organizacion', 'pedimento', 'pedimento_numero', 'archivo', 'document_type', 'size', 'extension', 'fuente','created_at', 'updated_at')
|
||||||
read_only_fields = ('id', 'size', 'extension', 'created_at', 'updated_at', 'pedimento_numero')
|
read_only_fields = ('id', 'size', 'extension', 'created_at', 'updated_at', 'pedimento_numero')
|
||||||
|
|
||||||
def get_pedimento_numero(self, obj):
|
def get_pedimento_numero(self, obj):
|
||||||
@@ -27,12 +26,6 @@ class DocumentSerializer(serializers.ModelSerializer):
|
|||||||
raise serializers.ValidationError("Se requiere un archivo para subir")
|
raise serializers.ValidationError("Se requiere un archivo para subir")
|
||||||
return value
|
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 FuenteSerializer(serializers.ModelSerializer):
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Fuente
|
model = Fuente
|
||||||
|
|||||||
@@ -9,10 +9,15 @@ class ReportDocument(models.Model):
|
|||||||
('ready', 'Listo'),
|
('ready', 'Listo'),
|
||||||
('error', 'Error'),
|
('error', 'Error'),
|
||||||
]
|
]
|
||||||
|
TYPE_REPORT = [
|
||||||
|
('cumplimiento', 'cumplimiento'),
|
||||||
|
('control_pedimento', 'control_pedimento'),
|
||||||
|
]
|
||||||
user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE, related_name='report_documents')
|
user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE, related_name='report_documents')
|
||||||
filters = models.JSONField(blank=True, null=True)
|
filters = models.JSONField(blank=True, null=True)
|
||||||
status = models.CharField(max_length=20, choices=STATUS_CHOICES, default='pending')
|
status = models.CharField(max_length=20, choices=STATUS_CHOICES, default='pending')
|
||||||
file = models.FileField(upload_to='reports/', blank=True, null=True)
|
file = models.FileField(upload_to='reports/', blank=True, null=True)
|
||||||
|
report_type = models.CharField(max_length=30, choices=TYPE_REPORT, default='cumplimiento')
|
||||||
error_message = models.TextField(blank=True, null=True)
|
error_message = models.TextField(blank=True, null=True)
|
||||||
created_at = models.DateTimeField(auto_now_add=True)
|
created_at = models.DateTimeField(auto_now_add=True)
|
||||||
finished_at = models.DateTimeField(blank=True, null=True)
|
finished_at = models.DateTimeField(blank=True, null=True)
|
||||||
|
|||||||
@@ -1,9 +1,12 @@
|
|||||||
from celery import shared_task
|
from celery import shared_task
|
||||||
|
from api.organization.models import Organizacion
|
||||||
from django.core.files.base import ContentFile
|
from django.core.files.base import ContentFile
|
||||||
from django.utils import timezone
|
from django.utils import timezone
|
||||||
from api.reports.models import ReportDocument
|
from api.reports.models import ReportDocument
|
||||||
from api.customs.models import Pedimento, Cove, EDocument, Partida
|
from api.customs.models import Pedimento, Cove, EDocument, Partida
|
||||||
from django.db.models import Q
|
from django.db.models import Q, Exists, OuterRef
|
||||||
|
# from django.db.models import Q,
|
||||||
|
from api.record.models import Document
|
||||||
import csv
|
import csv
|
||||||
import os
|
import os
|
||||||
from django.conf import settings
|
from django.conf import settings
|
||||||
@@ -15,7 +18,6 @@ def generate_report_document(report_id):
|
|||||||
report.status = 'processing'
|
report.status = 'processing'
|
||||||
report.save(update_fields=['status'])
|
report.save(update_fields=['status'])
|
||||||
filters = report.filters or {}
|
filters = report.filters or {}
|
||||||
# Construir Q para filtros complejos
|
|
||||||
pedimentos_filters = Q()
|
pedimentos_filters = Q()
|
||||||
if filters.get('organizacion_id'):
|
if filters.get('organizacion_id'):
|
||||||
pedimentos_filters &= Q(organizacion_id=filters['organizacion_id'])
|
pedimentos_filters &= Q(organizacion_id=filters['organizacion_id'])
|
||||||
@@ -83,3 +85,199 @@ def generate_report_document(report_id):
|
|||||||
report.error_message = str(e)
|
report.error_message = str(e)
|
||||||
report.finished_at = timezone.now()
|
report.finished_at = timezone.now()
|
||||||
report.save(update_fields=['status', 'error_message', 'finished_at'])
|
report.save(update_fields=['status', 'error_message', 'finished_at'])
|
||||||
|
|
||||||
|
@shared_task
|
||||||
|
def generate_report_control_pedimento(report_id):
|
||||||
|
try:
|
||||||
|
|
||||||
|
report = ReportDocument.objects.get(id=report_id)
|
||||||
|
report.status = 'processing'
|
||||||
|
report.save(update_fields=['status'])
|
||||||
|
filters = report.filters or {}
|
||||||
|
|
||||||
|
|
||||||
|
# Construir filtros
|
||||||
|
pedimentos_filters = {}
|
||||||
|
if filters.get('organizacion_id'):
|
||||||
|
pedimentos_filters['organizacion_id'] = filters['organizacion_id']
|
||||||
|
if filters.get('fecha_pago__gte'):
|
||||||
|
pedimentos_filters['fecha_pago__gte'] = filters['fecha_pago__gte']
|
||||||
|
if filters.get('fecha_pago__lte'):
|
||||||
|
pedimentos_filters['fecha_pago__lte'] = filters['fecha_pago__lte']
|
||||||
|
if filters.get('pedimento_app'):
|
||||||
|
pedimentos_filters['pedimento_app'] = filters['pedimento_app']
|
||||||
|
|
||||||
|
# pedimentos por organizacion
|
||||||
|
pedimentos_qs = Pedimento.objects.filter(**pedimentos_filters)
|
||||||
|
pedimentos_total = pedimentos_qs.count()
|
||||||
|
|
||||||
|
|
||||||
|
pedimento_ids = list(pedimentos_qs.values_list('id', flat=True))
|
||||||
|
rfcs_raw = list(pedimentos_qs.values_list('agente_aduanal', flat=True))
|
||||||
|
|
||||||
|
# inicializar totales
|
||||||
|
pedimentos_completos = 0
|
||||||
|
total_documentos = 0
|
||||||
|
documentos_sin_descargar = 0
|
||||||
|
|
||||||
|
nombre_organizacion = ''
|
||||||
|
if filters.get('organizacion_id'):
|
||||||
|
try:
|
||||||
|
# Asumo que tienes un modelo Organizacion - ajusta según tu modelo real
|
||||||
|
organizacion = Organizacion.objects.get(id=filters['organizacion_id'])
|
||||||
|
nombre_organizacion = organizacion.nombre # ajusta el campo según tu modelo
|
||||||
|
except Organizacion.DoesNotExist:
|
||||||
|
nombre_organizacion = f"ID: {filters['organizacion_id']}"
|
||||||
|
except Exception as e:
|
||||||
|
nombre_organizacion = f"Error: {str(e)}"
|
||||||
|
|
||||||
|
# lista de rfc
|
||||||
|
rfc_list = ', '.join(sorted(set([rfc for rfc in rfcs_raw if rfc])))
|
||||||
|
|
||||||
|
fecha_inicio = ''
|
||||||
|
fecha_fin = ''
|
||||||
|
|
||||||
|
if pedimentos_qs.exists():
|
||||||
|
primer_pedimento = pedimentos_qs.order_by('fecha_pago').first()
|
||||||
|
if primer_pedimento and primer_pedimento.fecha_pago:
|
||||||
|
fecha_inicio = primer_pedimento.fecha_pago.strftime('%Y-%m-%d')
|
||||||
|
|
||||||
|
ultimo_pedimento = pedimentos_qs.order_by('-fecha_pago').first()
|
||||||
|
if ultimo_pedimento and ultimo_pedimento.fecha_pago:
|
||||||
|
fecha_fin = ultimo_pedimento.fecha_pago.strftime('%Y-%m-%d')
|
||||||
|
|
||||||
|
# Para cada pedimento, verificar si está completo
|
||||||
|
for pedimento in pedimentos_qs:
|
||||||
|
# Contar documentos de este pedimento
|
||||||
|
docs_pedimento = 0
|
||||||
|
docs_pendientes_pedimento = 0
|
||||||
|
|
||||||
|
# COVES
|
||||||
|
coves_count = Cove.objects.filter(pedimento_id=pedimento.id).count()
|
||||||
|
coves_pendientes = Cove.objects.filter(pedimento_id=pedimento.id, cove_descargado=False).count()
|
||||||
|
docs_pedimento += coves_count
|
||||||
|
docs_pendientes_pedimento += coves_pendientes
|
||||||
|
|
||||||
|
# PARTIDAS
|
||||||
|
partidas_count = Partida.objects.filter(pedimento_id=pedimento.id).count()
|
||||||
|
partidas_pendientes = Partida.objects.filter(pedimento_id=pedimento.id, descargado=False).count()
|
||||||
|
docs_pedimento += partidas_count
|
||||||
|
docs_pendientes_pedimento += partidas_pendientes
|
||||||
|
|
||||||
|
# EDOCUMENTS
|
||||||
|
edocs_count = EDocument.objects.filter(pedimento_id=pedimento.id).count()
|
||||||
|
edocs_pendientes = EDocument.objects.filter(pedimento_id=pedimento.id, edocument_descargado=False).count()
|
||||||
|
docs_pedimento += edocs_count
|
||||||
|
docs_pendientes_pedimento += edocs_pendientes
|
||||||
|
|
||||||
|
# Acumular totales
|
||||||
|
total_documentos += docs_pedimento
|
||||||
|
documentos_sin_descargar += docs_pendientes_pedimento
|
||||||
|
|
||||||
|
# Si no tiene documentos pendientes, está completo
|
||||||
|
if docs_pendientes_pedimento == 0 and docs_pedimento > 0:
|
||||||
|
pedimentos_completos += 1
|
||||||
|
|
||||||
|
# 3. PORCENTAJE
|
||||||
|
porcentaje_faltantes = (documentos_sin_descargar / total_documentos * 100) if total_documentos > 0 else 0
|
||||||
|
|
||||||
|
# 4. GENERAR CSV CON DETALLES
|
||||||
|
filename = f"report_{report.id}_{timezone.now().strftime('%Y%m%d%H%M%S')}.csv"
|
||||||
|
file_path = os.path.join(settings.MEDIA_ROOT, 'reports', filename)
|
||||||
|
os.makedirs(os.path.dirname(file_path), exist_ok=True)
|
||||||
|
|
||||||
|
todas_las_filas = []
|
||||||
|
|
||||||
|
# Recopilar datos detallados - UNA FILA POR CADA DOCUMENTO
|
||||||
|
for pedimento in pedimentos_qs:
|
||||||
|
# DATOS BASE DEL PEDIMENTO (se repiten en cada fila)
|
||||||
|
datos_base_pedimento = [
|
||||||
|
pedimento.aduana or '',
|
||||||
|
pedimento.patente or '',
|
||||||
|
pedimento.regimen or '',
|
||||||
|
pedimento.pedimento or '', # No. Pedimento (7 dígitos)
|
||||||
|
pedimento.pedimento_app or '', # No. Pedimento App completo
|
||||||
|
pedimento.clave_pedimento or '',
|
||||||
|
pedimento.tipo_operacion.tipo if pedimento.tipo_operacion else '',
|
||||||
|
str(pedimento.contribuyente_id) if pedimento.contribuyente_id else ''
|
||||||
|
]
|
||||||
|
|
||||||
|
# COVES - Una fila por cada COVE
|
||||||
|
coves = Cove.objects.filter(pedimento_id=pedimento.id)
|
||||||
|
for cove in coves:
|
||||||
|
estado = 'VERDADERO' if cove.cove_descargado else 'FALSO'
|
||||||
|
fila = datos_base_pedimento + [
|
||||||
|
# str(cove.id), # Identificador de documento
|
||||||
|
cove.numero_cove,
|
||||||
|
'COVE', # Tipo de documento
|
||||||
|
estado
|
||||||
|
]
|
||||||
|
todas_las_filas.append(fila)
|
||||||
|
|
||||||
|
# PARTIDAS - Una fila por cada Partida
|
||||||
|
partidas = Partida.objects.filter(pedimento_id=pedimento.id)
|
||||||
|
for partida in partidas:
|
||||||
|
estado = 'VERDADERO' if partida.descargado else 'FALSO'
|
||||||
|
fila = datos_base_pedimento + [
|
||||||
|
# str(partida.id),
|
||||||
|
partida.numero_partida,
|
||||||
|
'PARTIDA', # Tipo de documento
|
||||||
|
estado
|
||||||
|
]
|
||||||
|
todas_las_filas.append(fila)
|
||||||
|
|
||||||
|
# EDOCUMENTS - Una fila por cada EDocument
|
||||||
|
edocuments = EDocument.objects.filter(pedimento_id=pedimento.id)
|
||||||
|
for edoc in edocuments:
|
||||||
|
estado = 'VERDADERO' if edoc.edocument_descargado else 'FALSO'
|
||||||
|
fila = datos_base_pedimento + [
|
||||||
|
# str(edoc.id),
|
||||||
|
edoc.numero_edocument,
|
||||||
|
'EDOCUMENT', # Tipo de documento
|
||||||
|
estado
|
||||||
|
]
|
||||||
|
todas_las_filas.append(fila)
|
||||||
|
|
||||||
|
# 5. ESCRIBIR ARCHIVO CSV
|
||||||
|
with open(file_path, 'w', newline='', encoding='utf-8') as f:
|
||||||
|
writer = csv.writer(f)
|
||||||
|
|
||||||
|
# SECCIÓN DE TOTALES
|
||||||
|
writer.writerow(['RESUMEN DEL REPORTE - CONTROL DE PEDIMENTOS'])
|
||||||
|
writer.writerow(['OOGANIZACION:', nombre_organizacion])
|
||||||
|
writer.writerow([])
|
||||||
|
writer.writerow(['TOTAL DE EXPEDIENTES:', pedimentos_total])
|
||||||
|
writer.writerow(['TOTAL DE EXPEDIENTES COMPLETOS:', pedimentos_completos])
|
||||||
|
writer.writerow(['TOTAL DE DOCUMENTOS:', total_documentos])
|
||||||
|
writer.writerow(['DOCUMENTOS SIN DESCARGAR:', documentos_sin_descargar])
|
||||||
|
writer.writerow(['PORCENTAJE DE DOCUMENTOS FALTANTES (%):', f"{porcentaje_faltantes:.2f}%"])
|
||||||
|
writer.writerow(['DESDE: ', fecha_inicio, ' HASTA: ', fecha_fin])
|
||||||
|
writer.writerow(['LISTA RFC:', rfc_list])
|
||||||
|
writer.writerow([])
|
||||||
|
writer.writerow([])
|
||||||
|
|
||||||
|
# ENCABEZADOS DE DATOS (según requerimiento)
|
||||||
|
headers = [
|
||||||
|
'ADUANA', 'PATENTE', 'REGIMEN', 'NO. PEDIMENTO', 'PEDIMENTO_APP',
|
||||||
|
'CLAVE_PEDIMENTO', 'TIPO_OPERACION', 'CONTRIBUYENTE_ID',
|
||||||
|
'IDENTIFICADOR_DOCUMENTO', 'TIPO_DOCUMENTO', 'ESTADO'
|
||||||
|
]
|
||||||
|
writer.writerow(headers)
|
||||||
|
|
||||||
|
# DATOS DETALLADOS
|
||||||
|
for fila in todas_las_filas:
|
||||||
|
writer.writerow(fila)
|
||||||
|
|
||||||
|
|
||||||
|
with open(file_path, 'rb') as f:
|
||||||
|
report.file.save(filename, ContentFile(f.read()), save=True)
|
||||||
|
|
||||||
|
report.status = 'ready'
|
||||||
|
report.finished_at = timezone.now()
|
||||||
|
report.save(update_fields=['status', 'file', 'finished_at'])
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
report.status = 'error'
|
||||||
|
report.error_message = str(e)
|
||||||
|
report.finished_at = timezone.now()
|
||||||
|
report.save(update_fields=['status', 'error_message', 'finished_at'])
|
||||||
@@ -1,10 +1,12 @@
|
|||||||
from django.urls import path, include
|
from django.urls import path, include
|
||||||
from .views import ExportModelView, dashboard_summary
|
from .views import ExportModelView, ExportDataStageView, dashboard_summary
|
||||||
# from .views_stats import documentos_por_fecha
|
# from .views_stats import documentos_por_fecha
|
||||||
from .views_table import table_summary, report_document_status, report_document_list, report_document_download
|
from .views_table import table_summary, report_document_status, report_document_list, report_document_download, control_pedimento
|
||||||
|
|
||||||
urlpatterns = [
|
urlpatterns = [
|
||||||
path('exportmodel/', ExportModelView.as_view(), name='export-model'),
|
path('exportmodel/', ExportModelView.as_view(), name='export-model'),
|
||||||
|
path('exportmodel/datastage/', ExportDataStageView.as_view(), name='export-datastage-model'),
|
||||||
|
path('control-pedimento/', control_pedimento, name='control_pedimento'),
|
||||||
path('dashboard/summary/', dashboard_summary, name='dashboard-summary'),
|
path('dashboard/summary/', dashboard_summary, name='dashboard-summary'),
|
||||||
#path('documentos-por-fecha/', documentos_por_fecha, name='documentos-por-fecha'),
|
#path('documentos-por-fecha/', documentos_por_fecha, name='documentos-por-fecha'),
|
||||||
path('table-summary/', table_summary, name='table-summary'),
|
path('table-summary/', table_summary, name='table-summary'),
|
||||||
|
|||||||
@@ -48,7 +48,10 @@ from core.permissions import (
|
|||||||
IsSuperUser
|
IsSuperUser
|
||||||
)
|
)
|
||||||
from .serializers import ExportModelSerializer
|
from .serializers import ExportModelSerializer
|
||||||
|
import uuid
|
||||||
|
import datetime
|
||||||
|
import zipfile
|
||||||
|
from django.db import models
|
||||||
|
|
||||||
def export_model_to_csv(request, model_name, fields, module='datastage', filters=None):
|
def export_model_to_csv(request, model_name, fields, module='datastage', filters=None):
|
||||||
model = apps.get_model(module, model_name)
|
model = apps.get_model(module, model_name)
|
||||||
@@ -86,11 +89,797 @@ def export_model_to_excel(request, model_name, fields, module='datastage', filte
|
|||||||
response['Content-Disposition'] = f'attachment; filename="{model_name}.xlsx"'
|
response['Content-Disposition'] = f'attachment; filename="{model_name}.xlsx"'
|
||||||
return response
|
return response
|
||||||
|
|
||||||
|
# class ControlPedimentoView(APIView):
|
||||||
|
# my_tags = ['Control-Pedimento']
|
||||||
|
# permission_classes = [IsAuthenticated & (IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper | IsSuperUser)]
|
||||||
|
|
||||||
|
# @swagger_auto_schema(request_body=ExportModelSerializer, responses={200: 'Archivo generado (Excel o CSV)'})
|
||||||
|
# def post(self, request, *args, **kwargs):
|
||||||
|
# """
|
||||||
|
# Endpoint específico para exportación de DataStage con soporte múltiple
|
||||||
|
# """
|
||||||
|
# # Verificar si es modo múltiple
|
||||||
|
# modo = request.data.get('modo', 'simple')
|
||||||
|
|
||||||
|
# if modo == 'multiple':
|
||||||
|
# return self.handle_multiple_export(request)
|
||||||
|
# else:
|
||||||
|
# return self.handle_simple_export(request)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
class ExportDataStageView(APIView):
|
||||||
|
my_tags = ['Reportes-DataStage']
|
||||||
|
permission_classes = [IsAuthenticated & (IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper | IsSuperUser)]
|
||||||
|
|
||||||
|
# Constantes para partición
|
||||||
|
# MAX_RECORDS_PER_FILE = 100 # Límite seguro por archivo
|
||||||
|
MAX_RECORDS_PER_FILE = 120000 # Límite seguro por archivo
|
||||||
|
|
||||||
|
def safe_excel_value(self, value):
|
||||||
|
"""
|
||||||
|
Convierte cualquier valor a un formato seguro para Excel
|
||||||
|
"""
|
||||||
|
if value is None:
|
||||||
|
return ''
|
||||||
|
elif isinstance(value, (uuid.UUID,)):
|
||||||
|
return str(value)
|
||||||
|
elif hasattr(value, 'uuid'):
|
||||||
|
return str(value.uuid)
|
||||||
|
elif hasattr(value, 'id'):
|
||||||
|
return str(value.id)
|
||||||
|
elif isinstance(value, (datetime.datetime, datetime.date)):
|
||||||
|
return value.isoformat()
|
||||||
|
elif isinstance(value, (dict, list)):
|
||||||
|
return str(value)
|
||||||
|
else:
|
||||||
|
return str(value)
|
||||||
|
|
||||||
|
@swagger_auto_schema(request_body=ExportModelSerializer, responses={200: 'Archivo generado (Excel o CSV)'})
|
||||||
|
def post(self, request, *args, **kwargs):
|
||||||
|
"""
|
||||||
|
Endpoint específico para exportación de DataStage con soporte múltiple
|
||||||
|
"""
|
||||||
|
# Verificar si es modo múltiple
|
||||||
|
modo = request.data.get('modo', 'simple')
|
||||||
|
|
||||||
|
if modo == 'multiple':
|
||||||
|
return self.handle_multiple_export(request)
|
||||||
|
else:
|
||||||
|
return self.handle_simple_export(request)
|
||||||
|
|
||||||
|
def handle_simple_export(self, request):
|
||||||
|
"""Maneja exportación simple de DataStage (un solo modelo)"""
|
||||||
|
model_name = request.data.get('model')
|
||||||
|
fields = request.data.get('fields')
|
||||||
|
global_filters = request.data.get('globalFilters', {})
|
||||||
|
export_type = request.data.get('format', 'csv')
|
||||||
|
module = 'datastage'
|
||||||
|
|
||||||
|
if not model_name or not fields:
|
||||||
|
return Response({'error': 'model and fields are required'}, status=status.HTTP_400_BAD_REQUEST)
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model(module, model_name)
|
||||||
|
filters = self.apply_global_filters_to_model(global_filters, model, request.user)
|
||||||
|
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
total_records = queryset.count()
|
||||||
|
|
||||||
|
if export_type == 'excel':
|
||||||
|
# Verificar si necesita partición
|
||||||
|
if total_records > self.MAX_RECORDS_PER_FILE:
|
||||||
|
return self.export_single_model_partitioned(request, model_name, fields, filters, total_records)
|
||||||
|
else:
|
||||||
|
return export_model_to_excel(request, model_name, fields, module, filters)
|
||||||
|
else:
|
||||||
|
if total_records > self.MAX_RECORDS_PER_FILE:
|
||||||
|
return self.export_single_model_csv_partitioned(request, model_name, fields, filters, total_records)
|
||||||
|
else:
|
||||||
|
return export_model_to_csv(request, model_name, fields, module, filters)
|
||||||
|
|
||||||
|
except LookupError:
|
||||||
|
return Response({'error': f'Model {model_name} not found'}, status=status.HTTP_404_NOT_FOUND)
|
||||||
|
|
||||||
|
def handle_multiple_export(self, request):
|
||||||
|
"""Maneja exportación múltiple de DataStage (varios modelos)"""
|
||||||
|
models_data = request.data.get('models', [])
|
||||||
|
export_type = request.data.get('format', 'csv')
|
||||||
|
global_filters = request.data.get('globalFilters', {})
|
||||||
|
|
||||||
|
if not models_data:
|
||||||
|
return Response({'error': 'models are required for multiple export'}, status=status.HTTP_400_BAD_REQUEST)
|
||||||
|
|
||||||
|
related_keys = self.get_related_keys_from_filters(global_filters, models_data, request.user)
|
||||||
|
|
||||||
|
if export_type == 'excel':
|
||||||
|
# Siempre usar el método particionado inteligente para Excel
|
||||||
|
return self.export_datastage_multiple_partitioned_excel(request, models_data, global_filters, related_keys)
|
||||||
|
else:
|
||||||
|
# Para CSV, podemos mantener la lógica actual o mejorarla
|
||||||
|
total_estimated_records = self.estimate_total_records(models_data, global_filters, related_keys, request.user)
|
||||||
|
if total_estimated_records > self.MAX_RECORDS_PER_FILE:
|
||||||
|
return self.export_datastage_multiple_partitioned_csv(request, models_data, global_filters, related_keys)
|
||||||
|
else:
|
||||||
|
return self.export_datastage_multiple_to_csv(request, models_data, global_filters, related_keys)
|
||||||
|
|
||||||
|
def estimate_total_records(self, models_data, global_filters, related_keys, user):
|
||||||
|
"""Estima el total de registros para todos los modelos"""
|
||||||
|
total = 0
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
filters = self.apply_related_filters(global_filters, model, related_keys, user)
|
||||||
|
total += model.objects.filter(**filters).count()
|
||||||
|
except:
|
||||||
|
continue
|
||||||
|
return total
|
||||||
|
|
||||||
|
def export_datastage_multiple_to_excel(self, request, models_data, global_filters, related_keys):
|
||||||
|
"""Exporta múltiples modelos de DataStage con filtrado relacionado (múltiples hojas)"""
|
||||||
|
wb = openpyxl.Workbook()
|
||||||
|
wb.remove(wb.active)
|
||||||
|
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
fields = model_data.get('fields', [])
|
||||||
|
|
||||||
|
if not model_name or not fields:
|
||||||
|
continue
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
|
||||||
|
# 🔥 APLICAR FILTROS RELACIONADOS
|
||||||
|
filters = self.apply_related_filters(global_filters, model, related_keys, request.user)
|
||||||
|
|
||||||
|
# Si hay filtros, aplicarlos; si no, obtener todos los registros
|
||||||
|
if filters:
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
else:
|
||||||
|
queryset = model.objects.none() # No obtener nada si no hay filtros
|
||||||
|
|
||||||
|
# Si no hay registros, saltar este modelo
|
||||||
|
if queryset.count() == 0:
|
||||||
|
continue
|
||||||
|
|
||||||
|
# Crear hoja (limitar nombre a 31 caracteres)
|
||||||
|
sheet_name = model_name[:31]
|
||||||
|
ws = wb.create_sheet(title=sheet_name)
|
||||||
|
|
||||||
|
# Escribir encabezados
|
||||||
|
ws.append(fields)
|
||||||
|
|
||||||
|
# Escribir datos
|
||||||
|
for row in queryset:
|
||||||
|
row_values = []
|
||||||
|
for field in fields:
|
||||||
|
value = row[field]
|
||||||
|
# 🔥 USAR safe_excel_value para convertir valores
|
||||||
|
row_values.append(self.safe_excel_value(value))
|
||||||
|
ws.append(row_values)
|
||||||
|
|
||||||
|
except LookupError:
|
||||||
|
continue
|
||||||
|
|
||||||
|
# Si no se crearon hojas, crear una vacía
|
||||||
|
if len(wb.sheetnames) == 0:
|
||||||
|
ws = wb.create_sheet(title="Sin datos")
|
||||||
|
ws.append(["No se encontraron datos para los modelos especificados"])
|
||||||
|
|
||||||
|
output = io.BytesIO()
|
||||||
|
wb.save(output)
|
||||||
|
output.seek(0)
|
||||||
|
|
||||||
|
response = HttpResponse(
|
||||||
|
output.read(),
|
||||||
|
content_type='application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'
|
||||||
|
)
|
||||||
|
response['Content-Disposition'] = 'attachment; filename="datastage_related_report.xlsx"'
|
||||||
|
return response
|
||||||
|
|
||||||
|
def export_datastage_multiple_partitioned_excel(self, request, models_data, global_filters, related_keys):
|
||||||
|
"""Exporta múltiples modelos de DataStage a múltiples archivos Excel particionados inteligentemente"""
|
||||||
|
try:
|
||||||
|
zip_buffer = io.BytesIO()
|
||||||
|
|
||||||
|
with zipfile.ZipFile(zip_buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
|
||||||
|
file_counter = 1
|
||||||
|
current_wb = None
|
||||||
|
current_file_records_count = 0
|
||||||
|
MAX_SHEETS_PER_FILE = 10 # Límite de hojas por archivo Excel
|
||||||
|
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
fields = model_data.get('fields', [])
|
||||||
|
|
||||||
|
if not model_name or not fields:
|
||||||
|
continue
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
filters = self.apply_related_filters(global_filters, model, related_keys, request.user)
|
||||||
|
|
||||||
|
if filters:
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
else:
|
||||||
|
queryset = model.objects.none()
|
||||||
|
|
||||||
|
total_records = queryset.count()
|
||||||
|
|
||||||
|
if total_records == 0:
|
||||||
|
continue
|
||||||
|
|
||||||
|
# Si el modelo necesita particionarse (más de MAX_RECORDS_PER_FILE)
|
||||||
|
if total_records > self.MAX_RECORDS_PER_FILE:
|
||||||
|
from django.core.paginator import Paginator
|
||||||
|
paginator = Paginator(queryset, self.MAX_RECORDS_PER_FILE)
|
||||||
|
|
||||||
|
for page_num in paginator.page_range:
|
||||||
|
page = paginator.page(page_num)
|
||||||
|
|
||||||
|
# Verificar si necesitamos crear nuevo archivo
|
||||||
|
# 1. Si no hay archivo actual
|
||||||
|
# 2. Si ya tenemos muchas hojas en este archivo
|
||||||
|
# 3. Si este archivo ya está "lleno" (muchos registros)
|
||||||
|
if (current_wb is None or
|
||||||
|
len(current_wb.sheetnames) >= MAX_SHEETS_PER_FILE or
|
||||||
|
current_file_records_count > self.MAX_RECORDS_PER_FILE * 3): # ~150K registros
|
||||||
|
|
||||||
|
if current_wb is not None:
|
||||||
|
# Guardar archivo actual en ZIP
|
||||||
|
part_buffer = io.BytesIO()
|
||||||
|
current_wb.save(part_buffer)
|
||||||
|
part_buffer.seek(0)
|
||||||
|
zip_file.writestr(f"datastage_part{file_counter}.xlsx", part_buffer.getvalue())
|
||||||
|
file_counter += 1
|
||||||
|
|
||||||
|
# Crear nuevo workbook
|
||||||
|
current_wb = openpyxl.Workbook()
|
||||||
|
current_wb.remove(current_wb.active) # Remover hoja por defecto
|
||||||
|
current_file_records_count = 0
|
||||||
|
|
||||||
|
# Crear hoja para esta parte del modelo
|
||||||
|
sheet_name = f"{model_name[:25]}_p{page_num}"
|
||||||
|
ws = current_wb.create_sheet(title=sheet_name[:31])
|
||||||
|
ws.append(fields)
|
||||||
|
|
||||||
|
# Escribir datos
|
||||||
|
for row in page.object_list:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
ws.append(row_values)
|
||||||
|
|
||||||
|
current_file_records_count += len(page.object_list)
|
||||||
|
|
||||||
|
else:
|
||||||
|
# Modelo pequeño (≤ MAX_RECORDS_PER_FILE)
|
||||||
|
# Verificar si necesitamos nuevo archivo
|
||||||
|
if (current_wb is None or
|
||||||
|
len(current_wb.sheetnames) >= MAX_SHEETS_PER_FILE or
|
||||||
|
current_file_records_count + total_records > self.MAX_RECORDS_PER_FILE * 3):
|
||||||
|
|
||||||
|
if current_wb is not None:
|
||||||
|
# Guardar archivo actual
|
||||||
|
part_buffer = io.BytesIO()
|
||||||
|
current_wb.save(part_buffer)
|
||||||
|
part_buffer.seek(0)
|
||||||
|
zip_file.writestr(f"datastage_part{file_counter}.xlsx", part_buffer.getvalue())
|
||||||
|
file_counter += 1
|
||||||
|
|
||||||
|
# Crear nuevo workbook
|
||||||
|
current_wb = openpyxl.Workbook()
|
||||||
|
current_wb.remove(current_wb.active)
|
||||||
|
current_file_records_count = 0
|
||||||
|
|
||||||
|
# Crear hoja para este modelo
|
||||||
|
sheet_name = model_name[:31]
|
||||||
|
ws = current_wb.create_sheet(title=sheet_name)
|
||||||
|
ws.append(fields)
|
||||||
|
|
||||||
|
# Escribir datos
|
||||||
|
for row in queryset:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
ws.append(row_values)
|
||||||
|
|
||||||
|
current_file_records_count += total_records
|
||||||
|
|
||||||
|
except LookupError:
|
||||||
|
continue
|
||||||
|
|
||||||
|
# Guardar el último workbook si existe
|
||||||
|
if current_wb is not None:
|
||||||
|
part_buffer = io.BytesIO()
|
||||||
|
current_wb.save(part_buffer)
|
||||||
|
part_buffer.seek(0)
|
||||||
|
zip_file.writestr(f"datastage_part{file_counter}.xlsx", part_buffer.getvalue())
|
||||||
|
|
||||||
|
zip_buffer.seek(0)
|
||||||
|
|
||||||
|
response = HttpResponse(zip_buffer.read(), content_type='application/zip')
|
||||||
|
response['Content-Disposition'] = 'attachment; filename="datastage_reports.zip"'
|
||||||
|
return response
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
return Response({'error': f'Error en exportación particionada: {str(e)}'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
|
||||||
|
|
||||||
|
def export_datastage_multiple_to_csv(self, request, models_data, global_filters, related_keys):
|
||||||
|
"""Exporta múltiples modelos de DataStage a múltiples archivos CSV en ZIP"""
|
||||||
|
zip_buffer = io.BytesIO()
|
||||||
|
|
||||||
|
with zipfile.ZipFile(zip_buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
|
||||||
|
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
fields = model_data.get('fields', [])
|
||||||
|
|
||||||
|
if not model_name or not fields:
|
||||||
|
continue
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
filters = self.apply_related_filters(global_filters, model, related_keys, request.user)
|
||||||
|
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
total_records = queryset.count()
|
||||||
|
|
||||||
|
if total_records == 0:
|
||||||
|
continue
|
||||||
|
|
||||||
|
csv_buffer = io.StringIO()
|
||||||
|
writer = csv.writer(csv_buffer)
|
||||||
|
writer.writerow(fields)
|
||||||
|
|
||||||
|
for row in queryset:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
writer.writerow(row_values)
|
||||||
|
|
||||||
|
# Agregar al ZIP
|
||||||
|
filename = f"{model_name}.csv"
|
||||||
|
zip_file.writestr(filename, csv_buffer.getvalue())
|
||||||
|
|
||||||
|
except LookupError:
|
||||||
|
continue
|
||||||
|
|
||||||
|
zip_buffer.seek(0)
|
||||||
|
|
||||||
|
response = HttpResponse(zip_buffer.read(), content_type='application/zip')
|
||||||
|
response['Content-Disposition'] = 'attachment; filename="datastage_reports.zip"'
|
||||||
|
return response
|
||||||
|
|
||||||
|
def export_datastage_multiple_partitioned_csv(self, request, models_data, global_filters, related_keys):
|
||||||
|
"""Exporta múltiples modelos de DataStage a múltiples archivos CSV particionados en ZIP"""
|
||||||
|
try:
|
||||||
|
zip_buffer = io.BytesIO()
|
||||||
|
|
||||||
|
with zipfile.ZipFile(zip_buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
|
||||||
|
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
fields = model_data.get('fields', [])
|
||||||
|
|
||||||
|
if not model_name or not fields:
|
||||||
|
continue
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
filters = self.apply_related_filters(global_filters, model, related_keys, request.user)
|
||||||
|
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
total_records = queryset.count()
|
||||||
|
|
||||||
|
if total_records == 0:
|
||||||
|
continue
|
||||||
|
|
||||||
|
if total_records > self.MAX_RECORDS_PER_FILE:
|
||||||
|
from django.core.paginator import Paginator
|
||||||
|
paginator = Paginator(queryset, self.MAX_RECORDS_PER_FILE)
|
||||||
|
|
||||||
|
for page_num in paginator.page_range:
|
||||||
|
page = paginator.page(page_num)
|
||||||
|
|
||||||
|
csv_buffer = io.StringIO()
|
||||||
|
writer = csv.writer(csv_buffer)
|
||||||
|
|
||||||
|
writer.writerow(fields)
|
||||||
|
|
||||||
|
for row in page.object_list:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
writer.writerow(row_values)
|
||||||
|
|
||||||
|
# Agregar al ZIP
|
||||||
|
filename = f"{model_name}_part{page_num}.csv"
|
||||||
|
zip_file.writestr(filename, csv_buffer.getvalue())
|
||||||
|
|
||||||
|
else:
|
||||||
|
# Modelo pequeño, exportar completo
|
||||||
|
csv_buffer = io.StringIO()
|
||||||
|
writer = csv.writer(csv_buffer)
|
||||||
|
|
||||||
|
# Escribir encabezados
|
||||||
|
writer.writerow(fields)
|
||||||
|
|
||||||
|
# Escribir datos
|
||||||
|
for row in queryset:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
writer.writerow(row_values)
|
||||||
|
|
||||||
|
# Agregar al ZIP
|
||||||
|
filename = f"{model_name}.csv"
|
||||||
|
zip_file.writestr(filename, csv_buffer.getvalue())
|
||||||
|
|
||||||
|
except LookupError as e:
|
||||||
|
continue
|
||||||
|
except Exception as e:
|
||||||
|
continue
|
||||||
|
|
||||||
|
zip_buffer.seek(0)
|
||||||
|
|
||||||
|
response = HttpResponse(zip_buffer.read(), content_type='application/zip')
|
||||||
|
response['Content-Disposition'] = 'attachment; filename="datastage_reports.zip"'
|
||||||
|
return response
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
return Response({'error': f'Error en exportación CSV particionada: {str(e)}'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
|
||||||
|
|
||||||
|
def export_single_model_partitioned(self, request, model_name, fields, filters, total_records):
|
||||||
|
"""Exporta un solo modelo particionado a ZIP"""
|
||||||
|
try:
|
||||||
|
zip_buffer = io.BytesIO()
|
||||||
|
module = 'datastage'
|
||||||
|
|
||||||
|
model = apps.get_model(module, model_name)
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
|
||||||
|
with zipfile.ZipFile(zip_buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
|
||||||
|
from django.core.paginator import Paginator
|
||||||
|
paginator = Paginator(queryset, self.MAX_RECORDS_PER_FILE)
|
||||||
|
|
||||||
|
for page_num in paginator.page_range:
|
||||||
|
page = paginator.page(page_num)
|
||||||
|
|
||||||
|
# Crear Excel para esta parte
|
||||||
|
wb = openpyxl.Workbook()
|
||||||
|
ws = wb.active
|
||||||
|
ws.title = f"Parte_{page_num}"[:31]
|
||||||
|
ws.append(fields)
|
||||||
|
|
||||||
|
for row in page.object_list:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
ws.append(row_values)
|
||||||
|
|
||||||
|
part_buffer = io.BytesIO()
|
||||||
|
wb.save(part_buffer)
|
||||||
|
part_buffer.seek(0)
|
||||||
|
|
||||||
|
filename = f"{model_name}_part{page_num}.xlsx"
|
||||||
|
zip_file.writestr(filename, part_buffer.getvalue())
|
||||||
|
|
||||||
|
zip_buffer.seek(0)
|
||||||
|
zip_content = zip_buffer.getvalue()
|
||||||
|
|
||||||
|
response = HttpResponse(zip_content, content_type='application/zip')
|
||||||
|
response['Content-Disposition'] = f'attachment; filename="{model_name}_particionado.zip"'
|
||||||
|
response['Content-Length'] = len(zip_content)
|
||||||
|
|
||||||
|
return response
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
return Response({'error': f'Error exportando modelo: {str(e)}'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
|
||||||
|
|
||||||
|
def export_single_model_csv_partitioned(self, request, model_name, fields, filters, total_records):
|
||||||
|
"""Exporta un solo modelo CSV particionado a ZIP"""
|
||||||
|
try:
|
||||||
|
zip_buffer = io.BytesIO()
|
||||||
|
module = 'datastage'
|
||||||
|
|
||||||
|
model = apps.get_model(module, model_name)
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
|
||||||
|
with zipfile.ZipFile(zip_buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
|
||||||
|
from django.core.paginator import Paginator
|
||||||
|
paginator = Paginator(queryset, self.MAX_RECORDS_PER_FILE)
|
||||||
|
|
||||||
|
for page_num in paginator.page_range:
|
||||||
|
page = paginator.page(page_num)
|
||||||
|
|
||||||
|
csv_buffer = io.StringIO()
|
||||||
|
writer = csv.writer(csv_buffer)
|
||||||
|
writer.writerow(fields)
|
||||||
|
|
||||||
|
for row in page.object_list:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
writer.writerow(row_values)
|
||||||
|
|
||||||
|
# Agregar al ZIP
|
||||||
|
filename = f"{model_name}_part{page_num}.csv"
|
||||||
|
zip_file.writestr(filename, csv_buffer.getvalue())
|
||||||
|
|
||||||
|
zip_buffer.seek(0)
|
||||||
|
|
||||||
|
zip_content = zip_buffer.getvalue()
|
||||||
|
|
||||||
|
response = HttpResponse(zip_content, content_type='application/zip')
|
||||||
|
response['Content-Disposition'] = f'attachment; filename="{model_name}_particionado.zip"'
|
||||||
|
response['Content-Length'] = len(zip_content)
|
||||||
|
|
||||||
|
return response
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
return Response({'error': f'Error exportando modelo CSV: {str(e)}'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
|
||||||
|
|
||||||
|
def get_related_keys_from_filters(self, global_filters, models_data, user):
|
||||||
|
"""
|
||||||
|
Obtiene patentes, pedimentos y datastages que cumplen EXACTAMENTE con TODOS los filtros globales
|
||||||
|
VERSIÓN SIMPLIFICADA - Usa la MISMA lógica que apply_global_filters_to_model
|
||||||
|
"""
|
||||||
|
related_keys = {
|
||||||
|
'patentes': set(),
|
||||||
|
'pedimentos': set(),
|
||||||
|
'datastage_ids': set()
|
||||||
|
}
|
||||||
|
|
||||||
|
# Si no hay filtros, retornar vacío
|
||||||
|
if not any(v for v in global_filters.values() if v not in [None, '']):
|
||||||
|
return {}
|
||||||
|
|
||||||
|
all_records_with_filters = []
|
||||||
|
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
|
||||||
|
# ¡USAR LA MISMA FUNCIÓN QUE EN MODO SINGULAR!
|
||||||
|
filters = self.apply_global_filters_to_model(global_filters, model, user)
|
||||||
|
|
||||||
|
if filters:
|
||||||
|
# EJECUTAR CONSULTA - IDÉNTICO A MODO SINGULAR
|
||||||
|
queryset = model.objects.filter(**filters)
|
||||||
|
total = queryset.count()
|
||||||
|
|
||||||
|
# VERIFICACIÓN ESPECIAL PARA RFC
|
||||||
|
if 'rfc' in filters:
|
||||||
|
rfc_value = filters['rfc']
|
||||||
|
# Doble verificación: contar registros con ese RFC exacto
|
||||||
|
rfc_exact_count = queryset.filter(rfc=rfc_value).count()
|
||||||
|
|
||||||
|
if rfc_exact_count != total:
|
||||||
|
try:
|
||||||
|
other_rfcs = queryset.exclude(rfc=rfc_value).values_list('rfc', flat=True).distinct()[:5]
|
||||||
|
except:
|
||||||
|
pass
|
||||||
|
|
||||||
|
# Obtener registros
|
||||||
|
records = queryset.values('patente', 'pedimento', 'datastage_id')
|
||||||
|
all_records_with_filters.extend(list(records))
|
||||||
|
|
||||||
|
except LookupError:
|
||||||
|
continue
|
||||||
|
|
||||||
|
if not all_records_with_filters:
|
||||||
|
return {'patentes': set(), 'pedimentos': set(), 'datastage_ids': set()}
|
||||||
|
|
||||||
|
for record in all_records_with_filters:
|
||||||
|
if record.get('patente'):
|
||||||
|
related_keys['patentes'].add(record['patente'])
|
||||||
|
if record.get('pedimento'):
|
||||||
|
related_keys['pedimentos'].add(record['pedimento'])
|
||||||
|
if record.get('datastage_id'):
|
||||||
|
related_keys['datastage_ids'].add(record['datastage_id'])
|
||||||
|
|
||||||
|
return {k: list(v) for k, v in related_keys.items() if v}
|
||||||
|
|
||||||
|
def apply_global_filters_to_model(self, global_filters, model, user):
|
||||||
|
"""
|
||||||
|
Aplica filtros globales - VERSIÓN CORREGIDA CON UUID
|
||||||
|
"""
|
||||||
|
|
||||||
|
filters = {}
|
||||||
|
model_fields = [f.name for f in model._meta.get_fields()]
|
||||||
|
|
||||||
|
# ORGANIZACIÓN - Manejar como UUID
|
||||||
|
org_value = global_filters.get('organizacion')
|
||||||
|
if org_value and org_value != '' and 'organizacion' in model_fields:
|
||||||
|
field = model._meta.get_field('organizacion')
|
||||||
|
|
||||||
|
if hasattr(field, 'related_model'): # Es ForeignKey
|
||||||
|
# Convertir string a UUID
|
||||||
|
try:
|
||||||
|
import uuid
|
||||||
|
org_uuid = uuid.UUID(org_value)
|
||||||
|
filters['organizacion_id'] = org_uuid
|
||||||
|
except Exception as e:
|
||||||
|
# Fallback: dejar como string (puede no funcionar)
|
||||||
|
filters['organizacion_id'] = org_value
|
||||||
|
else: # Es CharField
|
||||||
|
filters['organizacion'] = org_value
|
||||||
|
|
||||||
|
# RFC - Manejar normalmente
|
||||||
|
rfc_value = global_filters.get('rfc')
|
||||||
|
if rfc_value and rfc_value != '' and 'rfc' in model_fields:
|
||||||
|
filters['rfc'] = rfc_value
|
||||||
|
|
||||||
|
# PATENTE
|
||||||
|
if global_filters.get('patente'):
|
||||||
|
filters['patente'] = global_filters['patente']
|
||||||
|
|
||||||
|
# PEDIMENTO
|
||||||
|
if global_filters.get('pedimento'):
|
||||||
|
filters['pedimento'] = global_filters['pedimento']
|
||||||
|
|
||||||
|
# FECHAS
|
||||||
|
if 'fecha_pago_real' in model_fields:
|
||||||
|
if global_filters.get('fecha_pago_desde'):
|
||||||
|
filters['fecha_pago_real__gte'] = global_filters['fecha_pago_desde']
|
||||||
|
|
||||||
|
if global_filters.get('fecha_pago_hasta'):
|
||||||
|
filters['fecha_pago_real__lte'] = global_filters['fecha_pago_hasta']
|
||||||
|
|
||||||
|
return filters
|
||||||
|
|
||||||
|
def apply_related_filters(self, global_filters, model, related_keys, user):
|
||||||
|
filters = {}
|
||||||
|
model_fields = [f.name for f in model._meta.get_fields()]
|
||||||
|
|
||||||
|
# 1. Organización
|
||||||
|
if 'organizacion' in model_fields and global_filters.get('organizacion'):
|
||||||
|
filters['organizacion'] = global_filters['organizacion']
|
||||||
|
|
||||||
|
# 2. RFC (¡ESTO ES LO QUE FALTA!)
|
||||||
|
if 'rfc' in model_fields and global_filters.get('rfc'):
|
||||||
|
filters['rfc'] = global_filters['rfc']
|
||||||
|
|
||||||
|
# 3. Fechas (SIEMPRE se aplican)
|
||||||
|
if 'fecha_pago_real' in model_fields:
|
||||||
|
if global_filters.get('fecha_pago_desde'):
|
||||||
|
filters['fecha_pago_real__gte'] = global_filters['fecha_pago_desde']
|
||||||
|
|
||||||
|
if global_filters.get('fecha_pago_hasta'):
|
||||||
|
filters['fecha_pago_real__lte'] = global_filters['fecha_pago_hasta']
|
||||||
|
|
||||||
|
# 🔥 SEGUNDO: Si hay related_keys, AÑADIRLAS a los filtros existentes
|
||||||
|
if any(related_keys.values()):
|
||||||
|
|
||||||
|
# Añadir patentes si existen
|
||||||
|
if related_keys.get('patentes') and 'patente' in model_fields:
|
||||||
|
filters['patente__in'] = related_keys['patentes']
|
||||||
|
|
||||||
|
# Añadir pedimentos si existen
|
||||||
|
if related_keys.get('pedimentos') and 'pedimento' in model_fields:
|
||||||
|
filters['pedimento__in'] = related_keys['pedimentos']
|
||||||
|
|
||||||
|
# Añadir datastage_ids si existen
|
||||||
|
if related_keys.get('datastage_ids') and 'datastage_id' in model_fields:
|
||||||
|
filters['datastage_id__in'] = related_keys['datastage_ids']
|
||||||
|
|
||||||
|
else:
|
||||||
|
# Solo patente y pedimento específicos (no listas)
|
||||||
|
if 'patente' in model_fields and global_filters.get('patente'):
|
||||||
|
filters['patente'] = global_filters['patente']
|
||||||
|
|
||||||
|
if 'pedimento' in model_fields and global_filters.get('pedimento'):
|
||||||
|
filters['pedimento'] = global_filters['pedimento']
|
||||||
|
|
||||||
|
return filters
|
||||||
|
|
||||||
|
def estimate_excel_file_size(self, num_records, num_columns):
|
||||||
|
"""Estima tamaño aproximado del archivo Excel"""
|
||||||
|
# Estimación aproximada: 100 bytes por celda
|
||||||
|
return num_records * num_columns * 100
|
||||||
|
|
||||||
|
def export_with_size_control(self, request, models_data, global_filters, related_keys):
|
||||||
|
"""Versión con control de tamaño de archivo"""
|
||||||
|
try:
|
||||||
|
zip_buffer = io.BytesIO()
|
||||||
|
|
||||||
|
with zipfile.ZipFile(zip_buffer, 'w', zipfile.ZIP_DEFLATED) as zip_file:
|
||||||
|
file_counter = 1
|
||||||
|
current_wb = None
|
||||||
|
current_file_size_estimate = 0
|
||||||
|
MAX_FILE_SIZE_ESTIMATE = 50 * 1024 * 1024 # 50MB estimado
|
||||||
|
|
||||||
|
for model_data in models_data:
|
||||||
|
model_name = model_data.get('model')
|
||||||
|
fields = model_data.get('fields', [])
|
||||||
|
|
||||||
|
if not model_name or not fields:
|
||||||
|
continue
|
||||||
|
|
||||||
|
try:
|
||||||
|
model = apps.get_model('datastage', model_name)
|
||||||
|
filters = self.apply_related_filters(global_filters, model, related_keys, request.user)
|
||||||
|
|
||||||
|
if filters:
|
||||||
|
queryset = model.objects.filter(**filters).values(*fields)
|
||||||
|
else:
|
||||||
|
queryset = model.objects.none()
|
||||||
|
|
||||||
|
total_records = queryset.count()
|
||||||
|
|
||||||
|
if total_records == 0:
|
||||||
|
continue
|
||||||
|
|
||||||
|
# Calcular tamaño estimado para este modelo
|
||||||
|
model_size_estimate = self.estimate_excel_file_size(total_records, len(fields))
|
||||||
|
|
||||||
|
# Si el modelo es muy grande o no cabe en el archivo actual
|
||||||
|
needs_new_file = (
|
||||||
|
current_wb is None or
|
||||||
|
current_file_size_estimate + model_size_estimate > MAX_FILE_SIZE_ESTIMATE or
|
||||||
|
(total_records > self.MAX_RECORDS_PER_FILE and current_file_size_estimate > 0)
|
||||||
|
)
|
||||||
|
|
||||||
|
if needs_new_file and current_wb is not None:
|
||||||
|
# Guardar archivo actual
|
||||||
|
part_buffer = io.BytesIO()
|
||||||
|
current_wb.save(part_buffer)
|
||||||
|
part_buffer.seek(0)
|
||||||
|
zip_file.writestr(f"datastage_part{file_counter}.xlsx", part_buffer.getvalue())
|
||||||
|
file_counter += 1
|
||||||
|
current_wb = None
|
||||||
|
current_file_size_estimate = 0
|
||||||
|
|
||||||
|
if current_wb is None:
|
||||||
|
current_wb = openpyxl.Workbook()
|
||||||
|
current_wb.remove(current_wb.active)
|
||||||
|
|
||||||
|
# Manejar modelos que exceden el límite por hoja
|
||||||
|
if total_records > self.MAX_RECORDS_PER_FILE:
|
||||||
|
from django.core.paginator import Paginator
|
||||||
|
paginator = Paginator(queryset, self.MAX_RECORDS_PER_FILE)
|
||||||
|
|
||||||
|
for page_num in paginator.page_range:
|
||||||
|
page = paginator.page(page_num)
|
||||||
|
|
||||||
|
# Crear hoja para esta parte
|
||||||
|
sheet_name = f"{model_name[:20]}_p{page_num}"[:31]
|
||||||
|
ws = current_wb.create_sheet(title=sheet_name)
|
||||||
|
ws.append(fields)
|
||||||
|
|
||||||
|
for row in page.object_list:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
ws.append(row_values)
|
||||||
|
|
||||||
|
# Actualizar tamaño estimado
|
||||||
|
page_size = self.estimate_excel_file_size(len(page.object_list), len(fields))
|
||||||
|
current_file_size_estimate += page_size
|
||||||
|
|
||||||
|
else:
|
||||||
|
# Modelo pequeño, una hoja
|
||||||
|
sheet_name = model_name[:31]
|
||||||
|
ws = current_wb.create_sheet(title=sheet_name)
|
||||||
|
ws.append(fields)
|
||||||
|
|
||||||
|
for row in queryset:
|
||||||
|
row_values = [self.safe_excel_value(row[field]) for field in fields]
|
||||||
|
ws.append(row_values)
|
||||||
|
|
||||||
|
current_file_size_estimate += model_size_estimate
|
||||||
|
|
||||||
|
except LookupError:
|
||||||
|
continue
|
||||||
|
|
||||||
|
# Guardar último archivo si existe
|
||||||
|
if current_wb is not None:
|
||||||
|
part_buffer = io.BytesIO()
|
||||||
|
current_wb.save(part_buffer)
|
||||||
|
part_buffer.seek(0)
|
||||||
|
zip_file.writestr(f"datastage_part{file_counter}.xlsx", part_buffer.getvalue())
|
||||||
|
|
||||||
|
zip_buffer.seek(0)
|
||||||
|
|
||||||
|
response = HttpResponse(zip_buffer.read(), content_type='application/zip')
|
||||||
|
response['Content-Disposition'] = 'attachment; filename="datastage_reports.zip"'
|
||||||
|
return response
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
return Response({'error': f'Error: {str(e)}'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
|
||||||
|
|
||||||
class ExportModelView(APIView):
|
class ExportModelView(APIView):
|
||||||
my_tags = ['Reportes']
|
my_tags = ['Reportes']
|
||||||
permission_classes = [IsAuthenticated & (
|
permission_classes = [IsAuthenticated & (IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper | IsSuperUser)]
|
||||||
IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper | IsSuperUser)]
|
|
||||||
|
|
||||||
@swagger_auto_schema(
|
@swagger_auto_schema(
|
||||||
manual_parameters=[
|
manual_parameters=[
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
from api.reports.models import ReportDocument
|
from api.reports.models import ReportDocument
|
||||||
from api.reports.tasks.report_document import generate_report_document
|
from api.reports.tasks.report_document import generate_report_document, generate_report_control_pedimento
|
||||||
from django.http import FileResponse
|
from django.http import FileResponse
|
||||||
from rest_framework.decorators import api_view, permission_classes
|
from rest_framework.decorators import api_view, permission_classes
|
||||||
from rest_framework.permissions import IsAuthenticated
|
from rest_framework.permissions import IsAuthenticated
|
||||||
@@ -11,7 +11,10 @@ def table_summary(request):
|
|||||||
"""
|
"""
|
||||||
Solo dispara la tarea asíncrona para generar el reporte CSV. No consulta ni procesa datos.
|
Solo dispara la tarea asíncrona para generar el reporte CSV. No consulta ni procesa datos.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
org_id = request.query_params.get('organizacion_id')
|
org_id = request.query_params.get('organizacion_id')
|
||||||
|
# hasta aqui si llega y crea el registro en la base de datos
|
||||||
|
print(f'🖼️🖼️🖼️🖼️🖼️🖼️🖼️ table_summary organizacion id = {org_id}')
|
||||||
if not org_id:
|
if not org_id:
|
||||||
return Response({"error": "organizacion_id es requerido"}, status=400)
|
return Response({"error": "organizacion_id es requerido"}, status=400)
|
||||||
# Obtener filtros de query params
|
# Obtener filtros de query params
|
||||||
@@ -60,7 +63,8 @@ def table_summary(request):
|
|||||||
report = ReportDocument.objects.create(
|
report = ReportDocument.objects.create(
|
||||||
user=request.user,
|
user=request.user,
|
||||||
filters=filtros,
|
filters=filtros,
|
||||||
status='pending'
|
status='pending',
|
||||||
|
report_type='cumplimiento'
|
||||||
)
|
)
|
||||||
generate_report_document.delay(report.id)
|
generate_report_document.delay(report.id)
|
||||||
return Response({
|
return Response({
|
||||||
@@ -94,6 +98,7 @@ def report_document_list(request):
|
|||||||
data = [
|
data = [
|
||||||
{
|
{
|
||||||
"report_id": r.id,
|
"report_id": r.id,
|
||||||
|
"report_type": r.report_type,
|
||||||
"status": r.status,
|
"status": r.status,
|
||||||
"created_at": r.created_at,
|
"created_at": r.created_at,
|
||||||
"finished_at": r.finished_at,
|
"finished_at": r.finished_at,
|
||||||
@@ -114,4 +119,50 @@ def report_document_download(request, report_id):
|
|||||||
response = FileResponse(report.file.open('rb'), as_attachment=True, filename=report.file.name)
|
response = FileResponse(report.file.open('rb'), as_attachment=True, filename=report.file.name)
|
||||||
return response
|
return response
|
||||||
except ReportDocument.DoesNotExist:
|
except ReportDocument.DoesNotExist:
|
||||||
return Response({"error": "Reporte no encontrado"}, status=404)
|
return Response({"error": "Reporte no encontrado"}, status=404)
|
||||||
|
|
||||||
|
@api_view(['GET'])
|
||||||
|
@permission_classes([IsAuthenticated])
|
||||||
|
def control_pedimento(request):
|
||||||
|
"""
|
||||||
|
Dispara la tarea asíncrona para generar el reporte CSV de control de Pedimentos.
|
||||||
|
"""
|
||||||
|
org_id = request.query_params.get('organizacion_id')
|
||||||
|
|
||||||
|
if not org_id:
|
||||||
|
return Response({"error": "organizacion_id es requerido"}, status=400)
|
||||||
|
|
||||||
|
# Simplificar la lógica de fechas
|
||||||
|
fecha_pago_gte = request.query_params.get('fecha_pago__gte')
|
||||||
|
fecha_pago_lte = request.query_params.get('fecha_pago__lte')
|
||||||
|
pedimento_app = request.query_params.get('pedimento_app')
|
||||||
|
|
||||||
|
# Si las fechas vienen como string, mantenerlas como están
|
||||||
|
fecha_pago_gte_str = fecha_pago_gte if fecha_pago_gte else None
|
||||||
|
fecha_pago_lte_str = fecha_pago_lte if fecha_pago_lte else None
|
||||||
|
|
||||||
|
filtros = {
|
||||||
|
"pedimento_app": pedimento_app,
|
||||||
|
"organizacion_id": org_id,
|
||||||
|
"fecha_pago__gte": fecha_pago_gte_str,
|
||||||
|
"fecha_pago__lte": fecha_pago_lte_str,
|
||||||
|
}
|
||||||
|
|
||||||
|
# Crear el reporte
|
||||||
|
report = ReportDocument.objects.create(
|
||||||
|
user=request.user,
|
||||||
|
filters=filtros,
|
||||||
|
status='pending',
|
||||||
|
report_type='control_pedimento'
|
||||||
|
)
|
||||||
|
|
||||||
|
# Disparar la tarea asíncrona
|
||||||
|
generate_report_control_pedimento.delay(report.id)
|
||||||
|
|
||||||
|
return Response({
|
||||||
|
"report_id": report.id,
|
||||||
|
"status": report.status,
|
||||||
|
"created_at": report.created_at,
|
||||||
|
"message": "Reporte en proceso de generación",
|
||||||
|
"download_url": report.file.url if report.file else None
|
||||||
|
}, status=202)
|
||||||
Reference in New Issue
Block a user