2025-11-24 zwy 加日志打印，机场下发任务和通过flighttask_resource_get消息获取航线文件地址的下发参数flightT...

zhaowenyu

2025-11-24 9788a64497a78e65a03011e82cf163f68b3b3c6c

2025-11-24 zwy 加日志打印，机场下发任务和通过flighttask_resource_get消息获取航线文件地址的下发参数flightTask的值打印，看看是否有错误。

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

@@ -329,6 +329,15 @@
//                        .build())
                .build();

        // 下发参数打印
        try{
            String json = objectMapper.writeValueAsString(flightTask);
            log.info("机场下发航线任务的参数flightTask：{}", json);
        }
        catch (Exception e){
            log.error("机场下发航线任务的参数flightTask异常：{}", e.getMessage());
        }

        String topic = TopicConst.THING_MODEL_PRE + TopicConst.PRODUCT +
                waylineJob.getDockSn() + TopicConst.SERVICES_SUF;
        CommonTopicResponse<Object> response = CommonTopicResponse.builder()
@@ -340,9 +349,11 @@
                .build();

        ServiceReply serviceReply = messageSender.publishWithReply(topic, response);

        log.info("下发任务结果： {}", serviceReply.getResult());
        log.info("机场任务航线文件url地址：{}", url);
        log.info("机场任务航线文件md5值：{}", md5);

        if (ResponseResult.CODE_SUCCESS != serviceReply.getResult()) {
            log.info("Prepare task ====> Error code: {}", serviceReply.getResult());
            this.updateJob(WaylineJobDTO.builder()
@@ -699,6 +710,16 @@
            messageSender.publish(topic, builder.build());
            return;
        }

        // 下发参数打印
        try{
            String json = objectMapper.writeValueAsString(builder.build());
            log.info("机场通过flighttask_resource_get获取航线文件的参数flightTask：{}", json);
        }
        catch (Exception e){
            log.error("机场通过flighttask_resource_get获取航线文件的参数flightTask异常：{}", e.getMessage());
        }

        messageSender.publish(topic, builder.build());

    }