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

feat(templateMatcher): незначительные улучшения

Browse Source
This commit is contained in:
Mikhail Kuznetsov
2026-02-05 09:15:40 +10:00
parent 0264ac9d52
commit 7b3e64c733
1 changed files with 19 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
PARR.TemplateUpdater/Services/TemplateUpdaterService.cs
View File

@@ -40,7 +40,7 @@ namespace PARR.TemplateUpdater.Services
var isValid = await IsValidAsync(query);
if (!isValid)
{
logger.LogError($"Не валидны входные данные. Конец обработки сообщения {query.ToJson()}");
logger.LogError("Не валидны входные данные. Конец обработки сообщения {Query}", query.ToJson());
return;
}
@@ -51,7 +51,7 @@ namespace PARR.TemplateUpdater.Services
.FirstOrDefaultAsync(t => t.Id == query.TemplateId);
if (template == null)
{
logger.LogError($"Не найден шаблон с id {query.TemplateId}");
logger.LogError("Не найден шаблон с id {TemplateId}", query.TemplateId);
return;
}
@@ -140,7 +140,7 @@ namespace PARR.TemplateUpdater.Services
var config = robotConfigurationService.GetFromTemplateByRobotCode(RobotsEnum.TemplateOrder, template);
robotConfigurationService.ChangeTaskStatus(TaskStatusEnum.Updating, config);
logger.LogDebug($"Для шаблона {nameof(template.Id)}:{template.Id} устанавливаю статус {RobotStatusEnum.Wait.ToString()}");
logger.LogDebug("Для шаблона {TemplateId} устанавливаю статус {Status}", template.Id, RobotStatusEnum.Wait.ToString());
}
if (scheduleIsChanged)
@@ -149,14 +149,17 @@ namespace PARR.TemplateUpdater.Services
var config = robotConfigurationService.GetFromTemplateByRobotCode(RobotsEnum.ScheduleOrder, template);
robotConfigurationService.ChangeTaskStatus(TaskStatusEnum.Updating, config);
logger.LogDebug($"Для расписания {nameof(template.Id)}:{template.Id} устанавливаю статус {RobotStatusEnum.Wait.ToString()}");
logger.LogDebug("Для расписания {TemplateId} устанавливаю статус {Status}", template.Id, RobotStatusEnum.Wait.ToString());
}
if (!await templateService.CommitAsync(query.Initiator))
logger.LogError($"Не удалось сохранить изменения в БД. {nameof(TemplateUpdaterMq)}: {query.ToJson()}.");
{
logger.LogError("Не удалось сохранить изменения в БД. {QueryType}: {Query}", nameof(TemplateUpdaterMq), query.ToJson());
return;
}
logger.LogInformation($"Выполнено изменение шаблона в БД. Отправлен запрос на синхронизацию шаблона: {templateIsChanged}, расписания: {scheduleIsChanged} .Query {query.ToJson()}");
logger.LogInformation("Выполнено изменение шаблона в БД. Отправлен запрос на синхронизацию шаблона: {TemplateIsChanged}, расписания: {ScheduleIsChanged}. Query {Query}", templateIsChanged, scheduleIsChanged, query.ToJson());
}
@@ -170,37 +173,37 @@ namespace PARR.TemplateUpdater.Services
var template = await templateService.Get().AsNoTracking().AnyAsync(t => t.Id == query.TemplateId);
if (!template)
{
logger.LogError($"Сообщение не валидно. Не найден шаблон с id: {query.TemplateId}");
logger.LogError("Сообщение не валидно. Не найден шаблон с id: {TemplateId}", query.TemplateId);
return false;
}
if (string.IsNullOrEmpty(query.Name.Trim()))
if (string.IsNullOrEmpty(query.Name?.Trim()))
{
logger.LogError($"Сообщение не валидно. Имя шаблона не может быть пустым: {query.Name}");
logger.LogError("Сообщение не валидно. Имя шаблона не может быть пустым: {TemplateName}", query.Name);
return false;
}
var existTemplateName = await templateService.Get().AsNoTracking().AnyAsync(t =>
t.Id != query.TemplateId
&& t.Name.ToUpper() == query.Name.Trim().ToUpper()
&& t.Name!.ToUpper() == query.Name.Trim().ToUpper()
&& t.Index == query.Index);
if (existTemplateName)
{
logger.LogError($"Сообщение не валидно. Имя шаблона не уникально: {query.Name}");
logger.LogError("Сообщение не валидно. Имя шаблона не уникально: {TemplateName}", query.Name);
return false;
}
var job = await jobService.Get().AsNoTracking().AnyAsync(t => t.Id == query.JobId);
if (!job)
{
logger.LogError($"Сообщение не валидно. Не найдена работа с JobId: {query.JobId}");
logger.LogError("Сообщение не валидно. Не найдена работа с JobId: {JobId}", query.JobId);
return false;
}
var unit = await unitService.Get().AsNoTracking().AnyAsync(t => t.Id == query.UnitId);
if (!unit)
{
logger.LogError($"Сообщение не валидно. Не найден unit с UnitId: {query.UnitId}");
logger.LogError("Сообщение не валидно. Не найден unit с UnitId: {UnitId}", query.UnitId);
return false;
}