Commit 4673f8f44206722bac21ce1c7e9961dfca941d67

Authored by xp.Huang
1 parent 7955e3b8

fix: 修复[DEFECT-1194]事件查询

@@ -15,7 +15,6 @@ import org.thingsboard.server.common.data.yunteng.dto.TkEventKvDto; @@ -15,7 +15,6 @@ import org.thingsboard.server.common.data.yunteng.dto.TkEventKvDto;
15 import org.thingsboard.server.common.data.yunteng.enums.DeviceEventTypeEnum; 15 import org.thingsboard.server.common.data.yunteng.enums.DeviceEventTypeEnum;
16 import org.thingsboard.server.common.data.yunteng.enums.OrderTypeEnum; 16 import org.thingsboard.server.common.data.yunteng.enums.OrderTypeEnum;
17 import org.thingsboard.server.controller.BaseController; 17 import org.thingsboard.server.controller.BaseController;
18 -import org.thingsboard.server.dao.model.ModelConstants;  
19 import org.thingsboard.server.dao.yunteng.event.TkEventsService; 18 import org.thingsboard.server.dao.yunteng.event.TkEventsService;
20 19
21 import java.util.UUID; 20 import java.util.UUID;
@@ -30,29 +29,37 @@ import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant. @@ -30,29 +29,37 @@ import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.
30 @Api(tags = {"设备事件"}) 29 @Api(tags = {"设备事件"})
31 @RequiredArgsConstructor 30 @RequiredArgsConstructor
32 public class TkEventController extends BaseController { 31 public class TkEventController extends BaseController {
33 - private final TkEventsService eventsService; 32 + private final TkEventsService eventsService;
34 33
35 - @GetMapping(params = {PAGE_SIZE, PAGE})  
36 - @ApiOperation("分页")  
37 - public PageData<TkEventKvDto> pageAlarmProfile(  
38 - @RequestParam(PAGE_SIZE) int pageSize,  
39 - @RequestParam(PAGE) int page,  
40 - @RequestParam(value = "eventIdentifier", required = false) String eventIdentifier,  
41 - @RequestParam(value = "eventType", required = false) DeviceEventTypeEnum eventType,  
42 - @RequestParam(value = "tbDeviceId", required = true) String tbDeviceId,  
43 - @RequestParam(required = false) Long startTime,  
44 - @RequestParam(required = false) Long endTime,  
45 - @RequestParam(value = ORDER_FILED, required = false) String orderBy,  
46 - @RequestParam(value = ORDER_TYPE, required = false) OrderTypeEnum orderType)  
47 - throws ThingsboardException {  
48 - checkParameter("tbDeviceId", tbDeviceId); 34 + @GetMapping(params = {PAGE_SIZE, PAGE})
  35 + @ApiOperation("分页")
  36 + public PageData<TkEventKvDto> pageAlarmProfile(
  37 + @RequestParam(PAGE_SIZE) int pageSize,
  38 + @RequestParam(PAGE) int page,
  39 + @RequestParam(value = "eventIdentifier", required = false) String eventIdentifier,
  40 + @RequestParam(value = "eventType", required = false) DeviceEventTypeEnum eventType,
  41 + @RequestParam(value = "tbDeviceId") String tbDeviceId,
  42 + @RequestParam(required = false) Long startTime,
  43 + @RequestParam(required = false) Long endTime,
  44 + @RequestParam(value = ORDER_FILED, required = false) String orderBy,
  45 + @RequestParam(value = ORDER_TYPE, required = false) OrderTypeEnum orderType)
  46 + throws ThingsboardException {
  47 + checkParameter("tbDeviceId", tbDeviceId);
49 48
50 - if (orderBy == null || orderBy.isEmpty()) {  
51 - orderBy = ModelConstants.EVENT_TIME_COLUMN;  
52 - }  
53 - TimePageLink pageLink = createTimePageLink(pageSize, page, null, orderBy, orderType==null?"":orderType.name(), startTime, endTime);  
54 - return checkNotNull(eventsService.findEvents(new DeviceId(UUID.fromString(tbDeviceId)),eventIdentifier,eventType, pageLink)); 49 + if (orderBy == null || orderBy.isEmpty()) {
  50 + orderBy = "id.eventTime";
55 } 51 }
56 -  
57 - 52 + TimePageLink pageLink =
  53 + createTimePageLink(
  54 + pageSize,
  55 + page,
  56 + null,
  57 + orderBy,
  58 + orderType != null ? orderType.name():OrderTypeEnum.DESC.name(),
  59 + startTime,
  60 + endTime);
  61 + return checkNotNull(
  62 + eventsService.findEvents(
  63 + new DeviceId(UUID.fromString(tbDeviceId)), eventIdentifier, eventType, pageLink));
  64 + }
58 } 65 }