305 lines
10 KiB
Ruby
305 lines
10 KiB
Ruby
class Cache::V2::PlatformStatisticService < ApplicationService
|
|
attr_reader :follow_count, :fork_count, :issue_count, :project_count, :project_language_count_key, :project_language_count, :project_praise_count, :project_watcher_count, :pullrequest_count
|
|
|
|
def initialize(params={})
|
|
@follow_count = params[:follow_count]
|
|
@fork_count = params[:fork_count]
|
|
@issue_count = params[:issue_count]
|
|
@project_count = params[:project_count]
|
|
@project_language_count_key = params[:project_language_count_key]
|
|
@project_language_count = params[:project_language_count]
|
|
@project_praise_count = params[:project_praise_count]
|
|
@project_watcher_count = params[:project_watcher_count]
|
|
@pullrequest_count = params[:pullrequest_count]
|
|
end
|
|
|
|
def read
|
|
platform_statistic
|
|
end
|
|
|
|
def call
|
|
set_platform_statistic
|
|
end
|
|
|
|
def reset
|
|
reset_platform_statistic
|
|
end
|
|
|
|
private
|
|
|
|
def platform_statistic_key
|
|
"v2-platform-statistic"
|
|
end
|
|
|
|
# 平台最高关注数
|
|
def max_watcher_count_key
|
|
"max-watcher-count"
|
|
end
|
|
|
|
# 平台最高点赞数
|
|
def max_praise_count_key
|
|
"max-praise-count"
|
|
end
|
|
|
|
# 平台最高fork数
|
|
def max_fork_count_key
|
|
"max-fork-count"
|
|
end
|
|
|
|
# 平台最高pr数
|
|
def max_pullrequest_count_key
|
|
"max-pullrequest-count"
|
|
end
|
|
|
|
# 平台最高issue数
|
|
def max_issue_count_key
|
|
"max-issue-count"
|
|
end
|
|
|
|
# 平台最高commit数
|
|
def max_commit_count_key
|
|
"max-commit-count"
|
|
end
|
|
|
|
# 平台最高仓库人数
|
|
def max_member_count_key
|
|
"max-member-count"
|
|
end
|
|
|
|
# 平台近一个月新增成员最大值
|
|
def max_recent_one_month_member_count_key
|
|
"max-recent-one-month-member-count"
|
|
end
|
|
|
|
# 平台近一个月合并请求最大值
|
|
def max_recent_one_month_pullrequest_count_key
|
|
"max-recent-one-month-pullrequest-count"
|
|
end
|
|
|
|
# 平台近一个月issue最大值
|
|
def max_recent_one_month_issue_count_key
|
|
"max-recent-one-month-issue-count"
|
|
end
|
|
|
|
# 平台近一个月commit最大值
|
|
def max_recent_one_month_commit_count_key
|
|
"max-recent-one-month-commit-count"
|
|
end
|
|
|
|
def follow_count_key
|
|
"follow-count"
|
|
end
|
|
|
|
def fork_count_key
|
|
"fork-count"
|
|
end
|
|
|
|
def issue_count_key
|
|
"issue-count"
|
|
end
|
|
|
|
def project_count_key
|
|
"project-count"
|
|
end
|
|
|
|
def project_language_key
|
|
"project-language"
|
|
end
|
|
|
|
def project_praise_count_key
|
|
"project-praise-count"
|
|
end
|
|
|
|
def project_watcher_count_key
|
|
"project-watcher-count"
|
|
end
|
|
|
|
def pullrequest_count_key
|
|
"pullrequest-count"
|
|
end
|
|
|
|
def platform_statistic
|
|
result = $redis_cache.hgetall(platform_statistic_key)
|
|
|
|
result.blank? ? reset_platform_statistic : result
|
|
end
|
|
|
|
def set_platform_statistic
|
|
if $redis_cache.hgetall(platform_statistic_key).blank?
|
|
reset_platform_statistic
|
|
return
|
|
end
|
|
if @follow_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, follow_count_key).nil?
|
|
reset_platform_follow_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, follow_count_key, @follow_count)
|
|
end
|
|
end
|
|
if @fork_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, fork_count_key).nil?
|
|
reset_platform_fork_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, fork_count_key, @fork_count)
|
|
end
|
|
end
|
|
if @issue_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, issue_count_key).nil?
|
|
reset_platform_issue_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, issue_count_key, @issue_count)
|
|
end
|
|
end
|
|
if @project_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, project_count_key).nil?
|
|
reset_platform_project_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, project_count_key, @project_count)
|
|
end
|
|
end
|
|
if @project_language_count_key.present? && project_language_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, project_language_key).nil?
|
|
reset_platform_project_language
|
|
else
|
|
result = JSON.parse($redis_cache.hget(platform_statistic_key, project_language_key))
|
|
result[@project_language_count_key] ||= 0
|
|
result[@project_language_count_key] += project_language_count.to_i
|
|
$redis_cache.hset(platform_statistic_key, project_language_key, result.to_json)
|
|
end
|
|
end
|
|
if @project_praise_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, project_praise_count_key).nil?
|
|
reset_platform_project_praise_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, project_praise_count_key, @project_praise_count)
|
|
end
|
|
end
|
|
if @project_watcher_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, project_watcher_count_key).nil?
|
|
reset_platform_project_watcher_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, project_watcher_count_key, @project_watcher_count)
|
|
end
|
|
end
|
|
if @pullrequest_count.present?
|
|
if $redis_cache.hget(platform_statistic_key, pullrequest_count_key).nil?
|
|
reset_platform_pullrequest_count
|
|
else
|
|
$redis_cache.hincrby(platform_statistic_key, pullrequest_count_key, @pullrequest_count)
|
|
end
|
|
end
|
|
$redis_cache.hgetall(platform_statistic_key)
|
|
end
|
|
|
|
def reset_platform_max_watcher_count
|
|
max_watcher = Watcher.where(watchable_type:"Project").group(:watchable_type, :watchable_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_watcher_count_key, max_watcher[1].nil? ? 0 : max_watcher[1])
|
|
end
|
|
|
|
def reset_platform_max_praise_count
|
|
max_praise = PraiseTread.where(praise_tread_object_type: "Project").group(:praise_tread_object_type, :praise_tread_object_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_praise_count_key, max_praise[1].nil? ? 0 : max_praise[1])
|
|
end
|
|
|
|
def reset_platform_max_fork_count
|
|
max_fork = ForkUser.group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_fork_count_key, max_fork[1].nil? ? 0 : max_fork[1])
|
|
end
|
|
|
|
def reset_platform_max_pullrequest_count
|
|
max_pullrequest = PullRequest.group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_pullrequest_count_key, max_pullrequest[1].nil? ? 0 : max_pullrequest[1])
|
|
end
|
|
|
|
def reset_platform_max_issue_count
|
|
max_issue = Issue.where.not(project_id: 0).issue_issue.group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_issue_count_key, max_issue[1].nil? ? 0 : max_issue[1])
|
|
end
|
|
|
|
def reset_platform_max_commit_count
|
|
max_commit = CommitLog.joins(:project).merge(Project.common).group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_commit_count_key, max_commit[1].nil? ? 0 : max_commit[1])
|
|
end
|
|
|
|
def reset_platform_max_member_count
|
|
max_member = Member.where.not(project_id: [0,-1]).group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_member_count_key, max_member[1].nil? ? 0 : max_member[1])
|
|
end
|
|
|
|
def reset_platform_max_recent_one_month_member_count
|
|
max_recent_one_month_member = Member.where("created_on > ?", Time.now - 30.days).group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_recent_one_month_member_count_key, max_recent_one_month_member[1].nil? ? 0 : max_recent_one_month_member[1])
|
|
end
|
|
|
|
def reset_platform_max_recent_one_month_pullrequest_count
|
|
max_recent_one_month_pullrequest = PullRequest.where("created_at > ?", Time.now - 30.days).group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_recent_one_month_pullrequest_count_key, max_recent_one_month_pullrequest[1].nil? ? 0 : max_recent_one_month_pullrequest[1])
|
|
end
|
|
|
|
def reset_platform_max_recent_one_month_issue_count
|
|
max_recent_one_month_issue = Issue.issue_issue.where("created_on > ?", Time.now - 30.days).group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_recent_one_month_issue_count_key, max_recent_one_month_issue[1].nil? ? 0 : max_recent_one_month_issue[1])
|
|
end
|
|
|
|
def reset_platform_max_recent_one_month_commit_count
|
|
max_recent_one_month_commit = CommitLog.joins(:project).merge(Project.common).where("created_at > ?", Time.now - 30.days).group(:project_id).count.sort_by{|i|i[1]}.last || []
|
|
$redis_cache.hset(platform_statistic_key, max_recent_one_month_commit_count_key, max_recent_one_month_commit[1].nil? ? 0 : max_recent_one_month_commit[1])
|
|
end
|
|
|
|
def reset_platform_follow_count
|
|
$redis_cache.hset(platform_statistic_key, follow_count_key, Watcher.where(watchable_type: 'User').count)
|
|
end
|
|
|
|
def reset_platform_fork_count
|
|
$redis_cache.hset(platform_statistic_key, fork_count_key, ForkUser.count)
|
|
end
|
|
|
|
def reset_platform_issue_count
|
|
$redis_cache.hset(platform_statistic_key, issue_count_key, Issue.count)
|
|
end
|
|
|
|
def reset_platform_project_count
|
|
$redis_cache.hset(platform_statistic_key, project_count_key, Project.count)
|
|
end
|
|
|
|
def reset_platform_project_language
|
|
$redis_cache.hset(platform_statistic_key, project_language_key, ProjectLanguage.where.not(projects_count: 0).group("project_languages.name").sum(:projects_count).to_json)
|
|
end
|
|
|
|
def reset_platform_project_praise_count
|
|
$redis_cache.hset(platform_statistic_key, project_praise_count_key, PraiseTread.where(praise_tread_object_type: "Project").count)
|
|
end
|
|
|
|
def reset_platform_project_watcher_count
|
|
$redis_cache.hset(platform_statistic_key, project_watcher_count_key, Watcher.where(watchable_type: 'Project').count)
|
|
end
|
|
|
|
def reset_platform_pullrequest_count
|
|
$redis_cache.hset(platform_statistic_key, pullrequest_count_key, PullRequest.count)
|
|
end
|
|
|
|
def reset_platform_statistic
|
|
$redis_cache.del(platform_statistic_key)
|
|
reset_platform_follow_count
|
|
reset_platform_fork_count
|
|
reset_platform_issue_count
|
|
reset_platform_project_count
|
|
reset_platform_project_language
|
|
reset_platform_project_praise_count
|
|
reset_platform_project_watcher_count
|
|
reset_platform_pullrequest_count
|
|
reset_platform_max_watcher_count
|
|
reset_platform_max_praise_count
|
|
reset_platform_max_fork_count
|
|
reset_platform_max_pullrequest_count
|
|
reset_platform_max_issue_count
|
|
reset_platform_max_commit_count
|
|
reset_platform_max_member_count
|
|
reset_platform_max_recent_one_month_member_count
|
|
reset_platform_max_recent_one_month_pullrequest_count
|
|
reset_platform_max_recent_one_month_issue_count
|
|
reset_platform_max_recent_one_month_commit_count
|
|
|
|
$redis_cache.hgetall(platform_statistic_key)
|
|
end
|
|
end |