Quartz.Net—基本操作

/// <summary>
/// 调度器信息
/// </summary>
/// <returns></returns>
public async Task<SchedulerMetaData> GetSchedulerI
{
    var mate = await schedu.GetMetaData();
    var json = JsonConvert.SerializeObject(mate);
    return mate;
}

/// <summary>
/// 开始schedulequetzthread开始调度
/// </summary>
/// <returns></returns>
public async Task SchedulerStart()
{
    if (!schedu.IsStarted)
    {
        await schedu.Start();
    }
}

/// <summary>
/// 关闭，关机。并清理关联的资源。
/// </summary>
/// <returns></returns>
public async Task SchedulerShutdown()
{
    if (!schedu.IsShutdown)
    {
        await schedu.Shutdown();
    }
}

/// <summary>
/// 停止
/// </summary>
/// <returns></returns>
public async Task StopScheduler()
{
    if (schedu.IsStarted)
    {
        await schedu.Standby();
    }
}

/// <summary>
/// 重启
/// </summary>
/// <returns></returns>
public async Task ResumScheduler()
{
    if (schedu.InStandbyMode)
    {
        //Standby  靠边站的，
        await schedu.Start();
    }
}

public async Task AddJob(string name, string group, string des, string dll, string typename)
{
    if (await schedu.CheckExists(new JobKey(name, group)))
    {

    }
    else
    {
        //先建立好一个job项目，然后只用创建一个实现了IJob接口的类库。在把这个类库添加到动态的添加到job项目中。
        var dllinstanck = Assembly.LoadFile(dll).CreateInstance(typename);
        IJobDetail job = JobBuilder.Create(dllinstanck.GetType()).WithIdentity(name, group).WithDescription(des).StoreDurably(true).Build();
        await schedu.AddJob(job, true);

    }
}

public async Task AddOrUpdateJob(string name, string group, string des, string dll, string typename)
{
    //StoreDurably  持久化存储
    //该工作在孤儿之后是否应该继续存储（没有触发器就是孤儿）
    var dllinstanck = Assembly.LoadFile(dll).CreateInstance(typename);
    IJobDetail job = JobBuilder.Create(dllinstanck.GetType()).WithIdentity(name, group).WithDescription(des).StoreDurably(true).Build();
    await schedu.AddJob(job, true);


    //var jobde = await schedu.GetJobDetail(new JobKey(name, group));
    //jobde.GetJobBuilder().OfType().WithDescription("sdfsdf");

}
public async Task DelJob(string name, string group)
{
    await schedu.DeleteJob(new JobKey(name, group));
}

/// <summary>
/// 停止job就是停止job关联的trigger。
/// job是没有状态的。
/// 
/// 播放器 暂停 。在开始将 接着原来的。
/// 
/// </summary>
/// <param name="name"></param>
/// <param name="group"></param>
/// <returns></returns>
public async Task SchedulerPauseJob(string name, string group)
{
    await schedu.PauseJob(new JobKey(name, group));
}

/// <summary>
/// 恢复job 和 pause相对
/// </summary>
/// <param name="name"></param>
/// <param name="group"></param>
/// <returns></returns>
public async Task SchedulerResumeJob(string name, string group)
{
    await schedu.ResumeJob(new JobKey(name, group));
}

public async Task AddTrigger(string jobName, string jobGroupName, string triggerName, string triggerGroupName, string cron, string des)
        {
            var exitTrigger = await schedu.CheckExists(new TriggerKey(triggerName, triggerGroupName));
            if (!exitTrigger)
            {
                if (await schedu.CheckExists(new JobKey(jobName, jobGroupName)))
                {
                    var trigger = TriggerBuilder.Create().WithIdentity(triggerName, triggerGroupName).WithDescription(des).WithCronSchedule(cron).ForJob(jobName, jobGroupName).Build();
                    await schedu.ScheduleJob(trigger);
                }
            }
        }

public async Task<IList<ITrigger>> GetTrrigers()
{
    List<ITrigger> triggerList = new List<ITrigger>();
    var triggerKeys = await schedu.GetTriggerKeys(GroupMatcher<TriggerKey>.AnyGroup());
    foreach (var item in triggerKeys)
    {
        var trigger = await schedu.GetTrigger(item);
        var job = await schedu.GetJobDetail(trigger.JobKey);
        var actionName = job.GetType().FullName;
        var nextTime = trigger.GetNextFireTimeUtc();
        var preTime = trigger.GetPreviousFireTimeUtc();
        var startTime = trigger.StartTimeUtc;
        triggerList.Add(trigger);
    }
    return triggerList;
}

public async Task UpdateTrigger(string triggerName, string triggerGroupName, string des)
{
    var trigger = await schedu.GetTrigger(new TriggerKey(triggerName, triggerGroupName));
    var triggerNew = TriggerBuilder.Create().WithIdentity(triggerName, triggerGroupName).WithDescription(des).ForJob(trigger.JobKey).Build();
    await schedu.RescheduleJob(trigger.Key, triggerNew);
}

public async Task PauseTrigger(string name, string group)
{
    await schedu.PauseTrigger(new TriggerKey(name, group));
}

public async Task ResumeTrigger(string name, string group)
{
    await schedu.ResumeTrigger(new TriggerKey(name, group));
}

public async Task DelTrigger(string name, string group)
{
    await schedu.UnscheduleJob(new TriggerKey(name, group));
}