zhaowenyu
2025-12-03 b5b95f50e7905e9424628254b3cba7b92aa77cde
ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java
@@ -71,8 +71,11 @@
                new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){});
        eventsReceiver.setBid(receiver.getBid());
        eventsReceiver.setSn(receiver.getGateway());
        eventsReceiver.setGateway(receiver.getGateway());
        eventsReceiver.setType(MessageType.STATUS.getType()+"-flighttask_progress");
        eventsReceiver.setMethod(EventsMethodEnum.FLIGHT_TASK_PROGRESS.getMethod());
        WaylineTaskProgressReceiver output = eventsReceiver.getOutput();
@@ -119,15 +122,6 @@
                        .bizCode(BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode())
                        .build());
        String json="";
        try {
            json = mapper.writeValueAsString(eventsReceiver);
        }
        catch (Exception e){
            e.printStackTrace();
        }
        _dockWebSocketHandler.sendMessageToSubscribers(dockSn, MessageType.STATUS.getType() + "-flighttask_progress",json);
        if (receiver.getNeedReply()!=null &&receiver.getNeedReply() == 1) {
            messageSender.publish(receivedTopic + TopicConst._REPLY_SUF,
                    CommonTopicResponse.builder()
@@ -138,7 +132,18 @@
                            .data(RequestsReply.success())
                            .build());
        }
        // 进度
        if(eventsReceiver.getOutput().getProgress().getPercent()>=95){
            return;
        }
        String json="";
        try {
            json = mapper.writeValueAsString(eventsReceiver);
        }
        catch (Exception e){
            e.printStackTrace();
        }
        _dockWebSocketHandler.sendMessageToSubscribers(dockSn, MessageType.STATUS.getType(),json);
    }
    /**