blob: ce663396bfa3c5739fa4573eabbe86c3afe39aec (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
module Stif
module ReflexSynchronization
class << self
def defaut_referential
StopAreaReferential.find_by(name: "Reflex")
end
# Todo remove dummy objectid
def find_by_object_id objectid
Chouette::StopArea.find_by(objectid: "dummy:StopArea:#{objectid.tr(':', '')}")
end
def synchronize_stop_area
client = Reflex::API.new
['getOR', 'getOP'].each do |method|
results = client.process method
results = results[:Quay].merge(results[:StopPlace])
processed = []
results.each do |id, entry|
Rails.logger.debug "Reflex - Processing - #{entry.id}"
processed << self.create_or_update_stop_area(entry)
end
processed.each do |entry|
Rails.logger.debug "Reflex - Set parent for - #{entry.id}"
self.set_parent entry
end
end
end
def set_parent entry
return false unless entry.try(:parent_site_ref) || entry.try(:quays)
stop = self.find_by_object_id entry.id
if entry.try(:parent_site_ref)
stop.parent = self.find_by_object_id entry.parent_site_ref
stop.save! if stop.changed
end
if entry.try(:quays)
entry.quays.each do |quay|
children = self.find_by_object_id(quay[:ref])
next unless children
children.parent = stop
children.save! if children.changed?
end
end
end
def create_or_update_stop_area entry
stop = Chouette::StopArea.find_or_create_by(objectid: "dummy:StopArea:#{entry.id.tr(':', '')}")
stop.stop_area_referential = self.defaut_referential
stop.name = entry.name
stop.creation_time = entry.created
stop.area_type = entry.area_type
# stop.object_version = entry.version
stop.zip_code = entry.postal_code
stop.city_name = entry.city
if stop.changed?
Rails.logger.debug "Reflex - Updating - #{entry.id}"
stop.save!
stop
end
end
end
end
end
|
