diff options
| author | Xinhui | 2016-09-07 10:39:26 +0200 |
|---|---|---|
| committer | Xinhui | 2016-09-07 10:41:43 +0200 |
| commit | ce3640d67b28eb2193659a78af04cd7d52cfd320 (patch) | |
| tree | 1e20407bc255c3dfaf36a54fcc7c6bb77c765c38 | |
| parent | cce7cea1afb1907f92baef42237e731e16af710c (diff) | |
| download | chouette-core-ce3640d67b28eb2193659a78af04cd7d52cfd320.tar.bz2 | |
Reflex:sync default deleted_at to nil
| -rw-r--r-- | lib/stif/reflex_synchronization.rb | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/stif/reflex_synchronization.rb b/lib/stif/reflex_synchronization.rb index dea590eea..55fe3d404 100644 --- a/lib/stif/reflex_synchronization.rb +++ b/lib/stif/reflex_synchronization.rb @@ -44,7 +44,7 @@ module Stif def set_deleted_stop_area processed Rails.logger.info "Reflex:sync - StopArea start deleted_stop_area" start = Time.now - deleted = Chouette::StopArea.pluck(:objectid).uniq - processed + deleted = Chouette::StopArea.where(deleted_at: nil).pluck(:objectid).uniq - processed deleted.each_slice(50) do |object_ids| Chouette::StopArea.where(objectid: object_ids).update_all(deleted_at: Time.now) end @@ -91,6 +91,7 @@ module Stif stop = Chouette::StopArea.find_or_create_by(objectid: "dummy:StopArea:#{entry.id.tr(':', '')}") # Hack, on save object_version will be incremented by 1 entry.version = entry.version.to_i + 1 if stop.persisted? + stop.deleted_at = nil stop.stop_area_referential = self.defaut_referential { :name => :name, |