IA que transforma el reclutamiento
en el sector energético

# Módulo de educación — patrón aplicado a los 5 módulos
# Retorno -1 señaliza descarte automático al orquestador

def _modulo_educacion(educacion: dict | None) -> tuple[float, dict]:
    detalle = {"puntaje": 0, "peso": PESO_EDUCACION}
    if not educacion:
        return 0.0, detalle
    nivel  = educacion.get("nivel", "")
    estado = educacion.get("estado", "")
    if nivel == "primario" or (nivel == "secundario" and estado != "completo"):
        return -1.0, detalle  # descarte: no puede compensarse
    puntaje = 100 if estado == "completo" else 60
    return puntaje * PESO_EDUCACION, {**detalle, "puntaje": puntaje}

def calcular_puntaje(datos: dict, **params) -> tuple[int, str]:
    item = datos["items"][0]
    puntaje_llm = item.get("puntaje_final", 3)
    if item.get("descartado") or _descarte_por_params(item, params):
        return 0, reporte_descarte(item)
    mapa = {1: 10, 2: 30, 3: 50, 4: 70, 5: 90}
    base = mapa[puntaje_llm]
    base += _bonus_atencion_publica(item.get("experiencias", []))
    base += _bonus_comida_rapida(item.get("experiencias", []))
    escala = _mapear_escala_5(min(100, base))
    return escala, generar_reporte(base, escala, item)

# Envío masivo con fallos parciales aislados
# Un mensaje fallido NO cancela toda la campaña

@shared_task
def enviar_campaña_masiva(id_envio: int):
    envio = Envio.objects.get(id=id_envio)
    contactos = set(envio.contactos.all())
    for etiqueta in envio.etiquetas.all():
        contactos.update(etiqueta.contactos.all())

    servicio = ServicioTwilio()
    for contacto in contactos:
        envio.refresh_from_db()          # verificar cancelación en tiempo real
        if envio.estado == "cancelado":
            return
        try:
            msg = servicio.enviar_plantilla(contacto, envio.plantilla)
            MensajeEnvio.objects.create(
                envio=envio, contacto=contacto,
                twilio_sid=msg.sid, estado=msg.status or "queued"
            )
            envio.enviados += 1
        except TwilioRestException as exc:
            MensajeEnvio.objects.create(
                envio=envio, contacto=contacto, estado="failed",
                codigo_error=str(exc.code), mensaje_error=str(exc.msg)
            )
            envio.fallidos += 1
        envio.save()
        time.sleep(0.1)  # respetar rate limit Twilio: ~10 msg/s
    envio.estado = "completado"
    envio.completado_en = timezone.now()
    envio.save()