use equals with getAsString

telefonicaid · May 11, 2021 · e17130e · e17130e
1 parent 0185c6b
commit e17130e
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIMongoSink.java b/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIMongoSink.java
@@ -235,17 +235,19 @@ private void persistAggregation(NGSIGenericAggregator aggregator) throws CygnusP
             JsonElement attType;
             if (rowAttrPersistence) {
                 attType = aggregator.getAggregation().get(NGSIConstants.ATTR_TYPE).get(i);
-                if ( (attType != null) &&
-                     (attType.toString().contains("ISO8601") ||
-                      attType.toString().contains("DateTime")) ) {
+                if ( (attType != null &&
+                      attType.isJsonPrimitive()) &&
+                     (attType.getAsString().equals("ISO8601") ||
+                      attType.getAsString().equals("DateTime")) ) {
                     basicDBObject = castDate(NGSIConstants.ATTR_VALUE, basicDBObject);
                 }
             } else {
                 for (String key : basicDBObject.keySet()) {
                     attType = aggregator.getAggregation().get(key + NGSIConstants.AUTOGENERATED_ATTR_TYPE).get(i);
-                    if ( (attType != null) &&
-                         (attType.toString().contains("ISO8601") ||
-                          attType.toString().contains("DateTime")) ) {
+                    if ( (attType != null &&
+                          attType.isJsonPrimitive()) &&
+                         (attType.getAsString().equals("ISO8601") ||
+                          attType.getAsString().equals("DateTime")) ) {
                         basicDBObject = castDate(key, basicDBObject);
                     }
                 }