From f355ef485a56e613b71d0262c089b995d7ca10d2 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 23 五月 2025 17:38:39 +0800
Subject: [PATCH] 集成MQTT对接公交主防数据
---
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