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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
class Merge < ActiveRecord::Base
extend Enumerize
belongs_to :workbench
enumerize :status, in: %w[new pending successful failed running]
has_array_of :referentials, class_name: 'Referential'
delegate :output, to: :workbench
attr_reader :new
def merge!
update started_at: Time.now, status: :running
prepare_new
referentials.each do |referential|
merge_referential referential
end
save_current
ensure
update ended_at: Time.now, status: :successful
end
def prepare_new
new =
if workbench.output.current
Rails.logger.debug "Clone current output"
Referential.new_from(workbench.output.current, fixme_functional_scope).tap do |clone|
clone.inline_clone = true
end
else
Rails.logger.debug "Create a new output"
# 'empty' one
attributes = {
workbench: workbench,
organisation: workbench.organisation, # TODO could be workbench.organisation by default
name: I18n.t("merges.referential_name"),
slug: "output_#{workbench.id}_#{Time.now.to_i}"
}
workbench.output.referentials.new attributes
end
new.save!
output.update new: new
@new = new
end
def merge_referential(referential)
Rails.logger.debug "Merge #{referential.slug}"
puts referential.metadatas.inspect
metadata_merger = MetadatasMerger.new new, referential
metadata_merger.merge
new.metadatas.delete metadata_merger.empty_metadatas
new.save!
puts new.metadatas.inspect
referential.metadatas.each do |metadata|
metadata.line_ids.each do |line_id|
metadata.periodes.each do |period|
puts "Clean data for #{line_id} #{period}"
end
end
end
# let's merge data :)
end
def save_current
output.update current: new, new: nil
output.current.update referential_suite: output
end
def fixme_functional_scope
if attribute = workbench.organisation.sso_attributes.try(:[], "functional_scope")
JSON.parse(attribute)
end
end
def child_change
end
class MetadatasMerger
attr_reader :merge_metadatas, :referential
def initialize(merge_referential, referential)
@merge_metadatas = merge_referential.metadatas
@referential = referential
end
delegate :metadatas, to: :referential, prefix: :referential
def merge
referential_metadatas.each do |metadata|
merge_one metadata
end
end
def merged_line_metadatas(line_id)
merge_metadatas.select do |m|
m.line_ids.include? line_id
end
end
def merge_one(metadata)
metadata.line_ids.each do |line_id|
line_metadatas = merged_line_metadatas(line_id)
metadata.periodes.each do |period|
puts "#{line_id} #{period}"
line_metadatas.each do |m|
m.periodes = m.periodes.map do |existing_period|
existing_period.remove period
end.flatten
end
attributes = {
line_ids: [line_id],
periodes: [period],
referential_source_id: referential.id,
created_at: metadata.created_at # TODO check required dates
}
# line_metadatas should not contain conflicted metadatas
merge_metadatas << ReferentialMetadata.new(attributes)
end
end
end
def empty_metadatas
merge_metadatas.select { |m| m.periodes.empty? }
end
end
end
|
