feat: add power control

server/src/Controllers/PowerController.cs

@@ -0,0 +1,46 @@
+using System.Collections;
+using Microsoft.AspNetCore.Cors;
+using Microsoft.AspNetCore.Mvc;
+
+namespace server.Controllers;
+
+/// <summary>
+/// 矩阵键控制器，用于管理矩阵键的启用、禁用和状态设置
+/// </summary>
+[ApiController]
+[Route("api/[controller]")]
+public class PowerController : ControllerBase
+{
+    private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
+
+    /// <summary>
+    /// [TODO:description]
+    /// </summary>
+    /// <param name="address">[TODO:parameter]</param>
+    /// <param name="port">[TODO:parameter]</param>
+    /// <param name="enable">[TODO:parameter]</param>
+    /// <returns>[TODO:return]</returns>
+    [HttpPost("SetPowerOnOff")]
+    [EnableCors("Users")]
+    [ProducesResponseType(typeof(bool), StatusCodes.Status200OK)]
+    [ProducesResponseType(typeof(Exception), StatusCodes.Status500InternalServerError)]
+    public async ValueTask<IResult> SetPowerOnOff(string address, int port, bool enable)
+    {
+        var powerCtrl = new Peripherals.PowerClient.Power(address, port);
+        var ret = await powerCtrl.SetPowerOnOff(enable);
+
+        if (ret.IsSuccessful)
+        {
+            var powerStatus = enable ? "ON" : "OFF";
+            logger.Info($"Set device {address}:{port.ToString()} power {powerStatus} finished: {ret.Value}.");
+            return TypedResults.Ok(ret.Value);
+        }
+        else
+        {
+            logger.Error(ret.Error);
+            return TypedResults.InternalServerError(ret.Error);
+        }
+    }
+
+}
+

server/src/Peripherals/PowerClient.cs

@@ -0,0 +1,56 @@
+using System.Net;
+using DotNext;
+
+namespace Peripherals.PowerClient;
+
+class PowerAddr
+{
+    public const UInt32 Base = 0x10_00_00_00;
+    public const UInt32 PowerCtrl = Base + 7;
+}
+
+/// <summary>
+/// [TODO:description]
+/// </summary>
+public class Power
+{
+    private static readonly NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
+
+    readonly int timeout;
+
+    readonly int port;
+    readonly string address;
+    private IPEndPoint ep;
+
+    /// <summary>
+    /// [TODO:description]
+    /// </summary>
+    /// <param name="address">[TODO:parameter]</param>
+    /// <param name="port">[TODO:parameter]</param>
+    /// <param name="timeout">[TODO:parameter]</param>
+    /// <returns>[TODO:return]</returns>
+    public Power(string address, int port, int timeout = 1000)
+    {
+        this.address = address;
+        this.port = port;
+        this.ep = new IPEndPoint(IPAddress.Parse(address), port);
+        this.timeout = timeout;
+    }
+
+    /// <summary>
+    /// [TODO:description]
+    /// </summary>
+    /// <param name="enable">[TODO:parameter]</param>
+    /// <returns>[TODO:return]</returns>
+    public async ValueTask<Result<bool>> SetPowerOnOff(bool enable)
+    {
+        if (MsgBus.IsRunning)
+            await MsgBus.UDPServer.ClearUDPData(this.address);
+        else return new(new Exception("Message Bus not work!"));
+
+        var ret = await UDPClientPool.WriteAddr(this.ep, PowerAddr.PowerCtrl, Convert.ToUInt32(enable), this.timeout);
+        if (!ret.IsSuccessful) return new(ret.Error);
+        return ret.Value;
+    }
+}
+