dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Events clearing by filter

Browse Source
This commit is contained in:
Viacheslav Klimov 2021-11-08 14:19:44 +02:00
parent e718e31f63
commit 13a74c784e
5 changed files with 33 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
application/src/main/java/org/thingsboard/server/controller/EventController.java
View File

@ -242,15 +242,13 @@ public class EventController extends BaseController {
@ApiOperation(value = "Clear Events (clearEvents)", notes = "Clears events for specified entity.") @ApiOperation(value = "Clear Events (clearEvents)", notes = "Clears events for specified entity.")
@PreAuthorize("hasAnyAuthority('SYS_ADMIN', 'TENANT_ADMIN', 'CUSTOMER_USER')") @PreAuthorize("hasAnyAuthority('SYS_ADMIN', 'TENANT_ADMIN', 'CUSTOMER_USER')")
@RequestMapping(value = "/events/{entityType}/{entityId}/{eventType}/clear", method = RequestMethod.POST) @RequestMapping(value = "/events/{entityType}/{entityId}/clear", method = RequestMethod.POST)
@ResponseStatus(HttpStatus.OK) @ResponseStatus(HttpStatus.OK)
public void clearEvents( public void clearEvents(
@ApiParam(value = ENTITY_TYPE_PARAM_DESCRIPTION, required = true) @ApiParam(value = ENTITY_TYPE_PARAM_DESCRIPTION, required = true)
@PathVariable(ENTITY_TYPE) String strEntityType, @PathVariable(ENTITY_TYPE) String strEntityType,
@ApiParam(value = ENTITY_ID_PARAM_DESCRIPTION, required = true) @ApiParam(value = ENTITY_ID_PARAM_DESCRIPTION, required = true)
@PathVariable(ENTITY_ID) String strEntityId, @PathVariable(ENTITY_ID) String strEntityId,
@ApiParam(value = TENANT_ID_PARAM_DESCRIPTION, required = true)
@PathVariable("eventType") String eventType,
@ApiParam(value = EVENT_START_TIME_DESCRIPTION) @ApiParam(value = EVENT_START_TIME_DESCRIPTION)
@RequestParam("tenantId") String strTenantId, @RequestParam("tenantId") String strTenantId,
@ApiParam(value = "A string value representing event type", example = "STATS", required = true) @ApiParam(value = "A string value representing event type", example = "STATS", required = true)
@ -266,7 +264,7 @@ public class EventController extends BaseController {
EntityId entityId = EntityIdFactory.getByTypeAndId(strEntityType, strEntityId); EntityId entityId = EntityIdFactory.getByTypeAndId(strEntityType, strEntityId);
checkEntityId(entityId, Operation.DELETE); checkEntityId(entityId, Operation.DELETE);
eventService.removeEvents(tenantId, entityId, eventType, startTime, endTime); eventService.removeEvents(tenantId, entityId, eventFilter, startTime, endTime);
} catch (Exception e) { } catch (Exception e) {
throw handleException(e); throw handleException(e);
} }

2
common/dao-api/src/main/java/org/thingsboard/server/dao/event/EventService.java
View File

@ -46,7 +46,7 @@ public interface EventService {
void removeEvents(TenantId tenantId, EntityId entityId); void removeEvents(TenantId tenantId, EntityId entityId);
void removeEvents(TenantId tenantId, EntityId entityId, String eventType, Long startTime, Long endTime); void removeEvents(TenantId tenantId, EntityId entityId, EventFilter eventFilter, Long startTime, Long endTime);
void cleanupEvents(long ttl, long debugTtl); void cleanupEvents(long ttl, long debugTtl);

7
dao/src/main/java/org/thingsboard/server/dao/event/BaseEventService.java
View File

@ -34,7 +34,6 @@ import org.thingsboard.server.dao.service.DataValidator;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.UUID;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Service @Service
@ -125,14 +124,14 @@ public class BaseEventService implements EventService {
} }
@Override @Override
public void removeEvents(TenantId tenantId, EntityId entityId, String eventType, Long startTime, Long endTime) { public void removeEvents(TenantId tenantId, EntityId entityId, EventFilter eventFilter, Long startTime, Long endTime) {
TimePageLink eventsPageLink = new TimePageLink(1000, 0, null, null, startTime, endTime); TimePageLink eventsPageLink = new TimePageLink(1000, 0, null, null, startTime, endTime);
PageData<Event> eventsPageData; PageData<Event> eventsPageData;
do { do {
if (eventType == null) { if (eventFilter == null) {
eventsPageData = findEvents(tenantId, entityId, eventsPageLink); eventsPageData = findEvents(tenantId, entityId, eventsPageLink);
} else { } else {
eventsPageData = findEvents(tenantId, entityId, eventType, eventsPageLink); eventsPageData = findEventsByFilter(tenantId, entityId, eventFilter, eventsPageLink);
} }
eventDao.removeAllByIds(eventsPageData.getData().stream() eventDao.removeAllByIds(eventsPageData.getData().stream()

5
ui-ngx/src/app/core/http/event.service.ts
View File

@ -47,8 +47,9 @@ export class EventService {
public clearEvents(entityId: EntityId, eventType: EventType | DebugEventType, filters: FilterEventBody, tenantId: string, public clearEvents(entityId: EntityId, eventType: EventType | DebugEventType, filters: FilterEventBody, tenantId: string,
pageLink: TimePageLink, config?: RequestConfig) { pageLink: TimePageLink, config?: RequestConfig) {
return this.http.post(`/api/events/${entityId.entityType}/${entityId.id}/${eventType}/clear&tenantId=${tenantId}` + return this.http.post(`/api/events/${entityId.entityType}/${entityId.id}/clear?tenantId=${tenantId}` +
`${pageLink.toQuery()}`, {...filters, eventType}, (pageLink.startTime ? `&startTime=${pageLink.startTime}` : ``) +
(pageLink.endTime ? `&endTime=${pageLink.endTime}` : ``), {...filters, eventType},
defaultHttpOptionsFromConfig(config)); defaultHttpOptionsFromConfig(config));
} }
} }

7
ui-ngx/src/app/modules/home/components/event/event-table-config.ts
View File

@ -141,7 +141,12 @@ export class EventTableConfig extends EntityTableConfig<Event, TimePageLink> {
icon: 'delete', icon: 'delete',
isEnabled: () => true, isEnabled: () => true,
onAction: ($event, entity, pageLink: TimePageLink) => { onAction: ($event, entity, pageLink: TimePageLink) => {
this.eventService.clearEvents(entity.entityId, entity.eventType, entity.filterParams, entity.tenantId, pageLink).subscribe(); this.eventService.clearEvents(entity.entityId, entity.eventType, entity.filterParams, entity.tenantId, pageLink).subscribe(
() => {
this.table.paginator.pageIndex = 0;
this.table.updateData();
}
);
} }
}); });
} }