From 87c2f1ec41e244dfdd4722884fcdf285a1fe9b41 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 24 三月 2025 14:41:25 +0800
Subject: [PATCH] 完成音视频协议接口对接

---
 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/netty/server/NettyHandle.java |   15 +++++++++++----
 1 files changed, 11 insertions(+), 4 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 0727ebb..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
@@ -58,7 +58,10 @@
 	private AuthorizeMsgService authorizeMsgService = SpringUtils.getBean(AuthorizeMsgService.class);
 	
 	@Resource
-	private RealvideoMsg realvideoMsg = SpringUtils.getBean(RealvideoMsg.class);
+	private RealvideoMsgService realvideoMsgService = SpringUtils.getBean(RealvideoMsgService.class);
+	
+	@Resource
+	private PlaybackMsgService playbackMsgService = SpringUtils.getBean(PlaybackMsgService.class);
 	
 	
 	@Override
@@ -160,12 +163,16 @@
 				baseMsgService.up_base_msg(ctx, out);
 				break;
 			case UP_AUTHORIZE_MSG:
-				log.info("主链路视频时效口令交互({}):{}", DataType.UP_AUTHORIZE_MSG.getCode(), out);
+				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);
+				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