97 lines
3.5 KiB
C#
97 lines
3.5 KiB
C#
|
using Ayay.SerilogLogs;
|
|||
|
|
using Newtonsoft.Json.Linq;
|
|||
|
|
using Serilog;
|
|||
|
|
using SHH.CameraSdk;
|
|||
|
|
using SHH.Contracts;
|
|||
|
|
|
|||
|
|
namespace SHH.CameraService;
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 预置点控制指令处理器
|
|||
|
|
/// 响应 gRpc 指令：ProtocolCodes.Preset_Control
|
|||
|
|
/// </summary>
|
|||
|
|
public class PresetControlHandler : ICommandHandler
|
|||
|
|
{
|
|||
|
|
private readonly ILogger _sysLog = Log.ForContext("SourceContext", LogModules.Core);
|
|||
|
|
private readonly CameraManager _cameraManager;
|
|||
|
|
|
|||
|
|
/// <summary>指令名称（需与网关下发的 CmdCode 一致）</summary>
|
|||
|
|
public string ActionName => ProtocolCodes.Device_Preset;
|
|||
|
|
|
|||
|
|
public PresetControlHandler(CameraManager cameraManager)
|
|||
|
|
{
|
|||
|
|
_cameraManager = cameraManager ?? throw new ArgumentNullException(nameof(cameraManager));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task ExecuteAsync(JToken payload)
|
|||
|
|
{
|
|||
|
|
// 1. 解析预置点控制参数
|
|||
|
|
// 假设 PresetControlDto 包含 DeviceId, PresetIndex, 和 Action (GOTO/SET/REMOVE)
|
|||
|
|
var presetDto = payload.ToObject<PresetControlDto>();
|
|||
|
|
if (presetDto == null || presetDto.DeviceId <= 0)
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning("[Preset] 无效指令：参数缺失或设备ID非法");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 2. 获取目标设备并校验能力
|
|||
|
|
var device = _cameraManager.GetDevice(presetDto.DeviceId);
|
|||
|
|
if (device == null)
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning($"[Preset] 设备 {presetDto.DeviceId} 不存在");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if (!device.IsPhysicalOnline)
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning($"[Preset] 设备 {presetDto.DeviceId} 未在线，无法执行预置点控制");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Optimized: [原因] 检查设备是否实现了预置点功能接口
|
|||
|
|
if (!(device is IPresetFeature presetFeature))
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning($"[Preset] 设备 {presetDto.DeviceId} ({device.Config.Name}) 不支持预置点功能");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 3. 分发执行逻辑
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
switch (presetDto.Action.ToUpper())
|
|||
|
|
{
|
|||
|
|
case "GOTO":
|
|||
|
|
await presetFeature.GotoPresetAsync(presetDto.PresetIndex);
|
|||
|
|
_sysLog.Information($"[Preset] 设备 {presetDto.DeviceId} 跳转至预置点: {presetDto.PresetIndex}");
|
|||
|
|
break;
|
|||
|
|
case "SET":
|
|||
|
|
await presetFeature.SetPresetAsync(presetDto.PresetIndex);
|
|||
|
|
_sysLog.Information($"[Preset] 设备 {presetDto.DeviceId} 设置当前位置为预置点: {presetDto.PresetIndex}");
|
|||
|
|
break;
|
|||
|
|
case "REMOVE":
|
|||
|
|
await presetFeature.RemovePresetAsync(presetDto.PresetIndex);
|
|||
|
|
_sysLog.Information($"[Preset] 设备 {presetDto.DeviceId} 删除预置点: {presetDto.PresetIndex}");
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
_sysLog.Warning($"[Preset] 未知操作类型: {presetDto.Action}");
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
_sysLog.Error(ex, $"[Preset] 设备 {presetDto.DeviceId} 预置点操作失败");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>PresetControlDto 参数</summary>
|
|||
|
|
public class PresetControlDto
|
|||
|
|
{
|
|||
|
|
/// <summary>设备ID</summary>
|
|||
|
|
public int DeviceId { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>预置点编号 (1-255)</summary>
|
|||
|
|
public int PresetIndex { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>动作：GOTO, SET, REMOVE</summary>
|
|||
|
|
public string Action { get; set; } = string.Empty;
|
|||
|
|
}
|