航线断点

xieb

2024-03-22 1728457ec067a09c4a5dc8b6ab1921d7f2ad4eec

航线断点

 src/main/java/com/dji/sample/wayline/model/dto/WaylineTaskProgressExt.java

@@ -17,4 +17,9 @@
    private String flightId;

    private String trackId;

    /**
     * 航线断点信息
     */
    private WaylineTaskProgressExtBreakPoint breakPoint;
}

 src/main/java/com/dji/sample/wayline/model/dto/WaylineTaskProgressExtBreakPoint.java

New file
@@ -0,0 +1,24 @@
package com.dji.sample.wayline.model.dto;

import lombok.Data;

/**
 * @PROJECT_NAME: iot_drone_api
 * @DESCRIPTION:
 * @USER: aix
 * @DATE: 2024/3/22 14:54
 */
@Data
public class WaylineTaskProgressExtBreakPoint {

    private Integer attitudeHead;
    private Integer breakReason;
    private Integer height;
    private Integer index;
    private Integer latitude;
    private Integer longitude;
    private Integer progress;
    private Integer state;
    private Integer waylineId;

}

 src/main/java/com/dji/sample/wayline/service/impl/FlightTaskServiceImpl.java

@@ -71,6 +71,7 @@
     */
    @ServiceActivator(inputChannel = ChannelName.INBOUND_EVENTS_FLIGHT_TASK_PROGRESS, outputChannel = ChannelName.OUTBOUND_EVENTS)
    public CommonTopicReceiver handleProgress(CommonTopicReceiver receiver, MessageHeaders headers) {
        log.info("上报航线任务进度: {}", receiver.toString());
        EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.convertValue(receiver.getData(),
                new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){});
        eventsReceiver.setBid(receiver.getBid());
@@ -81,10 +82,14 @@

        WaylineTaskProgressReceiver output = eventsReceiver.getOutput();

        log.info("Task progress: {}", output.getProgress().toString());
        log.info("任务进度: {}", output.getProgress().toString());

        if (null != output.getExt().getBreakPoint()) {
            log.info("任务进度 ===> 断点信息：{}", output.getExt().getBreakPoint().toString());
        }

        if (eventsReceiver.getResult() != ResponseResult.CODE_SUCCESS) {
            log.error("Task progress ===> Error code: " + eventsReceiver.getResult());
            log.error("任务进度 ===> 错误编码: " + eventsReceiver.getResult());
        }

        EventsResultStatusEnum statusEnum = EventsResultStatusEnum.find(output.getStatus());