davinTI/app-dono-modulos
16
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Inserção de agendamento para atualização de dados da implmentação C5
davinTI/app-dono-modulos/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Lucas Favaro da Silva
2026-05-21 11:33:24 -03:00
parent e2f1020888
commit c909a1a42a
1 changed files with 89 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/flash/flash.module.ts
+89 -5
View File
@@ -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({