diff --git a/src/main/java/com/qyft/ms/system/service/device/DeviceCommandService.java b/src/main/java/com/qyft/ms/system/service/device/DeviceCommandService.java index 7751abb..0e733d7 100644 --- a/src/main/java/com/qyft/ms/system/service/device/DeviceCommandService.java +++ b/src/main/java/com/qyft/ms/system/service/device/DeviceCommandService.java @@ -33,6 +33,7 @@ public class DeviceCommandService { commandFutureMap.put(cmdToDevice.getCommandId(), cmdFuture); if (!deviceTcpClient.sendToJSON(cmdToDevice)) { commandFutureMap.remove(cmdToDevice.getCommandId()); + throw new RuntimeException("向设备发送指令失败"); } cmdFuture.getResponseFuture().whenComplete((result, ex) ->