| ... |
... |
@@ -22,12 +22,9 @@ |
|
22
|
22
|
package fr.ird.observe.application.swing.ui.admin.consolidate;
|
|
23
|
23
|
|
|
24
|
24
|
import com.google.common.collect.ImmutableSet;
|
|
|
25
|
+import fr.ird.observe.application.swing.ObserveRunner;
|
|
25
|
26
|
import fr.ird.observe.application.swing.db.ObserveSwingDataSource;
|
|
26
|
|
-import fr.ird.observe.application.swing.ui.admin.AdminStep;
|
|
27
|
|
-import fr.ird.observe.application.swing.ui.admin.AdminTabUI;
|
|
28
|
|
-import fr.ird.observe.application.swing.ui.admin.AdminTabUIHandler;
|
|
29
|
|
-import fr.ird.observe.application.swing.ui.admin.AdminUI;
|
|
30
|
|
-import fr.ird.observe.application.swing.ui.admin.AdminUIModel;
|
|
|
27
|
+import fr.ird.observe.application.swing.ui.admin.*;
|
|
31
|
28
|
import fr.ird.observe.application.swing.ui.admin.config.SelectDataUI;
|
|
32
|
29
|
import fr.ird.observe.application.swing.ui.storage.tabs.DataSelectionModel;
|
|
33
|
30
|
import fr.ird.observe.application.swing.ui.tree.DataSelectionTreeSelectionModel;
|
| ... |
... |
@@ -41,7 +38,7 @@ import jaxx.runtime.swing.wizard.ext.WizardState; |
|
41
|
38
|
import org.apache.commons.logging.Log;
|
|
42
|
39
|
import org.apache.commons.logging.LogFactory;
|
|
43
|
40
|
|
|
44
|
|
-import javax.swing.JTree;
|
|
|
41
|
+import javax.swing.*;
|
|
45
|
42
|
import java.beans.PropertyChangeListener;
|
|
46
|
43
|
import java.util.Date;
|
|
47
|
44
|
import java.util.Set;
|
| ... |
... |
@@ -131,35 +128,50 @@ public class ConsolidateUIHandler extends AdminTabUIHandler { |
|
131
|
128
|
|
|
132
|
129
|
ConsolidateDataService consolidateDataService = dataSource.newConsolidateDataService();
|
|
133
|
130
|
|
|
134
|
|
- ConsolidateTripSeineDataRequest request = new ConsolidateTripSeineDataRequest();
|
|
135
|
|
- request.setTripSeineIds(tripIds);
|
|
136
|
|
- request.setFailIfLenghtWeightParameterNotFound(false);
|
|
|
131
|
+ int nbResults = 0;
|
|
|
132
|
+ int index=0;
|
|
|
133
|
+ int nbTrips = tripIds.size();
|
|
137
|
134
|
|
|
138
|
|
- ImmutableSet<ConsolidateTripSeineDataResult> results = consolidateDataService.consolidateTripSeines(request);
|
|
|
135
|
+ for (String tripId : tripIds) {
|
|
139
|
136
|
|
|
140
|
|
- if (results.isEmpty()) {
|
|
|
137
|
+ ConsolidateTripSeineDataRequest request = new ConsolidateTripSeineDataRequest();
|
|
|
138
|
+ request.setTripSeineIds(ImmutableSet.of(tripId));
|
|
|
139
|
+ request.setFailIfLenghtWeightParameterNotFound(false);
|
|
141
|
140
|
|
|
142
|
|
- sendMessage(t("observe.actions.consolidate.message.noChanges"));
|
|
|
141
|
+ sendMessage(t("observe.actions.consolidate.start.trip", ++index, nbTrips, tripId));
|
|
143
|
142
|
|
|
144
|
|
- } else {
|
|
|
143
|
+ ImmutableSet<ConsolidateTripSeineDataResult> results = consolidateDataService.consolidateTripSeines(request);
|
|
145
|
144
|
|
|
146
|
|
- for (ConsolidateTripSeineDataResult tripSeineDataResult : results) {
|
|
|
145
|
+ ObserveRunner.cleanMemory();
|
|
147
|
146
|
|
|
148
|
|
- String tripSeineLabel = tripSeineDataResult.getTripSeineLabel();
|
|
|
147
|
+ nbResults+=results.size();
|
|
149
|
148
|
|
|
150
|
|
- sendMessage(t("observe.actions.consolidate.message.trip", tripSeineLabel));
|
|
|
149
|
+ if (results.isEmpty()) {
|
|
151
|
150
|
|
|
152
|
|
- for (ConsolidateActivitySeineDataResult activitySeineDataResult : tripSeineDataResult.getConsolidateActivitySeineDataResults()) {
|
|
|
151
|
+ sendMessage(t("observe.actions.consolidate.message.noChanges"));
|
|
153
|
152
|
|
|
154
|
|
- sendMessage(t("observe.actions.consolidate.message.activity", activitySeineDataResult.getActivitySeineLabel()));
|
|
|
153
|
+ }
|
|
|
154
|
+ else {
|
|
|
155
|
+ for (ConsolidateTripSeineDataResult tripSeineDataResult : results) {
|
|
155
|
156
|
|
|
156
|
|
- }
|
|
|
157
|
+ String tripSeineLabel = tripSeineDataResult.getTripSeineLabel();
|
|
|
158
|
+
|
|
|
159
|
+ sendMessage(t("observe.actions.consolidate.message.trip", tripSeineLabel));
|
|
|
160
|
+
|
|
|
161
|
+ for (ConsolidateActivitySeineDataResult activitySeineDataResult : tripSeineDataResult.getConsolidateActivitySeineDataResults()) {
|
|
|
162
|
+
|
|
|
163
|
+ sendMessage(t("observe.actions.consolidate.message.activity", activitySeineDataResult.getActivitySeineLabel()));
|
|
157
|
164
|
|
|
|
165
|
+ }
|
|
|
166
|
+
|
|
|
167
|
+ }
|
|
158
|
168
|
}
|
|
159
|
169
|
|
|
160
|
|
- sendMessage(t("observe.actions.consolidate.message.save.changes", results.size()));
|
|
161
|
170
|
}
|
|
162
|
171
|
|
|
|
172
|
+ sendMessage(t("observe.actions.consolidate.message.save.changes", nbResults));
|
|
|
173
|
+
|
|
|
174
|
+
|
|
163
|
175
|
sendMessage(t("observe.actions.consolidate.message.operation.done", new Date()));
|
|
164
|
176
|
|
|
165
|
177
|
}
|