forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
zhaowenyu
2025-11-25 91266c607c6a6292781c1dcea740d7b478718386 
 ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java


@@ -5,6 +5,8 @@


import com.ard.sample.component.mqtt.service.IMessageSenderService;


import com.ard.common.core.redis.RedisConst;


import com.ard.common.core.redis.RedisOpsUtils;


import com.ard.sample.component.websocket.enums.MessageType;


import com.ard.sample.component.websocket.handler.DockWebSocketHandler;


import com.ard.sample.component.websocket.model.BizCodeEnum;


import com.ard.sample.component.websocket.model.CustomWebSocketMessage;


import com.ard.sample.component.websocket.service.ISendMessageService;


@@ -48,6 +50,9 @@


    private ObjectMapper mapper;




    @Autowired


    private DockWebSocketHandler _dockWebSocketHandler;




    @Autowired


    private ISendMessageService websocketMessageService;




    @Autowired


@@ -66,6 +71,8 @@


                new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){});


        eventsReceiver.setBid(receiver.getBid());


        eventsReceiver.setSn(receiver.getGateway());


        eventsReceiver.setType(MessageType.STATUS.getType()+"-flighttask_progress");


        eventsReceiver.setMethod(EventsMethodEnum.FLIGHT_TASK_PROGRESS.getMethod());




        WaylineTaskProgressReceiver output = eventsReceiver.getOutput();




@@ -112,6 +119,15 @@


                        .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()


@@ -122,6 +138,7 @@


                            .data(RequestsReply.success())


                            .build());


        }




    }




    /**