90 lines
3.2 KiB
JavaScript
90 lines
3.2 KiB
JavaScript
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 = ['B119', 'B122', 'B110'];
|
|
for (const of of ofsToTest) {
|
|
await deleteOF(of);
|
|
}
|
|
}
|
|
|
|
run();
|