watson/umami
1
0
Fork 0
mirror of https://github.com/umami-software/umami.git synced 2026-02-10 07:37:11 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

update psql getChannelMetrics

Browse source
This commit is contained in:
Francis Cao 2025-07-31 09:45:19 -07:00
parent fba7e12c36
commit c8b4ee8ca5
1 changed files with 32 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

42
src/queries/sql/getChannelMetrics.ts
View file

@ -29,17 +29,35 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) {
return rawQuery( return rawQuery(
` `
select WITH channels as (
referrer_domain as domain, select case when ${toPostgresPositionClause('utm_medium', ['cp', 'ppc', 'retargeting', 'paid'])} then 'paid' else 'organic' end prefix,
url_query as query, case
count(distinct session_id) as visitors when referrer_domain = '' and url_query = '' then 'direct'
from website_event when ${toPostgresPositionClause('url_query', PAID_AD_PARAMS)} then 'paidAds'
${cohortQuery} when ${toPostgresPositionClause('utm_medium', ['referral', 'app', 'link'])} then 'referral'
where website_id = {{websiteId::uuid}} when position(utm_medium, 'affiliate') > 0 then 'affiliate'
${filterQuery} when position(utm_medium, 'sms') > 0 or position(utm_source, 'sms') > 0 then 'sms'
when ${toPostgresPositionClause('referrer_domain', SEARCH_DOMAINS)} or position(utm_medium, 'organic') > 0 then concat(prefix, 'Search')
when ${toPostgresPositionClause('referrer_domain', SOCIAL_DOMAINS)} then concat(prefix, 'Social')
when ${toPostgresPositionClause('referrer_domain', EMAIL_DOMAINS)} or position(utm_medium, 'mail') > 0 then 'email'
when ${toPostgresPositionClause('referrer_domain', SHOPPING_DOMAINS)} or position(utm_medium, 'shop') > 0 then concat(prefix, 'Shopping')
when ${toPostgresPositionClause('referrer_domain', VIDEO_DOMAINS)} or position(utm_medium, 'video') > 0 then concat(prefix, 'Video')
else '' end AS x,
count(distinct session_id) y
from website_event
${cohortQuery}
where website_id = {{websiteId::uuid}}
and event_type = {{eventType}}
${dateQuery} ${dateQuery}
group by 1, 2 ${filterQuery}
order by visitors desc group by 1, 2
order by y desc)
select x, sum(y) y
from channels
where x != ''
group by x
order by y desc;
`, `,
queryParams, queryParams,
); );
@ -106,3 +124,7 @@ async function clickhouseQuery(
function toClickHouseStringArray(arr: string[]): string { function toClickHouseStringArray(arr: string[]): string {
return arr.map(p => `'${p.replace(/'/g, "\\'")}'`).join(', '); return arr.map(p => `'${p.replace(/'/g, "\\'")}'`).join(', ');
} }
function toPostgresPositionClause(column: string, arr: string[]) {
return arr.map(val => `position(${column}, '${val.replace(/'/g, "''")}') > 0`).join(' OR\n ');
}