49 lines
1.6 KiB
JavaScript
49 lines
1.6 KiB
JavaScript
const { pool } = require('../db');
|
|
const { formatOrderRow, normalizeOrderPayload } = require('../mappers/orderMapper');
|
|
|
|
const listOrders = async () => {
|
|
const result = await pool.query('SELECT * FROM orders ORDER BY id DESC');
|
|
return result.rows.map(formatOrderRow);
|
|
};
|
|
|
|
const upsertOrders = async (payload) => {
|
|
const client = await pool.connect();
|
|
|
|
try {
|
|
await client.query('BEGIN');
|
|
|
|
const insertQuery = `
|
|
INSERT INTO orders (
|
|
cliente_nome, data_pedido, data_pedido_date, valor_pedido,
|
|
produto_id, produto_descricao, quantidade, valor_unitario, pedido_id, cliente_fone
|
|
) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
|
|
ON CONFLICT (pedido_id, produto_id) DO UPDATE SET
|
|
cliente_nome = EXCLUDED.cliente_nome,
|
|
data_pedido = EXCLUDED.data_pedido,
|
|
data_pedido_date = EXCLUDED.data_pedido_date,
|
|
valor_pedido = EXCLUDED.valor_pedido,
|
|
produto_descricao = EXCLUDED.produto_descricao,
|
|
quantidade = EXCLUDED.quantidade,
|
|
valor_unitario = EXCLUDED.valor_unitario,
|
|
cliente_fone = EXCLUDED.cliente_fone,
|
|
created_at = CURRENT_TIMESTAMP
|
|
`;
|
|
|
|
for (const item of payload) {
|
|
await client.query(insertQuery, normalizeOrderPayload(item));
|
|
}
|
|
|
|
await client.query('COMMIT');
|
|
} catch (error) {
|
|
await client.query('ROLLBACK');
|
|
throw error;
|
|
} finally {
|
|
client.release();
|
|
}
|
|
};
|
|
|
|
module.exports = {
|
|
listOrders,
|
|
upsertOrders
|
|
};
|