Sha256: 40426e5bdd269bd53993a57ca29194de84b3e5f8ffdfe138b5e04bc820059fcb
Contents?: true
Size: 1.93 KB
Versions: 26
Compression:
Stored size: 1.93 KB
Contents
module Workarea
module Insights
class TrendingSearches < Base
class << self
def dashboards
%w(search)
end
def generate_monthly!
results = generate_results.map do |result|
result.merge(
query_id: result['_id'],
query_string: result['query_string'].presence || result['_id']
)
end
create!(results: results) if results.present?
end
def generate_results
Metrics::SearchByWeek
.collection
.aggregate([filter_date_range, group_by_query, add_improving_weeks, sort, limit])
.to_a
end
def filter_date_range
{
'$match' => {
'reporting_on' => {
'$gte' => beginning_of_last_month.utc,
'$lte' => end_of_last_month.utc
}
}
}
end
def group_by_query
{
'$group' => {
'_id' => '$query_id',
'query_string' => { '$first' => '$query_string' },
'improving_weeks' => { '$sum' => 1 },
'revenue_changes' => { '$push' => '$revenue_change' },
'orders' => { '$sum' => '$orders' }
}
}
end
def add_improving_weeks
{
'$addFields' => {
'improving_weeks' => {
'$size' => {
'$filter' => {
'input' => '$revenue_changes',
'as' => 'revenue_change',
'cond' => { '$gt' => ['$$revenue_change', 0] }
}
}
}
}
}
end
def sort
{ '$sort' => { 'improving_weeks' => -1, 'orders' => -1 } }
end
def limit
{ '$limit' => Workarea.config.insights_searches_list_max_results }
end
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems