From 2fcc1a1b8f09a731af53247d0b5e88397649fb44 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期五, 10 一月 2025 17:50:44 +0800
Subject: [PATCH] 数据采集bug

---
 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