更新！

OneCardIotServer/src/main/java/com/zhongshu/iot/server/core/domain/iot/mqtt/DeviceOnLineInfo.java

@@ -35,4 +35,5 @@ public class DeviceOnLineInfo extends SuperEntity {
 
     @Indexed(expireAfterSeconds = 0)
     private Date TTL;
+
 }

OneCardIotServer/src/main/java/com/zhongshu/iot/server/core/listener/MongodbAutoEvent.java

@@ -4,10 +4,7 @@ import com.zhongshu.iot.server.core.service.mqtt.DevicePingInfoService;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.mapping.event.AbstractMongoEventListener;
-import org.springframework.data.mongodb.core.mapping.event.AfterDeleteEvent;
-import org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent;
-import org.springframework.data.mongodb.core.mapping.event.BeforeConvertEvent;
+import org.springframework.data.mongodb.core.mapping.event.*;
 import org.springframework.stereotype.Component;
 
 @Component
@@ -30,9 +27,16 @@ public class MongodbAutoEvent extends AbstractMongoEventListener<Object> {
         log.info("onAfterSave");
     }
 
+    @Override
+    public void onBeforeDelete(BeforeDeleteEvent<Object> event) {
+        log.info("onBeforeDelete");
+        super.onBeforeDelete(event);
+    }
+
     @Override
     public void onAfterDelete(AfterDeleteEvent<Object> event) {
         log.info("onAfterDelete--- ");
+        super.onAfterDelete(event);
         Object source = event.getSource();
         try {
             log.info("onAfterDelete 删除了数据...");

OneCardIotServer/src/main/java/com/zhongshu/iot/server/core/service/mqtt/DevicePingInfoService.java

@@ -138,7 +138,7 @@ public class DevicePingInfoService extends SuperService {
                 devicePingInfoDao.save(devicePingInfo);
 
                 // 网关在线状态
-                updateDeviceOnLine(gateWayInfo.getGateWayId(), gateWayInfo.getGateWayName(), OnLineDeviceType.GateWay);
+//                updateDeviceOnLine(gateWayInfo.getGateWayId(), gateWayInfo.getGateWayName(), OnLineDeviceType.GateWay);
             }
         }
         pingResult.setSuccess();