From 973c429dc1e46872f340b16337d56e9c2c524d8e Mon Sep 17 00:00:00 2001
From: huangzj <826100833@qq.com>
Date: Tue, 7 Nov 2023 16:41:24 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/njcn/csharmonic/handler/MqttMessageHandler.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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<ThdDataVO> 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);
            });