parr_api/PARR.EsppSync/SyncService.cs

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using PARR.Core.Repositories.Interfaces;
using PARR.Core.Repositories.Interfaces.TemplateRepositories;
using PARR.Core.Services.Shortcodes;
using PARR.Domain.Entities;
using PARR.Domain.Entities.Base.History;
using PARR.Domain.Enums;
using PARR.EsppSync.Attributes;
using PARR.EsppSync.Helpers;
using System.Reflection;

namespace PARR.EsppSync
{
    internal class SyncService<EsppObject> : ISyncService<EsppObject> where EsppObject : class, IEsppObject
    {
        private readonly ILogger<SyncService<EsppObject>> _logger;
        private readonly IServiceProvider _serviceProvider;

        public SyncService(
            ILogger<SyncService<EsppObject>> logger,
            IServiceProvider serviceProvider
            )
        {
            _logger = logger;
            _serviceProvider = serviceProvider;
        }


        public async Task SyncEsppObjectAsync(
            string str,
            ParseStringToEsppObject<EsppObject> parseStringToEsppObject,
            ConvertDbToEsppObject<EsppObject> converterDbToEsppObject,
            CustomComparisionCheckAsync<EsppObject>? customComparisionAsync = null,
            AfterParseStringToEsppObjectAsync<EsppObject>? afterParseStringToEsppObjectAsync = null
            )
        {
            _logger.LogDebug("Получил строку. Начинаю работать. Строка: {String}", str);

            if (string.IsNullOrEmpty(str))
            {
                _logger.LogWarning("Получил пустую строку, ничего не делаю.");
                return;
            }

            var esppObject = parseStringToEsppObject.Invoke(str);

            if (esppObject == null)
            {
                _logger.LogWarning("После парсинга строки, esppObject = null. Дальше ничего не буду делать.");
                return;
            }

            // Вызовем кастомный метод, если он есть
            if (afterParseStringToEsppObjectAsync != null)
                await afterParseStringToEsppObjectAsync.Invoke(esppObject);


            using (var scope = _serviceProvider.CreateScope())
            {
                var templateService = scope.ServiceProvider.GetRequiredService<ITemplateRepository>();
                var robotConfigurationService = scope.ServiceProvider.GetRequiredService<IRobotConfigurationRepository>();
                var shortcodesService = scope.ServiceProvider.GetRequiredService<IShortcodesService>();
                var templateRenamePendingRepository = scope.ServiceProvider.GetRequiredService<ITemplateRenamePendingRepository>();

                try
                {
                    #region Проверка, идет ли переименование

                    // Если есть у этого шаблона запись в TemplateRenamePending, значит сейчас идет переименование, пропускаем синхронизацию этого шаблона
                    // Если имя этого шаблона находится в таблице TemplateRenamePending, значит идет переименование связанного шаблона, пропускаем синхронизацию этого шаблона
                    var isPartOfRename = await templateRenamePendingRepository.Get()
                                                                .AnyAsync(t => t.Template.Name == esppObject.TemplateName || t.OldName == esppObject.TemplateName);

                    if (isPartOfRename)
                    {
                        _logger.LogInformation("Пропускаем синхронизацию '{TemplateName}', так как шаблон ({EsppObject}) участвует в процессе переименования.", esppObject.TemplateName, nameof(EsppObject));
                        // Выходим сразу
                        return;
                    }

                    #endregion

                    // Загружаем Template и TemplateForShortcodes в одном запросе
                    var query = templateService.Get()
                                                    .Include(h => h.Unit)
                                                        .ThenInclude(t => t!.UnitValues)
                                                            .ThenInclude(t => t.Value)
                                                    .Include(h => h.Unit)
                                                        .ThenInclude(t => t!.UnitValues)
                                                            .ThenInclude(t => t.Field)
                                                    .Include(t => t.RobotConfigurations)
                                                    .Include(t => t.Job)
                                                        .ThenInclude(j => j.Group)
                                                            .ThenInclude(g => g.GroupType)
                                                    .Include(t => t.Job)
                                                        .ThenInclude(t => t.Group)
                                                            .ThenInclude(t => t.ScheduleExcludeType)
                                                    .Include(t => t.Job)
                                                        .ThenInclude(t => t.Group)
                                                            .ThenInclude(t => t.ScheduleExcludeTypeCalendar)
                                                    .Include(t => t.Job)
                                                        .ThenInclude(j => j.Tnk)
                                                            .ThenInclude(s => s!.Subprocess)
                                                                .ThenInclude(p => p!.Process)
                                                    .Include(t => t.UnitsInTemplate);

                    var template = await query.FirstOrDefaultAsync(t => t.Name == esppObject.TemplateName);

                    if (template == null)
                    {
                        _logger.LogWarning("Найден объект в ЕСПП с именем шаблона '{TemplateName}' незарегистрированный в ПАРР. Строка: {String}", esppObject.TemplateName, str);
                        return;
                    }


                    var dbObjectInEsppObject = converterDbToEsppObject.Invoke(template);

                    await ApplyShortcodesAsync(dbObjectInEsppObject, template, shortcodesService);

                    bool isChanged = false;

                    // если в БД isActive == false, то синхронизировать только по полям из IEsppObject

                    if (dbObjectInEsppObject.IsActive == false)
                    {
                        _logger.LogDebug("Объект деактивирован в ПАРР. Сравниваем только обязательные поля. {TemplateName}", esppObject.TemplateName);
                        var lightDbObj = new EsppLightObject(dbObjectInEsppObject);
                        var lightEsppObject = new EsppLightObject(esppObject);

                        isChanged = IsChanged(lightEsppObject, lightDbObj, esppObject.TemplateName);
                    }
                    else
                    {
                        _logger.LogDebug("Объект активирован в ПАРР. Сравниваем все поля. {TemplateName}", esppObject.TemplateName);
                        isChanged = IsChanged(esppObject, dbObjectInEsppObject, esppObject.TemplateName);

                        // выполняем кастомную дополнительную проверку (только если isChanged==false, чтоб лишний раз не гонять)
                        if (!isChanged)
                        {
                            if (customComparisionAsync != null)
                            {
                                // добавлена дополнительная проверка
                                var isCustomComparision = await customComparisionAsync.Invoke(esppObject, dbObjectInEsppObject, template.Id);
                                if (isCustomComparision)
                                {
                                    _logger.LogDebug("Дополнительная проверка прошла.");
                                }
                                else
                                {
                                    // если дополнительная проверка не прошла, то говорим что есть изменения
                                    isChanged = true;
                                    _logger.LogDebug("Дополнительная проверка не прошла, ставим статус isChanged: {isChanged}", isChanged);
                                }
                            }
                            else
                            {
                                _logger.LogDebug("Дополнительная проверка отсутствует");
                            }
                        }
                    }

                    if (isChanged)
                    {
                        _logger.LogDebug("Есть изменения, требуется обновление. {TemplateName}", esppObject.TemplateName);

                        var config = robotConfigurationService.GetFromTemplateByRobotCode(esppObject.Robot, template);

                        // Если предыдущий статус был Create или Ок, то ставим ему Update
                        // пусть даже Create завершился с ошибками, но раз он уже есть в ЕСПП, то изменим на Update, сбросим все счетчики и пусть попробует обновить и исправить все
                        if (config.TaskStatusCode != (int)TaskStatusEnum.Updating)
                        {
                            //SetUpdateStatus(ref template, robotConfigurationService, esppObject.Robot);

                            var isChangedStatus = robotConfigurationService.SetUpdateTaskStatusIfAllow(config);

                            if (isChangedStatus)
                            {
                                if (!await templateService.CommitAsync(GetInitiator()))
                                    _logger.LogError("Не удалось изменить запись Template {TemplateName}, Robot: {Robot}", template.Name, esppObject.Robot);
                                else
                                    _logger.LogInformation("Установлен принудительный статус {TaskStatus}, Template {templateName}, Robot: {Robot}", TaskStatusEnum.Updating, template.Name, esppObject.Robot);
                            }
                            else
                            {
                                _logger.LogInformation("Нельзя установить статус Updating для шаблона {templateName}, так как текущий статус это запрещает.", template.Name);
                            }
                        }
                        else
                        {
                            // Если пред статус был Update, то ничего не делаем, так его и оставляем, не сбрасывам кол-во попыток и ошибок
                            _logger.LogInformation("Есть изменения в Template {TemplateName}, но предыдущий статус TaskStatusCode: {TaskStatusCode}. Не меняем статус, будем разбираться вручную.", template.Name, (TaskStatusEnum)config.TaskStatusCode);
                        }

                    }//надо ли проверять если не изменился, но был статус Updating не понятно. Доверяем роботу пока, что после окончания работ он точно сообщит 
                    else
                    {
                        _logger.LogDebug("Нет изменений, обновление не требуется. {TemplateName}", esppObject.TemplateName);

                        //если все поля совпали
                        //проверяем, какой был статус предыдущий статус в БД, если он был не Ок, то ставим ему ОК
                        var robotConfig = robotConfigurationService.GetFromTemplateByRobotCode(esppObject.Robot, template);
                        if (robotConfig.TaskStatusCode != (int)TaskStatusEnum.Ok)
                        {
                            robotConfigurationService.ChangeTaskStatus(TaskStatusEnum.Ok, robotConfig);
                            if (!await templateService.CommitAsync(GetInitiator()))
                                _logger.LogError("Не удалось изменить запись Template {TemplateName}, Robot: {Robot}", template.Name, esppObject.Robot);
                            else
                                _logger.LogInformation("Установлен принудительный статус {TaskStatus}, Template {TemplateName}, Robot: {Robot}", TaskStatusEnum.Ok, template.Name, esppObject.Robot);
                        }
                    }
                }
                catch (Exception ex)
                {
                    _logger.LogError(ex, "Ошибка синхронизации объекта АСУ ЕСПП {TemplateName}, {EsppObject}", esppObject.TemplateName, nameof(EsppObject));
                }
            }
        }


        /// <summary>
        /// Получить инициатора изменений для сохранения в БД
        /// </summary>
        /// <returns></returns>
        private IHistoryInitiator GetInitiator()
        {
            return new HistoryInitiator
            {
                InitiatorComment = "Обновление статуса синхронизации, SyncService.",
                InitiatorParrComponentId = typeof(EsppObject).Name.Contains("Template") ? ParrComponentsEnum.EsppTemplateSync : ParrComponentsEnum.EsppScheduleSync
            };
        }


        /// <summary>
        /// Применяем шорткоды
        /// </summary>
        /// <param name="dbObjectInEsppObject"></param>
        /// <param name="template"></param>
        /// <param name="shortcodesService"></param>
        /// <returns></returns>
        private async Task ApplyShortcodesAsync(EsppObject dbObjectInEsppObject, Template template, IShortcodesService shortcodesService)
        {
            // Проверяем наличие Shortcode в полях объекта из БД
            var properties = dbObjectInEsppObject.GetType().GetProperties();

            foreach (PropertyInfo property in properties)
            {
                if (property.PropertyType == typeof(string))
                {
                    var value = property.GetValue(dbObjectInEsppObject)?.ToString();
                    if (!string.IsNullOrEmpty(value))
                    {
                        // Передаём исходный template — он уже загружен с Include
                        var processedValue = await shortcodesService.ApplyShortcodesAsync(value, template);
                        property.SetValue(dbObjectInEsppObject, processedValue);
                    }
                }
            }
        }


        /// <summary>
        /// Сравнение объектов
        /// </summary>
        /// <param name="esppObj"></param>
        /// <param name="dbObj"></param>
        /// <param name="templateName"></param>
        /// <returns></returns>
        private bool IsChanged(object esppObj, object dbObj, string templateName)
        {
            var dbType = dbObj.GetType();
            var esppType = esppObj.GetType();

            foreach (var dbProp in dbType.GetProperties())
            {
                // Пропускаем свойства, помеченные атрибутом SkipComparison
                if (Attribute.IsDefined(dbProp, typeof(SkipComparisonAttribute)))
                {
                    _logger.LogDebug("Пропущено сравнение поля {PropertyName} (помечено [SkipComparison]). Шаблон: {TemplateName}", dbProp.Name, templateName);
                    continue;
                }

                // Значение из объекта БД
                //var dbValue = dbObj.GetType().GetProperty(prop.Name)?.GetValue(dbObj, null);
                var dbValue = dbProp.GetValue(dbObj);

                // Ищем аналогичное свойство в объекте из ЕСПП по имени
                //var esppValue = esppObj.GetType().GetProperty(dbProp.Name)?.GetValue(esppObj, null);
                var esppProp = esppType.GetProperty(dbProp.Name);
                var esppValue = esppProp?.GetValue(esppObj);

                // Replace("\r","").Replace("\n","") - в подробном описании могут быть переносы строк, в Rabbit прилетает без переносов. Убираем переносы для стравнения
                // Если значение null, хелпер Normalize вернет string.Empty, что предотвратит NRE и ложные срабатывания.
                var dbValueStr = EsppSyncHelpers.Normalize(dbValue?.ToString());
                var esppValueStr = EsppSyncHelpers.Normalize(esppValue?.ToString());

                if (dbValueStr != esppValueStr)
                {
                    _logger.LogInformation("Не совпадают поля ({PropertyName}). dbValueStr: {DbValueStr}, esppValueStr: {EsppValueStr}. Имя шаблона: {TemplateName}", dbProp.Name, dbValueStr, esppValueStr, templateName);

                    return true;
                }
            }

            return false;
        }

    }
}