require 'csv' class BikeCsvImporter include BikeCsvImporter::Cache include BikeCsvImporter::Cleaner include BikeCsvImporter::BikeAttrs attr_reader :file, :dry_run def initialize(file, dry_run) @file = file @dry_run = !!dry_run end def run result = {imported: {}, skipped: {}} fetch do |bike_hash| bike = import_bike bike_hash check_method = dry_run ? :valid? : :persisted? if bike.try check_method result[:imported][bike.shop_id] = bike.inspect else result[:skipped][bike.try(:shop_id) || bike_hash.values.first] = bike.try(:errors).try(:messages) end end result end def analyze(fields = []) fields = fields.map &:downcase grouped = {} fetch do |bike_hash| bike_hash.each do |key, value| next if fields.any? && !fields.include?(key) grouped[key] ||= {} grouped[key][value] ||= 0 grouped[key][value] += 1 end end grouped end private def fetch CSV.foreach(file).each_with_index do |row, i| if i.zero? parse_header row else yield parse_bike(row) end end end def parse_header(row) @header = row.map(&:downcase) end def parse_bike(row) @header.zip(row).to_h end # Gone -> If "Yes", set 'gone' to true, then create a Log entry like the following: # id | loggable_id | loggable_type | logger_id | logger_type | context | start_date | end_date | description | log_action_id | log_action_type | created_at | updated_at # 18 | 1 | Bike | 4 | User | | 2017-02-03 23:27:00 | 2017-02-03 23:27:00 | Gone | 5 | ActsAsLoggable::BikeAction | 2017-02-03 23:27:36.8387 | 2017-02-03 23:27:36.8387 # See https://github.com/spacemunkay/BikeShed/blob/master/app/components/bike_logs.rb#L12-L18 for example. Use user_id 1 for current_user_id (1 should be the admin ID I think). Use "Date Out" column for start_date & end_date. Set action_id to "COMPLETED". # # Date In -> Create a bike log entry with start_date & end_date with same value as "Date In". Set action_id to "AQUIRED" # Date Out -> Should be the start_date & end_date value for "Gone" column mentioned above. # Comment -> Create a bike log entry with action_id "NOTE". The log 'description' should be the value of 'Comment'. def import_bike(bike_hash) bike = Bike.new bike_attrs(bike_hash) #bike.save unless dry_run raise 'TODO save' unless dry_run bike end end