diff --git a/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java b/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java index 6647fc7d..8cbd2907 100644 --- a/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java +++ b/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 devDataList,Integer index,PreDetectionParam param){ + Runnable runnable = new Runnable() { + @Override + public void run() { + DateTimeFormatter formatter = DateTimeFormatter.ISO_DATE_TIME; // ISO 8601格式 + + List 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 { } } + }