diff --git a/pqs-gateway/src/main/resources/bootstrap.yml b/pqs-gateway/src/main/resources/bootstrap.yml index a29e7c4cc..f2e7966c3 100644 --- a/pqs-gateway/src/main/resources/bootstrap.yml +++ b/pqs-gateway/src/main/resources/bootstrap.yml @@ -186,6 +186,12 @@ spring: filters: - SwaggerHeaderFilter - StripPrefix=1 + #河北国网总部调用省侧接口,路径总部统一规定 + - id: hb_pms_down + uri: lb://harmonic-boot + predicates: + - Path=/IndexAnalysis/** + #项目日志的配置 logging: @@ -233,9 +239,7 @@ whitelist: - /user-boot/** - /harmonic-boot/** - /user-boot/user/listAllUserByDeptId - - /harmonic-boot/IndexAnalysis/BenchmarkLevelEva/getBaseEvaOnlineBusDetail - - + - /IndexAnalysis/** mqtt: client-id: @artifactId@${random.value} diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/param/UploadDataParam.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/param/UploadDataParam.java index 0501a4f12..a237116dd 100644 --- a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/param/UploadDataParam.java +++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/param/UploadDataParam.java @@ -26,4 +26,13 @@ public class UploadDataParam extends BaseParam { @NotBlank(message = "时间维度不可为空") private String dataType; + @ApiModelProperty("电压等级") + private String voltageLevel; + + @ApiModelProperty("指标类型") + private String targetType; + + @ApiModelProperty("谐波次数") + private Integer harmCount; + } diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/upload/EvaluationDownController.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/upload/EvaluationDownController.java index f1f58f5b5..ab7fbcef3 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/upload/EvaluationDownController.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/upload/EvaluationDownController.java @@ -14,10 +14,7 @@ import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; /** * pqs @@ -91,5 +88,14 @@ public class EvaluationDownController extends BaseController { return new PmsHttpResult<>(0, page); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @GetMapping("/test") + @ApiOperation("国网上送-测试") + public PmsHttpResult> test() { + String methodDescribe = getMethodDescribe("test"); + return new PmsHttpResult<>(0, new PmsPage<>()); + } + + } diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/REvaluationDataServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/REvaluationDataServiceImpl.java index c4099fefb..27dcf132e 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/REvaluationDataServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/REvaluationDataServiceImpl.java @@ -562,6 +562,10 @@ public class REvaluationDataServiceImpl extends ServiceImpl deptRStatIntegrityDList = rStatIntegrityDList.stream().filter(it->runMonitorIds.contains(it.getLineIndex())).collect(toList()); - + int due = deptRStatIntegrityDList.stream().mapToInt(RStatIntegrityD::getDueTime).sum(); + int real = deptRStatIntegrityDList.stream().mapToInt(RStatIntegrityD::getRealTime).sum(); mapKey.forEach((key, val) -> { @@ -353,54 +354,9 @@ public class RUploadPointStatisticalDataDServiceImpl extends MppServiceImpl100 ? 100:rate); - if (due == 0 || real == 0) { - rUploadPointStatisticalDataD.setDataFullRate(BigDecimal.valueOf(0).setScale(4, RoundingMode.HALF_UP).doubleValue()); - } else { - double inVal = BigDecimal.valueOf(real * 100.0 / due).setScale(4, RoundingMode.HALF_UP).doubleValue(); - rUploadPointStatisticalDataD.setDataFullRate(inVal>100?100:inVal); - } - List keyItem; - if(key.equals("9999")){ - //其他 - keyItem = lineDTOList.stream().filter(o -> !val.contains(o.getObjType())).collect(toList()); - }else { - keyItem = lineDTOList.stream().filter(o -> val.contains(o.getObjType())).collect(toList()); - } - long pointCount = keyItem.stream().map(LineDTO::getLineId).distinct().count(); - rUploadPointStatisticalDataD.setStationMonitorNum((int) pointCount); - switch (key) { - case "2100": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Trans_Sub.getCode()).getId()); - break; - case "1200": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Converter.getCode()).getId()); - break; - case "1300": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Ele_Railways.getCode()).getId()); - break; - case "1401": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Wind_Farms.getCode()).getId()); - break; - case "1402": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Power_Station.getCode()).getId()); - break; - case "2300": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Smelting_Load.getCode()).getId()); - break; - case "2400": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Imp_Users.getCode()).getId()); - break; - case "9999": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Station_Other.getCode()).getId()); - break; - } + assDataRate(deptRStatIntegrityDList,due,real,rUploadPointStatisticalDataD); + assStationType(key,val,lineDTOList,dictDataMap,rUploadPointStatisticalDataD); resultPO.add(rUploadPointStatisticalDataD); }); }); @@ -492,58 +448,16 @@ public class RUploadPointStatisticalDataDServiceImpl extends MppServiceImpl100 ? 100:rate); - if (due == 0 || real == 0) { - rUploadPointStatisticalDataD.setDataFullRate(BigDecimal.valueOf(0).setScale(4, RoundingMode.HALF_UP).doubleValue()); - } else { - double inVal = BigDecimal.valueOf(real * 100.0 / due).setScale(4, RoundingMode.HALF_UP).doubleValue(); - rUploadPointStatisticalDataD.setDataFullRate(inVal>100?100:inVal); - } + //fixme over + judgeLevel(dept.getLevel(), rUploadPointStatisticalDataD, dept.getCode(), dept.getName(), deptList, deptMap); - List keyItem; - if(key.equals("9999")){ - //其他 - keyItem = lineDTOList.stream().filter(o -> !val.contains(o.getObjType())).collect(toList()); - }else { - keyItem = lineDTOList.stream().filter(o -> val.contains(o.getObjType())).collect(toList()); - } - long pointCount = keyItem.stream().map(LineDTO::getLineId).distinct().count(); - rUploadPointStatisticalDataD.setStationMonitorNum((int) pointCount); - switch (key) { - case "2100": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Trans_Sub.getCode()).getId()); - break; - case "1200": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Converter.getCode()).getId()); - break; - case "1300": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Ele_Railways.getCode()).getId()); - break; - case "1401": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Wind_Farms.getCode()).getId()); - break; - case "1402": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Power_Station.getCode()).getId()); - break; - case "2300": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Smelting_Load.getCode()).getId()); - break; - case "2400": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Imp_Users.getCode()).getId()); - break; - case "9999": - rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Station_Other.getCode()).getId()); - break; - } + + assDataRate(deptRStatIntegrityDList,due,real,rUploadPointStatisticalDataD); + assStationType(key,val,lineDTOList,dictDataMap,rUploadPointStatisticalDataD); resultPO.add(rUploadPointStatisticalDataD); }); }); @@ -552,7 +466,77 @@ public class RUploadPointStatisticalDataDServiceImpl extends MppServiceImpl val,List lineDTOList,Map dictDataMap,RUploadPointStatisticalDataD rUploadPointStatisticalDataD){ + List keyItem; + if(key.equals("9999")){ + //其他 + keyItem = lineDTOList.stream().filter(o -> !val.contains(o.getObjType())).collect(toList()); + }else { + keyItem = lineDTOList.stream().filter(o -> val.contains(o.getObjType())).collect(toList()); + } + long pointCount = keyItem.stream().map(LineDTO::getLineId).distinct().count(); + rUploadPointStatisticalDataD.setStationMonitorNum((int) pointCount); + switch (key) { + case "2100": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Trans_Sub.getCode()).getId()); + break; + case "1200": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Converter.getCode()).getId()); + break; + case "1300": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Ele_Railways.getCode()).getId()); + break; + case "1401": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Wind_Farms.getCode()).getId()); + break; + case "1402": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Power_Station.getCode()).getId()); + break; + case "2300": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Smelting_Load.getCode()).getId()); + break; + case "2400": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Imp_Users.getCode()).getId()); + break; + case "9999": + rUploadPointStatisticalDataD.setStationType(dictDataMap.get(DicDataEnum.Station_Other.getCode()).getId()); + break; + } + } + /** + * 数据完整性赋值 + * @author cdf + * @date 2024/5/30 + */ + private void assDataRate(List deptRStatIntegrityDList,int due,int real,RUploadPointStatisticalDataD rUploadPointStatisticalDataD){ + rUploadPointStatisticalDataD.setExpectCollectNum(due); + rUploadPointStatisticalDataD.setActualCollectNum(real); + BigDecimal onlineMonitorRate = BigDecimal.ZERO; + if (deptRStatIntegrityDList.size() != 0) { + BigDecimal onlineMonitorNum = BigDecimal.valueOf(rUploadPointStatisticalDataD.getOnlineMonitorNum()); + BigDecimal runMonitorNum = BigDecimal.valueOf(rUploadPointStatisticalDataD.getRunMonitorNum()); + onlineMonitorRate = onlineMonitorNum.multiply(BigDecimal.valueOf(100)) + .divide(runMonitorNum, 4, RoundingMode.HALF_UP); + onlineMonitorRate = onlineMonitorRate.min(BigDecimal.valueOf(100)); // 确保不超过100 + } + rUploadPointStatisticalDataD.setOnlineMonitorRate(onlineMonitorRate.doubleValue()); + + BigDecimal dataFullRate = BigDecimal.ZERO; + if (due != 0 && real != 0) { + BigDecimal realValue = BigDecimal.valueOf(real); + BigDecimal dueValue = BigDecimal.valueOf(due); + dataFullRate = realValue.multiply(BigDecimal.valueOf(100)) + .divide(dueValue, 4, RoundingMode.HALF_UP); + dataFullRate = dataFullRate.min(BigDecimal.valueOf(100)); // 确保不超过100 + } + rUploadPointStatisticalDataD.setDataFullRate(dataFullRate.doubleValue()); + } /** * @param calculatedParam