From 8c62b7b8b28ba0350cbbe2f32f977d384368991e Mon Sep 17 00:00:00 2001 From: "sylor_huang@126.com" Date: Fri, 13 Mar 2020 16:58:53 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0watchers=E5=92=8Cpraise=5Ftre?= =?UTF-8?q?nds?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/tasks/sync_user_forge_task.rb | 27 ++++++++++++++++++++++++++- 1 file changed, 26 insertions(+), 1 deletion(-) diff --git a/app/tasks/sync_user_forge_task.rb b/app/tasks/sync_user_forge_task.rb index 371e1e68e..a95b97701 100644 --- a/app/tasks/sync_user_forge_task.rb +++ b/app/tasks/sync_user_forge_task.rb @@ -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 \ No newline at end of file