task.js 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. const LoggerKit = require('../kit/logger-kit')
  2. const log4js = require('log4js')
  3. const TimeKit = require('../kit/time-kit')
  4. class Task {
  5. context
  6. delayTime
  7. name
  8. logger
  9. fileLogger
  10. running = true
  11. constructor(taskName, delayTime, initFun, onTickFun) {
  12. this.name = taskName
  13. this.delayTime = delayTime
  14. this.init = initFun
  15. this.onTick = onTickFun
  16. this.consoleLoggerInit()
  17. this.fileLoggerInit(this.name.concat('Task.log'))
  18. }
  19. consoleLoggerInit() {
  20. this.logger = LoggerKit.getLogger(this.name)
  21. }
  22. fileLoggerInit(logFilePath) {
  23. const logFileCategoryName = this.name.concat('FileLog')
  24. const appender = { type: 'file', filename: logFilePath }
  25. const category = { appenders: [logFileCategoryName], level: log4js.levels.TRACE }
  26. LoggerKit.pushAppender(logFileCategoryName, appender)
  27. this.fileLogger = LoggerKit.pushCategory(logFileCategoryName, category)
  28. this.fileLogger.info('File logger has init.')
  29. }
  30. async Start() {
  31. const task = this
  32. this.logger.info(`Init context or others.`)
  33. await this.init()
  34. this.logger.info(`Dida dida dida, on tick, on tick...`)
  35. while (task.running) {
  36. try {
  37. await task.onTick()
  38. } catch (e) {
  39. task.fileLogger.error(e)
  40. }
  41. await TimeKit.sleep(task.delayTime)
  42. }
  43. }
  44. async Stop() {
  45. this.running = false
  46. }
  47. }
  48. module.exports = Task