| | |
| | | import com.ard.tianyu.domain.dto.signal.SignalInfo; |
| | | import com.ard.tianyu.domain.dto.state.UavState; |
| | | import com.ard.tianyu.domain.dto.telemetry.TelemetryData; |
| | | import com.ard.tianyu.component.netty.TyNettyTcpClient; |
| | | import com.ard.tianyu.component.netty.NettyTcpClient; |
| | | import com.ard.tianyu.component.netty.command.control.AbsAngleControlCmd; |
| | | import com.ard.tianyu.component.netty.command.control.AngleControlCmd; |
| | | import com.ard.tianyu.component.netty.command.control.SpeedControlCmd; |
| | |
| | | |
| | | //公共日志打印 |
| | | private void logPrint(String message, Object obj) { |
| | | log.warn("收到{}回复{}", message, obj); |
| | | log.debug("收到{}回复{}", message, obj); |
| | | } |
| | | |
| | | //公共日志打印 |
| | |
| | | */ |
| | | private void sendMessage(String key, BaseCmd msg) { |
| | | try { |
| | | ChannelFuture future = TyNettyTcpClient.channels.get(key).getChannelFuture(); |
| | | ChannelFuture future = NettyTcpClient.channels.get(key).getChannelFuture(); |
| | | Channel channel = future.channel(); |
| | | if (channel.isActive()) { |
| | | InetSocketAddress ipSocket = (InetSocketAddress) channel.remoteAddress(); |