reports_controller.rb

reports_controller.rb

class ReportsController < ApplicationController
  def index
    #  get all daily feeds
    @feeds = Feed.where(:feed_type => 'daily')
    @late_daily_feeds = []
    @feeds.each do |d|
      daily_state = FeedStatus.where({:feed_id => d.id, :target_date => Date.today.to_s}).exists? ? "green" : "red"
      daily_time = FeedStatus.where({:feed_id => d.id}).order("updated_at").last
      @late_daily_feeds << {:feed_name => d.feed_name, :state => daily_state, :received => daily_time }
    end
    #@feed_statuses = FeedStatus.includes(:feed).where(:feeds => {:feed_type => 'daily'})
    #@live_feeds = AhProfileError.connection.select_all("select *, (UNIX_TIMESTAMP() - tsecs) as 'seconds ago' from error_log where tsecs > unix_timestamp() - (60*120) and subcomponent like '%ah_%'")
    #@live_feeds = AhProfileError.connection.select_all("select (unix_timestamp() - max(updated_timestamp)) / 60 as 'minutes_ago' from ah_lynx_arrivals")
    @live_feeds = Feed.where(:feed_type =>'pull')
    @late_feeds = []
    @live_feeds.each do |l|
      feed_state = AhProfileError.connection.select_all("select (unix_timestamp() - max(updated_timestamp)) / 60 as 'minutes_ago' from #{l.feed_name}")
        if feed_state[0]["minutes_ago"] > 30
          @late_feeds << {:feed_name => l.feed_name, :minutes_ago => feed_state[0]["minutes_ago"]}
        end
      @intraday_feeds = Feed.where(:feed_type => 'intraday')
    end
  end

end