From cab404b1a79927964a546a118cf4c171fa0bbfdf Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 21 三月 2025 19:34:27 +0800
Subject: [PATCH] 新增加管理后台接口和对接音视频协议
---
ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java | 14 ++++++++++++++
1 files changed, 14 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..0727ebb 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,12 @@
@Resource
private BaseMsgService baseMsgService = SpringUtils.getBean(BaseMsgService.class);
+ @Resource
+ private AuthorizeMsgService authorizeMsgService = SpringUtils.getBean(AuthorizeMsgService.class);
+
+ @Resource
+ private RealvideoMsg realvideoMsg = SpringUtils.getBean(RealvideoMsg.class);
+
@Override
public void channelRead(ChannelHandlerContext ctx, Object object) throws Exception {
@@ -153,6 +159,14 @@
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);
+ realvideoMsg.up_realvideo_msg(ctx, out);
+ break;
default:
break;
}
--
Gitblit v1.7.1