|
|
|
@ -28,6 +28,8 @@ class SyncUserForgeTask
|
|
|
|
|
project_score_params = get_scores(p)
|
|
|
|
|
commit_params = get_commits(p)
|
|
|
|
|
pull_request_params = get_prs(p)
|
|
|
|
|
watchers_params = get_watchers(p.watchers)
|
|
|
|
|
praise_trends_params = get_praises(p.id)
|
|
|
|
|
|
|
|
|
|
repo_params = get_repository(p) #repository的内容
|
|
|
|
|
|
|
|
|
@ -39,7 +41,9 @@ class SyncUserForgeTask
|
|
|
|
|
project_score_params: project_score_params,
|
|
|
|
|
pull_request_params: pull_request_params,
|
|
|
|
|
repo_params: repo_params,
|
|
|
|
|
commit_params: commit_params
|
|
|
|
|
commit_params: commit_params,
|
|
|
|
|
watchers_params: watchers_params,
|
|
|
|
|
praise_trends_params: praise_trends_params
|
|
|
|
|
}
|
|
|
|
|
target_params.push(relate_project_params)
|
|
|
|
|
end
|
|
|
|
@ -164,4 +168,25 @@ class SyncUserForgeTask
|
|
|
|
|
end
|
|
|
|
|
member_params
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def get_watchers(watchers)
|
|
|
|
|
watcher_params = []
|
|
|
|
|
if watchers.present?
|
|
|
|
|
watchers.find_each do |m|
|
|
|
|
|
watcher_params.push(m.as_json)
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
watcher_params
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def get_praises(project_id)
|
|
|
|
|
prasie_params = []
|
|
|
|
|
praise_trends = PraiseTread.where(praise_tread_object_id: project_id, praise_tread_object_type: "Project")
|
|
|
|
|
if praise_trends.present?
|
|
|
|
|
praise_trends.find_each do |m|
|
|
|
|
|
prasie_params.push(m.as_json)
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
prasie_params
|
|
|
|
|
end
|
|
|
|
|
end
|