Class: CrossRef

Inherits:
Object
  • Object
show all
Includes:
CSVHandlers, SecureRandom
Defined in:
lib/linsc/cross_ref.rb

Instance Method Summary collapse

Methods included from CSVHandlers

#append_to_csv, #create_file, #create_file_with_headers, #create_row, #get_headers

Constructor Details

#initialize(input_dir:, child_path:, master_path:, output_path:, master_lookup_field: 'Email', child_lookup_field: 'Email', master_secondary_lookups: ['Email 2', 'Email 3'], static_values: {'Account Name' => 'Candidates', 'Account ID' => '00120000019Covx'}, options:) ⇒ CrossRef

Returns a new instance of CrossRef.



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/linsc/cross_ref.rb', line 8

def initialize(input_dir:, child_path:, master_path:, output_path:,
               master_lookup_field: 'Email', child_lookup_field: 'Email',
               master_secondary_lookups: ['Email 2', 'Email 3'],
               static_values: {'Account Name' => 'Candidates', 'Account ID' => '00120000019Covx'}, options:)
  @input_dir, @child_path, @master_path, @output_path, @options =
    input_dir, child_path, master_path, output_path, options
  @master_lookup_field, @child_lookup_field, @master_secondary_lookups, @static_values =
    master_lookup_field, child_lookup_field, master_secondary_lookups, static_values
  @headers = get_headers(@master_path)
  child_lookup_field == 'Email' ? @email_key = true : @email_key = false
  @child_headers = get_headers(@child_path)
  @child_headers.each do |child_header|
    unless @headers.include?(child_header)
      @headers << child_header
    end
  end
  @static_values.each do |static_key, static_value|
    unless @headers.include?(static_key)
      @headers << static_key
    end
  end if @static_values
  @child_length = CSV.read(@child_path).length - 1
  if File.exist?(@output_path)
    File.delete(@output_path)
  end
  create_file(@output_path)
  cross_ref
end

Instance Method Details

#convert_row(child_row) ⇒ Object 



102
103
104
105
106
107
108
109
110
111
112
113
114
 
# File 'lib/linsc/cross_ref.rb', line 102

def convert_row(child_row)
  master_row = CSV::Row.new(@headers, [])
  master_row['LIN ID'] = SecureRandom.hex(16)
  child_row.each do |child_key, child_value|
    master_row[child_key] = child_value if master_row.has_key?(child_key)
  end
  if @static_values
    @static_values.each do |static_key, static_value|
      master_row[static_key] = static_value if master_row.has_key?(static_key)
    end
  end
  master_row
end

#cross_ref ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/linsc/cross_ref.rb', line 37

def cross_ref
  master_data = CSV.read(@master_path, headers: true)
  puts "sorting lookup values"
  master_data = master_data.sort do |x, y|
    a = x[@master_lookup_field]
    b = y[@master_lookup_field]
    a && b ? a <=> b : a ? -1 : 1
  end
  i = 0
  CSV.foreach(@child_path, headers: true, encoding: 'utf-8') do |child_row|
    i += 1
    puts "email lookup - row: #{i}/#{@child_length}"
    child_lookup_value = child_row[@child_lookup_field].downcase if child_row[@child_lookup_field]
    if (child_lookup_value && child_lookup_value.include?('@')) || !@email_key ## generalize this
      matching_row = master_data.bsearch do |master_lookup_row|
        master_lookup_value = master_lookup_row[@master_lookup_field]
         child_lookup_value && master_lookup_value ?
              child_lookup_value <=> master_lookup_value : child_lookup_value ? -1 : 1
      end
      if @master_secondary_lookups && !matching_row
        matching_row = master_data.find do |master_row|
          master_secondary_lookups = @master_secondary_lookups.collect{|x| master_row[x]&.downcase}
          master_secondary_lookups.include?(child_lookup_value)
        end
      end
      if matching_row
        if @options[:update]
          append_to_csv(@output_path, splice_rows(matching_row, child_row))
        end
      else
        if @options[:insert]
          append_to_csv(@output_path, convert_row(child_row))
        end
      end
    else
      puts "missing lookup value"
    end
  end
end

#splice_rows(master_row, child_row) ⇒ Object 



77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/linsc/cross_ref.rb', line 77

def splice_rows(master_row, child_row)
  unless master_row['LIN ID'] && master_row['LIN ID'].strip.length > 20
    master_row['LIN ID'] = SecureRandom.hex(16)
  end

  child_row.each do |child_key, child_value|
    if child_value && child_value.strip.length > 0
      if master_row.has_key?(child_key)
        master_row[child_key] = child_value
      else
        master_row << [child_key, child_value]
      end
    else
      unless master_row.has_key?(child_key)
        master_row << [child_key, child_value]
      end
    end
  end
  master_row_new = CSV::Row.new(@headers, [])
  master_row.each do |key, value|
    master_row_new[key] = value.encode('utf-8', invalid: :replace, undef: :replace, replace: '#') if value
  end
  master_row_new
end