2025-12-16 zwy 优化-待执行的定时任务状态在立即任务执行时，不发送websocket消息

zhaowenyu

2025-12-16 6b6364d2afb0ccfe59b8878d3f43adc6adf3e483

 ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java

@@ -172,8 +172,11 @@
        // format: {workspace_id}:{dock_sn}:{job_id}
        String[] jobArr = String.valueOf(jobIdValue).split(RedisConst.DELIMITER);
        double time = RedisOpsUtils.zScore(RedisConst.WAYLINE_JOB_TIMED_EXECUTE, jobIdValue);
        // 取到待执行的定时任务ID，获取任务信息websocket发给前端
        // region 取定时任务信息websocket发给前端
        // 定时任务执行前，判断有没有任务正在执行，在执行则不发送websocket消息
        String key = RedisConst.WAYLINE_JOB_RUNNING_PREFIX + jobArr[0];
        if (!RedisOpsUtils.checkExist(key)) {
            // 取到待执行的定时任务ID，获取任务信息websocket发给前端
        // pending status状态待执行
        EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = new EventsReceiver<>();
        WaylineTaskProgressReceiver waylineTaskProgressReceiver = new WaylineTaskProgressReceiver();
@@ -196,6 +199,7 @@
        }
        _dockWebSocketHandler.sendMessageToSubscribers(jobArr[0], MessageType.STATUS.getType(), json, "");
        log.info("定时任务自定义状态为待执行，json: {}", json);
        }
        // endregion
        long now = System.currentTimeMillis();
        int offset = 30_000;