d

taskexecutor/app/base/task.base.js

@@ -4,6 +4,7 @@ class TaskBase{
     //  this.redisClient=system.getObject("util.redisClient");
     //  this.redisClient=system.getObject("util.redisClient");
      this.serviceName=className;
      this.serviceName=className;
      this.isThrough=false;
      this.isThrough=false;
+     this.isDaemon=false;
   }
   }
   async beforeTask(params){
   async beforeTask(params){
      console.log("前置操作......",this.serviceName);
      console.log("前置操作......",this.serviceName);
@@ -16,7 +17,19 @@ class TaskBase{
       await this.beforeTask(params);
       await this.beforeTask(params);
       if(!this.isThrough){
       if(!this.isThrough){
         await this.subDoTask(params);
         await this.subDoTask(params);
+        if(this.isDaemon){
+          var http = require('http');
+          var server = http.createServer((req,res) => {
+
+            //设置 HTTP 头部，状态码是 200，文件类型是 html，字符集是 utf-8
+              res.writeHead(200,{"Content-Type":"text/html;charset='utf-8'"});
+              res.write('<h1>Node.js</h1>');
+              res.end('Hello World\\n');
+          })
+          server.listen(3000)；//监听端口号是3000的服务器
+        }
       }
       }
+      
       await this.postTask(params);
       await this.postTask(params);
       //日志记录
       //日志记录
        console.log(JSON.stringify({
        console.log(JSON.stringify({
@@ -27,6 +40,7 @@ class TaskBase{
         status:"ok"
         status:"ok"
       }));
       }));
 
 
+
     } catch (e) {
     } catch (e) {
       //日志记录
       //日志记录
       console.log(JSON.stringify({
       console.log(JSON.stringify({

taskexecutor/app/config/settings.js

 var path       = require('path');
 var path       = require('path');
+var ENVINPUT={
+  DB_HOST:process.env.DB_HOST,
+  DB_PORT:process.env.DB_PORT,
+  DB_USER:process.env.DB_USER,
+  DB_PWD:process.env.DB_PWD,
+  REDIS_HOST:process.env.REDIS_HOST,
+  REDIS_PORT:process.env.REDIS_PORT,
+  REDIS_PWD:process.env.REDIS_PWD,
+  REDIS_DB:process.env.TASK_REDIS_DB,
+  DB_NAME:process.env.TASK_DB_NAME,
+  APP_ENV:process.env.APP_ENV?process.env.APP_ENV:"dev"
+};
 var settings = {
 var settings = {
-  env:"dev",
+  env:ENVINPUT.APP_ENV,
   basepath   : path.normalize(path.join(__dirname, '../..')),
   basepath   : path.normalize(path.join(__dirname, '../..')),
-  port       : process.env.NODE_PORT || 3001,
   redis:function(){
   redis:function(){
     if(this.env=="dev"){
     if(this.env=="dev"){
       var localsettings=require("./localsettings");
       var localsettings=require("./localsettings");
       return localsettings.redis;
       return localsettings.redis;
     }else {
     }else {
       return {
       return {
-        host:"xxxxx",
-        port:xxxxx,
-        password:"xxxxx",
-        db:xx,
+        host:ENVINPUT.REDIS_HOST,
+        port:ENVINPUT.REDIS_PORT,
+        password:ENVINPUT.REDIS_PWD,
+        db:ENVINPUT.REDIS_DB,
       };
       };
     }
     }
   },
   },
   database:function(){
   database:function(){
     if(this.env=="dev"){
     if(this.env=="dev"){
       var localsettings=require("./localsettings");
       var localsettings=require("./localsettings");
-      return  localsettings.database();
+      return  localsettings.database;
     }else{
     }else{
       return {
       return {
-       dbname : "xxxxx",
-       user     : "xxxx",
-       password : "xxxxx",
+       dbname : ENVINPUT.DB_NAME,
+       user     : ENVINPUT.DB_USER,
+       password : ENVINPUT.DB_PWD,
        config   : {
        config   : {
-           host: 'xxxxxx',
+           host: ENVINPUT.DB_HOST,
            dialect: 'mysql',
            dialect: 'mysql',
            operatorsAliases: false,
            operatorsAliases: false,
            pool: {
            pool: {
@@ -45,4 +56,5 @@ var settings = {
     }
     }
   }
   }
 };
 };
+settings.ENVINPUT=ENVINPUT;
 module.exports = settings;
 module.exports = settings;

taskexecutor/main.js

@@ -5,6 +5,7 @@ var downClient=system.getObject("util.restClient");
 con=dbf.getCon();
 con=dbf.getCon();
 var taskName = process.env.TASK_NAME;
 var taskName = process.env.TASK_NAME;
 var params= process.env.TASK_PARAM;
 var params= process.env.TASK_PARAM;
+var port=process.env.TASK_PORT;
 if(taskName){
 if(taskName){
     var t=system.getObject("task.test."+taskName);
     var t=system.getObject("task.test."+taskName);
     (async()=>{
     (async()=>{