This commit is contained in:
Cat /dev/Nulo 2024-12-01 16:58:14 -03:00
parent 8da80120d8
commit ad9d2b15c2
2 changed files with 24 additions and 14 deletions

View file

@ -8,11 +8,11 @@ CREATE SEQUENCE seq_datasets START 1;
CREATE TABLE precios ( CREATE TABLE precios (
id_dataset INTEGER, id_dataset INTEGER not null,
id_comercio INTEGER, id_comercio INTEGER not null,
id_bandera INTEGER, id_bandera INTEGER not null,
id_sucursal INTEGER, id_sucursal INTEGER not null,
id_producto BIGINT, id_producto BIGINT not null,
productos_ean INTEGER, productos_ean INTEGER,
productos_descripcion TEXT, productos_descripcion TEXT,
productos_cantidad_presentacion DECIMAL(10,2), productos_cantidad_presentacion DECIMAL(10,2),
@ -36,16 +36,16 @@ CREATE TABLE productos_descripcion_index (
); );
CREATE TABLE sucursales ( CREATE TABLE sucursales (
id_dataset INTEGER, id_dataset INTEGER not null,
id_comercio INTEGER, id_comercio INTEGER not null,
id_bandera INTEGER, id_bandera INTEGER not null,
id_sucursal INTEGER, id_sucursal INTEGER not null,
sucursales_nombre TEXT, sucursales_nombre TEXT,
sucursales_tipo TEXT, sucursales_tipo TEXT,
sucursales_calle TEXT, sucursales_calle TEXT,
sucursales_numero TEXT, sucursales_numero TEXT,
sucursales_latitud DECIMAL, sucursales_latitud DECIMAL(18, 15),
sucursales_longitud DECIMAL, sucursales_longitud DECIMAL(18, 15),
sucursales_observaciones TEXT, sucursales_observaciones TEXT,
sucursales_barrio TEXT, sucursales_barrio TEXT,
sucursales_codigo_postal TEXT, sucursales_codigo_postal TEXT,
@ -63,7 +63,7 @@ CREATE TABLE sucursales (
); );
CREATE TABLE banderas ( CREATE TABLE banderas (
id_dataset INTEGER, id_dataset INTEGER not null,
id_comercio INTEGER NOT NULL, id_comercio INTEGER NOT NULL,
id_bandera INTEGER NOT NULL, id_bandera INTEGER NOT NULL,
comercio_cuit TEXT NOT NULL, comercio_cuit TEXT NOT NULL,

View file

@ -76,8 +76,18 @@ async function importSucursales(connection, datasetId, dir) {
appender.appendVarchar(data.sucursales_tipo); appender.appendVarchar(data.sucursales_tipo);
appender.appendVarchar(data.sucursales_calle); appender.appendVarchar(data.sucursales_calle);
appender.appendVarchar(data.sucursales_numero); appender.appendVarchar(data.sucursales_numero);
appender.appendInteger(parseFloat(data.sucursales_latitud)); /** @type {[number, number]} */
appender.appendInteger(parseFloat(data.sucursales_longitud)); let [lat, lon] = [
parseFloat(data.sucursales_latitud),
parseFloat(data.sucursales_longitud),
];
if (isNaN(lat) || isNaN(lon)) {
appender.appendNull();
appender.appendNull();
} else {
appender.appendDouble(lat);
appender.appendDouble(lon);
}
appender.appendVarchar(data.sucursales_observaciones); appender.appendVarchar(data.sucursales_observaciones);
appender.appendVarchar(data.sucursales_barrio); appender.appendVarchar(data.sucursales_barrio);
appender.appendVarchar(data.sucursales_codigo_postal); appender.appendVarchar(data.sucursales_codigo_postal);