with estaciones as (
select
*
from {{ ref('stg_estaciones') }}
where id_estacion is not null
),
distritos as (
select
distrito_id,
distrito_nombre,
{{ normalizar_texto('distrito_nombre') }} as distrito_clave
from {{ ref('stg_distritos') }}
)
select
e.id_estacion,
e.nombre_estacion,
coalesce(e.tipo_estacion, 'desconocido') as tipo_estacion,
e.estado,
capacidad,
e.latitud,
e.longitud,
e.altitud,
e.codigo_postal,
e.direccion,
d.distrito_id,
e.distrito,
e.fecha_instalacion
from estaciones as e
left join distritos as d
on d.distrito_clave = e.distrito