task.js 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. class Task {
  2. context
  3. delayTime
  4. name
  5. logger
  6. fileLogger
  7. constructor(taskName, delayTime, initFun, onTickFun, logFilePath='task.log') {
  8. this.name = taskName
  9. this.delayTime = delayTime
  10. this.init = initFun
  11. this.onTick = onTickFun
  12. this.consoleLoggerInit()
  13. this.fileLoggerInit(logFilePath)
  14. }
  15. consoleLoggerInit() {
  16. const log4js = require('log4js')
  17. this.logger = log4js.getLogger(this.name)
  18. }
  19. fileLoggerInit(logFilePath) {
  20. const log4js = require('log4js')
  21. const logFileCategoryName = this.name + 'FileLog'
  22. const appenders = {}
  23. appenders['default'] = {
  24. type: 'console'
  25. }
  26. appenders[logFileCategoryName] = {
  27. type: 'file',
  28. filename: logFilePath
  29. }
  30. const categories = {}
  31. categories['default'] = {
  32. appenders: ['default'],
  33. level: log4js.levels.TRACE
  34. }
  35. categories[logFileCategoryName] = {
  36. appenders: [logFileCategoryName],
  37. level: log4js.levels.TRACE
  38. }
  39. const config = {
  40. appenders: appenders,
  41. categories: categories
  42. }
  43. log4js.configure(config)
  44. this.fileLogger = log4js.getLogger(logFileCategoryName)
  45. this.fileLogger.level = log4js.levels.TRACE
  46. }
  47. async Start() {
  48. const task = this
  49. this.logger.info(`Init context or others.`)
  50. await this.init()
  51. this.logger.info(`Dida dida dida, on tick, on tick...`)
  52. this.interval = setInterval(async () => {
  53. try {
  54. await task.onTick()
  55. } catch (e) {
  56. task.logger.error(e)
  57. }
  58. }, this.delayTime)
  59. }
  60. async Stop() {
  61. clearInterval(this.interval)
  62. }
  63. }
  64. module.exports = Task