From bf9e8703cde9c86fa64898cb340762b93be07c19 Mon Sep 17 00:00:00 2001
From: huangzj <826100833@qq.com>
Date: Wed, 30 Aug 2023 16:23:09 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=A8=A1=E5=9D=97=E6=98=A0?=
 =?UTF-8?q?=E5=B0=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../handler/MqttMessageHandler.java           | 26 +++++++++++++++++++
 1 file changed, 26 insertions(+)

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 7ae7939..e30fc24 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
@@ -61,6 +61,9 @@ public class MqttMessageHandler {
     @MqttSubscribe(value = "/zl/askTemperData/{devId}",qos = 1)
     public void responseTemperData(String topic, @NamedValue("devId") String devId, MqttMessage message, @Payload String payload) {
         List<StatisticalDataDTO> statisticalDataDTOS = temperatureService.queryTemperature(devId);
+        statisticalDataDTOS.stream().forEach(temp->{
+            temp.setClDid(getCldidName(temp.getClDid()));
+        });
         Gson gson = new Gson();
         publisher.send("/zl/TemperData/"+devId,gson.toJson(statisticalDataDTOS),1,false);
     }
@@ -172,4 +175,27 @@ public class MqttMessageHandler {
         Gson gson = new Gson();
         publisher.send("/zl/devData/"+devId,gson.toJson(result),1,false);
     }
+
+    public String getCldidName( String cldid) {
+
+        switch (cldid) {
+            case "0":
+                return "主模块";
+            case "1":
+                return "模块1";
+            case "2":
+                return "模块2";
+            case "3":
+                return "模块3";
+            case "4":
+                return "模块4";
+            case "5":
+                return "模块5";
+            case "6":
+                return "模块6";
+            default:
+                break;
+        }
+        return "";
+    }
 }