Microservice/govern
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改bug

Browse Source
This commit is contained in:
huangzj
2023-11-07 16:41:24 +08:00
parent 91e2c883f1
commit 973c429dc1
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/handler/MqttMessageHandler.java
View File

@@ -214,6 +214,8 @@ public class MqttMessageHandler {
Double capacity = devCapacityFeignClient.getDevCapacity(devId).getData(); Double capacity = devCapacityFeignClient.getDevCapacity(devId).getData();
//获取输出电流计算负载率 //获取输出电流计算负载率
List<ThdDataVO> iTolOut = tempList.stream().filter(temp -> Objects.equals(temp.getStatisticalName(), "Apf_RmsI_TolOut(A)")).collect(Collectors.toList()); List<ThdDataVO> iTolOut = tempList.stream().filter(temp -> Objects.equals(temp.getStatisticalName(), "Apf_RmsI_TolOut(A)")).collect(Collectors.toList());
result.addAll(iTolOut);
iTolOut.forEach(temp->{ iTolOut.forEach(temp->{
ThdDataVO thdDataVO = new ThdDataVO(); ThdDataVO thdDataVO = new ThdDataVO();
BeanUtils.copyProperties(temp,thdDataVO); BeanUtils.copyProperties(temp,thdDataVO);
@@ -226,7 +228,7 @@ public class MqttMessageHandler {
thdDataVO.setStatisticalData(Double.valueOf(df.format(v))); thdDataVO.setStatisticalData(Double.valueOf(df.format(v)));
} }
result.add(thdDataVO);
}); });