vegantech/sims

module CSVImporter
  class Schools < CSVImporter::Base
#
    FIELD_DESCRIPTIONS = { 
        :district_school_id =>"Key for school",
        :name =>"Name of school"
    }
    class << self
      def description
        "Schools in the district"
      end

      def csv_headers
        [:district_school_id, :name]
      end

      def overwritten
        "Any school in your district with a district_school_id in the csv file will get updated."
      end

      def load_order
        "1. This should be done first.  You may already have schools loaded in your district, if so, then you should go in manually to each one and add the
        district_school_id."
      end

      def removed
        "Any schools in your district with district_school_id assigned but not in this file will be removed."
      end

#      def related
#      end

      def how_often
        "Start of the school year, or handle manually.  If schools are added, closed, or renamed, then you could upload this again."
      end

#      def alternate
#      end
      #
      def how_many_rows
        "One row per school"
      end

      def upload_responses
        super
      end

    end




  private
    def index_options
      [:district_school_id]
    end


    def sims_model
      School
    end

    def migration t
      t.column :district_school_id, :integer
      t.column :name, :string
   end


    def update
      query = "update schools s inner join 
      #{temporary_table_name} ts on ts.district_school_id = s.district_school_id and s.district_id = #{@district.id}
      and s.district_school_id is not null
      set s.name=ts.name, s.updated_at=CURDATE()"
      ActiveRecord::Base.connection.update(query)
    end

    def insert_update_delete
      @updated=update
      @created=insert
      @deleted=delete
    end


    def delete
      query = "delete from s
      using schools s
      left outer join #{temporary_table_name} ts
      on ts.district_school_id=s.district_school_id
      where s.district_id=#{@district.id} and  s.district_school_id is not null and ts.district_school_id is null"
      ActiveRecord::Base.connection.update(query)
    end

    def insert
      query=("insert into schools
      (district_school_id, name, created_at, updated_at, district_id)
      select ts.district_school_id, ts.name,  CURDATE(), CURDATE(), #{@district.id} from #{temporary_table_name} ts 
      left outer join schools s  
      on ts.district_school_id = s.district_school_id
      and s.district_id = #{@district.id} 
      where s.id is null and ts.district_school_id is not null
      "
      )
      Group.connection.update query
    end
  end
end