84 lines
3.1 KiB
C#
84 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;
|
|
|
|
namespace YY.Admin.Services.Service.RawMaterialEntry;
|
|
|
|
/// <summary>
|
|
/// 监听 STOMP 收到的原料入场记录变更信号，转发为桌面端 Prism 事件，触发列表刷新。
|
|
/// </summary>
|
|
public class RawMaterialEntrySyncCoordinator : ISingletonDependency
|
|
{
|
|
private readonly IEventAggregator _eventAggregator;
|
|
private readonly ILoggerService _logger;
|
|
private SubscriptionToken? _remoteCommandToken;
|
|
private SubscriptionToken? _networkStatusToken;
|
|
|
|
public RawMaterialEntrySyncCoordinator(
|
|
IEventAggregator eventAggregator,
|
|
SyncPollManager pollManager,
|
|
ILoggerService logger)
|
|
{
|
|
_eventAggregator = eventAggregator;
|
|
_logger = logger;
|
|
_remoteCommandToken = _eventAggregator
|
|
.GetEvent<RemoteCommandReceivedEvent>()
|
|
.Subscribe(OnRemoteCommand, ThreadOption.BackgroundThread);
|
|
_networkStatusToken = _eventAggregator
|
|
.GetEvent<NetworkStatusChangedEvent>()
|
|
.Subscribe(OnNetworkStatusChanged, ThreadOption.BackgroundThread);
|
|
|
|
pollManager.Register("原料入场", () =>
|
|
{
|
|
_eventAggregator.GetEvent<RawMaterialEntryChangedEvent>()
|
|
.Publish(new RawMaterialEntryChangedPayload { Action = "poll" });
|
|
return Task.CompletedTask;
|
|
});
|
|
|
|
_logger.Information("[原料入场] RawMaterialEntrySyncCoordinator 已启动");
|
|
}
|
|
|
|
private void OnNetworkStatusChanged(NetworkStatusChangedPayload payload)
|
|
{
|
|
if (!payload.IsOnline) return;
|
|
_logger.Information("[原料入场] 网络恢复，触发补偿刷新");
|
|
_eventAggregator.GetEvent<RawMaterialEntryChangedEvent>().Publish(new RawMaterialEntryChangedPayload { Action = "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;
|
|
|
|
var cmd = cmdEl.GetString() ?? string.Empty;
|
|
if (!cmd.Equals("MES_RAW_MATERIAL_ENTRY_CHANGED", StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return;
|
|
}
|
|
|
|
doc.RootElement.TryGetProperty("action", out var actionEl);
|
|
doc.RootElement.TryGetProperty("entryId", out var idEl);
|
|
|
|
var changedPayload = new RawMaterialEntryChangedPayload
|
|
{
|
|
Action = actionEl.GetString() ?? string.Empty,
|
|
EntryId = idEl.ValueKind == JsonValueKind.String ? idEl.GetString() : null,
|
|
};
|
|
|
|
_logger.Information($"收到原料入场变更信号: action={changedPayload.Action}, entryId={changedPayload.EntryId}");
|
|
_eventAggregator.GetEvent<RawMaterialEntryChangedEvent>().Publish(changedPayload);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.Warning($"处理 STOMP 原料入场变更信号失败: {ex.Message}");
|
|
}
|
|
}
|
|
}
|