72 lines
1.9 KiB
Ruby
72 lines
1.9 KiB
Ruby
require 'csv'
|
|
require_dependency 'system_message'
|
|
|
|
module Jobs
|
|
|
|
class ExportCsvFile < Jobs::Base
|
|
sidekiq_options retry: false
|
|
attr_accessor :current_user
|
|
|
|
def initialize
|
|
@file_name = ""
|
|
end
|
|
|
|
def execute(args)
|
|
entity = args[:entity]
|
|
@current_user = User.find_by(id: args[:user_id])
|
|
|
|
raise Discourse::InvalidParameters.new(:entity) if entity.blank?
|
|
|
|
case entity
|
|
when 'user'
|
|
query = ::AdminUserIndexQuery.new
|
|
user_data = query.find_users_query.to_a
|
|
data = Array.new
|
|
|
|
user_data.each do |user|
|
|
user_array = Array.new
|
|
user_array.push(user['id']).push(user['name']).push(user['username']).push(user['email'])
|
|
data.push(user_array)
|
|
end
|
|
end
|
|
|
|
if data && data.length > 0
|
|
set_file_path
|
|
write_csv_file(data)
|
|
end
|
|
|
|
notify_user
|
|
end
|
|
|
|
private
|
|
|
|
def set_file_path
|
|
@file_name = "export_#{SecureRandom.hex(4)}.csv"
|
|
# ensure directory exists
|
|
dir = File.dirname("#{ExportCsv.base_directory}/#{@file_name}")
|
|
FileUtils.mkdir_p(dir) unless Dir.exists?(dir)
|
|
end
|
|
|
|
def write_csv_file(data)
|
|
# write to CSV file
|
|
CSV.open(File.expand_path("#{ExportCsv.base_directory}/#{@file_name}", __FILE__), "w") do |csv|
|
|
data.each do |value|
|
|
csv << value
|
|
end
|
|
end
|
|
end
|
|
|
|
def notify_user
|
|
if @current_user
|
|
if @file_name != "" && File.exists?("#{ExportCsv.base_directory}/#{@file_name}")
|
|
SystemMessage.create_from_system_user(@current_user, :csv_export_succeeded, download_link: "#{Discourse.base_url}/admin/export_csv/#{@file_name}/download", file_name: @file_name)
|
|
else
|
|
SystemMessage.create_from_system_user(@current_user, :csv_export_failed)
|
|
end
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
end
|