Ver código fonte

修改到docker外运行环境

tags/v1.0.0^2
林万龙 3 anos atrás
pai
commit
233dc29bbb
1 arquivos alterados com 18 adições e 18 exclusões
  1. +18
    -18
      src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java

+ 18
- 18
src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java Ver arquivo

@@ -58,19 +58,19 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
//通知客户端链接建立成功
// 默认返回取得时间成功
String ackAckCheckRef = "233E0101020004020A1D";
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()) {
// if (Integer.parseInt(nettyServerConfig.getPosAsycServerPort()) == channel.localAddress().getPort()) {
// ackAckCheckRef = "233E010102000401091C";
// }
// if (9012 == channel.localAddress().getPort()) {
// if (Integer.parseInt(nettyServerConfig.getStarsAsycServerPort()) == channel.localAddress().getPort()) {
// ackAckCheckRef = "233E010102000421293C";
// }

if (9013 == channel.localAddress().getPort()) {
ackAckCheckRef = "233E010102000401091C";
}
if (9012 == channel.localAddress().getPort()) {
ackAckCheckRef = "233E010102000421293C";
}
//String str = "通知客户端链接建立成功" + " " + LocalDateTime.now() + " " + channel.localAddress().getHostString() +
// "\r\n";
ByteBuf buf = Unpooled.buffer(ackAckCheckRef.getBytes().length);
@@ -113,16 +113,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,
// "/csv/provinceLonAlt.csv",
// "湖北省",
// "https://restapi.amap.com/v3/ip",
// "65e794b0a1a4b87eeec86f93fea05411");
// positionConfig.getCenterProvinceFilePath(),
// positionConfig.getCenterProvince(),
// positionConfig.getIpPositionRequestPath(),
// positionConfig.getIpPositionRequestKey());
channelAns = dipperAstPosAsyncTaskService.pushAstPos(ipAddress,
"/csv/provinceLonAlt.csv",
"湖北省",
"https://restapi.amap.com/v3/ip",
"65e794b0a1a4b87eeec86f93fea05411");
}

// 从缓存获取SDBP-AST-EPH星历数


Carregando…
Cancelar
Salvar