提交次数写入动态中

Gemfile

@@ -51,7 +51,7 @@ gem 'elasticsearch-rails'
 
 
 ### profile
-gem 'oneapm_rpm'
+# gem 'oneapm_rpm'
 
 group :development do
   gem 'grape-swagger'

app/models/changeset.rb

@@ -64,14 +64,12 @@ class Changeset < ActiveRecord::Base
     includes(:repository => :project).where(Project.allowed_to_condition(args.shift || User.current, :view_changesets, *args))
   }
 
-  after_create :scan_for_issues,:refresh_changests#:be_user_score # user_score
-  after_update :be_user_score
+  # after_create :scan_for_issues,:refresh_changests#:be_user_score # user_score
+  # after_update :be_user_score
   after_destroy :down_user_score
-  before_create :before_create_cs
-  
-  # fq
-  # after_create :act_as_activity
-  # end
+  # before_create :before_create_cs
+  after_create :act_as_forge_activity
+
   
   def revision=(r)
     write_attribute :revision, (r.nil? ? nil : r.to_s)
@@ -117,6 +115,12 @@ class Changeset < ActiveRecord::Base
     self.user = repository.find_committer_user(self.committer)
   end
 
+  # 项目中提交动态，类型Changeset
+  # type：0 为老版本即Trsutie数据 1为gitlab中获取的动态
+  def act_as_forge_activity
+    self.acts << ForgeActivity.new(:user_id => self.user_id, :project_id => self.project_id, :type => true)
+  end
+
   def scan_for_issues
     scan_comment_for_issue_ids
   end

app/models/forge_activity.rb

@@ -23,46 +23,52 @@ class ForgeActivity < ActiveRecord::Base
   after_create :add_user_activity, :add_org_activity
   before_destroy :destroy_user_activity, :destroy_org_activity
 
-  #在个人动态里面增加当前动态
+  # 在个人动态里面增加当前动态
+  # 版本库提交动态不显示在用户动态中
   def add_user_activity
-    user_activity = UserActivity.where("act_type = '#{self.forge_act_type.to_s}' and act_id = '#{self.forge_act_id}'").first
-    if user_activity
-      user_activity.save
-    else
-      if self.forge_act_type == 'Message' && !self.forge_act.parent_id.nil?
-        user_activity = UserActivity.where("act_type = 'Message' and act_id = #{self.forge_act.parent.id}").first
-        user_activity.created_at = self.created_at
+    if self.forge_act_type != "Changeset"
+      user_activity = UserActivity.where("act_type = '#{self.forge_act_type.to_s}' and act_id = '#{self.forge_act_id}'").first
+      if user_activity
         user_activity.save
       else
-        user_activity = UserActivity.new
-        user_activity.act_id = self.forge_act_id
-        user_activity.act_type = self.forge_act_type
-        user_activity.container_type = "Project"
-        user_activity.container_id = self.project_id
-        user_activity.user_id = self.user_id
-        user_activity.save
+        if self.forge_act_type == 'Message' && !self.forge_act.parent_id.nil?
+          user_activity = UserActivity.where("act_type = 'Message' and act_id = #{self.forge_act.parent.id}").first
+          user_activity.created_at = self.created_at
+          user_activity.save
+        else
+          user_activity = UserActivity.new
+          user_activity.act_id = self.forge_act_id
+          user_activity.act_type = self.forge_act_type
+          user_activity.container_type = "Project"
+          user_activity.container_id = self.project_id
+          user_activity.user_id = self.user_id
+          user_activity.save
+        end
       end
     end
   end
 
+  # 项目提交动态不显示在组织动态中
   def add_org_activity
-    org_activity = OrgActivity.where("org_act_type = '#{self.forge_act_type.to_s}' and org_act_id = #{self.forge_act_id}").first
-    if org_activity
-      org_activity.updated_at = self.updated_at
-      org_activity.save
-    else
-      if self.forge_act_type == 'Message' && !self.forge_act.parent_id.nil?
-        org_activity = OrgActivity.where("org_act_type = 'Message' and org_act_id = #{self.forge_act.parent.id}").first
-        org_activity.created_at = self.created_at
+    if self.forge_act_type != "Changeset"
+      org_activity = OrgActivity.where("org_act_type = '#{self.forge_act_type.to_s}' and org_act_id = #{self.forge_act_id}").first
+      if org_activity
+        org_activity.updated_at = self.updated_at
         org_activity.save
       else
-        OrgActivity.create(:user_id => self.user_id,
-                           :org_act_id => self.forge_act_id,
-                           :org_act_type => self.forge_act_type,
-                           :container_id => self.project_id,
-                           :container_type => 'Project',
-                           :created_at => self.created_at,
-                           :updated_at => self.updated_at)
+        if self.forge_act_type == 'Message' && !self.forge_act.parent_id.nil?
+          org_activity = OrgActivity.where("org_act_type = 'Message' and org_act_id = #{self.forge_act.parent.id}").first
+          org_activity.created_at = self.created_at
+          org_activity.save
+        else
+          OrgActivity.create(:user_id => self.user_id,
+                             :org_act_id => self.forge_act_id,
+                             :org_act_type => self.forge_act_type,
+                             :container_id => self.project_id,
+                             :container_type => 'Project',
+                             :created_at => self.created_at,
+                             :updated_at => self.updated_at)
+        end
       end
     end
   end

db/migrate/20160718064146_add_type_to_changeset.rb

@@ -0,0 +1,6 @@
+class AddTypeToChangeset < ActiveRecord::Migration
+  def change
+    add_column :changesets, :project_id, :integer
+    add_column :changesets, :type, :integer, :default => false
+  end
+end

lib/tasks/gitlab_act_project.rake

@@ -0,0 +1,25 @@
+namespace :gitlab do
+  desc "sync gitlab's commit acts to trustie"
+  task :forge_acts => :environment do
+    begin
+      g = Gitlab.client
+      projects = Project.where("gpid is not null")
+      projects.each do |project|
+        g_project = g.project(project.gpid)
+        # 获取默认分支
+        g_default_branch = g_project.default_branch.nil? ?  "master" : g_project.default_branch
+        # 总的提交次数
+        commit_count = g.user_static(project.gpid, :rev => g_default_branch).count
+        pages = commit_count / 20 + 1
+        pages.each do |page|
+          commits = g.commits(g_project.gpid, :ref_name => g_default_branch, :page => page)
+          commits.each do |commit|
+            Changeset.create(:project_id => project.id, :repository_id => project.gpid, :revision => commit.id, :committer => commit.author_email, :comments => Redmine::CodesetUtil.to_utf8(commit.title, 'UTF-8'), :committed_on => commit.created_at)
+          end
+        end
+      end
+    rescue Exception => e
+      puts e
+    end
+  end
+end