# License: AGPL-3.0-or-later WITH Web-Template-Output-Additional-Permission-3.0-or-later module QueryEventMetrics def self.expression(additional_selects=[]) selects = [ "coalesce(tickets.total, 0) AS total_attendees", "coalesce(tickets.checked_in_count, 0) AS checked_in_count", "coalesce(ticket_payments.total_paid, 0) AS tickets_total_paid", "coalesce(donations.payment_total, 0) AS donations_total_paid", "coalesce(ticket_payments.total_paid, 0) + coalesce(donations.payment_total, 0) AS total_paid" ] tickets_sub = Qx.select("event_id", "SUM(quantity) AS total", "SUM(tickets.checked_in::int) AS checked_in_count") .from("tickets") .group_by("event_id") .as("tickets") ticket_payments_subquery = Qx.select("payment_id", "MAX(event_id) AS event_id").from("tickets").group_by("payment_id").as("tickets") ticket_payments_sub = Qx.select("SUM(payments.gross_amount) AS total_paid", "tickets.event_id") .from(:payments) .join(ticket_payments_subquery, "payments.id=tickets.payment_id") .group_by("tickets.event_id") .as("ticket_payments") donations_sub = Qx.select("event_id", "SUM(payments.gross_amount) as payment_total") .from("donations") .group_by("event_id") .left_join("payments", "donations.id=payments.donation_id") .as("donations") selects = selects.concat(additional_selects) return Qx.select(*selects) .from("events") .left_join( [tickets_sub, "tickets.event_id = events.id"], [donations_sub, "donations.event_id = events.id"], [ticket_payments_sub, "ticket_payments.event_id=events.id"] ) end def self.with_event_ids(event_ids) return [] if event_ids.empty? QueryEventMetrics.expression().where("events.id in ($ids)", ids: event_ids).execute end def self.for_listings(id_type, id, params) selects = [ 'events.id', 'events.name', 'events.venue_name', 'events.address', 'events.city', 'events.state_code', 'events.zip_code', 'events.start_datetime', 'events.end_datetime', 'events.organizer_email' ] exp = QueryEventMetrics.expression(selects) if id_type == 'profile' exp = exp.and_where(["events.profile_id = $id", id: id]) end if id_type == 'nonprofit' exp = exp.and_where(["events.nonprofit_id = $id", id: id]) end if params['active'].present? exp = exp .and_where(['events.end_datetime >= $date', date: Time.now]) .and_where(["events.published = TRUE AND coalesce(events.deleted, FALSE) = FALSE"]) end if params['past'].present? exp = exp .and_where(['events.end_datetime < $date', date: Time.now]) .and_where(["events.published = TRUE AND coalesce(events.deleted, FALSE) = FALSE"]) end if params['unpublished'].present? exp = exp.and_where(["coalesce(events.published, FALSE) = FALSE AND coalesce(events.deleted, FALSE) = FALSE"]) end if params['deleted'].present? exp = exp.and_where(["events.deleted = TRUE"]) end return exp.execute end end