diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryC.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryC.java index 01e22a505..0747d51f1 100644 --- a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryC.java +++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryC.java @@ -13,7 +13,7 @@ public class HarmonicHistoryC { private String tg_id; //数据id private String id; - //相位标识 + //相位标识 0-总 1-A相 2-B相 3-C相 private Integer phase_flag; //时间 private String ds; diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryV.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryV.java index 38a1553c3..00c32a00a 100644 --- a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryV.java +++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/zt/HarmonicHistoryV.java @@ -13,7 +13,7 @@ public class HarmonicHistoryV { private String tg_id; //数据id private String id; - //相位标识 + //相位标识 1-A相 2-B相 3-C相 private Integer phase_flag; //时间 private String ds; diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/OracleResultServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/OracleResultServiceImpl.java index 8c5aee421..5a5c428ee 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/OracleResultServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/OracleResultServiceImpl.java @@ -745,19 +745,12 @@ public class OracleResultServiceImpl implements OracleResultService { break; case 50: //谐波有功功率 - if(type==0) { - harmonicHistoryData = HistoryDataMapper.getDataHarmpowerP_p(historyParam, number); - }else{ - harmonicHistoryData =ztHarmonicHistoryP(historyParam,1); - } + harmonicHistoryData = HistoryDataMapper.getDataHarmpowerP_p(historyParam, number); break; case 51: //谐波无功功率 - if(type==0) { - harmonicHistoryData=HistoryDataMapper.getDataHarmpowerQ_q(historyParam,number); - }else{ - harmonicHistoryData =ztHarmonicHistoryP(historyParam,0); - } + harmonicHistoryData=HistoryDataMapper.getDataHarmpowerQ_q(historyParam,number); + break; case 52: //谐波视在功率 @@ -765,11 +758,19 @@ public class OracleResultServiceImpl implements OracleResultService { break; case 53: //三相有功功率 - harmonicHistoryData=HistoryDataMapper.getDataHarmpowerP(historyParam); + if(type==0) { + harmonicHistoryData=HistoryDataMapper.getDataHarmpowerP(historyParam); + }else{ + harmonicHistoryData =ztHarmonicHistoryP(historyParam,1); + } break; case 54: //三相无功功率 - harmonicHistoryData=HistoryDataMapper.getDataHarmpowerQ(historyParam); + if(type==0) { + harmonicHistoryData=HistoryDataMapper.getDataHarmpowerQ(historyParam); + }else{ + harmonicHistoryData =ztHarmonicHistoryP(historyParam,2); + } break; case 55: //三相视在功率 @@ -781,18 +782,26 @@ public class OracleResultServiceImpl implements OracleResultService { break; case 57: //三相总无功功率 + if(type==0) { harmonicHistoryData=HistoryDataMapper.getDataHarmpowerQ_t(historyParam); + }else{ + harmonicHistoryData =ztHarmonicHistoryP(historyParam,3); + } break; case 58: //三相总视在功率 - harmonicHistoryData=HistoryDataMapper.getDataHarmpowerS_t(historyParam); + if(type==0) { + harmonicHistoryData=HistoryDataMapper.getDataHarmpowerS_t(historyParam); + }else{ + harmonicHistoryData =ztHarmonicHistoryP(historyParam,4); + } break; case 59: //视在功率因数 if(type==0) { harmonicHistoryData=HistoryDataMapper.getDataHarmpowerP_pf(historyParam); }else{ - harmonicHistoryData =ztHarmonicHistoryC(historyParam); + harmonicHistoryData =ztHarmonicHistoryC(historyParam,1); } break; case 591: @@ -801,7 +810,11 @@ public class OracleResultServiceImpl implements OracleResultService { break; case 592: //总视在功率因数 - harmonicHistoryData=HistoryDataMapper.getDataHarmpowerP_pf_T(historyParam); + if(type==0) { + harmonicHistoryData=HistoryDataMapper.getDataHarmpowerP_pf_T(historyParam); + }else{ + harmonicHistoryData =ztHarmonicHistoryC(historyParam,2); + } break; case 593: //总位移功率因数 @@ -871,7 +884,7 @@ public class OracleResultServiceImpl implements OracleResultService { return ztDataP(harmonicHistory,type); } //功率因数 - private List ztHarmonicHistoryC(HarmonicHistoryParam historyParam) { + private List ztHarmonicHistoryC(HarmonicHistoryParam historyParam,Integer type) { String id = historyParam.getLineId(); String starTime = historyParam.getStartTime(); String endTime = historyParam.getEndTime(); @@ -881,7 +894,7 @@ public class OracleResultServiceImpl implements OracleResultService { String apiId = "9c3ebd9c19dc0eb8e24385e40bd50a53"; String apiName = "get_电能质量谐波监测系统_分布式光伏台区功率因数日数据_e_mp_TGfactor_zl_时间"; List harmonicHistory = adsDiList(HarmonicHistoryC.class, id, starTime, endTime, key, secret, url, apiId, apiName); - return ztDataC(harmonicHistory); + return ztDataC(harmonicHistory,type); } /** @@ -1064,21 +1077,32 @@ public class OracleResultServiceImpl implements OracleResultService { List info=new ArrayList<>(); HarmonicHistoryData d; //a - List a; + List a= new ArrayList<>(); //b - List b; + List b= new ArrayList<>(); //c - List c; - //1:有功 0:无功 + List c = new ArrayList<>(); + //1:三相有功 if(type==1){ a = value.stream().filter(x -> x.getData_type() == 2).distinct().collect(Collectors.toList()); b = value.stream().filter(x -> x.getData_type() == 3).distinct().collect(Collectors.toList()); c = value.stream().filter(x -> x.getData_type() == 4).distinct().collect(Collectors.toList()); - }else{ + } + //2:三相无功 + if(type==2){ a = value.stream().filter(x -> x.getData_type() == 6).distinct().collect(Collectors.toList()); b = value.stream().filter(x -> x.getData_type() == 7).distinct().collect(Collectors.toList()); c = value.stream().filter(x -> x.getData_type() == 8).distinct().collect(Collectors.toList()); } + //3:总有功 + if(type==3){ + a = value.stream().filter(x -> x.getData_type() == 1).distinct().collect(Collectors.toList()); + } + //4:总无功 + if(type==4){ + a = value.stream().filter(x -> x.getData_type() == 5).distinct().collect(Collectors.toList()); + } + Integer num=97; //15分钟增加信息 Duration duration = Duration.ofMinutes(15); @@ -1096,7 +1120,7 @@ public class OracleResultServiceImpl implements OracleResultService { } d.setTimeId(parse.toInstant(ZoneOffset.UTC)); d.setPhasicType("A"); - d.setAValue(reflectDataP(harmonicHistoryP,"u"+i)); + d.setAValue(reflectDataP(harmonicHistoryP,"p"+i)); info.add(d); } } @@ -1113,7 +1137,7 @@ public class OracleResultServiceImpl implements OracleResultService { } d.setTimeId(parse.toInstant(ZoneOffset.UTC)); d.setPhasicType("B"); - d.setAValue(reflectDataP(harmonicHistoryP,"u"+i)); + d.setAValue(reflectDataP(harmonicHistoryP,"p"+i)); info.add(d); } @@ -1131,7 +1155,7 @@ public class OracleResultServiceImpl implements OracleResultService { } d.setTimeId(parse.toInstant(ZoneOffset.UTC)); d.setPhasicType("C"); - d.setAValue(reflectDataP(harmonicHistoryP,"u"+i)); + d.setAValue(reflectDataP(harmonicHistoryP,"p"+i)); info.add(d); } @@ -1161,15 +1185,25 @@ public class OracleResultServiceImpl implements OracleResultService { * @param value * @return */ - private List ztDataC(List value) { + private List ztDataC(List value,Integer type) { List info=new ArrayList<>(); HarmonicHistoryData d; //a - List a= value.stream().filter(x -> x.getPhase_flag() == 1).collect(Collectors.toList()); + List a= new ArrayList<>(); //b - List b= value.stream().filter(x -> x.getPhase_flag() == 2).distinct().collect(Collectors.toList()); + List b= new ArrayList<>(); //c - List c= value.stream().filter(x -> x.getPhase_flag() == 3).distinct().collect(Collectors.toList()); + List c = new ArrayList<>(); + //1:视在功率因数 + if(type==1){ + a = value.stream().filter(x -> x.getPhase_flag() == 1).distinct().collect(Collectors.toList()); + b = value.stream().filter(x -> x.getPhase_flag() == 2).distinct().collect(Collectors.toList()); + c = value.stream().filter(x -> x.getPhase_flag() == 3).distinct().collect(Collectors.toList()); + } + //2:总视在功率因数 + if(type==2){ + a = value.stream().filter(x -> x.getPhase_flag() == 0).distinct().collect(Collectors.toList()); + } Integer num=97; //15分钟增加信息 @@ -1188,7 +1222,7 @@ public class OracleResultServiceImpl implements OracleResultService { } d.setTimeId(parse.toInstant(ZoneOffset.UTC)); d.setPhasicType("A"); - d.setAValue(reflectDataC(harmonicHistoryC,"u"+i)); + d.setAValue(reflectDataC(harmonicHistoryC,"c"+i)); info.add(d); } } @@ -1205,7 +1239,7 @@ public class OracleResultServiceImpl implements OracleResultService { } d.setTimeId(parse.toInstant(ZoneOffset.UTC)); d.setPhasicType("B"); - d.setAValue(reflectDataC(harmonicHistoryC,"u"+i)); + d.setAValue(reflectDataC(harmonicHistoryC,"c"+i)); info.add(d); } @@ -1223,7 +1257,7 @@ public class OracleResultServiceImpl implements OracleResultService { } d.setTimeId(parse.toInstant(ZoneOffset.UTC)); d.setPhasicType("C"); - d.setAValue(reflectDataC(harmonicHistoryC,"u"+i)); + d.setAValue(reflectDataC(harmonicHistoryC,"c"+i)); info.add(d); }