zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix funnel sql

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-03-13 12:38:48 +01:00
parent 195a26794c
commit a0d0cfb5b8
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
apps/dashboard/src/server/api/routers/chart.ts
View File

@@ -45,9 +45,9 @@ async function getFunnelData({ projectId, ...payload }: IChartInput) {
windowFunnel(6048000000000000,'strict_increase')(toUnixTimestamp(created_at), ${funnels.join(', ')}) AS level windowFunnel(6048000000000000,'strict_increase')(toUnixTimestamp(created_at), ${funnels.join(', ')}) AS level
FROM events FROM events
WHERE (project_id = '${projectId}' AND created_at >= '${formatClickhouseDate(startDate)}') AND (created_at <= '${formatClickhouseDate(endDate)}') WHERE (project_id = '${projectId}' AND created_at >= '${formatClickhouseDate(startDate)}') AND (created_at <= '${formatClickhouseDate(endDate)}')
GROUP BY session_id;`; GROUP BY session_id`;
const sql = `SELECT level, count() AS count FROM (${innerSql}) GROUP BY level ORDER BY level DESC;`; const sql = `SELECT level, count() AS count FROM (${innerSql}) GROUP BY level ORDER BY level DESC`;
const [funnelRes, sessionRes] = await Promise.all([ const [funnelRes, sessionRes] = await Promise.all([
chQuery<{ level: number; count: number }>(sql), chQuery<{ level: number; count: number }>(sql),
@@ -56,8 +56,6 @@ async function getFunnelData({ projectId, ...payload }: IChartInput) {
), ),
]); ]);
console.log('Funnel SQL: ', sql);
if (funnelRes[0]?.level !== payload.events.length) { if (funnelRes[0]?.level !== payload.events.length) {
funnelRes.unshift({ funnelRes.unshift({
level: payload.events.length, level: payload.events.length,