Browse Source
Merge pull request #5922 from volodymyr-babak/code-review
[3.3.3] Code review minor misc fixes
pull/5938/head
Andrew Shvayka
5 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
7 changed files with
26 additions and
3 deletions
-
application/src/main/java/org/thingsboard/server/service/ttl/EdgeEventsCleanUpService.java
-
common/data/src/main/java/org/thingsboard/server/common/data/id/EdgeId.java
-
common/data/src/main/java/org/thingsboard/server/common/data/query/AlarmDataPageLink.java
-
common/data/src/main/java/org/thingsboard/server/common/data/query/AssetSearchQueryFilter.java
-
common/data/src/main/java/org/thingsboard/server/common/data/query/DeviceSearchQueryFilter.java
-
common/data/src/main/java/org/thingsboard/server/common/data/query/EdgeSearchQueryFilter.java
-
common/data/src/main/java/org/thingsboard/server/common/data/query/EntityViewSearchQueryFilter.java
|
|
|
@ -28,6 +28,9 @@ import org.thingsboard.server.queue.util.TbCoreComponent; |
|
|
|
@Service |
|
|
|
public class EdgeEventsCleanUpService extends AbstractCleanUpService { |
|
|
|
|
|
|
|
public static final String RANDOM_DELAY_INTERVAL_MS_EXPRESSION = |
|
|
|
"#{T(org.apache.commons.lang3.RandomUtils).nextLong(0, ${sql.ttl.edge_events.execution_interval_ms})}"; |
|
|
|
|
|
|
|
@Value("${sql.ttl.edge_events.edge_events_ttl}") |
|
|
|
private long ttl; |
|
|
|
|
|
|
|
@ -41,7 +44,7 @@ public class EdgeEventsCleanUpService extends AbstractCleanUpService { |
|
|
|
this.edgeEventService = edgeEventService; |
|
|
|
} |
|
|
|
|
|
|
|
@Scheduled(initialDelayString = "${sql.ttl.edge_events.execution_interval_ms}", fixedDelayString = "${sql.ttl.edge_events.execution_interval_ms}") |
|
|
|
@Scheduled(initialDelayString = RANDOM_DELAY_INTERVAL_MS_EXPRESSION, fixedDelayString = "${sql.ttl.edge_events.execution_interval_ms}") |
|
|
|
public void cleanUp() { |
|
|
|
if (ttlTaskExecutionEnabled && isSystemTenantPartitionMine()) { |
|
|
|
edgeEventService.cleanupEvents(ttl); |
|
|
|
|
|
|
|
@ -32,8 +32,8 @@ public class EdgeId extends UUIDBased implements EntityId { |
|
|
|
super(id); |
|
|
|
} |
|
|
|
|
|
|
|
public static EdgeId fromString(String integrationId) { |
|
|
|
return new EdgeId(UUID.fromString(integrationId)); |
|
|
|
public static EdgeId fromString(String edgeId) { |
|
|
|
return new EdgeId(UUID.fromString(edgeId)); |
|
|
|
} |
|
|
|
|
|
|
|
@ApiModelProperty(position = 2, required = true, value = "string", example = "EDGE", allowableValues = "EDGE") |
|
|
|
|
|
|
|
@ -18,7 +18,9 @@ package org.thingsboard.server.common.data.query; |
|
|
|
import com.fasterxml.jackson.annotation.JsonIgnore; |
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
import lombok.Data; |
|
|
|
import lombok.EqualsAndHashCode; |
|
|
|
import lombok.Getter; |
|
|
|
import lombok.ToString; |
|
|
|
import org.thingsboard.server.common.data.alarm.AlarmSearchStatus; |
|
|
|
import org.thingsboard.server.common.data.alarm.AlarmSeverity; |
|
|
|
import org.thingsboard.server.common.data.alarm.AlarmStatus; |
|
|
|
@ -26,6 +28,8 @@ import org.thingsboard.server.common.data.alarm.AlarmStatus; |
|
|
|
import java.util.List; |
|
|
|
|
|
|
|
@Data |
|
|
|
@EqualsAndHashCode(callSuper = true) |
|
|
|
@ToString(callSuper = true) |
|
|
|
@AllArgsConstructor |
|
|
|
public class AlarmDataPageLink extends EntityDataPageLink { |
|
|
|
|
|
|
|
|
|
|
|
@ -16,10 +16,14 @@ |
|
|
|
package org.thingsboard.server.common.data.query; |
|
|
|
|
|
|
|
import lombok.Data; |
|
|
|
import lombok.EqualsAndHashCode; |
|
|
|
import lombok.ToString; |
|
|
|
|
|
|
|
import java.util.List; |
|
|
|
|
|
|
|
@Data |
|
|
|
@EqualsAndHashCode(callSuper = true) |
|
|
|
@ToString(callSuper = true) |
|
|
|
public class AssetSearchQueryFilter extends EntitySearchQueryFilter { |
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
|
|
@ -16,10 +16,14 @@ |
|
|
|
package org.thingsboard.server.common.data.query; |
|
|
|
|
|
|
|
import lombok.Data; |
|
|
|
import lombok.EqualsAndHashCode; |
|
|
|
import lombok.ToString; |
|
|
|
|
|
|
|
import java.util.List; |
|
|
|
|
|
|
|
@Data |
|
|
|
@EqualsAndHashCode(callSuper = true) |
|
|
|
@ToString(callSuper = true) |
|
|
|
public class DeviceSearchQueryFilter extends EntitySearchQueryFilter { |
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
|
|
@ -16,10 +16,14 @@ |
|
|
|
package org.thingsboard.server.common.data.query; |
|
|
|
|
|
|
|
import lombok.Data; |
|
|
|
import lombok.EqualsAndHashCode; |
|
|
|
import lombok.ToString; |
|
|
|
|
|
|
|
import java.util.List; |
|
|
|
|
|
|
|
@Data |
|
|
|
@EqualsAndHashCode(callSuper = true) |
|
|
|
@ToString(callSuper = true) |
|
|
|
public class EdgeSearchQueryFilter extends EntitySearchQueryFilter { |
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
|
|
@ -16,10 +16,14 @@ |
|
|
|
package org.thingsboard.server.common.data.query; |
|
|
|
|
|
|
|
import lombok.Data; |
|
|
|
import lombok.EqualsAndHashCode; |
|
|
|
import lombok.ToString; |
|
|
|
|
|
|
|
import java.util.List; |
|
|
|
|
|
|
|
@Data |
|
|
|
@EqualsAndHashCode(callSuper = true) |
|
|
|
@ToString(callSuper = true) |
|
|
|
public class EntityViewSearchQueryFilter extends EntitySearchQueryFilter { |
|
|
|
|
|
|
|
@Override |
|
|
|
|