import { pool } from '../src/db/pool';

async function cleanupDuplicates() {
  console.log('Cleaning up duplicate tenant batches...');

  // 1. Delete stock movements referencing duplicate user batches
  await pool.query(`
    DELETE FROM stock_movements 
    WHERE batch_no IN (
      SELECT batch_no FROM batches WHERE batch_no LIKE '%-usr_%' OR tenant_id LIKE 'usr_%'
    )
  `);

  // 2. Delete duplicate user batches
  const res1 = await pool.query(`DELETE FROM batches WHERE batch_no LIKE '%-usr_%' OR tenant_id LIKE 'usr_%'`);
  console.log('Deleted duplicate user batches count:', res1.rowCount);

  // 3. Count remaining batches in DB
  const countRes = await pool.query(`SELECT COUNT(*) FROM batches`);
  console.log('Remaining total batches in DB:', countRes.rows[0].count);

  await pool.end();
}

cleanupDuplicates().catch(console.error);