From b554a106bc1b06e0320b642d16c31554ae558301 Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期二, 03 六月 2025 17:28:11 +0800 Subject: [PATCH] 新增加川标报警处理结果 --- ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java | 21 +++++++++++++++++++++ 1 files changed, 21 insertions(+), 0 deletions(-) diff --git a/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java b/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java index b05df08..18f472b 100644 --- a/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java +++ b/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java @@ -54,6 +54,15 @@ @Resource private BaseMsgService baseMsgService = SpringUtils.getBean(BaseMsgService.class); + @Resource + private AuthorizeMsgService authorizeMsgService = SpringUtils.getBean(AuthorizeMsgService.class); + + @Resource + private RealvideoMsgService realvideoMsgService = SpringUtils.getBean(RealvideoMsgService.class); + + @Resource + private PlaybackMsgService playbackMsgService = SpringUtils.getBean(PlaybackMsgService.class); + @Override public void channelRead(ChannelHandlerContext ctx, Object object) throws Exception { @@ -153,6 +162,18 @@ log.info("车辆静态信息交换业务({}):{}", 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); + authorizeMsgService.up_authorize_msg(ctx, out); + break; + case UP_REALVIDEO_MSG: + log.info("实时音视频交互({}):{}", 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); + playbackMsgService.up_playback_msg(ctx, out); + break; default: break; } -- Gitblit v1.7.1