puzhibing
2025-05-26 8c6849d98fc168369d6de2d94d2f42a6d67cd9c5
ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/UPLinkTestReqService.java
@@ -22,6 +22,9 @@
   
   @Resource
   private RedisTemplate redisTemplate;
   @Resource
   private DOWNConnectRspService downConnectRspService;
   
   
   /**
@@ -32,7 +35,7 @@
    */
   public void linkTest(ChannelHandlerContext ctx, OuterPacket out) {
      if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) {
         log.error("链路还未登录校验,拒绝连接");
         log.error("链路还未登录校验,拒绝连接:{}", out.getGnsscenterId());
         ctx.close();
         return;
      }
@@ -43,5 +46,7 @@
      rep.setGnsscenterId(gnsscenterId);
      log.info("主链路连接保持应答({}):{}", DataType.UP_LINKTEST_RSP.getCode(), JSON.toJSONString(rep));
      ctx.writeAndFlush(rep);
      //从链路保持请求
      downConnectRspService.downLinkTest(gnsscenterId);
   }
}