d

taskexecutor/app/base/db/task.base.js

@@ -28,9 +28,12 @@ class TaskBase {
     //任务打点
     //key taskuptime
     let taskName = this.formatedTaskName(this.serviceName)
+    console.log(taskName, "vvvvvvvvvvvvvvvvvvvvvvvvvvvvvvv")
     if (taskName && taskName.trim() != "") {
       let nowtime = Date.now()
-      this.redisClient.hmset("taskuptime", { taskName: nowtime })
+      let tp = {}
+      tp[taskName] = nowtime
+      this.redisClient.hmset("taskuptime", tp)
     }
     //订阅任务频道
     await this.redisClient.subscribe(this.TASK_CHANNEL);

taskexecutor/app/base/db/task/monitor/monitorTask.js

@@ -12,12 +12,14 @@ class MonitorTask extends TaskBase {
    * @param {*} taskName 
    */
   formatedTaskName (taskName) {
+    console.log("formatedTaskName", "ddddddddddddddddddd")
     return taskName + "|i|10"
   }
   isFail (taskName, lastAccess) {
     let n = Date.now()
     let postMinute = (n - lastAccess) / 1000 / 60
     let tnameparams = taskName.split("|")
+    if (tnameparams.length == 3) {
       let tname = tnameparams[0].trim()
       let mtype = tnameparams[1].trim()
       let pvalue = Number(tnameparams[2].trim())
@@ -38,6 +40,11 @@ class MonitorTask extends TaskBase {
           this.sendDing(tname + "可能失联啦...请检查")
         }
       }
+
+    } else {
+      this.sendDing(taskName + ":任务名不符合监控格式")
+    }
+
   }
   async subBeforeTask (params) {
     console.log("前置操作......", this.serviceName);