DFP Scan

gistfile1.rb

task :scan_all_dfp => :environment do
  dfp_videos = DfpVideo.where(yyyymm: 201408).group(:video_id).select("video_id, SUM(gross_rev) AS total_gross_rev").entries; nil

  CSV.open("scan_all_dfp.csv", 'wb') do |csv|
    csv << [ 'video_id', 'video_revenue.id', 'video_revenue.amount', 'video_revenue.total_earnings', 'video_revenue.gross_partner_sold', 'milton_video.gross_partner_sold_revenue', 'dfp_video.total_gross_rev' ]
    dfp_videos.each_with_index do |dfp_video, i|
      video = Video.find_by(youtube_video_id: dfp_video.video_id)
      video_revenue = video.video_revenues.find_by(year: 2014, month: 8, :dfp_video_id.ne => nil)
      if video_revenue.milton_row_id > 0
        milton_video = Milton::VideoData.find(video_revenue.milton_row_id)
        milton_gpsr  = milton_video.gross_partner_sold_revenue
      else
        milton_gpsr = 0
      end

      video_id                                = dfp_video.video_id
      video_revenue_id                        = video_revenue.id.to_s
      video_revenue_amount                    = video_revenue.amount
      video_revenue_total_earnings            = video_revenue.total_earnings
      video_revenue_gross_partner_sold        = video_revenue.gross_partner_sold
      milton_video_gross_partner_sold_revenue = milton_gpsr
      dfp_video_total_gross_rev               = dfp_video.total_gross_rev

      line = [ video_id, video_revenue_id, video_revenue_amount, video_revenue_total_earnings, video_revenue_gross_partner_sold, milton_video_gross_partner_sold_revenue, dfp_video_total_gross_rev ]
      puts "LINE[#{i}] ======= #{line.join(', ')}"
      csv << line
    end
  end
end