From 1cb2830d71a1d6eefd9e86a03d51d0c4fb59275f Mon Sep 17 00:00:00 2001 From: Luis Date: Tue, 16 Dec 2025 08:30:49 -0700 Subject: [PATCH] fix: se quitan los print del endpoint bulk-create-pedimento_desk --- api/customs/views.py | 106 +++++++++++++++++++++++-------------------- 1 file changed, 56 insertions(+), 50 deletions(-) diff --git a/api/customs/views.py b/api/customs/views.py index 85f478e..5125cc9 100644 --- a/api/customs/views.py +++ b/api/customs/views.py @@ -976,35 +976,41 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada temp_dir = None # Obtener DocumentType ANTES de la transacción atómica - print("Intentando obtener o crear DocumentType...") + # 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})") + # 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})") + # 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)}") + # print(f"Error al obtener/crear DocumentType: {str(e)}") # Como fallback, intentar obtener cualquier DocumentType existente try: + # document_type = DocumentType.objects.first() + # if document_type: + # print(f"Usando DocumentType existente como fallback: {document_type.nombre} (ID: {document_type.id})") + # else: + # print("No hay DocumentType disponible") + # return Response( + # {"error": "No se pudo configurar el tipo de documento y no hay tipos existentes"}, + # status=status.HTTP_500_INTERNAL_SERVER_ERROR + # ) document_type = DocumentType.objects.first() - if document_type: - print(f"Usando DocumentType existente como fallback: {document_type.nombre} (ID: {document_type.id})") - else: - print("No hay DocumentType disponible") + if not document_type: return Response( {"error": "No se pudo configurar el tipo de documento y no hay tipos existentes"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR ) except Exception as fallback_error: - print(f"Error en fallback: {str(fallback_error)}") + # print(f"Error en fallback: {str(fallback_error)}") return Response( { "tieneError": True, @@ -1014,30 +1020,30 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada ) try: - print("Iniciando transacción atómica...") + # print("Iniciando transacción atómica...") with transaction.atomic(): # Crear directorio temporal temp_dir = tempfile.mkdtemp() - print(f"Directorio temporal creado: {temp_dir}") + # 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}") + # 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}") + # print(f"Subdirectorio creado: {sub_dir}") if archivo_name.endswith('.zip'): # Manejar archivo ZIP - print("Es un 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") + # print("Archivo ZIP extraído exitosamente") except zipfile.BadZipFile as e: return Response( { @@ -1063,7 +1069,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada f.write(chunk) try: 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: 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." @@ -1081,21 +1087,21 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada 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) + # 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}") + # print(f"Revisando directorio: {root}") + # print(f"Archivos encontrados: {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) # 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}") + # print(f"Ruta relativa: {relative_path}") # Determinar si el archivo está en una carpeta que sigue la nomenclatura 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 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 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}") + # 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({ @@ -1126,16 +1132,16 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada if match: - print(f"Nomenclatura válida: {folder_name}") + # 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}") + # 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}") + # 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({ @@ -1147,11 +1153,11 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada 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 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 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) 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 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}") + # 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), @@ -1189,18 +1195,18 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada organizacion=organizacion ).first() - print(f"Pedimento existente: {existing_pedimento is not None}") + # print(f"Pedimento existente: {existing_pedimento is not None}") if not existing_pedimento: - print("📝 Pedimento no existe, creando nuevo...") + # print("📝 Pedimento no existe, creando nuevo...") # Crear nuevo pedimento try: - print("🔄 Iniciando creación de pedimento...") + # print("🔄 Iniciando creación de pedimento...") importador = None if contribuyente: # 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( rfc=contribuyente, defaults={ @@ -1208,10 +1214,10 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada 'organizacion': organizacion } ) - if created: - print(f"✅ Importador creado: {importador.rfc} - {importador.nombre}") - else: - print(f"♻️ Importador existente: {importador.rfc} - {importador.nombre}") + # 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) @@ -1232,7 +1238,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada 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({ "id": str(pedimento.id), @@ -1242,7 +1248,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada }) 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') failed_files.append({ "file": relative_path, @@ -1251,7 +1257,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada }) continue else: - print(f"♻️ Usando pedimento existente: ID {existing_pedimento.id}") + # print(f"♻️ Usando pedimento existente: ID {existing_pedimento.id}") # Usar pedimento existente # # Actualizar Importador if contribuyente: @@ -1325,15 +1331,15 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada 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 try: - print("📖 Leyendo archivo desde directorio temporal...") + # 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") + # print(f"📄 Archivo leído: {len(file_content)} bytes") # Crear ContentFile que Django puede manejar correctamente 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' ) - 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/ document = Document.objects.create( organizacion=organizacion, @@ -1380,13 +1386,13 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada size=len(file_content), 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 - print(f"📊 Total documentos creados hasta ahora: {documents_created}") + # print(f"📊 Total documentos creados hasta ahora: {documents_created}") 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') failed_files.append({ "file": relative_path, @@ -1395,7 +1401,7 @@ class ViewSetPedimento(LoggingMixin, viewsets.ModelViewSet, OrganizacionFiltrada }) continue - print(f"🏁 Procesamiento completado. Archivos procesados en este directorio.") + # print(f"🏁 Procesamiento completado. Archivos procesados en este directorio.") except Exception as e: return Response( { "tieneError": True,