From 213afc8ee0fea62ce448db3539e0eb5ed2031982 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期五, 17 一月 2025 16:12:54 +0800
Subject: [PATCH] 导入通过PointNo判断是否重复
---
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointCollectStatusServiceImpl.java | 26 +-------------------------
1 files changed, 1 insertions(+), 25 deletions(-)
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointCollectStatusServiceImpl.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointCollectStatusServiceImpl.java
index c426c92..a21f21b 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointCollectStatusServiceImpl.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointCollectStatusServiceImpl.java
@@ -57,31 +57,7 @@
}
@Override
- public void recordStatusList(List<InfluxPointValuePOJO> pointValues, Date collectTime) {
- List<String> listGood = new ArrayList<>();
- List<String> listBad = new ArrayList<>();
- Object collectValue = null;
- for (InfluxPointValuePOJO pointValue : pointValues) {
- if (pointValue instanceof InfluxPointValueSimPOJO) {
- InfluxPointValueSimPOJO pvo = (InfluxPointValueSimPOJO) pointValue;
- collectValue = pvo.getValue();
- } else if (pointValue instanceof InfluxPointValueDigPOJO) {
- InfluxPointValueDigPOJO pvo = (InfluxPointValueDigPOJO) pointValue;
- collectValue = pvo.getValue();
- } else {
- continue;
- }
- switch (DataQualityEnum.getEumByValue(collectValue)) {
- case GOOD:
- listGood.add(pointValue.getPoint());
- break;
- case BAD:
- listBad.add(pointValue.getPoint());
- break;
- default:
- break;
- }
- }
+ public void recordStatusList(List<String> listGood,List<String> listBad, Date collectTime) {
if (!CollectionUtils.isEmpty(listGood)) {
QueryWrapper<DaPointCollectStatusEntity> queryWrapper = new QueryWrapper<>();
queryWrapper.in("point_no", listGood);
--
Gitblit v1.9.3