Nguyen Ngoc Nghia · @nghiann · Van Hau Le · Nguyen Ngoc Nghia · Van Hau Le · Nguyen Ngoc Nghia
--- a/app/controllers/jobs_controller.rb
+++ b/app/controllers/jobs_controller.rb
  before_action :find_user, only: :apply_available

  def index
+    @search = params[:search] || ":"
    if params[:city_id]
      @city = City.find(params[:city_id])
      @jobs = @city.jobs
+      @jobs = @jobs.page(params[:page]).per(Settings.job.per_page).decorate
    elsif params[:industry_id]
      @industry = Industry.find(params[:industry_id])
      @jobs = @industry.jobs
+      @jobs = @jobs.page(params[:page]).per(Settings.job.per_page).decorate
    else
-      @jobs = Job.all
+      @jobs_count = SolrService.new.search(@search)["numFound"]
--- a/app/services/solr_service.rb 0 → 100644
+++ b/app/services/solr_service.rb 0 → 100644
+    @solr.delete_by_query("*:*")
+    @solr.commit
+  end
+
+  def search(params)
+    # city = @city.present? ? "city:\"#{escape_str(@city.name)}\"" : ""
+    # industry = @industry.present? ? "industry:\"#{escape_str(@industry.name)}\"" : ""
+    response = @solr.get "select", params: {
+      q: "*#{params}*",
+      # fq: [industry, city],
+      rows: Job.count
+    }
+    response["response"]
+  end
+
+  def escape_str(str)
--- a/app/services/solr_service.rb 0 → 100644
+++ b/app/services/solr_service.rb 0 → 100644
+require "rsolr"
+
+class SolrService
+  def initialize
+    @solr = RSolr.connect(
+      url: Settings.solr.connection.server_url,
+      read_timeout: Settings.solr.connection.read_timeout,
+      open_timeout: Settings.solr.connection.open_timeout,
+      retry_503: Settings.solr.connection.retry_503
+    )
+  end
+
+  def add_data
+    jobs = Job.includes(:cities, :industries, :company).all
--- a/app/services/solr_service.rb 0 → 100644
+++ b/app/services/solr_service.rb 0 → 100644
+require "rsolr"
+
+class SolrService
+  def initialize
+    @solr = RSolr.connect(
+      url: Settings.solr.connection.server_url,
+      read_timeout: Settings.solr.connection.read_timeout,
+      open_timeout: Settings.solr.connection.open_timeout,
+      retry_503: Settings.solr.connection.retry_503
+    )
+  end
+
+  def add_data
+    jobs = Job.includes(:cities, :industries, :company).all
+    jobs_solr_index = jobs.map do |job|
--- a/app/views/jobs/index.html.erb
+++ b/app/views/jobs/index.html.erb
+<%= form_tag( jobs_path, method: :get, class: "form-inline") do %>
+  <%= search_field_tag :search, params[:search], class: "form-control mb-2 mr-sm-2" %>
+  <%= submit_tag "Search", class: "btn btn-primary mb-2" %>
+<% end %>
+
 <h3>Total: <%= params[:city_id] ? @city.job_count :
-              (params[:industry_id] ? @industry.job_count : Job.count) %></h3>
-<h3>Result for: </h3>
+              (params[:industry_id] ? @industry.job_count : @jobs_count) %></h3>
--- a/lib/tasks/task.rake
+++ b/lib/tasks/task.rake
+
+namespace :solr do
+  desc "solr index data"
+  task solr_index: :environment do
+    SolrService.new.add_data
+
+    index = ActiveSupport::Logger.new("log/solr_service.log")
+    index.info "Solr index data succesfully at #{Time.current}"
+  end
+
+  desc "solr delete data"
+  task solr_delete: :environment do
+    SolrService.new.delete_data
+
+    delete = ActiveSupport::Logger.new("log/solr_service.log")
+    delete.info "Solr delete all data succesfully at #{Time.current}"
--- a/app/services/solr_service.rb 0 → 100644
+++ b/app/services/solr_service.rb 0 → 100644
+
+    send_request(q, fq)
+  end
+
+  def query_by_city
+    city = City.find(@search_keyword)
+    city_name = city.name
+
+    q = "*:*"
+    fq = "city: #{escape_str(city_name)}"
+
+    send_request(q, fq)
+  end
+
+  def query_by_industry
+    industry = Industry.find(@search_keyword)
--- a/app/services/solr_service.rb 0 → 100644
+++ b/app/services/solr_service.rb 0 → 100644
+require "rsolr"
+
+class SolrService
+  def initialize(search_keyword)
--- a/lib/tasks/task.rake
+++ b/lib/tasks/task.rake
    import.info "Cities, industries, companies, jobs imported succesfully at #{Time.current}"
  end
 end
+
+namespace :solr do
+  desc "solr index data"
+  task solr_index: :environment do
+    SolrService.new.add_data
+
+    solr_index_data = ActiveSupport::Logger.new("log/solr_service.log")