Thanh Hung Pham · @hungpt · Tan Phat Nguyen · Thanh Hung Pham · Tan Phat Nguyen · Thanh Hung Pham
--- a/lib/import/csv_reader.rb 0 → 100644
+++ b/lib/import/csv_reader.rb 0 → 100644
+require 'csv'
+
+class Import::CSVReader
+  attr_reader :thread_count, :logger
+
+  def initialize(file, thread_count)
+    @file = file
+    @thread_count = thread_count
+    @mutex = Mutex.new
+    @logger = Logger.new("#{Rails.root}/log/csv_reader.log")
+  end
+
+  def import
+    @logger.info('Start read data')
+    workers = (0...thread_count).map do
+      Thread.new do
--- a/lib/tasks/import_csv.rake 0 → 100644
+++ b/lib/tasks/import_csv.rake 0 → 100644
+require 'net/ftp'
+require 'rubygems'
+require 'zip'
+
+namespace :import do
+  desc 'Import CSV'
+  task csv: :environment do
+    thread_count = ENV['THREAD_COUNT'] || 1
+
+    ftp = Net::FTP.new