Package ru.bitel.bgbilling.kernel.task.server.bean

Class RunTaskDataManager

java.lang.Object
ru.bitel.bgbilling.kernel.task.server.bean.RunTaskDataManager
public class RunTaskDataManager extends Object

  • Constructor Details

    • RunTaskDataManager

      public RunTaskDataManager(Connection con)

  • Method Details

    • addTask

      public void addTask(RunTask task)
      Добавить задание, пишется в БД
      Parameters:
      task - объект RunTask

    • removeTask

      @Deprecated public void removeTask(int id) throws SQLException
      Deprecated.
      Использовать {@link SchedulerManager.deleteCurrentRunTask( int taskId )}
      Parameters:
      id -
      Throws:
      SQLException

    • getCurrentPeriodic

      @Deprecated public List<RunTaskDataManager.PeriodicTaskRun> getCurrentPeriodic()
      Deprecated.
      Использовать {@link SchedulerManager.getPeriodicTasks()}

    • getTaskCount

      public int getTaskCount()

    • getTasks

      @Deprecated public List<RunningTask> getTasks()
      Deprecated.
      Использовать {@link SchedulerManager.getRunningTaskList()}

    • getNextTask

      public RunTask getNextTask() throws SQLException
      Выбирает следующий (первый с минимальным id) RunTask к исполнению. Если записи следующей нет, то вернётся null. Если есть, но не смогли мы прочитать корректный объект, то запись с битым объектом удаляется и возвращается также null (и выводится в лог запись с ошибкой). Помечает задачу как начавшуюся. Старый метод, заменён методом getNextTasks.
      Returns:
      прочитанный из БД объект RunTask, или null, если нету больше в БД записей, или же при чтении текущего произошла ошибка.
      Throws:
      SQLException - ошибка БД.

    • getNextTasks

      public List<RunTask> getNextTasks() throws SQLException
      Выбирает все следующие готовые к выполнению RunTask-и. Сортировка по возрастанию id. Может вернуться пустой список (не null). Помечает вернутые задачи как начавшиеся. Поддерживает ключи задач для схлопывания (таковые удаляются из очереди) и незапуска параллельно (таковые оставляются до следующей проверки).
      Throws:
      SQLException

    • clearCurrentPeriodic

      public void clearCurrentPeriodic() throws SQLException
      Очистка таблицы с текущими запущенными задачами планировщика. Вызывается при старте таск экзекутера.
      Throws:
      SQLException

    • getTaskDataForReload

      public List<TaskData> getTaskDataForReload() throws SQLException, ru.bitel.bgbilling.common.BGException
      Все текущие задачи к исполнению(?). Вызывается при reloadTasks(). В случае, если в системе отсутствует экземпляр модуля и/или выключен плагин, то задачи этого модуля и/и плагина не учитываются
      Returns:
      список готовых объектов TaskData.
      Throws:
      SQLException - ошибка БД.
      ru.bitel.bgbilling.common.BGException