Class: Amazon::ExportAmalyticsSnapshot

Inherits:
BaseService show all
Defined in:
app/services/amazon/export_amalytics_snapshot.rb

Overview

Service object: export amalytics snapshot.

Defined Under Namespace

Classes: Result

Constant Summary collapse

COLUMNS =

Column names for the spreadsheet

[
  'Market', 'ASIN', 'Title', 'Desc.', 'Bullet 1', 'Bullet 2', 'Bullet 3',
  'Bullet 4', 'Bullet 5', 'Bullet 6', 'Bullet 7', 'Bullet 8', 'Bullet 9',
  'Generic Keywords', 'SKU', 'Variation ASINs', 'tags', 'imageMain', 'image1', 'image2', 'image3',
  'image4', 'image5', 'image6', 'image7', 'image8', 'image9', 'image10',
  'image11', 'image12', 'image13', 'image14', 'imageSwatch'
].freeze

Instance Attribute Summary

Attributes inherited from BaseService

#options

Instance Method Summary collapse

Methods inherited from BaseService

#initialize, #log_debug, #log_error, #log_info, #log_warning, #logger, #tagged_logger

Constructor Details

This class inherits a constructor from BaseService

Instance Method Details

#append_catalog_item_to_workbook(worksheet, row_index, catalog_item, locale = nil) ⇒ Object 



59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 59

def append_catalog_item_to_workbook(worksheet, row_index, catalog_item, locale = nil)
  # Determine the locale we will use, because amalytics snapshot seems to be single market country we use the first one
  # This method allows to pass in a specific locale, thinking in the future if we need to target canadian french fr-CA
  # specifically
  locale ||= catalog_item.catalog.locales.first
  # Now with mobility we get the right attributes
  Mobility.with_locale(locale) do
    row = catalog_item_to_row_array(catalog_item)
    row.each_with_index do |value, col_index|
      worksheet.add_cell(row_index + 1, col_index, value) # +1 for header offset
    end
  end
  worksheet
end

#append_header_to_worksheet(worksheet) ⇒ Object 



53
54
55
56
57
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 53

def append_header_to_worksheet(worksheet)
  COLUMNS.each_with_index do |header, col_index|
    worksheet.add_cell(0, col_index, header)
  end
end

#catalog_item_to_row_array(catalog_item) ⇒ Object 



74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 74

def catalog_item_to_row_array(catalog_item)
  row = [
    catalog_item.amazon_marketplace.country.iso,
    catalog_item.amazon_asin,
    catalog_item.amazon_title,
    catalog_item.amazon_description,
    catalog_item.amazon_feature_1,
    catalog_item.amazon_feature_2,
    catalog_item.amazon_feature_3,
    catalog_item.amazon_feature_4,
    catalog_item.amazon_feature_5,
    catalog_item.amazon_feature_6,
    catalog_item.amazon_feature_7,
    catalog_item.amazon_feature_8,
    catalog_item.amazon_feature_9,
    catalog_item.amazon_generic_keyword,
    catalog_item.reported_vendor_sku,
    get_variation_asins(catalog_item),
    catalog_item.amalytix_tags.join(',')
  ]
  row += get_images(catalog_item)
  row
end

#get_images(catalog_item) ⇒ Object 



108
109
110
111
112
113
114
115
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 108

def get_images(catalog_item)
  # we add 15 image slots, then the swatch
  images = catalog_item.all_amazon_image_profiles.where.not(image_type: 'AMZ_SWCH').first(15).map(&:image_url)
  images.fill(nil, images.size...15)
  # Add the swatch at the end
  images << catalog_item.all_amazon_image_profiles.find_by(image_type: 'AMZ_SWCH')&.image_url
  images
end

#get_variation_asins(catalog_item) ⇒ Object 



98
99
100
101
102
103
104
105
106
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 98

def get_variation_asins(catalog_item)
  # Per-marketplace Amazon parent for THIS catalog_item's marketplace
  # (catalog_items.variant_group_id -> VariantGroup amazon row), not the
  # legacy marketplace-agnostic item.amazon_variation.
  return if catalog_item.variant_group.blank?

  # Get the variation asins
  catalog_item.variant_group.catalog_items.active.where(catalog_id: catalog_item.catalog_id).joins(:item).distinct.pluck(Item[:amazon_asin]).filter_map(&:presence).sort.join(',')
end

#prepare_catalog_items(catalog_items, limit = nil) ⇒ Object

Adds the necessary performance and joins to process our export, by default
uses the north american seller catlaogs



48
49
50
51
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 48

def prepare_catalog_items(catalog_items, limit = nil)
  catalog_items = catalog_items.limit(limit) if limit.present?
  catalog_items.with_asin.includes(:item, :variant_group, { amazon_marketplace: :country })
end

#process(catalog_items: nil, output_file_path: nil, limit: nil) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'app/services/amazon/export_amalytics_snapshot.rb', line 19

def process(catalog_items: nil, output_file_path: nil, limit: nil)
  require 'rubyXL'
  # Create a new workbook
  workbook = RubyXL::Workbook.new
  worksheet = workbook[0] # Get the first sheet
  # Prepare a temp file if no path is specified
  output_file_path ||= begin
    tempfile = Tempfile.new(["amalytics_snapshot_#{Time.current.to_i}", '.xlsx'])
    tempfile.path
  end
  # Write headers
  append_header_to_worksheet(worksheet)

  # Populate rows with catalog items
  filtered_catalog_items = prepare_catalog_items(catalog_items, limit)
  filtered_catalog_items.each_with_index do |catalog_item, row_index|
    append_catalog_item_to_workbook(worksheet, row_index, catalog_item)
  end
  workbook.write(output_file_path)
  # If we created a tempfile we will flush and fsync it to ensure its written to disk
  if tempfile
    tempfile.flush
    tempfile.fsync
  end
  Result.new(success: true, output_file_path:)
end