diff --git a/src/task/utils/time.ts b/src/task/utils/time.ts index 5c25ca8..ff03c61 100644 --- a/src/task/utils/time.ts +++ b/src/task/utils/time.ts @@ -23,7 +23,7 @@ export const getTimeDuration = () => { { start: '12:01', end: '14:00', - duration: 20 * 1000, // 20s + duration: 30 * 1000, // 30s }, { start: '14:01', @@ -32,9 +32,14 @@ export const getTimeDuration = () => { }, { start: '18:01', - end: '23:59', + end: '22:00', duration: 10 * 1000, // 10s }, + { + start: '22:01', + end: '23:59', + duration: 3 * 1000, // 3s + }, { start: '00:01', end: '03:00', diff --git a/src/task/worker.ts b/src/task/worker.ts index 86b4798..56cdf60 100644 --- a/src/task/worker.ts +++ b/src/task/worker.ts @@ -14,7 +14,7 @@ class TimeRecorder { endTime: number; duration: number; updateTime: number; - maxDuration: number = 40 * 1000; // 30s; + maxDuration: number = 30 * 1000; // 30s; constructor() { const now = Date.now(); this.startTime = now; @@ -105,6 +105,7 @@ worker.on('completed', async (job) => { const nextTime = up.nextTime + getTimeDuration(); const unread = await queue.getJob('unread'); if (!unread) { + console.log('====add unread next-time', nextTime, getTimeDuration()); addUnreadTask(nextTime); } }