添加联网记录

device-api-service/src/main/java/com/xy/config/DeviceThreadPoolConfig.java

@@ -65,7 +65,7 @@ public class DeviceThreadPoolConfig {
                 .keepAlive(60)
                 .queueSize(coreSize * 10)
                 .rejected((r, executor) -> {
-                    throw new CommRuntimeException("统计消费者线程池已满");
+                    throw new CommRuntimeException("设备上下线消费者线程池已满");
                 })
                 .builder();
     }

device-api-service/src/main/java/com/xy/consumer/connected/ConnectedConsumer.java

@@ -57,7 +57,7 @@ public class ConnectedConsumer implements MqttConsumer {
                     DeviceNetRecordDto.Save save = new DeviceNetRecordDto.Save()
                             .setDeviceId(deviceId);
                     save.setNetStatus(netState);
-                    deviceNetRecordService.save(new DeviceNetRecordDto.Save());
+                    deviceNetRecordService.save(save);
                 });
         return true;
     }