From dcd848984abc983a1288af2e514b424e66d8bef5 Mon Sep 17 00:00:00 2001 From: chendaofei <857448963@qq.com> Date: Mon, 30 Dec 2024 16:38:24 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/SocketDevResponseService.java | 38 ++++++++++++++++++- 1 file changed, 37 insertions(+), 1 deletion(-) 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 { } } + }