Bladeren bron

task name植入成功,可以更方便区分日志来源

龚成明 2 jaren geleden
bovenliggende
commit
cac209c98b
2 gewijzigde bestanden met toevoegingen van 17 en 9 verwijderingen
  1. 15 6
      libs/task.js
  2. 2 3
      scripts/monitors/price-monitor.js

+ 15 - 6
libs/task.js

@@ -1,27 +1,36 @@
-const logger = require('../kit/logger-kit')
-
 class Task {
   context
+  delayTime
+  name
+  logger
 
-  constructor(delayTime, initFun, onTickFun) {
+  constructor(taskName, delayTime, initFun, onTickFun) {
+    this.name = taskName
     this.delayTime = delayTime
 
     this.init = initFun
     this.onTick = onTickFun
+
+    this.loggerInit()
+  }
+
+  loggerInit() {
+    this.logger = require('log4js').getLogger(this.name)
+    this.logger.level = 'debug'
   }
 
   async Start() {
     const task = this
 
-    logger.info('Init context or others.')
+    this.logger.info(`Init context or others.`)
     await this.init()
 
-    logger.info('Dida dida dida, on tick, on tick...')
+    this.logger.info(`Dida dida dida, on tick, on tick...`)
     this.interval = setInterval(async () => {
       try {
         await task.onTick()
       } catch (e) {
-        logger.error(e)
+        this.logger.error(e)
       }
     }, this.delayTime)
   }

+ 2 - 3
scripts/monitors/price-monitor.js

@@ -1,10 +1,9 @@
 const OneTask = require('../../libs/one-task')
-const logger = require('../../kit/logger-kit')
 
 const onTickFun = async function() {
-  logger.info(this.context)
+  this.logger.info(this.context)
 }
 
-const priceMonitor = new OneTask(1000, OneTask.baseInit, onTickFun)
+const priceMonitor = new OneTask('PriceMonitor',1000, OneTask.baseInit, onTickFun)
 
 priceMonitor.Start()