From 258a769f6790f832d1c67839d59be04a118767e5 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期日, 28 四月 2024 10:50:48 +0800
Subject: [PATCH] 用时分析代码整理+注释整理
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java | 12 +++++++-----
1 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java
index 7b1064e..f571767 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java
@@ -20,7 +20,6 @@
import org.springframework.stereotype.Service;
@Service
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/mdc/service/impl/SuperNewCollectServiceImpl.class */
public class SuperNewCollectServiceImpl implements ISuperNewCollectService {
private final SuperCollectJsonMapper collectJsonMapper;
private static final Logger log = LoggerFactory.getLogger(SuperNewCollectServiceImpl.class);
@@ -40,15 +39,15 @@
this.collectJsonMapper = collectJsonMapper;
}
- @Override // org.springblade.modules.mdc.service.ISuperNewCollectService
+ @Override
public void insertData(Set<String> workstationIds) {
- List<NewParamSaveDTO> data = (List) workstationIds.stream().map(workstationId -> {
+ List<NewParamSaveDTO> data = workstationIds.stream().map(workstationId -> {
Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId);
if (Func.isNotEmpty(realTimeData)) {
int size = realTimeData.size();
long time = DateUtil.now().getTime();
Map<String, String> valuesMap = new HashMap<>(size);
- realTimeData.forEach(n, telemetry -> {
+ realTimeData.forEach((n, telemetry) -> {
if (!n.toUpperCase().contains(CollectConstant.ALARM)) {
TelemetryDataResponseDTO dto = (TelemetryDataResponseDTO) telemetry;
String v = dto.getV();
@@ -66,8 +65,11 @@
return Func.notNull(v0);
}).collect(Collectors.toList());
List<List<NewParamSaveDTO>> groupList = CommonUtil.groupList(data, 10);
+
+ groupList.forEach(this.collectJsonMapper::insertValueJson);
+ /*
SuperCollectJsonMapper superCollectJsonMapper = this.collectJsonMapper;
superCollectJsonMapper.getClass();
- groupList.forEach(this::insertValueJson);
+ groupList.forEach(this::insertValueJson);*/
}
}
--
Gitblit v1.9.3