2025-11-25 zwy rth_mode默认值1

zhaowenyu

2025-11-25 d456e429f4e1235a6a30488879d3d47f8dce44fe

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

@@ -112,7 +112,7 @@
                        .bizCode(BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode())
                        .build());

        if (receiver.getNeedReply() == 1) {
        if (receiver.getNeedReply()!=null &&receiver.getNeedReply() == 1) {
            messageSender.publish(receivedTopic + TopicConst._REPLY_SUF,
                    CommonTopicResponse.builder()
                            .tid(receiver.getTid())
@@ -124,6 +124,16 @@
        }
    }

    /**
     * 定时检查并处理航线定时任务
     * <p>
     * 该方法每5秒执行一次，从Redis有序集合中获取最早需要执行的任务，检查其执行时间：
     * 1. 若任务已过期（超过当前时间30秒），则标记为失败并删除
     * 2. 若任务在允许的时间窗口内（当前时间±30秒），则执行任务并删除
     * </p>
     *
     * <p>任务ID格式：{workspace_id}:{dock_sn}:{job_id}</p>
     */
    @Scheduled(initialDelay = 10, fixedRate = 5, timeUnit = TimeUnit.SECONDS)
    private void checkScheduledJob() {
        Object jobIdValue = RedisOpsUtils.zGetMin(RedisConst.WAYLINE_JOB_TIMED_EXECUTE);