feat(dal,templateMatcher): Shortcodes добавлены %МАКС:ИМЯ АТРИБУТА%, %ГР_ПОЛЕ-ПН%, %БУКВЫ:ИМЯ АТРИБУТА%, исправлена фильтрация в UnitFilter, TemplateMatcher отдельные классы для типов работ, Shortcodes теперь работает по своим моделям Dto
This commit is contained in:
Mikhail Kuznetsov
@@ -0,0 +1,710 @@
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using PARR.BLL.Domain.Mq;
|
||||
using PARR.BLL.Services.Interfaces;
|
||||
using PARR.Common.Domain;
|
||||
using PARR.Constants;
|
||||
using PARR.DAL.DomainServices.Interfaces;
|
||||
using PARR.DAL.DomainServices.Shortcodes;
|
||||
using PARR.DAL.DomainServices.Shortcodes.Models;
|
||||
using PARR.DAL.Models;
|
||||
using PARR.DAL.Models.Job;
|
||||
using PARR.DAL.Models.Unit;
|
||||
using PARR.DAL.Services.Interfaces;
|
||||
using PARR.DAL.Services.Interfaces.Job;
|
||||
using PARR.DAL.Services.Interfaces.Unit;
|
||||
using PARR.DAL.TransformServices;
|
||||
using PARR.TemplateMatcher.Services.Interfaces;
|
||||
using PARR.TemplateMatcher.Settings;
|
||||
using System.Text.Json;
|
||||
|
||||
namespace PARR.TemplateMatcher.Services.Implemetaions;
|
||||
|
||||
internal class GroupedTemplateSynchronizer : ITemplateSynchronizer
|
||||
{
|
||||
private const bool DefaultUnusedTemplateState = false;
|
||||
private const bool DefaultUnusedScheduleState = false;
|
||||
private const bool DefaultUsedTemplateState = false;
|
||||
private const bool DefaultUsedScheduleState = false;
|
||||
|
||||
private readonly ILogger<GroupedTemplateSynchronizer> logger;
|
||||
private readonly IUnitFilterService unitFilterService;
|
||||
private readonly IUnitInUnitService unitInUnitService;
|
||||
private readonly IUnitInValueService unitInValueService;
|
||||
private readonly IUnitService unitService;
|
||||
private readonly MqSettings mqSettings;
|
||||
private readonly IMqService mqService;
|
||||
private readonly ITemplateService templateService;
|
||||
private readonly IJobGroupService jobGroupService;
|
||||
private readonly ITemplateReuser templateReuser;
|
||||
private readonly IShortcodesService shortcodesService;
|
||||
private readonly IEsppScheduleTransformService esppScheduleTransformService;
|
||||
private readonly IUnitRegionalEkPtkGroupService regionalEkPtkGroupService;
|
||||
private readonly IUnitFieldService unitFieldService;
|
||||
|
||||
public GroupedTemplateSynchronizer(
|
||||
ILogger<GroupedTemplateSynchronizer> logger,
|
||||
IUnitFilterService unitFilterService,
|
||||
IUnitInUnitService unitInUnitService,
|
||||
IUnitInValueService unitInValueService,
|
||||
IUnitService unitService,
|
||||
MqSettings mqSettings,
|
||||
IMqService mqService,
|
||||
ITemplateService templateService,
|
||||
IJobGroupService jobGroupService,
|
||||
ITemplateReuser templateReuser,
|
||||
IShortcodesService shortcodesService,
|
||||
IEsppScheduleTransformService esppScheduleTransformService,
|
||||
IUnitRegionalEkPtkGroupService regionalEkPtkGroupService,
|
||||
IUnitFieldService unitFieldService
|
||||
)
|
||||
{
|
||||
this.logger = logger;
|
||||
this.unitFilterService = unitFilterService;
|
||||
this.unitInUnitService = unitInUnitService;
|
||||
this.unitInValueService = unitInValueService;
|
||||
this.unitService = unitService;
|
||||
this.mqSettings = mqSettings;
|
||||
this.mqService = mqService;
|
||||
this.templateService = templateService;
|
||||
this.jobGroupService = jobGroupService;
|
||||
this.templateReuser = templateReuser;
|
||||
this.shortcodesService = shortcodesService;
|
||||
this.esppScheduleTransformService = esppScheduleTransformService;
|
||||
this.regionalEkPtkGroupService = regionalEkPtkGroupService;
|
||||
this.unitFieldService = unitFieldService;
|
||||
}
|
||||
|
||||
public async Task SyncTemplatesForJobAsync(Guid jobId, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogWarning("GroupedTemplateSynchronizer: SyncTemplatesForJob вызван для JobId {JobId}. Это не поддерживаемая операция.", jobId);
|
||||
}
|
||||
|
||||
public async Task SyncTemplatesForJobGroupAsync(Guid jobGroupId, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogDebug("Начало синхронизации шаблонов для JobGroup {JobGroupId}", jobGroupId);
|
||||
|
||||
// 1. Получить JobGroup и связанные Job'ы
|
||||
var jobGroup = await jobGroupService.Get()
|
||||
.AsNoTracking()
|
||||
.Include(jg => jg.Jobs)
|
||||
.ThenInclude(j => j.AutoControl)
|
||||
.Include(jg => jg.Jobs)
|
||||
.ThenInclude(j => j.UnitFilters)
|
||||
.ThenInclude(uf => uf.RelationshipFilters)
|
||||
.FirstOrDefaultAsync(jg => jg.Id == jobGroupId);
|
||||
|
||||
if (jobGroup == null || jobGroup.Jobs == null || !jobGroup.Jobs.Any())
|
||||
{
|
||||
logger.LogWarning("JobGroup {JobGroupId} не найден или не содержит Job'ов.", jobGroupId);
|
||||
return;
|
||||
}
|
||||
|
||||
var jobsInGroup = jobGroup.Jobs.ToList();
|
||||
|
||||
// --- НОВАЯ ЛОГИКА: Получение FieldId и разрешённых значений для "РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК" ---
|
||||
var workGroupField = await unitFieldService.GetByAihitNameAsync("РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК");
|
||||
if (workGroupField == null)
|
||||
{
|
||||
logger.LogError("Поле 'РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК' не найдено в справочнике полей. Синхронизация прервана.");
|
||||
return;
|
||||
}
|
||||
var workGroupFieldId = workGroupField.Id;
|
||||
|
||||
var regionalGroupValueIds = regionalEkPtkGroupService.Get()
|
||||
.Select(g => g.FieldValueId)
|
||||
.ToList(); // Получаем список UnitFieldValue.Id
|
||||
|
||||
logger.LogDebug("Найдено {Count} значений из UnitRegionalEkPtkGroup для проверки поля 'РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК'.", regionalGroupValueIds.Count);
|
||||
|
||||
// 2. Найти Job с максимальным MaxValueRelationships
|
||||
var maxJob = jobsInGroup
|
||||
.Where(j => j.MaxValueRelationships.HasValue)
|
||||
.OrderByDescending(j => j.MaxValueRelationships)
|
||||
.FirstOrDefault();
|
||||
|
||||
if (maxJob == null)
|
||||
{
|
||||
logger.LogWarning("В JobGroup {JobGroupId} не найдено Job с установленным MaxValueRelationships.", jobGroupId);
|
||||
return;
|
||||
}
|
||||
|
||||
// Проверяем, что UnitFilters и RelationshipFilters загружены (если используется для выбора targetJob)
|
||||
if (maxJob.UnitFilters == null)
|
||||
{
|
||||
logger.LogWarning("Job {JobId} не содержит UnitFilters.", maxJob.Id);
|
||||
}
|
||||
|
||||
logger.LogDebug("Используется Job {JobId} с максимальным MaxValueRelationships ({MaxValue}) для фильтрации.", maxJob.Id, maxJob.MaxValueRelationships);
|
||||
|
||||
// 3. Использовать фильтры maxJob для получения expectedUnitIds
|
||||
var expectedUnitIds = await unitFilterService.GetUnitsIdByJobFilterAsync(maxJob.Id);
|
||||
if (expectedUnitIds == null || !expectedUnitIds.Any())
|
||||
{
|
||||
logger.LogInformation("Для JobGroup {JobGroupId} фильтры не дали Unit'ов.", jobGroupId);
|
||||
return;
|
||||
}
|
||||
|
||||
// 4. Отфильтровать expectedUnitIds по GroupingUnitFieldId (дополнительный фильтр)
|
||||
if (!jobGroup.GroupingUnitFieldId.HasValue)
|
||||
{
|
||||
logger.LogError("JobGroup {JobGroupId} не имеет GroupingUnitFieldId, необходимого для группировки.", jobGroupId);
|
||||
return;
|
||||
}
|
||||
|
||||
var groupingFieldId = jobGroup.GroupingUnitFieldId.Value;
|
||||
|
||||
// Загрузить UnitValues для юнитов из expectedUnitIds, чтобы проверить GroupingUnitFieldId
|
||||
var expectedUnitsWithGroupingField = await unitService.Get()
|
||||
.AsNoTracking()
|
||||
.AsSplitQuery() // Для Unit -> UnitValues
|
||||
.Include(u => u.UnitValues)
|
||||
.ThenInclude(uv => uv.Value)
|
||||
.Where(u => expectedUnitIds.Contains(u.Id))
|
||||
.ToListAsync();
|
||||
|
||||
var unitIdsWithValidGroupingFieldSet = expectedUnitsWithGroupingField
|
||||
.Where(u => u.UnitValues.Any(uv => uv.FieldId == groupingFieldId && uv.Value != null && !string.IsNullOrEmpty(uv.Value.Value)))
|
||||
.Select(u => u.Id)
|
||||
.ToHashSet();
|
||||
|
||||
logger.LogDebug("После фильтрации по GroupingUnitFieldId осталось {Count} юнитов.", unitIdsWithValidGroupingFieldSet.Count);
|
||||
|
||||
if (!unitIdsWithValidGroupingFieldSet.Any())
|
||||
{
|
||||
logger.LogInformation("После фильтрации по GroupingUnitFieldId в JobGroup {JobGroupId} не осталось юнитов.", jobGroupId);
|
||||
return;
|
||||
}
|
||||
|
||||
// --- НОВАЯ ЛОГИКА: Дополнительная фильтрация по "РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК" ---
|
||||
var unitIdsWithValidWorkGroupFieldSet = expectedUnitsWithGroupingField
|
||||
.Where(u => unitIdsWithValidGroupingFieldSet.Contains(u.Id) && // Убедимся, что юнит уже прошёл фильтр по GroupingFieldId
|
||||
u.UnitValues.Any(uv =>
|
||||
uv.FieldId == workGroupFieldId && // Поле "РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК"
|
||||
uv.Value != null && // Значение существует
|
||||
regionalGroupValueIds.Contains(uv.Value.Id) // Значение в списке разрешённых
|
||||
))
|
||||
.Select(u => u.Id) // Выбираем Id юнита
|
||||
.ToHashSet(); // И снова в HashSet
|
||||
|
||||
logger.LogDebug("После фильтрации по 'РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК' осталось {Count} юнитов.", unitIdsWithValidWorkGroupFieldSet.Count);
|
||||
|
||||
if (!unitIdsWithValidWorkGroupFieldSet.Any())
|
||||
{
|
||||
logger.LogInformation("После фильтрации по 'РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК' в JobGroup {JobGroupId} не осталось юнитов.", jobGroupId);
|
||||
return;
|
||||
}
|
||||
|
||||
// Обновляем список юнитов, прошедших оба фильтра
|
||||
unitIdsWithValidGroupingFieldSet = unitIdsWithValidWorkGroupFieldSet;
|
||||
|
||||
// 5. Получить RelationshipFilters из maxJob
|
||||
var relationshipFilters = maxJob.UnitFilters?.SelectMany(uf => uf.RelationshipFilters).ToList() ?? new List<JobRelationshipFilter>();
|
||||
|
||||
// --- Найти и отфильтровать UnitInUnit связи ---
|
||||
logger.LogDebug("Получение связей UnitInUnit для юнитов, прошедших фильтрацию по GroupingUnitFieldId и 'РАБОЧАЯ_ГР_ОТВ_ЗА_ЭК'.");
|
||||
var potentialUnitInUnitLinks = await unitInUnitService.Get()
|
||||
.AsNoTracking()
|
||||
.Where(link => unitIdsWithValidGroupingFieldSet.Contains(link.ParentUnitId) || unitIdsWithValidGroupingFieldSet.Contains(link.ChildUnitId))
|
||||
.ToListAsync();
|
||||
|
||||
logger.LogDebug("Найдено {Count} потенциальных связей UnitInUnit.", potentialUnitInUnitLinks.Count);
|
||||
|
||||
// Загрузить UnitInValue для всех ParentUnitId и ChildUnitId из potentialUnitInUnitLinks
|
||||
var allParentIds = potentialUnitInUnitLinks.Select(l => l.ParentUnitId).ToHashSet();
|
||||
var allChildIds = potentialUnitInUnitLinks.Select(l => l.ChildUnitId).ToHashSet();
|
||||
|
||||
var parentUnitValues = await unitInValueService.Get()
|
||||
.AsNoTracking()
|
||||
.Include(uv => uv.Field)
|
||||
.Include(uv => uv.Value)
|
||||
.Where(uv => allParentIds.Contains(uv.UnitId))
|
||||
.ToListAsync();
|
||||
|
||||
var childUnitValues = await unitInValueService.Get()
|
||||
.AsNoTracking()
|
||||
.Include(uv => uv.Field)
|
||||
.Include(uv => uv.Value)
|
||||
.Where(uv => allChildIds.Contains(uv.UnitId))
|
||||
.ToListAsync();
|
||||
|
||||
// Сгруппировать значения по UnitId для быстрого доступа
|
||||
var parentValuesMap = parentUnitValues
|
||||
.GroupBy(uv => uv.UnitId)
|
||||
.ToDictionary(g => g.Key, g => g.ToList());
|
||||
|
||||
var childValuesMap = childUnitValues
|
||||
.GroupBy(uv => uv.UnitId)
|
||||
.ToDictionary(g => g.Key, g => g.ToList());
|
||||
|
||||
// Применить фильтры к связям
|
||||
logger.LogDebug("Применение {Count} RelationshipFilters к найденным связям.", relationshipFilters.Count);
|
||||
var filteredUnitInUnitLinks = new List<UnitInUnit>();
|
||||
foreach (var link in potentialUnitInUnitLinks)
|
||||
{
|
||||
bool linkMatchesAllFilters = true;
|
||||
|
||||
foreach (var rf in relationshipFilters)
|
||||
{
|
||||
var valuesToCheck = rf.IsParent ? parentValuesMap.GetValueOrDefault(link.ParentUnitId, new List<UnitInValue>()) : childValuesMap.GetValueOrDefault(link.ChildUnitId, new List<UnitInValue>());
|
||||
|
||||
bool filterMatch = valuesToCheck.Any(uv =>
|
||||
uv.FieldId == rf.FieldId &&
|
||||
uv.Value != null &&
|
||||
uv.Value.Value != null &&
|
||||
uv.Value.Value.Contains(rf.ValueMask ?? "", StringComparison.OrdinalIgnoreCase)
|
||||
);
|
||||
|
||||
if (rf.IsInverse)
|
||||
filterMatch = !filterMatch;
|
||||
|
||||
if (!filterMatch)
|
||||
{
|
||||
linkMatchesAllFilters = false;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (linkMatchesAllFilters)
|
||||
{
|
||||
filteredUnitInUnitLinks.Add(link);
|
||||
}
|
||||
}
|
||||
|
||||
logger.LogDebug("После применения RelationshipFilters осталось {Count} связей UnitInUnit.", filteredUnitInUnitLinks.Count);
|
||||
|
||||
// --- НОВАЯ ЛОГИКА: Сгруппировать юниты из unitIdsWithValidGroupingFieldSet по связанному юниту ---
|
||||
var groupedRelationships = new Dictionary<Guid, List<Guid>>();
|
||||
foreach (var link in filteredUnitInUnitLinks)
|
||||
{
|
||||
var parentUnitId = link.ParentUnitId;
|
||||
var childUnitId = link.ChildUnitId;
|
||||
|
||||
if (unitIdsWithValidGroupingFieldSet.Contains(parentUnitId))
|
||||
{
|
||||
if (!groupedRelationships.ContainsKey(childUnitId))
|
||||
{
|
||||
groupedRelationships[childUnitId] = new List<Guid>();
|
||||
}
|
||||
groupedRelationships[childUnitId].Add(parentUnitId);
|
||||
}
|
||||
else if (unitIdsWithValidGroupingFieldSet.Contains(childUnitId))
|
||||
{
|
||||
if (!groupedRelationships.ContainsKey(parentUnitId))
|
||||
{
|
||||
groupedRelationships[parentUnitId] = new List<Guid>();
|
||||
}
|
||||
groupedRelationships[parentUnitId].Add(childUnitId);
|
||||
}
|
||||
}
|
||||
|
||||
logger.LogDebug("Сформировано {Count} групп по связанным юнитам до разрешения конфликтов.", groupedRelationships.Count);
|
||||
|
||||
// --- НОВАЯ ЛОГИКА: Разрешение конфликта - один юнит из unitIdsWithValidGroupingFieldSet только в одном списке значений ---
|
||||
var unitToKeys = new Dictionary<Guid, List<Guid>>(); // Карта: юнит из списка -> список ключей, где он встречается
|
||||
|
||||
foreach (var kvp in groupedRelationships)
|
||||
{
|
||||
var key = kvp.Key;
|
||||
var units = kvp.Value;
|
||||
foreach (var unitId in units)
|
||||
{
|
||||
if (!unitToKeys.ContainsKey(unitId))
|
||||
{
|
||||
unitToKeys[unitId] = new List<Guid>();
|
||||
}
|
||||
unitToKeys[unitId].Add(key);
|
||||
}
|
||||
}
|
||||
|
||||
// Найти юниты, которые находятся в нескольких списках
|
||||
var conflictedUnits = unitToKeys.Where(kvp => kvp.Value.Count > 1).ToList();
|
||||
|
||||
foreach (var conflictedUnitEntry in conflictedUnits)
|
||||
{
|
||||
var unitId = conflictedUnitEntry.Key;
|
||||
var keysForUnit = conflictedUnitEntry.Value;
|
||||
|
||||
Guid bestKey = keysForUnit[0]; // Инициализируем первым ключом
|
||||
int maxCount = groupedRelationships[bestKey].Count;
|
||||
|
||||
for (int i = 1; i < keysForUnit.Count; i++)
|
||||
{
|
||||
var currentKey = keysForUnit[i];
|
||||
var currentCount = groupedRelationships[currentKey].Count;
|
||||
if (currentCount > maxCount)
|
||||
{
|
||||
bestKey = currentKey;
|
||||
maxCount = currentCount;
|
||||
}
|
||||
}
|
||||
|
||||
// Удалить юнит из списков всех ключей, кроме bestKey
|
||||
foreach (var key in keysForUnit)
|
||||
{
|
||||
if (key != bestKey)
|
||||
{
|
||||
groupedRelationships[key].Remove(unitId);
|
||||
logger.LogDebug("Юнит {UnitId} перемещён из группы {OldKey} в группу {BestKey} (по кол-ву).", unitId, key, bestKey);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Удаляем ключи, у которых список стал пустым после разрешения конфликтов
|
||||
var keysToRemove = groupedRelationships.Where(kvp => kvp.Value.Count == 0).Select(kvp => kvp.Key).ToList();
|
||||
foreach (var key in keysToRemove)
|
||||
{
|
||||
groupedRelationships.Remove(key);
|
||||
logger.LogDebug("Ключ {Key} удалён, так как его список юнитов стал пустым после разрешения конфликтов.", key);
|
||||
}
|
||||
|
||||
logger.LogDebug("Сформировано {Count} групп по связанным юнитам после разрешения конфликтов.", groupedRelationships.Count);
|
||||
|
||||
// 7. Разбить каждую группу и сопоставить с Job
|
||||
foreach (var kvp in groupedRelationships)
|
||||
{
|
||||
var relationshipUnitId = kvp.Key; // Связанный юнит (не из unitIdsWithValidGroupingFieldSet)
|
||||
var childUnitIds = kvp.Value; // Юниты из unitIdsWithValidGroupingFieldSet, связанные с regionalUnitId
|
||||
|
||||
logger.LogDebug("Обработка связанного юнита {RegionalUnitId} с {Count} юнитами из списка.", relationshipUnitId, childUnitIds.Count);
|
||||
|
||||
// Применяем ограничение MaxValueRelationships maxJob
|
||||
if (!maxJob.MaxValueRelationships.HasValue)
|
||||
{
|
||||
logger.LogWarning("Job {JobId} не заполнено MaxValueRelationships.", maxJob.Id);
|
||||
return;
|
||||
}
|
||||
int maxValueForSplitting = maxJob.MaxValueRelationships.Value;
|
||||
var childUnitGroups = childUnitIds
|
||||
.Select((id, index) => new { id, groupIndex = index / maxValueForSplitting })
|
||||
.GroupBy(x => x.groupIndex)
|
||||
.Select(g => g.Select(x => x.id).ToList())
|
||||
.ToList();
|
||||
|
||||
logger.LogDebug("Связанный юнит {RegionalUnitId}: разбит на {GroupCount} подгрупп.", relationshipUnitId, childUnitGroups.Count);
|
||||
|
||||
// Для каждой подгруппы:
|
||||
for (int i = 0; i < childUnitGroups.Count; i++)
|
||||
{
|
||||
var subGroup = childUnitGroups[i];
|
||||
var subGroupSize = subGroup.Count;
|
||||
|
||||
logger.LogDebug("Обработка подгруппы {Index} связанного юнита {RegionalUnitId}, размер {Size}.", i, relationshipUnitId, subGroupSize);
|
||||
|
||||
// 8. Найти подходящий Job для подгруппы (логика без изменений)
|
||||
Job? targetJob = jobsInGroup
|
||||
.Where(j => j.MaxValueRelationships.HasValue && j.MaxValueRelationships.Value == subGroupSize)
|
||||
.FirstOrDefault();
|
||||
|
||||
if (targetJob == null)
|
||||
{
|
||||
targetJob = jobsInGroup
|
||||
.Where(j => j.MaxValueRelationships.HasValue && j.MaxValueRelationships.Value >= subGroupSize)
|
||||
.OrderBy(j => j.MaxValueRelationships!.Value)
|
||||
.FirstOrDefault();
|
||||
}
|
||||
|
||||
if (targetJob == null)
|
||||
{
|
||||
targetJob = maxJob; // maxJob уже проверен на null ранее
|
||||
logger.LogDebug("Для подгруппы {Index} связанного юнита {RegionalUnitId} не найден подходящий Job, используем maxJob {MaxJobId}.", i, relationshipUnitId, maxJob.Id);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogDebug("Для подгруппы {Index} связанного юнита {RegionalUnitId} выбран Job {TargetJobId} с MaxValueRelationships {MaxValue}.", i, relationshipUnitId, targetJob.Id, targetJob.MaxValueRelationships);
|
||||
}
|
||||
|
||||
// 9. Загрузить существующие шаблоны для targetJob, связанные с regionalUnitId
|
||||
var existingTemplatesForRelationship = await templateService.Get()
|
||||
.AsNoTracking()
|
||||
.Include(t => t.UnitsInTemplate)
|
||||
.Where(t => t.JobId == targetJob.Id && t.UnitId == relationshipUnitId && t.Index == i)
|
||||
.ToListAsync();
|
||||
|
||||
var existingTemplateForSubGroup = existingTemplatesForRelationship.FirstOrDefault();
|
||||
|
||||
if (existingTemplateForSubGroup != null)
|
||||
{
|
||||
// Проверить, изменились ли юниты
|
||||
var existingUnitIds = existingTemplateForSubGroup.UnitsInTemplate.Select(uit => uit.UnitId).ToHashSet();
|
||||
var newUnitIds = subGroup.ToHashSet();
|
||||
|
||||
if (existingUnitIds.SetEquals(newUnitIds))
|
||||
{
|
||||
logger.LogDebug("Шаблон {TemplateId} (Job {JobId}, Regional {RegionalId}, Index {Index}) актуален.", existingTemplateForSubGroup.Id, targetJob.Id, relationshipUnitId, i);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogDebug("Шаблон {TemplateId} (Job {JobId}, Regional {RegionalId}, Index {Index}) требует обновления юнитов.", existingTemplateForSubGroup.Id, targetJob.Id, relationshipUnitId, i);
|
||||
await UpdateTemplateUnitsAsync(existingTemplateForSubGroup, subGroup, targetJob, initiator);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
var reusableTemplate = await templateReuser.TryReuseOneUnusedTemplateAsync(targetJob.Id, relationshipUnitId, initiator);
|
||||
|
||||
if (reusableTemplate != null)
|
||||
{
|
||||
logger.LogInformation("Переиспользован шаблон {TemplateId} для Job {JobId}, связанного юнита {RegionalId}, Index {Index}.", reusableTemplate.Id, targetJob.Id, relationshipUnitId, i);
|
||||
|
||||
var expectedName = await GetNormalizedTemplateNameAsync(targetJob, relationshipUnitId, i, subGroup);
|
||||
var nextRun = await GetNextRunAsync(targetJob);
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = reusableTemplate.Id,
|
||||
JobId = targetJob.Id,
|
||||
UnitId = relationshipUnitId,
|
||||
Name = expectedName,
|
||||
IsActiveTemplate = targetJob.AutoControl?.InitUsedTemplateState ?? DefaultUsedTemplateState,
|
||||
IsActiveSchedule = targetJob.AutoControl?.InitUsedScheduleState ?? DefaultUsedScheduleState,
|
||||
StatusTypeId = TemplateStatusTypeEnum.Used,
|
||||
Initiator = initiator,
|
||||
NextRun = nextRun,
|
||||
Index = i,
|
||||
UnitsInTemplate = subGroup
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogDebug("Создание нового шаблона для Job {JobId}, связанного юнита {RegionalId}, Index {Index}, с {Count} юнитами.", targetJob.Id, relationshipUnitId, i, subGroup.Count);
|
||||
await CreateGroupedTemplateAsync(targetJob.Id, relationshipUnitId, subGroup, i, initiator);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 10. Деактивировать шаблоны, которые больше не соответствуют ни одной подгруппе (логика без изменений)
|
||||
var expectedTemplateKeys = new HashSet<(Guid JobId, Guid UnitId, int Index)>();
|
||||
foreach (var kvp in groupedRelationships)
|
||||
{
|
||||
var regionalUnitId = kvp.Key;
|
||||
var childUnitIds = kvp.Value;
|
||||
int maxValueForSplitting = maxJob.MaxValueRelationships!.Value;
|
||||
var childUnitGroups = childUnitIds
|
||||
.Select((id, index) => new { id, groupIndex = index / maxValueForSplitting })
|
||||
.GroupBy(x => x.groupIndex)
|
||||
.Select(g => g.Select(x => x.id).ToList())
|
||||
.ToList();
|
||||
|
||||
for (int i = 0; i < childUnitGroups.Count; i++)
|
||||
{
|
||||
var subGroup = childUnitGroups[i];
|
||||
var subGroupSize = subGroup.Count;
|
||||
|
||||
Job? targetJobForExpectedKey = jobsInGroup
|
||||
.Where(j => j.MaxValueRelationships.HasValue && j.MaxValueRelationships.Value == subGroupSize)
|
||||
.FirstOrDefault();
|
||||
|
||||
if (targetJobForExpectedKey == null)
|
||||
{
|
||||
targetJobForExpectedKey = jobsInGroup
|
||||
.Where(j => j.MaxValueRelationships.HasValue && j.MaxValueRelationships.Value >= subGroupSize)
|
||||
.OrderBy(j => j.MaxValueRelationships!.Value)
|
||||
.FirstOrDefault();
|
||||
}
|
||||
|
||||
if (targetJobForExpectedKey == null) targetJobForExpectedKey = maxJob; // maxJob уже проверен на null
|
||||
|
||||
expectedTemplateKeys.Add((targetJobForExpectedKey.Id, regionalUnitId, i));
|
||||
}
|
||||
}
|
||||
|
||||
var allRegionalUnitIds = groupedRelationships.Keys.ToHashSet();
|
||||
var allJobIdsInGroup = jobsInGroup.Select(j => j.Id).ToHashSet();
|
||||
|
||||
var allExistingTemplatesInGroup = await templateService.Get()
|
||||
.AsNoTracking()
|
||||
.Include(t => t.UnitsInTemplate)
|
||||
.Where(t => allJobIdsInGroup.Contains(t.JobId) && allRegionalUnitIds.Contains(t.UnitId))
|
||||
.ToListAsync();
|
||||
|
||||
foreach (var existingTemplate in allExistingTemplatesInGroup)
|
||||
{
|
||||
var key = (existingTemplate.JobId, existingTemplate.UnitId, existingTemplate.Index ?? -1);
|
||||
if (!expectedTemplateKeys.Contains(key))
|
||||
{
|
||||
logger.LogInformation("Деактивация лишнего шаблона {TemplateId} (Job {JobId}, Regional {UnitId}, Index {Index}).", existingTemplate.Id, existingTemplate.JobId, existingTemplate.UnitId, existingTemplate.Index);
|
||||
await DeactivateTemplateAsync(existingTemplate, existingTemplate.JobId, initiator);
|
||||
}
|
||||
}
|
||||
|
||||
logger.LogInformation("Синхронизация шаблонов завершена для JobGroup {JobGroupId}.", jobGroupId);
|
||||
}
|
||||
|
||||
public async Task UpdateTemplatesForJobAsync(Guid jobId, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogWarning("GroupedTemplateSynchronizer: UpdateTemplatesForJob вызван для JobId {JobId}. Это не поддерживаемая операция. Используйте SyncTemplatesForJobGroup для обновления.", jobId);
|
||||
return;
|
||||
}
|
||||
|
||||
// --- Вспомогательные методы ---
|
||||
private async Task UpdateTemplateUnitsAsync(Template template, List<Guid> newUnitIds, Job targetJob, HistoryInitiator initiator)
|
||||
{
|
||||
template.StatusTypeId = TemplateStatusTypeEnum.Updating;
|
||||
template.DateModified = DateTimeOffset.UtcNow;
|
||||
|
||||
if (!await templateService.CommitAsync(initiator))
|
||||
{
|
||||
logger.LogError("Не удалось перевести шаблон {TemplateId} в Updating для обновления юнитов.", template.Id);
|
||||
return;
|
||||
}
|
||||
|
||||
var expectedName = await GetNormalizedTemplateNameAsync(targetJob, template.UnitId, template.Index, newUnitIds);
|
||||
var nextRun = await GetNextRunAsync(targetJob, template.NextRun);
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = template.Id,
|
||||
JobId = targetJob.Id,
|
||||
UnitId = template.UnitId,
|
||||
Name = expectedName,
|
||||
IsActiveTemplate = template.IsActiveTemplate,
|
||||
IsActiveSchedule = template.IsActiveSchedule,
|
||||
LastRun = template.LastRun,
|
||||
NextRun = nextRun,
|
||||
Index = template.Index,
|
||||
StatusTypeId = TemplateStatusTypeEnum.Used,
|
||||
Initiator = initiator,
|
||||
UnitsInTemplate = newUnitIds
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
}
|
||||
|
||||
private async Task CreateGroupedTemplateAsync(Guid jobId, Guid regionalUnitId, List<Guid> unitIds, int index, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogInformation("Создание нового группового шаблона для Job {JobId}, связанного юнита {RegionalUnitId}, Index {Index}, с {Count} юнитами.", jobId, regionalUnitId, index, unitIds.Count);
|
||||
|
||||
var mqRequest = new TemplateGeneratorMq
|
||||
{
|
||||
JobId = jobId,
|
||||
UnitId = regionalUnitId, // UnitId шаблона
|
||||
UnitsInTemplate = unitIds, // Юниты для UnitsInTemplate
|
||||
Index = index, // Индекс шаблона
|
||||
HistoryInitiator = initiator
|
||||
};
|
||||
|
||||
var msg = JsonSerializer.Serialize(mqRequest);
|
||||
var result = await mqService.SendAsync(mqSettings.TemplateGenerator, new[] { msg });
|
||||
|
||||
if (!result.IsSuccess)
|
||||
logger.LogError("Ошибка отправки команды создания группового шаблона для Job {JobId}, связанного юнита {RegionalUnitId}, Index {Index}.", jobId, regionalUnitId, index);
|
||||
}
|
||||
|
||||
private async Task<bool> DeactivateTemplateAsync(
|
||||
Template template,
|
||||
Guid jobId,
|
||||
HistoryInitiator initiator)
|
||||
{
|
||||
if (template.StatusTypeId == TemplateStatusTypeEnum.Updating)
|
||||
return true; // уже в обработке
|
||||
|
||||
logger.LogInformation("Шаблон {TemplateId} (UnitId {UnitId}) → деактивация.",
|
||||
template.Id, template.UnitId);
|
||||
|
||||
template.StatusTypeId = TemplateStatusTypeEnum.Updating;
|
||||
template.DateModified = DateTimeOffset.UtcNow;
|
||||
|
||||
if (!await templateService.CommitAsync(initiator))
|
||||
{
|
||||
logger.LogError("Не удалось перевести шаблон {TemplateId} в Updating.", template.Id);
|
||||
return false;
|
||||
}
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = template.Id,
|
||||
JobId = jobId,
|
||||
UnitId = template.UnitId,
|
||||
Name = GetTemplateNameForUnused(template.Name),
|
||||
IsActiveTemplate = DefaultUnusedTemplateState,
|
||||
IsActiveSchedule = DefaultUnusedScheduleState,
|
||||
LastRun = template.LastRun,
|
||||
NextRun = template.NextRun,
|
||||
Index = template.Index,
|
||||
StatusTypeId = TemplateStatusTypeEnum.Unused,
|
||||
Initiator = initiator,
|
||||
UnitsInTemplate = new List<Guid>()
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
return true;
|
||||
}
|
||||
|
||||
private async Task SendTemplateUpdateMessage(TemplateUpdaterMq updateRequest)
|
||||
{
|
||||
logger.LogDebug("Отправка сообщения в очередь '{Queue}' для шаблона {TemplateId}",
|
||||
mqSettings.TemplateUpdater.QueueName, updateRequest.TemplateId);
|
||||
|
||||
var msg = JsonSerializer.Serialize(updateRequest);
|
||||
var result = await mqService.SendAsync(mqSettings.TemplateUpdater, new[] { msg });
|
||||
|
||||
if (result.IsSuccess)
|
||||
{
|
||||
logger.LogInformation("Отправлен запрос на обновление шаблона {TemplateId}", updateRequest.TemplateId);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogError("Ошибка при отправке запроса на обновление шаблона {TemplateId} в очередь '{Queue}'.",
|
||||
updateRequest.TemplateId, mqSettings.TemplateUpdater.QueueName);
|
||||
}
|
||||
}
|
||||
|
||||
private string GetTemplateNameForUnused(string templateName)
|
||||
{
|
||||
return templateName + "_" + DateTimeOffset.UtcNow.ToUnixTimeSeconds();
|
||||
}
|
||||
|
||||
// Изменённая сигнатура: добавлен templateUnitIds
|
||||
private async Task<string> GetNormalizedTemplateNameAsync(Job targetJob, Guid unitId, int? index = null, List<Guid>? templateUnitIds = null)
|
||||
{
|
||||
// Подготовка объекта TemplateForShortcodes для передачи в ShortcodesService
|
||||
var templateForShortcodes = new TemplateForShortcodes
|
||||
{
|
||||
Id = Guid.Empty, // Не используется в подстановке, но нужен для структуры
|
||||
Index = index,
|
||||
JobId = targetJob.Id,
|
||||
UnitId = unitId,
|
||||
Job = new JobForShortcodes
|
||||
{
|
||||
Group = targetJob.Group != null ? new JobGroupForShortcodes
|
||||
{
|
||||
Id = targetJob.Group.Id,
|
||||
GroupingUnitFieldId = targetJob.Group.GroupingUnitFieldId,
|
||||
GroupType = targetJob.Group.GroupType != null ? new JobGroupTypeForShortcodes
|
||||
{
|
||||
Code = targetJob.Group.GroupType.Code
|
||||
} : null,
|
||||
GroupName = targetJob.Group.GroupName
|
||||
} : null,
|
||||
Tnk = targetJob.Tnk != null ? new TnkForShortcodes
|
||||
{
|
||||
Name = targetJob.Tnk.Name,
|
||||
ShortName = targetJob.Tnk.ShortName ?? ""
|
||||
} : null,
|
||||
WorkName = targetJob.WorkName,
|
||||
Name = targetJob.Name
|
||||
},
|
||||
// Преобразование List<Guid> в List<UnitInTemplateForShortcodes>
|
||||
UnitsInTemplate = templateUnitIds?.Select(id => new UnitInTemplateForShortcodes { UnitId = id }).ToList() ?? new List<UnitInTemplateForShortcodes>()
|
||||
};
|
||||
|
||||
var rawName = await shortcodesService.ApplyShortcodesAsync(targetJob.TemplateNameMask, templateForShortcodes);
|
||||
return rawName.ToUpper();
|
||||
}
|
||||
|
||||
private async Task<DateTimeOffset> GetNextRunAsync(Job targetJob, DateTimeOffset? currentNextRun = null)
|
||||
{
|
||||
var now = DateTimeOffset.UtcNow;
|
||||
if (currentNextRun.HasValue && currentNextRun.Value > now)
|
||||
{
|
||||
return currentNextRun.Value;
|
||||
}
|
||||
|
||||
var referenceDate = targetJob.Group?.ReferenceDate ?? now;
|
||||
return await esppScheduleTransformService.GetNextDateAsync(targetJob.GroupId, referenceDate);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,487 @@
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using PARR.BLL.Domain.Mq;
|
||||
using PARR.BLL.Services.Interfaces;
|
||||
using PARR.Common.Domain;
|
||||
using PARR.Constants;
|
||||
using PARR.DAL.Contracts;
|
||||
using PARR.DAL.DomainServices.Interfaces;
|
||||
using PARR.DAL.DomainServices.Shortcodes;
|
||||
using PARR.DAL.DomainServices.Shortcodes.Models;
|
||||
using PARR.DAL.Models;
|
||||
using PARR.DAL.Models.Job;
|
||||
using PARR.DAL.Services.Interfaces;
|
||||
using PARR.DAL.Services.Interfaces.Job;
|
||||
using PARR.DAL.TransformServices;
|
||||
using PARR.TemplateMatcher.Services.Interfaces;
|
||||
using PARR.TemplateMatcher.Settings;
|
||||
using System.Text.Json;
|
||||
|
||||
namespace PARR.TemplateMatcher.Services.Implemetaions;
|
||||
|
||||
internal class SimpleTemplateSynchronizer : ITemplateSynchronizer
|
||||
{
|
||||
private const bool DefaultUnusedTemplateState = false;
|
||||
private const bool DefaultUnusedScheduleState = false;
|
||||
private const bool DefaultUsedTemplateState = false;
|
||||
private const bool DefaultUsedScheduleState = false;
|
||||
|
||||
private readonly ILogger<SimpleTemplateSynchronizer> logger;
|
||||
private readonly IUnitFilterService unitFilterService;
|
||||
private readonly MqSettings mqSettings;
|
||||
private readonly IMqService mqService;
|
||||
private readonly ITemplateService templateService;
|
||||
private readonly IJobService jobService;
|
||||
private readonly ITemplateReuser templateReuser;
|
||||
private readonly IShortcodesService shortcodesService;
|
||||
private readonly IEsppScheduleTransformService esppScheduleTransformService;
|
||||
|
||||
public SimpleTemplateSynchronizer(
|
||||
ILogger<SimpleTemplateSynchronizer> logger,
|
||||
IUnitFilterService unitFilterService,
|
||||
MqSettings mqSettings,
|
||||
IMqService mqService,
|
||||
ITemplateService templateService,
|
||||
IJobService jobService,
|
||||
ITemplateReuser templateReuser,
|
||||
IShortcodesService shortcodesService,
|
||||
IEsppScheduleTransformService esppScheduleTransformService)
|
||||
{
|
||||
this.logger = logger;
|
||||
this.unitFilterService = unitFilterService;
|
||||
this.mqSettings = mqSettings;
|
||||
this.mqService = mqService;
|
||||
this.templateService = templateService;
|
||||
this.jobService = jobService;
|
||||
this.templateReuser = templateReuser;
|
||||
this.shortcodesService = shortcodesService;
|
||||
this.esppScheduleTransformService = esppScheduleTransformService;
|
||||
}
|
||||
|
||||
public async Task SyncTemplatesForJobGroupAsync(Guid jobGroupId, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogWarning("SimpleTemplateSynchronizer: SyncTemplatesForJobGroup вызван для JobGroupId {JobGroupId}. Это не поддерживаемая операция.", jobGroupId);
|
||||
// Не делаем ничего
|
||||
return;
|
||||
}
|
||||
|
||||
public async Task SyncTemplatesForJobAsync(Guid jobId, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogDebug("Начало синхронизации шаблонов для JobId {JobId}", jobId);
|
||||
|
||||
var expectedUnitIds = await GetExpectedUnitIdsAsync(jobId) ?? new HashSet<Guid>();
|
||||
logger.LogDebug("JobId {JobId}: найдено {Count} UnitId по фильтрам.", jobId, expectedUnitIds.Count);
|
||||
|
||||
var job = await GetJobWithGroupAndAutoControlAsync(jobId);
|
||||
if (job == null)
|
||||
{
|
||||
logger.LogError("Job с Id {JobId} не найден.", jobId);
|
||||
return;
|
||||
}
|
||||
|
||||
// Проверяем, является ли Job "групповым"
|
||||
bool isGroupJob = job.Group != null && job.Group.GroupType?.Code == JobGroupTypesEnum.Group;
|
||||
|
||||
if (isGroupJob && job.Group!.GroupingUnitFieldId.HasValue)
|
||||
{
|
||||
logger.LogInformation("Job {JobId} является групповым. Используйте SyncTemplatesForJobGroup для синхронизации.", jobId);
|
||||
return; // Ничего не делаем для группового Job
|
||||
}
|
||||
|
||||
var existingTemplates = await templateService.Get()
|
||||
.AsNoTracking()
|
||||
.Where(t => t.JobId == jobId)
|
||||
.ToListAsync();
|
||||
|
||||
logger.LogDebug("JobId {JobId}: {Expected} ожидаемых UnitId, {Existing} существующих шаблонов.",
|
||||
jobId, expectedUnitIds.Count, existingTemplates.Count);
|
||||
|
||||
// Обработка случая: фильтр вернул 0 UnitId → деактивировать ВСЕ шаблоны
|
||||
if (!expectedUnitIds.Any())
|
||||
{
|
||||
if (existingTemplates.Any())
|
||||
{
|
||||
logger.LogInformation("Для JobId {JobId} фильтры не дали Unit'ов — будет деактивировано {Count} шаблонов.",
|
||||
jobId, existingTemplates.Count);
|
||||
|
||||
foreach (var template in existingTemplates)
|
||||
{
|
||||
await DeactivateTemplateAsync(template, jobId, initiator);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogInformation("Для JobId {JobId} нет Unit'ов по фильтрам и нет существующих шаблонов — синхронизация завершена.", jobId);
|
||||
}
|
||||
|
||||
logger.LogInformation("Синхронизация завершена для JobId {JobId} (фильтр пуст).", jobId);
|
||||
return;
|
||||
}
|
||||
|
||||
// Деактивация шаблонов, которые вышли из фильтра
|
||||
var templatesToDeactivate = existingTemplates
|
||||
.Where(t => !expectedUnitIds.Contains(t.UnitId))
|
||||
.ToList();
|
||||
|
||||
foreach (var template in templatesToDeactivate)
|
||||
{
|
||||
await DeactivateTemplateAsync(template, jobId, initiator);
|
||||
}
|
||||
|
||||
// Перечитываем шаблоны после деактивации
|
||||
existingTemplates = await templateService.Get()
|
||||
.AsNoTracking()
|
||||
.Where(t => t.JobId == jobId)
|
||||
.ToListAsync();
|
||||
|
||||
var unitToTemplate = existingTemplates.ToDictionary(t => t.UnitId, t => t);
|
||||
|
||||
// UnitId без шаблона → попытка переиспользования или создание
|
||||
var unitIdsMissingTemplates = expectedUnitIds
|
||||
.Where(unitId => !unitToTemplate.ContainsKey(unitId))
|
||||
.ToList();
|
||||
|
||||
var unitIdsToCreateFresh = new List<Guid>();
|
||||
|
||||
foreach (var unitId in unitIdsMissingTemplates)
|
||||
{
|
||||
var reused = await templateReuser.TryReuseOneUnusedTemplateAsync(jobId, unitId, initiator);
|
||||
if (reused != null) // если захват успешен
|
||||
{
|
||||
logger.LogInformation("Переиспользован шаблон {TemplateId} для UnitId {UnitId}.", reused.Id, unitId);
|
||||
|
||||
var expectedName = await GetNormalizedTemplateNameAsync(job, unitId);
|
||||
var nextRun = await GetNextRunAsync(job); // всегда пересчитываем для нового назначения
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = reused.Id,
|
||||
JobId = jobId,
|
||||
UnitId = unitId,
|
||||
Name = expectedName,
|
||||
IsActiveTemplate = job.AutoControl?.InitUsedTemplateState ?? DefaultUsedTemplateState,
|
||||
IsActiveSchedule = job.AutoControl?.InitUsedScheduleState ?? DefaultUsedScheduleState,
|
||||
StatusTypeId = TemplateStatusTypeEnum.Used,
|
||||
Initiator = initiator,
|
||||
NextRun = nextRun,
|
||||
UnitsInTemplate = new List<Guid>() // Для простого шаблона
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogInformation("Нет доступных Unused-шаблонов для UnitId {UnitId} → создадим новый.", unitId);
|
||||
unitIdsToCreateFresh.Add(unitId);
|
||||
}
|
||||
}
|
||||
|
||||
// Обновление/реактивация шаблонов, оставшихся в фильтре
|
||||
var templatesInFilter = existingTemplates
|
||||
.Where(t => expectedUnitIds.Contains(t.UnitId))
|
||||
.ToList();
|
||||
|
||||
foreach (var template in templatesInFilter)
|
||||
{
|
||||
var expectedName = await GetNormalizedTemplateNameAsync(job, template.UnitId);
|
||||
await ReactivateOrRenameTemplateAsync(template, job, expectedName, initiator);
|
||||
}
|
||||
|
||||
// Создание новых шаблонов
|
||||
foreach (var unitId in unitIdsToCreateFresh)
|
||||
{
|
||||
await SendTemplateGeneratorMessageAsync(jobId, unitId, initiator);
|
||||
}
|
||||
|
||||
logger.LogInformation("Синхронизация завершена для JobId {JobId}.", jobId);
|
||||
}
|
||||
|
||||
public async Task UpdateTemplatesForJobAsync(Guid jobId, HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogDebug("Начало обновления шаблонов для JobId {JobId}", jobId);
|
||||
|
||||
var existingTemplates = await templateService.Get()
|
||||
.AsNoTracking()
|
||||
.Where(t => t.JobId == jobId)
|
||||
.ToListAsync();
|
||||
|
||||
if (!existingTemplates.Any()) return;
|
||||
|
||||
var job = await GetJobWithGroupAndAutoControlAsync(jobId);
|
||||
if (job == null) return;
|
||||
|
||||
var currentUnitIds = await GetExpectedUnitIdsAsync(jobId) ?? new HashSet<Guid>();
|
||||
logger.LogDebug("JobId {JobId}: {Count} UnitId по текущему фильтру.", jobId, currentUnitIds.Count);
|
||||
|
||||
foreach (var template in existingTemplates)
|
||||
{
|
||||
logger.LogDebug("Обработка шаблона {TemplateId} (UnitId {UnitId}).", template.Id, template.UnitId);
|
||||
|
||||
bool unitStillInFilter = currentUnitIds.Contains(template.UnitId);
|
||||
var expectedName = await GetNormalizedTemplateNameAsync(job, template.UnitId);
|
||||
|
||||
TemplateStatusTypeEnum targetStatus;
|
||||
bool targetIsActiveTemplate;
|
||||
bool targetIsActiveSchedule;
|
||||
|
||||
if (unitStillInFilter)
|
||||
{
|
||||
targetStatus = TemplateStatusTypeEnum.Used;
|
||||
targetIsActiveTemplate = template.IsActiveTemplate;
|
||||
targetIsActiveSchedule = template.IsActiveSchedule;
|
||||
}
|
||||
else
|
||||
{
|
||||
targetStatus = TemplateStatusTypeEnum.Unused;
|
||||
targetIsActiveTemplate = DefaultUnusedTemplateState;
|
||||
targetIsActiveSchedule = DefaultUnusedScheduleState;
|
||||
expectedName = GetTemplateNameForUnused(expectedName);
|
||||
logger.LogInformation("Шаблон {TemplateId} (UnitId {UnitId}) → деактивация.", template.Id, template.UnitId);
|
||||
}
|
||||
|
||||
bool needsUpdate = template.StatusTypeId != TemplateStatusTypeEnum.Updating &&
|
||||
(
|
||||
// 1. Статус изменился (например, Used → Unused или Unused → Used)
|
||||
template.StatusTypeId != targetStatus ||
|
||||
|
||||
// 2. Для Used — имя должно соответствовать шаблону
|
||||
(targetStatus == TemplateStatusTypeEnum.Used && template.Name != expectedName) ||
|
||||
|
||||
// 3. Флаги изменились (редко, но возможно через AutoControl изменение)
|
||||
template.IsActiveTemplate != targetIsActiveTemplate ||
|
||||
template.IsActiveSchedule != targetIsActiveSchedule
|
||||
);
|
||||
|
||||
if (!needsUpdate) continue;
|
||||
|
||||
template.StatusTypeId = TemplateStatusTypeEnum.Updating;
|
||||
template.DateModified = DateTimeOffset.UtcNow;
|
||||
|
||||
if (!await templateService.CommitAsync(initiator))
|
||||
{
|
||||
logger.LogError("Не удалось перевести шаблон {TemplateId} в Updating.", template.Id);
|
||||
continue;
|
||||
}
|
||||
|
||||
var nextRun = await GetNextRunAsync(job, template.NextRun);
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = template.Id,
|
||||
JobId = jobId,
|
||||
UnitId = template.UnitId,
|
||||
Name = expectedName,
|
||||
IsActiveTemplate = targetIsActiveTemplate,
|
||||
IsActiveSchedule = targetIsActiveSchedule,
|
||||
LastRun = template.LastRun,
|
||||
NextRun = nextRun,
|
||||
Index = template.Index,
|
||||
StatusTypeId = targetStatus,
|
||||
Initiator = initiator,
|
||||
UnitsInTemplate = template.UnitsInTemplate.Select(t => t.UnitId).ToList() // Для простого шаблона это список из одного элемента или пустой
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
}
|
||||
|
||||
logger.LogInformation("Обновление шаблонов завершено для JobId {JobId}.", jobId);
|
||||
}
|
||||
|
||||
// --- Вспомогательные методы ---
|
||||
private async Task<bool> DeactivateTemplateAsync(
|
||||
Template template,
|
||||
Guid jobId,
|
||||
HistoryInitiator initiator)
|
||||
{
|
||||
if (template.StatusTypeId == TemplateStatusTypeEnum.Updating)
|
||||
return true; // уже в обработке
|
||||
|
||||
logger.LogInformation("Шаблон {TemplateId} (UnitId {UnitId}) → деактивация.",
|
||||
template.Id, template.UnitId);
|
||||
|
||||
template.StatusTypeId = TemplateStatusTypeEnum.Updating;
|
||||
template.DateModified = DateTimeOffset.UtcNow;
|
||||
|
||||
if (!await templateService.CommitAsync(initiator))
|
||||
{
|
||||
logger.LogError("Не удалось перевести шаблон {TemplateId} в Updating.", template.Id);
|
||||
return false;
|
||||
}
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = template.Id,
|
||||
JobId = jobId,
|
||||
UnitId = template.UnitId,
|
||||
Name = GetTemplateNameForUnused(template.Name),
|
||||
IsActiveTemplate = DefaultUnusedTemplateState,
|
||||
IsActiveSchedule = DefaultUnusedScheduleState,
|
||||
LastRun = template.LastRun,
|
||||
NextRun = template.NextRun,
|
||||
Index = template.Index,
|
||||
StatusTypeId = TemplateStatusTypeEnum.Unused,
|
||||
Initiator = initiator,
|
||||
UnitsInTemplate = new List<Guid>() // Для простого шаблона
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
return true;
|
||||
}
|
||||
|
||||
private async Task<bool> ReactivateOrRenameTemplateAsync(
|
||||
Template template,
|
||||
Job job,
|
||||
string expectedName,
|
||||
HistoryInitiator initiator)
|
||||
{
|
||||
if (template.StatusTypeId == TemplateStatusTypeEnum.Updating)
|
||||
return true;
|
||||
|
||||
bool needsUpdate = template.Name != expectedName
|
||||
|| template.StatusTypeId != TemplateStatusTypeEnum.Used;
|
||||
|
||||
if (!needsUpdate) return true;
|
||||
|
||||
logger.LogInformation("Шаблон {TemplateId}: требуется обновление имени или реактивация.", template.Id);
|
||||
|
||||
template.StatusTypeId = TemplateStatusTypeEnum.Updating;
|
||||
template.DateModified = DateTimeOffset.UtcNow;
|
||||
|
||||
if (!await templateService.CommitAsync(initiator))
|
||||
{
|
||||
logger.LogError("Не удалось перевести шаблон {TemplateId} в Updating.", template.Id);
|
||||
return false;
|
||||
}
|
||||
|
||||
var nextRun = await GetNextRunAsync(job, template.NextRun);
|
||||
|
||||
var updateRequest = new TemplateUpdaterMq
|
||||
{
|
||||
TemplateId = template.Id,
|
||||
JobId = job.Id,
|
||||
UnitId = template.UnitId,
|
||||
Name = expectedName,
|
||||
IsActiveTemplate = template.IsActiveTemplate,
|
||||
IsActiveSchedule = template.IsActiveSchedule,
|
||||
LastRun = template.LastRun,
|
||||
NextRun = nextRun,
|
||||
Index = template.Index,
|
||||
StatusTypeId = TemplateStatusTypeEnum.Used,
|
||||
Initiator = initiator,
|
||||
UnitsInTemplate = template.UnitsInTemplate.Select(t => t.UnitId).ToList() // Для простого шаблона это список из одного элемента
|
||||
};
|
||||
|
||||
await SendTemplateUpdateMessage(updateRequest);
|
||||
return true;
|
||||
}
|
||||
|
||||
private async Task<bool> SendTemplateGeneratorMessageAsync(
|
||||
Guid jobId,
|
||||
Guid unitId,
|
||||
HistoryInitiator initiator)
|
||||
{
|
||||
logger.LogInformation("Создание нового шаблона для UnitId {UnitId}.", unitId);
|
||||
var mqRequest = new TemplateGeneratorMq
|
||||
{
|
||||
JobId = jobId,
|
||||
UnitId = unitId,
|
||||
HistoryInitiator = initiator,
|
||||
UnitsInTemplate = new List<Guid>() // Для простого шаблона
|
||||
};
|
||||
|
||||
var msg = JsonSerializer.Serialize(mqRequest);
|
||||
var result = await mqService.SendAsync(mqSettings.TemplateGenerator, new[] { msg });
|
||||
|
||||
if (!result.IsSuccess)
|
||||
logger.LogError("Ошибка отправки команды создания шаблона для UnitId {UnitId}.", unitId);
|
||||
|
||||
return result.IsSuccess;
|
||||
}
|
||||
|
||||
private async Task SendTemplateUpdateMessage(TemplateUpdaterMq updateRequest)
|
||||
{
|
||||
logger.LogDebug("Отправка сообщения в очередь '{Queue}' для шаблона {TemplateId}",
|
||||
mqSettings.TemplateUpdater.QueueName, updateRequest.TemplateId);
|
||||
|
||||
var msg = JsonSerializer.Serialize(updateRequest);
|
||||
var result = await mqService.SendAsync(mqSettings.TemplateUpdater, new[] { msg });
|
||||
|
||||
if (result.IsSuccess)
|
||||
{
|
||||
logger.LogInformation("Отправлен запрос на обновление шаблона {TemplateId}", updateRequest.TemplateId);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.LogError("Ошибка при отправке запроса на обновление шаблона {TemplateId} в очередь '{Queue}'.",
|
||||
updateRequest.TemplateId, mqSettings.TemplateUpdater.QueueName);
|
||||
}
|
||||
}
|
||||
|
||||
private string GetTemplateNameForUnused(string templateName)
|
||||
{
|
||||
return templateName + "_" + DateTimeOffset.UtcNow.ToUnixTimeSeconds();
|
||||
}
|
||||
|
||||
private async Task<Job?> GetJobWithGroupAndAutoControlAsync(Guid jobId)
|
||||
{
|
||||
return await jobService.Get()
|
||||
.AsNoTracking()
|
||||
.Include(j => j.Group)
|
||||
.ThenInclude(j => j.GroupType)
|
||||
.Include(j => j.AutoControl)
|
||||
.FirstOrDefaultAsync(j => j.Id == jobId);
|
||||
}
|
||||
|
||||
private async Task<HashSet<Guid>> GetExpectedUnitIdsAsync(Guid jobId)
|
||||
{
|
||||
var units = await unitFilterService.GetUnitsIdByJobFilterAsync(jobId);
|
||||
return units?.ToHashSet() ?? new HashSet<Guid>();
|
||||
}
|
||||
|
||||
private async Task<string> GetNormalizedTemplateNameAsync(Job job, Guid unitId)
|
||||
{
|
||||
// Создаём TemplateForShortcodes "на лету", без запроса к БД
|
||||
var templateForShortcodes = new TemplateForShortcodes
|
||||
{
|
||||
Id = Guid.Empty, // шаблон ещё не создан
|
||||
Index = null,
|
||||
JobId = job.Id,
|
||||
UnitId = unitId,
|
||||
Job = new JobForShortcodes
|
||||
{
|
||||
Group = job.Group == null ? null : new JobGroupForShortcodes
|
||||
{
|
||||
GroupingUnitFieldId = job.Group.GroupingUnitFieldId,
|
||||
GroupType = job.Group.GroupType == null ? null : new JobGroupTypeForShortcodes
|
||||
{
|
||||
Code = job.Group.GroupType.Code
|
||||
},
|
||||
GroupName = job.Group.GroupName
|
||||
},
|
||||
Tnk = job.Tnk == null ? null : new TnkForShortcodes
|
||||
{
|
||||
Name = job.Tnk.Name,
|
||||
ShortName = job.Tnk.ShortName ?? ""
|
||||
},
|
||||
WorkName = job.WorkName,
|
||||
Name = job.Name
|
||||
},
|
||||
UnitsInTemplate = new List<UnitInTemplateForShortcodes>() // для простого шаблона
|
||||
};
|
||||
|
||||
var rawName = await shortcodesService.ApplyShortcodesAsync(job.TemplateNameMask, templateForShortcodes);
|
||||
return rawName.ToUpper();
|
||||
}
|
||||
|
||||
private async Task<DateTimeOffset> GetNextRunAsync(Job job, DateTimeOffset? currentNextRun = null)
|
||||
{
|
||||
var now = DateTimeOffset.UtcNow;
|
||||
if (currentNextRun.HasValue && currentNextRun.Value > now)
|
||||
{
|
||||
return currentNextRun.Value;
|
||||
}
|
||||
|
||||
var referenceDate = job.Group?.ReferenceDate ?? now;
|
||||
return await esppScheduleTransformService.GetNextDateAsync(job.GroupId, referenceDate);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,93 @@
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using PARR.Common.Domain;
|
||||
using PARR.Constants;
|
||||
using PARR.DAL.Models;
|
||||
using PARR.DAL.Services.Interfaces;
|
||||
using PARR.TemplateMatcher.Services.Interfaces;
|
||||
|
||||
namespace PARR.TemplateMatcher.Services.Implementations;
|
||||
|
||||
internal class TemplateReuser : ITemplateReuser
|
||||
{
|
||||
private const int UnusedCandidateBatchSize = 10;
|
||||
|
||||
private readonly ILogger<TemplateReuser> logger;
|
||||
private readonly ITemplateService templateService;
|
||||
|
||||
public TemplateReuser(
|
||||
ILogger<TemplateReuser> logger,
|
||||
ITemplateService templateService)
|
||||
{
|
||||
this.logger = logger;
|
||||
this.templateService = templateService;
|
||||
}
|
||||
|
||||
public async Task<Template?> TryReuseOneUnusedTemplateAsync(
|
||||
Guid jobId,
|
||||
Guid unitId,
|
||||
HistoryInitiator initiator,
|
||||
int maxAttempts = 3)
|
||||
{
|
||||
for (int attempt = 1; attempt <= maxAttempts; attempt++)
|
||||
{
|
||||
try
|
||||
{
|
||||
var unusedCandidates = await templateService.Get()
|
||||
.AsNoTracking()
|
||||
.Where(t => t.StatusTypeId == TemplateStatusTypeEnum.Unused)
|
||||
.OrderBy(t => t.DateModified ?? t.DateCreated)
|
||||
.Take(UnusedCandidateBatchSize)
|
||||
.ToListAsync();
|
||||
|
||||
if (!unusedCandidates.Any())
|
||||
{
|
||||
logger.LogDebug("Нет Unused-шаблонов (попытка {Attempt}).", attempt);
|
||||
return null;
|
||||
}
|
||||
|
||||
foreach (var candidate in unusedCandidates)
|
||||
{
|
||||
var originalStatus = candidate.StatusTypeId;
|
||||
var originalModified = candidate.DateModified;
|
||||
|
||||
try
|
||||
{
|
||||
candidate.StatusTypeId = TemplateStatusTypeEnum.Updating;
|
||||
candidate.DateModified = DateTimeOffset.UtcNow;
|
||||
|
||||
if (await templateService.CommitAsync(initiator))
|
||||
{
|
||||
logger.LogInformation("Успешно захвачен шаблон {TemplateId} для переиспользования (попытка {Attempt}).",
|
||||
candidate.Id, attempt);
|
||||
return candidate; // Возвращаем захваченный шаблон
|
||||
}
|
||||
|
||||
// Откат при неудаче
|
||||
candidate.StatusTypeId = originalStatus;
|
||||
candidate.DateModified = originalModified;
|
||||
}
|
||||
catch (Exception ex) when (
|
||||
ex is DbUpdateException ||
|
||||
ex.InnerException?.Message.Contains("deadlock", StringComparison.OrdinalIgnoreCase) == true ||
|
||||
ex.InnerException?.Message.Contains("timeout", StringComparison.OrdinalIgnoreCase) == true)
|
||||
{
|
||||
logger.LogWarning(ex, "Конфликт при захвате шаблона {TemplateId} (попытка {Attempt}).", candidate.Id, attempt);
|
||||
candidate.StatusTypeId = originalStatus;
|
||||
candidate.DateModified = originalModified;
|
||||
}
|
||||
}
|
||||
|
||||
if (attempt < maxAttempts)
|
||||
await Task.Delay(Random.Shared.Next(5, 15) * attempt);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger.LogError(ex, "Ошибка в попытке захвата (попытка {Attempt}).", attempt);
|
||||
if (attempt == maxAttempts) throw;
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user