From 90b3fdfec278d818b82864670f1366cf32695f0b Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Thu, 11 Dec 2025 15:57:24 +0800
Subject: [PATCH] 2025-12-11 zwy 优化,在机场重启时清redis视频路径

---
 ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java |   18 ++++++++++++++++++
 1 files changed, 18 insertions(+), 0 deletions(-)

diff --git a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java
index 8e315ce..b2c1dbd 100644
--- a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java
+++ b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java
@@ -63,6 +63,7 @@
             return ResponseResult.error("The " + serviceIdentifier + " method does not exist.");
         }
 
+
         Object data = "";
         // Add parameter validation.
         if (Objects.nonNull(controlMethodEnum.getClazz())) {
@@ -111,6 +112,23 @@
             RedisOpsUtils.setWithExpire(serviceIdentifier + RedisConst.DELIMITER +  bid, sn,
                     RedisConst.DEVICE_ALIVE_SECOND * RedisConst.DEVICE_ALIVE_SECOND);
         }
+        // 执行操作成功后,更新摄像头内外镜头状态
+        if(RemoteControlMethodEnum.COVER_OPEN == controlMethodEnum) {
+            // 打开盖子,切换机场舱内摄像头镜头
+            //打开,摄像头为舱内;将摄像头状态存到redis,格式为:CONVERSTATE:设备SN:1(舱外)或0(舱内)
+            _deviceService.setRedisCameraPosition(sn,0);
+        }
+        if(RemoteControlMethodEnum.COVER_CLOSE == controlMethodEnum) {
+            // 关闭盖子,切换机场舱外摄像头镜头
+            //关闭,摄像头为舱外;将摄像头状态存到redis,格式为:CONVERSTATE:设备SN:1(舱外)或0(舱内)
+            _deviceService.setRedisCameraPosition(sn,1);
+        }
+        // 重启机场时清redis视频直播地址,机场重启不掉线。但是流停了。
+        if(RemoteControlMethodEnum.DEVICE_REBOOT == controlMethodEnum) {
+            RedisOpsUtils.del(RedisConst.WEBSOCKET_VIDEO_ADDRESS_PREFIX + sn);
+            RedisOpsUtils.del(RedisConst.COVER_STATE_PREFIX + sn);
+        }
+
         return ResponseResult.success();
     }
 

--
Gitblit v1.9.3