Initial commit

This commit is contained in:
minguezsanzjuanjose
2026-04-11 03:31:05 +02:00
commit 1e78ad3a40
15 changed files with 244 additions and 0 deletions

0
apps/__init__.py Normal file
View File

11
apps/common/utils.py Normal file
View File

@@ -0,0 +1,11 @@
# Ejemplo de limpieza de tipos para SQL
def clean_sql_string(value):
if value is None:
return ""
return str(value).strip().replace("'", "''")
def clean_sql_int(value):
try:
return int(value)
except (ValueError, TypeError):
return 0

View File

@@ -0,0 +1,56 @@
from django.db import connection
from common.utils import clean_sql_string, clean_sql_int
def getData(params):
"""
Función estándar para obtener datos de promociones.
"""
# 1. Definimos la query con placeholders (%s)
query = """
SELECT id, nombre, fecha_inicio, descripcion
FROM promociones
WHERE id = %s AND activo = %s
"""
# 2. Preparamos el diccionario de parámetros (tu estándar get_parameterized)
# Limpiamos los datos antes de enviarlos a la base de datos
id_promocion = clean_sql_int(params.get('id'))
is_active = 1 if params.get('activo') else 0
parameter_dict = [id_promocion, is_active]
# 3. Ejecución parametrizada
with connection.cursor() as cursor:
cursor.execute(query, parameter_dict)
columns = [col[0] for col in cursor.description]
result = [dict(zip(columns, row)) for row in cursor.fetchall()]
return result
def setData(params):
"""
Función estándar para insertar o actualizar (set_parameterized).
"""
# Ejemplo de UPDATE con JOIN (como solicitaste en tu estándar)
query = """
UPDATE promociones p
SET p.nombre = %s, p.fecha_modificacion = %s
FROM categorias c
WHERE p.categoria_id = c.id AND p.id = %s
"""
# Fecha en formato Año-Día-Mes (Y-d-m)
import datetime
fecha_hoy = datetime.datetime.now().strftime('%Y-%d-%m')
parameter_dict = [
clean_sql_string(params.get('nombre')),
fecha_hoy,
clean_sql_int(params.get('id'))
]
with connection.cursor() as cursor:
cursor.execute(query, parameter_dict)
affected_rows = cursor.rowcount
return affected_rows

7
apps/promociones/urls.py Normal file
View File

@@ -0,0 +1,7 @@
from django.urls import path
from .views import get_promocion_view
urlpatterns = [
# Capa 1: Definición del endpoint
path('obtener/', get_promocion_view, name='get_promocion'),
]

54
apps/promociones/views.py Normal file
View File

@@ -0,0 +1,54 @@
import logging
from django.http import JsonResponse
from .actions import getData
# Configuración del logger para rastrear la ejecución
logger = logging.getLogger(__name__)
def get_promocion_view(request):
"""
Vista estandarizada para la obtención de una promoción.
"""
# ---------------------------------------------------------
# BLOQUE 1: Log de iniciación
# ---------------------------------------------------------
logger.info("[START] Iniciando ejecución de get_promocion_view")
try:
# ---------------------------------------------------------
# BLOQUE 2: Limpieza de datos (Data Cleaning)
# ---------------------------------------------------------
# Extraemos los parámetros del request y preparamos el diccionario
raw_data = request.GET.dict()
# Aquí es donde ella aplicaría validaciones adicionales si fuera necesario
clean_params = {
'id': raw_data.get('id'),
'activo': raw_data.get('activo', True) # Valor por defecto
}
# ---------------------------------------------------------
# BLOQUE 3: Llamada a la Action (Execution)
# ---------------------------------------------------------
# La lógica de SQL y parametrización vive dentro de esta llamada
resultado_db = getData(clean_params)
# ---------------------------------------------------------
# BLOQUE 4: Log de cierre y respuesta (Closure)
# ---------------------------------------------------------
logger.info(f"[SUCCESS] get_promocion_view finalizada. Registros encontrados: {len(resultado_db)}")
return JsonResponse({
'status': 'success',
'data': resultado_db
}, status=200)
except Exception as e:
# Log de error detallado en caso de fallo
logger.error(f"[ERROR] Fallo crítico en get_promocion_view: {str(e)}")
return JsonResponse({
'status': 'error',
'message': 'Error interno del servidor'
}, status=500)