387 lines
19 KiB
C#
387 lines
19 KiB
C#
using Microsoft.EntityFrameworkCore;
|
||
using Microsoft.Extensions.Logging;
|
||
using PARR.DAL.Models;
|
||
using PARR.DAL.Services.Interfaces;
|
||
using PARR.Domain.Common.Rabbit.Messages;
|
||
using PARR.Domain.Enums;
|
||
|
||
namespace PARR.TemplateActivator;
|
||
|
||
internal class TemplateActivator : ITemplateActivator
|
||
{
|
||
private readonly ILogger<TemplateActivator> logger;
|
||
private readonly ITemplateService templateService;
|
||
private readonly IRobotConfigurationService robotConfigurationService;
|
||
//private readonly IJobAutoControlService jobAutoControlService;
|
||
//private readonly IApplicationsInWorkService applicationsInWorkService;
|
||
|
||
public TemplateActivator(
|
||
ILogger<TemplateActivator> logger,
|
||
ITemplateService templateService,
|
||
IRobotConfigurationService robotConfigurationService
|
||
//IJobAutoControlService jobAutoControlService,
|
||
//IApplicationsInWorkService applicationsInWorkService
|
||
)
|
||
{
|
||
this.logger = logger;
|
||
this.templateService = templateService;
|
||
this.robotConfigurationService = robotConfigurationService;
|
||
//this.jobAutoControlService = jobAutoControlService;
|
||
//this.applicationsInWorkService = applicationsInWorkService;
|
||
}
|
||
|
||
public async Task ChangeStateAsync(TemplateActivatorMq query)
|
||
{
|
||
var templates = await GetTemplatesAsync(query);
|
||
|
||
logger.LogInformation($"Объектов для изменения: {templates.Count} шт.");
|
||
|
||
if (templates.Count == 0)
|
||
return;
|
||
|
||
switch (query.EsppObject)
|
||
{
|
||
case TemplateActivatorEsppObjectTypesEnum.Template:
|
||
foreach (var template in templates)
|
||
{
|
||
if (template.IsActiveTemplate != query.NewState)
|
||
{
|
||
template.IsActiveTemplate = query.NewState;
|
||
UpdateRobotConfiguration(RobotsEnum.TemplateOrder, template);
|
||
}
|
||
}
|
||
break;
|
||
|
||
case TemplateActivatorEsppObjectTypesEnum.Schedule:
|
||
foreach (var template in templates)
|
||
{
|
||
if (template.IsActiveSchedule != query.NewState)
|
||
{
|
||
template.IsActiveSchedule = query.NewState;
|
||
UpdateRobotConfiguration(RobotsEnum.ScheduleOrder, template);
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
|
||
if (!await templateService.CommitAsync(query.HistoryInitiator))
|
||
logger.LogError($"Не удалось записать измения в БД о новых состояниях шаблонов и расписаний.");
|
||
|
||
logger.LogInformation($"Изменено состояние объектов: {templates.Count}");
|
||
|
||
}
|
||
|
||
private async Task<List<Template>> GetTemplatesAsync(TemplateActivatorMq query)
|
||
{
|
||
// ищем все шаблоны попадающие под условие
|
||
var templatesQuery = templateService.Get();
|
||
|
||
switch (query.EsppObject)
|
||
{
|
||
case TemplateActivatorEsppObjectTypesEnum.Template:
|
||
//нужно изменить шаблоны
|
||
templatesQuery = templatesQuery.Where(t => t.IsActiveTemplate != query.NewState);
|
||
break;
|
||
|
||
case TemplateActivatorEsppObjectTypesEnum.Schedule:
|
||
//нужно изменить расписания
|
||
templatesQuery = templatesQuery.Where(t => t.IsActiveSchedule != query.NewState);
|
||
break;
|
||
}
|
||
|
||
|
||
switch (query.EntityType)
|
||
{
|
||
case SyncTaskEntityTypeEnum.JobGroup:
|
||
templatesQuery = templatesQuery.Where(t => t.Job!.GroupId == query.Id);
|
||
break;
|
||
case SyncTaskEntityTypeEnum.Job:
|
||
templatesQuery = templatesQuery.Where(t => t.JobId == query.Id);
|
||
break;
|
||
case SyncTaskEntityTypeEnum.Template:
|
||
templatesQuery = templatesQuery.Where(t => t.Id == query.Id);
|
||
break;
|
||
default:
|
||
// прекращаем, чтоб слуяайно не обновить все шаблоны
|
||
throw new InvalidOperationException($"Неверный тип объекта. {nameof(query.EntityType)}: {query.EntityType}");
|
||
}
|
||
|
||
if (query.AllowUnused == false)
|
||
// учитываем только шаблоны которые не помеченные как IsUnused = true (неиспользуемые)
|
||
// т е берем только используемые шаблоны
|
||
templatesQuery = templatesQuery.Where(t => t.StatusTypeId == TemplateStatusTypeEnum.Used);
|
||
|
||
return await templatesQuery.Include(t => t.RobotConfigurations).ToListAsync();
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// принудительно обновить состояние задачи, связанной с шаблоном/расписанием, на обновление
|
||
/// </summary>
|
||
/// <param name="robotsEnum"></param>
|
||
/// <param name="t"></param>
|
||
private void UpdateRobotConfiguration(RobotsEnum robotsEnum, Template t)
|
||
{
|
||
var config = robotConfigurationService.GetFromTemplateByRobotCode(robotsEnum, t);
|
||
// robotConfigurationService.ChangeTaskStatus(TaskStatusEnum.Updating, config);
|
||
robotConfigurationService.SetUpdateTaskStatusIfAllow(config);
|
||
}
|
||
|
||
|
||
|
||
#region old
|
||
|
||
//public async Task ChangeStateAsyncOld(Guid applicationInWorkId, TemplateActivatorActionsEnum action, IHistoryInitiator? historyInitiator)//TODO Migratin to Job
|
||
//{
|
||
// var query = templateService.Get()
|
||
// .Include(t => t.RobotConfigurations).ThenInclude(t => t.Robot)
|
||
// .Where(t => t.JobId == applicationInWorkId);//TODO Migratin to Job
|
||
// var changes = 0;
|
||
// switch (action)
|
||
// {
|
||
// case TemplateActivatorActionsEnum.ActivateAllTemplates:
|
||
// logger.LogInformation($"Получен запрос на активацию всех шаблонов");
|
||
// query = query.Where(t => !t.IsActiveTemplate);
|
||
// changes = await UpdateTemplateStateAsync(query, true);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.ActivateTemplatesWithActiveSchedules:
|
||
// logger.LogInformation($"Получен запрос на активацию всех шаблонов, у которых активировано расписание");
|
||
// query = query.Where(t => !t.IsActiveTemplate && t.IsActiveSchedule);
|
||
// changes = await UpdateTemplateStateAsync(query, true);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.DeactivateAllTemplates:
|
||
// logger.LogInformation($"Получен запрос на деактивацию всех шаблонов");
|
||
// query = query.Where(t => t.IsActiveTemplate);
|
||
// changes = await UpdateTemplateStateAsync(query, false);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.DeactivateTemplatesWithDeactivationSchedules:
|
||
// logger.LogInformation($"Получен запрос на деактивацию всех шаблонов, у которых неактивированы расписания");
|
||
// query = query.Where(t => t.IsActiveTemplate && !t.IsActiveSchedule);
|
||
// changes = await UpdateTemplateStateAsync(query, false);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.ActivateAllSchedules:
|
||
// logger.LogInformation($"Получен запрос на активацию всех расписаний");
|
||
// query = query.Where(t => !t.IsActiveSchedule);
|
||
// changes = await UpdateScheduleStateAsync(query, true);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.DeactivateAllSchedules:
|
||
// logger.LogInformation($"Получен запрос на деактивацию всех расписаний");
|
||
// query = query.Where(t => t.IsActiveSchedule);
|
||
// changes = await UpdateScheduleStateAsync(query, false);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.ActivateSchedulesWithActiveTemplates:
|
||
// logger.LogInformation($"Получен запрос на активацию всех расписаний, у которых активированы шаблоны");
|
||
// query = query.Where(t => t.IsActiveTemplate && !t.IsActiveSchedule);
|
||
// changes = await UpdateScheduleStateAsync(query, true);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.DeactivateSchedulesWithDeactivationTemplates:
|
||
// logger.LogInformation($"Получен запрос на деактивацию всех расписаний, у которых неактивированы шаблоны");
|
||
// query = query.Where(t => !t.IsActiveTemplate && t.IsActiveSchedule);
|
||
// changes = await UpdateScheduleStateAsync(query, false);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.DeactivateSchedulesWithTemplateSyncErrors:
|
||
// logger.LogInformation($"Получен запрос на деактивацию всех расписаний, у которых шаблоны синхронизированы с ошибкой");
|
||
// query = query.Where(t => t.IsActiveTemplate &&
|
||
// t.RobotConfigurations.Any(t =>
|
||
// t.RobotCode == (int)RobotsEnum.TemplateOrder &&
|
||
// t.RobotStatusCode == (int)RobotStatusEnum.Error)
|
||
// );
|
||
// changes = await UpdateScheduleStateAsync(query, false);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.DeactivateAllForAutoControl:
|
||
// logger.LogInformation($"Получен запрос на деактивацию шаблонов и расписаний, для ЭК неудовлетворяющим условиям автоконтроля");
|
||
// changes = await CoordinateJobsWithAutoControlAsync(applicationInWorkId, query, false);
|
||
// break;
|
||
// case TemplateActivatorActionsEnum.ActivateAllForAutoControl:
|
||
// logger.LogInformation($"Получен запрос на активацию шаблонов и расписаний, для ЭК удовлетворяющим условиям автоконтроля");
|
||
// changes = await CoordinateJobsWithAutoControlAsync(applicationInWorkId, query, true);
|
||
// break;
|
||
// default:
|
||
// break;
|
||
// }
|
||
|
||
// if (historyInitiator != null)
|
||
// {
|
||
// historyInitiator.InitiatorComment += $" Action: {action.ToString()}";
|
||
// historyInitiator.InitiatorComment = historyInitiator.InitiatorComment.Trim();
|
||
// }
|
||
|
||
// if (changes > 0 && !await templateService.CommitAsync(historyInitiator))
|
||
// logger.LogError($"{GetType().Name} не удалось записать измения в БД о новых состояниях шаблонов и расписаний регламентной работы Id {applicationInWorkId}");
|
||
|
||
// logger.LogDebug($"{GetType().Name} изменил состояние шаблонов/расписаний({changes}) регламентной работы Id {applicationInWorkId}");
|
||
//}
|
||
|
||
//private async Task<int> CoordinateJobsWithAutoControlAsync(Guid applicationInWorkId, IQueryable<Template> query, bool isActivate)
|
||
//{
|
||
// var changes = 0;
|
||
|
||
// //Добавляем информацию о рабочих группах для возможности их фильтрации
|
||
// query = query.Include(t => t.Unit);//TODO Migratin to Job
|
||
|
||
// //Получаем настройки авто-контроля
|
||
// var jobAutoControlSettings = await GetJobAutoControlSettingsAsync(applicationInWorkId);
|
||
// if (jobAutoControlSettings == null)
|
||
// return 0;
|
||
|
||
// var trueEkStatuses = jobAutoControlSettings.JobAutoControlInEkStatuses;
|
||
// var trueMasks = jobAutoControlSettings.JobEkMasks;
|
||
|
||
// if (!trueEkStatuses.Any() || !trueMasks.Any())
|
||
// {
|
||
// logger.LogWarning($"В ApplicationInWork({applicationInWorkId}) не заданы настройки фильтрации статусов ЭК хоста или маски его имени");
|
||
// return 0;
|
||
// }
|
||
|
||
// //Фильтруем обратное состояние - активированные для деактивации
|
||
// query = FilterTemplatesQueryByWrongState(query, jobAutoControlSettings, isActivate);
|
||
|
||
// //Фильтруем по маскам ЭК
|
||
// var templates = FilterTemplatesByNameNotMatchToMasks(query, trueMasks);
|
||
|
||
// if (!templates.Any())
|
||
// return 0;
|
||
|
||
// //Фильтруем по рабочим группам
|
||
// var appInWorkWorkGroups = GetApplicationInWorkWorkGroups(applicationInWorkId);
|
||
// if (appInWorkWorkGroups.Any())
|
||
// templates = templates.Where(t => appInWorkWorkGroups.Any(awg => t.Unit!.BaseFields!.WorkGroup == awg.WorkGroup!.Name)).ToList();//TODO Migratin to Job
|
||
|
||
// //Фильтруем соответствие статусов ЭК условиям автоконтроля
|
||
// var checkEkStatus = FilterTemplatesByWrongEkStatus(templates, trueEkStatuses, isActivate);
|
||
// //Меняем состояние отфильтрованных шаблонов если какие-то остались
|
||
// if (checkEkStatus.Any())
|
||
// changes = UpdateState(checkEkStatus,
|
||
// isActivate ? jobAutoControlSettings.OnTemplateIsActive : jobAutoControlSettings.OffTemplateIsActive,
|
||
// isActivate ? jobAutoControlSettings.OnScheduleIsActive : jobAutoControlSettings.OffScheduleIsActive);
|
||
|
||
// return changes;
|
||
//}
|
||
|
||
//private List<AppInWorkInWorkGroup> GetApplicationInWorkWorkGroups(Guid applicationInWorkId)
|
||
//{
|
||
// var appInWorkInWorkGroups = applicationsInWorkService.Get()
|
||
// .Include(aiw => aiw.WorkGroups)
|
||
// .FirstOrDefault(t => t.Id == applicationInWorkId)?.WorkGroups;
|
||
|
||
// if (appInWorkInWorkGroups != null)
|
||
// return appInWorkInWorkGroups.ToList();
|
||
|
||
// return new List<AppInWorkInWorkGroup>();
|
||
//}
|
||
|
||
//private List<Template> FilterTemplatesByWrongEkStatus(List<Template> templates, ICollection<JobAutoControlInEkStatus> trueEkStatuses, bool isActivate)
|
||
//{
|
||
// if (isActivate)
|
||
// return templates.Where(t => trueEkStatuses.Any(tes => tes.EkStatus!.Name == t.Unit!.BaseFields!.Status)).ToList();//TODO Migratin to Job
|
||
|
||
// return templates.Where(t => !trueEkStatuses.Any(tes => tes.EkStatus!.Name == t.Unit!.BaseFields!.Status)).ToList();//TODO Migratin to Job
|
||
//}
|
||
|
||
//private List<Template> FilterTemplatesByNameNotMatchToMasks(IQueryable<Template> query, ICollection<JobEkMask> trueMasks)
|
||
//{
|
||
// var result = new List<Template>();
|
||
// foreach (var mask in trueMasks)
|
||
// {
|
||
// var templates = query.Where(t => EF.Functions.Like(t.Unit!.Name.ToLower(), SqlHelpers.RegexToLike(mask.Name))).ToList();
|
||
// result.AddRange(templates);
|
||
// }
|
||
|
||
// return result;
|
||
//}
|
||
|
||
//private IQueryable<Template> FilterTemplatesQueryByWrongState(IQueryable<Template> query, JobAutoControl jobAutoControlSettings, bool isActivate)
|
||
//{
|
||
// if (isActivate)
|
||
// return query.Where(t => t.IsActiveTemplate != jobAutoControlSettings.OnTemplateIsActive || t.IsActiveSchedule != jobAutoControlSettings.OnScheduleIsActive);
|
||
|
||
// return query.Where(t => t.IsActiveTemplate != jobAutoControlSettings.OffTemplateIsActive || t.IsActiveSchedule != jobAutoControlSettings.OffScheduleIsActive);
|
||
//}
|
||
|
||
//private async Task<JobAutoControl> GetJobAutoControlSettingsAsync(Guid applicationInWorkId)
|
||
//{
|
||
// return await jobAutoControlService.Get()
|
||
// .Include(jac => jac.JobAutoControlInEkStatuses)
|
||
// .Include(jac => jac.JobEkMasks)
|
||
// .Where(jac => jac.ApplicationInWorkId == applicationInWorkId).FirstAsync();
|
||
//}
|
||
|
||
///// <summary>
|
||
///// Обновить состояние расписаний по запросу query на newState, без записи в БД. Возвращает количество шаблонов требующих фиксации в БД
|
||
///// </summary>
|
||
///// <param name="query"></param>
|
||
///// <param name="newState"></param>
|
||
///// <returns></returns>
|
||
//private async Task<int> UpdateScheduleStateAsync(IQueryable<Template> query, bool newState)
|
||
//{
|
||
// var templates = await query.Select(t => t).ToListAsync();
|
||
|
||
// if (templates.Any())
|
||
// templates.ForEach(t =>
|
||
// {
|
||
// t.IsActiveSchedule = newState;
|
||
// UpdateRobotConfiguration(RobotsEnum.ScheduleOrder, t);
|
||
// });
|
||
|
||
// templates.ForEach(t => t.IsActiveSchedule = newState);
|
||
|
||
// 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)
|
||
//{
|
||
// var templates = await query.Select(t => t).ToListAsync();
|
||
|
||
// if (templates.Any())
|
||
// templates.ForEach(t =>
|
||
// {
|
||
// t.IsActiveTemplate = newState;
|
||
// UpdateRobotConfiguration(RobotsEnum.TemplateOrder, t);
|
||
// });
|
||
|
||
|
||
// return templates.Count;
|
||
//}
|
||
|
||
|
||
///// <summary>
|
||
///// Обновить состояние шаблонов по запросу query на newState, без записи в БД. Возвращает количество расписаний требующих фиксацию в БД
|
||
///// </summary>
|
||
///// <param name="query"></param>
|
||
///// <param name="newState"></param>
|
||
///// <returns></returns>
|
||
//private async Task<int> UpdateStateAsync(IQueryable<Template> query, bool newTemplateState, bool newSchedulerState)
|
||
//{
|
||
// var templates = await query.Select(t => t).ToListAsync();
|
||
|
||
// return UpdateState(templates, newTemplateState, newSchedulerState);
|
||
//}
|
||
|
||
|
||
//private int UpdateState(List<Template> templates, bool newTemplateState, bool newSchedulerState)
|
||
//{
|
||
// if (templates.Any())
|
||
// templates.ForEach(t =>
|
||
// {
|
||
// t.IsActiveTemplate = newTemplateState;
|
||
// t.IsActiveSchedule = newSchedulerState;
|
||
// UpdateRobotConfiguration(RobotsEnum.TemplateOrder, t);
|
||
// });
|
||
|
||
|
||
// return templates.Count;
|
||
//}
|
||
|
||
|
||
|
||
|
||
#endregion
|
||
}
|