From 14f604869e1353c942911639c98b7691ff71a8b68e7e95071f5930717148a0fb Mon Sep 17 00:00:00 2001
From: attiya <2413103649@qq.com>
Date: Mon, 3 Nov 2025 09:42:42 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E5=A4=87=E5=9C=A8=E7=BA=BF=E6=A3=80?=
 =?UTF-8?q?=E6=B5=8B=E5=8A=9F=E8=83=BD=E5=AE=8C=E5=96=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/EbikeEcuInfoServiceImpl.java        | 12 ++++++------
 .../com/cdzy/operations/utils/EmqxApiClient.java     |  8 ++++++++
 2 files changed, 14 insertions(+), 6 deletions(-)

diff --git a/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeEcuInfoServiceImpl.java b/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeEcuInfoServiceImpl.java
index 5255524..fe78e13 100644
--- a/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeEcuInfoServiceImpl.java
+++ b/ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeEcuInfoServiceImpl.java
@@ -112,12 +112,12 @@ public class EbikeEcuInfoServiceImpl extends ServiceImpl<EbikeEcuInfoMapper, Ebi
     @Override
     public boolean online(String ecuSn, String bikeCode) throws IOException {
         check(ecuSn, bikeCode);
-        if (StringUtil.hasText(ecuSn)) {
-            checkEcuSn(ecuSn);
-        } else {
-            EbikeEcuInfo ebikeEcuInfo = getEcu(bikeCode);
-            ecuSn = ebikeEcuInfo.getEcuSn();
-        }
+//        if (StringUtil.hasText(ecuSn)) {
+//            checkEcuSn(ecuSn);
+//        } else {
+//            EbikeEcuInfo ebikeEcuInfo = getEcu(bikeCode);
+//            ecuSn = ebikeEcuInfo.getEcuSn();
+//        }
         return EmqxApiClient.isClientOnline(ecuSn);
     }
 
diff --git a/ebike-operations/src/main/java/com/cdzy/operations/utils/EmqxApiClient.java b/ebike-operations/src/main/java/com/cdzy/operations/utils/EmqxApiClient.java
index 4a40138..fe02f97 100644
--- a/ebike-operations/src/main/java/com/cdzy/operations/utils/EmqxApiClient.java
+++ b/ebike-operations/src/main/java/com/cdzy/operations/utils/EmqxApiClient.java
@@ -77,6 +77,14 @@ public class EmqxApiClient {
 
         String response = executeRequest(request);
         JsonNode jsonNode = mapper.readValue(response,JsonNode.class);
+       try {
+           JsonNode node = jsonNode.get("code");
+           if (node!=null && node.asInt() != 200) {
+               return false;
+           }
+       }catch (Exception e){
+           return false;
+       }
         return jsonNode.get("connected").asBoolean();
     }