From ed156a00f98e250ddc87c01e74a1ad5d16b3247b Mon Sep 17 00:00:00 2001
From: jay <75509151@qq.com>
Date: Wed, 29 May 2024 13:58:51 +0800
Subject: [PATCH] =?UTF-8?q?add=20=E8=AE=BE=E5=A4=87=E6=9C=80=E5=90=8E?=
 =?UTF-8?q?=E9=80=9A=E8=AE=AF=E6=97=B6=E9=97=B4=20fix=20DeviceStateCheckTa?=
 =?UTF-8?q?sk,=E5=8F=96=E8=AE=BE=E5=A4=87=E6=9C=80=E5=90=8E=E9=80=9A?=
 =?UTF-8?q?=E8=AE=AF=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iotkit/plugins/mqtt/service/MqttVerticle.java | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java b/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java
index 674db69..c956bc7 100755
--- a/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java
+++ b/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java
@@ -215,6 +215,9 @@ public class MqttVerticle extends AbstractVerticle implements Handler<MqttEndpoi
             endpointMap.remove(deviceName);
             MQTT_CONNECT_POOL.put(clientId, false);
             DEVICE_ONLINE.clear();
+        }).pingHandler(msg->{
+            // 心跳 ping
+            ping(productKey,deviceName);
         }).subscribeHandler(subscribe -> {
             List<MqttSubAckReasonCode> reasonCodes = new ArrayList<>();
             for (MqttTopicSubscription s : subscribe.topicSubscriptions()) {
@@ -418,6 +421,18 @@ public class MqttVerticle extends AbstractVerticle implements Handler<MqttEndpoi
         }
     }
 
+    private void ping(String productKey, String deviceName) {
+        thingService.post(
+                pluginInfo.getPluginId(),
+                fillAction(
+                        DevicePing.builder()
+                                .productKey(productKey)
+                                .deviceName(deviceName)
+                                .build()
+                )
+        );
+    }
+
     private void offline(String productKey, String deviceName) {
         thingService.post(
                 pluginInfo.getPluginId(),