d

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

@@ -34,13 +34,16 @@ class TaskBase{
   }
   async postTask(params){
     await this.subPostTask();
+    this.redisClient.client.quit();
+    this.redisClient.subclient.quit();
+
+
  }
   async doTask(params){
     try {
       await this.beforeTask(params);
       if(!this.isThrough){
         await this.subDoTask(params);
-        await this.postTask(params);
         if(this.isDaemon){
           var http = require('http');
           var server = http.createServer((req,res) => {
@@ -48,7 +51,10 @@ class TaskBase{
           })
           server.listen(process.env.TASK_PORT);//监听端口号是3000的服务器
           console.log("is listenning........on "+process.env.TASK_PORT);
+        }else{
+          await this.postTask(params);
         }
+      
       }
     } catch (e) {
       await  this.redisClient.unsubscribe(this.TASK_CHANNEL);

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

+const TaskBase=require("../../task.base");
+const settings=require("../../../../config/settings");
+var excel = require('exceljs');
+const system = require("../../../system");
+const fs = require('fs');
+class TestTask extends TaskBase{
+  constructor(){
+    super(TaskBase.getServiceName(TestTask));
+  }
+  async subBeforeTask(params){
+    console.log("前置操作......",this.serviceName);
+ }
+ async subDoTask(params){
+    console.log(params);
+    console.log("TestTask1.....");
+  }
+}
+module.exports=TestTask;
\ No newline at end of file

taskexecutor/app/base/utils/redisClient.js

@@ -149,6 +149,9 @@ class RedisClient {
   async incr(key) {
     return this.client.incrAsync(key);
   }
+  async close(){
+     this.client.quit();
+  }
 }
 module.exports = RedisClient;
 

taskexecutor/app/base/utils/test.js

-var excel = require('exceljs');
-async  function readxls(path) {
-  var promise = new Promise((resv, rej) => {
-      var workbook = new excel.Workbook();
-      workbook.properties.date1904 = true;
-      workbook.xlsx.readFile(path)
-          .then(function () {
-              return resv(workbook);
-          }).catch(function (e) {
-              return rej(e);
-          });
-  });
-  return promise;
-}
-(async ()=>{
-  var wb= await readxls("./GT.xlsx");
-  var sheet = wb.getWorksheet(1);
-  sheet.eachRow({ includeEmpty: true }, function(row, rowNumber) {
-    if(rowNumber>=10 && rowNumber<=10){
-      row.eachCell({ includeEmpty: true }, function(cell, colNumber) {
-        if(colNumber==28){
-          var sval=cell.value?(typeof cell.value=="object"?cell.value.result:cell.value):"0";
-          console.log(sval);
-        }
-      });
-    }
-  });
-})()
+// var excel = require('exceljs');
+// async  function readxls(path) {
+//   var promise = new Promise((resv, rej) => {
+//       var workbook = new excel.Workbook();
+//       workbook.properties.date1904 = true;
+//       workbook.xlsx.readFile(path)
+//           .then(function () {
+//               return resv(workbook);
+//           }).catch(function (e) {
+//               return rej(e);
+//           });
+//   });
+//   return promise;
+// }
+// (async ()=>{
+//   var wb= await readxls("./GT.xlsx");
+//   var sheet = wb.getWorksheet(1);
+//   sheet.eachRow({ includeEmpty: true }, function(row, rowNumber) {
+//     if(rowNumber>=10 && rowNumber<=10){
+//       row.eachCell({ includeEmpty: true }, function(cell, colNumber) {
+//         if(colNumber==28){
+//           var sval=cell.value?(typeof cell.value=="object"?cell.value.result:cell.value):"0";
+//           console.log(sval);
+//         }
+//       });
+//     }
+//   });
+// })()