Compare commits
6 Commits
T2025-09-0
...
FIX2025-10
| Author | SHA1 | Date | |
|---|---|---|---|
| 1cb2830d71 | |||
| 942847680a | |||
| 97ac547a4b | |||
| ed63a4854c | |||
| 202b053698 | |||
| 77f9fe4389 |
2
.gitignore
vendored
2
.gitignore
vendored
@@ -178,4 +178,4 @@ cython_debug/
|
|||||||
#.idea/
|
#.idea/
|
||||||
|
|
||||||
# End of https://www.toptal.com/developers/gitignore/api/django
|
# End of https://www.toptal.com/developers/gitignore/api/django
|
||||||
|
*.bak
|
||||||
|
|||||||
@@ -3,12 +3,17 @@ FROM python:3.11-slim
|
|||||||
|
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
|
|
||||||
|
# Instalar dependencias del sistema necesarias
|
||||||
|
RUN apt-get update && apt-get install -y --no-install-recommends wget && \
|
||||||
|
wget https://www.rarlab.com/rar/rarlinux-x64-621.tar.gz && \
|
||||||
|
tar -xzvf rarlinux*.tar.gz && \
|
||||||
|
cp rar/unrar /usr/bin/unrar && \
|
||||||
|
rm -rf rarlinux*.tar.gz rar
|
||||||
|
|
||||||
COPY requirements.txt ./
|
COPY requirements.txt ./
|
||||||
RUN pip install --no-cache-dir -r requirements.txt
|
RUN pip install --no-cache-dir -r requirements.txt
|
||||||
|
|
||||||
RUN pip install flower
|
RUN pip install flower
|
||||||
|
|
||||||
|
|
||||||
COPY . .
|
COPY . .
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -3,8 +3,16 @@ FROM python:3.11-slim
|
|||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
|
|
||||||
# Instalar dependencias del sistema
|
# Instalar dependencias del sistema
|
||||||
RUN apt-get update && apt-get install -y \
|
# RUN apt-get update && apt-get install -y \
|
||||||
|
# supervisor \
|
||||||
|
# && rm -rf /var/lib/apt/lists/*
|
||||||
|
RUN apt-get update && apt-get install -y --no-install-recommends \
|
||||||
supervisor \
|
supervisor \
|
||||||
|
wget \
|
||||||
|
&& wget https://www.rarlab.com/rar/rarlinux-x64-621.tar.gz \
|
||||||
|
&& tar -xzvf rarlinux*.tar.gz \
|
||||||
|
&& cp rar/unrar /usr/bin/unrar \
|
||||||
|
&& rm -rf rarlinux*.tar.gz rar \
|
||||||
&& rm -rf /var/lib/apt/lists/*
|
&& rm -rf /var/lib/apt/lists/*
|
||||||
|
|
||||||
# Copiar e instalar dependencias de Python
|
# Copiar e instalar dependencias de Python
|
||||||
|
|||||||
@@ -9,6 +9,7 @@ from api.customs.models import (
|
|||||||
Partida
|
Partida
|
||||||
)
|
)
|
||||||
from django.db import models
|
from django.db import models
|
||||||
|
from django.db.models import Q
|
||||||
from api.record.models import Document # Asegúrate de importar el modelo Documento
|
from api.record.models import Document # Asegúrate de importar el modelo Documento
|
||||||
from api.record.serializers import DocumentSerializer
|
from api.record.serializers import DocumentSerializer
|
||||||
from api.vucem.serializers import VucemSerializer
|
from api.vucem.serializers import VucemSerializer
|
||||||
@@ -43,6 +44,59 @@ class PedimentoSerializer(serializers.ModelSerializer):
|
|||||||
return rep
|
return rep
|
||||||
|
|
||||||
class PartidaSerializer(serializers.ModelSerializer):
|
class PartidaSerializer(serializers.ModelSerializer):
|
||||||
|
documentos = serializers.SerializerMethodField()
|
||||||
|
|
||||||
|
def get_documentos(self, obj):
|
||||||
|
"""
|
||||||
|
Busca documentos en la tabla `document` que coincidan EXACTAMENTE con:
|
||||||
|
'documents/vu_PT_{pedimentoApp}_{numero}' al inicio del nombre del archivo.
|
||||||
|
"""
|
||||||
|
|
||||||
|
if not obj or not getattr(obj, 'pedimento', None):
|
||||||
|
return []
|
||||||
|
|
||||||
|
if not obj or not getattr(obj, 'numero_partida', None):
|
||||||
|
return []
|
||||||
|
|
||||||
|
try:
|
||||||
|
pedimentoApp = str(obj.pedimento.pedimento_app).strip()
|
||||||
|
numero = str(obj.numero_partida).strip()
|
||||||
|
|
||||||
|
# Construir el patrón exacto de búsqueda
|
||||||
|
patron_exacto = f'documents/vu_PT_{pedimentoApp}_{numero}.xml'
|
||||||
|
|
||||||
|
# Buscar documentos que empiecen EXACTAMENTE con ese patrón
|
||||||
|
qs = Document.objects.filter(
|
||||||
|
archivo=patron_exacto
|
||||||
|
)
|
||||||
|
|
||||||
|
# Opción 2: Si puede tener diferentes extensiones
|
||||||
|
# patron_base = f'documents/vu_PT_{pedimentoApp}_{numero}'
|
||||||
|
# qs = Document.objects.filter(
|
||||||
|
# archivo__startswith=patron_base
|
||||||
|
# ).filter(
|
||||||
|
# archivo__in=[
|
||||||
|
# f'{patron_base}.xml',
|
||||||
|
# f'{patron_base}.pdf',
|
||||||
|
# f'{patron_base}.zip'
|
||||||
|
# ]
|
||||||
|
# )
|
||||||
|
|
||||||
|
# Filtro adicional por pedimento si el modelo Document tiene este campo
|
||||||
|
if hasattr(Document, 'pedimento'):
|
||||||
|
qs = qs.filter(pedimento=obj.pedimento)
|
||||||
|
|
||||||
|
# Filtro por organización
|
||||||
|
if hasattr(obj, 'organizacion') and obj.organizacion:
|
||||||
|
qs = qs.filter(organizacion=obj.organizacion)
|
||||||
|
|
||||||
|
serializer = DocumentSerializer(qs, many=True, context=self.context)
|
||||||
|
return serializer.data
|
||||||
|
|
||||||
|
#return []
|
||||||
|
except Exception:
|
||||||
|
# En caso de cualquier error (por ejemplo, importaciones circulares), devolver lista vacía
|
||||||
|
return []
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Partida
|
model = Partida
|
||||||
fields = '__all__'
|
fields = '__all__'
|
||||||
@@ -129,6 +183,47 @@ class ProcesamientoPedimentoSerializer(serializers.ModelSerializer):
|
|||||||
return representation
|
return representation
|
||||||
|
|
||||||
class EDocumentSerializer(serializers.ModelSerializer):
|
class EDocumentSerializer(serializers.ModelSerializer):
|
||||||
|
documentos = serializers.SerializerMethodField()
|
||||||
|
|
||||||
|
def get_documentos(self, obj):
|
||||||
|
"""
|
||||||
|
Busca documentos en la tabla `document` que coincidan con el
|
||||||
|
`numero_edocument` dentro del nombre del archivo (`archivo`). Se
|
||||||
|
filtra por organización para evitar devolver documentos de otras orgs.
|
||||||
|
Devuelve la serialización completa de los documentos encontrados:
|
||||||
|
1. Empiecen con 'vu_EDOCUMENT' en el nombre del archivo
|
||||||
|
2. Terminen con el numero_edocument + .xml
|
||||||
|
3. Pertenezcan a la misma organización
|
||||||
|
"""
|
||||||
|
if not obj or not getattr(obj, 'numero_edocument', None):
|
||||||
|
return []
|
||||||
|
|
||||||
|
if not obj or not getattr(obj, 'pedimento', None):
|
||||||
|
return []
|
||||||
|
|
||||||
|
# if not obj or not getattr(obj, 'pedimento_id', None):
|
||||||
|
# return []
|
||||||
|
|
||||||
|
try:
|
||||||
|
numero = str(obj.numero_edocument).strip()
|
||||||
|
# id_pedimento = str(obj.pedimento_id).strip()
|
||||||
|
|
||||||
|
qs = Document.objects.filter(
|
||||||
|
pedimento=obj.pedimento,
|
||||||
|
archivo__icontains=numero,
|
||||||
|
)
|
||||||
|
|
||||||
|
# Filtro por organización si aplica
|
||||||
|
if hasattr(obj, 'organizacion') and obj.organizacion:
|
||||||
|
qs = qs.filter(organizacion=obj.organizacion)
|
||||||
|
|
||||||
|
serializer = DocumentSerializer(qs, many=True, context=self.context)
|
||||||
|
return serializer.data
|
||||||
|
|
||||||
|
except Exception:
|
||||||
|
# En caso de cualquier error (por ejemplo, importaciones circulares), devolver lista vacía
|
||||||
|
return []
|
||||||
|
|
||||||
class Meta:
|
class Meta:
|
||||||
model = EDocument
|
model = EDocument
|
||||||
fields = '__all__'
|
fields = '__all__'
|
||||||
@@ -142,11 +237,48 @@ class EDocumentSerializer(serializers.ModelSerializer):
|
|||||||
self.fields['organizacion'].read_only = True
|
self.fields['organizacion'].read_only = True
|
||||||
|
|
||||||
class CoveSerializer(serializers.ModelSerializer):
|
class CoveSerializer(serializers.ModelSerializer):
|
||||||
|
documentos = serializers.SerializerMethodField()
|
||||||
|
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Cove
|
model = Cove
|
||||||
fields = '__all__'
|
fields = '__all__'
|
||||||
read_only_fields = ('created_at', 'updated_at')
|
read_only_fields = ('created_at', 'updated_at')
|
||||||
|
|
||||||
|
def get_documentos(self, obj):
|
||||||
|
"""
|
||||||
|
Busca documentos en la tabla `document` que coincidan con el
|
||||||
|
`numero_cove` dentro del nombre del archivo (`archivo`). Se
|
||||||
|
filtra por organización para evitar devolver documentos de otras orgs.
|
||||||
|
Devuelve la serialización completa de los documentos encontrados:
|
||||||
|
1. Empiecen con 'vu_COVE' en el nombre del archivo
|
||||||
|
2. Terminen con el numero_cove + .xml
|
||||||
|
3. Pertenezcan a la misma organización
|
||||||
|
"""
|
||||||
|
if not obj or not getattr(obj, 'numero_cove', None):
|
||||||
|
return []
|
||||||
|
|
||||||
|
if not obj or not getattr(obj, 'pedimento', None):
|
||||||
|
return []
|
||||||
|
|
||||||
|
try:
|
||||||
|
numero = str(obj.numero_cove).strip()
|
||||||
|
|
||||||
|
qs = Document.objects.filter(
|
||||||
|
pedimento=obj.pedimento,
|
||||||
|
archivo__icontains=numero,
|
||||||
|
)
|
||||||
|
|
||||||
|
# Filtro por organización si aplica
|
||||||
|
if hasattr(obj, 'organizacion') and obj.organizacion:
|
||||||
|
qs = qs.filter(organizacion=obj.organizacion)
|
||||||
|
|
||||||
|
serializer = DocumentSerializer(qs, many=True, context=self.context)
|
||||||
|
return serializer.data
|
||||||
|
|
||||||
|
except Exception:
|
||||||
|
# En caso de cualquier error (por ejemplo, importaciones circulares), devolver lista vacía
|
||||||
|
return []
|
||||||
|
|
||||||
class ImportadorSerializer(serializers.ModelSerializer):
|
class ImportadorSerializer(serializers.ModelSerializer):
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Importador
|
model = Importador
|
||||||
|
|||||||
1115
api/customs/views.py
1115
api/customs/views.py
File diff suppressed because it is too large
Load Diff
@@ -9,10 +9,11 @@ from api.customs.models import Pedimento
|
|||||||
class DocumentSerializer(serializers.ModelSerializer):
|
class DocumentSerializer(serializers.ModelSerializer):
|
||||||
pedimento_numero = serializers.SerializerMethodField(read_only=True)
|
pedimento_numero = serializers.SerializerMethodField(read_only=True)
|
||||||
pedimento = serializers.PrimaryKeyRelatedField(queryset=Pedimento.objects.all())
|
pedimento = serializers.PrimaryKeyRelatedField(queryset=Pedimento.objects.all())
|
||||||
|
fuente_nombre = serializers.SerializerMethodField()
|
||||||
|
fuente = serializers.PrimaryKeyRelatedField(queryset=Fuente.objects.all())
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Document
|
model = Document
|
||||||
fields = ('id', 'organizacion', 'pedimento', 'pedimento_numero', 'archivo', 'document_type', 'size', 'extension', 'fuente','created_at', 'updated_at')
|
fields = ('id', 'organizacion', 'pedimento', 'pedimento_numero', 'archivo', 'document_type', 'size', 'extension', 'fuente','fuente_nombre','created_at', 'updated_at')
|
||||||
read_only_fields = ('id', 'size', 'extension', 'created_at', 'updated_at', 'pedimento_numero')
|
read_only_fields = ('id', 'size', 'extension', 'created_at', 'updated_at', 'pedimento_numero')
|
||||||
|
|
||||||
def get_pedimento_numero(self, obj):
|
def get_pedimento_numero(self, obj):
|
||||||
@@ -26,6 +27,12 @@ class DocumentSerializer(serializers.ModelSerializer):
|
|||||||
raise serializers.ValidationError("Se requiere un archivo para subir")
|
raise serializers.ValidationError("Se requiere un archivo para subir")
|
||||||
return value
|
return value
|
||||||
|
|
||||||
|
def get_fuente_nombre(self, obj):
|
||||||
|
# Método 1: Si la fuente está precargada con select_related
|
||||||
|
if obj.fuente:
|
||||||
|
return obj.fuente.nombre
|
||||||
|
return "Desconocido"
|
||||||
|
|
||||||
class FuenteSerializer(serializers.ModelSerializer):
|
class FuenteSerializer(serializers.ModelSerializer):
|
||||||
class Meta:
|
class Meta:
|
||||||
model = Fuente
|
model = Fuente
|
||||||
|
|||||||
@@ -4,7 +4,16 @@ from rest_framework.routers import DefaultRouter
|
|||||||
|
|
||||||
# import necessary viewsets
|
# import necessary viewsets
|
||||||
# from .views import YourViewSet # Import your viewsets here
|
# from .views import YourViewSet # Import your viewsets here
|
||||||
from .views import DocumentViewSet, ProtectedDocumentDownloadView, BulkDownloadZipView, GetFuenteView, DocumentTypeView, ExpedienteZipDownloadView, MultiPedimentoZipDownloadView
|
from .views import (DocumentViewSet
|
||||||
|
, ProtectedDocumentDownloadView
|
||||||
|
, BulkDownloadZipView
|
||||||
|
, GetFuenteView
|
||||||
|
, DocumentTypeView
|
||||||
|
, ExpedienteZipDownloadView
|
||||||
|
, MultiPedimentoZipDownloadView
|
||||||
|
, PedimentoDocumentViewSet)
|
||||||
|
|
||||||
|
|
||||||
# Create a router and register your viewsets with it
|
# Create a router and register your viewsets with it
|
||||||
|
|
||||||
router = DefaultRouter()
|
router = DefaultRouter()
|
||||||
@@ -25,5 +34,6 @@ urlpatterns = [
|
|||||||
path('document-type/', DocumentTypeView.as_view(), name='document-type-list-create'),
|
path('document-type/', DocumentTypeView.as_view(), name='document-type-list-create'),
|
||||||
path('documents/expediente-zip/', ExpedienteZipDownloadView.as_view(), name='expediente-zip-download'),
|
path('documents/expediente-zip/', ExpedienteZipDownloadView.as_view(), name='expediente-zip-download'),
|
||||||
path('documents/multi-pedimento-zip/', MultiPedimentoZipDownloadView.as_view(), name='multi-pedimento-zip-download'),
|
path('documents/multi-pedimento-zip/', MultiPedimentoZipDownloadView.as_view(), name='multi-pedimento-zip-download'),
|
||||||
|
path('pedimento-documents/', PedimentoDocumentViewSet.as_view({'get': 'list'}), name='pedimento-document-list'),
|
||||||
path('', include(router.urls)),
|
path('', include(router.urls)),
|
||||||
]
|
]
|
||||||
@@ -63,7 +63,8 @@ class DocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
|
|||||||
pagination_class = CustomPagination
|
pagination_class = CustomPagination
|
||||||
serializer_class = DocumentSerializer
|
serializer_class = DocumentSerializer
|
||||||
# Habilitar filtro por pedimento (UUID) y pedimento_numero (campo pedimento del modelo relacionado)
|
# Habilitar filtro por pedimento (UUID) y pedimento_numero (campo pedimento del modelo relacionado)
|
||||||
filterset_fields = ['extension', 'size', 'document_type', 'pedimento', 'pedimento__pedimento']
|
filterset_fields = ['extension', 'size', 'document_type', 'pedimento', 'pedimento__pedimento', 'created_at']
|
||||||
|
# filterset_fields = ['extension', 'size', 'pedimento', 'pedimento__pedimento']
|
||||||
|
|
||||||
# Puedes filtrar por pedimento usando: /api/record/documents/?pedimento=<id> o /api/record/documents/?pedimento__pedimento=<numero>
|
# Puedes filtrar por pedimento usando: /api/record/documents/?pedimento=<id> o /api/record/documents/?pedimento__pedimento=<numero>
|
||||||
# Ejemplo: /api/record/documents/?pedimento_numero=12345678
|
# Ejemplo: /api/record/documents/?pedimento_numero=12345678
|
||||||
@@ -71,6 +72,33 @@ class DocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
|
|||||||
|
|
||||||
def get_queryset(self):
|
def get_queryset(self):
|
||||||
queryset = self.get_queryset_filtrado_por_organizacion()
|
queryset = self.get_queryset_filtrado_por_organizacion()
|
||||||
|
|
||||||
|
modulo_efc = self.request.query_params.get('modulo')
|
||||||
|
if modulo_efc:
|
||||||
|
if modulo_efc == 'expedientes-detalle-pedimentos':
|
||||||
|
queryset = queryset.exclude(document_type_id__in=['1','2','3','4','5','6','7','8','9','10'])
|
||||||
|
# Filtro personalizado por document_type
|
||||||
|
# document_type = self.request.query_params.get('document_type')
|
||||||
|
# if document_type:
|
||||||
|
# # Puedes agregar lógica personalizada aquí si es necesario
|
||||||
|
# if document_type == '1':
|
||||||
|
# queryset = queryset.filter(document_type_id=document_type)
|
||||||
|
# elif document_type == '2':
|
||||||
|
# queryset = queryset.filter(document_type_id=document_type)
|
||||||
|
# else:
|
||||||
|
# queryset = queryset.filter(document_type_id=document_type)
|
||||||
|
# else:
|
||||||
|
# queryset = queryset.filter(document_type_id='11')
|
||||||
|
|
||||||
|
fechaCreacion = self.request.query_params.get('created_at__date')
|
||||||
|
if fechaCreacion:
|
||||||
|
queryset = queryset.filter(created_at=fechaCreacion)
|
||||||
|
|
||||||
|
buscarArchivo = self.request.query_params.get('archivo__icontains')
|
||||||
|
if buscarArchivo:
|
||||||
|
queryset = queryset.filter(archivo__icontains=buscarArchivo)
|
||||||
|
|
||||||
|
|
||||||
pedimento_numero = self.request.query_params.get('pedimento_numero')
|
pedimento_numero = self.request.query_params.get('pedimento_numero')
|
||||||
if pedimento_numero:
|
if pedimento_numero:
|
||||||
queryset = queryset.filter(pedimento__pedimento_app=pedimento_numero)
|
queryset = queryset.filter(pedimento__pedimento_app=pedimento_numero)
|
||||||
@@ -762,6 +790,50 @@ class MultiPedimentoZipDownloadView(APIView):
|
|||||||
|
|
||||||
return response
|
return response
|
||||||
|
|
||||||
|
class PedimentoDocumentViewSet(viewsets.ModelViewSet, DocumentosFiltradosMixin):
|
||||||
|
"""
|
||||||
|
ViewSet for Document model.
|
||||||
|
"""
|
||||||
|
permission_classes = [IsAuthenticated & (IsSuperUser | IsSameOrganization | IsSameOrganizationAndAdmin | IsSameOrganizationDeveloper )]
|
||||||
|
model = Document
|
||||||
|
|
||||||
|
pagination_class = CustomPagination
|
||||||
|
serializer_class = DocumentSerializer
|
||||||
|
# Habilitar filtro por pedimento (UUID) y pedimento_numero (campo pedimento del modelo relacionado)
|
||||||
|
# filterset_fields = ['extension', 'size', 'document_type', 'pedimento', 'pedimento__pedimento']
|
||||||
|
filterset_fields = ['extension', 'size', 'pedimento', 'pedimento__pedimento','fuente']
|
||||||
|
|
||||||
|
# Puedes filtrar por pedimento usando: /api/record/documents/?pedimento=<id> o /api/record/documents/?pedimento__pedimento=<numero>
|
||||||
|
# Ejemplo: /api/record/documents/?pedimento_numero=12345678
|
||||||
|
my_tags = ['Documents']
|
||||||
|
|
||||||
|
def get_queryset(self):
|
||||||
|
queryset = self.get_queryset_filtrado_por_organizacion()
|
||||||
|
|
||||||
|
# Tipos de documento permitidos (fijos en código, Pedimento completo y remesas)
|
||||||
|
TIPOS_PERMITIDOS = ['2', '3'] # <-- Ajusta aquí tus tipos
|
||||||
|
tipo_documento = self.request.query_params.get('document_type')
|
||||||
|
if tipo_documento:
|
||||||
|
queryset = queryset.filter(document_type_id=tipo_documento)
|
||||||
|
else:
|
||||||
|
# Filtrar por tipos permitidos
|
||||||
|
queryset = queryset.filter(document_type_id__in=TIPOS_PERMITIDOS)
|
||||||
|
|
||||||
|
buscar_archivo = self.request.query_params.get('archivo__icontains')
|
||||||
|
if buscar_archivo:
|
||||||
|
queryset = queryset.filter(archivo__icontains=buscar_archivo)
|
||||||
|
|
||||||
|
created_at__date = self.request.query_params.get('created_at__date')
|
||||||
|
if created_at__date:
|
||||||
|
queryset = queryset.filter(created_at=created_at__date)
|
||||||
|
|
||||||
|
# Filtro adicional por pedimento_numero si se proporciona
|
||||||
|
pedimento_numero = self.request.query_params.get('pedimento_numero')
|
||||||
|
if pedimento_numero:
|
||||||
|
queryset = queryset.filter(pedimento__pedimento_app=pedimento_numero)
|
||||||
|
|
||||||
|
return queryset
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
Reference in New Issue
Block a user