< Summary

Information
Class: OzonOrdersWeb.TransactionServices.SupplierOrderIntentStore
Assembly: OzonOrdersWeb
File(s): /home/runner/work/Studio2Prod/Studio2Prod/OzonOrdersWeb/Services/Transactions/SupplierOrderIntentStore.cs
Line coverage
96%
Covered lines: 98
Uncovered lines: 4
Coverable lines: 102
Total lines: 221
Line coverage: 96%
Branch coverage
85%
Covered branches: 55
Total branches: 64
Branch coverage: 85.9%
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.cctor()100%11100%
.ctor(...)100%11100%
get_IsDown()100%11100%
GetActiveAsync()100%6690.9%
BeginAsync()85%202097.82%
ResolveAsync()90%101086.66%
TryDegrade(...)50%22100%
IsMissingTable(...)100%88100%
IsUniqueViolation(...)78.57%1414100%
ToInfo(...)100%11100%
Trim(...)75%44100%

File(s)

/home/runner/work/Studio2Prod/Studio2Prod/OzonOrdersWeb/Services/Transactions/SupplierOrderIntentStore.cs

#LineLine coverage
 1using Microsoft.EntityFrameworkCore;
 2using Microsoft.Extensions.Logging;
 3using OzonDomains.Models.SupplierStatuses;
 4using OzonRepositories.Context;
 5
 6namespace OzonOrdersWeb.TransactionServices;
 7
 8public sealed record SupplierOrderIntentInfo(
 9    long Id, string RequestId, string ProviderKey, int StudioOrderId, string Status,
 10    string? ExternalOrderNumber, string? RequestedBy, DateTime CreatedAtUtc, DateTime UpdatedAtUtc);
 11
 12/// <summary>Итог <see cref="ISupplierOrderIntentStore.BeginAsync"/>.</summary>
 13/// <param name="Started">Созданные намерения (Placing).</param>
 14/// <param name="Busy">Активные намерения, из-за которых новое не создано: другой запрос оказался быстрее.</param>
 15/// <param name="Recorded"><c>false</c> — таблицы намерений ещё нет (миграция не применена), запись не велась.</param>
 16public sealed record SupplierOrderIntentBeginResult(
 17    IReadOnlyList<SupplierOrderIntentInfo> Started, IReadOnlyList<SupplierOrderIntentInfo> Busy, bool Recorded)
 18{
 19    public static SupplierOrderIntentBeginResult NotRecorded { get; } = new([], [], false);
 20}
 21
 22/// <summary>
 23/// Хранилище намерений оформить заказ у поставщика (outbox). Каждая операция выполняется в собственном
 24/// контексте и сразу фиксируется — запись не откатывается вместе с основной транзакцией запроса.
 25/// </summary>
 26public interface ISupplierOrderIntentStore
 27{
 28    Task<IReadOnlyList<SupplierOrderIntentInfo>> GetActiveAsync(IReadOnlyCollection<int> orderIds, CancellationToken ct)
 29
 30    /// <summary>
 31    /// Создаёт намерения Placing. Если по (поставщик, заказ) уже есть активное — оно попадает в <c>Busy</c>,
 32    /// кроме пар из <paramref name="supersede"/> (пользователь явно подтвердил повтор): тогда старое закрывается как Su
 33    /// </summary>
 34    Task<SupplierOrderIntentBeginResult> BeginAsync(
 35        string requestId, string source, string? user,
 36        IReadOnlyCollection<(string ProviderKey, int OrderId)> targets,
 37        IReadOnlySet<(string ProviderKey, int OrderId)> supersede, CancellationToken ct);
 38
 39    /// <summary>Переводит намерение в итоговый статус; для не-активных статусов освобождает уникальный индекс.</summary
 40    Task ResolveAsync(long id, string status, string? externalOrderNumber, string? note, string? resolvedBy);
 41}
 42
 43/// <summary>
 44/// Реализация на <c>IDbContextFactory</c>. Пока таблицы <c>SupplierOrderIntents</c> нет (миграция ещё не применена),
 45/// работает «в холостую»: ничего не пишет и не находит, чтобы деплой кода раньше схемы не ломал оформление заказов;
 46/// проверка таблицы повторяется раз в две минуты. Любая другая ошибка БД пробрасывается — заказ без записи
 47/// намерения поставщику не отправляется.
 48/// </summary>
 49public sealed class SupplierOrderIntentStore : ISupplierOrderIntentStore
 50{
 151    private static readonly TimeSpan RetryAfterMissingTable = TimeSpan.FromMinutes(2);
 52
 53    private readonly IDbContextFactory<ApplicationDbContext> _factory;
 54    private readonly ILogger<SupplierOrderIntentStore> _logger;
 55    private long _unavailableUntilTicks;
 56
 4357    public SupplierOrderIntentStore(IDbContextFactory<ApplicationDbContext> factory, ILogger<SupplierOrderIntentStore> l
 58    {
 4359        _factory = factory;
 4360        _logger = logger;
 4361    }
 62
 9863    private bool IsDown => DateTime.UtcNow.Ticks < Interlocked.Read(ref _unavailableUntilTicks);
 64
 65    public async Task<IReadOnlyList<SupplierOrderIntentInfo>> GetActiveAsync(IReadOnlyCollection<int> orderIds, Cancella
 66    {
 3467        if (IsDown || orderIds.Count == 0) return [];
 68        try
 69        {
 3270            await using var db = await _factory.CreateDbContextAsync(ct);
 3271            var ids = orderIds.ToList();
 3272            var rows = await db.SupplierOrderIntents.AsNoTracking()
 3273                .Where(x => ids.Contains(x.StudioOrderId) && x.ActiveStudioOrderId != null)
 3274                .ToListAsync(ct);
 3175            return rows.Select(ToInfo).ToList();
 076        }
 177        catch (Exception ex) when (TryDegrade(ex))
 78        {
 179            return [];
 80        }
 3381    }
 82
 83    public async Task<SupplierOrderIntentBeginResult> BeginAsync(
 84        string requestId, string source, string? user,
 85        IReadOnlyCollection<(string ProviderKey, int OrderId)> targets,
 86        IReadOnlySet<(string ProviderKey, int OrderId)> supersede, CancellationToken ct)
 87    {
 4688        if (IsDown || targets.Count == 0) return SupplierOrderIntentBeginResult.NotRecorded;
 89        try
 90        {
 4491            await using var db = await _factory.CreateDbContextAsync(ct);
 4492            var started = new List<SupplierOrderIntentInfo>();
 4493            var busy = new List<SupplierOrderIntentInfo>();
 4494            var by = Trim(user, 450);
 18195            foreach (var (providerKey, orderId) in targets.Distinct())
 96            {
 4797                var active = await db.SupplierOrderIntents
 4798                    .FirstOrDefaultAsync(x => x.ProviderKey == providerKey && x.ActiveStudioOrderId == orderId, ct);
 4699                if (active is not null)
 100                {
 7101                    if (!supersede.Contains((providerKey, orderId)))
 102                    {
 4103                        busy.Add(ToInfo(active));
 4104                        continue;
 105                    }
 106
 3107                    active.Status = SupplierOrderIntentStatus.Superseded;
 3108                    active.ActiveStudioOrderId = null;
 3109                    active.UpdatedAtUtc = DateTime.UtcNow;
 3110                    active.ResolvedBy = by;
 3111                    active.Note = "Заменено новым намерением после явного подтверждения пользователя.";
 3112                    await db.SaveChangesAsync(ct);
 113                }
 114
 42115                var now = DateTime.UtcNow;
 42116                var row = new SupplierOrderIntent
 42117                {
 42118                    RequestId = Trim(requestId, 64) ?? string.Empty,
 42119                    ProviderKey = providerKey,
 42120                    StudioOrderId = orderId,
 42121                    ActiveStudioOrderId = orderId,
 42122                    Status = SupplierOrderIntentStatus.Placing,
 42123                    Source = Trim(source, 30) ?? string.Empty,
 42124                    RequestedBy = by,
 42125                    CreatedAtUtc = now,
 42126                    UpdatedAtUtc = now
 42127                };
 42128                db.SupplierOrderIntents.Add(row);
 129                try
 130                {
 42131                    await db.SaveChangesAsync(ct);
 41132                    started.Add(ToInfo(row));
 41133                }
 1134                catch (DbUpdateException ex) when (IsUniqueViolation(ex))
 135                {
 136                    // Гонка: между проверкой и вставкой активное намерение успел создать другой запрос или инстанс.
 1137                    db.Entry(row).State = EntityState.Detached;
 1138                    var winner = await db.SupplierOrderIntents.AsNoTracking()
 1139                        .FirstOrDefaultAsync(x => x.ProviderKey == providerKey && x.ActiveStudioOrderId == orderId, ct);
 1140                    busy.Add(winner is null ? ToInfo(row) : ToInfo(winner));
 141                }
 42142            }
 143
 43144            return new SupplierOrderIntentBeginResult(started, busy, true);
 0145        }
 1146        catch (Exception ex) when (TryDegrade(ex))
 147        {
 1148            return SupplierOrderIntentBeginResult.NotRecorded;
 149        }
 45150    }
 151
 152    public async Task ResolveAsync(long id, string status, string? externalOrderNumber, string? note, string? resolvedBy
 153    {
 21154        if (IsDown) return;
 155        try
 156        {
 19157            await using var db = await _factory.CreateDbContextAsync(CancellationToken.None);
 19158            var row = await db.SupplierOrderIntents.FirstOrDefaultAsync(x => x.Id == id, CancellationToken.None);
 19159            if (row is null) return;
 160
 19161            row.Status = status;
 19162            row.ActiveStudioOrderId = SupplierOrderIntentStatus.IsActive(status) ? row.StudioOrderId : null;
 31163            if (!string.IsNullOrWhiteSpace(externalOrderNumber)) row.ExternalOrderNumber = Trim(externalOrderNumber, 200
 19164            row.Note = Trim(note, 500);
 19165            row.ResolvedBy = Trim(resolvedBy, 450);
 19166            row.UpdatedAtUtc = DateTime.UtcNow;
 19167            await db.SaveChangesAsync(CancellationToken.None);
 19168        }
 0169        catch (Exception ex) when (TryDegrade(ex))
 170        {
 171            // Таблицы нет — писать некуда.
 0172        }
 20173    }
 174
 175    private bool TryDegrade(Exception ex)
 176    {
 2177        if (!IsMissingTable(ex)) return false;
 2178        Interlocked.Exchange(ref _unavailableUntilTicks, (DateTime.UtcNow + RetryAfterMissingTable).Ticks);
 2179        _logger.LogWarning(
 2180            "SupplierOrderIntents: таблицы нет — миграция AddSupplierOrderIntents не применена. Намерения заказов не зап
 2181            "защита от обрыва запроса работает без outbox (повторная проверка через {Minutes} мин)", RetryAfterMissingTa
 2182        return true;
 183    }
 184
 185    public static bool IsMissingTable(Exception ex)
 186    {
 14187        for (var e = ex; e is not null; e = e.InnerException)
 188        {
 6189            var message = e.Message;
 6190            if (message.Contains(nameof(ApplicationDbContext.SupplierOrderIntents), StringComparison.OrdinalIgnoreCase)
 6191                && (message.Contains("doesn't exist", StringComparison.OrdinalIgnoreCase)
 6192                    || message.Contains("no such table", StringComparison.OrdinalIgnoreCase)))
 4193                return true;
 194        }
 195
 1196        return false;
 197    }
 198
 199    public static bool IsUniqueViolation(Exception ex)
 200    {
 14201        for (var e = ex; e is not null; e = e.InnerException)
 202        {
 6203            var message = e.Message;
 6204            if (message.Contains("Duplicate entry", StringComparison.OrdinalIgnoreCase)
 6205                || message.Contains("UNIQUE constraint failed", StringComparison.OrdinalIgnoreCase)
 6206                || message.Contains("unique index", StringComparison.OrdinalIgnoreCase))
 3207                return true;
 208
 209            // MySqlException.Number == 1062 (ER_DUP_ENTRY) без ссылки на сборку коннектора.
 3210            if (e.GetType().GetProperty("Number")?.GetValue(e) is int number && number == 1062) return true;
 211        }
 212
 1213        return false;
 214    }
 215
 67216    private static SupplierOrderIntentInfo ToInfo(SupplierOrderIntent x) => new(
 67217        x.Id, x.RequestId, x.ProviderKey, x.StudioOrderId, x.Status, x.ExternalOrderNumber, x.RequestedBy, x.CreatedAtUt
 218
 219    private static string? Trim(string? value, int maxLength) =>
 178220        string.IsNullOrWhiteSpace(value) ? null : value.Length <= maxLength ? value : value[..maxLength];
 221}
Generated by: ReportGenerator 5.5.11.0
10/25/2026 - 07:43:45
GitHub | reportgenerator.io

Methods/Properties

.cctor()
.ctor(Microsoft.EntityFrameworkCore.IDbContextFactory`1<OzonRepositories.Context.ApplicationDbContext>,Microsoft.Extensions.Logging.ILogger`1<OzonOrdersWeb.TransactionServices.SupplierOrderIntentStore>)
get_IsDown()
GetActiveAsync()
BeginAsync()
ResolveAsync()
TryDegrade(System.Exception)
IsMissingTable(System.Exception)
IsUniqueViolation(System.Exception)
ToInfo(OzonDomains.Models.SupplierStatuses.SupplierOrderIntent)
Trim(System.String,System.Int32)