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

Se agregaron mensajes en microservice_v3

Browse Source
This commit is contained in:
Kevin Rosales
2025-10-04 00:22:49 -06:00
parent 14ae5e97ac
commit a403391ead
1 changed files with 13 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
api/customs/tasks/microservice_v2.py
View File

@@ -77,14 +77,13 @@ def procesar_pedimentos_completos(organizacion_id):
headers={"Content-Type": "application/json"} headers={"Content-Type": "application/json"}
) )
# Aquí puedes continuar con el resto de tu lógica # 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 @shared_task
def procesar_remesas(organizacion_id): def procesar_remesas(organizacion_id):
pedimentos = Pedimento.objects.filter(organizacion_id=organizacion_id) pedimentos = Pedimento.objects.filter(organizacion_id=organizacion_id)
respuestas = []
for pedimento in pedimentos: for pedimento in pedimentos:
if not pedimento.documents.filter(document_type=3).exists(): # Tipo 3: Remesa if not pedimento.documents.filter(document_type=3).exists(): # Tipo 3: Remesa
# Convertir el pedimento a JSON usando el serializer # 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 # Aquí puedes continuar con el resto de tu lógica
respuestas.append(response.json()) print(f"Servicio enviado para pedimento {pedimento.pedimento}")
return respuestas
@shared_task @shared_task
def procesar_coves(organizacion_id): def procesar_coves(organizacion_id):
@@ -115,7 +114,6 @@ def procesar_coves(organizacion_id):
organizacion_id=organizacion_id, organizacion_id=organizacion_id,
coves__isnull=False coves__isnull=False
).distinct() ).distinct()
respuestas = []
for pedimento in pedimentos: for pedimento in pedimentos:
if pedimento.coves.filter(cove_descargado=False).exists(): # Tipo 3: Remesa 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 # Aquí puedes continuar con el resto de tu lógica
respuestas.append(response.json()) print(f"Servicio enviado para pedimento {pedimento.pedimento}")
return respuestas
@shared_task @shared_task
def procesar_acuse_coves(organizacion_id): def procesar_acuse_coves(organizacion_id):
@@ -147,7 +144,7 @@ def procesar_acuse_coves(organizacion_id):
organizacion_id=organizacion_id, organizacion_id=organizacion_id,
coves__isnull=False coves__isnull=False
).distinct() ).distinct()
respuestas = []
for pedimento in pedimentos: for pedimento in pedimentos:
if pedimento.coves.filter(acuse_cove_descargado=False).exists(): # Tipo 3: Remesa 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 # Aquí puedes continuar con el resto de tu lógica
respuestas.append(response.json()) print(f"Servicio enviado para pedimento {pedimento.pedimento}")
return respuestas
@shared_task @shared_task
def procesar_acuses(organizacion_id): def procesar_acuses(organizacion_id):
@@ -179,7 +175,7 @@ def procesar_acuses(organizacion_id):
organizacion_id=organizacion_id, organizacion_id=organizacion_id,
documentos__isnull=False documentos__isnull=False
).distinct() ).distinct()
respuestas = []
for pedimento in pedimentos: for pedimento in pedimentos:
if pedimento.documentos.filter(acuse_descargado=False).exists(): # Tipo 3: Remesa 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 # Aquí puedes continuar con el resto de tu lógica
respuestas.append(response.json()) print(f"Servicio enviado para pedimento {pedimento.pedimento}")
return respuestas
@shared_task @shared_task
def procesar_edocs(organizacion_id): def procesar_edocs(organizacion_id):
@@ -211,7 +206,7 @@ def procesar_edocs(organizacion_id):
organizacion_id=organizacion_id, organizacion_id=organizacion_id,
documentos__isnull=False documentos__isnull=False
).distinct() ).distinct()
respuestas = []
for pedimento in pedimentos: for pedimento in pedimentos:
if pedimento.documentos.filter(edocument_descargado=False).exists(): # Tipo 3: Remesa 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 # Aquí puedes continuar con el resto de tu lógica
respuestas.append(response.json()) print(f"Servicio enviado para pedimento {pedimento.pedimento}")
return respuestas
@shared_task @shared_task
def procesar_partidas(organizacion_id): def procesar_partidas(organizacion_id):
@@ -243,7 +237,7 @@ def procesar_partidas(organizacion_id):
organizacion_id=organizacion_id, organizacion_id=organizacion_id,
partidas__isnull=False partidas__isnull=False
).distinct() ).distinct()
respuestas = []
for pedimento in pedimentos: for pedimento in pedimentos:
if pedimento.partidas.filter(descargado=False).exists(): # Tipo 4: Partidas if pedimento.partidas.filter(descargado=False).exists(): # Tipo 4: Partidas
# Convertir el pedimento a JSON usando el serializer # 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 # Aquí puedes continuar con el resto de tu lógica
respuestas.append(response.json()) print(f"Servicio enviado para pedimento {pedimento.pedimento}")
return respuestas