sync-product-prices.js

Go to the documentation of this file.

#!/usr/bin/env node
const { Pool } = require('pg');
 
const pool = new Pool({
  host: 'rmm-psa-db-do-user-28531160-0.i.db.ondigitalocean.com',
  port: 25060,
  database: 'defaultdb',
  user: 'doadmin',
  password: 'AVNS_J8RJAmsEwsHFG52_-F2',
  ssl: { rejectUnauthorized: false }
});
 
/**
 *
 */
async function syncPrices() {
  console.log('Syncing price_retail and price_ex_tax from unit_price...\n');
  
  const result = await pool.query(`
    UPDATE products 
    SET 
      price_retail = unit_price,
      price_ex_tax = unit_price
    WHERE unit_price > 0 AND (price_retail = 0 OR price_ex_tax = 0)
    RETURNING product_id, name, unit_price
  `);
  
  console.log(`✓ Updated ${result.rows.length} products\n`);
  
  for (const product of result.rows) {
    console.log(`  ${product.name.padEnd(40)} $${parseFloat(product.unit_price).toFixed(2)}`);
  }
  
  await pool.end();
}
 
syncPrices().catch(console.error);