feature/agregar eventos en las tareas de fondo, se modificaron modelos para capturar cuales si deben accionar tareas de fondo y cuales no necesariamente tienen que accionar tareas de fondo
This commit is contained in:
@@ -1,5 +1,4 @@
|
||||
from celery import shared_task
|
||||
from django.core.files.base import ContentFile
|
||||
from django.utils import timezone
|
||||
import os
|
||||
import zipfile
|
||||
@@ -615,66 +614,66 @@ def bulk_upload_record_task(self, organizacion_id, parametros, archivo_paths):
|
||||
tiene_nomenclatura_especial = True
|
||||
info_extraida = procesar_archivo_m_con_nomenclatura(file_content, existing_pedimento)
|
||||
|
||||
django_file = ContentFile(file_content, name=file_name)
|
||||
|
||||
# Buscar documento existente
|
||||
existing_documents = Document.objects.filter(
|
||||
pedimento_id=existing_pedimento.id,
|
||||
organizacion=organizacion
|
||||
)
|
||||
|
||||
|
||||
existing_document = None
|
||||
for doc in existing_documents:
|
||||
if is_same_document(doc, file_name):
|
||||
existing_document = doc
|
||||
break
|
||||
|
||||
|
||||
if existing_document:
|
||||
# Actualizar documento existente
|
||||
# try:
|
||||
# if existing_document.archivo and os.path.exists(existing_document.archivo.path):
|
||||
# os.remove(existing_document.archivo.path)
|
||||
# except (ValueError, OSError):
|
||||
# pass
|
||||
|
||||
# existing_document.archivo = django_file
|
||||
# existing_document.size = len(file_content)
|
||||
# existing_document.extension = extension
|
||||
# existing_document.updated_at = timezone.now()
|
||||
# existing_document.save()
|
||||
|
||||
# doc = Document.objects.get(id=existing_document.id)
|
||||
# doc.archivo.delete(save=False) # Eliminar el archivo anterior
|
||||
# doc.delete() # Eliminar el registro para crear uno nuevo (evita problemas con archivos en Django)
|
||||
|
||||
updated_pedimentos.append({
|
||||
"id": str(existing_pedimento.id),
|
||||
"pedimento_app": existing_pedimento.pedimento_app,
|
||||
"accion": "Documento actualizado",
|
||||
"accion": "Documento ya existente, omitido",
|
||||
"documento": file_name
|
||||
})
|
||||
|
||||
documents_created += 1
|
||||
else:
|
||||
# Crear nuevo documento
|
||||
# Crear registro sin archivo primero
|
||||
document = Document.objects.create(
|
||||
organizacion=organizacion,
|
||||
pedimento_id=existing_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('.')
|
||||
)
|
||||
|
||||
updated_pedimentos.append({
|
||||
"id": str(existing_pedimento.id),
|
||||
"pedimento_app": existing_pedimento.pedimento_app,
|
||||
"accion": "Documento creado",
|
||||
"documento": file_name
|
||||
})
|
||||
from api.utils.storage_service import storage_service
|
||||
ruta = storage_service.save_document_from_path(
|
||||
file_path=file_path,
|
||||
file_name=file_name,
|
||||
organizacion_id=organizacion.id,
|
||||
pedimento_app=existing_pedimento.pedimento_app,
|
||||
metadata={
|
||||
'pedimento_id': str(existing_pedimento.id),
|
||||
'document_id': str(document.id),
|
||||
'source': 'bulk_upload_async'
|
||||
}
|
||||
)
|
||||
|
||||
documents_created += 1
|
||||
if ruta:
|
||||
document.archivo = ruta
|
||||
document.save()
|
||||
documents_created += 1
|
||||
updated_pedimentos.append({
|
||||
"id": str(existing_pedimento.id),
|
||||
"pedimento_app": existing_pedimento.pedimento_app,
|
||||
"accion": "Documento creado",
|
||||
"documento": file_name
|
||||
})
|
||||
else:
|
||||
document.delete()
|
||||
failed_records.append({
|
||||
"file": relative_path,
|
||||
"archivo_original": folder_name + '.zip',
|
||||
"error": f"Error al guardar {file_name} en almacenamiento"
|
||||
})
|
||||
|
||||
except Exception as e:
|
||||
failed_records.append({
|
||||
|
||||
@@ -563,11 +563,14 @@ def process_all_organizations():
|
||||
"""
|
||||
Envía una tarea por organización activa a la cola org_processing.
|
||||
"""
|
||||
active_orgs = Organizacion.objects.filter(is_active=True, is_verified=True)
|
||||
|
||||
active_orgs = Organizacion.objects.filter(
|
||||
is_active=True,
|
||||
is_verified=True,
|
||||
apply_auto_download=True,
|
||||
)
|
||||
for org in active_orgs:
|
||||
process_organization_batch.apply_async(
|
||||
args=[org.id],
|
||||
args=[str(org.id)],
|
||||
queue='org_processing'
|
||||
)
|
||||
return f"Dispatched {active_orgs.count()} organizations"
|
||||
|
||||
Reference in New Issue
Block a user