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.MixerMaterial; public class MixerMaterialSyncCoordinator : ISingletonDependency { private readonly IEventAggregator _eventAggregator; private readonly IMixerMaterialService _mixerMaterialService; private readonly ILoggerService _logger; public MixerMaterialSyncCoordinator( IEventAggregator eventAggregator, IMixerMaterialService mixerMaterialService, SyncPollManager pollManager, ILoggerService logger) { _eventAggregator = eventAggregator; _mixerMaterialService = mixerMaterialService; _logger = logger; _eventAggregator.GetEvent() .Subscribe(OnRemoteCommand, ThreadOption.BackgroundThread); _eventAggregator.GetEvent() .Subscribe(OnNetworkStatusChanged, ThreadOption.BackgroundThread); pollManager.Register("密炼物料", async () => { await _mixerMaterialService.SyncFromRemoteAsync().ConfigureAwait(false); _eventAggregator.GetEvent() .Publish(new MixerMaterialChangedPayload { Action = "poll" }); }); _logger.Information("[密炼物料推送] MixerMaterialSyncCoordinator 已启动"); _ = _mixerMaterialService.SyncFromRemoteAsync(); } private void OnNetworkStatusChanged(NetworkStatusChangedPayload payload) { if (!payload.IsOnline) return; _ = Task.Run(async () => { await _mixerMaterialService.SyncFromRemoteAsync().ConfigureAwait(false); _eventAggregator.GetEvent() .Publish(new MixerMaterialChangedPayload { 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; if (!cmdEl.GetString().Equals("MIXER_MATERIAL_CHANGED", StringComparison.OrdinalIgnoreCase)) return; doc.RootElement.TryGetProperty("action", out var actionEl); doc.RootElement.TryGetProperty("mixerMaterialId", out var idEl); if (idEl.ValueKind != JsonValueKind.String && doc.RootElement.TryGetProperty("id", out var id2El)) idEl = id2El; var changed = new MixerMaterialChangedPayload { Action = actionEl.GetString() ?? string.Empty, MixerMaterialId = idEl.ValueKind == JsonValueKind.String ? idEl.GetString() : null }; _ = Task.Run(async () => { await _mixerMaterialService.SyncFromRemoteAsync().ConfigureAwait(false); _eventAggregator.GetEvent().Publish(changed); }); } catch (Exception ex) { _logger.Warning($"[密炼物料推送] 处理STOMP命令失败:{ex.Message}"); } } }