Community resource importer

app/models/importers/community_resource_importer.rb

@@ -0,0 +1,104 @@
+class Importers::CommunityResourceImporter < Importers::BaseImporter
+  def primary_import_klass_name
+    "CommunityResource"
+  end
+
+  def process_row(row)
+    organization = Organization.joins(:location).includes(:location)
+                       .where(name: row["organization_name"])
+                       .where(locations: {
+                           street_address: row["street"],
+                           city: row["city"],
+                           zip: row["zip"]
+                       }).take
+
+    business_location = LocationType.find_or_create_by(name: "business")
+
+    unless organization
+      organization = Organization.create! name: row["organization_name"] do |organization|
+        organization.location = Location.create! do |location|
+          location.street_address = row["street"]
+          location.city = row["city"]
+          location.state = row["state"]
+          location.zip = row["zip"]
+          location.county = row["county"]
+          location.location_type = business_location
+        end
+      end
+    end
+
+    community_resource = organization.community_resources.i18n.where(name: row["name"], publish_from: row["publish_from"])
+    if community_resource
+      community_resource.description = row["description"]
+
+      row["category_name"].split(/,\s*/).each do |category|
+        community_resource.tag_list << category
+      end
+
+      community_resource.save
+
+      # Resource exists so there's nothing else to update. Return early and move onto the new row.
+      # This assumes nothing else needs to be updated for existing data.
+      return
+    end
+
+    community_resource = CommunityResource.create!(
+        name: row["name"],
+        website_url: row["website_url"],
+        facebook_url: row["facebook_url"],
+        phone: row["phone"],
+        youtube_identifier: row["youtube_identifier"],
+        publish_from: row["publish_from"],
+        publish_until: row["publish_until"],
+        is_created_by_admin: row["is_created_by_admin"],
+        is_approved: row["is_approved"],
+        description: row["description"],
+        organization: organization
+    )
+
+    row["category_name"].split(/,\s*/).each do |category|
+      community_resource.tag_list << category
+    end
+
+    community_resource.location = Location.create! do |location|
+      location.street_address = row["street"]
+      location.city = row["city"]
+      location.state = row["state"]
+      location.zip = row["zip"]
+      location.county = row["county"]
+      location.location_type = business_location
+    end
+
+    service_location_type = LocationType.find_or_create_by(name: "service_area")
+    community_resource.service_area = ServiceArea.create! do |service_area|
+      if row["service_area_name"]
+        service_area.name = row["service_area_name"]
+      elsif row["service_area_town_names"]
+        service_area.name = row["service_area_town_names"]
+      elsif row["service_area_counties"]
+        service_area.name = row["service_area_counties"]
+      else
+        service_area.name = row["city"]
+      end
+
+      if row["service_area_counties"]
+        service_area.service_area_type = "county"
+      else
+        service_area.service_area_type = "city"
+      end
+
+      service_area.organization = community_resource.organization
+      service_area.location = Location.create! do |location|
+        location.location_type = service_location_type
+
+        location.city = row["service_area_town_names"] ? row["service_area_town_names"] : row["city"]
+
+        location.state = row["state"]
+
+        location.county = row["service_area_counties"] ? row["service_area_counties"] : row["county"]
+      end
+    end
+
+    community_resource.save
+  end
+end

db/scripts/community_resource_seeds.rb

@@ -0,0 +1,8 @@
+require 'csv'
+
+csv = "community_resources.csv"
+path = Rails.root.join('db', 'seeds', 'public_template_csvs', csv)
+importer = Importers::CommunityResourceImporter.new(User.first)
+importer.import(path)
+
+puts "completed community_resources.csv"