Browse Source

added ordering by id

pull/12037/head
dashevchenko 2 years ago
parent
commit
7d088bda02
  1. 6
      application/src/main/java/org/thingsboard/server/service/subscription/DefaultTbEntityDataSubscriptionService.java
  2. 2
      application/src/main/java/org/thingsboard/server/service/subscription/TbAlarmStatusSubscription.java
  3. 2
      dao/src/main/java/org/thingsboard/server/dao/sql/alarm/AlarmRepository.java

6
application/src/main/java/org/thingsboard/server/service/subscription/DefaultTbEntityDataSubscriptionService.java

@ -470,7 +470,7 @@ public class DefaultTbEntityDataSubscriptionService implements TbEntityDataSubsc
List<UUID> alarmIds = alarmService.findActiveOriginatorAlarms(subscription.getTenantId(), originatorAlarmFilter, alarmsPerAlarmStatusSubscriptionCacheSize);
subscription.getAlarmIds().addAll(alarmIds);
subscription.setFullCache(alarmIds.size() == alarmsPerAlarmStatusSubscriptionCacheSize);
subscription.setCacheFull(alarmIds.size() == alarmsPerAlarmStatusSubscriptionCacheSize);
}
private void sendUpdate(String sessionId, CmdUpdate update) {
@ -487,7 +487,7 @@ public class DefaultTbEntityDataSubscriptionService implements TbEntityDataSubsc
if (!subscription.matches(alarm) || subscriptionUpdate.isAlarmDeleted()) {
alarmsIds.remove(alarm.getId().getId());
if (alarmsIds.isEmpty()) {
if (subscription.isFullCache()) {
if (subscription.isCacheFull()) {
fetchActiveAlarms(subscription);
if (alarmsIds.isEmpty()) {
sendUpdate(subscription.getSessionId(), subscription.createUpdate());
@ -504,7 +504,7 @@ public class DefaultTbEntityDataSubscriptionService implements TbEntityDataSubsc
sendUpdate(subscription.getSessionId(), subscription.createUpdate());
}
} else {
subscription.setFullCache(true);
subscription.setCacheFull(true);
}
}
} catch (Exception e) {

2
application/src/main/java/org/thingsboard/server/service/subscription/TbAlarmStatusSubscription.java

@ -38,7 +38,7 @@ public class TbAlarmStatusSubscription extends TbSubscription<AlarmSubscriptionU
private final Set<UUID> alarmIds = new HashSet<>();
@Getter
@Setter
private boolean fullCache;
private boolean cacheFull;
@Getter
private final List<String> typeList;
@Getter

2
dao/src/main/java/org/thingsboard/server/dao/sql/alarm/AlarmRepository.java

@ -408,7 +408,7 @@ public interface AlarmRepository extends JpaRepository<AlarmEntity, UUID> {
"WHERE a.originator_id = :originatorId " +
"AND (COALESCE(:alarmTypes) IS NULL OR a.type IN (:alarmTypes)) " +
"AND (COALESCE(:alarmSeverities) IS NULL OR a.severity IN (:alarmSeverities)) " +
"AND (a.cleared = false) LIMIT :limit", nativeQuery = true)
"AND (a.cleared = false) ORDER BY id LIMIT :limit", nativeQuery = true)
List<UUID> findActiveOriginatorAlarms(@Param("originatorId") UUID originatorId,
@Param("alarmTypes") List<String> alarmTypes,
@Param("alarmSeverities") List<String> alarmSeverities,

Loading…
Cancel
Save