EFC/backend
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: EFC:T2025-10-021
Branches Tags
EFC:main EFC:feature/minio-implementation EFC:filtros-doctype EFC:formato-pedimento-completo EFC:pedimento-app-patente EFC:efc-nuevos-cambios EFC:T2026-01-098 EFC:T2025-12-100 EFC:T2025-09-056 EFC:T2026-01-032 EFC:req--T2025-08-098 EFC:fix-ejecucion-manual-proceso-pedimento-completo EFC:T2025-09-004 EFC:fix-T2025-09-007 EFC:only-datastage EFC:datastage-autoprocesar EFC:celery-pedimentos EFC:T2025-10-152-001 EFC:Fix--Auditor-backend EFC:duplicidad-documentos EFC:FIX2025-10-021 EFC:correccion-reportes EFC:T2025-10-021 EFC:T2025-10-152 EFC:reportes EFC:T2025-09-007 EFC:T2025-09-020 EFC:feature/Agendar-todos EFC:feature/bulk-document-upload-nomenclatura EFC:feature/bulk-delete-endpoints
..
compare: EFC:FIX2025-10-021
Branches Tags
EFC:main EFC:feature/minio-implementation EFC:filtros-doctype EFC:formato-pedimento-completo EFC:pedimento-app-patente EFC:efc-nuevos-cambios EFC:T2026-01-098 EFC:T2025-12-100 EFC:T2025-09-056 EFC:T2026-01-032 EFC:req--T2025-08-098 EFC:fix-ejecucion-manual-proceso-pedimento-completo EFC:T2025-09-004 EFC:fix-T2025-09-007 EFC:only-datastage EFC:datastage-autoprocesar EFC:celery-pedimentos EFC:T2025-10-152-001 EFC:Fix--Auditor-backend EFC:duplicidad-documentos EFC:FIX2025-10-021 EFC:correccion-reportes EFC:T2025-10-021 EFC:T2025-10-152 EFC:reportes EFC:T2025-09-007 EFC:T2025-09-020 EFC:feature/Agendar-todos EFC:feature/bulk-document-upload-nomenclatura EFC:feature/bulk-delete-endpoints

1 Commits
T2025-10-0 ... FIX2025-10

Author SHA1 Message Date
Luis
1cb2830d71 fix: se quitan los print del endpoint bulk-create-pedimento_desk 2025-12-16 08:30:49 -07:00
1 changed files with 56 additions and 50 deletions
Expand all files Collapse all files

106
api/customs/views.py
View File

@@ -976,35 +976,41 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
temp_dir = None temp_dir = None
# Obtener DocumentType ANTES de la transacción atómica # Obtener DocumentType ANTES de la transacción atómica
print("Intentando obtener o crear DocumentType...") # print("Intentando obtener o crear DocumentType...")
try: try:
# Primero intentar obtener si ya existe # Primero intentar obtener si ya existe
try: try:
document_type = DocumentType.objects.get(nombre="Pedimento") document_type = DocumentType.objects.get(nombre="Pedimento")
print(f"DocumentType obtenido existente: {document_type.nombre} (ID: {document_type.id})") # print(f"DocumentType obtenido existente: {document_type.nombre} (ID: {document_type.id})")
except DocumentType.DoesNotExist: except DocumentType.DoesNotExist:
# Si no existe, crear uno nuevo # Si no existe, crear uno nuevo
document_type = DocumentType.objects.create( document_type = DocumentType.objects.create(
nombre="Pedimento", nombre="Pedimento",
descripcion="Documento de pedimento" descripcion="Documento de pedimento"
) )
print(f"DocumentType creado nuevo: {document_type.nombre} (ID: {document_type.id})") # print(f"DocumentType creado nuevo: {document_type.nombre} (ID: {document_type.id})")
except Exception as e: except Exception as e:
print(f"Error al obtener/crear DocumentType: {str(e)}") # print(f"Error al obtener/crear DocumentType: {str(e)}")
# Como fallback, intentar obtener cualquier DocumentType existente # Como fallback, intentar obtener cualquier DocumentType existente
try: 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() document_type = DocumentType.objects.first()
if document_type: if not document_type:
print(f"Usando DocumentType existente como fallback: {document_type.nombre} (ID: {document_type.id})")
else:
print("No hay DocumentType disponible")
return Response( return Response(
{"error": "No se pudo configurar el tipo de documento y no hay tipos existentes"}, {"error": "No se pudo configurar el tipo de documento y no hay tipos existentes"},
status=status.HTTP_500_INTERNAL_SERVER_ERROR status=status.HTTP_500_INTERNAL_SERVER_ERROR
) )
except Exception as fallback_error: except Exception as fallback_error:
print(f"Error en fallback: {str(fallback_error)}") # print(f"Error en fallback: {str(fallback_error)}")
return Response( return Response(
{ {
"tieneError": True, "tieneError": True,
@@ -1014,30 +1020,30 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
) )
try: try:
print("Iniciando transacción atómica...") # print("Iniciando transacción atómica...")
with transaction.atomic(): with transaction.atomic():
# Crear directorio temporal # Crear directorio temporal
temp_dir = tempfile.mkdtemp() temp_dir = tempfile.mkdtemp()
print(f"Directorio temporal creado: {temp_dir}") # print(f"Directorio temporal creado: {temp_dir}")
# Procesar cada archivo enviado # Procesar cada archivo enviado
for idx, archivo in enumerate(archivos): for idx, archivo in enumerate(archivos):
archivo_name = archivo.name.lower() archivo_name = archivo.name.lower()
print(f"Procesando archivo {idx + 1}/{len(archivos)}: {archivo_name}") # print(f"Procesando archivo {idx + 1}/{len(archivos)}: {archivo_name}")
# Crear subdirectorio para cada archivo usando el nombre del archivo sin extensión # Crear subdirectorio para cada archivo usando el nombre del archivo sin extensión
archivo_name_sin_extension = os.path.splitext(archivo.name)[0] archivo_name_sin_extension = os.path.splitext(archivo.name)[0]
sub_dir = os.path.join(temp_dir, archivo_name_sin_extension) sub_dir = os.path.join(temp_dir, archivo_name_sin_extension)
os.makedirs(sub_dir, exist_ok=True) os.makedirs(sub_dir, exist_ok=True)
print(f"Subdirectorio creado: {sub_dir}") # print(f"Subdirectorio creado: {sub_dir}")
if archivo_name.endswith('.zip'): if archivo_name.endswith('.zip'):
# Manejar archivo ZIP # Manejar archivo ZIP
print("Es un archivo ZIP") # print("Es un archivo ZIP")
try: try:
with zipfile.ZipFile(archivo, 'r') as zip_ref: with zipfile.ZipFile(archivo, 'r') as zip_ref:
zip_ref.extractall(sub_dir) zip_ref.extractall(sub_dir)
print("Archivo ZIP extraído exitosamente") # print("Archivo ZIP extraído exitosamente")
except zipfile.BadZipFile as e: except zipfile.BadZipFile as e:
return Response( return Response(
{ {
@@ -1063,7 +1069,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
f.write(chunk) f.write(chunk)
try: try:
extract_rar_to_dir(archivo_temp_path, sub_dir) extract_rar_to_dir(archivo_temp_path, sub_dir)
print(f"Archivo RAR {archivo.name} extraído en {sub_dir}") # print(f"Archivo RAR {archivo.name} extraído en {sub_dir}")
except Exception as e: except Exception as e:
error_msg = str(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." help_msg = "Instale 'unrar' o 'p7zip' (7z) y asegúrese de que estén en PATH, o instale y configure 'rarfile' con un backend."
@@ -1081,21 +1087,21 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
with open(archivo_path, 'wb') as f: with open(archivo_path, 'wb') as f:
for chunk in archivo.chunks(): for chunk in archivo.chunks():
f.write(chunk) f.write(chunk)
print(f"Archivo individual {archivo.name} guardado en sub_dir:", archivo_path) # print(f"Archivo individual {archivo.name} guardado en sub_dir:", archivo_path)
# Recorrer todos los archivos extraídos o el directorio # Recorrer todos los archivos extraídos o el directorio
print("Iniciando recorrido de archivos...") print("Iniciando recorrido de archivos...")
for root, dirs, files in os.walk(temp_dir): for root, dirs, files in os.walk(temp_dir):
print(f"Revisando directorio: {root}") # print(f"Revisando directorio: {root}")
print(f"Archivos encontrados: {files}") # print(f"Archivos encontrados: {files}")
for file_name in files: for file_name in files:
print(f"Procesando archivo: {file_name}") # print(f"Procesando archivo: {file_name}")
file_path = os.path.join(root, file_name) file_path = os.path.join(root, file_name)
# Obtener la ruta relativa para determinar la estructura de carpetas # Obtener la ruta relativa para determinar la estructura de carpetas
relative_path = os.path.relpath(file_path, temp_dir) relative_path = os.path.relpath(file_path, temp_dir)
print(f"Ruta relativa: {relative_path}") # print(f"Ruta relativa: {relative_path}")
# Determinar si el archivo está en una carpeta que sigue la nomenclatura # Determinar si el archivo está en una carpeta que sigue la nomenclatura
folder_name = None folder_name = None
@@ -1107,14 +1113,14 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
# El archivo está en la raíz, usar el nombre del archivo sin extensión # El archivo está en la raíz, usar el nombre del archivo sin extensión
folder_name = os.path.splitext(file_name)[0] folder_name = os.path.splitext(file_name)[0]
print(f"Folder name para validación: {folder_name}") # print(f"Folder name para validación: {folder_name}")
# Validar nomenclatura # Validar nomenclatura
match = nomenclatura_pattern.match(folder_name) match = nomenclatura_pattern.match(folder_name)
match_sin_anio = nomenclatura_pattern_sin_anio.match(folder_name) match_sin_anio = nomenclatura_pattern_sin_anio.match(folder_name)
if not match and not match_sin_anio: if not match and not match_sin_anio:
print(f"Nomenclatura inválida: {folder_name}") # print(f"Nomenclatura inválida: {folder_name}")
# Determinar el archivo original basado en el subdirectorio # 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') archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
failed_files.append({ failed_files.append({
@@ -1126,16 +1132,16 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
if match: if match:
print(f"Nomenclatura válida: {folder_name}") # print(f"Nomenclatura válida: {folder_name}")
anio, aduana, patente, pedimento_num = match.groups() anio, aduana, patente, pedimento_num = match.groups()
print(f"Extraído - Año: {anio}, Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}") # print(f"Extraído - Año: {anio}, Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
# Formato original: anio-aduana-patente-pedimento # Formato original: anio-aduana-patente-pedimento
# Crear fecha_pago basada en el año # Crear fecha_pago basada en el año
try: try:
# Convertir año de 2 dígitos a 4 dígitos # Convertir año de 2 dígitos a 4 dígitos
anio_completo = 2000 + int(anio) if int(anio) < 50 else 1900 + int(anio) anio_completo = 2000 + int(anio) if int(anio) < 50 else 1900 + int(anio)
fecha_pago = datetime(anio_completo, 1, 1).date() fecha_pago = datetime(anio_completo, 1, 1).date()
print(f"Fecha de pago calculada: {fecha_pago}") # print(f"Fecha de pago calculada: {fecha_pago}")
except ValueError: except ValueError:
archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar') archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
failed_files.append({ failed_files.append({
@@ -1147,11 +1153,11 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
elif match_sin_anio: elif match_sin_anio:
print(f"Nomenclatura válida sin año: {folder_name}") # print(f"Nomenclatura válida sin año: {folder_name}")
# Formato sin año: aduana-patente-pedimento # Formato sin año: aduana-patente-pedimento
aduana, patente, pedimento_num = match_sin_anio.groups() aduana, patente, pedimento_num = match_sin_anio.groups()
print(f"Extraído - Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}") # print(f"Extraído - Aduana: {aduana}, Patente: {patente}, Pedimento: {pedimento_num}")
# Obtener el primer dígito del pedimento # Obtener el primer dígito del pedimento
primer_digito_pedimento = int(pedimento_num[0]) if pedimento_num else 0 primer_digito_pedimento = int(pedimento_num[0]) if pedimento_num else 0
@@ -1176,12 +1182,12 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
# Crear fecha de pago (primer día del año) # Crear fecha de pago (primer día del año)
fecha_pago = datetime(año_final , 1, 1).date() fecha_pago = datetime(año_final , 1, 1).date()
print(f"Fecha de pago (año actual) calculada: {fecha_pago}") # print(f"Fecha de pago (año actual) calculada: {fecha_pago}")
# Generar pedimento_app # Generar pedimento_app
pedimento_app = f"{anio}-{aduana.zfill(2)}-{patente}-{pedimento_num}" pedimento_app = f"{anio}-{aduana.zfill(2)}-{patente}-{pedimento_num}"
print(f"Pedimento_app generado: {pedimento_app}") # print(f"Pedimento_app generado: {pedimento_app}")
print(f"Buscando pedimento existente con pedimento_app: {pedimento_app} y organización ID: {organizacion.id}") # print(f"Buscando pedimento existente con pedimento_app: {pedimento_app} y organización ID: {organizacion.id}")
# Verificar si el pedimento ya existe # Verificar si el pedimento ya existe
existing_pedimento = Pedimento.objects.filter( existing_pedimento = Pedimento.objects.filter(
pedimento=int(pedimento_num), pedimento=int(pedimento_num),
@@ -1189,18 +1195,18 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
organizacion=organizacion organizacion=organizacion
).first() ).first()
print(f"Pedimento existente: {existing_pedimento is not None}") # print(f"Pedimento existente: {existing_pedimento is not None}")
if not existing_pedimento: if not existing_pedimento:
print("📝 Pedimento no existe, creando nuevo...") # print("📝 Pedimento no existe, creando nuevo...")
# Crear nuevo pedimento # Crear nuevo pedimento
try: try:
print("🔄 Iniciando creación de pedimento...") # print("🔄 Iniciando creación de pedimento...")
importador = None importador = None
if contribuyente: if contribuyente:
# Obtener o crear el importador # Obtener o crear el importador
print(f"🏢 Buscando/creando importador con RFC: {contribuyente}") # print(f"🏢 Buscando/creando importador con RFC: {contribuyente}")
importador, created = Importador.objects.get_or_create( importador, created = Importador.objects.get_or_create(
rfc=contribuyente, rfc=contribuyente,
defaults={ defaults={
@@ -1208,10 +1214,10 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
'organizacion': organizacion 'organizacion': organizacion
} }
) )
if created: # if created:
print(f"✅ Importador creado: {importador.rfc} - {importador.nombre}") # print(f"✅ Importador creado: {importador.rfc} - {importador.nombre}")
else: # else:
print(f"♻️ Importador existente: {importador.rfc} - {importador.nombre}") # print(f"♻️ Importador existente: {importador.rfc} - {importador.nombre}")
if tipo_operacion_input: if tipo_operacion_input:
tipo_operacion_input = TipoOperacion.objects.get(id=tipo_operacion_input) tipo_operacion_input = TipoOperacion.objects.get(id=tipo_operacion_input)
@@ -1232,7 +1238,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
clave_pedimento=clave_pedimento_input if clave_pedimento_input else "A1" # 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}") # print(f"✅ Pedimento creado exitosamente: ID {pedimento.id}, pedimento_app: {pedimento_app}")
created_pedimentos.append({ created_pedimentos.append({
"id": str(pedimento.id), "id": str(pedimento.id),
@@ -1242,7 +1248,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
}) })
except Exception as e: except Exception as e:
print(f"❌ Error al crear pedimento: {str(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') archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
failed_files.append({ failed_files.append({
"file": relative_path, "file": relative_path,
@@ -1251,7 +1257,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
}) })
continue continue
else: else:
print(f"♻️ Usando pedimento existente: ID {existing_pedimento.id}") # print(f"♻️ Usando pedimento existente: ID {existing_pedimento.id}")
# Usar pedimento existente # Usar pedimento existente
# # Actualizar Importador # # Actualizar Importador
if contribuyente: if contribuyente:
@@ -1325,15 +1331,15 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
pedimento = existing_pedimento pedimento = existing_pedimento
print(f"🔄 Iniciando creación de documento para pedimento ID: {pedimento.id}") # print(f"🔄 Iniciando creación de documento para pedimento ID: {pedimento.id}")
# Crear documento asociado al pedimento # Crear documento asociado al pedimento
try: try:
print("📖 Leyendo archivo desde directorio temporal...") # print("📖 Leyendo archivo desde directorio temporal...")
# Leer el archivo desde el directorio temporal # Leer el archivo desde el directorio temporal
with open(file_path, 'rb') as f: with open(file_path, 'rb') as f:
file_content = f.read() file_content = f.read()
print(f"📄 Archivo leído: {len(file_content)} bytes") # print(f"📄 Archivo leído: {len(file_content)} bytes")
# Crear ContentFile que Django puede manejar correctamente # Crear ContentFile que Django puede manejar correctamente
django_file = ContentFile(file_content, name=file_name) django_file = ContentFile(file_content, name=file_name)
@@ -1369,7 +1375,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
descripcion='Transmitido por la app de escritorio' descripcion='Transmitido por la app de escritorio'
) )
print(f"Creando documento para archivo: {file_name}") # print(f"Creando documento para archivo: {file_name}")
# Crear documento - Django automáticamente guardará el archivo en media/documents/ # Crear documento - Django automáticamente guardará el archivo en media/documents/
document = Document.objects.create( document = Document.objects.create(
organizacion=organizacion, organizacion=organizacion,
@@ -1380,13 +1386,13 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
size=len(file_content), size=len(file_content),
extension=os.path.splitext(file_name)[1].lower().lstrip('.') extension=os.path.splitext(file_name)[1].lower().lstrip('.')
) )
print(f"Documento creado exitosamente: {document.id}") # print(f"Documento creado exitosamente: {document.id}")
documents_created += 1 documents_created += 1
print(f"📊 Total documentos creados hasta ahora: {documents_created}") # print(f"📊 Total documentos creados hasta ahora: {documents_created}")
except Exception as e: except Exception as e:
print(f"❌ Error al crear documento: {str(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') archivo_original = folder_name + ('.zip' if any(f.endswith('.zip') for f in [a.name for a in archivos]) else '.rar')
failed_files.append({ failed_files.append({
"file": relative_path, "file": relative_path,
@@ -1395,7 +1401,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada
}) })
continue continue
print(f"🏁 Procesamiento completado. Archivos procesados en este directorio.") # print(f"🏁 Procesamiento completado. Archivos procesados en este directorio.")
except Exception as e: except Exception as e:
return Response( return Response(
{ "tieneError": True, { "tieneError": True,