代码调整

detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java

@@ -732,7 +732,42 @@ public class SocketDevResponseService {
     }
 
 
-    private LocalDateTime timeFormat(String dateTimeStr, DateTimeFormatter formatter) {
+
+    /**
+     * 原始数据入库
+     * @author cdf
+     * @date 2024/12/29
+     */
+    private void baseDataInsert(List<DevData> devDataList,Integer index,PreDetectionParam param){
+        Runnable runnable = new Runnable() {
+            @Override
+            public void run() {
+                DateTimeFormatter formatter = DateTimeFormatter.ISO_DATE_TIME; // ISO 8601格式
+
+                List<AdNonHarmonicResult> adHarmonicResultList = new ArrayList<>();
+                for(DevData data : devDataList){
+                    AdNonHarmonicResult adNonHarmonicResult = new AdNonHarmonicResult();
+
+                    LocalDateTime localDateTime = timeFormat(data.getTime(),formatter);
+                    if(Objects.nonNull(localDateTime)){
+                        adNonHarmonicResult.setTimeId(localDateTime);
+                        adNonHarmonicResult.setMonitorId(data.getId());
+                        adNonHarmonicResult.setScriptId(param.getScriptId());
+                        adNonHarmonicResult.setIndex(index);
+                        adNonHarmonicResult.setAValue(data.getSqlData().get(0).getList().getA().toString());
+                        adNonHarmonicResult.setBValue(data.getSqlData().get(0).getList().getB().toString());
+                        adNonHarmonicResult.setCValue(data.getSqlData().get(0).getList().getC().toString());
+                        adHarmonicResultList.add(adNonHarmonicResult);
+                    }
+                }
+                //detectionDataDealService.acceptAdNon(adHarmonicResultList,"1");
+            }
+        };
+        runnable.run();
+    }
+
+
+    private LocalDateTime timeFormat(String dateTimeStr, DateTimeFormatter formatter){
         //DateTimeFormatter formatter = DateTimeFormatter.ISO_DATE_TIME; // ISO 8601格式
         try {
             // 假设输入是UTC时间，将其解析为ZonedDateTime
@@ -748,4 +783,5 @@ public class SocketDevResponseService {
         }
     }
 
+
 }