| | | 1 | | using System.Globalization; |
| | | 2 | | using Microsoft.EntityFrameworkCore; |
| | | 3 | | using Newtonsoft.Json.Linq; |
| | | 4 | | using OzonDomains.Models; |
| | | 5 | | using OzonDomains.Models.SupplierStatuses; |
| | | 6 | | using OzonRepositories.Context; |
| | | 7 | | using Services.ApiServices.ZZapApi; |
| | | 8 | | |
| | | 9 | | namespace Services.SupplierStatusServices.Providers; |
| | | 10 | | |
| | | 11 | | /// <summary> |
| | | 12 | | /// Статусы ZZap. Корзина — из зеркала ZZapCartItems (сверка с живой корзиной делается на странице корзины, |
| | | 13 | | /// а не в джобе: ZZap не чаще одного запроса в 3 секунды). Заказ — GET /orders/{code_order}: |
| | | 14 | | /// code_track/class_track из справочника /orders/status, конечные статусы закрывают отслеживание. |
| | | 15 | | /// </summary> |
| | | 16 | | public sealed class ZZapSupplierStatusProvider : ISupplierStatusProvider |
| | | 17 | | { |
| | | 18 | | /// <summary>Конечные статусы ZZap: выполнен, получен, отменён покупателем/продавцом, архив.</summary> |
| | 1 | 19 | | private static readonly HashSet<int> FinalTrackCodes = [11, 153, 10, 142, 169]; |
| | | 20 | | |
| | | 21 | | private readonly ApplicationDbContext _db; |
| | | 22 | | private readonly ZZapDataManager _api; |
| | | 23 | | private readonly LocalCartStatusReader _cartReader; |
| | | 24 | | |
| | 34 | 25 | | public ZZapSupplierStatusProvider(ApplicationDbContext db, ZZapDataManager api, LocalCartStatusReader cartReader) => |
| | 34 | 26 | | (_db, _api, _cartReader) = (db, api, cartReader); |
| | | 27 | | |
| | 35 | 28 | | public string ProviderKey => ApiSupplierSettings.ZZapMoscowProviderKey; |
| | | 29 | | |
| | | 30 | | public Task<IReadOnlyList<SupplierStatusSnapshot>> FetchCartAsync(IReadOnlyList<OrderSupplierStateRef> states, Cance |
| | 4 | 31 | | _cartReader.ReadAsync(ProviderKey, states, ct); |
| | | 32 | | |
| | | 33 | | public async Task<IReadOnlyList<SupplierStatusSnapshot>> FetchOrderAsync(IReadOnlyList<OrderSupplierStateRef> states |
| | | 34 | | { |
| | 29 | 35 | | var result = new List<SupplierStatusSnapshot>(); |
| | 59 | 36 | | var orderIds = states.Select(x => x.OrderId).ToList(); |
| | 29 | 37 | | var rows = await _db.ZZapCartItems |
| | 29 | 38 | | .Where(x => x.ProviderKey == ProviderKey && x.Status == ZZapCartItemStatus.Ordered && orderIds.Contains(x.St |
| | 29 | 39 | | .ToListAsync(ct); |
| | | 40 | | |
| | 118 | 41 | | foreach (var state in states) |
| | | 42 | | { |
| | 30 | 43 | | var code = ReadCodeOrder(state); |
| | 56 | 44 | | var row = rows.Where(x => x.StudioOrderId == state.OrderId).OrderByDescending(x => x.OrderedAtUtc).FirstOrDe |
| | 40 | 45 | | if (code <= 0) code = row?.CodeOrder ?? 0; |
| | 30 | 46 | | if (code <= 0) |
| | | 47 | | { |
| | 5 | 48 | | result.Add(new SupplierStatusSnapshot { OrderId = state.OrderId, Kind = SupplierStatusKind.Order, Status |
| | 5 | 49 | | continue; |
| | | 50 | | } |
| | | 51 | | |
| | | 52 | | try |
| | | 53 | | { |
| | 25 | 54 | | var order = (await _api.GetOrderAsync(code, ct))["result"] as JObject; |
| | 20 | 55 | | var trackCode = order?.Value<int?>("code_track"); |
| | 20 | 56 | | var trackName = order?.Value<string>("class_track"); |
| | 20 | 57 | | if (order is null || string.IsNullOrWhiteSpace(trackName)) |
| | | 58 | | { |
| | 5 | 59 | | result.Add(new SupplierStatusSnapshot { OrderId = state.OrderId, Kind = SupplierStatusKind.Order, St |
| | 5 | 60 | | continue; |
| | | 61 | | } |
| | | 62 | | |
| | 15 | 63 | | if (row is not null) |
| | | 64 | | { |
| | 10 | 65 | | row.ExternalStatusCode = trackCode; |
| | 10 | 66 | | row.ExternalStatusName = trackName.Length > 120 ? trackName[..120] : trackName; |
| | 10 | 67 | | row.UpdatedAtUtc = DateTime.UtcNow; |
| | | 68 | | } |
| | | 69 | | |
| | 15 | 70 | | result.Add(new SupplierStatusSnapshot |
| | 15 | 71 | | { |
| | 15 | 72 | | OrderId = state.OrderId, |
| | 15 | 73 | | Kind = SupplierStatusKind.Order, |
| | 15 | 74 | | ExternalCode = trackCode?.ToString(CultureInfo.InvariantCulture), |
| | 15 | 75 | | StatusName = trackName, |
| | 15 | 76 | | ExternalOrderNumber = code.ToString(CultureInfo.InvariantCulture), |
| | 15 | 77 | | ExternalOrderId = code.ToString(CultureInfo.InvariantCulture), |
| | 15 | 78 | | QuantityConfirmed = decimal.TryParse(order.Value<string>("qty_order"), NumberStyles.Number, CultureI |
| | 15 | 79 | | StatusChangedAt = order.Value<DateTime?>("create_track") |
| | 15 | 80 | | }); |
| | 15 | 81 | | } |
| | 5 | 82 | | catch (Exception ex) when (ex is ZZapApiException or HttpRequestException or TaskCanceledException) |
| | | 83 | | { |
| | 5 | 84 | | result.Add(new SupplierStatusSnapshot { OrderId = state.OrderId, Kind = SupplierStatusKind.Order, Status |
| | 5 | 85 | | } |
| | 20 | 86 | | } |
| | | 87 | | |
| | 29 | 88 | | await _db.SaveChangesAsync(ct); |
| | 29 | 89 | | return result; |
| | 29 | 90 | | } |
| | | 91 | | |
| | | 92 | | /// <summary>Конечен ли статус по коду ZZap — для сида справочника; резолвер сам IsFinal не ставит.</summary> |
| | 20 | 93 | | public static bool IsFinalTrackCode(int? code) => code.HasValue && FinalTrackCodes.Contains(code.Value); |
| | | 94 | | |
| | | 95 | | private static long ReadCodeOrder(OrderSupplierStateRef state) => |
| | 30 | 96 | | long.TryParse(state.ExternalOrderId ?? state.ExternalOrderNumber ?? state.ExternalBasketItemId, NumberStyles.Int |
| | 30 | 97 | | CultureInfo.InvariantCulture, out var id) ? id : 0; |
| | | 98 | | } |