| | | 1 | | using Microsoft.EntityFrameworkCore; |
| | | 2 | | using OzonDomains.Models; |
| | | 3 | | using OzonRepositories.Context; |
| | | 4 | | |
| | | 5 | | namespace Services.LabelServices; |
| | | 6 | | |
| | | 7 | | public sealed record LabelPrintLogEntry( |
| | | 8 | | string FileName, |
| | | 9 | | int? OrderId, |
| | | 10 | | LabelPrintSource Source, |
| | | 11 | | LabelPrintActorKind ActorKind, |
| | | 12 | | string? ActorId, |
| | | 13 | | string ActorName); |
| | | 14 | | |
| | | 15 | | public interface ILabelPrintLogService |
| | | 16 | | { |
| | | 17 | | Task RecordAsync(IEnumerable<LabelPrintLogEntry> entries, CancellationToken cancellationToken = default); |
| | | 18 | | Task<IReadOnlyList<LabelPrintLog>> GetLatestByPdfAsync(CancellationToken cancellationToken = default); |
| | | 19 | | } |
| | | 20 | | |
| | | 21 | | /// <summary>Журналирует только успешно доступные из хранилища PDF и инвалидирует каталог этикеток.</summary> |
| | 1 | 22 | | public sealed class LabelPrintLogService( |
| | 1 | 23 | | ApplicationDbContext context, |
| | 1 | 24 | | ILabelCatalogCache catalogCache) : ILabelPrintLogService |
| | | 25 | | { |
| | | 26 | | public async Task RecordAsync(IEnumerable<LabelPrintLogEntry> entries, CancellationToken cancellationToken = default |
| | | 27 | | { |
| | 1 | 28 | | var rows = entries |
| | 2 | 29 | | .Where(x => !string.IsNullOrWhiteSpace(x.FileName)) |
| | 2 | 30 | | .Select(x => new LabelPrintLog |
| | 2 | 31 | | { |
| | 2 | 32 | | FileName = x.FileName.Trim(), |
| | 2 | 33 | | OrderId = x.OrderId, |
| | 2 | 34 | | Source = x.Source, |
| | 2 | 35 | | ActorKind = x.ActorKind, |
| | 2 | 36 | | ActorId = Truncate(x.ActorId, 450), |
| | 2 | 37 | | ActorName = Truncate(x.ActorName, 300) ?? "Неизвестный пользователь", |
| | 2 | 38 | | OccurredAtUtc = DateTime.UtcNow |
| | 2 | 39 | | }) |
| | 1 | 40 | | .ToList(); |
| | 1 | 41 | | if (rows.Count == 0) return; |
| | | 42 | | |
| | 1 | 43 | | context.LabelPrintLogs.AddRange(rows); |
| | 1 | 44 | | await context.SaveChangesAsync(cancellationToken).ConfigureAwait(false); |
| | 1 | 45 | | catalogCache.Invalidate(); |
| | 1 | 46 | | } |
| | | 47 | | |
| | | 48 | | public async Task<IReadOnlyList<LabelPrintLog>> GetLatestByPdfAsync(CancellationToken cancellationToken = default) |
| | | 49 | | { |
| | 1 | 50 | | var latestIds = context.LabelPrintLogs.AsNoTracking() |
| | 1 | 51 | | .GroupBy(x => x.FileName) |
| | 1 | 52 | | .Select(x => x.OrderByDescending(log => log.OccurredAtUtc).ThenByDescending(log => log.Id) |
| | 1 | 53 | | .Select(log => log.Id).First()); |
| | | 54 | | |
| | 1 | 55 | | return await context.LabelPrintLogs.AsNoTracking() |
| | 1 | 56 | | .Where(x => latestIds.Contains(x.Id)) |
| | 1 | 57 | | .ToListAsync(cancellationToken) |
| | 1 | 58 | | .ConfigureAwait(false); |
| | 1 | 59 | | } |
| | | 60 | | |
| | | 61 | | private static string? Truncate(string? value, int max) => |
| | 4 | 62 | | string.IsNullOrWhiteSpace(value) ? null : value.Length <= max ? value : value[..max]; |
| | | 63 | | } |