|
@@ -42,7 +42,7 @@ const taskCallback = async (context) => {
|
|
}
|
|
}
|
|
|
|
|
|
if(!cur_day_data.get(today)[timeRange.start]){
|
|
if(!cur_day_data.get(today)[timeRange.start]){
|
|
- cur_day_data.get(today)[timeRange.start] = {name:timeRange.name}
|
|
|
|
|
|
+ cur_day_data.get(today)[timeRange.start] = {name:timeRange.name,interval_minute:timeRange.interval_minute}
|
|
}
|
|
}
|
|
console.log("cur_day_data[today]:",cur_day_data.get(today),today)
|
|
console.log("cur_day_data[today]:",cur_day_data.get(today),today)
|
|
const existingRecord = await manager.getRecord(today);
|
|
const existingRecord = await manager.getRecord(today);
|
|
@@ -220,7 +220,7 @@ CMD.get_novel_material_list = async function(page,size=500) {
|
|
const now = new Date(); // 当前时间
|
|
const now = new Date(); // 当前时间
|
|
|
|
|
|
let interval_minute = 60;
|
|
let interval_minute = 60;
|
|
-
|
|
|
|
|
|
+
|
|
if(cur_timeRange!=null){
|
|
if(cur_timeRange!=null){
|
|
interval_minute = cur_timeRange.interval_minute
|
|
interval_minute = cur_timeRange.interval_minute
|
|
}
|
|
}
|
|
@@ -272,9 +272,17 @@ CMD.init = async function(){
|
|
// processTask()
|
|
// processTask()
|
|
_24HourRanges = PullDataConfig
|
|
_24HourRanges = PullDataConfig
|
|
// 定义任务回调函数
|
|
// 定义任务回调函数
|
|
|
|
+ let key = new Date().toISOString().slice(0, 10);
|
|
|
|
+ let record_res = await manager.getRecord(key);
|
|
|
|
+ if(record_res!=null){
|
|
|
|
+ if(!cur_day_data.has(key)){
|
|
|
|
+ cur_day_data.set(key,record_res.content)
|
|
|
|
+ }
|
|
|
|
+ }
|
|
// 启动调度器
|
|
// 启动调度器
|
|
CMD.startScheduler(taskCallback);
|
|
CMD.startScheduler(taskCallback);
|
|
|
|
|
|
|
|
+
|
|
})
|
|
})
|
|
}
|
|
}
|
|
|
|
|