Nulo/preciazo
1
0
Fork 0
mirror of https://github.com/catdevnull/preciazo.git synced 2024-11-22 14:16:19 +00:00
Code Issues Projects Releases Packages Wiki Activity

format

Browse source
This commit is contained in:
Cat /dev/Nulo 2024-09-06 23:43:46 -03:00
parent b7ced28868
commit c8c603aade
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
sepa/sepa-precios-importer/index.ts
View file

@ -74,13 +74,13 @@ await sql`
async function importSucursales( async function importSucursales(
sql: postgres.Sql, sql: postgres.Sql,
datasetId: number, datasetId: number,
dir: string, dir: string
) { ) {
const sucursales: Papa.ParseResult<any> = Papa.parse( const sucursales: Papa.ParseResult<any> = Papa.parse(
await readFile(join(dir, "sucursales.csv"), "utf-8"), await readFile(join(dir, "sucursales.csv"), "utf-8"),
{ {
header: true, header: true,
}, }
); );
const objs = sucursales.data const objs = sucursales.data
@ -99,7 +99,7 @@ async function importSucursales(
}); });
const keys = Object.keys(objs[0]); const keys = Object.keys(objs[0]);
const lines = Readable.from( const lines = Readable.from(
objs.map((data) => keys.map((key) => (data as any)[key]).join("\t") + "\n"), objs.map((data) => keys.map((key) => (data as any)[key]).join("\t") + "\n")
); );
const writable = const writable =
await sql`copy sucursales (${sql.unsafe(keys.join(", "))}) from stdin with CSV DELIMITER E'\t' QUOTE E'\b'`.writable(); await sql`copy sucursales (${sql.unsafe(keys.join(", "))}) from stdin with CSV DELIMITER E'\t' QUOTE E'\b'`.writable();
@ -126,7 +126,7 @@ async function importDataset(dir: string) {
const comercios: Papa.ParseResult<{ comercio_cuit: string }> = Papa.parse( const comercios: Papa.ParseResult<{ comercio_cuit: string }> = Papa.parse(
await readFile(join(dir, "comercio.csv"), "utf-8"), await readFile(join(dir, "comercio.csv"), "utf-8"),
{ header: true }, { header: true }
); );
const comercioCuit = comercios.data[0].comercio_cuit; const comercioCuit = comercios.data[0].comercio_cuit;
console.log(`dataset ${datasetId}, comercio ${comercioCuit}`); console.log(`dataset ${datasetId}, comercio ${comercioCuit}`);
@ -149,7 +149,7 @@ async function importDataset(dir: string) {
// productos_precio_lista seria precio_unitario_bulto_por_unidad_venta_con_iva. // productos_precio_lista seria precio_unitario_bulto_por_unidad_venta_con_iva.
// pero no quiero mentir, asi que por ahora no lo importo // pero no quiero mentir, asi que por ahora no lo importo
console.error( console.error(
`No voy a importar el dataset ${dir} porque el formato está mal. Pero se podría importar. Pero por ahora no lo voy a hacer. Véase https://gist.github.com/catdevnull/587d5c63c4bab11b9798861c917db93b`, `No voy a importar el dataset ${dir} porque el formato está mal. Pero se podría importar. Pero por ahora no lo voy a hacer. Véase https://gist.github.com/catdevnull/587d5c63c4bab11b9798861c917db93b`
); );
return; return;
} }
@ -178,7 +178,7 @@ async function importDataset(dir: string) {
...data, ...data,
productos_descripcion: data.productos_descripcion.replaceAll( productos_descripcion: data.productos_descripcion.replaceAll(
"\t", "\t",
" ", " "
), ),
}; };
}); });