78 lines
3.5 KiB
C#
78 lines
3.5 KiB
C#
using File_Watcher.Models;
|
|
using Microsoft.Extensions.Hosting.WindowsServices;
|
|
|
|
namespace File_Watcher;
|
|
|
|
public partial class Worker : BackgroundService
|
|
{
|
|
|
|
private readonly bool _IsWindowsService;
|
|
private readonly ILogger<Worker> _Logger;
|
|
private readonly AppSettings _AppSettings;
|
|
|
|
public Worker(IServiceProvider serviceProvider, ILogger<Worker> logger, AppSettings appSettings, List<string> collection)
|
|
{
|
|
_Logger = logger;
|
|
_AppSettings = appSettings;
|
|
logger.LogInformation("{buildNumber}-{gitCommitSeven}", _AppSettings.BuildNumber, _AppSettings.GitCommitSeven);
|
|
try
|
|
{ logger.LogInformation("<{folder}>", Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData)); }
|
|
catch (Exception) { }
|
|
_IsWindowsService = collection.Contains(nameof(WindowsServiceLifetime));
|
|
}
|
|
|
|
private void Body()
|
|
{
|
|
_Logger.LogInformation("A) Next execute will be at {date}", DateTime.Now.AddMilliseconds(_AppSettings.MillisecondsDelay).ToString("yyyy-MM-dd hh:mm:ss.fff tt"));
|
|
if (!Directory.Exists(_AppSettings.WatchDirectory))
|
|
_ = Directory.CreateDirectory(_AppSettings.WatchDirectory);
|
|
if (!Directory.Exists(Path.GetPathRoot(_AppSettings.Destination)) || !Directory.Exists(_AppSettings.Destination))
|
|
_Logger.LogCritical("<{Destination}> Doesn't exist!", _AppSettings.Destination);
|
|
else
|
|
{
|
|
string[] files;
|
|
string checkFile;
|
|
FileInfo fileInfo;
|
|
string checkDirectory;
|
|
string[] directories = Directory.GetDirectories(_AppSettings.WatchDirectory, "*", SearchOption.TopDirectoryOnly);
|
|
foreach (string directory in directories)
|
|
{
|
|
checkDirectory = !_AppSettings.MatchPath ? _AppSettings.Destination : Path.Combine(_AppSettings.Destination, Path.GetFileName(directory));
|
|
try
|
|
{
|
|
if (!Directory.Exists(checkDirectory))
|
|
_ = Directory.CreateDirectory(checkDirectory);
|
|
files = Directory.GetFiles(directory, "*", SearchOption.TopDirectoryOnly);
|
|
foreach (string file in files)
|
|
{
|
|
fileInfo = new(file);
|
|
if (new TimeSpan(DateTime.Now.Ticks - fileInfo.LastWriteTime.Ticks).TotalMilliseconds < _AppSettings.MillisecondsDelay)
|
|
continue;
|
|
checkFile = Path.Combine(checkDirectory, Path.GetFileName(file));
|
|
if (File.Exists(checkFile))
|
|
continue;
|
|
try
|
|
{ File.Move(file, checkFile); }
|
|
catch (Exception ex)
|
|
{ _Logger.LogError(ex, "Inner loop error!"); }
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{ _Logger.LogError(ex, "Loop error!"); }
|
|
}
|
|
}
|
|
_Logger.LogInformation("B) Next execute will be at {date}", DateTime.Now.AddMilliseconds(_AppSettings.MillisecondsDelay).ToString("yyyy-MM-dd hh:mm:ss.fff tt"));
|
|
}
|
|
|
|
private async Task Body(CancellationToken stoppingToken)
|
|
{
|
|
while (_IsWindowsService && !stoppingToken.IsCancellationRequested)
|
|
{
|
|
Body();
|
|
await Task.Delay(_AppSettings.MillisecondsDelay, stoppingToken);
|
|
}
|
|
}
|
|
|
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken) =>
|
|
await Body(stoppingToken);
|
|
} |