61 lines
1.6 KiB
C#
61 lines
1.6 KiB
C#
using New_College.Common.Helper;
|
||
using New_College.IServices;
|
||
using Microsoft.Extensions.Hosting;
|
||
using System;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace New_College.Tasks
|
||
{
|
||
public class Job1TimedService : IHostedService, IDisposable
|
||
{
|
||
private Timer _timer;
|
||
private readonly IBlogArticleServices _blogArticleServices;
|
||
|
||
// 这里可以注入
|
||
public Job1TimedService(IBlogArticleServices blogArticleServices)
|
||
{
|
||
_blogArticleServices = blogArticleServices;
|
||
}
|
||
|
||
public Task StartAsync(CancellationToken cancellationToken)
|
||
{
|
||
Console.WriteLine("Job 1 is starting.");
|
||
|
||
_timer = new Timer(DoWork, null, TimeSpan.Zero,
|
||
TimeSpan.FromSeconds(60 * 60));//一个小时
|
||
|
||
return Task.CompletedTask;
|
||
}
|
||
|
||
private async void DoWork(object state)
|
||
{
|
||
try
|
||
{
|
||
var model = await _blogArticleServices.GetBlogDetails(1);
|
||
Console.WriteLine($"Job 1 启动成功，获取id=1的博客title为:{model?.btitle}");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine($"Error:{ex.Message}");
|
||
}
|
||
|
||
ConsoleHelper.WriteSuccessLine($"Job 1： {DateTime.Now}");
|
||
}
|
||
|
||
public Task StopAsync(CancellationToken cancellationToken)
|
||
{
|
||
Console.WriteLine("Job 1 is stopping.");
|
||
|
||
_timer?.Change(Timeout.Infinite, 0);
|
||
|
||
return Task.CompletedTask;
|
||
}
|
||
|
||
public void Dispose()
|
||
{
|
||
_timer?.Dispose();
|
||
}
|
||
}
|
||
}
|