diff --git a/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java b/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java index f176aeb..2ed49b1 100644 --- a/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java +++ b/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java @@ -58,10 +58,17 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { //通知客户端链接建立成功 // 默认返回取得时间成功 String ackAckCheckRef = "233E0101020004020A1D"; - if (Integer.parseInt(nettyServerConfig.getPosAsycServerPort()) == channel.localAddress().getPort()) { +// if (Integer.parseInt(nettyServerConfig.getPosAsycServerPort()) == channel.localAddress().getPort()) { +// ackAckCheckRef = "233E010102000401091C"; +// } +// if (Integer.parseInt(nettyServerConfig.getStarsAsycServerPort()) == channel.localAddress().getPort()) { +// ackAckCheckRef = "233E010102000421293C"; +// } + + if (9013 == channel.localAddress().getPort()) { ackAckCheckRef = "233E010102000401091C"; } - if (Integer.parseInt(nettyServerConfig.getStarsAsycServerPort()) == channel.localAddress().getPort()) { + if (9012 == channel.localAddress().getPort()) { ackAckCheckRef = "233E010102000421293C"; } //String str = "通知客户端链接建立成功" + " " + LocalDateTime.now() + " " + channel.localAddress().getHostString() + @@ -107,11 +114,16 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { // if (Integer.parseInt(posAsycServerPort) == channel.localAddress().getPort()) { if (AST_POS_CMD.equals(recvmg)) { +// channelAns = dipperAstPosAsyncTaskService.pushAstPos(ipAddress, +// positionConfig.getCenterProvinceFilePath(), +// positionConfig.getCenterProvince(), +// positionConfig.getIpPositionRequestPath(), +// positionConfig.getIpPositionRequestKey()); channelAns = dipperAstPosAsyncTaskService.pushAstPos(ipAddress, - positionConfig.getCenterProvinceFilePath(), - positionConfig.getCenterProvince(), - positionConfig.getIpPositionRequestPath(), - positionConfig.getIpPositionRequestKey()); + "/csv/provinceLonAlt.csv", + "湖北省", + "https://restapi.amap.com/v3/ip", + "65e794b0a1a4b87eeec86f93fea05411"); buf = Unpooled.buffer(channelAns.getBytes().length); }