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

Убрал все эти watchers. Написал свой простой как 3 копейки.

Browse Source
This commit is contained in:
Mikhail Trubnikov
2023-08-28 16:03:39 +10:00
parent 04e4122ffc
commit a11885ded0
8 changed files with 62 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
PARR.EsppTemplateSync/EsppTemplateSyncInstaller.cs
View File

@@ -3,6 +3,7 @@ using Microsoft.Extensions.DependencyInjection;
using PARR.BLL;
using PARR.DAL;
using PARR.EsppTemplateSync.Services;
using PARR.EsppTemplateSync.Settings;
namespace PARR.EsppTemplateSync
{
@@ -13,6 +14,10 @@ namespace PARR.EsppTemplateSync
services.InstallBllServices(configuration);
services.InstallDalServices(configuration);
var globalSettings = new GlobalSettings();
configuration.GetSection(nameof(GlobalSettings)).Bind(globalSettings);
services.AddSingleton(globalSettings);
services.AddTransient<ITemplateSyncer, TemplateSyncer>();
services.AddTransient<IParserService, ParserService>();
}

2
PARR.EsppTemplateSync/ITemplateSyncer.cs
View File

@@ -2,7 +2,7 @@
{
public interface ITemplateSyncer
{
void StartWatching();
Task StartWatchingAsync();
void StopWatching();
}
}

7
PARR.EsppTemplateSync/Settings/GlobalSettings.cs Normal file
View File

@@ -0,0 +1,7 @@
namespace PARR.EsppTemplateSync.Settings
{
internal class GlobalSettings
{
public int CheckIntervalSeconds { get; set; } = 5;
}
}

66
PARR.EsppTemplateSync/TemplateSyncer.cs
View File

@@ -2,6 +2,7 @@
using PARR.BLL.Services.Interfaces;
using PARR.BLL.Settings;
using PARR.EsppTemplateSync.Services;
using PARR.EsppTemplateSync.Settings;
namespace PARR.EsppTemplateSync
{
@@ -10,22 +11,24 @@ namespace PARR.EsppTemplateSync
private readonly ILogger<TemplateSyncer> logger;
private readonly IParserService parserService;
private readonly IFileService fileService;
private readonly GlobalSettings globalSettings;
private readonly string dirPath;
private readonly string filterExtensions;
private FileSystemWatcher? watcher;
//private FileSystemWatcher? watcher;
public TemplateSyncer(
StorageSettings storageSettings,
ILogger<TemplateSyncer> logger,
IParserService parserService,
IFileService fileService
IFileService fileService,
GlobalSettings globalSettings
)
{
this.logger = logger;
this.parserService = parserService;
this.fileService = fileService;
this.globalSettings = globalSettings;
if (storageSettings.EsppTemplates == null)
{
logger.LogError("Нет секции настроек хранилища. StorageSettings, EsppTemplates");
@@ -38,7 +41,7 @@ namespace PARR.EsppTemplateSync
filterExtensions = string.Join(",", storageSettings.EsppTemplates!.AllowedExtensions).Replace(".", "*.");
}
public void StartWatching()
public async Task StartWatchingAsync()
{
//смотрим, доступна ли папка
if (!Directory.Exists(dirPath))
@@ -47,49 +50,64 @@ namespace PARR.EsppTemplateSync
throw new Exception($"Не найдена папка: {dirPath}.");
}
logger.LogInformation($"Запущена проверка директории. Интервал: {globalSettings.CheckIntervalSeconds} секунд. Фильтр: {filterExtensions}");
while (true)
{
await GetFilesAsync();
await Task.Delay(globalSettings.CheckIntervalSeconds * 1000);
}
// сначала обрабатываем существующие файлы, до тех пор пока все не обработаем
// после обработки всех файлов, запускаем вотчер
GetExistingFilesAsync();
//await GetFilesAsync();
watcher = new FileSystemWatcher(dirPath);
watcher.NotifyFilter = NotifyFilters.FileName;
//watcher.Changed += OnChanged;
//todo: тут await???
watcher.Created += OnChanged;
// код ниже, это то что надо использовать, но в доккере не работает watcher
////--- watcher
//watcher = new FileSystemWatcher(dirPath);
//watcher.NotifyFilter = NotifyFilters.FileName;
////watcher.Changed += OnChanged;
////todo: тут await???
//watcher.Created += OnChanged;
watcher.Filter = filterExtensions;
watcher.EnableRaisingEvents = true;
//watcher.Filter = filterExtensions;
//watcher.EnableRaisingEvents = true;
//watcher.IncludeSubdirectories = false;
logger.LogInformation($"--- --- --- FileWatcher запущен --- --- ---");
////=== watcher
//logger.LogInformation($"--- --- --- FileWatcher запущен --- --- ---");
}
public void StopWatching()
{
watcher?.Dispose();
//watcher?.Dispose();
logger.LogInformation($"=== === === FileWatcher остановлен === === ===");
}
private async void OnChanged(object sender, FileSystemEventArgs e)
{
var path = e.FullPath;
await ParseFileAsync(path);
}
//private async void OnChanged(object sender, FileSystemEventArgs e)
//{
// var path = e.FullPath;
// await ParseFileAsync(path);
//}
private async void GetExistingFilesAsync()
private async Task GetFilesAsync()
{
// при первом запуске воркера, обрабатываем существующие файлы
// обрабатываем существующие файлы
var files = Directory.GetFiles(this.dirPath, filterExtensions);
logger.LogInformation($"Запуск первоначальной загрузки файлов после старта сервиса. (До старта вотчера). Найдено файлов: {files.Length} шт.");
//logger.LogInformation($"Запуск первоначальной загрузки файлов после старта сервиса. (До старта вотчера). Найдено файлов: {files.Length} шт.");
logger.LogInformation($"Найдено файлов: {files.Length} шт.");
foreach (var file in files)
await ParseFileAsync(file);
//если были файлы, запустим еще раз ручную обработку, вдруг за это время еще загрузили, а вотчер еще не был запущен
//запускаем до тех пор, пока не останется необработанных файлов
if (files.Any())
GetExistingFilesAsync();
//if (files.Any())
// await GetFilesAsync();
}