class Admin::FeedsController < OrbitAdminController layout :compute_layout helper_method :search_all_words def compute_layout if action_name== 'annc_content' false else 'back_end' end end def index @site_feeds = SiteFeed.all.group_by(&:remote_site_url) @school_urls = @site_feeds.keys redirect_to new_admin_feed_path and return if @site_feeds.count == 0 end def settings @setting = SiteFeedSetting.first end def update_settings @setting = SiteFeedSetting.first p = params.require(:site_feed_setting).permit! @setting.update_attributes(p) Thread.new do sleep 3 content = "UNICORN_PID=\"`fuser tmp/pids/unicorn.sock tmp/sockets/unicorn.sock tmp/unicorn.sock` `cat tmp/pids/unicorn.pid `\" && kill -s USR2 $UNICORN_PID ; n=20; while (kill -0 $UNICORN_PID > /dev/null 2>&1) && test $n -ge 0; do printf '.' && sleep 1 && n=$(( $n - 1 )); done ; if test $n -lt 0; then kill -s TERM $UNICORN_PID; sleep 3; bundle exec unicorn_rails -c config/unicorn.rb -D -E #{Rails.env}; else kill -s QUIT $UNICORN_PID; fi" system(content) end redirect_to admin_feeds_settings_path end def new end def annc_content site_feed_annc = SiteFeedAnnc.where(id: params['feed_annc_id']).first @annc = site_feed_annc.get_annc(params['annc_uid'].to_s) rescue {} end def process_annc now_process = params['process'] annc_uid = params['annc_uid'].to_s site_feed_annc = SiteFeedAnnc.where(id: params['feed_annc_id']).first if !site_feed_annc.nil? case now_process when /is_top|is_hot/ cmd = now_process.split(':') f = cmd[0]=='is_top' ? 'top_list' : 'hot_list' if cmd[1] == 'enable' if site_feed_annc[f].exclude?(annc_uid) tmp = site_feed_annc.send(f) tmp << annc_uid site_feed_annc.update_attributes(f.to_sym => tmp) end else if site_feed_annc[f].include?(annc_uid) tmp = site_feed_annc.send(f) tmp -= [annc_uid] site_feed_annc.update_attributes(f.to_sym => tmp) end end when /hidden|display/ if now_process == 'hidden' if site_feed_annc[:hidden_annc].exclude?(annc_uid) tmp = site_feed_annc.hidden_annc tmp << annc_uid site_feed_annc.update_attributes(:hidden_annc =>tmp) end else if site_feed_annc[:hidden_annc].include?(annc_uid) tmp = site_feed_annc.hidden_annc tmp -= [annc_uid] site_feed_annc.update_attributes(:hidden_annc =>tmp) end end end end render :text => 'success' end def announcements @filter_fields = {} @filter_fields['feed.source'] = SiteFeed.all.pluck(:channel_title,:remote_site_url).collect do |a,b| tp = (a.blank? || a[I18n.locale].blank?) ? b.gsub(/http:\/\/|https:\/\//,'').gsub(/\./,'-') : a[I18n.locale] {:title => tp,:id => tp} end @filter_fields['feed.module_name'] = SiteFeed.all.map{|s| s.channel_key}.uniq.map do |key| {:title => I18n.t("module_name.#{key}"),:id => key} end @module_name = params[:filters][:module_name].to_a rescue [] @module_name = SiteFeed.all.map{|s| s.channel_key}.uniq if @module_name == [] @all_feed_annc = SiteFeedAnnc.where(:channel_key.in => @module_name).order(created_at: 1).to_a rescue [] @source = params[:filters][:source] rescue [] @keywords = params[:keywords] rescue nil if request.xhr? render :partial => "announcements" end end def get_category_list app_key = params[:channel] ma = ModuleApp.find_by_key(app_key) rescue nil categories = [] if !ma.nil? ma.categories.each do |category| cat = {} cat["title"] = category.title cat["id"] = category.id.to_s categories << cat end end render :json => {"categories" => categories}.to_json end def get_channel_list puts params['url'] url = URI.decode(params['url']).chomp("/") + "/feeds/channel_lists" puts url uri = URI.parse(URI.decode(url).encode) begin res = Timeout.timeout(10){Net::HTTP.get_response(uri).body} rescue http = Net::HTTP.new(uri.host, uri.port) http.use_ssl = true if (uri.scheme == "https") http.verify_mode = OpenSSL::SSL::VERIFY_NONE res = http.get(uri.request_uri).body rescue nil puts uri.to_s puts uri.hostname end data = JSON.parse(res) rescue {} print data render :json => data.to_json end def get_feed_list url = params['url'].chomp("/") + params[:feed_list_url] uri = URI.parse(url) begin res = Net::HTTP.start(uri.host, uri.port,:use_ssl => uri.scheme == 'https', open_timeout: 10,read_timeout: 10, verify_mode: OpenSSL::SSL::VERIFY_NONE) do |http| req = Net::HTTP::Get.new(uri) http.request(req) end res = res.code=='200' ? res.body : nil rescue res = nil puts uri.to_s puts uri.hostname end data = JSON.parse(res) rescue {} data_to_send = {} data_to_send["feeds"] = [] Array(data["feeds"]).each do |feed| sf = SiteFeed.find_by(:feed_uid => feed["uid"]) rescue nil if !sf.nil? feed["subscribed"] = true else feed["subscribed"] = false end data_to_send["feeds"] << feed end render :json => data_to_send.to_json end def channel_title site_feeds = SiteFeed.where(:remote_site_url => params["url"]) site_feeds.each do |sf| sf.channel_title_translations = params["channel_title_translations"] sf.save end render :json => {"success" => true, "title" => params["channel_title_translations"][I18n.locale.to_s]}.to_json end def subscribe site_feed = SiteFeed.new site_feed.remote_site_url = params[:url].chomp("/") site_feed.merge_with_category = params[:category] site_feed.channel_name = params[:channel] site_feed.channel_key = params[:channel_key] site_feed.feed_uid = params[:feed][:uid] site_feed.feed_name_translations = params[:feed][:title_translations] site_feed.disabled = false site_feed.feed_url = params[:feed][:url] site_feed.save render :json => {"success" => true}.to_json end def disable feed = SiteFeed.find(params[:feed_id]) rescue nil if !feed.nil? feed.disabled = params[:disable] feed.save end render :json => {"success" => true}.to_json end def unsubscribe sf = SiteFeed.find_by(:feed_uid => params[:feed_uid]) rescue nil if !sf.nil? sf.destroy end render :json => {"success" => true}.to_json end def force_refresh sf = SiteFeed.find_by(:feed_uid => params[:feed_uid]) rescue nil if !sf.nil? FeedModel::Cache.recreate_annc_cache(sf) end render :json => {"success" => true}.to_json end def search_all_words(target, word) target = target.upcase words = word.upcase.split(' ') words.select { |value| target.include? value } == words end end