Browse Source

fixed tests

pull/12652/head
dashevchenko 2 years ago
parent
commit
33eac2f778
  1. 15
      application/src/main/java/org/thingsboard/server/service/subscription/TbAlarmCountSubCtx.java
  2. 6
      common/data/src/main/java/org/thingsboard/server/common/data/query/AlarmCountQuery.java
  3. 2
      common/data/src/main/java/org/thingsboard/server/common/data/query/EntityCountQuery.java
  4. 3
      dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java
  5. 4
      dao/src/main/java/org/thingsboard/server/dao/sql/query/DefaultAlarmQueryRepository.java

15
application/src/main/java/org/thingsboard/server/service/subscription/TbAlarmCountSubCtx.java

@ -80,14 +80,15 @@ public class TbAlarmCountSubCtx extends TbAbstractEntityQuerySubCtx<AlarmCountQu
} }
private int countAlarms() { private int countAlarms() {
PageData<EntityData> data = entityService.findEntityDataByQuery(getTenantId(), getCustomerId(), buildEntityDataQuery()); List<EntityId> entityIds = null;
List<EntityId> entityIds = data.getData().stream().map(EntityData::getEntityId).toList(); if (query.getEntityFilter() != null) {
if (entityIds.isEmpty()) { PageData<EntityData> data = entityService.findEntityDataByQuery(getTenantId(), getCustomerId(), buildEntityDataQuery());
return 0; if (data.getData().isEmpty()) {
} else { return 0;
return (int) alarmService.countAlarmsByQuery(getTenantId(), getCustomerId(), query, entityIds); }
entityIds = data.getData().stream().map(EntityData::getEntityId).toList();
} }
return (int) alarmService.countAlarmsByQuery(getTenantId(), getCustomerId(), query, entityIds);
} }
private EntityDataQuery buildEntityDataQuery() { private EntityDataQuery buildEntityDataQuery() {

6
common/data/src/main/java/org/thingsboard/server/common/data/query/AlarmCountQuery.java

@ -17,9 +17,8 @@ package org.thingsboard.server.common.data.query;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;
import lombok.Getter; import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.thingsboard.server.common.data.alarm.AlarmSearchStatus; import org.thingsboard.server.common.data.alarm.AlarmSearchStatus;
import org.thingsboard.server.common.data.alarm.AlarmSeverity; import org.thingsboard.server.common.data.alarm.AlarmSeverity;
@ -30,8 +29,7 @@ import java.util.List;
@Builder @Builder
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
@Getter @Data
@Setter
@ToString @ToString
public class AlarmCountQuery extends EntityCountQuery { public class AlarmCountQuery extends EntityCountQuery {
private long startTs; private long startTs;

2
common/data/src/main/java/org/thingsboard/server/common/data/query/EntityCountQuery.java

@ -27,7 +27,7 @@ import java.util.List;
public class EntityCountQuery { public class EntityCountQuery {
@Getter @Getter
protected EntityFilter entityFilter; private EntityFilter entityFilter;
@Getter @Getter
protected List<KeyFilter> keyFilters; protected List<KeyFilter> keyFilters;

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

@ -351,8 +351,7 @@ public class BaseAlarmService extends AbstractCachedEntityService<TenantId, Page
@Override @Override
public long countAlarmsByQuery(TenantId tenantId, CustomerId customerId, AlarmCountQuery query) { public long countAlarmsByQuery(TenantId tenantId, CustomerId customerId, AlarmCountQuery query) {
validateId(tenantId, id -> INCORRECT_TENANT_ID + id); return countAlarmsByQuery(tenantId, customerId, query, null);
return alarmDao.countAlarmsByQuery(tenantId, customerId, query, Collections.emptyList());
} }
@Override @Override

4
dao/src/main/java/org/thingsboard/server/dao/sql/query/DefaultAlarmQueryRepository.java

@ -327,7 +327,7 @@ public class DefaultAlarmQueryRepository implements AlarmQueryRepository {
ctx.append(" and a.customer_id = :customerId and ea.customer_id = :customerId"); ctx.append(" and a.customer_id = :customerId and ea.customer_id = :customerId");
ctx.addUuidParameter("customerId", customerId.getId()); ctx.addUuidParameter("customerId", customerId.getId());
} }
if (!orderedEntityIds.isEmpty()) { if (orderedEntityIds != null) {
ctx.addUuidListParameter("entity_filter_entity_ids", orderedEntityIds.stream().map(EntityId::getId).collect(Collectors.toList())); ctx.addUuidListParameter("entity_filter_entity_ids", orderedEntityIds.stream().map(EntityId::getId).collect(Collectors.toList()));
ctx.append(" and ea.entity_id in (:entity_filter_entity_ids)"); ctx.append(" and ea.entity_id in (:entity_filter_entity_ids)");
} }
@ -339,7 +339,7 @@ public class DefaultAlarmQueryRepository implements AlarmQueryRepository {
ctx.append(" and a.customer_id = :customerId"); ctx.append(" and a.customer_id = :customerId");
ctx.addUuidParameter("customerId", customerId.getId()); ctx.addUuidParameter("customerId", customerId.getId());
} }
if (!orderedEntityIds.isEmpty()) { if (orderedEntityIds != null) {
ctx.addUuidListParameter("entity_filter_entity_ids", orderedEntityIds.stream().map(EntityId::getId).collect(Collectors.toList())); ctx.addUuidListParameter("entity_filter_entity_ids", orderedEntityIds.stream().map(EntityId::getId).collect(Collectors.toList()));
ctx.append(" and a.originator_id in (:entity_filter_entity_ids)"); ctx.append(" and a.originator_id in (:entity_filter_entity_ids)");
} }

Loading…
Cancel
Save