using Furion.DatabaseAccessor;
|
using Furion.DependencyInjection;
|
using Furion.TaskScheduler;
|
|
namespace Admin.NET.Application
|
{
|
/// <summary>
|
/// 定时任务demo
|
/// </summary>
|
public class SpareTimeDemo : ISpareTimeWorker
|
{
|
/// <summary>
|
/// 3秒后出勤统计
|
/// </summary>
|
/// <param name="timer">参数</param>
|
/// <param name="count">次数</param>
|
[SpareTime(3000, "执行Sql", DoOnce = true, StartNow = true, ExecuteType = SpareTimeExecuteTypes.Serial)]
|
public void ExecSql(SpareTimer timer, long count)
|
{
|
//创建作用域
|
Scoped.Create((factory, scope) =>
|
{
|
var start = DateTime.Now;
|
Console.WriteLine(start.ToString("yyyy-MM-dd HH:mm:ss") + ":任务开始-----------");
|
var services = scope.ServiceProvider;
|
// 数据库操作
|
var db = Db.GetSqlRepository(services);
|
if (!string.IsNullOrEmpty(timer.Description)) //假设 后台任务 中把 sql 语句写到了备注里面
|
db.SqlNonQuery(timer.Description);
|
var end = DateTime.Now;
|
Console.WriteLine(end.ToString("yyyy-MM-dd HH:mm:ss") + ":任务结束-----------");
|
Console.WriteLine($"SQL执行了：{count} 次,耗时：{(end - start).TotalMilliseconds}ms");
|
});
|
}
|
}
|
}
|
