job

src/jobs/jobs.js

@@ -151,8 +151,15 @@ async function confirm (job = mock, done = mock) {
 }
 
 async function mineJob (job = mock, done = mock) {
-    exec('node ./src/jobs/mine.js');
+    const rl = exec('node ./src/jobs/mine.js');
-    mylog.info('挖矿程序执行完毕');
+    rl.stderr.on('data', function (data) {
+        mylog.error('[mine]定时任务出错\n');
+        mylog.error(data);
+    });
+    rl.on('close', function (code) {
+        mylog.info('child process exited with code ' + code); // 输出到控制台
+        mylog.info('挖矿程序执行完毕');
+    });
     typeof done === 'function' && done('挖矿程序执行完毕');
 }
 

src/jobs/mine.js

@@ -34,10 +34,10 @@ const filename = 'minelog' + new Date().getFullYear() + new Date().getMonth() +
 const mylog = logger(({ root: 'minelog', file: filename }));
 
 const mongoose = require('mongoose');
-const User = require('./src/modules/user/user.model');
+const User = require('../modules/user/user.model');
-const Fund = require('./src/modules/fund/fund.model');
+const Fund = require('../modules/fund/fund.model');
-const system = require('./src/modules/system/system.model');
+const system = require('../modules/system/system.model');
-const { createAction } = require('./src/modules/action/action.handler');
+const { createAction } = require('../modules/action/action.handler');
 
 const tokenReleaseRate = 0.02;
 const inviteReward = 2.5;
@@ -180,7 +180,7 @@ async function mine (job = mock, done = mock) {
 }
 
 const start = async () => {
-    const SysConfig = require('./configSec');
+    const SysConfig = require('../../configSec');
     mongoose.set('useCreateIndex', true);
     const { DB_USER_NAME, DB_PASSWD, DB_HOST, DB_PORT, DB_NAME } = SysConfig;
     const db = mongoose.connection;