| | | 1 | | using System.Globalization; |
| | | 2 | | using Microsoft.EntityFrameworkCore; |
| | | 3 | | using Microsoft.Extensions.Logging; |
| | | 4 | | using Newtonsoft.Json.Linq; |
| | | 5 | | using OzonDomains.Models; |
| | | 6 | | using OzonDomains.Models.SupplierStatuses; |
| | | 7 | | using OzonRepositories.Context; |
| | | 8 | | using Services.ApiServices.MoskvorechieApi; |
| | | 9 | | |
| | | 10 | | namespace Services.SupplierStatusServices.Providers; |
| | | 11 | | |
| | | 12 | | /// <summary> |
| | | 13 | | /// Москворечье (Истра): корзина сверяется с <c>my_basket</c>, а созданные заказы — |
| | | 14 | | /// с <c>make_order_v2&oids=…</c>. API отдаёт только начальный этап размещения; |
| | | 15 | | /// дальнейшее движение товара поставщик рекомендует получать отдельными методами учётной системы. |
| | | 16 | | /// </summary> |
| | | 17 | | public sealed class MoskvorechieIstraSupplierStatusProvider : ISupplierStatusProvider |
| | | 18 | | { |
| | | 19 | | private readonly ApplicationDbContext _db; |
| | | 20 | | private readonly MoskvorechieIstraDataManager _api; |
| | | 21 | | private readonly ILogger<MoskvorechieIstraSupplierStatusProvider> _logger; |
| | | 22 | | |
| | 31 | 23 | | public MoskvorechieIstraSupplierStatusProvider(ApplicationDbContext db, MoskvorechieIstraDataManager api, |
| | 62 | 24 | | ILogger<MoskvorechieIstraSupplierStatusProvider> logger) => (_db, _api, _logger) = (db, api, logger); |
| | | 25 | | |
| | 2 | 26 | | public string ProviderKey => ApiSupplierSettings.MoskvorechieIstraProviderKey; |
| | | 27 | | |
| | | 28 | | public async Task<IReadOnlyList<SupplierStatusSnapshot>> FetchCartAsync( |
| | | 29 | | IReadOnlyList<OrderSupplierStateRef> states, CancellationToken ct) |
| | | 30 | | { |
| | 9 | 31 | | if (states.Count == 0) return []; |
| | | 32 | | |
| | | 33 | | JToken basket; |
| | 13 | 34 | | try { basket = await _api.GetBasketAsync(ct); } |
| | 1 | 35 | | catch (Exception ex) when (ex is MoskvorechieApiException or HttpRequestException or TaskCanceledException) |
| | | 36 | | { |
| | 1 | 37 | | _logger.LogInformation("Москворечье: не удалось прочитать API-корзину: {Error}", ex.Message); |
| | 3 | 38 | | return states.Select(x => ErrorSnapshot(x.OrderId, SupplierStatusKind.Cart, ex)).ToList(); |
| | | 39 | | } |
| | | 40 | | |
| | 12 | 41 | | var orderIds = states.Select(x => x.OrderId).Distinct().ToList(); |
| | 6 | 42 | | var items = await _db.MoskvorechieIstraCartItems |
| | 6 | 43 | | .Where(x => x.ActiveStudioOrderId != null && orderIds.Contains(x.ActiveStudioOrderId.Value)) |
| | 6 | 44 | | .ToListAsync(ct); |
| | 6 | 45 | | var rows = GetRows(basket); |
| | 6 | 46 | | var result = new List<SupplierStatusSnapshot>(states.Count); |
| | 6 | 47 | | var changed = false; |
| | 24 | 48 | | foreach (var state in states) |
| | | 49 | | { |
| | 20 | 50 | | var item = items.Where(x => x.ActiveStudioOrderId == state.OrderId).OrderByDescending(x => x.UpdatedAtUtc).F |
| | 11 | 51 | | var exists = item is not null && rows.Any(row => Matches(row, item)); |
| | 6 | 52 | | var code = exists ? SupplierCartStatusCode.Pending : SupplierCartStatusCode.Removed; |
| | 6 | 53 | | if (!exists && item is not null) |
| | | 54 | | { |
| | 3 | 55 | | item.Status = "Removed"; |
| | 3 | 56 | | item.ActiveStudioOrderId = null; |
| | 3 | 57 | | item.LastError = "Позиция отсутствует в API-корзине Москворечья."; |
| | 3 | 58 | | item.UpdatedAtUtc = DateTime.UtcNow; |
| | 3 | 59 | | changed = true; |
| | | 60 | | } |
| | 6 | 61 | | result.Add(new SupplierStatusSnapshot |
| | 6 | 62 | | { |
| | 6 | 63 | | OrderId = state.OrderId, Kind = SupplierStatusKind.Cart, ExternalCode = code, |
| | 6 | 64 | | StatusName = code == SupplierCartStatusCode.Pending ? "В корзине, нужна проверка" : "Удалён из корзины" |
| | 6 | 65 | | }); |
| | | 66 | | } |
| | 9 | 67 | | if (changed) await _db.SaveChangesAsync(ct); |
| | 6 | 68 | | return result; |
| | 8 | 69 | | } |
| | | 70 | | |
| | | 71 | | public async Task<IReadOnlyList<SupplierStatusSnapshot>> FetchOrderAsync( |
| | | 72 | | IReadOnlyList<OrderSupplierStateRef> states, CancellationToken ct) |
| | | 73 | | { |
| | 23 | 74 | | if (states.Count == 0) return []; |
| | 43 | 75 | | var ids = states.Select(x => x.ExternalOrderId ?? x.ExternalOrderNumber) |
| | 43 | 76 | | .Where(x => !string.IsNullOrWhiteSpace(x)).Cast<string>().Distinct(StringComparer.Ordinal).ToList(); |
| | 24 | 77 | | if (ids.Count == 0) return []; |
| | | 78 | | |
| | | 79 | | JToken response; |
| | 35 | 80 | | try { response = await _api.GetOrderStatesAsync(ids, ct); } |
| | 1 | 81 | | catch (Exception ex) when (ex is MoskvorechieApiException or HttpRequestException or TaskCanceledException) |
| | | 82 | | { |
| | 1 | 83 | | _logger.LogInformation("Москворечье: не удалось получить статусы заказов: {Error}", ex.Message); |
| | 3 | 84 | | return states.Select(x => ErrorSnapshot(x.OrderId, SupplierStatusKind.Order, ex)).ToList(); |
| | | 85 | | } |
| | | 86 | | |
| | 34 | 87 | | var rows = GetRows(response).Where(x => !string.IsNullOrWhiteSpace(Read(x, "id"))) |
| | 34 | 88 | | .ToDictionary(x => Read(x, "id")!, StringComparer.Ordinal); |
| | 17 | 89 | | var localOrders = await _db.MoskvorechieIstraOrders |
| | 17 | 90 | | .Where(x => x.ExternalOrderNumber != null && ids.Contains(x.ExternalOrderNumber)) |
| | 17 | 91 | | .ToListAsync(ct); |
| | 17 | 92 | | var result = new List<SupplierStatusSnapshot>(states.Count); |
| | 68 | 93 | | foreach (var state in states) |
| | | 94 | | { |
| | 17 | 95 | | var id = state.ExternalOrderId ?? state.ExternalOrderNumber; |
| | 17 | 96 | | if (string.IsNullOrWhiteSpace(id) || !rows.TryGetValue(id, out var row)) continue; |
| | 16 | 97 | | var code = Read(row, "status_id"); |
| | 16 | 98 | | var name = Read(row, "status_txt") ?? StatusName(code); |
| | 18 | 99 | | var local = localOrders.FirstOrDefault(x => x.ExternalOrderNumber == id); |
| | 16 | 100 | | if (local is not null) |
| | | 101 | | { |
| | 2 | 102 | | local.Status = name.Length > 30 ? name[..30] : name; |
| | 2 | 103 | | local.ResponseJson = row.ToString(Newtonsoft.Json.Formatting.None); |
| | | 104 | | } |
| | 16 | 105 | | result.Add(new SupplierStatusSnapshot |
| | 16 | 106 | | { |
| | 16 | 107 | | OrderId = state.OrderId, Kind = SupplierStatusKind.Order, ExternalCode = code, StatusName = name, |
| | 16 | 108 | | ExternalOrderNumber = id, ExternalOrderId = id |
| | 16 | 109 | | }); |
| | | 110 | | } |
| | 17 | 111 | | await _db.SaveChangesAsync(ct); |
| | 17 | 112 | | return result; |
| | 22 | 113 | | } |
| | | 114 | | |
| | 4 | 115 | | private static SupplierStatusSnapshot ErrorSnapshot(int orderId, string kind, Exception ex) => new() |
| | 4 | 116 | | { |
| | 4 | 117 | | OrderId = orderId, Kind = kind, StatusName = string.Empty, Error = $"Москворечье: {ex.Message}" |
| | 4 | 118 | | }; |
| | | 119 | | |
| | | 120 | | private static IReadOnlyList<JObject> GetRows(JToken response) => |
| | 23 | 121 | | (response["result"] ?? response) is JArray array ? array.OfType<JObject>().ToList() : []; |
| | | 122 | | |
| | | 123 | | private static bool Matches(JObject row, MoskvorechieIstraCartItem item) |
| | | 124 | | { |
| | 5 | 125 | | if (!string.Equals(Read(row, "nr"), item.Article, StringComparison.OrdinalIgnoreCase) || |
| | 5 | 126 | | !string.Equals(Read(row, "brand"), item.Brand, StringComparison.OrdinalIgnoreCase)) return false; |
| | 5 | 127 | | var quantity = ParseDecimal(Read(row, "quantity")); |
| | 5 | 128 | | var price = ParseDecimal(Read(row, "price")); |
| | 5 | 129 | | return quantity >= item.Quantity && (!item.SourcePrice.HasValue || Math.Abs(price - item.SourcePrice.Value) < 0. |
| | | 130 | | } |
| | | 131 | | |
| | 86 | 132 | | private static string? Read(JObject row, string name) => row.Properties() |
| | 247 | 133 | | .FirstOrDefault(x => string.Equals(x.Name, name, StringComparison.OrdinalIgnoreCase))?.Value.ToString(); |
| | | 134 | | |
| | 10 | 135 | | private static decimal ParseDecimal(string? value) => decimal.TryParse(value, NumberStyles.Number, |
| | 10 | 136 | | CultureInfo.InvariantCulture, out var parsed) ? parsed : 0m; |
| | | 137 | | |
| | 13 | 138 | | private static string StatusName(string? code) => code switch |
| | 13 | 139 | | { |
| | 3 | 140 | | "-1" => "Подключение к учётной системе", "-2" => "Создание заказа", "-3" => "Резервирование товара", |
| | 3 | 141 | | "-4" => "Создание расходной накладной", "-9" => "Передача менеджеру", "0" => "Заказ не найден", |
| | 3 | 142 | | "1" => "Размещён в учётной системе", "2" => "Создана расходная накладная", "3" => "Создана заявка", |
| | 4 | 143 | | "9" => "Ручная обработка менеджером", _ => string.IsNullOrWhiteSpace(code) ? "Ожидает статуса" : $"Статус API {c |
| | 13 | 144 | | }; |
| | | 145 | | } |