d

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

@@ -6,10 +6,13 @@ class TaskPushPublicService extends TaskBase {
     super(TaskBase.getServiceName(TaskPushPublicService));
     this.restclient = system.getObject("util.restClient");
   }
-  async beforeTask (params) {
-    console.log("前置操作......", this.serviceName);
-    //this.isThrough=true; 
-    //console.log(this.cacheManager);
+  /**
+  * 每隔10分钟检查一次
+  * @param {*} taskName 
+  */
+  formatedTaskName (taskName) {
+    console.log("formatedTaskName", taskName)
+    return taskName + "|i|5"
   }
   async subDoTask () {
     console.log("--------------");