refactor: 重构videostream; fix: 修复进度条guid无法生成的问题

server.test/NumberTest.cs

@@ -35,57 +35,133 @@ public class NumberTest
     }
 
     /// <summary>
-    /// 测试 BytesToUInt64 的正常与异常情况
+    /// 测试 BytesToUInt64 的正常与异常情况，覆盖不同参数组合
     /// </summary>
     [Fact]
     public void Test_BytesToUInt64()
     {
-        // 正常大端
+        // 正常大端（isLowNumHigh=false）
         var bytes = new byte[] { 0x12, 0x34, 0x56, 0x78, 0xAB, 0xCD, 0xEF, 0x01 };
-        var result = Number.BytesToUInt64((byte[])bytes.Clone(), false);
+        var result = Number.BytesToUInt64((byte[])bytes.Clone());
         Assert.True(result.IsSuccessful);
         Assert.Equal(0x12345678ABCDEF01UL, result.Value);
 
-        // 正常小端
+        // 正常小端（isLowNumHigh=true）
         var bytes2 = new byte[] { 0x01, 0xEF, 0xCD, 0xAB, 0x78, 0x56, 0x34, 0x12 };
         var result2 = Number.BytesToUInt64((byte[])bytes2.Clone(), true);
         Assert.True(result2.IsSuccessful);
         Assert.Equal(0x12345678ABCDEF01UL, result2.Value);
 
-        // 异常：长度超限
+        // 长度不足8字节（numLength=4），大端
-        var result3 = Number.BytesToUInt64(new byte[9], false);
+        var bytes3 = new byte[] { 0x12, 0x34, 0x56, 0x78 };
-        Assert.False(result3.IsSuccessful);
+        var result3 = Number.BytesToUInt64((byte[])bytes3.Clone(), 0, 4, false);
+        Assert.True(result3.IsSuccessful);
+        Assert.Equal(0x1234567800000000UL, result3.Value);
 
-        // 异常：不足8字节
+        // 长度不足8字节（numLength=4），小端
-        var result4 = Number.BytesToUInt64(new byte[] { 0x01, 0x02 }, false);
+        var bytes4 = new byte[] { 0x78, 0x56, 0x34, 0x12 };
-        Assert.False(result4.IsSuccessful); // BitConverter.ToUInt64 需要8字节
+        var result4 = Number.BytesToUInt64((byte[])bytes4.Clone(), 0, 4, true);
+        Assert.True(result4.IsSuccessful);
+        Assert.Equal(0x12345678UL, result4.Value);
+
+        // numLength=0
+        var bytes5 = new byte[] { 0x12, 0x34, 0x56, 0x78 };
+        var result5 = Number.BytesToUInt64((byte[])bytes5.Clone(), 0, 0, false);
+        Assert.True(result5.IsSuccessful);
+        Assert.Equal(0UL, result5.Value);
+
+        // offset测试
+        var bytes6 = new byte[] { 0x00, 0x00, 0x12, 0x34, 0x56, 0x78, 0xAB, 0xCD, 0xEF, 0x01 };
+        var result6 = Number.BytesToUInt64(bytes6, 2, 8, false);
+        Assert.True(result6.IsSuccessful);
+        Assert.Equal(0x12345678ABCDEF01UL, result6.Value);
+
+        // numLength超限（>8），应返回异常
+        var bytes7 = new byte[9];
+        var result7 = Number.BytesToUInt64(bytes7, 0, 9, false);
+        Assert.False(result7.IsSuccessful);
+
+        // offset+numLength超限
+        var bytes8 = new byte[] { 0x01, 0x02, 0x03, 0x04 };
+        var result8 = Number.BytesToUInt64(bytes8, 2, 4, false);
+        Assert.True(result8.IsSuccessful);
+        Assert.Equal(0x0304000000000000UL, result8.Value);
+
+        // bytes长度不足offset+numLength
+        var bytes9 = new byte[] { 0x01, 0x02 };
+        var result9 = Number.BytesToUInt64(bytes9, 1, 2, true);
+        Assert.True(result9.IsSuccessful);
+        Assert.Equal(0x02UL, result9.Value);
+
+        // 空数组
+        var result10 = Number.BytesToUInt64(new byte[0], 0, 0, false);
+        Assert.True(result10.IsSuccessful);
+        Assert.Equal(0UL, result10.Value);
     }
 
     /// <summary>
-    /// 测试 BytesToUInt32 的正常与异常情况
+    /// 测试 BytesToUInt32 的正常与异常情况，覆盖不同参数组合
     /// </summary>
     [Fact]
     public void Test_BytesToUInt32()
     {
-        // 正常大端
+        // 正常大端（isLowNumHigh=false）
         var bytes = new byte[] { 0x12, 0x34, 0x56, 0x78 };
-        var result = Number.BytesToUInt32((byte[])bytes.Clone(), false);
+        var result = Number.BytesToUInt32((byte[])bytes.Clone());
         Assert.True(result.IsSuccessful);
         Assert.Equal(0x12345678U, result.Value);
 
-        // 正常小端
+        // 正常小端（isLowNumHigh=true）
         var bytes2 = new byte[] { 0x78, 0x56, 0x34, 0x12 };
         var result2 = Number.BytesToUInt32((byte[])bytes2.Clone(), true);
         Assert.True(result2.IsSuccessful);
         Assert.Equal(0x12345678U, result2.Value);
 
-        // 异常：长度超限
+        // 长度不足4字节（numLength=2），大端
-        var result3 = Number.BytesToUInt32(new byte[5], false);
+        var bytes3 = new byte[] { 0x12, 0x34 };
-        Assert.False(result3.IsSuccessful);
+        var result3 = Number.BytesToUInt32((byte[])bytes3.Clone(), 0, 2, false);
+        Assert.True(result3.IsSuccessful);
+        Assert.Equal(0x12340000U, result3.Value);
 
-        // 异常：不足4字节
+        // 长度不足4字节（numLength=2），小端
-        var result4 = Number.BytesToUInt32(new byte[] { 0x01, 0x02 }, false);
+        var bytes4 = new byte[] { 0x34, 0x12 };
-        Assert.False(result4.IsSuccessful); // BitConverter.ToUInt32 需要4字节
+        var result4 = Number.BytesToUInt32((byte[])bytes4.Clone(), 0, 2, true);
+        Assert.True(result4.IsSuccessful);
+        Assert.Equal(0x1234U, result4.Value);
+
+        // numLength=0
+        var bytes5 = new byte[] { 0x12, 0x34, 0x56, 0x78 };
+        var result5 = Number.BytesToUInt32((byte[])bytes5.Clone(), 0, 0, false);
+        Assert.True(result5.IsSuccessful);
+        Assert.Equal(0U, result5.Value);
+
+        // offset测试
+        var bytes6 = new byte[] { 0x00, 0x00, 0x12, 0x34, 0x56, 0x78 };
+        var result6 = Number.BytesToUInt32(bytes6, 2, 4, false);
+        Assert.True(result6.IsSuccessful);
+        Assert.Equal(0x12345678U, result6.Value);
+
+        // numLength超限（>4），应返回异常
+        var bytes7 = new byte[5];
+        var result7 = Number.BytesToUInt32(bytes7, 0, 5, false);
+        Assert.False(result7.IsSuccessful);
+
+        // offset+numLength超限
+        var bytes8 = new byte[] { 0x01, 0x02, 0x03, 0x04 };
+        var result8 = Number.BytesToUInt32(bytes8, 2, 2, false);
+        Assert.True(result8.IsSuccessful);
+        Assert.Equal(0x03040000U, result8.Value);
+
+        // bytes长度不足offset+numLength
+        var bytes9 = new byte[] { 0x01, 0x02 };
+        var result9 = Number.BytesToUInt32(bytes9, 1, 1, true);
+        Assert.True(result9.IsSuccessful);
+        Assert.Equal(0x02U, result9.Value);
+
+        // 空数组
+        var result10 = Number.BytesToUInt32(new byte[0], 0, 0, false);
+        Assert.True(result10.IsSuccessful);
+        Assert.Equal(0U, result10.Value);
     }
 
     /// <summary>

server/server.csproj

@@ -11,6 +11,7 @@
     <SpaRoot>../</SpaRoot>
     <SpaProxyServerUrl>http://localhost:5173</SpaProxyServerUrl>
     <SpaProxyLaunchCommand>npm run dev</SpaProxyLaunchCommand>
+    <NoWarn>CS1591</NoWarn>
   </PropertyGroup>
 
   <ItemGroup>

server/src/Common/Number.cs

@@ -78,6 +78,56 @@ public class Number
         return arr;
     }
 
+    /// <summary>
+    /// 二进制字节数组转成64bits整数
+    /// </summary>
+    /// <param name="bytes">二进制字节数组</param>
+    /// <param name="offset">字节数组偏移量</param>
+    /// <param name="numLength">字节数组长度</param>
+    /// <param name="isLowNumHigh">是否高位在数组索引低</param>
+    /// <returns>整数</returns>
+    public static Result<UInt64> BytesToUInt64(byte[] bytes, int offset = 0, int numLength = 8, bool isLowNumHigh = false)
+    {
+        if (bytes.Length < offset)
+        {
+            return new(new ArgumentException($"The Length of bytes is less than offset"));
+        }
+
+        if (numLength > 8)
+        {
+            return new(new ArgumentException($"The Length of bytes is greater than 8"));
+        }
+
+        if (numLength <= 0) return 0;
+
+        try
+        {
+            byte[] numBytes = new byte[8]; // 8字节
+            int copyLen = Math.Min(numLength, bytes.Length - offset);
+
+            if (isLowNumHigh)
+            {
+                // 小端：拷贝到低位
+                Buffer.BlockCopy(bytes, offset, numBytes, 0, copyLen);
+            }
+            else
+            {
+                // 大端：拷贝到高位
+                byte[] temp = new byte[copyLen];
+                Buffer.BlockCopy(bytes, offset, temp, 0, copyLen);
+                Array.Reverse(temp);
+                Buffer.BlockCopy(temp, 0, numBytes, 8 - copyLen, copyLen);
+            }
+
+            UInt64 num = BitConverter.ToUInt64(numBytes, 0);
+            return num;
+        }
+        catch (Exception error)
+        {
+            return new(error);
+        }
+    }
+
     /// <summary>
     /// 二进制字节数组转成64bits整数
     /// </summary>
@@ -86,25 +136,78 @@ public class Number
     /// <returns>整数</returns>
     public static Result<UInt64> BytesToUInt64(byte[] bytes, bool isLowNumHigh = false)
     {
-        if (bytes.Length > 8)
+        return BytesToUInt64(bytes, 0, 8, isLowNumHigh);
+    }
+
+    /// <summary>
+    /// 二进制字节数组转成64bits整数
+    /// </summary>
+    /// <param name="bytes">二进制字节数组</param>
+    /// <returns>整数</returns>
+    public static Result<UInt64> BytesToUInt64(byte[] bytes)
+    {
+        return BytesToUInt64(bytes, 0, 8, false);
+    }
+
+    /// <summary>
+    /// 二进制字节数组转成32bits整数
+    /// </summary>
+    /// <param name="bytes">二进制字节数组</param>
+    /// <param name="offset">字节数组偏移量</param>
+    /// <param name="numLength">整形所占字节数组长度</param>
+    /// <param name="isLowNumHigh">是否高位在数组索引低</param>
+    /// <returns>整数</returns>
+    public static Result<UInt32> BytesToUInt32(byte[] bytes, int offset = 0, int numLength = 4, bool isLowNumHigh = false)
+    {
+        if (bytes.Length < offset)
         {
-            return new(new ArgumentException(
+            return new(new ArgumentException($"The Length of bytes is less than offset"));
-                "Unsigned long number can't over 8 bytes(64 bits).",
-                nameof(bytes)
-            ));
         }
 
-        UInt64 num = 0;
+        if (numLength > 4)
-        int len = bytes.Length;
+        {
+            return new(new ArgumentException($"The Length of bytes is greater than 4"));
+        }
+
+        if (bytes.Length < offset)
+        {
+            return new(new ArgumentException($"The Length of bytes is less than offset"));
+        }
+
+        if (numLength > 4)
+        {
+            return new(new ArgumentException($"The Length of bytes is greater than 4"));
+        }
+
+        if (numLength <= 0) return 0;
 
         try
         {
-            if (!isLowNumHigh)
+            byte[] numBytes = new byte[4]; // 4字节
-            {
+            int copyLen = Math.Min(numLength, bytes.Length - offset);
-                Array.Reverse(bytes);
+            if (copyLen < 0) copyLen = 0;
-            }
-            num = BitConverter.ToUInt64(bytes, 0);
 
+            if (isLowNumHigh)
+            {
+                // 小端：拷贝到低位
+                if (copyLen > 0)
+                {
+                    Buffer.BlockCopy(bytes, offset, numBytes, 0, copyLen);
+                }
+            }
+            else
+            {
+                // 大端：拷贝到高位
+                if (copyLen > 0)
+                {
+                    byte[] temp = new byte[copyLen];
+                    Buffer.BlockCopy(bytes, offset, temp, 0, copyLen);
+                    Array.Reverse(temp);
+                    Buffer.BlockCopy(temp, 0, numBytes, 4 - copyLen, copyLen);
+                }
+            }
+
+            UInt32 num = BitConverter.ToUInt32(numBytes, 0);
             return num;
         }
         catch (Exception error)
@@ -121,32 +224,17 @@ public class Number
     /// <returns>整数</returns>
     public static Result<UInt32> BytesToUInt32(byte[] bytes, bool isLowNumHigh = false)
     {
-        if (bytes.Length > 4)
+        return BytesToUInt32(bytes, 0, 4, isLowNumHigh);
-        {
+    }
-            return new(new ArgumentException(
-                "Unsigned long number can't over 4 bytes(32 bits).",
-                nameof(bytes)
-            ));
-        }
-
-        UInt32 num = 0;
-        int len = bytes.Length;
-
-        try
-        {
-            if (!isLowNumHigh)
-            {
-                Array.Reverse(bytes);
-            }
-            num = BitConverter.ToUInt32(bytes, 0);
-
-            return num;
-        }
-        catch (Exception error)
-        {
-            return new(error);
-        }
 
+    /// <summary>
+    /// 二进制字节数组转成32bits整数
+    /// </summary>
+    /// <param name="bytes">二进制字节数组</param>
+    /// <returns>整数</returns>
+    public static Result<UInt32> BytesToUInt32(byte[] bytes)
+    {
+        return BytesToUInt32(bytes, 0, 4, false);
     }
 
     /// <summary>

server/src/Controllers/VideoStreamController.cs

@@ -1,77 +1,22 @@
 using System.ComponentModel.DataAnnotations;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Cors;
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Authorization;
+using System.Security.Claims;
+using Database;
+using DotNext;
 
 /// <summary>
 /// 视频流控制器，支持动态配置摄像头连接
 /// </summary>
 [ApiController]
+[Authorize]
 [Route("api/[controller]")]
 public class VideoStreamController : ControllerBase
 {
     private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
     private readonly server.Services.HttpVideoStreamService _videoStreamService;
 
-    /// <summary>
-    /// 视频流信息结构体
-    /// </summary>
-    public class StreamInfoResult
-    {
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public int FrameRate { get; set; }
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public int FrameWidth { get; set; }
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public int FrameHeight { get; set; }
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public string Format { get; set; } = "MJPEG";
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public string HtmlUrl { get; set; } = "";
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public string MjpegUrl { get; set; } = "";
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public string SnapshotUrl { get; set; } = "";
-        /// <summary>
-        /// TODO:
-        /// </summary>
-        public string UsbCameraUrl { get; set; } = "";
-    }
-
-    /// <summary>
-    /// 摄像头配置请求模型
-    /// </summary>
-    public class CameraConfigRequest
-    {
-        /// <summary>
-        /// 摄像头地址
-        /// </summary>
-        [Required]
-        [RegularExpression(@"^(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$", ErrorMessage = "请输入有效的IP地址")]
-        public string Address { get; set; } = "";
-
-        /// <summary>
-        /// 摄像头端口
-        /// </summary>
-        [Required]
-        [Range(1, 65535, ErrorMessage = "端口必须在1-65535范围内")]
-        public int Port { get; set; }
-    }
-
     /// <summary>
     /// 分辨率配置请求模型
     /// </summary>
@@ -92,6 +37,14 @@ public class VideoStreamController : ControllerBase
         public int Height { get; set; }
     }
 
+    public class AvailableResolutionsResponse
+    {
+        public int Width { get; set; }
+        public int Height { get; set; }
+        public string Name { get; set; } = string.Empty;
+        public string Value => $"{Width}x{Height}";
+    }
+
     /// <summary>
     /// 初始化HTTP视频流控制器
     /// </summary>
@@ -102,6 +55,40 @@ public class VideoStreamController : ControllerBase
         _videoStreamService = videoStreamService;
     }
 
+    private Optional<string> TryGetBoardId()
+    {
+        var userName = User.FindFirstValue(ClaimTypes.Name);
+        if (string.IsNullOrEmpty(userName))
+        {
+            logger.Error("User name not found in claims.");
+            return Optional<string>.None;
+        }
+
+        var db = new AppDataConnection();
+        if (db == null)
+        {
+            logger.Error("Database connection failed.");
+            return Optional<string>.None;
+        }
+
+        var userRet = db.GetUserByName(userName);
+        if (!userRet.IsSuccessful || !userRet.Value.HasValue)
+        {
+            logger.Error("User not found.");
+            return Optional<string>.None;
+        }
+
+        var user = userRet.Value.Value;
+        var boardId = user.BoardID;
+        if (boardId == Guid.Empty)
+        {
+            logger.Error("No board bound to this user.");
+            return Optional<string>.None;
+        }
+
+        return boardId.ToString();
+    }
+
     /// <summary>
     /// 获取 HTTP 视频流服务状态
     /// </summary>
@@ -114,8 +101,6 @@ public class VideoStreamController : ControllerBase
     {
         try
         {
-            logger.Info("GetStatus方法被调用，控制器：{Controller}，路径：api/VideoStream/Status", this.GetType().Name);
-
             // 使用HttpVideoStreamService提供的状态信息
             var status = _videoStreamService.GetServiceStatus();
 
@@ -129,101 +114,18 @@ public class VideoStreamController : ControllerBase
         }
     }
 
-    /// <summary>
+    [HttpGet("MyEndpoint")]
-    /// 获取 HTTP 视频流信息
-    /// </summary>
-    /// <returns>流信息</returns>
-    [HttpGet("StreamInfo")]
-    [EnableCors("Users")]
-    [ProducesResponseType(typeof(StreamInfoResult), StatusCodes.Status200OK)]
-    [ProducesResponseType(typeof(Exception), StatusCodes.Status500InternalServerError)]
-    public IResult GetStreamInfo()
-    {
-        try
-        {
-            logger.Info("获取 HTTP 视频流信息");
-            var result = new StreamInfoResult
-            {
-                FrameRate = _videoStreamService.FrameRate,
-                FrameWidth = _videoStreamService.FrameWidth,
-                FrameHeight = _videoStreamService.FrameHeight,
-                Format = "MJPEG",
-                HtmlUrl = $"http://{Global.localhost}:{_videoStreamService.ServerPort}/video-feed.html",
-                MjpegUrl = $"http://{Global.localhost}:{_videoStreamService.ServerPort}/video-stream",
-                SnapshotUrl = $"http://{Global.localhost}:{_videoStreamService.ServerPort}/snapshot",
-                UsbCameraUrl = $"http://{Global.localhost}:{_videoStreamService.ServerPort}/usb-camera"
-            };
-            return TypedResults.Ok(result);
-        }
-        catch (Exception ex)
-        {
-            logger.Error(ex, "获取 HTTP 视频流信息失败");
-            return TypedResults.InternalServerError(ex.Message);
-        }
-    }
-
-    /// <summary>
-    /// 配置摄像头连接参数
-    /// </summary>
-    /// <param name="config">摄像头配置</param>
-    /// <returns>配置结果</returns>
-    [HttpPost("ConfigureCamera")]
-    [EnableCors("Users")]
-    [ProducesResponseType(typeof(object), StatusCodes.Status200OK)]
-    [ProducesResponseType(typeof(object), StatusCodes.Status400BadRequest)]
-    [ProducesResponseType(typeof(Exception), StatusCodes.Status500InternalServerError)]
-    public async Task<IResult> ConfigureCamera([FromBody] CameraConfigRequest config)
-    {
-        try
-        {
-            logger.Info("配置摄像头连接: {Address}:{Port}", config.Address, config.Port);
-
-            var success = await _videoStreamService.ConfigureCameraAsync(config.Address, config.Port);
-
-            if (success)
-            {
-                return TypedResults.Ok(new
-                {
-                    success = true,
-                    message = "摄像头配置成功",
-                    cameraAddress = config.Address,
-                    cameraPort = config.Port
-                });
-            }
-            else
-            {
-                return TypedResults.BadRequest(new
-                {
-                    success = false,
-                    message = "摄像头配置失败",
-                    cameraAddress = config.Address,
-                    cameraPort = config.Port
-                });
-            }
-        }
-        catch (Exception ex)
-        {
-            logger.Error(ex, "配置摄像头连接失败");
-            return TypedResults.InternalServerError(ex.Message);
-        }
-    }
-
-    /// <summary>
-    /// 获取当前摄像头配置
-    /// </summary>
-    /// <returns>摄像头配置信息</returns>
-    [HttpGet("CameraConfig")]
     [EnableCors("Users")]
     [ProducesResponseType(typeof(object), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(Exception), StatusCodes.Status500InternalServerError)]
-    public IResult GetCameraConfig()
+    public IResult MyEndpoint()
     {
         try
         {
-            logger.Info("获取摄像头配置");
+            var boardId = TryGetBoardId().OrThrow(() => new Exception("Board ID not found"));
-            var cameraStatus = _videoStreamService.GetCameraStatus();
+            var endpoint = _videoStreamService.GetVideoEndpoint(boardId);
 
-            return TypedResults.Ok(cameraStatus);
+            return TypedResults.Ok(endpoint);
         }
         catch (Exception ex)
         {
@@ -232,22 +134,6 @@ public class VideoStreamController : ControllerBase
         }
     }
 
-    /// <summary>
-    /// 控制 HTTP 视频流服务开关
-    /// </summary>
-    /// <param name="enabled">是否启用服务</param>
-    /// <returns>操作结果</returns>
-    [HttpPost("SetEnabled")]
-    [EnableCors("Users")]
-    [ProducesResponseType(typeof(object), StatusCodes.Status200OK)]
-    [ProducesResponseType(typeof(Exception), StatusCodes.Status500InternalServerError)]
-    public async Task<IResult> SetEnabled([FromQuery] bool enabled)
-    {
-        logger.Info("设置视频流服务开关: {Enabled}", enabled);
-        await _videoStreamService.SetEnable(enabled);
-        return TypedResults.Ok();
-    }
-
     /// <summary>
     /// 测试 HTTP 视频流连接
     /// </summary>
@@ -260,32 +146,23 @@ public class VideoStreamController : ControllerBase
     {
         try
         {
-            logger.Info("测试 HTTP 视频流连接");
+            var boardId = TryGetBoardId().OrThrow(() => new Exception("Board ID not found"));
+            var endpoint = _videoStreamService.GetVideoEndpoint(boardId);
 
             // 尝试通过HTTP请求检查视频流服务是否可访问
             bool isConnected = false;
             using (var httpClient = new HttpClient())
             {
                 httpClient.Timeout = TimeSpan.FromSeconds(2); // 设置较短的超时时间
-                var response = await httpClient.GetAsync($"http://{Global.localhost}:{_videoStreamService.ServerPort}/");
+                var response = await httpClient.GetAsync(endpoint.MjpegUrl);
 
                 // 只要能连接上就认为成功，不管返回状态
                 isConnected = response.IsSuccessStatusCode;
             }
 
-            logger.Info("测试摄像头连接");
+            var ret = await _videoStreamService.TestCameraConnection(boardId);
 
-            var (isSuccess, message) = await _videoStreamService.TestCameraConnectionAsync();
+            return TypedResults.Ok(ret);
-
-            return TypedResults.Ok(new
-            {
-                isConnected = isConnected,
-                success = isSuccess,
-                message = message,
-                cameraAddress = _videoStreamService.CameraAddress,
-                cameraPort = _videoStreamService.CameraPort,
-                timestamp = DateTime.Now
-            });
         }
         catch (Exception ex)
         {
@@ -295,6 +172,23 @@ public class VideoStreamController : ControllerBase
         }
     }
 
+    [HttpPost("DisableTransmission")]
+    public async Task<IActionResult> DisableHdmiTransmission()
+    {
+        try
+        {
+            var boardId = TryGetBoardId().OrThrow(() => new ArgumentException("Board ID is required"));
+
+            await _videoStreamService.DisableHdmiTransmissionAsync(boardId.ToString());
+            return Ok($"HDMI transmission for board {boardId} disabled.");
+        }
+        catch (Exception ex)
+        {
+            logger.Error(ex, $"Failed to disable HDMI transmission for board");
+            return StatusCode(500, $"Error disabling HDMI transmission: {ex.Message}");
+        }
+    }
+
     /// <summary>
     /// 设置视频流分辨率
     /// </summary>
@@ -309,16 +203,16 @@ public class VideoStreamController : ControllerBase
     {
         try
         {
-            logger.Info($"设置视频流分辨率为 {request.Width}x{request.Height}");
+            var boardId = TryGetBoardId().OrThrow(() => new Exception("Board ID not found"));
 
-            var (isSuccess, message) = await _videoStreamService.SetResolutionAsync(request.Width, request.Height);
+            var ret = await _videoStreamService.SetResolutionAsync(boardId, request.Width, request.Height);
 
-            if (isSuccess)
+            if (ret.IsSuccessful && ret.Value)
             {
                 return TypedResults.Ok(new
                 {
                     success = true,
-                    message = message,
+                    message = $"成功设置分辨率为 {request.Width}x{request.Height}",
                     width = request.Width,
                     height = request.Height,
                     timestamp = DateTime.Now
@@ -329,7 +223,7 @@ public class VideoStreamController : ControllerBase
                 return TypedResults.BadRequest(new
                 {
                     success = false,
-                    message = message,
+                    message = ret.Error?.ToString() ?? "未知错误",
                     timestamp = DateTime.Now
                 });
             }
@@ -341,37 +235,6 @@ public class VideoStreamController : ControllerBase
         }
     }
 
-    /// <summary>
-    /// 获取当前分辨率
-    /// </summary>
-    /// <returns>当前分辨率信息</returns>
-    [HttpGet("Resolution")]
-    [EnableCors("Users")]
-    [ProducesResponseType(typeof(object), StatusCodes.Status200OK)]
-    [ProducesResponseType(typeof(string), StatusCodes.Status500InternalServerError)]
-    public IResult GetCurrentResolution()
-    {
-        try
-        {
-            logger.Info("获取当前视频流分辨率");
-
-            var (width, height) = _videoStreamService.GetCurrentResolution();
-
-            return TypedResults.Ok(new
-            {
-                width = width,
-                height = height,
-                resolution = $"{width}x{height}",
-                timestamp = DateTime.Now
-            });
-        }
-        catch (Exception ex)
-        {
-            logger.Error(ex, "获取当前分辨率失败");
-            return TypedResults.InternalServerError($"获取当前分辨率失败: {ex.Message}");
-        }
-    }
-
     /// <summary>
     /// 获取支持的分辨率列表
     /// </summary>
@@ -382,29 +245,19 @@ public class VideoStreamController : ControllerBase
     [ProducesResponseType(typeof(string), StatusCodes.Status500InternalServerError)]
     public IResult GetSupportedResolutions()
     {
-        try
+        // (640, 480, "640x480 (VGA)"),
+        // (960, 540, "960x540 (qHD)"),
+        // (1280, 720, "1280x720 (HD)"),
+        // (1280, 960, "1280x960 (SXGA)"),
+        // (1920, 1080, "1920x1080 (Full HD)")
+        return TypedResults.Ok(new AvailableResolutionsResponse[]
         {
-            logger.Info("获取支持的分辨率列表");
+            new AvailableResolutionsResponse { Width = 640, Height = 480, Name = "640x480(VGA)" },
-
+            new AvailableResolutionsResponse { Width = 960, Height = 480, Name = "960x480(qHD)" },
-            var resolutions = _videoStreamService.GetSupportedResolutions();
+            new AvailableResolutionsResponse { Width = 1280, Height = 720, Name = "1280x720(HD)" },
-
+            new AvailableResolutionsResponse { Width = 1280, Height = 960, Name = "1280x960(SXGA)" },
-            return TypedResults.Ok(new
+            new AvailableResolutionsResponse { Width = 1920, Height = 1080, Name = "1920x1080(Full HD)" }
-            {
+        });
-                resolutions = resolutions.Select(r => new
-                {
-                    width = r.Width,
-                    height = r.Height,
-                    name = r.Name,
-                    value = $"{r.Width}x{r.Height}"
-                }),
-                timestamp = DateTime.Now
-            });
-        }
-        catch (Exception ex)
-        {
-            logger.Error(ex, "获取支持的分辨率列表失败");
-            return TypedResults.InternalServerError($"获取支持的分辨率列表失败: {ex.Message}");
-        }
     }
 
     /// <summary>
@@ -420,9 +273,9 @@ public class VideoStreamController : ControllerBase
     {
         try
         {
-            logger.Info("收到初始化自动对焦请求");
+            var boardId = TryGetBoardId().OrThrow(() => new Exception("Board ID not found"));
 
-            var result = await _videoStreamService.InitAutoFocusAsync();
+            var result = await _videoStreamService.InitAutoFocusAsync(boardId);
 
             if (result)
             {
@@ -465,9 +318,9 @@ public class VideoStreamController : ControllerBase
     {
         try
         {
-            logger.Info("收到执行自动对焦请求");
+            var boardId = TryGetBoardId().OrThrow(() => new Exception("Board ID not found"));
 
-            var result = await _videoStreamService.PerformAutoFocusAsync();
+            var result = await _videoStreamService.PerformAutoFocusAsync(boardId);
 
             if (result)
             {
@@ -496,61 +349,4 @@ public class VideoStreamController : ControllerBase
             return TypedResults.InternalServerError($"执行自动对焦失败: {ex.Message}");
         }
     }
-
-    /// <summary>
-    /// 执行一次自动对焦 (GET方式)
-    /// </summary>
-    /// <returns>对焦结果</returns>
-    [HttpGet("Focus")]
-    [EnableCors("Users")]
-    [ProducesResponseType(typeof(object), StatusCodes.Status200OK)]
-    [ProducesResponseType(typeof(object), StatusCodes.Status400BadRequest)]
-    [ProducesResponseType(typeof(string), StatusCodes.Status500InternalServerError)]
-    public async Task<IResult> Focus()
-    {
-        try
-        {
-            logger.Info("收到执行一次对焦请求 (GET)");
-
-            // 检查摄像头是否已配置
-            if (!_videoStreamService.IsCameraConfigured())
-            {
-                logger.Warn("摄像头未配置，无法执行对焦");
-                return TypedResults.BadRequest(new
-                {
-                    success = false,
-                    message = "摄像头未配置，请先配置摄像头连接",
-                    timestamp = DateTime.Now
-                });
-            }
-
-            var result = await _videoStreamService.PerformAutoFocusAsync();
-
-            if (result)
-            {
-                logger.Info("对焦执行成功");
-                return TypedResults.Ok(new
-                {
-                    success = true,
-                    message = "对焦执行成功",
-                    timestamp = DateTime.Now
-                });
-            }
-            else
-            {
-                logger.Warn("对焦执行失败");
-                return TypedResults.BadRequest(new
-                {
-                    success = false,
-                    message = "对焦执行失败",
-                    timestamp = DateTime.Now
-                });
-            }
-        }
-        catch (Exception ex)
-        {
-            logger.Error(ex, "执行对焦时发生异常");
-            return TypedResults.InternalServerError($"执行对焦失败: {ex.Message}");
-        }
-    }
 }

server/src/Peripherals/CameraClient.cs

@@ -1,6 +1,5 @@
 using System.Net;
 using DotNext;
-using Peripherals.PowerClient;
 using WebProtocol;
 
 namespace Peripherals.CameraClient;
@@ -16,7 +15,7 @@ static class CameraAddr
     public const UInt32 CAMERA_POWER = BASE + 0x10; //[0]: rstn, 0 is reset. [8]: power down, 1 is down.
 }
 
-class Camera
+public class Camera
 {
     private static readonly NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
 
@@ -637,7 +636,7 @@ class Camera
             [0x3008, 0x42] // 休眠命令
         };
 
-        return await ConfigureRegisters(sleepRegisters,  customDelayMs: 50);
+        return await ConfigureRegisters(sleepRegisters, customDelayMs: 50);
     }
 
     /// <summary>

server/src/Peripherals/DebuggerClient.cs

@@ -170,7 +170,7 @@ public class DebuggerClient
     /// <returns>操作结果，成功返回状态标志字节，失败返回错误信息</returns>
     public async ValueTask<Result<byte>> ReadFlag()
     {
-        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, DebuggerAddr.Signal, this.timeout);
+        var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, DebuggerAddr.Signal, this.timeout);
         if (!ret.IsSuccessful)
         {
             logger.Error($"Failed to read flag: {ret.Error}");

server/src/Peripherals/HdmiInClient.cs

@@ -100,6 +100,51 @@ class HdmiIn
         return result.Value;
     }
 
+    public async ValueTask<(byte[] header, byte[] data, byte[] footer)?> GetMJpegFrame()
+    {
+        // 从HDMI读取RGB24数据
+        var readStartTime = DateTime.UtcNow;
+        var frameResult = await ReadFrame();
+        var readEndTime = DateTime.UtcNow;
+        var readTime = (readEndTime - readStartTime).TotalMilliseconds;
+
+        if (!frameResult.IsSuccessful || frameResult.Value == null)
+        {
+            logger.Warn("HDMI帧读取失败或为空");
+            return null;
+        }
+
+        var rgb24Data = frameResult.Value;
+
+        // 验证数据长度是否正确 (RGB24为每像素2字节)
+        var expectedLength = _currentWidth * _currentHeight * 2;
+        if (rgb24Data.Length != expectedLength)
+        {
+            logger.Warn("HDMI数据长度不匹配，期望: {Expected}, 实际: {Actual}",
+                expectedLength, rgb24Data.Length);
+        }
+
+        // 将RGB24转换为JPEG（参考Camera版本的处理）
+        var jpegStartTime = DateTime.UtcNow;
+        var jpegResult = Common.Image.ConvertRGB24ToJpeg(rgb24Data, _currentWidth, _currentHeight, 80);
+        var jpegEndTime = DateTime.UtcNow;
+        var jpegTime = (jpegEndTime - jpegStartTime).TotalMilliseconds;
+
+        if (!jpegResult.IsSuccessful)
+        {
+            logger.Error("HDMI RGB24转JPEG失败: {Error}", jpegResult.Error);
+            return null;
+        }
+
+        var jpegData = jpegResult.Value;
+
+        // 发送MJPEG帧（使用Camera版本的格式）
+        var mjpegFrameHeader = Common.Image.CreateMjpegFrameHeader(jpegData.Length);
+        var mjpegFrameFooter = Common.Image.CreateMjpegFrameFooter();
+
+        return (mjpegFrameHeader, jpegData, mjpegFrameFooter);
+    }
+
     /// <summary>
     /// 获取当前分辨率
     /// </summary>

server/src/Peripherals/I2cClient.cs

@@ -296,7 +296,7 @@ public class I2c
 
         // 读取数据
         {
-            var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, I2cAddr.Read);
+            var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, I2cAddr.Read);
             if (!ret.IsSuccessful)
             {
                 logger.Error($"Failed to read data from I2C FIFO: {ret.Error}");

server/src/Peripherals/JpegClient.cs

@@ -0,0 +1,281 @@
+using System.Net;
+using DotNext;
+using Common;
+
+namespace Peripherals.JpegClient;
+
+static class JpegAddr
+{
+    const UInt32 BASE = 0x0000_0000;
+    public const UInt32 ENABLE = BASE + 0x0;
+    public const UInt32 FRAME_NUM = BASE + 0x1;
+    public const UInt32 FRAME_INFO = BASE + 0x2;
+    public const UInt32 FRAME_SAMPLE_RATE = BASE + 0x3;
+    public const UInt32 FRAME_DATA_MAX_POINTER = BASE + 0x4;
+
+    public const UInt32 DDR_FRAME_DATA_ADDR = 0x0000_0000;
+    public const UInt32 DDR_FRAME_DATA_MAX_ADDR = 0x8000_0000;
+}
+
+public class JpegInfo
+{
+    public UInt32 Width { get; set; }
+    public UInt32 Height { get; set; }
+    public UInt32 Size { get; set; }
+
+    public JpegInfo(UInt32 width, UInt32 height, UInt32 size)
+    {
+        Width = width;
+        Height = height;
+        Size = size;
+    }
+
+    public JpegInfo(byte[] data)
+    {
+        if (data.Length < 8)
+            throw new ArgumentException("Invalid data length", nameof(data));
+
+        Width = ((UInt32)(data[5] << 8 + data[6] & 0xF0));
+        Height = ((UInt32)((data[6] & 0x0F) << 4 + data[7]));
+        Size = Number.BytesToUInt32(data, 0, 4).Value;
+    }
+}
+
+public enum JpegSampleRate : UInt32
+{
+    RATE_1_1 = 0b1111_1111_1111_1111_1111_1111_1111_1111,
+    RATE_1_2 = 0b1010_1010_1010_1010_1010_1010_1010_1010,
+    RATE_1_4 = 0b1000_1000_1000_1000_1000_1000_1000_1000,
+    RATE_3_4 = 0b1110_1110_1110_1110_1110_1110_1110_1110,
+    RATE_1_8 = 0b1000_0000_1000_0000_1000_0000_1000_0000,
+    RATE_3_8 = 0b1001_0010_0100_1001_1001_0010_0100_1001,
+    RATE_7_8 = 0b1111_1110_1111_1110_1111_1110_1111_1110,
+    RATE_1_16 = 0b1000_0000_0000_0000_1000_0000_0000_0000,
+    RATE_3_16 = 0b1000_0100_0010_0000_1000_0100_0010_0000,
+    RATE_5_16 = 0b1001_0001_0010_0010_0100_0100_1000_1001,
+    RATE_15_16 = 0b1111_1111_1111_1110_1111_1111_1111_1110,
+    RATE_1_32 = 0b1000_0000_0000_0000_0000_0000_0000_0000,
+    RATE_31_32 = 0b1111_1111_1111_1111_1111_1111_1111_1110,
+}
+
+public class Jpeg
+{
+    private static readonly NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
+
+    readonly int timeout = 2000;
+    readonly int taskID;
+    readonly int port;
+    readonly string address;
+    private IPEndPoint ep;
+
+    public Jpeg(string address, int port, int taskID, int timeout = 2000)
+    {
+        if (timeout < 0)
+            throw new ArgumentException("Timeout couldn't be negative", nameof(timeout));
+        this.address = address;
+        this.taskID = taskID;
+        this.port = port;
+        this.ep = new IPEndPoint(IPAddress.Parse(address), port);
+        this.timeout = timeout;
+    }
+
+    public async ValueTask<bool> SetEnable(bool enable)
+    {
+        var ret = await UDPClientPool.WriteAddr(
+            this.ep, this.taskID, JpegAddr.ENABLE, Convert.ToUInt32(enable), this.timeout);
+        if (!ret.IsSuccessful)
+        {
+            logger.Error($"Failed to set JPEG enable: {ret.Error}");
+            return false;
+        }
+        return ret.Value;
+    }
+
+    public async ValueTask<bool> SetSampleRate(uint rate)
+    {
+        var ret = await UDPClientPool.WriteAddr(
+            this.ep, this.taskID, JpegAddr.FRAME_SAMPLE_RATE, rate, this.timeout);
+        if (!ret.IsSuccessful)
+        {
+            logger.Error($"Failed to set JPEG sample rate: {ret.Error}");
+            return false;
+        }
+        return ret.Value;
+    }
+
+    public async ValueTask<bool> SetSampleRate(JpegSampleRate rate)
+    {
+        return await SetSampleRate((uint)rate);
+    }
+
+    public async ValueTask<uint> GetFrameNumber()
+    {
+        var ret = await UDPClientPool.ReadAddrByte(
+            this.ep, this.taskID, JpegAddr.FRAME_NUM, this.timeout);
+        if (!ret.IsSuccessful)
+        {
+            logger.Error($"Failed to get JPEG frame number: {ret.Error}");
+            return 0;
+        }
+        return Number.BytesToUInt32(ret.Value.Options.Data ?? Array.Empty<byte>()).Value;
+    }
+
+    public async ValueTask<Optional<List<JpegInfo>>> GetFrameInfo(int num)
+    {
+        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, JpegAddr.FRAME_INFO, num, this.timeout);
+        if (!ret.IsSuccessful)
+        {
+            logger.Error($"Failed to get JPEG frame info: {ret.Error}");
+            return new(null);
+        }
+
+        var data = ret.Value.Options.Data;
+        if (data == null || data.Length == 0)
+        {
+            logger.Error($"Data is null or empty");
+            return new(null);
+        }
+        if (data.Length != num * 2)
+        {
+            logger.Error(
+                $"Data length should be {num * 2} bytes, instead of {data.Length} bytes");
+            return new(null);
+        }
+
+        var infos = new List<JpegInfo>();
+        for (int i = 0; i < num; i++)
+        {
+            infos.Add(new JpegInfo(data[i..(i + 1)]));
+        }
+        return new(infos);
+    }
+
+    public async ValueTask<bool> UpdatePointer(uint cnt)
+    {
+        var ret = await UDPClientPool.WriteAddr(
+            this.ep, this.taskID, JpegAddr.FRAME_DATA_MAX_POINTER, cnt, this.timeout);
+        if (!ret.IsSuccessful)
+        {
+            logger.Error($"Failed to update pointer: {ret.Error}");
+            return false;
+        }
+        return ret.Value;
+    }
+
+    public async ValueTask<Result<byte[]?>> GetFrame(uint offset, uint length)
+    {
+        if (!MsgBus.IsRunning)
+        {
+            logger.Error("Message bus is not running");
+            return new(new Exception("Message bus is not running"));
+        }
+        MsgBus.UDPServer.ClearUDPData(this.ep.Address.ToString(), this.ep.Port);
+
+        var firstReadLength = (int)(Math.Min(length, JpegAddr.DDR_FRAME_DATA_MAX_ADDR - offset));
+        var secondReadLength = (int)(length - firstReadLength);
+        var dataBytes = new byte[length];
+
+        {
+            var ret = await UDPClientPool.ReadAddr4Bytes(
+                this.ep, this.taskID, JpegAddr.DDR_FRAME_DATA_ADDR + offset, firstReadLength, this.timeout);
+            if (!ret.IsSuccessful)
+            {
+                logger.Error($"Failed to get JPEG frame data: {ret.Error}");
+                return null;
+            }
+            if (ret.Value.Length != firstReadLength)
+            {
+                logger.Error($"Data length should be {firstReadLength} bytes, instead of {ret.Value.Length} bytes");
+                return null;
+            }
+            Buffer.BlockCopy(ret.Value, 0, dataBytes, 0, firstReadLength);
+        }
+
+        if (secondReadLength > 0)
+        {
+            var ret = await UDPClientPool.ReadAddr4Bytes(
+                this.ep, this.taskID, JpegAddr.DDR_FRAME_DATA_ADDR, secondReadLength, this.timeout);
+            if (!ret.IsSuccessful)
+            {
+                logger.Error($"Failed to get JPEG frame data: {ret.Error}");
+                return null;
+            }
+            if (ret.Value.Length != secondReadLength)
+            {
+                logger.Error($"Data length should be {secondReadLength} bytes, instead of {ret.Value.Length} bytes");
+                return null;
+            }
+            Buffer.BlockCopy(ret.Value, 0, dataBytes, firstReadLength, secondReadLength);
+        }
+
+        return dataBytes;
+    }
+
+    public async ValueTask<List<byte[]>> GetMultiFrames(uint offset, uint[] sizes)
+    {
+        var frames = new List<byte[]>();
+        for (int i = 0; i < sizes.Length; i++)
+        {
+            var ret = await GetFrame(offset, sizes[i]);
+            if (!ret.IsSuccessful)
+            {
+                logger.Error($"Failed to get JPEG frame {i} data: {ret.Error}");
+                continue;
+            }
+            if (ret.Value == null)
+            {
+                logger.Error($"Frame {i} data is null");
+                continue;
+            }
+            if (ret.Value.Length != sizes[i])
+            {
+                logger.Error(
+                    $"Frame {i} data length should be {sizes[i]} bytes, instead of {ret.Value.Length} bytes");
+                continue;
+            }
+
+            frames.Add(ret.Value);
+            offset += sizes[i];
+        }
+
+        {
+            var ret = await UpdatePointer((uint)sizes.Length);
+            if (!ret) logger.Error($"Failed to update pointer");
+        }
+
+        return frames;
+    }
+
+    public async ValueTask<Result<List<byte[]>?>> GetMultiFrames(uint offset)
+    {
+        if (!MsgBus.IsRunning)
+        {
+            logger.Error("Message bus is not running");
+            return new(new Exception("Message bus is not running"));
+        }
+        MsgBus.UDPServer.ClearUDPData(this.ep.Address.ToString(), this.ep.Port);
+
+        var frameNum = await GetFrameNumber();
+        if (frameNum == 0) return null;
+
+        List<uint>? frameSizes = null;
+        {
+            var ret = await GetFrameInfo((int)frameNum);
+            if (!ret.HasValue || ret.Value.Count == 0)
+            {
+                logger.Error($"Failed to get frame info");
+                return null;
+            }
+            frameSizes = ret.Value.Select(x => x.Size).ToList();
+        }
+
+        var frames = await GetMultiFrames(offset, frameSizes.ToArray());
+        if (frames.Count == 0)
+        {
+            logger.Error($"Failed to get frames");
+            return null;
+        }
+
+        return frames;
+    }
+}

server/src/Peripherals/LogicAnalyzerClient.cs

@@ -366,7 +366,7 @@ public class Analyzer
     /// <returns>操作结果，成功返回寄存器值，否则返回异常信息</returns>
     public async ValueTask<Result<CaptureStatus>> ReadCaptureStatus()
     {
-        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, AnalyzerAddr.CAPTURE_MODE, this.timeout);
+        var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, AnalyzerAddr.CAPTURE_MODE, this.timeout);
         if (!ret.IsSuccessful)
         {
             logger.Error($"Failed to read capture status: {ret.Error}");

server/src/Peripherals/OscilloscopeClient.cs

@@ -232,7 +232,7 @@ class Oscilloscope
     /// <returns>操作结果，成功返回采样频率值，否则返回异常信息</returns>
     public async ValueTask<Result<UInt32>> GetADFrequency()
     {
-        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, OscilloscopeAddr.AD_FREQ, this.timeout);
+        var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, OscilloscopeAddr.AD_FREQ, this.timeout);
         if (!ret.IsSuccessful)
         {
             logger.Error($"Failed to read AD frequency: {ret.Error}");
@@ -255,7 +255,7 @@ class Oscilloscope
     /// <returns>操作结果，成功返回采样幅度值，否则返回异常信息</returns>
     public async ValueTask<Result<byte>> GetADVpp()
     {
-        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, OscilloscopeAddr.AD_VPP, this.timeout);
+        var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, OscilloscopeAddr.AD_VPP, this.timeout);
         if (!ret.IsSuccessful)
         {
             logger.Error($"Failed to read AD VPP: {ret.Error}");
@@ -275,7 +275,7 @@ class Oscilloscope
     /// <returns>操作结果，成功返回采样最大值，否则返回异常信息</returns>
     public async ValueTask<Result<byte>> GetADMax()
     {
-        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, OscilloscopeAddr.AD_MAX, this.timeout);
+        var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, OscilloscopeAddr.AD_MAX, this.timeout);
         if (!ret.IsSuccessful)
         {
             logger.Error($"Failed to read AD max: {ret.Error}");
@@ -295,7 +295,7 @@ class Oscilloscope
     /// <returns>操作结果，成功返回采样最小值，否则返回异常信息</returns>
     public async ValueTask<Result<byte>> GetADMin()
     {
-        var ret = await UDPClientPool.ReadAddr(this.ep, this.taskID, OscilloscopeAddr.AD_MIN, this.timeout);
+        var ret = await UDPClientPool.ReadAddrByte(this.ep, this.taskID, OscilloscopeAddr.AD_MIN, this.timeout);
         if (!ret.IsSuccessful)
         {
             logger.Error($"Failed to read AD min: {ret.Error}");

server/src/Peripherals/RemoteUpdateClient.cs

@@ -339,7 +339,7 @@ public class RemoteUpdater
         }
 
         {
-            var ret = await UDPClientPool.ReadAddr(this.ep, 0, RemoteUpdaterAddr.ReadCRC, this.timeout);
+            var ret = await UDPClientPool.ReadAddrByte(this.ep, 0, RemoteUpdaterAddr.ReadCRC, this.timeout);
             if (!ret.IsSuccessful) return new(ret.Error);
 
             var bytes = ret.Value.Options.Data;
@@ -543,7 +543,7 @@ public class RemoteUpdater
         logger.Trace("Clear udp data finished");
 
         {
-            var ret = await UDPClientPool.ReadAddr(this.ep, 0, RemoteUpdaterAddr.Version, this.timeout);
+            var ret = await UDPClientPool.ReadAddrByte(this.ep, 0, RemoteUpdaterAddr.Version, this.timeout);
             if (!ret.IsSuccessful) return new(ret.Error);
 
             var retData = ret.Value.Options.Data;

server/src/Services/HttpHdmiVideoStreamService.cs

@@ -23,7 +23,7 @@ public class HttpHdmiVideoStreamService : BackgroundService
     public override async Task StartAsync(CancellationToken cancellationToken)
     {
         _httpListener = new HttpListener();
-        _httpListener.Prefixes.Add($"http://*:{_serverPort}/");
+        _httpListener.Prefixes.Add($"http://{Global.localhost}:{_serverPort}/");
         _httpListener.Start();
         logger.Info($"HDMI Video Stream Service started on port {_serverPort}");
 
@@ -32,46 +32,38 @@ public class HttpHdmiVideoStreamService : BackgroundService
 
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
-        try
+        while (!stoppingToken.IsCancellationRequested)
         {
-            while (!stoppingToken.IsCancellationRequested)
+            if (_httpListener == null) continue;
+            try
             {
-                HttpListenerContext? context = null;
+                logger.Debug("Waiting for HTTP request...");
-                try
+                var contextTask = _httpListener.GetContextAsync();
+                var completedTask = await Task.WhenAny(contextTask, Task.Delay(-1, stoppingToken));
+                if (completedTask == contextTask)
                 {
-                    logger.Debug("Waiting for HTTP request...");
+                    var context = contextTask.Result;
-                    context = await _httpListener.GetContextAsync();
                     logger.Debug($"Received request: {context.Request.Url?.AbsolutePath}");
+                    if (context != null)
+                        _ = HandleRequestAsync(context, stoppingToken);
                 }
-                catch (ObjectDisposedException)
+                else
                 {
-                    // Listener closed, exit loop
                     break;
                 }
-                catch (HttpListenerException)
-                {
-                    // Listener closed, exit loop
-                    break;
-                }
-                catch (Exception ex)
-                {
-                    logger.Error(ex, "Error in GetContextAsync");
-                    break;
-                }
-                if (context != null)
-                    _ = HandleRequestAsync(context, stoppingToken);
             }
-        }
+            catch (Exception ex)
-        finally
+            {
-        {
+                logger.Error(ex, "Error in GetContextAsync");
-            _httpListener?.Close();
+                break;
-            logger.Info("HDMI Video Stream Service stopped.");
+            }
         }
     }
 
     public override async Task StopAsync(CancellationToken cancellationToken)
     {
         logger.Info("Stopping HDMI Video Stream Service...");
+        _httpListener?.Close();
 
         // 禁用所有活跃的HDMI传输
         var disableTasks = new List<Task>();
@@ -229,9 +221,6 @@ public class HttpHdmiVideoStreamService : BackgroundService
         {
             logger.Debug("处理HDMI快照请求");
 
-            const int frameWidth = 960;  // HDMI输入分辨率
-            const int frameHeight = 540;
-
             // 从HDMI读取RGB565数据
             var frameResult = await hdmiIn.ReadFrame();
             if (!frameResult.IsSuccessful || frameResult.Value == null)
@@ -244,41 +233,7 @@ public class HttpHdmiVideoStreamService : BackgroundService
                 return;
             }
 
-            var rgb565Data = frameResult.Value;
+            var jpegData = frameResult.Value;
-
-            // 验证数据长度
-            var expectedLength = frameWidth * frameHeight * 2;
-            if (rgb565Data.Length != expectedLength)
-            {
-                logger.Warn("HDMI快照数据长度不匹配，期望: {Expected}, 实际: {Actual}",
-                    expectedLength, rgb565Data.Length);
-            }
-
-            // 将RGB565转换为RGB24
-            var rgb24Result = Common.Image.ConvertRGB565ToRGB24(rgb565Data, frameWidth, frameHeight, isLittleEndian: false);
-            if (!rgb24Result.IsSuccessful)
-            {
-                logger.Error("HDMI快照RGB565转RGB24失败: {Error}", rgb24Result.Error);
-                response.StatusCode = 500;
-                var errorBytes = System.Text.Encoding.UTF8.GetBytes("Failed to process HDMI snapshot");
-                await response.OutputStream.WriteAsync(errorBytes, 0, errorBytes.Length, cancellationToken);
-                response.Close();
-                return;
-            }
-
-            // 将RGB24转换为JPEG
-            var jpegResult = Common.Image.ConvertRGB24ToJpeg(rgb24Result.Value, frameWidth, frameHeight, 80);
-            if (!jpegResult.IsSuccessful)
-            {
-                logger.Error("HDMI快照RGB24转JPEG失败: {Error}", jpegResult.Error);
-                response.StatusCode = 500;
-                var errorBytes = System.Text.Encoding.UTF8.GetBytes("Failed to encode HDMI snapshot");
-                await response.OutputStream.WriteAsync(errorBytes, 0, errorBytes.Length, cancellationToken);
-                response.Close();
-                return;
-            }
-
-            var jpegData = jpegResult.Value;
 
             // 设置响应头（参考Camera版本）
             response.ContentType = "image/jpeg";
@@ -314,8 +269,6 @@ public class HttpHdmiVideoStreamService : BackgroundService
             logger.Debug("开始HDMI MJPEG流传输");
 
             int frameCounter = 0;
-            const int frameWidth = 960;  // HDMI输入分辨率
-            const int frameHeight = 540;
 
             while (!cancellationToken.IsCancellationRequested)
             {
@@ -323,61 +276,13 @@ public class HttpHdmiVideoStreamService : BackgroundService
                 {
                     var frameStartTime = DateTime.UtcNow;
 
-                    // 从HDMI读取RGB565数据
+                    var ret = await hdmiIn.GetMJpegFrame();
-                    var readStartTime = DateTime.UtcNow;
+                    if (ret == null) continue;
-                    var frameResult = await hdmiIn.ReadFrame();
+                    var frame = ret.Value;
-                    var readEndTime = DateTime.UtcNow;
-                    var readTime = (readEndTime - readStartTime).TotalMilliseconds;
 
-                    if (!frameResult.IsSuccessful || frameResult.Value == null)
+                    await response.OutputStream.WriteAsync(frame.header, 0, frame.header.Length, cancellationToken);
-                    {
+                    await response.OutputStream.WriteAsync(frame.data, 0, frame.data.Length, cancellationToken);
-                        logger.Warn("HDMI帧读取失败或为空");
+                    await response.OutputStream.WriteAsync(frame.footer, 0, frame.footer.Length, cancellationToken);
-                        continue;
-                    }
-
-                    var rgb565Data = frameResult.Value;
-
-                    // 验证数据长度是否正确 (RGB565为每像素2字节)
-                    var expectedLength = frameWidth * frameHeight * 2;
-                    if (rgb565Data.Length != expectedLength)
-                    {
-                        logger.Warn("HDMI数据长度不匹配，期望: {Expected}, 实际: {Actual}",
-                            expectedLength, rgb565Data.Length);
-                    }
-
-                    // 将RGB565转换为RGB24（参考Camera版本的处理）
-                    var convertStartTime = DateTime.UtcNow;
-                    var rgb24Result = Common.Image.ConvertRGB565ToRGB24(rgb565Data, frameWidth, frameHeight, isLittleEndian: false);
-                    var convertEndTime = DateTime.UtcNow;
-                    var convertTime = (convertEndTime - convertStartTime).TotalMilliseconds;
-
-                    if (!rgb24Result.IsSuccessful)
-                    {
-                        logger.Error("HDMI RGB565转RGB24失败: {Error}", rgb24Result.Error);
-                        continue;
-                    }
-
-                    // 将RGB24转换为JPEG（参考Camera版本的处理）
-                    var jpegStartTime = DateTime.UtcNow;
-                    var jpegResult = Common.Image.ConvertRGB24ToJpeg(rgb24Result.Value, frameWidth, frameHeight, 80);
-                    var jpegEndTime = DateTime.UtcNow;
-                    var jpegTime = (jpegEndTime - jpegStartTime).TotalMilliseconds;
-
-                    if (!jpegResult.IsSuccessful)
-                    {
-                        logger.Error("HDMI RGB24转JPEG失败: {Error}", jpegResult.Error);
-                        continue;
-                    }
-
-                    var jpegData = jpegResult.Value;
-
-                    // 发送MJPEG帧（使用Camera版本的格式）
-                    var mjpegFrameHeader = Common.Image.CreateMjpegFrameHeader(jpegData.Length);
-                    var mjpegFrameFooter = Common.Image.CreateMjpegFrameFooter();
-
-                    await response.OutputStream.WriteAsync(mjpegFrameHeader, 0, mjpegFrameHeader.Length, cancellationToken);
-                    await response.OutputStream.WriteAsync(jpegData, 0, jpegData.Length, cancellationToken);
-                    await response.OutputStream.WriteAsync(mjpegFrameFooter, 0, mjpegFrameFooter.Length, cancellationToken);
                     await response.OutputStream.FlushAsync(cancellationToken);
 
                     frameCounter++;
@@ -387,8 +292,8 @@ public class HttpHdmiVideoStreamService : BackgroundService
                     // 性能统计日志（每30帧记录一次）
                     if (frameCounter % 30 == 0)
                     {
-                        logger.Debug("HDMI帧 {FrameNumber} 性能统计 - 读取: {ReadTime:F1}ms, RGB转换: {ConvertTime:F1}ms, JPEG转换: {JpegTime:F1}ms, 总计: {TotalTime:F1}ms, JPEG大小: {JpegSize} 字节",
+                        logger.Debug("HDMI帧 {FrameNumber} 性能统计 - 总计: {TotalTime:F1}ms, JPEG大小: {JpegSize} 字节",
-                            frameCounter, readTime, convertTime, jpegTime, totalTime, jpegData.Length);
+                            frameCounter, totalTime, frame.data.Length);
                     }
                 }
                 catch (Exception ex)

server/src/Services/ProgressTrackerService.cs

@@ -21,7 +21,7 @@ public class ProgressReporter : ProgressInfo, IProgress<int>
         set
         {
             _stepProgress = value;
-            ExpectedSteps = MaxProgress / value;
+            _expectedSteps = MaxProgress / value;
         }
     }
     public int ExpectedSteps
@@ -31,7 +31,7 @@ public class ProgressReporter : ProgressInfo, IProgress<int>
         {
             _expectedSteps = value;
             MaxProgress = Number.IntPow(10, Number.GetLength(value));
-            StepProgress = MaxProgress / value;
+            _stepProgress = MaxProgress / value;
         }
     }
     public Func<int, Task>? ReporterFunc { get; set; } = null;
@@ -41,7 +41,7 @@ public class ProgressReporter : ProgressInfo, IProgress<int>
     private ProgressStatus _status = ProgressStatus.Pending;
     private string _errorMessage;
 
-    public string TaskId { get; set; } = new Guid().ToString();
+    public string TaskId { get; set; } = Guid.NewGuid().ToString();
     public int ProgressPercent => _progress * 100 / MaxProgress;
     public ProgressStatus Status => _status;
     public string ErrorMessage => _errorMessage;
@@ -190,7 +190,7 @@ public class ProgressTrackerService : BackgroundService
             {
                 logger.Error(ex, "Error during ProgressTracker cleanup");
             }
-            await Task.Delay(TimeSpan.FromSeconds(30));
+            await Task.Delay(TimeSpan.FromSeconds(30), stoppingToken);
         }
     }
 

server/src/UdpClientPool.cs

@@ -223,22 +223,28 @@ public class UDPClientPool
     /// <param name="endPoint">IP端点（IP地址与端口）</param>
     /// <param name="taskID">任务ID</param>
     /// <param name="devAddr">设备地址</param>
+    /// <param name="dataLength">数据长度(0~255)</param>
     /// <param name="timeout">超时时间（毫秒）</param>
     /// <returns>读取结果，包含接收到的数据包</returns>
     public static async ValueTask<Result<RecvDataPackage>> ReadAddr(
-            IPEndPoint endPoint, int taskID, uint devAddr, int timeout = 1000)
+            IPEndPoint endPoint, int taskID, uint devAddr, int dataLength, int timeout = 1000)
     {
+        if (dataLength <= 0)
+            return new(new ArgumentException("Data length must be greater than 0"));
+
+        if (dataLength > 255)
+            return new(new ArgumentException("Data length must be less than or equal to 255"));
+
         var ret = false;
         var opts = new SendAddrPackOptions()
         {
             BurstType = BurstType.FixedBurst,
-            BurstLength = 0,
+            BurstLength = ((byte)(dataLength - 1)),
             CommandID = Convert.ToByte(taskID),
             Address = devAddr,
             IsWrite = false,
         };
 
-
         // Read Register
         ret = await UDPClientPool.SendAddrPackAsync(endPoint, new SendAddrPackage(opts));
         if (!ret) return new(new Exception("Send Address Package Failed!"));
@@ -260,6 +266,20 @@ public class UDPClientPool
         return retPack;
     }
 
+    /// <summary>
+    /// 读取设备地址数据
+    /// </summary>
+    /// <param name="endPoint">IP端点（IP地址与端口）</param>
+    /// <param name="taskID">任务ID</param>
+    /// <param name="devAddr">设备地址</param>
+    /// <param name="timeout">超时时间（毫秒）</param>
+    /// <returns>读取结果，包含接收到的数据包</returns>
+    public static async ValueTask<Result<RecvDataPackage>> ReadAddrByte(
+            IPEndPoint endPoint, int taskID, uint devAddr, int timeout = 1000)
+    {
+        return await ReadAddr(endPoint, taskID, devAddr, 0, timeout);
+    }
+
     /// <summary>
     /// 读取设备地址数据并校验结果
     /// </summary>
@@ -271,11 +291,11 @@ public class UDPClientPool
     /// <param name="timeout">超时时间（毫秒）</param>
     /// <returns>校验结果，true表示数据匹配期望值</returns>
     public static async ValueTask<Result<bool>> ReadAddr(
-            IPEndPoint endPoint, int taskID, uint devAddr, UInt32 result, UInt32 resultMask, int timeout = 1000)
+                IPEndPoint endPoint, int taskID, uint devAddr, UInt32 result, UInt32 resultMask, int timeout = 1000)
     {
         var address = endPoint.Address.ToString();
 
-        var ret = await ReadAddr(endPoint, taskID, devAddr, timeout);
+        var ret = await ReadAddrByte(endPoint, taskID, devAddr, timeout);
         if (!ret.IsSuccessful) return new(ret.Error);
         if (!ret.Value.IsSuccessful)
             return new(new Exception($"Read device {address} address {devAddr} failed"));
@@ -324,7 +344,7 @@ public class UDPClientPool
             await Task.Delay(waittime);
             try
             {
-                var ret = await ReadAddr(endPoint, taskID, devAddr, Convert.ToInt32(timeleft.TotalMilliseconds));
+                var ret = await ReadAddrByte(endPoint, taskID, devAddr, Convert.ToInt32(timeleft.TotalMilliseconds));
                 if (!ret.IsSuccessful) return new(ret.Error);
                 if (!ret.Value.IsSuccessful)
                     return new(new Exception($"Read device {address} address {devAddr} failed"));
@@ -555,7 +575,7 @@ public class UDPClientPool
         var resultData = new List<byte>();
         for (int i = 0; i < length; i++)
         {
-            var ret = await ReadAddr(endPoint, taskID, addr[i], timeout);
+            var ret = await ReadAddrByte(endPoint, taskID, addr[i], timeout);
             if (!ret.IsSuccessful)
             {
                 logger.Error($"ReadAddrSeq failed at index {i}: {ret.Error}");

src/APIClient.ts

@@ -185,12 +185,8 @@ export class VideoStreamClient {
         return Promise.resolve<any>(null as any);
     }
 
-    /**
+    myEndpoint( cancelToken?: CancelToken): Promise<any> {
-     * 获取 HTTP 视频流信息
+        let url_ = this.baseUrl + "/api/VideoStream/MyEndpoint";
-     * @return 流信息
-     */
-    getStreamInfo( cancelToken?: CancelToken): Promise<StreamInfoResult> {
-        let url_ = this.baseUrl + "/api/VideoStream/StreamInfo";
         url_ = url_.replace(/[?&]$/, "");
 
         let options_: AxiosRequestConfig = {
@@ -209,208 +205,11 @@ export class VideoStreamClient {
                 throw _error;
             }
         }).then((_response: AxiosResponse) => {
-            return this.processGetStreamInfo(_response);
+            return this.processMyEndpoint(_response);
         });
     }
 
-    protected processGetStreamInfo(response: AxiosResponse): Promise<StreamInfoResult> {
+    protected processMyEndpoint(response: AxiosResponse): Promise<any> {
-        const status = response.status;
-        let _headers: any = {};
-        if (response.headers && typeof response.headers === "object") {
-            for (const k in response.headers) {
-                if (response.headers.hasOwnProperty(k)) {
-                    _headers[k] = response.headers[k];
-                }
-            }
-        }
-        if (status === 200) {
-            const _responseText = response.data;
-            let result200: any = null;
-            let resultData200  = _responseText;
-            result200 = StreamInfoResult.fromJS(resultData200);
-            return Promise.resolve<StreamInfoResult>(result200);
-
-        } else if (status === 500) {
-            const _responseText = response.data;
-            let result500: any = null;
-            let resultData500  = _responseText;
-            result500 = Exception.fromJS(resultData500);
-            return throwException("A server side error occurred.", status, _responseText, _headers, result500);
-
-        } else if (status !== 200 && status !== 204) {
-            const _responseText = response.data;
-            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
-        }
-        return Promise.resolve<StreamInfoResult>(null as any);
-    }
-
-    /**
-     * 配置摄像头连接参数
-     * @param config 摄像头配置
-     * @return 配置结果
-     */
-    configureCamera(config: CameraConfigRequest, cancelToken?: CancelToken): Promise<any> {
-        let url_ = this.baseUrl + "/api/VideoStream/ConfigureCamera";
-        url_ = url_.replace(/[?&]$/, "");
-
-        const content_ = JSON.stringify(config);
-
-        let options_: AxiosRequestConfig = {
-            data: content_,
-            method: "POST",
-            url: url_,
-            headers: {
-                "Content-Type": "application/json",
-                "Accept": "application/json"
-            },
-            cancelToken
-        };
-
-        return this.instance.request(options_).catch((_error: any) => {
-            if (isAxiosError(_error) && _error.response) {
-                return _error.response;
-            } else {
-                throw _error;
-            }
-        }).then((_response: AxiosResponse) => {
-            return this.processConfigureCamera(_response);
-        });
-    }
-
-    protected processConfigureCamera(response: AxiosResponse): Promise<any> {
-        const status = response.status;
-        let _headers: any = {};
-        if (response.headers && typeof response.headers === "object") {
-            for (const k in response.headers) {
-                if (response.headers.hasOwnProperty(k)) {
-                    _headers[k] = response.headers[k];
-                }
-            }
-        }
-        if (status === 200) {
-            const _responseText = response.data;
-            let result200: any = null;
-            let resultData200  = _responseText;
-                result200 = resultData200 !== undefined ? resultData200 : <any>null;
-    
-            return Promise.resolve<any>(result200);
-
-        } else if (status === 400) {
-            const _responseText = response.data;
-            let result400: any = null;
-            let resultData400  = _responseText;
-                result400 = resultData400 !== undefined ? resultData400 : <any>null;
-    
-            return throwException("A server side error occurred.", status, _responseText, _headers, result400);
-
-        } else if (status === 500) {
-            const _responseText = response.data;
-            let result500: any = null;
-            let resultData500  = _responseText;
-            result500 = Exception.fromJS(resultData500);
-            return throwException("A server side error occurred.", status, _responseText, _headers, result500);
-
-        } else if (status !== 200 && status !== 204) {
-            const _responseText = response.data;
-            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
-        }
-        return Promise.resolve<any>(null as any);
-    }
-
-    /**
-     * 获取当前摄像头配置
-     * @return 摄像头配置信息
-     */
-    getCameraConfig( cancelToken?: CancelToken): Promise<any> {
-        let url_ = this.baseUrl + "/api/VideoStream/CameraConfig";
-        url_ = url_.replace(/[?&]$/, "");
-
-        let options_: AxiosRequestConfig = {
-            method: "GET",
-            url: url_,
-            headers: {
-                "Accept": "application/json"
-            },
-            cancelToken
-        };
-
-        return this.instance.request(options_).catch((_error: any) => {
-            if (isAxiosError(_error) && _error.response) {
-                return _error.response;
-            } else {
-                throw _error;
-            }
-        }).then((_response: AxiosResponse) => {
-            return this.processGetCameraConfig(_response);
-        });
-    }
-
-    protected processGetCameraConfig(response: AxiosResponse): Promise<any> {
-        const status = response.status;
-        let _headers: any = {};
-        if (response.headers && typeof response.headers === "object") {
-            for (const k in response.headers) {
-                if (response.headers.hasOwnProperty(k)) {
-                    _headers[k] = response.headers[k];
-                }
-            }
-        }
-        if (status === 200) {
-            const _responseText = response.data;
-            let result200: any = null;
-            let resultData200  = _responseText;
-                result200 = resultData200 !== undefined ? resultData200 : <any>null;
-    
-            return Promise.resolve<any>(result200);
-
-        } else if (status === 500) {
-            const _responseText = response.data;
-            let result500: any = null;
-            let resultData500  = _responseText;
-            result500 = Exception.fromJS(resultData500);
-            return throwException("A server side error occurred.", status, _responseText, _headers, result500);
-
-        } else if (status !== 200 && status !== 204) {
-            const _responseText = response.data;
-            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
-        }
-        return Promise.resolve<any>(null as any);
-    }
-
-    /**
-     * 控制 HTTP 视频流服务开关
-     * @param enabled (optional) 是否启用服务
-     * @return 操作结果
-     */
-    setEnabled(enabled: boolean | undefined, cancelToken?: CancelToken): Promise<any> {
-        let url_ = this.baseUrl + "/api/VideoStream/SetEnabled?";
-        if (enabled === null)
-            throw new Error("The parameter 'enabled' cannot be null.");
-        else if (enabled !== undefined)
-            url_ += "enabled=" + encodeURIComponent("" + enabled) + "&";
-        url_ = url_.replace(/[?&]$/, "");
-
-        let options_: AxiosRequestConfig = {
-            method: "POST",
-            url: url_,
-            headers: {
-                "Accept": "application/json"
-            },
-            cancelToken
-        };
-
-        return this.instance.request(options_).catch((_error: any) => {
-            if (isAxiosError(_error) && _error.response) {
-                return _error.response;
-            } else {
-                throw _error;
-            }
-        }).then((_response: AxiosResponse) => {
-            return this.processSetEnabled(_response);
-        });
-    }
-
-    protected processSetEnabled(response: AxiosResponse): Promise<any> {
         const status = response.status;
         let _headers: any = {};
         if (response.headers && typeof response.headers === "object") {
@@ -502,6 +301,59 @@ export class VideoStreamClient {
         return Promise.resolve<boolean>(null as any);
     }
 
+    disableHdmiTransmission( cancelToken?: CancelToken): Promise<FileResponse | null> {
+        let url_ = this.baseUrl + "/api/VideoStream/DisableTransmission";
+        url_ = url_.replace(/[?&]$/, "");
+
+        let options_: AxiosRequestConfig = {
+            responseType: "blob",
+            method: "POST",
+            url: url_,
+            headers: {
+                "Accept": "application/octet-stream"
+            },
+            cancelToken
+        };
+
+        return this.instance.request(options_).catch((_error: any) => {
+            if (isAxiosError(_error) && _error.response) {
+                return _error.response;
+            } else {
+                throw _error;
+            }
+        }).then((_response: AxiosResponse) => {
+            return this.processDisableHdmiTransmission(_response);
+        });
+    }
+
+    protected processDisableHdmiTransmission(response: AxiosResponse): Promise<FileResponse | null> {
+        const status = response.status;
+        let _headers: any = {};
+        if (response.headers && typeof response.headers === "object") {
+            for (const k in response.headers) {
+                if (response.headers.hasOwnProperty(k)) {
+                    _headers[k] = response.headers[k];
+                }
+            }
+        }
+        if (status === 200 || status === 206) {
+            const contentDisposition = response.headers ? response.headers["content-disposition"] : undefined;
+            let fileNameMatch = contentDisposition ? /filename\*=(?:(\\?['"])(.*?)\1|(?:[^\s]+'.*?')?([^;\n]*))/g.exec(contentDisposition) : undefined;
+            let fileName = fileNameMatch && fileNameMatch.length > 1 ? fileNameMatch[3] || fileNameMatch[2] : undefined;
+            if (fileName) {
+                fileName = decodeURIComponent(fileName);
+            } else {
+                fileNameMatch = contentDisposition ? /filename="?([^"]*?)"?(;|$)/g.exec(contentDisposition) : undefined;
+                fileName = fileNameMatch && fileNameMatch.length > 1 ? fileNameMatch[1] : undefined;
+            }
+            return Promise.resolve({ fileName: fileName, status: status, data: new Blob([response.data], { type: response.headers["content-type"] }), headers: _headers });
+        } else if (status !== 200 && status !== 204) {
+            const _responseText = response.data;
+            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
+        }
+        return Promise.resolve<FileResponse | null>(null as any);
+    }
+
     /**
      * 设置视频流分辨率
      * @param request 分辨率配置请求
@@ -576,67 +428,6 @@ export class VideoStreamClient {
         return Promise.resolve<any>(null as any);
     }
 
-    /**
-     * 获取当前分辨率
-     * @return 当前分辨率信息
-     */
-    getCurrentResolution( cancelToken?: CancelToken): Promise<any> {
-        let url_ = this.baseUrl + "/api/VideoStream/Resolution";
-        url_ = url_.replace(/[?&]$/, "");
-
-        let options_: AxiosRequestConfig = {
-            method: "GET",
-            url: url_,
-            headers: {
-                "Accept": "application/json"
-            },
-            cancelToken
-        };
-
-        return this.instance.request(options_).catch((_error: any) => {
-            if (isAxiosError(_error) && _error.response) {
-                return _error.response;
-            } else {
-                throw _error;
-            }
-        }).then((_response: AxiosResponse) => {
-            return this.processGetCurrentResolution(_response);
-        });
-    }
-
-    protected processGetCurrentResolution(response: AxiosResponse): Promise<any> {
-        const status = response.status;
-        let _headers: any = {};
-        if (response.headers && typeof response.headers === "object") {
-            for (const k in response.headers) {
-                if (response.headers.hasOwnProperty(k)) {
-                    _headers[k] = response.headers[k];
-                }
-            }
-        }
-        if (status === 200) {
-            const _responseText = response.data;
-            let result200: any = null;
-            let resultData200  = _responseText;
-                result200 = resultData200 !== undefined ? resultData200 : <any>null;
-    
-            return Promise.resolve<any>(result200);
-
-        } else if (status === 500) {
-            const _responseText = response.data;
-            let result500: any = null;
-            let resultData500  = _responseText;
-                result500 = resultData500 !== undefined ? resultData500 : <any>null;
-    
-            return throwException("A server side error occurred.", status, _responseText, _headers, result500);
-
-        } else if (status !== 200 && status !== 204) {
-            const _responseText = response.data;
-            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
-        }
-        return Promise.resolve<any>(null as any);
-    }
-
     /**
      * 获取支持的分辨率列表
      * @return 支持的分辨率列表
@@ -835,75 +626,6 @@ export class VideoStreamClient {
         }
         return Promise.resolve<any>(null as any);
     }
-
-    /**
-     * 执行一次自动对焦 (GET方式)
-     * @return 对焦结果
-     */
-    focus( cancelToken?: CancelToken): Promise<any> {
-        let url_ = this.baseUrl + "/api/VideoStream/Focus";
-        url_ = url_.replace(/[?&]$/, "");
-
-        let options_: AxiosRequestConfig = {
-            method: "GET",
-            url: url_,
-            headers: {
-                "Accept": "application/json"
-            },
-            cancelToken
-        };
-
-        return this.instance.request(options_).catch((_error: any) => {
-            if (isAxiosError(_error) && _error.response) {
-                return _error.response;
-            } else {
-                throw _error;
-            }
-        }).then((_response: AxiosResponse) => {
-            return this.processFocus(_response);
-        });
-    }
-
-    protected processFocus(response: AxiosResponse): Promise<any> {
-        const status = response.status;
-        let _headers: any = {};
-        if (response.headers && typeof response.headers === "object") {
-            for (const k in response.headers) {
-                if (response.headers.hasOwnProperty(k)) {
-                    _headers[k] = response.headers[k];
-                }
-            }
-        }
-        if (status === 200) {
-            const _responseText = response.data;
-            let result200: any = null;
-            let resultData200  = _responseText;
-                result200 = resultData200 !== undefined ? resultData200 : <any>null;
-    
-            return Promise.resolve<any>(result200);
-
-        } else if (status === 400) {
-            const _responseText = response.data;
-            let result400: any = null;
-            let resultData400  = _responseText;
-                result400 = resultData400 !== undefined ? resultData400 : <any>null;
-    
-            return throwException("A server side error occurred.", status, _responseText, _headers, result400);
-
-        } else if (status === 500) {
-            const _responseText = response.data;
-            let result500: any = null;
-            let resultData500  = _responseText;
-                result500 = resultData500 !== undefined ? resultData500 : <any>null;
-    
-            return throwException("A server side error occurred.", status, _responseText, _headers, result500);
-
-        } else if (status !== 200 && status !== 204) {
-            const _responseText = response.data;
-            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
-        }
-        return Promise.resolve<any>(null as any);
-    }
 }
 
 export class BsdlParserClient {
@@ -7253,134 +6975,6 @@ export interface IException {
     stackTrace?: string | undefined;
 }
 
-/** 视频流信息结构体 */
-export class StreamInfoResult implements IStreamInfoResult {
-    /** TODO: */
-    frameRate!: number;
-    /** TODO: */
-    frameWidth!: number;
-    /** TODO: */
-    frameHeight!: number;
-    /** TODO: */
-    format!: string;
-    /** TODO: */
-    htmlUrl!: string;
-    /** TODO: */
-    mjpegUrl!: string;
-    /** TODO: */
-    snapshotUrl!: string;
-    /** TODO: */
-    usbCameraUrl!: string;
-
-    constructor(data?: IStreamInfoResult) {
-        if (data) {
-            for (var property in data) {
-                if (data.hasOwnProperty(property))
-                    (<any>this)[property] = (<any>data)[property];
-            }
-        }
-    }
-
-    init(_data?: any) {
-        if (_data) {
-            this.frameRate = _data["frameRate"];
-            this.frameWidth = _data["frameWidth"];
-            this.frameHeight = _data["frameHeight"];
-            this.format = _data["format"];
-            this.htmlUrl = _data["htmlUrl"];
-            this.mjpegUrl = _data["mjpegUrl"];
-            this.snapshotUrl = _data["snapshotUrl"];
-            this.usbCameraUrl = _data["usbCameraUrl"];
-        }
-    }
-
-    static fromJS(data: any): StreamInfoResult {
-        data = typeof data === 'object' ? data : {};
-        let result = new StreamInfoResult();
-        result.init(data);
-        return result;
-    }
-
-    toJSON(data?: any) {
-        data = typeof data === 'object' ? data : {};
-        data["frameRate"] = this.frameRate;
-        data["frameWidth"] = this.frameWidth;
-        data["frameHeight"] = this.frameHeight;
-        data["format"] = this.format;
-        data["htmlUrl"] = this.htmlUrl;
-        data["mjpegUrl"] = this.mjpegUrl;
-        data["snapshotUrl"] = this.snapshotUrl;
-        data["usbCameraUrl"] = this.usbCameraUrl;
-        return data;
-    }
-}
-
-/** 视频流信息结构体 */
-export interface IStreamInfoResult {
-    /** TODO: */
-    frameRate: number;
-    /** TODO: */
-    frameWidth: number;
-    /** TODO: */
-    frameHeight: number;
-    /** TODO: */
-    format: string;
-    /** TODO: */
-    htmlUrl: string;
-    /** TODO: */
-    mjpegUrl: string;
-    /** TODO: */
-    snapshotUrl: string;
-    /** TODO: */
-    usbCameraUrl: string;
-}
-
-/** 摄像头配置请求模型 */
-export class CameraConfigRequest implements ICameraConfigRequest {
-    /** 摄像头地址 */
-    address!: string;
-    /** 摄像头端口 */
-    port!: number;
-
-    constructor(data?: ICameraConfigRequest) {
-        if (data) {
-            for (var property in data) {
-                if (data.hasOwnProperty(property))
-                    (<any>this)[property] = (<any>data)[property];
-            }
-        }
-    }
-
-    init(_data?: any) {
-        if (_data) {
-            this.address = _data["address"];
-            this.port = _data["port"];
-        }
-    }
-
-    static fromJS(data: any): CameraConfigRequest {
-        data = typeof data === 'object' ? data : {};
-        let result = new CameraConfigRequest();
-        result.init(data);
-        return result;
-    }
-
-    toJSON(data?: any) {
-        data = typeof data === 'object' ? data : {};
-        data["address"] = this.address;
-        data["port"] = this.port;
-        return data;
-    }
-}
-
-/** 摄像头配置请求模型 */
-export interface ICameraConfigRequest {
-    /** 摄像头地址 */
-    address: string;
-    /** 摄像头端口 */
-    port: number;
-}
-
 /** 分辨率配置请求模型 */
 export class ResolutionConfigRequest implements IResolutionConfigRequest {
     /** 宽度 */

src/main.ts

@@ -1,10 +1,9 @@
-import './assets/main.css'
+import "./assets/main.css";
 
-import { createApp } from 'vue'
+import { createApp } from "vue";
-import { createPinia } from 'pinia'
+import { createPinia } from "pinia";
 
-import App from '@/App.vue'
+import App from "@/App.vue";
-import router from './router'
+import router from "./router";
-
-const app = createApp(App).use(router).use(createPinia()).mount('#app')
 
+const app = createApp(App).use(router).use(createPinia()).mount("#app");