114 lines
4.5 KiB
C#
114 lines
4.5 KiB
C#
using Microsoft.Extensions.Logging;
|
||
using PARR.BLL.Services.Interfaces;
|
||
using PARR.BLL.Settings;
|
||
using PARR.EsppTemplateSync.Services;
|
||
|
||
namespace PARR.EsppTemplateSync
|
||
{
|
||
internal class TemplateSyncer : ITemplateSyncer
|
||
{
|
||
private readonly ILogger<TemplateSyncer> logger;
|
||
private readonly IParserService parserService;
|
||
private readonly IFileService fileService;
|
||
private readonly string dirPath;
|
||
private readonly string filterExtensions;
|
||
|
||
private FileSystemWatcher? watcher;
|
||
|
||
public TemplateSyncer(
|
||
StorageSettings storageSettings,
|
||
ILogger<TemplateSyncer> logger,
|
||
IParserService parserService,
|
||
IFileService fileService
|
||
)
|
||
{
|
||
this.logger = logger;
|
||
this.parserService = parserService;
|
||
this.fileService = fileService;
|
||
|
||
if (storageSettings.EsppTemplates == null)
|
||
{
|
||
logger.LogError("Нет секции настроек хранилища. StorageSettings, EsppTemplates");
|
||
throw new Exception("Нет секции настроек хранилища. StorageSettings, EsppTemplates");
|
||
}
|
||
|
||
string dirPath = Path.Combine(storageSettings.EsppTemplates.TemplatePath);
|
||
this.dirPath = Path.Combine(storageSettings.StoragePath, dirPath);
|
||
|
||
filterExtensions = string.Join(",", storageSettings.EsppTemplates!.AllowedExtensions).Replace(".", "*.");
|
||
}
|
||
|
||
public void StartWatching()
|
||
{
|
||
//смотрим, доступна ли папка
|
||
if (!Directory.Exists(dirPath))
|
||
{
|
||
logger.LogError($"Не найдена папка: {dirPath}.");
|
||
throw new Exception($"Не найдена папка: {dirPath}.");
|
||
}
|
||
|
||
|
||
// сначала обрабатываем существующие файлы, до тех пор пока все не обработаем
|
||
// после обработки всех файлов, запускаем вотчер
|
||
GetExistingFilesAsync();
|
||
|
||
watcher = new FileSystemWatcher(dirPath);
|
||
watcher.NotifyFilter = NotifyFilters.FileName;
|
||
//watcher.Changed += OnChanged;
|
||
//todo: тут await???
|
||
watcher.Created += OnChanged;
|
||
|
||
watcher.Filter = filterExtensions;
|
||
watcher.EnableRaisingEvents = true;
|
||
|
||
logger.LogInformation($"--- --- --- FileWatcher запущен --- --- ---");
|
||
}
|
||
|
||
public void StopWatching()
|
||
{
|
||
watcher?.Dispose();
|
||
logger.LogInformation($"=== === === FileWatcher остановлен === === ===");
|
||
}
|
||
|
||
private async void OnChanged(object sender, FileSystemEventArgs e)
|
||
{
|
||
var path = e.FullPath;
|
||
await ParseFileAsync(path);
|
||
}
|
||
|
||
private async void GetExistingFilesAsync()
|
||
{
|
||
// при первом запуске воркера, обрабатываем существующие файлы
|
||
var files = Directory.GetFiles(this.dirPath, filterExtensions);
|
||
|
||
logger.LogInformation($"Запуск первоначальной загрузки файлов после старта сервиса. (До старта вотчера). Найдено файлов: {files.Length} шт.");
|
||
|
||
foreach (var file in files)
|
||
await ParseFileAsync(file);
|
||
|
||
//если были файлы, запустим еще раз ручную обработку, вдруг за это время еще загрузили, а вотчер еще не был запущен
|
||
//запускаем до тех пор, пока не останется необработанных файлов
|
||
if (files.Any())
|
||
GetExistingFilesAsync();
|
||
}
|
||
|
||
|
||
private async Task ParseFileAsync(string path)
|
||
{
|
||
logger.LogInformation($"--- --- Найден файл. Готов для парсинга {path} --- ---");
|
||
var parseResult = await parserService.ParseAsync(path);
|
||
|
||
if (parseResult)
|
||
{
|
||
logger.LogInformation($"Парсинг успешно завершен. Удаляю файл {path}");
|
||
var removeResult = fileService.DeleteFile(path);
|
||
}
|
||
else
|
||
{
|
||
logger.LogError($"Парсинг завершен c ошибкой. Файл не удален {path}");
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|