1、把倾角计数据的处理挪到一个新的服务InclineServer
2、InclineServer处理D350,推送第三方
This commit is contained in:
parent
bfca030420
commit
353e94cd05
@ -32,11 +32,11 @@ public class RtcmUdpHandler extends ChannelInboundHandlerAdapter {
|
|||||||
if (packet.content() == null) {
|
if (packet.content() == null) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
/*if (logger.isDebugEnabled()) {
|
if (logger.isDebugEnabled()) {
|
||||||
byte[] data = new byte[packet.content().readableBytes()];
|
byte[] data = new byte[packet.content().readableBytes()];
|
||||||
packet.content().getBytes(0, data);
|
packet.content().getBytes(0, data);
|
||||||
logger.debug("receive message:" + DataTypeUtil.getHexString(data));
|
logger.debug("receive message:" + DataTypeUtil.getHexString(data));
|
||||||
}*/
|
}
|
||||||
// 消息解析
|
// 消息解析
|
||||||
BaseMessage message = MessageParser.instance.parse(packet.content());
|
BaseMessage message = MessageParser.instance.parse(packet.content());
|
||||||
OnlineChannels.INSTANCE.updateDataChannel(message.getId(), ctx.channel(), packet.sender());
|
OnlineChannels.INSTANCE.updateDataChannel(message.getId(), ctx.channel(), packet.sender());
|
||||||
|
|||||||
@ -96,7 +96,7 @@ public class InclineDataForwarder{
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void send(GnssDeviceJoin device, D350SurfaceInclineMessage message){
|
public void send(GnssDeviceJoin device, D350SurfaceInclineMessage message){
|
||||||
logger.debug("forward {}: {}",device.getDeviceid(), message.getInclineData().toString());
|
//logger.debug("forward {}: {}",device.getDeviceid(), message.getInclineData().toString());
|
||||||
InclineData inclineData = new InclineData();
|
InclineData inclineData = new InclineData();
|
||||||
|
|
||||||
inclineData.setProjectID(device.getProject_id());
|
inclineData.setProjectID(device.getProject_id());
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user