Commit e8dba35c by 泽锋 李

fix

parent 073b8734
using AutoTurnOver.DB;
using AutoTurnOver.Services;
using Microsoft.Extensions.Hosting;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace ShortagePush
{
public class FirstBackgroundService : BackgroundService
{
protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
// 每5分钟下一次首单
Task.Factory.StartNew(() => {
while (true)
{
try
{
System.Console.WriteLine($"开始下首单,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_auto_first_order_sku_dao.GeneratePurchaseAdvise();
System.Console.WriteLine($"结束下首单,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
Thread.Sleep(5 * 60 * 1000);
}
});
return Task.CompletedTask;
}
public override void Dispose()
{
base.Dispose();
}
}
}
using AutoTurnOver.Services; using AutoTurnOver.DB;
using AutoTurnOver.Services;
using Microsoft.Extensions.Hosting; using Microsoft.Extensions.Hosting;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
...@@ -14,6 +15,7 @@ namespace AutoGeneratePurchaseAdvise ...@@ -14,6 +15,7 @@ namespace AutoGeneratePurchaseAdvise
protected override Task ExecuteAsync(CancellationToken stoppingToken) protected override Task ExecuteAsync(CancellationToken stoppingToken)
{ {
_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(1)); _timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(1));
return Task.CompletedTask; return Task.CompletedTask;
} }
......
...@@ -2,6 +2,7 @@ ...@@ -2,6 +2,7 @@
using AutoTurnOver.Services; using AutoTurnOver.Services;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting; using Microsoft.Extensions.Hosting;
using ShortagePush;
using System; using System;
using System.Threading.Tasks; using System.Threading.Tasks;
...@@ -20,6 +21,7 @@ namespace AutoGeneratePurchaseAdvise ...@@ -20,6 +21,7 @@ namespace AutoGeneratePurchaseAdvise
var builder = new HostBuilder().ConfigureServices((hostContext, services) => var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
{ {
services.AddHostedService<GeneratePurchaseAdviseBackgroundService>(); services.AddHostedService<GeneratePurchaseAdviseBackgroundService>();
services.AddHostedService<FirstBackgroundService>();
}); });
await builder.RunConsoleAsync(); await builder.RunConsoleAsync();
......
...@@ -38,26 +38,6 @@ namespace ShortagePush ...@@ -38,26 +38,6 @@ namespace ShortagePush
} }
}); });
// 每5分钟下一次首单
Task.Factory.StartNew(() => {
while (true)
{
try
{
System.Console.WriteLine($"开始下首单,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_auto_first_order_sku_dao.GeneratePurchaseAdvise();
System.Console.WriteLine($"结束下首单,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
Thread.Sleep(5 * 60 * 1000);
}
});
return Task.CompletedTask; return Task.CompletedTask;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment