Commit 3415e6ca by HlQ

[add] 查询项目绑定的指标列表优化查询速度

1 parent a522eaa1
...@@ -18,6 +18,9 @@ import vion.service.monitor.IEventRecordService; ...@@ -18,6 +18,9 @@ import vion.service.monitor.IEventRecordService;
import vion.service.monitor.IEventService; import vion.service.monitor.IEventService;
import vion.vo.monitor.EventVO; import vion.vo.monitor.EventVO;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
...@@ -54,6 +57,7 @@ public class EventServiceImpl extends MPJBaseServiceImpl<EventMapper, Event> imp ...@@ -54,6 +57,7 @@ public class EventServiceImpl extends MPJBaseServiceImpl<EventMapper, Event> imp
var eventRecWrapper = Wrappers.<EventRecord>query() var eventRecWrapper = Wrappers.<EventRecord>query()
.select("DISTINCT on (mall_uid,event_type) *") .select("DISTINCT on (mall_uid,event_type) *")
.eq("mall_uid", dto.getMallUid()) .eq("mall_uid", dto.getMallUid())
.ge("create_time", LocalDateTime.of(LocalDate.now(), LocalTime.MIN))
.orderByDesc("mall_uid", "event_type", "create_time"); .orderByDesc("mall_uid", "event_type", "create_time");
var eventRecordList = eventRecordService.list(eventRecWrapper); var eventRecordList = eventRecordService.list(eventRecWrapper);
var eventUid2SelfMap = eventRecordList.stream().collect(Collectors.toMap(EventRecord::getEventUid, Function.identity())); var eventUid2SelfMap = eventRecordList.stream().collect(Collectors.toMap(EventRecord::getEventUid, Function.identity()));
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!