publico/drivers
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refatoração PilaoEnviar

Browse source
This commit is contained in:
Luiz Silva 2024-10-01 13:38:40 -03:00
parent dc1b5171d7
commit 93d3caa378
11 changed files with 179 additions and 71 deletions
Download patch file Download diff file Expand all files Collapse all files

64
dist-import/pilao-de-dados/_enviar_registros.js
View file

@ -17,27 +17,45 @@ export const zp_enviar_registros = z.object({
tipo: z_tipo_coluna_base_dados.optional().nullable(),
}))),
});
export const enviar_registros = ({ conta, produto, emDesenvolvimento, ver_log, }) => async ({ registros: registros_entrada, tabela, }) => {
const registros = [...registros_entrada];
const url = new URL(`${urlPilao(emDesenvolvimento).api}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`);
if (ver_log)
console.log(`[PILÃO]: Enviando "${registros.length}" registros na tabela "${tabela}" para "${url}".`);
const tamanhoBlocos = 1000;
while (registros.length > 0) {
const bloco = registros
.splice(0, tamanhoBlocos)
.map((r) => Object.fromEntries(Object.entries(r).map(([k, v]) => [k, v === undefined ? null : v])));
const resp = await node_fetch(url.toString(), {
method: "POST",
body: JSON.stringify({ tabela, registros: bloco }),
headers: { "Content-Type": "application/json" },
})
.then((r) => r.json())
.catch((e) => respostaComuns.erro("Erro ao enviar registros", [e.message]))
.then((r) => r);
if (resp.eErro) {
return resp;
}
class ClassPilaoEnviar {
constructor({ conta, produto, emDesenvolvimento, ver_log, }) {
this.__registros = [];
this.__conta = conta;
this.__produto = produto;
this.__emDesenvolvimento = emDesenvolvimento;
this.__ver_log = ver_log;
}
return respostaComuns.valor(true);
};
tabela(tabela) {
this.__tabela = tabela;
return this;
}
adicionarRegistro(...registro) {
this.__registros.push(...registro);
return this;
}
async enviar() {
const registros = this.__registros;
const url = new URL(`${urlPilao(this.__emDesenvolvimento).api}/enviar_registros/${this.__produto}/${this.__conta}`);
if (this.__ver_log)
console.log(`[PILÃO]: Enviando "${registros.length}" registros na tabela "${this.__tabela}" para "${url}".`);
const tamanhoBlocos = 1000;
while (registros.length > 0) {
const bloco = registros
.splice(0, tamanhoBlocos)
.map((r) => Object.fromEntries(Object.entries(r).map(([k, v]) => [k, v === undefined ? null : v])));
const resp = await node_fetch(url.toString(), {
method: "POST",
body: JSON.stringify({ tabela: this.__tabela, registros: bloco }),
headers: { "Content-Type": "application/json" },
})
.then((r) => r.json())
.catch((e) => respostaComuns.erro("Erro ao enviar registros", [e.message]))
.then((r) => r);
if (resp.eErro) {
return resp;
}
}
return respostaComuns.valor(true);
}
}
export const PilaoEnviar = (_) => new ClassPilaoEnviar(_);