zhangyuheng/MCSManager
1
0
Fork 0
forked from mirror/MCSManager
Code Pull Requests Activity

新增 - 完善计划任务辅助器

Browse Source
This commit is contained in:
suwings 2018-06-02 09:57:57 +08:00
parent ff75380386
commit 6e3aa9c6cd
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
helper/Schedule.js
View File

@ -3,7 +3,7 @@ const schedule = require("node-schedule");
MCSERVER.Schedule = {}; MCSERVER.Schedule = {};
MCSERVER.Schedule.container = {}; MCSERVER.Schedule.container = {};
//循环型任务
module.exports.createScheduleJob = (id, time, callback) => { module.exports.createScheduleJob = (id, time, callback) => {
let mask = MCSERVER.Schedule.container[id] = schedule.scheduleJob(time, (fireDate) => { let mask = MCSERVER.Schedule.container[id] = schedule.scheduleJob(time, (fireDate) => {
let res = callback(); let res = callback();
@ -13,9 +13,7 @@ module.exports.createScheduleJob = (id, time, callback) => {
}); });
} }
//计次型任务
module.exports.createScheduleJobCount = (id, time, callback, count) => { module.exports.createScheduleJobCount = (id, time, callback, count) => {
let lco = 0; let lco = 0;
let mask = MCSERVER.Schedule.container[id] = schedule.scheduleJob(time, (fireDate) => { let mask = MCSERVER.Schedule.container[id] = schedule.scheduleJob(time, (fireDate) => {
@ -29,4 +27,12 @@ module.exports.createScheduleJobCount = (id, time, callback, count) => {
mask.cancel(); mask.cancel();
} }
}); });
}
//删除
module.exports.deleteScheduleJob = (id) => {
let mask = MCSERVER.Schedule.container[id] || null;
if (mask) {
mask.cancel();
}
} }