Sincronizar frequência com ERP/folha externa

1. Cron 01:00 BRT
2. Calcular data ontem (D-1)
3. Verificar se D-1 está em fechamento concluído (opcional mas recomendado)
4. Paginar por GET /frequency/daily?dataInicio=D-1&dataFim=D-1
5. Para cada linha, upsertar no ERP
6. Salvar cursor (timestamp da última sync) para auditoria

async function syncDiarioFrequencia(token) {
  const TOKEN = token || process.env.PONTUA_API_TOKEN
  const ontem = new Date(Date.now() - 86400000).toISOString().slice(0, 10)
  const headers = { Authorization: `Bearer ${TOKEN}` }

  console.log(`Sync frequência de ${ontem}`)

  // 1. Validação opcional: só sync se fechamento aberto/concluído
  // (algumas empresas preferem aguardar fechamento; outras puxam preview)

  // 2. Paginar todas as frequências do dia
  let pagina = 0
  let totalLido = 0
  let totalUpsertado = 0
  let totalErros = 0

  while (true) {
    const params = new URLSearchParams({
      dataInicio: ontem,
      dataFim: ontem,
      pagina: String(pagina),
      limite: '100',
    })

    const resp = await fetch(
      `https://api.pontua.com.br/frequency/daily?${params}`,
      { headers },
    )

    if (!resp.ok) {
      throw new Error(`Falha ao listar frequências: ${resp.status}`)
    }

    const { resultados, totalRegistros } = await resp.json()
    totalLido += resultados.length

    // 3. Upsert cada linha no ERP
    for (const freq of resultados) {
      try {
        await meuErp.upsertFrequencia({
          colaboradorCpf: freq.colaboradorCpf,  // ou ID conforme ERP
          data: freq.data,
          horasTrabalhadasMinutos: parseHHMMToMin(freq.totais.horasTrabalhadas),
          horasExtrasMinutos: parseHHMMToMin(freq.totais.horasExtras),
          status: freq.status,
        })
        totalUpsertado++
      } catch (e) {
        console.error(`Erro upsert ${freq.colaboradorId} ${freq.data}:`, e.message)
        totalErros++
      }
    }

    // 4. Próxima página?
    if ((pagina + 1) * 100 >= totalRegistros) break
    pagina++
  }

  // 5. Log/cursor
  console.log(`Sync ${ontem} concluído: ${totalLido} lidos, ${totalUpsertado} upsertados, ${totalErros} erros`)
  await storage.set('pontua.ultimo_sync_frequencia', new Date().toISOString())

  return { lido: totalLido, upsertado: totalUpsertado, erros: totalErros }
}

function parseHHMMToMin(hhmm) {
  const [h, m] = hhmm.split(':').map(Number)
  return h * 60 + m
}

// Setup cron (ex: node-cron)
import cron from 'node-cron'
cron.schedule('0 1 * * *', () => syncDiarioFrequencia().catch(console.error), {
  timezone: 'America/Sao_Paulo',
})

async function syncComRetry(maxAttempts = 5) {
  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    try {
      return await syncDiarioFrequencia()
    } catch (e) {
      if (attempt === maxAttempts - 1) throw e
      const delay = Math.pow(2, attempt) * 1000 + Math.random() * 1000
      console.warn(`Tentativa ${attempt + 1} falhou, aguardando ${delay}ms`)
      await new Promise((r) => setTimeout(r, delay))
    }
  }
}

async function catchUpFrequencia(token, diasAtras = 7) {
  const hoje = new Date()

  for (let i = 1; i <= diasAtras; i++) {
    const data = new Date(hoje.getTime() - i * 86400000)
      .toISOString().slice(0, 10)

    console.log(`Catch-up ${data}`)
    await syncDiaEspecifico(token, data)
  }
}