diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/handler/MqttMessageHandler.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/handler/MqttMessageHandler.java index 239d350..4709607 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/handler/MqttMessageHandler.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/handler/MqttMessageHandler.java @@ -214,6 +214,8 @@ public class MqttMessageHandler { Double capacity = devCapacityFeignClient.getDevCapacity(devId).getData(); //获取输出电流计算负载率 List iTolOut = tempList.stream().filter(temp -> Objects.equals(temp.getStatisticalName(), "Apf_RmsI_TolOut(A)")).collect(Collectors.toList()); + result.addAll(iTolOut); + iTolOut.forEach(temp->{ ThdDataVO thdDataVO = new ThdDataVO(); BeanUtils.copyProperties(temp,thdDataVO); @@ -226,7 +228,7 @@ public class MqttMessageHandler { thdDataVO.setStatisticalData(Double.valueOf(df.format(v))); } - + result.add(thdDataVO); });