From ea29e2c5518ab164521d6639fd3264783bcf9e01 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8D=92?= Date: Fri, 7 Nov 2025 14:50:40 +0800 Subject: [PATCH] 1 --- .../service/impl/TencentDocBatchPushServiceImpl.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/TencentDocBatchPushServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/TencentDocBatchPushServiceImpl.java index 28d451b..082a60c 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/TencentDocBatchPushServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/TencentDocBatchPushServiceImpl.java @@ -28,7 +28,7 @@ public class TencentDocBatchPushServiceImpl implements ITencentDocBatchPushServi private RedisCache redisCache; private static final String DELAYED_PUSH_TASK_KEY = "tendoc:delayed_push:task_scheduled"; - private static final String DELAYED_PUSH_SCHEDULE_TIME_KEY = "tendoc:delayed_push:schedule_time"; + private static final String DELAYED_PUSH_SCHEDULE_TIME_KEY = "tendoc:delayed_push:next_time"; @Override public String createBatchPushRecord(String fileId, String sheetId, String pushType, @@ -122,13 +122,14 @@ public class TencentDocBatchPushServiceImpl implements ITencentDocBatchPushServi public Map getPushStatusAndCountdown() { Map result = new HashMap<>(); - // 检查是否有定时任务 - Boolean isScheduled = redisCache.getCacheObject(DELAYED_PUSH_TASK_KEY); + // 检查是否有定时任务（通过时间戳是否存在来判断） Long scheduleTime = redisCache.getCacheObject(DELAYED_PUSH_SCHEDULE_TIME_KEY); - result.put("isScheduled", isScheduled != null && isScheduled); + // 如果有推送时间戳，就认为有定时任务 + boolean isScheduled = scheduleTime != null; + result.put("isScheduled", isScheduled); - if (isScheduled != null && isScheduled && scheduleTime != null) { + if (isScheduled && scheduleTime != null) { long now = System.currentTimeMillis(); long remainingMs = scheduleTime - now;