#发电负荷

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/AnalyseDataServiceImpl.java

@@ -73,10 +73,12 @@ public class AnalyseDataServiceImpl implements IAnalyseDataService {
 		analyzeDataConditionPO.setEndTime(LocalDateTime.parse(DateUtil.format(new Date(), endTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
 		signboardConditions.add(analyzeDataConditionPO);
 		po.setSignboardConditions(signboardConditions);
+		log.error("period_target_data_request {}",po);
 		R<List<AnalyzeDataConditionVO>> result = analyseDataSearchClient.getAnalyzeDataByAnalyzeCodeAndSignages(po);
 		if (!result.isSuccess() || CollectionUtil.isEmpty(result.getData())) {
 			return new ArrayList<>();
 		}
+		log.error("period_target_data_resp {}",result);
 		return result.getData().get(0).getList();
 	}
 

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java

@@ -749,7 +749,12 @@ public class HydropowerServiceImpl implements HydropowerService {
 		if(CollectionUtil.isEmpty(realList)){
 			return 0.0;
 		}
-		return realList.stream().filter(o->deptId.equals(o.getDeptId())).mapToDouble(HydropowerUnitRealVo::getActivePower).sum();
+		return realList.stream().filter(o->deptId.equals(o.getDeptId())).mapToDouble(o->{
+			if("MW".equalsIgnoreCase(o.getPowerUnit())){
+				return o.getActivePower() * 1000;
+			}
+			return o.getActivePower();
+		}).sum();
 	}
 
 	/**
@@ -1006,7 +1011,12 @@ public class HydropowerServiceImpl implements HydropowerService {
 				// 容量
 				kpi.setInstalledCapacity(reals.stream().mapToDouble(HydropowerUnitRealVo::getInstalledCapacity).sum());
 				// 负荷
-				kpi.setLoad(reals.stream().mapToDouble(HydropowerUnitRealVo::getActivePower).sum());
+				kpi.setLoad(reals.stream().mapToDouble(o->{
+					if("MW".equalsIgnoreCase(o.getPowerUnit())){
+						return o.getActivePower() * 1000;
+					}
+					return o.getActivePower();
+				}).sum());
 				// 容量利用率
 				if (Math.abs(kpi.getInstalledCapacity()) <= 0) {
 					kpi.setCapacityRate(0.0);
@@ -1105,7 +1115,12 @@ public class HydropowerServiceImpl implements HydropowerService {
 			// 实时数据: 容量利用率、电站利用率
 			if(CollectionUtil.isNotEmpty(reals)){
 				// 实时功率
-				double use = reals.stream().filter(real->entry.getValue().stream().map(StationEntity::getRefDept).collect(Collectors.toList()).contains(real.getDeptId())).mapToDouble(HydropowerUnitRealVo::getActivePower).sum();
+				double use = reals.stream().filter(real->entry.getValue().stream().map(StationEntity::getRefDept).collect(Collectors.toList()).contains(real.getDeptId())).mapToDouble(o->{
+					if("MW".equalsIgnoreCase(o.getPowerUnit())){
+						return o.getActivePower() * 1000;
+					}
+					return o.getActivePower();
+				}).sum();
 				if(CollectionUtil.isNotEmpty(plans)){
 					// 装机容量
 					double capacity = reals.stream().filter(real-> entry.getValue().stream().map(StationEntity::getRefDept).collect(Collectors.toList()).contains(real.getDeptId())).mapToDouble(HydropowerUnitRealVo::getInstalledCapacity).sum();