| | |
|---|
| | | ByteBuf byteBuf = Unpooled.wrappedBuffer(outerPacket.getBody()); |
|---|
| | | //解析封装原元数据 |
|---|
| | | UPConnectReq upConnectReq = new UPConnectReq().decode(byteBuf); |
|---|
| | | log.info("主链路登录请求体：" + JSON.toJSONString(upConnectReq)); |
|---|
| | | Enterprise data = enterpriseClient.getEnterprise(upConnectReq.getUserId() + "").getData(); |
|---|
| | | UPConnectRsp upConnectRsp = new UPConnectRsp(); |
|---|
| | | if (null == data) { |
|---|
| | |
|---|
| | | ctx.flush(); |
|---|
| | | if (upConnectRsp.getResult() == 0x00) { |
|---|
| | | //保存链路 |
|---|
| | | ChannelMap.addServerChannel(outerPacket.getGnsscenterId(), ctx.channel().id()); |
|---|
| | | //从链路连接 TODO 临时注释掉 |
|---|
| | | ChannelMap.addServerChannel(outerPacket.getGnsscenterId(), ctx.channel()); |
|---|
| | | //从链路连接 |
|---|
| | | // downConnect(ctx, outerPacket.getGnsscenterId(), upConnectReq.getDownLinkIp(), upConnectReq.getDownLinkPort(), verifyCode); |
|---|
| | | } else { |
|---|
| | | ctx.close(); |
|---|
