Fixed aggregate references

FraunhoferIOSB · Jul 25, 2023 · a599e4e · a599e4e
1 parent c05e9a3
commit a599e4e
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/de/fraunhofer/iosb/ilt/sensorthingsmanager/aggregation/AggregationData.java b/src/main/java/de/fraunhofer/iosb/ilt/sensorthingsmanager/aggregation/AggregationData.java
@@ -358,9 +358,14 @@ private void checkReferenceFromDs(Entity sourceDs, Entity aggregateMds, Aggregat
         String aggKey = null;
         Object aggId = null;
         if (sourceEqualsTarget) {
-            expectedAggFor = "/Datastreams(" + formatKeyValuesForUrl(sourceDs.getPrimaryKeyValues()) + ")";
+            final Object[] primaryKeyValues = sourceDs.getPrimaryKeyValues();
+            expectedAggFor = "/Datastreams(" + formatKeyValuesForUrl(primaryKeyValues) + ")";
             aggKey = KEY_AGGREGATE_SOURCE_D;
-            aggId = formatKeyValuesForUrl(sourceDs.getPrimaryKeyValues());
+            if (primaryKeyValues.length == 1) {
+                aggId = primaryKeyValues[0];
+            } else {
+                aggId = formatKeyValuesForUrl(primaryKeyValues);
+            }
         } else {
             expectedAggFor = sourceDs.getSelfLink();
         }