diff --git a/src/jobs/index.js b/src/jobs/index.js index 0ef4554..537e6cd 100644 --- a/src/jobs/index.js +++ b/src/jobs/index.js @@ -3,6 +3,7 @@ const { inject } = require('../common/Provider'); const Agenda = require('agenda'); const mongoose = require('mongoose'); const mountJobs = require('./jobs'); +const exec = require('child_process').exec; module.exports = () => inject(async function startJob(SysConfig) { const { DB_USER_NAME, DB_PASSWD, DB_HOST, DB_PORT, DB_NAME } = SysConfig; @@ -18,5 +19,8 @@ module.exports = () => inject(async function startJob(SysConfig) { mountJobs(Job); await Job.start(); mylog.info('任务队列启动...'); + // app.use('/admin/myAgendash', Agendash(Job)); + exec(`npx agendash --db=mongodb://${DB_USER_NAME}:${DB_PASSWD.replace('&', `\\&`)}@${DB_HOST}:${DB_PORT}/${DB_NAME} --collection=agendaJobs --port=6057`); + mylog.info('agendash启动...'); return Job; }); diff --git a/src/jobs/jobs.js b/src/jobs/jobs.js index a91a233..21d434d 100644 --- a/src/jobs/jobs.js +++ b/src/jobs/jobs.js @@ -170,7 +170,7 @@ const jobs = [ // timezone: "ETC/GMT+8" // }, { - name: 'mine', + name: 'mineCorn', processor: mineJob, type: 'every', slot: '0 0 2 * * *',