From 00ff1a5f0146987b38e9584d64ff719c4ec0a623 Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期五, 06 十月 2023 16:10:56 +0800
Subject: [PATCH] 雷达

---
 src/main/java/com/ard/utils/tcp/ClientHandler.java |   14 ++++++--------
 1 files changed, 6 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/ard/utils/tcp/ClientHandler.java b/src/main/java/com/ard/utils/tcp/ClientHandler.java
index e4c4479..856cc9b 100644
--- a/src/main/java/com/ard/utils/tcp/ClientHandler.java
+++ b/src/main/java/com/ard/utils/tcp/ClientHandler.java
@@ -194,7 +194,7 @@
             // log.info("鏈夋晥璐熻浇澶у皬(杞暣鍨�):" + payloadSizeToDecimal);
             //endregion
             List<ArdAlarmRadar> radarAlarmInfos = new ArrayList<>();
-            //鎶芥补鏈烘柊鎺ㄩ�侀泦鍚�
+            //鎶芥补鏈虹姸鎬侀浄杈炬帹閫侀泦鍚�
             List<ArdAlarmRadar> well = new ArrayList<>();
             String alarmTime = "";
             Integer targetNum = 0;
@@ -383,8 +383,8 @@
                     //log.info("鎵�灞炵粍:" + Grp);
                     //endregion
                     String alarmType;
-                    //鏂伴泦鍚堜腑杩愯鍙橀噺
-                    String wellType = "杩愯";
+                    //鎶芥补鏈虹姸鎬佸彉閲�
+                    String wellType;
                     byte[] cStat = Arrays.copyOfRange(data, index + 23, index + 24);
                     cStat = ByteUtils.toLittleEndian(cStat);
                     //String binaryString = String.format("%8s", Integer.toBinaryString(cStat[0] & 0xFF)).replace(' ', '0');
@@ -408,12 +408,10 @@
                         wellType = "鍋滄満";
                     } else {
                         wellType = "杩愯";
-//                        continue;
                     }
-                    //鏂扮殑闆嗗悎涓鍏ユ暟鎹�
+                    //鎶芥补鏈虹姸鎬侀泦鍚堜腑瑁呭叆鏁版嵁
                     byte[] szName = Arrays.copyOfRange(data, index + 32, index + 64);
                     String alarmPointName = ByteUtils.bytesToStringZh(szName);
-                    //log.info("鎶ヨ绫诲瀷:" + alarmType);
                     ArdAlarmRadar wellAlarm = new ArdAlarmRadar();
                     wellAlarm.setTargetId(id);
                     wellAlarm.setName(alarmPointName);
@@ -434,9 +432,9 @@
             radarAlarmData.setAlarmTime(alarmTime);
             radarAlarmData.setArdAlarmRadars(radarAlarmInfos);
             MqttConsumer.publish(2, false, "radar", JSON.toJSONString(radarAlarmData));
-            //鏂扮殑MQTT闃熷垪
+            //鎶芥补鏈虹姸鎬丮QTT闃熷垪
             radarAlarmData.setArdAlarmRadars(well);
-            MqttConsumer.publish(2, false, "well", JSON.toJSONString(radarAlarmData));
+            MqttConsumer.publish(2, false, "radarWellData", JSON.toJSONString(radarAlarmData));
         } catch (Exception ex) {
             log.error("闆疯揪鎶ユ枃瑙f瀽寮傚父:" + ex.getMessage());
         }

--
Gitblit v1.9.3