fix example

This commit is contained in:
MysticBoy
2021-02-22 00:16:20 +08:00
parent dd807a80a3
commit 1b055eb88b

View File

@@ -36,7 +36,11 @@ namespace SilkierQuartz
.StartNow() .StartNow()
.WithCronSchedule("0 0 8 1/1 * ? *") .WithCronSchedule("0 0 8 1/1 * ? *")
.Build(); .Build();
scheduler.ScheduleJob(job, trigger).Wait(); if (!scheduler.CheckExists(job.Key).GetAwaiter().GetResult())
{
scheduler.ScheduleJob(job, trigger).Wait();
}
trigger = TriggerBuilder.Create() trigger = TriggerBuilder.Create()
.WithIdentity("MonthlySales") .WithIdentity("MonthlySales")
@@ -44,7 +48,10 @@ namespace SilkierQuartz
.StartNow() .StartNow()
.WithCronSchedule("0 0 12 1 1/1 ? *") .WithCronSchedule("0 0 12 1 1/1 ? *")
.Build(); .Build();
scheduler.ScheduleJob(trigger).Wait(); ; if (!scheduler.CheckExists(trigger.Key).GetAwaiter().GetResult())
{
scheduler.ScheduleJob(trigger).Wait(); ;
}
scheduler.PauseTrigger(trigger.Key).Wait(); ; scheduler.PauseTrigger(trigger.Key).Wait(); ;
trigger = TriggerBuilder.Create() trigger = TriggerBuilder.Create()
@@ -53,7 +60,10 @@ namespace SilkierQuartz
.StartNow() .StartNow()
.WithSimpleSchedule(x => x.WithIntervalInHours(1).RepeatForever()) .WithSimpleSchedule(x => x.WithIntervalInHours(1).RepeatForever())
.Build(); .Build();
scheduler.ScheduleJob(trigger).Wait(); ; if (!scheduler.CheckExists(trigger.Key).GetAwaiter().GetResult())
{
scheduler.ScheduleJob(trigger).Wait(); ;
}
} }
Task.Run(async () => Task.Run(async () =>
{ {