Quartz.NET开源作业调度框架系列(三):IJobExecutionContext 参数传递

usingSystem;
usingSystem.Threading;
usingCommon.Logging;
usingQuartz;
usingQuartz.Impl;
usingQuartz.Job;
usingQuartz.Impl.Calendar;
usingQuartz.Impl.Matchers;
namespaceQuartzDemo{
publicclassJobWithParametersExample    {
publicstringName        {
get { returnGetType().Name; }
        }
privateISchedulersched=null;
publicJobWithParametersExample(IScheduler_sched)
        {
sched=_sched;
        }
publicvirtualvoidRun()
        {
//2S后执行DateTimeOffsetstartTime=DateBuilder.NextGivenSecondDate(null, 2);
IJobDetailjob1=JobBuilder.Create<JobWithParameters>()
                .WithIdentity("job1", "group1")
                .Build();
ISimpleTriggertrigger1= (ISimpleTrigger)TriggerBuilder.Create()
                       .WithIdentity("trigger1", "group1")
                       .StartAt(startTime)
                       .WithSimpleSchedule(x=>x.WithIntervalInSeconds(5).WithRepeatCount(100))
                       .Build();
// 设置初始参数job1.JobDataMap.Put(JobWithParameters.tSQL, "SELECT * FROM [ACT_ID_USER]");
job1.JobDataMap.Put(JobWithParameters.ExecutionCount, 1);
// 设置监听器JobListenerlistener=newJobListener();
IMatcher<JobKey>matcher=KeyMatcher<JobKey>.KeyEquals(job1.Key);
sched.ListenerManager.AddJobListener(listener, matcher);
// 绑定trigger和jobsched.ScheduleJob(job1, trigger1);
//启动sched.Start();
        }
    }
}

usingSystem;
usingCommon.Logging;
usingQuartz;
usingQuartz.Impl;
usingQuartz.Job;
usingSystem.Windows.Forms;
namespaceQuartzDemo{
    [PersistJobDataAfterExecution]
    [DisallowConcurrentExecution]
publicclassJobWithParameters : IJob    {
// 定义参数常量publicconststringtSQL="tSQL";
publicconststringExecutionCount="count";
publicconststringRowCount="rowCount";
publicconststringtableAlert="tAlert";
//  Quartz 每次执行时都会重新实例化一个类, 因此Job类中的非静态变量不能存储状态信息privateintcounter=1;//都为1//private static  int counter = 1;//可以保存状态publicvirtualvoidExecute(IJobExecutionContextcontext)
        {
JobKeyjobKey=context.JobDetail.Key;
// 获取传递过来的参数JobDataMapdata=context.JobDetail.JobDataMap;
stringSQL=data.GetString(tSQL);
intcount=data.GetInt(ExecutionCount);
if (isOpen("FrmConsole"))
            {
try                {
//获取当前Form1实例__instance= (FrmConsole)Application.OpenForms["FrmConsole"];
//获取当前执行的线程ID__instance.SetInfo(jobKey+"Thread ID "+System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());
//数据库操作System.Data.DataTabletAlert=SqlHelper.getDateTable(SQL, null);
//回写条数data.Put(RowCount, tAlert.Rows.Count);
//通过方法更新消息__instance.SetInfo(string.Format("{0} exec {1} = {2} get {3} rows\r\n           execution count (from job map) is {4}\r\n           execution count (from job member variable) is {5}",
jobKey,
tSQL,
SQL,
tAlert.Rows.Count,
count, counter));
//怎么取出Datatable ? json to datatable//data.Put(tableAlert, tAlert);                }
catch (Exceptionex)
                {
Console.WriteLine(ex.Message);
                }
            }
// 修改执行计数并回写到job data map中count++;
data.Put(ExecutionCount, count);
// 修改本地变量,如果是非静态变量,不能存储状态counter++;
        }
privatestaticFrmConsole__instance=null;
/// <summary>/// 判断窗体是否打开/// </summary>/// <param name="appName"></param>/// <returns></returns>privateboolisOpen(stringappName)
        {
FormCollectioncollection=Application.OpenForms;
foreach (Formformincollection)
            {
if (form.Name==appName)
                {
returntrue;
                }
            }
returnfalse;
        }
    }
}

usingSystem;
usingCommon.Logging;
usingQuartz;
usingQuartz.Impl;
usingQuartz.Job;
namespaceQuartzDemo{
publicclassJobListener : IJobListener    {
publicvirtualstringName        {
get { return"JobListener"; }
        }
publicvirtualvoidJobToBeExecuted(IJobExecutionContextinContext)
        {
//执行前执行Console.WriteLine("JobToBeExecuted");
        }
publicvirtualvoidJobExecutionVetoed(IJobExecutionContextinContext)
        {
//否决时执行Console.WriteLine("JobExecutionVetoed");
        }
publicvirtualvoidJobWasExecuted(IJobExecutionContextinContext, JobExecutionExceptioninException)
        {
JobKeyjobKey=inContext.JobDetail.Key;
// 获取传递过来的参数JobDataMapdata=inContext.JobDetail.JobDataMap;
//获取回传的数据库表条目数introwCount=data.GetInt(JobWithParameters.RowCount);
try            {
if (rowCount>9)
                {
inContext.Scheduler.PauseAll();
System.Windows.Forms.MessageBox.Show("预警已超9条");
inContext.Scheduler.ResumeAll();
                }
Console.WriteLine(rowCount.ToString());
            }
catch (SchedulerExceptione)
            {
Console.Error.WriteLine(e.StackTrace);
            }
        }
    }
}