|
@@ -30,6 +30,7 @@ ipc.on("global:refresh:done", () => {
|
|
|
|
|
|
}
|
|
}
|
|
});
|
|
});
|
|
|
|
+ crawlState = 'off'
|
|
})
|
|
})
|
|
|
|
|
|
let crawlFnSafe = async () => {
|
|
let crawlFnSafe = async () => {
|
|
@@ -38,14 +39,18 @@ let crawlFnSafe = async () => {
|
|
await crawlFn()
|
|
await crawlFn()
|
|
} catch (e) {
|
|
} catch (e) {
|
|
console.error("error on job", e)
|
|
console.error("error on job", e)
|
|
- } finally {
|
|
|
|
- crawlState = 'off'
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
-schedule.scheduleJob('0 0 3 * *', async () => {
|
|
|
|
|
|
+schedule.scheduleJob('0 3 * * *', () => {
|
|
if(crawlState === 'off'){
|
|
if(crawlState === 'off'){
|
|
- await crawlFnSafe()
|
|
|
|
|
|
+ return new Promise(async () => await crawlFnSafe())
|
|
|
|
+ } else {
|
|
|
|
+ console.log("job already running")
|
|
}
|
|
}
|
|
});
|
|
});
|
|
|
|
+
|
|
|
|
+schedule.scheduleJob('*/5 * * * *', () => {
|
|
|
|
+ console.log("service is alive")
|
|
|
|
+})
|