wahyd4/Libr

class DoubanBooksWorker

  include Sidekiq::Worker

  def perform(user_id, name)
    user = User.find_by_id user_id
    count = 40
    total = 0
    start = 0
    while (start == 0) || (total-start > count)
      url = "http://api.douban.com/v2/book/user/#{name}/collections?start=#{start}&count=#{count}"
      logger.info "url============#{url}"
      result = RestClient.get url
      json = JSON.parse(result)
      storeBooks(json, user)
      total = json['total']
      start += count
    end
  end


  def storeBooks(json, user)
    collections = json['collections']
    collections.each { |collection, index|
      book = collection['book']
      if book['isbn13'] != nil
        Book.create_book_by_isbn book unless Book.find_by_isbn book['isbn13']
        user.create_book_instance book['isbn13']
      end
    }

  end

end