|
|
@ -44,6 +44,7 @@ public class DeviceMessageHandler extends ChannelInboundHandlerAdapter { |
|
|
|
DeviceStatus deviceStatus = JSONUtil.toBean(jsonRpcResponse.getData(), DeviceStatus.class); |
|
|
|
deviceStateService.updateDeviceStatus(deviceStatus); // 更新设备状态 |
|
|
|
} else if (TcpMessageType.ALARM.equals(jsonRpcResponse.getType())) {//设备报警 |
|
|
|
log.error("设备报警: {}", serverMsg); |
|
|
|
DeviceAlarm deviceAlarm = JSONUtil.toBean(jsonRpcResponse.getData(), DeviceAlarm.class); |
|
|
|
webSocketService.pushMsg(WebSocketMessageType.ALARM, deviceAlarm); |
|
|
|
} else if (TcpMessageType.FEEDBACK.equals(jsonRpcResponse.getType())) {//设备指令反馈 |
|
|
|