OnlineUserJob.cs 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. // Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
  2. //
  3. // 本项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
  4. //
  5. // 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动!任何基于本项目二次开发而产生的一切法律纠纷和责任,我们不承担任何责任!
  6. using Furion.Logging.Extensions;
  7. namespace Admin.NET.Core;
  8. /// <summary>
  9. /// 清理在线用户作业任务
  10. /// </summary>
  11. [JobDetail("job_onlineUser", Description = "清理在线用户", GroupName = "default", Concurrent = false)]
  12. [PeriodSeconds(1, TriggerId = "trigger_onlineUser", Description = "清理在线用户", MaxNumberOfRuns = 1, RunOnStart = true)]
  13. public class OnlineUserJob : IJob
  14. {
  15. private readonly IServiceScopeFactory _scopeFactory;
  16. private readonly ILogger _logger;
  17. public OnlineUserJob(IServiceScopeFactory scopeFactory, ILoggerFactory loggerFactory)
  18. {
  19. _scopeFactory = scopeFactory;
  20. _logger = loggerFactory.CreateLogger(CommonConst.SysLogCategoryName);
  21. }
  22. public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
  23. {
  24. using var serviceScope = _scopeFactory.CreateScope();
  25. var rep = serviceScope.ServiceProvider.GetRequiredService<SqlSugarRepository<SysOnlineUser>>();
  26. await rep.CopyNew().AsDeleteable().ExecuteCommandAsync(stoppingToken);
  27. // 缓存租户列表
  28. await serviceScope.ServiceProvider.GetRequiredService<SysTenantService>().CacheTenant();
  29. string msg = $"【{DateTime.Now}】清理在线用户成功!服务已重启...";
  30. var originColor = Console.ForegroundColor;
  31. Console.ForegroundColor = ConsoleColor.Red;
  32. Console.WriteLine(msg);
  33. Console.ForegroundColor = originColor;
  34. // 自定义日志
  35. _logger.LogInformation(msg);
  36. }
  37. }