class FeedsController < ApplicationController skip_before_action :verify_authenticity_token def notify_change feed = SiteFeed.where(:feed_uid=>params[:uid]).first feed_annc = SiteFeedAnnc.where(:feed_id=>feed.id).first if feed_annc feeds_model = feed.feeds_model if feeds_model.present? feeds_model = feeds_model.constantize end feed_id = feed.id feeds_uid_field = feed.feeds_uid_field rescue nil feeds_update_callback = feed.feeds_update_callback rescue nil feeds_time_field = feed.feeds_time_field feeds_finish_callback = feed.feeds_finish_callback category_id = feed.merge_with_category can_create_record = feeds_model && feeds_uid_field && feeds_update_callback locales = Site.first.in_use_locales rescue I18n.available_locales locales.map!{|l| l.to_s} site_root_url = Site.first.root_url rescue "" main_directory = File.join("#{Rails.root}","public","site_feeds") feed_directory = File.join(main_directory.to_s, feed.id.to_s) feed_data = JSON.parse(File.read(File.join(feed_directory.to_s, feed.feed_uid + ".json"))) channel_key_pluralize = feed_annc.channel_key.pluralize need_write = true if params[:type] == 'create' trans = {} locales.each do |locale| trans[locale] = {} I18n.with_locale(locale) do trans[locale]['top'] = I18n.t(:top) trans[locale]['hot'] = I18n.t(:hot) trans[locale]['more_plus'] = I18n.t("feed.more") end end params[:data].each do |a| a = JSON.parse(a) a["category_id"] = category_id locales.each do |locale| locale_sym = locale.to_sym time_field_value = Time.parse(a[feeds_time_field]) rescue a[feeds_time_field] if feed_annc[:all_contents_for_feed][locale_sym].index{|aa| aa["id"] == a["id"]} next end insert_idx = 0 if time_field_value insert_idx = feed_annc[:all_contents_for_feed][locale_sym].index{|aa| (aa["org_is_top"] < a["org_is_top"] rescue false) || ((aa["org_is_top"] == a["org_is_top"]) && (aa[feeds_time_field] <= time_field_value))} if insert_idx.nil? insert_idx = ((a["org_is_top"] == 1) ? 0 : -1) end end feed_annc.all_contents_for_feed_will_change! feed_annc[:all_contents_for_feed][locale_sym].insert(insert_idx, feed_annc.process_tmp(a,locale,trans,site_root_url)) feed_data[channel_key_pluralize].insert(insert_idx, a) end if can_create_record record = feeds_model.where(feeds_uid_field=>a["id"], :site_feed_id=>feed_id).first if record.nil? record = feeds_model.new record.instance_variable_set(:@skip_callback, true) record[feeds_uid_field] = a["id"] record[:site_feed_id] = feed_id record.save record.instance_variable_set(:@skip_callback, true) end record.send(feeds_update_callback, a) end end feed_annc.instance_variable_set(:@skip_callback, true) feed_annc.save! elsif params[:type] == 'update' trans = {} locales.each do |locale| trans[locale] = {} I18n.with_locale(locale) do trans[locale]['top'] = I18n.t(:top) trans[locale]['hot'] = I18n.t(:hot) trans[locale]['more_plus'] = I18n.t("feed.more") end end params[:data].each do |a| a = JSON.parse(a) a["category_id"] = category_id locales.each do |locale| locale_sym = locale.to_sym has_create = false feed_annc[:all_contents_for_feed][locale_sym].each_with_index do |aa, i| if aa["id"] == a["id"] feed_annc.all_contents_for_feed_will_change! feed_annc[:all_contents_for_feed][locale_sym][i] = feed_annc.process_tmp(a,locale,trans,site_root_url) feed_data[channel_key_pluralize][i] = a has_create = true break end end unless has_create insert_idx = 0 if time_field_value insert_idx = feed_annc[:all_contents_for_feed][locale_sym].index{|aa| (aa["org_is_top"] < a["org_is_top"] rescue false) || ((aa["org_is_top"] == a["org_is_top"]) && (aa[feeds_time_field] <= time_field_value))} if insert_idx.nil? insert_idx = ((a["org_is_top"] == 1) ? 0 : -1) end end feed_annc.all_contents_for_feed_will_change! feed_annc[:all_contents_for_feed][locale_sym].insert(insert_idx, feed_annc.process_tmp(a,locale,trans,site_root_url)) feed_data[channel_key_pluralize].insert(insert_idx, a) end end if can_create_record record = feeds_model.where(feeds_uid_field=>a["id"], :site_feed_id=>feed_id).first if record.nil? record = feeds_model.new record.instance_variable_set(:@skip_callback, true) record[feeds_uid_field] = a["id"] record[:site_feed_id] = feed_id record.save record.instance_variable_set(:@skip_callback, true) end record.send(feeds_update_callback, a) end end feed_annc.instance_variable_set(:@skip_callback, true) feed_annc.save! elsif params[:type] == 'destroy' locales.each do |locale| locale_sym = locale.to_sym feed_annc.all_contents_for_feed_will_change! feed_annc[:all_contents_for_feed][locale_sym].reject!{|a| params[:data].include?(a["id"]) } feed_data[channel_key_pluralize].reject!{|a| params[:data].include?(a["id"]) } end feed_annc.instance_variable_set(:@skip_callback, true) feed_annc.save! if can_create_record feeds_model.where(feeds_uid_field.to_sym.in =>params[:data].map{|a| a["id"]}, :site_feed_id=>feed_id).destroy end elsif params[:type] == 'update_all' feed_data = params[:data] FileUtils.mkdir_p(feed_directory) if !File.exists?(feed_directory) File.open(File.join(feed_directory.to_s,feed.feed_uid + ".json"),"w") do |file| feed_data.force_encoding("utf-8") file.write(feed_data) end need_write = false feed_annc.all_contents_for_feed_will_change! feed_annc[:all_contents_for_feed] = feed_annc.cache_annc feed_annc.save! if feeds_finish_callback feeds_model.send(feeds_finish_callback, 'update_all', {"data"=>feed.get_annc(false),"feed_id"=>feed.id,"category_id"=>feed.merge_with_category}) end end if need_write feed_data = feed_data.to_json FileUtils.mkdir_p(feed_directory) if !File.exists?(feed_directory) File.open(File.join(feed_directory.to_s,feed.feed_uid + ".json"),"w") do |file| feed_data.force_encoding("utf-8") file.write(feed_data) end if feeds_finish_callback feeds_model.send(feeds_finish_callback, params[:type]) end end end render :json => {success: true} end end