Browse Source

minor refactoring

pull/8825/head
YevhenBondarenko 3 years ago
parent
commit
ccdb0212a8
  1. 2
      dao/src/main/java/org/thingsboard/server/dao/alarm/AlarmDao.java
  2. 2
      dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java
  3. 2
      dao/src/main/java/org/thingsboard/server/dao/sql/alarm/JpaAlarmDao.java

2
dao/src/main/java/org/thingsboard/server/dao/alarm/AlarmDao.java

@ -98,6 +98,6 @@ public interface AlarmDao extends Dao<Alarm> {
long countAlarmsByQuery(TenantId tenantId, CustomerId customerId, AlarmCountQuery query);
List<EntitySubtype> findTenantAlarmTypesAsync(UUID tenantId);
List<EntitySubtype> findTenantAlarmTypes(UUID tenantId);
}

2
dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java

@ -401,7 +401,7 @@ public class BaseAlarmService extends AbstractCachedEntityService<TenantId, Arra
log.trace("Executing findAlarmTypesByTenantId, tenantId [{}]", tenantId);
validateId(tenantId, INCORRECT_TENANT_ID + tenantId);
return cache.getAndPutInTransaction(tenantId, () ->
alarmDao.findTenantAlarmTypesAsync(tenantId.getId()).stream()
alarmDao.findTenantAlarmTypes(tenantId.getId()).stream()
.sorted(Comparator.comparing(EntitySubtype::getType))
.collect(Collectors.toCollection(ArrayList::new)), false);
}

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

@ -370,7 +370,7 @@ public class JpaAlarmDao extends JpaAbstractDao<AlarmEntity, Alarm> implements A
}
@Override
public List<EntitySubtype> findTenantAlarmTypesAsync(UUID tenantId) {
public List<EntitySubtype> findTenantAlarmTypes(UUID tenantId) {
return convertTenantEntityTypesToDto(tenantId, EntityType.ALARM, alarmRepository.findTenantAlarmTypes(tenantId));
}

Loading…
Cancel
Save