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

Class SchedulerDao

java.lang.Object
ru.bitel.bgbilling.kernel.base.server.logger.BGLogger
ru.bitel.bgbilling.common.dao.AbstractDaoConstant
ru.bitel.bgbilling.kernel.task.server.dao.SchedulerDao
public class SchedulerDao extends ru.bitel.bgbilling.common.dao.AbstractDaoConstant
Менеджер по работе с БД планировщика заданий.

  • Field Summary

    Fields inherited from class ru.bitel.bgbilling.common.dao.AbstractDaoConstant

    con, ERROR, fields, moduleId, SQL_ALL, SQL_AND, SQL_DELETE, SQL_DISTINCT, SQL_EQ, SQL_EQCS, SQL_FROM, SQL_GROUP, SQL_IN, SQL_INSERT, SQL_JOIN, SQL_LEFT_JOIN, SQL_LIMIT, SQL_NOT_IN, SQL_ON, SQL_ORDER, SQL_SELECT, SQL_SET, SQL_UPDATE, SQL_VALUES, SQL_WHERE, tableName

  • Constructor Summary

    Constructors
    Constructor
    Description
    SchedulerDao(Connection con)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addTask(PackageTaskData task)
    Как следует из названия метод добавляет новую задачу планировщика в БД
    void
    deleteCurrentRunTask(int taskId)
    Удаление выполняемой задачи из очереди асинхронных задач.
    void
    deleteTask(int taskId)
    Метод удаляет данную задачу из БД.
    void
    deleteTaskLog()
     
    List<PackageTaskData>
    getPackageTasks(int componentId, boolean plugin)
    Метод возвращает список пакетных задач планировщика из БД.
    List<PeriodicTask>
    getPeriodicTaskList()
    Получение списка периодических задач, выполняемых в данный момент
    List<RunningTask>
    getRunningTaskList()
    Метод получения списка выполняемых асинхронных заданий планирощика.
    List<IdTitle>
    getTaskList()
    Метод возвращает список задач планировщика из БД.
    void
    getTaskLog(int taskId, SearchResult<SchedulerTaskLog> searchResult)
    Получение статистики по выполненным задачам планировщика с фильтрацией по задаче и периоду.
    void
    updateTask(PackageTaskData task)
    Метод обновляет данные задачи планировщика в БД.
    void
    updateTaskLog(SchedulerTaskLog taskLog)
    Добавление информации о запуске/окончании работы задачи.

    Methods inherited from class ru.bitel.bgbilling.common.dao.AbstractDaoConstant

    getPeriod, getPlaceholders, getSQLOrder, getSQLOrderFields, getTableName, psSetDate, psSetDateOrNull, psSetInt, psSetIntOrNull, psSetPeriod, psSetString, psSetStringOrNull, psSetTimestampOrNull, queryAndIn, setStatementParam, sqlDelete, sqlDeleteBatch, sqlInsert, sqlInsertBatch, sqlInsertGetId, sqlInsertGetLongId, sqlInsertOnDuplicateKeyUpdate, sqlInsertSelect, sqlInsertUpdateById, sqlSelectCountAsInt, sqlUpdate, sqlUpdateBatch

    Methods inherited from class ru.bitel.bgbilling.kernel.base.server.logger.BGLogger

    error, error, error, getLogger, logError, logError, warn

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • SchedulerDao

      public SchedulerDao(Connection con)

  • Method Details

    • getPackageTasks

      public List<PackageTaskData> getPackageTasks(int componentId, boolean plugin) throws Exception
      Метод возвращает список пакетных задач планировщика из БД.
      Parameters:
      filterModuleId - код модуля. Если 0 - ядро, число - экземпляр модуля, "p+число" - плагин
      Returns:
      отфильтрованный список задач
      Throws:
      Exception

    • getTaskList

      public List<IdTitle> getTaskList() throws SQLException
      Метод возвращает список задач планировщика из БД.
      Parameters:
      moduleId - код модуля. Если 0 - ядро, число - экземпляр модуля, "p+число" - плагин
      Returns:
      отфильтрованный список задач
      Throws:
      SQLException

    • addTask

      public void addTask(PackageTaskData task) throws SQLException
      Как следует из названия метод добавляет новую задачу планировщика в БД
      Parameters:
      task - добавляемая залача
      Throws:
      SQLException

    • updateTask

      public void updateTask(PackageTaskData task) throws SQLException
      Метод обновляет данные задачи планировщика в БД.
      Parameters:
      task - обновляемая задача
      Throws:
      SQLException

    • deleteTask

      public void deleteTask(int taskId) throws SQLException
      Метод удаляет данную задачу из БД.
      Parameters:
      taskId - удаляемая задача.
      Throws:
      SQLException - возникает, в случае ошибок,выдаваемых СУБД

    • getRunningTaskList

      public List<RunningTask> getRunningTaskList() throws ru.bitel.bgbilling.common.BGException
      Метод получения списка выполняемых асинхронных заданий планирощика.
      Returns:
      список заданий
      Throws:
      ru.bitel.bgbilling.common.BGException

    • getPeriodicTaskList

      public List<PeriodicTask> getPeriodicTaskList() throws ru.bitel.bgbilling.common.BGException
      Получение списка периодических задач, выполняемых в данный момент
      Returns:
      Throws:
      ru.bitel.bgbilling.common.BGException

    • deleteCurrentRunTask

      public void deleteCurrentRunTask(int taskId) throws SQLException
      Удаление выполняемой задачи из очереди асинхронных задач. Используется в клиентском коде.
      Parameters:
      taskId - код выполняемой задачи
      Throws:
      SQLException

    • getTaskLog

      public void getTaskLog(int taskId, SearchResult<SchedulerTaskLog> searchResult) throws ru.bitel.bgbilling.common.BGException
      Получение статистики по выполненным задачам планировщика с фильтрацией по задаче и периоду.
      Parameters:
      taskId - код задачи
      Throws:
      ru.bitel.bgbilling.common.BGException

    • updateTaskLog

      public void updateTaskLog(SchedulerTaskLog taskLog) throws ru.bitel.bgbilling.common.BGException
      Добавление информации о запуске/окончании работы задачи.
      Parameters:
      taskLog - бин с информацией по задаче.
      Throws:
      ru.bitel.bgbilling.common.BGException

    • deleteTaskLog

      public void deleteTaskLog() throws ru.bitel.bgbilling.common.BGException
      Throws:
      ru.bitel.bgbilling.common.BGException