1
0
mirror of https://github.com/LaCasemate/fab-manager.git synced 2024-12-05 16:24:21 +01:00
fab-manager/app/services/members/import_service.rb
2020-05-19 11:45:51 +02:00

190 lines
5.7 KiB
Ruby

# frozen_string_literal: true
# Provides helper methods to bulk-import some users from a CSV file
class Members::ImportService
class << self
def import(import)
require 'csv'
log = []
begin
CSV.foreach(import.attachment.url, headers: true, col_sep: ';') do |row|
password = hide_password(row)
log << { row: row.to_hash }
# try to find member based on import.update_field
user = User.find_by(import.update_field.to_sym => row[import.update_field])
params = row_to_params(row, user, password)
if user
service = Members::MembersService.new(user)
res = service.update(params)
log << { user: user.id, status: 'update', result: res }
else
user = User.new(params)
service = Members::MembersService.new(user)
res = service.create(import.user, params)
log << { user: user.id, status: 'create', result: res }
end
log << user.errors.to_hash unless user.errors.to_hash.empty?
rescue StandardError => e
log << e.to_s
puts e
puts e.backtrace
end
rescue ArgumentError => e
log << e.to_s
puts e
puts e.backtrace
end
log
end
private
def hashify(row, property, value: row[property], key: property.to_sym)
res = {}
res[key] = value if row[property]
res
end
def row_to_params(row, user, password)
res = {}
res.merge! hashify(row, 'id')
res.merge! hashify(row, 'username')
res.merge! hashify(row, 'email')
res.merge! hashify(row, 'password', value: password)
res.merge! hashify(row, 'password', key: :password_confirmation, value: password)
res.merge! hashify(row, 'allow_contact', value: row['allow_contact'] == 'yes', key: :is_allow_contact)
res.merge! hashify(row, 'allow_newsletter', value: row['allow_newsletter'] == 'yes', key: :is_allow_newsletter)
res.merge! hashify(row, 'group', value: group_id(row), key: :group_id)
res.merge! hashify(row, 'tags', value: tag_ids(row), key: :tag_ids)
profile_attributes = profile(row, user)
res[:profile_attributes] = profile_attributes if profile_attributes
invoicing_profile_attributes = invoicing_profile(row, user)
res[:invoicing_profile_attributes] = invoicing_profile_attributes if invoicing_profile_attributes
statistic_profile_attributes = statistic_profile(row, user)
res[:statistic_profile_attributes] = statistic_profile_attributes if statistic_profile_attributes
res
end
def group_id(row)
return unless row['group']
Group.friendly.find(row['group'])&.id
end
def tag_ids(row)
return unless row['tags']
Tag.where(id: row['tags'].split(',')).map(&:id)
end
def profile(row, user)
res = {}
res.merge! hashify(row, 'first_name')
res.merge! hashify(row, 'last_name')
res.merge! hashify(row, 'phone')
res.merge! hashify(row, 'interests', key: :interest)
res.merge! hashify(row, 'softwares', key: :software_mastered)
res.merge! hashify(row, 'website')
res.merge! hashify(row, 'job')
res.merge! hashify(row, 'facebook')
res.merge! hashify(row, 'twitter')
res.merge! hashify(row, 'googleplus', key: :google_plus)
res.merge! hashify(row, 'viadeo')
res.merge! hashify(row, 'linkedin')
res.merge! hashify(row, 'instagram')
res.merge! hashify(row, 'youtube')
res.merge! hashify(row, 'vimeo')
res.merge! hashify(row, 'dailymotion')
res.merge! hashify(row, 'github')
res.merge! hashify(row, 'echosciences')
res.merge! hashify(row, 'pinterest')
res.merge! hashify(row, 'lastfm')
res.merge! hashify(row, 'flickr')
res[:id] = user.profile.id if user&.profile
res
end
def invoicing_profile(row, user)
res = {}
res[:id] = user.invoicing_profile.id if user&.invoicing_profile
address_attributes = address(row, user)
res[:address_attributes] = address_attributes if address_attributes
organization_attributes = organization(row, user)
res[:organization_attributes] = organization_attributes if organization_attributes
res
end
def statistic_profile(row, user)
res = {}
res.merge! hashify(row, 'gender', value: row['gender'] == 'male')
res.merge! hashify(row, 'birthdate', key: :birthday)
res[:id] = user.statistic_profile.id if user&.statistic_profile
training_ids = training_ids(row)
res[:training_ids] = training_ids if training_ids
res
end
def address(row, user)
return unless row['address']
res = { address: row['address'] }
res[:id] = user.invoicing_profile.address.id if user&.invoicing_profile&.address
res
end
def organization(row, user)
return unless row['organization_name']
res = { name: row['organization_name'] }
res[:id] = user.invoicing_profile.organization.id if user&.invoicing_profile&.organization
address_attributes = organization_address(row, user)
res[:address_attributes] = address_attributes if address_attributes
res
end
def organization_address(row, user)
return unless row['organization_address']
res = { address: row['organization_address'] }
res[:id] = user.invoicing_profile.organization.address.id if user&.invoicing_profile&.organization&.address
res
end
def training_ids(row)
return unless row['trainings']
Training.where(id: row['trainings'].split(',')).map(&:id)
end
def hide_password(row)
password = row['password']
row['password'] = '********' if row['password']
password
end
end
end