mikhail/parr_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(aihit-syncer): ограничение использования scope. Создан отдельный SyncerService

Browse Source
This commit is contained in:
Mikhail Kuznetsov
2024-02-06 16:54:40 +10:00
parent 0697d5b6b4
commit 90306b7a63
4 changed files with 401 additions and 265 deletions
Download Patch File Download Diff File Expand all files Collapse all files

354
PARR.AIHITSyncer/AihitSyncer.cs
View File

@@ -1,60 +1,50 @@
using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using PARR.AIHITSyncer.Services;
using PARR.AIHITSyncer.Settings; using PARR.AIHITSyncer.Settings;
using PARR.BLL.Domain.Mq;
using PARR.BLL.Services.Interfaces; using PARR.BLL.Services.Interfaces;
using PARR.DAL.Contracts;
using PARR.DAL.Extensions;
using PARR.DAL.Models; using PARR.DAL.Models;
using PARR.DAL.Services.Interfaces;
using System.Text.RegularExpressions;
namespace PARR.AIHITSyncer namespace PARR.AIHITSyncer
{ {
internal class AihitSyncer : IAihitSyncer internal class AihitSyncer : IAihitSyncer
{ {
private readonly ILogger<AihitSyncer> logger; private readonly ILogger<AihitSyncer> logger;
private readonly WorkerSettings workerSettings;
private readonly IMqService mqService; private readonly IMqService mqService;
private readonly MqSettings mqSettings; private readonly MqSettings mqSettings;
private readonly ITransformService transformService;
private readonly IServiceProvider serviceProvider; private readonly IServiceProvider serviceProvider;
public List<ApplicationType> AppTypes { get; private set; } = new List<ApplicationType>();
public AihitSyncer( public AihitSyncer(
ILogger<AihitSyncer> logger, ILogger<AihitSyncer> logger,
WorkerSettings workerSettings,
IMqService mqService, IMqService mqService,
MqSettings mqSettings, MqSettings mqSettings,
ITransformService transformService,
IServiceProvider serviceProvider IServiceProvider serviceProvider
) )
{ {
this.logger = logger; this.logger = logger;
this.workerSettings = workerSettings;
this.mqService = mqService; this.mqService = mqService;
this.mqSettings = mqSettings; this.mqSettings = mqSettings;
this.transformService = transformService;
this.serviceProvider = serviceProvider; this.serviceProvider = serviceProvider;
} }
private async Task GetAppTypesAsync()
{
if (AppTypes == null || AppTypes.Count == 0)
using (var scope = serviceProvider.CreateScope())
{
var appTypesService = scope.ServiceProvider.GetService<IApplicationTypeService>();
if (appTypesService == null)
throw new Exception("Не смог получить серивс IApplicationTypeService, scope.ServiceProvider.GetService<IApplicationTypeService>()");
AppTypes = await appTypesService.Get().ToListAsync();
}
}
public void Start() public void Start()
{ {
logger.LogInformation("Запуск сервиса синхронизации данных из АИХИТ и ПАРР."); logger.LogInformation("Запуск сервиса синхронизации данных из АИХИТ и ПАРР.");
var isConnected = mqService.InitConsumer(mqSettings, SyncDataAsync); //var isConnected = mqService.InitConsumer(mqSettings, SyncDataAsync);
var isConnected = mqService.InitConsumer(mqSettings, async (string msg) =>
{
using (var scope = serviceProvider.CreateScope())
{
var syncerService = scope.ServiceProvider.GetService<ISyncerService>();
if (syncerService == null)
throw new Exception("Не смог получить серивс ISyncerService, scope.ServiceProvider.GetService<ISyncerService>()");
await syncerService.SyncAsync(msg);
//await Task.CompletedTask;
}
});
if (!isConnected) if (!isConnected)
throw new Exception("Ошибка при подключении к RabbitMq"); throw new Exception("Ошибка при подключении к RabbitMq");
@@ -64,273 +54,107 @@ namespace PARR.AIHITSyncer
mqService.Dispose(); mqService.Dispose();
} }
private async Task SyncDataAsync(string msg) //private async Task SyncDataAsync(string msg)
{ //{
var objFromQuery = transformService.GetModelFromJson<AihitDataMq>(msg); // //SyncService
if (objFromQuery == null) // using (var scope = serviceProvider.CreateScope())
return; // {
// var service = scope.ServiceProvider.GetService<SyncerService>();
// //if (service == null)
// // throw new Exception("Не смог получить серивс IHostService, scope.ServiceProvider.GetService<IHostService>()");
using (var scope = serviceProvider.CreateScope()) // await service.StartAsync(msg);
{
var hostService = scope.ServiceProvider.GetService<IHostService>();
if (hostService == null)
throw new Exception("Не смог получить серивс IHostService, scope.ServiceProvider.GetService<IHostService>()");
await SyncHostToScopeAsync(hostService, objFromQuery); // //await SyncHostToScopeAsync(hostService, objFromQuery);
await GetAppTypesAsync(); // //await GetAppTypesAsync();
} // }
logger.LogDebug($"Закончил работу с сообщением: {msg}"); //var objFromQuery = transformService.GetModelFromJson<AihitDataMq>(msg);
//await Task.CompletedTask; //if (objFromQuery == null)
} // return;
private async Task SyncHostToScopeAsync(IHostService hostService, AihitDataMq objFromQuery) //using (var scope = serviceProvider.CreateScope())
{ //{
//ищем существующий хост в БД // var hostService = scope.ServiceProvider.GetService<IHostService>();
var host = await hostService.GetHostWithAppsAsync(objFromQuery.IP); // if (hostService == null)
var isNew = false; // throw new Exception("Не смог получить серивс IHostService, scope.ServiceProvider.GetService<IHostService>()");
//если не нашли - создаём
if (host == null)
{
isNew = true;
host = await CreateHostAsync(hostService, objFromQuery);
}
else
{
logger.LogDebug($"Найден хост в БД: {host!.Ek}({host.IP})");
//проверям и обновляем поля
await SyncHostFieldsAsync(hostService, host, objFromQuery);
}
//получаем лист ПО из объекта // await SyncHostToScopeAsync(hostService, objFromQuery);
var appsInObj = await GetAppInObjectAsync(host, objFromQuery);
await SyncApplicationAndHostAsync(host, appsInObj, !isNew); // await GetAppTypesAsync();
} //}
private async Task<List<Application>> GetAppInObjectAsync(Host? host, AihitDataMq objFromQuery) //logger.LogDebug($"Закончил работу с сообщением: {msg}");
{ //await Task.CompletedTask;
var applications = new List<Application>(); //}
if (objFromQuery.APPType != null) //private async Task SyncHostToScopeAsync(IHostService hostService, AihitDataMq objFromQuery)
{ //{
var appList = objFromQuery.APPType.Split(new char[] { ',', ';' }).Distinct().ToList(); // //ищем существующий хост в БД
foreach (var app in appList) // var host = await hostService.GetHostWithAppsAsync(objFromQuery.IP);
{ // var isNew = false;
var created = await CreateAppIfNotExistAsync(app, ApplicationTypesEnum.APP); // //если не нашли - создаём
if (created != null) // if (host == null)
applications.Add(created); // {
} // isNew = true;
} // host = await CreateHostAsync(hostService, objFromQuery);
if (objFromQuery.DBType != null) // }
{ // else
var appList = objFromQuery.DBType.Split(new char[] { ',', ';' }).Distinct().ToList(); // {
foreach (var app in appList) // logger.LogDebug($"Найден хост в БД: {host!.Ek}({host.IP})");
{ // //проверям и обновляем поля
var created = await CreateAppIfNotExistAsync(app, ApplicationTypesEnum.DB); // await SyncHostFieldsAsync(hostService, host, objFromQuery);
if (created != null) // }
applications.Add(created);
}
}
if (objFromQuery.OSType != null)
{
var appList = objFromQuery.OSType.Split(new char[] { ',', ';' }).Distinct().ToList();
foreach (var app in appList)
{
var created = await CreateAppIfNotExistAsync(app, ApplicationTypesEnum.OS);
if (created != null)
applications.Add(created);
}
}
return applications;
}
private async Task SyncHostFieldsAsync(IHostService hostService, Host host, AihitDataMq objFromQuery) // //получаем лист ПО из объекта
{ // var appsInObj = await GetAppInObjectAsync(host, objFromQuery);
var isChanged = false;
if (host.IP != objFromQuery.IP)
{
host.IP = objFromQuery.IP;
isChanged = true;
}
if (host.EkStatusCode != ResolveCode(objFromQuery.Status))
{
host.EkStatusCode = ResolveCode(objFromQuery.Status);
isChanged = true;
}
if (objFromQuery.WorkGroup != null && (host.WorkGroup == null || !host.WorkGroup!.Equals(objFromQuery.WorkGroup)))
{
host.WorkGroup = objFromQuery.WorkGroup;
isChanged = true;
}
if (host.ResponseAreaCode != ((ResolveCode(objFromQuery.ResponseArea) == 0) ? 99 : ResolveCode(objFromQuery.ResponseArea)))
{//TODO Возможно проще выгружать с помощью INCLUDE зону ответственности и сравнивать string
host.ResponseAreaCode = ((ResolveCode(objFromQuery.ResponseArea) == 0) ? 99 : ResolveCode(objFromQuery.ResponseArea));
isChanged = true;
}
if (isChanged)
{
host.DateModified = DateTimeOffset.UtcNow;
if (!await hostService.CommitAsync())
logger.LogError($"Не удалось обновить узел {host.Ek}({host.IP})");
else
logger.LogInformation($"Обновлён Host: {host.Ek}({host.Id})");
}
}
private async Task<Host?> CreateHostAsync(IHostService hostService, AihitDataMq objFromQuery) // await SyncApplicationInHostAsync(host, appsInObj, !isNew);
{ //}
var id = Guid.NewGuid();
var host = new Host
{
Id = id,
Ek = objFromQuery.EK,
IP = objFromQuery.IP,
EkStatusCode = ResolveCode(objFromQuery.Status),
WorkGroup = objFromQuery.WorkGroup,
ResponseAreaCode = ResolveCode(objFromQuery.ResponseArea)
};
if (!await hostService.CreateAsync(host) || !await hostService.CommitAsync())
logger.LogError($"Не удалось создать узел {host.Ek}({host.IP})");
else
logger.LogInformation($"----- Создан узел: {host.Id} -----");
return await hostService.GetHostWithAppsAsync(host.IP);
}
/// <summary>
/// Возвращает первую цифру из строки, котроая является кодом статуса или зоны ответственности для ЭК
/// </summary>
/// <param name="field"></param>
/// <returns></returns>
private int ResolveCode(string field)
{
var pattern = "\\d+";
var regex = new Regex(pattern);
int.TryParse(regex.Match(field).Value, out int result); //private async Task<Host?> CreateHostAsync(IHostService hostService, AihitDataMq objFromQuery)
//{
// var id = Guid.NewGuid();
// var host = new Host
// {
// Id = id,
// Ek = objFromQuery.EK,
// IP = objFromQuery.IP,
// EkStatusCode = ResolveCode(objFromQuery.Status),
// WorkGroup = objFromQuery.WorkGroup,
// ResponseAreaCode = ResolveCode(objFromQuery.ResponseArea)
// };
return result; // if (!await hostService.CreateAsync(host) || !await hostService.CommitAsync())
} // logger.LogError($"Не удалось создать узел {host.Ek}({host.IP})");
// else
private async Task<Application?> CreateAppIfNotExistAsync(string appName, ApplicationTypesEnum type) // logger.LogInformation($"----- Создан узел: {host.Id} -----");
{
if (string.IsNullOrEmpty(appName) || string.IsNullOrWhiteSpace(appName)) return null;
using (var scope = serviceProvider.CreateScope()) // return await hostService.GetHostWithAppsAsync(host.IP);
{ //}
var appService = scope.ServiceProvider.GetService<IApplicationService>();
if (appService == null)
throw new Exception("Не смог получить серивс IApplicationService, scope.ServiceProvider.GetService<IApplicationService>()");
var existApp = await appService.GetByNameAsync(appName);
if (existApp != null)
return existApp;
//Создаем
var appType = GetAppTypeByName(type);
if (appType == null)
{
logger.LogError($"Не удалось создать запись в таблице Applications: {appName}, так как не получил AppType: {type.ToString()}");
return null;
}
var app = new Application
{
Id = Guid.NewGuid(),
Name = appName.Trim(),
ApplicationTypeId = appType.Id
};
if (!await appService.CreateAsync(app) || !await appService.CommitAsync())
logger.LogError($"Не удалось создать запись в таблице Application: {appName}, {app.ToJson()}");
else
logger.LogInformation($"Создана запись а таблице Application: {appName}, {app.ToJson()}");
return await appService.GetAsync(app.Id);
}
}
/// <summary>
/// Метод синхронизации
/// </summary>
/// <param name="host">Хост</param>
/// <param name="hostApplications">Список программного обеспечения</param>
/// <param name="isUpdateDateModified">Признак обновления поля DateModified</param>
/// <returns></returns>
private async Task SyncApplicationAndHostAsync(Host? host, List<Application> appsInObject, bool isUpdateDateModified = false)
{
var isUpdated = false;
if (host == null)
return;
logger.LogDebug($"Host: {host.Ek}({host.IP}), начало синхронизации приложений ({appsInObject.Count()}) ");
using (var scope = serviceProvider.CreateScope())
{
var appInHostService = scope.ServiceProvider.GetService<IApplicationInHostService>();
if (appInHostService == null)
throw new Exception("Не смог получить серивс IApplicationInHostService, scope.ServiceProvider.GetService<IApplicationInHostService>()");
foreach (var appInObject in appsInObject)
{
var exist = host.ApplicationsInHosts.FirstOrDefault(a => a.ApplicationId == appInObject.Id);
if (exist == null) //private int ResolveCode(string field)
{ //{
//add // var pattern = "\\d+";
logger.LogInformation($"Host: {host.Ek}({host.IP}), добавление нового приложения Application {appInObject.Name}"); // var regex = new Regex(pattern);
var newAppHost = new ApplicationInHost { Id = Guid.NewGuid(), ApplicationId = appInObject.Id, HostId = host.Id }; // int.TryParse(regex.Match(field).Value, out int result);
if (!await appInHostService.CreateAsync(newAppHost))
logger.LogError($"Не удалось создать ApplicationInHost {appInObject.Name}, host: {host.Ek}({host.IP})");
isUpdated = true; // return result;
} //}
}
foreach (var appInHost in host.ApplicationsInHosts)
{
var appToRemove = appsInObject.FirstOrDefault(a => a.Id == appInHost.ApplicationId);
if (appToRemove == null)
{
//todo remove appToRemove
var obj = await appInHostService.Get().FirstOrDefaultAsync(t => t.ApplicationId == appInHost.ApplicationId && t.HostId == host.Id);
if (obj != null)
{
logger.LogInformation($"Host: {host.Ek}({host.IP}), удаление неактуального приложения Application {appInHost.Application?.Name}");
appInHostService.Delete(obj);
if (!await appInHostService.CommitAsync())
logger.LogError($"Не удалось удалить Application {appInHost.Application?.Name} узла {host.Ek}({host.IP})");
isUpdated = true;
}
}
}
if (isUpdated && isUpdateDateModified)
host.DateModified = DateTimeOffset.UtcNow;
if (!await appInHostService.CommitAsync())
logger.LogError($"Не удалось обновить ApplicationInHost для Host: {host.Ek}({host.IP})");
}
logger.LogDebug($"Host: {host.Ek}({host.IP} конец синхронизации приложений");
}
private ApplicationType? GetAppTypeByName(ApplicationTypesEnum type)
{
var existType = AppTypes.FirstOrDefault(t => t.Name == type.ToString());
if (existType == null)
logger.LogError($"Не найден AppType: {type}");
return existType;
}
} }
} }

2
PARR.AIHITSyncer/AihitSyncerInstaller.cs
View File

@@ -1,5 +1,6 @@
using Microsoft.Extensions.Configuration; using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using PARR.AIHITSyncer.Services;
using PARR.AIHITSyncer.Settings; using PARR.AIHITSyncer.Settings;
using PARR.BLL; using PARR.BLL;
using PARR.DAL; using PARR.DAL;
@@ -22,6 +23,7 @@ namespace PARR.AIHITSyncer
services.AddSingleton(mqSettings); services.AddSingleton(mqSettings);
services.AddTransient<IAihitSyncer, AihitSyncer>(); services.AddTransient<IAihitSyncer, AihitSyncer>();
services.AddTransient<ISyncerService, SyncerService>();
} }
} }
} }

7
PARR.AIHITSyncer/Services/ISyncerService.cs Normal file
View File

@@ -0,0 +1,7 @@
namespace PARR.AIHITSyncer.Services
{
public interface ISyncerService
{
Task SyncAsync(string msq);
}
}

303
PARR.AIHITSyncer/Services/SyncerService.cs Normal file
View File

@@ -0,0 +1,303 @@
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using PARR.BLL.Domain.Mq;
using PARR.BLL.Services.Interfaces;
using PARR.DAL.Contracts;
using PARR.DAL.Extensions;
using PARR.DAL.Models;
using PARR.DAL.Services.Interfaces;
using System.Text.RegularExpressions;
namespace PARR.AIHITSyncer.Services
{
internal class SyncerService : ISyncerService
{
private readonly ILogger<SyncerService> logger;
private readonly IHostService hostService;
private readonly IApplicationService appService;
private readonly IApplicationInHostService appInHostService;
private readonly IApplicationTypeService appTypeService;
private readonly ITransformService transformService;
public List<ApplicationType> AppTypes { get; private set; } = new List<ApplicationType>();
public SyncerService(
ILogger<SyncerService> logger,
IHostService hostService,
IApplicationService appService,
IApplicationInHostService appInHostService,
IApplicationTypeService appTypeService,
ITransformService transformService
)
{
this.logger = logger;
this.hostService = hostService;
this.appService = appService;
this.appInHostService = appInHostService;
this.appTypeService = appTypeService;
this.transformService = transformService;
}
public async Task SyncAsync(string msg)
{
await GetAppTypesAsync();
var objFromQuery = transformService.GetModelFromJson<AihitDataMq>(msg);
if (objFromQuery == null)
return;
await SyncHostAsync(objFromQuery);
}
private async Task SyncHostAsync(AihitDataMq objFromQuery)
{
//ищем существующий хост в БД
var host = await hostService.GetHostWithAppsAsync(objFromQuery.IP);
var isNew = false;
//если не нашли - создаём
if (host == null)
{
isNew = true;
host = await CreateHostAsync(objFromQuery);
}
else
{
logger.LogDebug($"Найден хост в БД: {host!.Ek}({host.IP})");
//проверям и обновляем поля
await SyncHostFieldsAsync(host, objFromQuery);
}
//получаем лист ПО из объекта
var appsInObj = await GetAppsInObjectAsync(host, objFromQuery);
await SyncApplicationInHostAsync(host, appsInObj, !isNew);
}
private async Task<Host?> CreateHostAsync(AihitDataMq objFromQuery)
{
var id = Guid.NewGuid();
var host = new Host
{
Id = id,
Ek = objFromQuery.EK,
IP = objFromQuery.IP,
EkStatusCode = ResolveCode(objFromQuery.Status),
WorkGroup = objFromQuery.WorkGroup,
ResponseAreaCode = ResolveCode(objFromQuery.ResponseArea)
};
if (!await hostService.CreateAsync(host) || !await hostService.CommitAsync())
logger.LogError($"Не удалось создать узел {host.Ek}({host.IP})");
else
logger.LogInformation($"----- Создан узел: {host.Id} -----");
return await hostService.GetHostWithAppsAsync(host.IP);
}
private async Task SyncHostFieldsAsync(Host host, AihitDataMq objFromQuery)
{
var isChanged = false;
if (host.IP != objFromQuery.IP)
{
host.IP = objFromQuery.IP;
isChanged = true;
}
if (host.EkStatusCode != ResolveCode(objFromQuery.Status))
{
host.EkStatusCode = ResolveCode(objFromQuery.Status);
isChanged = true;
}
if (objFromQuery.WorkGroup != null && (host.WorkGroup == null || !host.WorkGroup!.Equals(objFromQuery.WorkGroup)))
{
host.WorkGroup = objFromQuery.WorkGroup;
isChanged = true;
}
if (host.ResponseAreaCode != ((ResolveCode(objFromQuery.ResponseArea) == 0) ? 99 : ResolveCode(objFromQuery.ResponseArea)))
{//TODO Возможно проще выгружать с помощью INCLUDE зону ответственности и сравнивать string
host.ResponseAreaCode = ((ResolveCode(objFromQuery.ResponseArea) == 0) ? 99 : ResolveCode(objFromQuery.ResponseArea));
isChanged = true;
}
if (isChanged)
{
host.DateModified = DateTimeOffset.UtcNow;
if (!await hostService.CommitAsync())
logger.LogError($"Не удалось обновить узел {host.Ek}({host.IP})");
else
logger.LogInformation($"Обновлён Host: {host.Ek}({host.Id})");
}
}
private async Task<List<Application>> GetAppsInObjectAsync(Host? host, AihitDataMq objFromQuery)
{
var applications = new List<Application>();
if (objFromQuery.APPType != null)
{
var appList = objFromQuery.APPType.Split(new char[] { ',', ';' }).Distinct().ToList();
foreach (var app in appList)
{
var created = await CreateAppIfNotExistAsync(app, ApplicationTypesEnum.APP);
if (created != null)
applications.Add(created);
}
}
if (objFromQuery.DBType != null)
{
var appList = objFromQuery.DBType.Split(new char[] { ',', ';' }).Distinct().ToList();
foreach (var app in appList)
{
var created = await CreateAppIfNotExistAsync(app, ApplicationTypesEnum.DB);
if (created != null)
applications.Add(created);
}
}
if (objFromQuery.OSType != null)
{
var appList = objFromQuery.OSType.Split(new char[] { ',', ';' }).Distinct().ToList();
foreach (var app in appList)
{
var created = await CreateAppIfNotExistAsync(app, ApplicationTypesEnum.OS);
if (created != null)
applications.Add(created);
}
}
return applications;
}
private async Task<Application?> CreateAppIfNotExistAsync(string appName, ApplicationTypesEnum type)
{
if (string.IsNullOrEmpty(appName) || string.IsNullOrWhiteSpace(appName)) return null;
var existApp = await appService.GetByNameAsync(appName);
if (existApp != null)
return existApp;
//Создаем
var appType = GetAppTypeByName(type);
if (appType == null)
{
logger.LogError($"Не удалось создать запись в таблице Applications: {appName}, так как не получил AppType: {type.ToString()}");
return null;
}
var app = new Application
{
Id = Guid.NewGuid(),
Name = appName.Trim(),
ApplicationTypeId = appType.Id
};
if (!await appService.CreateAsync(app) || !await appService.CommitAsync())
logger.LogError($"Не удалось создать запись в таблице Application: {appName}, {app.ToJson()}");
else
logger.LogInformation($"Создана запись а таблице Application: {appName}, {app.ToJson()}");
return await appService.GetAsync(app.Id);
}
/// <summary>
/// Метод синхронизации
/// </summary>
/// <param name="host">Хост</param>
/// <param name="hostApplications">Список программного обеспечения</param>
/// <param name="isUpdateDateModified">Признак обновления поля DateModified</param>
/// <returns></returns>
private async Task SyncApplicationInHostAsync(Host? host, List<Application> appsInObject, bool isUpdateDateModified = false)
{
var isUpdated = false;
if (host == null)
return;
logger.LogDebug($"Host: {host.Ek}({host.IP}), начало синхронизации приложений ({appsInObject.Count()}) ");
foreach (var appInObject in appsInObject)
{
var exist = host.ApplicationsInHosts.FirstOrDefault(a => a.ApplicationId == appInObject.Id);
if (exist == null)
{
//add
logger.LogInformation($"Host: {host.Ek}({host.IP}), добавление нового приложения Application {appInObject.Name}");
var newAppHost = new ApplicationInHost { Id = Guid.NewGuid(), ApplicationId = appInObject.Id, HostId = host.Id };
if (!await appInHostService.CreateAsync(newAppHost))
logger.LogError($"Не удалось создать ApplicationInHost {appInObject.Name}, host: {host.Ek}({host.IP})");
isUpdated = true;
}
}
foreach (var appInHost in host.ApplicationsInHosts)
{
var appToRemove = appsInObject.FirstOrDefault(a => a.Id == appInHost.ApplicationId);
if (appToRemove == null)
{
//todo remove appToRemove
var obj = await appInHostService.Get().FirstOrDefaultAsync(t => t.ApplicationId == appInHost.ApplicationId && t.HostId == host.Id);
if (obj != null)
{
logger.LogInformation($"Host: {host.Ek}({host.IP}), удаление неактуального приложения Application {appInHost.Application?.Name}");
appInHostService.Delete(obj);
if (!await appInHostService.CommitAsync())
logger.LogError($"Не удалось удалить Application {appInHost.Application?.Name} узла {host.Ek}({host.IP})");
isUpdated = true;
}
}
}
if (isUpdated && isUpdateDateModified)
host.DateModified = DateTimeOffset.UtcNow;
if (!await appInHostService.CommitAsync())
logger.LogError($"Не удалось обновить ApplicationInHost для Host: {host.Ek}({host.IP})");
logger.LogDebug($"Host: {host.Ek}({host.IP} конец синхронизации приложений");
}
private ApplicationType? GetAppTypeByName(ApplicationTypesEnum type)
{
var existType = AppTypes.FirstOrDefault(t => t.Name == type.ToString());
if (existType == null)
logger.LogError($"Не найден AppType: {type}");
return existType;
}
/// <summary>
/// Возвращает первую цифру из строки, котроая является кодом статуса или зоны ответственности для ЭК
/// </summary>
/// <param name="field"></param>
/// <returns></returns>
private int ResolveCode(string field)
{
var pattern = "\\d+";
var regex = new Regex(pattern);
int.TryParse(regex.Match(field).Value, out int result);
return result;
}
private async Task GetAppTypesAsync()
{
if (AppTypes == null || AppTypes.Count == 0)
AppTypes = await appTypeService.Get().ToListAsync();
}
}
}