traffic-a22-forecast: sync data types and add origin to stations

noi-techpark · Sep 25, 2023 · fb5bea8 · fb5bea8
1 parent b9375be
commit fb5bea8
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/...traffic-a22-forecast/src/main/java/com/opendatahub/traffic/a22/forecast/JobScheduler.java b/...traffic-a22-forecast/src/main/java/com/opendatahub/traffic/a22/forecast/JobScheduler.java
@@ -36,7 +36,8 @@
 import it.bz.idm.bdp.dto.StationDto;
 import it.bz.idm.bdp.dto.StationList;
 
-import com.opendatahub.traffic.a22.forecast.config.DataTypes;;
+import com.opendatahub.traffic.a22.forecast.config.DataTypes;
+import com.opendatahub.traffic.a22.forecast.config.ProvenanceConfig;;
 
 @Service
 public class JobScheduler {
@@ -68,17 +69,17 @@ public class JobScheduler {
     @Value("${station.stationType}")
     public String stationType;
 
-    // @Autowired
-    // private ProvenanceConfig provenanceConfig;
+    @Autowired
+    private ProvenanceConfig provenanceConfig;
 
     @PostConstruct
     public void postConstruct() {
         // sync data types
-        // odhClient.syncDataTypes(stationType,
-        // Arrays.stream(DataTypes.values())
-        // .filter(d -> d.syncToOdh)
-        // .map(DataTypes::toDataTypeDto)
-        // .toList());
+        odhClient.syncDataTypes(stationType,
+                Arrays.stream(DataTypes.values())
+                        .filter(d -> d.syncToOdh)
+                        .map(DataTypes::toDataTypeDto)
+                        .toList());
 
         // historical import
         if (historyEnabled) {
@@ -120,7 +121,7 @@ public void syncData(YearMonth from, YearMonth to) {
                 Coordinate coordinate = coordinateMap.get(km);
                 StationDto stationDto = new StationDto(tollBoothName, tollBoothName, coordinate.latitude,
                         coordinate.longitude);
-                // stationDto.setOrigin(provenanceConfig.origin);
+                stationDto.setOrigin(provenanceConfig.origin);
                 stations.add(stationDto);
 
                 // create measurements