diff --git a/api/customs/tasks/microservice_v2.py b/api/customs/tasks/microservice_v2.py index 7ccd9b9..c484f8d 100644 --- a/api/customs/tasks/microservice_v2.py +++ b/api/customs/tasks/microservice_v2.py @@ -77,14 +77,13 @@ def procesar_pedimentos_completos(organizacion_id): headers={"Content-Type": "application/json"} ) # Aquí puedes continuar con el resto de tu lógica + print(f"Servicio enviado para pedimento {pedimento.pedimento}") - respuestas.append(response.json()) - return respuestas @shared_task def procesar_remesas(organizacion_id): pedimentos = Pedimento.objects.filter(organizacion_id=organizacion_id) - respuestas = [] + for pedimento in pedimentos: if not pedimento.documents.filter(document_type=3).exists(): # Tipo 3: Remesa # Convertir el pedimento a JSON usando el serializer @@ -106,8 +105,8 @@ def procesar_remesas(organizacion_id): ) # Aquí puedes continuar con el resto de tu lógica - respuestas.append(response.json()) - return respuestas + print(f"Servicio enviado para pedimento {pedimento.pedimento}") + @shared_task def procesar_coves(organizacion_id): @@ -115,7 +114,6 @@ def procesar_coves(organizacion_id): organizacion_id=organizacion_id, coves__isnull=False ).distinct() - respuestas = [] for pedimento in pedimentos: if pedimento.coves.filter(cove_descargado=False).exists(): # Tipo 3: Remesa @@ -138,8 +136,7 @@ def procesar_coves(organizacion_id): ) # Aquí puedes continuar con el resto de tu lógica - respuestas.append(response.json()) - return respuestas + print(f"Servicio enviado para pedimento {pedimento.pedimento}") @shared_task def procesar_acuse_coves(organizacion_id): @@ -147,7 +144,7 @@ def procesar_acuse_coves(organizacion_id): organizacion_id=organizacion_id, coves__isnull=False ).distinct() - respuestas = [] + for pedimento in pedimentos: if pedimento.coves.filter(acuse_cove_descargado=False).exists(): # Tipo 3: Remesa @@ -170,8 +167,7 @@ def procesar_acuse_coves(organizacion_id): ) # Aquí puedes continuar con el resto de tu lógica - respuestas.append(response.json()) - return respuestas + print(f"Servicio enviado para pedimento {pedimento.pedimento}") @shared_task def procesar_acuses(organizacion_id): @@ -179,7 +175,7 @@ def procesar_acuses(organizacion_id): organizacion_id=organizacion_id, documentos__isnull=False ).distinct() - respuestas = [] + for pedimento in pedimentos: if pedimento.documentos.filter(acuse_descargado=False).exists(): # Tipo 3: Remesa @@ -202,8 +198,7 @@ def procesar_acuses(organizacion_id): ) # Aquí puedes continuar con el resto de tu lógica - respuestas.append(response.json()) - return respuestas + print(f"Servicio enviado para pedimento {pedimento.pedimento}") @shared_task def procesar_edocs(organizacion_id): @@ -211,7 +206,7 @@ def procesar_edocs(organizacion_id): organizacion_id=organizacion_id, documentos__isnull=False ).distinct() - respuestas = [] + for pedimento in pedimentos: if pedimento.documentos.filter(edocument_descargado=False).exists(): # Tipo 3: Remesa @@ -234,8 +229,7 @@ def procesar_edocs(organizacion_id): ) # Aquí puedes continuar con el resto de tu lógica - respuestas.append(response.json()) - return respuestas + print(f"Servicio enviado para pedimento {pedimento.pedimento}") @shared_task def procesar_partidas(organizacion_id): @@ -243,7 +237,7 @@ def procesar_partidas(organizacion_id): organizacion_id=organizacion_id, partidas__isnull=False ).distinct() - respuestas = [] + for pedimento in pedimentos: if pedimento.partidas.filter(descargado=False).exists(): # Tipo 4: Partidas # Convertir el pedimento a JSON usando el serializer @@ -265,5 +259,4 @@ def procesar_partidas(organizacion_id): ) # Aquí puedes continuar con el resto de tu lógica - respuestas.append(response.json()) - return respuestas \ No newline at end of file + print(f"Servicio enviado para pedimento {pedimento.pedimento}") \ No newline at end of file