| | | 1 | | using Microsoft.EntityFrameworkCore; |
| | | 2 | | using Microsoft.Extensions.Caching.Memory; |
| | | 3 | | using OzonRepositories.Context; |
| | | 4 | | |
| | | 5 | | namespace Services.ApiServices.InterpartsPriceApi; |
| | | 6 | | |
| | | 7 | | /// <summary>Справочник валют Interparts: курс к рублю и отображаемое имя по id.</summary> |
| | | 8 | | /// <param name="Rates">id валюты → курс к рублю.</param> |
| | | 9 | | /// <param name="Names">id валюты → название из справочника.</param> |
| | | 10 | | public sealed record InterpartsCurrencyDirectory( |
| | | 11 | | IReadOnlyDictionary<int, decimal> Rates, |
| | | 12 | | IReadOnlyDictionary<int, string> Names); |
| | | 13 | | |
| | | 14 | | /// <summary> |
| | | 15 | | /// Курсы валют из таблицы InterpartsSutCurrencies (основная MySQL БД) для перевода цен Interparts в рубли. |
| | | 16 | | /// </summary> |
| | | 17 | | public sealed class InterpartsCurrencyRateService |
| | | 18 | | { |
| | | 19 | | private const string CacheKey = "Interparts_SutCurrency_Directory_v3_mysql"; |
| | 0 | 20 | | private static readonly TimeSpan CacheTtl = TimeSpan.FromMinutes(10); |
| | | 21 | | |
| | | 22 | | private readonly ApplicationDbContext _db; |
| | | 23 | | private readonly IMemoryCache _cache; |
| | | 24 | | |
| | 5 | 25 | | public InterpartsCurrencyRateService(ApplicationDbContext db, IMemoryCache cache) |
| | | 26 | | { |
| | 5 | 27 | | _db = db; |
| | 5 | 28 | | _cache = cache; |
| | 5 | 29 | | } |
| | | 30 | | |
| | | 31 | | public async Task<IReadOnlyDictionary<int, decimal>> GetRatesToRubAsync(CancellationToken cancellationToken = defaul |
| | | 32 | | { |
| | 0 | 33 | | var directory = await GetDirectoryAsync(cancellationToken).ConfigureAwait(false); |
| | 0 | 34 | | return directory.Rates; |
| | 0 | 35 | | } |
| | | 36 | | |
| | | 37 | | /// <summary>Курсы вместе с названиями валют — для подсказки «цена × курс» в проценке.</summary> |
| | | 38 | | public async Task<InterpartsCurrencyDirectory> GetDirectoryAsync(CancellationToken cancellationToken = default) |
| | | 39 | | { |
| | 0 | 40 | | if (_cache.TryGetValue(CacheKey, out InterpartsCurrencyDirectory? cached) && cached != null) |
| | 0 | 41 | | return cached; |
| | | 42 | | |
| | 0 | 43 | | var rows = await _db.InterpartsSutCurrencies |
| | 0 | 44 | | .AsNoTracking() |
| | 0 | 45 | | .Select(c => new { c.Id, c.Name, c.RateToRub }) |
| | 0 | 46 | | .ToListAsync(cancellationToken) |
| | 0 | 47 | | .ConfigureAwait(false); |
| | | 48 | | |
| | 0 | 49 | | var directory = new InterpartsCurrencyDirectory( |
| | 0 | 50 | | rows.ToDictionary(x => x.Id, x => x.RateToRub), |
| | 0 | 51 | | rows.ToDictionary(x => x.Id, x => x.Name)); |
| | | 52 | | |
| | 0 | 53 | | _cache.Set(CacheKey, directory, new MemoryCacheEntryOptions |
| | 0 | 54 | | { |
| | 0 | 55 | | AbsoluteExpirationRelativeToNow = CacheTtl |
| | 0 | 56 | | }); |
| | | 57 | | |
| | 0 | 58 | | return directory; |
| | 0 | 59 | | } |
| | | 60 | | |
| | | 61 | | /// <summary>Сбрасывает кэш после ручного изменения курсов в админке.</summary> |
| | 0 | 62 | | public void InvalidateRatesCache() => _cache.Remove(CacheKey); |
| | | 63 | | |
| | | 64 | | /// <summary> |
| | | 65 | | /// Курс для SupplierCurrencyId; при отсутствии id или записи — 1 и <paramref name="usedFallback"/> = true. |
| | | 66 | | /// </summary> |
| | | 67 | | public static decimal GetRateToRub(int? supplierCurrencyId, IReadOnlyDictionary<int, decimal> rates, out bool usedFa |
| | | 68 | | { |
| | 44 | 69 | | usedFallback = false; |
| | 44 | 70 | | if (!supplierCurrencyId.HasValue || supplierCurrencyId.Value <= 0) |
| | | 71 | | { |
| | 3 | 72 | | usedFallback = true; |
| | 3 | 73 | | return 1m; |
| | | 74 | | } |
| | | 75 | | |
| | 41 | 76 | | if (rates.TryGetValue(supplierCurrencyId.Value, out var rate)) |
| | 13 | 77 | | return rate; |
| | | 78 | | |
| | 28 | 79 | | usedFallback = true; |
| | 28 | 80 | | return 1m; |
| | | 81 | | } |
| | | 82 | | } |