backend/scripts/reavaliarAudiosSemTranscricao.js

import "dotenv/config";
import { Atendimento } from "../src/models/Atendimento.model.js";
import { AtendimentoMensagem } from "../src/models/AtendimentoMensagem.model.js";
import { avaliarAtendimento } from "../src/services/atendimentoAvaliacaoService.js";
import { AUDIO_MEDIA_TYPES } from "../src/utils/atendimentoFormat.js";

// backfill pós-correção do viés de julgamento em áudios de atendente sem transcrição
// (ver plano "corrigir viés de julgamento em áudios de atendente sem transcrição",
// 2026-08-10): reavalia atendimentos que já foram avaliados ANTES da mudança de prompt/
// placeholder e que têm ao menos uma mensagem de áudio sem transcrição real, pra que a
// nova regra do AVALIACAO_SYSTEM_PROMPT seja aplicada ao histórico.

const limiteIdx = process.argv.indexOf("--limite");
const LIMITE = limiteIdx > -1 ? Number(process.argv[limiteIdx + 1]) : null;

// --janela 19-8: só processa dentro do intervalo de horas (cruzando meia-noite, se preciso);
// fora dele, pausa e fica checando a cada 5min até reabrir — pensado pra rodar madrugadas
// seguidas sem precisar reiniciar o processo manualmente.
const janelaIdx = process.argv.indexOf("--janela");
const JANELA = janelaIdx > -1 ? process.argv[janelaIdx + 1] : null;
const [JANELA_INICIO, JANELA_FIM] = JANELA ? JANELA.split("-").map(Number) : [null, null];

const SENTINELS = ["__processando__", "__erro__"];

function dentroDaJanela(inicioHora, fimHora) {
  const horaSp = Number(
    new Intl.DateTimeFormat("en-US", { timeZone: "America/Sao_Paulo", hour: "2-digit", hourCycle: "h23" }).format(new Date())
  );
  if (inicioHora <= fimHora) return horaSp >= inicioHora && horaSp < fimHora;
  return horaSp >= inicioHora || horaSp < fimHora; // janela cruza a meia-noite
}

async function aguardarJanela(inicioHora, fimHora) {
  let avisado = false;
  while (!dentroDaJanela(inicioHora, fimHora)) {
    if (!avisado) {
      console.log(`[reavaliar-audios] fora da janela noturna (${inicioHora}h-${fimHora}h) — pausado até reabrir`);
      avisado = true;
    }
    await new Promise((r) => setTimeout(r, 5 * 60 * 1000));
  }
  if (avisado) console.log("[reavaliar-audios] janela reaberta, retomando");
}

async function main() {
  // subquery (não JOIN) pra evitar duplicar uma linha de atendimento por cada mensagem de
  // áudio que ele tiver — JOIN + DISTINCT ... ORDER BY Abertura quebra no MySQL porque
  // Abertura não entra no SELECT do DISTINCT.
  const atendimentosComAudioPendente = AtendimentoMensagem.query()
    .select("AtendimentoId")
    .whereIn("Tipodemidia", [...AUDIO_MEDIA_TYPES])
    .where((qb) => {
      qb.whereNull("Transcricao").orWhere("Transcricao", "").orWhereIn("Transcricao", SENTINELS);
    });

  let query = Atendimento.query()
    .join("atendimento_avaliacoes as av", "av.AtendimentoId", "atendimentos.Id")
    .where("av.Avaliavel", true)
    .whereIn("atendimentos.Id", atendimentosComAudioPendente)
    .select("atendimentos.Id", "atendimentos.Codigo")
    .orderBy("atendimentos.Abertura", "desc");
  if (LIMITE) query = query.limit(LIMITE);

  const alvos = await query;
  const total = alvos.length;
  console.log(`[reavaliar-audios] iniciando: ${total} atendimentos`);

  let processados = 0;
  let erros = 0;
  const t0 = Date.now();

  for (const a of alvos) {
    if (JANELA) await aguardarJanela(JANELA_INICIO, JANELA_FIM);
    try {
      await avaliarAtendimento(a.Id);
    } catch (err) {
      erros += 1;
      console.warn(`[reavaliar-audios] erro em ${a.Codigo}: ${err.message}`);
    } finally {
      processados += 1;
      if (processados % 25 === 0 || processados === total) {
        const s = Math.round((Date.now() - t0) / 1000);
        const ritmo = s / processados;
        const restamMin = Math.round(((total - processados) * ritmo) / 60);
        console.log(
          `[reavaliar-audios] progresso: ${processados}/${total} | erros: ${erros} | ${Math.round(s / 60)}min decorridos | ~${restamMin}min restantes`
        );
      }
    }
  }

  console.log(`[reavaliar-audios] concluído: ${processados}/${total} | erros: ${erros} | ${Math.round((Date.now() - t0) / 60000)}min total`);
  process.exit(0);
}

main().catch((err) => {
  console.error("[reavaliar-audios] falha fatal:", err);
  process.exit(1);
});