|
@ -1,14 +1,14 @@ |
|
|
package com.qyft.ms.device.handler; |
|
|
package com.qyft.ms.device.handler; |
|
|
|
|
|
|
|
|
import cn.hutool.json.JSONUtil; |
|
|
import cn.hutool.json.JSONUtil; |
|
|
import com.qyft.ms.common.constant.WebSocketMessageType; |
|
|
|
|
|
|
|
|
import com.qyft.ms.app.common.constant.WebSocketMessageType; |
|
|
import com.qyft.ms.device.common.constant.TcpMessageType; |
|
|
import com.qyft.ms.device.common.constant.TcpMessageType; |
|
|
import com.qyft.ms.device.common.jsonrpc.JsonRpcResponse; |
|
|
import com.qyft.ms.device.common.jsonrpc.JsonRpcResponse; |
|
|
import com.qyft.ms.device.model.bo.DeviceAlarm; |
|
|
import com.qyft.ms.device.model.bo.DeviceAlarm; |
|
|
import com.qyft.ms.device.model.bo.DeviceFeedback; |
|
|
import com.qyft.ms.device.model.bo.DeviceFeedback; |
|
|
import com.qyft.ms.device.model.bo.DeviceStatus; |
|
|
import com.qyft.ms.device.model.bo.DeviceStatus; |
|
|
import com.qyft.ms.device.service.DeviceStatusService; |
|
|
import com.qyft.ms.device.service.DeviceStatusService; |
|
|
import com.qyft.ms.service.WebSocketService; |
|
|
|
|
|
|
|
|
import com.qyft.ms.app.service.WebSocketService; |
|
|
import io.netty.buffer.ByteBuf; |
|
|
import io.netty.buffer.ByteBuf; |
|
|
import io.netty.channel.ChannelHandler; |
|
|
import io.netty.channel.ChannelHandler; |
|
|
import io.netty.channel.ChannelHandlerContext; |
|
|
import io.netty.channel.ChannelHandlerContext; |
|
|