|
|
|
@ -8,10 +8,12 @@ namespace SynPlc;
|
|
|
|
|
public class Worker : BackgroundService
|
|
|
|
|
{
|
|
|
|
|
private readonly IServiceScopeFactory scopeFactory;
|
|
|
|
|
|
|
|
|
|
public Worker(IServiceScopeFactory scopeFactory)
|
|
|
|
|
private readonly IConfiguration _configuration;
|
|
|
|
|
public Worker(IServiceScopeFactory scopeFactory, IConfiguration configuration)
|
|
|
|
|
{
|
|
|
|
|
this.scopeFactory = scopeFactory;
|
|
|
|
|
_configuration = configuration;
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
|
|
|
@ -29,6 +31,7 @@ public class Worker : BackgroundService
|
|
|
|
|
|
|
|
|
|
XTrace.WriteLine("Worker running at: {0}", DateTimeOffset.Now);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await Task.Delay(1000, stoppingToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
@ -43,7 +46,6 @@ public class Worker : BackgroundService
|
|
|
|
|
// var operateResult = await S7.ConnectServerAsync();
|
|
|
|
|
// if (!operateResult.IsSuccess) XTrace.WriteLine("连接失败");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var list = await dbClient.Queryable<EEquipmentStateEntity>().ToListAsync(stoppingToken);
|
|
|
|
|
foreach (var e in list)
|
|
|
|
|
{
|
|
|
|
|