Add log for comment count sync

Author: edokeh

app/controllers/admin/dashboard_controller.rb

@@ -4,17 +4,12 @@ def show
     @blog_publish_count = Blog.with_status(:publish).count
     @blog_draft_count = Blog.with_status(:draft).count
     @comment_count = Blog.sum(:comment_count)
-    @category_count = Category.count
-    @attach_count = Attach.count
-    @attach_size = Attach.sum('file_size')
-
     @total_visits = GaClient.get_total_visits if Setting.ga.chart_enable
 
     render :json => {
         :blog => {:publish => @blog_publish_count, :draft => @blog_draft_count},
         :comment => @comment_count,
-        :category => @category_count,
-        :attach => {:count => @attach_count, :size => view_context.number_to_human_size(@attach_size)},
+        :disqus_enable => Setting.disqus.enable,
         :total_visits => @total_visits
     }
   end
@@ -46,4 +41,31 @@ def hot_blogs
 
     render :json => @hot_blogs
   end
+
+  # 附件统计
+  def attach
+    @attach_count = Attach.count
+    @attach_size = Attach.sum('file_size')
+
+    render :json => {
+        :count => @attach_count,
+        :size => view_context.number_to_human_size(@attach_size),
+    }
+  end
+
+  # 评论数同步日志
+  def sync_comment_logs
+    @logs = Setting.sync_comment_logs || []
+    @logs.map!(&:marshal_dump)
+
+    render :json => @logs
+  end
+
+  # 同步评论数
+  def sync_comment
+    # 防御 get
+    render :text => '', :status => 404 and return if request.get?
+    Comment.sync_count
+    head :no_content
+  end
 end

app/controllers/feed_controller.rb

@@ -3,10 +3,7 @@ class FeedController < ApplicationController
   def show
     expires_in 1.hours, :public=>true
     @blogs = Blog.with_status(:publish).order('created_at DESC')
-    
-    respond_to do |format|
-      format.rss { render :layout => false }
-    end
+    render :layout => false
   end
 
 end

app/models/comment.rb

@@ -24,9 +24,22 @@ def self.remove(id)
 
   # 从 disqus api 同步 BLOG 评论数
   def self.sync_count
-    DisqusClient.all_thread.each do |th|
-      blog = Blog.where(:id => th["identifiers"][0]).first
-      blog.update_columns(:comment_count => th["posts"]) if blog
+    return unless Disqus.find.enable?
+    latest_log = {:at => Time.now}
+
+    begin
+      DisqusClient.all_thread.each do |th|
+        blog = Blog.where(:id => th["identifiers"][0]).first
+        blog.update_columns(:comment_count => th["posts"]) if blog
+      end
+      latest_log[:status] = "success"
+    rescue Exception => e
+      latest_log[:error] = e.message
+      latest_log[:status] = "failed"
+    ensure
+      sync_logs = Setting.sync_comment_logs || []
+      sync_logs = sync_logs.push(latest_log).slice(-5..-1)
+      Setting.sync_comment_logs = sync_logs
     end
   end
 

app/models/setting.rb

@@ -69,6 +69,7 @@ def value
   # 使用 JSON 保存值
   def value=(new_value)
     new_value = new_value.marshal_dump if new_value.is_a? OpenStruct
+    new_value.map! { |o| (o.is_a? OpenStruct) ? o.marshal_dump : o } if new_value.is_a? Array
     self[:value] = new_value.to_json
   end
 end

config/routes.rb

@@ -16,13 +16,14 @@
   get 'categories/:id/page/:page' => 'categories#show'
   get 'tags/:id/page/:page' => 'tags#show'
 
-  get '/feed' => 'feed#show', :format => :rss, :as => :feed
+  get '/feed' => 'feed#show', :as => :feed, :defaults => {:format => 'rss'}
   get '/archive.html' => 'archive#show', :as => :archive
   get '/page/:id.html' => 'pages#show', :as => :page
 
   namespace :admin do
     get '/' => 'home#show'
     get '/dashboard' => 'dashboard#show'
+    post '/dashboard/sync_comment' => 'dashboard#sync_comment'
     get '/dashboard/:action' => 'dashboard'
 
     resource :session