From c909a1a42a578afef68ca520c66b43d3e397a701 Mon Sep 17 00:00:00 2001 From: "lucas.favaro" Date: Thu, 21 May 2026 11:33:24 -0300 Subject: [PATCH] =?UTF-8?q?Inser=C3=A7=C3=A3o=20de=20agendamento=20para=20?= =?UTF-8?q?atualiza=C3=A7=C3=A3o=20de=20dados=20da=20implmenta=C3=A7=C3=A3?= =?UTF-8?q?o=20C5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/flash/flash.module.ts | 94 ++++++++++++++++++++++++++++++++++++--- 1 file changed, 89 insertions(+), 5 deletions(-) diff --git a/src/flash/flash.module.ts b/src/flash/flash.module.ts index 4eeb4f5..c1e8f80 100644 --- a/src/flash/flash.module.ts +++ b/src/flash/flash.module.ts @@ -200,7 +200,82 @@ export default moduleFactory C5: { flash: (args) => { return { - sql: /*sql*/ ``, + sql: /*sql*/ ` + SELECT + x.canalapp AS canalapp, + x.numero_loja AS cod_empresa, + x.nome_loja AS nomeempresaapp, + CASE + WHEN GROUPING(x.numero_loja) = 1 THEN 1 + ELSE 0 + END AS is_total, + SUM(CASE WHEN x.periodo = 'ATUAL' AND x.data = TO_DATE(${args.data_venda}, 'YYYY-MM-DD') THEN x.venda ELSE 0 END) AS venda_dia, + SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) * 1.02 AS meta_mes, + SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) AS mes_atual, + SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) - + SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) * 1.02 AS dif_mes_atual, + CASE + WHEN SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) * 1.02 = 0 THEN 0 + ELSE ROUND( + ((SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) / + (SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) * 1.02)) * 100) - 100 + , 2) + END AS variacao_atual, + SUM(CASE WHEN x.periodo = 'MES_ANTERIOR' THEN x.venda ELSE 0 END) AS mes_anterior, + SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) - + SUM(CASE WHEN x.periodo = 'MES_ANTERIOR' THEN x.venda ELSE 0 END) AS dif_mes_anterior, + CASE + WHEN SUM(CASE WHEN x.periodo = 'MES_ANTERIOR' THEN x.venda ELSE 0 END) = 0 THEN 0 + ELSE ROUND( + ((SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) / + SUM(CASE WHEN x.periodo = 'MES_ANTERIOR' THEN x.venda ELSE 0 END)) * 100) - 100 + , 2) + END AS variacao_mes_anterior, + SUM(CASE WHEN x.periodo = 'ANO_ANTERIOR' THEN x.venda ELSE 0 END) AS ano_anterior, + SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) - + SUM(CASE WHEN x.periodo = 'ANO_ANTERIOR' THEN x.venda ELSE 0 END) AS dif_ano_anterior, + CASE + WHEN SUM(CASE WHEN x.periodo = 'ANO_ANTERIOR' THEN x.venda ELSE 0 END) = 0 THEN 0 + ELSE ROUND( + ((SUM(CASE WHEN x.periodo = 'ATUAL' THEN x.venda ELSE 0 END) / + SUM(CASE WHEN x.periodo = 'ANO_ANTERIOR' THEN x.venda ELSE 0 END)) * 100) - 100 + , 2) + END AS variacao_ano_anterior + FROM ( + SELECT + sv.numero_loja, + sv.nome_loja, + sv.data, + sv.venda, + CASE WHEN sv.nrosegmento = 5 THEN 'GOURMET' ELSE 'VAREJO' END AS canalapp, + CASE + WHEN sv.data BETWEEN TRUNC(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), 'MM') + AND TO_DATE(${args.data_venda}, 'YYYY-MM-DD') + THEN 'ATUAL' + WHEN sv.data BETWEEN ADD_MONTHS(TRUNC(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), 'MM'), -1) + AND ADD_MONTHS(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), -1) + THEN 'MES_ANTERIOR' + WHEN sv.data BETWEEN ADD_MONTHS(TRUNC(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), 'MM'), -12) + AND ADD_MONTHS(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), -12) + THEN 'ANO_ANTERIOR' + END AS periodo + FROM TB_SUMARIZACAO_VENDA sv + WHERE (sv.numero_loja IN (${args.ctx_user_companies_for_module})) + AND ( + sv.data BETWEEN TRUNC(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), 'MM') + AND TO_DATE(${args.data_venda}, 'YYYY-MM-DD') + OR sv.data BETWEEN ADD_MONTHS(TRUNC(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), 'MM'), -1) + AND ADD_MONTHS(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), -1) + OR sv.data BETWEEN ADD_MONTHS(TRUNC(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), 'MM'), -12) + AND ADD_MONTHS(TO_DATE(${args.data_venda}, 'YYYY-MM-DD'), -12) + ) + ) x + GROUP BY + GROUPING SETS ( + (x.canalapp, x.numero_loja, x.nome_loja), + () + ) + `, }; }, flash_categorias: (args) => { @@ -604,13 +679,22 @@ where 1 = 0`, }) .withSchedules({ C5: [ - { + createSchedule({ name: "Procedure que atualiza os dados do flash", - command: /*sql*/ `BEGIN - END`, + params: [], + command: (params) => ({ + sql: /*sql*/ `BEGIN + PRC_FLASH_ATUALIZA_VENDA_DONO( + p_data_inicial => TRUNC(SYSDATE) - 30, + p_data_final => TRUNC(SYSDATE), + p_empresa_ini => 1, + p_empresa_fim => 300 + ); + END;`, + }), cron: "0 * * * *", timeout_seconds: 2400, - }, + }), ], C5_big: [ createSchedule({