open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2025-07-27 14:46:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复schedule进程

Browse Source
This commit is contained in:
whyour 2021-05-04 12:10:50 +08:00
parent eb9217d46e
commit 43d5063293
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
back/schedule.ts
View File

@ -1,10 +1,13 @@
import schedule from 'node-schedule'; import schedule from 'node-schedule';
import express from 'express';
import { exec } from 'child_process'; import { exec } from 'child_process';
import Logger from './loaders/logger'; import Logger from './loaders/logger';
import { Container } from 'typedi'; import { Container } from 'typedi';
import CronService from './services/cron'; import CronService from './services/cron';
import { CrontabStatus } from './data/cron'; import { CrontabStatus } from './data/cron';
const app = express();
const run = async () => { const run = async () => {
const cronService = Container.get(CronService); const cronService = Container.get(CronService);
const cronDb = cronService.getDb(); const cronDb = cronService.getDb();
@ -36,9 +39,16 @@ const run = async () => {
}); });
}; };
run(); app
Logger.info(` .listen(5800, () => {
run();
Logger.info(`
################################################ ################################################
🛡️ 定时任务schedule启动成功 🛡️ 🛡️ Schedule listening on port: 5800 🛡️
################################################ ################################################
`); `);
})
.on('error', (err) => {
Logger.error(err);
process.exit(1);
});