Rake任务以数据库更新特定产品

Question

嗨，我有一个充满产品的数据库，我需要安排一个rake任务运行每周。我不太确定如何编写rake任务。例如，我有一个id=1name=“testname”description=“description”sku=“198”price=12.99的产品，我需要上传一个带有name=“testname”的csv，并将价格更新为13.99，同时保持id不变。这是我尝试到目前为止，但它不是完整的，如果有人能帮助，这将是伟大的。

require 'csv'
desc "Updates Products inside an ActiveRecord table"
task :update_prods, [:filename] => :environment do
    products = Spree::Product.all
    CSV.foreach('update_prods.csv', :headers => true) do |row|
    Spree::Product.update!(row.to_hash)
end
end

Answer 1

下面是我们如何将产品从Shopify导入Spree的一个要点，它可以给你一些关于如何进行https://gist.github.com/dgross881/b4f1ac96bafa2e29be7f的想法。

def update_products

  puts 'Updating Products...'
  require 'csv'
  products_csv = File.read(Rails.root.join('lib/assets/products_list.csv'))
  products = CSV.parse(products_csv, headers: true)

  products.each_with_index do |row, index|
    Rails.logger.info { [#{index + 1}..#{products.length}] Updating product: #{row['title']} }
    product = Spree::Product.find!(row['id'])
    update_product = product.update_attributes(name: row['title'], description:row['description'],
    meta_title: row['seo_title'], meta_description: row['seo_description'],
    meta_keywords: "#{row['handle']}, #{row['title']}, the Squirrelz",
    available_on: Time.zone.now, price: row['price'],
    shipping_category: Spree::ShippingCategory.find_by!(name: 'Shipping'))

    update_product.tag_list = row['tags']
    update_product.slug = row['handle']
    update_product.save!
  end
  Rails.logger.info { "Finished Updating Products" }
end

def update_variants
  puts 'updating Variants...'
  require 'csv'
  products_variants_csv =File.read(Rails.root.join('lib/assets/variants_list.csv'))

  products_variants = CSV.parse(products_variants_csv, headers: true)

  products_variants.each_with_index do |row, index|
    puts "[#{index + 1}..#{products_variants.length}] Adding Variant (#{row['sku']} to Product: #{Spree::Product.find_by!(slug: row['handle']).name})"
    variant = Spree::Variant.find_by!(sku: row['sku']
    update_variant = variant.update_attributes!(sku: row['sku'], stock_items_count: row['qty'], cost_price: row['price'], weight: row['weight']

    unless row['option1'].blank?
      variant.option_values << Spree::OptionValue.find_by!(name: row['option1'])
    end
    unless row['option2'].blank?
      variant.option_values << Spree::OptionValue.find_by!(name: row['option2'])
    end
    variant.save!
  end
  puts 'Updated Variants'
end