diff options
| author | Xinhui | 2016-08-31 15:23:31 +0200 | 
|---|---|---|
| committer | Xinhui | 2016-08-31 15:23:31 +0200 | 
| commit | a71d5b8ff5804094bcbe1c945ad8fde02ba7f9f0 (patch) | |
| tree | 169f4433efcece6d503b27de0c6bbb65c8788918 | |
| parent | c3d262e691c3301243be89e498c8d8034c9f4b53 (diff) | |
| download | chouette-core-a71d5b8ff5804094bcbe1c945ad8fde02ba7f9f0.tar.bz2 | |
Reflex:sync log processing time
| -rw-r--r-- | lib/stif/reflex_synchronization.rb | 23 | ||||
| -rw-r--r-- | lib/tasks/reflex.rake | 2 | 
2 files changed, 19 insertions, 6 deletions
| diff --git a/lib/stif/reflex_synchronization.rb b/lib/stif/reflex_synchronization.rb index fd2f497e2..2da8664a9 100644 --- a/lib/stif/reflex_synchronization.rb +++ b/lib/stif/reflex_synchronization.rb @@ -11,23 +11,36 @@ module Stif        end        def synchronize +        start  = Time.now          client = Reflex::API.new +          ['getOR', 'getOP'].each do |method| -          results    = client.process method -          stop_areas = results[:Quay].merge(results[:StopPlace]) +          results = client.process method +          Rails.logger.info "Reflex:sync - Process #{method} done in #{Time.now - start} seconds" +          results.each do |type, entries| +            Rails.logger.info "Reflex:sync - #{entries.count} #{type} retrieved" +          end +          start = Time.now            results[:StopPlaceEntrance].each do |id, entry|              self.create_or_update_access_point entry            end -          Rails.logger.debug "Reflex:sync - StopPlaceEntrance sync done !" +          Rails.logger.info "Reflex:sync - Create or update AccessPoint done in #{Time.now - start} seconds" + +          # Create or update stop_area for every quay, stop_place +          stop_areas = results[:Quay].merge(results[:StopPlace]) +          start = Time.now            stop_areas.each do |id, entry|              self.create_or_update_stop_area entry            end -          Rails.logger.debug "Reflex:sync - StopAreas sync done !" +          Rails.logger.info "Reflex:sync - Create or update StopArea done in #{Time.now - start} seconds" + +          # Walk through every entry and set parent stop_area +          start = Time.now            stop_areas.each do |id, entry|              self.stop_area_set_parent entry            end -          Rails.logger.debug "Reflex:sync - StopAreas : set  parents sync done !" +          Rails.logger.info "Reflex:sync - StopArea set parent done in #{Time.now - start} seconds"          end        end diff --git a/lib/tasks/reflex.rake b/lib/tasks/reflex.rake index 0bc3953a8..0020f1b60 100644 --- a/lib/tasks/reflex.rake +++ b/lib/tasks/reflex.rake @@ -3,6 +3,6 @@ namespace :reflex do    task sync: :environment  do      start = Time.now      Stif::ReflexSynchronization.synchronize -    Rails.logger.debug "Reflex-api sync done in #{Time.now - start} seconds !" +    Rails.logger.debug "Reflex:sync done in #{Time.now - start} seconds !"    end  end | 
