Кварц .Net Работа должна перенести себя - PullRequest
1 голос
/ 20 сентября 2011

Я использую задание Quartz .NET для периодического получения данных с последовательного порта. Проблема в том, что если последовательный порт используется другой программой, задание должно быть перепланировано, чтобы попытаться повторить попытку через 30 минут. Как мне это сделать?

public virtual void Execute(JobExecutionContext context)
    { 
        SetYModemEvents();
        JobDataMap data = context.JobDetail.JobDataMap;
        string COM = data.GetString("COM");
        string BAUD = data.GetString("BAUD");
        string name = data.GetString("NAME");

        _yModem.AllowDisconnect = true;

        _connection.Port.PortName = COM;
        try
        {
            _connection.Port.BaudRate = int.Parse(BAUD);
        }catch(FormatException)
        {
            _connection.Port.BaudRate = 9600;
        }
        try
        {
            _connection.Port.Open();
        }catch(UnauthorizedAccessException ex)
        {
            //Reschedule this job

        }

        _connection.Port.DataReceived += new SerialDataReceivedEventHandler(DataReceviedHandler);
        DeadManSwitch.Tick += new EventHandler(DeadManSwitch_Tick);
        DeadManSwitch.Start();

        if(Properties.Settings.Default.UseBubbels)
        {
            ReadOutHelperClass.ShowNotifiy(name, mynotifyicon);
        }

        //Starten der Auslesung
        _connection.Write(protocoll.ReadLoggerData(), 0, protocoll.ReadLoggerData().Length);
        DeadManSwitch.Interval = DeadManTimeOut;

    }

1 Ответ

0 голосов
/ 22 сентября 2011

Я что-то пробовал.Это добавляет новую работу, которая является копией старой только что отложенной.Может быть, лучше добавить еще один триггер к существующей работе, но я не получаю его работать со вторым триггером.

public virtual void Execute(JobExecutionContext context)
    { 
        SetYModemEvents();
        JobDataMap data = context.JobDetail.JobDataMap;
        string COM = data.GetString("COM");
        string BAUD = data.GetString("BAUD");
        string name = data.GetString("NAME");

        _yModem.AllowDisconnect = true;

        _connection.Port.PortName = COM;
        try
        {
            _connection.Port.BaudRate = int.Parse(BAUD);
        }catch(FormatException)
        {
            _connection.Port.BaudRate = 9600;
        }
        try
        {
            _connection.Port.Open();
        }catch(UnauthorizedAccessException ex)
        {
            //TODO Testen
            Trigger[] trArray = context.Scheduler.GetTriggersOfJob(context.JobDetail.Name, context.JobDetail.Group);
            if (trArray.Length >= 2)
            {
                trArray.ToList().RemoveRange(1, 1);
            }
            JobDetail JB = context.JobDetail;
            Trigger delayTrigger = new SimpleTrigger(JB.Name + "_Delay", "DGroup", DateTime.UtcNow.AddMinutes(_delay), null, 1, TimeSpan.FromMinutes(_delay)); 
            JB.Name = JB.Name + "_Delay";
            JB.Group = "DGroup";

            context.Scheduler.ScheduleJob(context.JobDetail, delayTrigger);
            return;
        }


        _connection.Port.DataReceived += new SerialDataReceivedEventHandler(DataReceviedHandler);
        DeadManSwitch.Tick += new EventHandler(DeadManSwitch_Tick);
        DeadManSwitch.Start();

        if(Properties.Settings.Default.UseBubbels)
        {
            ReadOutHelperClass.ShowNotifiy(name, mynotifyicon);
        }

        //Starten der Auslesung
        _connection.Write(protocoll.ReadLoggerData(), 0, protocoll.ReadLoggerData().Length);
        DeadManSwitch.Interval = DeadManTimeOut;

    }
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...