diff --git a/detection/src/main/java/com/njcn/gather/detection/handler/SocketContrastResponseService.java b/detection/src/main/java/com/njcn/gather/detection/handler/SocketContrastResponseService.java index f7617d27..db26f563 100644 --- a/detection/src/main/java/com/njcn/gather/detection/handler/SocketContrastResponseService.java +++ b/detection/src/main/java/com/njcn/gather/detection/handler/SocketContrastResponseService.java @@ -1953,6 +1953,17 @@ public class SocketContrastResponseService { boolean isStar = DetectionCodeEnum.STAR.getCode().equals(monitorListDTO.getConnection()); boolean isDelta = DetectionCodeEnum.DELTA.getCode().equals(monitorListDTO.getConnection()); + PreDetection preDetection = FormalTestManager.devList.stream().filter(obj -> obj.getDevIP().equals(split[0])).findFirst().orElse(null); + if (ObjectUtil.isNotNull(preDetection)) { + if (preDetection.getUsePhaseIndex() == 1) { + isStar = true; + isDelta = false; + } else { + isStar = false; + isDelta = true; + } + } + List dataList = new ArrayList<>(); for (int i = 0; i < channelDevDataList.size(); i++) { DevData.SqlDataDTO.ListDTO list1 = null; @@ -2032,6 +2043,7 @@ public class SocketContrastResponseService { channelDataMap.forEach((channel, channelDevDataList) -> { String standardDevMonitorId = ip + CnSocketUtil.SPLIT_TAG + channel; String devMonitorId = FormalTestManager.pairsIpMap.inverse().get(standardDevMonitorId); + String[] split = devMonitorId.split(CnSocketUtil.SPLIT_TAG); PreDetection.MonitorListDTO monitorListDTO = FormalTestManager.monitorMap.get(devMonitorId); List devDataList = BeanUtil.copyToList(FormalTestManager.devDataMap.get(devMonitorId), DevData.class); channelDevDataList.sort(Comparator.comparing(obj -> DetectionUtil.getMillis(obj.getTime()))); @@ -2042,9 +2054,21 @@ public class SocketContrastResponseService { exportParams.setSheetName(standardDevName + "通道" + channel); sheet.put("title", exportParams); - List dataList = new ArrayList<>(); boolean isStar = DetectionCodeEnum.STAR.getCode().equals(monitorListDTO.getConnection()); boolean isDelta = DetectionCodeEnum.DELTA.getCode().equals(monitorListDTO.getConnection()); + + PreDetection preDetection = FormalTestManager.devList.stream().filter(obj -> obj.getDevIP().equals(split[0])).findFirst().orElse(null); + if (ObjectUtil.isNotNull(preDetection)) { + if (preDetection.getUsePhaseIndex() == 1) { + isStar = true; + isDelta = false; + } else { + isStar = false; + isDelta = true; + } + } + + List dataList = new ArrayList<>(); for (int i = 0; i < channelDevDataList.size(); i++) { DevData.SqlDataDTO.ListDTO list1 = null; DevData.SqlDataDTO sqlDataDTO1 = null; @@ -2252,6 +2276,19 @@ public class SocketContrastResponseService { boolean isStar = DetectionCodeEnum.STAR.getCode().equals(monitorListDTO.getConnection()); boolean isDelta = DetectionCodeEnum.DELTA.getCode().equals(monitorListDTO.getConnection()); + String[] split = devMonitorId.split(CnSocketUtil.SPLIT_TAG); + PreDetection preDetection = FormalTestManager.devList.stream().filter(obj -> obj.getDevIP().equals(split[0])).findFirst().orElse(null); + + if (ObjectUtil.isNotNull(preDetection)) { + if (preDetection.getUsePhaseIndex() == 1) { + isStar = true; + isDelta = false; + } else { + isStar = false; + isDelta = true; + } + } + // 电压校验 List uDev = null; List uStd = null; @@ -2374,7 +2411,6 @@ public class SocketContrastResponseService { } boolean isPhaseAngle = false; - PreDetection preDetection = FormalTestManager.devList.stream().filter(dev -> dev.getDevId().equals(devMonitorId.split(CnSocketUtil.SPLIT_TAG)[0])).findFirst().orElse(null); if (ObjectUtil.isNotNull(preDetection)) { isPhaseAngle = preDetection.getAngle() == 1 ? true : false; } diff --git a/detection/src/main/java/com/njcn/gather/monitor/service/impl/PqMonitorServiceImpl.java b/detection/src/main/java/com/njcn/gather/monitor/service/impl/PqMonitorServiceImpl.java index b879c0fa..dd1cd491 100644 --- a/detection/src/main/java/com/njcn/gather/monitor/service/impl/PqMonitorServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/monitor/service/impl/PqMonitorServiceImpl.java @@ -163,10 +163,19 @@ public class PqMonitorServiceImpl extends ServiceImpl { Map> timeListMap = value.stream().collect(Collectors.groupingBy(ContrastHarmonicResult::getTimeId, Collectors.toList())); + String[] split1 = devMonitorId.split(CnSocketUtil.SPLIT_TAG); timeListMap.forEach((time, value1) -> { - DevData devData = info.stream().filter(x -> x.getTime().equals(time.format(DateTimeFormatter.ofPattern(DatePattern.ISO8601_PATTERN)))).findFirst().orElse(null); +// DevData devData = info.stream().filter(x -> x.getTime().equals(time.format(DateTimeFormatter.ofPattern(DatePattern.ISO8601_PATTERN)))).findFirst().orElse(null); + DevData devData = null; + for (int i = 0; i < info.size(); i++) { + DevData devData1 = info.get(i); + if (time.format(DateTimeFormatter.ofPattern(DatePattern.ISO8601_PATTERN)).equals(devData1.getTime()) && devData1.getId().split(CnSocketUtil.SPLIT_TAG)[1].equals(split1[1])) { + devData = devData1; + break; + } + } if (ObjectUtil.isNotNull(devData)) { String[] split = devMonitorId.split(CnSocketUtil.SPLIT_TAG); if (flag == 0) {