houdini/lib/query/query_event_metrics.rb

# 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