blyzer/graphs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Optimize RFV all-period analytics
All checks were successful
Build and Deploy / build-and-deploy (push) Successful in 58s
Details

Browse Source
This commit is contained in:
Cauê Faleiros
2026-06-17 10:36:47 -03:00
parent 1889c172d0
commit 7fb2507f53
2 changed files with 63 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
backend/services/analyticsService.js
View File

@@ -262,12 +262,14 @@ const getClientAnalytics = async (range = {}) => {
const getRfmAnalytics = async (range = {}) => {
const { params, whereClause } = buildDateFilter(range);
const normalizedStart = normalizeDateParam(range.start);
const normalizedEnd = normalizeDateParam(range.end);
const periodRecencyReferenceDate = normalizedEnd ? `$${params.length}::date` : 'CURRENT_DATE';
const recencyReferenceDate = normalizedEnd ? '$1::date' : 'CURRENT_DATE';
const historyParams = normalizedEnd ? [normalizedEnd] : [];
const usePeriodAsHistory = !normalizedStart || normalizedStart <= '2000-01-01';
const [periodResult, historyResult] = await Promise.all([
pool.query(`
const periodQuery = pool.query(`
SELECT
${CUSTOMER_KEY_SQL} as customer_key,
MAX(cliente_nome) as name,
@@ -275,13 +277,15 @@ const getRfmAnalytics = async (range = {}) => {
COALESCE(SUM(quantidade * valor_unitario), 0) as monetary,
COUNT(DISTINCT COALESCE(NULLIF(pedido_id, ''), data_pedido || '_' || valor_pedido::text))::int as frequency,
COALESCE(SUM(quantidade), 0) as quantity_purchased,
MAX(data_pedido_date) as last_purchase_date
MAX(data_pedido_date) as last_purchase_date,
GREATEST((${periodRecencyReferenceDate} - MAX(data_pedido_date))::int, 0) as recency_days
FROM orders
${whereClause}
GROUP BY customer_key
ORDER BY monetary DESC;
`, params),
pool.query(`
`, params);
const historyQuery = usePeriodAsHistory ? null : pool.query(`
SELECT
${CUSTOMER_KEY_SQL} as customer_key,
MAX(cliente_nome) as name,
@@ -295,10 +299,15 @@ const getRfmAnalytics = async (range = {}) => {
WHERE data_pedido_date IS NOT NULL
AND data_pedido_date <= ${recencyReferenceDate}
GROUP BY customer_key;
`, historyParams)
]);
`, historyParams);
const historyClients = buildRfmClients(historyResult.rows.map(row => ({
const [periodResult, historyResult] = historyQuery
? await Promise.all([periodQuery, historyQuery])
: [await periodQuery, null];
const historyRows = historyResult ? historyResult.rows : periodResult.rows;
const historyClients = buildRfmClients(historyRows.map(row => ({
customerKey: row.customer_key,
name: row.name,
phone: row.phone || '',