import { createClient } from '@supabase/supabase-js';

const supabaseUrl = 'https://supabase.reifonas.cloud';
const supabaseKey = 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJzdXBhYmFzZSIsImlhdCI6MTc3Mjk5NTUwMCwiZXhwIjo0OTI4NjY5MTAwLCJyb2xlIjoic2VydmljZV9yb2xlIn0._n2Kj2f29z1u0pOYUGqAr-1Xjt-xQpK9KDhhhGvOIro';

const sbERP = createClient(supabaseUrl, supabaseKey, { db: { schema: 'TS_ERP' } });
const sbPub = createClient(supabaseUrl, supabaseKey, { db: { schema: 'public' } });

async function del(table, col, val) {
  if (!val) return;
  let res = await sbERP.from(table).delete().eq(col, val);
  if (res.error && res.error.message.includes("does not exist")) {
    res = await sbPub.from(table).delete().eq(col, val);
  }
  if (res.error) console.log(`    ❌ Erro em ${table}: ${res.error.message}`);
  else console.log(`    ✅ ${table} limpo.`);
}

async function delIn(table, col, vals) {
  if (!vals || vals.length === 0) return;
  let res = await sbERP.from(table).delete().in(col, vals);
  if (res.error && res.error.message.includes("does not exist")) {
    res = await sbPub.from(table).delete().in(col, vals);
  }
  if (res.error) console.log(`    ❌ Erro em ${table}: ${res.error.message}`);
  else console.log(`    ✅ ${table} limpo.`);
}

async function getOF(ofNumber) {
  let res = await sbERP.from('ordens_fabricacao').select('id').eq('num_of', ofNumber).single();
  if (res.error) {
    res = await sbPub.from('ordens_fabricacao').select('id').eq('num_of', ofNumber).single();
  }
  return res.data ? res.data.id : null;
}

async function getPecas(ofNumber) {
  let res = await sbERP.from('pecas').select('id').eq('of_number', ofNumber);
  if (res.error) {
    res = await sbPub.from('pecas').select('id').eq('of_number', ofNumber);
  }
  return res.data ? res.data.map(p => p.id) : [];
}

async function deleteOF(ofNumber) {
  console.log(`\nIniciando EXCLUSÃO TOTAL da OF: ${ofNumber}`);
  
  const ofId = await getOF(ofNumber);
  const pecaIds = await getPecas(ofNumber);

  console.log(`  - ID da OF encontrado: ${ofId || 'Nenhum (já excluída?)'}`);
  console.log(`  - Total de peças encontradas: ${pecaIds.length}`);

  // 1. Limpar dependências de peças
  if (pecaIds.length > 0) {
    await delIn('itens_romaneio_pecas', 'peca_id', pecaIds);
    await delIn('itens_prioridade_fabricacao', 'peca_id', pecaIds);
    await delIn('processos_pecas_datas', 'peca_id', pecaIds);
  }

  // 2. Limpar dependências diretas de of_number
  await del('logs_apontamentos_automaticos', 'of_number', ofNumber);
  await del('romaneios_expedicao', 'of_number', ofNumber);
  await del('apontamentos_producao', 'of_number', ofNumber);
  await del('apontamentos_diario_recursos', 'of_number', ofNumber);
  await del('prioridades_fabricacao', 'of_number', ofNumber);
  
  // 3. Limpar cronogramas
  if (ofId) {
    await del('cronogramas_of', 'of_id', ofId);
  }

  // 4. Excluir Peças
  await del('pecas', 'of_number', ofNumber);

  // 5. Excluir OF
  await del('ordens_fabricacao', 'num_of', ofNumber);

  console.log(`✅ Fim da rotina para a OF ${ofNumber}.\n`);
}

async function run() {
  const ofsToTest = ['B117', 'B114'];
  for (const of of ofsToTest) {
    await deleteOF(of);
  }
}

run();