From 0b0c0b04ad4fc558d72648be17e90d6a9e56b127 Mon Sep 17 00:00:00 2001 From: Mikhail Trubnikov Date: Wed, 22 Jul 2026 09:49:27 +1000 Subject: [PATCH 1/6] =?UTF-8?q?feat(dal,templateUpdater):=20=D0=A1=D0=BE?= =?UTF-8?q?=D1=85=D1=80=D0=B0=D0=BD=D0=B5=D0=BD=D0=B8=D0=B5=20=D1=88=D0=B0?= =?UTF-8?q?=D0=B1=D0=BB=D0=BE=D0=BD=D0=BE=D0=B2=20=D0=B4=D0=BB=D1=8F=20?= =?UTF-8?q?=D0=BF=D0=B5=D1=80=D0=B5=D0=B8=D0=BC=D0=B5=D0=BD=D0=BE=D0=B2?= =?UTF-8?q?=D0=B0=D0=BD=D0=B8=D1=8F=20=D0=B2=20=D1=82=D0=B0=D0=B1=D0=BB?= =?UTF-8?q?=D0=B8=D1=86=D1=83=20TemplateRenamePending?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- PARR.API/appsettings.json | 6 +- .../ITemplateRenamePendingRepository.cs | 10 +++ PARR.DAL/DependencyInjection.cs | 8 +++ PARR.DAL/Repositories/Base/BaseRepository.cs | 10 --- .../TemplateRenamePendingRepository.cs | 42 +++++++++++ .../Services/TemplateUpdaterService.cs | 72 +++++++++++++++++-- 6 files changed, 132 insertions(+), 16 deletions(-) create mode 100644 PARR.Core/Repositories/Interfaces/TemplateRepositories/ITemplateRenamePendingRepository.cs create mode 100644 PARR.DAL/Repositories/TemplateRepositories/TemplateRenamePendingRepository.cs diff --git a/PARR.API/appsettings.json b/PARR.API/appsettings.json index 1d9e827e..e0ebee46 100644 --- a/PARR.API/appsettings.json +++ b/PARR.API/appsettings.json @@ -6,7 +6,8 @@ "Logging": { "LogLevel": { "Default": "Information", - "Microsoft.AspNetCore": "Warning" + "Microsoft.AspNetCore": "Warning", + "Microsoft.AspNetCore.Diagnostics.ExceptionHandlerMiddleware": "None" } }, "Serilog": { @@ -14,7 +15,8 @@ "Default": "Information", "Override": { "Microsoft": "Warning", - "Microsoft.Hosting.Lifetime": "Information" + "Microsoft.Hosting.Lifetime": "Information", + "Microsoft.AspNetCore.Diagnostics.ExceptionHandlerMiddleware": "Fatal" } } }, diff --git a/PARR.Core/Repositories/Interfaces/TemplateRepositories/ITemplateRenamePendingRepository.cs b/PARR.Core/Repositories/Interfaces/TemplateRepositories/ITemplateRenamePendingRepository.cs new file mode 100644 index 00000000..9e892852 --- /dev/null +++ b/PARR.Core/Repositories/Interfaces/TemplateRepositories/ITemplateRenamePendingRepository.cs @@ -0,0 +1,10 @@ +using PARR.Domain.Entities.TemplateEntities; + +namespace PARR.Core.Repositories.Interfaces.TemplateRepositories +{ + public interface ITemplateRenamePendingRepository + { + Task CreateAsync(TemplateRenamePending obj); + IQueryable Get(); + } +} diff --git a/PARR.DAL/DependencyInjection.cs b/PARR.DAL/DependencyInjection.cs index 8a41b0f7..c2d342b9 100644 --- a/PARR.DAL/DependencyInjection.cs +++ b/PARR.DAL/DependencyInjection.cs @@ -8,6 +8,7 @@ using PARR.Core.Repositories.Interfaces.JobRepositories; using PARR.Core.Repositories.Interfaces.RobotRepositories; using PARR.Core.Repositories.Interfaces.Schedule; using PARR.Core.Repositories.Interfaces.TaskRepositories; +using PARR.Core.Repositories.Interfaces.TemplateRepositories; using PARR.Core.Repositories.Interfaces.Unit; using PARR.DAL.Configurations.DbSettings; using PARR.DAL.Context; @@ -18,6 +19,7 @@ using PARR.DAL.Repositories.JobRepositories; using PARR.DAL.Repositories.RobotRepositories; using PARR.DAL.Repositories.Schedule; using PARR.DAL.Repositories.TaskRepositories; +using PARR.DAL.Repositories.TemplateRepositories; using PARR.DAL.Repositories.Unit; using PARR.Domain.Settings; @@ -142,6 +144,12 @@ namespace PARR.DAL #endregion + #region Templates + + services.AddScoped(); + + #endregion + //services.AddTransient(); #region NextRun Services diff --git a/PARR.DAL/Repositories/Base/BaseRepository.cs b/PARR.DAL/Repositories/Base/BaseRepository.cs index 7eedce14..98e83bc1 100644 --- a/PARR.DAL/Repositories/Base/BaseRepository.cs +++ b/PARR.DAL/Repositories/Base/BaseRepository.cs @@ -15,16 +15,6 @@ namespace PARR.DAL.Repositories.Base { internal abstract class BaseRepository : IBaseRepository where T : class, IBaseEntity { - //private readonly ILogger> logger; - - //protected abstract DbSet EntitySet { get; } - //protected abstract DataContext EntitiContext { get; } - - //public BaseRepository(ILogger> logger) - //{ - // this.logger = logger; - //} - protected readonly ILogger logger; protected readonly DbSet EntitySet; protected readonly DataContext EntityContext; diff --git a/PARR.DAL/Repositories/TemplateRepositories/TemplateRenamePendingRepository.cs b/PARR.DAL/Repositories/TemplateRepositories/TemplateRenamePendingRepository.cs new file mode 100644 index 00000000..a1e0f023 --- /dev/null +++ b/PARR.DAL/Repositories/TemplateRepositories/TemplateRenamePendingRepository.cs @@ -0,0 +1,42 @@ +using Microsoft.Extensions.Logging; +using PARR.Core.Repositories.Interfaces.TemplateRepositories; +using PARR.DAL.Context; +using PARR.Domain.Entities.TemplateEntities; + +namespace PARR.DAL.Repositories.TemplateRepositories +{ + internal class TemplateRenamePendingRepository : ITemplateRenamePendingRepository + { + private readonly DataContext _dataContext; + private readonly ILogger _logger; + + public TemplateRenamePendingRepository( + DataContext dataContext, + ILogger logger + ) + { + _dataContext = dataContext; + _logger = logger; + } + + + public IQueryable Get() + { + return _dataContext.TemplateRenamePendings; + } + + public async Task CreateAsync(TemplateRenamePending obj) + { + try + { + await _dataContext.TemplateRenamePendings.AddAsync(obj); + return true; + } + catch (Exception ex) + { + _logger.LogError(ex, "Ошибка при добавлении объекта типа TemplateRenamePending в БД"); + return false; + } + } + } +} diff --git a/PARR.TemplateUpdater/Services/TemplateUpdaterService.cs b/PARR.TemplateUpdater/Services/TemplateUpdaterService.cs index ca86b4e5..3ed6c86a 100644 --- a/PARR.TemplateUpdater/Services/TemplateUpdaterService.cs +++ b/PARR.TemplateUpdater/Services/TemplateUpdaterService.cs @@ -3,10 +3,13 @@ using Microsoft.Extensions.Logging; using PARR.Core.Extensions; using PARR.Core.Repositories.Interfaces; using PARR.Core.Repositories.Interfaces.JobRepositories; +using PARR.Core.Repositories.Interfaces.TemplateRepositories; using PARR.Core.Repositories.Interfaces.Unit; using PARR.Core.Services.NextRunServices; using PARR.Domain.Common.Rabbit.Messages.TemplateMatching; +using PARR.Domain.Entities; using PARR.Domain.Entities.JobEntities; +using PARR.Domain.Entities.TemplateEntities; using PARR.Domain.Enums; namespace PARR.TemplateUpdater.Services @@ -20,6 +23,7 @@ namespace PARR.TemplateUpdater.Services private readonly IRobotConfigurationRepository robotConfigurationService; private readonly INextRunService nextRunService; private readonly IUnitInValueRepository unitInValueService; + private readonly ITemplateRenamePendingRepository _templateRenamePendingRepository; public TemplateUpdaterService( ILogger logger, @@ -28,7 +32,8 @@ namespace PARR.TemplateUpdater.Services IUnitRepository unitService, IRobotConfigurationRepository robotConfigurationService, INextRunService nextRunService, - IUnitInValueRepository unitInValueService + IUnitInValueRepository unitInValueService, + ITemplateRenamePendingRepository templateRenamePendingRepository ) { this.logger = logger; @@ -38,6 +43,7 @@ namespace PARR.TemplateUpdater.Services this.robotConfigurationService = robotConfigurationService; this.nextRunService = nextRunService; this.unitInValueService = unitInValueService; + _templateRenamePendingRepository = templateRenamePendingRepository; } @@ -53,7 +59,8 @@ namespace PARR.TemplateUpdater.Services var template = await templateService.Get() .Include(t => t.RobotConfigurations) .Include(t => t.UnitsInTemplate) - .AsSplitQuery() + //.AsSplitQuery() + .AsSingleQuery() .FirstOrDefaultAsync(t => t.Id == query.TemplateId); if (template == null) { @@ -64,9 +71,14 @@ namespace PARR.TemplateUpdater.Services var templateIsChanged = false; var scheduleIsChanged = false; - if (template.Name != query.Name.Trim()) + var trimmedNewName = query.Name.Trim(); + if (template.Name != trimmedNewName) { - template.Name = query.Name.Trim(); + var prepareOldNameResult = await PrepareOldTemplateNameAsync(template.Name, trimmedNewName, template); + if (!prepareOldNameResult) + return; + + template.Name = trimmedNewName; templateIsChanged = true; scheduleIsChanged = true; } @@ -276,5 +288,57 @@ namespace PARR.TemplateUpdater.Services return true; } + + + /// + /// Добавление записи в таблицу ожидания переименования + /// + /// + /// + /// + /// + private async Task PrepareOldTemplateNameAsync(string oldName, string newName, Template template) + { + // Проверяем, не запущено ли уже переименование для этого шаблона + var alreadyPending = await _templateRenamePendingRepository.Get() + .AsNoTracking() + .FirstOrDefaultAsync(t => t.TemplateId == template.Id); + + if (alreadyPending != null) + { + logger.LogError("При попытке переименования шаблона {TemplateId}, из '{OldName}' в '{NewName}', " + + "произошла ошибка, этот шаблон уже находится в процессе переименования (старое имя {PendingName})", template.Id, oldName, newName, alreadyPending.OldName); + return false; + } + + // Уникально ли имя в таблице ожидания переименования + var existPendingOldName = await _templateRenamePendingRepository.Get() + .AsNoTracking() + .FirstOrDefaultAsync(t => t.OldName == oldName); + + if (existPendingOldName != null) + { + logger.LogError("При добавлении старого имени в таблицу ожидания для шаблона {TemplateId} обнаружен конфликт: " + + "имя '{ExistOldName}' уже зарезервировано другим процессом для шаблона {ExistTemplateId}", + template.Id, existPendingOldName.OldName, existPendingOldName.TemplateId); + + return false; + } + + // Все нормально, добавляем запись в таблицу + var pendingRename = new TemplateRenamePending + { + TemplateId = template.Id, + DateCreated = DateTimeOffset.UtcNow, + OldName = oldName, + Template = template + }; + + var addResult = await _templateRenamePendingRepository.CreateAsync(pendingRename); + if (!addResult) + return false; + + return true; + } } } \ No newline at end of file From 1cc2beb9ca9174f01c3e0fbcfbd5bb8d58131dc3 Mon Sep 17 00:00:00 2001 From: Mikhail Trubnikov Date: Wed, 22 Jul 2026 16:02:04 +1000 Subject: [PATCH 2/6] =?UTF-8?q?feat(core):=20=D0=9B=D0=BE=D0=B3=D0=B8?= =?UTF-8?q?=D0=BA=D0=B0=20=D0=B2=D1=8B=D0=B4=D0=B0=D1=87=D0=B8=20=D0=B7?= =?UTF-8?q?=D0=B0=D0=B4=D0=B0=D0=BD=D0=B8=D1=8F=20=D1=80=D0=BE=D0=B1=D0=BE?= =?UTF-8?q?=D1=82=D1=83=20=D0=B4=D0=BB=D1=8F=20=D0=BF=D0=B5=D1=80=D0=B5?= =?UTF-8?q?=D0=B8=D0=BC=D0=B5=D0=BD=D0=BE=D0=B2=D0=B0=D0=BD=D0=BD=D1=8B?= =?UTF-8?q?=D1=85=20=D1=88=D0=B0=D0=B1=D0=BB=D0=BE=D0=BD=D0=BE=D0=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../IRobotConfigurationRepository.cs | 6 + .../Implementations/RobotTaskService.cs | 291 ++++++++++++++---- .../RobotTask/Models/RobotTaskDetails.cs | 9 + .../RobotConfigurationRepository.cs | 63 +++- 4 files changed, 297 insertions(+), 72 deletions(-) create mode 100644 PARR.Core/Services/RobotTask/Models/RobotTaskDetails.cs diff --git a/PARR.Core/Repositories/Interfaces/IRobotConfigurationRepository.cs b/PARR.Core/Repositories/Interfaces/IRobotConfigurationRepository.cs index 5bc2d65a..0160ee45 100644 --- a/PARR.Core/Repositories/Interfaces/IRobotConfigurationRepository.cs +++ b/PARR.Core/Repositories/Interfaces/IRobotConfigurationRepository.cs @@ -49,5 +49,11 @@ namespace PARR.Core.Repositories.Interfaces /// /// Task SetInProgressStatusAsync(Guid id); + + /// + /// Установить статус робота - Ошибка, и поставить максимальное значение попыток + /// + /// + void SetErrorRobotStatusAndMaxAttempts(RobotConfiguration configuration); } } diff --git a/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs b/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs index a10536b5..3757b276 100644 --- a/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs +++ b/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs @@ -1,11 +1,15 @@ using AutoMapper; +using InfluxDB.Client.Api.Domain; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Logging; using PARR.BLL.Helpers; using PARR.Core.Repositories.Interfaces; +using PARR.Core.Repositories.Interfaces.TemplateRepositories; using PARR.Core.Services.NextRunServices; using PARR.Core.Services.RobotTask.Interfaces; +using PARR.Core.Services.RobotTask.Models; using PARR.Core.Services.Shortcodes; +using PARR.Domain.Common.Template; using PARR.Domain.DTOs.RobotTask; using PARR.Domain.Entities; using PARR.Domain.Entities.Base.History; @@ -20,16 +24,18 @@ namespace PARR.Core.Services.RobotTask.Implementations { /// /// Количество заданий которые рассматриваем для взятия в работу. + /// Рекомендованное значение, кол-во роботов * 3 /// - private readonly int TakeTasks = 10; + private readonly int TakeTasks = 15 * 3; - private readonly ILogger logger; - private readonly IRobotConfigurationRepository robotConfigurationRepository; - private readonly SettingsFromDb settingsFromDb; - private readonly IRobotHistoryRepository robotHistoryRepository; - private readonly IMapper mapper; - private readonly IShortcodesService shortcodesService; - private readonly INextRunService nextRunService; + private readonly ILogger _logger; + private readonly IRobotConfigurationRepository _robotConfigurationRepository; + private readonly SettingsFromDb _settingsFromDb; + private readonly IRobotHistoryRepository _robotHistoryRepository; + private readonly IMapper _mapper; + private readonly IShortcodesService _shortcodesService; + private readonly INextRunService _nextRunService; + private readonly ITemplateRenamePendingRepository _templateRenamePendingRepository; public RobotTaskService( ILogger logger, @@ -38,16 +44,18 @@ namespace PARR.Core.Services.RobotTask.Implementations IRobotHistoryRepository robotHistoryRepository, IMapper mapper, IShortcodesService shortcodesService, - INextRunService nextRunService + INextRunService nextRunService, + ITemplateRenamePendingRepository templateRenamePendingRepository ) { - this.logger = logger; - this.robotConfigurationRepository = robotConfigurationRepository; - this.settingsFromDb = settingsFromDb; - this.robotHistoryRepository = robotHistoryRepository; - this.mapper = mapper; - this.shortcodesService = shortcodesService; - this.nextRunService = nextRunService; + this._logger = logger; + this._robotConfigurationRepository = robotConfigurationRepository; + this._settingsFromDb = settingsFromDb; + this._robotHistoryRepository = robotHistoryRepository; + this._mapper = mapper; + this._shortcodesService = shortcodesService; + this._nextRunService = nextRunService; + _templateRenamePendingRepository = templateRenamePendingRepository; } @@ -55,19 +63,19 @@ namespace PARR.Core.Services.RobotTask.Implementations { var templateTask = await GetTaskAsync(RobotsEnum.TemplateOrder, taskStatusCode, acquireTask, robotIp, robotId, TimeSpan.Zero); - var task = mapper.Map(templateTask); + var task = _mapper.Map(templateTask); - task = task with { FullDescription = NormalizeLineEndingsToCrlf(await shortcodesService.ApplyShortcodesAsync(task.FullDescription, templateTask.Template!)) }; - task = task with { ShortDescription = await shortcodesService.ApplyShortcodesAsync(task.ShortDescription, templateTask.Template!) }; - task = task with { Solution = NormalizeLineEndingsToCrlf(await shortcodesService.ApplyShortcodesAsync(task.Solution, templateTask.Template!)) }; - task = task with { TnkName = await shortcodesService.ApplyShortcodesAsync(task.TnkName, templateTask.Template!) }; - task = task with { WorkName = await shortcodesService.ApplyShortcodesAsync(task.WorkName, templateTask.Template!) }; - task = task with { WorkGroup = await shortcodesService.ApplyShortcodesAsync(task.WorkGroup, templateTask.Template!) }; - task = task with { ResponseArea = await shortcodesService.ApplyShortcodesAsync(task.ResponseArea, templateTask.Template!) }; + task = task with { FullDescription = NormalizeLineEndingsToCrlf(await _shortcodesService.ApplyShortcodesAsync(task.FullDescription, templateTask.Template!)) }; + task = task with { ShortDescription = await _shortcodesService.ApplyShortcodesAsync(task.ShortDescription, templateTask.Template!) }; + task = task with { Solution = NormalizeLineEndingsToCrlf(await _shortcodesService.ApplyShortcodesAsync(task.Solution, templateTask.Template!)) }; + task = task with { TnkName = await _shortcodesService.ApplyShortcodesAsync(task.TnkName, templateTask.Template!) }; + task = task with { WorkName = await _shortcodesService.ApplyShortcodesAsync(task.WorkName, templateTask.Template!) }; + task = task with { WorkGroup = await _shortcodesService.ApplyShortcodesAsync(task.WorkGroup, templateTask.Template!) }; + task = task with { ResponseArea = await _shortcodesService.ApplyShortcodesAsync(task.ResponseArea, templateTask.Template!) }; - task = task with { ClosingCode = settingsFromDb.ClosingCode }; - task = task with { Initiator = settingsFromDb.Initiator }; - task = task with { Category = settingsFromDb.Category }; + task = task with { ClosingCode = _settingsFromDb.ClosingCode }; + task = task with { Initiator = _settingsFromDb.Initiator }; + task = task with { Category = _settingsFromDb.Category }; return task; } @@ -82,22 +90,22 @@ namespace PARR.Core.Services.RobotTask.Implementations var resultUpdateNextRun = await UpdateNextRunAsync(scheduleTask, historyInitiator); if (!resultUpdateNextRun) { - logger.LogError("Ошибка при расчете NextRun для templateId: {templateId}", scheduleTask.TemplateId); + _logger.LogError("Ошибка при расчете NextRun для templateId: {templateId}", scheduleTask.TemplateId); throw new NextRunException($"Ошибка при расчете NextRun для templateId: {scheduleTask.TemplateId}"); } - var task = mapper.Map(scheduleTask); + var task = _mapper.Map(scheduleTask); - task = task with { Timezone = settingsFromDb.EsppScheduleTimezone }; - task = task with { WorkGroup = await shortcodesService.ApplyShortcodesAsync(task.WorkGroup, scheduleTask.Template!) }; - task = task with { ResponseArea = await shortcodesService.ApplyShortcodesAsync(task.ResponseArea, scheduleTask.Template!) }; + task = task with { Timezone = _settingsFromDb.EsppScheduleTimezone }; + task = task with { WorkGroup = await _shortcodesService.ApplyShortcodesAsync(task.WorkGroup, scheduleTask.Template!) }; + task = task with { ResponseArea = await _shortcodesService.ApplyShortcodesAsync(task.ResponseArea, scheduleTask.Template!) }; //nextRun в часовой зоне УЗ Робота ЕСПП - var nextRunWithRobotTz = scheduleTask.Template!.NextRun.Add(nextRunService.GetEsppAccountOffset()); + var nextRunWithRobotTz = scheduleTask.Template!.NextRun.Add(_nextRunService.GetEsppAccountOffset()); //на всякий случай еще раз проверяем, что дата не устарела и отправляем задание if (nextRunWithRobotTz < DateTimeOffset.UtcNow) { - logger.LogError("Ошибка при расчете NextRun для templateId: {templateId}, итоговое значение для робота, меньше чем сейчас {nextRunWithRobotTz}<{now}", + _logger.LogError("Ошибка при расчете NextRun для templateId: {templateId}, итоговое значение для робота, меньше чем сейчас {nextRunWithRobotTz}<{now}", task.TemplateId, nextRunWithRobotTz, DateTimeOffset.UtcNow); throw new NextRunException($"Ошибка при расчете NextRun для templateId: {scheduleTask.TemplateId}"); } @@ -105,7 +113,7 @@ namespace PARR.Core.Services.RobotTask.Implementations task = task with { NextStart = EsppScheduleHelpers.GetNextRun(nextRunWithRobotTz) }; task = task with { GenerationTime = EsppScheduleHelpers.GetGenerationTime(nextRunWithRobotTz) }; - task = task with { RepeatRange = settingsFromDb.ScheduleRepeatRange }; + task = task with { RepeatRange = _settingsFromDb.ScheduleRepeatRange }; task = task with { }; return task; @@ -125,7 +133,7 @@ namespace PARR.Core.Services.RobotTask.Implementations private async Task GetTaskAsync(RobotsEnum robotCode, TaskStatusEnum taskStatusCode, bool acquireTask, string? robotIp, string? robotId, TimeSpan scheduleCooldownDuration) { // 1. Ищем все задания с превышенным кол-вом попыток и просроченным временем, ставим им статус ошибки - await robotConfigurationRepository.MarkExpiredTasksAsFailedAsync(settingsFromDb.RobotAttemptsNumber, settingsFromDb.RobotWaitTime); + await _robotConfigurationRepository.MarkExpiredTasksAsFailedAsync(_settingsFromDb.RobotAttemptsNumber, _settingsFromDb.RobotWaitTime); // 2. Ищем доступные задания @@ -148,7 +156,7 @@ namespace PARR.Core.Services.RobotTask.Implementations { // Берем первую задачу из списка доступных acquiredTaskId = availableTasks.First(); - logger.LogDebug("Задача не требует захвата, взята первая из доступных: {TaskId}", acquiredTaskId); + _logger.LogDebug("Задача не требует захвата, взята первая из доступных: {TaskId}", acquiredTaskId); } @@ -168,20 +176,14 @@ namespace PARR.Core.Services.RobotTask.Implementations /// private async Task> GetAvailableTasksAsync(RobotsEnum robotCode, TaskStatusEnum taskStatusCode, TimeSpan scheduleCooldownDuration) { - var query = robotConfigurationRepository.Get() + var query = _robotConfigurationRepository.Get() .AsNoTracking() - .Where(t => t.RobotCode == (int)robotCode/* && t.TaskStatusCode == (int)taskStatusCode*/); + .Where(t => t.RobotCode == (int)robotCode); // Если это задание для робота расписаний if (robotCode == RobotsEnum.ScheduleOrder) { // Выбираем только записи с созданными шаблонами (у которых статус 30), а только потом ищем у них расписания - #region Старый не оптимизированный запрос - //var createdTemplates = robotConfigurationRepository.Get() - // .Where(t => t.RobotCode == (int)RobotsEnum.TemplateOrder && t.TaskStatusCode == (int)TaskStatusEnum.Ok) - // .Select(t => t.TemplateId); - //query = query.Where(t => createdTemplates.Contains(t.TemplateId)); - #endregion query = query.Where(t => t.Template!.RobotConfigurations.Any(x => x.RobotCode == (int)RobotsEnum.TemplateOrder && x.TaskStatusCode == (int)TaskStatusEnum.Ok)); @@ -200,20 +202,22 @@ namespace PARR.Core.Services.RobotTask.Implementations // Сортируем по nextRun, чтобы те, у кого nextRun ближе к текущей, выполнились скорее query = query.OrderBy(t => t.Template!.NextRun).ThenBy(t => t.Template!.IsActiveSchedule).ThenBy(t => t.Template!.IsActiveTemplate); - // Кандидаты заданий - var tasks = new List(); + // Кандидаты заданий, Id задания и имя шаблона + //var tasks = new List(); + var tasks = new List(); - // Ещем первые 10 заданий в статусе ОЖИДАНИЕ + // Ищем первые TakeTasks заданий в статусе ОЖИДАНИЕ tasks = await query .Where(t => t.RobotStatusCode == (int)RobotStatusEnum.Wait && t.TaskStatusCode == (int)taskStatusCode ).Take(TakeTasks) - .Select(t => t.Id) + //.Select(t => t.Id) + .Select(t => new RobotTaskDetails(t.Id, t.Template!.Name, t.Template.NextRun)) .ToListAsync(); - logger.LogDebug("Найдено заданий в статусе 'Ожидание' {Count} шт. Робот '{Robot}'", tasks.Count, robotCode.ToString()); + _logger.LogDebug("Найдено заданий в статусе 'Ожидание' {Count} шт. Робот '{Robot}'", tasks.Count, robotCode.ToString()); if (tasks.Count == 0) { @@ -222,20 +226,171 @@ namespace PARR.Core.Services.RobotTask.Implementations // Далее проверяется `LastStatusUpdated`, что время последнего смены статуса не превышает допустимого(берется из настроек, поле `RobotWaitTime`) // и что текущая попытка не больше разрешенной(берется из настроек, поле `RobotAttemptsNumber`) - если это так, берется эта запись. - var endDate = DateTimeOffset.UtcNow.Add(-settingsFromDb.RobotWaitTime); + var endDate = DateTimeOffset.UtcNow.Add(-_settingsFromDb.RobotWaitTime); tasks = await query.Where(t => t.RobotStatusCode == (int)RobotStatusEnum.InProgress - && t.TaskStatusCode==(int)taskStatusCode - && t.AttemptsNumber < settingsFromDb.RobotAttemptsNumber + && t.TaskStatusCode == (int)taskStatusCode + && t.AttemptsNumber < _settingsFromDb.RobotAttemptsNumber && t.LastRobotStatusUpdated < endDate) .Take(TakeTasks) - .Select(t => t.Id) + //.Select(t => t.Id) + .Select(t => new RobotTaskDetails(t.Id, t.Template!.Name, t.Template.NextRun)) .ToListAsync(); - logger.LogDebug("Найдено заданий в статусе 'В работе' {Count} шт. Робот '{Robot}'", tasks.Count, robotCode.ToString()); + _logger.LogDebug("Найдено заданий в статусе 'В работе' {Count} шт. Робот '{Robot}'", tasks.Count, robotCode.ToString()); } - return tasks; + if (robotCode == RobotsEnum.TemplateOrder) + { + // Если запрашиваем шаблоны, смотрим корректируем список заданий в зависимости от статуса переименования. + // Это не относится к расписаниям, потому что у переименованных расписаний статус Updating, а оно не возьмется в работу, пока не обновится шаблон + tasks = await ReplaceTemplateTasksForRenameAsync(tasks, robotCode); + } + + return tasks.Select(t => t.TaskId).ToList(); + } + + + /// + /// Проверяет наличие шаблонов в процессе переименования и заменяет обычные задания на задания по переименованию. + /// Если связанный шаблон не переименован, и у него статус ошибки, целевому шаблону устанавливается статус ошибки. + /// + /// + /// + private async Task> ReplaceTemplateTasksForRenameAsync(List tasks, RobotsEnum robotCode) + { + if (tasks.Count == 0 || robotCode != RobotsEnum.TemplateOrder) + return tasks; + + + // Ищем есть ли связанные шаблоны с таким имененм на переименование + var taskTemplateNames = tasks.Select(t => t.TemplateName); + var templatesToRename = await _templateRenamePendingRepository.Get().AsNoTracking() + .Where(t => taskTemplateNames.Contains(t.OldName)) + .ToListAsync(); + + _logger.LogDebug("Шаблонов для переименования в текущем задании: {Count} шт.", templatesToRename.Count); + + if (templatesToRename.Count == 0) + return tasks; + + // Ищем связанные переименованные шаблоны по ИД, смотрим можем ли взять их в работу + var renameTemplateIds = templatesToRename.Select(t => t.TemplateId).ToList(); + var renameTasks = await _robotConfigurationRepository.Get() + .AsNoTracking() + .Include(t => t.Template) + .Where(t => + t.RobotCode == (int)robotCode + && renameTemplateIds.Contains(t.TemplateId) + // Это может быть только обновление. Так как переименования для создаваемого шаблона быть не может + && t.TaskStatusCode == (int)TaskStatusEnum.Updating + ).ToListAsync(); + + // Ищем связанные задания которые в ошибке, и ставим целевому шаблону задание в ошибку + var errorTasks = renameTasks.Where(t => t.RobotStatusCode == (int)RobotStatusEnum.Error && t.AttemptsNumber >= _settingsFromDb.RobotAttemptsNumber).ToList(); + + var tasksToSetErrorStatus = new List(); + if (errorTasks.Count > 0) + { + _logger.LogDebug("Найдено связанных заданий на переименование с ошибками: {ErrorCount}. Будем целевым шаблонам тоже ставить статус ошибки.", errorTasks.Count); + + var errorTemplateNames = errorTasks.Select(t => t.Template!.Name).ToList(); + // Берем целевые таски, находим в них задания которым надо поставить ошибку + tasksToSetErrorStatus = tasks.Where(t => errorTemplateNames.Contains(t.TemplateName)).Select(t => t.TaskId).ToList(); + + // Устанавливаем ошибку целевым + пишем комментарий от робота + нажимаем комит + var logMessage = "[RobotTaskService] Установлен статус ошибки, так как не переименован связанный шаблон"; + await SetErrorStatusAsync(tasksToSetErrorStatus, logMessage); + } + + var endDate = DateTimeOffset.UtcNow.Add(-_settingsFromDb.RobotWaitTime); + // Смотрим статусы роботов, можно взять в работу, только если (RobotStatus == Wait) или (InpRogress но которые еще не просрочены) + var allowedTasks = renameTasks.Where(t => + t.RobotStatusCode == (int)RobotStatusEnum.Wait + || (t.RobotStatusCode == (int)RobotStatusEnum.InProgress && t.AttemptsNumber < _settingsFromDb.RobotAttemptsNumber && t.LastRobotStatusUpdated < endDate) + ); + + // Формируем список заданий + + var originalCount = tasks.Count; // Запоминаем сколько было изначально + + // Из исходных тасков удалить те которым установлен статус ошибки + var filteredOriginalTasks = tasks.Where(t => !tasksToSetErrorStatus.Contains(t.TaskId)).ToList(); + var errorCount = tasksToSetErrorStatus.Count; // Столько ушло в ошибку + + // Определяем, какие имена шаблонов мы БУДЕМ подменять на задачи переименования + var allowedRenameTemplateNames = allowedTasks.Select(t => t.Template!.Name).ToList(); + + // Из исходных удаляем те, которые мы сейчас заменим (подменим) + var resultsTasks = filteredOriginalTasks.Where(t => !allowedRenameTemplateNames.Contains(t.TemplateName)).ToList(); + + // Считаем сколько именно задач мы ВЫКИНУЛИ из исходного списка ради подмены + var replacedCount = filteredOriginalTasks.Count - resultsTasks.Count; + + // В исходные добавляем подменные таски для переименования (мапим их в RobotTaskDetails) + var mappedRenameTasks = allowedTasks.Select(t => new RobotTaskDetails(t.Id, t.Template!.Name, t.Template.NextRun)).ToList(); + resultsTasks.AddRange(mappedRenameTasks); + + var injectedCount = mappedRenameTasks.Count; // Столько задач переименования добавили взамен + + // Логируем итоговую статистику трансформации пула задач + // TODO: Позже этот лог можно понизить до Debug!!! + _logger.LogInformation( + "Трансформация пула задач завершена. Исходных: {OriginalCount} шт. " + + "Отклонено (ошибка): {ErrorCount} шт. Удалено обычных для подмены: {ReplacedCount} шт. " + + "Внедрено задач переименования: {InjectedCount} шт. Итого к выдаче: {FinalCount} шт.", + originalCount, errorCount, replacedCount, injectedCount, resultsTasks.Count); + + // Затем отсортируем по NextRun, чтоб ближайшие были выше + return resultsTasks.OrderBy(t => t.NextRun).ToList(); + } + + + /// + /// Установить статус задания - ошибка + /// + /// + /// + private async Task SetErrorStatusAsync(List taskIds, string logMessage) + { + var tasks = await _robotConfigurationRepository.Get() + .Include(t => t.Template) + .Where(t => taskIds.Contains(t.Id)).ToListAsync(); + + if (tasks.Count == 0) + return; + + foreach (var task in tasks) + { + // Так как это целевой шаблон, то ставим ему сразу максимальное кол-во попыток и ошибку, чтоб больше он не выдавался в заданиях, пока не исправим связанный + // Устанавливаем статус ошибки + _robotConfigurationRepository.SetErrorRobotStatusAndMaxAttempts(task); + + // Пишем в лог роботу + var history = new RobotHistory + { + Id = Guid.NewGuid(), + HistoryLevel = (int)RobotStatusEnum.Error, + TaskStatusCode = task.TaskStatusCode, + RobotConfigurationId = task.Id, + RobotIp = null, + RobotId = ParrComponentsEnum.Api.ToString(), + RobotMessage = logMessage + }; + + await _robotHistoryRepository.CreateAsync(history); + + _logger.LogInformation("Для целевого задания {TaskId}, по переименованию шаблона в {TemplateName}, установлен статус ошибки, так как связанное задание со старым шаблоном со статусом ошибка.", task.Id, task.Template!.Name); + } + + if (await _robotHistoryRepository.CommitAsync()) + { + _logger.LogDebug("Установлен статус Ошибка, для заданий {TaskCount} шт.", tasks.Count); + } + else + { + _logger.LogError("Ошибка при установке статуса задания Ошибка, для заданий {TaskCount} шт.", tasks.Count); + } } @@ -248,12 +403,12 @@ namespace PARR.Core.Services.RobotTask.Implementations { foreach (var taskId in tasks) { - var isChangedStatus = await robotConfigurationRepository.SetInProgressStatusAsync(taskId); + var isChangedStatus = await _robotConfigurationRepository.SetInProgressStatusAsync(taskId); if (isChangedStatus) { - logger.LogDebug("Захвачена задача {TaskId}", taskId); + _logger.LogDebug("Захвачена задача {TaskId}", taskId); - var task = await robotConfigurationRepository.Get() + var task = await _robotConfigurationRepository.Get() .AsNoTracking() .FirstAsync(t => t.Id == taskId); @@ -268,18 +423,18 @@ namespace PARR.Core.Services.RobotTask.Implementations RobotId = robotId }; - if (!await robotHistoryRepository.CreateAsync(history) || !await robotHistoryRepository.CommitAsync()) + if (!await _robotHistoryRepository.CreateAsync(history) || !await _robotHistoryRepository.CommitAsync()) throw new DbErrorException("Ошибка при добавлении истории робота, при взятии задания в работу."); return taskId; } else { - logger.LogDebug("Не удалось захватить задачу {TaskId}", taskId); + _logger.LogDebug("Не удалось захватить задачу {TaskId}", taskId); } } - logger.LogDebug("Не удалось захватить ни одну из доступных задач для робота"); + _logger.LogDebug("Не удалось захватить ни одну из доступных задач для робота"); return null; } @@ -293,7 +448,7 @@ namespace PARR.Core.Services.RobotTask.Implementations /// private async Task GetTaskWithAllDataAsync(Guid taskId, RobotsEnum robotCode) { - IQueryable query = robotConfigurationRepository.Get() + IQueryable query = _robotConfigurationRepository.Get() //.AsNoTracking() // нужно обязательно трекать, так как может измениться nextRun и его нужно будет сохранить .AsSingleQuery() // Общие инклуды для шаблонов и расписаний @@ -372,23 +527,23 @@ namespace PARR.Core.Services.RobotTask.Implementations var template = task.Template!; //var nextRun = await esppScheduleTransformService.GetNextDateAsync(template.Job!.GroupId, template!.Job!.Group!.ReferenceDate); - var nextRun = await nextRunService.GetNextRunForTemplateAsync(template.Id, false); + var nextRun = await _nextRunService.GetNextRunForTemplateAsync(template.Id, false); if (!nextRun.HasValue) { - logger.LogError("При обновлении nextRun для шаблона {templateId}, расчитанный nextRun=null, ошибка в расчетах.", template.Id); + _logger.LogError("При обновлении nextRun для шаблона {templateId}, расчитанный nextRun=null, ошибка в расчетах.", template.Id); return false; } if (nextRun.Value < DateTimeOffset.UtcNow) { - logger.LogError("При обновлении nextRun для шаблона {templateId}, расчитанный nextRun + /// Модель задания для робота + /// + /// + /// + internal record RobotTaskDetails(Guid TaskId, string TemplateName, DateTimeOffset NextRun); +} diff --git a/PARR.DAL/Repositories/RobotConfigurationRepository.cs b/PARR.DAL/Repositories/RobotConfigurationRepository.cs index efbb22be..ba4909ed 100644 --- a/PARR.DAL/Repositories/RobotConfigurationRepository.cs +++ b/PARR.DAL/Repositories/RobotConfigurationRepository.cs @@ -1,9 +1,11 @@ -using Microsoft.EntityFrameworkCore; +using InfluxDB.Client.Api.Domain; +using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Logging; using PARR.Core.Repositories.Interfaces; using PARR.DAL.Context; using PARR.DAL.Repositories.Base; using PARR.Domain.Entities; +using PARR.Domain.Entities.RobotEntities; using PARR.Domain.Enums; using PARR.Domain.Settings; @@ -94,8 +96,8 @@ namespace PARR.DAL.Repositories configuration.AttemptsNumber++; configuration.LastRobotStatusUpdated = DateTimeOffset.UtcNow; break; - //case RobotStatusEnum.Error: - // break; + case RobotStatusEnum.Error: + break; case RobotStatusEnum.Complete: configuration.LastRobotStatusUpdated = DateTimeOffset.UtcNow; break; @@ -108,6 +110,14 @@ namespace PARR.DAL.Repositories } } + public void SetErrorRobotStatusAndMaxAttempts(RobotConfiguration configuration) + { + ChangeRobotStatus(RobotStatusEnum.Error, configuration); + + configuration.AttemptsNumber = settingsFromDb.RobotAttemptsNumber; + configuration.LastRobotStatusUpdated = DateTimeOffset.UtcNow; + } + public async Task SetInProgressStatusAsync(Guid id) { @@ -175,10 +185,55 @@ namespace PARR.DAL.Repositories logger.LogInformation($"Устанавливаю RobotStatus: {RobotStatusEnum.Error} для RobotConfigurationId {item.Id}"); }); + #region Ищем, есть ли связанные шаблоны, которые должны переименоваться, им тоже нужно установить статус ошибки, но только для Шаблонов + + var linksCount = 0; + + var templateIds = configObjs.Where(t => t.RobotCode == (int)RobotsEnum.TemplateOrder).Select(t => t.TemplateId).ToList(); + if (templateIds.Any()) + { + // По этим именам находим целевые шаблоны, берем их задания, и ставим им статус Ошибка + записать в лог робота + var configs = await EntitySet + .Where(t => t.RobotCode == (int)RobotsEnum.TemplateOrder + && t.RobotStatusCode != (int)RobotStatusEnum.Error + && EntityContext.Templates.Any(tmpl => + templateIds.Contains(tmpl.Id) + && tmpl.TemplateRenamePending != null + && tmpl.TemplateRenamePending.OldName == t.Template!.Name)) + .ToListAsync(); + + linksCount = configs.Count; + + foreach (var item in configs) + { + SetErrorRobotStatusAndMaxAttempts(item); + + // Пишем в лог роботу + var history = new RobotHistory + { + Id = Guid.NewGuid(), + HistoryLevel = (int)RobotStatusEnum.Error, + TaskStatusCode = item.TaskStatusCode, + RobotConfigurationId = item.Id, + RobotIp = null, + RobotId = ParrComponentsEnum.Api.ToString(), + RobotMessage = "[RobotConfigurationRepository] Установлен статус ошибки, так как не переименован связанный шаблон" + }; + + // Синхронный Add работает быстрее и безопаснее внутри цикла + EntityContext.RobotHistories.Add(history); + + logger.LogInformation($"Устанавливаю RobotStatus: {RobotStatusEnum.Error} для RobotConfigurationId {item.Id}"); + } + } + #endregion + var result = await CommitAsync(); if (!result) - logger.LogError($"Ошибка при сохранении изменений RobotStatus для RobotConfigurationId: item.Id, RobotStatus: {RobotStatusEnum.Error}"); + logger.LogError("Ошибка при сохранении изменений RobotStatus для просроченных заданий в количестве {Count} шт.", configObjs.Count + linksCount); + //else + // logger.LogInformation("Успешно обработано и переведено в статус Ошибки просроченных заданий: {Count} шт.", configObjs.Count + linksCount); } From 58b4d98b16b7991e2b99646eadc0145e4b9533d9 Mon Sep 17 00:00:00 2001 From: Mikhail Trubnikov Date: Thu, 23 Jul 2026 10:48:59 +1000 Subject: [PATCH 3/6] =?UTF-8?q?feat(dal,core):=20=D0=A0=D0=B5=D1=84=D0=B0?= =?UTF-8?q?=D0=BA=D1=82=D0=BE=D1=80=D0=B8=D0=BD=D0=B3=20=D0=BC=D0=B5=D1=82?= =?UTF-8?q?=D0=BE=D0=B4=D0=BE=D0=B2=20=D0=B8=20=D0=BB=D0=BE=D0=B3=D0=B8?= =?UTF-8?q?=D0=BA=D0=B8=20=D0=B2=D1=8B=D0=B4=D0=B0=D1=87=D0=B8=20=D0=B7?= =?UTF-8?q?=D0=B0=D0=B4=D0=B0=D0=BD=D0=B8=D0=B9=20=D1=80=D0=BE=D0=B1=D0=BE?= =?UTF-8?q?=D1=82=D0=BE=D0=BC=20=D0=BF=D1=80=D0=B8=20=D0=BF=D0=B5=D1=80?= =?UTF-8?q?=D0=B5=D0=B8=D0=BC=D0=B5=D0=BD=D0=BE=D0=B2=D0=B0=D0=BD=D0=B8?= =?UTF-8?q?=D0=B8=20=D1=88=D0=B0=D0=B1=D0=BB=D0=BE=D0=BD=D0=BE=D0=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Implementations/RobotTaskService.cs | 148 +++++++++++------- PARR.DAL/Repositories/Base/BaseRepository.cs | 74 ++++----- .../RobotConfigurationRepository.cs | 92 ++++++----- PARR.DAL/Repositories/TemplateRepository.cs | 20 +-- PARR.DAL/Repositories/WeekendDayRepository.cs | 2 +- 5 files changed, 193 insertions(+), 143 deletions(-) diff --git a/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs b/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs index 3757b276..e44c506a 100644 --- a/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs +++ b/PARR.Core/Services/RobotTask/Implementations/RobotTaskService.cs @@ -48,13 +48,13 @@ namespace PARR.Core.Services.RobotTask.Implementations ITemplateRenamePendingRepository templateRenamePendingRepository ) { - this._logger = logger; - this._robotConfigurationRepository = robotConfigurationRepository; - this._settingsFromDb = settingsFromDb; - this._robotHistoryRepository = robotHistoryRepository; - this._mapper = mapper; - this._shortcodesService = shortcodesService; - this._nextRunService = nextRunService; + _logger = logger; + _robotConfigurationRepository = robotConfigurationRepository; + _settingsFromDb = settingsFromDb; + _robotHistoryRepository = robotHistoryRepository; + _mapper = mapper; + _shortcodesService = shortcodesService; + _nextRunService = nextRunService; _templateRenamePendingRepository = templateRenamePendingRepository; } @@ -264,17 +264,18 @@ namespace PARR.Core.Services.RobotTask.Implementations // Ищем есть ли связанные шаблоны с таким имененм на переименование - var taskTemplateNames = tasks.Select(t => t.TemplateName); + var taskTemplateNames = tasks.Select(t => t.TemplateName).Distinct().ToList(); + // Ищем записи в таблице переименований, где OldName совпадает с именами наших новых задач var templatesToRename = await _templateRenamePendingRepository.Get().AsNoTracking() .Where(t => taskTemplateNames.Contains(t.OldName)) .ToListAsync(); - _logger.LogDebug("Шаблонов для переименования в текущем задании: {Count} шт.", templatesToRename.Count); + _logger.LogDebug("Найдено шаблонов в процессе переименования для текущих задач: {Count} шт.", templatesToRename.Count); if (templatesToRename.Count == 0) return tasks; - // Ищем связанные переименованные шаблоны по ИД, смотрим можем ли взять их в работу + // Ищем конфигурации роботов для СТАРЫХ шаблонов (которые переименовываются) по ИД, смотрим, можем ли взять их в работу var renameTemplateIds = templatesToRename.Select(t => t.TemplateId).ToList(); var renameTasks = await _robotConfigurationRepository.Get() .AsNoTracking() @@ -286,63 +287,93 @@ namespace PARR.Core.Services.RobotTask.Implementations && t.TaskStatusCode == (int)TaskStatusEnum.Updating ).ToListAsync(); - // Ищем связанные задания которые в ошибке, и ставим целевому шаблону задание в ошибку - var errorTasks = renameTasks.Where(t => t.RobotStatusCode == (int)RobotStatusEnum.Error && t.AttemptsNumber >= _settingsFromDb.RobotAttemptsNumber).ToList(); + // --- Блок обработки ошибок --- + + // Если старый шаблон в ошибке и лимит попыток исчерпан, ставим ошибку и новому шаблону + var errorTasks = renameTasks + .Where(t => + t.RobotStatusCode == (int)RobotStatusEnum.Error + && t.AttemptsNumber >= _settingsFromDb.RobotAttemptsNumber + ).ToList(); var tasksToSetErrorStatus = new List(); if (errorTasks.Count > 0) { - _logger.LogDebug("Найдено связанных заданий на переименование с ошибками: {ErrorCount}. Будем целевым шаблонам тоже ставить статус ошибки.", errorTasks.Count); + _logger.LogDebug("Найдено старых заданий на переименование с ошибками: {ErrorCount}. Ставим ошибку целевым (новым) заданиям.", errorTasks.Count); - var errorTemplateNames = errorTasks.Select(t => t.Template!.Name).ToList(); + var errorTemplateNames = errorTasks.Select(t => t.Template!.Name).ToHashSet(); // Берем целевые таски, находим в них задания которым надо поставить ошибку - tasksToSetErrorStatus = tasks.Where(t => errorTemplateNames.Contains(t.TemplateName)).Select(t => t.TaskId).ToList(); + tasksToSetErrorStatus = tasks + .Where(t => errorTemplateNames.Contains(t.TemplateName)) + .Select(t => t.TaskId) + .ToList(); - // Устанавливаем ошибку целевым + пишем комментарий от робота + нажимаем комит - var logMessage = "[RobotTaskService] Установлен статус ошибки, так как не переименован связанный шаблон"; - await SetErrorStatusAsync(tasksToSetErrorStatus, logMessage); + if (tasksToSetErrorStatus.Count > 0) + { + // Устанавливаем ошибку целевым + пишем комментарий от робота + нажимаем комит + var logMessage = "[RobotTaskService] Установлен статус ошибки, так как не переименован связанный шаблон"; + await SetErrorStatusAsync(tasksToSetErrorStatus, logMessage); + } } + // --- Блок подмены задач --- + var endDate = DateTimeOffset.UtcNow.Add(-_settingsFromDb.RobotWaitTime); - // Смотрим статусы роботов, можно взять в работу, только если (RobotStatus == Wait) или (InpRogress но которые еще не просрочены) - var allowedTasks = renameTasks.Where(t => + + // Фильтруем старые задачи, которые МОЖНО взять в работу. Смотрим статусы роботов, можно взять в работу, только если (RobotStatus == Wait) или (InpRogress но которые еще не просрочены) + var allowedRenameTasks = renameTasks.Where(t => t.RobotStatusCode == (int)RobotStatusEnum.Wait - || (t.RobotStatusCode == (int)RobotStatusEnum.InProgress && t.AttemptsNumber < _settingsFromDb.RobotAttemptsNumber && t.LastRobotStatusUpdated < endDate) - ); + || (t.RobotStatusCode == (int)RobotStatusEnum.InProgress + && t.AttemptsNumber < _settingsFromDb.RobotAttemptsNumber + && t.LastRobotStatusUpdated < endDate) + ).ToList(); - // Формируем список заданий + // Словарь для поиска подменной задачи по имени шаблона. + // GroupBy + First на случай, если в бд есть дубликаты, но такого быть не может + var renameTasksToDictionary = allowedRenameTasks + .GroupBy(t => t.Template!.Name) + .ToDictionary( + t => t.Key, + t => new RobotTaskDetails(t.First().Id, t.First().Template!.Name, t.First().Template!.NextRun) + ); - var originalCount = tasks.Count; // Запоминаем сколько было изначально + var errorTaskIdsSet = tasksToSetErrorStatus.ToHashSet(); - // Из исходных тасков удалить те которым установлен статус ошибки - var filteredOriginalTasks = tasks.Where(t => !tasksToSetErrorStatus.Contains(t.TaskId)).ToList(); - var errorCount = tasksToSetErrorStatus.Count; // Столько ушло в ошибку + // Создаем итоговый список + var finalTasks = new List(tasks.Count); + int replacedCount = 0; + int errorCount = errorTaskIdsSet.Count; - // Определяем, какие имена шаблонов мы БУДЕМ подменять на задачи переименования - var allowedRenameTemplateNames = allowedTasks.Select(t => t.Template!.Name).ToList(); + // Проходим по ИСХОДНОМУ списку, чтобы сохранить его порядок сортировки + foreach (var task in tasks) + { + // Если задаче нужно поставить ошибку, просто пропускаем ее (она не попадет в итоговый список) + if (errorTaskIdsSet.Contains(task.TaskId)) + { + continue; + } - // Из исходных удаляем те, которые мы сейчас заменим (подменим) - var resultsTasks = filteredOriginalTasks.Where(t => !allowedRenameTemplateNames.Contains(t.TemplateName)).ToList(); + // Если для этого имени шаблона есть разрешенная задача на переименование - вставляем ее на место текущей + if (renameTasksToDictionary.TryGetValue(task.TemplateName, out var renameTask)) + { + finalTasks.Add(renameTask); + replacedCount++; + } + else + { + // Иначе оставляем исходную задачу на месте + finalTasks.Add(task); + } + } - // Считаем сколько именно задач мы ВЫКИНУЛИ из исходного списка ради подмены - var replacedCount = filteredOriginalTasks.Count - resultsTasks.Count; - - // В исходные добавляем подменные таски для переименования (мапим их в RobotTaskDetails) - var mappedRenameTasks = allowedTasks.Select(t => new RobotTaskDetails(t.Id, t.Template!.Name, t.Template.NextRun)).ToList(); - resultsTasks.AddRange(mappedRenameTasks); - - var injectedCount = mappedRenameTasks.Count; // Столько задач переименования добавили взамен - - // Логируем итоговую статистику трансформации пула задач - // TODO: Позже этот лог можно понизить до Debug!!! _logger.LogInformation( - "Трансформация пула задач завершена. Исходных: {OriginalCount} шт. " + - "Отклонено (ошибка): {ErrorCount} шт. Удалено обычных для подмены: {ReplacedCount} шт. " + - "Внедрено задач переименования: {InjectedCount} шт. Итого к выдаче: {FinalCount} шт.", - originalCount, errorCount, replacedCount, injectedCount, resultsTasks.Count); + "Трансформация пула задач (Rename). Исходных: {OriginalCount}. Отклонено (Error): {ErrorCount}. " + + "Заменено на старые: {ReplacedCount}. Итого к выдаче: {FinalCount}", + tasks.Count, errorCount, replacedCount, finalTasks.Count + ); - // Затем отсортируем по NextRun, чтоб ближайшие были выше - return resultsTasks.OrderBy(t => t.NextRun).ToList(); + // Возвращаем без дополнительной сортировки по NextRun. Порядок сохранен начального списка + return finalTasks; } @@ -353,9 +384,13 @@ namespace PARR.Core.Services.RobotTask.Implementations /// private async Task SetErrorStatusAsync(List taskIds, string logMessage) { + if (taskIds == null || taskIds.Count == 0) + return; + var tasks = await _robotConfigurationRepository.Get() .Include(t => t.Template) - .Where(t => taskIds.Contains(t.Id)).ToListAsync(); + .Where(t => taskIds.Contains(t.Id)) + .ToListAsync(); if (tasks.Count == 0) return; @@ -380,16 +415,19 @@ namespace PARR.Core.Services.RobotTask.Implementations await _robotHistoryRepository.CreateAsync(history); - _logger.LogInformation("Для целевого задания {TaskId}, по переименованию шаблона в {TemplateName}, установлен статус ошибки, так как связанное задание со старым шаблоном со статусом ошибка.", task.Id, task.Template!.Name); + _logger.LogInformation("Для целевого задания {TaskId} (шаблон '{TemplateName}') установлен статус ошибки, " + + "так как связанное задание со старым шаблоном не было успешно выполнено.", + task.Id, task.Template!.Name); } if (await _robotHistoryRepository.CommitAsync()) { - _logger.LogDebug("Установлен статус Ошибка, для заданий {TaskCount} шт.", tasks.Count); + _logger.LogDebug("Установлен статус 'Ошибка', для заданий {TaskCount} шт.", tasks.Count); } else { - _logger.LogError("Ошибка при установке статуса задания Ошибка, для заданий {TaskCount} шт.", tasks.Count); + _logger.LogError("Ошибка при установке статуса задания 'Ошибка', для заданий {TaskCount} шт. Транзакция отменена", tasks.Count); + throw new DbErrorException("Не удалось сохранить изменения статусов заданий при обработке переименования шаблона."); } } @@ -531,19 +569,19 @@ namespace PARR.Core.Services.RobotTask.Implementations if (!nextRun.HasValue) { - _logger.LogError("При обновлении nextRun для шаблона {templateId}, расчитанный nextRun=null, ошибка в расчетах.", template.Id); + _logger.LogError("При обновлении nextRun для шаблона {TemplateId}, расчитанный nextRun=null, ошибка в расчетах.", template.Id); return false; } if (nextRun.Value < DateTimeOffset.UtcNow) { - _logger.LogError("При обновлении nextRun для шаблона {templateId}, расчитанный nextRun : IBaseRepository where T : class, IBaseEntity { - protected readonly ILogger logger; + protected readonly ILogger _logger; protected readonly DbSet EntitySet; protected readonly DataContext EntityContext; protected BaseRepository(ILogger logger, DataContext dataContext) { - this.logger = logger; + this._logger = logger; this.EntityContext = dataContext; this.EntitySet = dataContext.Set(); } @@ -29,7 +29,7 @@ namespace PARR.DAL.Repositories.Base public virtual async Task AddRangeAsync(List objs) { - logger.LogDebug("Начинаю добавление диапазона объектов типа {EntityType}, количество: {Count}", + _logger.LogDebug("Начинаю добавление диапазона объектов типа {EntityType}, количество: {Count}", typeof(T).Name, objs.Count); objs.ForEach(item => item.DateCreated = DateTimeOffset.UtcNow); @@ -37,26 +37,26 @@ namespace PARR.DAL.Repositories.Base try { await EntitySet.AddRangeAsync(objs); - logger.LogDebug("Успешно добавлено {Count} объектов типа {EntityType}", + _logger.LogDebug("Успешно добавлено {Count} объектов типа {EntityType}", objs.Count, typeof(T).Name); return true; } catch (Exception ex) { - logger.LogError(ex, "Ошибка при добавлении диапазона объектов типа {EntityType}", typeof(T).Name); + _logger.LogError(ex, "Ошибка при добавлении диапазона объектов типа {EntityType}", typeof(T).Name); return false; } } public async Task CommitAsync(IHistoryInitiator? initiator = null) { - logger.LogDebug("Начинаю сохранение изменений в БД для объектов типа {EntityType}", typeof(T).Name); + _logger.LogDebug("Начинаю сохранение изменений в БД для объектов типа {EntityType}", typeof(T).Name); #region Изменения var modifiedEntrities = EntityContext.ChangeTracker.Entries() .Where(t => t.State == EntityState.Modified/* || t.State == EntityState.Deleted*/); - logger.LogDebug("Найдено {Count} измененных сущностей для обработки истории", modifiedEntrities.Count()); + _logger.LogDebug("Найдено {Count} измененных сущностей для обработки истории", modifiedEntrities.Count()); foreach (var obj in modifiedEntrities) { @@ -73,13 +73,13 @@ namespace PARR.DAL.Repositories.Base try { var changedCount = await EntityContext.SaveChangesAsync(); - logger.LogDebug("Успешно сохранено {ChangedCount} изменений в БД для объектов типа {EntityType}", + _logger.LogDebug("Успешно сохранено {ChangedCount} изменений в БД для объектов типа {EntityType}", changedCount, typeof(T).Name); return true; } catch (Exception ex) { - logger.LogError(ex, "Ошибка при сохранении изменений в БД для объектов типа {EntityType}", typeof(T).Name); + _logger.LogError(ex, "Ошибка при сохранении изменений в БД для объектов типа {EntityType}", typeof(T).Name); return false; } } @@ -94,14 +94,14 @@ namespace PARR.DAL.Repositories.Base if (initiator == null) return; - logger.LogDebug("Устанавливаю инициатора для изменений"); + _logger.LogDebug("Устанавливаю инициатора для изменений"); // Задаем инициатора только для новых и измененных записей var entrities = EntityContext.ChangeTracker.Entries() .Where(t => t.State == EntityState.Modified || t.State == EntityState.Added); var entityCount = entrities.Count(); - logger.LogDebug("Найдено {Count} сущностей для установки инициатора", entityCount); + _logger.LogDebug("Найдено {Count} сущностей для установки инициатора", entityCount); // смотрим есть ли у объекта интерфейс IHistoryInitiator, если есть, задаём значения foreach (var obj in entrities) @@ -113,7 +113,7 @@ namespace PARR.DAL.Repositories.Base (obj.Entity as IHistoryInitiator)!.InitiatorParrComponentId = initiator?.InitiatorParrComponentId ?? null; (obj.Entity as IHistoryInitiator)!.InitiatorComment = initiator?.InitiatorComment ?? null; - logger.LogDebug("Установлен инициатор для сущности типа {EntityType}", obj.Entity.GetType().Name); + _logger.LogDebug("Установлен инициатор для сущности типа {EntityType}", obj.Entity.GetType().Name); } } } @@ -140,12 +140,12 @@ namespace PARR.DAL.Repositories.Base if (!isManual) { - logger.LogDebug("Обновляю DateModified для сущности типа {EntityType}", obj.Entity.GetType().Name); + _logger.LogDebug("Обновляю DateModified для сущности типа {EntityType}", obj.Entity.GetType().Name); entity.DateModified = DateTimeOffset.UtcNow; } else { - logger.LogDebug("Пропуск обновления DateModified (ManualControl) для {EntityType}", entityType.Name); + _logger.LogDebug("Пропуск обновления DateModified (ManualControl) для {EntityType}", entityType.Name); } } } @@ -156,7 +156,7 @@ namespace PARR.DAL.Repositories.Base /// private void TableHistoryResolver(EntityEntry obj) { - logger.LogDebug("Проверяю необходимость создания истории для сущности типа {EntityType}", obj.Entity.GetType().Name); + _logger.LogDebug("Проверяю необходимость создания истории для сущности типа {EntityType}", obj.Entity.GetType().Name); var myHistoryInterface = obj.Entity.GetType().GetInterfaces() .Where(t => t.IsGenericType) @@ -166,7 +166,7 @@ namespace PARR.DAL.Repositories.Base // у этого объекта нет интерфейса IMyHistory<>. Не ведем историю if (myHistoryInterface == null) { - logger.LogDebug("Сущность типа {EntityType} не требует ведения истории", obj.Entity.GetType().Name); + _logger.LogDebug("Сущность типа {EntityType} не требует ведения истории", obj.Entity.GetType().Name); return; } @@ -176,13 +176,13 @@ namespace PARR.DAL.Repositories.Base var historyType = myHistoryInterface.GetGenericArguments().First(); var historyProps = historyType.GetProperties(/*BindingFlags.DeclaredOnly | */ /*BindingFlags.Public*/).ToList(); - logger.LogDebug("Создаю историю для сущности типа {EntityType}, тип истории: {HistoryType}", + _logger.LogDebug("Создаю историю для сущности типа {EntityType}, тип истории: {HistoryType}", obj.Entity.GetType().Name, historyType.Name); var historyInstance = Activator.CreateInstance(historyType); if (historyInstance == null) { - logger.LogError("Не смог создать инстанс для ведения истории {HistoryType}", historyType.Name); + _logger.LogError("Не смог создать инстанс для ведения истории {HistoryType}", historyType.Name); return; } @@ -198,11 +198,11 @@ namespace PARR.DAL.Repositories.Base try { EntityContext.Add(historyInstance); - logger.LogDebug("История добавлена для сущности типа {EntityType}", obj.Entity.GetType().Name); + _logger.LogDebug("История добавлена для сущности типа {EntityType}", obj.Entity.GetType().Name); } catch (Exception ex) { - logger.LogError(ex, "Ошибка при добавлении объекта в историю {HistoryType}", historyType.Name); + _logger.LogError(ex, "Ошибка при добавлении объекта в историю {HistoryType}", historyType.Name); } } @@ -215,7 +215,7 @@ namespace PARR.DAL.Repositories.Base /// private void FillHistoryProps(EntityEntry originalObj, ref object historyInstance, List propsList) { - logger.LogDebug("Заполняю историю для сущности типа {EntityType}", originalObj.Entity.GetType().Name); + _logger.LogDebug("Заполняю историю для сущности типа {EntityType}", originalObj.Entity.GetType().Name); foreach (var prop in propsList) { @@ -240,7 +240,7 @@ namespace PARR.DAL.Repositories.Base histProp.SetValue(historyInstance, origValues); } - logger.LogDebug("Завершено заполнение истории для сущности типа {EntityType}", originalObj.Entity.GetType().Name); + _logger.LogDebug("Завершено заполнение истории для сущности типа {EntityType}", originalObj.Entity.GetType().Name); } @@ -256,14 +256,14 @@ namespace PARR.DAL.Repositories.Base var histProp = instanceObj.GetType().GetProperty(propName); if (histProp == null) { - logger.LogError("При изменении объекта для БД, не найдено свойство {PropertyName}", propName); + _logger.LogError("При изменении объекта для БД, не найдено свойство {PropertyName}", propName); return; } // сравним типы if (histProp.PropertyType != typeof(TValue)) { - logger.LogError("При изменении объекта для БД, не совпадают типы у свойства {PropertyName}, {PropertyType}!={ValueType}", + _logger.LogError("При изменении объекта для БД, не совпадают типы у свойства {PropertyName}, {PropertyType}!={ValueType}", propName, histProp.PropertyType.Name, typeof(TValue).Name); return; } @@ -330,7 +330,7 @@ namespace PARR.DAL.Repositories.Base public virtual async Task CreateAsync(T obj) { - logger.LogDebug("Начинаю создание объекта типа {EntityType}", typeof(T).Name); + _logger.LogDebug("Начинаю создание объекта типа {EntityType}", typeof(T).Name); if (obj.DateCreated == DateTimeOffset.MinValue) obj.DateCreated = DateTimeOffset.UtcNow; @@ -338,73 +338,73 @@ namespace PARR.DAL.Repositories.Base try { await EntitySet.AddAsync(obj); - logger.LogDebug("Объект типа {EntityType} добавлен в контекст", typeof(T).Name); + _logger.LogDebug("Объект типа {EntityType} добавлен в контекст", typeof(T).Name); return true; } catch (Exception ex) { - logger.LogError(ex, "Ошибка при добавлении объекта типа {EntityType} в БД", typeof(T).Name); + _logger.LogError(ex, "Ошибка при добавлении объекта типа {EntityType} в БД", typeof(T).Name); return false; } } public virtual bool Delete(T obj) { - logger.LogDebug("Начинаю удаление объекта типа {EntityType}", obj.GetType().Name); + _logger.LogDebug("Начинаю удаление объекта типа {EntityType}", obj.GetType().Name); try { EntitySet.Remove(obj); - logger.LogDebug("Объект типа {EntityType} удален из контекста", obj.GetType().Name); + _logger.LogDebug("Объект типа {EntityType} удален из контекста", obj.GetType().Name); return true; } catch (Exception ex) { - logger.LogError(ex, "Ошибка при удалении объекта типа {EntityType} из БД", obj.GetType().Name); + _logger.LogError(ex, "Ошибка при удалении объекта типа {EntityType} из БД", obj.GetType().Name); return false; } } public virtual async Task DeleteAsync(Guid id) { - logger.LogDebug("Начинаю удаление объекта типа {EntityType} по ID: {Id}", typeof(T).Name, id); + _logger.LogDebug("Начинаю удаление объекта типа {EntityType} по ID: {Id}", typeof(T).Name, id); try { var exist = await GetAsync(id); if (exist == null) { - logger.LogError("Ошибка при удалении из БД. Не найдена запись в БД типа {EntityType} с id: {Id}", + _logger.LogError("Ошибка при удалении из БД. Не найдена запись в БД типа {EntityType} с id: {Id}", typeof(T).Name, id); return false; } EntitySet.Remove(exist); - logger.LogDebug("Объект типа {EntityType} с ID {Id} удален из контекста", typeof(T).Name, id); + _logger.LogDebug("Объект типа {EntityType} с ID {Id} удален из контекста", typeof(T).Name, id); return true; } catch (Exception ex) { - logger.LogError(ex, "Ошибка при удалении объекта типа {EntityType} из БД по ID: {Id}", typeof(T).Name, id); + _logger.LogError(ex, "Ошибка при удалении объекта типа {EntityType} из БД по ID: {Id}", typeof(T).Name, id); return false; } } public virtual IQueryable Get() { - logger.LogDebug("Получаю набор объектов типа {EntityType}", typeof(T).Name); + _logger.LogDebug("Получаю набор объектов типа {EntityType}", typeof(T).Name); return EntitySet; } public virtual async Task GetAsync(Guid id) { - logger.LogDebug("Получаю объект типа {EntityType} по ID: {Id}", typeof(T).Name, id); + _logger.LogDebug("Получаю объект типа {EntityType} по ID: {Id}", typeof(T).Name, id); return await EntitySet.FirstOrDefaultAsync(t => t.Id == id); } public virtual IQueryable GetPage(IQueryable query, PaginationFilter paginationFilter) { - logger.LogDebug("Получаю страницу объектов типа {EntityType}, страница: {PageNumber}, размер: {PageSize}", + _logger.LogDebug("Получаю страницу объектов типа {EntityType}, страница: {PageNumber}, размер: {PageSize}", typeof(T).Name, paginationFilter.PageNumber, paginationFilter.PageSize); int skip = (paginationFilter.PageNumber - 1) * paginationFilter.PageSize; diff --git a/PARR.DAL/Repositories/RobotConfigurationRepository.cs b/PARR.DAL/Repositories/RobotConfigurationRepository.cs index ba4909ed..b8db45b1 100644 --- a/PARR.DAL/Repositories/RobotConfigurationRepository.cs +++ b/PARR.DAL/Repositories/RobotConfigurationRepository.cs @@ -54,7 +54,7 @@ namespace PARR.DAL.Repositories ? ((TaskStatusEnum)taskStatusValue).ToString() : $"Unknown ({taskStatusValue})"; - logger.LogInformation("Нельзя установить статус {newStatus} для конфигурации {configurationId}, templateId: {templateId}, так как текущий статус {currentStatus}", + _logger.LogInformation("Нельзя установить статус {newStatus} для конфигурации {configurationId}, templateId: {templateId}, так как текущий статус {currentStatus}", updatingStatus, configuration.Id, configuration.TemplateId, taskStatusName); return false; } @@ -65,13 +65,13 @@ namespace PARR.DAL.Repositories // есть ли связь у config с templetes, может инклуда нет, мало ли if (configuration.Template == null) { - logger.LogWarning("При изменении статуса задания на обновление шаблона, не смог проверить наличае ScheduleEsppId, так как нет Include с Templates. Пропустил эту проверку. configurationId: {configurationId}", configuration.Id); + _logger.LogWarning("При изменении статуса задания на обновление шаблона, не смог проверить наличае ScheduleEsppId, так как нет Include с Templates. Пропустил эту проверку. configurationId: {configurationId}", configuration.Id); } else { if (configuration.Template.ScheduleEsppId == null) { - logger.LogInformation("Нельзя установить статус {newStatus} для конфигурации {configurationId}, templateId: {templateId}, так как у шаблона отсутсвтует ScheduleEsppId=null", + _logger.LogInformation("Нельзя установить статус {newStatus} для конфигурации {configurationId}, templateId: {templateId}, так как у шаблона отсутсвтует ScheduleEsppId=null", updatingStatus, configuration.Id, configuration.TemplateId); return false; } @@ -80,7 +80,7 @@ namespace PARR.DAL.Repositories // Статус ОК, можно ставить Updating ChangeTaskStatus(updatingStatus, configuration); - logger.LogInformation("Установлен статус {newStatus} для конфигурации {configurationId}, templateId: {templateId}", updatingStatus, configuration.Id, configuration.TemplateId); + _logger.LogInformation("Установлен статус {newStatus} для конфигурации {configurationId}, templateId: {templateId}", updatingStatus, configuration.Id, configuration.TemplateId); return true; } @@ -154,7 +154,7 @@ namespace PARR.DAL.Repositories if (config == null) { - logger.LogError($"У шаблона нет конфигурации роботов. TemplateId: {template.Id}"); + _logger.LogError($"У шаблона нет конфигурации роботов. TemplateId: {template.Id}"); throw new Exception($"У шаблона нет конфигурации роботов. TemplateId: {template.Id}"); } @@ -170,60 +170,72 @@ namespace PARR.DAL.Repositories var endDate = DateTimeOffset.UtcNow.Add(-robotWaitTime); - var configObjs = await EntitySet.Where(t => + var expiredConfigs = await EntitySet.Where(t => t.RobotStatusCode == (int)RobotStatusEnum.InProgress && t.AttemptsNumber >= robotAttemptsNumber && t.LastRobotStatusUpdated <= endDate ).ToListAsync(); - if (!configObjs.Any()) + if (!expiredConfigs.Any()) return; - configObjs.ForEach(item => + foreach (var item in expiredConfigs) { ChangeRobotStatus(RobotStatusEnum.Error, item); - logger.LogInformation($"Устанавливаю RobotStatus: {RobotStatusEnum.Error} для RobotConfigurationId {item.Id}"); - }); + _logger.LogInformation("Устанавливаю статус RobotStatus: {RobotStatus} для RobotConfigurationId: {RobotConfigurationId}", RobotStatusEnum.Error, item.Id); + } #region Ищем, есть ли связанные шаблоны, которые должны переименоваться, им тоже нужно установить статус ошибки, но только для Шаблонов - var linksCount = 0; + // Проактивная обработка связанных шаблонов переименования Old->New + // Если старый шаблон умен, мы должны сразу убить (!!!замочить!!!) и новый (целевой), чтобы он не висел вечно в ожидании. - var templateIds = configObjs.Where(t => t.RobotCode == (int)RobotsEnum.TemplateOrder).Select(t => t.TemplateId).ToList(); - if (templateIds.Any()) + var expiredTemplateIds = expiredConfigs + .Where(t => t.RobotCode == (int)RobotsEnum.TemplateOrder) + .Select(t => t.TemplateId) + .Distinct() + .ToList(); + + if (expiredTemplateIds.Any()) { - // По этим именам находим целевые шаблоны, берем их задания, и ставим им статус Ошибка + записать в лог робота - var configs = await EntitySet - .Where(t => t.RobotCode == (int)RobotsEnum.TemplateOrder - && t.RobotStatusCode != (int)RobotStatusEnum.Error - && EntityContext.Templates.Any(tmpl => - templateIds.Contains(tmpl.Id) - && tmpl.TemplateRenamePending != null - && tmpl.TemplateRenamePending.OldName == t.Template!.Name)) - .ToListAsync(); + // Находим OldName для этих шаблонов из таблицы переименований. + var oldNamesToFail = await EntityContext.Templates + .Where(t => expiredTemplateIds.Contains(t.Id) && t.TemplateRenamePending != null) + .Select(t => t.TemplateRenamePending!.OldName) + .Distinct() + .ToListAsync(); - linksCount = configs.Count; - - foreach (var item in configs) + // Находим целевые (новые задачи), имена которых совпадают с найденными OldName + if (oldNamesToFail.Any()) { - SetErrorRobotStatusAndMaxAttempts(item); + var targetConfigs = await EntitySet + .Where(t => + t.RobotCode == (int)RobotsEnum.TemplateOrder + && t.RobotStatusCode != (int)RobotStatusEnum.Error // Не трогаем те, что уже в ошибке + && oldNamesToFail.Contains(t.Template!.Name) + ).ToListAsync(); - // Пишем в лог роботу - var history = new RobotHistory + foreach (var item in targetConfigs) { - Id = Guid.NewGuid(), - HistoryLevel = (int)RobotStatusEnum.Error, - TaskStatusCode = item.TaskStatusCode, - RobotConfigurationId = item.Id, - RobotIp = null, - RobotId = ParrComponentsEnum.Api.ToString(), - RobotMessage = "[RobotConfigurationRepository] Установлен статус ошибки, так как не переименован связанный шаблон" - }; + SetErrorRobotStatusAndMaxAttempts(item); - // Синхронный Add работает быстрее и безопаснее внутри цикла - EntityContext.RobotHistories.Add(history); + // Пишем в лог роботу + var history = new RobotHistory + { + Id = Guid.NewGuid(), + HistoryLevel = (int)RobotStatusEnum.Error, + TaskStatusCode = item.TaskStatusCode, + RobotConfigurationId = item.Id, + RobotIp = null, + RobotId = ParrComponentsEnum.Api.ToString(), + RobotMessage = "[RobotConfigurationRepository] Установлен статус ошибки, так как не переименован связанный шаблон" + }; - logger.LogInformation($"Устанавливаю RobotStatus: {RobotStatusEnum.Error} для RobotConfigurationId {item.Id}"); + // Синхронный Add работает быстрее и безопаснее внутри цикла + EntityContext.RobotHistories.Add(history); + + _logger.LogInformation("Проактивно установлен статус {Status} для целевого задания RobotConfigurationID: {Id} из-за ошибки старого шаблона.", RobotStatusEnum.Error, item.Id); + } } } #endregion @@ -231,7 +243,7 @@ namespace PARR.DAL.Repositories var result = await CommitAsync(); if (!result) - logger.LogError("Ошибка при сохранении изменений RobotStatus для просроченных заданий в количестве {Count} шт.", configObjs.Count + linksCount); + _logger.LogError("Ошибка при сохранении изменений RobotStatus для просроченных заданий. Откат транзакции."); //else // logger.LogInformation("Успешно обработано и переведено в статус Ошибки просроченных заданий: {Count} шт.", configObjs.Count + linksCount); diff --git a/PARR.DAL/Repositories/TemplateRepository.cs b/PARR.DAL/Repositories/TemplateRepository.cs index 4a81b015..44b4661e 100644 --- a/PARR.DAL/Repositories/TemplateRepository.cs +++ b/PARR.DAL/Repositories/TemplateRepository.cs @@ -16,7 +16,7 @@ namespace PARR.DAL.Repositories public async Task GetTemplateByNameAsync(string name) { - logger.LogDebug("Поиск шаблона по имени: {TemplateName}", name); + _logger.LogDebug("Поиск шаблона по имени: {TemplateName}", name); var template = await GetWithIncludes() .Include(t => t.RobotConfigurations) @@ -24,11 +24,11 @@ namespace PARR.DAL.Repositories if (template != null) { - logger.LogDebug("Шаблон найден: {TemplateId}, имя: {TemplateName}", template.Id, template.Name); + _logger.LogDebug("Шаблон найден: {TemplateId}, имя: {TemplateName}", template.Id, template.Name); } else { - logger.LogDebug("Шаблон с именем {TemplateName} не найден", name); + _logger.LogDebug("Шаблон с именем {TemplateName} не найден", name); } return template; @@ -36,7 +36,7 @@ namespace PARR.DAL.Repositories public IQueryable