79 lines
2.7 KiB
C#
79 lines
2.7 KiB
C#
|
using Ayay.SerilogLogs;
|
|||
|
|
using Newtonsoft.Json.Linq;
|
|||
|
|
using Serilog;
|
|||
|
|
using SHH.CameraSdk;
|
|||
|
|
using SHH.Contracts;
|
|||
|
|
|
|||
|
|
namespace SHH.CameraService;
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 设备时间同步处理器
|
|||
|
|
/// 响应 gRpc 指令：ProtocolCodes.Time_Sync
|
|||
|
|
/// </summary>
|
|||
|
|
public class TimeSyncHandler : ICommandHandler
|
|||
|
|
{
|
|||
|
|
private readonly ILogger _sysLog = Log.ForContext("SourceContext", LogModules.Core);
|
|||
|
|
private readonly CameraManager _cameraManager;
|
|||
|
|
|
|||
|
|
// Optimized: 需在 ProtocolCodes 中定义此常量，确保与网关下发的 CmdCode 对应
|
|||
|
|
public string ActionName => ProtocolCodes.Device_TimeSync;
|
|||
|
|
|
|||
|
|
public TimeSyncHandler(CameraManager cameraManager)
|
|||
|
|
{
|
|||
|
|
_cameraManager = cameraManager ?? throw new ArgumentNullException(nameof(cameraManager));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task ExecuteAsync(JToken payload)
|
|||
|
|
{
|
|||
|
|
// 1. 解析基础参数
|
|||
|
|
var deviceId = payload["DeviceId"]?.Value<int>() ?? 0;
|
|||
|
|
var method = payload["Method"]?.Value<string>()?.ToLower(); // "get" 或 "set"
|
|||
|
|
|
|||
|
|
if (deviceId <= 0)
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning("[TimeSync] 无效指令：设备ID非法");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 2. 获取设备并校验能力
|
|||
|
|
var device = _cameraManager.GetDevice(deviceId);
|
|||
|
|
if (device == null)
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning($"[TimeSync] 设备 {deviceId} 不存在");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Modified: 根据 ISyncFeature.cs 校验是否实现 ITimeSyncFeature 接口
|
|||
|
|
if (!(device is ITimeSyncFeature syncFeature))
|
|||
|
|
{
|
|||
|
|
_sysLog.Warning($"[TimeSync] 设备 {deviceId} 不支持时间同步功能");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 3. 业务逻辑分支
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
if (method == "set")
|
|||
|
|
{
|
|||
|
|
// 解析待设置的时间，若无则默认使用服务器当前系统时间
|
|||
|
|
var targetTime = payload["SyncTime"]?.Value<DateTime>() ?? DateTime.Now;
|
|||
|
|
|
|||
|
|
// 调用接口设置时间
|
|||
|
|
await syncFeature.SetTimeAsync(targetTime);
|
|||
|
|
_sysLog.Information($"[TimeSync] 设备 {deviceId} 时间已同步为: {targetTime:yyyy-MM-dd HH:mm:ss}");
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
// 执行获取时间
|
|||
|
|
var deviceTime = await syncFeature.GetTimeAsync();
|
|||
|
|
_sysLog.Information($"[TimeSync] 获取设备 {deviceId} 当前时间成功: {deviceTime:yyyy-MM-dd HH:mm:ss}");
|
|||
|
|
|
|||
|
|
// TODO: 若需要将结果返回给网关，需在此处调用 GatewayService 异步回传
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
_sysLog.Error(ex, $"[TimeSync] 设备 {deviceId} 操作失败 ({method})");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|