Yuebon.NetCore/Yuebon.Quartz.Jobs/SysLogJob.cs

（开头部分） 3KB

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

using MediatR;
using Yuebon.Email.CommandHandler;

namespace Yuebon.Quartz.Jobs;

/// <summary>
/// 定时删除操作日志和任务日志
/// 
/// </summary>
public class SysLogJob : IJob
{
    private readonly ITaskManagerService iService;
    private readonly ITaskJobsLogService iJobLogService;
    private readonly ILogService iLogService;
    private IMediator _mediatR;

    public SysLogJob(ITaskManagerService iService, ITaskJobsLogService iJobLogService, ILogService iLogService, IMediator mediatR)
    {
        this.iService = iService;
        this.iJobLogService = iJobLogService;
        this.iLogService = iLogService;
        _mediatR = mediatR;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        DateTime dateTime = DateTime.Now; 
        Stopwatch stopwatch = new Stopwatch();
        stopwatch.Start();
        AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger;
        string sqlWhere = string.Format("Id='{0}' and GroupName='{1}'", trigger.Name, trigger.Group);
        TaskManager taskManager = iService.GetWhere(sqlWhere);
        if (taskManager == null)
        {
            FileQuartz.WriteErrorLog($"任务不存在");
        }
        try
        {
            string msg = $"开始时间:{dateTime.ToString("yyyy-MM-dd HH:mm:ss ffff")}";
            //记录任务执行记录
            iService.RecordRun(taskManager.Id, JobAction.开始, true, msg);
            //初始化任务日志
            FileQuartz.InitTaskJobLogPath(taskManager.Id);

            var jobId = context.MergedJobDataMap.GetString("OpenJob");
            iJobLogService.ClearLog();
            string where = "CreatorTime<'"+ DateTime.Now.AddDays(-7).ToString("yyyy-MM-dd") + "'";
            await iLogService.DeleteBatchWhereAsync(where);

            stopwatch.Stop();
            string resume = $"结束时间:{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ffff")} 共耗时{stopwatch.ElapsedMilliseconds} 毫秒\r\n";
            iService.RecordRun(taskManager.Id, JobAction.结束, true, resume);
            if ((MsgType)taskManager.SendMail == MsgType.All)
            {
                if (!string.IsNullOrEmpty(taskManager.EmailAddress))
                {
                    List<string> recipients = new List<string>();
                    recipients = taskManager.EmailAddress.Split(",").ToList();
                    var mailBodyEntity = new MailBodyEntity()
                    {
后面还有 34 行代码，解锁后查看完整代码

24 小时内免费解锁 3 个项目，之后 1 算力/个。 规则说明

AI 解读 AI

登录后可用，每次 10 算力，解读结果公开显示在下面。

还没有人解读过这个文件。