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.Dict; public class DictSyncCoordinator : ISingletonDependency { private readonly IEventAggregator _eventAggregator; private readonly IJeecgDictSyncService _dictSyncService; private readonly ILoggerService _logger; public DictSyncCoordinator( IEventAggregator eventAggregator, IJeecgDictSyncService dictSyncService, SyncPollManager pollManager, ILoggerService logger) { _eventAggregator = eventAggregator; _dictSyncService = dictSyncService; _logger = logger; _eventAggregator.GetEvent() .Subscribe(OnRemoteCommand, ThreadOption.BackgroundThread); _eventAggregator.GetEvent() .Subscribe(OnNetworkStatusChanged, ThreadOption.BackgroundThread); pollManager.Register("数据字典", () => SyncAndPublishAsync("poll", null)); _logger.Information("[数据字典] DictSyncCoordinator 已启动"); _ = Task.Run(() => SyncAndPublishAsync("startup", null)); } private void OnNetworkStatusChanged(NetworkStatusChangedPayload payload) { if (!payload.IsOnline) return; _logger.Information("[数据字典] 网络恢复,触发补偿刷新"); _ = Task.Run(() => SyncAndPublishAsync("reconnect", null)); } 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("SYS_DICT_CHANGED", StringComparison.OrdinalIgnoreCase)) return; doc.RootElement.TryGetProperty("action", out var actionEl); doc.RootElement.TryGetProperty("dictId", out var idEl); var action = actionEl.GetString() ?? string.Empty; var dictId = idEl.ValueKind == JsonValueKind.String ? idEl.GetString() : null; _logger.Information($"[数据字典] 收到变更信号 action={action}"); _ = Task.Run(() => SyncAndPublishAsync(action, dictId)); } catch (Exception ex) { _logger.Warning($"[数据字典] 处理STOMP命令失败:{ex.Message}"); } } private async Task SyncAndPublishAsync(string action, string? dictId) { try { var count = await _dictSyncService.SyncFromJeecgAsync().ConfigureAwait(false); if (count > 0) _logger.Information($"[数据字典] 同步完成,共处理 {count} 条"); _eventAggregator.GetEvent() .Publish(new DictChangedPayload { Action = action, DictId = dictId }); } catch (Exception ex) { _logger.Warning($"[数据字典] 同步失败:{ex.Message}"); } } }