| | | 1 | | using Microsoft.EntityFrameworkCore; |
| | | 2 | | using Microsoft.Extensions.Caching.Memory; |
| | | 3 | | using OzonDomains.Models; |
| | | 4 | | using OzonRepositories.Context; |
| | | 5 | | using Services.ApiServices.ApiSupplierIntegration; |
| | | 6 | | using Services.ApiServices.FidApi.Models; |
| | | 7 | | |
| | | 8 | | namespace Services.FidSupplierLinkServices; |
| | | 9 | | |
| | | 10 | | public sealed class FidSupplierLinkService |
| | | 11 | | { |
| | | 12 | | // Глобальный рубильник автопроценки — одна строка-синглтон, меняется только из админки. |
| | | 13 | | // Читается на каждой странице транзакции, поэтому кэшируем с инвалидацией в SetGlobalAutoCartAsync. |
| | | 14 | | private const string GlobalAutoCartCacheKey = "FidSupplierLink:GlobalAutoCartEnabled"; |
| | 1 | 15 | | private static readonly TimeSpan GlobalAutoCartCacheTtl = TimeSpan.FromMinutes(10); |
| | | 16 | | |
| | | 17 | | private readonly ApplicationDbContext _context; |
| | | 18 | | private readonly ApiSupplierConnectorRegistry _registry; |
| | | 19 | | private readonly FidSuppliersFeedCache _feedCache; |
| | | 20 | | private readonly IMemoryCache _cache; |
| | | 21 | | |
| | 30 | 22 | | public FidSupplierLinkService(ApplicationDbContext context, ApiSupplierConnectorRegistry registry, |
| | 30 | 23 | | FidSuppliersFeedCache feedCache, IMemoryCache cache) |
| | 150 | 24 | | { _context = context; _registry = registry; _feedCache = feedCache; _cache = cache; } |
| | | 25 | | |
| | | 26 | | public async Task<FidSupplierLinkOverview> GetOverviewAsync(bool forceRefresh = false, CancellationToken ct = defaul |
| | | 27 | | { |
| | 2 | 28 | | var (feed, error) = await _feedCache.GetAsync(forceRefresh, ct); |
| | 4 | 29 | | if (feed is not null) await SyncDiscoveredAsync(feed, ct); |
| | 2 | 30 | | var links = await _context.FidSupplierLinks.AsNoTracking().ToListAsync(ct); |
| | 2 | 31 | | return BuildOverview(feed, links, error, await GetGlobalAutoCartEnabledAsync(ct)); |
| | 2 | 32 | | } |
| | | 33 | | |
| | | 34 | | /// <summary> |
| | | 35 | | /// Принудительно получает список из фид-API и возвращает имена добавленных при синхронизации поставщиков. |
| | | 36 | | /// Первый снимок не считается уведомляемым изменением, чтобы не рассылать накопленные записи. |
| | | 37 | | /// </summary> |
| | | 38 | | public async Task<FidSupplierLinkRefreshResult> RefreshAsync(CancellationToken ct = default) |
| | | 39 | | { |
| | 1 | 40 | | var (feed, error) = await _feedCache.GetAsync(forceRefresh: true, ct); |
| | 1 | 41 | | var isInitialSnapshot = false; |
| | 1 | 42 | | IReadOnlyList<string> newSupplierNames = []; |
| | 1 | 43 | | if (feed is not null) |
| | | 44 | | { |
| | 1 | 45 | | isInitialSnapshot = !await _context.FidSupplierLinks.AnyAsync(ct); |
| | 1 | 46 | | newSupplierNames = await SyncDiscoveredAsync(feed, ct); |
| | | 47 | | } |
| | | 48 | | |
| | 1 | 49 | | var links = await _context.FidSupplierLinks.AsNoTracking().ToListAsync(ct); |
| | 1 | 50 | | var overview = BuildOverview(feed, links, error, await GetGlobalAutoCartEnabledAsync(ct)); |
| | 1 | 51 | | return new FidSupplierLinkRefreshResult(overview, newSupplierNames, isInitialSnapshot); |
| | 1 | 52 | | } |
| | | 53 | | |
| | | 54 | | /// <summary>Главный рубильник автопроценки. Строки настроек может не быть — тогда автоподстановка включена.</summar |
| | | 55 | | public async Task<bool> GetGlobalAutoCartEnabledAsync(CancellationToken ct = default) |
| | | 56 | | { |
| | 6 | 57 | | if (_cache.TryGetValue(GlobalAutoCartCacheKey, out bool cached)) |
| | 2 | 58 | | return cached; |
| | | 59 | | |
| | 4 | 60 | | var settings = await _context.FidSupplierLinkSettings.AsNoTracking() |
| | 4 | 61 | | .SingleOrDefaultAsync(x => x.Id == FidSupplierLinkSettings.SingletonId, ct); |
| | 4 | 62 | | var enabled = settings?.IsAutoCartEnabled ?? true; |
| | 4 | 63 | | _cache.Set(GlobalAutoCartCacheKey, enabled, GlobalAutoCartCacheTtl); |
| | 4 | 64 | | return enabled; |
| | 6 | 65 | | } |
| | | 66 | | |
| | | 67 | | public async Task SetGlobalAutoCartAsync(bool enabled, string userName, CancellationToken ct = default) |
| | | 68 | | { |
| | 2 | 69 | | var settings = await _context.FidSupplierLinkSettings |
| | 2 | 70 | | .SingleOrDefaultAsync(x => x.Id == FidSupplierLinkSettings.SingletonId, ct); |
| | 2 | 71 | | if (settings is null) |
| | | 72 | | { |
| | 1 | 73 | | settings = new FidSupplierLinkSettings { Id = FidSupplierLinkSettings.SingletonId }; |
| | 1 | 74 | | _context.FidSupplierLinkSettings.Add(settings); |
| | | 75 | | } |
| | 2 | 76 | | settings.IsAutoCartEnabled = enabled; |
| | 2 | 77 | | settings.UpdatedAtUtc = DateTime.UtcNow; |
| | 2 | 78 | | settings.UpdatedBy = userName; |
| | 2 | 79 | | await _context.SaveChangesAsync(ct); |
| | 2 | 80 | | _cache.Remove(GlobalAutoCartCacheKey); |
| | 2 | 81 | | } |
| | | 82 | | |
| | | 83 | | public async Task SetRowAutoCartAsync(string name, bool enabled, string userName, CancellationToken ct = default) |
| | | 84 | | { |
| | 2 | 85 | | var link = await _context.FidSupplierLinks.SingleOrDefaultAsync(x => x.FidSupplierName == name.Trim(), ct); |
| | 3 | 86 | | if (link is null) throw new InvalidOperationException("Связь поставщика фида не найдена."); |
| | 1 | 87 | | link.IsAutoCartEnabled = enabled; |
| | 1 | 88 | | link.UpdatedAtUtc = DateTime.UtcNow; |
| | 1 | 89 | | link.UpdatedBy = userName; |
| | 1 | 90 | | await _context.SaveChangesAsync(ct); |
| | 1 | 91 | | } |
| | | 92 | | |
| | | 93 | | public async Task SaveAsync(FidSupplierLinkInput input, string userName, CancellationToken ct = default) |
| | | 94 | | { |
| | 9 | 95 | | var name = input.FidSupplierName?.Trim(); |
| | 12 | 96 | | if (string.IsNullOrWhiteSpace(name)) throw new InvalidOperationException("Имя поставщика фида не задано."); |
| | 6 | 97 | | var providerKey = string.IsNullOrWhiteSpace(input.ProviderKey) ? null : input.ProviderKey.Trim(); |
| | 6 | 98 | | if (providerKey is not null && !_registry.TryGet(providerKey, out _)) |
| | 1 | 99 | | throw new InvalidOperationException("Указан неизвестный API-поставщик."); |
| | 5 | 100 | | var now = DateTime.UtcNow; |
| | 5 | 101 | | var link = await _context.FidSupplierLinks.SingleOrDefaultAsync(x => x.FidSupplierName == name, ct); |
| | 5 | 102 | | if (link is null) |
| | | 103 | | { |
| | 2 | 104 | | link = new FidSupplierLink { FidSupplierName = name, FirstSeenAtUtc = now }; |
| | 2 | 105 | | _context.FidSupplierLinks.Add(link); |
| | | 106 | | } |
| | 5 | 107 | | var providerChanged = !string.Equals(link.ProviderKey, providerKey, StringComparison.OrdinalIgnoreCase); |
| | 5 | 108 | | link.ProviderKey = providerKey; |
| | 5 | 109 | | link.Note = string.IsNullOrWhiteSpace(input.Note) ? null : input.Note.Trim(); |
| | 10 | 110 | | link.UpdatedAtUtc = now; link.UpdatedBy = userName; |
| | 5 | 111 | | if (providerChanged) |
| | | 112 | | { |
| | 4 | 113 | | link.LinkedAtUtc = providerKey is null ? null : now; |
| | 4 | 114 | | link.LinkedBy = providerKey is null ? null : userName; |
| | 4 | 115 | | var (feed, _) = await _feedCache.GetAsync(false, ct); |
| | 4 | 116 | | link.FidRowsAtLink = providerKey is null ? null : feed?.Suppliers |
| | 6 | 117 | | .FirstOrDefault(x => string.Equals(x.Name, name, StringComparison.OrdinalIgnoreCase))?.Rows; |
| | | 118 | | } |
| | 5 | 119 | | await _context.SaveChangesAsync(ct); |
| | 5 | 120 | | } |
| | | 121 | | |
| | | 122 | | public async Task UnlinkAsync(string name, string userName, CancellationToken ct = default) |
| | | 123 | | { |
| | 2 | 124 | | var link = await _context.FidSupplierLinks.SingleOrDefaultAsync(x => x.FidSupplierName == name.Trim(), ct); |
| | 3 | 125 | | if (link is null) throw new InvalidOperationException("Связь поставщика фида не найдена."); |
| | 4 | 126 | | link.ProviderKey = null; link.FidRowsAtLink = null; link.LinkedAtUtc = null; link.LinkedBy = null; |
| | 2 | 127 | | link.UpdatedAtUtc = DateTime.UtcNow; link.UpdatedBy = userName; |
| | 1 | 128 | | await _context.SaveChangesAsync(ct); |
| | 1 | 129 | | } |
| | | 130 | | |
| | | 131 | | public async Task<IReadOnlyList<string>> SyncDiscoveredAsync(FidSuppliers feed, CancellationToken ct = default) |
| | | 132 | | { |
| | 9 | 133 | | var now = DateTime.UtcNow; |
| | 9 | 134 | | var existing = await _context.FidSupplierLinks.ToListAsync(ct); |
| | | 135 | | var byName = existing.ToDictionary(x => x.FidSupplierName, StringComparer.OrdinalIgnoreCase); |
| | 9 | 136 | | var initial = existing.Count == 0; |
| | 9 | 137 | | var discovered = new List<string>(); |
| | | 138 | | foreach (var supplier in feed.Suppliers.Where(x => !string.IsNullOrWhiteSpace(x.Name))) |
| | | 139 | | { |
| | 12 | 140 | | if (!byName.TryGetValue(supplier.Name, out var link)) |
| | | 141 | | { |
| | 5 | 142 | | link = new FidSupplierLink { FidSupplierName = supplier.Name.Trim(), FirstSeenAtUtc = now, UpdatedAtUtc |
| | 15 | 143 | | _context.FidSupplierLinks.Add(link); byName.Add(link.FidSupplierName, link); discovered.Add(link.FidSupp |
| | | 144 | | } |
| | 24 | 145 | | link.LastSeenInFeedAtUtc = now; link.UpdatedAtUtc = now; |
| | | 146 | | } |
| | 18 | 147 | | if (_context.ChangeTracker.HasChanges()) await _context.SaveChangesAsync(ct); |
| | 9 | 148 | | return discovered; |
| | 9 | 149 | | } |
| | | 150 | | |
| | | 151 | | public Task<List<FidSupplierLink>> GetPendingNotificationsAsync(TimeSpan renotifyAfter, CancellationToken ct = defau |
| | | 152 | | { |
| | 4 | 153 | | var cutoff = DateTime.UtcNow - renotifyAfter; |
| | 4 | 154 | | return _context.FidSupplierLinks.Where(x => x.ProviderKey == null && x.LastSeenInFeedAtUtc != null && |
| | 4 | 155 | | (x.NotifiedAtUtc == null || x.NotifiedAtUtc < cutoff)).ToListAsync(ct); |
| | | 156 | | } |
| | | 157 | | |
| | | 158 | | public async Task MarkNotifiedAsync(IEnumerable<string> names, CancellationToken ct = default) |
| | | 159 | | { |
| | 2 | 160 | | var set = names.ToHashSet(StringComparer.OrdinalIgnoreCase); |
| | 2 | 161 | | var links = await _context.FidSupplierLinks.Where(x => set.Contains(x.FidSupplierName)).ToListAsync(ct); |
| | 15 | 162 | | var now = DateTime.UtcNow; foreach (var link in links) link.NotifiedAtUtc = now; |
| | 2 | 163 | | await _context.SaveChangesAsync(ct); |
| | 2 | 164 | | } |
| | | 165 | | |
| | | 166 | | public Task<int> CountActionRequiredAsync(CancellationToken ct = default) => |
| | 1 | 167 | | _context.FidSupplierLinks.CountAsync(x => x.ProviderKey == null && x.LastSeenInFeedAtUtc != null, ct); |
| | | 168 | | |
| | | 169 | | public static FidSupplierLinkOverview BuildOverview(FidSuppliers? feed, IReadOnlyCollection<FidSupplierLink> links, |
| | | 170 | | bool globalAutoCartEnabled = true) |
| | | 171 | | { |
| | 7 | 172 | | if (feed is null) |
| | | 173 | | { |
| | 5 | 174 | | var unavailable = links.Select(x => ToRow(x, null, FidSupplierLinkState.FeedUnavailable)); |
| | 5 | 175 | | return new FidSupplierLinkOverview(unavailable.OrderBy(x => x.FidSupplierName).ToList(), 0, 0, 0, null, |
| | 2 | 176 | | feedError ?? "Фид-сервис недоступен.", globalAutoCartEnabled); |
| | | 177 | | } |
| | 14 | 178 | | var linkByName = links.ToDictionary(x => x.FidSupplierName, StringComparer.OrdinalIgnoreCase); |
| | 5 | 179 | | var rows = new List<FidSupplierLinkRow>(); |
| | 28 | 180 | | foreach (var supplier in feed.Suppliers) |
| | | 181 | | { |
| | 9 | 182 | | linkByName.TryGetValue(supplier.Name, out var link); |
| | 9 | 183 | | rows.Add(ToRow(link, supplier, link?.ProviderKey is null ? FidSupplierLinkState.Unlinked : FidSupplierLinkSt |
| | | 184 | | } |
| | 14 | 185 | | var names = feed.Suppliers.Select(x => x.Name).ToHashSet(StringComparer.OrdinalIgnoreCase); |
| | 14 | 186 | | rows.AddRange(links.Where(x => !string.IsNullOrWhiteSpace(x.ProviderKey) && !names.Contains(x.FidSupplierName)) |
| | 6 | 187 | | .Select(x => ToRow(x, null, FidSupplierLinkState.Orphaned))); |
| | 25 | 188 | | var sorted = rows.OrderBy(x => x.State switch { FidSupplierLinkState.Unlinked => 0, FidSupplierLinkState.Orphane |
| | 15 | 189 | | .ThenBy(x => x.FidSupplierName, StringComparer.OrdinalIgnoreCase).ToList(); |
| | 15 | 190 | | return new FidSupplierLinkOverview(sorted, sorted.Count(x => x.State == FidSupplierLinkState.Linked), |
| | 20 | 191 | | sorted.Count(x => x.State == FidSupplierLinkState.Unlinked), sorted.Count(x => x.State == FidSupplierLinkSta |
| | 5 | 192 | | globalAutoCartEnabled); |
| | | 193 | | } |
| | | 194 | | |
| | 13 | 195 | | private static FidSupplierLinkRow ToRow(FidSupplierLink? link, FidSupplier? supplier, FidSupplierLinkState state) => |
| | 13 | 196 | | supplier?.Name ?? link!.FidSupplierName, link?.ProviderKey, link?.Note, state, supplier?.Rows, link?.FidRowsAtLi |
| | 4 | 197 | | supplier?.Warehouses.Select(x => x.LastImportedAt).Where(x => x.HasValue).Max(), supplier?.Warehouses ?? [], lin |
| | 13 | 198 | | link?.IsAutoCartEnabled ?? true); |
| | | 199 | | } |