diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/NormalLimitServiceImpl.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/NormalLimitServiceImpl.java index fcaf518d4..17ee9b8b9 100644 --- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/NormalLimitServiceImpl.java +++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/NormalLimitServiceImpl.java @@ -19,6 +19,9 @@ import com.njcn.prepare.harmonic.pojo.mysql.po.line.MpSurplusAbnormalD; import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.vo.AbnormalVO; import com.njcn.prepare.harmonic.service.mysql.line.NormalLimitService; +import com.njcn.user.api.DeptFeignClient; +import com.njcn.user.api.UserFeignClient; +import com.njcn.user.pojo.po.Dept; import lombok.AllArgsConstructor; import org.influxdb.dto.QueryResult; import org.springframework.scheduling.annotation.Async; @@ -46,1143 +49,11 @@ public class NormalLimitServiceImpl extends ServiceImpl lineIds = new ArrayList<>(); - - DateTime start = DateUtil.beginOfDay(DateUtil.parse(lineParam.getDataDate())); - DateTime end = DateUtil.endOfDay(DateUtil.parse(lineParam.getDataDate())); - - if (CollectionUtils.isEmpty(lineParam.getLineIds())) { - DeviceInfoParam deviceInfoParam = new DeviceInfoParam(); - deviceInfoParam.setDeptIndex("5699e5916a18a6381e1ac92da5bd2628"); - deviceInfoParam.setPowerFlag(2); - deviceInfoParam.setMonitorFlag(2); - deviceInfoParam.setServerName(ServerEnum.HARMONIC.getName()); - SimpleDTO simpleDTO = new SimpleDTO(); - simpleDTO.setName("电网拓扑"); - simpleDTO.setSort(0); - simpleDTO.setCode("Power_Network"); - deviceInfoParam.setStatisticalType(simpleDTO); - //处理监测点 - List deviceDataList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData(); - for (GeneralDeviceDTO generalDeviceDTO : deviceDataList) { - lineIds.addAll(generalDeviceDTO.getLineIndexes()); - } - if (!lineIds.isEmpty()) { - for (String lineIndex : lineIds) { - //获取当前监测点的限值详情 - Overlimit overlimit = lineFeignClient.getOverLimitData(lineIndex).getData(); - for (int i = 1; i < 5; i++) { - for (int j = 1; j < 5; j++) { - //电压上偏差 - List voDev = getConntion(i, j, start, end, lineIndex, 1); - //电压下偏差 - List uoDev = getConntion(i, j, start, end, lineIndex, 2); - //三相电压不平衡度 - List uba = getConntion(i, j, start, end, lineIndex, 3); - //电压总畸变率 - List uab = getConntion(i, j, start, end, lineIndex, 4); - //负序电流 - List ing = getConntion(i, j, start, end, lineIndex, 5); - //频率 - List freq = getConntion(i, j, start, end, lineIndex, 6); - //2-25次谐波含有率 - //谐波电压含有率 - List uharm2 = getConntion(i, j, start, end, lineIndex, 7); - List uharm3 = getConntion(i, j, start, end, lineIndex, 8); - List uharm4 = getConntion(i, j, start, end, lineIndex, 9); - List uharm5 = getConntion(i, j, start, end, lineIndex, 10); - List uharm6 = getConntion(i, j, start, end, lineIndex, 11); - List uharm7 = getConntion(i, j, start, end, lineIndex, 12); - List uharm8 = getConntion(i, j, start, end, lineIndex, 13); - List uharm9 = getConntion(i, j, start, end, lineIndex, 14); - List uharm10 = getConntion(i, j, start, end, lineIndex, 15); - List uharm11 = getConntion(i, j, start, end, lineIndex, 16); - List uharm12 = getConntion(i, j, start, end, lineIndex, 17); - List uharm13 = getConntion(i, j, start, end, lineIndex, 18); - List uharm14 = getConntion(i, j, start, end, lineIndex, 19); - List uharm15 = getConntion(i, j, start, end, lineIndex, 20); - List uharm16 = getConntion(i, j, start, end, lineIndex, 21); - List uharm17 = getConntion(i, j, start, end, lineIndex, 22); - List uharm18 = getConntion(i, j, start, end, lineIndex, 23); - List uharm19 = getConntion(i, j, start, end, lineIndex, 24); - List uharm20 = getConntion(i, j, start, end, lineIndex, 25); - List uharm21 = getConntion(i, j, start, end, lineIndex, 26); - List uharm22 = getConntion(i, j, start, end, lineIndex, 27); - List uharm23 = getConntion(i, j, start, end, lineIndex, 28); - List uharm24 = getConntion(i, j, start, end, lineIndex, 29); - List uharm25 = getConntion(i, j, start, end, lineIndex, 30); + private final DeptFeignClient deptFeignClient; - //2-25次谐波电流幅值 - List iharm2 = getConntion(i, j, start, end, lineIndex, 31); - List iharm3 = getConntion(i, j, start, end, lineIndex, 32); - List iharm4 = getConntion(i, j, start, end, lineIndex, 33); - List iharm5 = getConntion(i, j, start, end, lineIndex, 34); - List iharm6 = getConntion(i, j, start, end, lineIndex, 35); - List iharm7 = getConntion(i, j, start, end, lineIndex, 36); - List iharm8 = getConntion(i, j, start, end, lineIndex, 37); - List iharm9 = getConntion(i, j, start, end, lineIndex, 38); - List iharm10 = getConntion(i, j, start, end, lineIndex, 39); - List iharm11 = getConntion(i, j, start, end, lineIndex, 40); - List iharm12 = getConntion(i, j, start, end, lineIndex, 41); - List iharm13 = getConntion(i, j, start, end, lineIndex, 42); - List iharm14 = getConntion(i, j, start, end, lineIndex, 43); - List iharm15 = getConntion(i, j, start, end, lineIndex, 44); - List iharm16 = getConntion(i, j, start, end, lineIndex, 45); - List iharm17 = getConntion(i, j, start, end, lineIndex, 46); - List iharm18 = getConntion(i, j, start, end, lineIndex, 47); - List iharm19 = getConntion(i, j, start, end, lineIndex, 48); - List iharm20 = getConntion(i, j, start, end, lineIndex, 49); - List iharm21 = getConntion(i, j, start, end, lineIndex, 50); - List iharm22 = getConntion(i, j, start, end, lineIndex, 51); - List iharm23 = getConntion(i, j, start, end, lineIndex, 52); - List iharm24 = getConntion(i, j, start, end, lineIndex, 53); - List iharm25 = getConntion(i, j, start, end, lineIndex, 54); - //0.5-15.5次间谐波电压含有率 - List inharm = getConntion(i, j, start, end, lineIndex, 55); - List inharm1 = getConntion(i, j, start, end, lineIndex, 56); - List inharm2 = getConntion(i, j, start, end, lineIndex, 57); - List inharm3 = getConntion(i, j, start, end, lineIndex, 58); - List inharm4 = getConntion(i, j, start, end, lineIndex, 59); - List inharm5 = getConntion(i, j, start, end, lineIndex, 60); - List inharm6 = getConntion(i, j, start, end, lineIndex, 61); - List inharm7 = getConntion(i, j, start, end, lineIndex, 62); - List inharm8 = getConntion(i, j, start, end, lineIndex, 63); - List inharm9 = getConntion(i, j, start, end, lineIndex, 64); - List inharm10 = getConntion(i, j, start, end, lineIndex, 65); - List inharm11 = getConntion(i, j, start, end, lineIndex, 66); - List inharm12 = getConntion(i, j, start, end, lineIndex, 67); - List inharm13 = getConntion(i, j, start, end, lineIndex, 68); - List inharm14 = getConntion(i, j, start, end, lineIndex, 69); - List inharm15 = getConntion(i, j, start, end, lineIndex, 70); - //长时闪变 - List flicker = getConntion(i, j, start, end, lineIndex, 71); - //只需要判断一个指标即可 - if (voDev.size() > 0 && uoDev.size() > 0 && uba.size() > 0 && uab.size() > 0 && ing.size() > 0 && freq.size() > 0 && uharm2.size() > 0 && uharm3.size() > 0 && uharm4.size() > 0 - && uharm5.size() > 0 && uharm6.size() > 0 && uharm7.size() > 0 && uharm8.size() > 0 && uharm9.size() > 0 && uharm10.size() > 0 && uharm11.size() > 0 && uharm12.size() > 0 && uharm13.size() > 0 && uharm14.size() > 0 - && uharm15.size() > 0 && uharm16.size() > 0 && uharm17.size() > 0 && uharm18.size() > 0 && uharm19.size() > 0 && uharm20.size() > 0 && uharm21.size() > 0 && uharm22.size() > 0 && uharm23.size() > 0 && uharm24.size() > 0 - && uharm25.size() > 0 && iharm2.size() > 0 && iharm3.size() > 0 && iharm4.size() > 0 - && iharm5.size() > 0 && iharm6.size() > 0 && iharm7.size() > 0 && iharm8.size() > 0 && iharm9.size() > 0 && iharm10.size() > 0 && iharm11.size() > 0 && iharm12.size() > 0 && iharm13.size() > 0 && iharm14.size() > 0 - && iharm15.size() > 0 && iharm16.size() > 0 && iharm17.size() > 0 && iharm18.size() > 0 && iharm19.size() > 0 && iharm20.size() > 0 && iharm21.size() > 0 && iharm22.size() > 0 && iharm23.size() > 0 && iharm24.size() > 0 - && iharm25.size() > 0 && inharm.size() > 0 && inharm1.size() > 0 && inharm2.size() > 0 - && inharm3.size() > 0 && inharm4.size() > 0 && inharm5.size() > 0 && inharm6.size() > 0 && inharm7.size() > 0 && inharm8.size() > 0 && inharm9.size() > 0 && inharm10.size() > 0 && inharm11.size() > 0 && inharm12.size() > 0 - && inharm13.size() > 0 && inharm14.size() > 0 && inharm15.size() > 0) { - MpSurplusAbnormalD abnormalPO = new MpSurplusAbnormalD(); - abnormalPO.setTimeId(LocalDateTimeUtil.of(start)); - abnormalPO.setId(lineIndex); - if (i == 1) { - abnormalPO.setPhasicType("A"); - } else if (i == 2) { - abnormalPO.setPhasicType("B"); - } else if (i == 3) { - abnormalPO.setPhasicType("C"); - } else { - abnormalPO.setPhasicType("T"); - } - if (j == 1) { - abnormalPO.setFreq(freq.get(0).getNormValue()); - abnormalPO.setValueType("AVG"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue()); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue()); - abnormalPO.setFlicker(flicker.get(0).getNormValue()); - abnormalPO.setUaberrance(uab.get(0).getNormValue()); - abnormalPO.setUbalance(uba.get(0).getNormValue()); - abnormalPO.setINeg(ing.get(0).getNormValue()); - abnormalPO.setUharm2(uharm2.get(0).getNormValue()); - abnormalPO.setUharm3(uharm3.get(0).getNormValue()); - abnormalPO.setUharm4(uharm4.get(0).getNormValue()); - abnormalPO.setUharm5(uharm5.get(0).getNormValue()); - abnormalPO.setUharm6(uharm6.get(0).getNormValue()); - abnormalPO.setUharm7(uharm7.get(0).getNormValue()); - abnormalPO.setUharm8(uharm8.get(0).getNormValue()); - abnormalPO.setUharm9(uharm9.get(0).getNormValue()); - abnormalPO.setUharm10(uharm10.get(0).getNormValue()); - abnormalPO.setUharm11(uharm11.get(0).getNormValue()); - abnormalPO.setUharm12(uharm12.get(0).getNormValue()); - abnormalPO.setUharm13(uharm13.get(0).getNormValue()); - abnormalPO.setUharm14(uharm14.get(0).getNormValue()); - abnormalPO.setUharm15(uharm15.get(0).getNormValue()); - abnormalPO.setUharm16(uharm16.get(0).getNormValue()); - abnormalPO.setUharm17(uharm17.get(0).getNormValue()); - abnormalPO.setUharm18(uharm18.get(0).getNormValue()); - abnormalPO.setUharm19(uharm19.get(0).getNormValue()); - abnormalPO.setUharm20(uharm20.get(0).getNormValue()); - abnormalPO.setUharm21(uharm21.get(0).getNormValue()); - abnormalPO.setUharm22(uharm22.get(0).getNormValue()); - abnormalPO.setUharm23(uharm23.get(0).getNormValue()); - abnormalPO.setUharm24(uharm24.get(0).getNormValue()); - abnormalPO.setUharm25(uharm25.get(0).getNormValue()); - abnormalPO.setIharm2(iharm2.get(0).getNormValue()); - abnormalPO.setIharm3(iharm3.get(0).getNormValue()); - abnormalPO.setIharm4(iharm4.get(0).getNormValue()); - abnormalPO.setIharm5(iharm5.get(0).getNormValue()); - abnormalPO.setIharm6(iharm6.get(0).getNormValue()); - abnormalPO.setIharm7(iharm7.get(0).getNormValue()); - abnormalPO.setIharm8(iharm8.get(0).getNormValue()); - abnormalPO.setIharm9(iharm9.get(0).getNormValue()); - abnormalPO.setIharm10(iharm10.get(0).getNormValue()); - abnormalPO.setIharm11(iharm11.get(0).getNormValue()); - abnormalPO.setIharm12(iharm12.get(0).getNormValue()); - abnormalPO.setIharm13(iharm13.get(0).getNormValue()); - abnormalPO.setIharm14(iharm14.get(0).getNormValue()); - abnormalPO.setIharm15(iharm15.get(0).getNormValue()); - abnormalPO.setIharm16(iharm16.get(0).getNormValue()); - abnormalPO.setIharm17(iharm17.get(0).getNormValue()); - abnormalPO.setIharm18(iharm18.get(0).getNormValue()); - abnormalPO.setIharm19(iharm19.get(0).getNormValue()); - abnormalPO.setIharm20(iharm20.get(0).getNormValue()); - abnormalPO.setIharm21(iharm21.get(0).getNormValue()); - abnormalPO.setIharm22(iharm22.get(0).getNormValue()); - abnormalPO.setIharm23(iharm23.get(0).getNormValue()); - abnormalPO.setIharm24(iharm24.get(0).getNormValue()); - abnormalPO.setIharm25(iharm25.get(0).getNormValue()); - abnormalPO.setInuharm1(inharm.get(0).getNormValue()); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue()); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue()); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue()); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue()); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue()); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue()); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue()); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue()); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue()); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue()); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue()); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue()); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue()); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue()); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue()); - } else if (j == 2) { - abnormalPO.setFreq(freq.get(0).getNormValue() > 50 + overlimit.getFreqDev() ? freq.get(0).getNormValue() : -3.14159f); - abnormalPO.setValueType("MAX"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue() > overlimit.getVoltageDev() ? voDev.get(0).getNormValue() : -3.14159f); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue() > Math.abs(overlimit.getUvoltageDev()) ? uoDev.get(0).getNormValue() : -3.14159f); - abnormalPO.setFlicker(flicker.get(0).getNormValue() > overlimit.getFlicker() ? flicker.get(0).getNormValue() : -3.14159f); - abnormalPO.setUaberrance(uab.get(0).getNormValue() > overlimit.getUaberrance() ? uab.get(0).getNormValue() : -3.14159f); - abnormalPO.setUbalance(uba.get(0).getNormValue() > overlimit.getUbalance() ? uba.get(0).getNormValue() : -3.14159f); - abnormalPO.setINeg(ing.get(0).getNormValue() > overlimit.getINeg() ? ing.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm2(uharm2.get(0).getNormValue() > overlimit.getUharm2() ? uharm2.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm3(uharm3.get(0).getNormValue() > overlimit.getUharm3() ? uharm3.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm4(uharm4.get(0).getNormValue() > overlimit.getUharm4() ? uharm4.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm5(uharm5.get(0).getNormValue() > overlimit.getUharm5() ? uharm5.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm6(uharm6.get(0).getNormValue() > overlimit.getUharm6() ? uharm6.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm7(uharm7.get(0).getNormValue() > overlimit.getUharm7() ? uharm7.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm8(uharm8.get(0).getNormValue() > overlimit.getUharm8() ? uharm8.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm9(uharm9.get(0).getNormValue() > overlimit.getUharm9() ? uharm9.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm10(uharm10.get(0).getNormValue() > overlimit.getUharm10() ? uharm10.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm11(uharm11.get(0).getNormValue() > overlimit.getUharm11() ? uharm11.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm12(uharm12.get(0).getNormValue() > overlimit.getUharm12() ? uharm12.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm13(uharm13.get(0).getNormValue() > overlimit.getUharm13() ? uharm13.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm14(uharm14.get(0).getNormValue() > overlimit.getUharm14() ? uharm14.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm15(uharm15.get(0).getNormValue() > overlimit.getUharm15() ? uharm15.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm16(uharm16.get(0).getNormValue() > overlimit.getUharm16() ? uharm16.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm17(uharm17.get(0).getNormValue() > overlimit.getUharm17() ? uharm17.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm18(uharm18.get(0).getNormValue() > overlimit.getUharm18() ? uharm18.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm19(uharm19.get(0).getNormValue() > overlimit.getUharm19() ? uharm19.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm20(uharm20.get(0).getNormValue() > overlimit.getUharm20() ? uharm20.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm21(uharm21.get(0).getNormValue() > overlimit.getUharm21() ? uharm21.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm22(uharm22.get(0).getNormValue() > overlimit.getUharm22() ? uharm22.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm23(uharm23.get(0).getNormValue() > overlimit.getUharm23() ? uharm23.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm24(uharm24.get(0).getNormValue() > overlimit.getUharm24() ? uharm24.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm25(uharm25.get(0).getNormValue() > overlimit.getUharm25() ? uharm25.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm2(iharm2.get(0).getNormValue() > overlimit.getIharm2() ? iharm2.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm3(iharm3.get(0).getNormValue() > overlimit.getIharm3() ? iharm3.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm4(iharm4.get(0).getNormValue() > overlimit.getIharm4() ? iharm4.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm5(iharm5.get(0).getNormValue() > overlimit.getIharm5() ? iharm5.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm6(iharm6.get(0).getNormValue() > overlimit.getIharm6() ? iharm6.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm7(iharm7.get(0).getNormValue() > overlimit.getIharm7() ? iharm7.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm8(iharm8.get(0).getNormValue() > overlimit.getIharm8() ? iharm8.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm9(iharm9.get(0).getNormValue() > overlimit.getIharm9() ? iharm9.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm10(iharm10.get(0).getNormValue() > overlimit.getIharm10() ? iharm10.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm11(iharm11.get(0).getNormValue() > overlimit.getIharm11() ? iharm11.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm12(iharm12.get(0).getNormValue() > overlimit.getIharm12() ? iharm12.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm13(iharm13.get(0).getNormValue() > overlimit.getIharm13() ? iharm13.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm14(iharm14.get(0).getNormValue() > overlimit.getIharm14() ? iharm14.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm15(iharm15.get(0).getNormValue() > overlimit.getIharm15() ? iharm15.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm16(iharm16.get(0).getNormValue() > overlimit.getIharm16() ? iharm16.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm17(iharm17.get(0).getNormValue() > overlimit.getIharm17() ? iharm17.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm18(iharm18.get(0).getNormValue() > overlimit.getIharm18() ? iharm18.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm19(iharm19.get(0).getNormValue() > overlimit.getIharm19() ? iharm19.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm20(iharm20.get(0).getNormValue() > overlimit.getIharm20() ? iharm20.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm21(iharm21.get(0).getNormValue() > overlimit.getIharm21() ? iharm21.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm22(iharm22.get(0).getNormValue() > overlimit.getIharm22() ? iharm22.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm23(iharm23.get(0).getNormValue() > overlimit.getIharm23() ? iharm23.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm24(iharm24.get(0).getNormValue() > overlimit.getIharm24() ? iharm24.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm25(iharm25.get(0).getNormValue() > overlimit.getIharm25() ? iharm25.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm1(inharm.get(0).getNormValue() > overlimit.getInuharm1() ? inharm.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue() > overlimit.getInuharm2() ? inharm1.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue() > overlimit.getInuharm3() ? inharm2.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue() > overlimit.getInuharm4() ? inharm3.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue() > overlimit.getInuharm5() ? inharm4.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue() > overlimit.getInuharm6() ? inharm5.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue() > overlimit.getInuharm7() ? inharm6.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue() > overlimit.getInuharm8() ? inharm7.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue() > overlimit.getInuharm9() ? inharm8.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue() > overlimit.getInuharm10() ? inharm9.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue() > overlimit.getInuharm11() ? inharm10.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue() > overlimit.getInuharm12() ? inharm11.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue() > overlimit.getInuharm13() ? inharm12.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue() > overlimit.getInuharm14() ? inharm13.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue() > overlimit.getInuharm15() ? inharm14.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue() > overlimit.getInuharm16() ? inharm15.get(0).getNormValue() : -3.14159f); - } else if (j == 3) { - abnormalPO.setFreq(freq.get(0).getNormValue()); - abnormalPO.setValueType("MIN"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue()); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue()); - abnormalPO.setFlicker(flicker.get(0).getNormValue()); - abnormalPO.setUaberrance(uab.get(0).getNormValue()); - abnormalPO.setUbalance(uba.get(0).getNormValue()); - abnormalPO.setINeg(ing.get(0).getNormValue()); - abnormalPO.setUharm2(uharm2.get(0).getNormValue()); - abnormalPO.setUharm3(uharm3.get(0).getNormValue()); - abnormalPO.setUharm4(uharm4.get(0).getNormValue()); - abnormalPO.setUharm5(uharm5.get(0).getNormValue()); - abnormalPO.setUharm6(uharm6.get(0).getNormValue()); - abnormalPO.setUharm7(uharm7.get(0).getNormValue()); - abnormalPO.setUharm8(uharm8.get(0).getNormValue()); - abnormalPO.setUharm9(uharm9.get(0).getNormValue()); - abnormalPO.setUharm10(uharm10.get(0).getNormValue()); - abnormalPO.setUharm11(uharm11.get(0).getNormValue()); - abnormalPO.setUharm12(uharm12.get(0).getNormValue()); - abnormalPO.setUharm13(uharm13.get(0).getNormValue()); - abnormalPO.setUharm14(uharm14.get(0).getNormValue()); - abnormalPO.setUharm15(uharm15.get(0).getNormValue()); - abnormalPO.setUharm16(uharm16.get(0).getNormValue()); - abnormalPO.setUharm17(uharm17.get(0).getNormValue()); - abnormalPO.setUharm18(uharm18.get(0).getNormValue()); - abnormalPO.setUharm19(uharm19.get(0).getNormValue()); - abnormalPO.setUharm20(uharm20.get(0).getNormValue()); - abnormalPO.setUharm21(uharm21.get(0).getNormValue()); - abnormalPO.setUharm22(uharm22.get(0).getNormValue()); - abnormalPO.setUharm23(uharm23.get(0).getNormValue()); - abnormalPO.setUharm24(uharm24.get(0).getNormValue()); - abnormalPO.setUharm25(uharm25.get(0).getNormValue()); - abnormalPO.setIharm2(iharm2.get(0).getNormValue()); - abnormalPO.setIharm3(iharm3.get(0).getNormValue()); - abnormalPO.setIharm4(iharm4.get(0).getNormValue()); - abnormalPO.setIharm5(iharm5.get(0).getNormValue()); - abnormalPO.setIharm6(iharm6.get(0).getNormValue()); - abnormalPO.setIharm7(iharm7.get(0).getNormValue()); - abnormalPO.setIharm8(iharm8.get(0).getNormValue()); - abnormalPO.setIharm9(iharm9.get(0).getNormValue()); - abnormalPO.setIharm10(iharm10.get(0).getNormValue()); - abnormalPO.setIharm11(iharm11.get(0).getNormValue()); - abnormalPO.setIharm12(iharm12.get(0).getNormValue()); - abnormalPO.setIharm13(iharm13.get(0).getNormValue()); - abnormalPO.setIharm14(iharm14.get(0).getNormValue()); - abnormalPO.setIharm15(iharm15.get(0).getNormValue()); - abnormalPO.setIharm16(iharm16.get(0).getNormValue()); - abnormalPO.setIharm17(iharm17.get(0).getNormValue()); - abnormalPO.setIharm18(iharm18.get(0).getNormValue()); - abnormalPO.setIharm19(iharm19.get(0).getNormValue()); - abnormalPO.setIharm20(iharm20.get(0).getNormValue()); - abnormalPO.setIharm21(iharm21.get(0).getNormValue()); - abnormalPO.setIharm22(iharm22.get(0).getNormValue()); - abnormalPO.setIharm23(iharm23.get(0).getNormValue()); - abnormalPO.setIharm24(iharm24.get(0).getNormValue()); - abnormalPO.setIharm25(iharm25.get(0).getNormValue()); - abnormalPO.setInuharm1(inharm.get(0).getNormValue()); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue()); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue()); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue()); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue()); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue()); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue()); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue()); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue()); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue()); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue()); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue()); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue()); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue()); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue()); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue()); - } else { - abnormalPO.setFreq(freq.get(0).getNormValue()); - abnormalPO.setValueType("CP95"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue()); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue()); - abnormalPO.setFlicker(flicker.get(0).getNormValue()); - abnormalPO.setUaberrance(uab.get(0).getNormValue()); - abnormalPO.setUbalance(uba.get(0).getNormValue()); - abnormalPO.setINeg(ing.get(0).getNormValue()); - abnormalPO.setUharm2(uharm2.get(0).getNormValue()); - abnormalPO.setUharm3(uharm3.get(0).getNormValue()); - abnormalPO.setUharm4(uharm4.get(0).getNormValue()); - abnormalPO.setUharm5(uharm5.get(0).getNormValue()); - abnormalPO.setUharm6(uharm6.get(0).getNormValue()); - abnormalPO.setUharm7(uharm7.get(0).getNormValue()); - abnormalPO.setUharm8(uharm8.get(0).getNormValue()); - abnormalPO.setUharm9(uharm9.get(0).getNormValue()); - abnormalPO.setUharm10(uharm10.get(0).getNormValue()); - abnormalPO.setUharm11(uharm11.get(0).getNormValue()); - abnormalPO.setUharm12(uharm12.get(0).getNormValue()); - abnormalPO.setUharm13(uharm13.get(0).getNormValue()); - abnormalPO.setUharm14(uharm14.get(0).getNormValue()); - abnormalPO.setUharm15(uharm15.get(0).getNormValue()); - abnormalPO.setUharm16(uharm16.get(0).getNormValue()); - abnormalPO.setUharm17(uharm17.get(0).getNormValue()); - abnormalPO.setUharm18(uharm18.get(0).getNormValue()); - abnormalPO.setUharm19(uharm19.get(0).getNormValue()); - abnormalPO.setUharm20(uharm20.get(0).getNormValue()); - abnormalPO.setUharm21(uharm21.get(0).getNormValue()); - abnormalPO.setUharm22(uharm22.get(0).getNormValue()); - abnormalPO.setUharm23(uharm23.get(0).getNormValue()); - abnormalPO.setUharm24(uharm24.get(0).getNormValue()); - abnormalPO.setUharm25(uharm25.get(0).getNormValue()); - abnormalPO.setIharm2(iharm2.get(0).getNormValue()); - abnormalPO.setIharm3(iharm3.get(0).getNormValue()); - abnormalPO.setIharm4(iharm4.get(0).getNormValue()); - abnormalPO.setIharm5(iharm5.get(0).getNormValue()); - abnormalPO.setIharm6(iharm6.get(0).getNormValue()); - abnormalPO.setIharm7(iharm7.get(0).getNormValue()); - abnormalPO.setIharm8(iharm8.get(0).getNormValue()); - abnormalPO.setIharm9(iharm9.get(0).getNormValue()); - abnormalPO.setIharm10(iharm10.get(0).getNormValue()); - abnormalPO.setIharm11(iharm11.get(0).getNormValue()); - abnormalPO.setIharm12(iharm12.get(0).getNormValue()); - abnormalPO.setIharm13(iharm13.get(0).getNormValue()); - abnormalPO.setIharm14(iharm14.get(0).getNormValue()); - abnormalPO.setIharm15(iharm15.get(0).getNormValue()); - abnormalPO.setIharm16(iharm16.get(0).getNormValue()); - abnormalPO.setIharm17(iharm17.get(0).getNormValue()); - abnormalPO.setIharm18(iharm18.get(0).getNormValue()); - abnormalPO.setIharm19(iharm19.get(0).getNormValue()); - abnormalPO.setIharm20(iharm20.get(0).getNormValue()); - abnormalPO.setIharm21(iharm21.get(0).getNormValue()); - abnormalPO.setIharm22(iharm22.get(0).getNormValue()); - abnormalPO.setIharm23(iharm23.get(0).getNormValue()); - abnormalPO.setIharm24(iharm24.get(0).getNormValue()); - abnormalPO.setIharm25(iharm25.get(0).getNormValue()); - abnormalPO.setInuharm1(inharm.get(0).getNormValue()); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue()); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue()); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue()); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue()); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue()); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue()); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue()); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue()); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue()); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue()); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue()); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue()); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue()); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue()); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue()); - } - // abnormalMapper.insert(abnormalPO); - } - } - } - } - } - } else { - //不为空则为补招 - lineIds.addAll(lineParam.getLineIds()); - } - - - for (String lineIndex : lineIds) { - //获取当前监测点的限值详情 - Overlimit overlimit = lineFeignClient.getOverLimitData(lineIndex).getData(); - for (int i = 1; i < 5; i++) { - for (int j = 1; j < 5; j++) { - //电压上偏差 - List voDev = getConntion(i, j, start, end, lineIndex, 1); - //电压下偏差 - List uoDev = getConntion(i, j, start, end, lineIndex, 2); - //三相电压不平衡度 - List uba = getConntion(i, j, start, end, lineIndex, 3); - //电压总畸变率 - List uab = getConntion(i, j, start, end, lineIndex, 4); - //负序电流 - List ing = getConntion(i, j, start, end, lineIndex, 5); - //频率 - List freq = getConntion(i, j, start, end, lineIndex, 6); - //2-25次谐波含有率 - //谐波电压含有率 - List uharm2 = getConntion(i, j, start, end, lineIndex, 7); - List uharm3 = getConntion(i, j, start, end, lineIndex, 8); - List uharm4 = getConntion(i, j, start, end, lineIndex, 9); - List uharm5 = getConntion(i, j, start, end, lineIndex, 10); - List uharm6 = getConntion(i, j, start, end, lineIndex, 11); - List uharm7 = getConntion(i, j, start, end, lineIndex, 12); - List uharm8 = getConntion(i, j, start, end, lineIndex, 13); - List uharm9 = getConntion(i, j, start, end, lineIndex, 14); - List uharm10 = getConntion(i, j, start, end, lineIndex, 15); - List uharm11 = getConntion(i, j, start, end, lineIndex, 16); - List uharm12 = getConntion(i, j, start, end, lineIndex, 17); - List uharm13 = getConntion(i, j, start, end, lineIndex, 18); - List uharm14 = getConntion(i, j, start, end, lineIndex, 19); - List uharm15 = getConntion(i, j, start, end, lineIndex, 20); - List uharm16 = getConntion(i, j, start, end, lineIndex, 21); - List uharm17 = getConntion(i, j, start, end, lineIndex, 22); - List uharm18 = getConntion(i, j, start, end, lineIndex, 23); - List uharm19 = getConntion(i, j, start, end, lineIndex, 24); - List uharm20 = getConntion(i, j, start, end, lineIndex, 25); - List uharm21 = getConntion(i, j, start, end, lineIndex, 26); - List uharm22 = getConntion(i, j, start, end, lineIndex, 27); - List uharm23 = getConntion(i, j, start, end, lineIndex, 28); - List uharm24 = getConntion(i, j, start, end, lineIndex, 29); - List uharm25 = getConntion(i, j, start, end, lineIndex, 30); - - - //2-25次谐波电流幅值 - List iharm2 = getConntion(i, j, start, end, lineIndex, 31); - List iharm3 = getConntion(i, j, start, end, lineIndex, 32); - List iharm4 = getConntion(i, j, start, end, lineIndex, 33); - List iharm5 = getConntion(i, j, start, end, lineIndex, 34); - List iharm6 = getConntion(i, j, start, end, lineIndex, 35); - List iharm7 = getConntion(i, j, start, end, lineIndex, 36); - List iharm8 = getConntion(i, j, start, end, lineIndex, 37); - List iharm9 = getConntion(i, j, start, end, lineIndex, 38); - List iharm10 = getConntion(i, j, start, end, lineIndex, 39); - List iharm11 = getConntion(i, j, start, end, lineIndex, 40); - List iharm12 = getConntion(i, j, start, end, lineIndex, 41); - List iharm13 = getConntion(i, j, start, end, lineIndex, 42); - List iharm14 = getConntion(i, j, start, end, lineIndex, 43); - List iharm15 = getConntion(i, j, start, end, lineIndex, 44); - List iharm16 = getConntion(i, j, start, end, lineIndex, 45); - List iharm17 = getConntion(i, j, start, end, lineIndex, 46); - List iharm18 = getConntion(i, j, start, end, lineIndex, 47); - List iharm19 = getConntion(i, j, start, end, lineIndex, 48); - List iharm20 = getConntion(i, j, start, end, lineIndex, 49); - List iharm21 = getConntion(i, j, start, end, lineIndex, 50); - List iharm22 = getConntion(i, j, start, end, lineIndex, 51); - List iharm23 = getConntion(i, j, start, end, lineIndex, 52); - List iharm24 = getConntion(i, j, start, end, lineIndex, 53); - List iharm25 = getConntion(i, j, start, end, lineIndex, 54); - - - //0.5-15.5次间谐波电压含有率 - List inharm = getConntion(i, j, start, end, lineIndex, 55); - List inharm1 = getConntion(i, j, start, end, lineIndex, 56); - List inharm2 = getConntion(i, j, start, end, lineIndex, 57); - List inharm3 = getConntion(i, j, start, end, lineIndex, 58); - List inharm4 = getConntion(i, j, start, end, lineIndex, 59); - List inharm5 = getConntion(i, j, start, end, lineIndex, 60); - List inharm6 = getConntion(i, j, start, end, lineIndex, 61); - List inharm7 = getConntion(i, j, start, end, lineIndex, 62); - List inharm8 = getConntion(i, j, start, end, lineIndex, 63); - List inharm9 = getConntion(i, j, start, end, lineIndex, 64); - List inharm10 = getConntion(i, j, start, end, lineIndex, 65); - List inharm11 = getConntion(i, j, start, end, lineIndex, 66); - List inharm12 = getConntion(i, j, start, end, lineIndex, 67); - List inharm13 = getConntion(i, j, start, end, lineIndex, 68); - List inharm14 = getConntion(i, j, start, end, lineIndex, 69); - List inharm15 = getConntion(i, j, start, end, lineIndex, 70); - //长时闪变 - List flicker = getConntion(i, j, start, end, lineIndex, 71); - //只需要判断一个指标即可 - if (voDev.size() > 0 && uoDev.size() > 0 && uba.size() > 0 && uab.size() > 0 && ing.size() > 0 && freq.size() > 0 && uharm2.size() > 0 && uharm3.size() > 0 && uharm4.size() > 0 - && uharm5.size() > 0 && uharm6.size() > 0 && uharm7.size() > 0 && uharm8.size() > 0 && uharm9.size() > 0 && uharm10.size() > 0 && uharm11.size() > 0 && uharm12.size() > 0 && uharm13.size() > 0 && uharm14.size() > 0 - && uharm15.size() > 0 && uharm16.size() > 0 && uharm17.size() > 0 && uharm18.size() > 0 && uharm19.size() > 0 && uharm20.size() > 0 && uharm21.size() > 0 && uharm22.size() > 0 && uharm23.size() > 0 && uharm24.size() > 0 - && uharm25.size() > 0 && iharm2.size() > 0 && iharm3.size() > 0 && iharm4.size() > 0 - && iharm5.size() > 0 && iharm6.size() > 0 && iharm7.size() > 0 && iharm8.size() > 0 && iharm9.size() > 0 && iharm10.size() > 0 && iharm11.size() > 0 && iharm12.size() > 0 && iharm13.size() > 0 && iharm14.size() > 0 - && iharm15.size() > 0 && iharm16.size() > 0 && iharm17.size() > 0 && iharm18.size() > 0 && iharm19.size() > 0 && iharm20.size() > 0 && iharm21.size() > 0 && iharm22.size() > 0 && iharm23.size() > 0 && iharm24.size() > 0 - && iharm25.size() > 0 && inharm.size() > 0 && inharm1.size() > 0 && inharm2.size() > 0 - && inharm3.size() > 0 && inharm4.size() > 0 && inharm5.size() > 0 && inharm6.size() > 0 && inharm7.size() > 0 && inharm8.size() > 0 && inharm9.size() > 0 && inharm10.size() > 0 && inharm11.size() > 0 && inharm12.size() > 0 - && inharm13.size() > 0 && inharm14.size() > 0 && inharm15.size() > 0) { - MpSurplusAbnormalD abnormalPO = new MpSurplusAbnormalD(); - abnormalPO.setTimeId(LocalDateTimeUtil.of(start)); - abnormalPO.setId(lineIndex); - if (i == 1) { - abnormalPO.setPhasicType("A"); - } else if (i == 2) { - abnormalPO.setPhasicType("B"); - } else if (i == 3) { - abnormalPO.setPhasicType("C"); - } else { - abnormalPO.setPhasicType("T"); - } - if (j == 1) { - abnormalPO.setFreq(freq.get(0).getNormValue()); - abnormalPO.setValueType("AVG"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue()); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue()); - abnormalPO.setFlicker(flicker.get(0).getNormValue()); - abnormalPO.setUaberrance(uab.get(0).getNormValue()); - abnormalPO.setUbalance(uba.get(0).getNormValue()); - abnormalPO.setINeg(ing.get(0).getNormValue()); - abnormalPO.setUharm2(uharm2.get(0).getNormValue()); - abnormalPO.setUharm3(uharm3.get(0).getNormValue()); - abnormalPO.setUharm4(uharm4.get(0).getNormValue()); - abnormalPO.setUharm5(uharm5.get(0).getNormValue()); - abnormalPO.setUharm6(uharm6.get(0).getNormValue()); - abnormalPO.setUharm7(uharm7.get(0).getNormValue()); - abnormalPO.setUharm8(uharm8.get(0).getNormValue()); - abnormalPO.setUharm9(uharm9.get(0).getNormValue()); - abnormalPO.setUharm10(uharm10.get(0).getNormValue()); - abnormalPO.setUharm11(uharm11.get(0).getNormValue()); - abnormalPO.setUharm12(uharm12.get(0).getNormValue()); - abnormalPO.setUharm13(uharm13.get(0).getNormValue()); - abnormalPO.setUharm14(uharm14.get(0).getNormValue()); - abnormalPO.setUharm15(uharm15.get(0).getNormValue()); - abnormalPO.setUharm16(uharm16.get(0).getNormValue()); - abnormalPO.setUharm17(uharm17.get(0).getNormValue()); - abnormalPO.setUharm18(uharm18.get(0).getNormValue()); - abnormalPO.setUharm19(uharm19.get(0).getNormValue()); - abnormalPO.setUharm20(uharm20.get(0).getNormValue()); - abnormalPO.setUharm21(uharm21.get(0).getNormValue()); - abnormalPO.setUharm22(uharm22.get(0).getNormValue()); - abnormalPO.setUharm23(uharm23.get(0).getNormValue()); - abnormalPO.setUharm24(uharm24.get(0).getNormValue()); - abnormalPO.setUharm25(uharm25.get(0).getNormValue()); - abnormalPO.setIharm2(iharm2.get(0).getNormValue()); - abnormalPO.setIharm3(iharm3.get(0).getNormValue()); - abnormalPO.setIharm4(iharm4.get(0).getNormValue()); - abnormalPO.setIharm5(iharm5.get(0).getNormValue()); - abnormalPO.setIharm6(iharm6.get(0).getNormValue()); - abnormalPO.setIharm7(iharm7.get(0).getNormValue()); - abnormalPO.setIharm8(iharm8.get(0).getNormValue()); - abnormalPO.setIharm9(iharm9.get(0).getNormValue()); - abnormalPO.setIharm10(iharm10.get(0).getNormValue()); - abnormalPO.setIharm11(iharm11.get(0).getNormValue()); - abnormalPO.setIharm12(iharm12.get(0).getNormValue()); - abnormalPO.setIharm13(iharm13.get(0).getNormValue()); - abnormalPO.setIharm14(iharm14.get(0).getNormValue()); - abnormalPO.setIharm15(iharm15.get(0).getNormValue()); - abnormalPO.setIharm16(iharm16.get(0).getNormValue()); - abnormalPO.setIharm17(iharm17.get(0).getNormValue()); - abnormalPO.setIharm18(iharm18.get(0).getNormValue()); - abnormalPO.setIharm19(iharm19.get(0).getNormValue()); - abnormalPO.setIharm20(iharm20.get(0).getNormValue()); - abnormalPO.setIharm21(iharm21.get(0).getNormValue()); - abnormalPO.setIharm22(iharm22.get(0).getNormValue()); - abnormalPO.setIharm23(iharm23.get(0).getNormValue()); - abnormalPO.setIharm24(iharm24.get(0).getNormValue()); - abnormalPO.setIharm25(iharm25.get(0).getNormValue()); - abnormalPO.setInuharm1(inharm.get(0).getNormValue()); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue()); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue()); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue()); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue()); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue()); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue()); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue()); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue()); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue()); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue()); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue()); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue()); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue()); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue()); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue()); - } else if (j == 2) { - abnormalPO.setFreq(freq.get(0).getNormValue() > 50 + overlimit.getFreqDev() ? freq.get(0).getNormValue() : -3.14159f); - abnormalPO.setValueType("MAX"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue() > overlimit.getVoltageDev() ? voDev.get(0).getNormValue() : -3.14159f); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue() > Math.abs(overlimit.getUvoltageDev()) ? uoDev.get(0).getNormValue() : -3.14159f); - abnormalPO.setFlicker(flicker.get(0).getNormValue() > overlimit.getFlicker() ? flicker.get(0).getNormValue() : -3.14159f); - abnormalPO.setUaberrance(uab.get(0).getNormValue() > overlimit.getUaberrance() ? uab.get(0).getNormValue() : -3.14159f); - abnormalPO.setUbalance(uba.get(0).getNormValue() > overlimit.getUbalance() ? uba.get(0).getNormValue() : -3.14159f); - abnormalPO.setINeg(ing.get(0).getNormValue() > overlimit.getINeg() ? ing.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm2(uharm2.get(0).getNormValue() > overlimit.getUharm2() ? uharm2.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm3(uharm3.get(0).getNormValue() > overlimit.getUharm3() ? uharm3.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm4(uharm4.get(0).getNormValue() > overlimit.getUharm4() ? uharm4.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm5(uharm5.get(0).getNormValue() > overlimit.getUharm5() ? uharm5.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm6(uharm6.get(0).getNormValue() > overlimit.getUharm6() ? uharm6.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm7(uharm7.get(0).getNormValue() > overlimit.getUharm7() ? uharm7.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm8(uharm8.get(0).getNormValue() > overlimit.getUharm8() ? uharm8.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm9(uharm9.get(0).getNormValue() > overlimit.getUharm9() ? uharm9.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm10(uharm10.get(0).getNormValue() > overlimit.getUharm10() ? uharm10.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm11(uharm11.get(0).getNormValue() > overlimit.getUharm11() ? uharm11.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm12(uharm12.get(0).getNormValue() > overlimit.getUharm12() ? uharm12.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm13(uharm13.get(0).getNormValue() > overlimit.getUharm13() ? uharm13.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm14(uharm14.get(0).getNormValue() > overlimit.getUharm14() ? uharm14.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm15(uharm15.get(0).getNormValue() > overlimit.getUharm15() ? uharm15.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm16(uharm16.get(0).getNormValue() > overlimit.getUharm16() ? uharm16.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm17(uharm17.get(0).getNormValue() > overlimit.getUharm17() ? uharm17.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm18(uharm18.get(0).getNormValue() > overlimit.getUharm18() ? uharm18.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm19(uharm19.get(0).getNormValue() > overlimit.getUharm19() ? uharm19.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm20(uharm20.get(0).getNormValue() > overlimit.getUharm20() ? uharm20.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm21(uharm21.get(0).getNormValue() > overlimit.getUharm21() ? uharm21.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm22(uharm22.get(0).getNormValue() > overlimit.getUharm22() ? uharm22.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm23(uharm23.get(0).getNormValue() > overlimit.getUharm23() ? uharm23.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm24(uharm24.get(0).getNormValue() > overlimit.getUharm24() ? uharm24.get(0).getNormValue() : -3.14159f); - abnormalPO.setUharm25(uharm25.get(0).getNormValue() > overlimit.getUharm25() ? uharm25.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm2(iharm2.get(0).getNormValue() > overlimit.getIharm2() ? iharm2.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm3(iharm3.get(0).getNormValue() > overlimit.getIharm3() ? iharm3.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm4(iharm4.get(0).getNormValue() > overlimit.getIharm4() ? iharm4.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm5(iharm5.get(0).getNormValue() > overlimit.getIharm5() ? iharm5.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm6(iharm6.get(0).getNormValue() > overlimit.getIharm6() ? iharm6.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm7(iharm7.get(0).getNormValue() > overlimit.getIharm7() ? iharm7.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm8(iharm8.get(0).getNormValue() > overlimit.getIharm8() ? iharm8.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm9(iharm9.get(0).getNormValue() > overlimit.getIharm9() ? iharm9.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm10(iharm10.get(0).getNormValue() > overlimit.getIharm10() ? iharm10.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm11(iharm11.get(0).getNormValue() > overlimit.getIharm11() ? iharm11.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm12(iharm12.get(0).getNormValue() > overlimit.getIharm12() ? iharm12.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm13(iharm13.get(0).getNormValue() > overlimit.getIharm13() ? iharm13.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm14(iharm14.get(0).getNormValue() > overlimit.getIharm14() ? iharm14.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm15(iharm15.get(0).getNormValue() > overlimit.getIharm15() ? iharm15.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm16(iharm16.get(0).getNormValue() > overlimit.getIharm16() ? iharm16.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm17(iharm17.get(0).getNormValue() > overlimit.getIharm17() ? iharm17.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm18(iharm18.get(0).getNormValue() > overlimit.getIharm18() ? iharm18.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm19(iharm19.get(0).getNormValue() > overlimit.getIharm19() ? iharm19.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm20(iharm20.get(0).getNormValue() > overlimit.getIharm20() ? iharm20.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm21(iharm21.get(0).getNormValue() > overlimit.getIharm21() ? iharm21.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm22(iharm22.get(0).getNormValue() > overlimit.getIharm22() ? iharm22.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm23(iharm23.get(0).getNormValue() > overlimit.getIharm23() ? iharm23.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm24(iharm24.get(0).getNormValue() > overlimit.getIharm24() ? iharm24.get(0).getNormValue() : -3.14159f); - abnormalPO.setIharm25(iharm25.get(0).getNormValue() > overlimit.getIharm25() ? iharm25.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm1(inharm.get(0).getNormValue() > overlimit.getInuharm1() ? inharm.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue() > overlimit.getInuharm2() ? inharm1.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue() > overlimit.getInuharm3() ? inharm2.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue() > overlimit.getInuharm4() ? inharm3.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue() > overlimit.getInuharm5() ? inharm4.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue() > overlimit.getInuharm6() ? inharm5.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue() > overlimit.getInuharm7() ? inharm6.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue() > overlimit.getInuharm8() ? inharm7.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue() > overlimit.getInuharm9() ? inharm8.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue() > overlimit.getInuharm10() ? inharm9.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue() > overlimit.getInuharm11() ? inharm10.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue() > overlimit.getInuharm12() ? inharm11.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue() > overlimit.getInuharm13() ? inharm12.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue() > overlimit.getInuharm14() ? inharm13.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue() > overlimit.getInuharm15() ? inharm14.get(0).getNormValue() : -3.14159f); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue() > overlimit.getInuharm16() ? inharm15.get(0).getNormValue() : -3.14159f); - } else if (j == 3) { - abnormalPO.setFreq(freq.get(0).getNormValue()); - abnormalPO.setValueType("MIN"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue()); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue()); - abnormalPO.setFlicker(flicker.get(0).getNormValue()); - abnormalPO.setUaberrance(uab.get(0).getNormValue()); - abnormalPO.setUbalance(uba.get(0).getNormValue()); - abnormalPO.setINeg(ing.get(0).getNormValue()); - abnormalPO.setUharm2(uharm2.get(0).getNormValue()); - abnormalPO.setUharm3(uharm3.get(0).getNormValue()); - abnormalPO.setUharm4(uharm4.get(0).getNormValue()); - abnormalPO.setUharm5(uharm5.get(0).getNormValue()); - abnormalPO.setUharm6(uharm6.get(0).getNormValue()); - abnormalPO.setUharm7(uharm7.get(0).getNormValue()); - abnormalPO.setUharm8(uharm8.get(0).getNormValue()); - abnormalPO.setUharm9(uharm9.get(0).getNormValue()); - abnormalPO.setUharm10(uharm10.get(0).getNormValue()); - abnormalPO.setUharm11(uharm11.get(0).getNormValue()); - abnormalPO.setUharm12(uharm12.get(0).getNormValue()); - abnormalPO.setUharm13(uharm13.get(0).getNormValue()); - abnormalPO.setUharm14(uharm14.get(0).getNormValue()); - abnormalPO.setUharm15(uharm15.get(0).getNormValue()); - abnormalPO.setUharm16(uharm16.get(0).getNormValue()); - abnormalPO.setUharm17(uharm17.get(0).getNormValue()); - abnormalPO.setUharm18(uharm18.get(0).getNormValue()); - abnormalPO.setUharm19(uharm19.get(0).getNormValue()); - abnormalPO.setUharm20(uharm20.get(0).getNormValue()); - abnormalPO.setUharm21(uharm21.get(0).getNormValue()); - abnormalPO.setUharm22(uharm22.get(0).getNormValue()); - abnormalPO.setUharm23(uharm23.get(0).getNormValue()); - abnormalPO.setUharm24(uharm24.get(0).getNormValue()); - abnormalPO.setUharm25(uharm25.get(0).getNormValue()); - abnormalPO.setIharm2(iharm2.get(0).getNormValue()); - abnormalPO.setIharm3(iharm3.get(0).getNormValue()); - abnormalPO.setIharm4(iharm4.get(0).getNormValue()); - abnormalPO.setIharm5(iharm5.get(0).getNormValue()); - abnormalPO.setIharm6(iharm6.get(0).getNormValue()); - abnormalPO.setIharm7(iharm7.get(0).getNormValue()); - abnormalPO.setIharm8(iharm8.get(0).getNormValue()); - abnormalPO.setIharm9(iharm9.get(0).getNormValue()); - abnormalPO.setIharm10(iharm10.get(0).getNormValue()); - abnormalPO.setIharm11(iharm11.get(0).getNormValue()); - abnormalPO.setIharm12(iharm12.get(0).getNormValue()); - abnormalPO.setIharm13(iharm13.get(0).getNormValue()); - abnormalPO.setIharm14(iharm14.get(0).getNormValue()); - abnormalPO.setIharm15(iharm15.get(0).getNormValue()); - abnormalPO.setIharm16(iharm16.get(0).getNormValue()); - abnormalPO.setIharm17(iharm17.get(0).getNormValue()); - abnormalPO.setIharm18(iharm18.get(0).getNormValue()); - abnormalPO.setIharm19(iharm19.get(0).getNormValue()); - abnormalPO.setIharm20(iharm20.get(0).getNormValue()); - abnormalPO.setIharm21(iharm21.get(0).getNormValue()); - abnormalPO.setIharm22(iharm22.get(0).getNormValue()); - abnormalPO.setIharm23(iharm23.get(0).getNormValue()); - abnormalPO.setIharm24(iharm24.get(0).getNormValue()); - abnormalPO.setIharm25(iharm25.get(0).getNormValue()); - abnormalPO.setInuharm1(inharm.get(0).getNormValue()); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue()); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue()); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue()); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue()); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue()); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue()); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue()); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue()); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue()); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue()); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue()); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue()); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue()); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue()); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue()); - } else { - abnormalPO.setFreq(freq.get(0).getNormValue()); - abnormalPO.setValueType("CP95"); - abnormalPO.setVoltageDev(voDev.get(0).getNormValue()); - abnormalPO.setUvoltageDev(uoDev.get(0).getNormValue()); - abnormalPO.setFlicker(flicker.get(0).getNormValue()); - abnormalPO.setUaberrance(uab.get(0).getNormValue()); - abnormalPO.setUbalance(uba.get(0).getNormValue()); - abnormalPO.setINeg(ing.get(0).getNormValue()); - abnormalPO.setUharm2(uharm2.get(0).getNormValue()); - abnormalPO.setUharm3(uharm3.get(0).getNormValue()); - abnormalPO.setUharm4(uharm4.get(0).getNormValue()); - abnormalPO.setUharm5(uharm5.get(0).getNormValue()); - abnormalPO.setUharm6(uharm6.get(0).getNormValue()); - abnormalPO.setUharm7(uharm7.get(0).getNormValue()); - abnormalPO.setUharm8(uharm8.get(0).getNormValue()); - abnormalPO.setUharm9(uharm9.get(0).getNormValue()); - abnormalPO.setUharm10(uharm10.get(0).getNormValue()); - abnormalPO.setUharm11(uharm11.get(0).getNormValue()); - abnormalPO.setUharm12(uharm12.get(0).getNormValue()); - abnormalPO.setUharm13(uharm13.get(0).getNormValue()); - abnormalPO.setUharm14(uharm14.get(0).getNormValue()); - abnormalPO.setUharm15(uharm15.get(0).getNormValue()); - abnormalPO.setUharm16(uharm16.get(0).getNormValue()); - abnormalPO.setUharm17(uharm17.get(0).getNormValue()); - abnormalPO.setUharm18(uharm18.get(0).getNormValue()); - abnormalPO.setUharm19(uharm19.get(0).getNormValue()); - abnormalPO.setUharm20(uharm20.get(0).getNormValue()); - abnormalPO.setUharm21(uharm21.get(0).getNormValue()); - abnormalPO.setUharm22(uharm22.get(0).getNormValue()); - abnormalPO.setUharm23(uharm23.get(0).getNormValue()); - abnormalPO.setUharm24(uharm24.get(0).getNormValue()); - abnormalPO.setUharm25(uharm25.get(0).getNormValue()); - abnormalPO.setIharm2(iharm2.get(0).getNormValue()); - abnormalPO.setIharm3(iharm3.get(0).getNormValue()); - abnormalPO.setIharm4(iharm4.get(0).getNormValue()); - abnormalPO.setIharm5(iharm5.get(0).getNormValue()); - abnormalPO.setIharm6(iharm6.get(0).getNormValue()); - abnormalPO.setIharm7(iharm7.get(0).getNormValue()); - abnormalPO.setIharm8(iharm8.get(0).getNormValue()); - abnormalPO.setIharm9(iharm9.get(0).getNormValue()); - abnormalPO.setIharm10(iharm10.get(0).getNormValue()); - abnormalPO.setIharm11(iharm11.get(0).getNormValue()); - abnormalPO.setIharm12(iharm12.get(0).getNormValue()); - abnormalPO.setIharm13(iharm13.get(0).getNormValue()); - abnormalPO.setIharm14(iharm14.get(0).getNormValue()); - abnormalPO.setIharm15(iharm15.get(0).getNormValue()); - abnormalPO.setIharm16(iharm16.get(0).getNormValue()); - abnormalPO.setIharm17(iharm17.get(0).getNormValue()); - abnormalPO.setIharm18(iharm18.get(0).getNormValue()); - abnormalPO.setIharm19(iharm19.get(0).getNormValue()); - abnormalPO.setIharm20(iharm20.get(0).getNormValue()); - abnormalPO.setIharm21(iharm21.get(0).getNormValue()); - abnormalPO.setIharm22(iharm22.get(0).getNormValue()); - abnormalPO.setIharm23(iharm23.get(0).getNormValue()); - abnormalPO.setIharm24(iharm24.get(0).getNormValue()); - abnormalPO.setIharm25(iharm25.get(0).getNormValue()); - abnormalPO.setInuharm1(inharm.get(0).getNormValue()); - abnormalPO.setInuharm2(inharm1.get(0).getNormValue()); - abnormalPO.setInuharm3(inharm2.get(0).getNormValue()); - abnormalPO.setInuharm4(inharm3.get(0).getNormValue()); - abnormalPO.setInuharm5(inharm4.get(0).getNormValue()); - abnormalPO.setInuharm6(inharm5.get(0).getNormValue()); - abnormalPO.setInuharm7(inharm6.get(0).getNormValue()); - abnormalPO.setInuharm8(inharm7.get(0).getNormValue()); - abnormalPO.setInuharm9(inharm8.get(0).getNormValue()); - abnormalPO.setInuharm10(inharm9.get(0).getNormValue()); - abnormalPO.setInuharm11(inharm10.get(0).getNormValue()); - abnormalPO.setInuharm12(inharm11.get(0).getNormValue()); - abnormalPO.setInuharm13(inharm12.get(0).getNormValue()); - abnormalPO.setInuharm14(inharm13.get(0).getNormValue()); - abnormalPO.setInuharm15(inharm14.get(0).getNormValue()); - abnormalPO.setInuharm16(inharm15.get(0).getNormValue()); - } - // abnormalMapper.insert(abnormalPO); - } - } - } - } - return true; - } - - public List getConntion(int i, int j, DateTime startTime, DateTime endTime, String lineIndex, int conntion) { - List abnormalVOList = new ArrayList<>(); - String sql = ""; - String phasic = ""; - String valueType = ""; - StringBuilder stringBuilder = new StringBuilder(); - stringBuilder.append(InfluxDBPublicParam.TIME + " >= '").append(startTime).append("' and ").append(InfluxDBPublicParam.TIME + " <= '").append(endTime).append("'"); - stringBuilder.append(" and ").append(InfluxDBPublicParam.LINE_ID + "='").append(lineIndex).append("'"); - switch (i) { - case 1: - phasic = "A"; - break; - case 2: - phasic = "B"; - break; - case 3: - phasic = "C"; - break; - case 4: - phasic = "T"; - break; - } - switch (j) { - case 1: - valueType = "AVG"; - break; - case 2: - valueType = "MAX"; - break; - case 3: - valueType = "MIN"; - break; - case 4: - valueType = "CP95"; - break; - } - stringBuilder.append(" and value_type ='").append(valueType).append("'"); - stringBuilder.append(" and ").append("phasic_type ='").append(phasic).append("'").append("order by time asc ").append(InfluxDBPublicParam.TIME_ZONE); - switch (conntion) { - case 1: - sql = "SELECT vl_dev as normValue,value_type as valueType FROM day_v WHERE " + stringBuilder.toString(); - break; - case 2: - sql = "SELECT vu_dev as normValue,value_type as valueType FROM day_v WHERE " + stringBuilder.toString(); - break; - case 3: - sql = "SELECT v_unbalance as normValue,value_type as valueType FROM day_v WHERE " + stringBuilder.toString(); - break; - case 4: - sql = "SELECT v_thd as normValue,value_type as valueType FROM day_v WHERE " + stringBuilder.toString(); - break; - case 5: - sql = "SELECT i_neg as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 6: - sql = "SELECT freq as normValue,value_type as valueType FROM day_v WHERE " + stringBuilder.toString(); - break; - case 7: - sql = "SELECT v_2 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 8: - sql = "SELECT v_3 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 9: - sql = "SELECT v_4 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 10: - sql = "SELECT v_5 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 11: - sql = "SELECT v_6 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 12: - sql = "SELECT v_7 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 13: - sql = "SELECT v_8 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 14: - sql = "SELECT v_9 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 15: - sql = "SELECT v_10 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 16: - sql = "SELECT v_11 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 17: - sql = "SELECT v_12 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 18: - sql = "SELECT v_13 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 19: - sql = "SELECT v_14 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 20: - sql = "SELECT v_15 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 21: - sql = "SELECT v_16 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 22: - sql = "SELECT v_17 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 23: - sql = "SELECT v_18 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 24: - sql = "SELECT v_19 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 25: - sql = "SELECT v_20 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 26: - sql = "SELECT v_21 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 27: - sql = "SELECT v_22 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 28: - sql = "SELECT v_23 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 29: - sql = "SELECT v_24 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 30: - sql = "SELECT v_25 as normValue,value_type as valueType FROM day_harmrate_v WHERE " + stringBuilder.toString(); - break; - case 31: - sql = "SELECT i_2 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 32: - sql = "SELECT i_3 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 33: - sql = "SELECT i_4 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 34: - sql = "SELECT i_5 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 35: - sql = "SELECT i_6 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 36: - sql = "SELECT i_7 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 37: - sql = "SELECT i_8 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 38: - sql = "SELECT i_9 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 39: - sql = "SELECT i_10 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 40: - sql = "SELECT i_11 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 41: - sql = "SELECT i_12 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 42: - sql = "SELECT i_13 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 43: - sql = "SELECT i_14 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 44: - sql = "SELECT i_15 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 45: - sql = "SELECT i_16 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 46: - sql = "SELECT i_17 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 47: - sql = "SELECT i_18 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 48: - sql = "SELECT i_19 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 49: - sql = "SELECT i_20 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 50: - sql = "SELECT i_21 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 51: - sql = "SELECT i_22 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 52: - sql = "SELECT i_23 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 53: - sql = "SELECT i_24 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 54: - sql = "SELECT i_25 as normValue,value_type as valueType FROM day_i WHERE " + stringBuilder.toString(); - break; - case 55: - sql = "SELECT v_1 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 56: - sql = "SELECT v_2 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 57: - sql = "SELECT v_3 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 58: - sql = "SELECT v_4 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 59: - sql = "SELECT v_5 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 60: - sql = "SELECT v_6 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 61: - sql = "SELECT v_7 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 62: - sql = "SELECT v_8 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 63: - sql = "SELECT v_9 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 64: - sql = "SELECT v_10 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 65: - sql = "SELECT v_11 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 66: - sql = "SELECT v_12 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 67: - sql = "SELECT v_13 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 68: - sql = "SELECT v_14 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 69: - sql = "SELECT v_15 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 70: - sql = "SELECT v_16 as normValue,value_type as valueType FROM day_inharm_v WHERE " + stringBuilder.toString(); - break; - case 71: - sql = "SELECT plt as normValue,value_type as valueType FROM day_plt WHERE " + stringBuilder.toString(); - break; - - - } - //进行查询数据 - QueryResult result = influxDbUtils.query(sql); - List list = result.getResults().get(0).getSeries(); - if (!CollectionUtils.isEmpty(list)) { - list.forEach(po -> { - List> valueList = po.getValues(); - if (!CollectionUtils.isEmpty(valueList)) { - for (List value : valueList) { - AbnormalVO abnormalVO = new AbnormalVO(); - //谐波畸变率 保留两位小数 - Double distortion = value.get(1) == null ? null : BigDecimal.valueOf(Double.parseDouble(value.get(1).toString())).setScale(4, BigDecimal.ROUND_HALF_UP).doubleValue(); - abnormalVO.setValueType(value.get(2).toString()); - abnormalVO.setNormValue(distortion.floatValue()); - abnormalVOList.add(abnormalVO); - } - } - }); - return abnormalVOList; - } else { - return abnormalVOList; - } - } - @Override @Async("asyncExecutor") @@ -1190,11 +61,10 @@ public class NormalLimitServiceImpl extends ServiceImpl lineIds = new ArrayList<>(); List all = new ArrayList<>(); - - + Dept dept = deptFeignClient.getRootDept().getData(); if (CollectionUtils.isEmpty(lineParam.getLineIds())) { DeviceInfoParam deviceInfoParam = new DeviceInfoParam(); - deviceInfoParam.setDeptIndex("5699e5916a18a6381e1ac92da5bd2628"); + deviceInfoParam.setDeptIndex(dept.getId()); deviceInfoParam.setPowerFlag(2); deviceInfoParam.setMonitorFlag(2); deviceInfoParam.setServerName(ServerEnum.HARMONIC.getName()); diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/NormalLimitService.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/NormalLimitService.java index f9874645f..6a8e98a18 100644 --- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/NormalLimitService.java +++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/NormalLimitService.java @@ -11,8 +11,6 @@ import com.njcn.prepare.harmonic.pojo.param.LineParam; */ public interface NormalLimitService extends IService { - Boolean getNormLimitData(LineParam lineParam); - Boolean AbnormalLineData(LineParam lineParam); diff --git a/pqs-user/user-api/src/main/java/com/njcn/user/api/DeptFeignClient.java b/pqs-user/user-api/src/main/java/com/njcn/user/api/DeptFeignClient.java index 2ae7c243a..359ebbb4f 100644 --- a/pqs-user/user-api/src/main/java/com/njcn/user/api/DeptFeignClient.java +++ b/pqs-user/user-api/src/main/java/com/njcn/user/api/DeptFeignClient.java @@ -97,4 +97,10 @@ public interface DeptFeignClient { */ @GetMapping("/getSpecialDeptList") HttpResult> getSpecialDeptList(); + + /** + * 获取根部门 + */ + @GetMapping("/getRootDept") + HttpResult getRootDept(); } diff --git a/pqs-user/user-api/src/main/java/com/njcn/user/api/fallback/DeptFeignClientFallbackFactory.java b/pqs-user/user-api/src/main/java/com/njcn/user/api/fallback/DeptFeignClientFallbackFactory.java index 13dc4a4d7..11c48ade5 100644 --- a/pqs-user/user-api/src/main/java/com/njcn/user/api/fallback/DeptFeignClientFallbackFactory.java +++ b/pqs-user/user-api/src/main/java/com/njcn/user/api/fallback/DeptFeignClientFallbackFactory.java @@ -105,6 +105,12 @@ public class DeptFeignClientFallbackFactory implements FallbackFactory getRootDept() { + log.error("{}异常，降级处理，异常为：{}","查询根部门异常",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } }; } } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/controller/DeptController.java b/pqs-user/user-boot/src/main/java/com/njcn/user/controller/DeptController.java index 7e530d26d..7ced83303 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/controller/DeptController.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/controller/DeptController.java @@ -375,6 +375,25 @@ public class DeptController extends BaseController { } + /** + * 获取最高级部门 + * @author cdf + * @date 2023/1/6 + */ + @OperateInfo(info = LogEnum.SYSTEM_COMMON) + @GetMapping("/getRootDept") + @ApiOperation("获取根部门") + public HttpResult getRootDept(){ + String methodDescribe = getMethodDescribe("getRootDept"); + Dept dept = deptService.getRootDept(); + if(Objects.nonNull(dept)){ + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, dept, methodDescribe); + }else { + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe); + } + } + + } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/service/IDeptService.java b/pqs-user/user-boot/src/main/java/com/njcn/user/service/IDeptService.java index 54eb8a9f3..87d9d08e8 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/service/IDeptService.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/service/IDeptService.java @@ -193,4 +193,11 @@ public interface IDeptService extends IService { * @date 2022/12/8 */ List getSpecialDeptList(); + + /** + * 获取根部门 + * @author cdf + * @date 2023/1/6 + */ + Dept getRootDept(); } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/DeptServiceImpl.java b/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/DeptServiceImpl.java index 170b6cda1..e1268cec1 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/DeptServiceImpl.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/DeptServiceImpl.java @@ -364,4 +364,11 @@ public class DeptServiceImpl extends ServiceImpl implements ID lambdaQueryWrapper.eq(Dept::getSpecialType,1).eq(Dept::getState, DataStateEnum.ENABLE.getCode()); return this.list(lambdaQueryWrapper); } + + @Override + public Dept getRootDept(){ + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(Dept::getState,DataStateEnum.ENABLE.getCode()).eq(Dept::getPid,0); + return this.getOne(lambdaQueryWrapper); + } }