mirror of
https://github.com/discourse/discourse.git
synced 2025-02-25 18:55:32 -06:00
FEATURE: part 2 of dashboard improvements
- moderation tab - sorting/pagination - improved third party reports support - trending charts - better perf - many fixes - refactoring - new reports Co-Authored-By: Simon Cossar <scossar@users.noreply.github.com>
This commit is contained in:
@@ -1,11 +1,12 @@
|
||||
require_dependency 'topic_subtype'
|
||||
|
||||
class Report
|
||||
|
||||
attr_accessor :type, :data, :total, :prev30Days, :start_date,
|
||||
:end_date, :category_id, :group_id, :labels, :async,
|
||||
:prev_period, :facets, :limit, :processing, :average, :percent,
|
||||
:higher_is_better
|
||||
:higher_is_better, :icon, :modes, :category_filtering,
|
||||
:group_filtering, :prev_data, :prev_start_date, :prev_end_date,
|
||||
:dates_filtering, :timeout
|
||||
|
||||
def self.default_days
|
||||
30
|
||||
@@ -15,9 +16,15 @@ class Report
|
||||
@type = type
|
||||
@start_date ||= Report.default_days.days.ago.beginning_of_day
|
||||
@end_date ||= Time.zone.now.end_of_day
|
||||
@prev_end_date = @start_date
|
||||
@average = false
|
||||
@percent = false
|
||||
@higher_is_better = true
|
||||
@category_filtering = false
|
||||
@group_filtering = false
|
||||
@modes = [:table, :chart]
|
||||
@prev_data = nil
|
||||
@dates_filtering = true
|
||||
end
|
||||
|
||||
def self.cache_key(report)
|
||||
@@ -39,6 +46,28 @@ class Report
|
||||
end
|
||||
end
|
||||
|
||||
def self.wrap_slow_query(timeout = 20000)
|
||||
begin
|
||||
ActiveRecord::Base.connection.transaction do
|
||||
# Set a statement timeout so we can't tie up the server
|
||||
DB.exec "SET LOCAL statement_timeout = #{timeout}"
|
||||
yield
|
||||
end
|
||||
rescue ActiveRecord::QueryCanceled
|
||||
return :timeout
|
||||
end
|
||||
|
||||
nil
|
||||
end
|
||||
|
||||
def prev_start_date
|
||||
self.start_date - (self.end_date - self.start_date)
|
||||
end
|
||||
|
||||
def prev_end_date
|
||||
self.start_date
|
||||
end
|
||||
|
||||
def as_json(options = nil)
|
||||
description = I18n.t("reports.#{type}.description", default: "")
|
||||
|
||||
@@ -51,18 +80,29 @@ class Report
|
||||
data: data,
|
||||
start_date: start_date&.iso8601,
|
||||
end_date: end_date&.iso8601,
|
||||
prev_data: self.prev_data,
|
||||
prev_start_date: prev_start_date&.iso8601,
|
||||
prev_end_date: prev_end_date&.iso8601,
|
||||
category_id: category_id,
|
||||
group_id: group_id,
|
||||
prev30Days: self.prev30Days,
|
||||
dates_filtering: self.dates_filtering,
|
||||
report_key: Report.cache_key(self),
|
||||
labels: labels,
|
||||
labels: labels || [
|
||||
{ type: :date, properties: [:x], title: I18n.t("reports.default.labels.day") },
|
||||
{ type: :number, properties: [:y], title: I18n.t("reports.default.labels.count") },
|
||||
],
|
||||
processing: self.processing,
|
||||
average: self.average,
|
||||
percent: self.percent,
|
||||
higher_is_better: self.higher_is_better
|
||||
higher_is_better: self.higher_is_better,
|
||||
category_filtering: self.category_filtering,
|
||||
group_filtering: self.group_filtering,
|
||||
modes: self.modes
|
||||
}.tap do |json|
|
||||
json[:total] = total if total
|
||||
json[:prev_period] = prev_period if prev_period
|
||||
json[:timeout] = self.timeout if self.timeout
|
||||
json[:total] = self.total if self.total
|
||||
json[:prev_period] = self.prev_period if self.prev_period
|
||||
json[:prev30Days] = self.prev30Days if self.prev30Days
|
||||
json[:limit] = self.limit if self.limit
|
||||
|
||||
@@ -105,6 +145,8 @@ class Report
|
||||
end
|
||||
|
||||
def self.find(type, opts = nil)
|
||||
clear_cache
|
||||
|
||||
report = _get(type, opts)
|
||||
report_method = :"report_#{type}"
|
||||
|
||||
@@ -129,6 +171,10 @@ class Report
|
||||
ApplicationRequest.where(req_type: ApplicationRequest.req_types[filter])
|
||||
end
|
||||
|
||||
if filter == :page_view_total
|
||||
report.icon = 'file'
|
||||
end
|
||||
|
||||
report.data = []
|
||||
data.where('date >= ? AND date <= ?', report.start_date, report.end_date)
|
||||
.order(date: :asc)
|
||||
@@ -147,6 +193,9 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_visits(report)
|
||||
report.group_filtering = true
|
||||
report.icon = 'user'
|
||||
|
||||
basic_report_about report, UserVisit, :by_day, report.start_date, report.end_date, report.group_id
|
||||
|
||||
add_counts report, UserVisit, 'visited_at'
|
||||
@@ -159,13 +208,16 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_signups(report)
|
||||
report.group_filtering = true
|
||||
|
||||
if report.group_id
|
||||
basic_report_about report, User.real, :count_by_signup_date, report.start_date, report.end_date, report.group_id
|
||||
add_counts report, User.real, 'users.created_at'
|
||||
else
|
||||
|
||||
report_about report, User.real, :count_by_signup_date
|
||||
end
|
||||
|
||||
add_prev_data report, User.real, :count_by_signup_date, report.prev_start_date, report.prev_end_date
|
||||
end
|
||||
|
||||
def self.report_new_contributors(report)
|
||||
@@ -183,8 +235,9 @@ class Report
|
||||
end
|
||||
|
||||
if report.facets.include?(:prev_period)
|
||||
prev_period_data = User.real.count_by_first_post(report.start_date - (report.end_date - report.start_date), report.start_date)
|
||||
prev_period_data = User.real.count_by_first_post(report.prev_start_date, report.prev_end_date)
|
||||
report.prev_period = prev_period_data.sum { |k, v| v }
|
||||
report.prev_data = prev_period_data.map { |k, v| { x: k, y: v } }
|
||||
end
|
||||
|
||||
data.each do |key, value|
|
||||
@@ -209,7 +262,7 @@ class Report
|
||||
end
|
||||
|
||||
if report.facets.include?(:prev_period)
|
||||
prev_data = UserAction.count_daily_engaged_users(report.start_date - (report.end_date - report.start_date), report.start_date)
|
||||
prev_data = UserAction.count_daily_engaged_users(report.prev_start_date, report.prev_end_date)
|
||||
|
||||
prev = prev_data.sum { |k, v| v }
|
||||
if prev > 0
|
||||
@@ -252,7 +305,7 @@ class Report
|
||||
end
|
||||
|
||||
if report.facets.include?(:prev_period)
|
||||
report.prev_period = dau_avg.call(report.start_date - (report.end_date - report.start_date), report.start_date)
|
||||
report.prev_period = dau_avg.call(report.prev_start_date, report.prev_end_date)
|
||||
end
|
||||
|
||||
if report.facets.include?(:prev30Days)
|
||||
@@ -261,6 +314,7 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_profile_views(report)
|
||||
report.group_filtering = true
|
||||
start_date = report.start_date
|
||||
end_date = report.end_date
|
||||
basic_report_about report, UserProfileView, :profile_views_by_day, start_date, end_date, report.group_id
|
||||
@@ -270,6 +324,7 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_topics(report)
|
||||
report.category_filtering = true
|
||||
basic_report_about report, Topic, :listable_count_per_day, report.start_date, report.end_date, report.category_id
|
||||
countable = Topic.listable_topics
|
||||
countable = countable.where(category_id: report.category_id) if report.category_id
|
||||
@@ -277,6 +332,8 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_posts(report)
|
||||
report.modes = [:table, :chart]
|
||||
report.category_filtering = true
|
||||
basic_report_about report, Post, :public_posts_count_per_day, report.start_date, report.end_date, report.category_id
|
||||
countable = Post.public_posts.where(post_type: Post.types[:regular])
|
||||
countable = countable.joins(:topic).where("topics.category_id = ?", report.category_id) if report.category_id
|
||||
@@ -284,6 +341,8 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_time_to_first_response(report)
|
||||
report.category_filtering = true
|
||||
report.icon = 'reply'
|
||||
report.higher_is_better = false
|
||||
report.data = []
|
||||
Topic.time_to_first_response_per_day(report.start_date, report.end_date, category_id: report.category_id).each do |r|
|
||||
@@ -294,6 +353,7 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_topics_with_no_response(report)
|
||||
report.category_filtering = true
|
||||
report.data = []
|
||||
Topic.with_no_response_per_day(report.start_date, report.end_date, report.category_id).each do |r|
|
||||
report.data << { x: r["date"], y: r["count"].to_i }
|
||||
@@ -319,12 +379,21 @@ class Report
|
||||
end
|
||||
end
|
||||
|
||||
def self.add_prev_data(report, subject_class, report_method, *args)
|
||||
if report.modes.include?(:chart) && report.facets.include?(:prev_period)
|
||||
prev_data = subject_class.send(report_method, *args)
|
||||
report.prev_data = prev_data.map { |k, v| { x: k, y: v } }
|
||||
end
|
||||
end
|
||||
|
||||
def self.add_counts(report, subject_class, query_column = 'created_at')
|
||||
if report.facets.include?(:prev_period)
|
||||
report.prev_period = subject_class
|
||||
prev_data = subject_class
|
||||
.where("#{query_column} >= ? and #{query_column} < ?",
|
||||
(report.start_date - (report.end_date - report.start_date)),
|
||||
report.start_date).count
|
||||
report.prev_start_date,
|
||||
report.prev_end_date)
|
||||
|
||||
report.prev_period = prev_data.count
|
||||
end
|
||||
|
||||
if report.facets.include?(:total)
|
||||
@@ -342,6 +411,15 @@ class Report
|
||||
def self.report_users_by_trust_level(report)
|
||||
report.data = []
|
||||
|
||||
report.modes = [:table]
|
||||
|
||||
report.dates_filtering = false
|
||||
|
||||
report.labels = [
|
||||
{ properties: [:key], title: I18n.t("reports.users_by_trust_level.labels.level") },
|
||||
{ properties: [:y], title: I18n.t("reports.default.labels.count") },
|
||||
]
|
||||
|
||||
User.real.group('trust_level').count.sort.each do |level, count|
|
||||
key = TrustLevel.levels[level.to_i]
|
||||
url = Proc.new { |k| "/admin/users/list/#{k}" }
|
||||
@@ -351,6 +429,8 @@ class Report
|
||||
|
||||
# Post action counts:
|
||||
def self.report_flags(report)
|
||||
report.category_filtering = true
|
||||
report.icon = 'flag'
|
||||
report.higher_is_better = false
|
||||
|
||||
basic_report_about report, PostAction, :flag_count_by_date, report.start_date, report.end_date, report.category_id
|
||||
@@ -360,10 +440,14 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_likes(report)
|
||||
report.category_filtering = true
|
||||
report.icon = 'heart'
|
||||
post_action_report report, PostActionType.types[:like]
|
||||
end
|
||||
|
||||
def self.report_bookmarks(report)
|
||||
report.category_filtering = true
|
||||
report.icon = 'bookmark'
|
||||
post_action_report report, PostActionType.types[:bookmark]
|
||||
end
|
||||
|
||||
@@ -380,47 +464,68 @@ class Report
|
||||
# Private messages counts:
|
||||
|
||||
def self.private_messages_report(report, topic_subtype)
|
||||
report.icon = 'envelope'
|
||||
basic_report_about report, Topic, :private_message_topics_count_per_day, report.start_date, report.end_date, topic_subtype
|
||||
add_counts report, Topic.private_messages.with_subtype(topic_subtype), 'topics.created_at'
|
||||
end
|
||||
|
||||
def self.report_user_to_user_private_messages(report)
|
||||
report.icon = 'envelope'
|
||||
private_messages_report report, TopicSubtype.user_to_user
|
||||
end
|
||||
|
||||
def self.report_user_to_user_private_messages_with_replies(report)
|
||||
report.icon = 'envelope'
|
||||
topic_subtype = TopicSubtype.user_to_user
|
||||
basic_report_about report, Post, :private_messages_count_per_day, report.start_date, report.end_date, topic_subtype
|
||||
add_counts report, Post.private_posts.with_topic_subtype(topic_subtype), 'posts.created_at'
|
||||
end
|
||||
|
||||
def self.report_system_private_messages(report)
|
||||
report.icon = 'envelope'
|
||||
private_messages_report report, TopicSubtype.system_message
|
||||
end
|
||||
|
||||
def self.report_moderator_warning_private_messages(report)
|
||||
report.icon = 'envelope'
|
||||
private_messages_report report, TopicSubtype.moderator_warning
|
||||
end
|
||||
|
||||
def self.report_notify_moderators_private_messages(report)
|
||||
report.icon = 'envelope'
|
||||
private_messages_report report, TopicSubtype.notify_moderators
|
||||
end
|
||||
|
||||
def self.report_notify_user_private_messages(report)
|
||||
report.icon = 'envelope'
|
||||
private_messages_report report, TopicSubtype.notify_user
|
||||
end
|
||||
|
||||
def self.report_web_crawlers(report)
|
||||
report.labels = [
|
||||
{ type: :string, properties: [:user_agent], title: I18n.t("reports.web_crawlers.labels.user_agent") },
|
||||
{ properties: [:count], title: I18n.t("reports.web_crawlers.labels.page_views") }
|
||||
]
|
||||
report.modes = [:table]
|
||||
report.data = WebCrawlerRequest.where('date >= ? and date <= ?', report.start_date, report.end_date)
|
||||
.limit(200)
|
||||
.order('sum_count DESC')
|
||||
.group(:user_agent).sum(:count)
|
||||
.map { |ua, count| { x: ua, y: count } }
|
||||
.map { |ua, count| { user_agent: ua, count: count } }
|
||||
end
|
||||
|
||||
def self.report_users_by_type(report)
|
||||
report.data = []
|
||||
|
||||
report.modes = [:table]
|
||||
|
||||
report.dates_filtering = false
|
||||
|
||||
report.labels = [
|
||||
{ properties: [:x], title: I18n.t("reports.users_by_type.labels.type") },
|
||||
{ properties: [:y], title: I18n.t("reports.default.labels.count") },
|
||||
]
|
||||
|
||||
label = Proc.new { |x| I18n.t("reports.users_by_type.xaxis_labels.#{x}") }
|
||||
url = Proc.new { |key| "/admin/users/list/#{key}" }
|
||||
|
||||
@@ -438,15 +543,49 @@ class Report
|
||||
end
|
||||
|
||||
def self.report_top_referred_topics(report)
|
||||
report.labels = [I18n.t("reports.top_referred_topics.xaxis"),
|
||||
I18n.t("reports.top_referred_topics.num_clicks")]
|
||||
result = IncomingLinksReport.find(:top_referred_topics, start_date: 7.days.ago, limit: report.limit)
|
||||
report.data = result.data
|
||||
report.modes = [:table]
|
||||
|
||||
report.labels = [
|
||||
{ type: :link, properties: [:topic_title, :topic_url], title: I18n.t("reports.top_referred_topics.labels.topic") },
|
||||
{ properties: [:num_clicks], title: I18n.t("reports.top_referred_topics.labels.num_clicks") }
|
||||
]
|
||||
|
||||
options = { end_date: report.end_date, start_date: report.start_date, limit: report.limit || 8 }
|
||||
result = nil
|
||||
report.timeout = wrap_slow_query do
|
||||
result = IncomingLinksReport.find(:top_referred_topics, options)
|
||||
report.data = result.data
|
||||
end
|
||||
end
|
||||
|
||||
def self.report_top_traffic_sources(report)
|
||||
report.modes = [:table]
|
||||
|
||||
report.labels = [
|
||||
{ properties: [:domain], title: I18n.t("reports.top_traffic_sources.labels.domain") },
|
||||
{ properties: [:num_clicks], title: I18n.t("reports.top_traffic_sources.labels.num_clicks") },
|
||||
{ properties: [:num_topics], title: I18n.t("reports.top_traffic_sources.labels.num_topics") }
|
||||
]
|
||||
|
||||
options = { end_date: report.end_date, start_date: report.start_date, limit: report.limit || 8 }
|
||||
result = nil
|
||||
report.timeout = wrap_slow_query do
|
||||
result = IncomingLinksReport.find(:top_traffic_sources, options)
|
||||
report.data = result.data
|
||||
end
|
||||
end
|
||||
|
||||
def self.report_trending_search(report)
|
||||
report.labels = [
|
||||
{ properties: [:term], title: I18n.t("reports.trending_search.labels.term") },
|
||||
{ properties: [:unique_searches], title: I18n.t("reports.trending_search.labels.searches") },
|
||||
{ type: :percent, properties: [:ctr], title: I18n.t("reports.trending_search.labels.click_through") }
|
||||
]
|
||||
|
||||
report.data = []
|
||||
|
||||
report.modes = [:table]
|
||||
|
||||
select_sql = <<~SQL
|
||||
lower(term) term,
|
||||
COUNT(*) AS searches,
|
||||
@@ -463,10 +602,6 @@ class Report
|
||||
.order('unique_searches DESC, click_through ASC, term ASC')
|
||||
.limit(report.limit || 20).to_a
|
||||
|
||||
report.labels = [:term, :searches, :click_through].map { |key|
|
||||
I18n.t("reports.trending_search.labels.#{key}")
|
||||
}
|
||||
|
||||
trends.each do |trend|
|
||||
ctr =
|
||||
if trend.click_through == 0 || trend.searches == 0
|
||||
@@ -478,8 +613,300 @@ class Report
|
||||
report.data << {
|
||||
term: trend.term,
|
||||
unique_searches: trend.unique_searches,
|
||||
ctr: (ctr * 100).ceil(1).to_s + "%"
|
||||
ctr: (ctr * 100).ceil(1)
|
||||
}
|
||||
end
|
||||
end
|
||||
|
||||
def self.report_moderators_activity(report)
|
||||
report.labels = [
|
||||
{ type: :link, properties: [:username, :user_url], title: I18n.t("reports.moderators_activity.labels.moderator") },
|
||||
{ properties: [:flag_count], title: I18n.t("reports.moderators_activity.labels.flag_count") },
|
||||
{ type: :seconds, properties: [:time_read], title: I18n.t("reports.moderators_activity.labels.time_read") },
|
||||
{ properties: [:topic_count], title: I18n.t("reports.moderators_activity.labels.topic_count") },
|
||||
{ properties: [:post_count], title: I18n.t("reports.moderators_activity.labels.post_count") }
|
||||
]
|
||||
|
||||
report.modes = [:table]
|
||||
|
||||
report.data = []
|
||||
mod_data = {}
|
||||
|
||||
User.real.where(moderator: true).find_each do |u|
|
||||
mod_data[u.id] = {
|
||||
user_id: u.id,
|
||||
username: u.username,
|
||||
user_url: "/admin/users/#{u.id}/#{u.username}"
|
||||
}
|
||||
end
|
||||
|
||||
time_read_query = <<~SQL
|
||||
SELECT SUM(uv.time_read) AS time_read,
|
||||
uv.user_id
|
||||
FROM user_visits uv
|
||||
JOIN users u
|
||||
ON u.id = uv.user_id
|
||||
WHERE u.moderator = 'true'
|
||||
AND u.id > 0
|
||||
AND uv.visited_at >= '#{report.start_date}'
|
||||
AND uv.visited_at <= '#{report.end_date}'
|
||||
GROUP BY uv.user_id
|
||||
SQL
|
||||
|
||||
flag_count_query = <<~SQL
|
||||
WITH period_actions AS (
|
||||
SELECT agreed_by_id,
|
||||
disagreed_by_id
|
||||
FROM post_actions
|
||||
WHERE post_action_type_id IN (#{PostActionType.flag_types_without_custom.values.join(',')})
|
||||
AND created_at >= '#{report.start_date}'
|
||||
AND created_at <= '#{report.end_date}'
|
||||
),
|
||||
agreed_flags AS (
|
||||
SELECT pa.agreed_by_id AS user_id,
|
||||
COUNT(*) AS flag_count
|
||||
FROM period_actions pa
|
||||
JOIN users u
|
||||
ON u.id = pa.agreed_by_id
|
||||
WHERE u.moderator = 'true'
|
||||
AND u.id > 0
|
||||
GROUP BY agreed_by_id
|
||||
),
|
||||
disagreed_flags AS (
|
||||
SELECT pa.disagreed_by_id AS user_id,
|
||||
COUNT(*) AS flag_count
|
||||
FROM period_actions pa
|
||||
JOIN users u
|
||||
ON u.id = pa.disagreed_by_id
|
||||
WHERE u.moderator = 'true'
|
||||
AND u.id > 0
|
||||
GROUP BY disagreed_by_id
|
||||
)
|
||||
SELECT
|
||||
COALESCE(af.user_id, df.user_id) AS user_id,
|
||||
COALESCE(af.flag_count, 0) + COALESCE(df.flag_count, 0) AS flag_count
|
||||
FROM agreed_flags af
|
||||
FULL OUTER JOIN disagreed_flags df
|
||||
ON df.user_id = af.user_id
|
||||
SQL
|
||||
|
||||
topic_count_query = <<~SQL
|
||||
SELECT t.user_id,
|
||||
COUNT(*) AS topic_count
|
||||
FROM topics t
|
||||
JOIN users u
|
||||
ON u.id = t.user_id
|
||||
AND u.moderator = 'true'
|
||||
AND u.id > 0
|
||||
AND t.created_at >= '#{report.start_date}'
|
||||
AND t.created_at <= '#{report.end_date}'
|
||||
GROUP BY t.user_id
|
||||
SQL
|
||||
|
||||
post_count_query = <<~SQL
|
||||
SELECT p.user_id,
|
||||
COUNT(*) AS post_count
|
||||
FROM posts p
|
||||
JOIN users u
|
||||
ON u.id = p.user_id
|
||||
WHERE u.moderator = 'true'
|
||||
AND u.id > 0
|
||||
AND p.created_at >= '#{report.start_date}'
|
||||
AND p.created_at <= '#{report.end_date}'
|
||||
GROUP BY user_id
|
||||
SQL
|
||||
|
||||
DB.query(time_read_query).each do |row|
|
||||
mod_data[row.user_id][:time_read] = row.time_read
|
||||
end
|
||||
|
||||
DB.query(flag_count_query).each do |row|
|
||||
mod_data[row.user_id][:flag_count] = row.flag_count
|
||||
end
|
||||
|
||||
DB.query(topic_count_query).each do |row|
|
||||
mod_data[row.user_id][:topic_count] = row.topic_count
|
||||
end
|
||||
|
||||
DB.query(post_count_query).each do |row|
|
||||
mod_data[row.user_id][:post_count] = row.post_count
|
||||
end
|
||||
|
||||
report.data = mod_data.values
|
||||
end
|
||||
|
||||
def self.report_flags_status(report)
|
||||
report.modes = [:table]
|
||||
|
||||
report.labels = [
|
||||
{ properties: [:action_type], title: I18n.t("reports.flags_status.labels.flag") },
|
||||
{ type: :link, properties: [:staff_username, :staff_url], title: I18n.t("reports.flags_status.labels.assigned") },
|
||||
{ type: :link, properties: [:poster_username, :poster_url], title: I18n.t("reports.flags_status.labels.poster") },
|
||||
{ type: :link, properties: [:flagger_username, :flagger_url], title: I18n.t("reports.flags_status.labels.flagger") },
|
||||
{ type: :seconds, properties: [:response_time], title: I18n.t("reports.flags_status.labels.time_to_resolution") }
|
||||
]
|
||||
|
||||
report.data = []
|
||||
|
||||
flag_types = PostActionType.flag_types_without_custom
|
||||
|
||||
sql = <<~SQL
|
||||
WITH period_actions AS (
|
||||
SELECT id,
|
||||
post_action_type_id,
|
||||
created_at,
|
||||
agreed_at,
|
||||
disagreed_at,
|
||||
deferred_at,
|
||||
agreed_by_id,
|
||||
disagreed_by_id,
|
||||
deferred_by_id,
|
||||
post_id,
|
||||
user_id,
|
||||
COALESCE(disagreed_at, agreed_at, deferred_at) AS responded_at
|
||||
FROM post_actions
|
||||
WHERE post_action_type_id IN (#{PostActionType.flag_types_without_custom.values.join(',')})
|
||||
AND created_at >= '#{report.start_date}'
|
||||
AND created_at <= '#{report.end_date}'
|
||||
),
|
||||
poster_data AS (
|
||||
SELECT pa.id,
|
||||
p.user_id AS poster_id,
|
||||
u.username AS poster_username
|
||||
FROM period_actions pa
|
||||
JOIN posts p
|
||||
ON p.id = pa.post_id
|
||||
JOIN users u
|
||||
ON u.id = p.user_id
|
||||
),
|
||||
flagger_data AS (
|
||||
SELECT pa.id,
|
||||
u.id AS flagger_id,
|
||||
u.username AS flagger_username
|
||||
FROM period_actions pa
|
||||
JOIN users u
|
||||
ON u.id = pa.user_id
|
||||
),
|
||||
staff_data AS (
|
||||
SELECT pa.id,
|
||||
u.id AS staff_id,
|
||||
u.username AS staff_username
|
||||
FROM period_actions pa
|
||||
JOIN users u
|
||||
ON u.id = COALESCE(pa.agreed_by_id, pa.disagreed_by_id, pa.deferred_by_id)
|
||||
)
|
||||
SELECT
|
||||
sd.staff_username,
|
||||
sd.staff_id,
|
||||
pd.poster_username,
|
||||
pd.poster_id,
|
||||
fd.flagger_username,
|
||||
fd.flagger_id,
|
||||
pa.post_action_type_id,
|
||||
pa.created_at,
|
||||
pa.agreed_at,
|
||||
pa.disagreed_at,
|
||||
pa.deferred_at,
|
||||
pa.agreed_by_id,
|
||||
pa.disagreed_by_id,
|
||||
pa.deferred_by_id,
|
||||
COALESCE(pa.disagreed_at, pa.agreed_at, pa.deferred_at) AS responded_at
|
||||
FROM period_actions pa
|
||||
FULL OUTER JOIN staff_data sd
|
||||
ON sd.id = pa.id
|
||||
FULL OUTER JOIN flagger_data fd
|
||||
ON fd.id = pa.id
|
||||
FULL OUTER JOIN poster_data pd
|
||||
ON pd.id = pa.id
|
||||
SQL
|
||||
|
||||
DB.query(sql).each do |row|
|
||||
data = {}
|
||||
data[:action_type] = flag_types.key(row.post_action_type_id).to_s
|
||||
data[:staff_username] = row.staff_username
|
||||
data[:staff_id] = row.staff_id
|
||||
if row.staff_username && row.staff_id
|
||||
data[:staff_url] = "/admin/users/#{row.staff_id}/#{row.staff_username}"
|
||||
end
|
||||
data[:poster_username] = row.poster_username
|
||||
data[:poster_id] = row.poster_id
|
||||
data[:poster_url] = "/admin/users/#{row.poster_id}/#{row.poster_username}"
|
||||
data[:flagger_id] = row.flagger_id
|
||||
data[:flagger_username] = row.flagger_username
|
||||
data[:flagger_url] = "/admin/users/#{row.flagger_id}/#{row.flagger_username}"
|
||||
if row.agreed_by_id
|
||||
data[:resolution] = I18n.t("reports.flags_status.values.agreed")
|
||||
elsif row.disagreed_by_id
|
||||
data[:resolution] = I18n.t("reports.flags_status.values.disagreed")
|
||||
elsif row.deferred_by_id
|
||||
data[:resolution] = I18n.t("reports.flags_status.values.deferred")
|
||||
else
|
||||
data[:resolution] = I18n.t("reports.flags_status.values.no_action")
|
||||
end
|
||||
data[:response_time] = row.responded_at ? row.responded_at - row.created_at : nil
|
||||
report.data << data
|
||||
end
|
||||
end
|
||||
|
||||
def self.report_post_edits(report)
|
||||
report.modes = [:table]
|
||||
|
||||
report.labels = [
|
||||
{ type: :link, properties: [:post_id, :post_url], title: I18n.t("reports.post_edits.labels.post") },
|
||||
{ type: :link, properties: [:editor_username, :editor_url], title: I18n.t("reports.post_edits.labels.editor") },
|
||||
{ type: :link, properties: [:author_username, :author_url], title: I18n.t("reports.post_edits.labels.author") },
|
||||
{ type: :text, properties: [:edit_reason], title: I18n.t("reports.post_edits.labels.edit_reason") }
|
||||
]
|
||||
|
||||
report.data = []
|
||||
|
||||
sql = <<~SQL
|
||||
WITH period_revisions AS (
|
||||
SELECT pr.user_id AS editor_id,
|
||||
pr.number AS revision_version,
|
||||
pr.created_at,
|
||||
pr.post_id,
|
||||
u.username AS editor_username
|
||||
FROM post_revisions pr
|
||||
JOIN users u
|
||||
ON u.id = pr.user_id
|
||||
WHERE pr.created_at >= '#{report.start_date}'
|
||||
AND pr.created_at <= '#{report.end_date}'
|
||||
ORDER BY pr.created_at DESC
|
||||
LIMIT 20
|
||||
)
|
||||
SELECT pr.editor_id,
|
||||
pr.editor_username,
|
||||
p.user_id AS author_id,
|
||||
u.username AS author_username,
|
||||
pr.revision_version,
|
||||
p.version AS post_version,
|
||||
pr.post_id,
|
||||
p.topic_id,
|
||||
p.post_number,
|
||||
p.edit_reason,
|
||||
pr.created_at
|
||||
FROM period_revisions pr
|
||||
JOIN posts p
|
||||
ON p.id = pr.post_id
|
||||
JOIN users u
|
||||
ON u.id = p.user_id
|
||||
SQL
|
||||
|
||||
DB.query(sql).each do |r|
|
||||
revision = {}
|
||||
revision[:editor_id] = r.editor_id
|
||||
revision[:editor_username] = r.editor_username
|
||||
revision[:editor_url] = "/admin/users/#{r.editor_id}/#{r.editor_username}"
|
||||
revision[:author_id] = r.author_id
|
||||
revision[:author_username] = r.author_username
|
||||
revision[:author_url] = "/admin/users/#{r.author_id}/#{r.author_username}"
|
||||
revision[:edit_reason] = r.revision_version == r.post_version ? r.edit_reason : nil
|
||||
revision[:created_at] = r.created_at
|
||||
revision[:post_id] = r.post_id
|
||||
revision[:post_url] = "/t/-/#{r.topic_id}/#{r.post_number}"
|
||||
|
||||
report.data << revision
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
Reference in New Issue
Block a user