alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-06 21:37:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] records

Browse Source
This commit is contained in:
wujiawei 2024-11-13 21:12:28 +08:00
parent 20bb29350c
commit 5a079fcba8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortFlowApplicationImpl.java
View File

@ -256,7 +256,7 @@ public class LazyVisitorPortFlowApplicationImpl implements LazyVisitorPortFlowAp
lazyVisitorPortFlow.setServerId(serverId); lazyVisitorPortFlow.setServerId(serverId);
return lazyVisitorPortFlowRepository.findPageGroupByClientId(size, current, lazyVisitorPortFlow).convert(visitorPortFlowLazyPage -> { return lazyVisitorPortFlowRepository.findPageGroupByClientId(size, current, lazyVisitorPortFlow).convert(visitorPortFlowLazyPage -> {
List<String> clientIdList = visitorPortFlowLazyPage List<String> clientIdList = visitorPortFlowLazyPage
.getRecord() .getRecords()
.stream() .stream()
.map(LazyVisitorPortFlow::getClientId) .map(LazyVisitorPortFlow::getClientId)
.toList(); .toList();
@ -268,7 +268,7 @@ public class LazyVisitorPortFlowApplicationImpl implements LazyVisitorPortFlowAp
List<LazyVisitorPortFlowDTO> lazyVisitorPortFlowDTOList = lazyVisitorPortFlowList.stream().map(VisitorPortFlowDTOAssembler.INSTANCE::fromVisitorFlow).toList(); List<LazyVisitorPortFlowDTO> lazyVisitorPortFlowDTOList = lazyVisitorPortFlowList.stream().map(VisitorPortFlowDTOAssembler.INSTANCE::fromVisitorFlow).toList();
Map<String/*客户端ID*/, List<LazyVisitorPortFlowDTO>> client_port_flow_map = lazyVisitorPortFlowDTOList.stream().collect(Collectors.groupingBy(visitorPortFlowDTO -> visitorPortFlowDTO.getClientId())); Map<String/*客户端ID*/, List<LazyVisitorPortFlowDTO>> client_port_flow_map = lazyVisitorPortFlowDTOList.stream().collect(Collectors.groupingBy(LazyVisitorPortFlowDTO::getClientId));
Map<String/*客户端ID*/, Integer/*客户端进口流量*/> client_in_flow = lazyVisitorPortFlowDTOList.stream() Map<String/*客户端ID*/, Integer/*客户端进口流量*/> client_in_flow = lazyVisitorPortFlowDTOList.stream()
.collect( .collect(