open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2025-05-29 11:19:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

更新任务运行日志

Browse Source
This commit is contained in:
whyour 2021-05-12 17:57:13 +08:00
parent f59f1bb0c4
commit 7f66e0624d
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
back/services/cron.ts
View File

@ -170,27 +170,30 @@ export default class CronService {
); );
cmd.stdout.on('data', (data) => { cmd.stdout.on('data', (data) => {
this.logger.silly(`stdout: ${data}`); this.logger.info(`stdout: ${data}`);
fs.appendFileSync(logFile, data); fs.appendFileSync(logFile, data);
}); });
cmd.stderr.on('data', (data) => { cmd.stderr.on('data', (data) => {
this.logger.error(`stderr: ${data}`); this.logger.info(`stderr: ${data}`);
fs.appendFileSync(logFile, data); fs.appendFileSync(logFile, data);
}); });
cmd.on('close', (code) => { cmd.on('close', (code) => {
this.logger.silly(`child process exited with code ${code}`); this.logger.info(`child process exited with code ${code}`);
this.cronDb.update({ _id }, { $set: { status: CrontabStatus.idle } }); this.cronDb.update(
{ _id },
{ $set: { status: CrontabStatus.idle }, $unset: { pid: true } },
);
}); });
cmd.on('error', (err) => { cmd.on('error', (err) => {
this.logger.silly(err); this.logger.info(err);
fs.appendFileSync(logFile, err.stack); fs.appendFileSync(logFile, err.stack);
}); });
cmd.on('exit', (code: number, signal: any) => { cmd.on('exit', (code: number, signal: any) => {
this.logger.silly(`cmd exit ${code}`); this.logger.info(`cmd exit ${code}`);
this.cronDb.update( this.cronDb.update(
{ _id }, { _id },
{ $set: { status: CrontabStatus.idle }, $unset: { pid: true } }, { $set: { status: CrontabStatus.idle }, $unset: { pid: true } },
@ -199,7 +202,7 @@ export default class CronService {
}); });
cmd.on('disconnect', () => { cmd.on('disconnect', () => {
this.logger.silly(`cmd disconnect`); this.logger.info(`cmd disconnect`);
this.cronDb.update({ _id }, { $set: { status: CrontabStatus.idle } }); this.cronDb.update({ _id }, { $set: { status: CrontabStatus.idle } });
fs.appendFileSync(logFile, `\n\n连接断开...`); fs.appendFileSync(logFile, `\n\n连接断开...`);
}); });