mikhail/parr_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(core, infrastructure): UnitService - массовое получение юнитов

Browse Source
This commit is contained in:
Mikhail Trubnikov
2026-06-01 11:58:08 +10:00
parent 437f996ea8
commit bdcc858bc5
3 changed files with 57 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
PARR.Core/Services/UnitService/Implementations/UnitCacheService.cs
View File

@@ -83,20 +83,40 @@ namespace PARR.Core.Services.UnitService.Implementations
return (HashKey: hashKey, FieldKey: fieldKey);
}).ToList();
logger.LogDebug("Необходимо найти инорфмацию для {Count} объектов.", ids.Count);
// Получаем из кэш
var cacheData = await redisCacheService.GetHashFieldsAsync<UnitInfo>(keys, true);
// проверить, если получили все элементы, вернуть
// если не все, докачать из бд
logger.LogDebug("Из кэша получена информация о {Count} объектах.", cacheData.Count);
var resultDictionary = cacheData.ToDictionary(unit => unit.Id, unit => unit);
// Проверям каких данных нет в кэш, догрузим из из БД
if (resultDictionary.Count < ids.Count)
{
// Находим id которых нет в кэше
var missingIds = ids.Where(id => !resultDictionary.ContainsKey(id)).ToHashSet();
logger.LogDebug("Запрашиваем из БД дополнительно {Count} юнитов", missingIds.Count);
var dbData = await GetUnitsAsync(missingIds);
foreach (var unit in dbData)
{
resultDictionary[unit.Id] = unit;
// Добавляем в кэш
var hashKey = redisCacheService.GetKey(CacheKeys.Unit.UnitHashWithBucket(unit.Id));
var unitKey = redisCacheService.GetKey(CacheKeys.Unit.UnitItem(unit.Id));
await redisCacheService.SetHashFieldAsync(hashKey, unitKey, unit, CacheTtl, true);
}
}
// сохранить докаченные в кэш + ттл + не забыть указать сжатие (может вообще этот метод вынести отдельно, так как пересекается когда по одному)
//var dbData = await GetUnitsAsync(ids);
//todo:
return null;
return resultDictionary;
}
/// <summary>

2
PARR.DAL/Context/DataContext.cs
View File

@@ -203,7 +203,7 @@ namespace PARR.DAL.Context
new { Name = nameof(SettingsFromDb.Category), Description = "Категория создаваемого объекта в ЕСПП", Value = "регламентная работа" },
new { Name = nameof(SettingsFromDb.TemplatePrefixName), Description = "Префикс имени шаблона в ЕСПП", Value = "%PREFIX%-ЭИТИ-ПТК-ПАРР" },
new { Name = nameof(SettingsFromDb.RobotAttemptsNumber), Description = "Количество попыток выполнения задания роботом", Value = "3" },
new { Name = nameof(SettingsFromDb.RobotWaitTime), Description = "Время ожидания выполнения роботом задания", Value = "00:15:00" },
new { Name = nameof(SettingsFromDb.RobotWaitTime), Description = "Время ожидания выполнения роботом задания", Value = "00:10:00" },
new { Name = nameof(SettingsFromDb.EsppScheduleTimezone), Description = "Расписание регламентной работы - В каком часовом поясе", Value = "MSK" },
//new { Name = nameof(SettingsFromDb.ScheduleExcludeType), Description = "Расписание регламентной работы - Тип исключения", Value = "Выполнить ТОЛЬКО В указанном календаре" },
//new { Name = nameof(SettingsFromDb.ScheduleExcludeCalendar), Description = "Расписание регламентной работы - Календарь", Value = "8x5 (8.00-17.00)" },

51
PARR.Infrastructure/Redis/RedisCacheService.cs
View File

@@ -226,7 +226,8 @@ namespace PARR.Infrastructure.Redis
// хранили в байтах
try
{
return DeserializeWithCompression<T>(value);
byte[] rawBytes = value!;
return DeserializeWithCompression<T>(rawBytes);
}
catch (Exception ex)
{
@@ -236,7 +237,7 @@ namespace PARR.Infrastructure.Redis
else
{
// хранили в строке
return JsonSerializer.Deserialize<T>(value);
return JsonSerializer.Deserialize<T>(value!);
}
}
@@ -257,33 +258,35 @@ namespace PARR.Infrastructure.Redis
logger.LogDebug("Сформировал {Count} одновременных запросов в кэш", tasks.Count);
// Ждем ответа от текущей порции
RedisValue[] results = await Task.WhenAll(tasks);
RedisValue[] results = await Task.WhenAll(tasks);
// Парсим
foreach (var result in results)
{
if (result.HasValue)
{
if (useCompression)
{
try
{
var item = DeserializeWithCompression<T>((byte[])result);
if (item != null)
allItems.Add(item);
}
catch (Exception ex)
{
throw new InvalidOperationException("Формат данных не байты.", ex);
}
}
else
{
var item = JsonSerializer.Deserialize<T>(result.ToString());
if (item != null)
allItems.Add(item);
}
if (!result.HasValue)
continue;
if (useCompression)
{
// Сжатые данные
try
{
byte[] rawBytes = result!;
var data = DeserializeWithCompression<T>(rawBytes);
if (data != null)
allItems.Add(data!);
}
catch (Exception ex)
{
throw new InvalidOperationException("Формат данных не байты.", ex);
}
}
else
{
// Json
var data = JsonSerializer.Deserialize<T>(result!.ToString());
if (data != null)
allItems.Add(data);
}
}