修改生产环境配置

Pu Zhibing

2025-07-18 fdfa8b3b237d8bba8964bda67364f54c08d79432

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java

@@ -98,28 +98,6 @@
      
   }
   
	
   @Override
   public void channelActive(ChannelHandlerContext ctx) throws Exception {
      log.info("Netty客户端链接成功");
      super.channelActive(ctx);
   }
	
	
   @Override
   public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
      log.info("Netty客户端连链接常关闭");
      cause.printStackTrace();
      ctx.close();
   }
	
   @Override
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {
      log.info("Netty客户端离线");
      super.channelInactive(ctx);
   }
	
	
   /**
    * 业务路由
    *
@@ -128,54 +106,73 @@
    * @param out
    */
   public void serviceRouting(DataType dataType, ChannelHandlerContext ctx, OuterPacket out) {
      log.info("主链路信息交换响应({})：{}", dataType.getCode(), out);
      log.debug("主链路信息交换响应({})：{}", dataType.getCode(), out);
      switch (dataType) {
         case UP_CONNECT_REQ:
            log.info("主链路登录请求({})：{}", DataType.UP_CONNECT_REQ.getCode(), out);
            log.debug("主链路登录请求({})：{}", DataType.UP_CONNECT_REQ.getCode(), out);
            connectReqService.connect(ctx, out);
            break;
         case UP_DISCONNECT_REQ:
            log.info("主链路注销请求({})：{}", DataType.UP_DISCONNECT_REQ.getCode(), out);
            log.debug("主链路注销请求({})：{}", DataType.UP_DISCONNECT_REQ.getCode(), out);
            upDisconnectReqService.disconnect(ctx, out);
            break;
         case UP_LINKTEST_REQ:
            log.info("主链路连接保持请求({})：{}", DataType.UP_LINKTEST_REQ.getCode(), out);
            log.debug("主链路连接保持请求({})：{}", DataType.UP_LINKTEST_REQ.getCode(), out);
            upLinkTestReqService.linkTest(ctx, out);
            break;
         case UP_EXG_MSG:
            log.info("主链路车辆动态信息交换({})：{}", DataType.UP_EXG_MSG.getCode(), out);
            log.debug("主链路车辆动态信息交换({})：{}", DataType.UP_EXG_MSG.getCode(), out);
            exgMsgService.up_exg_msg(ctx, out);
            break;
         case UP_PLATFORM_MSG:
            log.info("主链路平台间信息交互({})：{}", DataType.UP_PLATFORM_MSG.getCode(), out);
            log.debug("主链路平台间信息交互({})：{}", DataType.UP_PLATFORM_MSG.getCode(), out);
            platformMsgService.up_platform_msg(ctx, out);
            break;
         case UP_WARN_MSG:
            log.info("报警信息交互({})：{}", DataType.UP_WARN_MSG.getCode(), out);
            log.debug("报警信息交互({})：{}", DataType.UP_WARN_MSG.getCode(), out);
            warnMsgService.up_warn_msg(ctx, out);
            break;
         case UP_CTRL_MSG:
            log.info("车辆监管业务({})：{}", DataType.UP_CTRL_MSG.getCode(), out);
            log.debug("车辆监管业务({})：{}", DataType.UP_CTRL_MSG.getCode(), out);
            ctrlMsgService.up_ctrl_msg(ctx, out);
            break;
         case UP_BASE_MSG:
            log.info("车辆静态信息交换业务({})：{}", DataType.UP_BASE_MSG.getCode(), out);
            log.debug("车辆静态信息交换业务({})：{}", DataType.UP_BASE_MSG.getCode(), out);
            baseMsgService.up_base_msg(ctx, out);
            break;
         case UP_AUTHORIZE_MSG:
            log.info("视频时效口令交互({})：{}", DataType.UP_AUTHORIZE_MSG.getCode(), out);
            log.debug("视频时效口令交互({})：{}", DataType.UP_AUTHORIZE_MSG.getCode(), out);
            authorizeMsgService.up_authorize_msg(ctx, out);
            break;
         case UP_REALVIDEO_MSG:
            log.info("实时音视频交互({})：{}", DataType.UP_REALVIDEO_MSG.getCode(), out);
            log.debug("实时音视频交互({})：{}", DataType.UP_REALVIDEO_MSG.getCode(), out);
            realvideoMsgService.up_realvideo_msg(ctx, out);
            break;
         case UP_PLAYBACK_MSG:
            log.info("远程录像回放交互({})：{}", DataType.UP_PLAYBACK_MSG.getCode(), out);
            log.debug("远程录像回放交互({})：{}", DataType.UP_PLAYBACK_MSG.getCode(), out);
            playbackMsgService.up_playback_msg(ctx, out);
            break;
         default:
            break;
      }
   }
	
   @Override
   public void channelActive(ChannelHandlerContext ctx) throws Exception {
      log.info("Netty客户端链接成功");
      super.channelActive(ctx);
   }
	
   @Override
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {
      log.info("Netty客户端离线");
      super.channelInactive(ctx);
   }
	
   @Override
   public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
      log.info("Netty客户端连链接常关闭");
      cause.printStackTrace();
      ctx.close();
   }
}