refactor(TemplateActivator): Добавлены комментарии в коде

This commit is contained in:
Mikhail Kuznetsov
2024-07-26 11:41:40 +10:00
parent 014c760225
commit dfd6b29f0c
2 changed files with 38 additions and 5 deletions

View File

@@ -4,5 +4,11 @@ namespace PARR.TemplateActivator;
public interface ITemplateActivator public interface ITemplateActivator
{ {
/// <summary>
/// Обновить состояние шаблонов или расписаний в соответствии со значением параметра action по applicationInWorkId
/// </summary>
/// <param name="applicationInWorkId"></param>
/// <param name="action"></param>
/// <returns></returns>
Task ChangeStateAsync(Guid applicationInWorkId, TemplateActivatorActionsEnum action); Task ChangeStateAsync(Guid applicationInWorkId, TemplateActivatorActionsEnum action);
} }

View File

@@ -23,6 +23,8 @@ internal class TemplateActivator : ITemplateActivator
this.templateService = templateService; this.templateService = templateService;
this.robotConfigurationService = robotConfigurationService; this.robotConfigurationService = robotConfigurationService;
} }
public async Task ChangeStateAsync(Guid applicationInWorkId, TemplateActivatorActionsEnum action) public async Task ChangeStateAsync(Guid applicationInWorkId, TemplateActivatorActionsEnum action)
{ {
var query = templateService.Get() var query = templateService.Get()
@@ -32,35 +34,43 @@ internal class TemplateActivator : ITemplateActivator
switch (action) switch (action)
{ {
case TemplateActivatorActionsEnum.ActivateAllTemplates: case TemplateActivatorActionsEnum.ActivateAllTemplates:
logger.LogInformation($"Получен запрос на активацию всех шаблонов");
query = query.Where(t => !t.IsActiveTemplate); query = query.Where(t => !t.IsActiveTemplate);
changes = await UpdateTemplateStateAsync(query, true); changes = await UpdateTemplateStateAsync(query, true);
break; break;
case TemplateActivatorActionsEnum.ActivateTemplatesWithActiveSchedules: case TemplateActivatorActionsEnum.ActivateTemplatesWithActiveSchedules:
logger.LogInformation($"Получен запрос на активацию всех шаблонов, у которых активировано расписание");
query = query.Where(t => !t.IsActiveTemplate && t.IsActiveSchedule); query = query.Where(t => !t.IsActiveTemplate && t.IsActiveSchedule);
changes = await UpdateTemplateStateAsync(query, true); changes = await UpdateTemplateStateAsync(query, true);
break; break;
case TemplateActivatorActionsEnum.DeactivateAllTemplates: case TemplateActivatorActionsEnum.DeactivateAllTemplates:
logger.LogInformation($"Получен запрос на деактивацию всех шаблонов");
query = query.Where(t => t.IsActiveTemplate); query = query.Where(t => t.IsActiveTemplate);
changes = await UpdateTemplateStateAsync(query, false); changes = await UpdateTemplateStateAsync(query, false);
break; break;
case TemplateActivatorActionsEnum.DeactivateTemplatesWithDeactivationSchedules: case TemplateActivatorActionsEnum.DeactivateTemplatesWithDeactivationSchedules:
query = query.Where(t => !t.IsActiveTemplate && !t.IsActiveSchedule); logger.LogInformation($"Получен запрос на деактивацию всех шаблонов, у которых неактивированы расписания");
query = query.Where(t => t.IsActiveTemplate && !t.IsActiveSchedule);
changes = await UpdateTemplateStateAsync(query, false); changes = await UpdateTemplateStateAsync(query, false);
break; break;
case TemplateActivatorActionsEnum.ActivateAllSchedules: case TemplateActivatorActionsEnum.ActivateAllSchedules:
logger.LogInformation($"Получен запрос на активацию всех расписаний");
query = query.Where(t => !t.IsActiveSchedule); query = query.Where(t => !t.IsActiveSchedule);
changes = await UpdateScheduleStateAsync(query, true); changes = await UpdateScheduleStateAsync(query, true);
break; break;
case TemplateActivatorActionsEnum.DeactivateAllSchedules: case TemplateActivatorActionsEnum.DeactivateAllSchedules:
logger.LogInformation($"Получен запрос на деактивацию всех расписаний");
query = query.Where(t => t.IsActiveSchedule); query = query.Where(t => t.IsActiveSchedule);
changes = await UpdateScheduleStateAsync(query, false); changes = await UpdateScheduleStateAsync(query, false);
break; break;
case TemplateActivatorActionsEnum.ActivateSchedulesWithActiveTemplates: case TemplateActivatorActionsEnum.ActivateSchedulesWithActiveTemplates:
logger.LogInformation($"Получен запрос на активацию всех расписаний, у которых активированы шаблоны");
query = query.Where(t => t.IsActiveTemplate && !t.IsActiveSchedule); query = query.Where(t => t.IsActiveTemplate && !t.IsActiveSchedule);
changes = await UpdateScheduleStateAsync(query, true); changes = await UpdateScheduleStateAsync(query, true);
break; break;
case TemplateActivatorActionsEnum.DeactivateSchedulesWithDeactivationTemplates: case TemplateActivatorActionsEnum.DeactivateSchedulesWithDeactivationTemplates:
query = query.Where(t => !t.IsActiveTemplate); logger.LogInformation($"Получен запрос на деактивацию всех расписаний, у которых неактивированы шаблоны");
query = query.Where(t => !t.IsActiveTemplate && t.IsActiveSchedule);
changes = await UpdateScheduleStateAsync(query, false); changes = await UpdateScheduleStateAsync(query, false);
break; break;
default: default:
@@ -68,10 +78,17 @@ internal class TemplateActivator : ITemplateActivator
} }
if (changes > 0 && !await templateService.CommitAsync()) if (changes > 0 && !await templateService.CommitAsync())
logger.LogError($"{this.GetType} не удалось записать измения состояний шаблонов и расписаний регламентной работы {applicationInWorkId}"); logger.LogError($"{this.GetType} не удалось записать измения в БД о новых состояниях шаблонов и расписаний регламентной работы Id {applicationInWorkId}");
} }
/// <summary>
/// Обновить состояние расписаний по запросу query на newState, без записи в БД. Возвращает количество шаблонов требующих фиксации в БД
/// </summary>
/// <param name="query"></param>
/// <param name="newState"></param>
/// <returns></returns>
private async Task<int> UpdateScheduleStateAsync(IQueryable<Template> query, bool newState) private async Task<int> UpdateScheduleStateAsync(IQueryable<Template> query, bool newState)
{ {
var templates = await query.Select(t => t).ToListAsync(); var templates = await query.Select(t => t).ToListAsync();
@@ -83,12 +100,18 @@ internal class TemplateActivator : ITemplateActivator
UpdateRobotConfiguration(RobotsEnum.ScheduleOrder, t); UpdateRobotConfiguration(RobotsEnum.ScheduleOrder, t);
}); });
templates.ForEach(t => t.IsActiveSchedule = newState); templates.ForEach(t => t.IsActiveSchedule = newState);
return templates.Count; return templates.Count;
} }
/// <summary>
/// Обновить состояние расписаний по запросу query на newState, без записи в БД. Возвращает количество расписаний требующих фиксацию в БД
/// </summary>
/// <param name="query"></param>
/// <param name="newState"></param>
/// <returns></returns>
private async Task<int> UpdateTemplateStateAsync(IQueryable<Template> query, bool newState) private async Task<int> UpdateTemplateStateAsync(IQueryable<Template> query, bool newState)
{ {
var templates = await query.Select(t => t).ToListAsync(); var templates = await query.Select(t => t).ToListAsync();
@@ -104,7 +127,11 @@ internal class TemplateActivator : ITemplateActivator
return templates.Count; return templates.Count;
} }
/// <summary>
/// принудительно обновить состояние задачи, связанной с шаблоном/расписанием, на обновление
/// </summary>
/// <param name="robotsEnum"></param>
/// <param name="t"></param>
private void UpdateRobotConfiguration(RobotsEnum robotsEnum, Template t) private void UpdateRobotConfiguration(RobotsEnum robotsEnum, Template t)
{ {
var config = robotConfigurationService.GetFromTemplateByRobotCode(robotsEnum, ref t); var config = robotConfigurationService.GetFromTemplateByRobotCode(robotsEnum, ref t);