86 lines
3.1 KiB
C#
86 lines
3.1 KiB
C#
using Prism.Events;
|
|
using System.Text.Json;
|
|
using YY.Admin.Core;
|
|
using YY.Admin.Core.Events;
|
|
using YY.Admin.Core.Services;
|
|
using YY.Admin.Services.Service;
|
|
|
|
namespace YY.Admin.Services.Service.RubberQuickTestStd;
|
|
|
|
public class RubberQuickTestStdSyncCoordinator : ISingletonDependency
|
|
{
|
|
private readonly IEventAggregator _eventAggregator;
|
|
private readonly IRubberQuickTestStdService _stdService;
|
|
private readonly ILoggerService _logger;
|
|
|
|
public RubberQuickTestStdSyncCoordinator(
|
|
IEventAggregator eventAggregator,
|
|
IRubberQuickTestStdService stdService,
|
|
MesQuickTestDataPollManager pollManager,
|
|
ILoggerService logger)
|
|
{
|
|
_eventAggregator = eventAggregator;
|
|
_stdService = stdService;
|
|
_logger = logger;
|
|
|
|
_eventAggregator.GetEvent<RemoteCommandReceivedEvent>()
|
|
.Subscribe(OnRemoteCommand, ThreadOption.BackgroundThread);
|
|
|
|
_eventAggregator.GetEvent<NetworkStatusChangedEvent>()
|
|
.Subscribe(OnNetworkStatusChanged, ThreadOption.BackgroundThread);
|
|
|
|
pollManager.Register("胶料快检实验标准", () => PollSyncAsync("poll"));
|
|
|
|
_logger.Information("[快检实验标准] RubberQuickTestStdSyncCoordinator 已启动");
|
|
_ = PollSyncAsync("startup");
|
|
}
|
|
|
|
private async Task PollSyncAsync(string action)
|
|
{
|
|
if (!await _stdService.SyncFromRemoteAsync(CancellationToken.None).ConfigureAwait(false))
|
|
return;
|
|
|
|
_eventAggregator.GetEvent<RubberQuickTestStdChangedEvent>()
|
|
.Publish(new RubberQuickTestStdChangedPayload { Action = action });
|
|
}
|
|
|
|
private void OnNetworkStatusChanged(NetworkStatusChangedPayload payload)
|
|
{
|
|
if (!payload.IsOnline) return;
|
|
_ = Task.Run(() => PollSyncAsync("reconnect"));
|
|
}
|
|
|
|
private void OnRemoteCommand(RemoteCommandPayload payload)
|
|
{
|
|
try
|
|
{
|
|
var json = payload.CommandJson ?? string.Empty;
|
|
if (string.IsNullOrWhiteSpace(json)) return;
|
|
|
|
using var doc = JsonDocument.Parse(json);
|
|
if (!doc.RootElement.TryGetProperty("cmd", out var cmdEl)) return;
|
|
if (!cmdEl.GetString()?.Equals("MES_RUBBER_QUICK_TEST_STD_CHANGED", StringComparison.OrdinalIgnoreCase) ?? true)
|
|
return;
|
|
|
|
doc.RootElement.TryGetProperty("action", out var actionEl);
|
|
doc.RootElement.TryGetProperty("stdId", out var idEl);
|
|
|
|
var changed = new RubberQuickTestStdChangedPayload
|
|
{
|
|
Action = actionEl.GetString() ?? string.Empty,
|
|
StdId = idEl.ValueKind == JsonValueKind.String ? idEl.GetString() : null
|
|
};
|
|
_logger.Information($"[快检实验标准] STOMP action={changed.Action}, stdId={changed.StdId}");
|
|
_ = Task.Run(async () =>
|
|
{
|
|
if (await _stdService.SyncFromRemoteAsync(CancellationToken.None).ConfigureAwait(false))
|
|
_eventAggregator.GetEvent<RubberQuickTestStdChangedEvent>().Publish(changed);
|
|
});
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.Warning($"[快检实验标准] 处理 STOMP 命令失败：{ex.Message}");
|
|
}
|
|
}
|
|
}
|