thingsboard-aplcache

Reviewed

9/27/2018 11:07:54 AM

Details

diff --git a/dao/src/main/java/org/thingsboard/server/dao/entityview/EntityViewServiceImpl.java b/dao/src/main/java/org/thingsboard/server/dao/entityview/EntityViewServiceImpl.java
index a45a641..9fdadcd 100644
--- a/dao/src/main/java/org/thingsboard/server/dao/entityview/EntityViewServiceImpl.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/entityview/EntityViewServiceImpl.java
@@ -228,17 +228,13 @@ public class EntityViewServiceImpl extends AbstractEntityService implements Enti
                     filteredAttributes =
                             attributeKvEntries.stream()
                                     .filter(attributeKvEntry -> {
-                                        if (entityView.getStartTimeMs() == 0 && entityView.getEndTimeMs() == 0) {
-                                            return true;
-                                        }
-                                        if (entityView.getEndTimeMs() == 0 && entityView.getStartTimeMs() < attributeKvEntry.getLastUpdateTs()) {
-                                            return true;
-                                        }
-                                        if (entityView.getStartTimeMs() == 0 && entityView.getEndTimeMs() > attributeKvEntry.getLastUpdateTs()) {
-                                            return true;
-                                        }
-                                        return entityView.getStartTimeMs() < attributeKvEntry.getLastUpdateTs()
-                                                && entityView.getEndTimeMs() > attributeKvEntry.getLastUpdateTs();
+                                        long startTime = entityView.getStartTimeMs();
+                                        long endTime = entityView.getEndTimeMs();
+                                        long lastUpdateTs = attributeKvEntry.getLastUpdateTs();
+                                        return startTime == 0 && endTime == 0 ||
+                                                (endTime == 0 && startTime < lastUpdateTs) ||
+                                                (startTime == 0 && endTime > lastUpdateTs) ||
+                                                (startTime < lastUpdateTs && endTime > lastUpdateTs);
                                     }).collect(Collectors.toList());
                 }
                 try {