From 2cf1dfe75d4a6af0688f1568e9f24dc49f8c0ef0 Mon Sep 17 00:00:00 2001 From: Luiz Silva Date: Tue, 1 Oct 2024 14:19:18 -0300 Subject: [PATCH] build --- .../pilao-de-dados/_deletar_registros.d.ts | 14 ----- .../pilao-de-dados/_deletar_registros.js | 29 ---------- .../pilao-de-dados/_enviar_registros.d.ts | 9 ++- .../pilao-de-dados/_enviar_registros.js | 41 ++++++++++++-- dist-import/pilao-de-dados/index.d.ts | 21 ++----- dist-import/pilao-de-dados/index.js | 3 - .../pilao-de-dados/_deletar_registros.d.ts | 14 ----- .../pilao-de-dados/_deletar_registros.js | 36 ------------ .../pilao-de-dados/_enviar_registros.d.ts | 9 ++- .../pilao-de-dados/_enviar_registros.js | 41 ++++++++++++-- dist-require/pilao-de-dados/index.d.ts | 21 ++----- dist-require/pilao-de-dados/index.js | 3 - package.json | 2 +- src/pilao-de-dados/_deletar_registros.ts | 47 ---------------- src/pilao-de-dados/_enviar_registros.ts | 55 +++++++++++++++++-- src/pilao-de-dados/index.ts | 5 +- 16 files changed, 149 insertions(+), 201 deletions(-) delete mode 100644 dist-import/pilao-de-dados/_deletar_registros.d.ts delete mode 100644 dist-import/pilao-de-dados/_deletar_registros.js delete mode 100644 dist-require/pilao-de-dados/_deletar_registros.d.ts delete mode 100644 dist-require/pilao-de-dados/_deletar_registros.js delete mode 100644 src/pilao-de-dados/_deletar_registros.ts diff --git a/dist-import/pilao-de-dados/_deletar_registros.d.ts b/dist-import/pilao-de-dados/_deletar_registros.d.ts deleted file mode 100644 index ef3fa21..0000000 --- a/dist-import/pilao-de-dados/_deletar_registros.d.ts +++ /dev/null @@ -1,14 +0,0 @@ -import type { tipoResposta } from "p-respostas"; -import { z } from "zod"; -import { type zp_produto_conta } from "./variaveis"; -export declare const zp_deletar_registros: z.ZodObject<{ - tabela: z.ZodString; - codigos: z.ZodArray; -}, "strip", z.ZodTypeAny, { - tabela: string; - codigos: string[]; -}, { - tabela: string; - codigos: string[]; -}>; -export declare const deletar_registros: ({ conta, produto, emDesenvolvimento }: z.infer) => ({ codigos: codigos_entrada, tabela, }: z.infer) => Promise>; diff --git a/dist-import/pilao-de-dados/_deletar_registros.js b/dist-import/pilao-de-dados/_deletar_registros.js deleted file mode 100644 index 7a0ca13..0000000 --- a/dist-import/pilao-de-dados/_deletar_registros.js +++ /dev/null @@ -1,29 +0,0 @@ -import node_fetch from "cross-fetch"; -import { respostaComuns } from "p-respostas"; -import { z } from "zod"; -import { urlPilao } from "./variaveis"; -//enviar registros para base de dados -export const zp_deletar_registros = z.object({ - tabela: z.string(), - codigos: z.array(z.string()), -}); -export const deletar_registros = ({ conta, produto, emDesenvolvimento }) => async ({ codigos: codigos_entrada, tabela, }) => { - const codigos = [...codigos_entrada]; - const url = new URL(`${urlPilao(emDesenvolvimento).api}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`); - const tamanhoBlocos = 1000; - while (codigos.length > 0) { - const bloco = codigos.splice(0, tamanhoBlocos); - const resp = await node_fetch(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela, codigos: 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); -}; diff --git a/dist-import/pilao-de-dados/_enviar_registros.d.ts b/dist-import/pilao-de-dados/_enviar_registros.d.ts index b293360..d355390 100644 --- a/dist-import/pilao-de-dados/_enviar_registros.d.ts +++ b/dist-import/pilao-de-dados/_enviar_registros.d.ts @@ -57,11 +57,14 @@ declare class ClassPilaoEnviar { __emDesenvolvimento: boolean | undefined; __ver_log: boolean | undefined; __tabela: string | undefined; - __registros: z.infer["registros"]; + __registrosParaEnvio: z.infer["registros"]; + __codigosParaDeletar: string[]; constructor({ conta, produto, emDesenvolvimento, ver_log, }: z.infer); tabela(tabela: string): this; - adicionarRegistro(...registro: z.infer["registros"]): this; - enviar(): Promise>; + adicionarRegistroParaEnviar(...registro: z.infer["registros"]): this; + __salvar_enviar_registros(): Promise>; + __salvar_deletar_registros(): Promise>; + salvar(): Promise>; } export declare const PilaoEnviar: (_: z.infer) => ClassPilaoEnviar; export {}; diff --git a/dist-import/pilao-de-dados/_enviar_registros.js b/dist-import/pilao-de-dados/_enviar_registros.js index 8ee218c..a3b0db8 100644 --- a/dist-import/pilao-de-dados/_enviar_registros.js +++ b/dist-import/pilao-de-dados/_enviar_registros.js @@ -19,7 +19,8 @@ export const zp_enviar_registros = z.object({ }); class ClassPilaoEnviar { constructor({ conta, produto, emDesenvolvimento, ver_log, }) { - this.__registros = []; + this.__registrosParaEnvio = []; + this.__codigosParaDeletar = []; this.__conta = conta; this.__produto = produto; this.__emDesenvolvimento = emDesenvolvimento; @@ -29,12 +30,12 @@ class ClassPilaoEnviar { this.__tabela = tabela; return this; } - adicionarRegistro(...registro) { - this.__registros.push(...registro); + adicionarRegistroParaEnviar(...registro) { + this.__registrosParaEnvio.push(...registro); return this; } - async enviar() { - const registros = this.__registros; + async __salvar_enviar_registros() { + const registros = this.__registrosParaEnvio; 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}".`); @@ -57,5 +58,35 @@ class ClassPilaoEnviar { } return respostaComuns.valor(true); } + async __salvar_deletar_registros() { + const codigos = [...this.__codigosParaDeletar]; + const url = new URL(`${urlPilao(this.__emDesenvolvimento).api}/deletar_registros/${this.__produto}/${this.__conta}`); + const tamanhoBlocos = 1000; + while (codigos.length > 0) { + const bloco = codigos.splice(0, tamanhoBlocos); + const resp = await node_fetch(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela: this.__tabela, codigos: 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; + } + } + this.__codigosParaDeletar; + return respostaComuns.valor(true); + } + async salvar() { + const re = await this.__salvar_enviar_registros(); + if (re.eErro) + return re; + const rd = await this.__salvar_deletar_registros(); + if (rd.eErro) + return rd; + return respostaComuns.valor(true); + } } export const PilaoEnviar = (_) => new ClassPilaoEnviar(_); diff --git a/dist-import/pilao-de-dados/index.d.ts b/dist-import/pilao-de-dados/index.d.ts index dfd0f7f..c11f8e9 100644 --- a/dist-import/pilao-de-dados/index.d.ts +++ b/dist-import/pilao-de-dados/index.d.ts @@ -1,4 +1,3 @@ -import { zp_deletar_registros } from "./_deletar_registros"; export { PREFIXO_PILAO, urlPilao } from "./variaveis"; import { zp_enviar_registros } from "./_enviar_registros"; import { zp_produto_conta } from "./variaveis"; @@ -313,10 +312,13 @@ export declare const pPilao: { __emDesenvolvimento: boolean | undefined; __ver_log: boolean | undefined; __tabela: string | undefined; - __registros: import("zod").TypeOf["registros"]; + __registrosParaEnvio: import("zod").TypeOf["registros"]; + __codigosParaDeletar: string[]; tabela(tabela: string): any; - adicionarRegistro(...registro: import("zod").TypeOf["registros"]): any; - enviar(): Promise>; + adicionarRegistroParaEnviar(...registro: import("zod").TypeOf["registros"]): any; + __salvar_enviar_registros(): Promise>; + __salvar_deletar_registros(): Promise>; + salvar(): Promise>; }; zp_enviar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; @@ -368,17 +370,6 @@ export declare const pPilao: { ver_log?: boolean | undefined; }>; validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; - deletar_registros: ({ conta, produto, emDesenvolvimento }: import("zod").TypeOf) => ({ codigos: codigos_entrada, tabela, }: import("zod").TypeOf) => Promise>; - zp_deletar_registros: import("zod").ZodObject<{ - tabela: import("zod").ZodString; - codigos: import("zod").ZodArray; - }, "strip", import("zod").ZodTypeAny, { - tabela: string; - codigos: string[]; - }, { - tabela: string; - codigos: string[]; - }>; operadores_pilao: import("zod").ZodEnum<["=", "!=", ">", "<", ">=", "<=", "∩"]>; operadores_permitidos_por_tipo: { texto: ("=" | "!=" | ">" | "<" | ">=" | "<=" | "∩")[]; diff --git a/dist-import/pilao-de-dados/index.js b/dist-import/pilao-de-dados/index.js index e923830..de0c914 100644 --- a/dist-import/pilao-de-dados/index.js +++ b/dist-import/pilao-de-dados/index.js @@ -1,4 +1,3 @@ -import { deletar_registros, zp_deletar_registros } from "./_deletar_registros"; export { PREFIXO_PILAO, urlPilao } from "./variaveis"; import { PilaoEnviar, zp_enviar_registros, zp_registrar_base_dados, } from "./_enviar_registros"; import { operadores_permitidos_por_tipo, operadores_pilao, validarZ, zp_produto_conta, } from "./variaveis"; @@ -11,8 +10,6 @@ export const pPilao = { serie_consultar, zp_produto_conta, validarZ, - deletar_registros, - zp_deletar_registros, operadores_pilao, operadores_permitidos_por_tipo, z_filtro, diff --git a/dist-require/pilao-de-dados/_deletar_registros.d.ts b/dist-require/pilao-de-dados/_deletar_registros.d.ts deleted file mode 100644 index ef3fa21..0000000 --- a/dist-require/pilao-de-dados/_deletar_registros.d.ts +++ /dev/null @@ -1,14 +0,0 @@ -import type { tipoResposta } from "p-respostas"; -import { z } from "zod"; -import { type zp_produto_conta } from "./variaveis"; -export declare const zp_deletar_registros: z.ZodObject<{ - tabela: z.ZodString; - codigos: z.ZodArray; -}, "strip", z.ZodTypeAny, { - tabela: string; - codigos: string[]; -}, { - tabela: string; - codigos: string[]; -}>; -export declare const deletar_registros: ({ conta, produto, emDesenvolvimento }: z.infer) => ({ codigos: codigos_entrada, tabela, }: z.infer) => Promise>; diff --git a/dist-require/pilao-de-dados/_deletar_registros.js b/dist-require/pilao-de-dados/_deletar_registros.js deleted file mode 100644 index 7dae1b6..0000000 --- a/dist-require/pilao-de-dados/_deletar_registros.js +++ /dev/null @@ -1,36 +0,0 @@ -"use strict"; -var __importDefault = (this && this.__importDefault) || function (mod) { - return (mod && mod.__esModule) ? mod : { "default": mod }; -}; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.deletar_registros = exports.zp_deletar_registros = void 0; -const cross_fetch_1 = __importDefault(require("cross-fetch")); -const p_respostas_1 = require("p-respostas"); -const zod_1 = require("zod"); -const variaveis_1 = require("./variaveis"); -//enviar registros para base de dados -exports.zp_deletar_registros = zod_1.z.object({ - tabela: zod_1.z.string(), - codigos: zod_1.z.array(zod_1.z.string()), -}); -const deletar_registros = ({ conta, produto, emDesenvolvimento }) => async ({ codigos: codigos_entrada, tabela, }) => { - const codigos = [...codigos_entrada]; - const url = new URL(`${(0, variaveis_1.urlPilao)(emDesenvolvimento).api}/${Object.keys({ deletar_registros: exports.deletar_registros })[0]}/${produto}/${conta}`); - const tamanhoBlocos = 1000; - while (codigos.length > 0) { - const bloco = codigos.splice(0, tamanhoBlocos); - const resp = await (0, cross_fetch_1.default)(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela, codigos: bloco }), - headers: { "Content-Type": "application/json" }, - }) - .then((r) => r.json()) - .catch((e) => p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message])) - .then((r) => r); - if (resp.eErro) { - return resp; - } - } - return p_respostas_1.respostaComuns.valor(true); -}; -exports.deletar_registros = deletar_registros; diff --git a/dist-require/pilao-de-dados/_enviar_registros.d.ts b/dist-require/pilao-de-dados/_enviar_registros.d.ts index b293360..d355390 100644 --- a/dist-require/pilao-de-dados/_enviar_registros.d.ts +++ b/dist-require/pilao-de-dados/_enviar_registros.d.ts @@ -57,11 +57,14 @@ declare class ClassPilaoEnviar { __emDesenvolvimento: boolean | undefined; __ver_log: boolean | undefined; __tabela: string | undefined; - __registros: z.infer["registros"]; + __registrosParaEnvio: z.infer["registros"]; + __codigosParaDeletar: string[]; constructor({ conta, produto, emDesenvolvimento, ver_log, }: z.infer); tabela(tabela: string): this; - adicionarRegistro(...registro: z.infer["registros"]): this; - enviar(): Promise>; + adicionarRegistroParaEnviar(...registro: z.infer["registros"]): this; + __salvar_enviar_registros(): Promise>; + __salvar_deletar_registros(): Promise>; + salvar(): Promise>; } export declare const PilaoEnviar: (_: z.infer) => ClassPilaoEnviar; export {}; diff --git a/dist-require/pilao-de-dados/_enviar_registros.js b/dist-require/pilao-de-dados/_enviar_registros.js index c72ad4f..5ec56ba 100644 --- a/dist-require/pilao-de-dados/_enviar_registros.js +++ b/dist-require/pilao-de-dados/_enviar_registros.js @@ -25,7 +25,8 @@ exports.zp_enviar_registros = zod_1.z.object({ }); class ClassPilaoEnviar { constructor({ conta, produto, emDesenvolvimento, ver_log, }) { - this.__registros = []; + this.__registrosParaEnvio = []; + this.__codigosParaDeletar = []; this.__conta = conta; this.__produto = produto; this.__emDesenvolvimento = emDesenvolvimento; @@ -35,12 +36,12 @@ class ClassPilaoEnviar { this.__tabela = tabela; return this; } - adicionarRegistro(...registro) { - this.__registros.push(...registro); + adicionarRegistroParaEnviar(...registro) { + this.__registrosParaEnvio.push(...registro); return this; } - async enviar() { - const registros = this.__registros; + async __salvar_enviar_registros() { + const registros = this.__registrosParaEnvio; const url = new URL(`${(0, variaveis_1.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}".`); @@ -63,6 +64,36 @@ class ClassPilaoEnviar { } return p_respostas_1.respostaComuns.valor(true); } + async __salvar_deletar_registros() { + const codigos = [...this.__codigosParaDeletar]; + const url = new URL(`${(0, variaveis_1.urlPilao)(this.__emDesenvolvimento).api}/deletar_registros/${this.__produto}/${this.__conta}`); + const tamanhoBlocos = 1000; + while (codigos.length > 0) { + const bloco = codigos.splice(0, tamanhoBlocos); + const resp = await (0, cross_fetch_1.default)(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela: this.__tabela, codigos: bloco }), + headers: { "Content-Type": "application/json" }, + }) + .then((r) => r.json()) + .catch((e) => p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message])) + .then((r) => r); + if (resp.eErro) { + return resp; + } + } + this.__codigosParaDeletar; + return p_respostas_1.respostaComuns.valor(true); + } + async salvar() { + const re = await this.__salvar_enviar_registros(); + if (re.eErro) + return re; + const rd = await this.__salvar_deletar_registros(); + if (rd.eErro) + return rd; + return p_respostas_1.respostaComuns.valor(true); + } } const PilaoEnviar = (_) => new ClassPilaoEnviar(_); exports.PilaoEnviar = PilaoEnviar; diff --git a/dist-require/pilao-de-dados/index.d.ts b/dist-require/pilao-de-dados/index.d.ts index dfd0f7f..c11f8e9 100644 --- a/dist-require/pilao-de-dados/index.d.ts +++ b/dist-require/pilao-de-dados/index.d.ts @@ -1,4 +1,3 @@ -import { zp_deletar_registros } from "./_deletar_registros"; export { PREFIXO_PILAO, urlPilao } from "./variaveis"; import { zp_enviar_registros } from "./_enviar_registros"; import { zp_produto_conta } from "./variaveis"; @@ -313,10 +312,13 @@ export declare const pPilao: { __emDesenvolvimento: boolean | undefined; __ver_log: boolean | undefined; __tabela: string | undefined; - __registros: import("zod").TypeOf["registros"]; + __registrosParaEnvio: import("zod").TypeOf["registros"]; + __codigosParaDeletar: string[]; tabela(tabela: string): any; - adicionarRegistro(...registro: import("zod").TypeOf["registros"]): any; - enviar(): Promise>; + adicionarRegistroParaEnviar(...registro: import("zod").TypeOf["registros"]): any; + __salvar_enviar_registros(): Promise>; + __salvar_deletar_registros(): Promise>; + salvar(): Promise>; }; zp_enviar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; @@ -368,17 +370,6 @@ export declare const pPilao: { ver_log?: boolean | undefined; }>; validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; - deletar_registros: ({ conta, produto, emDesenvolvimento }: import("zod").TypeOf) => ({ codigos: codigos_entrada, tabela, }: import("zod").TypeOf) => Promise>; - zp_deletar_registros: import("zod").ZodObject<{ - tabela: import("zod").ZodString; - codigos: import("zod").ZodArray; - }, "strip", import("zod").ZodTypeAny, { - tabela: string; - codigos: string[]; - }, { - tabela: string; - codigos: string[]; - }>; operadores_pilao: import("zod").ZodEnum<["=", "!=", ">", "<", ">=", "<=", "∩"]>; operadores_permitidos_por_tipo: { texto: ("=" | "!=" | ">" | "<" | ">=" | "<=" | "∩")[]; diff --git a/dist-require/pilao-de-dados/index.js b/dist-require/pilao-de-dados/index.js index 33cf3f8..8c7d4e5 100644 --- a/dist-require/pilao-de-dados/index.js +++ b/dist-require/pilao-de-dados/index.js @@ -1,7 +1,6 @@ "use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.pPilao = exports.urlPilao = exports.PREFIXO_PILAO = void 0; -const _deletar_registros_1 = require("./_deletar_registros"); var variaveis_1 = require("./variaveis"); Object.defineProperty(exports, "PREFIXO_PILAO", { enumerable: true, get: function () { return variaveis_1.PREFIXO_PILAO; } }); Object.defineProperty(exports, "urlPilao", { enumerable: true, get: function () { return variaveis_1.urlPilao; } }); @@ -16,8 +15,6 @@ exports.pPilao = { serie_consultar: _serie_consultar_1.serie_consultar, zp_produto_conta: variaveis_2.zp_produto_conta, validarZ: variaveis_2.validarZ, - deletar_registros: _deletar_registros_1.deletar_registros, - zp_deletar_registros: _deletar_registros_1.zp_deletar_registros, operadores_pilao: variaveis_2.operadores_pilao, operadores_permitidos_por_tipo: variaveis_2.operadores_permitidos_por_tipo, z_filtro: _serie_consultar_1.z_filtro, diff --git a/package.json b/package.json index 94349d0..6b6a100 100755 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "p-drives", - "version": "0.151.0", + "version": "0.152.0", "description": "", "main": "src/index.ts", "exports": { diff --git a/src/pilao-de-dados/_deletar_registros.ts b/src/pilao-de-dados/_deletar_registros.ts deleted file mode 100644 index 2502b0a..0000000 --- a/src/pilao-de-dados/_deletar_registros.ts +++ /dev/null @@ -1,47 +0,0 @@ -import node_fetch from "cross-fetch" -import type { tipoResposta } from "p-respostas" -import { respostaComuns } from "p-respostas" -import { z } from "zod" -import { urlPilao, type zp_produto_conta } from "./variaveis" -//enviar registros para base de dados -export const zp_deletar_registros = z.object({ - tabela: z.string(), - codigos: z.array(z.string()), -}) - -export const deletar_registros = - ({ conta, produto, emDesenvolvimento }: z.infer) => - async ({ - codigos: codigos_entrada, - tabela, - }: z.infer): Promise> => { - const codigos = [...codigos_entrada] - - const url = new URL( - `${ - urlPilao(emDesenvolvimento).api - }/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`, - ) - - const tamanhoBlocos = 1000 - - while (codigos.length > 0) { - const bloco = codigos.splice(0, tamanhoBlocos) - const resp = await node_fetch(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela, codigos: bloco }), - headers: { "Content-Type": "application/json" }, - }) - .then((r) => r.json()) - .catch((e) => - respostaComuns.erro("Erro ao enviar registros", [e.message]), - ) - .then((r) => r as tipoResposta) - - if (resp.eErro) { - return resp - } - } - - return respostaComuns.valor(true) - } diff --git a/src/pilao-de-dados/_enviar_registros.ts b/src/pilao-de-dados/_enviar_registros.ts index cebdf7d..35ea744 100644 --- a/src/pilao-de-dados/_enviar_registros.ts +++ b/src/pilao-de-dados/_enviar_registros.ts @@ -38,7 +38,8 @@ class ClassPilaoEnviar { __emDesenvolvimento: boolean | undefined __ver_log: boolean | undefined __tabela: string | undefined - __registros: z.infer["registros"] = [] + __registrosParaEnvio: z.infer["registros"] = [] + __codigosParaDeletar: string[] = [] constructor({ conta, @@ -57,15 +58,15 @@ class ClassPilaoEnviar { return this } - adicionarRegistro( + adicionarRegistroParaEnviar( ...registro: z.infer["registros"] ) { - this.__registros.push(...registro) + this.__registrosParaEnvio.push(...registro) return this } - async enviar(): Promise> { - const registros = this.__registros + async __salvar_enviar_registros(): Promise> { + const registros = this.__registrosParaEnvio const url = new URL( `${ @@ -107,6 +108,50 @@ class ClassPilaoEnviar { return respostaComuns.valor(true) } + + async __salvar_deletar_registros() { + const codigos = [...this.__codigosParaDeletar] + + const url = new URL( + `${ + urlPilao(this.__emDesenvolvimento).api + }/deletar_registros/${this.__produto}/${this.__conta}`, + ) + + const tamanhoBlocos = 1000 + + while (codigos.length > 0) { + const bloco = codigos.splice(0, tamanhoBlocos) + const resp = await node_fetch(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela: this.__tabela, codigos: bloco }), + headers: { "Content-Type": "application/json" }, + }) + .then((r) => r.json()) + .catch((e) => + respostaComuns.erro("Erro ao enviar registros", [e.message]), + ) + .then((r) => r as tipoResposta) + + if (resp.eErro) { + return resp + } + } + + this.__codigosParaDeletar + + return respostaComuns.valor(true) + } + + async salvar() { + const re = await this.__salvar_enviar_registros() + if (re.eErro) return re + + const rd = await this.__salvar_deletar_registros() + if (rd.eErro) return rd + + return respostaComuns.valor(true) + } } export const PilaoEnviar = (_: z.infer) => diff --git a/src/pilao-de-dados/index.ts b/src/pilao-de-dados/index.ts index 31a3638..507f159 100644 --- a/src/pilao-de-dados/index.ts +++ b/src/pilao-de-dados/index.ts @@ -1,4 +1,3 @@ -import { deletar_registros, zp_deletar_registros } from "./_deletar_registros" export { PREFIXO_PILAO, urlPilao } from "./variaveis" import { PilaoEnviar, @@ -18,12 +17,12 @@ import { extruturas_de_campos, visoes } from "./visoes" export const pPilao = { zp_registrar_base_dados, PilaoEnviar, + zp_enviar_registros, serie_consultar, zp_produto_conta, validarZ, - deletar_registros, - zp_deletar_registros, + operadores_pilao, operadores_permitidos_por_tipo, z_filtro,